# frozen_string_literal: true

module Workato
  module CLI
    class SchemaCommand
      include Thor::Shell

      SAMPLE_TO_SCHEMA_SUPPORT_TYPES = %w[csv json].freeze
      CSV_SEPARATORS = %w[comma space tab colon semicolon pipe].freeze

      WORKATO_BASE_URL = ENV['WORKATO_BASE_URL'] || 'https://app.workato.com'
      API_GENERATE_SCHEMA_PATH = '/api/sdk/generate_schema'

      def initialize(options:)
        @api_email = options[:api_email] || ENV[Workato::Connector::Sdk::WORKATO_API_EMAIL_ENV]
        @api_token = options[:api_token] || ENV[Workato::Connector::Sdk::WORKATO_API_TOKEN_ENV]
        @options = options
      end

      def call
        if verbose?
          say('INPUT')
          say sample[:sample]
        end

        schema = sample_to_schema(sample)

        say('SCHEMA') if verbose?
        jj schema
      end

      private

      attr_reader :options,
                  :api_token,
                  :api_email

      def verbose?
        @options[:verbose]
      end

      def sample
        return @sample if @sample

        @sample = if options[:json]
                    { sample: File.read(options[:json]), type: :json }
                  elsif options[:csv]
                    { sample: File.read(options[:csv]), type: :csv, col_sep: options[:col_sep] }
                  else
                    { sample: {}, type: :json }
                  end
      end

      def sample_to_schema(sample)
        url = "#{WORKATO_BASE_URL}#{API_GENERATE_SCHEMA_PATH}/#{sample.delete(:type)}"
        response = RestClient.post(
          url,
          sample.to_json,
          {
            content_type: :json,
            accept: :json
          }.merge(auth_headers)
        )
        JSON.parse(response.body)
      rescue RestClient::ExceptionWithResponse => e
        message = JSON.parse(e.response.body).fetch('message') rescue e.message
        raise "Failed to generate schema: #{message}"
      end

      def auth_headers
        {
          'x-user-email' => api_email,
          'x-user-token' => api_token
        }
      end

      private_constant :API_GENERATE_SCHEMA_PATH,
                       :WORKATO_BASE_URL
    end
  end
end