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 |