OLD | NEW |
1 // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file |
2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
4 | 4 |
5 import 'dart:async'; | 5 import 'dart:async'; |
6 import 'dart:io'; | 6 import 'dart:io'; |
7 | 7 |
8 import 'package:path/path.dart' as path; | 8 import 'package:path/path.dart' as path; |
9 import 'package:json_rpc_2/json_rpc_2.dart' as json_rpc; | 9 import 'package:json_rpc_2/json_rpc_2.dart' as json_rpc; |
10 import 'package:web_socket_channel/web_socket_channel.dart'; | 10 import 'package:web_socket_channel/web_socket_channel.dart'; |
(...skipping 10 matching lines...) Expand all Loading... |
21 /// This is a [JSON-RPC 2.0](http://www.jsonrpc.org/specification) server. Its | 21 /// This is a [JSON-RPC 2.0](http://www.jsonrpc.org/specification) server. Its |
22 /// methods are described in the method-level documentation below. | 22 /// methods are described in the method-level documentation below. |
23 class WebSocketApi { | 23 class WebSocketApi { |
24 final AssetEnvironment _environment; | 24 final AssetEnvironment _environment; |
25 final json_rpc.Server _server; | 25 final json_rpc.Server _server; |
26 | 26 |
27 /// Whether the application should exit when this connection closes. | 27 /// Whether the application should exit when this connection closes. |
28 bool _exitOnClose = false; | 28 bool _exitOnClose = false; |
29 | 29 |
30 WebSocketApi(WebSocketChannel socket, this._environment) | 30 WebSocketApi(WebSocketChannel socket, this._environment) |
31 : _server = new json_rpc.Server(socket) { | 31 : _server = new json_rpc.Server(socket.cast()) { |
32 _server.registerMethod("urlToAssetId", _urlToAssetId); | 32 _server.registerMethod("urlToAssetId", _urlToAssetId); |
33 _server.registerMethod("pathToUrls", _pathToUrls); | 33 _server.registerMethod("pathToUrls", _pathToUrls); |
34 _server.registerMethod("serveDirectory", _serveDirectory); | 34 _server.registerMethod("serveDirectory", _serveDirectory); |
35 _server.registerMethod("unserveDirectory", _unserveDirectory); | 35 _server.registerMethod("unserveDirectory", _unserveDirectory); |
36 | 36 |
37 /// Tells the server to exit as soon as this WebSocket connection is closed. | 37 /// Tells the server to exit as soon as this WebSocket connection is closed. |
38 /// | 38 /// |
39 /// This takes no arguments and returns no results. It can safely be called | 39 /// This takes no arguments and returns no results. It can safely be called |
40 /// as a JSON-RPC notification. | 40 /// as a JSON-RPC notification. |
41 _server.registerMethod("exitOnClose", () { | 41 _server.registerMethod("exitOnClose", () { |
(...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
109 return _environment.getAssetIdForUrl(url).then((id) { | 109 return _environment.getAssetIdForUrl(url).then((id) { |
110 if (id == null) { | 110 if (id == null) { |
111 throw new json_rpc.RpcException(_Error.NOT_SERVED, | 111 throw new json_rpc.RpcException(_Error.NOT_SERVED, |
112 '"${url.host}:${url.port}" is not being served by pub.'); | 112 '"${url.host}:${url.port}" is not being served by pub.'); |
113 } | 113 } |
114 | 114 |
115 // TODO(rnystrom): When this is hooked up to actually talk to barback to | 115 // TODO(rnystrom): When this is hooked up to actually talk to barback to |
116 // see if assets exist, consider supporting implicit index.html at that | 116 // see if assets exist, consider supporting implicit index.html at that |
117 // point. | 117 // point. |
118 | 118 |
119 var result = {"package": id.package, "path": id.path}; | 119 var result = <String, Object>{"package": id.package, "path": id.path}; |
120 | 120 |
121 // Map the line. | 121 // Map the line. |
122 // TODO(rnystrom): Right now, source maps are not supported and it just | 122 // TODO(rnystrom): Right now, source maps are not supported and it just |
123 // passes through the original line. This lets the editor start using | 123 // passes through the original line. This lets the editor start using |
124 // this API before we've fully implemented it. See #12339 and #16061. | 124 // this API before we've fully implemented it. See #12339 and #16061. |
125 if (line != null) result["line"] = line; | 125 if (line != null) result["line"] = line; |
126 | 126 |
127 return result; | 127 return result; |
128 }); | 128 }); |
129 } | 129 } |
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
181 Future<Map> _pathToUrls(json_rpc.Parameters params) { | 181 Future<Map> _pathToUrls(json_rpc.Parameters params) { |
182 var assetPath = params["path"].asString; | 182 var assetPath = params["path"].asString; |
183 var line = params["line"].asIntOr(null); | 183 var line = params["line"].asIntOr(null); |
184 | 184 |
185 return _environment.getUrlsForAssetPath(assetPath).then((urls) { | 185 return _environment.getUrlsForAssetPath(assetPath).then((urls) { |
186 if (urls.isEmpty) { | 186 if (urls.isEmpty) { |
187 throw new json_rpc.RpcException(_Error.NOT_SERVED, | 187 throw new json_rpc.RpcException(_Error.NOT_SERVED, |
188 'Asset path "$assetPath" is not currently being served.'); | 188 'Asset path "$assetPath" is not currently being served.'); |
189 } | 189 } |
190 | 190 |
191 var result = {"urls": urls.map((url) => url.toString()).toList()}; | 191 var result = <String, Object>{ |
| 192 "urls": urls.map((url) => url.toString()).toList() |
| 193 }; |
192 | 194 |
193 // Map the line. | 195 // Map the line. |
194 // TODO(rnystrom): Right now, source maps are not supported and it just | 196 // TODO(rnystrom): Right now, source maps are not supported and it just |
195 // passes through the original line. This lets the editor start using | 197 // passes through the original line. This lets the editor start using |
196 // this API before we've fully implemented it. See #12339 and #16061. | 198 // this API before we've fully implemented it. See #12339 and #16061. |
197 if (line != null) result["line"] = line; | 199 if (line != null) result["line"] = line; |
198 | 200 |
199 return result; | 201 return result; |
200 }); | 202 }); |
201 } | 203 } |
(...skipping 96 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
298 } | 300 } |
299 | 301 |
300 /// The pub-specific JSON RPC error codes. | 302 /// The pub-specific JSON RPC error codes. |
301 class _Error { | 303 class _Error { |
302 /// The specified directory is not being served. | 304 /// The specified directory is not being served. |
303 static const NOT_SERVED = 1; | 305 static const NOT_SERVED = 1; |
304 | 306 |
305 /// The specified directory overlaps one or more ones already being served. | 307 /// The specified directory overlaps one or more ones already being served. |
306 static const OVERLAPPING = 2; | 308 static const OVERLAPPING = 2; |
307 } | 309 } |
OLD | NEW |