dynamodb-recs - npm Package Compare versions

Comparing version 1.0.13 to 1.0.14

handlers/index.js

@@ -11,3 +11,3 @@ const graphedHandlers = require('graphed');
     if (argsOrApp instanceof App) {
-        argsOrApp = argsOrApp.models.recs.edge;
+        argsOrApp = argsOrApp.models.recs.graph;
     }
@@ -14,0 +14,0 @@

handlers/index.spec.js

@@ -27,4 +27,4 @@ const chai = require('chai');
         
-        expect(graphedHandlers.linkFirehose).to.have.been.calledWith(app.models.recs.edge);
+        expect(graphedHandlers.linkFirehose).to.have.been.calledWith(app.models.recs.graph);
     });
 });

handlers/logsFirehose.spec.js

 const _ = require('lodash');
 const chai = require('chai');
+const rx = require('rxjs');
+const sinon = require('sinon');
+const sinonChai = require('sinon-chai');
 
@@ -11,2 +14,4 @@ const App = require('../App');
 
+chai.use(sinonChai);
+
 const namespace = 'spec';
@@ -23,2 +28,11 @@ const expect = chai.expect;
 
+    beforeEach(() => {
+        sinon.stub(app.models.logs, 'processFirehose')
+            .returns(rx.of(null));
+    });
+
+    afterEach(() => {
+        app.models.logs.processFirehose.restore();
+    });
+
     it('should throw if no firehose configured', () => {
@@ -73,2 +87,4 @@ expect(() => logsFirehose(new App('spec', 'partition', {
         }, {}, (err, data) => {
+            expect(app.models.logs.processFirehose).to.have.been.calledOnce;
+
             expect(data).to.deep.equal({
@@ -75,0 +91,0 @@ records: _.times(3, i => ({

models/Recs.js

@@ -5,3 +5,3 @@ const _ = require('lodash');
 const {
-    Edge,
+    Graph,
     DynamoDbStore
@@ -55,3 +55,3 @@ } = require('graphed');
         this.cache = new Cache(this.app);
-        this.edge = new Edge({
+        this.graph = new Graph({
             partition: app.partition,
@@ -109,3 +109,3 @@ store: new DynamoDbStore({
                                     if (!response || ((_.now() - response.createdAt) >= this.options.ttr)) {
-                                        return this.edge.traverse(args)
+                                        return this.graph.traverse(args)
                                             .pipe(
@@ -205,3 +205,3 @@ rxop.map(response => {
 
-                    return this.edge.allAll({
+                    return this.graph.allAll({
                         collection,
@@ -208,0 +208,0 @@ distance: 1,

models/Recs.spec.js

@@ -8,3 +8,3 @@ const _ = require('lodash');
 const {
-    Edge
+    Graph
 } = require('graphed');
@@ -43,4 +43,4 @@
 
-        it('should have edge', () => {
-            expect(app.models.recs.edge).to.be.instanceOf(Edge);
+        it('should have graph', () => {
+            expect(app.models.recs.graph).to.be.instanceOf(Graph);
         });
@@ -95,3 +95,3 @@ });
         beforeEach(() => {
-            sinon.stub(app.models.recs.edge, 'allAll')
+            sinon.stub(app.models.recs.graph, 'allAll')
                 .returns(rx.from(allAll));
@@ -101,6 +101,6 @@ });
         afterEach(() => {
-            app.models.recs.edge.allAll.restore();
+            app.models.recs.graph.allAll.restore();
         });
 
-        it('should call edge.allAll', done => {
+        it('should call graph.allAll', done => {
             app.models.recs.ingest({
@@ -117,3 +117,3 @@ collection: [
                     expect(response).to.deep.equal(_.flatten(allAll));
-                    expect(app.models.recs.edge.allAll).to.have.been.calledOnceWithExactly({
+                    expect(app.models.recs.graph.allAll).to.have.been.calledOnceWithExactly({
                         collection: [
@@ -140,3 +140,3 @@ '0',
                 .subscribe(() => {
-                    expect(app.models.recs.edge.allAll).to.not.have.been.called;
+                    expect(app.models.recs.graph.allAll).to.not.have.been.called;
                 }, null, done);
@@ -173,15 +173,15 @@ });
             rx.forkJoin(
-                    app.models.recs.edge.deleteByNode({
+                    app.models.recs.graph.deleteByNode({
                         fromNode: '0',
                         namespace
                     }),
-                    app.models.recs.edge.deleteByNode({
+                    app.models.recs.graph.deleteByNode({
                         fromNode: '1',
                         namespace
                     }),
-                    app.models.recs.edge.deleteByNode({
+                    app.models.recs.graph.deleteByNode({
                         fromNode: '2',
                         namespace
                     }),
-                    app.models.recs.edge.deleteByNode({
+                    app.models.recs.graph.deleteByNode({
                         fromNode: '3',
@@ -198,7 +198,7 @@ namespace
         beforeEach(() => {
-            sinon.spy(app.models.recs.edge, 'traverse');
+            sinon.spy(app.models.recs.graph, 'traverse');
         });
 
         afterEach(() => {
-            app.models.recs.edge.traverse.restore();
+            app.models.recs.graph.traverse.restore();
         });
@@ -238,3 +238,3 @@
 
-                    expect(app.models.recs.edge.traverse).to.have.been.calledOnce;
+                    expect(app.models.recs.graph.traverse).to.have.been.calledOnce;
                 }, null, done);
@@ -277,3 +277,3 @@ });
 
-                    expect(app.models.recs.edge.traverse).to.not.have.been.called;
+                    expect(app.models.recs.graph.traverse).to.not.have.been.called;
                 }, null, done);
@@ -299,3 +299,3 @@ });
 
-                    expect(app.models.recs.edge.traverse).to.have.been.calledOnce;
+                    expect(app.models.recs.graph.traverse).to.have.been.calledOnce;
                 }, null, done);
@@ -330,3 +330,3 @@ });
 
-                    expect(app.models.recs.edge.traverse).to.have.been.calledTwice;
+                    expect(app.models.recs.graph.traverse).to.have.been.calledTwice;
                 }, null, done);
@@ -355,3 +355,3 @@ });
 
-                    expect(app.models.recs.edge.traverse).to.have.been.calledTwice;
+                    expect(app.models.recs.graph.traverse).to.have.been.calledTwice;
                 }, null, done);
@@ -379,3 +379,3 @@ });
 
-                    expect(app.models.recs.edge.traverse).to.not.have.been.called;
+                    expect(app.models.recs.graph.traverse).to.not.have.been.called;
                 }, null, done);
@@ -405,3 +405,3 @@ });
 
-                    expect(app.models.recs.edge.traverse).to.have.been.calledTwice;
+                    expect(app.models.recs.graph.traverse).to.have.been.calledTwice;
                 }, null, done);
@@ -408,0 +408,0 @@ });

models/schema/logs.js

@@ -7,2 +7,3 @@ const joi = require('@hapi/joi');
             .min(0)
+            .max(1000)
             .default(100),
@@ -15,2 +16,3 @@ stream: joi.string()
                 .min(0)
+                .max(1000)
                 .default(100),
@@ -17,0 +19,0 @@ offset: joi.number()

models/schema/recs.js

@@ -34,3 +34,3 @@ const joi = require('@hapi/joi');
         .min(0)
-        .default(2 * 365 * 24 * 60 * 60 * 1000), // 2 years
+        .default(365 * 24 * 60 * 60 * 1000), // 1 year
     ttr: joi.number()
@@ -37,0 +37,0 @@ .min(0)

package.json

 {
     "name": "dynamodb-recs",
-    "version": "1.0.13",
+    "version": "1.0.14",
     "main": "index.js",
     "license": "MIT",
     "scripts": {
-        "coverage": "rm -rf coverage; NODE_ENV=test ENCRYPT_KEY='hWmZq3t6w9z$C&F)J@NcRfUjXn2r5u7x' nyc ./node_modules/.bin/_mocha **/*.spec.js --recursive --timeout 5000; rm -rf .nyc_output",
+        "coverage": "rm -rf coverage; NODE_ENV=test nyc ./node_modules/.bin/_mocha **/*.spec.js --recursive --timeout 5000; rm -rf .nyc_output",
         "eslint": "eslint . --ext .js --config node_modules/eslint-config/index.js",
-        "test": "NODE_ENV=test ./node_modules/.bin/_mocha **.spec.js **/**.spec.js --recursive --watch --timeout 5000"
+        "test": "NODE_ENV=test ./node_modules/.bin/_mocha **/**.spec.js --recursive --watch --timeout 5000"
     },
     "dependencies": {
         "@hapi/joi": "^16.1.8",
-        "aws-sdk": "^2.585.0",
-        "graphed": "^1.0.10",
+        "aws-sdk": "^2.595.0",
+        "graphed": "^1.0.11",
         "lodash": "^4.17.15",
@@ -22,3 +22,3 @@ "rxjs": "6.5.3",
         "chai": "^4.2.0",
-        "eslint": "^6.7.2",
+        "eslint": "^6.8.0",
         "mocha": "^6.2.2",
@@ -25,0 +25,0 @@ "nyc": "^14.1.1",

No alert changes

Worsened metrics

Total package byte prevSize

67940

decreased by-3.95%

Number of package files

33

decreased by-5.71%

Lines of code

1885

decreased by-4.17%

Dependency changes

• Updatedaws-sdk@^2.595.0

• Updatedgraphed@^1.0.11