feat: add debug info

packages/api/src/router/widgets/hardware-usage.ts

@@ -1,12 +1,23 @@
 import { observable } from "@trpc/server/observable";
 
-import type { CpuLoad, MemoryLoad, NetworkLoad } from "@homarr/integrations";
+import type { CpuLoad, MemoryLoad, NetworkLoad, ServerInfo } from "@homarr/integrations";
 import { createItemAndIntegrationChannel } from "@homarr/redis";
 
 import { createOneIntegrationMiddleware } from "../../middlewares/integration";
 import { createTRPCRouter, publicProcedure } from "../../trpc";
 
 export const hardwareUsageRouter = createTRPCRouter({
+  getServerInfo: publicProcedure
+    .unstable_concat(createOneIntegrationMiddleware("query", "getDashDot"))
+    .query(async ({ ctx }) => {
+      const channel = createItemAndIntegrationChannel<{
+        info: ServerInfo;
+      }>("hardwareUsage", ctx.integration.id);
+      const data = await channel.getAsync();
+      return {
+        info: data?.data.info ?? ({} as ServerInfo),
+      };
+    }),
   getHardwareInformationHistory: publicProcedure
     .unstable_concat(createOneIntegrationMiddleware("query", "getDashDot"))
     .query(async ({ ctx }) => {

packages/cron-jobs/src/jobs/integrations/hardware-usage.ts

@@ -2,7 +2,7 @@ import { decryptSecret } from "@homarr/common/server";
 import { EVERY_SECOND } from "@homarr/cron-jobs-core/expressions";
 import { db, eq } from "@homarr/db";
 import { items } from "@homarr/db/schema/sqlite";
-import type { CpuLoad, MemoryLoad, NetworkLoad } from "@homarr/integrations";
+import type { CpuLoad, MemoryLoad, NetworkLoad, ServerInfo } from "@homarr/integrations";
 import { DashDotIntegration } from "@homarr/integrations";
 import { createItemAndIntegrationChannel } from "@homarr/redis";
 
@@ -38,11 +38,14 @@ export const hardwareUsageJob = createCronJob("hardwareUsage", EVERY_SECOND).wit
           value: decryptSecret(secret.value),
         })),
       });
+
+      const info = await dashDotIntegration.getInfoAsync();
       const cpuLoad = await dashDotIntegration.getCurrentCpuLoadAsync();
       const memoryLoad = await dashDotIntegration.getCurrentMemoryLoadAsync();
       const networkLoad = await dashDotIntegration.getCurrentNetworkLoadAsync();
 
       const cache = createItemAndIntegrationChannel<{
+        info: ServerInfo;
         cpuLoad: CpuLoad;
         memoryLoad: MemoryLoad;
         networkLoad: NetworkLoad;
@@ -51,11 +54,13 @@ export const hardwareUsageJob = createCronJob("hardwareUsage", EVERY_SECOND).wit
         memoryLoad,
         networkLoad,
         cpuLoad,
+        info
       });
       await cache.publishAndUpdateLastStateAsync({
         cpuLoad,
         networkLoad,
         memoryLoad,
+        info
       });
     }
   }

packages/integrations/src/dashdot/dashdot-integration.ts

@@ -2,6 +2,7 @@ import { Integration } from "../base/integration";
 import type { CpuLoad } from "../interfaces/hardware-usage/cpu-load";
 import type { MemoryLoad } from "../interfaces/hardware-usage/memory-load";
 import type { NetworkLoad } from "../interfaces/hardware-usage/network-load";
