Compare commits
3
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
9220e41530 | ||
|
|
14ac885550 | ||
|
|
643721fc16 |
No files matched your search
@@ -29,7 +29,6 @@ import {
|
|||||||
queryCacheDefaultGcTimeMs,
|
queryCacheDefaultGcTimeMs,
|
||||||
queryCacheDefaultRefetchIntervalMs,
|
queryCacheDefaultRefetchIntervalMs,
|
||||||
queryCacheDefaultStaleTimeMs,
|
queryCacheDefaultStaleTimeMs,
|
||||||
widgetRefetchIntervalOverrides,
|
|
||||||
} from "@homarr/api/query-cache";
|
} from "@homarr/api/query-cache";
|
||||||
import { createHeadersCallbackForSource, getTrpcUrl } from "@homarr/api/shared";
|
import { createHeadersCallbackForSource, getTrpcUrl } from "@homarr/api/shared";
|
||||||
import { env } from "@homarr/common/env";
|
import { env } from "@homarr/common/env";
|
||||||
@@ -91,9 +90,6 @@ export function TRPCReactProvider(props: PropsWithChildren) {
|
|||||||
},
|
},
|
||||||
});
|
});
|
||||||
client.setQueryDefaults([["widget"]], { refetchInterval: queryCacheDefaultRefetchIntervalMs });
|
client.setQueryDefaults([["widget"]], { refetchInterval: queryCacheDefaultRefetchIntervalMs });
|
||||||
for (const [path, interval] of Object.entries(widgetRefetchIntervalOverrides)) {
|
|
||||||
client.setQueryDefaults([path.split(".")], { refetchInterval: interval });
|
|
||||||
}
|
|
||||||
return client;
|
return client;
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|||||||
@@ -1,9 +1,17 @@
|
|||||||
"use client";
|
"use client";
|
||||||
|
|
||||||
import type { MutableRefObject, ReactNode } from "react";
|
import type { MutableRefObject, ReactNode } from "react";
|
||||||
import { useCallback, useEffect, useMemo, useState } from "react";
|
import { useCallback, useMemo } from "react";
|
||||||
import { Group, Loader, Menu, Switch, Text } from "@mantine/core";
|
import { Group, Loader, Menu, Switch, Text, Tooltip } from "@mantine/core";
|
||||||
import { IconCopy, IconLayoutKanban, IconRefresh, IconSettings, IconTrash } from "@tabler/icons-react";
|
import {
|
||||||
|
IconAlertTriangle,
|
||||||
|
IconCircleCheck,
|
||||||
|
IconCopy,
|
||||||
|
IconLayoutKanban,
|
||||||
|
IconRefresh,
|
||||||
|
IconSettings,
|
||||||
|
IconTrash,
|
||||||
|
} from "@tabler/icons-react";
|
||||||
import type { QueryClient, QueryKey } from "@tanstack/react-query";
|
import type { QueryClient, QueryKey } from "@tanstack/react-query";
|
||||||
import { useIsFetching, useQueryClient } from "@tanstack/react-query";
|
import { useIsFetching, useQueryClient } from "@tanstack/react-query";
|
||||||
|
|
||||||
@@ -11,10 +19,12 @@ import { clientApi } from "@homarr/api/client";
|
|||||||
import { useSession } from "@homarr/auth/client";
|
import { useSession } from "@homarr/auth/client";
|
||||||
import { useRequiredBoard } from "@homarr/boards/context";
|
import { useRequiredBoard } from "@homarr/boards/context";
|
||||||
import { useEditMode } from "@homarr/boards/edit-mode";
|
import { useEditMode } from "@homarr/boards/edit-mode";
|
||||||
|
import { useTimeAgo } from "@homarr/common";
|
||||||
import { useConfirmModal, useModalAction } from "@homarr/modals";
|
import { useConfirmModal, useModalAction } from "@homarr/modals";
|
||||||
import { useSettings } from "@homarr/settings";
|
import { useSettings } from "@homarr/settings";
|
||||||
import { translateIfNecessary } from "@homarr/translation";
|
import { translateIfNecessary } from "@homarr/translation";
|
||||||
import { useI18n, useScopedI18n } from "@homarr/translation/client";
|
import { useI18n, useScopedI18n } from "@homarr/translation/client";
|
||||||
|
import type { TranslationFunction } from "@homarr/translation";
|
||||||
import type { WidgetContextMenuAction } from "@homarr/widgets";
|
import type { WidgetContextMenuAction } from "@homarr/widgets";
|
||||||
import { reduceWidgetOptionsWithDefaultValues, widgetImports } from "@homarr/widgets";
|
import { reduceWidgetOptionsWithDefaultValues, widgetImports } from "@homarr/widgets";
|
||||||
import { WidgetEditModal } from "@homarr/widgets/modals";
|
import { WidgetEditModal } from "@homarr/widgets/modals";
|
||||||
@@ -232,11 +242,14 @@ export const WidgetContextMenu = ({ item, widgetStateRef, children }: WidgetCont
|
|||||||
onClick={handleRefetch}
|
onClick={handleRefetch}
|
||||||
disabled={isWidgetFetching}
|
disabled={isWidgetFetching}
|
||||||
>
|
>
|
||||||
<Group justify="space-between" wrap="nowrap">
|
<Group justify="space-between" wrap="nowrap" gap="sm">
|
||||||
{tMenu("refresh")}
|
{tMenu("refresh")}
|
||||||
<Text size="xs" c="dimmed">
|
<WidgetQueryStatus
|
||||||
<WidgetCacheAge queryClient={queryClient} queryKey={widgetQueryKey} isFetching={isWidgetFetching} />
|
queryClient={queryClient}
|
||||||
</Text>
|
queryKey={widgetQueryKey}
|
||||||
|
isFetching={isWidgetFetching}
|
||||||
|
t={t}
|
||||||
|
/>
|
||||||
</Group>
|
</Group>
|
||||||
</Menu.Item>
|
</Menu.Item>
|
||||||
<Menu.Item
|
<Menu.Item
|
||||||
@@ -273,34 +286,65 @@ export const WidgetContextMenu = ({ item, widgetStateRef, children }: WidgetCont
|
|||||||
);
|
);
|
||||||
};
|
};
|
||||||
|
|
||||||
const WidgetCacheAge = ({
|
interface WidgetQueryStatusProps {
|
||||||
queryClient,
|
|
||||||
queryKey,
|
|
||||||
isFetching,
|
|
||||||
}: {
|
|
||||||
queryClient: QueryClient;
|
queryClient: QueryClient;
|
||||||
queryKey: QueryKey;
|
queryKey: QueryKey;
|
||||||
isFetching: boolean;
|
isFetching: boolean;
|
||||||
}) => {
|
t: TranslationFunction;
|
||||||
// 1s tick for "just now" → "1s ago" label transition; isFetching prop handles refetch reactivity
|
}
|
||||||
const [, setTick] = useState(0);
|
|
||||||
useEffect(() => {
|
|
||||||
const id = setInterval(() => setTick((n) => n + 1), 1000);
|
|
||||||
return () => clearInterval(id);
|
|
||||||
}, []);
|
|
||||||
|
|
||||||
if (isFetching) return <Loader size={12} />;
|
const WidgetQueryStatus = ({ queryClient, queryKey, isFetching, t }: WidgetQueryStatusProps) => {
|
||||||
|
const queries = queryClient.getQueryCache().findAll({ queryKey });
|
||||||
|
const timestamps = queries.map((query) => query.state.dataUpdatedAt).filter(Boolean);
|
||||||
|
const latest = timestamps.length > 0 ? Math.max(...timestamps) : 0;
|
||||||
|
const ageLabel = useTimeAgo(new Date(latest));
|
||||||
|
|
||||||
const timestamps = queryClient
|
if (isFetching) {
|
||||||
.getQueryCache()
|
return (
|
||||||
.findAll({ queryKey })
|
<Group gap={4} wrap="nowrap">
|
||||||
.map((q) => q.state.dataUpdatedAt)
|
<Loader size={12} />
|
||||||
.filter(Boolean);
|
<Text size="xs" c="dimmed">
|
||||||
if (timestamps.length === 0) return null;
|
{t("item.menu.status.loading")}
|
||||||
|
</Text>
|
||||||
|
</Group>
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
const latest = Math.max(...timestamps);
|
if (queries.length === 0) {
|
||||||
const seconds = Math.floor((Date.now() - latest) / 1000);
|
return (
|
||||||
if (seconds < 5) return "just now";
|
<Text size="xs" c="dimmed">
|
||||||
if (seconds < 60) return `${seconds}s ago`;
|
{t("item.menu.status.idle")}
|
||||||
return `${Math.floor(seconds / 60)}m ago`;
|
</Text>
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
const hasError = queries.some((q) => q.state.status === "error");
|
||||||
|
|
||||||
|
if (hasError) {
|
||||||
|
const errorQuery = queries.find((q) => q.state.status === "error");
|
||||||
|
const errorMessage =
|
||||||
|
errorQuery?.state.error instanceof Error
|
||||||
|
? errorQuery.state.error.message
|
||||||
|
: String(errorQuery?.state.error ?? "Unknown error");
|
||||||
|
|
||||||
|
return (
|
||||||
|
<Tooltip label={errorMessage} multiline position="left" w={250}>
|
||||||
|
<Group gap={4} wrap="nowrap">
|
||||||
|
<IconAlertTriangle size={12} color="var(--mantine-color-red-6)" />
|
||||||
|
<Text size="xs" c="red.6">
|
||||||
|
{t("item.menu.status.error")} · {ageLabel}
|
||||||
|
</Text>
|
||||||
|
</Group>
|
||||||
|
</Tooltip>
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
return (
|
||||||
|
<Group gap={4} wrap="nowrap">
|
||||||
|
<IconCircleCheck size={12} color="var(--mantine-color-green-6)" />
|
||||||
|
<Text size="xs" c="dimmed">
|
||||||
|
{t("item.menu.status.success")} · {ageLabel}
|
||||||
|
</Text>
|
||||||
|
</Group>
|
||||||
|
);
|
||||||
};
|
};
|
||||||
@@ -7,44 +7,6 @@ export const queryCacheMaxValueBytes = 1024 * 1024;
|
|||||||
export const queryCacheStoragePrefix = "homarr-widget-query";
|
export const queryCacheStoragePrefix = "homarr-widget-query";
|
||||||
export const queryCacheBuster = "v2-superjson";
|
export const queryCacheBuster = "v2-superjson";
|
||||||
|
|
||||||
export const widgetRefetchIntervalOverrides: Record<string, number> = {
|
|
||||||
"widget.healthMonitoring": 5_000,
|
|
||||||
"widget.dnsHole": 5_000,
|
|
||||||
"widget.downloads": 5_000,
|
|
||||||
"widget.mediaServer": 5_000,
|
|
||||||
"widget.tracearr": 5_000,
|
|
||||||
"widget.firewall.getFirewallCpuStatus": 5_000,
|
|
||||||
"widget.firewall.getFirewallMemoryStatus": 15_000,
|
|
||||||
"widget.firewall.getFirewallInterfacesStatus": 30_000,
|
|
||||||
"widget.firewall.getFirewallVersionStatus": 3_600_000,
|
|
||||||
"widget.anchorNotes": 15_000,
|
|
||||||
"widget.coolify": 30_000,
|
|
||||||
"widget.umami.getActiveVisitors": 30_000,
|
|
||||||
"widget.umami": 300_000,
|
|
||||||
"widget.calendar": 60_000,
|
|
||||||
"widget.mediaRequests": 60_000,
|
|
||||||
"widget.smartHome": 60_000,
|
|
||||||
"widget.ups": 60_000,
|
|
||||||
"widget.uptimeKuma": 60_000,
|
|
||||||
"widget.weather": 60_000,
|
|
||||||
"widget.timetable": 60_000,
|
|
||||||
"widget.indexerManager": 300_000,
|
|
||||||
"widget.mediaRelease": 300_000,
|
|
||||||
"widget.mediaTranscoding": 300_000,
|
|
||||||
"widget.networkController": 300_000,
|
|
||||||
"widget.notifications": 300_000,
|
|
||||||
"widget.rssFeed": 300_000,
|
|
||||||
"widget.stockPrice": 300_000,
|
|
||||||
"widget.minecraft": 300_000,
|
|
||||||
"widget.vpn": 300_000,
|
|
||||||
"widget.archiveTeamWarrior": 300_000,
|
|
||||||
"widget.audiobookshelf": 600_000,
|
|
||||||
"widget.navidrome": 600_000,
|
|
||||||
"widget.speedtestTracker": 600_000,
|
|
||||||
"widget.immich": 900_000,
|
|
||||||
"widget.paperlessNgx": 900_000,
|
|
||||||
};
|
|
||||||
|
|
||||||
let activeQueryCacheBoardId: string | null = null;
|
let activeQueryCacheBoardId: string | null = null;
|
||||||
|
|
||||||
export const setActiveQueryCacheBoardId = (boardId: string | null) => {
|
export const setActiveQueryCacheBoardId = (boardId: string | null) => {
|
||||||
|
|||||||
@@ -153,9 +153,9 @@ export class OverseerrIntegration
|
|||||||
);
|
);
|
||||||
} else if (pendingResults.length > 0) requests = pendingResults;
|
} else if (pendingResults.length > 0) requests = pendingResults;
|
||||||
else if (allResults.length > 0) requests = allResults;
|
else if (allResults.length > 0) requests = allResults;
|
||||||
else return Promise.all([]);
|
else return [];
|
||||||
|
|
||||||
return await Promise.all(
|
const settled = await Promise.allSettled(
|
||||||
requests.map(async (request): Promise<MediaRequest> => {
|
requests.map(async (request): Promise<MediaRequest> => {
|
||||||
const information = await this.getItemInformationAsync(request.media.tmdbId, request.type);
|
const information = await this.getItemInformationAsync(request.media.tmdbId, request.type);
|
||||||
|
|
||||||
@@ -184,6 +184,10 @@ export class OverseerrIntegration
|
|||||||
};
|
};
|
||||||
}),
|
}),
|
||||||
);
|
);
|
||||||
|
|
||||||
|
return settled
|
||||||
|
.filter((result): result is PromiseFulfilledResult<MediaRequest> => result.status === "fulfilled")
|
||||||
|
.map((result) => result.value);
|
||||||
}
|
}
|
||||||
|
|
||||||
protected mapRequestStatus(status: UpstreamMediaRequestStatus): MediaRequestStatus {
|
protected mapRequestStatus(status: UpstreamMediaRequestStatus): MediaRequestStatus {
|
||||||
@@ -301,6 +305,10 @@ export class OverseerrIntegration
|
|||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
|
if (!response.ok) {
|
||||||
|
throw new Error(`Failed to fetch ${type} information for id ${id}: ${response.status} ${response.statusText}`);
|
||||||
|
}
|
||||||
|
|
||||||
if (type === "tv") {
|
if (type === "tv") {
|
||||||
const series = (await response.json()) as TvInformation;
|
const series = (await response.json()) as TvInformation;
|
||||||
return {
|
return {
|
||||||
|
|||||||
@@ -12,7 +12,6 @@ export const anchorNotesListRequestHandler = createIntegrationRequestHandler<
|
|||||||
const instance = await createIntegrationAsync(integration);
|
const instance = await createIntegrationAsync(integration);
|
||||||
return instance.listNotesAsync(input);
|
return instance.listNotesAsync(input);
|
||||||
},
|
},
|
||||||
cacheTtlMs: 15_000,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
export const anchorNoteRequestHandler = createIntegrationRequestHandler<AnchorNote, "anchor", { noteId: string }>({
|
export const anchorNoteRequestHandler = createIntegrationRequestHandler<AnchorNote, "anchor", { noteId: string }>({
|
||||||
@@ -20,5 +19,4 @@ export const anchorNoteRequestHandler = createIntegrationRequestHandler<AnchorNo
|
|||||||
const instance = await createIntegrationAsync(integration);
|
const instance = await createIntegrationAsync(integration);
|
||||||
return instance.getNoteAsync(input.noteId);
|
return instance.getNoteAsync(input.noteId);
|
||||||
},
|
},
|
||||||
cacheTtlMs: 15_000,
|
|
||||||
});
|
});
|
||||||
@@ -13,5 +13,4 @@ export const archiveTeamWarriorRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getStatusAsync();
|
return await integrationInstance.getStatusAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 300_000,
|
|
||||||
});
|
});
|
||||||
@@ -12,5 +12,4 @@ export const audiobookshelfRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getDashboardDataAsync();
|
return await integrationInstance.getDashboardDataAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 600_000,
|
|
||||||
});
|
});
|
||||||
@@ -23,5 +23,4 @@ export const calendarMonthRequestHandler = createIntegrationRequestHandler<
|
|||||||
input.showUnmonitored,
|
input.showUnmonitored,
|
||||||
);
|
);
|
||||||
},
|
},
|
||||||
cacheTtlMs: 60_000,
|
|
||||||
});
|
});
|
||||||
@@ -12,5 +12,4 @@ export const coolifyRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getInstanceInfoAsync();
|
return await integrationInstance.getInstanceInfoAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 30_000,
|
|
||||||
});
|
});
|
||||||
@@ -13,5 +13,4 @@ export const dnsHoleRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getSummaryAsync();
|
return await integrationInstance.getSummaryAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 5_000,
|
|
||||||
});
|
});
|
||||||
@@ -177,7 +177,6 @@ export const dockerContainersRequestHandler = createWidgetRequestHandler({
|
|||||||
}
|
}
|
||||||
return await getContainersWithStatsAsync();
|
return await getContainersWithStatsAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 20_000,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
const extractImage = (container: ContainerInfo) => extractContainerImageName(container.Image);
|
const extractImage = (container: ContainerInfo) => extractContainerImageName(container.Image);
|
||||||
|
|||||||
@@ -13,5 +13,4 @@ export const downloadClientRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getClientJobsAndStatusAsync(input);
|
return await integrationInstance.getClientJobsAndStatusAsync(input);
|
||||||
},
|
},
|
||||||
cacheTtlMs: 5_000,
|
|
||||||
});
|
});
|
||||||
@@ -69,5 +69,4 @@ export const duckDuckGoBangsRequestHandler = createRequestHandler({
|
|||||||
|
|
||||||
return normalized;
|
return normalized;
|
||||||
},
|
},
|
||||||
cacheTtlMs: 86_400_000,
|
|
||||||
});
|
});
|
||||||
@@ -18,7 +18,6 @@ export const firewallCpuRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return integrationInstance.getFirewallCpuAsync();
|
return integrationInstance.getFirewallCpuAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 5_000,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
export const firewallMemoryRequestHandler = createIntegrationRequestHandler<
|
export const firewallMemoryRequestHandler = createIntegrationRequestHandler<
|
||||||
@@ -30,7 +29,6 @@ export const firewallMemoryRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getFirewallMemoryAsync();
|
return await integrationInstance.getFirewallMemoryAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 15_000,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
export const firewallInterfacesRequestHandler = createIntegrationRequestHandler<
|
export const firewallInterfacesRequestHandler = createIntegrationRequestHandler<
|
||||||
@@ -42,7 +40,6 @@ export const firewallInterfacesRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getFirewallInterfacesAsync();
|
return await integrationInstance.getFirewallInterfacesAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 30_000,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
export const firewallVersionRequestHandler = createIntegrationRequestHandler<
|
export const firewallVersionRequestHandler = createIntegrationRequestHandler<
|
||||||
@@ -54,5 +51,4 @@ export const firewallVersionRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getFirewallVersionAsync();
|
return await integrationInstance.getFirewallVersionAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 3_600_000,
|
|
||||||
});
|
});
|
||||||
@@ -13,7 +13,6 @@ export const systemInfoRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getSystemInfoAsync();
|
return await integrationInstance.getSystemInfoAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 5_000,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
export const clusterInfoRequestHandler = createIntegrationRequestHandler<
|
export const clusterInfoRequestHandler = createIntegrationRequestHandler<
|
||||||
@@ -25,5 +24,4 @@ export const clusterInfoRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getClusterInfoAsync();
|
return await integrationInstance.getClusterInfoAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 5_000,
|
|
||||||
});
|
});
|
||||||
@@ -13,7 +13,6 @@ export const immichStatsRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getServerStatsAsync();
|
return await integrationInstance.getServerStatsAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 900_000,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
export const immichAlbumsRequestHandler = createIntegrationRequestHandler<
|
export const immichAlbumsRequestHandler = createIntegrationRequestHandler<
|
||||||
@@ -29,7 +28,6 @@ export const immichAlbumsRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getAlbumsAsync();
|
return await integrationInstance.getAlbumsAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 900_000,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
export const immichAlbumRequestHandler = createIntegrationRequestHandler<
|
export const immichAlbumRequestHandler = createIntegrationRequestHandler<
|
||||||
@@ -41,5 +39,4 @@ export const immichAlbumRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getAlbumAsync(input.albumId);
|
return await integrationInstance.getAlbumAsync(input.albumId);
|
||||||
},
|
},
|
||||||
cacheTtlMs: 900_000,
|
|
||||||
});
|
});
|
||||||
@@ -13,5 +13,4 @@ export const indexerManagerRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getIndexersAsync();
|
return await integrationInstance.getIndexersAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 300_000,
|
|
||||||
});
|
});
|
||||||
@@ -13,6 +13,7 @@ type IntegrationOfKind<TKind extends IntegrationKind> = Omit<Integration, "kind"
|
|||||||
interface Options<TData, TKind extends IntegrationKind, TInput extends Record<string, unknown>> {
|
interface Options<TData, TKind extends IntegrationKind, TInput extends Record<string, unknown>> {
|
||||||
requestAsync: (integration: IntegrationOfKind<TKind>, input: TInput) => Promise<TData>;
|
requestAsync: (integration: IntegrationOfKind<TKind>, input: TInput) => Promise<TData>;
|
||||||
cacheTtlMs?: number;
|
cacheTtlMs?: number;
|
||||||
|
fallbackToStaleOnError?: boolean;
|
||||||
}
|
}
|
||||||
|
|
||||||
export const createIntegrationRequestHandler = <
|
export const createIntegrationRequestHandler = <
|
||||||
@@ -32,6 +33,7 @@ export const createIntegrationRequestHandler = <
|
|||||||
return options.requestAsync(integration, input.options);
|
return options.requestAsync(integration, input.options);
|
||||||
},
|
},
|
||||||
cacheTtlMs: options.cacheTtlMs,
|
cacheTtlMs: options.cacheTtlMs,
|
||||||
|
fallbackToStaleOnError: options.fallbackToStaleOnError,
|
||||||
});
|
});
|
||||||
|
|
||||||
return {
|
return {
|
||||||
|
|||||||
@@ -1,6 +1,7 @@
|
|||||||
interface Options<TData, TInput extends Record<string, unknown>> {
|
interface Options<TData, TInput extends Record<string, unknown>> {
|
||||||
requestAsync: (input: TInput) => Promise<TData>;
|
requestAsync: (input: TInput) => Promise<TData>;
|
||||||
cacheTtlMs?: number;
|
cacheTtlMs?: number;
|
||||||
|
fallbackToStaleOnError?: boolean;
|
||||||
}
|
}
|
||||||
|
|
||||||
type CacheEntry<TData> = { data: TData; timestamp: Date; expiresAt: number };
|
type CacheEntry<TData> = { data: TData; timestamp: Date; expiresAt: number };
|
||||||
@@ -35,7 +36,6 @@ export const createRequestHandler = <TData, TInput extends Record<string, unknow
|
|||||||
if (cached && Date.now() < cached.expiresAt) {
|
if (cached && Date.now() < cached.expiresAt) {
|
||||||
return { data: cached.data, timestamp: cached.timestamp };
|
return { data: cached.data, timestamp: cached.timestamp };
|
||||||
}
|
}
|
||||||
if (cached) cache.delete(key);
|
|
||||||
|
|
||||||
const existing = inflight.get(key);
|
const existing = inflight.get(key);
|
||||||
if (existing) return existing;
|
if (existing) return existing;
|
||||||
@@ -55,6 +55,9 @@ export const createRequestHandler = <TData, TInput extends Record<string, unknow
|
|||||||
})
|
})
|
||||||
.catch((err) => {
|
.catch((err) => {
|
||||||
inflight.delete(key);
|
inflight.delete(key);
|
||||||
|
if (options.fallbackToStaleOnError && cached) {
|
||||||
|
return cached;
|
||||||
|
}
|
||||||
throw err;
|
throw err;
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|||||||
@@ -2,7 +2,6 @@ import { createRequestHandler } from "./request-handler";
|
|||||||
|
|
||||||
interface Options<TData, TInput extends Record<string, unknown>> {
|
interface Options<TData, TInput extends Record<string, unknown>> {
|
||||||
requestAsync: (input: TInput) => Promise<TData>;
|
requestAsync: (input: TInput) => Promise<TData>;
|
||||||
cacheTtlMs?: number;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
export const createWidgetRequestHandler = <TData, TInput extends Record<string, unknown>>(
|
export const createWidgetRequestHandler = <TData, TInput extends Record<string, unknown>>(
|
||||||
@@ -11,6 +10,5 @@ export const createWidgetRequestHandler = <TData, TInput extends Record<string,
|
|||||||
handler: (widgetOptions: TInput) =>
|
handler: (widgetOptions: TInput) =>
|
||||||
createRequestHandler<TData, TInput>({
|
createRequestHandler<TData, TInput>({
|
||||||
requestAsync: options.requestAsync,
|
requestAsync: options.requestAsync,
|
||||||
cacheTtlMs: options.cacheTtlMs,
|
|
||||||
}).handler(widgetOptions),
|
}).handler(widgetOptions),
|
||||||
});
|
});
|
||||||
@@ -13,5 +13,4 @@ export const mediaReleaseRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getMediaReleasesAsync();
|
return await integrationInstance.getMediaReleasesAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 300_000,
|
|
||||||
});
|
});
|
||||||
@@ -13,4 +13,6 @@ export const mediaRequestListRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getRequestsAsync();
|
return await integrationInstance.getRequestsAsync();
|
||||||
},
|
},
|
||||||
|
cacheTtlMs: 60_000,
|
||||||
|
fallbackToStaleOnError: true,
|
||||||
});
|
});
|
||||||
@@ -16,5 +16,4 @@ export const mediaRequestStatsRequestHandler = createIntegrationRequestHandler<
|
|||||||
users: await integrationInstance.getUsersAsync(),
|
users: await integrationInstance.getUsersAsync(),
|
||||||
};
|
};
|
||||||
},
|
},
|
||||||
cacheTtlMs: 60_000,
|
|
||||||
});
|
});
|
||||||
@@ -15,5 +15,4 @@ export const mediaServerRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getCurrentSessionsAsync({ showOnlyPlaying: input.showOnlyPlaying });
|
return await integrationInstance.getCurrentSessionsAsync({ showOnlyPlaying: input.showOnlyPlaying });
|
||||||
},
|
},
|
||||||
cacheTtlMs: 5_000,
|
|
||||||
});
|
});
|
||||||
@@ -17,7 +17,6 @@ export const mediaTranscodingRequestHandler = createIntegrationRequestHandler<
|
|||||||
statistics: await integrationInstance.getStatisticsAsync(),
|
statistics: await integrationInstance.getStatisticsAsync(),
|
||||||
};
|
};
|
||||||
},
|
},
|
||||||
cacheTtlMs: 300_000,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
export interface MediaTranscoding {
|
export interface MediaTranscoding {
|
||||||
|
|||||||
@@ -14,7 +14,6 @@ export const minecraftServerStatusRequestHandler = createWidgetRequestHandler({
|
|||||||
);
|
);
|
||||||
return responseSchema.parse(await response.json());
|
return responseSchema.parse(await response.json());
|
||||||
},
|
},
|
||||||
cacheTtlMs: 300_000,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
const responseSchema = z
|
const responseSchema = z
|
||||||
|
|||||||
@@ -12,5 +12,4 @@ export const navidromeRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getDashboardDataAsync();
|
return await integrationInstance.getDashboardDataAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 600_000,
|
|
||||||
});
|
});
|
||||||
@@ -13,5 +13,4 @@ export const networkControllerRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getNetworkSummaryAsync();
|
return await integrationInstance.getNetworkSummaryAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 300_000,
|
|
||||||
});
|
});
|
||||||
@@ -13,5 +13,4 @@ export const notificationsRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getNotificationsAsync();
|
return await integrationInstance.getNotificationsAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 300_000,
|
|
||||||
});
|
});
|
||||||
@@ -12,5 +12,4 @@ export const paperlessNgxStatsRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getStatsAsync();
|
return await integrationInstance.getStatsAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 900_000,
|
|
||||||
});
|
});
|
||||||
@@ -28,7 +28,6 @@ export const rssFeedsRequestHandler = createWidgetRequestHandler({
|
|||||||
entries: result.entries?.map((entry) => ({ ...entry, feedUrl: input.url })).slice(0, input.count) ?? [],
|
entries: result.entries?.map((entry) => ({ ...entry, feedUrl: input.url })).slice(0, input.count) ?? [],
|
||||||
};
|
};
|
||||||
},
|
},
|
||||||
cacheTtlMs: 300_000,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
const attemptGetImageFromEntry = (feedUrl: string, entry: object) => {
|
const attemptGetImageFromEntry = (feedUrl: string, entry: object) => {
|
||||||
|
|||||||
@@ -18,5 +18,4 @@ export const smartHomeEntityStateRequestHandler = createIntegrationRequestHandle
|
|||||||
|
|
||||||
return result.data.state;
|
return result.data.state;
|
||||||
},
|
},
|
||||||
cacheTtlMs: 60_000,
|
|
||||||
});
|
});
|
||||||
@@ -12,5 +12,4 @@ export const speedtestTrackerRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getDashboardDataAsync();
|
return await integrationInstance.getDashboardDataAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 600_000,
|
|
||||||
});
|
});
|
||||||
@@ -39,7 +39,6 @@ export const fetchStockPriceHandler = createWidgetRequestHandler({
|
|||||||
shortName: firstResult.meta.shortName,
|
shortName: firstResult.meta.shortName,
|
||||||
};
|
};
|
||||||
},
|
},
|
||||||
cacheTtlMs: 300_000,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
const dataSchema = z
|
const dataSchema = z
|
||||||
|
|||||||
@@ -12,5 +12,4 @@ export const tracearrRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getDashboardDataAsync();
|
return await integrationInstance.getDashboardDataAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 5_000,
|
|
||||||
});
|
});
|
||||||
@@ -12,7 +12,6 @@ export const umamiRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getVisitorStatsAsync(input.websiteId, input.timeFrame, input.eventName);
|
return await integrationInstance.getVisitorStatsAsync(input.websiteId, input.timeFrame, input.eventName);
|
||||||
},
|
},
|
||||||
cacheTtlMs: 300_000,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
export const umamiEventNamesRequestHandler = createIntegrationRequestHandler<string[], "umami", { websiteId: string }>({
|
export const umamiEventNamesRequestHandler = createIntegrationRequestHandler<string[], "umami", { websiteId: string }>({
|
||||||
@@ -20,7 +19,6 @@ export const umamiEventNamesRequestHandler = createIntegrationRequestHandler<str
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getEventNamesAsync(input.websiteId);
|
return await integrationInstance.getEventNamesAsync(input.websiteId);
|
||||||
},
|
},
|
||||||
cacheTtlMs: 300_000,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
export const umamiTopPagesRequestHandler = createIntegrationRequestHandler<
|
export const umamiTopPagesRequestHandler = createIntegrationRequestHandler<
|
||||||
@@ -32,7 +30,6 @@ export const umamiTopPagesRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getTopPagesAsync(input.websiteId, input.timeFrame, input.limit);
|
return await integrationInstance.getTopPagesAsync(input.websiteId, input.timeFrame, input.limit);
|
||||||
},
|
},
|
||||||
cacheTtlMs: 300_000,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
export const umamiTopReferrersRequestHandler = createIntegrationRequestHandler<
|
export const umamiTopReferrersRequestHandler = createIntegrationRequestHandler<
|
||||||
@@ -44,7 +41,6 @@ export const umamiTopReferrersRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getTopReferrersAsync(input.websiteId, input.timeFrame, input.limit);
|
return await integrationInstance.getTopReferrersAsync(input.websiteId, input.timeFrame, input.limit);
|
||||||
},
|
},
|
||||||
cacheTtlMs: 300_000,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
export const umamiMultiEventRequestHandler = createIntegrationRequestHandler<
|
export const umamiMultiEventRequestHandler = createIntegrationRequestHandler<
|
||||||
@@ -56,7 +52,6 @@ export const umamiMultiEventRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getMultiEventTimeSeriesAsync(input.websiteId, input.timeFrame, input.eventNames);
|
return await integrationInstance.getMultiEventTimeSeriesAsync(input.websiteId, input.timeFrame, input.eventNames);
|
||||||
},
|
},
|
||||||
cacheTtlMs: 300_000,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
export const umamiActiveVisitorsRequestHandler = createIntegrationRequestHandler<
|
export const umamiActiveVisitorsRequestHandler = createIntegrationRequestHandler<
|
||||||
@@ -68,5 +63,4 @@ export const umamiActiveVisitorsRequestHandler = createIntegrationRequestHandler
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getActiveVisitorsAsync(input.websiteId);
|
return await integrationInstance.getActiveVisitorsAsync(input.websiteId);
|
||||||
},
|
},
|
||||||
cacheTtlMs: 30_000,
|
|
||||||
});
|
});
|
||||||
@@ -13,5 +13,4 @@ export const upsSummariesRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getUpsSummariesAsync();
|
return await integrationInstance.getUpsSummariesAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 60_000,
|
|
||||||
});
|
});
|
||||||
@@ -12,5 +12,4 @@ export const uptimeKumaRequestHandler = createIntegrationRequestHandler<
|
|||||||
const integrationInstance = await createIntegrationAsync(integration);
|
const integrationInstance = await createIntegrationAsync(integration);
|
||||||
return await integrationInstance.getDashboardDataAsync();
|
return await integrationInstance.getDashboardDataAsync();
|
||||||
},
|
},
|
||||||
cacheTtlMs: 60_000,
|
|
||||||
});
|
});
|
||||||
@@ -25,5 +25,4 @@ export const vpnSummaryHandler = createIntegrationRequestHandler<
|
|||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
cacheTtlMs: 300_000,
|
|
||||||
});
|
});
|
||||||
@@ -31,7 +31,6 @@ export const weatherRequestHandler = createWidgetRequestHandler({
|
|||||||
}),
|
}),
|
||||||
} satisfies Weather;
|
} satisfies Weather;
|
||||||
},
|
},
|
||||||
cacheTtlMs: 60_000,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
const atLocationOutput = z.object({
|
const atLocationOutput = z.object({
|
||||||
|
|||||||
@@ -1598,10 +1598,16 @@
|
|||||||
},
|
},
|
||||||
"menu": {
|
"menu": {
|
||||||
"label": {
|
"label": {
|
||||||
"settings": "Settings",
|
"settings": "",
|
||||||
"refresh": "",
|
"refresh": "",
|
||||||
"options": "",
|
"options": "",
|
||||||
"actions": ""
|
"actions": ""
|
||||||
|
},
|
||||||
|
"status": {
|
||||||
|
"success": "",
|
||||||
|
"error": "",
|
||||||
|
"loading": "",
|
||||||
|
"idle": ""
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"create": {
|
"create": {
|
||||||
|
|||||||
@@ -1622,6 +1622,12 @@
|
|||||||
"refresh": "Refresh",
|
"refresh": "Refresh",
|
||||||
"options": "Options",
|
"options": "Options",
|
||||||
"actions": "Actions"
|
"actions": "Actions"
|
||||||
|
},
|
||||||
|
"status": {
|
||||||
|
"success": "OK",
|
||||||
|
"error": "Error",
|
||||||
|
"loading": "Loading",
|
||||||
|
"idle": "Idle"
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"create": {
|
"create": {
|
||||||
|
|||||||
@@ -184,8 +184,12 @@ export default function DockerWidget({ options, width, isEditMode }: WidgetCompo
|
|||||||
const t = useScopedI18n("docker");
|
const t = useScopedI18n("docker");
|
||||||
const isTiny = width <= 256;
|
const isTiny = width <= 256;
|
||||||
|
|
||||||
const { data, refetch, isFetching } = clientApi.docker.getContainers.useQuery(undefined, {
|
const {
|
||||||
refetchInterval: 20_000,
|
data,
|
||||||
|
refetch,
|
||||||
|
isFetching,
|
||||||
|
} = clientApi.docker.getContainers.useQuery(undefined, {
|
||||||
|
refetchInterval: 30_000,
|
||||||
});
|
});
|
||||||
const containers = data?.containers ?? [];
|
const containers = data?.containers ?? [];
|
||||||
const timestamp = useMemo(() => data?.timestamp ?? new Date(), [data?.timestamp]);
|
const timestamp = useMemo(() => data?.timestamp ?? new Date(), [data?.timestamp]);
|
||||||
@@ -300,7 +304,9 @@ export default function DockerWidget({ options, width, isEditMode }: WidgetCompo
|
|||||||
{t("table.totalMemory", { memory: formatBytes(totals.memory) })}
|
{t("table.totalMemory", { memory: formatBytes(totals.memory) })}
|
||||||
</Text>
|
</Text>
|
||||||
|
|
||||||
<Tooltip label={t("table.refresh.lastUpdated", { when: relativeTime })}>
|
<Tooltip
|
||||||
|
label={t("table.refresh.lastUpdated", { when: relativeTime })}
|
||||||
|
>
|
||||||
<ActionIcon
|
<ActionIcon
|
||||||
size="sm"
|
size="sm"
|
||||||
variant="transparent"
|
variant="transparent"
|
||||||
|
|||||||
Reference in new issue
Block a user