Domotique et objets connectés à faire soi-même

MySensors v2.3. Décoder et envoyer des messages avec Node-RED

node-red mysensors v2 mysencap mysdescenc

Les objets MySensors communiquent entre eux sous la forme de petits messages envoyés par ondes radio. Il est très facile de décoder les messages en suivants les spécifications techniques de l’API série disponible sur le site officiel du projet

 

Dernière mise à jour : 25 mars 2020

La librairie MySensors permet de faciliter le développement d’applications en tout genre (mobile, robotique, domotique) sans avoir à gérer la couche de communication entre les appareils. Nous allons utiliser Node-RED pour décoder les messages reçus par une gateway réseau ou série. Pour vous connecter à un réseau d’objets MySensors, vous aurez besoin d’une Gateway réseau WiFi. Suivez ce tutoriel pour en fabriquer une avec un ESP8266 avant d’aller plus loin.

Pour en savoir plus sur la librairie MySensors, vous pouvez commencer par lire cet article.

Structure d’un message MySensors (API)

MySensors communique avec de petits messages de 32 bytes (la taille maximale des messages envoyés par une puce nRF24L01). L’entête (header) du message d’une taille de 7 bytes est constitué ainsi :

node-id ; child-sensor-id ; message-type ; ack ; sub-type ; payload \n

25 bytes peut sembler faible, mais le nRF24L01 n’est pas conçu pour transmettre de grands messages, plutôt des états ou des mesures physiques.

Cas des messages MQTT

Les messages MQTT ont une structure similaire. Le prefix peut être personnalisé dans le sketch Arduino.

prefix/node-id/child-sensor-id/message-type/ack/sub-type + payload

Comment se connecter à une gateway MySensors depuis Node-RED

On dispose de trois types de gateway MySensors. La serial gateway qui se branche sur le port USB d’un ordinateur ou d’un Raspberry. Elle est pratique pour débuter et lire les messages de debug envoyés sur le port série (par exemple avec le moniteur série de l’IDE Arduino). La passerelle réseau est maintenant très simple (et pas cher) à fabriquer à l’aide d’un ESP8266 (toutes les explications dans cet article). On peut l’installer (la cacher !) dans en endroit ou la réception radio est meilleure et on ne monopolise pas un port USB du Raspberry Pi.

Serial gateway, passerelle série connectée sur le port USB

Pour se connecter à une passerelle série, ajoutez un Node serial (dans Input)

Ouvrez le pour le configurer et appuyez sur le crayon pour configurer le port série. Appuyez sur la loupe et choisissez le port USB sur lequel est branché la gateway. Par exemple /dev/ttyUSB0.

 

Par défaut, la vitesse de communication avec la gateway est de 115200 bauds. Laissez la configuration par défaut. 8 bits Data, Parity None, Stop Bits 1.

Enregistrez la configuration en appuyant sur Done.

LAN Gateway, pour se connecter à une passerelle sur le réseau WiFi

Pour se connecter à une passerelle réseau, nous allons utiliser un Node TCP

Configurez la connexion ainsi :

 

Gateway MQTT

Dernière solution, utiliser un broker MQTT. Rien de bien compliqué ici, il suffit de se connecter au broker MQTT comme d’habitude.

Installer le plugin node-red-contrib-mysensors pour Node-RED

Le plugin node-red-contrib-mysensors développé par Thomas Mørch permet de décoder et d’envoyer des messages à un réseau d’objets MySensors. Le Plugin MySensors peut également d’enregistrer les états et les mesures dans une base de données sqlite.

Attention à installer le plugon sqlite pour éviter une erreur au moment de déployer le flow

Ouvrez le gestionnaire de palette de Node-RED

Faites une recherche sur le mot clé sqlite

Ensuite, vous pouvez installer le plugin mysensor. Vous trouverez 2 plugins :

Vous disposer maintenant d’une nouvelle palette appelée mysensors. Elle est constituée de cinq Nodes


Fonction mysdebug

Partons par la fin pour une fois. La fonction mysdebug permet de décoder et de rendre plus lisible les messages reçus en envoyés par la gateway. Chaque code est remplacé par sa signification.

Messages décodés affichés dans la console. Tout n’est pas correctement décodé (dans la version actuelle du plugin).

Comment utiliser la fonction mysdecode

