mirror of
https://github.com/correl/SleekXMPP.git
synced 2024-12-18 03:00:18 +00:00
My hunch is that these should also be updated.
This commit is contained in:
parent
da332365d4
commit
c3be6ea0b2
4 changed files with 4 additions and 4 deletions
|
@ -33,7 +33,7 @@ class testps(sleekxmpp.ClientXMPP):
|
||||||
self.node = "pstestnode_%s"
|
self.node = "pstestnode_%s"
|
||||||
self.pshost = pshost
|
self.pshost = pshost
|
||||||
if pshost is None:
|
if pshost is None:
|
||||||
self.pshost = self.server
|
self.pshost = self.boundjid.host
|
||||||
self.nodenum = int(nodenum)
|
self.nodenum = int(nodenum)
|
||||||
self.leafnode = self.nodenum + 1
|
self.leafnode = self.nodenum + 1
|
||||||
self.collectnode = self.nodenum + 2
|
self.collectnode = self.nodenum + 2
|
||||||
|
|
|
@ -164,7 +164,7 @@ class ClientXMPP(BaseXMPP):
|
||||||
log.debug("Since no address is supplied," + \
|
log.debug("Since no address is supplied," + \
|
||||||
"attempting SRV lookup.")
|
"attempting SRV lookup.")
|
||||||
try:
|
try:
|
||||||
xmpp_srv = "_xmpp-client._tcp.%s" % self.server
|
xmpp_srv = "_xmpp-client._tcp.%s" % self.boundjid.host
|
||||||
answers = dns.resolver.query(xmpp_srv, dns.rdatatype.SRV)
|
answers = dns.resolver.query(xmpp_srv, dns.rdatatype.SRV)
|
||||||
except (dns.resolver.NXDOMAIN, dns.resolver.NoAnswer):
|
except (dns.resolver.NXDOMAIN, dns.resolver.NoAnswer):
|
||||||
log.debug("No appropriate SRV record found." + \
|
log.debug("No appropriate SRV record found." + \
|
||||||
|
|
|
@ -36,7 +36,7 @@ class xep_0078(base.base_plugin):
|
||||||
log.debug("Starting jabber:iq:auth Authentication")
|
log.debug("Starting jabber:iq:auth Authentication")
|
||||||
auth_request = self.xmpp.makeIqGet()
|
auth_request = self.xmpp.makeIqGet()
|
||||||
auth_request_query = ET.Element('{jabber:iq:auth}query')
|
auth_request_query = ET.Element('{jabber:iq:auth}query')
|
||||||
auth_request.attrib['to'] = self.xmpp.server
|
auth_request.attrib['to'] = self.xmpp.boundjid.host
|
||||||
username = ET.Element('username')
|
username = ET.Element('username')
|
||||||
username.text = self.xmpp.username
|
username.text = self.xmpp.username
|
||||||
auth_request_query.append(username)
|
auth_request_query.append(username)
|
||||||
|
|
|
@ -33,7 +33,7 @@ class xep_0199(base.base_plugin):
|
||||||
|
|
||||||
def scheduled_ping(self):
|
def scheduled_ping(self):
|
||||||
log.debug("pinging...")
|
log.debug("pinging...")
|
||||||
if self.sendPing(self.xmpp.server, self.config.get('timeout', 30)) is False:
|
if self.sendPing(self.xmpp.boundjid.host, self.config.get('timeout', 30)) is False:
|
||||||
log.debug("Did not recieve ping back in time. Requesting Reconnect.")
|
log.debug("Did not recieve ping back in time. Requesting Reconnect.")
|
||||||
self.xmpp.reconnect()
|
self.xmpp.reconnect()
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue