Maildir local mailbox type. More...

#include "config.h"
#include <dirent.h>
#include <errno.h>
#include <fcntl.h>
#include <inttypes.h>
#include <limits.h>
#include <stdbool.h>
#include <stdio.h>
#include <string.h>
#include <sys/stat.h>
#include <unistd.h>
#include <utime.h>
#include "private.h"
#include "mutt/lib.h"
#include "config/lib.h"
#include "email/lib.h"
#include "core/lib.h"
#include "lib.h"
#include "progress/lib.h"
#include "copy.h"
#include "edata.h"
#include "globals.h"
#include "mdata.h"
#include "mdemail.h"
#include "mx.h"
#include "sort.h"
#include "monitor.h"
#include "hcache/lib.h"
#include "notmuch/lib.h"

Include dependency graph for maildir.c:

Go to the source code of this file.

Macros
#define	MMC_NO_DIRS 0
	No directories changed.

#define	MMC_NEW_DIR (1 << 0)
	'new' directory changed

#define	MMC_CUR_DIR (1 << 1)
	'cur' directory changed

Functions
struct Email *	maildir_email_new (void)
	Create a Maildir Email.

static void	maildir_check_dir (struct Mailbox m, const char dir_name, bool check_new, bool check_stats)
	Check for new mail / mail counts.

static int	maildir_sort_flags (const void a, const void b, void *sdata)
	Compare two flag characters - Implements sort_t -.

void	maildir_gen_flags (char dest, size_t destlen, struct Email e)
	Generate the Maildir flags for an email.

static int	maildir_commit_message (struct Mailbox m, struct Message msg, struct Email *e)
	Commit a message to a maildir folder.

static int	maildir_rewrite_message (struct Mailbox m, struct Email e)
	Sync a message in an MH folder.

static int	maildir_sync_message (struct Mailbox m, struct Email e)
	Sync an email to a Maildir folder.

static void	maildir_update_mtime (struct Mailbox *m)
	Update our record of the Maildir modification time.

static int	maildir_sort_inode (const void a, const void b, void *sdata)
	Compare two Maildirs by inode number - Implements sort_t -.

static int	maildir_parse_dir (struct Mailbox m, struct MdEmailArray mda, const char subdir, struct Progress progress)
	Read a Maildir mailbox.

static size_t	maildir_hcache_keylen (const char *fn)
	Calculate the length of the Maildir path.

static void	maildir_delayed_parsing (struct Mailbox m, struct MdEmailArray mda, struct Progress *progress)
	This function does the second parsing pass.

static int	maildir_read_dir (struct Mailbox m, const char subdir)
	Read a Maildir style mailbox.

static void	maildir_canon_filename (struct Buffer dest, const char src)
	Generate the canonical filename for a Maildir folder.

static FILE *	maildir_open_find_message_dir (const char folder, const char unique, const char subfolder, char *newname)
	Find a message in a maildir folder.

void	maildir_parse_flags (struct Email e, const char path)
	Parse Maildir file flags.

bool	maildir_parse_stream (enum MailboxType type, FILE fp, const char fname, bool is_old, struct Email *e)
	Parse a Maildir message.

bool	maildir_parse_message (enum MailboxType type, const char fname, bool is_old, struct Email e)
	Actually parse a maildir message.

bool	maildir_sync_mailbox_message (struct Mailbox m, struct Email e, struct HeaderCache *hc)
	Save changes to the mailbox.

FILE *	maildir_open_find_message (const char folder, const char msg, char **newname)
	Find a message by name.

int	maildir_check_empty (struct Buffer *path)
	Is the mailbox empty.

static bool	maildir_ac_owns_path (struct Account a, const char path)
	Check whether an Account own a Mailbox path - Implements MxOps::ac_owns_path() -.

static bool	maildir_ac_add (struct Account a, struct Mailbox m)
	Add a Mailbox to an Account - Implements MxOps::ac_add() -.

static enum MxOpenReturns	maildir_mbox_open (struct Mailbox *m)
	Open a Mailbox - Implements MxOps::mbox_open() -.

static bool	maildir_mbox_open_append (struct Mailbox *m, OpenMailboxFlags flags)
	Open a Mailbox for appending - Implements MxOps::mbox_open_append() -.

static enum MxStatus	maildir_check (struct Mailbox *m)
	Check for new mail.

static enum MxStatus	maildir_mbox_check (struct Mailbox *m)
	Check for new mail - Implements MxOps::mbox_check() -.

static enum MxStatus	maildir_mbox_check_stats (struct Mailbox *m, uint8_t flags)
	Check the Mailbox statistics - Implements MxOps::mbox_check_stats() -.

static enum MxStatus	maildir_mbox_sync (struct Mailbox *m)
	Save changes to the Mailbox - Implements MxOps::mbox_sync() -.

static enum MxStatus	maildir_mbox_close (struct Mailbox *m)
	Close a Mailbox - Implements MxOps::mbox_close() -.

static bool	maildir_msg_open (struct Mailbox m, struct Message msg, struct Email *e)
	Open an email message in a Mailbox - Implements MxOps::msg_open() -.

bool	maildir_msg_open_new (struct Mailbox m, struct Message msg, const struct Email *e)
	Open a new message in a Mailbox - Implements MxOps::msg_open_new() -.

static int	maildir_msg_commit (struct Mailbox m, struct Message msg)
	Save changes to an email - Implements MxOps::msg_commit() -.

