Contents

class Eye::Notify
  include Celluloid
  include Eye::Logger::Helpers
  extend Eye::Dsl::Validation

  autoload :Mail,     'eye/notify/mail'
  autoload :Jabber,   'eye/notify/jabber'

  TYPES = {:mail => "Mail", :jabber => "Jabber"}

  def self.get_class(type)
    klass = eval("Eye::Notify::#{TYPES[type]}") rescue nil
    raise "Unknown notify #{type}" unless klass
    klass
  end

  def self.validate!(options)
    get_class(options[:type]).validate(options)
  end

  def self.notify(contact, message_h)
    settings = Eye::Control.settings
    needed_hash = (settings[:contacts] || {})[contact.to_s]

    return if needed_hash.blank?

    create_proc = lambda do |nh|
      type = nh[:type]
      config = (settings[type] || {}).merge(nh[:opts] || {}).merge(:contact => nh[:contact])
      klass = get_class(type)
      notify = klass.new(config, message_h)
      notify.async_notify if notify
    end

    if needed_hash.is_a?(Array)
      needed_hash.each{|nh| create_proc[nh] }
    else
      create_proc[needed_hash]
    end
  end

  TIMEOUT = 1.minute

  def initialize(options = {}, message_h = {})
    @logger = Eye::Logger.new("#{self.class.name.downcase} - #{options[:contact]}")
    debug "created notifier #{options}"

    @message_h = message_h
    @options = options
  end

  def async_notify
    async.notify
    after(TIMEOUT){ terminate }
  end

  def notify
    debug "start notify #{@message_h}"
    execute
    debug "end notify #{@message_h}"
    terminate
  end

  def execute
    raise "realize me"
  end

  param :contact, [String]

  def message_subject
    "[#{msg_host}] [#{msg_full_name}] #{msg_message}"
  end
  
  def message_body
    "#{message_subject} at #{msg_at.to_s(:short)}"
  end

private

  %w{at host message name full_name pid level}.each do |name|
    define_method("msg_#{name}") do
      @message_h[name.to_sym]
    end
  end

end

Version data entries

4 entries across 4 versions & 2 rubygems

Version	Path
reel-eye-0.3.2	lib/eye/notify.rb
eye-0.3.2	lib/eye/notify.rb
reel-eye-0.3.1	lib/eye/notify.rb
eye-0.3.1	lib/eye/notify.rb