Cette fonction permet de décoder les messages MySensors. Pour l’utiliser, il suffit de la brancher à une gateway (série, réseau ou MQTT). En sortie (payload), on récupère directement le payload de chaque message. Chaque information disponible est publiée sur un flux différent :

Cette architecture présente des avantages et des inconvénients. On récupère directement en sortie le payload de chaque message mais cela peut rapidement devenir compliqué pour filtrer les données de tel ou tel capteur.

Messages décodés affichés dans la console.

Code du flow

[{"id":"62351421.a2a7ec","type":"serial in","z":"eb4ead14.fd77f","name":"MySensors Serial Gateway","serial":"219cc581.f9b252","x":145.6666717529297,"y":134.66666412353516,"wires":[["2027984.714eb68","d8174c63.f752a"]]},{"id":"893c2411.1181e8","type":"debug","z":"eb4ead14.fd77f","name":"","active":false,"console":"false","complete":"payload","x":559,"y":35,"wires":[]},{"id":"d8174c63.f752a","type":"mysdecenc","z":"eb4ead14.fd77f","name":"","x":372.5,"y":36,"wires":[["893c2411.1181e8","80842fe1.74a72"]]},{"id":"80842fe1.74a72","type":"debug","z":"eb4ead14.fd77f","name":"","active":false,"console":"false","complete":"nodeId","x":559.5,"y":80,"wires":[]},{"id":"2027984.714eb68","type":"mysdebug","z":"eb4ead14.fd77f","name":"","x":374.5,"y":135,"wires":[["ed9596a0.eaa2b8"]]},{"id":"ed9596a0.eaa2b8","type":"debug","z":"eb4ead14.fd77f","name":"","active":false,"console":"false","complete":"false","x":561.5,"y":140,"wires":[]},{"id":"219cc581.f9b252","type":"serial-port","z":"","serialport":"/dev/ttyUSB0","serialbaud":"115200","databits":"8","parity":"none","stopbits":"1","newline":"\\n","bin":"false","out":"char","addchar":false}]

Fonction pour décoder un message (objet JSON) sans le plugin Node-RED

Le plugin contrib-mysensors est très efficace mais il ne permet (pour le moment du moins) que d’extraire le payload (contenu du message). Dans certains cas, il peut s’avérer nécessaire d’extraire des informations supplémentaire. Voici une petite fonction que vous pouvez ajouter à vos projets Node-RED. Elle remplace le plugin node-red-contrib-mysensors.

Pour une gateway Serial ou LAN

La fonction décode le message est décodé en renvoyant un objet JSON au format clé:valeur.

Elle renvoie un payload avec les informations suivantes :

Vous pouvez également installer ce flow depuis le site officiel de Node-RED http://flows.nodered.org/flow/fa02078c160cb3e00e09f4980b534490

