pop.c File Reference

POP network mailbox. More...

#include "config.h"
#include <errno.h>
#include <limits.h>
#include <stdbool.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include "pop_private.h"
#include "mutt/lib.h"
#include "config/lib.h"
#include "email/lib.h"
#include "core/lib.h"
#include "conn/lib.h"
#include "lib.h"
#include "context.h"
#include "globals.h"
#include "hook.h"
#include "init.h"
#include "mutt_account.h"
#include "mutt_header.h"
#include "mutt_logging.h"
#include "mutt_socket.h"
#include "muttlib.h"
#include "mx.h"
#include "progress.h"
#include "bcache/lib.h"
#include "ncrypt/lib.h"
#include <libintl.h>
#include "hcache/lib.h"

Include dependency graph for pop.c:

Go to the source code of this file.

Macros
#define	HC_FNAME   "neomutt" /* filename for hcache as POP lacks paths */
#define	HC_FEXT   "hcache" /* extension for hcache as POP lacks paths */

Functions
static const char *	cache_id (const char *id)
	Make a message-cache-compatible id. More...
static void	pop_adata_free (void **ptr)
	Free data attached to the Mailbox. More...
static struct PopAccountData *	pop_adata_new (void)
	Create a new PopAccountData object. More...
static void	pop_edata_free (void **ptr)
	Free data attached to an Email. More...
static struct PopEmailData *	pop_edata_new (const char *uid)
	Create a new PopEmailData for an email. More...
static int	fetch_message (const char *line, void *data)
	write line to file - Implements pop_fetch_t More...
static int	pop_read_header (struct PopAccountData *adata, struct Email *e)
	Read header. More...
static int	fetch_uidl (const char *line, void *data)
	parse UIDL - Implements pop_fetch_t More...
static int	msg_cache_check (const char *id, struct BodyCache *bcache, void *data)
	Check the Body Cache for an ID - Implements bcache_list_t. More...
static void	pop_hcache_namer (const char *path, struct Buffer *dest)
	Create a header cache filename for a POP mailbox - Implements hcache_namer_t. More...
static header_cache_t *	pop_hcache_open (struct PopAccountData *adata, const char *path)
	Open the header cache. More...
static int	pop_fetch_headers (struct Mailbox *m)
	Read headers. More...
static void	pop_clear_cache (struct PopAccountData *adata)
	delete all cached messages More...
void	pop_fetch_mail (void)
	Fetch messages and save them in $spoolfile. More...
static struct Account *	pop_ac_find (struct Account *a, const char *path)
	Find an Account that matches a Mailbox path - Implements MxOps::ac_find() More...
static int	pop_ac_add (struct Account *a, struct Mailbox *m)
	Add a Mailbox to an Account - Implements MxOps::ac_add() More...
static int	pop_mbox_open (struct Mailbox *m)
	Open a Mailbox - Implements MxOps::mbox_open() More...
static int	pop_mbox_check (struct Mailbox *m, int *index_hint)
	Check for new mail - Implements MxOps::mbox_check() More...
static int	pop_mbox_sync (struct Mailbox *m, int *index_hint)
	Save changes to the Mailbox - Implements MxOps::mbox_sync() More...
static int	pop_mbox_close (struct Mailbox *m)
	Close a Mailbox - Implements MxOps::mbox_close() More...
static int	pop_msg_open (struct Mailbox *m, struct Message *msg, int msgno)
	Open an email message in a Mailbox - Implements MxOps::msg_open() More...
static int	pop_msg_close (struct Mailbox *m, struct Message *msg)
	Close an email - Implements MxOps::msg_close() More...
static int	pop_msg_save_hcache (struct Mailbox *m, struct Email *e)
	Save message to the header cache - Implements MxOps::msg_save_hcache() More...
enum MailboxType	pop_path_probe (const char *path, const struct stat *st)
	Is this a POP Mailbox? - Implements MxOps::path_probe() More...
static int	pop_path_canon (char *buf, size_t buflen)
	Canonicalise a Mailbox path - Implements MxOps::path_canon() More...
static int	pop_path_pretty (char *buf, size_t buflen, const char *folder)
	Abbreviate a Mailbox path - Implements MxOps::path_pretty() More...
static int	pop_path_parent (char *buf, size_t buflen)
	Find the parent of a Mailbox path - Implements MxOps::path_parent() More...

Variables
short	C_PopCheckinterval
	Config: (pop) Interval between checks for new mail. More...
unsigned char	C_PopDelete
	Config: (pop) After downloading POP messages, delete them on the server. More...
char *	C_PopHost
	Config: (pop) Url of the POP server. More...
bool	C_PopLast
	Config: (pop) Use the 'LAST' command to fetch new mail. More...
struct MxOps	MxPopOps
	POP Mailbox - Implements MxOps. More...

Detailed Description

POP network mailbox.

Authors

• Vsevolod Volkov
• Rocco Rutte
• 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 pop.c.

Macro Definition Documentation

HC_FNAME

#define HC_FNAME   "neomutt" /* filename for hcache as POP lacks paths */

Definition at line 75 of file pop.c.

HC_FEXT

#define HC_FEXT   "hcache" /* extension for hcache as POP lacks paths */

