@saulx/selva - npm Package Compare versions

Comparing version 19.2.1 to 20.0.0

dist/src/connection/execBatch.js

@@ -110,2 +110,3 @@ "use strict";
                         if (queue.length > 1e3) {
+                            // make this timeout longer
                             process.nextTick(() => {
@@ -112,0 +113,0 @@ // let it gc a bit

dist/src/connection/index.js

@@ -578,2 +578,3 @@ "use strict";
         }
+        // NEW SELVA CONNECTION which shared connecton as an abtract class for ts conflicts
         connection = new Connection(serverDescriptor);
@@ -580,0 +581,0 @@ }

dist/src/set/fieldParsers/array.js

@@ -22,3 +22,8 @@ "use strict";
 }
-async function sendInsert(typeArg, idx, client, schema, field, payload, result, fields, type, $lang) {
+async function sendInsert(typeArg, idx, client, schema, field, payload, result, fields, type, maxLen, $lang) {
+    if (maxLen >= 0) {
+        const content = new Uint32Array([maxLen - 1]);
+        const buf = Buffer.from(content.buffer);
+        result.push('H', field, buf);
+    }
     result.push('E', field, typeArg);
@@ -73,8 +78,20 @@ if (!Number.isInteger(idx) || !payload) {
                 for (let i = payload.$unshift.length - 1; i >= 0; i--) {
-                    const v = payload[i];
-                    await sendInsert(buf, 0, client, schema, field, v, result, fields, type, $lang);
+                    const v = payload.$unshift[i];
+                    await sendInsert(buf, 0, client, schema, field, v, result, fields, type, undefined, $lang);
                 }
             }
+            else if (payload.$unshift.$value) {
+                const { $maxLen, $value } = payload.$unshift;
+                if (Array.isArray($value)) {
+                    for (let i = $value.length - 1; i >= 0; i--) {
+                        const v = $value[i];
+                        await sendInsert(buf, 0, client, schema, field, v, result, fields, type, $maxLen, $lang);
+                    }
+                }
+                else {
+                    await sendInsert(buf, 0, client, schema, field, $value, result, fields, type, $maxLen, $lang);
+                }
+            }
             else {
-                await sendInsert(buf, 0, client, schema, field, payload.$unshift, result, fields, type, $lang);
+                await sendInsert(buf, 0, client, schema, field, payload.$unshift, result, fields, type, undefined, $lang);
             }
@@ -101,7 +118,7 @@ }
                     const v = payload.$insert.$value[i];
-                    await sendInsert(buf, idx, client, schema, field, v, result, fields, type, $lang);
+                    await sendInsert(buf, idx, client, schema, field, v, result, fields, type, undefined, $lang);
                 }
             }
             else {
-                await sendInsert(buf, idx, client, schema, field, payload.$insert.$value, result, fields, type, $lang);
+                await sendInsert(buf, idx, client, schema, field, payload.$insert.$value, result, fields, type, undefined, $lang);
             }
@@ -108,0 +125,0 @@ }

dist/src/set/fieldParsers/simple.js

@@ -84,7 +84,7 @@ "use strict";
                                 $default: isNaN(payload.$default)
-                                    ? 0
-                                    : Number(payload.$default),
+                                    ? BigInt(0)
+                                    : BigInt(Number(payload.$default)),
                                 $increment: isNaN(payload.$increment)
-                                    ? 0
-                                    : Number(payload.$increment),
+                                    ? BigInt(0)
+                                    : BigInt(Number(payload.$increment)),
                             }));
@@ -91,0 +91,0 @@ }

package.json

 {
   "name": "@saulx/selva",
-  "version": "19.2.1",
+  "version": "20.0.0",
   "license": "MIT",
@@ -54,3 +54,3 @@ "main": "dist/src/index.js",
     "@types/pg": "^8.6.1",
-    "@saulx/selva-server": "19.2.1",
+    "@saulx/selva-server": "20.0.0",
     "before-exit": "1.0.0",
@@ -57,0 +57,0 @@ "async-exec": "^1.1.0",

No alert changes

Improved metrics

Total package byte prevSize

1214122

increased by0.18%

Number of package files

318

increased by0.95%

Lines of code

16754

increased by0.12%

No dependency changes