Function createSendMessageTimerController

cli/src/utils/send-message-timer.ts:41–110

(
  options: SendMessageTimerControllerOptions,
)

}

export const createSendMessageTimerController = (
  options: SendMessageTimerControllerOptions,
): SendMessageTimerController => {
  const {
    mainAgentTimer,
    onTimerEvent,
    agentId,
    now = () => Date.now(),
  } = options

  let timerStartedAt: number | null = null
  let timerMessageId: string | null = null
  let timerActive = false

  const start = (messageId: string) => {
    if (timerActive) {
      return
    }
    timerActive = true
    timerMessageId = messageId
    timerStartedAt = now()
    mainAgentTimer.start()
    const startEvent: SendMessageTimerEvent = {
      type: 'start',
      startedAt: timerStartedAt,
      messageId,
    }
    if (agentId) {
      startEvent.agentId = agentId
    }
    onTimerEvent(startEvent)
  }

  const stop = (outcome: SendMessageTimerOutcome) => {
    if (!timerActive || timerStartedAt == null || !timerMessageId) {
      return null
    }
    timerActive = false
    mainAgentTimer.stop()
    const finishedAt = now()
    const elapsedMs = Math.max(0, finishedAt - timerStartedAt)
    const stopEvent: SendMessageTimerEvent = {
      type: 'stop',
      startedAt: timerStartedAt,
      finishedAt,
      elapsedMs,
      messageId: timerMessageId,
      outcome,
    }
    if (agentId) {
      stopEvent.agentId = agentId
    }
    onTimerEvent(stopEvent)
    timerStartedAt = null
    timerMessageId = null
    return { finishedAt, elapsedMs }
  }