misc: wrap some calls in ensure_future to prepare for slix API change

Some things need to be rewritten in a cleaner way, and other need to be
directly deleted, but that will need to wait for the slix api change
merge.
This commit is contained in:
mathieui 2021-02-27 11:09:38 +01:00
parent 49820f1460
commit 2d1bf7b1dd
3 changed files with 11 additions and 3 deletions

View file

@ -621,7 +621,9 @@ class Core:
else: else:
self.do_command(''.join(char_list), True) self.do_command(''.join(char_list), True)
if self.status.show not in ('xa', 'away'): if self.status.show not in ('xa', 'away'):
self.xmpp.plugin['xep_0319'].idle() asyncio.ensure_future(
self.xmpp.plugin['xep_0319'].idle()
)
self.doupdate() self.doupdate()
def save_config(self): def save_config(self):

View file

@ -5,6 +5,7 @@ upstream.
TODO: Check that they are fixed and remove those hacks TODO: Check that they are fixed and remove those hacks
""" """
import asyncio
from typing import Callable, Any from typing import Callable, Any
from slixmpp import Message, Iq, ClientXMPP from slixmpp import Message, Iq, ClientXMPP
from slixmpp.xmlstream import ET from slixmpp.xmlstream import ET
@ -23,7 +24,9 @@ def has_identity(xmpp, jid, identity, on_true=None, on_false=None):
if not res and on_false is not None: if not res and on_false is not None:
on_false() on_false()
xmpp.plugin['xep_0030'].get_info(jid=jid, callback=_cb) asyncio.ensure_future(
xmpp.plugin['xep_0030'].get_info(jid=jid, callback=_cb)
)
def _filter_add_receipt_request(self, stanza): def _filter_add_receipt_request(self, stanza):

View file

@ -12,6 +12,7 @@ slix plugin
from __future__ import annotations from __future__ import annotations
import asyncio
from xml.etree import ElementTree as ET from xml.etree import ElementTree as ET
from typing import ( from typing import (
Optional, Optional,
@ -118,7 +119,9 @@ def join_groupchat(
xmpp.plugin['xep_0045'].rooms[jid] = {} xmpp.plugin['xep_0045'].rooms[jid] = {}
xmpp.plugin['xep_0045'].our_nicks[jid] = to.resource xmpp.plugin['xep_0045'].our_nicks[jid] = to.resource
xmpp.plugin['xep_0030'].get_info(jid=jid, callback=on_disco) asyncio.ensure_future(
xmpp.plugin['xep_0030'].get_info(jid=jid, callback=on_disco)
)
def leave_groupchat( def leave_groupchat(