New feature

PH_library.py

@@ -8,7 +8,7 @@
 
 import json
 
-from socketIO_client_nexus import SocketIO
+#from socketIO_client_nexus import SocketIO
 
 class AtlasI2C:
 	long_timeout = 1.5         	# the timeout needed to query readings and calibrations
@@ -85,55 +85,65 @@ def list_i2c_devices(self):
 				pass
 		self.set_i2c_address(prev_addr) # restore the address we were using
 		return i2c_devices
+def main():
+	device = AtlasI2C() 	# creates the I2C port object, specify the address or bus if necessary
+
+	print(">> Atlas Scientific sample code")
+	print(">> Any commands entered are passed to the board via I2C except:")
+	print(">>   List_addr lists the available I2C addresses.")
+	print(">>   Address,xx changes the I2C address the Raspberry Pi communicates with.")
+	print(">>   Poll,xx.x command continuously polls the board every xx.x seconds")
+	print(" where xx.x is longer than the %0.2f second timeout." % AtlasI2C.long_timeout)
+	print(">> Pressing ctrl-c will stop the polling")
+
+	# main loop
+	while True:
+		input = raw_input("Enter command: ")
+
+		if input.upper().startswith("LIST_ADDR"):
+			devices = device.list_i2c_devices()
+			for i in range(len (devices)):
+				print devices[i]
+
+		# address command lets you change which address the Raspberry Pi will poll
+		elif input.upper().startswith("ADDRESS"):
+			addr = int(string.split(input, ',')[1])
+			device.set_i2c_address(addr)
+			print("I2C address set to " + str(addr))
+
+		# continuous polling command automatically polls the board
+		elif input.upper().startswith("POLL"):
+			delaytime = float(string.split(input, ',')[1])
+
+			# check for polling time being too short, change it to the minimum timeout if too short
+			if delaytime < AtlasI2C.long_timeout:
+				print("Polling time is shorter than timeout, setting polling time to %0.2f" % AtlasI2C.long_timeout)
+				delaytime = AtlasI2C.long_timeout
 
-#Function
+			# get the information of the board you're polling
+			info = string.split(device.query("I"), ",")[1]
+			print("Polling %s sensor every %0.2f seconds, press ctrl-c to stop polling" % (info, delaytime))
+
+			try:
+				while True:
+					print(device.query("R"))
+					time.sleep(delaytime - AtlasI2C.long_timeout)
+			except KeyboardInterrupt: 		# catches the ctrl-c command, which breaks the loop above
+				print("Continuous polling stopped")
+
+		# if not a special keyword, pass commands straight to board
+		else:
+			if len(input) == 0:
+				print "Please input valid command."
+			else:
+				try:
+					print(device.query(input))
+				except IOError:
+					print("Query failed \n - Address may be invalid, use List_addr command to see available addresses")
 def measure_PH():
 	devices = AtlasI2C()
 	#jsonData = {"current_PH_value":devices.query("R")}
 	return (devices.query("R"))
 
-def calibrate_PH():
-	print("hey")
-	devices    = AtlasI2C();
-	socket_url = "localhost"
-
-	socketIO = SocketIO(socket_url, 9000, verify=False)
-
-	# def welcome(data):
-	#     print('welcome received')
-	#     print(data)
-	def start_calibrate(*arg):
-		# Process(target=read).terminate()
-		try:
-			print("should be something")
-			print(arg)
-			a  = arg[0][u'data']
-			print(a)
-			if(a=="low"):
-				command = "cal,low,4"
-			if(a=="medium"):
-				command = "cal,mid,7"
-			if(a=="high"):
-				command = "cal,high,10"
-			print(command)
-
-			# a = float(arg[0][u'data'])
-			# if(a < 7):
-			# 	command = "cal,low,"+str(a)
-			# if(a==7):
-			# 	command = "cal,mid,7"
-			# if(a > 7):
-			# 	command = "cal,high,"+str(a)
-			# print(command)
-			# devices.query(command)
-
-			print("Command Successful")
-
-		except ValueError:
-			print("Wrong Command")
-		# Process(target=read).start()
-
-	socketIO.on('welcome',start_calibrate)
-	socketIO.wait()
-	while True:
-		pass
+# if __name__ == '__main__':
+# 	main()

README.md

