nilsteampassnet / TeamPass

sources/backups.queries.php

Braces +24 added lines, -8 removed lines

@@ -465,7 +465,9 @@ 
             }
 
             $dataReceived = prepareExchangedData($post_data, 'decode');
-            if (!is_array($dataReceived)) $dataReceived = [];
+            if (!is_array($dataReceived)) {
+                $dataReceived = [];
+            }
 
             $enabled = (int)($dataReceived['enabled'] ?? 0);
             $enabled = ($enabled === 1) ? 1 : 0;
@@ -486,22 +488,34 @@ 
             }
 
             $dow = (int)($dataReceived['dow'] ?? 1);
-            if ($dow < 1 || $dow > 7) $dow = 1;
+            if ($dow < 1 || $dow > 7) {
+                $dow = 1;
+            }
 
             $dom = (int)($dataReceived['dom'] ?? 1);
-            if ($dom < 1) $dom = 1;
-            if ($dom > 31) $dom = 31;
+            if ($dom < 1) {
+                $dom = 1;
+            }
+            if ($dom > 31) {
+                $dom = 31;
+            }
 
             $retentionDays = (int)($dataReceived['retention_days'] ?? 30);
-            if ($retentionDays < 1) $retentionDays = 1;
-            if ($retentionDays > 3650) $retentionDays = 3650;
+            if ($retentionDays < 1) {
+                $retentionDays = 1;
+            }
+            if ($retentionDays > 3650) {
+                $retentionDays = 3650;
+            }
 
             // Output dir: default to <files>/backups
             $baseFilesDir = (string)($SETTINGS['path_to_files_folder'] ?? (__DIR__ . '/../files'));
             $defaultDir = rtrim($baseFilesDir, '/') . '/backups';
 
             $outputDir = trim((string)($dataReceived['output_dir'] ?? ''));
-            if ($outputDir === '') $outputDir = $defaultDir;
+            if ($outputDir === '') {
+                $outputDir = $defaultDir;
+            }
 
             // Safety: prevent path traversal / outside files folder
             @mkdir($outputDir, 0770, true);
@@ -578,7 +592,9 @@ 
             }
 
             $dataReceived = prepareExchangedData($post_data, 'decode');
-            if (!is_array($dataReceived)) $dataReceived = [];
+            if (!is_array($dataReceived)) {
+                $dataReceived = [];
+            }
 
             $file = (string)($dataReceived['file'] ?? '');
             $file = basename($file);

scripts/background_tasks___handler.php

Braces +42 added lines, -14 removed lines

@@ -72,7 +72,9 @@ 
     public function processBackgroundTasks() {
         // Prevent multiple concurrent executions
         if (!$this->acquireProcessLock()) {
-            if (LOG_TASKS=== true) $this->logger->log('Process already running', 'INFO');
+            if (LOG_TASKS=== true) {
+                $this->logger->log('Process already running', 'INFO');
+            }
             return false;
         }
 
@@ -82,7 +84,9 @@ 
             $this->processTaskBatches();
             $this->performMaintenanceTasks();
         } catch (Exception $e) {
-            if (LOG_TASKS=== true) $this->logger->log('Task processing error: ' . $e->getMessage(), 'ERROR');
+            if (LOG_TASKS=== true) {
+                $this->logger->log('Task processing error: ' . $e->getMessage(), 'ERROR');
+            }
         } finally {
             $this->releaseProcessLock();
         }
@@ -112,7 +116,9 @@ 
         if ($nextRunAt <= 0) {
             $nextRunAt = $this->computeNextBackupRunAt($now);
             $this->upsertSettingValue('bck_scheduled_next_run_at', (string)$nextRunAt);
-            if (LOG_TASKS === true) $this->logger->log('backup scheduler initialized next_run_at=' . $nextRunAt, 'INFO');
+            if (LOG_TASKS === true) {
+                $this->logger->log('backup scheduler initialized next_run_at=' . $nextRunAt, 'INFO');
+            }
             return;
         }
 
@@ -131,7 +137,9 @@ 
         );
 
         if ($pending > 0) {
-            if (LOG_TASKS === true) $this->logger->log('backup scheduler: a database_backup task is already pending/running', 'INFO');
+            if (LOG_TASKS === true) {
+                $this->logger->log('backup scheduler: a database_backup task is already pending/running', 'INFO');
+            }
             return;
         }
 
@@ -161,7 +169,9 @@ 
         $newNext = $this->computeNextBackupRunAt($now + 60);
         $this->upsertSettingValue('bck_scheduled_next_run_at', (string)$newNext);
 
