Node-REDでECHONET Liteの送受信nodeを作成してみた

##概要
　Node-REDにdefaultでinstallされるUDPの送信nodeと受信nodeを利用して、ECHONET Liteの送受信を容易にするnodeを作成しました。受信したUDP dataはパースされECHONET Liteで規定されるブロックに分解されます。データを送信する場合はECHONET Liteで規定される各ブロックの値を引数として渡します。ECHONET Liteはバイト単位でパケットが構成されますが、UInt8のdata typeを持たないJavaScriptでは扱いにくいため、データはIntで渡します。
　サンプルプログラムとして以下の３つを用意しました。

• Node-REDからマニュアルでエアコンと照明のON/OFF制御
• 電子錠の開閉でエアコンと照明のON/OFF制御
• スマホのブラウザーをエアコンと照明のON/OFF制御リモコンにするweb application

なお、以下の環境で動作確認しています。
Node-RED version: v0.15.1
Node.js version: v6.9.1

全体のFLOWはこんな感じです。

##送信

まず送信側から見ていきましょう。画面上で「EL send」と表示されているUDPの送信ノードの設定はこのようになります。to portに3610を入力してください。

このudp nodeの入力側に接続されている「Send EL1」というfunction nodeの中身はこのようになりますが、理解しなくても使えます。

// Send ECHONET Lite packet
// Assumption: OPC = 1
//
//  Usage:
//      Input following data
//
//  msg.els.ip      // ip address (String)
//  msg.els.tid     // TID (Int)
//  msg.els.seoj    // SEOJ ([Int:device, Int:instance])
//  msg.els.deoj    // DEOJ ([Int:device, Int:instance])
//  msg.els.esv     // ESV (Int)
//  msg.els.epc     // EPC (Int)
//  msg.els.edt     // EDT ([Int])
//          // in case of no EDT data, no edt or []

const tid_buffer = Buffer.allocUnsafe(2);
let   seoj_buffer = Buffer.allocUnsafe(3);
const seoj = msg.els.seoj;
let   deoj_buffer = Buffer.allocUnsafe(3);
const deoj = msg.els.deoj;
const esv_buffer = Buffer.allocUnsafe(1);
const opc_buffer = Buffer.from([1]);
const epc_buffer = Buffer.allocUnsafe(1);
const pdc_buffer = Buffer.allocUnsafe(1);
let edt = msg.els.edt;

tid_buffer.writeUInt16BE(msg.els.tid, 0);
esv_buffer.writeUInt8(msg.els.esv, 0);
epc_buffer.writeUInt8(msg.els.epc, 0);

seoj_buffer.writeUInt16BE(seoj[0], 0);
seoj_buffer.writeUInt8(seoj[1], 2);
deoj_buffer.writeUInt16BE(deoj[0], 0);
deoj_buffer.writeUInt8(deoj[1], 2);

// edt[]からedt_bufferを作成
if ((typeof edt) == "undefined") {
    edt = [];
}

const edt_buffer = Buffer.allocUnsafe(edt.length);
for (var i = 0; i < edt.length; i++) {
    edt_buffer.writeUInt8(edt[i], i);
}

pdc_buffer.writeUInt8(edt_buffer.length, 0);

// Create ECHONET Lite packet
const el_buffer = Buffer.from([
	0x10, 0x81,
	tid_buffer[0], tid_buffer[1],
	seoj_buffer[0], seoj_buffer[1], seoj_buffer[2],
	deoj_buffer[0], deoj_buffer[1], deoj_buffer[2],
	esv_buffer[0], opc_buffer[0], epc_buffer[0], pdc_buffer[0]]);

// add EDT data
if (edt_buffer.length !== 0) {
    msg.payload = Buffer.concat([el_buffer, edt_buffer], 
        (el_buffer.length + edt_buffer.length));
} else {
    msg.payload = el_buffer;
}

msg.ip = msg.els.ip;
return msg;

　冒頭のコメントに記述されているように、このfunctionに以下のデータを渡してやると、byte列のECHONET Liteデータパケットに変換してudp nodeに渡します。なお、OPC=1のみ対応しています。

• msg.els.ip // ip address (String)
• msg.els.tid // TID (Int)
• msg.els.seoj // SEOJ ([Int:device, Int:instance])
• msg.els.deoj // DEOJ ([Int:device, Int:instance])
• msg.els.esv // ESV (Int)
• msg.els.epc // EPC (Int)
• msg.els.edt // EDT ([Int])

具体的には、この「Send EL1」functionの入力側に接続されている「エアコン ON」functionを見てみましょう。

