mod_proxy_ftp.c revision 6f4dadd94220f9bdfe34fc4530527e4482319541
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny/* Licensed to the Apache Software Foundation (ASF) under one or more
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny * contributor license agreements. See the NOTICE file distributed with
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny * this work for additional information regarding copyright ownership.
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny * The ASF licenses this file to You under the Apache License, Version 2.0
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny * (the "License"); you may not use this file except in compliance with
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny * the License. You may obtain a copy of the License at
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny *
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny * http://www.apache.org/licenses/LICENSE-2.0
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny *
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny * Unless required by applicable law or agreed to in writing, software
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny * distributed under the License is distributed on an "AS IS" BASIS,
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny * See the License for the specific language governing permissions and
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny * limitations under the License.
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny/* FTP routines for Apache proxy */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny#include "mod_proxy.h"
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny#if APR_HAVE_TIME_H
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny#include <time.h>
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny#endif
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny#include "apr_version.h"
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny#if (APR_MAJOR_VERSION < 1)
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce#undef apr_socket_create
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny#define apr_socket_create apr_socket_create_ex
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny#endif
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny#define AUTODETECT_PWD
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny/* Automatic timestamping (Last-Modified header) based on MDTM is used if:
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny * 1) the FTP server supports the MDTM command and
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce * 2) HAVE_TIMEGM (preferred) or HAVE_GMTOFF is available at compile time
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny#define USE_MDTM
9822d4d468ec74e4e173f5adf0db12d02974cd18Sumit Bose
a6cca9c284724fafd670a3163812f248ba53ad97Jakub Hrozek
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bosemodule AP_MODULE_DECLARE_DATA proxy_ftp_module;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce/*
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny * Decodes a '%' escaped string, and returns the number of characters
9822d4d468ec74e4e173f5adf0db12d02974cd18Sumit Bose */
9822d4d468ec74e4e173f5adf0db12d02974cd18Sumit Bosestatic int decodeenc(char *x)
9822d4d468ec74e4e173f5adf0db12d02974cd18Sumit Bose{
9822d4d468ec74e4e173f5adf0db12d02974cd18Sumit Bose int i, j, ch;
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose
9822d4d468ec74e4e173f5adf0db12d02974cd18Sumit Bose if (x[0] == '\0')
a6cca9c284724fafd670a3163812f248ba53ad97Jakub Hrozek return 0; /* special case for no characters */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny for (i = 0, j = 0; x[i] != '\0'; i++, j++) {
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny /* decode it if not already done */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny ch = x[i];
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny if (ch == '%' && apr_isxdigit(x[i + 1]) && apr_isxdigit(x[i + 2])) {
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny ch = ap_proxy_hex2c(&x[i + 1]);
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny i += 2;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny }
aab938c5975f0e3b85c7c79a5d718e5fefed7217Simo Sorce x[j] = ch;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny }
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny x[j] = '\0';
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny return j;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny}
aab938c5975f0e3b85c7c79a5d718e5fefed7217Simo Sorce
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny/*
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny * Escape the globbing characters in a path used as argument to
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny * the FTP commands (SIZE, CWD, RETR, MDTM, ...).
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny * ftpd assumes '\\' as a quoting character to escape special characters.
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny * Returns: escaped string
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny#define FTP_GLOBBING_CHARS "*?[{~"
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorcestatic char *ftp_escape_globbingchars(apr_pool_t *p, const char *path)
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce{
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce char *ret = apr_palloc(p, 2*strlen(path)+sizeof(""));
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce char *d;
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce for (d = ret; *path; ++path) {
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce if (strchr(FTP_GLOBBING_CHARS, *path) != NULL)
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce *d++ = '\\';
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce *d++ = *path;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny }
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny *d = '\0';
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny return ret;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny}
aab938c5975f0e3b85c7c79a5d718e5fefed7217Simo Sorce
aab938c5975f0e3b85c7c79a5d718e5fefed7217Simo Sorce/*
aab938c5975f0e3b85c7c79a5d718e5fefed7217Simo Sorce * Check for globbing characters in a path used as argument to
7fe69bb6ec70bce439c6b975a9a0044c98ff502bSimo Sorce * the FTP commands (SIZE, CWD, RETR, MDTM, ...).
7fe69bb6ec70bce439c6b975a9a0044c98ff502bSimo Sorce * ftpd assumes '\\' as a quoting character to escape special characters.
7fe69bb6ec70bce439c6b975a9a0044c98ff502bSimo Sorce * Returns: 0 (no globbing chars, or all globbing chars escaped), 1 (globbing chars)
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zelenystatic int ftp_check_globbingchars(const char *path)
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny{
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny for ( ; *path; ++path) {
aab938c5975f0e3b85c7c79a5d718e5fefed7217Simo Sorce if (*path == '\\')
aab938c5975f0e3b85c7c79a5d718e5fefed7217Simo Sorce ++path;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny if (*path != '\0' && strchr(FTP_GLOBBING_CHARS, *path) != NULL)
aab938c5975f0e3b85c7c79a5d718e5fefed7217Simo Sorce return TRUE;
aab938c5975f0e3b85c7c79a5d718e5fefed7217Simo Sorce }
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce return FALSE;
aab938c5975f0e3b85c7c79a5d718e5fefed7217Simo Sorce}
aab938c5975f0e3b85c7c79a5d718e5fefed7217Simo Sorce
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny/*
9822d4d468ec74e4e173f5adf0db12d02974cd18Sumit Bose * checks an encoded ftp string for bad characters, namely, CR, LF or
9822d4d468ec74e4e173f5adf0db12d02974cd18Sumit Bose * non-ascii character
9822d4d468ec74e4e173f5adf0db12d02974cd18Sumit Bose */
a6cca9c284724fafd670a3163812f248ba53ad97Jakub Hrozekstatic int ftp_check_string(const char *x)
a6cca9c284724fafd670a3163812f248ba53ad97Jakub Hrozek{
a6cca9c284724fafd670a3163812f248ba53ad97Jakub Hrozek int i, ch = 0;
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose#if APR_CHARSET_EBCDIC
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose char buf[1];
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose#endif
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce for (i = 0; x[i] != '\0'; i++) {
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce ch = x[i];
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce if (ch == '%' && apr_isxdigit(x[i + 1]) && apr_isxdigit(x[i + 2])) {
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce ch = ap_proxy_hex2c(&x[i + 1]);
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce i += 2;
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce }
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce#if !APR_CHARSET_EBCDIC
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce if (ch == '\015' || ch == '\012' || (ch & 0x80))
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce#else /* APR_CHARSET_EBCDIC */
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce if (ch == '\r' || ch == '\n')
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce return 0;
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce buf[0] = ch;
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce ap_xlate_proto_to_ascii(buf, 1);
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce if (buf[0] & 0x80)
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce#endif /* APR_CHARSET_EBCDIC */
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce return 0;
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce }
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce return 1;
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce}
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce/*
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce * Canonicalise ftp URLs.
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce */
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorcestatic int proxy_ftp_canon(request_rec *r, char *url)
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce{
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce char *user, *password, *host, *path, *parms, *strp, sport[7];
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce apr_pool_t *p = r->pool;
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce const char *err;
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce apr_port_t port, def_port;
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce /* */
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce if (strncasecmp(url, "ftp:", 4) == 0) {
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce url += 4;
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce }
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce else {
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce return DECLINED;
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce }
9822d4d468ec74e4e173f5adf0db12d02974cd18Sumit Bose def_port = apr_uri_port_of_scheme("ftp");
9822d4d468ec74e4e173f5adf0db12d02974cd18Sumit Bose
9822d4d468ec74e4e173f5adf0db12d02974cd18Sumit Bose ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
9822d4d468ec74e4e173f5adf0db12d02974cd18Sumit Bose "proxy: FTP: canonicalising URL %s", url);
9822d4d468ec74e4e173f5adf0db12d02974cd18Sumit Bose
9822d4d468ec74e4e173f5adf0db12d02974cd18Sumit Bose port = def_port;
9822d4d468ec74e4e173f5adf0db12d02974cd18Sumit Bose err = ap_proxy_canon_netloc(p, &url, &user, &password, &host, &port);
9822d4d468ec74e4e173f5adf0db12d02974cd18Sumit Bose if (err)
9822d4d468ec74e4e173f5adf0db12d02974cd18Sumit Bose return HTTP_BAD_REQUEST;
a6cca9c284724fafd670a3163812f248ba53ad97Jakub Hrozek if (user != NULL && !ftp_check_string(user))
a6cca9c284724fafd670a3163812f248ba53ad97Jakub Hrozek return HTTP_BAD_REQUEST;
a6cca9c284724fafd670a3163812f248ba53ad97Jakub Hrozek if (password != NULL && !ftp_check_string(password))
a6cca9c284724fafd670a3163812f248ba53ad97Jakub Hrozek return HTTP_BAD_REQUEST;
a6cca9c284724fafd670a3163812f248ba53ad97Jakub Hrozek
a6cca9c284724fafd670a3163812f248ba53ad97Jakub Hrozek /* now parse path/parameters args, according to rfc1738 */
a6cca9c284724fafd670a3163812f248ba53ad97Jakub Hrozek /*
a6cca9c284724fafd670a3163812f248ba53ad97Jakub Hrozek * N.B. if this isn't a true proxy request, then the URL path (but not
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose * query args) has already been decoded. This gives rise to the problem
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose * of a ; being decoded into the path.
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose */
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose strp = strchr(url, ';');
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose if (strp != NULL) {
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose *(strp++) = '\0';
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose parms = ap_proxy_canonenc(p, strp, strlen(strp), enc_parm, 0,
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose r->proxyreq);
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose if (parms == NULL)
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose return HTTP_BAD_REQUEST;
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose }
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose else
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose parms = "";
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce path = ap_proxy_canonenc(p, url, strlen(url), enc_path, 0, r->proxyreq);
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce if (path == NULL)
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce return HTTP_BAD_REQUEST;
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce if (!ftp_check_string(path))
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce return HTTP_BAD_REQUEST;
a6cca9c284724fafd670a3163812f248ba53ad97Jakub Hrozek
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose if (r->proxyreq && r->args != NULL) {
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce if (strp != NULL) {
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce strp = ap_proxy_canonenc(p, r->args, strlen(r->args), enc_parm, 1, r->proxyreq);
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce if (strp == NULL)
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce return HTTP_BAD_REQUEST;
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce parms = apr_pstrcat(p, parms, "?", strp, NULL);
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny }
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny else {
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny strp = ap_proxy_canonenc(p, r->args, strlen(r->args), enc_fpath, 1, r->proxyreq);
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny if (strp == NULL)
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny return HTTP_BAD_REQUEST;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny path = apr_pstrcat(p, path, "?", strp, NULL);
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny }
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny r->args = NULL;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny }
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce/* now, rebuild URL */
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny if (port != def_port)
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny apr_snprintf(sport, sizeof(sport), ":%d", port);
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny else
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny sport[0] = '\0';
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny if (ap_strchr_c(host, ':')) { /* if literal IPv6 address */
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce host = apr_pstrcat(p, "[", host, "]", NULL);
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny }
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny r->filename = apr_pstrcat(p, "proxy:ftp://", (user != NULL) ? user : "",
17195241500e46272018d7897d6e87249870caf2Pavel Reichl (password != NULL) ? ":" : "",
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny (password != NULL) ? password : "",
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny (user != NULL) ? "@" : "", host, sport, "/", path,
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny (parms[0] != '\0') ? ";" : "", parms, NULL);
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny return OK;
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny}
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce/* we chop lines longer than 80 characters */
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce#define MAX_LINE_LEN 80
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny/*
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny * Reads response lines, returns both the ftp status code and
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny * remembers the response message in the supplied buffer
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce */
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorcestatic int ftp_getrc_msg(conn_rec *ftp_ctrl, apr_bucket_brigade *bb, char *msgbuf, int msglen)
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny{
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny int status;
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny char response[MAX_LINE_LEN];
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny char buff[5];
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny char *mb = msgbuf, *me = &msgbuf[msglen];
cb388d52f49f54963379cc20a25e14d17fe6e9a3Simo Sorce apr_status_t rv;
cb388d52f49f54963379cc20a25e14d17fe6e9a3Simo Sorce int eos;
cb388d52f49f54963379cc20a25e14d17fe6e9a3Simo Sorce
cb388d52f49f54963379cc20a25e14d17fe6e9a3Simo Sorce if (APR_SUCCESS != (rv = ap_proxy_string_read(ftp_ctrl, bb, response, sizeof(response), &eos))) {
cb388d52f49f54963379cc20a25e14d17fe6e9a3Simo Sorce return -1;
cb388d52f49f54963379cc20a25e14d17fe6e9a3Simo Sorce }
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny/*
cb388d52f49f54963379cc20a25e14d17fe6e9a3Simo Sorce ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, NULL,
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny "proxy: <FTP: %s", response);
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny*/
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny if (!apr_isdigit(response[0]) || !apr_isdigit(response[1]) ||
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny !apr_isdigit(response[2]) || (response[3] != ' ' && response[3] != '-'))
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce status = 0;
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce else
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce status = 100 * response[0] + 10 * response[1] + response[2] - 111 * '0';
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce mb = apr_cpystrn(mb, response + 4, me - mb);
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce if (response[3] == '-') {
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce memcpy(buff, response, 3);
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce buff[3] = ' ';
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce do {
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce if (APR_SUCCESS != (rv = ap_proxy_string_read(ftp_ctrl, bb, response, sizeof(response), &eos))) {
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce return -1;
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny }
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny mb = apr_cpystrn(mb, response + (' ' == response[0] ? 1 : 4), me - mb);
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce } while (memcmp(response, buff, 4) != 0);
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce }
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce return status;
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce}
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny/* this is a filter that turns a raw ASCII directory listing into pretty HTML */
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny/* ideally, mod_proxy should simply send the raw directory list up the filter
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny * stack to mod_autoindex, which in theory should turn the raw ascii into
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny * pretty html along with all the bells and whistles it provides...
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny *
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny * all in good time...! :)
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce */
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorcetypedef struct {
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce apr_bucket_brigade *in;
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce char buffer[MAX_STRING_LEN];
65393a294e635822c1d7a15fe5853dc457ad8a2aSimo Sorce enum {
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny HEADER, BODY, FOOTER
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny } state;
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny} proxy_dir_ctx_t;
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny/* fallback regex for ls -s1; ($0..$2) == 3 */
17195241500e46272018d7897d6e87249870caf2Pavel Reichl#define LS_REG_PATTERN "^ *([0-9]+) +([^ ]+)$"
17195241500e46272018d7897d6e87249870caf2Pavel Reichl#define LS_REG_MATCH 3
17195241500e46272018d7897d6e87249870caf2Pavel Reichl
17195241500e46272018d7897d6e87249870caf2Pavel Reichlstatic apr_status_t proxy_send_dir_filter(ap_filter_t *f,
17195241500e46272018d7897d6e87249870caf2Pavel Reichl apr_bucket_brigade *in)
17195241500e46272018d7897d6e87249870caf2Pavel Reichl{
17195241500e46272018d7897d6e87249870caf2Pavel Reichl request_rec *r = f->r;
17195241500e46272018d7897d6e87249870caf2Pavel Reichl conn_rec *c = r->connection;
17195241500e46272018d7897d6e87249870caf2Pavel Reichl apr_pool_t *p = r->pool;
17195241500e46272018d7897d6e87249870caf2Pavel Reichl apr_bucket_brigade *out = apr_brigade_create(p, c->bucket_alloc);
17195241500e46272018d7897d6e87249870caf2Pavel Reichl apr_status_t rv;
17195241500e46272018d7897d6e87249870caf2Pavel Reichl
17195241500e46272018d7897d6e87249870caf2Pavel Reichl register int n;
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny char *dir, *path, *reldir, *site, *str, *type;
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny const char *pwd = apr_table_get(r->notes, "Directory-PWD");
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny const char *readme = apr_table_get(r->notes, "Directory-README");
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
3912262270a6449ebe1d3e92c27c217b4044f894Simo Sorce proxy_dir_ctx_t *ctx = f->ctx;
17195241500e46272018d7897d6e87249870caf2Pavel Reichl
17195241500e46272018d7897d6e87249870caf2Pavel Reichl if (!ctx) {
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny f->ctx = ctx = apr_pcalloc(p, sizeof(*ctx));
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny ctx->in = apr_brigade_create(p, c->bucket_alloc);
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny ctx->buffer[0] = 0;
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny ctx->state = HEADER;
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny }
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny /* combine the stored and the new */
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny APR_BRIGADE_CONCAT(ctx->in, in);
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny if (HEADER == ctx->state) {
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny /* basedir is either "", or "/%2f" for the "squid %2f hack" */
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny const char *basedir = ""; /* By default, path is relative to the $HOME dir */
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny char *wildcard = NULL;
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny /* Save "scheme://site" prefix without password */
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny site = apr_uri_unparse(p, &f->r->parsed_uri, APR_URI_UNP_OMITPASSWORD | APR_URI_UNP_OMITPATHINFO);
3912262270a6449ebe1d3e92c27c217b4044f894Simo Sorce /* ... and path without query args */
0754ff886f909f0404038eb9c99dd61be1acf5b9Simo Sorce path = apr_uri_unparse(p, &f->r->parsed_uri, APR_URI_UNP_OMITSITEPART | APR_URI_UNP_OMITQUERY);
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny /* If path began with /%2f, change the basedir */
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny if (strncasecmp(path, "/%2f", 4) == 0) {
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny basedir = "/%2f";
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny }
3912262270a6449ebe1d3e92c27c217b4044f894Simo Sorce
3912262270a6449ebe1d3e92c27c217b4044f894Simo Sorce /* Strip off a type qualifier. It is ignored for dir listings */
7fe69bb6ec70bce439c6b975a9a0044c98ff502bSimo Sorce if ((type = strstr(path, ";type=")) != NULL)
7fe69bb6ec70bce439c6b975a9a0044c98ff502bSimo Sorce *type++ = '\0';
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny (void)decodeenc(path);
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny while (path[1] == '/') /* collapse multiple leading slashes to one */
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny ++path;
3912262270a6449ebe1d3e92c27c217b4044f894Simo Sorce
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny reldir = strrchr(path, '/');
c03b28a38b14fdb59f74864ae4dc56affe256508Simo Sorce if (reldir != NULL && ftp_check_globbingchars(reldir)) {
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny wildcard = &reldir[1];
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny reldir[0] = '\0'; /* strip off the wildcard suffix */
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny }
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny /* Copy path, strip (all except the last) trailing slashes */
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny /* (the trailing slash is needed for the dir component loop below) */
3912262270a6449ebe1d3e92c27c217b4044f894Simo Sorce path = dir = apr_pstrcat(p, path, "/", NULL);
3912262270a6449ebe1d3e92c27c217b4044f894Simo Sorce for (n = strlen(path); n > 1 && path[n - 1] == '/' && path[n - 2] == '/'; --n)
3912262270a6449ebe1d3e92c27c217b4044f894Simo Sorce path[n - 1] = '\0';
3912262270a6449ebe1d3e92c27c217b4044f894Simo Sorce
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny /* Add a link to the root directory (if %2f hack was used) */
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny str = (basedir[0] != '\0') ? "<a href=\"/%2f/\">%2f</a>/" : "";
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny /* print "ftp://host/" */
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny str = apr_psprintf(p, DOCTYPE_HTML_3_2
3912262270a6449ebe1d3e92c27c217b4044f894Simo Sorce "<html>\n <head>\n <title>%s%s%s</title>\n"
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny " </head>\n"
c03b28a38b14fdb59f74864ae4dc56affe256508Simo Sorce " <body>\n <h2>Directory of "
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny "<a href=\"/\">%s</a>/%s",
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny site, basedir, ap_escape_html(p, path),
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny site, str);
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny APR_BRIGADE_INSERT_TAIL(out, apr_bucket_pool_create(str, strlen(str),
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny p, c->bucket_alloc));
17195241500e46272018d7897d6e87249870caf2Pavel Reichl
17195241500e46272018d7897d6e87249870caf2Pavel Reichl for (dir = path+1; (dir = strchr(dir, '/')) != NULL; )
17195241500e46272018d7897d6e87249870caf2Pavel Reichl {
17195241500e46272018d7897d6e87249870caf2Pavel Reichl *dir = '\0';
17195241500e46272018d7897d6e87249870caf2Pavel Reichl if ((reldir = strrchr(path+1, '/'))==NULL) {
17195241500e46272018d7897d6e87249870caf2Pavel Reichl reldir = path+1;
17195241500e46272018d7897d6e87249870caf2Pavel Reichl }
17195241500e46272018d7897d6e87249870caf2Pavel Reichl else
17195241500e46272018d7897d6e87249870caf2Pavel Reichl ++reldir;
17195241500e46272018d7897d6e87249870caf2Pavel Reichl /* print "path/" component */
17195241500e46272018d7897d6e87249870caf2Pavel Reichl str = apr_psprintf(p, "<a href=\"%s%s/\">%s</a>/", basedir,
17195241500e46272018d7897d6e87249870caf2Pavel Reichl ap_escape_uri(p, path),
17195241500e46272018d7897d6e87249870caf2Pavel Reichl ap_escape_html(p, reldir));
17195241500e46272018d7897d6e87249870caf2Pavel Reichl *dir = '/';
17195241500e46272018d7897d6e87249870caf2Pavel Reichl while (*dir == '/')
17195241500e46272018d7897d6e87249870caf2Pavel Reichl ++dir;
17195241500e46272018d7897d6e87249870caf2Pavel Reichl APR_BRIGADE_INSERT_TAIL(out, apr_bucket_pool_create(str,
17195241500e46272018d7897d6e87249870caf2Pavel Reichl strlen(str), p,
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny c->bucket_alloc));
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny }
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny if (wildcard != NULL) {
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny APR_BRIGADE_INSERT_TAIL(out, apr_bucket_pool_create(wildcard,
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny strlen(wildcard), p,
3912262270a6449ebe1d3e92c27c217b4044f894Simo Sorce c->bucket_alloc));
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny }
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
3912262270a6449ebe1d3e92c27c217b4044f894Simo Sorce /* If the caller has determined the current directory, and it differs */
3912262270a6449ebe1d3e92c27c217b4044f894Simo Sorce /* from what the client requested, then show the real name */
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny if (pwd == NULL || strncmp(pwd, path, strlen(pwd)) == 0) {
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny str = apr_psprintf(p, "</h2>\n\n <hr />\n\n<pre>");
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny }
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny else {
3b0e0352d8076909608d04750d3ea6b0d9ba33f6Jakub Hrozek str = apr_psprintf(p, "</h2>\n\n(%s)\n\n <hr />\n\n<pre>",
3b0e0352d8076909608d04750d3ea6b0d9ba33f6Jakub Hrozek ap_escape_html(p, pwd));
3b0e0352d8076909608d04750d3ea6b0d9ba33f6Jakub Hrozek }
3b0e0352d8076909608d04750d3ea6b0d9ba33f6Jakub Hrozek APR_BRIGADE_INSERT_TAIL(out, apr_bucket_pool_create(str, strlen(str),
3b0e0352d8076909608d04750d3ea6b0d9ba33f6Jakub Hrozek p, c->bucket_alloc));
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny /* print README */
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny if (readme) {
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny str = apr_psprintf(p, "%s\n</pre>\n\n<hr />\n\n<pre>\n",
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny ap_escape_html(p, readme));
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny
84c611c1b7c04cc7735ab54d4e5f48284b79e6fbJan Zeleny APR_BRIGADE_INSERT_TAIL(out, apr_bucket_pool_create(str,
3912262270a6449ebe1d3e92c27c217b4044f894Simo Sorce strlen(str), p,
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce c->bucket_alloc));
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce }
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose /* make sure page intro gets sent out */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny APR_BRIGADE_INSERT_TAIL(out, apr_bucket_flush_create(c->bucket_alloc));
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny if (APR_SUCCESS != (rv = ap_pass_brigade(f->next, out))) {
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny return rv;
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce }
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce apr_brigade_cleanup(out);
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce ctx->state = BODY;
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce }
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose /* loop through each line of directory */
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek while (BODY == ctx->state) {
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose char *filename;
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce int found = 0;
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce int eos = 0;
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce ap_regex_t *re = NULL;
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce ap_regmatch_t re_result[LS_REG_MATCH];
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce /* Compile the output format of "ls -s1" as a fallback for non-unix ftp listings */
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose re = ap_pregcomp(p, LS_REG_PATTERN, AP_REG_EXTENDED);
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek ap_assert(re != NULL);
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny /* get a complete line */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny /* if the buffer overruns - throw data away */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny while (!found && !APR_BRIGADE_EMPTY(ctx->in)) {
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny char *pos, *response;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny apr_size_t len, max;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny apr_bucket *e;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce e = APR_BRIGADE_FIRST(ctx->in);
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce if (APR_BUCKET_IS_EOS(e)) {
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce eos = 1;
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce break;
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce }
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce if (APR_SUCCESS != (rv = apr_bucket_read(e, (const char **)&response, &len, APR_BLOCK_READ))) {
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce return rv;
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce }
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce pos = memchr(response, APR_ASCII_LF, len);
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny if (pos != NULL) {
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny if ((response + len) != (pos + 1)) {
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny len = pos - response + 1;
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce apr_bucket_split(e, pos - response + 1);
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce }
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce found = 1;
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce }
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce max = sizeof(ctx->buffer) - strlen(ctx->buffer) - 1;
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce if (len > max) {
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce len = max;
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce }
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose /* len+1 to leave space for the trailing nil char */
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek apr_cpystrn(ctx->buffer+strlen(ctx->buffer), response, len+1);
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce APR_BUCKET_REMOVE(e);
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce apr_bucket_destroy(e);
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny }
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce /* EOS? jump to footer */
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce if (eos) {
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce ctx->state = FOOTER;
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce break;
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce }
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce /* not complete? leave and try get some more */
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce if (!found) {
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce return APR_SUCCESS;
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce }
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce {
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce apr_size_t n = strlen(ctx->buffer);
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce if (ctx->buffer[n-1] == CRLF[1]) /* strip trailing '\n' */
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce ctx->buffer[--n] = '\0';
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce if (ctx->buffer[n-1] == CRLF[0]) /* strip trailing '\r' if present */
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce ctx->buffer[--n] = '\0';
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce }
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce /* a symlink? */
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce if (ctx->buffer[0] == 'l' && (filename = strstr(ctx->buffer, " -> ")) != NULL) {
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose char *link_ptr = filename;
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose do {
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose filename--;
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose } while (filename[0] != ' ' && filename > ctx->buffer);
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose if (filename > ctx->buffer)
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek *(filename++) = '\0';
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek *(link_ptr++) = '\0';
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek str = apr_psprintf(p, "%s <a href=\"%s\">%s %s</a>\n",
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek ap_escape_html(p, ctx->buffer),
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek ap_escape_uri(p, filename),
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose ap_escape_html(p, filename),
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose ap_escape_html(p, link_ptr));
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose }
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose /* a directory/file? */
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose else if (ctx->buffer[0] == 'd' || ctx->buffer[0] == '-' || ctx->buffer[0] == 'l' || apr_isdigit(ctx->buffer[0])) {
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose int searchidx = 0;
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose char *searchptr = NULL;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny int firstfile = 1;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny if (apr_isdigit(ctx->buffer[0])) { /* handle DOS dir */
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose searchptr = strchr(ctx->buffer, '<');
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose if (searchptr != NULL)
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce *searchptr = '[';
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny searchptr = strchr(ctx->buffer, '>');
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny if (searchptr != NULL)
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny *searchptr = ']';
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce }
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce filename = strrchr(ctx->buffer, ' ');
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny if (filename == NULL) {
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny /* Line is broken. Ignore it. */
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce ap_log_error(APLOG_MARK, APLOG_WARNING, 0, r->server,
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce "proxy_ftp: could not parse line %s", ctx->buffer);
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose /* erase buffer for next time around */
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce ctx->buffer[0] = 0;
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce continue; /* while state is BODY */
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce }
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce *(filename++) = '\0';
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce /* handle filenames with spaces in 'em */
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce if (!strcmp(filename, ".") || !strcmp(filename, "..") || firstfile) {
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce firstfile = 0;
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce searchidx = filename - ctx->buffer;
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce }
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce else if (searchidx != 0 && ctx->buffer[searchidx] != 0) {
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce *(--filename) = ' ';
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny ctx->buffer[searchidx - 1] = '\0';
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce filename = &ctx->buffer[searchidx];
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce }
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce /* Append a slash to the HREF link for directories */
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce if (!strcmp(filename, ".") || !strcmp(filename, "..") || ctx->buffer[0] == 'd') {
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce str = apr_psprintf(p, "%s <a href=\"%s/\">%s</a>\n",
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce ap_escape_html(p, ctx->buffer),
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce ap_escape_uri(p, filename),
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce ap_escape_html(p, filename));
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce }
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce else {
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce str = apr_psprintf(p, "%s <a href=\"%s\">%s</a>\n",
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce ap_escape_html(p, ctx->buffer),
204cfc89a076fd32bf34f2abb3f809304aaa88abSimo Sorce ap_escape_uri(p, filename),
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce ap_escape_html(p, filename));
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce }
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny }
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny /* Try a fallback for listings in the format of "ls -s1" */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny else if (0 == ap_regexec(re, ctx->buffer, LS_REG_MATCH, re_result, 0)) {
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny filename = apr_pstrndup(p, &ctx->buffer[re_result[2].rm_so], re_result[2].rm_eo - re_result[2].rm_so);
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny str = apr_pstrcat(p, ap_escape_html(p, apr_pstrndup(p, ctx->buffer, re_result[2].rm_so)),
c03b28a38b14fdb59f74864ae4dc56affe256508Simo Sorce "<a href=\"", ap_escape_uri(p, filename), "\">",
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny ap_escape_html(p, filename), "</a>\n", NULL);
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny }
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny else {
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny strcat(ctx->buffer, "\n"); /* re-append the newline */
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce str = ap_escape_html(p, ctx->buffer);
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce }
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny /* erase buffer for next time around */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny ctx->buffer[0] = 0;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny APR_BRIGADE_INSERT_TAIL(out, apr_bucket_pool_create(str, strlen(str), p,
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce c->bucket_alloc));
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny APR_BRIGADE_INSERT_TAIL(out, apr_bucket_flush_create(c->bucket_alloc));
c03b28a38b14fdb59f74864ae4dc56affe256508Simo Sorce if (APR_SUCCESS != (rv = ap_pass_brigade(f->next, out))) {
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny return rv;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny }
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny apr_brigade_cleanup(out);
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose }
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose if (FOOTER == ctx->state) {
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose str = apr_psprintf(p, "</pre>\n\n <hr />\n\n %s\n\n </body>\n</html>\n", ap_psignature("", r));
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose APR_BRIGADE_INSERT_TAIL(out, apr_bucket_pool_create(str, strlen(str), p,
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose c->bucket_alloc));
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose APR_BRIGADE_INSERT_TAIL(out, apr_bucket_flush_create(c->bucket_alloc));
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose APR_BRIGADE_INSERT_TAIL(out, apr_bucket_eos_create(c->bucket_alloc));
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose if (APR_SUCCESS != (rv = ap_pass_brigade(f->next, out))) {
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose return rv;
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose }
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose apr_brigade_destroy(out);
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose }
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose
09d7c105839bfc7447ea0f766413ed86675ca075Sumit Bose return APR_SUCCESS;
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek}
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek/*
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek * Generic "send FTP command to server" routine, using the control socket.
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek * Returns the FTP returncode (3 digit code)
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek * Allows for tracing the FTP protocol (in LogLevel debug)
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek */
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozekstatic int
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozekproxy_ftp_command(const char *cmd, request_rec *r, conn_rec *ftp_ctrl,
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek apr_bucket_brigade *bb, char **pmessage)
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek{
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek char *crlf;
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek int rc;
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek char message[HUGE_STRING_LEN];
b3458bbb5315b05d7ac1abc58f1c380761756603Jakub Hrozek
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose /* If cmd == NULL, we retrieve the next ftp response line */
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose if (cmd != NULL) {
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose conn_rec *c = r->connection;
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose APR_BRIGADE_INSERT_TAIL(bb, apr_bucket_pool_create(cmd, strlen(cmd), r->pool, c->bucket_alloc));
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose APR_BRIGADE_INSERT_TAIL(bb, apr_bucket_flush_create(c->bucket_alloc));
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose ap_pass_brigade(ftp_ctrl->output_filters, bb);
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose /* strip off the CRLF for logging */
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose apr_cpystrn(message, cmd, sizeof(message));
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose if ((crlf = strchr(message, '\r')) != NULL ||
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose (crlf = strchr(message, '\n')) != NULL)
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose *crlf = '\0';
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose if (strncmp(message,"PASS ", 5) == 0)
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose strcpy(&message[5], "****");
c5711b0279ea85d69fe3c77dfb194360c346e1d7Sumit Bose ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny "proxy:>FTP: %s", message);
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny }
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny
1187a07ed4207c1c326fdf83915dddfe472b8620Simo Sorce rc = ftp_getrc_msg(ftp_ctrl, bb, message, sizeof message);
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny if (rc == -1 || rc == 421)
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny strcpy(message,"<unable to read result>");
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny if ((crlf = strchr(message, '\r')) != NULL ||
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny (crlf = strchr(message, '\n')) != NULL)
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny *crlf = '\0';
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny "proxy:<FTP: %3.3u %s", rc, message);
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny if (pmessage != NULL)
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny *pmessage = apr_pstrdup(r->pool, message);
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny return rc;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny}
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny/* Set ftp server to TYPE {A,I,E} before transfer of a directory or file */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zelenystatic int ftp_set_TYPE(char xfer_type, request_rec *r, conn_rec *ftp_ctrl,
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny apr_bucket_brigade *bb, char **pmessage)
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce{
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny char old_type[2] = { 'A', '\0' }; /* After logon, mode is ASCII */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny int ret = HTTP_OK;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny int rc;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny /* set desired type */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny old_type[0] = xfer_type;
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce rc = proxy_ftp_command(apr_pstrcat(r->pool, "TYPE ", old_type, CRLF, NULL),
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce r, ftp_ctrl, bb, pmessage);
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce/* responses: 200, 421, 500, 501, 504, 530 */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny /* 200 Command okay. */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny /* 421 Service not available, closing control connection. */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny /* 500 Syntax error, command unrecognized. */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny /* 501 Syntax error in parameters or arguments. */
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce /* 504 Command not implemented for that parameter. */
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny /* 530 Not logged in. */
bba1a5fd62cffcae076d1351df5a83fbc4a6ec17Simo Sorce if (rc == -1 || rc == 421) {
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny ret = ap_proxyerror(r, HTTP_BAD_GATEWAY,
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny "Error reading from remote server");
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny }
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny else if (rc != 200 && rc != 504) {
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny ret = ap_proxyerror(r, HTTP_BAD_GATEWAY,
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny "Unable to set transfer type");
e76d78338026fa47dca32eaf7f5c15eabb1b951aJan Zeleny }
/* Allow not implemented */
else if (rc == 504)
/* ignore it silently */;
return ret;
}
/* Return the current directory which we have selected on the FTP server, or NULL */
static char *ftp_get_PWD(request_rec *r, conn_rec *ftp_ctrl, apr_bucket_brigade *bb)
{
char *cwd = NULL;
char *ftpmessage = NULL;
/* responses: 257, 500, 501, 502, 421, 550 */
/* 257 "<directory-name>" <commentary> */
/* 421 Service not available, closing control connection. */
/* 500 Syntax error, command unrecognized. */
/* 501 Syntax error in parameters or arguments. */
/* 502 Command not implemented. */
/* 550 Requested action not taken. */
switch (proxy_ftp_command("PWD" CRLF, r, ftp_ctrl, bb, &ftpmessage)) {
case -1:
case 421:
case 550:
ap_proxyerror(r, HTTP_BAD_GATEWAY,
"Failed to read PWD on ftp server");
break;
case 257: {
const char *dirp = ftpmessage;
cwd = ap_getword_conf(r->pool, &dirp);
}
}
return cwd;
}
/* Common routine for failed authorization (i.e., missing or wrong password)
* to an ftp service. This causes most browsers to retry the request
* with username and password (which was presumably queried from the user)
* supplied in the Authorization: header.
* Note that we "invent" a realm name which consists of the
* ftp://user@host part of the reqest (sans password -if supplied but invalid-)
*/
static int ftp_unauthorized(request_rec *r, int log_it)
{
r->proxyreq = PROXYREQ_NONE;
/*
* Log failed requests if they supplied a password (log username/password
* guessing attempts)
*/
if (log_it)
ap_log_rerror(APLOG_MARK, APLOG_INFO, 0, r,
"proxy: missing or failed auth to %s",
apr_uri_unparse(r->pool,
&r->parsed_uri, APR_URI_UNP_OMITPATHINFO));
apr_table_setn(r->err_headers_out, "WWW-Authenticate",
apr_pstrcat(r->pool, "Basic realm=\"",
apr_uri_unparse(r->pool, &r->parsed_uri,
APR_URI_UNP_OMITPASSWORD | APR_URI_UNP_OMITPATHINFO),
"\"", NULL));
return HTTP_UNAUTHORIZED;
}
static
apr_status_t proxy_ftp_cleanup(request_rec *r, proxy_conn_rec *backend)
{
backend->close = 1;
ap_set_module_config(r->connection->conn_config, &proxy_ftp_module, NULL);
ap_proxy_release_connection("FTP", backend, r->server);
return OK;
}
static
int ftp_proxyerror(request_rec *r, proxy_conn_rec *conn, int statuscode, const char *message)
{
proxy_ftp_cleanup(r, conn);
return ap_proxyerror(r, statuscode, message);
}
/*
* Handles direct access of ftp:// URLs
* Original (Non-PASV) version from
* Troy Morrison <spiffnet@zoom.com>
* PASV added by Chuck
* Filters by [Graham Leggett <minfrin@sharp.fm>]
*/
static int proxy_ftp_handler(request_rec *r, proxy_worker *worker,
proxy_server_conf *conf, char *url,
const char *proxyhost, apr_port_t proxyport)
{
apr_pool_t *p = r->pool;
conn_rec *c = r->connection;
proxy_conn_rec *backend;
apr_socket_t *sock, *local_sock, *data_sock = NULL;
apr_sockaddr_t *connect_addr = NULL;
apr_status_t rv;
conn_rec *origin, *data = NULL;
apr_status_t err = APR_SUCCESS;
apr_status_t uerr = APR_SUCCESS;
apr_bucket_brigade *bb = apr_brigade_create(p, c->bucket_alloc);
char *buf, *connectname;
apr_port_t connectport;
char buffer[MAX_STRING_LEN];
char *ftpmessage = NULL;
char *path, *strp, *type_suffix, *cwd = NULL;
apr_uri_t uri;
char *user = NULL;
/* char *account = NULL; how to supply an account in a URL? */
const char *password = NULL;
int len, rc;
int one = 1;
char *size = NULL;
char xfer_type = 'A'; /* after ftp login, the default is ASCII */
int dirlisting = 0;
#if defined(USE_MDTM) && (defined(HAVE_TIMEGM) || defined(HAVE_GMTOFF))
apr_time_t mtime = 0L;
#endif
/* stuff for PASV mode */
int connect = 0, use_port = 0;
char dates[APR_RFC822_DATE_LEN];
int status;
apr_pool_t *address_pool;
/* is this for us? */
if (proxyhost) {
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: declining URL %s - proxyhost %s specified:", url, proxyhost);
return DECLINED; /* proxy connections are via HTTP */
}
if (strncasecmp(url, "ftp:", 4)) {
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: declining URL %s - not ftp:", url);
return DECLINED; /* only interested in FTP */
}
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: serving URL %s", url);
/*
* I: Who Do I Connect To? -----------------------
*
* Break up the URL to determine the host to connect to
*/
/* we only support GET and HEAD */
if (r->method_number != M_GET)
return HTTP_NOT_IMPLEMENTED;
/* We break the URL into host, port, path-search */
if (r->parsed_uri.hostname == NULL) {
if (APR_SUCCESS != apr_uri_parse(p, url, &uri)) {
return ap_proxyerror(r, HTTP_BAD_REQUEST,
apr_psprintf(p, "URI cannot be parsed: %s", url));
}
connectname = uri.hostname;
connectport = uri.port;
path = apr_pstrdup(p, uri.path);
}
else {
connectname = r->parsed_uri.hostname;
connectport = r->parsed_uri.port;
path = apr_pstrdup(p, r->parsed_uri.path);
}
if (connectport == 0) {
connectport = apr_uri_port_of_scheme("ftp");
}
path = (path != NULL && path[0] != '\0') ? &path[1] : "";
type_suffix = strchr(path, ';');
if (type_suffix != NULL)
*(type_suffix++) = '\0';
if (type_suffix != NULL && strncmp(type_suffix, "type=", 5) == 0
&& apr_isalpha(type_suffix[5])) {
/* "type=d" forces a dir listing.
* The other types (i|a|e) are directly used for the ftp TYPE command
*/
if ( ! (dirlisting = (apr_tolower(type_suffix[5]) == 'd')))
xfer_type = apr_toupper(type_suffix[5]);
/* Check valid types, rather than ignoring invalid types silently: */
if (strchr("AEI", xfer_type) == NULL)
return ap_proxyerror(r, HTTP_BAD_REQUEST, apr_pstrcat(r->pool,
"ftp proxy supports only types 'a', 'i', or 'e': \"",
type_suffix, "\" is invalid.", NULL));
}
else {
/* make binary transfers the default */
xfer_type = 'I';
}
/*
* The "Authorization:" header must be checked first. We allow the user
* to "override" the URL-coded user [ & password ] in the Browsers'
* User&Password Dialog. NOTE that this is only marginally more secure
* than having the password travel in plain as part of the URL, because
* Basic Auth simply uuencodes the plain text password. But chances are
* still smaller that the URL is logged regularly.
*/
if ((password = apr_table_get(r->headers_in, "Authorization")) != NULL
&& strcasecmp(ap_getword(r->pool, &password, ' '), "Basic") == 0
&& (password = ap_pbase64decode(r->pool, password))[0] != ':') {
/*
* Note that this allocation has to be made from r->connection->pool
* because it has the lifetime of the connection. The other
* allocations are temporary and can be tossed away any time.
*/
user = ap_getword_nulls(r->connection->pool, &password, ':');
r->ap_auth_type = "Basic";
r->user = r->parsed_uri.user = user;
}
else if ((user = r->parsed_uri.user) != NULL) {
user = apr_pstrdup(p, user);
decodeenc(user);
if ((password = r->parsed_uri.password) != NULL) {
char *tmp = apr_pstrdup(p, password);
decodeenc(tmp);
password = tmp;
}
}
else {
user = "anonymous";
password = "apache-proxy@";
}
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: connecting %s to %s:%d", url, connectname, connectport);
if (worker->is_address_reusable) {
if (!worker->cp->addr) {
if ((err = PROXY_THREAD_LOCK(worker)) != APR_SUCCESS) {
ap_log_error(APLOG_MARK, APLOG_ERR, err, r->server,
"proxy: FTP: lock");
return HTTP_INTERNAL_SERVER_ERROR;
}
}
connect_addr = worker->cp->addr;
address_pool = worker->cp->pool;
}
else
address_pool = r->pool;
/* do a DNS lookup for the destination host */
if (!connect_addr)
err = apr_sockaddr_info_get(&(connect_addr),
connectname, APR_UNSPEC,
connectport, 0,
address_pool);
if (worker->is_address_reusable && !worker->cp->addr) {
worker->cp->addr = connect_addr;
if ((uerr = PROXY_THREAD_UNLOCK(worker)) != APR_SUCCESS) {
ap_log_error(APLOG_MARK, APLOG_ERR, uerr, r->server,
"proxy: FTP: unlock");
}
}
/*
* get all the possible IP addresses for the destname and loop through
* them until we get a successful connection
*/
if (APR_SUCCESS != err) {
return ap_proxyerror(r, HTTP_BAD_GATEWAY, apr_pstrcat(p,
"DNS lookup failure for: ",
connectname, NULL));
}
/* check if ProxyBlock directive on this host */
if (OK != ap_proxy_checkproxyblock(r, conf, connect_addr)) {
return ap_proxyerror(r, HTTP_FORBIDDEN,
"Connect to remote machine blocked");
}
/* create space for state information */
backend = (proxy_conn_rec *) ap_get_module_config(c->conn_config, &proxy_ftp_module);
if (!backend) {
status = ap_proxy_acquire_connection("FTP", &backend, worker, r->server);
if (status != OK) {
if (backend) {
backend->close = 1;
ap_proxy_release_connection("FTP", backend, r->server);
}
return status;
}
/* TODO: see if ftp could use determine_connection */
backend->addr = connect_addr;
backend->r = r;
ap_set_module_config(c->conn_config, &proxy_ftp_module, backend);
}
/*
* II: Make the Connection -----------------------
*
* We have determined who to connect to. Now make the connection.
*/
if (ap_proxy_connect_backend("FTP", backend, worker, r->server)) {
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: an error occurred creating a new connection to %pI (%s)",
connect_addr, connectname);
proxy_ftp_cleanup(r, backend);
return HTTP_SERVICE_UNAVAILABLE;
}
if (!backend->connection) {
status = ap_proxy_connection_create("FTP", backend, c, r->server);
if (status != OK) {
proxy_ftp_cleanup(r, backend);
return status;
}
}
/* Use old naming */
origin = backend->connection;
sock = backend->sock;
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: control connection complete");
/*
* III: Send Control Request -------------------------
*
* Log into the ftp server, send the username & password, change to the
* correct directory...
*/
/* possible results: */
/* 120 Service ready in nnn minutes. */
/* 220 Service ready for new user. */
/* 421 Service not available, closing control connection. */
rc = proxy_ftp_command(NULL, r, origin, bb, &ftpmessage);
if (rc == -1 || rc == 421) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY, "Error reading from remote server");
}
if (rc == 120) {
/*
* RFC2616 states: 14.37 Retry-After
*
* The Retry-After response-header field can be used with a 503 (Service
* Unavailable) response to indicate how long the service is expected
* to be unavailable to the requesting client. [...] The value of
* this field can be either an HTTP-date or an integer number of
* seconds (in decimal) after the time of the response. Retry-After
* = "Retry-After" ":" ( HTTP-date | delta-seconds )
*/
char *secs_str = ftpmessage;
time_t secs;
/* Look for a number, preceded by whitespace */
while (*secs_str)
if ((secs_str==ftpmessage || apr_isspace(secs_str[-1])) &&
apr_isdigit(secs_str[0]))
break;
if (*secs_str != '\0') {
secs = atol(secs_str);
apr_table_add(r->headers_out, "Retry-After",
apr_psprintf(p, "%lu", (unsigned long)(60 * secs)));
}
return ftp_proxyerror(r, backend, HTTP_SERVICE_UNAVAILABLE, ftpmessage);
}
if (rc != 220) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY, ftpmessage);
}
rc = proxy_ftp_command(apr_pstrcat(p, "USER ", user, CRLF, NULL),
r, origin, bb, &ftpmessage);
/* possible results; 230, 331, 332, 421, 500, 501, 530 */
/* states: 1 - error, 2 - success; 3 - send password, 4,5 fail */
/* 230 User logged in, proceed. */
/* 331 User name okay, need password. */
/* 332 Need account for login. */
/* 421 Service not available, closing control connection. */
/* 500 Syntax error, command unrecognized. */
/* (This may include errors such as command line too long.) */
/* 501 Syntax error in parameters or arguments. */
/* 530 Not logged in. */
if (rc == -1 || rc == 421) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY, "Error reading from remote server");
}
if (rc == 530) {
proxy_ftp_cleanup(r, backend);
return ftp_unauthorized(r, 1); /* log it: user name guessing
* attempt? */
}
if (rc != 230 && rc != 331) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY, ftpmessage);
}
if (rc == 331) { /* send password */
if (password == NULL) {
proxy_ftp_cleanup(r, backend);
return ftp_unauthorized(r, 0);
}
rc = proxy_ftp_command(apr_pstrcat(p, "PASS ", password, CRLF, NULL),
r, origin, bb, &ftpmessage);
/* possible results 202, 230, 332, 421, 500, 501, 503, 530 */
/* 230 User logged in, proceed. */
/* 332 Need account for login. */
/* 421 Service not available, closing control connection. */
/* 500 Syntax error, command unrecognized. */
/* 501 Syntax error in parameters or arguments. */
/* 503 Bad sequence of commands. */
/* 530 Not logged in. */
if (rc == -1 || rc == 421) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY,
"Error reading from remote server");
}
if (rc == 332) {
return ftp_proxyerror(r, backend, HTTP_UNAUTHORIZED,
apr_pstrcat(p, "Need account for login: ", ftpmessage, NULL));
}
/* @@@ questionable -- we might as well return a 403 Forbidden here */
if (rc == 530) {
proxy_ftp_cleanup(r, backend);
return ftp_unauthorized(r, 1); /* log it: passwd guessing
* attempt? */
}
if (rc != 230 && rc != 202) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY, ftpmessage);
}
}
apr_table_set(r->notes, "Directory-README", ftpmessage);
/* Special handling for leading "%2f": this enforces a "cwd /"
* out of the $HOME directory which was the starting point after login
*/
if (strncasecmp(path, "%2f", 3) == 0) {
path += 3;
while (*path == '/') /* skip leading '/' (after root %2f) */
++path;
rc = proxy_ftp_command("CWD /" CRLF, r, origin, bb, &ftpmessage);
if (rc == -1 || rc == 421)
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY,
"Error reading from remote server");
}
/*
* set the directory (walk directory component by component): this is
* what we must do if we don't know the OS type of the remote machine
*/
for (;;) {
strp = strchr(path, '/');
if (strp == NULL)
break;
*strp = '\0';
len = decodeenc(path); /* Note! This decodes a %2f -> "/" */
if (strchr(path, '/')) { /* are there now any '/' characters? */
return ftp_proxyerror(r, backend, HTTP_BAD_REQUEST,
"Use of /%2f is only allowed at the base directory");
}
/* NOTE: FTP servers do globbing on the path.
* So we need to escape the URI metacharacters.
* We use a special glob-escaping routine to escape globbing chars.
* We could also have extended gen_test_char.c with a special T_ESCAPE_FTP_PATH
*/
rc = proxy_ftp_command(apr_pstrcat(p, "CWD ",
ftp_escape_globbingchars(p, path), CRLF, NULL),
r, origin, bb, &ftpmessage);
*strp = '/';
/* responses: 250, 421, 500, 501, 502, 530, 550 */
/* 250 Requested file action okay, completed. */
/* 421 Service not available, closing control connection. */
/* 500 Syntax error, command unrecognized. */
/* 501 Syntax error in parameters or arguments. */
/* 502 Command not implemented. */
/* 530 Not logged in. */
/* 550 Requested action not taken. */
if (rc == -1 || rc == 421) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY,
"Error reading from remote server");
}
if (rc == 550) {
return ftp_proxyerror(r, backend, HTTP_NOT_FOUND, ftpmessage);
}
if (rc != 250) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY, ftpmessage);
}
path = strp + 1;
}
/*
* IV: Make Data Connection? -------------------------
*
* Try EPSV, if that fails... try PASV, if that fails... try PORT.
*/
/* this temporarily switches off EPSV/PASV */
/*goto bypass;*/
/* set up data connection - EPSV */
{
apr_sockaddr_t *data_addr;
char *data_ip;
apr_port_t data_port;
/*
* The EPSV command replaces PASV where both IPV4 and IPV6 is
* supported. Only the port is returned, the IP address is always the
* same as that on the control connection. Example: Entering Extended
* Passive Mode (|||6446|)
*/
rc = proxy_ftp_command("EPSV" CRLF,
r, origin, bb, &ftpmessage);
/* possible results: 227, 421, 500, 501, 502, 530 */
/* 227 Entering Passive Mode (h1,h2,h3,h4,p1,p2). */
/* 421 Service not available, closing control connection. */
/* 500 Syntax error, command unrecognized. */
/* 501 Syntax error in parameters or arguments. */
/* 502 Command not implemented. */
/* 530 Not logged in. */
if (rc == -1 || rc == 421) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY,
"Error reading from remote server");
}
if (rc != 229 && rc != 500 && rc != 501 && rc != 502) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY, ftpmessage);
}
else if (rc == 229) {
char *pstr;
char *tok_cntx;
pstr = ftpmessage;
pstr = apr_strtok(pstr, " ", &tok_cntx); /* separate result code */
if (pstr != NULL) {
if (*(pstr + strlen(pstr) + 1) == '=') {
pstr += strlen(pstr) + 2;
}
else {
pstr = apr_strtok(NULL, "(", &tok_cntx); /* separate address &
* port params */
if (pstr != NULL)
pstr = apr_strtok(NULL, ")", &tok_cntx);
}
}
if (pstr) {
apr_sockaddr_t *epsv_addr;
data_port = atoi(pstr + 3);
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: EPSV contacting remote host on port %d",
data_port);
if ((rv = apr_socket_create(&data_sock, connect_addr->family, SOCK_STREAM, 0, r->pool)) != APR_SUCCESS) {
ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r,
"proxy: FTP: error creating EPSV socket");
proxy_ftp_cleanup(r, backend);
return HTTP_INTERNAL_SERVER_ERROR;
}
#if !defined (TPF) && !defined(BEOS)
if (conf->recv_buffer_size > 0
&& (rv = apr_socket_opt_set(data_sock, APR_SO_RCVBUF,
conf->recv_buffer_size))) {
ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r,
"proxy: FTP: apr_socket_opt_set(SO_RCVBUF): Failed to set ProxyReceiveBufferSize, using default");
}
#endif
rv = apr_socket_opt_set(data_sock, APR_TCP_NODELAY, 1);
if (rv != APR_SUCCESS && rv != APR_ENOTIMPL) {
ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r,
"apr_socket_opt_set(APR_TCP_NODELAY): Failed to set");
}
/* make the connection */
apr_socket_addr_get(&data_addr, APR_REMOTE, sock);
apr_sockaddr_ip_get(&data_ip, data_addr);
apr_sockaddr_info_get(&epsv_addr, data_ip, connect_addr->family, data_port, 0, p);
rv = apr_socket_connect(data_sock, epsv_addr);
if (rv != APR_SUCCESS) {
ap_log_error(APLOG_MARK, APLOG_ERR, rv, r->server,
"proxy: FTP: EPSV attempt to connect to %pI failed - Firewall/NAT?", epsv_addr);
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY, apr_psprintf(r->pool,
"EPSV attempt to connect to %pI failed - firewall/NAT?", epsv_addr));
}
else {
connect = 1;
}
}
else {
/* and try the regular way */
apr_socket_close(data_sock);
}
}
}
/* set up data connection - PASV */
if (!connect) {
rc = proxy_ftp_command("PASV" CRLF,
r, origin, bb, &ftpmessage);
/* possible results: 227, 421, 500, 501, 502, 530 */
/* 227 Entering Passive Mode (h1,h2,h3,h4,p1,p2). */
/* 421 Service not available, closing control connection. */
/* 500 Syntax error, command unrecognized. */
/* 501 Syntax error in parameters or arguments. */
/* 502 Command not implemented. */
/* 530 Not logged in. */
if (rc == -1 || rc == 421) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY,
"Error reading from remote server");
}
if (rc != 227 && rc != 502) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY, ftpmessage);
}
else if (rc == 227) {
unsigned int h0, h1, h2, h3, p0, p1;
char *pstr;
char *tok_cntx;
/* FIXME: Check PASV against RFC1123 */
pstr = ftpmessage;
pstr = apr_strtok(pstr, " ", &tok_cntx); /* separate result code */
if (pstr != NULL) {
if (*(pstr + strlen(pstr) + 1) == '=') {
pstr += strlen(pstr) + 2;
}
else {
pstr = apr_strtok(NULL, "(", &tok_cntx); /* separate address &
* port params */
if (pstr != NULL)
pstr = apr_strtok(NULL, ")", &tok_cntx);
}
}
/* FIXME: Only supports IPV4 - fix in RFC2428 */
if (pstr != NULL && (sscanf(pstr,
"%d,%d,%d,%d,%d,%d", &h3, &h2, &h1, &h0, &p1, &p0) == 6)) {
apr_sockaddr_t *pasv_addr;
apr_port_t pasvport = (p1 << 8) + p0;
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: PASV contacting host %d.%d.%d.%d:%d",
h3, h2, h1, h0, pasvport);
if ((rv = apr_socket_create(&data_sock, connect_addr->family, SOCK_STREAM, 0, r->pool)) != APR_SUCCESS) {
ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r,
"proxy: error creating PASV socket");
proxy_ftp_cleanup(r, backend);
return HTTP_INTERNAL_SERVER_ERROR;
}
#if !defined (TPF) && !defined(BEOS)
if (conf->recv_buffer_size > 0
&& (rv = apr_socket_opt_set(data_sock, APR_SO_RCVBUF,
conf->recv_buffer_size))) {
ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r,
"proxy: FTP: apr_socket_opt_set(SO_RCVBUF): Failed to set ProxyReceiveBufferSize, using default");
}
#endif
rv = apr_socket_opt_set(data_sock, APR_TCP_NODELAY, 1);
if (rv != APR_SUCCESS && rv != APR_ENOTIMPL) {
ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r,
"apr_socket_opt_set(APR_TCP_NODELAY): Failed to set");
}
/* make the connection */
apr_sockaddr_info_get(&pasv_addr, apr_psprintf(p, "%d.%d.%d.%d", h3, h2, h1, h0), connect_addr->family, pasvport, 0, p);
rv = apr_socket_connect(data_sock, pasv_addr);
if (rv != APR_SUCCESS) {
ap_log_error(APLOG_MARK, APLOG_ERR, rv, r->server,
"proxy: FTP: PASV attempt to connect to %pI failed - Firewall/NAT?", pasv_addr);
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY, apr_psprintf(r->pool,
"PASV attempt to connect to %pI failed - firewall/NAT?", pasv_addr));
}
else {
connect = 1;
}
}
else {
/* and try the regular way */
apr_socket_close(data_sock);
}
}
}
/*bypass:*/
/* set up data connection - PORT */
if (!connect) {
apr_sockaddr_t *local_addr;
char *local_ip;
apr_port_t local_port;
unsigned int h0, h1, h2, h3, p0, p1;
if ((rv = apr_socket_create(&local_sock, connect_addr->family, SOCK_STREAM, 0, r->pool)) != APR_SUCCESS) {
ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r,
"proxy: FTP: error creating local socket");
proxy_ftp_cleanup(r, backend);
return HTTP_INTERNAL_SERVER_ERROR;
}
apr_socket_addr_get(&local_addr, APR_LOCAL, sock);
local_port = local_addr->port;
apr_sockaddr_ip_get(&local_ip, local_addr);
if ((rv = apr_socket_opt_set(local_sock, APR_SO_REUSEADDR, one))
!= APR_SUCCESS) {
#ifndef _OSD_POSIX /* BS2000 has this option "always on" */
ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r,
"proxy: FTP: error setting reuseaddr option");
proxy_ftp_cleanup(r, backend);
return HTTP_INTERNAL_SERVER_ERROR;
#endif /* _OSD_POSIX */
}
apr_sockaddr_info_get(&local_addr, local_ip, APR_UNSPEC, local_port, 0, r->pool);
if ((rv = apr_socket_bind(local_sock, local_addr)) != APR_SUCCESS) {
ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r,
"proxy: FTP: error binding to ftp data socket %pI", local_addr);
proxy_ftp_cleanup(r, backend);
return HTTP_INTERNAL_SERVER_ERROR;
}
/* only need a short queue */
if ((rv = apr_socket_listen(local_sock, 2)) != APR_SUCCESS) {
ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r,
"proxy: FTP: error listening to ftp data socket %pI", local_addr);
proxy_ftp_cleanup(r, backend);
return HTTP_INTERNAL_SERVER_ERROR;
}
/* FIXME: Sent PORT here */
if (local_ip && (sscanf(local_ip,
"%d.%d.%d.%d", &h3, &h2, &h1, &h0) == 4)) {
p1 = (local_port >> 8);
p0 = (local_port & 0xFF);
rc = proxy_ftp_command(apr_psprintf(p, "PORT %d,%d,%d,%d,%d,%d" CRLF, h3, h2, h1, h0, p1, p0),
r, origin, bb, &ftpmessage);
/* possible results: 200, 421, 500, 501, 502, 530 */
/* 200 Command okay. */
/* 421 Service not available, closing control connection. */
/* 500 Syntax error, command unrecognized. */
/* 501 Syntax error in parameters or arguments. */
/* 502 Command not implemented. */
/* 530 Not logged in. */
if (rc == -1 || rc == 421) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY,
"Error reading from remote server");
}
if (rc != 200) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY, buffer);
}
/* signal that we must use the EPRT/PORT loop */
use_port = 1;
}
else {
/* IPV6 FIXME:
* The EPRT command replaces PORT where both IPV4 and IPV6 is supported. The first
* number (1,2) indicates the protocol type. Examples:
* EPRT |1|132.235.1.2|6275|
* EPRT |2|1080::8:800:200C:417A|5282|
*/
return ftp_proxyerror(r, backend, HTTP_NOT_IMPLEMENTED,
"Connect to IPV6 ftp server using EPRT not supported. Enable EPSV.");
}
}
/*
* V: Set The Headers -------------------
*
* Get the size of the request, set up the environment for HTTP.
*/
/* set request; "path" holds last path component */
len = decodeenc(path);
if (strchr(path, '/')) { /* are there now any '/' characters? */
return ftp_proxyerror(r, backend, HTTP_BAD_REQUEST,
"Use of /%2f is only allowed at the base directory");
}
/* If len == 0 then it must be a directory (you can't RETR nothing)
* Also, don't allow to RETR by wildcard. Instead, create a dirlisting
*/
if (len == 0 || ftp_check_globbingchars(path)) {
dirlisting = 1;
}
else {
/* (from FreeBSD ftpd):
* SIZE is not in RFC959, but Postel has blessed it and
* it will be in the updated RFC.
*
* Return size of file in a format suitable for
* using with RESTART (we just count bytes).
*/
/* from draft-ietf-ftpext-mlst-14.txt:
* This value will
* change depending on the current STRUcture, MODE and TYPE of the data
* connection, or a data connection which would be created were one
* created now. Thus, the result of the SIZE command is dependent on
* the currently established STRU, MODE and TYPE parameters.
*/
/* Therefore: switch to binary if the user did not specify ";type=a" */
ftp_set_TYPE(xfer_type, r, origin, bb, &ftpmessage);
rc = proxy_ftp_command(apr_pstrcat(p, "SIZE ",
ftp_escape_globbingchars(p, path), CRLF, NULL),
r, origin, bb, &ftpmessage);
if (rc == -1 || rc == 421) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY,
"Error reading from remote server");
}
else if (rc == 213) {/* Size command ok */
int j;
for (j = 0; apr_isdigit(ftpmessage[j]); j++)
;
ftpmessage[j] = '\0';
if (ftpmessage[0] != '\0')
size = ftpmessage; /* already pstrdup'ed: no copy necessary */
}
else if (rc == 550) { /* Not a regular file */
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: SIZE shows this is a directory");
dirlisting = 1;
rc = proxy_ftp_command(apr_pstrcat(p, "CWD ",
ftp_escape_globbingchars(p, path), CRLF, NULL),
r, origin, bb, &ftpmessage);
/* possible results: 250, 421, 500, 501, 502, 530, 550 */
/* 250 Requested file action okay, completed. */
/* 421 Service not available, closing control connection. */
/* 500 Syntax error, command unrecognized. */
/* 501 Syntax error in parameters or arguments. */
/* 502 Command not implemented. */
/* 530 Not logged in. */
/* 550 Requested action not taken. */
if (rc == -1 || rc == 421) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY,
"Error reading from remote server");
}
if (rc == 550) {
return ftp_proxyerror(r, backend, HTTP_NOT_FOUND, ftpmessage);
}
if (rc != 250) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY, ftpmessage);
}
path = "";
len = 0;
}
}
cwd = ftp_get_PWD(r, origin, bb);
if (cwd != NULL) {
apr_table_set(r->notes, "Directory-PWD", cwd);
}
if (dirlisting) {
ftp_set_TYPE('A', r, origin, bb, NULL);
/* If the current directory contains no slash, we are talking to
* a non-unix ftp system. Try LIST instead of "LIST -lag", it
* should return a long listing anyway (unlike NLST).
* Some exotic FTP servers might choke on the "-lag" switch.
*/
/* Note that we do not escape the path here, to allow for
* queries like: ftp://user@host/apache/src/server/http_*.c
*/
if (len != 0)
buf = apr_pstrcat(p, "LIST ", path, CRLF, NULL);
else if (cwd == NULL || strchr(cwd, '/') != NULL)
buf = apr_pstrcat(p, "LIST -lag", CRLF, NULL);
else
buf = "LIST" CRLF;
}
else {
/* switch to binary if the user did not specify ";type=a" */
ftp_set_TYPE(xfer_type, r, origin, bb, &ftpmessage);
#if defined(USE_MDTM) && (defined(HAVE_TIMEGM) || defined(HAVE_GMTOFF))
/* from draft-ietf-ftpext-mlst-14.txt:
* The FTP command, MODIFICATION TIME (MDTM), can be used to determine
* when a file in the server NVFS was last modified. <..>
* The syntax of a time value is:
* time-val = 14DIGIT [ "." 1*DIGIT ] <..>
* Symbolically, a time-val may be viewed as
* YYYYMMDDHHMMSS.sss
* The "." and subsequent digits ("sss") are optional. <..>
* Time values are always represented in UTC (GMT)
*/
rc = proxy_ftp_command(apr_pstrcat(p, "MDTM ", ftp_escape_globbingchars(p, path), CRLF, NULL),
r, origin, bb, &ftpmessage);
/* then extract the Last-Modified time from it (YYYYMMDDhhmmss or YYYYMMDDhhmmss.xxx GMT). */
if (rc == 213) {
struct {
char YYYY[4+1];
char MM[2+1];
char DD[2+1];
char hh[2+1];
char mm[2+1];
char ss[2+1];
} time_val;
if (6 == sscanf(ftpmessage, "%4[0-9]%2[0-9]%2[0-9]%2[0-9]%2[0-9]%2[0-9]",
time_val.YYYY, time_val.MM, time_val.DD, time_val.hh, time_val.mm, time_val.ss)) {
struct tm tms;
memset (&tms, '\0', sizeof tms);
tms.tm_year = atoi(time_val.YYYY) - 1900;
tms.tm_mon = atoi(time_val.MM) - 1;
tms.tm_mday = atoi(time_val.DD);
tms.tm_hour = atoi(time_val.hh);
tms.tm_min = atoi(time_val.mm);
tms.tm_sec = atoi(time_val.ss);
#ifdef HAVE_TIMEGM /* Does system have timegm()? */
mtime = timegm(&tms);
mtime *= APR_USEC_PER_SEC;
#elif HAVE_GMTOFF /* does struct tm have a member tm_gmtoff? */
/* mktime will subtract the local timezone, which is not what we want.
* Add it again because the MDTM string is GMT
*/
mtime = mktime(&tms);
mtime += tms.tm_gmtoff;
mtime *= APR_USEC_PER_SEC;
#else
mtime = 0L;
#endif
}
}
#endif /* USE_MDTM */
/* FIXME: Handle range requests - send REST */
buf = apr_pstrcat(p, "RETR ", ftp_escape_globbingchars(p, path), CRLF, NULL);
}
rc = proxy_ftp_command(buf, r, origin, bb, &ftpmessage);
/* rc is an intermediate response for the LIST or RETR commands */
/*
* RETR: 110, 125, 150, 226, 250, 421, 425, 426, 450, 451, 500, 501, 530,
* 550 NLST: 125, 150, 226, 250, 421, 425, 426, 450, 451, 500, 501, 502,
* 530
*/
/* 110 Restart marker reply. */
/* 125 Data connection already open; transfer starting. */
/* 150 File status okay; about to open data connection. */
/* 226 Closing data connection. */
/* 250 Requested file action okay, completed. */
/* 421 Service not available, closing control connection. */
/* 425 Can't open data connection. */
/* 426 Connection closed; transfer aborted. */
/* 450 Requested file action not taken. */
/* 451 Requested action aborted. Local error in processing. */
/* 500 Syntax error, command unrecognized. */
/* 501 Syntax error in parameters or arguments. */
/* 530 Not logged in. */
/* 550 Requested action not taken. */
if (rc == -1 || rc == 421) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY,
"Error reading from remote server");
}
if (rc == 550) {
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: RETR failed, trying LIST instead");
/* Directory Listings should always be fetched in ASCII mode */
dirlisting = 1;
ftp_set_TYPE('A', r, origin, bb, NULL);
rc = proxy_ftp_command(apr_pstrcat(p, "CWD ",
ftp_escape_globbingchars(p, path), CRLF, NULL),
r, origin, bb, &ftpmessage);
/* possible results: 250, 421, 500, 501, 502, 530, 550 */
/* 250 Requested file action okay, completed. */
/* 421 Service not available, closing control connection. */
/* 500 Syntax error, command unrecognized. */
/* 501 Syntax error in parameters or arguments. */
/* 502 Command not implemented. */
/* 530 Not logged in. */
/* 550 Requested action not taken. */
if (rc == -1 || rc == 421) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY,
"Error reading from remote server");
}
if (rc == 550) {
return ftp_proxyerror(r, backend, HTTP_NOT_FOUND, ftpmessage);
}
if (rc != 250) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY, ftpmessage);
}
/* Update current directory after CWD */
cwd = ftp_get_PWD(r, origin, bb);
if (cwd != NULL) {
apr_table_set(r->notes, "Directory-PWD", cwd);
}
/* See above for the "LIST" vs. "LIST -lag" discussion. */
rc = proxy_ftp_command((cwd == NULL || strchr(cwd, '/') != NULL)
? "LIST -lag" CRLF : "LIST" CRLF,
r, origin, bb, &ftpmessage);
/* rc is an intermediate response for the LIST command (125 transfer starting, 150 opening data connection) */
if (rc == -1 || rc == 421)
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY,
"Error reading from remote server");
}
if (rc != 125 && rc != 150 && rc != 226 && rc != 250) {
return ftp_proxyerror(r, backend, HTTP_BAD_GATEWAY, ftpmessage);
}
r->status = HTTP_OK;
r->status_line = "200 OK";
apr_rfc822_date(dates, r->request_time);
apr_table_setn(r->headers_out, "Date", dates);
apr_table_setn(r->headers_out, "Server", ap_get_server_banner());
/* set content-type */
if (dirlisting) {
ap_set_content_type(r, "text/html");
}
else {
if (r->content_type) {
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: Content-Type set to %s", r->content_type);
}
else {
ap_set_content_type(r, ap_default_type(r));
}
if (xfer_type != 'A' && size != NULL) {
/* We "trust" the ftp server to really serve (size) bytes... */
apr_table_setn(r->headers_out, "Content-Length", size);
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: Content-Length set to %s", size);
}
}
apr_table_setn(r->headers_out, "Content-Type", r->content_type);
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: Content-Type set to %s", r->content_type);
#if defined(USE_MDTM) && (defined(HAVE_TIMEGM) || defined(HAVE_GMTOFF))
if (mtime != 0L) {
char datestr[APR_RFC822_DATE_LEN];
apr_rfc822_date(datestr, mtime);
apr_table_set(r->headers_out, "Last-Modified", datestr);
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: Last-Modified set to %s", datestr);
}
#endif /* USE_MDTM */
/* If an encoding has been set by mistake, delete it.
* @@@ FIXME (e.g., for ftp://user@host/file*.tar.gz,
* @@@ the encoding is currently set to x-gzip)
*/
if (dirlisting && r->content_encoding != NULL)
r->content_encoding = NULL;
/* set content-encoding (not for dir listings, they are uncompressed)*/
if (r->content_encoding != NULL && r->content_encoding[0] != '\0') {
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: Content-Encoding set to %s", r->content_encoding);
apr_table_setn(r->headers_out, "Content-Encoding", r->content_encoding);
}
/* wait for connection */
if (use_port) {
for (;;) {
rv = apr_socket_accept(&data_sock, local_sock, r->pool);
if (rv == APR_EINTR) {
continue;
}
else if (rv == APR_SUCCESS) {
break;
}
else {
ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r,
"proxy: FTP: failed to accept data connection");
proxy_ftp_cleanup(r, backend);
return HTTP_BAD_GATEWAY;
}
}
}
/* the transfer socket is now open, create a new connection */
data = ap_run_create_connection(p, r->server, data_sock, r->connection->id,
r->connection->sbh, c->bucket_alloc);
if (!data) {
/*
* the peer reset the connection already; ap_run_create_connection() closed
* the socket
*/
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: an error occurred creating the transfer connection");
proxy_ftp_cleanup(r, backend);
return HTTP_INTERNAL_SERVER_ERROR;
}
/* set up the connection filters */
rc = ap_run_pre_connection(data, data_sock);
if (rc != OK && rc != DONE) {
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: pre_connection setup failed (%d)",
rc);
data->aborted = 1;
proxy_ftp_cleanup(r, backend);
return rc;
}
/*
* VI: Receive the Response ------------------------
*
* Get response from the remote ftp socket, and pass it up the filter chain.
*/
/* send response */
r->sent_bodyct = 1;
if (dirlisting) {
/* insert directory filter */
ap_add_output_filter("PROXY_SEND_DIR", NULL, r, r->connection);
}
/* send body */
if (!r->header_only) {
apr_bucket *e;
int finish = FALSE;
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: start body send");
/* read the body, pass it to the output filters */
while (ap_get_brigade(data->input_filters,
bb,
AP_MODE_READBYTES,
APR_BLOCK_READ,
conf->io_buffer_size) == APR_SUCCESS) {
#if DEBUGGING
{
apr_off_t readbytes;
apr_brigade_length(bb, 0, &readbytes);
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0,
r->server, "proxy (PID %d): readbytes: %#x",
getpid(), readbytes);
}
#endif
/* sanity check */
if (APR_BRIGADE_EMPTY(bb)) {
apr_brigade_cleanup(bb);
break;
}
/* found the last brigade? */
if (APR_BUCKET_IS_EOS(APR_BRIGADE_LAST(bb))) {
/* if this is the last brigade, cleanup the
* backend connection first to prevent the
* backend server from hanging around waiting
* for a slow client to eat these bytes
*/
ap_flush_conn(data);
apr_socket_close(data_sock);
data_sock = NULL;
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: data connection closed");
/* signal that we must leave */
finish = TRUE;
}
/* if no EOS yet, then we must flush */
if (FALSE == finish) {
e = apr_bucket_flush_create(c->bucket_alloc);
APR_BRIGADE_INSERT_TAIL(bb, e);
}
/* try send what we read */
if (ap_pass_brigade(r->output_filters, bb) != APR_SUCCESS
|| c->aborted) {
/* Ack! Phbtt! Die! User aborted! */
finish = TRUE;
}
/* make sure we always clean up after ourselves */
apr_brigade_cleanup(bb);
/* if we are done, leave */
if (TRUE == finish) {
break;
}
}
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: end body send");
}
if (data_sock) {
ap_flush_conn(data);
apr_socket_close(data_sock);
ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
"proxy: FTP: data connection closed");
}
/* Retrieve the final response for the RETR or LIST commands */
rc = proxy_ftp_command(NULL, r, origin, bb, &ftpmessage);
apr_brigade_cleanup(bb);
/*
* VII: Clean Up -------------
*
* If there are no KeepAlives, or if the connection has been signalled to
* close, close the socket and clean up
*/
/* finish */
rc = proxy_ftp_command("QUIT" CRLF,
r, origin, bb, &ftpmessage);
/* responses: 221, 500 */
/* 221 Service closing control connection. */
/* 500 Syntax error, command unrecognized. */
ap_flush_conn(origin);
proxy_ftp_cleanup(r, backend);
apr_brigade_destroy(bb);
return OK;
}
static void ap_proxy_ftp_register_hook(apr_pool_t *p)
{
/* hooks */
proxy_hook_scheme_handler(proxy_ftp_handler, NULL, NULL, APR_HOOK_MIDDLE);
proxy_hook_canon_handler(proxy_ftp_canon, NULL, NULL, APR_HOOK_MIDDLE);
/* filters */
ap_register_output_filter("PROXY_SEND_DIR", proxy_send_dir_filter,
NULL, AP_FTYPE_RESOURCE);
}
module AP_MODULE_DECLARE_DATA proxy_ftp_module = {
STANDARD20_MODULE_STUFF,
NULL, /* create per-directory config structure */
NULL, /* merge per-directory config structures */
NULL, /* create per-server config structure */
NULL, /* merge per-server config structures */
NULL, /* command apr_table_t */
ap_proxy_ftp_register_hook /* register hooks */
};