dynamodb-enhanced
Advanced tools
Comparing version 0.4.0-ac to 0.4.0-ad
@@ -27,2 +27,3 @@ // Copyright Teleportd Ltd. and other Contributors | ||
var AWS = require('aws-sdk'); | ||
var fwk = require('fwk'); | ||
@@ -35,3 +36,3 @@ | ||
* | ||
* @param spec {secretAccessKey, accessKeyId, endpoint, agent, sessionToken, sessionExpires} | ||
* @param spec {secretAccessKey, accessKeyId, endpoint, agent, region, sessionToken, sessionExpires} | ||
*/ | ||
@@ -42,2 +43,3 @@ | ||
var _super = {}; | ||
var dynamodb = new AWS.DynamoDB({apiVersion: '2012-08-10'}); | ||
@@ -50,2 +52,11 @@ my.accessKeyId = spec.accessKeyId; | ||
AWS.config.region = spec.region || 'us-east-1'; | ||
AWS.config.credentials.accessKeyId = spec.accessKeyId; | ||
AWS.config.credentials.secretAccessKey = spec.secretAccessKey; | ||
AWS.config.maxRetries = spec.retries || undefined; | ||
my.retries = spec.retries || 3; | ||
@@ -61,2 +72,5 @@ | ||
my.inAuth = false; | ||
@@ -125,3 +139,3 @@ my.consumedCapacity = 0; | ||
} | ||
execute('CreateTable', data, function(err, res) { | ||
dynamodb.createTable(data, function(err, res) { | ||
if(err) { cb(err) } | ||
@@ -152,3 +166,3 @@ else { | ||
} | ||
execute('UpdateTable', data, function(err, res) { | ||
dynamodb.updateTable(data, function(err, res) { | ||
if(err) { cb(err) } | ||
@@ -171,3 +185,3 @@ else { | ||
data.TableName = table; | ||
execute('DeleteTable', data, function(err, res) { | ||
dynamodb.deleteTable(data, function(err, res) { | ||
if(err) { cb(err) } | ||
@@ -192,3 +206,3 @@ else { | ||
data.ExclusiveStartTableName = options.exclusiveStartTableName; | ||
execute('ListTables', data, cb); | ||
dynamodb.listTables(data, cb); | ||
}; | ||
@@ -206,3 +220,3 @@ | ||
data.TableName = table; | ||
execute('DescribeTable', data, function(err, res) { | ||
dynamodb.describeTable(data, function(err, res) { | ||
if(err) { cb(err) } | ||
@@ -245,3 +259,3 @@ else { | ||
} | ||
execute('GetItem', data, function(err, res) { | ||
dynamodb.getItem(data, function(err, res) { | ||
if(err) { cb(err) } | ||
@@ -302,3 +316,3 @@ else { | ||
} | ||
execute('PutItem', data, function(err, res) { | ||
dynamodb.putItem(data, function(err, res) { | ||
if(err) { cb(err) } | ||
@@ -359,3 +373,3 @@ else { | ||
} | ||
execute('DeleteItem', data, function(err, res) { | ||
dynamodb.deleteItem(data, function(err, res) { | ||
if(err) { cb(err) } | ||
@@ -429,3 +443,3 @@ else { | ||
//console.log(require('util').inspect(data, false, 20)); | ||
execute('UpdateItem', data, function(err, res) { | ||
dynamodb.updateItem(data, function(err, res) { | ||
if(err) { cb(err) } | ||
@@ -488,3 +502,3 @@ else { | ||
} | ||
execute('BatchGetItem', data, function(err, res) { | ||
dynamodb.batchGetItem(data, function(err, res) { | ||
if(err) { cb(err) } | ||
@@ -562,3 +576,3 @@ else { | ||
} | ||
execute('BatchWriteItem', data, function(err, res) { | ||
dynamodb.batchWriteItem(data, function(err, res) { | ||
if(err) | ||
@@ -643,3 +657,3 @@ cb(err); | ||
} | ||
execute('Query', data, function(err, res) { | ||
dynamodb.query(data, function(err, res) { | ||
if(err) { cb(err) } | ||
@@ -726,3 +740,3 @@ else { | ||
//console.log(require('util').inspect(data)); | ||
execute('Scan', data, function(err, res) { | ||
dynamodb.scan(data, function(err, res) { | ||
if(err) { cb(err) } | ||
@@ -953,3 +967,2 @@ else { | ||
var sdfsdf = 0; | ||
execute = function(op, data, cb) { | ||
@@ -968,2 +981,3 @@ auth(function(err) { | ||
('host' + ':' + my.endpoint + '\n' + | ||
'x-amz-date' + ':' + dtStr + '\n' + | ||
'x-amz-security-token' + ':' + my.access.sessionToken + '\n' + | ||
@@ -985,5 +999,7 @@ 'x-amz-target' + ':' + 'DynamoDB_20120810.' + op + '\n') + '\n' + | ||
var headers = { 'Host': my.endpoint, | ||
'x-amz-date': dtStr, | ||
'x-amz-security-token': my.access.sessionToken, | ||
'X-amz-target': 'DynamoDB_20120810.' + op, | ||
'X-amzn-authorization' : auth, | ||
'date': dtStr, | ||
'content-type': 'application/x-amz-json-1.0', | ||
@@ -1000,4 +1016,2 @@ 'content-length': Buffer.byteLength(rqBody,'utf8') }; | ||
var executeRequest = function(cb) { | ||
sdfsdf++; | ||
console.log(sdfsdf); | ||
var req = http.request(options, function(res) { | ||
@@ -1004,0 +1018,0 @@ var body = ''; |
{ | ||
"name": "dynamodb-enhanced", | ||
"version": "0.4.0ac", | ||
"version": "0.4.0ad", | ||
"description": "Simple DynamoDB Library for Node.js. enhanced version of dynamodb by Stanislas Polu", | ||
"keywords": ["dynamo", "node", "db", "aws", "amazon"], | ||
"keywords": [ | ||
"dynamo", | ||
"node", | ||
"db", | ||
"aws", | ||
"amazon" | ||
], | ||
"homepage": "https://github.com/teleportd/node-dynamodb", | ||
"author": { "name": "Jt Whissel", | ||
"email": "jtwhissel@gmail.com", | ||
"url": "http://www.linkedin.com/in/jtwhissel/" }, | ||
"repository" : { "type" : "git", | ||
"url" : "https://github.com/jtwhissel/node-dynamodb" }, | ||
"contributors" : [ "Stanislas Polu", | ||
"Karl Seguin", | ||
"Juan Carlos del Valle", | ||
"Pablo Cantero", | ||
"Chris Stivers", | ||
"Juho Mäkinen", | ||
"Paul Tax", | ||
"Alex Bosworth", | ||
"Jimb Esser", | ||
"Anthony Moi" ], | ||
"author": { | ||
"name": "Jt Whissel", | ||
"email": "jtwhissel@gmail.com", | ||
"url": "http://www.linkedin.com/in/jtwhissel/" | ||
}, | ||
"repository": { | ||
"type": "git", | ||
"url": "https://github.com/jtwhissel/node-dynamodb" | ||
}, | ||
"contributors": [ | ||
"Stanislas Polu", | ||
"Karl Seguin", | ||
"Juan Carlos del Valle", | ||
"Pablo Cantero", | ||
"Chris Stivers", | ||
"Juho Mäkinen", | ||
"Paul Tax", | ||
"Alex Bosworth", | ||
"Jimb Esser", | ||
"Anthony Moi" | ||
], | ||
"dependencies": { | ||
"aws-sdk": "^2.0.23", | ||
"fwk": "0.1.x" | ||
}, | ||
"main" : "./lib/ddb", | ||
"engines" : { "node" : ">=0.4.0" } | ||
"main": "./lib/ddb", | ||
"engines": { | ||
"node": ">=0.4.0" | ||
} | ||
} |
Manifest confusion
Supply chain riskThis package has inconsistent metadata. This could be malicious or caused by an error when publishing the package.
Found 1 instance in 1 package
Manifest confusion
Supply chain riskThis package has inconsistent metadata. This could be malicious or caused by an error when publishing the package.
Found 1 instance in 1 package
81434
1876
2
+ Addedaws-sdk@^2.0.23
+ Addedavailable-typed-arrays@1.0.7(transitive)
+ Addedaws-sdk@2.1692.0(transitive)
+ Addedbase64-js@1.5.1(transitive)
+ Addedbuffer@4.9.2(transitive)
+ Addedcall-bind@1.0.8(transitive)
+ Addedcall-bind-apply-helpers@1.0.1(transitive)
+ Addedcall-bound@1.0.3(transitive)
+ Addeddefine-data-property@1.1.4(transitive)
+ Addeddunder-proto@1.0.1(transitive)
+ Addedes-define-property@1.0.1(transitive)
+ Addedes-errors@1.3.0(transitive)
+ Addedes-object-atoms@1.1.1(transitive)
+ Addedevents@1.1.1(transitive)
+ Addedfor-each@0.3.4(transitive)
+ Addedfunction-bind@1.1.2(transitive)
+ Addedget-intrinsic@1.2.7(transitive)
+ Addedget-proto@1.0.1(transitive)
+ Addedgopd@1.2.0(transitive)
+ Addedhas-property-descriptors@1.0.2(transitive)
+ Addedhas-symbols@1.1.0(transitive)
+ Addedhas-tostringtag@1.0.2(transitive)
+ Addedhasown@2.0.2(transitive)
+ Addedieee754@1.1.13(transitive)
+ Addedinherits@2.0.4(transitive)
+ Addedis-arguments@1.2.0(transitive)
+ Addedis-callable@1.2.7(transitive)
+ Addedis-generator-function@1.1.0(transitive)
+ Addedis-regex@1.2.1(transitive)
+ Addedis-typed-array@1.1.15(transitive)
+ Addedisarray@1.0.0(transitive)
+ Addedjmespath@0.16.0(transitive)
+ Addedmath-intrinsics@1.1.0(transitive)
+ Addedpossible-typed-array-names@1.1.0(transitive)
+ Addedpunycode@1.3.2(transitive)
+ Addedquerystring@0.2.0(transitive)
+ Addedsafe-regex-test@1.1.0(transitive)
+ Addedsax@1.2.1(transitive)
+ Addedset-function-length@1.2.2(transitive)
+ Addedurl@0.10.3(transitive)
+ Addedutil@0.12.5(transitive)
+ Addeduuid@8.0.0(transitive)
+ Addedwhich-typed-array@1.1.18(transitive)
+ Addedxml2js@0.6.2(transitive)
+ Addedxmlbuilder@11.0.1(transitive)