meld_co_issue_credential_to_alice = {'attributes': {'age': '44', 'name': 'Alice', 'speed': '10'}, 'connection_id': 'b8e36995-5202-4e91-a41c-95ad5acd75a5',...': '2024-09-18T12:46:07.816048Z', 'credential_definition_id': 'RqDUJMdAoWL9Ci5fJhEfXX:3:CL:101:RegressionTestTag', ...}
meld_co_credential_definition_id = 'RqDUJMdAoWL9Ci5fJhEfXX:3:CL:101:RegressionTestTag'
alice_member_client = <shared.util.rich_async_client.RichAsyncClient object at 0x7f15654e90d0>
meld_co_client = <shared.util.rich_async_client.RichAsyncClient object at 0x7f1565d9b2c0>
meld_co_and_alice_connection = MeldCoAliceConnect(alice_connection_id='b8e36995-5202-4e91-a41c-95ad5acd75a5', meld_co_connection_id='a421824f-a1c9-4391-921f-3618111442c8')
protocol_version = 'v2'

    @pytest.mark.anyio
    @pytest.mark.parametrize("protocol_version", ["v1", "v2"])
    @pytest.mark.parametrize(
        "meld_co_and_alice_connection", ["trust_registry", "default"], indirect=True
    )
    async def test_accept_proof_request_verifier_has_issuer_role(
        meld_co_issue_credential_to_alice: CredentialExchange,  # pylint: disable=unused-argument
        meld_co_credential_definition_id: str,
        alice_member_client: RichAsyncClient,
        meld_co_client: RichAsyncClient,
        meld_co_and_alice_connection: MeldCoAliceConnect,
        protocol_version: str,
    ):
        request_body = {
            "connection_id": meld_co_and_alice_connection.meld_co_connection_id,
            "protocol_version": protocol_version,
            "indy_proof_request": sample_indy_proof_request(
                restrictions=[{"cred_def_id": meld_co_credential_definition_id}]
            ).to_dict(),
        }
        send_proof_response = await send_proof_request(meld_co_client, request_body)
    
        meld_co_proof_id = send_proof_response["proof_id"]
    
        alice_payload = await check_webhook_state(
            client=alice_member_client,
            topic="proofs",
            state="request-received",
        )
        alice_proof_id = alice_payload["proof_id"]
    
        requested_credentials = await alice_member_client.get(
            f"{VERIFIER_BASE_PATH}/proofs/{alice_proof_id}/credentials"
        )
    
>       assert await check_webhook_state(
            client=alice_member_client,
            topic="proofs",
            state="request-received",
            filter_map={
                "proof_id": alice_proof_id,
            },
        )

app/tests/e2e/verifier/test_verifier.py:532: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
app/tests/util/webhooks.py:64: in check_webhook_state
    event = await listener.wait_for_event(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <app.tests.util.sse_listener.SseListener object at 0x7f156611b440>
field = 'proof_id', field_id = 'v2-49dbb159-7153-4902-8416-ac50c0ae1eef'
desired_state = 'request-received', timeout = Timeout(timeout=30), look_back = 1

    async def wait_for_event(
        self,
        field,
        field_id,
        desired_state,
        timeout: int = DEFAULT_LISTENER_TIMEOUT,
        look_back=1,
    ) -> Dict[str, Any]:
        """
        Start listening for SSE events. When an event is received that matches the specified parameters.
        """
        url = f"{base_url}/{self.wallet_id}/{self.topic}/{field}/{field_id}/{desired_state}"
    
        timeout = Timeout(timeout)
        async with RichAsyncClient(timeout=timeout) as client:
            async with client.stream(
                "GET", url, params={"look_back": look_back}
            ) as response:
                async for line in response.aiter_lines():
                    if line.startswith("data: "):
                        data = json.loads(line[6:])
                        return data["payload"]
                    elif line == "" or line.startswith(": ping"):
                        pass  # ignore newlines and pings
                    else:
                        logger.warning("Unexpected SSE line: {}", line)
    
>       raise SseListenerTimeout("Requested filtered event was not returned by server.")
E       app.tests.util.sse_listener.SseListenerTimeout: Requested filtered event was not returned by server.

app/tests/util/sse_listener.py:84: SseListenerTimeout