/* MySensors v2 Message Decoder
*  Payload : JSON object
*  www.projetsdiy.fr - oct. 2016
*/
var mySensorsMessage = {}
var newPayload = {};
var message = msg.payload.toString();
message = message.replace(/(\r\n|\n|\r)/gm, "");
var tokens = message.split(";")
if(tokens.length == 6)
{
    mySensorsMessage.nodeId =       parseInt(tokens[0]);
    mySensorsMessage.childSensorId= parseInt(tokens[1]);
    mySensorsMessage.messageType =  parseInt(tokens[2]);
    mySensorsMessage.ack =          parseInt(tokens[3]);
    mySensorsMessage.subType =      parseInt(tokens[4]);
    mySensorsMessage.value =        Number(tokens[5]);

    var messageType = mySensorsMessage.messageType;
    var subType = mySensorsMessage.subType;
    var labelPresentation = ["S_DOOR","S_MOTION","S_SMOKE","S_LIGHT","S_BINARY","S_DIMMER","S_COVER","S_TEMP","S_HUM","S_BARO","S_WIND","S_RAIN","S_UV","S_WEIGHT","S_POWER","S_HEATER","S_DISTANCE","S_LIGHT_LEVEL","S_ARDUINO_NODE","S_ARDUINO_REPEATER_NODE","S_LOCK","S_IR","S_WATER","S_AIR_QUALITY","S_CUSTOM","S_DUST","S_SCENE_CONTROLLER","S_RGB_LIGHT","S_RGBW_LIGHT","S_COLOR_SENSOR","S_HVAC","S_MULTIMETER","S_SPRINKLER","S_WATER_LEAK","S_SOUND","S_VIBRATION","S_MOISTURE","S_INFO","S_GAS","S_GPS","S_WATER_QUALITY"];
    var labelSet = ["V_TEMP","V_HUM","V_STATUS","V_LIGHT","V_PERCENTAGE","V_DIMMER","V_PRESSURE","V_FORECAST","V_RAIN","V_RAINRATE","V_WIND","V_GUST","V_DIRECTION","V_UV","V_WEIGHT","V_DISTANCE","V_IMPEDANCE","V_ARMED","V_TRIPPED","V_WATT","V_KWH","V_SCENE_ON","V_SCENE_OFF","V_HVAC_FLOW_STATE","V_HVAC_SPEED","V_LIGHT_LEVEL","V_VAR1","V_VAR2","V_VAR3","V_VAR4","V_VAR5","V_UP","V_DOWN","V_STOP","V_IR_SEND","V_IR_RECEIVE","V_FLOW","V_VOLUME","V_LOCK_STATUS","V_LEVEL","V_VOLTAGE","V_CURRENT","V_RGB","V_RGBW","V_ID","V_UNIT_PREFIX","V_HVAC_SETPOINT_COOL","V_HVAC_SETPOINT_HEAT","V_HVAC_FLOW_MODE","V_TEXT","V_CUSTOM","V_POSITION","V_IR_RECORD","V_PH","V_ORP","V_EC","V_VAR","V_VA","V_POWER_FACTOR"]
    var labelInternal = ["I_BATTERY_LEVEL","I_TIME","I_VERSION","I_ID_REQUEST","I_ID_RESPONSE","I_INCLUSION_MODE","I_CONFIG","I_FIND_PARENT","I_FIND_PARENT_RESPONSE","I_LOG_MESSAGE","I_CHILDREN","I_SKETCH_NAME","I_SKETCH_VERSION","I_REBOOT","I_GATEWAY_READY","I_REQUEST_SIGNING","I_GET_NONCE","I_GET_NONCE_RESPONSE","I_HEARTBEAT","I_PRESENTATION","I_DISCOVER","I_DISCOVER_RESPONSE","I_HEARTBEAT_RESPONSE","I_LOCKED","I_PING","I_PONG","I_REGISTRATION_REQUEST","I_REGISTRATION_RESPONSE","I_DEBUG"]
    
    switch (messageType) {
        case 0:     // Presentation
            newPayload.mode =       "Presentation";
            newPayload.type =       labelPresentation[subType];
            newPayload.value =      mySensorsMessage.value;
            break;
        case 1:     // Set
            newPayload.nodeId =     mySensorsMessage.nodeId;
            newPayload.sensorId =   mySensorsMessage.childSensorId;
            newPayload.mode=        "Set";
            newPayload.type=        subType;
            newPayload.typeLabel=   labelSet[subType];
            newPayload.value=       mySensorsMessage.value;
            break;
        case 2:     // Req
            newPayload.nodeId=      mySensorsMessage.nodeId;
            newPayload.sensorId=    mySensorsMessage.childSensorId;
            newPayload.mode=        "Req";
            newPayload.type=        subType;
            newPayload.typeLabel=   labelSet[subType];
            newPayload.value=       mySensorsMessage.value;
            break;  
        case 3:     // Internal
            newPayload.nodeId=      mySensorsMessage.nodeId;
            newPayload.sensorId=    mySensorsMessage.childSensorId;
            newPayload.mode=        "Internal";
            newPayload.type=        subType;
            newPayload.typeLabel=   labelInternal[subType];
            newPayload.value=       mySensorsMessage.value;
            break;    
        case 4:     // Stream - OTA firmware update
            newPayload.nodeId=      mySensorsMessage.nodeId;
            newPayload.mode=        "stream";
            break;
        default:
            break;
    }
    msg.payload = newPayload; 
} else {
    msg.payload = "Error! Nothing to decode"
}  

return msg;

Voici ce que vous obtiendrez avec la fonction. Chaque message est maintenant explicite et formaté sous la forme d’un objet JSON plus facile à exploiter dans un projet.

Libre à vous de la modifier en fonction de vos besoins.

Pour une gateway MQTT

Si vous utilisez une gateway MQTT, utilisez ce Flow pour décoder les messages

/* MySensors v2.3.x Message Decoder
*  Payload : JSON object
*  www.projetsdiy.fr - 03/2020
*/
var mySensorsMessage = {}
var newPayload = {};
var tokens = msg.topic.split("/")
console.log(msg.topic, "|", tokens);
if(tokens.length == 6) {
    //  0       1         2                 3       4    5
    // prefix/node-id/child-sensor-id/message-type/ack/sub-type
    mySensorsMessage.nodeId =       parseInt(tokens[1]);
    mySensorsMessage.childSensorId= parseInt(tokens[2]);
    mySensorsMessage.messageType =  parseInt(tokens[3]);
    mySensorsMessage.ack =          parseInt(tokens[3]);
    mySensorsMessage.subType =      parseInt(tokens[5]);
    mySensorsMessage.value =        msg.payload;

    var messageType = mySensorsMessage.messageType;
    var subType = mySensorsMessage.subType;
    var labelPresentation = ["S_DOOR","S_MOTION","S_SMOKE","S_LIGHT","S_BINARY","S_DIMMER","S_COVER","S_TEMP","S_HUM","S_BARO","S_WIND","S_RAIN","S_UV","S_WEIGHT","S_POWER","S_HEATER","S_DISTANCE","S_LIGHT_LEVEL","S_ARDUINO_NODE","S_ARDUINO_REPEATER_NODE","S_LOCK","S_IR","S_WATER","S_AIR_QUALITY","S_CUSTOM","S_DUST","S_SCENE_CONTROLLER","S_RGB_LIGHT","S_RGBW_LIGHT","S_COLOR_SENSOR","S_HVAC","S_MULTIMETER","S_SPRINKLER","S_WATER_LEAK","S_SOUND","S_VIBRATION","S_MOISTURE","S_INFO","S_GAS","S_GPS","S_WATER_QUALITY"];
    var labelSet = ["V_TEMP","V_HUM","V_STATUS","V_LIGHT","V_PERCENTAGE","V_DIMMER","V_PRESSURE","V_FORECAST","V_RAIN","V_RAINRATE","V_WIND","V_GUST","V_DIRECTION","V_UV","V_WEIGHT","V_DISTANCE","V_IMPEDANCE","V_ARMED","V_TRIPPED","V_WATT","V_KWH","V_SCENE_ON","V_SCENE_OFF","V_HVAC_FLOW_STATE","V_HVAC_SPEED","V_LIGHT_LEVEL","V_VAR1","V_VAR2","V_VAR3","V_VAR4","V_VAR5","V_UP","V_DOWN","V_STOP","V_IR_SEND","V_IR_RECEIVE","V_FLOW","V_VOLUME","V_LOCK_STATUS","V_LEVEL","V_VOLTAGE","V_CURRENT","V_RGB","V_RGBW","V_ID","V_UNIT_PREFIX","V_HVAC_SETPOINT_COOL","V_HVAC_SETPOINT_HEAT","V_HVAC_FLOW_MODE","V_TEXT","V_CUSTOM","V_POSITION","V_IR_RECORD","V_PH","V_ORP","V_EC","V_VAR","V_VA","V_POWER_FACTOR"]
    var labelInternal = ["I_BATTERY_LEVEL","I_TIME","I_VERSION","I_ID_REQUEST","I_ID_RESPONSE","I_INCLUSION_MODE","I_CONFIG","I_FIND_PARENT","I_FIND_PARENT_RESPONSE","I_LOG_MESSAGE","I_CHILDREN","I_SKETCH_NAME","I_SKETCH_VERSION","I_REBOOT","I_GATEWAY_READY","I_REQUEST_SIGNING","I_GET_NONCE","I_GET_NONCE_RESPONSE","I_HEARTBEAT","I_PRESENTATION","I_DISCOVER","I_DISCOVER_RESPONSE","I_HEARTBEAT_RESPONSE","I_LOCKED","I_PING","I_PONG","I_REGISTRATION_REQUEST","I_REGISTRATION_RESPONSE","I_DEBUG"]
    
    newPayload.topic = tokens[0]
    switch (messageType) {
        case 0:     // Presentation
            newPayload.mode =       "Presentation";
            newPayload.type =       labelPresentation[subType];
            newPayload.value=       mySensorsMessage.value;      
            break;
        case 1:     // Set
            newPayload.nodeId=      mySensorsMessage.nodeId;
            newPayload.sensorId=    mySensorsMessage.childSensorId;
            newPayload.mode=        "Set";
            newPayload.type=        subType;
            newPayload.typeLabel=   labelSet[subType];
            newPayload.value=       mySensorsMessage.value;
            break;
        case 2:     // Req
            newPayload.nodeId=      mySensorsMessage.nodeId;
            newPayload.sensorId=    mySensorsMessage.childSensorId;
            newPayload.mode=        "Req";
            newPayload.type=        subType;
            newPayload.typeLabel=   labelSet[subType];
            newPayload.value=       mySensorsMessage.value;
            break;  
        case 3:     // Internal
            newPayload.nodeId=      mySensorsMessage.nodeId;
            newPayload.sensorId=    mySensorsMessage.childSensorId;
            newPayload.mode=        "Internal";
            newPayload.type=        subType;
            newPayload.typeLabel=   labelInternal[subType];
            newPayload.value=       mySensorsMessage.value;
            break;    
        case 4:     // Stream - OTA firmware update
            newPayload.nodeId=      mySensorsMessage.nodeId;
            newPayload.mode=        "stream";
            break;
        default:
            break;
    }

    msg.payload = newPayload; 
} else {
    msg.payload = "Error! Nothing to decode. Lenght =" + tokens.length
}  

