()
| 643 | } |
| 644 | #[test(tokio::test)] |
| 645 | async fn get_interests_for_peer() { |
| 646 | let peer_id_a = |
| 647 | PeerId::from_str("12D3KooWRyGSRzzEBpHbHyRkGTgCpXuoRMQgYrqk7tFQzM3AFEWp").unwrap(); |
| 648 | let node_id_b = NodeId::try_from_peer_id( |
| 649 | &PeerId::from_str("12D3KooWR1M8JiXyfdBKUhCLUmTJGhtNsgxnhvFVD4AU4EioDUwu").unwrap(), |
| 650 | ) |
| 651 | .unwrap(); |
| 652 | let network = Network::InMemory; |
| 653 | let model = "k2t6wz4ylx0qr6v7dvbczbxqy7pqjb0879qx930c1e27gacg3r8sllonqt4xx9"; // cspell:disable-line |
| 654 | let controller = "did:key:zGs1Det7LHNeu7DXT4nvoYrPfj3n6g7d6bj2K4AMXEvg1"; |
| 655 | let stream = |
| 656 | StreamId::from_str("k2t6wz4ylx0qs435j9oi1s6469uekyk6qkxfcb21ikm5ag2g1cook14ole90aw") // cspell:disable-line |
| 657 | .unwrap(); |
| 658 | let start = EventId::builder() |
| 659 | .with_network(&network) |
| 660 | .with_sep("model", &decode_multibase_data(model).unwrap()) |
| 661 | .with_controller(controller) |
| 662 | .with_init(&stream.cid) |
| 663 | .with_min_event() |
| 664 | .build_fencepost(); |
| 665 | let end = EventId::builder() |
| 666 | .with_network(&network) |
| 667 | .with_sep("model", &decode_multibase_data(model).unwrap()) |
| 668 | .with_controller(controller) |
| 669 | .with_init(&stream.cid) |
| 670 | .with_max_event() |
| 671 | .build_fencepost(); |
| 672 | let mut mock_interest = MockAccessInterestStoreTest::new(); |
| 673 | mock_interest |
| 674 | .expect_range() |
| 675 | .with( |
| 676 | predicate::eq(Interest::min_value()), |
| 677 | predicate::eq(Interest::max_value()), |
| 678 | ) |
| 679 | .once() |
| 680 | .return_once(move |_, _| { |
| 681 | Ok(vec![ |
| 682 | Interest::builder() |
| 683 | .with_sep_key("model") |
| 684 | .with_peer_id(&peer_id_a) |
| 685 | .with_range((start.as_slice(), end.as_slice())) |
| 686 | .with_not_after(0) |
| 687 | .build(), |
| 688 | Interest::builder() |
| 689 | .with_sep_key("model") |
| 690 | .with_peer_id(&peer_id_a) |
| 691 | .with_range((start.as_slice(), end.as_slice())) |
| 692 | .with_not_after(1) |
| 693 | .build(), |
| 694 | Interest::builder() |
| 695 | .with_sep_key("model") |
| 696 | .with_peer_id(&node_id_b.peer_id()) |
| 697 | .with_range((start.as_slice(), end.as_slice())) |
| 698 | .with_not_after(0) |
| 699 | .build(), |
| 700 | Interest::builder() |
| 701 | .with_sep_key("model") |
| 702 | .with_peer_id(&node_id_b.peer_id()) |
nothing calls this directly
no test coverage detected