index/mbox/mbox-sync-private.h

	mbox-sync-private.h revision e5c08648676d1989f6e70b95e5990c26b3e8b96b
#ifndef __MBOX_SYNC_PRIVATE_H
#define __MBOX_SYNC_PRIVATE_H

#include "mail-index.h"

struct mbox_flag_type {
    char chr;
    enum mail_flags flag;
};

enum header_position {
    MBOX_HDR_STATUS,
    MBOX_HDR_X_IMAPBASE,
    MBOX_HDR_X_KEYWORDS,
    MBOX_HDR_X_STATUS,
    MBOX_HDR_X_UID,

        MBOX_HDR_COUNT
};

#define MBOX_NONRECENT MAIL_RECENT /* kludgy */

#define STATUS_FLAGS_MASK (MAIL_SEEN|MBOX_NONRECENT)
#define XSTATUS_FLAGS_MASK (MAIL_ANSWERED|MAIL_FLAGGED|MAIL_DRAFT|MAIL_DELETED)
extern struct mbox_flag_type mbox_status_flags[];
extern struct mbox_flag_type mbox_xstatus_flags[];

struct mbox_sync_mail {
    uint32_t uid;
    uint8_t flags;
    keywords_mask_t keywords;

    uoff_t from_offset;
    uoff_t body_size;

    /* following variables have a bit overloaded functionality:

       a) space <= 0 : offset points to beginning of headers. space is the
          amount of space missing that is required to be able to rewrite
          the headers
       b) space > 0 : offset points to beginning of whitespace that can
          be removed. space is the amount of data that can be removed from
          there. note that the message may contain more whitespace
          elsewhere. */
    uoff_t offset;
    off_t space;
};

struct mbox_sync_mail_context {
    struct mbox_sync_context *sync_ctx;
    struct mbox_sync_mail mail;

    uint32_t seq;
    uoff_t from_offset, hdr_offset, body_offset;

    size_t header_first_change, header_last_change;
    string_t *header;

    uoff_t content_length;

    size_t hdr_pos[MBOX_HDR_COUNT];
    uint32_t parsed_uid;

    unsigned int have_eoh:1;
    unsigned int need_rewrite:1;
    unsigned int no_partial_rewrite:1;
    unsigned int seen_imapbase:1;
    unsigned int pseudo:1;
    unsigned int updated:1;
};

struct mbox_sync_context {
    struct index_mailbox *ibox;
    struct istream *input, *file_input;
    unsigned int lock_id;
    int fd;

    struct mail_index_sync_ctx *index_sync_ctx;
    struct mail_index_view *sync_view;
    struct mail_index_transaction *t;
    const struct mail_index_header *hdr;

    string_t *header, *from_line;

    /* header state: */
    uint32_t base_uid_validity, base_uid_last;
    uint32_t update_base_uid_last;

    /* mail state: */
    buffer_t *mails, *syncs;
    struct mail_index_sync_rec sync_rec;

    uint32_t prev_msg_uid, next_uid;
    uint32_t seq, idx_seq, need_space_seq, need_space_idx_seq;
    off_t expunged_space, space_diff;

    unsigned int dest_first_mail:1;
    unsigned int seen_first_mail:1;
};

int mbox_sync(struct index_mailbox *ibox, int last_commit,
          int sync_header, int lock);
int mbox_sync_has_changed(struct index_mailbox *ibox);

void mbox_sync_parse_next_mail(struct istream *input,
                   struct mbox_sync_mail_context *ctx);
void mbox_sync_update_header(struct mbox_sync_mail_context *ctx,
                 buffer_t *syncs_buf);
void mbox_sync_update_header_from(struct mbox_sync_mail_context *ctx,
                  const struct mbox_sync_mail *mail);
int mbox_sync_try_rewrite(struct mbox_sync_mail_context *ctx, off_t move_diff);
int mbox_sync_rewrite(struct mbox_sync_context *sync_ctx, uoff_t extra_space,
              uint32_t first_seq, uint32_t last_seq);

int mbox_sync_seek(struct mbox_sync_context *sync_ctx, uoff_t from_offset);
int mbox_move(struct mbox_sync_context *sync_ctx,
          uoff_t dest, uoff_t source, uoff_t size);

#endif