2022-09-26 12:04:37 +03:00
|
|
|
/* eslint-disable no-console */
|
|
|
|
import { promises as fs } from "fs";
|
|
|
|
import path from "path";
|
|
|
|
|
|
|
|
import yaml from "js-yaml";
|
|
|
|
|
2022-10-11 20:26:07 -07:00
|
|
|
import checkAndCopyConfig from "utils/config/config";
|
2022-09-26 15:25:10 +03:00
|
|
|
import { servicesFromConfig, servicesFromDocker, cleanServiceGroups } from "utils/config/service-helpers";
|
2022-10-11 20:26:07 -07:00
|
|
|
import { cleanWidgetGroups, widgetsFromConfig } from "utils/config/widget-helpers";
|
2022-09-26 12:04:37 +03:00
|
|
|
|
|
|
|
export async function bookmarksResponse() {
|
|
|
|
checkAndCopyConfig("bookmarks.yaml");
|
|
|
|
|
|
|
|
const bookmarksYaml = path.join(process.cwd(), "config", "bookmarks.yaml");
|
|
|
|
const fileContents = await fs.readFile(bookmarksYaml, "utf8");
|
|
|
|
const bookmarks = yaml.load(fileContents);
|
|
|
|
|
2022-09-29 11:40:09 +03:00
|
|
|
if (!bookmarks) return [];
|
|
|
|
|
2022-09-26 12:04:37 +03:00
|
|
|
// map easy to write YAML objects into easy to consume JS arrays
|
|
|
|
const bookmarksArray = bookmarks.map((group) => ({
|
|
|
|
name: Object.keys(group)[0],
|
|
|
|
bookmarks: group[Object.keys(group)[0]].map((entries) => ({
|
|
|
|
name: Object.keys(entries)[0],
|
|
|
|
...entries[Object.keys(entries)[0]][0],
|
|
|
|
})),
|
|
|
|
}));
|
|
|
|
|
|
|
|
return bookmarksArray;
|
|
|
|
}
|
|
|
|
|
|
|
|
export async function widgetsResponse() {
|
2022-10-11 20:26:07 -07:00
|
|
|
let configuredWidgets;
|
2022-09-26 12:04:37 +03:00
|
|
|
|
2022-10-11 20:26:07 -07:00
|
|
|
try {
|
|
|
|
configuredWidgets = cleanWidgetGroups(await widgetsFromConfig());
|
|
|
|
} catch (e) {
|
|
|
|
console.error("Failed to load widgets, please check widgets.yaml for errors or remove example entries.");
|
|
|
|
if (e) console.error(e);
|
|
|
|
configuredWidgets = [];
|
|
|
|
}
|
2022-09-26 12:04:37 +03:00
|
|
|
|
2022-10-11 20:26:07 -07:00
|
|
|
return configuredWidgets;
|
2022-09-26 12:04:37 +03:00
|
|
|
}
|
|
|
|
|
|
|
|
export async function servicesResponse() {
|
|
|
|
let discoveredServices;
|
|
|
|
let configuredServices;
|
|
|
|
|
|
|
|
try {
|
|
|
|
discoveredServices = cleanServiceGroups(await servicesFromDocker());
|
|
|
|
} catch (e) {
|
|
|
|
console.error("Failed to discover services, please check docker.yaml for errors or remove example entries.");
|
2022-09-28 22:40:54 +03:00
|
|
|
if (e) console.error(e);
|
2022-09-26 12:04:37 +03:00
|
|
|
discoveredServices = [];
|
|
|
|
}
|
|
|
|
|
|
|
|
try {
|
|
|
|
configuredServices = cleanServiceGroups(await servicesFromConfig());
|
|
|
|
} catch (e) {
|
|
|
|
console.error("Failed to load services.yaml, please check for errors");
|
2022-09-28 22:40:54 +03:00
|
|
|
if (e) console.error(e);
|
2022-09-26 12:04:37 +03:00
|
|
|
configuredServices = [];
|
|
|
|
}
|
|
|
|
|
|
|
|
const mergedGroupsNames = [
|
|
|
|
...new Set([discoveredServices.map((group) => group.name), configuredServices.map((group) => group.name)].flat()),
|
|
|
|
];
|
|
|
|
|
|
|
|
const mergedGroups = [];
|
|
|
|
|
|
|
|
mergedGroupsNames.forEach((groupName) => {
|
|
|
|
const discoveredGroup = discoveredServices.find((group) => group.name === groupName) || { services: [] };
|
|
|
|
const configuredGroup = configuredServices.find((group) => group.name === groupName) || { services: [] };
|
|
|
|
|
|
|
|
const mergedGroup = {
|
|
|
|
name: groupName,
|
|
|
|
services: [...discoveredGroup.services, ...configuredGroup.services].filter((service) => service),
|
|
|
|
};
|
|
|
|
|
|
|
|
mergedGroups.push(mergedGroup);
|
|
|
|
});
|
|
|
|
|
|
|
|
return mergedGroups;
|
|
|
|
}
|