state.ts

import { readFileSync, writeFile, existsSync } from 'fs';
import { join } from 'path';

import states from "./initial-state";

export function initState(devices: any, dataDir: string) {
  // console.log("init devices", devices);

  const jsonPath = join(dataDir, "state.json");
  const loaded = existsSync(jsonPath) ? JSON.parse(readFileSync(jsonPath, 'utf8')) : {};

  const state: any = devices.reduce((obj: any, device: any) => {
    const initial = device.traits
      .map((t: any) => t.replace("action.devices.traits.", ""))
      .reduce(
        (s: any, t: string) => Object.assign(s, states[t] || {}),
        loaded[device.id] || {
          online: true
        }
      );

    obj[device.id] = initial;
    return obj;
  }, {});

  // console.log(state);
  // setInterval(() => console.log(state), 10000);
  setInterval(() => writeFile(jsonPath, JSON.stringify(state), (err) => {
    if (err) console.error(err);
  }), 60000);

  return state;
}