feat(user page): Recently published

AugustinMauroy · AugustinMauroy · commit 7ce790e8c2d7 · 2025-04-26T12:09:10.000+02:00
diff --git a/api/src/api/users.rs b/api/src/api/users.rs
@@ -13,13 +13,15 @@ use crate::util::ApiResult;
 use crate::util::RequestIdExt;
 
 use super::ApiError;
+use super::ApiPackage;
 use super::ApiScope;
 use super::ApiUser;
 
 pub fn users_router() -> Router<Body, ApiError> {
   Router::builder()
     .get("/:id", util::json(get_handler))
     .get("/:id/scopes", util::json(get_scopes_handler))
+    .get("/:id/packages", util::json(get_packages_handler))
     .build()
     .unwrap()
 }
@@ -54,3 +56,25 @@ pub async fn get_scopes_handler(
 
   Ok(scopes.into_iter().map(ApiScope::from).collect())
 }
+
+#[instrument(name = "GET /api/users/:id/packages", skip(req), err, fields(id))]
+pub async fn get_packages_handler(
+  req: Request<Body>,
+) -> ApiResult<Vec<ApiPackage>> {
+  let id = req.param_uuid("id")?;
+  Span::current().record("id", field::display(id));
+
+  let db = req.data::<Database>().unwrap();
+  db.get_user_public(id)
+    .await?
+    .ok_or(ApiError::UserNotFound)?;
+
+  let packages = db.get_recent_packages_by_user(&id).await?;
+
+  Ok(
+    packages
+      .into_iter()
+      .map(|package| ApiPackage::from((package, None, Default::default())))
+      .collect(),
+  )
+}
diff --git a/api/src/db/database.rs b/api/src/db/database.rs
@@ -4858,6 +4858,39 @@ impl Database {
 
     Ok((total_scopes as usize, scopes))
   }
+
+  pub async fn get_recent_packages_by_user(
+    &self,
+    user_id: &uuid::Uuid,
+  ) -> Result<Vec<Package>> {
+    let packages = sqlx::query_as!(
+        Package,
+        r#"
+        SELECT DISTINCT ON (packages.scope, packages.name)
+          packages.scope as "scope: ScopeName",
+          packages.name as "name: PackageName",
+          packages.description,
+          packages.github_repository_id,
+          packages.runtime_compat as "runtime_compat: RuntimeCompat",
+          packages.when_featured,
+          packages.is_archived,
+          packages.updated_at,
+          packages.created_at,
+          (SELECT COUNT(created_at) FROM package_versions WHERE scope = packages.scope AND name = packages.name) as "version_count!",
+          (SELECT version FROM package_versions WHERE scope = packages.scope AND name = packages.name AND version NOT LIKE '%-%' AND is_yanked = false ORDER BY version DESC LIMIT 1) as "latest_version"
+        FROM packages
+        JOIN scope_members ON packages.scope = scope_members.scope
+        WHERE scope_members.user_id = $1
+        ORDER BY packages.scope, packages.name, packages.created_at DESC
+        LIMIT 10;
+        "#,
+        user_id
+    )
+    .fetch_all(&self.pool)
+    .await?;
+
+    Ok(packages)
+  }
 }
 
 async fn finalize_package_creation(
