Migrate to tracing instead of log crate

Cargo.toml

@@ -22,7 +22,7 @@ jsonrpc-core-client = { version = "18.0.0", features = ["ws", "http"] }
 
 bs58 = "0.5"
 base64 = "0.21.0"
-log = "0.4"
+tracing = "0.1.40"
 rand = "0.7"
 anyhow = "1.0"
 toml = "0.5"

connector/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "mango-feeds-connector"
-version = "0.2.1"
+version = "0.2.2"
 authors = ["Christian Kamm <[email protected]>"]
 edition = "2021"
 license = "AGPL-3.0-or-later"
@@ -27,7 +27,7 @@ rustls = { workspace = true }
 serde = { workspace = true }
 serde_derive = { workspace = true }
 
-log = { workspace = true }
+tracing = { workspace = true }
 anyhow = { workspace = true }
 
 itertools = { workspace = true }

connector/src/account_write_filter.rs

@@ -5,13 +5,13 @@ use crate::{
 };
 
 use async_trait::async_trait;
-use log::*;
 use solana_sdk::{account::WritableAccount, pubkey::Pubkey, stake_history::Epoch};
 use std::{
     collections::{BTreeSet, HashMap},
     sync::Arc,
     time::{Duration, Instant},
 };
+use tracing::*;
 
 #[async_trait]
 pub trait AccountWriteSink {

connector/src/grpc_plugin_source.rs

@@ -11,10 +11,10 @@ use yellowstone_grpc_proto::tonic::{
     Request,
 };
 
-use log::*;
 use std::sync::atomic::{AtomicBool, Ordering};
 use std::sync::Arc;
 use std::{collections::HashMap, env, str::FromStr, time::Duration};
+use tracing::*;
 use yellowstone_grpc_proto::geyser::{
     subscribe_request_filter_accounts_filter, subscribe_request_filter_accounts_filter_memcmp,
     SubscribeRequestFilterAccountsFilter, SubscribeRequestFilterAccountsFilterMemcmp,

connector/src/metrics.rs

@@ -1,10 +1,10 @@
 use {
     crate::MetricsConfig,
-    log::*,
     std::collections::HashMap,
     std::fmt,
     std::sync::{atomic, Arc, Mutex, RwLock},
     tokio::time,
+    tracing::*,
     warp::{Filter, Rejection, Reply},
 };
 

connector/src/snapshot.rs

@@ -1,5 +1,4 @@
 use jsonrpc_core_client::transports::http;
-use log::*;
 use solana_account_decoder::{UiAccount, UiAccountEncoding};
 use solana_client::{
     rpc_config::{RpcAccountInfoConfig, RpcProgramAccountsConfig},
@@ -8,6 +7,7 @@ use solana_client::{
 use solana_rpc::rpc::rpc_accounts::AccountsDataClient;
 use solana_rpc::rpc::rpc_accounts_scan::AccountsScanClient;
 use solana_sdk::{commitment_config::CommitmentConfig, slot_history::Slot};
+use tracing::*;
 
 use crate::{AnyhowWrap, FeedFilterType};
 

connector/src/websocket_source.rs

@@ -12,14 +12,14 @@ use solana_sdk::{
 };
 
 use anyhow::Context;
-use log::*;
 use std::ops::Sub;
 use std::{
     str::FromStr,
     sync::Arc,
     time::{Duration, Instant},
 };
 use tokio::time::timeout;
+use tracing::*;
 
 use crate::snapshot::{
     get_snapshot_gma, get_snapshot_gpa, SnapshotMultipleAccounts, SnapshotProgramAccounts,
@@ -363,7 +363,7 @@ pub async fn process_events(
                     .expect("send success");
             }
             WebsocketMessage::SnapshotUpdate((slot, accounts)) => {
-                trace!("snapshot update {slot}");
+                debug!("snapshot update {slot}");
                 let mut to_send = vec![];
                 for (pubkey, account) in accounts {
                     if let Some(account) = account {