fix e2e tests: backoff after sending error event

Signed-off-by: Alexandra Oberaigner <[email protected]>

Author: alexandraoberaigner

providers/flagd/e2e/inprocess_test.go

@@ -3,9 +3,10 @@
 package e2e
 
 import (
-	flagd "github.com/open-feature/go-sdk-contrib/providers/flagd/pkg"
 	"testing"
 
+	flagd "github.com/open-feature/go-sdk-contrib/providers/flagd/pkg"
+
 	"github.com/open-feature/go-sdk-contrib/tests/flagd/testframework"
 )
 
@@ -19,7 +20,7 @@ func TestInProcessProviderE2E(t *testing.T) {
 		ResolverType:  testframework.InProcess,
 		TestbedConfig: "default",
 		ExtraOptions: []flagd.ProviderOption{
-			flagd.WithRetryBackoffMaxMs(5000),
+			flagd.WithRetryBackoffMaxMs(3000),
 		},
 	})
 	defer runner.Cleanup()

providers/flagd/pkg/service/in_process/grpc_sync.go

@@ -1,10 +1,13 @@
 package process
 
 import (
-	"buf.build/gen/go/open-feature/flagd/grpc/go/flagd/sync/v1/syncv1grpc"
-	v1 "buf.build/gen/go/open-feature/flagd/protocolbuffers/go/flagd/sync/v1"
 	"context"
 	"fmt"
+	msync "sync"
+	"time"
+
+	"buf.build/gen/go/open-feature/flagd/grpc/go/flagd/sync/v1/syncv1grpc"
+	v1 "buf.build/gen/go/open-feature/flagd/protocolbuffers/go/flagd/sync/v1"
 	"github.com/open-feature/flagd/core/pkg/logger"
 	"github.com/open-feature/flagd/core/pkg/sync"
 	grpccredential "github.com/open-feature/flagd/core/pkg/sync/grpc/credentials"
@@ -13,8 +16,6 @@ import (
 	"google.golang.org/grpc/connectivity"
 	"google.golang.org/grpc/keepalive"
 	"google.golang.org/grpc/status"
-	msync "sync"
-	"time"
 )
 
 // FlagSyncServiceClient Type aliases for interfaces required by this component - needed for mock generation with gomock
@@ -193,16 +194,15 @@ func (g *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error {
 					}
 				}
 			}
-
-			// Backoff before retrying
-			time.Sleep(time.Duration(g.RetryBackOffMaxMs) * time.Millisecond)
-
-			g.Logger.Warn(fmt.Sprintf("sync cycle failed: %v, retrying...", err))
 			g.sendEvent(ctx, SyncEvent{event: of.ProviderError})
 
 			if ctx.Err() != nil {
 				return ctx.Err()
 			}
+
+			// Backoff before retrying
+			g.Logger.Warn(fmt.Sprintf("sync cycle failed: %v, retrying after %d backoff...", err, g.RetryBackOffMaxMs))
+			time.Sleep(time.Duration(g.RetryBackOffMaxMs) * time.Millisecond)
 		}
 	}
 }

providers/flagd/pkg/service/in_process/service.go

@@ -573,6 +573,8 @@ func createSyncProvider(cfg Configuration, log *logger.Logger) (isync.ISync, str
 		Selector:                cfg.Selector,
 		URI:                     uri,
 		FatalStatusCodes:        cfg.FatalStatusCodes,
+		RetryBackOffMaxMs: 		 cfg.RetryBackOffMaxMs,
+		RetryBackOffMs: 		 cfg.RetryBackOffMs,
 	}, uri
 }