| 1 | -- SPDX-License-Identifier: AGPL-3.0-or-later |
| 2 | |
| 3 | -- name: GetRepoSourceRemote :one |
| 4 | SELECT repo_id, remote_url, last_fetched_at, last_error, created_at, updated_at |
| 5 | FROM repo_source_remotes |
| 6 | WHERE repo_id = $1; |
| 7 | |
| 8 | -- name: UpsertRepoSourceRemote :one |
| 9 | INSERT INTO repo_source_remotes (repo_id, remote_url, last_error) |
| 10 | VALUES ($1, $2, NULL) |
| 11 | ON CONFLICT (repo_id) DO UPDATE |
| 12 | SET remote_url = EXCLUDED.remote_url, |
| 13 | last_error = NULL, |
| 14 | updated_at = now() |
| 15 | RETURNING repo_id, remote_url, last_fetched_at, last_error, created_at, updated_at; |
| 16 | |
| 17 | -- name: DeleteRepoSourceRemote :exec |
| 18 | DELETE FROM repo_source_remotes |
| 19 | WHERE repo_id = $1; |
| 20 | |
| 21 | -- name: MarkRepoSourceRemoteFetched :exec |
| 22 | UPDATE repo_source_remotes |
| 23 | SET last_fetched_at = now(), |
| 24 | last_error = NULL, |
| 25 | updated_at = now() |
| 26 | WHERE repo_id = $1; |
| 27 | |
| 28 | -- name: MarkRepoSourceRemoteFetchError :exec |
| 29 | UPDATE repo_source_remotes |
| 30 | SET last_error = $2, |
| 31 | updated_at = now() |
| 32 | WHERE repo_id = $1; |
| 33 |