# frozen_string_literal: true

require "tempfile"
module DocomoNlu
  module Management
    class OKNGBase < Base
      class_attribute :extention

      def save
        self.class.create(attributes[:file], prefix_options)
      end

      def destroy
        super
      end

      def download
        self.file = self.class.download(prefix_options).file
      end

      class << self
        def create(file, prefix_options)
          check_prefix_options(prefix_options)
          raise ActiveResource::BadRequest, "" if file.nil?

          upload(file, prefix_options)
        end

        def all(options = {})
          find(options)
        end

        def find(options)
          prefix_options, = split_options(options[:params])
          check_prefix_options(prefix_options)
          download(prefix_options)
        end

        def where(clauses = {})
          find(params: clauses)
        end

        def download(prefix_options = {})
          conn = Faraday.new(url: site.to_s, ssl: { verify: false }) do |builder|
            builder.adapter :net_http
          end
          conn.headers["Authorization"] = access_token

          response = conn.get(element_path(nil, prefix_options))

          if check_response(response)
            return instantiate_record({}, prefix_options).tap do |record|
              record.file = Tempfile.open(["docomo-nlu", extention]) do |f|
                f.write response.body.force_encoding("UTF-8")
                f
              end
            end
          end
          nil
        end

        def upload(file, prefix_options)
          conn = Faraday.new(url: site.to_s, ssl: { verify: false }) do |builder|
            builder.request :multipart
            builder.request :url_encoded
            builder.adapter :net_http
          end
          conn.headers["Authorization"] = access_token
          params = {
            uploadFile: Faraday::UploadIO.new(file.path, "text/plain"),
          }
          response = conn.put collection_path(prefix_options), params
          check_response(response)
        end
      end
    end
  end
end