Never send reserved status codes in a close frame

runtime/bin/websocket_impl.dart

 // Copyright (c) 2012, 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.
 
 const String _webSocketGUID = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
 
 class _WebSocketMessageType {
   static const int NONE = 0;
   static const int BINARY = 1;
   static const int TEXT = 2;
@@ skipping 271 matching lines @@
   void _controlFrameEnd() {
     switch (_opcode) {
       case _WebSocketOpcode.CLOSE:
         int status = WebSocketStatus.NO_STATUS_RECEIVED;
         String reason = "";
         if (_controlPayload.length > 0) {
           if (_controlPayload.length == 1) {
             throw new WebSocketException("Protocol error");
           }
           status = _controlPayload[0] << 8 | _controlPayload[1];
+          if (status == WebSocketStatus.NO_STATUS_RECEIVED) {
+            throw new WebSocketException("Protocol error");
+          }
           if (_controlPayload.length > 2) {
             var decoder = _StringDecoders.decoder(Encoding.UTF_8);
             decoder.write(
                 _controlPayload.getRange(2, _controlPayload.length - 2));
             reason = decoder.decoded();
           }
         }
         if (onClosed !== null) onClosed(status, reason);
         _state = CLOSED;
         break;
@@ skipping 114 matching lines @@
         opcode = _WebSocketOpcode.BINARY;
         data = message;
       }
     } else {
       opcode = _WebSocketOpcode.TEXT;
     }
     _sendFrame(opcode, data);
   }
 
   close([int status, String reason]) {
+    if (status == WebSocketStatus.RESERVED_1004 ||
+        status == WebSocketStatus.NO_STATUS_RECEIVED ||
+        status == WebSocketStatus.RESERVED_1015) {
+      throw new WebSocketException("Reserved status code $status");
+    }
+
     if (_closeSent) return;
     List<int> data;
     if (status !== null) {
       data = new List<int>();
       data.add((status >> 8) & 0xFF);
       data.add(status & 0xFF);
       if (reason !== null) {
         data.addAll(
            _StringEncoders.encoder(Encoding.UTF_8).encodeString(reason));
       }
@@ skipping 63 matching lines @@
   }
 
   _onWebSocketClosed(int status, String reason) {
     _closeReceived = true;
     if (_onClosed !== null) _onClosed(status, reason);
     if (_closeSent) {
       // Got close frame in response to close frame. Now close the socket.
       if (_closeTimer !== null) _closeTimer.cancel();
       _socket.close();
     } else {
-      close(status);
+      if (status != WebSocketStatus.NO_STATUS_RECEIVED) {
+        close(status);
+      } else {
+        close();
+      }
     }
   }
 
   _sendFrame(int opcode, [List<int> data]) {
     bool mask = false;  // Masking not implemented for server.
     int dataLength = data == null ? 0 : data.length;
     // Determine the header size.
     int headerSize = (mask) ? 6 : 2;
     if (dataLength > 65535) {
       headerSize += 8;
@@ skipping 331 matching lines @@
 
 class _WebSocketCloseEvent implements CloseEvent {
   _WebSocketCloseEvent(this._wasClean, this._code, this._reason);
   bool get wasClean => _wasClean;
   int get code => _code;
   String get reason => _reason;
   bool _wasClean;
   int _code;
   String _reason;
 }