| 59e6667 | | | 1 | import { spinner, log } from "@clack/prompts"; |
| 69d1a72 | | | 2 | import { hubRequest } from "../api.js"; |
| 69d1a72 | | | 3 | import { getRepoSlug } from "../config.js"; |
| 0d9d723 | | | 4 | import { STATUS_COLORS, colorStatus, formatDuration, formatTime } from "../format.js"; |
| 69d1a72 | | | 5 | |
| 69d1a72 | | | 6 | interface PipelineRun { |
| 69d1a72 | | | 7 | id: number; |
| 69d1a72 | | | 8 | pipeline_name: string; |
| 69d1a72 | | | 9 | status: string; |
| 69d1a72 | | | 10 | trigger_ref: string | null; |
| 69d1a72 | | | 11 | commit_id: string | null; |
| 69d1a72 | | | 12 | started_at: string | null; |
| 69d1a72 | | | 13 | finished_at: string | null; |
| 69d1a72 | | | 14 | duration_ms: number | null; |
| 69d1a72 | | | 15 | created_at: string; |
| 69d1a72 | | | 16 | } |
| 69d1a72 | | | 17 | |
| 69d1a72 | | | 18 | export async function ciRuns(args: string[]) { |
| 69d1a72 | | | 19 | const slug = await getRepoSlug(args); |
| 69d1a72 | | | 20 | |
| 69d1a72 | | | 21 | const statusIdx = args.indexOf("--status"); |
| 69d1a72 | | | 22 | const status = statusIdx !== -1 ? args[statusIdx + 1] : undefined; |
| 69d1a72 | | | 23 | |
| 69d1a72 | | | 24 | const limitIdx = args.indexOf("--limit"); |
| 69d1a72 | | | 25 | const limit = limitIdx !== -1 ? args[limitIdx + 1] : "10"; |
| 69d1a72 | | | 26 | |
| 69d1a72 | | | 27 | const params = new URLSearchParams(); |
| 69d1a72 | | | 28 | if (status) params.set("status", status); |
| 69d1a72 | | | 29 | if (limit) params.set("limit", limit); |
| 69d1a72 | | | 30 | |
| 69d1a72 | | | 31 | const qs = params.toString() ? `?${params}` : ""; |
| 59e6667 | | | 32 | |
| 59e6667 | | | 33 | const s = spinner(); |
| 59e6667 | | | 34 | s.start("Fetching pipeline runs"); |
| 69d1a72 | | | 35 | const { runs } = await hubRequest<{ runs: PipelineRun[] }>( |
| 69d1a72 | | | 36 | `/api/repos/${slug}/canopy/runs${qs}` |
| 69d1a72 | | | 37 | ); |
| 59e6667 | | | 38 | s.stop(`${runs.length} run${runs.length !== 1 ? "s" : ""}`); |
| 69d1a72 | | | 39 | |
| 69d1a72 | | | 40 | if (runs.length === 0) { |
| 59e6667 | | | 41 | log.info("No pipeline runs."); |
| 69d1a72 | | | 42 | return; |
| 69d1a72 | | | 43 | } |
| 69d1a72 | | | 44 | |
| 69d1a72 | | | 45 | // Table header |
| 69d1a72 | | | 46 | console.log( |
| 69d1a72 | | | 47 | `${"ID".padEnd(6)}${"Pipeline".padEnd(22)}${"Status".padEnd(18)}${"Branch".padEnd(14)}${"Duration".padEnd(10)}Created` |
| 69d1a72 | | | 48 | ); |
| 69d1a72 | | | 49 | console.log("-".repeat(90)); |
| 69d1a72 | | | 50 | |
| 69d1a72 | | | 51 | for (const run of runs) { |
| 69d1a72 | | | 52 | const id = String(run.id).padEnd(6); |
| 69d1a72 | | | 53 | const name = (run.pipeline_name || "-").slice(0, 20).padEnd(22); |
| 69d1a72 | | | 54 | const st = colorStatus(run.status).padEnd(18 + (STATUS_COLORS[run.status] ? 9 : 0)); |
| 69d1a72 | | | 55 | const branch = (run.trigger_ref || "-").slice(0, 12).padEnd(14); |
| 69d1a72 | | | 56 | const dur = formatDuration(run.duration_ms).padEnd(10); |
| 69d1a72 | | | 57 | const time = formatTime(run.created_at); |
| 69d1a72 | | | 58 | console.log(`${id}${name}${st}${branch}${dur}${time}`); |
| 69d1a72 | | | 59 | } |
| 69d1a72 | | | 60 | } |