Ingress proxy version

Author: danyalprout

.github/workflows/ci.yml

@@ -0,0 +1,55 @@
+name: CI
+
+on:
+  push:
+    branches: [ main, prototype ]
+  pull_request:
+    branches: [ main ]
+
+env:
+  CARGO_TERM_COLOR: always
+
+jobs:
+  check:
+    name: Check
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: dtolnay/rust-toolchain@stable
+      - run: cargo check
+
+  test:
+    name: Test
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: dtolnay/rust-toolchain@stable
+      - run: cargo test
+
+  fmt:
+    name: Rustfmt
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: dtolnay/rust-toolchain@stable
+        with:
+          components: rustfmt
+      - run: cargo fmt --all -- --check
+
+  clippy:
+    name: Clippy
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: dtolnay/rust-toolchain@stable
+        with:
+          components: clippy
+      - run: cargo clippy -- -D warnings
+
+  build:
+    name: Build
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: dtolnay/rust-toolchain@stable
+      - run: cargo build --release

.gitignore

@@ -0,0 +1,24 @@
+# Rust
+/target/
+Cargo.lock
+
+# IDE
+.idea/
+.vscode/
+*.swp
+*.swo
+
+# OS
+.DS_Store
+Thumbs.db
+
+# Logs
+*.log
+
+# Environment variables
+.env
+.env.local
+
+# Backup files
+*~
+*.bak

CLAUDE.md

@@ -0,0 +1,15 @@
+# Project: Tips - Transaction Inclusion Pipeline Services
+
+## Notes
+- Always run `just ci` before claiming a task is complete and fix any issues
+- Use `just fix` to fix formatting and warnings
+- Always add dependencies to the cargo.toml in the root and reference them in the crate cargo files
+- Use https://crates.io/ to find dependency versions when adding new deps
+
+## Project Structure
+```
+├── Cargo.toml          # Workspace configuration
+├── ingress/            # Main binary crate
+├── .github/workflows/
+│   └── ci.yml         # GitHub Actions CI
+```

Cargo.toml

@@ -0,0 +1,18 @@
+[workspace]
+members = ["crates/ingress"]
+resolver = "2"
+
+[workspace.dependencies]
+jsonrpsee = { version = "0.26", features = ["server", "macros"] }
+alloy-rpc-types-mev = "1.0.30"
+alloy-rpc-types = "1.0.30"
+alloy-primitives = "1.3.1"
+alloy-provider = "1.0.30"
+alloy-transport-http = "1.0.30"
+alloy-rpc-client = "1.0.30"
+tokio = { version = "1.47.1", features = ["full"] }
+tracing = "0.1.41"
+tracing-subscriber = "0.3.20"
+anyhow = "1.0.99"
+clap = { version = "4.5", features = ["derive", "env"] }
+url = "2.5"

crates/ingress/Cargo.toml

@@ -0,0 +1,19 @@
+[package]
+name = "ingress"
+version = "0.1.0"
+edition = "2024"
+
+[dependencies]
+jsonrpsee = { workspace = true }
+alloy-rpc-types-mev = { workspace = true }
+alloy-rpc-types = { workspace = true }
+alloy-primitives = { workspace = true }
+alloy-provider = { workspace = true }
+alloy-transport-http = { workspace = true }
+alloy-rpc-client = { workspace = true }
+tokio = { workspace = true }
+tracing = { workspace = true }
+tracing-subscriber = { workspace = true }
+anyhow = { workspace = true }
+clap = { workspace = true }
+url = { workspace = true }

crates/ingress/src/main.rs

