Add special handling of the content type HTTP header

runtime/bin/http_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.
 
 class _HttpHeaders implements HttpHeaders {
   _HttpHeaders() : _headers = new Map<String, List<String>>();
 
   List<String> operator[](String name) {
     name = name.toLowerCase();
     return _headers[name];
   }
 
   String value(String name) {
     name = name.toLowerCase();
+    _syncHeaderValuesCache(name);
     List<String> values = _headers[name];
     if (values == null) return null;
     if (values.length > 1) {
       throw new HttpException("More than one value for header $name");
     }
     return values[0];
   }
 
   void add(String name, Object value) {
     _checkMutable();
     if (value is List) {
       for (int i = 0; i < value.length; i++) {
         _add(name, value[i]);
       }
     } else {
       _add(name, value);
     }
   }
 
   void set(String name, Object value) {
+    name = name.toLowerCase();
     _checkMutable();
     removeAll(name);
     add(name, value);
   }
 
   void remove(String name, Object value) {
     _checkMutable();
     name = name.toLowerCase();
     List<String> values = _headers[name];
     if (values != null) {
       int index = values.indexOf(value);
       if (index != -1) {
         values.removeRange(index, 1);
       }
     }
+    _clearHeaderValueCache(name);
   }
 
   void removeAll(String name) {
     _checkMutable();
     name = name.toLowerCase();
     _headers.remove(name);
+    _clearHeaderValueCache(name);
   }
 
   void forEach(void f(String name, List<String> values)) {
+    _syncHeaderValuesCache();
     _headers.forEach(f);
   }
 
   String get host() => _host;
 
   void set host(String host) {
     _checkMutable();
     _host = host;
     _updateHostHeader();
   }
@@ skipping 39 matching lines @@
   }
 
   void set expires(Date expires) {
     _checkMutable();
     // Format "Expires" header with date in Greenwich Mean Time (GMT).
     String formatted =
         _HttpUtils.formatDate(expires.changeTimeZone(new TimeZone.utc()));
     _set("expires", formatted);
   }
 
+  void get contentType() {
+    if (_contentType == null) {
+      var values = _headers["content-type"];
+      if (values != null) {
+        _contentType = new ContentType.fromString(values[0]);
+      } else {
+        _contentType = new ContentType();
+      }
+    }
+    return _contentType;
+  }
+
   void _add(String name, Object value) {
     // TODO(sgjesse): Add immutable state throw HttpException is immutable.
     if (name.toLowerCase() == "date") {
       if (value is Date) {
         date = value;
       } else if (value is String) {
         _set("date", value);
       } else {
         throw new HttpException("Unexpected type for header named $name");
       }
@@ skipping 20 matching lines @@
           _port = HttpClient.DEFAULT_HTTP_PORT;
         } else {
           try {
             _port = Math.parseInt(value.substring(pos + 1));
           } catch (BadNumberFormatException e) {
             _port = null;
           }
         }
         _set("host", value);
       }
+    } else if (name.toLowerCase() == "content-type") {
+      _set("content-type", value);
+      _contentType = null;
     } else {
       name = name.toLowerCase();
       List<String> values = _headers[name];
       if (values == null) {
         values = new List<String>();
         _headers[name] = values;
       }
       values.add(value.toString());
     }
   }
 
   void _set(String name, String value) {
     name = name.toLowerCase();
     List<String> values = new List<String>();
     _headers[name] = values;
     values.add(value);
   }
 
   _checkMutable() {
     if (!_mutable) throw new HttpException("HTTP headers are not mutable");
   }
 
   _updateHostHeader() {
     bool defaultPort = _port == null || _port == HttpClient.DEFAULT_HTTP_PORT;
     String portPart = defaultPort ? "" : ":$_port";
     _set("host", "$host$portPart");
   }
 
+  void _syncHeaderValuesCache([String name]) {
+    if (name == null) {
+      if (_contentType != null) {
+        _set("content-type", _contentType.toString());
+      }
+    } else if (name == "content-type" && _contentType != null) {
+      _set("content-type", _contentType.toString());
+    }
+  }
+
+  void _clearHeaderValueCache([String name]) {
+    if (name == null) {
+      _contentType = null;
+    } else if (name == "content-type") {
+      _contentType = null;
+    }
+  }
+
   _write(_HttpConnectionBase connection) {
     final COLONSP = const [_CharCode.COLON, _CharCode.SP];
     final COMMASP = const [_CharCode.COMMA, _CharCode.SP];
     final CRLF = const [_CharCode.CR, _CharCode.LF];
 
+    _syncHeaderValuesCache();
+
     // Format headers.
     _headers.forEach((String name, List<String> values) {
       List<int> data;
       data = name.charCodes();
       connection._write(data);
       connection._write(COLONSP);
       for (int i = 0; i < values.length; i++) {
         if (i > 0) {
           connection._write(COMMASP);
         }
         data = values[i].charCodes();
         connection._write(data);
       }
       connection._write(CRLF);
     });
   }
 
   String toString() {
+    _syncHeaderValuesCache();
     StringBuffer sb = new StringBuffer();
     _headers.forEach((String name, List<String> values) {
       sb.add(name);
       sb.add(": ");
       for (int i = 0; i < values.length; i++) {
         if (i > 0) {
           sb.add(", ");
         }
         sb.add(values[i]);
       }
       sb.add("\n");
     });
     return sb.toString();
   }
 
   bool _mutable = true;  // Are the headers currently mutable?
   Map<String, List<String>> _headers;
 
   String _host;
   int _port;
