107 lines
2.8 KiB
JavaScript
107 lines
2.8 KiB
JavaScript
// Global API configuration
|
|
var Api = new Restivus({
|
|
version: 'v1.0',
|
|
useDefaultAuth: true,
|
|
prettyJson: true
|
|
});
|
|
|
|
Api.addRoute('sensorData', {
|
|
authRequired: false
|
|
}, {
|
|
post: function() {
|
|
reactToSensorData(this.bodyParams);
|
|
SensorData.insert({
|
|
temperatureValue: parseFloat(this.bodyParams.temperatureValue),
|
|
humidityValue: parseFloat(this.bodyParams.humidityValue),
|
|
tankFull: this.bodyParams.tankFull,
|
|
owner: this.bodyParams.owner,
|
|
controllerId: this.bodyParams.controllerId,
|
|
created_at: new Date()
|
|
});
|
|
return [];
|
|
}
|
|
});
|
|
|
|
|
|
function reactToSensorData(nextSensorReading) {
|
|
var controllerId = nextSensorReading.controllerId;
|
|
var state = stateOrDefault(controllerId).state;
|
|
console.log(nextSensorReading , state);
|
|
var shouldStartPumping = (!state.in_valve || state.in_valve === 'closed' || state.in_valve === 'closing') && ((parseInt(nextSensorReading.tankFull) === 0) && (state.out_valve === 'closed' || state.out_valve === 'closing'));
|
|
|
|
var shouldStopPumping = (state.in_valve === 'open' || state.in_valve === 'opening') && (parseInt(nextSensorReading.tankFull) === 1 || state.out_valve === 'open' || state.out_valve === 'opening');
|
|
|
|
if (shouldStartPumping) {
|
|
ControllerState.update({
|
|
controller_id: controllerId
|
|
}, {
|
|
'$set': {
|
|
'state.in_valve': 'opening',
|
|
'time': new Date(),
|
|
'set_by': 'server'
|
|
}
|
|
});
|
|
} else if (shouldStopPumping) {
|
|
ControllerState.update({
|
|
controller_id: controllerId
|
|
}, {
|
|
'$set': {
|
|
'state.in_valve': 'closing',
|
|
'time': new Date(),
|
|
'set_by': 'server'
|
|
}
|
|
});
|
|
}
|
|
}
|
|
|
|
Api.addRoute('state/:id', {
|
|
authRequired: false
|
|
}, {
|
|
post: function() {
|
|
console.log("setting state", this.bodyParams);
|
|
return ControllerState.update({
|
|
controller_id: this.urlParams.id
|
|
}, {
|
|
'$set': {
|
|
'state.out_valve': this.bodyParams.out_valve,
|
|
'state.in_valve': this.bodyParams.in_valve,
|
|
'time': new Date(),
|
|
'set_by': 'client'
|
|
}
|
|
});
|
|
},
|
|
get: function() {
|
|
return stateOrDefault(this.urlParams.id).state;
|
|
}
|
|
});
|
|
|
|
|
|
function stateOrDefault(id) {
|
|
var stateEntry = ControllerState.findOne({
|
|
controller_id: id,
|
|
});
|
|
|
|
if (stateEntry === undefined) {
|
|
stateEntry = ControllerState.insert({
|
|
controller_id: id,
|
|
state: {
|
|
out_valve: 'closed',
|
|
in_valve: 'closed'
|
|
},
|
|
time: new Date(),
|
|
config: {
|
|
draining_period_amount: 60,
|
|
draining_period_unit: 'minutes'
|
|
},
|
|
set_by: 'server'
|
|
});
|
|
};
|
|
var stateEntry = ControllerState.findOne({
|
|
controller_id: id,
|
|
});
|
|
return stateEntry;
|
|
}
|
|
|
|
Meteor.sharedFunctions = Meteor.sharedFunctions || {};
|
|
Meteor.sharedFunctions.reactToSensorData = reactToSensorData;
|