static int	maildir_msg_close (struct Mailbox m, struct Message msg)
	Close an email - Implements MxOps::msg_close() -.

static int	maildir_msg_save_hcache (struct Mailbox m, struct Email e)
	Save message to the header cache - Implements MxOps::msg_save_hcache() -.

static int	maildir_path_canon (struct Buffer *path)
	Canonicalise a Mailbox path - Implements MxOps::path_canon() -.

static int	maildir_path_parent (struct Buffer *path)
	Find the parent of a Mailbox path - Implements MxOps::path_parent() -.

static int	maildir_path_pretty (struct Buffer path, const char folder)
	Abbreviate a Mailbox path - Implements MxOps::path_pretty() -.

static enum MailboxType	maildir_path_probe (const char path, const struct stat st)
	Is this a Maildir Mailbox? - Implements MxOps::path_probe() -.

Variables
const struct MxOps	MxMaildirOps
	Maildir Mailbox - Implements MxOps -.

Detailed Description

Maildir local mailbox type.

Authors

Michael R. Elkins
Thomas Roessler
Michael R. Elkins
Richard Russon

Copyright: This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 2 of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or 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 this program. If not, see http://www.gnu.org/licenses/.

Definition in file maildir.c.

Macro Definition Documentation

◆ MMC_NO_DIRS

#define MMC_NO_DIRS 0

No directories changed.

Definition at line 73 of file maildir.c.

◆ MMC_NEW_DIR

#define MMC_NEW_DIR (1 << 0)

'new' directory changed

Definition at line 74 of file maildir.c.

◆ MMC_CUR_DIR

#define MMC_CUR_DIR (1 << 1)

'cur' directory changed

Definition at line 75 of file maildir.c.

Function Documentation

◆ maildir_email_new()

struct Email * maildir_email_new ( void )

Create a Maildir Email.

Return values

ptr	Newly created Email

Create a new Email and attach MaildirEmailData.

Note: This should be freed using email_free()

Definition at line 85 of file maildir.c.

