mbox-sync-update.c revision 1e76a5b92f9d82d557f81f080f3dfad1c9d8f200
c25356d5978632df6203437e1953bcb29e0c736fTimo Sirainen/* Copyright (C) 2004 Timo Sirainen */
c25356d5978632df6203437e1953bcb29e0c736fTimo Sirainen
5ce2084ada06ade9f44fc2914c34658e9a842dc1Timo Sirainen#include "lib.h"
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen#include "array.h"
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen#include "buffer.h"
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen#include "str.h"
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen#include "message-parser.h"
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen#include "index-storage.h"
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen#include "mbox-storage.h"
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen#include "mbox-sync-private.h"
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen/* Line length when to wrap X-IMAP, X-IMAPbase and X-Keywords headers to next
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen line. Keep this pretty long, as after we wrap we lose compatibility with
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen UW-IMAP */
5ce2084ada06ade9f44fc2914c34658e9a842dc1Timo Sirainen#define KEYWORD_WRAP_LINE_LENGTH 1024
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainenstatic void status_flags_append(struct mbox_sync_mail_context *ctx,
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen const struct mbox_flag_type *flags_list)
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen{
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen int i;
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen for (i = 0; flags_list[i].chr != 0; i++) {
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen if ((ctx->mail.flags & flags_list[i].flag) != 0)
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen str_append_c(ctx->header, flags_list[i].chr);
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen }
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen}
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen
5ce2084ada06ade9f44fc2914c34658e9a842dc1Timo Sirainenvoid mbox_sync_move_buffer(struct mbox_sync_mail_context *ctx,
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen size_t pos, size_t need, size_t have)
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen{
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen ssize_t diff = (ssize_t)need - (ssize_t)have;
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen int i;
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen i_assert(have < SSIZE_T_MAX);
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen
79fcd3f95a6266cc62ceaa753e56dd4456ab7c4bTimo Sirainen if (diff == 0) {
3ddbbe03fe74b3ee7b1dff4e08ec706d7880d052Timo Sirainen if (ctx->header_last_change < pos + have ||
3ddbbe03fe74b3ee7b1dff4e08ec706d7880d052Timo Sirainen ctx->header_last_change == (size_t)-1)
3ddbbe03fe74b3ee7b1dff4e08ec706d7880d052Timo Sirainen ctx->header_last_change = pos + have;
79fcd3f95a6266cc62ceaa753e56dd4456ab7c4bTimo Sirainen } else {
79fcd3f95a6266cc62ceaa753e56dd4456ab7c4bTimo Sirainen /* FIXME: if (diff < ctx->space && pos < ctx->offset) then
5ce2084ada06ade9f44fc2914c34658e9a842dc1Timo Sirainen move the data only up to space offset and give/take the
5ce2084ada06ade9f44fc2914c34658e9a842dc1Timo Sirainen space from there. update header_last_change accordingly.
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen (except pos and offset can't be compared directly) */
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen ctx->header_last_change = (size_t)-1;
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen for (i = 0; i < MBOX_HDR_COUNT; i++) {
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen if (ctx->hdr_pos[i] > pos &&
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen ctx->hdr_pos[i] != (size_t)-1)
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen ctx->hdr_pos[i] += diff;
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen }
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen if (ctx->mail.space > 0) {
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen i_assert(ctx->mail.offset + ctx->mail.space <=
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen ctx->hdr_offset + pos ||
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen ctx->mail.offset > ctx->hdr_offset + pos + have);
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen if (ctx->mail.offset > ctx->hdr_offset + pos) {
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen /* free space offset moves */
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen ctx->mail.offset += diff;
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen }
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen }
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen if (diff < 0)
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen str_delete(ctx->header, pos, -diff);
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen else {
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen ctx->header_last_change = (size_t)-1;
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen buffer_copy(ctx->header, pos + diff,
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen ctx->header, pos, (size_t)-1);
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen }
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen }
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen}
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen
5ce2084ada06ade9f44fc2914c34658e9a842dc1Timo Sirainenstatic void status_flags_replace(struct mbox_sync_mail_context *ctx, size_t pos,
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen const struct mbox_flag_type *flags_list)
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen{
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen unsigned char *data;
5ce2084ada06ade9f44fc2914c34658e9a842dc1Timo Sirainen size_t size;
a342a31752dd71ac444259ca57ad33ea6b79a572Timo Sirainen int i, need, have;
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen
8d80659e504ffb34bb0c6a633184fece35751b18Timo Sirainen ctx->mail.flags ^= MBOX_NONRECENT_KLUDGE;
88ea893b45d3ed8d68000921db9156c03cbe1b00Timo Sirainen
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen if (ctx->header_first_change > pos)
8039af9679af6fb56116b353fe44f7dd4c08f031Timo Sirainen ctx->header_first_change = pos;
5ce2084ada06ade9f44fc2914c34658e9a842dc1Timo Sirainen
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen /* how many bytes do we need? */
d10a370b2614712d9cb6a1dd8625f62a071b6377Timo Sirainen for (i = 0, need = 0; flags_list[i].chr != 0; i++) {
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen if ((ctx->mail.flags & flags_list[i].flag) != 0)
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen need++;
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen }
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen
5ce2084ada06ade9f44fc2914c34658e9a842dc1Timo Sirainen /* how many bytes do we have now? */
5ce2084ada06ade9f44fc2914c34658e9a842dc1Timo Sirainen data = buffer_get_modifiable_data(ctx->header, &size);
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen for (have = 0; pos < size; pos++) {
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen if (data[pos] == '\n' || data[pos] == '\r')
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen break;
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen /* see if this is unknown flag for us */
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen for (i = 0; flags_list[i].chr != 0; i++) {
a10ed8c47534b4c6b6bf2711ccfe577e720a47b4Timo Sirainen if (flags_list[i].chr == data[pos])
a10ed8c47534b4c6b6bf2711ccfe577e720a47b4Timo Sirainen break;
2cfe9983ce7a6280636ee12beccc2e865111967bTimo Sirainen }
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen
2cfe9983ce7a6280636ee12beccc2e865111967bTimo Sirainen if (flags_list[i].chr != 0)
2cfe9983ce7a6280636ee12beccc2e865111967bTimo Sirainen have++;
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen else {
2cfe9983ce7a6280636ee12beccc2e865111967bTimo Sirainen /* save this one */
2cfe9983ce7a6280636ee12beccc2e865111967bTimo Sirainen data[pos-have] = data[pos];
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen }
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen }
2cfe9983ce7a6280636ee12beccc2e865111967bTimo Sirainen pos -= have;
2cfe9983ce7a6280636ee12beccc2e865111967bTimo Sirainen mbox_sync_move_buffer(ctx, pos, need, have);
2767104d81e97a109f0aa9758792bfa1da325a97Timo Sirainen
51cbc45fc1ac5dde29bc2adbb175945df1b4f7d4Timo Sirainen /* @UNSAFE */
51cbc45fc1ac5dde29bc2adbb175945df1b4f7d4Timo Sirainen data = buffer_get_space_unsafe(ctx->header, pos, need);
51cbc45fc1ac5dde29bc2adbb175945df1b4f7d4Timo Sirainen for (i = 0, need = 0; flags_list[i].chr != 0; i++) {
51cbc45fc1ac5dde29bc2adbb175945df1b4f7d4Timo Sirainen if ((ctx->mail.flags & flags_list[i].flag) != 0)
51cbc45fc1ac5dde29bc2adbb175945df1b4f7d4Timo Sirainen *data++ = flags_list[i].chr;
923eb3dde28e4d8841c14fd6b4a69635b7070c3eTimo Sirainen }
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen ctx->mail.flags ^= MBOX_NONRECENT_KLUDGE;
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen}
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainenstatic void
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainenkeywords_append(struct mbox_sync_context *sync_ctx, string_t *dest,
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen const ARRAY_TYPE(keyword_indexes) *keyword_indexes_arr)
51cbc45fc1ac5dde29bc2adbb175945df1b4f7d4Timo Sirainen{
3a985b4f3481d7061ee0c6ace3a5bb0bcbcb67adTimo Sirainen const char *const *keyword_names;
923eb3dde28e4d8841c14fd6b4a69635b7070c3eTimo Sirainen const unsigned int *keyword_indexes;
51cbc45fc1ac5dde29bc2adbb175945df1b4f7d4Timo Sirainen unsigned int i, idx_count, keywords_count;
51cbc45fc1ac5dde29bc2adbb175945df1b4f7d4Timo Sirainen size_t last_break;
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen keyword_names = array_get(sync_ctx->mbox->ibox.keyword_names,
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen &keywords_count);
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen keyword_indexes = array_get(keyword_indexes_arr, &idx_count);
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen for (i = 0, last_break = str_len(dest); i < idx_count; i++) {
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen i_assert(keyword_indexes[i] < keywords_count);
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen /* wrap the line whenever it gets too long */
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen if (str_len(dest) - last_break < KEYWORD_WRAP_LINE_LENGTH) {
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen if (i > 0)
e82e363e7a6917f470412d629db6c5b1f5891a35Timo Sirainen str_append_c(dest, ' ');
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen } else {
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen str_append(dest, "\n\t");
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen last_break = str_len(dest);
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen }
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen str_append(dest, keyword_names[keyword_indexes[i]]);
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen }
5ce2084ada06ade9f44fc2914c34658e9a842dc1Timo Sirainen}
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainen
d6c5ceea8521b92d10e51a59da00c792f6140b1dTimo Sirainenstatic void
306b3f41b05da642d87e7ca7a1496efce9f5902fTimo Sirainenkeywords_append_all(struct mbox_sync_mail_context *ctx, string_t *dest)
6789ed17e7ca4021713507baf0dcf6979bb42e0cTimo Sirainen{
16834f18f903048c772112838c015051642a0e77Timo Sirainen const char *const *names;
16834f18f903048c772112838c015051642a0e77Timo Sirainen const unsigned char *p;
16834f18f903048c772112838c015051642a0e77Timo Sirainen unsigned int i, count;
5ce2084ada06ade9f44fc2914c34658e9a842dc1Timo Sirainen size_t last_break;
p = str_data(dest);
if (str_len(dest) < KEYWORD_WRAP_LINE_LENGTH)
last_break = 0;
else {
/* set last_break to beginning of line */
for (last_break = str_len(dest); last_break > 0; last_break--) {
if (p[last_break-1] == '\n')
break;
}
}
names = array_get(ctx->sync_ctx->mbox->ibox.keyword_names, &count);
for (i = 0; i < count; i++) {
/* wrap the line whenever it gets too long */
if (str_len(dest) - last_break < KEYWORD_WRAP_LINE_LENGTH)
str_append_c(dest, ' ');
else {
str_append(dest, "\n\t");
last_break = str_len(dest);
}
str_append(dest, names[i]);
}
}
static void mbox_sync_add_missing_headers(struct mbox_sync_mail_context *ctx)
{
size_t old_hdr_size, new_hdr_size;
old_hdr_size = ctx->body_offset - ctx->hdr_offset;
new_hdr_size = str_len(ctx->header);
if (new_hdr_size > 0 &&
str_data(ctx->header)[new_hdr_size-1] != '\n') {
/* broken header - doesn't end with \n. fix it. */
str_append_c(ctx->header, '\n');
}
if (ctx->sync_ctx->dest_first_mail &&
ctx->hdr_pos[MBOX_HDR_X_IMAPBASE] == (size_t)-1) {
i_assert(ctx->sync_ctx->base_uid_validity != 0);
str_append(ctx->header, "X-IMAPbase: ");
ctx->hdr_pos[MBOX_HDR_X_IMAPBASE] = str_len(ctx->header);
str_printfa(ctx->header, "%u ",
ctx->sync_ctx->base_uid_validity);
ctx->last_uid_updated_value = ctx->sync_ctx->next_uid-1;
ctx->last_uid_value_start_pos = str_len(ctx->header) -
ctx->hdr_pos[MBOX_HDR_X_IMAPBASE];
ctx->imapbase_updated = TRUE;
str_printfa(ctx->header, "%010u", ctx->last_uid_updated_value);
keywords_append_all(ctx, ctx->header);
str_append_c(ctx->header, '\n');
}
if (ctx->hdr_pos[MBOX_HDR_X_UID] == (size_t)-1 && !ctx->mail.pseudo) {
str_append(ctx->header, "X-UID: ");
ctx->hdr_pos[MBOX_HDR_X_UID] = str_len(ctx->header);
str_printfa(ctx->header, "%u\n", ctx->mail.uid);
}
ctx->mail.flags ^= MBOX_NONRECENT_KLUDGE;
if (ctx->hdr_pos[MBOX_HDR_STATUS] == (size_t)-1 &&
(ctx->mail.flags & STATUS_FLAGS_MASK) != 0) {
str_append(ctx->header, "Status: ");
ctx->hdr_pos[MBOX_HDR_STATUS] = str_len(ctx->header);
status_flags_append(ctx, mbox_status_flags);
str_append_c(ctx->header, '\n');
}
if (ctx->hdr_pos[MBOX_HDR_X_STATUS] == (size_t)-1 &&
(ctx->mail.flags & XSTATUS_FLAGS_MASK) != 0) {
str_append(ctx->header, "X-Status: ");
ctx->hdr_pos[MBOX_HDR_X_STATUS] = str_len(ctx->header);
status_flags_append(ctx, mbox_xstatus_flags);
str_append_c(ctx->header, '\n');
}
ctx->mail.flags ^= MBOX_NONRECENT_KLUDGE;
if (ctx->hdr_pos[MBOX_HDR_X_KEYWORDS] == (size_t)-1 &&
array_is_created(&ctx->mail.keywords) &&
array_count(&ctx->mail.keywords) > 0) {
str_append(ctx->header, "X-Keywords: ");
ctx->hdr_pos[MBOX_HDR_X_KEYWORDS] = str_len(ctx->header);
keywords_append(ctx->sync_ctx, ctx->header,
&ctx->mail.keywords);
str_append_c(ctx->header, '\n');
}
if (ctx->content_length == (uoff_t)-1 &&
ctx->mail.body_size >= MBOX_MIN_CONTENT_LENGTH_SIZE) {
str_printfa(ctx->header, "Content-Length: %"PRIuUOFF_T"\n",
ctx->mail.body_size);
}
if (str_len(ctx->header) != new_hdr_size) {
if (ctx->header_first_change == (size_t)-1)
ctx->header_first_change = new_hdr_size;
ctx->header_last_change = (size_t)-1;
}
if (ctx->have_eoh)
str_append_c(ctx->header, '\n');
}
static void mbox_sync_update_status(struct mbox_sync_mail_context *ctx)
{
if (ctx->hdr_pos[MBOX_HDR_STATUS] != (size_t)-1) {
status_flags_replace(ctx, ctx->hdr_pos[MBOX_HDR_STATUS],
mbox_status_flags);
}
}
static void mbox_sync_update_xstatus(struct mbox_sync_mail_context *ctx)
{
if (ctx->hdr_pos[MBOX_HDR_X_STATUS] != (size_t)-1) {
status_flags_replace(ctx, ctx->hdr_pos[MBOX_HDR_X_STATUS],
mbox_xstatus_flags);
}
}
static void mbox_sync_update_line(struct mbox_sync_mail_context *ctx,
size_t pos, string_t *new_line)
{
const char *hdr, *p;
uoff_t file_pos;
if (ctx->header_first_change > pos)
ctx->header_first_change = pos;
/* set p = end of header, handle also wrapped headers */
hdr = p = str_c(ctx->header) + pos;
for (;;) {
p = strchr(p, '\n');
if (p == NULL) {
/* shouldn't really happen, but allow anyway.. */
p = hdr + strlen(hdr);
break;
}
if (p[1] != '\t' && p[1] != ' ')
break;
p += 2;
}
file_pos = pos + ctx->hdr_offset;
if (ctx->mail.space > 0 && ctx->mail.offset >= file_pos &&
ctx->mail.offset < file_pos + (p - hdr)) {
/* extra space points to this line. remove it. */
ctx->mail.offset = ctx->hdr_offset;
ctx->mail.space = 0;
}
mbox_sync_move_buffer(ctx, pos, str_len(new_line), p - hdr + 1);
buffer_copy(ctx->header, pos, new_line, 0, (size_t)-1);
}
static void mbox_sync_update_xkeywords(struct mbox_sync_mail_context *ctx)
{
string_t *str;
if (ctx->hdr_pos[MBOX_HDR_X_KEYWORDS] == (size_t)-1)
return;
t_push();
str = t_str_new(256);
keywords_append(ctx->sync_ctx, str, &ctx->mail.keywords);
str_append_c(str, '\n');
mbox_sync_update_line(ctx, ctx->hdr_pos[MBOX_HDR_X_KEYWORDS], str);
t_pop();
}
static void mbox_sync_update_x_imap_base(struct mbox_sync_mail_context *ctx)
{
struct mbox_sync_context *sync_ctx = ctx->sync_ctx;
string_t *str;
i_assert(sync_ctx->base_uid_validity != 0);
if (!sync_ctx->dest_first_mail ||
ctx->hdr_pos[MBOX_HDR_X_IMAPBASE] == (size_t)-1)
return;
if (!ctx->imapbase_rewrite) {
/* uid-last might need updating, but we'll do it later by
writing it directly where needed. */
return;
}
/* a) keyword list changed, b) uid-last didn't use 10 digits */
t_push();
str = t_str_new(200);
str_printfa(str, "%u ", sync_ctx->base_uid_validity);
ctx->last_uid_updated_value = sync_ctx->next_uid-1;
ctx->last_uid_value_start_pos = str_len(str);
ctx->imapbase_updated = TRUE;
str_printfa(str, "%010u", ctx->last_uid_updated_value);
keywords_append_all(ctx, str);
str_append_c(str, '\n');
mbox_sync_update_line(ctx, ctx->hdr_pos[MBOX_HDR_X_IMAPBASE], str);
t_pop();
}
static void mbox_sync_update_x_uid(struct mbox_sync_mail_context *ctx)
{
string_t *str;
if (ctx->hdr_pos[MBOX_HDR_X_UID] == (size_t)-1 ||
ctx->mail.uid == ctx->parsed_uid)
return;
t_push();
str = t_str_new(64);
str_printfa(str, "%u\n", ctx->mail.uid);
mbox_sync_update_line(ctx, ctx->hdr_pos[MBOX_HDR_X_UID], str);
t_pop();
}
void mbox_sync_update_header(struct mbox_sync_mail_context *ctx)
{
uint8_t old_flags;
bool keywords_changed;
i_assert(ctx->mail.uid != 0 || ctx->mail.pseudo);
old_flags = ctx->mail.flags;
if (array_count(&ctx->sync_ctx->syncs) > 0) {
mbox_sync_apply_index_syncs(ctx->sync_ctx, &ctx->mail,
&keywords_changed);
if ((old_flags & XSTATUS_FLAGS_MASK) !=
(ctx->mail.flags & XSTATUS_FLAGS_MASK))
mbox_sync_update_xstatus(ctx);
if (keywords_changed)
mbox_sync_update_xkeywords(ctx);
}
if (!ctx->sync_ctx->mbox->ibox.keep_recent)
ctx->mail.flags &= ~MAIL_RECENT;
if ((old_flags & STATUS_FLAGS_MASK) !=
(ctx->mail.flags & STATUS_FLAGS_MASK))
mbox_sync_update_status(ctx);
mbox_sync_update_x_imap_base(ctx);
mbox_sync_update_x_uid(ctx);
mbox_sync_add_missing_headers(ctx);
ctx->updated = TRUE;
}
void mbox_sync_update_header_from(struct mbox_sync_mail_context *ctx,
const struct mbox_sync_mail *mail)
{
if ((ctx->mail.flags & STATUS_FLAGS_MASK) !=
(mail->flags & STATUS_FLAGS_MASK) ||
(ctx->mail.flags & MAIL_RECENT) != 0) {
ctx->mail.flags = (ctx->mail.flags & ~STATUS_FLAGS_MASK) |
(mail->flags & STATUS_FLAGS_MASK);
if (!ctx->sync_ctx->mbox->ibox.keep_recent)
ctx->mail.flags &= ~MAIL_RECENT;
mbox_sync_update_status(ctx);
}
if ((ctx->mail.flags & XSTATUS_FLAGS_MASK) !=
(mail->flags & XSTATUS_FLAGS_MASK)) {
ctx->mail.flags = (ctx->mail.flags & ~XSTATUS_FLAGS_MASK) |
(mail->flags & XSTATUS_FLAGS_MASK);
mbox_sync_update_xstatus(ctx);
}
if (!array_is_created(&mail->keywords) ||
array_count(&mail->keywords) == 0) {
/* no keywords for this mail */
if (array_is_created(&ctx->mail.keywords)) {
array_clear(&ctx->mail.keywords);
mbox_sync_update_xkeywords(ctx);
}
} else if (!array_is_created(&ctx->mail.keywords)) {
/* adding first keywords */
p_array_init(&ctx->mail.keywords,
ctx->sync_ctx->mail_keyword_pool,
array_count(&mail->keywords));
array_append_array(&ctx->mail.keywords,
&mail->keywords);
mbox_sync_update_xkeywords(ctx);
} else if (!array_cmp(&ctx->mail.keywords, &mail->keywords)) {
/* keywords changed. */
array_clear(&ctx->mail.keywords);
array_append_array(&ctx->mail.keywords,
&mail->keywords);
mbox_sync_update_xkeywords(ctx);
}
i_assert(ctx->mail.uid == 0 || ctx->mail.uid == mail->uid);
ctx->mail.uid = mail->uid;
mbox_sync_update_x_imap_base(ctx);
mbox_sync_update_x_uid(ctx);
mbox_sync_add_missing_headers(ctx);
}