Code coverage in Observatory

runtime/bin/vmservice/client/lib/src/observatory/request_manager.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.
 
 part of observatory;
 
 /// A request response interceptor is called for each response.
 typedef void RequestResponseInterceptor();
 
 abstract class RequestManager extends Observable {
@@ skipping 84 matching lines @@
 
   static String isolateIdFromRequest(String url) {
     var prefix = isolatePrefixFromRequest(url);
     if (prefix == null) {
       return null;
     }
     // Chop off the '/'.
     return prefix.substring(1);
   }
 
+  static final RegExp _scriptMatcher = new RegExp(r'/isolates/\d+/scripts/.+');
+  static bool isScriptRequest(url) => _scriptMatcher.hasMatch(url);
+  static final RegExp _scriptPrefixMatcher =
+      new RegExp(r'/isolates/\d+/');
+  static String scriptUrlFromRequest(String url) {
+    var m = _scriptPrefixMatcher.matchAsPrefix(url);
+    if (m == null) {
+      return null;
+    }
+    return m.input.substring(m.end);
+  }
+
   void _setModelResponse(String type, String modelName, dynamic model) {
     var response = {
       'type': type,
       modelName: model
     };
     setResponses([response]);
   }
 
   /// Handle 'Code' requests
   void _getCode(String requestString) {
@@ skipping 26 matching lines @@
       }
       assert(map['type'] == 'Code');
       var code = new Code.fromMap(map);
       Logger.root.info(
           'Added code with 0x${address.toRadixString(16)} to isolate.');
       isolate.codes.add(code);
       _setModelResponse('Code', 'code', code);
     }).catchError(_requestCatchError);
   }
 
+  void _getScript(String requestString) {
+    var isolateId = isolateIdFromRequest(requestString);
+    if (isolateId == null) {
+      setResponseError('$isolateId is not an isolate id.');
+      return;
+    }
+    var isolate = _application.isolateManager.getIsolate(isolateId);
+    if (isolate == null) {
+      setResponseError('$isolateId could not be found.');
+      return;
+    }
+    var url = scriptUrlFromRequest(requestString);
+    if (url == null) {
+      setResponseError('$requestString is not a valid script request.');
+      return;
+    }
+    var script = isolate.scripts[url];
+    if ((script != null) && !script.needsSource) {
+      Logger.root.info('Found script ${script.scriptRef['name']} in isolate');
+      _setModelResponse('Script', 'script', script);
+      return;
+    }
+    if (script != null) {
+      // The isolate has the script but no script source code.
+      requestMap(requestString).then((response) {
+        assert(response['type'] == 'Script');
+        script._processSource(response['source']);
+        Logger.root.info(
+            'Grabbed script ${script.scriptRef['name']} source.');
+        _setModelResponse('Script', 'script', script);
+      });
+      return;
+    }
+    // New script.
+    requestMap(requestString).then((response) {
+      assert(response['type'] == 'Script');
+      var script = new Script.fromMap(response);
+      Logger.root.info(
+          'Added script ${script.scriptRef['name']} to isolate.');
+      _setModelResponse('Script', 'script', script);
+      isolate.scripts[url] = script;
+    });
+  }
+
   void _requestCatchError(e, st) {
     if (e is HttpRequest) {
       setResponseRequestError(e.target);
     } else {
       setResponseError('$e $st');
     }
   }
 
   /// Request [request] from the VM service. Updates [responses].
   /// Will trigger [interceptor] if one is set.
   void get(String requestString) {
     if (isCodeRequest(requestString)) {
       _getCode(requestString);
       return;
     }
+    if (isScriptRequest(requestString)) {
+      _getScript(requestString);
+      return;
+    }
     request(requestString).then((responseString) {
       parseResponses(responseString);
     }).catchError(_requestCatchError);
   }
 
   /// Abstract method. Given the [requestString], return a String in the
   /// future which contains the reply from the VM service.
   Future<String> request(String requestString);
 
   Future<Map> requestMap(String requestString) {
@@ skipping 48 matching lines @@
     message['query'] = requestString;
     _requestSerial++;
 
     var completer = new Completer();
     _outstandingRequests[idString] = completer;
 
     window.parent.postMessage(JSON.encode(message), '*');
     return completer.future;
   }
 }