25757faf029c369a8318349dafe952e2358df1d8Timo Sirainen

25757faf029c369a8318349dafe952e2358df1d8Timo Sirainen#include "lib.h"

70cb37c37e4dce8f57cd3f882f7444e76b918befTimo Sirainen#include "array.h"

25757faf029c369a8318349dafe952e2358df1d8Timo Sirainen#include "istream.h"

25757faf029c369a8318349dafe952e2358df1d8Timo Sirainen#include "ostream.h"

25757faf029c369a8318349dafe952e2358df1d8Timo Sirainen#include "str.h"

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen#include "message-size.h"

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen#include "message-parser.h"

25757faf029c369a8318349dafe952e2358df1d8Timo Sirainen#include "message-decoder.h"

ba3a54872528db0eae3f36e45592219965b9faf8Timo Sirainen#include "imap-util.h"

ba3a54872528db0eae3f36e45592219965b9faf8Timo Sirainen#include "mail-user.h"

ba3a54872528db0eae3f36e45592219965b9faf8Timo Sirainen#include "mail-storage.h"

ba3a54872528db0eae3f36e45592219965b9faf8Timo Sirainen#include "mail-search.h"

ba3a54872528db0eae3f36e45592219965b9faf8Timo Sirainen#include "mail-namespace.h"

ba3a54872528db0eae3f36e45592219965b9faf8Timo Sirainen#include "doveadm-print.h"

ba3a54872528db0eae3f36e45592219965b9faf8Timo Sirainen#include "doveadm-mail.h"

ba3a54872528db0eae3f36e45592219965b9faf8Timo Sirainen#include "doveadm-mail-list-iter.h"

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen#include "doveadm-mail-iter.h"

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen#include <stdio.h>

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainenstruct fetch_cmd_context {

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen struct doveadm_mail_cmd_context ctx;

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen

0a00890f8ec34ee08d0d391441fca36ed42d7a0cTimo Sirainen struct ostream *output;

0a00890f8ec34ee08d0d391441fca36ed42d7a0cTimo Sirainen struct mail *mail;

0a00890f8ec34ee08d0d391441fca36ed42d7a0cTimo Sirainen

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen ARRAY_DEFINE(fields, const struct fetch_field);

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen ARRAY_TYPE(const_string) header_fields;

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen enum mail_fetch_field wanted_fields;

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen const struct fetch_field *cur_field;

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen};

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainenstruct fetch_field {

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen const char *name;

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen enum mail_fetch_field wanted_fields;

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen int (*print)(struct fetch_cmd_context *ctx);

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen};

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainenstatic int fetch_user(struct fetch_cmd_context *ctx)

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen{

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen doveadm_print(ctx->ctx.cur_mail_user->username);

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen return 0;

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen}

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen

137ea7ca34005345aa2304a940149b7f3774d727Timo Sirainenstatic int fetch_mailbox(struct fetch_cmd_context *ctx)

137ea7ca34005345aa2304a940149b7f3774d727Timo Sirainen{

137ea7ca34005345aa2304a940149b7f3774d727Timo Sirainen const char *value;

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen if (mail_get_special(ctx->mail, MAIL_FETCH_MAILBOX_NAME, &value) < 0)

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen return -1;

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen doveadm_print(value);

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen return 0;

49e513d090753ccbf95560b2f3a21f081a5b6c51Timo Sirainen}

49e513d090753ccbf95560b2f3a21f081a5b6c51Timo Sirainen

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainenstatic int fetch_mailbox_guid(struct fetch_cmd_context *ctx)

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen{

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen struct mailbox_metadata metadata;

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen if (mailbox_get_metadata(ctx->mail->box, MAILBOX_METADATA_GUID,

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen &metadata) < 0)

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen return -1;

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen doveadm_print(guid_128_to_string(metadata.guid));

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen return 0;

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen}

137ea7ca34005345aa2304a940149b7f3774d727Timo Sirainen

137ea7ca34005345aa2304a940149b7f3774d727Timo Sirainenstatic int fetch_seq(struct fetch_cmd_context *ctx)

