Method document_get_impl

nodedb-client/src/native/client/document.rs:15–50

(
        &self,
        collection: &str,
        id: &str,
    )

impl NativeClient {
    pub(super) async fn document_get_impl(
        &self,
        collection: &str,
        id: &str,
    ) -> NodeDbResult<Option<Document>> {
        let mut conn = self.pool.acquire().await?;
        let resp = conn
            .send(
                OpCode::PointGet,
                TextFields {
                    collection: Some(collection.to_string()),
                    document_id: Some(id.to_string()),
                    ..Default::default()
                },
            )
            .await?;

        let rows = resp.rows.unwrap_or_default();
        if rows.is_empty() {
            return Ok(None);
        }

        let json_text = rows[0].first().and_then(|v| v.as_str()).unwrap_or("{}");
        let obj: HashMap<String, serde_json::Value> =
            sonic_rs::from_str(json_text).map_err(|e| {
                NodeDbError::serialization(
                    "json",
                    format!("document_get response for id '{id}': {e}"),
                )
            })?;
        let mut doc = Document::new(id);
        for (k, v) in obj {
            doc.set(&k, json_to_value(v));
        }
        Ok(Some(doc))
    }

    pub(super) async fn document_put_impl(
        &self,