# encoding: utf-8
require 'rest_client'
require 'rack'
require 'ostruct'
require 'json'

module Apiary
  module Command
    # Display preview of local blueprint file
    class Publish

      attr_reader :options

      # TODO: use OpenStruct to store @options
      def initialize(opts)
        @options = OpenStruct.new(opts)
        @options.path           ||= "apiary.apib"
        @options.api_host       ||= "api.apiary.io"
        @options.port           ||= 8080
        @options.api_name       ||= false
        @options.api_key        ||= ENV['APIARY_API_KEY']
        @options.proxy          ||= ENV['http_proxy']
        @options.headers        ||= {
          :accept => "text/html",
          :content_type => "text/plain",
          :authentication => "Token #{@options.api_key}"
        }
        @options.commit_message ||= "Saving blueprint from apiary-client"
      end

      def execute()
        publish_on_apiary
      end

      def publish_on_apiary
        unless @options.api_name
          abort "Please provide an api-name option (subdomain part from your http://docs.<api-name>.apiary.io/)"
        end

        unless @options.api_key
          abort "API key must be provided through environment variable APIARY_API_KEY. Please go to https://login.apiary.io/tokens to obtain it."
        end

        self.query_apiary(@options.api_host, @options.path)

      end

      def validate_apib_file(apib_file)
        unless File.exist?(apib_file)
          abort "Apiary definition file hasn't been found: #{apib_file.inspect}"
        end
      end

      def path
        @options.path || "#{File.basename(Dir.pwd)}.apib"
      end

      def query_apiary(host, path)
        url  = "https://#{host}/blueprint/publish/#{@options.api_name}"
        validate_apib_file path
        data = {
          :code => File.read(path),
          :messageToSave => @options.commit_message
        }
        RestClient.proxy = @options.proxy

        begin
          RestClient.post url, data, @options.headers
        rescue RestClient::BadRequest => e
          err = JSON.parse e.response
          if err.has_key? 'parserError'
            abort "#{err['message']}: #{err['parserError']}"
          else
            abort "Apiary service responded with an error: #{err['message']}"
          end
        rescue RestClient::Exception => e
          abort "Apiary service responded with an error: #{e.message}"
        end
      end

      private
        def api_name
          "-a"
        end

    end
  end
end