fetch-imap.c

/* $Id$ */

/*
 * Copyright (c) 2006 Nicholas Marriott <nicholas.marriott@gmail.com>
 *
 * Permission to use, copy, modify, and distribute this software for any
 * purpose with or without fee is hereby granted, provided that the above
 * copyright notice and this permission notice appear in all copies.
 *
 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 * WHATSOEVER RESULTING FROM LOSS OF MIND, USE, DATA OR PROFITS, WHETHER
 * IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING
 * OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 */

#include<sys/types.h>

#include<unistd.h>

#include"fdm.h"
#include"fetch.h"

voidfetch_imap_fill(structaccount*, structiolist*);
voidfetch_imap_desc(structaccount*, char*, size_t);

intfetch_imap_connect(structaccount*);
voidfetch_imap_disconnect(structaccount*);

structfetchfetch_imap= {
"imap",
fetch_imap_state_init,

fetch_imap_fill,
imap_commit, /* from imap-common.c */
imap_abort, /* from imap-common.c */
imap_total, /* from imap-common.c */
fetch_imap_desc
};

/* Write line to server. */
int
fetch_imap_putln(structaccount*a, constchar*fmt, va_listap)
{
structfetch_imap_data*data=a->data;

io_vwriteline(data->io, fmt, ap);

return (0);
}

/* Write buffer to server. */
int
fetch_imap_putn(structaccount*a, constchar*buf, size_tlen)
{
structfetch_imap_data*data=a->data;

io_write(data->io, buf, len);

return (0);
}

/* Get line from server. */
int
fetch_imap_getln(structaccount*a, structfetch_ctx*fctx, char**line)
{
structfetch_imap_data*data=a->data;

*line=io_readline2(data->io, &fctx->lbuf, &fctx->llen);
return (0);
}

/* Fill io list. */
void
fetch_imap_fill(structaccount*a, structiolist*iol)
{
structfetch_imap_data*data=a->data;

ARRAY_ADD(iol, data->io);
}

/* Connect to server. */
int
fetch_imap_connect(structaccount*a)
{
structfetch_imap_data*data=a->data;
char*cause;

data->io=connectproxy(&data->server,
conf.verify_certs, conf.proxy, IO_CRLF, conf.timeout, &cause);
if (data->io==NULL) {
log_warnx("%s: %s", a->name, cause);
xfree(cause);
return (-1);
 }
if (conf.debug>3&& !conf.syslog)
data->io->dup_fd=STDOUT_FILENO;

return (0);
}

/* Close connection. */
void
fetch_imap_disconnect(structaccount*a)
{
structfetch_imap_data*data=a->data;

if (data->io!=NULL) {
io_close(data->io);
io_free(data->io);
data->io=NULL;
 }
}

/* IMAP initial state. */
int
fetch_imap_state_init(structaccount*a, structfetch_ctx*fctx)
{
structfetch_imap_data*data=a->data;

data->connect=fetch_imap_connect;
data->getln=fetch_imap_getln;
data->putln=fetch_imap_putln;
data->putn=fetch_imap_putn;
data->disconnect=fetch_imap_disconnect;

data->src=data->server.host;

return (imap_state_init(a, fctx));
}

void
fetch_imap_desc(structaccount*a, char*buf, size_tlen)
{
structfetch_imap_data*data=a->data;
char*folders;

folders=fmt_strings("folders ", data->folders);
xsnprintf(buf, len,
"imap%s server \"%s\" port %s user \"%s\" %s",
data->server.ssl ? "s" : "", data->server.host, data->server.port,
data->user, folders);
xfree(folders);
}