forked from sch/Slixfeed
b1a1955545
Fix ping functionality when activated as component (thank you Guus and MattJ). Add initial code for XEP-0060: Publish-Subscribe. Fix case-sensitivity with setting keys sent in-chat-command (Thank you mirux)
96 lines
3 KiB
Python
96 lines
3 KiB
Python
#!/usr/bin/env python3
|
|
# -*- coding: utf-8 -*-
|
|
|
|
"""
|
|
|
|
FIXME
|
|
|
|
Message from OpenFire server log.
|
|
|
|
2024.03.12 14:21:22.518 ERROR [nioEventLoopGroup-3-2]: org.jivesoftware.openfire.IQRouter - Unable to process a stanza that has no 'from' attribute, addressed to a remote entity. Stanza is being dropped: <iq id="8e4e60ae0d894b40a2fc465268d46d0b" type="get" to="rss.simon.goodbytes.im"><ping xmlns="urn:xmpp:ping"></ping></iq>
|
|
|
|
|
|
TODO
|
|
|
|
1) Check interval, and if no connection is establish after 30 seconds
|
|
then disconnect and reconnect again.
|
|
|
|
2) or Check ping, and if no ping is received after 30 seconds then
|
|
disconnect and try to reconnect again.
|
|
|
|
"""
|
|
|
|
import asyncio
|
|
from slixfeed.config import get_value
|
|
from slixfeed.dt import current_time
|
|
from slixmpp.exceptions import IqTimeout, IqError
|
|
from time import sleep
|
|
import logging
|
|
|
|
|
|
class XmppConnect:
|
|
|
|
|
|
async def ping(self, jid=None):
|
|
"""
|
|
Check for ping and disconnect if no ping has been received.
|
|
|
|
Parameters
|
|
----------
|
|
jid : str, optional
|
|
Jabber ID. The default is None.
|
|
|
|
Returns
|
|
-------
|
|
None.
|
|
|
|
"""
|
|
jid_from = str(self.boundjid) if self.is_component else None
|
|
if not jid:
|
|
jid = self.boundjid.bare
|
|
while True:
|
|
rtt = None
|
|
try:
|
|
rtt = await self['xep_0199'].ping(jid,
|
|
ifrom=jid_from,
|
|
timeout=10)
|
|
logging.info('Success! RTT: %s', rtt)
|
|
except IqError as e:
|
|
logging.error('Error pinging %s: %s', jid,
|
|
e.iq['error']['condition'])
|
|
except IqTimeout:
|
|
logging.warning('No response from %s', jid)
|
|
if not rtt:
|
|
logging.warning('Disconnecting...')
|
|
self.disconnect()
|
|
break
|
|
await asyncio.sleep(60 * 1)
|
|
|
|
|
|
def recover(self, message):
|
|
logging.warning(message)
|
|
print(current_time(), message, 'Attempting to reconnect.')
|
|
self.connection_attempts += 1
|
|
# if self.connection_attempts <= self.max_connection_attempts:
|
|
# self.reconnect(wait=5.0) # wait a bit before attempting to reconnect
|
|
# else:
|
|
# print(current_time(),"Maximum connection attempts exceeded.")
|
|
# logging.error("Maximum connection attempts exceeded.")
|
|
print(current_time(), 'Attempt number', self.connection_attempts)
|
|
seconds = self.reconnect_timeout or 30
|
|
seconds = int(seconds)
|
|
print(current_time(), 'Next attempt within', seconds, 'seconds')
|
|
# NOTE asyncio.sleep doesn't interval as expected
|
|
# await asyncio.sleep(seconds)
|
|
sleep(seconds)
|
|
self.reconnect(wait=5.0)
|
|
|
|
|
|
def inspect(self):
|
|
print('Disconnected\n'
|
|
'Reconnecting...')
|
|
try:
|
|
self.reconnect
|
|
except:
|
|
self.disconnect()
|
|
print('Problem reconnecting')
|