return msg;

Code du flow

[{"id":"61bbd468.bddf9c","type":"tcp in","z":"eb4ead14.fd77f","name":"MySensors Gateway","server":"client","host":"192.168.1.20","port":"5003","datamode":"stream","datatype":"utf8","newline":"","topic":"","base64":false,"x":169.88886260986328,"y":226.92767333984375,"wires":[["f4fd4940.32ba8"]]},{"id":"f4fd4940.32ba8","type":"function","z":"eb4ead14.fd77f","name":"Decode MySensor Message","func":"/* MySensors v2 Message Decoder\n*  Payload : JSON object\n*  www.projetsdiy.fr - oct. 2016\n*/\nvar mySensorsMessage = {}\nvar newPayload = {};\nvar message = msg.payload.toString();\nmessage = message.replace(/(\\r\\n|\\n|\\r)/gm, \"\");\nvar tokens = message.split(\";\")\nif(tokens.length == 6)\n{\n    mySensorsMessage.nodeId =       parseInt(tokens[0]);\n    mySensorsMessage.childSensorId= parseInt(tokens[1]);\n    mySensorsMessage.messageType =  parseInt(tokens[2]);\n    mySensorsMessage.ack =          parseInt(tokens[3]);\n    mySensorsMessage.subType =      parseInt(tokens[4]);\n    mySensorsMessage.value =        Number(tokens[5]);\n\n    var messageType = mySensorsMessage.messageType;\n    var subType = mySensorsMessage.subType;\n    var labelPresentation = [\"S_DOOR\",\"S_MOTION\",\"S_SMOKE\",\"S_LIGHT\",\"S_BINARY\",\"S_DIMMER\",\"S_COVER\",\"S_TEMP\",\"S_HUM\",\"S_BARO\",\"S_WIND\",\"S_RAIN\",\"S_UV\",\"S_WEIGHT\",\"S_POWER\",\"S_HEATER\",\"S_DISTANCE\",\"S_LIGHT_LEVEL\",\"S_ARDUINO_NODE\",\"S_ARDUINO_REPEATER_NODE\",\"S_LOCK\",\"S_IR\",\"S_WATER\",\"S_AIR_QUALITY\",\"S_CUSTOM\",\"S_DUST\",\"S_SCENE_CONTROLLER\",\"S_RGB_LIGHT\",\"S_RGBW_LIGHT\",\"S_COLOR_SENSOR\",\"S_HVAC\",\"S_MULTIMETER\",\"S_SPRINKLER\",\"S_WATER_LEAK\",\"S_SOUND\",\"S_VIBRATION\",\"S_MOISTURE\",\"S_INFO\",\"S_GAS\",\"S_GPS\",\"S_WATER_QUALITY\"];\n    var labelSet = [\"V_TEMP\",\"V_HUM\",\"V_STATUS\",\"V_LIGHT\",\"V_PERCENTAGE\",\"V_DIMMER\",\"V_PRESSURE\",\"V_FORECAST\",\"V_RAIN\",\"V_RAINRATE\",\"V_WIND\",\"V_GUST\",\"V_DIRECTION\",\"V_UV\",\"V_WEIGHT\",\"V_DISTANCE\",\"V_IMPEDANCE\",\"V_ARMED\",\"V_TRIPPED\",\"V_WATT\",\"V_KWH\",\"V_SCENE_ON\",\"V_SCENE_OFF\",\"V_HVAC_FLOW_STATE\",\"V_HVAC_SPEED\",\"V_LIGHT_LEVEL\",\"V_VAR1\",\"V_VAR2\",\"V_VAR3\",\"V_VAR4\",\"V_VAR5\",\"V_UP\",\"V_DOWN\",\"V_STOP\",\"V_IR_SEND\",\"V_IR_RECEIVE\",\"V_FLOW\",\"V_VOLUME\",\"V_LOCK_STATUS\",\"V_LEVEL\",\"V_VOLTAGE\",\"V_CURRENT\",\"V_RGB\",\"V_RGBW\",\"V_ID\",\"V_UNIT_PREFIX\",\"V_HVAC_SETPOINT_COOL\",\"V_HVAC_SETPOINT_HEAT\",\"V_HVAC_FLOW_MODE\",\"V_TEXT\",\"V_CUSTOM\",\"V_POSITION\",\"V_IR_RECORD\",\"V_PH\",\"V_ORP\",\"V_EC\",\"V_VAR\",\"V_VA\",\"V_POWER_FACTOR\"]\n    var labelInternal = [\"I_BATTERY_LEVEL\",\"I_TIME\",\"I_VERSION\",\"I_ID_REQUEST\",\"I_ID_RESPONSE\",\"I_INCLUSION_MODE\",\"I_CONFIG\",\"I_FIND_PARENT\",\"I_FIND_PARENT_RESPONSE\",\"I_LOG_MESSAGE\",\"I_CHILDREN\",\"I_SKETCH_NAME\",\"I_SKETCH_VERSION\",\"I_REBOOT\",\"I_GATEWAY_READY\",\"I_REQUEST_SIGNING\",\"I_GET_NONCE\",\"I_GET_NONCE_RESPONSE\",\"I_HEARTBEAT\",\"I_PRESENTATION\",\"I_DISCOVER\",\"I_DISCOVER_RESPONSE\",\"I_HEARTBEAT_RESPONSE\",\"I_LOCKED\",\"I_PING\",\"I_PONG\",\"I_REGISTRATION_REQUEST\",\"I_REGISTRATION_RESPONSE\",\"I_DEBUG\"]\n    \n    switch (messageType) {\n        case 0:     // Presentation\n            \n            newPayload.mode =       \"Presentation\";\n            newPayload.type =       labelPresentation[subType];\n            break;\n        case 1:     // Set\n            newPayload.nodeId=      mySensorsMessage.nodeId;\n            newPayload.sensorId=    mySensorsMessage.childSensorId;\n            newPayload.mode=        \"Set\";\n            newPayload.type=        subType;\n            newPayload.typeLabel=   labelSet[subType];\n            newPayload.value=       mySensorsMessage.value;\n            break;\n        case 2:     // Req\n            newPayload.nodeId=      mySensorsMessage.nodeId;\n            newPayload.sensorId=    mySensorsMessage.childSensorId;\n            newPayload.mode=        \"Req\";\n            newPayload.type=        subType;\n            newPayload.typeLabel=   labelSet[subType];\n            newPayload.value=       mySensorsMessage.value;\n            break;  \n        case 3:     // Internal\n            newPayload.nodeId=      mySensorsMessage.nodeId;\n            newPayload.sensorId=    mySensorsMessage.childSensorId;\n            newPayload.mode=        \"Internal\";\n            newPayload.type=        subType;\n            newPayload.typeLabel=   labelInternal[subType];\n            newPayload.value=       mySensorsMessage.value;\n            break;    \n        case 4:     // Stream - OTA firmware update\n            newPayload.nodeId=      mySensorsMessage.nodeId;\n            newPayload.mode=        \"stream\";\n            break;\n        default:\n            break;\n    }\n\n    msg.payload = newPayload; \n} else {\n    msg.payload = \"Error! Nothing to decode\"\n}  \n\nreturn msg;","outputs":1,"noerr":0,"x":394.5555419921875,"y":279.5555725097656,"wires":[["22cb3401.ef7e24","2d12c5a2.7304aa","fd30fa09.244ce8"]]},{"id":"fd30fa09.244ce8","type":"debug","z":"eb4ead14.fd77f","name":"","active":true,"console":"false","complete":"false","x":628.5,"y":235,"wires":[]}]

