Function register_interest_sort_value

api/src/tests.rs:364–416

()

#[test(tokio::test)]
async fn register_interest_sort_value() {
    let node_id = NodeKey::random().id();
    let network = Network::InMemory;
    let model = "k2t6wz4ylx0qr6v7dvbczbxqy7pqjb0879qx930c1e27gacg3r8sllonqt4xx9"; // cspell:disable-line

    // Construct start and end event ids
    let start = EventId::builder()
        .with_network(&network)
        .with_sep("model", &decode_multibase_data(model).unwrap())
        .with_min_controller()
        .with_min_init()
        .with_min_event()
        .build_fencepost();
    let end = EventId::builder()
        .with_network(&network)
        .with_sep("model", &decode_multibase_data(model).unwrap())
        .with_max_controller()
        .with_max_init()
        .with_max_event()
        .build_fencepost();

    // Setup mock expectations
    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 interest = models::Interest {
        sep: "model".to_string(),
        sep_value: model.to_owned(),
        controller: None,
        stream_id: None,
    };
    let resp = server.interests_post(interest, &Context).await.unwrap();
    assert_eq!(resp, InterestsPostResponse::Success);
}

#[test(tokio::test)]