src/lmtp/commands.c

	commands.c revision c4390dad33b03dd51ba2a475f550347c86ebdb9a
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen/* Copyright (c) 2009 Dovecot authors, see the included COPYING file */
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen#include "lib.h"
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen#include "ioloop.h"
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen#include "array.h"
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen#include "str.h"
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen#include "istream.h"
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen#include "ostream.h"
c4390dad33b03dd51ba2a475f550347c86ebdb9aTimo Sirainen#include "istream-dot.h"
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen#include "safe-mkstemp.h"
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen#include "mail-storage-service.h"
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen#include "index/raw/raw-storage.h"
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen#include "lda-settings.h"
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen#include "mail-deliver.h"
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen#include "main.h"
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen#include "client.h"
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen#include "commands.h"
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen#define ERRSTR_MAILBOX_TEMP_FAIL "451 4.2.0 <%s> Temporary internal error"
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainenint cmd_lhlo(struct client *client, const char *args ATTR_UNUSED)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen{
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client_state_reset(client);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client_send_line(client, "250-%s", client->my_domain);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client_send_line(client, "250-8BITMIME");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client_send_line(client, "250-ENHANCEDSTATUSCODES");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client_send_line(client, "250 PIPELINING");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    return 0;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen}
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainenint cmd_mail(struct client *client, const char *args)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen{
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen    const char *addr, *const *argv;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    unsigned int len;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    if (client->state.mail_from != NULL) {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        client_send_line(client, "503 5.5.1 MAIL already given");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        return 0;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen    argv = t_strsplit(args, " ");
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen    if (argv == NULL)
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen        addr = "";
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    else {
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen        addr = argv[0];
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen        argv++;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    len = strlen(addr);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    if (strncasecmp(addr, "FROM:<", 6) != 0 || addr[len-1] != '>') {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        client_send_line(client, "501 5.5.4 Invalid parameters");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        return 0;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen    for (; *argv != NULL; argv++) {
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen        if (strcasecmp(*argv, "BODY=7BIT") == 0 ||
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen            strcasecmp(*argv, "BODY=8BITMIME") == 0) {
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen            /* just skip these */
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen        } else {
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen            client_send_line(client,
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen                "501 5.5.4 Unsupported options");
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen            return 0;
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen        }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client->state.mail_from =
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        p_strndup(client->state_pool, addr + 6, len - 7);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    p_array_init(&client->state.rcpt_to, client->state_pool, 64);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client_send_line(client, "250 2.1.0 OK");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    return 0;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen}
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainenstatic bool rcpt_is_duplicate(struct client *client, const char *name)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen{
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    const struct mail_recipient *rcpts;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    unsigned int i, count;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    rcpts = array_get(&client->state.rcpt_to, &count);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    for (i = 0; i < count; i++) {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        if (strcmp(rcpts[i].name, name) == 0)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen            return TRUE;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    return FALSE;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen}
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainenint cmd_rcpt(struct client *client, const char *args)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen{
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    struct mail_recipient rcpt;
d1fff80640050631b06bfab904a34b2ad24601e8Timo Sirainen    struct mail_storage_service_input input;
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen    const char *name, *error, *addr, *const *argv;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    unsigned int len;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    int ret;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    if (client->state.mail_from == NULL) {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        client_send_line(client, "503 5.5.1 MAIL needed first");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        return 0;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen    argv = t_strsplit(args, " ");
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen    if (argv == NULL)
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen        addr = "";
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen    else {
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen        addr = argv[0];
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen        argv++;
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen    }
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen    len = strlen(addr);
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen    if (strncasecmp(addr, "TO:<", 4) != 0 || addr[len-1] != '>') {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        client_send_line(client, "501 5.5.4 Invalid parameters");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        return 0;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    memset(&rcpt, 0, sizeof(rcpt));
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen    name = t_strndup(addr + 4, len - 5);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    if (rcpt_is_duplicate(client, name)) {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        client_send_line(client, "250 2.1.5 OK, ignoring duplicate");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        return 0;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen    if (*argv != NULL) {
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen        client_send_line(client, "501 5.5.4 Unsupported options");
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen        return 0;
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen    }
65514ab6ccc1889e1667211fddb0cca4b51017dfTimo Sirainen
d1fff80640050631b06bfab904a34b2ad24601e8Timo Sirainen    memset(&input, 0, sizeof(input));
d1fff80640050631b06bfab904a34b2ad24601e8Timo Sirainen    input.username = name;
d1fff80640050631b06bfab904a34b2ad24601e8Timo Sirainen    input.local_ip = client->local_ip;
d1fff80640050631b06bfab904a34b2ad24601e8Timo Sirainen    input.remote_ip = client->remote_ip;
d1fff80640050631b06bfab904a34b2ad24601e8Timo Sirainen
d1fff80640050631b06bfab904a34b2ad24601e8Timo Sirainen    ret = mail_storage_service_multi_lookup(multi_service, &input,
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen                        client->state_pool,
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen                        &rcpt.multi_user, &error);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    if (ret < 0) {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        i_error("User lookup failed: %s", error);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        client_send_line(client,
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen                 "451 4.3.0 Temporary user lookup failure");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        return 0;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    if (ret == 0) {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        client_send_line(client,
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen                 "550 5.1.1 <%s> User doesn't exist", name);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        return 0;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    rcpt.name = p_strdup(client->state_pool, name);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    array_append(&client->state.rcpt_to, &rcpt, 1);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client_send_line(client, "250 2.1.5 OK");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    return 0;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen}
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainenint cmd_quit(struct client *client, const char *args ATTR_UNUSED)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen{
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client_destroy(client, "221 2.0.0", "Logged out");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    return -1;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen}
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainenint cmd_vrfy(struct client *client, const char *args ATTR_UNUSED)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen{
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client_send_line(client, "252 2.3.3 Try RCPT instead");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    return 0;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen}
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainenint cmd_rset(struct client *client, const char *args ATTR_UNUSED)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen{
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client_state_reset(client);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client_send_line(client, "250 2.0.0 OK");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    return 0;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen}
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainenint cmd_noop(struct client *client, const char *args ATTR_UNUSED)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen{
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client_send_line(client, "250 2.0.0 OK");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    return 0;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen}
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainenstatic int
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainenclient_deliver(struct client *client, const struct mail_recipient *rcpt,
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen           struct mail *src_mail)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen{
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    struct mail_deliver_context dctx;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    struct mail_storage *storage;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    void **sets;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    const char *error;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    enum mail_error mail_error;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    int ret;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    i_set_failure_prefix(t_strdup_printf("lmtp(%s): ", rcpt->name));
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    if (mail_storage_service_multi_next(multi_service, rcpt->multi_user,
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen                        &client->state.dest_user,
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen                        &error) < 0) {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        i_error("%s", error);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        client_send_line(client, ERRSTR_MAILBOX_TEMP_FAIL, rcpt->name);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        return -1;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    sets = mail_storage_service_multi_user_get_set(rcpt->multi_user);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    memset(&dctx, 0, sizeof(dctx));
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    dctx.pool = pool_alloconly_create("mail delivery", 1024);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    dctx.set = sets[1];
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    dctx.src_mail = src_mail;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    dctx.src_envelope_sender = client->state.mail_from;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    dctx.dest_user = client->state.dest_user;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    dctx.dest_addr = rcpt->name;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    dctx.dest_mailbox_name = "INBOX";
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    dctx.save_dest_mail = array_count(&client->state.rcpt_to) > 1 &&
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        client->state.first_saved_mail == NULL;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    if (mail_deliver(&dctx, &storage) == 0) {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        if (dctx.dest_mail != NULL) {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen            i_assert(client->state.first_saved_mail == NULL);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen            client->state.first_saved_mail = dctx.dest_mail;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        client_send_line(client, "250 2.0.0 <%s> Saved", rcpt->name);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        ret = 0;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    } else if (storage == NULL) {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        /* This shouldn't happen */
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        i_error("BUG: Saving failed to unknown storage");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        client_send_line(client, ERRSTR_MAILBOX_TEMP_FAIL,
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen                 rcpt->name);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        ret = -1;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    } else {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        error = mail_storage_get_last_error(storage, &mail_error);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        if (mail_error == MAIL_ERROR_NOSPACE) {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen            client_send_line(client, "%s <%s> %s",
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen                     dctx.set->quota_full_tempfail ?
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen                     "452 4.2.2" : "552 5.2.2",
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen                     rcpt->name, error);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        } else {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen            client_send_line(client, "451 4.2.0 <%s> %s",
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen                     rcpt->name, error);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        ret = -1;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    pool_unref(&dctx.pool);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    return ret;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen}
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainenstatic bool client_deliver_next(struct client *client, struct mail *src_mail)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen{
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    const struct mail_recipient *rcpts;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    unsigned int count;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    int ret;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    rcpts = array_get(&client->state.rcpt_to, &count);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    while (client->state.rcpt_idx < count) {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        ret = client_deliver(client, &rcpts[client->state.rcpt_idx],
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen                     src_mail);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        i_set_failure_prefix("lmtp: ");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        client->state.rcpt_idx++;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        if (ret == 0)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen            return TRUE;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        /* failed. try the next one. */
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        if (client->state.dest_user != NULL)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen            mail_user_unref(&client->state.dest_user);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    return FALSE;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen}
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainenstatic void client_rcpt_fail_all(struct client *client)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen{
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    const struct mail_recipient *rcpts;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    unsigned int i, count;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    rcpts = array_get(&client->state.rcpt_to, &count);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    for (i = 0; i < count; i++) {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        client_send_line(client, ERRSTR_MAILBOX_TEMP_FAIL,
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen                 rcpts[i].name);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen}
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainenstatic int client_open_raw_mail(struct client *client)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen{
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    static const char *wanted_headers[] = {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        "From", "To", "Message-ID", "Subject", "Return-Path",
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        NULL
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    };
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen    struct mailbox_list *raw_list = client->raw_mail_user->namespaces->list;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    struct mailbox *box;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    struct raw_mailbox *raw_box;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    struct mailbox_header_lookup_ctx *headers_ctx;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    struct istream *input;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    enum mail_error error;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    if (client->state.mail_data_output != NULL) {
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen        o_stream_unref(&client->state.mail_data_output);
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen        input = i_stream_create_fd(client->state.mail_data_fd,
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen                       MAIL_READ_BLOCK_SIZE, FALSE);
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    } else {
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen        input = i_stream_create_from_data(client->state.mail_data->data,
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen                          client->state.mail_data->used);
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client->state.raw_box = box =
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen        mailbox_alloc(raw_list, "Dovecot Delivery Mail", input,
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen                  MAILBOX_FLAG_NO_INDEX_FILES);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    i_stream_unref(&input);
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen    if (mailbox_open(box) < 0 ||
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen        mailbox_sync(box, 0, 0, NULL) < 0) {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        i_error("Can't open delivery mail as raw: %s",
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen            mail_storage_get_last_error(box->storage, &error));
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen        mailbox_close(&box);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        client_rcpt_fail_all(client);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        return -1;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    raw_box = (struct raw_mailbox *)box;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    raw_box->envelope_sender = client->state.mail_from;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client->state.raw_trans = mailbox_transaction_begin(box, 0);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    headers_ctx = mailbox_header_lookup_init(box, wanted_headers);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client->state.raw_mail = mail_alloc(client->state.raw_trans,
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen                        0, headers_ctx);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    mailbox_header_lookup_unref(&headers_ctx);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    mail_set_seq(client->state.raw_mail, 1);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    return 0;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen}
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainenstatic void client_input_data_finish(struct client *client)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen{
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    struct mail *src_mail;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
c4390dad33b03dd51ba2a475f550347c86ebdb9aTimo Sirainen    i_stream_destroy(&client->dot_input);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    io_remove(&client->io);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client->io = io_add(client->fd_in, IO_READ, client_input, client);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    if (client_open_raw_mail(client) < 0)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        return;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    /* save the message to the first recipient's mailbox */
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    src_mail = client->state.raw_mail;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    if (!client_deliver_next(client, src_mail))
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        return;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    if (client->state.first_saved_mail == NULL)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        mail_user_unref(&client->state.dest_user);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    else
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        src_mail = client->state.first_saved_mail;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    /* use the first saved message to save it elsewhere too.
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen       this might allow hard linking the files. */
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    while (client_deliver_next(client, src_mail))
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        mail_user_unref(&client->state.dest_user);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    if (client->state.first_saved_mail != NULL) {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        struct mail *mail = client->state.first_saved_mail;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        struct mailbox_transaction_context *trans = mail->transaction;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        struct mailbox *box = trans->box;
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen        struct mail_user *user = box->storage->user;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        mail_free(&mail);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        mailbox_transaction_rollback(&trans);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        mailbox_close(&box);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        mail_user_unref(&user);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen}
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainenstatic int client_input_add_file(struct client *client,
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen                 const unsigned char *data, size_t size)
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen{
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    string_t *path;
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    int fd;
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    if (client->state.mail_data_output != NULL) {
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen        /* continue writing to file */
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen        if (o_stream_send(client->state.mail_data_output,
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen                  data, size) != (ssize_t)size)
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen            return -1;
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen        return 0;
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    }
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    /* move everything to a temporary file. FIXME: it really shouldn't
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen       be in /tmp.. */
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    path = t_str_new(256);
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    str_append(path, "/tmp/dovecot.lmtp.");
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    fd = safe_mkstemp_hostpid(path, 0600, (uid_t)-1, (gid_t)-1);
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    if (fd == -1)
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen        return -1;
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    /* we just want the fd, unlink it */
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    if (unlink(str_c(path)) < 0) {
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen        /* shouldn't happen.. */
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen        i_error("unlink(%s) failed: %m", str_c(path));
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen        (void)close(fd);
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen        return -1;
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    }
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    client->state.mail_data_fd = fd;
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    client->state.mail_data_output = o_stream_create_fd_file(fd, 0, FALSE);
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    o_stream_cork(client->state.mail_data_output);
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    if (o_stream_send(client->state.mail_data_output,
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen              data, size) != (ssize_t)size)
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen        return -1;
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    return 0;
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen}
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainenstatic int
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainenclient_input_add(struct client *client, const unsigned char *data, size_t size)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen{
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    if (client->state.mail_data->used + size <=
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen        CLIENT_MAIL_DATA_MAX_INMEMORY_SIZE) {
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen        buffer_append(client->state.mail_data, data, size);
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen        return 0;
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    } else {
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen        return client_input_add_file(client, data, size);
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen}
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainenstatic void client_input_data_handle(struct client *client)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen{
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    const unsigned char *data;
c4390dad33b03dd51ba2a475f550347c86ebdb9aTimo Sirainen    size_t size;
c4390dad33b03dd51ba2a475f550347c86ebdb9aTimo Sirainen    ssize_t ret;
c4390dad33b03dd51ba2a475f550347c86ebdb9aTimo Sirainen
c4390dad33b03dd51ba2a475f550347c86ebdb9aTimo Sirainen    while ((ret = i_stream_read(client->dot_input)) > 0 || ret == -2) {
c4390dad33b03dd51ba2a475f550347c86ebdb9aTimo Sirainen        data = i_stream_get_data(client->dot_input, &size);
c4390dad33b03dd51ba2a475f550347c86ebdb9aTimo Sirainen        if (client_input_add(client, data, size) < 0) {
c4390dad33b03dd51ba2a475f550347c86ebdb9aTimo Sirainen            client_destroy(client, "451 4.3.0",
c4390dad33b03dd51ba2a475f550347c86ebdb9aTimo Sirainen                       "Temporary internal failure");
c4390dad33b03dd51ba2a475f550347c86ebdb9aTimo Sirainen            return;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        }
c4390dad33b03dd51ba2a475f550347c86ebdb9aTimo Sirainen        i_stream_skip(client->dot_input, size);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    }
c4390dad33b03dd51ba2a475f550347c86ebdb9aTimo Sirainen    if (ret == 0)
dd3ccdbb29dad006f7781ea138a5ba39727963c4Timo Sirainen        return;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
c4390dad33b03dd51ba2a475f550347c86ebdb9aTimo Sirainen    client_input_data_finish(client);
c4390dad33b03dd51ba2a475f550347c86ebdb9aTimo Sirainen    client_state_reset(client);
c4390dad33b03dd51ba2a475f550347c86ebdb9aTimo Sirainen    if (i_stream_have_bytes_left(client->input))
c4390dad33b03dd51ba2a475f550347c86ebdb9aTimo Sirainen        client_input_handle(client);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen}
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainenstatic void client_input_data(struct client *client)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen{
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    if (client_input_read(client) < 0)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        return;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client_input_data_handle(client);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen}
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainenint cmd_data(struct client *client, const char *args ATTR_UNUSED)
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen{
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    if (client->state.mail_from == NULL) {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        client_send_line(client, "503 5.5.1 MAIL needed first");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        return 0;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    if (array_count(&client->state.rcpt_to) == 0) {
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        client_send_line(client, "554 5.5.1 No valid recipients");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen        return 0;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    }
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    i_assert(client->state.mail_data == NULL);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client->state.mail_data = buffer_create_dynamic(default_pool, 1024*64);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
c4390dad33b03dd51ba2a475f550347c86ebdb9aTimo Sirainen    i_assert(client->dot_input == NULL);
c4390dad33b03dd51ba2a475f550347c86ebdb9aTimo Sirainen    client->dot_input = i_stream_create_dot(client->input, TRUE);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    io_remove(&client->io);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client->io = io_add(client->fd_in, IO_READ, client_input_data, client);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client_send_line(client, "354 OK");
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    client_input_data_handle(client);
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen    return -1;
315ce5be539bfe8bc7777ab0654499c49583cea2Timo Sirainen}