mbox-sync-update.c revision 51ff0538ab38def8045b3f7feb43e1e069cbe037
08b30498acefc69e223baf7eda6429be98cc3a10Timo Sirainen/* Copyright (C) 2004 Timo Sirainen */
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenstatic void status_flags_append(struct mbox_sync_mail_context *ctx,
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen if ((ctx->mail.flags & flags_list[i].flag) != 0)
d371507847d62ba311b4bcc23d18f45c3d0f1a38Timo Sirainenvoid mbox_sync_move_buffer(struct mbox_sync_mail_context *ctx,
f0569d9fbb25c8437760be69f194595a841ad711Timo Sirainen /* FIXME: if (diff < ctx->space && pos < ctx->offset) then
f0569d9fbb25c8437760be69f194595a841ad711Timo Sirainen move the data only up to space offset and give/take the
a205d315b0978985ba77d871f44e4a98273612e6Timo Sirainen space from there. update header_last_change accordingly.
a205d315b0978985ba77d871f44e4a98273612e6Timo Sirainen (except pos and offset can't be compared directly) */
abe8230dd1dd37d7ccf0163100e934bb5e658c20Timo Sirainen for (i = 0; i < MBOX_HDR_COUNT; i++) {
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainenstatic void status_flags_replace(struct mbox_sync_mail_context *ctx, size_t pos,
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen unsigned char *data;
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen /* how many bytes do we need? */
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen for (i = 0, need = 0; flags_list[i].chr != 0; i++) {
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen if ((ctx->mail.flags & flags_list[i].flag) != 0)
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen /* how many bytes do we have now? */
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen data = buffer_get_modifyable_data(ctx->header, &size);
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen /* see if this is unknown flag for us */
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen /* save this one */
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen /* @UNSAFE */
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen data = buffer_get_space_unsafe(ctx->header, pos, need);
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen for (i = 0, need = 0; flags_list[i].chr != 0; i++) {
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen if ((ctx->mail.flags & flags_list[i].flag) != 0)
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainenstatic void keywords_append(struct mbox_sync_context *sync_ctx, string_t *dest,
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen ARRAY_SET_TYPE(keyword_indexes_arr, unsigned int);
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen const char *const *keyword_names;
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen const unsigned int *keyword_indexes;
b5e6f6f27c1461f0f9f202615eeb738a645188c3Timo Sirainen keyword_names = array_get(sync_ctx->mbox->ibox.keyword_names,
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen keyword_indexes = array_get(keyword_indexes_arr, &idx_count);
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen for (i = 0, last_break = 0; i < idx_count; i++) {
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen i_assert(keyword_indexes[i] < keywords_count);
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen /* try avoid overly long lines but cutting them
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen every 70 chars or so */
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen str_append(dest, keyword_names[keyword_indexes[i]]);
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainenkeywords_append_all(struct mbox_sync_mail_context *ctx, string_t *dest)
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen const char *const *names;
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen const unsigned char *p;
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen unsigned int i, count;
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen /* set last_break to beginning of line */
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen for (last_break = str_len(dest); last_break > 0; last_break--) {
b5e6f6f27c1461f0f9f202615eeb738a645188c3Timo Sirainen names = array_get(ctx->sync_ctx->mbox->ibox.keyword_names, &count);
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen for (i = 0; i < count; i++) {
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen /* try avoid overly long lines but cutting them
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen every 70 chars or so */
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenstatic void mbox_sync_add_missing_headers(struct mbox_sync_mail_context *ctx)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen old_hdr_size = ctx->body_offset - ctx->hdr_offset;
7f773564b94e6054a40d3785cb63c29f1e4d4deeTimo Sirainen str_data(ctx->header)[new_hdr_size-1] != '\n') {
7f773564b94e6054a40d3785cb63c29f1e4d4deeTimo Sirainen /* broken header - doesn't end with \n. fix it. */
33ae95df45c9b5ec51332a6b39eb5322038686b9Timo Sirainen ctx->hdr_pos[MBOX_HDR_X_IMAPBASE] == (size_t)-1) {
84e1634acc701d14e358e27f1beff5ad74f5004aTimo Sirainen i_assert(ctx->sync_ctx->base_uid_validity != 0);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen ctx->hdr_pos[MBOX_HDR_X_IMAPBASE] = str_len(ctx->header);
84e1634acc701d14e358e27f1beff5ad74f5004aTimo Sirainen ctx->last_uid_value_start_pos = str_len(ctx->header) -
84e1634acc701d14e358e27f1beff5ad74f5004aTimo Sirainen str_printfa(ctx->header, "%010u", ctx->sync_ctx->next_uid-1);
907723f35f4d3dfc774ca42d00a8a7b8ef90dd5dTimo Sirainen if (ctx->hdr_pos[MBOX_HDR_X_UID] == (size_t)-1 && !ctx->pseudo) {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen ctx->hdr_pos[MBOX_HDR_X_UID] = str_len(ctx->header);
d371507847d62ba311b4bcc23d18f45c3d0f1a38Timo Sirainen str_printfa(ctx->header, "%u\n", ctx->mail.uid);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen if (ctx->hdr_pos[MBOX_HDR_STATUS] == (size_t)-1 &&
d371507847d62ba311b4bcc23d18f45c3d0f1a38Timo Sirainen ctx->hdr_pos[MBOX_HDR_STATUS] = str_len(ctx->header);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen if (ctx->hdr_pos[MBOX_HDR_X_STATUS] == (size_t)-1 &&
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen (ctx->mail.flags & XSTATUS_FLAGS_MASK) != 0) {
d371507847d62ba311b4bcc23d18f45c3d0f1a38Timo Sirainen ctx->hdr_pos[MBOX_HDR_X_STATUS] = str_len(ctx->header);
16c89b1260c9d07c01c83a9219424d3727069b2eTimo Sirainen if (ctx->hdr_pos[MBOX_HDR_X_KEYWORDS] == (size_t)-1 &&
d371507847d62ba311b4bcc23d18f45c3d0f1a38Timo Sirainen ctx->hdr_pos[MBOX_HDR_X_KEYWORDS] = str_len(ctx->header);
08b30498acefc69e223baf7eda6429be98cc3a10Timo Sirainen ctx->mail.body_size >= MBOX_MIN_CONTENT_LENGTH_SIZE) {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen str_printfa(ctx->header, "Content-Length: %"PRIuUOFF_T"\n",
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenstatic void mbox_sync_update_status(struct mbox_sync_mail_context *ctx)
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen if (ctx->hdr_pos[MBOX_HDR_STATUS] != (size_t)-1) {
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen status_flags_replace(ctx, ctx->hdr_pos[MBOX_HDR_STATUS],
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenstatic void mbox_sync_update_xstatus(struct mbox_sync_mail_context *ctx)
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen if (ctx->hdr_pos[MBOX_HDR_X_STATUS] != (size_t)-1) {
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen status_flags_replace(ctx, ctx->hdr_pos[MBOX_HDR_X_STATUS],
6843896c40bee4f9b6680ca7ced598c446e9f999Timo Sirainenstatic void mbox_sync_update_line(struct mbox_sync_mail_context *ctx,
6843896c40bee4f9b6680ca7ced598c446e9f999Timo Sirainen const char *hdr, *p;
6843896c40bee4f9b6680ca7ced598c446e9f999Timo Sirainen /* shouldn't really happen, but allow anyway.. */
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen if (ctx->mail.space > 0 && ctx->mail.offset >= file_pos &&
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen /* extra space points to this line. remove it. */
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen mbox_sync_move_buffer(ctx, pos, str_len(new_line), p - hdr + 1);
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen buffer_copy(ctx->header, pos, new_line, 0, (size_t)-1);
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainenstatic void mbox_sync_update_xkeywords(struct mbox_sync_mail_context *ctx)
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen if (ctx->hdr_pos[MBOX_HDR_X_KEYWORDS] == (size_t)-1)
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen keywords_append(ctx->sync_ctx, str, &ctx->mail.keywords);
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen mbox_sync_update_line(ctx, ctx->hdr_pos[MBOX_HDR_X_KEYWORDS], str);
abe8230dd1dd37d7ccf0163100e934bb5e658c20Timo Sirainenstatic void mbox_sync_update_x_imap_base(struct mbox_sync_mail_context *ctx)
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen struct mbox_sync_context *sync_ctx = ctx->sync_ctx;
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen ctx->hdr_pos[MBOX_HDR_X_IMAPBASE] == (size_t)-1)
84e1634acc701d14e358e27f1beff5ad74f5004aTimo Sirainen /* uid-last might need updating, but we'll do it later by
84e1634acc701d14e358e27f1beff5ad74f5004aTimo Sirainen writing it directly where needed. */
84e1634acc701d14e358e27f1beff5ad74f5004aTimo Sirainen /* a) keyword list changed, b) uid-last didn't use 10 digits */
84e1634acc701d14e358e27f1beff5ad74f5004aTimo Sirainen str_printfa(str, "%u ", sync_ctx->base_uid_validity);
84e1634acc701d14e358e27f1beff5ad74f5004aTimo Sirainen str_printfa(str, "%010u", sync_ctx->next_uid - 1);
6843896c40bee4f9b6680ca7ced598c446e9f999Timo Sirainen mbox_sync_update_line(ctx, ctx->hdr_pos[MBOX_HDR_X_IMAPBASE], str);
6843896c40bee4f9b6680ca7ced598c446e9f999Timo Sirainenstatic void mbox_sync_update_x_uid(struct mbox_sync_mail_context *ctx)
6843896c40bee4f9b6680ca7ced598c446e9f999Timo Sirainen if (ctx->hdr_pos[MBOX_HDR_X_UID] == (size_t)-1 ||
6843896c40bee4f9b6680ca7ced598c446e9f999Timo Sirainen mbox_sync_update_line(ctx, ctx->hdr_pos[MBOX_HDR_X_UID], str);
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainenvoid mbox_sync_update_header(struct mbox_sync_mail_context *ctx)
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen mbox_sync_apply_index_syncs(ctx->sync_ctx, &ctx->mail,
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainenvoid mbox_sync_update_header_from(struct mbox_sync_mail_context *ctx,
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen ctx->mail.flags = (ctx->mail.flags & ~STATUS_FLAGS_MASK) |
313fe89df4d91cd0cd7f3558dc6d7fd21ad39eeeTimo Sirainen ctx->mail.flags = (ctx->mail.flags & ~XSTATUS_FLAGS_MASK) |
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen /* no keywords for this mail */
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen } else if (!array_is_created(&ctx->mail.keywords)) {
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen /* adding first keywords */
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen unsigned int,
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen } else if (!buffer_cmp(ctx->mail.keywords.buffer,
bb10ebcf076c959c752f583746d83805d7686df8Timo Sirainen /* keywords changed. */
912e870dcab2dadac8a6b20b42367999cdd8b5a1Timo Sirainen /* we might not have done the UID validity checks in same way this
912e870dcab2dadac8a6b20b42367999cdd8b5a1Timo Sirainen time, so just overwrite conflicting UIDs if uid_broken was set in
912e870dcab2dadac8a6b20b42367999cdd8b5a1Timo Sirainen first parse time */