Sha256: 90623cd0f5c39bc475ac4aef6c009d85bebdd0eb4616331d6a10959f2a446a70
Contents?: true
Size: 1.93 KB
Versions: 14
Compression:
Stored size: 1.93 KB
Contents
require 'blather/client/client'
require 'blather/client/dsl'
module DaemonKit
# Thin wrapper around the blather DSL
class XMPP
include ::Blather::DSL
class << self
def run( &block )
DaemonKit.trap('INT') { ::EM.stop }
DaemonKit.trap('TERM') { ::EM.stop }
DaemonKit::EM.run {
xmpp = new
xmpp.instance_eval( &block )
xmpp.run
}
end
end
def initialize
@config = DaemonKit::Config.load('xmpp')
if @config.enable_logging
Blather.logger = DaemonKit.logger
end
jid = if @config.resource
"#{@config.jabber_id}/#{@config.resource}"
else
@config.jabber_id
end
setup jid, @config.password
when_ready do
configure_roster!
become_available
end
return if @config['require_master'] == false
message do |m|
trusted?( m ) ? pass : halt
end
end
def configure_roster!
DaemonKit.logger.debug 'Configuring roster'
my_roster.each do |(jid, item)|
unless contacts.include?( jid )
DaemonKit.logger.debug "Removing #{jid} from roster"
my_roster.delete( item.jid )
next
end
end
contacts.each do |jid|
DaemonKit.logger.debug "Adding #{jid} to roster"
my_roster.add( Blather::JID.new( jid ) )
end
my_roster.each do |(jid,item)|
item.subscription = :both
item.ask = :subscribe
end
end
def become_available
set_status( :chat, "#{DaemonKit.configuration.daemon_name} is available" )
end
def trusted?( message )
@config.masters.include?( message.from.stripped.to_s )
end
def contacts
@config.masters + @config.supporters
end
def run
client.run
end
def busy( message = nil, &block )
set_status( :dnd, message )
block.call
become_available
end
end
end
Version data entries
14 entries across 14 versions & 3 rubygems