Contents

require 'rubygems'

module Botfly
  class Bot < CommonBlockAcceptor
    attr_reader :client, :roster, :jid, :host    
    def initialize(jid,pass, opts = {})
      super
      Botfly.logger.info("  BOT: Bot#new")
      @password = pass
      @jid = Jabber::JID.new(jid)
      @client = Jabber::Client.new(@jid)
      @main_thread = Thread.current
      if opts[:gtalk]
        @host = "talk.google.com"
      end
    end
    
    def connect
      Botfly.logger.info("  BOT: Connecting to #{@host || @jid}...")
      @client.connect(@host)
      @client.auth(@password)
      @roster = Jabber::Roster::Helper.new(@client)
      Botfly.logger.info("  BOT: Connected")
      register_for_callbacks
      self
    end

    def join(room_name,&block)
      return Botfly::MUCClient.new(room_name,self,&block)
    end

    def quit
      @client.close
      @main_thread.wakeup
    end

    def to_debug_s; "BOT"; end

  private

    def register_for_callbacks
      Botfly.logger.info("  BOT: Registering for callbacks with client")
          # @client.add_update_callback {|presence| respond_to(:update, :presence => presence) }
      @roster.add_subscription_request_callback do |item, pres| # requires Roster helper
        respond_to(:subscription_request, :roster_item => item, :presence => pres)
      end

      @client.add_message_callback do |message|
        respond_to(:message, :message => message)
      end

      @client.add_presence_callback do |new_presence,old_presence|
        respond_to(:preesence, :old_presence => old_presence, :presence => new_presence)
      end

    end
    
    def respond_to(callback_type, params)
      Botfly.logger.info("  BOT: Responding to #{callback_type}")
      @responders[callback_type].each {|r| r.callback_with params} if @responders[callback_type]
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
botfly-0.3.6	lib/botfly/bot.rb
botfly-0.3.5	lib/botfly/bot.rb
botfly-0.3.4	lib/botfly/bot.rb