//////////////////////////////////////////////////////////////////////////// // // Copyright 2016 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 { keys } from './constants'; import * as rpc from './rpc'; let mutationListeners = {}; function addMutationListener(realmId, callback) { let listeners = mutationListeners[realmId] || (mutationListeners[realmId] = new Set()); listeners.add(callback); } function removeMutationListener(realmId, callback) { let listeners = mutationListeners[realmId]; if (listeners) { listeners.delete(callback); } } export function clearMutationListeners() { mutationListeners = {}; } export function fireMutationListeners(realmId) { let listeners = mutationListeners[realmId]; if (listeners) { listeners.forEach((cb) => cb()); } } export function createCollection(prototype, realmId, info, mutable) { let list = Object.create(prototype); let size = 0; Object.defineProperties(list, { 'length': { get: getterForProperty('length'), }, '-1': { value: undefined, }, }); let resize = function(length) { if (length == null) { length = list.length; } if (length == size) { return; } let props = {}; if (length > size) { for (let i = size; i < length; i++) { props[i] = { get: getterForProperty(i), set: mutable ? setterForProperty(i) : undefined, enumerable: true, configurable: true, }; } } else if (length < size) { for (let i = size; i >= length; i--) { delete list[i]; } } // Helpfully throw an exception on attempts to set to list[list.length]. props[length] = { value: undefined, configurable: true, }; Object.defineProperties(list, props); size = length; }; list[keys.realm] = realmId; list[keys.id] = info.id; list[keys.type] = info.type; resize(info.size); addMutationListener(realmId, function listener() { try { resize(); } catch (e) { // If the error indicates the list was deleted, then remove this listener. if (e.message.indexOf('is not attached') > 0) { removeMutationListener(realmId, listener); } else { throw e; } } }); return list; } export function createMethods(prototype, type, methodNames, mutates) { let props = {}; methodNames.forEach((name) => { props[name] = { value: createMethod(type, name, mutates), }; }); Object.defineProperties(prototype, props); } export function createMethod(type, name, mutates) { return function() { let realmId = this[keys.realm]; let id = this[keys.id]; if (!realmId || !id) { throw new TypeError(name + ' method was not called a Realm object!'); } if (this[keys.type] !== type) { throw new TypeError(name + ' method was called on an object of the wrong type!'); } let result = rpc.callMethod(realmId, id, name, Array.from(arguments)); if (mutates) { fireMutationListeners(realmId); } return result; }; } export function getterForProperty(name) { return function() { return rpc.getProperty(this[keys.realm], this[keys.id], name); }; } export function setterForProperty(name) { return function(value) { let realmId = this[keys.realm]; rpc.setProperty(realmId, this[keys.id], name, value); // If this isn't a primitive value, then it might create a new object in the Realm. if (value && typeof value == 'object') { fireMutationListeners(realmId); } }; }