hanna/fabrica

feat(store): bookmarks (repository stars)

86b8de2 · hanna committed on 2026-07-26

Add the bookmarks table (migration 0018) and store layer: add/remove a
bookmark, is_bookmarked, count_repo_bookmarks, and bookmarked_repos (a
join back to repos so callers can filter by the viewer's read access).

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Signed by hannaSSH key fingerprint: SHA256:4g9cWhkAAw8gwqhJUcVbSnGEvdGwklW+1Aa/fMUu59k

crates/store/src/bookmarks.rs +98 −0

crates/store/src/lib.rs +1 −0

crates/store/src/repos.rs +2 −2

data/repos/01/01kye754pv7cb136x910ppnvja.git/FETCH_HEAD +2 −0

data/repos/01/01kye754pv7cb136x910ppnvja.git/HEAD +1 −0

data/repos/01/01kye754pv7cb136x910ppnvja.git/config +9 −0

data/repos/01/01kye754pv7cb136x910ppnvja.git/description +1 −0

data/repos/01/01kye754pv7cb136x910ppnvja.git/hooks/README.sample +5 −0

data/repos/01/01kye754pv7cb136x910ppnvja.git/hooks/post-receive +2 −0

data/repos/01/01kye754pv7cb136x910ppnvja.git/hooks/pre-receive +2 −0

data/repos/01/01kye754pv7cb136x910ppnvja.git/info/exclude +2 −0

data/repos/01/01kye754pv7cb136x910ppnvja.git/logs/HEAD +1 −0

data/repos/01/01kye754pv7cb136x910ppnvja.git/logs/refs/heads/a +1 −0

data/repos/01/01kye754pv7cb136x910ppnvja.git/logs/refs/heads/main +1 −0

data/repos/01/01kye754pv7cb136x910ppnvja.git/objects/pack/pack-a7fdcb5c169f40c31c03119f33105da551053535.idx +0 −0

Binary file not shown.

data/repos/01/01kye754pv7cb136x910ppnvja.git/objects/pack/pack-a7fdcb5c169f40c31c03119f33105da551053535.pack +0 −0

Binary file not shown.

data/repos/01/01kye754pv7cb136x910ppnvja.git/objects/pack/pack-a7fdcb5c169f40c31c03119f33105da551053535.rev +0 −0

Binary file not shown.

data/repos/01/01kye754pv7cb136x910ppnvja.git/refs/heads/a +1 −0

data/repos/01/01kye754pv7cb136x910ppnvja.git/refs/heads/main +1 −0

migrations/postgres/0018_bookmarks.sql +10 −0

migrations/sqlite/0018_bookmarks.sql +10 −0

+// This Source Code Form is subject to the terms of the Mozilla Public
+// License, v. 2.0. If a copy of the MPL was not distributed with this
+// file, You can obtain one at https://mozilla.org/MPL/2.0/.
+//! Bookmarks (stars): a user marking a repository. A bookmark is a `(user, repo)`
+//! pair; the listing joins back to `repos` so callers can filter by visibility.
+use model::Repo;
+use sqlx::{AssertSqlSafe, Row};
+use crate::repos::REPO_COLUMNS;
+use crate::{Store, StoreError, new_id, now_ms};
+impl Store {
+    /// Bookmark a repository for a user. Idempotent.
+    ///
+    /// # Errors
+    ///
+    /// Returns [`StoreError::Query`] on a database failure.
+    pub async fn add_bookmark(&self, user_id: &str, repo_id: &str) -> Result<(), StoreError> {
+        sqlx::query(
+            "INSERT INTO bookmarks (id, user_id, repo_id, created_at) VALUES ($1, $2, $3, $4) \
+             ON CONFLICT (user_id, repo_id) DO NOTHING",
+        )
+        .bind(new_id())
+        .bind(user_id)
+        .bind(repo_id)
+        .bind(now_ms())
+        .execute(&self.pool)
+        .await?;
+        Ok(())
+    }
+    /// Remove a user's bookmark of a repository.
+    ///
+    /// # Errors
+    ///
+    /// Returns [`StoreError::Query`] on a database failure.
+    pub async fn remove_bookmark(&self, user_id: &str, repo_id: &str) -> Result<(), StoreError> {
+        sqlx::query("DELETE FROM bookmarks WHERE user_id = $1 AND repo_id = $2")
+            .bind(user_id)
+            .bind(repo_id)
+            .execute(&self.pool)
+            .await?;
+        Ok(())
+    }
+    /// Whether `user_id` has bookmarked `repo_id`.
+    ///
+    /// # Errors
+    ///
+    /// Returns [`StoreError::Query`] on a database failure.
+    pub async fn is_bookmarked(&self, user_id: &str, repo_id: &str) -> Result<bool, StoreError> {
+        let row = sqlx::query("SELECT 1 AS n FROM bookmarks WHERE user_id = $1 AND repo_id = $2")
+            .bind(user_id)
+            .bind(repo_id)
+            .fetch_optional(&self.pool)
+            .await?;
+        Ok(row.is_some())
+    }
+    /// How many users have bookmarked `repo_id`.
+    ///
+    /// # Errors
+    ///
+    /// Returns [`StoreError::Query`] on a database failure.
+    pub async fn count_repo_bookmarks(&self, repo_id: &str) -> Result<i64, StoreError> {
+        let n: i64 = sqlx::query("SELECT COUNT(*) AS n FROM bookmarks WHERE repo_id = $1")
+            .bind(repo_id)
+            .fetch_one(&self.pool)
+            .await?
+            .try_get("n")?;
+        Ok(n)
+    }
+    /// The repositories `user_id` has bookmarked, most recent first. Callers
+    /// filter by the viewer's read access before display.
+    ///
+    /// # Errors
+    ///
+    /// Returns [`StoreError::Query`] on a database failure.
+    pub async fn bookmarked_repos(&self, user_id: &str) -> Result<Vec<Repo>, StoreError> {
+        // Qualify every repo column so nothing collides with `bookmarks`.
+        let cols = format!("r.{}", REPO_COLUMNS.replace(", ", ", r."));
+        let sql = format!(
+            "SELECT {cols} FROM repos r JOIN bookmarks b ON b.repo_id = r.id \
+             WHERE b.user_id = $1 ORDER BY b.created_at DESC"
+        );
+        let rows = sqlx::query(AssertSqlSafe(sql))
+            .bind(user_id)
+            .fetch_all(&self.pool)
+            .await?;
+        rows.iter()
+            .map(|r| self.map_repo(r))
+            .collect::<Result<_, _>>()
+            .map_err(Into::into)
+    }
+}

 //! set is embedded at build time and selected at runtime by [`Store::migrate`].
 mod admin;
+mod bookmarks;
 mod groups;
 mod invites;
 mod issues;

 use crate::{Store, StoreError, map_conflict, new_id, now_ms};
 /// The columns of `repos` in a fixed order, shared by every `SELECT`.
-const REPO_COLUMNS: &str = "id, owner_id, group_id, name, path, description, visibility, \
+pub(crate) const REPO_COLUMNS: &str = "id, owner_id, group_id, name, path, description, visibility, \
      default_branch, object_format, issues_enabled, pulls_enabled, releases_enabled, is_mirror, \
      fork_parent_id, next_iid, archived_at, size_bytes, pushed_at, created_at, updated_at";
+    }
     /// Map a `repos` row (selected via [`REPO_COLUMNS`]) to a [`Repo`].
