better-queue - npm Package Compare versions

Comparing version 3.7.7 to 3.7.8

lib/stores/PostgresAdapter.js

@@ -33,26 +33,26 @@ var _      = require('lodash');
 PostgresAdapter.prototype.initialize = function (cb) {
-  var sql = '                                                                                                          \n\
-    CREATE FUNCTION upsert_' + this.tableName + '(_id TEXT, _lock TEXT, _task TEXT, _priority NUMERIC) RETURNS VOID AS \n\
-    $$                                                                                                                 \n\
-    BEGIN                                                                                                              \n\
-        LOOP                                                                                                           \n\
-            -- first try to update the key                                                                             \n\
-            -- note that "id" must be unique                                                                           \n\
-            UPDATE ' + this.tableName + ' SET lock=_lock, task=_task, priority=_priority WHERE id=_id;                 \n\
-            IF found THEN                                                                                              \n\
-                RETURN;                                                                                                \n\
-            END IF;                                                                                                    \n\
-            -- not there, so try to insert the key                                                                     \n\
-            -- if someone else inserts the same key concurrently,                                                      \n\
-            -- we could get a unique-key failure                                                                       \n\
-            BEGIN                                                                                                      \n\
-                INSERT INTO ' + this.tableName + ' (id, lock, task, priority) VALUES (_id, _lock, _task, _priority);   \n\
-                RETURN;                                                                                                \n\
-            EXCEPTION WHEN unique_violation THEN                                                                       \n\
-                -- do nothing, and loop to try the UPDATE again                                                        \n\
-            END;                                                                                                       \n\
-        END LOOP;                                                                                                      \n\
-    END;                                                                                                               \n\
-    $$                                                                                                                 \n\
-    LANGUAGE plpgsql;                                                                                                  \n\
+  var sql = '                                                                                                                     \n\
+    CREATE OR REPLACE FUNCTION upsert_' + this.tableName + '(_id TEXT, _lock TEXT, _task TEXT, _priority NUMERIC) RETURNS VOID AS \n\
+    $$                                                                                                                            \n\
+    BEGIN                                                                                                                         \n\
+        LOOP                                                                                                                      \n\
+            -- first try to update the key                                                                                        \n\
+            -- note that "id" must be unique                                                                                      \n\
+            UPDATE ' + this.tableName + ' SET lock=_lock, task=_task, priority=_priority WHERE id=_id;                            \n\
+            IF found THEN                                                                                                         \n\
+                RETURN;                                                                                                           \n\
+            END IF;                                                                                                               \n\
+            -- not there, so try to insert the key                                                                                \n\
+            -- if someone else inserts the same key concurrently,                                                                 \n\
+            -- we could get a unique-key failure                                                                                  \n\
+            BEGIN                                                                                                                 \n\
+                INSERT INTO ' + this.tableName + ' (id, lock, task, priority) VALUES (_id, _lock, _task, _priority);              \n\
+                RETURN;                                                                                                           \n\
+            EXCEPTION WHEN unique_violation THEN                                                                                  \n\
+                -- do nothing, and loop to try the UPDATE again                                                                   \n\
+            END;                                                                                                                  \n\
+        END LOOP;                                                                                                                 \n\
+    END;                                                                                                                          \n\
+    $$                                                                                                                            \n\
+    LANGUAGE plpgsql;                                                                                                             \n\
   ';
@@ -59,0 +59,0 @@ this.run(sql, function (err) {

package.json

 {
   "name": "better-queue",
-  "version": "3.7.7",
+  "version": "3.7.8",
   "description": "Better Queue for NodeJS",
@@ -5,0 +5,0 @@ "main": "lib/queue.js",

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

Long strings

Supply chain risk

Contains long string literals, which may be a sign of obfuscated or packed code.

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

Long strings

Supply chain risk

Contains long string literals, which may be a sign of obfuscated or packed code.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

90751

increased by0.29%

Worsened metrics

Number of low supply chain risk alerts

3

increased by50%

No dependency changes