Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-04-06 07:32:12 +03:00
Code Issues Packages Projects Releases Wiki Activity

minimal get_next_event api

Browse Source
This commit is contained in:
dignifiedquire
2020-03-22 01:07:06 +01:00
parent 11fa60d690
commit 9b4c195872
6 changed files with 254 additions and 143 deletions
Download Patch File Download Diff File Expand all files Collapse all files

83
python/tests/test_lowlevel.py
View File

@@ -1,5 +1,6 @@
from __future__ import print_function
import threading
import time
from deltachat import capi, cutil, const, set_context_callback, clear_context_callback
from deltachat.capi import ffi
from deltachat.capi import lib
@@ -11,12 +12,27 @@ class EventThread(threading.Thread):
self.dc_context = dc_context
super(EventThread, self).__init__()
self.setDaemon(1)
self._running = True
def run(self):
lib.dc_context_run(self.dc_context)#, lib.py_dc_callback)
lib.dc_context_run(self.dc_context)
while self._running:
if lib.dc_has_next_event(self.dc_context):
event = lib.dc_get_next_event(self.dc_context)
if event != ffi.NULL:
deltachat.py_dc_callback(
self._dc_context,
lib.dc_event_get_id(event),
lib.dc_event_get_data1(event),
lib.dc_event_get_data2(event)
)
lib.dc_event_unref(event)
else:
time.sleep(0.05)
def stop(self):
lib.dc_context_shutdown(self.dc_context)
self._running = False
def test_empty_context():
@@ -40,39 +56,41 @@ def test_start_stop_event_thread_basic():
print("4 -- stopping event thread")
ev_thread.stop()
def test_dc_close_events(tmpdir):
ctx = ffi.gc(
capi.lib.dc_context_new(ffi.NULL, ffi.NULL),
lib.dc_context_unref,
)
evlog = EventLogger(ctx)
evlog.set_timeout(5)
set_context_callback(
ctx,
lambda ctx, evt_name, data1, data2: evlog(evt_name, data1, data2)
)
ev_thread = EventThread(ctx)
ev_thread.start()
p = tmpdir.join("hello.db")
lib.dc_open(ctx, p.strpath.encode("ascii"), ffi.NULL)
capi.lib.dc_close(ctx)
# FIXME: EventLogger doesn't work without an account anymore
# def test_dc_close_events(tmpdir):
# ctx = ffi.gc(
# capi.lib.dc_context_new(ffi.NULL, ffi.NULL),
# lib.dc_context_unref,
# )
# evlog = EventLogger(ctx)
# evlog.set_timeout(5)
# set_context_callback(
# ctx,
# lambda ctx, evt_name, data1, data2: evlog(evt_name, data1, data2)
# )
# ev_thread = EventThread(ctx)
# ev_thread.start()
def find(info_string):
while 1:
ev = evlog.get_matching("DC_EVENT_INFO", check_error=False)
data2 = ev[2]
if info_string in data2:
return
else:
print("skipping event", *ev)
# p = tmpdir.join("hello.db")
# lib.dc_open(ctx, p.strpath.encode("ascii"), ffi.NULL)
# capi.lib.dc_close(ctx)
find("disconnecting inbox-thread")
find("disconnecting sentbox-thread")
find("disconnecting mvbox-thread")
find("disconnecting SMTP")
find("Database closed")
ev_thread.stop()
# def find(info_string):
# while 1:
# ev = evlog.get_matching("DC_EVENT_INFO", check_error=False)
# data2 = ev[2]
# if info_string in data2:
# return
# else:
# print("skipping event", *ev)
# find("disconnecting inbox-thread")
# find("disconnecting sentbox-thread")
# find("disconnecting mvbox-thread")
# find("disconnecting SMTP")
# find("Database closed")
# ev_thread.stop()
def test_wrong_db(tmpdir):
@@ -113,6 +131,8 @@ def test_sig():
def test_markseen_invalid_message_ids(acfactory):
ac1 = acfactory.get_configured_offline_account()
ac1.start_threads()
contact1 = ac1.create_contact(email="some1@example.com", name="some1")
chat = ac1.create_chat_by_contact(contact1)
chat.send_text("one messae")
@@ -120,6 +140,7 @@ def test_markseen_invalid_message_ids(acfactory):
msg_ids = [9]
lib.dc_markseen_msgs(ac1._dc_context, msg_ids, len(msg_ids))
ac1._evlogger.ensure_event_not_queued("DC_EVENT_WARNING|DC_EVENT_ERROR")
ac1.stop_threads()
def test_get_special_message_id_returns_empty_message(acfactory):