watproto / packages / server / src / lib / inbox-operations / cachePrivatePost.ts

import { db } from '@api/db/db'
import type { Did } from '@atcute/lexicons'
import type { AppWafrnContentPrivatePost } from '@watproto/lexicon'

/**
 * Cache a private post in the database
 */
export default async function cachePrivatePost(
  uri: string,
  authorDid: Did,
  record: AppWafrnContentPrivatePost.Main
) {
  const row = await db
    .insertInto('private_posts')
    .values({
      author_did: authorDid,
      uri,
      encrypted_content: record.encryptedContent,
      key_version: record.keyVersion,
      created_at: new Date(record.createdAt).getTime(),
      visibility: record.visibility
    })
    .returning(['indexed_at'])
    .executeTakeFirstOrThrow()

  return new Date(row.indexed_at).toISOString()
}