Function sync

src/sync/station.ts:10–143

()

  `st_${type}_${id}`.toLocaleLowerCase()

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 schema = z.object({
    status: z.number(),
    message: z.string(),
    data: z.array(
      z.object({
        sta_id: z.string(),
        sta_name: z.string(),
        group_wil: z.number(),
        fg_enable: z.number(),
      }),
    ),
  })

  const url = `${process.env.KRL_ENDPOINT_BASE_URL}/krl-station`

  const req = await fetch(url, {
    method: "GET",
    headers: KAI_HEADERS,
  })

  if (!req.ok)
    throw new Error(
      `[SYNC][STATION] Request failed with status: ${req.status}`,
      {
        cause: await req.text(),
      },
    )

  const data = await req.json()

  const parsedData = schema.safeParse(data)

  if (!parsedData.success) {
    throw new Error(parsedData.error.message, {
      cause: parsedData.error.cause,
    })
  }

  const filteredStation = parsedData.data.data.filter(
    (d) => !d.sta_id.includes("WIL"),
  )

  const stations = filteredStation.map((s) => {
    return {
      uid: createStationKey("KRL", s.sta_id),
      id: s.sta_id,
      name: s.sta_name,