dpool - npm Package Compare versions

Comparing version 0.1.3 to 0.1.4

index.js

@@ -1,2 +0,2 @@
-const dpool = require("./src/dpool.js");
+const { dpool } = require("./src/dpool.js");
 module.exports = { dpool };

package.json

 {
   "name": "dpool",
   "repository": "git://github.com/ryanbethel/dpool.git", 
-  "version": "0.1.3",
+  "version": "0.1.4",
   "description": "Serverless pooling function for relational databases, using a DynamoDB table as a queue",
@@ -6,0 +6,0 @@ "main": "index.js",

src/dpool.js

@@ -56,2 +56,3 @@ let arc = require("@architect/functions");
         queryLimit,
+        poolTable,
     });
@@ -75,5 +76,5 @@
     dynamo,
-    { lockId, nowMs, poolName, poolSize, minWaitQueueMs, waitVarianceMs, maxRetries }
+    { lockId, nowMs, poolName, poolSize, minWaitQueueMs, waitVarianceMs, maxRetries, poolTable }
 ) {
-    let maxTimeToQueue = await checkQueue(dynamo, { lockId, nowMs, poolName, poolSize });
+    let maxTimeToQueue = await checkQueue(dynamo, { lockId, nowMs, poolName, poolSize, poolTable });
     let retries = 0;
@@ -88,7 +89,7 @@ while (maxTimeToQueue > Date.now()) {
         );
-        maxTimeToQueue = await checkQueue(dynamo, { lockId, nowMs, poolName, poolSize });
+        maxTimeToQueue = await checkQueue(dynamo, { lockId, nowMs, poolName, poolSize, poolTable });
     }
 }
 
-async function checkQueue(dynamo, { queryLimit, poolName, poolSize, nowMs, lockId }) {
+async function checkQueue(dynamo, { queryLimit, poolName, poolSize, nowMs, lockId, poolTable }) {
     let poolQuery = await dynamo[poolTable].query({
@@ -95,0 +96,0 @@ ExpressionAttributeNames: { "#p": "pk" },

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

10374

increased by0.65%

Lines of code

119

increased by0.85%

No dependency changes