Ui is completely changed

Added 4 new images for opening and closing out valve while barrell is…

.gitignore

@@ -1,3 +1,6 @@
+# configuration
+controller/config/__init__.py
+
 # Byte-compiled / optimized / DLL files
 __pycache__/
 *.py[cod]

app/.meteor/packages

@@ -16,8 +16,6 @@ standard-minifiers      # JS/CSS minifiers run for production mode
 es5-shim                # ECMAScript 5 compatibility for older browsers.
 ecmascript              # Enable ECMAScript2015+ syntax in app code
 
-autopublish             # Publish all data to the clients (for prototyping)
-insecure                # Allow all DB writes from clients (for prototyping)
 less
 huttonr:bootstrap3
 nimble:restivus
@@ -26,3 +24,5 @@ selaias:meteor-simpleweather
 u2622:persistent-session
 percolate:synced-cron
 rzymek:moment-locale-bs
+peppelg:bootstrap-3-modal
+fortawesome:fontawesome

app/.meteor/versions

@@ -1,7 +1,6 @@
 accounts-base@1.2.2
 accounts-password@1.1.4
 amplify@1.0.0
-autopublish@1.0.4
 autoupdate@1.2.4
 babel-compiler@5.8.24_1
 babel-runtime@0.1.4
@@ -29,6 +28,7 @@ ejson@1.0.7
 email@1.0.8
 es5-shim@4.1.14
 fastclick@1.0.7
+fortawesome:fontawesome@4.5.0
 geojson-utils@1.0.4
 handlebars@1.0.4
 hot-code-push@1.0.0
@@ -38,7 +38,6 @@ http@1.1.1
 huttonr:bootstrap3@3.3.6_6
 huttonr:bootstrap3-assets@3.3.6_2
 id-map@1.0.4
-insecure@1.0.4
 jquery@1.11.4
 json@1.0.3
 launch-screen@1.0.4
@@ -60,6 +59,7 @@ npm-bcrypt@0.7.8_2
 npm-mongo@1.4.39_1
 observe-sequence@1.0.7
 ordered-dict@1.0.4
+peppelg:bootstrap-3-modal@1.0.4
 percolate:synced-cron@1.3.0
 promise@0.5.1
 random@1.0.5

app/client/app.less

@@ -9,5 +9,6 @@
 
 
 #bucket_image {
-  width: 30%;
+  width: 50%;
+  cursor: pointer;
 }

app/client/log.js

@@ -5,7 +5,8 @@ function sensor_data_collection() {
   }, {
     sort: {
       created_at: -1
-    }
+    },
+    limit: 100
   });
 }
 

app/client/settings.html

@@ -1,88 +1,103 @@
 <template name="settings">
