etp - npm Package Compare versions

Comparing version 2.0.1-81 to 2.0.1-82

lib/EtpMessages.js

@@ -59,15 +59,2 @@ (function (Energistics) {
     (function (Datatypes) {
-        (function (ErrorCodes) {
-            ErrorCodes[ErrorCodes["ENOROLE"] = 0] = "ENOROLE";
-            ErrorCodes[ErrorCodes["ENOSUPPORTEDPROTOCOLS"] = 1] = "ENOSUPPORTEDPROTOCOLS";
-            ErrorCodes[ErrorCodes["EINVALID_MESSAGETYPE"] = 2] = "EINVALID_MESSAGETYPE";
-            ErrorCodes[ErrorCodes["EUNSUPPORTED_PROTOCOL"] = 3] = "EUNSUPPORTED_PROTOCOL";
-        })(Datatypes.ErrorCodes || (Datatypes.ErrorCodes = {}));
-        var ErrorCodes = Datatypes.ErrorCodes;
-    })(Energistics.Datatypes || (Energistics.Datatypes = {}));
-    var Datatypes = Energistics.Datatypes;
-})(exports.Energistics || (exports.Energistics = {}));
-var Energistics = exports.Energistics;
-(function (Energistics) {
-    (function (Datatypes) {
         var MessageHeader = (function () {
@@ -91,2 +78,15 @@ function MessageHeader() {
     (function (Datatypes) {
+        (function (ErrorCodes) {
+            ErrorCodes[ErrorCodes["ENOROLE"] = 0] = "ENOROLE";
+            ErrorCodes[ErrorCodes["ENOSUPPORTEDPROTOCOLS"] = 1] = "ENOSUPPORTEDPROTOCOLS";
+            ErrorCodes[ErrorCodes["EINVALID_MESSAGETYPE"] = 2] = "EINVALID_MESSAGETYPE";
+            ErrorCodes[ErrorCodes["EUNSUPPORTED_PROTOCOL"] = 3] = "EUNSUPPORTED_PROTOCOL";
+        })(Datatypes.ErrorCodes || (Datatypes.ErrorCodes = {}));
+        var ErrorCodes = Datatypes.ErrorCodes;
+    })(Energistics.Datatypes || (Energistics.Datatypes = {}));
+    var Datatypes = Energistics.Datatypes;
+})(exports.Energistics || (exports.Energistics = {}));
+var Energistics = exports.Energistics;
+(function (Energistics) {
+    (function (Datatypes) {
         (function (Protocols) {
@@ -171,7 +171,7 @@ Protocols[Protocols["Core"] = 0] = "Core";
         (function (ChannelData) {
-            (function (ErrorCodes) {
-                ErrorCodes[ErrorCodes["EINVALID_URI"] = 0] = "EINVALID_URI";
-                ErrorCodes[ErrorCodes["EINVALID_CHANNELID"] = 1] = "EINVALID_CHANNELID";
-            })(ChannelData.ErrorCodes || (ChannelData.ErrorCodes = {}));
-            var ErrorCodes = ChannelData.ErrorCodes;
+            (function (IndexDirections) {
+                IndexDirections[IndexDirections["Increasing"] = 0] = "Increasing";
+                IndexDirections[IndexDirections["Decreasing"] = 1] = "Decreasing";
+            })(ChannelData.IndexDirections || (ChannelData.IndexDirections = {}));
+            var IndexDirections = ChannelData.IndexDirections;
         })(Datatypes.ChannelData || (Datatypes.ChannelData = {}));
@@ -186,7 +186,7 @@ var ChannelData = Datatypes.ChannelData;
         (function (ChannelData) {
-            (function (IndexDirections) {
-                IndexDirections[IndexDirections["Increasing"] = 0] = "Increasing";
-                IndexDirections[IndexDirections["Decreasing"] = 1] = "Decreasing";
-            })(ChannelData.IndexDirections || (ChannelData.IndexDirections = {}));
-            var IndexDirections = ChannelData.IndexDirections;
+            (function (ErrorCodes) {
+                ErrorCodes[ErrorCodes["EINVALID_URI"] = 0] = "EINVALID_URI";
+                ErrorCodes[ErrorCodes["EINVALID_CHANNELID"] = 1] = "EINVALID_CHANNELID";
+            })(ChannelData.ErrorCodes || (ChannelData.ErrorCodes = {}));
+            var ErrorCodes = ChannelData.ErrorCodes;
         })(Datatypes.ChannelData || (Datatypes.ChannelData = {}));
@@ -218,2 +218,16 @@ var ChannelData = Datatypes.ChannelData;
         (function (ChannelData) {
+            (function (Roles) {
+                Roles[Roles["Producer"] = 0] = "Producer";
+                Roles[Roles["Consumer"] = 1] = "Consumer";
+            })(ChannelData.Roles || (ChannelData.Roles = {}));
+            var Roles = ChannelData.Roles;
+        })(Datatypes.ChannelData || (Datatypes.ChannelData = {}));
+        var ChannelData = Datatypes.ChannelData;
+    })(Energistics.Datatypes || (Energistics.Datatypes = {}));
+    var Datatypes = Energistics.Datatypes;
+})(exports.Energistics || (exports.Energistics = {}));
+var Energistics = exports.Energistics;
+(function (Energistics) {
+    (function (Datatypes) {
+        (function (ChannelData) {
             var IndexValue = (function () {
@@ -234,2 +248,20 @@ function IndexValue() {
     (function (Datatypes) {
+        (function (ChannelDataFrame) {
+            var DataRow = (function () {
+                function DataRow() {
+                    this.index = [];
+                    this.data = [];
+                    this._schema = JSON.parse('{"type":"record","namespace":"Energistics.Datatypes.ChannelDataFrame","name":"DataRow","fields":[{"name":"index","type":{"type":"array","items":"Energistics.Datatypes.ChannelData.IndexValue"}},{"name":"data","type":{"type":"array","items":"Energistics.Datatypes.DataValue"}}],"fullName":"Energistics.Datatypes.ChannelDataFrame.DataRow","depends":["Energistics.Datatypes.ChannelData.IndexValue","Energistics.Datatypes.DataValue"]}');
+                }
+                return DataRow;
+            })();
+            ChannelDataFrame.DataRow = DataRow;
+        })(Datatypes.ChannelDataFrame || (Datatypes.ChannelDataFrame = {}));
+        var ChannelDataFrame = Datatypes.ChannelDataFrame;
+    })(Energistics.Datatypes || (Energistics.Datatypes = {}));
+    var Datatypes = Energistics.Datatypes;
+})(exports.Energistics || (exports.Energistics = {}));
+var Energistics = exports.Energistics;
+(function (Energistics) {
+    (function (Datatypes) {
         (function (ChannelData) {
@@ -295,16 +327,2 @@ var ChannelMetadataRecord = (function () {
         (function (ChannelData) {
-            (function (Roles) {
-                Roles[Roles["Producer"] = 0] = "Producer";
-                Roles[Roles["Consumer"] = 1] = "Consumer";
-            })(ChannelData.Roles || (ChannelData.Roles = {}));
-            var Roles = ChannelData.Roles;
-        })(Datatypes.ChannelData || (Datatypes.ChannelData = {}));
-        var ChannelData = Datatypes.ChannelData;
-    })(Energistics.Datatypes || (Energistics.Datatypes = {}));
-    var Datatypes = Energistics.Datatypes;
-})(exports.Energistics || (exports.Energistics = {}));
-var Energistics = exports.Energistics;
-(function (Energistics) {
-    (function (Datatypes) {
-        (function (ChannelData) {
             var StreamingStartIndex = (function () {
@@ -343,20 +361,2 @@ function StreamingStartIndex() {
     (function (Datatypes) {
-        (function (ChannelDataFrame) {
-            var DataRow = (function () {
-                function DataRow() {
-                    this.index = [];
-                    this.data = [];
-                    this._schema = JSON.parse('{"type":"record","namespace":"Energistics.Datatypes.ChannelDataFrame","name":"DataRow","fields":[{"name":"index","type":{"type":"array","items":"Energistics.Datatypes.ChannelData.IndexValue"}},{"name":"data","type":{"type":"array","items":"Energistics.Datatypes.DataValue"}}],"fullName":"Energistics.Datatypes.ChannelDataFrame.DataRow","depends":["Energistics.Datatypes.ChannelData.IndexValue","Energistics.Datatypes.DataValue"]}');
-                }
-                return DataRow;
-            })();
-            ChannelDataFrame.DataRow = DataRow;
-        })(Datatypes.ChannelDataFrame || (Datatypes.ChannelDataFrame = {}));
-        var ChannelDataFrame = Datatypes.ChannelDataFrame;
-    })(Energistics.Datatypes || (Energistics.Datatypes = {}));
-    var Datatypes = Energistics.Datatypes;
-})(exports.Energistics || (exports.Energistics = {}));
-var Energistics = exports.Energistics;
-(function (Energistics) {
-    (function (Datatypes) {
         (function (Object) {
@@ -482,99 +482,2 @@ var DataObject = (function () {
     (function (Protocol) {
-        (function (Core) {
-            var Acknowledge = (function () {
-                function Acknowledge() {
-                    this._schema = JSON.parse('{"type":"record","namespace":"Energistics.Protocol.Core","name":"Acknowledge","messageType":"1001","protocol":"0","fields":[],"fullName":"Energistics.Protocol.Core.Acknowledge","depends":[]}');
-                }
-                Acknowledge._protocol = 0;
-                Acknowledge._messageTypeId = 1001;
-                return Acknowledge;
-            })();
-            Core.Acknowledge = Acknowledge;
-        })(Protocol.Core || (Protocol.Core = {}));
-        var Core = Protocol.Core;
-    })(Energistics.Protocol || (Energistics.Protocol = {}));
-    var Protocol = Energistics.Protocol;
-})(exports.Energistics || (exports.Energistics = {}));
-var Energistics = exports.Energistics;
-(function (Energistics) {
-    (function (Protocol) {
-        (function (Core) {
-            var CloseSession = (function () {
-                function CloseSession() {
-                    this._schema = JSON.parse('{"type":"record","namespace":"Energistics.Protocol.Core","name":"CloseSession","messageType":"5","protocol":"0","fields":[{"name":"reason","type":["null","string"]}],"fullName":"Energistics.Protocol.Core.CloseSession","depends":[]}');
-                }
-                CloseSession._protocol = 0;
-                CloseSession._messageTypeId = 5;
-                return CloseSession;
-            })();
-            Core.CloseSession = CloseSession;
-        })(Protocol.Core || (Protocol.Core = {}));
-        var Core = Protocol.Core;
-    })(Energistics.Protocol || (Energistics.Protocol = {}));
-    var Protocol = Energistics.Protocol;
-})(exports.Energistics || (exports.Energistics = {}));
-var Energistics = exports.Energistics;
-(function (Energistics) {
-    (function (Protocol) {
-        (function (Core) {
-            var OpenSession = (function () {
-                function OpenSession() {
-                    this.applicationName = null;
-                    this.sessionId = null;
-                    this.supportedProtocols = [];
-                    this._schema = JSON.parse('{"type":"record","namespace":"Energistics.Protocol.Core","name":"OpenSession","messageType":"2","protocol":"0","fields":[{"name":"applicationName","type":"string"},{"name":"sessionId","type":"string"},{"name":"supportedProtocols","type":{"type":"array","items":"Energistics.Datatypes.SupportedProtocol"}}],"fullName":"Energistics.Protocol.Core.OpenSession","depends":["Energistics.Datatypes.SupportedProtocol"]}');
-                }
-                OpenSession._protocol = 0;
-                OpenSession._messageTypeId = 2;
-                return OpenSession;
-            })();
-            Core.OpenSession = OpenSession;
-        })(Protocol.Core || (Protocol.Core = {}));
-        var Core = Protocol.Core;
-    })(Energistics.Protocol || (Energistics.Protocol = {}));
-    var Protocol = Energistics.Protocol;
-})(exports.Energistics || (exports.Energistics = {}));
-var Energistics = exports.Energistics;
-(function (Energistics) {
-    (function (Protocol) {
-        (function (Core) {
-            var ProtocolException = (function () {
-                function ProtocolException() {
-                    this.errorCode = null;
-                    this.errorMessage = null;
-                    this._schema = JSON.parse('{"type":"record","namespace":"Energistics.Protocol.Core","name":"ProtocolException","messageType":"1000","protocol":"0","fields":[{"name":"errorCode","type":"int"},{"name":"errorMessage","type":"string"}],"fullName":"Energistics.Protocol.Core.ProtocolException","depends":[]}');
-                }
-                ProtocolException._protocol = 0;
-                ProtocolException._messageTypeId = 1000;
-                return ProtocolException;
-            })();
-            Core.ProtocolException = ProtocolException;
-        })(Protocol.Core || (Protocol.Core = {}));
-        var Core = Protocol.Core;
-    })(Energistics.Protocol || (Energistics.Protocol = {}));
-    var Protocol = Energistics.Protocol;
-})(exports.Energistics || (exports.Energistics = {}));
-var Energistics = exports.Energistics;
-(function (Energistics) {
-    (function (Protocol) {
-        (function (Core) {
-            var RequestSession = (function () {
-                function RequestSession() {
-                    this.requestedProtocols = [];
-                    this.applicationName = null;
-                    this._schema = JSON.parse('{"type":"record","namespace":"Energistics.Protocol.Core","name":"RequestSession","messageType":"1","protocol":"0","fields":[{"name":"requestedProtocols","type":{"type":"array","items":"Energistics.Datatypes.SupportedProtocol"}},{"name":"applicationName","type":"string"}],"fullName":"Energistics.Protocol.Core.RequestSession","depends":["Energistics.Datatypes.SupportedProtocol"]}');
-                }
-                RequestSession._protocol = 0;
-                RequestSession._messageTypeId = 1;
-                return RequestSession;
-            })();
-            Core.RequestSession = RequestSession;
-        })(Protocol.Core || (Protocol.Core = {}));
-        var Core = Protocol.Core;
-    })(Energistics.Protocol || (Energistics.Protocol = {}));
-    var Protocol = Energistics.Protocol;
-})(exports.Energistics || (exports.Energistics = {}));
-var Energistics = exports.Energistics;
-(function (Energistics) {
-    (function (Protocol) {
         (function (ChannelStreaming) {
@@ -772,2 +675,99 @@ var ChannelData = (function () {
     (function (Protocol) {
+        (function (Core) {
+            var Acknowledge = (function () {
+                function Acknowledge() {
+                    this._schema = JSON.parse('{"type":"record","namespace":"Energistics.Protocol.Core","name":"Acknowledge","messageType":"1001","protocol":"0","fields":[],"fullName":"Energistics.Protocol.Core.Acknowledge","depends":[]}');
+                }
+                Acknowledge._protocol = 0;
+                Acknowledge._messageTypeId = 1001;
+                return Acknowledge;
+            })();
+            Core.Acknowledge = Acknowledge;
+        })(Protocol.Core || (Protocol.Core = {}));
+        var Core = Protocol.Core;
+    })(Energistics.Protocol || (Energistics.Protocol = {}));
+    var Protocol = Energistics.Protocol;
+})(exports.Energistics || (exports.Energistics = {}));
+var Energistics = exports.Energistics;
+(function (Energistics) {
+    (function (Protocol) {
+        (function (Core) {
+            var CloseSession = (function () {
+                function CloseSession() {
+                    this._schema = JSON.parse('{"type":"record","namespace":"Energistics.Protocol.Core","name":"CloseSession","messageType":"5","protocol":"0","fields":[{"name":"reason","type":["null","string"]}],"fullName":"Energistics.Protocol.Core.CloseSession","depends":[]}');
+                }
+                CloseSession._protocol = 0;
+                CloseSession._messageTypeId = 5;
+                return CloseSession;
+            })();
+            Core.CloseSession = CloseSession;
+        })(Protocol.Core || (Protocol.Core = {}));
+        var Core = Protocol.Core;
+    })(Energistics.Protocol || (Energistics.Protocol = {}));
+    var Protocol = Energistics.Protocol;
+})(exports.Energistics || (exports.Energistics = {}));
+var Energistics = exports.Energistics;
+(function (Energistics) {
+    (function (Protocol) {
+        (function (Core) {
+            var OpenSession = (function () {
+                function OpenSession() {
+                    this.applicationName = null;
+                    this.sessionId = null;
+                    this.supportedProtocols = [];
+                    this._schema = JSON.parse('{"type":"record","namespace":"Energistics.Protocol.Core","name":"OpenSession","messageType":"2","protocol":"0","fields":[{"name":"applicationName","type":"string"},{"name":"sessionId","type":"string"},{"name":"supportedProtocols","type":{"type":"array","items":"Energistics.Datatypes.SupportedProtocol"}}],"fullName":"Energistics.Protocol.Core.OpenSession","depends":["Energistics.Datatypes.SupportedProtocol"]}');
+                }
+                OpenSession._protocol = 0;
+                OpenSession._messageTypeId = 2;
+                return OpenSession;
+            })();
+            Core.OpenSession = OpenSession;
+        })(Protocol.Core || (Protocol.Core = {}));
+        var Core = Protocol.Core;
+    })(Energistics.Protocol || (Energistics.Protocol = {}));
+    var Protocol = Energistics.Protocol;
+})(exports.Energistics || (exports.Energistics = {}));
+var Energistics = exports.Energistics;
+(function (Energistics) {
+    (function (Protocol) {
+        (function (Core) {
+            var ProtocolException = (function () {
+                function ProtocolException() {
+                    this.errorCode = null;
+                    this.errorMessage = null;
+                    this._schema = JSON.parse('{"type":"record","namespace":"Energistics.Protocol.Core","name":"ProtocolException","messageType":"1000","protocol":"0","fields":[{"name":"errorCode","type":"int"},{"name":"errorMessage","type":"string"}],"fullName":"Energistics.Protocol.Core.ProtocolException","depends":[]}');
+                }
+                ProtocolException._protocol = 0;
+                ProtocolException._messageTypeId = 1000;
+                return ProtocolException;
+            })();
+            Core.ProtocolException = ProtocolException;
+        })(Protocol.Core || (Protocol.Core = {}));
+        var Core = Protocol.Core;
+    })(Energistics.Protocol || (Energistics.Protocol = {}));
+    var Protocol = Energistics.Protocol;
+})(exports.Energistics || (exports.Energistics = {}));
+var Energistics = exports.Energistics;
+(function (Energistics) {
+    (function (Protocol) {
+        (function (Core) {
+            var RequestSession = (function () {
+                function RequestSession() {
+                    this.requestedProtocols = [];
+                    this.applicationName = null;
+                    this._schema = JSON.parse('{"type":"record","namespace":"Energistics.Protocol.Core","name":"RequestSession","messageType":"1","protocol":"0","fields":[{"name":"requestedProtocols","type":{"type":"array","items":"Energistics.Datatypes.SupportedProtocol"}},{"name":"applicationName","type":"string"}],"fullName":"Energistics.Protocol.Core.RequestSession","depends":["Energistics.Datatypes.SupportedProtocol"]}');
+                }
+                RequestSession._protocol = 0;
+                RequestSession._messageTypeId = 1;
+                return RequestSession;
+            })();
+            Core.RequestSession = RequestSession;
+        })(Protocol.Core || (Protocol.Core = {}));
+        var Core = Protocol.Core;
+    })(Energistics.Protocol || (Energistics.Protocol = {}));
+    var Protocol = Energistics.Protocol;
+})(exports.Energistics || (exports.Energistics = {}));
+var Energistics = exports.Energistics;
+(function (Energistics) {
+    (function (Protocol) {
         (function (Store) {
@@ -774,0 +774,0 @@ var AddToStore = (function () {

mocha.json

@@ -8,5 +8,5 @@ {
     "failures": 0,
-    "start": "2014-10-18T02:50:18.366Z",
-    "end": "2014-10-18T02:50:18.368Z",
-    "duration": 2
+    "start": "2014-10-18T02:53:10.406Z",
+    "end": "2014-10-18T02:53:10.409Z",
+    "duration": 3
   },
@@ -18,3 +18,3 @@ "failures": [],
       "fullTitle": "EtpSchemaCache #find() should find schemas by protocol and message type id",
-      "duration": 0
+      "duration": 1
     },
@@ -24,3 +24,3 @@ {
       "fullTitle": "Energistics.Datatypes.Version #write() should write a version",
-      "duration": 0
+      "duration": 1
     }
@@ -27,0 +27,0 @@ ],

package.json

 {
   "name": "etp",
-  "version": "2.0.1-81",
+  "version": "2.0.1-82",
   "repository": {
@@ -5,0 +5,0 @@ "type": "git",

No alert changes

Worsened metrics

Total package byte prevSize

25797567

Lines of code

27297

decreased by-22.64%

No dependency changes