github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 06:37:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

- style fixes

Browse source
This commit is contained in:
Jordan Sissel 2011-08-15 02:01:56 -07:00
parent c53a6432ea
commit 971c1c5edc
1 changed files with 42 additions and 41 deletions
Download patch file Download diff file Expand all files Collapse all files

83
lib/logstash/inputs/xmpp.rb
View file

@ -5,60 +5,61 @@ class LogStash::Inputs::Xmpp < LogStash::Inputs::Base
config_name "xmpp"
# user's id: foo@example.com
# The user or resource ID, like foo@example.com.
config :jid, :validate => :string, :required => :true
# password
config :pass, :validate => :string, :required => :true
# The xmpp password for the JID.
config :password, :validate => :password, :required => :true
# if muc/multi-user-chat required, pass the name of the room: room@conference.domain/nick
# if muc/multi-user-chat required, give the name of the room that
# you want to join: room@conference.domain/nick
config :rooms, :validate => :array
# The server to connect to. This is optional. If you omit this setting, the
# host on the JID is used. (foo.com for user@foo.com)
config :server, :validate => :string
# The xmpp server to connect to. This is optional. If you omit this setting,
# the host on the JID is used. (foo.com for user@foo.com)
config :host, :validate => :string
# Set to true to enable greater debugging in XMPP. Useful for debugging
# network/authentication erros.
config :debug, :validate => :boolean, :default => false
public
def register
require 'xmpp4r' # xmpp4r gem
Jabber::debug = true if @debug
def register
require 'xmpp4r' # xmpp4r gem
Jabber::debug = true if @debug
@cl = Jabber::Client.new(Jabber::JID.new(@jid))
@cl.connect(@server) # ok if @server is nill
@cl.auth(@pass)
@cl.send(Jabber::Presence.new.set_type(:available))
if @rooms
require 'xmpp4r/muc/helper/simplemucclient' # xmpp4r muc helper
@client = Jabber::Client.new(Jabber::JID.new(@jid))
@client.connect(@host) # it is ok if host is nil
@client.auth(@password.value)
@client.send(Jabber::Presence.new.set_type(:available))
# load the MUC Client if we are joining rooms.
require 'xmpp4r/muc/helper/simplemucclient' if @rooms && !@rooms.empty?
end # def register
public
def run(queue)
if @rooms
@rooms.each do |room| # handle muc messages in different rooms
@muc = Jabber::MUC::SimpleMUCClient.new(@client)
@muc.join(room)
@muc.on_message do |time,from,body|
e = to_event(body, "#{room}/#{from}")
queue << e if e
end # @muc.on_message
end # @rooms.each
end # if @rooms
@client.add_message_callback do |msg| # handle direct/private messages
source = "xmpp://#{msg.from.node}@#{msg.from.domain}/#{msg.from.resource}"
# accept normal msgs (skip presence updates, etc)
if msg.body != nil
e = to_event(msg.body, source)
queue << e
end
end # def register
def run(queue)
if @rooms
@rooms.each do |room| # handle muc messages in different rooms
@muc = Jabber::MUC::SimpleMUCClient.new(@cl)
@muc.join(room)
@muc.on_message { |time,from,body|
e = to_event(body, "#{room}/#{from}")
if e
queue << e
end
}
end
end
@cl.add_message_callback { |msg| # handle direct/private messages
source = "xmpp://#{msg.from.node}@#{msg.from.domain}/#{msg.from.resource}"
# accept normal msgs (skip presence updates, etc)
e = to_event(msg.body, source) unless msg.body == nil
if e
queue << e
end
}
end # def run
end # @client.add_message_callback
end # def run
end # def class LogStash:Inputs::Xmpp