OLD | NEW |
1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2013, 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 part of dart.io; | 5 part of dart.io; |
6 | 6 |
7 const String _webSocketGUID = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11"; | 7 const String _webSocketGUID = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11"; |
8 | 8 |
9 // Matches _WebSocketOpcode. | 9 // Matches _WebSocketOpcode. |
10 class _WebSocketMessageType { | 10 class _WebSocketMessageType { |
(...skipping 757 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
768 Timer _closeTimer; | 768 Timer _closeTimer; |
769 | 769 |
770 static final HttpClient _httpClient = new HttpClient(); | 770 static final HttpClient _httpClient = new HttpClient(); |
771 | 771 |
772 static Future<WebSocket> connect( | 772 static Future<WebSocket> connect( |
773 String url, Iterable<String> protocols, Map<String, dynamic> headers) { | 773 String url, Iterable<String> protocols, Map<String, dynamic> headers) { |
774 Uri uri = Uri.parse(url); | 774 Uri uri = Uri.parse(url); |
775 if (uri.scheme != "ws" && uri.scheme != "wss") { | 775 if (uri.scheme != "ws" && uri.scheme != "wss") { |
776 throw new WebSocketException("Unsupported URL scheme '${uri.scheme}'"); | 776 throw new WebSocketException("Unsupported URL scheme '${uri.scheme}'"); |
777 } | 777 } |
778 if (uri.userInfo != "") { | |
779 throw new WebSocketException("Unsupported user info '${uri.userInfo}'"); | |
780 } | |
781 | 778 |
782 Random random = new Random(); | 779 Random random = new Random(); |
783 // Generate 16 random bytes. | 780 // Generate 16 random bytes. |
784 Uint8List nonceData = new Uint8List(16); | 781 Uint8List nonceData = new Uint8List(16); |
785 for (int i = 0; i < 16; i++) { | 782 for (int i = 0; i < 16; i++) { |
786 nonceData[i] = random.nextInt(256); | 783 nonceData[i] = random.nextInt(256); |
787 } | 784 } |
788 String nonce = _CryptoUtils.bytesToBase64(nonceData); | 785 String nonce = _CryptoUtils.bytesToBase64(nonceData); |
789 | 786 |
790 uri = new Uri(scheme: uri.scheme == "wss" ? "https" : "http", | 787 uri = new Uri(scheme: uri.scheme == "wss" ? "https" : "http", |
791 userInfo: uri.userInfo, | 788 userInfo: uri.userInfo, |
792 host: uri.host, | 789 host: uri.host, |
793 port: uri.port, | 790 port: uri.port, |
794 path: uri.path, | 791 path: uri.path, |
795 query: uri.query, | 792 query: uri.query, |
796 fragment: uri.fragment); | 793 fragment: uri.fragment); |
797 return _httpClient.openUrl("GET", uri) | 794 return _httpClient.openUrl("GET", uri) |
798 .then((request) { | 795 .then((request) { |
| 796 if (uri.userInfo != null && !uri.userInfo.isEmpty) { |
| 797 // If the URL contains user information use that for basic |
| 798 // authorization. |
| 799 String auth = |
| 800 _CryptoUtils.bytesToBase64(UTF8.encode(uri.userInfo)); |
| 801 request.headers.set(HttpHeaders.AUTHORIZATION, "Basic $auth"); |
| 802 } |
799 if (headers != null) { | 803 if (headers != null) { |
800 headers.forEach((field, value) => request.headers.add(field, value)); | 804 headers.forEach((field, value) => request.headers.add(field, value)); |
801 } | 805 } |
802 // Setup the initial handshake. | 806 // Setup the initial handshake. |
803 request.headers | 807 request.headers |
804 ..set(HttpHeaders.CONNECTION, "Upgrade") | 808 ..set(HttpHeaders.CONNECTION, "Upgrade") |
805 ..set(HttpHeaders.UPGRADE, "websocket") | 809 ..set(HttpHeaders.UPGRADE, "websocket") |
806 ..set("Sec-WebSocket-Key", nonce) | 810 ..set("Sec-WebSocket-Key", nonce) |
807 ..set("Cache-Control", "no-cache") | 811 ..set("Cache-Control", "no-cache") |
808 ..set("Sec-WebSocket-Version", "13"); | 812 ..set("Sec-WebSocket-Version", "13"); |
(...skipping 203 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1012 (code < WebSocketStatus.NORMAL_CLOSURE || | 1016 (code < WebSocketStatus.NORMAL_CLOSURE || |
1013 code == WebSocketStatus.RESERVED_1004 || | 1017 code == WebSocketStatus.RESERVED_1004 || |
1014 code == WebSocketStatus.NO_STATUS_RECEIVED || | 1018 code == WebSocketStatus.NO_STATUS_RECEIVED || |
1015 code == WebSocketStatus.ABNORMAL_CLOSURE || | 1019 code == WebSocketStatus.ABNORMAL_CLOSURE || |
1016 (code > WebSocketStatus.INTERNAL_SERVER_ERROR && | 1020 (code > WebSocketStatus.INTERNAL_SERVER_ERROR && |
1017 code < WebSocketStatus.RESERVED_1015) || | 1021 code < WebSocketStatus.RESERVED_1015) || |
1018 (code >= WebSocketStatus.RESERVED_1015 && | 1022 (code >= WebSocketStatus.RESERVED_1015 && |
1019 code < 3000)); | 1023 code < 3000)); |
1020 } | 1024 } |
1021 } | 1025 } |
OLD | NEW |