cojson-storage-sqlite - npm Package Compare versions

Comparing version 0.13.31 to 0.13.32

CHANGELOG.md

 # cojson-storage-sqlite
 
+## 0.13.32
+
+### Patch Changes
+
+- Updated dependencies [2bf9743]
+  - cojson-storage@0.13.32
+
 ## 0.13.31
@@ -4,0 +11,0 @@

dist/sqliteClient.d.ts

@@ -24,3 +24,3 @@ import type { Database as DatabaseT } from "better-sqlite3";
     getSingleCoValueSession(coValueRowId: number, sessionID: SessionID): StoredSessionRow | undefined;
-    getNewTransactionInSession(sessionRowId: number, firstNewTxIdx: number): TransactionRow[];
+    getNewTransactionInSession(sessionRowId: number, fromIdx: number, toIdx: number): TransactionRow[];
     getSignatures(sessionRowId: number, firstNewTxIdx: number): SignatureAfterRow[];
@@ -27,0 +27,0 @@ addCoValue(msg: CojsonInternalTypes.NewContentMessage): number;

dist/sqliteClient.js

@@ -43,6 +43,6 @@ import { logger, } from "cojson";
     }
-    getNewTransactionInSession(sessionRowId, firstNewTxIdx) {
+    getNewTransactionInSession(sessionRowId, fromIdx, toIdx) {
         const txs = this.db
-            .prepare("SELECT * FROM transactions WHERE ses = ? AND idx >= ?")
-            .all(sessionRowId, firstNewTxIdx);
+            .prepare("SELECT * FROM transactions WHERE ses = ? AND idx >= ? AND idx <= ?")
+            .all(sessionRowId, fromIdx, toIdx);
         try {
@@ -49,0 +49,0 @@ return txs.map((transactionRow) => ({

dist/tests/testUtils.d.ts

@@ -9,2 +9,3 @@ import type { LocalNode, SyncMessage } from "cojson";
 };
+export declare function waitFor(callback: () => boolean | undefined | Promise<boolean | undefined>): Promise<void>;
 //# sourceMappingURL=testUtils.d.ts.map

dist/tests/testUtils.js

@@ -33,2 +33,26 @@ import { StorageManagerSync } from "cojson-storage";
 }
+export function waitFor(callback) {
+    return new Promise((resolve, reject) => {
+        const checkPassed = async () => {
+            try {
+                return { ok: await callback(), error: null };
+            }
+            catch (error) {
+                return { ok: false, error };
+            }
+        };
+        let retries = 0;
+        const interval = setInterval(async () => {
+            const { ok, error } = await checkPassed();
+            if (ok !== false) {
+                clearInterval(interval);
+                resolve();
+            }
+            if (++retries > 10) {
+                clearInterval(interval);
+                reject(error);
+            }
+        }, 100);
+    });
+}
 //# sourceMappingURL=testUtils.js.map

package.json

 {
   "name": "cojson-storage-sqlite",
   "type": "module",
-  "version": "0.13.31",
+  "version": "0.13.32",
   "main": "dist/index.js",
@@ -11,3 +11,3 @@ "types": "dist/index.d.ts",
     "cojson": "0.13.31",
-    "cojson-storage": "0.13.31"
+    "cojson-storage": "0.13.32"
   },
@@ -14,0 +14,0 @@ "devDependencies": {

src/sqliteClient.ts

@@ -89,9 +89,10 @@ import type { Database as DatabaseT } from "better-sqlite3";
     sessionRowId: number,
-    firstNewTxIdx: number,
+    fromIdx: number,
+    toIdx: number,
   ): TransactionRow[] {
     const txs = this.db
-      .prepare<[number, number]>(
-        "SELECT * FROM transactions WHERE ses = ? AND idx >= ?",
+      .prepare<[number, number, number]>(
+        "SELECT * FROM transactions WHERE ses = ? AND idx >= ? AND idx <= ?",
       )
-      .all(sessionRowId, firstNewTxIdx) as RawTransactionRow[];
+      .all(sessionRowId, fromIdx, toIdx) as RawTransactionRow[];
 
@@ -98,0 +99,0 @@ try {

src/tests/testUtils.ts

@@ -45,1 +45,30 @@ import type { LocalNode, SyncMessage } from "cojson";
 }
+export function waitFor(
+  callback: () => boolean | undefined | Promise<boolean | undefined>,
+) {
+  return new Promise<void>((resolve, reject) => {
+    const checkPassed = async () => {
+      try {
+        return { ok: await callback(), error: null };
+      } catch (error) {
+        return { ok: false, error };
+      }
+    };
+
+    let retries = 0;
+
+    const interval = setInterval(async () => {
+      const { ok, error } = await checkPassed();
+
+      if (ok !== false) {
+        clearInterval(interval);
+        resolve();
+      }
+
+      if (++retries > 10) {
+        clearInterval(interval);
+        reject(error);
+      }
+    }, 100);
+  });
+}

New alerts

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

113033

18.83%

Lines of code

1785

23.79%

Worsened metrics

Number of medium supply chain risk alerts

1

Infinity%

Number of versions

175

-1.13%

Published versions last months

14

-12.5%

Published versions last two months

34

-5.56%

Published versions last week

3

-25%

Published versions last year

123

-1.6%

Dependency changes

• + Added

  cojson-storage@0.13.32
  (transitive)

• - Removed

  cojson-storage@0.13.31
  (transitive)

• Updated

  cojson-storage@0.13.32