| Index: content/renderer/presentation/presentation_connection_proxy.cc
|
| diff --git a/content/renderer/presentation/presentation_connection_proxy.cc b/content/renderer/presentation/presentation_connection_proxy.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..f4faa028b99018e4403c70a5deac598c574785d4
|
| --- /dev/null
|
| +++ b/content/renderer/presentation/presentation_connection_proxy.cc
|
| @@ -0,0 +1,94 @@
|
| +// Copyright 2016 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 "content/renderer/presentation/presentation_connection_proxy.h"
|
| +
|
| +#include "base/logging.h"
|
| +#include "third_party/WebKit/public/platform/WebString.h"
|
| +#include "third_party/WebKit/public/platform/modules/presentation/WebPresentationConnection.h"
|
| +#include "third_party/WebKit/public/platform/modules/presentation/WebPresentationConnectionClient.h"
|
| +
|
| +namespace content {
|
| +
|
| +PresentationConnectionProxy::PresentationConnectionProxy()
|
| + : binding_(this),
|
| + target_connection_(nullptr),
|
| + source_connection_(nullptr) {}
|
| +
|
| +PresentationConnectionProxy::~PresentationConnectionProxy() = default;
|
| +
|
| +blink::mojom::PresentationConnectionPtr PresentationConnectionProxy::Bind() {
|
| + return binding_.CreateInterfacePtrAndBind();
|
| +}
|
| +
|
| +void PresentationConnectionProxy::SendSessionMessage(
|
| + blink::mojom::PresentationSessionInfoPtr session,
|
| + blink::mojom::SessionMessagePtr session_message) const {
|
| + DCHECK(target_connection_);
|
| + target_connection_->OnMessage(std::move(session_message),
|
| + on_message_callback_);
|
| +}
|
| +
|
| +void PresentationConnectionProxy::SetSourceConnection(
|
| + blink::WebPresentationConnection* connection) {
|
| + DCHECK(!source_connection_);
|
| + source_connection_ = connection;
|
| +}
|
| +
|
| +void PresentationConnectionProxy::SetTargetConnection(
|
| + blink::mojom::PresentationConnectionPtr connection) {
|
| + DCHECK(!target_connection_);
|
| + target_connection_ = std::move(connection);
|
| + target_connection_->DidChangeState(
|
| + blink::mojom::PresentationConnectionState::CONNECTED);
|
| +}
|
| +
|
| +void PresentationConnectionProxy::OnMessage(
|
| + blink::mojom::SessionMessagePtr session_message,
|
| + const OnMessageCallback& callback) {
|
| + DCHECK(source_connection_);
|
| + DCHECK(!callback.is_null());
|
| +
|
| + switch (session_message->type) {
|
| + case blink::mojom::PresentationMessageType::TEXT: {
|
| + DCHECK(session_message->message);
|
| + source_connection_->didReceiveTextMessage(
|
| + blink::WebString::fromUTF8(session_message->message.value()));
|
| + break;
|
| + }
|
| + case blink::mojom::PresentationMessageType::ARRAY_BUFFER:
|
| + case blink::mojom::PresentationMessageType::BLOB: {
|
| + DCHECK(session_message->data);
|
| + source_connection_->didReceiveBinaryMessage(
|
| + &(session_message->data->front()), session_message->data->size());
|
| + break;
|
| + }
|
| + default: {
|
| + NOTREACHED();
|
| + break;
|
| + }
|
| + }
|
| +
|
| + callback.Run(true);
|
| +}
|
| +
|
| +void PresentationConnectionProxy::DidChangeState(
|
| + blink::mojom::PresentationConnectionState state) {
|
| + DCHECK(source_connection_);
|
| + if (state == blink::mojom::PresentationConnectionState::CONNECTED) {
|
| + source_connection_->didChangeState(
|
| + blink::WebPresentationConnectionState::Connected);
|
| + } else {
|
| + // |DidChangeState| should only handles state transition from connecting ->
|
| + // connected. PresentationService and MRP handles other state transitions.
|
| + NOTREACHED();
|
| + }
|
| +}
|
| +
|
| +void PresentationConnectionProxy::RegisterOnMessageCallback(
|
| + const OnMessageCallback& callback) {
|
| + on_message_callback_ = callback;
|
| +}
|
| +
|
| +} // namespace content
|
|
|