module Pubsubstub class Event attr_reader :id, :name, :data def initialize(data, name: nil, id: nil) @id = id || time_now @name = name @data = data end def to_json {id: @id, name: @name, data: @data}.to_json end def to_message data = @data.split("\n").map{ |segment| "data: #{segment}" }.join("\n") message = "id: #{id}" << "\n" message << "event: #{name}" << "\n" if name message << data << "\n\n" message end def self.from_json(json) hash = JSON.load(json) new(hash['data'], name: hash['name'], id: hash['id']) end def ==(other) id == other.id && name == other.name && data == other.data end private def time_now (Time.now.to_f * 1000).to_i end end end