fetch.c revision 1.69 1 1.69 mycroft /* $NetBSD: fetch.c,v 1.69 1999/09/14 22:49:14 mycroft Exp $ */
2 1.1 lukem
3 1.1 lukem /*-
4 1.50 lukem * Copyright (c) 1997, 1998, 1999 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.1 lukem * This product includes software developed by the NetBSD
21 1.1 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.69 mycroft __RCSID("$NetBSD: fetch.c,v 1.69 1999/09/14 22:49:14 mycroft 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.43 lukem #include <sys/utsname.h>
54 1.1 lukem
55 1.1 lukem #include <netinet/in.h>
56 1.1 lukem
57 1.2 lukem #include <arpa/ftp.h>
58 1.1 lukem #include <arpa/inet.h>
59 1.1 lukem
60 1.1 lukem #include <ctype.h>
61 1.1 lukem #include <err.h>
62 1.22 lukem #include <errno.h>
63 1.1 lukem #include <netdb.h>
64 1.1 lukem #include <fcntl.h>
65 1.3 lukem #include <signal.h>
66 1.1 lukem #include <stdio.h>
67 1.1 lukem #include <stdlib.h>
68 1.1 lukem #include <string.h>
69 1.1 lukem #include <unistd.h>
70 1.57 christos #include <time.h>
71 1.24 lukem #include <util.h>
72 1.1 lukem
73 1.1 lukem #include "ftp_var.h"
74 1.1 lukem
75 1.27 lukem typedef enum {
76 1.27 lukem UNKNOWN_URL_T=-1,
77 1.27 lukem HTTP_URL_T,
78 1.27 lukem FTP_URL_T,
79 1.53 lukem FILE_URL_T,
80 1.53 lukem CLASSIC_URL_T
81 1.27 lukem } url_t;
82 1.27 lukem
83 1.50 lukem void aborthttp __P((int));
84 1.54 lukem static int auth_url __P((const char *, char **, const char *,
85 1.54 lukem const char *));
86 1.50 lukem static void base64_encode __P((const char *, size_t, char *));
87 1.52 lukem static int go_fetch __P((const char *));
88 1.52 lukem static int fetch_ftp __P((const char *));
89 1.52 lukem static int fetch_url __P((const char *, const char *, char *, char *));
90 1.27 lukem static int parse_url __P((const char *, const char *, url_t *, char **,
91 1.60 itojun char **, char **, char **, 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.1 lukem #define EMPTYSTRING(x) ((x) == NULL || (*(x) == '\0'))
104 1.27 lukem #define FREEPTR(x) if ((x) != NULL) { free(x); (x) = NULL; }
105 1.27 lukem
106 1.27 lukem /*
107 1.44 lukem * Generate authorization response based on given authentication challenge.
108 1.44 lukem * Returns -1 if an error occurred, otherwise 0.
109 1.44 lukem * Sets response to a malloc(3)ed string; caller should free.
110 1.44 lukem */
111 1.44 lukem static int
112 1.54 lukem auth_url(challenge, response, guser, gpass)
113 1.44 lukem const char *challenge;
114 1.44 lukem char **response;
115 1.54 lukem const char *guser;
116 1.54 lukem const char *gpass;
117 1.44 lukem {
118 1.44 lukem char *cp, *ep, *clear, *line, *realm, *scheme;
119 1.44 lukem char user[BUFSIZ], *pass;
120 1.44 lukem int rval;
121 1.44 lukem size_t len;
122 1.44 lukem
123 1.44 lukem *response = NULL;
124 1.44 lukem clear = realm = scheme = NULL;
125 1.44 lukem rval = -1;
126 1.44 lukem line = xstrdup(challenge);
127 1.44 lukem cp = line;
128 1.44 lukem
129 1.44 lukem if (debug)
130 1.44 lukem fprintf(ttyout, "auth_url: challenge `%s'\n", challenge);
131 1.44 lukem
132 1.44 lukem scheme = strsep(&cp, " ");
133 1.44 lukem #define SCHEME_BASIC "Basic"
134 1.44 lukem if (strncasecmp(scheme, SCHEME_BASIC, sizeof(SCHEME_BASIC) - 1) != 0) {
135 1.44 lukem warnx("Unsupported WWW Authentication challenge - `%s'",
136 1.44 lukem challenge);
137 1.44 lukem goto cleanup_auth_url;
138 1.44 lukem }
139 1.44 lukem cp += strspn(cp, " ");
140 1.44 lukem
141 1.44 lukem #define REALM "realm=\""
142 1.44 lukem if (strncasecmp(cp, REALM, sizeof(REALM) - 1) == 0)
143 1.44 lukem cp += sizeof(REALM) - 1;
144 1.44 lukem else {
145 1.44 lukem warnx("Unsupported WWW Authentication challenge - `%s'",
146 1.44 lukem challenge);
147 1.44 lukem goto cleanup_auth_url;
148 1.44 lukem }
149 1.44 lukem if ((ep = strchr(cp, '\"')) != NULL) {
150 1.44 lukem size_t len = ep - cp;
151 1.44 lukem
152 1.44 lukem realm = (char *)xmalloc(len + 1);
153 1.44 lukem strncpy(realm, cp, len);
154 1.44 lukem realm[len] = '\0';
155 1.44 lukem } else {
156 1.44 lukem warnx("Unsupported WWW Authentication challenge - `%s'",
157 1.44 lukem challenge);
158 1.44 lukem goto cleanup_auth_url;
159 1.44 lukem }
160 1.44 lukem
161 1.54 lukem if (guser != NULL) {
162 1.54 lukem strncpy(user, guser, sizeof(user) - 1);
163 1.54 lukem user[sizeof(user) - 1] = '\0';
164 1.54 lukem } else {
165 1.54 lukem fprintf(ttyout, "Username for `%s': ", realm);
166 1.54 lukem (void)fflush(ttyout);
167 1.54 lukem if (fgets(user, sizeof(user) - 1, stdin) == NULL)
168 1.54 lukem goto cleanup_auth_url;
169 1.54 lukem user[strlen(user) - 1] = '\0';
170 1.54 lukem }
171 1.54 lukem if (gpass != NULL)
172 1.54 lukem pass = (char *)gpass;
173 1.54 lukem else
174 1.54 lukem pass = getpass("Password: ");
175 1.44 lukem
176 1.64 lukem len = strlen(user) + strlen(pass) + 2; /* user + ":" + pass + "\0" */
177 1.64 lukem clear = (char *)xmalloc(len);
178 1.55 lukem snprintf(clear, len, "%s:%s", user, pass);
179 1.54 lukem if (gpass == NULL)
180 1.54 lukem memset(pass, '\0', strlen(pass));
181 1.44 lukem
182 1.64 lukem /* scheme + " " + enc + "\0" */
183 1.64 lukem len = strlen(scheme) + 1 + (len + 2) * 4 / 3 + 1;
184 1.64 lukem *response = (char *)xmalloc(len);
185 1.55 lukem len = snprintf(*response, len, "%s ", scheme);
186 1.50 lukem base64_encode(clear, strlen(clear), *response + len);
187 1.54 lukem memset(clear, '\0', strlen(clear));
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.44 lukem char *cp;
210 1.44 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.50 lukem p = q = url;
238 1.50 lukem
239 1.50 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.63 lukem * IPv6 address (as per draft-ietf-ipngwg-url-literal-01.txt).
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.27 lukem parse_url(url, desc, type, user, pass, host, port, 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.27 lukem char **path;
294 1.27 lukem {
295 1.63 lukem char *cp, *ep, *thost, *tport;
296 1.50 lukem size_t len;
297 1.27 lukem
298 1.27 lukem if (url == NULL || desc == NULL || type == NULL || user == NULL
299 1.27 lukem || pass == NULL || host == NULL || port == NULL || path == NULL)
300 1.27 lukem errx(1, "parse_url: invoked with NULL argument!");
301 1.27 lukem
302 1.27 lukem *type = UNKNOWN_URL_T;
303 1.63 lukem *user = *pass = *host = *port = *path = NULL;
304 1.63 lukem tport = NULL;
305 1.27 lukem
306 1.27 lukem if (strncasecmp(url, HTTP_URL, sizeof(HTTP_URL) - 1) == 0) {
307 1.27 lukem url += sizeof(HTTP_URL) - 1;
308 1.27 lukem *type = HTTP_URL_T;
309 1.63 lukem tport = httpport;
310 1.27 lukem } else if (strncasecmp(url, FTP_URL, sizeof(FTP_URL) - 1) == 0) {
311 1.27 lukem url += sizeof(FTP_URL) - 1;
312 1.27 lukem *type = FTP_URL_T;
313 1.63 lukem tport = ftpport;
314 1.27 lukem } else if (strncasecmp(url, FILE_URL, sizeof(FILE_URL) - 1) == 0) {
315 1.27 lukem url += sizeof(FILE_URL) - 1;
316 1.27 lukem *type = FILE_URL_T;
317 1.27 lukem } else {
318 1.27 lukem warnx("Invalid %s `%s'", desc, url);
319 1.27 lukem cleanup_parse_url:
320 1.27 lukem FREEPTR(*user);
321 1.27 lukem FREEPTR(*pass);
322 1.27 lukem FREEPTR(*host);
323 1.60 itojun FREEPTR(*port);
324 1.27 lukem FREEPTR(*path);
325 1.27 lukem return (-1);
326 1.27 lukem }
327 1.27 lukem
328 1.27 lukem if (*url == '\0')
329 1.27 lukem return (0);
330 1.27 lukem
331 1.27 lukem /* find [user[:pass]@]host[:port] */
332 1.27 lukem ep = strchr(url, '/');
333 1.27 lukem if (ep == NULL)
334 1.27 lukem thost = xstrdup(url);
335 1.27 lukem else {
336 1.50 lukem len = ep - url;
337 1.27 lukem thost = (char *)xmalloc(len + 1);
338 1.27 lukem strncpy(thost, url, len);
339 1.27 lukem thost[len] = '\0';
340 1.53 lukem if (*type == FTP_URL_T) /* skip first / for ftp URLs */
341 1.53 lukem ep++;
342 1.27 lukem *path = xstrdup(ep);
343 1.27 lukem }
344 1.27 lukem
345 1.63 lukem cp = strchr(thost, '@'); /* look for user[:pass]@ in URLs */
346 1.54 lukem if (cp != NULL) {
347 1.54 lukem if (*type == FTP_URL_T)
348 1.54 lukem anonftp = 0; /* disable anonftp */
349 1.27 lukem *user = thost;
350 1.27 lukem *cp = '\0';
351 1.63 lukem thost = xstrdup(cp + 1);
352 1.27 lukem cp = strchr(*user, ':');
353 1.27 lukem if (cp != NULL) {
354 1.27 lukem *cp = '\0';
355 1.27 lukem *pass = xstrdup(cp + 1);
356 1.27 lukem }
357 1.63 lukem }
358 1.63 lukem
359 1.63 lukem #ifdef INET6
360 1.63 lukem /*
361 1.63 lukem * Check if thost is an encoded IPv6 address, as per
362 1.63 lukem * draft-ietf-ipngwg-url-literal-01.txt:
363 1.63 lukem * `[' ipv6-address ']'
364 1.63 lukem */
365 1.63 lukem if (*thost == '[') {
366 1.63 lukem cp = thost + 1;
367 1.63 lukem if ((ep = strchr(cp, ']')) == NULL ||
368 1.63 lukem (ep[1] != '\0' && ep[1] != '\0')) {
369 1.63 lukem warnx("Invalid address `%s' in %s `%s'",
370 1.63 lukem thost, desc, url);
371 1.63 lukem goto cleanup_parse_url;
372 1.63 lukem }
373 1.63 lukem len = ep - cp; /* change `[xxx]' -> `xxx' */
374 1.63 lukem memmove(thost, thost + 1, len);
375 1.63 lukem thost[len] = '\0';
376 1.63 lukem if (! isipv6addr(thost)) {
377 1.63 lukem warnx("Invalid IPv6 address `%s' in %s `%s'",
378 1.63 lukem thost, desc, url);
379 1.63 lukem goto cleanup_parse_url;
380 1.63 lukem }
381 1.63 lukem cp = ep + 1;
382 1.63 lukem if (*cp == ':')
383 1.63 lukem cp++;
384 1.63 lukem else
385 1.63 lukem cp = NULL;
386 1.27 lukem } else
387 1.63 lukem #endif /* INET6 */
388 1.63 lukem if ((cp = strchr(thost, ':')) != NULL)
389 1.63 lukem *cp++ = '\0';
390 1.63 lukem *host = thost;
391 1.60 itojun
392 1.27 lukem /* look for [:port] */
393 1.27 lukem if (cp != NULL) {
394 1.27 lukem long nport;
395 1.27 lukem
396 1.63 lukem nport = strtol(cp, &ep, 10);
397 1.27 lukem if (nport < 1 || nport > MAX_IN_PORT_T || *ep != '\0') {
398 1.42 lukem warnx("Invalid port `%s' in %s `%s'", cp, desc, url);
399 1.27 lukem goto cleanup_parse_url;
400 1.27 lukem }
401 1.63 lukem tport = cp;
402 1.27 lukem }
403 1.63 lukem if (tport != NULL);
404 1.63 lukem *port = xstrdup(tport);
405 1.27 lukem
406 1.27 lukem if (debug)
407 1.27 lukem fprintf(ttyout,
408 1.60 itojun "parse_url: user `%s' pass `%s' host %s:%s path `%s'\n",
409 1.53 lukem *user ? *user : "<null>", *pass ? *pass : "<null>",
410 1.60 itojun *host ? *host : "<null>", *port ? *port : "<null>",
411 1.53 lukem *path ? *path : "<null>");
412 1.27 lukem
413 1.27 lukem return (0);
414 1.27 lukem }
415 1.27 lukem
416 1.1 lukem
417 1.2 lukem jmp_buf httpabort;
418 1.2 lukem
419 1.1 lukem /*
420 1.50 lukem * Retrieve URL, via a proxy if necessary, using HTTP.
421 1.50 lukem * If proxyenv is set, use that for the proxy, otherwise try ftp_proxy or
422 1.50 lukem * http_proxy as appropriate.
423 1.50 lukem * Supports HTTP redirects.
424 1.41 lukem * Returns -1 on failure, 0 on completed xfer, 1 if ftp connection
425 1.41 lukem * is still open (e.g, ftp xfer with trailing /)
426 1.1 lukem */
427 1.12 lukem static int
428 1.52 lukem fetch_url(url, proxyenv, proxyauth, wwwauth)
429 1.44 lukem const char *url;
430 1.44 lukem const char *proxyenv;
431 1.44 lukem char *proxyauth;
432 1.44 lukem char *wwwauth;
433 1.1 lukem {
434 1.66 christos #ifdef NI_NUMERICHOST
435 1.66 christos struct addrinfo hints, *res = NULL;
436 1.66 christos int error;
437 1.66 christos #else
438 1.66 christos struct sockaddr_in sin;
439 1.66 christos struct hostent *hp = NULL;
440 1.66 christos #endif
441 1.42 lukem volatile sig_t oldintr, oldintp;
442 1.42 lukem volatile int s;
443 1.45 lukem int ischunked, isproxy, rval, hcode;
444 1.42 lukem size_t len;
445 1.44 lukem char *cp, *ep, *buf, *savefile;
446 1.44 lukem char *auth, *location, *message;
447 1.63 lukem char *user, *pass, *host, *port, *path, *decodedpath;
448 1.54 lukem char *puser, *ppass;
449 1.42 lukem off_t hashbytes;
450 1.42 lukem int (*closefunc) __P((FILE *));
451 1.42 lukem FILE *fin, *fout;
452 1.42 lukem time_t mtime;
453 1.42 lukem url_t urltype;
454 1.60 itojun in_port_t portnum;
455 1.1 lukem
456 1.22 lukem closefunc = NULL;
457 1.24 lukem fin = fout = NULL;
458 1.1 lukem s = -1;
459 1.44 lukem buf = savefile = NULL;
460 1.44 lukem auth = location = message = NULL;
461 1.52 lukem ischunked = isproxy = hcode = 0;
462 1.42 lukem rval = 1;
463 1.54 lukem user = pass = host = path = decodedpath = puser = ppass = NULL;
464 1.1 lukem
465 1.27 lukem #ifdef __GNUC__ /* shut up gcc warnings */
466 1.22 lukem (void)&closefunc;
467 1.24 lukem (void)&fin;
468 1.22 lukem (void)&fout;
469 1.24 lukem (void)&buf;
470 1.12 lukem (void)&savefile;
471 1.42 lukem (void)&rval;
472 1.28 fvdl (void)&isproxy;
473 1.51 christos (void)&hcode;
474 1.51 christos (void)&ischunked;
475 1.51 christos (void)&message;
476 1.51 christos (void)&location;
477 1.51 christos (void)&auth;
478 1.51 christos (void)&decodedpath;
479 1.12 lukem #endif
480 1.12 lukem
481 1.27 lukem if (parse_url(url, "URL", &urltype, &user, &pass, &host, &port, &path)
482 1.27 lukem == -1)
483 1.42 lukem goto cleanup_fetch_url;
484 1.67 christos portnum = strtol(port, &ep, 10);
485 1.67 christos if (*ep || port == ep) {
486 1.67 christos struct servent *svp = getservbyname(port, "tcp");
487 1.67 christos if (svp != NULL)
488 1.67 christos portnum = ntohs(svp->s_port);
489 1.67 christos }
490 1.5 lukem
491 1.27 lukem if (urltype == FILE_URL_T && ! EMPTYSTRING(host)
492 1.27 lukem && strcasecmp(host, "localhost") != 0) {
493 1.27 lukem warnx("No support for non local file URL `%s'", url);
494 1.42 lukem goto cleanup_fetch_url;
495 1.9 lukem }
496 1.27 lukem
497 1.9 lukem if (EMPTYSTRING(path)) {
498 1.42 lukem if (urltype == FTP_URL_T) {
499 1.52 lukem rval = fetch_ftp(url);
500 1.42 lukem goto cleanup_fetch_url;
501 1.42 lukem }
502 1.27 lukem if (urltype != HTTP_URL_T || outfile == NULL) {
503 1.27 lukem warnx("Invalid URL (no file after host) `%s'", url);
504 1.42 lukem goto cleanup_fetch_url;
505 1.27 lukem }
506 1.9 lukem }
507 1.1 lukem
508 1.50 lukem decodedpath = xstrdup(path);
509 1.50 lukem url_decode(decodedpath);
510 1.50 lukem
511 1.22 lukem if (outfile)
512 1.29 lukem savefile = xstrdup(outfile);
513 1.22 lukem else {
514 1.50 lukem cp = strrchr(decodedpath, '/'); /* find savefile */
515 1.29 lukem if (cp != NULL)
516 1.29 lukem savefile = xstrdup(cp + 1);
517 1.22 lukem else
518 1.50 lukem savefile = xstrdup(decodedpath);
519 1.22 lukem }
520 1.9 lukem if (EMPTYSTRING(savefile)) {
521 1.42 lukem if (urltype == FTP_URL_T) {
522 1.52 lukem rval = fetch_ftp(url);
523 1.42 lukem goto cleanup_fetch_url;
524 1.42 lukem }
525 1.27 lukem warnx("Invalid URL (no file after directory) `%s'", url);
526 1.42 lukem goto cleanup_fetch_url;
527 1.52 lukem } else {
528 1.52 lukem if (debug)
529 1.52 lukem fprintf(ttyout, "got savefile as `%s'\n", savefile);
530 1.9 lukem }
531 1.1 lukem
532 1.25 lukem filesize = -1;
533 1.25 lukem mtime = -1;
534 1.25 lukem if (urltype == FILE_URL_T) { /* file:// URLs */
535 1.25 lukem struct stat sb;
536 1.25 lukem
537 1.25 lukem direction = "copied";
538 1.50 lukem fin = fopen(decodedpath, "r");
539 1.25 lukem if (fin == NULL) {
540 1.50 lukem warn("Cannot open file `%s'", decodedpath);
541 1.42 lukem goto cleanup_fetch_url;
542 1.5 lukem }
543 1.25 lukem if (fstat(fileno(fin), &sb) == 0) {
544 1.25 lukem mtime = sb.st_mtime;
545 1.25 lukem filesize = sb.st_size;
546 1.25 lukem }
547 1.49 lukem if (verbose)
548 1.50 lukem fprintf(ttyout, "Copying %s\n", decodedpath);
549 1.25 lukem } else { /* ftp:// or http:// URLs */
550 1.65 lukem char *leading;
551 1.65 lukem int hasleading;
552 1.65 lukem
553 1.42 lukem if (proxyenv == NULL) {
554 1.42 lukem if (urltype == HTTP_URL_T)
555 1.42 lukem proxyenv = httpproxy;
556 1.42 lukem else if (urltype == FTP_URL_T)
557 1.42 lukem proxyenv = ftpproxy;
558 1.42 lukem }
559 1.25 lukem direction = "retrieved";
560 1.25 lukem if (proxyenv != NULL) { /* use proxy */
561 1.27 lukem url_t purltype;
562 1.54 lukem char *phost, *ppath;
563 1.60 itojun char *pport;
564 1.27 lukem
565 1.27 lukem isproxy = 1;
566 1.27 lukem
567 1.27 lukem /* check URL against list of no_proxied sites */
568 1.27 lukem if (no_proxy != NULL) {
569 1.27 lukem char *np, *np_copy;
570 1.27 lukem long np_port;
571 1.27 lukem size_t hlen, plen;
572 1.27 lukem
573 1.27 lukem np_copy = xstrdup(no_proxy);
574 1.27 lukem hlen = strlen(host);
575 1.27 lukem while ((cp = strsep(&np_copy, " ,")) != NULL) {
576 1.27 lukem if (*cp == '\0')
577 1.27 lukem continue;
578 1.60 itojun if ((np = strrchr(cp, ':')) != NULL) {
579 1.27 lukem *np = '\0';
580 1.27 lukem np_port =
581 1.27 lukem strtol(np + 1, &ep, 10);
582 1.27 lukem if (*ep != '\0')
583 1.27 lukem continue;
584 1.60 itojun if (portnum !=
585 1.27 lukem htons((in_port_t)np_port))
586 1.27 lukem continue;
587 1.27 lukem }
588 1.27 lukem plen = strlen(cp);
589 1.27 lukem if (strncasecmp(host + hlen - plen,
590 1.27 lukem cp, plen) == 0) {
591 1.27 lukem isproxy = 0;
592 1.27 lukem break;
593 1.27 lukem }
594 1.27 lukem }
595 1.27 lukem FREEPTR(np_copy);
596 1.25 lukem }
597 1.1 lukem
598 1.27 lukem if (isproxy) {
599 1.27 lukem if (parse_url(proxyenv, "proxy URL", &purltype,
600 1.60 itojun &puser, &ppass, &phost, &pport, &ppath)
601 1.27 lukem == -1)
602 1.42 lukem goto cleanup_fetch_url;
603 1.27 lukem
604 1.27 lukem if ((purltype != HTTP_URL_T
605 1.27 lukem && purltype != FTP_URL_T) ||
606 1.27 lukem EMPTYSTRING(phost) ||
607 1.27 lukem (! EMPTYSTRING(ppath)
608 1.27 lukem && strcmp(ppath, "/") != 0)) {
609 1.27 lukem warnx("Malformed proxy URL `%s'",
610 1.27 lukem proxyenv);
611 1.27 lukem FREEPTR(phost);
612 1.60 itojun FREEPTR(pport);
613 1.27 lukem FREEPTR(ppath);
614 1.42 lukem goto cleanup_fetch_url;
615 1.27 lukem }
616 1.12 lukem
617 1.27 lukem FREEPTR(host);
618 1.27 lukem host = phost;
619 1.62 tron FREEPTR(port);
620 1.62 tron port = pport;
621 1.27 lukem FREEPTR(path);
622 1.54 lukem path = xstrdup(url);
623 1.27 lukem FREEPTR(ppath);
624 1.27 lukem }
625 1.27 lukem } /* proxyenv != NULL */
626 1.25 lukem
627 1.66 christos #ifndef NI_NUMERICHOST
628 1.25 lukem memset(&sin, 0, sizeof(sin));
629 1.25 lukem sin.sin_family = AF_INET;
630 1.25 lukem
631 1.25 lukem if (isdigit((unsigned char)host[0])) {
632 1.25 lukem if (inet_aton(host, &sin.sin_addr) == 0) {
633 1.27 lukem warnx("Invalid IP address `%s'", host);
634 1.42 lukem goto cleanup_fetch_url;
635 1.25 lukem }
636 1.25 lukem } else {
637 1.25 lukem hp = gethostbyname(host);
638 1.25 lukem if (hp == NULL) {
639 1.25 lukem warnx("%s: %s", host, hstrerror(h_errno));
640 1.42 lukem goto cleanup_fetch_url;
641 1.25 lukem }
642 1.25 lukem if (hp->h_addrtype != AF_INET) {
643 1.27 lukem warnx("`%s': not an Internet address?", host);
644 1.42 lukem goto cleanup_fetch_url;
645 1.25 lukem }
646 1.66 christos if (hp->h_length > sizeof(sin.sin_addr))
647 1.66 christos hp->h_length = sizeof(sin.sin_addr);
648 1.25 lukem memcpy(&sin.sin_addr, hp->h_addr, hp->h_length);
649 1.1 lukem }
650 1.1 lukem
651 1.60 itojun if (port == NULL) {
652 1.41 lukem warnx("Unknown port for URL `%s'", url);
653 1.42 lukem goto cleanup_fetch_url;
654 1.68 christos }
655 1.68 christos portnum = strtol(port, &ep, 10);
656 1.68 christos if (*ep || port == ep) {
657 1.68 christos struct servent *svp = getservbyname(port, "tcp");
658 1.68 christos if (svp != NULL)
659 1.68 christos portnum = ntohs(svp->s_port);
660 1.41 lukem }
661 1.63 lukem sin.sin_port = portnum;
662 1.25 lukem
663 1.25 lukem s = socket(AF_INET, SOCK_STREAM, 0);
664 1.25 lukem if (s == -1) {
665 1.25 lukem warn("Can't create socket");
666 1.42 lukem goto cleanup_fetch_url;
667 1.22 lukem }
668 1.1 lukem
669 1.25 lukem while (xconnect(s, (struct sockaddr *)&sin,
670 1.25 lukem sizeof(sin)) == -1) {
671 1.25 lukem if (errno == EINTR)
672 1.25 lukem continue;
673 1.25 lukem if (hp && hp->h_addr_list[1]) {
674 1.25 lukem int oerrno = errno;
675 1.25 lukem char *ia;
676 1.25 lukem
677 1.25 lukem ia = inet_ntoa(sin.sin_addr);
678 1.25 lukem errno = oerrno;
679 1.27 lukem warn("Connect to address `%s'", ia);
680 1.25 lukem hp->h_addr_list++;
681 1.25 lukem memcpy(&sin.sin_addr, hp->h_addr_list[0],
682 1.25 lukem (size_t)hp->h_length);
683 1.49 lukem if (verbose)
684 1.49 lukem fprintf(ttyout, "Trying %s...\n",
685 1.49 lukem inet_ntoa(sin.sin_addr));
686 1.25 lukem (void)close(s);
687 1.25 lukem s = socket(AF_INET, SOCK_STREAM, 0);
688 1.25 lukem if (s < 0) {
689 1.25 lukem warn("Can't create socket");
690 1.42 lukem goto cleanup_fetch_url;
691 1.25 lukem }
692 1.25 lukem continue;
693 1.25 lukem }
694 1.27 lukem warn("Can't connect to `%s'", host);
695 1.42 lukem goto cleanup_fetch_url;
696 1.25 lukem }
697 1.60 itojun #else
698 1.60 itojun memset(&hints, 0, sizeof(hints));
699 1.65 lukem hints.ai_flags = 0;
700 1.60 itojun hints.ai_family = AF_UNSPEC;
701 1.60 itojun hints.ai_socktype = SOCK_STREAM;
702 1.60 itojun hints.ai_protocol = 0;
703 1.60 itojun error = getaddrinfo(host, port, &hints, &res);
704 1.60 itojun if (error) {
705 1.69 mycroft warnx(gai_strerror(error));
706 1.60 itojun goto cleanup_fetch_url;
707 1.60 itojun }
708 1.60 itojun
709 1.60 itojun while (1) {
710 1.60 itojun s = socket(res->ai_family,
711 1.60 itojun res->ai_socktype, res->ai_protocol);
712 1.60 itojun if (s < 0) {
713 1.60 itojun warn("Can't create socket");
714 1.60 itojun goto cleanup_fetch_url;
715 1.60 itojun }
716 1.60 itojun
717 1.60 itojun if (xconnect(s, res->ai_addr, res->ai_addrlen) < 0) {
718 1.60 itojun char hbuf[MAXHOSTNAMELEN];
719 1.60 itojun getnameinfo(res->ai_addr, res->ai_addrlen,
720 1.60 itojun hbuf, sizeof(hbuf), NULL, 0,
721 1.60 itojun NI_NUMERICHOST);
722 1.60 itojun warn("Connect to address `%s'", hbuf);
723 1.60 itojun close(s);
724 1.60 itojun res = res->ai_next;
725 1.60 itojun if (res) {
726 1.63 lukem getnameinfo(res->ai_addr,
727 1.63 lukem res->ai_addrlen, hbuf, sizeof(hbuf),
728 1.63 lukem NULL, 0, NI_NUMERICHOST);
729 1.60 itojun if (verbose)
730 1.63 lukem fprintf(ttyout,
731 1.63 lukem "Trying %s...\n", hbuf);
732 1.60 itojun continue;
733 1.60 itojun }
734 1.60 itojun warn("Can't connect to %s", host);
735 1.60 itojun goto cleanup_fetch_url;
736 1.60 itojun }
737 1.60 itojun
738 1.60 itojun break;
739 1.60 itojun }
740 1.60 itojun #endif
741 1.60 itojun
742 1.24 lukem
743 1.25 lukem fin = fdopen(s, "r+");
744 1.25 lukem /*
745 1.27 lukem * Construct and send the request.
746 1.25 lukem */
747 1.65 lukem if (verbose)
748 1.65 lukem fprintf(ttyout, "Requesting %s\n", url);
749 1.65 lukem leading = " (";
750 1.65 lukem hasleading = 0;
751 1.27 lukem if (isproxy) {
752 1.65 lukem if (verbose) {
753 1.65 lukem fprintf(ttyout, "%svia %s:%s", leading,
754 1.65 lukem host, port);
755 1.65 lukem leading = ", ";
756 1.65 lukem hasleading++;
757 1.65 lukem }
758 1.44 lukem fprintf(fin, "GET %s HTTP/1.0\r\n", path);
759 1.47 lukem if (flushcache)
760 1.47 lukem fprintf(fin, "Pragma: no-cache\r\n");
761 1.27 lukem } else {
762 1.43 lukem struct utsname unam;
763 1.43 lukem
764 1.27 lukem fprintf(fin, "GET %s HTTP/1.1\r\n", path);
765 1.60 itojun fprintf(fin, "Host: %s:%s\r\n", host, port);
766 1.40 explorer fprintf(fin, "Accept: */*\r\n");
767 1.43 lukem if (uname(&unam) != -1) {
768 1.43 lukem fprintf(fin, "User-Agent: %s-%s/ftp\r\n",
769 1.43 lukem unam.sysname, unam.release);
770 1.43 lukem }
771 1.42 lukem fprintf(fin, "Connection: close\r\n");
772 1.47 lukem if (flushcache)
773 1.47 lukem fprintf(fin, "Cache-Control: no-cache\r\n");
774 1.25 lukem }
775 1.44 lukem if (wwwauth) {
776 1.65 lukem if (verbose) {
777 1.65 lukem fprintf(ttyout, "%swith authorization",
778 1.65 lukem leading);
779 1.65 lukem leading = ", ";
780 1.65 lukem hasleading++;
781 1.65 lukem }
782 1.44 lukem fprintf(fin, "Authorization: %s\r\n", wwwauth);
783 1.44 lukem }
784 1.46 lukem if (proxyauth) {
785 1.65 lukem if (verbose) {
786 1.49 lukem fprintf(ttyout,
787 1.65 lukem "%swith proxy authorization", leading);
788 1.65 lukem leading = ", ";
789 1.65 lukem hasleading++;
790 1.65 lukem }
791 1.44 lukem fprintf(fin, "Proxy-Authorization: %s\r\n", proxyauth);
792 1.46 lukem }
793 1.65 lukem if (verbose && hasleading)
794 1.65 lukem fputs(")\n", ttyout);
795 1.44 lukem fprintf(fin, "\r\n");
796 1.25 lukem if (fflush(fin) == EOF) {
797 1.25 lukem warn("Writing HTTP request");
798 1.42 lukem goto cleanup_fetch_url;
799 1.25 lukem }
800 1.1 lukem
801 1.25 lukem /* Read the response */
802 1.24 lukem if ((buf = fparseln(fin, &len, NULL, "\0\0\0", 0)) == NULL) {
803 1.24 lukem warn("Receiving HTTP reply");
804 1.42 lukem goto cleanup_fetch_url;
805 1.24 lukem }
806 1.24 lukem while (len > 0 && (buf[len-1] == '\r' || buf[len-1] == '\n'))
807 1.24 lukem buf[--len] = '\0';
808 1.24 lukem if (debug)
809 1.27 lukem fprintf(ttyout, "received `%s'\n", buf);
810 1.1 lukem
811 1.42 lukem /* Determine HTTP response code */
812 1.25 lukem cp = strchr(buf, ' ');
813 1.25 lukem if (cp == NULL)
814 1.25 lukem goto improper;
815 1.25 lukem else
816 1.25 lukem cp++;
817 1.42 lukem hcode = strtol(cp, &ep, 10);
818 1.42 lukem if (*ep != '\0' && !isspace((unsigned char)*ep))
819 1.42 lukem goto improper;
820 1.42 lukem message = xstrdup(cp);
821 1.25 lukem
822 1.25 lukem /* Read the rest of the header. */
823 1.27 lukem FREEPTR(buf);
824 1.25 lukem while (1) {
825 1.25 lukem if ((buf = fparseln(fin, &len, NULL, "\0\0\0", 0))
826 1.25 lukem == NULL) {
827 1.25 lukem warn("Receiving HTTP reply");
828 1.42 lukem goto cleanup_fetch_url;
829 1.25 lukem }
830 1.25 lukem while (len > 0 &&
831 1.25 lukem (buf[len-1] == '\r' || buf[len-1] == '\n'))
832 1.25 lukem buf[--len] = '\0';
833 1.25 lukem if (len == 0)
834 1.25 lukem break;
835 1.25 lukem if (debug)
836 1.27 lukem fprintf(ttyout, "received `%s'\n", buf);
837 1.25 lukem
838 1.25 lukem /* Look for some headers */
839 1.25 lukem cp = buf;
840 1.42 lukem
841 1.1 lukem #define CONTENTLEN "Content-Length: "
842 1.25 lukem if (strncasecmp(cp, CONTENTLEN,
843 1.44 lukem sizeof(CONTENTLEN) - 1) == 0) {
844 1.25 lukem cp += sizeof(CONTENTLEN) - 1;
845 1.25 lukem filesize = strtol(cp, &ep, 10);
846 1.25 lukem if (filesize < 1 || *ep != '\0')
847 1.25 lukem goto improper;
848 1.25 lukem if (debug)
849 1.25 lukem fprintf(ttyout,
850 1.25 lukem #ifndef NO_QUAD
851 1.25 lukem "parsed length as: %qd\n",
852 1.25 lukem (long long)filesize);
853 1.25 lukem #else
854 1.25 lukem "parsed length as: %ld\n",
855 1.25 lukem (long)filesize);
856 1.25 lukem #endif
857 1.42 lukem
858 1.25 lukem #define LASTMOD "Last-Modified: "
859 1.25 lukem } else if (strncasecmp(cp, LASTMOD,
860 1.44 lukem sizeof(LASTMOD) - 1) == 0) {
861 1.25 lukem struct tm parsed;
862 1.25 lukem char *t;
863 1.25 lukem
864 1.25 lukem cp += sizeof(LASTMOD) - 1;
865 1.25 lukem /* RFC 1123 */
866 1.25 lukem if ((t = strptime(cp,
867 1.25 lukem "%a, %d %b %Y %H:%M:%S GMT",
868 1.25 lukem &parsed))
869 1.25 lukem /* RFC 850 */
870 1.25 lukem || (t = strptime(cp,
871 1.25 lukem "%a, %d-%b-%y %H:%M:%S GMT",
872 1.25 lukem &parsed))
873 1.25 lukem /* asctime */
874 1.25 lukem || (t = strptime(cp,
875 1.25 lukem "%a, %b %d %H:%M:%S %Y",
876 1.25 lukem &parsed))) {
877 1.38 lukem parsed.tm_isdst = -1;
878 1.25 lukem if (*t == '\0')
879 1.39 itohy mtime = mkgmtime(&parsed);
880 1.38 lukem if (debug && mtime != -1) {
881 1.25 lukem fprintf(ttyout,
882 1.25 lukem "parsed date as: %s",
883 1.25 lukem ctime(&mtime));
884 1.38 lukem }
885 1.25 lukem }
886 1.42 lukem
887 1.24 lukem #define LOCATION "Location: "
888 1.42 lukem } else if (strncasecmp(cp, LOCATION,
889 1.44 lukem sizeof(LOCATION) - 1) == 0) {
890 1.25 lukem cp += sizeof(LOCATION) - 1;
891 1.42 lukem location = xstrdup(cp);
892 1.25 lukem if (debug)
893 1.25 lukem fprintf(ttyout,
894 1.25 lukem "parsed location as: %s\n", cp);
895 1.44 lukem
896 1.45 lukem #define TRANSENC "Transfer-Encoding: "
897 1.45 lukem } else if (strncasecmp(cp, TRANSENC,
898 1.45 lukem sizeof(TRANSENC) - 1) == 0) {
899 1.45 lukem cp += sizeof(TRANSENC) - 1;
900 1.45 lukem if (strcasecmp(cp, "chunked") != 0) {
901 1.45 lukem warnx(
902 1.45 lukem "Unsupported transfer encoding - `%s'",
903 1.45 lukem cp);
904 1.45 lukem goto cleanup_fetch_url;
905 1.45 lukem }
906 1.45 lukem ischunked++;
907 1.45 lukem if (debug)
908 1.45 lukem fprintf(ttyout,
909 1.45 lukem "using chunked encoding\n");
910 1.45 lukem
911 1.44 lukem #define PROXYAUTH "Proxy-Authenticate: "
912 1.44 lukem } else if (strncasecmp(cp, PROXYAUTH,
913 1.44 lukem sizeof(PROXYAUTH) - 1) == 0) {
914 1.44 lukem cp += sizeof(PROXYAUTH) - 1;
915 1.44 lukem FREEPTR(auth);
916 1.44 lukem auth = xstrdup(cp);
917 1.44 lukem if (debug)
918 1.44 lukem fprintf(ttyout,
919 1.44 lukem "parsed proxy-auth as: %s\n", cp);
920 1.44 lukem
921 1.44 lukem #define WWWAUTH "WWW-Authenticate: "
922 1.44 lukem } else if (strncasecmp(cp, WWWAUTH,
923 1.44 lukem sizeof(WWWAUTH) - 1) == 0) {
924 1.44 lukem cp += sizeof(WWWAUTH) - 1;
925 1.44 lukem FREEPTR(auth);
926 1.44 lukem auth = xstrdup(cp);
927 1.44 lukem if (debug)
928 1.44 lukem fprintf(ttyout,
929 1.44 lukem "parsed www-auth as: %s\n", cp);
930 1.44 lukem
931 1.25 lukem }
932 1.44 lukem
933 1.24 lukem }
934 1.54 lukem /* finished parsing header */
935 1.27 lukem FREEPTR(buf);
936 1.1 lukem
937 1.52 lukem switch (hcode) {
938 1.52 lukem case 200:
939 1.52 lukem break;
940 1.52 lukem case 300:
941 1.52 lukem case 301:
942 1.52 lukem case 302:
943 1.52 lukem case 303:
944 1.52 lukem case 305:
945 1.52 lukem if (EMPTYSTRING(location)) {
946 1.52 lukem warnx(
947 1.52 lukem "No redirection Location provided by server");
948 1.52 lukem goto cleanup_fetch_url;
949 1.52 lukem }
950 1.52 lukem if (redirect_loop++ > 5) {
951 1.52 lukem warnx("Too many redirections requested");
952 1.52 lukem goto cleanup_fetch_url;
953 1.52 lukem }
954 1.52 lukem if (hcode == 305) {
955 1.52 lukem if (verbose)
956 1.52 lukem fprintf(ttyout, "Redirected via %s\n",
957 1.52 lukem location);
958 1.52 lukem rval = fetch_url(url, location,
959 1.52 lukem proxyauth, wwwauth);
960 1.52 lukem } else {
961 1.52 lukem if (verbose)
962 1.52 lukem fprintf(ttyout, "Redirected to %s\n",
963 1.52 lukem location);
964 1.52 lukem rval = go_fetch(location);
965 1.52 lukem }
966 1.42 lukem goto cleanup_fetch_url;
967 1.52 lukem case 401:
968 1.52 lukem case 407:
969 1.52 lukem {
970 1.52 lukem char **authp;
971 1.54 lukem char *auser, *apass;
972 1.52 lukem
973 1.52 lukem fprintf(ttyout, "%s\n", message);
974 1.52 lukem if (EMPTYSTRING(auth)) {
975 1.52 lukem warnx(
976 1.52 lukem "No authentication challenge provided by server");
977 1.52 lukem goto cleanup_fetch_url;
978 1.52 lukem }
979 1.54 lukem if (hcode == 401) {
980 1.54 lukem authp = &wwwauth;
981 1.54 lukem auser = user;
982 1.54 lukem apass = pass;
983 1.54 lukem } else {
984 1.54 lukem authp = &proxyauth;
985 1.54 lukem auser = puser;
986 1.54 lukem apass = ppass;
987 1.54 lukem }
988 1.52 lukem if (*authp != NULL) {
989 1.52 lukem char reply[10];
990 1.52 lukem
991 1.52 lukem fprintf(ttyout,
992 1.52 lukem "Authorization failed. Retry (y/n)? ");
993 1.52 lukem if (fgets(reply, sizeof(reply), stdin) != NULL
994 1.52 lukem && tolower(reply[0]) != 'y')
995 1.52 lukem goto cleanup_fetch_url;
996 1.54 lukem auser = NULL;
997 1.54 lukem apass = NULL;
998 1.52 lukem }
999 1.54 lukem if (auth_url(auth, authp, auser, apass) == 0) {
1000 1.52 lukem rval = fetch_url(url, proxyenv,
1001 1.52 lukem proxyauth, wwwauth);
1002 1.52 lukem memset(*authp, '\0', strlen(*authp));
1003 1.52 lukem FREEPTR(*authp);
1004 1.52 lukem }
1005 1.42 lukem goto cleanup_fetch_url;
1006 1.52 lukem }
1007 1.52 lukem default:
1008 1.52 lukem if (message)
1009 1.52 lukem warnx("Error retrieving file - `%s'", message);
1010 1.52 lukem else
1011 1.52 lukem warnx("Unknown error retrieving file");
1012 1.44 lukem goto cleanup_fetch_url;
1013 1.44 lukem }
1014 1.52 lukem } /* end of ftp:// or http:// specific setup */
1015 1.42 lukem
1016 1.22 lukem oldintr = oldintp = NULL;
1017 1.22 lukem
1018 1.22 lukem /* Open the output file. */
1019 1.22 lukem if (strcmp(savefile, "-") == 0) {
1020 1.22 lukem fout = stdout;
1021 1.22 lukem } else if (*savefile == '|') {
1022 1.22 lukem oldintp = signal(SIGPIPE, SIG_IGN);
1023 1.22 lukem fout = popen(savefile + 1, "w");
1024 1.22 lukem if (fout == NULL) {
1025 1.27 lukem warn("Can't run `%s'", savefile + 1);
1026 1.42 lukem goto cleanup_fetch_url;
1027 1.22 lukem }
1028 1.22 lukem closefunc = pclose;
1029 1.22 lukem } else {
1030 1.22 lukem fout = fopen(savefile, "w");
1031 1.22 lukem if (fout == NULL) {
1032 1.27 lukem warn("Can't open `%s'", savefile);
1033 1.42 lukem goto cleanup_fetch_url;
1034 1.22 lukem }
1035 1.22 lukem closefunc = fclose;
1036 1.1 lukem }
1037 1.1 lukem
1038 1.22 lukem /* Trap signals */
1039 1.2 lukem if (setjmp(httpabort)) {
1040 1.2 lukem if (oldintr)
1041 1.3 lukem (void)signal(SIGINT, oldintr);
1042 1.22 lukem if (oldintp)
1043 1.22 lukem (void)signal(SIGPIPE, oldintp);
1044 1.42 lukem goto cleanup_fetch_url;
1045 1.2 lukem }
1046 1.2 lukem oldintr = signal(SIGINT, aborthttp);
1047 1.2 lukem
1048 1.1 lukem bytes = 0;
1049 1.1 lukem hashbytes = mark;
1050 1.1 lukem progressmeter(-1);
1051 1.2 lukem
1052 1.24 lukem /* Finally, suck down the file. */
1053 1.45 lukem buf = xmalloc(BUFSIZ + 1);
1054 1.45 lukem do {
1055 1.45 lukem ssize_t chunksize;
1056 1.45 lukem
1057 1.45 lukem chunksize = 0;
1058 1.45 lukem /* read chunksize */
1059 1.45 lukem if (ischunked) {
1060 1.45 lukem if (fgets(buf, BUFSIZ, fin) == NULL) {
1061 1.45 lukem warnx("Unexpected EOF reading chunksize");
1062 1.45 lukem goto cleanup_fetch_url;
1063 1.45 lukem }
1064 1.45 lukem chunksize = strtol(buf, &ep, 16);
1065 1.45 lukem if (strcmp(ep, "\r\n") != 0) {
1066 1.45 lukem warnx("Unexpected data following chunksize");
1067 1.45 lukem goto cleanup_fetch_url;
1068 1.45 lukem }
1069 1.45 lukem if (debug)
1070 1.59 lukem fprintf(ttyout,
1071 1.59 lukem #ifndef NO_QUAD
1072 1.59 lukem "got chunksize of %qd\n",
1073 1.45 lukem (long long)chunksize);
1074 1.59 lukem #else
1075 1.59 lukem "got chunksize of %ld\n",
1076 1.59 lukem (long)chunksize);
1077 1.59 lukem #endif
1078 1.45 lukem if (chunksize == 0)
1079 1.45 lukem break;
1080 1.45 lukem }
1081 1.59 lukem /* transfer file or chunk */
1082 1.59 lukem while (1) {
1083 1.59 lukem struct timeval then, now, td;
1084 1.59 lukem off_t bufrem;
1085 1.59 lukem
1086 1.59 lukem (void)gettimeofday(&then, NULL);
1087 1.59 lukem bufrem = rate_get ? rate_get : BUFSIZ;
1088 1.59 lukem while (bufrem > 0) {
1089 1.59 lukem len = fread(buf, sizeof(char),
1090 1.59 lukem ischunked ? MIN(chunksize, bufrem) : BUFSIZ,
1091 1.59 lukem fin);
1092 1.59 lukem if (len <= 0)
1093 1.59 lukem goto chunkdone;
1094 1.59 lukem bytes += len;
1095 1.59 lukem bufrem -= len;
1096 1.59 lukem if (fwrite(buf, sizeof(char), len, fout)
1097 1.59 lukem != len) {
1098 1.59 lukem warn("Writing `%s'", savefile);
1099 1.59 lukem goto cleanup_fetch_url;
1100 1.59 lukem }
1101 1.45 lukem }
1102 1.45 lukem if (hash && !progress) {
1103 1.45 lukem while (bytes >= hashbytes) {
1104 1.45 lukem (void)putc('#', ttyout);
1105 1.45 lukem hashbytes += mark;
1106 1.45 lukem }
1107 1.45 lukem (void)fflush(ttyout);
1108 1.45 lukem }
1109 1.59 lukem if (ischunked) {
1110 1.45 lukem chunksize -= len;
1111 1.59 lukem if (chunksize <= 0)
1112 1.59 lukem goto chunkdone;
1113 1.59 lukem }
1114 1.59 lukem if (rate_get) {
1115 1.59 lukem while (1) {
1116 1.59 lukem (void)gettimeofday(&now, NULL);
1117 1.59 lukem timersub(&now, &then, &td);
1118 1.59 lukem if (td.tv_sec > 0)
1119 1.59 lukem break;
1120 1.59 lukem usleep(1000000 - td.tv_usec);
1121 1.59 lukem }
1122 1.59 lukem }
1123 1.1 lukem }
1124 1.45 lukem /* read CRLF after chunk*/
1125 1.59 lukem chunkdone:
1126 1.45 lukem if (ischunked) {
1127 1.45 lukem if (fgets(buf, BUFSIZ, fin) == NULL)
1128 1.45 lukem break;
1129 1.45 lukem if (strcmp(buf, "\r\n") != 0) {
1130 1.45 lukem warnx("Unexpected data following chunk");
1131 1.45 lukem goto cleanup_fetch_url;
1132 1.1 lukem }
1133 1.1 lukem }
1134 1.45 lukem } while (ischunked);
1135 1.1 lukem if (hash && !progress && bytes > 0) {
1136 1.1 lukem if (bytes < mark)
1137 1.22 lukem (void)putc('#', ttyout);
1138 1.22 lukem (void)putc('\n', ttyout);
1139 1.1 lukem }
1140 1.25 lukem if (ferror(fin)) {
1141 1.25 lukem warn("Reading file");
1142 1.42 lukem goto cleanup_fetch_url;
1143 1.1 lukem }
1144 1.2 lukem progressmeter(1);
1145 1.25 lukem (void)fflush(fout);
1146 1.3 lukem (void)signal(SIGINT, oldintr);
1147 1.22 lukem if (oldintp)
1148 1.22 lukem (void)signal(SIGPIPE, oldintp);
1149 1.25 lukem if (closefunc == fclose && mtime != -1) {
1150 1.25 lukem struct timeval tval[2];
1151 1.25 lukem
1152 1.25 lukem (void)gettimeofday(&tval[0], NULL);
1153 1.25 lukem tval[1].tv_sec = mtime;
1154 1.25 lukem tval[1].tv_usec = 0;
1155 1.31 lukem (*closefunc)(fout);
1156 1.31 lukem fout = NULL;
1157 1.31 lukem
1158 1.31 lukem if (utimes(savefile, tval) == -1) {
1159 1.25 lukem fprintf(ttyout,
1160 1.25 lukem "Can't change modification time to %s",
1161 1.25 lukem asctime(localtime(&mtime)));
1162 1.25 lukem }
1163 1.25 lukem }
1164 1.25 lukem if (bytes > 0)
1165 1.25 lukem ptransfer(0);
1166 1.1 lukem
1167 1.42 lukem rval = 0;
1168 1.42 lukem goto cleanup_fetch_url;
1169 1.11 lukem
1170 1.1 lukem improper:
1171 1.27 lukem warnx("Improper response from `%s'", host);
1172 1.11 lukem
1173 1.42 lukem cleanup_fetch_url:
1174 1.23 thorpej resetsockbufsize();
1175 1.24 lukem if (fin != NULL)
1176 1.24 lukem fclose(fin);
1177 1.24 lukem else if (s != -1)
1178 1.1 lukem close(s);
1179 1.22 lukem if (closefunc != NULL && fout != NULL)
1180 1.22 lukem (*closefunc)(fout);
1181 1.66 christos #ifdef NI_NUMERICHOST
1182 1.65 lukem if (res != NULL)
1183 1.65 lukem freeaddrinfo(res);
1184 1.66 christos #endif
1185 1.29 lukem FREEPTR(savefile);
1186 1.27 lukem FREEPTR(user);
1187 1.27 lukem FREEPTR(pass);
1188 1.27 lukem FREEPTR(host);
1189 1.60 itojun FREEPTR(port);
1190 1.27 lukem FREEPTR(path);
1191 1.50 lukem FREEPTR(decodedpath);
1192 1.54 lukem FREEPTR(puser);
1193 1.54 lukem FREEPTR(ppass);
1194 1.27 lukem FREEPTR(buf);
1195 1.44 lukem FREEPTR(auth);
1196 1.42 lukem FREEPTR(location);
1197 1.42 lukem FREEPTR(message);
1198 1.42 lukem return (rval);
1199 1.1 lukem }
1200 1.1 lukem
1201 1.1 lukem /*
1202 1.50 lukem * Abort a HTTP retrieval
1203 1.2 lukem */
1204 1.2 lukem void
1205 1.3 lukem aborthttp(notused)
1206 1.3 lukem int notused;
1207 1.2 lukem {
1208 1.2 lukem
1209 1.2 lukem alarmtimer(0);
1210 1.24 lukem fputs("\nHTTP fetch aborted.\n", ttyout);
1211 1.2 lukem longjmp(httpabort, 1);
1212 1.2 lukem }
1213 1.2 lukem
1214 1.2 lukem /*
1215 1.50 lukem * Retrieve ftp URL or classic ftp argument using FTP.
1216 1.63 lukem * Returns 1 on failure, 0 on completed xfer, -1 if ftp connection
1217 1.42 lukem * is still open (e.g, ftp xfer with trailing /)
1218 1.42 lukem */
1219 1.42 lukem static int
1220 1.52 lukem fetch_ftp(url)
1221 1.42 lukem const char *url;
1222 1.42 lukem {
1223 1.42 lukem char *cp, *xargv[5], rempath[MAXPATHLEN];
1224 1.42 lukem char *host, *path, *dir, *file, *user, *pass;
1225 1.60 itojun char *port;
1226 1.53 lukem int dirhasglob, filehasglob, oautologin, rval, type, xargc;
1227 1.53 lukem url_t urltype;
1228 1.42 lukem
1229 1.42 lukem host = path = dir = file = user = pass = NULL;
1230 1.60 itojun port = NULL;
1231 1.42 lukem rval = 1;
1232 1.53 lukem type = TYPE_I;
1233 1.42 lukem
1234 1.42 lukem if (strncasecmp(url, FTP_URL, sizeof(FTP_URL) - 1) == 0) {
1235 1.42 lukem if ((parse_url(url, "URL", &urltype, &user, &pass,
1236 1.42 lukem &host, &port, &path) == -1) ||
1237 1.42 lukem (user != NULL && *user == '\0') ||
1238 1.42 lukem (pass != NULL && *pass == '\0') ||
1239 1.42 lukem EMPTYSTRING(host)) {
1240 1.42 lukem warnx("Invalid URL `%s'", url);
1241 1.42 lukem goto cleanup_fetch_ftp;
1242 1.42 lukem }
1243 1.50 lukem url_decode(user);
1244 1.50 lukem url_decode(pass);
1245 1.53 lukem /*
1246 1.53 lukem * Note: Don't url_decode(path) here. We need to keep the
1247 1.53 lukem * distinction between "/" and "%2F" until later.
1248 1.53 lukem */
1249 1.53 lukem
1250 1.53 lukem /* check for trailing ';type=[aid]' */
1251 1.63 lukem if (! EMPTYSTRING(path) && (cp = strrchr(path, ';')) != NULL) {
1252 1.53 lukem if (strcasecmp(cp, ";type=a") == 0)
1253 1.53 lukem type = TYPE_A;
1254 1.53 lukem else if (strcasecmp(cp, ";type=i") == 0)
1255 1.53 lukem type = TYPE_I;
1256 1.53 lukem else if (strcasecmp(cp, ";type=d") == 0) {
1257 1.53 lukem warnx(
1258 1.53 lukem "Directory listing via a URL is not supported");
1259 1.53 lukem goto cleanup_fetch_ftp;
1260 1.53 lukem } else {
1261 1.53 lukem warnx("Invalid suffix `%s' in URL `%s'", cp,
1262 1.53 lukem url);
1263 1.53 lukem goto cleanup_fetch_ftp;
1264 1.53 lukem }
1265 1.53 lukem *cp = 0;
1266 1.53 lukem }
1267 1.42 lukem } else { /* classic style `host:file' */
1268 1.53 lukem urltype = CLASSIC_URL_T;
1269 1.42 lukem host = xstrdup(url);
1270 1.42 lukem cp = strchr(host, ':');
1271 1.42 lukem if (cp != NULL) {
1272 1.42 lukem *cp = '\0';
1273 1.42 lukem path = xstrdup(cp + 1);
1274 1.42 lukem }
1275 1.42 lukem }
1276 1.42 lukem if (EMPTYSTRING(host))
1277 1.42 lukem goto cleanup_fetch_ftp;
1278 1.42 lukem
1279 1.50 lukem /* Extract the file and (if present) directory name. */
1280 1.42 lukem dir = path;
1281 1.42 lukem if (! EMPTYSTRING(dir)) {
1282 1.53 lukem /*
1283 1.53 lukem * If we are dealing with classic `host:path' syntax,
1284 1.53 lukem * then a path of the form `/file' (resulting from
1285 1.53 lukem * input of the form `host:/file') means that we should
1286 1.63 lukem * do "CWD /" before retrieving the file. So we set
1287 1.53 lukem * dir="/" and file="file".
1288 1.53 lukem *
1289 1.53 lukem * But if we are dealing with URLs like
1290 1.53 lukem * `ftp://host/path' then a path of the form `/file'
1291 1.53 lukem * (resulting from a URL of the form `ftp://host//file')
1292 1.53 lukem * means that we should do `CWD ' (with an empty
1293 1.53 lukem * argument) before retrieving the file. So we set
1294 1.53 lukem * dir="" and file="file".
1295 1.53 lukem *
1296 1.53 lukem * If the path does not contain / at all, we set
1297 1.53 lukem * dir=NULL. (We get a path without any slashes if
1298 1.53 lukem * we are dealing with classic `host:file' or URL
1299 1.53 lukem * `ftp://host/file'.)
1300 1.53 lukem *
1301 1.53 lukem * In all other cases, we set dir to a string that does
1302 1.53 lukem * not include the final '/' that separates the dir part
1303 1.53 lukem * from the file part of the path. (This will be the
1304 1.53 lukem * empty string if and only if we are dealing with a
1305 1.53 lukem * path of the form `/file' resulting from an URL of the
1306 1.53 lukem * form `ftp://host//file'.)
1307 1.53 lukem */
1308 1.42 lukem cp = strrchr(dir, '/');
1309 1.53 lukem if (cp == dir && urltype == CLASSIC_URL_T) {
1310 1.50 lukem file = cp + 1;
1311 1.50 lukem dir = "/";
1312 1.50 lukem } else if (cp != NULL) {
1313 1.42 lukem *cp++ = '\0';
1314 1.42 lukem file = cp;
1315 1.42 lukem } else {
1316 1.42 lukem file = dir;
1317 1.42 lukem dir = NULL;
1318 1.42 lukem }
1319 1.63 lukem } else
1320 1.63 lukem dir = NULL;
1321 1.53 lukem if (urltype == FTP_URL_T && file != NULL) {
1322 1.53 lukem url_decode(file);
1323 1.53 lukem /* but still don't url_decode(dir) */
1324 1.53 lukem }
1325 1.42 lukem if (debug)
1326 1.42 lukem fprintf(ttyout,
1327 1.60 itojun "fetch_ftp: user `%s' pass `%s' host %s:%s path `%s' dir `%s' file `%s'\n",
1328 1.53 lukem user ? user : "<null>", pass ? pass : "<null>",
1329 1.60 itojun host ? host : "<null>", port ? port : "<null>",
1330 1.60 itojun path ? path : "<null>",
1331 1.53 lukem dir ? dir : "<null>", file ? file : "<null>");
1332 1.42 lukem
1333 1.42 lukem dirhasglob = filehasglob = 0;
1334 1.53 lukem if (doglob && urltype == CLASSIC_URL_T) {
1335 1.42 lukem if (! EMPTYSTRING(dir) && strpbrk(dir, "*?[]{}") != NULL)
1336 1.42 lukem dirhasglob = 1;
1337 1.42 lukem if (! EMPTYSTRING(file) && strpbrk(file, "*?[]{}") != NULL)
1338 1.42 lukem filehasglob = 1;
1339 1.42 lukem }
1340 1.42 lukem
1341 1.50 lukem /* Set up the connection */
1342 1.50 lukem if (connected)
1343 1.50 lukem disconnect(0, NULL);
1344 1.50 lukem xargv[0] = __progname;
1345 1.50 lukem xargv[1] = host;
1346 1.50 lukem xargv[2] = NULL;
1347 1.50 lukem xargc = 2;
1348 1.50 lukem if (port) {
1349 1.60 itojun xargv[2] = port;
1350 1.50 lukem xargv[3] = NULL;
1351 1.50 lukem xargc = 3;
1352 1.50 lukem }
1353 1.50 lukem oautologin = autologin;
1354 1.50 lukem if (user != NULL)
1355 1.50 lukem autologin = 0;
1356 1.50 lukem setpeer(xargc, xargv);
1357 1.50 lukem autologin = oautologin;
1358 1.50 lukem if ((connected == 0) || ((connected == 1)
1359 1.50 lukem && !ftp_login(host, user, pass))) {
1360 1.50 lukem warnx("Can't connect or login to host `%s'", host);
1361 1.50 lukem goto cleanup_fetch_ftp;
1362 1.50 lukem }
1363 1.42 lukem
1364 1.53 lukem switch (type) {
1365 1.53 lukem case TYPE_A:
1366 1.53 lukem setascii(0, NULL);
1367 1.53 lukem break;
1368 1.53 lukem case TYPE_I:
1369 1.53 lukem setbinary(0, NULL);
1370 1.53 lukem break;
1371 1.53 lukem default:
1372 1.53 lukem errx(1, "fetch_ftp: unknown transfer type %d\n", type);
1373 1.53 lukem }
1374 1.53 lukem
1375 1.63 lukem /*
1376 1.63 lukem * Change directories, if necessary.
1377 1.63 lukem *
1378 1.63 lukem * Note: don't use EMPTYSTRING(dir) below, because
1379 1.63 lukem * dir=="" means something different from dir==NULL.
1380 1.63 lukem */
1381 1.53 lukem if (dir != NULL && !dirhasglob) {
1382 1.53 lukem char *nextpart;
1383 1.42 lukem
1384 1.53 lukem /*
1385 1.53 lukem * If we are dealing with a classic `host:path' (urltype
1386 1.53 lukem * is CLASSIC_URL_T) then we have a raw directory
1387 1.53 lukem * name (not encoded in any way) and we can change
1388 1.53 lukem * directories in one step.
1389 1.53 lukem *
1390 1.53 lukem * If we are dealing with an `ftp://host/path' URL
1391 1.53 lukem * (urltype is FTP_URL_T), then RFC 1738 says we need to
1392 1.53 lukem * send a separate CWD command for each unescaped "/"
1393 1.53 lukem * in the path, and we have to interpret %hex escaping
1394 1.53 lukem * *after* we find the slashes. It's possible to get
1395 1.53 lukem * empty components here, (from multiple adjacent
1396 1.53 lukem * slashes in the path) and RFC 1738 says that we should
1397 1.53 lukem * still do `CWD ' (with a null argument) in such cases.
1398 1.53 lukem *
1399 1.63 lukem * Many ftp servers don't support `CWD ', so if there's an
1400 1.63 lukem * error performing that command, bail out with a descriptive
1401 1.63 lukem * message.
1402 1.53 lukem *
1403 1.53 lukem * Examples:
1404 1.53 lukem *
1405 1.63 lukem * host: dir="", urltype=CLASSIC_URL_T
1406 1.63 lukem * logged in (to default directory)
1407 1.53 lukem * host:file dir=NULL, urltype=CLASSIC_URL_T
1408 1.53 lukem * "RETR file"
1409 1.63 lukem * host:dir/ dir="dir", urltype=CLASSIC_URL_T
1410 1.63 lukem * "CWD dir", logged in
1411 1.63 lukem * ftp://host/ dir="", urltype=FTP_URL_T
1412 1.63 lukem * logged in (to default directory)
1413 1.63 lukem * ftp://host/dir/ dir="dir", urltype=FTP_URL_T
1414 1.63 lukem * "CWD dir", logged in
1415 1.53 lukem * ftp://host/file dir=NULL, urltype=FTP_URL_T
1416 1.53 lukem * "RETR file"
1417 1.53 lukem * ftp://host//file dir="", urltype=FTP_URL_T
1418 1.63 lukem * "CWD ", "RETR file"
1419 1.53 lukem * host:/file dir="/", urltype=CLASSIC_URL_T
1420 1.53 lukem * "CWD /", "RETR file"
1421 1.53 lukem * ftp://host///file dir="/", urltype=FTP_URL_T
1422 1.63 lukem * "CWD ", "CWD ", "RETR file"
1423 1.53 lukem * ftp://host/%2F/file dir="%2F", urltype=FTP_URL_T
1424 1.53 lukem * "CWD /", "RETR file"
1425 1.53 lukem * ftp://host/foo/file dir="foo", urltype=FTP_URL_T
1426 1.53 lukem * "CWD foo", "RETR file"
1427 1.53 lukem * ftp://host/foo/bar/file dir="foo/bar"
1428 1.53 lukem * "CWD foo", "CWD bar", "RETR file"
1429 1.53 lukem * ftp://host//foo/bar/file dir="/foo/bar"
1430 1.63 lukem * "CWD ", "CWD foo", "CWD bar", "RETR file"
1431 1.53 lukem * ftp://host/foo//bar/file dir="foo//bar"
1432 1.63 lukem * "CWD foo", "CWD ", "CWD bar", "RETR file"
1433 1.53 lukem * ftp://host/%2F/foo/bar/file dir="%2F/foo/bar"
1434 1.53 lukem * "CWD /", "CWD foo", "CWD bar", "RETR file"
1435 1.53 lukem * ftp://host/%2Ffoo/bar/file dir="%2Ffoo/bar"
1436 1.53 lukem * "CWD /foo", "CWD bar", "RETR file"
1437 1.53 lukem * ftp://host/%2Ffoo%2Fbar/file dir="%2Ffoo%2Fbar"
1438 1.53 lukem * "CWD /foo/bar", "RETR file"
1439 1.53 lukem * ftp://host/%2Ffoo%2Fbar%2Ffile dir=NULL
1440 1.53 lukem * "RETR /foo/bar/file"
1441 1.53 lukem *
1442 1.53 lukem * Note that we don't need `dir' after this point.
1443 1.53 lukem */
1444 1.53 lukem do {
1445 1.53 lukem if (urltype == FTP_URL_T) {
1446 1.53 lukem nextpart = strchr(dir, '/');
1447 1.53 lukem if (nextpart) {
1448 1.53 lukem *nextpart = '\0';
1449 1.53 lukem nextpart++;
1450 1.53 lukem }
1451 1.53 lukem url_decode(dir);
1452 1.53 lukem } else
1453 1.53 lukem nextpart = NULL;
1454 1.53 lukem if (debug)
1455 1.53 lukem fprintf(ttyout, "dir `%s', nextpart `%s'\n",
1456 1.53 lukem dir ? dir : "<null>",
1457 1.53 lukem nextpart ? nextpart : "<null>");
1458 1.63 lukem if (urltype == FTP_URL_T || *dir != '\0') {
1459 1.53 lukem xargv[0] = "cd";
1460 1.53 lukem xargv[1] = dir;
1461 1.53 lukem xargv[2] = NULL;
1462 1.53 lukem dirchange = 0;
1463 1.53 lukem cd(2, xargv);
1464 1.63 lukem if (! dirchange) {
1465 1.63 lukem if (*dir == '\0' && code == 500)
1466 1.63 lukem fprintf(stderr,
1467 1.63 lukem "\n"
1468 1.63 lukem "ftp: The `CWD ' command (without a directory), which is required by\n"
1469 1.63 lukem " RFC 1738 to support the empty directory in the URL pathname (`//'),\n"
1470 1.63 lukem " conflicts with the server's conformance to RFC 959.\n"
1471 1.63 lukem " Try the same URL without the `//' in the URL pathname.\n"
1472 1.63 lukem "\n");
1473 1.53 lukem goto cleanup_fetch_ftp;
1474 1.63 lukem }
1475 1.53 lukem }
1476 1.53 lukem dir = nextpart;
1477 1.53 lukem } while (dir != NULL);
1478 1.42 lukem }
1479 1.42 lukem
1480 1.42 lukem if (EMPTYSTRING(file)) {
1481 1.42 lukem rval = -1;
1482 1.42 lukem goto cleanup_fetch_ftp;
1483 1.42 lukem }
1484 1.42 lukem
1485 1.42 lukem if (dirhasglob) {
1486 1.42 lukem snprintf(rempath, sizeof(rempath), "%s/%s", dir, file);
1487 1.42 lukem file = rempath;
1488 1.42 lukem }
1489 1.42 lukem
1490 1.42 lukem /* Fetch the file(s). */
1491 1.42 lukem xargc = 2;
1492 1.42 lukem xargv[0] = "get";
1493 1.42 lukem xargv[1] = file;
1494 1.42 lukem xargv[2] = NULL;
1495 1.42 lukem if (dirhasglob || filehasglob) {
1496 1.42 lukem int ointeractive;
1497 1.42 lukem
1498 1.42 lukem ointeractive = interactive;
1499 1.42 lukem interactive = 0;
1500 1.42 lukem xargv[0] = "mget";
1501 1.42 lukem mget(xargc, xargv);
1502 1.42 lukem interactive = ointeractive;
1503 1.42 lukem } else {
1504 1.53 lukem if (outfile == NULL) {
1505 1.53 lukem cp = strrchr(file, '/'); /* find savefile */
1506 1.53 lukem if (cp != NULL)
1507 1.53 lukem outfile = cp + 1;
1508 1.53 lukem else
1509 1.53 lukem outfile = file;
1510 1.42 lukem }
1511 1.53 lukem xargv[2] = (char *)outfile;
1512 1.53 lukem xargv[3] = NULL;
1513 1.53 lukem xargc++;
1514 1.52 lukem if (restartautofetch)
1515 1.52 lukem reget(xargc, xargv);
1516 1.52 lukem else
1517 1.52 lukem get(xargc, xargv);
1518 1.42 lukem }
1519 1.42 lukem
1520 1.42 lukem if ((code / 100) == COMPLETE)
1521 1.42 lukem rval = 0;
1522 1.42 lukem
1523 1.42 lukem cleanup_fetch_ftp:
1524 1.42 lukem FREEPTR(host);
1525 1.42 lukem FREEPTR(path);
1526 1.42 lukem FREEPTR(user);
1527 1.42 lukem FREEPTR(pass);
1528 1.42 lukem return (rval);
1529 1.42 lukem }
1530 1.42 lukem
1531 1.42 lukem /*
1532 1.42 lukem * Retrieve the given file to outfile.
1533 1.42 lukem * Supports arguments of the form:
1534 1.42 lukem * "host:path", "ftp://host/path" if $ftpproxy, call fetch_url() else
1535 1.42 lukem * call fetch_ftp()
1536 1.50 lukem * "http://host/path" call fetch_url() to use HTTP
1537 1.42 lukem * "file:///path" call fetch_url() to copy
1538 1.42 lukem * "about:..." print a message
1539 1.42 lukem *
1540 1.42 lukem * Returns 1 on failure, 0 on completed xfer, -1 if ftp connection
1541 1.42 lukem * is still open (e.g, ftp xfer with trailing /)
1542 1.42 lukem */
1543 1.42 lukem static int
1544 1.52 lukem go_fetch(url)
1545 1.42 lukem const char *url;
1546 1.42 lukem {
1547 1.42 lukem
1548 1.56 cgd #ifndef NO_ABOUT
1549 1.42 lukem /*
1550 1.42 lukem * Check for about:*
1551 1.42 lukem */
1552 1.42 lukem if (strncasecmp(url, ABOUT_URL, sizeof(ABOUT_URL) - 1) == 0) {
1553 1.42 lukem url += sizeof(ABOUT_URL) -1;
1554 1.42 lukem if (strcasecmp(url, "ftp") == 0) {
1555 1.42 lukem fprintf(ttyout, "%s\n%s\n",
1556 1.42 lukem "This version of ftp has been enhanced by Luke Mewburn <lukem (at) netbsd.org>.",
1557 1.50 lukem "Execute `man ftp' for more details");
1558 1.42 lukem } else if (strcasecmp(url, "netbsd") == 0) {
1559 1.42 lukem fprintf(ttyout, "%s\n%s\n",
1560 1.42 lukem "NetBSD is a freely available and redistributable UNIX-like operating system.",
1561 1.42 lukem "For more information, see http://www.netbsd.org/index.html");
1562 1.42 lukem } else {
1563 1.42 lukem fprintf(ttyout, "`%s' is an interesting topic.\n", url);
1564 1.42 lukem }
1565 1.42 lukem return (0);
1566 1.42 lukem }
1567 1.56 cgd #endif /* NO_ABOUT */
1568 1.42 lukem
1569 1.42 lukem /*
1570 1.42 lukem * Check for file:// and http:// URLs.
1571 1.42 lukem */
1572 1.42 lukem if (strncasecmp(url, HTTP_URL, sizeof(HTTP_URL) - 1) == 0 ||
1573 1.42 lukem strncasecmp(url, FILE_URL, sizeof(FILE_URL) - 1) == 0)
1574 1.52 lukem return (fetch_url(url, NULL, NULL, NULL));
1575 1.42 lukem
1576 1.42 lukem /*
1577 1.42 lukem * Try FTP URL-style and host:file arguments next.
1578 1.42 lukem * If ftpproxy is set with an FTP URL, use fetch_url()
1579 1.42 lukem * Othewise, use fetch_ftp().
1580 1.42 lukem */
1581 1.42 lukem if (ftpproxy && strncasecmp(url, FTP_URL, sizeof(FTP_URL) - 1) == 0)
1582 1.52 lukem return (fetch_url(url, NULL, NULL, NULL));
1583 1.42 lukem
1584 1.52 lukem return (fetch_ftp(url));
1585 1.42 lukem }
1586 1.42 lukem
1587 1.42 lukem /*
1588 1.42 lukem * Retrieve multiple files from the command line,
1589 1.42 lukem * calling go_fetch() for each file.
1590 1.42 lukem *
1591 1.42 lukem * If an ftp path has a trailing "/", the path will be cd-ed into and
1592 1.41 lukem * the connection remains open, and the function will return -1
1593 1.41 lukem * (to indicate the connection is alive).
1594 1.1 lukem * If an error occurs the return value will be the offset+1 in
1595 1.1 lukem * argv[] of the file that caused a problem (i.e, argv[x]
1596 1.1 lukem * returns x+1)
1597 1.1 lukem * Otherwise, 0 is returned if all files retrieved successfully.
1598 1.1 lukem */
1599 1.1 lukem int
1600 1.52 lukem auto_fetch(argc, argv)
1601 1.1 lukem int argc;
1602 1.1 lukem char *argv[];
1603 1.1 lukem {
1604 1.42 lukem volatile int argpos;
1605 1.42 lukem int rval;
1606 1.22 lukem
1607 1.2 lukem argpos = 0;
1608 1.1 lukem
1609 1.2 lukem if (setjmp(toplevel)) {
1610 1.2 lukem if (connected)
1611 1.2 lukem disconnect(0, NULL);
1612 1.3 lukem return (argpos + 1);
1613 1.2 lukem }
1614 1.3 lukem (void)signal(SIGINT, (sig_t)intr);
1615 1.3 lukem (void)signal(SIGPIPE, (sig_t)lostpeer);
1616 1.1 lukem
1617 1.1 lukem /*
1618 1.1 lukem * Loop through as long as there's files to fetch.
1619 1.1 lukem */
1620 1.27 lukem for (rval = 0; (rval == 0) && (argpos < argc); argpos++) {
1621 1.1 lukem if (strchr(argv[argpos], ':') == NULL)
1622 1.1 lukem break;
1623 1.42 lukem redirect_loop = 0;
1624 1.50 lukem anonftp = 1; /* Handle "automatic" transfers. */
1625 1.52 lukem rval = go_fetch(argv[argpos]);
1626 1.52 lukem if (outfile != NULL && strcmp(outfile, "-") != 0
1627 1.52 lukem && outfile[0] != '|')
1628 1.52 lukem outfile = NULL;
1629 1.42 lukem if (rval > 0)
1630 1.1 lukem rval = argpos + 1;
1631 1.42 lukem }
1632 1.3 lukem
1633 1.1 lukem if (connected && rval != -1)
1634 1.1 lukem disconnect(0, NULL);
1635 1.1 lukem return (rval);
1636 1.1 lukem }
1637