[DevTools] Refactor connection-related classes.

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

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 /**
  * @constructor
  * @extends {WebInspector.SDKModel}
  * @param {!WebInspector.Target} target
  */
 WebInspector.SubTargetsManager = function(target)
 {
     WebInspector.SDKModel.call(this, WebInspector.SubTargetsManager, target);
     target.registerTargetDispatcher(new WebInspector.SubTargetsDispatcher(this));
     this._lastAnonymousTargetId = 0;
     this._agent = target.targetAgent();
 
     /** @type {!Map<string, !WebInspector.Target>} */
     this._attachedTargets = new Map();
-    /** @type {!Map<string, !WebInspector.SubTargetConnection>} */
-    this._connections = new Map();
+    /** @type {!Map<string, !WebInspector.SubTargetChannel>} */
+    this._channels = new Map();
 
     this._agent.setAutoAttach(true /* autoAttach */, true /* waitForDebuggerOnStart */);
     this._agent.setAttachToFrames(Runtime.experiments.isEnabled("autoAttachToCrossProcessSubframes"));
 
     if (Runtime.experiments.isEnabled("nodeDebugging") && !target.parentTarget()) {
         var defaultLocations = [{host: "localhost", port: 9229}];
         this._agent.setRemoteLocations(defaultLocations);
         this._agent.setDiscoverTargets(true);
     }
 }
@@ skipping 29 matching lines @@
         var promise = new Promise(f => fulfill = f);
         this._agent.setAutoAttach(true /* autoAttach */, true /* waitForDebuggerOnStart */, fulfill);
         return promise;
     },
 
     /**
      * @override
      */
     dispose: function()
     {
-        for (var connection of this._connections.values())
-            connection.close();
-        this._connections.clear();
+        for (var channel of this._channels.values())
+            channel._detach();
+        this._channels.clear();
         this._attachedTargets.clear();
     },
 
     /**
      * @param {!TargetAgent.TargetID} targetId
      */
     activateTarget: function(targetId)
     {
         this._agent.activateTarget(targetId);
     },
@@ skipping 59 matching lines @@
             return WebInspector.Target.Capability.JS;
         return 0;
     },
 
     /**
      * @param {!WebInspector.TargetInfo} targetInfo
      * @param {boolean} waitingForDebugger
      */
     _attachedToTarget: function(targetInfo, waitingForDebugger)
     {
-        var connection = new WebInspector.SubTargetConnection(this._agent, targetInfo.id);
-        this._connections.set(targetInfo.id, connection);
+        var channel = new WebInspector.SubTargetChannel(this._agent, targetInfo.id);
+        this._channels.set(targetInfo.id, channel);
 
         var targetName = "";
         if (targetInfo.type === "node") {
             targetName = targetInfo.title;
         } else if (targetInfo.type !== "iframe") {
             var parsedURL = targetInfo.url.asParsedURL();
             targetName = parsedURL ? parsedURL.lastPathComponentWithFragment() : "#" + (++this._lastAnonymousTargetId);
         }
-        var target = WebInspector.targetManager.createTarget(targetName, this._capabilitiesForType(targetInfo.type), connection, this.target());
+        var target = WebInspector.targetManager.createTarget(targetName, this._capabilitiesForType(targetInfo.type), channel, this.target());
         target[WebInspector.SubTargetsManager._InfoSymbol] = targetInfo;
         this._attachedTargets.set(targetInfo.id, target);
 
         // Only pause new worker if debugging SW - we are going through the pause on start checkbox.
         var mainIsServiceWorker = !this.target().parentTarget() && this.target().hasWorkerCapability() && !this.target().hasBrowserCapability();
         if (mainIsServiceWorker && waitingForDebugger)
             target.debuggerAgent().pause();
         target.runtimeAgent().runIfWaitingForDebugger();
 
         this.dispatchEventToListeners(WebInspector.SubTargetsManager.Events.SubTargetAdded, target);
     },
 
     /**
      * @param {string} targetId
      */
     _detachedFromTarget: function(targetId)
     {
-        var connection = this._connections.get(targetId);
-        if (connection)
-            connection._reportClosed();
-        this._connections.delete(targetId);
         var target = this._attachedTargets.get(targetId);
         this._attachedTargets.delete(targetId);
         this.dispatchEventToListeners(WebInspector.SubTargetsManager.Events.SubTargetRemoved, target);
+        var channel = this._channels.get(targetId);
+        if (channel)
+            channel._channelClosed();
+        this._channels.delete(targetId);
     },
 
     /**
      * @param {string} targetId
      * @param {string} message
      */
     _receivedMessageFromTarget: function(targetId, message)
     {
-        var connection = this._connections.get(targetId);
-        if (connection)
-            connection.dispatch(message);
+        var channel = this._channels.get(targetId);
+        if (channel)
+            channel.dispatchEventToListeners(InspectorBackendClass.Channel.Events.MessageReceived, message);
     },
 
     /**
      * @param {!WebInspector.TargetInfo} targetInfo
      */
     _targetCreated: function(targetInfo)
     {
         if (targetInfo.type !== "node")
             return;
         this._agent.attachToTarget(targetInfo.id);
@@ skipping 64 matching lines @@
      * @param {string} message
      */
     receivedMessageFromTarget: function(targetId, message)
     {
         this._manager._receivedMessageFromTarget(targetId, message);
     }
 }
 
 /**
  * @constructor
- * @extends {InspectorBackendClass.Connection}
+ * @extends {WebInspector.Object}
+ * @implements {InspectorBackendClass.Channel}
  * @param {!Protocol.TargetAgent} agent
  * @param {string} targetId
  */
-WebInspector.SubTargetConnection = function(agent, targetId)
+WebInspector.SubTargetChannel = function(agent, targetId)
 {
-    InspectorBackendClass.Connection.call(this);
+    WebInspector.Object.call(this);
     this._agent = agent;
     this._targetId = targetId;
 }
 
-WebInspector.SubTargetConnection.prototype = {
+WebInspector.SubTargetChannel.prototype = {
     /**
      * @override
-     * @param {!Object} messageObject
+     * @param {string} message
      */
-    sendMessage: function(messageObject)
+    sendMessage: function(message)
     {
-        this._agent.sendMessageToTarget(this._targetId, JSON.stringify(messageObject));
+        this._agent.sendMessageToTarget(this._targetId, message);
     },
 
     /**
      * @override
+     * @param {function()} callback
      */
-    forceClose: function()
+    reconnect: function(callback)
+    {
+        throw new Error("Not implemented");
+    },
+
+    _detach: function()
     {
         this._agent.detachFromTarget(this._targetId);
+        this._channelClosed();
     },
 
-    _reportClosed: function()
+    _channelClosed: function()
     {
-        this.connectionClosed("target_terminated");
+        this.dispatchEventToListeners(InspectorBackendClass.Channel.Events.ChannelClosed, "target terminated");
     },
 
-    __proto__: InspectorBackendClass.Connection.prototype
+    __proto__: WebInspector.Object.prototype
 }
 
 /**
  * @constructor
  * @param {!TargetAgent.TargetInfo} payload
  */
 WebInspector.TargetInfo = function(payload)
 {
     this.id = payload.targetId;
     this.url = payload.url;
     this.type = payload.type;
     if (this.type !== "page" && this.type !== "iframe") {
         this.title = WebInspector.UIString("Worker: %s", this.url);
         this.canActivate = false;
     } else {
         this.title = payload.title;
         this.canActivate = true;
     }
 }