deliver-pipe.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<errno.h>
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<unistd.h>

#include"fdm.h"
#include"deliver.h"

intdeliver_pipe_deliver(structdeliver_ctx*, structactitem*);
voiddeliver_pipe_desc(structactitem*, char*, size_t);

structdeliverdeliver_pipe= {
"pipe",
DELIVER_ASUSER,
deliver_pipe_deliver,
deliver_pipe_desc
};

int
deliver_pipe_deliver(structdeliver_ctx*dctx, structactitem*ti)
{
structaccount*a=dctx->account;
structmail*m=dctx->mail;
structdeliver_pipe_data*data=ti->data;
char*s, *cause, *err;
intstatus;
structcmd*cmd=NULL;
char*lbuf;
size_tllen;

s=replacepath(&data->cmd, m->tags, m, &m->rml, dctx->udata->home);
if (s==NULL||*s=='\0') {
log_warnx("%s: empty command", a->name);
 goto error;
 }

if (data->pipe) {
log_debug2("%s: piping to \"%s\"", a->name, s);
cmd=cmd_start(s, CMD_IN|CMD_ONCE, m->data, m->size, &cause);
 } else {
log_debug2("%s: executing \"%s\"", a->name, s);
cmd=cmd_start(s, 0, NULL, 0, &cause);
 }
if (cmd==NULL)
 goto error_cause;
log_debug3("%s: %s: started", a->name, s);

llen=IO_LINESIZE;
lbuf=xmalloc(llen);

do {
status=cmd_poll(
cmd, NULL, &err, &lbuf, &llen, conf.timeout, &cause);
if (status==-1) {
xfree(lbuf);
 goto error_cause;
 }
if (status==0&&err!=NULL)
log_warnx("%s: %s: %s", a->name, s, err);
 } while (status==0);
status--;

xfree(lbuf);

if (status!=0) {
log_warnx("%s: %s: command returned %d", a->name, s, status);
 goto error;
 }

cmd_free(cmd);
xfree(s);
return (DELIVER_SUCCESS);

error_cause:
log_warnx("%s: %s: %s", a->name, s, cause);
xfree(cause);

error:
if (cmd!=NULL)
cmd_free(cmd);
if (s!=NULL)
xfree(s);
return (DELIVER_FAILURE);
}

void
deliver_pipe_desc(structactitem*ti, char*buf, size_tlen)
{
structdeliver_pipe_data*data=ti->data;

if (data->pipe)
xsnprintf(buf, len, "pipe \"%s\"", data->cmd.str);
else
xsnprintf(buf, len, "exec \"%s\"", data->cmd.str);
}