feat: insert database row into selected database

Cargo.toml

@@ -312,13 +312,13 @@ lto = false          # Disable Link-Time Optimization
 [patch.crates-io]
 # It's diffcult to resovle different version with the same crate used in AppFlowy Frontend and the Client-API crate.
 # So using patch to workaround this issue.
-collab = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "0efc824a6e1a56e4485646e6428c07fdccf6e918" }
-collab-entity = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "0efc824a6e1a56e4485646e6428c07fdccf6e918" }
-collab-folder = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "0efc824a6e1a56e4485646e6428c07fdccf6e918" }
-collab-document = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "0efc824a6e1a56e4485646e6428c07fdccf6e918" }
-collab-user = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "0efc824a6e1a56e4485646e6428c07fdccf6e918" }
-collab-database = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "0efc824a6e1a56e4485646e6428c07fdccf6e918" }
-collab-importer = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "0efc824a6e1a56e4485646e6428c07fdccf6e918" }
+collab = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "bd61aebe485c2c15328c008154021a286c6da8c3" }
+collab-entity = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "bd61aebe485c2c15328c008154021a286c6da8c3" }
+collab-folder = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "bd61aebe485c2c15328c008154021a286c6da8c3" }
+collab-document = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "bd61aebe485c2c15328c008154021a286c6da8c3" }
+collab-user = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "bd61aebe485c2c15328c008154021a286c6da8c3" }
+collab-database = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "bd61aebe485c2c15328c008154021a286c6da8c3" }
+collab-importer = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "bd61aebe485c2c15328c008154021a286c6da8c3" }
 
 [features]
 history = []

libs/client-api/src/http_collab.rs

@@ -4,8 +4,8 @@ use app_error::AppError;
 use bytes::Bytes;
 use chrono::{DateTime, Utc};
 use client_api_entity::workspace_dto::{
-  AFDatabase, AFDatabaseField, AFDatabaseRow, AFDatabaseRowDetail, DatabaseRowUpdatedItem,
-  ListDatabaseRowDetailParam, ListDatabaseRowUpdatedParam,
+  AFDatabase, AFDatabaseField, AFDatabaseRow, AFDatabaseRowDetail, AFInsertDatabaseField,
+  DatabaseRowUpdatedItem, ListDatabaseRowDetailParam, ListDatabaseRowUpdatedParam,
 };
 use client_api_entity::{
   BatchQueryCollabParams, BatchQueryCollabResult, CollabParams, CreateCollabParams,
@@ -210,6 +210,28 @@ impl Client {
     AppResponse::from_response(resp).await?.into_data()
   }
 
+  // Adds a database field to the specified database.
+  // Returns the field id of the newly created field.
+  pub async fn add_database_field(
+    &self,
+    workspace_id: &str,
+    database_id: &str,
+    insert_field: &AFInsertDatabaseField,
+  ) -> Result<String, AppResponseError> {
+    let url = format!(
+      "{}/api/workspace/{}/database/{}/fields",
+      self.base_url, workspace_id, database_id
+    );
+    let resp = self
+      .http_client_with_auth(Method::POST, &url)
+      .await?
+      .json(insert_field)
+      .send()
+      .await?;
+    log_request_id(&resp);
+    AppResponse::from_response(resp).await?.into_data()
+  }
+
   pub async fn list_database_row_ids_updated(
     &self,
     workspace_id: &str,
@@ -250,6 +272,32 @@ impl Client {
     AppResponse::from_response(resp).await?.into_data()
   }
 
+  /// Example payload:
+  /// {
+  ///   "Name": "some_data",        # using column name
+  ///   "_pIkG": "some other data"  # using field_id (can be obtained from [get_database_fields])
+  /// }
+  /// Upon success, returns the row id for the newly created row.
+  pub async fn add_database_item(
+    &self,
+    workspace_id: &str,
+    database_id: &str,
+    payload: &serde_json::Value,
+  ) -> Result<String, AppResponseError> {
+    let url = format!(
+      "{}/api/workspace/{}/database/{}/row",
+      self.base_url, workspace_id, database_id
+    );
+    let resp = self
+      .http_client_with_auth(Method::POST, &url)
+      .await?
+      .json(&payload)
+      .send()
+      .await?;
+    log_request_id(&resp);
+    AppResponse::from_response(resp).await?.into_data()
+  }
+
   #[instrument(level = "debug", skip_all, err)]
   pub async fn post_realtime_msg(
     &self,

libs/shared-entity/src/dto/workspace_dto.rs

@@ -376,3 +376,10 @@ pub struct AFDatabaseField {
   pub type_option: HashMap<String, serde_json::Value>,
   pub is_primary: bool,
 }
+
+#[derive(Default, Debug, Clone, Serialize, Deserialize)]
+pub struct AFInsertDatabaseField {
+  pub name: String,
+  pub field_type: i64,                             // FieldType ID
+  pub type_option_data: Option<serde_json::Value>, // TypeOptionData
+}

services/appflowy-collaborate/src/group/manager.rs

@@ -186,7 +186,7 @@ where
       )
       .await?,
     );
-    self.state.insert_group(object_id, group.clone()).await;
+    self.state.insert_group(object_id, group).await;
     Ok(())
   }
 }

