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 |