require "curb"
require "forwardable"

module Semaphore
  module Sms
    class Client
      extend Forwardable
      Response = Struct.new(:status, :content)

      def initialize(config)
        raise Semaphore::Sms::Error, 'Config must have app credentials' unless config.respond_to? :api_key
        @config = config
      end

      #TODO: add number validation here. Use piliponi gem.
      def send_message(message, recipients, sendername = nil)
        options = {
          message: message,
          sendername: sendername || sender_name,
          number: recipients.kind_of?(Array) ? recipients.join(",") : recipients
        }.compact
        api_post("messages", options)
      end

      def send_priority_message(message, recipients, sendername = nil)
        options = {
          message: message,
          sendername: sendername || sender_name,
          number: recipients.kind_of?(Array) ? recipients.join(",") : recipients
        }.compact
        api_post("priority", options)
      end

      def messages(id: nil)
        options = { id: id }.compact
        api_get("messages", options)
      end

      def account
        api_get("account")
      end

      def transactions(page: nil, limit: nil)
        options = {
          page: page,
          limit: limit
        }
        api_get("account/transactions", options)
      end

      def sender_names(page: nil, limit: nil)
        options = {
          page: page,
          limit: limit
        }
        api_get("account/sendernames", options)
      end

      def users(page: nil, limit: nil)
        options = {
          page: page,
          limit: limit
        }
        api_get("account/users", options)
      end

      private

      def_delegators :@config, :api_key, :sender_name

      BASE_URI = "http://api.semaphore.co/api/v4/"

      def api_post(uri, params = {})
        handle_errors do
          resp = Curl.post("#{BASE_URI}#{uri}", params.merge(apikey: api_key))
          content = JSON.parse(resp.body_str)[0].symbolize_keys
          Response.new(content[:status], content)
        end
      end

      def api_get(uri, params = {})
        handle_errors do
          resp = Curl.post("#{BASE_URI}#{uri}", params.merge(apikey: api_key))
          content = JSON.parse(resp.body_str)[0].symbolize_keys
          Response.new(content[:status], content)
        end
      end

      def handle_errors
        begin
          yield
        rescue => e
          Response.new(:error, { error: e.message })
        end
      end
    end
  end
end