#include <stdio.h>
#include <stdlib.h>
#include <string.h>
+#include <sysexits.h>
#include <unistd.h>
-#include "brum.h"
-
-#define BUFSIZE 1024
+#include "umpf.h"
+#define MAIL_LEN 65536
int curbufsize;
else {
*p = 0;
new->value = xstrdup(p+1);
+ p = strrchr(new->value, '\n');
+ if (p && !*(p+1))
+ *p = 0;
}
new->name = xstrdup(buf);
}
last = c;
}
- free(buf);
+ free_string(buf);
return l;
}
-char*
+struct email*
get_body(void)
{
char* buf;
- int c;
+ struct email* b;
+ int c, fd;
+ int will_save = 0;
int i = 0;
- int curbufsize = BUFSIZE;
+ int curbufsize = MAIL_LEN;
+ char* tmpfile;
+ int res;
+
+ buf = xmalloc(MAIL_LEN);
+ b = xmalloc(sizeof(struct email));
+ b->body = buf;
+ b->tmpfile = NULL;
+ b->fd = -1;
- buf = xmalloc(BUFSIZE);
+ /* read mail body, if it is too big, try to make tmp file */
while ((c = getchar()) != EOF){
buf[i++] = c;
-
- if (i >= curbufsize - 1)
- buf = xrealloc(buf, curbufsize *= 2);
+ if (i >= curbufsize - 1) {
+ tmpfile = xstrdup("/tmp/umpf.XXXXXX");
+ fd = mkstemp(tmpfile);
+ /* cannot create tmpfile, try to continue reading */
+ if (fd < 0)
+ bye(EX_TEMPFAIL, "%m");
+ else {
+ will_save = 1;
+ b->body = NULL;
+ b->tmpfile = tmpfile;
+ b->fd = fd;
+ res = write(fd, buf, MAIL_LEN);
+ if (res < MAIL_LEN) {
+ unlink(b->tmpfile);
+ bye(EX_TEMPFAIL, "%m");
+ }
+ break;
+ }
+ }
}
-
- buf[i] = 0;
-
- return buf;
+ b->body_len = i;
+ /* save rest of the body to the tmpfile */
+ if (will_save) {
+ int j = 0;
+ while ((c = getchar()) != EOF){
+ buf[j++] = c;
+ b->body_len++;
+ if (j >= MAIL_LEN) {
+ j = 0;
+ res = write(fd, buf, MAIL_LEN);
+ if (res < MAIL_LEN) {
+ unlink(b->tmpfile);
+ bye(EX_TEMPFAIL, "%m");
+ }
+ }
+ }
+ res = write(fd, buf, j);
+ if (res < j) {
+ unlink(b->tmpfile);
+ bye(EX_TEMPFAIL, "%m");
+ }
+ }
+ return b;
}
void
struct hlist* p;
LIST_FOREACH(p,l)
- printf("%s:%s",p->name,p->value);
+ printf("%s:%s\n",p->name,p->value);
}
static void
-write_char_to_mailbox(char c, int fd)
+flush_mbox_buffer(int fd)
{
+ if (mbox_write_err || !mbox_write_pos)
+ return;
+
int res;
+ res = write(fd, mbox_write_buf, mbox_write_pos);
+ if (res < 0)
+ mbox_write_err++;
+ mbox_write_pos = 0;
+}
- if (mbox_write_err)
- return;
+static void
+write_char_to_mailbox(char c, int fd)
+{
+ int res;
- if (!c){
- if (!mbox_write_pos)
- return;
- res = write(fd, mbox_write_buf, mbox_write_pos);
- if (res < 0)
- mbox_write_err++;
- mbox_write_pos = 0;
- return;
- }
if (mbox_write_pos >= BUFSIZE){
res = write(fd, mbox_write_buf, BUFSIZE);
if (res < 0)
mbox_write_buf[mbox_write_pos++] = c;
}
+int email_pos;
+int headers_sent;
+int email_opened;
+
+void
+open_email(void)
+{
+ email_pos = 0;
+ headers_sent = 0;
+ email_opened = 1;
+}
+
+char*
+read_email(struct email* em)
+{
+ char* buf;
+ int r, pos;
+
+ if (! email_opened) {
+ chars_written = 0;
+ return NULL;
+ }
+
+ if (! headers_sent) {
+ struct hlist* ph;
+ int curbufsize = BUFSIZE;
+ buf = xmalloc(BUFSIZE);
+ pos = 0;
+
+ LIST_FOREACH(ph, em->headers){
+ int needed = strlen(ph->name) + strlen(ph->value) + 3;
+ if (curbufsize < pos + needed)
+ buf = xrealloc(buf, curbufsize*=2);
+ strcpy(buf + pos, ph->name);
+ pos += strlen(ph->name);
+ buf[pos++] = ':';
+ strcpy(buf + pos, ph->value);
+ pos += strlen(ph->value);
+ buf[pos++] = '\n';
+
+ }
+ buf[pos] = '\n';
+ headers_sent = 1;
+ chars_written = pos;
+ return buf;
+ }
+
+ if (em->body) {
+ buf = xstrdup(em->body);
+ chars_written = em->body_len;
+ //printf("%d: %s\n", em->body_len, em->body);
+ email_opened = 0;
+ return buf;
+ }
+
+ if (! email_pos)
+ lseek(em->fd, 0, SEEK_SET);
+
+ buf = xmalloc(MAIL_LEN + 1);
+ r = read(em->fd, buf, MAIL_LEN);
+ if (r < MAIL_LEN)
+ email_opened = 0;
+ chars_written = r;
+
+ return buf;
+}
+
+int
+write_email_to_fd(int fd, struct email* email)
+{
+ char* buf;
+ int wr;
+
+ open_email();
+ do {
+ buf = read_email(email);
+ wr = write(fd, buf, chars_written);
+ if (wr < chars_written)
+ return 1;
+ } while (chars_written);
+
+ return 0;
+}
+
/* try to copy e-mail to mailbox, if it fails,
truncate mailbox to the original size */
static int
off_t mb_end;
mb_end = lseek(fd, 0, SEEK_END);
- if (mb_end < 1)
+ if (mb_end < 0)
return -1;
/* init globals */
for (pc = ph->name; *pc; pc++)
write_char_to_mailbox(*pc, fd);
write_char_to_mailbox(':', fd);
- write_char_to_mailbox(' ', fd);
for (pc = ph->value; *pc; pc++)
write_char_to_mailbox(*pc, fd);
write_char_to_mailbox('\n', fd);
write_char_to_mailbox('\n', fd);
/* body */
- //FIXME that nasty FROM
- for (pc = email->body; *pc; pc++){
- write_char_to_mailbox(*pc, fd);
- }
+ /* FIXME: do not forget change Content-Length */
+ if (email->body) {
+ for (pc = email->body; pc < email->body + email->body_len; pc++){
+ write_char_to_mailbox(*pc, fd);
+ if (*pc == '\n'){
+ if ((pc + 5 < email->body + email->body_len)
+ && pc[1] == 'F' && pc[2] == 'r'
+ && pc[3] == 'o' && pc[4] == 'm'
+ && pc[5] == ' ')
+ write_char_to_mailbox('>', fd);
+ }
+ }
+ } else {
+ int i;
+ char buf[MAIL_LEN];
+ for(i = 0; i < email->body_len; i+=MAIL_LEN) {
+ int len = MAIL_LEN;
+ if (i >= email->body_len)
+ len = len - (i - email->body_len);
+ read(email->fd, buf, len); //FIXME: check it?
+ for (pc = buf; pc < buf + len; pc++) {
+ write_char_to_mailbox(*pc, fd);
+ if (*pc == '\n'){
+ if ((pc + 5 < email->body + email->body_len)
+ && pc[1] == 'F' && pc[2] == 'r'
+ && pc[3] == 'o' && pc[4] == 'm'
+ && pc[5] == ' ')
+ write_char_to_mailbox('>', fd);
+ }
+ }
+ }
+ }
- /* flush the buffer */
- write_char_to_mailbox(0, fd);
+ flush_mbox_buffer(fd);
/* errors? */
- if (mbox_write_err)
- return -1;
+ if (mbox_write_err){
+ /* try to truncate to the original length */
+ ftruncate(fd, mb_end);
+ return -1;
+ }
return 0;
}
-static int
+int
deliver_local_email(char* folder, struct email* email)
{
int res = -1;
return res;
}
-
-void
-do_action(struct action* a)
-{
- /* -> address */
- if (! a->r && !a->l ){
- deliver_local_email(a->s, &a->e);
- }
-}