You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
82 lines
2.8 KiB
82 lines
2.8 KiB
import { JSONRPCClient, JSONRPCErrorException } from "json-rpc-2.0";
|
|
|
|
import { formatApiCall } from "utils/proxy/api-helpers";
|
|
import { httpProxy } from "utils/proxy/http";
|
|
import getServiceWidget from "utils/config/service-helpers";
|
|
import createLogger from "utils/logger";
|
|
import widgets from "widgets/widgets";
|
|
|
|
const logger = createLogger("jsonrpcProxyHandler");
|
|
|
|
export async function sendJsonRpcRequest(url, method, params, username, password) {
|
|
const headers = {
|
|
"content-type": "application/json",
|
|
accept: "application/json",
|
|
};
|
|
|
|
if (username && password) {
|
|
headers.authorization = `Basic ${Buffer.from(`${username}:${password}`).toString("base64")}`;
|
|
}
|
|
|
|
const client = new JSONRPCClient(async (rpcRequest) => {
|
|
const body = JSON.stringify(rpcRequest);
|
|
const httpRequestParams = {
|
|
method: "POST",
|
|
headers,
|
|
body,
|
|
};
|
|
|
|
// eslint-disable-next-line no-unused-vars
|
|
const [status, contentType, data] = await httpProxy(url, httpRequestParams);
|
|
if (status === 200) {
|
|
const json = JSON.parse(data.toString());
|
|
|
|
// in order to get access to the underlying error object in the JSON response
|
|
// you must set `result` equal to undefined
|
|
if (json.error && json.result === null) {
|
|
json.result = undefined;
|
|
}
|
|
return client.receive(json);
|
|
}
|
|
|
|
return Promise.reject(data?.error ? data : new Error(data.toString()));
|
|
});
|
|
|
|
try {
|
|
const response = await client.request(method, params);
|
|
return [200, "application/json", JSON.stringify(response)];
|
|
} catch (e) {
|
|
if (e instanceof JSONRPCErrorException) {
|
|
logger.debug("Error calling JSONPRC endpoint: %s. %s", url, e.message);
|
|
return [200, "application/json", JSON.stringify({ result: null, error: { code: e.code, message: e.message } })];
|
|
}
|
|
|
|
logger.warn("Error calling JSONPRC endpoint: %s. %s", url, e);
|
|
return [500, "application/json", JSON.stringify({ result: null, error: { code: 2, message: e.toString() } })];
|
|
}
|
|
}
|
|
|
|
export default async function jsonrpcProxyHandler(req, res) {
|
|
const { group, service, endpoint: method } = req.query;
|
|
|
|
if (group && service) {
|
|
const widget = await getServiceWidget(group, service);
|
|
const api = widgets?.[widget.type]?.api;
|
|
|
|
if (!api) {
|
|
return res.status(403).json({ error: "Service does not support API calls" });
|
|
}
|
|
|
|
if (widget) {
|
|
const url = formatApiCall(api, { ...widget });
|
|
|
|
// eslint-disable-next-line no-unused-vars
|
|
const [status, contentType, data] = await sendJsonRpcRequest(url, method, null, widget.username, widget.password);
|
|
return res.status(status).end(data);
|
|
}
|
|
}
|
|
|
|
logger.debug("Invalid or missing proxy service type '%s' in group '%s'", service, group);
|
|
return res.status(400).json({ error: "Invalid proxy service type" });
|
|
}
|