3 Commits
Author SHA1 Message Date
valknar e14fbc9205 feat: streamline traefik widget with icon/status dot, fix grid gap
CI / Static checks (push) Successful in 36s
CI / Build and push image (push) Successful in 1m9s
Traefik's widget was the only card without a BrandIcon or StatusDot in
its header, and had no href either - added icon/href fields to the
schema and matched the exact docker/service widget header markup.
StatusDot reuses the same "running once data loaded" convention the
other widgets already use for a non-container up/down signal.

System's widget was span=5 while every other widget in this app is
span=4 (docker/service/traefik) or 3 (http) - on a 12-column grid that
left a permanent 3-column gap next to it every row. Matched it to
span=4 so system+traefik+one more widget tile a full row exactly.
Also added grid-auto-flow: dense as a general safety net against
future span-mismatch gaps.
2026-08-17 21:23:01 +02:00
valknar 813cad613e feat: simplify traefik widget to a route count, add coolify resource count
CI / Static checks (push) Successful in 36s
CI / Build and push image (push) Successful in 1m6s
Traefik's widget listed every router with rule/TLS/status detail,
which reads as noise now that other widgets in the dashboard show a
single headline stat - collapse it to a route count (with an
"enabled" secondary stat when some routers aren't) plus the existing
middlewares count as a small footer line, same visual language as the
new service widgets.

Coolify's widget only reported project count; /api/v1/resources gives
the deployed-resource count (apps/services/databases across all
projects), which is the more useful "how much is actually running"
number, so it's added as a second stat alongside Projects.
2026-08-17 21:11:56 +02:00
valknar ffb70ecddf feat: add combined docker+API service widgets for gitea/coolify/immich/n8n/umami/headscale
CI / Static checks (push) Successful in 35s
CI / Build and push image (push) Successful in 1m12s
One new `service` widget type (nested discriminated union on `service`)
rather than six, so a single config entry shows both docker container
health and a service-specific stat (repo count, project list, photo
count, workflow count, active users, users/nodes) - avoiding the
overhead of configuring a docker widget and a separate service widget
per container. All six collectors hit the service's container name +
internal port directly on falcon_network, the same container-to-
container pattern just proven out for Traefik's own API, avoiding
vpn-only/hairpin-NAT entirely.

Also adds the public/private config split that was scoped in the
original project plan but never built: lib/config/public.ts strips
apiToken/apiKey/password fields before the config reaches the browser
via SSR or the WS config topic - required before any widget could
carry a real secret. Verified via a throwaway secret field that it's
absent from both the SSR HTML and the WS config:update frame.

Endpoint shapes verified live against the running gitea/coolify/immich/
n8n/umami/headscale containers before committing (unauthenticated
requests correctly 401/200 on every target route; gitea's
X-Total-Count header confirmed present).
2026-08-17 20:45:29 +02:00
21 changed files with 507 additions and 33 deletions
+1
View File
@@ -144,6 +144,7 @@ body {
.pn-bento { .pn-bento {
display: grid; display: grid;
grid-template-columns: repeat(12, 1fr); grid-template-columns: repeat(12, 1fr);
grid-auto-flow: dense;
} }
@media (max-width: 860px) { @media (max-width: 860px) {
+2 -1
View File
@@ -1,5 +1,6 @@
import { ConfigError } from "@/lib/config/loader"; import { ConfigError } from "@/lib/config/loader";
import { effectiveConfigStore } from "@/lib/config/effective"; import { effectiveConfigStore } from "@/lib/config/effective";
import { toPublicConfig } from "@/lib/config/public";
import { Dashboard } from "@/components/layout/Dashboard"; import { Dashboard } from "@/components/layout/Dashboard";
export const dynamic = "force-dynamic"; export const dynamic = "force-dynamic";
@@ -20,5 +21,5 @@ export default function Home() {
); );
} }
return <Dashboard config={config} />; return <Dashboard config={toPublicConfig(config)} />;
} }
+2
View File
@@ -7,6 +7,7 @@ import { DatabaseWidget } from "./database/Widget";
import { SystemWidget } from "./system/Widget"; import { SystemWidget } from "./system/Widget";
import { HttpWidget } from "./http/Widget"; import { HttpWidget } from "./http/Widget";
import { TraefikWidget } from "./traefik/Widget"; import { TraefikWidget } from "./traefik/Widget";
import { ServiceWidget } from "./service/Widget";
type WidgetComponent<T extends Widget["type"]> = ComponentType<{ type WidgetComponent<T extends Widget["type"]> = ComponentType<{
widget: Extract<Widget, { type: T }>; widget: Extract<Widget, { type: T }>;
@@ -21,4 +22,5 @@ export const widgetRegistry: { [K in Widget["type"]]: WidgetComponent<K> } = {
system: SystemWidget, system: SystemWidget,
http: HttpWidget, http: HttpWidget,
traefik: TraefikWidget, traefik: TraefikWidget,
service: ServiceWidget,
}; };
+90
View File
@@ -0,0 +1,90 @@
"use client";
import type { Widget } from "@/lib/config/schema";
import { useWidgetSubscription } from "@/lib/ws/client";
import { StatusDot } from "@/components/widgets/StatusDot";
import { StatusTag } from "@/components/widgets/StatusTag";
import { SkeletonLines } from "@/components/widgets/Skeleton";
import { WidgetCard } from "@/components/widgets/WidgetCard";
import { MetricBar } from "@/components/widgets/MetricBar";
import { BrandIcon } from "@/components/widgets/BrandIcon";
import { formatBytes, formatUptime } from "@/lib/format";
type ServiceWidget = Extract<Widget, { type: "service" }>;
export function ServiceWidget({ widget, widgetId }: { widget: ServiceWidget; widgetId: string }) {
const result = useWidgetSubscription(widgetId);
const data = result?.type === "service" ? result.data : null;
const errorMessage = result?.type === "error" ? result.message : null;
const memPercent =
data?.docker.memUsageBytes != null && data.docker.memLimitBytes
? (data.docker.memUsageBytes / data.docker.memLimitBytes) * 100
: null;
return (
<WidgetCard span={4}>
<div className="flex items-center justify-between gap-2">
<div className="flex min-w-0 items-center gap-2">
<BrandIcon slug={widget.icon} />
{widget.href ? (
<a
href={widget.href}
target="_blank"
rel="noreferrer"
className="truncate text-[15px] font-medium text-fg hover:text-accent"
>
{widget.name}
</a>
) : (
<span className="truncate text-[15px] font-medium text-fg">{widget.name}</span>
)}
</div>
<StatusDot status={data?.docker.status} health={data?.docker.health} />
</div>
{errorMessage && <span className="text-xs text-status-down">{errorMessage}</span>}
{!result && !errorMessage && <SkeletonLines count={3} />}
{data && (
<>
{data.stats.length > 0 && (
<div className="flex items-start gap-4">
{data.stats.map((stat, index) => (
<div
key={stat.label}
className={`flex flex-col gap-0.5 ${index > 0 ? "border-l border-border pl-4" : ""}`}
>
<span className="font-mono text-2xl leading-none font-semibold tabular-nums text-accent">
{stat.value}
</span>
<span className="text-[10px] tracking-wide text-fg-muted uppercase">{stat.label}</span>
</div>
))}
</div>
)}
{data.detail && data.detail.length > 0 && (
<div className="flex flex-wrap gap-1.5">
{data.detail.map((entry) => (
<StatusTag key={entry} tone="neutral">
{entry}
</StatusTag>
))}
</div>
)}
{data.statError && <StatusTag tone="degraded">{data.statError}</StatusTag>}
{widget.showStats && data.docker.cpuPercent !== null && memPercent !== null && (
<div className="mt-0.5 flex gap-4">
<MetricBar label="CPU" percent={data.docker.cpuPercent} detail={`${data.docker.cpuPercent.toFixed(1)}%`} />
<MetricBar label="MEM" percent={memPercent} detail={`${memPercent.toFixed(0)}%`} />
</div>
)}
<div className="flex items-center gap-3 text-[11px] text-fg-muted">
{data.docker.uptimeSeconds !== null && <span>up {formatUptime(data.docker.uptimeSeconds)}</span>}
{widget.showStats && data.docker.memUsageBytes !== null && memPercent === null && (
<span className="font-mono tabular-nums">{formatBytes(data.docker.memUsageBytes)}</span>
)}
{data.docker.restartCount > 0 && <span>{data.docker.restartCount} restarts</span>}
</div>
</>
)}
</WidgetCard>
);
}
+1 -1
View File
@@ -19,7 +19,7 @@ export function SystemWidget({ widget, widgetId }: { widget: SystemWidget; widge
const errorMessage = result?.type === "error" ? result.message : null; const errorMessage = result?.type === "error" ? result.message : null;
return ( return (
<WidgetCard span={5} rowSpan={2}> <WidgetCard span={4} rowSpan={2}>
<div className="text-[10px] tracking-[0.1em] text-accent uppercase">System</div> <div className="text-[10px] tracking-[0.1em] text-accent uppercase">System</div>
<span className="text-[15px] font-medium text-fg">{widget.name}</span> <span className="text-[15px] font-medium text-fg">{widget.name}</span>
{errorMessage && <span className="text-xs text-status-down">{errorMessage}</span>} {errorMessage && <span className="text-xs text-status-down">{errorMessage}</span>}
+40 -21
View File
@@ -1,10 +1,11 @@
"use client"; "use client";
import { Lock } from "@phosphor-icons/react/ssr";
import type { Widget } from "@/lib/config/schema"; import type { Widget } from "@/lib/config/schema";
import { useWidgetSubscription } from "@/lib/ws/client"; import { useWidgetSubscription } from "@/lib/ws/client";
import { SkeletonLines } from "@/components/widgets/Skeleton"; import { SkeletonLines } from "@/components/widgets/Skeleton";
import { WidgetCard } from "@/components/widgets/WidgetCard"; import { WidgetCard } from "@/components/widgets/WidgetCard";
import { StatusDot } from "@/components/widgets/StatusDot";
import { BrandIcon } from "@/components/widgets/BrandIcon";
type TraefikWidget = Extract<Widget, { type: "traefik" }>; type TraefikWidget = Extract<Widget, { type: "traefik" }>;
@@ -12,41 +13,59 @@ export function TraefikWidget({ widget, widgetId }: { widget: TraefikWidget; wid
const result = useWidgetSubscription(widgetId); const result = useWidgetSubscription(widgetId);
const data = result?.type === "traefik" ? result.data : null; const data = result?.type === "traefik" ? result.data : null;
const errorMessage = result?.type === "error" ? result.message : null; const errorMessage = result?.type === "error" ? result.message : null;
const enabledCount = data?.routers.filter((router) => router.status === "enabled").length ?? 0;
return ( return (
<WidgetCard span={4}> <WidgetCard span={4}>
<div className="flex items-center justify-between"> <div className="flex items-center justify-between gap-2">
<span className="text-[15px] font-medium text-fg">{widget.name}</span> <div className="flex min-w-0 items-center gap-2">
<BrandIcon slug={widget.icon} />
{widget.href ? (
<a
href={widget.href}
target="_blank"
rel="noreferrer"
className="truncate text-[15px] font-medium text-fg hover:text-accent"
>
{widget.name}
</a>
) : (
<span className="truncate text-[15px] font-medium text-fg">{widget.name}</span>
)}
</div>
<div className="flex items-center gap-2">
{data && ( {data && (
<span className="font-mono text-[11px] tabular-nums text-fg-muted"> <span className="font-mono text-[11px] tabular-nums text-fg-muted">
{data.entrypoints.map((ep) => ep.address).join(" · ") || `${data.entrypoints.length} entrypoints`} {data.entrypoints.length} entrypoints
</span> </span>
)} )}
<StatusDot status={data ? "running" : undefined} />
</div>
</div> </div>
{errorMessage && <span className="text-xs text-status-down">{errorMessage}</span>} {errorMessage && <span className="text-xs text-status-down">{errorMessage}</span>}
{!result && !errorMessage && <SkeletonLines count={3} />} {!result && !errorMessage && <SkeletonLines count={3} />}
{data && ( {data && (
<div className="flex flex-col"> <>
{data.routers.map((router) => ( <div className="flex items-start gap-4">
<div key={router.name} className="flex items-center justify-between gap-2 border-t border-border py-1.5 text-[13px] first:border-t-0"> <div className="flex flex-col gap-0.5">
<span className="truncate text-fg" title={router.rule}> <span className="font-mono text-2xl leading-none font-semibold tabular-nums text-accent">
{router.name.replace(/@.*$/, "")} {data.routers.length}
</span>
<span className="flex items-center gap-1.5 text-[11px] text-fg-muted">
{router.tls && <Lock size={11} aria-label="TLS enabled" />}
<span
className={`flex items-center gap-1.5 ${router.status === "enabled" ? "text-status-up" : "text-status-down"}`}
>
<span className="h-1.5 w-1.5 rounded-full bg-current" />
{router.status}
</span>
</span> </span>
<span className="text-[10px] tracking-wide text-fg-muted uppercase">Routes</span>
</div> </div>
))} {enabledCount !== data.routers.length && (
<span className="pt-2 text-[11px] text-fg-muted"> <div className="flex flex-col gap-0.5 border-l border-border pl-4">
<span className="font-mono text-2xl leading-none font-semibold tabular-nums text-status-degraded">
{enabledCount}
</span>
<span className="text-[10px] tracking-wide text-fg-muted uppercase">Enabled</span>
</div>
)}
</div>
<span className="text-[11px] text-fg-muted">
<span className="font-mono tabular-nums">{data.middlewaresCount}</span> middlewares <span className="font-mono tabular-nums">{data.middlewaresCount}</span> middlewares
</span> </span>
</div> </>
)} )}
</WidgetCard> </WidgetCard>
); );
+3
View File
@@ -1,11 +1,14 @@
import Docker from "dockerode"; import Docker from "dockerode";
import type { ContainerStats } from "dockerode"; import type { ContainerStats } from "dockerode";
import pLimit from "p-limit";
import type { DockerContainerResult } from "@/lib/types/widget-result"; import type { DockerContainerResult } from "@/lib/types/widget-result";
const docker = new Docker({ const docker = new Docker({
socketPath: process.env.DOCKER_SOCKET_PATH ?? "/var/run/docker.sock", socketPath: process.env.DOCKER_SOCKET_PATH ?? "/var/run/docker.sock",
}); });
export const dockerLimit = pLimit(4);
function calcCpuPercent(stats: ContainerStats): number | null { function calcCpuPercent(stats: ContainerStats): number | null {
const cpuDelta = stats.cpu_stats.cpu_usage.total_usage - stats.precpu_stats.cpu_usage.total_usage; const cpuDelta = stats.cpu_stats.cpu_usage.total_usage - stats.precpu_stats.cpu_usage.total_usage;
const systemDelta = stats.cpu_stats.system_cpu_usage - stats.precpu_stats.system_cpu_usage; const systemDelta = stats.cpu_stats.system_cpu_usage - stats.precpu_stats.system_cpu_usage;
+19 -4
View File
@@ -2,13 +2,13 @@ import pLimit from "p-limit";
import type { Config, Widget } from "@/lib/config/schema"; import type { Config, Widget } from "@/lib/config/schema";
import { flattenWidgets } from "@/lib/config/widgets"; import { flattenWidgets } from "@/lib/config/widgets";
import { parseDuration } from "@/lib/config/duration"; import { parseDuration } from "@/lib/config/duration";
import { collectDockerContainer } from "./docker"; import { collectDockerContainer, dockerLimit } from "./docker";
import { collectSystem } from "./system"; import { collectSystem } from "./system";
import { collectHttp } from "./http"; import { collectHttp } from "./http";
import { collectTraefik } from "./traefik"; import { collectTraefik } from "./traefik";
import { collectService } from "./service";
import type { WidgetResult } from "@/lib/types/widget-result"; import type { WidgetResult } from "@/lib/types/widget-result";
const dockerLimit = pLimit(4);
const httpLimit = pLimit(8); const httpLimit = pLimit(8);
type ResultListener = (widgetId: string, result: WidgetResult) => void; type ResultListener = (widgetId: string, result: WidgetResult) => void;
@@ -20,7 +20,14 @@ interface Job {
consecutiveFailures: number; consecutiveFailures: number;
} }
const COLLECTOR_TYPES = new Set<Widget["type"]>(["docker", "database", "system", "http", "traefik"]); const COLLECTOR_TYPES = new Set<Widget["type"]>([
"docker",
"database",
"system",
"http",
"traefik",
"service",
]);
function isCollectorWidget(widget: Widget): boolean { function isCollectorWidget(widget: Widget): boolean {
return COLLECTOR_TYPES.has(widget.type); return COLLECTOR_TYPES.has(widget.type);
@@ -32,7 +39,8 @@ function getIntervalMs(widget: Widget): number {
widget.type === "database" || widget.type === "database" ||
widget.type === "system" || widget.type === "system" ||
widget.type === "http" || widget.type === "http" ||
widget.type === "traefik" widget.type === "traefik" ||
widget.type === "service"
) { ) {
return parseDuration(widget.interval); return parseDuration(widget.interval);
} }
@@ -55,6 +63,9 @@ function sameTarget(a: Widget, b: Widget): boolean {
if (a.type === "traefik" && b.type === "traefik") { if (a.type === "traefik" && b.type === "traefik") {
return a.apiUrl === b.apiUrl; return a.apiUrl === b.apiUrl;
} }
if (a.type === "service" && b.type === "service") {
return a.containerName === b.containerName && a.service === b.service && a.showStats === b.showStats;
}
return false; return false;
} }
@@ -81,6 +92,10 @@ async function collect(widget: Widget): Promise<WidgetResult> {
const data = await collectTraefik(widget.apiUrl); const data = await collectTraefik(widget.apiUrl);
return { type: "traefik", data }; return { type: "traefik", data };
} }
if (widget.type === "service") {
const data = await collectService(widget);
return { type: "service", data };
}
throw new Error(`No collector for widget type "${widget.type}"`); throw new Error(`No collector for widget type "${widget.type}"`);
} }
+41
View File
@@ -0,0 +1,41 @@
import type { ServiceWidget } from "@/lib/config/schema";
import type { ServiceStat, ServiceWidgetResult } from "@/lib/types/service-result";
import { collectDockerContainer, dockerLimit } from "./docker";
import { collectGitea } from "./services/gitea";
import { collectCoolify } from "./services/coolify";
import { collectImmich } from "./services/immich";
import { collectN8n } from "./services/n8n";
import { collectUmami } from "./services/umami";
import { collectHeadscale } from "./services/headscale";
function collectServiceStat(widget: ServiceWidget): Promise<{ stats: ServiceStat[]; detail?: string[] }> {
switch (widget.service) {
case "gitea":
return collectGitea(widget);
case "coolify":
return collectCoolify(widget);
case "immich":
return collectImmich(widget);
case "n8n":
return collectN8n(widget);
case "umami":
return collectUmami(widget);
case "headscale":
return collectHeadscale(widget);
}
}
export async function collectService(widget: ServiceWidget): Promise<ServiceWidgetResult> {
const dockerPromise = dockerLimit(() => collectDockerContainer(widget.containerName, widget.showStats));
// A failed service-API call (bad token, service down) must not take out the
// docker health readout too - the two are independent failure modes and
// merging them into one card should not let one mask the other.
const statPromise = collectServiceStat(widget).catch((err) => ({
stats: [] as ServiceStat[],
statError: (err as Error).message,
}));
const [docker, statResult] = await Promise.all([dockerPromise, statPromise]);
return { docker, ...statResult };
}
+14
View File
@@ -0,0 +1,14 @@
import type { ServiceWidget } from "@/lib/config/schema";
const SERVICE_PORTS: Record<ServiceWidget["service"], number> = {
gitea: 3000,
coolify: 8080,
immich: 2283,
n8n: 5678,
umami: 3000,
headscale: 8080,
};
export function serviceBaseUrl(widget: ServiceWidget): string {
return `http://${widget.containerName}:${SERVICE_PORTS[widget.service]}`;
}
+40
View File
@@ -0,0 +1,40 @@
import type { CoolifyServiceWidget } from "@/lib/config/schema";
import type { ServiceStat } from "@/lib/types/service-result";
import { serviceBaseUrl } from "./base-url";
const DETAIL_LIMIT = 5;
interface CoolifyProject {
name: string;
}
async function fetchCoolify<T>(base: string, path: string, apiToken: string): Promise<T> {
const response = await fetch(`${base}${path}`, {
headers: { Authorization: `Bearer ${apiToken}` },
signal: AbortSignal.timeout(5_000),
});
if (!response.ok) {
throw new Error(`Coolify API returned ${response.status}`);
}
return (await response.json()) as T;
}
export async function collectCoolify(
widget: CoolifyServiceWidget
): Promise<{ stats: ServiceStat[]; detail?: string[] }> {
const base = serviceBaseUrl(widget);
const [projects, resources] = await Promise.all([
fetchCoolify<CoolifyProject[]>(base, "/api/v1/projects", widget.apiToken),
fetchCoolify<unknown[]>(base, "/api/v1/resources", widget.apiToken),
]);
const names = projects.slice(0, DETAIL_LIMIT).map((p) => p.name);
if (projects.length > DETAIL_LIMIT) names.push(`+${projects.length - DETAIL_LIMIT} more`);
return {
stats: [
{ label: "Projects", value: String(projects.length) },
{ label: "Resources", value: String(resources.length) },
],
detail: names.length > 0 ? names : undefined,
};
}
+16
View File
@@ -0,0 +1,16 @@
import type { GiteaServiceWidget } from "@/lib/config/schema";
import type { ServiceStat } from "@/lib/types/service-result";
import { serviceBaseUrl } from "./base-url";
export async function collectGitea(widget: GiteaServiceWidget): Promise<{ stats: ServiceStat[] }> {
const base = serviceBaseUrl(widget);
const response = await fetch(`${base}/api/v1/users/${widget.username}/repos?limit=1`, {
headers: { Authorization: `token ${widget.apiToken}` },
signal: AbortSignal.timeout(5_000),
});
if (!response.ok) {
throw new Error(`Gitea API returned ${response.status}`);
}
const count = response.headers.get("X-Total-Count") ?? "0";
return { stats: [{ label: "Repos", value: count }] };
}
+30
View File
@@ -0,0 +1,30 @@
import type { HeadscaleServiceWidget } from "@/lib/config/schema";
import type { ServiceStat } from "@/lib/types/service-result";
import { serviceBaseUrl } from "./base-url";
async function fetchList(url: string, apiToken: string, label: string, key: "users" | "nodes"): Promise<unknown[]> {
const response = await fetch(url, {
headers: { Authorization: `Bearer ${apiToken}` },
signal: AbortSignal.timeout(5_000),
});
if (!response.ok) {
throw new Error(`Headscale ${label} API returned ${response.status}`);
}
const body = (await response.json()) as Record<string, unknown[]>;
return body[key] ?? [];
}
export async function collectHeadscale(widget: HeadscaleServiceWidget): Promise<{ stats: ServiceStat[] }> {
const base = serviceBaseUrl(widget);
const [users, nodes] = await Promise.all([
fetchList(`${base}/api/v1/user`, widget.apiToken, "user", "users"),
fetchList(`${base}/api/v1/node`, widget.apiToken, "node", "nodes"),
]);
return {
stats: [
{ label: "Users", value: String(users.length) },
{ label: "Nodes", value: String(nodes.length) },
],
};
}
+26
View File
@@ -0,0 +1,26 @@
import type { ImmichServiceWidget } from "@/lib/config/schema";
import type { ServiceStat } from "@/lib/types/service-result";
import { serviceBaseUrl } from "./base-url";
interface ImmichStatistics {
photos: number;
videos: number;
}
export async function collectImmich(widget: ImmichServiceWidget): Promise<{ stats: ServiceStat[] }> {
const base = serviceBaseUrl(widget);
const response = await fetch(`${base}/api/server/statistics`, {
headers: { "x-api-key": widget.apiKey },
signal: AbortSignal.timeout(5_000),
});
if (!response.ok) {
throw new Error(`Immich API returned ${response.status}`);
}
const stats = (await response.json()) as ImmichStatistics;
return {
stats: [
{ label: "Photos", value: String(stats.photos) },
{ label: "Videos", value: String(stats.videos) },
],
};
}
+20
View File
@@ -0,0 +1,20 @@
import type { N8nServiceWidget } from "@/lib/config/schema";
import type { ServiceStat } from "@/lib/types/service-result";
import { serviceBaseUrl } from "./base-url";
interface N8nWorkflowsPage {
data: unknown[];
}
export async function collectN8n(widget: N8nServiceWidget): Promise<{ stats: ServiceStat[] }> {
const base = serviceBaseUrl(widget);
const response = await fetch(`${base}/api/v1/workflows?limit=250`, {
headers: { "X-N8N-API-KEY": widget.apiKey },
signal: AbortSignal.timeout(5_000),
});
if (!response.ok) {
throw new Error(`n8n API returned ${response.status}`);
}
const page = (await response.json()) as N8nWorkflowsPage;
return { stats: [{ label: "Workflows", value: String(page.data.length) }] };
}
+48
View File
@@ -0,0 +1,48 @@
import type { UmamiServiceWidget } from "@/lib/config/schema";
import type { ServiceStat } from "@/lib/types/service-result";
import { serviceBaseUrl } from "./base-url";
// Self-hosted Umami has no static API-key header (that's Cloud-only) - it needs
// a username/password login exchanged for a Bearer token. Cache the token per
// container and only re-login when a request comes back 401, since the docs
// don't document a fixed token lifetime to pre-emptively refresh against.
const tokenCache = new Map<string, string>();
async function login(widget: UmamiServiceWidget, base: string): Promise<string> {
const response = await fetch(`${base}/api/auth/login`, {
method: "POST",
headers: { "Content-Type": "application/json" },
body: JSON.stringify({ username: widget.username, password: widget.password }),
signal: AbortSignal.timeout(5_000),
});
if (!response.ok) {
throw new Error(`Umami login returned ${response.status}`);
}
const body = (await response.json()) as { token: string };
tokenCache.set(widget.containerName, body.token);
return body.token;
}
export async function collectUmami(widget: UmamiServiceWidget): Promise<{ stats: ServiceStat[] }> {
const base = serviceBaseUrl(widget);
let token = tokenCache.get(widget.containerName) ?? (await login(widget, base));
let response = await fetch(`${base}/api/websites/${widget.websiteId}/active`, {
headers: { Authorization: `Bearer ${token}` },
signal: AbortSignal.timeout(5_000),
});
if (response.status === 401) {
token = await login(widget, base);
response = await fetch(`${base}/api/websites/${widget.websiteId}/active`, {
headers: { Authorization: `Bearer ${token}` },
signal: AbortSignal.timeout(5_000),
});
}
if (!response.ok) {
throw new Error(`Umami API returned ${response.status}`);
}
const body = (await response.json()) as { visitors: number };
return { stats: [{ label: "Active", value: String(body.visitors) }] };
}
+19
View File
@@ -0,0 +1,19 @@
import type { Config, Widget } from "./schema";
const SECRET_WIDGET_FIELDS = ["apiToken", "apiKey", "password"] as const;
export function toPublicConfig(config: Config): Config {
return {
...config,
groups: config.groups.map((group) => ({
...group,
widgets: group.widgets.map(redactWidget),
})),
};
}
function redactWidget(widget: Widget): Widget {
const clone: Record<string, unknown> = { ...widget };
for (const key of SECRET_WIDGET_FIELDS) delete clone[key];
return clone as Widget;
}
+68
View File
@@ -62,9 +62,69 @@ export const traefikWidgetSchema = z.object({
type: z.literal("traefik"), type: z.literal("traefik"),
name: z.string().default("Traefik"), name: z.string().default("Traefik"),
apiUrl: z.string().url(), apiUrl: z.string().url(),
href: z.string().url().optional(),
icon: z.string().optional(),
interval: durationSchema.default("15s"), interval: durationSchema.default("15s"),
}); });
const serviceCommonFields = {
type: z.literal("service") as z.ZodLiteral<"service">,
name: z.string(),
containerName: z.string(),
href: z.string().url().optional(),
showStats: z.boolean().default(true),
interval: durationSchema.default("15s"),
icon: z.string().optional(),
};
export const giteaServiceWidgetSchema = z.object({
...serviceCommonFields,
service: z.literal("gitea"),
username: z.string().default("Valknar"),
apiToken: z.string(),
});
export const coolifyServiceWidgetSchema = z.object({
...serviceCommonFields,
service: z.literal("coolify"),
apiToken: z.string(),
});
export const immichServiceWidgetSchema = z.object({
...serviceCommonFields,
service: z.literal("immich"),
apiKey: z.string(),
});
export const n8nServiceWidgetSchema = z.object({
...serviceCommonFields,
service: z.literal("n8n"),
apiKey: z.string(),
});
export const umamiServiceWidgetSchema = z.object({
...serviceCommonFields,
service: z.literal("umami"),
username: z.string(),
password: z.string(),
websiteId: z.string(),
});
export const headscaleServiceWidgetSchema = z.object({
...serviceCommonFields,
service: z.literal("headscale"),
apiToken: z.string(),
});
export const serviceWidgetSchema = z.discriminatedUnion("service", [
giteaServiceWidgetSchema,
coolifyServiceWidgetSchema,
immichServiceWidgetSchema,
n8nServiceWidgetSchema,
umamiServiceWidgetSchema,
headscaleServiceWidgetSchema,
]);
export const widgetSchema = z.discriminatedUnion("type", [ export const widgetSchema = z.discriminatedUnion("type", [
bookmarkWidgetSchema, bookmarkWidgetSchema,
searchWidgetSchema, searchWidgetSchema,
@@ -73,6 +133,7 @@ export const widgetSchema = z.discriminatedUnion("type", [
systemWidgetSchema, systemWidgetSchema,
httpWidgetSchema, httpWidgetSchema,
traefikWidgetSchema, traefikWidgetSchema,
serviceWidgetSchema,
]); ]);
export const groupSchema = z.object({ export const groupSchema = z.object({
@@ -126,3 +187,10 @@ export type Config = z.infer<typeof configSchema>;
export type Widget = z.infer<typeof widgetSchema>; export type Widget = z.infer<typeof widgetSchema>;
export type Group = z.infer<typeof groupSchema>; export type Group = z.infer<typeof groupSchema>;
export type SearchEngine = z.infer<typeof searchEngineSchema>; export type SearchEngine = z.infer<typeof searchEngineSchema>;
export type ServiceWidget = z.infer<typeof serviceWidgetSchema>;
export type GiteaServiceWidget = z.infer<typeof giteaServiceWidgetSchema>;
export type CoolifyServiceWidget = z.infer<typeof coolifyServiceWidgetSchema>;
export type ImmichServiceWidget = z.infer<typeof immichServiceWidgetSchema>;
export type N8nServiceWidget = z.infer<typeof n8nServiceWidgetSchema>;
export type UmamiServiceWidget = z.infer<typeof umamiServiceWidgetSchema>;
export type HeadscaleServiceWidget = z.infer<typeof headscaleServiceWidgetSchema>;
+13
View File
@@ -0,0 +1,13 @@
import type { DockerContainerResult } from "./widget-result";
export interface ServiceStat {
label: string;
value: string;
}
export interface ServiceWidgetResult {
docker: DockerContainerResult;
stats: ServiceStat[];
detail?: string[];
statError?: string;
}
+2
View File
@@ -1,6 +1,7 @@
import type { SystemResult } from "./system-result"; import type { SystemResult } from "./system-result";
import type { HttpCheckResult } from "./http-result"; import type { HttpCheckResult } from "./http-result";
import type { TraefikResult } from "./traefik-result"; import type { TraefikResult } from "./traefik-result";
import type { ServiceWidgetResult } from "./service-result";
export interface DockerContainerResult { export interface DockerContainerResult {
status: "running" | "exited" | "restarting" | "paused" | "dead" | "created" | "unknown"; status: "running" | "exited" | "restarting" | "paused" | "dead" | "created" | "unknown";
@@ -20,4 +21,5 @@ export type WidgetResult =
| { type: "system"; data: SystemResult } | { type: "system"; data: SystemResult }
| { type: "http"; data: HttpCheckResult } | { type: "http"; data: HttpCheckResult }
| { type: "traefik"; data: TraefikResult } | { type: "traefik"; data: TraefikResult }
| { type: "service"; data: ServiceWidgetResult }
| { type: "error"; message: string }; | { type: "error"; message: string };
+8 -2
View File
@@ -3,6 +3,7 @@ import { WebSocket, WebSocketServer } from "ws";
import { collectorScheduler } from "@/lib/collectors/scheduler"; import { collectorScheduler } from "@/lib/collectors/scheduler";
import { configStore, type ConfigError } from "@/lib/config/loader"; import { configStore, type ConfigError } from "@/lib/config/loader";
import { effectiveConfigStore } from "@/lib/config/effective"; import { effectiveConfigStore } from "@/lib/config/effective";
import { toPublicConfig } from "@/lib/config/public";
import type { Config } from "@/lib/config/schema"; import type { Config } from "@/lib/config/schema";
import type { WidgetResult } from "@/lib/types/widget-result"; import type { WidgetResult } from "@/lib/types/widget-result";
@@ -49,7 +50,7 @@ export function attachWebSocketServer(httpServer: HttpServer): WebSocketServer {
try { try {
const config = effectiveConfigStore.get(); const config = effectiveConfigStore.get();
send(socket, { topic: "config", type: "config:update", ts: Date.now(), data: config }); send(socket, { topic: "config", type: "config:update", ts: Date.now(), data: toPublicConfig(config) });
} catch { } catch {
// no valid config loaded yet; client keeps its SSR-seeded config until one arrives // no valid config loaded yet; client keeps its SSR-seeded config until one arrives
} }
@@ -80,7 +81,12 @@ export function attachWebSocketServer(httpServer: HttpServer): WebSocketServer {
}); });
effectiveConfigStore.onUpdate((config) => { effectiveConfigStore.onUpdate((config) => {
const envelope: Envelope = { topic: "config", type: "config:update", ts: Date.now(), data: config }; const envelope: Envelope = {
topic: "config",
type: "config:update",
ts: Date.now(),
data: toPublicConfig(config),
};
for (const socket of allSockets) send(socket, envelope); for (const socket of allSockets) send(socket, envelope);
}); });