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

1// Code generated by sqlc. DO NOT EDIT. 2// versions: 3// sqlc v1.31.1 4// source: sourcing.sql 5 6package dbgen 7 8import ( 9 "context" 10 "time" 11 12 "github.com/google/uuid" 13) 14 15const deleteExternalCandidate = `-- name: DeleteExternalCandidate :execrows 16DELETE FROM candidates WHERE id = $1 AND source = 'external' 17` 18 19func (q *Queries) DeleteExternalCandidate(ctx context.Context, id uuid.UUID) (int64, error) { 20 result, err := q.db.Exec(ctx, deleteExternalCandidate, id) 21 if err != nil { 22 return 0, err 23 } 24 return result.RowsAffected(), nil 25} 26 27const deleteSlateMembersForCandidate = `-- name: DeleteSlateMembersForCandidate :exec 28DELETE FROM slate_members WHERE candidate_id = $1 29` 30 31// Erasure must also remove slate placements of the sourced person; slate_members has no ON DELETE rule 32// so the candidate delete would otherwise fail. RLS scopes this to the caller's org. 33func (q *Queries) DeleteSlateMembersForCandidate(ctx context.Context, candidateID uuid.UUID) error { 34 _, err := q.db.Exec(ctx, deleteSlateMembersForCandidate, candidateID) 35 return err 36} 37 38const detachSourcingLog = `-- name: DetachSourcingLog :exec 39UPDATE sourcing_log SET candidate_id = NULL WHERE candidate_id = $1 40` 41 42func (q *Queries) DetachSourcingLog(ctx context.Context, candidateID *uuid.UUID) error { 43 _, err := q.db.Exec(ctx, detachSourcingLog, candidateID) 44 return err 45} 46 47const insertSourcingLog = `-- name: InsertSourcingLog :exec 48INSERT INTO sourcing_log (organization_id, candidate_id, external_id, source, provider, query, legal_basis) 49VALUES ($1, $2, $3, $4, $5, $6, $7) 50` 51 52type InsertSourcingLogParams struct { 53 OrganizationID uuid.UUID `json:"organization_id"` 54 CandidateID *uuid.UUID `json:"candidate_id"` 55 ExternalID string `json:"external_id"` 56 Source string `json:"source"` 57 Provider string `json:"provider"` 58 Query string `json:"query"` 59 LegalBasis string `json:"legal_basis"` 60} 61 62func (q *Queries) InsertSourcingLog(ctx context.Context, arg InsertSourcingLogParams) error { 63 _, err := q.db.Exec(ctx, insertSourcingLog, 64 arg.OrganizationID, 65 arg.CandidateID, 66 arg.ExternalID, 67 arg.Source, 68 arg.Provider, 69 arg.Query, 70 arg.LegalBasis, 71 ) 72 return err 73} 74 75const listExternalCandidates = `-- name: ListExternalCandidates :many 76SELECT id, full_name, email, headline, location, years_experience, available, external_id, created_at 77FROM candidates 78WHERE source = 'external' AND deleted_at IS NULL 79ORDER BY created_at DESC, id DESC 80LIMIT $1 81` 82 83type ListExternalCandidatesRow struct { 84 ID uuid.UUID `json:"id"` 85 FullName string `json:"full_name"` 86 Email *string `json:"email"` 87 Headline *string `json:"headline"` 88 Location *string `json:"location"` 89 YearsExperience int32 `json:"years_experience"` 90 Available bool `json:"available"` 91 ExternalID *string `json:"external_id"` 92 CreatedAt time.Time `json:"created_at"` 93} 94 95// id is the unique trailing sort key so created_at ties leave a total order and the LIMIT cut is stable. 96func (q *Queries) ListExternalCandidates(ctx context.Context, limit int32) ([]ListExternalCandidatesRow, error) { 97 rows, err := q.db.Query(ctx, listExternalCandidates, limit) 98 if err != nil { 99 return nil, err 100 } 101 defer rows.Close() 102 items := []ListExternalCandidatesRow{} 103 for rows.Next() { 104 var i ListExternalCandidatesRow 105 if err := rows.Scan( 106 &i.ID, 107 &i.FullName, 108 &i.Email, 109 &i.Headline, 110 &i.Location, 111 &i.YearsExperience, 112 &i.Available, 113 &i.ExternalID, 114 &i.CreatedAt, 115 ); err != nil { 116 return nil, err 117 } 118 items = append(items, i) 119 } 120 if err := rows.Err(); err != nil { 121 return nil, err 122 } 123 return items, nil 124} 125 126const listSourcingLog = `-- name: ListSourcingLog :many 127SELECT id, candidate_id, external_id, source, provider, query, legal_basis, collected_at 128FROM sourcing_log 129ORDER BY collected_at DESC, id DESC 130LIMIT $1 131` 132 133type ListSourcingLogRow struct { 134 ID uuid.UUID `json:"id"` 135 CandidateID *uuid.UUID `json:"candidate_id"` 136 ExternalID string `json:"external_id"` 137 Source string `json:"source"` 138 Provider string `json:"provider"` 139 Query string `json:"query"` 140 LegalBasis string `json:"legal_basis"` 141 CollectedAt time.Time `json:"collected_at"` 142} 143 144// id is the unique trailing sort key so collected_at ties leave a total order and the LIMIT cut is stable. 145func (q *Queries) ListSourcingLog(ctx context.Context, limit int32) ([]ListSourcingLogRow, error) { 146 rows, err := q.db.Query(ctx, listSourcingLog, limit) 147 if err != nil { 148 return nil, err 149 } 150 defer rows.Close() 151 items := []ListSourcingLogRow{} 152 for rows.Next() { 153 var i ListSourcingLogRow 154 if err := rows.Scan( 155 &i.ID, 156 &i.CandidateID, 157 &i.ExternalID, 158 &i.Source, 159 &i.Provider, 160 &i.Query, 161 &i.LegalBasis, 162 &i.CollectedAt, 163 ); err != nil { 164 return nil, err 165 } 166 items = append(items, i) 167 } 168 if err := rows.Err(); err != nil { 169 return nil, err 170 } 171 return items, nil 172} 173 174const upsertExternalCandidate = `-- name: UpsertExternalCandidate :one 175 176INSERT INTO candidates ( 177 organization_id, full_name, email, headline, 178 clearance_level, clearance_poly, clearance_status, 179 years_experience, location, remote, relocatable, available, source, external_id 180) VALUES ( 181 $1, $2, $3, $4, 182 'unknown', 'none', 'unknown', 183 $5, $6, $7, false, true, 'external', $8 184) 185ON CONFLICT (organization_id, external_id) WHERE external_id IS NOT NULL DO UPDATE SET 186 full_name = EXCLUDED.full_name, 187 email = EXCLUDED.email, 188 headline = EXCLUDED.headline, 189 years_experience = EXCLUDED.years_experience, 190 location = EXCLUDED.location, 191 remote = EXCLUDED.remote, 192 updated_at = now() 193RETURNING id 194` 195 196type UpsertExternalCandidateParams struct { 197 OrganizationID uuid.UUID `json:"organization_id"` 198 FullName string `json:"full_name"` 199 Email *string `json:"email"` 200 Headline *string `json:"headline"` 201 YearsExperience int32 `json:"years_experience"` 202 Location *string `json:"location"` 203 Remote bool `json:"remote"` 204 ExternalID *string `json:"external_id"` 205} 206 207// External candidate sourcing. The import command (cmd/import-candidates) writes as the migrator role 208// with an explicit organization_id; the delete path runs as the app role inside a tenant tx (RLS). 209func (q *Queries) UpsertExternalCandidate(ctx context.Context, arg UpsertExternalCandidateParams) (uuid.UUID, error) { 210 row := q.db.QueryRow(ctx, upsertExternalCandidate, 211 arg.OrganizationID, 212 arg.FullName, 213 arg.Email, 214 arg.Headline, 215 arg.YearsExperience, 216 arg.Location, 217 arg.Remote, 218 arg.ExternalID, 219 ) 220 var id uuid.UUID 221 err := row.Scan(&id) 222 return id, err 223} 224