ADD test for #2048

pubkey · Apr 13, 2020 · 791041c · 791041c
1 parent 9f4f14d
commit 791041c
Show file tree

Hide file tree

Showing 2 changed files with 36 additions and 0 deletions.
diff --git a/src/plugins/replication-graphql/index.ts b/src/plugins/replication-graphql/index.ts
@@ -62,6 +62,7 @@ Core.plugin(RxDBWatchForChangesPlugin);
 
 
 export class RxGraphQLReplicationState {
+
     constructor(
         public collection: RxCollection,
         url: string,
@@ -94,7 +95,12 @@ export class RxGraphQLReplicationState {
     };
     public _runningPromise: Promise<void> = Promise.resolve();
     public _subs: Subscription[] = [];
+
+    // counts how often the replication has run
+    // used in tests
+    public _runCount = 0;
     public _runQueueCount: number = 0;
+
     public initialReplicationComplete$: Observable<any> = undefined as any;
 
     public recieved$: Observable<any> = undefined as any;
@@ -161,6 +167,8 @@ export class RxGraphQLReplicationState {
     }
 
     async _run() {
+        this._runCount = this._runCount + 1;
+
         let willRetry = false;
 
         if (this.push) {

diff --git a/test/unit/replication-graphql.test.ts b/test/unit/replication-graphql.test.ts
@@ -2030,6 +2030,34 @@ describe('replication-graphql.test.js', () => {
                 server.close();
                 db.destroy();
             });
+            it('#2048 GraphQL .run() fires exponentially', async () => {
+                const c = await humansCollection.createHumanWithTimestamp(0);
+                const server = await SpawnServer.spawn(getTestData(1));
+
+                const replicationState = c.syncGraphQL({
+                    url: server.url,
+                    pull: {
+                        queryBuilder
+                    },
+                    live: true,
+                    deletedFlag: 'deleted'
+                });
+                assert.strictEqual(replicationState._runCount, 0);
+
+                // call run() many times
+                const amount = 100;
+                await Promise.all(
+                    new Array(amount).map(
+                        () => replicationState.run()
+                    )
+                );
+
+                await AsyncTestUtil.wait(50);
+                assert.ok(replicationState._runCount > 0);
+                assert.ok(replicationState._runCount < amount);
+
+                c.database.destroy();
+            });
         });
     });
     describe('browser', () => {