node-opcua-transport - npm Package Compare versions

Comparing version 2.126.0 to 2.128.0

dist/source/client_tcp_transport.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="node" />
 import { ErrorCallback } from "node-opcua-status-code";
@@ -3,0 +2,0 @@ import { TCP_transport } from "./tcp_transport";

dist/source/client_tcp_transport.js

@@ -168,3 +168,3 @@ "use strict";
                     if (!this._socket) {
-                        throw new Error("internal error");
+                        return callback(new Error("Abandoned"));
                     }
@@ -171,0 +171,0 @@ // install error handler to detect connection break

dist/source/message_builder_base.d.ts

@@ -1,3 +0,1 @@
-/// <reference types="node" />
-/// <reference types="node" />
 /**
@@ -4,0 +2,0 @@ * @module node-opcua-transport

dist/source/message_builder_base.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.MessageBuilderBase = exports.readRawMessageHeader = void 0;
+exports.MessageBuilderBase = void 0;
+exports.readRawMessageHeader = readRawMessageHeader;
 /**
@@ -29,3 +30,2 @@ * @module node-opcua-transport
 }
-exports.readRawMessageHeader = readRawMessageHeader;
 /**
@@ -32,0 +32,0 @@ * @class MessageBuilderBase

dist/source/server_tcp_transport.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="node" />
 import { ErrorCallback } from "node-opcua-status-code";
@@ -3,0 +2,0 @@ import { ISocketLike, TCP_transport } from "./tcp_transport";

dist/source/server_tcp_transport.js

@@ -6,3 +6,4 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.ServerTCP_transport = exports.adjustLimitsWithParameters = void 0;
+exports.ServerTCP_transport = void 0;
+exports.adjustLimitsWithParameters = adjustLimitsWithParameters;
 /**
@@ -73,3 +74,2 @@ * @module node-opcua-transport
 }
-exports.adjustLimitsWithParameters = adjustLimitsWithParameters;
 const defaultAdjustLimits = (hello) => adjustLimitsWithParameters(hello, defaultTransportParameters);
@@ -76,0 +76,0 @@ /**

dist/source/tcp_transport.d.ts

@@ -1,3 +0,1 @@
-/// <reference types="node" />
-/// <reference types="node" />
 /**
@@ -4,0 +2,0 @@ * @module node-opcua-transport

dist/source/tcp_transport.js

@@ -6,3 +6,5 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.TCP_transport = exports.getFakeTransport = exports.setFakeTransport = void 0;
+exports.TCP_transport = void 0;
+exports.setFakeTransport = setFakeTransport;
+exports.getFakeTransport = getFakeTransport;
 /* eslint-disable @typescript-eslint/ban-types */
