feat: added cron jobs and speedtest job

Author: mrepol742

package-lock.json

@@ -39,6 +39,7 @@
     "google-tts-api": "^2.0.2",
     "groq-sdk": "^0.27.0",
     "is-spaghetti-code": "^1.0.1",
+    "node-cron": "^4.2.1",
     "npmlog": "^7.0.1",
     "ollama": "^0.5.16",
     "openai": "^5.10.2",

package.json

@@ -17,7 +17,7 @@ export default async function (msg: Message) {
     https://github.com/mrepol742/project-canis
 
     \`Canis for Telegram\`
-    https://github.com/mrepol742/project-canis-ts
+    https://github.com/mrepol742/project-canis-tg
 
     This bot is not affiliated, endorsed, partner, or connected to Meta.
     Use it at your own RISK.

src/commands/fork.ts

@@ -0,0 +1,30 @@
+import cron from "node-cron";
+import speedtestJob, { info as speedtestInfo } from "./jobs/speedtest";
+import log from "./components/utils/log";
+
+interface CronJobInfo {
+  name: string;
+  description?: string;
+  schedule: string;
+  runOnStartup?: boolean;
+}
+
+interface CronJob {
+  info: CronJobInfo;
+  job: () => Promise<void> | void;
+}
+
+// register more cron jobin here
+const jobs: CronJob[] = [{ info: speedtestInfo, job: speedtestJob }];
+
+export function registerCronJobs() {
+  for (const { info, job } of jobs) {
+    cron.schedule(info.schedule, job);
+    log.info(info.name, `Registered cron job on (${info.schedule})`);
+
+    if (info.runOnStartup) {
+      log.info(info.name, "Running on startup...");
+      job();
+    }
+  }
+}

src/cron.ts

@@ -2,6 +2,7 @@ import dotenv from "dotenv";
 dotenv.config();
 
 import "./instrument";
+import { registerCronJobs } from "./cron";
 import { client } from "./components/client";
 import { checkRequirements } from "./components/utils/requirements";
 import log from "./components/utils/log";
@@ -28,6 +29,7 @@ async function main() {
   await Promise.all([
     monitor.start(),
     phishtank.startAutoUpdateLoop(),
+    registerCronJobs(),
     (async () => {
       if (autoUpdateDaily || autoUpdateTimer) return;
       await phishtank.init();

src/index.ts

@@ -0,0 +1,32 @@
+import speedTest from "speedtest-net";
+import log from "../components/utils/log";
+import redis from "../components/redis";
+
+const CACHE_KEY = "speedtest:result";
+const CACHE_TTL = 60 * 60; // 1 hour
+
+export const info = {
+  name: "SpeedTestJob",
+  description: "Runs an internet speed test and logs results.",
+  schedule: "0 * * * *", // every hour
+  runOnStartup: true,
+};
+
+export default async function () {
+  try {
+    const results = await speedTest({ acceptLicense: true, acceptGdpr: true });
+    console.log("")// to create new line
+    log.info(
+      "SpeedTestJob",
+      `Download: ${results.download.bandwidth / 125000} Mbps`,
+    );
+    log.info(
+      "SpeedTestJob",
+      `Upload: ${results.upload.bandwidth / 125000} Mbps`,
+    );
+    log.info("SpeedTestJob", `Ping: ${results.ping.latency} ms`);
+    await redis.set(CACHE_KEY, JSON.stringify(results), { EX: CACHE_TTL });
+  } catch (err) {
+    log.error("SpeedTestJob", err);
+  }
+}