lifion-kinesis - npm Package Compare versions

Comparing version 1.0.9 to 1.0.10

CHANGELOG.md

@@ -10,2 +10,22 @@ ## Changelog
 
+### v1.0.10 (2019-08-02)
+
+- [`#199`](https://github.com/lifion/lifion-kinesis/pull/199): Recreate the shard iterator if it expired in between polling reads
+- [`#197`](https://github.com/lifion/lifion-kinesis/pull/197): Update dependency husky to ^3.0.2
+- [`#198`](https://github.com/lifion/lifion-kinesis/pull/198): Update dependency aws-sdk to ^2.503.0
+- [`#196`](https://github.com/lifion/lifion-kinesis/pull/196): Update dependency aws-sdk to ^2.501.0
+- [`#194`](https://github.com/lifion/lifion-kinesis/pull/194): Update dependency lint-staged to ^9.2.1
+- [`#195`](https://github.com/lifion/lifion-kinesis/pull/195): Update dependency aws-sdk to ^2.500.0
+- [`#193`](https://github.com/lifion/lifion-kinesis/pull/193): Update dependency aws-sdk to ^2.499.0
+- [`#191`](https://github.com/lifion/lifion-kinesis/pull/191): Update dependency aws-sdk to ^2.498.0
+- [`#192`](https://github.com/lifion/lifion-kinesis/pull/192): Update dependency semver to ^6.3.0
+- [`#190`](https://github.com/lifion/lifion-kinesis/pull/190): Update dependency aws-sdk to ^2.497.0
+- [`#189`](https://github.com/lifion/lifion-kinesis/pull/189): Update dependency aws-sdk to ^2.496.0
+- [`#188`](https://github.com/lifion/lifion-kinesis/pull/188): Update dependency husky to ^3.0.1
+- [`#187`](https://github.com/lifion/lifion-kinesis/pull/187): Update dependency aws-sdk to ^2.495.0
+- [`#186`](https://github.com/lifion/lifion-kinesis/pull/186): Update dependency aws-sdk to ^2.494.0
+- [`25e92c5`](https://github.com/lifion/lifion-kinesis/commit/25e92c53da9809aa4ef1cd3249d4bf7d178dc05b): Recreate the shard iterator if it is expired
+- [`62a37b0`](https://github.com/lifion/lifion-kinesis/commit/62a37b02c8c59c0e3eed1df20b7a059671c0260f): Recreate lock file
+- [`2ca7572`](https://github.com/lifion/lifion-kinesis/commit/2ca7572039f1bdf67a1180672180c6254a61b8c3): Upgrade dependencies
+
 ### v1.0.9 (2019-07-09)
@@ -12,0 +32,0 @@

lib/constants.js

@@ -17,2 +17,3 @@ /**
   'ConditionalCheckFailedException',
+  'ExpiredIteratorException',
   'MissingParameter',
@@ -19,0 +20,0 @@ 'MissingRequiredParameter',

lib/polling-consumer.js

@@ -163,2 +163,8 @@ /**
   } catch (err) {
+    if (err.code === 'ExpiredIteratorException') {
+      logger.warn('Previous shard iterator expired, recreating…');
+      privateProps.iterator = null;
+      await pollForRecords(instance);
+      return;
+    }
     logger.error(err);
@@ -253,4 +259,6 @@ pushToStream(err);
 
-    privateProps.setCheckpoint = sequenceNumber =>
-      stateStore.storeShardCheckpoint(shardId, sequenceNumber, shardsPath, shardsPathNames);
+    privateProps.setCheckpoint = async sequenceNumber => {
+      await stateStore.storeShardCheckpoint(shardId, sequenceNumber, shardsPath, shardsPathNames);
+      privateProps.checkpoint = sequenceNumber;
+    };
 
@@ -257,0 +265,0 @@ privateProps.continuePolling = () => pollForRecords(this);

package.json

 {
   "name": "lifion-kinesis",
-  "version": "1.0.9",
+  "version": "1.0.10",
   "description": "Lifion client for Amazon Kinesis Data streams",
@@ -18,2 +18,3 @@ "keywords": [
   "maintainers": [
+    "Chen Doron <[e-mail]>",
     "Edgardo Avilés <[e-mail]>",
@@ -42,3 +43,3 @@ "Mackenzie Turner <[e-mail]>"
     "async-retry": "^1.2.3",
-    "aws-sdk": "^2.490.0",
+    "aws-sdk": "^2.503.0",
     "aws4": "^1.8.0",
@@ -48,3 +49,3 @@ "fast-deep-equal": "^2.0.1",
     "is-retry-allowed": "^1.1.0",
-    "lifion-aws-event-stream": "^1.0.4",
+    "lifion-aws-event-stream": "^1.0.5",
     "lru-cache": "^5.1.1",
@@ -61,10 +62,10 @@ "lzutf8": "^0.5.5",
     "eslint": "^5.16.0",
-    "eslint-config-lifion": "^1.2.4",
-    "husky": "^3.0.0",
+    "eslint-config-lifion": "^1.2.6",
+    "husky": "^3.0.2",
     "jest": "^24.8.0",
     "jsdoc-to-markdown": "^5.0.0",
-    "lint-staged": "^9.1.0",
+    "lint-staged": "^9.2.1",
     "npm-watch": "^0.6.0",
     "prettier": "^1.18.2",
-    "semver": "^6.2.0"
+    "semver": "^6.3.0"
   },
@@ -71,0 +72,0 @@ "auto-changelog": {

No alert changes

Improved metrics

Total package byte prevSize

201362

increased by1.11%

Lines of code

3835

increased by0.24%

Dependency changes

• Updatedaws-sdk@^2.503.0

• Updatedlifion-aws-event-stream@^1.0.5