Merge branch 'master' into timestamp

# Conflicts:
#	test/unit/utils.js

Author: dmurvihill

API.md

@@ -19,6 +19,10 @@ Only `MockFirebase` methods are included here. For details on normal Firebase AP
 - [Server Timestamps](#server-timestamps)
   - [`setClock(fn)`](#firebasesetclockfn---undefined)
   - [`restoreClock()`](#firebasesetclockfn---undefined)
+- [Messaging](#messaging)
+  - [`respondNext(methodName, result)`](#respondnextmethodname-result---undefined)
+  - [`failNext(methodName, err)`](#failnextmethodname-err---undefined)
+  - [`on(methodName, callback)`](#onmethodname-callback---undefined)
 
 ## Core
 
@@ -175,8 +179,9 @@ Authentication methods for simulating changes to the auth state of a Firebase re
 Changes the active authentication credentials to the `authData` object.
 Before changing the authentication state, `changeAuthState` checks the
 `user` object against the current authentication data.
-`onAuthStateChanged` listeners will only be triggered if the data is not
-deeply equal.
+`onIdTokenChanged` listeners will be triggered if the data is not
+deeply equal. `onAuthStateChanged` listeners will be triggered if the
+data is deeply equal but with different ID token validity.
 
 `user` should be a `MockUser` object or an object with the same fields
 as `MockUser`. To simulate no user being authenticated, pass `null` for
@@ -225,9 +230,13 @@ Finds a user previously created with [`createUser`](https://www.firebase.com/doc
 ##### `updateUser(user)` -> `Promise<MockUser>`
 
 Replace the existing user with a new one, by matching uid. Throws an
-error if no user exists whose uid matches the given user's uid. Resolves
-with the updated user when complete. This operation is queued until the
-next flush.
+error if no user exists whose uid matches the given user's uid.
+Appropriate `onAuthStateChanged` and `onIdTokenChanged` listeners will
+be triggered if the new user has the same `uid` as the current
+authenticated user.
+
+Resolves with the updated user when complete. This operation is queued
+until the next flush.
 
 ## Server Timestamps
 
@@ -242,3 +251,31 @@ Instead of using `Date.now()`, MockFirebase will call the `fn` you provide to ge
 ##### `Firebase.restoreClock()` -> `undefined`
 
 After calling `Firebase.setClock`, calling `Firebase.restoreClock` will restore the default timestamp behavior.
+
+## Messaging
+
+API reference of `MockMessaging`.
+
+##### `respondNext(methodName, result)` -> `undefined`
+
+When `methodName` is next invoked, the `Promise` (that is returned from the `methodName`) will be resolved with the specified `result`. This is useful for testing specific results of firebase messaging (e. g. partial success of sending messaging). The result will be triggered with the next `flush`.
+
+If no result is specified, `methodName` will resolve a default response.
+
+`result` must not be undefined.
+
+<hr>
+
+##### `failNext(methodName, err)` -> `undefined`
+
+When `methodName` is next invoked, the `Promise` will be rejected with the specified `err`. This is useful for simulating validation or any other errors. The error will be triggered with the next `flush`.
+
+`err` must be a proper `Error` object and not a string or any other primitive.
+
+<hr>
+
+##### `on(methodName, callback)` -> `undefined`
+
+When `methodName` is next invoked, the `callback` will be triggered. The callback gets an array as argument. The array contains all arguments, that were passed on invoking `methodName`. This is useful to assert the input arguments of `methodName`.
+
+See [docs.js](/test/unit/docs.js) for an example.

CHANGELOG.md

@@ -7,8 +7,15 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 ## [Unreleased]
 ### Added
 - Changelog
+- Mock `auth.Auth.onIdTokenChanged()` method, matching the previous
+  behavior of `onAuthStateChanged()` (see below)
+- Support for Firebase Messaging (Admin API)
 
 ### Changed
+- (Breaking) Consistent with Firebase SDK [version 4.0.0](https://firebase.google.com/support/release-notes/js#version_500_-_may_8_2018) and later,
+  and later, `onAuthStateChanged` no longer issues an event when a new
+  ID token is issued for the same user. The `onIdTokenChanged` method is
+  now mocked, keeping the previous behavior.
 - `MockStorageFile.download()` now allows omitting the destination arg;
   in that case, it simply resolves the `Promise` with the file contents
   and does not write it anywhere else.
@@ -21,6 +28,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
   one.
 - `DataSnapshot.child` now correctly splits child paths by '/'
   characters
+- Boolean values are now allowed in RTDB priority fields and as
+  arguments to `Query.startAt`, `Query.endAt`, and `Query.equalTo`.
 
 
 [Unreleased]: https://github.com/dmurvihill/firebase-mock/compare/v2.2.10...HEAD

README.md

@@ -35,6 +35,7 @@ Firebase Mock supports the client-side [JavaScript API](https://firebase.google.
 * Authentication
   * [Basic](tutorials/admin/authentication.md)
   * [JWT Tokens](tutorials/admin/tokens.md)
+* [Messaging](tutorials/admin/messaging.md)
 * [Realtime Database](tutorials/admin/rtdb.md)
 * [Firestore](tutorials/admin/firestore.md)
 * [Storage](tutorials/admin/storage.md)

package.json

@@ -12,7 +12,7 @@
   },
   "repository": {
     "type": "git",
-    "url": "git://github.com/soumak77/firebase-mock.git"
+    "url": "git://github.com/dmurvihill/firebase-mock.git"
   },
   "keywords": [
     "firebase",
@@ -21,13 +21,13 @@
   "author": "Brian Soumakian",
   "license": "MIT",
   "bugs": {
-    "url": "https://github.com/soumak77/firebase-mock/issues"
+    "url": "https://github.com/dmurvihill/firebase-mock/issues"
   },
   "files": [
     "src/",
     "browser/"
   ],
-  "homepage": "https://github.com/soumak77/firebase-mock",
+  "homepage": "https://github.com/dmurvihill/firebase-mock",
   "dependencies": {
     "firebase-auto-ids": "~1.1.0",
     "lodash.assign": "^4.2.0",

src/firebase-auth.js

@@ -9,6 +9,7 @@ function FirebaseAuth () {
   this.currentUser = null;
   this._auth = {
     listeners: [],
+    idTokenListeners: [],
     completionListeners: [],
     users: [],
     uidCounter: 1
@@ -17,10 +18,10 @@ function FirebaseAuth () {
 
 FirebaseAuth.prototype.changeAuthState = function (userData) {
   this._defer('changeAuthState', _.toArray(arguments), function() {
-    if (!_.isEqual(this.currentUser, userData)) {
-      this.currentUser = _.isObject(userData) ? userData : null;
-      this._triggerAuthEvent();
-    }
+    userData = _.isObject(userData) ? userData : null;
+    const oldUser = _.cloneDeep(this.currentUser);
+    this.currentUser = userData;
+    this._notify_state_listeners(oldUser);
   });
 };
 
@@ -47,6 +48,13 @@ FirebaseAuth.prototype.onAuthStateChanged = function (callback) {
   }
 };
 
+FirebaseAuth.prototype.onIdTokenChanged = function (callback) {
+  const currentUser = this.currentUser;
+  this._auth.idTokenListeners.push({fn: callback});
+  callback.call(null, _.cloneDeep(currentUser));
+  return () => this.offAuth(callback);
+};
+
 FirebaseAuth.prototype.getUserByEmail = function (email, onComplete) {
   var err = this._nextErr('getUserByEmail');
   var self = this;
@@ -100,6 +108,11 @@ FirebaseAuth.prototype.updateUser = function (newUser) {
         reject(new Error('Tried to update a nonexistent user'));
       } else {
         self._auth.users[i] = newUser.clone();
+        if (this.currentUser && this.currentUser.uid === newUser.uid) {
+          const oldUser = this.currentUser.clone();
+          this.currentUser = self._auth.users[i];
+          this._notify_state_listeners(oldUser);
+        }
         resolve(newUser);
       }
     });
@@ -167,15 +180,14 @@ Object.keys(signinMethods)
     FirebaseAuth.prototype[method] = function () {
       var self = this;
       var user = getUser.apply(this, arguments);
-      var promise = new Promise(function(resolve, reject) {
+      return new Promise(function(resolve, reject) {
         self._authEvent(method, function(err) {
           if (err) reject(err);
           self.currentUser = user;
           resolve(user);
           self._triggerAuthEvent();
         }, true);
       });
-      return promise;
     };
   });
 
@@ -218,6 +230,15 @@ FirebaseAuth.prototype._triggerAuthEvent = function () {
   listeners.forEach(function (parts) {
     parts.fn.call(parts.context, _.cloneDeep(user));
   });
+  this._triggerIdTokenEvent();
+};
+
+FirebaseAuth.prototype._triggerIdTokenEvent = function () {
+  var user = this.currentUser;
+  var listeners = _.cloneDeep(this._auth.idTokenListeners);
+  listeners.forEach(function (parts) {
+    parts.fn.call(parts.context, _.cloneDeep(user));
+  });
 };
 
 FirebaseAuth.prototype._getUser = function (uid) {
@@ -239,12 +260,11 @@ FirebaseAuth.prototype.onAuth = function (onComplete, context) {
 };
 
 FirebaseAuth.prototype.offAuth = function (onComplete, context) {
-  var index = _.findIndex(this._auth.listeners, function (listener) {
+  function shouldRemove(listener) {
     return listener.fn === onComplete && listener.context === context;
-  });
-  if (index > -1) {
-    this._auth.listeners.splice(index, 1);
   }
+  [this._auth.listeners, this._auth.idTokenListeners]
+    .forEach(event => _.remove(event, shouldRemove));
 };
 
 FirebaseAuth.prototype.unauth = function () {
@@ -256,7 +276,7 @@ FirebaseAuth.prototype.unauth = function () {
 
 FirebaseAuth.prototype.signOut = function () {
   var self = this, updateuser = this.currentUser !== null;
-  var promise = new Promise(function(resolve, reject) {
+  return new Promise(function(resolve, reject) {
     self._authEvent('signOut', function(err) {
       if (err) reject(err);
       self.currentUser = null;
@@ -267,7 +287,6 @@ FirebaseAuth.prototype.signOut = function () {
       }
     }, true);
   });
-  return promise;
 };
 
 FirebaseAuth.prototype.createUserWithEmailAndPassword = function (email, password) {
@@ -502,14 +521,54 @@ FirebaseAuth.prototype.setCustomUserClaims = function (uid, claims) {
   });
 };
 
+FirebaseAuth.prototype._notify_state_listeners = function (previousUser) {
+  const difference = scanDifference(previousUser, this.currentUser);
+  if (difference === 'different_user') {
+    this._triggerAuthEvent();
+  } else if(difference === 'different_token') {
+    this._triggerIdTokenEvent();
+  } else if (difference === 'same') {
+    // do nothing
+  } else {
+    throw new Error('Unexpected result from scanDifference');
+  }
+
+  function scanDifference(oldUser, newUser) {
+    if (_.isObject(oldUser)) {
+      if (_.isObject(newUser)) {
+        if (_.isEqual(oldUser, newUser)) {
+          return 'same';
+        } else {
+          return equalExceptToken(oldUser, newUser) ?
+            'different_token' : 'different_user';
+        }
+      } else {
+        return 'different_user';
+      }
+    } else {
+      return _.isObject(newUser) ? 'different_user' : 'same';
+    }
+  }
+
+  function equalExceptToken(user1, user2) {
+    const u1 = user1.clone();
+    const u2 = user2.clone();
+    delete u1._idtoken;
+    delete u1._tokenValidity;
+    delete u2._idtoken;
+    delete u2._tokenValidity;
+    return _.isEqual(u1, u2);
+  }
+};
+
 FirebaseAuth.prototype._nextUid = function () {
   return 'simplelogin:' + (this._auth.uidCounter++);
 };
 
 FirebaseAuth.prototype._validateNewUid = function (uid) {
   if (uid) {
     var user = _.find(this._auth.users, function(user) {
-      return user.uid == uid;
+      return user.uid === uid;
     });
     if (user) {
       var err = new Error('The provided uid is already in use by an existing user. Each user must have a unique uid.');
@@ -523,7 +582,7 @@ FirebaseAuth.prototype._validateNewUid = function (uid) {
 FirebaseAuth.prototype._validateExistingUid = function (uid) {
   if (uid) {
     var user = _.find(this._auth.users, function(user) {
-      return user.uid == uid;
+      return user.uid === uid;
     });
     if (!user) {
       var err = new Error('There is no existing user record corresponding to the provided identifier.');