Chromium Code Reviews| Index: chrome/browser/media/cast_remoting_connector_unittest.cc |
| diff --git a/chrome/browser/media/cast_remoting_connector_unittest.cc b/chrome/browser/media/cast_remoting_connector_unittest.cc |
| index a258a7ae1273400677d7c8bad6b3ceb6af5fa83b..bbf74060202325e8793cdfa3f3d9c47ae0bc0ae1 100644 |
| --- a/chrome/browser/media/cast_remoting_connector_unittest.cc |
| +++ b/chrome/browser/media/cast_remoting_connector_unittest.cc |
| @@ -15,8 +15,8 @@ |
| #include "chrome/browser/media/router/route_message_observer.h" |
| #include "chrome/common/media_router/media_route.h" |
| #include "chrome/common/media_router/media_source.h" |
| -#include "chrome/common/media_router/route_message.h" |
| #include "content/public/browser/browser_thread.h" |
| +#include "content/public/common/presentation_connection_message.h" |
| #include "content/public/test/test_browser_thread_bundle.h" |
| #include "media/mojo/interfaces/remoting.mojom.h" |
| #include "mojo/public/cpp/bindings/binding.h" |
| @@ -24,6 +24,7 @@ |
| #include "testing/gtest/include/gtest/gtest.h" |
| using content::BrowserThread; |
| +using content::PresentationConnectionMessage; |
| using media::mojom::RemoterPtr; |
| using media::mojom::RemoterRequest; |
| @@ -36,7 +37,6 @@ using media::mojom::RemotingStopReason; |
| using media_router::MediaRoutesObserver; |
| using media_router::MediaRoute; |
| using media_router::MediaSource; |
| -using media_router::RouteMessage; |
| using media_router::RouteMessageObserver; |
| using ::testing::_; |
| @@ -102,9 +102,8 @@ class FakeMediaRouter : public media_router::MockMediaRouter { |
| } |
| void OnMessageFromProvider(const std::string& message) { |
| - inbound_messages_.push_back(RouteMessage()); |
| - inbound_messages_.back().type = RouteMessage::TEXT; |
| - inbound_messages_.back().text = message; |
| + inbound_messages_.push_back(PresentationConnectionMessage()); |
|
mark a. foltz
2017/06/28 07:29:54
Does emplace_back(message) work here and below?
imcheng
2017/06/29 08:21:08
Done.
|
| + inbound_messages_.back().message = message; |
| BrowserThread::PostTask( |
| BrowserThread::UI, FROM_HERE, |
| base::BindOnce(&FakeMediaRouter::DoDeliverInboundMessages, |
| @@ -112,20 +111,20 @@ class FakeMediaRouter : public media_router::MockMediaRouter { |
| } |
| void OnBinaryMessageFromProvider(const std::vector<uint8_t>& message) { |
| - inbound_messages_.push_back(RouteMessage()); |
| - inbound_messages_.back().type = RouteMessage::BINARY; |
| - inbound_messages_.back().binary = std::vector<uint8_t>(message); |
| + inbound_messages_.push_back(PresentationConnectionMessage()); |
| + inbound_messages_.back().data = std::vector<uint8_t>(message); |
| BrowserThread::PostTask( |
| BrowserThread::UI, FROM_HERE, |
| base::BindOnce(&FakeMediaRouter::DoDeliverInboundMessages, |
| weak_factory_.GetWeakPtr())); |
| } |
| - void TakeMessagesSentToProvider(RouteMessage::Type type, |
| - std::vector<RouteMessage>* messages) { |
| + void TakeMessagesSentToProvider( |
| + bool text, |
| + std::vector<PresentationConnectionMessage>* messages) { |
| decltype(outbound_messages_) untaken_messages; |
| for (auto& entry : outbound_messages_) { |
| - if (entry.first.type == type) { |
| + if (entry.first.message.has_value() == text) { |
|
mark a. foltz
2017/06/28 07:29:54
Did you mean !entry.first.is_binary() ?
imcheng
2017/06/29 08:21:09
Done.
|
| messages->push_back(entry.first); |
| BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, |
| base::BindOnce(std::move(entry.second), true)); |
| @@ -167,9 +166,8 @@ class FakeMediaRouter : public media_router::MockMediaRouter { |
| SendRouteMessageCallback callback) final { |
| EXPECT_EQ(message_observer_->route_id(), route_id); |
| ASSERT_FALSE(callback.is_null()); |
| - RouteMessage message; |
| - message.type = RouteMessage::TEXT; |
| - message.text = text; |
| + PresentationConnectionMessage message; |
|
mark a. foltz
2017/06/28 07:29:54
message(text)
imcheng
2017/06/29 08:21:08
Done.
|
| + message.message = text; |
| outbound_messages_.push_back(std::make_pair(message, std::move(callback))); |
| } |
| @@ -179,9 +177,8 @@ class FakeMediaRouter : public media_router::MockMediaRouter { |
| EXPECT_EQ(message_observer_->route_id(), route_id); |
| ASSERT_TRUE(!!data); |
| ASSERT_FALSE(callback.is_null()); |
| - RouteMessage message; |
| - message.type = RouteMessage::BINARY; |
| - message.binary = std::move(*data); |
| + PresentationConnectionMessage message; |
|
mark a. foltz
2017/06/28 07:29:54
message(*data)
imcheng
2017/06/29 08:21:08
Done.
|
| + message.data = std::move(*data); |
| outbound_messages_.push_back(std::make_pair(message, std::move(callback))); |
| } |
| @@ -205,10 +202,10 @@ class FakeMediaRouter : public media_router::MockMediaRouter { |
| std::vector<MediaRoute> routes_; |
| // Messages from Cast Provider to the connector. |
| - std::vector<RouteMessage> inbound_messages_; |
| + std::vector<PresentationConnectionMessage> inbound_messages_; |
| // Messages from the connector to the Cast Provider. |
| using OutboundMessageAndCallback = |
| - std::pair<RouteMessage, SendRouteMessageCallback>; |
| + std::pair<PresentationConnectionMessage, SendRouteMessageCallback>; |
| std::vector<OutboundMessageAndCallback> outbound_messages_; |
| base::WeakPtrFactory<FakeMediaRouter> weak_factory_; |
| @@ -271,11 +268,11 @@ class CastRemotingConnectorTest : public ::testing::Test { |
| } |
| void ConnectorSentMessageToProvider(const std::string& expected_message) { |
| - std::vector<RouteMessage> messages; |
| - media_router_.TakeMessagesSentToProvider(RouteMessage::TEXT, &messages); |
| + std::vector<PresentationConnectionMessage> messages; |
| + media_router_.TakeMessagesSentToProvider(true, &messages); |
| bool did_see_expected_message = false; |
| - for (const RouteMessage& message : messages) { |
| - if (message.text && expected_message == *message.text) { |
| + for (const PresentationConnectionMessage& message : messages) { |
|
mark a. foltz
2017/06/28 07:29:55
const auto& ?
imcheng
2017/06/29 08:21:09
Done.
|
| + if (message.message && expected_message == *message.message) { |
|
mark a. foltz
2017/06/28 07:29:54
if (expected_message == message.message)
Here and
imcheng
2017/06/29 08:21:09
I don't think you can use std::string operator== o
mark a. foltz
2017/06/29 17:38:56
There's an operator declared in optional.h.
https
imcheng
2017/06/29 17:58:22
Oh that's right. I tried it and it compiles and I
|
| did_see_expected_message = true; |
| } else { |
| ADD_FAILURE() |
| @@ -287,11 +284,11 @@ class CastRemotingConnectorTest : public ::testing::Test { |
| void ConnectorSentMessageToSink( |
| const std::vector<uint8_t>& expected_message) { |
| - std::vector<RouteMessage> messages; |
| - media_router_.TakeMessagesSentToProvider(RouteMessage::BINARY, &messages); |
| + std::vector<PresentationConnectionMessage> messages; |
| + media_router_.TakeMessagesSentToProvider(false, &messages); |
| bool did_see_expected_message = false; |
| - for (const RouteMessage& message : messages) { |
| - if (message.binary && expected_message == *message.binary) { |
| + for (const auto& message : messages) { |
| + if (message.data && expected_message == *message.data) { |
| did_see_expected_message = true; |
| } else { |
| ADD_FAILURE() |
| @@ -302,14 +299,14 @@ class CastRemotingConnectorTest : public ::testing::Test { |
| } |
| void ConnectorSentNoMessagesToProvider() { |
| - std::vector<RouteMessage> messages; |
| - media_router_.TakeMessagesSentToProvider(RouteMessage::TEXT, &messages); |
| + std::vector<PresentationConnectionMessage> messages; |
| + media_router_.TakeMessagesSentToProvider(true, &messages); |
| EXPECT_TRUE(messages.empty()); |
| } |
| void ConnectorSentNoMessagesToSink() { |
| - std::vector<RouteMessage> messages; |
| - media_router_.TakeMessagesSentToProvider(RouteMessage::BINARY, &messages); |
| + std::vector<PresentationConnectionMessage> messages; |
| + media_router_.TakeMessagesSentToProvider(false, &messages); |
| EXPECT_TRUE(messages.empty()); |
| } |