137ea7ca34005345aa2304a940149b7f3774d727Timo Sirainen{

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen doveadm_print_num(ctx->mail->seq);

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen return 0;

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen}

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainenstatic int fetch_uid(struct fetch_cmd_context *ctx)

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen{

49e513d090753ccbf95560b2f3a21f081a5b6c51Timo Sirainen doveadm_print_num(ctx->mail->uid);

49e513d090753ccbf95560b2f3a21f081a5b6c51Timo Sirainen return 0;

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen}

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainenstatic int fetch_guid(struct fetch_cmd_context *ctx)

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen{

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen const char *value;

12aad74464367f7e8be11eafe1af985bf7b1adecTimo Sirainen

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen if (mail_get_special(ctx->mail, MAIL_FETCH_GUID, &value) < 0)

25757faf029c369a8318349dafe952e2358df1d8Timo Sirainen return -1;

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen doveadm_print(value);

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen return 0;

965ed6ea3fc8f7637bd0d159d2fdb283a191ce34Timo Sirainen}

91e4199476cb2add8143c18583fa57e1decfea88Timo Sirainen

0727e38ac12efb8963a339daf56255e2be1f29fcTimo Sirainenstatic int fetch_flags(struct fetch_cmd_context *ctx)

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen{

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen string_t *str = t_str_new(64);

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen imap_write_flags(str, mail_get_flags(ctx->mail),

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen mail_get_keywords(ctx->mail));

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen doveadm_print(str_c(str));

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen return 0;

08aea01ef9a9d20703e0fcf8618e6195c0037a44Timo Sirainen}

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainenstatic int fetch_hdr(struct fetch_cmd_context *ctx)

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen{

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen struct istream *input;

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen struct message_size hdr_size;

1f1e81aab38d833d1c9cdc244c91fd762e0080d4Timo Sirainen const unsigned char *data;

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen size_t size;

98a711be68ba64e1cabf8cacc150af44421e2ac9Timo Sirainen int ret = 0;

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen if (mail_get_hdr_stream(ctx->mail, &hdr_size, &input) < 0)

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen return -1;

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen input = i_stream_create_limit(input, hdr_size.physical_size);

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen while (!i_stream_is_eof(input)) {

70cb37c37e4dce8f57cd3f882f7444e76b918befTimo Sirainen if (i_stream_read_data(input, &data, &size, 0) == -1)

70cb37c37e4dce8f57cd3f882f7444e76b918befTimo Sirainen break;

25757faf029c369a8318349dafe952e2358df1d8Timo Sirainen if (size == 0)

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen break;

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen doveadm_print_stream(data, size);

25757faf029c369a8318349dafe952e2358df1d8Timo Sirainen i_stream_skip(input, size);

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen }

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen if (input->stream_errno != 0) {

08aea01ef9a9d20703e0fcf8618e6195c0037a44Timo Sirainen i_error("read() failed: %m");

08aea01ef9a9d20703e0fcf8618e6195c0037a44Timo Sirainen ret = -1;

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen }

08aea01ef9a9d20703e0fcf8618e6195c0037a44Timo Sirainen i_stream_unref(&input);

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen doveadm_print_stream(NULL, 0);

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen return ret;

25757faf029c369a8318349dafe952e2358df1d8Timo Sirainen}

25757faf029c369a8318349dafe952e2358df1d8Timo Sirainen

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainenstatic int fetch_hdr_field(struct fetch_cmd_context *ctx)

25757faf029c369a8318349dafe952e2358df1d8Timo Sirainen{

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen const char *const *value;

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen string_t *str = t_str_new(256);

98a711be68ba64e1cabf8cacc150af44421e2ac9Timo Sirainen bool add_lf = FALSE;

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen

e9503210d3521a6833ed62dc332fc42ffb0e7a13Timo Sirainen if (mail_get_headers(ctx->mail, ctx->cur_field->name, &value) < 0)

70cb37c37e4dce8f57cd3f882f7444e76b918befTimo Sirainen return -1;

25757faf029c369a8318349dafe952e2358df1d8Timo Sirainen

for (; *value != NULL; value++) {

if (add_lf)

str_append_c(str, '\n');

str_append(str, *value);

add_lf = TRUE;

}

doveadm_print(str_c(str));

return 0;

}

