lifion-kinesis - npm Package Compare versions

Comparing version 1.2.0 to 1.2.1

CHANGELOG.md

@@ -10,2 +10,9 @@ ## Changelog
 
+### v1.2.1 (2020-04-16)
+
+- [`#317`](https://github.com/lifion/lifion-kinesis/pull/317): Hotfix/fallback to describeStream when describeStreamSummary operation not available
+- [`d0c1b12`](https://github.com/lifion/lifion-kinesis/commit/d0c1b121a22d9143184b3153ee17a0db7f771c39): Fallback to describeStream when the describeStream operation is unavailable (e.g. on localstack)
+- [`5954425`](https://github.com/lifion/lifion-kinesis/commit/595442515e5b5d4120fb48d1b55539d94232a101): Lint issues
+- [`bb7020c`](https://github.com/lifion/lifion-kinesis/commit/bb7020c538b5188752b99e6f173b7657eae58ab9): Lint issues
+
 ### v1.2.0 (2020-04-14)
@@ -12,0 +19,0 @@

lib/kinesis-client.js

@@ -219,3 +219,13 @@ /**
     const { client, retryOpts, streamName } = internal(this);
-    return retriableSdkCall(client, 'describeStreamSummary', streamName, retryOpts, ...args);
+
+    return sdkCall(client, 'describeStreamSummary', streamName, ...args).catch((err) => {
+      if (err.code !== 'UnknownOperationException') throw err;
+
+      return retriableSdkCall(client, 'describeStream', streamName, retryOpts, ...args).then(
+        (data) => {
+          const { StreamDescription } = data;
+          return { StreamDescriptionSummary: StreamDescription };
+        }
+      );
+    });
   }
@@ -222,0 +232,0 @@

package.json

 {
   "name": "lifion-kinesis",
-  "version": "1.2.0",
+  "version": "1.2.1",
   "description": "Lifion client for Amazon Kinesis Data streams",
@@ -51,3 +51,3 @@ "keywords": [
     "async-retry": "^1.3.1",
-    "aws-sdk": "^2.656.0",
+    "aws-sdk": "^2.657.0",
     "aws4": "^1.9.1",
@@ -54,0 +54,0 @@ "fast-deep-equal": "^3.1.1",

No alert changes

Improved metrics

Total package byte prevSize

247189

increased by0.38%

Lines of code

4617

increased by0.17%

Dependency changes

• Updatedaws-sdk@^2.657.0