refactor: Simplify Task types

Author: snawaz

magicblock-committor-service/README.md

@@ -23,18 +23,18 @@ IntentExecutor - responsible for execution of Intent. Calls  **TransactionPrepar
 TransactionPreparator - is an entity that handles all of the above "Transaction preparation" calling **TaskBuilderV1**,  **TaskStrategist**, **DeliveryPreparator** and then assempling it all and passing to **MessageExecutor**
 
 ## DeliveryPreparator
-After our **BaseTask**s are ready we need to prepare eveything for their successful execution. **DeliveryPreparator** - handles ALTs and commit buffers
+After our **DlpTask**s are ready we need to prepare eveything for their successful execution. **DeliveryPreparator** - handles ALTs and commit buffers
 
 ## TaskBuilder
 First, lets build atomic tasks from scheduled message/intent.
 
-High level: TaskBuilder responsible for creating BaseTasks(to be renamed...) from ScheduledBaseIntent(to be renamed...).
+High level: TaskBuilder responsible for creating DlpTasks(to be renamed...) from ScheduledBaseIntent(to be renamed...).
 Details: To do that is requires additional information from DelegationMetadata, it is provided **CommitIdFetcher**
 
-### BaseTask
-High level: BaseTask - is an atomic operation that is to be performed on the Base layer, like: Commit, Undelegate, Finalize, Action.
+### DlpTask
+High level: DlpTask - is an atomic operation that is to be performed on the Base layer, like: Commit, Undelegate, Finalize, Action.
 
-Details: There's to implementation of BaseTask: ArgsTask, BufferTask. ArgsTask - gives instruction using args. BufferTask - gives instruction using buffer. BufferTask at the moment supports only commits
+Details: There's to implementation of DlpTask: ArgsTask, BufferTask. ArgsTask - gives instruction using args. BufferTask - gives instruction using buffer. BufferTask at the moment supports only commits
 
 ### TaskInfoFetcher
 High level: for account to be accepted by `dlp` it needs to have incremental commit ids. TaskInfoFetcher provides a user with the correct ids/nonces for set of committees

magicblock-committor-service/src/intent_executor/error.rs

@@ -11,8 +11,8 @@ use solana_sdk::{
 
 use crate::{
     tasks::{
-        task_builder::TaskBuilderError, task_strategist::TaskStrategistError,
-        BaseTask, TaskType,
+        dlp_task::DlpTask, task_builder::TaskBuilderError,
+        task_strategist::TaskStrategistError, TaskType,
     },
     transaction_preparator::error::TransactionPreparatorError,
 };
@@ -138,7 +138,7 @@ impl TransactionStrategyExecutionError {
     pub fn try_from_transaction_error(
         err: TransactionError,
         signature: Option<Signature>,
-        tasks: &[Box<dyn BaseTask>],
+        tasks: &[DlpTask],
     ) -> Result<Self, TransactionError> {
         // There's always 2 budget instructions in front
         const OFFSET: u8 = 2;
@@ -196,7 +196,7 @@ impl TransactionStrategyExecutionError {
 }
 
 pub(crate) struct IntentTransactionErrorMapper<'a> {
-    pub tasks: &'a [Box<dyn BaseTask>],
+    pub tasks: &'a [DlpTask],
 }
 impl TransactionErrorMapper for IntentTransactionErrorMapper<'_> {
     type ExecutionError = TransactionStrategyExecutionError;

magicblock-committor-service/src/intent_executor/mod.rs

@@ -43,12 +43,13 @@ use crate::{
     },
     persist::{CommitStatus, CommitStatusSignatures, IntentPersister},
     tasks::{
+        dlp_task::DlpTask,
         task_builder::{TaskBuilderError, TaskBuilderImpl, TasksBuilder},
         task_strategist::{
             TaskStrategist, TaskStrategistError, TransactionStrategy,
         },
         task_visitors::utility_visitor::TaskVisitorUtils,
-        BaseTask, TaskType,
+        TaskType,
     },
     transaction_preparator::{
         error::TransactionPreparatorError, TransactionPreparator,
@@ -122,8 +123,8 @@ where
     /// Checks if it is possible to unite Commit & Finalize stages in 1 transaction
     /// Returns corresponding `TransactionStrategy` if possible, otherwise `None`
     fn try_unite_tasks<P: IntentPersister>(
-        commit_tasks: &[Box<dyn BaseTask>],
-        finalize_task: &[Box<dyn BaseTask>],
+        commit_tasks: &[DlpTask],
+        finalize_task: &[DlpTask],
         authority: &Pubkey,
         persister: &Option<P>,
     ) -> Result<Option<TransactionStrategy>, SignerError> {
@@ -621,7 +622,7 @@ where
     async fn execute_message_with_retries(
         &self,
         prepared_message: VersionedMessage,
-        tasks: &[Box<dyn BaseTask>],
+        tasks: &[DlpTask],
     ) -> IntentExecutorResult<Signature, TransactionStrategyExecutionError>
     {
         struct IntentErrorMapper<TxMap> {