-  <div class="col-md-3 col-md-offset-4">
-    <h1>Automatsko zaljevanje: </h1>
-    <select name="time_of_day" id="time_of_day">
-      <option value="00:00" selected={{ timeSelected "00:00" }}>00:00</option>
-      <option value="00:30" selected={{ timeSelected "00:30" }}>00:30</option>
-      <option value="01:00" selected={{ timeSelected "01:00" }}>01:00</option>
-      <option value="01:30" selected={{ timeSelected "01:30" }}>01:30</option>
-      <option value="02:00" selected={{ timeSelected "02:00" }}>02:00</option>
-      <option value="02:30" selected={{ timeSelected "02:30" }}>02:30</option>
-      <option value="03:00" selected={{ timeSelected "03:00" }}>03:00</option>
-      <option value="03:30" selected={{ timeSelected "03:30" }}>03:30</option>
-      <option value="04:00" selected={{ timeSelected "04:00" }}>04:00</option>
-      <option value="04:30" selected={{ timeSelected "04:30" }}>04:30</option>
-      <option value="05:00" selected={{ timeSelected "05:00" }}>05:00</option>
-      <option value="05:30" selected={{ timeSelected "05:30" }}>05:30</option>
-      <option value="06:00" selected={{ timeSelected "06:00" }}>06:00</option>
-      <option value="06:30" selected={{ timeSelected "06:30" }}>06:30</option>
-      <option value="07:00" selected={{ timeSelected "07:00" }}>07:00</option>
-      <option value="07:30" selected={{ timeSelected "07:30" }}>07:30</option>
-      <option value="08:00" selected={{ timeSelected "08:00" }}>08:00</option>
-      <option value="08:30" selected={{ timeSelected "08:30" }}>08:30</option>
-      <option value="09:00" selected={{ timeSelected "09:00" }}>09:00</option>
-      <option value="09:30" selected={{ timeSelected "09:30" }}>09:30</option>
-      <option value="10:00" selected={{ timeSelected "10:00" }}>10:00</option>
-      <option value="10:30" selected={{ timeSelected "10:30" }}>10:30</option>
-      <option value="11:00" selected={{ timeSelected "11:00" }}>11:00</option>
-      <option value="11:30" selected={{ timeSelected "11:30" }}>11:30</option>
-      <option value="12:00" selected={{ timeSelected "12:00" }}>12:00</option>
-      <option value="12:30" selected={{ timeSelected "12:30" }}>12:30</option>
-      <option value="13:00" selected={{ timeSelected "13:00" }}>13:00</option>
-      <option value="13:30" selected={{ timeSelected "13:30" }}>13:30</option>
-      <option value="14:00" selected={{ timeSelected "14:00" }}>14:00</option>
-      <option value="14:30" selected={{ timeSelected "14:30" }}>14:30</option>
-      <option value="15:00" selected={{ timeSelected "15:00" }}>15:00</option>
-      <option value="15:30" selected={{ timeSelected "15:30" }}>15:30</option>
-      <option value="16:00" selected={{ timeSelected "16:00" }}>16:00</option>
-      <option value="16:30" selected={{ timeSelected "16:30" }}>16:30</option>
-      <option value="17:00" selected={{ timeSelected "17:00" }}>17:00</option>
-      <option value="17:30" selected={{ timeSelected "17:30" }}>17:30</option>
-      <option value="18:00" selected={{ timeSelected "18:00" }}>18:00</option>
-      <option value="18:30" selected={{ timeSelected "18:30" }}>18:30</option>
-      <option value="19:00" selected={{ timeSelected "19:00" }}>19:00</option>
-      <option value="19:30" selected={{ timeSelected "19:30" }}>19:30</option>
-      <option value="20:00" selected={{ timeSelected "20:00" }}>20:00</option>
-      <option value="20:30" selected={{ timeSelected "20:30" }}>20:30</option>
-      <option value="21:00" selected={{ timeSelected "21:00" }}>21:00</option>
-      <option value="21:30" selected={{ timeSelected "21:30" }}>21:30</option>
-      <option value="22:00" selected={{ timeSelected "22:00" }}>22:00</option>
-      <option value="22:30" selected={{ timeSelected "22:30" }}>22:30</option>
-      <option value="23:00" selected={{ timeSelected "23:00" }}>23:00</option>
-      <option value="23:30" selected={{ timeSelected "23:30" }}>23:30</option>
-    </select>
-    <div>
+  <div class="modal fade">
+    <div class="modal-dialog">
+      <div class="modal-content">
 
-      <input type="checkbox" id="day_1" name="day_1" value="2" class="day_checkbox" checked="{{ dayChecked '2' }}" />
-      <label for="day_1">Ponedjeljak</label>
-    </div>
-    <div>
-      <input type="checkbox" id="day_2" name="day_2" value="3" class="day_checkbox" checked="{{ dayChecked '3' }}" />
-      <label for="day_2">Utorak</label>
-    </div>
-    <div>
-      <input type="checkbox" id="day_3" name="day_3" value="4" class="day_checkbox" checked="{{ dayChecked '4' }}" />
-      <label for="day_3">Srijeda</label>
-    </div>
-    <div>
-      <input type="checkbox" id="day_4" name="day_4" value="5" class="day_checkbox" checked="{{ dayChecked '5' }}" />
-      <label for="day_4">Četvrtak</label>
-    </div>
-    <div>
-      <input type="checkbox" id="day_5" name="day_5" value="6" class="day_checkbox"  checked="{{ dayChecked '6' }}" />
-      <label for="day_5">Petak</label>
-    </div>
-    <div>
-      <input type="checkbox" id="day_6" name="day_6" value="7" class="day_checkbox" checked="{{ dayChecked '7' }}" />
-      <label for="day_6">Subota</label>
-    </div>
-    <div>
-      <input type="checkbox" id="day_7" name="day_7" value="1" class="day_checkbox" checked="{{ dayChecked '1' }}" />
-      <label for="day_7">Nedjelja</label>
-    </div>
+        <div class="modal-header">
+          <h4 class="modal-title">Automatsko zaljevanje</h4>
+        </div>
 
