Add support for multiple widgets in widgets with custom proxies
This commit is contained in:
parent
b225d3850e
commit
43e8010375
@ -23,14 +23,14 @@ async function retrieveFromAPI(url, key) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default async function audiobookshelfProxyHandler(req, res) {
|
export default async function audiobookshelfProxyHandler(req, res) {
|
||||||
const { group, service, endpoint } = req.query;
|
const { group, service, endpoint, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
|
|||||||
@ -34,10 +34,10 @@ async function login(loginUrl, username, password, service) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default async function beszelProxyHandler(req, res) {
|
export default async function beszelProxyHandler(req, res) {
|
||||||
const { group, service, endpoint } = req.query;
|
const { group, service, endpoint, name } = req.query;
|
||||||
|
|
||||||
if (group && service) {
|
if (group && service) {
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (!widgets?.[widget.type]?.api) {
|
if (!widgets?.[widget.type]?.api) {
|
||||||
return res.status(403).json({ error: "Service does not support API calls" });
|
return res.status(403).json({ error: "Service does not support API calls" });
|
||||||
|
|||||||
@ -5,10 +5,10 @@ import createLogger from "utils/logger";
|
|||||||
const logger = createLogger("calendarProxyHandler");
|
const logger = createLogger("calendarProxyHandler");
|
||||||
|
|
||||||
export default async function calendarProxyHandler(req, res) {
|
export default async function calendarProxyHandler(req, res) {
|
||||||
const { group, service, endpoint } = req.query;
|
const { group, service, endpoint, name } = req.query;
|
||||||
|
|
||||||
if (group && service) {
|
if (group && service) {
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
const integration = widget.integrations?.find((i) => i.name === endpoint);
|
const integration = widget.integrations?.find((i) => i.name === endpoint);
|
||||||
|
|
||||||
if (integration) {
|
if (integration) {
|
||||||
|
|||||||
@ -35,14 +35,14 @@ async function login(widget, service) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default async function crowdsecProxyHandler(req, res) {
|
export default async function crowdsecProxyHandler(req, res) {
|
||||||
const { group, service, endpoint } = req.query;
|
const { group, service, endpoint, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.error("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.error("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
if (!widget || !widgets[widget.type].api) {
|
if (!widget || !widgets[widget.type].api) {
|
||||||
logger.error("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.error("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid widget configuration" });
|
return res.status(400).json({ error: "Invalid widget configuration" });
|
||||||
|
|||||||
@ -40,14 +40,14 @@ function login(url, password) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default async function delugeProxyHandler(req, res) {
|
export default async function delugeProxyHandler(req, res) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
|
|||||||
@ -28,14 +28,14 @@ async function login(widget) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default async function floodProxyHandler(req, res) {
|
export default async function floodProxyHandler(req, res) {
|
||||||
const { group, service, endpoint } = req.query;
|
const { group, service, endpoint, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
|
|||||||
@ -74,14 +74,14 @@ async function apiCall(widget, endpoint, service) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default async function freshrssProxyHandler(req, res) {
|
export default async function freshrssProxyHandler(req, res) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
|
|||||||
@ -46,8 +46,8 @@ async function requestEndpoint(apiBaseUrl, service, action) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default async function fritzboxProxyHandler(req, res) {
|
export default async function fritzboxProxyHandler(req, res) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
const serviceWidget = await getServiceWidget(group, service);
|
const serviceWidget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (!serviceWidget) {
|
if (!serviceWidget) {
|
||||||
res.status(500).json({ error: { message: "Service widget not found" } });
|
res.status(500).json({ error: { message: "Service widget not found" } });
|
||||||
|
|||||||
@ -7,8 +7,8 @@ const proxyName = "gamedigProxyHandler";
|
|||||||
const logger = createLogger(proxyName);
|
const logger = createLogger(proxyName);
|
||||||
|
|
||||||
export default async function gamedigProxyHandler(req, res) {
|
export default async function gamedigProxyHandler(req, res) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
const serviceWidget = await getServiceWidget(group, service);
|
const serviceWidget = await getServiceWidget(group, service, name ? name : null);
|
||||||
const url = new URL(serviceWidget.url);
|
const url = new URL(serviceWidget.url);
|
||||||
|
|
||||||
try {
|
try {
|
||||||
|
|||||||
@ -62,14 +62,14 @@ async function getQuery(query, { url, key }) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default async function homeassistantProxyHandler(req, res) {
|
export default async function homeassistantProxyHandler(req, res) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
|
|||||||
@ -68,14 +68,14 @@ async function apiCall(widget, endpoint, service) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default async function homeboxProxyHandler(req, res) {
|
export default async function homeboxProxyHandler(req, res) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
|
|||||||
@ -71,14 +71,14 @@ async function apiCall(widget, endpoint, service) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default async function homebridgeProxyHandler(req, res) {
|
export default async function homebridgeProxyHandler(req, res) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
|
|||||||
@ -25,14 +25,14 @@ async function fetchJackettCookie(widget, loginURL) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default async function jackettProxyHandler(req, res) {
|
export default async function jackettProxyHandler(req, res) {
|
||||||
const { group, service, endpoint } = req.query;
|
const { group, service, endpoint, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.error("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.error("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
if (!widget || !widgets[widget.type].api) {
|
if (!widget || !widgets[widget.type].api) {
|
||||||
logger.error("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.error("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid widget configuration" });
|
return res.status(400).json({ error: "Invalid widget configuration" });
|
||||||
|
|||||||
@ -12,12 +12,12 @@ const proxyName = "jdownloaderProxyHandler";
|
|||||||
const logger = createLogger(proxyName);
|
const logger = createLogger(proxyName);
|
||||||
|
|
||||||
async function getWidget(req) {
|
async function getWidget(req) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
return null;
|
return null;
|
||||||
|
|||||||
@ -70,14 +70,14 @@ async function apiCall(widget, endpoint, service) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default async function KavitaProxyHandler(req, res) {
|
export default async function KavitaProxyHandler(req, res) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
|
|||||||
@ -7,8 +7,8 @@ const proxyName = "minecraftProxyHandler";
|
|||||||
const logger = createLogger(proxyName);
|
const logger = createLogger(proxyName);
|
||||||
|
|
||||||
export default async function minecraftProxyHandler(req, res) {
|
export default async function minecraftProxyHandler(req, res) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
const serviceWidget = await getServiceWidget(group, service);
|
const serviceWidget = await getServiceWidget(group, service, name ? name : null);
|
||||||
const url = new URL(serviceWidget.url);
|
const url = new URL(serviceWidget.url);
|
||||||
try {
|
try {
|
||||||
const pingResponse = await pingWithPromise(url.hostname, url.port || 25565);
|
const pingResponse = await pingWithPromise(url.hostname, url.port || 25565);
|
||||||
|
|||||||
@ -36,10 +36,10 @@ async function login(loginUrl, username, password, service) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default async function npmProxyHandler(req, res) {
|
export default async function npmProxyHandler(req, res) {
|
||||||
const { group, service, endpoint } = req.query;
|
const { group, service, endpoint, name } = req.query;
|
||||||
|
|
||||||
if (group && service) {
|
if (group && service) {
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (!widgets?.[widget.type]?.api) {
|
if (!widgets?.[widget.type]?.api) {
|
||||||
return res.status(403).json({ error: "Service does not support API calls" });
|
return res.status(403).json({ error: "Service does not support API calls" });
|
||||||
|
|||||||
@ -33,10 +33,10 @@ async function login(loginUrl, username, password, controllerVersionMajor) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default async function omadaProxyHandler(req, res) {
|
export default async function omadaProxyHandler(req, res) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
|
|
||||||
if (group && service) {
|
if (group && service) {
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (widget) {
|
if (widget) {
|
||||||
const { url } = widget;
|
const { url } = widget;
|
||||||
|
|||||||
@ -12,14 +12,14 @@ const BG_POLL_PERIOD = 500;
|
|||||||
const logger = createLogger(PROXY_NAME);
|
const logger = createLogger(PROXY_NAME);
|
||||||
|
|
||||||
async function getWidget(req) {
|
async function getWidget(req) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
|
|||||||
@ -17,14 +17,14 @@ const PARAMS = {
|
|||||||
};
|
};
|
||||||
|
|
||||||
async function getWidget(req) {
|
async function getWidget(req) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
|
|||||||
@ -6,14 +6,14 @@ import createLogger from "utils/logger";
|
|||||||
const logger = createLogger("photoprismProxyHandler");
|
const logger = createLogger("photoprismProxyHandler");
|
||||||
|
|
||||||
export default async function photoprismProxyHandler(req, res) {
|
export default async function photoprismProxyHandler(req, res) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
|
|||||||
@ -33,7 +33,7 @@ async function login(widget, service) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default async function piholeProxyHandler(req, res) {
|
export default async function piholeProxyHandler(req, res) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
let endpoint = "stats/summary";
|
let endpoint = "stats/summary";
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
@ -41,7 +41,7 @@ export default async function piholeProxyHandler(req, res) {
|
|||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.error("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.error("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid widget configuration" });
|
return res.status(400).json({ error: "Invalid widget configuration" });
|
||||||
|
|||||||
@ -16,14 +16,14 @@ const tvCacheKey = `${proxyName}__tv`;
|
|||||||
const logger = createLogger(proxyName);
|
const logger = createLogger(proxyName);
|
||||||
|
|
||||||
async function getWidget(req) {
|
async function getWidget(req) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
|
|||||||
@ -67,11 +67,11 @@ async function login(loginUrl, service, username, password = "") {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default async function pyloadProxyHandler(req, res) {
|
export default async function pyloadProxyHandler(req, res) {
|
||||||
const { group, service, endpoint } = req.query;
|
const { group, service, endpoint, name } = req.query;
|
||||||
|
|
||||||
try {
|
try {
|
||||||
if (group && service) {
|
if (group && service) {
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (widget) {
|
if (widget) {
|
||||||
const url = new URL(formatApiCall(widgets[widget.type].api, { endpoint, ...widget }));
|
const url = new URL(formatApiCall(widgets[widget.type].api, { endpoint, ...widget }));
|
||||||
|
|||||||
@ -21,14 +21,14 @@ async function login(widget) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default async function qbittorrentProxyHandler(req, res) {
|
export default async function qbittorrentProxyHandler(req, res) {
|
||||||
const { group, service, endpoint } = req.query;
|
const { group, service, endpoint, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
|
|||||||
@ -77,14 +77,14 @@ async function apiCall(widget, endpoint, service) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default async function qnapProxyHandler(req, res) {
|
export default async function qnapProxyHandler(req, res) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
|
|||||||
@ -45,10 +45,10 @@ const getTorrentInfo = (data) => ({
|
|||||||
});
|
});
|
||||||
|
|
||||||
export default async function rutorrentProxyHandler(req, res) {
|
export default async function rutorrentProxyHandler(req, res) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
|
|
||||||
if (group && service) {
|
if (group && service) {
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (widget) {
|
if (widget) {
|
||||||
const api = widgets?.[widget.type]?.api;
|
const api = widgets?.[widget.type]?.api;
|
||||||
|
|||||||
@ -114,14 +114,14 @@ function extractCounts(responseJSON, fields) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default async function suwayomiProxyHandler(req, res) {
|
export default async function suwayomiProxyHandler(req, res) {
|
||||||
const { group, service, endpoint } = req.query;
|
const { group, service, endpoint, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
|
|||||||
@ -8,14 +8,14 @@ const proxyName = "tdarrProxyHandler";
|
|||||||
const logger = createLogger(proxyName);
|
const logger = createLogger(proxyName);
|
||||||
|
|
||||||
export default async function tdarrProxyHandler(req, res) {
|
export default async function tdarrProxyHandler(req, res) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
|
|||||||
@ -11,14 +11,14 @@ const headerCacheKey = `${proxyName}__headers`;
|
|||||||
const logger = createLogger(proxyName);
|
const logger = createLogger(proxyName);
|
||||||
|
|
||||||
export default async function transmissionProxyHandler(req, res) {
|
export default async function transmissionProxyHandler(req, res) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
|
|||||||
@ -14,7 +14,7 @@ const prefixCacheKey = `${proxyName}__prefix`;
|
|||||||
const logger = createLogger(proxyName);
|
const logger = createLogger(proxyName);
|
||||||
|
|
||||||
async function getWidget(req) {
|
async function getWidget(req) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
|
|
||||||
let widget = null;
|
let widget = null;
|
||||||
if (group === "unifi_console" && service === "unifi_console") {
|
if (group === "unifi_console" && service === "unifi_console") {
|
||||||
@ -32,7 +32,7 @@ async function getWidget(req) {
|
|||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
widget = await getServiceWidget(group, service);
|
widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
|
|||||||
@ -3,8 +3,8 @@ import { UrbackupServer } from "urbackup-server-api";
|
|||||||
import getServiceWidget from "utils/config/service-helpers";
|
import getServiceWidget from "utils/config/service-helpers";
|
||||||
|
|
||||||
export default async function urbackupProxyHandler(req, res) {
|
export default async function urbackupProxyHandler(req, res) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
const serviceWidget = await getServiceWidget(group, service);
|
const serviceWidget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
const server = new UrbackupServer({
|
const server = new UrbackupServer({
|
||||||
url: serviceWidget.url,
|
url: serviceWidget.url,
|
||||||
|
|||||||
@ -8,14 +8,14 @@ const proxyName = "watchtowerProxyHandler";
|
|||||||
const logger = createLogger(proxyName);
|
const logger = createLogger(proxyName);
|
||||||
|
|
||||||
export default async function watchtowerProxyHandler(req, res) {
|
export default async function watchtowerProxyHandler(req, res) {
|
||||||
const { group, service, endpoint } = req.query;
|
const { group, service, endpoint, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
logger.debug("Invalid or missing service '%s' or group '%s'", service, group);
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
|
|
||||||
if (!widget) {
|
if (!widget) {
|
||||||
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
|
||||||
|
|||||||
@ -7,13 +7,13 @@ import getServiceWidget from "utils/config/service-helpers";
|
|||||||
const logger = createLogger("xteveProxyHandler");
|
const logger = createLogger("xteveProxyHandler");
|
||||||
|
|
||||||
export default async function xteveProxyHandler(req, res) {
|
export default async function xteveProxyHandler(req, res) {
|
||||||
const { group, service } = req.query;
|
const { group, service, name } = req.query;
|
||||||
|
|
||||||
if (!group || !service) {
|
if (!group || !service) {
|
||||||
return res.status(400).json({ error: "Invalid proxy service type" });
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
||||||
}
|
}
|
||||||
|
|
||||||
const widget = await getServiceWidget(group, service);
|
const widget = await getServiceWidget(group, service, name ? name : null);
|
||||||
const api = widgets?.[widget.type]?.api;
|
const api = widgets?.[widget.type]?.api;
|
||||||
if (!api) {
|
if (!api) {
|
||||||
return res.status(403).json({ error: "Service does not support API calls" });
|
return res.status(403).json({ error: "Service does not support API calls" });
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user