fmt

Author: Larkooo

crates/torii/core/src/constants.rs

@@ -13,4 +13,4 @@ pub const IPFS_CLIENT_USERNAME: &str = "2EBrzr7ZASQZKH32sl2xWauXPSA";
 pub const IPFS_CLIENT_PASSWORD: &str = "12290b883db9138a8ae3363b6739d220";
 
 pub const WORLD_CONTRACT_TYPE: &str = "WORLD";
-pub const SQL_FELT_DELIMITER: &str = "/";
+pub const SQL_FELT_DELIMITER: &str = "/";

crates/torii/core/src/engine.rs

@@ -24,6 +24,7 @@ use tokio::task::JoinSet;
 use tokio::time::{sleep, Instant};
 use tracing::{debug, error, info, trace, warn};
 
+use crate::constants::LOG_TARGET;
 use crate::processors::erc20_legacy_transfer::Erc20LegacyTransferProcessor;
 use crate::processors::erc20_transfer::Erc20TransferProcessor;
 use crate::processors::erc721_legacy_transfer::Erc721LegacyTransferProcessor;
@@ -44,7 +45,6 @@ use crate::processors::{
 };
 use crate::sql::{Cursors, Sql};
 use crate::types::{Contract, ContractType};
-use crate::constants::LOG_TARGET;
 
 type EventProcessorMap<P> = HashMap<Felt, Vec<Box<dyn EventProcessor<P>>>>;
 

crates/torii/core/src/executor/erc.rs

@@ -13,11 +13,10 @@ use starknet_crypto::Felt;
 use tracing::{debug, trace};
 
 use super::{ApplyBalanceDiffQuery, Executor};
-use crate::constants::TOKEN_BALANCE_TABLE;
+use crate::constants::{IPFS_CLIENT_MAX_RETRY, SQL_FELT_DELIMITER, TOKEN_BALANCE_TABLE};
 use crate::sql::utils::{felt_to_sql_string, sql_string_to_u256, u256_to_sql_string, I256};
 use crate::types::ContractType;
 use crate::utils::fetch_content_from_ipfs;
-use crate::constants::{SQL_FELT_DELIMITER, IPFS_CLIENT_MAX_RETRY};
 
 #[derive(Debug, Clone)]
 pub struct RegisterErc721TokenQuery {

crates/torii/core/src/sql/mod.rs

@@ -827,11 +827,7 @@ impl Sql {
             Ty::Enum(e) => {
                 if e.options.iter().all(
                     |o| {
-                        if let Ty::Tuple(t) = &o.ty {
-                            t.is_empty()
-                        } else {
-                            false
-                        }
+                        if let Ty::Tuple(t) = &o.ty { t.is_empty() } else { false }
                     },
                 ) {
                     return Ok(());

crates/torii/core/src/utils.rs

@@ -7,7 +7,9 @@ use ipfs_api_backend_hyper::{IpfsApi, IpfsClient, TryFromUri};
 use tokio_util::bytes::Bytes;
 use tracing::info;
 
-use crate::constants::{IPFS_CLIENT_MAX_RETRY, IPFS_CLIENT_PASSWORD, IPFS_CLIENT_URL, IPFS_CLIENT_USERNAME};
+use crate::constants::{
+    IPFS_CLIENT_MAX_RETRY, IPFS_CLIENT_PASSWORD, IPFS_CLIENT_URL, IPFS_CLIENT_USERNAME,
+};
 
 pub fn must_utc_datetime_from_timestamp(timestamp: u64) -> DateTime<Utc> {
     let naive_dt = DateTime::from_timestamp(timestamp as i64, 0)
@@ -20,8 +22,8 @@ pub fn utc_dt_string_from_timestamp(timestamp: u64) -> String {
 }
 
 pub async fn fetch_content_from_ipfs(cid: &str, mut retries: u8) -> Result<Bytes> {
-    let client =
-        IpfsClient::from_str(IPFS_CLIENT_URL)?.with_credentials(IPFS_CLIENT_USERNAME, IPFS_CLIENT_PASSWORD);
+    let client = IpfsClient::from_str(IPFS_CLIENT_URL)?
+        .with_credentials(IPFS_CLIENT_USERNAME, IPFS_CLIENT_PASSWORD);
     while retries > 0 {
         let response = client.cat(cid).map_ok(|chunk| chunk.to_vec()).try_concat().await;
         match response {

crates/torii/graphql/src/object/event.rs

@@ -3,8 +3,8 @@ use async_graphql::dynamic::{
 };
 use async_graphql::{Name, Result, Value};
 use tokio_stream::{Stream, StreamExt};
-use torii_core::simple_broker::SimpleBroker;
 use torii_core::constants::SQL_FELT_DELIMITER;
+use torii_core::simple_broker::SimpleBroker;
 use torii_core::types::Event;
 
 use super::inputs::keys_input::{keys_argument, parse_keys_argument};

crates/torii/grpc/src/server/subscriptions/entity.rs

@@ -13,9 +13,9 @@ use tokio::sync::mpsc::{
     channel, unbounded_channel, Receiver, Sender, UnboundedReceiver, UnboundedSender,
 };
 use tokio::sync::RwLock;
+use torii_core::constants::SQL_FELT_DELIMITER;
 use torii_core::error::{Error, ParseError};
 use torii_core::simple_broker::SimpleBroker;
-use torii_core::constants::SQL_FELT_DELIMITER;
 use torii_core::types::OptimisticEntity;
 use tracing::{error, trace};
 

crates/torii/grpc/src/server/subscriptions/event.rs

@@ -13,9 +13,9 @@ use tokio::sync::mpsc::{
     channel, unbounded_channel, Receiver, Sender, UnboundedReceiver, UnboundedSender,
 };
 use tokio::sync::RwLock;
+use torii_core::constants::SQL_FELT_DELIMITER;
 use torii_core::error::{Error, ParseError};
 use torii_core::simple_broker::SimpleBroker;
-use torii_core::constants::SQL_FELT_DELIMITER;
 use torii_core::types::Event;
 use tracing::{error, trace};
 

crates/torii/grpc/src/server/subscriptions/event_message.rs

@@ -13,9 +13,9 @@ use tokio::sync::mpsc::{
     channel, unbounded_channel, Receiver, Sender, UnboundedReceiver, UnboundedSender,
 };
 use tokio::sync::RwLock;
+use torii_core::constants::SQL_FELT_DELIMITER;
 use torii_core::error::{Error, ParseError};
 use torii_core::simple_broker::SimpleBroker;
-use torii_core::constants::SQL_FELT_DELIMITER;
 use torii_core::types::OptimisticEventMessage;
 use tracing::{error, trace};