#include "lib.h"
#include "ioloop.h"
#include "array.h"
#include "str.h"
#include "str-sanitize.h"
#include "var-expand.h"
#include "message-address.h"
#include "imap-utf7.h"
#include "lda-settings.h"
#include "mail-storage.h"
#include "mail-namespace.h"
#include "duplicate.h"
#include "mail-deliver.h"
deliver_mail_func_t *deliver_mail = NULL;
#ifdef APPLE_OS_X_SERVER
deliver_hook_func_t *deliver_hook = NULL;
#endif
static const char *lda_log_wanted_headers[] = {
"From", "Message-ID", "Subject",
NULL
};
static enum mail_fetch_field lda_log_wanted_fetch_fields =
MAIL_FETCH_PHYSICAL_SIZE | MAIL_FETCH_VIRTUAL_SIZE;
const char *mail_deliver_get_address(struct mail *mail, const char *header)
{
struct message_address *addr;
const char *str;
if (mail_get_first_header(mail, header, &str) <= 0)
return NULL;
addr = message_address_parse(pool_datastack_create(),
(const unsigned char *)str,
strlen(str), 1, FALSE);
return addr == NULL || addr->mailbox == NULL || addr->domain == NULL ||
*addr->mailbox == '\0' || *addr->domain == '\0' ?
NULL : t_strconcat(addr->mailbox, "@", addr->domain, NULL);
}
const struct var_expand_table *
mail_deliver_get_log_var_expand_table(struct mail *mail, const char *message)
{
static struct var_expand_table static_tab[] = {
{ '$', NULL, NULL },
{ 'm', NULL, "msgid" },
{ 's', NULL, "subject" },
{ 'f', NULL, "from" },
{ 'p', NULL, "size" },
{ 'w', NULL, "vsize" },
{ '\0', NULL, NULL }
};
struct var_expand_table *tab;
uoff_t size;
tab = t_malloc(sizeof(static_tab));
memcpy(tab, static_tab, sizeof(static_tab));
tab[0].value = message;
(void)mail_get_first_header(mail, "Message-ID", &tab[1].value);
tab[1].value = tab[1].value == NULL ? "unspecified" :
str_sanitize(tab[1].value, 200);
(void)mail_get_first_header_utf8(mail, "Subject", &tab[2].value);
tab[2].value = str_sanitize(tab[2].value, 80);
tab[3].value = str_sanitize(mail_deliver_get_address(mail, "From"), 80);
if (mail_get_physical_size(mail, &size) == 0)
tab[4].value = dec2str(size);
if (mail_get_virtual_size(mail, &size) == 0)
tab[5].value = dec2str(size);
return tab;
}
static void
mail_deliver_log_cache_var_expand_table(struct mail_deliver_context *ctx)
{
const struct var_expand_table *src;
struct var_expand_table *dest;
struct mail *mail;
unsigned int i, len;
mail = ctx->dest_mail != NULL ? ctx->dest_mail : ctx->src_mail;
src = mail_deliver_get_log_var_expand_table(mail, "");
for (len = 0; src[len].key != '\0'; len++) ;
dest = p_new(ctx->pool, struct var_expand_table, len + 1);
for (i = 0; i < len; i++) {
dest[i] = src[i];
dest[i].value = p_strdup(ctx->pool, src[i].value);
}
ctx->var_expand_table = dest;
}
void mail_deliver_log(struct mail_deliver_context *ctx, const char *fmt, ...)
{
va_list args;
string_t *str;
const char *msg;
if (*ctx->set->deliver_log_format == '\0')
return;
va_start(args, fmt);
msg = t_strdup_vprintf(fmt, args);
str = t_str_new(256);
if (ctx->session_id != NULL)
str_printfa(str, "%s: ", ctx->session_id);
if (ctx->var_expand_table == NULL)
mail_deliver_log_cache_var_expand_table(ctx);
ctx->var_expand_table[0].value = msg;
var_expand(str, ctx->set->deliver_log_format, ctx->var_expand_table);
ctx->var_expand_table[0].value = "";
i_info("%s", str_c(str));
va_end(args);
}
struct mail_deliver_session *mail_deliver_session_init(void)
{
struct mail_deliver_session *session;
pool_t pool;
pool = pool_alloconly_create("mail deliver session", 1024);
session = p_new(pool, struct mail_deliver_session, 1);
session->pool = pool;
return session;
}
void mail_deliver_session_deinit(struct mail_deliver_session **_session)
{
struct mail_deliver_session *session = *_session;
*_session = NULL;
pool_unref(&session->pool);
}
static const char *mailbox_name_to_mutf7(const char *mailbox_utf8)
{
string_t *str = t_str_new(128);
if (imap_utf8_to_utf7(mailbox_utf8, str) < 0)
return mailbox_utf8;
else
return str_c(str);
}
int mail_deliver_save_open(struct mail_deliver_save_open_context *ctx,
const char *name, struct mailbox **box_r,
enum mail_error *error_r, const char **error_str_r)
{
struct mail_namespace *ns;
struct mail_storage *storage;
struct mailbox *box;
enum mailbox_flags flags =
MAILBOX_FLAG_KEEP_RECENT | MAILBOX_FLAG_SAVEONLY |
MAILBOX_FLAG_POST_SESSION;
*box_r = NULL;
*error_r = MAIL_ERROR_NONE;
*error_str_r = NULL;
name = mailbox_name_to_mutf7(name);
ns = mail_namespace_find(ctx->user->namespaces, &name);
if (ns == NULL) {
*error_str_r = "Unknown namespace";
*error_r = MAIL_ERROR_PARAMS;
return -1;
}
if (*name == '\0' && (ns->flags & NAMESPACE_FLAG_INBOX_USER) != 0) {
name = "INBOX";
ns = mail_namespace_find_inbox(ctx->user->namespaces);
}
if (strcasecmp(name, "INBOX") == 0) {
flags |= MAILBOX_FLAG_IGNORE_ACLS;
}
*box_r = box = mailbox_alloc(ns->list, name, flags);
if (mailbox_open(box) == 0)
return 0;
storage = mailbox_get_storage(box);
*error_str_r = mail_storage_get_last_error(storage, error_r);
if (!ctx->lda_mailbox_autocreate || *error_r != MAIL_ERROR_NOTFOUND)
return -1;
if (mailbox_create(box, NULL, FALSE) < 0) {
*error_str_r = mail_storage_get_last_error(storage, error_r);
if (*error_r != MAIL_ERROR_EXISTS)
return -1;
}
if (ctx->lda_mailbox_autosubscribe) {
(void)mailbox_list_set_subscribed(ns->list, name, TRUE);
}
if (mailbox_sync(box, 0) < 0) {
*error_str_r = mail_storage_get_last_error(storage, error_r);
return -1;
}
return 0;
}
static bool mail_deliver_check_duplicate(struct mail_deliver_session *session,
struct mailbox *box)
{
uint8_t box_guid[MAIL_GUID_128_SIZE];
const mail_guid_128_t *guid;
if (mailbox_get_guid(box, box_guid) < 0) {
return TRUE;
}
if (!array_is_created(&session->inbox_guids))
p_array_init(&session->inbox_guids, session->pool, 8);
array_foreach(&session->inbox_guids, guid) {
if (memcmp(box_guid, guid, sizeof(box_guid)) == 0)
return TRUE;
}
array_append(&session->inbox_guids, &box_guid, 1);
return FALSE;
}
void mail_deliver_deduplicate_guid_if_needed(struct mail_deliver_session *session,
struct mail_save_context *save_ctx)
{
struct mailbox_transaction_context *trans =
mailbox_save_get_transaction(save_ctx);
struct mailbox *box = mailbox_transaction_get_mailbox(trans);
uint8_t guid[MAIL_GUID_128_SIZE];
if (strcmp(mailbox_get_name(box), "INBOX") != 0)
return;
if (mail_deliver_check_duplicate(session, box)) {
mail_generate_guid_128(guid);
mailbox_save_set_guid(save_ctx, mail_guid_128_to_string(guid));
}
}
int mail_deliver_save(struct mail_deliver_context *ctx, const char *mailbox,
enum mail_flags flags, const char *const *keywords,
struct mail_storage **storage_r)
{
struct mail_deliver_save_open_context open_ctx;
struct mailbox *box;
enum mailbox_transaction_flags trans_flags;
struct mailbox_transaction_context *t;
struct mail_save_context *save_ctx;
struct mailbox_header_lookup_ctx *headers_ctx;
struct mail_keywords *kw;
enum mail_error error;
const char *mailbox_name, *errstr;
struct mail_transaction_commit_changes changes;
const struct seq_range *range;
bool default_save;
int ret = 0;
i_assert(ctx->dest_mail == NULL);
default_save = strcmp(mailbox, ctx->dest_mailbox_name) == 0;
if (default_save)
ctx->tried_default_save = TRUE;
memset(&open_ctx, 0, sizeof(open_ctx));
open_ctx.user = ctx->dest_user;
open_ctx.lda_mailbox_autocreate = ctx->set->lda_mailbox_autocreate;
open_ctx.lda_mailbox_autosubscribe = ctx->set->lda_mailbox_autosubscribe;
mailbox_name = str_sanitize(mailbox, 80);
if (mail_deliver_save_open(&open_ctx, mailbox, &box,
&error, &errstr) < 0) {
if (box != NULL)
mailbox_free(&box);
mail_deliver_log(ctx, "save failed to open mailbox %s: %s",
mailbox_name, errstr);
return -1;
}
*storage_r = mailbox_get_storage(box);
trans_flags = MAILBOX_TRANSACTION_FLAG_EXTERNAL;
if (ctx->save_dest_mail)
trans_flags |= MAILBOX_TRANSACTION_FLAG_ASSIGN_UIDS;
t = mailbox_transaction_begin(box, trans_flags);
kw = str_array_length(keywords) == 0 ? NULL :
mailbox_keywords_create_valid(box, keywords);
save_ctx = mailbox_save_alloc(t);
if (ctx->src_envelope_sender != NULL)
mailbox_save_set_from_envelope(save_ctx, ctx->src_envelope_sender);
mailbox_save_set_flags(save_ctx, flags, kw);
headers_ctx = mailbox_header_lookup_init(box, lda_log_wanted_headers);
ctx->dest_mail = mail_alloc(t, lda_log_wanted_fetch_fields, NULL);
mailbox_header_lookup_unref(&headers_ctx);
mailbox_save_set_dest_mail(save_ctx, ctx->dest_mail);
mail_deliver_deduplicate_guid_if_needed(ctx->session, save_ctx);
if (mailbox_copy(&save_ctx, ctx->src_mail) < 0)
ret = -1;
else
mail_deliver_log_cache_var_expand_table(ctx);
if (kw != NULL)
mailbox_keywords_unref(box, &kw);
mail_free(&ctx->dest_mail);
if (ret < 0)
mailbox_transaction_rollback(&t);
else
ret = mailbox_transaction_commit_get_changes(&t, &changes);
if (ret == 0) {
ctx->saved_mail = TRUE;
mail_deliver_log(ctx, "saved mail to %s", mailbox_name);
if (ctx->save_dest_mail && mailbox_sync(box, 0) == 0) {
range = array_idx(&changes.saved_uids, 0);
i_assert(range[0].seq1 == range[0].seq2);
t = mailbox_transaction_begin(box, 0);
ctx->dest_mail = mail_alloc(t, MAIL_FETCH_STREAM_BODY,
NULL);
if (!mail_set_uid(ctx->dest_mail, range[0].seq1)) {
mail_free(&ctx->dest_mail);
mailbox_transaction_rollback(&t);
}
}
pool_unref(&changes.pool);
#ifdef APPLE_OS_X_SERVER
if (deliver_hook != NULL)
deliver_hook(ctx, mailbox);
#endif
} else {
mail_deliver_log(ctx, "save failed to %s: %s", mailbox_name,
mail_storage_get_last_error(*storage_r, &error));
}
if (ctx->dest_mail == NULL)
mailbox_free(&box);
return ret;
}
const char *mail_deliver_get_return_address(struct mail_deliver_context *ctx)
{
if (ctx->src_envelope_sender != NULL)
return ctx->src_envelope_sender;
return mail_deliver_get_address(ctx->src_mail, "Return-Path");
}
const char *mail_deliver_get_new_message_id(struct mail_deliver_context *ctx)
{
static int count = 0;
return t_strdup_printf("<dovecot-%s-%s-%d@%s>",
dec2str(ioloop_timeval.tv_sec),
dec2str(ioloop_timeval.tv_usec),
count++, ctx->set->hostname);
}
int mail_deliver(struct mail_deliver_context *ctx,
struct mail_storage **storage_r)
{
int ret;
*storage_r = NULL;
if (deliver_mail == NULL)
ret = -1;
else {
ctx->dup_ctx = duplicate_init(ctx->dest_user);
if (deliver_mail(ctx, storage_r) <= 0) {
ret = ctx->saved_mail ? 0 : -1;
} else {
ret = 0;
}
#ifdef APPLE_OS_X_SERVER
if (!ret && deliver_hook)
deliver_hook(ctx, ctx->dest_mailbox_name);
#endif
duplicate_deinit(&ctx->dup_ctx);
}
if (ret < 0 && !ctx->tried_default_save) {
ret = mail_deliver_save(ctx, ctx->dest_mailbox_name, 0, NULL,
storage_r);
}
if (ret < 0 && strcasecmp(ctx->dest_mailbox_name, "INBOX") != 0) {
ret = mail_deliver_save(ctx, "INBOX", 0, NULL, storage_r);
}
return ret;
}
deliver_mail_func_t *mail_deliver_hook_set(deliver_mail_func_t *new_hook)
{
deliver_mail_func_t *old_hook = deliver_mail;
deliver_mail = new_hook;
return old_hook;
}