# Send a notice to a Campfire room (http://campfirenow.com).
#
#  subdomain - The String subdomain of the Campfire account. If your URL is
#              "foo.campfirenow.com" then your subdomain is "foo".
#  token     - The String token used for authentication.
#  room      - The String room name to which the message should be sent.
#  ssl       - A Boolean determining whether or not to use SSL
#              (default: false).

require 'net/http'
require 'net/https'

CONTACT_DEPS[:campfire] = ['json']
CONTACT_DEPS[:campfire].each do |d|
  require d
end

module Marshmallow
  class Connection
    def initialize(options)
      raise "Required option :subdomain not set." unless options[:subdomain]
      raise "Required option :token not set." unless options[:token]
      @options = options
    end

    def base_url
      scheme = @options[:ssl] ? 'https' : 'http'
      subdomain = @options[:subdomain]
      "#{scheme}://#{subdomain}.campfirenow.com"
    end

    def find_room_id_by_name(room)
      url = URI.parse("#{base_url}/rooms.json")

      http = Net::HTTP.new(url.host, url.port)
      http.use_ssl = true if @options[:ssl]

      req = Net::HTTP::Get.new(url.path)
      req.basic_auth(@options[:token], 'X')

      res = http.request(req)
      case res
        when Net::HTTPSuccess
          rooms = JSON.parse(res.body)
          room = rooms['rooms'].select { |x| x['name'] == room }
          rooms.empty? ? nil : room.first['id']
        else
          raise res.error!
      end
    end

    def speak(room, message)
      room_id = find_room_id_by_name(room)
      raise "No such room: #{room}." unless room_id

      url = URI.parse("#{base_url}/room/#{room_id}/speak.json")

      http = Net::HTTP.new(url.host, url.port)
      http.use_ssl = true if @options[:ssl]

      req = Net::HTTP::Post.new(url.path)
      req.basic_auth(@options[:token], 'X')
      req.set_content_type('application/json')
      req.body = { 'message' => { 'body' => message } }.to_json

      res = http.request(req)
      case res
        when Net::HTTPSuccess
          true
        else
          raise res.error!
      end
    end
  end
end

module God
  module Contacts

    class Campfire < Contact
      class << self
        attr_accessor :subdomain, :token, :room, :ssl
        attr_accessor :format
      end

      self.ssl = false

      self.format = lambda do |message, time, priority, category, host|
        "[#{time.strftime('%H:%M:%S')}] #{host} - #{message}"
      end

      attr_accessor :subdomain, :token, :room, :ssl

      def valid?
        valid = true
        valid &= complain("Attribute 'subdomain' must be specified", self) unless arg(:subdomain)
        valid &= complain("Attribute 'token' must be specified", self) unless arg(:token)
        valid &= complain("Attribute 'room' must be specified", self) unless arg(:room)
        valid
      end

      def notify(message, time, priority, category, host)
        body = Campfire.format.call(message, time, priority, category, host)

        conn = Marshmallow::Connection.new(
          :subdomain => arg(:subdomain),
          :token => arg(:token),
          :ssl => arg(:ssl)
        )

        conn.speak(arg(:room), body)

        self.info = "notified campfire: #{arg(:subdomain)}"
      rescue Object => e
        applog(nil, :info, "failed to notify campfire: #{e.message}")
        applog(nil, :debug, e.backtrace.join("\n"))
      end
    end

  end
end