imp(api)!: return Result in logger and event emitter methods

.changelog/unreleased/breaking-changes/859-return-result-in-logger-event-emitter-methods.md

@@ -0,0 +1,2 @@
+- logger and event emitter methods return `Result<(), ContextError>` type.
+  ([#859](https://github.com/cosmos/ibc-rs/issues/859))

crates/ibc/src/applications/transfer/relay/send_transfer.rs

@@ -170,7 +170,7 @@ where
         send_packet_ctx_a.log_message(format!(
             "IBC fungible token transfer: {} --({})--> {}",
             msg.packet_data.sender, token, msg.packet_data.receiver
-        ));
+        ))?;
 
         let transfer_event = TransferEvent {
             sender: msg.packet_data.sender,
@@ -179,9 +179,9 @@ where
             denom: msg.packet_data.token.denom,
             memo: msg.packet_data.memo,
         };
-        send_packet_ctx_a.emit_ibc_event(ModuleEvent::from(transfer_event).into());
+        send_packet_ctx_a.emit_ibc_event(ModuleEvent::from(transfer_event).into())?;
 
-        send_packet_ctx_a.emit_ibc_event(MessageEvent::Module(MODULE_ID_STR.to_string()).into());
+        send_packet_ctx_a.emit_ibc_event(MessageEvent::Module(MODULE_ID_STR.to_string()).into())?;
     }
 
     Ok(())

crates/ibc/src/core/context.rs

@@ -356,8 +356,8 @@ pub trait ExecutionContext: ValidationContext {
     fn increase_channel_counter(&mut self) -> Result<(), ContextError>;
 
     /// Emit the given IBC event
-    fn emit_ibc_event(&mut self, event: IbcEvent);
+    fn emit_ibc_event(&mut self, event: IbcEvent) -> Result<(), ContextError>;
 
     /// Log the given message.
-    fn log_message(&mut self, message: String);
+    fn log_message(&mut self, message: String) -> Result<(), ContextError>;
 }

crates/ibc/src/core/ics02_client/handler/create_client.rs

@@ -88,12 +88,12 @@ where
         client_type,
         latest_height,
     ));
-    ctx.emit_ibc_event(IbcEvent::Message(MessageEvent::Client));
-    ctx.emit_ibc_event(event);
+    ctx.emit_ibc_event(IbcEvent::Message(MessageEvent::Client))?;
+    ctx.emit_ibc_event(event)?;
 
     ctx.log_message(format!(
         "success: generated new client identifier: {client_id}"
-    ));
+    ))?;
 
     Ok(())
 }

crates/ibc/src/core/ics02_client/handler/update_client.rs

@@ -79,8 +79,8 @@ where
             client_id,
             client_state.client_type(),
         ));
-        ctx.emit_ibc_event(IbcEvent::Message(MessageEvent::Client));
-        ctx.emit_ibc_event(event);
+        ctx.emit_ibc_event(IbcEvent::Message(MessageEvent::Client))?;
+        ctx.emit_ibc_event(event)?;
     } else {
         if !matches!(update_kind, UpdateKind::UpdateClient) {
             return Err(ClientError::MisbehaviourHandlingFailure {
@@ -122,8 +122,8 @@ where
                     header.encode_to_vec(),
                 ))
             };
-            ctx.emit_ibc_event(IbcEvent::Message(MessageEvent::Client));
-            ctx.emit_ibc_event(event);
+            ctx.emit_ibc_event(IbcEvent::Message(MessageEvent::Client))?;
+            ctx.emit_ibc_event(event)?;
         }
     }
 

crates/ibc/src/core/ics02_client/handler/upgrade_client.rs

@@ -76,8 +76,8 @@ where
         old_client_state.client_type(),
         latest_height,
     ));
-    ctx.emit_ibc_event(IbcEvent::Message(MessageEvent::Client));
-    ctx.emit_ibc_event(event);
+    ctx.emit_ibc_event(IbcEvent::Message(MessageEvent::Client))?;
+    ctx.emit_ibc_event(event)?;
 
     Ok(())
 }

crates/ibc/src/core/ics03_connection/handler/conn_open_ack.rs

