diff --git a/spec/runners/unified/event_subscriber.rb b/spec/runners/unified/event_subscriber.rb index 0201261a00..c0f686f9bb 100644 --- a/spec/runners/unified/event_subscriber.rb +++ b/spec/runners/unified/event_subscriber.rb @@ -74,7 +74,7 @@ def failed(event) def published(event) payload = { 'name' => event.class.name.sub(/.*::/, '') + 'Event', - 'time' => Time.now.to_f, + 'observedAt' => Time.now.to_f, 'address' => event.address.seed, }.tap do |entry| if event.respond_to?(:connection_id) diff --git a/spec/runners/unified/support_operations.rb b/spec/runners/unified/support_operations.rb index 293f992948..f18b4993cc 100644 --- a/spec/runners/unified/support_operations.rb +++ b/spec/runners/unified/support_operations.rb @@ -198,7 +198,7 @@ def _loop(op) STDERR.puts "Error: #{e.class}: #{e}" entities.get(:error_list, store_errors) << { error: "#{e.class}: #{e}", - time: Time.now.to_f, + observedAt: Time.now.to_f, } else raise diff --git a/spec/runners/unified/test.rb b/spec/runners/unified/test.rb index 228b923ebc..55defe3449 100644 --- a/spec/runners/unified/test.rb +++ b/spec/runners/unified/test.rb @@ -89,10 +89,12 @@ def create_entities if store_events = spec.use('storeEventsAsEntities') store_event_names = {} - store_events.each do |event_name, entity_name| + store_events.each do |entity_name, event_names| #event_name = event_name.gsub(/Event$/, '').gsub(/[A-Z]/) { |m| "_#{m}" }.upcase #event_name = event_name.gsub(/Event$/, '').sub(/./) { |m| m.upcase } - store_event_names[event_name] = entity_name + event_names.each do |event_name| + store_event_names[event_name] = entity_name + end end store_event_names.values.uniq.each do |entity_name| entities.set(:event_list, entity_name, [])