lib.c File Reference

POP helper routines. More...

#include "config.h"
#include <arpa/inet.h>
#include <errno.h>
#include <netdb.h>
#include <stdbool.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "private.h"
#include "mutt/lib.h"
#include "config/lib.h"
#include "email/lib.h"
#include "core/lib.h"
#include "conn/lib.h"
#include "question/lib.h"
#include "progress/lib.h"
#include "adata.h"
#include "edata.h"
#include "mutt_logging.h"

Include dependency graph for lib.c:

Go to the source code of this file.

Functions
const char *	pop_get_field (enum ConnAccountField field, void *gf_data)
	Get connection login credentials - Implements ConnAccount::get_field() -.
int	pop_parse_path (const char *path, struct ConnAccount *cac)
	Parse a POP mailbox name.
static void	pop_error (struct PopAccountData *adata, char *msg)
	Copy error message to err_msg buffer.
static int	fetch_capa (const char *line, void *data)
	Parse CAPA response - Implements pop_fetch_t -.
static int	fetch_auth (const char *line, void *data)
	Parse AUTH response - Implements pop_fetch_t -.
static int	pop_capabilities (struct PopAccountData *adata, int mode)
	Get capabilities from a POP server.
int	pop_connect (struct PopAccountData *adata)
	Open connection.
int	pop_open_connection (struct PopAccountData *adata)
	Open connection and authenticate.
void	pop_logout (struct Mailbox *m)
	Logout from a POP server.
int	pop_query_d (struct PopAccountData *adata, char *buf, size_t buflen, char *msg)
	Send data from buffer and receive answer to the same buffer.
int	pop_fetch_data (struct PopAccountData *adata, const char *query, struct Progress *progress, pop_fetch_t callback, void *data)
	Read Headers with callback function.
static int	check_uidl (const char *line, void *data)
	Parse UIDL response - Implements pop_fetch_t -.
int	pop_reconnect (struct Mailbox *m)
	Reconnect and verify indexes if connection was lost.

Detailed Description

POP helper routines.

Authors

• Vsevolod Volkov
• Richard Russon
• Pietro Cerutti

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 lib.c.

Function Documentation

pop_parse_path()

int pop_parse_path	(	const char *	path,
		struct ConnAccount *	cac
	)

Parse a POP mailbox name.

Parameters

path	Path to parse
cac	Account to store details

Return values

0	success
-1	error

Split a POP path into host, port, username and password

Definition at line 82 of file lib.c.

