fixing sse event parsing

Author: sanzmauro

lib/splitclient-rb/sse/event_source/event_parser.rb

@@ -43,7 +43,8 @@ def first_event(raw_data)
         private
 
         def parse_event_data(data, type)
-          event_data = JSON.parse(data.sub('data: ', ''))
+          data_value = data.sub('data:', '')
+          event_data = JSON.parse(data_value.strip)
           client_id = event_data['clientId']&.strip
           channel = event_data['channel']&.strip
           parsed_data = JSON.parse(event_data['data']) unless type == 'error'

spec/sse/event_source/event_parser_spec.rb

@@ -7,6 +7,7 @@
   let(:log) { StringIO.new }
   let(:config) { SplitIoClient::SplitConfig.new(logger: Logger.new(log)) }
 
+  let(:event_split_update_ws) { "fb\r\nid: 123\nevent: message\ndata:{\"id\":\"1\",\"clientId\":\"emptyClientId\",\"connectionId\":\"1\",\"timestamp\":1582045421733,\"channel\":\"channel-test\",\"data\":\"{\\\"type\\\" : \\\"SPLIT_UPDATE\\\",\\\"changeNumber\\\": 5564531221}\",\"name\":\"asdasd\"}\n\n\r\n" }
   let(:event_split_update) { "fb\r\nid: 123\nevent: message\ndata: {\"id\":\"1\",\"clientId\":\"emptyClientId\",\"connectionId\":\"1\",\"timestamp\":1582045421733,\"channel\":\"channel-test\",\"data\":\"{\\\"type\\\" : \\\"SPLIT_UPDATE\\\",\\\"changeNumber\\\": 5564531221}\",\"name\":\"asdasd\"}\n\n\r\n" }
   let(:event_split_kill) { "fb\r\nid: 123\nevent: message\ndata: {\"id\":\"1\",\"clientId\":\"emptyClientId\",\"connectionId\":\"1\",\"timestamp\":1582045421733,\"channel\":\"channel-test\",\"data\":\"{\\\"type\\\" : \\\"SPLIT_KILL\\\",\\\"changeNumber\\\": 5564531221, \\\"defaultTreatment\\\" : \\\"off\\\", \\\"splitName\\\" : \\\"split-test\\\"}\",\"name\":\"asdasd\"}\n\n\r\n" }
   let(:event_segment_update) { "fb\r\nid: 123\nevent: message\ndata: {\"id\":\"1\",\"clientId\":\"emptyClientId\",\"connectionId\":\"1\",\"timestamp\":1582045421733,\"channel\":\"channel-test\",\"data\":\"{\\\"type\\\" : \\\"SEGMENT_UPDATE\\\",\\\"changeNumber\\\": 5564531221, \\\"segmentName\\\" : \\\"segment-test\\\"}\",\"name\":\"asdasd\"}\n\n\r\n" }
@@ -25,6 +26,16 @@
     expect(event.channel).to eq('channel-test')
   end
 
+  it 'split update event - fixing event parser' do
+    parser = subject.new(config)
+
+    event = parser.parse(event_split_update_ws)[0]
+    expect(event.event_type).to eq('message')
+    expect(event.data['type']).to eq('SPLIT_UPDATE')
+    expect(event.data['changeNumber']).to eq(5_564_531_221)
+    expect(event.channel).to eq('channel-test')
+  end
+
   it 'split kill event' do
     parser = subject.new(config)