raw-storage.c revision c0d069950af1dbc6a4e5c3de3bf2e437796e3ae0
e59faf65ce864fe95dc00f5d52b8323cdbd0608aTimo Sirainen/* Copyright (c) 2007-2010 Dovecot authors, see the included COPYING file */
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen#include "lib.h"
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen#include "ioloop.h"
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen#include "istream.h"
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen#include "index-mail.h"
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen#include "mail-copy.h"
7a7d2aa11e46195e2d92d6c337d7e78052a5ce67Timo Sirainen#include "mailbox-list-private.h"
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen#include "raw-sync.h"
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen#include "raw-storage.h"
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainenextern struct mail_storage raw_storage;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainenextern struct mailbox raw_mailbox;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainenstatic struct mail_storage *raw_storage_alloc(void)
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen{
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen struct raw_storage *storage;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen pool_t pool;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen pool = pool_alloconly_create("raw storage", 512+256);
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen storage = p_new(pool, struct raw_storage, 1);
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen storage->storage = raw_storage;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen storage->storage.pool = pool;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen return &storage->storage;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen}
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainenstatic void
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainenraw_storage_get_list_settings(const struct mail_namespace *ns ATTR_UNUSED,
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen struct mailbox_list_settings *set)
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen{
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen if (set->layout == NULL)
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen set->layout = MAILBOX_LIST_NAME_FS;
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen if (set->subscription_fname == NULL)
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen set->subscription_fname = RAW_SUBSCRIPTION_FILE_NAME;
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen}
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainenstatic struct mailbox *
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainenraw_mailbox_alloc(struct mail_storage *storage, struct mailbox_list *list,
c0a87e5f3316a57e6f915882fa1951d0fbb74a61Timo Sirainen const char *vname, enum mailbox_flags flags)
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen{
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen struct raw_mailbox *mbox;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen pool_t pool;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen flags |= MAILBOX_FLAG_READONLY | MAILBOX_FLAG_NO_INDEX_FILES;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
3b32bc12710240f86465a00fbb2bd1ef030e6c40Timo Sirainen pool = pool_alloconly_create("raw mailbox", 1024*3);
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen mbox = p_new(pool, struct raw_mailbox, 1);
d22301419109ed4a38351715e6760011421dadecTimo Sirainen mbox->box = raw_mailbox;
d22301419109ed4a38351715e6760011421dadecTimo Sirainen mbox->box.pool = pool;
d22301419109ed4a38351715e6760011421dadecTimo Sirainen mbox->box.storage = storage;
d22301419109ed4a38351715e6760011421dadecTimo Sirainen mbox->box.list = list;
d22301419109ed4a38351715e6760011421dadecTimo Sirainen mbox->box.mail_vfuncs = &raw_mail_vfuncs;
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen
c0a87e5f3316a57e6f915882fa1951d0fbb74a61Timo Sirainen index_storage_mailbox_alloc(&mbox->box, vname, flags, NULL);
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
e5fd6dfd0a492e4708d4dbb7971d7fc5d7b8fd85Timo Sirainen mbox->mtime = mbox->ctime = (time_t)-1;
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen mbox->storage = (struct raw_storage *)storage;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen mbox->size = (uoff_t)-1;
d22301419109ed4a38351715e6760011421dadecTimo Sirainen return &mbox->box;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen}
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainenstatic int raw_mailbox_open(struct mailbox *box)
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen{
e5fd6dfd0a492e4708d4dbb7971d7fc5d7b8fd85Timo Sirainen struct raw_mailbox *mbox = (struct raw_mailbox *)box;
ca98892a6b8a30ffc1fe26fcf02c7d59e3204e7eTimo Sirainen const char *path;
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen int fd;
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen
e5fd6dfd0a492e4708d4dbb7971d7fc5d7b8fd85Timo Sirainen if (box->input != NULL) {
e5fd6dfd0a492e4708d4dbb7971d7fc5d7b8fd85Timo Sirainen mbox->mtime = mbox->ctime = ioloop_time;
d22301419109ed4a38351715e6760011421dadecTimo Sirainen return index_storage_mailbox_open(box, FALSE);
e5fd6dfd0a492e4708d4dbb7971d7fc5d7b8fd85Timo Sirainen }
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
ca98892a6b8a30ffc1fe26fcf02c7d59e3204e7eTimo Sirainen path = box->_path = box->name;
e5fd6dfd0a492e4708d4dbb7971d7fc5d7b8fd85Timo Sirainen mbox->have_filename = TRUE;
ca98892a6b8a30ffc1fe26fcf02c7d59e3204e7eTimo Sirainen fd = open(path, O_RDONLY);
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen if (fd == -1) {
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen if (ENOTFOUND(errno)) {
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen mail_storage_set_error(box->storage,
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen MAIL_ERROR_NOTFOUND,
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen T_MAIL_ERR_MAILBOX_NOT_FOUND(box->name));
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen } else if (!mail_storage_set_error_from_errno(box->storage)) {
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen mail_storage_set_critical(box->storage,
ca98892a6b8a30ffc1fe26fcf02c7d59e3204e7eTimo Sirainen "open(%s) failed: %m", path);
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen }
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen return -1;
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen }
573f0491a5733fe21fa062a455acb4790b4e0499Timo Sirainen box->input = i_stream_create_fd(fd, MAIL_READ_FULL_BLOCK_SIZE, TRUE);
ca98892a6b8a30ffc1fe26fcf02c7d59e3204e7eTimo Sirainen i_stream_set_name(box->input, path);
573f0491a5733fe21fa062a455acb4790b4e0499Timo Sirainen i_stream_set_init_buffer_size(box->input, MAIL_READ_FULL_BLOCK_SIZE);
d22301419109ed4a38351715e6760011421dadecTimo Sirainen return index_storage_mailbox_open(box, FALSE);
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen}
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainenstatic int
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainenraw_mailbox_create(struct mailbox *box,
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen const struct mailbox_update *update ATTR_UNUSED,
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen bool directory ATTR_UNUSED)
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen{
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen mail_storage_set_error(box->storage, MAIL_ERROR_NOTPOSSIBLE,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen "Raw mailbox creation isn't supported");
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen return -1;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen}
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainenstatic int
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainenraw_mailbox_update(struct mailbox *box,
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen const struct mailbox_update *update ATTR_UNUSED)
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen{
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen mail_storage_set_error(box->storage, MAIL_ERROR_NOTPOSSIBLE,
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen "Raw mailbox update isn't supported");
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen return -1;
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen}
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainenstatic void raw_notify_changes(struct mailbox *box ATTR_UNUSED)
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen{
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen}
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainenstruct mail_storage raw_storage = {
7bafda1813454621e03615e83d55bccfa7cc56bdTimo Sirainen .name = RAW_STORAGE_NAME,
e5fd6dfd0a492e4708d4dbb7971d7fc5d7b8fd85Timo Sirainen .class_flags = MAIL_STORAGE_CLASS_FLAG_MAILBOX_IS_FILE |
e5fd6dfd0a492e4708d4dbb7971d7fc5d7b8fd85Timo Sirainen MAIL_STORAGE_CLASS_FLAG_OPEN_STREAMS,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
7bafda1813454621e03615e83d55bccfa7cc56bdTimo Sirainen .v = {
a64adf62fa33f2463a86f990217b0c9078531a40Timo Sirainen NULL,
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen raw_storage_alloc,
563273bdac80393af63b9520cbf4d24cc0efd028Timo Sirainen NULL,
ac26a4607cb12b156f6a42f1ead2881bedd43d94Timo Sirainen NULL,
dca6d617a23e3f93af3b8df59acb46478179fe55Timo Sirainen NULL,
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen raw_storage_get_list_settings,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen NULL,
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen raw_mailbox_alloc,
3e564425db51f3921ce4de11859777135fdedd15Timo Sirainen NULL
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen }
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen};
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainenstruct mailbox raw_mailbox = {
7bafda1813454621e03615e83d55bccfa7cc56bdTimo Sirainen .v = {
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_storage_is_readonly,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_storage_allow_new_keywords,
a2f250a332dfc1e6cd4ffd196c621eb9dbf7b8a1Timo Sirainen index_storage_mailbox_enable,
306cfd77100131c08b243de10f6d40500f4c27c6Timo Sirainen index_storage_mailbox_exists,
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen raw_mailbox_open,
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen index_storage_mailbox_close,
438f12d7a776da695019114884b48188d94613efTimo Sirainen index_storage_mailbox_free,
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen raw_mailbox_create,
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen raw_mailbox_update,
61b0637759146621cbb7edcbd0b03a71cfd66dfeTimo Sirainen index_storage_mailbox_delete,
2649b237dd4690575e75a30b2bf3b39ebd37b835Timo Sirainen index_storage_mailbox_rename,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_storage_get_status,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen NULL,
c0d069950af1dbc6a4e5c3de3bf2e437796e3ae0Timo Sirainen index_storage_list_index_has_changed,
c0d069950af1dbc6a4e5c3de3bf2e437796e3ae0Timo Sirainen index_storage_list_index_update_sync,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen raw_storage_sync_init,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_mailbox_sync_next,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_mailbox_sync_deinit,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen NULL,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen raw_notify_changes,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_transaction_begin,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_transaction_commit,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_transaction_rollback,
ecdce39e5ef4b62eefa9f5818f17d153fd5d710aTimo Sirainen NULL,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_mail_alloc,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_storage_search_init,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_storage_search_deinit,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_storage_search_next_nonblock,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_storage_search_next_update_seq,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen NULL,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen NULL,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen NULL,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen NULL,
e3aeeb634245e80d4f643f8d2eea11d6b72336d8Timo Sirainen NULL,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen mail_storage_copy,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_storage_is_inconsistent
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen }
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen};