Contents

require 'rubygems'
require 'net/http'
require 'timeout'
require 'uri'
require 'json'
require 'hoptoad_notifier'

HoptoadNotifier.configure { |config| config.api_key='f625b37e34b6084e4a2eae85e6de954f' }

class Eotb

  METHODS = [:to_actor, :to_subject, :to_json, :to_hash, :inspect]
    
  def self.configure(api_key, host = '127.0.0.1', port = '3000')
    @@uri = URI.parse('http://' + host + ':' + port + '/events/' + api_key)
    @@post = Net::HTTP::Post.new(@@uri.path)
  end
  
  def self.register_event(actor, action, subject = {})
    action = { "event[action]" => action.to_s }    
    event = (hash_format(actor, :actor)).merge(action).merge(hash_format(subject, :subject))
    @@post.set_form_data(event)
    begin
    Timeout::timeout(2) {
      Net::HTTP.new(@@uri.host, @@uri.port).start.request(@@post)
    }
    rescue => e
      puts "TIMEOUT"
      HoptoadNotifier.notify(e)
    end
  end
  
  def self.value_format(value)
    value.send METHODS.find { |m| m if value.respond_to? m }
  end
  
  def self.hash_flatten(hash)
    hash.inject({}) do |h, (k, v)|
      if v.is_a?(Hash)
        hash_flatten(v).each do |sk, sv|
          h[[k] + sk] = sv
        end
      else
        k = k ? [k] : []
        h[k] = v
      end
      h
    end
  end

  def self.hash_format(hash, type)
    if hash.is_a?(Hash)
      h = hash_flatten(hash).map do |k, v|
        key = k.map{ |e| "[#{e}]" }.join
        "\"event[#{type}]#{key}\" => #{value_format(v)}"
      end.join(', ')
    else
      h = "\"event[#{type}]\" => #{value_format(hash)}"
    end
    eval "{#{h.to_s}}"
  end
  
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
eotb-0.4.6	lib/eotb.rb