[DevTools] Move subtargets functionality from ServiceWorker to Target domain.

third_party/WebKit/Source/devtools/front_end/sdk/ServiceWorkerManager.js

 /*
  * Copyright (C) 2011 Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions are
  * met:
  *
  *     * Redistributions of source code must retain the above copyright
  * notice, this list of conditions and the following disclaimer.
  *     * Redistributions in binary form must reproduce the above
@@ skipping 14 matching lines @@
  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  */
 
 /**
  * @constructor
  * @extends {WebInspector.SDKObject}
  * @param {!WebInspector.Target} target
+ * @param {!WebInspector.SubTargetsManager} subTargetsManager
  */
-WebInspector.ServiceWorkerManager = function(target)
+WebInspector.ServiceWorkerManager = function(target, subTargetsManager)
 {
     WebInspector.SDKObject.call(this, target);
     target.registerServiceWorkerDispatcher(new WebInspector.ServiceWorkerDispatcher(this));
     this._lastAnonymousTargetId = 0;
+    this._subTargetsManager = subTargetsManager;
+    this._subTargetsManager.addEventListener(WebInspector.SubTargetsManager.Events.SubTargetsUpdated, this._updateAllContextLabels, this);
     this._agent = target.serviceWorkerAgent();
-    /** @type {!Map.<string, !WebInspector.ServiceWorker>} */
-    this._workers = new Map();
     /** @type {!Map.<string, !WebInspector.ServiceWorkerRegistration>} */
     this._registrations = new Map();
     this.enable();
     this._forceUpdateSetting = WebInspector.settings.createSetting("serviceWorkerUpdateOnReload", false);
     if (this._forceUpdateSetting.get())
         this._forceUpdateSettingChanged();
     this._forceUpdateSetting.addChangeListener(this._forceUpdateSettingChanged, this);
     WebInspector.targetManager.addModelListener(WebInspector.RuntimeModel, WebInspector.RuntimeModel.Events.ExecutionContextCreated, this._executionContextCreated, this);
 }
 
 /** @enum {symbol} */
 WebInspector.ServiceWorkerManager.Events = {
-    WorkersUpdated: Symbol("WorkersUpdated"),
     RegistrationUpdated: Symbol("RegistrationUpdated"),
     RegistrationErrorAdded: Symbol("RegistrationErrorAdded"),
     RegistrationDeleted: Symbol("RegistrationDeleted")
 }
 
