WebSocket Compression

tests/standalone/io/web_socket_test.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.
 //
 // VMOptions=
 // VMOptions=--short_socket_read
 // VMOptions=--short_socket_write
 // VMOptions=--short_socket_read --short_socket_write
 
 import "dart:async";
@@ skipping 531 matching lines @@
           Expect.equals("Hello", message);
           return websocket.close();
         }).asFuture();
       }).then((_) {
         return server.close();
       }).whenComplete(() {
         asyncEnd();
       });
     });
   }
 

[Søren Gjesse, 2015/08/24 08:21:50]

Please create a new test file web_socket_compression_test.dart (just copy
createServer and other helpers needed).

+  void testCompressionSupport(bool enabled, bool allowContextTakeover) {

[Søren Gjesse, 2015/08/24 08:21:50]

Please add tests involving the max_window_bits as well.

+    asyncStart();
+
+    var options = new CompressionOptions(
+      enabled: enabled,
+      serverNoContextTakeover: allowContextTakeover,
+      clientNoContextTakeover: allowContextTakeover);
+
+    createServer().then((server) {
+      server.listen((request) {
+        Expect.isTrue(WebSocketTransformer.isUpgradeRequest(request));
+        WebSocketTransformer.upgrade(request, compression: options).then((webSocket) {

[Søren Gjesse, 2015/08/24 08:21:50]

nit: Long line.

+          webSocket.listen((message) {
+            Expect.equals("Hello World", message);
+
+            webSocket.add(message);
+            webSocket.close();
+          });
+          webSocket.add("Hello World");
+        });
+      });
+
+      var url = '${secure ? "wss" : "ws"}://$HOST_NAME:${server.port}/';
+      WebSocket.connect(url, compression: options).then((websocket) {
+        var future = websocket.listen((message) {
+          Expect.equals("Hello World", message);
+        }).asFuture();
+        websocket.add("Hello World");
+        return future;
+      }).then((_) {
+        server.close();
+        asyncEnd();
+      });
+    });
+  }
+
   void runTests() {
     testRequestResponseClientCloses(2, null, null, 1);
     testRequestResponseClientCloses(2, 3001, null, 2);
     testRequestResponseClientCloses(2, 3002, "Got tired", 3);
     testRequestResponseServerCloses(2, null, null);
     testRequestResponseServerCloses(2, 3001, null);
     testRequestResponseServerCloses(2, 3002, "Got tired");
     testMessageLength(125);
     testMessageLength(126);
     testMessageLength(127);
     testMessageLength(65535);
     testMessageLength(65536);
     testCloseNoListen();
     testCancelThenClose();
     testCloseThenCancel();
     testListenAfterClose();
     testDoubleCloseClient();
     testDoubleCloseServer();
     testImmediateCloseServer();
     testImmediateCloseClient();
     testNoUpgrade();
     testUsePOST();
     testConnections(10, 3002, "Got tired");
+    testCompressionSupport(false, false);
+    testCompressionSupport(true, false);
+    testCompressionSupport(true, true);
     testIndividualUpgrade(5);
     testFromUpgradedSocket();
     testAdditionalHeaders();
     testBasicAuthentication();
   }
 }
 
 
 void initializeSSL() {
   var testPkcertDatabase = Platform.script.resolve('pkcert').toFilePath();
   SecureSocket.initialize(database: testPkcertDatabase,
                           password: "dartdart");
 }
 
 
 main() {
   new SecurityConfiguration(secure: false).runTests();
   initializeSSL();
   new SecurityConfiguration(secure: true).runTests();
 }