spec/events_spec.rb in launchdarkly-server-sdk-5.6.1 vs spec/events_spec.rb in launchdarkly-server-sdk-5.6.2

@@ -414,10 +414,33 @@
     @ep.wait_until_inactive
     
     expect(hc.get_request["authorization"]).to eq "sdk_key"
   end
 
+  it "sends unique payload IDs" do
+    @ep = subject.new("sdk_key", default_config, hc)
+    e = { kind: "identify", user: user }
+  
+    @ep.add_event(e)
+    @ep.flush
+    @ep.wait_until_inactive
+    req0 = hc.get_request
+
+    @ep.add_event(e)
+    @ep.flush
+    @ep.wait_until_inactive
+    req1 = hc.get_request
+
+    id0 = req0["x-launchdarkly-payload-id"]
+    id1 = req1["x-launchdarkly-payload-id"]
+    expect(id0).not_to be_nil
+    expect(id0).not_to eq ""
+    expect(id1).not_to be nil
+    expect(id1).not_to eq ""
+    expect(id1).not_to eq id0
+  end
+
   def verify_unrecoverable_http_error(status)
     @ep = subject.new("sdk_key", default_config, hc)
     e = { kind: "identify", user: user }
     @ep.add_event(e)
 
@@ -440,11 +463,18 @@
 
     hc.set_response_status(503)
     @ep.flush
     @ep.wait_until_inactive
 
-    expect(hc.get_request).not_to be_nil
-    expect(hc.get_request).not_to be_nil
+    req0 = hc.get_request
+    expect(req0).not_to be_nil
+    req1 = hc.get_request
+    expect(req1).not_to be_nil
+    id0 = req0["x-launchdarkly-payload-id"]
+    expect(id0).not_to be_nil
+    expect(id0).not_to eq ""
+    expect(req1["x-launchdarkly-payload-id"]).to eq id0
+    
     expect(hc.get_request).to be_nil  # no 3rd request
 
     # now verify that a subsequent flush still generates a request
     hc.reset
     @ep.add_event(e)