-    fn map_repo(&self, row: &AnyRow) -> Result<Repo, sqlx::Error> {
+    pub(crate) fn map_repo(&self, row: &AnyRow) -> Result<Repo, sqlx::Error> {
         Ok(Repo {
             id: row.try_get("id")?,
             owner_id: row.try_get("owner_id")?,

+[core]
+	bare = true
+	repositoryformatversion = 0
+	filemode = true
+	logallrefupdates = true
+[receive]
+	denyNonFastForwards = false
+[gc]
+	auto = 0

+#!/bin/sh
+#
+# Place appropriately named executable hook scripts into this directory
+# to intercept various actions that git takes.  See `git help hooks` for
+# more information.

@@ -0,0 +1,2 @@
	1	66215cd4f32408a28a91cc10f0080bb4b3beb2a6 branch 'a' of data/repos/01/01kyc0j4dzrnx6afv3wwfvxgn4
	2	94ffb4ef79a86c7e24d038233859149ba61439aa branch 'main' of data/repos/01/01kyc0j4dzrnx6afv3wwfvxgn4

@@ -0,0 +1 @@
		1	Unnamed repository; edit this file 'description' to name the repository.

@@ -0,0 +1,2 @@
	1	#!/bin/sh
	2	exec "/nix/store/2ncl66xwbsl6qf2766w3sxy3dv9vaply-fabrica-0.1.0/bin/.fabrica-wrapped" hook post-receive

@@ -0,0 +1,2 @@
	1	# File patterns to ignore; see `git help ignore` for more information.
	2	# Lines that start with '#' are comments.

@@ -0,0 +1 @@
		1	0000000000000000000000000000000000000000 94ffb4ef79a86c7e24d038233859149ba61439aa hanna <me@hanna.lol> 1785036182 -0400 fetch --prune --quiet data/repos/01/01kyc0j4dzrnx6afv3wwfvxgn4.git +refs/heads/:refs/heads/ +refs/tags/:refs/tags/: storing head

+-- Bookmarks (stars): a user marking a repository. Public on the user's profile,
+-- filtered by the viewer's read access when listed.
+CREATE TABLE bookmarks (
+    id         TEXT PRIMARY KEY,
+    user_id    TEXT NOT NULL REFERENCES users(id) ON DELETE CASCADE,
+    repo_id    TEXT NOT NULL REFERENCES repos(id) ON DELETE CASCADE,
+    created_at BIGINT NOT NULL
+);
+CREATE UNIQUE INDEX idx_bookmarks_user_repo ON bookmarks (user_id, repo_id);
+CREATE INDEX idx_bookmarks_repo ON bookmarks (repo_id);

@@ -0,0 +1 @@
		1	ref: refs/heads/main