chore: disable SSE for all SDKs

harness/features/initialize.local.test.ts

@@ -92,7 +92,7 @@ describe('Initialize Tests - Local', () => {
         scope.get(configRequestUrl).times(3).reply(500)
         scope.post(`/client/${testClient.clientId}/v1/events/batch`).reply(201)
         await testClient.createClient(true, {
-            configPollingIntervalMS: 2000,
+            configPollingIntervalMS: 2300,
         })
 
         const variable = await testClient.callVariable(
@@ -105,7 +105,7 @@ describe('Initialize Tests - Local', () => {
         expect((await variable.json()).data.value).toEqual(0)
         scope.get(configRequestUrl).reply(200, testClient.getValidConfig)
 
-        await wait(2300)
+        await wait(2500)
         const variable2 = await testClient.callVariable(
             shouldBucketUser,
             sdkName,
@@ -162,12 +162,10 @@ describe('Initialize Tests - Local', () => {
     it('uses the same config if the etag matches', async () => {
         const testClient = new LocalTestClient(sdkName)
         const configRequestUrl = testClient.getValidConfigPath()
-        scope
-            .get(configRequestUrl)
-            .reply(200, testClient.getValidConfig(), {
-                ETag: 'test-etag',
-                'Last-Modified': lastModifiedDate.toUTCString(),
-            })
+        scope.get(configRequestUrl).reply(200, testClient.getValidConfig(), {
+            ETag: 'test-etag',
+            'Last-Modified': lastModifiedDate.toUTCString(),
+        })
         addEventsBatchMock(testClient)
 
         if (hasCapability(sdkName, Capabilities.lastModifiedHeader)) {

harness/helpers/proxyClientOptions.ts

@@ -9,6 +9,7 @@ export type ProxyClientOptions = {
     eventFlushIntervalMS?: number
     enableCloudBucketing?: boolean
     enableRealtimeUpdates?: boolean
+    disableRealtimeUpdates?: boolean
     logLevel?: string
     enableClientBootstrapping?: boolean
 }

package.json

@@ -12,6 +12,7 @@
         "start:dotnet": "cd proxies/dotnet && dotnet run",
         "start:java": "cd proxies/java && ./gradlew bootRun",
         "start:ruby": "cd proxies/ruby && bundle exec ruby app.rb",
+        "start:python": "cd proxies/python && python3 -m flask --app app run --host=0.0.0.0 -p 3000",
         "use-local": "scripts/use-local.sh"
     },
     "version": "1.0.0",
@@ -21,8 +22,8 @@
     "author": "DevCycle <[email protected]>",
     "license": "MIT",
     "devDependencies": {
-        "@devcycle/types": "^1.14.0",
-        "@eresearchqut/jest-testcontainers": "^3.2.0",
+        "@devcycle/types": "^1.20.0",
+        "@eresearchqut/jest-testcontainers": "^3.7.1",
         "@koa/router": "^12.0.0",
         "@types/jest": "^29.2.3",
         "@typescript-eslint/eslint-plugin": "^5.44.0",

proxies/dotnet/Controllers/Client.cs

@@ -35,6 +35,7 @@ public override string ToString()
         sb.Append("  ConfigCDNURLOverride: ").Append(ConfigCDNURLOverride).Append("\n");
         sb.Append("  EventsAPIURLOverride: ").Append(EventsAPIURLOverride).Append("\n");
         sb.Append("  EnableEdgeDB: ").Append(EnableEdgeDB).Append("\n");
+        sb.Append("  DisableRealtimeUpdates: ").Append(base.DisableRealtimeUpdates).Append("\n");
         sb.Append("}");
         return sb.ToString();
     }
@@ -97,7 +98,14 @@ public async Task<object> Post(ClientRequestBody ClientBody)
             }
             else
             {
-                if (ClientBody.Options?.ConfigCDNURLOverride != null)
+                if (ClientBody.Options == null)
+                {
+                    ClientBody.Options = new ClientOptions();
+                }
+                ClientBody.Options.DisableRealtimeUpdates = true;
+                Console.WriteLine($"DisableRealtimeUpdates set to: {ClientBody.Options.DisableRealtimeUpdates}");
+
+                if (ClientBody.Options.ConfigCDNURLOverride != null)
                 {
                     ClientBody.Options.CdnUri = ClientBody.Options.ConfigCDNURLOverride;
                 }

proxies/dotnet/dotnet.csproj

@@ -8,8 +8,8 @@
 
   <ItemGroup>
     <PackageReference Include="Microsoft.AspNetCore.Mvc.NewtonsoftJson" Version="7.0.1" />
-    <PackageReference Include="DevCycle.SDK.Server.Cloud" Version="3.0.1" />
-    <PackageReference Include="DevCycle.SDK.Server.Local" Version="4.0.1" />
+    <PackageReference Include="DevCycle.SDK.Server.Cloud" Version="3.4.0" />
+    <PackageReference Include="DevCycle.SDK.Server.Local" Version="4.4.0" />
     <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="7.0.0" />
     <PackageReference Include="Swashbuckle.AspNetCore" Version="6.4.0" />
   </ItemGroup>

proxies/go/go.mod

@@ -3,26 +3,26 @@ module github.com/devcyclehq/test-harness/proxies/go
 go 1.22.2
 
 require (
-	github.com/devcyclehq/go-server-sdk/v2 v2.15.1-0.20240607170116-8bd7750c7b99
+	github.com/devcyclehq/go-server-sdk/v2 v2.19.0
 	github.com/gorilla/mux v1.8.0
 )
 
 require (
-	github.com/gabriel-vasile/mimetype v1.4.3 // indirect
-	github.com/go-logr/logr v1.2.4 // indirect
+	github.com/gabriel-vasile/mimetype v1.4.8 // indirect
+	github.com/go-logr/logr v1.4.2 // indirect
 	github.com/go-playground/locales v0.14.1 // indirect
 	github.com/go-playground/universal-translator v0.18.1 // indirect
-	github.com/go-playground/validator/v10 v10.18.0 // indirect
-	github.com/google/uuid v1.3.0 // indirect
-	github.com/launchdarkly/eventsource v1.7.1 // indirect
+	github.com/go-playground/validator/v10 v10.24.0 // indirect
+	github.com/google/uuid v1.6.0 // indirect
+	github.com/launchdarkly/eventsource v1.8.0 // indirect
 	github.com/leodido/go-urn v1.4.0 // indirect
 	github.com/matryer/try v0.0.0-20161228173917-9ac251b645a2 // indirect
-	github.com/open-feature/go-sdk v1.8.0 // indirect
-	github.com/twmb/murmur3 v1.1.7 // indirect
-	golang.org/x/crypto v0.31.0 // indirect
-	golang.org/x/exp v0.0.0-20230811145659-89c5cff77bcb // indirect
-	golang.org/x/net v0.33.0 // indirect
-	golang.org/x/sys v0.28.0 // indirect
+	github.com/open-feature/go-sdk v1.14.1 // indirect
+	github.com/twmb/murmur3 v1.1.8 // indirect
+	golang.org/x/crypto v0.32.0 // indirect
+	golang.org/x/exp v0.0.0-20250106191152-7588d65b2ba8 // indirect
+	golang.org/x/net v0.34.0 // indirect
+	golang.org/x/sys v0.29.0 // indirect
 	golang.org/x/text v0.21.0 // indirect
 )
 

proxies/go/go.sum

@@ -5,10 +5,16 @@ github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/devcyclehq/go-server-sdk/v2 v2.15.1-0.20240607170116-8bd7750c7b99 h1:MZl7ZplpQfX83CYqFEr6yKmEJNoCf2FVmZ15lclNHeg=
 github.com/devcyclehq/go-server-sdk/v2 v2.15.1-0.20240607170116-8bd7750c7b99/go.mod h1:DzKrJ4s2apfphFwB/Aq8YDf7brB+NDr6IxX0TNi2c24=
+github.com/devcyclehq/go-server-sdk/v2 v2.19.0 h1:pNMv6fN6Y3UEKKFcPPA0HfRy8jlsQuk2rN+jO/n65ZM=
+github.com/devcyclehq/go-server-sdk/v2 v2.19.0/go.mod h1:Wo2nWl40oNwgzAM5q5bBdTssof9TAlmUauj0nxVHOjg=
 github.com/gabriel-vasile/mimetype v1.4.3 h1:in2uUcidCuFcDKtdcBxlR0rJ1+fsokWf+uqxgUFjbI0=
 github.com/gabriel-vasile/mimetype v1.4.3/go.mod h1:d8uq/6HKRL6CGdk+aubisF/M5GcPfT7nKyLpA0lbSSk=
+github.com/gabriel-vasile/mimetype v1.4.8 h1:FfZ3gj38NjllZIeJAmMhr+qKL8Wu+nOoI3GqacKw1NM=
+github.com/gabriel-vasile/mimetype v1.4.8/go.mod h1:ByKUIKGjh1ODkGM1asKUbQZOLGrPjydw3hYPU2YU9t8=
 github.com/go-logr/logr v1.2.4 h1:g01GSCwiDw2xSZfjJ2/T9M+S6pFdcNtFYsp+Y43HYDQ=
 github.com/go-logr/logr v1.2.4/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=
+github.com/go-logr/logr v1.4.2 h1:6pFjapn8bFcIbiKo3XT4j/BhANplGihG6tvd+8rYgrY=
+github.com/go-logr/logr v1.4.2/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=
 github.com/go-playground/assert/v2 v2.2.0 h1:JvknZsQTYeFEAhQwI4qEt9cyV5ONwRHC+lYKSsYSR8s=
 github.com/go-playground/assert/v2 v2.2.0/go.mod h1:VDjEfimB/XKnb+ZQfWdccd7VUvScMdVu0Titje2rxJ4=
 github.com/go-playground/locales v0.14.1 h1:EWaQ/wswjilfKLTECiXz7Rh+3BjFhfDFKv/oXslEjJA=
@@ -17,16 +23,22 @@ github.com/go-playground/universal-translator v0.18.1 h1:Bcnm0ZwsGyWbCzImXv+pAJn
 github.com/go-playground/universal-translator v0.18.1/go.mod h1:xekY+UJKNuX9WP91TpwSH2VMlDf28Uj24BCp08ZFTUY=
 github.com/go-playground/validator/v10 v10.18.0 h1:BvolUXjp4zuvkZ5YN5t7ebzbhlUtPsPm2S9NAZ5nl9U=
 github.com/go-playground/validator/v10 v10.18.0/go.mod h1:dbuPbCMFw/DrkbEynArYaCwl3amGuJotoKCe95atGMM=
+github.com/go-playground/validator/v10 v10.24.0 h1:KHQckvo8G6hlWnrPX4NJJ+aBfWNAE/HH+qdL2cBpCmg=
+github.com/go-playground/validator/v10 v10.24.0/go.mod h1:GGzBIJMuE98Ic/kJsBXbz1x/7cByt++cQ+YOuDM5wus=
 github.com/golang/mock v1.6.0 h1:ErTB+efbowRARo13NNdxyJji2egdxLGQhRaY+DUumQc=
 github.com/golang/mock v1.6.0/go.mod h1:p6yTPP+5HYm5mzsMV8JkE6ZKdX+/wYM6Hr+LicevLPs=
 github.com/google/uuid v1.3.0 h1:t6JiXgmwXMjEs8VusXIJk2BXHsn+wx8BZdTaoZ5fu7I=
 github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
+github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/gorilla/mux v1.8.0 h1:i40aqfkR1h2SlN9hojwV5ZA91wcXFOvkdNIeFDP5koI=
 github.com/gorilla/mux v1.8.0/go.mod h1:DVbg23sWSpFRCP0SfiEN6jmj59UnW/n46BH5rLB71So=
 github.com/jarcoal/httpmock v1.2.0 h1:gSvTxxFR/MEMfsGrvRbdfpRUMBStovlSRLw0Ep1bwwc=
 github.com/jarcoal/httpmock v1.2.0/go.mod h1:oCoTsnAz4+UoOUIf5lJOWV2QQIW5UoeUI6aM2YnWAZk=
 github.com/launchdarkly/eventsource v1.7.1 h1:StoRQeiPyrcQIXjlQ7b5jWMzHW4p+GGczN2r2oBhujg=
 github.com/launchdarkly/eventsource v1.7.1/go.mod h1:LHxSeb4OnqznNZxCSXbFghxS/CjIQfzHovNoAqbO/Wk=
+github.com/launchdarkly/eventsource v1.8.0 h1:o9TL53lINP9PCrKESlpIZADvN+eHWlSVmAzZDZ+FEA0=
+github.com/launchdarkly/eventsource v1.8.0/go.mod h1:IBckHy1VOjJGqSg07EJJLiUnk5DPunX9LKD9vbcgeHo=
 github.com/launchdarkly/go-test-helpers/v2 v2.2.0 h1:L3kGILP/6ewikhzhdNkHy1b5y4zs50LueWenVF0sBbs=
 github.com/launchdarkly/go-test-helpers/v2 v2.2.0/go.mod h1:L7+th5govYp5oKU9iN7To5PgznBuIjBPn+ejqKR0avw=
 github.com/leodido/go-urn v1.4.0 h1:WT9HwE9SGECu3lg4d/dIA+jxlljEa1/ffXKmRjqdmIQ=
@@ -35,6 +47,8 @@ github.com/matryer/try v0.0.0-20161228173917-9ac251b645a2 h1:JAEbJn3j/FrhdWA9jW8
 github.com/matryer/try v0.0.0-20161228173917-9ac251b645a2/go.mod h1:0KeJpeMD6o+O4hW7qJOT7vyQPKrWmj26uf5wMc/IiIs=
 github.com/open-feature/go-sdk v1.8.0 h1:jRkP7zeSGC3pSYn/s3EzJSpO9Q6CVP8BOnmvBZYQEa0=
 github.com/open-feature/go-sdk v1.8.0/go.mod h1:hpKxVZIJ0b+GpnI8imSJf9nFTcmTb0wWJZTgAS/3giw=
+github.com/open-feature/go-sdk v1.14.1 h1:jcxjCIG5Up3XkgYwWN5Y/WWfc6XobOhqrIwjyDBsoQo=
+github.com/open-feature/go-sdk v1.14.1/go.mod h1:t337k0VB/t/YxJ9S0prT30ISUHwYmUd/jhUZgFcOvGg=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
@@ -44,14 +58,24 @@ github.com/stretchr/testify v1.8.4 h1:CcVxjf3Q8PM0mHUKJCdn+eZZtm5yQwehR5yeSVQQcU
 github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
 github.com/twmb/murmur3 v1.1.7 h1:ULWBiM04n/XoN3YMSJ6Z2pHDFLf+MeIVQU71ZPrvbWg=
 github.com/twmb/murmur3 v1.1.7/go.mod h1:Qq/R7NUyOfr65zD+6Q5IHKsJLwP7exErjN6lyyq3OSQ=
+github.com/twmb/murmur3 v1.1.8 h1:8Yt9taO/WN3l08xErzjeschgZU2QSrwm1kclYq+0aRg=
+github.com/twmb/murmur3 v1.1.8/go.mod h1:Qq/R7NUyOfr65zD+6Q5IHKsJLwP7exErjN6lyyq3OSQ=
 golang.org/x/crypto v0.31.0 h1:ihbySMvVjLAeSH1IbfcRTkD/iNscyz8rGzjF/E5hV6U=
 golang.org/x/crypto v0.31.0/go.mod h1:kDsLvtWBEx7MV9tJOj9bnXsPbxwJQ6csT/x4KIN4Ssk=
+golang.org/x/crypto v0.32.0 h1:euUpcYgM8WcP71gNpTqQCn6rC2t6ULUPiOzfWaXVVfc=
+golang.org/x/crypto v0.32.0/go.mod h1:ZnnJkOaASj8g0AjIduWNlq2NRxL0PlBrbKVyZ6V/Ugc=
 golang.org/x/exp v0.0.0-20230811145659-89c5cff77bcb h1:mIKbk8weKhSeLH2GmUTrvx8CjkyJmnU1wFmg59CUjFA=
 golang.org/x/exp v0.0.0-20230811145659-89c5cff77bcb/go.mod h1:FXUEEKJgO7OQYeo8N01OfiKP8RXMtf6e8aTskBGqWdc=
+golang.org/x/exp v0.0.0-20250106191152-7588d65b2ba8 h1:yqrTHse8TCMW1M1ZCP+VAR/l0kKxwaAIqN/il7x4voA=
+golang.org/x/exp v0.0.0-20250106191152-7588d65b2ba8/go.mod h1:tujkw807nyEEAamNbDrEGzRav+ilXA7PCRAd6xsmwiU=
 golang.org/x/net v0.33.0 h1:74SYHlV8BIgHIFC/LrYkOGIwL19eTYXQ5wc6TBuO36I=
 golang.org/x/net v0.33.0/go.mod h1:HXLR5J+9DxmrqMwG9qjGCxZ+zKXxBru04zlTvWlWuN4=
+golang.org/x/net v0.34.0 h1:Mb7Mrk043xzHgnRM88suvJFwzVrRfHEHJEl5/71CKw0=
+golang.org/x/net v0.34.0/go.mod h1:di0qlW3YNM5oh6GqDGQr92MyTozJPmybPK4Ev/Gm31k=
 golang.org/x/sys v0.28.0 h1:Fksou7UEQUWlKvIdsqzJmUmCX3cZuD2+P3XyyzwMhlA=
 golang.org/x/sys v0.28.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/sys v0.29.0 h1:TPYlXGxvx1MGTn2GiZDhnjPA9wZzZeGKHHmKhHYvgaU=
+golang.org/x/sys v0.29.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/text v0.21.0 h1:zyQAAkrwaneQ066sspRyJaG9VNi/YJ1NfzcGB3hZ/qo=
 golang.org/x/text v0.21.0/go.mod h1:4IBbMaMmOPCJ8SecivzSH54+73PCFmPWxNTLm+vZkEQ=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=

proxies/go/handler_client.go

@@ -18,7 +18,7 @@ type clientRequestBodyOptions struct {
 	ConfigPollingIntervalMS int64  `json:"configPollingIntervalMS"`
 	EventFlushIntervalMS    int64  `json:"eventFlushIntervalMS"`
 	EnableCloudBucketing    bool   `json:"enableCloudBucketing"`
-	EnableRealtimeUpdates   bool   `json:"enableRealtimeUpdates"`
+	DisableRealTimeUpdates  bool   `json:"disableRealtimeUpdates"`
 }
 
 type clientRequestBody struct {
@@ -61,8 +61,7 @@ func clientHandler(w http.ResponseWriter, r *http.Request) {
 		EventFlushIntervalMS:    time.Duration(reqBody.Options.EventFlushIntervalMS * 1000000),
 		EnableCloudBucketing:    reqBody.EnableCloudBucketing,
 		ClientEventHandler:      clientEventChannel,
-		// TODO: Properly implement SSE tests. Currently the init delay on config pull breaks tests.
-		EnableBetaRealtimeUpdates: false,
+		DisableRealtimeUpdates:  true,
 	}
 
 	var res clientResponseBody

proxies/java/gradle/wrapper/gradle-wrapper.properties

@@ -1,5 +1,5 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-7.5.1-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.5-bin.zip
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists

proxies/java/src/main/java/com/dvc_harness/proxy/controller/ProxyController.java

@@ -46,6 +46,7 @@ public BaseResponse client(@RequestBody ClientRequestBody body, HttpServletRespo
                 DataStore.CloudClients.put(body.clientId, client);
             } else {
                 DevCycleLocalOptions.DevCycleLocalOptionsBuilder builder = DevCycleLocalOptions.builder();
+                builder.disableRealtimeUpdates(true);
 
                 if (body.options != null) {
                     if (body.options.configCDNURI != null) {
@@ -67,12 +68,16 @@ public BaseResponse client(@RequestBody ClientRequestBody body, HttpServletRespo
 
                 DevCycleLocalClient client = new DevCycleLocalClient(body.sdkKey, builder.build());
 
-                if(body.waitForInitialization) {
+                if (body.waitForInitialization) {
                     try {
                         long startWaitMS = System.currentTimeMillis();
+                        long timeoutMS = 2000;
+                        // body.options != null && body.options.configPollingIntervalMS != null && body.options.configPollingIntervalMS == 2000 
+                        //     ? 1500  // 2000 - 500
+                        //     : 2000;
                         while (!client.isInitialized()) {
-                            if (System.currentTimeMillis() - startWaitMS > 2000) {
-                                System.out.println("Client initialization timed out after 2000ms.");
+                            if (System.currentTimeMillis() - startWaitMS > timeoutMS) {
+                                System.out.println("Client initialization timed out after " + timeoutMS + "ms.");
                                 break;
                             }
                             Thread.sleep(50);

proxies/nodejs/handlers/client.ts

@@ -35,7 +35,10 @@ export const handleClient = async (ctx: Koa.ParameterizedContext) => {
         let client: DevCycleClient | DevCycleCloudClient
 
         if (!enableCloudBucketing) {
-            client = initializeDevCycle(sdkKey, { ...options })
+            client = initializeDevCycle(sdkKey, {
+                ...options,
+                disableRealTimeUpdates: true,
+            })
             if (waitForInitialization) {
                 try {
                     await client.onClientInitialized()

proxies/nodejs/package.json

@@ -1,7 +1,7 @@
 {
     "dependencies": {
-        "@devcycle/js-client-sdk": "^1.26.0",
-        "@devcycle/nodejs-server-sdk": "^1.31.1",
+        "@devcycle/js-client-sdk": "^1.34.0",
+        "@devcycle/nodejs-server-sdk": "^1.40.0",
         "@types/koa": "^2.13.5",
         "@types/koa-bodyparser": "^4.3.10",
         "@types/koa-router": "^7.4.4",