Migrate weave-related classes from proximity_auth/ble to cryptauth/ble.

components/proximity_auth/messenger_impl.h

 // Copyright 2014 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.
 
 #ifndef COMPONENTS_PROXIMITY_AUTH_MESSENGER_IMPL_H
 #define COMPONENTS_PROXIMITY_AUTH_MESSENGER_IMPL_H
 
 #include <deque>
 #include <memory>
 
 #include "base/macros.h"
 #include "base/memory/weak_ptr.h"
 #include "base/observer_list.h"
-#include "components/proximity_auth/connection_observer.h"
+#include "components/cryptauth/connection.h"
+#include "components/cryptauth/connection_observer.h"
 #include "components/proximity_auth/messenger.h"
 
 namespace base {
 class DictionaryValue;
 }
 
 namespace proximity_auth {
 
-class Connection;
 class SecureContext;
 
 // Concrete implementation of the Messenger interface.
-class MessengerImpl : public Messenger, public ConnectionObserver {
+class MessengerImpl : public Messenger, public cryptauth::ConnectionObserver {
  public:
   // Constructs a messenger that sends and receives messages over the given
   // |connection|, using the |secure_context| to encrypt and decrypt the
   // messages. The |connection| must be connected. The messenger begins
   // observing messages as soon as it is constructed.
-  MessengerImpl(std::unique_ptr<Connection> connection,
+  MessengerImpl(std::unique_ptr<cryptauth::Connection> connection,
                 std::unique_ptr<SecureContext> secure_context);
   ~MessengerImpl() override;
 
   // Messenger:
   void AddObserver(MessengerObserver* observer) override;
   void RemoveObserver(MessengerObserver* observer) override;
   bool SupportsSignIn() const override;
   void DispatchUnlockEvent() override;
   void RequestDecryption(const std::string& challenge) override;
   void RequestUnlock() override;
   SecureContext* GetSecureContext() const override;
 
   // Exposed for testing.
-  Connection* connection() { return connection_.get(); }
+  cryptauth::Connection* connection() { return connection_.get(); }
 
  private:
   // Internal data structure to represent a pending message that either hasn't
   // been sent yet or is waiting for a response from the remote device.
   struct PendingMessage {
     PendingMessage();
     PendingMessage(const base::DictionaryValue& message);
     PendingMessage(const std::string& message);
     ~PendingMessage();
 
@@ skipping 23 matching lines @@
   void HandleDecryptResponseMessage(const base::DictionaryValue& message);
 
   // Handles an incoming "unlock_response" message, notifying observers of the
   // response.
   void HandleUnlockResponseMessage(const base::DictionaryValue& message);
 
   // For iOS, we need to poll the phone every few seconds to keep the app alive
   // in the background. This function starts the poll loop.
   void PollScreenStateForIOS();
 
-  // ConnectionObserver:
-  void OnConnectionStatusChanged(Connection* connection,
-                                 Connection::Status old_status,
-                                 Connection::Status new_status) override;
-  void OnMessageReceived(const Connection& connection,
-                         const WireMessage& wire_message) override;
-  void OnSendCompleted(const Connection& connection,
-                       const WireMessage& wire_message,
+  // cryptauth::ConnectionObserver:
+  void OnConnectionStatusChanged(
+      cryptauth::Connection* connection,
+      cryptauth::Connection::Status old_status,
+      cryptauth::Connection::Status new_status) override;
+  void OnMessageReceived(const cryptauth::Connection& connection,
+                         const cryptauth::WireMessage& wire_message) override;
+  void OnSendCompleted(const cryptauth::Connection& connection,
+                       const cryptauth::WireMessage& wire_message,
                        bool success) override;
 
   // The connection used to send and receive events and status updates.
-  std::unique_ptr<Connection> connection_;
+  std::unique_ptr<cryptauth::Connection> connection_;
 
   // Used to encrypt and decrypt payloads sent and received over the
   // |connection_|.
   std::unique_ptr<SecureContext> secure_context_;
 
   // The registered observers of |this_| messenger.
   base::ObserverList<MessengerObserver> observers_;
 
   // Queue of messages to send to the remote device.
   std::deque<PendingMessage> queued_messages_;
 
   // The current message being sent or waiting on the remote device for a
   // response. Null if there is no message currently in this state.
   std::unique_ptr<PendingMessage> pending_message_;
 
   base::WeakPtrFactory<MessengerImpl> weak_ptr_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(MessengerImpl);
 };
 
 }  // namespace proximity_auth
 
 #endif  // COMPONENTS_PROXIMITY_AUTH_MESSENGER_IMPL_H