fix(tap-agent): handle manager error (#192)

Signed-off-by: Gustavo Inacio <[email protected]>

Author: gusinacio

tap-agent/src/agent/sender_account.rs

@@ -495,9 +495,16 @@ impl Actor for SenderAccount {
             SenderAccountMessage::UpdateAllocationIds(allocation_ids) => {
                 // Create new sender allocations
                 for allocation_id in allocation_ids.difference(&state.allocation_ids) {
-                    state
+                    if let Err(error) = state
                         .create_sender_allocation(myself.clone(), *allocation_id)
-                        .await?;
+                        .await
+                    {
+                        error!(
+                            %error,
+                            %allocation_id,
+                            "There was an error while creating Sender Allocation."
+                        );
+                    }
                 }
 
                 // Remove sender allocations
@@ -627,9 +634,16 @@ impl Actor for SenderAccount {
                     return Ok(());
                 };
 
-                state
+                if let Err(error) = state
                     .create_sender_allocation(myself.clone(), allocation_id)
-                    .await?;
+                    .await
+                {
+                    error!(
+                        %error,
+                        %allocation_id,
+                        "Error while recreating Sender Allocation."
+                    );
+                }
             }
             _ => {}
         }

tap-agent/src/agent/sender_accounts_manager.rs

@@ -190,9 +190,16 @@ impl Actor for SenderAccountsManager {
             SenderAccountsManagerMessage::UpdateSenderAccounts(target_senders) => {
                 // Create new sender accounts
                 for sender in target_senders.difference(&state.sender_ids) {
-                    state
+                    if let Err(e) = state
                         .create_sender_account(myself.get_cell(), *sender, HashSet::new())
-                        .await?;
+                        .await
+                    {
+                        error!(
+                            sender_address = %sender,
+                            error = %e,
+                            "There was an error while creating a sender account."
+                        );
+                    }
                 }
 
                 // Remove sender accounts
@@ -255,9 +262,16 @@ impl Actor for SenderAccountsManager {
                     .remove(&sender_id)
                     .unwrap_or(HashSet::new());
 
-                state
+                if let Err(e) = state
                     .create_sender_account(myself.get_cell(), sender_id, allocations)
-                    .await?;
+                    .await
+                {
+                    error!(
+                        error = %e,
+                        sender_address = %sender_id,
+                        "There was an error while re-creating sender account."
+                    );
+                }
             }
             _ => {}
         }