feat: support editing and modifying CLA protocol content and performing object storage. (#2000)

fix errors

Signed-off-by: Ruizhi Huang <231220075@smail.nju.edu.cn>
Co-authored-by: Quanyi Ma <eli@patch.sh>

Author: 231220075

ceres/src/api_service/mono_api_service.rs

@@ -55,6 +55,7 @@ use common::{
     errors::{BuckError, MegaError},
     utils::MEGA_BRANCH_NAME,
 };
+use futures::{StreamExt, stream};
 use git_internal::{
     DiffItem,
     diff::Diff as GitDiff,
@@ -69,6 +70,7 @@ use git_internal::{
         },
     },
 };
+use io_orbit::object_storage::{ObjectKey, ObjectMeta, ObjectNamespace};
 use jupiter::{
     service::buck_service::{
         CommitArtifacts, CompletePayload as SvcCompletePayload,
@@ -130,6 +132,8 @@ impl From<&ImportRepo> for MonoApiService {
         }
     }
 }
+// Key for storing the current CLA content in the object storage
+const CLA_CONTENT_OBJECT_KEY: &str = "cla/content/current.txt";
 
 pub struct TreeUpdateResult {
     pub updated_trees: Vec<Tree>,
@@ -1300,6 +1304,60 @@ impl MonoApiService {
         Ok((model.cla_signed, model.cla_signed_at))
     }
 
+    pub async fn get_cla_content(&self) -> Result<String, MegaError> {
+        let key = ObjectKey {
+            namespace: ObjectNamespace::Log,
+            key: CLA_CONTENT_OBJECT_KEY.to_string(),
+        };
+
+        let stream = self
+            .storage
+            .git_service
+            .obj_storage
+            .inner
+            .get_stream(&key)
+            .await;
+        let (mut stream, _meta) = match stream {
+            Ok(result) => result,
+            Err(MegaError::ObjStorageNotFound(_)) => return Ok(String::new()),
+            Err(e) => return Err(e),
+        };
+
+        let mut data = Vec::new();
+        while let Some(chunk) = stream.next().await {
+            let chunk = chunk?;
+            data.extend_from_slice(&chunk);
+        }
+
+        String::from_utf8(data).map_err(|e| {
+            MegaError::Other(format!(
+                "Invalid UTF-8 in CLA content from object storage: {e}"
+            ))
+        })
+    }
+
+    pub async fn update_cla_content(&self, content: &str) -> Result<(), MegaError> {
+        let key = ObjectKey {
+            namespace: ObjectNamespace::Log,
+            key: CLA_CONTENT_OBJECT_KEY.to_string(),
+        };
+
+        let bytes = Bytes::from(content.as_bytes().to_vec());
+        let stream = stream::once(async move { Ok::<Bytes, std::io::Error>(bytes) });
+        let meta = ObjectMeta {
+            size: content.len() as i64,
+            content_type: Some("text/plain; charset=utf-8".to_string()),
+            ..Default::default()
+        };
+
+        self.storage
+            .git_service
+            .obj_storage
+            .inner
+            .put_stream(&key, Box::pin(stream), meta)
+            .await
+    }
+
     pub async fn change_cla_sign_status(
         &self,
         username: &str,

ceres/src/model/user.rs

@@ -61,3 +61,13 @@ pub struct ClaSignStatusRes {
     pub cla_signed: bool,
     pub cla_signed_at: Option<i64>,
 }
+
+#[derive(Debug, Deserialize, Serialize, ToSchema)]
+pub struct UpdateClaContentPayload {
+    pub content: String,
+}
+
+#[derive(Debug, Serialize, Deserialize, ToSchema)]
+pub struct ClaContentRes {
+    pub content: String,
+}

mono/src/api/router/user_router.rs

@@ -4,7 +4,9 @@ use axum::{
     extract::{Path, State},
     routing::get,
 };
-use ceres::model::user::{AddSSHKey, ClaSignStatusRes, ListSSHKey, ListToken};
+use ceres::model::user::{
+    AddSSHKey, ClaContentRes, ClaSignStatusRes, ListSSHKey, ListToken, UpdateClaContentPayload,
+};
 use common::errors::MegaError;
 use russh::keys::{HashAlg, parse_public_key_base64};
 use utoipa_axum::{router::OpenApiRouter, routes};
@@ -26,7 +28,9 @@ pub fn routers() -> OpenApiRouter<MonoApiServiceState> {
             .routes(routes!(list_token))
             .routes(routes!(remove_token))
             .routes(routes!(get_cla_sign_status))
-            .routes(routes!(change_sign_status)),
+            .routes(routes!(change_sign_status))
+            .routes(routes!(get_cla_content))
+            .routes(routes!(update_cla_content)),
     )
 }
 
@@ -228,3 +232,44 @@ async fn change_sign_status(
     };
     Ok(Json(CommonResult::success(Some(res))))
 }
+
+/// Get latest CLA text content
+#[utoipa::path(
+    get,
+    path = "/cla/content",
+    responses(
+        (status = 200, body = CommonResult<ClaContentRes>, content_type = "application/json")
+    ),
+    tag = USER_TAG
+)]
+async fn get_cla_content(
+    _user: LoginUser,
+    state: State<MonoApiServiceState>,
+) -> Result<Json<CommonResult<ClaContentRes>>, ApiError> {
+    let content = state.monorepo().get_cla_content().await?;
+    Ok(Json(CommonResult::success(Some(ClaContentRes { content }))))
+}
+
+/// Update latest CLA text content
+#[utoipa::path(
+    post,
+    path = "/cla/content",
+    request_body = UpdateClaContentPayload,
+    responses(
+        (status = 200, body = CommonResult<ClaContentRes>, content_type = "application/json")
+    ),
+    tag = USER_TAG
+)]
+async fn update_cla_content(
+    _user: LoginUser,
+    state: State<MonoApiServiceState>,
+    Json(payload): Json<UpdateClaContentPayload>,
+) -> Result<Json<CommonResult<ClaContentRes>>, ApiError> {
+    state
+        .monorepo()
+        .update_cla_content(&payload.content)
+        .await?;
+    Ok(Json(CommonResult::success(Some(ClaContentRes {
+        content: payload.content,
+    }))))
+}