index/cydir/cydir-storage.c

	cydir-storage.c revision dca6d617a23e3f93af3b8df59acb46478179fe55
/* Copyright (c) 2007-2010 Dovecot authors, see the included COPYING file */

#include "lib.h"
#include "mail-copy.h"
#include "index-mail.h"
#include "cydir-sync.h"
#include "cydir-storage.h"

#include <sys/stat.h>

extern struct mail_storage cydir_storage;
extern struct mailbox cydir_mailbox;

static struct mail_storage *cydir_storage_alloc(void)
{
    struct cydir_storage *storage;
    pool_t pool;

    pool = pool_alloconly_create("cydir storage", 512+256);
    storage = p_new(pool, struct cydir_storage, 1);
    storage->storage = cydir_storage;
    storage->storage.pool = pool;
    return &storage->storage;
}

static void
cydir_storage_get_list_settings(const struct mail_namespace *ns ATTR_UNUSED,
                struct mailbox_list_settings *set)
{
    if (set->layout == NULL)
        set->layout = MAILBOX_LIST_NAME_FS;
    if (set->subscription_fname == NULL)
        set->subscription_fname = CYDIR_SUBSCRIPTION_FILE_NAME;
}

static struct mailbox *
cydir_mailbox_alloc(struct mail_storage *storage, struct mailbox_list *list,
            const char *name, enum mailbox_flags flags)
{
    struct cydir_mailbox *mbox;
    struct index_mailbox_context *ibox;
    pool_t pool;

    /* cydir can't work without index files */
    flags &= ~MAILBOX_FLAG_NO_INDEX_FILES;

    pool = pool_alloconly_create("cydir mailbox", 1024+512);
    mbox = p_new(pool, struct cydir_mailbox, 1);
    mbox->box = cydir_mailbox;
    mbox->box.pool = pool;
    mbox->box.storage = storage;
    mbox->box.list = list;
    mbox->box.mail_vfuncs = &cydir_mail_vfuncs;

    index_storage_mailbox_alloc(&mbox->box, name, flags,
                    CYDIR_INDEX_PREFIX);
    mail_index_set_fsync_types(mbox->box.index,
                   MAIL_INDEX_SYNC_TYPE_APPEND |
                   MAIL_INDEX_SYNC_TYPE_EXPUNGE);

    ibox = INDEX_STORAGE_CONTEXT(&mbox->box);
    ibox->save_commit_pre = cydir_transaction_save_commit_pre;
    ibox->save_commit_post = cydir_transaction_save_commit_post;
    ibox->save_rollback = cydir_transaction_save_rollback;

    mbox->storage = (struct cydir_storage *)storage;
    return &mbox->box;
}

static int cydir_mailbox_open(struct mailbox *box)
{
    struct stat st;

    if (stat(box->path, &st) == 0) {
        /* exists, open it */
    } else if (errno == ENOENT && strcmp(box->name, "INBOX") == 0) {
        /* INBOX always exists, create it */
        if (box->list->v.create_mailbox_dir(box->list,
                            box->name, FALSE) < 0)
            return -1;
    } else if (errno == ENOENT) {
        mail_storage_set_error(box->storage, MAIL_ERROR_NOTFOUND,
            T_MAIL_ERR_MAILBOX_NOT_FOUND(box->name));
        return -1;
    } else if (errno == EACCES) {
        mail_storage_set_critical(box->storage, "%s",
            mail_error_eacces_msg("stat", box->path));
        return -1;
    } else {
        mail_storage_set_critical(box->storage, "stat(%s) failed: %m",
                      box->path);
        return -1;
    }
    return index_storage_mailbox_open(box, FALSE);
}

static int
cydir_mailbox_create(struct mailbox *box, const struct mailbox_update *update,
             bool directory)
{
    if (directory &&
        (box->list->props & MAILBOX_LIST_PROP_NO_NOSELECT) == 0)
        return 0;

    return update == NULL ? 0 :
        index_storage_mailbox_update(box, update);
}

static void cydir_notify_changes(struct mailbox *box)
{
    struct cydir_mailbox *mbox = (struct cydir_mailbox *)box;

    if (box->notify_callback == NULL)
        index_mailbox_check_remove_all(&mbox->box);
    else
        index_mailbox_check_add(&mbox->box, mbox->box.path);
}

struct mail_storage cydir_storage = {
    .name = CYDIR_STORAGE_NAME,
    .class_flags = 0,

    .v = {
        NULL,
        cydir_storage_alloc,
        NULL,
        NULL,
        NULL,
        cydir_storage_get_list_settings,
        NULL,
        cydir_mailbox_alloc,
        NULL
    }
};

struct mailbox cydir_mailbox = {
    .v = {
        index_storage_is_readonly,
        index_storage_allow_new_keywords,
        index_storage_mailbox_enable,
        cydir_mailbox_open,
        index_storage_mailbox_close,
        cydir_mailbox_create,
        index_storage_mailbox_update,
        index_storage_mailbox_delete,
        index_storage_mailbox_rename,
        index_storage_get_status,
        NULL,
        NULL,
        NULL,
        cydir_storage_sync_init,
        index_mailbox_sync_next,
        index_mailbox_sync_deinit,
        NULL,
        cydir_notify_changes,
        index_transaction_begin,
        index_transaction_commit,
        index_transaction_rollback,
        index_transaction_set_max_modseq,
        index_keywords_create,
        index_keywords_create_from_indexes,
        index_keywords_ref,
        index_keywords_unref,
        index_keyword_is_valid,
        index_storage_get_seq_range,
        index_storage_get_uid_range,
        index_storage_get_expunges,
        NULL,
        NULL,
        NULL,
        index_mail_alloc,
        index_header_lookup_init,
        index_header_lookup_deinit,
        index_storage_search_init,
        index_storage_search_deinit,
        index_storage_search_next_nonblock,
        index_storage_search_next_update_seq,
        cydir_save_alloc,
        cydir_save_begin,
        cydir_save_continue,
        cydir_save_finish,
        cydir_save_cancel,
        mail_storage_copy,
        index_storage_is_inconsistent
    }
};