本文整理汇总了Python中pyxmpp.jabber.client.JabberClient类的典型用法代码示例。如果您正苦于以下问题：Python JabberClient类的具体用法？Python JabberClient怎么用？Python JabberClient使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了JabberClient类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: __init__
def __init__(self, jid, password, resource='Bot', tls_cacerts=None, server=None, port=5222):
# if bare JID is provided add a resource -- it is required
if isinstance(jid, basestring):
jid = JID(jid)
if not jid.resource:
jid=JID(jid.node, jid.domain, resource)
self.jid = jid
server = server or jid.domain
if tls_cacerts:
if tls_cacerts == 'tls_noverify':
tls_settings = TLSSettings(require = True, verify_peer = False)
else:
tls_settings = TLSSettings(require = True, cacert_file = tls_cacerts)
else:
tls_settings = None
# setup client with provided connection information
# and identity data
JabberClient.__init__(self, jid, password,
disco_name="PyXMPP example: echo bot", disco_type="bot",
server=None, port=None,
tls_settings=tls_settings)
# add the separate components
self.interface_providers = self.get_plugins()
self.loop_tasks = self.get_loop_tasks()
开发者ID:Apkawa，项目名称:nyasha，代码行数:27，代码来源:core.py
示例2: session_started
def session_started(self):
"""This is called when the IM session is successfully started
(after all the neccessery negotiations, authentication and
authorizasion).
That is the best place to setup various handlers for the stream.
Do not forget about calling the session_started() method of the base
class!"""
JabberClient.session_started(self)
# set up handlers for supported <iq/> queries
self.stream.set_iq_get_handler("query","jabber:iq:version",self.get_version)
# set up handlers for <presence/> stanzas
self.stream.set_presence_handler("available",self.presence)
self.stream.set_presence_handler("subscribe",self.presence_control)
self.stream.set_presence_handler("subscribed",self.presence_control)
self.stream.set_presence_handler("unsubscribe",self.presence_control)
self.stream.set_presence_handler("unsubscribed",self.presence_control)
# set up handler for <message stanza>
self.stream.set_message_handler("normal",self.message)
print(self.stream)
print u"joining..."
self.roommgr = MucRoomManager(self.stream)
self.roommgr.set_handlers()
nick = self.jid.node + '-' + self.jid.resource
for loc in options.channels: #['[email protected]','[email protected]']:
roomjid = JID(loc, options.muc)
print("\t %s" % roomjid.as_unicode())
h = RoomHandler()
self.muc.append(h)
mucstate = self.roommgr.join(roomjid, nick, h)
h.assign_state(mucstate)
开发者ID:ManiacTwister，项目名称:dionaea，代码行数:34，代码来源:pg_backend.py
示例3: __init__
def __init__(self, jid, password, server, port=5222, channel=None, tls_cacerts=None, listener=None):
self._jid = jid
self._server = server
self._port = port
self._channel = channel
self._listener = listener
# if bare JID is provided add a resource -- it is required
if not self._jid.resource:
self._jid=JID(self._jid.node, self._jid.domain, "Echobot")
if tls_cacerts:
if tls_cacerts == 'tls_noverify':
tls_settings = TLSSettings(require = True, verify_peer = False)
else:
tls_settings = TLSSettings(require = True, cacert_file = tls_cacerts)
else:
tls_settings = None
# setup client with provided connection information
# and identity data
JabberClient.__init__(self, jid=self._jid, password=password, disco_name="Datenverarbeitungseinheit Z45", disco_type="z45", tls_settings=tls_settings)
'''
JabberClient.__init__(self, jid, password,
disco_name="Datenverarbeitungseinheit Z45", disco_type="z45",
tls_settings = tls_settings)
'''
# add the separate components
self.interface_providers = [
VersionHandler(self),
EchoHandler(self),
]
开发者ID:s0x，项目名称:Z45，代码行数:32，代码来源:xmpp_connection.py
示例4: __init__
def __init__(self, jid, password, obj):
if not jid.resource:
jid = JID(jid.node, jid.domain, "JabberRTC")
tls = TLSSettings(require = True, verify_peer = False)
auth = ['sasl:PLAIN']
JabberClient.__init__(self, jid, password, tls_settings = tls, auth_methods = auth)
self._rtobj = obj
开发者ID:yosuke，项目名称:OpenHRIWeb，代码行数:7，代码来源:JabberRTC.py
示例5: connect
def connect(self):
JabberClient.connect(self)
while not self.isconnected:
stream = self.get_stream()
act = stream.loop_iter(10)
if not act:
self.idle()
开发者ID:StephenGWills，项目名称:OpenSRF，代码行数:7，代码来源:net.py
示例6: session_started
def session_started(self):
"""
Stream-related plugin setup (stanza handler registration, etc).
Send bot presence, set message handler for chat message
and call session_started for all loaded plugins.
"""
JabberClient.session_started(self)
presence = Presence();
presence.set_priority(20);
self.stream.send(presence)
# Set up handlers for supported <iq/> queries
self.stream.set_iq_get_handler('query', 'jabber:iq:version',
self.get_version)
# Set up handlers for <presence/> stanzas
self.stream.set_presence_handler('subscribe', self.presence_control)
self.stream.set_presence_handler('subscribed', self.presence_control)
self.stream.set_presence_handler('unsubscribe', self.presence_control)
self.stream.set_presence_handler('unsubscribed', self.presence_control)
self.stream.set_message_handler("chat", self.message_chat)
self.stream.set_message_handler("normal", self.plugins_message_normal)
for plugin in self.plugins.values():
try:
plugin.session_started(self.stream)
except StandardError:
self.print_exception()
self.logger.info("Plugin call failed")
开发者ID:yetist，项目名称:xmppdog，代码行数:31，代码来源:main.py
示例7: __init__
def __init__(self, *args, **kwargs):
IRCInterface.__init__(self, *args, **kwargs)
self.jid = JID(self.get_config('jid'))
password = self.get_config('pw')
#: If bare JID is provided add a resource -- it is required
if not self.jid.resource:
self.jid = JID(self.jid.node, self.jid.domain, "pyLoad")
if self.get_config('tls'):
tls_settings = streamtls.TLSSettings(require=True, verify_peer=False)
auth = ("sasl:PLAIN", "sasl:DIGEST-MD5")
else:
tls_settings = None
auth = ("sasl:DIGEST-MD5", "digest")
#: Setup client with provided connection information
#: And identity data
JabberClient.__init__(self, self.jid, password,
disco_name="pyLoad XMPP Client", disco_type="bot",
tls_settings=tls_settings, auth_methods=auth)
self.interface_providers = [
VersionHandler(self),
self,
]
开发者ID:OpenMediaVault-Plugin-Developers，项目名称:openmediavault-pyload，代码行数:27，代码来源:XMPPInterface.py
示例8: authorized
def authorized(self) :
JabberClient.authorized(self)
# ########################
self.sendPresence(None)
self.request_roster()
# ########################
evt = IMEvent(self, IM_AUTHORIZED_EVENT)
self.evtHandler.AddPendingEvent(evt)
开发者ID:walker8088，项目名称:easyworld，代码行数:8，代码来源:imclient.py
示例9: session_started
def session_started(self):
"""This is called when the IM session is successfully started
(after all the neccessery negotiations, authentication and
authorizasion).
That is the best place to setup various handlers for the stream.
Do not forget about calling the session_started() method of the base
class!"""
self.request_roster()
JabberClient.session_started(self)
开发者ID:davux，项目名称:Tavu，代码行数:9，代码来源:jabberbot.py
示例10: session_started
def session_started(self):
JabberClient.session_started(self)
self.stream.set_presence_handler(None, self.presence)
self.stream.set_presence_handler("unavailable", self.presence)
self.stream.set_presence_handler("subscribe", self.presence_control)
self.stream.set_presence_handler("subscribed", self.presence_control)
self.stream.set_presence_handler("unsubscribe", self.presence_control)
self.stream.set_presence_handler("unsubscribed", self.presence_control)
self.stream.set_message_handler("normal",self.message)
开发者ID:yosuke，项目名称:OpenHRIWeb，代码行数:9，代码来源:JabberRTC.py
示例11: __init__
def __init__(self, jid, password):
if not jid.resource:
jid=JID(jid.node, jid.domain, "WeiboNotifyRobot")
tls_settings = TLSSettings(require = True, verify_peer = False)
JabberClient.__init__(self, jid, password,
disco_name="Weibo Notify Robot", disco_type="bot",
tls_settings = tls_settings, auth_methods=("sasl:PLAIN",))
开发者ID:squarezhou，项目名称:weibo-notify，代码行数:9，代码来源:notify.py
示例12: _session_started_helper
def _session_started_helper(self,bot,muc_jid):
'''Pass this an instance of your bot (that subclasses MucRoomHandler) and a MUC room JID'''
JabberClient.session_started(self)
self.stream.set_iq_get_handler("query","jabber:iq:version",self.get_version)
self.stream.set_message_handler("normal",self.message)
self.muc_manager = MucRoomManager(self.stream)
self.muc_state = self.muc_manager.join(muc_jid,self.nick,bot,history_maxchars=0)
self.muc_manager.set_handlers()
开发者ID:iferguson90，项目名称:Walrus，代码行数:9，代码来源:mucroombot.py
示例13: __init__
def __init__(self, server_jid):
jid = JID("dummy", server_jid.domain, "GetCert")
tls_settings = TLSSettings(require = True, verify_peer = False)
# setup client with provided connection information
# and identity data
JabberClient.__init__(self, jid, "",
disco_name="PyXMPP example: getcert.py", disco_type="bot",
tls_settings = tls_settings)
开发者ID:AdamPrzybyla，项目名称:pyxmpp，代码行数:10，代码来源:getcert.py
示例14: session_started
def session_started(self):
log("session_started: jid:%s" % (self.jid.as_utf8(),))
self.connection = CONNECTION.connected
JabberClient.session_started(self)
self.stream.set_presence_handler("subscribe", self.subscribe)
self.stream.set_iq_set_handler(
"query", "http://vipadia.com/skype", self.vipadia_iq)
self.slave_online()
开发者ID:Ranushka，项目名称:karaka，代码行数:11，代码来源:slave.py
示例15: __init__
def __init__(self,jid,password,ini):
if not jid.resource:
jid=JID(jid.node,jid.domain,"rbot")
if ini:
self.ini=ini
tls=TLSSettings(require=True,verify_peer=False)
auth=['sasl:PLAIN']
JabberClient.__init__(self,jid,password,disco_name='rbot',disco_type='bot',tls_settings=tls,auth_methods=auth)
self.interface_providers=[VersionHandler(self),EchoHandler(self,ini),]
开发者ID:blueicesir，项目名称:utils，代码行数:12，代码来源:gtalk.py
示例16: __init__
def __init__(self, jid, password):
if not jid.resource:
jid=JID(jid.node, jid.domain, "Bot")
tls_settings = TLSSettings(require = True, verify_peer = False)
JabberClient.__init__(self, jid, password, auth_methods=['sasl:PLAIN'],
disco_name="Pythoner Club", disco_type="bot",
tls_settings = tls_settings)
self.interface_providers = [
DaemonHandler(self),
]
开发者ID:cuimuxi，项目名称:gtalkbot，代码行数:12，代码来源:run.py
示例17: __init__
def __init__(self, jid, password):
# if bare JID is provided add a resource -- it is required
if not jid.resource:
jid=JID(jid.node, jid.domain, "Logger")
# setup client with provided connection information
# and identity data
JabberClient.__init__(self, jid, password,
disco_name="PyXMPP Archiver bot", disco_type="bot")
# register features to be announced via Service Discovery
self.disco_info.add_feature("jabber:iq:version")
开发者ID:pontus，项目名称:jabber-logger，代码行数:13，代码来源:jabber-logger.py
示例18: __init__
def __init__(self, jid, password):
if not jid.resource:
jid=JID(jid.node, jid.domain, "WeiboNotifyRobot")
tls_settings = TLSSettings(require = True, verify_peer = False)
JabberClient.__init__(self, jid, password,
disco_name="Weibo Notify Robot", disco_type="bot",
tls_settings = tls_settings, auth_methods=("sasl:PLAIN",))
# add the separate components
self.interface_providers = [
CommandHandler(self),
]
开发者ID:squarezhou，项目名称:weibo-notify，代码行数:14，代码来源:robot.py
示例19: __init__
def __init__(self, jid, passwd,to_jid, message_list):
"""message_list is a list of tuples of strings, each tuple is a
sentence and it's expected reply
"""
self.messages = message_list
self.to_jid = JID(to_jid)
jid_ = JID(jid)
self.fail_count = 0
if not jid_.resource:
jid_ = JID(jid_.node, jid_.domain, "Mibot")
JabberClient.__init__(self, jid_, passwd)
self.send_next = True
self.failed_messages = []
开发者ID:dgsuarez，项目名称:jabbs，代码行数:14，代码来源:clienttester.py
示例20: __init__
def __init__(self, config):
self.config = config
self.connection = CONNECTION.idle
self.running = True
self.jid = JID("%[email protected]%s/%s" % (config.register, config.domain, config.register))
log("register: jid:%s" % (self.jid.as_utf8(),))
tls = streamtls.TLSSettings(require=True, verify_peer=False)
auth = [ 'digest' ]
JabberClient.__init__(self, self.jid, self.config.secret,
disco_name="Vipadia Skype Gateway Register", disco_type="bot",
tls_settings=tls, auth_methods=auth)
开发者ID:mor1，项目名称:karaka，代码行数:14，代码来源:register.py
注：本文中的pyxmpp.jabber.client.JabberClient类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论