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 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 95func (q *Queries) ListExternalCandidates(ctx context.Context, limit int32) ([]ListExternalCandidatesRow, error) { 96 rows, err := q.db.Query(ctx, listExternalCandidates, limit) 97 if err != nil { 98 return nil, err 99 } 100 defer rows.Close() 101 items := []ListExternalCandidatesRow{} 102 for rows.Next() { 103 var i ListExternalCandidatesRow 104 if err := rows.Scan( 105 &i.ID, 106 &i.FullName, 107 &i.Email, 108 &i.Headline, 109 &i.Location, 110 &i.YearsExperience, 111 &i.Available, 112 &i.ExternalID, 113 &i.CreatedAt, 114 ); err != nil { 115 return nil, err 116 } 117 items = append(items, i) 118 } 119 if err := rows.Err(); err != nil { 120 return nil, err 121 } 122 return items, nil 123} 124 125const listSourcingLog = `-- name: ListSourcingLog :many 126SELECT id, candidate_id, external_id, source, provider, query, legal_basis, collected_at 127FROM sourcing_log 128ORDER BY collected_at DESC 129LIMIT $1 130` 131 132type ListSourcingLogRow struct { 133 ID uuid.UUID `json:"id"` 134 CandidateID *uuid.UUID `json:"candidate_id"` 135 ExternalID string `json:"external_id"` 136 Source string `json:"source"` 137 Provider string `json:"provider"` 138 Query string `json:"query"` 139 LegalBasis string `json:"legal_basis"` 140 CollectedAt time.Time `json:"collected_at"` 141} 142 143func (q *Queries) ListSourcingLog(ctx context.Context, limit int32) ([]ListSourcingLogRow, error) { 144 rows, err := q.db.Query(ctx, listSourcingLog, limit) 145 if err != nil { 146 return nil, err 147 } 148 defer rows.Close() 149 items := []ListSourcingLogRow{} 150 for rows.Next() { 151 var i ListSourcingLogRow 152 if err := rows.Scan( 153 &i.ID, 154 &i.CandidateID, 155 &i.ExternalID, 156 &i.Source, 157 &i.Provider, 158 &i.Query, 159 &i.LegalBasis, 160 &i.CollectedAt, 161 ); err != nil { 162 return nil, err 163 } 164 items = append(items, i) 165 } 166 if err := rows.Err(); err != nil { 167 return nil, err 168 } 169 return items, nil 170} 171 172const upsertExternalCandidate = `-- name: UpsertExternalCandidate :one 173 174INSERT INTO candidates ( 175 organization_id, full_name, email, headline, 176 clearance_level, clearance_poly, clearance_status, 177 years_experience, location, remote, relocatable, available, source, external_id 178) VALUES ( 179 $1, $2, $3, $4, 180 'unknown', 'none', 'unknown', 181 $5, $6, $7, false, true, 'external', $8 182) 183ON CONFLICT (organization_id, external_id) WHERE external_id IS NOT NULL DO UPDATE SET 184 full_name = EXCLUDED.full_name, 185 email = EXCLUDED.email, 186 headline = EXCLUDED.headline, 187 years_experience = EXCLUDED.years_experience, 188 location = EXCLUDED.location, 189 remote = EXCLUDED.remote, 190 updated_at = now() 191RETURNING id 192` 193 194type UpsertExternalCandidateParams struct { 195 OrganizationID uuid.UUID `json:"organization_id"` 196 FullName string `json:"full_name"` 197 Email *string `json:"email"` 198 Headline *string `json:"headline"` 199 YearsExperience int32 `json:"years_experience"` 200 Location *string `json:"location"` 201 Remote bool `json:"remote"` 202 ExternalID *string `json:"external_id"` 203} 204 205// External candidate sourcing. The import command (cmd/import-candidates) writes as the migrator role 206// with an explicit organization_id; the delete path runs as the app role inside a tenant tx (RLS). 207func (q *Queries) UpsertExternalCandidate(ctx context.Context, arg UpsertExternalCandidateParams) (uuid.UUID, error) { 208 row := q.db.QueryRow(ctx, upsertExternalCandidate, 209 arg.OrganizationID, 210 arg.FullName, 211 arg.Email, 212 arg.Headline, 213 arg.YearsExperience, 214 arg.Location, 215 arg.Remote, 216 arg.ExternalID, 217 ) 218 var id uuid.UUID 219 err := row.Scan(&id) 220 return id, err 221} 222