require 'active_support'
require 'active_support/version'
%w{
  active_support/core_ext/array/conversions
  active_support/core_ext/string/access
  active_support/core_ext/string/multibyte
}.each do |active_support_3_requirement|
  require active_support_3_requirement
end if ActiveSupport::VERSION::MAJOR == 3

require 'active_record'
require 'blockenspiel'
require 'conversions'
require 'remote_table'
require 'errata'
require 'andand'
require 'log4r'
require 'fileutils'
require 'tmpdir'
require 'amatch'

require 'data_miner/attribute'
require 'data_miner/configuration'
require 'data_miner/dictionary'
require 'data_miner/import'
require 'data_miner/process'
require 'data_miner/clone'
require 'data_miner/run'

module DataMiner
  class MissingHashColumn < RuntimeError; end
  
  mattr_accessor :logger
  
  def self.start_logging
    return if logger

    if defined? Rails
      self.logger = Rails.logger
    else
      class_eval { include Log4r }
      info_outputter = FileOutputter.new 'f1', :filename => 'data_miner.log'
      error_outputter = Outputter.stderr
      info_outputter.only_at DEBUG, INFO
      error_outputter.only_at WARN, ERROR, FATAL
      
      self.logger = Logger.new 'data_miner'
      logger.add info_outputter, error_outputter
      ActiveRecord::Base.logger = logger
    end
  end
  
  def self.log_or_raise(message)
    message = "[data_miner gem] #{message}"
    if ENV['RAILS_ENV'] == 'production' or ENV['DONT_RAISE'] == 'true'
      logger.error message
    else
      raise message
    end
  end
  
  def self.log_info(message)
    logger.info "[data_miner gem] #{message}"
  end
  
  def self.run(options = {})
    DataMiner::Configuration.run options
  end
  
  def self.resource_names
    DataMiner::Configuration.resource_names
  end
end

ActiveRecord::Base.class_eval do
  # convenience
  %w{
    create_table
    execute
    add_column
    rename_column
    remove_column
    drop_table
  }.each do |method_name|
    eval %{
      def self.#{method_name}(*args, &block)
        ActiveRecord::Base.connection.send(:#{method_name}, *args, &block)
      end
    }
  end
  
  def self.x_data_miner(&block)
    DataMiner.start_logging
    
    DataMiner.log_info "Skipping data_miner block in #{self.name} because called as x_data_miner"
  end
  
  def self.data_miner(&block)
    DataMiner.start_logging
    
    DataMiner.log_info "Database table `#{table_name}` doesn't exist. It might be created in the data_miner block, but if it's not, DataMiner probably won't work properly until you run a migration or otherwise fix the schema." unless table_exists?
    
    DataMiner.resource_names.push self.name unless DataMiner.resource_names.include? self.name

    belongs_to :data_miner_last_run, :class_name => 'DataMiner::Run'
    
    # this is class_eval'ed here so that each ActiveRecord descendant has its own copy, or none at all
    class_eval do
      cattr_accessor :data_miner_config
      def self.data_miner_runs
        DataMiner::Run.scoped :conditions => { :resource_name => name }
      end
      def self.run_data_miner!(options = {})
        data_miner_config.run options
      end
    end
    self.data_miner_config = DataMiner::Configuration.new self

    Blockenspiel.invoke block, data_miner_config
    
    data_miner_config.after_invoke
  end
end