[CrOS Tether] Create DisconnectTetheringOperation, which sends a DisconnectTetheringRequest to a re…

chromeos/components/tether/disconnect_tethering_operation.cc

Index: chromeos/components/tether/disconnect_tethering_operation.cc
diff --git a/chromeos/components/tether/disconnect_tethering_operation.cc b/chromeos/components/tether/disconnect_tethering_operation.cc
new file mode 100644
index 0000000000000000000000000000000000000000..f8ba990672e9dda82e45a0a223881292b210d2c2
--- /dev/null
+++ b/chromeos/components/tether/disconnect_tethering_operation.cc
@@ -0,0 +1,85 @@
+// Copyright 2017 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 "chromeos/components/tether/disconnect_tethering_operation.h"
+
+#include "chromeos/components/tether/message_wrapper.h"
+#include "chromeos/components/tether/proto/tether.pb.h"
+#include "components/proximity_auth/logging/logging.h"
+
+namespace chromeos {
+
+namespace tether {
+
+// static
+DisconnectTetheringOperation::Factory*
+    DisconnectTetheringOperation::Factory::factory_instance_ = nullptr;
+
+// static
+std::unique_ptr<DisconnectTetheringOperation>
+DisconnectTetheringOperation::Factory::NewInstance(
+    const cryptauth::RemoteDevice& device_to_connect,
+    BleConnectionManager* connection_manager) {
+  if (!factory_instance_) {
+    factory_instance_ = new Factory();
+  }
+  return factory_instance_->BuildInstance(device_to_connect,
+                                          connection_manager);
+}
+
+// static
+void DisconnectTetheringOperation::Factory::SetInstanceForTesting(
+    Factory* factory) {
+  factory_instance_ = factory;
+}
+
+std::unique_ptr<DisconnectTetheringOperation>
+DisconnectTetheringOperation::Factory::BuildInstance(
+    const cryptauth::RemoteDevice& device_to_connect,
+    BleConnectionManager* connection_manager) {
+  return base::MakeUnique<DisconnectTetheringOperation>(device_to_connect,
+                                                        connection_manager);
+}
+
+DisconnectTetheringOperation::DisconnectTetheringOperation(
+    const cryptauth::RemoteDevice& device_to_connect,
+    BleConnectionManager* connection_manager)
+    : MessageTransferOperation(
+          std::vector<cryptauth::RemoteDevice>{device_to_connect},
+          connection_manager),
+      has_authenticated_(false) {}
+
+DisconnectTetheringOperation::~DisconnectTetheringOperation() {}
+
+void DisconnectTetheringOperation::AddObserver(Observer* observer) {
+  observer_list_.AddObserver(observer);
+}
+
+void DisconnectTetheringOperation::RemoveObserver(Observer* observer) {
+  observer_list_.RemoveObserver(observer);
+}
+
+void DisconnectTetheringOperation::OnDeviceAuthenticated(
+    const cryptauth::RemoteDevice& remote_device) {
+  DCHECK(remote_devices().size() == 1u && remote_devices()[0] == remote_device);
+  has_authenticated_ = true;
+
+  SendMessageToDevice(remote_device, base::MakeUnique<MessageWrapper>(
+                                         DisconnectTetheringRequest()));
+  UnregisterDevice(remote_device);
+}
+
+void DisconnectTetheringOperation::OnOperationFinished() {
+  for (auto& observer : observer_list_) {
+    observer.OnOperationFinished(has_authenticated_);
+  }
+}
+
+MessageType DisconnectTetheringOperation::GetMessageTypeForConnection() {
+  return MessageType::DISCONNECT_TETHERING_REQUEST;
+}
+
+}  // namespace tether
+
+}  // namespace chromeos