module RubyBranch
  module API
    module Resources
      class Link

        LINK_LENGTH_LIMIT = 2000

        def create_safely(analytics: {}, data: {}, settings: {})
          build(analytics: analytics, data: data, settings: settings)
        rescue Errors::LinkLengthExceedError
          create(analytics: analytics, data: data, settings: settings)
        end

        def update_safely(url:, analytics: {}, data: {}, settings: {})
          build(analytics: analytics, data: data, settings: settings)
        rescue Errors::LinkLengthExceedError
          update(url: url, analytics: analytics, data: data, settings: settings)
        end

        def create(analytics: {}, data: {}, settings: {})
          request_body = build_request_body(analytics, settings, data)
          response = do_create_request(request_body)

          return response.json[:url] if response.success?

          process_error(response)

          RubyBranch.config.link_to_homepage if RubyBranch.config.link_to_homepage
        end

        def update(url:, analytics: {}, data: {}, settings: {})
          request_body = build_request_body(analytics, settings, data)
          response = do_update_request(url, request_body)

          return true if response.success?

          process_error(response)
          false
        end

        def delete(url:)
          response = do_delete_request(url)

          return true if response.success?

          process_error(response)
          false
        end

        def build(analytics: {}, data: {}, settings: {})
          params = {}
          params.merge!(prepare_analytics(analytics))
          params.merge!(prepare_settings(settings))
          params.merge!(data)

          link = Addressable::URI.new(
            scheme: 'https',
            host: RubyBranch.config.branch_domain,
            path: "/a/#{RubyBranch.config.api_key}",
            query: ToQuery.call(params)
          ).to_s
          check_for_link_length_limit(link)
          link
        end

        private

        def do_create_request(request_body)
          request = Request.new
          request.post('v1/url', request_body.to_json)
        end

        def do_update_request(url, request_body)
          request = Request.new
          request.put("v1/url?url=#{url}", request_body.to_json)
        end

        def do_delete_request(url)
          request = Request.new
          request.delete("v1/url?url=#{url}")
        end

        def build_request_body(analytics, settings, data)
          body = { branch_key: RubyBranch.config.api_key, branch_secret: RubyBranch.config.secret_key }
          body.merge! prepare_analytics(analytics)
          body.merge! prepare_settings(settings)
          body.merge! prepare_data(data)
        end

        def prepare_data(data)
          { data: data }
        end

        def prepare_analytics(analytics)
          allowed_params = %i[channel feature campaign stage tags]
          analytics.reject { |k, v| !allowed_params.include?(k) || v.nil? }
        end

        def prepare_settings(settings)
          allowed_params = %i[alias type duration identity]
          settings.reject { |k, v| !allowed_params.include?(k) || v.nil? }
        end

        def check_for_link_length_limit(link)
          raise Errors::LinkLengthExceedError if link.size > LINK_LENGTH_LIMIT
        end

        def process_error(response)
          error_attrs = { status: response.status, body: response.body }
          if defined?(Bugsnag) && defined?(Rails) && Rails.env.production?
            Bugsnag.notify(Errors::ApiResponseError.new, error_attrs)
          end
        end

      end
    end
  end
end