Add profile pin persistence

Status	File	+
M	`internal/admin/sqlc/models.go`	14
M	`internal/auth/policy/sqlc/models.go`	14
M	`internal/checks/sqlc/models.go`	14
M	`internal/issues/sqlc/models.go`	14
M	`internal/meta/sqlc/models.go`	14
A	`internal/migrationsfs/migrations/0040_profile_pins.sql`	46
M	`internal/notif/sqlc/models.go`	14
M	`internal/orgs/sqlc/models.go`	14
M	`internal/pulls/sqlc/models.go`	14
M	`internal/ratelimit/sqlc/models.go`	14
M	`internal/repos/queries/repos.sql`	35
M	`internal/repos/sqlc/models.go`	14
M	`internal/repos/sqlc/querier.go`	8
M	`internal/repos/sqlc/repos.sql.go`	111
M	`internal/social/sqlc/models.go`	14
M	`internal/users/sqlc/models.go`	14
M	`internal/webhook/sqlc/models.go`	14
M	`internal/worker/sqlc/models.go`	14

internal/admin/sqlc/models.gomodified

  	ID   int64
+ }
 +type ProfilePin struct {
 +	SetID    int64
 +	RepoID   int64
 +	Position int32
 +	PinnedAt pgtype.Timestamptz
 +}
++
 +type ProfilePinSet struct {
 +	ID          int64
 +	OwnerUserID pgtype.Int8
 +	OwnerOrgID  pgtype.Int8
 +	UpdatedAt   pgtype.Timestamptz
 +}
++
  type PullRequest struct {
  	IssueID            int64
  	BaseRef            string

internal/auth/policy/sqlc/models.gomodified

  	ID   int64
+ }
 +type ProfilePin struct {
 +	SetID    int64
 +	RepoID   int64
 +	Position int32
 +	PinnedAt pgtype.Timestamptz
 +}
++
 +type ProfilePinSet struct {
 +	ID          int64
 +	OwnerUserID pgtype.Int8
 +	OwnerOrgID  pgtype.Int8
 +	UpdatedAt   pgtype.Timestamptz
 +}
++
  type PullRequest struct {
  	IssueID            int64
  	BaseRef            string

internal/checks/sqlc/models.gomodified

  	ID   int64
+ }
 +type ProfilePin struct {
 +	SetID    int64
 +	RepoID   int64
 +	Position int32
 +	PinnedAt pgtype.Timestamptz
 +}
++
 +type ProfilePinSet struct {
 +	ID          int64
 +	OwnerUserID pgtype.Int8
 +	OwnerOrgID  pgtype.Int8
 +	UpdatedAt   pgtype.Timestamptz
 +}
++
  type PullRequest struct {
  	IssueID            int64
  	BaseRef            string

internal/issues/sqlc/models.gomodified

  	ID   int64
+ }
 +type ProfilePin struct {
 +	SetID    int64
 +	RepoID   int64
 +	Position int32
 +	PinnedAt pgtype.Timestamptz
 +}
++
 +type ProfilePinSet struct {
 +	ID          int64
 +	OwnerUserID pgtype.Int8
 +	OwnerOrgID  pgtype.Int8
 +	UpdatedAt   pgtype.Timestamptz
 +}
++
  type PullRequest struct {
  	IssueID            int64
  	BaseRef            string

internal/meta/sqlc/models.gomodified

  	ID   int64
+ }
 +type ProfilePin struct {
 +	SetID    int64
 +	RepoID   int64
 +	Position int32
 +	PinnedAt pgtype.Timestamptz
 +}
++
 +type ProfilePinSet struct {
 +	ID          int64
 +	OwnerUserID pgtype.Int8
 +	OwnerOrgID  pgtype.Int8
 +	UpdatedAt   pgtype.Timestamptz
 +}
