Finished in valve support
This commit is contained in:
@@ -1,7 +1,6 @@
|
|||||||
function controller_state() {
|
function controller_state() {
|
||||||
var controllerId = Session.get('controller_id');
|
var controllerId = Session.get('controller_id');
|
||||||
result = ControllerState.findOne({});
|
result = ControllerState.findOne({});
|
||||||
console.log("jupiii", result);
|
|
||||||
if (!result) {
|
if (!result) {
|
||||||
result = {}
|
result = {}
|
||||||
};
|
};
|
||||||
|
|||||||
@@ -24,6 +24,7 @@ Api.addRoute('sensorData', {
|
|||||||
|
|
||||||
|
|
||||||
function reactToSensorData(nextSensorReading) {
|
function reactToSensorData(nextSensorReading) {
|
||||||
|
console.log("reacting to sensor");
|
||||||
var controllerId = nextSensorReading.controllerId;
|
var controllerId = nextSensorReading.controllerId;
|
||||||
var state = stateOrDefault(controllerId).state;
|
var state = stateOrDefault(controllerId).state;
|
||||||
var shouldStartPumping = (parseInt(nextSensorReading.tankFull) === 0 && (!state.in_valve || state.in_valve === 'closed'));
|
var shouldStartPumping = (parseInt(nextSensorReading.tankFull) === 0 && (!state.in_valve || state.in_valve === 'closed'));
|
||||||
@@ -39,12 +40,26 @@ function reactToSensorData(nextSensorReading) {
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
var shouldStopPumping = parseInt(nextSensorReading.tankFull) === 1 && (state.in_valve === 'open' || state.in_valve === 'opening');
|
||||||
|
|
||||||
|
if (shouldStopPumping) {
|
||||||
|
ControllerState.update({
|
||||||
|
controller_id: controllerId
|
||||||
|
}, {
|
||||||
|
'$set': {
|
||||||
|
'state.in_valve': 'closing',
|
||||||
|
'time': new Date(),
|
||||||
|
'set_by': 'server'
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
Api.addRoute('state/:id', {
|
Api.addRoute('state/:id', {
|
||||||
authRequired: false
|
authRequired: false
|
||||||
}, {
|
}, {
|
||||||
post: function() {
|
post: function() {
|
||||||
|
console.log("setting state", this.bodyParams);
|
||||||
return ControllerState.update({
|
return ControllerState.update({
|
||||||
controller_id: this.urlParams.id
|
controller_id: this.urlParams.id
|
||||||
}, {
|
}, {
|
||||||
|
|||||||
Reference in New Issue
Block a user