mirror of
https://git.notmuchmail.org/git/notmuch
synced 2024-11-26 20:57:58 +01:00
273 lines
9.2 KiB
Python
273 lines
9.2 KiB
Python
import ctypes
|
|
from ctypes import c_int, c_char_p, c_void_p
|
|
from cnotmuch.globals import nmlib, STATUS, NotmuchError
|
|
|
|
|
|
class Database(object):
|
|
""" Wrapper around a notmuch_database_t
|
|
|
|
Do note that as soon as we tear down this object, all derived queries,
|
|
threads, and messages will be freed as well.
|
|
"""
|
|
#constants
|
|
MODE_READ_ONLY = 0
|
|
MODE_READ_WRITE = 1
|
|
|
|
_std_db_path = None
|
|
"""Class attribute of users default database"""
|
|
|
|
"""notmuch_database_get_path (notmuch_database_t *database)"""
|
|
_get_path = nmlib.notmuch_database_get_path
|
|
_get_path.restype = c_char_p
|
|
|
|
"""notmuch_database_open (const char *path, notmuch_database_mode_t mode)"""
|
|
_open = nmlib.notmuch_database_open
|
|
_open.restype = c_void_p
|
|
|
|
""" notmuch_database_find_message """
|
|
_find_message = nmlib.notmuch_database_find_message
|
|
_find_message.restype = c_void_p
|
|
|
|
"""notmuch_database_get_all_tags (notmuch_database_t *database)"""
|
|
_get_all_tags = nmlib.notmuch_database_get_all_tags
|
|
_get_all_tags.restype = c_void_p
|
|
|
|
""" notmuch_database_create(const char *path):"""
|
|
_create = nmlib.notmuch_database_create
|
|
_create.restype = c_void_p
|
|
|
|
def __init__(self, path=None, create=False, status= MODE_READ_ONLY):
|
|
""" Open or create a notmuch database
|
|
|
|
If path is None, we will try to read a users notmuch configuration and
|
|
use his default database.
|
|
Throws a NotmuchError in case of failure.
|
|
"""
|
|
self._db = None
|
|
if path is None:
|
|
# no path specified. use a user's default database
|
|
if Database._std_db_path is None:
|
|
#the following line throws a NotmuchError if it fails
|
|
Database._std_db_path = self._get_user_default_db()
|
|
path = Database._std_db_path
|
|
|
|
if create == False:
|
|
self.open(path, status)
|
|
else:
|
|
self.create(path, status)
|
|
|
|
def create(self, path, status=MODE_READ_ONLY):
|
|
""" notmuch_database_create(const char *path)
|
|
|
|
:returns: Raises :exc:`notmuch.NotmuchError` in case
|
|
of any failure (after printing an error message on stderr).
|
|
"""
|
|
res = Database._create(path, status)
|
|
|
|
if res is None:
|
|
raise NotmuchError(
|
|
message="Could not create the specified database")
|
|
self._db = res
|
|
|
|
def open(self, path, status= MODE_READ_ONLY):
|
|
"""calls notmuch_database_open
|
|
|
|
:returns: Raises :exc:`notmuch.NotmuchError` in case
|
|
of any failure (after printing an error message on stderr).
|
|
"""
|
|
res = Database._open(path, status)
|
|
|
|
if res is None:
|
|
raise NotmuchError(
|
|
message="Could not open the specified database")
|
|
self._db = res
|
|
|
|
def get_path(self):
|
|
"""notmuch_database_get_path (notmuch_database_t *database); """
|
|
return Database._get_path(self._db)
|
|
|
|
def find_message(self, msgid):
|
|
"""notmuch_database_find_message
|
|
:param msgid: The message id
|
|
:ptype msgid: string
|
|
|
|
:returns: Message() or None if no message is found or if an
|
|
out-of-memory situation occurs.
|
|
"""
|
|
if self._db is None:
|
|
raise NotmuchError(STATUS.NOT_INITIALIZED)
|
|
msg_p = Database._find_message(self._db, msgid)
|
|
if msg_p is None:
|
|
return None
|
|
return Message(msg_p, self)
|
|
|
|
def get_all_tags(self):
|
|
"""Return a Tags() object (list of all tags found in the database)
|
|
|
|
:returns: Tags() object or raises :exc:`NotmuchError` with
|
|
STATUS.NULL_POINTER on error
|
|
"""
|
|
if self._db is None:
|
|
raise NotmuchError(STATUS.NOT_INITIALIZED)
|
|
|
|
tags_p = Database._get_all_tags (self._db)
|
|
if tags_p == None:
|
|
raise NotmuchError(STATUS.NULL_POINTER)
|
|
return Tags(tags_p, self)
|
|
|
|
def __repr__(self):
|
|
return "'Notmuch DB " + self.get_path() + "'"
|
|
|
|
def __del__(self):
|
|
"""Close and free the notmuch database if needed"""
|
|
if self._db is not None:
|
|
print("Freeing the database now")
|
|
nmlib.notmuch_database_close(self._db)
|
|
|
|
def _get_user_default_db(self):
|
|
""" Reads a user's notmuch config and returns his db location
|
|
|
|
Throws a NotmuchError if it cannot find it"""
|
|
from ConfigParser import SafeConfigParser
|
|
import os.path
|
|
config = SafeConfigParser()
|
|
config.read(os.path.expanduser('~/.notmuch-config'))
|
|
if not config.has_option('database','path'):
|
|
raise NotmuchError(message=
|
|
"No DB path specified and no user default found")
|
|
return config.get('database','path')
|
|
|
|
@property
|
|
def db_p(self):
|
|
"""Returns a pointer to the current notmuch_database_t or None"""
|
|
return self._db
|
|
|
|
#------------------------------------------------------------------------------
|
|
class Query(object):
|
|
""" Wrapper around a notmuch_query_t
|
|
|
|
Do note that as soon as we tear down this object, all derived
|
|
threads, and messages will be freed as well.
|
|
"""
|
|
def __init__(self, db, querystr):
|
|
pass
|
|
|
|
#------------------------------------------------------------------------------
|
|
class Tags(object):
|
|
"""Wrapper around notmuch_tags_t"""
|
|
|
|
#notmuch_tags_get
|
|
_get = nmlib.notmuch_tags_get
|
|
_get.restype = c_char_p
|
|
|
|
def __init__(self, tags_p, db=None):
|
|
"""
|
|
msg_p is a pointer to an notmuch_message_t Structure. If it is None,
|
|
we will raise an NotmuchError(STATUS.NULL_POINTER).
|
|
|
|
Is passed the db these tags are derived from, and saves a
|
|
reference to it, so we can automatically delete the db object
|
|
once all derived objects are dead.
|
|
|
|
Tags() provides an iterator over all contained tags. However, you will
|
|
only be able to iterate over the Tags once, because the underlying C
|
|
function only allows iterating once.
|
|
#TODO: make the iterator work more than once and cache the tags in
|
|
the Python object.
|
|
"""
|
|
if tags_p is None:
|
|
NotmuchError(STATUS.NULL_POINTER)
|
|
|
|
self._tags = tags_p
|
|
self._db = db
|
|
print "Inited Tags derived from %s" %(str(db))
|
|
|
|
def __iter__(self):
|
|
""" Make Tags an iterator """
|
|
return self
|
|
|
|
def next(self):
|
|
if self._tags is None:
|
|
raise StopIteration
|
|
nmlib.notmuch_tags_move_to_next(self._tags)
|
|
if not nmlib.notmuch_tags_valid(self._tags):
|
|
print("Freeing the Tags now")
|
|
nmlib.notmuch_tags_destroy (self._tags)
|
|
raise StopIteration
|
|
return Tags._get (self._tags)
|
|
|
|
def __del__(self):
|
|
"""Close and free the notmuch tags"""
|
|
if self._tags is not None:
|
|
print("Freeing the Tags now")
|
|
nmlib.notmuch_tags_destroy (self._tags)
|
|
|
|
#------------------------------------------------------------------------------
|
|
class Message(object):
|
|
"""Wrapper around notmuch_message_t"""
|
|
|
|
"""notmuch_message_get_filename (notmuch_message_t *message)"""
|
|
_get_filename = nmlib.notmuch_message_get_filename
|
|
_get_filename.restype = c_char_p
|
|
"""notmuch_message_get_message_id (notmuch_message_t *message)"""
|
|
_get_message_id = nmlib.notmuch_message_get_message_id
|
|
_get_message_id.restype = c_char_p
|
|
|
|
"""notmuch_message_get_tags (notmuch_message_t *message)"""
|
|
_get_tags = nmlib.notmuch_message_get_tags
|
|
_get_tags.restype = c_void_p
|
|
|
|
def __init__(self, msg_p, parent=None):
|
|
"""
|
|
msg_p is a pointer to an notmuch_message_t Structure. If it is None,
|
|
we will raise an NotmuchError(STATUS.NULL_POINTER).
|
|
|
|
Is a 'parent' object is passed which this message is derived from,
|
|
we save a reference to it, so we can automatically delete the parent
|
|
object once all derived objects are dead.
|
|
"""
|
|
if msg_p is None:
|
|
NotmuchError(STATUS.NULL_POINTER)
|
|
self._msg = msg_p
|
|
self._parent = parent
|
|
print "Inited Message derived from %s" %(str(parent))
|
|
|
|
|
|
def get_message_id(self):
|
|
""" return the msg id
|
|
|
|
Raises NotmuchError(STATUS.NOT_INITIALIZED) if not inited
|
|
"""
|
|
if self._msg is None:
|
|
raise NotmuchError(STATUS.NOT_INITIALIZED)
|
|
return Message._get_message_id(self._msg)
|
|
|
|
|
|
def get_filename(self):
|
|
""" return the msg filename
|
|
|
|
Raises NotmuchError(STATUS.NOT_INITIALIZED) if not inited
|
|
"""
|
|
if self._msg is None:
|
|
raise NotmuchError(STATUS.NOT_INITIALIZED)
|
|
return Message._get_filename(self._msg)
|
|
|
|
def get_tags(self):
|
|
""" return the msg tags
|
|
|
|
Raises NotmuchError(STATUS.NOT_INITIALIZED) if not inited
|
|
Raises NotmuchError(STATUS.NULL_POINTER) on error.
|
|
"""
|
|
if self._msg is None:
|
|
raise NotmuchError(STATUS.NOT_INITIALIZED)
|
|
|
|
tags_p = Message._get_tags(self._msg)
|
|
if tags_p == None:
|
|
raise NotmuchError(STATUS.NULL_POINTER)
|
|
return Tags(tags_p, self)
|
|
|
|
def __del__(self):
|
|
"""Close and free the notmuch Message"""
|
|
if self._msg is not None:
|
|
print("Freeing the Message now")
|
|
nmlib.notmuch_message_destroy (self._msg)
|