@@ -157,10 +157,10 @@ where
         msg.conn_id_on_b.clone(),
         vars.client_id_on_b().clone(),
     ));
-    ctx_a.emit_ibc_event(IbcEvent::Message(MessageEvent::Connection));
-    ctx_a.emit_ibc_event(event);
+    ctx_a.emit_ibc_event(IbcEvent::Message(MessageEvent::Connection))?;
+    ctx_a.emit_ibc_event(event)?;
 
-    ctx_a.log_message("success: conn_open_ack verification passed".to_string());
+    ctx_a.log_message("success: conn_open_ack verification passed".to_string())?;
 
     {
         let new_conn_end_on_a = {

crates/ibc/src/core/ics03_connection/handler/conn_open_confirm.rs

@@ -117,9 +117,9 @@ where
         conn_id_on_a.clone(),
         client_id_on_a.clone(),
     ));
-    ctx_b.emit_ibc_event(IbcEvent::Message(MessageEvent::Connection));
-    ctx_b.emit_ibc_event(event);
-    ctx_b.log_message("success: conn_open_confirm verification passed".to_string());
+    ctx_b.emit_ibc_event(IbcEvent::Message(MessageEvent::Connection))?;
+    ctx_b.emit_ibc_event(event)?;
+    ctx_b.log_message("success: conn_open_confirm verification passed".to_string())?;
 
     {
         let new_conn_end_on_b = {

crates/ibc/src/core/ics03_connection/handler/conn_open_init.rs

@@ -63,7 +63,7 @@ where
 
     ctx_a.log_message(format!(
         "success: conn_open_init: generated new connection identifier: {conn_id_on_a}"
-    ));
+    ))?;
 
     {
         let client_id_on_b = msg.counterparty.client_id().clone();
@@ -73,8 +73,8 @@ where
             msg.client_id_on_a.clone(),
             client_id_on_b,
         ));
-        ctx_a.emit_ibc_event(IbcEvent::Message(MessageEvent::Connection));
-        ctx_a.emit_ibc_event(event);
+        ctx_a.emit_ibc_event(IbcEvent::Message(MessageEvent::Connection))?;
+        ctx_a.emit_ibc_event(event)?;
     }
 
     ctx_a.increase_connection_counter()?;

crates/ibc/src/core/ics03_connection/handler/conn_open_try.rs

@@ -156,9 +156,9 @@ where
         conn_id_on_a.clone(),
         vars.client_id_on_a.clone(),
     ));
-    ctx_b.emit_ibc_event(IbcEvent::Message(MessageEvent::Connection));
-    ctx_b.emit_ibc_event(event);
-    ctx_b.log_message("success: conn_open_try verification passed".to_string());
+    ctx_b.emit_ibc_event(IbcEvent::Message(MessageEvent::Connection))?;
+    ctx_b.emit_ibc_event(event)?;
+    ctx_b.log_message("success: conn_open_try verification passed".to_string())?;
 
     ctx_b.increase_connection_counter()?;
     ctx_b.store_connection_to_client(

crates/ibc/src/core/ics04_channel/context.rs

@@ -103,10 +103,10 @@ pub trait SendPacketExecutionContext: SendPacketValidationContext {
     ) -> Result<(), ContextError>;
 
     /// Ibc events
-    fn emit_ibc_event(&mut self, event: IbcEvent);
+    fn emit_ibc_event(&mut self, event: IbcEvent) -> Result<(), ContextError>;
 
     /// Logging facility
-    fn log_message(&mut self, message: String);
+    fn log_message(&mut self, message: String) -> Result<(), ContextError>;
 }
 
 impl<T> SendPacketExecutionContext for T
@@ -129,11 +129,11 @@ where
         self.store_packet_commitment(commitment_path, commitment)
     }
 
-    fn emit_ibc_event(&mut self, event: IbcEvent) {
+    fn emit_ibc_event(&mut self, event: IbcEvent) -> Result<(), ContextError> {
         self.emit_ibc_event(event)
     }
 
-    fn log_message(&mut self, message: String) {
+    fn log_message(&mut self, message: String) -> Result<(), ContextError> {
         self.log_message(message)
     }
 }

crates/ibc/src/core/ics04_channel/handler/acknowledgement.rs

@@ -50,8 +50,8 @@ where
         chan_end_on_a.ordering,
         conn_id_on_a.clone(),
     ));
