Store owners

Author: lpil

src/packages/storage.gleam

@@ -82,21 +82,36 @@ pub type Package {
     downloads_day: Int,
     repository_url: Option(String),
     latest_version: String,
+    owners: List(String),
   )
 }
 
 fn package_to_json(package: Package) -> Json {
+  let Package(
+    name:,
+    description:,
+    inserted_in_hex_at:,
+    updated_in_hex_at:,
+    downloads_all:,
+    downloads_recent:,
+    downloads_week:,
+    downloads_day:,
+    repository_url:,
+    latest_version:,
+    owners:,
+  ) = package
   json.object([
-    #("name", json.string(package.name)),
-    #("description", json.string(package.description)),
-    #("inserted_in_hex_at", json_timestamp(package.inserted_in_hex_at)),
-    #("updated_in_hex_at", json_timestamp(package.updated_in_hex_at)),
-    #("latest_version", json.string(package.latest_version)),
-    #("downloads_all", json.int(package.downloads_all)),
-    #("downloads_recent", json.int(package.downloads_recent)),
-    #("downloads_week", json.int(package.downloads_week)),
-    #("downloads_day", json.int(package.downloads_day)),
-    #("repository_url", json.nullable(package.repository_url, json.string)),
+    #("name", json.string(name)),
+    #("description", json.string(description)),
+    #("inserted_in_hex_at", json_timestamp(inserted_in_hex_at)),
+    #("updated_in_hex_at", json_timestamp(updated_in_hex_at)),
+    #("latest_version", json.string(latest_version)),
+    #("downloads_all", json.int(downloads_all)),
+    #("downloads_recent", json.int(downloads_recent)),
+    #("downloads_week", json.int(downloads_week)),
+    #("downloads_day", json.int(downloads_day)),
+    #("repository_url", json.nullable(repository_url, json.string)),
+    #("owners", json.array(owners, json.string)),
   ])
 }
 
@@ -114,6 +129,7 @@ fn package_decoder() -> Decoder(Package) {
     decode.optional(decode.string),
   )
   use latest_version <- decode.field("latest_version", decode.string)
+  use owners <- decode.optional_field("owners", [], decode.list(decode.string))
   decode.success(Package(
     name:,
     description:,
@@ -125,6 +141,7 @@ fn package_decoder() -> Decoder(Package) {
     downloads_day:,
     repository_url:,
     latest_version:,
+    owners:,
   ))
 }
 
@@ -225,6 +242,10 @@ fn hex_package_to_storage_package(
   }
   let repository_url =
     dict.get(package.meta.links, "Repository") |> option.from_result
+  let owners =
+    package.owners
+    |> option.unwrap([])
+    |> list.map(fn(owner) { owner.username })
 
   Package(
     name: package.name,
@@ -237,6 +258,7 @@ fn hex_package_to_storage_package(
     downloads_day: downloads_count("day"),
     repository_url:,
     latest_version:,
+    owners:,
   )
 }
 

test/packages/storage_test.gleam

@@ -67,6 +67,62 @@ pub fn insert_package_test() {
       downloads_week: 0,
       latest_version: "1.0.0",
       repository_url: Some("https://github.com/gleam-lang/stdlib"),
+      owners: [],
+    )
+}
+
+pub fn insert_package_with_owners_test() {
+  use db <- tests.with_database
+
+  let assert Ok(_) =
+    storage.upsert_package_from_hex(
+      db,
+      hexpm.Package(
+        downloads: dict.from_list([#("all", 5), #("recent", 2)]),
+        docs_html_url: Some("https://hexdocs.pm/gleam_stdlib/"),
+        html_url: Some("https://hex.pm/packages/gleam_stdlib"),
+        meta: hexpm.PackageMeta(
+          description: Some("Standard library for Gleam"),
+          licenses: ["Apache-2.0"],
+          links: dict.from_list([
+            #("Website", "https://gleam.run/"),
+            #("Repository", "https://github.com/gleam-lang/stdlib"),
+          ]),
+        ),
+        name: "gleam_stdlib",
+        owners: Some([
+          hexpm.PackageOwner(
+            username: "user1",
+            email: Some("[email protected]"),
+            url: "https://hex.pm/api/users/user1",
+          ),
+          hexpm.PackageOwner(
+            username: "user2",
+            email: None,
+            url: "https://hex.pm/api/users/user2",
+          ),
+        ]),
+        releases: [],
+        inserted_at: timestamp.from_unix_seconds(100),
+        updated_at: timestamp.from_unix_seconds(2000),
+      ),
+      "1.0.0",
+    )
+
+  let assert Ok(package) = storage.get_package(db, "gleam_stdlib")
+  assert package
+    == Package(
+      description: "Standard library for Gleam",
+      name: "gleam_stdlib",
+      inserted_in_hex_at: timestamp.from_unix_seconds(100),
+      updated_in_hex_at: timestamp.from_unix_seconds(2000),
+      downloads_all: 5,
+      downloads_recent: 2,
+      downloads_day: 0,
+      downloads_week: 0,
+      latest_version: "1.0.0",
+      repository_url: Some("https://github.com/gleam-lang/stdlib"),
+      owners: ["user1", "user2"],
     )
 }