-        if (LOG_TASKS === true) $this->logger->log('backup scheduler: enqueued database_backup, next_run_at=' . $newNext, 'INFO');
+        if (LOG_TASKS === true) {
+            $this->logger->log('backup scheduler: enqueued database_backup, next_run_at=' . $newNext, 'INFO');
+        }
     }
 
     /**
@@ -207,7 +217,9 @@ 
 
         if ($freq === 'weekly') {
             $targetDow = (int)$this->getSettingValue('bck_scheduled_dow', '1'); // ISO 1..7
-            if ($targetDow < 1 || $targetDow > 7) $targetDow = 1;
+            if ($targetDow < 1 || $targetDow > 7) {
+                $targetDow = 1;
+            }
 
             $currentDow = (int)$candidate->format('N');
             $delta = ($targetDow - $currentDow + 7) % 7;
@@ -218,8 +230,12 @@ 
 
         } elseif ($freq === 'monthly') {
             $dom = (int)$this->getSettingValue('bck_scheduled_dom', '1');
-            if ($dom < 1) $dom = 1;
-            if ($dom > 31) $dom = 31;
+            if ($dom < 1) {
+                $dom = 1;
+            }
+            if ($dom > 31) {
+                $dom = 31;
+            }
 
             $year = (int)$now->format('Y');
             $month = (int)$now->format('m');
@@ -356,7 +372,9 @@ 
         
         // Check if the maximum number of parallel tasks is reached
         if ($runningTasks >= $this->maxParallelTasks) {
-            if (LOG_TASKS=== true) $this->logger->log('Wait ... '.$runningTasks.' out of '.$this->maxParallelTasks.' are already running ', 'INFO');
+            if (LOG_TASKS=== true) {
+                $this->logger->log('Wait ... '.$runningTasks.' out of '.$this->maxParallelTasks.' are already running ', 'INFO');
+            }
             return;
         }
 
@@ -374,7 +392,9 @@ 
         );
 
         foreach ($tasks as $task) {
-            if (LOG_TASKS=== true) $this->logger->log('Launching '.$task['increment_id'], 'INFO');
+            if (LOG_TASKS=== true) {
+                $this->logger->log('Launching '.$task['increment_id'], 'INFO');
+            }
             $this->processIndividualTask($task);
         }
     }
@@ -385,7 +405,9 @@ 
      * @param array $task The task to process.
      */
     private function processIndividualTask(array $task) {
-        if (LOG_TASKS=== true)  $this->logger->log('Starting task: ' . print_r($task, true), 'INFO');
+        if (LOG_TASKS=== true) {
+            $this->logger->log('Starting task: ' . print_r($task, true), 'INFO');
+        }
 
         // Store progress in the database        
         DB::update(
@@ -434,14 +456,18 @@ 
 
                 if ($rc === 0) {
                     // Worker ran successfully and updated the DB itself
-                    if (LOG_TASKS === true) $this->logger->log('Fallback exec succeeded for task ' . $task['increment_id'], 'INFO');
+                    if (LOG_TASKS === true) {
+                        $this->logger->log('Fallback exec succeeded for task ' . $task['increment_id'], 'INFO');
+                    }
                     return;
                 }
 
                 $msg .= ' | fallback_exit=' . $rc . ' | fallback_out=' . implode("\n", array_slice($out, -30));
             }
 
-            if (LOG_TASKS=== true) $this->logger->log('Error launching task: ' . $msg, 'ERROR');
+            if (LOG_TASKS=== true) {
+                $this->logger->log('Error launching task: ' . $msg, 'ERROR');
+            }
 
             DB::update(
                 prefixTable('background_tasks'),
@@ -545,7 +571,9 @@ 
             $taskIds
         );
     
-        if (LOG_TASKS=== true) $this->logger->log('Old finished tasks cleaned: ' . count($taskIds), 'INFO');
+        if (LOG_TASKS=== true) {
+            $this->logger->log('Old finished tasks cleaned: ' . count($taskIds), 'INFO');
+        }
     }
 }
 

scripts/background_tasks___worker.php

Braces +18 added lines, -6 removed lines

@@ -66,7 +66,9 @@ 
      */
     public function execute() {
         try {
-            if (LOG_TASKS=== true) $this->logger->log('Processing task: ' . print_r($this->taskData, true), 'DEBUG');
+            if (LOG_TASKS=== true) {
+                $this->logger->log('Processing task: ' . print_r($this->taskData, true), 'DEBUG');
+            }
             // Dispatch selon le type de processus
             switch ($this->processType) {
                 case 'item_copy':
@@ -307,7 +309,9 @@ 
             $arguments = '';
         }
 
-        if (LOG_TASKS=== true) $this->logger->log('Process: '.$this->processType.' -- '.print_r($arguments, true), 'DEBUG');
+        if (LOG_TASKS=== true) {
+            $this->logger->log('Process: '.$this->processType.' -- '.print_r($arguments, true), 'DEBUG');
+        }
 
         // Add 'arguments' only if not empty
         if (!empty($arguments)) {
@@ -322,7 +326,9 @@ 
             $this->taskId
         );
 
-        if (LOG_TASKS=== true) $this->logger->log('Finishing task: ' . $this->taskId, 'DEBUG');
+        if (LOG_TASKS=== true) {
+            $this->logger->log('Finishing task: ' . $this->taskId, 'DEBUG');
+        }
     }
 
     /**
@@ -366,7 +372,9 @@ 
      * @return void
      */
     private function processSubTasks($arguments) {
-        if (LOG_TASKS=== true) $this->logger->log('processSubTasks: '.print_r($arguments, true), 'DEBUG');
+        if (LOG_TASKS=== true) {
+            $this->logger->log('processSubTasks: '.print_r($arguments, true), 'DEBUG');
+        }
         // Get all subtasks related to this task
         $subtasks = DB::query(
             'SELECT * FROM ' . prefixTable('background_subtasks') . ' WHERE task_id = %i AND is_in_progress = 0 ORDER BY `task` ASC',
@@ -375,7 +383,9 @@ 
     
         // Check if there are any subtasks to process
         if (empty($subtasks)) {
-            if (LOG_TASKS=== true) $this->logger->log('No subtask was found for task: ' . $this->taskId, 'DEBUG');
+            if (LOG_TASKS=== true) {
+                $this->logger->log('No subtask was found for task: ' . $this->taskId, 'DEBUG');
+            }
             return;
         }
     
@@ -385,7 +395,9 @@ 
                 // Get the subtask data
                 $subtaskData = json_decode($subtask['task'], true);
 
-                if (LOG_TASKS=== true) $this->logger->log('Processing subtask: ' . $subtaskData['step'], 'DEBUG');
+                if (LOG_TASKS=== true) {
+                    $this->logger->log('Processing subtask: ' . $subtaskData['step'], 'DEBUG');
+                }
 
                 // Mark subtask as in progress
                 DB::update(