-    ctx_a.emit_ibc_event(IbcEvent::Message(MessageEvent::Channel));
-    ctx_a.emit_ibc_event(event);
+    ctx_a.emit_ibc_event(IbcEvent::Message(MessageEvent::Channel))?;
+    ctx_a.emit_ibc_event(event)?;
 
     let commitment_path_on_a = CommitmentPath::new(
         &msg.packet.port_id_on_a,
@@ -93,16 +93,16 @@ where
 
     // emit events and logs
     {
-        ctx_a.log_message("success: packet acknowledgement".to_string());
+        ctx_a.log_message("success: packet acknowledgement".to_string())?;
 
         // Note: Acknowledgement event was emitted at the beginning
 
         for module_event in extras.events {
-            ctx_a.emit_ibc_event(IbcEvent::Module(module_event));
+            ctx_a.emit_ibc_event(IbcEvent::Module(module_event))?
         }
 
         for log_message in extras.log {
-            ctx_a.log_message(log_message);
+            ctx_a.log_message(log_message)?;
         }
     }
 

crates/ibc/src/core/ics04_channel/handler/chan_close_confirm.rs

@@ -55,7 +55,7 @@ where
 
     // emit events and logs
     {
-        ctx_b.log_message("success: channel close confirm".to_string());
+        ctx_b.log_message("success: channel close confirm".to_string())?;
 
         let core_event = {
             let port_id_on_a = chan_end_on_b.counterparty().port_id.clone();
@@ -78,15 +78,15 @@ where
                 conn_id_on_b,
             ))
         };
-        ctx_b.emit_ibc_event(IbcEvent::Message(MessageEvent::Channel));
-        ctx_b.emit_ibc_event(core_event);
+        ctx_b.emit_ibc_event(IbcEvent::Message(MessageEvent::Channel))?;
+        ctx_b.emit_ibc_event(core_event)?;
 
         for module_event in extras.events {
-            ctx_b.emit_ibc_event(IbcEvent::Module(module_event));
+            ctx_b.emit_ibc_event(IbcEvent::Module(module_event))?;
         }
 
         for log_message in extras.log {
-            ctx_b.log_message(log_message);
+            ctx_b.log_message(log_message)?;
         }
     }
 

crates/ibc/src/core/ics04_channel/handler/chan_close_init.rs

@@ -52,7 +52,7 @@ where
 
     // emit events and logs
     {
-        ctx_a.log_message("success: channel close init".to_string());
+        ctx_a.log_message("success: channel close init".to_string())?;
 
         let core_event = {
             let port_id_on_b = chan_end_on_a.counterparty().port_id.clone();
@@ -75,15 +75,15 @@ where
                 conn_id_on_a,
             ))
         };
-        ctx_a.emit_ibc_event(IbcEvent::Message(MessageEvent::Channel));
-        ctx_a.emit_ibc_event(core_event);
+        ctx_a.emit_ibc_event(IbcEvent::Message(MessageEvent::Channel))?;
+        ctx_a.emit_ibc_event(core_event)?;
 
         for module_event in extras.events {
-            ctx_a.emit_ibc_event(IbcEvent::Module(module_event));
+            ctx_a.emit_ibc_event(IbcEvent::Module(module_event))?;
         }
 
         for log_message in extras.log {
-            ctx_a.log_message(log_message);
+            ctx_a.log_message(log_message)?;
         }
     }
 

crates/ibc/src/core/ics04_channel/handler/chan_open_ack.rs

@@ -60,7 +60,7 @@ where
 
     // emit events and logs
     {
-        ctx_a.log_message("success: channel open ack".to_string());
+        ctx_a.log_message("success: channel open ack".to_string())?;
 
         let core_event = {
             let port_id_on_b = chan_end_on_a.counterparty().port_id.clone();
@@ -74,15 +74,15 @@ where
                 conn_id_on_a,
             ))
         };
