fix: warnings

Author: kiseln

omni-relayer/src/main.rs

@@ -9,6 +9,7 @@ use reqwest::Url;
 use tracing::{error, info, warn};
 use tracing_subscriber::{EnvFilter, fmt, layer::SubscriberExt, util::SubscriberInitExt};
 
+#[allow(dead_code)]
 mod config;
 mod startup;
 mod types;

omni-relayer/src/startup/event_handlers.rs

@@ -19,8 +19,6 @@ use crate::{
     workers::{self, RetryableEvent},
 };
 
-pub(super) const OMNI_EVENTS: &str = "omni_events";
-
 fn near_event_key(origin_transaction_id: &str, origin_nonce: u64) -> String {
     utils::redis::composite_key(&[origin_transaction_id, &origin_nonce.to_string()])
 }

omni-relayer/src/startup/mongo_ingestion.rs

@@ -6,7 +6,9 @@ use tracing::{info, warn};
 
 use crate::{config, utils};
 
-use super::event_handlers::{OMNI_EVENTS, handle_meta_event, handle_transaction_event};
+use super::event_handlers::{handle_meta_event, handle_transaction_event};
+
+const OMNI_EVENTS: &str = "omni_events";
 
 async fn watch_omni_events_collection(
     collection: &Collection<OmniEvent>,

omni-relayer/src/startup/native_indexers/near.rs

@@ -215,3 +215,19 @@ fn is_nep_locker_event(config: &config::Config, receipt: &ReceiptView) -> bool {
             })
         )
 }
+
+pub async fn get_final_block(jsonrpc_client: &JsonRpcClient) -> Result<u64> {
+    info!("Getting final block");
+
+    let block_response = RpcBlockRequest {
+        block_reference: near_primitives::types::BlockReference::Finality(
+            near_primitives::types::Finality::Final,
+        ),
+    };
+
+    jsonrpc_client
+        .call(block_response)
+        .await
+        .map(|block| block.header.height)
+        .map_err(Into::into)
+}

omni-relayer/src/utils/near.rs

@@ -4,7 +4,7 @@ use anyhow::{Context, Result};
 use tracing::{info, warn};
 
 use near_crypto::{InMemorySigner, Signer};
-use near_jsonrpc_client::{JsonRpcClient, methods::block::RpcBlockRequest};
+use near_jsonrpc_client::JsonRpcClient;
 use near_primitives::{hash::CryptoHash, types::AccountId};
 use omni_types::ChainKind;
 
@@ -53,22 +53,6 @@ pub fn get_signer(
     }
 }
 
-pub async fn get_final_block(jsonrpc_client: &JsonRpcClient) -> Result<u64> {
-    info!("Getting final block");
-
-    let block_response = RpcBlockRequest {
-        block_reference: near_primitives::types::BlockReference::Finality(
-            near_primitives::types::Finality::Final,
-        ),
-    };
-
-    jsonrpc_client
-        .call(block_response)
-        .await
-        .map(|block| block.header.height)
-        .map_err(Into::into)
-}
-
 pub async fn resolve_tx_action(
     jsonrpc_client: &JsonRpcClient,
     tx_hash: CryptoHash,