OXYGENHUB
◆ cancel-landed-runs oxygenhub / crates / hub / src / db / repos.rs
14.5 KiB · Rust · last changed Agent tokens decide approval gates only where the repository allows it 17 days ago source blame history raw
1
//! The `repositories` and `pushes` tables.
2
3
use super::{now_ms, Pool};
4
use hub_api::Visibility;
5
use sqlx::FromRow;
6
7
#[derive(Clone, Debug, Default, FromRow)]
8
pub struct RepoRow {
9
    pub id: i64,
10
    pub owner: String,
11
    pub name: String,
12
    pub description: String,
13
    pub default_bookmark: String,
14
    pub visibility: String,
15
    pub created_ms: i64,
16
    pub updated_ms: i64,
17
    #[sqlx(default)]
18
    pub git_mirror: bool,
19
    #[sqlx(default)]
20
    pub git_mirror_state: String,
21
    /// The repository this one was forked from (migration 0009).
22
    #[sqlx(default)]
23
    pub forked_from: Option<i64>,
24
    /// Space-separated topics (migration 0010).
25
    #[sqlx(default)]
26
    pub topics: String,
27
    /// OxygenFlow: `on`, `off`, or empty to follow hub.toml (migration 0018).
28
    #[sqlx(default)]
29
    pub flow: String,
30
    /// Its jobs' priority: `low`, `normal`, `high`, or empty to follow its
31
    /// organisation's and the site's (oxygenhub#244, migration 0073).
32
    #[sqlx(default)]
33
    pub flow_priority: String,
34
    /// Diffusion: `off`, `green`, `any`, or empty to follow hub.toml
35
    /// (migration 0058, #148).
36
    #[sqlx(default)]
37
    pub diffusion: String,
38
    /// Diffusion auto-land: `auto`, `propose`, or empty for propose
39
    /// (migration 0061).
40
    #[sqlx(default)]
41
    pub diffusion_land: String,
42
    /// Backups (migration 0062): empty with its owner's, `off`, or its own
43
    /// `hourly` or `daily`.
44
    #[sqlx(default)]
45
    pub backup: String,
46
    /// Read-only, with why (migration 0040, #108).
47
    #[sqlx(default)]
48
    pub archived: bool,
49
    #[sqlx(default)]
50
    pub archived_reason: String,
51
    /// Agents' tokens may approve or reject its approval gates (#258).
52
    #[sqlx(default)]
53
    pub agents_decide_gates: bool,
54
    /// Counts for the tabs; filled by `get` only.
55
    #[sqlx(default)]
56
    pub open_issues: i64,
57
    #[sqlx(default)]
58
    pub open_proposals: i64,
59
}
60
61
impl RepoRow {
62
    pub fn visibility(&self) -> Visibility {
63
        Visibility::parse(&self.visibility).unwrap_or(Visibility::Private)
64
    }
65
66
    pub fn topic_list(&self) -> Vec<&str> {
67
        self.topics.split_whitespace().collect()
68
    }
69
70
    pub fn slug(&self) -> String {
71
        format!("{}/{}", self.owner, self.name)
72
    }
73
}
74
75
#[derive(Clone, Debug, FromRow)]
76
pub struct PushRow {
77
    pub id: i64,
78
    pub at_ms: i64,
79
    pub reference: String,
80
    pub ok: bool,
81
    pub reason: String,
82
    pub old_state: String,
83
    pub new_state: String,
84
    pub heads: i64,
85
    pub changes: i64,
86
    pub pusher: String,
87
}
88
89
/// One reference's outcome in a push, as the protocol backend reports it.
90
#[derive(Clone, Debug)]
91
pub struct PushOutcome {
92
    pub reference: String,
93
    pub ok: bool,
94
    pub reason: String,
95
    pub old_state: String,
96
    pub new_state: String,
97
    pub heads: i64,
98
    pub changes: i64,
99
}
100
101
pub async fn list(pool: &Pool) -> sqlx::Result<Vec<RepoRow>> {
102
    sqlx::query_as("SELECT * FROM repositories ORDER BY updated_ms DESC, owner, name").fetch_all(pool).await
103
}
104
105
pub async fn get_by_id(pool: &Pool, id: i64) -> sqlx::Result<Option<RepoRow>> {
106
    sqlx::query_as("SELECT * FROM repositories WHERE id = $1").bind(id).fetch_optional(pool).await
107
}
108
109
pub async fn list_by_owner(pool: &Pool, owner: &str) -> sqlx::Result<Vec<RepoRow>> {
110
    sqlx::query_as("SELECT * FROM repositories WHERE owner = $1 ORDER BY updated_ms DESC, name").bind(owner).fetch_all(pool).await
111
}
112
113
/// One repository, with its open issue and proposal counts for the tabs.
114
pub async fn get(pool: &Pool, owner: &str, name: &str) -> sqlx::Result<Option<RepoRow>> {
115
    sqlx::query_as(
116
        "SELECT r.*, \
117
           (SELECT COUNT(*) FROM issues i WHERE i.repo_id = r.id AND i.state = 'open') AS open_issues, \
118
           (SELECT COUNT(*) FROM proposals p WHERE p.repo_id = r.id AND p.state IN ('open', 'draft')) AS open_proposals \
119
         FROM repositories r WHERE r.owner = $1 AND r.name = $2",
120
    )
121
    .bind(owner)
122
    .bind(name)
123
    .fetch_optional(pool)
124
    .await
125
}
126
127
/// Create a repository row. One under an organisation of two or more
128
/// members requires one sealed approval to land a proposal (oxygenhub#64),
129
/// since someone other than the author can then give it; others require none.
130
pub async fn create(pool: &Pool, owner: &str, name: &str, description: &str, visibility: Visibility) -> sqlx::Result<RepoRow> {
131
    let now = now_ms();
132
    sqlx::query_as(
133
        "INSERT INTO repositories (owner, name, description, visibility, created_ms, updated_ms, required_approvals) \
134
         VALUES ($1, $2, $3, $4, $5, $6, (SELECT CASE WHEN COUNT(*) >= 2 THEN 1 ELSE 0 END FROM org_members m JOIN organisations o ON o.id = m.org_id WHERE o.name = $7)) RETURNING *",
135
    )
136
    .bind(owner)
137
    .bind(name)
138
    .bind(description)
139
    .bind(visibility.as_str())
140
    .bind(now)
141
    .bind(now)
142
    .bind(owner)
143
    .fetch_one(pool)
144
    .await
145
}
146
147
/// The repository an old name now points at, after a transfer.
148
pub async fn moved_to(pool: &Pool, owner: &str, name: &str) -> sqlx::Result<Option<RepoRow>> {
149
    let id: Option<i64> = sqlx::query_scalar("SELECT repo_id FROM repo_redirects WHERE old_owner = $1 AND old_name = $2")
150
        .bind(owner)
151
        .bind(name)
152
        .fetch_optional(pool)
153
        .await?;
154
    match id {
155
        Some(id) => get_by_id(pool, id).await,
156
        None => Ok(None),
157
    }
158
}
159
160
/// Move a repository to another owner, keeping its name: the row, and a
161
/// redirect from the old name. A redirect that pointed at the new name
162
/// goes, so names never loop.
163
pub async fn transfer(pool: &Pool, id: i64, old_owner: &str, name: &str, new_owner: &str) -> sqlx::Result<()> {
164
    sqlx::query("UPDATE repositories SET owner = $1, updated_ms = $2 WHERE id = $3")
165
        .bind(new_owner)
166
        .bind(now_ms())
167
        .bind(id)
168
        .execute(pool)
169
        .await?;
170
    sqlx::query("DELETE FROM repo_redirects WHERE old_owner = $1 AND old_name = $2").bind(new_owner).bind(name).execute(pool).await?;
171
    sqlx::query("INSERT INTO repo_redirects (old_owner, old_name, repo_id, moved_ms) VALUES ($1, $2, $3, $4) ON CONFLICT (old_owner, old_name) DO UPDATE SET repo_id = excluded.repo_id, moved_ms = excluded.moved_ms")
172
        .bind(old_owner)
173
        .bind(name)
174
        .bind(id)
175
        .bind(now_ms())
176
        .execute(pool)
177
        .await?;
178
    Ok(())
179
}
180
181
/// Archive (read-only) or bring back a repository.
182
pub async fn set_archived(pool: &Pool, id: i64, archived: bool, reason: &str) -> sqlx::Result<()> {
183
    sqlx::query("UPDATE repositories SET archived = $1, archived_reason = $2, updated_ms = $3 WHERE id = $4")
184
        .bind(archived)
185
        .bind(if archived { reason } else { "" })
186
        .bind(now_ms())
187
        .bind(id)
188
        .execute(pool)
189
        .await?;
190
    Ok(())
191
}
192
193
pub async fn delete(pool: &Pool, id: i64) -> sqlx::Result<()> {
194
    sqlx::query("DELETE FROM repositories WHERE id = $1").bind(id).execute(pool).await?;
195
    Ok(())
196
}
197
198
pub async fn set_description(pool: &Pool, id: i64, description: &str) -> sqlx::Result<()> {
199
    sqlx::query("UPDATE repositories SET description = $1 WHERE id = $2").bind(description).bind(id).execute(pool).await?;
200
    Ok(())
201
}
202
203
pub async fn set_default_bookmark(pool: &Pool, id: i64, bookmark: &str) -> sqlx::Result<()> {
204
    sqlx::query("UPDATE repositories SET default_bookmark = $1 WHERE id = $2").bind(bookmark).bind(id).execute(pool).await?;
205
    Ok(())
206
}
207
208
pub async fn set_visibility(pool: &Pool, id: i64, visibility: Visibility) -> sqlx::Result<()> {
209
    sqlx::query("UPDATE repositories SET visibility = $1 WHERE id = $2").bind(visibility.as_str()).bind(id).execute(pool).await?;
210
    Ok(())
211
}
212
213
/// Record a push's per-reference results and bump the repository's activity.
214
pub async fn record_push(pool: &Pool, id: i64, pusher: Option<(i64, &str)>, results: &[PushOutcome]) -> sqlx::Result<()> {
215
    record_push_via(pool, id, pusher, "", results).await
216
}
217
218
/// [`record_push`], naming the agent token the push came through (#217).
219
pub async fn record_push_via(pool: &Pool, id: i64, pusher: Option<(i64, &str)>, via: &str, results: &[PushOutcome]) -> sqlx::Result<()> {
220
    let now = now_ms();
221
    let mut tx = super::begin_write(pool).await?;
222
    for r in results {
223
        sqlx::query("INSERT INTO pushes (repo_id, at_ms, reference, ok, reason, old_state, new_state, heads, changes, account_id, pusher, via) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12)")
224
            .bind(id)
225
            .bind(now)
226
            .bind(&r.reference)
227
            .bind(r.ok)
228
            .bind(&r.reason)
229
            .bind(&r.old_state)
230
            .bind(&r.new_state)
231
            .bind(r.heads)
232
            .bind(r.changes)
233
            .bind(pusher.map(|p| p.0).filter(|id| *id > 0))
234
            .bind(pusher.map(|p| p.1).unwrap_or(""))
235
            .bind(via)
236
            .execute(&mut *tx)
237
            .await?;
238
    }
239
    if results.iter().any(|r| r.ok) {
240
        sqlx::query("UPDATE repositories SET updated_ms = $1 WHERE id = $2").bind(now).bind(id).execute(&mut *tx).await?;
241
    }
242
    tx.commit().await
243
}
244
245
pub async fn pushes(pool: &Pool, id: i64, limit: i64) -> sqlx::Result<Vec<PushRow>> {
246
    sqlx::query_as("SELECT id, at_ms, reference, ok, reason, old_state, new_state, heads, changes, pusher FROM pushes WHERE repo_id = $1 ORDER BY at_ms DESC, id DESC LIMIT $2")
247
        .bind(id)
248
        .bind(limit)
249
        .fetch_all(pool)
250
        .await
251
}
252
253
/// Topics from user input: comma or space separated, lower-cased,
254
/// letters, digits and dashes, at most 35 characters each and 20 in all.
255
/// Returns the stored form or what is wrong.
256
pub fn parse_topics(input: &str) -> Result<String, String> {
257
    let mut out: Vec<String> = Vec::new();
258
    for t in input.split([',', ' ', '\n', '\t']).map(|t| t.trim().to_ascii_lowercase()).filter(|t| !t.is_empty()) {
259
        if t.len() > 35 || !t.chars().all(|c| c.is_ascii_alphanumeric() || c == '-') || t.starts_with('-') {
260
            return Err(format!("\"{t}\" is not a topic: use letters, digits and dashes, up to 35 characters"));
261
        }
262
        if !out.contains(&t) {
263
            out.push(t);
264
        }
265
    }
266
    if out.len() > 20 {
267
        return Err("At most 20 topics.".into());
268
    }
269
    Ok(out.join(" "))
270
}
271
272
pub async fn set_topics(pool: &Pool, id: i64, topics: &str) -> sqlx::Result<()> {
273
    sqlx::query("UPDATE repositories SET topics = $1 WHERE id = $2").bind(topics).bind(id).execute(pool).await?;
274
    Ok(())
275
}
276
277
/// Star or unstar; returns whether it is now starred.
278
pub async fn toggle_star(pool: &Pool, account_id: i64, repo_id: i64) -> sqlx::Result<bool> {
279
    let gone = sqlx::query("DELETE FROM stars WHERE account_id = $1 AND repo_id = $2").bind(account_id).bind(repo_id).execute(pool).await?;
280
    if gone.rows_affected() > 0 {
281
        return Ok(false);
282
    }
283
    sqlx::query("INSERT INTO stars (account_id, repo_id, at_ms) VALUES ($1, $2, $3)")
284
        .bind(account_id)
285
        .bind(repo_id)
286
        .bind(now_ms())
287
        .execute(pool)
288
        .await?;
289
    Ok(true)
290
}
291
292
pub async fn starred(pool: &Pool, account_id: i64, repo_id: i64) -> sqlx::Result<bool> {
293
    let n: i64 = sqlx::query_scalar("SELECT COUNT(*) FROM stars WHERE account_id = $1 AND repo_id = $2")
294
        .bind(account_id)
295
        .bind(repo_id)
296
        .fetch_one(pool)
297
        .await?;
298
    Ok(n > 0)
299
}
300
301
/// Stars and watchers of one repository.
302
pub async fn counts(pool: &Pool, repo_id: i64) -> sqlx::Result<(i64, i64)> {
303
    let stars: i64 = sqlx::query_scalar("SELECT COUNT(*) FROM stars WHERE repo_id = $1").bind(repo_id).fetch_one(pool).await?;
304
    let watchers = super::notify::watchers(pool, repo_id).await?.len() as i64;
305
    Ok((stars, watchers))
306
}
307
308
/// Star counts of every starred repository.
309
pub async fn star_counts(pool: &Pool) -> sqlx::Result<std::collections::HashMap<i64, i64>> {
310
    let rows: Vec<(i64, i64)> = sqlx::query_as("SELECT repo_id, COUNT(*) FROM stars GROUP BY repo_id").fetch_all(pool).await?;
311
    Ok(rows.into_iter().collect())
312
}
313
314
/// Record that `id` is a fork of `from`.
315
pub async fn set_forked_from(pool: &Pool, id: i64, from: i64) -> sqlx::Result<()> {
316
    sqlx::query("UPDATE repositories SET forked_from = $1 WHERE id = $2").bind(from).bind(id).execute(pool).await?;
317
    Ok(())
318
}
319
320
/// The forks of `id`, newest activity first.
321
pub async fn forks_of(pool: &Pool, id: i64) -> sqlx::Result<Vec<RepoRow>> {
322
    sqlx::query_as("SELECT * FROM repositories WHERE forked_from = $1 ORDER BY updated_ms DESC").bind(id).fetch_all(pool).await
323
}
324
325
/// `on`, `off`, or `` (follow hub.toml's `[flow] repos`).
326
pub async fn set_flow(pool: &Pool, id: i64, setting: &str) -> sqlx::Result<()> {
327
    sqlx::query("UPDATE repositories SET flow = $1 WHERE id = $2").bind(setting).bind(id).execute(pool).await?;
328
    Ok(())
329
}
330
331
pub async fn set_flow_priority(pool: &Pool, id: i64, priority: &str) -> sqlx::Result<()> {
332
    sqlx::query("UPDATE repositories SET flow_priority = $1 WHERE id = $2").bind(priority).bind(id).execute(pool).await?;
333
    Ok(())
334
}
335
336
/// Whether agents' tokens may decide the repository's approval gates (#258).
337
pub async fn set_agents_decide_gates(pool: &Pool, id: i64, on: bool) -> sqlx::Result<()> {
338
    sqlx::query("UPDATE repositories SET agents_decide_gates = $1 WHERE id = $2").bind(on).bind(id).execute(pool).await?;
339
    Ok(())
340
}
341
342
pub async fn set_backup(pool: &Pool, id: i64, setting: &str) -> sqlx::Result<()> {
343
    sqlx::query("UPDATE repositories SET backup = $1 WHERE id = $2").bind(setting).bind(id).execute(pool).await?;
344
    Ok(())
345
}
346
347
pub async fn set_diffusion_land(pool: &Pool, id: i64, setting: &str) -> sqlx::Result<()> {
348
    sqlx::query("UPDATE repositories SET diffusion_land = $1 WHERE id = $2").bind(setting).bind(id).execute(pool).await?;
349
    Ok(())
350
}
351
352
pub async fn set_diffusion(pool: &Pool, id: i64, setting: &str) -> sqlx::Result<()> {
353
    sqlx::query("UPDATE repositories SET diffusion = $1 WHERE id = $2").bind(setting).bind(id).execute(pool).await?;
354
    Ok(())
355
}
356
357
pub async fn set_git_mirror(pool: &Pool, id: i64, on: bool) -> sqlx::Result<()> {
358
    sqlx::query("UPDATE repositories SET git_mirror = $1 WHERE id = $2").bind(on).bind(id).execute(pool).await?;
359
    Ok(())
360
}
361
362
pub async fn set_git_mirror_state(pool: &Pool, id: i64, state: &str) -> sqlx::Result<()> {
363
    sqlx::query("UPDATE repositories SET git_mirror_state = $1 WHERE id = $2").bind(state).bind(id).execute(pool).await?;
364
    Ok(())
365
}
366
367
#[cfg(test)]
368
mod topic_tests {
369
    use super::parse_topics;
370
371
    #[test]
372
    fn topics_are_normalised_and_checked() {
373
        assert_eq!(parse_topics("Rust, vcs  retro-computing,rust").unwrap(), "rust vcs retro-computing");
374
        assert_eq!(parse_topics("").unwrap(), "");
375
        assert!(parse_topics("c++").is_err());
376
        assert!(parse_topics("-lead").is_err());
377
        assert!(parse_topics(&"x".repeat(36)).is_err());
378
        assert!(parse_topics(&(0..21).map(|i| format!("t{i}")).collect::<Vec<_>>().join(" ")).is_err());
379
    }
380
}