add sentry

Cargo.toml

@@ -13,10 +13,8 @@ anyhow = { version = "1.0.75", features = ["backtrace"] }
 backoff = { version = "0.4.0", features = ["futures", "tokio"] }
 chrono = { version = "0.4.31", features = ["serde"] }
 itertools = "0.13.0"
-log = "0.4.20"
 once_cell = "1.18.0"
 pom = "3.3.0"
-pretty_env_logger = "0.5.0"
 regex = "1.10.0"
 reqwest = { version = "0.12.8", default-features = false, features = ["rustls-tls", "multipart", "json"] }
 serde = { version = "1.0.188", features = ["derive"] }
@@ -27,3 +25,6 @@ axum = { version = "0.7.7", features = ["macros"] }
 thiserror = "1.0.49"
 serde_json = "1.0.132"
 maud = "0.26.0"
+sentry = { version = "0.34.0", features = ["tracing", "rustls"], default-features = false }
+tracing = "0.1.40"
+tracing-subscriber = { version = "0.3.18", features = ["env-filter"] }

src/api_cache.rs

@@ -39,7 +39,7 @@ impl ApiCache {
         {
             let account_ids = account_chunk.to_vec();
 
-            log::debug!("fetching relationships: {:?}", account_ids);
+            tracing::debug!("fetching relationships: {:?}", account_ids);
 
             let chunk_result: Vec<Relationship> = client
                 .get(
@@ -73,7 +73,7 @@ impl ApiCache {
             return Ok(follows);
         }
 
-        log::info!("fetching all your follows");
+        tracing::info!("fetching all your follows");
 
         // TODO: cache that too
         let res: CredentialAccount = client

src/api_client.rs

@@ -85,7 +85,7 @@ impl ApiClient {
                 Ok(response)
             },
             |_err, dur| {
-                log::warn!(
+                tracing::warn!(
                     "[{}] encountered rate limit, backing off for {:?}",
                     self.host,
                     dur

src/error.rs

@@ -21,7 +21,7 @@ pub enum ResponseError {
 
 impl IntoResponse for ResponseError {
     fn into_response(self) -> Response {
-        log::error!("error while serving request: {}", self);
+        tracing::error!("error while serving request: {}", self);
         (StatusCode::INTERNAL_SERVER_ERROR, format!("{}\n", self)).into_response()
     }
 }

src/list_manager.rs

@@ -133,7 +133,7 @@ impl ListManager {
         client: &ApiClient,
         api_cache: &mut ApiCache,
     ) -> Result<(), Error> {
-        log::info!("syncing list {} ({})", self.list.id, self.list.title);
+        tracing::info!("syncing list {} ({})", self.list.id, self.list.title);
 
         let mut new_member_ids = self.get_new_member_ids(client, api_cache).await?;
 
@@ -174,7 +174,7 @@ impl ListManager {
             .chunks(UPDATE_CHUNK_SIZE)
         {
             let account_ids = account_chunk.to_vec();
-            log::debug!(
+            tracing::debug!(
                 "syncing list {} ({}): adding accounts: {:?}",
                 self.list.id,
                 self.list.title,
@@ -201,7 +201,7 @@ impl ListManager {
 
         for account_chunk in to_delete.chunks(UPDATE_CHUNK_SIZE) {
             let account_ids = account_chunk.to_vec();
-            log::debug!(
+            tracing::debug!(
                 "syncing list {} ({}): deleting accounts: {:?}",
                 self.list.id,
                 self.list.title,
@@ -226,7 +226,7 @@ impl ListManager {
                 .context("failed to remove members")?;
         }
 
-        log::info!(
+        tracing::info!(
             "done syncing, went from {} to {} members",
             num_old_accounts,
             num_new_accounts

src/main.rs

@@ -33,7 +33,18 @@ use store::{AccountPk, RegisterAccount, SyncImmediateResult};
 
 #[tokio::main]
 async fn main() -> Result<(), Error> {
-    pretty_env_logger::init();
+    use tracing_subscriber::prelude::*;
+
+    let _guard = sentry::init(sentry::ClientOptions {
+        release: sentry::release_name!(),
+        ..sentry::ClientOptions::default()
+    });
+
+    tracing_subscriber::registry()
+        .with(tracing_subscriber::fmt::layer())
+        .with(tracing_subscriber::EnvFilter::from_env("RUST_LOG"))
+        .with(sentry::integrations::tracing::layer())
+        .init();
 
     let cli = Cli::parse();
 
@@ -66,9 +77,9 @@ async fn serve(server_cli: Server) -> Result<(), Error> {
         loop {
             match cronjob_store.sync_all_accounts().await {
                 Ok((success, failure)) => {
-                    log::info!("cronjob: {} success, {} failure", success, failure)
+                    tracing::info!("cronjob: {} success, {} failure", success, failure)
                 }
-                Err(e) => log::error!("failed to run cronjob: {:?}", e),
+                Err(e) => tracing::error!("failed to run cronjob: {:?}", e),
             }
 
             tokio::time::sleep(Duration::from_secs(3600)).await;
@@ -101,7 +112,7 @@ async fn serve(server_cli: Server) -> Result<(), Error> {
         .route("/account", get(account))
         .with_state(state);
 
-    log::info!("listening on {}", socketaddr_str);
+    tracing::info!("listening on {}", socketaddr_str);
     let addr = SocketAddr::from_str(&socketaddr_str).expect("invalid host/port for server");
 
     let listener = tokio::net::TcpListener::bind(addr).await.unwrap();

src/runner.rs

@@ -9,7 +9,7 @@ use crate::list_manager::ListManager;
 pub async fn run_once(host: &str, token: &str) -> Result<(), Error> {
     let api_client = ApiClient::new(host, Some(token))?;
 
-    log::info!("fetching all your lists");
+    tracing::info!("fetching all your lists");
 
     let mut url_opt = Some("/api/v1/lists".to_owned());
 

src/store.rs

@@ -144,7 +144,7 @@ impl Store {
         let handle = &mut immediate_syncs
             .entry(account_pk.clone())
             .or_insert_with(move || {
-                log::info!("immediate sync for {}", account.primary_key().as_handle());
+                tracing::info!("immediate sync for {}", account.primary_key().as_handle());
                 let slf = self.clone();
                 let account2 = account.clone();
                 let future = async move { slf.run_once_and_log(account).await? };
@@ -220,7 +220,7 @@ impl Store {
         for account in results {
             let account_pk = account.primary_key();
             if self.immediate_syncs.lock().await.contains_key(&account_pk) {
-                log::warn!(
+                tracing::warn!(
                     "skipping cronjob for account {:?}, found immediate sync pending",
                     account_pk
                 );