omit access token exchange if talking to an emulator

Author: jmwski

packages/database/src/core/PersistentConnection.ts

@@ -28,6 +28,7 @@ import { isMobileCordova, isReactNative, isNodeSdk } from '@firebase/util';
 import { ServerActions } from './ServerActions';
 import { AuthTokenProvider } from './AuthTokenProvider';
 import { RepoInfo } from './RepoInfo';
+import { FIREBASE_DATABASE_EMULATOR_HOST_VAR } from './RepoManager';
 import { Query } from '../api/Query';
 import { SDK_VERSION } from './version';
 
@@ -41,6 +42,8 @@ const SERVER_KILL_INTERRUPT_REASON = 'server_kill';
 // If auth fails repeatedly, we'll assume something is wrong and log a warning / back off.
 const INVALID_AUTH_TOKEN_THRESHOLD = 3;
 
+const FIREBASE_DATABASE_EMULATOR_HOST_VAR = 'FIREBASE_DATABASE_EMULATOR_HOST';
+
 interface ListenSpec {
   onComplete(s: string, p?: any): void;
 
@@ -740,41 +743,58 @@ export class PersistentConnection extends ServerActions {
       const forceRefresh = this.forceTokenRefresh_;
       this.forceTokenRefresh_ = false;
 
-      // First fetch auth token, and establish connection after fetching the token was successful
-      this.authTokenProvider_
-        .getToken(forceRefresh)
-        .then(function(result) {
-          if (!canceled) {
-            log('getToken() completed. Creating connection.');
-            self.authToken_ = result && result.accessToken;
-            connection = new Connection(
-              connId,
-              self.repoInfo_,
-              onDataMessage,
-              onReady,
-              onDisconnect,
-              /* onKill= */ function(reason) {
-                warn(reason + ' (' + self.repoInfo_.toString() + ')');
-                self.interrupt(SERVER_KILL_INTERRUPT_REASON);
-              },
-              lastSessionId
-            );
-          } else {
-            log('getToken() completed but was canceled');
-          }
-        })
-        .then(null, function(error) {
-          self.log_('Failed to get token: ' + error);
-          if (!canceled) {
-            if (CONSTANTS.NODE_ADMIN) {
-              // This may be a critical error for the Admin Node.js SDK, so log a warning.
-              // But getToken() may also just have temporarily failed, so we still want to
-              // continue retrying.
-              warn(error);
+      if (typeof process !== 'undefined' && process.env[FIREBASE_DATABASE_EMULATOR_HOST_VAR]) {
+        log('Connecting to a database emulator, ommitting access token requests.');
+        self.authToken_ = "owner"
+        connection = new Connection(
+          connId,
+          self.repoInfo_,
+          onDataMessage,
+          onReady,
+          onDisconnect,
+          /* onKill= */ function(reason) {
+            warn(reason + ' (' + self.repoInfo_.toString() + ')');
+            self.interrupt(SERVER_KILL_INTERRUPT_REASON);
+          },
+          lastSessionId
+        );
+      } else {
+        // First fetch auth token, and establish connection after fetching the token was successful
+        this.authTokenProvider_
+          .getToken(forceRefresh)
+          .then(function(result) {
+            if (!canceled) {
+              log('getToken() completed. Creating connection.');
+              self.authToken_ = result && result.accessToken;
+              connection = new Connection(
+                connId,
+                self.repoInfo_,
+                onDataMessage,
+                onReady,
+                onDisconnect,
+                /* onKill= */ function(reason) {
+                  warn(reason + ' (' + self.repoInfo_.toString() + ')');
+                  self.interrupt(SERVER_KILL_INTERRUPT_REASON);
+                },
+                lastSessionId
+              );
+            } else {
+              log('getToken() completed but was canceled');
             }
-            closeFn();
-          }
-        });
+          })
+          .then(null, function(error) {
+            self.log_('Failed to get token: ' + error);
+            if (!canceled) {
+              if (CONSTANTS.NODE_ADMIN) {
+                // This may be a critical error for the Admin Node.js SDK, so log a warning.
+                // But getToken() may also just have temporarily failed, so we still want to
+                // continue retrying.
+                warn(error);
+              }
+              closeFn();
+            }
+          });
+      }
     }
   }
 

packages/database/src/core/RepoManager.ts

@@ -28,15 +28,7 @@ import { RepoInfo } from './RepoInfo';
 /** @const {string} */
 const DATABASE_URL_OPTION = 'databaseURL';
 
-/**
- * This variable is also defined in the firebase node.js admin SDK. Before
- * modifying this definition, consult the definition in:
- *
- * https://github.com/firebase/firebase-admin-node
- *
- * and make sure the two are consistent.
- */
-const FIREBASE_DATABASE_EMULATOR_HOST_VAR = 'FIREBASE_DATABASE_EMULATOR_HOST';
+export const FIREBASE_DATABASE_EMULATOR_HOST_VAR = 'FIREBASE_DATABASE_EMULATOR_HOST';
 
 let _staticInstance: RepoManager;