UNC-Libraries/hy-c

# frozen_string_literal: true
class IngestFromFtpController < ApplicationController
  before_action :ensure_admin!
  layout 'hyrax/dashboard'

  def list_packages
    add_breadcrumb t(:'hyrax.controls.home'), root_path
    add_breadcrumb t(:'hyrax.dashboard.breadcrumbs.admin'), hyrax.dashboard_path
    add_breadcrumb 'Ingest From FTP', request.path

    @package_results = build_package_listing
    @needs_revision_flag = needs_revision_flag?
  end

  def ingest_packages
    selected_filenames = params[:selected_filenames]
    if selected_filenames.blank?
      flash[:alert] = 'No packages were chosen'
      redirect_to ingest_from_ftp_path(source: source)
      return
    end
    selected_filepaths = list_selected_package_paths(selected_filenames)
    # Prepopulate statuses for packages so we can immediately view a report
    ingest_status_service.initialize_statuses(selected_filepaths.map { |f| File.basename(f) })
    if source == 'proquest'
      IngestFromProquestJob.perform_later(user_id, selected_filepaths)
    else
      IngestFromSageJob.perform_later(user_id, selected_filepaths)
    end
    redirect_to ingest_from_ftp_status_path(source: source)
  end

  def view_status
    add_breadcrumb t(:'hyrax.controls.home'), root_path
    add_breadcrumb t(:'hyrax.dashboard.breadcrumbs.admin'), hyrax.dashboard_path
    add_breadcrumb 'Ingest From FTP', ingest_from_ftp_path
    add_breadcrumb 'Ingest status', request.path
    statuses = ingest_status_service.load_statuses || {}
    @status_results = statuses.sort.to_h
  end

  def delete_packages
    selected_filenames = params[:selected_filenames]
    if selected_filenames.blank?
      flash[:alert] = 'No packages were chosen'
      redirect_to ingest_from_ftp_path(source: source)
      return
    end
    list_selected_package_paths(selected_filenames).each do |package_path|
      File.delete(package_path)
    end
    redirect_to ingest_from_ftp_path(source: source)
  end

  private

  def list_package_files
    Dir[File.join(storage_base_path, '*.zip')]
  end

  def list_selected_package_paths(selected_filenames)
    selected_package_paths = []
    list_package_files.each do |package_path|
      if selected_filenames.any? { |filename| File.basename(package_path) == filename }
        selected_package_paths << package_path
      end
    end
    selected_package_paths
  end

  def build_package_listing
    package_results = []
    list_package_files.each do |filename|
      result = {
        filename: File.basename(filename),
        last_modified: File.ctime(filename)
      }
      result[:is_revision] = is_revision?(filename) if needs_revision_flag?
      package_results << result
    end
    package_results.sort_by { |result| result[:filename] }
  end

  def source
    @source ||= params[:source].blank? ? 'proquest' : params[:source]
  end

  def ingest_status_service
    @ingest_status_service ||= Tasks::IngestStatusService.status_service_for_source(source)
  end

  def storage_base_path
    if source == 'proquest'
      base_path = ENV['INGEST_PROQUEST_PATH']
    else
      base_path = ENV['INGEST_SAGE_PATH']
    end
  end

  def needs_revision_flag?
    @needs_flag ||= source == 'sage'
  end

  def is_revision?(filename)
    File.basename(filename).match?(/\.r[0-9]{4}-[0-9]{2}-[0-9]{2}/)
  end

  def user_id
    current_ability.current_user.uid
  end

  def ensure_admin!
    authorize! :read, :admin_dashboard
  end
end