Converted Observatory timeline-page element

runtime/bin/vmservice/server.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 vmservice_io;
 
 class WebSocketClient extends Client {
   static const int PARSE_ERROR_CODE = 4000;
   static const int BINARY_MESSAGE_ERROR_CODE = 4001;
   static const int NOT_MAP_ERROR_CODE = 4002;
@@ skipping 61 matching lines @@
     map['socket'] = '$socket';
     return map;
   }
 }
 
 
 class HttpRequestClient extends Client {
   static ContentType jsonContentType =
       new ContentType("application", "json", charset: "utf-8");
   final HttpRequest request;
+  final List<String> _allowedOrigins;
 
-  HttpRequestClient(this.request, VMService service)
+  HttpRequestClient(this.request, VMService service, this._allowedOrigins)
       : super(service, sendEvents:false);
 
   disconnect() {
     request.response.close();
     close();
   }
 
   void post(dynamic result) {
     if (result == null) {
       close();
       return;
     }
     HttpResponse response = request.response;
     response.headers.contentType = jsonContentType;
+    final uri = Uri.parse(request.headers['Origin']?.single ?? 'http://localhost');

[rmacnak, 2016/09/02 16:42:01]

Let's put this in a separate CL.

+    final noPortOrigin = new Uri(host: uri.host, scheme: uri.scheme).origin;
+    if (_allowedOrigins.contains(noPortOrigin)) {
+      response.headers.add('Access-Control-Allow-Origin', uri.origin);
+    }
     if (result is String) {
       response.write(result);
     } else {
       assert(result is List);
       Uint8List cstring = result[0];  // Already in UTF-8.
       response.add(cstring);
     }
     response.close();
     close();
   }
@@ skipping 124 matching lines @@
     if (asset != null) {
       // Serving up a static asset (e.g. .css, .html, .png).
       request.response.headers.contentType =
           ContentType.parse(asset.mimeType);
       request.response.add(asset.data);
       request.response.close();
       return;
     }
     // HTTP based service request.
     try {
-      var client = new HttpRequestClient(request, _service);
+      var client = new HttpRequestClient(request, _service, _allowedOrigins);
       var message = new Message.fromUri(client, request.uri);
       client.onMessage(null, message);
     } catch (e) {
       print('Unexpected error processing HTTP request uri: '
             '${request.uri}\n$e\n');
       rethrow;
     }
   }
 
   Future startup() {
@@ skipping 67 matching lines @@
       _notifyServerState("", 0);
       onServerAddressChange(null);
       return this;
     });
   }
 
 }
 
 void _notifyServerState(String ip, int port)
     native "VMServiceIO_NotifyServerState";