Home Assistant sensor bridge (#42)

* refactor: Home Assistant sensor bridge

* refactor: Home Assistant sensor bridge

---------

Co-authored-by: Claude Agent <agent@protolabsai.com>
Co-authored-by: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: 3 people

apps/server/src/routes/sensors/index.ts

@@ -220,6 +220,7 @@ export function createSensorRoutes(sensorRegistryService: SensorRegistryService)
    * Queue a command for delivery to an IoT device.
    * Body: { action: 'set' | 'toggle' | 'reboot'; payload?: Record<string, unknown> }
    */
+
   router.post('/:id/command', (req, res) => {
     try {
       const { id } = req.params;

apps/server/src/server/services.ts

@@ -438,8 +438,8 @@ export async function createServices(dataDir: string, repoRoot: string): Promise
     settingsService,
     healthMonitorService
   );
-  // Sensor Registry (external sensor data ingestion + SQLite history persistence)
-  const sensorRegistryService = new SensorRegistryService(events, getHomemakerDb());
+  // Sensor Registry (external sensor data ingestion)
+  const sensorRegistryService = new SensorRegistryService(events);
 
   // Context Aggregator (reads sensor readings → unified UserPresenceState)
   const contextAggregator = new ContextAggregator(sensorRegistryService);

apps/server/src/services/scheduler.module.ts

@@ -250,24 +250,6 @@ export function register(container: ServiceContainer): void {
         true
       );
 
-      // Register daily sensor history cleanup — runs at 3 AM daily
-      // Deletes sensor readings older than SENSOR_HISTORY_RETENTION_DAYS (default 30)
-      await schedulerService.registerTask(
-        'sensor-history:cleanup',
-        'Sensor History Cleanup',
-        '0 3 * * *',
-        () => {
-          const result = container.sensorRegistryService.cleanupOldReadings();
-          if (result.deleted > 0) {
-            events.emit('sensor:history-cleanup', {
-              deleted: result.deleted,
-              timestamp: new Date().toISOString(),
-            });
-          }
-        },
-        true
-      );
-
       // Initialize and register daily standup cron (every 15 minutes)
       container.dailyStandupService.initialize(
         settingsService,

apps/server/src/services/sensor-registry-service.ts

@@ -14,7 +14,6 @@
  *   sensor:data-received — when a sensor reports a reading
  */
 
-import * as BetterSqlite3 from 'better-sqlite3';
 import { createLogger } from '@protolabsai/utils';
 import crypto from 'node:crypto';
 import type {
@@ -40,41 +39,20 @@ const STALE_TTL_MS = 5 * 60 * 1000;
 /** How long after the last reading a sensor is considered "offline" (15 minutes) */
 const OFFLINE_TTL_MS = 15 * 60 * 1000;
 
-/** Default number of days to retain sensor history readings */
-const DEFAULT_RETENTION_DAYS = 30;
-
-/** Row shape returned by the sensor_readings table */
-interface SensorReadingRow {
-  sensorId: string;
-  data: string;
-  receivedAt: string;
-}
-
-/** Row shape returned by aggregation queries */
-interface AggregatedRow {
-  period: string;
-  avg: number;
-  min: number;
-  max: number;
-  count: number;
-}
-
 export class SensorRegistryService {
   private sensors = new Map<string, SensorConfig>();
   private readings = new Map<string, SensorReading>();
   private commandQueue = new Map<string, SensorCommand[]>();
   private events?: EventEmitter;
-  private db?: BetterSqlite3.Database;
 
   /** Current tracked WebSocket client count for the builtin:websocket-clients sensor */
   private _wsClientCount = 0;
 
   /** Interval handle for the Electron idle time poller */
   private _electronIdleInterval?: ReturnType<typeof setInterval>;
 
-  constructor(events?: EventEmitter, db?: BetterSqlite3.Database) {
+  constructor(events?: EventEmitter) {
     this.events = events;
-    this.db = db;
   }
 
   /**
@@ -236,19 +214,6 @@ export class SensorRegistryService {
     // Store the latest reading (replaces previous)
     this.readings.set(input.sensorId, reading);
 
-    // Persist to SQLite for historical queries (fire-and-forget — never blocks the hot path)
-    if (this.db) {
-      try {
-        this.db
-          .prepare(
-            'INSERT OR REPLACE INTO sensor_readings (sensorId, data, receivedAt) VALUES (?, ?, ?)'
-          )
-          .run(input.sensorId, JSON.stringify(input.data), receivedAt);
-      } catch (err) {
-        logger.warn(`Failed to persist sensor reading for "${input.sensorId}" to SQLite`, err);
-      }
-    }
-
     // Update sensor's lastSeenAt
     sensor.lastSeenAt = receivedAt;
     this.sensors.set(sensor.id, sensor);

apps/ui/src/components/layout/sidebar/hooks/use-navigation.ts

@@ -15,7 +15,6 @@ import {
   Trophy,
   Cpu,
   DollarSign,
-  Wrench,
   KeyRound,
 } from 'lucide-react';
 import type { NavSection, NavItem } from '../types';
@@ -122,11 +121,6 @@ export function useNavigation({
         label: 'Maintenance',
         icon: CalendarClock,
       },
-      {
-        id: 'vendors',
-        label: 'Vendors',
-        icon: Wrench,
-      },
       {
         id: 'chat',
         label: 'Chat',