Compat and @exp class for Database

Author: schmidt-sebastian

packages/database/.idea/runConfigurations/All_Tests.xml

@@ -20,7 +20,10 @@ import { _registerComponent, registerVersion } from '@firebase/app-exp';
 import { Component, ComponentType } from '@firebase/component';
 
 import { version } from '../package.json';
-import { FirebaseDatabase } from '../src/exp/Database';
+import {
+  FirebaseDatabase,
+  repoManagerDatabaseFromApp
+} from '../src/exp/Database';
 
 export {
   enableLogging,
@@ -79,7 +82,7 @@ function registerDatabase(): void {
       (container, { instanceIdentifier: url }) => {
         const app = container.getProvider('app-exp').getImmediate()!;
         const authProvider = container.getProvider('auth-internal');
-        return new FirebaseDatabase(app, authProvider, url);
+        return repoManagerDatabaseFromApp(app, authProvider, url);
       },
       ComponentType.PUBLIC
     ).setMultipleInstances(true)

packages/database/exp/index.ts

@@ -24,12 +24,13 @@ import { CONSTANTS, isNodeSdk } from '@firebase/util';
 import { Client } from 'faye-websocket';
 
 import { name, version } from './package.json';
-import { Database, repoManagerDatabaseFromApp } from './src/api/Database';
+import { Database } from './src/api/Database';
 import * as INTERNAL from './src/api/internal';
 import { DataSnapshot, Query, Reference } from './src/api/Reference';
 import * as TEST_ACCESS from './src/api/test_access';
 import { enableLogging } from './src/core/util/util';
 import { setSDKVersion } from './src/core/version';
+import { repoManagerDatabaseFromApp } from './src/exp/Database';
 import { setWebSocketImpl } from './src/realtime/WebSocketConnection';
 
 setWebSocketImpl(Client);
@@ -86,8 +87,10 @@ export function registerDatabase(instance: FirebaseNamespace) {
         // getImmediate for FirebaseApp will always succeed
         const app = container.getProvider('app').getImmediate();
         const authProvider = container.getProvider('auth-internal');
-
-        return repoManagerDatabaseFromApp(app, authProvider, url, undefined);
+        return new Database(
+          repoManagerDatabaseFromApp(app, authProvider, url),
+          app
+        );
       },
       ComponentType.PUBLIC
     )

packages/database/index.node.ts

@@ -24,12 +24,13 @@ import * as types from '@firebase/database-types';
 import { isNodeSdk } from '@firebase/util';
 
 import { name, version } from './package.json';
-import { Database, repoManagerDatabaseFromApp } from './src/api/Database';
+import { Database } from './src/api/Database';
 import * as INTERNAL from './src/api/internal';
 import { DataSnapshot, Query, Reference } from './src/api/Reference';
 import * as TEST_ACCESS from './src/api/test_access';
 import { enableLogging } from './src/core/util/util';
 import { setSDKVersion } from './src/core/version';
+import { repoManagerDatabaseFromApp } from './src/exp/Database';
 
 const ServerValue = Database.ServerValue;
 
@@ -46,8 +47,10 @@ export function registerDatabase(instance: FirebaseNamespace) {
         // getImmediate for FirebaseApp will always succeed
         const app = container.getProvider('app').getImmediate();
         const authProvider = container.getProvider('auth-internal');
-
-        return repoManagerDatabaseFromApp(app, authProvider, url, undefined);
+        return new Database(
+          repoManagerDatabaseFromApp(app, authProvider, url),
+          app
+        );
       },
       ComponentType.PUBLIC
     )