virtual-mail.c revision 6de6ec228a41275ddda972d4a554699ea75cd06d
02c335c23bf5fa225a467c19f2c063fb0dc7b8c3Timo Sirainen/* Copyright (c) 2008-2016 Dovecot authors, see the included COPYING file */
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen struct mailbox_header_lookup_ctx *wanted_headers;
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen /* currently active mail */
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen /* all allocated mails */
a34bd633ab201f6a5ad1c00174fb8b0359031d00Timo Sirainen /* mail is lost if backend_mail doesn't point to correct mail */
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainenvirtual_mail_alloc(struct mailbox_transaction_context *t,
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen struct mailbox_header_lookup_ctx *wanted_headers)
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen struct virtual_mailbox *mbox = (struct virtual_mailbox *)t->box;
5f44975ec6c5755dd74bcd4c47a123a7242ecab3Timo Sirainen pool_alloconly_create("virtual index_mail", 512);
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen array_create(&vmail->imail.mail.module_contexts, pool,
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen sizeof(void *), 5);
d22301419109ed4a38351715e6760011421dadecTimo Sirainen vmail->imail.ibox = INDEX_STORAGE_CONTEXT(t->box);
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen i_array_init(&vmail->backend_mails, array_count(&mbox->backend_boxes));
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainenstatic void virtual_mail_free(struct mail *mail)
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen unsigned int i, count;
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen mails = array_get_modifiable(&vmail->backend_mails, &count);
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen for (i = 0; i < count; i++)
4542c94adb8910e0174c784754e737cec16af59cTimo Sirainen mailbox_header_lookup_unref(&vmail->wanted_headers);
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainenstatic struct mail *
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainenbackend_mail_find(struct virtual_mail *vmail, struct mailbox *box)
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen unsigned int i, count;
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen mails = array_get(&vmail->backend_mails, &count);
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen for (i = 0; i < count; i++) {
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainenstatic int backend_mail_get(struct virtual_mail *vmail,
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen struct virtual_mailbox *mbox = (struct virtual_mailbox *)mail->box;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen bbox = virtual_backend_box_lookup(mbox, vmail->cur_vrec.mailbox_id);
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen vmail->cur_backend_mail = backend_mail_find(vmail, bbox->box);
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen (void)virtual_mail_set_backend_mail(mail, bbox);
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen vmail->cur_lost = !mail_set_uid(vmail->cur_backend_mail,
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen mail->expunged = vmail->cur_lost || vmail->cur_backend_mail->expunged;
c115c742f730e312d6b6ab5064595cd0d8b4e26eTimo Sirainenvirtual_mail_set_backend_mail(struct mail *mail,
c115c742f730e312d6b6ab5064595cd0d8b4e26eTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
c115c742f730e312d6b6ab5064595cd0d8b4e26eTimo Sirainen struct mailbox_transaction_context *backend_trans;
c115c742f730e312d6b6ab5064595cd0d8b4e26eTimo Sirainen struct mailbox_header_lookup_ctx *backend_headers;
c115c742f730e312d6b6ab5064595cd0d8b4e26eTimo Sirainen backend_trans = virtual_transaction_get(mail->transaction, bbox->box);
c115c742f730e312d6b6ab5064595cd0d8b4e26eTimo Sirainen backend_headers = vmail->wanted_headers == NULL ? NULL :
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen mail_alloc(backend_trans, vmail->wanted_fields, backend_headers);
c115c742f730e312d6b6ab5064595cd0d8b4e26eTimo Sirainen mailbox_header_lookup_unref(&backend_headers);
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen backend_pmail = (struct mail_private *)vmail->cur_backend_mail;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen array_append(&vmail->backend_mails, &vmail->cur_backend_mail, 1);
7631f16156aca373004953fe6b01a7f343fb47e0Timo Sirainenstatic void virtual_mail_set_seq(struct mail *mail, uint32_t seq, bool saving)
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen struct virtual_mailbox *mbox = (struct virtual_mailbox *)mail->box;
a249dd267f05d349f1b4aa27b40a56083c8ba392Timo Sirainen mail_index_lookup_ext(mail->transaction->view, seq,
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen memcpy(&vmail->cur_vrec, data, sizeof(vmail->cur_vrec));
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen memset(&vmail->imail.data, 0, sizeof(vmail->imail.data));
a249dd267f05d349f1b4aa27b40a56083c8ba392Timo Sirainen mail_index_lookup_uid(mail->transaction->view, seq, &mail->uid);
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainenstatic bool virtual_mail_set_uid(struct mail *mail, uint32_t uid)
a249dd267f05d349f1b4aa27b40a56083c8ba392Timo Sirainen if (!mail_index_lookup_seq(mail->transaction->view, uid, &seq))
fe5cca45e94608d1c471990216941bf893bc8adaTimo Sirainenstatic void virtual_mail_set_uid_cache_updates(struct mail *mail, bool set)
fe5cca45e94608d1c471990216941bf893bc8adaTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (backend_mail_get(vmail, &backend_mail) < 0)
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen p->v.set_uid_cache_updates(backend_mail, set);
e15b305e90c9834734ccf35ed78f0ad29d570ee9Timo Sirainenstatic bool virtual_mail_prefetch(struct mail *mail)
e15b305e90c9834734ccf35ed78f0ad29d570ee9Timo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (backend_mail_get(vmail, &backend_mail) < 0)
421d30619384e72a27e2a5d13ff6525aff4d17feTimo Sirainenstatic void virtual_mail_precache(struct mail *mail)
421d30619384e72a27e2a5d13ff6525aff4d17feTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (backend_mail_get(vmail, &backend_mail) < 0)
ecd69c4e8371853667e01b0c16d436ef7f7393e2Timo Sirainenvirtual_mail_add_temp_wanted_fields(struct mail *mail,
ecd69c4e8371853667e01b0c16d436ef7f7393e2Timo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (backend_mail_get(vmail, &backend_mail) < 0)
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen p->v.add_temp_wanted_fields(backend_mail, fields, headers);
c0225f7f6b43d34dc58c17d3304f0fd60ab89894Timo Sirainenvirtual_mail_get_parts(struct mail *mail, struct message_part **parts_r)
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (backend_mail_get(vmail, &backend_mail) < 0)
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (mail_get_parts(backend_mail, parts_r) < 0) {
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen virtual_box_copy_error(mail->box, backend_mail->box);
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainenvirtual_mail_get_date(struct mail *mail, time_t *date_r, int *timezone_r)
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (backend_mail_get(vmail, &backend_mail) < 0)
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (mail_get_date(backend_mail, date_r, timezone_r) < 0) {
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen virtual_box_copy_error(mail->box, backend_mail->box);
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainenstatic int virtual_mail_get_received_date(struct mail *mail, time_t *date_r)
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (backend_mail_get(vmail, &backend_mail) < 0)
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (mail_get_received_date(backend_mail, date_r) < 0) {
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen virtual_box_copy_error(mail->box, backend_mail->box);
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainenstatic int virtual_mail_get_save_date(struct mail *mail, time_t *date_r)
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (backend_mail_get(vmail, &backend_mail) < 0)
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (mail_get_save_date(backend_mail, date_r) < 0) {
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen virtual_box_copy_error(mail->box, backend_mail->box);
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainenstatic int virtual_mail_get_virtual_mail_size(struct mail *mail, uoff_t *size_r)
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (backend_mail_get(vmail, &backend_mail) < 0)
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (mail_get_virtual_size(backend_mail, size_r) < 0) {
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen virtual_box_copy_error(mail->box, backend_mail->box);
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainenstatic int virtual_mail_get_physical_size(struct mail *mail, uoff_t *size_r)
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (backend_mail_get(vmail, &backend_mail) < 0)
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (mail_get_physical_size(backend_mail, size_r) < 0) {
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen virtual_box_copy_error(mail->box, backend_mail->box);
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainenvirtual_mail_get_first_header(struct mail *mail, const char *field,
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (backend_mail_get(vmail, &backend_mail) < 0)
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen ret = p->v.get_first_header(backend_mail, field,
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen virtual_box_copy_error(mail->box, backend_mail->box);
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainenvirtual_mail_get_headers(struct mail *mail, const char *field,
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen bool decode_to_utf8, const char *const **value_r)
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (backend_mail_get(vmail, &backend_mail) < 0)
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (p->v.get_headers(backend_mail, field, decode_to_utf8, value_r) < 0) {
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen virtual_box_copy_error(mail->box, backend_mail->box);
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainenvirtual_mail_get_header_stream(struct mail *mail,
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
c8d1ccf9dec39e9e145d55b472eee43d95764189Timo Sirainen struct mailbox_header_lookup_ctx *backend_headers;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (backend_mail_get(vmail, &backend_mail) < 0)
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen backend_headers = mailbox_header_lookup_init(backend_mail->box,
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen ret = mail_get_header_stream(backend_mail, backend_headers, stream_r);
c8d1ccf9dec39e9e145d55b472eee43d95764189Timo Sirainen mailbox_header_lookup_unref(&backend_headers);
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen virtual_box_copy_error(mail->box, backend_mail->box);
6df0ab0c1ab91f06b6418cb30eff44405a1b8f02Timo Sirainenvirtual_mail_get_stream(struct mail *mail, bool get_body,
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (backend_mail_get(vmail, &backend_mail) < 0)
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen ret = mail_get_stream(backend_mail, hdr_size, body_size,
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen ret = mail_get_hdr_stream(backend_mail, hdr_size, stream_r);
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen virtual_box_copy_error(mail->box, backend_mail->box);
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainenvirtual_mail_get_special(struct mail *mail, enum mail_fetch_field field,
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen const char **value_r)
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (backend_mail_get(vmail, &backend_mail) < 0)
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (mail_get_special(backend_mail, field, value_r) < 0) {
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen virtual_box_copy_error(mail->box, backend_mail->box);
ceac44e7560fcbf6fc2f932c7b624a5055dc3bc9Timo Sirainenstatic struct mail *virtual_mail_get_real_mail(struct mail *mail)
9af6cc9ebc9986c1275ebdfa29c39e152af1557eTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (backend_mail_get(vmail, &backend_mail) < 0)
ceac44e7560fcbf6fc2f932c7b624a5055dc3bc9Timo Sirainen if (mail_get_backend_mail(backend_mail, &real_mail) < 0)
225e82df5dd1e765f4e52b80c954558f00e5a7dfTimo Sirainenstatic void virtual_mail_update_pop3_uidl(struct mail *mail, const char *uidl)
225e82df5dd1e765f4e52b80c954558f00e5a7dfTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (backend_mail_get(vmail, &backend_mail) < 0)
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainenstatic void virtual_mail_expunge(struct mail *mail)
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (backend_mail_get(vmail, &backend_mail) < 0)
6de6ec228a41275ddda972d4a554699ea75cd06dTimo Sirainenvirtual_mail_set_cache_corrupted_reason(struct mail *mail,
24e5e4526d8f5cbc056ab97fd0d154d0936d7a5eTimo Sirainen struct virtual_mail *vmail = (struct virtual_mail *)mail;
18a41cbd38f83429b790414c1159c097af4a59b8Timo Sirainen if (backend_mail_get(vmail, &backend_mail) < 0)
6de6ec228a41275ddda972d4a554699ea75cd06dTimo Sirainen mail_set_cache_corrupted_reason(backend_mail, field, reason);
6de6ec228a41275ddda972d4a554699ea75cd06dTimo Sirainenvirtual_mail_set_cache_corrupted(struct mail *mail, enum mail_fetch_field field)