lib: modules: Change XXX_init interface from XXX_init(void) to XXX_init(TALLOC_CTX *)
[kai/samba-autobuild/.git] / source3 / winbindd / idmap_ad.c
1 /*
2  * idmap_ad: map between Active Directory and RFC 2307 accounts
3  *
4  * Copyright (C) Volker Lendecke 2015
5  *
6  * This program is free software; you can redistribute it and/or modify
7  * it under the terms of the GNU General Public License as published by
8  * the Free Software Foundation; either version 3 of the License, or
9  * (at your option) any later version.
10  *
11  * This program is distributed in the hope that it will be useful,
12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14  * GNU General Public License for more details.
15  *
16  * You should have received a copy of the GNU General Public License
17  * along with this program; if not, see <http://www.gnu.org/licenses/>.
18  */
19
20 #include "includes.h"
21 #include "winbindd.h"
22 #include "idmap.h"
23 #include "tldap_gensec_bind.h"
24 #include "tldap_util.h"
25 #include "passdb.h"
26 #include "lib/param/param.h"
27 #include "utils/net.h"
28 #include "auth/gensec/gensec.h"
29 #include "librpc/gen_ndr/ndr_netlogon.h"
30 #include "libads/ldap_schema_oids.h"
31 #include "../libds/common/flags.h"
32 #include "libcli/ldap/ldap_ndr.h"
33 #include "libcli/security/dom_sid.h"
34
35 struct idmap_ad_schema_names;
36
37 struct idmap_ad_context {
38         struct idmap_domain *dom;
39         struct tldap_context *ld;
40         struct idmap_ad_schema_names *schema;
41         const char *default_nc;
42
43         bool unix_primary_group;
44         bool unix_nss_info;
45 };
46
47 static NTSTATUS idmap_ad_get_context(struct idmap_domain *dom,
48                                      struct idmap_ad_context **pctx);
49
50 static char *get_schema_path(TALLOC_CTX *mem_ctx, struct tldap_context *ld)
51 {
52         struct tldap_message *rootdse;
53
54         rootdse = tldap_rootdse(ld);
55         if (rootdse == NULL) {
56                 return NULL;
57         }
58
59         return tldap_talloc_single_attribute(rootdse, "schemaNamingContext",
60                                              mem_ctx);
61 }
62
63 static char *get_default_nc(TALLOC_CTX *mem_ctx, struct tldap_context *ld)
64 {
65         struct tldap_message *rootdse;
66
67         rootdse = tldap_rootdse(ld);
68         if (rootdse == NULL) {
69                 return NULL;
70         }
71
72         return tldap_talloc_single_attribute(rootdse, "defaultNamingContext",
73                                              mem_ctx);
74 }
75
76 struct idmap_ad_schema_names {
77         char *name;
78         char *uid;
79         char *gid;
80         char *gecos;
81         char *dir;
82         char *shell;
83 };
84
85 static TLDAPRC get_attrnames_by_oids(struct tldap_context *ld,
86                                      TALLOC_CTX *mem_ctx,
87                                      const char *schema_path,
88                                      size_t num_oids,
89                                      const char **oids,
90                                      char **names)
91 {
92         char *filter;
93         const char *attrs[] = { "lDAPDisplayName", "attributeId" };
94         size_t i;
95         TLDAPRC rc;
96         struct tldap_message **msgs;
97         size_t num_msgs;
98
99         filter = talloc_strdup(mem_ctx, "(|");
100         if (filter == NULL) {
101                 return TLDAP_NO_MEMORY;
102         }
103
104         for (i=0; i<num_oids; i++) {
105                 filter = talloc_asprintf_append_buffer(
106                         filter, "(attributeId=%s)", oids[i]);
107                 if (filter == NULL) {
108                         return TLDAP_NO_MEMORY;
109                 }
110         }
111
112         filter = talloc_asprintf_append_buffer(filter, ")");
113         if (filter == NULL) {
114                 return TLDAP_NO_MEMORY;
115         }
116
117         rc = tldap_search(ld, schema_path, TLDAP_SCOPE_SUB, filter,
118                           attrs, ARRAY_SIZE(attrs), 0, NULL, 0, NULL, 0,
119                           0, 0, 0, mem_ctx, &msgs);;
120         TALLOC_FREE(filter);
121         if (!TLDAP_RC_IS_SUCCESS(rc)) {
122                 return rc;
123         }
124
125         for (i=0; i<num_oids; i++) {
126                 names[i] = NULL;
127         }
128
129         num_msgs = talloc_array_length(msgs);
130
131         for (i=0; i<num_msgs; i++) {
132                 struct tldap_message *msg = msgs[i];
133                 char *oid;
134                 size_t j;
135
136                 if (tldap_msg_type(msg) != TLDAP_RES_SEARCH_ENTRY) {
137                         /* Could be a TLDAP_RES_SEARCH_REFERENCE */
138                         continue;
139                 }
140
141                 oid = tldap_talloc_single_attribute(
142                         msg, "attributeId", msg);
143                 if (oid == NULL) {
144                         continue;
145                 }
146
147                 for (j=0; j<num_oids; j++) {
148                         if (strequal(oid, oids[j])) {
149                                 break;
150                         }
151                 }
152                 TALLOC_FREE(oid);
153
154                 if (j == num_oids) {
155                         /* not found */
156                         continue;
157                 }
158
159                 names[j] = tldap_talloc_single_attribute(
160                         msg, "lDAPDisplayName", mem_ctx);
161         }
162
163         TALLOC_FREE(msgs);
164
165         return TLDAP_SUCCESS;
166 }
167
168 static TLDAPRC get_posix_schema_names(struct tldap_context *ld,
169                                       const char *schema_mode,
170                                       TALLOC_CTX *mem_ctx,
171                                       struct idmap_ad_schema_names **pschema)
172 {
173         char *schema_path;
174         struct idmap_ad_schema_names *schema;
175         char *names[6];
176         const char *oids_sfu[] = {
177                 ADS_ATTR_SFU_UIDNUMBER_OID,
178                 ADS_ATTR_SFU_GIDNUMBER_OID,
179                 ADS_ATTR_SFU_HOMEDIR_OID,
180                 ADS_ATTR_SFU_SHELL_OID,
181                 ADS_ATTR_SFU_GECOS_OID,
182                 ADS_ATTR_SFU_UID_OID
183         };
184         const char *oids_sfu20[] = {
185                 ADS_ATTR_SFU20_UIDNUMBER_OID,
186                 ADS_ATTR_SFU20_GIDNUMBER_OID,
187                 ADS_ATTR_SFU20_HOMEDIR_OID,
188                 ADS_ATTR_SFU20_SHELL_OID,
189                 ADS_ATTR_SFU20_GECOS_OID,
190                 ADS_ATTR_SFU20_UID_OID
191         };
192         const char *oids_rfc2307[] = {
193                 ADS_ATTR_RFC2307_UIDNUMBER_OID,
194                 ADS_ATTR_RFC2307_GIDNUMBER_OID,
195                 ADS_ATTR_RFC2307_HOMEDIR_OID,
196                 ADS_ATTR_RFC2307_SHELL_OID,
197                 ADS_ATTR_RFC2307_GECOS_OID,
198                 ADS_ATTR_RFC2307_UID_OID
199         };
200         const char **oids;
201
202         TLDAPRC rc;
203
204         schema = talloc(mem_ctx, struct idmap_ad_schema_names);
205         if (schema == NULL) {
206                 return TLDAP_NO_MEMORY;
207         }
208
209         schema_path = get_schema_path(schema, ld);
210         if (schema_path == NULL) {
211                 TALLOC_FREE(schema);
212                 return TLDAP_NO_MEMORY;
213         }
214
215         oids = oids_rfc2307;
216
217         if ((schema_mode != NULL) && (schema_mode[0] != '\0')) {
218                 if (strequal(schema_mode, "sfu")) {
219                         oids = oids_sfu;
220                 } else if (strequal(schema_mode, "sfu20")) {
221                         oids = oids_sfu20;
222                 } else if (strequal(schema_mode, "rfc2307" )) {
223                         oids = oids_rfc2307;
224                 } else {
225                         DBG_WARNING("Unknown schema mode %s\n", schema_mode);
226                 }
227         }
228
229         rc = get_attrnames_by_oids(ld, schema, schema_path, 6, oids, names);
230         TALLOC_FREE(schema_path);
231         if (!TLDAP_RC_IS_SUCCESS(rc)) {
232                 TALLOC_FREE(schema);
233                 return rc;
234         }
235
236         schema->uid = names[0];
237         schema->gid = names[1];
238         schema->dir = names[2];
239         schema->shell = names[3];
240         schema->gecos = names[4];
241         schema->name = names[5];
242
243         *pschema = schema;
244
245         return TLDAP_SUCCESS;
246 }
247
248 static NTSTATUS idmap_ad_get_tldap_ctx(TALLOC_CTX *mem_ctx,
249                                        const char *domname,
250                                        struct tldap_context **pld)
251 {
252         struct netr_DsRGetDCNameInfo *dcinfo;
253         struct sockaddr_storage dcaddr;
254         struct cli_credentials *creds;
255         struct loadparm_context *lp_ctx;
256         struct tldap_context *ld;
257         int fd;
258         NTSTATUS status;
259         bool ok;
260         TLDAPRC rc;
261
262         status = wb_dsgetdcname_gencache_get(mem_ctx, domname, &dcinfo);
263         if (!NT_STATUS_IS_OK(status)) {
264                 DBG_DEBUG("Could not get dcinfo for %s: %s\n", domname,
265                           nt_errstr(status));
266                 return status;
267         }
268
269         if (dcinfo->dc_unc == NULL) {
270                 TALLOC_FREE(dcinfo);
271                 return NT_STATUS_DOMAIN_CONTROLLER_NOT_FOUND;
272         }
273         if (dcinfo->dc_unc[0] == '\\') {
274                 dcinfo->dc_unc += 1;
275         }
276         if (dcinfo->dc_unc[0] == '\\') {
277                 dcinfo->dc_unc += 1;
278         }
279
280         ok = resolve_name(dcinfo->dc_unc, &dcaddr, 0x20, true);
281         if (!ok) {
282                 DBG_DEBUG("Could not resolve name %s\n", dcinfo->dc_unc);
283                 TALLOC_FREE(dcinfo);
284                 return NT_STATUS_DOMAIN_CONTROLLER_NOT_FOUND;
285         }
286
287         status = open_socket_out(&dcaddr, 389, 10000, &fd);
288         if (!NT_STATUS_IS_OK(status)) {
289                 DBG_DEBUG("open_socket_out failed: %s\n", nt_errstr(status));
290                 TALLOC_FREE(dcinfo);
291                 return status;
292         }
293
294         ld = tldap_context_create(dcinfo, fd);
295         if (ld == NULL) {
296                 DBG_DEBUG("tldap_context_create failed\n");
297                 close(fd);
298                 TALLOC_FREE(dcinfo);
299                 return NT_STATUS_NO_MEMORY;
300         }
301
302         /*
303          * Here we use or own machine account as
304          * we run as domain member.
305          */
306         status = pdb_get_trust_credentials(lp_workgroup(),
307                                            lp_realm(),
308                                            dcinfo,
309                                            &creds);
310         if (!NT_STATUS_IS_OK(status)) {
311                 DBG_DEBUG("pdb_get_trust_credentials() failed - %s\n",
312                           nt_errstr(status));
313                 TALLOC_FREE(dcinfo);
314                 return status;
315         }
316
317         lp_ctx = loadparm_init_s3(dcinfo, loadparm_s3_helpers());
318         if (lp_ctx == NULL) {
319                 DBG_DEBUG("loadparm_init_s3 failed\n");
320                 TALLOC_FREE(dcinfo);
321                 return NT_STATUS_NO_MEMORY;
322         }
323
324         rc = tldap_gensec_bind(ld, creds, "ldap", dcinfo->dc_unc, NULL, lp_ctx,
325                                GENSEC_FEATURE_SIGN | GENSEC_FEATURE_SEAL);
326         if (!TLDAP_RC_IS_SUCCESS(rc)) {
327                 DBG_DEBUG("tldap_gensec_bind failed: %s\n",
328                           tldap_errstr(dcinfo, ld, rc));
329                 TALLOC_FREE(dcinfo);
330                 return NT_STATUS_LDAP(TLDAP_RC_V(rc));
331         }
332
333         rc = tldap_fetch_rootdse(ld);
334         if (!TLDAP_RC_IS_SUCCESS(rc)) {
335                 DBG_DEBUG("tldap_fetch_rootdse failed: %s\n",
336                           tldap_errstr(dcinfo, ld, rc));
337                 TALLOC_FREE(dcinfo);
338                 return NT_STATUS_LDAP(TLDAP_RC_V(rc));
339         }
340
341         *pld = talloc_move(mem_ctx, &ld);
342         TALLOC_FREE(dcinfo);
343         return NT_STATUS_OK;
344 }
345
346 static int idmap_ad_context_destructor(struct idmap_ad_context *ctx)
347 {
348         if ((ctx->dom != NULL) && (ctx->dom->private_data == ctx)) {
349                 ctx->dom->private_data = NULL;
350         }
351         return 0;
352 }
353
354 static NTSTATUS idmap_ad_context_create(TALLOC_CTX *mem_ctx,
355                                         struct idmap_domain *dom,
356                                         const char *domname,
357                                         struct idmap_ad_context **pctx)
358 {
359         struct idmap_ad_context *ctx;
360         const char *schema_mode;
361         NTSTATUS status;
362         TLDAPRC rc;
363
364         ctx = talloc(mem_ctx, struct idmap_ad_context);
365         if (ctx == NULL) {
366                 return NT_STATUS_NO_MEMORY;
367         }
368         ctx->dom = dom;
369
370         talloc_set_destructor(ctx, idmap_ad_context_destructor);
371
372         status = idmap_ad_get_tldap_ctx(ctx, domname, &ctx->ld);
373         if (!NT_STATUS_IS_OK(status)) {
374                 DBG_DEBUG("idmap_ad_get_tldap_ctx failed: %s\n",
375                           nt_errstr(status));
376                 TALLOC_FREE(ctx);
377                 return status;
378         }
379
380         ctx->default_nc = get_default_nc(ctx, ctx->ld);
381         if (ctx->default_nc == NULL) {
382                 DBG_DEBUG("No default nc\n");
383                 TALLOC_FREE(ctx);
384                 return status;
385         }
386
387         ctx->unix_primary_group = idmap_config_bool(
388                 domname, "unix_primary_group", false);
389         ctx->unix_nss_info = idmap_config_bool(
390                 domname, "unix_nss_info", false);
391
392         schema_mode = idmap_config_const_string(
393                 domname, "schema_mode", "rfc2307");
394
395         rc = get_posix_schema_names(ctx->ld, schema_mode, ctx, &ctx->schema);
396         if (!TLDAP_RC_IS_SUCCESS(rc)) {
397                 DBG_DEBUG("get_posix_schema_names failed: %s\n",
398                           tldap_errstr(ctx, ctx->ld, rc));
399                 TALLOC_FREE(ctx);
400                 return NT_STATUS_LDAP(TLDAP_RC_V(rc));
401         }
402
403         *pctx = ctx;
404         return NT_STATUS_OK;
405 }
406
407 static NTSTATUS idmap_ad_query_user(struct idmap_domain *domain,
408                                     struct wbint_userinfo *info)
409 {
410         struct idmap_ad_context *ctx;
411         TLDAPRC rc;
412         NTSTATUS status;
413         char *sidstr, *filter;
414         const char *attrs[4];
415         size_t i, num_msgs;
416         struct tldap_message **msgs;
417
418         status = idmap_ad_get_context(domain, &ctx);
419         if (!NT_STATUS_IS_OK(status)) {
420                 return status;
421         }
422
423         if (!(ctx->unix_primary_group || ctx->unix_nss_info)) {
424                 return NT_STATUS_OK;
425         }
426
427         attrs[0] = ctx->schema->gid;
428         attrs[1] = ctx->schema->gecos;
429         attrs[2] = ctx->schema->dir;
430         attrs[3] = ctx->schema->shell;
431
432         sidstr = ldap_encode_ndr_dom_sid(talloc_tos(), &info->user_sid);
433         if (sidstr == NULL) {
434                 return NT_STATUS_NO_MEMORY;
435         }
436
437         filter = talloc_asprintf(talloc_tos(), "(objectsid=%s)", sidstr);
438         TALLOC_FREE(sidstr);
439         if (filter == NULL) {
440                 return NT_STATUS_NO_MEMORY;
441         }
442
443         DBG_DEBUG("Filter: [%s]\n", filter);
444
445         rc = tldap_search(ctx->ld, ctx->default_nc, TLDAP_SCOPE_SUB, filter,
446                           attrs, ARRAY_SIZE(attrs), 0, NULL, 0, NULL, 0,
447                           0, 0, 0, talloc_tos(), &msgs);
448         if (!TLDAP_RC_IS_SUCCESS(rc)) {
449                 return NT_STATUS_LDAP(TLDAP_RC_V(rc));
450         }
451
452         TALLOC_FREE(filter);
453
454         num_msgs = talloc_array_length(msgs);
455
456         for (i=0; i<num_msgs; i++) {
457                 struct tldap_message *msg = msgs[i];
458
459                 if (tldap_msg_type(msg) != TLDAP_RES_SEARCH_ENTRY) {
460                         continue;
461                 }
462
463                 if (ctx->unix_primary_group) {
464                         bool ok;
465                         uint32_t gid;
466
467                         ok = tldap_pull_uint32(msg, ctx->schema->gid, &gid);
468                         if (ok) {
469                                 DBG_DEBUG("Setting primary group "
470                                           "to %"PRIu32" from attr %s\n",
471                                           gid, ctx->schema->gid);
472                                 info->primary_gid = gid;
473                         }
474                 }
475
476                 if (ctx->unix_nss_info) {
477                         char *attr;
478
479                         attr = tldap_talloc_single_attribute(
480                                 msg, ctx->schema->dir, talloc_tos());
481                         if (attr != NULL) {
482                                 info->homedir = talloc_move(info, &attr);
483                         }
484                         TALLOC_FREE(attr);
485
486                         attr = tldap_talloc_single_attribute(
487                                 msg, ctx->schema->shell, talloc_tos());
488                         if (attr != NULL) {
489                                 info->shell = talloc_move(info, &attr);
490                         }
491                         TALLOC_FREE(attr);
492
493                         attr = tldap_talloc_single_attribute(
494                                 msg, ctx->schema->gecos, talloc_tos());
495                         if (attr != NULL) {
496                                 info->full_name = talloc_move(info, &attr);
497                         }
498                         TALLOC_FREE(attr);
499                 }
500         }
501
502         return NT_STATUS_OK;
503 }
504
505 static NTSTATUS idmap_ad_initialize(struct idmap_domain *dom)
506 {
507         dom->query_user = idmap_ad_query_user;
508         dom->private_data = NULL;
509         return NT_STATUS_OK;
510 }
511
512 static NTSTATUS idmap_ad_get_context(struct idmap_domain *dom,
513                                      struct idmap_ad_context **pctx)
514 {
515         struct idmap_ad_context *ctx = NULL;
516         NTSTATUS status;
517
518         if (dom->private_data != NULL) {
519                 *pctx = talloc_get_type_abort(dom->private_data,
520                                               struct idmap_ad_context);
521                 return NT_STATUS_OK;
522         }
523
524         status = idmap_ad_context_create(dom, dom, dom->name, &ctx);
525         if (!NT_STATUS_IS_OK(status)) {
526                 DBG_DEBUG("idmap_ad_context_create failed: %s\n",
527                           nt_errstr(status));
528                 return status;
529         }
530
531         dom->private_data = ctx;
532         *pctx = ctx;
533         return NT_STATUS_OK;
534 }
535
536 static NTSTATUS idmap_ad_unixids_to_sids(struct idmap_domain *dom,
537                                          struct id_map **ids)
538 {
539         struct idmap_ad_context *ctx;
540         TLDAPRC rc;
541         NTSTATUS status;
542         struct tldap_message **msgs;
543
544         size_t i, num_msgs;
545         char *u_filter, *g_filter, *filter;
546
547         const char *attrs[] = {
548                 "sAMAccountType",
549                 "objectSid",
550                 NULL, /* attr_uidnumber */
551                 NULL, /* attr_gidnumber */
552         };
553
554         status = idmap_ad_get_context(dom, &ctx);
555         if (!NT_STATUS_IS_OK(status)) {
556                 return status;
557         }
558
559         attrs[2] = ctx->schema->uid;
560         attrs[3] = ctx->schema->gid;
561
562         u_filter = talloc_strdup(talloc_tos(), "");
563         if (u_filter == NULL) {
564                 return NT_STATUS_NO_MEMORY;
565         }
566
567         g_filter = talloc_strdup(talloc_tos(), "");
568         if (g_filter == NULL) {
569                 return NT_STATUS_NO_MEMORY;
570         }
571
572         for (i=0; ids[i] != NULL; i++) {
573                 struct id_map *id = ids[i];
574
575                 id->status = ID_UNKNOWN;
576
577                 switch (id->xid.type) {
578                     case ID_TYPE_UID: {
579                             u_filter = talloc_asprintf_append_buffer(
580                                     u_filter, "(%s=%ju)", ctx->schema->uid,
581                                     (uintmax_t)id->xid.id);
582                             if (u_filter == NULL) {
583                                     return NT_STATUS_NO_MEMORY;
584                             }
585                             break;
586                     }
587
588                     case ID_TYPE_GID: {
589                             g_filter = talloc_asprintf_append_buffer(
590                                     g_filter, "(%s=%ju)", ctx->schema->gid,
591                                     (uintmax_t)id->xid.id);
592                             if (g_filter == NULL) {
593                                     return NT_STATUS_NO_MEMORY;
594                             }
595                             break;
596                     }
597
598                     default:
599                             DBG_WARNING("Unknown id type: %u\n",
600                                         (unsigned)id->xid.type);
601                             break;
602                 }
603         }
604
605         filter = talloc_strdup(talloc_tos(), "(|");
606         if (filter == NULL) {
607                 return NT_STATUS_NO_MEMORY;
608         }
609
610         if (*u_filter != '\0') {
611                 filter = talloc_asprintf_append_buffer(
612                         filter,
613                         "(&(|(sAMAccountType=%d)(sAMAccountType=%d)"
614                         "(sAMAccountType=%d))(|%s))",
615                         ATYPE_NORMAL_ACCOUNT, ATYPE_WORKSTATION_TRUST,
616                         ATYPE_INTERDOMAIN_TRUST, u_filter);
617                 if (filter == NULL) {
618                         return NT_STATUS_NO_MEMORY;
619                 }
620         }
621         TALLOC_FREE(u_filter);
622
623         if (*g_filter != '\0') {
624                 filter = talloc_asprintf_append_buffer(
625                         filter,
626                         "(&(|(sAMAccountType=%d)(sAMAccountType=%d))(|%s))",
627                         ATYPE_SECURITY_GLOBAL_GROUP,
628                         ATYPE_SECURITY_LOCAL_GROUP,
629                         g_filter);
630                 if (filter == NULL) {
631                         return NT_STATUS_NO_MEMORY;
632                 }
633         }
634         TALLOC_FREE(g_filter);
635
636         filter = talloc_asprintf_append_buffer(filter, ")");
637         if (filter == NULL) {
638                 return NT_STATUS_NO_MEMORY;
639         }
640
641         DBG_DEBUG("Filter: [%s]\n", filter);
642
643         rc = tldap_search(ctx->ld, ctx->default_nc, TLDAP_SCOPE_SUB, filter,
644                           attrs, ARRAY_SIZE(attrs), 0, NULL, 0, NULL, 0,
645                           0, 0, 0, talloc_tos(), &msgs);
646         if (!TLDAP_RC_IS_SUCCESS(rc)) {
647                 return NT_STATUS_LDAP(TLDAP_RC_V(rc));
648         }
649
650         TALLOC_FREE(filter);
651
652         num_msgs = talloc_array_length(msgs);
653
654         for (i=0; i<num_msgs; i++) {
655                 struct tldap_message *msg = msgs[i];
656                 char *dn;
657                 struct id_map *map;
658                 struct dom_sid sid;
659                 size_t j;
660                 bool ok;
661                 uint32_t atype, xid;
662                 enum id_type type;
663
664                 if (tldap_msg_type(msg) != TLDAP_RES_SEARCH_ENTRY) {
665                         continue;
666                 }
667
668                 ok = tldap_entry_dn(msg, &dn);
669                 if (!ok) {
670                         DBG_DEBUG("No dn found in msg %zu\n", i);
671                         continue;
672                 }
673
674                 ok = tldap_pull_uint32(msg, "sAMAccountType", &atype);
675                 if (!ok) {
676                         DBG_DEBUG("No atype in object %s\n", dn);
677                         continue;
678                 }
679
680                 switch (atype & 0xF0000000) {
681                     case ATYPE_SECURITY_GLOBAL_GROUP:
682                     case ATYPE_SECURITY_LOCAL_GROUP:
683                             type = ID_TYPE_GID;
684                             break;
685                     case ATYPE_NORMAL_ACCOUNT:
686                     case ATYPE_WORKSTATION_TRUST:
687                     case ATYPE_INTERDOMAIN_TRUST:
688                             type = ID_TYPE_UID;
689                             break;
690                     default:
691                             DBG_WARNING("unrecognized SAM account type %08x\n",
692                                         atype);
693                         continue;
694                 }
695
696                 ok = tldap_pull_uint32(msg, (type == ID_TYPE_UID) ?
697                                        ctx->schema->uid : ctx->schema->gid,
698                                        &xid);
699                 if (!ok) {
700                         DBG_WARNING("No unix id in object %s\n", dn);
701                         continue;
702                 }
703
704                 ok = tldap_pull_binsid(msg, "objectSid", &sid);
705                 if (!ok) {
706                         DBG_DEBUG("No objectSid in object %s\n", dn);
707                         continue;
708                 }
709
710                 map = NULL;
711                 for (j=0; ids[j]; j++) {
712                         if ((type == ids[j]->xid.type) &&
713                             (xid == ids[j]->xid.id)) {
714                                 map = ids[j];
715                                 break;
716                         }
717                 }
718                 if (map == NULL) {
719                         DBG_DEBUG("Got unexpected sid %s from object %s\n",
720                                   sid_string_tos(&sid), dn);
721                         continue;
722                 }
723
724                 sid_copy(map->sid, &sid);
725                 map->status = ID_MAPPED;
726
727                 DBG_DEBUG("Mapped %s -> %ju (%d)\n", sid_string_dbg(map->sid),
728                           (uintmax_t)map->xid.id, map->xid.type);
729         }
730
731         TALLOC_FREE(msgs);
732
733         return NT_STATUS_OK;
734 }
735
736 static NTSTATUS idmap_ad_sids_to_unixids(struct idmap_domain *dom,
737                                          struct id_map **ids)
738 {
739         struct idmap_ad_context *ctx;
740         TLDAPRC rc;
741         NTSTATUS status;
742         struct tldap_message **msgs;
743
744         char *filter;
745         size_t i, num_msgs;
746
747         const char *attrs[] = {
748                 "sAMAccountType",
749                 "objectSid",
750                 NULL, /* attr_uidnumber */
751                 NULL, /* attr_gidnumber */
752         };
753
754         status = idmap_ad_get_context(dom, &ctx);
755         if (!NT_STATUS_IS_OK(status)) {
756                 return status;
757         }
758
759         attrs[2] = ctx->schema->uid;
760         attrs[3] = ctx->schema->gid;
761
762         filter = talloc_asprintf(
763                 talloc_tos(),
764                 "(&(|(sAMAccountType=%d)(sAMAccountType=%d)(sAMAccountType=%d)"
765                 "(sAMAccountType=%d)(sAMAccountType=%d))(|",
766                 ATYPE_NORMAL_ACCOUNT, ATYPE_WORKSTATION_TRUST,
767                 ATYPE_INTERDOMAIN_TRUST, ATYPE_SECURITY_GLOBAL_GROUP,
768                 ATYPE_SECURITY_LOCAL_GROUP);
769         if (filter == NULL) {
770                 return NT_STATUS_NO_MEMORY;
771         }
772
773         for (i=0; ids[i]; i++) {
774                 char *sidstr;
775
776                 ids[i]->status = ID_UNKNOWN;
777
778                 sidstr = ldap_encode_ndr_dom_sid(talloc_tos(), ids[i]->sid);
779                 if (sidstr == NULL) {
780                         return NT_STATUS_NO_MEMORY;
781                 }
782
783                 filter = talloc_asprintf_append_buffer(
784                         filter, "(objectSid=%s)", sidstr);
785                 TALLOC_FREE(sidstr);
786                 if (filter == NULL) {
787                         return NT_STATUS_NO_MEMORY;
788                 }
789         }
790
791         filter = talloc_asprintf_append_buffer(filter, "))");
792         if (filter == NULL) {
793                 return NT_STATUS_NO_MEMORY;
794         }
795
796         DBG_DEBUG("Filter: [%s]\n", filter);
797
798         rc = tldap_search(ctx->ld, ctx->default_nc, TLDAP_SCOPE_SUB, filter,
799                           attrs, ARRAY_SIZE(attrs), 0, NULL, 0, NULL, 0,
800                           0, 0, 0, talloc_tos(), &msgs);
801         if (!TLDAP_RC_IS_SUCCESS(rc)) {
802                 return NT_STATUS_LDAP(TLDAP_RC_V(rc));
803         }
804
805         TALLOC_FREE(filter);
806
807         num_msgs = talloc_array_length(msgs);
808
809         for (i=0; i<num_msgs; i++) {
810                 struct tldap_message *msg = msgs[i];
811                 char *dn;
812                 struct id_map *map;
813                 struct dom_sid sid;
814                 size_t j;
815                 bool ok;
816                 uint64_t account_type, xid;
817                 enum id_type type;
818
819                 if (tldap_msg_type(msg) != TLDAP_RES_SEARCH_ENTRY) {
820                         continue;
821                 }
822
823                 ok = tldap_entry_dn(msg, &dn);
824                 if (!ok) {
825                         DBG_DEBUG("No dn found in msg %zu\n", i);
826                         continue;
827                 }
828
829                 ok = tldap_pull_binsid(msg, "objectSid", &sid);
830                 if (!ok) {
831                         DBG_DEBUG("No objectSid in object %s\n", dn);
832                         continue;
833                 }
834
835                 map = NULL;
836                 for (j=0; ids[j]; j++) {
837                         if (dom_sid_equal(&sid, ids[j]->sid)) {
838                                 map = ids[j];
839                                 break;
840                         }
841                 }
842                 if (map == NULL) {
843                         DBG_DEBUG("Got unexpected sid %s from object %s\n",
844                                   sid_string_tos(&sid), dn);
845                         continue;
846                 }
847
848                 ok = tldap_pull_uint64(msg, "sAMAccountType", &account_type);
849                 if (!ok) {
850                         DBG_DEBUG("No sAMAccountType in %s\n", dn);
851                         continue;
852                 }
853
854                 switch (account_type & 0xF0000000) {
855                 case ATYPE_SECURITY_GLOBAL_GROUP:
856                 case ATYPE_SECURITY_LOCAL_GROUP:
857                         type = ID_TYPE_GID;
858                         break;
859                 case ATYPE_NORMAL_ACCOUNT:
860                 case ATYPE_WORKSTATION_TRUST:
861                 case ATYPE_INTERDOMAIN_TRUST:
862                         type = ID_TYPE_UID;
863                         break;
864                 default:
865                         DBG_WARNING("unrecognized SAM account type %"PRIu64"\n",
866                                     account_type);
867                         continue;
868                 }
869
870                 ok = tldap_pull_uint64(msg,
871                                        type == ID_TYPE_UID ?
872                                        ctx->schema->uid : ctx->schema->gid,
873                                        &xid);
874                 if (!ok) {
875                         DBG_DEBUG("No xid in %s\n", dn);
876                         continue;
877                 }
878
879                 /* mapped */
880                 map->xid.type = type;
881                 map->xid.id = xid;
882                 map->status = ID_MAPPED;
883
884                 DEBUG(10, ("Mapped %s -> %lu (%d)\n", sid_string_dbg(map->sid),
885                            (unsigned long)map->xid.id, map->xid.type));
886         }
887
888         TALLOC_FREE(msgs);
889
890         return NT_STATUS_OK;
891 }
892
893 static NTSTATUS idmap_ad_unixids_to_sids_retry(struct idmap_domain *dom,
894                                                struct id_map **ids)
895 {
896         const NTSTATUS status_server_down =
897                 NT_STATUS_LDAP(TLDAP_RC_V(TLDAP_SERVER_DOWN));
898         NTSTATUS status;
899
900         status = idmap_ad_unixids_to_sids(dom, ids);
901
902         if (NT_STATUS_EQUAL(status, status_server_down)) {
903                 TALLOC_FREE(dom->private_data);
904                 status = idmap_ad_unixids_to_sids(dom, ids);
905         }
906
907         return status;
908 }
909
910 static NTSTATUS idmap_ad_sids_to_unixids_retry(struct idmap_domain *dom,
911                                                struct id_map **ids)
912 {
913         const NTSTATUS status_server_down =
914                 NT_STATUS_LDAP(TLDAP_RC_V(TLDAP_SERVER_DOWN));
915         NTSTATUS status;
916
917         status = idmap_ad_sids_to_unixids(dom, ids);
918
919         if (NT_STATUS_EQUAL(status, status_server_down)) {
920                 TALLOC_FREE(dom->private_data);
921                 status = idmap_ad_sids_to_unixids(dom, ids);
922         }
923
924         return status;
925 }
926
927 static struct idmap_methods ad_methods = {
928         .init            = idmap_ad_initialize,
929         .unixids_to_sids = idmap_ad_unixids_to_sids_retry,
930         .sids_to_unixids = idmap_ad_sids_to_unixids_retry,
931 };
932
933 static_decl_idmap;
934 NTSTATUS idmap_ad_init(TALLOC_CTX *ctx)
935 {
936         NTSTATUS status;
937
938         status = smb_register_idmap(SMB_IDMAP_INTERFACE_VERSION,
939                                     "ad", &ad_methods);
940         if (!NT_STATUS_IS_OK(status)) {
941                 return status;
942         }
943
944         status = idmap_ad_nss_init(ctx);
945         if (!NT_STATUS_IS_OK(status)) {
946                 return status;
947         }
948
949         return NT_STATUS_OK;
950 }