msg.els = {
    "ip" : "224.0.23.0",
    "tid" : 5,
    "seoj" : [0x05ff,1],
    "deoj" : [0x0130,1],
    "esv" : 0x61,
    "epc" : 0x80,
    "edt" : [0x30]
};

return msg;

このfunction内の必要な箇所の値を変更するだけで、ECHONET Liteのデータ送信を実現できます。

##受信

続いて受信側を見ていきましょう。画面上で「EL receive」と表示されているUDPの受信ノードの設定はこのようになります。「Listen for」で「multicast message」を選択し、「Group」に224.0.23.0を「on port」に3610を入力してください。「Output」は「a Buffer」を選択してください。

このudp nodeの出力側に接続されている「Parse EL1」というfunction nodeの中身はこのようになりますが、理解しなくても使えます。

// Parse ECHONET Lite packet
// Assumption: OPC = 1

//  OUTPUT:
//  msg.elr.ip      // ip address (String)
//  msg.elr.ehd     // EHD (Int)
//  msg.elr.tid     // TID (Int)
//  msg.elr.seoj    // SEOJ ([Int:device, Int:instance])
//  msg.elr.deoj    // DEOJ ([Int:device, Int:instance])
//  msg.elr.esv     // ESV (Int)
//  msg.elr.opc     // OPC (Int)
//  msg.elr.epc     // EPC (Int)
//  msg.elr.pdc     // PDC (Int)
//  msg.elr.edt     // EDT ([Int]) or [](no EDT data)

const buffer = msg.payload;
msg.elr = null;

if (buffer.length >= 14) {
  const ehd_buffer = buffer.slice(0, 2);
  const tid_buffer = buffer.slice(2, 4);
  const seoj_device_buffer = buffer.slice(4, 6);
  const seoj_instance_buffer = buffer.slice(6, 7);
  const deoj_device_buffer = buffer.slice(7, 9);
  const deoj_instance_buffer = buffer.slice(9, 10);
  const esv_buffer = buffer.slice(10, 11);
  const opc_buffer = buffer.slice(11, 12);
  const epc_buffer = buffer.slice(12, 13);
  const pdc_buffer = buffer.slice(13, 14);

  const ehd = ehd_buffer.readUInt16BE(0);
  const tid = tid_buffer.readUInt16BE(0);
  const seoj_device = seoj_device_buffer.readUInt16BE(0);
  const seoj_instance = seoj_instance_buffer.readUInt8(0);
  const seoj = [seoj_device, seoj_instance];
  const deoj_device = deoj_device_buffer.readUInt16BE(0);
  const deoj_instance = deoj_instance_buffer.readUInt8(0);
  const deoj = [deoj_device, deoj_instance];
  const esv = esv_buffer.readUInt8(0);
  const opc = opc_buffer.readUInt8(0);
  const epc = epc_buffer.readUInt8(0);
  const pdc = pdc_buffer.readUInt8(0);
  let edt = [];
  
  if (buffer.length >= 15) {
    const edt_buffer = buffer.slice(14);
    for (var i = 0; i < edt_buffer.length; i++) {
        edt[i] = edt_buffer.readUInt8(i);
    }
  }

  // ECHONET Lite header check
  if (ehd == 0x1081) {
    msg.elr = {
        "ip"            : msg.ip,
        "ehd"           : ehd,
        "tid"           : tid,
        "seoj"          : seoj,
        "deoj"          : deoj,
        "esv"           : esv,
        "opc"           : opc,
        "epc"           : epc,
        "pdc"           : pdc,
        "edt"           : edt
    };
  }
}

return msg;

　冒頭のコメントに記述されているように、このfunctionから以下のデータが出力されます。なお、OPC=1のみ対応しています。

• msg.elr.ip // ip address (String)
• msg.elr.ehd // EHD (Int)
• msg.elr.tid // TID (Int)
• msg.elr.seoj // SEOJ ([Int:device, Int:instance])
• msg.elr.deoj // DEOJ ([Int:device, Int:instance])
• msg.elr.esv // ESV (Int)
• msg.elr.opc // OPC (Int)
• msg.elr.epc // EPC (Int)
• msg.elr.pdc // PDC (Int)
• msg.elr.edt // EDT ([Int])

パースされたデータの使い方の例を、この「Parse EL1」functionの出力側に接続されている「filter keyStatus」functionで見てみましょう。受信したデータの送信元が「電子錠」で、プロパティが「開閉状態」ならば、開閉状態を表すEDTデータをmsg.payloadに格納しています。次のswitch nodeで閉(0x41)または開(0x42)で分岐し、エアコンや照明をON/OFF制御しています。

