places-indexer.js

import { SanityDocumentStub } from '@sanity/client'
import { algolia, sanity } from '~/libs'
import { NextApiRequest, NextApiResponse } from 'next'
import indexer from 'sanity-algolia'

const handler = (req: NextApiRequest, res: NextApiResponse) => {
  if (req.headers['content-type'] !== 'application/json') {
    res.status(400)
    res.json({ message: 'Bad request' })

    return
  }

  if (req.headers['token'] !== process.env.SANITY_INDEXER_TOKEN) {
    res.status(401)
    res.json({ message: 'Unauthorized' })

    return
  }

  const algoliaIndex = algolia.initIndex('places')

  const typeIndexMap = {
    city: {
      index: algoliaIndex,
      projection: `{
        name,
        "path": slug.current,
      }`,
    },
    neighborhood: {
      index: algoliaIndex,
      projection: `{
        name,
        "path": slug.current,
        city->{
          _id,
          name,
          "path": slug.current,
        }
      }`,
    },
  }

  const serializer = (document: SanityDocumentStub) => {
    const { _id, _rev, _type, ...rest } = document

    switch (document._type) {
      case 'city':
        return {
          ...rest,
          objectID: document._id,
          type: 'city',
        }
      case 'neighborhood':
        return {
          ...rest,
          objectID: document._id,
          type: 'neighborhood',
          cityID: document.city?._id,
          cityName: document.city?.name,
          cityPath: document.city?.path,
          humanizedName: `${document.name}, ${document.city?.name}`,
        }
      default:
        return document
    }
  }

  const sanityAlgolia = indexer(typeIndexMap, serializer)

  return sanityAlgolia
    .webhookSync(sanity, req.body)
    .then(() => res.status(200).send('ok!'))
}

export default handler