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