Make web-socket pass AutobanhTestSuite.

sdk/lib/utf/utf_stream.dart

 // Copyright (c) 2013, 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.
 
 part of dart.utf;
 
 class _HelperStreamController<T> extends StreamController<T> {
   final Function onPauseChanged;
 
   _HelperStreamController(this.onPauseChanged);
 
   void onPauseStateChange() {
     onPauseChanged();
   }
 }
 
 abstract class _StringDecoder
     extends StreamEventTransformer<List<int>, String> {
   List<int> _carry;
   List<int> _buffer;
   int _replacementChar;
 
   _StringDecoder(int this._replacementChar);
 
   void handleData(List<int> bytes, EventSink<String> sink) {
-    _buffer = <int>[];
-    List<int> carry = _carry;
-    _carry = null;
-    int pos = 0;
-    int available = bytes.length;
-    // If we have carry-over data, start from negative index, indicating carry
-    // index.
-    int goodChars = 0;
-    if (carry != null) pos = -carry.length;
-    while (pos < available) {
-      int currentPos = pos;
-      int getNext() {
-        if (pos < 0) {
-          return carry[pos++ + carry.length];
-        } else if (pos < available) {
-          return bytes[pos++];
+    try {
+      _buffer = <int>[];
+      List<int> carry = _carry;
+      _carry = null;
+      int pos = 0;
+      int available = bytes.length;
+      // If we have carry-over data, start from negative index, indicating carry
+      // index.
+      int goodChars = 0;
+      if (carry != null) pos = -carry.length;
+      while (pos < available) {
+        int currentPos = pos;
+        int getNext() {
+          if (pos < 0) {
+            return carry[pos++ + carry.length];
+          } else if (pos < available) {
+            return bytes[pos++];
+          }
+          return null;
         }
-        return null;
+        int consumed = _processBytes(getNext);
+        if (consumed > 0) {
+          goodChars = _buffer.length;
+        } else if (consumed == 0) {
+          _buffer.length = goodChars;
+          if (currentPos < 0) {
+            _carry = [];
+            _carry.addAll(carry);
+            _carry.addAll(bytes);
+          } else {
+            _carry = bytes.sublist(currentPos);
+          }
+          break;
+        } else {
+          // Invalid byte at position pos - 1
+          _buffer.length = goodChars;
+          _addChar(-1);
+          goodChars = _buffer.length;
+        }
       }
-      int consumed = _processBytes(getNext);
-      if (consumed > 0) {
-        goodChars = _buffer.length;
-      } else if (consumed == 0) {
-        _buffer.length = goodChars;
-        if (currentPos < 0) {
-          _carry = [];
-          _carry.addAll(carry);
-          _carry.addAll(bytes);
-        } else {
-          _carry = bytes.sublist(currentPos);
-        }
-        break;
-      } else {
-        // Invalid byte at position pos - 1
-        _buffer.length = goodChars;
-        _addChar(-1);
-        goodChars = _buffer.length;
+      if (_buffer.length > 0) {
+        // Limit to 'goodChars', if lower than actual charCodes in the buffer.
+        sink.add(new String.fromCharCodes(_buffer));
       }
+      _buffer = null;
+    } catch (e) {
+      sink.addError(e);
     }
-    if (_buffer.length > 0) {
-      // Limit to 'goodChars', if lower than actual charCodes in the buffer.
-      sink.add(new String.fromCharCodes(_buffer));
-    }
-    _buffer = null;
   }
 
   void handleDone(EventSink<String> sink) {
     if (_carry != null) {
-      sink.add(new String.fromCharCodes(
-          new List.filled(_carry.length, _replacementChar)));
+      if (_replacementChar != null) {
+        sink.add(new String.fromCharCodes(
+            new List.filled(_carry.length, _replacementChar)));
+      } else {
+        throw new ArgumentError('Invalid codepoint');
+      }
     }
     sink.close();
   }
 
   int _processBytes(int getNext());
 
   void _addChar(int char) {
-    if (char > 0x10FFFF || char < 0) char = _replacementChar;
+    void error() {
+      if (_replacementChar != null) {
+        char = _replacementChar;
+      } else {
+        throw new ArgumentError('Invalid codepoint');
+      }
+    }
+    if (char < 0) error();
+    if (char >= 0xD800 && char <= 0xDFFF) error();
+    if (char > 0x10FFFF) error();
     _buffer.add(char);
   }
 }
 
 /**
  * StringTransformer that decodes a stream of UTF-8 encoded bytes.
  */
 class Utf8DecoderTransformer extends _StringDecoder {
   Utf8DecoderTransformer(
       [int replacementChar = UNICODE_REPLACEMENT_CHARACTER_CODEPOINT])
@@ skipping 26 matching lines @@
         additionalBytes = 5;
         min = 0x4000000;
       } else {
         return -1;
       }
       for (int i = 0; i < additionalBytes; i++) {
         int next = getNext();
         if (next == null) return 0;  // Not enough chars, reset.
         if ((next & 0xc0) != 0x80 || (next & 0xff) != next) return -1;
         value = value << 6 | (next & 0x3f);
+        if (additionalBytes >= 3 && i == 0 && value << 12 > 0x10FFFF) {
+          _addChar(-1);
+        }
       }
       // Invalid charCode if less then minimum expected.
       if (value < min) value = -1;
       _addChar(value);
       return 1 + additionalBytes;
     }
     _addChar(value);
     return 1;
   }
 }
@@ skipping 39 matching lines @@
       }
       for (int i = additionalBytes; i > 0; i--) {
         // 10xxxxxx (xxxxxx is next 6 bits from the top).
         bytes.add(((charCode >> (6 * (i - 1))) & 0x3F) | 0x80);
       }
       pos += additionalBytes + 1;
     }
     return bytes;
   }
 }