| Index: pkg/mutation_observer/lib/mutation_observer.js
|
| diff --git a/pkg/mutation_observer/lib/mutation_observer.js b/pkg/mutation_observer/lib/mutation_observer.js
|
| deleted file mode 100644
|
| index cae870950c866adc1f3d0af73812196e8e957d83..0000000000000000000000000000000000000000
|
| --- a/pkg/mutation_observer/lib/mutation_observer.js
|
| +++ /dev/null
|
| @@ -1,588 +0,0 @@
|
| -/*
|
| - * Copyright 2013 The Polymer Authors. All rights reserved.
|
| - * Use of this source code is goverened by a BSD-style
|
| - * license that can be found in the LICENSE file.
|
| - */
|
| -
|
| -// TODO(jmesserly): polyfill does not have feature testing or the definition of
|
| -// SideTable. The extra code is from:
|
| -// https://github.com/Polymer/CustomElements/blob/master/src/MutationObserver.js
|
| -// https://github.com/Polymer/CustomElements/blob/master/src/sidetable.js
|
| -// I also renamed JsMutationObserver -> MutationObserver to correctly interact
|
| -// with dart2js interceptors.
|
| -
|
| -if (!window.MutationObserver && !window.WebKitMutationObserver) {
|
| -
|
| -(function(global) {
|
| - // SideTable is a weak map where possible. If WeakMap is not available the
|
| - // association is stored as an expando property.
|
| - var SideTable;
|
| - // TODO(arv): WeakMap does not allow for Node etc to be keys in Firefox
|
| - if (typeof WeakMap !== 'undefined' && navigator.userAgent.indexOf('Firefox/') < 0) {
|
| - SideTable = WeakMap;
|
| - } else {
|
| - (function() {
|
| - var defineProperty = Object.defineProperty;
|
| - var hasOwnProperty = Object.hasOwnProperty;
|
| - var counter = new Date().getTime() % 1e9;
|
| -
|
| - SideTable = function() {
|
| - this.name = '__st' + (Math.random() * 1e9 >>> 0) + (counter++ + '__');
|
| - };
|
| -
|
| - SideTable.prototype = {
|
| - set: function(key, value) {
|
| - defineProperty(key, this.name, {value: value, writable: true});
|
| - },
|
| - get: function(key) {
|
| - return hasOwnProperty.call(key, this.name) ? key[this.name] : undefined;
|
| - },
|
| - delete: function(key) {
|
| - this.set(key, undefined);
|
| - }
|
| - }
|
| - })();
|
| - }
|
| -
|
| - var registrationsTable = new SideTable();
|
| -
|
| - // We use setImmediate or postMessage for our future callback.
|
| - var setImmediate = window.msSetImmediate;
|
| -
|
| - // Use post message to emulate setImmediate.
|
| - if (!setImmediate) {
|
| - var setImmediateQueue = [];
|
| - var sentinel = String(Math.random());
|
| - window.addEventListener('message', function(e) {
|
| - if (e.data === sentinel) {
|
| - var queue = setImmediateQueue;
|
| - setImmediateQueue = [];
|
| - queue.forEach(function(func) {
|
| - func();
|
| - });
|
| - }
|
| - });
|
| - setImmediate = function(func) {
|
| - setImmediateQueue.push(func);
|
| - window.postMessage(sentinel, '*');
|
| - };
|
| - }
|
| -
|
| - // This is used to ensure that we never schedule 2 callas to setImmediate
|
| - var isScheduled = false;
|
| -
|
| - // Keep track of observers that needs to be notified next time.
|
| - var scheduledObservers = [];
|
| -
|
| - /**
|
| - * Schedules |dispatchCallback| to be called in the future.
|
| - * @param {MutationObserver} observer
|
| - */
|
| - function scheduleCallback(observer) {
|
| - scheduledObservers.push(observer);
|
| - if (!isScheduled) {
|
| - isScheduled = true;
|
| - setImmediate(dispatchCallbacks);
|
| - }
|
| - }
|
| -
|
| - function wrapIfNeeded(node) {
|
| - return window.ShadowDOMPolyfill &&
|
| - window.ShadowDOMPolyfill.wrapIfNeeded(node) ||
|
| - node;
|
| - }
|
| -
|
| - function dispatchCallbacks() {
|
| - // http://dom.spec.whatwg.org/#mutation-observers
|
| -
|
| - isScheduled = false; // Used to allow a new setImmediate call above.
|
| -
|
| - var observers = scheduledObservers;
|
| - scheduledObservers = [];
|
| - // Sort observers based on their creation UID (incremental).
|
| - observers.sort(function(o1, o2) {
|
| - return o1.uid_ - o2.uid_;
|
| - });
|
| -
|
| - var anyNonEmpty = false;
|
| - observers.forEach(function(observer) {
|
| -
|
| - // 2.1, 2.2
|
| - var queue = observer.takeRecords();
|
| - // 2.3. Remove all transient registered observers whose observer is mo.
|
| - removeTransientObserversFor(observer);
|
| -
|
| - // 2.4
|
| - if (queue.length) {
|
| - observer.callback_(queue, observer);
|
| - anyNonEmpty = true;
|
| - }
|
| - });
|
| -
|
| - // 3.
|
| - if (anyNonEmpty)
|
| - dispatchCallbacks();
|
| - }
|
| -
|
| - function removeTransientObserversFor(observer) {
|
| - observer.nodes_.forEach(function(node) {
|
| - var registrations = registrationsTable.get(node);
|
| - if (!registrations)
|
| - return;
|
| - registrations.forEach(function(registration) {
|
| - if (registration.observer === observer)
|
| - registration.removeTransientObservers();
|
| - });
|
| - });
|
| - }
|
| -
|
| - /**
|
| - * This function is used for the "For each registered observer observer (with
|
| - * observer's options as options) in target's list of registered observers,
|
| - * run these substeps:" and the "For each ancestor ancestor of target, and for
|
| - * each registered observer observer (with options options) in ancestor's list
|
| - * of registered observers, run these substeps:" part of the algorithms. The
|
| - * |options.subtree| is checked to ensure that the callback is called
|
| - * correctly.
|
| - *
|
| - * @param {Node} target
|
| - * @param {function(MutationObserverInit):MutationRecord} callback
|
| - */
|
| - function forEachAncestorAndObserverEnqueueRecord(target, callback) {
|
| - for (var node = target; node; node = node.parentNode) {
|
| - var registrations = registrationsTable.get(node);
|
| -
|
| - if (registrations) {
|
| - for (var j = 0; j < registrations.length; j++) {
|
| - var registration = registrations[j];
|
| - var options = registration.options;
|
| -
|
| - // Only target ignores subtree.
|
| - if (node !== target && !options.subtree)
|
| - continue;
|
| -
|
| - var record = callback(options);
|
| - if (record)
|
| - registration.enqueue(record);
|
| - }
|
| - }
|
| - }
|
| - }
|
| -
|
| - var uidCounter = 0;
|
| -
|
| - /**
|
| - * The class that maps to the DOM MutationObserver interface.
|
| - * @param {Function} callback.
|
| - * @constructor
|
| - */
|
| - function MutationObserver(callback) {
|
| - this.callback_ = callback;
|
| - this.nodes_ = [];
|
| - this.records_ = [];
|
| - this.uid_ = ++uidCounter;
|
| - }
|
| -
|
| - MutationObserver.prototype = {
|
| - observe: function(target, options) {
|
| - target = wrapIfNeeded(target);
|
| -
|
| - // 1.1
|
| - if (!options.childList && !options.attributes && !options.characterData ||
|
| -
|
| - // 1.2
|
| - options.attributeOldValue && !options.attributes ||
|
| -
|
| - // 1.3
|
| - options.attributeFilter && options.attributeFilter.length &&
|
| - !options.attributes ||
|
| -
|
| - // 1.4
|
| - options.characterDataOldValue && !options.characterData) {
|
| -
|
| - throw new SyntaxError();
|
| - }
|
| -
|
| - var registrations = registrationsTable.get(target);
|
| - if (!registrations)
|
| - registrationsTable.set(target, registrations = []);
|
| -
|
| - // 2
|
| - // If target's list of registered observers already includes a registered
|
| - // observer associated with the context object, replace that registered
|
| - // observer's options with options.
|
| - var registration;
|
| - for (var i = 0; i < registrations.length; i++) {
|
| - if (registrations[i].observer === this) {
|
| - registration = registrations[i];
|
| - registration.removeListeners();
|
| - registration.options = options;
|
| - break;
|
| - }
|
| - }
|
| -
|
| - // 3.
|
| - // Otherwise, add a new registered observer to target's list of registered
|
| - // observers with the context object as the observer and options as the
|
| - // options, and add target to context object's list of nodes on which it
|
| - // is registered.
|
| - if (!registration) {
|
| - registration = new Registration(this, target, options);
|
| - registrations.push(registration);
|
| - this.nodes_.push(target);
|
| - }
|
| -
|
| - registration.addListeners();
|
| - },
|
| -
|
| - disconnect: function() {
|
| - this.nodes_.forEach(function(node) {
|
| - var registrations = registrationsTable.get(node);
|
| - for (var i = 0; i < registrations.length; i++) {
|
| - var registration = registrations[i];
|
| - if (registration.observer === this) {
|
| - registration.removeListeners();
|
| - registrations.splice(i, 1);
|
| - // Each node can only have one registered observer associated with
|
| - // this observer.
|
| - break;
|
| - }
|
| - }
|
| - }, this);
|
| - this.records_ = [];
|
| - },
|
| -
|
| - takeRecords: function() {
|
| - var copyOfRecords = this.records_;
|
| - this.records_ = [];
|
| - return copyOfRecords;
|
| - }
|
| - };
|
| -
|
| - /**
|
| - * @param {string} type
|
| - * @param {Node} target
|
| - * @constructor
|
| - */
|
| - function MutationRecord(type, target) {
|
| - this.type = type;
|
| - this.target = target;
|
| - this.addedNodes = [];
|
| - this.removedNodes = [];
|
| - this.previousSibling = null;
|
| - this.nextSibling = null;
|
| - this.attributeName = null;
|
| - this.attributeNamespace = null;
|
| - this.oldValue = null;
|
| - }
|
| -
|
| - // TODO(jmesserly): this fixes the interceptor dispatch on IE.
|
| - // Not sure why this is necessary.
|
| - MutationObserver.prototype.constructor = MutationObserver;
|
| - MutationObserver.name = 'MutationObserver';
|
| - MutationRecord.prototype.constructor = MutationRecord;
|
| - MutationRecord.name = 'MutationRecord';
|
| -
|
| - function copyMutationRecord(original) {
|
| - var record = new MutationRecord(original.type, original.target);
|
| - record.addedNodes = original.addedNodes.slice();
|
| - record.removedNodes = original.removedNodes.slice();
|
| - record.previousSibling = original.previousSibling;
|
| - record.nextSibling = original.nextSibling;
|
| - record.attributeName = original.attributeName;
|
| - record.attributeNamespace = original.attributeNamespace;
|
| - record.oldValue = original.oldValue;
|
| - return record;
|
| - };
|
| -
|
| - // We keep track of the two (possibly one) records used in a single mutation.
|
| - var currentRecord, recordWithOldValue;
|
| -
|
| - /**
|
| - * Creates a record without |oldValue| and caches it as |currentRecord| for
|
| - * later use.
|
| - * @param {string} oldValue
|
| - * @return {MutationRecord}
|
| - */
|
| - function getRecord(type, target) {
|
| - return currentRecord = new MutationRecord(type, target);
|
| - }
|
| -
|
| - /**
|
| - * Gets or creates a record with |oldValue| based in the |currentRecord|
|
| - * @param {string} oldValue
|
| - * @return {MutationRecord}
|
| - */
|
| - function getRecordWithOldValue(oldValue) {
|
| - if (recordWithOldValue)
|
| - return recordWithOldValue;
|
| - recordWithOldValue = copyMutationRecord(currentRecord);
|
| - recordWithOldValue.oldValue = oldValue;
|
| - return recordWithOldValue;
|
| - }
|
| -
|
| - function clearRecords() {
|
| - currentRecord = recordWithOldValue = undefined;
|
| - }
|
| -
|
| - /**
|
| - * @param {MutationRecord} record
|
| - * @return {boolean} Whether the record represents a record from the current
|
| - * mutation event.
|
| - */
|
| - function recordRepresentsCurrentMutation(record) {
|
| - return record === recordWithOldValue || record === currentRecord;
|
| - }
|
| -
|
| - /**
|
| - * Selects which record, if any, to replace the last record in the queue.
|
| - * This returns |null| if no record should be replaced.
|
| - *
|
| - * @param {MutationRecord} lastRecord
|
| - * @param {MutationRecord} newRecord
|
| - * @param {MutationRecord}
|
| - */
|
| - function selectRecord(lastRecord, newRecord) {
|
| - if (lastRecord === newRecord)
|
| - return lastRecord;
|
| -
|
| - // Check if the the record we are adding represents the same record. If
|
| - // so, we keep the one with the oldValue in it.
|
| - if (recordWithOldValue && recordRepresentsCurrentMutation(lastRecord))
|
| - return recordWithOldValue;
|
| -
|
| - return null;
|
| - }
|
| -
|
| - /**
|
| - * Class used to represent a registered observer.
|
| - * @param {MutationObserver} observer
|
| - * @param {Node} target
|
| - * @param {MutationObserverInit} options
|
| - * @constructor
|
| - */
|
| - function Registration(observer, target, options) {
|
| - this.observer = observer;
|
| - this.target = target;
|
| - this.options = options;
|
| - this.transientObservedNodes = [];
|
| - }
|
| -
|
| - Registration.prototype = {
|
| - enqueue: function(record) {
|
| - var records = this.observer.records_;
|
| - var length = records.length;
|
| -
|
| - // There are cases where we replace the last record with the new record.
|
| - // For example if the record represents the same mutation we need to use
|
| - // the one with the oldValue. If we get same record (this can happen as we
|
| - // walk up the tree) we ignore the new record.
|
| - if (records.length > 0) {
|
| - var lastRecord = records[length - 1];
|
| - var recordToReplaceLast = selectRecord(lastRecord, record);
|
| - if (recordToReplaceLast) {
|
| - records[length - 1] = recordToReplaceLast;
|
| - return;
|
| - }
|
| - } else {
|
| - scheduleCallback(this.observer);
|
| - }
|
| -
|
| - records[length] = record;
|
| - },
|
| -
|
| - addListeners: function() {
|
| - this.addListeners_(this.target);
|
| - },
|
| -
|
| - addListeners_: function(node) {
|
| - var options = this.options;
|
| - if (options.attributes)
|
| - node.addEventListener('DOMAttrModified', this, true);
|
| -
|
| - if (options.characterData)
|
| - node.addEventListener('DOMCharacterDataModified', this, true);
|
| -
|
| - if (options.childList)
|
| - node.addEventListener('DOMNodeInserted', this, true);
|
| -
|
| - if (options.childList || options.subtree)
|
| - node.addEventListener('DOMNodeRemoved', this, true);
|
| - },
|
| -
|
| - removeListeners: function() {
|
| - this.removeListeners_(this.target);
|
| - },
|
| -
|
| - removeListeners_: function(node) {
|
| - var options = this.options;
|
| - if (options.attributes)
|
| - node.removeEventListener('DOMAttrModified', this, true);
|
| -
|
| - if (options.characterData)
|
| - node.removeEventListener('DOMCharacterDataModified', this, true);
|
| -
|
| - if (options.childList)
|
| - node.removeEventListener('DOMNodeInserted', this, true);
|
| -
|
| - if (options.childList || options.subtree)
|
| - node.removeEventListener('DOMNodeRemoved', this, true);
|
| - },
|
| -
|
| - /**
|
| - * Adds a transient observer on node. The transient observer gets removed
|
| - * next time we deliver the change records.
|
| - * @param {Node} node
|
| - */
|
| - addTransientObserver: function(node) {
|
| - // Don't add transient observers on the target itself. We already have all
|
| - // the required listeners set up on the target.
|
| - if (node === this.target)
|
| - return;
|
| -
|
| - this.addListeners_(node);
|
| - this.transientObservedNodes.push(node);
|
| - var registrations = registrationsTable.get(node);
|
| - if (!registrations)
|
| - registrationsTable.set(node, registrations = []);
|
| -
|
| - // We know that registrations does not contain this because we already
|
| - // checked if node === this.target.
|
| - registrations.push(this);
|
| - },
|
| -
|
| - removeTransientObservers: function() {
|
| - var transientObservedNodes = this.transientObservedNodes;
|
| - this.transientObservedNodes = [];
|
| -
|
| - transientObservedNodes.forEach(function(node) {
|
| - // Transient observers are never added to the target.
|
| - this.removeListeners_(node);
|
| -
|
| - var registrations = registrationsTable.get(node);
|
| - for (var i = 0; i < registrations.length; i++) {
|
| - if (registrations[i] === this) {
|
| - registrations.splice(i, 1);
|
| - // Each node can only have one registered observer associated with
|
| - // this observer.
|
| - break;
|
| - }
|
| - }
|
| - }, this);
|
| - },
|
| -
|
| - handleEvent: function(e) {
|
| - // Stop propagation since we are managing the propagation manually.
|
| - // This means that other mutation events on the page will not work
|
| - // correctly but that is by design.
|
| - e.stopImmediatePropagation();
|
| -
|
| - switch (e.type) {
|
| - case 'DOMAttrModified':
|
| - // http://dom.spec.whatwg.org/#concept-mo-queue-attributes
|
| -
|
| - var name = e.attrName;
|
| - var namespace = e.relatedNode.namespaceURI;
|
| - var target = e.target;
|
| -
|
| - // 1.
|
| - var record = new getRecord('attributes', target);
|
| - record.attributeName = name;
|
| - record.attributeNamespace = namespace;
|
| -
|
| - // 2.
|
| - var oldValue =
|
| - e.attrChange === MutationEvent.ADDITION ? null : e.prevValue;
|
| -
|
| - forEachAncestorAndObserverEnqueueRecord(target, function(options) {
|
| - // 3.1, 4.2
|
| - if (!options.attributes)
|
| - return;
|
| -
|
| - // 3.2, 4.3
|
| - if (options.attributeFilter && options.attributeFilter.length &&
|
| - options.attributeFilter.indexOf(name) === -1 &&
|
| - options.attributeFilter.indexOf(namespace) === -1) {
|
| - return;
|
| - }
|
| - // 3.3, 4.4
|
| - if (options.attributeOldValue)
|
| - return getRecordWithOldValue(oldValue);
|
| -
|
| - // 3.4, 4.5
|
| - return record;
|
| - });
|
| -
|
| - break;
|
| -
|
| - case 'DOMCharacterDataModified':
|
| - // http://dom.spec.whatwg.org/#concept-mo-queue-characterdata
|
| - var target = e.target;
|
| -
|
| - // 1.
|
| - var record = getRecord('characterData', target);
|
| -
|
| - // 2.
|
| - var oldValue = e.prevValue;
|
| -
|
| -
|
| - forEachAncestorAndObserverEnqueueRecord(target, function(options) {
|
| - // 3.1, 4.2
|
| - if (!options.characterData)
|
| - return;
|
| -
|
| - // 3.2, 4.3
|
| - if (options.characterDataOldValue)
|
| - return getRecordWithOldValue(oldValue);
|
| -
|
| - // 3.3, 4.4
|
| - return record;
|
| - });
|
| -
|
| - break;
|
| -
|
| - case 'DOMNodeRemoved':
|
| - this.addTransientObserver(e.target);
|
| - // Fall through.
|
| - case 'DOMNodeInserted':
|
| - // http://dom.spec.whatwg.org/#concept-mo-queue-childlist
|
| - var target = e.relatedNode;
|
| - var changedNode = e.target;
|
| - var addedNodes, removedNodes;
|
| - if (e.type === 'DOMNodeInserted') {
|
| - addedNodes = [changedNode];
|
| - removedNodes = [];
|
| - } else {
|
| -
|
| - addedNodes = [];
|
| - removedNodes = [changedNode];
|
| - }
|
| - var previousSibling = changedNode.previousSibling;
|
| - var nextSibling = changedNode.nextSibling;
|
| -
|
| - // 1.
|
| - var record = getRecord('childList', target);
|
| - record.addedNodes = addedNodes;
|
| - record.removedNodes = removedNodes;
|
| - record.previousSibling = previousSibling;
|
| - record.nextSibling = nextSibling;
|
| -
|
| - forEachAncestorAndObserverEnqueueRecord(target, function(options) {
|
| - // 2.1, 3.2
|
| - if (!options.childList)
|
| - return;
|
| -
|
| - // 2.2, 3.3
|
| - return record;
|
| - });
|
| -
|
| - }
|
| -
|
| - clearRecords();
|
| - }
|
| - };
|
| -
|
| - global.MutationObserver = MutationObserver;
|
| -})(window);
|
| -
|
| -}
|
|
|