File: responder.rb

package info (click to toggle)
ruby-xmpp4r 0.5.6-2
  • links: PTS, VCS
  • area: main
  • in suites: bookworm, bullseye, forky, sid, trixie
  • size: 1,384 kB
  • sloc: ruby: 17,382; xml: 74; sh: 12; makefile: 4
file content (53 lines) | stat: -rw-r--r-- 1,342 bytes parent folder | download | duplicates (2)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
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
50
51
52
53
module Jabber

  module Command

    ##
    # The Responder Helper handles the low-level stuff of the
    # Ad-hoc commands (JEP 0050).
    class Responder

      ##
      # Initialize a Responder
      def initialize(stream)
        @stream = stream
        @commandsdiscocbs = CallbackList.new
        @commandexeccbs = CallbackList.new

        stream.add_iq_callback(180, self) { |iq|
          iq_callback(iq)
        }
      end

      ##
      # Add a callback for <query> stanzas asking for the list
      # of ad-hoc commands
      def add_commands_disco_callback(priority = 0, ref = nil, &block)
        @commandsdiscocbs.add(priority, ref, block)
      end

      ##
      # Add a callback for <command> stanzas asking for the execution
      # of an ad-hoc command
      def add_commands_exec_callback(priority = 0, ref = nil, &block)
        @commandexeccbs.add(priority, ref, block)
      end

      ##
      # Handles <iq> stanzas and execute callbacks
      def iq_callback(iq)
        if iq.type == :get
          if iq.query.kind_of?(Jabber::Discovery::IqQueryDiscoItems) &&
             iq.query.node == "http://jabber.org/protocol/commands"
            @commandsdiscocbs.process(iq)
          end
        elsif iq.type == :set && iq.command
          @commandexeccbs.process(iq)
        end
      end

    end

  end

end