++
  type PullRequest struct {
  	IssueID            int64
  	BaseRef            string

internal/migrationsfs/migrations/0040_profile_pins.sqladded

 +-- SPDX-License-Identifier: AGPL-3.0-or-later
 +--
 +-- Profile and organization pinned repositories.
 +--
 +-- A pin set records that the owner has customized their pinned
 +-- repositories. The separate row lets us distinguish "never customized"
 +-- from "customized to zero pins" while keeping the ordered pins table
 +-- normalized and easy to replace transactionally.
++
 +-- +goose Up
 +CREATE TABLE profile_pin_sets (
 +    id            bigserial   PRIMARY KEY,
 +    owner_user_id bigint      REFERENCES users(id) ON DELETE CASCADE,
 +    owner_org_id  bigint      REFERENCES orgs(id) ON DELETE CASCADE,
 +    updated_at    timestamptz NOT NULL DEFAULT now(),
++
 +    CONSTRAINT profile_pin_sets_owner_xor CHECK (
 +        (owner_user_id IS NOT NULL AND owner_org_id IS NULL)
 +     OR (owner_user_id IS NULL     AND owner_org_id IS NOT NULL)
 +    )
 +);
++
 +CREATE UNIQUE INDEX profile_pin_sets_owner_user_uq
 +    ON profile_pin_sets (owner_user_id)
 +    WHERE owner_user_id IS NOT NULL;
++
 +CREATE UNIQUE INDEX profile_pin_sets_owner_org_uq
 +    ON profile_pin_sets (owner_org_id)
 +    WHERE owner_org_id IS NOT NULL;
++
 +CREATE TABLE profile_pins (
 +    set_id    bigint      NOT NULL REFERENCES profile_pin_sets(id) ON DELETE CASCADE,
 +    repo_id   bigint      NOT NULL REFERENCES repos(id) ON DELETE CASCADE,
 +    position  integer     NOT NULL,
 +    pinned_at timestamptz NOT NULL DEFAULT now(),
++
 +    PRIMARY KEY (set_id, repo_id),
 +    CONSTRAINT profile_pins_position_range CHECK (position BETWEEN 1 AND 6),
 +    CONSTRAINT profile_pins_set_position_uq UNIQUE (set_id, position)
 +);
++
 +CREATE INDEX profile_pins_repo_idx ON profile_pins (repo_id);
++
 +-- +goose Down
 +DROP TABLE IF EXISTS profile_pins;
 +DROP TABLE IF EXISTS profile_pin_sets;

internal/notif/sqlc/models.gomodified

  	ID   int64
+ }
 +type ProfilePin struct {
 +	SetID    int64
 +	RepoID   int64
 +	Position int32
 +	PinnedAt pgtype.Timestamptz
 +}
++
 +type ProfilePinSet struct {
 +	ID          int64
 +	OwnerUserID pgtype.Int8
 +	OwnerOrgID  pgtype.Int8
 +	UpdatedAt   pgtype.Timestamptz
 +}
++
  type PullRequest struct {
  	IssueID            int64
  	BaseRef            string

internal/orgs/sqlc/models.gomodified

  	ID   int64
+ }
 +type ProfilePin struct {
 +	SetID    int64
 +	RepoID   int64
 +	Position int32
 +	PinnedAt pgtype.Timestamptz
 +}
++
 +type ProfilePinSet struct {
 +	ID          int64
 +	OwnerUserID pgtype.Int8
 +	OwnerOrgID  pgtype.Int8
 +	UpdatedAt   pgtype.Timestamptz
 +}
++
  type PullRequest struct {
  	IssueID            int64
  	BaseRef            string

internal/pulls/sqlc/models.gomodified

  	ID   int64
+ }
 +type ProfilePin struct {
 +	SetID    int64
 +	RepoID   int64
 +	Position int32
 +	PinnedAt pgtype.Timestamptz
 +}
++
 +type ProfilePinSet struct {
 +	ID          int64
 +	OwnerUserID pgtype.Int8
 +	OwnerOrgID  pgtype.Int8
 +	UpdatedAt   pgtype.Timestamptz
 +}
++
  type PullRequest struct {
  	IssueID            int64
  	BaseRef            string

internal/ratelimit/sqlc/models.gomodified

  	ID   int64
+ }
 +type ProfilePin struct {
 +	SetID    int64
 +	RepoID   int64
 +	Position int32
 +	PinnedAt pgtype.Timestamptz
 +}
++
 +type ProfilePinSet struct {
 +	ID          int64
 +	OwnerUserID pgtype.Int8
 +	OwnerOrgID  pgtype.Int8
 +	UpdatedAt   pgtype.Timestamptz
 +}
