refactor(qa): share mantis phase timer · openclaw/openclaw@7ee1daf

Recent Commits to openclaw:main

vincentkoc · 2026-06-20 · via Recent Commits to openclaw:main

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,52 @@`
	`1`	`+// Qa Lab plugin module implements shared Mantis phase timing behavior.`
	`2`	`+export type MantisPhaseTiming = {`
	`3`	`+durationMs: number;`
	`4`	`+finishedAt: string;`
	`5`	`+name: string;`
	`6`	`+startedAt: string;`
	`7`	`+status: "accepted" \| "fail" \| "pass";`
	`8`	`+};`
	`9`	`+`
	`10`	`+export type MantisPhaseTimings = {`
	`11`	`+phases: MantisPhaseTiming[];`
	`12`	`+totalMs: number;`
	`13`	`+};`
	`14`	`+`
	`15`	`+export function createPhaseTimer(startedAt: Date) {`
	`16`	`+const phases: MantisPhaseTiming[] = [];`
	`17`	`+const origin = startedAt.getTime();`
	`18`	`+function recordPhase(name: string, phaseStarted: Date, status: MantisPhaseTiming["status"]) {`
	`19`	`+const phaseFinished = new Date();`
	`20`	`+phases.push({`
	`21`	`+durationMs: phaseFinished.getTime() - phaseStarted.getTime(),`
	`22`	`+finishedAt: phaseFinished.toISOString(),`
	`23`	`+ name,`
	`24`	`+startedAt: phaseStarted.toISOString(),`
	`25`	`+ status,`
	`26`	`+});`
	`27`	`+}`
	`28`	`+async function timePhase<T>(name: string, run: () => Promise<T>): Promise<T> {`
	`29`	`+const phaseStarted = new Date();`
	`30`	`+try {`
	`31`	`+const result = await run();`
	`32`	`+recordPhase(name, phaseStarted, "pass");`
	`33`	`+return result;`
	`34`	`+} catch (error) {`
	`35`	`+recordPhase(name, phaseStarted, "fail");`
	`36`	`+throw error;`
	`37`	`+}`
	`38`	`+}`
	`39`	`+function snapshot(now = new Date()): MantisPhaseTimings {`
	`40`	`+return {`
	`41`	`+phases: [...phases],`
	`42`	`+totalMs: now.getTime() - origin,`
	`43`	`+};`
	`44`	`+}`
	`45`	`+function updatePhaseStatus(name: string, status: MantisPhaseTiming["status"]) {`
	`46`	`+const phase = phases.findLast((entry) => entry.name === name);`
	`47`	`+if (phase) {`
	`48`	`+phase.status = status;`
	`49`	`+}`
	`50`	`+}`
	`51`	`+return { recordPhase, snapshot, timePhase, updatePhaseStatus };`
	`52`	`+}`

Original file line number	Diff line number	Diff line change
`@@ -20,6 +20,7 @@ import {`
`20`	`20`	`stopCrabbox,`
`21`	`21`	`warmupCrabbox,`
`22`	`22`	`} from "./crabbox-runtime.js";`
	`23`	`+import { createPhaseTimer, type MantisPhaseTimings } from "../mantis-phase-timer.runtime.js";`
`23`	`24`
`24`	`25`	`export type MantisSlackDesktopSmokeOptions = {`
`25`	`26`	`alternateModel?: string;`
`@@ -103,19 +104,6 @@ type MantisSlackDesktopSmokeSummary = {`
`103`	`104`	`warning?: string;`
`104`	`105`	`};`
`105`	`106`
`106`		`-type MantisPhaseTiming = {`
`107`		`-durationMs: number;`
`108`		`-finishedAt: string;`
`109`		`-name: string;`
`110`		`-startedAt: string;`
`111`		`-status: "accepted" \| "fail" \| "pass";`
`112`		`-};`
`113`		`-`
`114`		`-type MantisPhaseTimings = {`
`115`		`-phases: MantisPhaseTiming[];`
`116`		`-totalMs: number;`
`117`		`-};`
`118`		`-`
`119`	`107`	`type SlackDesktopRemoteMetadata = {`
`120`	`108`	`gatewayAlive?: boolean;`
`121`	`109`	`gatewayPid?: string;`
`@@ -188,45 +176,6 @@ function normalizeHydrateMode(`
`188`	`176`	throw new Error(`Unsupported Mantis Slack desktop hydrate mode: ${value}`);
`189`	`177`	`}`
`190`	`178`
`191`		`-function createPhaseTimer(startedAt: Date) {`
`192`		`-const phases: MantisPhaseTiming[] = [];`
`193`		`-const origin = startedAt.getTime();`
`194`		`-function recordPhase(name: string, phaseStarted: Date, status: MantisPhaseTiming["status"]) {`
`195`		`-const phaseFinished = new Date();`
`196`		`-phases.push({`
`197`		`-durationMs: phaseFinished.getTime() - phaseStarted.getTime(),`
`198`		`-finishedAt: phaseFinished.toISOString(),`
`199`		`- name,`
`200`		`-startedAt: phaseStarted.toISOString(),`
`201`		`- status,`
`202`		`-});`
`203`		`-}`
`204`		`-async function timePhase<T>(name: string, run: () => Promise<T>): Promise<T> {`
`205`		`-const phaseStarted = new Date();`
`206`		`-try {`
`207`		`-const result = await run();`
`208`		`-recordPhase(name, phaseStarted, "pass");`
`209`		`-return result;`
`210`		`-} catch (error) {`
`211`		`-recordPhase(name, phaseStarted, "fail");`
`212`		`-throw error;`
`213`		`-}`
`214`		`-}`
`215`		`-function snapshot(now = new Date()): MantisPhaseTimings {`
`216`		`-return {`
`217`		`-phases: [...phases],`
`218`		`-totalMs: now.getTime() - origin,`
`219`		`-};`
`220`		`-}`
`221`		`-function updatePhaseStatus(name: string, status: MantisPhaseTiming["status"]) {`
`222`		`-const phase = phases.findLast((entry) => entry.name === name);`
`223`		`-if (phase) {`
`224`		`-phase.status = status;`
`225`		`-}`
`226`		`-}`
`227`		`-return { recordPhase, snapshot, timePhase, updatePhaseStatus };`
`228`		`-}`
`229`		`-`
`230`	`179`	`function defaultOutputDir(repoRoot: string, startedAt: Date) {`
`231`	`180`	`const stamp = startedAt.toISOString().replace(/[:.]/gu, "-");`
`232`	`181`	return path.join(repoRoot, ".artifacts", "qa-e2e", "mantis", `slack-desktop-${stamp}`);

