Function get_interests

api/src/tests.rs:566–643

()

#[test(tokio::test)]
async fn get_interests() {
    let node_id = NodeId::try_from_peer_id(
        &PeerId::from_str("12D3KooWRyGSRzzEBpHbHyRkGTgCpXuoRMQgYrqk7tFQzM3AFEWp").unwrap(),
    )
    .unwrap();
    let network = Network::InMemory;
    let model = "k2t6wz4ylx0qr6v7dvbczbxqy7pqjb0879qx930c1e27gacg3r8sllonqt4xx9"; // cspell:disable-line
    let controller = "did:key:zGs1Det7LHNeu7DXT4nvoYrPfj3n6g7d6bj2K4AMXEvg1";
    let stream =
        StreamId::from_str("k2t6wz4ylx0qs435j9oi1s6469uekyk6qkxfcb21ikm5ag2g1cook14ole90aw") // cspell:disable-line
            .unwrap();
    let start = EventId::builder()
        .with_network(&network)
        .with_sep("model", &decode_multibase_data(model).unwrap())
        .with_controller(controller)
        .with_init(&stream.cid)
        .with_min_event()
        .build_fencepost();
    let end = EventId::builder()
        .with_network(&network)
        .with_sep("model", &decode_multibase_data(model).unwrap())
        .with_controller(controller)
        .with_init(&stream.cid)
        .with_max_event()
        .build_fencepost();
    let mut mock_interest = MockAccessInterestStoreTest::new();
    mock_interest
        .expect_range()
        .with(
            predicate::eq(Interest::min_value()),
            predicate::eq(Interest::max_value()),
        )
        .once()
        .return_once(move |_, _| {
            Ok(vec![
                Interest::builder()
                    .with_sep_key("model")
                    .with_peer_id(&node_id.peer_id())
                    .with_range((start.as_slice(), end.as_slice()))
                    .with_not_after(0)
                    .build(),
                Interest::builder()
                    .with_sep_key("model")
                    .with_peer_id(&node_id.peer_id())
                    .with_range((start.as_slice(), end.as_slice()))
                    .with_not_after(1)
                    .build(),
            ])
        });

    let mock_event_store = MockEventStoreTest::new();
    let server = create_test_server(
        node_id,
        network,
        mock_interest,
        Arc::new(mock_event_store),
        MockP2PService::new(),
        None,