'',
'ftphostport' => 21,
'ftptimeout' => 90,
'ftpuser' => '',
'ftppass' => '',
'ftpdir' => trailingslashit( sanitize_title_with_dashes( get_bloginfo( 'name' ) ) ),
'ftpmaxbackups' => 15,
'ftppasv' => true,
'ftpssl' => false,
);
}
/**
* Edit Tab
*
* @param int $jobid The job ID.
*
* @return void
*/
public function edit_tab( $jobid ) {
?>
ftphost,
$job_options->ftpuser,
BackWPup_Encryption::decrypt( $job_options->ftppass ),
$job_options->ftphostport,
$job_options->ftptimeout,
$job_options->ftpssl,
$job_options->ftppasv
);
$resource = $service
->connect()
->resource();
// Delete file.
ftp_delete( $resource, $backupfile );
// Update file list of existing files.
foreach ( $files as $key => $file ) {
if ( is_array( $file ) && $file['file'] == $backupfile ) {
unset( $files[ $key ] );
}
}
set_site_transient( 'backwpup_' . strtolower( $jobdest ), $files, YEAR_IN_SECONDS );
}
/**
* @inheritdoc
*/
public function file_get_list( $jobdest ) {
$list = (array) get_site_transient( 'backwpup_' . strtolower( $jobdest ) );
$list = array_filter( $list );
return $list;
}
/**
* File Update List
*
* Update the list of files in the transient.
*
* @param BackWPup_Job|int $job Either the job object or job ID
* @param bool $delete Whether to delete old backups.
*/
public function file_update_list( $job, $delete = false ) {
if ( $job instanceof BackWPup_Job ) {
$job_object = $job;
$jobid = $job->job['jobid'];
} else {
$job_object = null;
$jobid = $job;
}
if ( ! $this->ftp_conn_id ) {
$ftp_ssl = BackWPup_Option::get( $jobid, 'ftpssl' );
if ( ! empty( $ftp_ssl )
&& function_exists( 'ftp_ssl_connect' ) ) {
$ftp_conn_id = ftp_ssl_connect(
BackWPup_Option::get( $jobid, 'ftphost' ),
BackWPup_Option::get( $jobid, 'ftphostport' ),
BackWPup_Option::get( $jobid, 'ftptimeout' )
);
} else { //make normal FTP connection if SSL not work
$ftp_conn_id = ftp_connect(
BackWPup_Option::get( $jobid, 'ftphost' ),
BackWPup_Option::get( $jobid, 'ftphostport' ),
BackWPup_Option::get( $jobid, 'ftptimeout' )
);
}
//FTP Login
if ( $loginok = @ftp_login(
$ftp_conn_id,
BackWPup_Option::get( $jobid, 'ftpuser' ),
BackWPup_Encryption::decrypt( BackWPup_Option::get( $jobid, 'ftppass' ) )
) ) {
} else { //if PHP ftp login don't work use raw login
$return = ftp_raw( $ftp_conn_id, 'USER ' . BackWPup_Option::get( $jobid, 'ftpuser' ) );
if ( substr( trim( $return[0] ), 0, 3 ) <= 400 ) {
$return = ftp_raw(
$ftp_conn_id,
'PASS ' . BackWPup_Encryption::decrypt( BackWPup_Option::get( $jobid, 'ftppass' ) )
);
if ( substr( trim( $return[0] ), 0, 3 ) <= 400 ) {
$loginok = true;
}
}
}
if ( ! $loginok ) {
throw new Exception( __( 'Could not log in to FTP server.', 'backwpup' ) );
}
//set actual ftp dir to ftp dir
$ftp_dir = BackWPup_Option::get( $jobid, 'ftpdir' );
if ( empty( $ftp_dir ) ) {
$ftp_dir = trailingslashit( ftp_pwd( $ftp_conn_id ) );
}
// prepend actual ftp dir if relative dir
if ( substr( $ftp_dir, 0, 1 ) != '/' ) {
$ftp_dir = trailingslashit( ftp_pwd( $ftp_conn_id ) ) . $ftp_dir;
}
ftp_chdir( $ftp_conn_id, $ftp_dir );
if ( BackWPup_Option::get( $jobid, 'ftppasv' ) ) {
ftp_pasv( $ftp_conn_id, true );
} else {
ftp_pasv( $ftp_conn_id, false );
}
} else {
$ftp_conn_id = $this->ftp_conn_id;
$ftp_dir = $job_object->job['ftpdir'];
}
$backupfilelist = array();
$filecounter = 0;
$files = array();
if ( $filelist = ftp_nlist( $ftp_conn_id, '.' ) ) {
foreach ( $filelist as $file ) {
if ( basename( $file ) != '.' && basename( $file ) != '..' ) {
if ( $this->is_backup_archive( $file )
&& $this->is_backup_owned_by_job(
$file, $jobid
) == true ) {
$time = ftp_mdtm( $ftp_conn_id, $file );
if ( $time != - 1 ) {
$backupfilelist[ $time ] = basename( $file );
} else {
$backupfilelist[] = basename( $file );
}
}
$files[ $filecounter ]['folder'] = 'ftp://' . BackWPup_Option::get( $jobid, 'ftphost' ) . ':' . BackWPup_Option::get( $jobid, 'ftphostport' ) . $ftp_dir;
$files[ $filecounter ]['file'] = trailingslashit( $ftp_dir ) . basename( $file );
$files[ $filecounter ]['filename'] = basename( $file );
$files[ $filecounter ]['downloadurl'] = network_admin_url(
'admin.php?page=backwpupbackups&action=downloadftp&file=' . trailingslashit( $ftp_dir ) . basename( $file ) . '&local_file=' . basename( $file ) . '&jobid=' . $jobid
);
$files[ $filecounter ]['filesize'] = ftp_size( $ftp_conn_id, $file );
$files[ $filecounter ]['time'] = ftp_mdtm( $ftp_conn_id, $file );
$filecounter ++;
}
}
}
if ( $delete && $job_object && ! empty( $job_object->job['ftpmaxbackups'] ) && $job_object->job['ftpmaxbackups'] > 0 ) { //Delete old backups
if ( count( $backupfilelist ) > $job_object->job['ftpmaxbackups'] ) {
ksort( $backupfilelist );
$numdeltefiles = 0;
while ( $file = array_shift( $backupfilelist ) ) {
if ( count( $backupfilelist ) < $job_object->job['ftpmaxbackups'] ) {
break;
}
if ( ftp_delete( $ftp_conn_id, $file ) ) { //delete files on ftp
foreach ( $files as $key => $filedata ) {
if ( $filedata['file'] == trailingslashit( $job_object->job['ftpdir'] ) . $file ) {
unset( $files[ $key ] );
}
}
$numdeltefiles ++;
} else {
$job_object->log(
sprintf(
__( 'Cannot delete "%s" on FTP server!', 'backwpup' ),
$job_object->job['ftpdir'] . $file
),
E_USER_ERROR
);
}
}
if ( $numdeltefiles > 0 ) {
$job_object->log(
sprintf(
_n(
'One file deleted on FTP server',
'%d files deleted on FTP server',
$numdeltefiles,
'backwpup'
),
$numdeltefiles
),
E_USER_NOTICE
);
}
}
}
set_site_transient( 'backwpup_' . $jobid . '_ftp', $files, YEAR_IN_SECONDS );
}
/**
* Run Job
*
* @param BackWPup_Job $job_object The instance of the job to use.
*
* @return bool True on success false on error
*/
public function job_run_archive( BackWPup_Job $job_object ) {
$job_object->substeps_todo = 2 + $job_object->backup_filesize;
if ( $job_object->steps_data[ $job_object->step_working ]['SAVE_STEP_TRY'] != $job_object->steps_data[ $job_object->step_working ]['STEP_TRY'] ) {
$job_object->log(
sprintf(
__( '%d. Try to send backup file to an FTP server …', 'backwpup' ),
$job_object->steps_data[ $job_object->step_working ]['STEP_TRY']
),
E_USER_NOTICE
);
}
if ( ! empty( $job_object->job['ftpssl'] ) ) { //make SSL FTP connection
if ( function_exists( 'ftp_ssl_connect' ) ) {
$ftp_conn_id = ftp_ssl_connect(
$job_object->job['ftphost'],
$job_object->job['ftphostport'],
$job_object->job['ftptimeout']
);
if ( $ftp_conn_id ) {
$job_object->log(
sprintf(
__( 'Connected via explicit SSL-FTP to server: %s', 'backwpup' ),
$job_object->job['ftphost'] . ':' . $job_object->job['ftphostport']
),
E_USER_NOTICE
);
} else {
$job_object->log(
sprintf(
__( 'Cannot connect via explicit SSL-FTP to server: %s', 'backwpup' ),
$job_object->job['ftphost'] . ':' . $job_object->job['ftphostport']
),
E_USER_ERROR
);
return false;
}
} else {
$job_object->log(
__( 'PHP function to connect with explicit SSL-FTP to server does not exist!', 'backwpup' ),
E_USER_ERROR
);
return true;
}
} else { //make normal FTP connection if SSL not work
$ftp_conn_id = ftp_connect(
$job_object->job['ftphost'],
$job_object->job['ftphostport'],
$job_object->job['ftptimeout']
);
if ( $ftp_conn_id ) {
$job_object->log(
sprintf(
__( 'Connected to FTP server: %s', 'backwpup' ),
$job_object->job['ftphost'] . ':' . $job_object->job['ftphostport']
),
E_USER_NOTICE
);
} else {
$job_object->log(
sprintf(
__( 'Cannot connect to FTP server: %s', 'backwpup' ),
$job_object->job['ftphost'] . ':' . $job_object->job['ftphostport']
),
E_USER_ERROR
);
return false;
}
}
//FTP Login
$job_object->log(
sprintf( __( 'FTP client command: %s', 'backwpup' ), 'USER ' . $job_object->job['ftpuser'] ),
E_USER_NOTICE
);
if ( $loginok = @ftp_login(
$ftp_conn_id,
$job_object->job['ftpuser'],
BackWPup_Encryption::decrypt( $job_object->job['ftppass'] )
) ) {
$job_object->log(
sprintf(
__( 'FTP server response: %s', 'backwpup' ),
'User ' . $job_object->job['ftpuser'] . ' logged in.'
),
E_USER_NOTICE
);
} else { //if PHP ftp login don't work use raw login
$return = ftp_raw( $ftp_conn_id, 'USER ' . $job_object->job['ftpuser'] );
$job_object->log( sprintf( __( 'FTP server reply: %s', 'backwpup' ), $return[0] ), E_USER_NOTICE );
if ( substr( trim( $return[0] ), 0, 3 ) <= 400 ) {
$job_object->log(
sprintf( __( 'FTP client command: %s', 'backwpup' ), 'PASS *******' ),
E_USER_NOTICE
);
$return = ftp_raw(
$ftp_conn_id,
'PASS ' . BackWPup_Encryption::decrypt( $job_object->job['ftppass'] )
);
if ( substr( trim( $return[0] ), 0, 3 ) <= 400 ) {
$job_object->log( sprintf( __( 'FTP server reply: %s', 'backwpup' ), $return[0] ), E_USER_NOTICE );
$loginok = true;
} else {
$job_object->log( sprintf( __( 'FTP server reply: %s', 'backwpup' ), $return[0] ), E_USER_ERROR );
}
}
}
if ( ! $loginok ) {
return false;
}
$this->ftp_conn_id = $ftp_conn_id;
//SYSTYPE
$job_object->log( sprintf( __( 'FTP client command: %s', 'backwpup' ), 'SYST' ), E_USER_NOTICE );
$systype = ftp_systype( $ftp_conn_id );
if ( $systype ) {
$job_object->log( sprintf( __( 'FTP server reply: %s', 'backwpup' ), $systype ), E_USER_NOTICE );
} else {
$job_object->log(
sprintf( __( 'FTP server reply: %s', 'backwpup' ), __( 'Error getting SYSTYPE', 'backwpup' ) ),
E_USER_ERROR
);
}
//set actual ftp dir to ftp dir
if ( empty( $job_object->job['ftpdir'] ) ) {
$job_object->job['ftpdir'] = trailingslashit( ftp_pwd( $ftp_conn_id ) );
}
// prepend actual ftp dir if relative dir
if ( substr( $job_object->job['ftpdir'], 0, 1 ) != '/' ) {
$job_object->job['ftpdir'] = trailingslashit( ftp_pwd( $ftp_conn_id ) ) . $job_object->job['ftpdir'];
}
//test ftp dir and create it if not exists
if ( $job_object->job['ftpdir'] != '/' ) {
@ftp_chdir( $ftp_conn_id, '/' ); //go to root
$ftpdirs = explode( '/', trim( $job_object->job['ftpdir'], '/' ) );
foreach ( $ftpdirs as $ftpdir ) {
if ( empty( $ftpdir ) ) {
continue;
}
if ( ! @ftp_chdir( $ftp_conn_id, $ftpdir ) ) {
if ( ! $this->create_dir( $ftp_conn_id, $ftpdir, $job_object ) ) {
return false;
}
ftp_chdir( $ftp_conn_id, $ftpdir );
}
}
}
// Get the current working directory
$current_ftp_dir = trailingslashit( ftp_pwd( $ftp_conn_id ) );
if ( $job_object->substeps_done == 0 ) {
$job_object->log(
sprintf( __( 'FTP current folder is: %s', 'backwpup' ), $current_ftp_dir ),
E_USER_NOTICE
);
}
//get file size to resume upload
@clearstatcache();
$job_object->substeps_done = @ftp_size( $ftp_conn_id, $job_object->job['ftpdir'] . $job_object->backup_file );
if ( $job_object->substeps_done == - 1 ) {
$job_object->substeps_done = 0;
}
//PASV
$job_object->log( sprintf( __( 'FTP client command: %s', 'backwpup' ), 'PASV' ), E_USER_NOTICE );
if ( $job_object->job['ftppasv'] ) {
if ( ftp_pasv( $ftp_conn_id, true ) ) {
$job_object->log(
sprintf( __( 'FTP server reply: %s', 'backwpup' ), __( 'Entering passive mode', 'backwpup' ) ),
E_USER_NOTICE
);
} else {
$job_object->log(
sprintf( __( 'FTP server reply: %s', 'backwpup' ), __( 'Cannot enter passive mode', 'backwpup' ) ),
E_USER_WARNING
);
}
} else {
if ( ftp_pasv( $ftp_conn_id, false ) ) {
$job_object->log(
sprintf( __( 'FTP server reply: %s', 'backwpup' ), __( 'Entering normal mode', 'backwpup' ) ),
E_USER_NOTICE
);
} else {
$job_object->log(
sprintf( __( 'FTP server reply: %s', 'backwpup' ), __( 'Cannot enter normal mode', 'backwpup' ) ),
E_USER_WARNING
);
}
}
if ( $job_object->substeps_done < $job_object->backup_filesize ) {
$job_object->log( __( 'Starting upload to FTP …', 'backwpup' ), E_USER_NOTICE );
if ( $fp = fopen( $job_object->backup_folder . $job_object->backup_file, 'rb' ) ) {
//go to actual file pos
fseek( $fp, $job_object->substeps_done );
$ret = ftp_nb_fput(
$ftp_conn_id,
$current_ftp_dir . $job_object->backup_file,
$fp,
FTP_BINARY,
$job_object->substeps_done
);
while ( $ret == FTP_MOREDATA ) {
$job_object->substeps_done = ftell( $fp );
$job_object->update_working_data();
$job_object->do_restart_time();
$ret = ftp_nb_continue( $ftp_conn_id );
}
if ( $ret != FTP_FINISHED ) {
$job_object->log( __( 'Cannot transfer backup to FTP server!', 'backwpup' ), E_USER_ERROR );
return false;
} else {
$job_object->substeps_done = $job_object->backup_filesize + 1;
$job_object->log(
sprintf(
__( 'Backup transferred to FTP server: %s', 'backwpup' ),
$current_ftp_dir . $job_object->backup_file
),
E_USER_NOTICE
);
if ( ! empty( $job_object->job['jobid'] ) ) {
BackWPup_Option::update(
$job_object->job['jobid'],
'lastbackupdownloadurl',
"ftp://" . $job_object->job['ftpuser'] . ":" . BackWPup_Encryption::decrypt(
$job_object->job['ftppass']
) . "@" . $job_object->job['ftphost'] . ':' . $job_object->job['ftphostport'] . $current_ftp_dir . $job_object->backup_file
);
}
}
fclose( $fp );
} else {
$job_object->log( __( 'Can not open source file for transfer.', 'backwpup' ), E_USER_ERROR );
return false;
}
}
$this->file_update_list( $job_object, true );
$job_object->substeps_done ++;
ftp_close( $ftp_conn_id );
return true;
}
/**
* Can Run
*
* @param array $job_settings The settings of the job.
*
* @return bool True if the job can run, false otherwise
*/
public function can_run( array $job_settings ) {
if ( empty( $job_settings['ftphost'] ) ) {
return false;
}
if ( empty( $job_settings['ftpuser'] ) ) {
return false;
}
if ( empty( $job_settings['ftppass'] ) ) {
return false;
}
return true;
}
/**
* Create Dir
*
* Try to create the directory and if not possible, try to change the permissions of the parent,
* then try to create it again.
*
* @param resource $stream The ftp stream pointer.
* @param string $dir The directory to create.
* @param BackWPup_Job $job_object The job instance.
*
* @return bool True on success false on failure
*/
private function create_dir( $stream, $dir, BackWPup_Job $job_object ) {
// Try to create the directory.
$response = (bool) ftp_mkdir( $stream, $dir );
if ( ! $response ) {
// Trying to set the parent directory permissions.
$response = (bool) ftp_chmod( $stream, 0775, './' );
if ( ! $response ) {
$job_object->log(
sprintf(
esc_html__(
'FTP Folder "%s" cannot be created! Parent directory may be not writable.',
'backwpup'
),
$dir
),
E_USER_ERROR
);
return $response;
}
// Try to create the directory for the second time.
$response = (bool) ftp_mkdir( $stream, $dir );
if ( ! $response ) {
$job_object->log(
sprintf(
esc_html__( 'FTP Folder "%s" cannot be created!', 'backwpup' ),
$dir
),
E_USER_ERROR
);
return $response;
}
}
$job_object->log(
sprintf(
esc_html__( 'FTP Folder "%s" created!', 'backwpup' ),
$dir
),
E_USER_NOTICE
);
return $response;
}
}