La fonction mysencap

La dernière fonction mysencap proposée par le plugin permet de formater un message avant de le publier sur un noeud du réseau MySensors. On peut envoyer ce que l’on veut dans la limite de 25 bytes. Il faut également ajouter un retour à la ligne (\n) avant de l’injecter dans la fonction. Par exemple, on peut récupérer l’état d’un switch créé avec le plugin node-red-contrib-ui pour allumer ou éteindre une Led (ou une lampe via un relai). Nous verrons en détail ce plugin dans un prochain tutoriel.

Ajoutez un Node switch

Donnez lui un nom. Pour la valeur de sortie, indiquez 1 et 0 pour Off. Ce n’est pas très important, on peut très bien laisser True/False. Il faudra juste tester la bonne valeur dans le code Arduino du noeud MySensors.

Allez sur la page d’interface à l’adresse

http://IP_NODE-RED:1880/ui

Vous disposer maintenant d’un interrupteur à deux états.

Il ne reste plus qu’à préparer le message. Ajoutez une fonction et coller ce code pour ajouter un retour à la ligne.

msg.payload = msg.payload + "\n"
return msg;

Ensuite ajoutez un Node mysencap et indiquez les paramètres du noeud de destination du message. Le type de message doit être Request. Voici un exemple :

Il ne reste plus qu’à injecter dans un Node mysdecenc avant d’envoyer le message sur une gateway (série ou réseau) MySensors.

