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

1// Code generated by sqlc. DO NOT EDIT. 2// versions: 3// sqlc v1.31.1 4// source: sam.sql 5 6package dbgen 7 8import ( 9 "context" 10 "time" 11 12 "github.com/jackc/pgx/v5/pgtype" 13) 14 15const getSamOpportunity = `-- name: GetSamOpportunity :one 16SELECT notice_id, title, solicitation_number, department, full_parent_path, sub_agency, naics_code, psc_code, set_aside_code, set_aside, notice_type, base_type, posted_date, response_deadline, active, pop_city, pop_state, pop_zip, ui_link, description_url, resource_links, poc, raw, source, synced_at FROM sam_opportunities WHERE notice_id = $1 17` 18 19func (q *Queries) GetSamOpportunity(ctx context.Context, noticeID string) (SamOpportunity, error) { 20 row := q.db.QueryRow(ctx, getSamOpportunity, noticeID) 21 var i SamOpportunity 22 err := row.Scan( 23 &i.NoticeID, 24 &i.Title, 25 &i.SolicitationNumber, 26 &i.Department, 27 &i.FullParentPath, 28 &i.SubAgency, 29 &i.NaicsCode, 30 &i.PscCode, 31 &i.SetAsideCode, 32 &i.SetAside, 33 &i.NoticeType, 34 &i.BaseType, 35 &i.PostedDate, 36 &i.ResponseDeadline, 37 &i.Active, 38 &i.PopCity, 39 &i.PopState, 40 &i.PopZip, 41 &i.UiLink, 42 &i.DescriptionUrl, 43 &i.ResourceLinks, 44 &i.Poc, 45 &i.Raw, 46 &i.Source, 47 &i.SyncedAt, 48 ) 49 return i, err 50} 51 52const listSamOpportunities = `-- name: ListSamOpportunities :many 53SELECT notice_id, title, solicitation_number, department, full_parent_path, sub_agency, naics_code, psc_code, set_aside_code, set_aside, notice_type, base_type, posted_date, response_deadline, active, pop_city, pop_state, pop_zip, ui_link, description_url, resource_links, poc, raw, source, synced_at FROM sam_opportunities 54WHERE ($1::text[] IS NULL OR naics_code = ANY($1::text[])) 55 AND ($2::text[] IS NULL OR upper(set_aside_code) = ANY($2::text[])) 56 AND ($3::text[] IS NULL OR upper(pop_state) = ANY($3::text[])) 57 AND ($4::text[] IS NULL OR upper(department) = ANY($4::text[])) 58 AND ($5::text[] IS NULL OR upper(sub_agency) = ANY($5::text[])) 59 AND ($6::text IS NULL OR position(lower($6::text) in lower(title)) > 0) 60 AND (NOT $7::boolean OR active = true) 61ORDER BY (response_deadline IS NULL OR response_deadline < now()), response_deadline ASC, posted_date DESC NULLS LAST, notice_id 62LIMIT $8::int 63` 64 65type ListSamOpportunitiesParams struct { 66 Naics []string `json:"naics"` 67 SetAsides []string `json:"set_asides"` 68 States []string `json:"states"` 69 Departments []string `json:"departments"` 70 SubAgencies []string `json:"sub_agencies"` 71 Q *string `json:"q"` 72 ActiveOnly bool `json:"active_only"` 73 Lim int32 `json:"lim"` 74} 75 76// All filters are optional (NULL array / NULL scalar = "no filter"). active_only defaults true at the 77// handler. Soonest-closing first, then most-recently-posted. 78// Text equality filters are case-insensitive (upper() both sides; the service upper-cases the params) 79// so casing drift from SAM's path text can't silently zero out results [review COR-3]. The title search 80// is a literal substring (position()), NOT a LIKE pattern, so q's %/_/\ are matched literally and a 81// trailing backslash can't 500 the request [review COR-1]. Past-deadline / null-deadline notices sort 82// to the bottom so the feed leads with what's still open [review COR-2]. 83func (q *Queries) ListSamOpportunities(ctx context.Context, arg ListSamOpportunitiesParams) ([]SamOpportunity, error) { 84 rows, err := q.db.Query(ctx, listSamOpportunities, 85 arg.Naics, 86 arg.SetAsides, 87 arg.States, 88 arg.Departments, 89 arg.SubAgencies, 90 arg.Q, 91 arg.ActiveOnly, 92 arg.Lim, 93 ) 94 if err != nil { 95 return nil, err 96 } 97 defer rows.Close() 98 items := []SamOpportunity{} 99 for rows.Next() { 100 var i SamOpportunity 101 if err := rows.Scan( 102 &i.NoticeID, 103 &i.Title, 104 &i.SolicitationNumber, 105 &i.Department, 106 &i.FullParentPath, 107 &i.SubAgency, 108 &i.NaicsCode, 109 &i.PscCode, 110 &i.SetAsideCode, 111 &i.SetAside, 112 &i.NoticeType, 113 &i.BaseType, 114 &i.PostedDate, 115 &i.ResponseDeadline, 116 &i.Active, 117 &i.PopCity, 118 &i.PopState, 119 &i.PopZip, 120 &i.UiLink, 121 &i.DescriptionUrl, 122 &i.ResourceLinks, 123 &i.Poc, 124 &i.Raw, 125 &i.Source, 126 &i.SyncedAt, 127 ); err != nil { 128 return nil, err 129 } 130 items = append(items, i) 131 } 132 if err := rows.Err(); err != nil { 133 return nil, err 134 } 135 return items, nil 136} 137 138const samSyncMeta = `-- name: SamSyncMeta :one 139SELECT COUNT(*)::bigint AS total, MAX(synced_at) AS last_synced FROM sam_opportunities 140` 141 142type SamSyncMetaRow struct { 143 Total int64 `json:"total"` 144 LastSynced interface{} `json:"last_synced"` 145} 146 147func (q *Queries) SamSyncMeta(ctx context.Context) (SamSyncMetaRow, error) { 148 row := q.db.QueryRow(ctx, samSyncMeta) 149 var i SamSyncMetaRow 150 err := row.Scan(&i.Total, &i.LastSynced) 151 return i, err 152} 153 154const upsertSamOpportunity = `-- name: UpsertSamOpportunity :exec 155 156INSERT INTO sam_opportunities ( 157 notice_id, title, solicitation_number, department, full_parent_path, sub_agency, 158 naics_code, psc_code, set_aside_code, set_aside, notice_type, base_type, 159 posted_date, response_deadline, active, pop_city, pop_state, pop_zip, 160 ui_link, description_url, resource_links, poc, raw, source, synced_at 161) VALUES ( 162 $1, $2, $3, $4, $5, $6, 163 $7, $8, $9, $10, $11, $12, 164 $13, $14, $15, $16, $17, $18, 165 $19, $20, $21, $22, $23, $24, now() 166) 167ON CONFLICT (notice_id) DO UPDATE SET 168 title = EXCLUDED.title, 169 solicitation_number = EXCLUDED.solicitation_number, 170 department = EXCLUDED.department, 171 full_parent_path = EXCLUDED.full_parent_path, 172 sub_agency = EXCLUDED.sub_agency, 173 naics_code = EXCLUDED.naics_code, 174 psc_code = EXCLUDED.psc_code, 175 set_aside_code = EXCLUDED.set_aside_code, 176 set_aside = EXCLUDED.set_aside, 177 notice_type = EXCLUDED.notice_type, 178 base_type = EXCLUDED.base_type, 179 posted_date = EXCLUDED.posted_date, 180 response_deadline = EXCLUDED.response_deadline, 181 active = EXCLUDED.active, 182 pop_city = EXCLUDED.pop_city, 183 pop_state = EXCLUDED.pop_state, 184 pop_zip = EXCLUDED.pop_zip, 185 ui_link = EXCLUDED.ui_link, 186 description_url = EXCLUDED.description_url, 187 resource_links = EXCLUDED.resource_links, 188 poc = EXCLUDED.poc, 189 raw = EXCLUDED.raw, 190 source = EXCLUDED.source, 191 synced_at = now() 192` 193 194type UpsertSamOpportunityParams struct { 195 NoticeID string `json:"notice_id"` 196 Title string `json:"title"` 197 SolicitationNumber string `json:"solicitation_number"` 198 Department string `json:"department"` 199 FullParentPath string `json:"full_parent_path"` 200 SubAgency string `json:"sub_agency"` 201 NaicsCode string `json:"naics_code"` 202 PscCode string `json:"psc_code"` 203 SetAsideCode string `json:"set_aside_code"` 204 SetAside string `json:"set_aside"` 205 NoticeType string `json:"notice_type"` 206 BaseType string `json:"base_type"` 207 PostedDate pgtype.Date `json:"posted_date"` 208 ResponseDeadline *time.Time `json:"response_deadline"` 209 Active bool `json:"active"` 210 PopCity string `json:"pop_city"` 211 PopState string `json:"pop_state"` 212 PopZip string `json:"pop_zip"` 213 UiLink string `json:"ui_link"` 214 DescriptionUrl string `json:"description_url"` 215 ResourceLinks []byte `json:"resource_links"` 216 Poc []byte `json:"poc"` 217 Raw []byte `json:"raw"` 218 Source string `json:"source"` 219} 220 221// SAM.gov opportunities cache. Global public catalog (no organization_id, outside RLS): reads run 222// straight off the pool, writes come from the daily sync (cmd/sam-sync) as the migrator role. 223func (q *Queries) UpsertSamOpportunity(ctx context.Context, arg UpsertSamOpportunityParams) error { 224 _, err := q.db.Exec(ctx, upsertSamOpportunity, 225 arg.NoticeID, 226 arg.Title, 227 arg.SolicitationNumber, 228 arg.Department, 229 arg.FullParentPath, 230 arg.SubAgency, 231 arg.NaicsCode, 232 arg.PscCode, 233 arg.SetAsideCode, 234 arg.SetAside, 235 arg.NoticeType, 236 arg.BaseType, 237 arg.PostedDate, 238 arg.ResponseDeadline, 239 arg.Active, 240 arg.PopCity, 241 arg.PopState, 242 arg.PopZip, 243 arg.UiLink, 244 arg.DescriptionUrl, 245 arg.ResourceLinks, 246 arg.Poc, 247 arg.Raw, 248 arg.Source, 249 ) 250 return err 251} 252