connection: emit networkError in all cases

quotient-im · Jul 18, 2023 · 4a74de6 · 4a74de6
1 parent 0e10076
commit 4a74de6
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 10 deletions.
diff --git a/Quotient/connection.cpp b/Quotient/connection.cpp
@@ -211,10 +211,7 @@ void Connection::assumeIdentity(const QString& mxId, const QString& accessToken)
             d->completeSetup(job->userId());
         });
         connect(job, &BaseJob::failure, this, [this, job] {
-            if (job->error() == BaseJob::StatusCode::NetworkError)
-                emit networkError(job->errorString(), job->rawDataSample(),
-                                  job->maxRetries(), -1);
-            else
+            if (job->error() != BaseJob::StatusCode::NetworkError)
                 emit loginError(job->errorString(), job->rawDataSample());
         });
     });
@@ -448,11 +445,6 @@ void Connection::sync(int timeout)
         d->syncJob = nullptr;
         emit syncDone();
     });
-    connect(job, &SyncJob::retryScheduled, this,
-            [this, job](int retriesTaken, int nextInMilliseconds) {
-                emit networkError(job->errorString(), job->rawDataSample(),
-                                  retriesTaken, nextInMilliseconds);
-            });
     connect(job, &SyncJob::failure, this, [this, job] {
         // SyncJob persists with retries on transient errors; if it fails,
         // there's likely something serious enough to stop the loop.
@@ -1624,6 +1616,11 @@ BaseJob* Connection::run(BaseJob* job, RunningPolicy runningPolicy)
     // Reparent to protect from #397, #398 and to prevent BaseJob* from being
     // garbage-collected if made by or returned to QML/JavaScript.
     job->setParent(this);
+    connect(job, &BaseJob::retryScheduled, this,
+            [this, job](int retriesTaken, int nextInMilliseconds) {
+                emit networkError(job->errorString(), job->rawDataSample(),
+                                  retriesTaken, nextInMilliseconds);
+            });
     connect(job, &BaseJob::failure, this, &Connection::requestFailed);
     job->initiate(d->data.get(), runningPolicy & BackgroundRequest);
     return job;

diff --git a/Quotient/connection.h b/Quotient/connection.h
@@ -771,7 +771,7 @@ public Q_SLOTS:
     //! \sa callApi
     void requestFailed(Quotient::BaseJob* request);
 
-    //! \brief A network request (job) failed due to network problems
+    //! \brief A network request (job) started by callAPI() failed due to network problems
     //!
     //! This is _only_ emitted when the job will retry on its own;
     //! once it gives up, requestFailed() will be emitted.