s3-secrets: only include secrets.h when needed.
[nivanova/samba-autobuild/.git] / source3 / lib / netapi / joindomain.c
index 96983d43e31f53f4e701b590cdb51ad4ad900f6b..13a06c7136c97b7d8637802648c88195f73d0809 100644 (file)
@@ -1,7 +1,7 @@
 /*
  *  Unix SMB/CIFS implementation.
  *  NetApi Join Support
- *  Copyright (C) Guenther Deschner 2007
+ *  Copyright (C) Guenther Deschner 2007-2008
  *
  *  This program is free software; you can redistribute it and/or modify
  *  it under the terms of the GNU General Public License as published by
  */
 
 #include "includes.h"
-#include "lib/netapi/joindomain.h"
-
-extern const char *opt_user_name;
-extern const char *opt_workgroup;
-extern const char *opt_password;
-
-static WERROR NetJoinDomainLocal(TALLOC_CTX *mem_ctx,
-                                const char *server_name,
-                                const char *domain_name,
-                                const char *account_ou,
-                                const char *Account,
-                                const char *password,
-                                uint32_t join_flags)
+#include "ads.h"
+#include "librpc/gen_ndr/libnetapi.h"
+#include "lib/netapi/netapi.h"
+#include "lib/netapi/netapi_private.h"
+#include "lib/netapi/libnetapi.h"
+#include "librpc/gen_ndr/libnet_join.h"
+#include "libnet/libnet_join.h"
+#include "libcli/auth/libcli_auth.h"
+#include "../librpc/gen_ndr/cli_wkssvc.h"
+#include "secrets.h"
+
+/****************************************************************
+****************************************************************/
+
+WERROR NetJoinDomain_l(struct libnetapi_ctx *mem_ctx,
+                      struct NetJoinDomain *r)
 {
-       struct libnet_JoinCtx *r = NULL;
+       struct libnet_JoinCtx *j = NULL;
        WERROR werr;
 
-       werr = libnet_init_JoinCtx(mem_ctx, &r);
-       W_ERROR_NOT_OK_RETURN(werr);
-
-       if (!server_name || !domain_name) {
+       if (!r->in.domain) {
                return WERR_INVALID_PARAM;
        }
 
-       r->in.server_name = talloc_strdup(mem_ctx, server_name);
-       W_ERROR_HAVE_NO_MEMORY(r->in.server_name);
+       werr = libnet_init_JoinCtx(mem_ctx, &j);
+       W_ERROR_NOT_OK_RETURN(werr);
+
+       j->in.domain_name = talloc_strdup(mem_ctx, r->in.domain);
+       W_ERROR_HAVE_NO_MEMORY(j->in.domain_name);
+
+       if (r->in.join_flags & WKSSVC_JOIN_FLAGS_JOIN_TYPE) {
+               NTSTATUS status;
+               struct netr_DsRGetDCNameInfo *info = NULL;
+               const char *dc = NULL;
+               uint32_t flags = DS_DIRECTORY_SERVICE_REQUIRED |
+                                DS_WRITABLE_REQUIRED |
+                                DS_RETURN_DNS_NAME;
+               status = dsgetdcname(mem_ctx, NULL, r->in.domain,
+                                    NULL, NULL, flags, &info);
+               if (!NT_STATUS_IS_OK(status)) {
+                       libnetapi_set_error_string(mem_ctx,
+                               "%s", get_friendly_nt_error_msg(status));
+                       return ntstatus_to_werror(status);
+               }
 
-       r->in.domain_name = talloc_strdup(mem_ctx, domain_name);
-       W_ERROR_HAVE_NO_MEMORY(r->in.domain_name);
+               dc = strip_hostname(info->dc_unc);
+               j->in.dc_name = talloc_strdup(mem_ctx, dc);
+               W_ERROR_HAVE_NO_MEMORY(j->in.dc_name);
+       }
 
-       if (account_ou) {
-               r->in.account_ou = talloc_strdup(mem_ctx, account_ou);
-               W_ERROR_HAVE_NO_MEMORY(r->in.account_ou);
+       if (r->in.account_ou) {
+               j->in.account_ou = talloc_strdup(mem_ctx, r->in.account_ou);
+               W_ERROR_HAVE_NO_MEMORY(j->in.account_ou);
        }
 
-       if (Account) {
-               r->in.admin_account = talloc_strdup(mem_ctx, Account);
-               W_ERROR_HAVE_NO_MEMORY(r->in.admin_account);
+       if (r->in.account) {
+               j->in.admin_account = talloc_strdup(mem_ctx, r->in.account);
+               W_ERROR_HAVE_NO_MEMORY(j->in.admin_account);
        }
 
-       if (password) {
-               r->in.password = talloc_strdup(mem_ctx, password);
-               W_ERROR_HAVE_NO_MEMORY(r->in.password);
+       if (r->in.password) {
+               j->in.admin_password = talloc_strdup(mem_ctx, r->in.password);
+               W_ERROR_HAVE_NO_MEMORY(j->in.admin_password);
        }
 
-       r->in.join_flags = join_flags;
-       r->in.modify_config = true;
+       j->in.join_flags = r->in.join_flags;
+       j->in.modify_config = true;
+       j->in.debug = true;
+
+       werr = libnet_Join(mem_ctx, j);
+       if (!W_ERROR_IS_OK(werr) && j->out.error_string) {
+               libnetapi_set_error_string(mem_ctx, "%s", j->out.error_string);
+       }
+       TALLOC_FREE(j);
 
-       return libnet_Join(mem_ctx, r);
+       return werr;
 }
 
-static WERROR NetJoinDomainRemote(TALLOC_CTX *mem_ctx,
-                                 const char *server_name,
-                                 const char *domain_name,
-                                 const char *account_ou,
-                                 const char *Account,
-                                 const char *password,
-                                 uint32_t join_flags)
+/****************************************************************
+****************************************************************/
+
+WERROR NetJoinDomain_r(struct libnetapi_ctx *ctx,
+                      struct NetJoinDomain *r)
 {
-       struct cli_state *cli = NULL;
        struct rpc_pipe_client *pipe_cli = NULL;
-       struct wkssvc_PasswordBuffer encrypted_password;
+       struct wkssvc_PasswordBuffer *encrypted_password = NULL;
        NTSTATUS status;
        WERROR werr;
        unsigned int old_timeout = 0;
 
-       ZERO_STRUCT(encrypted_password);
-
-       status = cli_full_connection(&cli, NULL, server_name,
-                                    NULL, 0,
-                                    "IPC$", "IPC",
-                                    opt_user_name, opt_workgroup,
-                                    opt_password, 0, Undefined, NULL);
-
-       if (!NT_STATUS_IS_OK(status)) {
-               werr = ntstatus_to_werror(status);
+       werr = libnetapi_open_pipe(ctx, r->in.server,
+                                  &ndr_table_wkssvc.syntax_id,
+                                  &pipe_cli);
+       if (!W_ERROR_IS_OK(werr)) {
                goto done;
        }
 
-       old_timeout = cli_set_timeout(cli, 60000);
-
-       pipe_cli = cli_rpc_pipe_open_noauth(cli, PI_WKSSVC,
-                                           &status);
-       if (!pipe_cli) {
-               werr = ntstatus_to_werror(status);
-               goto done;
-       };
-
-       if (password) {
-               encode_wkssvc_join_password_buffer(mem_ctx,
-                                                  password,
-                                                  &cli->user_session_key,
+       if (r->in.password) {
+               encode_wkssvc_join_password_buffer(ctx,
+                                                  r->in.password,
+                                                  &pipe_cli->auth->user_session_key,
                                                   &encrypted_password);
        }
 
-       old_timeout = cli_set_timeout(cli, 60000);
+       old_timeout = rpccli_set_timeout(pipe_cli, 600000);
 
-       status = rpccli_wkssvc_NetrJoinDomain2(pipe_cli, mem_ctx,
-                                              server_name, domain_name,
-                                              account_ou, Account,
-                                              &encrypted_password,
-                                              join_flags, &werr);
+       status = rpccli_wkssvc_NetrJoinDomain2(pipe_cli, ctx,
+                                              r->in.server,
+                                              r->in.domain,
+                                              r->in.account_ou,
+                                              r->in.account,
+                                              encrypted_password,
+                                              r->in.join_flags,
+                                              &werr);
        if (!NT_STATUS_IS_OK(status)) {
                werr = ntstatus_to_werror(status);
                goto done;
        }
 
  done:
-       if (cli) {
-               cli_set_timeout(cli, old_timeout);
-               cli_shutdown(cli);
+       if (pipe_cli && old_timeout) {
+               rpccli_set_timeout(pipe_cli, old_timeout);
        }
 
        return werr;
 }
+/****************************************************************
+****************************************************************/
 
-WERROR NetJoinDomain(const char *server_name,
-                    const char *domain_name,
-                    const char *account_ou,
-                    const char *Account,
-                    const char *password,
-                    uint32_t join_flags)
+WERROR NetUnjoinDomain_l(struct libnetapi_ctx *mem_ctx,
+                        struct NetUnjoinDomain *r)
 {
-       TALLOC_CTX *mem_ctx = NULL;
+       struct libnet_UnjoinCtx *u = NULL;
+       struct dom_sid domain_sid;
+       const char *domain = NULL;
        WERROR werr;
 
-       mem_ctx = talloc_init("NetJoinDomain");
-       if (!mem_ctx) {
-               werr = WERR_NOMEM;
-               goto done;
+       if (!secrets_fetch_domain_sid(lp_workgroup(), &domain_sid)) {
+               return WERR_SETUP_NOT_JOINED;
        }
 
-       if (!domain_name) {
-               werr = WERR_INVALID_PARAM;
-               goto done;
-       }
+       werr = libnet_init_UnjoinCtx(mem_ctx, &u);
+       W_ERROR_NOT_OK_RETURN(werr);
 
-       if (!server_name || is_myname_or_ipaddr(server_name)) {
+       if (lp_realm()) {
+               domain = lp_realm();
+       } else {
+               domain = lp_workgroup();
+       }
 
+       if (r->in.server_name) {
+               u->in.dc_name = talloc_strdup(mem_ctx, r->in.server_name);
+               W_ERROR_HAVE_NO_MEMORY(u->in.dc_name);
+       } else {
+               NTSTATUS status;
+               struct netr_DsRGetDCNameInfo *info = NULL;
                const char *dc = NULL;
-
-               /* FIXME: DsGetDcName */
-               if (server_name == NULL) {
-                       dc = domain_name;
-               } else {
-                       dc = domain_name;
+               uint32_t flags = DS_DIRECTORY_SERVICE_REQUIRED |
+                                DS_WRITABLE_REQUIRED |
+                                DS_RETURN_DNS_NAME;
+               status = dsgetdcname(mem_ctx, NULL, domain,
+                                    NULL, NULL, flags, &info);
+               if (!NT_STATUS_IS_OK(status)) {
+                       libnetapi_set_error_string(mem_ctx,
+                               "failed to find DC for domain %s: %s",
+                               domain,
+                               get_friendly_nt_error_msg(status));
+                       return ntstatus_to_werror(status);
                }
 
-               werr = NetJoinDomainLocal(mem_ctx,
-                                         dc,
-                                         domain_name,
-                                         account_ou,
-                                         Account,
-                                         password,
-                                         join_flags);
+               dc = strip_hostname(info->dc_unc);
+               u->in.dc_name = talloc_strdup(mem_ctx, dc);
+               W_ERROR_HAVE_NO_MEMORY(u->in.dc_name);
 
-               goto done;
+               u->in.domain_name = domain;
        }
 
-       werr = NetJoinDomainRemote(mem_ctx,
-                                  server_name,
-                                  domain_name,
-                                  account_ou,
-                                  Account,
-                                  password,
-                                  join_flags);
-done:
-       TALLOC_FREE(mem_ctx);
+       if (r->in.account) {
+               u->in.admin_account = talloc_strdup(mem_ctx, r->in.account);
+               W_ERROR_HAVE_NO_MEMORY(u->in.admin_account);
+       }
+
+       if (r->in.password) {
+               u->in.admin_password = talloc_strdup(mem_ctx, r->in.password);
+               W_ERROR_HAVE_NO_MEMORY(u->in.admin_password);
+       }
+
+       u->in.domain_name = domain;
+       u->in.unjoin_flags = r->in.unjoin_flags;
+       u->in.delete_machine_account = false;
+       u->in.modify_config = true;
+       u->in.debug = true;
+
+       u->in.domain_sid = &domain_sid;
+
+       werr = libnet_Unjoin(mem_ctx, u);
+       if (!W_ERROR_IS_OK(werr) && u->out.error_string) {
+               libnetapi_set_error_string(mem_ctx, "%s", u->out.error_string);
+       }
+       TALLOC_FREE(u);
 
        return werr;
 }
 
-WERROR NetUnjoinDomain(const char *server_name,
-                      const char *account,
-                      const char *password,
-                      uint32_t unjoin_flags)
+/****************************************************************
+****************************************************************/
+
+WERROR NetUnjoinDomain_r(struct libnetapi_ctx *ctx,
+                        struct NetUnjoinDomain *r)
 {
-       TALLOC_CTX *mem_ctx = NULL;
-       struct cli_state *cli = NULL;
        struct rpc_pipe_client *pipe_cli = NULL;
-       struct wkssvc_PasswordBuffer encrypted_password;
+       struct wkssvc_PasswordBuffer *encrypted_password = NULL;
        NTSTATUS status;
        WERROR werr;
        unsigned int old_timeout = 0;
 
-       ZERO_STRUCT(encrypted_password);
-
-       mem_ctx = talloc_init("NetUnjoinDomain");
-       if (!mem_ctx) {
-               werr = WERR_NOMEM;
+       werr = libnetapi_open_pipe(ctx, r->in.server_name,
+                                  &ndr_table_wkssvc.syntax_id,
+                                  &pipe_cli);
+       if (!W_ERROR_IS_OK(werr)) {
                goto done;
        }
 
-       if (!server_name || is_myname_or_ipaddr(server_name)) {
-               werr = WERR_NOT_SUPPORTED;
-               goto done;
+       if (r->in.password) {
+               encode_wkssvc_join_password_buffer(ctx,
+                                                  r->in.password,
+                                                  &pipe_cli->auth->user_session_key,
+                                                  &encrypted_password);
        }
 
-       status = cli_full_connection(&cli, NULL, server_name,
-                                    NULL, 0,
-                                    "IPC$", "IPC",
-                                    opt_user_name, opt_workgroup,
-                                    opt_password, 0, Undefined, NULL);
+       old_timeout = rpccli_set_timeout(pipe_cli, 60000);
 
+       status = rpccli_wkssvc_NetrUnjoinDomain2(pipe_cli, ctx,
+                                                r->in.server_name,
+                                                r->in.account,
+                                                encrypted_password,
+                                                r->in.unjoin_flags,
+                                                &werr);
        if (!NT_STATUS_IS_OK(status)) {
                werr = ntstatus_to_werror(status);
                goto done;
        }
 
-       old_timeout = cli_set_timeout(cli, 60000);
+ done:
+       if (pipe_cli && old_timeout) {
+               rpccli_set_timeout(pipe_cli, old_timeout);
+       }
 
-       pipe_cli = cli_rpc_pipe_open_noauth(cli, PI_WKSSVC,
-                                           &status);
-       if (!pipe_cli) {
-               werr = ntstatus_to_werror(status);
-               goto done;
-       };
+       return werr;
+}
 
-       if (password) {
-               encode_wkssvc_join_password_buffer(mem_ctx,
-                                                  password,
-                                                  &cli->user_session_key,
-                                                  &encrypted_password);
-       }
+/****************************************************************
+****************************************************************/
 
-       old_timeout = cli_set_timeout(cli, 60000);
+WERROR NetGetJoinInformation_r(struct libnetapi_ctx *ctx,
+                              struct NetGetJoinInformation *r)
+{
+       struct rpc_pipe_client *pipe_cli = NULL;
+       NTSTATUS status;
+       WERROR werr;
+       const char *buffer = NULL;
 
-       status = rpccli_wkssvc_NetrUnjoinDomain2(pipe_cli, mem_ctx,
-                                                server_name,
-                                                account,
-                                                &encrypted_password,
-                                                unjoin_flags,
-                                                &werr);
+       werr = libnetapi_open_pipe(ctx, r->in.server_name,
+                                  &ndr_table_wkssvc.syntax_id,
+                                  &pipe_cli);
+       if (!W_ERROR_IS_OK(werr)) {
+               goto done;
+       }
+
+       status = rpccli_wkssvc_NetrGetJoinInformation(pipe_cli, ctx,
+                                                     r->in.server_name,
+                                                     &buffer,
+                                                     (enum wkssvc_NetJoinStatus *)r->out.name_type,
+                                                     &werr);
        if (!NT_STATUS_IS_OK(status)) {
                werr = ntstatus_to_werror(status);
                goto done;
        }
 
+       *r->out.name_buffer = talloc_strdup(ctx, buffer);
+       W_ERROR_HAVE_NO_MEMORY(*r->out.name_buffer);
+
  done:
-       if (cli) {
-               cli_set_timeout(cli, old_timeout);
-               cli_shutdown(cli);
+       return werr;
+}
+
+/****************************************************************
+****************************************************************/
+
+WERROR NetGetJoinInformation_l(struct libnetapi_ctx *ctx,
+                              struct NetGetJoinInformation *r)
+{
+       if ((lp_security() == SEC_ADS) && lp_realm()) {
+               *r->out.name_buffer = talloc_strdup(ctx, lp_realm());
+       } else {
+               *r->out.name_buffer = talloc_strdup(ctx, lp_workgroup());
+       }
+       if (!*r->out.name_buffer) {
+               return WERR_NOMEM;
        }
-       TALLOC_FREE(mem_ctx);
 
-       return werr;
+       switch (lp_server_role()) {
+               case ROLE_DOMAIN_MEMBER:
+               case ROLE_DOMAIN_PDC:
+               case ROLE_DOMAIN_BDC:
+                       *r->out.name_type = NetSetupDomainName;
+                       break;
+               case ROLE_STANDALONE:
+               default:
+                       *r->out.name_type = NetSetupWorkgroupName;
+                       break;
+       }
+
+       return WERR_OK;
 }
 
-WERROR NetGetJoinInformation(const char *server_name,
-                            const char **name_buffer,
-                            uint16_t *name_type)
+/****************************************************************
+****************************************************************/
+
+WERROR NetGetJoinableOUs_l(struct libnetapi_ctx *ctx,
+                          struct NetGetJoinableOUs *r)
+{
+#ifdef WITH_ADS
+       NTSTATUS status;
+       ADS_STATUS ads_status;
+       ADS_STRUCT *ads = NULL;
+       struct netr_DsRGetDCNameInfo *info = NULL;
+       const char *dc = NULL;
+       uint32_t flags = DS_DIRECTORY_SERVICE_REQUIRED |
+                        DS_RETURN_DNS_NAME;
+
+       status = dsgetdcname(ctx, NULL, r->in.domain,
+                            NULL, NULL, flags, &info);
+       if (!NT_STATUS_IS_OK(status)) {
+               libnetapi_set_error_string(ctx, "%s",
+                       get_friendly_nt_error_msg(status));
+               return ntstatus_to_werror(status);
+       }
+
+       dc = strip_hostname(info->dc_unc);
+
+       ads = ads_init(info->domain_name, info->domain_name, dc);
+       if (!ads) {
+               return WERR_GENERAL_FAILURE;
+       }
+
+       SAFE_FREE(ads->auth.user_name);
+       if (r->in.account) {
+               ads->auth.user_name = SMB_STRDUP(r->in.account);
+       } else if (ctx->username) {
+               ads->auth.user_name = SMB_STRDUP(ctx->username);
+       }
+
+       SAFE_FREE(ads->auth.password);
+       if (r->in.password) {
+               ads->auth.password = SMB_STRDUP(r->in.password);
+       } else if (ctx->password) {
+               ads->auth.password = SMB_STRDUP(ctx->password);
+       }
+
+       ads_status = ads_connect_user_creds(ads);
+       if (!ADS_ERR_OK(ads_status)) {
+               ads_destroy(&ads);
+               return WERR_DEFAULT_JOIN_REQUIRED;
+       }
+
+       ads_status = ads_get_joinable_ous(ads, ctx,
+                                         (char ***)r->out.ous,
+                                         (size_t *)r->out.ou_count);
+       if (!ADS_ERR_OK(ads_status)) {
+               ads_destroy(&ads);
+               return WERR_DEFAULT_JOIN_REQUIRED;
+       }
+
+       ads_destroy(&ads);
+       return WERR_OK;
+#else
+       return WERR_NOT_SUPPORTED;
+#endif
+}
+
+/****************************************************************
+****************************************************************/
+
+WERROR NetGetJoinableOUs_r(struct libnetapi_ctx *ctx,
+                          struct NetGetJoinableOUs *r)
 {
-       TALLOC_CTX *mem_ctx = NULL;
-       struct cli_state *cli = NULL;
        struct rpc_pipe_client *pipe_cli = NULL;
+       struct wkssvc_PasswordBuffer *encrypted_password = NULL;
        NTSTATUS status;
        WERROR werr;
 
-       mem_ctx = talloc_init("NetGetJoinInformation");
-       if (!mem_ctx) {
-               werr = WERR_NOMEM;
+       werr = libnetapi_open_pipe(ctx, r->in.server_name,
+                                  &ndr_table_wkssvc.syntax_id,
+                                  &pipe_cli);
+       if (!W_ERROR_IS_OK(werr)) {
                goto done;
        }
 
-       status = cli_full_connection(&cli, NULL, server_name,
-                                    NULL, 0,
-                                    "IPC$", "IPC",
-                                    opt_user_name, opt_workgroup,
-                                    opt_password, 0, Undefined, NULL);
+       if (r->in.password) {
+               encode_wkssvc_join_password_buffer(ctx,
+                                                  r->in.password,
+                                                  &pipe_cli->auth->user_session_key,
+                                                  &encrypted_password);
+       }
 
+       status = rpccli_wkssvc_NetrGetJoinableOus2(pipe_cli, ctx,
+                                                  r->in.server_name,
+                                                  r->in.domain,
+                                                  r->in.account,
+                                                  encrypted_password,
+                                                  r->out.ou_count,
+                                                  r->out.ous,
+                                                  &werr);
        if (!NT_STATUS_IS_OK(status)) {
                werr = ntstatus_to_werror(status);
                goto done;
        }
 
-       pipe_cli = cli_rpc_pipe_open_noauth(cli, PI_WKSSVC,
-                                           &status);
-       if (!pipe_cli) {
-               werr = ntstatus_to_werror(status);
+ done:
+       return werr;
+}
+
+/****************************************************************
+****************************************************************/
+
+WERROR NetRenameMachineInDomain_r(struct libnetapi_ctx *ctx,
+                                 struct NetRenameMachineInDomain *r)
+{
+       struct rpc_pipe_client *pipe_cli = NULL;
+       struct wkssvc_PasswordBuffer *encrypted_password = NULL;
+       NTSTATUS status;
+       WERROR werr;
+
+       werr = libnetapi_open_pipe(ctx, r->in.server_name,
+                                  &ndr_table_wkssvc.syntax_id,
+                                  &pipe_cli);
+       if (!W_ERROR_IS_OK(werr)) {
                goto done;
-       };
+       }
 
-       status = rpccli_wkssvc_NetrGetJoinInformation(pipe_cli, mem_ctx,
-                                                     server_name,
-                                                     name_buffer,
-                                                     (enum wkssvc_NetJoinStatus *)name_type,
-                                                     &werr);
+       if (r->in.password) {
+               encode_wkssvc_join_password_buffer(ctx,
+                                                  r->in.password,
+                                                  &pipe_cli->auth->user_session_key,
+                                                  &encrypted_password);
+       }
+
+       status = rpccli_wkssvc_NetrRenameMachineInDomain2(pipe_cli, ctx,
+                                                         r->in.server_name,
+                                                         r->in.new_machine_name,
+                                                         r->in.account,
+                                                         encrypted_password,
+                                                         r->in.rename_options,
+                                                         &werr);
        if (!NT_STATUS_IS_OK(status)) {
                werr = ntstatus_to_werror(status);
                goto done;
        }
 
  done:
-       if (cli) {
-               cli_shutdown(cli);
-       }
-       TALLOC_FREE(mem_ctx);
-
        return werr;
 }
+
+/****************************************************************
+****************************************************************/
+
+WERROR NetRenameMachineInDomain_l(struct libnetapi_ctx *ctx,
+                                 struct NetRenameMachineInDomain *r)
+{
+       LIBNETAPI_REDIRECT_TO_LOCALHOST(ctx, r, NetRenameMachineInDomain);
+}