WIP

Cargo.toml

@@ -76,6 +76,7 @@ tokio = { version = "1.17", features = [
 ] }
 tracing = "0.1"
 tracing-futures = "0.2"
+tx-sitter-client = { path = "crates/tx-sitter-client" }
 url = { version = "2.2", features = ["serde"] }
 # `ethers-rs` requires an older version of primitive-types.
 # But `ruint` supports the latest version. So we need to override it.

crates/tx-sitter/Cargo.toml → crates/tx-sitter-client/Cargo.toml

@@ -1,5 +1,5 @@
 [package]
-name = "tx-sitter"
+name = "tx-sitter-client"
 version = "0.1.0"
 edition = "2021"
 publish = false

src/ethereum/write_oz/mod.rs

@@ -10,6 +10,7 @@ use tracing::{info, warn};
 use self::inner::Inner;
 use self::openzeppelin::OzRelay;
 use self::options::ParsedOptions;
+use self::tx_sitter::TxSitter;
 use super::write::TransactionId;
 use super::{ReadProvider, TxError};
 
@@ -44,7 +45,9 @@ impl WriteProvider {
 
         let inner: Arc<dyn Inner> = match options {
             ParsedOptions::Oz(oz_options) => Arc::new(OzRelay::new(&oz_options).await?),
-            ParsedOptions::TxSitter(tx_sitter_options) => todo!(),
+            ParsedOptions::TxSitter(tx_sitter_options) => {
+                Arc::new(TxSitter::new(&tx_sitter_options.tx_sitter_url))
+            }
         };
 
         Ok(Self {

src/ethereum/write_oz/tx_sitter.rs

@@ -1,12 +1,23 @@
+use anyhow::Context;
 use async_trait::async_trait;
 use ethers::types::transaction::eip2718::TypedTransaction;
+use tx_sitter_client::data::SendTxRequest;
+use tx_sitter_client::TxSitterClient;
 
 use super::inner::{Inner, TransactionResult};
 use crate::ethereum::write::TransactionId;
 use crate::ethereum::TxError;
 
 pub struct TxSitter {
-    url: String,
+    client: TxSitterClient,
+}
+
+impl TxSitter {
+    pub fn new(url: impl ToString) -> Self {
+        Self {
+            client: TxSitterClient::new(url),
+        }
+    }
 }
 
 #[async_trait]
@@ -16,6 +27,15 @@ impl Inner for TxSitter {
         tx: TypedTransaction,
         only_once: bool,
     ) -> Result<TransactionId, TxError> {
+        let x = self.client.send_tx(&SendTxRequest {
+            to: *tx.to_addr().context("Tx receiver must be an address")?,
+            value:     *tx.value().context("Missing tx value")?,
+            data:      todo!(),
+            gas_limit: todo!(),
+            priority:  todo!(),
+            tx_id:     todo!(),
+        }).await.unwrap();
+
         todo!()
     }