| OLD | NEW |
| (Empty) |
| 1 // Copyright 2017 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "chrome/browser/media/router/browser_presentation_connection_proxy.h" | |
| 6 | |
| 7 #include "chrome/browser/media/router/media_router.h" | |
| 8 #include "content/public/common/presentation_constants.h" | |
| 9 | |
| 10 namespace { | |
| 11 | |
| 12 // TODO(crbug.com/632623): remove this function when we finish typemaps for | |
| 13 // presentation.mojom. | |
| 14 std::unique_ptr<content::PresentationConnectionMessage> | |
| 15 PresentationConnectionMessageFromMojo( | |
| 16 blink::mojom::ConnectionMessagePtr input) { | |
| 17 std::unique_ptr<content::PresentationConnectionMessage> output; | |
| 18 if (input.is_null()) | |
| 19 return output; | |
| 20 | |
| 21 switch (input->type) { | |
| 22 case blink::mojom::PresentationMessageType::TEXT: { | |
| 23 // Return nullptr content::PresentationSessionMessage if invalid (unset | |
| 24 // |message|, set |data|, or size too large). | |
| 25 if (input->data || !input->message || | |
| 26 input->message->size() > | |
| 27 content::kMaxPresentationConnectionMessageSize) | |
| 28 return output; | |
| 29 | |
| 30 output.reset(new content::PresentationConnectionMessage( | |
| 31 content::PresentationMessageType::TEXT)); | |
| 32 output->message = std::move(input->message.value()); | |
| 33 return output; | |
| 34 } | |
| 35 case blink::mojom::PresentationMessageType::BINARY: { | |
| 36 // Return nullptr content::PresentationSessionMessage if invalid (unset | |
| 37 // |data|, set |message|, or size too large). | |
| 38 if (!input->data || input->message || | |
| 39 input->data->size() > content::kMaxPresentationConnectionMessageSize) | |
| 40 return output; | |
| 41 | |
| 42 output.reset(new content::PresentationConnectionMessage( | |
| 43 content::PresentationMessageType::BINARY)); | |
| 44 output->data.reset( | |
| 45 new std::vector<uint8_t>(std::move(input->data.value()))); | |
| 46 return output; | |
| 47 } | |
| 48 } | |
| 49 | |
| 50 NOTREACHED() << "Invalid presentation message type " << input->type; | |
| 51 return output; | |
| 52 } | |
| 53 | |
| 54 } // namespace | |
| 55 | |
| 56 namespace media_router { | |
| 57 | |
| 58 BrowserPresentationConnectionProxy::BrowserPresentationConnectionProxy( | |
| 59 MediaRouter* router, | |
| 60 const MediaRoute::Id& route_id, | |
| 61 blink::mojom::PresentationConnectionRequest receiver_connection_request, | |
| 62 blink::mojom::PresentationConnectionPtr controller_connection_ptr) | |
| 63 : router_(router), | |
| 64 route_id_(route_id), | |
| 65 binding_(this), | |
| 66 target_connection_ptr_(std::move(controller_connection_ptr)) { | |
| 67 DCHECK(router); | |
| 68 DCHECK(target_connection_ptr_); | |
| 69 | |
| 70 binding_.Bind(std::move(receiver_connection_request)); | |
| 71 target_connection_ptr_->DidChangeState( | |
| 72 content::PRESENTATION_CONNECTION_STATE_CONNECTED); | |
| 73 } | |
| 74 | |
| 75 BrowserPresentationConnectionProxy::~BrowserPresentationConnectionProxy() {} | |
| 76 | |
| 77 void BrowserPresentationConnectionProxy::OnMessage( | |
| 78 blink::mojom::ConnectionMessagePtr connection_message, | |
| 79 const OnMessageCallback& on_message_callback) { | |
| 80 DVLOG(2) << "BrowserPresentationConnectionProxy::OnMessage"; | |
| 81 DCHECK(!connection_message.is_null()); | |
| 82 | |
| 83 auto message = | |
| 84 PresentationConnectionMessageFromMojo(std::move(connection_message)); | |
| 85 | |
| 86 if (message->is_binary()) { | |
| 87 router_->SendRouteBinaryMessage(route_id_, std::move(message->data), | |
| 88 on_message_callback); | |
| 89 } else { | |
| 90 router_->SendRouteMessage(route_id_, message->message, on_message_callback); | |
| 91 } | |
| 92 } | |
| 93 | |
| 94 } // namespace media_router | |
| OLD | NEW |