@@ -58,3 +60,2 @@ /**
 }
-exports.setFakeTransport = setFakeTransport;
 function getFakeTransport() {
@@ -67,3 +68,2 @@ if (fakeSocket.invalid) {
 }
-exports.getFakeTransport = getFakeTransport;
 let counter = 0;
@@ -70,0 +70,0 @@ // tslint:disable:class-name

dist/source/tools.d.ts

@@ -1,3 +0,1 @@
-/// <reference types="node" />
-/// <reference types="node" />
 /**
@@ -4,0 +2,0 @@ * @module node-opcua-transport

dist/source/tools.js

@@ -6,3 +6,7 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.writeTCPMessageHeader = exports.is_valid_endpointUrl = exports.parseEndpointUrl = exports.packTcpMessage = exports.decodeMessage = void 0;
+exports.decodeMessage = decodeMessage;
+exports.packTcpMessage = packTcpMessage;
+exports.parseEndpointUrl = parseEndpointUrl;
+exports.is_valid_endpointUrl = is_valid_endpointUrl;
+exports.writeTCPMessageHeader = writeTCPMessageHeader;
 /**
@@ -45,3 +49,2 @@ * @module node-opcua-transport
 }
-exports.decodeMessage = decodeMessage;
 function packTcpMessage(msgType, encodableObject) {
@@ -55,3 +58,2 @@ (0, node_opcua_assert_1.assert)(is_valid_msg_type(msgType));
 }
-exports.packTcpMessage = packTcpMessage;
 // opc.tcp://hostname:51210/UA/SampleServer
@@ -83,3 +85,2 @@ function parseEndpointUrl(endpointUrl) {
 }
-exports.parseEndpointUrl = parseEndpointUrl;
 function is_valid_endpointUrl(endpointUrl) {
@@ -89,3 +90,2 @@ const e = parseEndpointUrl(endpointUrl);
 }
-exports.is_valid_endpointUrl = is_valid_endpointUrl;
 function writeTCPMessageHeader(msgType, chunkType, totalLength, stream) {
@@ -104,3 +104,2 @@ if (stream instanceof Buffer) {
 }
-exports.writeTCPMessageHeader = writeTCPMessageHeader;
 function encodeMessage(msgType, messageContent, stream) {
@@ -107,0 +106,0 @@ // the length of the message, in bytes. (includes the 8 bytes of the message header)

dist/test_helpers/fake_server.d.ts

@@ -1,4 +0,1 @@
-/// <reference types="node" />
-/// <reference types="node" />
-/// <reference types="node" />
 import { EventEmitter } from "events";
@@ -5,0 +2,0 @@ import net from "net";

dist/test_helpers/half_com_channel.d.ts

@@ -1,3 +0,1 @@
-/// <reference types="node" />
-/// <reference types="node" />
 import { EventEmitter } from "events";
@@ -4,0 +2,0 @@ import { ISocketLike } from "../source";

dist/test_helpers/transport_pair_direct.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="node" />
 import { HalfComChannel } from "./half_com_channel";
@@ -3,0 +2,0 @@ import { ITransportPair } from "./ITransportPair";

dist/test_helpers/transport_pair_socket.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="node" />
 import net from "net";
@@ -3,0 +2,0 @@ import { ISocketLike } from "../source";

dist/test-fixtures/fixture_full_tcp_packets.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="node" />
 export declare const helloMessage1: Buffer;
@@ -3,0 +2,0 @@ export declare const altered_helloMessage1: Buffer;

package.json

 {
     "name": "node-opcua-transport",
-    "version": "2.126.0",
+    "version": "2.128.0",
     "description": "pure nodejs OPCUA SDK - module transport",
@@ -17,17 +17,15 @@ "main": "./dist/source/index.js",
         "node-opcua-assert": "2.120.0",
-        "node-opcua-basic-types": "2.126.0",
-        "node-opcua-binary-stream": "2.125.0",
-        "node-opcua-buffer-utils": "2.125.0",
-        "node-opcua-chunkmanager": "2.126.0",
-        "node-opcua-debug": "2.125.0",
-        "node-opcua-factory": "2.126.0",
-        "node-opcua-object-registry": "2.125.0",
-        "node-opcua-packet-assembler": "2.125.0",
-        "node-opcua-status-code": "2.125.0",
-        "node-opcua-utils": "2.125.0"
+        "node-opcua-basic-types": "2.128.0",
+        "node-opcua-binary-stream": "2.128.0",
+        "node-opcua-buffer-utils": "2.128.0",
+        "node-opcua-chunkmanager": "2.128.0",
+        "node-opcua-debug": "2.128.0",
+        "node-opcua-factory": "2.128.0",
+        "node-opcua-object-registry": "2.128.0",
+        "node-opcua-packet-assembler": "2.128.0",
+        "node-opcua-status-code": "2.128.0",
+        "node-opcua-utils": "2.128.0"
     },
     "devDependencies": {
-        "node-opcua-leak-detector": "2.125.0",
-        "should": "^13.2.3",
-        "sinon": "^18.0.0"
+        "node-opcua-leak-detector": "2.128.0"
     },
@@ -49,3 +47,3 @@ "author": "Etienne Rossignon",
     "homepage": "http://node-opcua.github.io/",
-    "gitHead": "81b467f284c41813ab8caf17f6d20322d4734fdc",
+    "gitHead": "67a73af6b831d8651a0e66ceb295f159cab4386b",
     "files": [
@@ -52,0 +50,0 @@ "dist",

source/client_tcp_transport.ts

@@ -226,7 +226,6 @@ /**
                     if (!this._socket) {
-                        throw new Error("internal error");
+                        return callback(new Error("Abandoned"));                        
                     }
                     // install error handler to detect connection break
                     this._socket.on("error", _on_socket_error_after_connection);
-
                     /**
@@ -233,0 +232,0 @@ * notify the observers that the transport is connected (the socket is connected and the the HEL/ACK

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Dev dependency count

1

decreased by-66.67%

Worsened metrics

Total package byte prevSize

357729

decreased by-0.99%

Lines of code

5065

decreased by-0.33%

Dependency changes

• + Addednode-opcua-basic-types@2.128.0(transitive)

• + Addednode-opcua-binary-stream@2.128.0(transitive)

• + Addednode-opcua-buffer-utils@2.128.0(transitive)

• + Addednode-opcua-chunkmanager@2.128.0(transitive)

• + Addednode-opcua-date-time@2.128.0(transitive)

• + Addednode-opcua-debug@2.128.0(transitive)

• + Addednode-opcua-enum@2.128.0(transitive)

• + Addednode-opcua-factory@2.128.0(transitive)

• + Addednode-opcua-guid@2.128.0(transitive)

• + Addednode-opcua-nodeid@2.128.0(transitive)

• + Addednode-opcua-object-registry@2.128.0(transitive)

• + Addednode-opcua-packet-assembler@2.128.0(transitive)

• + Addednode-opcua-status-code@2.128.0(transitive)

• + Addednode-opcua-utils@2.128.0(transitive)

• - Removednode-opcua-basic-types@2.126.0(transitive)

• - Removednode-opcua-binary-stream@2.125.0(transitive)

• - Removednode-opcua-buffer-utils@2.125.0(transitive)

• - Removednode-opcua-chunkmanager@2.126.0(transitive)

• - Removednode-opcua-date-time@2.125.0(transitive)

• - Removednode-opcua-debug@2.125.0(transitive)

• - Removednode-opcua-enum@2.125.0(transitive)

• - Removednode-opcua-factory@2.126.0(transitive)

• - Removednode-opcua-guid@2.120.0(transitive)

• - Removednode-opcua-nodeid@2.125.0(transitive)

• - Removednode-opcua-object-registry@2.125.0(transitive)

• - Removednode-opcua-packet-assembler@2.125.0(transitive)

• - Removednode-opcua-status-code@2.125.0(transitive)

• - Removednode-opcua-utils@2.125.0(transitive)

• Updatednode-opcua-basic-types@2.128.0

• Updatednode-opcua-binary-stream@2.128.0

• Updatednode-opcua-buffer-utils@2.128.0

• Updatednode-opcua-chunkmanager@2.128.0

• Updatednode-opcua-debug@2.128.0

• Updatednode-opcua-factory@2.128.0

• Updatednode-opcua-object-registry@2.128.0

• Updatednode-opcua-packet-assembler@2.128.0

• Updatednode-opcua-status-code@2.128.0

• Updatednode-opcua-utils@2.128.0