1 /*
2 +----------------------------------------------------------------------+
3 | PHP Version 5 |
4 +----------------------------------------------------------------------+
5 | Copyright (c) 1997-2014 The PHP Group |
6 +----------------------------------------------------------------------+
7 | This source file is subject to version 3.01 of the PHP license, |
8 | that is bundled with this package in the file LICENSE, and is |
9 | available through the world-wide-web at the following url: |
10 | http://www.php.net/license/3_01.txt |
11 | If you did not receive a copy of the PHP license and are unable to |
12 | obtain it through the world-wide-web, please send a note to |
13 | license@php.net so we can mail you a copy immediately. |
14 +----------------------------------------------------------------------+
15 | Authors: Rasmus Lerdorf <rasmus@php.net> |
16 | Jim Winstead <jimw@php.net> |
17 | Hartmut Holzgraefe <hholzgra@php.net> |
18 | Sara Golemon <pollita@php.net> |
19 +----------------------------------------------------------------------+
20 */
21 /* $Id$ */
22
23 #include "php.h"
24 #include "php_globals.h"
25 #include "php_network.h"
26 #include "php_ini.h"
27
28 #include <stdio.h>
29 #include <stdlib.h>
30 #include <errno.h>
31 #include <sys/types.h>
32 #include <sys/stat.h>
33 #include <fcntl.h>
34
35 #ifdef PHP_WIN32
36 #include <winsock2.h>
37 #define O_RDONLY _O_RDONLY
38 #include "win32/param.h"
39 #else
40 #include <sys/param.h>
41 #endif
42
43 #include "php_standard.h"
44
45 #include <sys/types.h>
46 #if HAVE_SYS_SOCKET_H
47 #include <sys/socket.h>
48 #endif
49
50 #ifdef PHP_WIN32
51 #include <winsock2.h>
52 #elif defined(NETWARE) && defined(USE_WINSOCK)
53 #include <novsock2.h>
54 #else
55 #include <netinet/in.h>
56 #include <netdb.h>
57 #if HAVE_ARPA_INET_H
58 #include <arpa/inet.h>
59 #endif
60 #endif
61
62 #if defined(PHP_WIN32) || defined(__riscos__) || defined(NETWARE)
63 #undef AF_UNIX
64 #endif
65
66 #if defined(AF_UNIX)
67 #include <sys/un.h>
68 #endif
69
70 #include "php_fopen_wrappers.h"
71
72 #define FTPS_ENCRYPT_DATA 1
73 #define GET_FTP_RESULT(stream) get_ftp_result((stream), tmp_line, sizeof(tmp_line) TSRMLS_CC)
74
75 typedef struct _php_ftp_dirstream_data {
76 php_stream *datastream;
77 php_stream *controlstream;
78 php_stream *dirstream;
79 } php_ftp_dirstream_data;
80
81 /* {{{ get_ftp_result
82 */
get_ftp_result(php_stream * stream,char * buffer,size_t buffer_size TSRMLS_DC)83 static inline int get_ftp_result(php_stream *stream, char *buffer, size_t buffer_size TSRMLS_DC)
84 {
85 while (php_stream_gets(stream, buffer, buffer_size-1) &&
86 !(isdigit((int) buffer[0]) && isdigit((int) buffer[1]) &&
87 isdigit((int) buffer[2]) && buffer[3] == ' '));
88 return strtol(buffer, NULL, 10);
89 }
90 /* }}} */
91
92 /* {{{ php_stream_ftp_stream_stat
93 */
php_stream_ftp_stream_stat(php_stream_wrapper * wrapper,php_stream * stream,php_stream_statbuf * ssb TSRMLS_DC)94 static int php_stream_ftp_stream_stat(php_stream_wrapper *wrapper, php_stream *stream, php_stream_statbuf *ssb TSRMLS_DC)
95 {
96 /* For now, we return with a failure code to prevent the underlying
97 * file's details from being used instead. */
98 return -1;
99 }
100 /* }}} */
101
102 /* {{{ php_stream_ftp_stream_close
103 */
php_stream_ftp_stream_close(php_stream_wrapper * wrapper,php_stream * stream TSRMLS_DC)104 static int php_stream_ftp_stream_close(php_stream_wrapper *wrapper, php_stream *stream TSRMLS_DC)
105 {
106 php_stream *controlstream = stream->wrapperthis;
107 int ret = 0;
108
109 if (controlstream) {
110 if (strpbrk(stream->mode, "wa+")) {
111 char tmp_line[512];
112 int result;
113
114 /* For write modes close data stream first to signal EOF to server */
115 result = GET_FTP_RESULT(controlstream);
116 if (result != 226 && result != 250) {
117 php_error_docref(NULL TSRMLS_CC, E_WARNING, "FTP server error %d:%s", result, tmp_line);
118 ret = EOF;
119 }
120 }
121
122 php_stream_write_string(controlstream, "QUIT\r\n");
123 php_stream_close(controlstream);
124 stream->wrapperthis = NULL;
125 }
126
127 return ret;
128 }
129 /* }}} */
130
131 /* {{{ php_ftp_fopen_connect
132 */
php_ftp_fopen_connect(php_stream_wrapper * wrapper,char * path,char * mode,int options,char ** opened_path,php_stream_context * context,php_stream ** preuseid,php_url ** presource,int * puse_ssl,int * puse_ssl_on_data TSRMLS_DC)133 static php_stream *php_ftp_fopen_connect(php_stream_wrapper *wrapper, char *path, char *mode, int options, char **opened_path, php_stream_context *context,
134 php_stream **preuseid, php_url **presource, int *puse_ssl, int *puse_ssl_on_data TSRMLS_DC)
135 {
136 php_stream *stream = NULL, *reuseid = NULL;
137 php_url *resource = NULL;
138 int result, use_ssl, use_ssl_on_data = 0, tmp_len;
139 char tmp_line[512];
140 char *transport;
141 int transport_len;
142
143 resource = php_url_parse(path);
144 if (resource == NULL || resource->path == NULL) {
145 if (resource && presource) {
146 *presource = resource;
147 }
148 return NULL;
149 }
150
151 use_ssl = resource->scheme && (strlen(resource->scheme) > 3) && resource->scheme[3] == 's';
152
153 /* use port 21 if one wasn't specified */
154 if (resource->port == 0)
155 resource->port = 21;
156
157 transport_len = spprintf(&transport, 0, "tcp://%s:%d", resource->host, resource->port);
158 stream = php_stream_xport_create(transport, transport_len, REPORT_ERRORS, STREAM_XPORT_CLIENT | STREAM_XPORT_CONNECT, NULL, NULL, context, NULL, NULL);
159 efree(transport);
160 if (stream == NULL) {
161 result = 0; /* silence */
162 goto connect_errexit;
163 }
164
165 php_stream_context_set(stream, context);
166 php_stream_notify_info(context, PHP_STREAM_NOTIFY_CONNECT, NULL, 0);
167
168 /* Start talking to ftp server */
169 result = GET_FTP_RESULT(stream);
170 if (result > 299 || result < 200) {
171 php_stream_notify_error(context, PHP_STREAM_NOTIFY_FAILURE, tmp_line, result);
172 goto connect_errexit;
173 }
174
175 if (use_ssl) {
176
177 /* send the AUTH TLS request name */
178 php_stream_write_string(stream, "AUTH TLS\r\n");
179
180 /* get the response */
181 result = GET_FTP_RESULT(stream);
182 if (result != 234) {
183 /* AUTH TLS not supported try AUTH SSL */
184 php_stream_write_string(stream, "AUTH SSL\r\n");
185
186 /* get the response */
187 result = GET_FTP_RESULT(stream);
188 if (result != 334) {
189 use_ssl = 0;
190 } else {
191 /* we must reuse the old SSL session id */
192 /* if we talk to an old ftpd-ssl */
193 reuseid = stream;
194 }
195 } else {
196 /* encrypt data etc */
197
198
199 }
200
201 }
202
203 if (use_ssl) {
204 if (php_stream_xport_crypto_setup(stream,
205 STREAM_CRYPTO_METHOD_SSLv23_CLIENT, NULL TSRMLS_CC) < 0
206 || php_stream_xport_crypto_enable(stream, 1 TSRMLS_CC) < 0) {
207 php_stream_wrapper_log_error(wrapper, options TSRMLS_CC, "Unable to activate SSL mode");
208 php_stream_close(stream);
209 stream = NULL;
210 goto connect_errexit;
211 }
212
213 /* set PBSZ to 0 */
214 php_stream_write_string(stream, "PBSZ 0\r\n");
215
216 /* ignore the response */
217 result = GET_FTP_RESULT(stream);
218
219 /* set data connection protection level */
220 #if FTPS_ENCRYPT_DATA
221 php_stream_write_string(stream, "PROT P\r\n");
222
223 /* get the response */
224 result = GET_FTP_RESULT(stream);
225 use_ssl_on_data = (result >= 200 && result<=299) || reuseid;
226 #else
227 php_stream_write_string(stream, "PROT C\r\n");
228
229 /* get the response */
230 result = GET_FTP_RESULT(stream);
231 #endif
232 }
233
234 #define PHP_FTP_CNTRL_CHK(val, val_len, err_msg) { \
235 unsigned char *s = val, *e = s + val_len; \
236 while (s < e) { \
237 if (iscntrl(*s)) { \
238 php_stream_wrapper_log_error(wrapper, options TSRMLS_CC, err_msg, val); \
239 goto connect_errexit; \
240 } \
241 s++; \
242 } \
243 }
244
245 /* send the user name */
246 if (resource->user != NULL) {
247 tmp_len = php_raw_url_decode(resource->user, strlen(resource->user));
248
249 PHP_FTP_CNTRL_CHK(resource->user, tmp_len, "Invalid login %s")
250
251 php_stream_printf(stream TSRMLS_CC, "USER %s\r\n", resource->user);
252 } else {
253 php_stream_write_string(stream, "USER anonymous\r\n");
254 }
255
256 /* get the response */
257 result = GET_FTP_RESULT(stream);
258
259 /* if a password is required, send it */
260 if (result >= 300 && result <= 399) {
261 php_stream_notify_info(context, PHP_STREAM_NOTIFY_AUTH_REQUIRED, tmp_line, 0);
262
263 if (resource->pass != NULL) {
264 tmp_len = php_raw_url_decode(resource->pass, strlen(resource->pass));
265
266 PHP_FTP_CNTRL_CHK(resource->pass, tmp_len, "Invalid password %s")
267
268 php_stream_printf(stream TSRMLS_CC, "PASS %s\r\n", resource->pass);
269 } else {
270 /* if the user has configured who they are,
271 send that as the password */
272 if (FG(from_address)) {
273 php_stream_printf(stream TSRMLS_CC, "PASS %s\r\n", FG(from_address));
274 } else {
275 php_stream_write_string(stream, "PASS anonymous\r\n");
276 }
277 }
278
279 /* read the response */
280 result = GET_FTP_RESULT(stream);
281
282 if (result > 299 || result < 200) {
283 php_stream_notify_error(context, PHP_STREAM_NOTIFY_AUTH_RESULT, tmp_line, result);
284 } else {
285 php_stream_notify_info(context, PHP_STREAM_NOTIFY_AUTH_RESULT, tmp_line, result);
286 }
287 }
288 if (result > 299 || result < 200) {
289 goto connect_errexit;
290 }
291
292 if (puse_ssl) {
293 *puse_ssl = use_ssl;
294 }
295 if (puse_ssl_on_data) {
296 *puse_ssl_on_data = use_ssl_on_data;
297 }
298 if (preuseid) {
299 *preuseid = reuseid;
300 }
301 if (presource) {
302 *presource = resource;
303 }
304
305 return stream;
306
307 connect_errexit:
308 if (resource) {
309 php_url_free(resource);
310 }
311
312 if (stream) {
313 php_stream_close(stream);
314 }
315
316 return NULL;
317 }
318 /* }}} */
319
320 /* {{{ php_fopen_do_pasv
321 */
php_fopen_do_pasv(php_stream * stream,char * ip,size_t ip_size,char ** phoststart TSRMLS_DC)322 static unsigned short php_fopen_do_pasv(php_stream *stream, char *ip, size_t ip_size, char **phoststart TSRMLS_DC)
323 {
324 char tmp_line[512];
325 int result, i;
326 unsigned short portno;
327 char *tpath, *ttpath, *hoststart=NULL;
328
329 #ifdef HAVE_IPV6
330 /* We try EPSV first, needed for IPv6 and works on some IPv4 servers */
331 php_stream_write_string(stream, "EPSV\r\n");
332 result = GET_FTP_RESULT(stream);
333
334 /* check if we got a 229 response */
335 if (result != 229) {
336 #endif
337 /* EPSV failed, let's try PASV */
338 php_stream_write_string(stream, "PASV\r\n");
339 result = GET_FTP_RESULT(stream);
340
341 /* make sure we got a 227 response */
342 if (result != 227) {
343 return 0;
344 }
345
346 /* parse pasv command (129, 80, 95, 25, 13, 221) */
347 tpath = tmp_line;
348 /* skip over the "227 Some message " part */
349 for (tpath += 4; *tpath && !isdigit((int) *tpath); tpath++);
350 if (!*tpath) {
351 return 0;
352 }
353 /* skip over the host ip, to get the port */
354 hoststart = tpath;
355 for (i = 0; i < 4; i++) {
356 for (; isdigit((int) *tpath); tpath++);
357 if (*tpath != ',') {
358 return 0;
359 }
360 *tpath='.';
361 tpath++;
362 }
363 tpath[-1] = '\0';
364 memcpy(ip, hoststart, ip_size);
365 ip[ip_size-1] = '\0';
366 hoststart = ip;
367
368 /* pull out the MSB of the port */
369 portno = (unsigned short) strtoul(tpath, &ttpath, 10) * 256;
370 if (ttpath == NULL) {
371 /* didn't get correct response from PASV */
372 return 0;
373 }
374 tpath = ttpath;
375 if (*tpath != ',') {
376 return 0;
377 }
378 tpath++;
379 /* pull out the LSB of the port */
380 portno += (unsigned short) strtoul(tpath, &ttpath, 10);
381 #ifdef HAVE_IPV6
382 } else {
383 /* parse epsv command (|||6446|) */
384 for (i = 0, tpath = tmp_line + 4; *tpath; tpath++) {
385 if (*tpath == '|') {
386 i++;
387 if (i == 3)
388 break;
389 }
390 }
391 if (i < 3) {
392 return 0;
393 }
394 /* pull out the port */
395 portno = (unsigned short) strtoul(tpath + 1, &ttpath, 10);
396 }
397 #endif
398 if (ttpath == NULL) {
399 /* didn't get correct response from EPSV/PASV */
400 return 0;
401 }
402
403 if (phoststart) {
404 *phoststart = hoststart;
405 }
406
407 return portno;
408 }
409 /* }}} */
410
411 /* {{{ php_fopen_url_wrap_ftp
412 */
php_stream_url_wrap_ftp(php_stream_wrapper * wrapper,char * path,char * mode,int options,char ** opened_path,php_stream_context * context STREAMS_DC TSRMLS_DC)413 php_stream * php_stream_url_wrap_ftp(php_stream_wrapper *wrapper, char *path, char *mode, int options, char **opened_path, php_stream_context *context STREAMS_DC TSRMLS_DC)
414 {
415 php_stream *stream = NULL, *datastream = NULL;
416 php_url *resource = NULL;
417 char tmp_line[512];
418 char ip[sizeof("123.123.123.123")];
419 unsigned short portno;
420 char *hoststart = NULL;
421 int result = 0, use_ssl, use_ssl_on_data=0;
422 php_stream *reuseid=NULL;
423 size_t file_size = 0;
424 zval **tmpzval;
425 int allow_overwrite = 0;
426 int read_write = 0;
427 char *transport;
428 int transport_len;
429
430 tmp_line[0] = '\0';
431
432 if (strpbrk(mode, "r+")) {
433 read_write = 1; /* Open for reading */
434 }
435 if (strpbrk(mode, "wa+")) {
436 if (read_write) {
437 php_stream_wrapper_log_error(wrapper, options TSRMLS_CC, "FTP does not support simultaneous read/write connections");
438 return NULL;
439 }
440 if (strchr(mode, 'a')) {
441 read_write = 3; /* Open for Appending */
442 } else {
443 read_write = 2; /* Open for writing */
444 }
445 }
446 if (!read_write) {
447 /* No mode specified? */
448 php_stream_wrapper_log_error(wrapper, options TSRMLS_CC, "Unknown file open mode");
449 return NULL;
450 }
451
452 if (context &&
453 php_stream_context_get_option(context, "ftp", "proxy", &tmpzval) == SUCCESS) {
454 if (read_write == 1) {
455 /* Use http wrapper to proxy ftp request */
456 return php_stream_url_wrap_http(wrapper, path, mode, options, opened_path, context STREAMS_CC TSRMLS_CC);
457 } else {
458 /* ftp proxy is read-only */
459 php_stream_wrapper_log_error(wrapper, options TSRMLS_CC, "FTP proxy may only be used in read mode");
460 return NULL;
461 }
462 }
463
464 stream = php_ftp_fopen_connect(wrapper, path, mode, options, opened_path, context, &reuseid, &resource, &use_ssl, &use_ssl_on_data TSRMLS_CC);
465 if (!stream) {
466 goto errexit;
467 }
468
469 /* set the connection to be binary */
470 php_stream_write_string(stream, "TYPE I\r\n");
471 result = GET_FTP_RESULT(stream);
472 if (result > 299 || result < 200)
473 goto errexit;
474
475 /* find out the size of the file (verifying it exists) */
476 php_stream_printf(stream TSRMLS_CC, "SIZE %s\r\n", resource->path);
477
478 /* read the response */
479 result = GET_FTP_RESULT(stream);
480 if (read_write == 1) {
481 /* Read Mode */
482 char *sizestr;
483
484 /* when reading file, it must exist */
485 if (result > 299 || result < 200) {
486 errno = ENOENT;
487 goto errexit;
488 }
489
490 sizestr = strchr(tmp_line, ' ');
491 if (sizestr) {
492 sizestr++;
493 file_size = atoi(sizestr);
494 php_stream_notify_file_size(context, file_size, tmp_line, result);
495 }
496 } else if (read_write == 2) {
497 /* when writing file (but not appending), it must NOT exist, unless a context option exists which allows it */
498 if (context && php_stream_context_get_option(context, "ftp", "overwrite", &tmpzval) == SUCCESS) {
499 allow_overwrite = Z_LVAL_PP(tmpzval);
500 }
501 if (result <= 299 && result >= 200) {
502 if (allow_overwrite) {
503 /* Context permits overwriting file,
504 so we just delete whatever's there in preparation */
505 php_stream_printf(stream TSRMLS_CC, "DELE %s\r\n", resource->path);
506 result = GET_FTP_RESULT(stream);
507 if (result >= 300 || result <= 199) {
508 goto errexit;
509 }
510 } else {
511 php_stream_wrapper_log_error(wrapper, options TSRMLS_CC, "Remote file already exists and overwrite context option not specified");
512 errno = EEXIST;
513 goto errexit;
514 }
515 }
516 }
517
518 /* set up the passive connection */
519 portno = php_fopen_do_pasv(stream, ip, sizeof(ip), &hoststart TSRMLS_CC);
520
521 if (!portno) {
522 goto errexit;
523 }
524
525 /* Send RETR/STOR command */
526 if (read_write == 1) {
527 /* set resume position if applicable */
528 if (context &&
529 php_stream_context_get_option(context, "ftp", "resume_pos", &tmpzval) == SUCCESS &&
530 Z_TYPE_PP(tmpzval) == IS_LONG &&
531 Z_LVAL_PP(tmpzval) > 0) {
532 php_stream_printf(stream TSRMLS_CC, "REST %ld\r\n", Z_LVAL_PP(tmpzval));
533 result = GET_FTP_RESULT(stream);
534 if (result < 300 || result > 399) {
535 php_stream_wrapper_log_error(wrapper, options TSRMLS_CC, "Unable to resume from offset %ld", Z_LVAL_PP(tmpzval));
536 goto errexit;
537 }
538 }
539
540 /* retrieve file */
541 memcpy(tmp_line, "RETR", sizeof("RETR"));
542 } else if (read_write == 2) {
543 /* Write new file */
544 memcpy(tmp_line, "STOR", sizeof("STOR"));
545 } else {
546 /* Append */
547 memcpy(tmp_line, "APPE", sizeof("APPE"));
548 }
549 php_stream_printf(stream TSRMLS_CC, "%s %s\r\n", tmp_line, (resource->path != NULL ? resource->path : "/"));
550
551 /* open the data channel */
552 if (hoststart == NULL) {
553 hoststart = resource->host;
554 }
555 transport_len = spprintf(&transport, 0, "tcp://%s:%d", hoststart, portno);
556 datastream = php_stream_xport_create(transport, transport_len, REPORT_ERRORS, STREAM_XPORT_CLIENT | STREAM_XPORT_CONNECT, NULL, NULL, context, NULL, NULL);
557 efree(transport);
558 if (datastream == NULL) {
559 goto errexit;
560 }
561
562 result = GET_FTP_RESULT(stream);
563 if (result != 150 && result != 125) {
564 /* Could not retrieve or send the file
565 * this data will only be sent to us after connection on the data port was initiated.
566 */
567 php_stream_close(datastream);
568 datastream = NULL;
569 goto errexit;
570 }
571
572 php_stream_context_set(datastream, context);
573 php_stream_notify_progress_init(context, 0, file_size);
574
575 if (use_ssl_on_data && (php_stream_xport_crypto_setup(datastream,
576 STREAM_CRYPTO_METHOD_SSLv23_CLIENT, NULL TSRMLS_CC) < 0 ||
577 php_stream_xport_crypto_enable(datastream, 1 TSRMLS_CC) < 0)) {
578
579 php_stream_wrapper_log_error(wrapper, options TSRMLS_CC, "Unable to activate SSL mode");
580 php_stream_close(datastream);
581 datastream = NULL;
582 goto errexit;
583 }
584
585 /* remember control stream */
586 datastream->wrapperthis = stream;
587
588 php_url_free(resource);
589 return datastream;
590
591 errexit:
592 if (resource) {
593 php_url_free(resource);
594 }
595 if (stream) {
596 php_stream_notify_error(context, PHP_STREAM_NOTIFY_FAILURE, tmp_line, result);
597 php_stream_close(stream);
598 }
599 if (tmp_line[0] != '\0')
600 php_stream_wrapper_log_error(wrapper, options TSRMLS_CC, "FTP server reports %s", tmp_line);
601 return NULL;
602 }
603 /* }}} */
604
605 /* {{{ php_ftp_dirsteam_read
606 */
php_ftp_dirstream_read(php_stream * stream,char * buf,size_t count TSRMLS_DC)607 static size_t php_ftp_dirstream_read(php_stream *stream, char *buf, size_t count TSRMLS_DC)
608 {
609 php_stream_dirent *ent = (php_stream_dirent *)buf;
610 php_stream *innerstream;
611 size_t tmp_len;
612 char *basename;
613 size_t basename_len;
614
615 innerstream = ((php_ftp_dirstream_data *)stream->abstract)->datastream;
616
617 if (count != sizeof(php_stream_dirent)) {
618 return 0;
619 }
620
621 if (php_stream_eof(innerstream)) {
622 return 0;
623 }
624
625 if (!php_stream_get_line(innerstream, ent->d_name, sizeof(ent->d_name), &tmp_len)) {
626 return 0;
627 }
628
629 php_basename(ent->d_name, tmp_len, NULL, 0, &basename, &basename_len TSRMLS_CC);
630 if (!basename) {
631 return 0;
632 }
633
634 if (!basename_len) {
635 efree(basename);
636 return 0;
637 }
638
639 tmp_len = MIN(sizeof(ent->d_name), basename_len - 1);
640 memcpy(ent->d_name, basename, tmp_len);
641 ent->d_name[tmp_len - 1] = '\0';
642 efree(basename);
643
644 /* Trim off trailing whitespace characters */
645 tmp_len--;
646 while (tmp_len >= 0 &&
647 (ent->d_name[tmp_len] == '\n' || ent->d_name[tmp_len] == '\r' ||
648 ent->d_name[tmp_len] == '\t' || ent->d_name[tmp_len] == ' ')) {
649 ent->d_name[tmp_len--] = '\0';
650 }
651
652 return sizeof(php_stream_dirent);
653 }
654 /* }}} */
655
656 /* {{{ php_ftp_dirstream_close
657 */
php_ftp_dirstream_close(php_stream * stream,int close_handle TSRMLS_DC)658 static int php_ftp_dirstream_close(php_stream *stream, int close_handle TSRMLS_DC)
659 {
660 php_ftp_dirstream_data *data = stream->abstract;
661
662 /* close control connection */
663 if (data->controlstream) {
664 php_stream_close(data->controlstream);
665 data->controlstream = NULL;
666 }
667 /* close data connection */
668 php_stream_close(data->datastream);
669 data->datastream = NULL;
670
671 efree(data);
672 stream->abstract = NULL;
673
674 return 0;
675 }
676 /* }}} */
677
678 /* ftp dirstreams only need to support read and close operations,
679 They can't be rewound because the underlying ftp stream can't be rewound. */
680 static php_stream_ops php_ftp_dirstream_ops = {
681 NULL, /* write */
682 php_ftp_dirstream_read, /* read */
683 php_ftp_dirstream_close, /* close */
684 NULL, /* flush */
685 "ftpdir",
686 NULL, /* rewind */
687 NULL, /* cast */
688 NULL, /* stat */
689 NULL /* set option */
690 };
691
692 /* {{{ php_stream_ftp_opendir
693 */
php_stream_ftp_opendir(php_stream_wrapper * wrapper,char * path,char * mode,int options,char ** opened_path,php_stream_context * context STREAMS_DC TSRMLS_DC)694 php_stream * php_stream_ftp_opendir(php_stream_wrapper *wrapper, char *path, char *mode, int options, char **opened_path, php_stream_context *context STREAMS_DC TSRMLS_DC)
695 {
696 php_stream *stream, *reuseid, *datastream = NULL;
697 php_ftp_dirstream_data *dirsdata;
698 php_url *resource = NULL;
699 int result = 0, use_ssl, use_ssl_on_data = 0;
700 char *hoststart = NULL, tmp_line[512];
701 char ip[sizeof("123.123.123.123")];
702 unsigned short portno;
703
704 tmp_line[0] = '\0';
705
706 stream = php_ftp_fopen_connect(wrapper, path, mode, options, opened_path, context, &reuseid, &resource, &use_ssl, &use_ssl_on_data TSRMLS_CC);
707 if (!stream) {
708 goto opendir_errexit;
709 }
710
711 /* set the connection to be ascii */
712 php_stream_write_string(stream, "TYPE A\r\n");
713 result = GET_FTP_RESULT(stream);
714 if (result > 299 || result < 200)
715 goto opendir_errexit;
716
717 /* set up the passive connection */
718 portno = php_fopen_do_pasv(stream, ip, sizeof(ip), &hoststart TSRMLS_CC);
719
720 if (!portno) {
721 goto opendir_errexit;
722 }
723
724 php_stream_printf(stream TSRMLS_CC, "NLST %s\r\n", (resource->path != NULL ? resource->path : "/"));
725
726 /* open the data channel */
727 if (hoststart == NULL) {
728 hoststart = resource->host;
729 }
730 datastream = php_stream_sock_open_host(hoststart, portno, SOCK_STREAM, 0, 0);
731 if (datastream == NULL) {
732 goto opendir_errexit;
733 }
734
735 result = GET_FTP_RESULT(stream);
736 if (result != 150 && result != 125) {
737 /* Could not retrieve or send the file
738 * this data will only be sent to us after connection on the data port was initiated.
739 */
740 php_stream_close(datastream);
741 datastream = NULL;
742 goto opendir_errexit;
743 }
744
745 php_stream_context_set(datastream, context);
746
747 if (use_ssl_on_data && (php_stream_xport_crypto_setup(stream,
748 STREAM_CRYPTO_METHOD_SSLv23_CLIENT, NULL TSRMLS_CC) < 0 ||
749 php_stream_xport_crypto_enable(stream, 1 TSRMLS_CC) < 0)) {
750
751 php_stream_wrapper_log_error(wrapper, options TSRMLS_CC, "Unable to activate SSL mode");
752 php_stream_close(datastream);
753 datastream = NULL;
754 goto opendir_errexit;
755 }
756
757 php_url_free(resource);
758
759 dirsdata = emalloc(sizeof *dirsdata);
760 dirsdata->datastream = datastream;
761 dirsdata->controlstream = stream;
762 dirsdata->dirstream = php_stream_alloc(&php_ftp_dirstream_ops, dirsdata, 0, mode);
763
764 return dirsdata->dirstream;
765
766 opendir_errexit:
767 if (resource) {
768 php_url_free(resource);
769 }
770 if (stream) {
771 php_stream_notify_error(context, PHP_STREAM_NOTIFY_FAILURE, tmp_line, result);
772 php_stream_close(stream);
773 }
774 if (tmp_line[0] != '\0') {
775 php_stream_wrapper_log_error(wrapper, options TSRMLS_CC, "FTP server reports %s", tmp_line);
776 }
777 return NULL;
778 }
779 /* }}} */
780
781 /* {{{ php_stream_ftp_url_stat
782 */
php_stream_ftp_url_stat(php_stream_wrapper * wrapper,char * url,int flags,php_stream_statbuf * ssb,php_stream_context * context TSRMLS_DC)783 static int php_stream_ftp_url_stat(php_stream_wrapper *wrapper, char *url, int flags, php_stream_statbuf *ssb, php_stream_context *context TSRMLS_DC)
784 {
785 php_stream *stream = NULL;
786 php_url *resource = NULL;
787 int result;
788 char tmp_line[512];
789
790 /* If ssb is NULL then someone is misbehaving */
791 if (!ssb) return -1;
792
793 stream = php_ftp_fopen_connect(wrapper, url, "r", 0, NULL, context, NULL, &resource, NULL, NULL TSRMLS_CC);
794 if (!stream) {
795 goto stat_errexit;
796 }
797
798 ssb->sb.st_mode = 0644; /* FTP won't give us a valid mode, so aproximate one based on being readable */
799 php_stream_printf(stream TSRMLS_CC, "CWD %s\r\n", (resource->path != NULL ? resource->path : "/")); /* If we can CWD to it, it's a directory (maybe a link, but we can't tell) */
800 result = GET_FTP_RESULT(stream);
801 if (result < 200 || result > 299) {
802 ssb->sb.st_mode |= S_IFREG;
803 } else {
804 ssb->sb.st_mode |= S_IFDIR;
805 }
806
807 php_stream_write_string(stream, "TYPE I\r\n"); /* we need this since some servers refuse to accept SIZE command in ASCII mode */
808
809 result = GET_FTP_RESULT(stream);
810
811 if(result < 200 || result > 299) {
812 goto stat_errexit;
813 }
814
815 php_stream_printf(stream TSRMLS_CC, "SIZE %s\r\n", (resource->path != NULL ? resource->path : "/"));
816 result = GET_FTP_RESULT(stream);
817 if (result < 200 || result > 299) {
818 /* Failure either means it doesn't exist
819 or it's a directory and this server
820 fails on listing directory sizes */
821 if (ssb->sb.st_mode & S_IFDIR) {
822 ssb->sb.st_size = 0;
823 } else {
824 goto stat_errexit;
825 }
826 } else {
827 ssb->sb.st_size = atoi(tmp_line + 4);
828 }
829
830 php_stream_printf(stream TSRMLS_CC, "MDTM %s\r\n", (resource->path != NULL ? resource->path : "/"));
831 result = GET_FTP_RESULT(stream);
832 if (result == 213) {
833 char *p = tmp_line + 4;
834 int n;
835 struct tm tm, tmbuf, *gmt;
836 time_t stamp;
837
838 while (p - tmp_line < sizeof(tmp_line) && !isdigit(*p)) {
839 p++;
840 }
841
842 if (p - tmp_line > sizeof(tmp_line)) {
843 goto mdtm_error;
844 }
845
846 n = sscanf(p, "%4u%2u%2u%2u%2u%2u", &tm.tm_year, &tm.tm_mon, &tm.tm_mday, &tm.tm_hour, &tm.tm_min, &tm.tm_sec);
847 if (n != 6) {
848 goto mdtm_error;
849 }
850
851 tm.tm_year -= 1900;
852 tm.tm_mon--;
853 tm.tm_isdst = -1;
854
855 /* figure out the GMT offset */
856 stamp = time(NULL);
857 gmt = php_gmtime_r(&stamp, &tmbuf);
858 if (!gmt) {
859 goto mdtm_error;
860 }
861 gmt->tm_isdst = -1;
862
863 /* apply the GMT offset */
864 tm.tm_sec += stamp - mktime(gmt);
865 tm.tm_isdst = gmt->tm_isdst;
866
867 ssb->sb.st_mtime = mktime(&tm);
868 } else {
869 /* error or unsupported command */
870 mdtm_error:
871 ssb->sb.st_mtime = -1;
872 }
873
874 ssb->sb.st_ino = 0; /* Unknown values */
875 ssb->sb.st_dev = 0;
876 ssb->sb.st_uid = 0;
877 ssb->sb.st_gid = 0;
878 ssb->sb.st_atime = -1;
879 ssb->sb.st_ctime = -1;
880
881 ssb->sb.st_nlink = 1;
882 ssb->sb.st_rdev = -1;
883 #ifdef HAVE_ST_BLKSIZE
884 ssb->sb.st_blksize = 4096; /* Guess since FTP won't expose this information */
885 #ifdef HAVE_ST_BLOCKS
886 ssb->sb.st_blocks = (int)((4095 + ssb->sb.st_size) / ssb->sb.st_blksize); /* emulate ceil */
887 #endif
888 #endif
889 php_stream_close(stream);
890 php_url_free(resource);
891 return 0;
892
893 stat_errexit:
894 if (resource) {
895 php_url_free(resource);
896 }
897 if (stream) {
898 php_stream_close(stream);
899 }
900 return -1;
901 }
902 /* }}} */
903
904 /* {{{ php_stream_ftp_unlink
905 */
php_stream_ftp_unlink(php_stream_wrapper * wrapper,char * url,int options,php_stream_context * context TSRMLS_DC)906 static int php_stream_ftp_unlink(php_stream_wrapper *wrapper, char *url, int options, php_stream_context *context TSRMLS_DC)
907 {
908 php_stream *stream = NULL;
909 php_url *resource = NULL;
910 int result;
911 char tmp_line[512];
912
913 stream = php_ftp_fopen_connect(wrapper, url, "r", 0, NULL, NULL, NULL, &resource, NULL, NULL TSRMLS_CC);
914 if (!stream) {
915 if (options & REPORT_ERRORS) {
916 php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to connect to %s", url);
917 }
918 goto unlink_errexit;
919 }
920
921 if (resource->path == NULL) {
922 if (options & REPORT_ERRORS) {
923 php_error_docref(NULL TSRMLS_CC, E_WARNING, "Invalid path provided in %s", url);
924 }
925 goto unlink_errexit;
926 }
927
928 /* Attempt to delete the file */
929 php_stream_printf(stream TSRMLS_CC, "DELE %s\r\n", (resource->path != NULL ? resource->path : "/"));
930
931 result = GET_FTP_RESULT(stream);
932 if (result < 200 || result > 299) {
933 if (options & REPORT_ERRORS) {
934 php_error_docref(NULL TSRMLS_CC, E_WARNING, "Error Deleting file: %s", tmp_line);
935 }
936 goto unlink_errexit;
937 }
938
939 php_url_free(resource);
940 php_stream_close(stream);
941 return 1;
942
943 unlink_errexit:
944 if (resource) {
945 php_url_free(resource);
946 }
947 if (stream) {
948 php_stream_close(stream);
949 }
950 return 0;
951 }
952 /* }}} */
953
954 /* {{{ php_stream_ftp_rename
955 */
php_stream_ftp_rename(php_stream_wrapper * wrapper,char * url_from,char * url_to,int options,php_stream_context * context TSRMLS_DC)956 static int php_stream_ftp_rename(php_stream_wrapper *wrapper, char *url_from, char *url_to, int options, php_stream_context *context TSRMLS_DC)
957 {
958 php_stream *stream = NULL;
959 php_url *resource_from = NULL, *resource_to = NULL;
960 int result;
961 char tmp_line[512];
962
963 resource_from = php_url_parse(url_from);
964 resource_to = php_url_parse(url_to);
965 /* Must be same scheme (ftp/ftp or ftps/ftps), same host, and same port
966 (or a 21/0 0/21 combination which is also "same")
967 Also require paths to/from */
968 if (!resource_from ||
969 !resource_to ||
970 !resource_from->scheme ||
971 !resource_to->scheme ||
972 strcmp(resource_from->scheme, resource_to->scheme) ||
973 !resource_from->host ||
974 !resource_to->host ||
975 strcmp(resource_from->host, resource_to->host) ||
976 (resource_from->port != resource_to->port &&
977 resource_from->port * resource_to->port != 0 &&
978 resource_from->port + resource_to->port != 21) ||
979 !resource_from->path ||
980 !resource_to->path) {
981 goto rename_errexit;
982 }
983
984 stream = php_ftp_fopen_connect(wrapper, url_from, "r", 0, NULL, NULL, NULL, NULL, NULL, NULL TSRMLS_CC);
985 if (!stream) {
986 if (options & REPORT_ERRORS) {
987 php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to connect to %s", resource_from->host);
988 }
989 goto rename_errexit;
990 }
991
992 /* Rename FROM */
993 php_stream_printf(stream TSRMLS_CC, "RNFR %s\r\n", (resource_from->path != NULL ? resource_from->path : "/"));
994
995 result = GET_FTP_RESULT(stream);
996 if (result < 300 || result > 399) {
997 if (options & REPORT_ERRORS) {
998 php_error_docref(NULL TSRMLS_CC, E_WARNING, "Error Renaming file: %s", tmp_line);
999 }
1000 goto rename_errexit;
1001 }
1002
1003 /* Rename TO */
1004 php_stream_printf(stream TSRMLS_CC, "RNTO %s\r\n", (resource_to->path != NULL ? resource_to->path : "/"));
1005
1006 result = GET_FTP_RESULT(stream);
1007 if (result < 200 || result > 299) {
1008 if (options & REPORT_ERRORS) {
1009 php_error_docref(NULL TSRMLS_CC, E_WARNING, "Error Renaming file: %s", tmp_line);
1010 }
1011 goto rename_errexit;
1012 }
1013
1014 php_url_free(resource_from);
1015 php_url_free(resource_to);
1016 php_stream_close(stream);
1017 return 1;
1018
1019 rename_errexit:
1020 if (resource_from) {
1021 php_url_free(resource_from);
1022 }
1023 if (resource_to) {
1024 php_url_free(resource_to);
1025 }
1026 if (stream) {
1027 php_stream_close(stream);
1028 }
1029 return 0;
1030 }
1031 /* }}} */
1032
1033 /* {{{ php_stream_ftp_mkdir
1034 */
php_stream_ftp_mkdir(php_stream_wrapper * wrapper,char * url,int mode,int options,php_stream_context * context TSRMLS_DC)1035 static int php_stream_ftp_mkdir(php_stream_wrapper *wrapper, char *url, int mode, int options, php_stream_context *context TSRMLS_DC)
1036 {
1037 php_stream *stream = NULL;
1038 php_url *resource = NULL;
1039 int result, recursive = options & PHP_STREAM_MKDIR_RECURSIVE;
1040 char tmp_line[512];
1041
1042 stream = php_ftp_fopen_connect(wrapper, url, "r", 0, NULL, NULL, NULL, &resource, NULL, NULL TSRMLS_CC);
1043 if (!stream) {
1044 if (options & REPORT_ERRORS) {
1045 php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to connect to %s", url);
1046 }
1047 goto mkdir_errexit;
1048 }
1049
1050 if (resource->path == NULL) {
1051 if (options & REPORT_ERRORS) {
1052 php_error_docref(NULL TSRMLS_CC, E_WARNING, "Invalid path provided in %s", url);
1053 }
1054 goto mkdir_errexit;
1055 }
1056
1057 if (!recursive) {
1058 php_stream_printf(stream TSRMLS_CC, "MKD %s\r\n", resource->path);
1059 result = GET_FTP_RESULT(stream);
1060 } else {
1061 /* we look for directory separator from the end of string, thus hopefuly reducing our work load */
1062 char *p, *e, *buf;
1063
1064 buf = estrdup(resource->path);
1065 e = buf + strlen(buf);
1066
1067 /* find a top level directory we need to create */
1068 while ((p = strrchr(buf, '/'))) {
1069 *p = '\0';
1070 php_stream_printf(stream TSRMLS_CC, "CWD %s\r\n", buf);
1071 result = GET_FTP_RESULT(stream);
1072 if (result >= 200 && result <= 299) {
1073 *p = '/';
1074 break;
1075 }
1076 }
1077 if (p == buf) {
1078 php_stream_printf(stream TSRMLS_CC, "MKD %s\r\n", resource->path);
1079 result = GET_FTP_RESULT(stream);
1080 } else {
1081 php_stream_printf(stream TSRMLS_CC, "MKD %s\r\n", buf);
1082 result = GET_FTP_RESULT(stream);
1083 if (result >= 200 && result <= 299) {
1084 if (!p) {
1085 p = buf;
1086 }
1087 /* create any needed directories if the creation of the 1st directory worked */
1088 while (++p != e) {
1089 if (*p == '\0' && *(p + 1) != '\0') {
1090 *p = '/';
1091 php_stream_printf(stream TSRMLS_CC, "MKD %s\r\n", buf);
1092 result = GET_FTP_RESULT(stream);
1093 if (result < 200 || result > 299) {
1094 if (options & REPORT_ERRORS) {
1095 php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s", tmp_line);
1096 }
1097 break;
1098 }
1099 }
1100 }
1101 }
1102 }
1103 efree(buf);
1104 }
1105
1106 php_url_free(resource);
1107 php_stream_close(stream);
1108
1109 if (result < 200 || result > 299) {
1110 /* Failure */
1111 return 0;
1112 }
1113
1114 return 1;
1115
1116 mkdir_errexit:
1117 if (resource) {
1118 php_url_free(resource);
1119 }
1120 if (stream) {
1121 php_stream_close(stream);
1122 }
1123 return 0;
1124 }
1125 /* }}} */
1126
1127 /* {{{ php_stream_ftp_rmdir
1128 */
php_stream_ftp_rmdir(php_stream_wrapper * wrapper,char * url,int options,php_stream_context * context TSRMLS_DC)1129 static int php_stream_ftp_rmdir(php_stream_wrapper *wrapper, char *url, int options, php_stream_context *context TSRMLS_DC)
1130 {
1131 php_stream *stream = NULL;
1132 php_url *resource = NULL;
1133 int result;
1134 char tmp_line[512];
1135
1136 stream = php_ftp_fopen_connect(wrapper, url, "r", 0, NULL, NULL, NULL, &resource, NULL, NULL TSRMLS_CC);
1137 if (!stream) {
1138 if (options & REPORT_ERRORS) {
1139 php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to connect to %s", url);
1140 }
1141 goto rmdir_errexit;
1142 }
1143
1144 if (resource->path == NULL) {
1145 if (options & REPORT_ERRORS) {
1146 php_error_docref(NULL TSRMLS_CC, E_WARNING, "Invalid path provided in %s", url);
1147 }
1148 goto rmdir_errexit;
1149 }
1150
1151 php_stream_printf(stream TSRMLS_CC, "RMD %s\r\n", resource->path);
1152 result = GET_FTP_RESULT(stream);
1153
1154 if (result < 200 || result > 299) {
1155 if (options & REPORT_ERRORS) {
1156 php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s", tmp_line);
1157 }
1158 goto rmdir_errexit;
1159 }
1160
1161 php_url_free(resource);
1162 php_stream_close(stream);
1163
1164 return 1;
1165
1166 rmdir_errexit:
1167 if (resource) {
1168 php_url_free(resource);
1169 }
1170 if (stream) {
1171 php_stream_close(stream);
1172 }
1173 return 0;
1174 }
1175 /* }}} */
1176
1177 static php_stream_wrapper_ops ftp_stream_wops = {
1178 php_stream_url_wrap_ftp,
1179 php_stream_ftp_stream_close, /* stream_close */
1180 php_stream_ftp_stream_stat,
1181 php_stream_ftp_url_stat, /* stat_url */
1182 php_stream_ftp_opendir, /* opendir */
1183 "ftp",
1184 php_stream_ftp_unlink, /* unlink */
1185 php_stream_ftp_rename, /* rename */
1186 php_stream_ftp_mkdir, /* mkdir */
1187 php_stream_ftp_rmdir /* rmdir */
1188 };
1189
1190 PHPAPI php_stream_wrapper php_stream_ftp_wrapper = {
1191 &ftp_stream_wops,
1192 NULL,
1193 1 /* is_url */
1194 };
1195
1196
1197 /*
1198 * Local variables:
1199 * tab-width: 4
1200 * c-basic-offset: 4
1201 * End:
1202 * vim600: sw=4 ts=4 fdm=marker
1203 * vim<600: sw=4 ts=4
1204 */
1205