static int fetch_body(struct fetch_cmd_context *ctx)

{

struct istream *input;

struct message_size hdr_size;

const unsigned char *data;

size_t size;

int ret = 0;

if (mail_get_stream(ctx->mail, &hdr_size, NULL, &input) < 0)

return -1;

i_stream_skip(input, hdr_size.physical_size);

while (!i_stream_is_eof(input)) {

if (i_stream_read_data(input, &data, &size, 0) == -1)

break;

if (size == 0)

break;

doveadm_print_stream(data, size);

i_stream_skip(input, size);

}

if (input->stream_errno != 0) {

i_error("read() failed: %m");

ret = -1;

}

doveadm_print_stream(NULL, 0);

return ret;

}

static int fetch_text(struct fetch_cmd_context *ctx)

{

struct istream *input;

const unsigned char *data;

size_t size;

int ret = 0;

if (mail_get_stream(ctx->mail, NULL, NULL, &input) < 0)

return -1;

while (!i_stream_is_eof(input)) {

if (i_stream_read_data(input, &data, &size, 0) == -1)

break;

if (size == 0)

break;

doveadm_print_stream(data, size);

i_stream_skip(input, size);

}

if (input->stream_errno != 0) {

i_error("read() failed: %m");

ret = -1;

}

doveadm_print_stream(NULL, 0);

return ret;

}

static int fetch_text_utf8(struct fetch_cmd_context *ctx)

{

struct istream *input;

struct message_parser_ctx *parser;

struct message_decoder_context *decoder;

struct message_block raw_block, block;

struct message_part *parts;

int ret = 0;

if (mail_get_stream(ctx->mail, NULL, NULL, &input) < 0)

return -1;

parser = message_parser_init(pool_datastack_create(), input,

MESSAGE_HEADER_PARSER_FLAG_CLEAN_ONELINE,

0);

decoder = message_decoder_init(0);

while ((ret = message_parser_parse_next_block(parser, &raw_block)) > 0) {

if (!message_decoder_decode_next_block(decoder, &raw_block,

&block))

continue;

if (block.hdr == NULL) {

if (block.size > 0)

doveadm_print_stream(block.data, block.size);

} else if (block.hdr->eoh)

doveadm_print_stream("\n", 1);

else {

i_assert(block.hdr->name_len > 0);

doveadm_print_stream(block.hdr->name,

block.hdr->name_len);

doveadm_print_stream(": ", 2);

if (block.hdr->full_value_len > 0) {

doveadm_print_stream(block.hdr->full_value,

block.hdr->full_value_len);

}

doveadm_print_stream("\n", 1);

}

}

i_assert(ret != 0);

message_decoder_deinit(&decoder);

(void)message_parser_deinit(&parser, &parts);

if (input->stream_errno != 0) {

i_error("read() failed: %m");

ret = -1;

}

doveadm_print_stream(NULL, 0);

return ret;

}

static int fetch_size_physical(struct fetch_cmd_context *ctx)

{

uoff_t size;

if (mail_get_physical_size(ctx->mail, &size) < 0)

return -1;

doveadm_print_num(size);

return 0;

}

static int fetch_size_virtual(struct fetch_cmd_context *ctx)

{

uoff_t size;

if (mail_get_virtual_size(ctx->mail, &size) < 0)

return -1;

doveadm_print_num(size);

return 0;

}

static int fetch_date_received(struct fetch_cmd_context *ctx)

{

time_t t;

if (mail_get_received_date(ctx->mail, &t) < 0)

return -1;

doveadm_print(unixdate2str(t));

return 0;

}

static int fetch_date_sent(struct fetch_cmd_context *ctx)

{

time_t t;

int tz;

char chr;

if (mail_get_date(ctx->mail, &t, &tz) < 0)

return -1;

chr = tz < 0 ? '-' : '+';

if (tz < 0) tz = -tz;

doveadm_print(t_strdup_printf("%s (%c%02u%02u)", unixdate2str(t),

chr, tz/60, tz%60));

return 0;

}

