From 80c98577830f32826aa8583196d1f66c7efe6732 Mon Sep 17 00:00:00 2001 From: Morgan Hallgren Date: Wed, 12 Apr 2017 14:44:59 +0200 Subject: [PATCH] =?UTF-8?q?return=20events=20that=20don=C2=B4t=20include?= =?UTF-8?q?=20any=20data?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- lib/http_event_store/helpers/parse_entries.rb | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/lib/http_event_store/helpers/parse_entries.rb b/lib/http_event_store/helpers/parse_entries.rb index aa6d80e..83b4156 100644 --- a/lib/http_event_store/helpers/parse_entries.rb +++ b/lib/http_event_store/helpers/parse_entries.rb @@ -13,17 +13,18 @@ def call(entries) private def create_event(entry) - return nil unless entry['data'] + return nil unless entry['eventType'] id = entry['eventNumber'] event_id = entry['eventId'] type = entry['eventType'] source_event_uri = entry['id'] - data = JSON.parse(entry['data']) + data = entry['data'] ? JSON.parse(entry['data']) : nil stream_name = entry['streamId'] position = entry['positionEventNumber'] created_time = entry['updated'] ? Time.parse(entry['updated']) : nil + Event.new(type, data, source_event_uri, event_id, id, position, stream_name, created_time) end end