app.js

"use strict";

const debug = true;

// Enable TCP debug
// process.env.DEBUG = 'TCP';

const Homey = require('homey')
const { HomeyAPI } = require('athom-api')
const Homekit = require('./lib/homekit.js')



let allDevices = {},
    allPairedDevices = [],
    server = {},
    log = [];

if (debug) {
  console.log = function(string, type) {
    let d = new Date();
    let n = d.toLocaleTimeString();
    let item = {};
    item.time = n;
    item.string = string;
    item.type = type;
    log.push(item);
    Homey.ManagerApi.realtime('log.new', log)
      .catch( this.error )
    if(log.length > 50){
      log.splice(0,1);
    }
  };
}


class HomekitApp extends Homey.App
{
  // Get homey object
  getApi() {
    if (!this.api) {
      this.api = HomeyAPI.forCurrentHomey();
    }
    return this.api;
  }
  async getDevices() {
    let api = await this.getApi();
    allDevices = await api.devices.getDevices();
    return allDevices;
  }

  getLog() {
    return log;
  }

  // Start server function
  async startingServer()
  {
    // Get the homey object
    let api = await this.getApi();
    // Get system info
    let systeminfo = await api.system.getInfo();
    // Subscribe to realtime events and set all devices global
    await api.devices.subscribe();
    allDevices = await api.devices.getDevices();

    server = await Homekit.configServer(systeminfo);

    // Loop all devices
    allPairedDevices = await Homey.ManagerSettings.get('pairedDevices') || [];
    let deviceForDel = [];

    for (let i = 0; i < allPairedDevices.length; i++)
    {
      // If device has the class light
      let device = allPairedDevices[i];

      if (device.id in allDevices)
      {
        console.log(device.name + ' - device found.', 'info');
        await this.addDevice(device,true);
      }
      else
      {
        console.log(device.name + ' - device not found.', 'info');
        deviceForDel.push(device);
      }
    }

    if (deviceForDel.length)
    {
      for (let i = 0; i < deviceForDel.length; i++)
      {
        let device = deviceForDel[i];

        for (let i = 0; i < allPairedDevices.length; i++)
        {
          if (allPairedDevices[i] && allPairedDevices[i].id == device.id)
          {
            allPairedDevices.splice(i, 1);
            break;
          }
        }
      }

      await Homey.ManagerSettings.set('pairedDevices', allPairedDevices, (err, result) =>
      {
        if (err)
          return Homey.alert(err);
      });

      console.log('Delete paired devices! => ' + deviceForDel.length, 'success');
    }

    if(allPairedDevices.length)
    {
      await console.log('Added all devices..done here!', 'success');
    }
    else{
      await console.log('No devices found...', 'info');
    }

    // Start the server
    await server.startServer();
    console.log('Homekit server started.', 'success');

    api.devices.on('device.delete', deviceID =>
    {
      allPairedDevices = Homey.ManagerSettings.get('pairedDevices') || [];

      let deletePairedDevices = false;

      for (let i = 0; i < allPairedDevices.length; i++)
      {
        if (allPairedDevices[i] && allPairedDevices[i].id == deviceID)
        {
          allPairedDevices.splice(i, 1);
          deletePairedDevices = true;
          break;
        }
      }

      if (deletePairedDevices)
      {
        server.removeAccessory(server.config.getHASID(deviceID));

         Homey.ManagerSettings.set('pairedDevices', allPairedDevices, (err, result) =>
        {
          if (err)
            return Homey.alert(err);
        });

        console.log('Delete device! => ' + deviceID, 'success');

      }

    });

  }

  async onInit()
  {
    // Start the server
    await this.startingServer()
      .then(console.log('Homekit server starting!', 'info'))
      .catch(this.error);
  }



  async addDevice(device,noCheck)
  {
    if (noCheck === undefined)
    {
        await this.getDevices();
        console.log(device.name + ' getDevices() ', 'info');
    }

    console.log(device.name + ' class: ' + allDevices[device.id].class, 'info');

    let light = await Homekit.createDevice(allDevices[device.id], server.config.getHASID(device.id));
    await server.addAccessory(light);

    console.log(device.name + ' is added!', 'success');

  }

  async deleteDevice(device)
  {
    console.log('Trying to remove device ' + device.id, "info");

    allDevices[device.id].removeAllListeners('$state');
    server.removeAccessory(server.config.getHASID(device.id));
    server.config.resetHASID(device.id);

    console.log(device.name + ' is removed!', 'success');
  }

}

module.exports = HomekitApp