mirror of
https://github.com/chatmail/core.git
synced 2026-05-16 21:36:30 +03:00
python: Wait for initial Resync in the bot tests
This commit is contained in:
@@ -24,6 +24,8 @@ def test_echo_quit_plugin(acfactory, lp):
|
|||||||
lp.sec("creating a temp account to contact the bot")
|
lp.sec("creating a temp account to contact the bot")
|
||||||
(ac1,) = acfactory.get_online_accounts(1)
|
(ac1,) = acfactory.get_online_accounts(1)
|
||||||
|
|
||||||
|
botproc.await_resync()
|
||||||
|
|
||||||
lp.sec("sending a message to the bot")
|
lp.sec("sending a message to the bot")
|
||||||
bot_contact = ac1.create_contact(botproc.addr)
|
bot_contact = ac1.create_contact(botproc.addr)
|
||||||
bot_chat = bot_contact.create_chat()
|
bot_chat = bot_contact.create_chat()
|
||||||
@@ -40,7 +42,7 @@ def test_echo_quit_plugin(acfactory, lp):
|
|||||||
|
|
||||||
def test_group_tracking_plugin(acfactory, lp):
|
def test_group_tracking_plugin(acfactory, lp):
|
||||||
lp.sec("creating one group-tracking bot and two temp accounts")
|
lp.sec("creating one group-tracking bot and two temp accounts")
|
||||||
botproc = acfactory.run_bot_process(group_tracking, ffi=False)
|
botproc = acfactory.run_bot_process(group_tracking)
|
||||||
|
|
||||||
ac1, ac2 = acfactory.get_online_accounts(2)
|
ac1, ac2 = acfactory.get_online_accounts(2)
|
||||||
|
|
||||||
@@ -52,6 +54,8 @@ def test_group_tracking_plugin(acfactory, lp):
|
|||||||
ac1.add_account_plugin(FFIEventLogger(ac1))
|
ac1.add_account_plugin(FFIEventLogger(ac1))
|
||||||
ac2.add_account_plugin(FFIEventLogger(ac2))
|
ac2.add_account_plugin(FFIEventLogger(ac2))
|
||||||
|
|
||||||
|
botproc.await_resync()
|
||||||
|
|
||||||
lp.sec("creating bot test group with bot")
|
lp.sec("creating bot test group with bot")
|
||||||
bot_contact = ac1.create_contact(botproc.addr)
|
bot_contact = ac1.create_contact(botproc.addr)
|
||||||
ch = ac1.create_group_chat("bot test group")
|
ch = ac1.create_group_chat("bot test group")
|
||||||
|
|||||||
@@ -676,6 +676,13 @@ class BotProcess:
|
|||||||
print("+++IGN:", line)
|
print("+++IGN:", line)
|
||||||
ignored.append(line)
|
ignored.append(line)
|
||||||
|
|
||||||
|
def await_resync(self):
|
||||||
|
self.fnmatch_lines(
|
||||||
|
"""
|
||||||
|
*Resync: collected * message IDs in folder INBOX*
|
||||||
|
""",
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
@pytest.fixture()
|
@pytest.fixture()
|
||||||
def tmp_db_path(tmpdir):
|
def tmp_db_path(tmpdir):
|
||||||
|
|||||||
Reference in New Issue
Block a user