2023-01-27 12:25:57 +02:00
|
|
|
const fs = require("fs");
|
|
|
|
const { log } = require("../src/util");
|
|
|
|
const path = require("path");
|
|
|
|
const axios = require("axios");
|
|
|
|
const { Git } = require("./git");
|
|
|
|
const childProcess = require("child_process");
|
|
|
|
|
|
|
|
class PluginsManager {
|
|
|
|
|
|
|
|
static disable = false;
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Plugin List
|
|
|
|
* @type {PluginWrapper[]}
|
|
|
|
*/
|
|
|
|
pluginList = [];
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Plugins Dir
|
|
|
|
*/
|
|
|
|
pluginsDir;
|
|
|
|
|
|
|
|
server;
|
|
|
|
|
|
|
|
/**
|
|
|
|
*
|
|
|
|
* @param {UptimeKumaServer} server
|
|
|
|
*/
|
|
|
|
constructor(server) {
|
|
|
|
this.server = server;
|
|
|
|
|
|
|
|
if (!PluginsManager.disable) {
|
|
|
|
this.pluginsDir = "./data/plugins/";
|
|
|
|
|
|
|
|
if (! fs.existsSync(this.pluginsDir)) {
|
|
|
|
fs.mkdirSync(this.pluginsDir, { recursive: true });
|
|
|
|
}
|
|
|
|
|
|
|
|
log.debug("plugin", "Scanning plugin directory");
|
|
|
|
let list = fs.readdirSync(this.pluginsDir);
|
|
|
|
|
|
|
|
this.pluginList = [];
|
|
|
|
for (let item of list) {
|
|
|
|
this.loadPlugin(item);
|
|
|
|
}
|
|
|
|
|
|
|
|
} else {
|
|
|
|
log.warn("PLUGIN", "Skip scanning plugin directory");
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Install a Plugin
|
|
|
|
*/
|
|
|
|
async loadPlugin(name) {
|
|
|
|
log.info("plugin", "Load " + name);
|
|
|
|
let plugin = new PluginWrapper(this.server, this.pluginsDir + name);
|
|
|
|
|
|
|
|
try {
|
|
|
|
await plugin.load();
|
|
|
|
this.pluginList.push(plugin);
|
|
|
|
} catch (e) {
|
|
|
|
log.error("plugin", "Failed to load plugin: " + this.pluginsDir + name);
|
|
|
|
log.error("plugin", "Reason: " + e.message);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Download a Plugin
|
|
|
|
* @param {string} repoURL Git repo url
|
|
|
|
* @param {string} name Directory name, also known as plugin unique name
|
|
|
|
*/
|
|
|
|
downloadPlugin(repoURL, name) {
|
2023-01-28 13:00:13 +02:00
|
|
|
if (fs.existsSync(this.pluginsDir + name)) {
|
|
|
|
log.info("plugin", "Plugin folder already exists? Removing...");
|
|
|
|
fs.rmSync(this.pluginsDir + name, {
|
|
|
|
recursive: true
|
|
|
|
});
|
|
|
|
}
|
2023-01-27 12:25:57 +02:00
|
|
|
log.info("plugin", "Installing plugin: " + name + " " + repoURL);
|
|
|
|
let result = Git.clone(repoURL, this.pluginsDir, name);
|
|
|
|
log.info("plugin", "Install result: " + result);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Remove a plugin
|
|
|
|
* @param {string} name
|
|
|
|
*/
|
|
|
|
async removePlugin(name) {
|
|
|
|
log.info("plugin", "Removing plugin: " + name);
|
|
|
|
for (let plugin of this.pluginList) {
|
|
|
|
if (plugin.info.name === name) {
|
|
|
|
await plugin.unload();
|
|
|
|
|
|
|
|
// Delete the plugin directory
|
|
|
|
fs.rmSync(this.pluginsDir + name, {
|
|
|
|
recursive: true
|
|
|
|
});
|
|
|
|
|
|
|
|
this.pluginList.splice(this.pluginList.indexOf(plugin), 1);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
log.warn("plugin", "Plugin not found: " + name);
|
|
|
|
throw new Error("Plugin not found: " + name);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* TODO: Update a plugin
|
|
|
|
* Only available for plugins which were downloaded from the official list
|
|
|
|
* @param pluginID
|
|
|
|
*/
|
|
|
|
updatePlugin(pluginID) {
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Get the plugin list from server + local installed plugin list
|
|
|
|
* Item will be merged if the `name` is the same.
|
|
|
|
* @returns {Promise<[]>}
|
|
|
|
*/
|
|
|
|
async fetchPluginList() {
|
2023-01-28 13:00:13 +02:00
|
|
|
let remotePluginList;
|
|
|
|
try {
|
|
|
|
const res = await axios.get("https://uptime.kuma.pet/c/plugins.json");
|
|
|
|
remotePluginList = res.data.pluginList;
|
|
|
|
} catch (e) {
|
|
|
|
log.error("plugin", "Failed to fetch plugin list: " + e.message);
|
|
|
|
remotePluginList = [];
|
|
|
|
}
|
2023-01-27 12:25:57 +02:00
|
|
|
|
|
|
|
for (let plugin of this.pluginList) {
|
|
|
|
let find = false;
|
|
|
|
// Try to merge
|
2023-01-28 13:00:13 +02:00
|
|
|
for (let remotePlugin of remotePluginList) {
|
2023-01-27 12:25:57 +02:00
|
|
|
if (remotePlugin.name === plugin.info.name) {
|
|
|
|
find = true;
|
|
|
|
remotePlugin.installed = true;
|
|
|
|
remotePlugin.name = plugin.info.name;
|
|
|
|
remotePlugin.fullName = plugin.info.fullName;
|
|
|
|
remotePlugin.description = plugin.info.description;
|
|
|
|
remotePlugin.version = plugin.info.version;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// Local plugin
|
|
|
|
if (!find) {
|
|
|
|
plugin.info.local = true;
|
2023-01-28 13:00:13 +02:00
|
|
|
remotePluginList.push(plugin.info);
|
2023-01-27 12:25:57 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// Sort Installed first, then sort by name
|
2023-01-28 13:00:13 +02:00
|
|
|
return remotePluginList.sort((a, b) => {
|
2023-01-27 12:25:57 +02:00
|
|
|
if (a.installed === b.installed) {
|
2023-01-28 13:00:13 +02:00
|
|
|
if (a.fullName < b.fullName) {
|
2023-01-27 12:25:57 +02:00
|
|
|
return -1;
|
|
|
|
}
|
2023-01-28 13:00:13 +02:00
|
|
|
if (a.fullName > b.fullName) {
|
2023-01-27 12:25:57 +02:00
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
return 0;
|
|
|
|
} else if (a.installed) {
|
|
|
|
return -1;
|
|
|
|
} else {
|
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
class PluginWrapper {
|
|
|
|
|
|
|
|
server = undefined;
|
|
|
|
pluginDir = undefined;
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Must be an `new-able` class.
|
|
|
|
* @type {function}
|
|
|
|
*/
|
|
|
|
pluginClass = undefined;
|
|
|
|
|
|
|
|
/**
|
|
|
|
*
|
|
|
|
* @type {Plugin}
|
|
|
|
*/
|
|
|
|
object = undefined;
|
|
|
|
info = {};
|
|
|
|
|
|
|
|
/**
|
|
|
|
*
|
|
|
|
* @param {UptimeKumaServer} server
|
|
|
|
* @param {string} pluginDir
|
|
|
|
*/
|
|
|
|
constructor(server, pluginDir) {
|
|
|
|
this.server = server;
|
|
|
|
this.pluginDir = pluginDir;
|
|
|
|
}
|
|
|
|
|
|
|
|
async load() {
|
|
|
|
let indexFile = this.pluginDir + "/index.js";
|
|
|
|
let packageJSON = this.pluginDir + "/package.json";
|
|
|
|
|
2023-01-28 13:00:13 +02:00
|
|
|
log.info("plugin", "Installing dependencies");
|
|
|
|
|
2023-01-27 12:25:57 +02:00
|
|
|
if (fs.existsSync(indexFile)) {
|
|
|
|
// Install dependencies
|
2023-01-28 13:00:13 +02:00
|
|
|
let result = childProcess.spawnSync("npm", [ "install" ], {
|
2023-01-27 12:25:57 +02:00
|
|
|
cwd: this.pluginDir,
|
|
|
|
env: {
|
2023-01-28 13:00:13 +02:00
|
|
|
...process.env,
|
2023-01-27 12:25:57 +02:00
|
|
|
PLAYWRIGHT_BROWSERS_PATH: "../../browsers", // Special handling for read-browser-monitor
|
|
|
|
}
|
|
|
|
});
|
|
|
|
|
2023-01-28 13:00:13 +02:00
|
|
|
if (result.stdout) {
|
|
|
|
log.info("plugin", "Install dependencies result: " + result.stdout.toString("utf-8"));
|
|
|
|
} else {
|
|
|
|
log.warn("plugin", "Install dependencies result: no output");
|
|
|
|
}
|
|
|
|
|
2023-01-27 12:25:57 +02:00
|
|
|
this.pluginClass = require(path.join(process.cwd(), indexFile));
|
|
|
|
|
|
|
|
let pluginClassType = typeof this.pluginClass;
|
|
|
|
|
|
|
|
if (pluginClassType === "function") {
|
|
|
|
this.object = new this.pluginClass(this.server);
|
|
|
|
await this.object.load();
|
|
|
|
} else {
|
|
|
|
throw new Error("Invalid plugin, it does not export a class");
|
|
|
|
}
|
|
|
|
|
|
|
|
if (fs.existsSync(packageJSON)) {
|
|
|
|
this.info = require(path.join(process.cwd(), packageJSON));
|
|
|
|
} else {
|
|
|
|
this.info.fullName = this.pluginDir;
|
|
|
|
this.info.name = "[unknown]";
|
|
|
|
this.info.version = "[unknown-version]";
|
|
|
|
}
|
|
|
|
|
|
|
|
this.info.installed = true;
|
|
|
|
log.info("plugin", `${this.info.fullName} v${this.info.version} loaded`);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
async unload() {
|
|
|
|
await this.object.unload();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
module.exports = {
|
|
|
|
PluginsManager,
|
|
|
|
PluginWrapper
|
|
|
|
};
|