mirror of
https://github.com/CopilotKit/CopilotKit.git
synced 2026-09-14 16:26:20 +08:00
Jordan Ritter
6130c1acf0
Adds .github/workflows/showcase_promote_notify.yml — workflow_dispatch-only Slack notify workflow for promote results. Posts initiation + threaded reply to #team-showcase; cross-posts to #oss-alerts on partial/total failure. Also adds showcase_promote_notify.dry-run.sh — a local render-logic mirror that decodes the same payload and prints the messages the workflow would send to Slack, without making any Slack API calls. Used by the pre-merge runbook and by future CI fixture tests.
344 lines
15 KiB
YAML
344 lines
15 KiB
YAML
name: "Showcase: Promote Notify"
|
|
|
|
# HARD CONTRACT (spec N2): the CLI polls `gh run list` for a run whose
|
|
# display_title matches `promote-<run_id>`. Without this `run-name`
|
|
# directive, that polling lookup will always time out.
|
|
run-name: promote-${{ inputs.run_id }}
|
|
|
|
on:
|
|
workflow_dispatch:
|
|
inputs:
|
|
results:
|
|
description: "Base64-encoded results JSON (schema_version=1)"
|
|
required: true
|
|
type: string
|
|
trigger:
|
|
description: "Dispatch source"
|
|
required: true
|
|
type: choice
|
|
options:
|
|
- cli
|
|
- workflow
|
|
run_id:
|
|
description: "6-char lowercase hex run id"
|
|
required: true
|
|
type: string
|
|
|
|
permissions:
|
|
contents: read
|
|
|
|
jobs:
|
|
notify:
|
|
name: Post aggregated Slack notification
|
|
runs-on: ubuntu-latest
|
|
timeout-minutes: 5
|
|
env:
|
|
RESULTS_B64: ${{ inputs.results }}
|
|
TRIGGER: ${{ inputs.trigger }}
|
|
RUN_ID: ${{ inputs.run_id }}
|
|
SLACK_BOT_TOKEN: ${{ secrets.SLACK_BOT_TOKEN }}
|
|
TEAM_SHOWCASE_CHANNEL: "#team-showcase"
|
|
OSS_ALERTS_CHANNEL: "#oss-alerts"
|
|
steps:
|
|
- name: Decode and validate results
|
|
id: decode
|
|
run: |
|
|
set -euo pipefail
|
|
if ! command -v jq >/dev/null 2>&1; then
|
|
echo "::error::jq is required"
|
|
exit 1
|
|
fi
|
|
# Decode the base64 results blob into a JSON file. The blob may
|
|
# contain newlines from `base64` line-wrapping; -d handles that.
|
|
if ! printf '%s' "$RESULTS_B64" | base64 -d > /tmp/results.json 2>/tmp/results.err; then
|
|
echo "::error::base64 decode failed: $(cat /tmp/results.err)"
|
|
exit 1
|
|
fi
|
|
if ! jq -e . /tmp/results.json >/dev/null 2>&1; then
|
|
echo "::error::decoded payload is not valid JSON"
|
|
exit 1
|
|
fi
|
|
schema_version=$(jq -r '.schema_version // empty' /tmp/results.json)
|
|
if [ "$schema_version" != "1" ]; then
|
|
echo "::warning::schema_version mismatch — expected 1, got '${schema_version}'; aborting Slack post gracefully"
|
|
echo "abort=1" >> "$GITHUB_OUTPUT"
|
|
exit 0
|
|
fi
|
|
# Enforce the run_id contract — required for the CLI's gh run list polling.
|
|
# See HARD CONTRACT comment + run-name directive at top of file. A malformed
|
|
# run_id is a dispatcher-contract violation, not a recoverable runtime
|
|
# condition, so hard-fail (exit 1) rather than warn-and-abort.
|
|
if ! printf '%s' "$RUN_ID" | grep -Eq '^[0-9a-f]{6}$'; then
|
|
echo "::error::run_id '$RUN_ID' does not match ^[0-9a-f]{6}$ (breaks CLI polling contract; see run-name)"
|
|
exit 1
|
|
fi
|
|
echo "abort=0" >> "$GITHUB_OUTPUT"
|
|
|
|
- name: Render Slack messages and post
|
|
if: steps.decode.outputs.abort == '0'
|
|
env:
|
|
# Re-export for the script step
|
|
RESULTS_PATH: /tmp/results.json
|
|
run: |
|
|
set -euo pipefail
|
|
|
|
if [ -z "${SLACK_BOT_TOKEN:-}" ]; then
|
|
echo "::error::SLACK_BOT_TOKEN is not set"
|
|
exit 1
|
|
fi
|
|
|
|
# ---------- helpers ----------
|
|
slack_api() {
|
|
# $1 = method, $2 = JSON body
|
|
local method="$1"
|
|
local body="$2"
|
|
local resp http
|
|
resp=$(mktemp)
|
|
http=$(curl -sS -o "$resp" -w '%{http_code}' \
|
|
-X POST "https://slack.com/api/${method}" \
|
|
-H "Authorization: Bearer ${SLACK_BOT_TOKEN}" \
|
|
-H "Content-type: application/json; charset=utf-8" \
|
|
--data "$body" || echo "000")
|
|
if [ "$http" != "200" ]; then
|
|
echo "::warning::Slack ${method} non-2xx http=${http} body=$(head -c 500 "$resp")" >&2
|
|
echo "{}"
|
|
rm -f "$resp"
|
|
return 0
|
|
fi
|
|
cat "$resp"
|
|
rm -f "$resp"
|
|
}
|
|
|
|
# ---------- read payload ----------
|
|
R="$RESULTS_PATH"
|
|
|
|
run_id=$(jq -r '.run_id' "$R")
|
|
trigger=$(jq -r '.trigger' "$R")
|
|
operator_email=$(jq -r '.operator_email // ""' "$R")
|
|
operator_git_name=$(jq -r '.operator_git_name // ""' "$R")
|
|
elapsed=$(jq -r '.elapsed_seconds // 0' "$R")
|
|
pre_staging=$(jq -r '.pre_staging // "skipped"' "$R")
|
|
abort_reason=$(jq -r '.abort_reason // ""' "$R")
|
|
succeeded_count=$(jq -r '.succeeded | length' "$R")
|
|
failed_count=$(jq -r '.failed | length' "$R")
|
|
|
|
# Sort failed alphabetically by service and split off the
|
|
# truncation-suffix sentinel (if any) so it renders as a
|
|
# trailing "+ K more" line instead of a bullet.
|
|
jq '.failed | sort_by(.service)' "$R" > /tmp/failed-sorted.json
|
|
jq '[.[] | select(.category != "truncation-suffix")]' /tmp/failed-sorted.json > /tmp/failed-render.json
|
|
truncation_more=$(jq -r '[.[] | select(.category == "truncation-suffix") | .service] | .[0] // ""' /tmp/failed-sorted.json)
|
|
|
|
# Counts:
|
|
# total_count = succeeded_count + failed_real_count
|
|
# succeeded_count = raw .succeeded length
|
|
# failed_real_count = .failed length minus truncation-suffix sentinels
|
|
# (rendered to operators on all display lines)
|
|
# failed_count = raw .failed length (internal logging only)
|
|
failed_real_count=$(jq 'length' /tmp/failed-render.json)
|
|
|
|
# Service total = succeeded + real failures (truncation entries
|
|
# are not real services).
|
|
total_count=$((succeeded_count + failed_real_count))
|
|
|
|
# ---------- format elapsed seconds ----------
|
|
fmt_elapsed() {
|
|
local total="$1"
|
|
local m=$((total / 60))
|
|
local s=$((total % 60))
|
|
printf '%dm %02ds' "$m" "$s"
|
|
}
|
|
elapsed_str=$(fmt_elapsed "$elapsed")
|
|
|
|
# ---------- resolve operator mention ----------
|
|
operator_mention=""
|
|
if [ -n "$operator_email" ]; then
|
|
# users.lookupByEmail requires GET (Slack Web API).
|
|
lookup_resp=$(curl -sS \
|
|
-G "https://slack.com/api/users.lookupByEmail" \
|
|
-H "Authorization: Bearer ${SLACK_BOT_TOKEN}" \
|
|
--data-urlencode "email=${operator_email}" || echo '{}')
|
|
ok=$(echo "$lookup_resp" | jq -r '.ok // false')
|
|
if [ "$ok" = "true" ]; then
|
|
uid=$(echo "$lookup_resp" | jq -r '.user.id // ""')
|
|
if [ -n "$uid" ]; then
|
|
operator_mention="<@${uid}>"
|
|
fi
|
|
fi
|
|
fi
|
|
if [ -z "$operator_mention" ]; then
|
|
if [ -n "$operator_git_name" ]; then
|
|
operator_mention="$operator_git_name"
|
|
elif [ -n "$operator_email" ]; then
|
|
operator_mention="$operator_email"
|
|
else
|
|
operator_mention="unknown"
|
|
fi
|
|
fi
|
|
|
|
# ---------- pre_staging glyph ----------
|
|
case "$pre_staging" in
|
|
green) pre_staging_line="pre_staging: ✓ green" ;;
|
|
amber) pre_staging_line="pre_staging: ⚠ amber" ;;
|
|
red) pre_staging_line="pre_staging: ✗ red" ;;
|
|
skipped) pre_staging_line="pre_staging: — skipped" ;;
|
|
*) pre_staging_line="pre_staging: ${pre_staging}" ;;
|
|
esac
|
|
|
|
# ---------- trigger label ----------
|
|
if [ "$trigger" = "cli" ]; then
|
|
trigger_label='`bin/railway --notify`'
|
|
else
|
|
trigger_label='`showcase_promote.yml`'
|
|
fi
|
|
|
|
# ---------- initiation post ----------
|
|
init_text="🚂 *Promoting showcase → prod* (${total_count} services)
|
|
operator ${operator_mention} · trigger ${trigger_label} · run \`${run_id}\`
|
|
${pre_staging_line}"
|
|
# Strip leading whitespace introduced by the heredoc-style indent above.
|
|
init_text=$(printf '%s\n' "$init_text" | sed 's/^[[:space:]]\{10\}//')
|
|
|
|
init_body=$(jq -nc \
|
|
--arg channel "$TEAM_SHOWCASE_CHANNEL" \
|
|
--arg text "$init_text" \
|
|
'{channel:$channel, text:$text}')
|
|
|
|
init_resp=$(slack_api chat.postMessage "$init_body")
|
|
init_ok=$(echo "$init_resp" | jq -r '.ok // false')
|
|
init_ts=$(echo "$init_resp" | jq -r '.ts // ""')
|
|
init_channel_id=$(echo "$init_resp" | jq -r '.channel // ""')
|
|
|
|
if [ "$init_ok" != "true" ] || [ -z "$init_ts" ]; then
|
|
echo "::warning::initiation post failed; continuing without threading"
|
|
fi
|
|
|
|
# ---------- permalink (for #oss-alerts cross-post) ----------
|
|
permalink=""
|
|
if [ -n "$init_ts" ] && [ -n "$init_channel_id" ]; then
|
|
perm_resp=$(curl -sS \
|
|
-G "https://slack.com/api/chat.getPermalink" \
|
|
-H "Authorization: Bearer ${SLACK_BOT_TOKEN}" \
|
|
--data-urlencode "channel=${init_channel_id}" \
|
|
--data-urlencode "message_ts=${init_ts}" || echo '{}')
|
|
if [ "$(echo "$perm_resp" | jq -r '.ok // false')" = "true" ]; then
|
|
permalink=$(echo "$perm_resp" | jq -r '.permalink // ""')
|
|
fi
|
|
fi
|
|
|
|
# ---------- build failure bullets ----------
|
|
fail_bullets=$(jq -r '.[] | "• `\(.service)` — exit \(.exit) (\(.category))"' /tmp/failed-render.json)
|
|
if [ -n "$truncation_more" ]; then
|
|
if [ -n "$fail_bullets" ]; then
|
|
fail_bullets="${fail_bullets}
|
|
${truncation_more}"
|
|
else
|
|
fail_bullets="${truncation_more}"
|
|
fi
|
|
fi
|
|
|
|
# ---------- determine outcome & build thread reply ----------
|
|
# Branching uses failed_real_count (excludes truncation sentinel)
|
|
# so a sentinel-only failed[] does not get mis-classified as
|
|
# partial and spuriously cross-posted to #oss-alerts.
|
|
#
|
|
# An abort_reason combined with zero successes is ALWAYS a total
|
|
# abort, regardless of failed_real_count — fleet-preflight
|
|
# refusals abort the whole run BEFORE any service is attempted
|
|
# (succeeded=[], failed=[] or sentinel-only). Without this guard,
|
|
# the failed_real_count==0 branch would fire first and
|
|
# mis-announce the run as a clean success.
|
|
if [ -n "$abort_reason" ] && [ "$succeeded_count" -eq 0 ]; then
|
|
outcome="total"
|
|
case "$abort_reason" in
|
|
fleet-preflight) reason_line="*Reason:* fleet-wide preflight refused" ;;
|
|
per-service) reason_line="*Reason:* all services individually refused" ;;
|
|
*) reason_line="*Reason:* aborted" ;;
|
|
esac
|
|
if [ "$failed_real_count" -eq 0 ]; then
|
|
# Fleet-preflight abort with zero services touched: no
|
|
# bullets to render, so omit the *Failed:* heading entirely.
|
|
thread_text="❌ *Aborted in ${elapsed_str}* — 0 ✓ · 0 ✗
|
|
verify-prod: not run
|
|
${pre_staging_line}
|
|
${reason_line}"
|
|
else
|
|
thread_text="❌ *Aborted in ${elapsed_str}* — 0 ✓ · ${failed_real_count} ✗
|
|
verify-prod: not run
|
|
${pre_staging_line}
|
|
${reason_line}
|
|
*Failed:*
|
|
${fail_bullets}"
|
|
fi
|
|
elif [ "$failed_real_count" -eq 0 ]; then
|
|
outcome="success"
|
|
thread_text="✅ *Done in ${elapsed_str}* — ${succeeded_count} ✓ · 0 ✗
|
|
verify-prod: ✓ all green"
|
|
elif [ "$succeeded_count" -gt 0 ] && [ "$failed_real_count" -gt 0 ]; then
|
|
outcome="partial"
|
|
thread_text="⚠️ *Done in ${elapsed_str}* — ${succeeded_count} ✓ · ${failed_real_count} ✗
|
|
verify-prod: ✓ on succeeded · n/a on failed
|
|
*Failed:*
|
|
${fail_bullets}"
|
|
else
|
|
# succeeded_count == 0 && failed_real_count > 0 — per-service
|
|
# refusals without an abort_reason set (defensive fallback).
|
|
outcome="total"
|
|
case "$abort_reason" in
|
|
fleet-preflight) reason_line="*Reason:* fleet-wide preflight refused" ;;
|
|
per-service) reason_line="*Reason:* all services individually refused" ;;
|
|
*) reason_line="*Reason:* aborted" ;;
|
|
esac
|
|
thread_text="❌ *Aborted in ${elapsed_str}* — 0 ✓ · ${failed_real_count} ✗
|
|
verify-prod: not run
|
|
${pre_staging_line}
|
|
${reason_line}
|
|
*Failed:*
|
|
${fail_bullets}"
|
|
fi
|
|
|
|
# Strip the 10-space indent the heredoc-style strings carry.
|
|
thread_text=$(printf '%s\n' "$thread_text" | sed 's/^[[:space:]]\{10\}//')
|
|
|
|
# ---------- post thread reply ----------
|
|
if [ -n "$init_ts" ]; then
|
|
thread_body=$(jq -nc \
|
|
--arg channel "$TEAM_SHOWCASE_CHANNEL" \
|
|
--arg text "$thread_text" \
|
|
--arg ts "$init_ts" \
|
|
'{channel:$channel, text:$text, thread_ts:$ts}')
|
|
slack_api chat.postMessage "$thread_body" >/dev/null
|
|
else
|
|
# Initiation failed; post the thread text as a top-level
|
|
# message so the operator still gets the summary.
|
|
fallback_body=$(jq -nc \
|
|
--arg channel "$TEAM_SHOWCASE_CHANNEL" \
|
|
--arg text "$thread_text" \
|
|
'{channel:$channel, text:$text}')
|
|
slack_api chat.postMessage "$fallback_body" >/dev/null
|
|
fi
|
|
|
|
# ---------- cross-post to #oss-alerts on partial/total failure ----------
|
|
if [ "$outcome" != "success" ]; then
|
|
# Build the trailing link suffix once so both branches share it
|
|
# without relying on a trailing-space suffix-strip.
|
|
if [ -n "$permalink" ]; then
|
|
link_suffix="thread: ${permalink}"
|
|
else
|
|
# No Slack permalink available; link to the GitHub Actions run instead.
|
|
gha_url="https://github.com/${GITHUB_REPOSITORY}/actions/runs/${GITHUB_RUN_ID}"
|
|
link_suffix="thread permalink unavailable; see ${gha_url}"
|
|
fi
|
|
case "$outcome" in
|
|
partial) oss_text="⚠️ showcase promote: ${succeeded_count} ✓ · ${failed_real_count} ✗ — ${link_suffix}" ;;
|
|
total) oss_text="❌ showcase promote aborted: 0 ✓ · ${failed_real_count} ✗ — ${link_suffix}" ;;
|
|
esac
|
|
oss_body=$(jq -nc \
|
|
--arg channel "$OSS_ALERTS_CHANNEL" \
|
|
--arg text "$oss_text" \
|
|
'{channel:$channel, text:$text}')
|
|
slack_api chat.postMessage "$oss_body" >/dev/null
|
|
fi
|
|
|
|
echo "notify completed: outcome=${outcome} run_id=${run_id}"
|