Fixed a potential hanging on startup in ApplicationUpdater.

Also moved some log output to the end of the application startup process.

es-app/src/ApplicationUpdater.cpp

@@ -29,6 +29,7 @@ ApplicationUpdater::ApplicationUpdater()
     : mTimer {0}
     , mMaxTime {0}
     , mAbortDownload {false}
+    , mApplicationShutdown {false}
     , mCheckedForUpdate {false}
 {
     mUrl = "https://gitlab.com/api/v4/projects/18817634/repository/files/latest_release.json/"
@@ -38,6 +39,7 @@ ApplicationUpdater::ApplicationUpdater()
 ApplicationUpdater::~ApplicationUpdater()
 {
     // This is needed if getResults() was never called.
+    mApplicationShutdown = true;
     if (mThread)
         mThread->join();
 }
@@ -77,8 +79,9 @@ void ApplicationUpdater::checkForUpdates()
         mThread = std::make_unique<std::thread>(&ApplicationUpdater::updaterThread, this);
     }
     else {
-        LOG(LogDebug) << "ApplicationUpdater::checkForUpdates(): Skipping check as not enough time "
+        LOG(LogInfo) << "Skipping application update check as not enough time has passed "
-                         "has passed since the last run";
+                        "since the last run (configured to check \""
+                     << updateFrequency << "\")";
     }
 }
 
@@ -104,11 +107,11 @@ bool ApplicationUpdater::downloadFile()
             update();
         }
         catch (std::runtime_error& e) {
-            LOG(LogWarning) << "ApplicationUpdater: Couldn't download \"latest_release.json\": "
+            mLogWarning = "ApplicationUpdater: Couldn't download \"latest_release.json\": " +
-                            << e.what();
+                          std::string {e.what()};
             return true;
         }
-        if (mStatus == ASYNC_DONE)
+        if (mStatus == ASYNC_DONE || mApplicationShutdown)
             break;
         mTimer = SDL_GetTicks();
     };
@@ -117,11 +120,10 @@ bool ApplicationUpdater::downloadFile()
         rapidjson::Document doc;
         const std::string& fileContents {mRequest->getContent()};
         doc.Parse(&fileContents[0], fileContents.length());
-        if (doc.HasMember("error") && doc["error"].IsString()) {
+        if (!doc.HasParseError() && doc.HasMember("message") && doc["message"].IsString()) {
-            LOG(LogWarning)
+            mLogWarning = "ApplicationUpdater: Couldn't download \"latest_release.json\", received "
-                << "ApplicationUpdater: Couldn't download \"latest_release.json\", received "
+                          "server response \"" +
-                   "server error response \""
+                          std::string {doc["message"].GetString()} + "\"";
-                << doc["error"].GetString() << "\"";
             return true;
         }
         LOG(LogDebug)
@@ -131,12 +133,15 @@ bool ApplicationUpdater::downloadFile()
             parseFile();
         }
         catch (std::runtime_error& e) {
-            LOG(LogError) << "ApplicationUpdater: Couldn't parse \"latest_release.json\": "
+            mLogError = "ApplicationUpdater: Couldn't parse \"latest_release.json\": " +
-                          << e.what();
+                        std::string {e.what()};
             return true;
         }
     }
-    else if (mAbortDownload) {
+    else if (mApplicationShutdown) {
+        return true;
+    }
+    else if (mTimer - startTime - 10 > MAX_DOWNLOAD_TIME * 1000) {
         LOG(LogWarning) << "ApplicationUpdater: Aborted download of \"latest_release.json\" after "
                         << mTimer - startTime << " milliseconds as the application has started up";
         return true;
@@ -284,8 +289,9 @@ void ApplicationUpdater::compareVersions()
 #endif
     }
 
+    bool newVersion {false};
+
     for (auto& releaseType : releaseTypes) {
-        bool newVersion {false};
         // If the version does not follow the semantic versioning scheme then always consider it to
         // be a new release as perhaps the version scheme will be changed sometime in the future.
         if (count_if(releaseType->version.cbegin(), releaseType->version.cend(),
@@ -362,11 +368,14 @@ void ApplicationUpdater::compareVersions()
             // Cut the message to 280 characters so we don't make the message box exceedingly large.
             message = message.substr(0, 280);
 
-            LOG(LogInfo) << "ApplicationUpdater: A new "
+            mLogInfo = "A new ";
-                         << (releaseType == &mStableRelease ? "stable release" : "prerelease")
+            mLogInfo.append(releaseType == &mStableRelease ? "stable release" : "prerelease")
-                         << " is available for download at https://es-de.org: "
+                .append(" is available for download at https://es-de.org: ")
-                         << releaseType->version << " (r" << releaseType->releaseNum
+                .append(releaseType->version)
-                         << "), release date: " << releaseType->date;
+                .append(" (r")
+                .append(releaseType->releaseNum)
+                .append("), release date: ")
+                .append(releaseType->date);
 
             mResults.append("New ")
                 .append(releaseType == &mStableRelease ? "release " : "prerelease ")
@@ -385,6 +394,9 @@ void ApplicationUpdater::compareVersions()
             break;
         }
     }
+    if (!newVersion) {
+        mLogInfo = "No application updates available";
+    }
     mCheckedForUpdate = true;
 }
 
@@ -404,4 +416,16 @@ void ApplicationUpdater::getResults(std::string& results)
             Settings::getInstance()->saveFile();
         }
     }
+
+    // We output these messages here instead of immediately when they occur so that they will
+    // always be printed at the end of the application startup.
+    if (mLogError != "") {
+        LOG(LogError) << mLogError;
+    }
+    if (mLogWarning != "") {
+        LOG(LogWarning) << mLogWarning;
+    }
+    if (mLogInfo != "") {
+        LOG(LogInfo) << mLogInfo;
+    }
 }

es-app/src/ApplicationUpdater.h

@@ -51,9 +51,13 @@ private:
 
     std::string mUrl;
     std::string mResults;
+    std::string mLogInfo;
+    std::string mLogWarning;
+    std::string mLogError;
     unsigned int mTimer;
     unsigned int mMaxTime;
     std::atomic<bool> mAbortDownload;
+    std::atomic<bool> mApplicationShutdown;
     bool mCheckedForUpdate;
 
     std::unique_ptr<std::thread> mThread;