oneuptime/Probe/Jobs/Alive.ts

import { INGESTOR_URL } from "../Config";
import Register from "../Services/Register";
import ProbeAPIRequest from "../Utils/ProbeAPIRequest";
import URL from "Common/Types/API/URL";
import API from "Common/Utils/API";
import { EVERY_MINUTE } from "Common/Utils/CronTime";
import LocalCache from "CommonServer/Infrastructure/LocalCache";
import BasicCron from "CommonServer/Utils/BasicCron";
import logger from "CommonServer/Utils/Logger";

BasicCron({
  jobName: "Basic:Alive",
  options: {
    schedule: EVERY_MINUTE,
    runOnStartup: false,
  },
  runFunction: async () => {
    logger.debug("Checking if probe is alive...");

    const probeId: string | undefined = LocalCache.getString(
      "PROBE",
      "PROBE_ID",
    );

    if (!probeId) {
      logger.warn(
        "Probe is not registered yet. Skipping alive check. Trying to register probe again...",
      );
      await Register.registerProbe();
      return;
    }

    logger.debug("Probe ID: " + probeId.toString());

    await API.post(
      URL.fromString(INGESTOR_URL.toString()).addRoute("/alive"),
      ProbeAPIRequest.getDefaultRequestBody(),
    );
  },
});