omu/nokul

# frozen_string_literal: true

module Yoksis
  class ProspectiveStudentsSaveJob < ApplicationJob
    queue_as :high

    def perform(type, year, academic_term: AcademicTerm.current)
      @type          = type
      @year          = year.to_i
      @academic_term = academic_term
      process
    end

    private

    def process(page: 0)
      response = Xokul::Yoksis::Prospectives.all(@type, @year, page: page) || {}

      response.fetch(:data, []).each do |params|
        Actions::ProspectiveStudent::Upsert.call(params.merge(year: @year), academic_term: @academic_term)
      rescue ActiveRecord::RecordInvalid => e
        Rollbar.info(e, job: 'ProspectiveStudentsSaveJob', response: response)
        next
      end

      current_page, total_pages = response.fetch(:meta, {}).values_at(:current_page, :total_pages)

      process(page: current_page + 1) if current_page < total_pages - 1
    end
  end
end