From 3f64bda0ccf3b1bb67d8916164ca9a10ca4024ec Mon Sep 17 00:00:00 2001
From: Simone Gotti <simone.gotti@gmail.com>
Date: Thu, 18 Jul 2019 13:39:12 +0200
Subject: [PATCH] readdb: save walSequence provided by data file

---
 internal/services/configstore/readdb/readdb.go | 10 ++++++++++
 internal/services/runservice/readdb/readdb.go  | 10 ++++++++++
 2 files changed, 20 insertions(+)

diff --git a/internal/services/configstore/readdb/readdb.go b/internal/services/configstore/readdb/readdb.go
index 6095298..098e1b5 100644
--- a/internal/services/configstore/readdb/readdb.go
+++ b/internal/services/configstore/readdb/readdb.go
@@ -188,6 +188,16 @@ func (r *ReadDB) SyncFromDump() (string, error) {
 		}
 	}
 
+	err = r.rdb.Do(func(tx *db.Tx) error {
+		if err := r.insertCommittedWalSequence(tx, dumpIndex.WalSequence); err != nil {
+			return err
+		}
+		return nil
+	})
+	if err != nil {
+		return "", err
+	}
+
 	return dumpIndex.WalSequence, nil
 }
 
diff --git a/internal/services/runservice/readdb/readdb.go b/internal/services/runservice/readdb/readdb.go
index 07ab217..4f98696 100644
--- a/internal/services/runservice/readdb/readdb.go
+++ b/internal/services/runservice/readdb/readdb.go
@@ -702,6 +702,16 @@ func (r *ReadDB) SyncFromDump() (string, error) {
 		}
 	}
 
+	err = r.rdb.Do(func(tx *db.Tx) error {
+		if err := r.insertCommittedWalSequenceOST(tx, dumpIndex.WalSequence); err != nil {
+			return err
+		}
+		return nil
+	})
+	if err != nil {
+		return "", err
+	}
+
 	return dumpIndex.WalSequence, nil
 }