()
| 94 | |
| 95 | #[tokio::test] |
| 96 | async fn test_process_extra_interests_empty() { |
| 97 | let pool = SqlitePool::connect_in_memory().await.unwrap(); |
| 98 | let interest_svc = Arc::new(InterestService::new(pool)); |
| 99 | let network = Network::InMemory; |
| 100 | let node_key = ceramic_core::NodeKey::random(); |
| 101 | let node_id = node_key.id(); |
| 102 | |
| 103 | // Test with empty interests |
| 104 | let result = process_extra_interests(&[], &interest_svc, &network, &node_id).await; |
| 105 | assert!(result.is_ok()); |
| 106 | } |
| 107 | |
| 108 | #[tokio::test] |
| 109 | async fn test_process_extra_interests_invalid_stream_id() { |
nothing calls this directly
no test coverage detected