[WebSocket] Add tests for permessage deflate split frames.

Source/modules/websockets/WebSocketPerMessageDeflateTest.cpp

 /*
  * Copyright (C) 2013 Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions are
  * met:
  *
  *     * Redistributions of source code must retain the above copyright
  * notice, this list of conditions and the following disclaimer.
  *     * Redistributions in binary form must reproduce the above
@@ skipping 274 matching lines @@
     EXPECT_TRUE(f2.final);
 
     c.resetInflateBuffer();
     ASSERT_TRUE(c.inflate(f3));
     EXPECT_EQ(5u, f3.payloadLength);
     EXPECT_EQ(std::string("Hello"), std::string(f3.payload, f3.payloadLength));
     EXPECT_FALSE(f3.compress);
     EXPECT_TRUE(f3.final);
 }
 
+TEST(WebSocketPerMessageDeflateTest, TestInflateMultipleBlocksOverMultipleFrames)
+{
+    WebSocketPerMessageDeflate c;
+    c.enable(8, WebSocketDeflater::TakeOverContext);
+    WebSocketFrame::OpCode opcode = WebSocketFrame::OpCodeText;
+    WebSocketFrame::OpCode continuation = WebSocketFrame::OpCodeContinuation;
+    std::string expected = "HelloHello";
+    std::string actual;
+    WebSocketFrame f1(opcode, "\xf2\x48\xcd\xc9\xc9\x07\x00\x00\x00\xff\xff", 11, WebSocketFrame::Compress);
+    WebSocketFrame f2(continuation, "\xf2\x00\x11\x00\x00", 5, WebSocketFrame::Final);
+
+    ASSERT_TRUE(c.inflate(f1));
+    EXPECT_FALSE(f1.compress);
+    EXPECT_FALSE(f1.final);
+    actual += std::string(f1.payload, f1.payloadLength);
+
+    c.resetInflateBuffer();
+    ASSERT_TRUE(c.inflate(f2));
+    EXPECT_FALSE(f2.compress);
+    EXPECT_TRUE(f2.final);
+    actual += std::string(f2.payload, f2.payloadLength);
+
+    EXPECT_EQ(expected, actual);
+}
+
 TEST(WebSocketPerMessageDeflateTest, TestInflateEmptyFrame)
 {
     WebSocketPerMessageDeflate c;
     c.enable(8, WebSocketDeflater::TakeOverContext);
     WebSocketFrame::OpCode opcode = WebSocketFrame::OpCodeText;
     WebSocketFrame::OpCode continuation = WebSocketFrame::OpCodeContinuation;
     WebSocketFrame f1(opcode, "", 0, WebSocketFrame::Compress);
     WebSocketFrame f2(continuation, "\xf2\x48\xcd\xc9\xc9\x07\x00", 7, WebSocketFrame::Final);
 
     ASSERT_TRUE(c.inflate(f1));
@@ skipping 173 matching lines @@
         EXPECT_FALSE(processResponse(params));
     }
 }
 
 TEST(WebSocketPerMessageDeflateTest, TestNegotiationRequest)
 {
     String actual = WebSocketPerMessageDeflate().createExtensionProcessor()->handshakeString();
     EXPECT_EQ(String("permessage-deflate; client_max_window_bits"), actual);
 }
 } // namespace