require 'hitimes'
require 'json'
require 'mongo'
require 'yaml'

module Rack
  class Mole
    
    # Initialize The Mole rack component. It is recommended that you specify at a minimum a user_key to track
    # interactions on a per user basis. If you wish to use the mole for the same application in different 
    # environments you should set the environment attribute RAILS_ENV for example. The perf_threshold setting 
    # is also recommended to get performance notifications should your web app start sucking. 
    # By default your app will be moleable upon installation and you should see mole features spewing out in your 
    # logs. This is the default setting. Alternatively you can store mole information in a mongo database by 
    # specifying a different store option.
    #
    # === Options
    #
    # :config_file    :: This option will load rackamole options from a file versus individual options. 
    #                    You can leverage yaml and erb with the current rackamole context to specify each of
    #                    the following options but within a yaml file. This gives more flexibility to customize
    #                    the rack component for specific environment. You can specify the :environment option or
    #                    the default will be development.
    # :app_name       :: The name of the application (Default: Moled App)
    # :log_level      :: Rackamole logger level. (Default: info )
    # :environment    :: The environment for the application ie :environment => RAILS_ENV
    # :perf_threshold :: Any request taking longer than this value will get moled. Default: 10secs
    # :moleable       :: Enable/Disable the MOle (Default:true)
    # :store          :: The storage instance ie log file or mongodb [Default:stdout]
    # :expiration     :: Number of seconds to alert expiration. The mole will not keep sending alert if a particular
    #                    mole type has been reported in the past. This threshold specifies the limit at which
    #                    the previously sent alerts will expire and thus will be sent again. 
    #                    For instance, it might be the case that the app is consistently slow for a particular action.
    #                    On the first encounter an alert will be sent ( if configured ). Any subsequent requests for this action
    #                    will not fire an alert until the expiration threshold is hit. The default is 1 hour. 
    #                    Setting this threshold to Rackamole::Stash::Collector::NEVER will result in alerts being fired continually.
    # :user_key       :: If sessions are enable, this represents the session key for the user name or 
    #                    user_id.
    # ==
    #  If the username resides in the session hash with key :user_name the you can use:
    #    :user_key => :user_name
    #  Or you can eval it on the fly - though this will be much slower and not recommended
    #    :user_key => { :session_key => :user_id, :extractor => lambda{ |id| User.find( id ).name} }
    # ==
    #
    # :excluded_paths:: Exclude paths that you do not wish to mole by specifying an array of regular expresssions.
    # :twitter       :: Set this option to have the mole twitt certain alerts. You must configure your twitter auth 
    #                   via the :username and :password keys and :alert_on with an array of mole types you
    #                   wish to be notified on.
    # ==
    #   :twitter => { :username => 'fred', :password => 'blee', :alert_on => [Rackamole.perf, Rackamole.fault] }
    # ==
    # ==== BOZO! currently there is not support for throttling or monitoring these alerts. 
    # ==
    # :email        :: The mole can be configured to send out emails bases on interesting mole features.
    #                  This feature uses actionmailer. You must specify a hash with the following keys :from, :to 
    #                  and :alert_on options to indicate which mole type your wish to be alerted on.
    # ==
    #   :email => { :from => 'fred@acme.com', :to => ['blee@acme.com', 'doh@acme.com'], :alert_on => [Rackamole.perf, Rackamole.fault]  }
    # ==
    #
    def initialize( app, opts={} )    
      @app       = app
      init_options( opts )
      validate_options
      @logger = Rackamole::Logger.new( :logger_name => 'RACKAMOLE', :log_level => options[:log_level] )
    end
          
    # Entering the MOle zone...
    # Watches incoming requests and report usage information. The mole will also track request that
    # are taking longer than expected and also report any requests that are raising exceptions. 
    def call( env )      
      # Bail if application is not moleable
      return @app.call( env ) unless moleable?
                  
      @stash = env['mole.stash'] if env['mole.stash']      
      @stash = Rackamole::Stash::Collector.new( options[:app_name], options[:environment], options[:expiration] ) unless stash
            
      status, headers, body = nil
      elapsed = Hitimes::Interval.measure do
        begin
          status, headers, body = @app.call( env )
        rescue => boom
          env['mole.exception'] = boom
          mole_feature( env, elapsed, status, headers, body )
          raise boom
        end
      end
      mole_feature( env, elapsed, status, headers, body )
      return status, headers, body
    end 

  # ===========================================================================  
  private
       
    attr_reader :options, :logger, :stash #:nodoc:
        
    # Load up configuration options
    def init_options( opts )
      if opts[:config_file] && (env = opts[:environment] || "development")
        raise "Unable to find rackamole config file #{opts[:config_file]}" unless ::File.exists?( opts[:config_file] )
        begin
          opts = YAML.load( ERB.new( IO.read( opts[:config_file] ) ).result( binding ) )[env]
          opts[:environment] = env
        rescue => boom
          raise "Unable to parse Rackamole config file #{boom}"
        end        
      end      
      @options = default_options.merge( opts )
    end
    
    # Mole default options
    def default_options
      { 
        :moleable        =>  true,    
        :log_level       =>  :info,
        :expiration      =>  60*60, # 1 hour    
        :app_name        =>  "Moled App",
        :environment     =>  'development',
        :excluded_paths  =>  [/.?\.ico/, /.?\.png/],
        :perf_threshold  =>  10.0,
        :store           =>  Rackamole::Store::Log.new
      }
    end
           
    # Validates all configured options... Throws error if invalid configuration
    def validate_options
      return unless options[:moleable]
      
      %w[app_name environment perf_threshold store].each do |k|
        raise "[M()le] -- Unable to locate required option key `#{k}" unless options[k.to_sym]
      end
      
      # Barf early if something is wrong in the configuration
      configured?( :twitter, [:username, :password, :alert_on], true )
      configured?( :email  , [:from, :to, :alert_on], true )
    end
    
    # Send moled info to store and potentially send out alerts...
    def mole_feature( env, elapsed, status, headers, body )   
      env['mole.stash'] = stash
      
      attrs = mole_info( env, elapsed, status, headers, body )

      # If nothing to mole bail out!
      return if attrs.empty?

      # send info to configured store
      options[:store].mole( attrs )
      
      # Check for dups. If we've logged this req before don't log it again...
      unless duplicated?( env, attrs )
        # send email alert ?
        if alertable?( :email, attrs[:type] )
          logger.debug ">>> Sending out email on mole type #{attrs[:type]} to #{options[:email][:to].join( ", ")}"
          Rackamole::Alert::Emole.deliver_alert( options[:email][:from], options[:email][:to], attrs ) 
        end
      
        # send twitter alert ?
        if alertable?( :twitter, attrs[:type] )
          logger.debug ">>> Sending out twitt on mole type #{attrs[:type]} on @#{options[:twitter][:username]}"
          Rackamole::Alert::Twitt.deliver_alert( options[:twitter][:username], options[:twitter][:password], attrs )
        end
      end
    rescue => boom
      logger.error "!! MOLE RECORDING CRAPPED OUT !! -- #{boom}"
      boom.backtrace.each { |l| logger.error l }
    end
    
    # Check if we've already seen such an error
    def duplicated?( env, attrs )
      # Skip features for now...
      return true if attrs[:type] == Rackamole.feature
      
      # Don't bother if expiration is set to never. ie fire alerts all the time
      return false if options[:expiration] == Rackamole::Stash::Collector::NEVER
      
      now    = Time.now
      app_id = [attrs[:app_name], attrs[:environment]].join( '_' )
      path   = attrs[:route_info] ? "#{attrs[:route_info][:controller]}#{attrs[:route_info][:action]}" : attrs[:path]      
                        
      # Check expired entries
      stash.expire!
      
      # check if we've seen this error before. If so stash it.
      if attrs[:type] == Rackamole.fault
        return stash.stash_fault( path, attrs[:stack].first, now.utc )
      end
      
      # Check if we've seen this perf issue before. If so stash it
      if attrs[:type] == Rackamole.perf
        return stash.stash_perf( path, attrs[:request_time], now.utc )
      end      
    end
    
    # Check if an options is set and configured
    def configured?( key, configs, optional=true )
      return false if optional and !options.has_key?(key)
      raise "Missing option key :#{key}" unless options.has_key?(key)
      configs.each do |c|
        raise "Invalid value for option :#{key}. Expecting a hash with symbols [#{configs.join(',')}]" unless options[key].respond_to? :key?
        unless options[key].key?(c)
          raise "Option :#{key} is not properly configured. Missing #{c.inspect} in [#{options[key].keys.sort{|a,b| a.to_s <=> b.to_s}.join(',')}]"
        end
      end
      true
    end
    
    # Check if feature should be send to alert clients ie email or twitter
    def alertable?( filter, type )
      return false unless configured?( filter, [:alert_on] )
      return false unless options[filter][:alert_on]
      options[filter][:alert_on].include?( type )
    end
            
    # Check if this request should be moled according to the exclude filters        
    def mole_request?( request )
      options[:excluded_paths].each do |exclude_path|
        return false if request.path.match( exclude_path )
      end
      true
    end
    
    # Extract interesting information from the request
    def mole_info( env, elapsed, status, headers, body )      
      request = Rack::Request.new( env )
      info    = OrderedHash.new
                           
      return info unless mole_request?( request )
                        
      session     = env['rack.session']      
      route       = get_route( request )

      ip, user_agent = identify( env )
      user_id        = nil
      user_name      = nil
           
      # BOZO !! This could be slow if have to query db to get user name...
      # Preferred store username in session and give at key
      user_key = options[:user_key]
      if session and user_key
        if user_key.instance_of? Hash
          user_id  = session[ user_key[:session_key] ]
          if user_key[:extractor]
            user_name = user_key[:extractor].call( user_id )
          end
        else
          user_name = session[user_key]
        end
      end
          
      info[:type]         = (elapsed and elapsed > options[:perf_threshold] ? Rackamole.perf : Rackamole.feature)
      info[:app_name]     = options[:app_name]
      info[:environment]  = options[:environment] || "Unknown"
      info[:user_id]      = user_id      if user_id
      info[:user_name]    = user_name || "Unknown"
      info[:ip]           = ip
      info[:browser]      = id_browser( user_agent )
      info[:host]         = env['SERVER_NAME']
      info[:software]     = env['SERVER_SOFTWARE']
      info[:request_time] = elapsed if elapsed
      info[:url]          = request.url
      info[:method]       = env['REQUEST_METHOD']
      info[:path]         = request.path
      info[:route_info]   = route if route
      info[:created_at]   = Time.now.utc
      
      # Dump request params
      unless request.params.empty?
        info[:params] = OrderedHash.new
        request.params.keys.sort.each { |k| info[:params][k.to_sym] = request.params[k].to_json }
      end
            
      # Dump session var
      if session and !session.empty?
        info[:session] = OrderedHash.new 
        session.keys.sort{ |a,b| a.to_s <=> b.to_s }.each { |k| info[:session][k.to_sym] = session[k].to_json }
      end
      
      # Check if an exception was raised. If so consume it and clear state
      exception = env['mole.exception']
      if exception
        info[:ruby_version]   = %x[ruby -v]
        info[:fault]          = exception.to_s
        info[:stack]          = trim_stack( exception )
        info[:type]           = Rackamole.fault
        env['mole.exception'] = nil
      end      
      info
    end
        
    # Attempts to detect browser type from agent info.
    # BOZO !! Probably more efficient way to do this...
    def browser_types() @browsers ||= [ 'Firefox', 'Safari', 'MSIE 8.0', 'MSIE 7.0', 'MSIE 6.0', 'Opera', 'Chrome' ] end
      
    def id_browser( user_agent )
      return "N/A" if !user_agent or user_agent.empty?
      browser_types.each do |b|
        return b if user_agent.match( /.*?#{b.gsub(/\./,'\.')}.*?/ )
      end
      "N/A"
    end
    
    # Trim stack trace
    def trim_stack( boom )
      boom.backtrace[0...4]
    end

    # Identify request ie ip and browser configuration   
    def identify( request_env )
      return request_env['HTTP_X_FORWARDED_FOR'] || request_env['REMOTE_ADDR'], request_env['HTTP_USER_AGENT']
    end
            
    # Checks if this application is moleable
    def moleable?
      options[:moleable]
    end
    
    # Fetch route info if any...
    def get_route( request )
      return nil unless defined?( RAILS_ENV )
      # Check for invalid route exception...
      begin
        return ::ActionController::Routing::Routes.recognize_path( request.path, {:method => request.request_method.downcase.to_sym } )
      rescue => boom      
        return nil
      end
    end
    
    # Debug - Dump env to stdout
    def dump( env, level=0 )
      env.keys.sort{ |a,b| a.to_s <=> b.to_s }.each do |k|
        value = env[k]
        if value.respond_to?(:each_pair) 
          puts "%s %-#{40-level}s" % ['  '*level,k]
          dump( env[k], level+1 )
        elsif value.instance_of?(::ActionController::Request) or value.instance_of?(::ActionController::Response) 
          puts "%s %-#{40-level}s %s" % [ '  '*level, k, value.class ]
        else
          puts "%s %-#{40-level}s %s" % [ '  '*level, k, value.inspect ]
        end        
      end
    end
  end
end