voidf1sh/hestia
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Unconsolidate generating of states

Browse Source
This commit is contained in:
Skylar Grant 2024-08-15 11:12:54 -04:00
parent 2ef1e9320a
commit 259700a1b5
2 changed files with 37 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
src/assets/HestiaClasses.js
View File

@ -1,25 +1,40 @@
export class State {
constructor() {
this.publisher = 'front';
return this;
};
init(config) {
config.mqtt.subscriptions.forEach(sub => {
this[sub.name] = {
this.igniter = {
on: false,
topic: sub.topic,
topic: 'hestia/status/igniter',
publisher: 'front',
power: (communicator) => {
// This *should* toggle the state, asks if state is true, if it is set it false, otherwise set it true
this[sub.name].on ? this[sub.name].on = false : this[sub.name].on = true;
communicator.send(sub.topic, JSON.stringify(this));
this.igniter.on ? this.igniter.on = false : this.igniter.on = true;
communicator.send('hestia/status/igniter', JSON.stringify(this));
}
};
console.log(`${sub.name} initialized.`)
});
console.log(`State initialized.`)
this.exhaust = {
on: false,
topic: 'hestia/status/exhaust',
publisher: 'front',
power: (communicator) => {
// This *should* toggle the state, asks if state is true, if it is set it false, otherwise set it true
this.exhaust.on ? this.exhaust.on = false : this.exhaust.on = true;
communicator.send('hestia/status/exhaust', JSON.stringify(this));
}
};
this.auger = {
on: false,
feedRate: 500,
topic: 'hestia/status/auger',
publisher: 'front',
power: (communicator) => {
// This *should* toggle the state, asks if state is true, if it is set it false, otherwise set it true
this.auger.on ? this.auger.on = false : this.auger.on = true;
communicator.send('hestia/status/auger', JSON.stringify(this));
}
};
console.log(`State initialized.`)
};
};
export class Communicator {
@ -40,11 +55,10 @@ export class Communicator {
client.on('connect', () => {
console.log('Connected to MQTT broker');
// Subscribe to status topics
config.mqtt.subscriptions.forEach(sub => {
client.subscribe(sub.topic, (err) => {
state.forEach(element => {
client.subscribe(element.topic, (err) => {
if (!err) {
console.log(`Subscribed to ${sub.topic}`);
state[sub.name].topic = sub.topic;
console.log(`Subscribed to ${element.topic}`);
}
});
});

16
src/assets/hestia.js
View File

@ -5,21 +5,7 @@ const config = {
"mqtt": {
"address": "wss://mqtt.3411.one",
"username": "hestia",
"password": "hestia",
"subscriptions": [
{
"name": "igniter",
"topic": "hestia/status/igniter"
},
{
"name": "exhaust",
"topic": "hestia/status/exhaust"
},
{
"name": "auger",
"topic": "hestia/status/auger"
}
]
"password": "hestia"
}
};