Learn more  » Push, build, and install  RubyGems npm packages Python packages Maven artifacts PHP packages Go Modules Bower components Debian packages RPM packages NuGet packages

vistahigherlearning / logstash   deb

Repository URL to install this package:

/ opt / logstash / vendor / bundle / jruby / 1.9 / gems / xmpp4r-0.5 / lib / xmpp4r / roster / iq / roster.rb

# =XMPP4R - XMPP Library for Ruby
# License:: Ruby's license (see the LICENSE file) or GNU GPL, at your option.
# Website::http://home.gna.org/xmpp4r/

require 'xmpp4r/query'

module Jabber
  module Roster
    ##
    # Class for handling roster updates
    #
    # You must do 'client.send(Iq.new_rosterget)' or else you will
    # have nothing to put in receive_iq()
    #
    # You must require 'xmpp4r/rosterquery' to use this class
    # as its functionality is not needed for a working XMPP implementation.
    # This will make [IqQuery] convert all Queries with namespace 'jabber:iq:roster'
    # to [IqQueryRoster]
    #
    # This <query/> contains multiple <item/> children. See RosterItem.
    class IqQueryRoster < IqQuery
      name_xmlns 'query', 'jabber:iq:roster'

      ##
      # Iterate through all items
      # &block:: Yield for every [RosterItem]
      def each(&block)
        each_element { |item|
          # XPath won't work here as it's missing a prefix...
          yield(item) if item.kind_of?(RosterItem)
        }
      end

      ##
      # Get roster item by JID
      # jid:: [JID] or [Nil]
      # result:: [RosterItem]
      def [](jid)
        each { |item|
          return(item) if item.jid == jid
        }
        nil
      end

      ##
      # Get all items
      # result:: [Array] of [RosterItem]
      def to_a
        a = []
        each { |item|
          a.push(item)
        }
        a
      end

      ##
      # Update roster by <iq/> stanza
      # (to be fed by an iq_callback)
      # iq:: [Iq] Containing new roster
      # filter:: [Boolean] If false import non-roster-like results too
      def receive_iq(iq, filter=true)
        if filter && (((iq.type != :set) && (iq.type != :result)) || (iq.queryns != 'jabber:iq:roster'))
          return
        end

        import(iq.query)
      end

      ##
      # Output for "p"
      #
      # JIDs of all contained [RosterItem] elements are joined with a comma
      # result:: [String]
      def inspect
        jids = to_a.collect { |item| item.jid.inspect }
        jids.join(', ')
      end
    end

    ##
    # Class containing the <item/> elements of the roster
    #
    # The 'name' attribute has been renamed to 'iname' here
    # as 'name' is already used by REXML::Element for the
    # element's name. It's still name='...' in XML.
    class RosterItem < XMPPElement
      name_xmlns 'item', 'jabber:iq:roster'

      ##
      # Construct a new roster item
      # jid:: [JID] Jabber ID
      # iname:: [String] Name in the roster
      # subscription:: [Symbol] Type of subscription (see RosterItem#subscription=)
      # ask:: [Symbol] or [Nil] Can be :subscribe
      def initialize(jid=nil, iname=nil, subscription=nil, ask=nil)
        super()
        self.jid = jid
        self.iname = iname
        self.subscription = subscription
        self.ask = ask
      end

      ##
      # Get name of roster item
      #
      # names can be set by the roster's owner himself
      # return:: [String]
      def iname
        attributes['name']
      end

      ##
      # Set name of roster item
      # val:: [String] Name for this item
      def iname=(val)
        attributes['name'] = val
      end

      ##
      # Get JID of roster item
      # Resource of the JID will _not_ be stripped
      # return:: [JID]
      def jid
        (a = attributes['jid']) ? JID.new(a) : nil
      end

      ##
      # Set JID of roster item
      # val:: [JID] or nil
      def jid=(val)
        attributes['jid'] = val.nil? ? nil : val.to_s
      end

      ##
      # Get subscription type of roster item
      # result:: [Symbol] or [Nil] The following values are valid according to RFC3921:
      # * :both
      # * :from
      # * :none
      # * :remove
      # * :to
      def subscription
        case attributes['subscription']
          when 'both' then :both
          when 'from' then :from
          when 'none' then :none
          when 'remove' then :remove
          when 'to' then :to
          else nil
        end
      end

      ##
      # Set subscription type of roster item
      # val:: [Symbol] or [Nil] See subscription for possible Symbols
      def subscription=(val)
        case val
          when :both then attributes['subscription'] = 'both'
          when :from then attributes['subscription'] = 'from'
          when :none then attributes['subscription'] = 'none'
          when :remove then attributes['subscription'] = 'remove'
          when :to then attributes['subscription'] = 'to'
          else attributes['subscription'] = nil
        end
      end

      ##
      # Get if asking for subscription
      # result:: [Symbol] nil or :subscribe
      def ask
        case attributes['ask']
          when 'subscribe' then :subscribe
          else nil
        end
      end

      ##
      # Set if asking for subscription
      # val:: [Symbol] nil or :subscribe
      def ask=(val)
        case val
          when :subscribe then attributes['ask'] = 'subscribe'
          else attributes['ask'] = nil
        end
      end

      ##
      # Get groups the item belongs to
      # result:: [Array] of [String] The groups
      def groups
        result = []
        each_element('group') { |group|
          result.push(group.text)
        }
        result.uniq
      end

      ##
      # Set groups the item belongs to,
      # deletes old groups first.
      #
      # See JEP 0083 for nested groups
      # ary:: [Array] New groups, duplicate values will be removed
      def groups=(ary)
        # Delete old group elements
        delete_elements('group')

        # Add new group elements
        ary.uniq.each { |group|
          add_element('group').text = group
        }
      end
    end
  end #Module Roster
end #Module Jabber