Request GZIP compression (#239)

* Request GZIP compression

* Handle GZIP responses

Author: daniel-statsig

.github/workflows/kong.yml

@@ -16,7 +16,7 @@ env:
 
 jobs:
   KONG:
-    timeout-minutes: 5
+    timeout-minutes: 10
     runs-on: ubuntu-latest
     steps:
       - name: Get KONG

lib/network.rb

@@ -23,7 +23,6 @@ class Network
     extend T::Sig
 
     sig { params(server_secret: String, options: StatsigOptions, backoff_mult: Integer).void }
-
     def initialize(server_secret, options, backoff_mult = 10)
       super()
       URIHelper.initialize(options)
@@ -36,14 +35,14 @@ def initialize(server_secret, options, backoff_mult = 10)
       @session_id = SecureRandom.uuid
       @connection_pool = ConnectionPool.new(size: 3) do
         meta = Statsig.get_statsig_metadata
-        client = HTTP.headers(
+        client = HTTP.use(:auto_inflate).headers(
           {
             'STATSIG-API-KEY' => @server_secret,
-            'STATSIG-CLIENT-TIME' => (Time.now.to_f * 1000).to_i.to_s,
             'STATSIG-SERVER-SESSION-ID' => @session_id,
             'Content-Type' => 'application/json; charset=UTF-8',
             'STATSIG-SDK-TYPE' => meta['sdkType'],
-            'STATSIG-SDK-VERSION' => meta['sdkVersion']
+            'STATSIG-SDK-VERSION' => meta['sdkVersion'],
+            'Accept-Encoding' => 'gzip'
           }
         ).accept(:json)
         if @timeout
@@ -58,7 +57,6 @@ def initialize(server_secret, options, backoff_mult = 10)
       params(endpoint: String, body: String, retries: Integer, backoff: Integer)
         .returns([T.any(HTTP::Response, NilClass), T.any(StandardError, NilClass)])
     end
-
     def post_helper(endpoint, body, retries = 0, backoff = 1)
       if @local_mode
         return nil, nil

lib/spec_store.rb

@@ -222,6 +222,7 @@ def spawn_sync_id_lists_thread
         })
       end
     end
+
     def download_config_specs
       tracker = @diagnostics.track('download_config_specs', 'network_request')
 
@@ -237,6 +238,7 @@ def download_config_specs
         if e.nil?
           unless response.nil?
             tracker = @diagnostics.track('download_config_specs', 'process')
+
             if process_specs(response.body.to_s)
               @init_reason = EvaluationReason::NETWORK
             end
@@ -481,5 +483,6 @@ def process_single_id_list(list, content, content_length = nil, from_adapter: fa
         return false
       end
     end
+
   end
 end