Restructure contents of blimp/client.

blimp/client/session/render_widget_feature.cc

-// Copyright 2015 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 "blimp/client/session/render_widget_feature.h"
-
-#include "base/numerics/safe_conversions.h"
-#include "blimp/common/create_blimp_message.h"
-#include "blimp/common/proto/blimp_message.pb.h"
-#include "blimp/common/proto/compositor.pb.h"
-#include "blimp/common/proto/input.pb.h"
-#include "blimp/common/proto/render_widget.pb.h"
-#include "cc/proto/compositor_message.pb.h"
-#include "net/base/net_errors.h"
-
-namespace blimp {
-namespace client {
-
-RenderWidgetFeature::RenderWidgetFeature() {}
-
-RenderWidgetFeature::~RenderWidgetFeature() {}
-
-void RenderWidgetFeature::set_outgoing_input_message_processor(
-    scoped_ptr<BlimpMessageProcessor> processor) {
-  outgoing_input_message_processor_ = std::move(processor);
-}
-
-void RenderWidgetFeature::set_outgoing_compositor_message_processor(
-    scoped_ptr<BlimpMessageProcessor> processor) {
-  outgoing_compositor_message_processor_ = std::move(processor);
-}
-
-void RenderWidgetFeature::SendInputEvent(const int tab_id,
-                                         const blink::WebInputEvent& event) {
-  scoped_ptr<BlimpMessage> blimp_message =
-      input_message_generator_.GenerateMessage(event);
-
-  // Don't send unsupported WebInputEvents.
-  if (!blimp_message)
-    return;
-
-  blimp_message->set_target_tab_id(tab_id);
-  blimp_message->mutable_input()->set_render_widget_id(
-      GetRenderWidgetId(tab_id));
-
-  outgoing_input_message_processor_->ProcessMessage(std::move(blimp_message),
-                                                    net::CompletionCallback());
-}
-
-void RenderWidgetFeature::SendCompositorMessage(
-    const int tab_id,
-    const cc::proto::CompositorMessage& message) {
-  CompositorMessage* compositor_message;
-  scoped_ptr<BlimpMessage> blimp_message =
-      CreateBlimpMessage(&compositor_message, tab_id);
-
-  uint32_t render_widget_id = GetRenderWidgetId(tab_id);
-  DCHECK_LT(0U, render_widget_id);
-  compositor_message->set_render_widget_id(render_widget_id);
-  compositor_message->mutable_payload()->resize(
-      base::checked_cast<size_t>(message.ByteSize()));
-  if (message.SerializeToString(compositor_message->mutable_payload())) {
-    outgoing_compositor_message_processor_->ProcessMessage(
-        std::move(blimp_message), net::CompletionCallback());
-  } else {
-    LOG(ERROR) << "Unable to serialize compositor proto.";
-  }
-}
-
-void RenderWidgetFeature::SetDelegate(const int tab_id,
-                                      RenderWidgetFeatureDelegate* delegate) {
-  DCHECK(!FindDelegate(tab_id));
-  delegates_[tab_id] = delegate;
-}
-
-void RenderWidgetFeature::RemoveDelegate(const int tab_id) {
-  DelegateMap::iterator it = delegates_.find(tab_id);
-  if (it != delegates_.end())
-    delegates_.erase(it);
-}
-
-void RenderWidgetFeature::ProcessMessage(
-    scoped_ptr<BlimpMessage> message,
-    const net::CompletionCallback& callback) {
-  DCHECK(!callback.is_null());
-  DCHECK(message->type() == BlimpMessage::RENDER_WIDGET ||
-         message->type() == BlimpMessage::COMPOSITOR);
-
-  int target_tab_id = message->target_tab_id();
-  RenderWidgetFeatureDelegate* delegate = FindDelegate(target_tab_id);
-  DCHECK(delegate) << "RenderWidgetFeatureDelegate not found for "
-                   << target_tab_id;
-
-  switch (message->type()) {
-    case BlimpMessage::RENDER_WIDGET:
-      if (message->render_widget().type() == RenderWidgetMessage::INITIALIZE) {
-        render_widget_ids_[target_tab_id] =
-            message->render_widget().render_widget_id();
-        delegate->OnRenderWidgetInitialized();
-      }
-      break;
-    case BlimpMessage::COMPOSITOR: {
-      DCHECK_EQ(message->compositor().render_widget_id(),
-                GetRenderWidgetId(target_tab_id));
-      scoped_ptr<cc::proto::CompositorMessage> payload(
-          new cc::proto::CompositorMessage);
-      if (payload->ParseFromString(message->compositor().payload())) {
-        delegate->OnCompositorMessageReceived(std::move(payload));
-      }
-    } break;
-    default:
-      NOTIMPLEMENTED();
-  }
-
-  callback.Run(net::OK);
-}
-
-RenderWidgetFeature::RenderWidgetFeatureDelegate*
-RenderWidgetFeature::FindDelegate(const int tab_id) {
-  DelegateMap::const_iterator it = delegates_.find(tab_id);
-  if (it != delegates_.end())
-    return it->second;
-  return nullptr;
-}
-
-uint32_t RenderWidgetFeature::GetRenderWidgetId(const int tab_id) {
-  RenderWidgetIdMap::const_iterator it = render_widget_ids_.find(tab_id);
-  if (it != render_widget_ids_.end())
-    return it->second;
-  return 0U;
-}
-
-}  // namespace client
-}  // namespace blimp