@@ -1 +1,18 @@
-Nothing to see here, go away please.
+## Smart Services summer project:
+
+### The aim of this project is: 
+- Create an IoT system for monitoring algae growth factor( light, temperature, pH) 24/24. 
+- Create a local website for calibrating pH probe with instruction and good UI
+
+### Components:
+- 2 TSL2561 (https://www.adafruit.com/product/439)
+- 2 Platinum RTD sensor and 2 sensor amplifier: MAX31865 (https://www.adafruit.com/product/3328)
+- pH kit from Atlas Scientific (https://www.atlas-scientific.com/product_pages/kits/ph-kit.html)
+- Full spectrum quantum sensor (https://www.apogeeinstruments.com/full-spectrum-quantum-sensor/) and ADS1015 (https://www.adafruit.com/product/1083)
+- Raspberry Pi 3 Model B 
+
+### Code for each component:
+- https://github.com/ControlEverythingCommunity/TSL2561
+- https://github.com/steve71/MAX31865
+- https://github.com/AtlasScientific/Raspberry-Pi-sample-code/blob/master/i2c.py
+- https://github.com/adafruit/Adafruit_Python_ADS1x15

Server/app.js

@@ -5,34 +5,106 @@ var bodyParser     = require("body-parser"),
     flash          = require("connect-flash"),
     cookieParser   = require("cookie-parser"),
     session        = require("express-session"),
-    app            = express();
+    app            = express(),
+    fs             = require("fs");
 var server         = require("http").Server(app);
 var io             = require('socket.io')(server);
+var connected_socket;
+var status         = 0;
+var last_time      = "";
+var last_position  = "";
+fs.readFile("status.txt","utf8",(err,data)=>{
+  if (err) throw err;
+  status = data;
+})
+fs.readFile("history.txt","utf8",(err,data)=>{
+  if (err) throw err;
+  data = data.split(";");
+  last_position = data[0];
+  last_time= data[1];
+})
+function writeHistory() {
+    //get current date
+    var date = new Date();
+    //get current time
+    var hour = date.getHours();
+    hour = (hour < 10 ? "0" : "") + hour;
+    var min  = date.getMinutes();
+    min = (min < 10 ? "0" : "") + min;
+    var sec  = date.getSeconds();
+    sec = (sec < 10 ? "0" : "") + sec;
+    var year = date.getFullYear();
+    var month = date.getMonth();
+    // month = (month < 10 ? "0" : "") + month;
+    var monthArray = ["Jan","Feb","Mar","Apr","May","Jun","Jul","Aug","Sept","Oct","Nov","Dec"];
+    month = monthArray[month];
+
+    var day  = date.getDate();
+    day = (day < 10 ? "0" : "") + day;
+
+    last_time =  year +' '+ month + " " + day + "," + hour + ":" + min + "." + sec;
+    // write calibration time and position to the history text file
+    fs.writeFile("history.txt", last_position+";"+last_time, function(err) {
+    if(err) {
+        return console.log(err);
+    };
+});
+}
 app.use(express.static('public'));
-// app.use(flash());
-// app.use(require("express-session")({
-//     secret: "Once again Rusty wins cutest dog!",
-//     resave: false,
-//     saveUninitialized: false
-// }));
+app.use(flash());
+app.use(session({
+    secret: "secret",
+    resave: false,
+    saveUninitialized: false
+}));
+app.use(function(req, res, next){
+  res.io = io;
+  next();
+});
+app.use(function(req, res, next){
+   // res.locals.currentUser = req.user;
+   res.locals.error   = req.flash("error");
+   res.locals.success = req.flash("success");
+   next();
+});
+
 app.use(bodyParser.urlencoded({
   extended: true
 }));
-// app.use(cookieParser('secret'));
-//app.use(express.session({ cookie: { maxAge: 60000 }}));
 app.set('view engine', 'ejs');
+io.on("connection",(socket)=>{
+  connected_socket = socket;
+});
 app.get('/',(req,res)=>{
-  res.render('index2');
+  res.render('home',{status:status,last_position:last_position,last_time:last_time});
+});
+app.get('/instruction',(req,res)=>{
+  res.render('instruction');
 });
-app.post('/new',(req,res)=>{
-  position = Object.getOwnPropertyNames(req.body)[0];
-  console.log(position);
-  console.log(typeof(position));
-  io.emit('welcome', { "data":position });
-  res.redirect('/bio');
+app.post('/new_ph',(req,res)=>{
+  last_position = Object.getOwnPropertyNames(req.body)[0];
+  res.io.emit('send_data', { "data":last_position });
+  //console.log(connected_socket.connected);
+  connected_socket.on('success',function(message){
+      console.log("success");
+      status = message;
+      writeHistory(); //store calibration history in a text file
+      req.flash("success",last_position);
+    });
+  connected_socket.on('error',function(){
+      console.log("error");
+      req.flash("error","Some error exists!! Try to recalibrate !!!");
+    });
+  setTimeout(function(){
+      //res.redirect('/bio');
+      connected_socket.removeAllListeners("success");
+      connected_socket.removeAllListeners("error");
+      res.redirect('/');
 
+    },6000)
 });
 
+
 server.listen(process.env.PORT || 9000, process.env.IP, function(){
     console.log("SERVER IS RUNNING!");
 })

Server/history.txt

@@ -0,0 +1 @@
+high;2018 Aug 14,10:23.34