feat: add FreshRSS widget

This commit is contained in:
Heng-Yi Wu 2023-04-18 22:33:04 +08:00
parent 9f91cd27f3
commit 0fc662ba4d
No known key found for this signature in database
GPG Key ID: 3A63404431B91B99
6 changed files with 86 additions and 5 deletions

View File

@ -98,6 +98,10 @@
"leech": "Leech", "leech": "Leech",
"seed": "Seed" "seed": "Seed"
}, },
"freshrss": {
"subscriptions": "Subscriptions",
"unread": "Unread"
},
"changedetectionio": { "changedetectionio": {
"totalObserved": "Total Observed", "totalObserved": "Total Observed",
"diffsDetected": "Diffs Detected" "diffsDetected": "Diffs Detected"

View File

@ -34,9 +34,8 @@ export default async function credentialedProxyHandler(req, res, map) {
"ghostfolio", "ghostfolio",
"truenas", "truenas",
"pterodactyl", "pterodactyl",
].includes(widget.type)) ].includes(widget.type)) {
{ headers.Authorization = `Bearer ${widget.key}`;
headers.Authorization = `Bearer ${widget.key}`;
} else if (widget.type === "proxmox") { } else if (widget.type === "proxmox") {
headers.Authorization = `PVEAPIToken=${widget.username}=${widget.password}`; headers.Authorization = `PVEAPIToken=${widget.username}=${widget.password}`;
} else if (widget.type === "proxmoxbackupserver") { } else if (widget.type === "proxmoxbackupserver") {
@ -54,6 +53,20 @@ export default async function credentialedProxyHandler(req, res, map) {
} else { } else {
headers.Authorization = `Basic ${Buffer.from(`${widget.username}:${widget.password}`).toString("base64")}`; headers.Authorization = `Basic ${Buffer.from(`${widget.username}:${widget.password}`).toString("base64")}`;
} }
} else if (widget.type === "freshrss") {
const resp = await fetch(`${widget.url}/api/greader.php/accounts/ClientLogin`, {
method: "POST",
headers: {
"Content-Type": "application/x-www-form-urlencoded"
},
body: new URLSearchParams({
Email: widget.username,
Passwd: widget.password,
})
})
const text = await resp.text()
const [, token] = text.split('\n').find(line => line.startsWith('Auth=')).split('=')
headers.Authorization = `GoogleLogin auth=${token}`
} else { } else {
headers["X-API-Key"] = `${widget.key}`; headers["X-API-Key"] = `${widget.key}`;
} }
@ -78,10 +91,10 @@ export default async function credentialedProxyHandler(req, res, map) {
if (status >= 400) { if (status >= 400) {
logger.error("HTTP Error %d calling %s", status, url.toString()); logger.error("HTTP Error %d calling %s", status, url.toString());
} }
if (status === 200) { if (status === 200) {
if (!validateWidgetData(widget, endpoint, resultData)) { if (!validateWidgetData(widget, endpoint, resultData)) {
return res.status(500).json({error: {message: "Invalid data", url: sanitizeErrorURL(url), data: resultData}}); return res.status(500).json({ error: { message: "Invalid data", url: sanitizeErrorURL(url), data: resultData } });
} }
if (map) resultData = map(resultData); if (map) resultData = map(resultData);
} }

View File

@ -17,6 +17,7 @@ const components = {
emby: dynamic(() => import("./emby/component")), emby: dynamic(() => import("./emby/component")),
fileflows: dynamic(() => import("./fileflows/component")), fileflows: dynamic(() => import("./fileflows/component")),
flood: dynamic(() => import("./flood/component")), flood: dynamic(() => import("./flood/component")),
freshrss: dynamic(() => import("./freshrss/component")),
ghostfolio: dynamic(() => import("./ghostfolio/component")), ghostfolio: dynamic(() => import("./ghostfolio/component")),
gluetun: dynamic(() => import("./gluetun/component")), gluetun: dynamic(() => import("./gluetun/component")),
gotify: dynamic(() => import("./gotify/component")), gotify: dynamic(() => import("./gotify/component")),

View File

@ -0,0 +1,37 @@
import { useTranslation } from "next-i18next";
import Container from "components/services/widget/container";
import Block from "components/services/widget/block";
import useWidgetAPI from "utils/proxy/use-widget-api";
export default function Component({ service }) {
const { t } = useTranslation();
const { widget } = service;
const { data: subscriptionsData, error: subscriptionsError } = useWidgetAPI(widget, "subscriptions");
const { data: unreadData, error: unreadError } = useWidgetAPI(widget, "unread");
if (subscriptionsError) {
return <Container error={subscriptionsError} />;
}
if (unreadError) {
return <Container error={unreadError} />;
}
if (!subscriptionsData || !unreadData) {
return (
<Container service={service}>
<Block label="freshrss.unread" />
<Block label="freshrss.subscriptions" />
</Container>
);
}
return (
<Container service={service}>
<Block label="freshrss.unread" value={t("common.number", { value: unreadData.count })} />
<Block label="freshrss.subscriptions" value={t("common.number", { value: subscriptionsData.count })} />
</Container>
);
}

View File

@ -0,0 +1,24 @@
import { asJson } from "utils/proxy/api-helpers";
import credentialedProxyHandler from "utils/proxy/handlers/credentialed";
const widget = {
api: "{url}/api/greader.php/{endpoint}?output=json",
proxyHandler: credentialedProxyHandler,
mappings: {
subscriptions: {
endpoint: "reader/api/0/subscription/list",
map: (data) => ({
count: asJson(data).subscriptions.length
}),
},
unread: {
endpoint: "reader/api/0/unread-count",
map: (data) => ({
count: asJson(data).max
}),
}
}
};
export default widget;

View File

@ -12,6 +12,7 @@ import downloadstation from "./downloadstation/widget";
import emby from "./emby/widget"; import emby from "./emby/widget";
import fileflows from "./fileflows/widget"; import fileflows from "./fileflows/widget";
import flood from "./flood/widget"; import flood from "./flood/widget";
import freshrss from "./freshrss/widget";
import ghostfolio from "./ghostfolio/widget" import ghostfolio from "./ghostfolio/widget"
import gluetun from "./gluetun/widget"; import gluetun from "./gluetun/widget";
import gotify from "./gotify/widget"; import gotify from "./gotify/widget";
@ -90,6 +91,7 @@ const widgets = {
emby, emby,
fileflows, fileflows,
flood, flood,
freshrss,
ghostfolio, ghostfolio,
gluetun, gluetun,
gotify, gotify,