OLD | NEW |
1 // Copyright (c) 2016 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2016 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 #include "chromeos/dbus/auth_policy_client.h" | 4 #include "chromeos/dbus/auth_policy_client.h" |
5 | 5 |
6 #include "base/bind.h" | 6 #include "base/bind.h" |
7 #include "base/memory/weak_ptr.h" | 7 #include "base/memory/weak_ptr.h" |
8 #include "dbus/bus.h" | 8 #include "dbus/bus.h" |
9 #include "dbus/message.h" | 9 #include "dbus/message.h" |
10 #include "dbus/object_proxy.h" | 10 #include "dbus/object_proxy.h" |
11 #include "third_party/cros_system_api/dbus/service_constants.h" | |
12 | 11 |
13 namespace chromeos { | 12 namespace chromeos { |
14 | 13 |
15 namespace { | 14 namespace { |
16 | 15 |
| 16 authpolicy::ErrorType GetErrorFromReader(dbus::MessageReader* reader) { |
| 17 int32_t int_error; |
| 18 if (!reader->PopInt32(&int_error)) { |
| 19 DLOG(ERROR) << "AuthPolicyClient: Failed to get an error from the response"; |
| 20 return authpolicy::ERROR_DBUS_FAILURE; |
| 21 } |
| 22 if (int_error < 0 || int_error >= authpolicy::ERROR_COUNT) |
| 23 return authpolicy::ERROR_UNKNOWN; |
| 24 return static_cast<authpolicy::ErrorType>(int_error); |
| 25 } |
| 26 |
17 class AuthPolicyClientImpl : public AuthPolicyClient { | 27 class AuthPolicyClientImpl : public AuthPolicyClient { |
18 public: | 28 public: |
19 AuthPolicyClientImpl() : weak_ptr_factory_(this) {} | 29 AuthPolicyClientImpl() : weak_ptr_factory_(this) {} |
20 | 30 |
21 ~AuthPolicyClientImpl() override {} | 31 ~AuthPolicyClientImpl() override {} |
22 | 32 |
23 // AuthPolicyClient override. | 33 // AuthPolicyClient override. |
24 void JoinAdDomain(const std::string& machine_name, | 34 void JoinAdDomain(const std::string& machine_name, |
25 const std::string& user_principal_name, | 35 const std::string& user_principal_name, |
26 int password_fd, | 36 int password_fd, |
(...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
86 callback.Run(false); | 96 callback.Run(false); |
87 return; | 97 return; |
88 } | 98 } |
89 callback.Run(true); | 99 callback.Run(true); |
90 } | 100 } |
91 | 101 |
92 void HandleJoinCallback(const JoinCallback& callback, | 102 void HandleJoinCallback(const JoinCallback& callback, |
93 dbus::Response* response) { | 103 dbus::Response* response) { |
94 if (!response) { | 104 if (!response) { |
95 DLOG(ERROR) << "Join: Couldn't call to authpolicy"; | 105 DLOG(ERROR) << "Join: Couldn't call to authpolicy"; |
96 // TODO(rsorokin): make proper call, after defining possible errors codes. | 106 callback.Run(authpolicy::ERROR_DBUS_FAILURE); |
97 callback.Run(authpolicy::types::AD_JOIN_ERROR_UNKNOWN); | |
98 return; | 107 return; |
99 } | 108 } |
100 | 109 |
101 dbus::MessageReader reader(response); | 110 dbus::MessageReader reader(response); |
102 int res = authpolicy::types::AD_JOIN_ERROR_UNKNOWN; | 111 callback.Run(GetErrorFromReader(&reader)); |
103 if (!reader.PopInt32(&res)) { | |
104 DLOG(ERROR) << "Join: Couldn't get an error from the response"; | |
105 // TODO(rsorokin): make proper call, after defining possible errors codes. | |
106 callback.Run(authpolicy::types::AD_JOIN_ERROR_DBUS_FAIL); | |
107 return; | |
108 } | |
109 | |
110 callback.Run(res); | |
111 } | 112 } |
112 | 113 |
113 void HandleAuthCallback(const AuthCallback& callback, | 114 void HandleAuthCallback(const AuthCallback& callback, |
114 dbus::Response* response) { | 115 dbus::Response* response) { |
115 std::string user_id; | |
116 int32_t res = static_cast<int32_t>(authpolicy::AUTH_USER_ERROR_UNKNOWN); | |
117 if (!response) { | 116 if (!response) { |
118 DLOG(ERROR) << "Auth: Failed to call to authpolicy"; | 117 DLOG(ERROR) << "Auth: Failed to call to authpolicy"; |
119 // TODO(rsorokin): make proper call, after defining possible errors codes. | 118 callback.Run(authpolicy::ERROR_DBUS_FAILURE, std::string()); |
120 callback.Run(authpolicy::AUTH_USER_ERROR_DBUS_FAILURE, user_id); | |
121 return; | 119 return; |
122 } | 120 } |
123 dbus::MessageReader reader(response); | 121 dbus::MessageReader reader(response); |
124 if (!reader.PopInt32(&res)) { | 122 const authpolicy::ErrorType error(GetErrorFromReader(&reader)); |
125 DLOG(ERROR) << "Auth: Failed to get an error from the response"; | 123 std::string user_id; |
126 // TODO(rsorokin): make proper call, after defining possible errors codes. | |
127 callback.Run(static_cast<authpolicy::AuthUserErrorType>(res), user_id); | |
128 return; | |
129 } | |
130 if (res < 0 || res >= authpolicy::AUTH_USER_ERROR_COUNT) | |
131 res = static_cast<int32_t>(authpolicy::AUTH_USER_ERROR_UNKNOWN); | |
132 if (!reader.PopString(&user_id)) | 124 if (!reader.PopString(&user_id)) |
133 DLOG(ERROR) << "Auth: Failed to get user_id from the response"; | 125 DLOG(ERROR) << "Auth: Failed to get user_id from the response"; |
134 callback.Run(static_cast<authpolicy::AuthUserErrorType>(res), user_id); | 126 callback.Run(error, user_id); |
135 } | 127 } |
136 | 128 |
137 dbus::Bus* bus_ = nullptr; | 129 dbus::Bus* bus_ = nullptr; |
138 dbus::ObjectProxy* proxy_ = nullptr; | 130 dbus::ObjectProxy* proxy_ = nullptr; |
139 | 131 |
140 // Note: This should remain the last member so it'll be destroyed and | 132 // Note: This should remain the last member so it'll be destroyed and |
141 // invalidate its weak pointers before any other members are destroyed. | 133 // invalidate its weak pointers before any other members are destroyed. |
142 base::WeakPtrFactory<AuthPolicyClientImpl> weak_ptr_factory_; | 134 base::WeakPtrFactory<AuthPolicyClientImpl> weak_ptr_factory_; |
143 | 135 |
144 DISALLOW_COPY_AND_ASSIGN(AuthPolicyClientImpl); | 136 DISALLOW_COPY_AND_ASSIGN(AuthPolicyClientImpl); |
145 }; | 137 }; |
146 | 138 |
147 } // namespace | 139 } // namespace |
148 | 140 |
149 AuthPolicyClient::AuthPolicyClient() {} | 141 AuthPolicyClient::AuthPolicyClient() {} |
150 | 142 |
151 AuthPolicyClient::~AuthPolicyClient() {} | 143 AuthPolicyClient::~AuthPolicyClient() {} |
152 | 144 |
153 // static | 145 // static |
154 AuthPolicyClient* AuthPolicyClient::Create() { | 146 AuthPolicyClient* AuthPolicyClient::Create() { |
155 return new AuthPolicyClientImpl(); | 147 return new AuthPolicyClientImpl(); |
156 } | 148 } |
157 | 149 |
158 } // namespace chromeos | 150 } // namespace chromeos |
OLD | NEW |