Add GitHub actions

.github/CI.yml

@@ -0,0 +1,25 @@
+on: [push]
+
+name: CI
+
+jobs:
+  build_and_test:
+    name: Rust project
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v2
+      - uses: actions-rs/toolchain@v1
+        with:
+          toolchain: stable
+          components: rustfmt, clippy
+      - name: Setup
+        run: |
+          make fetch-thirdparty
+      - name: Lint
+        run: |
+          make lint
+      - name: Test
+        run: |
+          make cargo-test
+
+

.gitignore

@@ -1,2 +1,3 @@
 # Rust
-/target
+/target
+.local

Makefile

@@ -13,6 +13,10 @@ run-create-wallet:
 cargo-fmt:
 	cargo fmt --all
 
+lint:
+	cargo fmt --all -- --check
+	cargo clippy -- -D warnings -A clippy::derive_partial_eq_without_eq
+
 cargo-test:
 	cargo test 
 

bin/bundler-rpc.rs

@@ -2,7 +2,6 @@ use anyhow::Result;
 use clap::Parser;
 use jsonrpsee::{core::server::rpc_module::Methods, server::ServerBuilder, tracing::info};
 use std::future::pending;
-use tracing_subscriber;
 
 use aa_bundler::rpc::{eth::EthApiServerImpl, eth_api::EthApiServer};
 

bin/bundler.rs

@@ -1,5 +1,5 @@
 use aa_bundler::{
-    bundler::bundler::Bundler,
+    bundler::Bundler,
     models::wallet::Wallet,
     rpc::{eth::EthApiServerImpl, eth_api::EthApiServer},
 };

build.rs

@@ -4,7 +4,7 @@ use ethers::solc::{Project, ProjectPathsConfig};
 
 fn config() -> prost_build::Config {
     let mut config = prost_build::Config::new();
-    config.bytes(&["."]);
+    config.bytes(["."]);
     config
 }
 

src/bundler/mod.rs

@@ -1,10 +1,10 @@
-pub mod bundler;
-
 use std::str::FromStr;
 
 use clap::Parser;
 use ethers::types::{Address, U256};
 
+use crate::models::wallet::Wallet;
+
 #[derive(Debug, Parser, PartialEq)]
 pub struct BundlerOpts {
     #[clap(long, value_parser=parse_address)]
@@ -34,6 +34,16 @@ fn parse_u256(s: &str) -> Result<U256, String> {
     U256::from_str_radix(s, 10).map_err(|_| format!("{} is not a valid U256", s))
 }
 
+pub struct Bundler {
+    pub wallet: Wallet,
+}
+
+impl Bundler {
+    pub fn new(wallet: Wallet) -> Self {
+        Self { wallet }
+    }
+}
+
 #[cfg(test)]
 mod test {
     use super::*;

src/contracts/entrypoint.rs

@@ -3,7 +3,6 @@ use std::sync::Arc;
 
 use anyhow;
 use ethers::abi::AbiDecode;
-use ethers::prelude::ContractError;
 use ethers::providers::Middleware;
 use ethers::types::{Address, Bytes};
 use regex::Regex;
@@ -23,7 +22,7 @@ impl<M: Middleware + 'static> EntryPoint<M> {
         let api = EntryPointAPI::new(entry_point_address, provider.clone());
         Self {
             provider,
-            entry_point_address: entry_point_address,
+            entry_point_address,
             api,
         }
     }
@@ -39,7 +38,7 @@ impl<M: Middleware + 'static> EntryPoint<M> {
     fn deserialize_error_msg(
         err_msg: &str,
     ) -> Result<entry_point_api::EntryPointAPIErrors, EntryPointErr> {
-        JsonRpcError::from_str(&err_msg)
+        JsonRpcError::from_str(err_msg)
             .map_err(|_| {
                 EntryPointErr::DecodeErr(format!(
                     "{:?} is not a valid JsonRpcError message",
@@ -115,7 +114,7 @@ impl<M: Middleware + 'static> EntryPoint<M> {
             })
     }
 
-    async fn get_sender_address<U: Into<UserOperation>>(
+    pub async fn get_sender_address<U: Into<UserOperation>>(
         &self,
         initcode: Bytes,
     ) -> Result<entry_point_api::SenderAddressResult, EntryPointErr> {
@@ -141,10 +140,10 @@ impl<M: Middleware + 'static> EntryPoint<M> {
         }
     }
 
-    async fn handle_aggregated_ops<U: Into<UserOperation>>(
+    pub async fn handle_aggregated_ops<U: Into<UserOperation>>(
         &self,
-        ops_per_aggregator: Vec<U>,
-        beneficiary: Address,
+        _ops_per_aggregator: Vec<U>,
+        _beneficiary: Address,
     ) -> Result<(), EntryPointErr> {
         todo!()
     }

src/models/wallet.rs

@@ -13,7 +13,7 @@ impl Wallet {
     pub fn new(output_path: ExpandedPathBuf) -> Self {
         let mut rng = rand::thread_rng();
 
-        fs::create_dir_all(output_path.to_path_buf()).unwrap();
+        fs::create_dir_all(&output_path).unwrap();
 
         Self {
             signer: MnemonicBuilder::<English>::default()

src/types/user_operation.rs

@@ -1,6 +1,6 @@
 use ethers::abi::AbiEncode;
 use ethers::prelude::{EthAbiCodec, EthAbiType};
-use ethers::types::{Address, Bytes, H256, U256, TransactionReceipt};
+use ethers::types::{Address, Bytes, TransactionReceipt, H256, U256};
 use ethers::utils::keccak256;
 use serde::{Deserialize, Serialize};
 use std::str::FromStr;

src/uopool/mod.rs

@@ -1,6 +1,6 @@
 use crate::{
     types::user_operation::{UserOperation, UserOperationHash},
-    uopool::{server::server::uo_pool_server::UoPoolServer, services::UoPoolService},
+    uopool::{server::uopool_server::uo_pool_server::UoPoolServer, services::UoPoolService},
 };
 use anyhow::Result;
 use clap::Parser;
@@ -26,6 +26,12 @@ impl UserOperationPool {
     }
 }
 
+impl Default for UserOperationPool {
+    fn default() -> Self {
+        Self::new()
+    }
+}
+
 #[derive(Educe, Parser)]
 #[educe(Debug)]
 pub struct UoPoolOpts {

src/uopool/server.rs

@@ -2,6 +2,6 @@ mod types {
     tonic::include_proto!("types");
 }
 
-pub mod server {
+pub mod uopool_server {
     tonic::include_proto!("uopool");
 }

src/uopool/services/uopool.rs

@@ -1,7 +1,7 @@
 use std::sync::Arc;
 
 use crate::uopool::{
-    server::server::{
+    server::uopool_server::{
         uo_pool_server::UoPool, AddRequest, AddResponse, AllRequest, AllResponse, RemoveRequest,
         RemoveResponse,
     },