Function fireCompanionObserver

src/buddy/observer.ts:398–444

(
  messages: readonly Message[],
  onReaction: (reaction: string) => void,
)

}

export async function fireCompanionObserver(
  messages: readonly Message[],
  onReaction: (reaction: string) => void,
): Promise<void> {
  const companion = getCompanion()
  if (!companion || getGlobalConfig().companionMuted) {
    lastObservedMessageCount = messages.length
    return
  }

  const addressed = wasBuddyAddressed(messages, companion.name)
  const newToolOutput = collectRecentToolResults(messages.slice(lastObservedMessageCount))
  lastObservedMessageCount = messages.length

  const recentToolOutput = collectRecentToolResults(
    messages.slice(-REACTION_TRANSCRIPT_WINDOW),
  )
  const reason = addressed ? null : classifyToolResultContext(newToolOutput)
  const effectiveReason = reason ?? 'turn'
  const now = Date.now()

  if (!addressed && !reason && now - lastReactionAt < BUDDY_REACTION_COOLDOWN_MS) {
    return
  }

  const transcript = buildReactionTranscript(messages, recentToolOutput)
  if (!transcript.trim()) {
    return
  }

  lastReactionAt = now
  const reaction = await postBuddyReaction(
    companion,
    transcript,
    effectiveReason,
    recentReactions,
    addressed,
    AbortSignal.timeout(BUDDY_REQUEST_TIMEOUT_MS),
  )

  if (!reaction) {
    return
  }

  pushRecentReaction(reaction)
  onReaction(reaction)
}

export async function buildHatchContext(): Promise<string> {
  const cwd = getCwd()