r11409: The use of 'password server = ' here is still bogus, but for now at
[jelmer/samba4-debian.git] / source / libnet / libnet_vampire.c
1 /* 
2    Unix SMB/CIFS implementation.
3    
4    Extract the user/system database from a remote SamSync server
5
6    Copyright (C) Andrew Bartlett <abartlet@samba.org> 2004-2005
7    
8    This program is free software; you can redistribute it and/or modify
9    it under the terms of the GNU General Public License as published by
10    the Free Software Foundation; either version 2 of the License, or
11    (at your option) any later version.
12    
13    This program is distributed in the hope that it will be useful,
14    but WITHOUT ANY WARRANTY; without even the implied warranty of
15    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
16    GNU General Public License for more details.
17    
18    You should have received a copy of the GNU General Public License
19    along with this program; if not, write to the Free Software
20    Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
21 */
22
23
24 #include "includes.h"
25 #include "libnet/libnet.h"
26 #include "librpc/gen_ndr/ndr_netlogon.h"
27 #include "librpc/gen_ndr/ndr_samr.h"
28
29
30 /**
31  * Decrypt and extract the user's passwords.  
32  * 
33  * The writes decrypted (no longer 'RID encrypted' or arcfour encrypted) passwords back into the structure
34  */
35 static NTSTATUS fix_user(TALLOC_CTX *mem_ctx,
36                          struct creds_CredentialState *creds,
37                          enum netr_SamDatabaseID database,
38                          struct netr_DELTA_ENUM *delta,
39                          char **error_string) 
40 {
41
42         uint32_t rid = delta->delta_id_union.rid;
43         struct netr_DELTA_USER *user = delta->delta_union.user;
44         struct samr_Password lm_hash;
45         struct samr_Password nt_hash;
46         const char *username = user->account_name.string;
47         NTSTATUS nt_status;
48
49         if (user->lm_password_present) {
50                 sam_rid_crypt(rid, user->lmpassword.hash, lm_hash.hash, 0);
51                 user->lmpassword = lm_hash;
52         }
53
54         if (user->nt_password_present) {
55                 sam_rid_crypt(rid, user->ntpassword.hash, nt_hash.hash, 0);
56                 user->ntpassword = nt_hash;
57         }
58
59         if (user->user_private_info.SensitiveData) {
60                 DATA_BLOB data;
61                 struct netr_USER_KEYS keys;
62                 data.data = user->user_private_info.SensitiveData;
63                 data.length = user->user_private_info.DataLength;
64                 creds_arcfour_crypt(creds, data.data, data.length);
65                 user->user_private_info.SensitiveData = data.data;
66                 user->user_private_info.DataLength = data.length;
67
68                 nt_status = ndr_pull_struct_blob(&data, mem_ctx, &keys, (ndr_pull_flags_fn_t)ndr_pull_netr_USER_KEYS);
69                 if (NT_STATUS_IS_OK(nt_status)) {
70                         if (keys.keys.keys2.lmpassword.length == 16) {
71                                 sam_rid_crypt(rid, keys.keys.keys2.lmpassword.pwd.hash, lm_hash.hash, 0);
72                                 user->lmpassword = lm_hash;
73                                 user->lm_password_present = True;
74                         }
75                         if (keys.keys.keys2.ntpassword.length == 16) {
76                                 sam_rid_crypt(rid, keys.keys.keys2.ntpassword.pwd.hash, nt_hash.hash, 0);
77                                 user->ntpassword = nt_hash;
78                                 user->nt_password_present = True;
79                         }
80                 } else {
81                         *error_string = talloc_asprintf(mem_ctx, "Failed to parse Sensitive Data for %s:\n", username);
82                         dump_data(10, data.data, data.length);
83                         return nt_status;
84                 }
85         }
86         return NT_STATUS_OK;
87 }
88
89 /**
90  * Decrypt and extract the secrets
91  * 
92  * The writes decrypted secrets back into the structure
93  */
94 static NTSTATUS fix_secret(TALLOC_CTX *mem_ctx,
95                            struct creds_CredentialState *creds,
96                            enum netr_SamDatabaseID database,
97                            struct netr_DELTA_ENUM *delta,
98                            char **error_string) 
99 {
100         struct netr_DELTA_SECRET *secret = delta->delta_union.secret;
101         creds_arcfour_crypt(creds, secret->current_cipher.cipher_data, 
102                             secret->current_cipher.maxlen); 
103
104         creds_arcfour_crypt(creds, secret->old_cipher.cipher_data, 
105                             secret->old_cipher.maxlen); 
106
107         return NT_STATUS_OK;
108 }
109
110 /**
111  * Fix up the delta, dealing with encryption issues so that the final
112  * callback need only do the printing or application logic
113  */
114
115 static NTSTATUS fix_delta(TALLOC_CTX *mem_ctx,          
116                           struct creds_CredentialState *creds,
117                           enum netr_SamDatabaseID database,
118                           struct netr_DELTA_ENUM *delta,
119                           char **error_string)
120 {
121         NTSTATUS nt_status = NT_STATUS_OK;
122         *error_string = NULL;
123         switch (delta->delta_type) {
124         case NETR_DELTA_USER:
125         {
126                 nt_status = fix_user(mem_ctx, 
127                                      creds,
128                                      database,
129                                      delta,
130                                      error_string);
131                 break;
132         }
133         case NETR_DELTA_SECRET:
134         {
135                 nt_status = fix_secret(mem_ctx, 
136                                        creds,
137                                        database,
138                                        delta,
139                                        error_string);
140                 break;
141         }
142         default:
143                 break;
144         }
145         return nt_status;
146 }
147
148 NTSTATUS libnet_SamSync_netlogon(struct libnet_context *ctx, TALLOC_CTX *mem_ctx, struct libnet_SamSync *r)
149 {
150         NTSTATUS nt_status, dbsync_nt_status;
151         TALLOC_CTX *samsync_ctx, *loop_ctx, *delta_ctx;
152         struct creds_CredentialState *creds;
153         struct netr_DatabaseSync dbsync;
154         struct cli_credentials *machine_account;
155         struct dcerpc_binding *b;
156         struct dcerpc_pipe *p;
157         const enum netr_SamDatabaseID database_ids[] = {SAM_DATABASE_DOMAIN, SAM_DATABASE_BUILTIN, SAM_DATABASE_PRIVS}; 
158         int i;
159
160         /* TODO: This is bogus */
161         const char **bindings = lp_passwordserver();
162         const char *binding;
163
164         if (bindings && bindings[0]) {
165                 binding = bindings[0];
166         } else {
167                 return NT_STATUS_INVALID_PARAMETER;
168         }
169
170         samsync_ctx = talloc_named(mem_ctx, 0, "SamSync top context");
171
172         if (!r->machine_account) { 
173                 machine_account = cli_credentials_init(samsync_ctx);
174                 if (!machine_account) {
175                         talloc_free(samsync_ctx);
176                         return NT_STATUS_NO_MEMORY;
177                 }
178                 cli_credentials_set_conf(machine_account);
179                 nt_status = cli_credentials_set_machine_account(machine_account);
180                 if (!NT_STATUS_IS_OK(nt_status)) {
181                         r->error_string = talloc_strdup(mem_ctx, "Could not obtain machine account password - are we joined to the domain?");
182                         talloc_free(samsync_ctx);
183                         return nt_status;
184                 }
185         } else {
186                 machine_account = r->machine_account;
187         }
188
189         if (cli_credentials_get_secure_channel_type(machine_account) != SEC_CHAN_BDC) {
190                 r->error_string
191                         = talloc_asprintf(mem_ctx, 
192                                           "Our join to domain %s is not as a BDC (%d), please rejoin as a BDC",
193                                           
194                                           cli_credentials_get_domain(machine_account),
195                                           cli_credentials_get_secure_channel_type(machine_account));
196                 talloc_free(samsync_ctx);
197                 return NT_STATUS_CANT_ACCESS_DOMAIN_INFO;
198         }
199
200         /* Connect to DC (take a binding string for now) */
201
202         nt_status = dcerpc_parse_binding(samsync_ctx, binding, &b);
203         if (!NT_STATUS_IS_OK(nt_status)) {
204                 r->error_string = talloc_asprintf(mem_ctx, "Bad binding string %s\n", binding);
205                 talloc_free(samsync_ctx);
206                 return NT_STATUS_INVALID_PARAMETER;
207         }
208
209         /* We like schannel */
210         b->flags &= ~DCERPC_AUTH_OPTIONS;
211         b->flags |= DCERPC_SCHANNEL | DCERPC_SEAL /* | DCERPC_SCHANNEL_128 */;
212
213         /* Setup schannel */
214         nt_status = dcerpc_pipe_connect_b(samsync_ctx, &p, b, 
215                                           DCERPC_NETLOGON_UUID,
216                                           DCERPC_NETLOGON_VERSION,
217                                           machine_account, ctx->event_ctx);
218
219         if (!NT_STATUS_IS_OK(nt_status)) {
220                 talloc_free(samsync_ctx);
221                 return nt_status;
222         }
223
224         /* get NETLOGON credentails */
225
226         nt_status = dcerpc_schannel_creds(p->conn->security_state.generic_state, samsync_ctx, &creds);
227         if (!NT_STATUS_IS_OK(nt_status)) {
228                 r->error_string = talloc_strdup(mem_ctx, "Could not obtain NETLOGON credentials from DCERPC/GENSEC layer");
229                 talloc_free(samsync_ctx);
230                 return nt_status;
231         }
232
233         dbsync.in.logon_server = talloc_asprintf(samsync_ctx, "\\\\%s", dcerpc_server_name(p));
234         dbsync.in.computername = cli_credentials_get_workstation(machine_account);
235         dbsync.in.preferredmaximumlength = (uint32_t)-1;
236         ZERO_STRUCT(dbsync.in.return_authenticator);
237
238         for (i=0;i< ARRAY_SIZE(database_ids); i++) { 
239                 dbsync.in.sync_context = 0;
240                 dbsync.in.database_id = database_ids[i]; 
241                 
242                 do {
243                         int d;
244                         loop_ctx = talloc_named(samsync_ctx, 0, "DatabaseSync loop context");
245                         creds_client_authenticator(creds, &dbsync.in.credential);
246                         
247                         dbsync_nt_status = dcerpc_netr_DatabaseSync(p, loop_ctx, &dbsync);
248                         if (!NT_STATUS_IS_OK(dbsync_nt_status) &&
249                             !NT_STATUS_EQUAL(dbsync_nt_status, STATUS_MORE_ENTRIES)) {
250                                 r->error_string = talloc_asprintf(samsync_ctx, "DatabaseSync failed - %s", nt_errstr(nt_status));
251                                 talloc_free(samsync_ctx);
252                                 return nt_status;
253                         }
254                         
255                         if (!creds_client_check(creds, &dbsync.out.return_authenticator.cred)) {
256                                 r->error_string = talloc_strdup(samsync_ctx, "Credential chaining failed");
257                                 talloc_free(samsync_ctx);
258                                 return NT_STATUS_ACCESS_DENIED;
259                         }
260                         
261                         dbsync.in.sync_context = dbsync.out.sync_context;
262                         
263                         for (d=0; d < dbsync.out.delta_enum_array->num_deltas; d++) {
264                                 char *error_string = NULL;
265                                 delta_ctx = talloc_named(loop_ctx, 0, "DatabaseSync delta context");
266                                 nt_status = fix_delta(delta_ctx, 
267                                                       creds, 
268                                                       dbsync.in.database_id,
269                                                       &dbsync.out.delta_enum_array->delta_enum[d], 
270                                                       &error_string);
271                                 if (!NT_STATUS_IS_OK(nt_status)) {
272                                         r->error_string = talloc_steal(samsync_ctx, error_string);
273                                         talloc_free(samsync_ctx);
274                                         return nt_status;
275                                 }
276                                 nt_status = r->delta_fn(delta_ctx, 
277                                                                  r->fn_ctx,
278                                                                  creds,
279                                                                  dbsync.in.database_id,
280                                                                  &dbsync.out.delta_enum_array->delta_enum[d], 
281                                                                  &error_string);
282                                 if (!NT_STATUS_IS_OK(nt_status)) {
283                                         r->error_string = talloc_steal(samsync_ctx, error_string);
284                                         talloc_free(samsync_ctx);
285                                         return nt_status;
286                                 }
287                                 talloc_free(delta_ctx);
288                         }
289                         talloc_free(loop_ctx);
290                 } while (NT_STATUS_EQUAL(dbsync_nt_status, STATUS_MORE_ENTRIES));
291                 nt_status = dbsync_nt_status;
292         }
293         talloc_free(samsync_ctx);
294         return nt_status;
295 }
296