zigbee2mqtt/lib/state.js

const logger = require('./util/logger');
const data = require('./util/data');
const fs = require('fs');

const saveInterval = 1000 * 60 * 5; // 5 minutes

class State {
    constructor() {
        this.state = {};
        this.file = data.joinPath('state.json');
        this.timer = null;
    }

    start() {
        this._load();

        // Save the state on every interval
        this.clearTimer();
        this.timer = setInterval(() => this.save(), saveInterval);
    }

    clearTimer() {
        if (this.timer) {
            clearTimeout(this.timer);
            this.timer = null;
        }
    }

    stop() {
        this.clearTimer();
        this.save();
    }

    _load() {
        if (fs.existsSync(this.file)) {
            try {
                this.state = JSON.parse(fs.readFileSync(this.file, 'utf8'));
                logger.debug(`Loaded state from file ${this.file}`);
            } catch (e) {
                logger.debug(`Failed to load state from file ${this.file} (corrupt file?)`);
            }
        } else {
            logger.debug(`Can't load state from file ${this.file} (doesn't exsist)`);
        }
    }

    save() {
        logger.debug(`Saving state to file ${this.file}`);
        const json = JSON.stringify(this.state, null, 4);
        fs.writeFileSync(this.file, json, 'utf8');
    }

    exists(ieeeAddr) {
        return this.state.hasOwnProperty(ieeeAddr);
    }

    get(ieeeAddr) {
        return this.state[ieeeAddr];
    }

    set(ieeeAddr, state) {
        this.state[ieeeAddr] = state;
    }

    remove(ieeeAddr) {
        if (this.exists(ieeeAddr)) {
            delete this.state[ieeeAddr];
        }
    }
}

module.exports = State;