lib/fetch.php

@@ -1,4 +1,6 @@
<?php
require_once(__DIR__.'/FtpConnection.php');

function ftp_fetch_if_newer($url, $file = NULL) {
   $url = parse_url($url);
   if(!isset($url['scheme']) || $url['scheme'] != 'ftp') {
@@ -30,41 +32,23 @@
      $localSize = filesize($file);
   }
   
   $ftp = ftp_connect($url['host'], $url['port'], 10);
   if($ftp === FALSE) {
      throw new Exception('FTP connection failed');
   }
   if(!ftp_login($ftp, $url['user'], $url['pass'])) {
      throw new Exception('FTP login failed');
   }
   if(!ftp_pasv($ftp, TRUE)) {
      throw new Exception('Passive FTP request failed');
   }
   $remoteSize = ftp_size($ftp, $url['path']);
   if($remoteSize < 0) {
      throw new Exception('FTP file size fetch failed');
   }
   $remoteTime = ftp_mdtm($ftp, $url['path']);
   if($remoteTime < 0) {
      throw new Exception('FTP modification time fetch failed');
   }
   $ftp = FtpConnection::create($url['host'], $url['port'], $url['user'], $url['pass']);
   $remoteSize = $ftp->size($url['path']);
   $remoteTime = $ftp->mdtm($url['path']);
   
   $updated = FALSE;
   
   if($localSize != $remoteSize || $localTime < $remoteTime) {
   if($localTime < $remoteTime || ($localTime == $remoteTime && $localSize != $remoteSize)) {
      if(file_exists($file.'.tmp')) {
         unlink($file.'.tmp');
      }
      if(ftp_get($ftp, $file.'.tmp', $url['path'], FTP_BINARY)) {
         touch($file.'.tmp', $remoteTime);
         if(!rename($file.'.tmp', $file)) {
            throw new Exception('Temporary file rename failed');
         }
         $updated = TRUE;
      $ftp->get($file.'.tmp', $url['path'], FTP_BINARY);
      touch($file.'.tmp', $remoteTime);
      if(!rename($file.'.tmp', $file)) {
         throw new Exception('Temporary file rename failed');
      }
      $updated = TRUE;
   }
	
   ftp_close($ftp);
   
   return $updated;
}