rhea-promise - npm Package Compare versions

Comparing version 0.1.12 to 0.1.13

changelog.md

@@ -0,1 +1,4 @@
+### 0.1.13 - 2018-12-11
+- Throw `OperationTimeoutError` when a Promise to create/close an entity is rejected.
+
 ### 0.1.12 - 2018-11-16
@@ -2,0 +5,0 @@ - Fix a minor bug in receiver creation.

dist/lib/connection.js

@@ -13,2 +13,3 @@ "use strict";
 const entity_1 = require("./entity");
+const operationTimeoutError_1 = require("./operationTimeoutError");
 // Determines whether the given object is a CreatedRheConnectionOptions object.
@@ -277,3 +278,3 @@ function isCreatedRheaConnectionOptions(obj) {
                 log.error("[%s] %s", this.id, msg);
-                return reject(new Error(msg));
+                return reject(new operationTimeoutError_1.OperationTimeoutError(msg));
             };
@@ -280,0 +281,0 @@ // listeners that we add for completing the operation are added directly to rhea's objects.

dist/lib/link.js

@@ -10,2 +10,3 @@ "use strict";
 const entity_1 = require("./entity");
+const operationTimeoutError_1 = require("./operationTimeoutError");
 var LinkType;
@@ -215,3 +216,3 @@ (function (LinkType) {
                         log.error("[%s] %s", this.connection.id, this.type, msg);
-                        return reject(new Error(msg));
+                        return reject(new operationTimeoutError_1.OperationTimeoutError(msg));
                     };
@@ -218,0 +219,0 @@ // listeners that we add for completing the operation are added directly to rhea's objects.

dist/lib/session.js

@@ -11,2 +11,3 @@ "use strict";
 const entity_1 = require("./entity");
+const operationTimeoutError_1 = require("./operationTimeoutError");
 /**
@@ -112,3 +113,3 @@ * Describes the session that wraps the rhea session.
                     log.error("[%s] %s", this.connection.id, msg);
-                    reject(new Error(msg));
+                    reject(new operationTimeoutError_1.OperationTimeoutError(msg));
                 };
@@ -213,3 +214,3 @@ // listeners that we add for completing the operation are added directly to rhea's objects.
                 log.error("[%s] %s", this.connection.id, msg);
-                return reject(new Error(msg));
+                return reject(new operationTimeoutError_1.OperationTimeoutError(msg));
             };
@@ -292,3 +293,3 @@ // listeners that we add for completing the operation are added directly to rhea's objects.
                 log.error("[%s] %s", this.connection.id, msg);
-                return reject(new Error(msg));
+                return reject(new operationTimeoutError_1.OperationTimeoutError(msg));
             };
@@ -295,0 +296,0 @@ // listeners that we add for completing the operation are added directly to rhea's objects.

lib/connection.ts

@@ -21,2 +21,3 @@ // Copyright (c) Microsoft Corporation. All rights reserved.
 import { Entity } from "./entity";
+import { OperationTimeoutError } from "./operationTimeoutError";
 
@@ -420,3 +421,3 @@ /**
         log.error("[%s] %s", this.id, msg);
-        return reject(new Error(msg));
+        return reject(new OperationTimeoutError(msg));
       };
@@ -423,0 +424,0 @@

lib/link.ts

@@ -13,2 +13,3 @@ // Copyright (c) Microsoft Corporation. All rights reserved.
 import { Entity } from "./entity";
+import { OperationTimeoutError } from "./operationTimeoutError";
 
@@ -255,3 +256,3 @@ export enum LinkType {
           log.error("[%s] %s", this.connection.id, this.type, msg);
-          return reject(new Error(msg));
+          return reject(new OperationTimeoutError(msg));
         };
@@ -258,0 +259,0 @@

lib/session.ts

@@ -15,2 +15,3 @@ // Copyright (c) Microsoft Corporation. All rights reserved.
 import { Entity } from "./entity";
+import { OperationTimeoutError } from "./operationTimeoutError";
 
@@ -142,3 +143,3 @@ /**
           log.error("[%s] %s", this.connection.id, msg);
-          reject(new Error(msg));
+          reject(new OperationTimeoutError(msg));
         };
@@ -259,3 +260,3 @@
         log.error("[%s] %s", this.connection.id, msg);
-        return reject(new Error(msg));
+        return reject(new OperationTimeoutError(msg));
       };
@@ -349,3 +350,3 @@
         log.error("[%s] %s", this.connection.id, msg);
-        return reject(new Error(msg));
+        return reject(new OperationTimeoutError(msg));
       };
@@ -352,0 +353,0 @@

package.json

 {
   "name": "rhea-promise",
-  "version": "0.1.12",
+  "version": "0.1.13",
   "description": "A Promisified layer over rhea AMQP client",
@@ -10,3 +10,3 @@ "license": "Apache-2.0",
     "debug": "^3.1.0",
-    "rhea": "^0.3.4",
+    "rhea": "^0.3.5",
     "tslib": "^1.9.3"
@@ -28,4 +28,4 @@ },
     "tslint": "^5.11.0",
-    "typescript": "^3.1.6",
-    "dotenv": "^6.1.0"
+    "typescript": "^3.2.2",
+    "dotenv": "^6.2.0"
   },
@@ -32,0 +32,0 @@ "scripts": {

tsconfig.json

@@ -16,3 +16,4 @@ {
       "declaration": true,
-      "declarationDir": "./typings"
+      "declarationDir": "./typings",
+      "declarationMap": true
     },
@@ -19,0 +20,0 @@ "compileOnSave": true,

typings/lib/connection.d.ts

@@ -235,1 +235,2 @@ /// <reference types="node" />
 }
+//# sourceMappingURL=connection.d.ts.map

typings/lib/container.d.ts

@@ -47,1 +47,2 @@ /// <reference types="node" />
 }
+//# sourceMappingURL=container.d.ts.map

typings/lib/entity.d.ts

@@ -18,1 +18,2 @@ /// <reference types="node" />
 }
+//# sourceMappingURL=entity.d.ts.map

typings/lib/eventContext.d.ts

@@ -86,1 +86,2 @@ import { Connection } from "./connection";
 }
+//# sourceMappingURL=eventContext.d.ts.map

typings/lib/index.d.ts

@@ -9,1 +9,2 @@ export { Delivery, Message, MessageProperties, MessageHeader, EventContext as RheaEventContext, ConnectionOptions as ConnectionOptionsBase, AmqpError, Dictionary, types, message, filter, Filter, uuid_to_string, generate_uuid, string_to_uuid, LinkError, ProtocolError, LinkOptions, DeliveryAnnotations, MessageAnnotations, ReceiverEvents, SenderEvents, ConnectionEvents, SessionEvents, ContainerOptions as ContainerOptionsBase, TerminusOptions, Types, Sasl, EndpointOptions, MessageUtil, TypeError, SimpleError, Source, ConnectionError } from "rhea";
 export { Func, AmqpResponseStatusCode, isAmqpError, ConnectionStringParseOptions, delay, messageHeader, messageProperties, parseConnectionString, ParsedOutput } from "./util/utils";
+//# sourceMappingURL=index.d.ts.map

typings/lib/link.d.ts

@@ -114,1 +114,2 @@ import { link, LinkOptions, AmqpError, Dictionary, Source, TerminusOptions } from "rhea";
 }
+//# sourceMappingURL=link.d.ts.map

typings/lib/log.d.ts

@@ -42,1 +42,2 @@ import * as debugModule from "debug";
 export declare const contextTranslator: debugModule.IDebugger;
+//# sourceMappingURL=log.d.ts.map

typings/lib/receiver.d.ts

@@ -58,1 +58,2 @@ import { Session } from "./session";
 }
+//# sourceMappingURL=receiver.d.ts.map

typings/lib/sender.d.ts

@@ -82,1 +82,2 @@ /// <reference types="node" />
 }
+//# sourceMappingURL=sender.d.ts.map

typings/lib/session.d.ts

@@ -85,1 +85,2 @@ import { Connection } from "./connection";
 }
+//# sourceMappingURL=session.d.ts.map

typings/lib/util/constants.d.ts

@@ -5,1 +5,2 @@ /**
 export declare const defaultOperationTimeoutInSeconds = 60;
+//# sourceMappingURL=constants.d.ts.map

typings/lib/util/utils.d.ts

@@ -133,1 +133,2 @@ import { EventContext as RheaEventContext } from "rhea";
 export declare function emitEvent(params: EmitParameters): void;
+//# sourceMappingURL=utils.d.ts.map

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

Total package byte prevSize

257609

increased by7.42%

Number of package files

73

increased by30.36%

Lines of code

4441

increased by1.6%

Dependency changes

• Updatedrhea@^0.3.5