Function run_ws

fendermint/eth/api/examples/ethers.rs:726–765

The WebSocket interface provides JSON-RPC request/response interactions as well as subscriptions, both using messages over the socket. We subscribe to notifications first, then run the same suite of request/responses as the HTTP case, finally check that we have collected events over the subscriptions.

(mut provider: Provider<Ws>, opts: &Options)

/// We subscribe to notifications first, then run the same suite of request/responses
/// as the HTTP case, finally check that we have collected events over the subscriptions.
async fn run_ws(mut provider: Provider<Ws>, opts: &Options) -> anyhow::Result<()> {
    tracing::info!("Running the tests over WS...");
    adjust_provider(&mut provider);

    // Subscriptions as well.
    let subs = if FILTERS_ENABLED {
        let block_sub = provider.subscribe_blocks().await?;
        let txs_sub = provider.subscribe_pending_txs().await?;
        let log_sub = provider.subscribe_logs(&Filter::default()).await?;
        Some((block_sub, txs_sub, log_sub))
    } else {
        None
    };

    run(&provider, opts).await?;

    if let Some((mut block_sub, mut txs_sub, mut log_sub)) = subs {
        assert!(block_sub.next().await.is_some(), "blocks should arrive");
        assert!(txs_sub.next().await.is_some(), "transactions should arrive");
        assert!(log_sub.next().await.is_some(), "logs should arrive");

        block_sub
            .unsubscribe()
            .await
            .context("failed to unsubscribe blocks")?;

        txs_sub
            .unsubscribe()
            .await
            .context("failed to unsubscribe txs")?;

        log_sub
            .unsubscribe()
            .await
            .context("failed to unsubscribe logs")?;
    }

    tracing::info!("WS tests finished.");
    Ok(())
}

async fn make_transfer<C>(
    mw: &TestMiddleware<C>,