first public source commit

src/pages/api/bookmarks.js

@@ -0,0 +1,27 @@
+import { promises as fs } from "fs";
+import path from "path";
+import yaml from "js-yaml";
+import checkAndCopyConfig from "utils/config";
+
+export default async function handler(req, res) {
+  checkAndCopyConfig("bookmarks.yaml");
+
+  const bookmarksYaml = path.join(process.cwd(), "config", "bookmarks.yaml");
+  const fileContents = await fs.readFile(bookmarksYaml, "utf8");
+  const bookmarks = yaml.load(fileContents);
+
+  // map easy to write YAML objects into easy to consume JS arrays
+  const bookmarksArray = bookmarks.map((group) => {
+    return {
+      name: Object.keys(group)[0],
+      bookmarks: group[Object.keys(group)[0]].map((entries) => {
+        return {
+          name: Object.keys(entries)[0],
+          ...entries[Object.keys(entries)[0]][0],
+        };
+      }),
+    };
+  });
+
+  res.send(bookmarksArray);
+}

src/pages/api/docker/stats/[...service].js

@@ -0,0 +1,49 @@
+import Docker from "dockerode";
+import getDockerArguments from "utils/docker";
+
+export default async function handler(req, res) {
+  const { service } = req.query;
+  const [containerName, containerServer] = service;
+
+  if (!containerName && !containerServer) {
+    res.status(400).send({
+      error: "docker query parameters are required",
+    });
+    return;
+  }
+
+  try {
+    const docker = new Docker(await getDockerArguments(containerServer));
+    const containers = await docker.listContainers();
+
+    // bad docker connections can result in a <Buffer ...> object?
+    // in any case, this ensures the result is the expected array
+    if (!Array.isArray(containers)) {
+      return res.status(500).send({
+        error: "query failed",
+      });
+    }
+
+    const containerNames = containers.map((container) => {
+      return container.Names[0].replace(/^\//, "");
+    });
+    const containerExists = containerNames.includes(containerName);
+
+    if (!containerExists) {
+      return res.status(404).send({
+        error: "not found",
+      });
+    }
+
+    const container = docker.getContainer(containerName);
+    const stats = await container.stats({ stream: false });
+
+    return res.status(200).json({
+      stats: stats,
+    });
+  } catch {
+    return res.status(500).send({
+      error: "unknown error",
+    });
+  }
+}

src/pages/api/docker/status/[...service].js

@@ -0,0 +1,48 @@
+import Docker from "dockerode";
+import getDockerArguments from "utils/docker";
+
+export default async function handler(req, res) {
+  const { service } = req.query;
+  const [containerName, containerServer] = service;
+
+  if (!containerName && !containerServer) {
+    return res.status(400).send({
+      error: "docker query parameters are required",
+    });
+  }
+
+  try {
+    const docker = new Docker(await getDockerArguments(containerServer));
+    const containers = await docker.listContainers();
+
+    // bad docker connections can result in a <Buffer ...> object?
+    // in any case, this ensures the result is the expected array
+    if (!Array.isArray(containers)) {
+      return res.status(500).send({
+        error: "query failed",
+      });
+    }
+
+    const containerNames = containers.map((container) => {
+      return container.Names[0].replace(/^\//, "");
+    });
+    const containerExists = containerNames.includes(containerName);
+
+    if (!containerExists) {
+      return res.status(404).send({
+        error: "not found",
+      });
+    }
+
+    const container = docker.getContainer(containerName);
+    const info = await container.inspect();
+
+    return res.status(200).json({
+      status: info.State.Status,
+    });
+  } catch {
+    return res.status(500).send({
+      error: "unknown error",
+    });
+  }
+}

src/pages/api/proxy.js

@@ -0,0 +1,29 @@
+function pick(object, keys) {
+  return;
+}
+
+export default async function handler(req, res) {
+  const headers = ["X-API-Key", "Content-Type", "Authorization"].reduce((obj, key) => {
+    if (req.headers && req.headers.hasOwnProperty(key.toLowerCase())) {
+      obj[key] = req.headers[key.toLowerCase()];
+    }
+    return obj;
+  }, {});
+
+  try {
+    const result = await fetch(req.query.url, {
+      strictSSL: false,
+      rejectUnhauthorized: false,
+      method: req.method,
+      headers: headers,
+      body: req.method == "GET" || req.method == "HEAD" ? null : req.body,
+    }).then((res) => res);
+
+    const forward = await result.text();
+    return res.status(result.status).send(forward);
+  } catch {
+    return res.status(500).send({
+      error: "query failed",
+    });
+  }
+}

src/pages/api/services/index.js

@@ -0,0 +1,27 @@
+import { promises as fs } from "fs";
+import path from "path";
+import yaml from "js-yaml";
+import checkAndCopyConfig from "utils/config";
+
+export default async function handler(req, res) {
+  checkAndCopyConfig("services.yaml");
+
+  const servicesYaml = path.join(process.cwd(), "config", "services.yaml");
+  const fileContents = await fs.readFile(servicesYaml, "utf8");
+  const services = yaml.load(fileContents);
+
+  // map easy to write YAML objects into easy to consume JS arrays
+  const servicesArray = services.map((group) => {
+    return {
+      name: Object.keys(group)[0],
+      services: group[Object.keys(group)[0]].map((entries) => {
+        return {
+          name: Object.keys(entries)[0],
+          ...entries[Object.keys(entries)[0]],
+        };
+      }),
+    };
+  });
+
+  res.send(servicesArray);
+}

src/pages/api/widgets/index.js

@@ -0,0 +1,22 @@
+import { promises as fs } from "fs";
+import path from "path";
+import yaml from "js-yaml";
+import checkAndCopyConfig from "utils/config";
+
+export default async function handler(req, res) {
+  checkAndCopyConfig("widgets.yaml");
+
+  const widgetsYaml = path.join(process.cwd(), "config", "widgets.yaml");
+  const fileContents = await fs.readFile(widgetsYaml, "utf8");
+  const widgets = yaml.load(fileContents);
+
+  // map easy to write YAML objects into easy to consume JS arrays
+  const widgetsArray = widgets.map((group) => {
+    return {
+      type: Object.keys(group)[0],
+      options: { ...group[Object.keys(group)[0]] },
+    };
+  });
+
+  res.send(widgetsArray);
+}

src/pages/api/widgets/resources.js

@@ -0,0 +1,14 @@
+import { cpu, drive, mem, netstat } from "node-os-utils";
+
+export default async function handler(req, res) {
+  const { disk } = req.query;
+
+  res.send({
+    cpu: {
+      usage: await cpu.usage(),
+      load: cpu.loadavgTime(5),
+    },
+    drive: await drive.info(disk || "/"),
+    memory: await mem.info(),
+  });
+}

src/pages/api/widgets/weather.js

@@ -0,0 +1,9 @@
+import cachedFetch from "utils/cached-fetch";
+
+export default async function handler(req, res) {
+  const { lat, lon, apiKey, duration } = req.query;
+
+  const api_url = `http://api.weatherapi.com/v1/current.json?q=${lat},${lon}&key=${apiKey}`;
+
+  res.send(await cachedFetch(api_url, duration));
+}