refactor(agent): rename task life cycle module

Author: suchapalaver

crates/tap-agent/src/agent.rs

@@ -45,8 +45,8 @@ use sender_accounts_manager_task::SenderAccountsManagerTask;
 use tokio::task::JoinHandle;
 
 use crate::{
-    actor_migrate::LifecycleManager, agent::sender_accounts_manager::SenderAccountsManagerMessage,
-    database, CONFIG, EIP_712_DOMAIN,
+    agent::sender_accounts_manager::SenderAccountsManagerMessage, database,
+    task_lifecycle::LifecycleManager, CONFIG, EIP_712_DOMAIN,
 };
 
 /// Actor, Arguments, State, Messages and implementation for [crate::agent::sender_account::SenderAccount]
@@ -74,7 +74,7 @@ mod test_tokio_regression;
 /// Unaggregated receipts containing total value and last id stored in the table
 pub mod unaggregated_receipts;
 
-use crate::actor_migrate::TaskHandle;
+use crate::task_lifecycle::TaskHandle;
 
 /// This is the main entrypoint for starting up tap-agent
 ///

crates/tap-agent/src/agent/sender_account_task.rs

@@ -28,7 +28,7 @@ use super::{
     unaggregated_receipts::UnaggregatedReceipts,
 };
 use crate::{
-    actor_migrate::{LifecycleManager, RestartPolicy, TaskHandle, TaskRegistry},
+    task_lifecycle::{LifecycleManager, RestartPolicy, TaskHandle, TaskRegistry},
     tracker::{SenderFeeTracker, SimpleFeeTracker},
 };
 

crates/tap-agent/src/agent/sender_accounts_manager_task.rs

@@ -28,7 +28,7 @@ use super::{
 
 #[cfg(any(test, feature = "test"))]
 use super::sender_account_task::SenderAccountTask;
-use crate::actor_migrate::{LifecycleManager, RestartPolicy, TaskHandle, TaskRegistry};
+use crate::task_lifecycle::{LifecycleManager, RestartPolicy, TaskHandle, TaskRegistry};
 
 /// Tokio task-based replacement for SenderAccountsManager actor
 pub struct SenderAccountsManagerTask;

crates/tap-agent/src/agent/sender_allocation_task.rs

@@ -19,8 +19,8 @@ use super::{
     unaggregated_receipts::UnaggregatedReceipts,
 };
 use crate::{
-    actor_migrate::{LifecycleManager, RestartPolicy, TaskHandle},
     tap::context::{NetworkVersion, TapAgentContext},
+    task_lifecycle::{LifecycleManager, RestartPolicy, TaskHandle},
 };
 use indexer_receipt::TapReceipt;
 use tap_core::{

crates/tap-agent/src/agent/test_lifecycle_monitoring.rs

@@ -8,7 +8,7 @@
 
 #[cfg(test)]
 mod tests {
-    use crate::actor_migrate::{LifecycleManager, RestartPolicy, TaskStatus};
+    use crate::task_lifecycle::{LifecycleManager, RestartPolicy, TaskStatus};
     use anyhow::Result;
     use std::time::Duration;
     use tokio::time::sleep;

crates/tap-agent/src/agent/test_tokio_migration.rs

@@ -11,11 +11,11 @@
 mod tests {
     use crate::tap::context::Legacy;
     use crate::{
-        actor_migrate::LifecycleManager,
         agent::{
             sender_account::SenderAccountConfig,
             sender_accounts_manager_task::SenderAccountsManagerTask,
         },
+        task_lifecycle::LifecycleManager,
         test::{store_receipt, CreateReceipt},
     };
     use indexer_monitor::{DeploymentDetails, SubgraphClient};

crates/tap-agent/src/agent/test_tokio_regression.rs

@@ -11,11 +11,11 @@
 mod tests {
     use crate::tap::context::Legacy;
     use crate::{
-        actor_migrate::LifecycleManager,
         agent::{
             sender_account::SenderAccountConfig,
             sender_accounts_manager_task::SenderAccountsManagerTask,
         },
+        task_lifecycle::LifecycleManager,
         test::{store_receipt, CreateReceipt},
     };
     use indexer_monitor::{DeploymentDetails, SubgraphClient};

crates/tap-agent/src/lib.rs

@@ -28,7 +28,6 @@ pub static EIP_712_DOMAIN: LazyLock<Eip712Domain> = LazyLock::new(|| {
     )
 });
 
-pub mod actor_migrate;
 pub mod adaptative_concurrency;
 pub mod agent;
 pub mod backoff;
@@ -38,6 +37,7 @@ pub mod database;
 /// Prometheus Metrics server
 pub mod metrics;
 pub mod tap;
+pub mod task_lifecycle;
 
 /// Test utils to interact with Tap Actors
 #[cfg(any(test, feature = "test"))]

crates/tap-agent/src/main.rs

@@ -1,7 +1,7 @@
 // Copyright 2023-, Edge & Node, GraphOps, and Semiotic Labs.
 // SPDX-License-Identifier: Apache-2.0
 
-use indexer_tap_agent::actor_migrate::TaskStatus;
+use indexer_tap_agent::task_lifecycle::TaskStatus;
 use indexer_tap_agent::{agent, metrics, CONFIG};
 use tokio::signal::unix::{signal, SignalKind};