async def METHOD_NAME(self):
    handler, responder = MediationGrantHandler(), MockResponder()
    await MediationRecord(connection_id=TEST_CONN_ID).save(self.session)
    await handler.handle(self.context, responder)
    record = await MediationRecord.retrieve_by_connection_id(
        self.session, TEST_CONN_ID
    )
    assert record
    assert record.state == MediationRecord.STATE_GRANTED
    assert record.endpoint == TEST_ENDPOINT
    assert record.routing_keys == [TEST_RECORD_VERKEY]