chore: add logs

Author: appflowy

collab/src/database/blocks/block.rs

@@ -53,6 +53,7 @@ impl Block {
     self.notifier.subscribe()
   }
 
+  #[instrument(level = "debug", skip_all)]
   pub async fn batch_load_rows(&self, row_ids: Vec<RowId>) -> Result<(), CollabError> {
     let cloned_notifier = self.notifier.clone();
     let mut row_on_disk_details = vec![];
@@ -192,6 +193,7 @@ impl Block {
   }
 
   /// Get the [DatabaseRow] from the cache. If the row is not in the cache, initialize it.
+  #[instrument(level = "debug", skip_all)]
   pub fn init_database_row(&self, row_id: &RowId, ret: Option<InitRowChan>) {
     let row_id = *row_id;
     let row_change_tx = self.row_change_tx.clone();
@@ -217,6 +219,7 @@ impl Block {
       .map_err(|e| CollabError::Internal(anyhow::anyhow!(e)))?
   }
 
+  #[instrument(level = "debug", skip_all)]
   pub async fn init_database_rows(
     &self,
     row_ids: Vec<RowId>,

collab/src/database/database.rs

@@ -575,6 +575,7 @@ impl Database {
     self.body.block.init_database_row(row_id, ret)
   }
 
+  #[instrument(level = "debug", skip_all)]
   pub fn init_database_rows<'a, T: Into<RowId> + Send + 'a>(
     &'a self,
     row_ids: Vec<T>,
@@ -2090,6 +2091,7 @@ impl DatabaseBody {
   }
 
   /// Return list of [RowCell] for the given view and field.
+  #[instrument(level = "debug", skip_all)]
   pub async fn get_cells_for_field<T: ReadTxn>(
     &self,
     txn: &T,

collab/src/database/database_trait.rs

@@ -19,6 +19,7 @@ use rayon::prelude::*;
 use std::borrow::BorrowMut;
 use std::collections::HashMap;
 use std::sync::Arc;
+use tracing::instrument;
 use yrs::block::ClientID;
 
 // Database holder tracks initialization status and holds the database reference
@@ -263,6 +264,7 @@ where
     Ok(arc_row)
   }
 
+  #[instrument(level = "debug", skip_all)]
   async fn batch_build_arc_database_row(
     &self,
     row_ids: &[RowId],