feat: add homeassistant integration (#578)

apps/tasks/src/jobs.ts

@@ -1,4 +1,5 @@
 import { iconsUpdaterJob } from "~/jobs/icons-updater";
+import { smartHomeEntityStateJob } from "~/jobs/integrations/home-assistant";
 import { analyticsJob } from "./jobs/analytics";
 import { pingJob } from "./jobs/ping";
 import { queuesJob } from "./jobs/queue";
@@ -9,6 +10,7 @@ export const jobs = createJobGroup({
   analytics: analyticsJob,
   iconsUpdater: iconsUpdaterJob,
   ping: pingJob,
+  smartHomeEntityState: smartHomeEntityStateJob,
 
   // This job is used to process queues.
   queues: queuesJob,

apps/tasks/src/jobs/integrations/home-assistant.ts

@@ -0,0 +1,64 @@
+import SuperJSON from "superjson";
+
+import { decryptSecret } from "@homarr/common";
+import { db, eq } from "@homarr/db";
+import { items } from "@homarr/db/schema/sqlite";
+import { HomeAssistantIntegration } from "@homarr/integrations";
+import { logger } from "@homarr/log";
+import { homeAssistantEntityState } from "@homarr/redis";
+import type { WidgetComponentProps } from "@homarr/widgets";
+
+import { EVERY_MINUTE } from "~/lib/cron-job/constants";
+import { createCronJob } from "~/lib/cron-job/creator";
+
+export const smartHomeEntityStateJob = createCronJob(EVERY_MINUTE).withCallback(async () => {
+  const itemsForIntegration = await db.query.items.findMany({
+    where: eq(items.kind, "smartHome-entityState"),
+    with: {
+      integrations: {
+        with: {
+          integration: {
+            with: {
+              secrets: {
+                columns: {
+                  kind: true,
+                  value: true,
+                },
+              },
+            },
+          },
+        },
+      },
+    },
+  });
+
+  for (const itemForIntegration of itemsForIntegration) {
+    const integration = itemForIntegration.integrations[0]?.integration;
+    if (!integration) {
+      continue;
+    }
+
+    const options = SuperJSON.parse<WidgetComponentProps<"smartHome-entityState">["options"]>(
+      itemForIntegration.options,
+    );
+
+    const homeAssistant = new HomeAssistantIntegration({
+      ...integration,
+      decryptedSecrets: integration.secrets.map((secret) => ({
+        ...secret,
+        value: decryptSecret(secret.value),
+      })),
+    });
+    const state = await homeAssistant.getEntityStateAsync(options.entityId);
+
+    if (!state.success) {
+      logger.error("Unable to fetch data from Home Assistant");
+      continue;
+    }
+
+    await homeAssistantEntityState.publishAsync({
+      entityId: options.entityId,
+      state: state.data.state,
+    });
+  }
+});