src/api/workspace.rs

@@ -12,6 +12,7 @@ use futures_util::future::try_join_all;
 use prost::Message as ProstMessage;
 use rayon::prelude::*;
 use sqlx::types::uuid;
+use std::collections::HashMap;
 use std::time::Instant;
 
 use tokio_stream::StreamExt;
@@ -259,11 +260,13 @@ pub fn workspace_scope() -> Scope {
     .service(web::resource("/{workspace_id}/database").route(web::get().to(list_database_handler)))
     .service(
       web::resource("/{workspace_id}/database/{database_id}/row")
-        .route(web::get().to(list_database_row_id_handler)),
+        .route(web::get().to(list_database_row_id_handler))
+        .route(web::post().to(post_database_row_handler)),
     )
     .service(
       web::resource("/{workspace_id}/database/{database_id}/fields")
-        .route(web::get().to(get_database_fields_handler)),
+        .route(web::get().to(get_database_fields_handler))
+        .route(web::post().to(post_database_fields_handler)),
     )
     .service(
       web::resource("/{workspace_id}/database/{database_id}/row/updated")
@@ -1919,6 +1922,31 @@ async fn list_database_row_id_handler(
   Ok(Json(AppResponse::Ok().with_data(db_rows)))
 }
 
+async fn post_database_row_handler(
+  user_uuid: UserUuid,
+  path_param: web::Path<(String, String)>,
+  state: Data<AppState>,
+  cells_by_id: Json<HashMap<String, serde_json::Value>>,
+) -> Result<Json<AppResponse<String>>> {
+  let (workspace_id, db_id) = path_param.into_inner();
+  let uid = state.user_cache.get_user_uid(&user_uuid).await?;
+  state
+    .workspace_access_control
+    .enforce_action(&uid, &workspace_id, Action::Write)
+    .await?;
+
+  let new_db_row_id = biz::collab::ops::insert_database_row(
+    &state.collab_access_control_storage,
+    &state.pg_pool,
+    &workspace_id,
+    &db_id,
+    uid,
+    cells_by_id.into_inner(),
+  )
+  .await?;
+  Ok(Json(AppResponse::Ok().with_data(new_db_row_id)))
+}
+
 async fn get_database_fields_handler(
   user_uuid: UserUuid,
   path_param: web::Path<(String, String)>,
@@ -1941,6 +1969,32 @@ async fn get_database_fields_handler(
   Ok(Json(AppResponse::Ok().with_data(db_fields)))
 }
 
+async fn post_database_fields_handler(
+  user_uuid: UserUuid,
+  path_param: web::Path<(String, String)>,
+  state: Data<AppState>,
+  field: Json<AFInsertDatabaseField>,
+) -> Result<Json<AppResponse<String>>> {
+  let (workspace_id, db_id) = path_param.into_inner();
+  let uid = state.user_cache.get_user_uid(&user_uuid).await?;
+  state
+    .workspace_access_control
+    .enforce_action(&uid, &workspace_id, Action::Write)
+    .await?;
+
+  let field_id = biz::collab::ops::add_database_field(
+    uid,
+    &state.collab_access_control_storage,
+    &state.pg_pool,
+    &workspace_id,
+    &db_id,
+    field.into_inner(),
+  )
+  .await?;
+
+  Ok(Json(AppResponse::Ok().with_data(field_id)))
+}
+
 async fn list_database_row_id_updated_handler(
   user_uuid: UserUuid,
   path_param: web::Path<(String, String)>,

src/biz/collab/mod.rs

@@ -1,3 +1,4 @@
 pub mod folder_view;
 pub mod ops;
 pub mod publish_outline;
+pub mod utils;