Chromium Code Reviews| Index: chromeos/components/tether/active_host.cc |
| diff --git a/chromeos/components/tether/active_host.cc b/chromeos/components/tether/active_host.cc |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..ddfa0fe86aefa2834ccb83484b7229d2c3302236 |
| --- /dev/null |
| +++ b/chromeos/components/tether/active_host.cc |
| @@ -0,0 +1,139 @@ |
| +// 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/active_host.h" |
| + |
| +#include "base/bind.h" |
| +#include "base/values.h" |
| +#include "chromeos/components/tether/pref_names.h" |
| +#include "chromeos/components/tether/tether_host_fetcher.h" |
| +#include "components/cryptauth/remote_device.h" |
| +#include "components/prefs/pref_registry_simple.h" |
| +#include "components/prefs/pref_service.h" |
| +#include "components/proximity_auth/logging/logging.h" |
| + |
| +namespace chromeos { |
| + |
| +namespace tether { |
| + |
| +ActiveHost::ActiveHost(TetherHostFetcher* tether_host_fetcher, |
| + PrefService* pref_service) |
| + : tether_host_fetcher_(tether_host_fetcher), |
| + pref_service_(pref_service), |
| + weak_ptr_factory_(this) {} |
| + |
| +ActiveHost::~ActiveHost() {} |
| + |
| +// static |
| +void ActiveHost::RegisterPrefs(PrefRegistrySimple* registry) { |
| + registry->RegisterIntegerPref( |
| + prefs::kActiveHostStatus, |
| + static_cast<int>(ActiveHostStatus::DISCONNECTED)); |
| + registry->RegisterStringPref(prefs::kActiveHostDeviceId, ""); |
| + registry->RegisterStringPref(prefs::kWifiNetworkId, ""); |
| +} |
| + |
| +void ActiveHost::SetActiveHostDisconnected() { |
| + SetActiveHost(ActiveHostStatus::DISCONNECTED, "" /* active_host_device_id */, |
| + "" /* wifi_network_id */); |
| +} |
| + |
| +void ActiveHost::SetActiveHostConnecting( |
| + const std::string& active_host_device_id) { |
| + DCHECK(!active_host_device_id.empty()); |
| + |
| + SetActiveHost(ActiveHostStatus::CONNECTING, active_host_device_id, |
| + "" /* wifi_network_id */); |
| +} |
| + |
| +void ActiveHost::SetActiveHostConnected( |
| + const std::string& active_host_device_id, |
| + const std::string& wifi_network_id) { |
| + DCHECK(!active_host_device_id.empty()); |
| + DCHECK(!wifi_network_id.empty()); |
| + |
| + SetActiveHost(ActiveHostStatus::CONNECTED, active_host_device_id, |
| + wifi_network_id); |
| +} |
| + |
| +void ActiveHost::GetActiveHost(const ActiveHostCallback& active_host_callback) { |
| + ActiveHostStatus status = GetActiveHostStatus(); |
| + |
| + if (status == ActiveHostStatus::DISCONNECTED) { |
| + active_host_callback.Run(status, nullptr /* active_host */, |
| + "" /* wifi_network_id */); |
| + return; |
| + } |
| + |
| + std::string active_host_device_id = GetActiveHostDeviceId(); |
| + DCHECK(!active_host_device_id.empty()); |
| + |
| + tether_host_fetcher_->FetchTetherHost( |
| + active_host_device_id, |
| + base::Bind(&ActiveHost::OnTetherHostFetched, |
| + weak_ptr_factory_.GetWeakPtr(), active_host_callback)); |
| +} |
| + |
| +ActiveHost::ActiveHostStatus ActiveHost::GetActiveHostStatus() const { |
| + return static_cast<ActiveHostStatus>( |
| + pref_service_->GetInteger(prefs::kActiveHostStatus)); |
| +} |
| + |
| +const std::string ActiveHost::GetActiveHostDeviceId() const { |
| + return pref_service_->GetString(prefs::kActiveHostDeviceId); |
| +} |
| + |
| +const std::string ActiveHost::GetWifiNetworkId() const { |
| + return pref_service_->GetString(prefs::kWifiNetworkId); |
| +} |
| + |
| +void ActiveHost::SetActiveHost(ActiveHostStatus active_host_status, |
| + const std::string& active_host_device_id, |
| + const std::string& wifi_network_id) { |
| + pref_service_->Set(prefs::kActiveHostStatus, |
| + base::Value(static_cast<int>(active_host_status))); |
| + pref_service_->Set(prefs::kActiveHostDeviceId, |
| + base::Value(active_host_device_id)); |
| + pref_service_->Set(prefs::kWifiNetworkId, base::Value(wifi_network_id)); |
| +} |
| + |
| +void ActiveHost::OnTetherHostFetched( |
| + const ActiveHostCallback& active_host_callback, |
| + std::unique_ptr<cryptauth::RemoteDevice> remote_device) { |
| + if (GetActiveHostDeviceId().empty() || !remote_device) { |
| + DCHECK(GetActiveHostStatus() == ActiveHostStatus::DISCONNECTED); |
| + DCHECK(GetWifiNetworkId().empty()); |
| + |
| + // If the active host became disconnected while the tether host was being |
| + // fetched, forward this information to the callback. |
| + active_host_callback.Run(ActiveHostStatus::DISCONNECTED, |
| + nullptr /* active_host */, |
| + "" /* wifi_network_id */); |
| + return; |
| + } |
| + |
| + if (GetActiveHostDeviceId() != remote_device->GetDeviceId()) { |
| + // If the active host has changed while the tether host was being fetched, |
|
Jeremy Klein
2017/03/09 20:13:02
Do we do this in Android? Is it more likely to cha
Kyle Horimoto
2017/03/09 21:19:38
Nope, we don't. I don't think it's any more likely
|
| + // perform the fetch again. |
| + GetActiveHost(active_host_callback); |
| + return; |
| + } |
| + |
| + if (GetActiveHostStatus() == ActiveHostStatus::CONNECTING) { |
| + DCHECK(GetWifiNetworkId().empty()); |
| + active_host_callback.Run(ActiveHostStatus::CONNECTING, |
| + std::move(remote_device), |
| + "" /* wifi_network_id */); |
| + return; |
| + } |
| + |
| + DCHECK(GetActiveHostStatus() == ActiveHostStatus::CONNECTED); |
| + DCHECK(!GetWifiNetworkId().empty()); |
| + active_host_callback.Run(ActiveHostStatus::CONNECTED, |
| + std::move(remote_device), GetWifiNetworkId()); |
| +} |
| + |
| +} // namespace tether |
| + |
| +} // namespace chromeos |