Skip to content

Instantly share code, notes, and snippets.

@nestarz

nestarz/sibyl_monitoring.js

Created December 5, 2023 17:47
Show Gist options
  • Save nestarz/6f41165207b825c1d7185bd8f188b51d to your computer and use it in GitHub Desktop.
Save nestarz/6f41165207b825c1d7185bd8f188b51d to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. nestarz created this gist Dec 5, 2023.
    160 changes: 160 additions & 0 deletions sibyl_monitoring.js
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,160 @@
    const appName = "[Sibyl Monitoring System]";
    const endpointRaw = new URL(import.meta.url).searchParams.get("endpoint");
    const endpoint = endpointRaw ? decodeURIComponent(endpointRaw) : null;
    const isBrowser = typeof window !== "undefined";
    const isLocal =
    !isBrowser ||
    ["localhost", "127.0.0.1", "[::1]"].includes(location.hostname) ||
    location.hostname.includes("192.");
    const isRobot = /bot|googlebot|crawler|spider|robot|crawling/i.test(
    isBrowser ? navigator.userAgent : ""
    );
    const isFrenchOrNull = (v) => v === "FR" || !v;
    const rawConsole = isBrowser ? { ...globalThis.console } : {};
    const browser = (fn) => (isBrowser ? fn : () => null);
    const dev = {
    log: browser((...e) => rawConsole.log(appName, ...e)),
    error: browser((...e) => rawConsole.error(appName, ...e)),
    };
    if (!endpoint) dev.error("missing endpoint");

    const postHeaders = {
    method: "POST",
    headers: { "Content-Type": "application/json" },
    };

    const request = (e, variables) =>
    fetch(e, {
    ...postHeaders,
    body: JSON.stringify(variables),
    })
    .then((res) => res.json())
    .then((json) =>
    json?.errors
    ? json.errors.forEach(({ message }) => dev.error(message))
    : json?.data
    ? dev.log("sent", variables)
    : ""
    );

    const tracePromise = fetch("https://www.cloudflare.com/cdn-cgi/trace")
    .then((r) => r.text())
    .then((t) => t.split("\n").map((l) => l.split("=")))
    .then((entries) => Object.fromEntries(entries))
    .catch(() => {});

    const rateFactory = ({ to = 3, per = 30 * 1000 } = {}) => {
    const queue = [];
    let time = 0;
    let count = 0;
    let difference = 0;
    const limit = (func) => {
    if (func) queue.push(func);
    difference = per - (Date.now() - time);
    if (difference <= 0) {
    time = Date.now();
    count = 0;
    }
    if (++count <= to) queue.shift()();
    else setTimeout(limit, difference);
    };
    return limit;
    };

    const main = () => {
    const rateLimiter = rateFactory();
    const send = (e) => {
    return rateLimiter(async () => {
    dev.log("Error Reporting...");
    const trace = await tracePromise;
    const stacktrace = e?.stack || e?.message;
    const payload = {
    href: window?.location?.href,
    userAgent: globalThis?.navigator?.userAgent,
    hostname: window?.location?.hostname,
    ip: trace?.ip,
    country: trace?.loc,
    data:
    typeof window?.SIBYL_MONITORING_DATA === "object"
    ? JSON.stringify(window.SIBYL_MONITORING_DATA)
    : null,
    stacktrace,
    ...e,
    };
    isLocal || isRobot || !isFrenchOrNull(payload.country) || !endpoint
    ? dev.log(payload)
    : request(endpoint, payload);
    });
    };

    const origOpen = XMLHttpRequest.prototype.open;
    XMLHttpRequest.prototype.open = function () {
    const args = Object.values(arguments);
    ["error", "timeout"].map((message) =>
    this.addEventListener(message, function () {
    send({
    type: "network",
    name: args.join(", "),
    message: message ?? "",
    stack: "",
    });
    })
    );
    origOpen.apply(this, arguments);
    };

    console.error = (() => {
    const consoleError = console.error;
    return function (...args) {
    try {
    throw Error(
    args
    .map((d) => (String(d).includes("[object") ? JSON.stringify(d) : d))
    .join("\n")
    );
    } catch (err) {
    consoleError(...args);
    send({
    type: "error",
    name: err?.name ?? "",
    message: err?.message ?? err?.target?.src ?? "",
    stack: err?.stack ?? "",
    });
    }
    };
    })();

    ["rejectionhandled", "unhandledrejection"].map((type) =>
    window.addEventListener(
    type,
    ({ reason, stack, name }) => {
    send({
    type,
    name: name ?? "",
    message: `${reason}`,
    stack: stack ?? "",
    });
    return false;
    },
    true
    )
    );

    window.addEventListener(
    "error",
    function (err) {
    const { message, stack, name } = err?.error ?? err;
    send({
    type: "error",
    name: name ?? err?.name ?? "",
    message: message ?? err?.message ?? err?.target?.src ?? "",
    stack: stack ?? err?.stack ?? "",
    });
    return false;
    },
    true
    );
    dev.log("Activated");
    };

    if (isBrowser) main();