Index: components/proximity_auth/messenger_impl.cc |
diff --git a/components/proximity_auth/messenger_impl.cc b/components/proximity_auth/messenger_impl.cc |
index 897f82234f07a06e5906578b23b48d88a7f3482f..200539e9b294e7b7043d1d6382d3d9f63500afda 100644 |
--- a/components/proximity_auth/messenger_impl.cc |
+++ b/components/proximity_auth/messenger_impl.cc |
@@ -14,12 +14,12 @@ |
#include "base/memory/ptr_util.h" |
#include "base/threading/thread_task_runner_handle.h" |
#include "base/values.h" |
-#include "components/proximity_auth/connection.h" |
+#include "components/cryptauth/connection.h" |
+#include "components/cryptauth/wire_message.h" |
#include "components/proximity_auth/logging/logging.h" |
#include "components/proximity_auth/messenger_observer.h" |
#include "components/proximity_auth/remote_status_update.h" |
#include "components/proximity_auth/secure_context.h" |
-#include "components/proximity_auth/wire_message.h" |
namespace proximity_auth { |
namespace { |
@@ -68,7 +68,7 @@ std::string GetMessageType(const base::DictionaryValue& message) { |
} // namespace |
-MessengerImpl::MessengerImpl(std::unique_ptr<Connection> connection, |
+MessengerImpl::MessengerImpl(std::unique_ptr<cryptauth::Connection> connection, |
std::unique_ptr<SecureContext> secure_context) |
: connection_(std::move(connection)), |
secure_context_(std::move(secure_context)), |
@@ -179,7 +179,8 @@ void MessengerImpl::ProcessMessageQueue() { |
} |
void MessengerImpl::OnMessageEncoded(const std::string& encoded_message) { |
- connection_->SendMessage(base::MakeUnique<WireMessage>(encoded_message)); |
+ connection_->SendMessage( |
+ base::MakeUnique<cryptauth::WireMessage>(encoded_message)); |
} |
void MessengerImpl::OnMessageDecoded(const std::string& decoded_message) { |
@@ -306,11 +307,12 @@ void MessengerImpl::PollScreenStateForIOS() { |
base::TimeDelta::FromSeconds(kIOSPollingIntervalSeconds)); |
} |
-void MessengerImpl::OnConnectionStatusChanged(Connection* connection, |
- Connection::Status old_status, |
- Connection::Status new_status) { |
+void MessengerImpl::OnConnectionStatusChanged( |
+ cryptauth::Connection* connection, |
+ cryptauth::Connection::Status old_status, |
+ cryptauth::Connection::Status new_status) { |
DCHECK_EQ(connection, connection_.get()); |
- if (new_status == Connection::DISCONNECTED) { |
+ if (new_status == cryptauth::Connection::DISCONNECTED) { |
PA_LOG(INFO) << "Secure channel disconnected..."; |
connection_->RemoveObserver(this); |
for (auto& observer : observers_) |
@@ -320,15 +322,16 @@ void MessengerImpl::OnConnectionStatusChanged(Connection* connection, |
} |
} |
-void MessengerImpl::OnMessageReceived(const Connection& connection, |
- const WireMessage& wire_message) { |
+void MessengerImpl::OnMessageReceived( |
+ const cryptauth::Connection& connection, |
+ const cryptauth::WireMessage& wire_message) { |
secure_context_->Decode(wire_message.payload(), |
base::Bind(&MessengerImpl::OnMessageDecoded, |
weak_ptr_factory_.GetWeakPtr())); |
} |
-void MessengerImpl::OnSendCompleted(const Connection& connection, |
- const WireMessage& wire_message, |
+void MessengerImpl::OnSendCompleted(const cryptauth::Connection& connection, |
+ const cryptauth::WireMessage& wire_message, |
bool success) { |
if (!pending_message_) { |
PA_LOG(ERROR) << "Unexpected message sent."; |