From e6b4dd95e4f048bf98aea55c1c4da47a9a8b7b20 Mon Sep 17 00:00:00 2001
From: "benjamin.747" <benjamin.747@outlook.com>
Date: Mon, 26 May 2025 17:17:55 +0800
Subject: [PATCH] feat(mono): remove sql file & update router with utoipa

---
 .../docs/development/database/index.mdx       |   5 +-
 .../docs/development/quick-start/index.mdx    |  15 +-
 common/src/model.rs                           |   6 +-
 docs/development.md                           |  19 +-
 jupiter/callisto/Cargo.toml                   |   1 +
 jupiter/callisto/src/sea_orm_active_enums.rs  |   9 +-
 jupiter/sqlite_20241204_init.sql              |   1 -
 jupiter/src/storage/init.rs                   |  29 +-
 jupiter/src/storage/mono_storage.rs           |   2 +-
 mono/src/api/api_router.rs                    |   2 +-
 mono/src/api/issue/issue_router.rs            | 124 +++++--
 mono/src/api/issue/mod.rs                     |   5 +-
 mono/src/api/mr/mod.rs                        |  18 +-
 mono/src/api/mr/mr_router.rs                  | 205 +++++++----
 mono/src/server/https_server.rs               |   1 +
 sql/README.md                                 |  57 ---
 sql/postgres/pg_20241204__init.sql            | 324 ------------------
 sql/sqlite/sqlite_20241204_init.sql           | 310 -----------------
 18 files changed, 275 insertions(+), 858 deletions(-)
 delete mode 120000 jupiter/sqlite_20241204_init.sql
 delete mode 100644 sql/README.md
 delete mode 100644 sql/postgres/pg_20241204__init.sql
 delete mode 100644 sql/sqlite/sqlite_20241204_init.sql

diff --git a/aria/contents/docs/development/database/index.mdx b/aria/contents/docs/development/database/index.mdx
index 754c18519..30000d7ab 100644
--- a/aria/contents/docs/development/database/index.mdx
+++ b/aria/contents/docs/development/database/index.mdx
@@ -3,12 +3,11 @@ title: Database
 ---
 
 ## Database maintenance
-Currently, the tables of database are created by `.sql` file. 
+Currently, the tables of database are created by [SeaORM migration](https://www.sea-ql.org/SeaORM/docs/migration/setting-up-migration). 
 
-If you want to add a new table or modify the existing table, you need to update the `.sql` files which are located in the `sql` directory.
+If you want to add a new table or modify the existing table, you need to update the `migration` files which are located in the `jupiter/migration/src` directory.
 
 ### Attention
-- Each database corresponds to one `.sql` file, you must modify all of them if you want to update the tables in order to keep the consistency of the database.
 - DO NOT use `Array` Type in PostgreSQL but use `JSON` instead, for compatibility with SQLite & MySQL. (`JSON` &lt;==&gt; `serde_json::Value`)
 
 ---
diff --git a/aria/contents/docs/development/quick-start/index.mdx b/aria/contents/docs/development/quick-start/index.mdx
index c8f22944c..7a7379735 100644
--- a/aria/contents/docs/development/quick-start/index.mdx
+++ b/aria/contents/docs/development/quick-start/index.mdx
@@ -45,11 +45,6 @@ description: Quick start manuel to developing or testing.
    postgres=# \q
    ```
 
-   ```bash
-   $ cd mega/sql/postgres
-   $ psql mega < pg_YYYYMMDD_init.sql
-   ```
-
    3. Create user and grant privileges.
 
    ```sql
@@ -136,14 +131,7 @@ description: Quick start manuel to developing or testing.
    postgres=# \q
    ```
 
-   3.Import `mega/sql/postgres/pg_<time>_init.sql` to `mega`.
-
-   ```bash
-   $ cd mega/sql/postgres
-   $ sudo -u postgres psql mega < pg_YYYYMMDD__init.sql
-   ```
-
-   4.Create user and grant privileges.
+   3.Create user and grant privileges.
 
    ```sql
    $ sudo -u postgres psql postgres
@@ -202,7 +190,6 @@ When the codespace is ready, the PostgreSQL will be installed and started automa
 /etc/init.d/postgresql start
 
 sudo -u postgres psql mega -c "CREATE DATABASE mega;"
-sudo -u postgres psql mega < /workspaces/mega/sql/pg_YYYYMMDD__init.sql
 sudo -u postgres psql mega -c "CREATE USER mega WITH ENCRYPTED PASSWORD 'mega';"
 sudo -u postgres psql mega -c "GRANT ALL PRIVILEGES ON DATABASE mega TO mega;"
 sudo -u postgres psql mega -c "GRANT ALL ON ALL TABLES IN SCHEMA public to mega;"
diff --git a/common/src/model.rs b/common/src/model.rs
index 2f7643a99..f47c2786a 100644
--- a/common/src/model.rs
+++ b/common/src/model.rs
@@ -47,7 +47,7 @@ impl<T> CommonResult<T> {
     }
 }
 
-#[derive(Deserialize)]
+#[derive(Deserialize, ToSchema)]
 pub struct Pagination {
     pub page: u64,
     pub per_page: u64,
@@ -62,13 +62,13 @@ impl Default for Pagination {
     }
 }
 
-#[derive(Deserialize)]
+#[derive(Deserialize, ToSchema)]
 pub struct PageParams<T> {
     pub pagination: Pagination,
     pub additional: T,
 }
 
