mrmBot-Matrix/utils/misc.js

import util from "util";
import fs from "fs";
import pm2 from "pm2";
import { config } from "dotenv";

// playing messages
const { messages } = JSON.parse(fs.readFileSync(new URL("../config/messages.json", import.meta.url)));
const { types } = JSON.parse(fs.readFileSync(new URL("../config/commands.json", import.meta.url)));

let broadcast = false;

// random(array) to select a random entry in array
export function random(array) {
  if (!array || array.length < 1) return null;
  return array[Math.floor(Math.random() * array.length)];
}

const optionalReplace = (token) => {
  return token === undefined || token === "" ? "" : (token === "true" || token === "false" ? token : "<redacted>");
};

// clean(text) to clean message of any private info or mentions
export function clean(text) {
  if (typeof text !== "string")
    text = util.inspect(text, { depth: 1 });

  text = text
    .replaceAll("`", `\`${String.fromCharCode(8203)}`)
    .replaceAll("@", `@${String.fromCharCode(8203)}`);

  let { parsed } = config();
  if (!parsed) parsed = process.env;
  const imageServers = JSON.parse(fs.readFileSync(new URL("../config/servers.json", import.meta.url), { encoding: "utf8" })).image;

  if (imageServers?.length !== 0) {
    for (const { server, auth } of imageServers) {
      text = text.replaceAll(server, optionalReplace(server));
      text = text.replaceAll(auth, optionalReplace(auth));
    }
  }

  for (const env of Object.keys(parsed)) {
    text = text.replaceAll(parsed[env], optionalReplace(parsed[env]));
  }

  return text;
}

// textEncode(string) to encode characters for image processing
export function textEncode(string) {
  return string.replaceAll("&", "&amp;").replaceAll(">", "&gt;").replaceAll("<", "&lt;").replaceAll("\"", "&quot;").replaceAll("'", "&apos;").replaceAll("\\n", "\n").replaceAll("\\:", ":");
}

// set activity (a.k.a. the gamer code)
export function activityChanger(bot) {
  if (!broadcast) {
    bot.editStatus("dnd", {
      name: random(messages) + (types.classic ? ` | @${bot.user.username} help` : ""),
    });
  }
  setTimeout(() => activityChanger(bot), 900000);
}

export function checkBroadcast(bot) {
  /*if () {
    startBroadcast(bot, message);
  }*/
}

export function startBroadcast(bot, message) {
  bot.editStatus("dnd", {
    name: message + (types.classic ? ` | @${bot.user.username} help` : ""),
  });
  broadcast = true;
}

export function endBroadcast(bot) {
  bot.editStatus("dnd", {
    name: random(messages) + (types.classic ? ` | @${bot.user.username} help` : ""),
  });
  broadcast = false;
}

export function getServers() {
  return new Promise((resolve, reject) => {
    if (process.env.PM2_USAGE) {
      pm2.launchBus((err, pm2Bus) => {
        const listener = (packet) => {
          if (packet.data?.type === "countResponse") {
            resolve(packet.data.serverCount);
            pm2Bus.off("process:msg");
          }
        };
        pm2Bus.on("process:msg", listener);
      });
      pm2.sendDataToProcessId(0, {
        id: 0,
        type: "process:msg",
        data: {
          type: "getCount"
        },
        topic: true
      }, (err) => {
        if (err) reject(err);
      });
    } else {
      resolve(0);
    }
  });
}