linkwarden/apps/worker/worker.ts

import { startIndexing } from "./workers/linkIndexing";
import { startProcessing } from "./workers/linkProcessing";
import { startRSSPolling } from "./workers/rssPolling";

const workerIntervalInSeconds =
  Number(process.env.ARCHIVE_SCRIPT_INTERVAL) || 10;

async function init() {
  console.log("\x1b[34m%s\x1b[0m", "Initializing the worker...");
  startRSSPolling();
  startProcessing(workerIntervalInSeconds);
  startIndexing(workerIntervalInSeconds);
}

init();