commands.c revision 4afd50dff16661684ad2acddad7284bcd8c564db
bcb4e51a409d94ae670de96afb8483a4f7855294Stephan Bosch/* Copyright (c) 2009-2010 Dovecot authors, see the included COPYING file */
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen#include "lib.h"
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen#include "ioloop.h"
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen#include "array.h"
20b2d47ed762ca2c009aa37e360af6f223ac71bdTimo Sirainen#include "str.h"
20b2d47ed762ca2c009aa37e360af6f223ac71bdTimo Sirainen#include "strescape.h"
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen#include "hostpid.h"
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen#include "istream.h"
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen#include "istream-concat.h"
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen#include "ostream.h"
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen#include "istream-dot.h"
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen#include "safe-mkstemp.h"
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen#include "master-service.h"
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen#include "rfc822-parser.h"
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen#include "message-date.h"
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen#include "auth-master.h"
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen#include "mail-storage-service.h"
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen#include "index/raw/raw-storage.h"
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen#include "lda-settings.h"
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen#include "lmtp-settings.h"
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen#include "mail-namespace.h"
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen#include "mail-deliver.h"
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen#include "main.h"
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen#include "client.h"
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen#include "commands.h"
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen#include "lmtp-proxy.h"
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen#include <stdlib.h>
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen#define ERRSTR_TEMP_MAILBOX_FAIL "451 4.3.0 <%s> Temporary internal error"
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen#define ERRSTR_TEMP_USERDB_FAIL_PREFIX "451 4.3.0 <%s> "
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen#define ERRSTR_TEMP_USERDB_FAIL \
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen ERRSTR_TEMP_USERDB_FAIL_PREFIX "Temporary user lookup failure"
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen#define LMTP_PROXY_DEFAULT_TIMEOUT_MSECS (1000*30)
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainenint cmd_lhlo(struct client *client, const char *args)
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen{
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen struct rfc822_parser_context parser;
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen string_t *domain = t_str_new(128);
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen const char *p;
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen int ret = 0;
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen if (*args == '\0') {
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen client_send_line(client, "501 Missing hostname");
20b2d47ed762ca2c009aa37e360af6f223ac71bdTimo Sirainen return 0;
20b2d47ed762ca2c009aa37e360af6f223ac71bdTimo Sirainen }
20b2d47ed762ca2c009aa37e360af6f223ac71bdTimo Sirainen
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen /* domain / address-literal */
20b2d47ed762ca2c009aa37e360af6f223ac71bdTimo Sirainen rfc822_parser_init(&parser, (const unsigned char *)args, strlen(args),
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen NULL);
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen if (*args != '[')
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen ret = rfc822_parse_dot_atom(&parser, domain);
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen else {
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen for (p = args+1; *p != ']'; p++) {
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen if (*p == '\\' || *p == '[')
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen break;
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen }
0de1e3762d960366b5e311cad2b80b5d66f82c5bTimo Sirainen if (strcmp(p, "]") != 0)
0de1e3762d960366b5e311cad2b80b5d66f82c5bTimo Sirainen ret = -1;
0de1e3762d960366b5e311cad2b80b5d66f82c5bTimo Sirainen }
0de1e3762d960366b5e311cad2b80b5d66f82c5bTimo Sirainen if (ret < 0) {
0de1e3762d960366b5e311cad2b80b5d66f82c5bTimo Sirainen str_truncate(domain, 0);
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen str_append(domain, "invalid");
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen }
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen client_state_reset(client);
c2fbbf7515aa419dc8b2d62a3c2bb0471d51a391Timo Sirainen client_send_line(client, "250-%s", client->my_domain);
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen client_send_line(client, "250-8BITMIME");
20b2d47ed762ca2c009aa37e360af6f223ac71bdTimo Sirainen client_send_line(client, "250-ENHANCEDSTATUSCODES");
20b2d47ed762ca2c009aa37e360af6f223ac71bdTimo Sirainen client_send_line(client, "250 PIPELINING");
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen
20b2d47ed762ca2c009aa37e360af6f223ac71bdTimo Sirainen client->state.lhlo = p_strdup(client->state_pool, str_c(domain));
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen return 0;
20b2d47ed762ca2c009aa37e360af6f223ac71bdTimo Sirainen}
20b2d47ed762ca2c009aa37e360af6f223ac71bdTimo Sirainen
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainenint cmd_mail(struct client *client, const char *args)
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen{
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen const char *addr, *const *argv;
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen unsigned int len;
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen if (client->state.mail_from != NULL) {
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen client_send_line(client, "503 5.5.1 MAIL already given");
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen return 0;
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen }
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen argv = t_strsplit(args, " ");
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen addr = argv[0] == NULL ? "" : argv[0];
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen len = strlen(addr);
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen if (strncasecmp(addr, "FROM:<", 6) != 0 || addr[len-1] != '>') {
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen client_send_line(client, "501 5.5.4 Invalid parameters");
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen return 0;
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen }
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen for (argv++; *argv != NULL; argv++) {
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen if (strcasecmp(*argv, "BODY=7BIT") == 0)
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen client->state.mail_body_7bit = TRUE;
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen else if (strcasecmp(*argv, "BODY=8BITMIME") == 0)
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen client->state.mail_body_8bitmime = TRUE;
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen else {
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen client_send_line(client,
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen "501 5.5.4 Unsupported options");
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen return 0;
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen }
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen }
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen client->state.mail_from =
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen p_strndup(client->state_pool, addr + 6, len - 7);
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen p_array_init(&client->state.rcpt_to, client->state_pool, 64);
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen client_send_line(client, "250 2.1.0 OK");
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen return 0;
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen}
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainenstatic bool
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainenclient_proxy_rcpt_parse_fields(struct lmtp_proxy_settings *set,
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen const char *const *args, const char **address)
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen{
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen const char *p, *key, *value;
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen bool proxying = FALSE, port_set = FALSE;
4020006405eab97087f985a64b505d3cf48ceac7Timo Sirainen
4020006405eab97087f985a64b505d3cf48ceac7Timo Sirainen for (; *args != NULL; args++) {
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen p = strchr(*args, '=');
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen if (p == NULL) {
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen key = *args;
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen value = "";
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen } else {
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen key = t_strdup_until(*args, p);
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen value = p + 1;
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen }
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen if (strcmp(key, "proxy") == 0)
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen proxying = TRUE;
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen else if (strcmp(key, "host") == 0)
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen set->host = value;
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen else if (strcmp(key, "port") == 0) {
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen set->port = atoi(value);
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen port_set = TRUE;
20b2d47ed762ca2c009aa37e360af6f223ac71bdTimo Sirainen } else if (strcmp(key, "proxy_timeout") == 0)
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen set->timeout_msecs = atoi(value)*1000;
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen else if (strcmp(key, "protocol") == 0) {
0a1ec0f2a38370e8a073a60023b4365491947f6fTimo Sirainen if (strcmp(value, "lmtp") == 0)
0a1ec0f2a38370e8a073a60023b4365491947f6fTimo Sirainen set->protocol = LMTP_CLIENT_PROTOCOL_LMTP;
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen else if (strcmp(value, "smtp") == 0) {
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen set->protocol = LMTP_CLIENT_PROTOCOL_SMTP;
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen if (!port_set)
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen set->port = 25;
efe78d3ba24fc866af1c79b9223dc0809ba26cadStephan Bosch } else {
ce763c83d556eea9b74fc63e5d41f3b71a7e72deTimo Sirainen i_error("proxy: Unknown protocol %s", value);
20b2d47ed762ca2c009aa37e360af6f223ac71bdTimo Sirainen return FALSE;
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen }
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen } else if (strcmp(key, "user") == 0 ||
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen strcmp(key, "destuser") == 0) {
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen /* changing the username */
0a1ec0f2a38370e8a073a60023b4365491947f6fTimo Sirainen *address = value;
0a1ec0f2a38370e8a073a60023b4365491947f6fTimo Sirainen } else {
0a1ec0f2a38370e8a073a60023b4365491947f6fTimo Sirainen /* just ignore it */
13d58f3be3356c68ad4f53781f69bc6fe5623700Timo Sirainen }
0a1ec0f2a38370e8a073a60023b4365491947f6fTimo Sirainen }
0a1ec0f2a38370e8a073a60023b4365491947f6fTimo Sirainen if (proxying && set->host == NULL) {
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen i_error("proxy: host not given");
5c2d695acf9f95ae0dcdda89c4d2391ceda4d672Timo Sirainen return FALSE;
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen }
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen return proxying;
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen}
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainenstatic bool
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainenclient_proxy_is_ourself(const struct client *client,
013a0e03309a4a77552f6e8dd46d06c3d3f60f53Timo Sirainen const struct lmtp_proxy_settings *set)
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen{
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen struct ip_addr ip;
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen
4fc52b7b25c3d3f42348903e0154840f8761f306Timo Sirainen if (set->port != client->local_port)
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen return FALSE;
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen if (net_addr2ip(set->host, &ip) < 0)
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen return FALSE;
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen if (!net_ip_compare(&ip, &client->local_ip))
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen return FALSE;
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen return TRUE;
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen}
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainenstatic const char *
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainenaddress_add_detail(struct client *client, const char *username,
896093ae6961612ac6ef8722d79dd457f1b43dd0Timo Sirainen const char *detail)
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen{
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen const char *delim = client->set->recipient_delimiter;
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen const char *domain;
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen domain = strchr(username, '@');
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen if (domain == NULL)
55058d5f50f7e53bb22df4fa6ae951c8001416abTimo Sirainen return t_strconcat(username, delim, detail, NULL);
55058d5f50f7e53bb22df4fa6ae951c8001416abTimo Sirainen else {
55058d5f50f7e53bb22df4fa6ae951c8001416abTimo Sirainen username = t_strdup_until(username, domain);
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen return t_strconcat(username, delim, detail, domain, NULL);
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen }
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen}
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen
55058d5f50f7e53bb22df4fa6ae951c8001416abTimo Sirainenstatic bool client_proxy_rcpt(struct client *client, const char *address,
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen const char *username, const char *detail)
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen{
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen struct auth_master_connection *auth_conn;
55058d5f50f7e53bb22df4fa6ae951c8001416abTimo Sirainen struct lmtp_proxy_settings set;
55058d5f50f7e53bb22df4fa6ae951c8001416abTimo Sirainen struct auth_user_info info;
55058d5f50f7e53bb22df4fa6ae951c8001416abTimo Sirainen struct mail_storage_service_input input;
55058d5f50f7e53bb22df4fa6ae951c8001416abTimo Sirainen const char *args, *const *fields, *errstr, *orig_username = username;
55058d5f50f7e53bb22df4fa6ae951c8001416abTimo Sirainen pool_t pool;
e34d170f8f0e084bd94bfbc1a7085ece67e508dfTimo Sirainen int ret;
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen memset(&input, 0, sizeof(input));
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen input.module = input.service = "lmtp";
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen mail_storage_service_init_settings(storage_service, &input);
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen memset(&info, 0, sizeof(info));
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen info.service = master_service_get_name(master_service);
55058d5f50f7e53bb22df4fa6ae951c8001416abTimo Sirainen info.local_ip = client->local_ip;
55058d5f50f7e53bb22df4fa6ae951c8001416abTimo Sirainen info.remote_ip = client->remote_ip;
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen info.local_port = client->local_port;
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen info.remote_port = client->remote_port;
1176124297af5c56e932c0863c6637ff21d8a0efTimo Sirainen
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen pool = pool_alloconly_create("auth lookup", 1024);
13d58f3be3356c68ad4f53781f69bc6fe5623700Timo Sirainen auth_conn = mail_storage_service_get_auth_conn(storage_service);
13d58f3be3356c68ad4f53781f69bc6fe5623700Timo Sirainen ret = auth_master_pass_lookup(auth_conn, username, &info,
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen pool, &fields);
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen if (ret <= 0) {
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen errstr = ret < 0 && fields[0] != NULL ? t_strdup(fields[0]) :
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen t_strdup_printf(ERRSTR_TEMP_USERDB_FAIL, address);
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen pool_unref(&pool);
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen if (ret < 0) {
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen client_send_line(client, "%s", errstr);
8d35582f2577c64517b2341c5d6477c7010e0a0cPhil Carmody return TRUE;
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen } else {
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen /* user not found from passdb. try userdb also. */
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen return FALSE;
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen }
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen }
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen memset(&set, 0, sizeof(set));
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen set.port = client->local_port;
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen set.protocol = LMTP_CLIENT_PROTOCOL_LMTP;
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen set.timeout_msecs = LMTP_PROXY_DEFAULT_TIMEOUT_MSECS;
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen if (!client_proxy_rcpt_parse_fields(&set, fields, &username)) {
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen /* not proxying this user */
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen pool_unref(&pool);
0a1ec0f2a38370e8a073a60023b4365491947f6fTimo Sirainen return FALSE;
0a1ec0f2a38370e8a073a60023b4365491947f6fTimo Sirainen }
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen if (strcmp(username, orig_username) != 0) {
d798962a54c5cda054d57a0cfc7e5f47dfa20f6eTimo Sirainen /* username changed. change the address as well */
if (*detail == '\0')
address = username;
else
address = address_add_detail(client, username, detail);
} else if (client_proxy_is_ourself(client, &set)) {
i_error("Proxying to <%s> loops to itself", username);
client_send_line(client, "554 5.4.6 <%s> "
"Proxying loops to itself", address);
pool_unref(&pool);
return TRUE;
}
if (array_count(&client->state.rcpt_to) != 0) {
client_send_line(client, "451 4.3.0 <%s> "
"Can't handle mixed proxy/non-proxy destinations",
address);
pool_unref(&pool);
return TRUE;
}
if (client->proxy == NULL) {
client->proxy = lmtp_proxy_init(client->set->hostname,
dns_client_socket_path,
client->output);
if (client->state.mail_body_8bitmime)
args = " BODY=8BITMIME";
else if (client->state.mail_body_7bit)
args = " BODY=7BIT";
else
args = "";
lmtp_proxy_mail_from(client->proxy, t_strdup_printf(
"<%s>%s", client->state.mail_from, args));
}
if (lmtp_proxy_add_rcpt(client->proxy, address, &set) < 0)
client_send_line(client, ERRSTR_TEMP_REMOTE_FAILURE);
else
client_send_line(client, "250 2.1.5 OK");
pool_unref(&pool);
return TRUE;
}
static const char *lmtp_unescape_address(const char *name)
{
string_t *str;
const char *p;
if (*name != '"')
return name;
/* quoted-string local-part. drop the quotes unless there's a
'@' character inside or there's an error. */
str = t_str_new(128);
for (p = name+1; *p != '"'; p++) {
if (*p == '\0')
return name;
if (*p == '\\') {
if (p[1] == '\0') {
/* error */
return name;
}
p++;
}
if (*p == '@')
return name;
str_append_c(str, *p);
}
p++;
if (*p != '@' && *p != '\0')
return name;
str_append(str, p);
return str_c(str);
}
static void rcpt_address_parse(struct client *client, const char *address,
const char **username_r, const char **detail_r)
{
const char *p, *p2;
*username_r = address;
*detail_r = "";
if (*client->set->recipient_delimiter == '\0')
return;
p = strstr(address, client->set->recipient_delimiter);
if (p != NULL) {
/* user+detail@domain */
*username_r = t_strdup_until(*username_r, p);
p2 = strchr(p, '@');
if (p2 == NULL)
*detail_r = p+1;
else {
*detail_r = t_strdup_until(p+1, p2);
*username_r = t_strconcat(*username_r, p2, NULL);
}
}
}
int cmd_rcpt(struct client *client, const char *args)
{
struct mail_recipient rcpt;
struct mail_storage_service_input input;
const char *address, *username, *detail, *prefix;
const char *error = NULL, *arg, *const *argv;
unsigned int len;
int ret = 0;
if (client->state.mail_from == NULL) {
client_send_line(client, "503 5.5.1 MAIL needed first");
return 0;
}
argv = t_strsplit(args, " ");
arg = argv[0] == NULL ? "" : argv[0];
len = strlen(arg);
if (strncasecmp(arg, "TO:<", 4) != 0 || arg[len-1] != '>') {
client_send_line(client, "501 5.5.4 Invalid parameters");
return 0;
}
argv++;
memset(&rcpt, 0, sizeof(rcpt));
address = lmtp_unescape_address(t_strndup(arg + 4, len - 5));
if (*argv != NULL) {
client_send_line(client, "501 5.5.4 Unsupported options");
return 0;
}
rcpt_address_parse(client, address, &username, &detail);
if (client->lmtp_set->lmtp_proxy) {
if (client_proxy_rcpt(client, address, username, detail))
return 0;
}
if (client->proxy != NULL) {
client_send_line(client, "451 4.3.0 <%s> "
"Can't handle mixed proxy/non-proxy destinations",
address);
return 0;
}
memset(&input, 0, sizeof(input));
input.module = input.service = "lmtp";
input.username = username;
input.local_ip = client->local_ip;
input.remote_ip = client->remote_ip;
ret = mail_storage_service_lookup(storage_service, &input,
&rcpt.service_user, &error);
if (ret < 0) {
prefix = t_strdup_printf(ERRSTR_TEMP_USERDB_FAIL_PREFIX,
username);
client_send_line(client, "%s%s", prefix, error);
return 0;
}
if (ret == 0) {
client_send_line(client,
"550 5.1.1 <%s> User doesn't exist: %s",
address, username);
return 0;
}
rcpt.address = p_strdup(client->state_pool, address);
rcpt.detail = p_strdup(client->state_pool, detail);
array_append(&client->state.rcpt_to, &rcpt, 1);
client_send_line(client, "250 2.1.5 OK");
return 0;
}
int cmd_quit(struct client *client, const char *args ATTR_UNUSED)
{
client_destroy(client, "221 2.0.0", "Client quit");
return -1;
}
int cmd_vrfy(struct client *client, const char *args ATTR_UNUSED)
{
client_send_line(client, "252 2.3.3 Try RCPT instead");
return 0;
}
int cmd_rset(struct client *client, const char *args ATTR_UNUSED)
{
client_state_reset(client);
client_send_line(client, "250 2.0.0 OK");
return 0;
}
int cmd_noop(struct client *client, const char *args ATTR_UNUSED)
{
client_send_line(client, "250 2.0.0 OK");
return 0;
}
static int
client_deliver(struct client *client, const struct mail_recipient *rcpt,
struct mail *src_mail)
{
struct mail_deliver_context dctx;
struct mail_storage *storage;
const struct mail_storage_service_input *input;
void **sets;
const char *error, *username;
enum mail_error mail_error;
int ret;
input = mail_storage_service_user_get_input(rcpt->service_user);
username = t_strdup(input->username);
i_set_failure_prefix(t_strdup_printf("lmtp(%s, %s): ",
my_pid, username));
if (mail_storage_service_next(storage_service, rcpt->service_user,
&client->state.dest_user) < 0) {
client_send_line(client, ERRSTR_TEMP_MAILBOX_FAIL,
rcpt->address);
return -1;
}
sets = mail_storage_service_user_get_set(rcpt->service_user);
memset(&dctx, 0, sizeof(dctx));
dctx.pool = pool_alloconly_create("mail delivery", 1024);
dctx.set = sets[1];
dctx.session_id = client->state.session_id;
dctx.src_mail = src_mail;
dctx.src_envelope_sender = client->state.mail_from;
dctx.dest_user = client->state.dest_user;
if (*dctx.set->lda_original_recipient_header != '\0') {
dctx.dest_addr = mail_deliver_get_address(src_mail,
dctx.set->lda_original_recipient_header);
}
if (dctx.dest_addr == NULL)
dctx.dest_addr = rcpt->address;
dctx.final_dest_addr = rcpt->address;
dctx.dest_mailbox_name = *rcpt->detail == '\0' ? "INBOX" : rcpt->detail;
dctx.save_dest_mail = array_count(&client->state.rcpt_to) > 1 &&
client->state.first_saved_mail == NULL;
if (mail_deliver(&dctx, &storage) == 0) {
if (dctx.dest_mail != NULL) {
i_assert(client->state.first_saved_mail == NULL);
client->state.first_saved_mail = dctx.dest_mail;
}
client_send_line(client, "250 2.0.0 <%s> %s Saved",
rcpt->address, client->state.session_id);
ret = 0;
} else if (storage == NULL) {
/* This shouldn't happen */
i_error("BUG: Saving failed to unknown storage");
client_send_line(client, ERRSTR_TEMP_MAILBOX_FAIL,
rcpt->address);
ret = -1;
} else {
error = mail_storage_get_last_error(storage, &mail_error);
if (mail_error == MAIL_ERROR_NOSPACE) {
client_send_line(client, "%s <%s> %s",
dctx.set->quota_full_tempfail ?
"452 4.2.2" : "552 5.2.2",
rcpt->address, error);
} else {
client_send_line(client, "451 4.2.0 <%s> %s",
rcpt->address, error);
}
ret = -1;
}
pool_unref(&dctx.pool);
return ret;
}
static bool client_deliver_next(struct client *client, struct mail *src_mail)
{
const struct mail_recipient *rcpts;
unsigned int count;
int ret;
rcpts = array_get(&client->state.rcpt_to, &count);
while (client->state.rcpt_idx < count) {
ret = client_deliver(client, &rcpts[client->state.rcpt_idx],
src_mail);
i_set_failure_prefix(t_strdup_printf("lmtp(%s): ", my_pid));
client->state.rcpt_idx++;
if (ret == 0)
return TRUE;
/* failed. try the next one. */
if (client->state.dest_user != NULL)
mail_user_unref(&client->state.dest_user);
}
return FALSE;
}
static void client_rcpt_fail_all(struct client *client)
{
const struct mail_recipient *rcpt;
array_foreach(&client->state.rcpt_to, rcpt) {
client_send_line(client, ERRSTR_TEMP_MAILBOX_FAIL,
rcpt->address);
}
}
static struct istream *client_get_input(struct client *client)
{
struct client_state *state = &client->state;
struct istream *cinput, *inputs[3];
inputs[0] = i_stream_create_from_data(state->added_headers,
strlen(state->added_headers));
if (state->mail_data_output != NULL) {
o_stream_unref(&state->mail_data_output);
inputs[1] = i_stream_create_fd(state->mail_data_fd,
MAIL_READ_FULL_BLOCK_SIZE,
FALSE);
i_stream_set_init_buffer_size(inputs[1],
MAIL_READ_FULL_BLOCK_SIZE);
} else {
inputs[1] = i_stream_create_from_data(state->mail_data->data,
state->mail_data->used);
}
inputs[2] = NULL;
cinput = i_stream_create_concat(inputs);
i_stream_unref(&inputs[0]);
i_stream_unref(&inputs[1]);
return cinput;
}
static int client_open_raw_mail(struct client *client, struct istream *input)
{
static const char *wanted_headers[] = {
"From", "To", "Message-ID", "Subject", "Return-Path",
NULL
};
struct mailbox *box;
struct raw_mailbox *raw_box;
struct mailbox_header_lookup_ctx *headers_ctx;
enum mail_error error;
box = mailbox_alloc(client->raw_mail_user->namespaces->list,
"Dovecot Delivery Mail",
MAILBOX_FLAG_NO_INDEX_FILES);
if (mailbox_open_stream(box, input) < 0 ||
mailbox_sync(box, 0) < 0) {
i_error("Can't open delivery mail as raw: %s",
mail_storage_get_last_error(box->storage, &error));
mailbox_free(&box);
client_rcpt_fail_all(client);
return -1;
}
raw_box = (struct raw_mailbox *)box;
raw_box->envelope_sender = client->state.mail_from;
client->state.raw_box = box;
client->state.raw_trans = mailbox_transaction_begin(box, 0);
headers_ctx = mailbox_header_lookup_init(box, wanted_headers);
client->state.raw_mail = mail_alloc(client->state.raw_trans,
0, headers_ctx);
mailbox_header_lookup_unref(&headers_ctx);
mail_set_seq(client->state.raw_mail, 1);
return 0;
}
static void
client_input_data_write_local(struct client *client, struct istream *input)
{
struct mail *src_mail;
uid_t old_uid, first_uid = (uid_t)-1;
if (client_open_raw_mail(client, input) < 0)
return;
old_uid = geteuid();
src_mail = client->state.raw_mail;
while (client_deliver_next(client, src_mail)) {
if (client->state.first_saved_mail == NULL ||
client->state.first_saved_mail == src_mail)
mail_user_unref(&client->state.dest_user);
else {
/* use the first saved message to save it elsewhere too.
this might allow hard linking the files. */
client->state.dest_user = NULL;
src_mail = client->state.first_saved_mail;
first_uid = geteuid();
i_assert(first_uid != 0);
}
}
if (client->state.first_saved_mail != NULL) {
struct mail *mail = client->state.first_saved_mail;
struct mailbox_transaction_context *trans = mail->transaction;
struct mailbox *box = trans->box;
struct mail_user *user = box->storage->user;
/* just in case these functions are going to write anything,
change uid back to user's own one */
if (first_uid != old_uid) {
if (seteuid(0) < 0)
i_fatal("seteuid(0) failed: %m");
if (seteuid(first_uid) < 0)
i_fatal("seteuid() failed: %m");
}
mail_free(&mail);
mailbox_transaction_rollback(&trans);
mailbox_free(&box);
mail_user_unref(&user);
}
if (old_uid == 0) {
/* switch back to running as root, since that's what we're
practically doing anyway. it's also important in case we
lose e.g. config connection and need to reconnect to it. */
if (seteuid(0) < 0)
i_fatal("seteuid(0) failed: %m");
}
}
static void client_input_data_finish(struct client *client)
{
client_io_reset(client);
client_state_reset(client);
if (i_stream_have_bytes_left(client->input))
client_input_handle(client);
}
static void client_proxy_finish(bool timeout, void *context)
{
struct client *client = context;
lmtp_proxy_deinit(&client->proxy);
if (timeout) {
client_destroy(client,
t_strdup_printf("421 4.4.2 %s", client->my_domain),
"Disconnected for inactivity");
} else {
client_input_data_finish(client);
}
}
static const char *client_get_added_headers(struct client *client)
{
string_t *str = t_str_new(200);
const char *host, *address = NULL, *username = NULL;
if (array_count(&client->state.rcpt_to) == 1) {
const struct mail_recipient *rcpt =
array_idx(&client->state.rcpt_to, 0);
const char *detail;
address = rcpt->address;
rcpt_address_parse(client, address, &username, &detail);
}
str_printfa(str, "Return-Path: <%s>\r\n", client->state.mail_from);
if (username != NULL)
str_printfa(str, "Delivered-To: <%s>\r\n", username);
str_printfa(str, "Received: from %s", client->state.lhlo);
if ((host = net_ip2addr(&client->remote_ip)) != NULL)
str_printfa(str, " ([%s])", host);
str_printfa(str, "\r\n\tby %s ("PACKAGE_NAME") with LMTP id %s",
client->my_domain, client->state.session_id);
str_append(str, "\r\n\t");
if (address != NULL)
str_printfa(str, "for <%s>", address);
str_printfa(str, "; %s\r\n", message_date_create(ioloop_time));
return str_c(str);
}
static bool client_input_data_write(struct client *client)
{
struct istream *input;
bool ret = TRUE;
i_stream_destroy(&client->dot_input);
input = client_get_input(client);
client_input_data_write_local(client, input);
if (client->proxy != NULL) {
lmtp_proxy_start(client->proxy, input, NULL,
client_proxy_finish, client);
ret = FALSE;
}
i_stream_unref(&input);
return ret;
}
static int client_input_add_file(struct client *client,
const unsigned char *data, size_t size)
{
struct client_state *state = &client->state;
string_t *path;
ssize_t ret;
int fd;
if (state->mail_data_output != NULL) {
/* continue writing to file */
if (o_stream_send(state->mail_data_output,
data, size) != (ssize_t)size)
return -1;
return 0;
}
/* move everything to a temporary file. */
path = t_str_new(256);
mail_user_set_get_temp_prefix(path, client->raw_mail_user->set);
fd = safe_mkstemp_hostpid(path, 0600, (uid_t)-1, (gid_t)-1);
if (fd == -1) {
i_error("Temp file creation to %s failed: %m", str_c(path));
return -1;
}
/* we just want the fd, unlink it */
if (unlink(str_c(path)) < 0) {
/* shouldn't happen.. */
i_error("unlink(%s) failed: %m", str_c(path));
(void)close(fd);
return -1;
}
state->mail_data_fd = fd;
state->mail_data_output = o_stream_create_fd_file(fd, 0, FALSE);
o_stream_cork(state->mail_data_output);
ret = o_stream_send(state->mail_data_output,
state->mail_data->data, state->mail_data->used);
if (ret != (ssize_t)state->mail_data->used)
return -1;
if (o_stream_send(client->state.mail_data_output,
data, size) != (ssize_t)size)
return -1;
return 0;
}
static int
client_input_add(struct client *client, const unsigned char *data, size_t size)
{
if (client->state.mail_data->used + size <=
CLIENT_MAIL_DATA_MAX_INMEMORY_SIZE &&
client->state.mail_data_output == NULL) {
buffer_append(client->state.mail_data, data, size);
return 0;
} else {
return client_input_add_file(client, data, size);
}
}
static void client_input_data_handle(struct client *client)
{
const unsigned char *data;
size_t size;
ssize_t ret;
while ((ret = i_stream_read(client->dot_input)) > 0 || ret == -2) {
data = i_stream_get_data(client->dot_input, &size);
if (client_input_add(client, data, size) < 0) {
client_destroy(client, "451 4.3.0",
"Temporary internal failure");
return;
}
i_stream_skip(client->dot_input, size);
}
if (ret == 0)
return;
if (!client->dot_input->eof) {
/* client probably disconnected */
client_destroy(client, NULL, NULL);
return;
}
if (client_input_data_write(client))
client_input_data_finish(client);
}
static void client_input_data(struct client *client)
{
if (client_input_read(client) < 0)
return;
client_input_data_handle(client);
}
int cmd_data(struct client *client, const char *args ATTR_UNUSED)
{
if (client->state.mail_from == NULL) {
client_send_line(client, "503 5.5.1 MAIL needed first");
return 0;
}
if (array_count(&client->state.rcpt_to) == 0 && client->proxy == NULL) {
client_send_line(client, "554 5.5.1 No valid recipients");
return 0;
}
client->state.added_headers =
p_strdup(client->state_pool, client_get_added_headers(client));
i_assert(client->state.mail_data == NULL);
client->state.mail_data = buffer_create_dynamic(default_pool, 1024*64);
i_assert(client->dot_input == NULL);
client->dot_input = i_stream_create_dot(client->input, TRUE);
client_send_line(client, "354 OK");
io_remove(&client->io);
if (array_count(&client->state.rcpt_to) == 0) {
timeout_remove(&client->to_idle);
lmtp_proxy_start(client->proxy, client->dot_input,
client->state.added_headers,
client_proxy_finish, client);
i_stream_unref(&client->dot_input);
} else {
client->io = io_add(client->fd_in, IO_READ,
client_input_data, client);
client_input_data_handle(client);
}
return -1;
}