-        ctx_a.emit_ibc_event(IbcEvent::Message(MessageEvent::Channel));
-        ctx_a.emit_ibc_event(core_event);
+        ctx_a.emit_ibc_event(IbcEvent::Message(MessageEvent::Channel))?;
+        ctx_a.emit_ibc_event(core_event)?;
 
         for module_event in extras.events {
-            ctx_a.emit_ibc_event(IbcEvent::Module(module_event));
+            ctx_a.emit_ibc_event(IbcEvent::Module(module_event))?;
         }
 
         for log_message in extras.log {
-            ctx_a.log_message(log_message);
+            ctx_a.log_message(log_message)?;
         }
     }
 

crates/ibc/src/core/ics04_channel/handler/chan_open_confirm.rs

@@ -56,7 +56,7 @@ where
 
     // emit events and logs
     {
-        ctx_b.log_message("success: channel open confirm".to_string());
+        ctx_b.log_message("success: channel open confirm".to_string())?;
 
         let conn_id_on_b = chan_end_on_b.connection_hops[0].clone();
         let port_id_on_a = chan_end_on_b.counterparty().port_id.clone();
@@ -77,15 +77,15 @@ where
             chan_id_on_a,
             conn_id_on_b,
         ));
-        ctx_b.emit_ibc_event(IbcEvent::Message(MessageEvent::Channel));
-        ctx_b.emit_ibc_event(core_event);
+        ctx_b.emit_ibc_event(IbcEvent::Message(MessageEvent::Channel))?;
+        ctx_b.emit_ibc_event(core_event)?;
 
         for module_event in extras.events {
-            ctx_b.emit_ibc_event(IbcEvent::Module(module_event));
+            ctx_b.emit_ibc_event(IbcEvent::Module(module_event))?;
         }
 
         for log_message in extras.log {
-            ctx_b.log_message(log_message);
+            ctx_b.log_message(log_message)?;
         }
     }
 

crates/ibc/src/core/ics04_channel/handler/chan_open_init.rs

@@ -84,23 +84,23 @@ where
     {
         ctx_a.log_message(format!(
             "success: channel open init with channel identifier: {chan_id_on_a}"
-        ));
+        ))?;
         let core_event = IbcEvent::OpenInitChannel(OpenInit::new(
             msg.port_id_on_a.clone(),
             chan_id_on_a.clone(),
             msg.port_id_on_b,
             conn_id_on_a,
             version,
         ));
-        ctx_a.emit_ibc_event(IbcEvent::Message(MessageEvent::Channel));
-        ctx_a.emit_ibc_event(core_event);
+        ctx_a.emit_ibc_event(IbcEvent::Message(MessageEvent::Channel))?;
+        ctx_a.emit_ibc_event(core_event)?;
 
         for module_event in extras.events {
-            ctx_a.emit_ibc_event(IbcEvent::Module(module_event));
+            ctx_a.emit_ibc_event(IbcEvent::Module(module_event))?;
         }
 
         for log_message in extras.log {
-            ctx_a.log_message(log_message);
+            ctx_a.log_message(log_message)?;
         }
     }
 

crates/ibc/src/core/ics04_channel/handler/chan_open_try.rs

@@ -92,7 +92,7 @@ where
     {
         ctx_b.log_message(format!(
             "success: channel open try with channel identifier: {chan_id_on_b}"
-        ));
+        ))?;
 
         let core_event = IbcEvent::OpenTryChannel(OpenTry::new(
             msg.port_id_on_b.clone(),
@@ -102,15 +102,15 @@ where
             conn_id_on_b,
             version,
         ));
-        ctx_b.emit_ibc_event(IbcEvent::Message(MessageEvent::Channel));
-        ctx_b.emit_ibc_event(core_event);
+        ctx_b.emit_ibc_event(IbcEvent::Message(MessageEvent::Channel))?;
+        ctx_b.emit_ibc_event(core_event)?;
 
         for module_event in extras.events {
-            ctx_b.emit_ibc_event(IbcEvent::Module(module_event));
+            ctx_b.emit_ibc_event(IbcEvent::Module(module_event))?;
         }
 
         for log_message in extras.log {
-            ctx_b.log_message(log_message);
+            ctx_b.log_message(log_message)?;
         }
     }