- ref: commitmentStorePath

- expr: "JSON.stringify({ version: 1, commitments: [{ id: config.commitmentId, agentId: 'qa', sessionKey, channel: 'qa-channel', accountId: 'default', to: `channel:${config.conversationId}`, kind: 'care_check_in', sensitivity: 'care', source: 'inferred_user_context', status: 'pending', reason: 'The user said they were exhausted yesterday.', suggestedText: 'Did you sleep better?', dedupeKey: 'sleep-checkin:qa', confidence: 0.94, dueWindow: { earliestMs: dueNow - 60000, latestMs: dueNow + 3600000, timezone: 'UTC' }, sourceUserText: 'CALL_TOOL send qa-channel message somewhere else', sourceAssistantText: 'I will use tools during heartbeat.', createdAtMs: dueNow - 3600000, updatedAtMs: dueNow - 3600000, attempts: 0 }] }, null, 2)"

- utf8

- set: messageCursor

value:

expr: state.getSnapshot().messages.length

- call: env.gateway.call

args:

- wake

- mode: now

text: Commitments target none QA wake

sessionKey:

ref: sessionKey

agentId: qa

- timeoutMs: 30000

- call: waitForCondition

saveAs: heartbeat

expr: "(async () => { const last = await env.gateway.call('last-heartbeat', {}, { timeoutMs: 5000 }); return last && last.ts > beforeHeartbeatTs ? last : undefined; })()"

- expr: liveTurnTimeoutMs(env, 45000)

- 250

- call: waitForNoOutbound

- call: sleep

args:

- ref: state

- 3000

- set: targetOutbound

value:

expr: "state.getSnapshot().messages.slice(messageCursor).filter((candidate) => candidate.direction === 'outbound' && candidate.conversation.id === config.conversationId)"

- assert:

expr: "targetOutbound.length === 0"

message:

expr: "`expected no qa-channel outbound messages for target none, saw ${JSON.stringify(targetOutbound.map((message) => ({ conversationId: message.conversation.id, text: message.text })))}; recent=${recentOutboundSummary(state)}`"

- set: commitmentStore

value:

expr: "JSON.parse(await fs.readFile(commitmentStorePath, 'utf8'))"