From f547234a78343fcbebb48451866fa42bdcc94fef Mon Sep 17 00:00:00 2001 From: Kcermak Date: Tue, 3 Sep 2024 19:52:44 +0200 Subject: [PATCH] Added option to fix files in state error to new --- helpers/db.php | 331 ++++++++++++++++++++++--------------------- helpers/help.php | 269 +++++++++++++++++------------------ helpers/terminal.php | 78 +++++----- syncer.php | 158 ++++++++++----------- 4 files changed, 422 insertions(+), 414 deletions(-) diff --git a/helpers/db.php b/helpers/db.php index 9195e50..07fc006 100644 --- a/helpers/db.php +++ b/helpers/db.php @@ -1,163 +1,170 @@ -exec("CREATE TABLE `files` ( - `fileName` TEXT NOT NULL, - `state` INTEGER NOT NULL DEFAULT 0, - `discoveredOn` DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP, - `toDelete` DATETIME - )"); - - successMessage("Database created successfully."); - } - - - function canDelete() { - if (!file_exists(DB_FILE)) { - return True; - } - - errorMessage("Are you sure you want to DELETE your old database and create a new one? This operation is irreversible! Type 'destroy' to continue: "); - $handle = fopen ("php://stdin","r"); - $line = fgets($handle); - if(trim($line) != 'destroy'){ - echo "Cancelled..\n"; - return False; - } - - fclose($handle); - unlink(DB_FILE); //delete old db - return True; - } - - - function connectToDb() { - $conn = new PDO("sqlite:" . DB_FILE); - $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); - //enable foreign keys - $conn->exec("PRAGMA foreign_keys = ON;"); - if (!$conn) { - errorMessage("ERROR: Could not connect to the database."); - exit(1); - } - return $conn; - } - - - /* FILES */ - function getFileData($connection, $fileName) { - $stmt = $connection->prepare("SELECT * FROM files WHERE fileName = :fileName"); - $stmt->bindParam(':fileName', $fileName); - $stmt->execute(); - return $stmt->fetch(PDO::FETCH_ASSOC); - } - - - function addFile($connection, $fileName, $toDelete) { - $stmt = $connection->prepare("INSERT INTO files (fileName, toDelete) VALUES (:fileName, :toDelete)"); - $stmt->bindParam(':fileName', $fileName); - $stmt->bindParam(':toDelete', $toDelete); - $stmt->execute(); - } - - - function getFilesInState($connection, $state) { - $stmt = $connection->prepare("SELECT * FROM files WHERE state = :state"); - $stmt->bindParam(':state', $state); - $stmt->execute(); - return $stmt->fetchAll(PDO::FETCH_ASSOC); - } - - - function editDeletionDate($connection, $days) { - //get all files in state 0 / 1 / 2 - $stmt = $connection->prepare("SELECT * FROM files WHERE state < 3"); - $stmt->execute(); - $files = $stmt->fetchAll(PDO::FETCH_ASSOC); - - for ($i = 0; $i < count($files); $i++) { - $stmt = $connection->prepare("UPDATE files SET toDelete = :toDelete WHERE fileName = :fileName"); - $stmt->bindParam(':fileName', $files[$i]["fileName"]); - $toDelete = date("Y-m-d H:i:s", strtotime("+" . $days . " days", strtotime($files[$i]["toDelete"]))); - $stmt->bindParam(':toDelete', $toDelete); - $stmt->execute(); - } - } - - - function changeFileState($connection, $fileName, $state) { - $stmt = $connection->prepare("UPDATE files SET state = :state WHERE fileName = :fileName"); - $stmt->bindParam(':fileName', $fileName); - $stmt->bindParam(':state', $state); - $stmt->execute(); - } - - - function getFilesToDelete($connection) { - $time = date("Y-m-d H:i:s"); - $stmt = $connection->prepare("SELECT * FROM files WHERE toDelete <= :time AND state = 2"); - $stmt->bindParam(':time', $time); - $stmt->execute(); - return $stmt->fetchAll(PDO::FETCH_ASSOC); - } - - - function extendBackup($days) { - //if days is not number, is not set or is less than 0, or is decimal - if (!is_numeric($days) || $days != round($days)) { - errorMessage("ERROR: Days is not set, is not a number or is decimal."); - return; - } - - $connection = connectToDb(); - editDeletionDate($connection, $days); - if ($days > 0) { - successMessage("Backup extended for $days " . ngettext("day", "days", $days) . "."); - } else { - successMessage("Backup decreased for " . abs($days) . " " . ngettext("day", "days", abs($days)) . "."); - } - } - - - function fixErrors($fixing) { - if ($fixing != "upload" && $fixing != "delete") { - errorMessage("ERROR: Invalid argument. Use 'upload' or 'delete'."); - return; - } - - if ($fixing == "upload") { - $state = 1; - } else if ($fixing == "delete") { - $state = 3; - } - - //get all files in state 1 / 3 - $connection = connectToDb(); - $stmt = $connection->prepare("SELECT * FROM files WHERE state = :state"); - $stmt->bindParam(':state', $state); - $stmt->execute(); - $files = $stmt->fetchAll(PDO::FETCH_ASSOC); - - if (count($files) == 0) { - successMessage("Database is clean. No errors found."); - return; - } - - for ($i = 0; $i < count($files); $i++) { - $fileName = $files[$i]["fileName"]; - changeFileState($fileName, $state - 1, $connection); - } - - $text = ngettext("file", "files", count($files)); - successMessage("All files in state '". getState($state) ."' are now in state '" . getState($state - 1) . "'. (" . count($files) . " " . $text . ")"); - echo "Please run 'php syncer.php autorun' to continue.\n"; - } - +exec("CREATE TABLE `files` ( + `fileName` TEXT NOT NULL, + `state` INTEGER NOT NULL DEFAULT 0, + `discoveredOn` DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP, + `toDelete` DATETIME + )"); + + successMessage("Database created successfully."); + } + + + function canDelete() { + if (!file_exists(DB_FILE)) { + return True; + } + + errorMessage("Are you sure you want to DELETE your old database and create a new one? This operation is irreversible! Type 'destroy' to continue: "); + $handle = fopen ("php://stdin","r"); + $line = fgets($handle); + if(trim($line) != 'destroy'){ + echo "Cancelled..\n"; + return False; + } + + fclose($handle); + unlink(DB_FILE); //delete old db + return True; + } + + + function connectToDb() { + $conn = new PDO("sqlite:" . DB_FILE); + $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); + //enable foreign keys + $conn->exec("PRAGMA foreign_keys = ON;"); + if (!$conn) { + errorMessage("ERROR: Could not connect to the database."); + exit(1); + } + return $conn; + } + + + /* FILES */ + function getFileData($connection, $fileName) { + $stmt = $connection->prepare("SELECT * FROM files WHERE fileName = :fileName"); + $stmt->bindParam(':fileName', $fileName); + $stmt->execute(); + return $stmt->fetch(PDO::FETCH_ASSOC); + } + + + function addFile($connection, $fileName, $toDelete) { + $stmt = $connection->prepare("INSERT INTO files (fileName, toDelete) VALUES (:fileName, :toDelete)"); + $stmt->bindParam(':fileName', $fileName); + $stmt->bindParam(':toDelete', $toDelete); + $stmt->execute(); + } + + + function getFilesInState($connection, $state) { + $stmt = $connection->prepare("SELECT * FROM files WHERE state = :state"); + $stmt->bindParam(':state', $state); + $stmt->execute(); + return $stmt->fetchAll(PDO::FETCH_ASSOC); + } + + + function editDeletionDate($connection, $days) { + //get all files in state 0 / 1 / 2 + $stmt = $connection->prepare("SELECT * FROM files WHERE state < 3"); + $stmt->execute(); + $files = $stmt->fetchAll(PDO::FETCH_ASSOC); + + for ($i = 0; $i < count($files); $i++) { + $stmt = $connection->prepare("UPDATE files SET toDelete = :toDelete WHERE fileName = :fileName"); + $stmt->bindParam(':fileName', $files[$i]["fileName"]); + $toDelete = date("Y-m-d H:i:s", strtotime("+" . $days . " days", strtotime($files[$i]["toDelete"]))); + $stmt->bindParam(':toDelete', $toDelete); + $stmt->execute(); + } + } + + + function changeFileState($connection, $fileName, $state) { + $stmt = $connection->prepare("UPDATE files SET state = :state WHERE fileName = :fileName"); + $stmt->bindParam(':fileName', $fileName); + $stmt->bindParam(':state', $state); + $stmt->execute(); + } + + + function getFilesToDelete($connection) { + $time = date("Y-m-d H:i:s"); + $stmt = $connection->prepare("SELECT * FROM files WHERE toDelete <= :time AND state = 2"); + $stmt->bindParam(':time', $time); + $stmt->execute(); + return $stmt->fetchAll(PDO::FETCH_ASSOC); + } + + + function extendBackup($days) { + //if days is not number, is not set or is less than 0, or is decimal + if (!is_numeric($days) || $days != round($days)) { + errorMessage("ERROR: Days is not set, is not a number or is decimal."); + return; + } + + $connection = connectToDb(); + editDeletionDate($connection, $days); + if ($days > 0) { + successMessage("Backup extended for $days " . ngettext("day", "days", $days) . "."); + } else { + successMessage("Backup decreased for " . abs($days) . " " . ngettext("day", "days", abs($days)) . "."); + } + } + + + function fixErrors($fixing) { + if ($fixing != "upload" && $fixing != "delete" && $fixing != "error") { + errorMessage("ERROR: Invalid argument. Use 'upload' or 'delete' or 'error'."); + return; + } + + if ($fixing == "upload") { + $state = 1; + } else if ($fixing == "delete") { + $state = 3; + } else { + $state = 5; + } + + //get all files in state 1 / 3 / 5 + $connection = connectToDb(); + $stmt = $connection->prepare("SELECT * FROM files WHERE state = :state"); + $stmt->bindParam(':state', $state); + $stmt->execute(); + $files = $stmt->fetchAll(PDO::FETCH_ASSOC); + + if (count($files) == 0) { + successMessage("Database is clean. No errors found."); + return; + } + + $newState = $state - 1; + if ($state == 5) { + $newState = 0; + } + + for ($i = 0; $i < count($files); $i++) { + $fileName = $files[$i]["fileName"]; + changeFileState($connection, $fileName, $newState); + } + + $text = ngettext("file", "files", count($files)); + successMessage("All files in state '". getState($state) ."' are now in state '" . getState($newState) . "'. (" . count($files) . " " . $text . ")"); + echo "Please run 'php syncer.php autorun' to continue.\n"; + } + ?> \ No newline at end of file diff --git a/helpers/help.php b/helpers/help.php index 42e0008..e27df96 100644 --- a/helpers/help.php +++ b/helpers/help.php @@ -1,135 +1,136 @@ - \ No newline at end of file diff --git a/helpers/terminal.php b/helpers/terminal.php index ec08bc9..7f51c2c 100644 --- a/helpers/terminal.php +++ b/helpers/terminal.php @@ -1,40 +1,40 @@ -%-{$left}s] - $perc%% - $done/$total", "", ""); - fwrite(STDERR, $write); - } +%-{$left}s] - $perc%% - $done/$total", "", ""); + fwrite(STDERR, $write); + } ?> \ No newline at end of file diff --git a/syncer.php b/syncer.php index f2d2c8e..27f8bda 100644 --- a/syncer.php +++ b/syncer.php @@ -1,80 +1,80 @@ - 0, - "lost" => 0, - "uploaded" => 0, - "deleted" => 0, - "isok" => true, - "errors" => [] - ); - - require "settings.php"; - require CREDENTIALS_FILE; - require "helpers/help.php"; - require "helpers/terminal.php"; - require "helpers/db.php"; - require "helpers/ftp.php"; - require 'email/Exception.php'; - require 'email/PHPMailer.php'; - require 'email/SMTP.php'; - require 'helpers/email.php'; - - copyright(); - checkInstalledSqlite(); - checkInstalledFtp(); - - $arg = $argv[1] ?? '?'; - if ($arg == "?" || $arg == "help") { - if ($arg == "?") { - errorMessage("ERROR: Not command line arguments found."); - } - getHelp(); - - } else if ($arg == "create-db") { - build(); - } else if ($arg == "check-connection") { - checkConnection(); - } else if ($arg == "check-settings") { - checkSettings(); - } else if ($arg == "check-email") { - testEmail(); - } else if ($arg == "discovery") { - $type = $argv[2] ?? "safe"; - getNewFiles($type); - getLostFiles($type); - } else if ($arg == "sync") { - sync(); - } else if ($arg == "delete") { - deleteOld(); - } else if ($arg == "autorun") { - $start = microtime(true); - getNewFiles("classic"); - getLostFiles("classic"); - sync(); - deleteOld(); - - $end = microtime(true); - $emailStats["time"] = $end - $start; - sendReport(); - - } else if ($arg == "extend-backup") { - $days = $argv[2] ?? 0; - extendBackup($days); - } else if ($arg == "fix") { - $fixing = $argv[2] ?? "-"; - fixErrors($fixing); - } else { - errorMessage("ERROR: Invalid command line argument."); - getHelp(); - } - - + 0, + "lost" => 0, + "uploaded" => 0, + "deleted" => 0, + "isok" => true, + "errors" => [] + ); + + require "settings.php"; + require CREDENTIALS_FILE; + require "helpers/help.php"; + require "helpers/terminal.php"; + require "helpers/db.php"; + require "helpers/ftp.php"; + require 'email/Exception.php'; + require 'email/PHPMailer.php'; + require 'email/SMTP.php'; + require 'helpers/email.php'; + + copyright(); + checkInstalledSqlite(); + checkInstalledFtp(); + + $arg = $argv[1] ?? '?'; + if ($arg == "?" || $arg == "help") { + if ($arg == "?") { + errorMessage("ERROR: Not command line arguments found."); + } + getHelp(); + + } else if ($arg == "create-db") { + build(); + } else if ($arg == "check-connection") { + checkConnection(); + } else if ($arg == "check-settings") { + checkSettings(); + } else if ($arg == "check-email") { + testEmail(); + } else if ($arg == "discovery") { + $type = $argv[2] ?? "safe"; + getNewFiles($type); + getLostFiles($type); + } else if ($arg == "sync") { + sync(); + } else if ($arg == "delete") { + deleteOld(); + } else if ($arg == "autorun") { + $start = microtime(true); + getNewFiles("classic"); + getLostFiles("classic"); + sync(); + deleteOld(); + + $end = microtime(true); + $emailStats["time"] = $end - $start; + sendReport(); + + } else if ($arg == "extend-backup") { + $days = $argv[2] ?? 0; + extendBackup($days); + } else if ($arg == "fix") { + $fixing = $argv[2] ?? "-"; + fixErrors($fixing); + } else { + errorMessage("ERROR: Invalid command line argument."); + getHelp(); + } + + ?> \ No newline at end of file