module Appstats
  class ResultJob < ActiveRecord::Base
    set_table_name "appstats_result_jobs"
    establish_connection "appstats_#{Rails.env}" if configurations.keys.include?("appstats_#{Rails.env}")

    attr_accessible :name, :frequency, :status, :query, :last_run_at, :query_type

    @@frequency_methods = 

    def should_run
      return true if frequency == "once" && last_run_at.nil?
      period = { "daily" => :beginning_of_day, "weekly" => :beginning_of_week, "monthly" => :beginning_of_month, "quarterly" => :beginning_of_quarter, "yearly" => :beginning_of_year }[frequency]
      return false if period.nil?
      return true if last_run_at.nil?
      last_run_at.send(period) <= (Time.now.send(period) - 1.day).send(period)
    end

    def ==(o)
      o.class == self.class && o.send(:state) == state
    end
    alias_method :eql?, :==

    def self.require_third_party_queries(queries)
      if queries.nil?
        Appstats.log(:info, "No third party query provided.")
        return
      end
      queries.each do |q|
        if q[:path].nil?
          Appstats.log(:info, "Please specify the third party query ':path'.")
          next
        end
        unless File.exists?(q[:path])
          Appstats.log(:info, "Unable to find third party query [#{q[:path]}].")
          next
        end
        
        Appstats.log(:info, "Loaded to third party query [#{q[:path]}].")
        require q[:path]
      end
      
    end

    def self.run
      count = 0
      all = Appstats.rails3? ? ResultJob.where("frequency <> 'once' or last_run_at IS NULL").all : ResultJob.find(:all, :conditions => "frequency <> 'once' or last_run_at IS NULL")
      if all.size == 0
        Appstats.log(:info, "No result jobs to run.")
        return count
      end
      Appstats.log(:info, "About to analyze #{all.size} result job(s).")
      all.each do |job|
        if job.should_run
          Appstats.log(:info, "  - Job #{job.name} run [ID #{job.id}, FREQUENCY #{job.frequency}, QUERY #{job.query}]")
          query = Appstats::Query.new(:name => job.name, :result_type => "result_job", :query => job.query, :query_type => job.query_type)
          query.run
          job.last_run_at = Time.now
          job.save
          count += 1
        else
          Appstats.log(:info, "  - Job #{job.name} NOT run [ID #{job.id}, FREQUENCY #{job.frequency}, QUERY #{job.query}]")
        end
      end
      Appstats.log(:info, "Ran #{count} query(ies).")
      count
    end

    private

      def state
        [name, frequency, status, query, last_run_at]
      end

    
  end
end