WebSocket client for VM service

runtime/bin/vmservice/vmservice_dartium.dart

 // Copyright (c) 2013, 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.
 
 library vmservice_dartium;
 
 import 'dart:isolate';
 import 'vmservice.dart';
 
 // The receive port that isolate startup / shutdown messages are delivered on.
 RawReceivePort _receivePort;
 // The receive port that service request messages are delivered on.
 RawReceivePort _requestPort;
 
 // The native method that is called to post the response back to DevTools.
 void postResponse(String response, int cookie) native "VMService_PostResponse";
 
-void handleRequest(service, String uri, cookie) {
-  var serviceRequest = new ServiceRequest();
-  var r = serviceRequest.parse(Uri.parse(uri));
-  if (r) {
-    var f = service.runningIsolates.route(serviceRequest);
-    assert(f != null);
-    f.then((_) {
-      postResponse(serviceRequest.response, cookie);
-    }).catchError((e) {
+void handleMessage(service, uri, cookie) {
+  var message = new Message.fromUri(uri);

[turnidge, 2013/12/11 17:56:07]

So dartium will not support the /ws clients yet, right?

[Cutch, 2013/12/12 22:37:42]

Correct but the Observatory in Dartium communicates via postMessage. I've gone
ahead and made a DartiumClient which will serve as a persistent client on
Dartium.

+  var client = new HttpRequestClient(request, service);
+  message.future.then((response) {
+    try {
+      postResponse(response, cookie);
+    } catch (_) {
       // Error posting response back to Dartium.
-    });
-    return;
-  }
-  postResponse(serviceRequest.response, cookie);
+    }
+  });
+  // Send message for processing.
+  service.route(message);
 }
 
 main() {
   // Create VmService.
   var service = new VMService();
   _receivePort = service.receivePort;
   _requestPort = new RawReceivePort((message) {
     if (message == null) {
       return;
     }
     if (message is! List) {
       return;
     }
     if (message.length != 2) {
       return;
     }
-    var uri = message[0];
-    if (uri is! String) {
+    if (message[0] is! String) {
       return;
     }
+    var uri = Uri.parse(message[0]);
     var cookie = message[1];
-    handleRequest(service, uri, cookie);
+    handleMessage(service, uri, cookie);
   });
 }