const WHATSAPP_QA_CAPTURE_CONTENT_ENV = "OPENCLAW_QA_WHATSAPP_CAPTURE_CONTENT";

const QA_REDACT_PUBLIC_METADATA_ENV = "OPENCLAW_QA_REDACT_PUBLIC_METADATA";

const WHATSAPP_QA_TRANSIENT_DRIVER_ATTEMPTS = 3;

const WHATSAPP_QA_TRANSIENT_DRIVER_ATTEMPTS = 5;

const WHATSAPP_QA_READY_TIMEOUT_MS = 150_000;

const WHATSAPP_QA_DRIVER_RECONNECT_DELAY_MS = 2_000;

const WHATSAPP_QA_READY_STABILITY_MS = 8_000;

const WHATSAPP_QA_DRIVER_RECONNECT_DELAY_MS = 10_000;

const WHATSAPP_QA_ENV_KEYS = [

"OPENCLAW_QA_WHATSAPP_DRIVER_PHONE_E164",

"OPENCLAW_QA_WHATSAPP_SUT_PHONE_E164",

);

}

async function waitForWhatsAppChannelStable(

gateway: Awaited<ReturnType<typeof startQaGatewayChild>>,

accountId: string,

) {

await waitForWhatsAppChannelRunning(gateway, accountId);

await new Promise((resolve) => setTimeout(resolve, WHATSAPP_QA_READY_STABILITY_MS));

await waitForWhatsAppChannelRunning(gateway, accountId);

}

async function listTarEntries(archivePath: string): Promise<string[]> {

const { stdout } = await execFileAsync("tar", ["-tzf", archivePath], {

maxBuffer: 1024 * 1024,

});

let preservedGatewayDebug = false;

try {

await waitForWhatsAppChannelRunning(gatewayHarness.gateway, params.sutAccountId);

await waitForWhatsAppChannelStable(gatewayHarness.gateway, params.sutAccountId);

if (scenarioRun.quietInput) {

const quietStartedAt = new Date();

await params.driver.sendText(target, scenarioRun.quietInput);

isTransientWhatsAppQaDriverError(error)

) {

driverAttempt += 1;

await new Promise((resolve) =>

setTimeout(resolve, WHATSAPP_QA_DRIVER_RECONNECT_DELAY_MS),

);

try {

activeDriver = await restartWhatsAppQaDriverSession({

authDir: driverAuthDir,

id: scenario.id,

title: scenario.title,

status: "fail",

details: formatErrorMessage(error),

details:

driverAttempt > 1

? `${formatErrorMessage(error)}; driver reconnected ${driverAttempt - 1}x`

: formatErrorMessage(error),

});

break;

}