Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-05-19 14:56:33 +03:00
Code Issues Packages Projects Releases Wiki Activity

feat(deltachat-rpc-client): add Account.wait_for_incoming_msg_event()

Browse Source
This commit is contained in:
link2xt
2023-10-29 21:30:56 +00:00
parent 3876846410
commit 22b6d8c17b
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
deltachat-rpc-client/src/deltachat_rpc_client/account.py
View File

@@ -4,7 +4,7 @@ from warnings import warn
from ._utils import AttrDict from ._utils import AttrDict
from .chat import Chat from .chat import Chat
from .const import ChatlistFlag, ContactFlag, SpecialContactId from .const import ChatlistFlag, ContactFlag, SpecialContactId, EventType
from .contact import Contact from .contact import Contact
from .message import Message from .message import Message
@@ -250,6 +250,13 @@ class Account:
next_msg_ids = self._rpc.wait_next_msgs(self.id) next_msg_ids = self._rpc.wait_next_msgs(self.id)
return [Message(self, msg_id) for msg_id in next_msg_ids] return [Message(self, msg_id) for msg_id in next_msg_ids]
def wait_for_incoming_msg_event(self):
"""Wait for incoming message event and return it."""
while True:
event = self.wait_for_event()
if event.kind == EventType.INCOMING_MSG:
return event
def get_fresh_messages_in_arrival_order(self) -> List[Message]: def get_fresh_messages_in_arrival_order(self) -> List[Message]:
"""Return fresh messages list sorted in the order of their arrival, with ascending IDs.""" """Return fresh messages list sorted in the order of their arrival, with ascending IDs."""
warn( warn(