Definition at line 76 of file pop.c.

Function Documentation

cache_id()

static const char* cache_id ( const char *  id )

static

Make a message-cache-compatible id.

Parameters

id	POP message id

Return values

ptr	Sanitised string

The POP message id may contain '/' and other awkward characters.

Note

This function returns a pointer to a static buffer.

Definition at line 87 of file pop.c.

{
  static char clean[128];
  mutt_str_strfcpy(clean, id, sizeof(clean));
  mutt_file_sanitize_filename(clean, true);
  return clean;
}

Here is the call graph for this function:

Here is the caller graph for this function:

pop_adata_free()

static void pop_adata_free ( void **  ptr )

static

Free data attached to the Mailbox.

Parameters

[out]

ptr

POP data

The PopAccountData struct stores global POP data, such as the connection to the database. This function will close the database, free the resources and the struct itself.

Definition at line 103 of file pop.c.

{
  if (!ptr || !*ptr)
    return;

  struct PopAccountData *adata = *ptr;
  FREE(&adata->auth_list.data);
  FREE(ptr);
}

Here is the caller graph for this function:

pop_adata_new()

static struct PopAccountData* pop_adata_new ( void  )

static

Create a new PopAccountData object.

Return values

ptr	New PopAccountData struct

Definition at line 117 of file pop.c.

{
  return mutt_mem_calloc(1, sizeof(struct PopAccountData));
}

Here is the call graph for this function:

Here is the caller graph for this function:

pop_edata_free()

static void pop_edata_free ( void **  ptr )

static

Free data attached to an Email.

Parameters

[out]

ptr

Email data

Each email has an attached PopEmailData, which contains things like the tags (labels).

Definition at line 129 of file pop.c.

{
  if (!ptr || !*ptr)
    return;

  struct PopEmailData *edata = *ptr;
  FREE(&edata->uid);
  FREE(ptr);
}

Here is the caller graph for this function:

pop_edata_new()

static struct PopEmailData* pop_edata_new ( const char *  uid )

static

Create a new PopEmailData for an email.

Parameters

uid

Email UID

Return values

ptr	New PopEmailData struct

Definition at line 144 of file pop.c.

{
  struct PopEmailData *edata = mutt_mem_calloc(1, sizeof(struct PopEmailData));
  edata->uid = mutt_str_strdup(uid);
  return edata;
}

Here is the call graph for this function:

Here is the caller graph for this function:

fetch_message()

static int fetch_message ( const char *  line, void *  data  )

static

write line to file - Implements pop_fetch_t

Parameters

line	String to write
data	FILE pointer to write to

Return values

0	Success
-1	Failure

Definition at line 158 of file pop.c.

{
  FILE *fp = data;

  fputs(line, fp);
  if (fputc('\n', fp) == EOF)
    return -1;

  return 0;
}

Here is the caller graph for this function:

pop_read_header()

static int pop_read_header ( struct PopAccountData *  adata, struct Email *  e  )

static

Read header.

Parameters

adata	POP Account data
e	Email

Return values

0	Success
-1	Connection lost
-2	Invalid command or execution error
-3	Error writing to tempfile

Definition at line 178 of file pop.c.

{
  FILE *fp = mutt_file_mkstemp();
  if (!fp)
  {
    mutt_perror(_("Can't create temporary file"));
    return -3;
  }

  int index = 0;
  size_t length = 0;
  char buf[1024];

  struct PopEmailData *edata = pop_edata_get(e);

  snprintf(buf, sizeof(buf), "LIST %d\r\n", edata->refno);
  int rc = pop_query(adata, buf, sizeof(buf));
  if (rc == 0)
  {
    sscanf(buf, "+OK %d %zu", &index, &length);

    snprintf(buf, sizeof(buf), "TOP %d 0\r\n", edata->refno);
    rc = pop_fetch_data(adata, buf, NULL, fetch_message, fp);

    if (adata->cmd_top == 2)
    {
      if (rc == 0)
      {
        adata->cmd_top = 1;

        mutt_debug(LL_DEBUG1, "set TOP capability\n");
      }

      if (rc == -2)
      {
        adata->cmd_top = 0;

        mutt_debug(LL_DEBUG1, "unset TOP capability\n");
        snprintf(adata->err_msg, sizeof(adata->err_msg), "%s",
                 _("Command TOP is not supported by server"));
      }
    }
  }

  switch (rc)
  {
    case 0:
    {
      rewind(fp);
      e->env = mutt_rfc822_read_header(fp, e, false, false);
      e->content->length = length - e->content->offset + 1;
      rewind(fp);
      while (!feof(fp))
      {
        e->content->length--;
        fgets(buf, sizeof(buf), fp);
      }
      break;
    }
    case -2:
    {
      mutt_error("%s", adata->err_msg);
      break;
    }
    case -3:
    {
      mutt_error(_("Can't write header to temporary file"));
      break;
    }
  }

  mutt_file_fclose(&fp);
  return rc;
}

Here is the call graph for this function:

Here is the caller graph for this function:

fetch_uidl()

static int fetch_uidl ( const char *  line, void *  data  )

static

parse UIDL - Implements pop_fetch_t

Parameters

line	String to parse
data	Mailbox

Return values

0	Success
-1	Failure

Definition at line 260 of file pop.c.

{
  struct Mailbox *m = data;
  struct PopAccountData *adata = pop_adata_get(m);
  char *endp = NULL;

  errno = 0;
  int index = strtol(line, &endp, 10);
  if (errno)
    return -1;
  while (*endp == ' ')
    endp++;
  line = endp;

  /* uid must be at least be 1 byte */
  if (strlen(line) == 0)
    return -1;

  int i;
  for (i = 0; i < m->msg_count; i++)
  {
    struct PopEmailData *edata = pop_edata_get(m->emails[i]);
    if (mutt_str_strcmp(line, edata->uid) == 0)
      break;
  }

  if (i == m->msg_count)
  {
    mutt_debug(LL_DEBUG1, "new header %d %s\n", index, line);

    if (i >= m->email_max)
      mx_alloc_memory(m);

    m->msg_count++;
    m->emails[i] = email_new();

    m->emails[i]->edata = pop_edata_new(line);
    m->emails[i]->free_edata = pop_edata_free;
  }
  else if (m->emails[i]->index != index - 1)
    adata->clear_cache = true;

  m->emails[i]->index = index - 1;

  struct PopEmailData *edata = pop_edata_get(m->emails[i]);
  edata->refno = index;

  return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

msg_cache_check()

static int msg_cache_check ( const char *  id, struct BodyCache *  bcache, void *  data  )

static

Check the Body Cache for an ID - Implements bcache_list_t.

Definition at line 313 of file pop.c.

{
  struct Mailbox *m = data;
  if (!m)
    return -1;

  struct PopAccountData *adata = pop_adata_get(m);
  if (!adata)
    return -1;

#ifdef USE_HCACHE
  /* keep hcache file if hcache == bcache */
  if (strcmp(HC_FNAME "." HC_FEXT, id) == 0)
    return 0;
#endif

  for (int i = 0; i < m->msg_count; i++)
  {
    struct PopEmailData *edata = pop_edata_get(m->emails[i]);
    /* if the id we get is known for a header: done (i.e. keep in cache) */
    if (edata->uid && (mutt_str_strcmp(edata->uid, id) == 0))
      return 0;
  }

  /* message not found in context -> remove it from cache
   * return the result of bcache, so we stop upon its first error */
  return mutt_bcache_del(bcache, cache_id(id));
}

Here is the call graph for this function:

Here is the caller graph for this function:

pop_hcache_namer()

static void pop_hcache_namer ( const char *  path, struct Buffer *  dest  )

static

Create a header cache filename for a POP mailbox - Implements hcache_namer_t.

Definition at line 346 of file pop.c.

{
  mutt_buffer_printf(dest, "%s." HC_FEXT, path);
}

Here is the call graph for this function:

Here is the caller graph for this function:

pop_hcache_open()

static header_cache_t* pop_hcache_open ( struct PopAccountData *  adata, const char *  path  )

static

Open the header cache.

Parameters

adata	POP Account data
path	Path to the mailbox

Return values

ptr	Header cache

Definition at line 357 of file pop.c.

{
  if (!adata || !adata->conn)
    return mutt_hcache_open(C_HeaderCache, path, NULL);

  struct Url url = { 0 };
  char p[1024];

  mutt_account_tourl(&adata->conn->account, &url);
  url.path = HC_FNAME;
  url_tostring(&url, p, sizeof(p), U_PATH);
  return mutt_hcache_open(C_HeaderCache, p, pop_hcache_namer);
}

Here is the call graph for this function:

Here is the caller graph for this function:

pop_fetch_headers()

static int pop_fetch_headers ( struct Mailbox *  m )

static

Read headers.

Parameters

m

Mailbox

Return values

0	Success
-1	Connection lost
-2	Invalid command or execution error
-3	Error writing to tempfile

Definition at line 380 of file pop.c.

{
  if (!m)
    return -1;

  struct PopAccountData *adata = pop_adata_get(m);
  struct Progress progress;

#ifdef USE_HCACHE
  header_cache_t *hc = pop_hcache_open(adata, mailbox_path(m));
#endif

  adata->check_time = mutt_date_epoch();
  adata->clear_cache = false;

  for (int i = 0; i < m->msg_count; i++)
  {
    struct PopEmailData *edata = pop_edata_get(m->emails[i]);
    edata->refno = -1;
  }

  const int old_count = m->msg_count;
  int rc = pop_fetch_data(adata, "UIDL\r\n", NULL, fetch_uidl, m);
  const int new_count = m->msg_count;
  m->msg_count = old_count;

  if (adata->cmd_uidl == 2)
  {
    if (rc == 0)
    {
      adata->cmd_uidl = 1;

      mutt_debug(LL_DEBUG1, "set UIDL capability\n");
    }

    if ((rc == -2) && (adata->cmd_uidl == 2))
    {
      adata->cmd_uidl = 0;

      mutt_debug(LL_DEBUG1, "unset UIDL capability\n");
      snprintf(adata->err_msg, sizeof(adata->err_msg), "%s",
               _("Command UIDL is not supported by server"));
    }
  }

  if (!m->quiet)
  {
    mutt_progress_init(&progress, _("Fetching message headers..."),
                       MUTT_PROGRESS_READ, new_count - old_count);
  }

  if (rc == 0)
  {
    int i, deleted;
    for (i = 0, deleted = 0; i < old_count; i++)
    {
      struct PopEmailData *edata = pop_edata_get(m->emails[i]);
      if (edata->refno == -1)
      {
        m->emails[i]->deleted = true;
        deleted++;
      }
    }
    if (deleted > 0)
    {
      mutt_error(
          ngettext("%d message has been lost. Try reopening the mailbox.",
                   "%d messages have been lost. Try reopening the mailbox.", deleted),
          deleted);
    }

    bool hcached = false;
    for (i = old_count; i < new_count; i++)
    {
      if (!m->quiet)
        mutt_progress_update(&progress, i + 1 - old_count, -1);
      struct PopEmailData *edata = pop_edata_get(m->emails[i]);
#ifdef USE_HCACHE
      struct HCacheEntry hce = mutt_hcache_fetch(hc, edata->uid, strlen(edata->uid), 0);
      if (hce.email)
      {
        /* Detach the private data */
        m->emails[i]->edata = NULL;

        int index = m->emails[i]->index;
        /* - POP dynamically numbers headers and relies on e->refno
         *   to map messages; so restore header and overwrite restored
         *   refno with current refno, same for index
         * - e->data needs to a separate pointer as it's driver-specific
         *   data freed separately elsewhere
         *   (the old e->data should point inside a malloc'd block from
         *   hcache so there shouldn't be a memleak here) */
        email_free(&m->emails[i]);
        m->emails[i] = hce.email;
        m->emails[i]->index = index;

        /* Reattach the private data */
        m->emails[i]->edata = edata;
        m->emails[i]->free_edata = pop_edata_free;
        rc = 0;
        hcached = true;
      }
      else
#endif
          if ((rc = pop_read_header(adata, m->emails[i])) < 0)
        break;
#ifdef USE_HCACHE
      else
      {
        mutt_hcache_store(hc, edata->uid, strlen(edata->uid), m->emails[i], 0);
      }
#endif

      /* faked support for flags works like this:
       * - if 'hcached' is true, we have the message in our hcache:
       *        - if we also have a body: read
       *        - if we don't have a body: old
       *          (if $mark_old is set which is maybe wrong as
       *          $mark_old should be considered for syncing the
       *          folder and not when opening it XXX)
       * - if 'hcached' is false, we don't have the message in our hcache:
       *        - if we also have a body: read
       *        - if we don't have a body: new */
      const bool bcached =
          (mutt_bcache_exists(adata->bcache, cache_id(edata->uid)) == 0);
      m->emails[i]->old = false;
      m->emails[i]->read = false;
      if (hcached)
      {
        if (bcached)
          m->emails[i]->read = true;
        else if (C_MarkOld)
          m->emails[i]->old = true;
      }
      else
      {
        if (bcached)
          m->emails[i]->read = true;
      }

      m->msg_count++;
    }
  }

#ifdef USE_HCACHE
  mutt_hcache_close(hc);
#endif

  if (rc < 0)
  {
    for (int i = m->msg_count; i < new_count; i++)
      email_free(&m->emails[i]);
    return rc;
  }

  /* after putting the result into our structures,
   * clean up cache, i.e. wipe messages deleted outside
   * the availability of our cache */
  if (C_MessageCacheClean)
    mutt_bcache_list(adata->bcache, msg_cache_check, m);

  mutt_clear_error();
  return new_count - old_count;
}

Here is the call graph for this function:

Here is the caller graph for this function:

pop_clear_cache()

static void pop_clear_cache ( struct PopAccountData *  adata )

static

delete all cached messages

Parameters

adata

POP Account data

Definition at line 549 of file pop.c.

{
  if (!adata->clear_cache)
    return;

  mutt_debug(LL_DEBUG1, "delete cached messages\n");

  for (int i = 0; i < POP_CACHE_LEN; i++)
  {
    if (adata->cache[i].path)
    {
      unlink(adata->cache[i].path);
      FREE(&adata->cache[i].path);
    }
  }
}

Here is the caller graph for this function:

pop_fetch_mail()

void pop_fetch_mail

(

void

)

Fetch messages and save them in $spoolfile.

Definition at line 569 of file pop.c.

{
  if (!C_PopHost)
  {
    mutt_error(_("POP host is not defined"));
    return;
  }

  char buf[1024];
  char msgbuf[128];
  int last = 0, msgs, bytes, rset = 0, ret;
  struct ConnAccount cac = { { 0 } };

  char *p = mutt_mem_calloc(strlen(C_PopHost) + 7, sizeof(char));
  char *url = p;
  if (url_check_scheme(C_PopHost) == U_UNKNOWN)
  {
    strcpy(url, "pop://");
    p = strchr(url, '\0');
  }
  strcpy(p, C_PopHost);

  ret = pop_parse_path(url, &cac);
  FREE(&url);
  if (ret)
  {
    mutt_error(_("%s is an invalid POP path"), C_PopHost);
    return;
  }

  struct Connection *conn = mutt_conn_find(&cac);
  if (!conn)
    return;

  struct PopAccountData *adata = pop_adata_new();
  adata->conn = conn;

  if (pop_open_connection(adata) < 0)
  {
    //XXX mutt_socket_free(adata->conn);
    pop_adata_free((void **) &adata);
    return;
  }

  mutt_message(_("Checking for new messages..."));

  /* find out how many messages are in the mailbox. */
  mutt_str_strfcpy(buf, "STAT\r\n", sizeof(buf));
  ret = pop_query(adata, buf, sizeof(buf));
  if (ret == -1)
    goto fail;
  if (ret == -2)
  {
    mutt_error("%s", adata->err_msg);
    goto finish;
  }

  sscanf(buf, "+OK %d %d", &msgs, &bytes);

  /* only get unread messages */
  if ((msgs > 0) && C_PopLast)
  {
    mutt_str_strfcpy(buf, "LAST\r\n", sizeof(buf));
    ret = pop_query(adata, buf, sizeof(buf));
    if (ret == -1)
      goto fail;
    if (ret == 0)
      sscanf(buf, "+OK %d", &last);
  }

  if (msgs <= last)
  {
    mutt_message(_("No new mail in POP mailbox"));
    goto finish;
  }

  struct Mailbox *m_spool = mx_path_resolve(C_Spoolfile);
  struct Context *ctx = mx_mbox_open(m_spool, MUTT_OPEN_NO_FLAGS);
  if (!ctx)
  {
    mailbox_free(&m_spool);
    goto finish;
  }

  bool old_append = m_spool->append;
  m_spool->append = true;

  enum QuadOption delanswer =
      query_quadoption(C_PopDelete, _("Delete messages from server?"));

  snprintf(msgbuf, sizeof(msgbuf),
           ngettext("Reading new messages (%d byte)...",
                    "Reading new messages (%d bytes)...", bytes),
           bytes);
  mutt_message("%s", msgbuf);

  for (int i = last + 1; i <= msgs; i++)
  {
    struct Message *msg = mx_msg_open_new(ctx->mailbox, NULL, MUTT_ADD_FROM);
    if (msg)
    {
      snprintf(buf, sizeof(buf), "RETR %d\r\n", i);
      ret = pop_fetch_data(adata, buf, NULL, fetch_message, msg->fp);
      if (ret == -3)
        rset = 1;

      if ((ret == 0) && (mx_msg_commit(ctx->mailbox, msg) != 0))
      {
        rset = 1;
        ret = -3;
      }

      mx_msg_close(ctx->mailbox, &msg);
    }
    else
    {
      ret = -3;
    }

    if ((ret == 0) && (delanswer == MUTT_YES))
    {
      /* delete the message on the server */
      snprintf(buf, sizeof(buf), "DELE %d\r\n", i);
      ret = pop_query(adata, buf, sizeof(buf));
    }

    if (ret == -1)
    {
      m_spool->append = old_append;
      mx_mbox_close(&ctx);
      goto fail;
    }
    if (ret == -2)
    {
      mutt_error("%s", adata->err_msg);
      break;
    }
    if (ret == -3)
    {
      mutt_error(_("Error while writing mailbox"));
      break;
    }

    /* L10N: The plural is picked by the second numerical argument, i.e.
       the %d right before 'messages', i.e. the total number of messages. */
    mutt_message(ngettext("%s [%d of %d message read]",
                          "%s [%d of %d messages read]", msgs - last),
                 msgbuf, i - last, msgs - last);
  }

  m_spool->append = old_append;
  mx_mbox_close(&ctx);

  if (rset)
  {
    /* make sure no messages get deleted */
    mutt_str_strfcpy(buf, "RSET\r\n", sizeof(buf));
    if (pop_query(adata, buf, sizeof(buf)) == -1)
      goto fail;
  }

finish:
  /* exit gracefully */
  mutt_str_strfcpy(buf, "QUIT\r\n", sizeof(buf));
  if (pop_query(adata, buf, sizeof(buf)) == -1)
    goto fail;
  mutt_socket_close(conn);
  FREE(&conn);
  pop_adata_free((void **) &adata);
  return;

fail:
  mutt_error(_("Server closed connection"));
  mutt_socket_close(conn);
  pop_adata_free((void **) &adata);
}

Here is the call graph for this function:

Here is the caller graph for this function:

pop_ac_find()

static struct Account* pop_ac_find ( struct Account *  a, const char *  path  )

static

Find an Account that matches a Mailbox path - Implements MxOps::ac_find()

Definition at line 749 of file pop.c.

{
  if (!a || (a->type != MUTT_POP) || !path)
    return NULL;

  struct Url *url = url_parse(path);
  if (!url)
    return NULL;

  struct PopAccountData *adata = a->adata;
  struct ConnAccount *cac = &adata->conn->account;

  if ((mutt_str_strcasecmp(url->host, cac->host) != 0) ||
      (mutt_str_strcasecmp(url->user, cac->user) != 0))
  {
    a = NULL;
  }

  url_free(&url);
  return a;
}

Here is the call graph for this function:

pop_ac_add()

static int pop_ac_add ( struct Account *  a, struct Mailbox *  m  )

static

Add a Mailbox to an Account - Implements MxOps::ac_add()

Definition at line 774 of file pop.c.

{
  if (!a || !m || (m->type != MUTT_POP))
    return -1;

  if (a->adata)
    return 0;

  struct ConnAccount cac = { { 0 } };
  struct PopAccountData *adata = pop_adata_new();
  a->adata = adata;
  a->free_adata = pop_adata_free;

  if (pop_parse_path(mailbox_path(m), &cac))
  {
    mutt_error(_("%s is an invalid POP path"), mailbox_path(m));
    return -1;
  }

  adata->conn = mutt_conn_new(&cac);
  if (!adata->conn)
  {
    pop_adata_free((void **) &adata);
    return -1;
  }

  return 0;
}

Here is the call graph for this function:

pop_mbox_open()

static int pop_mbox_open ( struct Mailbox *  m )

static

Open a Mailbox - Implements MxOps::mbox_open()

Fetch only headers

Definition at line 808 of file pop.c.

{
  if (!m || !m->account)
    return -1;

  char buf[PATH_MAX];
  struct ConnAccount cac = { { 0 } };
  struct Url url = { 0 };

  if (pop_parse_path(mailbox_path(m), &cac))
  {
    mutt_error(_("%s is an invalid POP path"), mailbox_path(m));
    return -1;
  }

  mutt_account_tourl(&cac, &url);
  url.path = NULL;
  url_tostring(&url, buf, sizeof(buf), 0);

  mutt_buffer_strcpy(&m->pathbuf, buf);
  mutt_str_replace(&m->realpath, mailbox_path(m));

  struct PopAccountData *adata = m->account->adata;
  if (!adata)
  {
    adata = pop_adata_new();
    m->account->adata = adata;
    m->account->free_adata = pop_adata_free;
  }

  struct Connection *conn = adata->conn;
  if (!conn)
  {
    adata->conn = mutt_conn_new(&cac);
    conn = adata->conn;
    if (!conn)
      return -1;
  }

  if (conn->fd < 0)
    mutt_account_hook(m->realpath);

  if (pop_open_connection(adata) < 0)
    return -1;

  adata->bcache = mutt_bcache_open(&cac, NULL);

  /* init (hard-coded) ACL rights */
  m->rights = MUTT_ACL_SEEN | MUTT_ACL_DELETE;
#ifdef USE_HCACHE
  /* flags are managed using header cache, so it only makes sense to
   * enable them in that case */
  m->rights |= MUTT_ACL_WRITE;
#endif

  while (true)
  {
    if (pop_reconnect(m) < 0)
      return -1;

    m->size = adata->size;

    mutt_message(_("Fetching list of messages..."));

    const int rc = pop_fetch_headers(m);

    if (rc >= 0)
      return 0;

    if (rc < -1)
      return -1;
  }
}

Here is the call graph for this function:

pop_mbox_check()

static int pop_mbox_check ( struct Mailbox *  m, int *  index_hint  )

static

Check for new mail - Implements MxOps::mbox_check()

Definition at line 885 of file pop.c.

{
  if (!m)
    return -1;

  struct PopAccountData *adata = pop_adata_get(m);

  if ((adata->check_time + C_PopCheckinterval) > mutt_date_epoch())
    return 0;

  pop_logout(m);

  mutt_socket_close(adata->conn);

  if (pop_open_connection(adata) < 0)
    return -1;

  m->size = adata->size;

  mutt_message(_("Checking for new messages..."));

  int old_msg_count = m->msg_count;
  int rc = pop_fetch_headers(m);
  pop_clear_cache(adata);
  if (m->msg_count > old_msg_count)
    mailbox_changed(m, NT_MAILBOX_INVALID);

  if (rc < 0)
    return -1;

  if (rc > 0)
    return MUTT_NEW_MAIL;

  return 0;
}

Here is the call graph for this function:

pop_mbox_sync()

static int pop_mbox_sync ( struct Mailbox *  m, int *  index_hint  )

static

Save changes to the Mailbox - Implements MxOps::mbox_sync()

Update POP mailbox, delete messages from server

Definition at line 926 of file pop.c.

{
  if (!m)
    return -1;

  int i, j, rc = 0;
  char buf[1024];
  struct PopAccountData *adata = pop_adata_get(m);
  struct Progress progress;
#ifdef USE_HCACHE
  header_cache_t *hc = NULL;
#endif

  adata->check_time = 0;

  int num_deleted = 0;
  for (i = 0; i < m->msg_count; i++)
  {
    if (m->emails[i]->deleted)
      num_deleted++;
  }

  while (true)
  {
    if (pop_reconnect(m) < 0)
      return -1;

    mutt_progress_init(&progress, _("Marking messages deleted..."),
                       MUTT_PROGRESS_WRITE, num_deleted);

#ifdef USE_HCACHE
    hc = pop_hcache_open(adata, mailbox_path(m));
#endif

    for (i = 0, j = 0, rc = 0; (rc == 0) && (i < m->msg_count); i++)
    {
      struct PopEmailData *edata = pop_edata_get(m->emails[i]);
      if (m->emails[i]->deleted && (edata->refno != -1))
      {
        j++;
        if (!m->quiet)
          mutt_progress_update(&progress, j, -1);
        snprintf(buf, sizeof(buf), "DELE %d\r\n", edata->refno);
        rc = pop_query(adata, buf, sizeof(buf));
        if (rc == 0)
        {
          mutt_bcache_del(adata->bcache, cache_id(edata->uid));
#ifdef USE_HCACHE
          mutt_hcache_delete_header(hc, edata->uid, strlen(edata->uid));
#endif
        }
      }

#ifdef USE_HCACHE
      if (m->emails[i]->changed)
      {
        mutt_hcache_store(hc, edata->uid, strlen(edata->uid), m->emails[i], 0);
      }
#endif
    }

#ifdef USE_HCACHE
    mutt_hcache_close(hc);
#endif

    if (rc == 0)
    {
      mutt_str_strfcpy(buf, "QUIT\r\n", sizeof(buf));
      rc = pop_query(adata, buf, sizeof(buf));
    }

    if (rc == 0)
    {
      adata->clear_cache = true;
      pop_clear_cache(adata);
      adata->status = POP_DISCONNECTED;
      return 0;
    }

    if (rc == -2)
    {
      mutt_error("%s", adata->err_msg);
      return -1;
    }
  }
}

Here is the call graph for this function:

pop_mbox_close()

static int pop_mbox_close ( struct Mailbox *  m )

static

Close a Mailbox - Implements MxOps::mbox_close()

Definition at line 1016 of file pop.c.

{
  if (!m)
    return -1;

  struct PopAccountData *adata = pop_adata_get(m);
  if (!adata)
    return 0;

  pop_logout(m);

  if (adata->status != POP_NONE)
  {
    mutt_socket_close(adata->conn);
    // FREE(&adata->conn);
  }

  adata->status = POP_NONE;

  adata->clear_cache = true;
  pop_clear_cache(adata);

  mutt_bcache_close(&adata->bcache);

  return 0;
}

Here is the call graph for this function:

pop_msg_open()

static int pop_msg_open ( struct Mailbox *  m, struct Message *  msg, int  msgno  )

static

Open an email message in a Mailbox - Implements MxOps::msg_open()

Definition at line 1046 of file pop.c.

{
  if (!m)
    return -1;

  char buf[1024];
  struct Progress progress;
  struct PopAccountData *adata = pop_adata_get(m);
  struct Email *e = m->emails[msgno];
  struct PopEmailData *edata = pop_edata_get(e);
  bool bcache = true;
  int rc = -1;
  struct Buffer *path = NULL;

  /* see if we already have the message in body cache */
  msg->fp = mutt_bcache_get(adata->bcache, cache_id(edata->uid));
  if (msg->fp)
    return 0;

  /* see if we already have the message in our cache in
   * case $message_cachedir is unset */
  struct PopCache *cache = &adata->cache[e->index % POP_CACHE_LEN];

  if (cache->path)
  {
    if (cache->index == e->index)
    {
      /* yes, so just return a pointer to the message */
      msg->fp = fopen(cache->path, "r");
      if (msg->fp)
        return 0;

      mutt_perror(cache->path);
      return -1;
    }
    else
    {
      /* clear the previous entry */
      unlink(cache->path);
      FREE(&cache->path);
    }
  }

  path = mutt_buffer_pool_get();

  while (true)
  {
    if (pop_reconnect(m) < 0)
      goto cleanup;

    /* verify that massage index is correct */
    if (edata->refno < 0)
    {
      mutt_error(
          _("The message index is incorrect. Try reopening the mailbox."));
      goto cleanup;
    }

    mutt_progress_init(&progress, _("Fetching message..."), MUTT_PROGRESS_NET,
                       e->content->length + e->content->offset - 1);

    /* see if we can put in body cache; use our cache as fallback */
    msg->fp = mutt_bcache_put(adata->bcache, cache_id(edata->uid));
    if (!msg->fp)
    {
      /* no */
      bcache = false;
      mutt_buffer_mktemp(path);
      msg->fp = mutt_file_fopen(mutt_b2s(path), "w+");
      if (!msg->fp)
      {
        mutt_perror(mutt_b2s(path));
        goto cleanup;
      }
    }

    snprintf(buf, sizeof(buf), "RETR %d\r\n", edata->refno);

    const int ret = pop_fetch_data(adata, buf, &progress, fetch_message, msg->fp);
    if (ret == 0)
      break;

    mutt_file_fclose(&msg->fp);

    /* if RETR failed (e.g. connection closed), be sure to remove either
     * the file in bcache or from POP's own cache since the next iteration
     * of the loop will re-attempt to put() the message */
    if (!bcache)
      unlink(mutt_b2s(path));

    if (ret == -2)
    {
      mutt_error("%s", adata->err_msg);
      goto cleanup;
    }

    if (ret == -3)
    {
      mutt_error(_("Can't write message to temporary file"));
      goto cleanup;
    }
  }

  /* Update the header information.  Previously, we only downloaded a
   * portion of the headers, those required for the main display.  */
  if (bcache)
    mutt_bcache_commit(adata->bcache, cache_id(edata->uid));
  else
  {
    cache->index = e->index;
    cache->path = mutt_buffer_strdup(path);
  }
  rewind(msg->fp);

  /* Detach the private data */
  e->edata = NULL;

  /* we replace envelope, key in subj_hash has to be updated as well */
  if (m->subj_hash && e->env->real_subj)
    mutt_hash_delete(m->subj_hash, e->env->real_subj, e);
  mutt_label_hash_remove(m, e);
  mutt_env_free(&e->env);
  e->env = mutt_rfc822_read_header(msg->fp, e, false, false);
  if (m->subj_hash && e->env->real_subj)
    mutt_hash_insert(m->subj_hash, e->env->real_subj, e);
  mutt_label_hash_add(m, e);

  /* Reattach the private data */
  e->edata = edata;
  e->free_edata = pop_edata_free;

  e->lines = 0;
  fgets(buf, sizeof(buf), msg->fp);
  while (!feof(msg->fp))
  {
    m->emails[msgno]->lines++;
    fgets(buf, sizeof(buf), msg->fp);
  }

  e->content->length = ftello(msg->fp) - e->content->offset;

  /* This needs to be done in case this is a multipart message */
  if (!WithCrypto)
    e->security = crypt_query(e->content);

  mutt_clear_error();
  rewind(msg->fp);

  rc = 0;

cleanup:
  mutt_buffer_pool_release(&path);
  return rc;
}

Here is the call graph for this function:

pop_msg_close()

static int pop_msg_close ( struct Mailbox *  m, struct Message *  msg  )

static

Close an email - Implements MxOps::msg_close()

Return values

0	Success
EOF	Error, see errno

Definition at line 1206 of file pop.c.

{
  return mutt_file_fclose(&msg->fp);
}

Here is the call graph for this function:

pop_msg_save_hcache()

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

static

Save message to the header cache - Implements MxOps::msg_save_hcache()

Definition at line 1214 of file pop.c.

{
  int rc = 0;
#ifdef USE_HCACHE
  struct PopAccountData *adata = pop_adata_get(m);
  struct PopEmailData *edata = e->edata;
  header_cache_t *hc = pop_hcache_open(adata, mailbox_path(m));
  rc = mutt_hcache_store(hc, edata->uid, strlen(edata->uid), e, 0);
  mutt_hcache_close(hc);
#endif

  return rc;
}

Here is the call graph for this function:

pop_path_probe()

enum MailboxType pop_path_probe	(	const char *	path,
		const struct stat *	st
	)

Is this a POP Mailbox? - Implements MxOps::path_probe()

Definition at line 1231 of file pop.c.

{
  if (!path)
    return MUTT_UNKNOWN;

  if (mutt_str_startswith(path, "pop://", CASE_IGNORE))
    return MUTT_POP;

  if (mutt_str_startswith(path, "pops://", CASE_IGNORE))
    return MUTT_POP;

  return MUTT_UNKNOWN;
}

Here is the call graph for this function:

Here is the caller graph for this function:

pop_path_canon()

static int pop_path_canon ( char *  buf, size_t  buflen  )

static

Canonicalise a Mailbox path - Implements MxOps::path_canon()

Definition at line 1248 of file pop.c.

{
  if (!buf)
    return -1;

  return 0;
}

pop_path_pretty()

static int pop_path_pretty ( char *  buf, size_t  buflen, const char *  folder  )

static

Abbreviate a Mailbox path - Implements MxOps::path_pretty()

Definition at line 1259 of file pop.c.

{
  /* Succeed, but don't do anything, for now */
  return 0;
}

pop_path_parent()

static int pop_path_parent ( char *  buf, size_t  buflen  )

static

Find the parent of a Mailbox path - Implements MxOps::path_parent()

Definition at line 1268 of file pop.c.

{
  /* Succeed, but don't do anything, for now */
  return 0;
}

Variable Documentation

C_PopCheckinterval

short C_PopCheckinterval

Config: (pop) Interval between checks for new mail.

Definition at line 67 of file pop.c.

C_PopDelete

unsigned char C_PopDelete

Config: (pop) After downloading POP messages, delete them on the server.

Definition at line 71 of file pop.c.

C_PopHost

char* C_PopHost

Config: (pop) Url of the POP server.

Definition at line 72 of file pop.c.

C_PopLast

bool C_PopLast

Config: (pop) Use the 'LAST' command to fetch new mail.

Definition at line 73 of file pop.c.

MxPopOps

struct MxOps MxPopOps

Initial value:

= {
  .type            = MUTT_POP,
  .name             = "pop",
  .is_local         = false,
  .ac_find          = pop_ac_find,
  .ac_add           = pop_ac_add,
  .mbox_open        = pop_mbox_open,
  .mbox_open_append = NULL,
  .mbox_check       = pop_mbox_check,
  .mbox_check_stats = NULL,
  .mbox_sync        = pop_mbox_sync,
  .mbox_close       = pop_mbox_close,
  .msg_open         = pop_msg_open,
  .msg_open_new     = NULL,
  .msg_commit       = NULL,
  .msg_close        = pop_msg_close,
  .msg_padding_size = NULL,
  .msg_save_hcache  = pop_msg_save_hcache,
  .tags_edit        = NULL,
  .tags_commit      = NULL,
  .path_probe       = pop_path_probe,
  .path_canon       = pop_path_canon,
  .path_pretty      = pop_path_pretty,
  .path_parent      = pop_path_parent,
}

POP Mailbox - Implements MxOps.

Definition at line 1278 of file pop.c.