9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include "lib.h"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include "lib-signals.h"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include "str.h"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include "hostpid.h"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include "ioloop.h"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include "istream.h"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include "istream-dot.h"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include "istream-chain.h"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include "istream-failure-at.h"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include "ostream.h"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include "time-util.h"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include "connection.h"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include "test-common.h"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include "smtp-client.h"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include "smtp-client-connection.h"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include "smtp-client-transaction.h"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include <sys/types.h>

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include <sys/wait.h>

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include <signal.h>

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch#include <unistd.h>

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschenum server_connection_state {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SERVER_CONNECTION_STATE_EHLO = 0,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SERVER_CONNECTION_STATE_MAIL_FROM,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SERVER_CONNECTION_STATE_RCPT_TO,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SERVER_CONNECTION_STATE_DATA,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SERVER_CONNECTION_STATE_FINISH

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch};

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstruct server_connection {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct connection conn;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch void *context;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch enum server_connection_state state;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch char *file_path;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct istream *dot_input;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch pool_t pool;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch};

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtypedef void (*test_server_init_t)(unsigned int index);

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtypedef bool (*test_client_init_t)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch (const struct smtp_client_settings *client_set);

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtypedef void (*test_dns_init_t)(void);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic struct ip_addr bind_ip;

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic in_port_t *bind_ports = 0;

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic struct ioloop *ioloop;

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic bool debug = FALSE;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic pid_t dns_pid = (pid_t)-1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic struct io *io_listen;

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic int fd_listen = -1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic pid_t *server_pids = NULL;

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic unsigned int server_pids_count = 0;

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic struct connection_list *server_conn_list;

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic unsigned int server_index;

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void (*test_server_input)(struct server_connection *conn);

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic int (*test_server_input_line)(struct server_connection *conn,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch const char *line);

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic int (*test_server_input_data)(struct server_connection *conn,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch const unsigned char *data, size_t size);

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic int (*test_server_init)(struct server_connection *conn);

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void (*test_server_deinit)(struct server_connection *conn);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic struct smtp_client *smtp_client = NULL;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void test_server_run(unsigned int index);

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschserver_connection_deinit(struct server_connection **_conn);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_defaults(struct smtp_client_settings *smtp_set);

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void test_client_deinit(void);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void test_run_client_server(

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch const struct smtp_client_settings *client_set,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_init_t client_test,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_init_t server_test,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch unsigned int server_tests_count,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_dns_init_t dns_test)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch ATTR_NULL(3);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_server_unconfigured_ssl_input(

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct server_connection *conn ATTR_UNUSED)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch /* nothing */

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_server_unconfigured_ssl(unsigned int index)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sleep(100);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_input = test_server_unconfigured_ssl_input;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_run(index);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstruct _unconfigured_ssl {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch unsigned int count;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch};

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_unconfigured_ssl_reply(const struct smtp_reply *reply,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch void *context)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _unconfigured_ssl *ctx = (struct _unconfigured_ssl *)context;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (debug)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_debug("REPLY: %s", smtp_reply_log(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(reply->status == SMTP_CLIENT_COMMAND_ERROR_CONNECT_FAILED);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (--ctx->count == 0) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_free(ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch io_loop_stop(ioloop);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic bool

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_unconfigured_ssl(const struct smtp_client_settings *client_set)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_connection *sconn;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _unconfigured_ssl *ctx;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_expect_errors(2);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch ctx = i_new(struct _unconfigured_ssl, 1);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch ctx->count = 2;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client = smtp_client_init(client_set);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sconn = smtp_client_connection_create(smtp_client,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_PROTOCOL_SMTP, "127.0.0.1", bind_ports[0],

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_CLIENT_SSL_MODE_IMMEDIATE, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_connection_connect(sconn,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_unconfigured_ssl_reply, ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sconn = smtp_client_connection_create(smtp_client,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_PROTOCOL_SMTP, "127.0.0.1", bind_ports[0],

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_CLIENT_SSL_MODE_IMMEDIATE, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_connection_connect(sconn,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_unconfigured_ssl_reply, ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return TRUE;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void test_unconfigured_ssl(void)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_settings smtp_client_set;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_defaults(&smtp_client_set);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_begin("unconfigured ssl");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_run_client_server(&smtp_client_set,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_unconfigured_ssl,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_unconfigured_ssl, 1, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_end();

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_server_unconfigured_ssl_abort_input(

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct server_connection *conn ATTR_UNUSED)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch /* nothing */

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_server_unconfigured_ssl_abort(unsigned int index)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sleep(100);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_input = test_server_unconfigured_ssl_abort_input;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_run(index);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstruct _unconfigured_ssl_abort {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch unsigned int count;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch};

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_unconfigured_ssl_abort_reply1(const struct smtp_reply *reply,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _unconfigured_ssl_abort *ctx ATTR_UNUSED)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (debug)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_debug("REPLY: %s", smtp_reply_log(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_out_quiet("inappropriate callback", FALSE);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_unconfigured_ssl_abort_reply2(const struct smtp_reply *reply,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _unconfigured_ssl_abort *ctx)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (debug)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_debug("REPLY: %s", smtp_reply_log(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(reply->status == SMTP_CLIENT_COMMAND_ERROR_CONNECT_FAILED);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_free(ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch io_loop_stop(ioloop);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic bool

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_unconfigured_ssl_abort(

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch const struct smtp_client_settings *client_set)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_connection *sconn;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_command *scmd;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _unconfigured_ssl_abort *ctx;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_expect_errors(2);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch ctx = i_new(struct _unconfigured_ssl_abort, 1);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch ctx->count = 1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client = smtp_client_init(client_set);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sconn = smtp_client_connection_create(smtp_client,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_PROTOCOL_SMTP, "127.0.0.1", bind_ports[0],

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_CLIENT_SSL_MODE_IMMEDIATE, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_connection_connect(sconn, NULL, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch scmd = smtp_client_command_new(sconn, 0,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_unconfigured_ssl_abort_reply1, ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_write(scmd, "FROP");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_submit(scmd);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_abort(&scmd);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sconn = smtp_client_connection_create(smtp_client,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_PROTOCOL_SMTP, "127.0.0.1", bind_ports[0],

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_CLIENT_SSL_MODE_IMMEDIATE, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_connection_connect(sconn, NULL, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch scmd = smtp_client_command_new(sconn, 0,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_unconfigured_ssl_abort_reply2, ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_write(scmd, "FROP");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_submit(scmd);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return TRUE;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void test_unconfigured_ssl_abort(void)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_settings smtp_client_set;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_defaults(&smtp_client_set);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_begin("unconfigured ssl abort");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_run_client_server(&smtp_client_set,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_unconfigured_ssl_abort,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_unconfigured_ssl_abort, 1, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_end();

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstruct _host_lookup_failed {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch unsigned int count;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch};

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_host_lookup_failed_reply(const struct smtp_reply *reply,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _host_lookup_failed *ctx)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (debug)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_debug("REPLY: %s", smtp_reply_log(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(reply->status == SMTP_CLIENT_COMMAND_ERROR_HOST_LOOKUP_FAILED);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (--ctx->count == 0) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_free(ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch io_loop_stop(ioloop);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic bool

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_host_lookup_failed(

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch const struct smtp_client_settings *client_set)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_connection *sconn;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_command *scmd;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _host_lookup_failed *ctx;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_expect_errors(2);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch ctx = i_new(struct _host_lookup_failed, 1);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch ctx->count = 2;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client = smtp_client_init(client_set);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sconn = smtp_client_connection_create(smtp_client,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_PROTOCOL_SMTP, "host.in-addr.arpa", 465,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_CLIENT_SSL_MODE_IMMEDIATE, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_connection_connect(sconn, NULL, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch scmd = smtp_client_command_new(sconn, 0,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_host_lookup_failed_reply, ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_write(scmd, "FROP");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_submit(scmd);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sconn = smtp_client_connection_create(smtp_client,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_PROTOCOL_SMTP, "host.in-addr.arpa", 465,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_CLIENT_SSL_MODE_IMMEDIATE, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_connection_connect(sconn, NULL, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch scmd = smtp_client_command_new(sconn, 0,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_host_lookup_failed_reply, ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_write(scmd, "FROP");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_submit(scmd);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return TRUE;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void test_host_lookup_failed(void)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_settings smtp_client_set;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_defaults(&smtp_client_set);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_begin("host lookup failed");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_run_client_server(&smtp_client_set,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_host_lookup_failed,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch NULL, 0, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_end();

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_server_connection_refused(unsigned int index ATTR_UNUSED)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_close_fd(&fd_listen);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstruct _connection_refused {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch unsigned int count;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch};

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_connection_refused_reply(const struct smtp_reply *reply,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _connection_refused *ctx)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (debug)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_debug("REPLY: %s", smtp_reply_log(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(reply->status == SMTP_CLIENT_COMMAND_ERROR_CONNECT_FAILED);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (--ctx->count == 0) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_free(ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch io_loop_stop(ioloop);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic bool

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_connection_refused(

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch const struct smtp_client_settings *client_set)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_connection *sconn;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_command *scmd;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _connection_refused *ctx;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_expect_errors(2);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch ctx = i_new(struct _connection_refused, 1);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch ctx->count = 2;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client = smtp_client_init(client_set);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sconn = smtp_client_connection_create(smtp_client,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_PROTOCOL_SMTP, net_ip2addr(&bind_ip), bind_ports[0],

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_CLIENT_SSL_MODE_NONE, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_connection_connect(sconn, NULL, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch scmd = smtp_client_command_new(sconn, 0,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_connection_refused_reply, ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_write(scmd, "FROP");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_submit(scmd);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sconn = smtp_client_connection_create(smtp_client,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_PROTOCOL_SMTP, net_ip2addr(&bind_ip), bind_ports[0],

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_CLIENT_SSL_MODE_NONE, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_connection_connect(sconn, NULL, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch scmd = smtp_client_command_new(sconn, 0,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_connection_refused_reply, ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_write(scmd, "FROP");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_submit(scmd);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return TRUE;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void test_connection_refused(void)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_settings smtp_client_set;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_defaults(&smtp_client_set);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_begin("connection refused");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_run_client_server(&smtp_client_set,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_connection_refused,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_connection_refused, 1, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_end();

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_connection_lost_prematurely_input(struct server_connection *conn)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch const char *line;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch line = i_stream_read_next_line(conn->conn.input);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (line == NULL) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (conn->conn.input->eof ||

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch conn->conn.input->stream_errno != 0) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch server_connection_deinit(&conn);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch server_connection_deinit(&conn);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic int

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_connection_lost_prematurely_init(struct server_connection *conn)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch o_stream_send_str(conn->conn.output,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "220 testserver ESMTP Testfix (Frop/GNU)\r\n");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return 1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void test_server_connection_lost_prematurely(unsigned int index)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_init = test_connection_lost_prematurely_init;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_input = test_connection_lost_prematurely_input;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_run(index);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstruct _connection_lost_prematurely {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch unsigned int count;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch};

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_connection_lost_prematurely_reply(const struct smtp_reply *reply,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _connection_lost_prematurely *ctx)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (debug)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_debug("REPLY: %s", smtp_reply_log(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(reply->status == SMTP_CLIENT_COMMAND_ERROR_CONNECTION_LOST);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (--ctx->count == 0) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_free(ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch io_loop_stop(ioloop);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic bool

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_connection_lost_prematurely(

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch const struct smtp_client_settings *client_set)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_connection *sconn;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_command *scmd;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _connection_lost_prematurely *ctx;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch ctx = i_new(struct _connection_lost_prematurely, 1);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch ctx->count = 2;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client = smtp_client_init(client_set);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sconn = smtp_client_connection_create(smtp_client,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_PROTOCOL_SMTP, net_ip2addr(&bind_ip), bind_ports[0],

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_CLIENT_SSL_MODE_NONE, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_connection_connect(sconn, NULL, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch scmd = smtp_client_command_new(sconn, 0,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_connection_lost_prematurely_reply, ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_write(scmd, "FROP");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_submit(scmd);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sconn = smtp_client_connection_create(smtp_client,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_PROTOCOL_SMTP, net_ip2addr(&bind_ip), bind_ports[0],

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_CLIENT_SSL_MODE_NONE, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_connection_connect(sconn, NULL, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch scmd = smtp_client_command_new(sconn, 0,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_connection_lost_prematurely_reply, ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_write(scmd, "FROP");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_submit(scmd);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return TRUE;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void test_connection_lost_prematurely(void)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_settings smtp_client_set;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_defaults(&smtp_client_set);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_begin("connection lost prematurely");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_run_client_server(&smtp_client_set,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_connection_lost_prematurely,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_connection_lost_prematurely, 1, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_end();

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void test_server_connection_timed_out(unsigned int index ATTR_UNUSED)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sleep(10);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstruct _connection_timed_out {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch unsigned int count;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch};

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_connection_timed_out_reply(const struct smtp_reply *reply,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _connection_timed_out *ctx)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (debug)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_debug("REPLY: %s", smtp_reply_log(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(reply->status == SMTP_CLIENT_COMMAND_ERROR_CONNECT_FAILED);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (--ctx->count == 0) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_free(ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch io_loop_stop(ioloop);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic bool

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_connection_timed_out(

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch const struct smtp_client_settings *client_set)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_connection *sconn;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_command *scmd;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _connection_timed_out *ctx;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_expect_errors(2);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch ctx = i_new(struct _connection_timed_out, 1);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch ctx->count = 2;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client = smtp_client_init(client_set);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sconn = smtp_client_connection_create(smtp_client,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_PROTOCOL_SMTP, net_ip2addr(&bind_ip), bind_ports[0],

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_CLIENT_SSL_MODE_NONE, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_connection_connect(sconn, NULL, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch scmd = smtp_client_command_new(sconn, 0,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_connection_timed_out_reply, ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_write(scmd, "FROP");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_submit(scmd);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sconn = smtp_client_connection_create(smtp_client,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_PROTOCOL_SMTP, net_ip2addr(&bind_ip), bind_ports[0],

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_CLIENT_SSL_MODE_NONE, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_connection_connect(sconn, NULL, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch scmd = smtp_client_command_new(sconn, 0,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_connection_timed_out_reply, ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_write(scmd, "FROP");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_command_submit(scmd);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return TRUE;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void test_connection_timed_out(void)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_settings smtp_client_set;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_defaults(&smtp_client_set);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_set.connect_timeout_msecs = 1000;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_begin("connection timed out");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_run_client_server(&smtp_client_set,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_connection_timed_out,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_connection_timed_out, 1, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_end();

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic int

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_broken_payload_input_line(struct server_connection *conn ATTR_UNUSED,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch const char *line ATTR_UNUSED)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return 0;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void test_server_broken_payload(unsigned int index)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_input_line = test_broken_payload_input_line;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_run(index);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic int

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_broken_payload_chunking_input_line(

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct server_connection *conn, const char *line ATTR_UNUSED)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (conn->state == SERVER_CONNECTION_STATE_EHLO) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch o_stream_send_str(conn->conn.output,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "250-testserver\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "250-PIPELINING\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "250-CHUNKING\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "250-ENHANCEDSTATUSCODES\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "250 DSN\r\n");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return 1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return 0;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void test_server_broken_payload_chunking(unsigned int index)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_input_line = test_broken_payload_chunking_input_line;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_run(index);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_broken_payload_rcpt_to_cb(const struct smtp_reply *reply,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch void *context ATTR_UNUSED)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(smtp_reply_is_success(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_broken_payload_rcpt_data_cb(const struct smtp_reply *reply,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch void *context ATTR_UNUSED)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (debug)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_debug("REPLY: %s", smtp_reply_log(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(reply->status == SMTP_CLIENT_COMMAND_ERROR_BROKEN_PAYLOAD);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_broken_payload_data_cb(const struct smtp_reply *reply,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch void *context ATTR_UNUSED)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (debug)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_debug("REPLY: %s", smtp_reply_log(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(reply->status == SMTP_CLIENT_COMMAND_ERROR_BROKEN_PAYLOAD);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_broken_payload_finished(void *context ATTR_UNUSED)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch io_loop_stop(ioloop);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic bool

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_broken_payload(

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch const struct smtp_client_settings *client_set)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_connection *sconn;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_transaction *strans;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct istream *input;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_expect_errors(2);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch input = i_stream_create_error_str(EIO, "Moehahahaha!!");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_stream_set_name(input, "PURE EVIL");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client = smtp_client_init(client_set);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sconn = smtp_client_connection_create(smtp_client,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_PROTOCOL_SMTP, net_ip2addr(&bind_ip), bind_ports[0],

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_CLIENT_SSL_MODE_NONE, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch strans = smtp_client_transaction_create(sconn,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_ADDRESS_LITERAL("sender", "example.com"), NULL,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_broken_payload_finished, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_connection_unref(&sconn);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_transaction_add_rcpt(strans,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_ADDRESS_LITERAL("rcpt", "example.com"), NULL,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_broken_payload_rcpt_to_cb,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_broken_payload_rcpt_data_cb, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_transaction_send(strans, input,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_broken_payload_data_cb, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_stream_unref(&input);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return TRUE;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic bool

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_broken_payload_later(

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch const struct smtp_client_settings *client_set)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch static const char *message =

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "From: lucifer@example.com\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "To: lostsoul@example.com\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Subject: Moehahaha!\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Moehahahahahahahahahahahahahahahahahahahahahaha!!\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Moehahahahahahahahahahahahahahahahahahahahahaha!!\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Moehahahahahahahahahahahahahahahahahahahahahaha!!\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Moehahahahahahahahahahahahahahahahahahahahahaha!!\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Moehahahahahahahahahahahahahahahahahahahahahaha!!\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Moehahahahahahahahahahahahahahahahahahahahahaha!!\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Moehahahahahahahahahahahahahahahahahahahahahaha!!\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Moehahahahahahahahahahahahahahahahahahahahahaha!!\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Moehahahahahahahahahahahahahahahahahahahahahaha!!\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Moehahahahahahahahahahahahahahahahahahahahahaha!!\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Moehahahahahahahahahahahahahahahahahahahahahaha!!\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Moehahahahahahahahahahahahahahahahahahahahahaha!!\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Moehahahahahahahahahahahahahahahahahahahahahaha!!\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Moehahahahahahahahahahahahahahahahahahahahahaha!!\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Moehahahahahahahahahahahahahahahahahahahahahaha!!\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Moehahahahahahahahahahahahahahahahahahahahahaha!!\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Moehahahahahahahahahahahahahahahahahahahahahaha!!\r\n";

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_connection *sconn;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_transaction *strans;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct istream *input, *msg_input;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_expect_errors(1);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch msg_input = i_stream_create_from_data(message, strlen(message));

a4985564b81d51caaddd38376792432428fd449bStephan Bosch input = i_stream_create_failure_at(msg_input, 666,

a4985564b81d51caaddd38376792432428fd449bStephan Bosch EIO, "Moehahahaha!!");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_stream_unref(&msg_input);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_stream_set_name(input, "PURE EVIL");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client = smtp_client_init(client_set);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sconn = smtp_client_connection_create(smtp_client,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_PROTOCOL_SMTP, net_ip2addr(&bind_ip), bind_ports[0],

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_CLIENT_SSL_MODE_NONE, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch strans = smtp_client_transaction_create(sconn,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_ADDRESS_LITERAL("sender", "example.com"), NULL,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_broken_payload_finished, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_connection_unref(&sconn);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_transaction_add_rcpt(strans,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_ADDRESS_LITERAL("rcpt", "example.com"), NULL,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_broken_payload_rcpt_to_cb,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_broken_payload_rcpt_data_cb, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_transaction_send

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch (strans, input, test_client_broken_payload_data_cb, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_stream_unref(&input);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return TRUE;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void test_broken_payload(void)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_settings smtp_client_set;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_defaults(&smtp_client_set);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_set.connect_timeout_msecs = 1000;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_begin("broken payload");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_run_client_server(&smtp_client_set,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_broken_payload,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_broken_payload, 1, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_end();

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_begin("broken payload (later)");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_run_client_server(&smtp_client_set,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_broken_payload_later,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_broken_payload, 1, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_end();

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_begin("broken payload (later, chunking)");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_run_client_server(&smtp_client_set,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_broken_payload_later,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_broken_payload_chunking, 1, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_end();

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic int

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_connection_lost_input_line(struct server_connection *conn,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch const char *line ATTR_UNUSED)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch switch (conn->state) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case SERVER_CONNECTION_STATE_EHLO:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (server_index == 0) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch conn->state = SERVER_CONNECTION_STATE_MAIL_FROM;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sleep(1);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch server_connection_deinit(&conn);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return -1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case SERVER_CONNECTION_STATE_MAIL_FROM:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (server_index == 1) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch conn->state = SERVER_CONNECTION_STATE_RCPT_TO;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sleep(1);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch server_connection_deinit(&conn);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return -1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case SERVER_CONNECTION_STATE_RCPT_TO:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (server_index == 2) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch conn->state = SERVER_CONNECTION_STATE_DATA;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sleep(1);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch server_connection_deinit(&conn);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return -1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case SERVER_CONNECTION_STATE_DATA:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (server_index == 3) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch conn->state = SERVER_CONNECTION_STATE_FINISH;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sleep(1);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch server_connection_deinit(&conn);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return -1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case SERVER_CONNECTION_STATE_FINISH:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return 0;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic int

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_connection_lost_input_data(struct server_connection *conn,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch const unsigned char *data ATTR_UNUSED, size_t size ATTR_UNUSED)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sleep(1);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch server_connection_deinit(&conn);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return -1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void test_server_connection_lost(unsigned int index)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_input_line = test_connection_lost_input_line;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_input_data = test_connection_lost_input_data;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_run(index);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstruct _connection_lost {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch unsigned int count;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch};

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstruct _connection_lost_peer {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _connection_lost *context;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch unsigned int index;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch};

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_connection_lost_rcpt_to_cb(const struct smtp_reply *reply,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _connection_lost_peer *pctx)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (debug) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_debug("RCPT TO REPLY[%u]: %s",

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch pctx->index, smtp_reply_log(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch switch (pctx->index) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 0:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(reply->status ==

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_CLIENT_COMMAND_ERROR_CONNECTION_LOST);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 1:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(reply->status ==

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_CLIENT_COMMAND_ERROR_CONNECTION_LOST);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 2:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(reply->status ==

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_CLIENT_COMMAND_ERROR_CONNECTION_LOST);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 3:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(smtp_reply_is_success(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_connection_lost_rcpt_data_cb(const struct smtp_reply *reply,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _connection_lost_peer *pctx)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (debug) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_debug("RCPT DATA REPLY[%u]: %s",

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch pctx->index, smtp_reply_log(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch switch (pctx->index) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 0:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(FALSE);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 1:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(FALSE);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 2:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(FALSE);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 3:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(reply->status == SMTP_CLIENT_COMMAND_ERROR_CONNECTION_LOST);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_connection_lost_data_cb(const struct smtp_reply *reply,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _connection_lost_peer *pctx)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (debug) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_debug("DATA REPLY[%u]: %s",

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch pctx->index, smtp_reply_log(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(reply->status == SMTP_CLIENT_COMMAND_ERROR_CONNECTION_LOST);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_connection_lost_finished(struct _connection_lost_peer *pctx)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _connection_lost *ctx = pctx->context;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (debug)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_debug("FINISHED[%u]", pctx->index);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (--ctx->count == 0) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_free(ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch io_loop_stop(ioloop);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_free(pctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_connection_lost_submit(struct _connection_lost *ctx,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch unsigned int index)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch static const char *message =

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "From: stephan@example.com\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "To: timo@example.com\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Subject: Frop!\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Frop!\r\n";

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _connection_lost_peer *pctx;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_connection *sconn;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_transaction *strans;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct istream *input;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch pctx = i_new(struct _connection_lost_peer, 1);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch pctx->context = ctx;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch pctx->index = index;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch input = i_stream_create_from_data(message, strlen(message));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_stream_set_name(input, "message");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sconn = smtp_client_connection_create(smtp_client,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_PROTOCOL_SMTP, net_ip2addr(&bind_ip), bind_ports[index],

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_CLIENT_SSL_MODE_NONE, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch strans = smtp_client_transaction_create(sconn,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_ADDRESS_LITERAL("sender", "example.com"), NULL,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_connection_lost_finished, pctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_connection_unref(&sconn);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_transaction_add_rcpt(strans,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch SMTP_ADDRESS_LITERAL("rcpt", "example.com"), NULL,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_connection_lost_rcpt_to_cb,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_connection_lost_rcpt_data_cb, pctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_transaction_send

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch (strans, input, test_client_connection_lost_data_cb, pctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_stream_unref(&input);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic bool

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_connection_lost(

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch const struct smtp_client_settings *client_set)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _connection_lost *ctx;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch unsigned int i;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch ctx = i_new(struct _connection_lost, 1);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch ctx->count = 5;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client = smtp_client_init(client_set);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch for (i = 0; i < ctx->count; i++)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_connection_lost_submit(ctx, i);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return TRUE;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void test_connection_lost(void)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_settings smtp_client_set;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_defaults(&smtp_client_set);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_begin("connection lost");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_run_client_server(&smtp_client_set,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_client_connection_lost,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_connection_lost, 5, NULL);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_end();

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic int

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_unexpected_reply_init(struct server_connection *conn)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (server_index == 5) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch o_stream_send_str(conn->conn.output,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "220 testserver ESMTP Testfix (Debian/GNU)\r\n");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch o_stream_send_str(conn->conn.output,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "421 testserver Server shutting down for maintenance\r\n");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sleep(4);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch server_connection_deinit(&conn);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return 1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return 0;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic int

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_unexpected_reply_input_line(struct server_connection *conn,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch const char *line ATTR_UNUSED)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch switch (conn->state) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case SERVER_CONNECTION_STATE_EHLO:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (server_index == 4) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch o_stream_send_str(conn->conn.output,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "250-testserver\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "250-PIPELINING\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "250-ENHANCEDSTATUSCODES\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "250 DSN\r\n");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch o_stream_send_str(conn->conn.output,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "421 testserver Server shutting down for maintenance\r\n");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sleep(4);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch server_connection_deinit(&conn);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return -1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case SERVER_CONNECTION_STATE_MAIL_FROM:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (server_index == 3) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch o_stream_send_str(conn->conn.output,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "250 2.1.0 Ok\r\n");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch o_stream_send_str(conn->conn.output,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "421 testserver Server shutting down for maintenance\r\n");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sleep(4);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch server_connection_deinit(&conn);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return -1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case SERVER_CONNECTION_STATE_RCPT_TO:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (server_index == 2) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch o_stream_send_str(conn->conn.output,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "250 2.1.5 Ok\r\n");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch o_stream_send_str(conn->conn.output,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "421 testserver Server shutting down for maintenance\r\n");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sleep(4);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch server_connection_deinit(&conn);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return -1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case SERVER_CONNECTION_STATE_DATA:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (server_index == 1) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch o_stream_send_str(conn->conn.output,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "354 End data with <CR><LF>.<CR><LF>\r\n");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch o_stream_send_str(conn->conn.output,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "421 testserver Server shutting down for maintenance\r\n");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch sleep(4);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch server_connection_deinit(&conn);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return -1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case SERVER_CONNECTION_STATE_FINISH:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch return 0;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void test_server_unexpected_reply(unsigned int index)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_init = test_unexpected_reply_init;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_input_line = test_unexpected_reply_input_line;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_server_run(index);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstruct _unexpected_reply {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch unsigned int count;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch};

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstruct _unexpected_reply_peer {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _unexpected_reply *context;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch unsigned int index;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_connection *conn;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_transaction *trans;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct timeout *to;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch bool login_callback:1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch bool mail_from_callback:1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch bool rcpt_to_callback:1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch bool rcpt_data_callback:1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch bool data_callback:1;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch};

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_unexpected_reply_login_cb(const struct smtp_reply *reply,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch void *context)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _unexpected_reply_peer *pctx =

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch (struct _unexpected_reply_peer *)context;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch pctx->login_callback = TRUE;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (debug)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_debug("LOGIN REPLY[%u]: %s", pctx->index, smtp_reply_log(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch switch (pctx->index) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 0: case 1: case 2: case 3: case 4:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(smtp_reply_is_success(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 5:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(reply->status == 421);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_unexpected_reply_mail_from_cb(const struct smtp_reply *reply,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _unexpected_reply_peer *pctx)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (debug)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_debug("MAIL FROM REPLY[%u]: %s", pctx->index, smtp_reply_log(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch pctx->mail_from_callback = TRUE;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch switch (pctx->index) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 0: case 1: case 2: case 3:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(smtp_reply_is_success(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 4: case 5:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(reply->status == 421);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_unexpected_reply_rcpt_to_cb(const struct smtp_reply *reply,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _unexpected_reply_peer *pctx)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (debug)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_debug("RCPT TO REPLY[%u]: %s", pctx->index, smtp_reply_log(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch pctx->rcpt_to_callback = TRUE;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch switch (pctx->index) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 0: case 1: case 2:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(smtp_reply_is_success(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 3: case 4: case 5:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(reply->status == 421);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_unexpected_reply_rcpt_data_cb(const struct smtp_reply *reply,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _unexpected_reply_peer *pctx)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (debug)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_debug("RCPT DATA REPLY[%u]: %s", pctx->index, smtp_reply_log(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch pctx->rcpt_data_callback = TRUE;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch switch (pctx->index) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 0:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(smtp_reply_is_success(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 1: case 2:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(reply->status == 421);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 3: case 4: case 5:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_unreached();

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_unexpected_reply_data_cb(const struct smtp_reply *reply,

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _unexpected_reply_peer *pctx)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (debug)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_debug("DATA REPLY[%u]: %s", pctx->index, smtp_reply_log(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch pctx->data_callback = TRUE;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch switch (pctx->index) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 0:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(smtp_reply_is_success(reply));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 1: case 2: case 3: case 4: case 5:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(reply->status == 421);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_unexpected_reply_finished(struct _unexpected_reply_peer *pctx)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct _unexpected_reply *ctx = pctx->context;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (debug)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_debug("FINISHED[%u]", pctx->index);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch if (--ctx->count == 0) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_free(ctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch io_loop_stop(ioloop);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch switch (pctx->index) {

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 0: case 1: case 2:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(pctx->mail_from_callback);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(pctx->rcpt_to_callback);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(pctx->rcpt_data_callback);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(pctx->data_callback);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch case 3: case 4: case 5:

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(pctx->mail_from_callback);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(pctx->rcpt_to_callback);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(!pctx->rcpt_data_callback);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch test_assert(pctx->data_callback);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch break;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch }

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch pctx->trans = NULL;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch timeout_remove(&pctx->to);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_free(pctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschtest_client_unexpected_reply_submit2(struct _unexpected_reply_peer *pctx)

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch{

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct smtp_client_transaction *strans = pctx->trans;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch static const char *message =

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "From: stephan@example.com\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "To: timo@example.com\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Subject: Frop!\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "\r\n"

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch "Frop!\r\n";

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch struct istream *input;

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch timeout_remove(&pctx->to);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch input = i_stream_create_from_data(message, strlen(message));

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_stream_set_name(input, "message");

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch smtp_client_transaction_send

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch (strans, input, test_client_unexpected_reply_data_cb, pctx);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch i_stream_unref(&input);

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch}

9051b704ca26ef833544cf006134f25cddde2525Stephan Bosch

9051b704ca26ef833544cf006134f25cddde2525Stephan Boschstatic void