Mojo: Add a WebSocket/Client interface and hook it up to the HTML viewer.

mojo/services/network/web_socket_impl.cc

+// 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 "mojo/services/network/web_socket_impl.h"
+
+#include "base/logging.h"
+#include "mojo/services/network/network_context.h"
+#include "net/websockets/websocket_channel.h"
+#include "net/websockets/websocket_errors.h"
+#include "net/websockets/websocket_event_interface.h"
+#include "net/websockets/websocket_frame.h"  // for WebSocketFrameHeader::OpCode
+#include "net/websockets/websocket_handshake_request_info.h"
+#include "net/websockets/websocket_handshake_response_info.h"
+#include "url/origin.h"
+
+namespace mojo {
+
+template <>
+class TypeConverter<net::WebSocketFrameHeader::OpCode, WebSocket::MessageType> {
+ public:
+  static net::WebSocketFrameHeader::OpCode ConvertFrom(
+      WebSocket::MessageType type) {
+    DCHECK(type == WebSocket::MESSAGE_TYPE_CONTINUATION ||
+           type == WebSocket::MESSAGE_TYPE_TEXT ||
+           type == WebSocket::MESSAGE_TYPE_BINARY);
+    typedef net::WebSocketFrameHeader::OpCode OpCode;
+    // These compile asserts verify that the same underlying values are used for
+    // both types, so we can simply cast between them.
+    COMPILE_ASSERT(static_cast<OpCode>(WebSocket::MESSAGE_TYPE_CONTINUATION) ==
+                       net::WebSocketFrameHeader::kOpCodeContinuation,
+                   enum_values_must_match_for_opcode_continuation);
+    COMPILE_ASSERT(static_cast<OpCode>(WebSocket::MESSAGE_TYPE_TEXT) ==
+                       net::WebSocketFrameHeader::kOpCodeText,
+                   enum_values_must_match_for_opcode_text);
+    COMPILE_ASSERT(static_cast<OpCode>(WebSocket::MESSAGE_TYPE_BINARY) ==
+                       net::WebSocketFrameHeader::kOpCodeBinary,
+                   enum_values_must_match_for_opcode_binary);
+    return static_cast<OpCode>(type);
+  }
+};
+
+template <>
+class TypeConverter<WebSocket::MessageType, net::WebSocketFrameHeader::OpCode> {
+ public:
+  static WebSocket::MessageType ConvertFrom(
+      net::WebSocketFrameHeader::OpCode type) {
+    DCHECK(type == net::WebSocketFrameHeader::kOpCodeContinuation ||
+           type == net::WebSocketFrameHeader::kOpCodeText ||
+           type == net::WebSocketFrameHeader::kOpCodeBinary);
+    return static_cast<WebSocket::MessageType>(type);
+  }
+};
+
+// TODO(mpcomplete): remove this.
+template <typename T, typename U>
+inline T ConvertTo(const U& obj) {
+  return TypeConverter<T, U>::ConvertFrom(obj);
+}
+
+namespace {
+
+typedef net::WebSocketEventInterface::ChannelState ChannelState;
+
+class WebSocketEventHandler : public net::WebSocketEventInterface {
+ public:
+  WebSocketEventHandler(WebSocketClientPtr client)
+      : client_(client.Pass()) {
+  }
+  virtual ~WebSocketEventHandler() {}
+
+ private:
+  // net::WebSocketEventInterface methods:
+  virtual ChannelState OnAddChannelResponse(
+      bool fail,
+      const std::string& selected_subprotocol,
+      const std::string& extensions) OVERRIDE;
+  virtual ChannelState OnDataFrame(bool fin,
+                                   WebSocketMessageType type,
+                                   const std::vector<char>& data) OVERRIDE;
+  virtual ChannelState OnClosingHandshake() OVERRIDE;
+  virtual ChannelState OnFlowControl(int64 quota) OVERRIDE;
+  virtual ChannelState OnDropChannel(bool was_clean,
+                                     uint16 code,
+                                     const std::string& reason) OVERRIDE;
+  virtual ChannelState OnFailChannel(const std::string& message) OVERRIDE;
+  virtual ChannelState OnStartOpeningHandshake(
+      scoped_ptr<net::WebSocketHandshakeRequestInfo> request) OVERRIDE;
+  virtual ChannelState OnFinishOpeningHandshake(
+      scoped_ptr<net::WebSocketHandshakeResponseInfo> response) OVERRIDE;
+  virtual ChannelState OnSSLCertificateError(
+      scoped_ptr<net::WebSocketEventInterface::SSLErrorCallbacks> callbacks,
+      const GURL& url,
+      const net::SSLInfo& ssl_info,
+      bool fatal) OVERRIDE;
+
+  WebSocketClientPtr client_;
+
+  DISALLOW_COPY_AND_ASSIGN(WebSocketEventHandler);
+};
+
+ChannelState WebSocketEventHandler::OnAddChannelResponse(
+    bool fail,
+    const std::string& selected_protocol,
+    const std::string& extensions) {
+  client_->DidConnect(fail, selected_protocol, extensions);
+  return WebSocketEventInterface::CHANNEL_ALIVE;
+}
+
+ChannelState WebSocketEventHandler::OnDataFrame(
+    bool fin,
+    net::WebSocketFrameHeader::OpCode type,
+    const std::vector<char>& data) {
+  // TODO(mpcomplete): reuse the data pipe for subsequent frames.
+  uint32_t num_bytes = static_cast<uint32_t>(data.size());
+  MojoCreateDataPipeOptions options;
+  options.struct_size = sizeof(MojoCreateDataPipeOptions);
+  options.flags = MOJO_CREATE_DATA_PIPE_OPTIONS_FLAG_NONE;
+  options.element_num_bytes = 1;
+  options.capacity_num_bytes = num_bytes;
+  DataPipe data_pipe(options);
+  WriteDataRaw(data_pipe.producer_handle.get(),
+               &data[0],
+               &num_bytes,
+               MOJO_WRITE_DATA_FLAG_ALL_OR_NONE);
+  client_->DidReceiveData(fin, ConvertTo<WebSocket::MessageType>(type),
+                          data_pipe.consumer_handle.Pass());
+  return WebSocketEventInterface::CHANNEL_ALIVE;
+}
+
+ChannelState WebSocketEventHandler::OnClosingHandshake() {
+  return WebSocketEventInterface::CHANNEL_ALIVE;
+}
+
+ChannelState WebSocketEventHandler::OnFlowControl(int64 quota) {
+  client_->DidReceiveFlowControl(quota);
+  return WebSocketEventInterface::CHANNEL_ALIVE;
+}
+
+ChannelState WebSocketEventHandler::OnDropChannel(bool was_clean,
+                                          uint16 code,
+                                          const std::string& reason) {
+  return WebSocketEventInterface::CHANNEL_ALIVE;
+}
+
+ChannelState WebSocketEventHandler::OnFailChannel(const std::string& message) {
+  return WebSocketEventInterface::CHANNEL_ALIVE;
+}
+
+ChannelState WebSocketEventHandler::OnStartOpeningHandshake(
+    scoped_ptr<net::WebSocketHandshakeRequestInfo> request) {
+  return WebSocketEventInterface::CHANNEL_ALIVE;
+}
+
+ChannelState WebSocketEventHandler::OnFinishOpeningHandshake(
+    scoped_ptr<net::WebSocketHandshakeResponseInfo> response) {
+  return WebSocketEventInterface::CHANNEL_ALIVE;
+}
+
+ChannelState WebSocketEventHandler::OnSSLCertificateError(
+    scoped_ptr<net::WebSocketEventInterface::SSLErrorCallbacks> callbacks,
+    const GURL& url,
+    const net::SSLInfo& ssl_info,
+    bool fatal) {
+  // The above method is always asynchronous.
+  return WebSocketEventInterface::CHANNEL_ALIVE;
+}
+
+}  // namespace mojo
+
+WebSocketImpl::WebSocketImpl(NetworkContext* context) : context_(context) {
+}
+
+WebSocketImpl::~WebSocketImpl() {
+}
+
+void WebSocketImpl::Connect(const String& url,
+                            Array<String> protocols,
+                            const String& origin,
+                            WebSocketClientPtr client) {
+  DCHECK(!channel_);
+  scoped_ptr<net::WebSocketEventInterface> event_interface(
+      new WebSocketEventHandler(client.Pass()));
+  channel_.reset(new net::WebSocketChannel(event_interface.Pass(),
+                                           context_->url_request_context()));
+  channel_->SendAddChannelRequest(GURL(url.get()),
+                                  protocols.To<std::vector<std::string> >(),
+                                  url::Origin(origin.get()));
+}
+
+void WebSocketImpl::Send(bool fin,
+                         WebSocket::MessageType type,
+                         ScopedDataPipeConsumerHandle data_pipe) {
+  DCHECK(channel_);
+  uint32_t num_bytes;
+  ReadDataRaw(data_pipe.get(), NULL, &num_bytes, MOJO_READ_DATA_FLAG_QUERY);
+  std::vector<char> data(num_bytes);
+  ReadDataRaw(data_pipe.get(), &data[0], &num_bytes, MOJO_READ_DATA_FLAG_NONE);
+  channel_->SendFrame(
+      fin, ConvertTo<net::WebSocketFrameHeader::OpCode>(type), data);
+}
+
+void WebSocketImpl::FlowControl(int64_t quota) {
+  DCHECK(channel_);
+  channel_->SendFlowControl(quota);
+}
+
+void WebSocketImpl::Close(int16_t code, const String& reason) {
+  DCHECK(channel_);
+  channel_->StartClosingHandshake(code, reason);
+}
+
+
+}  // namespace mojo