Mercurial > dovecot > original-hg > dovecot-1.2
view src/imap/cmd-copy.c @ 3245:6491dab63e54 HEAD
Added input stream parameter to mailbox_open(). With mbox it now allows
opening a read-only mbox using a stream.
author | Timo Sirainen <tss@iki.fi> |
---|---|
date | Tue, 29 Mar 2005 16:33:07 +0300 |
parents | 2715077f9c3e |
children | 3de464cb604f |
line wrap: on
line source
/* Copyright (C) 2002 Timo Sirainen */ #include "common.h" #include "str.h" #include "commands.h" #include "imap-search.h" static int fetch_and_copy(struct mailbox_transaction_context *t, struct mailbox *srcbox, struct mail_search_arg *search_args) { struct mail_search_context *search_ctx; struct mailbox_transaction_context *src_trans; struct mail *mail; int ret; src_trans = mailbox_transaction_begin(srcbox, 0); search_ctx = mailbox_search_init(src_trans, NULL, search_args, NULL); mail = mail_alloc(src_trans, MAIL_FETCH_STREAM_HEADER | MAIL_FETCH_STREAM_BODY, NULL); ret = 1; while (mailbox_search_next(search_ctx, mail) > 0) { if (mail->expunged) { ret = 0; break; } if (mailbox_copy(t, mail, NULL) < 0) { ret = -1; break; } } mail_free(mail); if (mailbox_search_deinit(search_ctx) < 0) ret = -1; if (mailbox_transaction_commit(src_trans, 0) < 0) ret = -1; return ret; } int cmd_copy(struct client_command_context *cmd) { struct client *client = cmd->client; struct mail_storage *storage; struct mailbox *destbox; struct mailbox_transaction_context *t; struct mail_search_arg *search_arg; const char *messageset, *mailbox; enum mailbox_sync_flags sync_flags = 0; int ret; /* <message set> <mailbox> */ if (!client_read_string_args(cmd, 2, &messageset, &mailbox)) return FALSE; if (!client_verify_open_mailbox(cmd)) return TRUE; /* open the destination mailbox */ if (!client_verify_mailbox_name(cmd, mailbox, TRUE, FALSE)) return TRUE; search_arg = imap_search_get_arg(cmd, messageset, cmd->uid); if (search_arg == NULL) return TRUE; storage = client_find_storage(cmd, &mailbox); if (storage == NULL) return TRUE; if (mailbox_equals(client->mailbox, storage, mailbox)) destbox = client->mailbox; else { destbox = mailbox_open(storage, mailbox, NULL, MAILBOX_OPEN_FAST | MAILBOX_OPEN_KEEP_RECENT); if (destbox == NULL) { client_send_storage_error(cmd, storage); return TRUE; } } t = mailbox_transaction_begin(destbox, MAILBOX_TRANSACTION_FLAG_EXTERNAL); ret = fetch_and_copy(t, client->mailbox, search_arg); if (ret <= 0) mailbox_transaction_rollback(t); else { if (mailbox_transaction_commit(t, 0) < 0) ret = -1; } if (destbox != client->mailbox) { sync_flags |= MAILBOX_SYNC_FLAG_FAST; mailbox_close(destbox); } if (ret > 0) return cmd_sync(cmd, sync_flags, "OK Copy completed."); else if (ret == 0) { /* some messages were expunged, sync them */ return cmd_sync(cmd, 0, "NO Some of the requested messages no longer exist."); } else { client_send_storage_error(cmd, storage); return TRUE; } }