Class: DaemonKit::XMPP

Inherits:
Object show all
Includes:
Blather::DSL
Defined in:
lib/daemon_kit/xmpp.rb

Overview

Thin wrapper around the blather DSL

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ XMPP

Returns a new instance of XMPP.



24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
 
# File 'lib/daemon_kit/xmpp.rb', line 24

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

Class Method Details

.run(&block) ⇒ Object 



11
12
13
14
15
16
17
18
19
20
21
 
# File 'lib/daemon_kit/xmpp.rb', line 11

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

Instance Method Details

#become_available ⇒ Object 



75
76
77
 
# File 'lib/daemon_kit/xmpp.rb', line 75

def become_available
  set_status( :chat, "#{DaemonKit.configuration.daemon_name} is available" )
end

#busy(message = nil, &block) ⇒ Object 



91
92
93
94
95
96
97
 
# File 'lib/daemon_kit/xmpp.rb', line 91

def busy( message = nil, &block )
  set_status( :dnd, message )

  block.call

  become_available
end

#configure_roster! ⇒ Object 



51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
 
# File 'lib/daemon_kit/xmpp.rb', line 51

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

#contacts ⇒ Object 



83
84
85
 
# File 'lib/daemon_kit/xmpp.rb', line 83

def contacts
  @config.masters + @config.supporters
end

#run ⇒ Object 



87
88
89
 
# File 'lib/daemon_kit/xmpp.rb', line 87

def run
  client.run
end

#trusted?(message) ⇒ Boolean

Returns:

  • (Boolean) 


79
80
81
 
# File 'lib/daemon_kit/xmpp.rb', line 79

def trusted?( message )
  @config.masters.include?( message.from.stripped.to_s )
end