[ABANDONED] WebSocket Blob receive in the browser process: renderer changes

third_party/WebKit/Source/modules/websockets/DocumentWebSocketChannelTest.cpp

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "modules/websockets/WebSocketChannel.h"
 
 #include "core/dom/DOMArrayBuffer.h"
 #include "core/dom/Document.h"
 #include "core/fileapi/Blob.h"
 #include "core/frame/ConsoleTypes.h"
@@ skipping 34 matching lines @@
     {
         return new testing::StrictMock<MockWebSocketChannelClient>();
     }
 
     MockWebSocketChannelClient() { }
 
     ~MockWebSocketChannelClient() override { }
 
     MOCK_METHOD2(didConnect, void(const String&, const String&));
     MOCK_METHOD1(didReceiveTextMessage, void(const String&));
-    void didReceiveBinaryMessage(PassOwnPtr<Vector<char>> payload) override
+    void didReceiveArrayBuffer(PassOwnPtr<Vector<char>> payload) override
     {
-        didReceiveBinaryMessageMock(*payload);
+        didReceiveArrayBufferMock(*payload);
     }
-    MOCK_METHOD1(didReceiveBinaryMessageMock, void(const Vector<char>&));
+    MOCK_METHOD1(didReceiveArrayBufferMock, void(const Vector<char>&));
+    void didReceiveBlob(PassRefPtr<BlobDataHandle> blobDataHandle) override
+    {
+        didReceiveBlobMock(*blobDataHandle);
+    }
+    MOCK_METHOD1(didReceiveBlobMock, void(const BlobDataHandle&));
     MOCK_METHOD0(didError, void());
     MOCK_METHOD1(didConsumeBufferedAmount, void(uint64_t));
     MOCK_METHOD0(didStartClosingHandshake, void());
     MOCK_METHOD3(didClose, void(ClosingHandshakeCompletionStatus, unsigned short, const String&));
 
     DEFINE_INLINE_VIRTUAL_TRACE()
     {
         WebSocketChannelClient::trace(visitor);
     }
 
 };
 
 class MockWebSocketHandle : public WebSocketHandle {
 public:
     static MockWebSocketHandle* create()
     {
         return new testing::StrictMock<MockWebSocketHandle>();
     }
 
     MockWebSocketHandle() { }
 
     ~MockWebSocketHandle() override { }
 
     MOCK_METHOD4(connect, void(const WebURL&, const WebVector<WebString>&, const WebSecurityOrigin&, WebSocketHandleClient*));
     MOCK_METHOD4(send, void(bool, WebSocketHandle::MessageType, const char*, size_t));
     MOCK_METHOD1(flowControl, void(int64_t));
     MOCK_METHOD2(close, void(unsigned short, const WebString&));
+    MOCK_METHOD1(changeBinaryType, void(BinaryType));
+    MOCK_METHOD0(confirmBlob, void());
 };
 
 class DocumentWebSocketChannelTest : public ::testing::Test {
 public:
     DocumentWebSocketChannelTest()
         : m_pageHolder(DummyPageHolder::create())
         , m_channelClient(MockWebSocketChannelClient::create())
         , m_handle(MockWebSocketHandle::create())
         , m_channel(DocumentWebSocketChannel::create(&m_pageHolder->document(), m_channelClient.get(), String(), 0, handle()))
         , m_sumOfConsumedBufferedAmount(0)
@@ skipping 418 matching lines @@
     handleClient()->didReceiveData(handle(), false, WebSocketHandle::MessageTypeContinuation, "\x90\xe0", 2);
     handleClient()->didReceiveData(handle(), false, WebSocketHandle::MessageTypeContinuation, "\xa4", 1);
     handleClient()->didReceiveData(handle(), true, WebSocketHandle::MessageTypeContinuation, "\x94", 1);
 }
 
 TEST_F(DocumentWebSocketChannelTest, receiveBinary)
 {
     connect();
     Vector<char> fooVector;
     fooVector.append("FOO", 3);
-    EXPECT_CALL(*channelClient(), didReceiveBinaryMessageMock(fooVector));
+    EXPECT_CALL(*channelClient(), didReceiveArrayBufferMock(fooVector));
 
     handleClient()->didReceiveData(handle(), true, WebSocketHandle::MessageTypeBinary, "FOOx", 3);
 }
 
 TEST_F(DocumentWebSocketChannelTest, receiveBinaryContinuation)
 {
     connect();
     Vector<char> bazVector;
     bazVector.append("BAZ", 3);
-    EXPECT_CALL(*channelClient(), didReceiveBinaryMessageMock(bazVector));
+    EXPECT_CALL(*channelClient(), didReceiveArrayBufferMock(bazVector));
 
     handleClient()->didReceiveData(handle(), false, WebSocketHandle::MessageTypeBinary, "Bx", 1);
     handleClient()->didReceiveData(handle(), false, WebSocketHandle::MessageTypeContinuation, "Ax", 1);
     handleClient()->didReceiveData(handle(), true, WebSocketHandle::MessageTypeContinuation, "Zx", 1);
 }
 
 TEST_F(DocumentWebSocketChannelTest, receiveBinaryWithNullBytes)
 {
     connect();
     {
         InSequence s;
         {
             Vector<char> v;
             v.append("\0AR", 3);
-            EXPECT_CALL(*channelClient(), didReceiveBinaryMessageMock(v));
+            EXPECT_CALL(*channelClient(), didReceiveArrayBufferMock(v));
         }
         {
             Vector<char> v;
             v.append("B\0Z", 3);
-            EXPECT_CALL(*channelClient(), didReceiveBinaryMessageMock(v));
+            EXPECT_CALL(*channelClient(), didReceiveArrayBufferMock(v));
         }
         {
             Vector<char> v;
             v.append("QU\0", 3);
-            EXPECT_CALL(*channelClient(), didReceiveBinaryMessageMock(v));
+            EXPECT_CALL(*channelClient(), didReceiveArrayBufferMock(v));
         }
         {
             Vector<char> v;
             v.append("\0\0\0", 3);
-            EXPECT_CALL(*channelClient(), didReceiveBinaryMessageMock(v));
+            EXPECT_CALL(*channelClient(), didReceiveArrayBufferMock(v));
         }
     }
 
     handleClient()->didReceiveData(handle(), true, WebSocketHandle::MessageTypeBinary, "\0AR", 3);
     handleClient()->didReceiveData(handle(), true, WebSocketHandle::MessageTypeBinary, "B\0Z", 3);
     handleClient()->didReceiveData(handle(), true, WebSocketHandle::MessageTypeBinary, "QU\0", 3);
     handleClient()->didReceiveData(handle(), true, WebSocketHandle::MessageTypeBinary, "\0\0\0", 3);
 }
 
 TEST_F(DocumentWebSocketChannelTest, receiveBinaryNonLatin1UTF8)
 {
     connect();
     Vector<char> v;
     v.append("\xe7\x8b\x90\xe0\xa4\x94", 6);
-    EXPECT_CALL(*channelClient(), didReceiveBinaryMessageMock(v));
+    EXPECT_CALL(*channelClient(), didReceiveArrayBufferMock(v));
 
     handleClient()->didReceiveData(handle(), true, WebSocketHandle::MessageTypeBinary, "\xe7\x8b\x90\xe0\xa4\x94", 6);
 }
 
 TEST_F(DocumentWebSocketChannelTest, receiveBinaryNonLatin1UTF8Continuation)
 {
     connect();
     Vector<char> v;
     v.append("\xe7\x8b\x90\xe0\xa4\x94", 6);
-    EXPECT_CALL(*channelClient(), didReceiveBinaryMessageMock(v));
+    EXPECT_CALL(*channelClient(), didReceiveArrayBufferMock(v));
 
     handleClient()->didReceiveData(handle(), false, WebSocketHandle::MessageTypeBinary, "\xe7\x8b", 2);
     handleClient()->didReceiveData(handle(), false, WebSocketHandle::MessageTypeContinuation, "\x90\xe0", 2);
     handleClient()->didReceiveData(handle(), false, WebSocketHandle::MessageTypeContinuation, "\xa4", 1);
     handleClient()->didReceiveData(handle(), true, WebSocketHandle::MessageTypeContinuation, "\x94", 1);
 }
 
 TEST_F(DocumentWebSocketChannelTest, receiveBinaryNonUTF8)
 {
     connect();
     Vector<char> v;
     v.append("\x80\xff", 2);
-    EXPECT_CALL(*channelClient(), didReceiveBinaryMessageMock(v));
+    EXPECT_CALL(*channelClient(), didReceiveArrayBufferMock(v));
 
     handleClient()->didReceiveData(handle(), true, WebSocketHandle::MessageTypeBinary, "\x80\xff", 2);
 }
 
 TEST_F(DocumentWebSocketChannelTest, closeFromBrowser)
 {
     connect();
     Checkpoint checkpoint;
     {
         InSequence s;
@@ skipping 65 matching lines @@
         EXPECT_CALL(*channelClient(), didError());
         EXPECT_CALL(*channelClient(), didClose(WebSocketChannelClient::ClosingHandshakeIncomplete, WebSocketChannel::CloseEventCodeAbnormalClosure, String()));
     }
 
     channel()->fail("fail message from WebSocket", ErrorMessageLevel, "sourceURL", 1234);
 }
 
 } // namespace
 
 } // namespace blink