use std::ffi::CString;
use std::ops::Drop;
use std::path::PathBuf;
use supercow::{Phantomcow, Supercow};
use error::{Error, Result};
use ffi;
use ffi::Status;
use utils::ToStr;
use Filenames;
use FilenamesOwner;
use Messages;
use MessagesOwner;
use Tags;
use TagsOwner;
pub trait MessageOwner {}
#[derive(Debug)]
pub(crate) struct MessagePtr {
pub ptr: *mut ffi::notmuch_message_t,
}
impl Drop for MessagePtr {
fn drop(&mut self) {
unsafe { ffi::notmuch_message_destroy(self.ptr) };
}
}
#[derive(Debug)]
pub struct Message<'o, O>
where
O: MessageOwner + 'o,
{
pub(crate) handle: MessagePtr,
marker: Phantomcow<'o, O>,
}
impl<'o, O> MessagesOwner for Message<'o, O> where O: MessageOwner + 'o {}
impl<'o, O> FilenamesOwner for Message<'o, O> where O: MessageOwner + 'o {}
impl<'o, O> TagsOwner for Message<'o, O> where O: MessageOwner + 'o {}
impl<'o, O> Message<'o, O>
where
O: MessageOwner + 'o,
{
pub fn from_ptr
(ptr: *mut ffi::notmuch_message_t, owner: P) -> Message<'o, O>
where
P: Into>,
{
Message {
handle: MessagePtr { ptr },
marker: owner.into(),
}
}
pub fn id(self: &Self) -> String {
let mid = unsafe { ffi::notmuch_message_get_message_id(self.handle.ptr) };
mid.to_str().unwrap().to_string()
}
pub fn thread_id(self: &Self) -> String {
let tid = unsafe { ffi::notmuch_message_get_thread_id(self.handle.ptr) };
tid.to_str().unwrap().to_string()
}
pub fn replies(self: &Self) -> Messages {
>::replies(self)
}
#[cfg(feature = "v0_26")]
pub fn count_files(self: &Self) -> i32 {
unsafe { ffi::notmuch_message_count_files(self.handle.ptr) }
}
pub fn filenames(self: &Self) -> Filenames {
>::filenames(self)
}
pub fn filename(self: &Self) -> PathBuf {
PathBuf::from(
unsafe { ffi::notmuch_message_get_filename(self.handle.ptr) }
.to_str()
.unwrap(),
)
}
pub fn date(&self) -> i64 {
unsafe { ffi::notmuch_message_get_date(self.handle.ptr) }
}
pub fn header(&self, name: &str) -> Result> {
let name = CString::new(name).unwrap();
let ret = unsafe { ffi::notmuch_message_get_header(self.handle.ptr, name.as_ptr()) };
if ret.is_null() {
Err(Error::UnspecifiedError)
} else {
Ok(match ret.to_str().unwrap() {
"" => None,
ret => Some(ret),
})
}
}
pub fn tags(&self) -> Tags {
>::tags(self)
}
pub fn add_tag(self: &Self, tag: &str) -> Status {
let tag = CString::new(tag).unwrap();
Status::from(unsafe { ffi::notmuch_message_add_tag(self.handle.ptr, tag.as_ptr()) })
}
pub fn remove_tag(self: &Self, tag: &str) -> Status {
let tag = CString::new(tag).unwrap();
Status::from(unsafe { ffi::notmuch_message_remove_tag(self.handle.ptr, tag.as_ptr()) })
}
pub fn remove_all_tags(self: &Self) -> Status {
Status::from(unsafe { ffi::notmuch_message_remove_all_tags(self.handle.ptr) })
}
}
pub trait MessageExt<'o, O>
where
O: MessageOwner + 'o,
{
fn tags<'s, S>(message: S) -> Tags<'s, Message<'o, O>>
where
S: Into>>,
{
let messageref = message.into();
Tags::from_ptr(
unsafe { ffi::notmuch_message_get_tags(messageref.handle.ptr) },
Supercow::phantom(messageref),
)
}
fn replies<'s, S>(message: S) -> Messages<'s, Message<'o, O>>
where
S: Into>>,
{
let messageref = message.into();
Messages::from_ptr(
unsafe { ffi::notmuch_message_get_replies(messageref.handle.ptr) },
Supercow::phantom(messageref),
)
}
fn filenames<'s, S>(message: S) -> Filenames<'s, Message<'o, O>>
where
S: Into>>,
{
let messageref = message.into();
Filenames::from_ptr(
unsafe { ffi::notmuch_message_get_filenames(messageref.handle.ptr) },
Supercow::phantom(messageref),
)
}
}
impl<'o, O> MessageExt<'o, O> for Message<'o, O> where O: MessageOwner + 'o {}
unsafe impl<'o, O> Send for Message<'o, O> where O: MessageOwner + 'o {}
unsafe impl<'o, O> Sync for Message<'o, O> where O: MessageOwner + 'o {}