Ajoutez ce code sur le noeud MySensor pour intercepter les messages envoyés à cet objet.

void receive(const MyMessage &message) {
     Serial.print("Message recu pour le capteur :");
     Serial.print(message.sensor);
     Serial.print(", Nouveau statut : ");
     Serial.println(message.getBool()); 
}

Et voilà, si on appuie sur l’interrupteur, on reçoit bien les messages sur le noeud en provenance du flow Node-RED.

Code du flow

[{"id":"f34523e0.fa94a","type":"mysdecenc","z":"e1e0f04d.8c404","name":"","x":546.388916015625,"y":276,"wires":[["a9d71461.a61de8"]]},{"id":"45e9c56a.b8cdec","type":"mysencap","z":"e1e0f04d.8c404","name":"","nodeid":"3","childid":"0","subtype":"2","internal":0,"ack":false,"msgtype":"2","presentation":false,"presentationtype":0,"presentationtext":"","fullpresentation":false,"firmwarename":"","firmwareversion":"","x":400,"y":220.3333282470703,"wires":[["f34523e0.fa94a"]]},{"id":"a9d71461.a61de8","type":"tcp out","z":"e1e0f04d.8c404","host":"192.168.1.20","port":"5003","beserver":"client","base64":false,"end":false,"name":"to MySensors","x":738,"y":232.3333282470703,"wires":[]},{"id":"d253489c.087998","type":"function","z":"e1e0f04d.8c404","name":"slash n","func":"msg.payload = msg.payload + \"\\n\"\nreturn msg;","outputs":1,"noerr":0,"x":274,"y":276.3333282470703,"wires":[["45e9c56a.b8cdec"]]},{"id":"af4ddcee.88eaf","type":"ui_switch","z":"e1e0f04d.8c404","tab":"6df01db6.d8538c","name":"Switch","topic":"","group":"","order":1,"onvalue":"1","offvalue":"0","x":149,"y":224.3333282470703,"wires":[["d253489c.087998"]]},{"id":"6df01db6.d8538c","type":"ui_tab","z":"","name":"Salon","icon":"store","order":"1"}]

Mises à jour

[25/03/2020] Se connecter et décoder les messages MySensors MQTT

Avez-vous aimé cet article ?
[Total: 0 Moyenne: 0]
Quitter la version mobile