class Proxy

# File lib/twing_proxy/proxy.rb, line 5
def initialize(*args)
  super
  @endpoints = setting.endpoints
end

# File lib/twing_proxy/proxy.rb, line 10
def on_message(object)
  case object
  when Twitter::Tweet
    logger.debug("Tweet #{object.id}")
    execute(object)
  end
end

# File lib/twing_proxy/proxy.rb, line 20
def execute(object)
  @endpoints.each do |endpoint|
    Thread.new do
      begin
        RestClient.post(
          endpoint,
          object.to_h.to_json,
          content_type: :json,
          accept: :json
        )
      rescue => e
        logger.error("#{e.class} #{e.message}")
      end
    end
  end
end