// 電子錠 EOJ=0x026f, 開閉状態 EPC=0xe0
if ((msg.elr.seoj[0] == 0x026f) && (msg.elr.epc == 0xe0)) {
    msg.payload = msg.elr.edt[0];
}

return msg;

##Webリモコン
Node-REDはweb server機能をもっているので、web applicationを容易に作成することができます。全体Flowの下部の「ON/OFF Remote Controller」を見てください。スマホのブラウザで

http://:1880/control

をアクセスすると、このようなシンプルなリモコン画面が現れます。このON/OFFボタンでエアコンや照明をON/OFF制御できます。

全体のFlowの左下部にある「/control」と書かれたhttp nodeでGET requestを受け付けます。このnodeはURLに「/control」と入力してあるだけです。このnodeの出力が接続されている「ON/OFF button」と書かれたtemplate nodeがHTMLを出力して、ブラウザーにボタンを表示します。template nodeのソースコードはこのようになっています。

<!DOCTYPE html>
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
    <meta charset=“UFT-8”>
    <style>
        body { background: #FAFAD2; }
        h1 {color:black; font-family:sans-serif;}
        button { width: 300px; height: 100px; font-size: 36px; border-radius: 10px; border-style: none; background-color: #aaaaaa;}
        button:hover {background-color: #dddddd;}
    </style>
    <title> ON/OFF BUTTON </title>
    <script language="javascript" type="text/javascript">
        function OnButtonClick() {
            location.href = "/on";
        }
        function OffButtonClick() {
            location.href = "/off";
        }
    </script>
</head>
<body>
	<h1>HEMS Controller</h1>
    <button type="button" name="buttonOn" onclick="OnButtonClick()">ON</button> 
    <button type="button" name="buttonOff" onclick="OffButtonClick()">OFF</button> <br/>
</body>
</html>

このHTMLがhttp response nodeから出力されます。

##全体のFlow

全体のFlowのJSONデータはこちらです。

[{"id":"929982f7.1dfe88","type":"inject","z":"b25212d8.336a88","name":"Search","topic":"","payload":"","payloadType":"date","repeat":"","crontab":"","once":false,"x":145.63636779785156,"y":159,"wires":[["48da7a43.d0e234"]]},{"id":"2ab8c00.fd8fd4","type":"link in","z":"b25212d8.336a88","name":"ON","links":["60038e3d.3ea5","60579462.f009ac","a47b7d1b.85f958"],"x":144,"y":242.18182373046875,"wires":[["8f824877.268258","30b813d1.96d6f4"]]},{"id":"7bab7379.ce52ac","type":"link in","z":"b25212d8.336a88","name":"OFF","links":["19f3c295.8e39bd","49fe4793.c299c8","d6714c57.f29c38"],"x":146,"y":329.18182373046875,"wires":[["46ac93c4.9bf35c","2bcde2cc.b0e0b6"]]},{"id":"4f1896ac.7cfcb","type":"comment","z":"b25212d8.336a88","name":"Check Key Status","info":"電子錠のOn/OFFでエアコンと照明のON/OFFを制御","x":128.22727966308594,"y":422.5454406738281,"wires":[]},{"id":"e46582fe.0e69b","type":"comment","z":"b25212d8.336a88","name":"Flow: demoRoom","info":"ECHONET Liteの送受信を実現。\nBrowserで接続するとON/OFF制御のリモコンとなる。","x":138.86363220214844,"y":114.81817626953125,"wires":[]},{"id":"6e147962.3b1508","type":"http in","z":"b25212d8.336a88","name":"/on","url":"/on","method":"get","swaggerDoc":"","x":87.5,"y":628.1818237304688,"wires":[["a47b7d1b.85f958","cd5ec784.0801d8"]]},{"id":"a47b7d1b.85f958","type":"link out","z":"b25212d8.336a88","name":"REST/on","links":["2ab8c00.fd8fd4"],"x":219.5,"y":627.1818313598633,"wires":[]},{"id":"85a91f31.a3686","type":"http in","z":"b25212d8.336a88","name":"/off","url":"/off","method":"get","swaggerDoc":"","x":88,"y":669.1818237304688,"wires":[["d6714c57.f29c38","cd5ec784.0801d8"]]},{"id":"d6714c57.f29c38","type":"link out","z":"b25212d8.336a88","name":"REST/off","links":["7bab7379.ce52ac"],"x":217.5,"y":668.1818237304688,"wires":[]},{"id":"e35592e3.6ced4","type":"http in","z":"b25212d8.336a88","name":"/control","url":"/control","method":"get","swaggerDoc":"","x":87,"y":710.1818237304688,"wires":[["387d2a5d.fa9d76","cd5ec784.0801d8"]]},{"id":"8bb17ee2.8b71c","type":"http response","z":"b25212d8.336a88","name":"","x":596.5,"y":654.1818237304688,"wires":[]},{"id":"387d2a5d.fa9d76","type":"debug","z":"b25212d8.336a88","name":"","active":true,"console":"false","complete":"true","x":371.5,"y":709.1818313598633,"wires":[]},{"id":"dfdee8d8.e1e74","type":"comment","z":"b25212d8.336a88","name":"ON/OFF Remote Controller","info":"Browserで接続すると、ON/OFF制御のボタンが表示される\n\nhttp://<Node-redのIP address>:1880/control","x":149.5,"y":588.1818237304688,"wires":[]},{"id":"baad2d25.311cc8","type":"debug","z":"b25212d8.336a88","name":"","active":true,"console":"false","complete":"true","x":601.5,"y":705.1818237304688,"wires":[]},{"id":"cd5ec784.0801d8","type":"template","z":"b25212d8.336a88","name":"ON/OFF button","field":"payload","fieldType":"msg","format":"html","syntax":"mustache","template":"<!DOCTYPE html>\n<html xmlns=\"http://www.w3.org/1999/xhtml\">\n<head>\n    <meta charset=“UFT-8”>\n    <style>\n        body { background: #FAFAD2; }\n        h1 {color:black; font-family:sans-serif;}\n        button { width: 300px; height: 100px; font-size: 36px; border-radius: 10px; border-style: none; background-color: #aaaaaa;}\n        button:hover {background-color: #dddddd;}\n    </style>\n    <title> ON/OFF BUTTON </title>\n    <script language=\"javascript\" type=\"text/javascript\">\n        function OnButtonClick() {\n            location.href = \"/on\";\n        }\n        function OffButtonClick() {\n            location.href = \"/off\";\n        }\n    </script>\n</head>\n<body>\n\t<h1>HEMS Controller</h1>\n    <button type=\"button\" name=\"buttonOn\" onclick=\"OnButtonClick()\">ON</button> \n    <button type=\"button\" name=\"buttonOff\" onclick=\"OffButtonClick()\">OFF</button> <br/>\n</body>\n</html>","x":389.5,"y":653.1818237304688,"wires":[["8bb17ee2.8b71c","baad2d25.311cc8"]]},{"id":"2cd805cd.f6b84a","type":"function","z":"b25212d8.336a88","name":"Parse EL1","func":"// Parse ECHONET Lite packet\n// Assumption: OPC = 1\n\n//  OUTPUT:\n//  msg.elr.ip      // ip address (String)\n//  msg.elr.ehd     // EHD (Int)\n//  msg.elr.tid     // TID (Int)\n//  msg.elr.seoj    // SEOJ ([Int:device, Int:instance])\n//  msg.elr.deoj    // DEOJ ([Int:device, Int:instance])\n//  msg.elr.esv     // ESV (Int)\n//  msg.elr.opc     // OPC (Int)\n//  msg.elr.epc     // EPC (Int)\n//  msg.elr.pdc     // PDC (Int)\n//  msg.elr.edt     // EDT ([Int]) or [](no EDT data)\n\nconst buffer = msg.payload;\nmsg.elr = null;\n\nif (buffer.length >= 14) {\n  const ehd_buffer = buffer.slice(0, 2);\n  const tid_buffer = buffer.slice(2, 4);\n  const seoj_device_buffer = buffer.slice(4, 6);\n  const seoj_instance_buffer = buffer.slice(6, 7);\n  const deoj_device_buffer = buffer.slice(7, 9);\n  const deoj_instance_buffer = buffer.slice(9, 10);\n  const esv_buffer = buffer.slice(10, 11);\n  const opc_buffer = buffer.slice(11, 12);\n  const epc_buffer = buffer.slice(12, 13);\n  const pdc_buffer = buffer.slice(13, 14);\n\n  const ehd = ehd_buffer.readUInt16BE(0);\n  const tid = tid_buffer.readUInt16BE(0);\n  const seoj_device = seoj_device_buffer.readUInt16BE(0);\n  const seoj_instance = seoj_instance_buffer.readUInt8(0);\n  const seoj = [seoj_device, seoj_instance];\n  const deoj_device = deoj_device_buffer.readUInt16BE(0);\n  const deoj_instance = deoj_instance_buffer.readUInt8(0);\n  const deoj = [deoj_device, deoj_instance];\n  const esv = esv_buffer.readUInt8(0);\n  const opc = opc_buffer.readUInt8(0);\n  const epc = epc_buffer.readUInt8(0);\n  const pdc = pdc_buffer.readUInt8(0);\n  let edt = [];\n  \n  if (buffer.length >= 15) {\n    const edt_buffer = buffer.slice(14);\n    for (var i = 0; i < edt_buffer.length; i++) {\n        edt[i] = edt_buffer.readUInt8(i);\n    }\n  }\n\n  // ECHONET Lite header check\n  if (ehd == 0x1081) {\n    msg.elr = {\n        \"ip\"            : msg.ip,\n        \"ehd\"           : ehd,\n        \"tid\"           : tid,\n        \"seoj\"          : seoj,\n        \"deoj\"          : deoj,\n        \"esv\"           : esv,\n        \"opc\"           : opc,\n        \"epc\"           : epc,\n        \"pdc\"           : pdc,\n        \"edt\"           : edt\n    };\n  }\n}\n\nreturn msg;","outputs":1,"noerr":0,"x":324,"y":458,"wires":[["f79f22e2.9b9448","c709dd31.ebd05"]]},{"id":"f79f22e2.9b9448","type":"function","z":"b25212d8.336a88","name":"filter keyStatus","func":"//  msg.elr.ip      // ip address (String)\n//  msg.elr.ehd     // EHD (Int)\n//  msg.elr.tid     // TID (Int)\n//  msg.elr.seoj    // SEOJ ([Int:device, Int:instance])\n//  msg.elr.deoj    // DEOJ ([Int:device, Int:instance])\n//  msg.elr.esv     // ESV (Int)\n//  msg.elr.opc     // OPC (Int)\n//  msg.elr.epc     // EPC (Int)\n//  msg.elr.pdc     // PDC (Int)\n//  msg.elr.edt     // EDT ([Int]) or [](no EDT data)\n\n// 電子錠 EOJ=0x026f, 開閉状態 EPC=0xe0\nif ((msg.elr.seoj[0] == 0x026f) && (msg.elr.epc == 0xe0)) {\n    msg.payload = msg.elr.edt[0];\n}\n\nreturn msg;","outputs":1,"noerr":0,"x":519,"y":458,"wires":[["acff4917.ab63f8"]]},{"id":"acff4917.ab63f8","type":"switch","z":"b25212d8.336a88","name":"","property":"payload","propertyType":"msg","rules":[{"t":"eq","v":"0x41","vt":"num"},{"t":"eq","v":"0x42","vt":"num"},{"t":"else"}],"checkall":"true","outputs":3,"x":682.5,"y":459,"wires":[["60038e3d.3ea5"],["49fe4793.c299c8"],[]]},{"id":"60038e3d.3ea5","type":"link out","z":"b25212d8.336a88","name":"0x41","links":["2ab8c00.fd8fd4"],"x":798.5,"y":446,"wires":[]},{"id":"49fe4793.c299c8","type":"link out","z":"b25212d8.336a88","name":"0x42","links":["7bab7379.ce52ac"],"x":800.5,"y":484,"wires":[]},{"id":"42922bec.b77014","type":"udp in","z":"b25212d8.336a88","name":"EL receive","iface":"","port":"3610","ipv":"udp4","multicast":"true","group":"224.0.23.0","datatype":"buffer","x":118,"y":459,"wires":[["2cd805cd.f6b84a","c617b521.c138c8","81a3a52d.f2ecd8"]]},{"id":"c617b521.c138c8","type":"debug","z":"b25212d8.336a88","name":"","active":true,"console":"false","complete":"false","x":324.5,"y":509,"wires":[]},{"id":"c709dd31.ebd05","type":"debug","z":"b25212d8.336a88","name":"","active":true,"console":"false","complete":"elr","x":520,"y":506,"wires":[]},{"id":"41393aaf.0409c4","type":"inject","z":"b25212d8.336a88","name":"Search","topic":"","payload":"","payloadType":"date","repeat":"","crontab":"","once":false,"x":112,"y":1251,"wires":[["5819b7f9.f2929"]]},{"id":"5819b7f9.f2929","type":"function","z":"b25212d8.336a88","name":"Search","func":"//  msg.els.ip_string   // ip address (String)\n//  msg.els.tid         // TID (Int)\n//  msg.els.seoj        // SEOJ ([Int:device, Int:instance])\n//  msg.els.deoj        // DEOJ ([Int:device, Int:instance])\n//  msg.els.esv         // ESV (Int)\n//  msg.els.epc         // EPC (Int)\n//  msg.els.edt_int     // EDT ([Int])\n\nmsg.els = {\n    \"ip\" : \"224.0.23.0\",\n    \"tid\" : 5,\n    \"seoj\" : [0x05ff,1],\n    \"deoj\" : [0x0ef0,1],\n    \"esv\" : 0x62,\n    \"epc\" : 0xD6\n};\n\nreturn msg;","outputs":1,"noerr":0,"x":301,"y":1260,"wires":[[]]},{"id":"d1d50d8a.9a455","type":"udp out","z":"b25212d8.336a88","name":"","addr":"","iface":"","port":"3610","ipv":"udp4","outport":"","base64":false,"multicast":"multi","x":769,"y":206,"wires":[]},{"id":"816be296.50e15","type":"inject","z":"b25212d8.336a88","name":"ON","topic":"","payload":"","payloadType":"date","repeat":"","crontab":"","once":false,"x":146,"y":206,"wires":[["30b813d1.96d6f4","8f824877.268258"]]},{"id":"7b5baebc.d748d","type":"function","z":"b25212d8.336a88","name":"Send EL1","func":"// Send ECHONET Lite packet\n// Assumption: OPC = 1\n//\n//  Usage:\n//      Input following data\n//\n//  msg.els.ip      // ip address (String)\n//  msg.els.tid     // TID (Int)\n//  msg.els.seoj    // SEOJ ([Int:device, Int:instance])\n//  msg.els.deoj    // DEOJ ([Int:device, Int:instance])\n//  msg.els.esv     // ESV (Int)\n//  msg.els.epc     // EPC (Int)\n//  msg.els.edt     // EDT ([Int])\n//          // in case of no EDT data, no edt or []\n\nconst tid_buffer = Buffer.allocUnsafe(2);\nlet   seoj_buffer = Buffer.allocUnsafe(3);\nconst seoj = msg.els.seoj;\nlet   deoj_buffer = Buffer.allocUnsafe(3);\nconst deoj = msg.els.deoj;\nconst esv_buffer = Buffer.allocUnsafe(1);\nconst opc_buffer = Buffer.from([1]);\nconst epc_buffer = Buffer.allocUnsafe(1);\nconst pdc_buffer = Buffer.allocUnsafe(1);\nlet edt = msg.els.edt;\n\ntid_buffer.writeUInt16BE(msg.els.tid, 0);\nesv_buffer.writeUInt8(msg.els.esv, 0);\nepc_buffer.writeUInt8(msg.els.epc, 0);\n\nseoj_buffer.writeUInt16BE(seoj[0], 0);\nseoj_buffer.writeUInt8(seoj[1], 2);\ndeoj_buffer.writeUInt16BE(deoj[0], 0);\ndeoj_buffer.writeUInt8(deoj[1], 2);\n\n// edt[]からedt_bufferを作成\nif ((typeof edt) == \"undefined\") {\n    edt = [];\n}\n\nconst edt_buffer = Buffer.allocUnsafe(edt.length);\nfor (var i = 0; i < edt.length; i++) {\n    edt_buffer.writeUInt8(edt[i], i);\n}\n\npdc_buffer.writeUInt8(edt_buffer.length, 0);\n\n// Create ECHONET Lite packet\nconst el_buffer = Buffer.from([\n\t0x10, 0x81,\n\ttid_buffer[0], tid_buffer[1],\n\tseoj_buffer[0], seoj_buffer[1], seoj_buffer[2],\n\tdeoj_buffer[0], deoj_buffer[1], deoj_buffer[2],\n\tesv_buffer[0], opc_buffer[0], epc_buffer[0], pdc_buffer[0]]);\n\n// add EDT data\nif (edt_buffer.length !== 0) {\n    msg.payload = Buffer.concat([el_buffer, edt_buffer], \n        (el_buffer.length + edt_buffer.length));\n} else {\n    msg.payload = el_buffer;\n}\n\nmsg.ip = msg.els.ip;\nreturn msg;","outputs":1,"noerr":0,"x":547.5,"y":207,"wires":[["d1d50d8a.9a455","20a78033.c64988","2ecc22f4.b79f3e"]]},{"id":"20a78033.c64988","type":"debug","z":"b25212d8.336a88","name":"","active":true,"console":"false","complete":"ip","x":760,"y":262,"wires":[]},{"id":"8f824877.268258","type":"function","z":"b25212d8.336a88","name":"エアコン　ON","func":"//  msg.els.ip_string   // ip address (String)\n//  msg.els.tid         // TID (Int)\n//  msg.els.seoj        // SEOJ ([Int:device, Int:instance])\n//  msg.els.deoj        // DEOJ ([Int:device, Int:instance])\n//  msg.els.esv         // ESV (Int)\n//  msg.els.epc         // EPC (Int)\n//  msg.els.edt_int     // EDT ([Int])\n\nmsg.els = {\n    \"ip\" : \"224.0.23.0\",\n    \"tid\" : 5,\n    \"seoj\" : [0x05ff,1],\n    \"deoj\" : [0x0130,1],\n    \"esv\" : 0x61,\n    \"epc\" : 0x80,\n    \"edt\" : [0x30]\n};\n\nreturn msg;","outputs":1,"noerr":0,"x":348.5,"y":206,"wires":[["7b5baebc.d748d"]]},{"id":"30b813d1.96d6f4","type":"function","z":"b25212d8.336a88","name":"ライト　ON","func":"//  msg.els.ip_string   // ip address (String)\n//  msg.els.tid         // TID (Int)\n//  msg.els.seoj        // SEOJ ([Int:device, Int:instance])\n//  msg.els.deoj        // DEOJ ([Int:device, Int:instance])\n//  msg.els.esv         // ESV (Int)\n//  msg.els.epc         // EPC (Int)\n//  msg.els.edt_int     // EDT ([Int])\n\nmsg.els = {\n    \"ip\" : \"224.0.23.0\",\n    \"tid\" : 5,\n    \"seoj\" : [0x05ff,1],\n    \"deoj\" : [0x0290,1],\n    \"esv\" : 0x61,\n    \"epc\" : 0x80,\n    \"edt\" : [0x30]\n};\n\nreturn msg;","outputs":1,"noerr":0,"x":338.5,"y":248,"wires":[["7b5baebc.d748d"]]},{"id":"2bcde2cc.b0e0b6","type":"function","z":"b25212d8.336a88","name":"ライト　OFF","func":"//  msg.els.ip_string   // ip address (String)\n//  msg.els.tid         // TID (Int)\n//  msg.els.seoj        // SEOJ ([Int:device, Int:instance])\n//  msg.els.deoj        // DEOJ ([Int:device, Int:instance])\n//  msg.els.esv         // ESV (Int)\n//  msg.els.epc         // EPC (Int)\n//  msg.els.edt_int     // EDT ([Int])\n\nmsg.els = {\n    \"ip\" : \"224.0.23.0\",\n    \"tid\" : 5,\n    \"seoj\" : [0x05ff,1],\n    \"deoj\" : [0x0290,1],\n    \"esv\" : 0x61,\n    \"epc\" : 0x80,\n    \"edt\" : [0x31]\n};\n\nreturn msg;","outputs":1,"noerr":0,"x":334.5,"y":329,"wires":[["7b5baebc.d748d"]]},{"id":"46ac93c4.9bf35c","type":"function","z":"b25212d8.336a88","name":"エアコン　OFF","func":"//  msg.els.ip_string   // ip address (String)\n//  msg.els.tid         // TID (Int)\n//  msg.els.seoj        // SEOJ ([Int:device, Int:instance])\n//  msg.els.deoj        // DEOJ ([Int:device, Int:instance])\n//  msg.els.esv         // ESV (Int)\n//  msg.els.epc         // EPC (Int)\n//  msg.els.edt_int     // EDT ([Int])\n\nmsg.els = {\n    \"ip\" : \"224.0.23.0\",\n    \"tid\" : 5,\n    \"seoj\" : [0x05ff,1],\n    \"deoj\" : [0x0130,1],\n    \"esv\" : 0x61,\n    \"epc\" : 0x80,\n    \"edt\" : [0x31]\n};\n\nreturn msg;","outputs":1,"noerr":0,"x":348.5,"y":289,"wires":[["7b5baebc.d748d"]]},{"id":"9231a3bb.ce8bc","type":"inject","z":"b25212d8.336a88","name":"OFF","topic":"","payload":"","payloadType":"date","repeat":"","crontab":"","once":false,"x":149,"y":290,"wires":[["2bcde2cc.b0e0b6","46ac93c4.9bf35c"]]},{"id":"2ecc22f4.b79f3e","type":"debug","z":"b25212d8.336a88","name":"","active":true,"console":"false","complete":"false","x":780,"y":308,"wires":[]},{"id":"fad08edd.8db6c8","type":"link in","z":"b25212d8.336a88","name":"UDP send","links":[],"x":605,"y":269,"wires":[["d1d50d8a.9a455"]]},{"id":"81a3a52d.f2ecd8","type":"link out","z":"b25212d8.336a88","name":"UDP receive","links":[],"x":177.5,"y":513,"wires":[]},{"id":"48da7a43.d0e234","type":"function","z":"b25212d8.336a88","name":"Search","func":"//  msg.els.ip_string   // ip address (String)\n//  msg.els.tid         // TID (Int)\n//  msg.els.seoj        // SEOJ ([Int:device, Int:instance])\n//  msg.els.deoj        // DEOJ ([Int:device, Int:instance])\n//  msg.els.esv         // ESV (Int)\n//  msg.els.epc         // EPC (Int)\n//  msg.els.edt_int     // EDT ([Int])\n\nmsg.els = {\n    \"ip\" : \"224.0.23.0\",\n    \"tid\" : 0x30f0,\n    \"seoj\" : [0x05ff,1],\n    \"deoj\" : [0x0ef0,1],\n    \"esv\" : 0x62,\n    \"epc\" : 0xd6,\n    \"edt\" : []\n};\n\nreturn msg;","outputs":1,"noerr":0,"x":330,"y":158,"wires":[["7b5baebc.d748d"]]},{"id":"276ccd10.744a02","type":"comment","z":"b25212d8.336a88","name":"Send EL1","info":"Description: msg.elsの値を元にECHONET Liteのバイナリーデータを作成しUDP送信nodeに値を渡す\n\nAssumption: OPC = 1\n\nUsage: 以下のデータを入力します\n\n- msg.els.ip\n    - Content: ip address\n    - Data Type: String\n    - Sample: \"224.0.23.0\"\n- msg.els.tid\n    - Content: TID\n    - Data Type: Int\n    - Sample: 0x0101\n- msg.els.seoj\n    - Content: SEOJ\n    - Data Type: [Int:device, Int:instance]\n    - device: EOJ, instance: instance number\n    - Sample: [0x05ff, 0x01]\n- msg.els.deoj\n    - Content: DEOJ\n    - Data Type: [Int:device, Int:instance]\n    - device: EOJ, instance: instance number\n    - Sample: [0x0130, 0x01]\n- msg.els.esv\n    - Content: ESV\n    - Data Type: Int\n    - Sample: 0x62\n- msg.els.epc\n    - Content: EPC\n    - Data Type: Int\n    - Sample: 0x80\n- msg.els.edt\n    - Content: EDT\n    - Data Type: [Int]\n    - Sample: [0x30]\n    - Note: in case of no EDT data, []","x":546.5,"y":168,"wires":[]},{"id":"ac7445a8.9d057","type":"comment","z":"b25212d8.336a88","name":"Parse EL1","info":"Description: UDP受信nodeから渡されたデータをパースしmsg.elrとして渡す\n\nAssumption: OPC = 1\n\nUsage: 以下のデータを出力する\n\n- msg.elr.ip\n    - Content: ip address\n    - Data Type: String\n    - Sample: \"224.0.23.0\"\n- msg.elr.ehd\n    - Content: EHD\n    - Data Type: Int\n    - Sample: 0x1081\n- msg.elr.tid\n    - Content: TID\n    - Data Type: Int\n    - Sample: 0x0101\n- msg.elr.seoj\n    - Content: SEOJ\n    - Data Type: [Int:device, Int:instance]\n    - device: EOJ, instance: instance number\n    - Sample: [0x05ff, 0x01]\n- msg.elr.deoj\n    - Content: DEOJ\n    - Data Type: [Int:device, Int:instance]\n    - device: EOJ, instance: instance number\n    - Sample: [0x0130, 0x01]\n- msg.elr.esv\n    - Content: ESV\n    - Data Type: Int\n    - Sample: 0x62\n- msg.elr.opc\n    - Content: OPC\n    - Data Type: Int\n    - Sample: 0x01\n- msg.elr.epc\n    - Content: EPC\n    - Data Type: Int\n    - Sample: 0x80\n- msg.elr.pdc\n    - Content: PDC\n    - Data Type: Int\n    - Sample: 0x01\n- msg.elr.edt\n    - Content: EDT\n    - Data Type: [Int]\n    - Sample: [0x30]\n    - Note: in case of no EDT data, []","x":313,"y":419,"wires":[]}]