Function syncFile

modules/standard-site-sync.ts:191–254

(
  filePath: string,
  siteUrl: string,
  identifier: AtIdentifierString,
  pdsPublicClient: Client,
)

 * WARN: DOES NOT CATCH ERRORS, THIS MUST BE HANDLED
 */
const syncFile = async (
  filePath: string,
  siteUrl: string,
  identifier: AtIdentifierString,
  pdsPublicClient: Client,
) => {
  const { data: frontmatter } = read(filePath)

  const normalizedFrontmatter = normalizeBlogFrontmatter(frontmatter)
  // formats dates to ISO string for records
  if (normalizedFrontmatter['date']) {
    const rawDate = normalizedFrontmatter['date']
    normalizedFrontmatter.date = new Date(
      rawDate instanceof Date ? rawDate : String(rawDate),
    ).toISOString()
  }

  const result = safeParse(BlogPostSchema, normalizedFrontmatter)
  if (!result.success) {
    console.warn(`[standard-site-sync] Validation failed for ${filePath}`, result.issues)
    return
  }

  const data = result.output

  // filter drafts
  if (data.draft) {
    if (process.env.DEBUG === 'true') {
      console.debug(`[standard-site-sync] Skipping draft: ${data.path}`)
    }
    return
  }

  const hash = createContentHash(data)

  if (syncedDocuments.get(data.path) === hash) {
    return
  }

  const tid = generateBlogTID(data.date, data.slug)

  let checkForBlogResult = await pdsPublicClient.xrpcSafe(com.atproto.repo.getRecord, {
    params: {
      rkey: tid,
      repo: identifier,
      collection: site.standard.document.$nsid,
    },
  })

  if (checkForBlogResult.success) {
    console.log(`[standard-site-sync]: ${data.title} is already synced`)
    // Every thing is synced can now return
    return
  }
  if (checkForBlogResult instanceof XrpcResponseError) {
    //Means it's not been uploaded and we can do that now
    if (checkForBlogResult.error === 'RecordNotFound') {
      const document = buildATProtoDocument(siteUrl, data)