@@ -83,7 +83,9 @@ discard block |
||
83 | 83 | |
84 | 84 | if (DB::count() > 0) { |
85 | 85 | // handle tasks inside this process |
86 | - if (WIP === true) error_log("Process in progress: ".$process_to_perform['increment_id']); |
|
86 | + if (WIP === true) { |
|
87 | + error_log("Process in progress: ".$process_to_perform['increment_id']); |
|
88 | + } |
|
87 | 89 | handleTask( |
88 | 90 | $process_to_perform['increment_id'], |
89 | 91 | json_decode($process_to_perform['arguments'], true), |
@@ -100,7 +102,9 @@ discard block |
||
100 | 102 | ); |
101 | 103 | |
102 | 104 | if (DB::count() > 0) { |
103 | - if (WIP === true) error_log("New process ta start: ".$process_to_perform['increment_id']); |
|
105 | + if (WIP === true) { |
|
106 | + error_log("New process ta start: ".$process_to_perform['increment_id']); |
|
107 | + } |
|
104 | 108 | // update DB - started_at |
105 | 109 | DB::update( |
106 | 110 | prefixTable('background_tasks'), |
@@ -153,8 +157,9 @@ discard block |
||
153 | 157 | ); |
154 | 158 | |
155 | 159 | // No more tasks, exit |
156 | - if ($process_to_perform !== 1) |
|
157 | - break; |
|
160 | + if ($process_to_perform !== 1) { |
|
161 | + break; |
|
162 | + } |
|
158 | 163 | |
159 | 164 | // Run next task |
160 | 165 | $process = new Symfony\Component\Process\Process([ |
@@ -331,7 +336,9 @@ discard block |
||
331 | 336 | if ($args['step'] === 'create_users_files_key') { |
332 | 337 | // Loop on all files for this item |
333 | 338 | // and encrypt them for each user |
334 | - if (WIP === true) provideLog('[DEBUG] '.print_r($args['files_keys'], true), $SETTINGS); |
|
339 | + if (WIP === true) { |
|
340 | + provideLog('[DEBUG] '.print_r($args['files_keys'], true), $SETTINGS); |
|
341 | + } |
|
335 | 342 | foreach($args['files_keys'] as $file) { |
336 | 343 | storeUsersShareKey( |
337 | 344 | prefixTable('sharekeys_items'), |
@@ -347,7 +354,9 @@ discard block |
||
347 | 354 | } elseif ($args['step'] === 'create_users_fields_key') { |
348 | 355 | // Loop on all encrypted fields for this item |
349 | 356 | // and encrypt them for each user |
350 | - if (WIP === true) provideLog('[DEBUG] '.print_r($args, true), $SETTINGS); |
|
357 | + if (WIP === true) { |
|
358 | + provideLog('[DEBUG] '.print_r($args, true), $SETTINGS); |
|
359 | + } |
|
351 | 360 | foreach($args['fields_keys'] as $field) { |
352 | 361 | storeUsersShareKey( |
353 | 362 | prefixTable('sharekeys_fields'), |
@@ -77,8 +77,9 @@ |
||
77 | 77 | ); |
78 | 78 | |
79 | 79 | // No more pending user_build_cache_tree tasks |
80 | - if (DB::count() === 0) |
|
81 | - exit; |
|
80 | + if (DB::count() === 0) { |
|
81 | + exit; |
|
82 | + } |
|
82 | 83 | |
83 | 84 | // get email properties |
84 | 85 | $arguments = json_decode($record['arguments'], true); |
@@ -74,7 +74,9 @@ discard block |
||
74 | 74 | if ($args['step'] === 'create_users_files_key') { |
75 | 75 | // Loop on all files for this item |
76 | 76 | // and encrypt them for each user |
77 | - if (WIP === true) provideLog('[DEBUG] '.print_r($args['files_keys'], true), $SETTINGS); |
|
77 | + if (WIP === true) { |
|
78 | + provideLog('[DEBUG] '.print_r($args['files_keys'], true), $SETTINGS); |
|
79 | + } |
|
78 | 80 | foreach($args['files_keys'] as $file) { |
79 | 81 | storeUsersShareKey( |
80 | 82 | prefixTable('sharekeys_items'), |
@@ -91,7 +93,9 @@ discard block |
||
91 | 93 | } elseif ($args['step'] === 'create_users_fields_key') { |
92 | 94 | // Loop on all encrypted fields for this item |
93 | 95 | // and encrypt them for each user |
94 | - if (WIP === true) provideLog('[DEBUG] '.print_r($args, true), $SETTINGS); |
|
96 | + if (WIP === true) { |
|
97 | + provideLog('[DEBUG] '.print_r($args, true), $SETTINGS); |
|
98 | + } |
|
95 | 99 | foreach($args['fields_keys'] as $field) { |
96 | 100 | storeUsersShareKey( |
97 | 101 | prefixTable('sharekeys_fields'), |