feat: add bynamic sidebar db and api router (#1698)

* feat: add bynamic sidebar db and api router

* feat: fix review problems

* feat: fmt

Author: ztygod

ceres/src/model/dynamic_sidebar.rs

@@ -0,0 +1,46 @@
+use callisto::dynamic_sidebar;
+use serde::{Deserialize, Serialize};
+use utoipa::ToSchema;
+
+#[derive(Serialize, Deserialize, ToSchema)]
+pub struct SidebarRes {
+    pub id: i32,
+    pub public_id: String,
+    pub label: String,
+    pub href: String,
+    pub visible: bool,
+    pub order_index: i32,
+}
+
+impl From<dynamic_sidebar::Model> for SidebarRes {
+    fn from(value: dynamic_sidebar::Model) -> Self {
+        Self {
+            id: value.id,
+            public_id: value.public_id,
+            label: value.label,
+            href: value.href,
+            visible: value.visible,
+            order_index: value.order_index,
+        }
+    }
+}
+
+pub type SidebarMenuListRes = Vec<SidebarRes>;
+
+#[derive(Clone, Debug, ToSchema, Serialize, Deserialize)]
+pub struct CreateSidebarPayload {
+    pub public_id: String,
+    pub label: String,
+    pub href: String,
+    pub visible: bool,
+    pub order_index: i32,
+}
+
+#[derive(Clone, Debug, ToSchema, Serialize, Deserialize)]
+pub struct UpdateSidebarPayload {
+    pub public_id: Option<String>,
+    pub label: Option<String>,
+    pub href: Option<String>,
+    pub visible: Option<bool>,
+    pub order_index: Option<i32>,
+}

ceres/src/model/mod.rs

@@ -3,6 +3,7 @@ pub mod buck;
 pub mod change_list;
 pub mod commit;
 pub mod conversation;
+pub mod dynamic_sidebar;
 pub mod git;
 pub mod gpg;
 pub mod issue;

jupiter/callisto/src/dynamic_sidebar.rs

@@ -0,0 +1,23 @@
+//! `SeaORM` Entity, @generated by sea-orm-codegen 1.1.19
+
+use sea_orm::entity::prelude::*;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq, Serialize, Deserialize)]
+#[sea_orm(table_name = "dynamic_sidebar")]
+pub struct Model {
+    #[sea_orm(primary_key)]
+    pub id: i32,
+    #[sea_orm(unique)]
+    pub public_id: String,
+    pub label: String,
+    pub href: String,
+    pub visible: bool,
+    #[sea_orm(unique)]
+    pub order_index: i32,
+}
+
+#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
+pub enum Relation {}
+
+impl ActiveModelBehavior for ActiveModel {}

jupiter/callisto/src/mod.rs

@@ -8,6 +8,7 @@ pub mod buck_session_file;
 pub mod builds;
 pub mod check_result;
 pub mod commit_auths;
+pub mod dynamic_sidebar;
 pub mod entity_ext;
 pub mod git_blob;
 pub mod git_commit;

jupiter/callisto/src/prelude.rs

@@ -6,6 +6,7 @@ pub use super::buck_session_file::Entity as BuckSessionFile;
 pub use super::builds::Entity as Builds;
 pub use super::check_result::Entity as CheckResult;
 pub use super::commit_auths::Entity as CommitAuths;
+pub use super::dynamic_sidebar::Entity as DynamicSidebar;
 pub use super::git_blob::Entity as GitBlob;
 pub use super::git_commit::Entity as GitCommit;
 pub use super::git_issue::Entity as GitIssue;

jupiter/src/migration/m20251203_013745_add_dynamic_sidebar.rs

