finish twmq durable execution: simple

Author: d4mr

Cargo.lock

@@ -46,6 +46,8 @@ impl<'a, C: Chain> UserOpBuilder<'a, C> {
             EntrypointVersion::V0_7 => UserOpBuilderV0_7::new(&self.config).build().await?,
         };
 
+        tracing::debug!("UserOp built, proceeding with signing");
+
         let signature = self
             .config
             .signer
@@ -60,13 +62,15 @@ impl<'a, C: Chain> UserOpBuilder<'a, C> {
 
         match &mut userop {
             UserOpVersion::V0_6(userop) => {
-                userop.signature = signature.into();
+                userop.signature = signature;
             }
             UserOpVersion::V0_7(userop) => {
-                userop.signature = signature.into();
+                userop.signature = signature;
             }
         }
 
+        tracing::debug!("UserOp signed succcessfully");
+
         Ok(userop)
     }
 }
@@ -118,7 +122,7 @@ impl<'a, C: Chain> UserOpBuilderV0_6<'a, C> {
             .await
             .map_err(|err| err.to_engine_error(self.chain))?;
 
-        tracing::info!("Gas prices determined");
+        tracing::debug!("Gas prices determined");
 
         self.userop.max_fee_per_gas = U256::from(prices.max_fee_per_gas);
         self.userop.max_priority_fee_per_gas = U256::from(prices.max_priority_fee_per_gas);
@@ -130,7 +134,7 @@ impl<'a, C: Chain> UserOpBuilderV0_6<'a, C> {
             .await
             .map_err(|err| err.to_engine_paymaster_error(self.chain))?;
 
-        tracing::info!("Deployment status determined");
+        tracing::debug!("v6 Userop paymaster and data determined");
 
         self.userop.paymaster_and_data = pm_response.paymaster_and_data;
 
@@ -143,6 +147,8 @@ impl<'a, C: Chain> UserOpBuilderV0_6<'a, C> {
                 (call_gas_limit, verification_gas_limit, pre_verification_gas)
             }
             _ => {
+                tracing::debug!("No paymaster provided gas limits, getting from bundler");
+
                 let bundler_response = self
                     .chain
                     .bundler_client()
@@ -235,7 +241,7 @@ impl<'a, C: Chain> UserOpBuilderV0_7<'a, C> {
             .await
             .map_err(|err| err.to_engine_paymaster_error(self.chain))?;
 
-        tracing::info!("v7 Userop paymaster and data determined");
+        tracing::debug!("v7 Userop paymaster and data determined");
 
         // Apply paymaster data
         self.userop.paymaster = Some(pm_response.paymaster);
@@ -260,6 +266,8 @@ impl<'a, C: Chain> UserOpBuilderV0_7<'a, C> {
             }
             _ => {
                 // If paymaster didn't provide all gas limits, get them from the bundler
+                tracing::debug!("No paymaster provided gas limits, getting from bundler");
+
                 let bundler_response = self
                     .chain
                     .bundler_client()
@@ -283,7 +291,7 @@ impl<'a, C: Chain> UserOpBuilderV0_7<'a, C> {
             }
         };
 
-        tracing::info!("Gas limits determined");
+        tracing::debug!("Gas limits determined");
 
         // Set gas limits
         self.userop.call_gas_limit = call_gas_limit;

aa-core/src/userop/builder.rs

@@ -1,3 +1,3 @@
 [workspace]
 resolver = "2"
-members = [ "aa-core", "core","server"]
+members = [ "aa-core", "core","server", "twmq"]

cargo.toml

@@ -14,3 +14,4 @@ vault-types = { version = "0.1.0", git = "ssh://git@github.com/thirdweb-dev/vaul
 vault-sdk = { version = "0.1.0", git = "ssh://git@github.com/thirdweb-dev/vault.git", branch = "main" }
 tower = "0.5.2"
 tracing = "0.1.41"
+async-nats = "0.40.0"

core/Cargo.toml

@@ -7,9 +7,7 @@ use std::collections::HashMap;
 
 use crate::userop::UserOpVersion;
 
-use super::empty_params::JsonTransformerLayer;
-
-/// Gas buffer added for managed account factories (matches TypeScript)
+// Gas buffer added for managed account factories (matches TypeScript)
 pub const MANAGED_ACCOUNT_GAS_BUFFER: U256 = U256::from_limbs([21_000, 0, 0, 0]);
 
 /// A JSON-RPC client for interacting with an ERC-4337 bundler and paymaster

core/src/executor/mod.rs

@@ -1,6 +1,5 @@
 mod bundler;
 mod paymaster;
 
-pub(crate) mod empty_params;
 pub use bundler::*;
 pub use paymaster::*;

core/src/rpc_clients/bundler.rs

@@ -0,0 +1,17 @@
+[package]
+name = "twmq"
+version = "0.1.0"
+edition = "2024"
+
+[dependencies]
+redis = { version = "0.31.0", features = ["tokio-comp", "connection-manager"] }
+nanoid = "0.4.0"
+serde = { version = "1.0.219", features = ["derive"] }
+serde_json = "1.0.140"
+tokio = "1.45.0"
+thiserror = "2.0.12"
+tracing = "0.1.41"
+tracing-subscriber = { version = "0.3.19", features = ["env-filter", "fmt"] }
+
+[dev-dependencies]
+tokio = { version = "1.45.0", features = ["full"] }

core/src/rpc_clients/empty_params.rs

@@ -0,0 +1,8 @@
+#[derive(thiserror::Error, Debug)]
+pub enum TwmqError {
+    #[error("Redis error: {0}")]
+    RedisError(#[from] redis::RedisError),
+
+    #[error("JSON Serialization error: {0}")]
+    JsonError(#[from] serde_json::Error),
+}