fetch.c revision 1.110 1 1.110 lukem /* $NetBSD: fetch.c,v 1.110 2000/05/01 09:44:54 lukem Exp $ */
2 1.1 lukem
3 1.1 lukem /*-
4 1.110 lukem * Copyright (c) 1997-2000 The NetBSD Foundation, Inc.
5 1.1 lukem * All rights reserved.
6 1.1 lukem *
7 1.1 lukem * This code is derived from software contributed to The NetBSD Foundation
8 1.54 lukem * by Luke Mewburn.
9 1.1 lukem *
10 1.1 lukem * Redistribution and use in source and binary forms, with or without
11 1.1 lukem * modification, are permitted provided that the following conditions
12 1.1 lukem * are met:
13 1.1 lukem * 1. Redistributions of source code must retain the above copyright
14 1.1 lukem * notice, this list of conditions and the following disclaimer.
15 1.1 lukem * 2. Redistributions in binary form must reproduce the above copyright
16 1.1 lukem * notice, this list of conditions and the following disclaimer in the
17 1.1 lukem * documentation and/or other materials provided with the distribution.
18 1.1 lukem * 3. All advertising materials mentioning features or use of this software
19 1.1 lukem * must display the following acknowledgement:
20 1.84 lukem * This product includes software developed by the NetBSD
21 1.84 lukem * Foundation, Inc. and its contributors.
22 1.1 lukem * 4. Neither the name of The NetBSD Foundation nor the names of its
23 1.1 lukem * contributors may be used to endorse or promote products derived
24 1.1 lukem * from this software without specific prior written permission.
25 1.1 lukem *
26 1.1 lukem * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
27 1.1 lukem * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
28 1.1 lukem * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
29 1.14 lukem * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
30 1.14 lukem * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
31 1.1 lukem * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
32 1.1 lukem * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
33 1.1 lukem * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
34 1.1 lukem * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
35 1.1 lukem * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
36 1.1 lukem * POSSIBILITY OF SUCH DAMAGE.
37 1.1 lukem */
38 1.1 lukem
39 1.12 lukem #include <sys/cdefs.h>
40 1.1 lukem #ifndef lint
41 1.110 lukem __RCSID("$NetBSD: fetch.c,v 1.110 2000/05/01 09:44:54 lukem Exp $");
42 1.1 lukem #endif /* not lint */
43 1.1 lukem
44 1.1 lukem /*
45 1.1 lukem * FTP User Program -- Command line file retrieval
46 1.1 lukem */
47 1.1 lukem
48 1.1 lukem #include <sys/types.h>
49 1.1 lukem #include <sys/param.h>
50 1.1 lukem #include <sys/socket.h>
51 1.30 lukem #include <sys/stat.h>
52 1.32 lukem #include <sys/time.h>
53 1.1 lukem
54 1.1 lukem #include <netinet/in.h>
55 1.1 lukem
56 1.2 lukem #include <arpa/ftp.h>
57 1.1 lukem #include <arpa/inet.h>
58 1.1 lukem
59 1.1 lukem #include <ctype.h>
60 1.1 lukem #include <err.h>
61 1.22 lukem #include <errno.h>
62 1.1 lukem #include <netdb.h>
63 1.1 lukem #include <fcntl.h>
64 1.1 lukem #include <stdio.h>
65 1.1 lukem #include <stdlib.h>
66 1.1 lukem #include <string.h>
67 1.1 lukem #include <unistd.h>
68 1.57 christos #include <time.h>
69 1.24 lukem #include <util.h>
70 1.1 lukem
71 1.1 lukem #include "ftp_var.h"
72 1.100 lukem #include "version.h"
73 1.1 lukem
74 1.27 lukem typedef enum {
75 1.27 lukem UNKNOWN_URL_T=-1,
76 1.27 lukem HTTP_URL_T,
77 1.27 lukem FTP_URL_T,
78 1.53 lukem FILE_URL_T,
79 1.53 lukem CLASSIC_URL_T
80 1.27 lukem } url_t;
81 1.27 lukem
82 1.96 lukem void aborthttp __P((int));
83 1.54 lukem static int auth_url __P((const char *, char **, const char *,
84 1.54 lukem const char *));
85 1.50 lukem static void base64_encode __P((const char *, size_t, char *));
86 1.52 lukem static int go_fetch __P((const char *));
87 1.52 lukem static int fetch_ftp __P((const char *));
88 1.52 lukem static int fetch_url __P((const char *, const char *, char *, char *));
89 1.27 lukem static int parse_url __P((const char *, const char *, url_t *, char **,
90 1.82 lukem char **, char **, char **, in_port_t *,
91 1.82 lukem char **));
92 1.50 lukem static void url_decode __P((char *));
93 1.12 lukem
94 1.42 lukem static int redirect_loop;
95 1.42 lukem
96 1.12 lukem
97 1.25 lukem #define ABOUT_URL "about:" /* propaganda */
98 1.25 lukem #define FILE_URL "file://" /* file URL prefix */
99 1.1 lukem #define FTP_URL "ftp://" /* ftp URL prefix */
100 1.1 lukem #define HTTP_URL "http://" /* http URL prefix */
101 1.1 lukem
102 1.1 lukem
103 1.27 lukem /*
104 1.44 lukem * Generate authorization response based on given authentication challenge.
105 1.44 lukem * Returns -1 if an error occurred, otherwise 0.
106 1.44 lukem * Sets response to a malloc(3)ed string; caller should free.
107 1.44 lukem */
108 1.44 lukem static int
109 1.54 lukem auth_url(challenge, response, guser, gpass)
110 1.44 lukem const char *challenge;
111 1.44 lukem char **response;
112 1.54 lukem const char *guser;
113 1.54 lukem const char *gpass;
114 1.44 lukem {
115 1.44 lukem char *cp, *ep, *clear, *line, *realm, *scheme;
116 1.82 lukem char user[BUFSIZ], *pass;
117 1.82 lukem int rval;
118 1.82 lukem size_t len, clen, rlen;
119 1.44 lukem
120 1.44 lukem *response = NULL;
121 1.44 lukem clear = realm = scheme = NULL;
122 1.44 lukem rval = -1;
123 1.44 lukem line = xstrdup(challenge);
124 1.44 lukem cp = line;
125 1.44 lukem
126 1.44 lukem if (debug)
127 1.44 lukem fprintf(ttyout, "auth_url: challenge `%s'\n", challenge);
128 1.44 lukem
129 1.44 lukem scheme = strsep(&cp, " ");
130 1.91 lukem #define SCHEME_BASIC "Basic"
131 1.44 lukem if (strncasecmp(scheme, SCHEME_BASIC, sizeof(SCHEME_BASIC) - 1) != 0) {
132 1.44 lukem warnx("Unsupported WWW Authentication challenge - `%s'",
133 1.44 lukem challenge);
134 1.44 lukem goto cleanup_auth_url;
135 1.44 lukem }
136 1.44 lukem cp += strspn(cp, " ");
137 1.44 lukem
138 1.91 lukem #define REALM "realm=\""
139 1.44 lukem if (strncasecmp(cp, REALM, sizeof(REALM) - 1) == 0)
140 1.44 lukem cp += sizeof(REALM) - 1;
141 1.44 lukem else {
142 1.44 lukem warnx("Unsupported WWW Authentication challenge - `%s'",
143 1.44 lukem challenge);
144 1.44 lukem goto cleanup_auth_url;
145 1.44 lukem }
146 1.44 lukem if ((ep = strchr(cp, '\"')) != NULL) {
147 1.44 lukem size_t len = ep - cp;
148 1.44 lukem
149 1.44 lukem realm = (char *)xmalloc(len + 1);
150 1.78 lukem (void)strlcpy(realm, cp, len + 1);
151 1.44 lukem } else {
152 1.44 lukem warnx("Unsupported WWW Authentication challenge - `%s'",
153 1.44 lukem challenge);
154 1.44 lukem goto cleanup_auth_url;
155 1.44 lukem }
156 1.44 lukem
157 1.78 lukem if (guser != NULL)
158 1.78 lukem (void)strlcpy(user, guser, sizeof(user));
159 1.78 lukem else {
160 1.54 lukem fprintf(ttyout, "Username for `%s': ", realm);
161 1.54 lukem (void)fflush(ttyout);
162 1.90 lukem if (fgets(user, sizeof(user) - 1, stdin) == NULL) {
163 1.90 lukem clearerr(stdin);
164 1.54 lukem goto cleanup_auth_url;
165 1.90 lukem }
166 1.54 lukem user[strlen(user) - 1] = '\0';
167 1.54 lukem }
168 1.54 lukem if (gpass != NULL)
169 1.54 lukem pass = (char *)gpass;
170 1.54 lukem else
171 1.54 lukem pass = getpass("Password: ");
172 1.44 lukem
173 1.72 lukem clen = strlen(user) + strlen(pass) + 2; /* user + ":" + pass + "\0" */
174 1.72 lukem clear = (char *)xmalloc(clen);
175 1.78 lukem (void)strlcpy(clear, user, clen);
176 1.78 lukem (void)strlcat(clear, ":", clen);
177 1.78 lukem (void)strlcat(clear, pass, clen);
178 1.54 lukem if (gpass == NULL)
179 1.80 lukem memset(pass, 0, strlen(pass));
180 1.44 lukem
181 1.64 lukem /* scheme + " " + enc + "\0" */
182 1.74 lukem rlen = strlen(scheme) + 1 + (clen + 2) * 4 / 3 + 1;
183 1.72 lukem *response = (char *)xmalloc(rlen);
184 1.78 lukem (void)strlcpy(*response, scheme, rlen);
185 1.72 lukem len = strlcat(*response, " ", rlen);
186 1.72 lukem base64_encode(clear, clen, *response + len);
187 1.80 lukem memset(clear, 0, clen);
188 1.44 lukem rval = 0;
189 1.44 lukem
190 1.44 lukem cleanup_auth_url:
191 1.44 lukem FREEPTR(clear);
192 1.44 lukem FREEPTR(line);
193 1.44 lukem FREEPTR(realm);
194 1.44 lukem return (rval);
195 1.44 lukem }
196 1.44 lukem
197 1.44 lukem /*
198 1.44 lukem * Encode len bytes starting at clear using base64 encoding into encoded,
199 1.44 lukem * which should be at least ((len + 2) * 4 / 3 + 1) in size.
200 1.44 lukem */
201 1.44 lukem void
202 1.50 lukem base64_encode(clear, len, encoded)
203 1.44 lukem const char *clear;
204 1.44 lukem size_t len;
205 1.44 lukem char *encoded;
206 1.44 lukem {
207 1.44 lukem static const char enc[] =
208 1.44 lukem "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";
209 1.82 lukem char *cp;
210 1.82 lukem int i;
211 1.44 lukem
212 1.44 lukem cp = encoded;
213 1.44 lukem for (i = 0; i < len; i += 3) {
214 1.44 lukem *(cp++) = enc[((clear[i + 0] >> 2))];
215 1.44 lukem *(cp++) = enc[((clear[i + 0] << 4) & 0x30)
216 1.44 lukem | ((clear[i + 1] >> 4) & 0x0f)];
217 1.44 lukem *(cp++) = enc[((clear[i + 1] << 2) & 0x3c)
218 1.44 lukem | ((clear[i + 2] >> 6) & 0x03)];
219 1.44 lukem *(cp++) = enc[((clear[i + 2] ) & 0x3f)];
220 1.44 lukem }
221 1.44 lukem *cp = '\0';
222 1.44 lukem while (i-- > len)
223 1.44 lukem *(--cp) = '=';
224 1.44 lukem }
225 1.44 lukem
226 1.50 lukem /*
227 1.50 lukem * Decode %xx escapes in given string, `in-place'.
228 1.50 lukem */
229 1.50 lukem static void
230 1.50 lukem url_decode(url)
231 1.50 lukem char *url;
232 1.50 lukem {
233 1.50 lukem unsigned char *p, *q;
234 1.50 lukem
235 1.50 lukem if (EMPTYSTRING(url))
236 1.50 lukem return;
237 1.75 lukem p = q = (unsigned char *)url;
238 1.50 lukem
239 1.91 lukem #define HEXTOINT(x) (x - (isdigit(x) ? '0' : (islower(x) ? 'a' : 'A') - 10))
240 1.50 lukem while (*p) {
241 1.50 lukem if (p[0] == '%'
242 1.50 lukem && p[1] && isxdigit((unsigned char)p[1])
243 1.50 lukem && p[2] && isxdigit((unsigned char)p[2])) {
244 1.50 lukem *q++ = HEXTOINT(p[1]) * 16 + HEXTOINT(p[2]);
245 1.50 lukem p+=3;
246 1.50 lukem } else
247 1.50 lukem *q++ = *p++;
248 1.50 lukem }
249 1.50 lukem *q = '\0';
250 1.50 lukem }
251 1.50 lukem
252 1.44 lukem
253 1.44 lukem /*
254 1.27 lukem * Parse URL of form:
255 1.63 lukem * <type>://[<user>[:<password>@]]<host>[:<port>][/<path>]
256 1.27 lukem * Returns -1 if a parse error occurred, otherwise 0.
257 1.50 lukem * It's the caller's responsibility to url_decode() the returned
258 1.50 lukem * user, pass and path.
259 1.63 lukem *
260 1.27 lukem * Sets type to url_t, each of the given char ** pointers to a
261 1.27 lukem * malloc(3)ed strings of the relevant section, and port to
262 1.41 lukem * the number given, or ftpport if ftp://, or httpport if http://.
263 1.52 lukem *
264 1.63 lukem * If <host> is surrounded by `[' and ']', it's parsed as an
265 1.102 lukem * IPv6 address (as per RFC 2732).
266 1.63 lukem *
267 1.63 lukem * XXX: this is not totally RFC 1738 compliant; <path> will have the
268 1.53 lukem * leading `/' unless it's an ftp:// URL, as this makes things easier
269 1.53 lukem * for file:// and http:// URLs. ftp:// URLs have the `/' between the
270 1.53 lukem * host and the url-path removed, but any additional leading slashes
271 1.53 lukem * in the url-path are retained (because they imply that we should
272 1.53 lukem * later do "CWD" with a null argument).
273 1.53 lukem *
274 1.53 lukem * Examples:
275 1.53 lukem * input url output path
276 1.53 lukem * --------- -----------
277 1.63 lukem * "ftp://host" NULL
278 1.63 lukem * "http://host/" NULL
279 1.63 lukem * "file://host/dir/file" "dir/file"
280 1.63 lukem * "ftp://host/" ""
281 1.63 lukem * "ftp://host//" NULL
282 1.53 lukem * "ftp://host//dir/file" "/dir/file"
283 1.27 lukem */
284 1.27 lukem static int
285 1.82 lukem parse_url(url, desc, type, user, pass, host, port, portnum, path)
286 1.27 lukem const char *url;
287 1.27 lukem const char *desc;
288 1.27 lukem url_t *type;
289 1.27 lukem char **user;
290 1.27 lukem char **pass;
291 1.27 lukem char **host;
292 1.60 itojun char **port;
293 1.82 lukem in_port_t *portnum;
294 1.27 lukem char **path;
295 1.27 lukem {
296 1.82 lukem const char *origurl;
297 1.82 lukem char *cp, *ep, *thost, *tport;
298 1.82 lukem size_t len;
299 1.27 lukem
300 1.27 lukem if (url == NULL || desc == NULL || type == NULL || user == NULL
301 1.82 lukem || pass == NULL || host == NULL || port == NULL || portnum == NULL
302 1.82 lukem || path == NULL)
303 1.27 lukem errx(1, "parse_url: invoked with NULL argument!");
304 1.27 lukem
305 1.82 lukem origurl = url;
306 1.27 lukem *type = UNKNOWN_URL_T;
307 1.63 lukem *user = *pass = *host = *port = *path = NULL;
308 1.82 lukem *portnum = 0;
309 1.63 lukem tport = NULL;
310 1.27 lukem
311 1.27 lukem if (strncasecmp(url, HTTP_URL, sizeof(HTTP_URL) - 1) == 0) {
312 1.27 lukem url += sizeof(HTTP_URL) - 1;
313 1.27 lukem *type = HTTP_URL_T;
314 1.82 lukem *portnum = HTTP_PORT;
315 1.63 lukem tport = httpport;
316 1.27 lukem } else if (strncasecmp(url, FTP_URL, sizeof(FTP_URL) - 1) == 0) {
317 1.27 lukem url += sizeof(FTP_URL) - 1;
318 1.27 lukem *type = FTP_URL_T;
319 1.82 lukem *portnum = FTP_PORT;
320 1.63 lukem tport = ftpport;
321 1.27 lukem } else if (strncasecmp(url, FILE_URL, sizeof(FILE_URL) - 1) == 0) {
322 1.27 lukem url += sizeof(FILE_URL) - 1;
323 1.27 lukem *type = FILE_URL_T;
324 1.27 lukem } else {
325 1.27 lukem warnx("Invalid %s `%s'", desc, url);
326 1.27 lukem cleanup_parse_url:
327 1.27 lukem FREEPTR(*user);
328 1.27 lukem FREEPTR(*pass);
329 1.27 lukem FREEPTR(*host);
330 1.60 itojun FREEPTR(*port);
331 1.27 lukem FREEPTR(*path);
332 1.27 lukem return (-1);
333 1.27 lukem }
334 1.27 lukem
335 1.27 lukem if (*url == '\0')
336 1.27 lukem return (0);
337 1.27 lukem
338 1.27 lukem /* find [user[:pass]@]host[:port] */
339 1.27 lukem ep = strchr(url, '/');
340 1.27 lukem if (ep == NULL)
341 1.27 lukem thost = xstrdup(url);
342 1.27 lukem else {
343 1.50 lukem len = ep - url;
344 1.27 lukem thost = (char *)xmalloc(len + 1);
345 1.78 lukem (void)strlcpy(thost, url, len + 1);
346 1.53 lukem if (*type == FTP_URL_T) /* skip first / for ftp URLs */
347 1.53 lukem ep++;
348 1.27 lukem *path = xstrdup(ep);
349 1.27 lukem }
350 1.27 lukem
351 1.63 lukem cp = strchr(thost, '@'); /* look for user[:pass]@ in URLs */
352 1.54 lukem if (cp != NULL) {
353 1.54 lukem if (*type == FTP_URL_T)
354 1.54 lukem anonftp = 0; /* disable anonftp */
355 1.27 lukem *user = thost;
356 1.27 lukem *cp = '\0';
357 1.63 lukem thost = xstrdup(cp + 1);
358 1.27 lukem cp = strchr(*user, ':');
359 1.27 lukem if (cp != NULL) {
360 1.27 lukem *cp = '\0';
361 1.27 lukem *pass = xstrdup(cp + 1);
362 1.27 lukem }
363 1.63 lukem }
364 1.63 lukem
365 1.63 lukem #ifdef INET6
366 1.63 lukem /*
367 1.63 lukem * Check if thost is an encoded IPv6 address, as per
368 1.102 lukem * RFC 2732:
369 1.63 lukem * `[' ipv6-address ']'
370 1.63 lukem */
371 1.63 lukem if (*thost == '[') {
372 1.63 lukem cp = thost + 1;
373 1.63 lukem if ((ep = strchr(cp, ']')) == NULL ||
374 1.106 itojun (ep[1] != '\0' && ep[1] != ':')) {
375 1.63 lukem warnx("Invalid address `%s' in %s `%s'",
376 1.82 lukem thost, desc, origurl);
377 1.63 lukem goto cleanup_parse_url;
378 1.63 lukem }
379 1.103 lukem len = ep - cp; /* change `[xyz]' -> `xyz' */
380 1.63 lukem memmove(thost, thost + 1, len);
381 1.63 lukem thost[len] = '\0';
382 1.63 lukem if (! isipv6addr(thost)) {
383 1.63 lukem warnx("Invalid IPv6 address `%s' in %s `%s'",
384 1.82 lukem thost, desc, origurl);
385 1.63 lukem goto cleanup_parse_url;
386 1.63 lukem }
387 1.63 lukem cp = ep + 1;
388 1.63 lukem if (*cp == ':')
389 1.63 lukem cp++;
390 1.63 lukem else
391 1.63 lukem cp = NULL;
392 1.27 lukem } else
393 1.63 lukem #endif /* INET6 */
394 1.63 lukem if ((cp = strchr(thost, ':')) != NULL)
395 1.63 lukem *cp++ = '\0';
396 1.63 lukem *host = thost;
397 1.60 itojun
398 1.27 lukem /* look for [:port] */
399 1.27 lukem if (cp != NULL) {
400 1.82 lukem long nport;
401 1.27 lukem
402 1.63 lukem nport = strtol(cp, &ep, 10);
403 1.82 lukem if (*ep != '\0' && ep == cp) {
404 1.82 lukem struct servent *svp;
405 1.82 lukem
406 1.82 lukem svp = getservbyname(cp, "tcp");
407 1.82 lukem if (svp == NULL) {
408 1.82 lukem warnx("Unknown port `%s' in %s `%s'",
409 1.82 lukem cp, desc, origurl);
410 1.82 lukem goto cleanup_parse_url;
411 1.82 lukem } else
412 1.82 lukem nport = ntohs(svp->s_port);
413 1.82 lukem } else if (nport < 1 || nport > MAX_IN_PORT_T || *ep != '\0') {
414 1.82 lukem warnx("Invalid port `%s' in %s `%s'", cp, desc,
415 1.82 lukem origurl);
416 1.27 lukem goto cleanup_parse_url;
417 1.27 lukem }
418 1.82 lukem *portnum = nport;
419 1.63 lukem tport = cp;
420 1.27 lukem }
421 1.82 lukem
422 1.95 lukem if (tport != NULL)
423 1.63 lukem *port = xstrdup(tport);
424 1.81 lukem if (*path == NULL)
425 1.81 lukem *path = xstrdup("");
426 1.27 lukem
427 1.27 lukem if (debug)
428 1.27 lukem fprintf(ttyout,
429 1.107 itojun "parse_url: user `%s' pass `%s' host %s port %s(%d) "
430 1.107 itojun "path `%s'\n",
431 1.53 lukem *user ? *user : "<null>", *pass ? *pass : "<null>",
432 1.60 itojun *host ? *host : "<null>", *port ? *port : "<null>",
433 1.82 lukem *portnum ? *portnum : -1, *path ? *path : "<null>");
434 1.27 lukem
435 1.27 lukem return (0);
436 1.27 lukem }
437 1.27 lukem
438 1.89 lukem sigjmp_buf httpabort;
439 1.2 lukem
440 1.1 lukem /*
441 1.50 lukem * Retrieve URL, via a proxy if necessary, using HTTP.
442 1.50 lukem * If proxyenv is set, use that for the proxy, otherwise try ftp_proxy or
443 1.50 lukem * http_proxy as appropriate.
444 1.50 lukem * Supports HTTP redirects.
445 1.41 lukem * Returns -1 on failure, 0 on completed xfer, 1 if ftp connection
446 1.41 lukem * is still open (e.g, ftp xfer with trailing /)
447 1.1 lukem */
448 1.12 lukem static int
449 1.52 lukem fetch_url(url, proxyenv, proxyauth, wwwauth)
450 1.44 lukem const char *url;
451 1.44 lukem const char *proxyenv;
452 1.44 lukem char *proxyauth;
453 1.44 lukem char *wwwauth;
454 1.1 lukem {
455 1.105 lukem #if defined(NI_NUMERICHOST) && defined(INET6)
456 1.98 itojun struct addrinfo hints, *res, *res0 = NULL;
457 1.66 christos int error;
458 1.98 itojun char hbuf[NI_MAXHOST];
459 1.66 christos #else
460 1.66 christos struct sockaddr_in sin;
461 1.66 christos struct hostent *hp = NULL;
462 1.66 christos #endif
463 1.104 lukem volatile sigfunc oldintr, oldintp;
464 1.42 lukem volatile int s;
465 1.95 lukem struct stat sb;
466 1.96 lukem int ischunked, isproxy, rval, hcode;
467 1.42 lukem size_t len;
468 1.73 lukem static size_t bufsize;
469 1.73 lukem static char *xferbuf;
470 1.44 lukem char *cp, *ep, *buf, *savefile;
471 1.44 lukem char *auth, *location, *message;
472 1.63 lukem char *user, *pass, *host, *port, *path, *decodedpath;
473 1.54 lukem char *puser, *ppass;
474 1.95 lukem off_t hashbytes, rangestart, rangeend, entitylen;
475 1.42 lukem int (*closefunc) __P((FILE *));
476 1.42 lukem FILE *fin, *fout;
477 1.42 lukem time_t mtime;
478 1.42 lukem url_t urltype;
479 1.60 itojun in_port_t portnum;
480 1.1 lukem
481 1.86 lukem oldintr = oldintp = NULL;
482 1.22 lukem closefunc = NULL;
483 1.24 lukem fin = fout = NULL;
484 1.1 lukem s = -1;
485 1.44 lukem buf = savefile = NULL;
486 1.44 lukem auth = location = message = NULL;
487 1.52 lukem ischunked = isproxy = hcode = 0;
488 1.42 lukem rval = 1;
489 1.54 lukem user = pass = host = path = decodedpath = puser = ppass = NULL;
490 1.1 lukem
491 1.27 lukem #ifdef __GNUC__ /* shut up gcc warnings */
492 1.22 lukem (void)&closefunc;
493 1.24 lukem (void)&fin;
494 1.22 lukem (void)&fout;
495 1.24 lukem (void)&buf;
496 1.12 lukem (void)&savefile;
497 1.42 lukem (void)&rval;
498 1.28 fvdl (void)&isproxy;
499 1.51 christos (void)&hcode;
500 1.51 christos (void)&ischunked;
501 1.51 christos (void)&message;
502 1.51 christos (void)&location;
503 1.51 christos (void)&auth;
504 1.51 christos (void)&decodedpath;
505 1.12 lukem #endif
506 1.12 lukem
507 1.82 lukem if (parse_url(url, "URL", &urltype, &user, &pass, &host, &port,
508 1.82 lukem &portnum, &path) == -1)
509 1.42 lukem goto cleanup_fetch_url;
510 1.5 lukem
511 1.27 lukem if (urltype == FILE_URL_T && ! EMPTYSTRING(host)
512 1.27 lukem && strcasecmp(host, "localhost") != 0) {
513 1.27 lukem warnx("No support for non local file URL `%s'", url);
514 1.42 lukem goto cleanup_fetch_url;
515 1.9 lukem }
516 1.27 lukem
517 1.9 lukem if (EMPTYSTRING(path)) {
518 1.42 lukem if (urltype == FTP_URL_T) {
519 1.52 lukem rval = fetch_ftp(url);
520 1.42 lukem goto cleanup_fetch_url;
521 1.42 lukem }
522 1.27 lukem if (urltype != HTTP_URL_T || outfile == NULL) {
523 1.27 lukem warnx("Invalid URL (no file after host) `%s'", url);
524 1.42 lukem goto cleanup_fetch_url;
525 1.27 lukem }
526 1.9 lukem }
527 1.1 lukem
528 1.50 lukem decodedpath = xstrdup(path);
529 1.50 lukem url_decode(decodedpath);
530 1.50 lukem
531 1.22 lukem if (outfile)
532 1.29 lukem savefile = xstrdup(outfile);
533 1.22 lukem else {
534 1.50 lukem cp = strrchr(decodedpath, '/'); /* find savefile */
535 1.29 lukem if (cp != NULL)
536 1.29 lukem savefile = xstrdup(cp + 1);
537 1.22 lukem else
538 1.50 lukem savefile = xstrdup(decodedpath);
539 1.22 lukem }
540 1.9 lukem if (EMPTYSTRING(savefile)) {
541 1.42 lukem if (urltype == FTP_URL_T) {
542 1.52 lukem rval = fetch_ftp(url);
543 1.42 lukem goto cleanup_fetch_url;
544 1.42 lukem }
545 1.27 lukem warnx("Invalid URL (no file after directory) `%s'", url);
546 1.42 lukem goto cleanup_fetch_url;
547 1.52 lukem } else {
548 1.52 lukem if (debug)
549 1.52 lukem fprintf(ttyout, "got savefile as `%s'\n", savefile);
550 1.9 lukem }
551 1.1 lukem
552 1.95 lukem restart_point = 0;
553 1.25 lukem filesize = -1;
554 1.95 lukem rangestart = rangeend = entitylen = -1;
555 1.25 lukem mtime = -1;
556 1.95 lukem if (restartautofetch) {
557 1.95 lukem if (strcmp(savefile, "-") != 0 && *savefile != '|' &&
558 1.95 lukem stat(savefile, &sb) == 0)
559 1.95 lukem restart_point = sb.st_size;
560 1.95 lukem }
561 1.25 lukem if (urltype == FILE_URL_T) { /* file:// URLs */
562 1.25 lukem direction = "copied";
563 1.50 lukem fin = fopen(decodedpath, "r");
564 1.25 lukem if (fin == NULL) {
565 1.50 lukem warn("Cannot open file `%s'", decodedpath);
566 1.42 lukem goto cleanup_fetch_url;
567 1.5 lukem }
568 1.25 lukem if (fstat(fileno(fin), &sb) == 0) {
569 1.25 lukem mtime = sb.st_mtime;
570 1.25 lukem filesize = sb.st_size;
571 1.25 lukem }
572 1.95 lukem if (restart_point) {
573 1.95 lukem if (lseek(fileno(fin), restart_point, SEEK_SET) < 0) {
574 1.95 lukem warn("Can't lseek to restart `%s'",
575 1.95 lukem decodedpath);
576 1.95 lukem goto cleanup_fetch_url;
577 1.95 lukem }
578 1.95 lukem }
579 1.95 lukem if (verbose) {
580 1.95 lukem fprintf(ttyout, "Copying %s", decodedpath);
581 1.95 lukem if (restart_point)
582 1.95 lukem #ifndef NO_QUAD
583 1.95 lukem fprintf(ttyout, " (restarting at %lld)",
584 1.95 lukem (long long)restart_point);
585 1.95 lukem #else
586 1.95 lukem fprintf(ttyout, " (restarting at %ld)",
587 1.95 lukem (long)restart_point);
588 1.95 lukem #endif
589 1.95 lukem fputs("\n", ttyout);
590 1.95 lukem }
591 1.25 lukem } else { /* ftp:// or http:// URLs */
592 1.65 lukem char *leading;
593 1.65 lukem int hasleading;
594 1.65 lukem
595 1.42 lukem if (proxyenv == NULL) {
596 1.42 lukem if (urltype == HTTP_URL_T)
597 1.91 lukem proxyenv = getoptionvalue("http_proxy");
598 1.42 lukem else if (urltype == FTP_URL_T)
599 1.91 lukem proxyenv = getoptionvalue("ftp_proxy");
600 1.42 lukem }
601 1.25 lukem direction = "retrieved";
602 1.91 lukem if (! EMPTYSTRING(proxyenv)) { /* use proxy */
603 1.27 lukem url_t purltype;
604 1.54 lukem char *phost, *ppath;
605 1.91 lukem char *pport, *no_proxy;
606 1.27 lukem
607 1.27 lukem isproxy = 1;
608 1.27 lukem
609 1.27 lukem /* check URL against list of no_proxied sites */
610 1.91 lukem no_proxy = getoptionvalue("no_proxy");
611 1.91 lukem if (! EMPTYSTRING(no_proxy)) {
612 1.27 lukem char *np, *np_copy;
613 1.27 lukem long np_port;
614 1.27 lukem size_t hlen, plen;
615 1.27 lukem
616 1.27 lukem np_copy = xstrdup(no_proxy);
617 1.27 lukem hlen = strlen(host);
618 1.27 lukem while ((cp = strsep(&np_copy, " ,")) != NULL) {
619 1.27 lukem if (*cp == '\0')
620 1.27 lukem continue;
621 1.60 itojun if ((np = strrchr(cp, ':')) != NULL) {
622 1.27 lukem *np = '\0';
623 1.27 lukem np_port =
624 1.27 lukem strtol(np + 1, &ep, 10);
625 1.27 lukem if (*ep != '\0')
626 1.27 lukem continue;
627 1.82 lukem if (np_port != portnum)
628 1.27 lukem continue;
629 1.27 lukem }
630 1.27 lukem plen = strlen(cp);
631 1.109 lukem if (hlen < plen)
632 1.109 lukem continue;
633 1.27 lukem if (strncasecmp(host + hlen - plen,
634 1.27 lukem cp, plen) == 0) {
635 1.27 lukem isproxy = 0;
636 1.27 lukem break;
637 1.27 lukem }
638 1.27 lukem }
639 1.27 lukem FREEPTR(np_copy);
640 1.25 lukem }
641 1.1 lukem
642 1.27 lukem if (isproxy) {
643 1.27 lukem if (parse_url(proxyenv, "proxy URL", &purltype,
644 1.82 lukem &puser, &ppass, &phost, &pport, &portnum,
645 1.82 lukem &ppath) == -1)
646 1.42 lukem goto cleanup_fetch_url;
647 1.27 lukem
648 1.27 lukem if ((purltype != HTTP_URL_T
649 1.27 lukem && purltype != FTP_URL_T) ||
650 1.27 lukem EMPTYSTRING(phost) ||
651 1.27 lukem (! EMPTYSTRING(ppath)
652 1.27 lukem && strcmp(ppath, "/") != 0)) {
653 1.27 lukem warnx("Malformed proxy URL `%s'",
654 1.27 lukem proxyenv);
655 1.27 lukem FREEPTR(phost);
656 1.60 itojun FREEPTR(pport);
657 1.27 lukem FREEPTR(ppath);
658 1.42 lukem goto cleanup_fetch_url;
659 1.27 lukem }
660 1.12 lukem
661 1.27 lukem FREEPTR(host);
662 1.27 lukem host = phost;
663 1.62 tron FREEPTR(port);
664 1.62 tron port = pport;
665 1.27 lukem FREEPTR(path);
666 1.54 lukem path = xstrdup(url);
667 1.27 lukem FREEPTR(ppath);
668 1.27 lukem }
669 1.91 lukem } /* ! EMPTYSTRING(proxyenv) */
670 1.25 lukem
671 1.105 lukem #if !defined(NI_NUMERICHOST) || !defined(INET6)
672 1.25 lukem memset(&sin, 0, sizeof(sin));
673 1.25 lukem sin.sin_family = AF_INET;
674 1.25 lukem
675 1.25 lukem if (isdigit((unsigned char)host[0])) {
676 1.25 lukem if (inet_aton(host, &sin.sin_addr) == 0) {
677 1.27 lukem warnx("Invalid IP address `%s'", host);
678 1.42 lukem goto cleanup_fetch_url;
679 1.25 lukem }
680 1.25 lukem } else {
681 1.25 lukem hp = gethostbyname(host);
682 1.25 lukem if (hp == NULL) {
683 1.25 lukem warnx("%s: %s", host, hstrerror(h_errno));
684 1.42 lukem goto cleanup_fetch_url;
685 1.25 lukem }
686 1.25 lukem if (hp->h_addrtype != AF_INET) {
687 1.27 lukem warnx("`%s': not an Internet address?", host);
688 1.42 lukem goto cleanup_fetch_url;
689 1.25 lukem }
690 1.66 christos if (hp->h_length > sizeof(sin.sin_addr))
691 1.66 christos hp->h_length = sizeof(sin.sin_addr);
692 1.25 lukem memcpy(&sin.sin_addr, hp->h_addr, hp->h_length);
693 1.1 lukem }
694 1.82 lukem sin.sin_port = htons(portnum);
695 1.25 lukem
696 1.25 lukem s = socket(AF_INET, SOCK_STREAM, 0);
697 1.25 lukem if (s == -1) {
698 1.25 lukem warn("Can't create socket");
699 1.42 lukem goto cleanup_fetch_url;
700 1.22 lukem }
701 1.1 lukem
702 1.25 lukem while (xconnect(s, (struct sockaddr *)&sin,
703 1.25 lukem sizeof(sin)) == -1) {
704 1.25 lukem if (errno == EINTR)
705 1.25 lukem continue;
706 1.25 lukem if (hp && hp->h_addr_list[1]) {
707 1.25 lukem int oerrno = errno;
708 1.25 lukem char *ia;
709 1.25 lukem
710 1.25 lukem ia = inet_ntoa(sin.sin_addr);
711 1.25 lukem errno = oerrno;
712 1.27 lukem warn("Connect to address `%s'", ia);
713 1.25 lukem hp->h_addr_list++;
714 1.25 lukem memcpy(&sin.sin_addr, hp->h_addr_list[0],
715 1.25 lukem (size_t)hp->h_length);
716 1.49 lukem if (verbose)
717 1.49 lukem fprintf(ttyout, "Trying %s...\n",
718 1.49 lukem inet_ntoa(sin.sin_addr));
719 1.25 lukem (void)close(s);
720 1.25 lukem s = socket(AF_INET, SOCK_STREAM, 0);
721 1.25 lukem if (s < 0) {
722 1.25 lukem warn("Can't create socket");
723 1.42 lukem goto cleanup_fetch_url;
724 1.25 lukem }
725 1.25 lukem continue;
726 1.25 lukem }
727 1.27 lukem warn("Can't connect to `%s'", host);
728 1.42 lukem goto cleanup_fetch_url;
729 1.25 lukem }
730 1.60 itojun #else
731 1.60 itojun memset(&hints, 0, sizeof(hints));
732 1.65 lukem hints.ai_flags = 0;
733 1.60 itojun hints.ai_family = AF_UNSPEC;
734 1.60 itojun hints.ai_socktype = SOCK_STREAM;
735 1.60 itojun hints.ai_protocol = 0;
736 1.98 itojun error = getaddrinfo(host, port, &hints, &res0);
737 1.60 itojun if (error) {
738 1.69 mycroft warnx(gai_strerror(error));
739 1.60 itojun goto cleanup_fetch_url;
740 1.60 itojun }
741 1.98 itojun if (res0->ai_canonname)
742 1.98 itojun host = res0->ai_canonname;
743 1.60 itojun
744 1.98 itojun s = -1;
745 1.98 itojun for (res = res0; res; res = res->ai_next) {
746 1.98 itojun if (getnameinfo(res->ai_addr, res->ai_addrlen,
747 1.98 itojun hbuf, sizeof(hbuf), NULL, 0,
748 1.98 itojun NI_NUMERICHOST) != 0)
749 1.98 itojun strncpy(hbuf, "invalid", sizeof(hbuf));
750 1.98 itojun
751 1.98 itojun if (verbose && res != res0)
752 1.98 itojun fprintf(ttyout, "Trying %s...\n", hbuf);
753 1.98 itojun
754 1.98 itojun s = socket(res->ai_family, res->ai_socktype,
755 1.98 itojun res->ai_protocol);
756 1.60 itojun if (s < 0) {
757 1.60 itojun warn("Can't create socket");
758 1.98 itojun continue;
759 1.60 itojun }
760 1.60 itojun
761 1.60 itojun if (xconnect(s, res->ai_addr, res->ai_addrlen) < 0) {
762 1.60 itojun warn("Connect to address `%s'", hbuf);
763 1.60 itojun close(s);
764 1.98 itojun s = -1;
765 1.98 itojun continue;
766 1.60 itojun }
767 1.98 itojun
768 1.98 itojun /* success */
769 1.60 itojun break;
770 1.60 itojun }
771 1.98 itojun freeaddrinfo(res0);
772 1.98 itojun
773 1.98 itojun if (s < 0) {
774 1.98 itojun warn("Can't connect to %s", host);
775 1.98 itojun goto cleanup_fetch_url;
776 1.98 itojun }
777 1.60 itojun #endif
778 1.24 lukem
779 1.25 lukem fin = fdopen(s, "r+");
780 1.25 lukem /*
781 1.27 lukem * Construct and send the request.
782 1.25 lukem */
783 1.65 lukem if (verbose)
784 1.65 lukem fprintf(ttyout, "Requesting %s\n", url);
785 1.65 lukem leading = " (";
786 1.65 lukem hasleading = 0;
787 1.27 lukem if (isproxy) {
788 1.65 lukem if (verbose) {
789 1.65 lukem fprintf(ttyout, "%svia %s:%s", leading,
790 1.65 lukem host, port);
791 1.65 lukem leading = ", ";
792 1.65 lukem hasleading++;
793 1.65 lukem }
794 1.44 lukem fprintf(fin, "GET %s HTTP/1.0\r\n", path);
795 1.47 lukem if (flushcache)
796 1.47 lukem fprintf(fin, "Pragma: no-cache\r\n");
797 1.27 lukem } else {
798 1.27 lukem fprintf(fin, "GET %s HTTP/1.1\r\n", path);
799 1.106 itojun if (strchr(host, ':')) {
800 1.106 itojun fprintf(fin, "Host: [%s]:%d\r\n", host,
801 1.106 itojun portnum);
802 1.106 itojun } else
803 1.106 itojun fprintf(fin, "Host: %s:%d\r\n", host, portnum);
804 1.40 explorer fprintf(fin, "Accept: */*\r\n");
805 1.42 lukem fprintf(fin, "Connection: close\r\n");
806 1.95 lukem if (restart_point) {
807 1.95 lukem fputs(leading, ttyout);
808 1.95 lukem #ifndef NO_QUAD
809 1.95 lukem fprintf(fin, "Range: bytes=%lld-\r\n",
810 1.95 lukem (long long)restart_point);
811 1.95 lukem fprintf(ttyout, "restarting at %lld",
812 1.95 lukem (long long)restart_point);
813 1.95 lukem #else
814 1.95 lukem fprintf(fin, "Range: bytes=%ld-\r\n",
815 1.95 lukem (long)restart_point);
816 1.95 lukem fprintf(ttyout, "restarting at %ld",
817 1.95 lukem (long)restart_point);
818 1.95 lukem #endif
819 1.95 lukem leading = ", ";
820 1.95 lukem hasleading++;
821 1.95 lukem }
822 1.47 lukem if (flushcache)
823 1.47 lukem fprintf(fin, "Cache-Control: no-cache\r\n");
824 1.25 lukem }
825 1.94 lukem fprintf(fin, "User-Agent: %s/%s\r\n", FTP_PRODUCT, FTP_VERSION);
826 1.44 lukem if (wwwauth) {
827 1.65 lukem if (verbose) {
828 1.65 lukem fprintf(ttyout, "%swith authorization",
829 1.65 lukem leading);
830 1.65 lukem leading = ", ";
831 1.65 lukem hasleading++;
832 1.65 lukem }
833 1.44 lukem fprintf(fin, "Authorization: %s\r\n", wwwauth);
834 1.44 lukem }
835 1.46 lukem if (proxyauth) {
836 1.65 lukem if (verbose) {
837 1.49 lukem fprintf(ttyout,
838 1.65 lukem "%swith proxy authorization", leading);
839 1.65 lukem leading = ", ";
840 1.65 lukem hasleading++;
841 1.65 lukem }
842 1.44 lukem fprintf(fin, "Proxy-Authorization: %s\r\n", proxyauth);
843 1.46 lukem }
844 1.65 lukem if (verbose && hasleading)
845 1.65 lukem fputs(")\n", ttyout);
846 1.44 lukem fprintf(fin, "\r\n");
847 1.25 lukem if (fflush(fin) == EOF) {
848 1.25 lukem warn("Writing HTTP request");
849 1.42 lukem goto cleanup_fetch_url;
850 1.25 lukem }
851 1.1 lukem
852 1.25 lukem /* Read the response */
853 1.24 lukem if ((buf = fparseln(fin, &len, NULL, "\0\0\0", 0)) == NULL) {
854 1.24 lukem warn("Receiving HTTP reply");
855 1.42 lukem goto cleanup_fetch_url;
856 1.24 lukem }
857 1.24 lukem while (len > 0 && (buf[len-1] == '\r' || buf[len-1] == '\n'))
858 1.24 lukem buf[--len] = '\0';
859 1.24 lukem if (debug)
860 1.27 lukem fprintf(ttyout, "received `%s'\n", buf);
861 1.1 lukem
862 1.42 lukem /* Determine HTTP response code */
863 1.25 lukem cp = strchr(buf, ' ');
864 1.25 lukem if (cp == NULL)
865 1.25 lukem goto improper;
866 1.25 lukem else
867 1.25 lukem cp++;
868 1.42 lukem hcode = strtol(cp, &ep, 10);
869 1.42 lukem if (*ep != '\0' && !isspace((unsigned char)*ep))
870 1.42 lukem goto improper;
871 1.42 lukem message = xstrdup(cp);
872 1.25 lukem
873 1.25 lukem /* Read the rest of the header. */
874 1.27 lukem FREEPTR(buf);
875 1.25 lukem while (1) {
876 1.25 lukem if ((buf = fparseln(fin, &len, NULL, "\0\0\0", 0))
877 1.25 lukem == NULL) {
878 1.25 lukem warn("Receiving HTTP reply");
879 1.42 lukem goto cleanup_fetch_url;
880 1.25 lukem }
881 1.25 lukem while (len > 0 &&
882 1.25 lukem (buf[len-1] == '\r' || buf[len-1] == '\n'))
883 1.25 lukem buf[--len] = '\0';
884 1.25 lukem if (len == 0)
885 1.25 lukem break;
886 1.25 lukem if (debug)
887 1.27 lukem fprintf(ttyout, "received `%s'\n", buf);
888 1.25 lukem
889 1.25 lukem /* Look for some headers */
890 1.25 lukem cp = buf;
891 1.42 lukem
892 1.91 lukem #define CONTENTLEN "Content-Length: "
893 1.25 lukem if (strncasecmp(cp, CONTENTLEN,
894 1.44 lukem sizeof(CONTENTLEN) - 1) == 0) {
895 1.25 lukem cp += sizeof(CONTENTLEN) - 1;
896 1.95 lukem #ifndef NO_QUAD
897 1.108 lukem filesize = strtoll(cp, &ep, 10);
898 1.95 lukem #else
899 1.25 lukem filesize = strtol(cp, &ep, 10);
900 1.95 lukem #endif
901 1.95 lukem if (filesize < 0 || *ep != '\0')
902 1.25 lukem goto improper;
903 1.25 lukem if (debug)
904 1.25 lukem #ifndef NO_QUAD
905 1.95 lukem fprintf(ttyout, "parsed len as: %lld\n",
906 1.25 lukem (long long)filesize);
907 1.25 lukem #else
908 1.95 lukem fprintf(ttyout, "parsed len as: %ld\n",
909 1.25 lukem (long)filesize);
910 1.25 lukem #endif
911 1.42 lukem
912 1.95 lukem #define CONTENTRANGE "Content-Range: bytes "
913 1.95 lukem } else if (strncasecmp(cp, CONTENTRANGE,
914 1.95 lukem sizeof(CONTENTRANGE) - 1) == 0) {
915 1.95 lukem cp += sizeof(CONTENTRANGE) - 1;
916 1.95 lukem #ifndef NO_QUAD
917 1.108 lukem rangestart = strtoll(cp, &ep, 10);
918 1.95 lukem #else
919 1.95 lukem rangestart = strtol(cp, &ep, 10);
920 1.95 lukem #endif
921 1.95 lukem if (rangestart < 0 || *ep != '-')
922 1.95 lukem goto improper;
923 1.95 lukem cp = ep + 1;
924 1.95 lukem
925 1.95 lukem #ifndef NO_QUAD
926 1.108 lukem rangeend = strtoll(cp, &ep, 10);
927 1.95 lukem #else
928 1.95 lukem rangeend = strtol(cp, &ep, 10);
929 1.95 lukem #endif
930 1.95 lukem if (rangeend < 0 || *ep != '/' ||
931 1.95 lukem rangeend < rangestart)
932 1.95 lukem goto improper;
933 1.95 lukem cp = ep + 1;
934 1.95 lukem
935 1.95 lukem #ifndef NO_QUAD
936 1.108 lukem entitylen = strtoll(cp, &ep, 10);
937 1.95 lukem #else
938 1.95 lukem entitylen = strtol(cp, &ep, 10);
939 1.95 lukem #endif
940 1.95 lukem if (entitylen < 0 || *ep != '\0')
941 1.95 lukem goto improper;
942 1.95 lukem
943 1.95 lukem if (debug)
944 1.95 lukem #ifndef NO_QUAD
945 1.95 lukem fprintf(ttyout,
946 1.95 lukem "parsed range as: %lld-%lld/%lld\n",
947 1.95 lukem (long long)rangestart,
948 1.95 lukem (long long)rangeend,
949 1.95 lukem (long long)entitylen);
950 1.95 lukem #else
951 1.95 lukem fprintf(ttyout,
952 1.95 lukem "parsed range as: %ld-%ld/%ld\n",
953 1.95 lukem (long)rangestart,
954 1.95 lukem (long)rangeend,
955 1.95 lukem (long)entitylen);
956 1.95 lukem #endif
957 1.95 lukem if (! restart_point) {
958 1.95 lukem warnx(
959 1.95 lukem "Received unexpected Content-Range header");
960 1.95 lukem goto cleanup_fetch_url;
961 1.95 lukem }
962 1.95 lukem
963 1.91 lukem #define LASTMOD "Last-Modified: "
964 1.25 lukem } else if (strncasecmp(cp, LASTMOD,
965 1.44 lukem sizeof(LASTMOD) - 1) == 0) {
966 1.25 lukem struct tm parsed;
967 1.25 lukem char *t;
968 1.25 lukem
969 1.25 lukem cp += sizeof(LASTMOD) - 1;
970 1.25 lukem /* RFC 1123 */
971 1.25 lukem if ((t = strptime(cp,
972 1.25 lukem "%a, %d %b %Y %H:%M:%S GMT",
973 1.25 lukem &parsed))
974 1.25 lukem /* RFC 850 */
975 1.25 lukem || (t = strptime(cp,
976 1.25 lukem "%a, %d-%b-%y %H:%M:%S GMT",
977 1.25 lukem &parsed))
978 1.25 lukem /* asctime */
979 1.25 lukem || (t = strptime(cp,
980 1.25 lukem "%a, %b %d %H:%M:%S %Y",
981 1.25 lukem &parsed))) {
982 1.38 lukem parsed.tm_isdst = -1;
983 1.25 lukem if (*t == '\0')
984 1.76 lukem mtime = timegm(&parsed);
985 1.38 lukem if (debug && mtime != -1) {
986 1.25 lukem fprintf(ttyout,
987 1.25 lukem "parsed date as: %s",
988 1.25 lukem ctime(&mtime));
989 1.38 lukem }
990 1.25 lukem }
991 1.42 lukem
992 1.91 lukem #define LOCATION "Location: "
993 1.42 lukem } else if (strncasecmp(cp, LOCATION,
994 1.44 lukem sizeof(LOCATION) - 1) == 0) {
995 1.25 lukem cp += sizeof(LOCATION) - 1;
996 1.42 lukem location = xstrdup(cp);
997 1.25 lukem if (debug)
998 1.25 lukem fprintf(ttyout,
999 1.25 lukem "parsed location as: %s\n", cp);
1000 1.44 lukem
1001 1.91 lukem #define TRANSENC "Transfer-Encoding: "
1002 1.45 lukem } else if (strncasecmp(cp, TRANSENC,
1003 1.45 lukem sizeof(TRANSENC) - 1) == 0) {
1004 1.45 lukem cp += sizeof(TRANSENC) - 1;
1005 1.109 lukem if (strcasecmp(cp, "binary") == 0) {
1006 1.109 lukem warnx(
1007 1.109 lukem "Bogus transfer encoding - `%s' (fetching anyway)",
1008 1.109 lukem cp);
1009 1.109 lukem continue;
1010 1.109 lukem }
1011 1.45 lukem if (strcasecmp(cp, "chunked") != 0) {
1012 1.45 lukem warnx(
1013 1.45 lukem "Unsupported transfer encoding - `%s'",
1014 1.45 lukem cp);
1015 1.45 lukem goto cleanup_fetch_url;
1016 1.45 lukem }
1017 1.45 lukem ischunked++;
1018 1.45 lukem if (debug)
1019 1.45 lukem fprintf(ttyout,
1020 1.45 lukem "using chunked encoding\n");
1021 1.45 lukem
1022 1.91 lukem #define PROXYAUTH "Proxy-Authenticate: "
1023 1.44 lukem } else if (strncasecmp(cp, PROXYAUTH,
1024 1.44 lukem sizeof(PROXYAUTH) - 1) == 0) {
1025 1.44 lukem cp += sizeof(PROXYAUTH) - 1;
1026 1.44 lukem FREEPTR(auth);
1027 1.44 lukem auth = xstrdup(cp);
1028 1.44 lukem if (debug)
1029 1.44 lukem fprintf(ttyout,
1030 1.44 lukem "parsed proxy-auth as: %s\n", cp);
1031 1.44 lukem
1032 1.91 lukem #define WWWAUTH "WWW-Authenticate: "
1033 1.44 lukem } else if (strncasecmp(cp, WWWAUTH,
1034 1.44 lukem sizeof(WWWAUTH) - 1) == 0) {
1035 1.44 lukem cp += sizeof(WWWAUTH) - 1;
1036 1.44 lukem FREEPTR(auth);
1037 1.44 lukem auth = xstrdup(cp);
1038 1.44 lukem if (debug)
1039 1.44 lukem fprintf(ttyout,
1040 1.44 lukem "parsed www-auth as: %s\n", cp);
1041 1.44 lukem
1042 1.25 lukem }
1043 1.44 lukem
1044 1.24 lukem }
1045 1.54 lukem /* finished parsing header */
1046 1.27 lukem FREEPTR(buf);
1047 1.1 lukem
1048 1.52 lukem switch (hcode) {
1049 1.52 lukem case 200:
1050 1.52 lukem break;
1051 1.95 lukem case 206:
1052 1.95 lukem if (! restart_point) {
1053 1.95 lukem warnx("Not expecting partial content header");
1054 1.95 lukem goto cleanup_fetch_url;
1055 1.95 lukem }
1056 1.95 lukem break;
1057 1.52 lukem case 300:
1058 1.52 lukem case 301:
1059 1.52 lukem case 302:
1060 1.52 lukem case 303:
1061 1.52 lukem case 305:
1062 1.52 lukem if (EMPTYSTRING(location)) {
1063 1.52 lukem warnx(
1064 1.52 lukem "No redirection Location provided by server");
1065 1.52 lukem goto cleanup_fetch_url;
1066 1.52 lukem }
1067 1.52 lukem if (redirect_loop++ > 5) {
1068 1.52 lukem warnx("Too many redirections requested");
1069 1.52 lukem goto cleanup_fetch_url;
1070 1.52 lukem }
1071 1.52 lukem if (hcode == 305) {
1072 1.52 lukem if (verbose)
1073 1.52 lukem fprintf(ttyout, "Redirected via %s\n",
1074 1.52 lukem location);
1075 1.52 lukem rval = fetch_url(url, location,
1076 1.52 lukem proxyauth, wwwauth);
1077 1.52 lukem } else {
1078 1.52 lukem if (verbose)
1079 1.52 lukem fprintf(ttyout, "Redirected to %s\n",
1080 1.52 lukem location);
1081 1.52 lukem rval = go_fetch(location);
1082 1.52 lukem }
1083 1.42 lukem goto cleanup_fetch_url;
1084 1.52 lukem case 401:
1085 1.52 lukem case 407:
1086 1.52 lukem {
1087 1.52 lukem char **authp;
1088 1.54 lukem char *auser, *apass;
1089 1.52 lukem
1090 1.52 lukem fprintf(ttyout, "%s\n", message);
1091 1.52 lukem if (EMPTYSTRING(auth)) {
1092 1.52 lukem warnx(
1093 1.52 lukem "No authentication challenge provided by server");
1094 1.52 lukem goto cleanup_fetch_url;
1095 1.52 lukem }
1096 1.54 lukem if (hcode == 401) {
1097 1.54 lukem authp = &wwwauth;
1098 1.54 lukem auser = user;
1099 1.54 lukem apass = pass;
1100 1.54 lukem } else {
1101 1.54 lukem authp = &proxyauth;
1102 1.54 lukem auser = puser;
1103 1.54 lukem apass = ppass;
1104 1.54 lukem }
1105 1.52 lukem if (*authp != NULL) {
1106 1.52 lukem char reply[10];
1107 1.52 lukem
1108 1.52 lukem fprintf(ttyout,
1109 1.52 lukem "Authorization failed. Retry (y/n)? ");
1110 1.90 lukem if (fgets(reply, sizeof(reply), stdin)
1111 1.90 lukem == NULL) {
1112 1.90 lukem clearerr(stdin);
1113 1.52 lukem goto cleanup_fetch_url;
1114 1.90 lukem } else {
1115 1.90 lukem if (tolower(reply[0]) != 'y')
1116 1.90 lukem goto cleanup_fetch_url;
1117 1.90 lukem }
1118 1.54 lukem auser = NULL;
1119 1.54 lukem apass = NULL;
1120 1.52 lukem }
1121 1.54 lukem if (auth_url(auth, authp, auser, apass) == 0) {
1122 1.52 lukem rval = fetch_url(url, proxyenv,
1123 1.52 lukem proxyauth, wwwauth);
1124 1.80 lukem memset(*authp, 0, strlen(*authp));
1125 1.52 lukem FREEPTR(*authp);
1126 1.52 lukem }
1127 1.42 lukem goto cleanup_fetch_url;
1128 1.52 lukem }
1129 1.52 lukem default:
1130 1.52 lukem if (message)
1131 1.52 lukem warnx("Error retrieving file - `%s'", message);
1132 1.52 lukem else
1133 1.52 lukem warnx("Unknown error retrieving file");
1134 1.44 lukem goto cleanup_fetch_url;
1135 1.44 lukem }
1136 1.52 lukem } /* end of ftp:// or http:// specific setup */
1137 1.42 lukem
1138 1.22 lukem /* Open the output file. */
1139 1.22 lukem if (strcmp(savefile, "-") == 0) {
1140 1.22 lukem fout = stdout;
1141 1.22 lukem } else if (*savefile == '|') {
1142 1.77 lukem oldintp = xsignal(SIGPIPE, SIG_IGN);
1143 1.22 lukem fout = popen(savefile + 1, "w");
1144 1.22 lukem if (fout == NULL) {
1145 1.27 lukem warn("Can't run `%s'", savefile + 1);
1146 1.42 lukem goto cleanup_fetch_url;
1147 1.22 lukem }
1148 1.22 lukem closefunc = pclose;
1149 1.22 lukem } else {
1150 1.95 lukem if (restart_point){
1151 1.95 lukem if (entitylen != -1)
1152 1.95 lukem filesize = entitylen;
1153 1.95 lukem if (rangestart != -1 && rangestart != restart_point) {
1154 1.95 lukem warnx(
1155 1.95 lukem "Size of `%s' differs from save file `%s'",
1156 1.95 lukem url, savefile);
1157 1.95 lukem goto cleanup_fetch_url;
1158 1.95 lukem }
1159 1.95 lukem fout = fopen(savefile, "a");
1160 1.95 lukem } else
1161 1.95 lukem fout = fopen(savefile, "w");
1162 1.22 lukem if (fout == NULL) {
1163 1.27 lukem warn("Can't open `%s'", savefile);
1164 1.42 lukem goto cleanup_fetch_url;
1165 1.22 lukem }
1166 1.22 lukem closefunc = fclose;
1167 1.1 lukem }
1168 1.1 lukem
1169 1.22 lukem /* Trap signals */
1170 1.88 lukem if (sigsetjmp(httpabort, 1))
1171 1.42 lukem goto cleanup_fetch_url;
1172 1.86 lukem (void)xsignal(SIGQUIT, psummary);
1173 1.77 lukem oldintr = xsignal(SIGINT, aborthttp);
1174 1.2 lukem
1175 1.73 lukem if (rcvbuf_size > bufsize) {
1176 1.73 lukem if (xferbuf)
1177 1.73 lukem (void)free(xferbuf);
1178 1.73 lukem bufsize = rcvbuf_size;
1179 1.73 lukem xferbuf = xmalloc(bufsize);
1180 1.73 lukem }
1181 1.73 lukem
1182 1.1 lukem bytes = 0;
1183 1.1 lukem hashbytes = mark;
1184 1.1 lukem progressmeter(-1);
1185 1.2 lukem
1186 1.24 lukem /* Finally, suck down the file. */
1187 1.45 lukem do {
1188 1.77 lukem long chunksize;
1189 1.45 lukem
1190 1.45 lukem chunksize = 0;
1191 1.45 lukem /* read chunksize */
1192 1.45 lukem if (ischunked) {
1193 1.73 lukem if (fgets(xferbuf, bufsize, fin) == NULL) {
1194 1.45 lukem warnx("Unexpected EOF reading chunksize");
1195 1.45 lukem goto cleanup_fetch_url;
1196 1.45 lukem }
1197 1.73 lukem chunksize = strtol(xferbuf, &ep, 16);
1198 1.103 lukem
1199 1.103 lukem /*
1200 1.103 lukem * XXX: Work around bug in Apache 1.3.9, which
1201 1.103 lukem * incorrectly puts a trailing space after
1202 1.103 lukem * the chunksize.
1203 1.103 lukem */
1204 1.103 lukem if (*ep == ' ')
1205 1.103 lukem ep++;
1206 1.103 lukem
1207 1.45 lukem if (strcmp(ep, "\r\n") != 0) {
1208 1.45 lukem warnx("Unexpected data following chunksize");
1209 1.45 lukem goto cleanup_fetch_url;
1210 1.45 lukem }
1211 1.45 lukem if (debug)
1212 1.59 lukem fprintf(ttyout,
1213 1.59 lukem #ifndef NO_QUAD
1214 1.75 lukem "got chunksize of %lld\n",
1215 1.45 lukem (long long)chunksize);
1216 1.59 lukem #else
1217 1.59 lukem "got chunksize of %ld\n",
1218 1.59 lukem (long)chunksize);
1219 1.59 lukem #endif
1220 1.45 lukem if (chunksize == 0)
1221 1.45 lukem break;
1222 1.45 lukem }
1223 1.59 lukem /* transfer file or chunk */
1224 1.59 lukem while (1) {
1225 1.59 lukem struct timeval then, now, td;
1226 1.59 lukem off_t bufrem;
1227 1.59 lukem
1228 1.71 lukem if (rate_get)
1229 1.71 lukem (void)gettimeofday(&then, NULL);
1230 1.73 lukem bufrem = rate_get ? rate_get : bufsize;
1231 1.101 lukem if (ischunked)
1232 1.101 lukem bufrem = MIN(chunksize, bufrem);
1233 1.59 lukem while (bufrem > 0) {
1234 1.73 lukem len = fread(xferbuf, sizeof(char),
1235 1.101 lukem MIN(bufsize, bufrem), fin);
1236 1.59 lukem if (len <= 0)
1237 1.59 lukem goto chunkdone;
1238 1.59 lukem bytes += len;
1239 1.59 lukem bufrem -= len;
1240 1.73 lukem if (fwrite(xferbuf, sizeof(char), len, fout)
1241 1.59 lukem != len) {
1242 1.59 lukem warn("Writing `%s'", savefile);
1243 1.59 lukem goto cleanup_fetch_url;
1244 1.59 lukem }
1245 1.101 lukem if (hash && !progress) {
1246 1.101 lukem while (bytes >= hashbytes) {
1247 1.101 lukem (void)putc('#', ttyout);
1248 1.101 lukem hashbytes += mark;
1249 1.101 lukem }
1250 1.101 lukem (void)fflush(ttyout);
1251 1.101 lukem }
1252 1.101 lukem if (ischunked) {
1253 1.101 lukem chunksize -= len;
1254 1.101 lukem if (chunksize <= 0)
1255 1.101 lukem break;
1256 1.45 lukem }
1257 1.59 lukem }
1258 1.59 lukem if (rate_get) {
1259 1.59 lukem while (1) {
1260 1.59 lukem (void)gettimeofday(&now, NULL);
1261 1.59 lukem timersub(&now, &then, &td);
1262 1.59 lukem if (td.tv_sec > 0)
1263 1.59 lukem break;
1264 1.59 lukem usleep(1000000 - td.tv_usec);
1265 1.59 lukem }
1266 1.59 lukem }
1267 1.101 lukem if (ischunked && chunksize <= 0)
1268 1.101 lukem break;
1269 1.1 lukem }
1270 1.45 lukem /* read CRLF after chunk*/
1271 1.59 lukem chunkdone:
1272 1.45 lukem if (ischunked) {
1273 1.73 lukem if (fgets(xferbuf, bufsize, fin) == NULL)
1274 1.45 lukem break;
1275 1.73 lukem if (strcmp(xferbuf, "\r\n") != 0) {
1276 1.45 lukem warnx("Unexpected data following chunk");
1277 1.45 lukem goto cleanup_fetch_url;
1278 1.1 lukem }
1279 1.1 lukem }
1280 1.45 lukem } while (ischunked);
1281 1.1 lukem if (hash && !progress && bytes > 0) {
1282 1.1 lukem if (bytes < mark)
1283 1.22 lukem (void)putc('#', ttyout);
1284 1.22 lukem (void)putc('\n', ttyout);
1285 1.1 lukem }
1286 1.25 lukem if (ferror(fin)) {
1287 1.25 lukem warn("Reading file");
1288 1.42 lukem goto cleanup_fetch_url;
1289 1.1 lukem }
1290 1.2 lukem progressmeter(1);
1291 1.85 lukem bytes = 0;
1292 1.25 lukem (void)fflush(fout);
1293 1.25 lukem if (closefunc == fclose && mtime != -1) {
1294 1.25 lukem struct timeval tval[2];
1295 1.25 lukem
1296 1.25 lukem (void)gettimeofday(&tval[0], NULL);
1297 1.25 lukem tval[1].tv_sec = mtime;
1298 1.25 lukem tval[1].tv_usec = 0;
1299 1.31 lukem (*closefunc)(fout);
1300 1.31 lukem fout = NULL;
1301 1.31 lukem
1302 1.31 lukem if (utimes(savefile, tval) == -1) {
1303 1.25 lukem fprintf(ttyout,
1304 1.25 lukem "Can't change modification time to %s",
1305 1.25 lukem asctime(localtime(&mtime)));
1306 1.25 lukem }
1307 1.25 lukem }
1308 1.25 lukem if (bytes > 0)
1309 1.25 lukem ptransfer(0);
1310 1.1 lukem
1311 1.42 lukem rval = 0;
1312 1.42 lukem goto cleanup_fetch_url;
1313 1.11 lukem
1314 1.1 lukem improper:
1315 1.27 lukem warnx("Improper response from `%s'", host);
1316 1.11 lukem
1317 1.42 lukem cleanup_fetch_url:
1318 1.86 lukem if (oldintr)
1319 1.86 lukem (void)xsignal(SIGINT, oldintr);
1320 1.86 lukem if (oldintp)
1321 1.86 lukem (void)xsignal(SIGPIPE, oldintp);
1322 1.24 lukem if (fin != NULL)
1323 1.24 lukem fclose(fin);
1324 1.24 lukem else if (s != -1)
1325 1.1 lukem close(s);
1326 1.22 lukem if (closefunc != NULL && fout != NULL)
1327 1.22 lukem (*closefunc)(fout);
1328 1.29 lukem FREEPTR(savefile);
1329 1.27 lukem FREEPTR(user);
1330 1.27 lukem FREEPTR(pass);
1331 1.27 lukem FREEPTR(host);
1332 1.60 itojun FREEPTR(port);
1333 1.27 lukem FREEPTR(path);
1334 1.50 lukem FREEPTR(decodedpath);
1335 1.54 lukem FREEPTR(puser);
1336 1.54 lukem FREEPTR(ppass);
1337 1.27 lukem FREEPTR(buf);
1338 1.44 lukem FREEPTR(auth);
1339 1.42 lukem FREEPTR(location);
1340 1.42 lukem FREEPTR(message);
1341 1.42 lukem return (rval);
1342 1.1 lukem }
1343 1.1 lukem
1344 1.1 lukem /*
1345 1.50 lukem * Abort a HTTP retrieval
1346 1.2 lukem */
1347 1.2 lukem void
1348 1.3 lukem aborthttp(notused)
1349 1.3 lukem int notused;
1350 1.2 lukem {
1351 1.88 lukem char msgbuf[100];
1352 1.88 lukem int len;
1353 1.2 lukem
1354 1.2 lukem alarmtimer(0);
1355 1.88 lukem len = strlcpy(msgbuf, "\nHTTP fetch aborted.\n", sizeof(msgbuf));
1356 1.88 lukem write(fileno(ttyout), msgbuf, len);
1357 1.88 lukem siglongjmp(httpabort, 1);
1358 1.2 lukem }
1359 1.2 lukem
1360 1.2 lukem /*
1361 1.50 lukem * Retrieve ftp URL or classic ftp argument using FTP.
1362 1.63 lukem * Returns 1 on failure, 0 on completed xfer, -1 if ftp connection
1363 1.42 lukem * is still open (e.g, ftp xfer with trailing /)
1364 1.42 lukem */
1365 1.42 lukem static int
1366 1.52 lukem fetch_ftp(url)
1367 1.42 lukem const char *url;
1368 1.42 lukem {
1369 1.42 lukem char *cp, *xargv[5], rempath[MAXPATHLEN];
1370 1.42 lukem char *host, *path, *dir, *file, *user, *pass;
1371 1.60 itojun char *port;
1372 1.82 lukem int dirhasglob, filehasglob, oautologin, rval, type, xargc;
1373 1.82 lukem in_port_t portnum;
1374 1.82 lukem url_t urltype;
1375 1.42 lukem
1376 1.42 lukem host = path = dir = file = user = pass = NULL;
1377 1.60 itojun port = NULL;
1378 1.42 lukem rval = 1;
1379 1.53 lukem type = TYPE_I;
1380 1.42 lukem
1381 1.42 lukem if (strncasecmp(url, FTP_URL, sizeof(FTP_URL) - 1) == 0) {
1382 1.42 lukem if ((parse_url(url, "URL", &urltype, &user, &pass,
1383 1.82 lukem &host, &port, &portnum, &path) == -1) ||
1384 1.42 lukem (user != NULL && *user == '\0') ||
1385 1.42 lukem (pass != NULL && *pass == '\0') ||
1386 1.42 lukem EMPTYSTRING(host)) {
1387 1.42 lukem warnx("Invalid URL `%s'", url);
1388 1.42 lukem goto cleanup_fetch_ftp;
1389 1.42 lukem }
1390 1.50 lukem url_decode(user);
1391 1.50 lukem url_decode(pass);
1392 1.53 lukem /*
1393 1.53 lukem * Note: Don't url_decode(path) here. We need to keep the
1394 1.53 lukem * distinction between "/" and "%2F" until later.
1395 1.53 lukem */
1396 1.53 lukem
1397 1.53 lukem /* check for trailing ';type=[aid]' */
1398 1.63 lukem if (! EMPTYSTRING(path) && (cp = strrchr(path, ';')) != NULL) {
1399 1.53 lukem if (strcasecmp(cp, ";type=a") == 0)
1400 1.53 lukem type = TYPE_A;
1401 1.53 lukem else if (strcasecmp(cp, ";type=i") == 0)
1402 1.53 lukem type = TYPE_I;
1403 1.53 lukem else if (strcasecmp(cp, ";type=d") == 0) {
1404 1.53 lukem warnx(
1405 1.53 lukem "Directory listing via a URL is not supported");
1406 1.53 lukem goto cleanup_fetch_ftp;
1407 1.53 lukem } else {
1408 1.53 lukem warnx("Invalid suffix `%s' in URL `%s'", cp,
1409 1.53 lukem url);
1410 1.53 lukem goto cleanup_fetch_ftp;
1411 1.53 lukem }
1412 1.53 lukem *cp = 0;
1413 1.53 lukem }
1414 1.97 lukem } else { /* classic style `[user@]host:[file]' */
1415 1.53 lukem urltype = CLASSIC_URL_T;
1416 1.42 lukem host = xstrdup(url);
1417 1.97 lukem cp = strchr(host, '@');
1418 1.97 lukem if (cp != NULL) {
1419 1.97 lukem *cp = '\0';
1420 1.97 lukem user = host;
1421 1.97 lukem anonftp = 0; /* disable anonftp */
1422 1.97 lukem host = xstrdup(cp + 1);
1423 1.97 lukem }
1424 1.42 lukem cp = strchr(host, ':');
1425 1.42 lukem if (cp != NULL) {
1426 1.42 lukem *cp = '\0';
1427 1.42 lukem path = xstrdup(cp + 1);
1428 1.42 lukem }
1429 1.42 lukem }
1430 1.42 lukem if (EMPTYSTRING(host))
1431 1.42 lukem goto cleanup_fetch_ftp;
1432 1.42 lukem
1433 1.50 lukem /* Extract the file and (if present) directory name. */
1434 1.42 lukem dir = path;
1435 1.42 lukem if (! EMPTYSTRING(dir)) {
1436 1.53 lukem /*
1437 1.97 lukem * If we are dealing with classic `[user@]host:[path]' syntax,
1438 1.97 lukem * then a path of the form `/file' (resulting from input of the
1439 1.97 lukem * form `host:/file') means that we should do "CWD /" before
1440 1.97 lukem * retrieving the file. So we set dir="/" and file="file".
1441 1.53 lukem *
1442 1.97 lukem * But if we are dealing with URLs like `ftp://host/path' then
1443 1.97 lukem * a path of the form `/file' (resulting from a URL of the form
1444 1.97 lukem * `ftp://host//file') means that we should do `CWD ' (with an
1445 1.97 lukem * empty argument) before retrieving the file. So we set
1446 1.53 lukem * dir="" and file="file".
1447 1.53 lukem *
1448 1.97 lukem * If the path does not contain / at all, we set dir=NULL.
1449 1.97 lukem * (We get a path without any slashes if we are dealing with
1450 1.97 lukem * classic `[user@]host:[file]' or URL `ftp://host/file'.)
1451 1.53 lukem *
1452 1.97 lukem * In all other cases, we set dir to a string that does not
1453 1.97 lukem * include the final '/' that separates the dir part from the
1454 1.97 lukem * file part of the path. (This will be the empty string if
1455 1.97 lukem * and only if we are dealing with a path of the form `/file'
1456 1.97 lukem * resulting from an URL of the form `ftp://host//file'.)
1457 1.53 lukem */
1458 1.42 lukem cp = strrchr(dir, '/');
1459 1.53 lukem if (cp == dir && urltype == CLASSIC_URL_T) {
1460 1.50 lukem file = cp + 1;
1461 1.50 lukem dir = "/";
1462 1.50 lukem } else if (cp != NULL) {
1463 1.42 lukem *cp++ = '\0';
1464 1.42 lukem file = cp;
1465 1.42 lukem } else {
1466 1.42 lukem file = dir;
1467 1.42 lukem dir = NULL;
1468 1.42 lukem }
1469 1.63 lukem } else
1470 1.63 lukem dir = NULL;
1471 1.53 lukem if (urltype == FTP_URL_T && file != NULL) {
1472 1.53 lukem url_decode(file);
1473 1.53 lukem /* but still don't url_decode(dir) */
1474 1.53 lukem }
1475 1.42 lukem if (debug)
1476 1.42 lukem fprintf(ttyout,
1477 1.107 itojun "fetch_ftp: user `%s' pass `%s' host %s port %s "
1478 1.107 itojun "path `%s' dir `%s' file `%s'\n",
1479 1.53 lukem user ? user : "<null>", pass ? pass : "<null>",
1480 1.60 itojun host ? host : "<null>", port ? port : "<null>",
1481 1.60 itojun path ? path : "<null>",
1482 1.53 lukem dir ? dir : "<null>", file ? file : "<null>");
1483 1.42 lukem
1484 1.42 lukem dirhasglob = filehasglob = 0;
1485 1.53 lukem if (doglob && urltype == CLASSIC_URL_T) {
1486 1.42 lukem if (! EMPTYSTRING(dir) && strpbrk(dir, "*?[]{}") != NULL)
1487 1.42 lukem dirhasglob = 1;
1488 1.42 lukem if (! EMPTYSTRING(file) && strpbrk(file, "*?[]{}") != NULL)
1489 1.42 lukem filehasglob = 1;
1490 1.42 lukem }
1491 1.42 lukem
1492 1.50 lukem /* Set up the connection */
1493 1.50 lukem if (connected)
1494 1.50 lukem disconnect(0, NULL);
1495 1.50 lukem xargv[0] = __progname;
1496 1.50 lukem xargv[1] = host;
1497 1.50 lukem xargv[2] = NULL;
1498 1.50 lukem xargc = 2;
1499 1.50 lukem if (port) {
1500 1.60 itojun xargv[2] = port;
1501 1.50 lukem xargv[3] = NULL;
1502 1.50 lukem xargc = 3;
1503 1.50 lukem }
1504 1.50 lukem oautologin = autologin;
1505 1.50 lukem if (user != NULL)
1506 1.50 lukem autologin = 0;
1507 1.50 lukem setpeer(xargc, xargv);
1508 1.50 lukem autologin = oautologin;
1509 1.50 lukem if ((connected == 0) || ((connected == 1)
1510 1.50 lukem && !ftp_login(host, user, pass))) {
1511 1.50 lukem warnx("Can't connect or login to host `%s'", host);
1512 1.50 lukem goto cleanup_fetch_ftp;
1513 1.50 lukem }
1514 1.42 lukem
1515 1.53 lukem switch (type) {
1516 1.53 lukem case TYPE_A:
1517 1.53 lukem setascii(0, NULL);
1518 1.53 lukem break;
1519 1.53 lukem case TYPE_I:
1520 1.53 lukem setbinary(0, NULL);
1521 1.53 lukem break;
1522 1.53 lukem default:
1523 1.91 lukem errx(1, "fetch_ftp: unknown transfer type %d", type);
1524 1.53 lukem }
1525 1.53 lukem
1526 1.63 lukem /*
1527 1.63 lukem * Change directories, if necessary.
1528 1.63 lukem *
1529 1.63 lukem * Note: don't use EMPTYSTRING(dir) below, because
1530 1.63 lukem * dir=="" means something different from dir==NULL.
1531 1.63 lukem */
1532 1.53 lukem if (dir != NULL && !dirhasglob) {
1533 1.53 lukem char *nextpart;
1534 1.42 lukem
1535 1.53 lukem /*
1536 1.97 lukem * If we are dealing with a classic `[user@]host:[path]'
1537 1.97 lukem * (urltype is CLASSIC_URL_T) then we have a raw directory
1538 1.53 lukem * name (not encoded in any way) and we can change
1539 1.53 lukem * directories in one step.
1540 1.53 lukem *
1541 1.53 lukem * If we are dealing with an `ftp://host/path' URL
1542 1.53 lukem * (urltype is FTP_URL_T), then RFC 1738 says we need to
1543 1.53 lukem * send a separate CWD command for each unescaped "/"
1544 1.53 lukem * in the path, and we have to interpret %hex escaping
1545 1.53 lukem * *after* we find the slashes. It's possible to get
1546 1.53 lukem * empty components here, (from multiple adjacent
1547 1.53 lukem * slashes in the path) and RFC 1738 says that we should
1548 1.53 lukem * still do `CWD ' (with a null argument) in such cases.
1549 1.53 lukem *
1550 1.63 lukem * Many ftp servers don't support `CWD ', so if there's an
1551 1.63 lukem * error performing that command, bail out with a descriptive
1552 1.63 lukem * message.
1553 1.53 lukem *
1554 1.53 lukem * Examples:
1555 1.53 lukem *
1556 1.63 lukem * host: dir="", urltype=CLASSIC_URL_T
1557 1.63 lukem * logged in (to default directory)
1558 1.53 lukem * host:file dir=NULL, urltype=CLASSIC_URL_T
1559 1.53 lukem * "RETR file"
1560 1.63 lukem * host:dir/ dir="dir", urltype=CLASSIC_URL_T
1561 1.63 lukem * "CWD dir", logged in
1562 1.63 lukem * ftp://host/ dir="", urltype=FTP_URL_T
1563 1.63 lukem * logged in (to default directory)
1564 1.63 lukem * ftp://host/dir/ dir="dir", urltype=FTP_URL_T
1565 1.63 lukem * "CWD dir", logged in
1566 1.53 lukem * ftp://host/file dir=NULL, urltype=FTP_URL_T
1567 1.53 lukem * "RETR file"
1568 1.53 lukem * ftp://host//file dir="", urltype=FTP_URL_T
1569 1.63 lukem * "CWD ", "RETR file"
1570 1.53 lukem * host:/file dir="/", urltype=CLASSIC_URL_T
1571 1.53 lukem * "CWD /", "RETR file"
1572 1.53 lukem * ftp://host///file dir="/", urltype=FTP_URL_T
1573 1.63 lukem * "CWD ", "CWD ", "RETR file"
1574 1.53 lukem * ftp://host/%2F/file dir="%2F", urltype=FTP_URL_T
1575 1.53 lukem * "CWD /", "RETR file"
1576 1.53 lukem * ftp://host/foo/file dir="foo", urltype=FTP_URL_T
1577 1.53 lukem * "CWD foo", "RETR file"
1578 1.53 lukem * ftp://host/foo/bar/file dir="foo/bar"
1579 1.53 lukem * "CWD foo", "CWD bar", "RETR file"
1580 1.53 lukem * ftp://host//foo/bar/file dir="/foo/bar"
1581 1.63 lukem * "CWD ", "CWD foo", "CWD bar", "RETR file"
1582 1.53 lukem * ftp://host/foo//bar/file dir="foo//bar"
1583 1.63 lukem * "CWD foo", "CWD ", "CWD bar", "RETR file"
1584 1.53 lukem * ftp://host/%2F/foo/bar/file dir="%2F/foo/bar"
1585 1.53 lukem * "CWD /", "CWD foo", "CWD bar", "RETR file"
1586 1.53 lukem * ftp://host/%2Ffoo/bar/file dir="%2Ffoo/bar"
1587 1.53 lukem * "CWD /foo", "CWD bar", "RETR file"
1588 1.53 lukem * ftp://host/%2Ffoo%2Fbar/file dir="%2Ffoo%2Fbar"
1589 1.53 lukem * "CWD /foo/bar", "RETR file"
1590 1.53 lukem * ftp://host/%2Ffoo%2Fbar%2Ffile dir=NULL
1591 1.53 lukem * "RETR /foo/bar/file"
1592 1.53 lukem *
1593 1.53 lukem * Note that we don't need `dir' after this point.
1594 1.53 lukem */
1595 1.53 lukem do {
1596 1.53 lukem if (urltype == FTP_URL_T) {
1597 1.53 lukem nextpart = strchr(dir, '/');
1598 1.53 lukem if (nextpart) {
1599 1.53 lukem *nextpart = '\0';
1600 1.53 lukem nextpart++;
1601 1.53 lukem }
1602 1.53 lukem url_decode(dir);
1603 1.53 lukem } else
1604 1.53 lukem nextpart = NULL;
1605 1.53 lukem if (debug)
1606 1.53 lukem fprintf(ttyout, "dir `%s', nextpart `%s'\n",
1607 1.53 lukem dir ? dir : "<null>",
1608 1.53 lukem nextpart ? nextpart : "<null>");
1609 1.63 lukem if (urltype == FTP_URL_T || *dir != '\0') {
1610 1.53 lukem xargv[0] = "cd";
1611 1.53 lukem xargv[1] = dir;
1612 1.53 lukem xargv[2] = NULL;
1613 1.53 lukem dirchange = 0;
1614 1.53 lukem cd(2, xargv);
1615 1.63 lukem if (! dirchange) {
1616 1.63 lukem if (*dir == '\0' && code == 500)
1617 1.63 lukem fprintf(stderr,
1618 1.63 lukem "\n"
1619 1.63 lukem "ftp: The `CWD ' command (without a directory), which is required by\n"
1620 1.63 lukem " RFC 1738 to support the empty directory in the URL pathname (`//'),\n"
1621 1.63 lukem " conflicts with the server's conformance to RFC 959.\n"
1622 1.63 lukem " Try the same URL without the `//' in the URL pathname.\n"
1623 1.63 lukem "\n");
1624 1.53 lukem goto cleanup_fetch_ftp;
1625 1.63 lukem }
1626 1.53 lukem }
1627 1.53 lukem dir = nextpart;
1628 1.53 lukem } while (dir != NULL);
1629 1.42 lukem }
1630 1.42 lukem
1631 1.42 lukem if (EMPTYSTRING(file)) {
1632 1.42 lukem rval = -1;
1633 1.42 lukem goto cleanup_fetch_ftp;
1634 1.42 lukem }
1635 1.42 lukem
1636 1.42 lukem if (dirhasglob) {
1637 1.78 lukem (void)strlcpy(rempath, dir, sizeof(rempath));
1638 1.78 lukem (void)strlcat(rempath, "/", sizeof(rempath));
1639 1.78 lukem (void)strlcat(rempath, file, sizeof(rempath));
1640 1.42 lukem file = rempath;
1641 1.42 lukem }
1642 1.42 lukem
1643 1.42 lukem /* Fetch the file(s). */
1644 1.42 lukem xargc = 2;
1645 1.42 lukem xargv[0] = "get";
1646 1.42 lukem xargv[1] = file;
1647 1.42 lukem xargv[2] = NULL;
1648 1.42 lukem if (dirhasglob || filehasglob) {
1649 1.42 lukem int ointeractive;
1650 1.42 lukem
1651 1.42 lukem ointeractive = interactive;
1652 1.42 lukem interactive = 0;
1653 1.42 lukem xargv[0] = "mget";
1654 1.42 lukem mget(xargc, xargv);
1655 1.42 lukem interactive = ointeractive;
1656 1.42 lukem } else {
1657 1.53 lukem if (outfile == NULL) {
1658 1.53 lukem cp = strrchr(file, '/'); /* find savefile */
1659 1.53 lukem if (cp != NULL)
1660 1.53 lukem outfile = cp + 1;
1661 1.53 lukem else
1662 1.53 lukem outfile = file;
1663 1.42 lukem }
1664 1.53 lukem xargv[2] = (char *)outfile;
1665 1.53 lukem xargv[3] = NULL;
1666 1.53 lukem xargc++;
1667 1.52 lukem if (restartautofetch)
1668 1.52 lukem reget(xargc, xargv);
1669 1.52 lukem else
1670 1.52 lukem get(xargc, xargv);
1671 1.42 lukem }
1672 1.42 lukem
1673 1.42 lukem if ((code / 100) == COMPLETE)
1674 1.42 lukem rval = 0;
1675 1.42 lukem
1676 1.42 lukem cleanup_fetch_ftp:
1677 1.42 lukem FREEPTR(host);
1678 1.42 lukem FREEPTR(path);
1679 1.42 lukem FREEPTR(user);
1680 1.42 lukem FREEPTR(pass);
1681 1.42 lukem return (rval);
1682 1.42 lukem }
1683 1.42 lukem
1684 1.42 lukem /*
1685 1.42 lukem * Retrieve the given file to outfile.
1686 1.42 lukem * Supports arguments of the form:
1687 1.42 lukem * "host:path", "ftp://host/path" if $ftpproxy, call fetch_url() else
1688 1.42 lukem * call fetch_ftp()
1689 1.50 lukem * "http://host/path" call fetch_url() to use HTTP
1690 1.42 lukem * "file:///path" call fetch_url() to copy
1691 1.42 lukem * "about:..." print a message
1692 1.42 lukem *
1693 1.42 lukem * Returns 1 on failure, 0 on completed xfer, -1 if ftp connection
1694 1.42 lukem * is still open (e.g, ftp xfer with trailing /)
1695 1.42 lukem */
1696 1.42 lukem static int
1697 1.52 lukem go_fetch(url)
1698 1.42 lukem const char *url;
1699 1.42 lukem {
1700 1.91 lukem char *proxy;
1701 1.42 lukem
1702 1.42 lukem /*
1703 1.42 lukem * Check for about:*
1704 1.42 lukem */
1705 1.42 lukem if (strncasecmp(url, ABOUT_URL, sizeof(ABOUT_URL) - 1) == 0) {
1706 1.42 lukem url += sizeof(ABOUT_URL) -1;
1707 1.42 lukem if (strcasecmp(url, "ftp") == 0) {
1708 1.87 lukem fputs(
1709 1.87 lukem "This version of ftp has been enhanced by Luke Mewburn <lukem (at) netbsd.org>\n"
1710 1.87 lukem "for the NetBSD project. Execute `man ftp' for more details.\n", ttyout);
1711 1.87 lukem } else if (strcasecmp(url, "lukem") == 0) {
1712 1.87 lukem fputs(
1713 1.87 lukem "Luke Mewburn is the author of most of the enhancements in this ftp client.\n"
1714 1.87 lukem "Please email feedback to <lukem (at) netbsd.org>.\n", ttyout);
1715 1.42 lukem } else if (strcasecmp(url, "netbsd") == 0) {
1716 1.87 lukem fputs(
1717 1.87 lukem "NetBSD is a freely available and redistributable UNIX-like operating system.\n"
1718 1.87 lukem "For more information, see http://www.netbsd.org/index.html\n", ttyout);
1719 1.92 lukem } else if (strcasecmp(url, "version") == 0) {
1720 1.94 lukem fprintf(ttyout, "Version: %s %s\n",
1721 1.94 lukem FTP_PRODUCT, FTP_VERSION);
1722 1.42 lukem } else {
1723 1.42 lukem fprintf(ttyout, "`%s' is an interesting topic.\n", url);
1724 1.42 lukem }
1725 1.92 lukem fputs("\n", ttyout);
1726 1.42 lukem return (0);
1727 1.42 lukem }
1728 1.42 lukem
1729 1.42 lukem /*
1730 1.42 lukem * Check for file:// and http:// URLs.
1731 1.42 lukem */
1732 1.42 lukem if (strncasecmp(url, HTTP_URL, sizeof(HTTP_URL) - 1) == 0 ||
1733 1.42 lukem strncasecmp(url, FILE_URL, sizeof(FILE_URL) - 1) == 0)
1734 1.52 lukem return (fetch_url(url, NULL, NULL, NULL));
1735 1.42 lukem
1736 1.42 lukem /*
1737 1.42 lukem * Try FTP URL-style and host:file arguments next.
1738 1.42 lukem * If ftpproxy is set with an FTP URL, use fetch_url()
1739 1.42 lukem * Othewise, use fetch_ftp().
1740 1.42 lukem */
1741 1.91 lukem proxy = getoptionvalue("ftp_proxy");
1742 1.91 lukem if (!EMPTYSTRING(proxy) &&
1743 1.91 lukem strncasecmp(url, FTP_URL, sizeof(FTP_URL) - 1) == 0)
1744 1.52 lukem return (fetch_url(url, NULL, NULL, NULL));
1745 1.42 lukem
1746 1.52 lukem return (fetch_ftp(url));
1747 1.42 lukem }
1748 1.42 lukem
1749 1.42 lukem /*
1750 1.42 lukem * Retrieve multiple files from the command line,
1751 1.42 lukem * calling go_fetch() for each file.
1752 1.42 lukem *
1753 1.42 lukem * If an ftp path has a trailing "/", the path will be cd-ed into and
1754 1.41 lukem * the connection remains open, and the function will return -1
1755 1.41 lukem * (to indicate the connection is alive).
1756 1.1 lukem * If an error occurs the return value will be the offset+1 in
1757 1.1 lukem * argv[] of the file that caused a problem (i.e, argv[x]
1758 1.1 lukem * returns x+1)
1759 1.1 lukem * Otherwise, 0 is returned if all files retrieved successfully.
1760 1.1 lukem */
1761 1.1 lukem int
1762 1.52 lukem auto_fetch(argc, argv)
1763 1.1 lukem int argc;
1764 1.1 lukem char *argv[];
1765 1.1 lukem {
1766 1.42 lukem volatile int argpos;
1767 1.42 lukem int rval;
1768 1.22 lukem
1769 1.2 lukem argpos = 0;
1770 1.1 lukem
1771 1.88 lukem if (sigsetjmp(toplevel, 1)) {
1772 1.2 lukem if (connected)
1773 1.2 lukem disconnect(0, NULL);
1774 1.3 lukem return (argpos + 1);
1775 1.2 lukem }
1776 1.88 lukem (void)xsignal(SIGINT, intr);
1777 1.91 lukem (void)xsignal(SIGPIPE, lostpeer);
1778 1.1 lukem
1779 1.1 lukem /*
1780 1.1 lukem * Loop through as long as there's files to fetch.
1781 1.1 lukem */
1782 1.27 lukem for (rval = 0; (rval == 0) && (argpos < argc); argpos++) {
1783 1.1 lukem if (strchr(argv[argpos], ':') == NULL)
1784 1.1 lukem break;
1785 1.42 lukem redirect_loop = 0;
1786 1.90 lukem if (!anonftp)
1787 1.90 lukem anonftp = 2; /* Handle "automatic" transfers. */
1788 1.52 lukem rval = go_fetch(argv[argpos]);
1789 1.52 lukem if (outfile != NULL && strcmp(outfile, "-") != 0
1790 1.52 lukem && outfile[0] != '|')
1791 1.52 lukem outfile = NULL;
1792 1.42 lukem if (rval > 0)
1793 1.1 lukem rval = argpos + 1;
1794 1.42 lukem }
1795 1.3 lukem
1796 1.1 lukem if (connected && rval != -1)
1797 1.1 lukem disconnect(0, NULL);
1798 1.1 lukem return (rval);
1799 1.1 lukem }
1800