@@ -0,0 +1,101 @@
+use sea_orm::DatabaseBackend;
+use sea_orm_migration::prelude::*;
+
+#[derive(DeriveMigrationName)]
+pub struct Migration;
+
+#[async_trait::async_trait]
+impl MigrationTrait for Migration {
+    async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager
+            .create_table(
+                Table::create()
+                    .table(DynamicSidebar::Table)
+                    .if_not_exists()
+                    .col(
+                        ColumnDef::new(DynamicSidebar::Id)
+                            .integer()
+                            .not_null()
+                            .auto_increment()
+                            .primary_key(),
+                    )
+                    .col(ColumnDef::new(DynamicSidebar::PublicId).string().not_null())
+                    .col(ColumnDef::new(DynamicSidebar::Label).string().not_null())
+                    .col(ColumnDef::new(DynamicSidebar::Href).string().not_null())
+                    .col(ColumnDef::new(DynamicSidebar::Visible).boolean().not_null())
+                    .col(
+                        ColumnDef::new(DynamicSidebar::OrderIndex)
+                            .integer()
+                            .not_null(),
+                    )
+                    .to_owned(),
+            )
+            .await?;
+
+        manager
+            .create_index(
+                Index::create()
+                    .unique()
+                    .name("idx_dynamic_sidebar_public_id_unique")
+                    .table(DynamicSidebar::Table)
+                    .col(DynamicSidebar::PublicId)
+                    .to_owned(),
+            )
+            .await?;
+
+        manager
+            .create_index(
+                Index::create()
+                    .unique()
+                    .name("idx_dynamic_sidebar_order_index")
+                    .table(DynamicSidebar::Table)
+                    .col(DynamicSidebar::OrderIndex)
+                    .to_owned(),
+            )
+            .await?;
+
+        let backend = manager.get_database_backend();
+
+        match backend {
+            DatabaseBackend::Postgres => {
+                let sql = r#"
+                    INSERT INTO dynamic_sidebar (public_id, label, href, visible, order_index) VALUES
+                    ('home', 'Home', '/posts', true, 0),
+                    ('inbox', 'Inbox', '/inbox', true, 1),
+                    ('chat', 'Chat', '/chat', true, 2),
+                    ('notes', 'Docs', '/notes', true, 3),
+                    ('calls', 'Calls', '/calls', true, 4),
+                    ('drafts', 'Drafts', '/drafts', true, 5),
+                    ('code', 'Code', '/code', true, 6),
+                    ('tags', 'Tags', '/code/tags', true, 7),
+                    ('cl', 'Change List', '/cl', true, 8),
+                    ('mq', 'Merge Queue', '/queue/main', true, 9),
+                    ('issue', 'Issue', '/issue', true, 10),
+                    ('rust', 'Rust', '/rust', true, 11);
+                "#;
+
+                manager.get_connection().execute_unprepared(sql).await?;
+            }
+            DatabaseBackend::Sqlite | DatabaseBackend::MySql => {}
+        }
+
+        Ok(())
+    }
+
+    async fn down(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager
+            .drop_table(Table::drop().table(DynamicSidebar::Table).to_owned())
+            .await
+    }
+}
+
+#[derive(DeriveIden)]
+enum DynamicSidebar {
+    Table,
+    Id,
+    PublicId,
+    Label,
+    Href,
+    Visible,
+    OrderIndex,
+}

jupiter/src/migration/mod.rs

@@ -72,6 +72,7 @@ mod m20251117_181240_add_system_required_field_for_reviewer;
 mod m20251119_145041_add_draft_status;
 mod m20251125_135032_add_draft_conv_type;
 mod m20251128_000001_create_buck_session;
+mod m20251203_013745_add_dynamic_sidebar;
 
 /// Creates a primary key column definition with big integer type.
 ///
@@ -132,6 +133,7 @@ impl MigratorTrait for Migrator {
             Box::new(m20251119_145041_add_draft_status::Migration),
             Box::new(m20251125_135032_add_draft_conv_type::Migration),
             Box::new(m20251128_000001_create_buck_session::Migration),
+            Box::new(m20251203_013745_add_dynamic_sidebar::Migration),
         ]
     }
 }

jupiter/src/storage/dynamic_sidebar_storage.rs

