index.js

console.clear();
console.log("🐾 Starting...");
import yargs from "yargs";
import cfonts from "cfonts";
import { fileURLToPath } from "url";
import { join, dirname } from "path";
import { createRequire } from "module";
import { spawn } from "child_process";
import { createInterface } from "readline";
import { setupMaster, fork } from "cluster";
import { watchFile, unwatchFile } from "fs";

// https://stackoverflow.com/a/50052194
const { say } = cfonts;
const rl = createInterface(process.stdin, process.stdout);
const __dirname = dirname(fileURLToPath(import.meta.url));
const require = createRequire(__dirname); // Bring in the ability to create the 'require' method
const { name, author } = require(join(__dirname, "./package.json")); // https://www.stefanjudis.com/snippets/how-to-import-json-files-in-es-modules-node-js/
//import "./logger.js";

say("Lightweight\nWhatsApp Bot", {
  font: "chrome",
  align: "center",
  gradient: ["red", "magenta"],
});
say(`'${name}' By @${author.name || author}`, {
  font: "console",
  align: "center",
  gradient: ["red", "magenta"],
});

var isRunning = false;
/**
 * Start a js file
 * @param {String} file `path/to/file`
 */
function start(file) {
  let args = [join(__dirname, file), ...process.argv.slice(2)];
  say([process.argv[0], ...args].join(" "), {
    font: "console",
    align: "center",
    gradient: ["red", "magenta"],
  });
  let p = spawn(process.argv[0], args, {
    stdio: ["inherit", "inherit", "inherit", "ipc"],
  })
    .on("message", (data) => {
      console.log("[✅RECEIVED]", data);
      switch (data) {
        case "reset":
          console.log("Restarting...");
          p.kill();
          // delete p
          break;
        case "uptime":
          p.send(process.uptime());
          break;
      }
    })
    .on("exit", (code) => {
      console.error("[❗]Exited with code:", code);
      if (code !== 0) return start(file);
      start.apply(this, arguments);
      watchFile(args[0], () => {
        unwatchFile(args[0]);
        start(file);
      });
    });

  let opts = new Object(
    yargs(process.argv.slice(2)).exitProcess(false).parse()
  );
  if (!opts["test"])
    if (!rl.listenerCount())
      rl.on("line", (line) => {
        p.emit("message", line.trim());
      });
  // console.log(p)
}

/*
function start(file) {
  if (isRunning) return;
  isRunning = true;
  let args = [join(__dirname, file), ...process.argv.slice(2)];
  say([process.argv[0], ...args].join(" "), {
    font: "console",
    align: "center",
    gradient: ["red", "magenta"],
  });
  setupMaster({ exec: args[0], args: args.slice(1) });
  let p = fork();
  p.on("message", (data) => {
    console.log("[✅RECEIVED]", data);
    switch (data) {
      case "reset":
        p.process.kill();
        isRunning = false;
        start.apply(this, arguments);
        break;
      case "uptime":
        p.send(process.uptime());
        break;
    }
  });
  p.on("exit", (_, code) => {
    isRunning = false;
    console.error("[❗]Exited with code:", code);
    if (code !== 0) return start(file);
    watchFile(args[0], () => {
      unwatchFile(args[0]);
      start(file);
    });
  });

  let opts = new Object(
    yargs(process.argv.slice(2)).exitProcess(false).parse()
  );
  if (!opts["test"])
    if (!rl.listenerCount())
      rl.on("line", (line) => {
        p.emit("message", line.trim());
      });
  // console.log(p)
}
*/

start("main.js");