Function markMessageAsReadByIdentity

src/utils/teammateMailbox.ts:498–536

(
  agentName: string,
  teamName: string | undefined,
  expectedMessage: TeammateMessage,
)

}

export async function markMessageAsReadByIdentity(
  agentName: string,
  teamName: string | undefined,
  expectedMessage: TeammateMessage,
): Promise<boolean> {
  const inboxPath = getInboxPath(agentName, teamName)
  const lockFilePath = `${inboxPath}.lock`

  let release: (() => Promise<void>) | undefined
  try {
    release = await lockfile.lock(inboxPath, {
      lockfilePath: lockFilePath,
      ...LOCK_OPTIONS,
    })

    const messages = await readMailboxForMutation(agentName, teamName)
    const messageIndex = messages.findIndex(message => {
      return !message.read && sameMailboxMessage(message, expectedMessage)
    })
    if (messageIndex < 0) return false

    messages[messageIndex] = { ...messages[messageIndex]!, read: true }
    await writeCompactedMailbox(
      inboxPath,
      messages,
      'markMessageAsReadByIdentity',
    )
    return true
  } catch (error) {
    const code = getErrnoCode(error)
    if (code === 'ENOENT') return false
    logError(error)
    return false
  } finally {
    if (release) {
      await release()
    }
  }
}

/**
 * Mark all messages in a teammate's inbox as read