@@ -0,0 +1,121 @@
+use std::ops::Deref;
+
+use crate::storage::base_storage::{BaseStorage, StorageConnector};
+use callisto::dynamic_sidebar;
+use common::errors::MegaError;
+use sea_orm::{
+    ActiveModelTrait,
+    ActiveValue::{NotSet, Set},
+    EntityTrait, QueryOrder,
+};
+
+#[derive(Clone)]
+pub struct DynamicSidebarStorage {
+    pub base: BaseStorage,
+}
+
+impl Deref for DynamicSidebarStorage {
+    type Target = BaseStorage;
+    fn deref(&self) -> &Self::Target {
+        &self.base
+    }
+}
+
+impl DynamicSidebarStorage {
+    pub async fn get_sidebar_by_id(
+        &self,
+        id: i32,
+    ) -> Result<Option<dynamic_sidebar::Model>, MegaError> {
+        let model = dynamic_sidebar::Entity::find_by_id(id)
+            .one(self.get_connection())
+            .await?;
+
+        Ok(model)
+    }
+
+    pub async fn get_sidebars(&self) -> Result<Vec<dynamic_sidebar::Model>, MegaError> {
+        let res = dynamic_sidebar::Entity::find()
+            .order_by_asc(dynamic_sidebar::Column::OrderIndex)
+            .all(self.get_connection())
+            .await?;
+        Ok(res)
+    }
+
+    pub async fn new_sidebar(
+        &self,
+        public_id: String,
+        label: String,
+        href: String,
+        visible: bool,
+        order_index: i32,
+    ) -> Result<dynamic_sidebar::Model, MegaError> {
+        let active_model = dynamic_sidebar::ActiveModel {
+            id: NotSet,
+            public_id: Set(public_id),
+            label: Set(label),
+            href: Set(href),
+            visible: Set(visible),
+            order_index: Set(order_index),
+        };
+
+        let res = active_model.insert(self.get_connection()).await?;
+        Ok(res)
+    }
+
+    pub async fn update_sidebar(
+        &self,
+        id: i32,
+        public_id: Option<String>,
+        label: Option<String>,
+        href: Option<String>,
+        visible: Option<bool>,
+        order_index: Option<i32>,
+    ) -> Result<dynamic_sidebar::Model, MegaError> {
+        let model = dynamic_sidebar::Entity::find_by_id(id)
+            .one(self.get_connection())
+            .await?
+            .ok_or_else(|| MegaError::Other(format!("Sidebar with id `{id}` not found")))?;
+
+        let mut active_model: dynamic_sidebar::ActiveModel = model.into();
+
+        if let Some(public_id) = public_id {
+            active_model.public_id = Set(public_id);
+        }
+        if let Some(label) = label {
+            active_model.label = Set(label);
+        }
+        if let Some(href) = href {
+            active_model.href = Set(href);
+        }
+        if let Some(visible) = visible {
+            active_model.visible = Set(visible);
+        }
+        if let Some(order_index) = order_index {
+            active_model.order_index = Set(order_index);
+        }
+
+        let updated_model = active_model.update(self.get_connection()).await?;
+
+        Ok(updated_model)
+    }
+
+    pub async fn delete_sidebar(&self, id: i32) -> Result<dynamic_sidebar::Model, MegaError> {
+        let model = dynamic_sidebar::Entity::find_by_id(id)
+            .one(self.get_connection())
+            .await?
+            .ok_or_else(|| MegaError::Other(format!("Sidebar with id `{id}` not found")))?;
+
+        let delete_result = dynamic_sidebar::Entity::delete_by_id(id)
+            .exec(self.get_connection())
+            .await
+            .map_err(|e| MegaError::Other(format!("Failed to delete sidebar: {e}")))?;
+
+        if delete_result.rows_affected == 0 {
+            return Err(MegaError::Other(format!(
+                "Sidebar with id `{id}` was not deleted"
+            )));
+        }
+
+        Ok(model)
+    }
+}

jupiter/src/storage/mod.rs

@@ -4,6 +4,7 @@ pub mod cl_reviewer_storage;
 pub mod cl_storage;
 pub mod commit_binding_storage;
 pub mod conversation_storage;
+pub mod dynamic_sidebar_storage;
 pub mod git_db_storage;
 pub mod gpg_storage;
 pub mod init;
@@ -27,6 +28,7 @@ use crate::service::cl_service::CLService;
 use crate::service::issue_service::IssueService;
 use crate::service::merge_queue_service::MergeQueueService;
 use crate::storage::conversation_storage::ConversationStorage;
+use crate::storage::dynamic_sidebar_storage::DynamicSidebarStorage;
 use crate::storage::init::database_connection;
 use crate::storage::{
     buck_storage::BuckStorage, cl_storage::ClStorage, commit_binding_storage::CommitBindingStorage,
@@ -59,6 +61,7 @@ pub struct AppService {
     pub reviewer_storage: ClReviewerStorage,
     pub merge_queue_storage: MergeQueueStorage,
     pub buck_storage: BuckStorage,
+    pub dynamic_sidebar_storage: DynamicSidebarStorage,
 }
 
 impl AppService {
@@ -82,6 +85,7 @@ impl AppService {
             reviewer_storage: ClReviewerStorage { base: mock.clone() },
             merge_queue_storage: MergeQueueStorage::new(mock.clone()),
             buck_storage: BuckStorage { base: mock.clone() },
+            dynamic_sidebar_storage: DynamicSidebarStorage { base: mock.clone() },
         })
     }
 }
@@ -117,6 +121,7 @@ impl Storage {
         let reviewer_storage = ClReviewerStorage { base: base.clone() };
         let merge_queue_storage = MergeQueueStorage::new(base.clone());
         let buck_storage = BuckStorage { base: base.clone() };
+        let dynamic_sidebar_storage = DynamicSidebarStorage { base: base.clone() };
 
         let app_service = AppService {
             mono_storage: mono_storage.clone(),
@@ -136,6 +141,7 @@ impl Storage {
             reviewer_storage,
             merge_queue_storage: merge_queue_storage.clone(),
             buck_storage,
+            dynamic_sidebar_storage,
         };
         let merge_queue_service = MergeQueueService::new(base.clone());
 
@@ -220,6 +226,10 @@ impl Storage {
         self.app_service.buck_storage.clone()
     }
 
+    pub fn dynamic_sidebar_storage(&self) -> DynamicSidebarStorage {
+        self.app_service.dynamic_sidebar_storage.clone()
+    }
+
     pub fn mock() -> Self {
         // During test time, we don't need a AppContext,
         // Put config in a leaked static variable thus the weak reference will always be valid.