Hello,
I have updated and reworked my scheduler Subflow and my Dashboard example flow for it.
Scheduler Subflow
This minimal Subflow works just like a node. It executes a schedule passed in as an array of objects:
[
{
"item": "test",
"command": "ON",
"time": "08:30"
},
{
"item": "test",
"command": "OFF",
"time": "19:45"
}
]
using only core nodes and setTimeout() to execute in minute accuracy on the minute.
It now supports an optional days property:
{
"item": "test",
"command": "ON",
"days": [1,2,6,7],
"time": "08:30"
}
so you can now define on exactly which day which object of the schedule should be executed. Commands can now be of type string, of type number or of type boolean.
It also reflects the next object to be executed accurately in its status:
Here is a minimal example:
[{"id":"dc275690.07356","type":"subflow","name":"scheduler","info":"A scheduler that repeatedly executes\nschedules put in as an array of objects\nas a ```msg.payload``` in the format of:\n```\n[\n {\n \"item\": \"test\",\n \"command\": \"ON\",\n \"time\": \"08:30\"\n },\n {\n \"item\": \"test\",\n \"command\": \"OFF\",\n \"time\": \"19:45\"\n }\n]\n```\nEach schedule object can also contain an optional ```days``` property:\n```\n {\n \"item\": \"test\",\n \"command\": \"ON\",\n \"days\": [1,2,6,7],\n \"time\": \"08:30\"\n }\n```\nthe ```days property``` has the format of\nan array. Each day that the schedule object \nshould be executed on has to be in the array.\nThe week starts with monday(1) and ends with\nsunday(7). So the example above would only be\nexecuted on monday, tuesday, saturday and\nsunday.\nYou can mix objects with and without a\ndays property in one schedule array.\n\nSending an **empty array** as a\n```msg.payload``` to the subflow will\nreset it.\nThe second output is a debug.\nSending a ```msg.payload``` string of **\"debug\"**\nwill send an object of the schedule and the\ncorresponding timers that are scheduled\nto this output.\nAt schedule time a ```msg``` object will be send\nfrom the first output. The command will be\npassed as the ```msg.payload```, the item in\n```msg.item``` and the original schedule object\nin ```msg.original```.\nThe subflows status will show the next item to \nbe executed once a schedule is set.","category":"","in":[{"x":80,"y":180,"wires":[{"id":"be194cd9.78b218"}]}],"out":[{"x":1720,"y":180,"wires":[{"id":"8eb795c0.24899","port":0}]},{"x":560,"y":120,"wires":[{"id":"6680ab33.f83b5c","port":0}]}],"env":[],"color":"#FFAAAA","inputLabels":["schedule input"],"outputLabels":["command output",""],"icon":"node-red/timer.svg","status":{"x":1320,"y":360,"wires":[{"id":"a0ba0058.4cf528","port":0},{"id":"3bf2be21.9401aa","port":1}]}},{"id":"f476595.aa436a8","type":"function","z":"dc275690.07356","name":"schedule function","func":"const schedule = msg.payload;\nif(typeof msg.payload === \"undefined\") return null;\nlet scheduled = context.scheduled || [];\nlet todelete = [];\nscheduled.forEach((item,index) => {\n if(!schedule.some(element => JSON.stringify(element) == JSON.stringify(item.schedule))){\n clearTimeout(item.timer);\n todelete.push(index);\n }\n})\nscheduled = scheduled.filter((item,index) => !todelete.includes(index));\ncontext.scheduled = scheduled;\nschedule.forEach(element => {\n const execute = element;\n const time = new Date();\n const timestamp = time.getTime();\n const hour = time.getHours();\n const minute = time.getMinutes();\n const year = time.getFullYear();\n const month = time.getMonth();\n const day = time.getDate();\n const inputS = execute.time.split(\":\");\n const hourS = parseInt(inputS[0]);\n const minuteS = parseInt(inputS[1]);\n if(typeof hourS != \"number\" || typeof minuteS != \"number\") return null;\n const timeS = new Date(year, month, day, hourS, minuteS);\n const timestampS = timeS.getTime();\n let timestampD = 0;\n if(timestampS >= timestamp){\n timestampD = timestampS - timestamp;\n } else {\n timestampD = (timestampS + 86400000) - timestamp;\n }\n let oldscheduled = context.scheduled;\n if(!oldscheduled.some(element => JSON.stringify(element.schedule) == JSON.stringify(execute))){\n const newtimer = setTimeout(()=>{\n let newscheduled = context.scheduled;\n const deleteindex = newscheduled.indexOf(newschedule);\n newscheduled.splice(deleteindex,1);\n node.send({payload:newschedule.schedule});\n context.scheduled = newscheduled;\n },timestampD);\n const newschedule = {\n runtime: timestampD,\n timer: newtimer,\n schedule: execute\n };\n oldscheduled.push(newschedule);\n context.scheduled = oldscheduled;\n }\n});\nconst sendscheduled = context.scheduled;\nmsg.topic = \"scheduled\";\nconst newmsg = sendscheduled.map(item => {\n return {schedule:item.schedule,runtime:item.runtime}\n});\nmsg.payload = newmsg;\nreturn msg;","outputs":1,"noerr":0,"x":970,"y":180,"wires":[["cd6382ee.28d1c8"]]},{"id":"a0ba0058.4cf528","type":"function","z":"dc275690.07356","name":"get next schedule item","func":"const schedule = flow.get(\"schedule\") || [];\nif(schedule.length === 0){\n msg.payload = \"no schedule yet\";\n return msg;\n}\nconst time = new Date();\nconst dayNames = [\"Monday\",\"Tuesday\",\"Wednesday\",\"Thursday\",\"Friday\",\"Saturday\",\"Sunday\"];\nlet day = time.getDay();\nif (day === 0) { day = 7; }\nlet hour = String(time.getHours());\nlet minute = String(time.getMinutes());\nif(hour.length == 1) hour = \"0\" + hour;\nif(minute.length == 1) minute = \"0\" + minute;\nlet hmtime = hour + \":\" + minute;\nlet found = false;\nlet nextindex = 0;\nfor(let a=0; a<7; a++){\n for(i=0;i<schedule.length;i++){\n if(hmtime < schedule[i].time){\n if(schedule[i].hasOwnProperty(\"days\")){\n if(schedule[i].days.includes(day)){\n nextindex = i;\n found = true;\n break;\n } else {\n continue;\n }\n } else {\n nextindex = i;\n found = true;\n break;\n }\n } else {\n continue;\n }\n }\n if(found){break;}\n if(a === 0){ hmtime = \"\"; }\n if (day < 7) {\n day += 1;\n } else {\n day = 1;\n }\n}\nmsg.payload = schedule[nextindex].item + \", \" + schedule[nextindex].command + \", \" + dayNames[day-1] + \", \" + schedule[nextindex].time;\nreturn msg;","outputs":1,"noerr":0,"x":1140,"y":360,"wires":[[]]},{"id":"7f1ec532.7fc8bc","type":"function","z":"dc275690.07356","name":"sort schedule and save to flow","func":"const oldschedule = msg.payload;\nlet newschedule = [];\noldschedule.forEach(element => {\n let newindex = null;\n if(newschedule.length > 0){\n for(i=0;i<newschedule.length-1;i++){\n if(element.time >= newschedule[i].time && element.time < newschedule[i+1].time){\n newindex = i+1;\n }\n }\n if(newindex !== null){\n newschedule.splice(newindex,0,element);\n } else if (element.time < newschedule[0].time){\n newschedule.splice(0,0,element);\n } else {\n newschedule.push(element);\n }\n } else {\n newschedule.push(element);\n }\n});\nflow.set(\"schedule\",newschedule);\nmsg.payload = newschedule;\nreturn msg;","outputs":1,"noerr":0,"x":670,"y":180,"wires":[["a0ba0058.4cf528","f476595.aa436a8"]]},{"id":"694a5ae3.e4714c","type":"inject","z":"dc275690.07356","name":"","topic":"","payload":"","payloadType":"date","repeat":"","crontab":"","once":true,"onceDelay":"1","x":410,"y":360,"wires":[["a0ba0058.4cf528","cf9ed7a2.81f21"]]},{"id":"be194cd9.78b218","type":"switch","z":"dc275690.07356","name":"","property":"payload","propertyType":"msg","rules":[{"t":"eq","v":"debug","vt":"str"},{"t":"else"}],"checkall":"true","repair":false,"outputs":2,"x":210,"y":180,"wires":[["6680ab33.f83b5c"],["3bf2be21.9401aa"]]},{"id":"8eb795c0.24899","type":"change","z":"dc275690.07356","name":"","rules":[{"t":"move","p":"payload","pt":"msg","to":"original","tot":"msg"},{"t":"set","p":"payload","pt":"msg","to":"original.command","tot":"msg"},{"t":"set","p":"item","pt":"msg","to":"original.item","tot":"msg"}],"action":"","property":"","from":"","to":"","reg":false,"x":1560,"y":180,"wires":[[]]},{"id":"cd6382ee.28d1c8","type":"switch","z":"dc275690.07356","name":"","property":"topic","propertyType":"msg","rules":[{"t":"eq","v":"scheduled","vt":"str"},{"t":"else"}],"checkall":"true","repair":false,"outputs":2,"x":1150,"y":180,"wires":[["7e108ed9.acbd88"],["a0ba0058.4cf528","280402d5.27b2f6","ab8f82a4.0079b"]]},{"id":"6680ab33.f83b5c","type":"change","z":"dc275690.07356","name":"","rules":[{"t":"delete","p":"payload","pt":"msg"},{"t":"set","p":"payload.schedule","pt":"msg","to":"schedule","tot":"flow"},{"t":"set","p":"payload.scheduled","pt":"msg","to":"scheduled","tot":"flow"}],"action":"","property":"","from":"","to":"","reg":false,"x":400,"y":120,"wires":[[]]},{"id":"cf9ed7a2.81f21","type":"trigger","z":"dc275690.07356","op1":"[]","op2":"schedule","op1type":"json","op2type":"flow","duration":"1","extend":false,"units":"s","reset":"","bytopic":"all","name":"","x":760,"y":240,"wires":[["f476595.aa436a8"]]},{"id":"7e108ed9.acbd88","type":"change","z":"dc275690.07356","name":"","rules":[{"t":"set","p":"scheduled","pt":"flow","to":"payload","tot":"msg"}],"action":"","property":"","from":"","to":"","reg":false,"x":1330,"y":120,"wires":[[]]},{"id":"280402d5.27b2f6","type":"trigger","z":"dc275690.07356","op1":"","op2":"schedule","op1type":"nul","op2type":"flow","duration":"1","extend":false,"units":"s","reset":"","bytopic":"all","name":"","x":960,"y":120,"wires":[["f476595.aa436a8"]]},{"id":"ab8f82a4.0079b","type":"function","z":"dc275690.07356","name":"today?","func":"if (msg.payload.hasOwnProperty(\"days\")) {\n const date = new Date();\n let day = date.getDay();\n if (day === 0) { day = 7; }\n if (msg.payload.days.includes(day)) {\n return msg;\n } else {\n return null;\n }\n}\nreturn msg;","outputs":1,"noerr":0,"x":1350,"y":180,"wires":[["8eb795c0.24899"]]},{"id":"3bf2be21.9401aa","type":"function","z":"dc275690.07356","name":"validate input","func":"let errorMsg = \"\";\nif(!Array.isArray(msg.payload)) {\n errorMsg = \"msg.payload should be an array of schedule items\";\n node.warn(errorMsg)\n msg.payload = errorMsg;\n return [null, msg];\n}\nfor(i=0;i<msg.payload.length;i++){\n if(typeof msg.payload[i] !== \"object\") {\n errorMsg = \"each array item should be an object\";\n node.warn(errorMsg)\n msg.payload = errorMsg;\n return [null, msg];\n }\n if(!msg.payload[i].hasOwnProperty(\"item\") || !msg.payload[i].hasOwnProperty(\"command\") || !msg.payload[i].hasOwnProperty(\"time\")) {\n errorMsg = \"each array item should contain a item, a command and time property\";\n node.warn(errorMsg)\n msg.payload = errorMsg;\n return [null, msg];\n }\n if(typeof msg.payload[i].item !== \"string\") {\n errorMsg = \"the items in each schedule should be given as a string\";\n node.warn(errorMsg)\n msg.payload = errorMsg;\n return [null, msg];\n }\n if(typeof msg.payload[i].command !== \"string\" && typeof msg.payload[i].command !== \"number\") {\n errorMsg = \"the commands in each schedule should be given as a string or a number\";\n node.warn(errorMsg)\n msg.payload = errorMsg;\n return [null, msg];\n }\n if(!msg.payload[i].time.match(/[0-2]\\d\\:[0-5]\\d/g)) {\n errorMsg = \"the time should be in hh:mm 24 hour format\";\n node.warn(errorMsg)\n msg.payload = errorMsg;\n return [null, msg];\n }\n if(msg.payload[i].hasOwnProperty(\"days\")) {\n if(!Array.isArray(msg.payload[i].days)) {\n errorMsg = \"days should be given as an array of integers\";\n node.warn(errorMsg)\n msg.payload = errorMsg;\n return [null, msg];\n }\n for(let c=0; c<msg.payload[i].days.length; c++){\n if(typeof msg.payload[i].days[c] !== \"number\"){\n errorMsg = \"days should be given as integers of type number\";\n node.warn(errorMsg)\n msg.payload = errorMsg;\n return [null, msg];\n }\n if(msg.payload[i].days[c] < 1 || msg.payload[i].days[c] > 7){\n errorMsg = \"days should be in the range of 1-7\";\n node.warn(errorMsg)\n msg.payload = errorMsg;\n return [null, msg];\n }\n }\n }\n}\nreturn [msg, null];","outputs":2,"noerr":0,"x":400,"y":180,"wires":[["7f1ec532.7fc8bc"],["ead6c623.14ffd"]]},{"id":"ead6c623.14ffd","type":"trigger","z":"dc275690.07356","op1":"","op2":"1","op1type":"nul","op2type":"str","duration":"2","extend":false,"units":"s","reset":"","bytopic":"all","name":"","x":760,"y":300,"wires":[["a0ba0058.4cf528"]]},{"id":"8fccfd5a.753d9","type":"subflow:dc275690.07356","z":"7df8e457.799894","name":"","env":[],"x":520,"y":2940,"wires":[["8ffad206.67db6"],["3f8211e7.0e2ce6"]]},{"id":"7e735ac9.9494f4","type":"inject","z":"7df8e457.799894","name":"inject schedule","topic":"","payload":"[{\"command\":\"ON\",\"item\":\"test\",\"time\":\"09:28\"},{\"command\":\"OFF\",\"item\":\"test\",\"days\":[1,2,6,7],\"time\":\"11:50\"}]","payloadType":"json","repeat":"","crontab":"","once":true,"onceDelay":"1","x":340,"y":2920,"wires":[["8fccfd5a.753d9"]]},{"id":"8ffad206.67db6","type":"debug","z":"7df8e457.799894","name":"","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"true","targetType":"full","x":670,"y":2900,"wires":[]},{"id":"2faea919.87d7be","type":"inject","z":"7df8e457.799894","name":"","topic":"","payload":"debug","payloadType":"str","repeat":"","crontab":"","once":false,"onceDelay":0.1,"x":370,"y":2880,"wires":[["8fccfd5a.753d9"]]},{"id":"3f8211e7.0e2ce6","type":"debug","z":"7df8e457.799894","name":"debug output","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"payload","targetType":"msg","x":700,"y":2980,"wires":[]},{"id":"e55383b2.139f68","type":"inject","z":"7df8e457.799894","name":"reset","topic":"","payload":"[]","payloadType":"json","repeat":"","crontab":"","once":false,"onceDelay":0.1,"x":370,"y":3000,"wires":[["8fccfd5a.753d9"]]},{"id":"d61e7fb7.a9313","type":"inject","z":"7df8e457.799894","name":"schedule with error","topic":"","payload":"[{\"command\":\"ON\",\"item\":\"test\",\"time\":\"09:28\"},{\"command\":\"OFF\",\"item\":\"test\",\"days\":[1,2,6,7,8],\"time\":\"11:50\"}]","payloadType":"json","repeat":"","crontab":"","once":false,"onceDelay":"1","x":350,"y":2960,"wires":[["8fccfd5a.753d9"]]}]
It also validates your input schedule that you send in. If you set the inject that injects the schedule to inject once on deploy it will be running even if you restart Nodered. The full description and all functions can be found in the info panel or if you click the link above.
Johannes
but fortunately i have done all the work already (needs node-red-ui-table):
