233255fed4fe8c075fab08203a5c22681697dff7
[jra/samba/.git] / source3 / lib / netapi / cm.c
1 /*
2  *  Unix SMB/CIFS implementation.
3  *  NetApi Support
4  *  Copyright (C) Guenther Deschner 2008
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
22 #include "lib/netapi/netapi.h"
23 #include "lib/netapi/netapi_private.h"
24
25 /********************************************************************
26 ********************************************************************/
27
28 static WERROR libnetapi_open_ipc_connection(struct libnetapi_ctx *ctx,
29                                             const char *server_name,
30                                             struct cli_state **cli)
31 {
32         struct cli_state *cli_ipc = NULL;
33
34         if (!ctx || !cli || !server_name) {
35                 return WERR_INVALID_PARAM;
36         }
37
38         cli_cm_set_signing_state(Undefined);
39
40         if (ctx->use_kerberos) {
41                 cli_cm_set_use_kerberos();
42         }
43
44         if (ctx->password) {
45                 cli_cm_set_password(ctx->password);
46         }
47         if (ctx->username) {
48                 cli_cm_set_username(ctx->username);
49         }
50
51         if (ctx->username && ctx->username[0] &&
52             ctx->password && ctx->password[0] &&
53             ctx->use_kerberos) {
54                 cli_cm_set_fallback_after_kerberos();
55         }
56
57         cli_ipc = cli_cm_open(ctx, NULL,
58                               server_name, "IPC$",
59                               false, false,
60                               PROTOCOL_NT1,
61                               0, 0x20);
62         if (!cli_ipc) {
63                 libnetapi_set_error_string(ctx,
64                         "Failed to connect to IPC$ share on %s", server_name);
65                 return WERR_CAN_NOT_COMPLETE;
66         }
67
68         *cli = cli_ipc;
69
70         return WERR_OK;
71 }
72
73 /********************************************************************
74 ********************************************************************/
75
76 WERROR libnetapi_shutdown_cm(struct libnetapi_ctx *ctx)
77 {
78         cli_cm_shutdown();
79
80         return WERR_OK;
81 }
82
83 /********************************************************************
84 ********************************************************************/
85
86 struct client_pipe_connection {
87         struct client_pipe_connection *prev, *next;
88         struct rpc_pipe_client *pipe;
89 };
90
91 static struct client_pipe_connection *pipe_connections;
92
93 /********************************************************************
94 ********************************************************************/
95
96 static NTSTATUS pipe_cm_find(struct cli_state *cli,
97                              const struct ndr_syntax_id *interface,
98                              struct rpc_pipe_client **presult)
99 {
100         struct client_pipe_connection *p;
101
102         for (p = pipe_connections; p; p = p->next) {
103
104                 if (!rpc_pipe_np_smb_conn(p->pipe)) {
105                         return NT_STATUS_PIPE_EMPTY;
106                 }
107
108                 if (strequal(cli->desthost, p->pipe->desthost)
109                     && ndr_syntax_id_equal(&p->pipe->abstract_syntax,
110                                            interface)) {
111                         *presult = p->pipe;
112                         return NT_STATUS_OK;
113                 }
114         }
115
116         return NT_STATUS_PIPE_NOT_AVAILABLE;
117 }
118
119 /********************************************************************
120 ********************************************************************/
121
122 static NTSTATUS pipe_cm_connect(TALLOC_CTX *mem_ctx,
123                                 struct cli_state *cli,
124                                 const struct ndr_syntax_id *interface,
125                                 struct rpc_pipe_client **presult)
126 {
127         struct client_pipe_connection *p;
128         NTSTATUS status;
129
130         p = TALLOC_ZERO_ARRAY(mem_ctx, struct client_pipe_connection, 1);
131         if (!p) {
132                 return NT_STATUS_NO_MEMORY;
133         }
134
135         status = cli_rpc_pipe_open_noauth(cli, interface, &p->pipe);
136         if (!NT_STATUS_IS_OK(status)) {
137                 TALLOC_FREE(p);
138                 return status;
139         }
140
141         DLIST_ADD(pipe_connections, p);
142
143         *presult = p->pipe;
144         return NT_STATUS_OK;
145 }
146
147 /********************************************************************
148 ********************************************************************/
149
150 static NTSTATUS pipe_cm_open(TALLOC_CTX *ctx,
151                              struct cli_state *cli,
152                              const struct ndr_syntax_id *interface,
153                              struct rpc_pipe_client **presult)
154 {
155         if (NT_STATUS_IS_OK(pipe_cm_find(cli, interface, presult))) {
156                 return NT_STATUS_OK;
157         }
158
159         return pipe_cm_connect(ctx, cli, interface, presult);
160 }
161
162 /********************************************************************
163 ********************************************************************/
164
165 WERROR libnetapi_open_pipe(struct libnetapi_ctx *ctx,
166                            const char *server_name,
167                            const struct ndr_syntax_id *interface,
168                            struct rpc_pipe_client **presult)
169 {
170         struct rpc_pipe_client *result = NULL;
171         NTSTATUS status;
172         WERROR werr;
173         struct cli_state *cli = NULL;
174
175         if (!presult) {
176                 return WERR_INVALID_PARAM;
177         }
178
179         werr = libnetapi_open_ipc_connection(ctx, server_name, &cli);
180         if (!W_ERROR_IS_OK(werr)) {
181                 return werr;
182         }
183
184         status = pipe_cm_open(ctx, cli, interface, &result);
185         if (!NT_STATUS_IS_OK(status)) {
186                 libnetapi_set_error_string(ctx, "failed to open PIPE %s: %s",
187                         get_pipe_name_from_iface(interface),
188                         get_friendly_nt_error_msg(status));
189                 return WERR_DEST_NOT_FOUND;
190         }
191
192         *presult = result;
193
194         return WERR_OK;
195 }
196
197