rhea-promise - npm Package Compare versions

Comparing version 3.0.0 to 3.0.1

CODE_OF_CONDUCT.md

@@ -0,0 +0,0 @@ # Contributor Covenant Code of Conduct

dist/lib/connection.js

@@ -30,2 +30,3 @@ "use strict";
     constructor(options) {
+        var _a;
         super();
@@ -40,3 +41,3 @@ if (isCreatedRheaConnectionOptions(options)) {
                 connectionOptions = { transport: "tls" };
-            if (connectionOptions.operationTimeoutInSeconds == undefined) {
+            if (!connectionOptions.operationTimeoutInSeconds) {
                 connectionOptions.operationTimeoutInSeconds = constants_1.defaultOperationTimeoutInSeconds;
@@ -53,3 +54,3 @@ }
         this.options = this._connection.options;
-        this.options.operationTimeoutInSeconds = options.operationTimeoutInSeconds;
+        this.options.operationTimeoutInSeconds = (_a = options === null || options === void 0 ? void 0 : options.operationTimeoutInSeconds) !== null && _a !== void 0 ? _a : constants_1.defaultOperationTimeoutInSeconds;
         this._initializeEventListeners();
@@ -56,0 +57,0 @@ }

dist/test/connection.spec.js

@@ -560,4 +560,44 @@ "use strict";
         }));
+        it("constructor sets operationTimeoutInSeconds option when passing a ConnectionOptions", () => {
+            const connectionOptions = {
+                operationTimeoutInSeconds: 30,
+                transport: "tls",
+            };
+            const connection = new index_1.Connection(connectionOptions);
+            chai_1.assert.equal(30, connection["options"].operationTimeoutInSeconds);
+        });
+        it("constructor sets operationTimeoutInSeconds option when passing a ConnectionOptions with undefined operationTimeoutInSeconds", () => {
+            const connectionOptions = {
+                transport: "tls",
+            };
+            const connection = new index_1.Connection(connectionOptions);
+            chai_1.assert.equal(60, connection["options"].operationTimeoutInSeconds);
+        });
+        it("constructor sets operationTimeoutInSeconds option when not passing any options", () => {
+            const connection = new index_1.Connection();
+            chai_1.assert.equal(60, connection["options"].operationTimeoutInSeconds);
+        });
+        it("constructor sets operationTimeoutInSeconds option when passing a CreatedRheaConnectionOptions", () => {
+            const container = new index_1.Container();
+            const rheaConnection = rhea.create_connection();
+            const createdRheaConnectionOptions = {
+                operationTimeoutInSeconds: 20,
+                rheaConnection,
+                container,
+            };
+            const connection = new index_1.Connection(createdRheaConnectionOptions);
+            chai_1.assert.equal(20, connection["options"].operationTimeoutInSeconds);
+        });
+        it("constructor sets operationTimeoutInSeconds option when passing a CreatedRheaConnectionOptions with undefined operationTimeoutInSeconds", () => {
+            const container = new index_1.Container();
+            const rheaConnection = rhea.create_connection();
+            const createdRheaConnectionOptions = {
+                rheaConnection,
+                container,
+            };
+            const connection2 = new index_1.Connection(createdRheaConnectionOptions);
+            chai_1.assert.equal(60, connection2["options"].operationTimeoutInSeconds);
+        });
     });
 });
 //# sourceMappingURL=connection.spec.js.map

lib/awaitableSender.ts

@@ -0,0 +0,0 @@ // Copyright (c) Microsoft Corporation. All rights reserved.

lib/connection.ts

@@ -240,3 +240,3 @@ // Copyright (c) Microsoft Corporation. All rights reserved.
       if (!connectionOptions) connectionOptions = { transport: "tls" };
