Janady13/missionmatch / internal/platform/database/dbgen/governance.sql.go

1// Code generated by sqlc. DO NOT EDIT. 2// versions: 3// sqlc v1.31.1 4// source: governance.sql 5 6package dbgen 7 8import ( 9 "context" 10 11 "github.com/google/uuid" 12) 13 14const insertCandidateNotice = `-- name: InsertCandidateNotice :one 15INSERT INTO aedt_candidate_notices (organization_id, candidate_id, notice_version, data_categories, retention_days, disclosed_by) 16VALUES (NULLIF(current_setting('app.current_org_id', true), '')::uuid, $1, $2, $3, $4, $5) 17RETURNING id, organization_id, candidate_id, notice_version, data_categories, retention_days, disclosed_by, disclosed_at 18` 19 20type InsertCandidateNoticeParams struct { 21 CandidateID uuid.UUID `json:"candidate_id"` 22 NoticeVersion string `json:"notice_version"` 23 DataCategories []byte `json:"data_categories"` 24 RetentionDays int32 `json:"retention_days"` 25 DisclosedBy *uuid.UUID `json:"disclosed_by"` 26} 27 28func (q *Queries) InsertCandidateNotice(ctx context.Context, arg InsertCandidateNoticeParams) (AedtCandidateNotice, error) { 29 row := q.db.QueryRow(ctx, insertCandidateNotice, 30 arg.CandidateID, 31 arg.NoticeVersion, 32 arg.DataCategories, 33 arg.RetentionDays, 34 arg.DisclosedBy, 35 ) 36 var i AedtCandidateNotice 37 err := row.Scan( 38 &i.ID, 39 &i.OrganizationID, 40 &i.CandidateID, 41 &i.NoticeVersion, 42 &i.DataCategories, 43 &i.RetentionDays, 44 &i.DisclosedBy, 45 &i.DisclosedAt, 46 ) 47 return i, err 48} 49 50const listAedtInventory = `-- name: ListAedtInventory :many 51SELECT id, organization_id, tool_key, display_name, purpose, model_version, active, created_at, updated_at FROM aedt_inventory ORDER BY created_at DESC 52` 53 54func (q *Queries) ListAedtInventory(ctx context.Context) ([]AedtInventory, error) { 55 rows, err := q.db.Query(ctx, listAedtInventory) 56 if err != nil { 57 return nil, err 58 } 59 defer rows.Close() 60 items := []AedtInventory{} 61 for rows.Next() { 62 var i AedtInventory 63 if err := rows.Scan( 64 &i.ID, 65 &i.OrganizationID, 66 &i.ToolKey, 67 &i.DisplayName, 68 &i.Purpose, 69 &i.ModelVersion, 70 &i.Active, 71 &i.CreatedAt, 72 &i.UpdatedAt, 73 ); err != nil { 74 return nil, err 75 } 76 items = append(items, i) 77 } 78 if err := rows.Err(); err != nil { 79 return nil, err 80 } 81 return items, nil 82} 83 84const listModelVersions = `-- name: ListModelVersions :many 85 86SELECT version, weights, band_cuts, notes, effective_from, created_at 87FROM aedt_model_versions 88ORDER BY effective_from DESC 89` 90 91// AEDT governance: model version registry, the org AEDT inventory, candidate notices, and the 92// retention sweep. All on the app pool under RLS (the eeo schema is reached only by the compliance 93// pool, never here). 94func (q *Queries) ListModelVersions(ctx context.Context) ([]AedtModelVersion, error) { 95 rows, err := q.db.Query(ctx, listModelVersions) 96 if err != nil { 97 return nil, err 98 } 99 defer rows.Close() 100 items := []AedtModelVersion{} 101 for rows.Next() { 102 var i AedtModelVersion 103 if err := rows.Scan( 104 &i.Version, 105 &i.Weights, 106 &i.BandCuts, 107 &i.Notes, 108 &i.EffectiveFrom, 109 &i.CreatedAt, 110 ); err != nil { 111 return nil, err 112 } 113 items = append(items, i) 114 } 115 if err := rows.Err(); err != nil { 116 return nil, err 117 } 118 return items, nil 119} 120 121const retentionDueCandidates = `-- name: RetentionDueCandidates :many 122SELECT c.id 123FROM candidates c 124WHERE c.anonymized_at IS NULL 125 AND ( 126 SELECT max(sm.decided_at) 127 FROM slate_members sm 128 WHERE sm.candidate_id = c.id AND sm.decided_at IS NOT NULL 129 ) < now() - make_interval(days => $1::int) 130LIMIT 500 131` 132 133// Candidates whose most recent recorded decision is older than the retention window and whose PII is 134// not yet anonymized. The de identified slate_members outcomes are retained; only the candidate PII is 135// wiped (by AnonymizeCandidate). RLS scopes this to the caller's org. 136func (q *Queries) RetentionDueCandidates(ctx context.Context, dollar_1 int32) ([]uuid.UUID, error) { 137 rows, err := q.db.Query(ctx, retentionDueCandidates, dollar_1) 138 if err != nil { 139 return nil, err 140 } 141 defer rows.Close() 142 items := []uuid.UUID{} 143 for rows.Next() { 144 var id uuid.UUID 145 if err := rows.Scan(&id); err != nil { 146 return nil, err 147 } 148 items = append(items, id) 149 } 150 if err := rows.Err(); err != nil { 151 return nil, err 152 } 153 return items, nil 154} 155 156const upsertAedtInventory = `-- name: UpsertAedtInventory :one 157INSERT INTO aedt_inventory (organization_id, tool_key, display_name, purpose, model_version) 158VALUES (NULLIF(current_setting('app.current_org_id', true), '')::uuid, $1, $2, $3, $4) 159ON CONFLICT (organization_id, tool_key) DO UPDATE 160 SET display_name = EXCLUDED.display_name, 161 purpose = EXCLUDED.purpose, 162 model_version = EXCLUDED.model_version, 163 updated_at = now() 164RETURNING id, organization_id, tool_key, display_name, purpose, model_version, active, created_at, updated_at 165` 166 167type UpsertAedtInventoryParams struct { 168 ToolKey string `json:"tool_key"` 169 DisplayName string `json:"display_name"` 170 Purpose string `json:"purpose"` 171 ModelVersion *string `json:"model_version"` 172} 173 174func (q *Queries) UpsertAedtInventory(ctx context.Context, arg UpsertAedtInventoryParams) (AedtInventory, error) { 175 row := q.db.QueryRow(ctx, upsertAedtInventory, 176 arg.ToolKey, 177 arg.DisplayName, 178 arg.Purpose, 179 arg.ModelVersion, 180 ) 181 var i AedtInventory 182 err := row.Scan( 183 &i.ID, 184 &i.OrganizationID, 185 &i.ToolKey, 186 &i.DisplayName, 187 &i.Purpose, 188 &i.ModelVersion, 189 &i.Active, 190 &i.CreatedAt, 191 &i.UpdatedAt, 192 ) 193 return i, err 194} 195