Merge pull request #1686 from realm/2.3.x

Release 2.3.0
2018-03-13 17:11:00 +01:00 · 2018-03-13 17:11:00 +01:00 · 0efc4fbedb
parent e53cb3c7b1 55a4224d83
commit 0efc4fbedb
32 changed files with 1558 additions and 500 deletions
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@ -1,3 +1,43 @@
 2.3.0 Release notes (2018-3-13)
 =============================================================
 ### Breaking changes
 * [Sync] Sync protocol changed to version 24.
 * [Sync] History schema format for server-side Realm files bumped to version 4. This means that after the server has been upgraded, it cannot be downgraded again without restoring state from backup.
 * [Sync] `Realm.subscribeToObjects()` has been removed. Use `Realm.Results.subscribe()` instead.
 ### Enhancements
 * [Sync] Reduced initial download times in Realms with long transaction histories.
 * [Sync] Wait for pending notifications to complete when removing a sync listener (#1648).
 * Enabled sort and distinct in the query string. If sort or distinct are also applied outside of the query string, the conditions are stacked.
  - Example syntax: `age > 20 SORT(name ASC, age DESC) DISTINCT(name)`
  - The ordering for sorting can be one of the following case insensitive literals: `ASC`, `ASCENDING`, `DESC`, `DESCENDING`.
  - Any number of properties can appear inside the brackets in a comma separated list.
  - Any number of sort/distinct conditions can be indicated, they will be applied in the specified order.
  - Sort or distinct cannot operate independently, these conditions must be attached to at least one query filter.
 * Added support for queries over named backlinks (#1498/#1660).
  - Example syntax: `parents.age > 25` and `parents.@count == 2`.
 * [Sync] Added `Realm.Results.subscribe()` to subscribe to partial synced Realms.
 * [Sync] Added class `Realm.Sync.Subscription` and enum `Realm.Sync.SubscriptionState` to support partial synced Realms.
 * [Sync] Added an object-level permission subsystem. It is possible to grant fine-grained priviliges to users.
 * Added object-level permissions:
  - Schemas `Realm.Permissions.Realm`, `Realm.Permissions.Class`, `Realm.Permissions.Role`, `Realm.Permissions.User`, and `Realm.Permissions.Permission` to support working with permissions. These schemas can be used in user-defined Realms and schemas.
  - Permissions are enforced by the object server but connectivity is not required.
  - Method `Realm.privilges()` to compute privileges on a Realm, a Realm object schema, or a Realm object. The method returns either a `Realm.Permissions.Realm` or `Realm.Permissions.Class` object.
  - For non-synced Realms, all privileges are always granted.
  - For more details, please read the reference documentation.
 * [Sync] Revoke refresh token upon logout (#1354).
 * Added `Realm.automaticSyncConfiguration()` which will return the configuration for a default synced Realm (#1688).
 * [Sync] Deprecated `Realm.Sync.setFeatureToken` (#1689).
 ### Bug fixes
 * Fixed usage of disk space preallocation which would occasionally fail on recent MacOS running with the APFS filesystem (Realm Core #3005).
 ### Internal
 * Updated to Realm Core 5.4.0.
 * Updated to Realm Sync 3.0.0.
 * Tested against Realm Object Server 3.0.0-alpha.8.
 * Added `_disablePartialSyncUrlChecks` to `Realm.Configuration`.
 2.2.15 Release notes (2018-3-9)
 =============================================================
 ### Breaking changes
@ -22,8 +62,7 @@
 * None.
 ### Bug fixes
-* [Object Server] Fixed race condition in handling of session bootstrapping in client.
+* [Sync] Fixed race condition in handling of session bootstrapping in client.
 ### Internal
 * Updated to Realm Sync 2.2.15.
@ -38,7 +77,7 @@
 * None.
 ### Bug fixes
-* [Object Server] Fixed handling of SSL certificates for the sync client.
+* [Sync] Fixed handling of SSL certificates for the sync client.
 ### Internal
 * Updated to Realm Sync 2.2.14.
@ -68,7 +107,7 @@
 * None.
 ### Bug fixes
-* [Object Server] A use-after-free bug was fixed which could cause arrays of primitives to behave unexpectedly.
+* [Sync] A use-after-free bug was fixed which could cause arrays of primitives to behave unexpectedly.
 ### Internal
 * Updated to Realm Sync 2.2.12.
@ -95,12 +134,12 @@
 * None.
 ### Enhancements
-* [Object Server] For OpenSSL, the sync client includes a fixed list of certificates in its SSL certificate verification besides the default trust store in the case where the user is not specifying its own trust certificates or callback.
+* [Sync] For OpenSSL, the sync client includes a fixed list of certificates in its SSL certificate verification besides the default trust store in the case where the user is not specifying its own trust certificates or callback.
 ### Bug fixes
 * None.
-### Internaæ
+### Internal
 * Updated to Realm Sync 2.2.10.
@ -110,11 +149,11 @@
 * None.
 ### Enhancements
-* [Object Server] Wait for pending notifications to complete when removing a sync listener (#1648).
+* [Sync] Wait for pending notifications to complete when removing a sync listener (#1648).
 * Add schema name to missing primary key error message
 ### Bug fixes
-* [Object Server] Fixed a bug causing use-after-free crashes in Global Notifier (realm-js-private #405).
+* [Sync] Fixed a bug causing use-after-free crashes in Global Notifier (realm-js-private #405).
 ### Internal
 * None.
@ -129,7 +168,7 @@
 * None.
 ### Bug fixes
-* [Object Server] Fixed a bug where arguments were not transferred when debugging.
+* [Sync] Fixed a bug where arguments were not transferred when debugging.
 ### Internal
 * None.
@ -143,7 +182,7 @@
 * None.
 ### Bug fixes
-* [Object Server] Fixed a typing error leading to `_getExistingUser` wasn't defined in the Chrome debugging support library (#1625).
+* [Sync] Fixed a typing error leading to `_getExistingUser` wasn't defined in the Chrome debugging support library (#1625).
 * Fixed a bug in the TypeScript definition of `PermissionCondition` (#1574).
 * [Electron] Fixed a `dlopen` error related to OpenSSL that prevented using realm-js on Linux (#1636).
@ -159,8 +198,8 @@
 * None.
 ### Bug fixes
-* [Object Server] Fixed a bug where errors in `refreshAdminToken` wasn't catched (#1627).
+* [Sync] Fixed a bug where errors in `refreshAdminToken` wasn't catched (#1627).
-* [Object Server] Added `_getExitingUser` to the Chrome debugging support library.
+* [Sync] Added `_getExitingUser` to the Chrome debugging support library.
 ### Internal
 * None.
@ -174,8 +213,8 @@
 * None.
 ### Bug fixes
-* [Object Server] Fixed a bug in upload progress reporting.
+* [Sync] Fixed a bug in upload progress reporting.
-* [Object Server] Fixed a bug where any errors which occurred when trying to sync the admin Realm were ignored, which made attempting to add a listener with an invalid admin user silently do nothing.
+* [Sync] Fixed a bug where any errors which occurred when trying to sync the admin Realm were ignored, which made attempting to add a listener with an invalid admin user silently do nothing.
 ### Internal
 * None.
@ -189,7 +228,7 @@
 * None.
 ### Bug fixes
-* [Object Server] Added missing `Realm.Sync` listener functions.
+* [Sync] Added missing `Realm.Sync` listener functions.
 ### Internal
 * None.
@ -204,7 +243,7 @@
 * None.
 ### Bug fixes
-* [Object Server] Fixed a bug preventing opening Realms with an admin token without a working ROS directory service (#1615).
+* [Sync] Fixed a bug preventing opening Realms with an admin token without a working ROS directory service (#1615).
 ### Internal
 * None.
@ -217,8 +256,8 @@
 ### Enhancements
 * Added new query features to support a subset of `NSPredicates` for example `LIKE` for string matches, `@count` and `@sum` in lists. See documentation for more details.
 * Potential performance enhancements in cases of many writes between queries.
-* [Object Server] Added method `Realm.Sync.User.authenticate` to unify authentication of users.
+* [Sync] Added method `Realm.Sync.User.authenticate` to unify authentication of users.
-* [Object Server] Added JWT authenfication (#1548).
+* [Sync] Added JWT authenfication (#1548).
 ### Bug fixes
 * Fix a bug where `Realm.open` could unexpectedly raise a "Realm at path ... already opened with different schema version" error.
@ -239,10 +278,10 @@
 * None.
 ### Bug fixes
-* [Object Server] Fixed a bug where long reconnection happens when a proxy in front of the sync worker returns one of those.
+* [Sync] Fixed a bug where long reconnection happens when a proxy in front of the sync worker returns one of those.
 ### Internal
-* [Object Server] Updated to Realm Object Server v2.2.0 for testing.
+* [Sync] Updated to Realm Object Server v2.2.0 for testing.
 * Updated to Realm Sync 2.1.10 (see "Bug fixes").
@ -270,11 +309,11 @@
 * None.
 ### Bug fixes
-* [Object Server] When authentication fails due to a misbehaving server, a proper error is thrown.
+* [Sync] When authentication fails due to a misbehaving server, a proper error is thrown.
 ### Internal
-* [Object Server] Strings can now be assigned to Date columns. When that happens the JavaScript Date constructor will be invoked to parse the string.
+* [Sync] Strings can now be assigned to Date columns. When that happens the JavaScript Date constructor will be invoked to parse the string.
-* [Object Server] Base64 strings can now be assigned to Data columns.
+* [Sync] Base64 strings can now be assigned to Data columns.
 2.0.12 Release notes (2017-12-1)
 =============================================================
@ -300,8 +339,8 @@
 * None
 ### Bug fixes
-* [Object Server] Fixed a bug where deleted-then-recreated objects with identical primary keys to become empty.
+* [Sync] Fixed a bug where deleted-then-recreated objects with identical primary keys to become empty.
-* [Object Server] Fixed a bug in outward partial sync is changed to ensure convergence of partial sync in the case where the client creates a primary key object, that is already present on the server, and subscribes to it in the same transaction.
+* [Sync] Fixed a bug in outward partial sync is changed to ensure convergence of partial sync in the case where the client creates a primary key object, that is already present on the server, and subscribes to it in the same transaction.
 ### Internal
 * Updated to Realm Sync 2.1.7 (see under "Bug fixes").
@ -340,10 +379,10 @@
 * None.
 ### Enhancements
-* [Object Server] Improving performance of processing large changesets.
+* [Sync] Improving performance of processing large changesets.
 ### Bug fixes
-* [Object Server] Changesets over 16MB in size are now handled correctly.
+* [Sync] Changesets over 16MB in size are now handled correctly.
 ### Internal
 * Updated to Realm Sync 2.1.6.
--- a/dependencies.list
+++ b/dependencies.list
@ -1,5 +1,5 @@
 PACKAGE_NAME=realm-js
-VERSION=2.2.15
+VERSION=2.3.0
-REALM_CORE_VERSION=5.1.2
+REALM_CORE_VERSION=5.4.0
-REALM_SYNC_VERSION=2.2.15
+REALM_SYNC_VERSION=3.0.0
-REALM_OBJECT_SERVER_VERSION=2.5.1
+REALM_OBJECT_SERVER_VERSION=3.0.0-alpha.8
--- a/docs/collection.js
+++ b/docs/collection.js
@ -134,6 +134,27 @@ class Collection {
     */
    snapshot() {}
    /**
     * Subscribe to a subset of objects matching the query of the collection. The Realm will only be
     * partially synced. Not all queries are currently supported. Once subscribed, it is highly recommended
     * to add a listener.
     *
     * @example
     * let wines = realm.objects('Wine').filtered('vintage <= $0', maxYear);
     * let subscription = wines.subscribe();
     * wines.addListener((collection, changes) => {
     *     if (subscription.state === Realm.Sync.SubscriptionState.Complete) {
     *         // update UI
     *     }
     * });
     *
     * @param {string} subscriptionName - an optional name for the subscription.
     * @returns {Realm.Sync.Subscription} - the Realm.Sync.Subscription instance.
     * @throws {Error} if the partial sync is not enabled in the configuration or the query is not supported by Realm Object Server.
     * @since 2.3.0
     */
    subscribe(subscriptionName) {}
    /**
     * @see {@link https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Array/entries Array.prototype.entries}
     * @returns {Realm.Collection~Iterator<T>} of each `[index, object]` pair in the collection
@ -400,15 +421,21 @@ class Collection {
     *   The callback function is called with two arguments:
     *   - `collection`: the collection instance that changed,
     *   - `changes`: a dictionary with keys `insertions`, `modifications` and `deletions`,
-     *      each containing a list of indices that were inserted, updated or deleted respectively.
+     *      each containing a list of indices that were inserted, updated or deleted respectively. If
     *      partial sync is enabled, an additional key `partial_sync` is added.
     *   - `changes.partial_sync`: `error` indicates if an error has occurred, `old_state` is the previous
     *      state, and `new_state` is the current state.
     * @throws {Error} If `callback` is not a function.
     * @example
     * wines.addListener((collection, changes) => {
     *  // collection === wines
     *  if (changes.partial_sync.new_state == Realm.Sync.SubscriptionState.Initialized) {
     *     console.log('Our subset is ready');
     *     console.log(`${changes.insertions.length} insertions`);
     *     console.log(`${changes.modifications.length} modifications`);
     *     console.log(`${changes.deletions.length} deletions`);
     *     console.log(`new size of collection: ${collection.length}`);
     *   }
     * });
     */
    addListener(callback) {}
--- a/docs/permission.js
+++ b/docs/permission.js
@ -229,3 +229,161 @@ class PermissionOfferResponse {
     */
    get realmUrl() {}
 }
 /**
 * A permission which can be applied to a Realm, Class, or specific Object.
 * Permissions are applied by adding the permission to the Realm.Permission singleton
 * object, the RealmClass.Permission object for the desired class, or to a user-defined
 * Realm.List<Realm.Permission> property on a specific Object instance. The meaning of each of
 * the properties of Permission depend on what the permission is applied to, and so are
 * left undocumented here.
 * @since 2.3.0
 */
 class Permission {
    /**
     * The Role which this Permission applies to. All users within the Role are
     * granted the permissions specified by the fields below any
     * objects/classes/realms which use this Permission.
     *
     * This property cannot be modified once set.
     * @type {Role}
     */
    get role() {}
    /**
     * Whether the user can read the object to which this Permission is attached.
     * @type {boolean}
     */
    get canRead() {}
    /**
     * Whether the user can modify the object to which this Permission is attached.
     * @type {boolean}
     */
    get canUpdate() {}
    /**
     * Whether the user can delete the object to which this Permission is attached.
     *
     * This property is only applicable to Permissions attached to Objects, and not
     * to Realms or Classes.
     * @type {boolean}
     */
    get canDelete() {}
    /**
     * Whether the user can add or modify Permissions for the object which this
     * Permission is attached to.
     * @type {boolean}
     */
    get canSetPermissions() {}
    /**
     *  Whether the user can subscribe to queries for this object type.
     *
     * This property is only applicable to Permissions attached to Classes, and not
     * to Realms or Objects.
     * @type {boolean}
     */
    get canQuery() {}
    /**
     * Whether the user can create new objects of the type this Permission is attached to.
     *
     * This property is only applicable to Permissions attached to Classes, and not
     * to Realms or Objects.
     * @type {boolean}
     */
    get canCreate() {}
    /**
     * Whether the user can modify the schema of the Realm which this
     * Permission is attached to.
     *
     * This property is only applicable to Permissions attached to Realms, and not
     * to Realms or Objects.
     * @type {boolean}
     */
    get canModifySchema() {}
 }
 /**
 * A representation of a sync user within the permissions system.
 *
 * User objects are created automatically for each sync user which connects to
 * a Realm, and can also be created manually if you wish to grant permissions to a user
 * which has not yet connected to this Realm.
 * @since 2.3.0
 */
 class User {
    /**
     * The unique Realm Object Server user ID string identifying this user. This will have
     * the same value as Realm.Sync.User.identity.
     * @type {string}
     */
    get id() {}
 }
 /**
 * A Role within the permissions system.
 *
 * A Role consists of a name for the role and a list of users which are members of the role.
 * Roles are granted privileges on Realms, Classes and Objects, and in turn grant those
 * privileges to all users which are members of the role.
 * A role named "everyone" is automatically created in new Realms, and all new users which
 * connect to the Realm are automatically added to it. Any other roles you wish to use are
 * managed as normal Realm objects.
 * @since 2.3.0
 */
 class Role {
    /**
     * The name of the Role.
     * @type {string}
     */
    get name() {}
    /**
     * The users which belong to the role.
     * @type {Array<Realm.Sync.Permissions.User>}
     */
    get members() {}
 }
 /**
 * An object which describes class-wide permissions.
 *
 * An instance of this object is automatically created in the Realm for class in your schema,
 * and should not be created manually.
 * @since 2.3.0
 */
 class Class {
    /**
     * The name of the class which these permissions apply to.
     * @type {string}
     */
    get class_name() {}
    /**
     * The permissions for this class.
     * @type {Array<Realm.Sync.Permissions.Permission>}
     */
    get permissions() {}
 }
 /**
 *  A singleton object which describes Realm-wide permissions.
 *
 * An object of this type is automatically created in the Realm for you, and more objects
 * cannot be created manually.
 * @since 2.3.0
 */
 class Realm {
    /**
     * The permissions for the Realm.
     * @type {Array<Realm.Sync.Permission>}
     */
    get permissions() {}
 }
--- a/docs/realm.js
+++ b/docs/realm.js
@ -119,12 +119,42 @@ class Realm {
     */
    static openAsync(config, callback, progressCallback) {}
    /**
     * Return a configuration for a default synced Realm. The server URL for the current user will be used as base for
     * the URL for the synced Realm.
     * @throws {Error} if zero or multiple users are logged in
     * @returns {Realm~Configuration} - a configuration matching a default synced Realm.
     * @since 2.3.0
     */
    static automaticSyncConfiguration() {}
    /**
     * Closes this Realm so it may be re-opened with a newer schema version.
     * All objects and collections from this Realm are no longer valid after calling this method.
     */
    close() {}
    /**
     * Returns the granted privilges.
     *
     * This combines all privileges granted on the Realm/Class/Object by all Roles which
     * the current User is a member of into the final privileges which will
     * be enforced by the server.
     *
     * The privilege calculation is done locally using cached data, and inherently may
     * be stale. It is possible that this method may indicate that an operation is
     * permitted but the server will still reject it if permission is revoked before
     * the changes have been integrated on the server.
     *
     * Non-synchronized Realms always have permission to perform all operations.
     *
     * @param {(Realm~ObjectType|Realm.Object)} arg - the object type or the object to compute priviliges from
     * @returns {Object} as the computed priviliges as properties
     * @since 2.3.0
     * @see {Realm.Permissions} for details of priviliges and roles.
     */
    privileges(arg) {}
    /**
     * Create a new Realm object of the given type and with the specified properties.
     * @param {Realm~ObjectType} type - The type of Realm object to create.
@ -241,17 +271,6 @@ class Realm {
     * @returns {true} if compaction succeeds.
     */
    compact() {}
    /**
     * If the Realm is a partially synchronized Realm, fetch and synchronize the objects
     * of a given object type that match the given query (in string format).
     *
     * **Partial synchronization is a tech preview. Its APIs are subject to change.**
     * @param {Realm~ObjectType} type - The type of Realm objects to retrieve.
     * @param {string} query - Query used to filter objects.
     * @return {Promise} - a promise that will be resolved with the Realm.Results instance when it's available.
     */
    subscribeToObjects(className, query, callback) {}
 }
 /**
--- a/docs/sync.js
+++ b/docs/sync.js
@ -468,6 +468,64 @@ class Session {
    removeProgressNotification(progressCallback) {}
 }
 /**
 * An object encapsulating partial sync subscriptions.
 * @memberof Realm.Sync
 */
 class Subscription {
    /**
     * Gets the current state of the subscription.
     * Can be either:
     *  - Realm.Sync.SubscriptionState.Error: An error occurred while creating or processing the partial sync subscription.
     *  - Realm.Sync.SubscriptionState.Creating: The subscription is being created.
     *  - Realm.Sync.SubscriptionState.Pending: The subscription was created, but has not yet been processed by the sync server.
     *  - Realm.Sync.SubscriptionState.Complete: The subscription has been processed by the sync server and data is being synced to the device.
     *  - Realm.Sync.SubscriptionState.Invalidated: The subscription has been removed.
     * @type {number}
     */
    get state() {}
    /**
     * Gets the error message. `undefined` if no error.
     * @type {string}
     */
    get error() {}
    /**
     * Unsubscribe a partial synced `Realm.Results`. The state will change to `Realm.Sync.SubscriptionState.Invalidated`.
     * The `Realm.Results` will not produce any meaningful values. Moreover, any objects matching the query will be
     * removed if they are not matched by any other query. The object removal is done asynchronously.
     */
    unsubscribe() {}
    /**
     * Adds a listener `callback` which will be called when the state of the subscription changes.
     * @param {function(subscription, state)} callback - A function to be called when changes to the subscription occur.
     * @throws {Error} If `callback` is not a function.
     * @example
     * let subscription = results.subscribe();
     * subscription.addListener((subscription, state) => {
     *     switch (state) {
     *     case Realm.Sync.SubscriptionState.Complete:
     *         // results is ready to be consumed
     *         break;
     *     case Realm.Sync.SubscriptionState.Error:
     *         console.log('An error occurred: ', subscription.error);
     *         break;
     *     }
     * }
     */
     addListener(callback) {}
    /**
     * Remove the listener `callback` from the subscription instance.
     * @param {function(subscription, state)} callback - Callback function that was previously
     *   added as a listener through the {@link Subscription#addListener addListener} method.
     * @throws {Error} If `callback` is not a function.
     */
    removeListener(callback) {}
 }
 /**
 * A Realm Worker can be used to process Sync events in multiple automatically-managed child processes.
 *
--- a/examples/ReactExample/android/app/src/main/java/io/realm/react/example/MainApplication.java
+++ b/examples/ReactExample/android/app/src/main/java/io/realm/react/example/MainApplication.java
@ -20,7 +20,7 @@ public class MainApplication extends Application implements ReactApplication {
  private final ReactNativeHost mReactNativeHost = new ReactNativeHost(this) {
    @Override
-    protected boolean getUseDeveloperSupport() {
+    public boolean getUseDeveloperSupport() {
      return BuildConfig.DEBUG;
    }
--- a/lib/browser/constants.js
+++ b/lib/browser/constants.js
@ -41,6 +41,7 @@ export const propTypes = {};
    'RESULTS',
    'USER',
    'SESSION',
    'SUBSCRIPTION',
    'UNDEFINED',
 ].forEach(function(type) {
    Object.defineProperty(objectTypes, type, {
--- a/lib/browser/index.js
+++ b/lib/browser/index.js
@ -130,7 +130,6 @@ util.createMethods(Realm.prototype, objectTypes.REALM, [
    'close',
    '_waitForDownload',
    '_objectForObjectId',
    '_subscribeToObjects',
 ]);
 // Mutating methods:
@ -147,7 +146,8 @@ util.createMethods(Realm.prototype, objectTypes.REALM, [
 const Sync = {
    User,
-    Session
+    Session,
    Subscription,
 };
 Object.defineProperties(Realm, {
--- a/lib/browser/results.js
+++ b/lib/browser/results.js
@ -30,6 +30,7 @@ createMethods(Results.prototype, objectTypes.RESULTS, [
    'filtered',
    'sorted',
    'snapshot',
    'subscribe',
    'isValid',
    'indexOf',
    'min',
--- a/lib/browser/subscription.js
+++ b/lib/browser/subscription.js
@ -0,0 +1,38 @@
 ////////////////////////////////////////////////////////////////////////////
 //
 // Copyright 2018 Realm Inc.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
 // You may obtain a copy of the License at
 //
 // http://www.apache.org/licenses/LICENSE-2.0
 //
 // Unless required by applicable law or agreed to in writing, software
 // distributed under the License is distributed on an "AS IS" BASIS,
 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 // See the License for the specific language governing permissions and
 // limitations under the License.
 //
 ////////////////////////////////////////////////////////////////////////////
 'use strict';
 import { objectTypes } from './constants';
 import { getterForProperty, createMethods } from './util';
 export default class Subscription {
 }
 Object.defineProperties(Subscription.prototype, {
    error: { get: getterForProperty('error') },
    state: { get: getterForProperty('state') }
 });
 // // Non-mutating methods:
 createMethods(Subscription.prototype, objectTypes.SUBSCRIPTION, [
    'unsubscribe',
    'addListener',
    'removeListener'
 ]);
--- a/lib/extensions.js
+++ b/lib/extensions.js
@ -18,6 +18,8 @@
 'use strict';
 const URL = require('url-parse');
 let getOwnPropertyDescriptors = Object.getOwnPropertyDescriptors || function(obj) {
    return Object.getOwnPropertyNames(obj).reduce(function (descriptors, name) {
        descriptors[name] = Object.getOwnPropertyDescriptor(obj, name);
@ -149,29 +151,105 @@ module.exports = function(realmConstructor) {
        setConstructorOnPrototype(realmConstructor.Sync.User);
        setConstructorOnPrototype(realmConstructor.Sync.Session);
        // A configuration for a default Realm
        realmConstructor.automaticSyncConfiguration = function() {
            let users = this.Sync.User.all;
            let identities = Object.keys(users);
            if (identities.length === 1) {
                let user = users[identities[0]];
                let url = new URL(user.server);
                let secure = (url.protocol === 'https:')?'s':'';
                let port = (url.port === undefined)?'9080':url.port
                let realmUrl = `realm${secure}://${url.hostname}:${port}/~/default`;
                let config = {
                    sync: {
                        user,
                        url: realmUrl
                    }
                };
                return config;
            }
            new Error(`One and only one user should be logged in but found ${users.length} users.`);
        }
        if (realmConstructor.Sync._setFeatureToken) {
            realmConstructor.Sync.setFeatureToken = function(featureToken) {
-                if (typeof featureToken !== 'string' && !(featureToken instanceof String)) {
+                console.log('Realm.Sync.setFeatureToken() is deprecated and you can remove any calls to it.');
                    throw new Error("featureToken should be a string");
                }
                realmConstructor.Sync._setFeatureToken(featureToken.trim());
            }
        }
-        realmConstructor.prototype.subscribeToObjects = function(objectType, query) {
+        // Keep these value in sync with subscription_state.hpp
-            const realm = this;
+        realmConstructor.Sync.SubscriptionState = {
-            let promise = new Promise((resolve, reject) => {
+            Error: -1,      // An error occurred while creating or processing the partial sync subscription.
-                realm._subscribeToObjects(objectType, query, function(err, results) {
+            Creating: 2,    // The subscription is being created.
-                    if (err) {
+            Pending: 0,     // The subscription was created, but has not yet been processed by the sync server.
-                        reject(err);
+            Complete: 1,    // The subscription has been processed by the sync server and data is being synced to the device.
-                    } else {
+            Invalidated: 3, // The subscription has been removed.
                        resolve(results);
                    }
                });
            });
            return promise;
        };
        // Define the permission schemas as constructors so that they can be
        // passed into directly to functions which want object type names
        const permissionsSchema = Object.freeze({
            Class: function() {},
            Permission: function() {},
            Realm: function() {},
            Role: function() {},
            User: function() {},
        });
        permissionsSchema.Permission.schema = Object.freeze({
            name: '__Permission',
            properties: {
                role: '__Role',
                canRead: {type: 'bool', default: false},
                canUpdate: {type: 'bool', default: false},
                canDelete: {type: 'bool', default: false},
                canSetPermissions: {type: 'bool', default: false},
                canQuery: {type: 'bool', default: false},
                canCreate: {type: 'bool', default: false},
                canModifySchema: {type: 'bool', default: false},
            }
        });
        permissionsSchema.User.schema = Object.freeze({
            name: '__User',
            primaryKey: 'id',
            properties: {
                id: 'string',
                role: '__Role'
            }
        });
        permissionsSchema.Role.schema = Object.freeze({
            name: '__Role',
            primaryKey: 'name',
            properties: {
                name: 'string',
                members: '__User[]'
            }
        });
        permissionsSchema.Class.schema = Object.freeze({
            name: '__Class',
            primaryKey: 'class_name',
            properties: {
                class_name: 'string',
                permissions: '__Permission[]'
            }
        });
        permissionsSchema.Realm.schema = Object.freeze({
            name: '__Realm',
            primaryKey: 'id',
            properties: {
                id: 'int',
                permissions: '__Permission[]'
            }
        });
        Object.defineProperty(realmConstructor, 'Permissions', {
            value: permissionsSchema,
            configurable: false
        });
    }
    // TODO: Remove this now useless object.
--- a/lib/index.d.ts
+++ b/lib/index.d.ts
@ -81,7 +81,7 @@ declare namespace Realm {
        path?: string;
        readOnly?: boolean;
        inMemory?: boolean;
-        schema?: ObjectClass[] | ObjectSchema[];
+        schema?: (ObjectClass | ObjectSchema)[];
        schemaVersion?: number;
        sync?: Realm.Sync.SyncConfiguration;
        deleteRealmIfMigrationNeeded?: boolean;
@ -161,6 +161,11 @@ declare namespace Realm {
        sorted(descriptor: SortDescriptor[]): Results<T>;
        sorted(descriptor: string, reverse?: boolean): Results<T>;
        /**
         * @returns Results<T>
         */
        subscribe(subscriptionName?: string): Realm.Sync.Subscription;
        /**
         * @returns Results
         */
@ -374,6 +379,7 @@ declare namespace Realm.Sync {
        open_ssl_verify_callback?: SSLVerifyCallback;
        error?: ErrorCallback;
        partial?: boolean;
        _disablePartialSyncUrlChecks?:boolean;
    }
    type ProgressNotificationCallback = (transferred: number, transferable: number) => void;
@ -394,6 +400,29 @@ declare namespace Realm.Sync {
        removeProgressNotification(progressCallback: ProgressNotificationCallback): void;
    }
    type SubscriptionNotificationCallback = (subscription: Subscription, state: number) => void;
    /**
     * Subscription
     * @see { @link https://realm.io/docs/javascript/latest/api/Realm.Sync.Subscription.html }
     */
    class Subscription {
        readonly state: SubscriptionState;
        readonly error: string;
        unsubscribe(): void;
        addListener(subscruptionCallback: SubscriptionNotificationCallback): void;
        removeListener(subscruptionCallback: SubscriptionNotificationCallback): void;
    }
    enum SubscriptionState {
         Error,
         Creating,
         Pending,
         Complete,
         Invalidated,
    }
    /**
    * AuthError
    * @see { @link https://realm.io/docs/javascript/latest/api/Realm.Sync.AuthError.html }
@ -420,6 +449,10 @@ declare namespace Realm.Sync {
    function removeListener(regex: string, name: string, changeCallback: (changeEvent: ChangeEvent) => void): Promise<void>;
    function setLogLevel(logLevel: 'all' | 'trace' | 'debug' | 'detail' | 'info' | 'warn' | 'error' | 'fatal' | 'off'): void;
    function initiateClientReset(path: string): void;
    /**
     * @deprecated, to be removed in future versions
     */
    function setFeatureToken(token: string): void;
    type Instruction = {
@ -455,6 +488,42 @@ declare namespace Realm.Sync {
    }
 }
 declare namespace Realm.Permissions {
    class Permission {
        static schema: ObjectSchema;
        identity: string;
        canRead: boolean;
        canUpdate: boolean;
        canDelete: boolean;
        canSetPermissions: boolean;
        canQuery: boolean;
        canCreate: boolean;
        canModifySchema: boolean;
    }
    class User {
        static schema: ObjectSchema;
        identity: string;
    }
    class Role {
        static schema: ObjectSchema;
        name: string;
        members: User[];
    }
    class Class {
        static schema: ObjectSchema;
        class_name: string;
        permissions: Permission[];
    }
    class Realm {
        static schema: ObjectSchema;
        permissions: Permission[];
    }
 }
 interface ProgressPromise extends Promise<Realm> {
    progress(callback: Realm.Sync.ProgressNotificationCallback): Promise<Realm>
@ -497,11 +566,16 @@ declare class Realm {
     */
    static openAsync(config: Realm.Configuration, callback: (error: any, realm: Realm) => void, progressCallback?: Realm.Sync.ProgressNotificationCallback): void
    /**
     * Return a configuration for a default Realm.
     */
    static automaticSyncConfiguration(): string;
    /**
     * Delete the Realm file for the given configuration.
     * @param {Configuration} config
     */
-    static deleteFile(config: Realm.Configuration): void
+    static deleteFile(config: Realm.Configuration): void;
    /**
     * @param  {Realm.Configuration} config?
@ -524,7 +598,7 @@ declare class Realm {
     * @param  {boolean} update?
     * @returns T
     */
-    create<T>(type: string | Realm.ObjectClass | Function, properties: T & Realm.ObjectPropsType, update?: boolean): T;
+    create<T>(type: string | Realm.ObjectClass | Function, properties: T | Realm.ObjectPropsType, update?: boolean): T;
    /**
     * @param  {Realm.Object|Realm.Object[]|Realm.List<any>|Realm.Results<any>|any} object
@ -601,10 +675,9 @@ declare class Realm {
     */
    compact(): boolean;
-    /**
+    privileges() : Realm.Permissions.Realm;
-     * @returns Promise<Results<T>>
+    privileges(objectType: string | Realm.ObjectSchema | Function) : Realm.Permissions.Class;
-     */
+    privileges(obj: Realm.Object) : Realm.Permissions.Class;
    subscribeToObjects<T>(objectType: string, query: string): Promise<Realm.Results<T>>;
 }
 declare module 'realm' {
--- a/lib/user-methods.js
+++ b/lib/user-methods.js
@ -348,6 +348,27 @@ const staticMethods = {
 const instanceMethods = {
    logout() {
        this._logout();
        const url = url_parse(this.server);
        url.set('pathname', '/auth/revoke');
        const headers = {
            Authorization: this.token
        };
        const body = {
            token: this.token
        };
        const options = {
            method: 'POST',
            headers,
            body: body,
            open_timeout: 5000
        };
        performFetch(url.href, options)
            .then(() => console.log('User is logged out'))
            .catch((e) => print_error(e));
    },
        openManagementRealm() {
            let url = url_parse(this.server);
            if (url.protocol === 'http:') {
--- a/package.json
+++ b/package.json
@ -1,7 +1,7 @@
 {
  "name": "realm",
  "description": "Realm is a mobile database: an alternative to SQLite and key-value stores",
-  "version": "2.2.15",
+  "version": "2.3.0",
  "license": "Apache-2.0",
  "homepage": "https://realm.io",
  "keywords": [
@ -90,7 +90,7 @@
    "request": "^2.78.0",
    "stream-counter": "^1.0.0",
    "sync-request": "^3.0.1",
-    "url-parse": "^1.1.7"
+    "url-parse": "^1.2.0"
  },
  "devDependencies": {
    "@types/node": "^4.0.35",
--- a/react-native/android/src/main/jni/Android.mk
+++ b/react-native/android/src/main/jni/Android.mk
@ -78,6 +78,7 @@ LOCAL_SRC_FILES += src/object-store/src/sync/sync_user.cpp
 LOCAL_SRC_FILES += src/object-store/src/sync/sync_permission.cpp
 LOCAL_SRC_FILES += src/object-store/src/sync/impl/sync_file.cpp
 LOCAL_SRC_FILES += src/object-store/src/sync/impl/sync_metadata.cpp
 LOCAL_SRC_FILES += src/object-store/src/sync/impl/work_queue.cpp
 endif
 LOCAL_C_INCLUDES := src
--- a/realm.gypi
+++ b/realm.gypi
@ -99,6 +99,7 @@
        "src/object-store/src/sync/impl/sync_client.hpp",
        "src/object-store/src/sync/impl/sync_file.hpp",
        "src/object-store/src/sync/impl/sync_metadata.hpp",
        "src/object-store/src/sync/impl/work_queue.hpp",
        "src/object-store/src/sync/partial_sync.hpp",
        "src/object-store/src/sync/sync_config.hpp",
        "src/object-store/src/sync/sync_manager.hpp",
@ -147,7 +148,8 @@
            "src/object-store/src/sync/sync_session.cpp",
            "src/object-store/src/sync/sync_config.cpp",
            "src/object-store/src/sync/impl/sync_file.cpp",
-            "src/object-store/src/sync/impl/sync_metadata.cpp"
+            "src/object-store/src/sync/impl/sync_metadata.cpp",
            "src/object-store/src/sync/impl/work_queue.cpp"
          ],
        }]
      ],
--- a/src/RealmJS.xcodeproj/project.pbxproj
+++ b/src/RealmJS.xcodeproj/project.pbxproj
@ -41,6 +41,8 @@
 		3FCE2A931F58BE0300D4855B /* uuid.cpp in Sources */ = {isa = PBXBuildFile; fileRef = 3FCE2A911F58BDFF00D4855B /* uuid.cpp */; };
 		3FCE2A971F58BE2200D4855B /* sync_permission.cpp in Sources */ = {isa = PBXBuildFile; fileRef = 3FCE2A951F58BE1D00D4855B /* sync_permission.cpp */; };
 		420FB79F1F7FBFE900D43D0F /* partial_sync.cpp in Sources */ = {isa = PBXBuildFile; fileRef = 423737AF1F7E333400FAEDFF /* partial_sync.cpp */; };
 		425A121120235A1400C2F932 /* work_queue.cpp in Sources */ = {isa = PBXBuildFile; fileRef = 425A120F20235A1400C2F932 /* work_queue.cpp */; };
 		4261AF8E203C42000052450D /* work_queue.cpp in Sources */ = {isa = PBXBuildFile; fileRef = 425A120F20235A1400C2F932 /* work_queue.cpp */; };
 		502B07E41E2CD201007A84ED /* object.cpp in Sources */ = {isa = PBXBuildFile; fileRef = 502B07E31E2CD1FA007A84ED /* object.cpp */; };
 		504CF85E1EBCAE3600A9A4B6 /* network_reachability_observer.cpp in Sources */ = {isa = PBXBuildFile; fileRef = 504CF8541EBCAE3600A9A4B6 /* network_reachability_observer.cpp */; };
 		504CF85F1EBCAE3600A9A4B6 /* system_configuration.cpp in Sources */ = {isa = PBXBuildFile; fileRef = 504CF8561EBCAE3600A9A4B6 /* system_configuration.cpp */; };
@ -185,6 +187,8 @@
 		3FCE2A991F58BE3600D4855B /* feature_checks.hpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.h; name = feature_checks.hpp; path = "object-store/src/feature_checks.hpp"; sourceTree = SOURCE_ROOT; };
 		423737AF1F7E333400FAEDFF /* partial_sync.cpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.cpp; name = partial_sync.cpp; path = src/sync/partial_sync.cpp; sourceTree = "<group>"; };
 		423737B01F7E333400FAEDFF /* partial_sync.hpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.h; name = partial_sync.hpp; path = src/sync/partial_sync.hpp; sourceTree = "<group>"; };
 		425A120F20235A1400C2F932 /* work_queue.cpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.cpp; path = work_queue.cpp; sourceTree = "<group>"; };
 		425A121020235A1400C2F932 /* work_queue.hpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.h; path = work_queue.hpp; sourceTree = "<group>"; };
 		426FCDFF1F7DA2F9005565DC /* sync_config.cpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.cpp; name = sync_config.cpp; path = src/sync/sync_config.cpp; sourceTree = "<group>"; };
 		502B07E31E2CD1FA007A84ED /* object.cpp */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.cpp.cpp; name = object.cpp; path = src/object.cpp; sourceTree = "<group>"; };
 		502B07E51E2CD20D007A84ED /* object.hpp */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.cpp.h; name = object.hpp; path = src/object.hpp; sourceTree = "<group>"; };
@ -474,6 +478,8 @@
 		504CF8521EBCAE3600A9A4B6 /* impl */ = {
 			isa = PBXGroup;
 			children = (
 				425A120F20235A1400C2F932 /* work_queue.cpp */,
 				425A121020235A1400C2F932 /* work_queue.hpp */,
 				504CF8531EBCAE3600A9A4B6 /* apple */,
 				504CF8581EBCAE3600A9A4B6 /* network_reachability.hpp */,
 				504CF8591EBCAE3600A9A4B6 /* sync_client.hpp */,
@ -873,6 +879,7 @@
 			isa = PBXSourcesBuildPhase;
 			buildActionMask = 2147483647;
 			files = (
 				4261AF8E203C42000052450D /* work_queue.cpp in Sources */,
 				F63FF2E21C15921A00B3B8E0 /* base64.cpp in Sources */,
 				022BF1021E7266DF00F382F1 /* binding_callback_thread_observer.cpp in Sources */,
 				02414BA51CE6ABCF00A8669F /* collection_change_builder.cpp in Sources */,
@ -934,6 +941,7 @@
 				F63FF31E1C1642BB00B3B8E0 /* GCDWebServerRequest.m in Sources */,
 				F63FF31F1C1642BB00B3B8E0 /* GCDWebServerResponse.m in Sources */,
 				F63FF3271C1642BB00B3B8E0 /* GCDWebServerStreamedResponse.m in Sources */,
 				425A121120235A1400C2F932 /* work_queue.cpp in Sources */,
 				F63FF3231C1642BB00B3B8E0 /* GCDWebServerURLEncodedFormRequest.m in Sources */,
 			);
 			runOnlyForDeploymentPostprocessing = 0;
@ -961,7 +969,7 @@
 				CLANG_WARN__DUPLICATE_METHOD_MATCH = YES;
 				"CODE_SIGN_IDENTITY[sdk=iphoneos*]" = "iPhone Developer";
 				COPY_PHASE_STRIP = NO;
-				CURRENT_PROJECT_VERSION = 2.2.15;
+				CURRENT_PROJECT_VERSION = 2.3.0;
 				CXX = "$(SRCROOT)/../scripts/ccache-clang++.sh";
 				DEBUG_INFORMATION_FORMAT = "dwarf-with-dsym";
 				ENABLE_STRICT_OBJC_MSGSEND = YES;
@ -1025,7 +1033,7 @@
 				CLANG_WARN__DUPLICATE_METHOD_MATCH = YES;
 				"CODE_SIGN_IDENTITY[sdk=iphoneos*]" = "iPhone Developer";
 				COPY_PHASE_STRIP = NO;
-				CURRENT_PROJECT_VERSION = 2.2.15;
+				CURRENT_PROJECT_VERSION = 2.3.0;
 				CXX = "$(SRCROOT)/../scripts/ccache-clang++.sh";
 				DEBUG_INFORMATION_FORMAT = "dwarf-with-dsym";
 				ENABLE_NS_ASSERTIONS = NO;
@ -1115,10 +1123,7 @@
 					"-isystem",
 					"$(SRCROOT)/../vendor/sync/include",
 				);
-				OTHER_LIBTOOLFLAGS = (
+				OTHER_LIBTOOLFLAGS = "$(SRCROOT)/../vendor/realm-ios/librealm-parser-ios-dbg.a $(SRCROOT)/../vendor/realm-ios/librealm-ios-dbg.a";
                    "$(SRCROOT)/../vendor/realm-ios/librealm-parser-ios-dbg.a",
                    "$(SRCROOT)/../vendor/realm-ios/librealm-ios-dbg.a",
                );
 				PRODUCT_NAME = RealmJS;
 				SKIP_INSTALL = YES;
 			};
@ -1140,10 +1145,7 @@
 					"-isystem",
 					"$(SRCROOT)/../vendor/sync/include",
 				);
-				OTHER_LIBTOOLFLAGS = (
+				OTHER_LIBTOOLFLAGS = "$(SRCROOT)/../vendor/realm-ios/librealm-parser-ios.a $(SRCROOT)/../vendor/realm-ios/librealm-ios.a";
                    "$(SRCROOT)/../vendor/realm-ios/librealm-parser-ios.a",
                    "$(SRCROOT)/../vendor/realm-ios/librealm-ios.a",
                );
 				PRODUCT_NAME = RealmJS;
 				SKIP_INSTALL = YES;
 			};
--- a/src/js_collection.hpp
+++ b/src/js_collection.hpp
@ -23,6 +23,9 @@
 #include "js_observable.hpp"
 #include "collection_notifications.hpp"
 #if REALM_ENABLE_SYNC
 #include "sync/subscription_state.hpp"
 #endif
 namespace realm {
 namespace js {
--- a/src/js_realm.hpp
+++ b/src/js_realm.hpp
@ -35,7 +35,6 @@
 #include "js_sync.hpp"
 #include "sync/sync_config.hpp"
 #include "sync/sync_manager.hpp"
 #include "sync/partial_sync.hpp"
 #endif
 #include "shared_realm.hpp"
@ -186,9 +185,7 @@ public:
    static void compact(ContextType, ObjectType, Arguments, ReturnValue &);
    static void delete_model(ContextType, ObjectType, Arguments, ReturnValue &);
    static void object_for_object_id(ContextType, ObjectType, Arguments, ReturnValue&);
-#if REALM_ENABLE_SYNC
+    static void privileges(ContextType, ObjectType, Arguments, ReturnValue&);
    static void subscribe_to_objects(ContextType, ObjectType, Arguments, ReturnValue &);
 #endif
    // properties
    static void get_empty(ContextType, ObjectType, ReturnValue &);
@ -245,10 +242,10 @@ public:
        {"close", wrap<close>},
        {"compact", wrap<compact>},
        {"deleteModel", wrap<delete_model>},
        {"privileges", wrap<privileges>},
        {"_objectForObjectId", wrap<object_for_object_id>},
 #if REALM_ENABLE_SYNC
        {"_waitForDownload", wrap<wait_for_download_completion>},
        {"_subscribeToObjects", wrap<subscribe_to_objects>},
 #endif
    };
@ -295,7 +292,8 @@ public:
        return name;
    }
-    static const ObjectSchema& validated_object_schema_for_value(ContextType ctx, const SharedRealm &realm, const ValueType &value, std::string& object_type) {
+    static const ObjectSchema& validated_object_schema_for_value(ContextType ctx, const SharedRealm &realm, const ValueType &value) {
        std::string object_type;
        if (Value::is_constructor(ctx, value)) {
            FunctionType constructor = Value::to_constructor(ctx, value);
@ -555,9 +553,6 @@ SharedRealm RealmClass<T>::create_shared_realm(ContextType ctx, realm::Realm::Co
    catch (const RealmFileException& ex) {
        handleRealmFileException(ctx, config, ex);
    }
    catch (...) {
        throw;
    }
    GlobalContextType global_context = Context<T>::get_global_context(ctx);
    if (!realm->m_binding_context) {
@ -794,10 +789,8 @@ void RealmClass<T>::objects(ContextType ctx, ObjectType this_object, Arguments a
    args.validate_maximum(1);
    SharedRealm realm = *get_internal<T, RealmClass<T>>(this_object);
-    std::string object_type;
+    auto& object_schema = validated_object_schema_for_value(ctx, realm, args[0]);
-    validated_object_schema_for_value(ctx, realm, args[0], object_type);
+    return_value.set(ResultsClass<T>::create_instance(ctx, realm, object_schema.name));
    return_value.set(ResultsClass<T>::create_instance(ctx, realm, object_type));
 }
 template<typename T>
@ -806,7 +799,7 @@ void RealmClass<T>::object_for_primary_key(ContextType ctx, ObjectType this_obje
    SharedRealm realm = *get_internal<T, RealmClass<T>>(this_object);
    std::string object_type;
-    auto &object_schema = validated_object_schema_for_value(ctx, realm, args[0], object_type);
+    auto &object_schema = validated_object_schema_for_value(ctx, realm, args[0]);
    NativeAccessor accessor(ctx, realm, object_schema);
    auto realm_object = realm::Object::get_for_primary_key(accessor, realm, object_schema, args[1]);
@ -824,8 +817,7 @@ void RealmClass<T>::create(ContextType ctx, ObjectType this_object, Arguments ar
    SharedRealm realm = *get_internal<T, RealmClass<T>>(this_object);
    realm->verify_open();
-    std::string object_type;
+    auto &object_schema = validated_object_schema_for_value(ctx, realm, args[0]);
    auto &object_schema = validated_object_schema_for_value(ctx, realm, args[0], object_type);
    ObjectType object = Value::validated_to_object(ctx, args[1], "properties");
    if (Value::is_array(ctx, args[1])) {
@ -902,7 +894,13 @@ void RealmClass<T>::delete_all(ContextType ctx, ObjectType this_object, Argument
    }
    for (auto objectSchema : realm->schema()) {
-        ObjectStore::table_for_object_type(realm->read_group(), objectSchema.name)->clear();
+        auto table = ObjectStore::table_for_object_type(realm->read_group(), objectSchema.name);
        if (realm->is_partial()) {
            realm::Results(realm, *table).clear();
        }
        else {
            table->clear();
        }
    }
 }
@ -1006,36 +1004,6 @@ void RealmClass<T>::compact(ContextType ctx, ObjectType this_object, Arguments a
    return_value.set(realm->compact());
 }
 #if REALM_ENABLE_SYNC
 namespace {
 // FIXME: Sync should provide this: https://github.com/realm/realm-sync/issues/1796
 inline sync::ObjectID object_id_from_string(std::string const& string)
 {
    if (string.front() != '{' || string.back() != '}')
        throw std::invalid_argument("Invalid object ID.");
    size_t dash_index = string.find('-');
    if (dash_index == std::string::npos)
        throw std::invalid_argument("Invalid object ID.");
    std::string high_string = string.substr(1, dash_index - 1);
    std::string low_string = string.substr(dash_index + 1, string.size() - dash_index - 2);
    if (high_string.size() == 0 || high_string.size() > 16 || low_string.size() == 0 || low_string.size() > 16)
        throw std::invalid_argument("Invalid object ID.");
    auto isxdigit = static_cast<int(*)(int)>(std::isxdigit);
    if (!std::all_of(high_string.begin(), high_string.end(), isxdigit) ||
        !std::all_of(low_string.begin(), low_string.end(), isxdigit)) {
        throw std::invalid_argument("Invalid object ID.");
    }
    return sync::ObjectID(strtoull(high_string.c_str(), nullptr, 16), strtoull(low_string.c_str(), nullptr, 16));
 }
 } // unnamed namespace
 #endif // REALM_ENABLE_SYNC
 template<typename T>
 void RealmClass<T>::object_for_object_id(ContextType ctx, ObjectType this_object, Arguments args, ReturnValue& return_value) {
    args.validate_count(2);
@ -1045,67 +1013,67 @@ void RealmClass<T>::object_for_object_id(ContextType ctx, ObjectType this_object
    if (!sync::has_object_ids(realm->read_group()))
        throw std::logic_error("Realm._objectForObjectId() can only be used with synced Realms.");
-    std::string object_type = Value::validated_to_string(ctx, args[0]);
+    auto& object_schema = validated_object_schema_for_value(ctx, realm, args[0]);
    validated_object_schema_for_value(ctx, realm, args[0], object_type);
    std::string object_id_string = Value::validated_to_string(ctx, args[1]);
-    auto object_id = object_id_from_string(object_id_string);
+    auto object_id = sync::ObjectID::from_string(object_id_string);
    const Group& group = realm->read_group();
-    size_t ndx = sync::row_for_object_id(group, *ObjectStore::table_for_object_type(group, object_type), object_id);
+    size_t ndx = sync::row_for_object_id(group, *ObjectStore::table_for_object_type(group, object_schema.name), object_id);
    if (ndx != realm::npos) {
-        return_value.set(RealmObjectClass<T>::create_instance(ctx, realm::Object(realm, object_type, ndx)));
+        return_value.set(RealmObjectClass<T>::create_instance(ctx, realm::Object(realm, object_schema.name, ndx)));
    }
 #else
    throw std::logic_error("Realm._objectForObjectId() can only be used with synced Realms.");
 #endif // REALM_ENABLE_SYNC
 }
 #if REALM_ENABLE_SYNC
 template<typename T>
-void RealmClass<T>::subscribe_to_objects(ContextType ctx, ObjectType this_object, Arguments args, ReturnValue &return_value) {
+void RealmClass<T>::privileges(ContextType ctx, ObjectType this_object, Arguments args, ReturnValue &return_value) {
-    args.validate_count(3);
+    args.validate_maximum(1);
    using Privilege = realm::ComputedPrivileges;
    auto has_privilege = [](Privilege actual, Privilege expected) {
        return (static_cast<int>(actual) & static_cast<int>(expected)) == static_cast<int>(expected);
    };
    SharedRealm realm = *get_internal<T, RealmClass<T>>(this_object);
-    std::string object_type = Value::validated_to_string(ctx, args[0]);
+    if (args.count == 0) {
-    std::string query = Value::validated_to_string(ctx, args[1]);
+        auto p = realm->get_privileges();
-    auto callback = Value::validated_to_function(ctx, args[2]);
+        ObjectType object = Object::create_empty(ctx);
-
+        Object::set_property(ctx, object, "read", Value::from_boolean(ctx, has_privilege(p, Privilege::Read)));
-    auto &schema = realm->schema();
+        Object::set_property(ctx, object, "update", Value::from_boolean(ctx,has_privilege(p, Privilege::Update)));
-    auto object_schema = schema.find(object_type);
+        Object::set_property(ctx, object, "modifySchema", Value::from_boolean(ctx, has_privilege(p, Privilege::ModifySchema)));
-
+        Object::set_property(ctx, object, "setPermissions", Value::from_boolean(ctx, has_privilege(p, Privilege::SetPermissions)));
-    if (object_schema == schema.end()) {
+        return_value.set(object);
        throw std::runtime_error("Object type '" + object_type + "' not found in schema.");
    }
    Protected<ObjectType> protected_this(ctx, this_object);
    Protected<typename T::GlobalContext> protected_ctx(Context<T>::get_global_context(ctx));
    Protected<FunctionType> protected_callback(ctx, callback);
    auto cb = [=](realm::Results results, std::exception_ptr err) {
        HANDLESCOPE
        if (err) {
            try {
                std::rethrow_exception(err);
            }
            catch (const std::exception& e) {
                ValueType callback_arguments[2];
                callback_arguments[0] = Value::from_string(protected_ctx, e.what());
                callback_arguments[1] = Value::from_null(protected_ctx);
                Function<T>::callback(ctx, protected_callback, protected_this, 2, callback_arguments);
            }
        return;
    }
-        ValueType callback_arguments[2];
+    if (Value::is_object(ctx, args[0])) {
-        callback_arguments[0] = Value::from_null(protected_ctx);
+        auto arg = Value::to_object(ctx, args[0]);
-        callback_arguments[1] = ResultsClass<T>::create_instance(protected_ctx, results);
+        if (Object::template is_instance<RealmObjectClass<T>>(ctx, arg)) {
-        Function<T>::callback(protected_ctx, protected_callback, protected_this, 2, callback_arguments);
+            auto obj = get_internal<T, RealmObjectClass<T>>(arg);
-    };
+            auto p = realm->get_privileges(obj->row());
-    partial_sync::register_query(realm, object_type, query, std::move(cb));
+            ObjectType object = Object::create_empty(ctx);
            Object::set_property(ctx, object, "read", Value::from_boolean(ctx, has_privilege(p, Privilege::Read)));
            Object::set_property(ctx, object, "update", Value::from_boolean(ctx,has_privilege(p, Privilege::Update)));
            Object::set_property(ctx, object, "delete", Value::from_boolean(ctx,has_privilege(p, Privilege::Delete)));
            Object::set_property(ctx, object, "setPermissions", Value::from_boolean(ctx, has_privilege(p, Privilege::SetPermissions)));
            return_value.set(object);
            return;
        }
    }
    auto& object_schema = validated_object_schema_for_value(ctx, realm, args[0]);
    auto p = realm->get_privileges(object_schema.name);
    ObjectType object = Object::create_empty(ctx);
    Object::set_property(ctx, object, "read", Value::from_boolean(ctx, has_privilege(p, Privilege::Read)));
    Object::set_property(ctx, object, "update", Value::from_boolean(ctx,has_privilege(p, Privilege::Update)));
    Object::set_property(ctx, object, "create", Value::from_boolean(ctx, has_privilege(p, Privilege::Create)));
    Object::set_property(ctx, object, "subscribe", Value::from_boolean(ctx, has_privilege(p, Privilege::Query)));
    Object::set_property(ctx, object, "setPermissions", Value::from_boolean(ctx, has_privilege(p, Privilege::SetPermissions)));
    return_value.set(object);
 }
 #endif
 } // js
 } // realm
--- a/src/js_results.hpp
+++ b/src/js_results.hpp
@ -28,6 +28,11 @@
 #include <realm/parser/parser.hpp>
 #include <realm/parser/query_builder.hpp>
 #include <realm/util/optional.hpp>
 #ifdef REALM_ENABLE_SYNC
 #include "js_sync.hpp"
 #include "sync/partial_sync.hpp"
 #endif
 namespace realm {
 namespace js {
@ -82,6 +87,9 @@ struct ResultsClass : ClassDefinition<T, realm::js::Results<T>, CollectionClass<
    static void filtered(ContextType, ObjectType, Arguments, ReturnValue &);
    static void sorted(ContextType, ObjectType, Arguments, ReturnValue &);
    static void is_valid(ContextType, ObjectType, Arguments, ReturnValue &);
 #if REALM_ENABLE_SYNC
    static void subscribe(ContextType, ObjectType, Arguments, ReturnValue &);
 #endif
    static void index_of(ContextType, ObjectType, Arguments, ReturnValue &);
@ -107,6 +115,9 @@ struct ResultsClass : ClassDefinition<T, realm::js::Results<T>, CollectionClass<
        {"filtered", wrap<filtered>},
        {"sorted", wrap<sorted>},
        {"isValid", wrap<is_valid>},
 #if REALM_ENABLE_SYNC
        {"subscribe", wrap<subscribe>},
 #endif
        {"min", wrap<compute_aggregate_on_collection<ResultsClass<T>, AggregateFunc::Min>>},
        {"max", wrap<compute_aggregate_on_collection<ResultsClass<T>, AggregateFunc::Max>>},
        {"sum", wrap<compute_aggregate_on_collection<ResultsClass<T>, AggregateFunc::Sum>>},
@ -141,6 +152,21 @@ typename T::Object ResultsClass<T>::create_instance(ContextType ctx, SharedRealm
    return create_object<T, ResultsClass<T>>(ctx, new realm::js::Results<T>(realm, *table));
 }
 inline void alias_backlinks(parser::KeyPathMapping &mapping, const realm::SharedRealm &realm)
 {
    const realm::Schema &schema = realm->schema();
    for (auto it = schema.begin(); it != schema.end(); ++it) {
        for (const Property &property : it->computed_properties) {
            if (property.type == realm::PropertyType::LinkingObjects) {
                auto target_object_schema = schema.find(property.object_type);
                const TableRef table = ObjectStore::table_for_object_type(realm->read_group(), target_object_schema->name);
                std::string native_name = "@links." + std::string(table->get_name()) + "." + property.link_origin_property_name;
                mapping.add_mapping(table, property.name, native_name);
            }
        }
    }
 }
 template<typename T>
 template<typename U>
 typename T::Object ResultsClass<T>::create_filtered(ContextType ctx, const U &collection, Arguments args) {
@ -152,13 +178,17 @@ typename T::Object ResultsClass<T>::create_filtered(ContextType ctx, const U &co
    auto query = collection.get_query();
    auto const &realm = collection.get_realm();
    auto const &object_schema = collection.get_object_schema();
    DescriptorOrdering ordering;
    parser::KeyPathMapping mapping;
    alias_backlinks(mapping, realm);
-    parser::Predicate predicate = parser::parse(query_string);
+    parser::ParserResult result = parser::parse(query_string);
    NativeAccessor<T> accessor(ctx, realm, object_schema);
    query_builder::ArgumentConverter<ValueType, NativeAccessor<T>> converter(accessor, &args.value[1], args.count - 1);
-    query_builder::apply_predicate(query, predicate, converter);
+    query_builder::apply_predicate(query, result.predicate, converter, mapping);
    query_builder::apply_ordering(ordering, query.get_table(), result.ordering);
-    return create_instance(ctx, collection.filter(std::move(query)));
+    return create_instance(ctx, collection.filter(std::move(query)).apply_ordering(std::move(ordering)));
 }
 template<typename T>
@ -252,6 +282,28 @@ void ResultsClass<T>::is_valid(ContextType ctx, ObjectType this_object, Argument
    return_value.set(get_internal<T, ResultsClass<T>>(this_object)->is_valid());
 }
 #if REALM_ENABLE_SYNC
 template<typename T>
 void ResultsClass<T>::subscribe(ContextType ctx, ObjectType this_object, Arguments args, ReturnValue &return_value) {
    args.validate_maximum(1);
    auto results = get_internal<T, ResultsClass<T>>(this_object);
    auto realm = results->get_realm();
    auto sync_config = realm->config().sync_config;
    util::Optional<std::string> subscription_name;
    if (args.count == 1) {
        subscription_name = util::Optional<std::string>(Value::validated_to_string(ctx, args[0]));
    }
    else {
        subscription_name = util::none;
    }
    auto subscription = partial_sync::subscribe(*results, subscription_name);
    return_value.set(SubscriptionClass<T>::create_instance(ctx, std::move(subscription)));
 }
 #endif
 template<typename T>
 template<typename Fn>
 void ResultsClass<T>::index_of(ContextType ctx, Fn& fn, Arguments args, ReturnValue &return_value) {
--- a/src/js_sync.hpp
+++ b/src/js_sync.hpp
@ -29,6 +29,7 @@
 #include "sync/sync_config.hpp"
 #include "sync/sync_session.hpp"
 #include "sync/sync_user.hpp"
 #include "sync/partial_sync.hpp"
 #include "realm/util/logger.hpp"
 #include "realm/util/uri.hpp"
@ -102,7 +103,7 @@ public:
    static void session_for_on_disk_path(ContextType, FunctionType, ObjectType, size_t, const ValueType[], ReturnValue &);
    MethodMap<T> const methods = {
-        {"logout", wrap<logout>},
+        {"_logout", wrap<logout>},
        {"_sessionForOnDiskPath", wrap<session_for_on_disk_path>}
    };
 };
@ -555,6 +556,127 @@ void SessionClass<T>::override_server(ContextType ctx, ObjectType this_object, A
    }
 }
 template<typename T>
 class Subscription : public partial_sync::Subscription {
 public:
    Subscription(partial_sync::Subscription s) : partial_sync::Subscription(std::move(s)) {}
    Subscription(Subscription &&) = default;
    std::vector<std::pair<Protected<typename T::Function>, partial_sync::SubscriptionNotificationToken>> m_notification_tokens;
 };
 template<typename T>
 class SubscriptionClass : public ClassDefinition<T, Subscription<T>> {
    using GlobalContextType = typename T::GlobalContext;
    using ContextType = typename T::Context;
    using FunctionType = typename T::Function;
    using ObjectType = typename T::Object;
    using ValueType = typename T::Value;
    using String = js::String<T>;
    using Object = js::Object<T>;
    using Value = js::Value<T>;
    using Function = js::Function<T>;
    using ReturnValue = js::ReturnValue<T>;
    using Arguments = js::Arguments<T>;
 public:
    std::string const name = "Subscription";
    static FunctionType create_constructor(ContextType);
    static ObjectType create_instance(ContextType, partial_sync::Subscription);
    static void get_state(ContextType, ObjectType, ReturnValue &);
    static void get_error(ContextType, ObjectType, ReturnValue &);
    static void unsubscribe(ContextType, ObjectType, Arguments, ReturnValue &);
    static void add_listener(ContextType, ObjectType, Arguments, ReturnValue &);
    static void remove_listener(ContextType, ObjectType, Arguments, ReturnValue &);
    PropertyMap<T> const properties = {
        {"state", {wrap<get_state>, nullptr}},
        {"error", {wrap<get_error>, nullptr}}
    };
    MethodMap<T> const methods = {
        {"unsubscribe", wrap<unsubscribe>},
        {"addListener", wrap<add_listener>},
        {"removeListener", wrap<remove_listener>},
    };
 };
 template<typename T>
 typename T::Object SubscriptionClass<T>::create_instance(ContextType ctx, partial_sync::Subscription subscription) {
    return create_object<T, SubscriptionClass<T>>(ctx, new Subscription<T>(std::move(subscription)));
 }
 template<typename T>
 void SubscriptionClass<T>::get_state(ContextType ctx, ObjectType object, ReturnValue &return_value) {
    auto subscription = get_internal<T, SubscriptionClass<T>>(object);
    return_value.set(static_cast<int8_t>(subscription->state()));
 }
 template<typename T>
 void SubscriptionClass<T>::get_error(ContextType ctx, ObjectType object, ReturnValue &return_value) {
    auto subscription = get_internal<T, SubscriptionClass<T>>(object);
    if (auto error = subscription->error()) {
        try {
            std::rethrow_exception(error);
        }
        catch (const std::exception& e) {
            return_value.set(e.what());
        }
    }
    else {
        return_value.set_undefined();
    }
 }
 template<typename T>
 void SubscriptionClass<T>::unsubscribe(ContextType ctx, ObjectType this_object, Arguments args, ReturnValue &return_value) {
    args.validate_maximum(0);
    auto subscription = get_internal<T, SubscriptionClass<T>>(this_object);
    partial_sync::unsubscribe(*subscription);
    return_value.set_undefined();
 }
 template<typename T>
 void SubscriptionClass<T>::add_listener(ContextType ctx, ObjectType this_object, Arguments args, ReturnValue &return_value) {
    args.validate_maximum(1);
    auto subscription = get_internal<T, SubscriptionClass<T>>(this_object);
    auto callback = Value::validated_to_function(ctx, args[0]);
    Protected<FunctionType> protected_callback(ctx, callback);
    Protected<ObjectType> protected_this(ctx, this_object);
    Protected<typename T::GlobalContext> protected_ctx(Context<T>::get_global_context(ctx));
    auto token = subscription->add_notification_callback([=]() {
        HANDLESCOPE
        ValueType arguments[2];
        arguments[0] = static_cast<ObjectType>(protected_this),
        arguments[1] = Value::from_number(ctx, static_cast<double>(subscription->state()));
        Function::callback(protected_ctx, protected_callback, protected_this, 2, arguments);
    });
    subscription->m_notification_tokens.emplace_back(protected_callback, std::move(token));
 }
 template<typename T>
 void SubscriptionClass<T>::remove_listener(ContextType ctx, ObjectType this_object, Arguments args, ReturnValue &return_value) {
    args.validate_maximum(1);
    auto subscription = get_internal<T, SubscriptionClass<T>>(this_object);
    auto callback = Value::validated_to_function(ctx, args[0]);
    auto protected_function = Protected<FunctionType>(ctx, callback);
    auto& tokens = subscription->m_notification_tokens;
    auto compare = [&](auto&& token) {
        return typename Protected<FunctionType>::Comparator()(token.first, protected_function);
    };
    tokens.erase(std::remove_if(tokens.begin(), tokens.end(), compare), tokens.end());
 }
 template<typename T>
 class SyncClass : public ClassDefinition<T, void*> {
    using GlobalContextType = typename T::GlobalContext;
@ -701,7 +823,19 @@ void SyncClass<T>::populate_sync_config(ContextType ctx, ObjectType realm_constr
            is_partial = Value::validated_to_boolean(ctx, partial_value);
        }
        bool disable_partial_sync_url_checks = false;
        ValueType disable_partial_sync_url_checks_value = Object::get_property(ctx, sync_config_object, "_disablePartialSyncUrlChecks");
        if (!Value::is_undefined(ctx, disable_partial_sync_url_checks_value)) {
            disable_partial_sync_url_checks = Value::validated_to_boolean(ctx, disable_partial_sync_url_checks_value);
        }
        if (disable_partial_sync_url_checks) {
            config.sync_config = std::make_shared<SyncConfig>(shared_user, std::move(""));
            config.sync_config->reference_realm_url = std::move(raw_realm_url);
        }
        else {
            config.sync_config = std::make_shared<SyncConfig>(shared_user, std::move(raw_realm_url));
        }
        config.sync_config->bind_session_handler = std::move(bind);
        config.sync_config->error_handler = std::move(error_handler);
        config.sync_config->client_validate_ssl = client_validate_ssl;
--- a/src/object-store
+++ b/src/object-store
@ -1 +1 @@
-Subproject commit d5fe9a626c0adc0345d128201e0df8bb4004725d
+Subproject commit b250563ea1eb9f32ec7dbd76f2c6f8f1a26914cc
--- a/tests/js/asserts.js
+++ b/tests/js/asserts.js
@ -37,7 +37,8 @@ module.exports = {
        }
        else if (type === 'object') {
            for (const key of Object.keys(val1)) {
-                this.assertEqual(val1[key], val2[key], errorMessage, depth + 1);
+                const message = errorMessage ? `${errorMessage}: ${key}` : key;
                this.assertEqual(val1[key], val2[key], message, depth + 1);
            }
        }
        else if (type === 'list') {
--- a/tests/js/linkingobjects-tests.js
+++ b/tests/js/linkingobjects-tests.js
@ -83,6 +83,26 @@ module.exports = {
        TestCase.assertArraysEqual(names(resultsC), ['JP']);
    },
    testFilteredLinkingObjectsByName: function() {
        var realm = new Realm({schema: [schemas.PersonObject]});
        var christine, olivier;
        realm.write(function() {
            olivier = realm.create('PersonObject', {name: 'Olivier', age: 0});
            christine = realm.create('PersonObject', {name: 'Christine', age: 25, children: [olivier]});
            realm.create('PersonObject', {name: 'JP', age: 28, children: [olivier]});
        });
        let people = realm.objects('PersonObject')
        TestCase.assertEqual(people.filtered('parents.age > 25').length, 1);
        TestCase.assertEqual(people.filtered('parents.age > 25')[0].name, 'Olivier');
        TestCase.assertEqual(people.filtered('parents.@count == 2').length, 1);
        TestCase.assertEqual(people.filtered('parents.name CONTAINS[c] "chris"').length, 1);
        TestCase.assertEqual(people.filtered('parents.name.@size == 2').length, 1);
        TestCase.assertEqual(people.filtered('25 IN parents.age').length, 1);
    },
    testMethod: function() {
        var realm = new Realm({schema: [schemas.PersonObject]});
--- a/tests/js/nested-list-helper.js
+++ b/tests/js/nested-list-helper.js
@ -9,6 +9,8 @@ const realmName = process.argv[4];
 const realmModule = process.argv[5];
 const Realm = require(realmModule);
 // Ensure that schemas.js gets the correct module with `require('realm')`
 require.cache[require.resolve('realm')] = require.cache[require.resolve(realmModule)];
 let schemas = require(process.argv[2]);
 function createObjects(user) {
--- a/tests/js/permission-tests.js
+++ b/tests/js/permission-tests.js
@ -16,7 +16,6 @@
 //
 ////////////////////////////////////////////////////////////////////////////
 'use strict';
 var Realm = require('realm');
@ -31,7 +30,8 @@ function uuid() {
 function createUsersWithTestRealms(count) {
    const createUserWithTestRealm = () => {
-    return Realm.Sync.User.register('http://localhost:9080', uuid(), 'password')
+        return Realm.Sync.User
            .register('http://localhost:9080', uuid(), 'password')
            .then(user => {
                new Realm({sync: {user, url: 'realm://localhost:9080/~/test'}}).close();
                return user;
@ -57,38 +57,82 @@ function repeatUntil(fn, predicate) {
    return check;
 }
 function subscribe(results) {
    const subscription = results.subscribe();
    return new Promise((resolve, reject) => {
        subscription.addListener((subscription, state) => {
            if (state == Realm.Sync.SubscriptionState.Complete) {
                resolve();
            }
            else if (state == Realm.Sync.SubscriptionState.Error) {
                reject();
            }
        });
        setTimeout(() => reject("listener never called"), 5000);
    });
 }
 function waitForUpload(realm) {
    let session = realm.syncSession;
    return new Promise(resolve => {
        let callback = (transferred, total) => {
            if (transferred === total) {
                session.removeProgressNotification(callback);
                resolve(realm);
            }
        };
        session.addProgressNotification('upload', 'forCurrentlyOutstandingWork', callback);
    });
 }
 function permissionForPath(permissions, path) {
    for (const permission of permissions) {
        if (permission.path == path) {
            return permission;
        }
    }
 }
 module.exports = {
    testApplyAndGetGrantedPermissions() {
-      return createUsersWithTestRealms(1)
+        return createUsersWithTestRealms(1).then(([user]) => {
-        .then(([user]) => {
+            const path = `/${user.identity}/test`;
-          return user.applyPermissions({ userId: `${user.identity}` }, `/${user.identity}/test`, 'read')
+            return user
                .applyPermissions({userId: `${user.identity}`},
                                  `/${user.identity}/test`, 'read')
                .then(repeatUntil(() => user.getGrantedPermissions('any'),
-                              permissions => permissions.length > 1))
+                                  permissions => {
                                      let permission = permissionForPath(permissions, path);
                                      return permission && !permission.mayWrite;
                                  }))
                .then(permissions => {
-              TestCase.assertEqual(permissions[0].path, `/${user.identity}/test`);
+                    let permission = permissionForPath(permissions, path);
-              TestCase.assertEqual(permissions[0].mayRead, true);
+                    TestCase.assertDefined(permission);
-              TestCase.assertEqual(permissions[0].mayWrite, false);
+                    TestCase.assertEqual(permission.mayRead, true);
-              TestCase.assertEqual(permissions[0].mayManage, false);
+                    TestCase.assertEqual(permission.mayWrite, false);
                    TestCase.assertEqual(permission.mayManage, false);
                });
        });
    },
    testOfferPermissions() {
-      return createUsersWithTestRealms(2)
+        return createUsersWithTestRealms(2).then(([user1, user2]) => {
-        .then(([user1, user2]) => {
+            const path = `/${user1.identity}/test`;
            return user1.offerPermissions(`/${user1.identity}/test`, 'read')
                .then(token => user2.acceptPermissionOffer(token))
                .then(realmUrl => {
-              TestCase.assertEqual(realmUrl, `/${user1.identity}/test`);
+                    TestCase.assertEqual(realmUrl, path);
                    return realmUrl;
                })
                .then(repeatUntil(() => user2.getGrantedPermissions('any'),
-                              permissions => permissions.length > 1))
+                                  permissions => permissions.length > 2
                                              && permissionForPath(permissions, path)))
                .then(permissions => {
-              TestCase.assertEqual(permissions[2].path, `/${user1.identity}/test`);
+                    let permission = permissionForPath(permissions, path)
-              TestCase.assertEqual(permissions[2].mayRead, true);
+                    TestCase.assertDefined(permission);
-              TestCase.assertEqual(permissions[2].mayWrite, false);
+                    TestCase.assertEqual(permission.mayRead, true);
-              TestCase.assertEqual(permissions[2].mayManage, false);
+                    TestCase.assertEqual(permission.mayWrite, false);
                    TestCase.assertEqual(permission.mayManage, false);
                });
        });
    },
@ -101,13 +145,20 @@ module.exports = {
                user2 = users[1];
                return user1.offerPermissions(`/${user1.identity}/test`, 'read');
            })
-        .then(t => { token = t; return user1.invalidatePermissionOffer(token); })
+            .then(t => {
-        // Since we don't yet support notification when the invalidation has gone through,
+                token = t;
-        // wait for a bit and hope the server is done processing.
+                return user1.invalidatePermissionOffer(token);
-        .then(wait(100))
+            })
            // Since we don't yet support notification when the invalidation has
            // gone through, wait for a bit and hope the server is done
            // processing.
            .then(() => wait(100))
            .then(() => user2.acceptPermissionOffer(token))
-        // We want the call to fail, i.e. the catch() below should be called.
+            // We want the call to fail, i.e. the catch() below should be
-        .then(() => { throw new Error("User was able to accept an invalid permission offer token"); })
+            // called.
            .then(() => {
                throw new Error("User was able to accept an invalid permission offer token");
            })
            .catch(error => {
                try {
                    TestCase.assertEqual(error.message, 'The permission offer is expired.');
@ -118,5 +169,71 @@ module.exports = {
                }
            });
    },
 }
    testObjectPermissions() {
        let config = (user, url) => {
            return {
                schema: [
                    Realm.Permissions.Permission,
                    Realm.Permissions.User,
                    Realm.Permissions.Role,
                    {
                        name: 'Object',
                        properties: {
                            value: 'int',
                            permissions: '__Permission[]'
                        }
                    }
                ],
                sync: {user, url, partial: true}
            };
        };
        let owner, otherUser
        return Realm.Sync.User
            .register('http://localhost:9080', uuid(), 'password')
            .then(user => {
                owner = user;
                new Realm({sync: {user, url: 'realm://localhost:9080/~/test'}}).close();
                return Realm.Sync.User.register('http://localhost:9080', uuid(), 'password')
            })
            .then(user => {
                otherUser = user;
                return owner.applyPermissions({userId: otherUser.identity},
                                              `/${owner.identity}/test`, 'read')
            })
            .then(() => {
                let realm = new Realm(config(owner, 'realm://localhost:9080/~/test'));
                realm.write(() => {
                    let user = realm.create(Realm.Permissions.User, {id: otherUser.identity})
                    let role = realm.create(Realm.Permissions.Role, {name: 'reader'})
                    role.members.push(user)
                    let obj1 = realm.create('Object', {value: 1});
                    let obj2 = realm.create('Object', {value: 2});
                    obj2.permissions.push(realm.create(Realm.Permissions.Permission,
                                                       {role: role, canRead: true, canUpdate: false}))
                });
                return waitForUpload(realm).then(() => realm.close());
            })
            .then(() => Realm.open(config(otherUser, `realm://localhost:9080/${owner.identity}/test`)))
            .then((realm) => subscribe(realm.objects('Object')).then(() => realm))
            .then((realm) => {
                // Should have full access to the Realm as a whole
                TestCase.assertSimilar('object', realm.privileges(),
                                       {read: true, update: true, modifySchema: true, setPermissions: true});
                TestCase.assertSimilar('object', realm.privileges('Object'),
                                       {read: true, update: true, create: true, subscribe: true, setPermissions: true});
                // Verify that checking via constructor works too
                TestCase.assertSimilar('object', realm.privileges(Realm.Permissions.User),
                                       {read: true, update: true, create: true, subscribe: true, setPermissions: true});
                // Should only be able to see the second object
                let results = realm.objects('Object')
                TestCase.assertEqual(results.length, 1);
                TestCase.assertEqual(results[0].value, 2);
                TestCase.assertSimilar('object', realm.privileges(results[0]),
                                       {read: true, update: false, delete: false, setPermissions: false});
                realm.close();
            });
    }
 }
--- a/tests/js/query-tests.js
+++ b/tests/js/query-tests.js
@ -154,5 +154,8 @@ module.exports = {
    },
    testOptionalQueries: function() {
        runQuerySuite(testCases.optionalTests);
    },
    testOrderingQueries: function() {
        runQuerySuite(testCases.orderingTests);
    }
 };
--- a/tests/js/query-tests.json
+++ b/tests/js/query-tests.json
@ -375,9 +375,35 @@
        ["ObjectSet", [1], "LinkTypesObject", "basicLink.stringCol == null"],
        ["ObjectSet", [0], "LinkTypesObject", "basicLink.stringCol != null"],
        ["ObjectSet", [1], "LinkTypesObject", "basicLink.dateCol == null"],
-        ["ObjectSet", [0], "LinkTypesObject", "basicLink.dateCol != null"],
+        ["ObjectSet", [0], "LinkTypesObject", "basicLink.dateCol != null"]
-        ["QueryThrows", "LinkTypesObject", "basicLink.dataCol == null"]
+    ]
 },
 "orderingTests" : {
    "schema" : [
        { "name": "Person",
          "properties": [
              { "name": "id", "type": "int"},
              { "name": "name",  "type": "string" },
              { "name": "age", "type": "int"}
          ],
          "primaryKey" : "id" }
    ],
    "objects": [
        { "type": "Person", "value": [0, "John", 28] },
        { "type": "Person", "value": [1, "John", 37] },
        { "type": "Person", "value": [2, "Jake", 27] },
        { "type": "Person", "value": [3, "Jake", 32] },
        { "type": "Person", "value": [4, "Jake", 32] },
        { "type": "Person", "value": [5, "Johnny", 19] }
    ],
    "tests": [
        ["ObjectSet", [1, 3],       "Person", "age > 20 SORT(age DESC) DISTINCT(name)"],
        ["ObjectSet", [2, 0],       "Person", "age > 20 SORT(age ASC) DISTINCT(name)"],
        ["ObjectSet", [2, 0],       "Person", "age > 20 SORT(age ASC, name DESC) DISTINCT(name)"],
        ["ObjectSet", [2, 0],       "Person", "age > 20 SORT(name DESC) SORT(age ASC) DISTINCT(name)"],
        ["ObjectSet", [2, 0, 3, 1], "Person", "age > 20 SORT(age ASC, name DESC) DISTINCT(name, age)"],
        ["ObjectSet", [0, 2],       "Person", "age > 20 SORT(age ASC) DISTINCT(age) SORT(name DESC) DISTINCT(name)"]
    ]
 }
 }
--- a/tests/js/session-tests.js
+++ b/tests/js/session-tests.js
@ -61,20 +61,16 @@ function copyFileToTempDir(filename) {
    return tmpFile.name;
 }
-function runOutOfProcess(nodeJsFilePath) {
+function runOutOfProcess() {
-    var nodeArgs = Array.prototype.slice.call(arguments);
+    const args = Array.prototype.slice.call(arguments);
    let tmpDir = tmp.dirSync();
-    let content = fs.readFileSync(nodeJsFilePath, 'utf8');
+    console.log(`runOutOfProcess : ${args.join(' ')}`);
    let tmpFile = tmp.fileSync({ dir: tmpDir.name });
    fs.appendFileSync(tmpFile.fd, content, { encoding: 'utf8' });
    nodeArgs[0] = tmpFile.name;
    return new Promise((resolve, reject) => {
        try {
-            console.log('runOutOfProcess command\n node ' + nodeArgs.join(" "));
+            execFile(process.execPath, args, {cwd: tmpDir.name}, (error, stdout, stderr) => {
            const child = execFile('node', nodeArgs, { cwd: tmpDir.name }, (error, stdout, stderr) => {
                if (error) {
-                    console.error("runOutOfProcess failed\n" + error);
+                    console.error("runOutOfProcess failed\n", error, stdout, stderr);
-                    reject(new Error(`Running ${nodeJsFilePath} failed. error: ${error}`));
+                    reject(new Error(`Running ${args[0]} failed. error: ${error}`));
                    return;
                }
@ -170,6 +166,33 @@ module.exports = {
            });
    },
    testDefaultRealm() {
        if (!isNodeProccess) {
            return;
        }
        const username = uuid();
        const realmName = 'default';
        const expectedObjectsCount = 3;
        let user;
        return runOutOfProcess(__dirname + '/download-api-helper.js', username, realmName, REALM_MODULE_PATH)
            .then(() => Realm.Sync.User.login('http://localhost:9080', username, 'password'))
            .then(u => {
                user = u;
                return Realm.open(Realm.automaticSyncConfiguration());
            })
            .then(realm => {
                let actualObjectsCount = realm.objects('Dog').length;
                TestCase.assertEqual(actualObjectsCount, expectedObjectsCount, "Synced realm does not contain the expected objects count");
                const session = realm.syncSession;
                TestCase.assertInstanceOf(session, Realm.Sync.Session);
                TestCase.assertEqual(session.user.identity, user.identity);
                TestCase.assertEqual(session.state, 'active');
            });
    },
    testRealmOpenWithExistingLocalRealm() {
        if (!isNodeProccess) {
            return;
@ -275,22 +298,21 @@ module.exports = {
        const expectedObjectsCount = 3;
       return runOutOfProcess(__dirname + '/download-api-helper.js', username, realmName, REALM_MODULE_PATH)
-            .then(() => {
+            .then(() => Realm.Sync.User.login('http://localhost:9080', username, 'password'))
-                return Realm.Sync.User.login('http://localhost:9080', username, 'password').then(user => {
+            .then(user => {
                    return new Promise((resolve, reject) => {
                const accessTokenRefreshed = this;
                let successCounter = 0;
                let config = {
                    sync: { user, url: `realm://localhost:9080/~/${realmName}` }
                };
-
+                return new Promise((resolve, reject) => {
                    Realm.openAsync(config, (error, realm) => {
                            try {
                        if (error) {
                            reject(error);
                            return;
                        }
-
+                        try {
                            let actualObjectsCount = realm.objects('Dog').length;
                            TestCase.assertEqual(actualObjectsCount, expectedObjectsCount, "Synced realm does not contain the expected objects count");
@ -299,7 +321,6 @@ module.exports = {
                            TestCase.assertTrue(firstDog.name, "Synced realm object's property should have a value");
                            TestCase.assertTrue(firstDog.name.indexOf('Lassy') !== -1, "Synced realm object's property should contain the actual written value");
                            const session = realm.syncSession;
                            TestCase.assertInstanceOf(session, Realm.Sync.Session);
                            TestCase.assertEqual(session.user.identity, user.identity);
@ -314,15 +335,12 @@ module.exports = {
                    });
                });
            });
            });
    },
    testRealmOpenLocalRealm() {
        const username = uuid();
        const expectedObjectsCount = 3;
        return new Promise((resolve, reject) => {
        const accessTokenRefreshed = this;
        let successCounter = 0;
@ -330,7 +348,7 @@ module.exports = {
            schema: [{ name: 'Dog', properties: { name: 'string' } }],
        };
-            Realm.open(config).then(realm => {
+        return Realm.open(config).then(realm => {
            realm.write(() => {
                for (let i = 1; i <= 3; i++) {
                    realm.create('Dog', { name: `Lassy ${i}` });
@ -339,8 +357,6 @@ module.exports = {
            let actualObjectsCount = realm.objects('Dog').length;
            TestCase.assertEqual(actualObjectsCount, expectedObjectsCount, "Local realm does not contain the expected objects count");
                resolve();
            }).catch(error => reject(error));
        });
    },
@ -412,14 +428,14 @@ module.exports = {
        const realmName = uuid();
        return runOutOfProcess(__dirname + '/nested-list-helper.js', __dirname + '/schemas.js', username, realmName, REALM_MODULE_PATH)
-            .then(() => {
+            .then(() => Realm.Sync.User.login('http://localhost:9080', username, 'password'))
-                return Realm.Sync.User.login('http://localhost:9080', username, 'password').then(user => {
+            .then(user => {
                    return new Promise((resolve, reject) => {
                let config = {
                    schema: [schemas.ParentObject, schemas.NameObject],
                    sync: { user, url: `realm://localhost:9080/~/${realmName}` }
                };
-                        Realm.open(config).then(realm => {
+                return Realm.open(config)
            }).then(realm => {
                let objects = realm.objects('ParentObject');
                let json = JSON.stringify(objects);
@ -439,10 +455,6 @@ module.exports = {
                TestCase.assertEqual(objects[1].name[0].prefix.length, 0);
                TestCase.assertEqual(objects[1].name[0].given[0], 'Gurli');
                TestCase.assertEqual(objects[1].name[0].given[1], 'Margrete');
                            resolve();
                        }).catch(() => reject());
                    });
                });
            });
    },
@ -567,7 +579,7 @@ module.exports = {
        });
    },
-    testProgressNotificationsForRealmConstructor() {
+/*    testProgressNotificationsForRealmConstructor() {
        if (!isNodeProccess) {
            return;
        }
@ -599,7 +611,7 @@ module.exports = {
                    });
                });
            });
-    },
+    },*/
    testProgressNotificationsUnregisterForRealmConstructor() {
        if (!isNodeProccess) {
@ -610,9 +622,8 @@ module.exports = {
        const realmName = uuid();
        return runOutOfProcess(__dirname + '/download-api-helper.js', username, realmName, REALM_MODULE_PATH)
-            .then(() => {
+            .then(() => Realm.Sync.User.login('http://localhost:9080', username, 'password'))
-                return Realm.Sync.User.login('http://localhost:9080', username, 'password').then(user => {
+            .then(user => {
                    return new Promise((resolve, reject) => {
                let config = {
                    sync: {
                        user,
@ -632,6 +643,7 @@ module.exports = {
                    });
                }
                return new Promise((resolve, reject) => {
                    let syncFinished = false;
                    let failOnCall = false;
                    const progressCallback = (transferred, total) => {
@ -665,7 +677,6 @@ module.exports = {
                    writeDataFunc();
                });
            });
            });
    },
    testProgressNotificationsForRealmOpen() {
@ -675,11 +686,11 @@ module.exports = {
        const username = uuid();
        const realmName = uuid();
        let progressCalled = false;
        return runOutOfProcess(__dirname + '/download-api-helper.js', username, realmName, REALM_MODULE_PATH)
-            .then(() => {
+            .then(() => Realm.Sync.User.login('http://localhost:9080', username, 'password'))
-                return Realm.Sync.User.login('http://localhost:9080', username, 'password').then(user => {
+            .then(user => {
                    return new Promise((resolve, reject) => {
                let config = {
                    sync: {
                        user,
@ -688,23 +699,11 @@ module.exports = {
                    schema: [{ name: 'Dog', properties: { name: 'string' } }],
                };
-                        let progressCalled = false;
+                return Promise.race([
-                        Realm.open(config)
+                    Realm.open(config).progress((transferred, total) => { progressCalled = true; }),
-                            .progress((transferred, total) => {
+                    new Promise((_, reject) => setTimeout(() => reject("Progress Notifications API failed to call progress callback for Realm constructor"), 5000))
-                                progressCalled = true;
+                ]);
-                            })
+            }).then(() => TestCase.assertTrue(progressCalled));
                            .then(() => {
                                TestCase.assertTrue(progressCalled);
                                resolve();
                            })
                            .catch((e) => reject(e));
                        setTimeout(function() {
                            reject("Progress Notifications API failed to call progress callback for Realm constructor");
                        }, 5000);
                    });
                });
            });
    },
    testProgressNotificationsForRealmOpenAsync() {
@ -716,8 +715,8 @@ module.exports = {
        const realmName = uuid();
        return runOutOfProcess(__dirname + '/download-api-helper.js', username, realmName, REALM_MODULE_PATH)
-            .then(() => {
+            .then(() => Realm.Sync.User.login('http://localhost:9080', username, 'password'))
-                return Realm.Sync.User.login('http://localhost:9080', username, 'password').then(user => {
+            .then(user => {
                return new Promise((resolve, reject) => {
                    let config = {
                        sync: {
@ -748,10 +747,39 @@ module.exports = {
                    }, 5000);
                });
            });
    },
    testOpenPartialSyncUrl() {
        if (!isNodeProccess) {
            return;
        }
        const username = uuid();
        return Realm.Sync.User.register('http://localhost:9080', username, 'password')
            .then(user => {
                let config1 = {
                    sync: {
                        user: user,
                        url: `realm://localhost:9080/~/default/__partial/`,
                        partial: true,
                        _disablePartialSyncUrlChecks: true
                    }
                };
                const realm = new Realm(config1);
                TestCase.assertFalse(realm.isClosed);
                let config2 = {
                    sync: {
                        user: user,
                        url: `realm://localhost:9080/~/default/__partial/`,  // <--- not allowed URL
                        partial: true,
                    }
                };
                TestCase.assertThrows(() => new Realm(config2));
            });
    },
-    testPartialSync() {
+    testPartialSyncAnonymous_SubscriptionListener() {
        // FIXME: try to enable for React Native
        if (!isNodeProccess) {
            return;
@ -761,8 +789,8 @@ module.exports = {
        const realmName = uuid();
        return runOutOfProcess(__dirname + '/download-api-helper.js', username, realmName, REALM_MODULE_PATH)
-            .then(() => {
+            .then(() => Realm.Sync.User.login('http://localhost:9080', username, 'password'))
-                return Realm.Sync.User.login('http://localhost:9080', username, 'password').then(user => {
+            .then(user => {
                let config = {
                    sync: {
                        user: user,
@ -776,12 +804,198 @@ module.exports = {
                Realm.deleteFile(config);
                const realm = new Realm(config);
                TestCase.assertEqual(realm.objects('Dog').length, 0);
-                    return realm.subscribeToObjects("Dog", "name == 'Lassy 1'").then(results => {
+                var results = realm.objects('Dog').filtered("name == 'Lassy 1'");
                var subscription = results.subscribe();
                TestCase.assertEqual(subscription.state, Realm.Sync.SubscriptionState.Creating);
                return new Promise((resolve, reject) => {
                    subscription.addListener((subscription, state) => {
                        if (state == Realm.Sync.SubscriptionState.Complete) {
                            TestCase.assertEqual(results.length, 1);
                            TestCase.assertTrue(results[0].name === 'Lassy 1', "The object is not synced correctly");
                            resolve();
                        }
                    });
                    setTimeout(function() {
                        reject("listener never called");
                    }, 5000);
                });
            });
    },
    testPartialSyncAnonymous_ResultsListener() {
        // FIXME: try to enable for React Native
        if (!isNodeProccess) {
            return;
        }
        const username = uuid();
        const realmName = uuid();
        return runOutOfProcess(__dirname + '/download-api-helper.js', username, realmName, REALM_MODULE_PATH)
            .then(() => Realm.Sync.User.login('http://localhost:9080', username, 'password'))
            .then(user => {
                let config = {
                    sync: {
                        user: user,
                        url: `realm://localhost:9080/~/${realmName}`,
                        partial: true,
                        error: (session, error) => console.log(error)
                    },
                    schema: [{ name: 'Dog', properties: { name: 'string' } }]
                };
                Realm.deleteFile(config);
                const realm = new Realm(config);
                TestCase.assertEqual(realm.objects('Dog').length, 0);
                var results = realm.objects('Dog').filtered("name == 'Lassy 1'");
                var subscription = results.subscribe();
                TestCase.assertEqual(subscription.state, Realm.Sync.SubscriptionState.Creating);
                return new Promise((resolve, reject) => {
                    results.addListener((collection, changes) => {
                        if (subscription.state === Realm.Sync.SubscriptionState.Complete) {
                            TestCase.assertEqual(collection.length, 1);
                            TestCase.assertTrue(collection[0].name === 'Lassy 1', "The object is not synced correctly");
                            resolve();
                        }
                    });
                    setTimeout(function() {
                        reject("listener never called");
                    }, 5000);
                });
            });
    },
    testPartialSyncMultipleSubscriptions() {
        // FIXME: try to enable for React Native
        if (!isNodeProccess) {
            return;
        }
        const username = uuid();
        const realmName = uuid();
        return runOutOfProcess(__dirname + '/download-api-helper.js', username, realmName, REALM_MODULE_PATH)
            .then(() => Realm.Sync.User.login('http://localhost:9080', username, 'password'))
            .then(user => {
                let config = {
                    sync: {
                        user: user,
                        url: `realm://localhost:9080/~/${realmName}`,
                        partial: true,
                        error: (session, error) => console.log(error)
                    },
                    schema: [{ name: 'Dog', properties: { name: 'string' } }]
                };
                Realm.deleteFile(config);
                const realm = new Realm(config);
                TestCase.assertEqual(realm.objects('Dog').length, 0);
                var results1 = realm.objects('Dog').filtered("name == 'Lassy 1'");
                var results2 = realm.objects('Dog').filtered("name == 'Lassy 2'");
                var subscription1 = results1.subscribe();
                var subscription2 = results2.subscribe();
                return new Promise((resolve, reject) => {
                    let called1 = false;
                    let called2 = false;
                    results1.addListener((collection, changeset) => {
                        if (subscription1.state == Realm.Sync.SubscriptionState.Complete) {
                            TestCase.assertEqual(collection.length, 1);
                            TestCase.assertTrue(collection[0].name === 'Lassy 1', "The object is not synced correctly");
                            called1 = true;
                            if (called1 && called2) {
                                resolve();
                            }
                        }
                    });
                    results2.addListener((collection, changeset) => {
                        if (subscription2.state == Realm.Sync.SubscriptionState.Complete) {
                            TestCase.assertEqual(collection.length, 1);
                            TestCase.assertTrue(collection[0].name === 'Lassy 2', "The object is not synced correctly");
                            called2 = true;
                            if (called1 && called2) {
                                resolve();
                            }
                        }
                    });
                    setTimeout(function() {
                         reject("listener never called");
                    }, 5000);
                });
            });
    },
    testPartialSyncFailing() {
        // FIXME: try to enable for React Native
        if (!isNodeProccess) {
            return;
        }
        const username = uuid();
        const realmName = uuid();
        return runOutOfProcess(__dirname + '/download-api-helper.js', username, realmName, REALM_MODULE_PATH)
            .then(() => Realm.Sync.User.login('http://localhost:9080', username, 'password'))
            .then(user => {
                let config = {
                    sync: {
                        user: user,
                        url: `realm://localhost:9080/~/${realmName}`,
                        partial: false, // <---- calling subscribe should fail
                        error: (session, error) => console.log(error)
                    },
                    schema: [{ name: 'Dog', properties: { name: 'string' } }]
                };
                Realm.deleteFile(config);
                const realm = new Realm(config);
                TestCase.assertEqual(realm.objects('Dog').length, 0);
                TestCase.assertThrows(function () { var subscription = realm.objects('Dog').filtered("name == 'Lassy 1'").subscribe(); } );
            });
    },
    testPartialSyncUnsubscribe() {
        // FIXME: try to enable for React Native
        if (!isNodeProccess) {
            return;
        }
        const username = uuid();
        const realmName = uuid();
        return runOutOfProcess(__dirname + '/download-api-helper.js', username, realmName, REALM_MODULE_PATH)
            .then(() => Realm.Sync.User.login('http://localhost:9080', username, 'password'))
            .then(user => {
                let config = {
                    sync: {
                        user: user,
                        url: `realm://localhost:9080/~/${realmName}`,
                        partial: true,
                        error: (session, error) => console.log(error)
                    },
                    schema: [{ name: 'Dog', properties: { name: 'string' } }]
                };
                Realm.deleteFile(config);
                const realm = new Realm(config);
                var results = realm.objects('Dog').filtered("name == 'Lassy 1'");
                var subscription = results.subscribe();
                TestCase.assertEqual(subscription.state, Realm.Sync.SubscriptionState.Creating);
                return new Promise((resolve, reject) => {
                    results.addListener((collection, changes) => {
                        if (subscription.state === Realm.Sync.SubscriptionState.Complete) {
                            subscription.unsubscribe();
                        }
                        if (subscription.state === Realm.Sync.SubscriptionState.Invalidated) {
                            resolve();
                        }
                    });
                    setTimeout(function() {
                        reject("listener never called");
                    }, 5000);
                });
            });
                })
            })
    },
    testClientReset() {
		`@ -1 +1 @@`
			`Subproject commit d5fe9a626c0adc0345d128201e0df8bb4004725d`				`Subproject commit b250563ea1eb9f32ec7dbd76f2c6f8f1a26914cc`