using endpoints override

Author: tanderson-ld

pkgs/sdk/server/contract-tests/SdkClientEntity.cs

@@ -465,7 +465,8 @@ private static Configuration BuildSdkConfig(SdkConfigParams sdkParams, ILogAdapt
                             var pollingBuilder = DataSystemComponents.Polling();
                             if (initializer.Polling.BaseUri != null)
                             {
-                                endpoints.Polling(initializer.Polling.BaseUri);
+                                var endpointOverride = Components.ServiceEndpoints().Polling(initializer.Polling.BaseUri);
+                                pollingBuilder.ServiceEndpointsOverride(endpointOverride);
                             }
                             if (initializer.Polling.PollIntervalMs.HasValue)
                             {
@@ -493,7 +494,7 @@ private static Configuration BuildSdkConfig(SdkConfigParams sdkParams, ILogAdapt
                     // Primary synchronizer
                     if (sdkParams.DataSystem.Synchronizers.Primary != null)
                     {
-                        var primary = CreateSynchronizer(sdkParams.DataSystem.Synchronizers.Primary, endpoints, sdkParams.DataSystem.PayloadFilter);
+                        var primary = CreateSynchronizer(sdkParams.DataSystem.Synchronizers.Primary, sdkParams.DataSystem.PayloadFilter);
                         if (primary != null)
                         {
                             synchronizers.Add(primary);
@@ -503,7 +504,7 @@ private static Configuration BuildSdkConfig(SdkConfigParams sdkParams, ILogAdapt
                     // Secondary synchronizer (optional)
                     if (sdkParams.DataSystem.Synchronizers.Secondary != null)
                     {
-                        var secondary = CreateSynchronizer(sdkParams.DataSystem.Synchronizers.Secondary, endpoints, sdkParams.DataSystem.PayloadFilter);
+                        var secondary = CreateSynchronizer(sdkParams.DataSystem.Synchronizers.Secondary, sdkParams.DataSystem.PayloadFilter);
                         if (secondary != null)
                         {
                             synchronizers.Add(secondary);
@@ -524,15 +525,15 @@ private static Configuration BuildSdkConfig(SdkConfigParams sdkParams, ILogAdapt
 
         private static IComponentConfigurer<IDataSource> CreateSynchronizer(
             SdkConfigSynchronizerParams synchronizer,
-            ServiceEndpointsBuilder endpoints,
             string payloadFilter)
         {
             if (synchronizer.Polling != null)
             {
                 var pollingBuilder = DataSystemComponents.Polling();
                 if (synchronizer.Polling.BaseUri != null)
                 {
-                    endpoints.Polling(synchronizer.Polling.BaseUri);
+                    var endpointOverride = Components.ServiceEndpoints().Polling(synchronizer.Polling.BaseUri);
+                    pollingBuilder.ServiceEndpointsOverride(endpointOverride);
                 }
                 if (synchronizer.Polling.PollIntervalMs.HasValue)
                 {
@@ -550,7 +551,8 @@ private static IComponentConfigurer<IDataSource> CreateSynchronizer(
                 var streamingBuilder = DataSystemComponents.Streaming();
                 if (synchronizer.Streaming.BaseUri != null)
                 {
-                    endpoints.Streaming(synchronizer.Streaming.BaseUri);
+                    var endpointOverride = Components.ServiceEndpoints().Streaming(synchronizer.Streaming.BaseUri);
+                    streamingBuilder.ServiceEndpointsOverride(endpointOverride);
                 }
                 if (synchronizer.Streaming.InitialRetryDelayMs.HasValue)
                 {