} from "./service/state.js";

import type { CronJob } from "./types.js";

type CronWakeResult = { ok: true } | { ok: false };

type CronWakeResult = { ok: true } | { ok: false; reason?: "unwakeable-session-key" };

export type CronServiceRunResult = CronRunResult | { ok: true; ran: false; reason: "invalid-spec" };

HEARTBEAT_SKIP_CRON_IN_PROGRESS,

isRetryableHeartbeatBusySkipReason,

} from "../../infra/heartbeat-wake.js";

import { DEFAULT_AGENT_ID } from "../../routing/session-key.js";

import { DEFAULT_AGENT_ID, isSubagentSessionKey } from "../../routing/session-key.js";

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

import {

completeTaskRunByRunId,

return { ok: false } as const;

}

const sessionKey = opts.sessionKey?.trim() || undefined;

if (sessionKey && isSubagentSessionKey(sessionKey)) {

return { ok: false, reason: "unwakeable-session-key" } as const;

}

state.deps.enqueueSystemEvent(text, sessionKey ? { sessionKey } : undefined);

if (opts.mode === "now") {

state.deps.requestHeartbeat({

reason: "wake",

});

});

it("rejects subagent sessionKey targets without enqueueing or waking", () => {

const { state, enqueueSystemEvent, requestHeartbeat } = createState();

expect(

wake(state, {

mode: "now",

text: "ping",

sessionKey: "agent:main:subagent:worker",

}),

).toEqual({ ok: false, reason: "unwakeable-session-key" });

expect(enqueueSystemEvent).not.toHaveBeenCalled();

expect(requestHeartbeat).not.toHaveBeenCalled();

});

});

validateTargetProviderPrefix,

} from "../../infra/outbound/channel-target-prefix.js";

import { listConfiguredAnnounceChannelIdsForConfig } from "../../plugins/channel-plugin-ids.js";

import { isSubagentSessionKey } from "../../routing/session-key.js";

import { normalizeMessageChannel } from "../../utils/message-channel.js";

import {

ErrorCodes,

sessionKey?: string;

};

const sessionKey = p.sessionKey?.trim() || undefined;

if (sessionKey && isSubagentSessionKey(sessionKey)) {

respond(

false,

undefined,

errorShape(ErrorCodes.INVALID_REQUEST, "wake sessionKey cannot target a subagent session"),

);

return;

}

const result = context.cron.wake({

mode: p.mode,

text: p.text,

expect(context.cron.wake).not.toHaveBeenCalled();

expect(respond).toHaveBeenCalledWith(false, undefined, expect.any(Object));

});

it("rejects subagent sessionKey targets before enqueueing", async () => {

const { context, respond } = await invokeWake({

mode: "now",

text: "ping",

sessionKey: "agent:main:subagent:worker",

});

expect(context.cron.wake).not.toHaveBeenCalled();

expect(respond).toHaveBeenCalledWith(false, undefined, expect.any(Object));

});

});

});