| // Copyright 2013 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/dbus/fake_nfc_adapter_client.h" |
| |
| #include "base/logging.h" |
| #include "chromeos/dbus/dbus_thread_manager.h" |
| #include "chromeos/dbus/fake_nfc_device_client.h" |
| #include "chromeos/dbus/fake_nfc_tag_client.h" |
| #include "chromeos/dbus/nfc_client_helpers.h" |
| #include "dbus/message.h" |
| #include "dbus/object_path.h" |
| #include "third_party/cros_system_api/dbus/service_constants.h" |
| |
| namespace chromeos { |
| |
| using nfc_client_helpers::ObjectPathVector; |
| |
| const char FakeNfcAdapterClient::kAdapterPath0[] = "/fake/nfc0"; |
| const char FakeNfcAdapterClient::kAdapterPath1[] = "/fake/nfc1"; |
| |
| FakeNfcAdapterClient::Properties::Properties( |
| const PropertyChangedCallback& callback) |
| : NfcAdapterClient::Properties(NULL, callback) { |
| } |
| |
| FakeNfcAdapterClient::Properties::~Properties() { |
| } |
| |
| void FakeNfcAdapterClient::Properties::Get( |
| dbus::PropertyBase* property, |
| dbus::PropertySet::GetCallback callback) { |
| VLOG(1) << "Get " << property->name(); |
| callback.Run(false); |
| } |
| |
| void FakeNfcAdapterClient::Properties::GetAll() { |
| VLOG(1) << "GetAll"; |
| } |
| |
| void FakeNfcAdapterClient::Properties::Set( |
| dbus::PropertyBase* property, |
| dbus::PropertySet::SetCallback callback) { |
| VLOG(1) << "Set " << property->name(); |
| if (property->name() != powered.name()) { |
| callback.Run(false); |
| return; |
| } |
| |
| // Cannot set the power if currently polling. |
| if (polling.value()) { |
| LOG(ERROR) << "Cannot set power while polling."; |
| callback.Run(false); |
| return; |
| } |
| |
| // Cannot set power if there is a device or a tag that is currently |
| // "paired". |
| if (!devices.value().empty() || !tags.value().empty()) { |
| LOG(ERROR) << "Cannot set power while the device is paired."; |
| callback.Run(false); |
| return; |
| } |
| |
| // Obtain the cached "set value" and send a property changed signal only if |
| // its value is different from the current value of the property. |
| scoped_ptr<dbus::Response> response(dbus::Response::CreateEmpty()); |
| dbus::MessageWriter writer(response.get()); |
| property->AppendSetValueToWriter(&writer); |
| dbus::MessageReader reader(response.get()); |
| bool set_value = false; |
| if (!reader.PopVariantOfBool(&set_value) || set_value == powered.value()) { |
| LOG(WARNING) << "Property has not changed."; |
| callback.Run(false); |
| return; |
| } |
| property->ReplaceValueWithSetValue(); |
| callback.Run(true); |
| } |
| |
| FakeNfcAdapterClient::FakeNfcAdapterClient() |
| : present_(true), |
| second_present_(false), |
| start_pairing_on_poll_(true), |
| device_pairing_(false) { |
| VLOG(1) << "Creating FakeNfcAdapterClient"; |
| |
| std::vector<std::string> protocols; |
| protocols.push_back(nfc_common::kProtocolFelica); |
| protocols.push_back(nfc_common::kProtocolMifare); |
| protocols.push_back(nfc_common::kProtocolJewel); |
| protocols.push_back(nfc_common::kProtocolIsoDep); |
| protocols.push_back(nfc_common::kProtocolNfcDep); |
| |
| properties_.reset(new Properties(base::Bind( |
| &FakeNfcAdapterClient::OnPropertyChanged, |
| base::Unretained(this), |
| dbus::ObjectPath(kAdapterPath0)))); |
| properties_->protocols.ReplaceValue(protocols); |
| |
| second_properties_.reset(new Properties(base::Bind( |
| &FakeNfcAdapterClient::OnPropertyChanged, |
| base::Unretained(this), |
| dbus::ObjectPath(kAdapterPath1)))); |
| second_properties_->protocols.ReplaceValue(protocols); |
| } |
| |
| FakeNfcAdapterClient::~FakeNfcAdapterClient() { |
| } |
| |
| void FakeNfcAdapterClient::Init(dbus::Bus* bus) { |
| } |
| |
| void FakeNfcAdapterClient::AddObserver(Observer* observer) { |
| observers_.AddObserver(observer); |
| } |
| |
| void FakeNfcAdapterClient::RemoveObserver(Observer* observer) { |
| observers_.RemoveObserver(observer); |
| } |
| |
| std::vector<dbus::ObjectPath> FakeNfcAdapterClient::GetAdapters() { |
| std::vector<dbus::ObjectPath> object_paths; |
| if (present_) |
| object_paths.push_back(dbus::ObjectPath(kAdapterPath0)); |
| if (second_present_) |
| object_paths.push_back(dbus::ObjectPath(kAdapterPath1)); |
| return object_paths; |
| } |
| |
| FakeNfcAdapterClient::Properties* |
| FakeNfcAdapterClient::GetProperties(const dbus::ObjectPath& object_path) { |
| if (object_path == dbus::ObjectPath(kAdapterPath0)) |
| return properties_.get(); |
| if (object_path == dbus::ObjectPath(kAdapterPath1)) |
| return second_properties_.get(); |
| return NULL; |
| } |
| |
| void FakeNfcAdapterClient::StartPollLoop( |
| const dbus::ObjectPath& object_path, |
| const std::string& mode, |
| const base::Closure& callback, |
| const nfc_client_helpers::ErrorCallback& error_callback) { |
| VLOG(1) << "FakeNfcAdapterClient::StartPollLoop"; |
| if (object_path != dbus::ObjectPath(kAdapterPath0)) { |
| error_callback.Run(nfc_client_helpers::kNoResponseError, ""); |
| return; |
| } |
| if (!properties_->powered.value()) { |
| error_callback.Run(nfc_error::kFailed, "Adapter not powered."); |
| return; |
| } |
| if (properties_->polling.value()) { |
| error_callback.Run(nfc_error::kFailed, "Already polling."); |
| return; |
| } |
| if (!properties_->devices.value().empty() || |
| !properties_->tags.value().empty()) { |
| error_callback.Run(nfc_error::kFailed, "Adapter busy."); |
| return; |
| } |
| properties_->polling.ReplaceValue(true); |
| properties_->mode.ReplaceValue(mode); |
| callback.Run(); |
| |
| if (!start_pairing_on_poll_) |
| return; |
| |
| if (device_pairing_) { |
| FakeNfcDeviceClient* device_client = |
| static_cast<FakeNfcDeviceClient*>( |
| DBusThreadManager::Get()->GetNfcDeviceClient()); |
| device_client->BeginPairingSimulation(3000, 2000); |
| } else { |
| FakeNfcTagClient* tag_client = |
| static_cast<FakeNfcTagClient*>( |
| DBusThreadManager::Get()->GetNfcTagClient()); |
| tag_client->BeginPairingSimulation(2000); |
| } |
| device_pairing_ = !device_pairing_; |
| } |
| |
| void FakeNfcAdapterClient::StopPollLoop( |
| const dbus::ObjectPath& object_path, |
| const base::Closure& callback, |
| const nfc_client_helpers::ErrorCallback& error_callback) { |
| VLOG(1) << "FakeNfcAdapterClient::StopPollLoop."; |
| if (object_path != dbus::ObjectPath(kAdapterPath0)) { |
| error_callback.Run(nfc_client_helpers::kNoResponseError, ""); |
| return; |
| } |
| if (!properties_->polling.value()) { |
| error_callback.Run("org.neard.Error.Failed", "Not polling."); |
| return; |
| } |
| FakeNfcDeviceClient* device_client = |
| static_cast<FakeNfcDeviceClient*>( |
| DBusThreadManager::Get()->GetNfcDeviceClient()); |
| device_client->EndPairingSimulation(); |
| FakeNfcTagClient* tag_client = |
| static_cast<FakeNfcTagClient*>( |
| DBusThreadManager::Get()->GetNfcTagClient()); |
| tag_client->EndPairingSimulation(); |
| properties_->polling.ReplaceValue(false); |
| callback.Run(); |
| } |
| |
| void FakeNfcAdapterClient::SetAdapterPresent(bool present) { |
| if (present == present_) |
| return; |
| present_ = present; |
| if (present_) { |
| FOR_EACH_OBSERVER(NfcAdapterClient::Observer, observers_, |
| AdapterAdded(dbus::ObjectPath(kAdapterPath0))); |
| } else { |
| FOR_EACH_OBSERVER(NfcAdapterClient::Observer, observers_, |
| AdapterRemoved(dbus::ObjectPath(kAdapterPath0))); |
| } |
| } |
| |
| void FakeNfcAdapterClient::SetSecondAdapterPresent(bool present) { |
| if (present == second_present_) |
| return; |
| second_present_ = present; |
| if (present_) { |
| FOR_EACH_OBSERVER(NfcAdapterClient::Observer, observers_, |
| AdapterAdded(dbus::ObjectPath(kAdapterPath1))); |
| } else { |
| FOR_EACH_OBSERVER(NfcAdapterClient::Observer, observers_, |
| AdapterRemoved(dbus::ObjectPath(kAdapterPath1))); |
| } |
| } |
| |
| void FakeNfcAdapterClient::SetDevice(const dbus::ObjectPath& device_path) { |
| LOG(INFO) << "Add device path to the fake adapter: " << device_path.value(); |
| if (!properties_->polling.value()) { |
| LOG(ERROR) << "Adapter not polling, cannot set device."; |
| return; |
| } |
| const ObjectPathVector& devices(properties_->devices.value()); |
| for (ObjectPathVector::const_iterator iter = devices.begin(); |
| iter != devices.end(); ++iter) { |
| if (*iter == device_path) { |
| LOG(WARNING) << "Device path already in list of devices."; |
| return; |
| } |
| } |
| // Mark as not polling. |
| properties_->polling.ReplaceValue(false); |
| |
| ObjectPathVector new_devices = devices; |
| new_devices.push_back(device_path); |
| properties_->devices.ReplaceValue(new_devices); |
| } |
| |
| void FakeNfcAdapterClient::SetTag(const dbus::ObjectPath& tag_path) { |
| LOG(INFO) << "Add tag path to the fake adapter: " << tag_path.value(); |
| if (!properties_->polling.value()) { |
| LOG(ERROR) << "Adapter not polling, cannot set tag."; |
| return; |
| } |
| const ObjectPathVector& tags(properties_->tags.value()); |
| for (ObjectPathVector::const_iterator iter = tags.begin(); |
| iter != tags.end(); ++iter) { |
| if (*iter == tag_path) { |
| LOG(WARNING) << "Tag path already in list of tags."; |
| return; |
| } |
| } |
| // Mark as not polling. |
| properties_->polling.ReplaceValue(false); |
| |
| ObjectPathVector new_tags = tags; |
| new_tags.push_back(tag_path); |
| properties_->tags.ReplaceValue(new_tags); |
| } |
| |
| void FakeNfcAdapterClient::UnsetDevice(const dbus::ObjectPath& device_path) { |
| LOG(INFO) << "Remove device path from the fake adapter: " |
| << device_path.value(); |
| ObjectPathVector new_devices = properties_->devices.value(); |
| for (ObjectPathVector::iterator iter = new_devices.begin(); |
| iter != new_devices.end(); ++iter) { |
| if (*iter == device_path) { |
| new_devices.erase(iter); |
| properties_->devices.ReplaceValue(new_devices); |
| |
| // Mark as polling. |
| DCHECK(!properties_->polling.value()); |
| properties_->polling.ReplaceValue(true); |
| return; |
| } |
| } |
| LOG(WARNING) << "Device path not in list of devices."; |
| } |
| |
| void FakeNfcAdapterClient::UnsetTag(const dbus::ObjectPath& tag_path) { |
| LOG(INFO) << "Remove tag path from the fake adapter: " << tag_path.value(); |
| ObjectPathVector new_tags = properties_->tags.value(); |
| for (ObjectPathVector::iterator iter = new_tags.begin(); |
| iter != new_tags.end(); ++iter) { |
| if (*iter == tag_path) { |
| new_tags.erase(iter); |
| properties_->tags.ReplaceValue(new_tags); |
| |
| // Mark as polling. |
| DCHECK(!properties_->polling.value()); |
| properties_->polling.ReplaceValue(true); |
| return; |
| } |
| } |
| LOG(WARNING) << "Tag path not in list of tags."; |
| } |
| |
| void FakeNfcAdapterClient::EnablePairingOnPoll(bool enabled) { |
| start_pairing_on_poll_ = enabled; |
| } |
| |
| void FakeNfcAdapterClient::OnPropertyChanged( |
| const dbus::ObjectPath& object_path, |
| const std::string& property_name) { |
| FOR_EACH_OBSERVER(NfcAdapterClient::Observer, observers_, |
| AdapterPropertyChanged(object_path, property_name)); |
| } |
| |
| } // namespace chromeos |