From 19877e679c8e35c0cc5eba955d5d2a51631bec6b Mon Sep 17 00:00:00 2001
From: Simone Gotti <simone.gotti@gmail.com>
Date: Mon, 29 Apr 2019 10:15:44 +0200
Subject: [PATCH] configstore readdb: also resync changegroups

---
 internal/services/configstore/readdb/readdb.go | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/internal/services/configstore/readdb/readdb.go b/internal/services/configstore/readdb/readdb.go
index 192d2ff..cd5e349 100644
--- a/internal/services/configstore/readdb/readdb.go
+++ b/internal/services/configstore/readdb/readdb.go
@@ -368,6 +368,18 @@ func (r *ReadDB) SyncRDB(ctx context.Context) error {
 			}
 		}
 
+		// sync changegroups, use the same revision of previous operations
+		changeGroupsRevisions, err := r.dm.ListEtcdChangeGroups(ctx, revision)
+		if err != nil {
+			return err
+		}
+
+		for changeGroupID, changeGroupRevision := range changeGroupsRevisions {
+			if err := r.insertChangeGroupRevision(tx, changeGroupID, changeGroupRevision); err != nil {
+				return err
+			}
+		}
+
 		return nil
 	})