++
  type PullRequest struct {
  	IssueID            int64
  	BaseRef            string

internal/repos/queries/repos.sqlmodified

  -- name: ListRepoTopics :many
  SELECT topic FROM repo_topics WHERE repo_id = $1 ORDER BY topic ASC;
 +-- ─── profile/org pinned repositories ───────────────────────────────
++
 +-- name: GetProfilePinSetForUser :one
 +SELECT id FROM profile_pin_sets WHERE owner_user_id = $1;
++
 +-- name: GetProfilePinSetForOrg :one
 +SELECT id FROM profile_pin_sets WHERE owner_org_id = $1;
++
 +-- name: UpsertProfilePinSetForUser :one
 +INSERT INTO profile_pin_sets (owner_user_id)
 +VALUES ($1)
 +ON CONFLICT (owner_user_id) WHERE owner_user_id IS NOT NULL
 +DO UPDATE SET updated_at = now()
 +RETURNING id;
++
 +-- name: UpsertProfilePinSetForOrg :one
 +INSERT INTO profile_pin_sets (owner_org_id)
 +VALUES ($1)
 +ON CONFLICT (owner_org_id) WHERE owner_org_id IS NOT NULL
 +DO UPDATE SET updated_at = now()
 +RETURNING id;
++
 +-- name: ListProfilePinsForSet :many
 +SELECT repo_id, position
 +FROM profile_pins
 +WHERE set_id = $1
 +ORDER BY position ASC;
++
 +-- name: DeleteProfilePinsForSet :exec
 +DELETE FROM profile_pins WHERE set_id = $1;
++
 +-- name: InsertProfilePin :exec
 +INSERT INTO profile_pins (set_id, repo_id, position)
 +VALUES ($1, $2, $3);
++
  -- name: ReplaceRepoTopics :exec
  -- Atomic full-replace: callers compose the new topic set in Go,
  -- then replace the existing rows in one tx (DELETE + INSERT). The

internal/repos/sqlc/models.gomodified

  	ID   int64
+ }
 +type ProfilePin struct {
 +	SetID    int64
 +	RepoID   int64
 +	Position int32
 +	PinnedAt pgtype.Timestamptz
 +}
++
 +type ProfilePinSet struct {
 +	ID          int64
 +	OwnerUserID pgtype.Int8
 +	OwnerOrgID  pgtype.Int8
 +	UpdatedAt   pgtype.Timestamptz
 +}
++
  type PullRequest struct {
  	IssueID            int64
  	BaseRef            string

internal/repos/sqlc/querier.gomodified

  	CreateRepo(ctx context.Context, db DBTX, arg CreateRepoParams) (Repo, error)
  	DeclineTransferRequest(ctx context.Context, db DBTX, id int64) error
  	DeleteBranchProtectionRule(ctx context.Context, db DBTX, id int64) error
 +	DeleteProfilePinsForSet(ctx context.Context, db DBTX, setID int64) error
  	// Used by the rename compensator: drop a single redirect row when
  	// the rename has to be rolled back due to a filesystem failure. We
  	// avoided raw SQL here at the audit's request (S00-S25, M).
  	// offers past their expires_at to the expired terminal state.
  	ExpirePendingTransfers(ctx context.Context, db DBTX) (int64, error)
  	GetBranchProtectionRule(ctx context.Context, db DBTX, id int64) (BranchProtectionRule, error)
 +	GetProfilePinSetForOrg(ctx context.Context, db DBTX, ownerOrgID pgtype.Int8) (int64, error)
 +	// ─── profile/org pinned repositories ───────────────────────────────
 +	GetProfilePinSetForUser(ctx context.Context, db DBTX, ownerUserID pgtype.Int8) (int64, error)
  	GetRepoByID(ctx context.Context, db DBTX, id int64) (Repo, error)
  	// S30: org-owner mirror of GetRepoByOwnerUserAndName. The (owner_org_id,
  	// name) partial unique index from 0017 backs this lookup with the same
  	GetRepoOwnerUsernameByID(ctx context.Context, db DBTX, id int64) (GetRepoOwnerUsernameByIDRow, error)
  	GetTransferRequest(ctx context.Context, db DBTX, id int64) (RepoTransferRequest, error)
  	HardDeleteRepo(ctx context.Context, db DBTX, id int64) error
 +	InsertProfilePin(ctx context.Context, db DBTX, arg InsertProfilePinParams) error
  	// ─── redirects ─────────────────────────────────────────────────────────
  	// Both old-owner FKs are nullable; pass exactly one. The CHECK
  	// constraint on the table enforces the xor shape.
  	ListForksOfRepoForRepack(ctx context.Context, db DBTX, forkOfRepoID pgtype.Int8) ([]ListForksOfRepoForRepackRow, error)
  	// Inbox view: pending offers a user can act on.
  	ListPendingTransfersForUser(ctx context.Context, db DBTX, toPrincipalID int64) ([]RepoTransferRequest, error)
 +	ListProfilePinsForSet(ctx context.Context, db DBTX, setID int64) ([]ListProfilePinsForSetRow, error)
  	// ─── soft-delete sweep query ───────────────────────────────────────────
  	// The repo:hard_delete enqueuer queries this to find rows ready for
  	// destruction. The 7-day grace is hard-coded here; if we add a config
  	UpdateRepoGeneralSettings(ctx context.Context, db DBTX, arg UpdateRepoGeneralSettingsParams) error
  	UpdateRepoMergeSettings(ctx context.Context, db DBTX, arg UpdateRepoMergeSettingsParams) error
  	UpsertBranchProtectionRule(ctx context.Context, db DBTX, arg UpsertBranchProtectionRuleParams) (int64, error)
 +	UpsertProfilePinSetForOrg(ctx context.Context, db DBTX, ownerOrgID pgtype.Int8) (int64, error)
 +	UpsertProfilePinSetForUser(ctx context.Context, db DBTX, ownerUserID pgtype.Int8) (int64, error)
+ }
  var _ Querier = (*Queries)(nil)

internal/repos/sqlc/repos.sql.gomodified

  	return i, err
+ }
 +const deleteProfilePinsForSet = `-- name: DeleteProfilePinsForSet :exec
 +DELETE FROM profile_pins WHERE set_id = $1
 +`
++
 +func (q *Queries) DeleteProfilePinsForSet(ctx context.Context, db DBTX, setID int64) error {
 +	_, err := db.Exec(ctx, deleteProfilePinsForSet, setID)
 +	return err
 +}
++
  const existsRepoForOwnerOrg = `-- name: ExistsRepoForOwnerOrg :one
  SELECT EXISTS(
      SELECT 1 FROM repos
  	return exists, err
+ }
 +const getProfilePinSetForOrg = `-- name: GetProfilePinSetForOrg :one
 +SELECT id FROM profile_pin_sets WHERE owner_org_id = $1
 +`
++
 +func (q *Queries) GetProfilePinSetForOrg(ctx context.Context, db DBTX, ownerOrgID pgtype.Int8) (int64, error) {
 +	row := db.QueryRow(ctx, getProfilePinSetForOrg, ownerOrgID)
 +	var id int64
 +	err := row.Scan(&id)
 +	return id, err
 +}
++
 +const getProfilePinSetForUser = `-- name: GetProfilePinSetForUser :one
++
 +SELECT id FROM profile_pin_sets WHERE owner_user_id = $1
 +`
++
 +// ─── profile/org pinned repositories ───────────────────────────────
 +func (q *Queries) GetProfilePinSetForUser(ctx context.Context, db DBTX, ownerUserID pgtype.Int8) (int64, error) {
 +	row := db.QueryRow(ctx, getProfilePinSetForUser, ownerUserID)
 +	var id int64
 +	err := row.Scan(&id)
 +	return id, err
 +}
++
  const getRepoByID = `-- name: GetRepoByID :one
  SELECT id, owner_user_id, owner_org_id, name, description, visibility,
         default_branch, is_archived, archived_at, deleted_at,
  	return i, err
+ }
 +const insertProfilePin = `-- name: InsertProfilePin :exec
 +INSERT INTO profile_pins (set_id, repo_id, position)
 +VALUES ($1, $2, $3)
 +`
++
 +type InsertProfilePinParams struct {
 +	SetID    int64
 +	RepoID   int64
 +	Position int32
 +}
++
 +func (q *Queries) InsertProfilePin(ctx context.Context, db DBTX, arg InsertProfilePinParams) error {
 +	_, err := db.Exec(ctx, insertProfilePin, arg.SetID, arg.RepoID, arg.Position)
 +	return err
 +}
++
  const insertRepoTopic = `-- name: InsertRepoTopic :exec
  INSERT INTO repo_topics (repo_id, topic)
  VALUES ($1, $2)
  	return items, nil
+ }
 +const listProfilePinsForSet = `-- name: ListProfilePinsForSet :many
 +SELECT repo_id, position
 +FROM profile_pins
 +WHERE set_id = $1
 +ORDER BY position ASC
 +`
++
 +type ListProfilePinsForSetRow struct {
 +	RepoID   int64
 +	Position int32
 +}
++
 +func (q *Queries) ListProfilePinsForSet(ctx context.Context, db DBTX, setID int64) ([]ListProfilePinsForSetRow, error) {
 +	rows, err := db.Query(ctx, listProfilePinsForSet, setID)
 +	if err != nil {
 +		return nil, err
 +	}
 +	defer rows.Close()
 +	items := []ListProfilePinsForSetRow{}
 +	for rows.Next() {
 +		var i ListProfilePinsForSetRow
 +		if err := rows.Scan(&i.RepoID, &i.Position); err != nil {
 +			return nil, err
 +		}
 +		items = append(items, i)
 +	}
 +	if err := rows.Err(); err != nil {
 +		return nil, err
 +	}
 +	return items, nil
 +}
++
  const listRepoTopics = `-- name: ListRepoTopics :many
  SELECT topic FROM repo_topics WHERE repo_id = $1 ORDER BY topic ASC
