Comparing version 1.0.3 to 1.0.4
@@ -17,3 +17,3 @@ const _ = require('lodash'); | ||
const edge = new Edge({ | ||
prefix: app.prefix, | ||
partition: app.partition, | ||
store: app.store | ||
@@ -44,3 +44,3 @@ }, { | ||
expect(() => linkFirehose(new Edge({ | ||
prefix: app.prefix, | ||
partition: app.partition, | ||
store: app.store | ||
@@ -47,0 +47,0 @@ }))).to.throw('no firehose configured.'); |
@@ -33,3 +33,3 @@ const _ = require('lodash'); | ||
this.defaultEntity = value.defaultEntity; | ||
this.prefix = value.prefix; | ||
this.partition = value.partition; | ||
this.store = value.store; | ||
@@ -99,3 +99,3 @@ | ||
return this.getAll(_.extend({}, args, { | ||
namespace: _.compact([this.prefix, args.namespace]).join('.'), | ||
namespace: _.compact([this.partition, args.namespace]).join('.'), | ||
inverse: args.onlyNodes ? false : args.inverse | ||
@@ -126,3 +126,3 @@ })) | ||
return this.getAllByDistance(_.extend({}, args, { | ||
namespace: _.compact([this.prefix, args.namespace]).join('.') | ||
namespace: _.compact([this.partition, args.namespace]).join('.') | ||
})); | ||
@@ -143,3 +143,3 @@ }) | ||
return this.countEdges(_.extend({}, args, { | ||
namespace: _.compact([this.prefix, args.namespace]).join('.') | ||
namespace: _.compact([this.partition, args.namespace]).join('.') | ||
})); | ||
@@ -160,3 +160,3 @@ }) | ||
return this.deleteEdge(_.extend({}, args, { | ||
namespace: _.compact([this.prefix, args.namespace]).join('.') | ||
namespace: _.compact([this.partition, args.namespace]).join('.') | ||
})); | ||
@@ -177,3 +177,3 @@ }) | ||
return this.deleteEdges(_.extend({}, args, { | ||
namespace: _.compact([this.prefix, args.namespace]).join('.') | ||
namespace: _.compact([this.partition, args.namespace]).join('.') | ||
})); | ||
@@ -214,3 +214,3 @@ }) | ||
distance: args.absoluteDistance ? args.absoluteDistance : -(args.distance * this.decrementPath), | ||
namespace: _.compact([this.prefix, args.namespace]).join('.') | ||
namespace: _.compact([this.partition, args.namespace]).join('.') | ||
})); | ||
@@ -217,0 +217,0 @@ }) |
@@ -48,3 +48,3 @@ const joi = require('@hapi/joi'); | ||
defaultEntity: joi.string(), | ||
prefix: joi.string() | ||
partition: joi.string() | ||
.required(), | ||
@@ -51,0 +51,0 @@ store: joi.object({ |
{ | ||
"name": "graphed", | ||
"version": "1.0.3", | ||
"version": "1.0.4", | ||
"description": "Minimum graph's data structure implemented with pluggable stores (redis, dynamodb, memory, ...) and compatible with AWS Firehose", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
@@ -11,3 +11,3 @@ const AWS = require('aws-sdk'); | ||
constructor() { | ||
this.prefix = 'spec'; | ||
this.partition = 'spec'; | ||
this.dynamoDb = new DynamoDB({ | ||
@@ -14,0 +14,0 @@ client: new AWS.DynamoDB({ |
Sorry, the diff of this file is too big to display
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
176003