()
| 737 | |
| 738 | #[test(tokio::test)] |
| 739 | async fn get_events_for_interest_range() { |
| 740 | let node_id = NodeKey::random().id(); |
| 741 | let network = Network::InMemory; |
| 742 | let model = "k2t6wz4ylx0qr6v7dvbczbxqy7pqjb0879qx930c1e27gacg3r8sllonqt4xx9"; // cspell:disable-line |
| 743 | let controller = "did:key:zGs1Det7LHNeu7DXT4nvoYrPfj3n6g7d6bj2K4AMXEvg1"; |
| 744 | let stream = |
| 745 | StreamId::from_str("k2t6wz4ylx0qs435j9oi1s6469uekyk6qkxfcb21ikm5ag2g1cook14ole90aw") // cspell:disable-line |
| 746 | .unwrap(); |
| 747 | let cid = stream.cid; |
| 748 | let start = EventId::builder() |
| 749 | .with_network(&network) |
| 750 | .with_sep("model", &decode_multibase_data(model).unwrap()) |
| 751 | .with_controller(controller) |
| 752 | .with_init(&cid) |
| 753 | .with_min_event() |
| 754 | .build_fencepost(); |
| 755 | let end = EventId::builder() |
| 756 | .with_network(&network) |
| 757 | .with_sep("model", &decode_multibase_data(model).unwrap()) |
| 758 | .with_controller(controller) |
| 759 | .with_init(&stream.cid) |
| 760 | .with_max_event() |
| 761 | .build_fencepost(); |
| 762 | /* |
| 763 | l: Success(EventsGet { events: [Event { id: "fce0105ff012616e0f0c1e987ef0f772afbe2c7f05c50102bc800", data: "" }, Event { id: "fce0105ff012616e0f0c1e987ef0f772afbe2c7f05c50102bc8ff", data: "" }], resume_offset: 2, is_complete: false }) |
| 764 | r: Success(EventsGet { events: [Event { id: "fce0105ff012616e0f0c1e987ef0f772afbe2c7f05c50102bc800", data: "" }], resume_offset: 1, is_complete: false }) |
| 765 | */ |
| 766 | let mock_interest = MockAccessInterestStoreTest::new(); |
| 767 | let expected = BuildResponse::event(cid, None); |
| 768 | let mut mock_event_store = MockEventStoreTest::new(); |
| 769 | mock_event_store |
| 770 | .expect_range_with_values() |
| 771 | .with( |
| 772 | predicate::eq(start..end), |
| 773 | predicate::eq(0), |
| 774 | predicate::eq(1), |
| 775 | ) |
| 776 | .times(1) |
| 777 | .returning(move |_, _, _| Ok(vec![(cid, vec![])])); |
| 778 | let server = create_test_server( |
| 779 | node_id, |
| 780 | network, |
| 781 | mock_interest, |
| 782 | Arc::new(mock_event_store), |
| 783 | MockP2PService::new(), |
| 784 | None, |
| 785 | ); |
| 786 | let resp = server |
| 787 | .experimental_events_sep_sep_value_get( |
| 788 | "model".to_string(), |
| 789 | model.to_owned(), |
| 790 | Some(controller.to_owned()), |
| 791 | Some(stream.to_string()), |
| 792 | None, |
| 793 | Some(1), |
| 794 | &Context, |
| 795 | ) |
| 796 | .await |
nothing calls this directly
no test coverage detected