add sidekiq support

Author: wuminzhe

Cargo.lock

@@ -1,7 +1,7 @@
 //! This module is a library to get ERC1155 transfer events.
-use crate::{EvmClient, Result, erc1155_db::add_collection_to_db};
+use crate::{EvmClient, Result};
 use array_bytes::hex2bytes_unchecked as bytes;
-use web3::{ethabi::token, types::{Bytes, Log, H160, H256, U256}};
+use web3::types::{Bytes, Log, H160, H256, U256};
 
 /// The Erc721 Transfer Event Wrapper
 #[derive(Debug, Clone)]

libs/nft-events/src/erc1155_evm.rs

@@ -22,3 +22,6 @@ confy = "0.4.0"
 async-trait = "0.1.51"
 directories-next = "2.0.0"
 rusqlite = "0.25.3"
+
+serde_json = "1.0"
+sidekiq = "0.9"

livenets/ethereum-nft-tracker/Cargo.toml

@@ -1,54 +1,17 @@
 use directories_next::ProjectDirs;
-use nft_events::{Erc1155Event, Erc1155EventCallback, Erc721Event, Erc721EventCallback};
 use std::env;
 use std::path::PathBuf;
 
+pub mod sidekiq_helper;
+mod println_callbacks;
+mod sidekiq_callbacks;
+
 #[macro_use]
 extern crate log;
 
 #[macro_use]
 extern crate async_trait;
 
-struct EthereumErc721EventCallback {}
-
-#[async_trait]
-impl Erc721EventCallback for EthereumErc721EventCallback {
-    async fn on_erc721_event(
-        &mut self,
-        event: Erc721Event,
-        name: String,
-        symbol: String,
-        total_supply: Option<u128>,
-        token_uri: String,
-    ) -> nft_events::Result<()> {
-        println!("------------------------------------------------------------------------------------------");
-        println!("event: {:?}", event);
-        println!(
-            "name: {:?}, symbol: {:?}, token_uri: {:?}",
-            name, symbol, token_uri
-        );
-        println!("total_supply: {:?}", total_supply);
-
-        Ok(())
-    }
-}
-
-struct EthereumErc1155EventCallback {}
-
-#[async_trait]
-impl Erc1155EventCallback for EthereumErc1155EventCallback {
-    async fn on_erc1155_event(
-        &mut self,
-        event: Erc1155Event,
-        token_uri: String,
-    ) -> nft_events::Result<()> {
-        println!("++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
-        println!("event: {:?}", event);
-        println!("token_uri: {:?}", token_uri);
-
-        Ok(())
-    }
-}
 
 use serde::{Deserialize, Serialize};
 
@@ -95,26 +58,45 @@ async fn main() -> anyhow::Result<()> {
     info!("  Track step : {} blocks", step);
 
     let args: Vec<String> = env::args().collect();
-    if args.len() != 2 {
+    if args.len() == 1 {
         println!("Usage: ethereum-nft-tracker <ETHEREUM_BLOCK_NUMBER>")
     } else {
-        if let Ok(start_from) = args[1].parse::<u64>() {
-            let mut erc721_cb = EthereumErc721EventCallback {};
-            let mut erc1155_cb = EthereumErc1155EventCallback {};
-            nft_events::start_tracking(
-                chain_name,
-                rpc,
-                data_dir,
-                start_from,
-                step,
-                &mut erc721_cb,
-                &mut erc1155_cb,
-            )
-            .await?;
+        if args.len() == 2 {
+            if let Ok(start_from) = args[1].parse::<u64>() {
+                let mut erc721_cb = println_callbacks::EthereumErc721EventCallback {};
+                let mut erc1155_cb = println_callbacks::EthereumErc1155EventCallback {};
+                nft_events::start_tracking(
+                    chain_name,
+                    rpc,
+                    data_dir,
+                    start_from,
+                    step,
+                    &mut erc721_cb,
+                    &mut erc1155_cb,
+                )
+                .await?;
+            } else {
+                println!("Usage: ethereum-nft-tracker <ETHEREUM_BLOCK_NUMBER>")
+            }
         } else {
-            println!("Usage: ethereum-nft-tracker <ETHEREUM_BLOCK_NUMBER>")
+            if let Ok(start_from) = args[1].parse::<u64>() {
+                let mut erc721_cb = sidekiq_callbacks::EthereumErc721EventCallback {};
+                let mut erc1155_cb = sidekiq_callbacks::EthereumErc1155EventCallback {};
+                nft_events::start_tracking(
+                    chain_name,
+                    rpc,
+                    data_dir,
+                    start_from,
+                    step,
+                    &mut erc721_cb,
+                    &mut erc1155_cb,
+                )
+                .await?;
+            } else {
+                println!("Usage: ethereum-nft-tracker <ETHEREUM_BLOCK_NUMBER>")
+            }
+            
         }
     }
-
     Ok(())
 }

livenets/ethereum-nft-tracker/src/main.rs

@@ -0,0 +1,43 @@
+use nft_events::{Erc1155Event, Erc1155EventCallback, Erc721Event, Erc721EventCallback};
+
+pub struct EthereumErc721EventCallback {}
+
+#[async_trait]
+impl Erc721EventCallback for EthereumErc721EventCallback {
+    async fn on_erc721_event(
+        &mut self,
+        event: Erc721Event,
+        name: String,
+        symbol: String,
+        total_supply: Option<u128>,
+        token_uri: String,
+    ) -> nft_events::Result<()> {
+        println!("------------------------------------------------------------------------------------------");
+        println!("event: {:?}", event);
+        println!(
+            "name: {:?}, symbol: {:?}, token_uri: {:?}",
+            name, symbol, token_uri
+        );
+        println!("total_supply: {:?}", total_supply);
+
+        Ok(())
+    }
+}
+
+pub struct EthereumErc1155EventCallback {}
+
+#[async_trait]
+impl Erc1155EventCallback for EthereumErc1155EventCallback {
+    async fn on_erc1155_event(
+        &mut self,
+        event: Erc1155Event,
+        token_uri: String,
+    ) -> nft_events::Result<()> {
+        println!("++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
+        println!("event: {:?}", event);
+        println!("token_uri: {:?}", token_uri);
+
+        Ok(())
+    }
+}
+

livenets/ethereum-nft-tracker/src/println_callbacks.rs

@@ -0,0 +1,47 @@
+use nft_events::{Erc1155Event, Erc1155EventCallback, Erc721Event, Erc721EventCallback};
+use crate::sidekiq_helper;
+
+pub struct EthereumErc721EventCallback {}
+
+#[async_trait]
+impl Erc721EventCallback for EthereumErc721EventCallback {
+    async fn on_erc721_event(
+        &mut self,
+        event: Erc721Event,
+        name: String,
+        symbol: String,
+        total_supply: Option<u128>,
+        token_uri: String,
+    ) -> nft_events::Result<()> {
+        sidekiq_helper::send_erc721(
+            "Ethereum".to_string(),
+            event,
+            name,
+            symbol,
+            token_uri,
+            total_supply,
+        );
+
+        Ok(())
+    }
+}
+
+pub struct EthereumErc1155EventCallback {}
+
+#[async_trait]
+impl Erc1155EventCallback for EthereumErc1155EventCallback {
+    async fn on_erc1155_event(
+        &mut self,
+        event: Erc1155Event,
+        token_uri: String,
+    ) -> nft_events::Result<()> {
+        sidekiq_helper::send_erc1155(
+            "Ethereum".to_string(),
+            event,
+            token_uri,
+        );
+
+        Ok(())
+    }
+}
+