Initial web socket server implementation

runtime/bin/http_parser.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.
 
 // Global constants.
 class _Const {
   // Bytes for "HTTP".
   static final HTTP = const [72, 84, 84, 80];
   // Bytes for "HTTP/1.".
   static final HTTP1DOT = const [72, 84, 84, 80, 47, 49, 46];
@@ skipping 127 matching lines @@
   int writeList(List<int> buffer, int offset, int count) {
     int index = offset;
     int lastIndex = offset + count;
     try {
       if (_state == _State.CLOSED) {
         throw new HttpParserException("Data on closed connection");
       }
       if (_state == _State.UPGRADED) {
         throw new HttpParserException("Data on upgraded connection");
       }
+      if (_state == _State.FAILURE) {
+        throw new HttpParserException("Data on failed connection");
+      }
       while ((index < lastIndex) && _state != _State.FAILURE && _state != _State.UPGRADED) {
         int byte = buffer[index];
         switch (_state) {
           case _State.START:
             if (byte == _Const.HTTP[0]) {
               // Start parsing method or HTTP version.
               _httpVersionIndex = 1;
               _state = _State.METHOD_OR_RESPONSE_HTTP_VERSION;
             } else {
               // Start parsing method.
@@ skipping 203 matching lines @@
             _expect(byte, _CharCode.LF);
             _state = _State.HEADER_VALUE_FOLD_OR_END;
             break;
 
           case _State.HEADER_VALUE_FOLD_OR_END:
             if (byte == _CharCode.SP || byte == _CharCode.HT) {
               _state = _State.HEADER_VALUE_START;
             } else {
               String headerField = _headerField.toString();
               String headerValue =_headerValue.toString();
-              // Ignore the Content-Length header if Transfer-Encoding
-              // is chunked (RFC 2616 section 4.4)
+              bool reportHeader = true;
               if (headerField == "content-length" && !_chunked) {
+                // Ignore the Content-Length header if Transfer-Encoding
+                // is chunked (RFC 2616 section 4.4)
                 _contentLength = Math.parseInt(headerValue);
               } else if (headerField == "connection") {
                 List<String> tokens = _tokenizeFieldValue(headerValue);
                 for (int i = 0; i < tokens.length; i++) {
                   String token = tokens[i].toLowerCase();
                   if (token == "keep-alive") {
                     _persistentConnection = true;
                   } else if (token == "close") {
                     _persistentConnection = false;
                   } else if (token == "upgrade") {
                     _connectionUpgrade = true;
                   }
+                  if (headerReceived != null) {
+                    headerReceived(headerField, token);
+                  }
                 }
+                reportHeader = false;
               } else if (headerField == "transfer-encoding" &&
                          headerValue.toLowerCase() == "chunked") {
+                // Ignore the Content-Length header if Transfer-Encoding
+                // is chunked (RFC 2616 section 4.4)
                 _chunked = true;
                 _contentLength = -1;
               }
-              if (headerReceived != null) {
+              if (reportHeader && headerReceived != null) {
                 headerReceived(headerField, headerValue);
               }
               _headerField.clear();
               _headerValue.clear();
 
               if (byte == _CharCode.CR) {
                 _state = _State.HEADER_ENDING;
               } else {
                 // Start of new header field.
                 _headerField.addCharCode(_toLowerCase(byte));
@@ skipping 73 matching lines @@
             _state = _State.CHUNKED_BODY_DONE_LF;
             break;
 
           case _State.CHUNKED_BODY_DONE_LF:
             _expect(byte, _CharCode.LF);
             _bodyEnd();
             _reset();
             break;
 
           case _State.BODY:
-            // The body is not handled one byte at the time but in blocks.
+            // The body is not handled one byte at a time but in blocks.
             int dataAvailable = lastIndex - index;
             ByteArray data;
             if (_remainingContent == null ||
                 dataAvailable <= _remainingContent) {
               data = new ByteArray(dataAvailable);
               data.setRange(0, dataAvailable, buffer, index);
             } else {
               data = new ByteArray(_remainingContent);
               data.setRange(0, _remainingContent, buffer, index);
             }
@@ skipping 197 matching lines @@
   Function dataEnd;
   Function error;
 }
 
 
 class HttpParserException implements Exception {
   const HttpParserException([String this.message = ""]);
   String toString() => "HttpParserException: $message";
   final String message;
 }