PML-154: IntitialSync.completed status flips (#90)

Author: inelpandzic

.github/workflows/e2etests.yml

@@ -1,11 +1,7 @@
 # .github/workflows/e2e-tests.yml
 name: E2E Tests
 
-on:
-  push:
-    branches: [main]
-  pull_request:
-    branches: [main]
+on: [pull_request]
 
 jobs:
   rs:

.github/workflows/go.yml

@@ -1,9 +1,6 @@
 name: code
-on:
-  push:
-    branches: ["main"]
-  pull_request:
-    branches: ["main"]
+
+on: [pull_request]
 
 jobs:
   test:

.github/workflows/reviewdog.yml

@@ -1,5 +1,7 @@
 name: reviewdog
+
 on: [pull_request]
+
 jobs:
   misspell:
     name: misspell

.github/workflows/trivy.yml

@@ -1,9 +1,7 @@
 name: Scan
-on:
-  push:
-    branches: ["main"]
-  pull_request:
-    branches: ["main"]
+
+on: [pull_request]
+
 jobs:
   scan:
     name: Trivy

mongolink/mongolink.go

@@ -245,6 +245,12 @@ func (ml *MongoLink) Status(ctx context.Context) *Status {
 		s.Error = errors.Wrap(s.Clone.Err, "Clone")
 	}
 
+	if s.Repl.IsStarted() {
+		intialSyncLag := max(int64(s.Clone.FinishTS.T)-int64(s.Repl.LastReplicatedOpTime.T), 0)
+		s.InitialSyncLagTime = &intialSyncLag
+		s.InitialSyncCompleted = s.Repl.LastReplicatedOpTime.After(s.Clone.FinishTS)
+	}
+
 	if ml.state == StateFailed {
 		return s
 	}
@@ -266,12 +272,6 @@ func (ml *MongoLink) Status(ctx context.Context) *Status {
 
 	s.InitialSyncLagTime = s.TotalLagTime
 
-	if s.Repl.IsStarted() {
-		intialSyncLag := max(int64(s.Clone.FinishTS.T)-int64(s.Repl.LastReplicatedOpTime.T), 0)
-		s.InitialSyncLagTime = &intialSyncLag
-		s.InitialSyncCompleted = s.Repl.LastReplicatedOpTime.After(s.Clone.FinishTS)
-	}
-
 	return s
 }