+WebInspector.ServiceWorkerManager._VersionIdSymbol = Symbol("VersionId");
+
 WebInspector.ServiceWorkerManager.prototype = {
     enable: function()
     {
         if (this._enabled)
             return;
         this._enabled = true;
-
         this._agent.enable();
-        WebInspector.targetManager.addEventListener(WebInspector.TargetManager.Events.MainFrameNavigated, this._mainFrameNavigated, this);
     },
 
     disable: function()
     {
         if (!this._enabled)
             return;
         this._enabled = false;
-
-        for (var worker of this._workers.values())
-            worker._connection.close();
-        this._workers.clear();
         this._registrations.clear();
         this._agent.disable();
-        WebInspector.targetManager.removeEventListener(WebInspector.TargetManager.Events.MainFrameNavigated, this._mainFrameNavigated, this);
     },
 
     /**
-     * @return {!Iterable.<!WebInspector.ServiceWorker>}
-     */
-    workers: function()
-    {
-        return this._workers.values();
-    },
-
-    /**
      * @param {string} versionId
      * @return {?WebInspector.Target}
      */
     targetForVersionId: function(versionId)
     {
-        for (var pair of this._workers) {
-            if (pair[1]._versionId === versionId)
-                return pair[1]._target;
-        }
-        return null;
+        var version = this.findVersion(versionId);
+        if (!version || !version.targetId)
+            return null;
+        return this._subTargetsManager.targetForId(version.targetId);
     },
 
     /**
-     * @return {boolean}
+     * @param {!WebInspector.Target} target
+     * @return {?string}
      */
-    hasWorkers: function()
+    _versionIdForTarget: function(target)
     {
-        return !!this._workers.size;
+        return target[WebInspector.ServiceWorkerManager._VersionIdSymbol] || null;
     },
 
     /**
      * @return {!Map.<string, !WebInspector.ServiceWorkerRegistration>}
      */
     registrations: function()
     {
         return this._registrations;
     },
 
@@ skipping 62 matching lines @@
     dispatchSyncEvent: function(registrationId, tag, lastChance)
     {
         var registration = this._registrations.get(registrationId);
         if (!registration)
             return;
         var origin = WebInspector.ParsedURL.extractOrigin(registration.scopeURL);
         this._agent.dispatchSyncEvent(origin, registrationId, tag, lastChance);
     },
 
     /**
-     * @param {!ServiceWorkerAgent.TargetID} targetId
-     */
-    activateTarget: function(targetId)
-    {
-        this._agent.activateTarget(targetId);
-    },
-
-    /**
      * @param {string} scope
      */
     _unregister: function(scope)
     {
         this._agent.unregister(scope);
     },
 
     /**
      * @param {string} scope
      */
@@ skipping 20 matching lines @@
 
     /**
      * @param {string} versionId
      */
     inspectWorker: function(versionId)
     {
         this._agent.inspectWorker(versionId);
     },
 
     /**
-     * @param {!ServiceWorkerAgent.TargetID} targetId
-     * @param {function(?WebInspector.TargetInfo)=} callback
-     */
-    getTargetInfo: function(targetId, callback)
-    {
-        /**
-         * @param {?Protocol.Error} error
-         * @param {?ServiceWorkerAgent.TargetInfo} targetInfo
-         */
-        function innerCallback(error, targetInfo)
-        {
-            if (error) {
-                console.error(error);
-                callback(null);
-                return;
-            }
-            if (targetInfo)
-                callback(new WebInspector.TargetInfo(targetInfo));
-            else
-                callback(null)
-        }
-        this._agent.getTargetInfo(targetId, innerCallback);
-    },
-
-    /**
-     * @param {string} workerId
-     * @param {string} url
-     * @param {string} versionId
-     */
-    _workerCreated: function(workerId, url, versionId)
-    {
-        new WebInspector.ServiceWorker(this, workerId, url, versionId);
-        this._updateWorkerStatuses();
-    },
-
-    /**
-     * @param {string} workerId
-     */
-    _workerTerminated: function(workerId)
-    {
-        var worker = this._workers.get(workerId);
-        if (!worker)
-            return;
-
-        worker._closeConnection();
-        this._workers.delete(workerId);
-
-        this.dispatchEventToListeners(WebInspector.ServiceWorkerManager.Events.WorkersUpdated);
-    },
-
-    /**
-     * @param {string} workerId
-     * @param {string} message
-     */
-    _dispatchMessage: function(workerId, message)
-    {
-        var worker = this._workers.get(workerId);
-        if (worker)
-            worker._connection.dispatch(message);
-    },
-
-    /**
      * @param {!Array.<!ServiceWorkerAgent.ServiceWorkerRegistration>} registrations
      */
     _workerRegistrationUpdated: function(registrations)
     {
         for (var payload of registrations) {
             var registration = this._registrations.get(payload.registrationId);
             if (!registration) {
                 registration = new WebInspector.ServiceWorkerRegistration(payload);
                 this._registrations.set(payload.registrationId, registration);
                 this.dispatchEventToListeners(WebInspector.ServiceWorkerManager.Events.RegistrationUpdated, registration);
@@ skipping 14 matching lines @@
      * @param {!Array.<!ServiceWorkerAgent.ServiceWorkerVersion>} versions
      */
     _workerVersionUpdated: function(versions)
     {
         /** @type {!Set.<!WebInspector.ServiceWorkerRegistration>} */
         var registrations = new Set();
         for (var payload of versions) {
             var registration = this._registrations.get(payload.registrationId);
             if (!registration)
                 continue;
-            registration._updateVersion(payload);
+            var version = registration._updateVersion(payload);
+            var target = version.targetId ? this._subTargetsManager.targetForId(version.targetId) : null;
+            if (target)
+                target[WebInspector.ServiceWorkerManager._VersionIdSymbol] = version.id;
             registrations.add(registration);
         }
         for (var registration of registrations) {
             if (registration._shouldBeRemoved()) {
                 this._registrations.delete(registration.id);
                 this.dispatchEventToListeners(WebInspector.ServiceWorkerManager.Events.RegistrationDeleted, registration);
             } else {
                 this.dispatchEventToListeners(WebInspector.ServiceWorkerManager.Events.RegistrationUpdated, registration);
             }
         }
-        this._updateWorkerStatuses();
-    },
-
-    _updateWorkerStatuses: function()
-    {
-        /** @type {!Map<string, string>} */
-        var versionById = new Map();
-        for (var registration of this._registrations.valuesArray()) {
-            for (var version of registration.versions.valuesArray())
-                versionById.set(version.id, version.status);
-        }
-        for (var worker of this._workers.valuesArray()) {
-            var status = versionById.get(worker.versionId());
-            if (status)
-                worker.setStatus(status);
-        }
+        this._updateAllContextLabels();
     },
 
     /**
      * @param {!ServiceWorkerAgent.ServiceWorkerErrorMessage} payload
      */
     _workerErrorReported: function(payload)
     {
         var registration = this._registrations.get(payload.registrationId);
         if (!registration)
             return;
         registration.errors.push(payload);
         this.dispatchEventToListeners(WebInspector.ServiceWorkerManager.Events.RegistrationErrorAdded, { registration: registration, error: payload });
     },
 
     /**
-     * @param {!WebInspector.Event} event
-     */
-    _mainFrameNavigated: function(event)
-    {
-        // Attach to the new worker set.
-    },
-
-    /**
      * @return {!WebInspector.Setting}
      */
     forceUpdateOnReloadSetting: function()
     {
         return this._forceUpdateSetting;
     },
 
     _forceUpdateSettingChanged: function()
     {
         this._agent.setForceUpdateOnPageLoad(this._forceUpdateSetting.get());
     },
 
+    _updateAllContextLabels: function()
+    {
+        /** @type {!Map<string, string>} */
+        var statusByVersionId = new Map();
+        for (var registration of this._registrations.valuesArray()) {
+            for (var version of registration.versions.valuesArray()) {
+                var target = version.targetId ? this._subTargetsManager.targetForId(version.targetId) : null;
+                if (target)
+                    target[WebInspector.ServiceWorkerManager._VersionIdSymbol] = version.id;
+                statusByVersionId.set(version.id, version.status);
+            }
+        }
+
+        for (var target of WebInspector.targetManager.targets()) {
+            var versionId = this._versionForWorkerOfServiceWorkerTarget(target);
+            if (!versionId)
+                return;
+            var status = statusByVersionId.get(versionId) || "";
+            for (var context of target.runtimeModel.executionContexts())
+                this._updateContextLabel(context, versionId, status);
+        }
+    },
+
+    /**
+     * @param {!WebInspector.Target} target
+     * @return {?string}
+     */
+    _versionForWorkerOfServiceWorkerTarget: function(target)
+    {
+        var parent = target.parentTarget();
+        if (!parent || parent.parentTarget() !== this.target())
+            return null;
+        if (this._subTargetsManager.targetType(parent) !== TargetAgent.TargetType.Service_worker)
+            return null;
+        return this._versionIdForTarget(parent);
+    },
+
     /**
      * @param {!WebInspector.Event} event
      */
     _executionContextCreated: function(event)
     {
         var executionContext = /** @type {!WebInspector.ExecutionContext} */ (event.data);
-        var target = executionContext.target();
-        if (!target.parentTarget())
+        var versionId = this._versionForWorkerOfServiceWorkerTarget(executionContext.target());
+        if (!versionId)
             return;
-        var worker = target.parentTarget()[WebInspector.ServiceWorker.Symbol];
-        if (worker)
-            worker._setContextLabelFor(executionContext);
+        this._updateContextLabel(executionContext, versionId, this.findVersion(versionId).status);
+    },
+
+    /**
+     * @param {!WebInspector.ExecutionContext} context
+     * @param {string} versionId
+     * @param {string} status
+     */
+    _updateContextLabel: function(context, versionId, status)
+    {
+        var parsedUrl = context.origin.asParsedURL();
+        var label = parsedUrl ? parsedUrl.lastPathComponentWithFragment() : context.name;
+        if (status)
+            context.setLabel(label + " #" + versionId + " (" + status + ")");
+        else
+            context.setLabel(label);
     },
 
     __proto__: WebInspector.SDKObject.prototype
 }
 
 /**
- * @constructor
- * @param {!WebInspector.ServiceWorkerManager} manager
- * @param {string} workerId
- * @param {string} url
- * @param {string} versionId
- */
-WebInspector.ServiceWorker = function(manager, workerId, url, versionId)
-{
-    this._manager = manager;
-    this._agent = manager.target().serviceWorkerAgent();
-    this._workerId = workerId;
-    this._connection = new WebInspector.ServiceWorkerConnection(this._agent, workerId);
-    this._url = url;
-    this._versionId = versionId;
-    var parsedURL = url.asParsedURL();
-    this._name = parsedURL ? parsedURL.lastPathComponentWithFragment()  : "#" + (++WebInspector.ServiceWorker._lastAnonymousTargetId);
-    this._scope = parsedURL ? parsedURL.host + parsedURL.folderPathComponents : "";
-
-    this._manager._workers.set(workerId, this);
-    var capabilities =
-        WebInspector.Target.Capability.Log | WebInspector.Target.Capability.Network |
-        WebInspector.Target.Capability.Worker;
-    this._target = WebInspector.targetManager.createTarget(this._name, capabilities, this._connection, manager.target());
-    this._target[WebInspector.ServiceWorker.Symbol] = this;
-    this._manager.dispatchEventToListeners(WebInspector.ServiceWorkerManager.Events.WorkersUpdated);
-    this._target.runtimeAgent().runIfWaitingForDebugger();
-}
-
-WebInspector.ServiceWorker.Symbol = Symbol("serviceWorker");
-
-WebInspector.ServiceWorker._lastAnonymousTargetId = 0;
-
-WebInspector.ServiceWorker.prototype = {
-    /**
-     * @return {string}
-     */
-    name: function()
-    {
-        return this._name;
-    },
-
-    /**
-     * @return {string}
-     */
-    url: function()
-    {
-        return this._url;
-    },
-
-    /**
-     * @return {string}
-     */
-    versionId: function()
-    {
-        return this._versionId;
-    },
-
-    /**
-     * @return {string}
-     */
-    scope: function()
-    {
-        return this._scope;
-    },
-
-    stop: function()
-    {
-        this._agent.stop(this._workerId);
-    },
-
-    /** @param {string} status */
-    setStatus: function(status)
-    {
-        if (this._status === status)
-            return;
-        this._status = status;
-
-        for (var target of WebInspector.targetManager.targets()) {
-            if (target.parentTarget() !== this._target)
-                continue;
-            for (var context of target.runtimeModel.executionContexts())
-                this._setContextLabelFor(context);
-        }
-    },
-
-    /**
-     * @param {!WebInspector.ExecutionContext} context
-     */
-    _setContextLabelFor: function(context)
-    {
-        var parsedUrl = context.origin.asParsedURL();
-        var label = parsedUrl ? parsedUrl.lastPathComponentWithFragment() : context.name;
-        if (this._status)
-            context.setLabel(label + " #" + this._versionId + " (" + this._status + ")");
-        else
-            context.setLabel(label);
-    },
-
-    _closeConnection: function()
-    {
-        this._connection._close();
-        delete this._connection;
-    }
-}
-
-/**
  * @constructor
  * @implements {ServiceWorkerAgent.Dispatcher}
  * @param {!WebInspector.ServiceWorkerManager} manager
  */
 WebInspector.ServiceWorkerDispatcher = function(manager)
 {
     this._manager = manager;
 }
 
 WebInspector.ServiceWorkerDispatcher.prototype = {
     /**
      * @override
-     * @param {string} workerId
-     * @param {string} url
-     * @param {string} versionId
-     */
-    workerCreated: function(workerId, url, versionId)
-    {
-        this._manager._workerCreated(workerId, url, versionId);
-    },
-
-    /**
-     * @override
-     * @param {string} workerId
-     */
-    workerTerminated: function(workerId)
-    {
-        this._manager._workerTerminated(workerId);
-    },
-
-    /**
-     * @override
-     * @param {string} workerId
-     * @param {string} message
-     */
-    dispatchMessage: function(workerId, message)
-    {
-        this._manager._dispatchMessage(workerId, message);
-    },
-
-    /**
-     * @override
      * @param {!Array.<!ServiceWorkerAgent.ServiceWorkerRegistration>} registrations
      */
     workerRegistrationUpdated: function(registrations)
     {
         this._manager._workerRegistrationUpdated(registrations);
     },
 
     /**
      * @override
      * @param {!Array.<!ServiceWorkerAgent.ServiceWorkerVersion>} versions
      */
     workerVersionUpdated: function(versions)
     {
         this._manager._workerVersionUpdated(versions);
     },
 
     /**
      * @override
      * @param {!ServiceWorkerAgent.ServiceWorkerErrorMessage} errorMessage
      */
     workerErrorReported: function(errorMessage)
     {
         this._manager._workerErrorReported(errorMessage);
     }
 }
 
 /**
  * @constructor
- * @extends {InspectorBackendClass.Connection}
- * @param {!Protocol.ServiceWorkerAgent} agent
- * @param {string} workerId
- */
-WebInspector.ServiceWorkerConnection = function(agent, workerId)
-{
-    InspectorBackendClass.Connection.call(this);
-    // FIXME: remove resourceTreeModel and others from worker targets
-    this.suppressErrorsForDomains(["Worker", "Page", "CSS", "DOM", "DOMStorage", "Database", "Network", "IndexedDB"]);
-    this._agent = agent;
-    this._workerId = workerId;
-}
-
-WebInspector.ServiceWorkerConnection.prototype = {
-    /**
-     * @override
-     * @param {!Object} messageObject
-     */
-    sendMessage: function(messageObject)
-    {
-        this._agent.sendMessage(this._workerId, JSON.stringify(messageObject));
-    },
-
-    _close: function()
-    {
-        this.connectionClosed("worker_terminated");
-    },
-
-    __proto__: InspectorBackendClass.Connection.prototype
-}
-
-/**
- * @constructor
- * @param {!ServiceWorkerAgent.TargetInfo} payload
- */
-WebInspector.TargetInfo = function(payload)
-{
-    this.id = payload.id;
-    this.type = payload.type;
-    this.title = payload.title;
-    this.url = payload.url;
-}
-
-WebInspector.TargetInfo.prototype = {
-    /**
-     * @return {boolean}
-     */
-    isWebContents: function()
-    {
-        return this.type === "page";
-    },
-    /**
-     * @return {boolean}
-     */
-    isFrame: function()
-    {
-        return this.type === "frame";
-    },
-}
-
-/**
- * @constructor
  * @param {!WebInspector.ServiceWorkerRegistration} registration
  * @param {!ServiceWorkerAgent.ServiceWorkerVersion} payload
  */
 WebInspector.ServiceWorkerVersion = function(registration, payload)
 {
     this.registration = registration;
     this._update(payload);
 }
 
 /**
@@ skipping 16 matching lines @@
         this.scriptURL = payload.scriptURL;
         var parsedURL = new WebInspector.ParsedURL(payload.scriptURL);
         this.securityOrigin = parsedURL.securityOrigin();
         this.runningStatus = payload.runningStatus;
         this.status = payload.status;
         this.scriptLastModified = payload.scriptLastModified;
         this.scriptResponseTime = payload.scriptResponseTime;
         this.controlledClients = [];
         for (var i = 0; i < payload.controlledClients.length; ++i)
             this.controlledClients.push(payload.controlledClients[i]);
+        this.targetId = payload.targetId || null;
     },
 
     /**
      * @return {boolean}
      */
     isStartable: function()
     {
         return !this.registration.isDeleted && this.isActivated() && this.isStopped();
     },
 
@@ skipping 185 matching lines @@
     {
         return this._isRedundant() && (!this.errors.length || this._deleting);
     },
 
     clearErrors: function()
     {
         this._fingerprint = Symbol("fingerprint");
         this.errors = [];
     }
 }