refact: split scope & name

Author: elrrrrrrr

api/migrations/20250402143550_create_changes.sql renamed to api/migrations/20250402220510_changes.sql

@@ -6,10 +6,11 @@ CREATE TYPE change_type AS ENUM (
 CREATE TABLE changes (
     seq BIGSERIAL PRIMARY KEY,
     change_type change_type NOT NULL,
-    package_id VARCHAR(255) NOT NULL,
+    scope_name text NOT NULL,
+    package_name text NOT NULL,
     data TEXT NOT NULL,
     created_at TIMESTAMPTZ NOT NULL DEFAULT NOW()
 );
 
-CREATE INDEX changes_package_id_idx ON changes (package_id);
+CREATE INDEX changes_scope_name_idx ON changes (scope_name, package_name);
 CREATE INDEX changes_created_at_idx ON changes (created_at);

api/src/api/changes.rs

@@ -22,7 +22,7 @@ impl From<Change> for ApiChange {
         Self {
             seq: change.seq,
             r#type: change.change_type.to_string(),
-            id: change.package_id,
+            id: format!("@jsr/{}__{}", change.scope_name, change.package_name),
             changes: serde_json::from_str(&change.data).unwrap(),
         }
     }

api/src/db/database.rs

@@ -56,6 +56,7 @@ impl Database {
     .await
   }
 
+
   #[instrument(name = "Database::list_changes", skip(self), err)]
   pub async fn list_changes(
       &self,
@@ -68,7 +69,8 @@ impl Database {
           SELECT
               seq,
               change_type as "change_type: ChangeType",
-              package_id,
+              scope_name as "scope_name: ScopeName",
+              package_name as "package_name: PackageName",
               data,
               created_at
           FROM changes
@@ -83,35 +85,36 @@ impl Database {
       .await
   }
 
-
   #[instrument(name = "Database::create_change", skip(self), err)]
   pub async fn create_change(
     &self,
     change_type: ChangeType,
-    package_id: String,
+    scope_name: &ScopeName,
+    package_name: &PackageName,
     data: serde_json::Value,
   ) -> Result<Change> {
     sqlx::query_as!(
       Change,
       r#"
-      INSERT INTO changes (change_type, package_id, data)
-      VALUES ($1, $2, $3)
+      INSERT INTO changes (change_type, scope_name, package_name, data)
+      VALUES ($1, $2, $3, $4)
       RETURNING
         seq,
         change_type as "change_type: ChangeType",
-        package_id,
+        scope_name as "scope_name: ScopeName",
+        package_name as "package_name: PackageName",
         data,
         created_at
       "#,
       change_type as _,
-      package_id,
+      scope_name as _,
+      package_name as _,
       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!(

api/src/db/models.rs

@@ -847,14 +847,16 @@ impl std::fmt::Display for ChangeType {
 pub struct Change {
     pub seq: i64,
     pub change_type: ChangeType,
-    pub package_id: String,
+    pub scope_name: ScopeName,
+    pub package_name: PackageName,
     pub data: String,
     pub created_at: DateTime<Utc>,
 }
 
 #[derive(Debug)]
 pub struct NewChange<'s> {
     pub change_type: ChangeType,
-    pub package_id: &'s str,
+    pub scope_name: &'s ScopeName,
+    pub package_name: &'s PackageName,
     pub data: &'s str,
 }

api/src/publish.rs

@@ -244,7 +244,8 @@ async fn process_publishing_task(
     async move {
       if let Err(e) = db.create_change(
         ChangeType::PackageVersionAdded,
-        format!("@{}/{}", scope, name),
+        &scope,
+        &name,
         serde_json::json!({
           "version": version.to_string(),
         }),