-    <div>
-      <button id="save_settings" name="save_settings">Zapamti</button>
+        <div class="modal-body">
+          <select name="time_of_day" id="time_of_day">
+            <option value="00:00" selected={{ timeSelected "00:00" }}>00:00</option>
+            <option value="00:30" selected={{ timeSelected "00:30" }}>00:30</option>
+            <option value="01:00" selected={{ timeSelected "01:00" }}>01:00</option>
+            <option value="01:30" selected={{ timeSelected "01:30" }}>01:30</option>
+            <option value="02:00" selected={{ timeSelected "02:00" }}>02:00</option>
+            <option value="02:30" selected={{ timeSelected "02:30" }}>02:30</option>
+            <option value="03:00" selected={{ timeSelected "03:00" }}>03:00</option>
+            <option value="03:30" selected={{ timeSelected "03:30" }}>03:30</option>
+            <option value="04:00" selected={{ timeSelected "04:00" }}>04:00</option>
+            <option value="04:30" selected={{ timeSelected "04:30" }}>04:30</option>
+            <option value="05:00" selected={{ timeSelected "05:00" }}>05:00</option>
+            <option value="05:30" selected={{ timeSelected "05:30" }}>05:30</option>
+            <option value="06:00" selected={{ timeSelected "06:00" }}>06:00</option>
+            <option value="06:30" selected={{ timeSelected "06:30" }}>06:30</option>
+            <option value="07:00" selected={{ timeSelected "07:00" }}>07:00</option>
+            <option value="07:30" selected={{ timeSelected "07:30" }}>07:30</option>
+            <option value="08:00" selected={{ timeSelected "08:00" }}>08:00</option>
+            <option value="08:30" selected={{ timeSelected "08:30" }}>08:30</option>
+            <option value="09:00" selected={{ timeSelected "09:00" }}>09:00</option>
+            <option value="09:30" selected={{ timeSelected "09:30" }}>09:30</option>
+            <option value="10:00" selected={{ timeSelected "10:00" }}>10:00</option>
+            <option value="10:30" selected={{ timeSelected "10:30" }}>10:30</option>
+            <option value="11:00" selected={{ timeSelected "11:00" }}>11:00</option>
+            <option value="11:30" selected={{ timeSelected "11:30" }}>11:30</option>
+            <option value="12:00" selected={{ timeSelected "12:00" }}>12:00</option>
+            <option value="12:30" selected={{ timeSelected "12:30" }}>12:30</option>
+            <option value="13:00" selected={{ timeSelected "13:00" }}>13:00</option>
+            <option value="13:30" selected={{ timeSelected "13:30" }}>13:30</option>
+            <option value="14:00" selected={{ timeSelected "14:00" }}>14:00</option>
+            <option value="14:30" selected={{ timeSelected "14:30" }}>14:30</option>
+            <option value="15:00" selected={{ timeSelected "15:00" }}>15:00</option>
+            <option value="15:30" selected={{ timeSelected "15:30" }}>15:30</option>
+            <option value="16:00" selected={{ timeSelected "16:00" }}>16:00</option>
+            <option value="16:30" selected={{ timeSelected "16:30" }}>16:30</option>
+            <option value="17:00" selected={{ timeSelected "17:00" }}>17:00</option>
+            <option value="17:30" selected={{ timeSelected "17:30" }}>17:30</option>
+            <option value="18:00" selected={{ timeSelected "18:00" }}>18:00</option>
+            <option value="18:30" selected={{ timeSelected "18:30" }}>18:30</option>
+            <option value="19:00" selected={{ timeSelected "19:00" }}>19:00</option>
+            <option value="19:30" selected={{ timeSelected "19:30" }}>19:30</option>
+            <option value="20:00" selected={{ timeSelected "20:00" }}>20:00</option>
+            <option value="20:30" selected={{ timeSelected "20:30" }}>20:30</option>
+            <option value="21:00" selected={{ timeSelected "21:00" }}>21:00</option>
+            <option value="21:30" selected={{ timeSelected "21:30" }}>21:30</option>
+            <option value="22:00" selected={{ timeSelected "22:00" }}>22:00</option>
+            <option value="22:30" selected={{ timeSelected "22:30" }}>22:30</option>
+            <option value="23:00" selected={{ timeSelected "23:00" }}>23:00</option>
+            <option value="23:30" selected={{ timeSelected "23:30" }}>23:30</option>
+          </select>
+          <div>
+
+            <input type="checkbox" id="day_1" name="day_1" value="2" class="day_checkbox" checked="{{ dayChecked '2' }}" />
+            <label for="day_1">Ponedjeljak</label>
+          </div>
+          <div>
+            <input type="checkbox" id="day_2" name="day_2" value="3" class="day_checkbox" checked="{{ dayChecked '3' }}" />
+            <label for="day_2">Utorak</label>
+          </div>
+          <div>
+            <input type="checkbox" id="day_3" name="day_3" value="4" class="day_checkbox" checked="{{ dayChecked '4' }}" />
+            <label for="day_3">Srijeda</label>
+          </div>
+          <div>
+            <input type="checkbox" id="day_4" name="day_4" value="5" class="day_checkbox" checked="{{ dayChecked '5' }}" />
+            <label for="day_4">Četvrtak</label>
+          </div>
+          <div>
+            <input type="checkbox" id="day_5" name="day_5" value="6" class="day_checkbox" checked="{{ dayChecked '6' }}" />
+            <label for="day_5">Petak</label>
+          </div>
+          <div>
+            <input type="checkbox" id="day_6" name="day_6" value="7" class="day_checkbox" checked="{{ dayChecked '7' }}" />
+            <label for="day_6">Subota</label>
+          </div>
+          <div>
+            <input type="checkbox" id="day_7" name="day_7" value="1" class="day_checkbox" checked="{{ dayChecked '1' }}" />
+            <label for="day_7">Nedjelja</label>
+          </div>
+
+          <div>
+
+          </div>
+        </div>
+
+        <div class="modal-footer">
+          <button id="save_settings" class="btn btn-default" name="save_settings" data-dismiss="modal">Zapamti</button>
+        </div>
+
+      </div>
     </div>
   </div>
 

