messages.ts

// Below specific to message dispatcher

import { CID } from 'multiformats/cid'
import { AtUri } from '@atproto/uri'

export type IndexRecord = {
  type: 'index_record'
  uri: AtUri
  cid: CID
  obj: unknown
  timestamp: string
}

export type DeleteRecord = {
  type: 'delete_record'
  uri: AtUri
  cascading: boolean
}

export type DeleteRepo = {
  type: 'delete_repo'
  did: string
}

export const indexRecord = (
  uri: AtUri,
  cid: CID,
  obj: unknown,
  timestamp: string,
): IndexRecord => ({
  type: 'index_record',
  uri,
  cid,
  obj,
  timestamp,
})

export const deleteRecord = (uri: AtUri, cascading: boolean): DeleteRecord => ({
  type: 'delete_record',
  uri,
  cascading,
})

export const deleteRepo = (did: string): DeleteRepo => ({
  type: 'delete_repo',
  did,
})

// Below specific to message queue

export type CreateNotification = NotificationInfo & {
  type: 'create_notification'
}

export type NotificationInfo = {
  userDid: string
  author: string
  recordUri: string
  recordCid: string
  reason: NotificationReason
  reasonSubject?: string
}

export type NotificationReason =
  | 'vote'
  | 'assertion'
  | 'repost'
  | 'follow'
  | 'invite'
  | 'mention'
  | 'reply'

export type DeleteNotifications = {
  type: 'delete_notifications'
  recordUri: string
}

export type Message = CreateNotification | DeleteNotifications

export const createNotification = (
  notif: NotificationInfo,
): CreateNotification => ({
  type: 'create_notification',
  ...notif,
})

export const deleteNotifications = (
  recordUri: string,
): DeleteNotifications => ({
  type: 'delete_notifications',
  recordUri,
})