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

third_party/WebKit/Source/modules/websockets/DocumentWebSocketChannel.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 37 matching lines @@
 #include "platform/Logging.h"
 #include "platform/network/WebSocketHandshakeRequest.h"
 #include "platform/weborigin/SecurityOrigin.h"
 #include "public/platform/Platform.h"
 #include "public/platform/WebSecurityOrigin.h"
 #include "public/platform/WebString.h"
 #include "public/platform/WebURL.h"
 #include "public/platform/WebVector.h"
 #include "public/platform/modules/websockets/WebSocketHandshakeRequestInfo.h"
 #include "public/platform/modules/websockets/WebSocketHandshakeResponseInfo.h"
+#include <inttypes.h>
 
 using blink::WebSocketHandle;
 
 namespace blink {
 
 class DocumentWebSocketChannel::BlobLoader final : public GarbageCollectedFinalized<DocumentWebSocketChannel::BlobLoader>, public FileReaderLoaderClient {
 public:
     BlobLoader(PassRefPtr<BlobDataHandle>, DocumentWebSocketChannel*);
     ~BlobLoader() override { }
 
@@ skipping 156 matching lines @@
 
 void DocumentWebSocketChannel::close(int code, const String& reason)
 {
     WTF_LOG(Network, "DocumentWebSocketChannel %p close(%d, %s)", this, code, reason.utf8().data());
     ASSERT(m_handle);
     unsigned short codeToSend = static_cast<unsigned short>(code == CloseEventCodeNotSpecified ? CloseEventCodeNoStatusRcvd : code);
     m_messages.append(adoptPtr(new Message(codeToSend, reason)));
     processSendQueue();
 }
 
+static WebSocketHandle::BinaryType toHandleBinaryType(DocumentWebSocketChannel::BinaryType binaryType)
+{
+    static_assert(static_cast<WebSocketHandle::BinaryType>(DocumentWebSocketChannel::BinaryTypeBlob) == WebSocketHandle::BinaryTypeBlob, "enums must match");
+    static_assert(static_cast<WebSocketHandle::BinaryType>(DocumentWebSocketChannel::BinaryTypeArrayBuffer) == WebSocketHandle::BinaryTypeArrayBuffer, "enums must match");
+    ASSERT(binaryType == DocumentWebSocketChannel::BinaryTypeBlob || binaryType == DocumentWebSocketChannel::BinaryTypeArrayBuffer);
+    return static_cast<WebSocketHandle::BinaryType>(binaryType);
+}
+
+void DocumentWebSocketChannel::changeBinaryType(BinaryType newBinaryType)
+{
+    WTF_LOG(Network, "DocumentWebSocketChannel %p changeBinaryType(%d)", this, newBinaryType);
+    ASSERT(m_handle);
+    m_handle->changeBinaryType(toHandleBinaryType(newBinaryType));
+}
+
 void DocumentWebSocketChannel::fail(const String& reason, MessageLevel level, const String& sourceURL, unsigned lineNumber)
 {
     WTF_LOG(Network, "DocumentWebSocketChannel %p fail(%s)", this, reason.utf8().data());
     // m_handle and m_client can be null here.
 
     InspectorInstrumentation::didReceiveWebSocketFrameError(document(), m_identifier, reason);
     const String message = "WebSocket connection to '" + m_url.elidedString() + "' failed: " + reason;
     executionContext()->addConsoleMessage(ConsoleMessage::create(JSMessageSource, level, message, sourceURL, lineNumber));
 
     if (m_client)
@@ skipping 232 matching lines @@
         m_receivingMessageData.clear();
         if (message.isNull()) {
             failAsError("Could not decode a text frame as UTF-8.");
             // failAsError may delete this object.
         } else {
             m_client->didReceiveTextMessage(message);
         }
     } else {
         OwnPtr<Vector<char>> binaryData = adoptPtr(new Vector<char>);
         binaryData->swap(m_receivingMessageData);
-        m_client->didReceiveBinaryMessage(binaryData.release());
+        m_client->didReceiveArrayBuffer(binaryData.release());
     }
 }
 
+void DocumentWebSocketChannel::didReceiveBlob(WebSocketHandle* handle,
+    const WebString& uuid,
+    uint64_t size)
+{
+    WTF_LOG(Network, "DocumentWebSocketChannel %p didReceiveBlob(%p, %s, %" PRIu64 ")", this, handle, uuid.utf8().c_str(), size);
+
+    ASSERT(m_handle);
+    ASSERT(handle == m_handle);
+    ASSERT(m_client);
+
+    // FIXME: Report the Blob to InspectorInstrumentation.
+    RefPtr<BlobDataHandle> blobDataHandle = BlobDataHandle::create(uuid, "", size);
+    handle->confirmBlob();
+    m_client->didReceiveBlob(blobDataHandle.release());
+}
+
 void DocumentWebSocketChannel::didClose(WebSocketHandle* handle, bool wasClean, unsigned short code, const WebString& reason)
 {
     WTF_LOG(Network, "DocumentWebSocketChannel %p didClose(%p, %d, %u, %s)", this, handle, wasClean, code, String(reason).utf8().data());
 
     ASSERT(m_handle);
     ASSERT(handle == m_handle);
 
     m_handle.clear();
 
     if (m_identifier) {
@@ skipping 54 matching lines @@
 
 DEFINE_TRACE(DocumentWebSocketChannel)
 {
     visitor->trace(m_blobLoader);
     visitor->trace(m_client);
     WebSocketChannel::trace(visitor);
     ContextLifecycleObserver::trace(visitor);
 }
 
 } // namespace blink