fibermonitor/index.js

const cheerio = require("cheerio");
const axios = require("axios");
const fastify = require("fastify")({
  logger: true,
});
// Fiber Model URL
const fiberUrl = "http://192.168.1.254/cgi-bin/fiberstat.ha";

// Get Fiber Model Page

// implement prometheus client
const client = require("prom-client");

const fiberTx = new client.Gauge({
  name: "fiber_tx",
  help: "Fiber Tx Power",
});

const fiberRx = new client.Gauge({
  name: "fiber_rx",
  help: "Fiber Rx Power",
});

const fiberBias = new client.Gauge({
  name: "fiber_bias",
  help: "Fiber Bias",
});

const fiberVcc = new client.Gauge({
  name: "fiber_vcc",
  help: "Fiber Vcc",
});

const fiberTemp = new client.Gauge({
  name: "fiber_temp",
  help: "Fiber Temperature",
});

// Register the metrics
fastify.get("/metrics", async (req, res) => {
  const data = await getFiberData();
  res.header("Content-Type", "text/plain");
  res.send(await client.register.metrics());
});

async function getFiberData() {
  const modemData = await axios.get(fiberUrl);
  const $ = cheerio.load(modemData.data);

  // Parse the fiber and split to have Temp, Vcc, TX Bias, TX Power and RX Power
  // Look for a H1 header that has the text Tx Power in it

  const TxPower = $("h1")
    .filter((i, el) => $(el).text().includes("Tx Power"))
    .text()
    .split("Currently ")[1];

  const Bias = $("h1")
    .filter((i, el) => $(el).text().includes("Bias"))
    .text()
    .split("Currently ")[1];

  const RxPower = $("h1")
    .filter((i, el) => $(el).text().includes("Rx Power"))
    .text()
    .split("Currently ")[1];

  const Vcc = $("h1")
    .filter((i, el) => $(el).text().includes("Vcc"))
    .text()
    .split("Currently ")[1];

  const Temp = $("h1")
    .filter((i, el) => $(el).text().includes("Temperature"))
    .text()
    .split("Currently ")[1];

  fiberTx.set(parseFloat(TxPower));
  fiberRx.set(parseFloat(RxPower));
  fiberBias.set(parseFloat(Bias));
  fiberVcc.set(parseFloat(Vcc));
  fiberTemp.set(parseFloat(Temp));
}

const start = async () => {
  try {
    await fastify.listen({ host: "0.0.0.0", port: 3000 });
  } catch (err) {
    fastify.log.error(err);
    process.exit(1);
  }
};

start();