+  ContentType _contentType;
 }
 
 
+class _HeaderValue implements HeaderValue {
+  _HeaderValue([String this.value = ""]);
+
+  _HeaderValue.fromString(String value) {
+    // Parse the string.
+    _parse(value);
+  }
+
+  Map<String, String> get parameters() {
+    if (_parameters == null) _parameters = new Map<String, String>();
+    return _parameters;
+  }
+
+  String toString() {
+    StringBuffer sb = new StringBuffer();
+    sb.add(value);
+    if (parameters != null && parameters.length > 0) {
+      _parameters.forEach((String name, String value) {
+        sb.add("; ");
+        sb.add(name);
+        sb.add("=");
+        sb.add(value);
+      });
+    }
+    return sb.toString();
+  }
+
+  void _parse(String s) {
+    int index = 0;
+
+    bool done() => index == s.length;
+
+    void skipWS() {
+      while (!done()) {
+        if (s[index] != " " && s[index] != "\t") return;
+        index++;
+      }
+    }
+
+    String parseValue() {
+      int start = index;
+      while (!done()) {
+        if (s[index] == " " || s[index] == "\t" || s[index] == ";") break;
+        index++;
+      }
+      return s.substring(start, index).toLowerCase();
+    }
+
+    void expect(String expected) {
+      if (done()) throw new HttpException("Failed to parse header value [$s]");
+      if (s[index] != expected) {
+        throw new HttpException("Failed to parse header value [$s]");
+      }
+      index++;
+    }
+
+    void parseParameters() {
+      _parameters = new Map<String, String>();
+
+      String parseParameterName() {
+        int start = index;
+        while (!done()) {
+          if (s[index] == " " || s[index] == "\t" || s[index] == "=") break;
+          index++;
+        }
+        return s.substring(start, index).toLowerCase();
+      }
+
+      String parseParameterValue() {
+        if (s[index] == "\"") {
+          // Parse quoted value.
+          StringBuffer sb = new StringBuffer();
+          index++;
+          while (!done()) {
+            if (s[index] == "\\") {
+              if (index + 1 == s.length) {
+                throw new HttpException("Failed to parse header value [$s]");
+              }
+              index++;
+            } else if (s[index] == "\"") {
+              index++;
+              break;
+            }
+            sb.add(s[index]);
+            index++;
+          }
+          return sb.toString();
+        } else {
+          // Parse non-quoted value.
+          return parseValue();
+        }
+      }
+
+      while (!done()) {
+        skipWS();
+        if (done()) return;
+        String name = parseParameterName();
+        skipWS();
+        expect("=");
+        skipWS();
+        String value = parseParameterValue();
+        _parameters[name] = value;
+        skipWS();
+        if (done()) return;
+        expect(";");
+      }
+    }
+
+    skipWS();
+    value = parseValue();
+    skipWS();
+    if (done()) return;
+    expect(";");
+    parseParameters();
+  }
+
+  String value;
+  Map<String, String> _parameters;
+}
+
+
+class _ContentType extends _HeaderValue implements ContentType {
+  _ContentType([String this._primaryType = "", String this._subType = ""]);
+
+  _ContentType.fromString(String value) : super.fromString(value);
+
+  String get value() => "$_primaryType/$_subType";
+
+  void set value(String s) {
+    int index = s.indexOf("/");
+    if (index == -1 || s.length == index - 1) {

[Mads Ager (google), 2012/05/21 11:49:33]

I agree with Anders about this being: index == (s.length - 1)

However, it will probably work without that check because the substring for the
subType below will be the empty string. :-)

[Søren Gjesse, 2012/05/22 12:47:16]

Of cause you are both right.

+      primaryType = s.trim().toLowerCase();
+    } else {
+      primaryType = s.substring(0, index).trim().toLowerCase();
+      subType = s.substring(index + 1).trim().toLowerCase();
+    }
+  }
+
+  String get primaryType() => _primaryType;
+
+  void set primaryType(String s) {
+    _primaryType = s;
+  }
+
+  String get subType() => _subType;
+
+  void set subType(String s) {
+    _subType = s;
+  }
+
+  String get charset() => parameters["charset"];
+
+  void set charset(String s) {
+    parameters["charset"] = s;
+  }
+
+  String _primaryType = "";
+  String _subType = "";
+}
+
+
 class _HttpRequestResponseBase {
   final int START = 0;
   final int HEADER_SENT = 1;
   final int DONE = 2;
   final int UPGRADED = 3;
 
   _HttpRequestResponseBase(_HttpConnectionBase this._httpConnection)
       : _headers = new _HttpHeaders() {
     _state = START;
   }
@@ skipping 1405 matching lines @@
 
 
 class _RedirectInfo implements RedirectInfo {
   const _RedirectInfo(int this.statusCode,
                       String this.method,
                       Uri this.location);
   final int statusCode;
   final String method;
   final Uri location;
 }