Original file line number	Diff line number	Diff line change
`@@ -20,6 +20,7 @@ import {`
`20`	`20`	`stopCrabbox,`
`21`	`21`	`warmupCrabbox,`
`22`	`22`	`} from "./crabbox-runtime.js";`
	`23`	`+import { createPhaseTimer, type MantisPhaseTimings } from "../mantis-phase-timer.runtime.js";`
`23`	`24`
`24`	`25`	`export type MantisTelegramDesktopBuilderOptions = {`
`25`	`26`	`commandRunner?: CommandRunner;`
`@@ -95,19 +96,6 @@ type MantisTelegramDesktopBuilderSummary = {`
`95`	`96`	`timings: MantisPhaseTimings;`
`96`	`97`	`};`
`97`	`98`
`98`		`-type MantisPhaseTiming = {`
`99`		`-durationMs: number;`
`100`		`-finishedAt: string;`
`101`		`-name: string;`
`102`		`-startedAt: string;`
`103`		`-status: "accepted" \| "fail" \| "pass";`
`104`		`-};`
`105`		`-`
`106`		`-type MantisPhaseTimings = {`
`107`		`-phases: MantisPhaseTiming[];`
`108`		`-totalMs: number;`
`109`		`-};`
`110`		`-`
`111`	`99`	`type TelegramDesktopRemoteMetadata = {`
`112`	`100`	`gatewayAlive?: boolean;`
`113`	`101`	`gatewayPid?: string;`
`@@ -161,45 +149,6 @@ function normalizeHydrateMode(`
`161`	`149`	throw new Error(`Unsupported Mantis Telegram desktop hydrate mode: ${value}`);
`162`	`150`	`}`
`163`	`151`
`164`		`-function createPhaseTimer(startedAt: Date) {`
`165`		`-const phases: MantisPhaseTiming[] = [];`
`166`		`-const origin = startedAt.getTime();`
`167`		`-function recordPhase(name: string, phaseStarted: Date, status: MantisPhaseTiming["status"]) {`
`168`		`-const phaseFinished = new Date();`
`169`		`-phases.push({`
`170`		`-durationMs: phaseFinished.getTime() - phaseStarted.getTime(),`
`171`		`-finishedAt: phaseFinished.toISOString(),`
`172`		`- name,`
`173`		`-startedAt: phaseStarted.toISOString(),`
`174`		`- status,`
`175`		`-});`
`176`		`-}`
`177`		`-async function timePhase<T>(name: string, run: () => Promise<T>): Promise<T> {`
`178`		`-const phaseStarted = new Date();`
`179`		`-try {`
`180`		`-const result = await run();`
`181`		`-recordPhase(name, phaseStarted, "pass");`
`182`		`-return result;`
`183`		`-} catch (error) {`
`184`		`-recordPhase(name, phaseStarted, "fail");`
`185`		`-throw error;`
`186`		`-}`
`187`		`-}`
`188`		`-function snapshot(now = new Date()): MantisPhaseTimings {`
`189`		`-return {`
`190`		`-phases: [...phases],`
`191`		`-totalMs: now.getTime() - origin,`
`192`		`-};`
`193`		`-}`
`194`		`-function updatePhaseStatus(name: string, status: MantisPhaseTiming["status"]) {`
`195`		`-const phase = phases.findLast((entry) => entry.name === name);`
`196`		`-if (phase) {`
`197`		`-phase.status = status;`
`198`		`-}`
`199`		`-}`
`200`		`-return { recordPhase, snapshot, timePhase, updatePhaseStatus };`
`201`		`-}`
`202`		`-`
`203`	`152`	`function defaultOutputDir(repoRoot: string, startedAt: Date) {`
`204`	`153`	`const stamp = startedAt.toISOString().replace(/[:.]/gu, "-");`
`205`	`154`	return path.join(repoRoot, ".artifacts", "qa-e2e", "mantis", `telegram-desktop-${stamp}`);

此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。原文来自 — 版权归原作者所有。

推荐订阅源

Recent Commits to openclaw:main