-      if (connectionOptions.operationTimeoutInSeconds == undefined) {
+      if (!connectionOptions.operationTimeoutInSeconds) {
         connectionOptions.operationTimeoutInSeconds = defaultOperationTimeoutInSeconds;
@@ -257,3 +257,3 @@ }
     this.options = this._connection.options;
-    this.options.operationTimeoutInSeconds = options.operationTimeoutInSeconds;
+    this.options.operationTimeoutInSeconds = options?.operationTimeoutInSeconds ?? defaultOperationTimeoutInSeconds;
 
@@ -260,0 +260,0 @@ this._initializeEventListeners();

lib/container.ts

@@ -0,0 +0,0 @@ // Copyright (c) Microsoft Corporation. All rights reserved.

lib/entity.ts

@@ -0,0 +0,0 @@ // Copyright (c) Microsoft Corporation. All rights reserved.

lib/errorDefinitions.ts

@@ -0,0 +0,0 @@ // Copyright (c) Microsoft Corporation. All rights reserved.

lib/eventContext.ts

@@ -0,0 +0,0 @@ // Copyright (c) Microsoft Corporation. All rights reserved.

lib/index.ts

@@ -0,0 +0,0 @@ // Copyright (c) Microsoft Corporation. All rights reserved.

lib/link.ts

@@ -0,0 +0,0 @@ // Copyright (c) Microsoft Corporation. All rights reserved.

lib/log.ts

@@ -0,0 +0,0 @@ // Copyright (c) Microsoft Corporation. All rights reserved.

lib/receiver.ts

@@ -0,0 +0,0 @@ // Copyright (c) Microsoft Corporation. All rights reserved.

lib/sender.ts

@@ -0,0 +0,0 @@ // Copyright (c) Microsoft Corporation. All rights reserved.

lib/session.ts

@@ -0,0 +0,0 @@ // Copyright (c) Microsoft Corporation. All rights reserved.

lib/util/constants.ts

@@ -0,0 +0,0 @@ // Copyright (c) Microsoft Corporation. All rights reserved.

lib/util/utils.ts

@@ -0,0 +0,0 @@ // Copyright (c) Microsoft Corporation. All rights reserved.

package.json

 {
   "name": "rhea-promise",
-  "version": "3.0.0",
+  "version": "3.0.1",
   "description": "A Promisified layer over rhea AMQP client",
@@ -5,0 +5,0 @@ "license": "Apache-2.0",

README.md

@@ -0,0 +0,0 @@ # rhea-promise

test/connection.spec.ts

 import * as rhea from "rhea";
 import { assert } from "chai";
-import { Connection, ConnectionEvents } from "../lib/index";
+import { Connection, ConnectionEvents, ConnectionOptions, Container } from "../lib/index";
 import { AbortController } from "@azure/abort-controller";
 import { abortErrorName } from "../lib/util/utils";
+import { CreatedRheaConnectionOptions } from "../lib/connection";
 
@@ -694,3 +695,48 @@ describe("Connection", () => {
     });
+
+    it("constructor sets operationTimeoutInSeconds option when passing a ConnectionOptions", () => {
+      const connectionOptions: ConnectionOptions = {
+        operationTimeoutInSeconds: 30,
+        transport: "tls",
+      }
+      const connection = new Connection(connectionOptions);
+      assert.equal(30, connection["options"].operationTimeoutInSeconds);
+    });
+
+    it("constructor sets operationTimeoutInSeconds option when passing a ConnectionOptions with undefined operationTimeoutInSeconds", () => {
+      const connectionOptions: ConnectionOptions = {
+        transport: "tls",
+      }
+      const connection = new Connection(connectionOptions);
+      assert.equal(60, connection["options"].operationTimeoutInSeconds);
+    });
+
+    it("constructor sets operationTimeoutInSeconds option when not passing any options", () => {
+      const connection = new Connection();
+      assert.equal(60, connection["options"].operationTimeoutInSeconds);
+    });
+
+    it("constructor sets operationTimeoutInSeconds option when passing a CreatedRheaConnectionOptions", () => {
+      const container = new Container();
+      const rheaConnection = rhea.create_connection();
+      const createdRheaConnectionOptions: CreatedRheaConnectionOptions = {
+        operationTimeoutInSeconds: 20,
+        rheaConnection,
+        container,
+      };
+      const connection = new Connection(createdRheaConnectionOptions);
+      assert.equal(20, connection["options"].operationTimeoutInSeconds);
+    });
+
+    it("constructor sets operationTimeoutInSeconds option when passing a CreatedRheaConnectionOptions with undefined operationTimeoutInSeconds", () => {
+      const container = new Container();
+      const rheaConnection = rhea.create_connection();
+      const createdRheaConnectionOptions: CreatedRheaConnectionOptions = {
+        rheaConnection,
+        container,
+      };
+      const connection2 = new Connection(createdRheaConnectionOptions);
+      assert.equal(60, connection2["options"].operationTimeoutInSeconds);
+    });
   })
 });

test/receiver.spec.ts

@@ -0,0 +0,0 @@ import * as rhea from "rhea";

test/sender.spec.ts

@@ -0,0 +0,0 @@ import * as rhea from "rhea";

test/session.spec.ts

@@ -0,0 +0,0 @@ import * as rhea from "rhea";

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

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

Found 1 instance in 1 package

Improved metrics

Lines of code

8877

increased by0.93%

Number of medium supply chain risk alerts

0

decreased by-100%

Worsened metrics

Total package byte prevSize

538632

decreased by-1.28%

Number of package files

97

decreased by-1.02%

No dependency changes