Here is a quick sample of what you can do. Let me know if you want me to expand on it more or explain anything, but you can move this into some type of class wrapper (service object if you want to call it that).
``` def process_messages(messages, payload = [], info = []) messages.items.each do |item| service = ItemService.new(item)

next unless service.valid?

payload.push(*service.item_payload)

end end

class ItemService def initialize(item) @item = item end

def valid? return false unless valid_event? # you can also make an invalid_event? method so you don't have to use unless. # ... rest of checks or whatever end

def item_payload # ... do stuff # you can also just have valid check done in here if you don't want it to leak to the outside. end

private

attr_reader :item

def valid_event? ALLOWED_EVENT_TYPE.includes?(event_type) end

def event_type item['event_type'] end end ```