require "benchmark"

module ErpTechSvcs
  module Sessions
    # Delayed Job to Reset Daily Assignments to Forecast
    class DeleteExpiredSessionsJob  

      def initialize
        @priority = 1
      end
  
      def perform
        time = Benchmark.measure do
          begin
            process_job
          rescue => exception
            ErpTechSvcs::Util::CompassLogger.delete_expired_sessions_job.error("An unrecoverable error has occured, the job will be rescheduled: #{exception.message} : #{exception.backtrace}")
          end
        end #benchmark
        
        # Run once per day
        date = Date.tomorrow
        start_time = DateTime.civil(date.year, date.month, date.day, 2, 0, 1, -(5.0/24.0))
        
        Delayed::Job.enqueue(DeleteExpiredSessionsJob.new(), @priority, start_time)
        
        #update job tracker
        JobTracker.job_ran('Delete Expired Sessions', self.class.name, ("(%.4fs)" % time.real), start_time)
      end

      def self.schedule_job(schedule_dt)
        Delayed::Job.enqueue(DeleteExpiredSessionsJob.new(), @priority, schedule_dt)
      end

      def process_job
        start_time = Time.now
    
        ErpTechSvcs::Sessions::DeleteExpiredSessionsService.new.execute
    
        end_time = Time.now
    
        return end_time - start_time
      end
  
    end #Close DeleteExpiredSessionsJob
  end #Close Sessions
end #Close ErpTechSvcs