| OLD | NEW |
| (Empty) |
| 1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "chromeos/dbus/shill_profile_client_stub.h" | |
| 6 | |
| 7 #include "base/bind.h" | |
| 8 #include "base/bind_helpers.h" | |
| 9 #include "base/message_loop/message_loop.h" | |
| 10 #include "base/stl_util.h" | |
| 11 #include "base/values.h" | |
| 12 #include "chromeos/dbus/dbus_thread_manager.h" | |
| 13 #include "chromeos/dbus/shill_manager_client.h" | |
| 14 #include "chromeos/dbus/shill_property_changed_observer.h" | |
| 15 #include "chromeos/dbus/shill_service_client.h" | |
| 16 #include "dbus/bus.h" | |
| 17 #include "dbus/message.h" | |
| 18 #include "dbus/object_path.h" | |
| 19 #include "dbus/values_util.h" | |
| 20 #include "third_party/cros_system_api/dbus/service_constants.h" | |
| 21 | |
| 22 namespace chromeos { | |
| 23 | |
| 24 struct ShillProfileClientStub::ProfileProperties { | |
| 25 base::DictionaryValue entries; | |
| 26 base::DictionaryValue properties; | |
| 27 }; | |
| 28 | |
| 29 namespace { | |
| 30 | |
| 31 void PassDictionary( | |
| 32 const ShillProfileClient::DictionaryValueCallbackWithoutStatus& callback, | |
| 33 const base::DictionaryValue* dictionary) { | |
| 34 callback.Run(*dictionary); | |
| 35 } | |
| 36 | |
| 37 } // namespace | |
| 38 | |
| 39 ShillProfileClientStub::ShillProfileClientStub() { | |
| 40 } | |
| 41 | |
| 42 ShillProfileClientStub::~ShillProfileClientStub() { | |
| 43 STLDeleteValues(&profiles_); | |
| 44 } | |
| 45 | |
| 46 void ShillProfileClientStub::Init(dbus::Bus* bus) { | |
| 47 } | |
| 48 | |
| 49 void ShillProfileClientStub::AddPropertyChangedObserver( | |
| 50 const dbus::ObjectPath& profile_path, | |
| 51 ShillPropertyChangedObserver* observer) { | |
| 52 } | |
| 53 | |
| 54 void ShillProfileClientStub::RemovePropertyChangedObserver( | |
| 55 const dbus::ObjectPath& profile_path, | |
| 56 ShillPropertyChangedObserver* observer) { | |
| 57 } | |
| 58 | |
| 59 void ShillProfileClientStub::GetProperties( | |
| 60 const dbus::ObjectPath& profile_path, | |
| 61 const DictionaryValueCallbackWithoutStatus& callback, | |
| 62 const ErrorCallback& error_callback) { | |
| 63 ProfileProperties* profile = GetProfile(profile_path, error_callback); | |
| 64 if (!profile) | |
| 65 return; | |
| 66 | |
| 67 scoped_ptr<base::DictionaryValue> properties(profile->properties.DeepCopy()); | |
| 68 base::ListValue* entry_paths = new base::ListValue; | |
| 69 properties->SetWithoutPathExpansion(shill::kEntriesProperty, entry_paths); | |
| 70 for (base::DictionaryValue::Iterator it(profile->entries); !it.IsAtEnd(); | |
| 71 it.Advance()) { | |
| 72 entry_paths->AppendString(it.key()); | |
| 73 } | |
| 74 | |
| 75 base::MessageLoop::current()->PostTask( | |
| 76 FROM_HERE, | |
| 77 base::Bind(&PassDictionary, callback, base::Owned(properties.release()))); | |
| 78 } | |
| 79 | |
| 80 void ShillProfileClientStub::GetEntry( | |
| 81 const dbus::ObjectPath& profile_path, | |
| 82 const std::string& entry_path, | |
| 83 const DictionaryValueCallbackWithoutStatus& callback, | |
| 84 const ErrorCallback& error_callback) { | |
| 85 ProfileProperties* profile = GetProfile(profile_path, error_callback); | |
| 86 if (!profile) | |
| 87 return; | |
| 88 | |
| 89 base::DictionaryValue* entry = NULL; | |
| 90 profile->entries.GetDictionaryWithoutPathExpansion(entry_path, &entry); | |
| 91 if (!entry) { | |
| 92 error_callback.Run("Error.InvalidProfileEntry", "Invalid profile entry"); | |
| 93 return; | |
| 94 } | |
| 95 | |
| 96 base::MessageLoop::current()->PostTask( | |
| 97 FROM_HERE, | |
| 98 base::Bind(&PassDictionary, callback, base::Owned(entry->DeepCopy()))); | |
| 99 } | |
| 100 | |
| 101 void ShillProfileClientStub::DeleteEntry(const dbus::ObjectPath& profile_path, | |
| 102 const std::string& entry_path, | |
| 103 const base::Closure& callback, | |
| 104 const ErrorCallback& error_callback) { | |
| 105 ProfileProperties* profile = GetProfile(profile_path, error_callback); | |
| 106 if (!profile) | |
| 107 return; | |
| 108 | |
| 109 if (!profile->entries.RemoveWithoutPathExpansion(entry_path, NULL)) { | |
| 110 error_callback.Run("Error.InvalidProfileEntry", entry_path); | |
| 111 return; | |
| 112 } | |
| 113 | |
| 114 base::StringValue profile_path_value(""); | |
| 115 DBusThreadManager::Get()->GetShillServiceClient()->GetTestInterface()-> | |
| 116 SetServiceProperty(entry_path, | |
| 117 shill::kProfileProperty, | |
| 118 profile_path_value); | |
| 119 | |
| 120 base::MessageLoop::current()->PostTask(FROM_HERE, callback); | |
| 121 } | |
| 122 | |
| 123 ShillProfileClient::TestInterface* ShillProfileClientStub::GetTestInterface() { | |
| 124 return this; | |
| 125 } | |
| 126 | |
| 127 void ShillProfileClientStub::AddProfile(const std::string& profile_path, | |
| 128 const std::string& userhash) { | |
| 129 if (GetProfile(dbus::ObjectPath(profile_path), ErrorCallback())) | |
| 130 return; | |
| 131 | |
| 132 ProfileProperties* profile = new ProfileProperties; | |
| 133 profile->properties.SetStringWithoutPathExpansion(shill::kUserHashProperty, | |
| 134 userhash); | |
| 135 profiles_[profile_path] = profile; | |
| 136 DBusThreadManager::Get()->GetShillManagerClient()->GetTestInterface()-> | |
| 137 AddProfile(profile_path); | |
| 138 } | |
| 139 | |
| 140 void ShillProfileClientStub::AddEntry(const std::string& profile_path, | |
| 141 const std::string& entry_path, | |
| 142 const base::DictionaryValue& properties) { | |
| 143 ProfileProperties* profile = GetProfile(dbus::ObjectPath(profile_path), | |
| 144 ErrorCallback()); | |
| 145 DCHECK(profile); | |
| 146 profile->entries.SetWithoutPathExpansion(entry_path, | |
| 147 properties.DeepCopy()); | |
| 148 DBusThreadManager::Get()->GetShillManagerClient()->GetTestInterface()-> | |
| 149 AddManagerService(entry_path, false /* visible */, false /* watch */); | |
| 150 } | |
| 151 | |
| 152 bool ShillProfileClientStub::AddService(const std::string& profile_path, | |
| 153 const std::string& service_path) { | |
| 154 ProfileProperties* profile = GetProfile(dbus::ObjectPath(profile_path), | |
| 155 ErrorCallback()); | |
| 156 if (!profile) { | |
| 157 LOG(ERROR) << "No matching profile: " << profile_path; | |
| 158 return false; | |
| 159 } | |
| 160 | |
| 161 ShillServiceClient::TestInterface* service_test = | |
| 162 DBusThreadManager::Get()->GetShillServiceClient()->GetTestInterface(); | |
| 163 const base::DictionaryValue* service_properties = | |
| 164 service_test->GetServiceProperties(service_path); | |
| 165 if (!service_properties) { | |
| 166 LOG(ERROR) << "No matching service: " << service_path; | |
| 167 return false; | |
| 168 } | |
| 169 std::string service_profile_path; | |
| 170 service_properties->GetStringWithoutPathExpansion(shill::kProfileProperty, | |
| 171 &service_profile_path); | |
| 172 if (!service_profile_path.empty() && service_profile_path != profile_path) { | |
| 173 LOG(ERROR) << "Service has non matching profile path: " | |
| 174 << service_profile_path; | |
| 175 return false; | |
| 176 } | |
| 177 | |
| 178 base::StringValue profile_path_value(profile_path); | |
| 179 service_test->SetServiceProperty(service_path, | |
| 180 shill::kProfileProperty, | |
| 181 profile_path_value); | |
| 182 profile->entries.SetWithoutPathExpansion(service_path, | |
| 183 service_properties->DeepCopy()); | |
| 184 return true; | |
| 185 } | |
| 186 | |
| 187 void ShillProfileClientStub::GetProfilePaths( | |
| 188 std::vector<std::string>* profiles) { | |
| 189 for (ProfileMap::iterator iter = profiles_.begin(); | |
| 190 iter != profiles_.end(); ++iter) { | |
| 191 profiles->push_back(iter->first); | |
| 192 } | |
| 193 } | |
| 194 | |
| 195 ShillProfileClientStub::ProfileProperties* ShillProfileClientStub::GetProfile( | |
| 196 const dbus::ObjectPath& profile_path, | |
| 197 const ErrorCallback& error_callback) { | |
| 198 ProfileMap::const_iterator found = profiles_.find(profile_path.value()); | |
| 199 if (found == profiles_.end()) { | |
| 200 if (!error_callback.is_null()) | |
| 201 error_callback.Run("Error.InvalidProfile", "Invalid profile"); | |
| 202 return NULL; | |
| 203 } | |
| 204 | |
| 205 return found->second; | |
| 206 } | |
| 207 | |
| 208 } // namespace chromeos | |
| OLD | NEW |