class Earch

# File lib/earch.rb, line 10
def initialize(file)
  @setting = Hashie::Mash.load(file)
  @rules = Rules.new(@setting.rules)
  @stream_client = Twitter::Streaming::Client.new @setting.twitter.api_key
  @slack_client = Slack::Web::Client.new(@setting.slack.api_key)
end

# File lib/earch.rb, line 30
def debug(json)
  Slack::Web::Client.class_eval do
    define_method :chat_postMessage{|*args|p args}
  end
  execute(Twitter::Tweet.new(JSON.parse(json, {:symbolize_names => true})))
end

# File lib/earch.rb, line 17
def start
  @stream_client.user(@setting.twitter.stream_options) do |object|
    case object
    when Twitter::Tweet
      execute(object)
    end
  end
rescue SignalException, Interrupt
rescue Twitter::Error::ServerError, EOFError, Errno::EPIPE
  sleep 1
  retry
end

# File lib/earch.rb, line 38
def execute(object)
  if @rules.match?(object)
    notify(object)
  end
end

# File lib/earch.rb, line 44
def notify(object)
  @slack_client.chat_postMessage(
    icon_emoji: @setting.slack.user_icon,
    username: 'Earch',
    channel: @setting.slack.notify_channel,
    attachments: notify_content(object)
  )
end

# File lib/earch.rb, line 53
def notify_content(object)
  [
    {
      "fallback": "#{object.text} by @#{object.user.screen_name}",
      "color": "#4169e1",
      "author_name": "#{object.user.name}(@#{object.user.screen_name})",
      "author_link": object.user.url,
      "author_icon": object.user.profile_image_url_https,
      "text": object.text,
      "fields": [
        {
          "value": "<#{object.url}|Tweet>",
        }
      ],
      "footer": "#{@setting.slack.icon} #{@setting.twitter.screen_name}",
      "ts": object.created_at.to_f
    }
  ]
end