Allow Observatory to run as a hosted web service

runtime/bin/vmservice/client/lib/src/service/object.dart

 // Copyright (c) 2014, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 part of service;
 
 /// A [ServiceObject] is an object known to the VM service and is tied
 /// to an owning [Isolate].
 abstract class ServiceObject extends Observable {
   /// The owner of this [ServiceObject].  This can be an [Isolate], a
@@ skipping 359 matching lines @@
       'message': 'Could not decode JSON: $e',
     })));
   }
 
   /// Gets [id] as an [ObservableMap] from the service directly. If
   /// an error occurs, the future is completed as an error with a
   /// ServiceError or ServiceException. Therefore any chained then() calls
   /// will only receive a map encoding a valid ServiceObject.
   Future<ObservableMap> getAsMap(String id) {
     return getString(id).then((response) {
-      var map;
-      try {
-        map = _parseJSON(response);
-      } catch (e, st) {
-        print('Hit V8 bug.');
-        return _decodeError(e);
-      }
+      var map = _parseJSON(response);
       return _processMap(map);
     }).catchError((error) {
       // ServiceError, forward to VM's ServiceError stream.
       errors.add(error);
       return new Future.error(error);
     }, test: (e) => e is ServiceError).catchError((exception) {
       // ServiceException, forward to VM's ServiceException stream.
       exceptions.add(exception);
       return new Future.error(exception);
     }, test: (e) => e is ServiceException);
   }
 
   /// Get [id] as a [String] from the service directly. See [getAsMap].
   Future<String> getString(String id);
+  /// Force the VM to disconnect.
+  void disconnect();
+  /// Completes when the VM first connects.
+  Future get onConnect;
+  /// Completes when the VM disconnects or there was an error connecting.
+  Future get onDisconnect;
 
   void _update(ObservableMap map, bool mapIsRef) {
     if (mapIsRef) {
       return;
     }
     _loaded = true;
     version = map['version'];
     architecture = map['architecture'];
     uptime = map['uptime'];
     var dateInMillis = int.parse(map['date']);
@@ skipping 251 matching lines @@
 
   Future<ServiceObject> get(String id) {
     // Do not allow null ids or empty ids.
     assert(id != null && id != '');
     var obj = _cache[id];
     if (obj != null) {
       return obj.reload();
     }
     // Cache miss.  Get the object from the vm directly.
     return vm.getAsMap(relativeLink(id)).then((ObservableMap map) {
-        var obj = new ServiceObject._fromMap(this, map);
-        if (obj.canCache) {
-          _cache.putIfAbsent(id, () => obj);
-        }
-        return obj;
-      });
+      var obj = new ServiceObject._fromMap(this, map);
+      if (obj.canCache) {
+        _cache.putIfAbsent(id, () => obj);
+      }
+      return obj;
+    });
   }
 
   @observable Class objectClass;
   @observable final rootClasses = new ObservableList<Class>();
 
   @observable Library rootLib;
   @observable ObservableList<Library> libraries =
       new ObservableList<Library>();
   @observable ObservableMap topFrame;
 
@@ skipping 1152 matching lines @@
     var v = list[i];
     if ((v is ObservableMap) && _isServiceMap(v)) {
       list[i] = owner.getFromMap(v);
     } else if (v is ObservableList) {
       _upgradeObservableList(v, owner);
     } else if (v is ObservableMap) {
       _upgradeObservableMap(v, owner);
     }
   }
 }