set explicit sync ALL state to exisiting sync providers

Signed-off-by: Kavindu Dodanduwa <kavindudodanduwa@gmail.com>
open-feature · Jan 23, 2023 · 142a743 · 142a743
1 parent eafff32
commit 142a743
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 9 deletions.
diff --git a/pkg/sync/file/filepath_sync.go b/pkg/sync/file/filepath_sync.go
@@ -44,7 +44,7 @@ func (fs *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error {
 		return err
 	}
 
-	dataSync <- sync.DataSync{FlagData: fetch, Source: fs.URI}
+	dataSync <- sync.DataSync{FlagData: fetch, Source: fs.URI, Type: sync.ALL}
 
 	fs.Logger.Info(fmt.Sprintf("Watching filepath: %s", fs.URI))
 	for {
@@ -66,7 +66,7 @@ func (fs *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error {
 					continue
 				}
 
-				dataSync <- sync.DataSync{FlagData: msg, Source: fs.URI}
+				dataSync <- sync.DataSync{FlagData: msg, Source: fs.URI, Type: sync.ALL}
 			case fsnotify.Write:
 				fs.Logger.Debug("Configuration modified")
 				msg, err := fs.fetch(ctx)
@@ -75,7 +75,7 @@ func (fs *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error {
 					continue
 				}
 
-				dataSync <- sync.DataSync{FlagData: msg, Source: fs.URI}
+				dataSync <- sync.DataSync{FlagData: msg, Source: fs.URI, Type: sync.ALL}
 			case fsnotify.Remove:
 				// K8s exposes config maps as symlinks.
 				// Updates cause a remove event, we need to re-add the watcher in this case.

diff --git a/pkg/sync/http/http_sync.go b/pkg/sync/http/http_sync.go
@@ -44,7 +44,7 @@ func (hs *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error {
 		return err
 	}
 
-	dataSync <- sync.DataSync{FlagData: fetch, Source: hs.URI}
+	dataSync <- sync.DataSync{FlagData: fetch, Source: hs.URI, Type: sync.ALL}
 
 	_ = hs.Cron.AddFunc("*/5 * * * *", func() {
 		body, err := hs.fetchBodyFromURL(ctx, hs.URI)
@@ -62,7 +62,7 @@ func (hs *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error {
 				if err != nil {
 					hs.Logger.Error(fmt.Sprintf("Error fetching: %s", err.Error()))
 				} else {
-					dataSync <- sync.DataSync{FlagData: msg, Source: hs.URI}
+					dataSync <- sync.DataSync{FlagData: msg, Source: hs.URI, Type: sync.ALL}
 				}
 			} else {
 				currentSHA := hs.generateSha(body)
@@ -72,7 +72,7 @@ func (hs *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error {
 					if err != nil {
 						hs.Logger.Error(fmt.Sprintf("Error fetching: %s", err.Error()))
 					} else {
-						dataSync <- sync.DataSync{FlagData: msg, Source: hs.URI}
+						dataSync <- sync.DataSync{FlagData: msg, Source: hs.URI, Type: sync.ALL}
 					}
 				}
 

diff --git a/pkg/sync/kubernetes/kubernetes_sync.go b/pkg/sync/kubernetes/kubernetes_sync.go
@@ -40,7 +40,7 @@ func (k *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error {
 		return err
 	}
 
-	dataSync <- sync.DataSync{FlagData: fetch, Source: k.URI}
+	dataSync <- sync.DataSync{FlagData: fetch, Source: k.URI, Type: sync.ALL}
 
 	notifies := make(chan INotify)
 
@@ -60,7 +60,7 @@ func (k *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error {
 					continue
 				}
 
-				dataSync <- sync.DataSync{FlagData: msg, Source: k.URI}
+				dataSync <- sync.DataSync{FlagData: msg, Source: k.URI, Type: sync.ALL}
 			case DefaultEventTypeModify:
 				k.Logger.Debug("Configuration modified")
 				msg, err := k.fetch(ctx)
@@ -69,7 +69,7 @@ func (k *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error {
 					continue
 				}
 
-				dataSync <- sync.DataSync{FlagData: msg, Source: k.URI}
+				dataSync <- sync.DataSync{FlagData: msg, Source: k.URI, Type: sync.ALL}
 			case DefaultEventTypeDelete:
 				k.Logger.Debug("Configuration deleted")
 			case DefaultEventTypeReady: