import type { OpenClawConfig } from "../config/config.js";

import { resolveStateDir } from "../config/paths.js";

import { createSubsystemLogger } from "../logging/subsystem.js";

import { resolveExpiresAtMsFromDurationMs } from "../shared/number-coercion.js";

import { normalizeOptionalString } from "../shared/string-coerce.js";

import { resolveCommitmentTimezone, resolveCommitmentsConfig } from "./config.js";

import {

);

}

function openTerminalFailureCooldown(agentId: string, error: unknown): void {

terminalFailureCooldownUntilByAgent.set(

agentId,

Date.now() + TERMINAL_EXTRACTION_FAILURE_COOLDOWN_MS,

);

function openTerminalFailureCooldown(

agentId: string,

error: unknown,

nowMs: number,

fallbackNowMs: number,

): void {

const cooldownUntil =

resolveExpiresAtMsFromDurationMs(TERMINAL_EXTRACTION_FAILURE_COOLDOWN_MS, { nowMs }) ??

resolveExpiresAtMsFromDurationMs(TERMINAL_EXTRACTION_FAILURE_COOLDOWN_MS, {

nowMs: fallbackNowMs,

});

if (cooldownUntil !== undefined) {

terminalFailureCooldownUntilByAgent.set(agentId, cooldownUntil);

}

queue = queue.filter((item) => item.agentId !== agentId);

log.warn("commitment extraction disabled temporarily after terminal model/auth failure", {

agentId,

result = await extractor({ cfg: firstCfg, items });

} catch (error) {

if (isTerminalExtractionError(error)) {

openTerminalFailureCooldown(items[0]?.agentId ?? "", error);

openTerminalFailureCooldown(

items[0]?.agentId ?? "",

error,

Date.now(),

items[0]?.nowMs ?? Date.now(),

);

}

throw error;

}