app/client/start.html

@@ -1,5 +1,5 @@
 <template name="start">
-<div class="col-lg-12 text-center">
+<div class="col-lg-12 text-center form">
 {{>state}}
 </div>
 </template>

app/client/startup.js

@@ -0,0 +1,8 @@
+Tracker.autorun(function () {
+  var id = Session.get('controller_id');
+  if (id) {
+    Meteor.subscribe("sensor_data", id);
+    var hamo = Meteor.subscribe("controller_state", id);
+    console.log(hamo);
+  }
+});

app/client/state.html

@@ -1,24 +1,19 @@
 <template name="state">
-  <div class="col-md-3 col-md-offset-4">
+  <div class="col-md-12">
     {{#with controller_state}}
-    <h1>{{controller_id}}</h1>
-    <img src="{{ bucket_image }}" class="img-responsive center-block" id="bucket_image" /> {{#with last_sensor_reading}}
-    <div>
-      <strong>{{ temperatureValue }} °C, {{ humidityValue }} % </strong>
+    <img src="{{ bucket_image }}" class="img-responsive center-block" id="bucket_image" />
+    <div class="text-center">
+      {{controller_id}}:
+      {{#with last_sensor_reading}} <strong> {{ temperatureValue }} °C, {{ humidityValue }} % </strong>  {{/with}}
     </div>
-    <div>
-
+    <div class="text-center">
+      Automatsko zaljevanje: <strong>{{ pretty_days config.automaticDaysOfWeek }} {{ pretty_time config.automaticDaysOfWeek config.automaticTimeOfDay }}</strong> <button id="run_settings" class="btn btn-default"> <i class="fa fa-wrench"></i> </button>
     </div>
     {{/with}}
-    <div>Otpusni ventil: {{pretty_valve state.out_valve }}</div>
-    <div>Zadnja komunikacija: {{ last_communication_time }}</div>
-    {{/with}}
     <div>
       <button id="water_now" class="{{ water_now_button_class }}">Zalij sada</button>
       <button id="stop_water_now" class="{{ stop_button_class }}">Prekini zalijevanje</button>
+
     </div>
   </div>
-  <div class="col-md-1">
-
-  </div>
 </template>

app/client/state.js

@@ -1,12 +1,6 @@
 function controller_state() {
-  var controller = Session.get('controller_id');
-  var result = {}
-  if (controller) {
-    result = ControllerState.findOne({
-      controller_id: controller
-    });
-  }
-
+  var controllerId = Session.get('controller_id');
+  result = ControllerState.findOne({});
   if (!result) {
     result = {}
   };
@@ -20,7 +14,8 @@ function sensor_data_collection() {
   }, {
     sort: {
       created_at: -1
-    }
+    },
+    limit: 1
   });
 }
 
@@ -49,37 +44,59 @@ Template.state.helpers({
 
   bucket_image: function() {
     var sensor = last_sensor_reading();
-    if (sensor && sensor.tankFull === "1") {
-      return "/images/barell_full.png";
-    } else {
-      return "/images/barell_draining.png";
-    }
+    var stateObject = controller_state();
+    if (sensor) {
+      if (sensor.tankFull === 0 && stateObject.state.in_valve === 'open' && stateObject.state.out_valve === 'closed') return "/images/barellFillingUp.png";
+      else if (sensor.tankFull === 1 && (stateObject.state.out_valve === 'closed')) return "/images/barellFull.png";
+      else if (sensor.tankFull === 1 && (stateObject.state.out_valve === 'opening')) return "/images/barellStartWateringFull.png";
+      else if (sensor.tankFull === 1 && (stateObject.state.out_valve === 'open')) return "/images/barellWateringFull.png";
+      else if (sensor.tankFull === 1 && (stateObject.state.out_valve === 'closing')) return "/images/barellStopWateringFull.png";
+      else if (sensor.tankFull === 0 && (stateObject.state.out_valve === 'closed')) return "/images/barellNotFull.png";
+      else if (sensor.tankFull === 0 && (stateObject.state.out_valve === 'opening')) return "/images/barellStartWateringNotFull.png";
+      else if (sensor.tankFull === 0 && (stateObject.state.out_valve === 'open')) return "/images/barellWateringNotFull.png"
+      else if (sensor.tankFull === 0 && (stateObject.state.out_valve === 'closing')) return "/images/barellStopWateringNotFull.png"
+      else return "/images/statusAmber.png";
+    } else return "/images/statusRed.png";
   },
 
   last_sensor_reading: last_sensor_reading,
 
-  last_communication_time: function() {
-    return moment(controller_state().time).fromNow();
-  },
-
-
   water_now_button_class: function() {
     var stateObject = controller_state();
     if (stateObject.state && (stateObject.state.out_valve === 'open' || stateObject.state.out_valve === 'opening')) {
-      return 'hidden';
+      return 'hidden btn btn-success';
     } else {
-      return '';
+      return 'btn btn-success';
     }
   },
   stop_button_class: function() {
     var stateObject = controller_state();
     if (stateObject.state && (stateObject.state.out_valve === 'closed' || stateObject.state.out_valve === 'closing')) {
-      return 'hidden';
+      return 'hidden btn btn-success';
     } else {
-      return '';
+      return 'btn btn-success';
+    }
+  },
+
+  pretty_days: function(daysInNumbers) {
+    var days = ["Nedjelja", "Ponedjeljak", "Utorak", "Srijeda", "Četvrtak", "Petak", "Subota"];
+    if (daysInNumbers.length == 7) {
+      return "Svaki dan"
+    } else if (!daysInNumbers || daysInNumbers.length == 0) {
+      return "Nikad"
+    } else {
+      return daysInNumbers.map(function(number) {
+        return days[number -1 ];
+      }).join(", ");
+    }
+  },
+  pretty_time: function(daysInNumbers, time) {
+    if (!daysInNumbers || daysInNumbers.length == 0) {
+      return ""
+    } else {
+      return " u " + time;
     }
   }
-
 });
 
 Template.state.events({
@@ -91,6 +108,14 @@ Template.state.events({
   'click #stop_water_now': function() {
     var controller_id = Session.get('controller_id');
     Meteor.call('closeOutValve', controller_id)
+  },
+
+  'click #run_settings': function() {
+    Modal.show('settings');
+  },
+
+  'click #bucket_image': function() {
+    Modal.show('state_details', controller_state());
   }
 
 });

app/client/state_details.html

@@ -0,0 +1,24 @@
+<template name="state_details">
+  <div class="modal fade">
+    <div class="modal-dialog">
+      <div class="modal-content">
+
+        <div class="modal-header">
+          <h4 class="modal-title">Detalji</h4>
+        </div>
+
+        <div class="modal-body">
+          <div><strong>Otpusni ventil:</strong> {{pretty_valve state.out_valve }}</div>
+            <div><strong>Ulazni ventil/pumpa:</strong> {{pretty_valve state.in_valve }}</div>
+            <div><strong>Zadnja komunikacija: {{ last_communication_time }}</strong></div>
+        </div>
+
+        <div class="modal-footer">
+          <button id="close_details" class="btn btn-default" name="close_details" data-dismiss="modal">Zatvori</button>
+        </div>
+
+      </div>
+    </div>
+  </div>
+
+</template>

app/client/state_details.js

@@ -0,0 +1,14 @@
+Template.state_details.helpers({
+  pretty_valve: function(state) {
+    if (state === 'open') return "Otvoren";
+    if (state === 'opening') return "Otvara se";
+    if (state === 'closing') return "Zatvara se";
+    if (state === 'closed') return "Zatvoren";
+  },
+  last_communication_time: function() {
+    return moment(this.time).fromNow();
+  }
+});
+
+Template.state_details.events({
+});

app/client/tabs.html

@@ -4,7 +4,6 @@
     <li role="presentation" class="{{ class_for 'start' }}"><a href="#">Stanje</a></li>
     <li role="presentation" class="{{ class_for 'weather' }}"><a href="#">Vrijeme</a></li>
     <li role="presentation" class="{{ class_for 'log' }}"><a href="#">Novosti</a></li>
-    <li role="presentation" class="{{ class_for 'settings' }}"><a href="#">Podešavanje</a></li>
     <li role="presentation" class="controller_selection">  <input type="number" id="controller" name="controller"  value="{{ selected_controller }}" min="1" max="99999"> <button id="switch" name="switch">Prebaci</button>
     </li>
   </ul>

app/server/api.js

@@ -9,7 +9,7 @@ Api.addRoute('sensorData', {
   authRequired: false
 }, {
   post: function() {
-    console.log("Body params", this.bodyParams);
+    reactToSensorData(this.bodyParams);
     SensorData.insert({
       temperatureValue: parseFloat(this.bodyParams.temperatureValue),
       humidityValue: parseFloat(this.bodyParams.humidityValue),
@@ -23,16 +23,49 @@ Api.addRoute('sensorData', {
 });
 
 
+function reactToSensorData(nextSensorReading) {
+  console.log("reacting to sensor");
+  var controllerId = nextSensorReading.controllerId;
+  var state = stateOrDefault(controllerId).state;
+  var shouldStartPumping = (!state.in_valve || state.in_valve === 'closed') && ((parseInt(nextSensorReading.tankFull) === 0) && (state.out_valve === 'closed' || state.out_valve === 'closing'));
+
+  if (shouldStartPumping) {
+    ControllerState.update({
+      controller_id: controllerId
+    }, {
+      '$set': {
+        'state.in_valve': 'opening',
+        'time': new Date(),
+        'set_by': 'server'
+      }
+    });
+  }
+  var shouldStopPumping =  (state.in_valve === 'open' || state.in_valve === 'opening') && (parseInt(nextSensorReading.tankFull) === 1 || state.out_valve === 'open' || state.out_valve === 'opening');
+
+  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("Body params", this.bodyParams);
+    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'
       }
@@ -43,6 +76,7 @@ Api.addRoute('state/:id', {
   }
 });
 
+
 function stateOrDefault(id) {
   var stateEntry = ControllerState.findOne({
     controller_id: id,
@@ -52,13 +86,13 @@ function stateOrDefault(id) {
     stateEntry = ControllerState.insert({
       controller_id: id,
       state: {
-        out_valve: 'closed'
+        out_valve: 'closed',
+        in_valve: 'closed'
       },
       time: new Date(),
       config: {
-        draining_period_amount: 5,
+        draining_period_amount: 60,
         draining_period_unit: 'minutes'
-
       },
       set_by: 'server'
     });

app/server/publications.js

@@ -0,0 +1,18 @@
+// This code only runs on the server
+Meteor.publish("sensor_data", function(controllerId) {
+  return SensorData.find({
+    controllerId: controllerId
+  }, {
+    sort: {
+      created_at: -1
+    },
+    limit: 100
+  });
+});
+
+// This code only runs on the server
+Meteor.publish("controller_state", function(controllerId) {
+  return ControllerState.find({
+    controller_id: controllerId
+  });
+});

controller/config/copy__init__.py.example

@@ -3,7 +3,8 @@
 GPIO_PIN_DHT = 4 # BCM
 SENSORDATA_URL = 'http://tfm.meteor.com/api/v1.0/sensorData'
 GPIO_PIN_TANKFULL = 20 # BCM
-GPIO_PIN_VALVE = 21 # BCM
+GPIO_PIN_OUT_VALVE = 21 # BCM
+GPIO_PIN_IN_VALVE = 18 # BCM
 API_BASE_URL = 'http://tfm.meteor.com/api/v1.0'
 CONTROLLER_ID = '120' # every controller must have a different one
 STATE_FILE = '/var/run/controller_state'

controller/state/changer.py

@@ -7,29 +7,56 @@ class Changer(object):
         self.local_state = local_state
         self.remote_state = remote_state
         GPIO.setmode(GPIO.BCM) # Broadcom pin-numbering scheme
-        GPIO.setup(config.GPIO_PIN_VALVE, GPIO.OUT)
-
-        self.states = {
-          'opening': self.open_valve,
-          'closing': self.close_valve,
-          'open': self.open_valve,
-          'closed': self.close_valve
+        GPIO.setup(config.GPIO_PIN_OUT_VALVE, GPIO.OUT)
+        GPIO.setup(config.GPIO_PIN_IN_VALVE, GPIO.OUT)
 
+        self.out_valve_states = {
+            'opening': self.open_out_valve,
+            'closing': self.close_out_valve,
+            'open': self.open_out_valve,
+            'closed': self.close_out_valve
         }
 
+        self.in_valve_states = {
+            'opening': self.open_in_valve,
+            'closing': self.close_in_valve,
+            'open': self.open_in_valve,
+            'closed': self.close_in_valve
+        }
+
+    def safe_remote_state(self, key):
+        if key in ['out_valve', 'in_valve']:
+            return self.remote_state.get(key, 'closed')
+        else:
+            return self.remote_state.get(key,'');
+
     def process_change(self):
         self.validate_states()
-        change = self.states.get(self.remote_state['out_valve'], None )
-        if change is not None:
-            change()
+
+        out_valve_change = self.out_valve_states.get(self.safe_remote_state('out_valve'), None )
+        if out_valve_change is not None:
+            out_valve_change()
+
+        in_valve_change = self.in_valve_states.get(self.safe_remote_state('in_valve'), None )
+        if in_valve_change is not None:
+            in_valve_change()
+
         return self.local_state
 
-    def open_valve(self):
-        GPIO.output(config.GPIO_PIN_VALVE, GPIO.HIGH)
+    def open_in_valve(self):
+        GPIO.output(config.GPIO_PIN_IN_VALVE, GPIO.HIGH)
+        self.local_state['in_valve'] = 'open'
+
+    def close_in_valve(self):
+        GPIO.output(config.GPIO_PIN_IN_VALVE, GPIO.LOW)
+        self.local_state['in_valve'] = 'closed'
+
+    def open_out_valve(self):
+        GPIO.output(config.GPIO_PIN_OUT_VALVE, GPIO.HIGH)
         self.local_state['out_valve'] = 'open'
 
-    def close_valve(self):
-        GPIO.output(config.GPIO_PIN_VALVE, GPIO.LOW)
+    def close_out_valve(self):
+        GPIO.output(config.GPIO_PIN_OUT_VALVE, GPIO.LOW)
         self.local_state['out_valve'] = 'closed'
 
     def validate_states(self):