Cleanup

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "signup-sequencer"
-version = "0.1.0"
+version = "1.0.1"
 authors = [
     "Remco Bloemen <remco@worldcoin.org>",
     "Lucas Ege <lucas@worldcoin.org>",
@@ -13,7 +13,7 @@ description = "A tool that processes WorldID signups on-chain."
 keywords = ["worldcoin", "protocol", "signup"]
 categories = ["cryptography::cryptocurrencies"]
 readme = "Readme.md"
-license-file = "mit-license.md"
+license-file = "LICENSE.md"
 
 [workspace]
 members = ["crates/*"]
@@ -78,9 +78,6 @@ 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.
-# `cargo update --package primitive-types@0.12.1 --precise 0.11.1`
 zeroize = "1.6.0"
 
 [dev-dependencies]

src/app.rs

@@ -2,7 +2,6 @@ use std::collections::HashSet;
 use std::sync::Arc;
 use std::time::Instant;
 
-use anyhow::Result as AnyhowResult;
 use chrono::{Duration, Utc};
 use clap::Parser;
 use ruint::Uint;
@@ -86,7 +85,7 @@ impl App {
     /// Will return `Err` if the internal Ethereum handler errors or if the
     /// `options.storage_file` is not accessible.
     #[instrument(name = "App::new", level = "debug")]
-    pub async fn new(options: Options) -> AnyhowResult<Self> {
+    pub async fn new(options: Options) -> anyhow::Result<Self> {
         let ethereum = Ethereum::new(options.ethereum);
         let db = Database::new(options.database);
 
@@ -212,7 +211,7 @@ impl App {
         initial_root_hash: Hash,
         mmap_file_path: &str,
         force_cache_purge: bool,
-    ) -> AnyhowResult<TreeState> {
+    ) -> anyhow::Result<TreeState> {
         let mut mined_items = database
             .get_commitments_by_status(ProcessedStatus::Mined)
             .await?;
@@ -362,7 +361,7 @@ impl App {
         initial_leaf_value: Hash,
         mined_items: Vec<TreeUpdate>,
         mmap_file_path: &str,
-    ) -> AnyhowResult<TreeState> {
+    ) -> anyhow::Result<TreeState> {
         // Flatten the updates for initial leaves
         let mined_items = dedup_tree_updates(mined_items);
 
@@ -819,7 +818,7 @@ impl App {
     ///
     /// Will return an Error if any of the components cannot be shut down
     /// gracefully.
-    pub async fn shutdown(&self) -> AnyhowResult<()> {
+    pub async fn shutdown(&self) -> anyhow::Result<()> {
         info!("Shutting down identity committer.");
         self.identity_committer.shutdown().await
     }

src/ethereum/mod.rs

@@ -1,7 +1,6 @@
 use std::collections::HashMap;
 use std::sync::Arc;
 
-use anyhow::Result as AnyhowResult;
 use clap::Parser;
 use ethers::types::transaction::eip2718::TypedTransaction;
 use ethers::types::Address;
@@ -45,7 +44,7 @@ pub struct Ethereum {
 
 impl Ethereum {
     #[instrument(name = "Ethereum::new", level = "debug", skip_all)]
-    pub async fn new(options: Options) -> AnyhowResult<Self> {
+    pub async fn new(options: Options) -> anyhow::Result<Self> {
         let read_provider = ReadProvider::new(options.ethereum_provider).await?;
 
         let mut secondary_read_providers = HashMap::new();

src/ethereum/read/mod.rs

@@ -1,4 +1,4 @@
-use anyhow::{anyhow, Result as AnyhowResult};
+use anyhow::anyhow;
 use chrono::{Duration as ChronoDuration, Utc};
 use ethers::abi::Error as AbiError;
 use ethers::providers::{Http, Middleware, Provider};
@@ -22,7 +22,7 @@ pub struct ReadProvider {
 }
 
 impl ReadProvider {
-    pub async fn new(url: Url) -> AnyhowResult<Self> {
+    pub async fn new(url: Url) -> anyhow::Result<Self> {
         // Connect to the Ethereum provider
         // TODO: Allow multiple providers with failover / broadcast.
         // TODO: Requests don't seem to process in parallel. Check if this is

src/ethereum/write_provider/mod.rs

@@ -1,7 +1,6 @@
 use std::fmt;
 use std::sync::Arc;
 
-use anyhow::Result as AnyhowResult;
 use ethers::providers::Middleware;
 use ethers::types::transaction::eip2718::TypedTransaction;
 use ethers::types::{Address, U64};
@@ -39,7 +38,7 @@ impl fmt::Debug for WriteProvider {
 }
 
 impl WriteProvider {
-    pub async fn new(read_provider: ReadProvider, options: &Options) -> AnyhowResult<Self> {
+    pub async fn new(read_provider: ReadProvider, options: &Options) -> anyhow::Result<Self> {
         let options = options.to_parsed()?;
         let address = options.address();
 

src/ethereum/write_provider/openzeppelin.rs

@@ -1,7 +1,6 @@
 use std::fmt::Debug;
 use std::time::Duration;
 
-use anyhow::Result as AnyhowResult;
 use ethers::types::transaction::eip2718::TypedTransaction;
 use once_cell::sync::Lazy;
 use oz_api::data::transactions::{RelayerTransactionBase, SendBaseTransactionRequest, Status};
@@ -33,7 +32,7 @@ pub struct OzRelay {
 }
 
 impl OzRelay {
-    pub async fn new(options: &OzOptions) -> AnyhowResult<Self> {
+    pub async fn new(options: &OzOptions) -> anyhow::Result<Self> {
         let oz_api = if options.oz_api_key.is_empty() && options.oz_api_secret.is_empty() {
             tracing::warn!(
                 "OpenZeppelin Defender API Key and Secret are empty. Connection will operate \

src/lib.rs

@@ -20,7 +20,6 @@ pub mod utils;
 
 use std::sync::Arc;
 
-use anyhow::Result as AnyhowResult;
 use clap::Parser;
 use tracing::info;
 
@@ -40,7 +39,7 @@ pub struct Options {
 /// assert!(true);
 /// ```
 #[allow(clippy::missing_errors_doc)]
-pub async fn main(options: Options) -> AnyhowResult<()> {
+pub async fn main(options: Options) -> anyhow::Result<()> {
     // Create App struct
     let app = Arc::new(App::new(options.app).await?);
     let app_for_server = app.clone();

src/server/mod.rs

@@ -4,7 +4,7 @@ use std::net::{IpAddr, Ipv4Addr, SocketAddr, TcpListener};
 use std::sync::Arc;
 use std::time::Duration;
 
-use anyhow::{bail, ensure, Result as AnyhowResult};
+use anyhow::{bail, ensure};
 use axum::extract::{Query, State};
 use axum::routing::{get, post};
 use axum::{middleware, Json, Router};
@@ -148,7 +148,7 @@ async fn list_batch_sizes(
 /// Will return `Err` if `options.server` URI is not http, incorrectly includes
 /// a path beyond `/`, or cannot be cast into an IP address. Also returns an
 /// `Err` if the server cannot bind to the given address.
-pub async fn main(app: Arc<App>, options: Options) -> AnyhowResult<()> {
+pub async fn main(app: Arc<App>, options: Options) -> anyhow::Result<()> {
     ensure!(
         options.server.scheme() == "http",
         "Only http:// is supported in {}",
@@ -186,7 +186,7 @@ pub async fn bind_from_listener(
     app: Arc<App>,
     serve_timeout: Duration,
     listener: TcpListener,
-) -> AnyhowResult<()> {
+) -> anyhow::Result<()> {
     let router = Router::new()
         .route("/verifySemaphoreProof", post(verify_semaphore_proof))
         .route("/inclusionProof", post(inclusion_proof))

src/task_monitor.rs

@@ -1,7 +1,6 @@
 use std::sync::Arc;
 use std::time::Duration;
 
-use anyhow::Result as AnyhowResult;
 use clap::Parser;
 use once_cell::sync::Lazy;
 use prometheus::{linear_buckets, register_gauge, register_histogram, Gauge, Histogram};
@@ -52,7 +51,7 @@ static BATCH_SIZES: Lazy<Histogram> = Lazy::new(|| {
 });
 
 impl RunningInstance {
-    async fn shutdown(self) -> AnyhowResult<()> {
+    async fn shutdown(self) -> anyhow::Result<()> {
         info!("Sending a shutdown signal to the committer.");
         // Ignoring errors here, since we have two options: either the channel is full,
         // which is impossible, since this is the only use, and this method takes
@@ -286,19 +285,19 @@ impl TaskMonitor {
         });
     }
 
-    async fn log_pending_identities_count(database: &Database) -> AnyhowResult<()> {
+    async fn log_pending_identities_count(database: &Database) -> anyhow::Result<()> {
         let identities = database.count_pending_identities().await?;
         PENDING_IDENTITIES.set(f64::from(identities));
         Ok(())
     }
 
-    async fn log_unprocessed_identities_count(database: &Database) -> AnyhowResult<()> {
+    async fn log_unprocessed_identities_count(database: &Database) -> anyhow::Result<()> {
         let identities = database.count_unprocessed_identities().await?;
         UNPROCESSED_IDENTITIES.set(f64::from(identities));
         Ok(())
     }
 
-    async fn log_identities_queues(database: &Database) -> AnyhowResult<()> {
+    async fn log_identities_queues(database: &Database) -> anyhow::Result<()> {
         TaskMonitor::log_unprocessed_identities_count(database).await?;
         TaskMonitor::log_pending_identities_count(database).await?;
         Ok(())
@@ -313,7 +312,7 @@ impl TaskMonitor {
     ///
     /// Will return an Error if the committer thread cannot be shut down
     /// gracefully.
-    pub async fn shutdown(&self) -> AnyhowResult<()> {
+    pub async fn shutdown(&self) -> anyhow::Result<()> {
         let mut instance = self.instance.write().await;
         if let Some(instance) = instance.take() {
             instance.shutdown().await?;

src/task_monitor/tasks/delete_identities.rs

@@ -1,7 +1,6 @@
 use std::collections::HashSet;
 use std::sync::Arc;
 
-use anyhow::Result as AnyhowResult;
 use chrono::Utc;
 use tokio::sync::Notify;
 use tracing::info;
@@ -53,7 +52,7 @@ async fn delete_identities(
     deletion_time_interval: i64,
     min_deletion_batch_size: usize,
     wake_up_notify: Arc<Notify>,
-) -> AnyhowResult<()> {
+) -> anyhow::Result<()> {
     info!("Starting deletion processor.");
 
     let deletion_time_interval = chrono::Duration::seconds(deletion_time_interval);

src/task_monitor/tasks/finalize_identities.rs

@@ -2,7 +2,7 @@ use std::collections::HashMap;
 use std::sync::Arc;
 use std::time::Duration;
 
-use anyhow::{Context, Result as AnyhowResult};
+use anyhow::Context;
 use chrono::Utc;
 use ethers::abi::RawLog;
 use ethers::contract::EthEvent;
@@ -76,7 +76,7 @@ async fn finalize_roots_loop(
     scanning_chain_head_offset: u64,
     time_between_scans: Duration,
     max_epoch_duration: Duration,
-) -> AnyhowResult<()> {
+) -> anyhow::Result<()> {
     let mainnet_abi = identity_manager.abi();
     let secondary_abis = identity_manager.secondary_abis();
 

src/task_monitor/tasks/insert_identities.rs

@@ -1,7 +1,6 @@
 use std::sync::Arc;
 use std::time::Duration;
 
-use anyhow::Result as AnyhowResult;
 use tokio::sync::Notify;
 use tokio::time::sleep;
 use tracing::instrument;
@@ -38,7 +37,7 @@ async fn insert_identities_loop(
     database: &Database,
     latest_tree: &TreeVersion<Latest>,
     wake_up_notify: &Notify,
-) -> AnyhowResult<()> {
+) -> anyhow::Result<()> {
     loop {
         // get commits from database
         let unprocessed = database
@@ -60,7 +59,7 @@ async fn insert_identities(
     database: &Database,
     latest_tree: &TreeVersion<Latest>,
     identities: Vec<UnprocessedCommitment>,
-) -> AnyhowResult<()> {
+) -> anyhow::Result<()> {
     // Filter out any identities that are already in the `identities` table
     let mut filtered_identities = vec![];
     for identity in identities {

src/task_monitor/tasks/monitor_txs.rs

@@ -1,6 +1,5 @@
 use std::sync::Arc;
 
-use anyhow::Result as AnyhowResult;
 use tokio::sync::{mpsc, Mutex};
 
 use crate::contracts::{IdentityManager, SharedIdentityManager};
@@ -32,7 +31,7 @@ impl MonitorTxs {
 async fn monitor_txs_loop(
     identity_manager: &IdentityManager,
     monitored_txs_receiver: &Mutex<mpsc::Receiver<TransactionId>>,
-) -> AnyhowResult<()> {
+) -> anyhow::Result<()> {
     let mut monitored_txs_receiver = monitored_txs_receiver.lock().await;
 
     while let Some(tx) = monitored_txs_receiver.recv().await {