Function register_interest_value_controller_stream

api/src/tests.rs:508–563

()

#[test(tokio::test)]

async fn register_interest_value_controller_stream() {
    let node_id = NodeKey::random().id();
    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_insert()
        .with(predicate::eq(
            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(),
        ))
        .times(1)
        .returning(|__| Ok(true));
    let mock_event_store = MockEventStoreTest::new();
    let server = create_test_server(
        node_id,
        network,
        mock_interest,
        Arc::new(mock_event_store),
        MockP2PService::new(),
        None,
    );
    let resp = server
        .interests_sort_key_sort_value_post(
            "model".to_string(),
            model.to_owned(),
            Some(controller.to_owned()),
            Some(stream.to_string()),
            &Context,
        )
        .await
        .unwrap();
    assert_eq!(resp, InterestsSortKeySortValuePostResponse::Success);
}

#[test(tokio::test)]