-#[derive(PartialEq, Eq, Debug, Clone, Default, Serialize, Deserialize)]
+#[derive(PartialEq, Eq, Debug, Clone, Default, Serialize, Deserialize, ToSchema)]
 
 pub struct CommonPage<T> {
     pub total: u64,
diff --git a/docs/development.md b/docs/development.md
index 75353b09f..5032942b9 100644
--- a/docs/development.md
+++ b/docs/development.md
@@ -47,10 +47,6 @@
    postgres=# \q
    ```
 
-   ```bash
-   $ cd mega/sql/postgres
-   $ psql mega < pg_YYYYMMDD_init.sql
-   ```
 
    3. Create user and grant privileges.
 
@@ -138,14 +134,7 @@
    postgres=# \q
    ```
 
-   3.Import `mega/sql/postgres/pg_<time>_init.sql` to `mega`.
-
-   ```bash
-   $ cd mega/sql/postgres
-   $ sudo -u postgres psql mega < pg_YYYYMMDD__init.sql
-   ```
-
-   4.Create user and grant privileges.
+   3.Create user and grant privileges.
 
    ```sql
    $ sudo -u postgres psql postgres
@@ -204,7 +193,6 @@ When the codespace is ready, the PostgreSQL will be installed and started automa
 /etc/init.d/postgresql start
 
 sudo -u postgres psql mega -c "CREATE DATABASE mega;"
-sudo -u postgres psql mega < /workspaces/mega/sql/pg_YYYYMMDD__init.sql
 sudo -u postgres psql mega -c "CREATE USER mega WITH ENCRYPTED PASSWORD 'mega';"
 sudo -u postgres psql mega -c "GRANT ALL PRIVILEGES ON DATABASE mega TO mega;"
 sudo -u postgres psql mega -c "GRANT ALL ON ALL TABLES IN SCHEMA public to mega;"
@@ -235,13 +223,8 @@ Currently, the mono bin and mega bin use two different files, each with a differ
   - see codes in [config.rs](/common/src/config.rs)
 
 ---
-## Database maintenance
-Currently, the tables of database are created by `.sql` file. 
-
-If you want to add a new table or modify the existing table, you need to update the `.sql` files which are located in the `sql` directory.
 
 ### Attention
-- Each database corresponds to one `.sql` file, you must modify all of them if you want to update the tables in order to keep the consistency of the database.
 - DO NOT use `Array` Type in PostgreSQL but use `JSON` instead, for compatibility with SQLite & MySQL. (`JSON` <==> `serde_json::Value`)
 ---
 ## Tests
diff --git a/jupiter/callisto/Cargo.toml b/jupiter/callisto/Cargo.toml
index cb40e4e21..35859abba 100644
--- a/jupiter/callisto/Cargo.toml
+++ b/jupiter/callisto/Cargo.toml
@@ -13,3 +13,4 @@ serde = { workspace = true, features = ["derive"] }
 serde_json = { workspace = true }
 chrono = { workspace = true }
 sea-orm = { workspace = true, features = ["sqlx-postgres", "sqlx-mysql", "sqlx-sqlite"] }
+utoipa = { workspace = true, features = ["axum_extras"] }
diff --git a/jupiter/callisto/src/sea_orm_active_enums.rs b/jupiter/callisto/src/sea_orm_active_enums.rs
index 26f3177d3..b8d3ec6c6 100644
--- a/jupiter/callisto/src/sea_orm_active_enums.rs
+++ b/jupiter/callisto/src/sea_orm_active_enums.rs
@@ -2,8 +2,11 @@
 
 use sea_orm::entity::prelude::*;
 use serde::{Deserialize, Serialize};
+use utoipa::ToSchema;
 
-#[derive(Debug, Clone, PartialEq, Eq, EnumIter, DeriveActiveEnum, Serialize, Deserialize)]
+#[derive(
+    Debug, Clone, PartialEq, Eq, EnumIter, DeriveActiveEnum, Serialize, Deserialize, ToSchema,
+)]
 #[sea_orm(rs_type = "String", db_type = "Enum", enum_name = "conv_type_enum")]
 pub enum ConvTypeEnum {
     #[sea_orm(string_value = "comment")]
@@ -29,7 +32,9 @@ pub enum ConvTypeEnum {
     #[sea_orm(string_value = "reopen")]
     Reopen,
 }
-#[derive(Debug, Clone, PartialEq, Eq, EnumIter, DeriveActiveEnum, Serialize, Deserialize)]
+#[derive(
+    Debug, Clone, PartialEq, Eq, EnumIter, DeriveActiveEnum, Serialize, Deserialize, ToSchema,
+)]
 #[sea_orm(rs_type = "String", db_type = "Enum", enum_name = "merge_status_enum")]
 pub enum MergeStatusEnum {
     #[sea_orm(string_value = "open")]
diff --git a/jupiter/sqlite_20241204_init.sql b/jupiter/sqlite_20241204_init.sql
deleted file mode 120000
index 985206b99..000000000
--- a/jupiter/sqlite_20241204_init.sql
+++ /dev/null
@@ -1 +0,0 @@
-../sql/sqlite/sqlite_20241204_init.sql
\ No newline at end of file
diff --git a/jupiter/src/storage/init.rs b/jupiter/src/storage/init.rs
index bb7426be2..f6548bb10 100644
--- a/jupiter/src/storage/init.rs
+++ b/jupiter/src/storage/init.rs
@@ -1,9 +1,6 @@
 use common::errors::MegaError;
 use migration::{Migrator, MigratorTrait};
-use sea_orm::{
-    ConnectOptions, ConnectionTrait, Database, DatabaseConnection, DbErr, Statement,
-    TransactionError, TransactionTrait,
-};
+use sea_orm::{ConnectOptions, Database, DatabaseConnection};
 use std::{path::Path, time::Duration};
 use tracing::log;
 
@@ -55,33 +52,9 @@ async fn sqlite_connection(db_config: &DbConfig) -> Result<DatabaseConnection, M
     let opt = setup_option(db_url);
     let conn = Database::connect(opt).await?;
 
-    // setup sqlite database (execute .sql)
-    // if db_config.db_path.metadata()?.len() == 0 {
-    //     log::info!("Setting up sqlite database");
-    //     setup_sql(&conn)
-    //         .await
-    //         .map_err(|e| sea_orm::DbErr::Custom(e.to_string()))?;
-    // }
     Ok(conn)
 }
 
-/// create table from .sql file
-#[allow(unused)]
-async fn setup_sql(conn: &DatabaseConnection) -> Result<(), TransactionError<DbErr>> {
-    conn.transaction::<_, _, DbErr>(|txn| {
-        Box::pin(async move {
-            let backend = txn.get_database_backend();
-
-            // `include_str!` will expand the file while compiling, so `.sql` is not needed after that
-            const SETUP_SQL: &str = include_str!("../../sqlite_20241204_init.sql");
-            txn.execute(Statement::from_string(backend, SETUP_SQL))
-                .await?;
-            Ok(())
-        })
-    })
-    .await
-}
-
 fn setup_option(db_url: impl Into<String>) -> ConnectOptions {
     let mut opt = ConnectOptions::new(db_url);
     opt.max_connections(5)
diff --git a/jupiter/src/storage/mono_storage.rs b/jupiter/src/storage/mono_storage.rs
index 316a61883..9bc2aaf81 100644
--- a/jupiter/src/storage/mono_storage.rs
+++ b/jupiter/src/storage/mono_storage.rs
@@ -89,7 +89,7 @@ impl MonoStorage {
     pub async fn get_refs(&self, path: &str) -> Result<Vec<mega_refs::Model>, MegaError> {
         let result = mega_refs::Entity::find()
             .filter(mega_refs::Column::Path.eq(path))
-            .filter(mega_refs::Column::IsMr.eq(false))
+            // .filter(mega_refs::Column::IsMr.eq(false))
             .order_by_asc(mega_refs::Column::RefName)
             .all(self.get_connection())
             .await?;
diff --git a/mono/src/api/api_router.rs b/mono/src/api/api_router.rs
index bdbe4a17f..0836d8158 100644
--- a/mono/src/api/api_router.rs
+++ b/mono/src/api/api_router.rs
@@ -80,7 +80,7 @@ async fn life_cycle_check() -> Result<impl IntoResponse, ApiError> {
 
 /// Create file in web UI
 #[utoipa::path(
-    get,
+    post,
     path = "/create-file",
     request_body = CreateFileInfo,
     responses(
diff --git a/mono/src/api/issue/issue_router.rs b/mono/src/api/issue/issue_router.rs
index d294b511e..c3696b231 100644
--- a/mono/src/api/issue/issue_router.rs
+++ b/mono/src/api/issue/issue_router.rs
@@ -1,38 +1,47 @@
 use axum::{
     extract::{Path, State},
-    routing::{get, post},
     Json,
 };
-use bytes::Bytes;
 use serde::Deserialize;
-use utoipa_axum::router::OpenApiRouter;
+use utoipa::ToSchema;
+use utoipa_axum::{router::OpenApiRouter, routes};
 
 use common::model::{CommonPage, CommonResult, PageParams};
 
-use crate::api::error::ApiError;
 use crate::api::issue::{IssueDetail, IssueItem, NewIssue};
-use crate::api::oauth::model::LoginUser;
+use crate::api::mr::SaveCommentRequest;
 use crate::api::MonoApiServiceState;
+use crate::{api::error::ApiError, server::https_server::ISSUE_TAG};
 
 pub fn routers() -> OpenApiRouter<MonoApiServiceState> {
     OpenApiRouter::new().nest(
         "/issue",
         OpenApiRouter::new()
-            .route("/list", post(fetch_issue_list))
-            .route("/new", post(new_issue))
-            .route("/{link}/close", post(close_issue))
-            .route("/{link}/reopen", post(reopen_issue))
-            .route("/{link}/detail", get(issue_detail))
-            .route("/{link}/comment", post(save_comment))
-            .route("/comment/{id}/delete", post(delete_comment)),
+            .routes(routes!(fetch_issue_list))
+            .routes(routes!(new_issue))
+            .routes(routes!(close_issue))
+            .routes(routes!(reopen_issue))
+            .routes(routes!(issue_detail))
+            .routes(routes!(save_comment))
+            .routes(routes!(delete_comment)),
     )
 }
 
-#[derive(Deserialize)]
+#[derive(Deserialize, ToSchema)]
 pub struct StatusParams {
     pub status: String,
 }
 
+/// Fetch Issue list
+#[utoipa::path(
+    post,
+    path = "/list",
+    request_body = PageParams<StatusParams>,
+    responses(
+        (status = 200, body = CommonResult<CommonPage<IssueItem>>, content_type = "application/json")
+    ),
+    tag = ISSUE_TAG
+)]
 async fn fetch_issue_list(
     state: State<MonoApiServiceState>,
     Json(json): Json<PageParams<StatusParams>>,
@@ -52,6 +61,18 @@ async fn fetch_issue_list(
     Ok(Json(res))
 }
 
+/// Get issue details
+#[utoipa::path(
+    get,
+    params(
+        ("link", description = "Issue link"),
+    ),
+    path = "/{link}/detail",
+    responses(
+        (status = 200, body = CommonResult<String>, content_type = "application/json")
+    ),
+    tag = ISSUE_TAG
+)]
 async fn issue_detail(
     Path(link): Path<String>,
     state: State<MonoApiServiceState>,
@@ -72,15 +93,25 @@ async fn issue_detail(
     Ok(Json(res))
 }
 
+/// New Issue
+#[utoipa::path(
+    post,
+    path = "/new",
+    request_body = NewIssue,
+    responses(
+        (status = 200, body = CommonResult<String>, content_type = "application/json")
+    ),
+    tag = ISSUE_TAG
+)]
 async fn new_issue(
-    user: LoginUser,
+    // user: LoginUser,
     state: State<MonoApiServiceState>,
     Json(json): Json<NewIssue>,
 ) -> Result<Json<CommonResult<String>>, ApiError> {
     let stg = state.issue_stg().clone();
-    let res = stg.save_issue(user.user_id, &json.title).await.unwrap();
+    let res = stg.save_issue(0, &json.title).await.unwrap();
     let res = stg
-        .add_issue_conversation(&res.link, user.user_id, Some(json.description))
+        .add_issue_conversation(&res.link, 0, Some(json.description))
         .await;
     let res = match res {
         Ok(_) => CommonResult::success(None),
@@ -89,8 +120,20 @@ async fn new_issue(
     Ok(Json(res))
 }
 
+/// Close an issue
+#[utoipa::path(
+    post,
+    params(
+        ("link", description = "Issue link"),
+    ),
+    path = "/{link}/close",
+    responses(
+        (status = 200, body = CommonResult<String>, content_type = "application/json")
+    ),
+    tag = ISSUE_TAG
+)]
 async fn close_issue(
-    _: LoginUser,
+    // _: LoginUser,
     Path(link): Path<String>,
     state: State<MonoApiServiceState>,
 ) -> Result<Json<CommonResult<String>>, ApiError> {
@@ -101,8 +144,20 @@ async fn close_issue(
     Ok(Json(res))
 }
 
+/// Reopen an issue
+#[utoipa::path(
+    post,
+    params(
+        ("link", description = "Issue link"),
+    ),
+    path = "/{link}/reopen",
+    responses(
+        (status = 200, body = CommonResult<String>, content_type = "application/json")
+    ),
+    tag = ISSUE_TAG
+)]
 async fn reopen_issue(
-    _: LoginUser,
+    // _: LoginUser,
     Path(link): Path<String>,
     state: State<MonoApiServiceState>,
 ) -> Result<Json<CommonResult<String>>, ApiError> {
@@ -113,17 +168,28 @@ async fn reopen_issue(
     Ok(Json(res))
 }
 
+/// Add new comment on Issue
+#[utoipa::path(
+    post,
+    params(
+        ("link", description = "Issue link"),
+    ),
+    path = "/{link}/comment",
+    request_body = SaveCommentRequest,
+    responses(
+        (status = 200, body = CommonResult<String>, content_type = "application/json")
+    ),
+    tag = ISSUE_TAG
+)]
 async fn save_comment(
-    user: LoginUser,
+    // user: LoginUser,
     Path(link): Path<String>,
     state: State<MonoApiServiceState>,
-    body: Bytes,
+    Json(payload): Json<SaveCommentRequest>,
 ) -> Result<Json<CommonResult<String>>, ApiError> {
-    let json_string =
-        String::from_utf8(body.to_vec()).unwrap_or_else(|_| "Invalid UTF-8".to_string());
     let res = match state
         .issue_stg()
-        .add_issue_conversation(&link, user.user_id, Some(json_string))
+        .add_issue_conversation(&link, 0, Some(payload.content))
         .await
     {
         Ok(_) => CommonResult::success(None),
@@ -132,6 +198,18 @@ async fn save_comment(
     Ok(Json(res))
 }
 
+/// Delete Issue Comment
+#[utoipa::path(
+    delete,
+    params(
+        ("id", description = "Conversation id"),
+    ),
+    path = "/comment/{id}/delete",
+    responses(
+        (status = 200, body = CommonResult<String>, content_type = "application/json")
+    ),
+    tag = ISSUE_TAG
+)]
 async fn delete_comment(
     Path(id): Path<i64>,
     state: State<MonoApiServiceState>,
diff --git a/mono/src/api/issue/mod.rs b/mono/src/api/issue/mod.rs
index e717177e5..18f401bb4 100644
--- a/mono/src/api/issue/mod.rs
+++ b/mono/src/api/issue/mod.rs
@@ -1,11 +1,12 @@
 use callisto::mega_issue;
 use serde::{Deserialize, Serialize};
+use utoipa::ToSchema;
 
 use crate::api::mr::MegaConversation;
 
 pub mod issue_router;
 
-#[derive(Serialize, Deserialize)]
+#[derive(Serialize, Deserialize, ToSchema)]
 pub struct IssueItem {
     pub link: String,
     pub title: String,
@@ -30,7 +31,7 @@ impl From<mega_issue::Model> for IssueItem {
     }
 }
 
-#[derive(Serialize, Deserialize)]
+#[derive(Serialize, Deserialize, ToSchema)]
 pub struct NewIssue {
     pub title: String,
     pub description: String,
diff --git a/mono/src/api/mr/mod.rs b/mono/src/api/mr/mod.rs
index cb0a34853..af7d1b884 100644
--- a/mono/src/api/mr/mod.rs
+++ b/mono/src/api/mr/mod.rs
@@ -4,15 +4,16 @@ use callisto::{
     mega_conversation, mega_mr,
     sea_orm_active_enums::{ConvTypeEnum, MergeStatusEnum},
 };
+use utoipa::ToSchema;
 
 pub mod mr_router;
 
-#[derive(Deserialize)]
+#[derive(Deserialize, ToSchema)]
 pub struct MRStatusParams {
     pub status: String,
 }
 
-#[derive(Serialize, Deserialize)]
+#[derive(Serialize, Deserialize, ToSchema)]
 pub struct MrInfoItem {
     pub link: String,
     pub title: String,
@@ -35,7 +36,7 @@ impl From<mega_mr::Model> for MrInfoItem {
     }
 }
 
-#[derive(Serialize, Deserialize)]
+#[derive(Serialize, Deserialize, ToSchema)]
 pub struct MRDetail {
     pub id: i64,
     pub link: String,
@@ -60,7 +61,7 @@ impl From<mega_mr::Model> for MRDetail {
     }
 }
 
-#[derive(Serialize, Deserialize)]
+#[derive(Serialize, Deserialize, ToSchema)]
 pub struct MegaConversation {
     pub id: i64,
     pub user_id: i64,
@@ -83,14 +84,19 @@ impl From<mega_conversation::Model> for MegaConversation {
     }
 }
 
-#[derive(Serialize, Deserialize)]
+#[derive(Serialize, Deserialize, ToSchema)]
 pub struct FilesChangedItem {
     pub path: String,
     pub status: String,
 }
 
-#[derive(Serialize, Deserialize)]
+#[derive(Serialize, Deserialize, ToSchema)]
 pub struct FilesChangedList {
     pub files: Vec<FilesChangedItem>,
     pub content: String,
 }
+
+#[derive(Deserialize, ToSchema)]
+pub struct SaveCommentRequest {
+    pub content: String,
+}
diff --git a/mono/src/api/mr/mr_router.rs b/mono/src/api/mr/mr_router.rs
index 620a28e6d..3dd98c28f 100644
--- a/mono/src/api/mr/mr_router.rs
+++ b/mono/src/api/mr/mr_router.rs
@@ -2,60 +2,64 @@ use std::collections::HashMap;
 
 use axum::{
     extract::{Path, State},
-    routing::{get, post},
     Json,
 };
-use bytes::Bytes;
-use utoipa_axum::router::OpenApiRouter;
+use utoipa_axum::{router::OpenApiRouter, routes};
 
 use callisto::sea_orm_active_enums::{ConvTypeEnum, MergeStatusEnum};
 use ceres::protocol::mr::MergeRequest;
 use common::model::{CommonPage, CommonResult, PageParams};
-use saturn::ActionEnum;
 
-use crate::api::error::ApiError;
-use crate::api::mr::{FilesChangedItem, FilesChangedList, MRDetail, MRStatusParams, MrInfoItem};
-use crate::api::oauth::model::LoginUser;
-use crate::api::util;
+use crate::api::mr::{
+    FilesChangedItem, FilesChangedList, MRDetail, MRStatusParams, MrInfoItem, SaveCommentRequest,
+};
 use crate::api::MonoApiServiceState;
+use crate::{api::error::ApiError, server::https_server::MR_TAG};
 
 pub fn routers() -> OpenApiRouter<MonoApiServiceState> {
     OpenApiRouter::new().nest(
         "/mr",
         OpenApiRouter::new()
-            .route("/list", post(fetch_mr_list))
-            .route("/{link}/detail", get(mr_detail))
-            .route("/{link}/merge", post(merge))
-            .route("/{link}/close", post(close_mr))
-            .route("/{link}/reopen", post(reopen_mr))
-            .route("/{link}/files-changed", get(get_mr_files_changed))
-            .route("/{link}/comment", post(save_comment))
-            .route("/comment/{conv_id}/delete", post(delete_comment)),
+            .routes(routes!(fetch_mr_list))
+            .routes(routes!(mr_detail))
+            .routes(routes!(merge))
+            .routes(routes!(close_mr))
+            .routes(routes!(reopen_mr))
+            .routes(routes!(get_mr_files_changed))
+            .routes(routes!(save_comment))
+            .routes(routes!(delete_comment)),
     )
 }
 
+/// Reopen Merge Request
+#[utoipa::path(
+    post,
+    params(
+        ("link", description = "MR link"),
+    ),
+    path = "/{link}/reopen",
+    responses(
+        (status = 200, body = CommonResult<String>, content_type = "application/json")
+    ),
+    tag = MR_TAG
+)]
 async fn reopen_mr(
-    user: LoginUser,
     Path(link): Path<String>,
     state: State<MonoApiServiceState>,
 ) -> Result<Json<CommonResult<String>>, ApiError> {
     if let Some(model) = state.mr_stg().get_mr(&link).await.unwrap() {
         if model.status == MergeStatusEnum::Closed {
-            util::check_permissions(
-                &user.name,
-                &model.path,
-                ActionEnum::EditMergeRequest,
-                state.clone(),
-            )
-            .await
-            .unwrap();
+            // util::check_permissions(
+            //     &user.name,
+            //     &model.path,
+            //     ActionEnum::EditMergeRequest,
+            //     state.clone(),
+            // )
+            // .await
+            // .unwrap();
             let mut mr: MergeRequest = model.into();
             mr.status = MergeStatusEnum::Open;
-            let res = match state
-                .mr_stg()
-                .reopen_mr(mr.into(), user.user_id, &user.name)
-                .await
-            {
+            let res = match state.mr_stg().reopen_mr(mr.into(), 0, "admin").await {
                 Ok(_) => CommonResult::success(None),
                 Err(err) => CommonResult::failed(&err.to_string()),
             };
@@ -65,28 +69,36 @@ async fn reopen_mr(
     Ok(Json(CommonResult::failed("not found")))
 }
 
+/// Close Merge Request
+#[utoipa::path(
+    post,
+    params(
+        ("link", description = "MR link"),
+    ),
+    path = "/{link}/close",
+    responses(
+        (status = 200, body = CommonResult<String>, content_type = "application/json")
+    ),
+    tag = MR_TAG
+)]
 async fn close_mr(
-    user: LoginUser,
+    // user: LoginUser,
     Path(link): Path<String>,
     state: State<MonoApiServiceState>,
 ) -> Result<Json<CommonResult<String>>, ApiError> {
     if let Some(model) = state.mr_stg().get_mr(&link).await.unwrap() {
         if model.status == MergeStatusEnum::Open {
-            util::check_permissions(
-                &user.name,
-                &model.path,
-                ActionEnum::EditMergeRequest,
-                state.clone(),
-            )
-            .await
-            .unwrap();
+            // util::check_permissions(
+            //     &user.name,
+            //     &model.path,
+            //     ActionEnum::EditMergeRequest,
+            //     state.clone(),
+            // )
+            // .await
+            // .unwrap();
             let mut mr: MergeRequest = model.into();
             mr.status = MergeStatusEnum::Closed;
-            let res = match state
-                .mr_stg()
-                .close_mr(mr.into(), user.user_id, &user.name)
-                .await
-            {
+            let res = match state.mr_stg().close_mr(mr.into(), 0, "admin").await {
                 Ok(_) => CommonResult::success(None),
                 Err(err) => CommonResult::failed(&err.to_string()),
             };
@@ -96,22 +108,34 @@ async fn close_mr(
     Ok(Json(CommonResult::failed("not found")))
 }
 
+/// Approve Merge Request
+#[utoipa::path(
+    post,
+    params(
+        ("link", description = "MR link"),
+    ),
+    path = "/{link}/merge",
+    responses(
+        (status = 200, body = CommonResult<String>, content_type = "application/json")
+    ),
+    tag = MR_TAG
+)]
 async fn merge(
-    user: LoginUser,
+    // user: LoginUser,
     Path(link): Path<String>,
     state: State<MonoApiServiceState>,
 ) -> Result<Json<CommonResult<String>>, ApiError> {
     if let Some(model) = state.mr_stg().get_mr(&link).await.unwrap() {
         if model.status == MergeStatusEnum::Open {
-            let path = model.path.clone();
-            util::check_permissions(
-                &user.name,
-                &path,
-                ActionEnum::ApproveMergeRequest,
-                state.clone(),
-            )
-            .await
-            .unwrap();
+            // let path = model.path.clone();
+            // util::check_permissions(
+            //     &user.name,
+            //     &path,
+            //     ActionEnum::ApproveMergeRequest,
+            //     state.clone(),
+            // )
+            // .await
+            // .unwrap();
             let res = state.monorepo().merge_mr(&mut model.into()).await;
             let res = match res {
                 Ok(_) => CommonResult::success(None),
@@ -123,6 +147,16 @@ async fn merge(
     Ok(Json(CommonResult::failed("not found")))
 }
 
+/// Fetch MR list
+#[utoipa::path(
+    post,
+    path = "/list",
+    request_body = PageParams<MRStatusParams>,
+    responses(
+        (status = 200, body = CommonResult<CommonPage<MrInfoItem>>, content_type = "application/json")
+    ),
+    tag = MR_TAG
+)]
 async fn fetch_mr_list(
     state: State<MonoApiServiceState>,
     Json(json): Json<PageParams<MRStatusParams>>,
@@ -153,6 +187,18 @@ async fn fetch_mr_list(
     Ok(Json(res))
 }
 
+/// Get merge request details
+#[utoipa::path(
+    get,
+    params(
+        ("link", description = "MR link"),
+    ),
+    path = "/{link}/detail",
+    responses(
+        (status = 200, body = CommonResult<MRDetail>, content_type = "application/json")
+    ),
+    tag = MR_TAG
+)]
 async fn mr_detail(
     Path(link): Path<String>,
     state: State<MonoApiServiceState>,
@@ -173,6 +219,18 @@ async fn mr_detail(
     Ok(Json(res))
 }
 
+/// Get Merge Request file changed list
+#[utoipa::path(
+    get,
+    params(
+        ("link", description = "MR link"),
+    ),
+    path = "/{link}/files-changed",
+    responses(
+        (status = 200, body = CommonResult<FilesChangedList>, content_type = "application/json")
+    ),
+    tag = MR_TAG
+)]
 async fn get_mr_files_changed(
     Path(link): Path<String>,
     state: State<MonoApiServiceState>,
@@ -197,24 +255,29 @@ async fn get_mr_files_changed(
     Ok(Json(res))
 }
 
+/// Add new comment on Merge Request
+#[utoipa::path(
+    post,
+    params(
+        ("link", description = "MR link"),
+    ),
+    path = "/{link}/comment",
+    request_body = SaveCommentRequest,
+    responses(
+        (status = 200, body = CommonResult<String>, content_type = "application/json")
+    ),
+    tag = MR_TAG
+)]
 async fn save_comment(
-    user: LoginUser,
+    // user: LoginUser,
     Path(link): Path<String>,
     state: State<MonoApiServiceState>,
-    body: Bytes,
+    Json(payload): Json<SaveCommentRequest>,
 ) -> Result<Json<CommonResult<String>>, ApiError> {
-    let json_string =
-        String::from_utf8(body.to_vec()).unwrap_or_else(|_| "Invalid UTF-8".to_string());
-
     let res = if let Some(model) = state.mr_stg().get_mr(&link).await.unwrap() {
         state
             .mr_stg()
-            .add_mr_conversation(
-                &model.link,
-                user.user_id,
-                ConvTypeEnum::Comment,
-                Some(json_string),
-            )
+            .add_mr_conversation(&model.link, 0, ConvTypeEnum::Comment, Some(payload.content))
             .await
             .unwrap();
         CommonResult::success(None)
@@ -224,6 +287,18 @@ async fn save_comment(
     Ok(Json(res))
 }
 
+/// Delete Comment
+#[utoipa::path(
+    delete,
+    params(
+        ("conv_id", description = "Conversation id"),
+    ),
+    path = "/comment/{conv_id}/delete",
+    responses(
+        (status = 200, body = CommonResult<String>, content_type = "application/json")
+    ),
+    tag = MR_TAG
+)]
 async fn delete_comment(
     Path(conv_id): Path<i64>,
     state: State<MonoApiServiceState>,
diff --git a/mono/src/server/https_server.rs b/mono/src/server/https_server.rs
index 9d600b96e..cf7f040ff 100644
--- a/mono/src/server/https_server.rs
+++ b/mono/src/server/https_server.rs
@@ -179,6 +179,7 @@ pub async fn post_method_router(
 
 pub const GIT_TAG: &str = "git";
 pub const MR_TAG: &str = "merge_request";
+pub const ISSUE_TAG: &str = "issue";
 #[derive(OpenApi)]
 #[openapi(
     tags(
diff --git a/sql/README.md b/sql/README.md
deleted file mode 100644
index 9c38abb45..000000000
--- a/sql/README.md
+++ /dev/null
@@ -1,57 +0,0 @@
-# SQL File Update Guide
-
-Whenever making any updates to the SQL content in the project, **make sure to also update** both the `pg_YYYYMMDD__init.sql`, `sqlite_YYYYMMDD__init.sql` files, and the **Dockerfile**. These files are used to initialize the database for PostgreSQL and SQLite respectively, ensuring that SQL changes are properly applied across different environments. Failing to update these files may lead to database inconsistencies, disrupting the system’s operation.
-
-## Filename Date Convention
-
-The middle part of the filename (`YYYYMMDD`, e.g., `20240205` in `pg_20240205__init.sql`) represents the **date of the last modification**. When updating these SQL files, you must update this date to the **current modification date**. This ensures that the file accurately reflects when the last changes were made, aiding in version control and troubleshooting.
-
-For example, if you make modifications on September 5, 2024, the filenames should be updated to:
-- `pg_20240905__init.sql`
-- `sqlite_20240905__init.sql`
-
-## Dockerfile Update
-
-Mega's Docker setup relies on these SQL files for initializing the database, you **must also update the `Dockerfile`** to ensure the new SQL initialization files are copied and applied correctly. Make sure the Docker build includes the latest `pg_YYYYMMDD__init.sql` and `sqlite_YYYYMMDD__init.sql` filenames and paths, reflecting the current modification date.
-
-For example, update the `Dockerfile` to reference the newly updated filenames:
-
-```Dockerfile
-# PostgreSQL initialization
-COPY pg_20240905__init.sql /docker-entrypoint-initdb.d/
-
-# SQLite initialization
-COPY sqlite_20240905__init.sql /app/sqlite/
-```
-
-## Update Process
-
-1. **Modify SQL Statements**  
-   When modifying the database structure (such as tables, indexes, constraints, etc.) or data, first make the changes in the corresponding SQL file in the project.
-
-2. **Sync Changes to `pg_YYYYMMDD__init.sql`, `sqlite_YYYYMMDD__init.sql`, and the Dockerfile**  
-   Apply the SQL changes to both initialization files:
-   - `pg_YYYYMMDD__init.sql` for PostgreSQL
-   - `sqlite_YYYYMMDD__init.sql` for SQLite
-   
-   Update the `YYYYMMDD` part of the filename to reflect the current date of modification. Additionally, ensure that the `Dockerfile` is updated to reference the new SQL files.
-
-3. **Test Database Migration**  
-   Ensure the updated SQL files and the new `Dockerfile` are applied in the development and test environments. Verify that the database changes are successful for both PostgreSQL and SQLite.
-
-4. **Commit and Update Documentation**  
-   When committing your code, ensure the updates to both `pg_YYYYMMDD__init.sql`, `sqlite_YYYYMMDD__init.sql`, and the `Dockerfile` are included, with the correct date in the filenames, and document the related database changes in the project’s change log.
-
-## Example
-
-For instance, if you add a new table to the project:
-
-```sql
-CREATE TABLE users (
-    id SERIAL PRIMARY KEY,
-    name VARCHAR(100),
-    email VARCHAR(100) UNIQUE
-);
-```
-
-You need to add this SQL to both the `pg_YYYYMMDD__init.sql` and `sqlite_YYYYMMDD__init.sql` files, adapting the SQL syntax as needed for each database system. If the modification is made on September 5, 2024, the filenames should be updated to `pg_20240905__init.sql` and `sqlite_20240905__init.sql`. Update the `Dockerfile` to reference these new filenames for PostgreSQL and SQLite initialization.
diff --git a/sql/postgres/pg_20241204__init.sql b/sql/postgres/pg_20241204__init.sql
deleted file mode 100644
index a17844030..000000000
--- a/sql/postgres/pg_20241204__init.sql
+++ /dev/null
@@ -1,324 +0,0 @@
-CREATE TABLE IF NOT EXISTS "mega_commit" (
-  "id" BIGINT PRIMARY KEY,
-  "commit_id" VARCHAR(40) NOT NULL,
-  "tree" VARCHAR(40) NOT NULL,
-  "parents_id" JSON NOT NULL,  -- for compatibility with sqlite, DO NOT use Array Type
-  "author" TEXT,
-  "committer" TEXT,
-  "content" TEXT,
-  "created_at" TIMESTAMP NOT NULL,
-  CONSTRAINT uniq_mc_git_id UNIQUE (commit_id)
-);
-CREATE INDEX "idx_mc_git_id" ON "mega_commit" ("commit_id");
-CREATE TABLE IF NOT EXISTS "mega_tree" (
-  "id" BIGINT PRIMARY KEY,
-  "tree_id" VARCHAR(40) NOT NULL,
-  "sub_trees" BYTEA NOT NULL,
-  "size" INT NOT NULL,
-  "commit_id" VARCHAR(40) NOT NULL,
-  "created_at" TIMESTAMP NOT NULL
-);
-CREATE INDEX "idx_mt_git_id" ON "mega_tree" ("tree_id");
-CREATE TABLE IF NOT EXISTS "mega_blob" (
-  "id" BIGINT PRIMARY KEY,
-  "blob_id" VARCHAR(40) NOT NULL,
-  "commit_id" VARCHAR(40) NOT NULL,
-  "name" TEXT NOT NULL,
-  "size" INT NOT NULL,
-  "created_at" TIMESTAMP NOT NULL
-);
-CREATE INDEX "idx_mb_git_id" ON "mega_blob" ("blob_id");
-CREATE TABLE IF NOT EXISTS "mega_tag" (
-  "id" BIGINT PRIMARY KEY,
-  "tag_id" VARCHAR(40) NOT NULL,
-  "object_id" VARCHAR(40) NOT NULL,
-  "object_type" VARCHAR(20) NOT NULL,
-  "tag_name" TEXT NOT NULL,
-  "tagger" TEXT NOT NULL,
-  "message" TEXT NOT NULL,
-  "created_at" TIMESTAMP NOT NULL,
-  CONSTRAINT uniq_mtag_tag_id UNIQUE (tag_id)
-);
-CREATE TABLE IF NOT EXISTS "mega_mr" (
-  "id" BIGINT PRIMARY KEY,
-  "link" VARCHAR(40) NOT NULL,
-  "title" TEXT NOT NULL,
-  "merge_date" TIMESTAMP,
-  "status" VARCHAR(20) NOT NULL,
-  "path" TEXT NOT NULL,
-  "from_hash" VARCHAR(40) NOT NULL,
-  "to_hash" VARCHAR(40) NOT NULL,
-  "created_at" TIMESTAMP NOT NULL,
-  "updated_at" TIMESTAMP NOT NULL
-);
-CREATE INDEX "idx_mr_path" ON "mega_mr" ("path");
-
-CREATE TABLE IF NOT EXISTS "mega_conversation" (
-  "id" BIGINT PRIMARY KEY,
-  "link" VARCHAR(20) NOT NULL,
-  "user_id" BIGINT NOT NULL,
-  "conv_type"  VARCHAR(20) NOT NULL,
-  "comment" TEXT,
-  "created_at" TIMESTAMP NOT NULL,
-  "updated_at" TIMESTAMP NOT NULL
-);
-CREATE INDEX "idx_conversation" ON "mega_conversation" ("link");
-
-
-CREATE TABLE IF NOT EXISTS "mega_issue" (
-  "id" BIGINT PRIMARY KEY,
-  "link"  VARCHAR(20) NOT NULL,
-  "title" VARCHAR(255) NOT NULL,
-  "owner" BIGINT NOT NULL,
-  "status" VARCHAR(20) NOT NULL,
-  "created_at" TIMESTAMP NOT NULL,
-  "updated_at" TIMESTAMP NOT NULL,
-  "closed_at" TIMESTAMP DEFAULT NULL
-);
-CREATE INDEX "idx_issue" ON "mega_issue" ("link");
-
-CREATE TABLE IF NOT EXISTS "mega_refs" (
-  "id" BIGINT PRIMARY KEY,
-  "path" TEXT NOT NULL,
-  "ref_name" TEXT NOT NULL,
-  "ref_commit_hash" VARCHAR(40) NOT NULL,
-  "ref_tree_hash" VARCHAR(40) NOT NULL,
-  "created_at" TIMESTAMP NOT NULL,
-  "updated_at" TIMESTAMP NOT NULL,
-  CONSTRAINT uniq_mref_path UNIQUE (path, ref_name)
-);
-CREATE TABLE IF NOT EXISTS "import_refs" (
-  "id" BIGINT PRIMARY KEY,
-  "repo_id" BIGINT NOT NULL,
-  "ref_name" TEXT NOT NULL,
-  "ref_git_id" VARCHAR(40) NOT NULL,
-  "ref_type" VARCHAR(20) NOT NULL,
-  "default_branch" BOOLEAN NOT NULL,
-  "created_at" TIMESTAMP NOT NULL,
-  "updated_at" TIMESTAMP NOT NULL,
-  CONSTRAINT uniq_ref_path_name UNIQUE (repo_id, ref_name)
-);
-CREATE INDEX "idx_refs_repo_id" ON "import_refs" ("repo_id");
-CREATE TABLE IF NOT EXISTS "git_repo" (
-  "id" BIGINT PRIMARY KEY,
-  "repo_path" TEXT NOT NULL,
-  "repo_name" TEXT NOT NULL,
-  "created_at" TIMESTAMP NOT NULL,
-  "updated_at" TIMESTAMP NOT NULL,
-  CONSTRAINT uniq_ir_path UNIQUE (repo_path)
-);
-CREATE INDEX "idx_ir_repo_path" ON "git_repo" ("repo_path");
-CREATE TABLE IF NOT EXISTS "git_commit" (
-  "id" BIGINT PRIMARY KEY,
-  "repo_id" BIGINT NOT NULL,
-  "commit_id" VARCHAR(40) NOT NULL,
-  "tree" VARCHAR(40) NOT NULL,
-  "parents_id" JSON NOT NULL,
-  "author" TEXT,
-  "committer" TEXT,
-  "content" TEXT,
-  "created_at" TIMESTAMP NOT NULL,
-  CONSTRAINT uniq_c_git_repo_id UNIQUE (repo_id, commit_id)
-);
-CREATE INDEX "idx_ic_git_id" ON "git_commit" ("commit_id");
-CREATE INDEX "idx_ic_repo_id" ON "git_commit" ("repo_id");
-CREATE TABLE IF NOT EXISTS "git_tree" (
-  "id" BIGINT PRIMARY KEY,
-  "repo_id" BIGINT NOT NULL,
-  "tree_id" VARCHAR(40) NOT NULL,
-  "sub_trees" BYTEA NOT NULL,
-  "size" INT NOT NULL,
-  "commit_id" VARCHAR(40) NOT NULL,
-  "created_at" TIMESTAMP NOT NULL,
-  CONSTRAINT uniq_t_git_repo UNIQUE (repo_id, tree_id)
-);
-CREATE INDEX "idx_t_git_id" ON "git_tree" ("tree_id");
-CREATE INDEX "idx_t_repo_id" ON "git_tree" ("repo_id");
-CREATE TABLE IF NOT EXISTS "git_blob" (
-  "id" BIGINT PRIMARY KEY,
-  "repo_id" BIGINT NOT NULL,
-  "blob_id" VARCHAR(40) NOT NULL,
-  "name" VARCHAR(128),
-  "size" INT NOT NULL,
-  "commit_id" VARCHAR(40) NOT NULL,
-  "created_at" TIMESTAMP NOT NULL,
-  CONSTRAINT uniq_b_git_repo UNIQUE (repo_id, blob_id)
-);
-CREATE INDEX "idx_b_git_id" ON "git_blob" ("blob_id");
-CREATE TABLE IF NOT EXISTS "git_tag" (
-  "id" BIGINT PRIMARY KEY,
-  "repo_id" BIGINT NOT NULL,
-  "tag_id" VARCHAR(40) NOT NULL,
-  "object_id" VARCHAR(40) NOT NULL,
-  "object_type" VARCHAR(20) NOT NULL,
-  "tag_name" TEXT NOT NULL,
-  "tagger" TEXT NOT NULL,
-  "message" TEXT NOT NULL,
-  "created_at" TIMESTAMP NOT NULL,
-  CONSTRAINT uniq_gtag_tag_id UNIQUE (tag_id)
-);
-CREATE TABLE IF NOT EXISTS "raw_blob" (
-  "id" BIGINT PRIMARY KEY,
-  "sha1" VARCHAR(40) NOT NULL,
-  "content" TEXT,
-  "file_type" VARCHAR(20),
-  "storage_type" VARCHAR(20) NOT NULL,
-  "data" BYTEA,
-  "local_path" TEXT,
-  "remote_url" TEXT,
-  "created_at" TIMESTAMP NOT NULL,
-  CONSTRAINT uniq_rb_sha1 UNIQUE (sha1)
-);
-CREATE INDEX "idx_rb_sha1" ON "raw_blob" ("sha1");
-CREATE TABLE IF NOT EXISTS "git_pr" (
-  "id" BIGINT PRIMARY KEY,
-  "number" BIGINT NOT NULL,
-  "title" VARCHAR(255) NOT NULL,
-  "state" VARCHAR(255) NOT NULL,
-  "created_at" TIMESTAMP NOT NULL,
-  "updated_at" TIMESTAMP NOT NULL,
-  "closed_at" TIMESTAMP DEFAULT NULL,
-  "merged_at" TIMESTAMP DEFAULT NULL,
-  "merge_commit_sha" VARCHAR(200) DEFAULT NULL,
-  "repo_id" BIGINT NOT NULL,
-  "sender_name" VARCHAR(255) NOT NULL,
-  "sender_id" BIGINT NOT NULL,
-  "user_name" VARCHAR(255) NOT NULL,
-  "user_id" BIGINT NOT NULL,
-  "commits_url" VARCHAR(255) NOT NULL,
-  "patch_url" VARCHAR(255) NOT NULL,
-  "head_label" VARCHAR(255) NOT NULL,
-  "head_ref" VARCHAR(255) NOT NULL,
-  "base_label" VARCHAR(255) NOT NULL,
-  "base_ref" VARCHAR(255) NOT NULL
-);
-CREATE TABLE IF NOT EXISTS "git_issue" (
-  "id" BIGINT PRIMARY KEY,
-  "number" BIGINT NOT NULL,
-  "title" VARCHAR(255) NOT NULL,
-  "sender_name" VARCHAR(255) NOT NULL,
-  "sender_id" BIGINT NOT NULL,
-  "state" VARCHAR(255) NOT NULL,
-  "created_at" TIMESTAMP NOT NULL,
-  "updated_at" TIMESTAMP NOT NULL,
-  "closed_at" TIMESTAMP DEFAULT NULL,
-  "repo_id" BIGINT NOT NULL
-);
-CREATE TABLE IF NOT EXISTS "lfs_locks" (
-  "id" VARCHAR(40) PRIMARY KEY,
-  "data" TEXT NOT NULL
-);
-CREATE TABLE IF NOT EXISTS "lfs_objects" (
-  "oid" VARCHAR(64) PRIMARY KEY,
-  "size" BIGINT NOT NULL,
-  "exist" BOOLEAN NOT NULL,
-  "splited" BOOLEAN NOT NULL
-);
-CREATE TABLE IF NOT EXISTS "lfs_split_relations" (
-    "ori_oid" VARCHAR(64) NOT NULL,
-    "sub_oid" VARCHAR(64) NOT NULL,
-    "offset" BIGINT NOT NULL,
-    "size" BIGINT NOT NULL,
-    PRIMARY KEY ("ori_oid", "sub_oid", "offset")
-);
-
-CREATE TABLE IF NOT EXISTS "relay_node" (
-  "peer_id" VARCHAR(64) PRIMARY KEY,
-  "type" VARCHAR(64),
-  "online" BOOLEAN NOT NULL,
-  "last_online_time" BIGINT NOT NULL
-);
-
-CREATE TABLE IF NOT EXISTS "relay_repo_info" (
-  "identifier" VARCHAR(128) PRIMARY KEY,
-  "name" VARCHAR(64),
-  "origin" VARCHAR(64),
-  "update_time" BIGINT NOT NULL,
-  "commit" VARCHAR(64)
-);
-
-CREATE TABLE IF NOT EXISTS "relay_lfs_info" (
-  "id" BIGINT PRIMARY KEY,
-  "file_hash" VARCHAR(256),
-  "hash_type" VARCHAR(64),
-  "file_size" BIGINT NOT NULL,
-  "creation_time" BIGINT NOT NULL,
-  "peer_id" VARCHAR(64),
-  "origin" VARCHAR(256)
-);
-
-CREATE TABLE IF NOT EXISTS "relay_nostr_event" (
-  "id" VARCHAR(128) PRIMARY KEY,
-  "pubkey" VARCHAR(128),
-  "created_at" BIGINT NOT NULL,
-  "kind" INT,
-  "tags" TEXT,
-  "content" TEXT,
-  "sig" VARCHAR(256)
-);
-
-CREATE TABLE IF NOT EXISTS "relay_nostr_req" (
-  "id" VARCHAR(128) PRIMARY KEY,
-  "subscription_id" VARCHAR(128),
-  "filters" TEXT
-);
-
-CREATE TABLE IF NOT EXISTS "mq_storage" (
-  "id" BIGINT PRIMARY KEY,
-  "category" VARCHAR(64),
-  "create_time" TIMESTAMP NOT NULL,
-  "content" TEXT
-);
-
-CREATE TABLE IF NOT EXISTS "relay_path_mapping" (
-  "id" BIGINT PRIMARY KEY,
-  "alias" TEXT NOT NULL,
-  "repo_path" TEXT NOT NULL,
-  "created_at" TIMESTAMP NOT NULL,
-  "updated_at" TIMESTAMP NOT NULL,
-  CONSTRAINT uniq_alias UNIQUE (alias)
-);
-
-CREATE TABLE IF NOT EXISTS "user" (
-  "id" BIGINT PRIMARY KEY,
-  "name" TEXT NOT NULL,
-  "email" TEXT NOT NULL,
-  "avatar_url" TEXT NOT NULL,
-  "is_github" BOOLEAN NOT NULL,
-  "created_at" TIMESTAMP NOT NULL,
-  "updated_at" TIMESTAMP,
-  CONSTRAINT uniq_email UNIQUE (email)
-);
-
-CREATE TABLE IF NOT EXISTS "ssh_keys" (
-  "id" BIGINT PRIMARY KEY,
-  "user_id" BIGINT NOT NULL,
-  "title" TEXT NOT NULL,
-  "ssh_key" TEXT NOT NULL,
-  "finger" TEXT NOT NULL,
-  "created_at" TIMESTAMP NOT NULL
-);
-CREATE INDEX "idx_user_id" ON "ssh_keys" ("user_id");
-CREATE INDEX "idx_ssh_key_finger" ON "ssh_keys" ((left(finger, 8)));
-
-
-CREATE TABLE IF NOT EXISTS "access_token" (
-  "id" BIGINT PRIMARY KEY,
-  "user_id" BIGINT NOT NULL,
-  "token" TEXT NOT NULL,
-  "created_at" TIMESTAMP NOT NULL
-);
-CREATE INDEX "idx_token_user_id" ON "access_token" ("user_id");
-CREATE INDEX "idx_token" ON "access_token" ((left(token, 8)));
-
-
-CREATE TABLE IF NOT EXISTS "builds" (
-  "build_id" uuid NOT NULL PRIMARY KEY,
-  "output_file" varchar NOT NULL,
-  "exit_code" integer,
-  "start_at" timestamp with time zone NOT NULL,
-  "end_at" timestamp with time zone NOT NULL,
-  "repo_name" varchar NOT NULL,
-  "target" varchar NOT NULL,
-  "arguments" varchar NOT NULL
-);
\ No newline at end of file
diff --git a/sql/sqlite/sqlite_20241204_init.sql b/sql/sqlite/sqlite_20241204_init.sql
deleted file mode 100644
index f638547f8..000000000
--- a/sql/sqlite/sqlite_20241204_init.sql
+++ /dev/null
@@ -1,310 +0,0 @@
-CREATE TABLE IF NOT EXISTS "mega_commit" (
-  "id" INTEGER PRIMARY KEY,
-  "commit_id" TEXT NOT NULL,
-  "tree" TEXT NOT NULL,
-  "parents_id" TEXT NOT NULL,  -- Use JSON to store array
-  "author" TEXT,
-  "committer" TEXT,
-  "content" TEXT,
-  "created_at" TEXT NOT NULL,
-  CONSTRAINT uniq_mc_git_id UNIQUE (commit_id)
-);
-CREATE INDEX "idx_mc_git_id" ON "mega_commit" ("commit_id");
-CREATE TABLE IF NOT EXISTS "mega_tree" (
-  "id" INTEGER PRIMARY KEY,
-  "tree_id" TEXT NOT NULL,
-  "sub_trees" BLOB NOT NULL,
-  "size" INTEGER NOT NULL,
-  "commit_id" TEXT NOT NULL,
-  "created_at" TEXT NOT NULL
-);
-CREATE INDEX "idx_mt_git_id" ON "mega_tree" ("tree_id");
-CREATE TABLE IF NOT EXISTS "mega_blob" (
-  "id" INTEGER PRIMARY KEY,
-  "blob_id" TEXT NOT NULL,
-  "commit_id" TEXT NOT NULL,
-  "name" TEXT NOT NULL,
-  "size" INTEGER NOT NULL,
-  "created_at" TEXT NOT NULL
-);
-CREATE INDEX "idx_mb_git_id" ON "mega_blob" ("blob_id");
-CREATE TABLE IF NOT EXISTS "mega_tag" (
-  "id" INTEGER PRIMARY KEY,
-  "tag_id" TEXT NOT NULL,
-  "object_id" TEXT NOT NULL,
-  "object_type" TEXT NOT NULL,
-  "tag_name" TEXT NOT NULL,
-  "tagger" TEXT NOT NULL,
-  "message" TEXT NOT NULL,
-  "created_at" TEXT NOT NULL,
-  CONSTRAINT uniq_mtag_tag_id UNIQUE (tag_id)
-);
-CREATE TABLE IF NOT EXISTS "mega_mr" (
-  "id" INTEGER PRIMARY KEY,
-  "link" TEXT NOT NULL,
-  "title" TEXT NOT NULL,
-  "merge_date" TEXT,
-  "status" TEXT NOT NULL,
-  "path" TEXT NOT NULL,
-  "from_hash" TEXT NOT NULL,
-  "to_hash" TEXT NOT NULL,
-  "created_at" TEXT NOT NULL,
-  "updated_at" TEXT NOT NULL
-);
-CREATE INDEX "idx_mr_path" ON "mega_mr" ("path");
-
-CREATE TABLE IF NOT EXISTS "mega_conversation" (
-  "id" INTEGER PRIMARY KEY,
-  "link" INTEGER NOT NULL,
-  "user_id" INTEGER NOT NULL,
-  "conv_type" TEXT NOT NULL,
-  "comment" TEXT,
-  "created_at" TEXT NOT NULL,
-  "updated_at" TEXT NOT NULL
-);
-CREATE INDEX "idx_conversation" ON "mega_conversation" ("link");
-
-CREATE TABLE IF NOT EXISTS "mega_issue" (
-  "id" INTEGER PRIMARY KEY,
-  "number" INTEGER NOT NULL,
-  "title" TEXT NOT NULL,
-  "sender_name" TEXT NOT NULL,
-  "sender_id" INTEGER NOT NULL,
-  "state" TEXT NOT NULL,
-  "created_at" TEXT NOT NULL,
-  "updated_at" TEXT NOT NULL,
-  "closed_at" TEXT DEFAULT NULL
-);
-CREATE TABLE IF NOT EXISTS "mega_refs" (
-  "id" INTEGER PRIMARY KEY,
-  "path" TEXT NOT NULL,
-  "ref_name" TEXT NOT NULL,
-  "ref_commit_hash" TEXT NOT NULL,
-  "ref_tree_hash" TEXT NOT NULL,
-  "created_at" TEXT NOT NULL,
-  "updated_at" TEXT NOT NULL,
-  "is_mr" BOOLEAN NOT NULL DEFAULT false,
-  CONSTRAINT uniq_mref_path UNIQUE (path, ref_name)
-);
-CREATE TABLE IF NOT EXISTS "import_refs" (
-  "id" INTEGER PRIMARY KEY,
-  "repo_id" INTEGER NOT NULL,
-  "ref_name" TEXT NOT NULL,
-  "ref_git_id" TEXT NOT NULL,
-  "ref_type" TEXT NOT NULL,
-  "default_branch" INTEGER NOT NULL,
-  "created_at" TEXT NOT NULL,
-  "updated_at" TEXT NOT NULL,
-  CONSTRAINT uniq_ref_path_name UNIQUE (repo_id, ref_name)
-);
-CREATE INDEX "idx_refs_repo_id" ON "import_refs" ("repo_id");
-CREATE TABLE IF NOT EXISTS "git_repo" (
-  "id" INTEGER PRIMARY KEY,
-  "repo_path" TEXT NOT NULL,
-  "repo_name" TEXT NOT NULL,
-  "created_at" TEXT NOT NULL,
-  "updated_at" TEXT NOT NULL,
-  CONSTRAINT uniq_ir_path UNIQUE (repo_path)
-);
-CREATE INDEX "idx_ir_repo_path" ON "git_repo" ("repo_path");
-CREATE TABLE IF NOT EXISTS "git_commit" (
-  "id" INTEGER PRIMARY KEY,
-  "repo_id" INTEGER NOT NULL,
-  "commit_id" TEXT NOT NULL,
-  "tree" TEXT NOT NULL,
-  "parents_id" TEXT NOT NULL,  -- Use JSON to store array
-  "author" TEXT,
-  "committer" TEXT,
-  "content" TEXT,
-  "created_at" TEXT NOT NULL,
-  CONSTRAINT uniq_c_git_repo_id UNIQUE (repo_id, commit_id)
-);
-CREATE INDEX "idx_ic_git_id" ON "git_commit" ("commit_id");
-CREATE INDEX "idx_ic_repo_id" ON "git_commit" ("repo_id");
-CREATE TABLE IF NOT EXISTS "git_tree" (
-  "id" INTEGER PRIMARY KEY,
-  "repo_id" INTEGER NOT NULL,
-  "tree_id" TEXT NOT NULL,
-  "sub_trees" BLOB NOT NULL,
-  "size" INTEGER NOT NULL,
-  "commit_id" TEXT NOT NULL,
-  "created_at" TEXT NOT NULL,
-  CONSTRAINT uniq_t_git_repo UNIQUE (repo_id, tree_id)
-);
-CREATE INDEX "idx_t_git_id" ON "git_tree" ("tree_id");
-CREATE INDEX "idx_t_repo_id" ON "git_tree" ("repo_id");
-CREATE TABLE IF NOT EXISTS "git_blob" (
-  "id" INTEGER PRIMARY KEY,
-  "repo_id" INTEGER NOT NULL,
-  "blob_id" TEXT NOT NULL,
-  "name" TEXT,
-  "size" INTEGER NOT NULL,
-  "commit_id" TEXT NOT NULL,
-  "created_at" TEXT NOT NULL,
-  CONSTRAINT uniq_b_git_repo UNIQUE (repo_id, blob_id)
-);
-CREATE INDEX "idx_b_git_id" ON "git_blob" ("blob_id");
-CREATE TABLE IF NOT EXISTS "git_tag" (
-  "id" INTEGER PRIMARY KEY,
-  "repo_id" INTEGER NOT NULL,
-  "tag_id" TEXT NOT NULL,
-  "object_id" TEXT NOT NULL,
-  "object_type" TEXT NOT NULL,
-  "tag_name" TEXT NOT NULL,
-  "tagger" TEXT NOT NULL,
-  "message" TEXT NOT NULL,
-  "created_at" TEXT NOT NULL,
-  CONSTRAINT uniq_gtag_tag_id UNIQUE (tag_id)
-);
-CREATE TABLE IF NOT EXISTS "raw_blob" (
-  "id" INTEGER PRIMARY KEY,
-  "sha1" TEXT NOT NULL,
-  "content" TEXT,
-  "file_type" TEXT,
-  "storage_type" TEXT NOT NULL,
-  "data" BLOB,
-  "local_path" TEXT,
-  "remote_url" TEXT,
-  "created_at" TEXT NOT NULL,
-  CONSTRAINT uniq_rb_sha1 UNIQUE (sha1)
-);
-CREATE INDEX "idx_rb_sha1" ON "raw_blob" ("sha1");
-CREATE TABLE IF NOT EXISTS "git_pr" (
-  "id" INTEGER PRIMARY KEY,
-  "number" INTEGER NOT NULL,
-  "title" TEXT NOT NULL,
-  "state" TEXT NOT NULL,
-  "created_at" TEXT NOT NULL,
-  "updated_at" TEXT NOT NULL,
-  "closed_at" TEXT DEFAULT NULL,
-  "merged_at" TEXT DEFAULT NULL,
-  "merge_commit_sha" TEXT DEFAULT NULL,
-  "repo_id" INTEGER NOT NULL,
-  "sender_name" TEXT NOT NULL,
-  "sender_id" INTEGER NOT NULL,
-  "user_name" TEXT NOT NULL,
-  "user_id" INTEGER NOT NULL,
-  "commits_url" TEXT NOT NULL,
-  "patch_url" TEXT NOT NULL,
-  "head_label" TEXT NOT NULL,
-  "head_ref" TEXT NOT NULL,
-  "base_label" TEXT NOT NULL,
-  "base_ref" TEXT NOT NULL
-);
-CREATE TABLE IF NOT EXISTS "git_issue" (
-  "id" INTEGER PRIMARY KEY,
-  "number" INTEGER NOT NULL,
-  "title" TEXT NOT NULL,
-  "sender_name" TEXT NOT NULL,
-  "sender_id" INTEGER NOT NULL,
-  "state" TEXT NOT NULL,
-  "created_at" TEXT NOT NULL,
-  "updated_at" TEXT NOT NULL,
-  "closed_at" TEXT DEFAULT NULL,
-  "repo_id" INTEGER NOT NULL
-);
-CREATE TABLE IF NOT EXISTS "lfs_locks" (
-  "id" TEXT PRIMARY KEY,
-  "data" TEXT NOT NULL
-);
-CREATE TABLE IF NOT EXISTS "lfs_objects" (
-  "oid" TEXT PRIMARY KEY,
-  "size" INTEGER NOT NULL,
-  "exist" INTEGER NOT NULL,
-  "splited" INTEGER NOT NULL
-);
-CREATE TABLE IF NOT EXISTS "lfs_split_relations" (
-  "ori_oid" TEXT NOT NULL,
-  "sub_oid" TEXT NOT NULL,
-  "offset" INTEGER NOT NULL,
-  "size" INTEGER NOT NULL,
-  PRIMARY KEY ("ori_oid", "sub_oid", "offset")
-);
-
-CREATE TABLE IF NOT EXISTS "relay_node" (
-  "peer_id" VARCHAR(64) PRIMARY KEY,
-  "type" VARCHAR(64),
-  "online" BOOLEAN NOT NULL,
-  "last_online_time" BIGINT NOT NULL
-);
-
-CREATE TABLE IF NOT EXISTS "relay_repo_info" (
-  "identifier" TEXT PRIMARY KEY,
-  "name" TEXT,
-  "origin" TEXT,
-  "update_time" INTEGER NOT NULL,
-  "commit" TEXT
-);
-
-CREATE TABLE IF NOT EXISTS "relay_lfs_info" (
-  "id" BIGINT PRIMARY KEY,
-  "file_hash" VARCHAR(256),
-  "hash_type" VARCHAR(64),
-  "file_size" BIGINT NOT NULL,
-  "creation_time" BIGINT NOT NULL,
-  "peer_id" VARCHAR(64),
-  "origin" VARCHAR(256)
-);
-
-CREATE TABLE IF NOT EXISTS "relay_nostr_event" (
-  "id" VARCHAR(128) PRIMARY KEY,
-  "pubkey" VARCHAR(128),
-  "created_at" BIGINT NOT NULL,
-  "kind" INT,
-  "tags" TEXT,
-  "content" TEXT,
-  "sig" VARCHAR(256)
-);
-
-CREATE TABLE IF NOT EXISTS "relay_nostr_req" (
-  "id" VARCHAR(128) PRIMARY KEY,
-  "subscription_id" VARCHAR(128),
-  "filters" TEXT
-);
-
-CREATE TABLE IF NOT EXISTS "mq_storage" (
-  "id" INTEGER PRIMARY KEY,
-  "category" TEXT,
-  "create_time" TIMESTAMP NOT NULL,
-  "content" TEXT
-);
-
-CREATE TABLE IF NOT EXISTS "relay_path_mapping" (
-  "id" BIGINT PRIMARY KEY,
-  "alias" TEXT NOT NULL,
-  "repo_path" TEXT NOT NULL,
-  "created_at" TIMESTAMP NOT NULL,
-  "updated_at" TIMESTAMP NOT NULL,
-  CONSTRAINT uniq_alias UNIQUE (alias)
-);
-
-CREATE TABLE IF NOT EXISTS "user" (
-  "id" BIGINT PRIMARY KEY,
-  "name" TEXT NOT NULL,
-  "email" TEXT NOT NULL,
-  "avatar_url" TEXT NOT NULL,
-  "is_github" BOOLEAN NOT NULL,
-  "created_at" TIMESTAMP NOT NULL,
-  "updated_at" TIMESTAMP,
-  CONSTRAINT uniq_email UNIQUE (email)
-);
-
-CREATE TABLE IF NOT EXISTS "ssh_keys" (
-  "id" BIGINT PRIMARY KEY,
-  "user_id" BIGINT NOT NULL,
-  "title" TEXT NOT NULL,
-  "ssh_key" TEXT NOT NULL,
-  "finger" TEXT NOT NULL,
-  "created_at" TIMESTAMP NOT NULL
-);
-CREATE INDEX "idx_user_id" ON "ssh_keys" ("user_id");
-CREATE INDEX "idx_ssh_key_finger" ON "ssh_keys" ("finger");
-
-CREATE TABLE IF NOT EXISTS "access_token" (
-  "id" BIGINT PRIMARY KEY,
-  "user_id" BIGINT NOT NULL,
-  "token" TEXT NOT NULL,
-  "created_at" TIMESTAMP NOT NULL
-);
-CREATE INDEX "idx_token_user_id" ON "access_token" ("user_id");
-CREATE INDEX "idx_token" ON "access_token" ("token");
\ No newline at end of file