View file File name : CdnEngine_Ftp.php Content :<?php namespace W3TC; /** * W3 CDN FTP Class */ define( 'W3TC_CDN_FTP_CONNECT_TIMEOUT', 30 ); /** * class CdnEngine_Ftp */ class CdnEngine_Ftp extends CdnEngine_Base { /** * FTP resource * * @var resource */ var $_ftp = null; /** * PHP5 Constructor * * @param array $config */ function __construct( $config = array() ) { $config = array_merge( array( 'host' => '', 'type' => '', 'user' => '', 'pass' => '', 'path' => '', 'pasv' => false, 'domain' => array(), 'docroot' => '' ), $config ); $host_port = explode( ':', $config['host'] ); if ( sizeof( $host_port ) == 2 ) { $config['host'] = $host_port[0]; $config['port'] = $host_port[1]; } parent::__construct( $config ); } /** * Connects to FTP server * * @param string $error * @return boolean */ function _connect( &$error ) { if ( empty( $this->_config['host'] ) ) { $error = 'Empty host.'; return false; } if ( empty( $this->_config['port'] ) ) { $this->_config['port'] = 21; } $this->_set_error_handler(); if ( $this->_config['type'] == 'ftps' ) $this->_ftp = @ftp_ssl_connect( $this->_config['host'], (int) $this->_config['port'], W3TC_CDN_FTP_CONNECT_TIMEOUT ); else $this->_ftp = @ftp_connect( $this->_config['host'], (int) $this->_config['port'], W3TC_CDN_FTP_CONNECT_TIMEOUT ); if ( !$this->_ftp ) { $error = sprintf( 'Unable to connect to %s:%d (%s).', $this->_config['host'], $this->_config['port'], $this->_get_last_error() ); $this->_restore_error_handler(); return false; } if ( !@ftp_login( $this->_ftp, $this->_config['user'], $this->_config['pass'] ) ) { $error = sprintf( 'Incorrect login or password (%s).', $this->_get_last_error() ); $this->_restore_error_handler(); $this->_disconnect(); return false; } if ( !@ftp_pasv( $this->_ftp, $this->_config['pasv'] ) ) { $error = sprintf( 'Unable to change mode to passive (%s).', $this->_get_last_error() ); $this->_restore_error_handler(); $this->_disconnect(); return false; } if ( !empty( $this->_config['path'] ) && !@ftp_chdir( $this->_ftp, $this->_config['path'] ) ) { $error = sprintf( 'Unable to change directory to: %s (%s).', $this->_config['path'], $this->_get_last_error() ); $this->_restore_error_handler(); $this->_disconnect(); return false; } $this->_restore_error_handler(); return true; } /** * Disconnects from FTP server */ function _disconnect() { @ftp_close( $this->_ftp ); } /** * Sends MDTM command * * @param string $remote_file * @param integer $mtime * @return boolean */ function _mdtm( $remote_file, $mtime ) { $command = sprintf( 'MDTM %s %s', date( 'YmdHis', $mtime ), $remote_file ); return @ftp_raw( $this->_ftp, $command ); } /** * Uploads files to FTP * * @param array $files * @param array $results * @param boolean $force_rewrite * @return boolean */ function upload( $files, &$results, $force_rewrite = false, $timeout_time = NULL ) { $error = null; if ( !$this->_connect( $error ) ) { $results = $this->_get_results( $files, W3TC_CDN_RESULT_HALT, $error ); return false; } $this->_set_error_handler(); $home = @ftp_pwd( $this->_ftp ); if ( $home === false ) { $results = $this->_get_results( $files, W3TC_CDN_RESULT_HALT, sprintf( 'Unable to get current directory (%s).', $this->_get_last_error() ) ); $this->_restore_error_handler(); $this->_disconnect(); return false; } foreach ( $files as $file ) { $local_path = $file['local_path']; $remote_path = $file['remote_path']; // process at least one item before timeout so that progress goes on if ( !empty( $results ) ) { if ( !is_null( $timeout_time ) && time() > $timeout_time ) { return 'timeout'; } } if ( !file_exists( $local_path ) ) { $results[] = $this->_get_result( $local_path, $remote_path, W3TC_CDN_RESULT_ERROR, 'Source file not found.', $file ); continue; } @ftp_chdir( $this->_ftp, $home ); $remote_dir = dirname( $remote_path ); $remote_dirs = preg_split( '~\\/+~', $remote_dir ); foreach ( $remote_dirs as $dir ) { if ( !@ftp_chdir( $this->_ftp, $dir ) ) { if ( !@ftp_mkdir( $this->_ftp, $dir ) ) { $results[] = $this->_get_result( $local_path, $remote_path, W3TC_CDN_RESULT_ERROR, sprintf( 'Unable to create directory (%s).', $this->_get_last_error() ), $file ); continue 2; } if ( !@ftp_chdir( $this->_ftp, $dir ) ) { $results[] = $this->_get_result( $local_path, $remote_path, W3TC_CDN_RESULT_ERROR, sprintf( 'Unable to change directory (%s).', $this->_get_last_error() ), $file ); continue 2; } } } // basename cannot be used, kills chinese chars and similar characters $remote_file = substr( $remote_path, strrpos( $remote_path, '/' )+1 ); $mtime = @filemtime( $local_path ); if ( !$force_rewrite ) { $size = @filesize( $local_path ); $ftp_size = @ftp_size( $this->_ftp, $remote_file ); $ftp_mtime = @ftp_mdtm( $this->_ftp, $remote_file ); if ( $size === $ftp_size && $mtime === $ftp_mtime ) { $results[] = $this->_get_result( $local_path, $remote_path, W3TC_CDN_RESULT_OK, 'File up-to-date.', $file ); continue; } } $result = @ftp_put( $this->_ftp, $remote_file, $local_path, FTP_BINARY ); if ( $result ) { $this->_mdtm( $remote_file, $mtime ); $results[] = $this->_get_result( $local_path, $remote_path, W3TC_CDN_RESULT_OK, 'OK', $file ); } else { $results[] = $this->_get_result( $local_path, $remote_path, W3TC_CDN_RESULT_ERROR, sprintf( 'Unable to upload file (%s).', $this->_get_last_error() ), $file ); } } $this->_restore_error_handler(); $this->_disconnect(); return !$this->_is_error( $results ); } /** * Deletes files from FTP * * @param array $files * @param array $results * @return boolean */ function delete( $files, &$results ) { $error = null; if ( !$this->_connect( $error ) ) { $results = $this->_get_results( $files, W3TC_CDN_RESULT_HALT, $error ); return false; } $this->_set_error_handler(); foreach ( $files as $file ) { $local_path = $file['local_path']; $remote_path = $file['remote_path']; $result = @ftp_delete( $this->_ftp, $remote_path ); if ( $result ) { $results[] = $this->_get_result( $local_path, $remote_path, W3TC_CDN_RESULT_OK, 'OK', $file ); } else { $results[] = $this->_get_result( $local_path, $remote_path, W3TC_CDN_RESULT_ERROR, sprintf( 'Unable to delete file (%s).', $this->_get_last_error() ), $file ); } while ( true ) { $remote_path = dirname( $remote_path ); if ( $remote_path == '.' || !@ftp_rmdir( $this->_ftp, $remote_path ) ) { break; } } } $this->_restore_error_handler(); $this->_disconnect(); return !$this->_is_error( $results ); } /** * Tests FTP server * * @param string $error * @return boolean */ function test( &$error ) { if ( !parent::test( $error ) ) { return false; } $rand = md5( time() ); $tmp_dir = 'test_dir_' . $rand; $tmp_file = 'test_file_' . $rand; $tmp_path = W3TC_CACHE_TMP_DIR . '/' . $tmp_file; if ( !@file_put_contents( $tmp_path, $rand ) ) { $error = sprintf( 'Unable to create file: %s.', $tmp_path ); return false; } if ( !$this->_connect( $error ) ) { return false; } $this->_set_error_handler(); if ( !@ftp_mkdir( $this->_ftp, $tmp_dir ) ) { $error = sprintf( 'Unable to make directory: %s (%s).', $tmp_dir, $this->_get_last_error() ); @unlink( $tmp_path ); $this->_restore_error_handler(); $this->_disconnect(); return false; } if ( file_exists( $this->_config['docroot'] . '/' . $tmp_dir ) ) { $error = sprintf( 'Test directory was made in your site root, not on separate FTP host or path. Change path or FTP information: %s.', $tmp_dir ); @unlink( $tmp_path ); @ftp_rmdir( $this->_ftp, $tmp_dir ); $this->_restore_error_handler(); $this->_disconnect(); return false; } if ( !@ftp_chdir( $this->_ftp, $tmp_dir ) ) { $error = sprintf( 'Unable to change directory to: %s (%s).', $tmp_dir, $this->_get_last_error() ); @unlink( $tmp_path ); @ftp_rmdir( $this->_ftp, $tmp_dir ); $this->_restore_error_handler(); $this->_disconnect(); return false; } if ( !@ftp_put( $this->_ftp, $tmp_file, $tmp_path, FTP_BINARY ) ) { $error = sprintf( 'Unable to upload file: %s (%s).', $tmp_path, $this->_get_last_error() ); @unlink( $tmp_path ); @ftp_cdup( $this->_ftp ); @ftp_rmdir( $this->_ftp, $tmp_dir ); $this->_restore_error_handler(); $this->_disconnect(); return false; } @unlink( $tmp_path ); if ( !@ftp_delete( $this->_ftp, $tmp_file ) ) { $error = sprintf( 'Unable to delete file: %s (%s).', $tmp_path, $this->_get_last_error() ); @ftp_cdup( $this->_ftp ); @ftp_rmdir( $this->_ftp, $tmp_dir ); $this->_restore_error_handler(); $this->_disconnect(); return false; } @ftp_cdup( $this->_ftp ); if ( !@ftp_rmdir( $this->_ftp, $tmp_dir ) ) { $error = sprintf( 'Unable to remove directory: %s (%s).', $tmp_dir, $this->_get_last_error() ); $this->_restore_error_handler(); $this->_disconnect(); return false; } $this->_restore_error_handler(); $this->_disconnect(); return true; } /** * Returns array of CDN domains * * @return array */ function get_domains() { if ( !empty( $this->_config['domain'] ) ) { return (array) $this->_config['domain']; } return array(); } /** * How and if headers should be set * * @return string W3TC_CDN_HEADER_NONE, W3TC_CDN_HEADER_UPLOADABLE, W3TC_CDN_HEADER_MIRRORING */ function headers_support() { return W3TC_CDN_HEADER_MIRRORING; } }