68 lines
No EOL
1.9 KiB
JavaScript
68 lines
No EOL
1.9 KiB
JavaScript
const plejd = require('./plejd');
|
|
const api = require('./api');
|
|
const mqtt = require('./mqtt');
|
|
const fs = require('fs');
|
|
|
|
async function main() {
|
|
const rawData = fs.readFileSync('/data/plejd.json');
|
|
const config = JSON.parse(rawData);
|
|
|
|
const plejdApi = new api.PlejdApi(config.site, config.username, config.password);
|
|
const client = new mqtt.MqttClient(config.mqttBroker, config.mqttUsername, config.mqttPassword);
|
|
|
|
plejdApi.once('loggedIn', () => {
|
|
plejdApi.getCryptoKey((cryptoKey) => {
|
|
const devices = plejdApi.getDevices();
|
|
|
|
client.on('connected', () => {
|
|
console.log('plejd-mqtt: connected to mqtt.');
|
|
client.discover(devices);
|
|
});
|
|
|
|
client.init();
|
|
|
|
// init the BLE interface
|
|
const controller = new plejd.Controller(cryptoKey, true);
|
|
controller.on('scanComplete', async (peripherals) => {
|
|
await controller.connect();
|
|
});
|
|
|
|
controller.on('connected', () => {
|
|
console.log('plejd: connected via bluetooth.');
|
|
});
|
|
|
|
// subscribe to changes from Plejd
|
|
controller.on('stateChanged', (deviceId, state) => {
|
|
client.updateState(deviceId, state);
|
|
});
|
|
controller.on('dimChanged', (deviceId, state, dim) => {
|
|
client.updateState(deviceId, state);
|
|
client.updateBrightness(deviceId, dim);
|
|
});
|
|
|
|
// subscribe to changes from HA
|
|
client.on('stateChanged', async (deviceId, state) => {
|
|
if (state) {
|
|
await controller.turnOn(deviceId);
|
|
}
|
|
else {
|
|
await controller.turnOff(deviceId);
|
|
}
|
|
});
|
|
client.on('brightnessChanged', async (deviceId, brightness) => {
|
|
if (brightness > 0) {
|
|
await controller.turnOn(deviceId, brightness);
|
|
}
|
|
else {
|
|
await controller.turnOff(deviceId);
|
|
}
|
|
});
|
|
|
|
controller.init();
|
|
});
|
|
});
|
|
|
|
plejdApi.login();
|
|
}
|
|
|
|
main(); |