]> git.mxchange.org Git - friendica.git/blobdiff - src/Core/Update.php
Merge pull request #7355 from JeroenED/task/relationship-status2/no-dead-nodes
[friendica.git] / src / Core / Update.php
index aa400d1e8be0d1c51a4a876a58e182a9c8003f49..a52ef903b2da8867854fc1660317d57817e51cec 100644 (file)
@@ -2,6 +2,7 @@
 
 namespace Friendica\Core;
 
+use Friendica\App;
 use Friendica\Database\DBA;
 use Friendica\Database\DBStructure;
 use Friendica\Util\Strings;
@@ -14,16 +15,23 @@ class Update
        /**
         * @brief Function to check if the Database structure needs an update.
         *
-        * @param string $basePath The base path of this application
-        * @param boolean $via_worker boolean Is the check run via the worker?
+        * @param string   $basePath   The base path of this application
+        * @param boolean  $via_worker Is the check run via the worker?
+        * @param App\Mode $mode       The current app mode
+        *
         * @throws \Friendica\Network\HTTPException\InternalServerErrorException
         */
-       public static function check($basePath, $via_worker)
+       public static function check($basePath, $via_worker, App\Mode $mode)
        {
                if (!DBA::connected()) {
                        return;
                }
 
+               // Don't check the status if the last update was failed
+               if (Config::get('system', 'update', Update::SUCCESS, true) == Update::FAILED) {
+                       return;
+               }
+
                $build = Config::get('system', 'build');
 
                if (empty($build)) {
@@ -83,7 +91,7 @@ class Update
                        if ($stored < $current || $force) {
                                Config::load('database');
 
-                               Logger::log('Update from \'' . $stored . '\'  to \'' . $current . '\' - starting', Logger::DEBUG);
+                               Logger::info('Update starting.', ['from' => $stored, 'to' => $current]);
 
                                // Compare the current structure with the defined structure
                                // If the Lock is acquired, never release it automatically to avoid double updates
@@ -92,6 +100,7 @@ class Update
                                        // Checks if the build changed during Lock acquiring (so no double update occurs)
                                        $retryBuild = Config::get('system', 'build', null, true);
                                        if ($retryBuild !== $build) {
+                                               Logger::info('Update already done.', ['from' => $stored, 'to' => $current]);
                                                Lock::release('dbupdate');
                                                return '';
                                        }
@@ -100,7 +109,9 @@ class Update
                                        for ($x = $stored + 1; $x <= $current; $x++) {
                                                $r = self::runUpdateFunction($x, 'pre_update');
                                                if (!$r) {
-                                                       break;
+                                                       Config::set('system', 'update', Update::FAILED);
+                                                       Lock::release('dbupdate');
+                                                       return $r;
                                                }
                                        }
 
@@ -113,28 +124,32 @@ class Update
                                                                $retval
                                                        );
                                                }
-                                               Logger::log('ERROR: Update from \'' . $stored . '\'  to \'' . $current . '\' - failed:  ' - $retval, Logger::ALL);
+                                               Logger::error('Update ERROR.', ['from' => $stored, 'to' => $current, 'retval' => $retval]);
+                                               Config::set('system', 'update', Update::FAILED);
                                                Lock::release('dbupdate');
                                                return $retval;
                                        } else {
                                                Config::set('database', 'last_successful_update', $current);
                                                Config::set('database', 'last_successful_update_time', time());
-                                               Logger::log('Update from \'' . $stored . '\'  to \'' . $current . '\' - finished', Logger::DEBUG);
+                                               Logger::info('Update finished.', ['from' => $stored, 'to' => $current]);
                                        }
 
                                        // run the update_nnnn functions in update.php
                                        for ($x = $stored + 1; $x <= $current; $x++) {
                                                $r = self::runUpdateFunction($x, 'update');
                                                if (!$r) {
-                                                       break;
+                                                       Config::set('system', 'update', Update::FAILED);
+                                                       Lock::release('dbupdate');
+                                                       return $r;
                                                }
                                        }
 
-                                       Logger::log('Update from \'' . $stored . '\'  to \'' . $current . '\' - successful', Logger::DEBUG);
+                                       Logger::notice('Update success.', ['from' => $stored, 'to' => $current]);
                                        if ($sendMail) {
                                                self::updateSuccessfull($stored, $current);
                                        }
 
+                                       Config::set('system', 'update', Update::SUCCESS);
                                        Lock::release('dbupdate');
                                }
                        }
@@ -156,7 +171,7 @@ class Update
        {
                $funcname = $prefix . '_' . $x;
 
-               Logger::log('Update function \'' . $funcname . '\' - start', Logger::DEBUG);
+               Logger::info('Update function start.', ['function' => $funcname]);
 
                if (function_exists($funcname)) {
                        // There could be a lot of processes running or about to run.
@@ -177,7 +192,7 @@ class Update
                                                $x,
                                                L10n::t('Update %s failed. See error logs.', $x)
                                        );
-                                       Logger::log('ERROR: Update function \'' . $funcname . '\' - failed: ' . $retval, Logger::ALL);
+                                       Logger::error('Update function ERROR.', ['function' => $funcname, 'retval' => $retval]);
                                        Lock::release('dbupdate_function');
                                        return false;
                                } else {
@@ -189,12 +204,12 @@ class Update
                                        }
 
                                        Lock::release('dbupdate_function');
-                                       Logger::log('Update function \'' . $funcname . '\' - finished', Logger::DEBUG);
+                                       Logger::info('Update function finished.', ['function' => $funcname]);
                                        return true;
                                }
                        }
                } else {
-                        Logger::log('Skipping \'' . $funcname . '\' without executing', Logger::DEBUG);
+                       Logger::info('Update function skipped.', ['function' => $funcname]);
 
                        Config::set('database', 'last_successful_update_function', $funcname);
                        Config::set('database', 'last_successful_update_function_time', time());
@@ -221,7 +236,7 @@ class Update
 
                // No valid result?
                if (!DBA::isResult($adminlist)) {
-                       Logger::log(sprintf('Cannot notify administrators about update_id=%d, error_message=%s', $update_id, $error_message), Logger::INFO);
+                       Logger::warning('Cannot notify administrators .', ['update' => $update_id, 'message' => $error_message]);
 
                        // Don't continue
                        return;
@@ -251,6 +266,7 @@ class Update
                                        'uid'      => $admin['uid'],
                                        'type'     => SYSTEM_EMAIL,
                                        'to_email' => $admin['email'],
+                                       'subject'  => l10n::t('[Friendica Notify] Database update'),
                                        'preamble' => $preamble,
                                        'body'     => $body,
                                        'language' => $lang]
@@ -259,7 +275,7 @@ class Update
                }
 
                //try the logger
-               Logger::log("CRITICAL: Database structure update failed: " . $error_message);
+               Logger::alert('Database structure update FAILED.', ['error' => $error_message]);
        }
 
        private static function updateSuccessfull($from_build, $to_build)
@@ -289,6 +305,7 @@ class Update
                                                'uid' => $admin['uid'],
                                                'type' => SYSTEM_EMAIL,
                                                'to_email' => $admin['email'],
+                                               'subject'  => l10n::t('[Friendica Notify] Database update'),
                                                'preamble' => $preamble,
                                                'body' => $preamble,
                                                'language' => $lang]
@@ -298,6 +315,6 @@ class Update
                }
 
                //try the logger
-               Logger::log("Database structure update successful.", Logger::TRACE);
+               Logger::debug('Database structure update successful.');
        }
 }