feat(fetcher): implement vaksinasi.id db fetcher

etc/fetchers/__mocks__/vaksinid-locations-aceh.json

@@ -0,0 +1,26 @@
+{
+  "data": [
+    {
+      "province": "Aceh",
+      "city": "Kota Banda Aceh",
+      "title": "UPTD PUSKESMAS KOPELMA DARUSSALAM",
+      "datestart": "2021-06-24",
+      "dateend": "2022-03-31",
+      "timestart": "08:00:00",
+      "timeend": "12:00:00",
+      "registration": "Walk-in",
+      "agerange": [
+        "Dewasa (18-59 Tahun)",
+        "Lansia (60-)"
+      ],
+      "description": "-Senin dan Sabtu (bisa berubah sewaktu-waktu)\n-Dibeikan bagi warga dengan kriteria:\n1.petugas pelayanan publik\n2. Pra lansia &lansia\n3. Masyarakat Banda Aceh di utamakan yang berdomisili di wilayah Puskesmas Kopelma Darussalam,Rukoh,ie masen kayee adang,Lamgugob & Deah raya\n-Membawa KTP\n-informasi tambahan bisa dilihat di akun Instagram https://instagram.com/puskesmaskopelmadarussalam?utm_medium=copy_link",
+      "link": "https://www.instagram.com/p/CQgFAepnZkQ/?utm_medium=copy_link",
+      "address": "Jalan Inong Balee No.38 Darussalam Banda Aceh",
+      "map": "https://goo.gl/maps/9hViESZJ9rYwGypb9",
+      "isfree": true,
+      "isvalid": true,
+      "code": "",
+      "dateadded": "2021-07-30"
+    }
+  ]
+}

etc/fetchers/__mocks__/vaksinid-regions.json

@@ -0,0 +1,15 @@
+{
+  "data": [
+    {
+      "province": "Aceh",
+      "city": [
+        "Kota Banda Aceh",
+        "Kota Sabang",
+        "Kota Lhokseumawe",
+        "Kota Langsa",
+        "Kota Subulussalam",
+        "Kab. Aceh Selatan"
+      ]
+    }
+  ]
+}

etc/fetchers/__tests__/fetch-vaccination-database.test.ts

@@ -0,0 +1,48 @@
+import fs from "fs";
+import path from "path";
+import fetchMock from "jest-fetch-mock";
+import { fetchVaccinationDatabase } from "../fetch-vaccination-database";
+
+describe("fetchVaksinasiDB", () => {
+  const writeFileSyncSpy = jest.spyOn(fs, "writeFileSync");
+
+  beforeEach(() => {
+    fetchMock.resetMocks();
+    writeFileSyncSpy.mockImplementation(() => {});
+  });
+
+  afterEach(() => {
+    writeFileSyncSpy.mockRestore();
+  });
+  it("fetches database from api.vaksinasi.id correctly", async () => {
+    const mockedResponses: { [url: string]: string } = {
+      "/regions": fs.readFileSync(
+        path.resolve(__dirname, "../__mocks__/vaksinid-regions.json"),
+        "utf-8",
+      ),
+      "/locations/Aceh": fs.readFileSync(
+        path.resolve(__dirname, "../__mocks__/vaksinid-locations-aceh.json"),
+        "utf-8",
+      ),
+    };
+
+    fetchMock.mockResponse(
+      async (req) =>
+        mockedResponses[new URL(req.url).pathname] ||
+        '{ "details":"Not Found" }',
+    );
+    await fetchVaccinationDatabase();
+
+    expect(fetchMock).toBeCalledTimes(2);
+
+    expect(fetchMock).toBeCalledWith("https://api.vaksinasi.id/regions");
+    expect(fetchMock).toHaveBeenCalledWith(
+      "https://api.vaksinasi.id/locations/Aceh",
+    );
+
+    expect(writeFileSyncSpy).toHaveBeenCalledTimes(1);
+    expect(JSON.parse(writeFileSyncSpy.mock.calls[0][1] as string)).toEqual([
+      JSON.parse(mockedResponses["/locations/Aceh"]),
+    ]);
+  });
+});

etc/fetchers/fetch-vaccination-database.ts

@@ -0,0 +1,31 @@
+import fs from "fs";
+import path from "path";
+import fetch from "cross-fetch";
+import {
+  VaccinationRegionsResponse,
+  VaccinationRegion,
+} from "../../lib/data/vaccination";
+
+const vaksinId = "https://api.vaksinasi.id";
+
+export async function fetchVaccinationDatabase() {
+  const regions = (await (
+    await fetch(`${vaksinId}/regions`)
+  ).json()) as VaccinationRegionsResponse;
+
+  const promisedLocations = [];
+  for (const { province } of regions.data) {
+    promisedLocations.push(
+      fetch(`${vaksinId}/locations/${province}`).then(
+        (res) => res.json() as unknown as VaccinationRegion,
+      ),
+    );
+  }
+  const locations = await Promise.all(promisedLocations);
+
+  const text = JSON.stringify([...locations]);
+  fs.writeFileSync(
+    path.resolve(__dirname, "../../data/wbw-vaccination-database.json"),
+    text,
+  );
+}

etc/fetchers/fetch-wbw.ts

@@ -4,6 +4,7 @@ import { toSecond } from "../../lib/string-utils";
 import { fetchDatabase } from "./fetch-database";
 import { fetchFaqSheets } from "./fetch-faq-sheets";
 import { fetchSheets } from "./fetch-sheets";
+import { fetchVaccinationDatabase } from "./fetch-vaccination-database";
 
 (function fetchWbw() {
   const start = process.hrtime();
@@ -33,6 +34,20 @@ import { fetchSheets } from "./fetch-sheets";
     .then(() => {
       const end = `${toSecond(process.hrtime(start))} seconds`;
       spinner.succeed(`Fetching Sheets done in ${chalk.greenBright(end)}`);
+      spinner.start(`${chalk.yellowBright("Fetching next data...")}`);
+    })
+    .catch((err) => {
+      chalk.red(err);
+    });
+
+  fetchVaccinationDatabase()
+    .then(() => {
+      const end = `${toSecond(process.hrtime(start))} seconds`;
+      spinner.succeed(
+        `Fetching vaccination database (vaksinasi.id) done in ${chalk.greenBright(
+          end,
+        )}`,
+      );
     })
     .catch((err) => {
       chalk.red(err);

lib/data/vaccination.ts

@@ -0,0 +1,32 @@
+export interface VaccinationRegions {
+  province: string;
+  city: Array<`${"Kab." | "Kota"} ${string}`>;
+}
+
+export interface VaccinationRegionsResponse {
+  data: Array<VaccinationRegions>;
+}
+
+export interface VaccinationLocation {
+  province: string;
+  city: string;
+  title: string;
+  datestart: `${number}-${number}-${number}`;
+  dateend: `${number}-${number}-${number}`;
+  timestart: `${number}:${number}:${number}`;
+  timeend: `${number}:${number}:${number}`;
+  registration: string;
+  agerange: Array<`${string} (${number}-${number | null} Tahun)`>;
+  description: string;
+  link: string;
+  address: string;
+  map: string;
+  isFree: boolean;
+  isvalid: boolean;
+  code: string;
+  dateadded: `${number}-${number}-${number}`;
+}
+
+export interface VaccinationRegion {
+  data: Array<VaccinationLocation>;
+}