Contents

module Profit

  class MessageHandler

    include EM::Deferrable

    attr_reader :text

    def initialize(json, conn)
      @json, @conn = json, conn
    end

    def run
      return succeed("Starting") if @json.empty?
      message_hash = JSON.parse(@json)
      key = message_hash.delete("metric_type")
      response = @conn.rpush key, message_hash.to_json
      if response == "OK"
        succeed response
      else
        fail response
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
profit-0.1.1	lib/profit/message_handler.rb
profit-0.1.0	lib/profit/message_handler.rb