[Telemetry] Reorganize everything.

tools/telemetry/telemetry/tab_list_backend.py

Index: tools/telemetry/telemetry/tab_list_backend.py
diff --git a/tools/telemetry/telemetry/tab_list_backend.py b/tools/telemetry/telemetry/tab_list_backend.py
deleted file mode 100644
index 9b4c78498c880d148f37251049d0a20b13bd7f72..0000000000000000000000000000000000000000
--- a/tools/telemetry/telemetry/tab_list_backend.py
+++ /dev/null
@@ -1,145 +0,0 @@
-# Copyright (c) 2012 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.
-import httplib
-import json
-import socket
-import urllib2
-import weakref
-
-from telemetry import browser_gone_exception
-from telemetry import tab
-from telemetry import inspector_backend
-from telemetry import util
-
-class TabListBackend(object):
-  def __init__(self, browser_backend):
-    self._browser_backend = browser_backend
-
-    # Stores web socket debugger URLs in iteration order.
-    self._tab_list = []
-    # Maps debugger URLs to Tab objects.
-    self._tab_dict = weakref.WeakValueDictionary()
-
-  def Init(self):
-    self._UpdateTabList()
-
-  def Reset(self):
-    # TODO(hartmanng): Remove this method when crbug.com/166886 is fixed.
-    self.Init()
-    self._tab_list = []
-    self._tab_dict = weakref.WeakValueDictionary()
-
-  def New(self, timeout):
-    assert self._browser_backend.supports_tab_control
-
-    self._browser_backend.Request('new', timeout=timeout)
-    return self[-1]
-
-  def DoesDebuggerUrlExist(self, url):
-    self._UpdateTabList()
-    return url in self._tab_list
-
-  def CloseTab(self, debugger_url, timeout=None):
-    assert self._browser_backend.supports_tab_control
-
-    # TODO(dtu): crbug.com/160946, allow closing the last tab on some platforms.
-    # For now, just create a new tab before closing the last tab.
-    if len(self) <= 1:
-      self.New(timeout)
-
-    tab_id = debugger_url.split('/')[-1]
-    try:
-      response = self._browser_backend.Request('close/%s' % tab_id,
-                                               timeout=timeout)
-    except urllib2.HTTPError:
-      raise Exception('Unable to close tab, tab id not found: %s' % tab_id)
-    assert response == 'Target is closing'
-
-    util.WaitFor(lambda: not self._FindTabInfo(debugger_url), timeout=5)
-
-    if debugger_url in self._tab_dict:
-      del self._tab_dict[debugger_url]
-    self._UpdateTabList()
-
-  def ActivateTab(self, debugger_url, timeout=None):
-    assert self._browser_backend.supports_tab_control
-
-    assert debugger_url in self._tab_dict
-    tab_id = debugger_url.split('/')[-1]
-    try:
-      response = self._browser_backend.Request('activate/%s' % tab_id,
-                                               timeout=timeout)
-    except urllib2.HTTPError:
-      raise Exception('Unable to activate tab, tab id not found: %s' % tab_id)
-    assert response == 'Target activated'
-
-  def GetTabUrl(self, debugger_url):
-    tab_info = self._FindTabInfo(debugger_url)
-    # TODO(hartmanng): crbug.com/166886 (uncomment the following assert and
-    # remove the extra None check when _ListTabs is fixed):
-    # assert tab_info is not None
-    if tab_info is None:
-      return None
-    return tab_info['url']
-
-  def __iter__(self):
-    self._UpdateTabList()
-    return self._tab_list.__iter__()
-
-  def __len__(self):
-    self._UpdateTabList()
-    return len(self._tab_list)
-
-  def Get(self, index, ret):
-    """Returns self[index] if it exists, or ret if index is out of bounds.
-    """
-    self._UpdateTabList()
-    if len(self._tab_list) <= index:
-      return ret
-    debugger_url = self._tab_list[index]
-    # Lazily get/create a Tab object.
-    tab_object = self._tab_dict.get(debugger_url)
-    if not tab_object:
-      backend = inspector_backend.InspectorBackend(
-          self._browser_backend.browser,
-          self._browser_backend,
-          debugger_url)
-      tab_object = tab.Tab(backend)
-      self._tab_dict[debugger_url] = tab_object
-    return tab_object
-
-  def __getitem__(self, index):
-    tab_object = self.Get(index, None)
-    if tab_object is None:
-      raise IndexError('list index out of range')
-    return tab_object
-
-  def _ListTabs(self, timeout=None):
-    try:
-      data = self._browser_backend.Request('', timeout=timeout)
-      all_contexts = json.loads(data)
-      tabs = [ctx for ctx in all_contexts
-              if not ctx['url'].startswith('chrome-extension://')]
-      return tabs
-    except (socket.error, httplib.BadStatusLine, urllib2.URLError):
-      if not self._browser_backend.IsBrowserRunning():
-        raise browser_gone_exception.BrowserGoneException()
-      raise browser_gone_exception.BrowserConnectionGoneException()
-
-  def _UpdateTabList(self):
-    def GetDebuggerUrl(tab_info):
-      if 'webSocketDebuggerUrl' not in tab_info:
-        return None
-      return tab_info['webSocketDebuggerUrl']
-    new_tab_list = map(GetDebuggerUrl, self._ListTabs())
-    self._tab_list = [t for t in self._tab_list
-                      if t in self._tab_dict or t in new_tab_list]
-    self._tab_list += [t for t in new_tab_list
-                       if t is not None and t not in self._tab_list]
-
-  def _FindTabInfo(self, debugger_url):
-    for tab_info in self._ListTabs():
-      if tab_info.get('webSocketDebuggerUrl') == debugger_url:
-        return tab_info
-    return None