Function sync

src/sync/schedule.ts:14–200

()

import { KAI_HEADERS } from "./headers"

const sync = async () => {
  if (!process.env.DATABASE_URL) throw new Error("DATABASE_URL env is missing")
  if (!process.env.COMULINE_ENV) throw new Error("COMULINE_ENV env is missing")
  if (!process.env.KRL_ENDPOINT_BASE_URL)
    throw new Error("KRL_ENDPOINT_BASE_URL env is missing")

  const { db } = new Database({
    COMULINE_ENV: process.env.COMULINE_ENV,
    DATABASE_URL: process.env.DATABASE_URL,
  })

  const stations = await db
    .select({
      id: stationTable.id,
      metadata: stationTable.metadata,
      name: stationTable.name,
    })
    .from(stationTable)

  const batchSizes = 5
  const totalBatches = Math.ceil(stations.length / batchSizes)

  const schema = z.object({
    status: z.number(),
    data: z.array(
      z.object({
        train_id: z.string(),
        ka_name: z.string(),
        route_name: z.string(),
        dest: z.string(),
        time_est: z.string(),
        color: z.string(),
        dest_time: z.string(),
      }),
    ),
  })

  for (let i = 0; i < totalBatches; i++) {
    const start = i * batchSizes
    const end = start + batchSizes
    const batch = stations.slice(start, end)

    await Promise.allSettled(
      batch.map(async ({ id, metadata }) => {
        await sleep(5000)

        const url = `${process.env.KRL_ENDPOINT_BASE_URL}/schedule?stationid=${id}&timefrom=00:00&timeto=23:00`

        console.info(`[SYNC][SCHEDULE][${id}] Send preflight`)
        const optionsResponse = await fetch(url, {
          method: "OPTIONS",
          headers: {
            ...KAI_HEADERS,
            "Access-Control-Request-Method": "GET",
            "Access-Control-Request-Headers": "authorization,content-type",
          },
          credentials: "include",
          mode: "cors",