bot.js

/* global fetch */
import Prisma from '@prisma/client'
import { sendEmail } from './email.js'

process.env.TZ = 'Europe/Stockholm' // tell node to parse dates without timestamp (e.g. startTime) with Stockholm timezone

const prisma = new Prisma.PrismaClient()

const sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms))
const alreadyExists = ({ id }) => prisma.appointment.findUnique({ where: { id } })
  .then(Boolean)

const notifyUsers = async (appointment) => {
  const users = await prisma.user.findMany({
    where: {
      active: true,
      clinics: { has: appointment.clinic }
    }
  })
  for (const user of users) {
    await sendEmail({
      to: user.email,
      subject: `Ny tandläkartid i ${appointment.clinic}!`,
      text: [
        appointment.description,
        `${appointment.startTime.toLocaleString('sv-SE')} i ${appointment.clinic}`,
        'https://www.folktandvardenstockholm.se/webbokning/boka-sista-minuten/'
      ].join('\n')
    })
  }
}

const bot = async () => {
  console.time('fetchAppointments')
  const result = await fetch('https://www.folktandvardenstockholm.se/api/booking/lastminutenotcached')
  console.timeEnd('fetchAppointments')
  const appointments = await result.json()
  for (const appointment of appointments) {
    if (await alreadyExists(appointment)) {
      console.log(`already seen ${appointment.id} skipping`)
      continue
    }

    const {
      id,
      timeType: {
        description
      },
      clinicName: clinic,
      startTime
    } = appointment
    const savedAppointment = await prisma.appointment.create({
      data: {
        id,
        description,
        clinic,
        startTime: new Date(startTime)
      }
    })
    console.log('saved appointment', JSON.stringify(savedAppointment))
    await notifyUsers(savedAppointment)
  }
}

const server = async () => {
  try {
    await bot()
  } catch (error) {
    console.error('bot error', error)
  }
  await sleep(60 * 1000)
  server()
}

server()