[{"id":"ba386057.845d3","type":"mqtt-broker","broker":"192.168.0.58","port":"1883","clientid":"Opensprinkler"},{"id":"39eb56aa.c614aa","type":"emoncms-server","server":"http://192.168.0.58/emoncms","name":"Locally Hosted Emoncms"},{"id":"1b8d1377.e472ed","type":"mqtt-broker","broker":"192.168.0.182","port":"1883","clientid":"Opensprinkler"},{"id":"3a893528.c576ca","type":"mqtt in","name":"Returns/errors from API calls","topic":"OSPI/api-response","broker":"1b8d1377.e472ed","x":211.2972869873047,"y":461.5810241699219,"z":"d3ee92b5.2c117","wires":[["2cfd5217.d302ae","3da446dc.c25bba"]]},{"id":"2cfd5217.d302ae","type":"function","name":"fnSendtoXBMC","func":"var paylmqtt =  msg.payload;\nvar topicstr = msg.topic;\n// This is a lvl 2 topic\n// check if there is no payload. If you send a message to a topic with no payload,\n// with retain = true, it will clear retained messages for that topic.\nif (msg.payload == null) {\n   return null;\n   }\n\noutmsg = msg;\npayloadmqtto = '\"{\"lvl\":\"2\",\"sub\":\"';\npayloadmqtto = payloadmqtto +   topicstr + '\",';\npayloadmqtto = payloadmqtto + '\"txt\":\"'+paylmqtt+'\",\"img\":\"/home/pi/.xbmc/userdata/Thumbnails/background.png\",\"delay\": \"30000\"}';\noutmsg.payload = payloadmqtto;\noutmsg.topic = \"Home/xbmc1\";\nreturn  [outmsg];","outputs":1,"x":444.5926094055176,"y":430.06917572021484,"z":"d3ee92b5.2c117","wires":[["55c4e9fc.aa3b18"]]},{"id":"e5a6b31.f1a595","type":"mqtt in","name":"Someone logged on lg","topic":"OSPI/lg","broker":"1b8d1377.e472ed","x":191.69968032836914,"y":516.9102554321289,"z":"d3ee92b5.2c117","wires":[["89518f2f.76ae7"]]},{"id":"9e131c10.61ece","type":"emoncms","name":"Log runtimes on Emoncms","emonServer":"39eb56aa.c614aa","nodegroup":"25","x":835.4378852844238,"y":694.2833347320557,"z":"d3ee92b5.2c117","wires":[]},{"id":"dc704ba2.238fb8","type":"comment","name":"Respond to events","info":"Here the MQTT messages that are sent from OSPi are subscribed to, \nreformatted for the appropriate recipient,  and sent off.\n\nTo add eg an email message whenever a station starts, simply add another\nflow, subscribing to the start message, create a function to reformat the message \nfor email and pass the message to the email node. Same for twitter etc.\n","x":125.35440063476562,"y":277.9460105895996,"z":"d3ee92b5.2c117","wires":[]},{"id":"89518f2f.76ae7","type":"e-mail","server":"smtp.gmail.com","port":"465","name":"user@domain","dname":"Send to email","x":799.8905029296875,"y":517.0889616012573,"z":"d3ee92b5.2c117","wires":[]},{"id":"ada665bf.525998","type":"mqtt in","name":"System rebooted rb","topic":"OSPI/rb","broker":"1b8d1377.e472ed","x":185.43809509277344,"y":335.27938175201416,"z":"d3ee92b5.2c117","wires":[["4b647220.b49b8c","91e9124b.6e16f"]]},{"id":"91e9124b.6e16f","type":"e-mail","server":"smtp.gmail.com","port":"465","name":"user@domain","dname":"Send email","x":792.2595825195312,"y":334.05312728881836,"z":"d3ee92b5.2c117","wires":[]},{"id":"4b647220.b49b8c","type":"function","name":"fnSendrbtoXBMC","func":"var paylmqtt =  msg.payload;\nvar topicstr = msg.topic;\n// check if there is no payload. If you send a message to a topic with no payload,\n// with retain = true, it will clear retained messages for that topic.\nif (msg.payload == null) {\n   return null;\n   }\n\n// This is a lvl 2 topic\noutmsg = msg;\npayloadmqtto = '\"{\"lvl\":\"2\",\"sub\":\"';\npayloadmqtto = payloadmqtto +   topicstr + '\",';\npayloadmqtto = payloadmqtto + '\"txt\":\"'+paylmqtt+'\",\"img\":\"/home/pi/.xbmc/userdata/Thumbnails/background.png\",\"delay\": \"30000\"}';\noutmsg.payload = payloadmqtto;\noutmsg.topic = \"Home/xbmc1\";\nreturn  [outmsg];","outputs":1,"x":446.6286315917969,"y":366.3270263671875,"z":"d3ee92b5.2c117","wires":[["770dd5a1.88f22c"]]},{"id":"55c4e9fc.aa3b18","type":"mqtt out","name":"Send  errorsto XBMC","topic":"Home/ospi","qos":"0","retain":"false","broker":"ba386057.845d3","x":816.8070678710938,"y":430.0531406402588,"z":"d3ee92b5.2c117","wires":[]},{"id":"f049f8bc.0fb608","type":"mqtt in","name":"Station Name Change (sc)","topic":"OSPI/sc","broker":"1b8d1377.e472ed","x":194.34288787841797,"y":773.8983726501465,"z":"d3ee92b5.2c117","wires":[["62924919.9d6db8","3e638abc.c19c76"]]},{"id":"62924919.9d6db8","type":"function","name":"fnSendsctoXBMC","func":"var paylmqtt =  msg.payload;\nvar topicstr = msg.topic;\n// This is a lvl 2 topic\n// check if there is no payload. If you send a message to a topic with no payload,\n// with retain = true, it will clear retained messages for that topic.\nif (msg.payload == null) {\n   return null;\n   }\n\noutmsg = msg;\npayloadmqtto = '\"{\"lvl\":\"2\",\"sub\":\"';\npayloadmqtto = payloadmqtto +   topicstr + '\",';\npayloadmqtto = payloadmqtto + '\"txt\":\"'+paylmqtt+'\",\"img\":\"/home/pi/.xbmc/userdata/Thumbnails/background.png\",\"delay\": \"30000\"}';\noutmsg.payload = payloadmqtto;\noutmsg.topic = \"Home/xbmc1\";\nreturn  [outmsg];","outputs":1,"x":406.2953567504883,"y":803.7316989898682,"z":"d3ee92b5.2c117","wires":[["f21d8bc8.0de278"]]},{"id":"3e638abc.c19c76","type":"e-mail","server":"smtp.gmail.com","port":"465","name":"user@domain","dname":"Station change to email","x":827.4857559204102,"y":771.4936256408691,"z":"d3ee92b5.2c117","wires":[]},{"id":"cf0639bd.30f9c8","type":"function","name":"fnBuildurl","func":"// The received message is stored in 'msg'\n// It will have at  least a 'payload' property:\n\n// The payload of the injected message contains the hostname and port\n// of the OSPI as csv's\n\nmsgo = msg;\ncontext.host=msg.payload.split(\",\");\n\nmsgo.url = 'http://' + context.host[0] +':' + context.host[1] + '/gv?pw=' + context.host[2];\nmsgo.payload = msgo.url+ \" Get GV variables \";\n\nreturn [msgo]","outputs":"1","x":370.66663360595703,"y":99.90475654602051,"z":"d3ee92b5.2c117","wires":[["6b26b597.94d94c"]]},{"id":"1c4a359b.e3b5ca","type":"function","name":"fnProcessOSPIhttpresponse","func":"// Messages returned \n\n//  - errors\n\n// First  response processed is from OSPi (to /gv?pw=...  - get station names\n\n// This function just loads global variables that mirror the gv variables from OSPi\n\nomsg = msg;\ntopic = msg.topic;\nstatusCode = msg.statusCode;\n\nif (statusCode != 200 ) {\n\n// This error processing does not handle the case when there is no response from OSPI\n\n// Still need to get the api data, so retry \n// need to count errors, and do something when there are too many\n// will add more error processing.  For now just return and try again\n// the error message will go to MQTT\n\n     msg.topic   = \"OSPI/api-response\";\n     msg.payload = \"Error reaching server - code \" + statusCode;\n     return [omsg];\n} \ncontext.global.runtm = [\"0\",\"0\",\"0\",\"0\",\"0\",\"0\",\"0\",\"0\"];\nmsg.runtm = context.global.runtm[0];\ncontext.global.gmtnow = msg.payload.gmtnow;\ncontext.global.lrun   = msg.payload.lrun;\ncontext.global.now    = msg.payload.now;\ncontext.global.pd     = msg.payload.pd;\ncontext.global.pon    = msg.payload.pon;\ncontext.global.rovals = msg.payload.rovals;\ncontext.global.ps     = msg.payload.ps;\ncontext.global.rs     = msg.payload.rs;\ncontext.global.sbits  = msg.payload.sbits;\ncontext.global.scount = msg.payload.scount;\ncontext.global.sd     = msg.payload.sd;\ncontext.global.snames = msg.payload.snames;\ncontext.global.srvals = msg.payload.srvals;\nnst = context.global.sd['nst'];\n//for (i=0,i<nst,i++) {\n//    context.global.runtime[i] = \"0\";\n//}\n\n \n// Thats it. Wait for messages to come through. These globals represent the current state of the OSPi system.\n// They can be used to detect changes in the state, but should be updated when a change is detected.\n\nreturn [null];\n  \n\n\n\n","outputs":"1","x":588.8568725585938,"y":239.02261352539062,"z":"d3ee92b5.2c117","wires":[["5b94d2cc.a46b2c"]]},{"id":"c97eb820.368148","type":"json","name":"Json ","x":493.2045669555664,"y":193.91783714294434,"z":"d3ee92b5.2c117","wires":[["1c4a359b.e3b5ca"]]},{"id":"6b26b597.94d94c","type":"http request","name":"http request","method":"GET","url":"","x":444.3687629699707,"y":146.58204078674316,"z":"d3ee92b5.2c117","wires":[["c97eb820.368148"]]},{"id":"5b94d2cc.a46b2c","type":"mqtt out","name":"Errors in API","topic":"","qos":"0","retain":"false","broker":"ba386057.845d3","x":791.7735214233398,"y":238.87972450256348,"z":"d3ee92b5.2c117","wires":[]},{"id":"a555db69.5aaa28","type":"comment","name":"Initialisation and polling","info":"\nHere a http://host:port/gv?pw=password is sent to get the current state\n\n\nThe process is  \nBuild the URL\nSend the HTTP request\nPut the response through the JSON Node \n    (I have no idea what this does but the next function crashes if I dont).\nProcess the response - which sets the global context variables that mirror the gv values of OSPi.\n\nThis inject node runs hourly, so that if no response is received an email can be \nsent to notify me of the fact that the OSPi system is not responding.","x":135.62105560302734,"y":54.57014083862305,"z":"d3ee92b5.2c117","wires":[]},{"id":"78c24b67.873db4","type":"inject","name":"Hourly poll","topic":"OSPI/poll","payload":"192.168.0.182,8080,opendoor","payloadType":"string","repeat":"3600","crontab":"","once":true,"x":118.0972671508789,"y":100.73680686950684,"z":"d3ee92b5.2c117","wires":[["cf0639bd.30f9c8"]]},{"id":"f666ed2d.09991","type":"mqtt in","name":"Zone changes zc","topic":"OSPI/zc","broker":"1b8d1377.e472ed","x":172.80954360961914,"y":631.4761791229248,"z":"d3ee92b5.2c117","wires":[["da9ee197.25612"]]},{"id":"db83c9ab.247c38","type":"comment","name":"Something started or stopped","info":"There has been a change in the station run table\n\nCheck it against the global variables global.context.sn to see which one.\nIf it is a change in the master valve ignore it.\n\nIf it is a station starting, save its start time. Send a message to XBMC, email\n\nIf it is stopping, calculate its run time, send to Emoncms. Send a message to XBMC, email\n\n\n \n\n. ","x":158.6667251586914,"y":579.476203918457,"z":"d3ee92b5.2c117","wires":[]},{"id":"da9ee197.25612","type":"function","name":"Zone change","func":"// This module uses snames, mas, nst, srvals\n// Time - first 24 characters of message payload.\n// Ignore messages where the payload is null. These are probably clearing retained messages\n//if (msg.payload == null) {\n//    msg.err = \"null message\";\n//    return msg;\n//    };\n\nmsgTime = msg.payload.slice(0,24);\nmsgo = msg;\n\n// The rest of the message \n// there is a \" ,\" after the time\ntemp = msg.payload.slice(26,51);\ntemp = temp.replace('[','');\ntemp = temp.replace(']','');\nsrvals  = temp.split(\",\").map(Number);\nmas = context.global.sd['mas'];\nif (mas == 0) { mas=999;}\nmas = mas - 1;\nnst = context.global.sd['nst'];\nmsgo.payload =\"Empty\";\nfor (i=0;i<nst;i++) {\n\n    if ((srvals[i] != context.global.srvals[i]) && (i != mas)) {\n\n// It has turned on/off and is not the master valve\n\n        if (srvals[i] == 1) {        \n           \n            //  It turned on -  send message, save srvals, save start time\n            msgo.payload = msgTime + \" \" + context.global.snames[i] + \" turned on\";\n            context.global.srvals = srvals;\n            context.starttime = Date.parse(msgTime);\n            return msgo;           \n        }\n\n        if (srvals[i] == 0) {\n\n// It turned off  calculate run time, save srvals and get message ready\n          \n            msgo.payload = msgTime + \" \" + context.global.snames[i] + \" turned off. Run time = \";\n \n            duration = Date.parse(msgTime) - context.starttime;\n// convert it to decimal minutes\n            duration_minutes = ((duration/1000)/60).toFixed(2);\n        \n            msgo.payload += duration_minutes + \" minutes\";\n            msgo.minutes = duration;\n// store the run time in a format ready for fnsendtoEmoncms\n//      eg [0,0,0,10.02,0,0,0,0]  when the 4th station ran for 10.02 minutes\n            for (j=0;j<nst;j++){\n                context.global.runtm[j] = \"0\";\n                if (context.global.srvals[j] != 0) { \n                    context.global.runtm[j] = duration_minutes;\n                }\n            }\n            context.global.srvals = srvals;\n        }\n    }\n}\nmsgo.topic = \"OSPI/start-stop\"\nmsgo.runtime = context.global.runtm[4];\n// It can happen that the master valve will turn on then the station valve\n// Ignore the master valve event\n\nif (msgo.payload == \"Empty\") {\n   return null;\n   }\nreturn msgo;","outputs":1,"x":373.4381561279297,"y":631.00963306427,"z":"d3ee92b5.2c117","wires":[["d3addb22.2c5228","6c818033.937e8","1ee6c088.e1193f"]]},{"id":"d3addb22.2c5228","type":"e-mail","server":"smtp.gmail.com","port":"465","name":"user@domain","dname":"Send start/stop email","x":818.6405258178711,"y":631.4976482391357,"z":"d3ee92b5.2c117","wires":[]},{"id":"6c818033.937e8","type":"function","name":"fnSendtoEmoncms (4)","func":"paylmqtt =  msg.payload;\ntopicstr = msg.topic;\n// could be just clearing retained messages\nif (msg.payload == null) {\n    return null;\n    } \nmsg.topic = \"25\";\nmsg.runtime = context.global.runtm[4];\npaylmqtto =  \"[\"+context.global.runtm[0]+\",\" +context.global.runtm[1];\npaylmqtto += \",\"+context.global.runtm[2]+\",\" +context.global.runtm[3];\npaylmqtto += \",\"+context.global.runtm[4]+\",\" +context.global.runtm[5];\npaylmqtto += \",\"+context.global.runtm[6]+\",\" +context.global.runtm[7]+\"]\";\n\nmsg.payload = paylmqtto;\nreturn [msg];\n","outputs":1,"x":574.2000732421875,"y":694.104850769043,"z":"d3ee92b5.2c117","wires":[["9e131c10.61ece"]]},{"id":"1ee6c088.e1193f","type":"function","name":"fnSendtoXBMC","func":"var paylmqtt =  msg.payload;\nvar topicstr = msg.topic;\n// This is a lvl 1 topic\noutmsg = msg;\npayloadmqtto = '{\"lvl\":\"1\",\"sub\":'\npayloadmqtto = payloadmqtto + '\"' + topicstr + '\",';\npayloadmqtto = payloadmqtto + '\"txt\":\"'+paylmqtt+'\",\"img\":\"/home/pi/.xbmc/userdata/Thumbnails/background.png\",\"delay\": \"20000\"}';\noutmsg.payload = payloadmqtto;\noutmsg.topic = \"Home/ospi\";\nreturn  outmsg;","outputs":1,"x":551.1285209655762,"y":664.0214548110962,"z":"d3ee92b5.2c117","wires":[["e393b751.1c6c48"]]},{"id":"3da446dc.c25bba","type":"e-mail","server":"smtp.gmail.com","port":"465","name":"user@domain","dname":"Send errors to email","x":817.53564453125,"y":461.34527587890625,"z":"d3ee92b5.2c117","wires":[]},{"id":"770dd5a1.88f22c","type":"mqtt out","name":"Send rebooted to XBMC","topic":"Home/ospi","qos":"0","retain":"false","broker":"ba386057.845d3","x":832.8571586608887,"y":366.19046688079834,"z":"d3ee92b5.2c117","wires":[]},{"id":"f21d8bc8.0de278","type":"mqtt out","name":"Send SC to XBMC","topic":"Home/ospi","qos":"0","retain":"false","broker":"ba386057.845d3","x":814.2857894897461,"y":802.3334503173828,"z":"d3ee92b5.2c117","wires":[]},{"id":"e393b751.1c6c48","type":"mqtt out","name":"Send Zone Change to XBMC ","topic":"Home/ospi","qos":"0","retain":"false","broker":"ba386057.845d3","x":842.3810653686523,"y":663.2381477355957,"z":"d3ee92b5.2c117","wires":[]},{"id":"f245f205.0dba1","type":"comment","name":"Someone changed something","info":"","x":157.90480041503906,"y":729.5714244842529,"z":"d3ee92b5.2c117","wires":[]}]