Store the type of 'sec channel' that we establish to the DC. If we are a
[sfrench/samba-autobuild/.git] / source3 / utils / net_rpc.c
index dceb5ffd50408538a9ca9f90c1f2cc8d36413b76..9ae50aaf0ddce1a2cdb4e95fec9c13b4fb6c0582 100644 (file)
@@ -21,8 +21,6 @@
 #include "includes.h"
 #include "../utils/net.h"
 
-extern pstring global_myname;
-
 /**
  * @file net_rpc.c
  *
@@ -64,14 +62,14 @@ static DOM_SID *net_get_remote_domain_sid(struct cli_state *cli)
                goto error;
        }
            
-       if (!(mem_ctx=talloc_init()))
+       if (!(mem_ctx=talloc_init("net_get_remote_domain_sid")))
        {
                DEBUG(0,("net_get_remote_domain_sid: talloc_init returned NULL!\n"));
                goto error;
        }
 
 
-       if (!cli_nt_session_open (cli, PIPE_LSARPC)) {
+       if (!cli_nt_session_open (cli, PI_LSARPC)) {
                fprintf(stderr, "could not initialise lsa pipe\n");
                goto error;
        }
@@ -117,15 +115,21 @@ static DOM_SID *net_get_remote_domain_sid(struct cli_state *cli)
  * @return A shell status integer (0 for success)
  */
 
