cronmon.ts

#!/usr/bin/env -S deno run --ext=ts --allow-env --allow-read --allow-net --import-map=deno.json --lock=lock.json

import { dotenv, Application, Context, Router } from "./deps.ts";

await dotenv.load({ export: true });
const router = new Router();

interface Job {
  jobId: number;
  enabled: boolean;
  title: string;
  saveResponses: boolean;
  url: string;
  lastStatus: number; // > 1 means not OK
  lastDuration: number;
  lastExecution: number;
  nextExecution: number;
  type: number;
  requestTimeout: number;
  redirectSuccess: boolean;
  folderId: number;
  schedule: {
    timezone: string;
    hours: number[];
    mdays: number[];
    minutes: number[];
    months: number[];
    wdays: number[];
    expiresAt: number;
  };
  requestMethod: number;
}

router.get("/", async (context: Context) => {
  try {
    const resp = await fetch(`${Deno.env.get("CRON_JOB_API_URL")}/jobs`, {
      method: "GET",
      headers: {
        "Content-Type": "application/json",
        Authorization: `Bearer ${Deno.env.get("CRON_JOB_API_KEY")}`,
      },
    });
    const json = await resp.json();
    const failedJobs: Job[] = (json["jobs"] as Job[])
      .sort((a: Job, b: Job) => a.jobId - b.jobId)
      .filter((job: Job) => job.enabled && job.lastStatus > 1);
    if (failedJobs.length > 0) {
      context.response.status = 504;
      context.response.body = {
        success: false,
        msg: "Some jobs failed",
        // deno-lint-ignore no-explicit-any
        failedJobs: failedJobs.map((job: { [x: string]: any }) => job.title),
      };
      return;
    }
    context.response.body = {
      success: true,
      msg: "OK",
    };
  } catch (e) {
    context.response.status = 500;
    context.response.body = {
      success: false,
      msg: e,
    };
  }
});

const app = new Application();
app.use(router.routes());
app.use(router.allowedMethods());

const url = `${Deno.env.get("CRONMON_HOST")}:${Deno.env.get("CRONMON_PORT")}`;
console.log(`Server running on http://${url}`);
app.listen(url);