fix

Author: stevensJourney

modules/module-mongodb/src/storage/implementation/PersistedBatch.ts

@@ -74,7 +74,7 @@ export class PersistedBatch {
 
     const dchecksum = utils.hashDelete(replicaIdToSubkey(options.table.id, options.sourceKey));
 
-    for (let k of options.evaluated) {
+    for (const k of options.evaluated) {
       const key = currentBucketKey(k);
       remaining_buckets.delete(key);
 

modules/module-mongodb/src/storage/implementation/models.ts

@@ -1,6 +1,7 @@
 import { storage } from '@powersync/service-core';
 import { SqliteJsonValue } from '@powersync/service-sync-rules';
 import * as bson from 'bson';
+
 export interface SourceKey {
   /** group_id */
   g: number;

modules/module-mongodb/src/storage/implementation/util.ts

@@ -124,7 +124,7 @@ export function replicaIdEquals(a: storage.ReplicaId, b: storage.ReplicaId) {
     return a.equals(b);
   } else if (a == null && b == null) {
     return true;
-  } else if (a != null || b != null) {
+  } else if ((b == null && a != null) || (a == null && b != null)) {
     return false;
   } else {
     // There are many possible primitive values, this covers them all
@@ -156,10 +156,9 @@ export function isUUID(value: any): value is bson.UUID {
   return uuid._bsontype == 'Binary' && uuid.sub_type == bson.Binary.SUBTYPE_UUID;
 }
 
-
 /**
  * Helper function for creating a MongoDB client from consumers of this package
  */
-export const createMongoClient =(url: string, options?: mongo.MongoClientOptions) => {
+export const createMongoClient = (url: string, options?: mongo.MongoClientOptions) => {
   return new mongo.MongoClient(url, options);
-}
+};