github: allow all jobs in a suite to be cancelled at once

Author: jclulow

github/server/src/main.rs

@@ -828,7 +828,10 @@ async fn process_deliveries(app: &Arc<App>) -> Result<()> {
             }
             "check_run" if &payload.action == "requested_action" => {
                 let actid = if let Some(ra) = &payload.requested_action {
-                    if ra.identifier != "auth" && ra.identifier != "cancel" {
+                    if ra.identifier != "auth"
+                        && ra.identifier != "cancel"
+                        && ra.identifier != "cancel_all"
+                    {
                         /*
                          * Authorisation and cancellation are the only actions
                          * we know how to do for now.
@@ -904,23 +907,49 @@ async fn process_deliveries(app: &Arc<App>) -> Result<()> {
                         continue;
                     }
                     CheckRunVariety::Basic => {
-                        if actid != "cancel" {
-                            warn!(
-                                log,
-                                "delivery {} for {:?} on basic check run",
-                                del.seq,
-                                actid,
-                            );
-                            app.db.delivery_ack(del.seq, ack)?;
-                            continue;
+                        match actid.as_str() {
+                            "cancel" => {
+                                /*
+                                 * Cancel any work that has been queued but not
+                                 * yet performed:
+                                 */
+                                variety::basic::cancel(app, &cs, &mut cr)
+                                    .await?;
+                            }
+                            "cancel_all" => {
+                                /*
+                                 * Cancel any work that has been queued but not
+                                 * yet performed for all basic variety check
+                                 * runs in this suite:
+                                 */
+                                for mut cr in
+                                    app.db.list_check_runs_for_suite(&cs.id)?
+                                {
+                                    if !cr.active
+                                        || !matches!(
+                                            cr.variety,
+                                            CheckRunVariety::Basic
+                                        )
+                                    {
+                                        continue;
+                                    }
+
+                                    variety::basic::cancel(app, &cs, &mut cr)
+                                        .await?;
+                                }
+                            }
+                            other => {
+                                warn!(
+                                    log,
+                                    "delivery {} for {:?} on basic check run",
+                                    del.seq,
+                                    other,
+                                );
+                                app.db.delivery_ack(del.seq, ack)?;
+                                continue;
+                            }
                         }
 
-                        /*
-                         * Cancel any work that has been queued but not yet
-                         * performed:
-                         */
-                        variety::basic::cancel(app, &cs, &mut cr).await?;
-
                         app.db.delivery_ack(del.seq, ack)?;
                         continue;
                     }

github/server/src/variety/basic.rs

@@ -199,11 +199,18 @@ pub(crate) async fn flush(
         summary += "\n\n";
     }
 
-    let cancel = vec![octorust::types::ChecksCreateRequestActions {
-        description: "Cancel execution and fail the check.".into(),
-        identifier: "cancel".into(),
-        label: "Cancel".into(),
-    }];
+    let cancel = vec![
+        octorust::types::ChecksCreateRequestActions {
+            description: "Cancel execution and fail the check.".into(),
+            identifier: "cancel".into(),
+            label: "Cancel this job".into(),
+        },
+        octorust::types::ChecksCreateRequestActions {
+            description: "Cancel all jobs and fail all checks.".into(),
+            identifier: "cancel_all".into(),
+            label: "Cancel all jobs".into(),
+        },
+    ];
 
     Ok(if p.complete {
         if let Some(e) = p.error.as_deref() {