bikeindex/bike_index

class Admin::BulkImportsController < Admin::BaseController
  include SortableTable
  before_action :set_period, only: [:index]
  before_action :find_bulk_import, only: [:show, :update]

  def index
    page = params[:page] || 1
    @per_page = params[:per_page] || 10
    @org_count = InputNormalizer.boolean(params[:search_org_count])
    @bulk_imports = matching_bulk_imports.includes(:organization, :user, :ownerships)
      .reorder(sort_column + " " + sort_direction)
      .page(page).per(@per_page)
  end

  def show
  end

  def new
    @bulk_import = BulkImport.new(organization_id: current_organization&.id, no_notify: params[:no_notify])
  end

  def update
    if params[:reprocess]
      BulkImportWorker.perform_async(@bulk_import.id)
      flash[:success] = "Bulk Import enqueued for processing"
    else
      flash[:error] = "Ooooops, can't do that, how the hell did you manage to?"
    end
    redirect_to admin_bulk_import_url(@bulk_import)
  end

  def create
    @bulk_import = BulkImport.new(permitted_parameters.merge(user_id: current_user.id))
    if @bulk_import.save
      BulkImportWorker.perform_async(@bulk_import.id)
      flash[:success] = "Bulk Import created!"
      redirect_to admin_bulk_imports_url
    else
      flash[:error] = "Unable to create bulk import"
      render action: :new
    end
  end

  helper_method :matching_bulk_imports

  protected

  def permitted_parameters
    params.require(:bulk_import).permit(:organization_id, :file, :no_notify, :no_duplicate)
  end

  def default_period
    "month"
  end

  def find_bulk_import
    @bulk_import = BulkImport.find(params[:id])
  end

  def sortable_columns
    %w[created_at progress user_id]
  end

  def error_kinds
    %w[file_error line_error no_error ascend_error]
  end

  def matching_bulk_imports
    return @matching_bulk_imports if defined?(@matching_bulk_imports)
    bulk_imports = BulkImport
    if params[:search_ascend].present?
      bulk_imports = bulk_imports.ascend
    elsif params[:search_not_ascend].present?
      bulk_imports = bulk_imports.not_ascend
    end

    if params[:search_errors].present?
      @search_errors = error_kinds.include?(params[:search_errors]) ? params[:search_errors] : "any_error"
      bulk_imports = if params[:search_errors] == "file_error"
        bulk_imports.file_errors
      elsif params[:search_errors] == "line_error"
        bulk_imports.line_errors
      elsif params[:search_errors] == "no_error"
        bulk_imports.no_import_errors
      elsif params[:search_errors] == "ascend_error"
        bulk_imports.ascend_errors
      else
        bulk_imports.import_errors
      end
    end

    if BulkImport.progresses.include?(params[:search_progress])
      @progress = params[:search_progress]
      bulk_imports = bulk_imports.where(progress: @progress)
    else
      @progress = "all"
    end

    if params[:organization_id].present?
      bulk_imports = if current_organization.present?
        bulk_imports.where(organization_id: current_organization.id)
      else
        bulk_imports.where(organization_id: nil)
      end
    end
    @matching_bulk_imports = bulk_imports.where(created_at: @time_range)
  end
end