feat: create change

elrrrrrrr · elrrrrrrr · commit 4502b08149e8 · 2025-04-02T15:56:50.000+08:00
diff --git a/api/migrations/20250402143550_create_changes.sql b/api/migrations/20250402143550_create_changes.sql
@@ -11,6 +11,5 @@ CREATE TABLE changes (
     created_at TIMESTAMPTZ NOT NULL DEFAULT NOW()
 );
 
--- 创建索引
 CREATE INDEX changes_package_id_idx ON changes (package_id);
 CREATE INDEX changes_created_at_idx ON changes (created_at);
diff --git a/api/src/api/changes.rs b/api/src/api/changes.rs
@@ -1,12 +1,10 @@
-use crate::api::ApiError;
 use hyper::{Body, Request};
-use routerify::Router;
 use routerify::prelude::*;
 use serde::Serialize;
 
 use crate::{
     db::{Change, Database},
-    util::{self, pagination, ApiResult},
+    util::{pagination, ApiResult},
 };
 
 
@@ -29,14 +27,7 @@ impl From<Change> for ApiChange {
     }
 }
 
-pub fn changes_router() -> Router<Body, ApiError> {
-    Router::builder()
-        .get("/_changes", util::json(list_changes))
-        .build()
-        .unwrap()
-}
-
-async fn list_changes(req: Request<Body>) -> ApiResult<Vec<ApiChange>> {
+pub async fn list_changes(req: Request<Body>) -> ApiResult<Vec<ApiChange>> {
     let db = req.data::<Database>().unwrap();
     let (start, limit) = pagination(&req);
     let changes = db.list_changes(start, limit).await?;
diff --git a/api/src/api/mod.rs b/api/src/api/mod.rs
@@ -16,6 +16,7 @@ use hyper::Response;
 use package::global_list_handler;
 use package::global_metrics_handler;
 use package::global_stats_handler;
+use changes::list_changes;
 use routerify::Middleware;
 use routerify::Router;
 
@@ -29,7 +30,6 @@ use self::admin::admin_router;
 use self::authorization::authorization_router;
 use self::scope::scope_router;
 use self::users::users_router;
-use self::changes::changes_router;
 
 use crate::util;
 use crate::util::CacheDuration;
@@ -43,10 +43,10 @@ pub fn api_router() -> Router<Body, ApiError> {
         util::json(global_metrics_handler),
       ),
     )
+    .get("/_changes", util::json(list_changes))
     .middleware(Middleware::pre(util::auth_middleware))
     .scope("/admin", admin_router())
     .scope("/scopes", scope_router())
-    .scope("/changes", changes_router())
     .scope("/user", self_user_router())
     .scope("/users", users_router())
     .scope("/authorizations", authorization_router())
diff --git a/api/src/db/database.rs b/api/src/db/database.rs
@@ -83,6 +83,35 @@ impl Database {
       .await
   }
 
+
+  #[instrument(name = "Database::create_change", skip(self), err)]
+  pub async fn create_change(
+    &self,
+    change_type: ChangeType,
+    package_id: String,
+    data: serde_json::Value,
+  ) -> Result<Change> {
+    sqlx::query_as!(
+      Change,
+      r#"
+      INSERT INTO changes (change_type, package_id, data)
+      VALUES ($1, $2, $3)
+      RETURNING
+        seq,
+        change_type as "change_type: ChangeType",
+        package_id,
+        data,
+        created_at
+      "#,
+      change_type as _,
+      package_id,
+      data.to_string()
+    )
+    .fetch_one(&self.pool)
+    .await
+  }
+
+
   #[instrument(name = "Database::get_user_public", skip(self), err)]
   pub async fn get_user_public(&self, id: Uuid) -> Result<Option<UserPublic>> {
     sqlx::query_as!(
diff --git a/api/src/publish.rs b/api/src/publish.rs
@@ -5,6 +5,7 @@ use std::collections::HashSet;
 use crate::api::ApiError;
 use crate::buckets::Buckets;
 use crate::buckets::UploadTaskBody;
+use crate::db::ChangeType;
 use crate::db::Database;
 use crate::db::DependencyKind;
 use crate::db::ExportsMap;
@@ -234,6 +235,25 @@ async fn process_publishing_task(
     );
   }
 
+  tokio::spawn({
+    let db = db.clone();
+    let scope = publishing_task.package_scope.clone();
+    let name = publishing_task.package_name.clone();
+    let version = publishing_task.package_version.clone();
+
+    async move {
+      if let Err(e) = db.create_change(
+        ChangeType::PackageVersionAdded,
+        format!("@{}/{}", scope, name),
+        serde_json::json!({
+          "version": version.to_string(),
+        }),
+      ).await {
+        error!("Failed to create change record: {}", e);
+      }
+    }
+  });
+
   Ok(())
 }
 
