dropped eventuals

Author: taslimmuhammed

Cargo.lock

@@ -35,7 +35,7 @@ ruint = { version = "1.12.3", features = [
   "num-traits",
 ], default-features = false }
 futures-util = { version = "0.3.28", default-features = false }
-jsonrpsee = { version = "0.24.0", features = ["http-client", "tracing", "server"] }
+jsonrpsee = { version = "0.24.0", features = ["http-client", "tracing"] }
 tap_aggregator = { git = "https://github.com/semiotic-ai/timeline-aggregation-protocol", rev = "eb8447e" }
 ractor = { version = "0.13", features = [
   "async-trait",

tap-agent/Cargo.toml

@@ -14,13 +14,13 @@ use anyhow::{anyhow, bail};
 use futures::{stream, StreamExt};
 use indexer_common::escrow_accounts::EscrowAccounts;
 use indexer_common::prelude::{Allocation, SubgraphClient};
-use ractor::concurrency::JoinHandle;
 use ractor::{Actor, ActorCell, ActorProcessingErr, ActorRef, SupervisionEvent};
 use reqwest::Url;
 use serde::Deserialize;
 use sqlx::{postgres::PgListener, PgPool};
 use tokio::select;
 use tokio::sync::watch::{self, Receiver};
+use tokio::task::JoinHandle;
 use tracing::{error, warn};
 
 use prometheus::{register_counter_vec, CounterVec};

tap-agent/src/agent/sender_accounts_manager.rs

@@ -1042,7 +1042,7 @@ pub mod tests {
         .unwrap();
 
         let handle = Mutex::new(handle);
-
+        let aggregator_endpoint = "http://".to_owned() + &aggregator_endpoint.to_string();
         // Start mock GraphQL server
         let mock_server = MockServer::start().await;
 
@@ -1058,7 +1058,7 @@ pub mod tests {
             )
             .await;
 
-        (handle, aggregator_endpoint.to_string(), mock_server)
+        (handle, aggregator_endpoint, mock_server)
     }
     #[sqlx::test(migrations = "../migrations")]
     async fn should_update_unaggregated_fees_on_start(pgpool: PgPool) {
@@ -1076,7 +1076,7 @@ pub mod tests {
         // Create a sender_allocation.
         let sender_allocation = create_sender_allocation(
             pgpool.clone(),
-            "http://".to_owned() + &aggregator_endpoint.to_string(),
+            aggregator_endpoint,
             &mock_server.uri(),
             Some(sender_account),
         )
@@ -1124,7 +1124,7 @@ pub mod tests {
         // Create a sender_allocation.
         let sender_allocation = create_sender_allocation(
             pgpool.clone(),
-            "http://".to_owned() + &aggregator_endpoint.to_string(),
+            aggregator_endpoint,
             &mock_server.uri(),
             Some(sender_account),
         )
@@ -1173,7 +1173,7 @@ pub mod tests {
         // Create a sender_allocation.
         let sender_allocation = create_sender_allocation(
             pgpool.clone(),
-            "http://".to_owned() + &aggregator_endpoint.to_string(),
+            aggregator_endpoint,
             &mock_server.uri(),
             Some(sender_account),
         )
@@ -1257,7 +1257,7 @@ pub mod tests {
         // Create a sender_allocation.
         let sender_allocation = create_sender_allocation(
             pgpool.clone(),
-            "http://".to_owned() + &aggregator_endpoint.to_string(),
+            aggregator_endpoint,
             &mock_server.uri(),
             Some(sender_account),
         )
@@ -1322,7 +1322,7 @@ pub mod tests {
         // create allocation
         let sender_allocation = create_sender_allocation(
             pgpool.clone(),
-            "http://".to_owned() + &aggregator_endpoint.to_string(),
+            aggregator_endpoint,
             &mock_server.uri(),
             Some(sender_account),
         )
@@ -1445,7 +1445,7 @@ pub mod tests {
         // create allocation
         let args = create_sender_allocation_args(
             pgpool.clone(),
-            "http://".to_owned() + &aggregator_endpoint.to_string(),
+            aggregator_endpoint,
             &mock_server.uri(),
             None,
         )
@@ -1476,7 +1476,7 @@ pub mod tests {
         // create allocation
         let args = create_sender_allocation_args(
             pgpool.clone(),
-            "http://".to_owned() + &aggregator_endpoint.to_string(),
+            aggregator_endpoint,
             &mock_server.uri(),
             None,
         )
@@ -1514,7 +1514,7 @@ pub mod tests {
         // create allocation
         let args = create_sender_allocation_args(
             pgpool.clone(),
-            "http://".to_owned() + &aggregator_endpoint.to_string(),
+            aggregator_endpoint,
             &mock_server.uri(),
             None,
         )
@@ -1550,7 +1550,7 @@ pub mod tests {
         // create allocation
         let args = create_sender_allocation_args(
             pgpool.clone(),
-            "http://".to_owned() + &aggregator_endpoint.to_string(),
+            aggregator_endpoint,
             &mock_server.uri(),
             None,
         )
@@ -1590,7 +1590,7 @@ pub mod tests {
         // create allocation
         let args = create_sender_allocation_args(
             pgpool.clone(),
-            "http://".to_owned() + &aggregator_endpoint.to_string(),
+            aggregator_endpoint,
             &mock_server.uri(),
             None,
         )
@@ -1637,7 +1637,7 @@ pub mod tests {
         // create allocation
         let args = create_sender_allocation_args(
             pgpool.clone(),
-            "http://".to_owned() + &aggregator_endpoint.to_string(),
+            aggregator_endpoint,
             &mock_server.uri(),
             None,
         )
@@ -1673,7 +1673,7 @@ pub mod tests {
         // create allocation
         let sender_allocation = create_sender_allocation(
             pgpool.clone(),
-            "http://".to_owned() + &aggregator_endpoint.to_string(),
+            aggregator_endpoint,
             &mock_server.uri(),
             Some(sender_account),
         )
@@ -1752,7 +1752,7 @@ pub mod tests {
         // create allocation
         let sender_allocation = create_sender_allocation(
             pgpool.clone(),
-            "http://".to_owned() + &aggregator_endpoint.to_string(),
+            aggregator_endpoint,
             &mock_server.uri(),
             Some(sender_account),
         )