Index: runtime/bin/vmservice/message.dart |
diff --git a/runtime/bin/vmservice/message.dart b/runtime/bin/vmservice/message.dart |
deleted file mode 100644 |
index 9dce2a1d2b6bf23d3adb239c3711230d3670e704..0000000000000000000000000000000000000000 |
--- a/runtime/bin/vmservice/message.dart |
+++ /dev/null |
@@ -1,82 +0,0 @@ |
-// 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; |
- |
-class Message { |
- final Completer _completer = new Completer.sync(); |
- bool get completed => _completer.isCompleted; |
- /// Future of response. |
- Future<String> get response => _completer.future; |
- /// Path. |
- final List<String> path = new List<String>(); |
- /// Options. |
- final Map<String, String> options = new Map<String, String>(); |
- |
- void _setPath(List<String> pathSegments) { |
- if (pathSegments == null) { |
- return; |
- } |
- pathSegments.forEach((String segment) { |
- if (segment == null || segment == '') { |
- return; |
- } |
- path.add(segment); |
- }); |
- } |
- |
- Message.fromUri(Uri uri) { |
- var split = uri.path.split('/'); |
- if (split.length == 0) { |
- setErrorResponse('Invalid uri: $uri.'); |
- return; |
- } |
- _setPath(split); |
- options.addAll(uri.queryParameters); |
- } |
- |
- Message.fromMap(Map map) { |
- _setPath(map['path']); |
- if (map['options'] != null) { |
- options.addAll(map['options']); |
- } |
- } |
- |
- dynamic toJson() { |
- return { |
- 'path': path, |
- 'options': options |
- }; |
- } |
- |
- Future<String> send(SendPort sendPort) { |
- final receivePort = new RawReceivePort(); |
- receivePort.handler = (value) { |
- receivePort.close(); |
- if (value is Exception) { |
- _completer.completeError(value); |
- } else { |
- _completer.complete(value); |
- } |
- }; |
- var keys = options.keys.toList(); |
- var values = options.values.toList(); |
- var request = [receivePort.sendPort, path, keys, values]; |
- sendServiceMessage(sendPort, request); |
- return _completer.future; |
- } |
- |
- void setResponse(String response) { |
- _completer.complete(response); |
- } |
- |
- void setErrorResponse(String error) { |
- _completer.complete(JSON.encode({ |
- 'type': 'Error', |
- 'msg': error, |
- 'path': path, |
- 'options': options |
- })); |
- } |
-} |