6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch#include "lib.h"

bdd36cfdba3ff66d25570a9ff568d69e1eb543cfTimo Sirainen#include "ioloop.h"

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch#include "array.h"

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch#include "llist.h"

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch#include "istream.h"

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch#include "eacces-error.h"

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch#include "mkdir-parents.h"

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch#include "var-expand.h"

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch#include "mail-index-private.h"

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch#include "mail-index-alloc-cache.h"

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch#include "mailbox-list-private.h"

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch#include "mail-storage-private.h"

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch#include "mail-storage-settings.h"

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch#include "mail-namespace.h"

e9c433c5b8ef9a1b4246ebe10beb90fa01e05cafPhil Carmody#include "mail-search.h"

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch#include "mailbox-search-result-private.h"

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch#include <stdlib.h>

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch#include <ctype.h>

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch#define MAILBOX_DELETE_RETRY_SECS (60*5)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Boschstruct mail_storage_module_register mail_storage_module_register = { 0 };

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschstruct mail_module_register mail_module_register = { 0 };

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschstruct mail_storage_mail_index_module mail_storage_mail_index_module =

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch MODULE_CONTEXT_INIT(&mail_index_module_register);

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan BoschARRAY_TYPE(mail_storage) mail_storage_classes;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschvoid mail_storage_init(void)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mailbox_lists_init();

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch mail_storage_hooks_init();

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch i_array_init(&mail_storage_classes, 8);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschvoid mail_storage_deinit(void)

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (array_is_created(&mail_storage_classes))

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch array_free(&mail_storage_classes);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_storage_hooks_deinit();

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mailbox_lists_deinit();

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschvoid mail_storage_class_register(struct mail_storage *storage_class)

f883bf3eff62f5d27df5ee9ee664edc38a77937fStephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch i_assert(mail_storage_find_class(storage_class->name) == NULL);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* append it after the list, so the autodetection order is correct */

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch array_append(&mail_storage_classes, &storage_class, 1);

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch}

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch

f883bf3eff62f5d27df5ee9ee664edc38a77937fStephan Boschvoid mail_storage_class_unregister(struct mail_storage *storage_class)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mail_storage *const *classes;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch unsigned int i, count;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch classes = array_get(&mail_storage_classes, &count);

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch for (i = 0; i < count; i++) {

f883bf3eff62f5d27df5ee9ee664edc38a77937fStephan Bosch if (classes[i] == storage_class) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch array_delete(&mail_storage_classes, i, 1);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch break;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

f883bf3eff62f5d27df5ee9ee664edc38a77937fStephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschstruct mail_storage *mail_storage_find_class(const char *name)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mail_storage *const *classes;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch unsigned int i, count;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

f883bf3eff62f5d27df5ee9ee664edc38a77937fStephan Bosch i_assert(name != NULL);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch classes = array_get(&mail_storage_classes, &count);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch for (i = 0; i < count; i++) {

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch if (strcasecmp(classes[i]->name, name) == 0)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return classes[i];

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return NULL;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Boschstatic struct mail_storage *

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschmail_storage_autodetect(const struct mail_namespace *ns,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mailbox_list_settings *set)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mail_storage *const *classes;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch unsigned int i, count;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch classes = array_get(&mail_storage_classes, &count);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch for (i = 0; i < count; i++) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (classes[i]->v.autodetect != NULL) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (classes[i]->v.autodetect(ns, set))

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return classes[i];

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch return NULL;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschstatic void

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Boschmail_storage_set_autodetection(const char **data, const char **driver)

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch const char *p;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* check if data is in driver:data format (eg. mbox:~/mail) */

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch p = *data;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch while (i_isalnum(*p)) p++;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (*p == ':' && p != *data) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* no autodetection if the storage driver is given. */

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch *driver = t_strdup_until(*data, p);

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch *data = p + 1;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschstatic struct mail_storage *

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschmail_storage_get_class(struct mail_namespace *ns, const char *driver,

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch struct mailbox_list_settings *list_set,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch const char **error_r)

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mail_storage *storage_class;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch const char *home;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch if (driver != NULL) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch storage_class = mail_storage_find_class(driver);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (storage_class == NULL) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch *error_r = t_strdup_printf(

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch "Unknown mail storage driver %s", driver);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return NULL;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch storage_class->v.get_list_settings(ns, list_set);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return storage_class;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch storage_class = mail_storage_autodetect(ns, list_set);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (storage_class != NULL)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return storage_class;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (ns->set->location == NULL || *ns->set->location == '\0') {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch (void)mail_user_get_home(ns->user, &home);

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch if (home == NULL || *home == '\0') home = "(not set)";

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch *error_r = t_strdup_printf(

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch "Mail storage autodetection failed with home=%s", home);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch } else {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch *error_r = t_strdup_printf(

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch "Ambiguous mail location setting, "

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch "don't know what to do with it: %s "

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch "(try prefixing it with mbox: or maildir:)",

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch ns->set->location);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return NULL;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschstatic int

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschmail_storage_create_root(struct mailbox_list *list,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch enum mail_storage_flags flags, const char **error_r)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch const char *root_dir, *origin;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch struct stat st;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mode_t mode;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch gid_t gid;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch root_dir = mailbox_list_get_path(list, NULL,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch MAILBOX_LIST_PATH_TYPE_MAILBOX);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (root_dir == NULL) {

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch /* storage doesn't use directories (e.g. shared root) */

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return 0;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (stat(root_dir, &st) == 0) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* ok */

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return 0;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch } else if (errno == EACCES) {

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch *error_r = mail_error_eacces_msg("stat", root_dir);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return -1;

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch } else if (errno != ENOENT && errno != ENOTDIR) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch *error_r = t_strdup_printf("stat(%s) failed: %m", root_dir);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return -1;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch } else if (list->ns->type == NAMESPACE_SHARED) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* can't create a new user, but we don't want to fail

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch } else if ((flags & MAIL_STORAGE_FLAG_NO_AUTOCREATE) != 0) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch *error_r = t_strdup_printf(

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch "Root mail directory doesn't exist: %s", root_dir);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return -1;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* we need to create the root directory. */

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mailbox_list_get_dir_permissions(list, NULL, &mode, &gid, &origin);

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch if (mkdir_parents_chgrp(root_dir, mode, gid, origin) < 0 &&

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch errno != EEXIST) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch *error_r = mail_error_create_eacces_msg("mkdir", root_dir);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return -1;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch } else {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* created */

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return 0;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschstatic struct mail_storage *

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschmail_storage_find(struct mail_user *user,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch const struct mail_storage *storage_class,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch const struct mailbox_list_settings *set)

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mail_storage *storage = user->storages;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

17c29e3e2246972c3d988e05d91b9286398a624fStephan Bosch for (; storage != NULL; storage = storage->next) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (strcmp(storage->name, storage_class->name) == 0 &&

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch ((storage->class_flags &

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch MAIL_STORAGE_CLASS_FLAG_UNIQUE_ROOT) == 0 ||

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch strcmp(storage->unique_root_dir, set->root_dir) == 0))

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch return storage;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return NULL;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschint mail_storage_create(struct mail_namespace *ns, const char *driver,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch enum mail_storage_flags flags, const char **error_r)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch struct mail_storage *storage_class, *storage = NULL;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mailbox_list_settings list_set;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch enum mailbox_list_flags list_flags = 0;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch const char *data = ns->set->location;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch const char *p;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if ((flags & MAIL_STORAGE_FLAG_KEEP_HEADER_MD5) == 0 &&

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch ns->mail_set->pop3_uidl_format != NULL) {

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch /* if pop3_uidl_format contains %m, we want to keep the

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch p = ns->mail_set->pop3_uidl_format;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch while ((p = strchr(p, '%')) != NULL) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (p[1] == '%')

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch p += 2;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch else if (var_get_key(++p) == 'm') {

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch flags |= MAIL_STORAGE_FLAG_KEEP_HEADER_MD5;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch break;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch memset(&list_set, 0, sizeof(list_set));

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (data == NULL) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* autodetect */

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch } else if (driver != NULL && strcmp(driver, "shared") == 0) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* internal shared namespace */

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch list_set.root_dir = ns->user->set->base_dir;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch } else {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (driver == NULL)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_storage_set_autodetection(&data, &driver);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (mailbox_list_settings_parse(data, &list_set, ns,

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch error_r) < 0)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return -1;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if ((list_set.root_dir == NULL || *list_set.root_dir == '\0') &&

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch (driver != NULL ||

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch (flags & MAIL_STORAGE_FLAG_NO_AUTODETECTION) != 0)) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch *error_r = "Root mail directory not given";

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return -1;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch storage_class = mail_storage_get_class(ns, driver, &list_set, error_r);

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch if (storage_class == NULL)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return -1;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch i_assert(list_set.layout != NULL);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (ns->list == NULL) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* first storage for namespace */

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch if (mail_storage_is_mailbox_file(storage_class))

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch list_flags |= MAILBOX_LIST_FLAG_MAILBOX_FILES;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (mailbox_list_create(list_set.layout, ns, &list_set,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch list_flags, error_r) < 0) {

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch *error_r = t_strdup_printf("Mailbox list driver %s: %s",

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch list_set.layout, *error_r);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return -1;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (mail_storage_create_root(ns->list, flags, error_r) < 0)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return -1;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch storage = mail_storage_find(ns->user, storage_class, &list_set);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (storage != NULL) {

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch /* using an existing storage */

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch storage->refcount++;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_namespace_add_storage(ns, storage);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return 0;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch storage = storage_class->v.alloc();

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch storage->refcount = 1;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch storage->storage_class = storage_class;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch storage->user = ns->user;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch storage->set = ns->mail_set;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch storage->flags = flags;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch p_array_init(&storage->module_contexts, storage->pool, 5);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (storage->v.create != NULL &&

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch storage->v.create(storage, ns, error_r) < 0) {

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch *error_r = t_strdup_printf("%s: %s", storage->name, *error_r);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch pool_unref(&storage->pool);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return -1;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch T_BEGIN {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch hook_mail_storage_created(storage);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch } T_END;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch DLLIST_PREPEND(&ns->user->storages, storage);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_namespace_add_storage(ns, storage);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return 0;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschvoid mail_storage_ref(struct mail_storage *storage)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch storage->refcount++;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschvoid mail_storage_unref(struct mail_storage **_storage)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mail_storage *storage = *_storage;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch i_assert(storage->refcount > 0);

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* set *_storage=NULL only after calling destroy() callback.

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (--storage->refcount > 0) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch *_storage = NULL;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch return;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch DLLIST_REMOVE(&storage->user->storages, storage);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (storage->v.destroy != NULL)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch storage->v.destroy(storage);

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch i_free(storage->error_string);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch *_storage = NULL;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch pool_unref(&storage->pool);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_index_alloc_cache_destroy_unrefed();

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschvoid mail_storage_clear_error(struct mail_storage *storage)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch i_free_and_null(storage->error_string);

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch storage->error = MAIL_ERROR_NONE;

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch}

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Boschvoid mail_storage_set_error(struct mail_storage *storage,

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch enum mail_error error, const char *string)

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch{

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch i_free(storage->error_string);

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch storage->error_string = i_strdup(string);

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch storage->error = error;

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch}

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Boschvoid mail_storage_set_internal_error(struct mail_storage *storage)

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch{

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch struct tm *tm;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch char str[256];

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch tm = localtime(&ioloop_time);

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch i_free(storage->error_string);

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch storage->error_string =

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch strftime(str, sizeof(str),

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch MAIL_ERRSTR_CRITICAL_MSG_STAMP, tm) > 0 ?

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch i_strdup(str) : i_strdup(MAIL_ERRSTR_CRITICAL_MSG);

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch storage->error = MAIL_ERROR_TEMP;

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch}

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Boschvoid mail_storage_set_critical(struct mail_storage *storage,

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch const char *fmt, ...)

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch{

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch va_list va;

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch mail_storage_clear_error(storage);

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch if (fmt != NULL) {

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch va_start(va, fmt);

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch i_error("%s", t_strdup_vprintf(fmt, va));

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch va_end(va);

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch /* critical errors may contain sensitive data, so let user

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch mail_storage_set_internal_error(storage);

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch }

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch}

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Boschvoid mail_storage_copy_list_error(struct mail_storage *storage,

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch struct mailbox_list *list)

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch{

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch const char *str;

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch enum mail_error error;

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch str = mailbox_list_get_last_error(list, &error);

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch mail_storage_set_error(storage, error, str);

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch}

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Boschvoid mail_storage_set_index_error(struct mailbox *box)

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch{

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch if (mail_index_is_deleted(box->index))

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch mailbox_set_deleted(box);

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch else

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_storage_set_internal_error(box->storage);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_index_reset_error(box->index);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschconst struct mail_storage_settings *

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschmail_storage_get_settings(struct mail_storage *storage)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return storage->set;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschstruct mail_user *mail_storage_get_user(struct mail_storage *storage)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return storage->user;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschvoid mail_storage_set_callbacks(struct mail_storage *storage,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mail_storage_callbacks *callbacks,

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch void *context)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch storage->callbacks = *callbacks;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch storage->callback_context = context;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschint mail_storage_purge(struct mail_storage *storage)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return storage->v.purge == NULL ? 0 :

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch storage->v.purge(storage);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschconst char *mail_storage_get_last_error(struct mail_storage *storage,

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch enum mail_error *error_r)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* We get here only in error situations, so we have to return some

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (storage->error == MAIL_ERROR_NONE) {

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch if (error_r != NULL)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch *error_r = MAIL_ERROR_TEMP;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return storage->error_string != NULL ? storage->error_string :

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch "BUG: Unknown internal error";

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (storage->error_string == NULL) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* This shouldn't happen.. */

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch storage->error_string =

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch i_strdup_printf("BUG: Unknown 0x%x error",

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch storage->error);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (error_r != NULL)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch *error_r = storage->error;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch return storage->error_string;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschbool mail_storage_is_mailbox_file(struct mail_storage *storage)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return (storage->class_flags &

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch MAIL_STORAGE_CLASS_FLAG_MAILBOX_IS_FILE) != 0;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Boschbool mail_storage_set_error_from_errno(struct mail_storage *storage)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch const char *error_string;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch enum mail_error error;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (!mail_error_from_errno(&error, &error_string))

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return FALSE;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch if (storage->set->mail_debug && error != MAIL_ERROR_NOTFOUND) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* debugging is enabled - admin may be debugging a

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return FALSE;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_storage_set_error(storage, error, error_string);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return TRUE;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschstruct mailbox *mailbox_alloc(struct mailbox_list *list, const char *name,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch enum mailbox_flags flags)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mailbox_list *new_list = list;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mail_storage *storage;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch struct mailbox *box;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (mailbox_list_get_storage(&new_list, &name, &storage) < 0) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* just use the first storage. FIXME: does this break? */

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch storage = list->ns->storage;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch T_BEGIN {

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch box = storage->v.mailbox_alloc(storage, new_list, name, flags);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch hook_mailbox_allocated(box);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch } T_END;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return box;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschstatic int mailbox_open_full(struct mailbox *box, struct istream *input)

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch int ret;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (box->opened)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return 0;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (!mailbox_list_is_valid_existing_name(box->list, box->name)) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_storage_set_error(box->storage, MAIL_ERROR_PARAMS,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch "Invalid mailbox name");

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch return -1;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (input != NULL) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if ((box->storage->class_flags &

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch MAIL_STORAGE_CLASS_FLAG_OPEN_STREAMS) == 0) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_storage_set_critical(box->storage,

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch "Storage doesn't support streamed mailboxes");

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return -1;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->input = input;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->flags |= MAILBOX_FLAG_READONLY;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch i_stream_ref(box->input);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch T_BEGIN {

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch ret = box->v.open(box);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch } T_END;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (ret < 0 && box->storage->error == MAIL_ERROR_NOTFOUND &&

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->input == NULL && box->inbox) T_BEGIN {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* INBOX should always exist. try to create it and retry. */

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch (void)mailbox_create(box, NULL, FALSE);

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch mailbox_close(box);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch ret = box->v.open(box);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (ret < 0 && !box->storage->user->inbox_open_error_logged) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->storage->user->inbox_open_error_logged = TRUE;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch i_error("Opening INBOX failed: %s",

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_storage_get_last_error(box->storage, NULL));

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch } T_END;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch if (ret < 0) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (box->input != NULL)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch i_stream_unref(&box->input);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return -1;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->list->ns->flags |= NAMESPACE_FLAG_USABLE;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return 0;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschint mailbox_open(struct mailbox *box)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return mailbox_open_full(box, NULL);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschint mailbox_open_stream(struct mailbox *box, struct istream *input)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return mailbox_open_full(box, input);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschint mailbox_enable(struct mailbox *box, enum mailbox_feature features)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return box->v.enable(box, features);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschenum mailbox_feature mailbox_get_enabled_features(struct mailbox *box)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return box->enabled_features;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschvoid mailbox_close(struct mailbox *box)

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (!box->opened)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (box->transaction_count != 0) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch i_panic("Trying to close mailbox %s with open transactions",

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->name);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->v.close(box);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->opened = FALSE;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->mailbox_deleted = FALSE;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->backend_readonly = FALSE;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch array_clear(&box->search_results);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Boschvoid mailbox_free(struct mailbox **_box)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mailbox *box = *_box;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch *_box = NULL;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mailbox_close(box);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->v.free(box);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch pool_unref(&box->pool);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschint mailbox_create(struct mailbox *box, const struct mailbox_update *update,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch bool directory)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

e9c433c5b8ef9a1b4246ebe10beb90fa01e05cafPhil Carmody if (!mailbox_list_is_valid_create_name(box->list, box->name)) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_storage_set_error(box->storage, MAIL_ERROR_PARAMS,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch "Invalid mailbox name");

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return -1;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (box->list->v.create_mailbox_dir(box->list, box->name,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch directory) < 0) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_storage_copy_list_error(box->storage, box->list);

e9c433c5b8ef9a1b4246ebe10beb90fa01e05cafPhil Carmody return -1;

e9c433c5b8ef9a1b4246ebe10beb90fa01e05cafPhil Carmody }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mailbox_refresh_permissions(box);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return box->v.create(box, update, directory);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Boschint mailbox_update(struct mailbox *box, const struct mailbox_update *update)

639bb36b12b9f9bb54c8bb1be50eac623622f8a0Timo Sirainen{

639bb36b12b9f9bb54c8bb1be50eac623622f8a0Timo Sirainen return box->v.update(box, update);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschstatic int mailbox_mark_index_deleted(struct mailbox *box, bool del)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch enum mail_index_transaction_flags trans_flags = 0;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch struct mail_index_transaction *trans;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch trans_flags = del ? 0 : MAIL_INDEX_TRANSACTION_FLAG_EXTERNAL;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch trans = mail_index_transaction_begin(box->view, trans_flags);

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch if (del)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_index_set_deleted(trans);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch else

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody mail_index_set_undeleted(trans);

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody if (mail_index_transaction_commit(&trans) < 0) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_storage_set_index_error(box);

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody return -1;

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* sync the mailbox. this finishes the index deletion and it can

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return mailbox_sync(box, MAILBOX_SYNC_FLAG_FULL_READ);

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody}

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschstatic bool mailbox_try_undelete(struct mailbox *box)

f883bf3eff62f5d27df5ee9ee664edc38a77937fStephan Bosch{

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody time_t mtime;

f883bf3eff62f5d27df5ee9ee664edc38a77937fStephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (mail_index_get_modification_time(box->index, &mtime) < 0)

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody return FALSE;

f883bf3eff62f5d27df5ee9ee664edc38a77937fStephan Bosch if (mtime + MAILBOX_DELETE_RETRY_SECS > time(NULL))

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return FALSE;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch if (mailbox_mark_index_deleted(box, FALSE) < 0)

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch return FALSE;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->mailbox_deleted = FALSE;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch return TRUE;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschint mailbox_delete(struct mailbox *box)

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody{

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody enum mail_error error;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch int ret;

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody if (*box->name == '\0') {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_storage_set_error(box->storage, MAIL_ERROR_PARAMS,

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody "Storage root can't be deleted");

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody return -1;

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody }

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody if (box->inbox) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_storage_set_error(box->storage, MAIL_ERROR_NOTPOSSIBLE,

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody "INBOX can't be deleted.");

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody return -1;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody box->deleting = TRUE;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (mailbox_open(box) < 0) {

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody (void)mail_storage_get_last_error(box->storage, &error);

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody if (error != MAIL_ERROR_NOTFOUND)

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody return -1;

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody if (!box->mailbox_deleted) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* \noselect mailbox */

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody } else {

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody /* if deletion happened a long time ago, it means it

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody if (!mailbox_try_undelete(box))

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody return -1;

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* retry */

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (mailbox_open(box) < 0)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return -1;

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody }

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody if (box->opened) {

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody if (mailbox_mark_index_deleted(box, TRUE) < 0)

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody return -1;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch ret = box->v.delete(box);

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody box->deleting = FALSE;

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody mailbox_close(box);

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody return ret;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmodystatic bool

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmodymail_storages_rename_compatible(struct mail_storage *storage1,

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody struct mail_storage *storage2)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (storage1 == storage2)

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody return TRUE;

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody if (strcmp(storage1->name, storage2->name) != 0)

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody return FALSE;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if ((storage1->class_flags & MAIL_STORAGE_CLASS_FLAG_UNIQUE_ROOT) != 0)

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody return FALSE;

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody return TRUE;

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody}

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschstatic bool nullequals(const void *p1, const void *p2)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody return (p1 == NULL && p2 == NULL) || (p1 != NULL && p2 != NULL);

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody}

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschstatic bool

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmodymailbox_lists_rename_compatible(struct mailbox_list *list1,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mailbox_list *list2)

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return nullequals(list1->set.alt_dir, list2->set.alt_dir) &&

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch nullequals(list1->set.index_dir, list2->set.index_dir) &&

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody nullequals(list1->set.control_dir, list2->set.control_dir);

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody}

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschint mailbox_rename(struct mailbox *src, struct mailbox *dest,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch bool rename_children)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody if (!mailbox_list_is_valid_existing_name(src->list, src->name) ||

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody *src->name == '\0' ||

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody !mailbox_list_is_valid_create_name(dest->list, dest->name)) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_storage_set_error(src->storage, MAIL_ERROR_PARAMS,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch "Invalid mailbox name");

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return -1;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (!mail_storages_rename_compatible(src->storage, dest->storage) ||

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch !mailbox_lists_rename_compatible(src->list, dest->list)) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_storage_set_error(src->storage, MAIL_ERROR_NOTPOSSIBLE,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch "Can't rename mailboxes across specified storages.");

e87b25495e78a6f61f236b188bfd68070eff3295Phil Carmody return -1;

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (src->list->ns->type != NAMESPACE_PRIVATE ||

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch dest->list->ns->type != NAMESPACE_PRIVATE) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_storage_set_error(src->storage, MAIL_ERROR_NOTPOSSIBLE,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch "Renaming not supported across non-private namespaces.");

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return -1;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return src->v.rename(src, dest, rename_children);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschstruct mail_storage *mailbox_get_storage(const struct mailbox *box)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return box->storage;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

e9c433c5b8ef9a1b4246ebe10beb90fa01e05cafPhil Carmodystruct mail_namespace *

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschmailbox_get_namespace(const struct mailbox *box)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return box->list->ns;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschconst struct mail_storage_settings *mailbox_get_settings(struct mailbox *box)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return box->storage->set;

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschconst char *mailbox_get_name(const struct mailbox *box)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return box->name;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschconst char *mailbox_get_vname(const struct mailbox *box)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return box->vname;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschbool mailbox_is_readonly(struct mailbox *box)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return box->v.is_readonly(box);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschbool mailbox_allow_new_keywords(struct mailbox *box)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return box->v.allow_new_keywords(box);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschbool mailbox_backends_equal(const struct mailbox *box1,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch const struct mailbox *box2)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mail_namespace *ns1 = box1->list->ns, *ns2 = box2->list->ns;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (strcmp(box1->name, box2->name) != 0)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return FALSE;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch while (ns1->alias_for != NULL)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch ns1 = ns1->alias_for;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch while (ns2->alias_for != NULL)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch ns2 = ns2->alias_for;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return ns1 == ns2;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

4c8646ca7a1bfe3e5a43f1f3e329f8ff8c24d851Stephan Bosch

4c8646ca7a1bfe3e5a43f1f3e329f8ff8c24d851Stephan Boschvoid mailbox_get_status(struct mailbox *box,

4c8646ca7a1bfe3e5a43f1f3e329f8ff8c24d851Stephan Bosch enum mailbox_status_items items,

4c8646ca7a1bfe3e5a43f1f3e329f8ff8c24d851Stephan Bosch struct mailbox_status *status_r)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->v.get_status(box, items, status_r);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschint mailbox_get_guid(struct mailbox *box, uint8_t guid[MAIL_GUID_128_SIZE])

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (box->v.get_guid == NULL) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mail_storage_set_error(box->storage, MAIL_ERROR_NOTPOSSIBLE,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch "Storage doesn't support mailbox GUIDs");

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (!box->opened) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (mailbox_open(box) < 0)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return -1;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (box->v.get_guid(box, guid) < 0)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return -1;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch i_assert(!mail_guid_128_is_empty(guid));

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return 0;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschstruct mailbox_sync_context *

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschmailbox_sync_init(struct mailbox *box, enum mailbox_sync_flags flags)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mailbox_sync_context *ctx;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (box->transaction_count != 0) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch i_panic("Trying to sync mailbox %s with open transactions",

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->name);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch T_BEGIN {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch ctx = box->v.sync_init(box, flags);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch } T_END;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return ctx;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschbool mailbox_sync_next(struct mailbox_sync_context *ctx,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mailbox_sync_rec *sync_rec_r)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return ctx->box->v.sync_next(ctx, sync_rec_r);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschint mailbox_sync_deinit(struct mailbox_sync_context **_ctx,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mailbox_sync_status *status_r)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mailbox_sync_context *ctx = *_ctx;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mailbox *box = ctx->box;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch const char *errormsg;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch enum mail_error error;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch int ret;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch *_ctx = NULL;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch memset(status_r, 0, sizeof(*status_r));

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch ret = box->v.sync_deinit(ctx, status_r);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (ret < 0 && box->inbox &&

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch !box->storage->user->inbox_open_error_logged) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch errormsg = mail_storage_get_last_error(box->storage, &error);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (error == MAIL_ERROR_NOTPOSSIBLE) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->storage->user->inbox_open_error_logged = TRUE;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch i_error("Syncing INBOX failed: %s", errormsg);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return ret;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschint mailbox_sync(struct mailbox *box, enum mailbox_sync_flags flags)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mailbox_sync_context *ctx;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mailbox_sync_status status;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (array_count(&box->search_results) == 0) {

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch /* we don't care about mailbox's current state, so we might

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch flags |= MAILBOX_SYNC_FLAG_FIX_INCONSISTENT;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch ctx = mailbox_sync_init(box, flags);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return mailbox_sync_deinit(&ctx, &status);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch#undef mailbox_notify_changes

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschvoid mailbox_notify_changes(struct mailbox *box, unsigned int min_interval,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mailbox_notify_callback_t *callback, void *context)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->notify_min_interval = min_interval;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->notify_callback = callback;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->notify_context = context;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->v.notify_changes(box);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschvoid mailbox_notify_changes_stop(struct mailbox *box)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch mailbox_notify_changes(box, 0, NULL, NULL);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschint mailbox_keywords_create(struct mailbox *box, const char *const keywords[],

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mail_keywords **keywords_r)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch const char *empty_keyword_list = NULL;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (keywords == NULL)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch keywords = &empty_keyword_list;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return box->v.keywords_create(box, keywords, keywords_r, FALSE);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschstruct mail_keywords *

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschmailbox_keywords_create_valid(struct mailbox *box,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch const char *const keywords[])

e9c433c5b8ef9a1b4246ebe10beb90fa01e05cafPhil Carmody{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch const char *empty_keyword_list = NULL;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mail_keywords *kw;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (keywords == NULL)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch keywords = &empty_keyword_list;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch if (box->v.keywords_create(box, keywords, &kw, TRUE) < 0)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch i_unreached();

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return kw;

e9c433c5b8ef9a1b4246ebe10beb90fa01e05cafPhil Carmody}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschstruct mail_keywords *

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschmailbox_keywords_create_from_indexes(struct mailbox *box,

66134fbce11778241ca9f8458ee2a0488a05bde0Stephan Bosch const ARRAY_TYPE(keyword_indexes) *idx)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return box->v.keywords_create_from_indexes(box, idx);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

639bb36b12b9f9bb54c8bb1be50eac623622f8a0Timo Sirainenvoid mailbox_keywords_ref(struct mailbox *box, struct mail_keywords *keywords)

639bb36b12b9f9bb54c8bb1be50eac623622f8a0Timo Sirainen{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch box->v.keywords_ref(keywords);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschvoid mailbox_keywords_unref(struct mailbox *box,

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mail_keywords **_keywords)

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch struct mail_keywords *keywords = *_keywords;

e9c433c5b8ef9a1b4246ebe10beb90fa01e05cafPhil Carmody

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch *_keywords = NULL;

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch box->v.keywords_unref(keywords);

17c29e3e2246972c3d988e05d91b9286398a624fStephan Bosch}

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Boschbool mailbox_keyword_is_valid(struct mailbox *box, const char *keyword,

4c8646ca7a1bfe3e5a43f1f3e329f8ff8c24d851Stephan Bosch const char **error_r)

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch{

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch return box->v.keyword_is_valid(box, keyword, error_r);

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch}

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Boschvoid mailbox_get_seq_range(struct mailbox *box, uint32_t uid1, uint32_t uid2,

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch uint32_t *seq1_r, uint32_t *seq2_r)

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch{

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch box->v.get_seq_range(box, uid1, uid2, seq1_r, seq2_r);

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch}

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Boschvoid mailbox_get_uid_range(struct mailbox *box,

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch const ARRAY_TYPE(seq_range) *seqs,

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch ARRAY_TYPE(seq_range) *uids)

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch{

62aa68310d6f42467ca26880f678173bf1d26a83Stephan Bosch box->v.get_uid_range(box, seqs, uids);

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch}

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Boschbool mailbox_get_expunges(struct mailbox *box, uint64_t prev_modseq,

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch const ARRAY_TYPE(seq_range) *uids_filter,

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch ARRAY_TYPE(mailbox_expunge_rec) *expunges)

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch{

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch return box->v.get_expunges(box, prev_modseq,

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch uids_filter, expunges);

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch}

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Boschbool mailbox_get_virtual_uid(struct mailbox *box, const char *backend_mailbox,

e9c433c5b8ef9a1b4246ebe10beb90fa01e05cafPhil Carmody uint32_t backend_uidvalidity,

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch uint32_t backend_uid, uint32_t *uid_r)

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch{

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch if (box->v.get_virtual_uid == NULL)

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch return FALSE;

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch return box->v.get_virtual_uid(box, backend_mailbox, backend_uidvalidity,

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch backend_uid, uid_r);

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch}

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Boschvoid mailbox_get_virtual_backend_boxes(struct mailbox *box,

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch ARRAY_TYPE(mailboxes) *mailboxes,

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch bool only_with_msgs)

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch{

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch if (box->v.get_virtual_backend_boxes == NULL)

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch array_append(mailboxes, &box, 1);

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch else

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch box->v.get_virtual_backend_boxes(box, mailboxes, only_with_msgs);

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch}

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Boschvoid mailbox_get_virtual_box_patterns(struct mailbox *box,

289ce1246b1c7511f8ceec02344316064ffbe546Phil Carmody ARRAY_TYPE(mailbox_virtual_patterns) *includes,

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch ARRAY_TYPE(mailbox_virtual_patterns) *excludes)

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch{

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch if (box->v.get_virtual_box_patterns == NULL) {

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch struct mailbox_virtual_pattern pat;

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch memset(&pat, 0, sizeof(pat));

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch pat.ns = box->list->ns;

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch pat.pattern = box->name;

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch array_append(includes, &pat, 1);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch } else {

baf3e87e186453fda13bd21f7cbcb2efc8492e8bTimo Sirainen box->v.get_virtual_box_patterns(box, includes, excludes);

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch }

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch}

4d955db590c3d76a631dfc5d37bcdf578a43e55aStephan Bosch

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschstruct mailbox_header_lookup_ctx *

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Boschmailbox_header_lookup_init(struct mailbox *box, const char *const headers[])

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch{

6ae6496c225238a2c55a8cd96744ad976c44a726Stephan Bosch return box->v.header_lookup_init(box, headers);

}

void mailbox_header_lookup_ref(struct mailbox_header_lookup_ctx *ctx)

{

i_assert(ctx->refcount > 0);

ctx->refcount++;

}

void mailbox_header_lookup_unref(struct mailbox_header_lookup_ctx **_ctx)

{

struct mailbox_header_lookup_ctx *ctx = *_ctx;

*_ctx = NULL;

i_assert(ctx->refcount > 0);

if (--ctx->refcount > 0)

return;

ctx->box->v.header_lookup_deinit(ctx);

}

struct mail_search_context *

mailbox_search_init(struct mailbox_transaction_context *t,

struct mail_search_args *args,

const enum mail_sort_type *sort_program)

{

mail_search_args_ref(args);

if (!args->simplified)

mail_search_args_simplify(args);

return t->box->v.search_init(t, args, sort_program);

}

int mailbox_search_deinit(struct mail_search_context **_ctx)

{

struct mail_search_context *ctx = *_ctx;

struct mail_search_args *args = ctx->args;

int ret;

*_ctx = NULL;

mailbox_search_results_initial_done(ctx);

ret = ctx->transaction->box->v.search_deinit(ctx);

mail_search_args_unref(&args);

return ret;

}

bool mailbox_search_next(struct mail_search_context *ctx, struct mail *mail)

{

bool tryagain;

while (!mailbox_search_next_nonblock(ctx, mail, &tryagain)) {

if (!tryagain)

return FALSE;

}

return TRUE;

}

bool mailbox_search_next_nonblock(struct mail_search_context *ctx,

struct mail *mail, bool *tryagain_r)

{

struct mailbox *box = ctx->transaction->box;

if (!box->v.search_next_nonblock(ctx, mail, tryagain_r))

return FALSE;

else {

mailbox_search_results_add(ctx, mail->uid);

return TRUE;

}

}

bool mailbox_search_seen_lost_data(struct mail_search_context *ctx)

{

return ctx->seen_lost_data;

}

int mailbox_search_result_build(struct mailbox_transaction_context *t,

struct mail_search_args *args,

enum mailbox_search_result_flags flags,

struct mail_search_result **result_r)

{

struct mail_search_context *ctx;

struct mail *mail;

int ret;

ctx = mailbox_search_init(t, args, NULL);

*result_r = mailbox_search_result_save(ctx, flags);

mail = mail_alloc(t, 0, NULL);

while (mailbox_search_next(ctx, mail)) ;

mail_free(&mail);

ret = mailbox_search_deinit(&ctx);

if (ret < 0)

mailbox_search_result_free(result_r);

return ret;

}

struct mailbox_transaction_context *

mailbox_transaction_begin(struct mailbox *box,

enum mailbox_transaction_flags flags)

{

struct mailbox_transaction_context *trans;

box->transaction_count++;

trans = box->v.transaction_begin(box, flags);

trans->flags = flags;

return trans;

}

int mailbox_transaction_commit(struct mailbox_transaction_context **t)

{

struct mail_transaction_commit_changes changes;

int ret;

/* Store changes temporarily so that plugins overriding

ret = mailbox_transaction_commit_get_changes(t, &changes);

pool_unref(&changes.pool);

return ret;

}

int mailbox_transaction_commit_get_changes(

struct mailbox_transaction_context **_t,

struct mail_transaction_commit_changes *changes_r)

{

struct mailbox_transaction_context *t = *_t;

int ret;

t->box->transaction_count--;

*_t = NULL;

T_BEGIN {

ret = t->box->v.transaction_commit(t, changes_r);

} T_END;

return ret;

}

void mailbox_transaction_rollback(struct mailbox_transaction_context **_t)

{

struct mailbox_transaction_context *t = *_t;

t->box->transaction_count--;

*_t = NULL;

t->box->v.transaction_rollback(t);

}

unsigned int mailbox_transaction_get_count(const struct mailbox *box)

{

return box->transaction_count;

}

void mailbox_transaction_set_max_modseq(struct mailbox_transaction_context *t,

uint64_t max_modseq,

ARRAY_TYPE(seq_range) *seqs)

{

t->box->v.transaction_set_max_modseq(t, max_modseq, seqs);

}

struct mailbox *

mailbox_transaction_get_mailbox(const struct mailbox_transaction_context *t)

{

return t->box;

}

struct mail_save_context *

mailbox_save_alloc(struct mailbox_transaction_context *t)

{

struct mail_save_context *ctx;

ctx = t->box->v.save_alloc(t);

ctx->received_date = (time_t)-1;

ctx->save_date = (time_t)-1;

return ctx;

}

void mailbox_save_set_flags(struct mail_save_context *ctx,

enum mail_flags flags,

struct mail_keywords *keywords)

{

ctx->flags = flags;

ctx->keywords = keywords;

if (keywords != NULL)

mailbox_keywords_ref(ctx->transaction->box, keywords);

}

void mailbox_save_copy_flags(struct mail_save_context *ctx, struct mail *mail)

{

const char *const *keywords_list;

keywords_list = mail_get_keywords(mail);

ctx->keywords = str_array_length(keywords_list) == 0 ? NULL :

mailbox_keywords_create_valid(ctx->transaction->box,

keywords_list);

ctx->flags = mail_get_flags(mail);

}

void mailbox_save_set_min_modseq(struct mail_save_context *ctx,

uint64_t min_modseq)

{

ctx->min_modseq = min_modseq;

}

void mailbox_save_set_received_date(struct mail_save_context *ctx,

time_t received_date, int timezone_offset)

{

ctx->received_date = received_date;

ctx->received_tz_offset = timezone_offset;

}

void mailbox_save_set_save_date(struct mail_save_context *ctx,

time_t save_date)

{

ctx->save_date = save_date;

}

void mailbox_save_set_from_envelope(struct mail_save_context *ctx,

const char *envelope)

{

i_free(ctx->from_envelope);

ctx->from_envelope = i_strdup(envelope);

}

void mailbox_save_set_uid(struct mail_save_context *ctx, uint32_t uid)

{

ctx->uid = uid;

}

void mailbox_save_set_guid(struct mail_save_context *ctx, const char *guid)

{

i_assert(guid == NULL || *guid != '\0');

i_free(ctx->guid);

ctx->guid = i_strdup(guid);

}

void mailbox_save_set_pop3_uidl(struct mail_save_context *ctx, const char *uidl)

{

i_free(ctx->pop3_uidl);

ctx->pop3_uidl = i_strdup(uidl);

}

void mailbox_save_set_dest_mail(struct mail_save_context *ctx,

struct mail *mail)

{

ctx->dest_mail = mail;

}

int mailbox_save_begin(struct mail_save_context **ctx, struct istream *input)

{

struct mailbox *box = (*ctx)->transaction->box;

int ret;

if (mail_index_is_deleted(box->index)) {

mailbox_set_deleted(box);

return -1;

}

if (box->v.save_begin == NULL) {

mail_storage_set_error(box->storage, MAIL_ERROR_NOTPOSSIBLE,

"Saving messages not supported");

ret = -1;

} else {