+ 	)
  	return err
+ }
++
 +const upsertProfilePinSetForOrg = `-- name: UpsertProfilePinSetForOrg :one
 +INSERT INTO profile_pin_sets (owner_org_id)
 +VALUES ($1)
 +ON CONFLICT (owner_org_id) WHERE owner_org_id IS NOT NULL
 +DO UPDATE SET updated_at = now()
 +RETURNING id
 +`
++
 +func (q *Queries) UpsertProfilePinSetForOrg(ctx context.Context, db DBTX, ownerOrgID pgtype.Int8) (int64, error) {
 +	row := db.QueryRow(ctx, upsertProfilePinSetForOrg, ownerOrgID)
 +	var id int64
 +	err := row.Scan(&id)
 +	return id, err
 +}
++
 +const upsertProfilePinSetForUser = `-- name: UpsertProfilePinSetForUser :one
 +INSERT INTO profile_pin_sets (owner_user_id)
 +VALUES ($1)
 +ON CONFLICT (owner_user_id) WHERE owner_user_id IS NOT NULL
 +DO UPDATE SET updated_at = now()
 +RETURNING id
 +`
++
 +func (q *Queries) UpsertProfilePinSetForUser(ctx context.Context, db DBTX, ownerUserID pgtype.Int8) (int64, error) {
 +	row := db.QueryRow(ctx, upsertProfilePinSetForUser, ownerUserID)
 +	var id int64
 +	err := row.Scan(&id)
 +	return id, err
 +}

internal/social/sqlc/models.gomodified

  	ID   int64
+ }
 +type ProfilePin struct {
 +	SetID    int64
 +	RepoID   int64
 +	Position int32
 +	PinnedAt pgtype.Timestamptz
 +}
++
 +type ProfilePinSet struct {
 +	ID          int64
 +	OwnerUserID pgtype.Int8
 +	OwnerOrgID  pgtype.Int8
 +	UpdatedAt   pgtype.Timestamptz
 +}
++
  type PullRequest struct {
  	IssueID            int64
  	BaseRef            string

internal/users/sqlc/models.gomodified

  	ID   int64
+ }
 +type ProfilePin struct {
 +	SetID    int64
 +	RepoID   int64
 +	Position int32
 +	PinnedAt pgtype.Timestamptz
 +}
++
 +type ProfilePinSet struct {
 +	ID          int64
 +	OwnerUserID pgtype.Int8
 +	OwnerOrgID  pgtype.Int8
 +	UpdatedAt   pgtype.Timestamptz
 +}
++
  type PullRequest struct {
  	IssueID            int64
  	BaseRef            string

internal/webhook/sqlc/models.gomodified

  	ID   int64
+ }
 +type ProfilePin struct {
 +	SetID    int64
 +	RepoID   int64
 +	Position int32
 +	PinnedAt pgtype.Timestamptz
 +}
++
 +type ProfilePinSet struct {
 +	ID          int64
 +	OwnerUserID pgtype.Int8
 +	OwnerOrgID  pgtype.Int8
 +	UpdatedAt   pgtype.Timestamptz
 +}
++
  type PullRequest struct {
  	IssueID            int64
  	BaseRef            string

internal/worker/sqlc/models.gomodified

  	ID   int64
+ }
 +type ProfilePin struct {
 +	SetID    int64
 +	RepoID   int64
 +	Position int32
 +	PinnedAt pgtype.Timestamptz
 +}
++
 +type ProfilePinSet struct {
 +	ID          int64
 +	OwnerUserID pgtype.Int8
 +	OwnerOrgID  pgtype.Int8
 +	UpdatedAt   pgtype.Timestamptz
 +}
++
  type PullRequest struct {
  	IssueID            int64
  	BaseRef            string

tenseleyflow/shithub / `cd0fd78`

18 changed files