static int fetch_date_saved(struct fetch_cmd_context *ctx)

{

time_t t;

if (mail_get_save_date(ctx->mail, &t) < 0)

return -1;

doveadm_print(unixdate2str(t));

return 0;

}

static int fetch_imap_envelope(struct fetch_cmd_context *ctx)

{

const char *value;

if (mail_get_special(ctx->mail, MAIL_FETCH_IMAP_ENVELOPE, &value) < 0)

return -1;

doveadm_print(value);

return 0;

}

static int fetch_imap_body(struct fetch_cmd_context *ctx)

{

const char *value;

if (mail_get_special(ctx->mail, MAIL_FETCH_IMAP_BODY, &value) < 0)

return -1;

doveadm_print(value);

return 0;

}

static int fetch_imap_bodystructure(struct fetch_cmd_context *ctx)

{

const char *value;

if (mail_get_special(ctx->mail, MAIL_FETCH_IMAP_BODYSTRUCTURE, &value) < 0)

return -1;

doveadm_print(value);

return 0;

}

static int fetch_pop3_uidl(struct fetch_cmd_context *ctx)

{

const char *value;

if (mail_get_special(ctx->mail, MAIL_FETCH_UIDL_BACKEND, &value) < 0)

return -1;

doveadm_print(value);

return 0;

}

static const struct fetch_field fetch_fields[] = {

{ "user", 0, fetch_user },

{ "mailbox", 0, fetch_mailbox },

{ "mailbox-guid", 0, fetch_mailbox_guid },

{ "seq", 0, fetch_seq },

{ "uid", 0, fetch_uid },

{ "guid", 0, fetch_guid },

{ "flags", MAIL_FETCH_FLAGS, fetch_flags },

{ "hdr", MAIL_FETCH_STREAM_HEADER, fetch_hdr },

{ "body", MAIL_FETCH_STREAM_BODY, fetch_body },

{ "text", MAIL_FETCH_STREAM_HEADER |

MAIL_FETCH_STREAM_BODY, fetch_text },

{ "text.utf8", MAIL_FETCH_STREAM_HEADER |

MAIL_FETCH_STREAM_BODY, fetch_text_utf8 },

{ "size.physical", MAIL_FETCH_PHYSICAL_SIZE, fetch_size_physical },

{ "size.virtual", MAIL_FETCH_VIRTUAL_SIZE, fetch_size_virtual },

{ "date.received", MAIL_FETCH_RECEIVED_DATE, fetch_date_received },

{ "date.sent", MAIL_FETCH_DATE, fetch_date_sent },

{ "date.saved", MAIL_FETCH_SAVE_DATE, fetch_date_saved },

{ "imap.envelope", MAIL_FETCH_IMAP_ENVELOPE, fetch_imap_envelope },

{ "imap.body", MAIL_FETCH_IMAP_BODY, fetch_imap_body },

{ "imap.bodystructure", MAIL_FETCH_IMAP_BODYSTRUCTURE, fetch_imap_bodystructure },

{ "pop3.uidl", MAIL_FETCH_UIDL_BACKEND, fetch_pop3_uidl }

};

static const struct fetch_field *fetch_field_find(const char *name)

{

unsigned int i;

for (i = 0; i < N_ELEMENTS(fetch_fields); i++) {

if (strcmp(fetch_fields[i].name, name) == 0)

return &fetch_fields[i];

}

return NULL;

}

static void print_fetch_fields(void)

{

unsigned int i;

fprintf(stderr, "Available fetch fields: %s", fetch_fields[0].name);

for (i = 1; i < N_ELEMENTS(fetch_fields); i++)

fprintf(stderr, " %s", fetch_fields[i].name);

fprintf(stderr, "\n");

}

static void parse_fetch_fields(struct fetch_cmd_context *ctx, const char *str)