{
  /* Defaults */
  cac->flags = 0;
  cac->type = MUTT_ACCT_TYPE_POP;
  cac->port = 0;
  cac->service = "pop";
  cac->get_field = pop_get_field;
 
  struct Url *url = url_parse(path);
 
  if (!url || ((url->scheme != U_POP) && (url->scheme != U_POPS)) ||
      !url->host || (account_from_url(cac, url) < 0))
  {
    url_free(&url);
    mutt_error(_("Invalid POP URL: %s"), path);
    return -1;
  }
 
  if (url->scheme == U_POPS)
    cac->flags |= MUTT_ACCT_SSL;
 
  struct servent *service = getservbyname((url->scheme == U_POP) ? "pop3" : "pop3s", "tcp");
  if (cac->port == 0)
  {
    if (service)
      cac->port = ntohs(service->s_port);
    else
      cac->port = (url->scheme == U_POP) ? POP_PORT : POP_SSL_PORT;
  }
 
  url_free(&url);
  return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

pop_error()

static void pop_error ( struct PopAccountData *  adata, char *  msg  )

static

Copy error message to err_msg buffer.

Parameters

adata	POP Account data
msg	Error message to save

Definition at line 122 of file lib.c.

{
  char *t = strchr(adata->err_msg, '\0');
  char *c = msg;
 
  size_t plen = mutt_str_startswith(msg, "-ERR ");
  if (plen != 0)
  {
    char *c2 = mutt_str_skip_email_wsp(msg + plen);
 
    if (*c2)
      c = c2;
  }
 
  mutt_str_copy(t, c, sizeof(adata->err_msg) - strlen(adata->err_msg));
  mutt_str_remove_trailing_ws(adata->err_msg);
}

Here is the call graph for this function:

Here is the caller graph for this function:

pop_capabilities()

static int pop_capabilities ( struct PopAccountData *  adata, int  mode  )

static

Get capabilities from a POP server.

Parameters

adata	POP Account data
mode	Initial capabilities

Return values

0	Successful
-1	Connection lost
-2	Execution error

Definition at line 202 of file lib.c.

{
  char buf[1024] = { 0 };
 
  /* don't check capabilities on reconnect */
  if (adata->capabilities)
    return 0;
 
  /* init capabilities */
  if (mode == 0)
  {
    adata->cmd_capa = false;
    adata->cmd_stls = false;
    adata->cmd_user = 0;
    adata->cmd_uidl = 0;
    adata->cmd_top = 0;
    adata->resp_codes = false;
    adata->expire = true;
    adata->login_delay = 0;
    buf_init(&adata->auth_list);
  }
 
  /* Execute CAPA command */
  if ((mode == 0) || adata->cmd_capa)
  {
    mutt_str_copy(buf, "CAPA\r\n", sizeof(buf));
    switch (pop_fetch_data(adata, buf, NULL, fetch_capa, adata))
    {
      case 0:
      {
        adata->cmd_capa = true;
        break;
      }
      case -1:
        return -1;
    }
  }
 
  /* CAPA not supported, use defaults */
  if ((mode == 0) && !adata->cmd_capa)
  {
    adata->cmd_user = 2;
    adata->cmd_uidl = 2;
    adata->cmd_top = 2;
 
    mutt_str_copy(buf, "AUTH\r\n", sizeof(buf));
    if (pop_fetch_data(adata, buf, NULL, fetch_auth, adata) == -1)
      return -1;
  }
 
  /* Check capabilities */
  if (mode == 2)
  {
    char *msg = NULL;
 
    if (!adata->expire)
      msg = _("Unable to leave messages on server");
    if (adata->cmd_top == 0)
      msg = _("Command TOP is not supported by server");
    if (adata->cmd_uidl == 0)
      msg = _("Command UIDL is not supported by server");
    if (msg && adata->cmd_capa)
    {
      mutt_error("%s", msg);
      return -2;
    }
    adata->capabilities = true;
  }
 
  return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

pop_connect()

int pop_connect

(

struct PopAccountData *

adata

)

Open connection.

Parameters

adata

POP Account data

Return values

0	Successful
-1	Connection lost
-2	Invalid response

Definition at line 281 of file lib.c.

{
  char buf[1024] = { 0 };
 
  adata->status = POP_NONE;
  if ((mutt_socket_open(adata->conn) < 0) ||
      (mutt_socket_readln(buf, sizeof(buf), adata->conn) < 0))
  {
    mutt_error(_("Error connecting to server: %s"), adata->conn->account.host);
    return -1;
  }
 
  adata->status = POP_CONNECTED;
 
  if (!mutt_str_startswith(buf, "+OK"))
  {
    *adata->err_msg = '\0';
    pop_error(adata, buf);
    mutt_error("%s", adata->err_msg);
    return -2;
  }
 
  pop_apop_timestamp(adata, buf);
 
  return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

pop_open_connection()

int pop_open_connection

(

struct PopAccountData *

adata

)

Open connection and authenticate.

Parameters

adata

POP Account data

Return values

0	Successful
-1	Connection lost
-2	Invalid command or execution error
-3	Authentication cancelled

Definition at line 316 of file lib.c.

{
  char buf[1024] = { 0 };
 
  int rc = pop_connect(adata);
  if (rc < 0)
    return rc;
 
  rc = pop_capabilities(adata, 0);
  if (rc == -1)
    goto err_conn;
  if (rc == -2)
    return -2;
 
#ifdef USE_SSL
  /* Attempt STLS if available and desired. */
  const bool c_ssl_force_tls = cs_subset_bool(NeoMutt->sub, "ssl_force_tls");
  if ((adata->conn->ssf == 0) && (adata->cmd_stls || c_ssl_force_tls))
  {
    if (c_ssl_force_tls)
      adata->use_stls = 2;
    if (adata->use_stls == 0)
    {
      enum QuadOption ans = query_quadoption(_("Secure connection with TLS?"),
                                             NeoMutt->sub, "ssl_starttls");
      if (ans == MUTT_ABORT)
        return -2;
      adata->use_stls = 1;
      if (ans == MUTT_YES)
        adata->use_stls = 2;
    }
    if (adata->use_stls == 2)
    {
      mutt_str_copy(buf, "STLS\r\n", sizeof(buf));
      rc = pop_query(adata, buf, sizeof(buf));
      // Clear any data after the STLS acknowledgement
      mutt_socket_empty(adata->conn);
      if (rc == -1)
        goto err_conn;
      if (rc != 0)
      {
        mutt_error("%s", adata->err_msg);
      }
      else if (mutt_ssl_starttls(adata->conn))
      {
        mutt_error(_("Could not negotiate TLS connection"));
        return -2;
      }
      else
      {
        /* recheck capabilities after STLS completes */
        rc = pop_capabilities(adata, 1);
        if (rc == -1)
          goto err_conn;
        if (rc == -2)
          return -2;
      }
    }
  }
 
  if (c_ssl_force_tls && (adata->conn->ssf == 0))
  {
    mutt_error(_("Encrypted connection unavailable"));
    return -2;
  }
#endif
 
  rc = pop_authenticate(adata);
  if (rc == -1)
    goto err_conn;
  if (rc == -3)
    mutt_clear_error();
  if (rc != 0)
    return rc;
 
  /* recheck capabilities after authentication */
  rc = pop_capabilities(adata, 2);
  if (rc == -1)
    goto err_conn;
  if (rc == -2)
    return -2;
 
  /* get total size of mailbox */
  mutt_str_copy(buf, "STAT\r\n", sizeof(buf));
  rc = pop_query(adata, buf, sizeof(buf));
  if (rc == -1)
    goto err_conn;
  if (rc == -2)
  {
    mutt_error("%s", adata->err_msg);
    return rc;
  }
 
  unsigned int n = 0, size = 0;
  sscanf(buf, "+OK %u %u", &n, &size);
  adata->size = size;
  return 0;
 
err_conn:
  adata->status = POP_DISCONNECTED;
  mutt_error(_("Server closed connection"));
  return -1;
}

Here is the call graph for this function:

Here is the caller graph for this function:

pop_logout()

void pop_logout

(

struct Mailbox *

m

)

Logout from a POP server.

Parameters

m

Mailbox

Definition at line 424 of file lib.c.

{
  struct PopAccountData *adata = pop_adata_get(m);
 
  if (adata->status == POP_CONNECTED)
  {
    int rc = 0;
    char buf[1024] = { 0 };
    mutt_message(_("Closing connection to POP server..."));
 
    if (m->readonly)
    {
      mutt_str_copy(buf, "RSET\r\n", sizeof(buf));
      rc = pop_query(adata, buf, sizeof(buf));
    }
 
    if (rc != -1)
    {
      mutt_str_copy(buf, "QUIT\r\n", sizeof(buf));
      rc = pop_query(adata, buf, sizeof(buf));
    }
 
    if (rc < 0)
      mutt_debug(LL_DEBUG1, "Error closing POP connection\n");
 
    mutt_clear_error();
  }
 
  adata->status = POP_DISCONNECTED;
}

Here is the call graph for this function:

Here is the caller graph for this function:

pop_query_d()

int pop_query_d	(	struct PopAccountData *	adata,
		char *	buf,
		size_t	buflen,
		char *	msg
	)

Send data from buffer and receive answer to the same buffer.

Parameters

adata	POP Account data
buf	Buffer to send/store data
buflen	Buffer length
msg	Progress message

Return values

0	Successful
-1	Connection lost
-2	Invalid command or execution error

Definition at line 465 of file lib.c.

{
  if (adata->status != POP_CONNECTED)
    return -1;
 
  /* print msg instead of real command */
  if (msg)
  {
    mutt_debug(MUTT_SOCK_LOG_CMD, "> %s", msg);
  }
 
  mutt_socket_send_d(adata->conn, buf, MUTT_SOCK_LOG_FULL);
 
  char *c = strpbrk(buf, " \r\n");
  if (c)
    *c = '\0';
  snprintf(adata->err_msg, sizeof(adata->err_msg), "%s: ", buf);
 
  if (mutt_socket_readln_d(buf, buflen, adata->conn, MUTT_SOCK_LOG_FULL) < 0)
  {
    adata->status = POP_DISCONNECTED;
    return -1;
  }
  if (mutt_str_startswith(buf, "+OK"))
    return 0;
 
  pop_error(adata, buf);
  return -2;
}

Here is the call graph for this function:

Here is the caller graph for this function:

pop_fetch_data()

int pop_fetch_data	(	struct PopAccountData *	adata,
		const char *	query,
		struct Progress *	progress,
		pop_fetch_t	callback,
		void *	data
	)

Read Headers with callback function.

Parameters

adata	POP Account data
query	POP query to send to server
progress	Progress bar
callback	Function called for each header read
data	Data to pass to the callback

Return values

0	Successful
-1	Connection lost
-2	Invalid command or execution error
-3	Error in callback(*line, *data)

This function calls callback(*line, *data) for each received line, callback(NULL, *data) if rewind(*data) needs, exits when fail or done.

Definition at line 510 of file lib.c.

{
  char buf[1024] = { 0 };
  long pos = 0;
  size_t lenbuf = 0;
 
  mutt_str_copy(buf, query, sizeof(buf));
  int rc = pop_query(adata, buf, sizeof(buf));
  if (rc < 0)
    return rc;
 
  char *inbuf = MUTT_MEM_MALLOC(sizeof(buf), char);
 
  while (true)
  {
    const int chunk = mutt_socket_readln_d(buf, sizeof(buf), adata->conn, MUTT_SOCK_LOG_FULL);
    if (chunk < 0)
    {
      adata->status = POP_DISCONNECTED;
      rc = -1;
      break;
    }
 
    char *p = buf;
    if (!lenbuf && (buf[0] == '.'))
    {
      if (buf[1] != '.')
        break;
      p++;
    }
 
    mutt_str_copy(inbuf + lenbuf, p, sizeof(buf));
    pos += chunk;
 
    /* cast is safe since we break out of the loop when chunk<=0 */
    if ((size_t) chunk >= sizeof(buf))
    {
      lenbuf += strlen(p);
    }
    else
    {
      progress_update(progress, pos, -1);
      if ((rc == 0) && (callback(inbuf, data) < 0))
        rc = -3;
      lenbuf = 0;
    }
 
    MUTT_MEM_REALLOC(&inbuf, lenbuf + sizeof(buf), char);
  }
 
  FREE(&inbuf);
  return rc;
}

Here is the call graph for this function:

Here is the caller graph for this function:

pop_reconnect()

int pop_reconnect

(

struct Mailbox *

m

)

Reconnect and verify indexes if connection was lost.

Parameters

m

Mailbox

Return values

0	Success
-1	Error

Definition at line 608 of file lib.c.

{
  struct PopAccountData *adata = pop_adata_get(m);
 
  if (adata->status == POP_CONNECTED)
    return 0;
 
  while (true)
  {
    mutt_socket_close(adata->conn);
 
    int rc = pop_open_connection(adata);
    if (rc == 0)
    {
      struct Progress *progress = progress_new(MUTT_PROGRESS_NET, 0);
      progress_set_message(progress, _("Verifying message indexes..."));
 
      for (int i = 0; i < m->msg_count; i++)
      {
        struct PopEmailData *edata = pop_edata_get(m->emails[i]);
        edata->refno = -1;
      }
 
      rc = pop_fetch_data(adata, "UIDL\r\n", progress, check_uidl, m);
      progress_free(&progress);
      if (rc == -2)
      {
        mutt_error("%s", adata->err_msg);
      }
    }
 
    if (rc == 0)
      return 0;
 
    pop_logout(m);
 
    if (rc < -1)
      return -1;
 
    if (query_quadoption(_("Connection lost. Reconnect to POP server?"),
                         NeoMutt->sub, "pop_reconnect") != MUTT_YES)
    {
      return -1;
    }
  }
}

Here is the call graph for this function:

Here is the caller graph for this function: