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

components/proximity_auth/connection.cc

-// 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.
-
-#include "components/proximity_auth/connection.h"
-
-#include <utility>
-
-#include "base/logging.h"
-#include "components/proximity_auth/connection_observer.h"
-#include "components/proximity_auth/wire_message.h"
-
-namespace proximity_auth {
-
-Connection::Connection(const cryptauth::RemoteDevice& remote_device)
-    : remote_device_(remote_device),
-      status_(DISCONNECTED),
-      is_sending_message_(false) {}
-
-Connection::~Connection() {
-}
-
-bool Connection::IsConnected() const {
-  return status_ == CONNECTED;
-}
-
-void Connection::SendMessage(std::unique_ptr<WireMessage> message) {
-  if (!IsConnected()) {
-    VLOG(1) << "Cannot send message when disconnected.";
-    return;
-  }
-
-  if (is_sending_message_) {
-    VLOG(1) << "Another message is currently in progress.";
-    return;
-  }
-
-  is_sending_message_ = true;
-  SendMessageImpl(std::move(message));
-}
-
-void Connection::AddObserver(ConnectionObserver* observer) {
-  observers_.AddObserver(observer);
-}
-
-void Connection::RemoveObserver(ConnectionObserver* observer) {
-  observers_.RemoveObserver(observer);
-}
-
-std::string Connection::GetDeviceAddress() {
-  return remote_device_.bluetooth_address;
-}
-
-void Connection::SetStatus(Status status) {
-  if (status_ == status)
-    return;
-
-  received_bytes_.clear();
-
-  Status old_status = status_;
-  status_ = status;
-  for (auto& observer : observers_)
-    observer.OnConnectionStatusChanged(this, old_status, status_);
-}
-
-void Connection::OnDidSendMessage(const WireMessage& message, bool success) {
-  if (!is_sending_message_) {
-    VLOG(1) << "Send completed, but no message in progress.";
-    return;
-  }
-
-  is_sending_message_ = false;
-  for (auto& observer : observers_)
-    observer.OnSendCompleted(*this, message, success);
-}
-
-void Connection::OnBytesReceived(const std::string& bytes) {
-  if (!IsConnected()) {
-    VLOG(1) << "Received bytes, but not connected.";
-    return;
-  }
-
-  received_bytes_ += bytes;
-
-  bool is_incomplete_message;
-  std::unique_ptr<WireMessage> message =
-      DeserializeWireMessage(&is_incomplete_message);
-  if (is_incomplete_message)
-    return;
-
-  if (message) {
-    for (auto& observer : observers_)
-      observer.OnMessageReceived(*this, *message);
-  }
-
-  // Whether the message was parsed successfully or not, clear the
-  // |received_bytes_| buffer.
-  received_bytes_.clear();
-}
-
-std::unique_ptr<WireMessage> Connection::DeserializeWireMessage(
-    bool* is_incomplete_message) {
-  return WireMessage::Deserialize(received_bytes_, is_incomplete_message);
-}
-
-}  // namespace proximity_auth