proc_watcher_worker.ts

import CpuinfoParse, { extractAndMergeCpuInfo } from "./cpuinfo_parser.ts";
import { data_pipe } from "./main.ts";
import MeminfoParse from "./meminfo_parser.ts";
import {
  readCpuinfo,
  readMeminfo,
  readPidBinarySymlink,
  readPidSmaps,
  readProcDir,
} from "./reader.ts";
import PidSmapsParse from "./smaps_parser.ts";

declare global {
  interface Window {
    postMessage: any;
  }
}

// Timeout in ms
const TIMEOUT = 2000;

function callback() {
  const pids = readProcDir();
  const cpuinfo = readCpuinfo();
  const meminfo = readMeminfo();

  const parsedMeminfo = MeminfoParse(meminfo);
  const parsedCpuInfo = CpuinfoParse(cpuinfo);
  const extractedCpuInfo = extractAndMergeCpuInfo(parsedCpuInfo);

	let pidsMemUsageAll: any = [];

  for (const pid in pids) {
    const p = readPidSmaps(pids[pid]);
    if (p === "") {
      continue;
    }

    // Pidstat is too big for Deno.kv to store
    // so we read only the values we need for each PID
    const pidStat = PidSmapsParse(p);
		const bin = readPidBinarySymlink(pids[pid])

    pidsMemUsageAll.push({
      pid: pids[pid],
			exe: bin,
      meminfo: {
        Size: pidStat["Size"].value,
        Rss: pidStat["Rss"].value,
        Pss: pidStat["Pss"].value,
      },
    });
  }

  data_pipe.postMessage([
		{
			source: "pids",
			values: pidsMemUsageAll,
		},
		{
			source: "system",
			values: {
				cpu: extractedCpuInfo,
				meminfo: parsedMeminfo,
			}
		}
  ]);

	pidsMemUsageAll = [];

  setTimeout(callback, TIMEOUT);
}

callback();