shithub Public

Watch 1 Fork 0 Star 0
Go · 6093 bytes Raw Blame History
1 // Code generated by sqlc. DO NOT EDIT.
2 // versions:
3 // sqlc v1.31.1
4 // source: workflow_secrets.sql
5
6 package actionsdb
7
8 import (
9 "context"
10
11 "github.com/jackc/pgx/v5/pgtype"
12 )
13
14 const deleteOrgSecret = `-- name: DeleteOrgSecret :exec
15 DELETE FROM workflow_secrets WHERE org_id = $1 AND name = $2
16 `
17
18 type DeleteOrgSecretParams struct {
19 OrgID pgtype.Int8
20 Name string
21 }
22
23 func (q *Queries) DeleteOrgSecret(ctx context.Context, db DBTX, arg DeleteOrgSecretParams) error {
24 _, err := db.Exec(ctx, deleteOrgSecret, arg.OrgID, arg.Name)
25 return err
26 }
27
28 const deleteRepoSecret = `-- name: DeleteRepoSecret :exec
29 DELETE FROM workflow_secrets WHERE repo_id = $1 AND name = $2
30 `
31
32 type DeleteRepoSecretParams struct {
33 RepoID pgtype.Int8
34 Name string
35 }
36
37 func (q *Queries) DeleteRepoSecret(ctx context.Context, db DBTX, arg DeleteRepoSecretParams) error {
38 _, err := db.Exec(ctx, deleteRepoSecret, arg.RepoID, arg.Name)
39 return err
40 }
41
42 const getOrgSecret = `-- name: GetOrgSecret :one
43 SELECT id, name, ciphertext, nonce
44 FROM workflow_secrets
45 WHERE org_id = $1 AND name = $2
46 `
47
48 type GetOrgSecretParams struct {
49 OrgID pgtype.Int8
50 Name string
51 }
52
53 type GetOrgSecretRow struct {
54 ID int64
55 Name string
56 Ciphertext []byte
57 Nonce []byte
58 }
59
60 func (q *Queries) GetOrgSecret(ctx context.Context, db DBTX, arg GetOrgSecretParams) (GetOrgSecretRow, error) {
61 row := db.QueryRow(ctx, getOrgSecret, arg.OrgID, arg.Name)
62 var i GetOrgSecretRow
63 err := row.Scan(
64 &i.ID,
65 &i.Name,
66 &i.Ciphertext,
67 &i.Nonce,
68 )
69 return i, err
70 }
71
72 const getRepoSecret = `-- name: GetRepoSecret :one
73 SELECT id, name, ciphertext, nonce
74 FROM workflow_secrets
75 WHERE repo_id = $1 AND name = $2
76 `
77
78 type GetRepoSecretParams struct {
79 RepoID pgtype.Int8
80 Name string
81 }
82
83 type GetRepoSecretRow struct {
84 ID int64
85 Name string
86 Ciphertext []byte
87 Nonce []byte
88 }
89
90 func (q *Queries) GetRepoSecret(ctx context.Context, db DBTX, arg GetRepoSecretParams) (GetRepoSecretRow, error) {
91 row := db.QueryRow(ctx, getRepoSecret, arg.RepoID, arg.Name)
92 var i GetRepoSecretRow
93 err := row.Scan(
94 &i.ID,
95 &i.Name,
96 &i.Ciphertext,
97 &i.Nonce,
98 )
99 return i, err
100 }
101
102 const listOrgSecrets = `-- name: ListOrgSecrets :many
103 SELECT id, name, created_by_user_id, created_at, updated_at
104 FROM workflow_secrets
105 WHERE org_id = $1
106 ORDER BY name ASC
107 `
108
109 type ListOrgSecretsRow struct {
110 ID int64
111 Name string
112 CreatedByUserID pgtype.Int8
113 CreatedAt pgtype.Timestamptz
114 UpdatedAt pgtype.Timestamptz
115 }
116
117 func (q *Queries) ListOrgSecrets(ctx context.Context, db DBTX, orgID pgtype.Int8) ([]ListOrgSecretsRow, error) {
118 rows, err := db.Query(ctx, listOrgSecrets, orgID)
119 if err != nil {
120 return nil, err
121 }
122 defer rows.Close()
123 items := []ListOrgSecretsRow{}
124 for rows.Next() {
125 var i ListOrgSecretsRow
126 if err := rows.Scan(
127 &i.ID,
128 &i.Name,
129 &i.CreatedByUserID,
130 &i.CreatedAt,
131 &i.UpdatedAt,
132 ); err != nil {
133 return nil, err
134 }
135 items = append(items, i)
136 }
137 if err := rows.Err(); err != nil {
138 return nil, err
139 }
140 return items, nil
141 }
142
143 const listRepoSecrets = `-- name: ListRepoSecrets :many
144 SELECT id, name, created_by_user_id, created_at, updated_at
145 FROM workflow_secrets
146 WHERE repo_id = $1
147 ORDER BY name ASC
148 `
149
150 type ListRepoSecretsRow struct {
151 ID int64
152 Name string
153 CreatedByUserID pgtype.Int8
154 CreatedAt pgtype.Timestamptz
155 UpdatedAt pgtype.Timestamptz
156 }
157
158 func (q *Queries) ListRepoSecrets(ctx context.Context, db DBTX, repoID pgtype.Int8) ([]ListRepoSecretsRow, error) {
159 rows, err := db.Query(ctx, listRepoSecrets, repoID)
160 if err != nil {
161 return nil, err
162 }
163 defer rows.Close()
164 items := []ListRepoSecretsRow{}
165 for rows.Next() {
166 var i ListRepoSecretsRow
167 if err := rows.Scan(
168 &i.ID,
169 &i.Name,
170 &i.CreatedByUserID,
171 &i.CreatedAt,
172 &i.UpdatedAt,
173 ); err != nil {
174 return nil, err
175 }
176 items = append(items, i)
177 }
178 if err := rows.Err(); err != nil {
179 return nil, err
180 }
181 return items, nil
182 }
183
184 const upsertOrgSecret = `-- name: UpsertOrgSecret :one
185 INSERT INTO workflow_secrets (org_id, name, ciphertext, nonce, created_by_user_id)
186 VALUES ($1, $2, $3, $4, $5)
187 ON CONFLICT (org_id, name) WHERE org_id IS NOT NULL DO UPDATE
188 SET ciphertext = EXCLUDED.ciphertext,
189 nonce = EXCLUDED.nonce,
190 updated_at = now()
191 RETURNING id, repo_id, org_id, name, ciphertext, nonce,
192 created_by_user_id, created_at, updated_at
193 `
194
195 type UpsertOrgSecretParams struct {
196 OrgID pgtype.Int8
197 Name string
198 Ciphertext []byte
199 Nonce []byte
200 CreatedByUserID pgtype.Int8
201 }
202
203 func (q *Queries) UpsertOrgSecret(ctx context.Context, db DBTX, arg UpsertOrgSecretParams) (WorkflowSecret, error) {
204 row := db.QueryRow(ctx, upsertOrgSecret,
205 arg.OrgID,
206 arg.Name,
207 arg.Ciphertext,
208 arg.Nonce,
209 arg.CreatedByUserID,
210 )
211 var i WorkflowSecret
212 err := row.Scan(
213 &i.ID,
214 &i.RepoID,
215 &i.OrgID,
216 &i.Name,
217 &i.Ciphertext,
218 &i.Nonce,
219 &i.CreatedByUserID,
220 &i.CreatedAt,
221 &i.UpdatedAt,
222 )
223 return i, err
224 }
225
226 const upsertRepoSecret = `-- name: UpsertRepoSecret :one
227
228 INSERT INTO workflow_secrets (repo_id, name, ciphertext, nonce, created_by_user_id)
229 VALUES ($1, $2, $3, $4, $5)
230 ON CONFLICT (repo_id, name) WHERE repo_id IS NOT NULL DO UPDATE
231 SET ciphertext = EXCLUDED.ciphertext,
232 nonce = EXCLUDED.nonce,
233 updated_at = now()
234 RETURNING id, repo_id, org_id, name, ciphertext, nonce,
235 created_by_user_id, created_at, updated_at
236 `
237
238 type UpsertRepoSecretParams struct {
239 RepoID pgtype.Int8
240 Name string
241 Ciphertext []byte
242 Nonce []byte
243 CreatedByUserID pgtype.Int8
244 }
245
246 // SPDX-License-Identifier: AGPL-3.0-or-later
247 func (q *Queries) UpsertRepoSecret(ctx context.Context, db DBTX, arg UpsertRepoSecretParams) (WorkflowSecret, error) {
248 row := db.QueryRow(ctx, upsertRepoSecret,
249 arg.RepoID,
250 arg.Name,
251 arg.Ciphertext,
252 arg.Nonce,
253 arg.CreatedByUserID,
254 )
255 var i WorkflowSecret
256 err := row.Scan(
257 &i.ID,
258 &i.RepoID,
259 &i.OrgID,
260 &i.Name,
261 &i.Ciphertext,
262 &i.Nonce,
263 &i.CreatedByUserID,
264 &i.CreatedAt,
265 &i.UpdatedAt,
266 )
267 return i, err
268 }
269