conf-vods / src / utils / talks.ts

import { xrpcSafe } from "@atproto/lex";
import { getMiniDoc } from "./microcosm"
import * as com from "#/__generated__/com"
import * as tv from "#/__generated__/tv"

const IONOSPHERE_REPO_DID = "did:plc:lkeq4oghyhnztbu4dxr3joff";

export type Talks = Awaited<ReturnType<typeof getTalks>>
export type Talk = Talks[number]

export async function getTalks() {
  const pds = await getMiniDoc(IONOSPHERE_REPO_DID);
  if (!pds) throw new Error("Failed to get PDS for events repo")

  const talks = await xrpcSafe(pds, com.atproto.repo.listRecords, {
    params: {
      collection: "tv.ionosphere.talk",
      repo: IONOSPHERE_REPO_DID,
      limit: 100
    }
  })

  if (!talks.success) {
    throw new Error("Failed to fetch talks")
  }

  const validatedTalks = talks.body.records.map(record => tv.ionosphere.talk.$safeParse(record.value)).filter(result => result.success).map(result => result.value)

  const talksWithResolvedSpeakers = await Promise.all(validatedTalks.map(async talk => {
    if (!talk.speakerUris?.length) {
      return {
        ...talk,
        roomId: labelToId(talk.room),
        categoryId: labelToId(talk.category),
        speakers: []
      }
    }
    const speakers = await Promise.all(talk.speakerUris.map(async speakerUri => {
      const rkey = speakerUri.split("/").pop()!
      const result = await xrpcSafe(pds, com.atproto.repo.getRecord, {
        params: {
          collection: "tv.ionosphere.speaker",
          repo: IONOSPHERE_REPO_DID,
          rkey,
        },
      })
      if (!result.success) return null
      const speaker = tv.ionosphere.speaker.$safeParse(result.body.value)
      return speaker.success ? speaker.value : null
    }))
    return {
      ...talk,
      roomId: labelToId(talk.room),
      categoryId: labelToId(talk.category),
      speakers: speakers.filter((s): s is NonNullable<typeof s> => s !== null),
    }
  })
  )

  return talksWithResolvedSpeakers
}

function labelToId(label?: string) {
  return label?.toLowerCase().split(" ").join("-")
}