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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
# =XMPP4R - XMPP Library for Ruby
# License:: Ruby's license (see the LICENSE file) or GNU GPL, at your option.
# Website::http://xmpp4r.github.io
require 'xmpp4r/discovery'
module Jabber
module PubSub
class NodeBrowser
##
# Initialize a new NodeBrowser
# new(stream,pubsubservice)
# stream:: [Jabber::Stream]
def initialize(stream)
@stream = stream
end
##
# Retrieve the nodes
# Throws an ServerError when receiving
# <tt><iq type='error'/></tt>
# jid:: [JID] Target entity (set only domain!)
# return:: [Array] of [String] or [nil]
def nodes(jid)
iq = Iq.new(:get,jid)
iq.from = @stream.jid
iq.add(Discovery::IqQueryDiscoItems.new)
nodes = []
@stream.send_with_id(iq) do |answer|
answer.query.each_element('item') { |item|
nodes.push(item.node)
}
end
nodes
end
##
# Retrieve the nodes with names
# Throws a ServerError when receiving
# <tt><iq type='error'/></tt>
# jid:: [Jabber::JID] Target entity (set only domain!)
# return:: [Array] of [Hash] with keys 'node' => [String] and 'name' => [String] or [nil]
def nodes_names(jid)
iq = Iq.new(:get,jid)
iq.from = @stream.jid
iq.add(Discovery::IqQueryDiscoItems.new)
nodes = []
@stream.send_with_id(iq) do |answer|
answer.query.each_element('item') do |item|
nodes.push( {'node' => item.node,'name' => item.iname } )
end
end
nodes
end
##
# Retrieve the items from a node
# Throws an ServerError when receiving
# <tt><iq type='error'/></tt>
# jid:: [Jabber::JID] Target entity (set only domain!)
# node:: [String]
# return:: [Array] of [Hash] with keys 'name' => [String] and 'jid' => [Jabber::JID]
def items(jid,node)
iq = Iq.new(:get,jid)
iq.from = @stream.jid
discoitems = Discovery::IqQueryDiscoItems.new
discoitems.node = node
iq.add(discoitems)
items = []
err = nil
@stream.send_with_id(iq) do |answer|
answer.query.each_element('item') { |item|
items.push( {'jid' => item.jid,'name' => item.iname } )
}
end
items
end
##
# get disco info for a node
# jid:: [Jabber::JID]
# node:: [String]
# return:: [Hash] with possible keys type:: [String] ,category:: [String],features:: [Array] of feature, nodeinformation:: [Jabber::XData]
# check http://www.xmpp.org/extensions/xep-0060.html#entity for more infos
def get_info(jid,node)
iq = Iq.new(:get,jid)
iq.from = @stream.jid
discoinfo = Discovery::IqQueryDiscoInfo.new
discoinfo.node = node
iq.add(discoinfo)
info = {}
@stream.send_with_id(iq) do |answer|
identity = answer.query.identity
info['type'] = identity.type
info['category'] = identity.category
info['features'] = answer.query.features
answer.query.each_element('x') { |x|
info['nodeinformation'] = x
}
end
info
end
# this is only for a xep <-> nodebrowser.rb understanding
alias get_metadata get_info
##
# get type of node
# jid:: [Jabber::JID]
# node:: [String]
#
def type(jid,node)
info = get_info(jid,node)
return info['type']
end
##
# get category of node
# jid:: [Jabber::JID]
# node:: [String]
#
def category(jid,node)
info = get_info(jid,node)
return info['category']
end
end #class
end #module
end #module
|