{

const char *const *fields, *name;

const struct fetch_field *field;

struct fetch_field hdr_field;

memset(&hdr_field, 0, sizeof(hdr_field));

hdr_field.print = fetch_hdr_field;

t_array_init(&ctx->fields, 32);

t_array_init(&ctx->header_fields, 32);

fields = t_strsplit_spaces(str, " ");

for (; *fields != NULL; fields++) {

name = t_str_lcase(*fields);

doveadm_print_header_simple(name);

if (strncmp(name, "hdr.", 4) == 0) {

name += 4;

hdr_field.name = name;

array_append(&ctx->fields, &hdr_field, 1);

array_append(&ctx->header_fields, &name, 1);

} else {

field = fetch_field_find(name);

if (field == NULL) {

print_fetch_fields();

i_fatal("Unknown fetch field: %s", name);

}

ctx->wanted_fields |= field->wanted_fields;

array_append(&ctx->fields, field, 1);

}

}

(void)array_append_space(&ctx->header_fields);

}

static void cmd_fetch_mail(struct fetch_cmd_context *ctx)

{

const struct fetch_field *field;

struct mail *mail = ctx->mail;

array_foreach(&ctx->fields, field) {

ctx->cur_field = field;

if (field->print(ctx) < 0) {

i_error("fetch(%s) failed for box=%s uid=%u: %s",

field->name, mailbox_get_vname(mail->box),

mail->uid, mailbox_get_last_error(mail->box, NULL));

}

}

}

static int

cmd_fetch_box(struct fetch_cmd_context *ctx, const struct mailbox_info *info)

{

struct doveadm_mail_iter *iter;

struct mailbox_transaction_context *trans;

if (doveadm_mail_iter_init(info, ctx->ctx.search_args,

ctx->wanted_fields,

array_idx(&ctx->header_fields, 0),

&trans, &iter) < 0)

return -1;

while (doveadm_mail_iter_next(iter, &ctx->mail)) {

T_BEGIN {

cmd_fetch_mail(ctx);

} T_END;

}

return doveadm_mail_iter_deinit(&iter);

}

static void

cmd_fetch_run(struct doveadm_mail_cmd_context *_ctx, struct mail_user *user)

{

struct fetch_cmd_context *ctx = (struct fetch_cmd_context *)_ctx;

const enum mailbox_list_iter_flags iter_flags =

MAILBOX_LIST_ITER_NO_AUTO_BOXES |

MAILBOX_LIST_ITER_RETURN_NO_FLAGS;

struct doveadm_mail_list_iter *iter;

const struct mailbox_info *info;

iter = doveadm_mail_list_iter_init(user, _ctx->search_args, iter_flags);

while ((info = doveadm_mail_list_iter_next(iter)) != NULL) T_BEGIN {

(void)cmd_fetch_box(ctx, info);

} T_END;

doveadm_mail_list_iter_deinit(&iter);

}

static void cmd_fetch_deinit(struct doveadm_mail_cmd_context *_ctx)

{

struct fetch_cmd_context *ctx = (struct fetch_cmd_context *)_ctx;

o_stream_unref(&ctx->output);

}

static void cmd_fetch_init(struct doveadm_mail_cmd_context *_ctx,

const char *const args[])

{

struct fetch_cmd_context *ctx = (struct fetch_cmd_context *)_ctx;

const char *fetch_fields = args[0];

if (fetch_fields == NULL || args[1] == NULL)

doveadm_mail_help_name("fetch");

parse_fetch_fields(ctx, fetch_fields);

_ctx->search_args = doveadm_mail_build_search_args(args + 1);

ctx->output = o_stream_create_fd(STDOUT_FILENO, 0, FALSE);

}

static struct doveadm_mail_cmd_context *cmd_fetch_alloc(void)

{

struct fetch_cmd_context *ctx;

ctx = doveadm_mail_cmd_alloc(struct fetch_cmd_context);

ctx->ctx.v.init = cmd_fetch_init;

ctx->ctx.v.run = cmd_fetch_run;

ctx->ctx.v.deinit = cmd_fetch_deinit;

doveadm_print_init("pager");

return &ctx->ctx;

}

struct doveadm_mail_cmd cmd_fetch = {

cmd_fetch_alloc, "fetch", "<fields> <search query>"

};