feat: add get doc by id

sdk/src/provider/indexer_provider.ts

@@ -25,6 +25,7 @@ import {
     RunQueryRequest,
     GetContractSyncStatusRequest,
     GetCollectionOfDatabaseRequest,
+    GetDocRequest,
 } from '../proto/db3_indexer'
 import { SetupRequest, GetSystemStatusRequest } from '../proto/db3_system'
 import { Query } from '../proto/db3_database_v2'
@@ -61,6 +62,20 @@ export class IndexerProvider {
             throw new DB3Error(e as RpcError)
         }
     }
+
+    async getDoc(db: string, colName: string, id: string) {
+        const request: GetDocRequest = {
+            dbAddr: db,
+            colName,
+            id,
+        }
+        try {
+            const { response } = await this.client.getDoc(request)
+            return response
+        } catch (e) {
+            throw new DB3Error(e as RpcError)
+        }
+    }
     async setup(signature: string, payload: string) {
         try {
             const request: SetupRequest = {

sdk/src/store/document_v2.ts

@@ -40,6 +40,7 @@ async function runQueryInternal<T>(col: Collection, query: Query) {
             id: doc.id,
         } as DocumentEntry<T>
     })
+
     return {
         docs: entries,
         collection: col,
@@ -115,6 +116,22 @@ export async function queryDoc<T = DocumentData>(
     }
 }
 
+export async function getDoc<T = DocumentData>(col: Collection, id: string) {
+    const response = await col.db.client.indexer.getDoc(
+        col.db.addr,
+        col.name,
+        id
+    )
+    if (response.document) {
+        return {
+            doc: JSON.parse(response.document.doc) as T,
+            id: response.document.id,
+        } as DocumentEntry<T>
+    } else {
+        throw new Error('no document was found with id ' + id)
+    }
+}
+
 export async function deleteDoc(col: Collection, ids: string[]) {
     const documentMutation: DocumentMutation = {
         collectionName: col.name,

src/node/src/indexer_impl.rs

@@ -23,7 +23,8 @@ use db3_event::event_processor::EventProcessorConfig;
 use db3_proto::db3_indexer_proto::indexer_node_server::IndexerNode;
 use db3_proto::db3_indexer_proto::{
     ContractSyncStatus, GetCollectionOfDatabaseRequest, GetCollectionOfDatabaseResponse,
-    GetContractSyncStatusRequest, GetContractSyncStatusResponse, RunQueryRequest, RunQueryResponse,
+    GetContractSyncStatusRequest, GetContractSyncStatusResponse, GetDocRequest, GetDocResponse,
+    RunQueryRequest, RunQueryResponse,
 };
 use db3_proto::db3_mutation_v2_proto::MutationAction;
 use db3_proto::db3_storage_proto::block_response::MutationWrapper;
@@ -367,6 +368,21 @@ impl IndexerNode for IndexerNodeImpl {
         }))
     }
 
+    async fn get_doc(
+        &self,
+        request: Request<GetDocRequest>,
+    ) -> std::result::Result<Response<GetDocResponse>, Status> {
+        let r = request.into_inner();
+        let addr = DB3Address::from_hex(r.db_addr.as_str()).map_err(|e| {
+            Status::invalid_argument(format!("fail to parse the db address for {e}"))
+        })?;
+        let document = self
+            .db_store
+            .get_doc(&addr, r.col_name.as_str(), r.id)
+            .map_err(|e| Status::internal(format!("{e}")))?;
+        Ok(Response::new(GetDocResponse { document }))
+    }
+
     async fn run_query(
         &self,
         request: Request<RunQueryRequest>,
@@ -376,7 +392,6 @@ impl IndexerNode for IndexerNodeImpl {
             Status::invalid_argument(format!("fail to parse the db address for {e}"))
         })?;
         if let Some(q) = &r.query {
-            info!("query str {} q {:?}", q.query_str, q);
             let (documents, count) = self
                 .db_store
                 .query_docs(&addr, r.col_name.as_str(), q)

src/proto/proto/db3_indexer.proto

@@ -61,9 +61,20 @@ message GetContractSyncStatusResponse {
 
 message GetContractSyncStatusRequest {}
 
+message GetDocRequest {
+  string db_addr = 1;
+  string col_name = 2;
+  int64 id = 3;
+}
+
+message GetDocResponse {
+  db3_database_v2_proto.Document document = 1;
+}
+
 service IndexerNode {
   rpc GetContractSyncStatus(GetContractSyncStatusRequest) returns (GetContractSyncStatusResponse) {}
   rpc GetCollectionOfDatabase(GetCollectionOfDatabaseRequest) returns (GetCollectionOfDatabaseResponse) {}
   // method for query document
   rpc RunQuery(RunQueryRequest) returns (RunQueryResponse) {}
+  rpc GetDoc(GetDocRequest) returns (GetDocResponse) {}
 }

src/storage/src/db_store_v2.rs

@@ -845,6 +845,30 @@ impl DBStoreV2 {
         Ok(())
     }
 
+    pub fn get_doc(
+        &self,
+        db_addr: &DB3Address,
+        col_name: &str,
+        doc_id: i64,
+    ) -> Result<Option<Document>> {
+        if !self.is_db_collection_exist(db_addr, col_name)? {
+            return Err(DB3Error::CollectionNotFound(
+                col_name.to_string(),
+                db_addr.to_hex(),
+            ));
+        }
+        if self.config.enable_doc_store {
+            let doc = self.doc_store.get_doc(db_addr, col_name, doc_id)?;
+            if let Some(d) = doc {
+                Ok(Some(Document { id: doc_id, doc: d }))
+            } else {
+                Ok(None)
+            }
+        } else {
+            Ok(None)
+        }
+    }
+
     pub fn get_doc_key_from_doc_id(&self, doc_id: i64) -> Result<Vec<u8>> {
         let doc_owner_store_cf_handle = self
             .se

src/storage/src/doc_store.rs

@@ -237,18 +237,15 @@ impl DocStore {
         }
     }
 
-    pub fn get_doc(&self, db_addr: &DB3Address, col_name: &str, id: i64) -> Result<String> {
+    pub fn get_doc(&self, db_addr: &DB3Address, col_name: &str, id: i64) -> Result<Option<String>> {
         let db_opt = self.get_db_ref(db_addr);
         if let Some(db) = db_opt {
             let opt = db
                 .get::<String>(col_name, id)
                 .map_err(|e| DB3Error::WriteStoreError(format!("{e}")))?;
-            Ok(opt)
+            Ok(Some(opt))
         } else {
-            Err(DB3Error::WriteStoreError(format!(
-                "no database found with addr {}",
-                db_addr.to_hex()
-            )))
+            Ok(None)
         }
     }