16.0.0-beta.7

CHANGELOG.md

@@ -5,7 +5,7 @@
 
 <!-- ADD new changes here! -->
 
-### 16.0.0-beta.6 (4 December 2024)
+### 16.0.0-beta.7 (8 December 2024)
 
 🚀 **RxDB v16 is released**
 

dist/types/plugins/storage-denokv/index.d.ts

@@ -4,7 +4,7 @@ import { RxStorageInstanceDenoKV } from "./rx-storage-instance-denokv.ts";
 export declare class RxStorageDenoKV implements RxStorage<DenoKVStorageInternals<any>, DenoKVSettings> {
     settings: DenoKVSettings;
     name: string;
-    readonly rxdbVersion = "16.0.0-beta.6";
+    readonly rxdbVersion = "16.0.0-beta.7";
     constructor(settings: DenoKVSettings);
     createStorageInstance<RxDocType>(params: RxStorageInstanceCreationParams<RxDocType, DenoKVSettings>): Promise<RxStorageInstanceDenoKV<RxDocType>>;
 }

dist/types/plugins/storage-dexie/rx-storage-dexie.d.ts

@@ -4,7 +4,7 @@ import { RxStorageInstanceDexie } from './rx-storage-instance-dexie.ts';
 export declare class RxStorageDexie implements RxStorage<DexieStorageInternals, DexieSettings> {
     settings: DexieSettings;
     name: string;
-    readonly rxdbVersion = "16.0.0-beta.6";
+    readonly rxdbVersion = "16.0.0-beta.7";
     constructor(settings: DexieSettings);
     createStorageInstance<RxDocType>(params: RxStorageInstanceCreationParams<RxDocType, DexieSettings>): Promise<RxStorageInstanceDexie<RxDocType>>;
 }

dist/types/plugins/storage-mongodb/rx-storage-mongodb.d.ts

@@ -4,7 +4,7 @@ import { RxStorageInstanceMongoDB } from './rx-storage-instance-mongodb.ts';
 export declare class RxStorageMongoDB implements RxStorage<MongoDBStorageInternals, MongoDBSettings> {
     databaseSettings: MongoDBDatabaseSettings;
     name: string;
-    readonly rxdbVersion = "16.0.0-beta.6";
+    readonly rxdbVersion = "16.0.0-beta.7";
     constructor(databaseSettings: MongoDBDatabaseSettings);
     createStorageInstance<RxDocType>(params: RxStorageInstanceCreationParams<RxDocType, MongoDBSettings>): Promise<RxStorageInstanceMongoDB<RxDocType>>;
 }

dist/types/plugins/storage-remote/rx-storage-remote.d.ts

@@ -4,7 +4,7 @@ import type { MessageFromRemote, RemoteMessageChannel, RxStorageRemoteInternals,
 export declare class RxStorageRemote implements RxStorage<RxStorageRemoteInternals, any> {
     readonly settings: RxStorageRemoteSettings;
     readonly name: string;
-    readonly rxdbVersion = "16.0.0-beta.6";
+    readonly rxdbVersion = "16.0.0-beta.7";
     private seed;
     private lastRequestId;
     messageChannelIfOneMode?: Promise<RemoteMessageChannel>;

dist/types/plugins/utils/utils-rxdb-version.d.ts

@@ -1,4 +1,4 @@
 /**
  * This file is replaced in the 'npm run build:version' script.
  */
-export declare const RXDB_VERSION = "16.0.0-beta.6";
+export declare const RXDB_VERSION = "16.0.0-beta.7";

dist/types/rx-database.d.ts

@@ -1,5 +1,6 @@
 import { IdleQueue } from 'custom-idle-queue';
 import type { LeaderElector } from 'broadcast-channel';
+import { ObliviousSet } from 'oblivious-set';
 import type { CollectionsOfDatabase, RxDatabase, RxCollectionCreator, RxCollection, RxDumpDatabase, RxDumpDatabaseAny, BackupOptions, RxStorage, RxStorageInstance, RxChangeEvent, RxDatabaseCreator, RxChangeEventBulk, RxDocumentData, RxCleanupPolicy, InternalStoreDocType, InternalStoreStorageTokenDocType, RxTypeError, RxError, HashFunction, MaybePromise, RxState } from './types/index.d.ts';
 import { Subject, Subscription, Observable } from 'rxjs';
 import { WrappedRxStorageInstance } from './rx-storage-helper.ts';
@@ -28,7 +29,7 @@ export declare class RxDatabaseBase<Internals, InstanceCreationOptions, Collecti
     readonly allowSlowCount?: boolean | undefined;
     readonly reactivity?: RxReactivityFactory<any> | undefined;
     readonly idleQueue: IdleQueue;
-    readonly rxdbVersion = "16.0.0-beta.6";
+    readonly rxdbVersion = "16.0.0-beta.7";
     /**
      * Contains all known non-closed storage instances
      * that belong to this database.
@@ -88,6 +89,18 @@ export declare class RxDatabaseBase<Internals, InstanceCreationOptions, Collecti
      * We need this in some plugins.
      */
     storageTokenDocument: Promise<RxDocumentData<InternalStoreStorageTokenDocType>>;
+    /**
+     * Contains the ids of all event bulks that have been emitted
+     * by the database.
+     * Used to detect duplicates that come in again via BroadcastChannel
+     * or other streams.
+     * In the past we tried to remove this and to ensure
+     * all storages only emit the same event bulks only once
+     * but it turns out this is just not possible for all storages.
+     * JavaScript processes, workers and browser tabs can be closed and started at any time
+     * which can cause cases where it is not possible to know if an event bulk has been emitted already.
+     */
+    emittedEventBulkIds: ObliviousSet<string>;
     /**
      * This is the main handle-point for all change events
      * ChangeEvents created by this instance go:

package.json

@@ -1,7 +1,7 @@
 {
   "name": "rxdb",
   "description": "A local-first realtime NoSQL Database for JavaScript applications - https://rxdb.info/",
-  "version": "16.0.0-beta.6",
+  "version": "16.0.0-beta.7",
   "author": "pubkey",
   "repository": {
     "type": "git",
@@ -584,4 +584,4 @@
     "eslint": "9.16.0",
     "webpack-dev-server": "5.1.0"
   }
-}
+}

src/plugins/utils/utils-rxdb-version.ts

@@ -1,4 +1,4 @@
 /**
  * This file is replaced in the 'npm run build:version' script.
  */
-export const RXDB_VERSION = '16.0.0-beta.6';
+export const RXDB_VERSION = '16.0.0-beta.7';