Add Home Assistant connection, import, and interaction

.github/workflows/hacs-validate.yml

@@ -0,0 +1,17 @@
+name: Validate HACS
+
+on:
+  push:
+  pull_request:
+  workflow_dispatch:
+
+permissions: {}
+
+jobs:
+  validate-hacs:
+    runs-on: ubuntu-latest
+    steps:
+      - name: HACS validation
+        uses: hacs/action@main
+        with:
+          category: plugin

.gitignore

@@ -15,6 +15,7 @@ package-lock.json
 
 # Testing
 coverage
+test-results/
 
 # Turbo
 .turbo
@@ -30,7 +31,9 @@ supabase/.temp/
 .next/
 out/
 build
-dist
+**/dist/
+!/dist/
+!/dist/pascal-viewer-card.js
 *.tsbuildinfo
 
 

apps/editor/app/api/home-assistant/connect/route.ts

@@ -0,0 +1,32 @@
+import {
+  resolveHomeAssistantServerConfig,
+  validateHomeAssistantConnection,
+} from '@pascal-app/home-assistant/server'
+
+export const runtime = 'nodejs'
+
+export async function GET() {
+  try {
+    const result = await validateHomeAssistantConnection(await resolveHomeAssistantServerConfig())
+    return Response.json(result, { status: result.success ? 200 : 200 })
+  } catch (error) {
+    const message = error instanceof Error ? error.message : 'Failed to connect to Home Assistant.'
+    return Response.json(
+      {
+        baseUrl: null,
+        castEntityId: null,
+        castFriendlyName: null,
+        clientId: null,
+        entityCount: 0,
+        error: message,
+        externalUrl: null,
+        instanceUrl: null,
+        linked: false,
+        message,
+        mode: 'unlinked',
+        success: false,
+      },
+      { status: 500 },
+    )
+  }
+}

apps/editor/app/api/home-assistant/connection-status/route.ts

@@ -0,0 +1,32 @@
+import {
+  resolveHomeAssistantServerConfig,
+  validateHomeAssistantConnection,
+} from '@pascal-app/home-assistant/server'
+
+export const runtime = 'nodejs'
+
+export async function GET() {
+  try {
+    const result = await validateHomeAssistantConnection(await resolveHomeAssistantServerConfig())
+    return Response.json(result, { status: result.success ? 200 : 200 })
+  } catch (error) {
+    const message = error instanceof Error ? error.message : 'Failed to connect to Home Assistant.'
+    return Response.json(
+      {
+        baseUrl: null,
+        castEntityId: null,
+        castFriendlyName: null,
+        clientId: null,
+        entityCount: 0,
+        error: message,
+        externalUrl: null,
+        instanceUrl: null,
+        linked: false,
+        message,
+        mode: 'unlinked',
+        success: false,
+      },
+      { status: 200 },
+    )
+  }
+}

apps/editor/app/api/home-assistant/device-action/route.ts

@@ -0,0 +1,70 @@
+import type {
+  HomeAssistantActionRequest,
+  HomeAssistantCollectionBinding,
+} from '@pascal-app/home-assistant'
+import { getHomeAssistantLink } from '@pascal-app/home-assistant'
+import {
+  resolveHomeAssistantServerConfig,
+  runHomeAssistantCollectionAction,
+  runHomeAssistantDeviceAction,
+} from '@pascal-app/home-assistant/server'
+
+export const runtime = 'nodejs'
+
+type DeviceActionRequestBody = {
+  binding?: HomeAssistantCollectionBinding
+  collectionName?: string
+  itemName?: string
+  link?: unknown
+  request?: HomeAssistantActionRequest
+}
+
+export async function POST(request: Request) {
+  try {
+    const body = (await request.json()) as DeviceActionRequestBody
+    if (
+      body.binding &&
+      typeof body.binding === 'object' &&
+      body.request &&
+      typeof body.request === 'object'
+    ) {
+      const collectionName =
+        typeof body.collectionName === 'string' && body.collectionName.trim().length > 0
+          ? body.collectionName.trim()
+          : 'Linked collection'
+
+      const result = await runHomeAssistantCollectionAction(
+        await resolveHomeAssistantServerConfig(),
+        collectionName,
+        body.binding,
+        body.request,
+      )
+      return Response.json(result)
+    }
+
+    const itemName =
+      typeof body.itemName === 'string' && body.itemName.trim().length > 0
+        ? body.itemName.trim()
+        : 'Linked item'
+    const link = getHomeAssistantLink({
+      homeAssistantLink: body.link,
+    })
+
+    if (!link) {
+      return Response.json(
+        { error: 'Missing or invalid Home Assistant link payload.' },
+        { status: 400 },
+      )
+    }
+
+    const result = await runHomeAssistantDeviceAction(
+      await resolveHomeAssistantServerConfig(),
+      itemName,
+      link,
+    )
+    return Response.json(result)
+  } catch (error) {
+    const message = error instanceof Error ? error.message : 'Unknown Home Assistant action error.'
+    return Response.json({ error: message }, { status: 500 })
+  }
+}

apps/editor/app/api/home-assistant/discover-devices/route.ts

@@ -0,0 +1,38 @@
+import { discoverHomeAssistantDevices } from '@pascal-app/home-assistant/server'
+import {
+  hasHomeAssistantServerConfig,
+  resolveHomeAssistantServerConfig,
+} from '@pascal-app/home-assistant/server'
+
+export const runtime = 'nodejs'
+
+export async function GET() {
+  try {
+    const config = await resolveHomeAssistantServerConfig()
+    if (!hasHomeAssistantServerConfig(config)) {
+      return Response.json(
+        {
+          devices: [],
+          error: 'Home Assistant is not linked yet.',
+        },
+        { status: 412 },
+      )
+    }
+
+    const devices = await discoverHomeAssistantDevices(config)
+    return Response.json({
+      devices,
+      scannedAt: new Date().toISOString(),
+    })
+  } catch (error) {
+    const message =
+      error instanceof Error ? error.message : 'Unknown Home Assistant discovery error.'
+    return Response.json(
+      {
+        devices: [],
+        error: message,
+      },
+      { status: 500 },
+    )
+  }
+}

