Function writeMailboxAtomic

src/utils/teammateMailbox.ts:152–170

(
  inboxPath: string,
  content: string,
)

}

async function writeMailboxAtomic(
  inboxPath: string,
  content: string,
): Promise<void> {
  const bytes = Buffer.byteLength(content, 'utf8')
  if (bytes > MAX_MAILBOX_FILE_BYTES) {
    throw new Error(
      `Compacted mailbox still exceeds ${MAX_MAILBOX_FILE_BYTES} bytes`,
    )
  }
  const tempPath = `${inboxPath}.${process.pid}.${randomBytes(8).toString('hex')}.tmp`
  try {
    await writeFile(tempPath, content, 'utf-8')
    await rename(tempPath, inboxPath)
  } catch (error) {
    await unlink(tempPath).catch(() => undefined)
    throw error
  }
}

export function compactMailboxMessages(
  messages: TeammateMessage[],