module DocBase
  class Client
    DEFAULT_URL = 'https://api.docbase.io'
    USER_AGENT = "DocBase Ruby Gem #{DocBase::VERSION}"

    class NotSetTeamError < StandardError; end
    class NotSetPostIdError < StandardError; end

    attr_accessor :team

    def initialize(access_token: nil, url: nil, team: nil)
      @access_token = access_token || ENV['DOCBASE_ACCESS_TOKEN']
      self.team = team
      @url = url || DEFAULT_URL
    end

    def team!
      raise NotSetTeamError unless @team
      @team
    end

    def teams
      connection.get('/teams')
    end

    def users(q: nil, page: 1, per_page: 100, include_user_groups: false)
      connection.get("/teams/#{team!}/users", q: q, page: page, per_page: per_page, include_user_groups: include_user_groups)
    end

    def tags
      connection.get("/teams/#{team!}/tags")
    end

    def groups
      connection.get("/teams/#{team!}/groups")
    end

    def group(id)
      connection.get("/teams/#{team!}/groups/#{id}")
    end

    def create_group(params)
      connection.post("/teams/#{team!}/groups", params)
    end

    def add_users_to_group(params)
      group_id = params[:group_id].to_i
      raise NotSetTeamError if group_id <= 0

      users_params = except(params, :group_id)
      connection.post("/teams/#{team!}/groups/#{group_id}/users", users_params)
    end

    def remove_users_from_group(params)
      group_id = params[:group_id].to_i
      raise NotSetTeamError if group_id <= 0

      users_params = except(params, :group_id)
      connection.delete("/teams/#{team!}/groups/#{group_id}/users", users_params)
    end

    def post(id)
      connection.get("/teams/#{team!}/posts/#{id}")
    end

    def posts(q: '*', page: 1, per_page: 20)
      connection.get("/teams/#{team!}/posts", q: q, page: page, per_page: per_page)
    end

    def create_post(params)
      connection.post("/teams/#{team!}/posts", params)
    end

    def update_post(params)
      post_id = params[:id].to_i
      raise NotSetTeamError if post_id <= 0

      post_params = except(params, :id)
      connection.patch("/teams/#{team!}/posts/#{post_id}", post_params)
    end

    def delete_post(id)
      connection.delete("/teams/#{team!}/posts/#{id}")
    end

    def archive_post(id)
      connection.put("/teams/#{team!}/posts/#{id}/archive")
    end

    def unarchive_post(id)
      connection.put("/teams/#{team!}/posts/#{id}/unarchive")
    end

    def create_comment(params)
      post_id = params[:post_id].to_i
      raise NotSetTeamError if post_id <= 0

      comment_params = except(params, :post_id)
      connection.post("/teams/#{team!}/posts/#{post_id}/comments", params)
    end

    def delete_comment(id)
      connection.delete("/teams/#{team!}/comments/#{id}")
    end

    def upload(paths)
      paths = [paths] unless paths.instance_of?(Array)

      params = paths.map do |path|
        file = File.new(path, 'r+b')
        {
          name: file.path.split('/').last,
          content: Base64.strict_encode64(file.read),
        }
      end

      connection.post("/teams/#{team!}/attachments", params)
    end

    private

    def except(hash, reject_key)
      hash.reject { |key, _| key == reject_key }
    end

    def connection
      @connection ||= Faraday.new({ url: @url, headers: headers }) do |faraday|
        faraday.request :json
        faraday.response :json
        faraday.adapter Faraday.default_adapter
      end
    end

    def headers
      {
        'Accept'         => 'application/json',
        'User-Agent'     => USER_AGENT,
        'X-DocBaseToken' => @access_token,
        'X-Api-Version'  => 1,
      }
    end
  end
end