apps/editor/app/api/home-assistant/discover-instances/route.ts

@@ -0,0 +1,24 @@
+import { discoverHomeAssistantInstances } from '@pascal-app/home-assistant/server'
+
+export const runtime = 'nodejs'
+
+export async function GET() {
+  try {
+    const instances = await discoverHomeAssistantInstances()
+    return Response.json({
+      instances,
+      scannedAt: new Date().toISOString(),
+    })
+  } catch (error) {
+    const message =
+      error instanceof Error ? error.message : 'Unknown Home Assistant discovery error.'
+
+    return Response.json(
+      {
+        error: message,
+        instances: [],
+      },
+      { status: 500 },
+    )
+  }
+}

apps/editor/app/api/home-assistant/import-resources/route.ts

@@ -0,0 +1,37 @@
+import { listImportableHomeAssistantResources } from '@pascal-app/home-assistant/server'
+import {
+  hasHomeAssistantServerConfig,
+  resolveHomeAssistantServerConfig,
+} from '@pascal-app/home-assistant/server'
+
+export const runtime = 'nodejs'
+
+export async function GET() {
+  try {
+    const config = await resolveHomeAssistantServerConfig()
+    if (!hasHomeAssistantServerConfig(config)) {
+      return Response.json(
+        {
+          error: 'Home Assistant is not linked yet.',
+          resources: [],
+        },
+        { status: 412 },
+      )
+    }
+
+    const resources = await listImportableHomeAssistantResources(config)
+    return Response.json({
+      importedAt: new Date().toISOString(),
+      resources,
+    })
+  } catch (error) {
+    const message = error instanceof Error ? error.message : 'Unknown Home Assistant import error.'
+    return Response.json(
+      {
+        error: message,
+        resources: [],
+      },
+      { status: 500 },
+    )
+  }
+}

apps/editor/app/api/home-assistant/oauth/callback/route.ts

@@ -0,0 +1,81 @@
+import type { NextRequest } from 'next/server'
+import { NextResponse } from 'next/server'
+import {
+  exchangeAuthorizationCode,
+  HOME_ASSISTANT_OAUTH_COOKIE,
+} from '@pascal-app/home-assistant/server'
+import { writeLinkedHomeAssistantProfile } from '@pascal-app/home-assistant/server'
+
+export const runtime = 'nodejs'
+
+function buildRedirectUrl(base: string, status: 'success' | 'error', message?: string) {
+  const redirectUrl = new URL('/', base)
+  redirectUrl.searchParams.set('ha_link', status)
+  if (message) {
+    redirectUrl.searchParams.set('ha_message', message)
+  }
+  return redirectUrl
+}
+
+export async function GET(request: NextRequest) {
+  const oauthCookie = request.cookies.get(HOME_ASSISTANT_OAUTH_COOKIE)?.value
+  const fallbackBase = request.nextUrl.origin
+
+  if (!oauthCookie) {
+    return NextResponse.redirect(
+      buildRedirectUrl(fallbackBase, 'error', 'Missing Home Assistant OAuth state.'),
+    )
+  }
+
+  try {
+    const oauthState = JSON.parse(oauthCookie) as {
+      clientId?: string
+      externalUrl?: string | null
+      instanceUrl?: string
+      state?: string
+    }
+    const code = request.nextUrl.searchParams.get('code')
+    const state = request.nextUrl.searchParams.get('state')
+
+    if (!(oauthState.clientId && oauthState.instanceUrl && oauthState.state && code && state)) {
+      throw new Error('Missing OAuth callback parameters.')
+    }
+
+    if (state !== oauthState.state) {
+      throw new Error('Home Assistant OAuth state did not match.')
+    }
+
+    const tokens = await exchangeAuthorizationCode(
+      oauthState.instanceUrl,
+      oauthState.clientId,
+      code,
+      oauthState.externalUrl,
+    )
+
+    await writeLinkedHomeAssistantProfile({
+      accessToken: tokens.access_token,
+      accessTokenExpiresAt: new Date(Date.now() + tokens.expires_in * 1000).toISOString(),
+      clientId: oauthState.clientId,
+      externalUrl:
+        typeof oauthState.externalUrl === 'string' && oauthState.externalUrl.trim().length > 0
+          ? oauthState.externalUrl
+          : null,
+      instanceUrl: oauthState.instanceUrl,
+      linkedAt: new Date().toISOString(),
+      refreshToken: tokens.refresh_token ?? '',
+    })
+
+    const response = NextResponse.redirect(buildRedirectUrl(oauthState.clientId, 'success'))
+    response.cookies.delete(HOME_ASSISTANT_OAUTH_COOKIE)
+    return response
+  } catch (error) {
+    const message =
+      error instanceof Error ? error.message : 'Failed to complete Home Assistant sign-in.'
+    const parsedCookie = JSON.parse(oauthCookie) as { clientId?: string }
+    const response = NextResponse.redirect(
+      buildRedirectUrl(parsedCookie.clientId ?? fallbackBase, 'error', message),
+    )
+    response.cookies.delete(HOME_ASSISTANT_OAUTH_COOKIE)
+    return response
+  }
+}