@@ -0,0 +1,57 @@
+use alloy_provider::{ProviderBuilder, RootProvider};
+use clap::Parser;
+use jsonrpsee::server::Server;
+use std::net::IpAddr;
+use tracing::info;
+use url::Url;
+
+mod service;
+use service::{IngressApiServer, IngressService};
+
+#[derive(Parser, Debug)]
+#[command(author, version, about, long_about = None)]
+struct Config {
+    /// Address to bind the RPC server to
+    #[arg(long, env = "INGRESS_ADDRESS", default_value = "127.0.0.1")]
+    address: IpAddr,
+
+    /// Port to bind the RPC server to
+    #[arg(long, env = "INGRESS_PORT", default_value = "8080")]
+    port: u16,
+
+    /// URL of the mempool service to proxy transactions to
+    #[arg(long, env = "MEMPOOL_URL")]
+    mempool_url: Url,
+}
+
+#[tokio::main]
+async fn main() -> anyhow::Result<()> {
+    tracing_subscriber::fmt::init();
+
+    let config = Config::parse();
+    info!(
+        message = "Starting ingress service",
+        address = %config.address,
+        port = config.port,
+        mempool_url = %config.mempool_url
+    );
+
+    let provider: RootProvider = ProviderBuilder::new()
+        .disable_recommended_fillers()
+        .connect_http(config.mempool_url);
+
+    let service = IngressService::new(provider);
+    let bind_addr = format!("{}:{}", config.address, config.port);
+
+    let server = Server::builder().build(&bind_addr).await?;
+    let addr = server.local_addr()?;
+    let handle = server.start(service.into_rpc());
+
+    info!(
+        message = "Ingress RPC server started",
+        address = %addr
+    );
+
+    handle.stopped().await;
+    Ok(())
+}

crates/ingress/src/service.rs

@@ -0,0 +1,76 @@
+use alloy_primitives::{B256, Bytes};
+use alloy_provider::{Provider, RootProvider};
+use alloy_rpc_types_mev::{EthBundleHash, EthCancelBundle, EthSendBundle};
+use jsonrpsee::{
+    core::{RpcResult, async_trait},
+    proc_macros::rpc,
+    types::ErrorObjectOwned,
+};
+use tracing::warn;
+
+#[rpc(server, namespace = "eth")]
+pub trait IngressApi {
+    /// `eth_sendBundle` can be used to send your bundles to the builder.
+    #[method(name = "sendBundle")]
+    async fn send_bundle(&self, bundle: EthSendBundle) -> RpcResult<EthBundleHash>;
+
+    /// `eth_cancelBundle` is used to prevent a submitted bundle from being included on-chain.
+    #[method(name = "cancelBundle")]
+    async fn cancel_bundle(&self, request: EthCancelBundle) -> RpcResult<()>;
+
+    /// Handler for: `eth_sendRawTransaction`
+    #[method(name = "sendRawTransaction")]
+    async fn send_raw_transaction(&self, tx: Bytes) -> RpcResult<B256>;
+}
+
+pub struct IngressService {
+    provider: RootProvider,
+}
+
+impl IngressService {
+    pub fn new(provider: RootProvider) -> Self {
+        Self { provider }
+    }
+}
+
+#[async_trait]
+impl IngressApiServer for IngressService {
+    async fn send_bundle(&self, _bundle: EthSendBundle) -> RpcResult<EthBundleHash> {
+        warn!(
+            message = "TODO: implement send_bundle",
+            method = "send_bundle"
+        );
+        todo!("implement send_bundle")
+    }
+
+    async fn cancel_bundle(&self, _request: EthCancelBundle) -> RpcResult<()> {
+        warn!(
+            message = "TODO: implement cancel_bundle",
+            method = "cancel_bundle"
+        );
+        todo!("implement cancel_bundle")
+    }
+
+    async fn send_raw_transaction(&self, tx: Bytes) -> RpcResult<B256> {
+        let response = self
+            .provider
+            .send_raw_transaction(tx.iter().as_slice())
+            .await;
+
+        match response {
+            Ok(r) => Ok(*r.tx_hash()),
+            Err(e) => {
+                warn!(
+                    message = "Failed to send raw transaction to mempool",
+                    method = "send_raw_transaction",
+                    error = %e
+                );
+                Err(ErrorObjectOwned::owned(
+                    -32000,
+                    format!("Failed to send transaction: {}", e),
+                    None::<()>,
+                ))
+            }
+        }
+    }
+}

justfile

@@ -0,0 +1,37 @@
+# Run all CI checks locally
+ci: check test fmt clippy build
+
+# Check code compilation
+check:
+    cargo check
+
+# Run tests
+test:
+    cargo test
+
+# Check formatting
+fmt:
+    cargo fmt --all -- --check
+
+# Run clippy lints
+clippy:
+    cargo clippy -- -D warnings
+
+# Build release binary
+build:
+    cargo build
+
+# Run the ingress service with default mempool URL
+run:
+    cargo run -- --mempool-url http://localhost:2222
+
+# Run autofixes everything
+fix: fmt-fix clippy-fix
+
+# Format code (fix)
+fmt-fix:
+    cargo fmt --all
+
+# Run clippy with fixes
+clippy-fix:
+    cargo clippy --fix --allow-dirty --allow-staged