WIP

Author: maneesht

config/database.rules.json

@@ -1,6 +1,9 @@
 {
   "rules": {
     ".read": true,
-    ".write": true
+    ".write": true,
+    "testing": {
+      ".indexOn": "lease"
+    }
   }
 }

packages/database-compat/test/query.test.ts

@@ -4687,16 +4687,25 @@ describe('Query Tests', () => {
     await root
       .child('i|3')
       .set({ lease: 2, timestamp: Date.now(), action: 'test' });
-    query.on('child_added', snap => {
+    const childAdded = query.on('child_added', snap => {
       const value = snap.val();
+      console.log('onChildAdded', value);
+      if(value.timestamp && !value.lease) {
+        console.log("ERR: missing value");
+      }
       expect(value).to.haveOwnProperty('timestamp');
       expect(value).to.haveOwnProperty('action');
+      expect(value).to.haveOwnProperty('lease');
     });
-    root.child('i|1').on('value', snap => {
+    const onValue = root.child('i|1').on('value', snap => {
+      console.log('onValue', snap.val());
       //no-op
     });
     await root.child('i|1').update({ timestamp: `${Date.now()}|1` });
+    console.log('wrote value');
     await new Promise(resolve => setTimeout(resolve, 4000));
+    root.child('i|1').off('value', onValue);
+    query.off('child_added', childAdded);
   });
 
   it('Can JSON serialize refs', () => {

packages/database-compat/test/transaction.test.ts

@@ -20,7 +20,6 @@ import { _TEST_ACCESS_hijackHash as hijackHash } from '@firebase/database';
 import { Deferred } from '@firebase/util';
 import { expect } from 'chai';
 
-import { Path } from '../../database/src/core/util/Path';
 import {
   EventAccumulator,
   EventAccumulatorFactory
@@ -30,9 +29,7 @@ import { Reference } from '../src/api/Reference';
 import { eventTestHelper } from './helpers/events';
 import {
   canCreateExtraConnections,
-  getFreshRepo,
   getFreshRepoFromReference,
-  getPath,
   getRandomNode,
   getVal
 } from './helpers/util';
@@ -1533,35 +1530,4 @@ describe('Transaction Tests', () => {
     await incrementViaTransaction();
     expect(latestValue).to.equal(2);
   });
-  it.only('can send valid input with concurrent writes', async () => {
-    const rwRef = getFreshRepo(new Path('/')) as Reference;
-    const wRef = getFreshRepo(new Path('/')) as Reference;
-    async function runTransactions() {
-      while (1) {
-        console.log(getPath(rwRef));
-        await rwRef.child('abc').transaction((data: any) => {
-          console.log(data);
-          if (data) {
-            expect(!!data.test && !!data.timestamp).to.be.true;
-          }
-          return data;
-        });
-        await new Promise(resolve => setTimeout(resolve, 150));
-      }
-      console.log('done read');
-    }
-    async function runWrites() {
-      console.log(getPath(wRef));
-      while (1) {
-        await wRef.child('abc').set({
-          test: 'abc',
-          timestamp: Date.now()
-        });
-      }
-      console.log('done writing');
-    }
-    runWrites();
-    runTransactions();
-    await new Promise(resolve => setTimeout(resolve, 20000));
-  }).timeout(30000);
 });