process-info.ts

import { IProcessType, PROCESS_TYPES } from "@pm2.web/typings";
import bytes from "bytes-iec";
import pm2 from "pm2";

import type { IProcessInfo } from "../types/info.js";
import type { Pm2ProcessDescription } from "../types/pm2.js";

const getProcessInfo = async (): Promise<IProcessInfo[]> => {
  const pm2List = await new Promise<Pm2ProcessDescription[]>(
    (resolve, reject) => {
      pm2.list((err, list) => {
        if (err) {
          reject(err);
          return;
        }
        resolve(list as Pm2ProcessDescription[]);
      });
    },
  );

  const processList = pm2List
    .map((item) => {
      if (item.pm_id === undefined) return null;

      const usedHeapSize = item?.pm2_env?.axm_monitor?.["Used Heap Size"] || {
        value: "0",
        unit: "",
      };

      const interpreter = item?.pm2_env?.exec_interpreter;

      return {
        name: item.name || item.pm_id,
        pm_id: item.pm_id,
        stats: {
          cpu: item?.monit?.cpu || 0,
          memory: item?.monit?.memory || 0,
          heapUsed: bytes.parse(`${usedHeapSize.value}${usedHeapSize.unit}`),
          memoryMax: 0,
          uptime: Date.now() - (item?.pm2_env?.pm_uptime || 0),
        },
        versioning: {
          url: item.pm2_env?.versioning?.url,
          revision: item.pm2_env?.versioning?.revision,
          comment: item.pm2_env?.versioning?.comment,
          branch: item.pm2_env?.versioning?.branch,
          unstaged: item.pm2_env?.versioning?.unstaged ?? true,
        },
        status: item?.pm2_env?.status || "offline",
        type: PROCESS_TYPES.includes(interpreter as IProcessType)
          ? interpreter
          : "other",
      };
    })
    .filter((item) => !!item) as IProcessInfo[];

  return processList;
};

export default getProcessInfo;