Thermostats are discovered

Author: Surfysamy

src/auth.ts

@@ -222,15 +222,15 @@ export class AuthClient {
   /**
    * Accesseurs pour les métadonnées stockées
    */
-  get homeId(): string | undefined {
-    return this.tokens?.homeId;
+  get homeId(): string | null {
+    return this.tokens?.homeId ?? null;
   }
 
-  get userId(): string | undefined {
-    return this.tokens?.userId;
+  get userId(): string | null {
+    return this.tokens?.userId ?? null;
   }
 
-  get parkId(): string | undefined {
-    return this.tokens?.parkId;
+  get parkId(): string | null {
+    return this.tokens?.parkId ?? null;
   }
 }

src/platform.ts

@@ -1,26 +1,38 @@
-import type { API, DynamicPlatformPlugin, Logger, PlatformAccessory, PlatformConfig } from 'homebridge';
+import type {
+  API,
+  DynamicPlatformPlugin,
+  Logger,
+  PlatformAccessory,
+  PlatformConfig,
+} from 'homebridge';
 import { PLATFORM_NAME, PLUGIN_NAME } from './settings';
 import { TokenStore } from './tokenStore';
 import { AuthClient } from './auth';
 import { OtodoClient } from './otodoClient';
+import { ThermostatClient } from './thermostatClient';
+import type { ThermostatService, Room, Hub } from './types';
+import { ThermostatAccessory } from './thermostatAccessory';
 
 export class OtodoVavPlatform implements DynamicPlatformPlugin {
   public readonly accessories: PlatformAccessory[] = [];
+
   private auth!: AuthClient;
   private client!: OtodoClient;
+  private tClient!: ThermostatClient;
+
+  private roomsById: Map<string, Room> = new Map();
+  private hubsById: Map<string, Hub> = new Map();
 
   constructor(
     public readonly log: Logger,
     public readonly config: PlatformConfig,
     public readonly api: API,
   ) {
-    // Vérification de la configuration
     if (!config || !config.email || !config.password) {
       this.log.error('❌ Configuration invalide : email et password requis');
       return;
     }
 
-    // ⭐ Activation du mode debug si demandé
     if (config.debug === true) {
       this.log.debug('🔍 Mode debug activé');
     }
@@ -31,19 +43,16 @@ export class OtodoVavPlatform implements DynamicPlatformPlugin {
       try {
         await this.initializePlugin();
       } catch (error) {
-        this.log.error('❌ Échec de l\'initialisation du plugin:', error);
+        this.log.error("❌ Échec de l'initialisation du plugin:", error);
       }
     });
   }
 
-  /**
-   * Méthode d'initialisation séparée pour plus de clarté
-   */
   private async initializePlugin(): Promise<void> {
     this.log.debug('📦 Création du TokenStore...');
     const store = new TokenStore(this.api.user.storagePath());
 
-    this.log.debug('🔐 Initialisation de l\'authentification...');
+    this.log.debug("🔐 Initialisation de l'authentification...");
     this.auth = new AuthClient(this.log, store, {
       email: String(this.config.email),
       password: String(this.config.password),
@@ -52,60 +61,112 @@ export class OtodoVavPlatform implements DynamicPlatformPlugin {
 
     await this.auth.init();
 
-    this.log.debug('🌐 Création du client API...');
+    this.log.debug('🌐 Création des clients API...');
     this.client = new OtodoClient(this.log, this.auth);
+    this.tClient = new ThermostatClient(this.log, this.auth);
 
-    this.log.info('✅ Plugin initialisé avec succès');
-    this.log.info(`   HomeId: ${this.auth.homeId}`);
-    this.log.info(`   UserId: ${this.auth.userId}`);
-    this.log.info(`   ParkId: ${this.auth.parkId}`);
+    this.log.info('✅ Plugin initialisé');
+    if (this.auth.homeId) {
+      this.log.info(`   HomeId: ${this.auth.homeId}`);
+    }
+    if (this.auth.userId) {
+      this.log.info(`   UserId: ${this.auth.userId}`);
+    }
+    if (this.auth.parkId) {
+      this.log.info(`   ParkId: ${this.auth.parkId}`);
+    }
 
-    // TODO: Découverte des thermostats
-    // await this.discoverDevices();
+    await this.loadRooms();
+    await this.loadHubs();
+    this.hubsById.forEach(async hub => {
+      await this.discoverDevices(hub._id);
+    });
   }
 
   /**
-   * Appelé par Homebridge pour restaurer les accessoires en cache
+   * Chargement optionnel des pièces pour des noms plus jolis
+   */
+  private async loadRooms(): Promise<void> {
+    try {
+      this.log.debug('📂 Récupération des rooms...');
+      const rooms = await this.tClient.getRooms();
+      this.roomsById = new Map(rooms.map(r => [r._id, r]));
+      this.log.debug(`📂 ${rooms.length} rooms chargées`);
+    } catch (e) {
+      this.log.warn(
+        '⚠️ Impossible de récupérer les rooms (optionnel) : ' + String(e),
+      );
+    }
+  }
+
+  /**
+   * Chargement des hubs
+   */
+  private async loadHubs(): Promise<void> {
+    try {
+      this.log.debug('📂 Récupération des rooms...');
+      const hubs = await this.tClient.getHubs();
+      this.hubsById = new Map(hubs.map(r => [r._id, r]));
+      this.log.debug(`📂 ${hubs.length} hubs chargées`);
+    } catch (e) {
+      this.log.warn('⚠️ Impossible de récupérer les hubs : ' + String(e));
+    }
+  }
+
+  /**
+   * Restaurer depuis le cache
    */
   configureAccessory(accessory: PlatformAccessory): void {
-    this.log.debug('🔄 Restauration de l\'accessoire depuis le cache:', accessory.displayName);
+    this.log.debug(
+      "🔄 Restauration de l'accessoire depuis le cache:",
+      accessory.displayName,
+    );
     this.accessories.push(accessory);
   }
 
   /**
-   * Méthode pour créer ou mettre à jour un thermostat
+   * Upsert d'un thermostat : création ou restauration
    */
-  private upsertThermostat(device: { name: string; id: string }): void {
-    const uuid = this.api.hap.uuid.generate(device.id);
+  private upsertThermostat(t: ThermostatService): void {
+    const uuid = this.api.hap.uuid.generate(`hub:${t.hubId}:svc:${t._id}`);
     const existing = this.accessories.find(acc => acc.UUID === uuid);
 
+    const roomName = this.roomsById.get(t.roomId)?.name;
+    const displayName = roomName
+      ? `Thermostat ${roomName}`
+      : `Thermostat ${t._id}`;
+
     if (existing) {
-      this.log.info('♻️  Restauration du thermostat:', device.name);
-      // TODO: new ThermostatAccessory(this, existing, device, this.client);
+      this.log.info('♻️ Restauration du thermostat:', displayName);
+      new ThermostatAccessory(this, existing, t, this.tClient);
     } else {
-      this.log.info('➕ Enregistrement du nouveau thermostat:', device.name);
-      const accessory = new this.api.platformAccessory(device.name, uuid);
-      // TODO: new ThermostatAccessory(this, accessory, device, this.client);
-      this.api.registerPlatformAccessories(PLUGIN_NAME, PLATFORM_NAME, [accessory]);
+      this.log.info('➕ Enregistrement du nouveau thermostat:', displayName);
+      const accessory = new this.api.platformAccessory(displayName, uuid);
+      new ThermostatAccessory(this, accessory, t, this.tClient);
+
+      this.api.registerPlatformAccessories(PLUGIN_NAME, PLATFORM_NAME, [
+        accessory,
+      ]);
+      this.accessories.push(accessory);
     }
   }
 
   /**
-   * Future méthode de découverte des appareils
+   * Découverte des thermostats via /local-services
    */
-  private async discoverDevices(): Promise<void> {
-    this.log.debug('🔍 Recherche des thermostats...');
-    
-    // TODO: Implémenter quand tu auras l'endpoint de découverte
-    // Exemple :
-    // const devices = await this.client.getJson<DeviceSummary[]>(
-    //   `https://api.gateway.otodo.io/homes/${this.auth.homeId}/devices`
-    // );
-    // 
-    // for (const device of devices) {
-    //   if (device.type === 'thermostat') {
-    //     this.upsertThermostat(device);
-    //   }
-    // }
+  private async discoverDevices(hubId: string): Promise<void> {
+    this.log.info('🔍 Recherche des thermostats Otodo VAV...');
+    try {
+      const thermostats = await this.tClient.getAllThermostats(hubId);
+      this.log.info(`   ${thermostats.length} thermostat(s) trouvé(s)`);
+
+      for (const t of thermostats) {
+        this.upsertThermostat(t);
+      }
+    } catch (e) {
+      this.log.error(
+        '❌ Erreur lors de la découverte des thermostats : ' + String(e),
+      );
+    }
   }
-}
+}