Do @firebase/database integration

Author: jshcrowthe

packages/database/package.json

@@ -20,6 +20,7 @@
   },
   "dependencies": {
     "@firebase/database-types": "0.1.1",
+    "@firebase/logger": "0.1.0",
     "@firebase/util": "0.1.7",
     "faye-websocket": "0.11.1"
   },

packages/database/src/core/PersistentConnection.ts

@@ -935,8 +935,8 @@ export class PersistentConnection extends ServerActions {
     if (this.securityDebugCallback_) {
       this.securityDebugCallback_(body);
     } else {
-      if ('msg' in body && typeof console !== 'undefined') {
-        console.log('FIREBASE: ' + body['msg'].replace('\n', '\nFIREBASE: '));
+      if ('msg' in body) {
+        log('FIREBASE: ' + body['msg'].replace('\n', '\nFIREBASE: '));
       }
     }
   }

packages/database/src/core/Repo.ts

@@ -653,7 +653,7 @@ export class Repo {
     forEach(stats, (stat: string, value: any) => {
       // pad stat names to be the same length (plus 2 extra spaces).
       for (let i = stat.length; i < longestName + 2; i++) stat += ' ';
-      console.log(stat + value);
+      log(stat + value);
     });
   }
 

packages/database/src/core/util/util.ts

@@ -27,6 +27,9 @@ import { stringToByteArray } from '@firebase/util';
 import { stringify } from '@firebase/util';
 import { SessionStorage } from '../storage/storage';
 import { isNodeSdk } from '@firebase/util';
+import { Logger } from "@firebase/logger";
+
+const logClient = new Logger();
 
 /**
  * Returns a locally-unique ID (generated by just incrementing up from 0 each time its called).
@@ -105,16 +108,7 @@ export const enableLogging = function(
     "Can't turn on custom loggers persistently."
   );
   if (logger_ === true) {
-    if (typeof console !== 'undefined') {
-      if (typeof console.log === 'function') {
-        logger = console.log.bind(console);
-      } else if (typeof console.log === 'object') {
-        // IE does this.
-        logger = function(message) {
-          console.log(message);
-        };
-      }
-    }
+    logger = logClient.log.bind(logClient);
     if (persistent) SessionStorage.set('logging_enabled', true);
   } else if (typeof logger_ === 'function') {
     logger = logger_;
@@ -157,14 +151,8 @@ export const logWrapper = function(
  * @param {...string} var_args
  */
 export const error = function(...var_args: string[]) {
-  if (typeof console !== 'undefined') {
-    const message = 'FIREBASE INTERNAL ERROR: ' + buildLogMessage_(...var_args);
-    if (typeof console.error !== 'undefined') {
-      console.error(message);
-    } else {
-      console.log(message);
-    }
-  }
+  const message = 'FIREBASE INTERNAL ERROR: ' + buildLogMessage_(...var_args);
+  logClient.error(message);
 };
 
 /**
@@ -179,14 +167,8 @@ export const fatal = function(...var_args: string[]) {
  * @param {...*} var_args
  */
 export const warn = function(...var_args: any[]) {
-  if (typeof console !== 'undefined') {
-    const message = 'FIREBASE WARNING: ' + buildLogMessage_(...var_args);
-    if (typeof console.warn !== 'undefined') {
-      console.warn(message);
-    } else {
-      console.log(message);
-    }
-  }
+  const message = 'FIREBASE WARNING: ' + buildLogMessage_(...var_args);
+  logClient.warn(message);
 };
 
 /**