Merge pull request #2019 from pikasTech/feat/selfmedia-cicd-timing

增加 SELFMEDIA CI/CD 单次耗时查询

scripts/src/platform-infra-pipelines-as-code.ts

@@ -37,6 +37,7 @@ import {
   resolvePacBootstrapMirrorRepository,
 } from "./platform-infra-pipelines-as-code-bootstrap";
 import { featureConfigSchemaHistoryFields, renderFeatureConfigSchemaLine } from "./platform-infra-pac-feature-config-projection";
+import { observePacDeliveryTiming } from "./platform-infra-pac-delivery-timing";
 
 const configFile = rootPath("config", "platform-infra", "pipelines-as-code.yaml");
 const configLabel = "config/platform-infra/pipelines-as-code.yaml";
@@ -278,6 +279,11 @@ export async function runPlatformInfraPipelinesAsCodeCommand(config: UniDeskConf
     const result = await history(config, options);
     return options.raw ? result : options.full ? compactHistoryJson(result, true) : options.json ? compactHistoryJson(result) : renderHistory(result);
   }
+  if (action === "delivery-timing" || action === "timing") {
+    const options = parseCommonOptions(args.slice(1));
+    const result = await deliveryTiming(config, options);
+    return options.full || options.raw || options.json ? result : renderDeliveryTiming(result);
+  }
   if (action === "debug-step") {
     const options = parseHistoryOptions(args.slice(1));
     const result = await debugStep(config, options);
@@ -400,12 +406,13 @@ function help(scope: string | null): Record<string, unknown> {
     };
   }
   return {
-    command: "platform-infra pipelines-as-code plan|status|history|debug-step|source-artifact",
+    command: "platform-infra pipelines-as-code plan|status|history|delivery-timing|debug-step|source-artifact",
     configTruth: configLabel,
     usage: [
       "bun scripts/cli.ts platform-infra pipelines-as-code plan --target JD01",
       "bun scripts/cli.ts platform-infra pipelines-as-code status --target JD01 [--json|--full|--raw]",
       "bun scripts/cli.ts platform-infra pipelines-as-code history --target JD01 [--consumer hwlab-jd01-v03] [--limit 10]",
+      "bun scripts/cli.ts platform-infra pipelines-as-code delivery-timing --target NC01 --consumer selfmedia-nc01 [--json]",
       "bun scripts/cli.ts platform-infra pipelines-as-code history --target JD01 --id <pipelinerun>",
       "bun scripts/cli.ts platform-infra pipelines-as-code debug-step --target JD01 [--consumer <consumer>] [--id <pipelinerun>] [--json]",
       "bun scripts/cli.ts platform-infra pipelines-as-code source-artifact check --target NC01 --consumer agentrun-nc01-v02 --source-worktree /abs/worktree",
@@ -2402,6 +2409,49 @@ function renderCloseout(result: Record<string, unknown>): RenderedCliResult {
   return rendered(result, "platform-infra pipelines-as-code closeout", lines);
 }
 
+async function deliveryTiming(config: UniDeskConfig, options: CommonOptions): Promise<Record<string, unknown>> {
+  const pac = readPacConfig();
+  const target = resolveTarget(pac, options.targetId);
+  const consumer = resolveConsumer(pac, options.consumerId);
+  if (consumer.node.toLowerCase() !== target.id.toLowerCase()) throw new Error(`Pipelines-as-Code consumer ${consumer.id} belongs to ${consumer.node}, not target ${target.id}`);
+  const authority = resolveCicdDeliveryAuthority({ consumerId: consumer.id, node: consumer.node, lane: consumer.lane });
+  if (authority.kind !== "pac-pr-merge") throw new Error(`delivery authority is ${authority.kind}: ${authority.reason}`);
+  const historyOptions: HistoryOptions = { ...options, limit: 1, detailId: null };
+  return await observePacDeliveryTiming({
+    target: targetSummary(target),
+    consumer: {
+      id: consumer.id,
+      node: consumer.node,
+      lane: consumer.lane,
+      repository: authority.consumer.sourceRepository,
+      branch: authority.consumer.sourceBranch,
+      pipeline: consumer.pipeline,
+    },
+  }, {
+    history: async () => await history(config, historyOptions),
+    status: async () => await status(config, options),
+  });
+}
+
+function renderDeliveryTiming(result: Record<string, unknown>): RenderedCliResult {
+  const timing = record(result.timing);
+  const source = record(result.source);
+  const pr = record(source.pullRequest);
+  const runtime = record(result.runtime);
+  const argo = record(runtime.argo);
+  const health = record(runtime.health);
+  const lines = [
+    "PLATFORM-INFRA DELIVERY TIMING",
+    `STATE: ${stringValue(result.state)}  MUTATION: ${boolText(result.mutation)}`,
+    `SOURCE: ${stringValue(record(result.consumer).repository)}@${stringValue(source.commit)} PR#${stringValue(pr.number)}`,
+    `MERGED_AT: ${stringValue(timing.mergedAt)}  PIPELINE_START: ${stringValue(timing.pipelineStart)}  PIPELINE_DONE: ${stringValue(timing.pipelineCompletion)}`,
+    `TRIGGER_WAIT_S: ${stringValue(timing.triggerWaitSeconds)}  PIPELINE_S: ${stringValue(timing.pipelineDurationSeconds)}  END_TO_END_S: ${stringValue(timing.endToEndSeconds)}`,
+    `ARGO: ${stringValue(argo.sync)}/${stringValue(argo.health)}  RUNTIME_READY: ${stringValue(health.readyReplicas)}/${stringValue(health.replicas)}`,
+    `EVIDENCE_GAPS: ${(Array.isArray(result.evidenceGaps) ? result.evidenceGaps.map(String) : []).join(", ") || "-"}`,
+  ];
+  return rendered(result, "platform-infra pipelines-as-code delivery-timing", lines);
+}
+
 export function renderHistory(result: Record<string, unknown>): RenderedCliResult {
   const rows = arrayRecords(result.rows);
   const config = record(result.config);