r_backup/scripts/backup.php

<?php

function my_echo_with_eol($msg)
{
  if (false) echo $msg.PHP_EOL;
}

function gzCompressFile($source, $dest, $level = 9){ 
    $mode = 'wb' . $level; 
    $error = false; 
    if ($fp_out = gzopen($dest, $mode)) { 
        if ($fp_in = fopen($source,'rb')) { 
            while (!feof($fp_in)) 
                gzwrite($fp_out, fread($fp_in, 1024 * 512)); 
            fclose($fp_in); 
        } else {
            $error = true; 
        }
        gzclose($fp_out); 
    } else {
        $error = true; 
    }
    if ($error)
        return false; 
    else
        return $dest; 
} 

function fileBackup($file_db, $fichier, $destination) // Fonction qui liste un dossier de façon récursive
{
    $ladate = date('Ymd');
    $basename = basename($fichier);
    $filename = str_replace('//', '/', "$ladate/$fichier");
    $filesize = filesize($fichier);
    $archive  = "$destination/$filename"; 
    $flag = false;

    // On sort si c'est un dossier ou un fichier caché
    if ($basename[0] == '.') return FALSE;
    if (is_dir($fichier))    return FALSE;

    // On sort si l'archive existe
    if (file_exists($archive))      return FALSE;
    if (file_exists("$archive.gz")) return FALSE;

    my_echo_with_eol("Compute SHA1 of $basename");
    $sha1_fichier = sha1_file($fichier);

    // Re-Hash with filesize to avoid conflict
    $sha1_fichier = sha1($sha1_fichier.$filesize);

    $insert = "INSERT INTO signatures (sha1, filename, filesize) VALUES (:sha1, :filename, :filesize)"; 
    $stmt1  = $file_db->prepare($insert);

    $update = "UPDATE signatures SET filename = :filename , filesize = :filesize WHERE sha1 = :sha1";
    $stmt2  = $file_db->prepare($update);

    $delete = "DELETE FROM signatures WHERE sha1 = :sha1";
    $stmt3  = $file_db->prepare($delete);

    my_echo_with_eol("Searching SHA1 in database for $basename");
    $result = $file_db->query("SELECT filename, filesize FROM signatures WHERE sha1 = '$sha1_fichier'");
    if ($result !== FALSE)
    {
        foreach($result as $f) 
        {
            my_echo_with_eol("Found ".$f['filename']);
            if ($f['filesize'] != $filesize) my_echo_with_eol("Oups, database and file filesize differ !");
            $in  = $destination.'/'.$f['filename'];
            $out = $archive;
            if (file_exists($in)) link($in, $out);
            if (file_exists("$in.gz")) link("$in.gz", "$out.gz");
            if (file_exists($out)||file_exists("$out.gz"))
            {
              $stmt2->execute(array(':sha1' => $sha1_fichier, ':filename' => $filename, ':filesize' => $filesize));
              $flag = true;
              my_echo_with_eol("Update database filename : $filename");
            }

            if (!$flag)
	    {
              my_echo_with_eol("Delete database sha1 : $sha1_fichier");
              $stmt3->execute(array(':sha1' => $sha1_fichier));
            }
        }
    }
    if (!$flag) 
    {
        my_echo_with_eol("Not Found $basename");

        // Les formats compressés sont juste copiés
        $ext = pathinfo($fichier, PATHINFO_EXTENSION);
        if ($ext == "avi") copy($fichier, $archive);
        if ($ext == "mkv") copy($fichier, $archive);
        if ($ext == "mp4") copy($fichier, $archive);
        if ($ext == "mp3") copy($fichier, $archive);

        if ($ext == "bz2") copy($fichier, $archive);
        if ($ext == "gz")  copy($fichier, $archive);
        if ($ext == "zip") copy($fichier, $archive);

        if ($ext == "iso") copy($fichier, $archive);

        if (!file_exists($archive)) 
        {
          my_echo_with_eol("Compress $basename");
          gzCompressFile($fichier, "$archive.gz");
        } else my_echo_with_eol("Copy $basename");

        my_echo_with_eol("Insert database filename : $filename");
	$stmt1->execute(array(':sha1' => $sha1_fichier, ':filename' => $filename, ':filesize' => $filesize));
    }
    my_echo_with_eol("--------- ");
    return TRUE;
}

function listeDossier($file_db, $dossier, $destination) // Fonction qui liste un dossier de façon récursive
{
    $ladate = date('Ymd');

    if (file_exists("$destination/$ladate/$dossier"))
    {
      my_echo_with_eol('BACKUP already done');
      return true;
    }

    if (is_dir($dossier))
    {
        if (!file_exists("$destination/$ladate")) mkdir("$destination/$ladate");
        $path = explode("/", $dossier);
        $init_path = "$destination/$ladate";
        foreach($path as $p)
        {
            $init_path .= '/'.$p;
            if (!file_exists($init_path)) mkdir($init_path);
        }
        my_echo_with_eol("BACKUP OF $dossier");
        if($dossierOuvert=opendir($dossier))
        {
            $n = 0;
            while(($fichier=readdir($dossierOuvert))!== false)
            {
                // if ($n++ == 8) break;

                if ($fichier[0] == '.') continue;

                if(is_dir("$dossier/$fichier"))
                    listeDossier($file_db, "$dossier/$fichier", $destination);
                else 
                    fileBackup($file_db, "$dossier/$fichier", $destination);
            }
        }
    }
    else
    {
        my_echo_with_eol("Erreur, le paramètre précisé dans la fonction n'est pas un dossier!");
    }
}

$source = $argv[1];
$backup = $argv[2];
$signatures=$backup.'/signatures.sqlite';

if (!file_exists($source))     die("$source NOT FOUND !");
if (!is_dir($backup))          die("$backup NOT FOUND !");
if (!file_exists($signatures)) die("$signatures NOT FOUND !");

$connexion = new PDO('sqlite:'.$signatures);
my_echo_with_eol("DATABASE IS OPEN");
if(is_dir($backup))
    listeDossier($connexion, $source, $backup);
else 
    fileBackup($connexion, $source, $backup);
$connexion = null;
my_echo_with_eol("DATABASE IS CLOSED");

?>