{
  struct Email *e = email_new();
  e->edata = maildir_edata_new();
  e->edata_free = maildir_edata_free;
 
  return e;
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ maildir_check_dir()

static void maildir_check_dir	(	struct Mailbox *	m,
		const char *	dir_name,
		bool	check_new,
		bool	check_stats
	)

static

Check for new mail / mail counts.

Parameters

m	Mailbox to check
dir_name	Path to Mailbox
check_new	if true, check for new mail
check_stats	if true, count total, new, and flagged messages

Checks the specified maildir subdir (cur or new) for new mail or mail counts.

Definition at line 103 of file maildir.c.

{
  DIR *dir = NULL;
  struct dirent *de = NULL;
  char *p = NULL;
  struct stat st = { 0 };
 
  struct Buffer *path = buf_pool_get();
  struct Buffer *msgpath = buf_pool_get();
  buf_printf(path, "%s/%s", mailbox_path(m), dir_name);
 
  /* when $mail_check_recent is set, if the new/ directory hasn't been modified since
   * the user last exited the mailbox, then we know there is no recent mail.  */
  const bool c_mail_check_recent = cs_subset_bool(NeoMutt->sub, "mail_check_recent");
  if (check_new && c_mail_check_recent)
  {
    if ((stat(buf_string(path), &st) == 0) &&
        (mutt_file_stat_timespec_compare(&st, MUTT_STAT_MTIME, &m->last_visited) < 0))
    {
      check_new = false;
    }
  }
 
  if (!(check_new || check_stats))
    goto cleanup;
 
  dir = mutt_file_opendir(buf_string(path), MUTT_OPENDIR_CREATE);
  if (!dir)
  {
    m->type = MUTT_UNKNOWN;
    goto cleanup;
  }
 
  const char c_maildir_field_delimiter = *cc_maildir_field_delimiter();
 
  char delimiter_version[8] = { 0 };
  snprintf(delimiter_version, sizeof(delimiter_version), "%c2,", c_maildir_field_delimiter);
  while ((de = readdir(dir)))
  {
    if (*de->d_name == '.')
      continue;
 
    p = strstr(de->d_name, delimiter_version);
    if (p && strchr(p + 3, 'T'))
      continue;
 
    if (check_stats)
    {
      m->msg_count++;
      if (p && strchr(p + 3, 'F'))
        m->msg_flagged++;
    }
    if (!p || !strchr(p + 3, 'S'))
    {
      if (check_stats)
        m->msg_unread++;
      if (check_new)
      {
        if (c_mail_check_recent)
        {
          buf_printf(msgpath, "%s/%s", buf_string(path), de->d_name);
          /* ensure this message was received since leaving this m */
          if ((stat(buf_string(msgpath), &st) == 0) &&
              (mutt_file_stat_timespec_compare(&st, MUTT_STAT_CTIME, &m->last_visited) <= 0))
          {
            continue;
          }
        }
        m->has_new = true;
        if (check_stats)
        {
          m->msg_new++;
        }
        else
        {
          break;
        }
      }
    }
  }
 
  closedir(dir);
 
cleanup:
  buf_pool_release(&path);
  buf_pool_release(&msgpath);
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ maildir_gen_flags()

void maildir_gen_flags	(	char *	dest,
		size_t	destlen,
		struct Email *	e
	)

Generate the Maildir flags for an email.

Parameters

dest	Buffer for the result
destlen	Length of buffer
e	Email

Definition at line 206 of file maildir.c.

{
  *dest = '\0';
 
  const char *flags = NULL;
 
  struct MaildirEmailData *edata = maildir_edata_get(e);
  if (edata)
    flags = edata->maildir_flags;
 
  /* The maildir specification requires that all files in the cur
   * subdirectory have the :unique string appended, regardless of whether
   * or not there are any flags.  If .old is set, we know that this message
   * will end up in the cur directory, so we include it in the following
   * test even though there is no associated flag.  */
 
  if (e->flagged || e->replied || e->read || e->deleted || e->old || flags)
  {
    char tmp[1024] = { 0 };
    snprintf(tmp, sizeof(tmp), "%s%s%s%s%s", e->flagged ? "F" : "", e->replied ? "R" : "",
             e->read ? "S" : "", e->deleted ? "T" : "", NONULL(flags));
    if (flags)
      mutt_qsort_r(tmp, strlen(tmp), 1, maildir_sort_flags, NULL);
 
    const char c_maildir_field_delimiter = *cc_maildir_field_delimiter();
    snprintf(dest, destlen, "%c2,%s", c_maildir_field_delimiter, tmp);
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ maildir_commit_message()

static int maildir_commit_message	(	struct Mailbox *	m,
		struct Message *	msg,
		struct Email *	e
	)

static

Commit a message to a maildir folder.

Parameters

m	Mailbox
msg	Message to commit
e	Email

Return values

0	Success
-1	Failure

msg->path contains the file name of a file in tmp/. We take the flags from this file's name.

m is the mail folder we commit to.

e is a header structure to which we write the message's new file name. This is used in the mh and maildir folder sync routines. When this routine is invoked from mx_msg_commit(), e is NULL.

msg->path looks like this:

tmp/{cur,new}.neomutt-HOSTNAME-PID-COUNTER:flags

◆ maildir_rewrite_message()

static int maildir_rewrite_message	(	struct Mailbox *	m,
		struct Email *	e
	)

static

Sync a message in an MH folder.

Parameters

m	Mailbox
e	Email

Return values

0	Success
-1	Error

Definition at line 352 of file maildir.c.

{
  if (!m || !e)
    return -1;
 
  bool restore = true;
 
  long old_body_offset = e->body->offset;
  long old_body_length = e->body->length;
  long old_hdr_lines = e->lines;
 
  struct Message *src = mx_msg_open(m, e);
  struct Message *dest = mx_msg_open_new(m, e, MUTT_MSG_NO_FLAGS);
  if (!src || !dest)
    return -1;
 
  int rc = mutt_copy_message(dest->fp, e, src, MUTT_CM_UPDATE, CH_UPDATE | CH_UPDATE_LEN, 0);
  if (rc == 0)
  {
    char oldpath[PATH_MAX] = { 0 };
    char partpath[PATH_MAX] = { 0 };
    snprintf(oldpath, sizeof(oldpath), "%s/%s", mailbox_path(m), e->path);
    mutt_str_copy(partpath, e->path, sizeof(partpath));
 
    rc = maildir_commit_message(m, dest, e);
 
    if (rc == 0)
    {
      unlink(oldpath);
      restore = false;
    }
  }
  mx_msg_close(m, &src);
  mx_msg_close(m, &dest);
 
  if ((rc == -1) && restore)
  {
    e->body->offset = old_body_offset;
    e->body->length = old_body_length;
    e->lines = old_hdr_lines;
  }
 
  mutt_body_free(&e->body->parts);
  return rc;
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ maildir_sync_message()

static int maildir_sync_message	(	struct Mailbox *	m,
		struct Email *	e
	)

static

Sync an email to a Maildir folder.

Parameters

m	Mailbox
e	Email

Return values

0	Success
-1	Error

Definition at line 405 of file maildir.c.

{
  if (!m || !e)
    return -1;
 
  struct Buffer *newpath = NULL;
  struct Buffer *partpath = NULL;
  struct Buffer *fullpath = NULL;
  struct Buffer *oldpath = NULL;
  char suffix[16] = { 0 };
  int rc = 0;
 
  if (e->attach_del || e->env->changed)
  {
    /* when doing attachment deletion/rethreading, fall back to the MH case. */
    if (maildir_rewrite_message(m, e) != 0)
      return -1;
    e->env->changed = false;
  }
  else
  {
    /* we just have to rename the file. */
 
    char *p = strrchr(e->path, '/');
    if (!p)
    {
      mutt_debug(LL_DEBUG1, "%s: unable to find subdir!\n", e->path);
      return -1;
    }
    p++;
    newpath = buf_pool_get();
    partpath = buf_pool_get();
    fullpath = buf_pool_get();
    oldpath = buf_pool_get();
 
    buf_strcpy(newpath, p);
 
    /* kill the previous flags */
    const char c_maildir_field_delimiter = *cc_maildir_field_delimiter();
    p = strchr(newpath->data, c_maildir_field_delimiter);
    if (p)
    {
      *p = '\0';
      newpath->dptr = p; /* fix buffer up, just to be safe */
    }
 
    maildir_gen_flags(suffix, sizeof(suffix), e);
 
    buf_printf(partpath, "%s/%s%s", (e->read || e->old) ? "cur" : "new",
               buf_string(newpath), suffix);
    buf_printf(fullpath, "%s/%s", mailbox_path(m), buf_string(partpath));
    buf_printf(oldpath, "%s/%s", mailbox_path(m), e->path);
 
    if (mutt_str_equal(buf_string(fullpath), buf_string(oldpath)))
    {
      /* message hasn't really changed */
      goto cleanup;
    }
 
    /* record that the message is possibly marked as trashed on disk */
    e->trash = e->deleted;
 
    struct stat st = { 0 };
    if (stat(buf_string(oldpath), &st) == -1)
    {
      mutt_debug(LL_DEBUG1, "File already removed (just continuing)");
      goto cleanup;
    }
 
    if (rename(buf_string(oldpath), buf_string(fullpath)) != 0)
    {
      mutt_perror("rename");
      rc = -1;
      goto cleanup;
    }
    mutt_str_replace(&e->path, buf_string(partpath));
  }
 
cleanup:
  buf_pool_release(&newpath);
  buf_pool_release(&partpath);
  buf_pool_release(&fullpath);
  buf_pool_release(&oldpath);
 
  return rc;
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ maildir_update_mtime()

static void maildir_update_mtime ( struct Mailbox * m )

static

Update our record of the Maildir modification time.

Parameters

m Mailbox

Definition at line 496 of file maildir.c.

{
  char buf[PATH_MAX] = { 0 };
  struct stat st = { 0 };
  struct MaildirMboxData *mdata = maildir_mdata_get(m);
 
  snprintf(buf, sizeof(buf), "%s/%s", mailbox_path(m), "cur");
  if (stat(buf, &st) == 0)
    mutt_file_get_stat_timespec(&mdata->mtime_cur, &st, MUTT_STAT_MTIME);
 
  snprintf(buf, sizeof(buf), "%s/%s", mailbox_path(m), "new");
  if (stat(buf, &st) == 0)
    mutt_file_get_stat_timespec(&mdata->mtime, &st, MUTT_STAT_MTIME);
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ maildir_parse_dir()

static int maildir_parse_dir	(	struct Mailbox *	m,
		struct MdEmailArray *	mda,
		const char *	subdir,
		struct Progress *	progress
	)

static

Read a Maildir mailbox.

Parameters

[in]	m	Mailbox
[out]	mda	Array for results
[in]	subdir	Subdirectory, e.g. 'new'
[in]	progress	Progress bar

Return values

0	Success
-1	Error
-2	Aborted

Definition at line 532 of file maildir.c.

{
  struct dirent *de = NULL;
  int rc = 0;
  bool is_old = false;
  struct MdEmail *entry = NULL;
  struct Email *e = NULL;
 
  struct Buffer *buf = buf_pool_get();
 
  buf_printf(buf, "%s/%s", mailbox_path(m), subdir);
  is_old = mutt_str_equal("cur", subdir);
 
  DIR *dir = mutt_file_opendir(buf_string(buf), MUTT_OPENDIR_CREATE);
  if (!dir)
  {
    rc = -1;
    goto cleanup;
  }
 
  while (((de = readdir(dir))) && !SigInt)
  {
    if (*de->d_name == '.')
      continue;
 
    mutt_debug(LL_DEBUG2, "queueing %s\n", de->d_name);
 
    e = maildir_email_new();
    e->old = is_old;
    maildir_parse_flags(e, de->d_name);
 
    progress_update(progress, ARRAY_SIZE(mda) + 1, -1);
 
    buf_printf(buf, "%s/%s", subdir, de->d_name);
    e->path = buf_strdup(buf);
 
    entry = maildir_entry_new();
    entry->email = e;
    entry->inode = de->d_ino;
    ARRAY_ADD(mda, entry);
  }
 
  closedir(dir);
 
  if (SigInt)
  {
    SigInt = false;
    return -2; /* action aborted */
  }
 
  ARRAY_SORT(mda, maildir_sort_inode, NULL);
 
cleanup:
  buf_pool_release(&buf);
 
  return rc;
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ maildir_hcache_keylen()

static size_t maildir_hcache_keylen ( const char * fn )

static

Calculate the length of the Maildir path.

Parameters

fn File name

Return values

num	Length in bytes

Note: This length excludes the flags, which will vary

Definition at line 599 of file maildir.c.

{
  const char c_maildir_field_delimiter = *cc_maildir_field_delimiter();
  const char *p = strrchr(fn, c_maildir_field_delimiter);
  return p ? (size_t) (p - fn) : mutt_str_len(fn);
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ maildir_delayed_parsing()

static void maildir_delayed_parsing	(	struct Mailbox *	m,
		struct MdEmailArray *	mda,
		struct Progress *	progress
	)

static

This function does the second parsing pass.

Parameters

[in]	m	Mailbox
[out]	mda	Maildir array to parse
[in]	progress	Progress bar

Definition at line 613 of file maildir.c.

{
  char fn[PATH_MAX] = { 0 };
 
#ifdef USE_HCACHE
  const char *const c_header_cache = cs_subset_path(NeoMutt->sub, "header_cache");
  struct HeaderCache *hc = hcache_open(c_header_cache, mailbox_path(m), NULL);
  const bool c_maildir_header_cache_verify = cs_subset_bool(NeoMutt->sub, "maildir_header_cache_verify");
#endif
 
  struct MdEmail *md = NULL;
  struct MdEmail **mdp = NULL;
  ARRAY_FOREACH(mdp, mda)
  {
    md = *mdp;
    if (!md || !md->email || md->header_parsed)
      continue;
 
    progress_update(progress, ARRAY_FOREACH_IDX, -1);
 
    snprintf(fn, sizeof(fn), "%s/%s", mailbox_path(m), md->email->path);
 
#ifdef USE_HCACHE
    struct stat st_lastchanged = { 0 };
    int rc = 0;
 
    const char *key = md->email->path + 3;
    size_t keylen = maildir_hcache_keylen(key);
    struct HCacheEntry hce = { 0 };
 
    if (hc)
    {
      hce = hcache_fetch(hc, key, keylen, 0);
    }
 
    if (hce.email && c_maildir_header_cache_verify)
    {
      rc = stat(fn, &st_lastchanged);
    }
 
    if (hce.email && (rc == 0) && (st_lastchanged.st_mtime <= hce.uidvalidity))
    {
      hce.email->edata = maildir_edata_new();
      hce.email->edata_free = maildir_edata_free;
      hce.email->old = md->email->old;
      hce.email->path = mutt_str_dup(md->email->path);
      email_free(&md->email);
      md->email = hce.email;
      maildir_parse_flags(md->email, fn);
    }
    else
#endif
    {
      if (maildir_parse_message(m->type, fn, md->email->old, md->email))
      {
        md->header_parsed = true;
#ifdef USE_HCACHE
        key = md->email->path + 3;
        keylen = maildir_hcache_keylen(key);
        hcache_store(hc, key, keylen, md->email, 0);
#endif
      }
      else
      {
        email_free(&md->email);
      }
    }
  }
#ifdef USE_HCACHE
  hcache_close(&hc);
#endif
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ maildir_read_dir()

static int maildir_read_dir	(	struct Mailbox *	m,
		const char *	subdir
	)

static

Read a Maildir style mailbox.

Parameters

m	Mailbox
subdir	Subdir of the maildir mailbox to read from

Return values

0	Success
-1	Failure

Definition at line 694 of file maildir.c.

{
  if (!m)
    return -1;
 
  struct Progress *progress = NULL;
 
  if (m->verbose)
  {
    char msg[PATH_MAX] = { 0 };
    snprintf(msg, sizeof(msg), _("Scanning %s..."), mailbox_path(m));
    progress = progress_new(msg, MUTT_PROGRESS_READ, 0);
  }
 
  struct MaildirMboxData *mdata = maildir_mdata_get(m);
  if (!mdata)
  {
    mdata = maildir_mdata_new();
    m->mdata = mdata;
    m->mdata_free = maildir_mdata_free;
  }
 
  struct MdEmailArray mda = ARRAY_HEAD_INITIALIZER;
  int rc = maildir_parse_dir(m, &mda, subdir, progress);
  progress_free(&progress);
  if (rc < 0)
    return -1;
 
  if (m->verbose)
  {
    char msg[PATH_MAX] = { 0 };
    snprintf(msg, sizeof(msg), _("Reading %s..."), mailbox_path(m));
    progress = progress_new(msg, MUTT_PROGRESS_READ, ARRAY_SIZE(&mda));
  }
  maildir_delayed_parsing(m, &mda, progress);
  progress_free(&progress);
 
  maildir_move_to_mailbox(m, &mda);
  maildirarray_clear(&mda);
 
  if (!mdata->mh_umask)
    mdata->mh_umask = mh_umask(m);
 
  return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ maildir_canon_filename()

static void maildir_canon_filename	(	struct Buffer *	dest,
		const char *	src
	)

static

Generate the canonical filename for a Maildir folder.

Parameters

dest	Buffer for the result
src	Buffer containing source filename

Note: maildir filename is defined as: <base filename>:2,<flags> but <base filename> may contain additional comma separated fields. Additionally, : may be replaced as the field delimiter by a user defined alternative.

Definition at line 750 of file maildir.c.

{
  if (!dest || !src)
    return;
 
  char *t = strrchr(src, '/');
  if (t)
    src = t + 1;
 
  buf_strcpy(dest, src);
 
  const char c_maildir_field_delimiter = *cc_maildir_field_delimiter();
 
  char searchable_bytes[8] = { 0 };
  snprintf(searchable_bytes, sizeof(searchable_bytes), ",%c", c_maildir_field_delimiter);
  char *u = strpbrk(dest->data, searchable_bytes);
 
  if (u)
  {
    *u = '\0';
    dest->dptr = u;
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ maildir_open_find_message_dir()

static FILE * maildir_open_find_message_dir	(	const char *	folder,
		const char *	unique,
		const char *	subfolder,
		char **	newname
	)

static

Find a message in a maildir folder.

Parameters

[in]	folder	Base folder
[in]	unique	Unique part of filename
[in]	subfolder	Subfolder to search, e.g. 'cur'
[out]	newname	File's new name

Return values

ptr	File handle

These functions try to find a message in a maildir folder when it has moved under our feet. Note that this code is rather expensive, but then again, it's called rarely.

Definition at line 786 of file maildir.c.

{
  struct Buffer *dirname = buf_pool_get();
  struct Buffer *tunique = buf_pool_get();
  struct Buffer *fname = buf_pool_get();
 
  struct dirent *de = NULL;
 
  FILE *fp = NULL;
  int oe = ENOENT;
 
  buf_printf(dirname, "%s/%s", folder, subfolder);
 
  DIR *dir = mutt_file_opendir(buf_string(dirname), MUTT_OPENDIR_CREATE);
  if (!dir)
  {
    errno = ENOENT;
    goto cleanup;
  }
 
  while ((de = readdir(dir)))
  {
    maildir_canon_filename(tunique, de->d_name);
 
    if (mutt_str_equal(buf_string(tunique), unique))
    {
      buf_printf(fname, "%s/%s/%s", folder, subfolder, de->d_name);
      fp = fopen(buf_string(fname), "r");
      oe = errno;
      break;
    }
  }
 
  closedir(dir);
 
  if (newname && fp)
    *newname = buf_strdup(fname);
 
  errno = oe;
 
cleanup:
  buf_pool_release(&dirname);
  buf_pool_release(&tunique);
  buf_pool_release(&fname);
 
  return fp;
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ maildir_parse_flags()

void maildir_parse_flags	(	struct Email *	e,
		const char *	path
	)

Parse Maildir file flags.

Parameters

e	Email
path	Path to email file

Definition at line 840 of file maildir.c.

{
  char *q = NULL;
 
  e->flagged = false;
  e->read = false;
  e->replied = false;
 
  struct MaildirEmailData *edata = maildir_edata_get(e);
 
  const char c_maildir_field_delimiter = *cc_maildir_field_delimiter();
  char *p = strrchr(path, c_maildir_field_delimiter);
  if (p && mutt_str_startswith(p + 1, "2,"))
  {
    p += 3;
 
    mutt_str_replace(&edata->maildir_flags, p);
    q = edata->maildir_flags;
 
    while (*p)
    {
      switch (*p)
      {
        case 'F': // Flagged
          e->flagged = true;
          break;
 
        case 'R': // Replied
          e->replied = true;
          break;
 
        case 'S': // Seen
          e->read = true;
          break;
 
        case 'T': // Trashed
        {
          const bool c_flag_safe = cs_subset_bool(NeoMutt->sub, "flag_safe");
          if (!e->flagged || !c_flag_safe)
          {
            e->trash = true;
            e->deleted = true;
          }
          break;
        }
 
        default:
          *q++ = *p;
          break;
      }
      p++;
    }
  }
 
  if (q == edata->maildir_flags)
    FREE(&edata->maildir_flags);
  else if (q)
    *q = '\0';
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ maildir_parse_stream()

bool maildir_parse_stream	(	enum MailboxType	type,
		FILE *	fp,
		const char *	fname,
		bool	is_old,
		struct Email *	e
	)

Parse a Maildir message.

Parameters

type	Mailbox type, e.g. MUTT_MAILDIR
fp	Message file handle
fname	Message filename
is_old	true, if the email is old (read)
e	Email

Return values

true Success

Actually parse a maildir message. This may also be used to fill out a fake header structure generated by lazy maildir parsing.

Definition at line 912 of file maildir.c.

{
  if (!fp || !fname || !e)
    return false;
 
  const long size = mutt_file_get_size_fp(fp);
  if (size == 0)
    return false;
 
  e->env = mutt_rfc822_read_header(fp, e, false, false);
 
  if (e->received == 0)
    e->received = e->date_sent;
 
  /* always update the length since we have fresh information available. */
  e->body->length = size - e->body->offset;
 
  e->index = -1;
 
  if (type == MUTT_MAILDIR)
  {
    /* maildir stores its flags in the filename, so ignore the
     * flags in the header of the message */
 
    e->old = is_old;
    maildir_parse_flags(e, fname);
  }
  return e;
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ maildir_parse_message()

bool maildir_parse_message	(	enum MailboxType	type,
		const char *	fname,
		bool	is_old,
		struct Email *	e
	)

Actually parse a maildir message.

Parameters

type	Mailbox type, e.g. MUTT_MAILDIR
fname	Message filename
is_old	true, if the email is old (read)
e	Email to populate

Return values

true Success

This may also be used to fill out a fake header structure generated by lazy maildir parsing.

Definition at line 954 of file maildir.c.

{
  if (!fname || !e)
    return false;
 
  FILE *fp = fopen(fname, "r");
  if (!fp)
    return false;
 
  bool rc = maildir_parse_stream(type, fp, fname, is_old, e);
  mutt_file_fclose(&fp);
  return rc;
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ maildir_sync_mailbox_message()

bool maildir_sync_mailbox_message	(	struct Mailbox *	m,
		struct Email *	e,
		struct HeaderCache *	hc
	)

Save changes to the mailbox.

Parameters

m	Mailbox
e	Email
hc	Header cache handle

Return values

true	Success
false	Error

Definition at line 977 of file maildir.c.

{
  if (!e)
    return false;
 
  const bool c_maildir_trash = cs_subset_bool(NeoMutt->sub, "maildir_trash");
  if (e->deleted && !c_maildir_trash)
  {
    char path[PATH_MAX] = { 0 };
    snprintf(path, sizeof(path), "%s/%s", mailbox_path(m), e->path);
#ifdef USE_HCACHE
    if (hc)
    {
      const char *key = e->path + 3;
      size_t keylen = maildir_hcache_keylen(key);
      hcache_delete_record(hc, key, keylen);
    }
#endif
    unlink(path);
  }
  else if (e->changed || e->attach_del ||
           ((c_maildir_trash || e->trash) && (e->deleted != e->trash)))
  {
    if (maildir_sync_message(m, e) == -1)
      return false;
  }
 
#ifdef USE_HCACHE
  if (hc && e->changed)
  {
    const char *key = e->path + 3;
    size_t keylen = maildir_hcache_keylen(key);
    hcache_store(hc, key, keylen, e, 0);
  }
#endif
 
  return true;
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ maildir_open_find_message()

FILE * maildir_open_find_message	(	const char *	folder,
		const char *	msg,
		char **	newname
	)

Find a message by name.

Parameters

[in]	folder	Maildir path
[in]	msg	Email path
[out]	newname	New name, if it has moved

Return values

ptr	File handle

Definition at line 1023 of file maildir.c.

{
  static unsigned int new_hits = 0, cur_hits = 0; /* simple dynamic optimization */
 
  struct Buffer *unique = buf_pool_get();
  maildir_canon_filename(unique, msg);
 
  FILE *fp = maildir_open_find_message_dir(folder, buf_string(unique),
                                           (new_hits > cur_hits) ? "new" : "cur", newname);
  if (fp || (errno != ENOENT))
  {
    if ((new_hits < UINT_MAX) && (cur_hits < UINT_MAX))
    {
      new_hits += ((new_hits > cur_hits) ? 1 : 0);
      cur_hits += ((new_hits > cur_hits) ? 0 : 1);
    }
 
    goto cleanup;
  }
  fp = maildir_open_find_message_dir(folder, buf_string(unique),
                                     (new_hits > cur_hits) ? "cur" : "new", newname);
  if (fp || (errno != ENOENT))
  {
    if ((new_hits < UINT_MAX) && (cur_hits < UINT_MAX))
    {
      new_hits += ((new_hits > cur_hits) ? 0 : 1);
      cur_hits += ((new_hits > cur_hits) ? 1 : 0);
    }
 
    goto cleanup;
  }
 
  fp = NULL;
 
cleanup:
  buf_pool_release(&unique);
 
  return fp;
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ maildir_check_empty()

int maildir_check_empty ( struct Buffer * path )

Is the mailbox empty.

Parameters

path	Mailbox to check

Return values

1	Mailbox is empty
0	Mailbox contains mail
-1	Error

Definition at line 1070 of file maildir.c.

{
  DIR *dir = NULL;
  struct dirent *de = NULL;
  int rc = 1; /* assume empty until we find a message */
  char realpath[PATH_MAX] = { 0 };
  int iter = 0;
 
  /* Strategy here is to look for any file not beginning with a period */
 
  do
  {
    /* we do "cur" on the first iteration since it's more likely that we'll
     * find old messages without having to scan both subdirs */
    snprintf(realpath, sizeof(realpath), "%s/%s", buf_string(path),
             (iter == 0) ? "cur" : "new");
    dir = mutt_file_opendir(realpath, MUTT_OPENDIR_CREATE);
    if (!dir)
      return -1;
    while ((de = readdir(dir)))
    {
      if (*de->d_name != '.')
      {
        rc = 0;
        break;
      }
    }
    closedir(dir);
    iter++;
  } while (rc && iter < 2);
 
  return rc;
}

Here is the call graph for this function:

◆ maildir_check()

static enum MxStatus maildir_check ( struct Mailbox * m )

static

Check for new mail.

Parameters

m Mailbox

Return values

enum MxStatus

This function handles arrival of new mail and reopening of maildir folders. The basic idea here is we check to see if either the new or cur subdirectories have changed, and if so, we scan them for the list of files. We check for newly added messages, and then merge the flags messages we already knew about. We don't treat either subdirectory differently, as mail could be copied directly into the cur directory from another agent.

Definition at line 1199 of file maildir.c.

{
  struct stat st_new = { 0 }; /* status of the "new" subdirectory */
  struct stat st_cur = { 0 }; /* status of the "cur" subdirectory */
  int changed = MMC_NO_DIRS;  /* which subdirectories have changed */
  bool occult = false;        /* messages were removed from the mailbox */
  int num_new = 0;            /* number of new messages added to the mailbox */
  bool flags_changed = false; /* message flags were changed in the mailbox */
  struct HashTable *hash_names = NULL; // Hash Table: "base-filename" -> MdEmail
  struct MaildirMboxData *mdata = maildir_mdata_get(m);
 
  /* XXX seems like this check belongs in mx_mbox_check() rather than here.  */
  const bool c_check_new = cs_subset_bool(NeoMutt->sub, "check_new");
  if (!c_check_new)
    return MX_STATUS_OK;
 
  struct Buffer *buf = buf_pool_get();
  buf_printf(buf, "%s/new", mailbox_path(m));
  if (stat(buf_string(buf), &st_new) == -1)
  {
    buf_pool_release(&buf);
    return MX_STATUS_ERROR;
  }
 
  buf_printf(buf, "%s/cur", mailbox_path(m));
  if (stat(buf_string(buf), &st_cur) == -1)
  {
    buf_pool_release(&buf);
    return MX_STATUS_ERROR;
  }
 
  /* determine which subdirectories need to be scanned */
  if (mutt_file_stat_timespec_compare(&st_new, MUTT_STAT_MTIME, &mdata->mtime) > 0)
    changed = MMC_NEW_DIR;
  if (mutt_file_stat_timespec_compare(&st_cur, MUTT_STAT_MTIME, &mdata->mtime_cur) > 0)
    changed |= MMC_CUR_DIR;
 
  if (changed == MMC_NO_DIRS)
  {
    buf_pool_release(&buf);
    return MX_STATUS_OK; /* nothing to do */
  }
 
  /* Update the modification times on the mailbox.
   *
   * The monitor code notices changes in the open mailbox too quickly.
   * In practice, this sometimes leads to all the new messages not being
   * noticed during the SAME group of mtime stat updates.  To work around
   * the problem, don't update the stat times for a monitor caused check. */
#ifdef USE_INOTIFY
  if (MonitorContextChanged)
  {
    MonitorContextChanged = false;
  }
  else
#endif
  {
    mutt_file_get_stat_timespec(&mdata->mtime_cur, &st_cur, MUTT_STAT_MTIME);
    mutt_file_get_stat_timespec(&mdata->mtime, &st_new, MUTT_STAT_MTIME);
  }
 
  /* do a fast scan of just the filenames in
   * the subdirectories that have changed.  */
  struct MdEmailArray mda = ARRAY_HEAD_INITIALIZER;
  if (changed & MMC_NEW_DIR)
    maildir_parse_dir(m, &mda, "new", NULL);
  if (changed & MMC_CUR_DIR)
    maildir_parse_dir(m, &mda, "cur", NULL);
 
  /* we create a hash table keyed off the canonical (sans flags) filename
   * of each message we scanned.  This is used in the loop over the
   * existing messages below to do some correlation.  */
  hash_names = mutt_hash_new(ARRAY_SIZE(&mda), MUTT_HASH_NO_FLAGS);
 
  struct MdEmail *md = NULL;
  struct MdEmail **mdp = NULL;
  ARRAY_FOREACH(mdp, &mda)
  {
    md = *mdp;
    maildir_canon_filename(buf, md->email->path);
    md->canon_fname = buf_strdup(buf);
    mutt_hash_insert(hash_names, md->canon_fname, md);
  }
 
  /* check for modifications and adjust flags */
  for (int i = 0; i < m->msg_count; i++)
  {
    struct Email *e = m->emails[i];
    if (!e)
      break;
 
    maildir_canon_filename(buf, e->path);
    md = mutt_hash_find(hash_names, buf_string(buf));
    if (md && md->email)
    {
      /* message already exists, merge flags */
 
      /* check to see if the message has moved to a different
       * subdirectory.  If so, update the associated filename.  */
      if (!mutt_str_equal(e->path, md->email->path))
        mutt_str_replace(&e->path, md->email->path);
 
      /* if the user hasn't modified the flags on this message, update
       * the flags we just detected.  */
      if (!e->changed)
        if (maildir_update_flags(m, e, md->email))
          flags_changed = true;
 
      if (e->deleted == e->trash)
      {
        if (e->deleted != md->email->deleted)
        {
          e->deleted = md->email->deleted;
          flags_changed = true;
        }
      }
      e->trash = md->email->trash;
 
      /* this is a duplicate of an existing email, so remove it */
      email_free(&md->email);
    }
    /* This message was not in the list of messages we just scanned.
     * Check to see if we have enough information to know if the
     * message has disappeared out from underneath us.  */
    else if (((changed & MMC_NEW_DIR) && mutt_strn_equal(e->path, "new/", 4)) ||
             ((changed & MMC_CUR_DIR) && mutt_strn_equal(e->path, "cur/", 4)))
    {
      /* This message disappeared, so we need to simulate a "reopen"
       * event.  We know it disappeared because we just scanned the
       * subdirectory it used to reside in.  */
      occult = true;
      e->deleted = true;
      e->purge = true;
    }
    else
    {
      /* This message resides in a subdirectory which was not
       * modified, so we assume that it is still present and
       * unchanged.  */
    }
  }
 
  /* destroy the file name hash */
  mutt_hash_free(&hash_names);
 
  /* If we didn't just get new mail, update the tables. */
  if (occult)
    mailbox_changed(m, NT_MAILBOX_RESORT);
 
  /* do any delayed parsing we need to do. */
  maildir_delayed_parsing(m, &mda, NULL);
 
  /* Incorporate new messages */
  num_new = maildir_move_to_mailbox(m, &mda);
  maildirarray_clear(&mda);
 
  if (num_new > 0)
  {
    mailbox_changed(m, NT_MAILBOX_INVALID);
    m->changed = true;
  }
 
  buf_pool_release(&buf);
 
  ARRAY_FREE(&mda);
  if (occult)
    return MX_STATUS_REOPENED;
  if (num_new > 0)
    return MX_STATUS_NEW_MAIL;
  if (flags_changed)
    return MX_STATUS_FLAGS;
  return MX_STATUS_OK;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Macros

Functions

Variables

Detailed Description

Macro Definition Documentation

◆ MMC_NO_DIRS

◆ MMC_NEW_DIR

◆ MMC_CUR_DIR

Function Documentation

◆ maildir_email_new()

◆ maildir_check_dir()

◆ maildir_gen_flags()

◆ maildir_commit_message()

◆ maildir_rewrite_message()

◆ maildir_sync_message()

◆ maildir_update_mtime()

◆ maildir_parse_dir()

◆ maildir_hcache_keylen()

◆ maildir_delayed_parsing()

◆ maildir_read_dir()

◆ maildir_canon_filename()

◆ maildir_open_find_message_dir()

◆ maildir_parse_flags()

◆ maildir_parse_stream()

◆ maildir_parse_message()

◆ maildir_sync_mailbox_message()

◆ maildir_open_find_message()

◆ maildir_check_empty()

◆ maildir_check()