Classes Testing
This commit is contained in:
parent
c7ffc0c296
commit
5633c2340a
@ -4,9 +4,11 @@ export class State {
|
|||||||
this[subscription.name] = {
|
this[subscription.name] = {
|
||||||
on: false,
|
on: false,
|
||||||
topic: subscription.topic,
|
topic: subscription.topic,
|
||||||
power: () => {
|
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 *should* toggle the state, asks if state is true, if it is set it false, otherwise set it true
|
||||||
this[subscription.name].on ? this[subscription.name].on = false : this[subscription.name].on = true;
|
this[subscription.name].on ? this[subscription.name].on = false : this[subscription.name].on = true;
|
||||||
|
communicator.send(subscription.name, JSON.stringify(this));
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
});
|
});
|
||||||
@ -25,8 +27,8 @@ export class Communicator {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
powerOn(element, state) {
|
// Publish a message to the MQTT Broker
|
||||||
// Send the enable igniter message
|
send(topic, message) {
|
||||||
// Publish with retain flag set to true
|
// Publish with retain flag set to true
|
||||||
this.client.publish(topic, message, { retain: true }, (err) => {
|
this.client.publish(topic, message, { retain: true }, (err) => {
|
||||||
if (err) {
|
if (err) {
|
||||||
@ -34,38 +36,6 @@ export class Communicator {
|
|||||||
} else {
|
} else {
|
||||||
console.log('Message published and retained on topic:', topic);
|
console.log('Message published and retained on topic:', topic);
|
||||||
}
|
}
|
||||||
|
|
||||||
// Optionally close the connection
|
|
||||||
client.end();
|
|
||||||
});
|
});
|
||||||
// Confirm
|
|
||||||
|
|
||||||
// Update state
|
|
||||||
state.igniterOn();
|
|
||||||
return state;
|
|
||||||
}
|
|
||||||
|
|
||||||
igniterOn(state) {
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
augerOn(state) {
|
|
||||||
// Send the enable auger message
|
|
||||||
|
|
||||||
// Confirm
|
|
||||||
|
|
||||||
// Update state
|
|
||||||
state.augerOn();
|
|
||||||
return state;
|
|
||||||
}
|
|
||||||
|
|
||||||
exhaustOn(state) {
|
|
||||||
// Send the enable exhaust message
|
|
||||||
|
|
||||||
// Confirm
|
|
||||||
|
|
||||||
// Update state
|
|
||||||
state.exhaustOn();
|
|
||||||
return state;
|
|
||||||
}
|
}
|
||||||
}
|
}
|
Loading…
Reference in New Issue
Block a user