+import type { ServerInfo } from "../interfaces/hardware-usage/server-info";
 
 export class DashDotIntegration extends Integration {
   public async testConnectionAsync(): Promise<void> {
@@ -11,7 +12,10 @@ export class DashDotIntegration extends Integration {
 
   public async getInfoAsync(): Promise<ServerInfo> {
     const infoResponse = await fetch(this.appendPathToUrlWithEndingSlash(this.integration.url, "info"));
-    return (await infoResponse.json()) as ServerInfo;
+    const serverInfo = (await infoResponse.json()) as InternalServerInfo;
+    return {
+      maxAvailableMemoryBytes: serverInfo.ram.size
+    };
   }
 
   public async getCurrentCpuLoadAsync(): Promise<CpuLoad> {
@@ -56,7 +60,7 @@ interface NetworkLoadApi {
   down: number;
 }
 
-interface ServerInfo {
+interface InternalServerInfo {
   ram: {
     /**
      * Available memory in bytes

packages/integrations/src/index.ts

@@ -26,14 +26,11 @@ export type { ExtendedClientStatus } from "./interfaces/downloads/download-clien
 export type { CpuLoad } from "./interfaces/hardware-usage/cpu-load";
 export type { MemoryLoad } from "./interfaces/hardware-usage/memory-load";
 export type { NetworkLoad } from "./interfaces/hardware-usage/network-load";
+export type { ServerInfo } from "./interfaces/hardware-usage/server-info";
 export type { HealthMonitoring } from "./interfaces/health-monitoring/healt-monitoring";
 export { MediaRequestStatus } from "./interfaces/media-requests/media-request";
 export type { MediaRequestList, MediaRequestStats } from "./interfaces/media-requests/media-request";
 export type { StreamSession } from "./interfaces/media-server/session";
-export type { ExtendedClientStatus } from "./interfaces/downloads/download-client-status";
-export type { ExtendedDownloadClientItem } from "./interfaces/downloads/download-client-items";
-export type { DownloadClientJobsAndStatus } from "./interfaces/downloads/download-client-data";
-export type { IntegrationInput } from "./base/integration";
 
 // Schemas
 export { downloadClientItemSchema } from "./interfaces/downloads/download-client-items";

packages/integrations/src/interfaces/hardware-usage/server-info.ts

@@ -0,0 +1,3 @@
+export interface ServerInfo {
+  maxAvailableMemoryBytes: number;
+}

packages/widgets/src/hardware-usage/component.tsx

@@ -42,6 +42,7 @@ export default function HardwareUsageWidget({ serverData, integrationIds }: Widg
       <CpuGraph cpuLoad={hardwareUsage.map(usage => usage.cpuLoad)} hasLast={hasLast}/>
       <MemoryGraph memoryLoad={hardwareUsage.map(usage => usage.memoryLoad)} maxAvailableBytes={6000000000} hasLast={hasLast} />
       <Code block>{JSON.stringify(hardwareUsage[hardwareUsage.length - 1])}</Code>
+      <Code block>{JSON.stringify(serverData?.initialData.serverInfo)}</Code>
     </Stack>
   );
 }

packages/widgets/src/hardware-usage/serverData.ts

@@ -1,7 +1,7 @@
 "use server";
 
 import { api } from "@homarr/api/server";
-import { CpuLoad, MemoryLoad, NetworkLoad } from "@homarr/integrations";
+import { CpuLoad, MemoryLoad, NetworkLoad, ServerInfo } from "@homarr/integrations";
 
 import type { WidgetProps } from "../definition";
 
@@ -12,8 +12,9 @@ export default async function getServerDataAsync({ integrationIds }: WidgetProps
         hardwareInformationHistory: {
           cpuLoad: {} as CpuLoad,
           memoryLoad: {} as MemoryLoad,
-          networkLoad: {} as NetworkLoad,
+          networkLoad: {} as NetworkLoad
         },
+        serverInfo: {} as ServerInfo
       },
     };
   }
@@ -22,9 +23,14 @@ export default async function getServerDataAsync({ integrationIds }: WidgetProps
     integrationId: integrationIds[0] ?? "",
   });
 
+  const serverInfo = await api.widget.hardwareUsage.getServerInfo({
+    integrationId: integrationIds[0] ?? "",
+  });
+
   return {
     initialData: {
       hardwareInformationHistory: hardwareInformationHistory,
+      serverInfo
     },
   };
 }