EOA Production Readiness

executors/src/eoa/events.rs

@@ -0,0 +1,119 @@
+use std::fmt::Display;
+
+use engine_core::error::EngineError;
+use serde::{Deserialize, Serialize};
+use twmq::job::RequeuePosition;
+
+use crate::{
+    eoa::{
+        store::{SubmittedTransaction, TransactionData},
+        worker::ConfirmedTransactionWithRichReceipt,
+    },
+    webhook::envelope::{
+        BareWebhookNotificationEnvelope, SerializableNackData, SerializableSuccessData, StageEvent,
+    },
+};
+
+pub struct EoaExecutorEvent {
+    pub transaction_data: TransactionData,
+}
+
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub struct EoaSendAttemptNackData {
+    pub nonce: u64,
+    pub error: EngineError,
+}
+
+#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
+pub enum EoaExecutorStage {
+    SendAttempt,
+    SendAttemptNack,
+    TransactionReplaced,
+    TransactionConfirmed,
+}
+
+impl Display for EoaExecutorStage {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        match self {
+            EoaExecutorStage::SendAttempt => write!(f, "send_attempt"),
+            EoaExecutorStage::SendAttemptNack => write!(f, "send_attempt_nack"),
+            EoaExecutorStage::TransactionReplaced => write!(f, "transaction_replaced"),
+            EoaExecutorStage::TransactionConfirmed => write!(f, "transaction_confirmed"),
+        }
+    }
+}
+
+const EXECUTOR_NAME: &str = "eoa";
+
+impl EoaExecutorEvent {
+    pub fn send_attempt_success_envelopes(
+        &self,
+        submitted_transaction: SubmittedTransaction,
+    ) -> BareWebhookNotificationEnvelope<SerializableSuccessData<SubmittedTransaction>> {
+        BareWebhookNotificationEnvelope {
+            transaction_id: self.transaction_data.transaction_id.clone(),
+            executor_name: EXECUTOR_NAME.to_string(),
+            stage_name: EoaExecutorStage::SendAttempt.to_string(),
+            event_type: StageEvent::Success,
+            payload: SerializableSuccessData {
+                result: submitted_transaction.clone(),
+            },
+        }
+    }
+
+    pub fn send_attempt_nack_envelopes(
+        &self,
+        nonce: u64,
+        error: EngineError,
+        attempt_number: u32,
+    ) -> BareWebhookNotificationEnvelope<SerializableNackData<EoaSendAttemptNackData>> {
+        BareWebhookNotificationEnvelope {
+            transaction_id: self.transaction_data.transaction_id.clone(),
+            executor_name: EXECUTOR_NAME.to_string(),
+            stage_name: EoaExecutorStage::SendAttemptNack.to_string(),
+            event_type: StageEvent::Nack,
+            payload: SerializableNackData {
+                error: EoaSendAttemptNackData {
+                    nonce,
+                    error: error.clone(),
+                },
+                delay_ms: None,
+                position: RequeuePosition::Last,
+                attempt_number,
+                max_attempts: None,
+                next_retry_at: None,
+            },
+        }
+    }
+
+    pub fn transaction_replaced_envelopes(
+        &self,
+        replaced_transaction: SubmittedTransaction,
+    ) -> BareWebhookNotificationEnvelope<SerializableSuccessData<SubmittedTransaction>> {
+        BareWebhookNotificationEnvelope {
+            transaction_id: self.transaction_data.transaction_id.clone(),
+            executor_name: EXECUTOR_NAME.to_string(),
+            stage_name: EoaExecutorStage::TransactionReplaced.to_string(),
+            event_type: StageEvent::Success,
+            payload: SerializableSuccessData {
+                result: replaced_transaction.clone(),
+            },
+        }
+    }
+
+    pub fn transaction_confirmed_envelopes(
+        &self,
+        confirmed_transaction: ConfirmedTransactionWithRichReceipt,
+    ) -> BareWebhookNotificationEnvelope<SerializableSuccessData<ConfirmedTransactionWithRichReceipt>>
+    {
+        BareWebhookNotificationEnvelope {
+            transaction_id: self.transaction_data.transaction_id.clone(),
+            executor_name: EXECUTOR_NAME.to_string(),
+            stage_name: EoaExecutorStage::TransactionConfirmed.to_string(),
+            event_type: StageEvent::Success,
+            payload: SerializableSuccessData {
+                result: confirmed_transaction.clone(),
+            },
+        }
+    }
+}

executors/src/eoa/mod.rs

@@ -1,6 +1,8 @@
 pub mod error_classifier;
+pub mod events;
 pub mod store;
 pub mod worker;
+
 pub use error_classifier::{EoaErrorMapper, EoaExecutionError, RecoveryStrategy};
 pub use store::{EoaExecutorStore, EoaTransactionRequest};
 pub use worker::{EoaExecutorWorker, EoaExecutorWorkerJobData};