X-Git-Url: https://git.notmuchmail.org/git?p=notmuch;a=blobdiff_plain;f=bindings%2Fpython%2Fnotmuch%2Fquery.py;h=06c7b11bb8648de7488092c6c2d63efed3e13bf0;hp=94773ac508e37c6cfcd7fd68293fd637e08d3199;hb=3721bd45d72e50436ee760b03ae533d49bbb8724;hpb=f5db7ad7d243785c274a99734c681e69d13313d0 diff --git a/bindings/python/notmuch/query.py b/bindings/python/notmuch/query.py index 94773ac5..06c7b11b 100644 --- a/bindings/python/notmuch/query.py +++ b/bindings/python/notmuch/query.py @@ -12,12 +12,12 @@ FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License -along with notmuch. If not, see . +along with notmuch. If not, see . Copyright 2010 Sebastian Spaeth """ -from ctypes import c_char_p, c_uint +from ctypes import c_char_p, c_uint, POINTER, byref from .globals import ( nmlib, Enum, @@ -28,6 +28,7 @@ from .globals import ( NotmuchMessagesP, ) from .errors import ( + NotmuchError, NullPointerError, NotInitializedError, ) @@ -135,8 +136,8 @@ class Query(object): """notmuch_query_search_threads""" _search_threads = nmlib.notmuch_query_search_threads - _search_threads.argtypes = [NotmuchQueryP] - _search_threads.restype = NotmuchThreadsP + _search_threads.argtypes = [NotmuchQueryP, POINTER(NotmuchThreadsP)] + _search_threads.restype = c_uint def search_threads(self): """Execute a query for threads @@ -153,16 +154,19 @@ class Query(object): :raises: :exc:`NullPointerError` if search_threads failed """ self._assert_query_is_initialized() - threads_p = Query._search_threads(self._query) + threads_p = NotmuchThreadsP() # == NULL + status = Query._search_threads(self._query, byref(threads_p)) + if status != 0: + raise NotmuchError(status) if not threads_p: raise NullPointerError return Threads(threads_p, self) - """notmuch_query_search_messages""" + """notmuch_query_search_messages_st""" _search_messages = nmlib.notmuch_query_search_messages - _search_messages.argtypes = [NotmuchQueryP] - _search_messages.restype = NotmuchMessagesP + _search_messages.argtypes = [NotmuchQueryP, POINTER(NotmuchMessagesP)] + _search_messages.restype = c_uint def search_messages(self): """Filter messages according to the query and return @@ -172,14 +176,17 @@ class Query(object): :raises: :exc:`NullPointerError` if search_messages failed """ self._assert_query_is_initialized() - msgs_p = Query._search_messages(self._query) + msgs_p = NotmuchMessagesP() # == NULL + status = Query._search_messages(self._query, byref(msgs_p)) + if status != 0: + raise NotmuchError(status) if not msgs_p: raise NullPointerError return Messages(msgs_p, self) _count_messages = nmlib.notmuch_query_count_messages - _count_messages.argtypes = [NotmuchQueryP] + _count_messages.argtypes = [NotmuchQueryP, POINTER(c_uint)] _count_messages.restype = c_uint def count_messages(self): @@ -191,10 +198,14 @@ class Query(object): :rtype: int ''' self._assert_query_is_initialized() - return Query._count_messages(self._query) + count = c_uint(0) + status = Query._count_messages(self._query, byref(count)) + if status != 0: + raise NotmuchError(status) + return count.value _count_threads = nmlib.notmuch_query_count_threads - _count_threads.argtypes = [NotmuchQueryP] + _count_threads.argtypes = [NotmuchQueryP, POINTER(c_uint)] _count_threads.restype = c_uint def count_threads(self): @@ -210,7 +221,11 @@ class Query(object): :rtype: int ''' self._assert_query_is_initialized() - return Query._count_threads(self._query) + count = c_uint(0) + status = Query._count_threads(self._query, byref(count)) + if status != 0: + raise NotmuchError(status) + return count.value _destroy = nmlib.notmuch_query_destroy _destroy.argtypes = [NotmuchQueryP]