node-red-contrib-modbus - npm Package Compare versions

Comparing version 5.13.2 to 5.13.3

CHANGELOG.md

@@ -1,2 +0,2 @@
-## [5.13.2](https://github.com/biancoroyal/node-red-contrib-modbus/compare/v5.13.1...v5.13.2) (2020-05-26)
+## [5.13.1](https://github.com/biancoroyal/node-red-contrib-modbus/compare/v5.12.0...v5.13.1) (2020-05-24)
 
@@ -6,23 +6,6 @@
 
-* **msg:** modbus request data in msg object [#203](https://github.com/biancoroyal/node-red-contrib-modbus/issues/203) ([380357f](https://github.com/biancoroyal/node-red-contrib-modbus/commit/380357f825ebe0b3648b1d146bad136f1a195d89))
-
-
-
-## [5.13.1](https://github.com/biancoroyal/node-red-contrib-modbus/compare/v5.13.0...v5.13.1) (2020-05-24)
-
-
-### Bug Fixes
-
+* **serial:** [#202](https://github.com/biancoroyal/node-red-contrib-modbus/issues/202) locked queue on serial error ([757f341](https://github.com/biancoroyal/node-red-contrib-modbus/commit/757f34192885e7cf157aa438e22266928d477357))
 * **serial:** queue serial sequenced sending [#202](https://github.com/biancoroyal/node-red-contrib-modbus/issues/202) ([e11cb49](https://github.com/biancoroyal/node-red-contrib-modbus/commit/e11cb492037e0d91eb13f82596cbecbc87c6e24d))
 
 
-
-# [5.13.0](https://github.com/biancoroyal/node-red-contrib-modbus/compare/v5.12.0...v5.13.0) (2020-05-21)
-
-
-### Bug Fixes
-
-* **serial:** [#202](https://github.com/biancoroyal/node-red-contrib-modbus/issues/202) locked queue on serial error ([757f341](https://github.com/biancoroyal/node-red-contrib-modbus/commit/757f34192885e7cf157aa438e22266928d477357))
-
-
 ### Features
@@ -131,3 +114,3 @@
 
-# [5.2.0](https://github.com/biancoroyal/node-red-contrib-modbus/compare/5.1.0-0...v5.2.0) (2019-12-08)
+# [5.2.0](https://github.com/biancoroyal/node-red-contrib-modbus/compare/v5.1.0...v5.2.0) (2019-12-08)
 
@@ -139,3 +122,2 @@
 * serialport list call ([f401c58](https://github.com/biancoroyal/node-red-contrib-modbus/commit/f401c58cb384ce87489aecaa99a3000f18e4222b))
-* supporter file missing ([d24fad6](https://github.com/biancoroyal/node-red-contrib-modbus/commit/d24fad66e8730f9535b8d9edc0512087e55b7d07))
 * typo config node client ([9be8b16](https://github.com/biancoroyal/node-red-contrib-modbus/commit/9be8b1634469abfe6b8b6fb471a16f9387b6cee4))
@@ -150,5 +132,10 @@
 
-# [5.1.0-0](https://github.com/biancoroyal/node-red-contrib-modbus/compare/v4.1.3...5.1.0-0) (2019-11-24)
+# [5.1.0](https://github.com/biancoroyal/node-red-contrib-modbus/compare/v4.1.3...v5.1.0) (2019-12-03)
 
 
+### Bug Fixes
+
+* supporter file missing ([d24fad6](https://github.com/biancoroyal/node-red-contrib-modbus/commit/d24fad66e8730f9535b8d9edc0512087e55b7d07))
+
+
 ### Features
@@ -155,0 +142,0 @@

modbus/core/modbus-io-core.js

@@ -1,2 +0,2 @@
-"use strict";require("source-map-support").install();var de=de||{biancoroyal:{modbus:{io:{core:{}}}}};de.biancoroyal.modbus.io.core.internalDebug=de.biancoroyal.modbus.io.core.internalDebug||require("debug")("contribModbus:io:core"),de.biancoroyal.modbus.io.core.LineByLineReader=de.biancoroyal.modbus.io.core.LineByLineReader||require("line-by-line"),de.biancoroyal.modbus.io.core.core=de.biancoroyal.modbus.io.core.core||require("./modbus-core"),de.biancoroyal.modbus.io.core.nameValuesFromIOFile=function(r,e,a,s,t){var i=[],d=de.biancoroyal.modbus.io.core;return r.ioFile&&r.ioFile.configData&&r.ioFile.configData.forEach(function(e){e.valueAddress&&e.valueAddress.startsWith("%I")&&i.push(d.buildInputAddressMapping("MB-INPUTS",e,Number(r.ioFile.addressOffset),Number(t),r.logIOActivities)),e.valueAddress&&e.valueAddress.startsWith("%Q")&&i.push(d.buildOutputAddressMapping("MB-OUTPUTS",e,Number(r.ioFile.addressOffset),Number(t),r.logIOActivities))}),i=d.insertValues(i,a,r.logIOActivities),d.convertValuesByType(i,a,s,r.logIOActivities)},de.biancoroyal.modbus.io.core.allValueNamesFromIOFile=function(r){var a=[],s=de.biancoroyal.modbus.io.core;return r&&r.configData&&r.configData.forEach(function(e){e.valueAddress&&e.valueAddress.startsWith("%I")&&a.push(s.buildInputAddressMapping("MB-INPUTS",e,Number(r.addressOffset),0)),e.valueAddress&&e.valueAddress.startsWith("%Q")&&a.push(s.buildOutputAddressMapping("MB-OUTPUTS",e,Number(r.addressOffset),0))}),a},de.biancoroyal.modbus.io.core.getDataTypeFromFirstCharType=function(e){switch(e){case"w":return"Word";case"d":return"Double";case"r":return"Real";case"f":return"Float";case"i":return"Integer";case"l":return"Long";case"b":return"Boolean";default:return"Unsigned Integer"}},de.biancoroyal.modbus.io.core.buildInputAddressMapping=function(e,r,a,s,t){var i=de.biancoroyal.modbus.io.core,d=0,o=0,u=0,n=0,l=null,b=r.name.substring(0,1),c=r.valueAddress.substring(2,3),m=r.valueAddress.substring(0,3);switch(b){case"w":case"u":d=Number(r.valueAddress.split(m)[1]),u=1,n=16;break;case"i":d=Number(r.valueAddress.split(m)[1]),n="W"===c?(u=1,16):(u=2,32);break;case"r":case"f":d=Number(r.valueAddress.split(m)[1]),u=2,n=32;break;case"d":d=Number(r.valueAddress.split(m)[1]),u=4,n=64;break;case"l":d=Number(r.valueAddress.split(m)[1]),u=5,n=80;break;case"b":"X"===c&&(l=r.valueAddress.split("%IX")[1].split("."),d=Math.floor(Number(l[0])/2),o=8*Number(l[0])+Number(l[1]),n=u=1);break;default:t&&i.internalDebug("unknown input type "+b),n=0}if(n){var g=d-(Number(a)||0);return{register:e,name:r.name,addressStart:d,addressOffset:u,addressOffsetIO:Number(a)||0,addressStartIO:g,registerAddress:g-Number(s),coilStart:o,bitAddress:l,Bit:l?8*Number(l[0])+Number(l[1]):0,bits:n,dataType:i.getDataTypeFromFirstCharType(b),type:"input"}}return{name:r.name,type:b,mapping:r,error:"variable name does not match input mapping"}},de.biancoroyal.modbus.io.core.buildOutputAddressMapping=function(e,r,a,s,t){var i=de.biancoroyal.modbus.io.core,d=0,o=0,u=0,n=0,l=null,b=r.name.substring(0,1),c=r.valueAddress.substring(2,3),m=r.valueAddress.substring(0,3);switch(b){case"w":case"u":d=Number(r.valueAddress.split(m)[1]),u=1,n=16;break;case"i":d=Number(r.valueAddress.split(m)[1]),n="W"===c?(u=1,16):(u=2,32);break;case"r":case"f":d=Number(r.valueAddress.split(m)[1]),u=2,n=32;break;case"d":d=Number(r.valueAddress.split(m)[1]),u=4,n=64;break;case"l":d=Number(r.valueAddress.split(m)[1]),u=5,n=80;break;case"b":"X"===c&&(l=r.valueAddress.split("%QX")[1].split("."),d=Math.floor(Number(l[0])/2),o=8*Number(l[0])+Number(l[1]),n=u=1);break;default:t&&i.internalDebug("unknown output type "+b),n=0}if(n){var g=d-(Number(a)||0);return{register:e,name:r.name,addressStart:d,addressOffset:u,addressOffsetIO:Number(a)||0,addressStartIO:g,registerAddress:g-Number(s),coilStart:o,bitAddress:l,Bit:l?8*Number(l[0])+Number(l[1]):0,bits:n,dataType:i.getDataTypeFromFirstCharType(b),type:"output"}}return{name:r.name,type:b,mapping:r,error:"variable name does not match output mapping"}},de.biancoroyal.modbus.io.core.insertValues=function(e,r,a){var s=de.biancoroyal.modbus.io.core,t=0;for(t in e){var i=e[t];if(!i||!Object.prototype.hasOwnProperty.call(i,"registerAddress")||i.registerAddress<0)a&&s.internalDebug("Item Not Valid To Insert Value "+JSON.stringify(i));else{if(de.biancoroyal.modbus.io.core.isRegisterSizeWrong(r,i.registerAddress,Number(i.bits))){a&&s.internalDebug("Insert Value Register Reached At Address-Start-IO:"+i.registerAddress+" Bits:"+Number(i.bits));break}switch(Number(i.bits)){case 1:i.value=!!(r[i.registerAddress]&Math.pow(i.bitAddress[1],2));break;case 16:i.value=r[i.registerAddress];break;case 32:i.value=r[i.registerAddress+1]<<16|r[i.registerAddress];break;case 64:i.value=r[i.registerAddress+3]<<48|r[i.registerAddress+2]<<32|r[i.registerAddress+1]<<16|r[i.registerAddress];break;case 80:i.value=r[i.registerAddress+4]<<64|r[i.registerAddress+3]<<48|r[i.registerAddress+2]<<32|r[i.registerAddress+1]<<16|r[i.registerAddress];break;default:i.value=null}}}return e},de.biancoroyal.modbus.io.core.getValueFromBufferByDataType=function(e,r,a,s){var t=de.biancoroyal.modbus.io.core,i=a.length/2;if(r<0||r>a.length)return s&&(t.internalDebug("Wrong Buffer Access Parameter Type:"+e.dataType+" Register-Length: "+i+" Buffer-Length:"+a.length+" Address-Buffer-Offset:"+r),t.internalDebug(JSON.stringify(e))),e;switch(s&&t.internalDebug("Get Value From Buffer By Data Type:"+e.dataType+" Register:"+e.registerAddress+" Bits:"+Number(e.bits)),e.dataType){case"Boolean":e.value=!!(a.readUInt16BE(r)&Math.pow(e.bitAddress[1],2));break;case"Word":switch(e.bits){case"8":e.value=a.readInt8(r);break;default:e.value=a.readInt16BE(r),e.convertedValue=!1}break;case"Integer":switch(e.bits){case"8":e.value=a.readInt8(r);break;case"32":e.value=a.readInt32BE(r);break;case"64":e.value=a.readIntBE(r,8);break;default:e.value=a.readInt16BE(r)}break;case"Real":case"Float":e.value=a.readFloatBE(r,4);break;case"Double":e.value=a.readDoubleBE(r,8);break;case"Long":e.value=a.readDoubleBE(r,10);break;default:switch(e.bits){case"8":e.value=a.readUInt8(r);break;case"32":e.value=a.readUInt32BE(r);break;case"64":e.value=a.readUIntBE(r,8);break;default:e.value=a.readUInt16BE(r),e.convertedValue=!1}}return e},de.biancoroyal.modbus.io.core.convertValuesByType=function(e,r,a,s){var t=de.biancoroyal.modbus.io.core,i=0,d=0;for(d in e){var o=e[d];if(o&&Object.prototype.hasOwnProperty.call(o,"dataType")&&Object.prototype.hasOwnProperty.call(o,"registerAddress")&&!(o.registerAddress<0)){if(de.biancoroyal.modbus.io.core.isRegisterSizeWrong(r,o.registerAddress,Number(o.bits))){s&&t.internalDebug("Insert Value Register Reached At Address-Start-IO:"+o.registerAddress+" Bits:"+Number(o.bits));break}if(!(a.buffer instanceof Buffer)){s&&t.internalDebug("Response Buffer Is Not A Buffer");break}i=2*Number(o.registerAddress);try{o=t.getValueFromBufferByDataType(o,i,a.buffer,s)}catch(e){t.internalDebug(e.message)}}else s&&t.internalDebug("Item Not Valid To Convert "+JSON.stringify(o))}return e},de.biancoroyal.modbus.io.core.filterValueNames=function(e,r,a,s,t){if(!r.length||!r.filter)return r;var i=de.biancoroyal.modbus.io.core,d="input";2!==a&&4!==a||(d="output");var o=s,u=Number(s)+Number(t)-1;return e.logIOActivities&&i.internalDebug("adr:"+s+" quantity:"+t+" startRegister:"+o+" endRegister:"+u+" functionType:"+d),r.filter(function(e){return 0<=e.registerAddress&&e.addressStartIO>=o&&e.addressStartIO<=u&&e.type===d})},de.biancoroyal.modbus.io.core.isRegisterSizeWrong=function(e,r,a){var s=Number(a)||16,t=Number(r),i=16<s?t+s/16-1:t;return t<0||e.length<t||i>e.length},de.biancoroyal.modbus.io.core.buildMessageWithIO=function(e,r,a,s){var t=this.core.getOriginalMessage(e.bufferMessageList,s);t.modbusRequest=Object.assign({},s.payload),t.payload=r,t.topic=s.topic,t.responseBuffer=a;var i=Object.assign({},t);if(i.payload=a,i.values=r,delete i.responseBuffer,e.useIOFile&&e.ioFile.lastUpdatedAt){var d=this.nameValuesFromIOFile(e,s,r,a,parseInt(s.payload.address)||0),o=this.filterValueNames(e,d,parseInt(s.payload.fc)||3,parseInt(s.payload.address)||0,parseInt(s.payload.quantity)||1,e.logIOActivities);return e.useIOForPayload?(t.payload=o,t.values=r):(t.payload=r,t.valueNames=o),i.valueNames=o,[t,i]}return[t,i]},module.exports=de.biancoroyal.modbus.io.core;
+"use strict";require("source-map-support").install();var de=de||{biancoroyal:{modbus:{io:{core:{}}}}};de.biancoroyal.modbus.io.core.internalDebug=de.biancoroyal.modbus.io.core.internalDebug||require("debug")("contribModbus:io:core"),de.biancoroyal.modbus.io.core.LineByLineReader=de.biancoroyal.modbus.io.core.LineByLineReader||require("line-by-line"),de.biancoroyal.modbus.io.core.core=de.biancoroyal.modbus.io.core.core||require("./modbus-core"),de.biancoroyal.modbus.io.core.nameValuesFromIOFile=function(r,e,a,s,t){var i=[],d=de.biancoroyal.modbus.io.core;return r.ioFile&&r.ioFile.configData&&r.ioFile.configData.forEach(function(e){e.valueAddress&&e.valueAddress.startsWith("%I")&&i.push(d.buildInputAddressMapping("MB-INPUTS",e,Number(r.ioFile.addressOffset),Number(t),r.logIOActivities)),e.valueAddress&&e.valueAddress.startsWith("%Q")&&i.push(d.buildOutputAddressMapping("MB-OUTPUTS",e,Number(r.ioFile.addressOffset),Number(t),r.logIOActivities))}),i=d.insertValues(i,a,r.logIOActivities),d.convertValuesByType(i,a,s,r.logIOActivities)},de.biancoroyal.modbus.io.core.allValueNamesFromIOFile=function(r){var a=[],s=de.biancoroyal.modbus.io.core;return r&&r.configData&&r.configData.forEach(function(e){e.valueAddress&&e.valueAddress.startsWith("%I")&&a.push(s.buildInputAddressMapping("MB-INPUTS",e,Number(r.addressOffset),0)),e.valueAddress&&e.valueAddress.startsWith("%Q")&&a.push(s.buildOutputAddressMapping("MB-OUTPUTS",e,Number(r.addressOffset),0))}),a},de.biancoroyal.modbus.io.core.getDataTypeFromFirstCharType=function(e){switch(e){case"w":return"Word";case"d":return"Double";case"r":return"Real";case"f":return"Float";case"i":return"Integer";case"l":return"Long";case"b":return"Boolean";default:return"Unsigned Integer"}},de.biancoroyal.modbus.io.core.buildInputAddressMapping=function(e,r,a,s,t){var i=de.biancoroyal.modbus.io.core,d=0,o=0,u=0,n=0,l=null,b=r.name.substring(0,1),c=r.valueAddress.substring(2,3),m=r.valueAddress.substring(0,3);switch(b){case"w":case"u":d=Number(r.valueAddress.split(m)[1]),u=1,n=16;break;case"i":d=Number(r.valueAddress.split(m)[1]),n="W"===c?(u=1,16):(u=2,32);break;case"r":case"f":d=Number(r.valueAddress.split(m)[1]),u=2,n=32;break;case"d":d=Number(r.valueAddress.split(m)[1]),u=4,n=64;break;case"l":d=Number(r.valueAddress.split(m)[1]),u=5,n=80;break;case"b":"X"===c&&(l=r.valueAddress.split("%IX")[1].split("."),d=Math.floor(Number(l[0])/2),o=8*Number(l[0])+Number(l[1]),n=u=1);break;default:t&&i.internalDebug("unknown input type "+b),n=0}if(n){var g=d-(Number(a)||0);return{register:e,name:r.name,addressStart:d,addressOffset:u,addressOffsetIO:Number(a)||0,addressStartIO:g,registerAddress:g-Number(s),coilStart:o,bitAddress:l,Bit:l?8*Number(l[0])+Number(l[1]):0,bits:n,dataType:i.getDataTypeFromFirstCharType(b),type:"input"}}return{name:r.name,type:b,mapping:r,error:"variable name does not match input mapping"}},de.biancoroyal.modbus.io.core.buildOutputAddressMapping=function(e,r,a,s,t){var i=de.biancoroyal.modbus.io.core,d=0,o=0,u=0,n=0,l=null,b=r.name.substring(0,1),c=r.valueAddress.substring(2,3),m=r.valueAddress.substring(0,3);switch(b){case"w":case"u":d=Number(r.valueAddress.split(m)[1]),u=1,n=16;break;case"i":d=Number(r.valueAddress.split(m)[1]),n="W"===c?(u=1,16):(u=2,32);break;case"r":case"f":d=Number(r.valueAddress.split(m)[1]),u=2,n=32;break;case"d":d=Number(r.valueAddress.split(m)[1]),u=4,n=64;break;case"l":d=Number(r.valueAddress.split(m)[1]),u=5,n=80;break;case"b":"X"===c&&(l=r.valueAddress.split("%QX")[1].split("."),d=Math.floor(Number(l[0])/2),o=8*Number(l[0])+Number(l[1]),n=u=1);break;default:t&&i.internalDebug("unknown output type "+b),n=0}if(n){var g=d-(Number(a)||0);return{register:e,name:r.name,addressStart:d,addressOffset:u,addressOffsetIO:Number(a)||0,addressStartIO:g,registerAddress:g-Number(s),coilStart:o,bitAddress:l,Bit:l?8*Number(l[0])+Number(l[1]):0,bits:n,dataType:i.getDataTypeFromFirstCharType(b),type:"output"}}return{name:r.name,type:b,mapping:r,error:"variable name does not match output mapping"}},de.biancoroyal.modbus.io.core.insertValues=function(e,r,a){var s=de.biancoroyal.modbus.io.core,t=0;for(t in e){var i=e[t];if(!i||!Object.prototype.hasOwnProperty.call(i,"registerAddress")||i.registerAddress<0)a&&s.internalDebug("Item Not Valid To Insert Value "+JSON.stringify(i));else{if(de.biancoroyal.modbus.io.core.isRegisterSizeWrong(r,i.registerAddress,Number(i.bits))){a&&s.internalDebug("Insert Value Register Reached At Address-Start-IO:"+i.registerAddress+" Bits:"+Number(i.bits));break}switch(Number(i.bits)){case 1:i.value=!!(r[i.registerAddress]&Math.pow(i.bitAddress[1],2));break;case 16:i.value=r[i.registerAddress];break;case 32:i.value=r[i.registerAddress+1]<<16|r[i.registerAddress];break;case 64:i.value=r[i.registerAddress+3]<<48|r[i.registerAddress+2]<<32|r[i.registerAddress+1]<<16|r[i.registerAddress];break;case 80:i.value=r[i.registerAddress+4]<<64|r[i.registerAddress+3]<<48|r[i.registerAddress+2]<<32|r[i.registerAddress+1]<<16|r[i.registerAddress];break;default:i.value=null}}}return e},de.biancoroyal.modbus.io.core.getValueFromBufferByDataType=function(e,r,a,s){var t=de.biancoroyal.modbus.io.core,i=a.length/2;if(r<0||r>a.length)return s&&(t.internalDebug("Wrong Buffer Access Parameter Type:"+e.dataType+" Register-Length: "+i+" Buffer-Length:"+a.length+" Address-Buffer-Offset:"+r),t.internalDebug(JSON.stringify(e))),e;switch(s&&t.internalDebug("Get Value From Buffer By Data Type:"+e.dataType+" Register:"+e.registerAddress+" Bits:"+Number(e.bits)),e.dataType){case"Boolean":e.value=!!(a.readUInt16BE(r)&Math.pow(e.bitAddress[1],2));break;case"Word":switch(e.bits){case"8":e.value=a.readInt8(r);break;default:e.value=a.readInt16BE(r),e.convertedValue=!1}break;case"Integer":switch(e.bits){case"8":e.value=a.readInt8(r);break;case"32":e.value=a.readInt32BE(r);break;case"64":e.value=a.readIntBE(r,8);break;default:e.value=a.readInt16BE(r)}break;case"Real":case"Float":e.value=a.readFloatBE(r,4);break;case"Double":e.value=a.readDoubleBE(r,8);break;case"Long":e.value=a.readDoubleBE(r,10);break;default:switch(e.bits){case"8":e.value=a.readUInt8(r);break;case"32":e.value=a.readUInt32BE(r);break;case"64":e.value=a.readUIntBE(r,8);break;default:e.value=a.readUInt16BE(r),e.convertedValue=!1}}return e},de.biancoroyal.modbus.io.core.convertValuesByType=function(e,r,a,s){var t,i=de.biancoroyal.modbus.io.core,d=0;for(d in e){var o=e[d];if(o&&Object.prototype.hasOwnProperty.call(o,"dataType")&&Object.prototype.hasOwnProperty.call(o,"registerAddress")&&!(o.registerAddress<0)){if(de.biancoroyal.modbus.io.core.isRegisterSizeWrong(r,o.registerAddress,Number(o.bits))){s&&i.internalDebug("Insert Value Register Reached At Address-Start-IO:"+o.registerAddress+" Bits:"+Number(o.bits));break}if(!(a.buffer instanceof Buffer)){s&&i.internalDebug("Response Buffer Is Not A Buffer");break}t=2*Number(o.registerAddress);try{o=i.getValueFromBufferByDataType(o,t,a.buffer,s)}catch(e){i.internalDebug(e.message)}}else s&&i.internalDebug("Item Not Valid To Convert "+JSON.stringify(o))}return e},de.biancoroyal.modbus.io.core.filterValueNames=function(e,r,a,s,t){if(!r.length||!r.filter)return r;var i=de.biancoroyal.modbus.io.core,d="input";2!==a&&4!==a||(d="output");var o=s,u=Number(s)+Number(t)-1;return e.logIOActivities&&i.internalDebug("adr:"+s+" quantity:"+t+" startRegister:"+o+" endRegister:"+u+" functionType:"+d),r.filter(function(e){return 0<=e.registerAddress&&e.addressStartIO>=o&&e.addressStartIO<=u&&e.type===d})},de.biancoroyal.modbus.io.core.isRegisterSizeWrong=function(e,r,a){var s=Number(a)||16,t=Number(r),i=16<s?t+s/16-1:t;return t<0||e.length<t||i>e.length},de.biancoroyal.modbus.io.core.buildMessageWithIO=function(e,r,a,s){var t=this.core.getOriginalMessage(e.bufferMessageList,s);t.modbusRequest=Object.assign({},s.payload),t.payload=r,t.topic=s.topic,t.responseBuffer=a;var i=Object.assign({},t);if(i.payload=a,i.values=r,delete i.responseBuffer,e.useIOFile&&e.ioFile.lastUpdatedAt){var d=this.nameValuesFromIOFile(e,s,r,a,parseInt(s.payload.address)||0),o=this.filterValueNames(e,d,parseInt(s.payload.fc)||3,parseInt(s.payload.address)||0,parseInt(s.payload.quantity)||1,e.logIOActivities);return e.useIOForPayload?(t.payload=o,t.values=r):(t.payload=r,t.valueNames=o),i.valueNames=o,[t,i]}return[t,i]},module.exports=de.biancoroyal.modbus.io.core;
 //# sourceMappingURL=../maps/core/modbus-io-core.js.map

modbus/modbus-basics.js

@@ -1,2 +0,2 @@
-"use strict";require("source-map-support").install();var de=de||{biancoroyal:{modbus:{basics:{}}}};de.biancoroyal.modbus.basics.internalDebug=de.biancoroyal.modbus.basics.internalDebug||require("debug")("contribModbus:basics"),de.biancoroyal.modbus.basics.util=de.biancoroyal.modbus.basics.util||require("util"),de.biancoroyal.modbus.basics.statusLog=!1,de.biancoroyal.modbus.basics.get_timeUnit_name=function(e){var s="";switch(e){case"ms":s="msec.";break;case"s":s="sec.";break;case"m":s="min.";break;case"h":s="h."}return s},de.biancoroyal.modbus.basics.calc_rateByUnit=function(e,s){switch(s){case"ms":break;case"s":e=1e3*parseInt(e);break;case"m":e=6e4*parseInt(e);break;case"h":e=36e5*parseInt(e);break;default:e=1e4}return e},de.biancoroyal.modbus.basics.setNodeStatusProperties=function(e,s){var t="yellow",o="ring",a=(e=e||"waiting").value||e;switch(a){case"connecting":t="yellow",o="ring";break;case"error":t="red",o="ring";break;case"initialized":case"init":t="yellow",o="dot";break;case"not ready to read":case"not ready to write":t="yellow",o="ring";break;case"connected":case"queueing":case"queue":t="green",o="ring";break;case"timeout":t="red",o="ring";break;case"active":case"reading":case"writing":case"active reading":case"active writing":s||(a="active"),t="green",o="dot";break;case"disconnected":case"terminated":t="red",o="ring";break;case"stopped":t="red",o="dot";break;case"polling":t="green",o=s?"ring":(a="active","dot");break;default:"waiting"===a&&(t="blue",a="waiting ...")}return{fill:t,shape:o,status:a}},de.biancoroyal.modbus.basics.setNodeStatusByResponseTo=function(e,s,t){var o="red",a="dot";switch(e){case"initialized":case"queue":o="green",a="ring";break;case"active":o="green",a="dot";break;default:e&&"waiting"!==e||(o="blue",e="waiting ...")}t.status({fill:o,shape:a,text:this.util.inspect(s,!1,null)})},de.biancoroyal.modbus.basics.setNodeStatusResponse=function(e,s){s.status({fill:"green",shape:"dot",text:"active got length: "+e})},de.biancoroyal.modbus.basics.setModbusError=function(e,s,t,o){if(t)switch(t.message){case"Timed out":this.setNodeStatusTo("timeout",e);break;case"FSM Not Ready To Reconnect":this.setNodeStatusTo("not ready to reconnect",e);break;case"Port Not Open":this.setNodeStatusTo("reconnect",e),s.emit("reconnect");break;default:this.internalDebug(t.message),e.showErrors&&this.setNodeStatusTo("error "+t.message,e)}},de.biancoroyal.modbus.basics.setNodeStatusTo=function(e,s){var t;s.showStatusActivities&&(e!==s.statusText?(t=this.setNodeStatusProperties(e,s.showStatusActivities),s.statusText=e,s.status({fill:t.fill,shape:t.shape,text:t.status})):this.setNodeDefaultStatus())},de.biancoroyal.modbus.basics.onModbusInit=function(e){this.setNodeStatusTo("initialize",e)},de.biancoroyal.modbus.basics.onModbusConnect=function(e){this.setNodeStatusTo("connected",e)},de.biancoroyal.modbus.basics.onModbusActive=function(e){this.setNodeStatusTo("active",e)},de.biancoroyal.modbus.basics.onModbusError=function(e,s){this.setNodeStatusTo("failure",e),e.showErrors&&e.warn(s)},de.biancoroyal.modbus.basics.onModbusClose=function(e){this.setNodeStatusTo("closed",e)},de.biancoroyal.modbus.basics.onModbusQueue=function(e){this.setNodeStatusTo("queueing",e)},de.biancoroyal.modbus.basics.onModbusBroken=function(e,s){this.setNodeStatusTo("reconnecting after "+s.reconnectTimeout+" msec.",e)},de.biancoroyal.modbus.basics.setNodeDefaultStatus=function(e){e.status({fill:"green",shape:"ring",text:"active"})},de.biancoroyal.modbus.basics.initModbusClientEvents=function(s,e){var t=this;s.showStatusActivities?(e.on("mbinit",function(){t.onModbusInit(s)}),e.on("mbqueue",function(){t.onModbusQueue(s)}),e.on("mbconnected",function(){t.onModbusConnect(s)}),e.on("mbbroken",function(){t.onModbusBroken(s,e)}),e.on("mbactive",function(){t.onModbusActive(s)}),e.on("mberror",function(e){t.onModbusError(s,e)}),e.on("mbclosed",function(){t.onModbusClose(s)})):this.setNodeDefaultStatus(s)},de.biancoroyal.modbus.basics.invalidPayloadIn=function(e){return!(e&&Object.prototype.hasOwnProperty.call(e,"payload"))},de.biancoroyal.modbus.basics.sendEmptyMsgOnFail=function(e,s,t){e.emptyMsgOnFail&&(t.payload="",s&&s.message&&s.name?t.error=s:t.error=Error(s),t.error.nodeStatus=e.statusText,e.send([t,t]))},de.biancoroyal.modbus.basics.logMsgError=function(e,s,t){e.showErrors&&e.error(s,t)},de.biancoroyal.modbus.basics.buildNewMessage=function(e,s,t){return e?Object.assign(s,t):t},module.exports=de.biancoroyal.modbus.basics;
+"use strict";require("source-map-support").install();var de=de||{biancoroyal:{modbus:{basics:{}}}};de.biancoroyal.modbus.basics.internalDebug=de.biancoroyal.modbus.basics.internalDebug||require("debug")("contribModbus:basics"),de.biancoroyal.modbus.basics.util=de.biancoroyal.modbus.basics.util||require("util"),de.biancoroyal.modbus.basics.statusLog=!1,de.biancoroyal.modbus.basics.get_timeUnit_name=function(e){var s="";switch(e){case"ms":s="msec.";break;case"s":s="sec.";break;case"m":s="min.";break;case"h":s="h."}return s},de.biancoroyal.modbus.basics.calc_rateByUnit=function(e,s){switch(s){case"ms":break;case"s":e=1e3*parseInt(e);break;case"m":e=6e4*parseInt(e);break;case"h":e=36e5*parseInt(e);break;default:e=1e4}return e},de.biancoroyal.modbus.basics.setNodeStatusProperties=function(e,s){var t="yellow",o="ring",a=(e=e||"waiting").value||e;switch(a){case"connecting":t="yellow",o="ring";break;case"error":t="red",o="ring";break;case"initialized":case"init":t="yellow",o="dot";break;case"not ready to read":case"not ready to write":t="yellow",o="ring";break;case"connected":case"queueing":case"queue":t="green",o="ring";break;case"timeout":t="red",o="ring";break;case"active":case"reading":case"writing":case"active reading":case"active writing":s||(a="active"),t="green",o="dot";break;case"disconnected":case"terminated":t="red",o="ring";break;case"stopped":t="red",o="dot";break;case"polling":t="green",o=s?"ring":(a="active","dot");break;default:"waiting"===a&&(t="blue",a="waiting ...")}return{fill:t,shape:o,status:a}},de.biancoroyal.modbus.basics.setNodeStatusByResponseTo=function(e,s,t){var o="red",a="dot";switch(e){case"initialized":case"queue":o="green",a="ring";break;case"active":o="green",a="dot";break;default:e&&"waiting"!==e||(o="blue",e="waiting ...")}t.status({fill:o,shape:a,text:this.util.inspect(s,!1,null)})},de.biancoroyal.modbus.basics.setNodeStatusResponse=function(e,s){s.status({fill:"green",shape:"dot",text:"active got length: "+e})},de.biancoroyal.modbus.basics.setModbusError=function(e,s,t,o){if(t)switch(t.message){case"Timed out":this.setNodeStatusTo("timeout",e);break;case"FSM Not Ready To Reconnect":this.setNodeStatusTo("not ready to reconnect",e);break;case"Port Not Open":this.setNodeStatusTo("reconnect",e),s.emit("reconnect");break;default:this.internalDebug(t.message),e.showErrors&&this.setNodeStatusTo("error "+t.message,e)}},de.biancoroyal.modbus.basics.setNodeStatusTo=function(e,s){var t;s.showStatusActivities&&(e!==s.statusText?(t=this.setNodeStatusProperties(e,s.showStatusActivities),s.statusText=e,s.status({fill:t.fill,shape:t.shape,text:t.status})):this.setNodeDefaultStatus(s))},de.biancoroyal.modbus.basics.onModbusInit=function(e){this.setNodeStatusTo("initialize",e)},de.biancoroyal.modbus.basics.onModbusConnect=function(e){this.setNodeStatusTo("connected",e)},de.biancoroyal.modbus.basics.onModbusActive=function(e){this.setNodeStatusTo("active",e)},de.biancoroyal.modbus.basics.onModbusError=function(e,s){this.setNodeStatusTo("failure",e),e.showErrors&&e.warn(s)},de.biancoroyal.modbus.basics.onModbusClose=function(e){this.setNodeStatusTo("closed",e)},de.biancoroyal.modbus.basics.onModbusQueue=function(e){this.setNodeStatusTo("queueing",e)},de.biancoroyal.modbus.basics.onModbusBroken=function(e,s){this.setNodeStatusTo("reconnecting after "+s.reconnectTimeout+" msec.",e)},de.biancoroyal.modbus.basics.setNodeDefaultStatus=function(e){e.status({fill:"green",shape:"ring",text:"active"})},de.biancoroyal.modbus.basics.initModbusClientEvents=function(s,e){var t=this;s.showStatusActivities?(e.on("mbinit",function(){t.onModbusInit(s)}),e.on("mbqueue",function(){t.onModbusQueue(s)}),e.on("mbconnected",function(){t.onModbusConnect(s)}),e.on("mbbroken",function(){t.onModbusBroken(s,e)}),e.on("mbactive",function(){t.onModbusActive(s)}),e.on("mberror",function(e){t.onModbusError(s,e)}),e.on("mbclosed",function(){t.onModbusClose(s)})):this.setNodeDefaultStatus(s)},de.biancoroyal.modbus.basics.invalidPayloadIn=function(e){return!(e&&Object.prototype.hasOwnProperty.call(e,"payload"))},de.biancoroyal.modbus.basics.sendEmptyMsgOnFail=function(e,s,t){e.emptyMsgOnFail&&(t.payload="",s&&s.message&&s.name?t.error=s:t.error=Error(s),t.error.nodeStatus=e.statusText,e.send([t,t]))},de.biancoroyal.modbus.basics.logMsgError=function(e,s,t){e.showErrors&&e.error(s,t)},de.biancoroyal.modbus.basics.buildNewMessage=function(e,s,t){return e?Object.assign(s,t):t},module.exports=de.biancoroyal.modbus.basics;
 //# sourceMappingURL=maps/modbus-basics.js.map

modbus/modbus-queue-info.js

@@ -1,2 +0,2 @@
-"use strict";module.exports=function(i){require("source-map-support").install();var t=require("./modbus-basics"),o=require("./core/modbus-queue-core"),s=require("debug")("contribModbus:queue");i.nodes.registerType("modbus-queue-info",function(e){i.nodes.createNode(this,e),this.name=e.name,this.topic=e.topic,this.unitid=parseInt(e.unitid)||1,this.lowLowLevel=parseInt(e.lowLowLevel),this.lowLevel=parseInt(e.lowLevel),this.highLevel=parseInt(e.highLevel),this.highHighLevel=parseInt(e.highHighLevel),this.errorOnHighLevel=e.errorOnHighLevel,this.queueReadIntervalTime=e.queueReadIntervalTime||1e3,this.showStatusActivities=e.showStatusActivities,this.updateOnAllQueueChanges=e.updateOnAllQueueChanges,this.updateOnAllUnitQueues=e.updateOnAllUnitQueues,this.internalDebugLog=s;var n=this;n.queueReadInterval=null,n.updateStatusRrunning=!1,n.unitsWithQueue=new Map,t.setNodeStatusTo("waiting",n);var a=i.nodes.getNode(e.server);a&&(a.registerForModbus(n),n.initUnitQueueStates=function(){for(var e=0;e<256;e+=1)n.unitsWithQueue.set(e,{}),n.resetStates(e)},n.resetStates=function(e){var t=n.unitsWithQueue.get(e);t.lowLowLevelReached=!0,t.lowLevelReached=!1,t.highLevelReached=!1,t.highHighLevelReached=!1},n.initUnitQueueStates(),n.checkLowLevelReached=function(e,t,u){var i,n=e.unitsWithQueue.get(u);!n.lowLevelReached&&t>e.lowLowLevel&&t<e.lowLevel&&(n.lowLevelReached=!0,i={payload:Date.now(),topic:e.topic,state:"low level reached",unitid:u,modbusClientName:a.name,bufferCommandListLength:t},e.send(i))},n.checkHighLevelReached=function(e,t,u){var i,n=e.unitsWithQueue.get(u);!n.highLevelReached&&t>e.lowLevel&&t>e.highLevel&&(n.highLevelReached=!0,i={payload:Date.now(),topic:e.topic,state:"high level reached",unitid:u,modbusClientName:a.name||a.id,highLevel:e.highLevel,bufferCommandListLength:t},e.errorOnHighLevel?e.error(new Error("Queue High Level Reached"),i):e.warn(i),e.send(i))},n.checkHighHighLevelReached=function(e,t,u){var i,n=e.unitsWithQueue.get(u);!n.highHighLevelReached&&t>e.highLevel&&t>e.highHighLevel&&(n.highHighLevelReached=!0,i={payload:Date.now(),topic:e.topic,state:"high high level reached",unitid:u,modbusClientName:a.name||a.id,highLevel:e.highLevel,highHighLevel:e.highHighLevel,bufferCommandListLength:t},e.error(new Error("Queue High High Level Reached"),i),e.send(i))},n.getStatusSituationFillColor=function(e){var t=n.unitsWithQueue.get(e),u="blue";return t.lowLevelReached&&(u="green"),t.highLevelReached&&(u=n.errorOnHighLevel?"red":"yellow"),t.highHighLevelReached&&(u="red"),u},n.setNodeStatusByActivity=function(e,t){n.showStatusActivities&&n.status({fill:n.getStatusSituationFillColor(n.unitid),shape:"ring",text:e?"active unit "+t+" queue items: "+e:"active (Unit-Id: "+t+") empty"})},n.readFromQueue=function(){if(!n.updateStatusRrunning){var i=n.unitid<1||255<n.unitid?1:n.unitid;if(a.bufferCommands)return new Promise(function(e,t){try{n.updateStatusRrunning=!0;var u=a.bufferCommandList.get(i).length;n.checkQueueStates(u,i),n.setNodeStatusByActivity(u,i),n.updateStatusRrunning=!1,e()}catch(e){n.updateStatusRrunning=!1,t(e)}});n.showStatusActivities&&n.setNodeStatusByActivity(null,i)}},n.checkQueueStates=function(e,t){!n.unitsWithQueue.get(t).lowLowLevelReached&&e<n.lowLowLevel&&n.resetStates(t),n.checkLowLevelReached(n,e,t),n.checkHighLevelReached(n,e,t),n.checkHighHighLevelReached(n,e,t)},n.readFromAllUnitQueues=function(){if(!n.updateStatusRrunning)return a.bufferCommands?new Promise(function(e,t){try{n.updateStatusRrunning=!0;for(var u=0,i=0;i<256;i+=1)(u=a.bufferCommandList.get(i).length)&&n.checkQueueStates(u,i);n.updateStatusRrunning=!1,e()}catch(e){n.updateStatusRrunning=!1,t(e)}}):void 0},n.registerModbusQueueActionsToNode=function(e){n.updateOnAllQueueChanges&&a.on("mbqueue",e),a.on("mbactive",e),a.on("mbinit",e),a.on("mbconnected",e),a.on("mberror",e),a.on("mbclosed",e),n.queueReadInterval=setInterval(e,n.queueReadIntervalTime)},n.removeModbusQueueActionsFromNode=function(e){a.removeListener("mbqueue",e),a.removeListener("mbactive",e),a.removeListener("mbinit",e),a.removeListener("mbconnected",e),a.removeListener("mberror",e),a.removeListener("mbclosed",e)},n.updateOnAllUnitQueues?(n.registerModbusQueueActionsToNode(n.readFromAllUnitQueues),t.setNodeStatusTo("active for all queues",n)):n.registerModbusQueueActionsToNode(n.readFromQueue),n.on("input",function(e){var t,u=n.unitid,u=e.payload.resetQueue?parseInt(e.payload.unitId):parseInt(e.payload)||n.unitid;e.payload={},e.payload.queueEnabled=a.bufferCommands,n.updateOnAllUnitQueues?(e.payload.allQueueData=!0,e.payload.queues=a.bufferCommandList):(e.payload.allQueueData=!1,e.payload.unitid=u,e.payload.queue=a.bufferCommandList.get(u)),e.payload.queueOptions={date:Date.now(),state:"queue request",modbusClientName:a.name||a.id,lowlowLevel:n.lowlowLevel,unitId:u,lowLevel:n.lowLevel,highLevel:n.highLevel,highHighLevel:n.highHighLevel},(e.payload.resetQueue||e.resetQueue)&&a.bufferCommands&&(o.initQueue(a),i.settings.verbose&&(t="Init Queue By External Node",a.warn(t),s(t)),n.initUnitQueueStates(),n.showStatusActivities&&n.status({fill:"blue",shape:"ring",text:"active empty unit queue"}),e.payload.queueOptions.state="queue reset done"),n.send(e)}),n.on("close",function(e){n.updateOnAllUnitQueues?n.removeModbusQueueActionsFromNode(n.readFromAllUnitQueues):n.removeModbusQueueActionsFromNode(n.readFromQueue),t.setNodeStatusTo("closed",n),n.queueReadInterval&&clearInterval(n.queueReadInterval),n.queueReadInterval=null,a.deregisterForModbus(n.id,e)}),n.showStatusActivities||t.setNodeDefaultStatus(n))})};
+"use strict";module.exports=function(i){require("source-map-support").install();var t=require("./modbus-basics"),o=require("./core/modbus-queue-core"),s=require("debug")("contribModbus:queue");i.nodes.registerType("modbus-queue-info",function(e){i.nodes.createNode(this,e),this.name=e.name,this.topic=e.topic,this.unitid=parseInt(e.unitid)||1,this.lowLowLevel=parseInt(e.lowLowLevel),this.lowLevel=parseInt(e.lowLevel),this.highLevel=parseInt(e.highLevel),this.highHighLevel=parseInt(e.highHighLevel),this.errorOnHighLevel=e.errorOnHighLevel,this.queueReadIntervalTime=e.queueReadIntervalTime||1e3,this.showStatusActivities=e.showStatusActivities,this.updateOnAllQueueChanges=e.updateOnAllQueueChanges,this.updateOnAllUnitQueues=e.updateOnAllUnitQueues,this.internalDebugLog=s;var n=this;n.queueReadInterval=null,n.updateStatusRrunning=!1,n.unitsWithQueue=new Map,t.setNodeStatusTo("waiting",n);var a=i.nodes.getNode(e.server);a&&(a.registerForModbus(n),n.initUnitQueueStates=function(){for(var e=0;e<256;e+=1)n.unitsWithQueue.set(e,{}),n.resetStates(e)},n.resetStates=function(e){var t=n.unitsWithQueue.get(e);t.lowLowLevelReached=!0,t.lowLevelReached=!1,t.highLevelReached=!1,t.highHighLevelReached=!1},n.initUnitQueueStates(),n.checkLowLevelReached=function(e,t,u){var i,n=e.unitsWithQueue.get(u);!n.lowLevelReached&&t>e.lowLowLevel&&t<e.lowLevel&&(n.lowLevelReached=!0,i={payload:Date.now(),topic:e.topic,state:"low level reached",unitid:u,modbusClientName:a.name,bufferCommandListLength:t},e.send(i))},n.checkHighLevelReached=function(e,t,u){var i,n=e.unitsWithQueue.get(u);!n.highLevelReached&&t>e.lowLevel&&t>e.highLevel&&(n.highLevelReached=!0,i={payload:Date.now(),topic:e.topic,state:"high level reached",unitid:u,modbusClientName:a.name||a.id,highLevel:e.highLevel,bufferCommandListLength:t},e.errorOnHighLevel?e.error(new Error("Queue High Level Reached"),i):e.warn(i),e.send(i))},n.checkHighHighLevelReached=function(e,t,u){var i,n=e.unitsWithQueue.get(u);!n.highHighLevelReached&&t>e.highLevel&&t>e.highHighLevel&&(n.highHighLevelReached=!0,i={payload:Date.now(),topic:e.topic,state:"high high level reached",unitid:u,modbusClientName:a.name||a.id,highLevel:e.highLevel,highHighLevel:e.highHighLevel,bufferCommandListLength:t},e.error(new Error("Queue High High Level Reached"),i),e.send(i))},n.getStatusSituationFillColor=function(e){var t=n.unitsWithQueue.get(e),u="blue";return t.lowLevelReached&&(u="green"),t.highLevelReached&&(u=n.errorOnHighLevel?"red":"yellow"),t.highHighLevelReached&&(u="red"),u},n.setNodeStatusByActivity=function(e,t){n.showStatusActivities&&n.status({fill:n.getStatusSituationFillColor(n.unitid),shape:"ring",text:e?"active unit "+t+" queue items: "+e:"active (Unit-Id: "+t+") empty"})},n.readFromQueue=function(){if(!n.updateStatusRrunning){var i=n.unitid<1||255<n.unitid?1:n.unitid;if(a.bufferCommands)return new Promise(function(e,t){try{n.updateStatusRrunning=!0;var u=a.bufferCommandList.get(i).length;n.checkQueueStates(u,i),n.setNodeStatusByActivity(u,i),n.updateStatusRrunning=!1,e()}catch(e){n.updateStatusRrunning=!1,t(e)}});n.showStatusActivities&&n.setNodeStatusByActivity(null,i)}},n.checkQueueStates=function(e,t){!n.unitsWithQueue.get(t).lowLowLevelReached&&e<n.lowLowLevel&&n.resetStates(t),n.checkLowLevelReached(n,e,t),n.checkHighLevelReached(n,e,t),n.checkHighHighLevelReached(n,e,t)},n.readFromAllUnitQueues=function(){if(!n.updateStatusRrunning)return a.bufferCommands?new Promise(function(e,t){try{n.updateStatusRrunning=!0;for(var u,i=0;i<256;i+=1)(u=a.bufferCommandList.get(i).length)&&n.checkQueueStates(u,i);n.updateStatusRrunning=!1,e()}catch(e){n.updateStatusRrunning=!1,t(e)}}):void 0},n.registerModbusQueueActionsToNode=function(e){n.updateOnAllQueueChanges&&a.on("mbqueue",e),a.on("mbactive",e),a.on("mbinit",e),a.on("mbconnected",e),a.on("mberror",e),a.on("mbclosed",e),n.queueReadInterval=setInterval(e,n.queueReadIntervalTime)},n.removeModbusQueueActionsFromNode=function(e){a.removeListener("mbqueue",e),a.removeListener("mbactive",e),a.removeListener("mbinit",e),a.removeListener("mbconnected",e),a.removeListener("mberror",e),a.removeListener("mbclosed",e)},n.updateOnAllUnitQueues?(n.registerModbusQueueActionsToNode(n.readFromAllUnitQueues),t.setNodeStatusTo("active for all queues",n)):n.registerModbusQueueActionsToNode(n.readFromQueue),n.on("input",function(e){var t,u=n.unitid,u=e.payload.resetQueue?parseInt(e.payload.unitId):parseInt(e.payload)||n.unitid;e.payload={},e.payload.queueEnabled=a.bufferCommands,n.updateOnAllUnitQueues?(e.payload.allQueueData=!0,e.payload.queues=a.bufferCommandList):(e.payload.allQueueData=!1,e.payload.unitid=u,e.payload.queue=a.bufferCommandList.get(u)),e.payload.queueOptions={date:Date.now(),state:"queue request",modbusClientName:a.name||a.id,lowlowLevel:n.lowlowLevel,unitId:u,lowLevel:n.lowLevel,highLevel:n.highLevel,highHighLevel:n.highHighLevel},(e.payload.resetQueue||e.resetQueue)&&a.bufferCommands&&(o.initQueue(a),i.settings.verbose&&(t="Init Queue By External Node",a.warn(t),s(t)),n.initUnitQueueStates(),n.showStatusActivities&&n.status({fill:"blue",shape:"ring",text:"active empty unit queue"}),e.payload.queueOptions.state="queue reset done"),n.send(e)}),n.on("close",function(e){n.updateOnAllUnitQueues?n.removeModbusQueueActionsFromNode(n.readFromAllUnitQueues):n.removeModbusQueueActionsFromNode(n.readFromQueue),t.setNodeStatusTo("closed",n),n.queueReadInterval&&clearInterval(n.queueReadInterval),n.queueReadInterval=null,a.deregisterForModbus(n.id,e)}),n.showStatusActivities||t.setNodeDefaultStatus(n))})};
 //# sourceMappingURL=maps/modbus-queue-info.js.map

package.json

 {
   "name": "node-red-contrib-modbus",
-  "version": "5.13.2",
+  "version": "5.13.3",
   "private": false,
@@ -5,0 +5,0 @@ "description": "The all in one Modbus TCP and Serial contribution package for Node-RED.",

No alert changes

Worsened metrics

Total package byte prevSize

8319921

decreased by-0.01%

No dependency changes