From 144dfadfcb32085027fbd0b96eb4a167f2088363 Mon Sep 17 00:00:00 2001
From: waelkh12 <waelkhlifi12@gmail.com>
Date: Wed, 17 Apr 2024 00:21:26 +0100
Subject: [PATCH] added_mqtt_interface
---
zigbee_node_red.json | 599 +++++++-------------------------------
zigbee_node_red_cred.json | 3 +-
2 files changed, 104 insertions(+), 498 deletions(-)
diff --git a/zigbee_node_red.json b/zigbee_node_red.json
index e9bb548..246092b 100644
--- a/zigbee_node_red.json
+++ b/zigbee_node_red.json
@@ -7,14 +7,6 @@
"info": "",
"env": []
},
- {
- "id": "c2dd626a86cc6cc4",
- "type": "tab",
- "label": "Flow 1",
- "disabled": true,
- "info": "",
- "env": []
- },
{
"id": "9355c4bbb1adc9e0",
"type": "mqtt-broker",
@@ -46,6 +38,37 @@
"userProps": "",
"sessionExpiry": ""
},
+ {
+ "id": "ff246c28cc0fa0af",
+ "type": "mqtt-broker",
+ "name": "mqtt_broker",
+ "broker": "mqtt://192.168.1.105",
+ "port": "1883",
+ "clientid": "",
+ "autoConnect": true,
+ "usetls": false,
+ "protocolVersion": "4",
+ "keepalive": "60",
+ "cleansession": true,
+ "autoUnsubscribe": true,
+ "birthTopic": "",
+ "birthQos": "0",
+ "birthRetain": "false",
+ "birthPayload": "",
+ "birthMsg": {},
+ "closeTopic": "",
+ "closeQos": "0",
+ "closeRetain": "false",
+ "closePayload": "",
+ "closeMsg": {},
+ "willTopic": "",
+ "willQos": "0",
+ "willRetain": "false",
+ "willPayload": "",
+ "willMsg": {},
+ "userProps": "",
+ "sessionExpiry": ""
+ },
{
"id": "5504d7e57750a247",
"type": "mqtt in",
@@ -235,7 +258,7 @@
"id": "ef89c69c7929cec3",
"type": "opcua-compact-server",
"z": "2df1dfd158b253ed",
- "port": "54844",
+ "port": "4840",
"endpoint": "",
"productUri": "",
"acceptExternalCommands": true,
@@ -254,8 +277,8 @@
"xmlsetsOPCUA": [],
"publicCertificateFile": "",
"privateCertificateFile": "",
- "registerServerMethod": "2",
- "discoveryServerEndpointUrl": "opc.tcp://localhost:54840",
+ "registerServerMethod": "1",
+ "discoveryServerEndpointUrl": "opc.tcp://192.168.1.105:4840",
"capabilitiesForMDNS": "",
"maxNodesPerRead": 1000,
"maxNodesPerWrite": 1000,
@@ -266,7 +289,7 @@
"delayToInit": 1000,
"delayToClose": 200,
"serverShutdownTimeout": 100,
- "addressSpaceScript": "function constructAlarmAddressSpace(server, addressSpace, eventObjects, done) {\n // server = the created node-opcua server\n // addressSpace = address space of the node-opcua server\n // eventObjects = add event variables here to hold them in memory from this script\n\n // internal sandbox objects are:\n // node = the compact server node,\n // coreServer = core compact server object for debug and access to NodeOPCUA\n // this.sandboxNodeContext = node context node-red\n // this.sandboxFlowContext = flow context node-red\n // this.sandboxGlobalContext = global context node-red\n // this.sandboxEnv = env variables\n // timeout and interval functions as expected from nodejs\n\n \n const opcua = coreServer.choreCompact.opcua;\n const LocalizedText = opcua.LocalizedText;\n const namespace = addressSpace.getOwnNamespace();\n\n const Variant = opcua.Variant;\n const DataType = opcua.DataType;\n const DataValue = opcua.DataValue;\n\n var flexServerInternals = this;\n\n \n const rootFolder = addressSpace.findNode(\"RootFolder\");\n\n this.sandboxFlowContext.set(\"Humidity\", false);\n this.sandboxFlowContext.set(\"Temperature\", false);\n\n const sensor_Data = namespace.addFolder(rootFolder.objects, {\n \"browseName\": \"Sensor_data\"\n });\n const temperature = namespace.addFolder(sensor_Data, {\n \"browseName\": \"temperature\"\n });\n const humidity = namespace.addFolder(sensor_Data, {\n \"browseName\": \"humidity\"\n });\n const temperature_float = namespace.addFolder(temperature, {\n \"browseName\": \"Float_C\"\n });\n const humidity_float = namespace.addFolder(humidity, {\n \"browseName\": \"humidity_%\"\n });\n const tempCritical = namespace.addFolder(sensor_Data, {\n \"browseName\": \"Temp_critical\"\n });\n const humidityCritical = namespace.addFolder(sensor_Data, {\n \"browseName\": \"Humidity_critical\"\n });\n const temperature_var = namespace.addVariable({\n \"organizedBy\": temperature_float,\n \"browseName\": \"temperature\",\n \"nodeId\": \"ns=1;s=Temperature_value\",\n \"dataType\": \"Double\",\n \"value\": {\n \"get\": function () {\n return new Variant({\n \"dataType\": DataType.Double,\n \"value\": flexServerInternals.sandboxFlowContext.get(\"Temperature\")\n });\n },\n \"set\": function (Variant) {\n flexServerInternals.sandboxFlowContext.set(\n \"Temperature\",\n Variant.value\n );\n return opcua.StatusCodes.Good;\n }\n }\n });\n const humidity_var = namespace.addVariable({\n \"organizedBy\": humidity_float,\n \"browseName\": \"Humidity\",\n \"nodeId\": \"ns=1;s=Humidity_value\",\n \"dataType\": \"Double\",\n \"value\": {\n \"get\": function () {\n return new Variant({\n \"dataType\": DataType.Double,\n \"value\": flexServerInternals.sandboxFlowContext.get(\"Humidity\")\n });\n },\n \"set\": function (Variant) {\n flexServerInternals.sandboxFlowContext.set(\n \"Humidity\",\n Variant.value\n );\n return opcua.StatusCodes.Good;\n }\n }\n });\n const temperatureCritical = namespace.addVariable({\n \"organizedBy\": tempCritical,\n \"browseName\": \"Value\",\n \"nodeId\": \"ns=1;s=Temp_critical_value\",\n \"dataType\": \"Boolean\",\n \"value\": {\n \"get\": function () {\n return new Variant({\n \"dataType\": DataType.Boolean,\n \"value\": flexServerInternals.sandboxFlowContext.get(\"temp_critical\")\n });\n },\n \"set\": function (variant) {\n flexServerInternals.sandboxFlowContext.set(\n \"temp_critical\",\n variant.value\n );\n return opcua.StatusCodes.Good;\n }\n }\n });\n\n \n \n done();\n}",
+ "addressSpaceScript": "function constructAlarmAddressSpace(server, addressSpace, eventObjects, done) {\n // server = the created node-opcua server\n // addressSpace = address space of the node-opcua server\n // eventObjects = add event variables here to hold them in memory from this script\n\n // internal sandbox objects are:\n // node = the compact server node,\n // coreServer = core compact server object for debug and access to NodeOPCUA\n // this.sandboxNodeContext = node context node-red\n // this.sandboxFlowContext = flow context node-red\n // this.sandboxGlobalContext = global context node-red\n // this.sandboxEnv = env variables\n // timeout and interval functions as expected from nodejs\n\n \n const opcua = coreServer.choreCompact.opcua;\n const LocalizedText = opcua.LocalizedText;\n const namespace = addressSpace.getOwnNamespace();\n\n const Variant = opcua.Variant;\n const DataType = opcua.DataType;\n const DataValue = opcua.DataValue;\n\n var flexServerInternals = this;\n\n \n const rootFolder = addressSpace.findNode(\"RootFolder\");\n\n this.sandboxFlowContext.set(\"Humidity\", false);\n this.sandboxFlowContext.set(\"Temperature\", false);\n this.sandboxFlowContext.set(\"critical_temperature\", false);\n this.sandboxFlowContext.set(\"critical_humidity\", false);\n\n const sensor_Data = namespace.addFolder(rootFolder.objects, {\n \"browseName\": \"Sensor_data\"\n });\n const temperature = namespace.addFolder(sensor_Data, {\n \"browseName\": \"temperature\"\n });\n const humidity = namespace.addFolder(sensor_Data, {\n \"browseName\": \"humidity\"\n });\n const temperature_float = namespace.addFolder(temperature, {\n \"browseName\": \"Float_C\"\n });\n const humidity_float = namespace.addFolder(humidity, {\n \"browseName\": \"humidity_%\"\n });\n const tempCritical = namespace.addFolder(sensor_Data, {\n \"browseName\": \"Temp_critical\"\n });\n const humidityCritical = namespace.addFolder(sensor_Data, {\n \"browseName\": \"Humidity_critical\"\n });\n const temperature_var = namespace.addVariable({\n \"organizedBy\": temperature_float,\n \"browseName\": \"temperature\",\n \"nodeId\": \"ns=1;s=Temperature_value\",\n \"dataType\": \"Double\",\n \"value\": {\n \"get\": function () {\n return new Variant({\n \"dataType\": DataType.Double,\n \"value\": flexServerInternals.sandboxFlowContext.get(\"Temperature\")\n });\n },\n \"set\": function (Variant) {\n flexServerInternals.sandboxFlowContext.set(\n \"Temperature\",\n Variant.value\n );\n return opcua.StatusCodes.Good;\n }\n }\n });\n const humidity_var = namespace.addVariable({\n \"organizedBy\": humidity_float,\n \"browseName\": \"Humidity\",\n \"nodeId\": \"ns=1;s=Humidity_value\",\n \"dataType\": \"Double\",\n \"value\": {\n \"get\": function () {\n return new Variant({\n \"dataType\": DataType.Double,\n \"value\": flexServerInternals.sandboxFlowContext.get(\"Humidity\")\n });\n },\n \"set\": function (Variant) {\n flexServerInternals.sandboxFlowContext.set(\n \"Humidity\",\n Variant.value\n );\n return opcua.StatusCodes.Good;\n }\n }\n });\n const temperatureCritical = namespace.addVariable({\n \"organizedBy\": tempCritical,\n \"browseName\": \"Value\",\n \"nodeId\": \"ns=1;s=Temp_critical_value\",\n \"dataType\": \"Boolean\",\n \"value\": {\n \"get\": function () {\n return new Variant({\n \"dataType\": DataType.Boolean,\n \"value\": flexServerInternals.sandboxFlowContext.get(\"critical_temperature\")\n });\n },\n \"set\": function (variant) {\n flexServerInternals.sandboxFlowContext.set(\n \"critical_temperature\",\n variant.value\n );\n return opcua.StatusCodes.Good;\n }\n }\n });\n\n const humidityCrit = namespace.addVariable({\n \"organizedBy\": humidityCritical,\n \"browseName\": \"Value\",\n \"nodeId\": \"ns=1;s=Humidity_critical_value\",\n \"dataType\": \"Boolean\",\n \"value\": {\n \"get\": function () {\n return new Variant({\n \"dataType\": DataType.Boolean,\n \"value\": flexServerInternals.sandboxFlowContext.get(\"critical_humidity\")\n });\n },\n \"set\": function (variant) {\n flexServerInternals.sandboxFlowContext.set(\n \"critical_humidity\",\n variant.value\n );\n return opcua.StatusCodes.Good;\n }\n }\n });\n\n \n done();\n}",
"x": 540,
"y": 1120,
"wires": []
@@ -276,7 +299,7 @@
"type": "function",
"z": "2df1dfd158b253ed",
"name": "Check Temperature and Humidity",
- "func": "// Define the acceptable range for temperature and humidity\nconst minTemperature = 10; // Minimum temperature\nconst maxTemperature = 20; // Maximum temperature\nconst criticatemp = 20; // critical temperature \nconst minHumidity = 30; // Minimum humidity\nconst maxHumidity = 40; // Maximum humidity\nconst critichumidity =80; // critical value for humidity\n// Get the incoming message payload\nvar temperature = global.get('temperature'); // Get temperature from global context\nvar humidity = global.get('humidity'); // Get humidity from global context\n// set global variables that can be used by opc_server\n\n\n// Initialize payload as a JSON object\nvar data = {\n timestamp: Date.now(),\n temperature: temperature,\n humidity: humidity,\n criticalhumidity : false,\n criticaltemp : false,\n temperatureEvent: \"\",\n humidityEvent: \"\",\n turnAC: false // Initialize turn AC variable\n};\nglobal.set(\"critical_humidity\", data.criticalhumidity);\nglobal.set(\"critical_temperature\", data.criticaltemp);\n\n// Check if temperature is within the acceptable range\nif (temperature < minTemperature) {\n // Temperature is below the acceptable range\n data.temperatureEvent = \"Below Min\";\n} else if (temperature > maxTemperature) {\n // Temperature is above the acceptable range\n data.temperatureEvent = \"Above Max\";\n \n}\nelse if (temperature > criticatemp) {\n // Humidity is above the acceptable range\n data.criticaltemp= true;\n }\nelse {\n msg.payload.temperatureEvent = \"No action\"\n }\n// Check if humidity is within the acceptable range\nif (humidity < minHumidity) {\n // Humidity is below the acceptable range\n data.humidityEvent = \"Below Min\";\n} else if (humidity > maxHumidity) {\n // Humidity is above the acceptable range\n data.humidityEvent = \"Above Max\";\n }\n \n\nelse {\n data.humidityEvent = \"No action\"\n }\n\n// Set turn AC variable based on conditions\nif (data.temperatureEvent === \"Above Max\" || data.humidityEvent === \"Above Max\" || data.criticaltemp==true) {\n data.turnAC = true; // Turn on AC\n} else {\n data.turnAC = false; // Turn off AC\n}\n\n\n\n// Return message\nreturn {payload: data};",
+ "func": "// Define the acceptable range for temperature and humidity\nconst minTemperature = 10; // Minimum temperature\nconst maxTemperature = 20; // Maximum temperature\nconst criticatemp = 20; // critical temperature \nconst minHumidity = 30; // Minimum humidity\nconst maxHumidity = 40; // Maximum humidity\nconst critichumidity =80; // critical value for humidity\n// Get the incoming message payload\nvar temperature = global.get('temperature'); // Get temperature from global context\nvar humidity = global.get('humidity'); // Get humidity from global context\n// set global variables that can be used by opc_server\n\n\n// Initialize payload as a JSON object\nvar data = {\n timestamp: Date.now(),\n temperature: temperature,\n humidity: humidity,\n criticalhumidity : false,\n criticaltemp : false,\n temperatureEvent: \"\",\n humidityEvent: \"\",\n turnAC: false // Initialize turn AC variable\n};\n\n\n// Check if temperature is within the acceptable range\nif (temperature < minTemperature) {\n // Temperature is below the acceptable range\n data.temperatureEvent = \"Below Min\";\n} else if (temperature > maxTemperature) {\n // Temperature is above the acceptable range\n data.temperatureEvent = \"Above Max\";\n \n}\nelse if (temperature > criticatemp) {\n // Humidity is above the acceptable range\n data.criticaltemp= true;\n }\nelse {\n msg.payload.temperatureEvent = \"No action\"\n }\n// Check if humidity is within the acceptable range\nif (humidity < minHumidity) {\n // Humidity is below the acceptable range\n data.humidityEvent = \"Below Min\";\n} else if (humidity > maxHumidity) {\n // Humidity is above the acceptable range\n data.humidityEvent = \"Above Max\";\n }\n \n\nelse {\n data.humidityEvent = \"No action\"\n }\n\n// Set turn AC variable based on conditions\nif (data.temperatureEvent === \"Above Max\" || data.humidityEvent === \"Above Max\" || data.criticaltemp==true) {\n data.turnAC = true; // Turn on AC\n} else {\n data.turnAC = false; // Turn off AC\n}\n\n\n\n// Return message\nreturn {payload: data};",
"outputs": 1,
"timeout": "",
"noerr": 0,
@@ -289,7 +312,9 @@
[
"3b3b31131b8fdace",
"5f88eb2715f67f2e",
- "4e4eab1d17ba667b"
+ "4e4eab1d17ba667b",
+ "e858ed400a2da5cc",
+ "2bf7a4c1a64f3644"
]
]
},
@@ -472,114 +497,30 @@
"wires": []
},
{
- "id": "a5a23c5fa5c82f4d",
- "type": "udp in",
- "z": "c2dd626a86cc6cc4",
- "name": "temperature",
- "iface": "",
- "port": "48569",
- "ipv": "udp4",
- "multicast": "false",
- "group": "",
- "datatype": "utf8",
- "x": 70,
- "y": 160,
- "wires": [
- [
- "3008c509ada688e9",
- "c331e94f5129300c",
- "8efa1a3497c7a8e7"
- ]
- ]
- },
- {
- "id": "c331e94f5129300c",
- "type": "string",
- "z": "c2dd626a86cc6cc4",
- "name": "temperature",
- "methods": [
- {
- "name": "between",
- "params": [
- {
- "type": "str",
- "value": "temperature="
- },
- {
- "type": "str",
- "value": "°C"
- }
- ]
- }
- ],
- "prop": "payload",
- "propout": "payload",
- "object": "msg",
- "objectout": "msg",
- "x": 210,
- "y": 60,
- "wires": [
- [
- "8698d9f22991fb89",
- "9d39cc5a1491fbe1"
- ]
- ]
- },
- {
- "id": "8698d9f22991fb89",
- "type": "debug",
- "z": "c2dd626a86cc6cc4",
- "name": "temperature",
- "active": true,
- "tosidebar": true,
- "console": false,
- "tostatus": false,
- "complete": "payload",
- "targetType": "msg",
- "statusVal": "",
- "statusType": "auto",
- "x": 350,
- "y": 60,
- "wires": []
- },
- {
- "id": "8efa1a3497c7a8e7",
- "type": "string",
- "z": "c2dd626a86cc6cc4",
- "name": "humidity",
- "methods": [
- {
- "name": "between",
- "params": [
- {
- "type": "str",
- "value": "\"temperature= 19.52°C humidity="
- },
- {
- "type": "msg",
- "value": "%"
- }
- ]
- }
- ],
- "prop": "payload",
- "propout": "payload",
- "object": "msg",
- "objectout": "msg",
- "x": 200,
- "y": 280,
+ "id": "e858ed400a2da5cc",
+ "type": "function",
+ "z": "2df1dfd158b253ed",
+ "name": "set temperature event as global var",
+ "func": "msg.payload= msg.payload.criticaltemp;\nglobal.set(\"critical_temperature\", msg.payload);\n\nreturn msg;",
+ "outputs": 1,
+ "timeout": 0,
+ "noerr": 0,
+ "initialize": "",
+ "finalize": "",
+ "libs": [],
+ "x": 620,
+ "y": 560,
"wires": [
[
- "d1787efa3cdc78e5",
- "41b46193d88aea70"
+ "e2bb7f5d9a0715e0"
]
]
},
{
- "id": "d1787efa3cdc78e5",
+ "id": "e2bb7f5d9a0715e0",
"type": "debug",
- "z": "c2dd626a86cc6cc4",
- "name": "humidity",
+ "z": "2df1dfd158b253ed",
+ "name": "temp_event",
"active": true,
"tosidebar": true,
"console": false,
@@ -588,195 +529,35 @@
"targetType": "msg",
"statusVal": "",
"statusType": "auto",
- "x": 300,
- "y": 280,
+ "x": 840,
+ "y": 560,
"wires": []
},
{
- "id": "19896d575389fc1e",
+ "id": "2bf7a4c1a64f3644",
"type": "function",
- "z": "c2dd626a86cc6cc4",
- "name": "set temperature as global variable",
- "func": "global.set(\"temperature\", msg.payload);\nreturn msg;",
- "outputs": 1,
- "timeout": 0,
- "noerr": 0,
- "initialize": "",
- "finalize": "",
- "libs": [],
- "x": 560,
- "y": 120,
- "wires": [
- [
- "7712b3f75d46dea3"
- ]
- ]
- },
- {
- "id": "2a4e877502fcd289",
- "type": "function",
- "z": "c2dd626a86cc6cc4",
- "name": "set humidity as global variable",
- "func": "global.set(\"humidity\", msg.payload);\nreturn msg;",
- "outputs": 1,
- "timeout": 0,
- "noerr": 0,
- "initialize": "",
- "finalize": "",
- "libs": [],
- "x": 730,
- "y": 280,
- "wires": [
- [
- "12753bb56e15c445"
- ]
- ]
- },
- {
- "id": "046d88dfb617909c",
- "type": "inject",
- "z": "c2dd626a86cc6cc4",
- "name": "",
- "props": [
- {
- "p": "payload"
- },
- {
- "p": "topic",
- "vt": "str"
- }
- ],
- "repeat": "10",
- "crontab": "",
- "once": true,
- "onceDelay": "10",
- "topic": "",
- "payload": "",
- "payloadType": "date",
- "x": 150,
- "y": 420,
- "wires": [
- [
- "edb2fc8137368439"
- ]
- ]
- },
- {
- "id": "edb2fc8137368439",
- "type": "function",
- "z": "c2dd626a86cc6cc4",
- "name": "function 1",
- "func": "flow.set('Temperature', global.get(\"temperature\"));\nflow.set('Humidity', global.get(\"humidity\"));\nflow.set('tempecriticalvl', global.get(\"critical_temp\"))\nflow.set('humiditycriticalvl', global.get(\"critical_humditiy\"))\nmsg.payload = [\n\nflow.get('Temperature'),\nflow.get('Humidity'),\nflow.get('tempecriticalvl'),\nflow.get('humiditycriticalvl')\n\n];\nreturn msg;",
+ "z": "2df1dfd158b253ed",
+ "name": "set humidity event as global var",
+ "func": "msg.payload= msg.payload.criticalhumidity;\nglobal.set(\"critical_humidity\", msg.payload);\n\nreturn msg;\nreturn msg;",
"outputs": 1,
"timeout": 0,
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
- "x": 340,
- "y": 420,
+ "x": 640,
+ "y": 480,
"wires": [
[
- "aadf68330d6b8c5e"
+ "29f50b54201f70c3"
]
]
},
{
- "id": "12753bb56e15c445",
- "type": "debug",
- "z": "c2dd626a86cc6cc4",
- "name": "humidity_global_variable",
- "active": true,
- "tosidebar": true,
- "console": false,
- "tostatus": false,
- "complete": "payload",
- "targetType": "msg",
- "statusVal": "",
- "statusType": "auto",
- "x": 950,
- "y": 280,
- "wires": []
- },
- {
- "id": "aadf68330d6b8c5e",
- "type": "debug",
- "z": "c2dd626a86cc6cc4",
- "name": "data_for_opc_ua_server",
- "active": true,
- "tosidebar": true,
- "console": false,
- "tostatus": false,
- "complete": "payload",
- "targetType": "msg",
- "statusVal": "",
- "statusType": "auto",
- "x": 570,
- "y": 420,
- "wires": []
- },
- {
- "id": "7712b3f75d46dea3",
- "type": "debug",
- "z": "c2dd626a86cc6cc4",
- "name": "temperature_global_variable",
- "active": true,
- "tosidebar": true,
- "console": false,
- "tostatus": false,
- "complete": "payload",
- "targetType": "msg",
- "statusVal": "",
- "statusType": "auto",
- "x": 1060,
- "y": 60,
- "wires": []
- },
- {
- "id": "a3cae2a4cd7d398b",
- "type": "opcua-compact-server",
- "z": "c2dd626a86cc6cc4",
- "port": 54840,
- "endpoint": "",
- "productUri": "",
- "acceptExternalCommands": true,
- "maxAllowedSessionNumber": 10,
- "maxConnectionsPerEndpoint": 10,
- "maxAllowedSubscriptionNumber": 100,
- "alternateHostname": "",
- "name": "",
- "showStatusActivities": false,
- "showErrors": true,
- "allowAnonymous": true,
- "individualCerts": false,
- "isAuditing": false,
- "serverDiscovery": true,
- "users": [],
- "xmlsetsOPCUA": [],
- "publicCertificateFile": "",
- "privateCertificateFile": "",
- "registerServerMethod": "1",
- "discoveryServerEndpointUrl": "opc.tcp://localhost:54840",
- "capabilitiesForMDNS": "",
- "maxNodesPerRead": 1000,
- "maxNodesPerWrite": 1000,
- "maxNodesPerHistoryReadData": 100,
- "maxNodesPerBrowse": 3000,
- "maxBrowseContinuationPoints": 10,
- "maxHistoryContinuationPoints": 10,
- "delayToInit": 1000,
- "delayToClose": 200,
- "serverShutdownTimeout": 100,
- "addressSpaceScript": "function constructAlarmAddressSpace(server, addressSpace, eventObjects, done) {\n // server = the created node-opcua server\n // addressSpace = address space of the node-opcua server\n // eventObjects = add event variables here to hold them in memory from this script\n\n // internal sandbox objects are:\n // node = the compact server node,\n // coreServer = core compact server object for debug and access to NodeOPCUA\n // this.sandboxNodeContext = node context node-red\n // this.sandboxFlowContext = flow context node-red\n // this.sandboxGlobalContext = global context node-red\n // this.sandboxEnv = env variables\n // timeout and interval functions as expected from nodejs\n\n const opcua = coreServer.choreCompact.opcua;\n const LocalizedText = opcua.LocalizedText;\n const namespace = addressSpace.getOwnNamespace();\n\n const Variant = opcua.Variant;\n const DataType = opcua.DataType;\n\n var flexServerInternals = this;\n\n const rootFolder = addressSpace.findNode(\"RootFolder\");\n\n // Set initial values for global variables in flow context\n this.sandboxFlowContext.set(\"Humidity\", 90);\n this.sandboxFlowContext.set(\"Temperature\",900);\n this.sandboxFlowContext.set(\"temp_critical\", false);\n this.sandboxFlowContext.set(\"humidity_critical\", false);\n\n // Create folders for sensor data\n const sensorData = namespace.addFolder(rootFolder.objects, {\n \"browseName\": \"Sensor_data\"\n });\n const temperature = namespace.addFolder(sensorData, {\n \"browseName\": \"Temperature\"\n });\n const humidity = namespace.addFolder(sensorData, {\n \"browseName\": \"Humidity\"\n });\n const tempCritical = namespace.addFolder(sensorData, {\n \"browseName\": \"Temp_critical\"\n });\n const humidityCritical = namespace.addFolder(sensorData, {\n \"browseName\": \"Humidity_critical\"\n });\n\n // Create variables for temperature, humidity, and critical temperature\n const temperatureVar = namespace.addVariable({\n \"organizedBy\": temperature,\n \"browseName\": \"Value\",\n \"nodeId\": \"ns=1;s=Temperature_value\",\n \"dataType\": \"Double\",\n \"value\": {\n \"get\": function () {\n return new Variant({\n \"dataType\": DataType.Double,\n \"value\": flexServerInternals.sandboxFlowContext.get(\"Temperature\")\n });\n },\n \"set\": function (variant) {\n flexServerInternals.sandboxFlowContext.set(\n \"Temperature\",\n variant.value\n );\n return opcua.StatusCodes.Good;\n }\n }\n });\n\n const humidityVar = namespace.addVariable({\n \"organizedBy\": humidity,\n \"browseName\": \"Value\",\n \"nodeId\": \"ns=1;s=Humidity_value\",\n \"dataType\": \"Double\",\n \"value\": {\n \"get\": function () {\n return new Variant({\n \"dataType\": DataType.Double,\n \"value\": flexServerInternals.sandboxFlowContext.get(\"Humidity\")\n });\n },\n \"set\": function (variant) {\n flexServerInternals.sandboxFlowContext.set(\n \"Humidity\",\n variant.value\n );\n return opcua.StatusCodes.Good;\n }\n }\n });\n\n const temperatureCritical = namespace.addVariable({\n \"organizedBy\": tempCritical,\n \"browseName\": \"Value\",\n \"nodeId\": \"ns=1;s=Temp_critical_value\",\n \"dataType\": \"Boolean\",\n \"value\": {\n \"get\": function () {\n return new Variant({\n \"dataType\": DataType.Boolean,\n \"value\": flexServerInternals.sandboxFlowContext.get(\"temp_critical\")\n });\n },\n \"set\": function (variant) {\n flexServerInternals.sandboxFlowContext.set(\n \"temp_critical\",\n variant.value\n );\n return opcua.StatusCodes.Good;\n }\n }\n });\n\n const humidityCrit = namespace.addVariable({\n \"organizedBy\": humidityCritical,\n \"browseName\": \"Value\",\n \"nodeId\": \"ns=1;s=Humidity_critical_value\",\n \"dataType\": \"Boolean\",\n \"value\": {\n \"get\": function () {\n return new Variant({\n \"dataType\": DataType.Boolean,\n \"value\": flexServerInternals.sandboxFlowContext.get(\"humidity_critical\")\n });\n },\n \"set\": function (variant) {\n flexServerInternals.sandboxFlowContext.set(\n \"humidity_critical\",\n variant.value\n );\n return opcua.StatusCodes.Good;\n }\n }\n });\n \n \n done();\n}\n",
- "x": 280,
- "y": 540,
- "wires": []
- },
- {
- "id": "3008c509ada688e9",
+ "id": "29f50b54201f70c3",
"type": "debug",
- "z": "c2dd626a86cc6cc4",
- "name": "udp_message",
+ "z": "2df1dfd158b253ed",
+ "name": "humd_event",
"active": true,
"tosidebar": true,
"console": false,
@@ -785,146 +566,24 @@
"targetType": "msg",
"statusVal": "",
"statusType": "auto",
- "x": 220,
- "y": 160,
- "wires": []
- },
- {
- "id": "41b46193d88aea70",
- "type": "function",
- "z": "c2dd626a86cc6cc4",
- "name": "convert humidity to a number",
- "func": "msg.payload = parseFloat(msg.payload); // Convert string to float\nreturn msg;\n",
- "outputs": 1,
- "timeout": 0,
- "noerr": 0,
- "initialize": "",
- "finalize": "",
- "libs": [],
- "x": 480,
- "y": 280,
- "wires": [
- [
- "2a4e877502fcd289"
- ]
- ]
- },
- {
- "id": "9d39cc5a1491fbe1",
- "type": "function",
- "z": "c2dd626a86cc6cc4",
- "name": "Convert temperature to number",
- "func": "msg.payload = parseFloat(msg.payload); // Convert string to float\nreturn msg;\n",
- "outputs": 1,
- "timeout": 0,
- "noerr": 0,
- "initialize": "",
- "finalize": "",
- "libs": [],
- "x": 530,
- "y": 60,
- "wires": [
- [
- "19896d575389fc1e"
- ]
- ]
- },
- {
- "id": "7754ccb4c1d18f0b",
- "type": "comment",
- "z": "c2dd626a86cc6cc4",
- "name": "Read the global variables",
- "info": "Gets the temperature, humidity global variables",
- "x": 110,
- "y": 360,
- "wires": []
- },
- {
- "id": "1df9b17d245123d1",
- "type": "comment",
- "z": "c2dd626a86cc6cc4",
- "name": "OPC_UA_Server",
- "info": "This is the OPC UA server. It has two variables being \nreported, humidity and temperature.\n\nThe javascript code that defines the functionality\nof the opc server are found inside \"address\nspace\".",
- "x": 80,
+ "x": 850,
"y": 480,
"wires": []
},
{
- "id": "5a7a18d8c8d7e5fa",
+ "id": "53c78b710282cbfb",
"type": "comment",
- "z": "c2dd626a86cc6cc4",
- "name": "Logic engine 71",
+ "z": "2df1dfd158b253ed",
+ "name": "mqtt interface",
"info": "",
- "x": 80,
- "y": 640,
+ "x": 70,
+ "y": 1200,
"wires": []
},
{
- "id": "37b5f0073d1eafee",
- "type": "function",
- "z": "c2dd626a86cc6cc4",
- "name": "Check Temperature and Humidity",
- "func": "// Define the acceptable range for temperature and humidity\nconst minTemperature = 10; // Minimum temperature\nconst maxTemperature = 20; // Maximum temperature\nconst criticatemp = 40; // critical temperature \nconst minHumidity = 30; // Minimum humidity\nconst maxHumidity = 40; // Maximum humidity\nconst critichumidity =80; // critical value for humidity\n// Get the incoming message payload\nvar temperature = global.get('temperature'); // Get temperature from global context\nvar humidity = global.get('humidity'); // Get humidity from global context\n// set global variables that can be used by opc_server\n\n\n// Initialize payload as a JSON object\nvar data = {\n timestamp: Date.now(),\n temperature: temperature,\n humidity: humidity,\n criticalhumidity : false,\n criticaltemp : false,\n temperatureEvent: \"\",\n humidityEvent: \"\",\n turnAC: false // Initialize turn AC variable\n};\n\n// Check if temperature is within the acceptable range\nif (temperature < minTemperature) {\n // Temperature is below the acceptable range\n data.temperatureEvent = \"Below Min\";\n} else if (temperature > maxTemperature) {\n // Temperature is above the acceptable range\n data.temperatureEvent = \"Above Max\";\n}\nelse if (temperature > criticatemp) {\n // Humidity is above the acceptable range\n data.criticaltempEvent = true;\n }\nelse {\n msg.payload.temperatureEvent = \"No action\"\n }\n// Check if humidity is within the acceptable range\nif (humidity < minHumidity) {\n // Humidity is below the acceptable range\n data.humidityEvent = \"Below Min\";\n} else if (humidity > maxHumidity) {\n // Humidity is above the acceptable range\n data.humidityEvent = \"Above Max\";\n }\nelse if (temperature > criticatemp) {\n // Humidity is above the acceptable range\n data.criticalhumidity = true;\n } \nelse {\n msg.payload.humidityEvent = \"No action\"\n }\n\n// Set turn AC variable based on conditions\nif (data.temperatureEvent === \"Above Max\" || data.humidityEvent === \"Above Max\") {\n data.turnAC = true; // Turn on AC\n} else {\n data.turnAC = false; // Turn off AC\n}\n\n// Return message\nreturn {payload: data};",
- "outputs": 1,
- "timeout": "",
- "noerr": 0,
- "initialize": "",
- "finalize": "",
- "libs": [],
- "x": 320,
- "y": 760,
- "wires": [
- [
- "35b03154fcda4780",
- "f575d4536609e175",
- "25166850225e0aca"
- ]
- ]
- },
- {
- "id": "35b03154fcda4780",
- "type": "csv",
- "z": "c2dd626a86cc6cc4",
- "name": "",
- "sep": ",",
- "hdrin": true,
- "hdrout": "",
- "multi": "one",
- "ret": "\\n",
- "temp": "timestamp,temperature,humidity,temperatureEvent,humidityEvent,turnAC",
- "skip": "0",
- "strings": true,
- "include_empty_strings": false,
- "include_null_values": false,
- "x": 530,
- "y": 760,
- "wires": [
- [
- "9d700c25f37d23a2"
- ]
- ]
- },
- {
- "id": "9d700c25f37d23a2",
- "type": "file",
- "z": "c2dd626a86cc6cc4",
- "name": "",
- "filename": "C:\\Users\\waelk\\Desktop\\test.csv",
- "filenameType": "str",
- "appendNewline": true,
- "createDir": false,
- "overwriteFile": "false",
- "encoding": "none",
- "x": 760,
- "y": 760,
- "wires": [
- []
- ]
- },
- {
- "id": "ee40b905de178b3f",
+ "id": "92e00a55170fe173",
"type": "inject",
- "z": "c2dd626a86cc6cc4",
+ "z": "2df1dfd158b253ed",
"name": "Simulate Data",
"props": [
{
@@ -938,104 +597,50 @@
"topic": "",
"payload": "",
"payloadType": "date",
- "x": 80,
- "y": 760,
+ "x": 100,
+ "y": 1260,
"wires": [
[
- "37b5f0073d1eafee"
+ "e41b408c490a13dd"
]
]
},
{
- "id": "f575d4536609e175",
- "type": "debug",
- "z": "c2dd626a86cc6cc4",
- "name": "object containing_data_and_events",
- "active": true,
- "tosidebar": true,
- "console": false,
- "tostatus": false,
- "complete": "payload",
- "targetType": "msg",
- "statusVal": "",
- "statusType": "auto",
- "x": 660,
- "y": 840,
- "wires": []
- },
- {
- "id": "c20746defc6904de",
- "type": "comment",
- "z": "c2dd626a86cc6cc4",
- "name": "sending notifications to2",
- "info": "",
- "x": 100,
- "y": 840,
- "wires": []
- },
- {
- "id": "25166850225e0aca",
+ "id": "e41b408c490a13dd",
"type": "function",
- "z": "c2dd626a86cc6cc4",
- "name": "check_critical_temperature_trigger",
- "func": "var inputObject = msg.payload;\n\nvar criticalTemperature = inputObject.criticaltemp;\nvar criticalHumidity = inputObject.criticalhumidity;\n\nif (criticalTemperature || criticalHumidity) {\n // If either critical temperature or critical humidity is true\n msg.payload = \"Critical temperature or humidity condition is met.\";\n return msg;\n} else {\n // If neither critical temperature nor critical humidity is true\n msg.payload = \"Critical conditions are not met.\";\n}\n\n",
+ "z": "2df1dfd158b253ed",
+ "name": "Check Temperature and Humidity",
+ "func": "// Define the acceptable range for temperature and humidity\nconst minTemperature = 10; // Minimum temperature\nconst maxTemperature = 20; // Maximum temperature\nconst criticatemp = 20; // critical temperature \nconst minHumidity = 30; // Minimum humidity\nconst maxHumidity = 40; // Maximum humidity\nconst critichumidity =80; // critical value for humidity\n// Get the incoming message payload\nvar temperature = global.get('temperature'); // Get temperature from global context\nvar humidity = global.get('humidity'); // Get humidity from global context\n// set global variables that can be used by opc_server\n\n\n// Initialize payload as a JSON object\nvar data = {\n timestamp: Date.now(),\n temperature: temperature,\n humidity: humidity,\n criticalhumidity : false,\n criticaltemp : false,\n temperatureEvent: \"\",\n humidityEvent: \"\",\n turnAC: false // Initialize turn AC variable\n};\n\n\n// Check if temperature is within the acceptable range\nif (temperature < minTemperature) {\n // Temperature is below the acceptable range\n data.temperatureEvent = \"Below Min\";\n} else if (temperature > maxTemperature) {\n // Temperature is above the acceptable range\n data.temperatureEvent = \"Above Max\";\n \n}\nelse if (temperature > criticatemp) {\n // Humidity is above the acceptable range\n data.criticaltemp= true;\n }\nelse {\n msg.payload.temperatureEvent = \"No action\"\n }\n// Check if humidity is within the acceptable range\nif (humidity < minHumidity) {\n // Humidity is below the acceptable range\n data.humidityEvent = \"Below Min\";\n} else if (humidity > maxHumidity) {\n // Humidity is above the acceptable range\n data.humidityEvent = \"Above Max\";\n }\n \n\nelse {\n data.humidityEvent = \"No action\"\n }\n\n// Set turn AC variable based on conditions\nif (data.temperatureEvent === \"Above Max\" || data.humidityEvent === \"Above Max\" || data.criticaltemp==true) {\n data.turnAC = true; // Turn on AC\n} else {\n data.turnAC = false; // Turn off AC\n}\n\n\n\n// Return message\nreturn {payload: data};",
"outputs": 1,
- "timeout": 0,
+ "timeout": "",
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
- "x": 300,
- "y": 920,
+ "x": 340,
+ "y": 1260,
"wires": [
[
- "ac4de023899c1230",
- "7a6f850c89342c31"
+ "ad75dfa6a5ee9102"
]
]
},
{
- "id": "ac4de023899c1230",
- "type": "debug",
- "z": "c2dd626a86cc6cc4",
- "name": "trigger_conditions",
- "active": true,
- "tosidebar": true,
- "console": false,
- "tostatus": false,
- "complete": "payload",
- "targetType": "msg",
- "statusVal": "",
- "statusType": "auto",
- "x": 770,
- "y": 920,
- "wires": []
- },
- {
- "id": "7a6f850c89342c31",
- "type": "e-mail",
- "z": "c2dd626a86cc6cc4",
- "server": "smtp.gmail.com",
- "port": "465",
- "authtype": "BASIC",
- "saslformat": true,
- "token": "oauth2Response.access_token",
- "secure": true,
- "tls": true,
- "name": "waelkhlifi12@gmail.com",
- "dname": "notification_temperature",
- "x": 590,
- "y": 1000,
- "wires": []
- },
- {
- "id": "417c2d7eb6454ec7",
- "type": "comment",
- "z": "c2dd626a86cc6cc4",
- "name": "udp_interface",
- "info": "",
- "x": 70,
- "y": 40,
+ "id": "ad75dfa6a5ee9102",
+ "type": "mqtt out",
+ "z": "2df1dfd158b253ed",
+ "name": "",
+ "topic": "sensordata",
+ "qos": "",
+ "retain": "",
+ "respTopic": "",
+ "contentType": "",
+ "userProps": "",
+ "correl": "",
+ "expiry": "",
+ "broker": "ff246c28cc0fa0af",
+ "x": 610,
+ "y": 1260,
"wires": []
}
]
\ No newline at end of file
diff --git a/zigbee_node_red_cred.json b/zigbee_node_red_cred.json
index 0366bba..e46f025 100644
--- a/zigbee_node_red_cred.json
+++ b/zigbee_node_red_cred.json
@@ -1,3 +1,4 @@
{
- "9355c4bbb1adc9e0": {}
+ "9355c4bbb1adc9e0": {},
+ "ff246c28cc0fa0af": {}
}
\ No newline at end of file
--
GitLab