async def METHOD_NAME(self, request_context):
    registry = ProtocolRegistry()
    registry.register_message_types({TEST_MESSAGE_TYPE: object()})
    request_context.injector.bind_instance(ProtocolRegistry, registry)
    disclosures = Disclosures(
        disclosures=[
            {
                "id": DIDCommPrefix.qualify_current("basicmessage/1.0/message"),
                "feature-type": "protocol",
                "roles": [],
            },
            {"feature-type": "goal-code", "id": "aries.sell.goods.consumer"},
        ]
    )
    test_queries = [
        QueryItem(
            feature_type="protocol", match="https://didcomm.org/tictactoe/1.*"
        ),
        QueryItem(feature_type="goal-code", match="aries.*"),
    ]
    disclosures.assign_thread_id("test123")
    request_context.message = disclosures
    handler = DisclosuresHandler()
    mock_responder = MockResponder()
    with async_mock.patch.object(
        V20DiscoveryExchangeRecord,
        "retrieve_by_id",
        async_mock.CoroutineMock(side_effect=StorageNotFoundError),
    ) as mock_get_rec_thread_id, async_mock.patch.object(
        V20DiscoveryExchangeRecord,
        "retrieve_by_connection_id",
        async_mock.CoroutineMock(side_effect=StorageNotFoundError),
    ) as mock_get_rec_conn_id:
        await handler.handle(request_context, mock_responder)
        assert not mock_responder.messages