Zumri-Backend/app/workers/log.worker.js

/**
 * Copyright (c) 2026 Niolla
 * All rights reserved.
 *
 * This source code is proprietary and confidential.
 * Unauthorized copying, modification, distribution, or use
 * of this file, via any medium, is strictly prohibited.
 */

// app/workers/log.worker.js

const { Worker } = require("bullmq");
const fs = require("fs");
const path = require("path");

const connection = require("../config/redisClient");

const logsDirectory = path.join(__dirname, "../../logs");

// Ensure logs directory exists
fs.mkdirSync(logsDirectory, { recursive: true });

const createLogWorker = () => {
  const worker = new Worker(
    "logQueue",

    async (job) => {
      const { message, timestamp } = job.data;

      const logDate = new Date(timestamp)
        .toISOString()
        .split("T")[0];

      const logFilePath = path.join(
        logsDirectory,
        `app-${logDate}.log`
      );

      const logLine = `[${timestamp}] ${message}\n`;

      await fs.promises.appendFile(
        logFilePath,
        logLine,
        "utf8"
      );
    },

    {
      connection,
    }
  );

  worker.on("completed", (job) => {
    console.log(`Log job ${job.id} completed`);
  });

  worker.on("failed", (job, err) => {
    console.error(
      `Log job ${job?.id} failed:`,
      err
    );
  });

  worker.on("error", (err) => {
    console.error("Log worker error:", err);
  });

  console.log("🟢 Log worker started");

  return worker;
};

module.exports = createLogWorker;