From d401177902cb6f5f32ed2fcb3de766abd90f1c37 Mon Sep 17 00:00:00 2001
From: NotAShelf <raf@notashelf.dev>
Date: Mon, 16 Feb 2026 23:27:03 +0300
Subject: [PATCH] fc-common: add `get_cancelled_among` query for cancel-checker
 polling

Signed-off-by: NotAShelf <raf@notashelf.dev>
Change-Id: Iabc5fc932c8d7f1d19a80a27965524136a6a6964
---
 crates/common/src/repo/builds.rs | 20 ++++++++++++++++++++
 1 file changed, 20 insertions(+)

diff --git a/crates/common/src/repo/builds.rs b/crates/common/src/repo/builds.rs
index 28fba64..57a56aa 100644
--- a/crates/common/src/repo/builds.rs
+++ b/crates/common/src/repo/builds.rs
@@ -229,6 +229,26 @@ pub async fn count_filtered(
   Ok(row.0)
 }
 
+/// Return the subset of the given build IDs whose status is 'cancelled'.
+/// Used by the cancel-checker loop to detect builds cancelled while running.
+pub async fn get_cancelled_among(
+  pool: &PgPool,
+  build_ids: &[Uuid],
+) -> Result<Vec<Uuid>> {
+  if build_ids.is_empty() {
+    return Ok(Vec::new());
+  }
+  let rows: Vec<(Uuid,)> = sqlx::query_as(
+    "SELECT id FROM builds WHERE id = ANY($1) AND status = 'cancelled'",
+  )
+  .bind(build_ids)
+  .fetch_all(pool)
+  .await
+  .map_err(CiError::Database)?;
+
+  Ok(rows.into_iter().map(|(id,)| id).collect())
+}
+
 pub async fn cancel(pool: &PgPool, id: Uuid) -> Result<Build> {
   sqlx::query_as::<_, Build>(
     "UPDATE builds SET status = 'cancelled', completed_at = NOW() WHERE id = \