-static int run_rpc_command(const char *pipe_name, int conn_flags,
-                          rpc_command_fn fn,
-                          int argc, const char **argv) 
+static int run_rpc_command(struct cli_state *cli_arg, const int pipe_idx, int conn_flags,
+                           rpc_command_fn fn,
+                           int argc, const char **argv) 
 {
-       struct cli_state *cli = net_make_ipc_connection(conn_flags);
+       struct cli_state *cli = NULL;
        TALLOC_CTX *mem_ctx;
        NTSTATUS nt_status;
        DOM_SID *domain_sid;
 
+       /* make use of cli_state handed over as an argument, if possible */
+       if (!cli_arg)
+               cli = net_make_ipc_connection(conn_flags);
+       else
+               cli = cli_arg;
+
        if (!cli) {
                return -1;
        }
@@ -134,14 +138,14 @@ static int run_rpc_command(const char *pipe_name, int conn_flags,
 
        /* Create mem_ctx */
        
-       if (!(mem_ctx = talloc_init())) {
+       if (!(mem_ctx = talloc_init("run_rpc_command"))) {
                DEBUG(0, ("talloc_init() failed\n"));
                cli_shutdown(cli);
                return -1;
        }
        
-       if (!cli_nt_session_open(cli, pipe_name)) {
-               DEBUG(0, ("Could not initialise samr pipe\n"));
+       if (!cli_nt_session_open(cli, pipe_idx)) {
+               DEBUG(0, ("Could not initialise pipe\n"));
        }
        
        nt_status = fn(domain_sid, cli, mem_ctx, argc, argv);
@@ -156,6 +160,10 @@ static int run_rpc_command(const char *pipe_name, int conn_flags,
        if (cli->nt_pipe_fnum)
                cli_nt_session_close(cli);
        
+       /* close the connection only if it was opened here */
+       if (!cli_arg)
+               cli_shutdown(cli);
+       
        talloc_destroy(mem_ctx);
 
        return (!NT_STATUS_IS_OK(nt_status));
@@ -168,7 +176,7 @@ static int run_rpc_command(const char *pipe_name, int conn_flags,
 /** 
  * Force a change of the trust acccount password.
  *
- * All paramaters are provided by the run_rpc_command funcion, except for
+ * All parameters are provided by the run_rpc_command function, except for
  * argc, argv which are passes through. 
  *
  * @param domain_sid The domain sid aquired from the remote server
@@ -197,9 +205,9 @@ static NTSTATUS rpc_changetrustpw_internals(const DOM_SID *domain_sid, struct cl
  * @return A shell status integer (0 for success)
  **/
 
-static int rpc_changetrustpw(int argc, const char **argv) 
+int net_rpc_changetrustpw(int argc, const char **argv) 
 {
-       return run_rpc_command(PIPE_NETLOGON, NET_FLAGS_ANONYMOUS | NET_FLAGS_PDC, rpc_changetrustpw_internals,
+       return run_rpc_command(NULL, PI_NETLOGON, NET_FLAGS_ANONYMOUS | NET_FLAGS_PDC, rpc_changetrustpw_internals,
                               argc, argv);
 }
 
@@ -212,9 +220,9 @@ static int rpc_changetrustpw(int argc, const char **argv)
  *
  * This uses 'machinename' as the inital password, and changes it. 
  *
- * The password should be created with 'server manager' or eqiv first.
+ * The password should be created with 'server manager' or equiv first.
  *
- * All paramaters are provided by the run_rpc_command funcion, except for
+ * All parameters are provided by the run_rpc_command function, except for
  * argc, argv which are passes through. 
  *
  * @param domain_sid The domain sid aquired from the remote server
@@ -227,14 +235,15 @@ static int rpc_changetrustpw(int argc, const char **argv)
  * @return Normal NTSTATUS return.
  **/
 
-static NTSTATUS rpc_join_oldstyle_internals(const DOM_SID *domain_sid, struct cli_state *cli, TALLOC_CTX *mem_ctx, 
-                                      int argc, const char **argv) {
+static NTSTATUS rpc_join_oldstyle_internals(const DOM_SID *domain_sid, struct cli_state *cli, 
+                                           TALLOC_CTX *mem_ctx, 
+                                           int argc, const char **argv) {
        
-       extern pstring global_myname;
        fstring trust_passwd;
        unsigned char orig_trust_passwd_hash[16];
+       NTSTATUS result;
 
-       fstrcpy(trust_passwd, global_myname);
+       fstrcpy(trust_passwd, global_myname());
        strlower(trust_passwd);
 
        /*
@@ -246,7 +255,24 @@ static NTSTATUS rpc_join_oldstyle_internals(const DOM_SID *domain_sid, struct cl
 
        E_md4hash(trust_passwd, orig_trust_passwd_hash);
 
-       return trust_pw_change_and_store_it(cli, mem_ctx, orig_trust_passwd_hash);
+       result = trust_pw_change_and_store_it(cli, mem_ctx, opt_target_workgroup,
+                                             orig_trust_passwd_hash,
+                                             SEC_CHAN_WKSTA);
+
+       /* SEC_CHAN_WKSTA specified specifically, as you cannot use this
+          to join a BDC to the domain (MS won't allow it, and is *really*
+          insecure) */
+
+       if (NT_STATUS_IS_OK(result))
+               printf("Joined domain %s.\n",opt_target_workgroup);
+
+
+       if (!secrets_store_domain_sid(opt_target_workgroup, domain_sid)) {
+               DEBUG(0, ("error storing domain sid for %s\n", opt_target_workgroup));
+               result = NT_STATUS_UNSUCCESSFUL;
+       }
+
+       return result;
 }
 
 /** 
@@ -261,7 +287,38 @@ static NTSTATUS rpc_join_oldstyle_internals(const DOM_SID *domain_sid, struct cl
 
 static int net_rpc_join_oldstyle(int argc, const char **argv) 
 {
-       return run_rpc_command(PIPE_NETLOGON, NET_FLAGS_ANONYMOUS | NET_FLAGS_PDC, rpc_join_oldstyle_internals,
+       uint32 sec_channel_type;
+       /* check what type of join */
+       if (argc >= 0) {
+               sec_channel_type = get_sec_channel_type(argv[0]);
+       } else {
+               sec_channel_type = get_sec_channel_type(NULL);
+       }
+       
+       if (sec_channel_type != SEC_CHAN_WKSTA) 
+               return 1;
+
+       return run_rpc_command(NULL, PI_NETLOGON, 
+                              NET_FLAGS_ANONYMOUS | NET_FLAGS_PDC, 
+                              rpc_join_oldstyle_internals,
+                              argc, argv);
+}
+
+/** 
+ * Join a domain, the old way.
+ *
+ * @param argc  Standard main() style argc
+ * @param argc  Standard main() style argv.  Initial components are already
+ *              stripped
+ *
+ * @return A shell status integer (0 for success)
+ **/
+
+static int net_rpc_oldjoin(int argc, const char **argv) 
+{
+       return run_rpc_command(NULL, PI_NETLOGON, 
+                              NET_FLAGS_ANONYMOUS | NET_FLAGS_PDC, 
+                              rpc_join_oldstyle_internals,
                               argc, argv);
 }
 
@@ -274,11 +331,13 @@ static int net_rpc_join_oldstyle(int argc, const char **argv)
 
 static int rpc_join_usage(int argc, const char **argv) 
 {      
-       d_printf("net rpc join -U <username>[%%password] [options]\n"\
+       d_printf("net rpc join -U <username>[%%password] <type>[options]\n"\
                 "\t to join a domain with admin username & password\n"\
-                "\t\t password will be prompted if none is specified\n");
-       d_printf("net rpc join [options except -U]\n"\
-                "\t to join a domain created in server manager\n\n\n");
+                "\t\t password will be prompted if needed and none is specified\n"\
+                "\t <type> can be (default MEMBER)\n"\
+                "\t\t BDC - Join as a BDC\n"\
+                "\t\t PDC - Join as a PDC\n"\
+                "\t\t MEMBER - Join as a MEMBER server\n");
 
        net_common_flags_usage(argc, argv);
        return -1;
@@ -293,7 +352,7 @@ static int rpc_join_usage(int argc, const char **argv)
  * Main 'net_rpc_join()' (where the admain username/password is used) is 
  * in net_rpc_join.c
  * Assume if a -U is specified, it's the new style, otherwise it's the
- * old style
+ * old style.  If 'oldstyle' is specfied explicity, do it and don't prompt.
  **/
 
 int net_rpc_join(int argc, const char **argv) 
@@ -309,8 +368,8 @@ int net_rpc_join(int argc, const char **argv)
 /** 
  * display info about a rpc domain
  *
- * All paramaters are provided by the run_rpc_command function, except for
- * argc, argv which are passes through. 
+ * All parameters are provided by the run_rpc_command function, except for
+ * argc, argv which are passed through. 
  *
  * @param domain_sid The domain sid acquired from the remote server
  * @param cli A cli_state connected to the server.
@@ -329,6 +388,9 @@ rpc_info_internals(const DOM_SID *domain_sid, struct cli_state *cli,
        POLICY_HND connect_pol, domain_pol;
        NTSTATUS result = NT_STATUS_UNSUCCESSFUL;
        SAM_UNK_CTR ctr;
+       fstring sid_str;
+
+       sid_to_string(sid_str, domain_sid);
 
        /* Get sam policy handle */     
        result = cli_samr_connect(cli, mem_ctx, MAXIMUM_ALLOWED_ACCESS, 
@@ -349,8 +411,9 @@ rpc_info_internals(const DOM_SID *domain_sid, struct cli_state *cli,
        result = cli_samr_query_dom_info(cli, mem_ctx, &domain_pol,
                                         2, &ctr);
        if (NT_STATUS_IS_OK(result)) {
-               TALLOC_CTX *ctx = talloc_init();
+               TALLOC_CTX *ctx = talloc_init("rpc_info_internals");
                d_printf("Domain Name: %s\n", unistr2_tdup(ctx, &ctr.info.inf2.uni_domain));
+               d_printf("Domain SID: %s\n", sid_str);
                d_printf("Sequence number: %u\n", ctr.info.inf2.seq_num);
                d_printf("Num users: %u\n", ctr.info.inf2.num_domain_usrs);
                d_printf("Num domain groups: %u\n", ctr.info.inf2.num_domain_grps);
@@ -371,12 +434,59 @@ rpc_info_internals(const DOM_SID *domain_sid, struct cli_state *cli,
  **/
 int net_rpc_info(int argc, const char **argv) 
 {
-       return run_rpc_command(PIPE_SAMR, NET_FLAGS_ANONYMOUS | NET_FLAGS_PDC, 
+       return run_rpc_command(NULL, PI_SAMR, NET_FLAGS_ANONYMOUS | NET_FLAGS_PDC, 
                               rpc_info_internals,
                               argc, argv);
 }
 
 
+/** 
+ * Fetch domain SID into the local secrets.tdb
+ *
+ * All parameters are provided by the run_rpc_command function, except for
+ * argc, argv which are passes through. 
+ *
+ * @param domain_sid The domain sid acquired from the remote server
+ * @param cli A cli_state connected to the server.
+ * @param mem_ctx Talloc context, destoyed on completion of the function.
+ * @param argc  Standard main() style argc
+ * @param argv  Standard main() style argv.  Initial components are already
+ *              stripped
+ *
+ * @return Normal NTSTATUS return.
+ **/
+
+static NTSTATUS 
+rpc_getsid_internals(const DOM_SID *domain_sid, struct cli_state *cli,
+                  TALLOC_CTX *mem_ctx, int argc, const char **argv)
+{
+       fstring sid_str;
+
+       sid_to_string(sid_str, domain_sid);
+       d_printf("Storing SID %s for Domain %s in secrets.tdb\n",
+                sid_str, lp_workgroup());
+
+       if (!secrets_store_domain_sid(global_myname(), domain_sid)) {
+               DEBUG(0,("Can't store domain SID\n"));
+               return NT_STATUS_UNSUCCESSFUL;
+       }
+
+       return NT_STATUS_OK;
+}
+
+
+/** 
+ * 'net rpc getsid' entrypoint.
+ * @param argc  Standard main() style argc
+ * @param argc  Standard main() style argv.  Initial components are already
+ *              stripped
+ **/
+int net_rpc_getsid(int argc, const char **argv) 
+{
+       return run_rpc_command(NULL, PI_SAMR, NET_FLAGS_ANONYMOUS | NET_FLAGS_PDC, 
+                              rpc_getsid_internals,
+                              argc, argv);
+}
 
 
 /****************************************************************************/
@@ -396,7 +506,7 @@ static int rpc_user_usage(int argc, const char **argv)
 /** 
  * Add a new user to a remote RPC server
  *
- * All paramaters are provided by the run_rpc_command funcion, except for
+ * All parameters are provided by the run_rpc_command function, except for
  * argc, argv which are passes through. 
  *
  * @param domain_sid The domain sid acquired from the remote server
@@ -477,14 +587,14 @@ static NTSTATUS rpc_user_add_internals(const DOM_SID *domain_sid, struct cli_sta
 
 static int rpc_user_add(int argc, const char **argv) 
 {
-       return run_rpc_command(PIPE_SAMR, 0, rpc_user_add_internals,
+       return run_rpc_command(NULL, PI_SAMR, 0, rpc_user_add_internals,
                               argc, argv);
 }
 
 /** 
  * Delete a user from a remote RPC server
  *
- * All paramaters are provided by the run_rpc_command funcion, except for
+ * All parameters are provided by the run_rpc_command function, except for
  * argc, argv which are passes through. 
  *
  * @param domain_sid The domain sid acquired from the remote server
@@ -578,14 +688,14 @@ static NTSTATUS rpc_user_del_internals(const DOM_SID *domain_sid,
 
 static int rpc_user_delete(int argc, const char **argv) 
 {
-       return run_rpc_command(PIPE_SAMR, 0, rpc_user_del_internals,
+       return run_rpc_command(NULL, PI_SAMR, 0, rpc_user_del_internals,
                               argc, argv);
 }
 
 /** 
  * List user's groups on a remote RPC server
  *
- * All paramaters are provided by the run_rpc_command funcion, except for
+ * All parameters are provided by the run_rpc_command function, except for
  * argc, argv which are passes through. 
  *
  * @param domain_sid The domain sid acquired from the remote server
@@ -680,14 +790,14 @@ rpc_user_info_internals(const DOM_SID *domain_sid, struct cli_state *cli,
 
 static int rpc_user_info(int argc, const char **argv) 
 {
-       return run_rpc_command(PIPE_SAMR, 0, rpc_user_info_internals,
+       return run_rpc_command(NULL, PI_SAMR, 0, rpc_user_info_internals,
                               argc, argv);
 }
 
 /** 
  * List users on a remote RPC server
  *
- * All paramaters are provided by the run_rpc_command function, except for
+ * All parameters are provided by the run_rpc_command function, except for
  * argc, argv which are passes through. 
  *
  * @param domain_sid The domain sid acquired from the remote server
@@ -706,7 +816,7 @@ rpc_user_list_internals(const DOM_SID *domain_sid, struct cli_state *cli,
 {
        POLICY_HND connect_pol, domain_pol;
        NTSTATUS result = NT_STATUS_UNSUCCESSFUL;
-       uint32 start_idx=0, max_entries=250, num_entries, i;
+       uint32 start_idx=0, num_entries, i, loop_count = 0;
        SAM_DISPINFO_CTR ctr;
        SAM_DISPINFO_1 info1;
 
@@ -736,9 +846,16 @@ rpc_user_list_internals(const DOM_SID *domain_sid, struct cli_state *cli,
                         "\n-----------------------------\n");
        do {
                fstring user, desc;
+               uint32 max_entries, max_size;
+
+               get_query_dispinfo_params(
+                       loop_count, &max_entries, &max_size);
+
                result = cli_samr_query_dispinfo(cli, mem_ctx, &domain_pol,
                                                 &start_idx, 1, &num_entries,
-                                                max_entries, &ctr);
+                                                max_entries, max_size, &ctr);
+               loop_count++;
+
                for (i = 0; i < num_entries; i++) {
                        unistr2_to_ascii(user, &(&ctr.sam.info1->str[i])->uni_acct_name, sizeof(user)-1);
                        if (opt_long_list_entries) 
@@ -775,7 +892,7 @@ int net_rpc_user(int argc, const char **argv)
                if (opt_long_list_entries) {
                } else {
                }
-                       return run_rpc_command(PIPE_SAMR, 0, 
+                       return run_rpc_command(NULL,PI_SAMR, 0, 
                                               rpc_user_list_internals,
                                               argc, argv);
        }
@@ -801,7 +918,7 @@ static int rpc_group_usage(int argc, const char **argv)
 /** 
  * List groups on a remote RPC server
  *
- * All paramaters are provided by the run_rpc_command funcion, except for
+ * All parameters are provided by the run_rpc_command function, except for
  * argc, argv which are passes through. 
  *
  * @param domain_sid The domain sid acquired from the remote server
@@ -926,7 +1043,7 @@ int net_rpc_group(int argc, const char **argv)
                if (opt_long_list_entries) {
                } else {
                }
-               return run_rpc_command(PIPE_SAMR, 0, 
+               return run_rpc_command(NULL, PI_SAMR, 0, 
                                       rpc_group_list_internals,
                                       argc, argv);
        }
@@ -944,7 +1061,7 @@ static int rpc_share_usage(int argc, const char **argv)
 /** 
  * Add a share on a remote RPC server
  *
- * All paramaters are provided by the run_rpc_command function, except for
+ * All parameters are provided by the run_rpc_command function, except for
  * argc, argv which are passes through. 
  *
  * @param domain_sid The domain sid acquired from the remote server
@@ -984,7 +1101,7 @@ static int rpc_share_add(int argc, const char **argv)
                DEBUG(1,("Sharename or path not specified on add\n"));
                return rpc_share_usage(argc, argv);
        }
-       return run_rpc_command(PIPE_SRVSVC, 0, 
+       return run_rpc_command(NULL, PI_SRVSVC, 0, 
                               rpc_share_add_internals,
                               argc, argv);
 }
@@ -992,7 +1109,7 @@ static int rpc_share_add(int argc, const char **argv)
 /** 
  * Delete a share on a remote RPC server
  *
- * All paramaters are provided by the run_rpc_command function, except for
+ * All parameters are provided by the run_rpc_command function, except for
  * argc, argv which are passes through. 
  *
  * @param domain_sid The domain sid acquired from the remote server
@@ -1030,7 +1147,7 @@ static int rpc_share_delete(int argc, const char **argv)
                DEBUG(1,("Sharename not specified on delete\n"));
                return rpc_share_usage(argc, argv);
        }
-       return run_rpc_command(PIPE_SRVSVC, 0, 
+       return run_rpc_command(NULL, PI_SRVSVC, 0, 
                               rpc_share_del_internals,
                               argc, argv);
 }
@@ -1060,7 +1177,7 @@ static void display_share_info_1(SRV_SHARE_INFO_1 *info1)
 /** 
  * List shares on a remote RPC server
  *
- * All paramaters are provided by the run_rpc_command function, except for
+ * All parameters are provided by the run_rpc_command function, except for
  * argc, argv which are passes through. 
  *
  * @param domain_sid The domain sid acquired from the remote server
@@ -1120,7 +1237,7 @@ int net_rpc_share(int argc, const char **argv)
        };
 
        if (argc == 0)
-               return run_rpc_command(PIPE_SRVSVC, 0, 
+               return run_rpc_command(NULL, PI_SRVSVC, 0, 
                                       rpc_share_list_internals,
                                       argc, argv);
 
@@ -1137,7 +1254,7 @@ static int rpc_file_usage(int argc, const char **argv)
 /** 
  * Close a file on a remote RPC server
  *
- * All paramaters are provided by the run_rpc_command function, except for
+ * All parameters are provided by the run_rpc_command function, except for
  * argc, argv which are passes through. 
  *
  * @param domain_sid The domain sid acquired from the remote server
@@ -1174,7 +1291,7 @@ static int rpc_file_close(int argc, const char **argv)
                return(rpc_file_usage(argc, argv));
        }
 
-       return run_rpc_command(PIPE_SRVSVC, 0, 
+       return run_rpc_command(NULL, PI_SRVSVC, 0, 
                               rpc_file_close_internals,
                               argc, argv);
 }
@@ -1200,7 +1317,7 @@ static void display_file_info_3(FILE_INFO_3 *info3, FILE_INFO_3_STR *str3)
 /** 
  * List open files on a remote RPC server
  *
- * All paramaters are provided by the run_rpc_command funcion, except for
+ * All parameters are provided by the run_rpc_command function, except for
  * argc, argv which are passes through. 
  *
  * @param domain_sid The domain sid acquired from the remote server
@@ -1227,7 +1344,7 @@ rpc_file_list_internals(const DOM_SID *domain_sid, struct cli_state *cli,
 
        /* if argc > 0, must be user command */
        if (argc > 0)
-               username = argv[0];
+               username = smb_xstrdup(argv[0]);
                
        result = cli_srvsvc_net_file_enum(
                cli, mem_ctx, 3, username, &ctr, preferred_len, &hnd);
@@ -1265,7 +1382,7 @@ static int rpc_file_user(int argc, const char **argv)
                return(rpc_file_usage(argc, argv));
        }
 
-       return run_rpc_command(PIPE_SRVSVC, 0, 
+       return run_rpc_command(NULL, PI_SRVSVC, 0, 
                               rpc_file_list_internals,
                               argc, argv);
 }
@@ -1290,7 +1407,7 @@ int net_rpc_file(int argc, const char **argv)
        };
 
        if (argc == 0)
-               return run_rpc_command(PIPE_SRVSVC, 0, 
+               return run_rpc_command(NULL, PI_SRVSVC, 0, 
                                       rpc_file_list_internals,
                                       argc, argv);
 
@@ -1304,7 +1421,7 @@ int net_rpc_file(int argc, const char **argv)
 /** 
  * ABORT the shutdown of a remote RPC Server
  *
- * All paramaters are provided by the run_rpc_command function, except for
+ * All parameters are provided by the run_rpc_command function, except for
  * argc, argv which are passed through. 
  *
  * @param domain_sid The domain sid aquired from the remote server
@@ -1345,14 +1462,14 @@ static NTSTATUS rpc_shutdown_abort_internals(const DOM_SID *domain_sid, struct c
 
 static int rpc_shutdown_abort(int argc, const char **argv) 
 {
-       return run_rpc_command(PIPE_WINREG, 0, rpc_shutdown_abort_internals,
+       return run_rpc_command(NULL, PI_WINREG, 0, rpc_shutdown_abort_internals,
                               argc, argv);
 }
 
 /** 
  * Shut down a remote RPC Server
  *
- * All paramaters are provided by the run_rpc_command funcion, except for
+ * All parameters are provided by the run_rpc_command function, except for
  * argc, argv which are passes through. 
  *
  * @param domain_sid The domain sid aquired from the remote server
@@ -1369,11 +1486,8 @@ static NTSTATUS rpc_shutdown_internals(const DOM_SID *domain_sid, struct cli_sta
                                       int argc, const char **argv) 
 {
        NTSTATUS result = NT_STATUS_UNSUCCESSFUL;
-        char *msg = "This machine will be shutdown shortly";
+        const char *msg = "This machine will be shutdown shortly";
        uint32 timeout = 20;
-       uint16 flgs = 0;
-       BOOL reboot = opt_reboot;
-       BOOL force = opt_force;
 #if 0
        poptContext pc;
        int rc;
@@ -1399,12 +1513,6 @@ static NTSTATUS rpc_shutdown_internals(const DOM_SID *domain_sid, struct cli_sta
                return NT_STATUS_INVALID_PARAMETER;
        }
 #endif
-       if (reboot) {
-               flgs |= REG_REBOOT_ON_SHUTDOWN;
-       }
-       if (force) {
-               flgs |= REG_FORCE_SHUTDOWN;
-       }
        if (opt_comment) {
                msg = opt_comment;
        }
@@ -1413,7 +1521,7 @@ static NTSTATUS rpc_shutdown_internals(const DOM_SID *domain_sid, struct cli_sta
        }
 
        /* create an entry */
-       result = cli_reg_shutdown(cli, mem_ctx, msg, timeout, flgs);
+       result = cli_reg_shutdown(cli, mem_ctx, msg, timeout, opt_reboot, opt_force);
 
        if (NT_STATUS_IS_OK(result))
                DEBUG(5,("Shutdown of remote machine succeeded\n"));
@@ -1435,7 +1543,7 @@ static NTSTATUS rpc_shutdown_internals(const DOM_SID *domain_sid, struct cli_sta
 
 static int rpc_shutdown(int argc, const char **argv) 
 {
-       return run_rpc_command(PIPE_WINREG, 0, rpc_shutdown_internals,
+       return run_rpc_command(NULL, PI_WINREG, 0, rpc_shutdown_internals,
                                       argc, argv);
 }
 
@@ -1460,7 +1568,7 @@ static int rpc_shutdown(int argc, const char **argv)
  */
 
 static NTSTATUS rpc_trustdom_add_internals(const DOM_SID *domain_sid, struct cli_state *cli, TALLOC_CTX *mem_ctx, 
-                                      int argc, const char **argv) {
+                                           int argc, const char **argv) {
 
        POLICY_HND connect_pol, domain_pol, user_pol;
        NTSTATUS result = NT_STATUS_UNSUCCESSFUL;
@@ -1483,16 +1591,14 @@ static NTSTATUS rpc_trustdom_add_internals(const DOM_SID *domain_sid, struct cli
 
        strupper(acct_name);
 
-       /* Get sam policy handle */
-       
-       result = cli_samr_connect(cli, mem_ctx, MAXIMUM_ALLOWED_ACCESS, 
+       /* Get samr policy handle */
+       result = cli_samr_connect(cli, mem_ctx, MAXIMUM_ALLOWED_ACCESS,
                                  &connect_pol);
        if (!NT_STATUS_IS_OK(result)) {
                goto done;
        }
        
        /* Get domain policy handle */
-       
        result = cli_samr_open_domain(cli, mem_ctx, &connect_pol,
                                      MAXIMUM_ALLOWED_ACCESS,
                                      domain_sid, &domain_pol);
@@ -1501,10 +1607,9 @@ static NTSTATUS rpc_trustdom_add_internals(const DOM_SID *domain_sid, struct cli
        }
 
        /* Create trusting domain's account */
-
        acb_info = ACB_DOMTRUST;
-       unknown = 0xe005000b; /* No idea what this is - a permission mask? 
-                                Is it needed for interdomain account also ? */
+       unknown = 0xe005000b; /* No idea what this is - a permission mask?
+                                mimir: yes, most probably it is */
 
        result = cli_samr_create_dom_user(cli, mem_ctx, &domain_pol,
                                          acct_name, acb_info, unknown,
@@ -1529,7 +1634,7 @@ static NTSTATUS rpc_trustdom_add_internals(const DOM_SID *domain_sid, struct cli
 
 static int rpc_trustdom_add(int argc, const char **argv)
 {
-       return run_rpc_command(PIPE_SAMR, 0, rpc_trustdom_add_internals,
+       return run_rpc_command(NULL, PI_SAMR, 0, rpc_trustdom_add_internals,
                               argc, argv);
 }
 
@@ -1560,11 +1665,8 @@ static int rpc_trustdom_del(int argc, const char **argv)
  * @return Integer status (0 means success)
  **/
 
-extern char *opt_user_name;
-extern char *opt_password;
-
-static int rpc_trustdom_establish(int argc, const char **argv) {
-
+static int rpc_trustdom_establish(int argc, const char **argv)
+{
        struct cli_state *cli;
        struct in_addr server_ip;
        POLICY_HND connect_hnd;
@@ -1582,19 +1684,26 @@ static int rpc_trustdom_establish(int argc, const char **argv) {
         */
 
        if (argc != 1) {
-               d_printf("Usage: net rpc trustdom add <domain_name>\n");
+               d_printf("Usage: net rpc trustdom establish <domain_name>\n");
                return -1;
        }
 
-
        domain_name = smb_xstrdup(argv[0]);
        strupper(domain_name);
-       
+
+       /* account name used at first is our domain's name with '$' */
        asprintf(&acct_name, "%s$", lp_workgroup());
        strupper(acct_name);
        
-       opt_user_name = (char*)malloc(strlen(acct_name) + 1);
-       safe_strcpy(opt_user_name, acct_name, strlen(acct_name) + 1);
+       /*
+        * opt_workgroup will be used by connection functions further,
+        * hence it should be set to remote domain name instead of ours
+        */
+       if (opt_workgroup) {
+               opt_workgroup = smb_xstrdup(domain_name);
+       };
+       
+       opt_user_name = acct_name;
 
        /* find the domain controller */
        if (!net_find_dc(&server_ip, pdc_name, domain_name)) {
@@ -1634,23 +1743,16 @@ static int rpc_trustdom_establish(int argc, const char **argv) {
         
        /*
         * Call WksQueryInfo to check remote server's capabilities
-        * FIXME:Is really necessary ? nt serv does this, but from samba's
-        *       point of view it doesn't seem to make the difference
-        * IDEA: It may be used to get info about type of pdc we're talking to
-        *       (e.g. WinNT or Win2k)
+        * note: It is now used only to get unicode domain name
         */
        
-       if (!cli_nt_session_open(cli, PIPE_WKSSVC)) {
+       if (!cli_nt_session_open(cli, PI_WKSSVC)) {
                DEBUG(0, ("Couldn't not initialise wkssvc pipe\n"));
                return -1;
        }
 
-       /* TODO: convert this call from rpc_client/cli_wkssvc.c
-          to cli_wks_query_info() in libsmb/cli_wkssvc.c
-          UPDATE: already done :)
-       */
-
-       if (!(mem_ctx = talloc_init())) {
+       if (!(mem_ctx = talloc_init("establishing trust relationship to domain %s",
+                       domain_name))) {
                DEBUG(0, ("talloc_init() failed\n"));
                cli_shutdown(cli);
                return -1;
@@ -1671,18 +1773,20 @@ static int rpc_trustdom_establish(int argc, const char **argv) {
         * Call LsaOpenPolicy and LsaQueryInfo
         */
         
-       if (!(mem_ctx = talloc_init())) {
+       if (!(mem_ctx = talloc_init("rpc_trustdom_establish"))) {
                DEBUG(0, ("talloc_init() failed\n"));
                cli_shutdown(cli);
                return -1;
        }
 
-       if (!cli_nt_session_open(cli, PIPE_LSARPC)) {
+       if (!cli_nt_session_open(cli, PI_LSARPC)) {
                DEBUG(0, ("Could not initialise lsa pipe\n"));
+               cli_shutdown(cli);
+               return -1;
        }
 
        nt_status = cli_lsa_open_policy2(cli, mem_ctx, True, SEC_RIGHTS_QUERY_VALUE,
-                                       &connect_hnd);
+                                        &connect_hnd);
        if (NT_STATUS_IS_ERR(nt_status)) {
                DEBUG(0, ("Couldn't open policy handle. Error was %s\n",
                        nt_errstr(nt_status)));
@@ -1692,7 +1796,8 @@ static int rpc_trustdom_establish(int argc, const char **argv) {
        /* Querying info level 5 */
        
        nt_status = cli_lsa_query_info_policy(cli, mem_ctx, &connect_hnd,
-                                       5 /* info level */, domain_name, &domain_sid);
+                                             5 /* info level */, domain_name,
+                                             &domain_sid);
        if (NT_STATUS_IS_ERR(nt_status)) {
                DEBUG(0, ("LSA Query Info failed. Returned error was %s\n",
                        nt_errstr(nt_status)));
@@ -1700,6 +1805,8 @@ static int rpc_trustdom_establish(int argc, const char **argv) {
        }
 
 
+
+
        /* There should be actually query info level 3 (following nt serv behaviour),
           but I still don't know if it's _really_ necessary */
                        
@@ -1743,8 +1850,8 @@ static int rpc_trustdom_establish(int argc, const char **argv) {
  * @return Integer status (0 means success)
  **/
 
-static int rpc_trustdom_revoke(int argc, const char **argv) {
-
+static int rpc_trustdom_revoke(int argc, const char **argv)
+{
        char* domain_name;
 
        if (argc < 1) return -1;
@@ -1772,7 +1879,8 @@ static int rpc_trustdom_revoke(int argc, const char **argv) {
  * @return Integer status returned to shell
  **/
  
-static int rpc_trustdom_usage(int argc, const char **argv) {
+static int rpc_trustdom_usage(int argc, const char **argv)
+{
        d_printf("  net rpc trustdom add \t\t add trusting domain's account\n");
        d_printf("  net rpc trustdom del \t\t delete trusting domain's account\n");
        d_printf("  net rpc trustdom establish \t establish relationship to trusted domain\n");
@@ -1782,6 +1890,251 @@ static int rpc_trustdom_usage(int argc, const char **argv) {
 }
 
 
+static NTSTATUS rpc_query_domain_sid(const DOM_SID *domain_sid, struct cli_state *cli, TALLOC_CTX *mem_ctx,
+                              int argc, const char **argv)
+{
+       fstring str_sid;
+       sid_to_string(str_sid, domain_sid);
+       d_printf("%s\n", str_sid);
+       return NT_STATUS_OK;
+};
+
+
+static int rpc_trustdom_list(int argc, const char **argv)
+{
+       /* common variables */
+       TALLOC_CTX* mem_ctx;
+       struct cli_state *cli, *remote_cli;
+       NTSTATUS nt_status;
+       const char *domain_name = NULL;
+       DOM_SID queried_dom_sid;
+       fstring ascii_sid, padding;
+       int ascii_dom_name_len;
+       POLICY_HND connect_hnd;
+       
+       /* trusted domains listing variables */
+       int enum_ctx = 0;
+       int num_domains, i, pad_len, col_len = 20;
+       DOM_SID *domain_sids;
+       char **trusted_dom_names;
+       fstring pdc_name, dummy;
+       
+       /* trusting domains listing variables */
+       POLICY_HND domain_hnd;
+       char **trusting_dom_names;
+       uint32 *trusting_dom_rids;
+       
+       /*
+        * Listing trusted domains (stored in secrets.tdb, if local)
+        */
+
+       mem_ctx = talloc_init("trust relationships listing");
+
+       /*
+        * set domain and pdc name to local samba server (default)
+        * or to remote one given in command line
+        */
+       
+       if (StrCaseCmp(opt_workgroup, lp_workgroup())) {
+               domain_name = opt_workgroup;
+               opt_target_workgroup = opt_workgroup;
+       } else {
+               fstrcpy(pdc_name, global_myname());
+               domain_name = talloc_strdup(mem_ctx, lp_workgroup());
+               opt_target_workgroup = domain_name;
+       };
+
+       /* open \PIPE\lsarpc and open policy handle */
+       if (!(cli = net_make_ipc_connection(NET_FLAGS_PDC))) {
+               DEBUG(0, ("Couldn't connect to domain controller\n"));
+               return -1;
+       };
+
+       if (!cli_nt_session_open(cli, PI_LSARPC)) {
+               DEBUG(0, ("Could not initialise lsa pipe\n"));
+               return -1;
+       };
+
+       nt_status = cli_lsa_open_policy2(cli, mem_ctx, True, SEC_RIGHTS_QUERY_VALUE,
+                                       &connect_hnd);
+       if (NT_STATUS_IS_ERR(nt_status)) {
+               DEBUG(0, ("Couldn't open policy handle. Error was %s\n",
+                       nt_errstr(nt_status)));
+               return -1;
+       };
+       
+       /* query info level 5 to obtain sid of a domain being queried */
+       nt_status = cli_lsa_query_info_policy(
+               cli, mem_ctx, &connect_hnd, 5 /* info level */, 
+               dummy, &queried_dom_sid);
+
+       if (NT_STATUS_IS_ERR(nt_status)) {
+               DEBUG(0, ("LSA Query Info failed. Returned error was %s\n",
+                       nt_errstr(nt_status)));
+               return -1;
+       }
+               
+       /*
+        * Keep calling LsaEnumTrustdom over opened pipe until
+        * the end of enumeration is reached
+        */
+        
+       d_printf("Trusted domains list:\n\n");
+
+       do {
+               nt_status = cli_lsa_enum_trust_dom(cli, mem_ctx, &connect_hnd, &enum_ctx,
+                                                  &num_domains,
+                                                  &trusted_dom_names, &domain_sids);
+               
+               if (NT_STATUS_IS_ERR(nt_status)) {
+                       DEBUG(0, ("Couldn't enumerate trusted domains. Error was %s\n",
+                               nt_errstr(nt_status)));
+                       return -1;
+               };
+               
+               for (i = 0; i < num_domains; i++) {
+                       /* convert sid into ascii string */
+                       sid_to_string(ascii_sid, &(domain_sids[i]));
+               
+                       /* calculate padding space for d_printf to look nicer */
+                       pad_len = col_len - strlen(trusted_dom_names[i]);
+                       padding[pad_len] = 0;
+                       do padding[--pad_len] = ' '; while (pad_len);
+                       
+                       d_printf("%s%s%s\n", trusted_dom_names[i], padding, ascii_sid);
+               };
+               
+               /*
+                * in case of no trusted domains say something rather
+                * than just display blank line
+                */
+               if (!num_domains) d_printf("none\n");
+
+       } while (NT_STATUS_EQUAL(nt_status, STATUS_MORE_ENTRIES));
+
+       /* close this connection before doing next one */
+       nt_status = cli_lsa_close(cli, mem_ctx, &connect_hnd);
+       if (NT_STATUS_IS_ERR(nt_status)) {
+               DEBUG(0, ("Couldn't properly close lsa policy handle. Error was %s\n",
+                       nt_errstr(nt_status)));
+               return -1;
+       };
+       
+       cli_nt_session_close(cli);
+
+       /*
+        * Listing trusting domains (stored in passdb backend, if local)
+        */
+       
+       d_printf("\nTrusting domains list:\n\n");
+
+       /*
+        * Open \PIPE\samr and get needed policy handles
+        */
+       if (!cli_nt_session_open(cli, PI_SAMR)) {
+               DEBUG(0, ("Could not initialise samr pipe\n"));
+               return -1;
+       };
+       
+       /* SamrConnect */
+       nt_status = cli_samr_connect(cli, mem_ctx, SA_RIGHT_SAM_OPEN_DOMAIN,
+                                                                &connect_hnd);
+       if (!NT_STATUS_IS_OK(nt_status)) {
+               DEBUG(0, ("Couldn't open SAMR policy handle. Error was %s\n",
+                       nt_errstr(nt_status)));
+               return -1;
+       };
+       
+       /* SamrOpenDomain - we have to open domain policy handle in order to be
+          able to enumerate accounts*/
+       nt_status = cli_samr_open_domain(cli, mem_ctx, &connect_hnd,
+                                                                        SA_RIGHT_DOMAIN_ENUM_ACCOUNTS,
+                                                                        &queried_dom_sid, &domain_hnd);                                                                         
+       if (!NT_STATUS_IS_OK(nt_status)) {
+               DEBUG(0, ("Couldn't open domain object. Error was %s\n",
+                       nt_errstr(nt_status)));
+               return -1;
+       };
+       
+       /*
+        * perform actual enumeration
+        */
+        
+       enum_ctx = 0;   /* reset enumeration context from last enumeration */
+       do {
+                       
+               nt_status = cli_samr_enum_dom_users(cli, mem_ctx, &domain_hnd,
+                                                   &enum_ctx, ACB_DOMTRUST, 0xffff,
+                                                   &trusting_dom_names, &trusting_dom_rids,
+                                                   &num_domains);
+               if (NT_STATUS_IS_ERR(nt_status)) {
+                       DEBUG(0, ("Couldn't enumerate accounts. Error was: %s\n",
+                               nt_errstr(nt_status)));
+                       return -1;
+               };
+               
+               for (i = 0; i < num_domains; i++) {
+
+                       /*
+                        * get each single domain's sid (do we _really_ need this ?):
+                        *  1) connect to domain's pdc
+                        *  2) query the pdc for domain's sid
+                        */
+
+                       /* get rid of '$' tail */
+                       ascii_dom_name_len = strlen(trusting_dom_names[i]);
+                       if (ascii_dom_name_len && ascii_dom_name_len < FSTRING_LEN)
+                               trusting_dom_names[i][ascii_dom_name_len - 1] = '\0';
+                       
+                       /* calculate padding space for d_printf to look nicer */
+                       pad_len = col_len - strlen(trusting_dom_names[i]);
+                       padding[pad_len] = 0;
+                       do padding[--pad_len] = ' '; while (pad_len);
+
+                       /* set opt_* variables to remote domain */
+                       strupper(trusting_dom_names[i]);
+                       opt_workgroup = talloc_strdup(mem_ctx, trusting_dom_names[i]);
+                       opt_target_workgroup = opt_workgroup;
+                       
+                       d_printf("%s%s", trusting_dom_names[i], padding);
+                       
+                       /* connect to remote domain controller */
+                       remote_cli = net_make_ipc_connection(NET_FLAGS_PDC | NET_FLAGS_ANONYMOUS);
+                       if (remote_cli) {                       
+                               /* query for domain's sid */
+                               if (run_rpc_command(remote_cli, PI_LSARPC, 0, rpc_query_domain_sid, argc, argv))
+                                       d_printf("couldn't get domain's sid\n");
+
+                               cli_shutdown(remote_cli);
+                       
+                       } else {
+                               d_printf("domain controller is not responding\n");
+                       };
+               };
+               
+               if (!num_domains) d_printf("none\n");
+               
+       } while (NT_STATUS_EQUAL(nt_status, STATUS_MORE_ENTRIES));
+
+       /* close opened samr and domain policy handles */
+       nt_status = cli_samr_close(cli, mem_ctx, &domain_hnd);
+       if (!NT_STATUS_IS_OK(nt_status)) {
+               DEBUG(0, ("Couldn't properly close domain policy handle for domain %s\n", domain_name));
+       };
+       
+       nt_status = cli_samr_close(cli, mem_ctx, &connect_hnd);
+       if (!NT_STATUS_IS_OK(nt_status)) {
+               DEBUG(0, ("Couldn't properly close samr policy handle for domain %s\n", domain_name));
+       };
+       
+       /* close samr pipe and connection to IPC$ */
+       cli_nt_session_close(cli);
+       cli_shutdown(cli);
+
+       talloc_destroy(mem_ctx);         
+       return 0;
+}
+
 /**
  * Entrypoint for 'net rpc trustdom' code
  *
@@ -1799,6 +2152,7 @@ static int rpc_trustdom(int argc, const char **argv)
                {"establish", rpc_trustdom_establish},
                {"revoke", rpc_trustdom_revoke},
                {"help", rpc_trustdom_usage},
+               {"list", rpc_trustdom_list},
                {NULL, NULL}
        };
 
@@ -1825,7 +2179,7 @@ BOOL net_rpc_check(unsigned flags)
 
        /* flags (i.e. server type) may depend on command */
        if (!net_find_server(flags, &server_ip, &server_name))
-               goto done;
+               return False;
 
        ZERO_STRUCT(cli);
        if (cli_initialise(&cli) == False)
@@ -1833,7 +2187,7 @@ BOOL net_rpc_check(unsigned flags)
 
        if (!cli_connect(&cli, server_name, &server_ip))
                goto done;
-       if (!attempt_netbios_session_request(&cli, global_myname, 
+       if (!attempt_netbios_session_request(&cli, global_myname()
                                             server_name, &server_ip))
                goto done;
        if (!cli_negprot(&cli))
@@ -1862,11 +2216,16 @@ int net_rpc_usage(int argc, const char **argv)
 {
        d_printf("  net rpc info \t\t\tshow basic info about a domain \n");
        d_printf("  net rpc join \t\t\tto join a domain \n");
+       d_printf("  net rpc oldjoin \t\t\tto join a domain created in server manager\n\n\n");
+       d_printf("  net rpc testjoin \t\ttests that a join is valid\n");
        d_printf("  net rpc user \t\t\tto add, delete and list users\n");
        d_printf("  net rpc group \t\tto list groups\n");
        d_printf("  net rpc share \t\tto add, delete, and list shares\n");
        d_printf("  net rpc file \t\t\tto list open files\n");
        d_printf("  net rpc changetrustpw \tto change the trust account password\n");
+       d_printf("  net rpc getsid \t\tfetch the domain sid into the local secrets.tdb\n");
+       d_printf("  net rpc vampire \t\tsyncronise an NT PDC's users and groups into the local passdb\n");
+       d_printf("  net rpc samdump \t\tdiplay an NT PDC's users, groups and other data\n");
        d_printf("  net rpc trustdom \t\tto create trusting domain's account\n"
                 "\t\t\t\t\tor establish trust\n");
        d_printf("  net rpc abortshutdown \tto abort the shutdown of a remote server\n");
@@ -1924,14 +2283,19 @@ int net_rpc(int argc, const char **argv)
        struct functable func[] = {
                {"info", net_rpc_info},
                {"join", net_rpc_join},
+               {"oldjoin", net_rpc_oldjoin},
+               {"testjoin", net_rpc_testjoin},
                {"user", net_rpc_user},
                {"group", net_rpc_group},
                {"share", net_rpc_share},
                {"file", net_rpc_file},
-               {"changetrustpw", rpc_changetrustpw},
+               {"changetrustpw", net_rpc_changetrustpw},
                {"trustdom", rpc_trustdom},
                {"abortshutdown", rpc_shutdown_abort},
                {"shutdown", rpc_shutdown},
+               {"samdump", rpc_samdump},
+               {"vampire", rpc_vampire},
+               {"getsid", net_rpc_getsid},
                {"help", net_rpc_help},
                {NULL, NULL}
        };