63 files changed, 859 insertions, 78 deletions
diff --git a/kmicromail/libetpan/generic/imapdriver.c b/kmicromail/libetpan/generic/imapdriver.c index 0d63319..b3e5982 100644 --- a/kmicromail/libetpan/generic/imapdriver.c +++ b/kmicromail/libetpan/generic/imapdriver.c | |||
@@ -95,16 +95,18 @@ static int imapdriver_unseen_number(mailsession * session, char * mb, | |||
95 | static int imapdriver_list_folders(mailsession * session, char * mb, | 95 | static int imapdriver_list_folders(mailsession * session, char * mb, |
96 | struct mail_list ** result); | 96 | struct mail_list ** result); |
97 | static int imapdriver_lsub_folders(mailsession * session, char * mb, | 97 | static int imapdriver_lsub_folders(mailsession * session, char * mb, |
98 | struct mail_list ** result); | 98 | struct mail_list ** result); |
99 | static int imapdriver_subscribe_folder(mailsession * session, char * mb); | 99 | static int imapdriver_subscribe_folder(mailsession * session, char * mb); |
100 | static int imapdriver_unsubscribe_folder(mailsession * session, char * mb); | 100 | static int imapdriver_unsubscribe_folder(mailsession * session, char * mb); |
101 | static int imapdriver_append_message(mailsession * session, | 101 | static int imapdriver_append_message(mailsession * session, |
102 | char * message, size_t size); | 102 | char * message, size_t size); |
103 | static int imapdriver_append_message_flags(mailsession * session, | ||
104 | char * message, size_t size, struct mail_flags * flags); | ||
103 | static int imapdriver_copy_message(mailsession * session, | 105 | static int imapdriver_copy_message(mailsession * session, |
104 | uint32_t num, char * mb); | 106 | uint32_t num, char * mb); |
105 | 107 | ||
106 | static int imapdriver_get_messages_list(mailsession * session, | 108 | static int imapdriver_get_messages_list(mailsession * session, |
107 | struct mailmessage_list ** result); | 109 | struct mailmessage_list ** result); |
108 | 110 | ||
109 | static int | 111 | static int |
110 | imapdriver_get_envelopes_list(mailsession * session, | 112 | imapdriver_get_envelopes_list(mailsession * session, |
@@ -152,16 +154,17 @@ static mailsession_driver local_imap_session_driver = { | |||
152 | .sess_recent_number = imapdriver_recent_number, | 154 | .sess_recent_number = imapdriver_recent_number, |
153 | .sess_unseen_number = imapdriver_unseen_number, | 155 | .sess_unseen_number = imapdriver_unseen_number, |
154 | .sess_list_folders = imapdriver_list_folders, | 156 | .sess_list_folders = imapdriver_list_folders, |
155 | .sess_lsub_folders = imapdriver_lsub_folders, | 157 | .sess_lsub_folders = imapdriver_lsub_folders, |
156 | .sess_subscribe_folder = imapdriver_subscribe_folder, | 158 | .sess_subscribe_folder = imapdriver_subscribe_folder, |
157 | .sess_unsubscribe_folder = imapdriver_unsubscribe_folder, | 159 | .sess_unsubscribe_folder = imapdriver_unsubscribe_folder, |
158 | 160 | ||
159 | .sess_append_message = imapdriver_append_message, | 161 | .sess_append_message = imapdriver_append_message, |
162 | .sess_append_message_flags = imapdriver_append_message_flags, | ||
160 | .sess_copy_message = imapdriver_copy_message, | 163 | .sess_copy_message = imapdriver_copy_message, |
161 | .sess_move_message = NULL, | 164 | .sess_move_message = NULL, |
162 | 165 | ||
163 | .sess_get_messages_list = imapdriver_get_messages_list, | 166 | .sess_get_messages_list = imapdriver_get_messages_list, |
164 | .sess_get_envelopes_list = imapdriver_get_envelopes_list, | 167 | .sess_get_envelopes_list = imapdriver_get_envelopes_list, |
165 | .sess_remove_message = NULL, | 168 | .sess_remove_message = NULL, |
166 | #if 0 | 169 | #if 0 |
167 | .sess_search_messages = imapdriver_search_messages, | 170 | .sess_search_messages = imapdriver_search_messages, |
@@ -766,16 +769,41 @@ static int imapdriver_append_message(mailsession * session, | |||
766 | 769 | ||
767 | r = mailimap_append_simple(get_imap_session(session), | 770 | r = mailimap_append_simple(get_imap_session(session), |
768 | get_data(session)->imap_mailbox, | 771 | get_data(session)->imap_mailbox, |
769 | message, size); | 772 | message, size); |
770 | 773 | ||
771 | return imap_error_to_mail_error(r); | 774 | return imap_error_to_mail_error(r); |
772 | } | 775 | } |
773 | 776 | ||
777 | static int imapdriver_append_message_flags(mailsession * session, | ||
778 | char * message, size_t size, struct mail_flags * flags) | ||
779 | { | ||
780 | struct mailimap_flag_list * flag_list; | ||
781 | int r; | ||
782 | |||
783 | if (flags != NULL) { | ||
784 | r = imap_flags_to_imap_flags(flags, &flag_list); | ||
785 | if (r != MAIL_NO_ERROR) | ||
786 | return r; | ||
787 | } | ||
788 | else { | ||
789 | flag_list = NULL; | ||
790 | } | ||
791 | |||
792 | r = mailimap_append(get_imap_session(session), | ||
793 | get_data(session)->imap_mailbox, | ||
794 | flag_list, NULL, message, size); | ||
795 | |||
796 | if (flag_list != NULL) | ||
797 | mailimap_flag_list_free(flag_list); | ||
798 | |||
799 | return imap_error_to_mail_error(r); | ||
800 | } | ||
801 | |||
774 | static int imapdriver_copy_message(mailsession * session, | 802 | static int imapdriver_copy_message(mailsession * session, |
775 | uint32_t num, char * mb) | 803 | uint32_t num, char * mb) |
776 | { | 804 | { |
777 | int r; | 805 | int r; |
778 | struct mailimap_set * set; | 806 | struct mailimap_set * set; |
779 | int res; | 807 | int res; |
780 | 808 | ||
781 | set = mailimap_set_new_single(num); | 809 | set = mailimap_set_new_single(num); |
diff --git a/kmicromail/libetpan/generic/imapdriver_cached.c b/kmicromail/libetpan/generic/imapdriver_cached.c index e6af8e8..04044ae 100644 --- a/kmicromail/libetpan/generic/imapdriver_cached.c +++ b/kmicromail/libetpan/generic/imapdriver_cached.c | |||
@@ -100,16 +100,18 @@ static int imapdriver_cached_list_folders(mailsession * session, char * mb, | |||
100 | static int imapdriver_cached_lsub_folders(mailsession * session, char * mb, | 100 | static int imapdriver_cached_lsub_folders(mailsession * session, char * mb, |
101 | struct mail_list ** result); | 101 | struct mail_list ** result); |
102 | static int imapdriver_cached_subscribe_folder(mailsession * session, | 102 | static int imapdriver_cached_subscribe_folder(mailsession * session, |
103 | char * mb); | 103 | char * mb); |
104 | static int imapdriver_cached_unsubscribe_folder(mailsession * session, | 104 | static int imapdriver_cached_unsubscribe_folder(mailsession * session, |
105 | char * mb); | 105 | char * mb); |
106 | static int imapdriver_cached_append_message(mailsession * session, | 106 | static int imapdriver_cached_append_message(mailsession * session, |
107 | char * message, size_t size); | 107 | char * message, size_t size); |
108 | static int imapdriver_cached_append_message_flags(mailsession * session, | ||
109 | char * message, size_t size, struct mail_flags * flags); | ||
108 | static int imapdriver_cached_copy_message(mailsession * session, | 110 | static int imapdriver_cached_copy_message(mailsession * session, |
109 | uint32_t num, char * mb); | 111 | uint32_t num, char * mb); |
110 | 112 | ||
111 | static int imapdriver_cached_get_messages_list(mailsession * session, | 113 | static int imapdriver_cached_get_messages_list(mailsession * session, |
112 | struct mailmessage_list ** | 114 | struct mailmessage_list ** |
113 | result); | 115 | result); |
114 | static int | 116 | static int |
115 | imapdriver_cached_get_envelopes_list(mailsession * session, | 117 | imapdriver_cached_get_envelopes_list(mailsession * session, |
@@ -160,16 +162,17 @@ static mailsession_driver local_imap_cached_session_driver = { | |||
160 | .sess_recent_number = imapdriver_cached_recent_number, | 162 | .sess_recent_number = imapdriver_cached_recent_number, |
161 | .sess_unseen_number = imapdriver_cached_unseen_number, | 163 | .sess_unseen_number = imapdriver_cached_unseen_number, |
162 | .sess_list_folders = imapdriver_cached_list_folders, | 164 | .sess_list_folders = imapdriver_cached_list_folders, |
163 | .sess_lsub_folders = imapdriver_cached_lsub_folders, | 165 | .sess_lsub_folders = imapdriver_cached_lsub_folders, |
164 | .sess_subscribe_folder = imapdriver_cached_subscribe_folder, | 166 | .sess_subscribe_folder = imapdriver_cached_subscribe_folder, |
165 | .sess_unsubscribe_folder = imapdriver_cached_unsubscribe_folder, | 167 | .sess_unsubscribe_folder = imapdriver_cached_unsubscribe_folder, |
166 | 168 | ||
167 | .sess_append_message = imapdriver_cached_append_message, | 169 | .sess_append_message = imapdriver_cached_append_message, |
170 | .sess_append_message_flags = imapdriver_cached_append_message_flags, | ||
168 | .sess_copy_message = imapdriver_cached_copy_message, | 171 | .sess_copy_message = imapdriver_cached_copy_message, |
169 | .sess_move_message = NULL, | 172 | .sess_move_message = NULL, |
170 | 173 | ||
171 | .sess_get_messages_list = imapdriver_cached_get_messages_list, | 174 | .sess_get_messages_list = imapdriver_cached_get_messages_list, |
172 | .sess_get_envelopes_list = imapdriver_cached_get_envelopes_list, | 175 | .sess_get_envelopes_list = imapdriver_cached_get_envelopes_list, |
173 | .sess_remove_message = imapdriver_cached_remove_message, | 176 | .sess_remove_message = imapdriver_cached_remove_message, |
174 | #if 0 | 177 | #if 0 |
175 | .sess_search_messages = imapdriver_cached_search_messages, | 178 | .sess_search_messages = imapdriver_cached_search_messages, |
@@ -771,16 +774,29 @@ static int imapdriver_cached_append_message(mailsession * session, | |||
771 | 774 | ||
772 | r = mailsession_append_message(get_ancestor(session), message, size); | 775 | r = mailsession_append_message(get_ancestor(session), message, size); |
773 | 776 | ||
774 | check_for_uid_cache(session); | 777 | check_for_uid_cache(session); |
775 | 778 | ||
776 | return r; | 779 | return r; |
777 | } | 780 | } |
778 | 781 | ||
782 | static int imapdriver_cached_append_message_flags(mailsession * session, | ||
783 | char * message, size_t size, struct mail_flags * flags) | ||
784 | { | ||
785 | int r; | ||
786 | |||
787 | r = mailsession_append_message_flags(get_ancestor(session), | ||
788 | message, size, flags); | ||
789 | |||
790 | check_for_uid_cache(session); | ||
791 | |||
792 | return r; | ||
793 | } | ||
794 | |||
779 | static int imapdriver_cached_copy_message(mailsession * session, | 795 | static int imapdriver_cached_copy_message(mailsession * session, |
780 | uint32_t num, char * mb) | 796 | uint32_t num, char * mb) |
781 | { | 797 | { |
782 | int r; | 798 | int r; |
783 | 799 | ||
784 | r = mailsession_copy_message(get_ancestor(session), num, mb); | 800 | r = mailsession_copy_message(get_ancestor(session), num, mb); |
785 | 801 | ||
786 | check_for_uid_cache(session); | 802 | check_for_uid_cache(session); |
diff --git a/kmicromail/libetpan/generic/imapdriver_cached_message.c b/kmicromail/libetpan/generic/imapdriver_cached_message.c index c0542a3..c4357a3 100644 --- a/kmicromail/libetpan/generic/imapdriver_cached_message.c +++ b/kmicromail/libetpan/generic/imapdriver_cached_message.c | |||
@@ -207,17 +207,17 @@ static void generate_key_from_mime_section(char * key, size_t size, | |||
207 | mailmime_section_free(part); | 207 | mailmime_section_free(part); |
208 | 208 | ||
209 | return; | 209 | return; |
210 | 210 | ||
211 | free_str: | 211 | free_str: |
212 | mmap_string_free(gstr); | 212 | mmap_string_free(gstr); |
213 | free_section: | 213 | free_section: |
214 | mailmime_section_free(part); | 214 | mailmime_section_free(part); |
215 | err: | 215 | err:; |
216 | } | 216 | } |
217 | 217 | ||
218 | static void generate_key_from_section(char * key, size_t size, | 218 | static void generate_key_from_section(char * key, size_t size, |
219 | mailmessage * msg_info, | 219 | mailmessage * msg_info, |
220 | struct mailmime * mime, int type) | 220 | struct mailmime * mime, int type) |
221 | { | 221 | { |
222 | char section_str[PATH_MAX]; | 222 | char section_str[PATH_MAX]; |
223 | 223 | ||
diff --git a/kmicromail/libetpan/generic/imapdriver_tools.c b/kmicromail/libetpan/generic/imapdriver_tools.c index 3d737f3..de4008f 100644 --- a/kmicromail/libetpan/generic/imapdriver_tools.c +++ b/kmicromail/libetpan/generic/imapdriver_tools.c | |||
@@ -3102,26 +3102,25 @@ static int imap_flags_to_flags(struct mailimap_msg_att_dynamic * att_dyn, | |||
3102 | return MAIL_NO_ERROR; | 3102 | return MAIL_NO_ERROR; |
3103 | 3103 | ||
3104 | free: | 3104 | free: |
3105 | mail_flags_free(flags); | 3105 | mail_flags_free(flags); |
3106 | err: | 3106 | err: |
3107 | return MAIL_ERROR_MEMORY; | 3107 | return MAIL_ERROR_MEMORY; |
3108 | } | 3108 | } |
3109 | 3109 | ||
3110 | static int flags_to_imap_flags(struct mail_flags * flags, | 3110 | int imap_flags_to_imap_flags(struct mail_flags * flags, |
3111 | struct mailimap_store_att_flags ** result) | 3111 | struct mailimap_flag_list ** result) |
3112 | { | 3112 | { |
3113 | struct mailimap_flag * flag; | 3113 | struct mailimap_flag * flag; |
3114 | struct mailimap_flag_list * flag_list; | 3114 | struct mailimap_flag_list * flag_list; |
3115 | struct mailimap_store_att_flags * att_flags; | ||
3116 | int res; | 3115 | int res; |
3117 | clistiter * cur; | 3116 | clistiter * cur; |
3118 | int r; | 3117 | int r; |
3119 | 3118 | ||
3120 | flag_list = mailimap_flag_list_new_empty(); | 3119 | flag_list = mailimap_flag_list_new_empty(); |
3121 | if (flag_list == NULL) { | 3120 | if (flag_list == NULL) { |
3122 | res = MAIL_ERROR_MEMORY; | 3121 | res = MAIL_ERROR_MEMORY; |
3123 | goto err; | 3122 | goto err; |
3124 | } | 3123 | } |
3125 | 3124 | ||
3126 | if ((flags->fl_flags & MAIL_FLAG_DELETED) != 0) { | 3125 | if ((flags->fl_flags & MAIL_FLAG_DELETED) != 0) { |
3127 | flag = mailimap_flag_new_deleted(); | 3126 | flag = mailimap_flag_new_deleted(); |
@@ -3234,27 +3233,52 @@ static int flags_to_imap_flags(struct mail_flags * flags, | |||
3234 | r = mailimap_flag_list_add(flag_list, flag); | 3233 | r = mailimap_flag_list_add(flag_list, flag); |
3235 | if (r != MAILIMAP_NO_ERROR) { | 3234 | if (r != MAILIMAP_NO_ERROR) { |
3236 | mailimap_flag_free(flag); | 3235 | mailimap_flag_free(flag); |
3237 | res = MAIL_ERROR_MEMORY; | 3236 | res = MAIL_ERROR_MEMORY; |
3238 | goto free_flag_list; | 3237 | goto free_flag_list; |
3239 | } | 3238 | } |
3240 | } | 3239 | } |
3241 | } | 3240 | } |
3241 | |||
3242 | * result = flag_list; | ||
3243 | |||
3244 | return MAIL_NO_ERROR; | ||
3245 | |||
3246 | free_flag_list: | ||
3247 | mailimap_flag_list_free(flag_list); | ||
3248 | err: | ||
3249 | return res; | ||
3250 | } | ||
3242 | 3251 | ||
3252 | static int flags_to_imap_flags(struct mail_flags * flags, | ||
3253 | struct mailimap_store_att_flags ** result) | ||
3254 | { | ||
3255 | struct mailimap_flag_list * flag_list; | ||
3256 | struct mailimap_store_att_flags * att_flags; | ||
3257 | int res; | ||
3258 | int r; | ||
3259 | |||
3260 | r = imap_flags_to_imap_flags(flags, | ||
3261 | &flag_list); | ||
3262 | if (r != MAIL_NO_ERROR) { | ||
3263 | res = r; | ||
3264 | goto err; | ||
3265 | } | ||
3266 | |||
3243 | att_flags = mailimap_store_att_flags_new_set_flags_silent(flag_list); | 3267 | att_flags = mailimap_store_att_flags_new_set_flags_silent(flag_list); |
3244 | if (att_flags == NULL) { | 3268 | if (att_flags == NULL) { |
3245 | res = MAIL_ERROR_MEMORY; | 3269 | res = MAIL_ERROR_MEMORY; |
3246 | goto free_flag_list; | 3270 | goto free_flag_list; |
3247 | } | 3271 | } |
3248 | 3272 | ||
3249 | * result = att_flags; | 3273 | * result = att_flags; |
3250 | 3274 | ||
3251 | return MAIL_NO_ERROR; | 3275 | return MAIL_NO_ERROR; |
3252 | 3276 | ||
3253 | free_flag_list: | 3277 | free_flag_list: |
3254 | mailimap_flag_list_free(flag_list); | 3278 | mailimap_flag_list_free(flag_list); |
3255 | err: | 3279 | err: |
3256 | return res; | 3280 | return res; |
3257 | } | 3281 | } |
3258 | 3282 | ||
3259 | 3283 | ||
3260 | static int | 3284 | static int |
diff --git a/kmicromail/libetpan/generic/imapdriver_tools.h b/kmicromail/libetpan/generic/imapdriver_tools.h index 6582a31..59c993e 100644 --- a/kmicromail/libetpan/generic/imapdriver_tools.h +++ b/kmicromail/libetpan/generic/imapdriver_tools.h | |||
@@ -101,13 +101,16 @@ imapdriver_get_cached_envelope(struct mail_cache_db * cache_db, | |||
101 | struct mailimf_fields ** result); | 101 | struct mailimf_fields ** result); |
102 | 102 | ||
103 | int | 103 | int |
104 | imapdriver_write_cached_envelope(struct mail_cache_db * cache_db, | 104 | imapdriver_write_cached_envelope(struct mail_cache_db * cache_db, |
105 | MMAPString * mmapstr, | 105 | MMAPString * mmapstr, |
106 | mailsession * session, mailmessage * msg, | 106 | mailsession * session, mailmessage * msg, |
107 | struct mailimf_fields * fields); | 107 | struct mailimf_fields * fields); |
108 | 108 | ||
109 | int imap_flags_to_imap_flags(struct mail_flags * flags, | ||
110 | struct mailimap_flag_list ** result); | ||
111 | |||
109 | #ifdef __cplusplus | 112 | #ifdef __cplusplus |
110 | } | 113 | } |
111 | #endif | 114 | #endif |
112 | 115 | ||
113 | #endif | 116 | #endif |
diff --git a/kmicromail/libetpan/generic/imapstorage.c b/kmicromail/libetpan/generic/imapstorage.c index e8683d8..972b6dd 100644 --- a/kmicromail/libetpan/generic/imapstorage.c +++ b/kmicromail/libetpan/generic/imapstorage.c | |||
@@ -66,17 +66,17 @@ int imap_mailstorage_init(struct mailstorage * storage, | |||
66 | char * imap_servername, uint16_t imap_port, | 66 | char * imap_servername, uint16_t imap_port, |
67 | char * imap_command, | 67 | char * imap_command, |
68 | int imap_connection_type, int imap_auth_type, | 68 | int imap_connection_type, int imap_auth_type, |
69 | char * imap_login, char * imap_password, | 69 | char * imap_login, char * imap_password, |
70 | int imap_cached, char * imap_cache_directory) | 70 | int imap_cached, char * imap_cache_directory) |
71 | { | 71 | { |
72 | struct imap_mailstorage * imap_storage; | 72 | struct imap_mailstorage * imap_storage; |
73 | 73 | ||
74 | imap_storage = malloc(sizeof(struct imap_mailstorage)); | 74 | imap_storage = malloc(sizeof(* imap_storage)); |
75 | if (imap_storage == NULL) | 75 | if (imap_storage == NULL) |
76 | goto err; | 76 | goto err; |
77 | 77 | ||
78 | imap_storage->imap_servername = strdup(imap_servername); | 78 | imap_storage->imap_servername = strdup(imap_servername); |
79 | if (imap_storage->imap_servername == NULL) | 79 | if (imap_storage->imap_servername == NULL) |
80 | goto free; | 80 | goto free; |
81 | 81 | ||
82 | imap_storage->imap_connection_type = imap_connection_type; | 82 | imap_storage->imap_connection_type = imap_connection_type; |
diff --git a/kmicromail/libetpan/generic/maildirdriver.c b/kmicromail/libetpan/generic/maildirdriver.c index 7830ceb..5f21422 100644 --- a/kmicromail/libetpan/generic/maildirdriver.c +++ b/kmicromail/libetpan/generic/maildirdriver.c | |||
@@ -80,16 +80,19 @@ static int unseen_number(mailsession * session, char * mb, | |||
80 | uint32_t * result); | 80 | uint32_t * result); |
81 | 81 | ||
82 | static int messages_number(mailsession * session, char * mb, | 82 | static int messages_number(mailsession * session, char * mb, |
83 | uint32_t * result); | 83 | uint32_t * result); |
84 | 84 | ||
85 | static int append_message(mailsession * session, | 85 | static int append_message(mailsession * session, |
86 | char * message, size_t size); | 86 | char * message, size_t size); |
87 | 87 | ||
88 | static int append_message_flags(mailsession * session, | ||
89 | char * message, size_t size, struct mail_flags * flags); | ||
90 | |||
88 | static int get_messages_list(mailsession * session, | 91 | static int get_messages_list(mailsession * session, |
89 | struct mailmessage_list ** result); | 92 | struct mailmessage_list ** result); |
90 | 93 | ||
91 | static int get_envelopes_list(mailsession * session, | 94 | static int get_envelopes_list(mailsession * session, |
92 | struct mailmessage_list * env_list); | 95 | struct mailmessage_list * env_list); |
93 | 96 | ||
94 | static int check_folder(mailsession * session); | 97 | static int check_folder(mailsession * session); |
95 | 98 | ||
@@ -124,16 +127,17 @@ static mailsession_driver local_maildir_session_driver = { | |||
124 | .sess_recent_number = recent_number, | 127 | .sess_recent_number = recent_number, |
125 | .sess_unseen_number = unseen_number, | 128 | .sess_unseen_number = unseen_number, |
126 | .sess_list_folders = NULL, | 129 | .sess_list_folders = NULL, |
127 | .sess_lsub_folders = NULL, | 130 | .sess_lsub_folders = NULL, |
128 | .sess_subscribe_folder = NULL, | 131 | .sess_subscribe_folder = NULL, |
129 | .sess_unsubscribe_folder = NULL, | 132 | .sess_unsubscribe_folder = NULL, |
130 | 133 | ||
131 | .sess_append_message = append_message, | 134 | .sess_append_message = append_message, |
135 | .sess_append_message_flags = append_message_flags, | ||
132 | .sess_copy_message = NULL, | 136 | .sess_copy_message = NULL, |
133 | .sess_move_message = NULL, | 137 | .sess_move_message = NULL, |
134 | 138 | ||
135 | .sess_get_messages_list = get_messages_list, | 139 | .sess_get_messages_list = get_messages_list, |
136 | .sess_get_envelopes_list = get_envelopes_list, | 140 | .sess_get_envelopes_list = get_envelopes_list, |
137 | .sess_remove_message = NULL, | 141 | .sess_remove_message = NULL, |
138 | #if 0 | 142 | #if 0 |
139 | .sess_search_messages = maildriver_generic_search_messages, | 143 | .sess_search_messages = maildriver_generic_search_messages, |
@@ -350,28 +354,75 @@ static int recent_number(mailsession * session, char * mb, | |||
350 | } | 354 | } |
351 | 355 | ||
352 | 356 | ||
353 | /* messages operations */ | 357 | /* messages operations */ |
354 | 358 | ||
355 | static int append_message(mailsession * session, | 359 | static int append_message(mailsession * session, |
356 | char * message, size_t size) | 360 | char * message, size_t size) |
357 | { | 361 | { |
362 | #if 0 | ||
358 | struct maildir * md; | 363 | struct maildir * md; |
359 | int r; | 364 | int r; |
360 | 365 | ||
361 | md = get_maildir_session(session); | 366 | md = get_maildir_session(session); |
362 | if (md == NULL) | 367 | if (md == NULL) |
363 | return MAIL_ERROR_BAD_STATE; | 368 | return MAIL_ERROR_BAD_STATE; |
364 | 369 | ||
365 | r = maildir_message_add(md, message, size); | 370 | r = maildir_message_add(md, message, size); |
366 | if (r != MAILDIR_NO_ERROR) | 371 | if (r != MAILDIR_NO_ERROR) |
367 | return maildirdriver_maildir_error_to_mail_error(r); | 372 | return maildirdriver_maildir_error_to_mail_error(r); |
368 | 373 | ||
369 | return MAIL_NO_ERROR; | 374 | return MAIL_NO_ERROR; |
375 | #endif | ||
376 | |||
377 | return append_message_flags(session, message, size, NULL); | ||
378 | } | ||
379 | |||
380 | static int append_message_flags(mailsession * session, | ||
381 | char * message, size_t size, struct mail_flags * flags) | ||
382 | { | ||
383 | struct maildir * md; | ||
384 | int r; | ||
385 | char uid[PATH_MAX]; | ||
386 | struct maildir_msg * md_msg; | ||
387 | chashdatum key; | ||
388 | chashdatum value; | ||
389 | uint32_t md_flags; | ||
390 | |||
391 | md = get_maildir_session(session); | ||
392 | if (md == NULL) | ||
393 | return MAIL_ERROR_BAD_STATE; | ||
394 | |||
395 | r = maildir_message_add_uid(md, message, size, | ||
396 | uid, sizeof(uid)); | ||
397 | if (r != MAILDIR_NO_ERROR) | ||
398 | return maildirdriver_maildir_error_to_mail_error(r); | ||
399 | |||
400 | if (flags == NULL) | ||
401 | goto exit; | ||
402 | |||
403 | key.data = uid; | ||
404 | key.len = strlen(uid); | ||
405 | r = chash_get(md->mdir_msg_hash, &key, &value); | ||
406 | if (r < 0) | ||
407 | goto exit; | ||
408 | |||
409 | md_msg = value.data; | ||
410 | |||
411 | md_flags = maildirdriver_flags_to_maildir_flags(flags->fl_flags); | ||
412 | |||
413 | r = maildir_message_change_flags(md, uid, md_flags); | ||
414 | if (r != MAILDIR_NO_ERROR) | ||
415 | goto exit; | ||
416 | |||
417 | return MAIL_NO_ERROR; | ||
418 | |||
419 | exit: | ||
420 | return MAIL_NO_ERROR; | ||
370 | } | 421 | } |
371 | 422 | ||
372 | static int get_messages_list(mailsession * session, | 423 | static int get_messages_list(mailsession * session, |
373 | struct mailmessage_list ** result) | 424 | struct mailmessage_list ** result) |
374 | { | 425 | { |
375 | struct maildir * md; | 426 | struct maildir * md; |
376 | int r; | 427 | int r; |
377 | struct mailmessage_list * env_list; | 428 | struct mailmessage_list * env_list; |
diff --git a/kmicromail/libetpan/generic/maildirdriver_cached.c b/kmicromail/libetpan/generic/maildirdriver_cached.c index 503d1c9..8a5e206 100644 --- a/kmicromail/libetpan/generic/maildirdriver_cached.c +++ b/kmicromail/libetpan/generic/maildirdriver_cached.c | |||
@@ -81,16 +81,19 @@ static int unseen_number(mailsession * session, char * mb, | |||
81 | uint32_t * result); | 81 | uint32_t * result); |
82 | 82 | ||
83 | static int messages_number(mailsession * session, char * mb, | 83 | static int messages_number(mailsession * session, char * mb, |
84 | uint32_t * result); | 84 | uint32_t * result); |
85 | 85 | ||
86 | static int append_message(mailsession * session, | 86 | static int append_message(mailsession * session, |
87 | char * message, size_t size); | 87 | char * message, size_t size); |
88 | 88 | ||
89 | static int append_message_flags(mailsession * session, | ||
90 | char * message, size_t size, struct mail_flags * flags); | ||
91 | |||
89 | static int get_messages_list(mailsession * session, | 92 | static int get_messages_list(mailsession * session, |
90 | struct mailmessage_list ** result); | 93 | struct mailmessage_list ** result); |
91 | 94 | ||
92 | static int get_envelopes_list(mailsession * session, | 95 | static int get_envelopes_list(mailsession * session, |
93 | struct mailmessage_list * env_list); | 96 | struct mailmessage_list * env_list); |
94 | 97 | ||
95 | static int check_folder(mailsession * session); | 98 | static int check_folder(mailsession * session); |
96 | 99 | ||
@@ -128,16 +131,17 @@ static mailsession_driver local_maildir_cached_session_driver = { | |||
128 | .sess_recent_number = recent_number, | 131 | .sess_recent_number = recent_number, |
129 | .sess_unseen_number = unseen_number, | 132 | .sess_unseen_number = unseen_number, |
130 | .sess_list_folders = NULL, | 133 | .sess_list_folders = NULL, |
131 | .sess_lsub_folders = NULL, | 134 | .sess_lsub_folders = NULL, |
132 | .sess_subscribe_folder = NULL, | 135 | .sess_subscribe_folder = NULL, |
133 | .sess_unsubscribe_folder = NULL, | 136 | .sess_unsubscribe_folder = NULL, |
134 | 137 | ||
135 | .sess_append_message = append_message, | 138 | .sess_append_message = append_message, |
139 | .sess_append_message_flags = append_message_flags, | ||
136 | .sess_copy_message = NULL, | 140 | .sess_copy_message = NULL, |
137 | .sess_move_message = NULL, | 141 | .sess_move_message = NULL, |
138 | 142 | ||
139 | .sess_get_messages_list = get_messages_list, | 143 | .sess_get_messages_list = get_messages_list, |
140 | .sess_get_envelopes_list = get_envelopes_list, | 144 | .sess_get_envelopes_list = get_envelopes_list, |
141 | .sess_remove_message = NULL, | 145 | .sess_remove_message = NULL, |
142 | #if 0 | 146 | #if 0 |
143 | .sess_search_messages = maildriver_generic_search_messages, | 147 | .sess_search_messages = maildriver_generic_search_messages, |
@@ -449,19 +453,93 @@ static int recent_number(mailsession * session, char * mb, | |||
449 | { | 453 | { |
450 | return mailsession_recent_number(get_ancestor(session), mb, result); | 454 | return mailsession_recent_number(get_ancestor(session), mb, result); |
451 | } | 455 | } |
452 | 456 | ||
453 | 457 | ||
454 | static int append_message(mailsession * session, | 458 | static int append_message(mailsession * session, |
455 | char * message, size_t size) | 459 | char * message, size_t size) |
456 | { | 460 | { |
461 | #if 0 | ||
457 | return mailsession_append_message(get_ancestor(session), message, size); | 462 | return mailsession_append_message(get_ancestor(session), message, size); |
463 | #endif | ||
464 | return append_message_flags(session, message, size, NULL); | ||
458 | } | 465 | } |
459 | 466 | ||
467 | static int append_message_flags(mailsession * session, | ||
468 | char * message, size_t size, struct mail_flags * flags) | ||
469 | { | ||
470 | struct maildir * md; | ||
471 | int r; | ||
472 | char uid[PATH_MAX]; | ||
473 | struct maildir_msg * md_msg; | ||
474 | chashdatum key; | ||
475 | chashdatum value; | ||
476 | uint32_t md_flags; | ||
477 | struct mail_cache_db * cache_db_flags; | ||
478 | char filename_flags[PATH_MAX]; | ||
479 | MMAPString * mmapstr; | ||
480 | struct maildir_cached_session_state_data * data; | ||
481 | |||
482 | md = get_maildir_session(session); | ||
483 | if (md == NULL) | ||
484 | return MAIL_ERROR_BAD_STATE; | ||
485 | |||
486 | r = maildir_message_add_uid(md, message, size, | ||
487 | uid, sizeof(uid)); | ||
488 | if (r != MAILDIR_NO_ERROR) | ||
489 | return maildirdriver_maildir_error_to_mail_error(r); | ||
490 | |||
491 | if (flags == NULL) | ||
492 | goto exit; | ||
493 | |||
494 | data = get_cached_data(session); | ||
495 | |||
496 | snprintf(filename_flags, PATH_MAX, "%s%c%s%c%s", | ||
497 | data->md_flags_directory, MAIL_DIR_SEPARATOR, data->md_quoted_mb, | ||
498 | MAIL_DIR_SEPARATOR, FLAGS_NAME); | ||
499 | |||
500 | r = mail_cache_db_open_lock(filename_flags, &cache_db_flags); | ||
501 | if (r < 0) | ||
502 | goto exit; | ||
503 | |||
504 | mmapstr = mmap_string_new(""); | ||
505 | if (mmapstr == NULL) | ||
506 | goto close_db_flags; | ||
507 | |||
508 | r = write_cached_flags(cache_db_flags, mmapstr, | ||
509 | uid, flags); | ||
510 | |||
511 | mmap_string_free(mmapstr); | ||
512 | mail_cache_db_close_unlock(filename_flags, cache_db_flags); | ||
513 | |||
514 | if (r != MAIL_NO_ERROR) | ||
515 | goto exit; | ||
516 | |||
517 | key.data = uid; | ||
518 | key.len = strlen(uid); | ||
519 | r = chash_get(md->mdir_msg_hash, &key, &value); | ||
520 | if (r < 0) | ||
521 | goto exit; | ||
522 | |||
523 | md_msg = value.data; | ||
524 | |||
525 | md_flags = maildirdriver_flags_to_maildir_flags(flags->fl_flags); | ||
526 | |||
527 | r = maildir_message_change_flags(md, uid, md_flags); | ||
528 | if (r != MAILDIR_NO_ERROR) | ||
529 | goto exit; | ||
530 | |||
531 | return MAIL_NO_ERROR; | ||
532 | |||
533 | close_db_flags: | ||
534 | mail_cache_db_close_unlock(filename_flags, cache_db_flags); | ||
535 | exit: | ||
536 | return MAIL_NO_ERROR; | ||
537 | } | ||
460 | 538 | ||
461 | #define UID_NAME "uid.db" | 539 | #define UID_NAME "uid.db" |
462 | 540 | ||
463 | static int uid_clean_up(struct mail_cache_db * uid_db, | 541 | static int uid_clean_up(struct mail_cache_db * uid_db, |
464 | struct mailmessage_list * env_list) | 542 | struct mailmessage_list * env_list) |
465 | { | 543 | { |
466 | chash * hash_exist; | 544 | chash * hash_exist; |
467 | int res; | 545 | int res; |
diff --git a/kmicromail/libetpan/generic/maildirdriver_cached_message.c b/kmicromail/libetpan/generic/maildirdriver_cached_message.c index 51866aa..34de351 100644 --- a/kmicromail/libetpan/generic/maildirdriver_cached_message.c +++ b/kmicromail/libetpan/generic/maildirdriver_cached_message.c | |||
@@ -34,25 +34,30 @@ | |||
34 | */ | 34 | */ |
35 | 35 | ||
36 | #include "maildirdriver_message.h" | 36 | #include "maildirdriver_message.h" |
37 | 37 | ||
38 | #include "mailmessage_tools.h" | 38 | #include "mailmessage_tools.h" |
39 | #include "maildirdriver.h" | 39 | #include "maildirdriver.h" |
40 | #include "maildir.h" | 40 | #include "maildir.h" |
41 | #include "generic_cache.h" | 41 | #include "generic_cache.h" |
42 | #include "mail_cache_db.h" | ||
43 | #include "maildirdriver_tools.h" | ||
42 | 44 | ||
43 | #include <unistd.h> | 45 | #include <unistd.h> |
44 | #include <sys/mman.h> | 46 | #include <sys/mman.h> |
45 | #include <sys/types.h> | 47 | #include <sys/types.h> |
46 | #include <sys/stat.h> | 48 | #include <sys/stat.h> |
47 | #include <fcntl.h> | 49 | #include <fcntl.h> |
48 | #include <string.h> | 50 | #include <string.h> |
49 | #include <stdlib.h> | 51 | #include <stdlib.h> |
50 | 52 | ||
53 | static int get_flags(mailmessage * msg_info, | ||
54 | struct mail_flags ** result); | ||
55 | |||
51 | static int prefetch(mailmessage * msg_info); | 56 | static int prefetch(mailmessage * msg_info); |
52 | 57 | ||
53 | static void prefetch_free(struct generic_message_t * msg); | 58 | static void prefetch_free(struct generic_message_t * msg); |
54 | 59 | ||
55 | static int initialize(mailmessage * msg_info); | 60 | static int initialize(mailmessage * msg_info); |
56 | 61 | ||
57 | static void check(mailmessage * msg_info); | 62 | static void check(mailmessage * msg_info); |
58 | 63 | ||
@@ -73,17 +78,17 @@ static mailmessage_driver local_maildir_cached_message_driver = { | |||
73 | .msg_fetch_size = NULL, | 78 | .msg_fetch_size = NULL, |
74 | .msg_get_bodystructure = mailmessage_generic_get_bodystructure, | 79 | .msg_get_bodystructure = mailmessage_generic_get_bodystructure, |
75 | .msg_fetch_section = mailmessage_generic_fetch_section, | 80 | .msg_fetch_section = mailmessage_generic_fetch_section, |
76 | .msg_fetch_section_header = mailmessage_generic_fetch_section_header, | 81 | .msg_fetch_section_header = mailmessage_generic_fetch_section_header, |
77 | .msg_fetch_section_mime = mailmessage_generic_fetch_section_mime, | 82 | .msg_fetch_section_mime = mailmessage_generic_fetch_section_mime, |
78 | .msg_fetch_section_body = mailmessage_generic_fetch_section_body, | 83 | .msg_fetch_section_body = mailmessage_generic_fetch_section_body, |
79 | .msg_fetch_envelope = mailmessage_generic_fetch_envelope, | 84 | .msg_fetch_envelope = mailmessage_generic_fetch_envelope, |
80 | 85 | ||
81 | .msg_get_flags = NULL, | 86 | .msg_get_flags = get_flags, |
82 | }; | 87 | }; |
83 | 88 | ||
84 | mailmessage_driver * maildir_cached_message_driver = | 89 | mailmessage_driver * maildir_cached_message_driver = |
85 | &local_maildir_cached_message_driver; | 90 | &local_maildir_cached_message_driver; |
86 | 91 | ||
87 | struct maildir_msg_data { | 92 | struct maildir_msg_data { |
88 | int fd; | 93 | int fd; |
89 | }; | 94 | }; |
@@ -241,8 +246,89 @@ static void check(mailmessage * msg_info) | |||
241 | 246 | ||
242 | if (msg_info->msg_flags != NULL) { | 247 | if (msg_info->msg_flags != NULL) { |
243 | r = mail_flags_store_set(get_session_ancestor_data(msg_info)->md_flags_store, msg_info); | 248 | r = mail_flags_store_set(get_session_ancestor_data(msg_info)->md_flags_store, msg_info); |
244 | 249 | ||
245 | r = mail_flags_store_set(get_cached_session_data(msg_info)->md_flags_store, msg_info); | 250 | r = mail_flags_store_set(get_cached_session_data(msg_info)->md_flags_store, msg_info); |
246 | /* ignore errors */ | 251 | /* ignore errors */ |
247 | } | 252 | } |
248 | } | 253 | } |
254 | |||
255 | #define FLAGS_NAME "flags.db" | ||
256 | |||
257 | static int get_flags(mailmessage * msg_info, | ||
258 | struct mail_flags ** result) | ||
259 | { | ||
260 | struct mail_cache_db * cache_db_flags; | ||
261 | chashdatum key; | ||
262 | chashdatum value; | ||
263 | struct maildir * md; | ||
264 | struct mail_flags * flags; | ||
265 | struct maildir_cached_session_state_data * data; | ||
266 | struct maildir_msg * md_msg; | ||
267 | int r; | ||
268 | uint32_t driver_flags; | ||
269 | char filename_flags[PATH_MAX]; | ||
270 | char keyname[PATH_MAX]; | ||
271 | MMAPString * mmapstr; | ||
272 | |||
273 | if (msg_info->msg_flags != NULL) { | ||
274 | * result = msg_info->msg_flags; | ||
275 | return MAIL_NO_ERROR; | ||
276 | } | ||
277 | |||
278 | data = get_cached_session_data(msg_info); | ||
279 | flags = mail_flags_store_get(data->md_flags_store, | ||
280 | msg_info->msg_index); | ||
281 | if (flags != NULL) { | ||
282 | msg_info->msg_flags = flags; | ||
283 | * result = msg_info->msg_flags; | ||
284 | return MAIL_NO_ERROR; | ||
285 | } | ||
286 | |||
287 | snprintf(filename_flags, PATH_MAX, "%s%c%s%c%s", | ||
288 | data->md_flags_directory, MAIL_DIR_SEPARATOR, data->md_quoted_mb, | ||
289 | MAIL_DIR_SEPARATOR, FLAGS_NAME); | ||
290 | |||
291 | r = mail_cache_db_open_lock(filename_flags, &cache_db_flags); | ||
292 | if (r < 0) | ||
293 | return MAIL_ERROR_FILE; | ||
294 | |||
295 | snprintf(keyname, PATH_MAX, "%s-flags", msg_info->msg_uid); | ||
296 | |||
297 | mmapstr = mmap_string_new(""); | ||
298 | if (mmapstr == NULL) { | ||
299 | mail_cache_db_close_unlock(filename_flags, cache_db_flags); | ||
300 | return MAIL_ERROR_MEMORY; | ||
301 | } | ||
302 | |||
303 | r = generic_cache_flags_read(cache_db_flags, mmapstr, keyname, &flags); | ||
304 | mmap_string_free(mmapstr); | ||
305 | |||
306 | mail_cache_db_close_unlock(filename_flags, cache_db_flags); | ||
307 | |||
308 | if (r != MAIL_NO_ERROR) { | ||
309 | flags = mail_flags_new_empty(); | ||
310 | if (flags == NULL) | ||
311 | return MAIL_ERROR_MEMORY; | ||
312 | } | ||
313 | |||
314 | md = get_maildir_session(msg_info); | ||
315 | if (md == NULL) | ||
316 | return MAIL_ERROR_BAD_STATE; | ||
317 | |||
318 | key.data = msg_info->msg_uid; | ||
319 | key.len = strlen(msg_info->msg_uid); | ||
320 | r = chash_get(md->mdir_msg_hash, &key, &value); | ||
321 | if (r < 0) | ||
322 | return MAIL_ERROR_MSG_NOT_FOUND; | ||
323 | |||
324 | md_msg = value.data; | ||
325 | |||
326 | driver_flags = maildirdriver_maildir_flags_to_flags(md_msg->msg_flags); | ||
327 | |||
328 | flags->fl_flags = driver_flags; | ||
329 | msg_info->msg_flags = flags; | ||
330 | |||
331 | * result = msg_info->msg_flags; | ||
332 | |||
333 | return MAIL_NO_ERROR; | ||
334 | } | ||
diff --git a/kmicromail/libetpan/generic/maildirdriver_message.c b/kmicromail/libetpan/generic/maildirdriver_message.c index 7cf9dd1..613fc39 100644 --- a/kmicromail/libetpan/generic/maildirdriver_message.c +++ b/kmicromail/libetpan/generic/maildirdriver_message.c | |||
@@ -29,30 +29,34 @@ | |||
29 | * SUCH DAMAGE. | 29 | * SUCH DAMAGE. |
30 | */ | 30 | */ |
31 | 31 | ||
32 | /* | 32 | /* |
33 | * $Id$ | 33 | * $Id$ |
34 | */ | 34 | */ |
35 | 35 | ||
36 | #include "maildirdriver_message.h" | 36 | #include "maildirdriver_message.h" |
37 | #include "maildirdriver_tools.h" | ||
37 | 38 | ||
38 | #include "mailmessage_tools.h" | 39 | #include "mailmessage_tools.h" |
39 | #include "maildirdriver.h" | 40 | #include "maildirdriver.h" |
40 | #include "maildir.h" | 41 | #include "maildir.h" |
41 | #include "generic_cache.h" | 42 | #include "generic_cache.h" |
42 | 43 | ||
43 | #include <unistd.h> | 44 | #include <unistd.h> |
44 | #include <sys/mman.h> | 45 | #include <sys/mman.h> |
45 | #include <sys/types.h> | 46 | #include <sys/types.h> |
46 | #include <sys/stat.h> | 47 | #include <sys/stat.h> |
47 | #include <fcntl.h> | 48 | #include <fcntl.h> |
48 | #include <string.h> | 49 | #include <string.h> |
49 | #include <stdlib.h> | 50 | #include <stdlib.h> |
50 | 51 | ||
52 | static int get_flags(mailmessage * msg_info, | ||
53 | struct mail_flags ** result); | ||
54 | |||
51 | static int prefetch(mailmessage * msg_info); | 55 | static int prefetch(mailmessage * msg_info); |
52 | 56 | ||
53 | static void prefetch_free(struct generic_message_t * msg); | 57 | static void prefetch_free(struct generic_message_t * msg); |
54 | 58 | ||
55 | static int initialize(mailmessage * msg_info); | 59 | static int initialize(mailmessage * msg_info); |
56 | 60 | ||
57 | static void check(mailmessage * msg_info); | 61 | static void check(mailmessage * msg_info); |
58 | 62 | ||
@@ -73,17 +77,17 @@ static mailmessage_driver local_maildir_message_driver = { | |||
73 | .msg_fetch_size = NULL, | 77 | .msg_fetch_size = NULL, |
74 | .msg_get_bodystructure = mailmessage_generic_get_bodystructure, | 78 | .msg_get_bodystructure = mailmessage_generic_get_bodystructure, |
75 | .msg_fetch_section = mailmessage_generic_fetch_section, | 79 | .msg_fetch_section = mailmessage_generic_fetch_section, |
76 | .msg_fetch_section_header = mailmessage_generic_fetch_section_header, | 80 | .msg_fetch_section_header = mailmessage_generic_fetch_section_header, |
77 | .msg_fetch_section_mime = mailmessage_generic_fetch_section_mime, | 81 | .msg_fetch_section_mime = mailmessage_generic_fetch_section_mime, |
78 | .msg_fetch_section_body = mailmessage_generic_fetch_section_body, | 82 | .msg_fetch_section_body = mailmessage_generic_fetch_section_body, |
79 | .msg_fetch_envelope = mailmessage_generic_fetch_envelope, | 83 | .msg_fetch_envelope = mailmessage_generic_fetch_envelope, |
80 | 84 | ||
81 | .msg_get_flags = NULL, | 85 | .msg_get_flags = get_flags, |
82 | }; | 86 | }; |
83 | 87 | ||
84 | mailmessage_driver * maildir_message_driver = &local_maildir_message_driver; | 88 | mailmessage_driver * maildir_message_driver = &local_maildir_message_driver; |
85 | 89 | ||
86 | struct maildir_msg_data { | 90 | struct maildir_msg_data { |
87 | int fd; | 91 | int fd; |
88 | }; | 92 | }; |
89 | 93 | ||
@@ -192,8 +196,60 @@ static void check(mailmessage * msg_info) | |||
192 | int r; | 196 | int r; |
193 | 197 | ||
194 | if (msg_info->msg_flags != NULL) { | 198 | if (msg_info->msg_flags != NULL) { |
195 | r = mail_flags_store_set(get_session_data(msg_info)->md_flags_store, | 199 | r = mail_flags_store_set(get_session_data(msg_info)->md_flags_store, |
196 | msg_info); | 200 | msg_info); |
197 | /* ignore errors */ | 201 | /* ignore errors */ |
198 | } | 202 | } |
199 | } | 203 | } |
204 | |||
205 | static int get_flags(mailmessage * msg_info, | ||
206 | struct mail_flags ** result) | ||
207 | { | ||
208 | chashdatum key; | ||
209 | chashdatum value; | ||
210 | struct maildir * md; | ||
211 | struct mail_flags * flags; | ||
212 | struct maildir_session_state_data * data; | ||
213 | struct maildir_msg * md_msg; | ||
214 | int r; | ||
215 | uint32_t driver_flags; | ||
216 | clist * ext; | ||
217 | |||
218 | if (msg_info->msg_flags != NULL) { | ||
219 | * result = msg_info->msg_flags; | ||
220 | return MAIL_NO_ERROR; | ||
221 | } | ||
222 | |||
223 | data = get_session_data(msg_info); | ||
224 | flags = mail_flags_store_get(data->md_flags_store, | ||
225 | msg_info->msg_index); | ||
226 | if (flags != NULL) { | ||
227 | msg_info->msg_flags = flags; | ||
228 | * result = msg_info->msg_flags; | ||
229 | return MAIL_NO_ERROR; | ||
230 | } | ||
231 | |||
232 | md = get_maildir_session(msg_info); | ||
233 | if (md == NULL) | ||
234 | return MAIL_ERROR_BAD_STATE; | ||
235 | |||
236 | key.data = msg_info->msg_uid; | ||
237 | key.len = strlen(msg_info->msg_uid); | ||
238 | r = chash_get(md->mdir_msg_hash, &key, &value); | ||
239 | if (r < 0) | ||
240 | return MAIL_ERROR_MSG_NOT_FOUND; | ||
241 | |||
242 | md_msg = value.data; | ||
243 | |||
244 | driver_flags = maildirdriver_maildir_flags_to_flags(md_msg->msg_flags); | ||
245 | |||
246 | ext = clist_new(); | ||
247 | if (ext == NULL) | ||
248 | return MAIL_ERROR_MEMORY; | ||
249 | |||
250 | msg_info->msg_flags = mail_flags_new(driver_flags, ext); | ||
251 | |||
252 | * result = msg_info->msg_flags; | ||
253 | |||
254 | return MAIL_NO_ERROR; | ||
255 | } | ||
diff --git a/kmicromail/libetpan/generic/maildirstorage.c b/kmicromail/libetpan/generic/maildirstorage.c index 7e6b461..e37f591 100644 --- a/kmicromail/libetpan/generic/maildirstorage.c +++ b/kmicromail/libetpan/generic/maildirstorage.c | |||
@@ -28,16 +28,17 @@ | |||
28 | * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF | 28 | * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF |
29 | * SUCH DAMAGE. | 29 | * SUCH DAMAGE. |
30 | */ | 30 | */ |
31 | 31 | ||
32 | /* | 32 | /* |
33 | * $Id$ | 33 | * $Id$ |
34 | */ | 34 | */ |
35 | 35 | ||
36 | #include "maildirstorage.h" | ||
36 | #include "mailstorage.h" | 37 | #include "mailstorage.h" |
37 | 38 | ||
38 | #include "mail.h" | 39 | #include "mail.h" |
39 | #include "mailmessage.h" | 40 | #include "mailmessage.h" |
40 | #include "maildirdriver.h" | 41 | #include "maildirdriver.h" |
41 | #include "maildirdriver_cached.h" | 42 | #include "maildirdriver_cached.h" |
42 | #include "maildriver.h" | 43 | #include "maildriver.h" |
43 | 44 | ||
@@ -60,17 +61,17 @@ static mailstorage_driver maildir_mailstorage_driver = { | |||
60 | }; | 61 | }; |
61 | 62 | ||
62 | int maildir_mailstorage_init(struct mailstorage * storage, | 63 | int maildir_mailstorage_init(struct mailstorage * storage, |
63 | char * md_pathname, int md_cached, | 64 | char * md_pathname, int md_cached, |
64 | char * md_cache_directory, char * md_flags_directory) | 65 | char * md_cache_directory, char * md_flags_directory) |
65 | { | 66 | { |
66 | struct maildir_mailstorage * maildir_storage; | 67 | struct maildir_mailstorage * maildir_storage; |
67 | 68 | ||
68 | maildir_storage = malloc(sizeof(struct maildir_mailstorage)); | 69 | maildir_storage = malloc(sizeof(* maildir_storage)); |
69 | if (maildir_storage == NULL) | 70 | if (maildir_storage == NULL) |
70 | goto err; | 71 | goto err; |
71 | 72 | ||
72 | maildir_storage->md_pathname = strdup(md_pathname); | 73 | maildir_storage->md_pathname = strdup(md_pathname); |
73 | if (maildir_storage->md_pathname == NULL) | 74 | if (maildir_storage->md_pathname == NULL) |
74 | goto free; | 75 | goto free; |
75 | 76 | ||
76 | maildir_storage->md_cached = md_cached; | 77 | maildir_storage->md_cached = md_cached; |
diff --git a/kmicromail/libetpan/generic/maildirstorage.h b/kmicromail/libetpan/generic/maildirstorage.h index d17ea2c..73d7b20 100644 --- a/kmicromail/libetpan/generic/maildirstorage.h +++ b/kmicromail/libetpan/generic/maildirstorage.h | |||
@@ -39,17 +39,17 @@ | |||
39 | 39 | ||
40 | #include <libetpan/maildirdriver_types.h> | 40 | #include <libetpan/maildirdriver_types.h> |
41 | 41 | ||
42 | #ifdef __cplusplus | 42 | #ifdef __cplusplus |
43 | extern "C" { | 43 | extern "C" { |
44 | #endif | 44 | #endif |
45 | 45 | ||
46 | /* | 46 | /* |
47 | maildir_mailstorage_init is the constructor for a mbox storage. | 47 | maildir_mailstorage_init is the constructor for a maildir storage. |
48 | 48 | ||
49 | @param storage this is the storage to initialize. | 49 | @param storage this is the storage to initialize. |
50 | 50 | ||
51 | @param pathname is the directory that contains the mailbox. | 51 | @param pathname is the directory that contains the mailbox. |
52 | 52 | ||
53 | @param cached if this value is != 0, a persistant cache will be | 53 | @param cached if this value is != 0, a persistant cache will be |
54 | stored on local system. | 54 | stored on local system. |
55 | 55 | ||
diff --git a/kmicromail/libetpan/generic/maildriver.c b/kmicromail/libetpan/generic/maildriver.c index 01e3e34..1fc478a 100644 --- a/kmicromail/libetpan/generic/maildriver.c +++ b/kmicromail/libetpan/generic/maildriver.c | |||
@@ -277,16 +277,26 @@ int mailsession_append_message(mailsession * session, | |||
277 | char * message, size_t size) | 277 | char * message, size_t size) |
278 | { | 278 | { |
279 | if (session->sess_driver->sess_append_message == NULL) | 279 | if (session->sess_driver->sess_append_message == NULL) |
280 | return MAIL_ERROR_NOT_IMPLEMENTED; | 280 | return MAIL_ERROR_NOT_IMPLEMENTED; |
281 | 281 | ||
282 | return session->sess_driver->sess_append_message(session, message, size); | 282 | return session->sess_driver->sess_append_message(session, message, size); |
283 | } | 283 | } |
284 | 284 | ||
285 | int mailsession_append_message_flags(mailsession * session, | ||
286 | char * message, size_t size, struct mail_flags * flags) | ||
287 | { | ||
288 | if (session->sess_driver->sess_append_message_flags == NULL) | ||
289 | return MAIL_ERROR_NOT_IMPLEMENTED; | ||
290 | |||
291 | return session->sess_driver->sess_append_message_flags(session, | ||
292 | message, size, flags); | ||
293 | } | ||
294 | |||
285 | int mailsession_copy_message(mailsession * session, | 295 | int mailsession_copy_message(mailsession * session, |
286 | uint32_t num, char * mb) | 296 | uint32_t num, char * mb) |
287 | { | 297 | { |
288 | if (session->sess_driver->sess_copy_message == NULL) | 298 | if (session->sess_driver->sess_copy_message == NULL) |
289 | return MAIL_ERROR_NOT_IMPLEMENTED; | 299 | return MAIL_ERROR_NOT_IMPLEMENTED; |
290 | 300 | ||
291 | return session->sess_driver->sess_copy_message(session, num, mb); | 301 | return session->sess_driver->sess_copy_message(session, num, mb); |
292 | } | 302 | } |
diff --git a/kmicromail/libetpan/generic/maildriver.h b/kmicromail/libetpan/generic/maildriver.h index 7da9aea..c773190 100644 --- a/kmicromail/libetpan/generic/maildriver.h +++ b/kmicromail/libetpan/generic/maildriver.h | |||
@@ -395,16 +395,19 @@ int mailsession_unsubscribe_folder(mailsession * session, char * mb); | |||
395 | 395 | ||
396 | @return MAIL_NO_ERROR is returned on success, MAIL_ERROR_XXX is returned | 396 | @return MAIL_NO_ERROR is returned on success, MAIL_ERROR_XXX is returned |
397 | on error | 397 | on error |
398 | */ | 398 | */ |
399 | 399 | ||
400 | int mailsession_append_message(mailsession * session, | 400 | int mailsession_append_message(mailsession * session, |
401 | char * message, size_t size); | 401 | char * message, size_t size); |
402 | 402 | ||
403 | int mailsession_append_message_flags(mailsession * session, | ||
404 | char * message, size_t size, struct mail_flags * flags); | ||
405 | |||
403 | /* | 406 | /* |
404 | NOTE: some drivers does not implement this | 407 | NOTE: some drivers does not implement this |
405 | 408 | ||
406 | mailsession_copy_message copies a message whose number is given to | 409 | mailsession_copy_message copies a message whose number is given to |
407 | a given mailbox. The mailbox must be accessible from the same session. | 410 | a given mailbox. The mailbox must be accessible from the same session. |
408 | 411 | ||
409 | @param session the session | 412 | @param session the session |
410 | @param num the message number | 413 | @param num the message number |
diff --git a/kmicromail/libetpan/generic/maildriver_types.h b/kmicromail/libetpan/generic/maildriver_types.h index 3ff9440..9eab4d6 100644 --- a/kmicromail/libetpan/generic/maildriver_types.h +++ b/kmicromail/libetpan/generic/maildriver_types.h | |||
@@ -502,16 +502,18 @@ struct mailsession_driver { | |||
502 | 502 | ||
503 | int (* sess_subscribe_folder)(mailsession * session, char * mb); | 503 | int (* sess_subscribe_folder)(mailsession * session, char * mb); |
504 | int (* sess_unsubscribe_folder)(mailsession * session, char * mb); | 504 | int (* sess_unsubscribe_folder)(mailsession * session, char * mb); |
505 | 505 | ||
506 | /* messages operations */ | 506 | /* messages operations */ |
507 | 507 | ||
508 | int (* sess_append_message)(mailsession * session, | 508 | int (* sess_append_message)(mailsession * session, |
509 | char * message, size_t size); | 509 | char * message, size_t size); |
510 | int (* sess_append_message_flags)(mailsession * session, | ||
511 | char * message, size_t size, struct mail_flags * flags); | ||
510 | int (* sess_copy_message)(mailsession * session, | 512 | int (* sess_copy_message)(mailsession * session, |
511 | uint32_t num, char * mb); | 513 | uint32_t num, char * mb); |
512 | int (* sess_move_message)(mailsession * session, | 514 | int (* sess_move_message)(mailsession * session, |
513 | uint32_t num, char * mb); | 515 | uint32_t num, char * mb); |
514 | 516 | ||
515 | int (* sess_get_message)(mailsession * session, | 517 | int (* sess_get_message)(mailsession * session, |
516 | uint32_t num, mailmessage ** result); | 518 | uint32_t num, mailmessage ** result); |
517 | 519 | ||
diff --git a/kmicromail/libetpan/generic/mailfolder.c b/kmicromail/libetpan/generic/mailfolder.c index 2ddc37d..89ba891 100644 --- a/kmicromail/libetpan/generic/mailfolder.c +++ b/kmicromail/libetpan/generic/mailfolder.c | |||
@@ -27,16 +27,23 @@ int mailfolder_status(struct mailfolder * folder, | |||
27 | } | 27 | } |
28 | 28 | ||
29 | int mailfolder_append_message(struct mailfolder * folder, | 29 | int mailfolder_append_message(struct mailfolder * folder, |
30 | char * message, size_t size) | 30 | char * message, size_t size) |
31 | { | 31 | { |
32 | return mailsession_append_message(folder->fld_session, message, size); | 32 | return mailsession_append_message(folder->fld_session, message, size); |
33 | } | 33 | } |
34 | 34 | ||
35 | int mailfolder_append_message_flags(struct mailfolder * folder, | ||
36 | char * message, size_t size, struct mail_flags * flags) | ||
37 | { | ||
38 | return mailsession_append_message_flags(folder->fld_session, message, | ||
39 | size, flags); | ||
40 | } | ||
41 | |||
35 | int mailfolder_get_messages_list(struct mailfolder * folder, | 42 | int mailfolder_get_messages_list(struct mailfolder * folder, |
36 | struct mailmessage_list ** result) | 43 | struct mailmessage_list ** result) |
37 | { | 44 | { |
38 | int r; | 45 | int r; |
39 | struct mailmessage_list * msg_list; | 46 | struct mailmessage_list * msg_list; |
40 | unsigned int i; | 47 | unsigned int i; |
41 | 48 | ||
42 | r = mailsession_get_messages_list(folder->fld_session, &msg_list); | 49 | r = mailsession_get_messages_list(folder->fld_session, &msg_list); |
diff --git a/kmicromail/libetpan/generic/mailfolder.h b/kmicromail/libetpan/generic/mailfolder.h index 3ecad23..ff53470 100644 --- a/kmicromail/libetpan/generic/mailfolder.h +++ b/kmicromail/libetpan/generic/mailfolder.h | |||
@@ -12,16 +12,19 @@ int mailfolder_expunge(struct mailfolder * folder); | |||
12 | 12 | ||
13 | int mailfolder_status(struct mailfolder * folder, | 13 | int mailfolder_status(struct mailfolder * folder, |
14 | uint32_t * result_messages, uint32_t * result_recent, | 14 | uint32_t * result_messages, uint32_t * result_recent, |
15 | uint32_t * result_unseen); | 15 | uint32_t * result_unseen); |
16 | 16 | ||
17 | int mailfolder_append_message(struct mailfolder * folder, | 17 | int mailfolder_append_message(struct mailfolder * folder, |
18 | char * message, size_t size); | 18 | char * message, size_t size); |
19 | 19 | ||
20 | int mailfolder_append_message_flags(struct mailfolder * folder, | ||
21 | char * message, size_t size, struct mail_flags * flags); | ||
22 | |||
20 | int mailfolder_get_messages_list(struct mailfolder * folder, | 23 | int mailfolder_get_messages_list(struct mailfolder * folder, |
21 | struct mailmessage_list ** result); | 24 | struct mailmessage_list ** result); |
22 | 25 | ||
23 | int mailfolder_get_envelopes_list(struct mailfolder * folder, | 26 | int mailfolder_get_envelopes_list(struct mailfolder * folder, |
24 | struct mailmessage_list * result); | 27 | struct mailmessage_list * result); |
25 | 28 | ||
26 | int mailfolder_get_message(struct mailfolder * folder, | 29 | int mailfolder_get_message(struct mailfolder * folder, |
27 | uint32_t num, mailmessage ** result); | 30 | uint32_t num, mailmessage ** result); |
diff --git a/kmicromail/libetpan/generic/mailstorage.c b/kmicromail/libetpan/generic/mailstorage.c index 25e561e..dc91744 100644 --- a/kmicromail/libetpan/generic/mailstorage.c +++ b/kmicromail/libetpan/generic/mailstorage.c | |||
@@ -318,16 +318,23 @@ void mailstorage_disconnect(struct mailstorage * storage) | |||
318 | return; | 318 | return; |
319 | 319 | ||
320 | r = mailsession_logout(storage->sto_session); | 320 | r = mailsession_logout(storage->sto_session); |
321 | 321 | ||
322 | mailsession_free(storage->sto_session); | 322 | mailsession_free(storage->sto_session); |
323 | storage->sto_session = NULL; | 323 | storage->sto_session = NULL; |
324 | } | 324 | } |
325 | 325 | ||
326 | |||
327 | int mailstorage_noop(struct mailstorage * storage) | ||
328 | { | ||
329 | return mailsession_noop(storage->sto_session); | ||
330 | } | ||
331 | |||
332 | |||
326 | static int mailstorage_get_folder(struct mailstorage * storage, | 333 | static int mailstorage_get_folder(struct mailstorage * storage, |
327 | char * pathname, mailsession ** result) | 334 | char * pathname, mailsession ** result) |
328 | { | 335 | { |
329 | if (storage->sto_driver->sto_get_folder_session == NULL) | 336 | if (storage->sto_driver->sto_get_folder_session == NULL) |
330 | return MAIL_ERROR_NOT_IMPLEMENTED; | 337 | return MAIL_ERROR_NOT_IMPLEMENTED; |
331 | 338 | ||
332 | return storage->sto_driver->sto_get_folder_session(storage, | 339 | return storage->sto_driver->sto_get_folder_session(storage, |
333 | pathname, result); | 340 | pathname, result); |
diff --git a/kmicromail/libetpan/generic/mailstorage.h b/kmicromail/libetpan/generic/mailstorage.h index d56aef1..4c57883 100644 --- a/kmicromail/libetpan/generic/mailstorage.h +++ b/kmicromail/libetpan/generic/mailstorage.h | |||
@@ -66,16 +66,18 @@ void mailstorage_free(struct mailstorage * storage); | |||
66 | /* | 66 | /* |
67 | session will be initialized on success. | 67 | session will be initialized on success. |
68 | */ | 68 | */ |
69 | 69 | ||
70 | int mailstorage_connect(struct mailstorage * storage); | 70 | int mailstorage_connect(struct mailstorage * storage); |
71 | 71 | ||
72 | void mailstorage_disconnect(struct mailstorage * storage); | 72 | void mailstorage_disconnect(struct mailstorage * storage); |
73 | 73 | ||
74 | int mailstorage_noop(struct mailstorage * storage); | ||
75 | |||
74 | 76 | ||
75 | /* folder */ | 77 | /* folder */ |
76 | 78 | ||
77 | struct mailfolder * mailfolder_new(struct mailstorage * fld_storage, | 79 | struct mailfolder * mailfolder_new(struct mailstorage * fld_storage, |
78 | char * fld_pathname, char * fld_virtual_name); | 80 | char * fld_pathname, char * fld_virtual_name); |
79 | 81 | ||
80 | void mailfolder_free(struct mailfolder * folder); | 82 | void mailfolder_free(struct mailfolder * folder); |
81 | 83 | ||
@@ -83,16 +85,15 @@ int mailfolder_add_child(struct mailfolder * parent, | |||
83 | struct mailfolder * child); | 85 | struct mailfolder * child); |
84 | 86 | ||
85 | int mailfolder_detach_parent(struct mailfolder * folder); | 87 | int mailfolder_detach_parent(struct mailfolder * folder); |
86 | 88 | ||
87 | int mailfolder_connect(struct mailfolder * folder); | 89 | int mailfolder_connect(struct mailfolder * folder); |
88 | 90 | ||
89 | void mailfolder_disconnect(struct mailfolder * folder); | 91 | void mailfolder_disconnect(struct mailfolder * folder); |
90 | 92 | ||
91 | |||
92 | #ifdef __cplusplus | 93 | #ifdef __cplusplus |
93 | } | 94 | } |
94 | #endif | 95 | #endif |
95 | 96 | ||
96 | #endif | 97 | #endif |
97 | 98 | ||
98 | 99 | ||
diff --git a/kmicromail/libetpan/generic/mboxdriver.c b/kmicromail/libetpan/generic/mboxdriver.c index fa3e2ea..c19a668 100644 --- a/kmicromail/libetpan/generic/mboxdriver.c +++ b/kmicromail/libetpan/generic/mboxdriver.c | |||
@@ -72,16 +72,19 @@ static int mboxdriver_status_folder(mailsession * session, char * mb, | |||
72 | uint32_t * result_unseen); | 72 | uint32_t * result_unseen); |
73 | 73 | ||
74 | static int mboxdriver_messages_number(mailsession * session, char * mb, | 74 | static int mboxdriver_messages_number(mailsession * session, char * mb, |
75 | uint32_t * result); | 75 | uint32_t * result); |
76 | 76 | ||
77 | static int mboxdriver_append_message(mailsession * session, | 77 | static int mboxdriver_append_message(mailsession * session, |
78 | char * message, size_t size); | 78 | char * message, size_t size); |
79 | 79 | ||
80 | static int mboxdriver_append_message_flags(mailsession * session, | ||
81 | char * message, size_t size, struct mail_flags * flags); | ||
82 | |||
80 | static int mboxdriver_get_messages_list(mailsession * session, | 83 | static int mboxdriver_get_messages_list(mailsession * session, |
81 | struct mailmessage_list ** result); | 84 | struct mailmessage_list ** result); |
82 | 85 | ||
83 | static int | 86 | static int |
84 | mboxdriver_get_envelopes_list(mailsession * session, | 87 | mboxdriver_get_envelopes_list(mailsession * session, |
85 | struct mailmessage_list * env_list); | 88 | struct mailmessage_list * env_list); |
86 | 89 | ||
87 | static int mboxdriver_remove_message(mailsession * session, uint32_t num); | 90 | static int mboxdriver_remove_message(mailsession * session, uint32_t num); |
@@ -121,16 +124,17 @@ static mailsession_driver local_mbox_session_driver = { | |||
121 | .sess_recent_number = mboxdriver_messages_number, | 124 | .sess_recent_number = mboxdriver_messages_number, |
122 | .sess_unseen_number = mboxdriver_messages_number, | 125 | .sess_unseen_number = mboxdriver_messages_number, |
123 | .sess_list_folders = NULL, | 126 | .sess_list_folders = NULL, |
124 | .sess_lsub_folders = NULL, | 127 | .sess_lsub_folders = NULL, |
125 | .sess_subscribe_folder = NULL, | 128 | .sess_subscribe_folder = NULL, |
126 | .sess_unsubscribe_folder = NULL, | 129 | .sess_unsubscribe_folder = NULL, |
127 | 130 | ||
128 | .sess_append_message = mboxdriver_append_message, | 131 | .sess_append_message = mboxdriver_append_message, |
132 | .sess_append_message_flags = mboxdriver_append_message_flags, | ||
129 | .sess_copy_message = NULL, | 133 | .sess_copy_message = NULL, |
130 | .sess_move_message = NULL, | 134 | .sess_move_message = NULL, |
131 | 135 | ||
132 | .sess_get_messages_list = mboxdriver_get_messages_list, | 136 | .sess_get_messages_list = mboxdriver_get_messages_list, |
133 | .sess_get_envelopes_list = mboxdriver_get_envelopes_list, | 137 | .sess_get_envelopes_list = mboxdriver_get_envelopes_list, |
134 | .sess_remove_message = mboxdriver_remove_message, | 138 | .sess_remove_message = mboxdriver_remove_message, |
135 | #if 0 | 139 | #if 0 |
136 | .sess_search_messages = maildriver_generic_search_messages, | 140 | .sess_search_messages = maildriver_generic_search_messages, |
@@ -339,16 +343,22 @@ static int mboxdriver_append_message(mailsession * session, | |||
339 | switch (r) { | 343 | switch (r) { |
340 | case MAILMBOX_ERROR_FILE: | 344 | case MAILMBOX_ERROR_FILE: |
341 | return MAIL_ERROR_DISKSPACE; | 345 | return MAIL_ERROR_DISKSPACE; |
342 | default: | 346 | default: |
343 | return mboxdriver_mbox_error_to_mail_error(r); | 347 | return mboxdriver_mbox_error_to_mail_error(r); |
344 | } | 348 | } |
345 | } | 349 | } |
346 | 350 | ||
351 | static int mboxdriver_append_message_flags(mailsession * session, | ||
352 | char * message, size_t size, struct mail_flags * flags) | ||
353 | { | ||
354 | return mboxdriver_append_message(session, message, size); | ||
355 | } | ||
356 | |||
347 | static int mboxdriver_get_messages_list(mailsession * session, | 357 | static int mboxdriver_get_messages_list(mailsession * session, |
348 | struct mailmessage_list ** result) | 358 | struct mailmessage_list ** result) |
349 | { | 359 | { |
350 | struct mailmbox_folder * folder; | 360 | struct mailmbox_folder * folder; |
351 | int res; | 361 | int res; |
352 | 362 | ||
353 | folder = get_mbox_session(session); | 363 | folder = get_mbox_session(session); |
354 | if (folder == NULL) { | 364 | if (folder == NULL) { |
diff --git a/kmicromail/libetpan/generic/mboxdriver_cached.c b/kmicromail/libetpan/generic/mboxdriver_cached.c index 07871fa..3af7fb9 100644 --- a/kmicromail/libetpan/generic/mboxdriver_cached.c +++ b/kmicromail/libetpan/generic/mboxdriver_cached.c | |||
@@ -81,16 +81,19 @@ static int mboxdriver_cached_messages_number(mailsession * session, char * mb, | |||
81 | static int mboxdriver_cached_recent_number(mailsession * session, char * mb, | 81 | static int mboxdriver_cached_recent_number(mailsession * session, char * mb, |
82 | uint32_t * result); | 82 | uint32_t * result); |
83 | static int mboxdriver_cached_unseen_number(mailsession * session, char * mb, | 83 | static int mboxdriver_cached_unseen_number(mailsession * session, char * mb, |
84 | uint32_t * result); | 84 | uint32_t * result); |
85 | 85 | ||
86 | static int mboxdriver_cached_append_message(mailsession * session, | 86 | static int mboxdriver_cached_append_message(mailsession * session, |
87 | char * message, size_t size); | 87 | char * message, size_t size); |
88 | 88 | ||
89 | static int mboxdriver_cached_append_message_flags(mailsession * session, | ||
90 | char * message, size_t size, struct mail_flags * flags); | ||
91 | |||
89 | static int | 92 | static int |
90 | mboxdriver_cached_get_messages_list(mailsession * session, | 93 | mboxdriver_cached_get_messages_list(mailsession * session, |
91 | struct mailmessage_list ** result); | 94 | struct mailmessage_list ** result); |
92 | 95 | ||
93 | static int | 96 | static int |
94 | mboxdriver_cached_get_envelopes_list(mailsession * session, | 97 | mboxdriver_cached_get_envelopes_list(mailsession * session, |
95 | struct mailmessage_list * env_list); | 98 | struct mailmessage_list * env_list); |
96 | 99 | ||
@@ -132,16 +135,18 @@ static mailsession_driver local_mbox_cached_session_driver = { | |||
132 | .sess_recent_number = mboxdriver_cached_recent_number, | 135 | .sess_recent_number = mboxdriver_cached_recent_number, |
133 | .sess_unseen_number = mboxdriver_cached_unseen_number, | 136 | .sess_unseen_number = mboxdriver_cached_unseen_number, |
134 | .sess_list_folders = NULL, | 137 | .sess_list_folders = NULL, |
135 | .sess_lsub_folders = NULL, | 138 | .sess_lsub_folders = NULL, |
136 | .sess_subscribe_folder = NULL, | 139 | .sess_subscribe_folder = NULL, |
137 | .sess_unsubscribe_folder = NULL, | 140 | .sess_unsubscribe_folder = NULL, |
138 | 141 | ||
139 | .sess_append_message = mboxdriver_cached_append_message, | 142 | .sess_append_message = mboxdriver_cached_append_message, |
143 | .sess_append_message_flags = mboxdriver_cached_append_message_flags, | ||
144 | |||
140 | .sess_copy_message = NULL, | 145 | .sess_copy_message = NULL, |
141 | .sess_move_message = NULL, | 146 | .sess_move_message = NULL, |
142 | 147 | ||
143 | .sess_get_messages_list = mboxdriver_cached_get_messages_list, | 148 | .sess_get_messages_list = mboxdriver_cached_get_messages_list, |
144 | .sess_get_envelopes_list = mboxdriver_cached_get_envelopes_list, | 149 | .sess_get_envelopes_list = mboxdriver_cached_get_envelopes_list, |
145 | .sess_remove_message = mboxdriver_cached_remove_message, | 150 | .sess_remove_message = mboxdriver_cached_remove_message, |
146 | #if 0 | 151 | #if 0 |
147 | .sess_search_messages = maildriver_generic_search_messages, | 152 | .sess_search_messages = maildriver_generic_search_messages, |
@@ -901,17 +906,94 @@ static int mboxdriver_cached_unseen_number(mailsession * session, char * mb, | |||
901 | return MAIL_NO_ERROR; | 906 | return MAIL_NO_ERROR; |
902 | } | 907 | } |
903 | 908 | ||
904 | /* messages operations */ | 909 | /* messages operations */ |
905 | 910 | ||
906 | static int mboxdriver_cached_append_message(mailsession * session, | 911 | static int mboxdriver_cached_append_message(mailsession * session, |
907 | char * message, size_t size) | 912 | char * message, size_t size) |
908 | { | 913 | { |
909 | return mailsession_append_message(get_ancestor(session), message, size); | 914 | return mboxdriver_cached_append_message_flags(session, |
915 | message, size, NULL); | ||
916 | } | ||
917 | |||
918 | static int mboxdriver_cached_append_message_flags(mailsession * session, | ||
919 | char * message, size_t size, struct mail_flags * flags) | ||
920 | { | ||
921 | int r; | ||
922 | struct mailmbox_folder * folder; | ||
923 | struct mbox_cached_session_state_data * data; | ||
924 | unsigned int uid; | ||
925 | struct mailmbox_msg_info * msg_info; | ||
926 | chashdatum key; | ||
927 | chashdatum value; | ||
928 | struct mail_cache_db * cache_db_flags; | ||
929 | char filename_flags[PATH_MAX]; | ||
930 | MMAPString * mmapstr; | ||
931 | char keyname[PATH_MAX]; | ||
932 | |||
933 | folder = get_mbox_session(session); | ||
934 | if (folder == NULL) | ||
935 | return MAIL_ERROR_APPEND; | ||
936 | |||
937 | r = mailmbox_append_message_uid(folder, message, size, &uid); | ||
938 | |||
939 | switch (r) { | ||
940 | case MAILMBOX_ERROR_FILE: | ||
941 | return MAIL_ERROR_DISKSPACE; | ||
942 | case MAILMBOX_NO_ERROR: | ||
943 | break; | ||
944 | default: | ||
945 | return mboxdriver_mbox_error_to_mail_error(r); | ||
946 | } | ||
947 | |||
948 | /* could store in flags store instead */ | ||
949 | |||
950 | if (flags == NULL) | ||
951 | goto exit; | ||
952 | |||
953 | key.data = &uid; | ||
954 | key.len = sizeof(uid); | ||
955 | r = chash_get(folder->mb_hash, &key, &value); | ||
956 | if (r < 0) | ||
957 | goto exit; | ||
958 | |||
959 | msg_info = value.data; | ||
960 | |||
961 | data = get_cached_data(session); | ||
962 | |||
963 | snprintf(filename_flags, PATH_MAX, "%s%c%s%c%s", | ||
964 | data->mbox_flags_directory, MAIL_DIR_SEPARATOR, data->mbox_quoted_mb, | ||
965 | MAIL_DIR_SEPARATOR, FLAGS_NAME); | ||
966 | |||
967 | r = mail_cache_db_open_lock(filename_flags, &cache_db_flags); | ||
968 | if (r < 0) | ||
969 | goto exit; | ||
970 | |||
971 | mmapstr = mmap_string_new(""); | ||
972 | if (mmapstr == NULL) | ||
973 | goto close_db_flags; | ||
974 | |||
975 | snprintf(keyname, PATH_MAX, "%u-%lu", uid, | ||
976 | (unsigned long) msg_info->msg_body_len); | ||
977 | |||
978 | r = mboxdriver_write_cached_flags(cache_db_flags, mmapstr, keyname, flags); | ||
979 | |||
980 | mmap_string_free(mmapstr); | ||
981 | mail_cache_db_close_unlock(filename_flags, cache_db_flags); | ||
982 | |||
983 | if (r != MAIL_NO_ERROR) | ||
984 | goto exit; | ||
985 | |||
986 | return MAIL_NO_ERROR; | ||
987 | |||
988 | close_db_flags: | ||
989 | mail_cache_db_close_unlock(filename_flags, cache_db_flags); | ||
990 | exit: | ||
991 | return MAIL_NO_ERROR; | ||
910 | } | 992 | } |
911 | 993 | ||
912 | static int | 994 | static int |
913 | mboxdriver_cached_get_messages_list(mailsession * session, | 995 | mboxdriver_cached_get_messages_list(mailsession * session, |
914 | struct mailmessage_list ** result) | 996 | struct mailmessage_list ** result) |
915 | { | 997 | { |
916 | struct mailmbox_folder * folder; | 998 | struct mailmbox_folder * folder; |
917 | int res; | 999 | int res; |
@@ -955,17 +1037,18 @@ get_cached_envelope(struct mail_cache_db * cache_db, MMAPString * mmapstr, | |||
955 | r = chash_get(folder->mb_hash, &key, &data); | 1037 | r = chash_get(folder->mb_hash, &key, &data); |
956 | if (r < 0) { | 1038 | if (r < 0) { |
957 | res = MAIL_ERROR_MSG_NOT_FOUND; | 1039 | res = MAIL_ERROR_MSG_NOT_FOUND; |
958 | goto err; | 1040 | goto err; |
959 | } | 1041 | } |
960 | 1042 | ||
961 | info = data.data; | 1043 | info = data.data; |
962 | 1044 | ||
963 | snprintf(keyname, PATH_MAX, "%u-%u-envelope", num, info->msg_body_len); | 1045 | snprintf(keyname, PATH_MAX, "%u-%lu-envelope", num, |
1046 | (unsigned long) info->msg_body_len); | ||
964 | 1047 | ||
965 | r = generic_cache_fields_read(cache_db, mmapstr, keyname, &fields); | 1048 | r = generic_cache_fields_read(cache_db, mmapstr, keyname, &fields); |
966 | if (r != MAIL_NO_ERROR) { | 1049 | if (r != MAIL_NO_ERROR) { |
967 | res = r; | 1050 | res = r; |
968 | goto err; | 1051 | goto err; |
969 | } | 1052 | } |
970 | 1053 | ||
971 | * result = fields; | 1054 | * result = fields; |
@@ -1001,17 +1084,18 @@ write_cached_envelope(struct mail_cache_db * cache_db, MMAPString * mmapstr, | |||
1001 | r = chash_get(folder->mb_hash, &key, &data); | 1084 | r = chash_get(folder->mb_hash, &key, &data); |
1002 | if (r < 0) { | 1085 | if (r < 0) { |
1003 | res = MAIL_ERROR_MSG_NOT_FOUND; | 1086 | res = MAIL_ERROR_MSG_NOT_FOUND; |
1004 | goto err; | 1087 | goto err; |
1005 | } | 1088 | } |
1006 | 1089 | ||
1007 | info = data.data; | 1090 | info = data.data; |
1008 | 1091 | ||
1009 | snprintf(keyname, PATH_MAX, "%u-%u-envelope", num, info->msg_body_len); | 1092 | snprintf(keyname, PATH_MAX, "%u-%lu-envelope", num, |
1093 | (unsigned long) info->msg_body_len); | ||
1010 | 1094 | ||
1011 | r = generic_cache_fields_write(cache_db, mmapstr, keyname, fields); | 1095 | r = generic_cache_fields_write(cache_db, mmapstr, keyname, fields); |
1012 | if (r != MAIL_NO_ERROR) { | 1096 | if (r != MAIL_NO_ERROR) { |
1013 | res = r; | 1097 | res = r; |
1014 | goto err; | 1098 | goto err; |
1015 | } | 1099 | } |
1016 | 1100 | ||
1017 | return MAIL_NO_ERROR; | 1101 | return MAIL_NO_ERROR; |
diff --git a/kmicromail/libetpan/generic/mboxdriver_cached_message.c b/kmicromail/libetpan/generic/mboxdriver_cached_message.c index 6d92b22..828396b 100644 --- a/kmicromail/libetpan/generic/mboxdriver_cached_message.c +++ b/kmicromail/libetpan/generic/mboxdriver_cached_message.c | |||
@@ -177,17 +177,18 @@ static int mbox_initialize(mailmessage * msg_info) | |||
177 | r = chash_get(folder->mb_hash, &key, &data); | 177 | r = chash_get(folder->mb_hash, &key, &data); |
178 | if (r < 0) { | 178 | if (r < 0) { |
179 | res = MAIL_ERROR_MSG_NOT_FOUND; | 179 | res = MAIL_ERROR_MSG_NOT_FOUND; |
180 | goto err; | 180 | goto err; |
181 | } | 181 | } |
182 | 182 | ||
183 | info = (struct mailmbox_msg_info *) data.data; | 183 | info = (struct mailmbox_msg_info *) data.data; |
184 | 184 | ||
185 | snprintf(static_uid, PATH_MAX, "%u-%u", msg_info->msg_index, info->msg_body_len); | 185 | snprintf(static_uid, PATH_MAX, "%u-%lu", |
186 | msg_info->msg_index, (unsigned long) info->msg_body_len); | ||
186 | uid = strdup(static_uid); | 187 | uid = strdup(static_uid); |
187 | if (uid == NULL) { | 188 | if (uid == NULL) { |
188 | res = MAIL_ERROR_MEMORY; | 189 | res = MAIL_ERROR_MEMORY; |
189 | goto err; | 190 | goto err; |
190 | } | 191 | } |
191 | 192 | ||
192 | r = mailmessage_generic_initialize(msg_info); | 193 | r = mailmessage_generic_initialize(msg_info); |
193 | if (r != MAIL_NO_ERROR) { | 194 | if (r != MAIL_NO_ERROR) { |
diff --git a/kmicromail/libetpan/generic/mboxdriver_message.c b/kmicromail/libetpan/generic/mboxdriver_message.c index da9a65d..6922625 100644 --- a/kmicromail/libetpan/generic/mboxdriver_message.c +++ b/kmicromail/libetpan/generic/mboxdriver_message.c | |||
@@ -28,17 +28,17 @@ | |||
28 | * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF | 28 | * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF |
29 | * SUCH DAMAGE. | 29 | * SUCH DAMAGE. |
30 | */ | 30 | */ |
31 | 31 | ||
32 | /* | 32 | /* |
33 | * $Id$ | 33 | * $Id$ |
34 | */ | 34 | */ |
35 | 35 | ||
36 | #include "mhdriver_message.h" | 36 | #include "mboxdriver_message.h" |
37 | 37 | ||
38 | #include "mailmessage_tools.h" | 38 | #include "mailmessage_tools.h" |
39 | #include "mboxdriver_tools.h" | 39 | #include "mboxdriver_tools.h" |
40 | #include "mboxdriver.h" | 40 | #include "mboxdriver.h" |
41 | #include "mailmbox.h" | 41 | #include "mailmbox.h" |
42 | 42 | ||
43 | #include <unistd.h> | 43 | #include <unistd.h> |
44 | #include <sys/mman.h> | 44 | #include <sys/mman.h> |
@@ -151,18 +151,18 @@ static int mbox_initialize(mailmessage * msg_info) | |||
151 | r = chash_get(folder->mb_hash, &key, &data); | 151 | r = chash_get(folder->mb_hash, &key, &data); |
152 | if (r < 0) { | 152 | if (r < 0) { |
153 | res = MAIL_ERROR_MSG_NOT_FOUND; | 153 | res = MAIL_ERROR_MSG_NOT_FOUND; |
154 | goto err; | 154 | goto err; |
155 | } | 155 | } |
156 | 156 | ||
157 | info = data.data; | 157 | info = data.data; |
158 | 158 | ||
159 | snprintf(static_uid, PATH_MAX, "%u-%u", | 159 | snprintf(static_uid, PATH_MAX, "%u-%lu", |
160 | msg_info->msg_index, info->msg_body_len); | 160 | msg_info->msg_index, (unsigned long) info->msg_body_len); |
161 | uid = strdup(static_uid); | 161 | uid = strdup(static_uid); |
162 | if (uid == NULL) { | 162 | if (uid == NULL) { |
163 | res = MAIL_ERROR_MEMORY; | 163 | res = MAIL_ERROR_MEMORY; |
164 | goto err; | 164 | goto err; |
165 | } | 165 | } |
166 | 166 | ||
167 | r = mailmessage_generic_initialize(msg_info); | 167 | r = mailmessage_generic_initialize(msg_info); |
168 | if (r != MAIL_NO_ERROR) { | 168 | if (r != MAIL_NO_ERROR) { |
diff --git a/kmicromail/libetpan/generic/mboxdriver_tools.c b/kmicromail/libetpan/generic/mboxdriver_tools.c index 1e27798..252a20b 100644 --- a/kmicromail/libetpan/generic/mboxdriver_tools.c +++ b/kmicromail/libetpan/generic/mboxdriver_tools.c | |||
@@ -212,17 +212,18 @@ mboxdriver_get_cached_flags(struct mail_cache_db * cache_db, | |||
212 | r = chash_get(folder->mb_hash, &key, &data); | 212 | r = chash_get(folder->mb_hash, &key, &data); |
213 | if (r < 0) { | 213 | if (r < 0) { |
214 | res = MAIL_ERROR_MSG_NOT_FOUND; | 214 | res = MAIL_ERROR_MSG_NOT_FOUND; |
215 | goto err; | 215 | goto err; |
216 | } | 216 | } |
217 | 217 | ||
218 | info = data.data; | 218 | info = data.data; |
219 | 219 | ||
220 | snprintf(keyname, PATH_MAX, "%u-%u-flags", num, info->msg_body_len); | 220 | snprintf(keyname, PATH_MAX, "%u-%lu-flags", num, |
221 | (unsigned long) info->msg_body_len); | ||
221 | 222 | ||
222 | r = generic_cache_flags_read(cache_db, mmapstr, keyname, &flags); | 223 | r = generic_cache_flags_read(cache_db, mmapstr, keyname, &flags); |
223 | if (r != MAIL_NO_ERROR) { | 224 | if (r != MAIL_NO_ERROR) { |
224 | res = r; | 225 | res = r; |
225 | goto err; | 226 | goto err; |
226 | } | 227 | } |
227 | 228 | ||
228 | * result = flags; | 229 | * result = flags; |
diff --git a/kmicromail/libetpan/generic/mboxstorage.c b/kmicromail/libetpan/generic/mboxstorage.c index 0a7dc93..4b55b2b 100644 --- a/kmicromail/libetpan/generic/mboxstorage.c +++ b/kmicromail/libetpan/generic/mboxstorage.c | |||
@@ -60,17 +60,17 @@ static mailstorage_driver mbox_mailstorage_driver = { | |||
60 | }; | 60 | }; |
61 | 61 | ||
62 | int mbox_mailstorage_init(struct mailstorage * storage, | 62 | int mbox_mailstorage_init(struct mailstorage * storage, |
63 | char * mbox_pathname, int mbox_cached, | 63 | char * mbox_pathname, int mbox_cached, |
64 | char * mbox_cache_directory, char * mbox_flags_directory) | 64 | char * mbox_cache_directory, char * mbox_flags_directory) |
65 | { | 65 | { |
66 | struct mbox_mailstorage * mbox_storage; | 66 | struct mbox_mailstorage * mbox_storage; |
67 | 67 | ||
68 | mbox_storage = malloc(sizeof(struct mbox_mailstorage)); | 68 | mbox_storage = malloc(sizeof(* mbox_storage)); |
69 | if (mbox_storage == NULL) | 69 | if (mbox_storage == NULL) |
70 | goto err; | 70 | goto err; |
71 | 71 | ||
72 | mbox_storage->mbox_pathname = strdup(mbox_pathname); | 72 | mbox_storage->mbox_pathname = strdup(mbox_pathname); |
73 | if (mbox_storage->mbox_pathname == NULL) | 73 | if (mbox_storage->mbox_pathname == NULL) |
74 | goto free; | 74 | goto free; |
75 | 75 | ||
76 | mbox_storage->mbox_cached = mbox_cached; | 76 | mbox_storage->mbox_cached = mbox_cached; |
diff --git a/kmicromail/libetpan/generic/mhdriver.c b/kmicromail/libetpan/generic/mhdriver.c index af38d27..05a6a4f 100644 --- a/kmicromail/libetpan/generic/mhdriver.c +++ b/kmicromail/libetpan/generic/mhdriver.c | |||
@@ -84,16 +84,18 @@ static int mhdriver_lsub_folders(mailsession * session, char * mb, | |||
84 | struct mail_list ** result); | 84 | struct mail_list ** result); |
85 | 85 | ||
86 | static int mhdriver_subscribe_folder(mailsession * session, char * mb); | 86 | static int mhdriver_subscribe_folder(mailsession * session, char * mb); |
87 | 87 | ||
88 | static int mhdriver_unsubscribe_folder(mailsession * session, char * mb); | 88 | static int mhdriver_unsubscribe_folder(mailsession * session, char * mb); |
89 | 89 | ||
90 | static int mhdriver_append_message(mailsession * session, | 90 | static int mhdriver_append_message(mailsession * session, |
91 | char * message, size_t size); | 91 | char * message, size_t size); |
92 | static int mhdriver_append_message_flags(mailsession * session, | ||
93 | char * message, size_t size, struct mail_flags * flags); | ||
92 | static int mhdriver_copy_message(mailsession * session, | 94 | static int mhdriver_copy_message(mailsession * session, |
93 | uint32_t num, char * mb); | 95 | uint32_t num, char * mb); |
94 | 96 | ||
95 | static int mhdriver_remove_message(mailsession * session, uint32_t num); | 97 | static int mhdriver_remove_message(mailsession * session, uint32_t num); |
96 | 98 | ||
97 | static int mhdriver_move_message(mailsession * session, | 99 | static int mhdriver_move_message(mailsession * session, |
98 | uint32_t num, char * mb); | 100 | uint32_t num, char * mb); |
99 | 101 | ||
@@ -134,17 +136,18 @@ static mailsession_driver local_mh_session_driver = { | |||
134 | .sess_messages_number = mhdriver_messages_number, | 136 | .sess_messages_number = mhdriver_messages_number, |
135 | .sess_recent_number = mhdriver_messages_number, | 137 | .sess_recent_number = mhdriver_messages_number, |
136 | .sess_unseen_number = mhdriver_messages_number, | 138 | .sess_unseen_number = mhdriver_messages_number, |
137 | .sess_list_folders = mhdriver_list_folders, | 139 | .sess_list_folders = mhdriver_list_folders, |
138 | .sess_lsub_folders = mhdriver_lsub_folders, | 140 | .sess_lsub_folders = mhdriver_lsub_folders, |
139 | .sess_subscribe_folder = mhdriver_subscribe_folder, | 141 | .sess_subscribe_folder = mhdriver_subscribe_folder, |
140 | .sess_unsubscribe_folder = mhdriver_unsubscribe_folder, | 142 | .sess_unsubscribe_folder = mhdriver_unsubscribe_folder, |
141 | 143 | ||
142 | .sess_append_message = mhdriver_append_message, | 144 | .sess_append_message = mhdriver_append_message, |
145 | .sess_append_message_flags = mhdriver_append_message_flags, | ||
143 | .sess_copy_message = mhdriver_copy_message, | 146 | .sess_copy_message = mhdriver_copy_message, |
144 | .sess_move_message = mhdriver_move_message, | 147 | .sess_move_message = mhdriver_move_message, |
145 | 148 | ||
146 | .sess_get_messages_list = mhdriver_get_messages_list, | 149 | .sess_get_messages_list = mhdriver_get_messages_list, |
147 | .sess_get_envelopes_list = maildriver_generic_get_envelopes_list, | 150 | .sess_get_envelopes_list = maildriver_generic_get_envelopes_list, |
148 | .sess_remove_message = mhdriver_remove_message, | 151 | .sess_remove_message = mhdriver_remove_message, |
149 | #if 0 | 152 | #if 0 |
150 | .sess_search_messages = maildriver_generic_search_messages, | 153 | .sess_search_messages = maildriver_generic_search_messages, |
@@ -679,16 +682,22 @@ static int mhdriver_append_message(mailsession * session, | |||
679 | case MAILMH_ERROR_FILE: | 682 | case MAILMH_ERROR_FILE: |
680 | return MAIL_ERROR_DISKSPACE; | 683 | return MAIL_ERROR_DISKSPACE; |
681 | 684 | ||
682 | default: | 685 | default: |
683 | return mhdriver_mh_error_to_mail_error(r); | 686 | return mhdriver_mh_error_to_mail_error(r); |
684 | } | 687 | } |
685 | } | 688 | } |
686 | 689 | ||
690 | static int mhdriver_append_message_flags(mailsession * session, | ||
691 | char * message, size_t size, struct mail_flags * flags) | ||
692 | { | ||
693 | return mhdriver_append_message(session, message, size); | ||
694 | } | ||
695 | |||
687 | static int mhdriver_copy_message(mailsession * session, | 696 | static int mhdriver_copy_message(mailsession * session, |
688 | uint32_t num, char * mb) | 697 | uint32_t num, char * mb) |
689 | { | 698 | { |
690 | int fd; | 699 | int fd; |
691 | int r; | 700 | int r; |
692 | struct mailmh_folder * folder; | 701 | struct mailmh_folder * folder; |
693 | struct mailmh * mh; | 702 | struct mailmh * mh; |
694 | int res; | 703 | int res; |
diff --git a/kmicromail/libetpan/generic/mhdriver_cached.c b/kmicromail/libetpan/generic/mhdriver_cached.c index 5c35089..04aa523 100644 --- a/kmicromail/libetpan/generic/mhdriver_cached.c +++ b/kmicromail/libetpan/generic/mhdriver_cached.c | |||
@@ -103,16 +103,18 @@ static int mhdriver_cached_lsub_folders(mailsession * session, char * mb, | |||
103 | 103 | ||
104 | static int mhdriver_cached_subscribe_folder(mailsession * session, char * mb); | 104 | static int mhdriver_cached_subscribe_folder(mailsession * session, char * mb); |
105 | 105 | ||
106 | static int mhdriver_cached_unsubscribe_folder(mailsession * session, | 106 | static int mhdriver_cached_unsubscribe_folder(mailsession * session, |
107 | char * mb); | 107 | char * mb); |
108 | 108 | ||
109 | static int mhdriver_cached_append_message(mailsession * session, | 109 | static int mhdriver_cached_append_message(mailsession * session, |
110 | char * message, size_t size); | 110 | char * message, size_t size); |
111 | static int mhdriver_cached_append_message_flags(mailsession * session, | ||
112 | char * message, size_t size, struct mail_flags * flags); | ||
111 | static int mhdriver_cached_copy_message(mailsession * session, | 113 | static int mhdriver_cached_copy_message(mailsession * session, |
112 | uint32_t num, char * mb); | 114 | uint32_t num, char * mb); |
113 | 115 | ||
114 | static int mhdriver_cached_remove_message(mailsession * session, | 116 | static int mhdriver_cached_remove_message(mailsession * session, |
115 | uint32_t num); | 117 | uint32_t num); |
116 | 118 | ||
117 | static int mhdriver_cached_move_message(mailsession * session, | 119 | static int mhdriver_cached_move_message(mailsession * session, |
118 | uint32_t num, char * mb); | 120 | uint32_t num, char * mb); |
@@ -160,16 +162,17 @@ static mailsession_driver local_mh_cached_session_driver = { | |||
160 | .sess_recent_number = mhdriver_cached_recent_number, | 162 | .sess_recent_number = mhdriver_cached_recent_number, |
161 | .sess_unseen_number = mhdriver_cached_unseen_number, | 163 | .sess_unseen_number = mhdriver_cached_unseen_number, |
162 | .sess_list_folders = mhdriver_cached_list_folders, | 164 | .sess_list_folders = mhdriver_cached_list_folders, |
163 | .sess_lsub_folders = mhdriver_cached_lsub_folders, | 165 | .sess_lsub_folders = mhdriver_cached_lsub_folders, |
164 | .sess_subscribe_folder = mhdriver_cached_subscribe_folder, | 166 | .sess_subscribe_folder = mhdriver_cached_subscribe_folder, |
165 | .sess_unsubscribe_folder = mhdriver_cached_unsubscribe_folder, | 167 | .sess_unsubscribe_folder = mhdriver_cached_unsubscribe_folder, |
166 | 168 | ||
167 | .sess_append_message = mhdriver_cached_append_message, | 169 | .sess_append_message = mhdriver_cached_append_message, |
170 | .sess_append_message_flags = mhdriver_cached_append_message_flags, | ||
168 | .sess_copy_message = mhdriver_cached_copy_message, | 171 | .sess_copy_message = mhdriver_cached_copy_message, |
169 | .sess_move_message = mhdriver_cached_move_message, | 172 | .sess_move_message = mhdriver_cached_move_message, |
170 | 173 | ||
171 | .sess_get_messages_list = mhdriver_cached_get_messages_list, | 174 | .sess_get_messages_list = mhdriver_cached_get_messages_list, |
172 | .sess_get_envelopes_list = mhdriver_cached_get_envelopes_list, | 175 | .sess_get_envelopes_list = mhdriver_cached_get_envelopes_list, |
173 | .sess_remove_message = mhdriver_cached_remove_message, | 176 | .sess_remove_message = mhdriver_cached_remove_message, |
174 | #if 0 | 177 | #if 0 |
175 | .sess_search_messages = maildriver_generic_search_messages, | 178 | .sess_search_messages = maildriver_generic_search_messages, |
@@ -878,17 +881,95 @@ static int mhdriver_cached_unsubscribe_folder(mailsession * session, | |||
878 | return mailsession_unsubscribe_folder(get_ancestor(session), mb); | 881 | return mailsession_unsubscribe_folder(get_ancestor(session), mb); |
879 | } | 882 | } |
880 | 883 | ||
881 | /* messages operations */ | 884 | /* messages operations */ |
882 | 885 | ||
883 | static int mhdriver_cached_append_message(mailsession * session, | 886 | static int mhdriver_cached_append_message(mailsession * session, |
884 | char * message, size_t size) | 887 | char * message, size_t size) |
885 | { | 888 | { |
886 | return mailsession_append_message(get_ancestor(session), message, size); | 889 | return mhdriver_cached_append_message_flags(session, |
890 | message, size, NULL); | ||
891 | } | ||
892 | |||
893 | static int mhdriver_cached_append_message_flags(mailsession * session, | ||
894 | char * message, size_t size, struct mail_flags * flags) | ||
895 | { | ||
896 | int r; | ||
897 | struct mailmh_folder * folder; | ||
898 | struct mailmh_msg_info * msg_info; | ||
899 | chashdatum key; | ||
900 | chashdatum value; | ||
901 | uint32_t uid; | ||
902 | struct mh_cached_session_state_data * data; | ||
903 | char filename_flags[PATH_MAX]; | ||
904 | struct mail_cache_db * cache_db_flags; | ||
905 | MMAPString * mmapstr; | ||
906 | char keyname[PATH_MAX]; | ||
907 | |||
908 | folder = get_mh_cur_folder(session); | ||
909 | if (folder == NULL) | ||
910 | return MAIL_ERROR_BAD_STATE; | ||
911 | |||
912 | r = mailmh_folder_add_message_uid(folder, | ||
913 | message, size, &uid); | ||
914 | |||
915 | switch (r) { | ||
916 | case MAILMH_ERROR_FILE: | ||
917 | return MAIL_ERROR_DISKSPACE; | ||
918 | |||
919 | case MAILMH_NO_ERROR: | ||
920 | break; | ||
921 | |||
922 | default: | ||
923 | return mhdriver_mh_error_to_mail_error(r); | ||
924 | } | ||
925 | |||
926 | if (flags == NULL) | ||
927 | goto exit; | ||
928 | |||
929 | key.data = &uid; | ||
930 | key.len = sizeof(uid); | ||
931 | r = chash_get(folder->fl_msgs_hash, &key, &value); | ||
932 | if (r < 0) | ||
933 | return MAIL_ERROR_CACHE_MISS; | ||
934 | |||
935 | msg_info = value.data; | ||
936 | |||
937 | data = get_cached_data(session); | ||
938 | |||
939 | snprintf(filename_flags, PATH_MAX, "%s/%s/%s", | ||
940 | data->mh_flags_directory, data->mh_quoted_mb, FLAGS_NAME); | ||
941 | |||
942 | r = mail_cache_db_open_lock(filename_flags, &cache_db_flags); | ||
943 | if (r < 0) | ||
944 | goto exit; | ||
945 | |||
946 | mmapstr = mmap_string_new(""); | ||
947 | if (mmapstr == NULL) | ||
948 | goto close_db_flags; | ||
949 | |||
950 | snprintf(keyname, PATH_MAX, "%u-%lu-%lu-flags", | ||
951 | uid, (unsigned long) msg_info->msg_mtime, | ||
952 | (unsigned long) msg_info->msg_size); | ||
953 | |||
954 | r = mhdriver_write_cached_flags(cache_db_flags, mmapstr, keyname, flags); | ||
955 | |||
956 | mmap_string_free(mmapstr); | ||
957 | mail_cache_db_close_unlock(filename_flags, cache_db_flags); | ||
958 | |||
959 | if (r != MAIL_NO_ERROR) | ||
960 | goto exit; | ||
961 | |||
962 | return MAIL_NO_ERROR; | ||
963 | |||
964 | close_db_flags: | ||
965 | mail_cache_db_close_unlock(filename_flags, cache_db_flags); | ||
966 | exit: | ||
967 | return MAIL_NO_ERROR; | ||
887 | } | 968 | } |
888 | 969 | ||
889 | static int mhdriver_cached_copy_message(mailsession * session, | 970 | static int mhdriver_cached_copy_message(mailsession * session, |
890 | uint32_t num, char * mb) | 971 | uint32_t num, char * mb) |
891 | { | 972 | { |
892 | return mailsession_copy_message(get_ancestor(session), num, mb); | 973 | return mailsession_copy_message(get_ancestor(session), num, mb); |
893 | } | 974 | } |
894 | 975 | ||
@@ -948,18 +1029,19 @@ get_cached_envelope(struct mail_cache_db * cache_db, MMAPString * mmapstr, | |||
948 | #endif | 1029 | #endif |
949 | key.data = # | 1030 | key.data = # |
950 | key.len = sizeof(num); | 1031 | key.len = sizeof(num); |
951 | r = chash_get(folder->fl_msgs_hash, &key, &data); | 1032 | r = chash_get(folder->fl_msgs_hash, &key, &data); |
952 | if (r < 0) | 1033 | if (r < 0) |
953 | return MAIL_ERROR_CACHE_MISS; | 1034 | return MAIL_ERROR_CACHE_MISS; |
954 | msg_info = data.data; | 1035 | msg_info = data.data; |
955 | 1036 | ||
956 | snprintf(keyname, PATH_MAX, "%u-%u-%u-envelope", | 1037 | snprintf(keyname, PATH_MAX, "%u-%lu-%lu-envelope", |
957 | num, (uint32_t) msg_info->msg_mtime, msg_info->msg_size); | 1038 | num, (unsigned long) msg_info->msg_mtime, |
1039 | (unsigned long) msg_info->msg_size); | ||
958 | 1040 | ||
959 | r = generic_cache_fields_read(cache_db, mmapstr, keyname, &fields); | 1041 | r = generic_cache_fields_read(cache_db, mmapstr, keyname, &fields); |
960 | if (r != MAIL_NO_ERROR) { | 1042 | if (r != MAIL_NO_ERROR) { |
961 | res = r; | 1043 | res = r; |
962 | goto err; | 1044 | goto err; |
963 | } | 1045 | } |
964 | 1046 | ||
965 | * result = fields; | 1047 | * result = fields; |
@@ -993,18 +1075,19 @@ write_cached_envelope(struct mail_cache_db * cache_db, MMAPString * mmapstr, | |||
993 | #endif | 1075 | #endif |
994 | key.data = # | 1076 | key.data = # |
995 | key.len = sizeof(num); | 1077 | key.len = sizeof(num); |
996 | r = chash_get(folder->fl_msgs_hash, &key, &data); | 1078 | r = chash_get(folder->fl_msgs_hash, &key, &data); |
997 | if (r < 0) | 1079 | if (r < 0) |
998 | return MAIL_ERROR_CACHE_MISS; | 1080 | return MAIL_ERROR_CACHE_MISS; |
999 | msg_info = data.data; | 1081 | msg_info = data.data; |
1000 | 1082 | ||
1001 | snprintf(keyname, PATH_MAX, "%u-%u-%u-envelope", | 1083 | snprintf(keyname, PATH_MAX, "%u-%lu-%lu-envelope", |
1002 | num, (uint32_t) msg_info->msg_mtime, msg_info->msg_size); | 1084 | num, (unsigned long) msg_info->msg_mtime, |
1085 | (unsigned long) msg_info->msg_size); | ||
1003 | 1086 | ||
1004 | r = generic_cache_fields_write(cache_db, mmapstr, keyname, fields); | 1087 | r = generic_cache_fields_write(cache_db, mmapstr, keyname, fields); |
1005 | if (r != MAIL_NO_ERROR) { | 1088 | if (r != MAIL_NO_ERROR) { |
1006 | res = r; | 1089 | res = r; |
1007 | goto err; | 1090 | goto err; |
1008 | } | 1091 | } |
1009 | 1092 | ||
1010 | return MAIL_NO_ERROR; | 1093 | return MAIL_NO_ERROR; |
diff --git a/kmicromail/libetpan/generic/mhdriver_cached_message.c b/kmicromail/libetpan/generic/mhdriver_cached_message.c index f716fb9..f69868d 100644 --- a/kmicromail/libetpan/generic/mhdriver_cached_message.c +++ b/kmicromail/libetpan/generic/mhdriver_cached_message.c | |||
@@ -174,18 +174,18 @@ static int mh_initialize(mailmessage * msg_info) | |||
174 | key.data = &msg_info->msg_index; | 174 | key.data = &msg_info->msg_index; |
175 | key.len = sizeof(msg_info->msg_index); | 175 | key.len = sizeof(msg_info->msg_index); |
176 | r = chash_get(folder->fl_msgs_hash, &key, &data); | 176 | r = chash_get(folder->fl_msgs_hash, &key, &data); |
177 | if (r < 0) | 177 | if (r < 0) |
178 | return MAIL_ERROR_INVAL; | 178 | return MAIL_ERROR_INVAL; |
179 | 179 | ||
180 | mh_msg_info = data.data; | 180 | mh_msg_info = data.data; |
181 | 181 | ||
182 | snprintf(static_uid, PATH_MAX, "%u-%lu-%u", msg_info->msg_index, | 182 | snprintf(static_uid, PATH_MAX, "%u-%lu-%lu", msg_info->msg_index, |
183 | mh_msg_info->msg_mtime, mh_msg_info->msg_size); | 183 | mh_msg_info->msg_mtime, (unsigned long) mh_msg_info->msg_size); |
184 | uid = strdup(static_uid); | 184 | uid = strdup(static_uid); |
185 | if (uid == NULL) | 185 | if (uid == NULL) |
186 | return MAIL_ERROR_MEMORY; | 186 | return MAIL_ERROR_MEMORY; |
187 | 187 | ||
188 | r = mailmessage_generic_initialize(msg_info); | 188 | r = mailmessage_generic_initialize(msg_info); |
189 | if (r != MAIL_NO_ERROR) { | 189 | if (r != MAIL_NO_ERROR) { |
190 | free(uid); | 190 | free(uid); |
191 | return r; | 191 | return r; |
diff --git a/kmicromail/libetpan/generic/mhdriver_message.c b/kmicromail/libetpan/generic/mhdriver_message.c index 2c023e7..aafd2d9 100644 --- a/kmicromail/libetpan/generic/mhdriver_message.c +++ b/kmicromail/libetpan/generic/mhdriver_message.c | |||
@@ -139,18 +139,19 @@ static int mh_initialize(mailmessage * msg_info) | |||
139 | key.data = &msg_info->msg_index; | 139 | key.data = &msg_info->msg_index; |
140 | key.len = sizeof(msg_info->msg_index); | 140 | key.len = sizeof(msg_info->msg_index); |
141 | r = chash_get(get_mh_cur_folder(msg_info)->fl_msgs_hash, &key, &value); | 141 | r = chash_get(get_mh_cur_folder(msg_info)->fl_msgs_hash, &key, &value); |
142 | if (r < 0) | 142 | if (r < 0) |
143 | return MAIL_ERROR_INVAL; | 143 | return MAIL_ERROR_INVAL; |
144 | 144 | ||
145 | mh_msg_info = value.data; | 145 | mh_msg_info = value.data; |
146 | 146 | ||
147 | snprintf(static_uid, PATH_MAX, "%u-%lu-%u", msg_info->msg_index, | 147 | snprintf(static_uid, PATH_MAX, "%u-%lu-%lu", msg_info->msg_index, |
148 | mh_msg_info->msg_mtime, mh_msg_info->msg_size); | 148 | (unsigned long) mh_msg_info->msg_mtime, |
149 | (unsigned long) mh_msg_info->msg_size); | ||
149 | uid = strdup(static_uid); | 150 | uid = strdup(static_uid); |
150 | if (uid == NULL) | 151 | if (uid == NULL) |
151 | return MAIL_ERROR_MEMORY; | 152 | return MAIL_ERROR_MEMORY; |
152 | 153 | ||
153 | r = mailmessage_generic_initialize(msg_info); | 154 | r = mailmessage_generic_initialize(msg_info); |
154 | if (r != MAIL_NO_ERROR) { | 155 | if (r != MAIL_NO_ERROR) { |
155 | free(uid); | 156 | free(uid); |
156 | return r; | 157 | return r; |
diff --git a/kmicromail/libetpan/generic/mhdriver_tools.c b/kmicromail/libetpan/generic/mhdriver_tools.c index cb863fa..c15bb6d 100644 --- a/kmicromail/libetpan/generic/mhdriver_tools.c +++ b/kmicromail/libetpan/generic/mhdriver_tools.c | |||
@@ -364,18 +364,19 @@ mhdriver_get_cached_flags(struct mail_cache_db * cache_db, | |||
364 | #endif | 364 | #endif |
365 | key.data = # | 365 | key.data = # |
366 | key.len = sizeof(num); | 366 | key.len = sizeof(num); |
367 | r = chash_get(folder->fl_msgs_hash, &key, &data); | 367 | r = chash_get(folder->fl_msgs_hash, &key, &data); |
368 | if (r < 0) | 368 | if (r < 0) |
369 | return MAIL_ERROR_CACHE_MISS; | 369 | return MAIL_ERROR_CACHE_MISS; |
370 | msg_info = data.data; | 370 | msg_info = data.data; |
371 | 371 | ||
372 | snprintf(keyname, PATH_MAX, "%u-%u-%u-flags", | 372 | snprintf(keyname, PATH_MAX, "%u-%lu-%lu-flags", |
373 | num, (uint32_t) msg_info->msg_mtime, msg_info->msg_size); | 373 | num, (unsigned long) msg_info->msg_mtime, |
374 | (unsigned long) msg_info->msg_size); | ||
374 | 375 | ||
375 | r = generic_cache_flags_read(cache_db, mmapstr, keyname, &flags); | 376 | r = generic_cache_flags_read(cache_db, mmapstr, keyname, &flags); |
376 | if (r != MAIL_NO_ERROR) { | 377 | if (r != MAIL_NO_ERROR) { |
377 | res = r; | 378 | res = r; |
378 | goto err; | 379 | goto err; |
379 | } | 380 | } |
380 | 381 | ||
381 | * result = flags; | 382 | * result = flags; |
diff --git a/kmicromail/libetpan/generic/mhstorage.c b/kmicromail/libetpan/generic/mhstorage.c index 32fc26b..715b961 100644 --- a/kmicromail/libetpan/generic/mhstorage.c +++ b/kmicromail/libetpan/generic/mhstorage.c | |||
@@ -57,17 +57,17 @@ static mailstorage_driver mh_mailstorage_driver = { | |||
57 | }; | 57 | }; |
58 | 58 | ||
59 | int mh_mailstorage_init(struct mailstorage * storage, | 59 | int mh_mailstorage_init(struct mailstorage * storage, |
60 | char * mh_pathname, int mh_cached, | 60 | char * mh_pathname, int mh_cached, |
61 | char * mh_cache_directory, char * mh_flags_directory) | 61 | char * mh_cache_directory, char * mh_flags_directory) |
62 | { | 62 | { |
63 | struct mh_mailstorage * mh_storage; | 63 | struct mh_mailstorage * mh_storage; |
64 | 64 | ||
65 | mh_storage = malloc(sizeof(struct mh_mailstorage)); | 65 | mh_storage = malloc(sizeof(* mh_storage)); |
66 | if (mh_storage == NULL) | 66 | if (mh_storage == NULL) |
67 | goto err; | 67 | goto err; |
68 | 68 | ||
69 | mh_storage->mh_pathname = strdup(mh_pathname); | 69 | mh_storage->mh_pathname = strdup(mh_pathname); |
70 | if (mh_storage->mh_pathname == NULL) | 70 | if (mh_storage->mh_pathname == NULL) |
71 | goto free; | 71 | goto free; |
72 | 72 | ||
73 | mh_storage->mh_cached = mh_cached; | 73 | mh_storage->mh_cached = mh_cached; |
diff --git a/kmicromail/libetpan/generic/nntpdriver.c b/kmicromail/libetpan/generic/nntpdriver.c index fde5f1a..1b65838 100644 --- a/kmicromail/libetpan/generic/nntpdriver.c +++ b/kmicromail/libetpan/generic/nntpdriver.c | |||
@@ -64,16 +64,19 @@ static int nntpdriver_status_folder(mailsession * session, char * mb, | |||
64 | uint32_t * result_unseen); | 64 | uint32_t * result_unseen); |
65 | 65 | ||
66 | static int nntpdriver_messages_number(mailsession * session, char * mb, | 66 | static int nntpdriver_messages_number(mailsession * session, char * mb, |
67 | uint32_t * result); | 67 | uint32_t * result); |
68 | 68 | ||
69 | static int nntpdriver_append_message(mailsession * session, | 69 | static int nntpdriver_append_message(mailsession * session, |
70 | char * message, size_t size); | 70 | char * message, size_t size); |
71 | 71 | ||
72 | static int nntpdriver_append_message_flags(mailsession * session, | ||
73 | char * message, size_t size, struct mail_flags * flags); | ||
74 | |||
72 | static int | 75 | static int |
73 | nntpdriver_get_envelopes_list(mailsession * session, | 76 | nntpdriver_get_envelopes_list(mailsession * session, |
74 | struct mailmessage_list * env_list); | 77 | struct mailmessage_list * env_list); |
75 | 78 | ||
76 | 79 | ||
77 | static int nntpdriver_get_messages_list(mailsession * session, | 80 | static int nntpdriver_get_messages_list(mailsession * session, |
78 | struct mailmessage_list ** result); | 81 | struct mailmessage_list ** result); |
79 | 82 | ||
@@ -124,16 +127,17 @@ static mailsession_driver local_nntp_session_driver = { | |||
124 | .sess_recent_number = nntpdriver_messages_number, | 127 | .sess_recent_number = nntpdriver_messages_number, |
125 | .sess_unseen_number = nntpdriver_messages_number, | 128 | .sess_unseen_number = nntpdriver_messages_number, |
126 | .sess_list_folders = nntpdriver_list_folders, | 129 | .sess_list_folders = nntpdriver_list_folders, |
127 | .sess_lsub_folders = nntpdriver_lsub_folders, | 130 | .sess_lsub_folders = nntpdriver_lsub_folders, |
128 | .sess_subscribe_folder = nntpdriver_subscribe_folder, | 131 | .sess_subscribe_folder = nntpdriver_subscribe_folder, |
129 | .sess_unsubscribe_folder = nntpdriver_unsubscribe_folder, | 132 | .sess_unsubscribe_folder = nntpdriver_unsubscribe_folder, |
130 | 133 | ||
131 | .sess_append_message = nntpdriver_append_message, | 134 | .sess_append_message = nntpdriver_append_message, |
135 | .sess_append_message_flags = nntpdriver_append_message_flags, | ||
132 | .sess_copy_message = NULL, | 136 | .sess_copy_message = NULL, |
133 | .sess_move_message = NULL, | 137 | .sess_move_message = NULL, |
134 | 138 | ||
135 | .sess_get_messages_list = nntpdriver_get_messages_list, | 139 | .sess_get_messages_list = nntpdriver_get_messages_list, |
136 | .sess_get_envelopes_list = nntpdriver_get_envelopes_list, | 140 | .sess_get_envelopes_list = nntpdriver_get_envelopes_list, |
137 | .sess_remove_message = NULL, | 141 | .sess_remove_message = NULL, |
138 | #if 0 | 142 | #if 0 |
139 | .sess_search_messages = maildriver_generic_search_messages, | 143 | .sess_search_messages = maildriver_generic_search_messages, |
@@ -625,16 +629,22 @@ static int nntpdriver_append_message(mailsession * session, | |||
625 | 629 | ||
626 | default: | 630 | default: |
627 | return nntpdriver_nntp_error_to_mail_error(r); | 631 | return nntpdriver_nntp_error_to_mail_error(r); |
628 | } | 632 | } |
629 | } | 633 | } |
630 | while (1); | 634 | while (1); |
631 | } | 635 | } |
632 | 636 | ||
637 | static int nntpdriver_append_message_flags(mailsession * session, | ||
638 | char * message, size_t size, struct mail_flags * flags) | ||
639 | { | ||
640 | return nntpdriver_append_message(session, message, size); | ||
641 | } | ||
642 | |||
633 | 643 | ||
634 | static int xover_resp_to_fields(struct newsnntp_xover_resp_item * item, | 644 | static int xover_resp_to_fields(struct newsnntp_xover_resp_item * item, |
635 | struct mailimf_fields ** result); | 645 | struct mailimf_fields ** result); |
636 | 646 | ||
637 | 647 | ||
638 | static int | 648 | static int |
639 | nntpdriver_get_envelopes_list(mailsession * session, | 649 | nntpdriver_get_envelopes_list(mailsession * session, |
640 | struct mailmessage_list * env_list) | 650 | struct mailmessage_list * env_list) |
diff --git a/kmicromail/libetpan/generic/nntpdriver_cached.c b/kmicromail/libetpan/generic/nntpdriver_cached.c index 1f8a8af..0343a65 100644 --- a/kmicromail/libetpan/generic/nntpdriver_cached.c +++ b/kmicromail/libetpan/generic/nntpdriver_cached.c | |||
@@ -91,16 +91,19 @@ static int nntpdriver_cached_recent_number(mailsession * session, char * mb, | |||
91 | uint32_t * result); | 91 | uint32_t * result); |
92 | 92 | ||
93 | static int nntpdriver_cached_unseen_number(mailsession * session, char * mb, | 93 | static int nntpdriver_cached_unseen_number(mailsession * session, char * mb, |
94 | uint32_t * result); | 94 | uint32_t * result); |
95 | 95 | ||
96 | static int nntpdriver_cached_append_message(mailsession * session, | 96 | static int nntpdriver_cached_append_message(mailsession * session, |
97 | char * message, size_t size); | 97 | char * message, size_t size); |
98 | 98 | ||
99 | static int nntpdriver_cached_append_message_flags(mailsession * session, | ||
100 | char * message, size_t size, struct mail_flags * flags); | ||
101 | |||
99 | static int | 102 | static int |
100 | nntpdriver_cached_get_envelopes_list(mailsession * session, | 103 | nntpdriver_cached_get_envelopes_list(mailsession * session, |
101 | struct mailmessage_list * env_list); | 104 | struct mailmessage_list * env_list); |
102 | 105 | ||
103 | 106 | ||
104 | static int | 107 | static int |
105 | nntpdriver_cached_get_messages_list(mailsession * session, | 108 | nntpdriver_cached_get_messages_list(mailsession * session, |
106 | struct mailmessage_list ** result); | 109 | struct mailmessage_list ** result); |
@@ -154,16 +157,17 @@ static mailsession_driver local_nntp_cached_session_driver = { | |||
154 | .sess_recent_number = nntpdriver_cached_recent_number, | 157 | .sess_recent_number = nntpdriver_cached_recent_number, |
155 | .sess_unseen_number = nntpdriver_cached_unseen_number, | 158 | .sess_unseen_number = nntpdriver_cached_unseen_number, |
156 | .sess_list_folders = nntpdriver_cached_list_folders, | 159 | .sess_list_folders = nntpdriver_cached_list_folders, |
157 | .sess_lsub_folders = nntpdriver_cached_lsub_folders, | 160 | .sess_lsub_folders = nntpdriver_cached_lsub_folders, |
158 | .sess_subscribe_folder = nntpdriver_cached_subscribe_folder, | 161 | .sess_subscribe_folder = nntpdriver_cached_subscribe_folder, |
159 | .sess_unsubscribe_folder = nntpdriver_cached_unsubscribe_folder, | 162 | .sess_unsubscribe_folder = nntpdriver_cached_unsubscribe_folder, |
160 | 163 | ||
161 | .sess_append_message = nntpdriver_cached_append_message, | 164 | .sess_append_message = nntpdriver_cached_append_message, |
165 | .sess_append_message_flags = nntpdriver_cached_append_message_flags, | ||
162 | .sess_copy_message = NULL, | 166 | .sess_copy_message = NULL, |
163 | .sess_move_message = NULL, | 167 | .sess_move_message = NULL, |
164 | 168 | ||
165 | .sess_get_messages_list = nntpdriver_cached_get_messages_list, | 169 | .sess_get_messages_list = nntpdriver_cached_get_messages_list, |
166 | .sess_get_envelopes_list = nntpdriver_cached_get_envelopes_list, | 170 | .sess_get_envelopes_list = nntpdriver_cached_get_envelopes_list, |
167 | .sess_remove_message = NULL, | 171 | .sess_remove_message = NULL, |
168 | #if 0 | 172 | #if 0 |
169 | .sess_search_messages = maildriver_generic_search_messages, | 173 | .sess_search_messages = maildriver_generic_search_messages, |
@@ -626,16 +630,22 @@ static int nntpdriver_cached_unsubscribe_folder(mailsession * session, | |||
626 | /* messages operations */ | 630 | /* messages operations */ |
627 | 631 | ||
628 | static int nntpdriver_cached_append_message(mailsession * session, | 632 | static int nntpdriver_cached_append_message(mailsession * session, |
629 | char * message, size_t size) | 633 | char * message, size_t size) |
630 | { | 634 | { |
631 | return mailsession_append_message(get_ancestor(session), message, size); | 635 | return mailsession_append_message(get_ancestor(session), message, size); |
632 | } | 636 | } |
633 | 637 | ||
638 | static int nntpdriver_cached_append_message_flags(mailsession * session, | ||
639 | char * message, size_t size, struct mail_flags * flags) | ||
640 | { | ||
641 | return nntpdriver_cached_append_message(session, message, size); | ||
642 | } | ||
643 | |||
634 | 644 | ||
635 | 645 | ||
636 | static int | 646 | static int |
637 | get_cached_envelope(struct mail_cache_db * cache_db, MMAPString * mmapstr, | 647 | get_cached_envelope(struct mail_cache_db * cache_db, MMAPString * mmapstr, |
638 | mailsession * session, uint32_t num, | 648 | mailsession * session, uint32_t num, |
639 | struct mailimf_fields ** result) | 649 | struct mailimf_fields ** result) |
640 | { | 650 | { |
641 | char keyname[PATH_MAX]; | 651 | char keyname[PATH_MAX]; |
diff --git a/kmicromail/libetpan/generic/nntpstorage.c b/kmicromail/libetpan/generic/nntpstorage.c index 5ba333b..89974cd 100644 --- a/kmicromail/libetpan/generic/nntpstorage.c +++ b/kmicromail/libetpan/generic/nntpstorage.c | |||
@@ -66,17 +66,17 @@ int nntp_mailstorage_init(struct mailstorage * storage, | |||
66 | char * nn_command, | 66 | char * nn_command, |
67 | int nn_connection_type, int nn_auth_type, | 67 | int nn_connection_type, int nn_auth_type, |
68 | char * nn_login, char * nn_password, | 68 | char * nn_login, char * nn_password, |
69 | int nn_cached, char * nn_cache_directory, char * nn_flags_directory) | 69 | int nn_cached, char * nn_cache_directory, char * nn_flags_directory) |
70 | { | 70 | { |
71 | struct nntp_mailstorage * nntp_storage; | 71 | struct nntp_mailstorage * nntp_storage; |
72 | int res; | 72 | int res; |
73 | 73 | ||
74 | nntp_storage = malloc(sizeof(struct nntp_mailstorage)); | 74 | nntp_storage = malloc(sizeof(* nntp_storage)); |
75 | if (nntp_storage == NULL) { | 75 | if (nntp_storage == NULL) { |
76 | res = MAIL_ERROR_MEMORY; | 76 | res = MAIL_ERROR_MEMORY; |
77 | goto err; | 77 | goto err; |
78 | } | 78 | } |
79 | 79 | ||
80 | nntp_storage->nntp_servername = strdup(nn_servername); | 80 | nntp_storage->nntp_servername = strdup(nn_servername); |
81 | if (nntp_storage->nntp_servername == NULL) { | 81 | if (nntp_storage->nntp_servername == NULL) { |
82 | res = MAIL_ERROR_MEMORY; | 82 | res = MAIL_ERROR_MEMORY; |
diff --git a/kmicromail/libetpan/generic/pop3driver.c b/kmicromail/libetpan/generic/pop3driver.c index 20b0fc2..375879e 100644 --- a/kmicromail/libetpan/generic/pop3driver.c +++ b/kmicromail/libetpan/generic/pop3driver.c | |||
@@ -104,16 +104,17 @@ static mailsession_driver local_pop3_session_driver = { | |||
104 | .sess_recent_number = pop3driver_messages_number, | 104 | .sess_recent_number = pop3driver_messages_number, |
105 | .sess_unseen_number = pop3driver_messages_number, | 105 | .sess_unseen_number = pop3driver_messages_number, |
106 | .sess_list_folders = NULL, | 106 | .sess_list_folders = NULL, |
107 | .sess_lsub_folders = NULL, | 107 | .sess_lsub_folders = NULL, |
108 | .sess_subscribe_folder = NULL, | 108 | .sess_subscribe_folder = NULL, |
109 | .sess_unsubscribe_folder = NULL, | 109 | .sess_unsubscribe_folder = NULL, |
110 | 110 | ||
111 | .sess_append_message = NULL, | 111 | .sess_append_message = NULL, |
112 | .sess_append_message_flags = NULL, | ||
112 | .sess_copy_message = NULL, | 113 | .sess_copy_message = NULL, |
113 | .sess_move_message = NULL, | 114 | .sess_move_message = NULL, |
114 | 115 | ||
115 | .sess_get_messages_list = pop3driver_get_messages_list, | 116 | .sess_get_messages_list = pop3driver_get_messages_list, |
116 | .sess_get_envelopes_list = maildriver_generic_get_envelopes_list, | 117 | .sess_get_envelopes_list = maildriver_generic_get_envelopes_list, |
117 | .sess_remove_message = pop3driver_remove_message, | 118 | .sess_remove_message = pop3driver_remove_message, |
118 | #if 0 | 119 | #if 0 |
119 | .sess_search_messages = maildriver_generic_search_messages, | 120 | .sess_search_messages = maildriver_generic_search_messages, |
diff --git a/kmicromail/libetpan/generic/pop3driver_cached.c b/kmicromail/libetpan/generic/pop3driver_cached.c index 6f97303..24f624b 100644 --- a/kmicromail/libetpan/generic/pop3driver_cached.c +++ b/kmicromail/libetpan/generic/pop3driver_cached.c | |||
@@ -105,16 +105,19 @@ pop3driver_cached_get_messages_list(mailsession * session, | |||
105 | 105 | ||
106 | static int | 106 | static int |
107 | pop3driver_cached_get_envelopes_list(mailsession * session, | 107 | pop3driver_cached_get_envelopes_list(mailsession * session, |
108 | struct mailmessage_list * env_list); | 108 | struct mailmessage_list * env_list); |
109 | 109 | ||
110 | static int pop3driver_cached_get_message(mailsession * session, | 110 | static int pop3driver_cached_get_message(mailsession * session, |
111 | uint32_t num, mailmessage ** result); | 111 | uint32_t num, mailmessage ** result); |
112 | 112 | ||
113 | static int pop3driver_cached_get_message_by_uid(mailsession * session, | ||
114 | const char * uid, mailmessage ** result); | ||
115 | |||
113 | static mailsession_driver local_pop3_cached_session_driver = { | 116 | static mailsession_driver local_pop3_cached_session_driver = { |
114 | .sess_name = "pop3-cached", | 117 | .sess_name = "pop3-cached", |
115 | 118 | ||
116 | .sess_initialize = pop3driver_cached_initialize, | 119 | .sess_initialize = pop3driver_cached_initialize, |
117 | .sess_uninitialize = pop3driver_cached_uninitialize, | 120 | .sess_uninitialize = pop3driver_cached_uninitialize, |
118 | 121 | ||
119 | .sess_parameters = pop3driver_cached_parameters, | 122 | .sess_parameters = pop3driver_cached_parameters, |
120 | 123 | ||
@@ -138,28 +141,29 @@ static mailsession_driver local_pop3_cached_session_driver = { | |||
138 | .sess_recent_number = pop3driver_cached_recent_number, | 141 | .sess_recent_number = pop3driver_cached_recent_number, |
139 | .sess_unseen_number = pop3driver_cached_unseen_number, | 142 | .sess_unseen_number = pop3driver_cached_unseen_number, |
140 | .sess_list_folders = NULL, | 143 | .sess_list_folders = NULL, |
141 | .sess_lsub_folders = NULL, | 144 | .sess_lsub_folders = NULL, |
142 | .sess_subscribe_folder = NULL, | 145 | .sess_subscribe_folder = NULL, |
143 | .sess_unsubscribe_folder = NULL, | 146 | .sess_unsubscribe_folder = NULL, |
144 | 147 | ||
145 | .sess_append_message = NULL, | 148 | .sess_append_message = NULL, |
149 | .sess_append_message_flags = NULL, | ||
146 | .sess_copy_message = NULL, | 150 | .sess_copy_message = NULL, |
147 | .sess_move_message = NULL, | 151 | .sess_move_message = NULL, |
148 | 152 | ||
149 | .sess_get_messages_list = pop3driver_cached_get_messages_list, | 153 | .sess_get_messages_list = pop3driver_cached_get_messages_list, |
150 | .sess_get_envelopes_list = pop3driver_cached_get_envelopes_list, | 154 | .sess_get_envelopes_list = pop3driver_cached_get_envelopes_list, |
151 | .sess_remove_message = pop3driver_cached_remove_message, | 155 | .sess_remove_message = pop3driver_cached_remove_message, |
152 | #if 0 | 156 | #if 0 |
153 | .sess_search_messages = maildriver_generic_search_messages, | 157 | .sess_search_messages = maildriver_generic_search_messages, |
154 | #endif | 158 | #endif |
155 | 159 | ||
156 | .sess_get_message = pop3driver_cached_get_message, | 160 | .sess_get_message = pop3driver_cached_get_message, |
157 | .sess_get_message_by_uid = NULL, | 161 | .sess_get_message_by_uid = pop3driver_cached_get_message_by_uid, |
158 | }; | 162 | }; |
159 | 163 | ||
160 | mailsession_driver * pop3_cached_session_driver = | 164 | mailsession_driver * pop3_cached_session_driver = |
161 | &local_pop3_cached_session_driver; | 165 | &local_pop3_cached_session_driver; |
162 | 166 | ||
163 | #define ENV_NAME "env.db" | 167 | #define ENV_NAME "env.db" |
164 | #define FLAGS_NAME "flags.db" | 168 | #define FLAGS_NAME "flags.db" |
165 | 169 | ||
@@ -850,8 +854,46 @@ static int pop3driver_cached_get_message(mailsession * session, | |||
850 | mailmessage_free(msg_info); | 854 | mailmessage_free(msg_info); |
851 | return r; | 855 | return r; |
852 | } | 856 | } |
853 | 857 | ||
854 | * result = msg_info; | 858 | * result = msg_info; |
855 | 859 | ||
856 | return MAIL_NO_ERROR; | 860 | return MAIL_NO_ERROR; |
857 | } | 861 | } |
862 | |||
863 | static int pop3driver_cached_get_message_by_uid(mailsession * session, | ||
864 | const char * uid, mailmessage ** result) | ||
865 | { | ||
866 | mailpop3 * pop3; | ||
867 | struct mailpop3_msg_info * msg_info; | ||
868 | int found; | ||
869 | unsigned int i; | ||
870 | |||
871 | if (uid == NULL) | ||
872 | return MAIL_ERROR_INVAL; | ||
873 | |||
874 | pop3 = get_pop3_session(session); | ||
875 | |||
876 | found = 0; | ||
877 | |||
878 | /* iterate all messages and look for uid */ | ||
879 | for(i = 0 ; i < carray_count(pop3->pop3_msg_tab) ; i++) { | ||
880 | msg_info = carray_get(pop3->pop3_msg_tab, i); | ||
881 | |||
882 | if (msg_info == NULL) | ||
883 | continue; | ||
884 | |||
885 | if (msg_info->msg_deleted) | ||
886 | continue; | ||
887 | |||
888 | /* uid found, stop looking */ | ||
889 | if (strcmp(msg_info->msg_uidl, uid) == 0) { | ||
890 | found = 1; | ||
891 | break; | ||
892 | } | ||
893 | } | ||
894 | |||
895 | if (!found) | ||
896 | return MAIL_ERROR_MSG_NOT_FOUND; | ||
897 | |||
898 | return pop3driver_cached_get_message(session, msg_info->msg_index, result); | ||
899 | } | ||
diff --git a/kmicromail/libetpan/generic/pop3driver_message.c b/kmicromail/libetpan/generic/pop3driver_message.c index 77bd94c..357bb2e 100644 --- a/kmicromail/libetpan/generic/pop3driver_message.c +++ b/kmicromail/libetpan/generic/pop3driver_message.c | |||
@@ -34,16 +34,18 @@ | |||
34 | */ | 34 | */ |
35 | 35 | ||
36 | #include "pop3driver_message.h" | 36 | #include "pop3driver_message.h" |
37 | 37 | ||
38 | #include "mailmessage_tools.h" | 38 | #include "mailmessage_tools.h" |
39 | #include "pop3driver_tools.h" | 39 | #include "pop3driver_tools.h" |
40 | #include "pop3driver.h" | 40 | #include "pop3driver.h" |
41 | #include "mailpop3.h" | 41 | #include "mailpop3.h" |
42 | #include <stdlib.h> | ||
43 | #include <string.h> | ||
42 | 44 | ||
43 | static int pop3_prefetch(mailmessage * msg_info); | 45 | static int pop3_prefetch(mailmessage * msg_info); |
44 | 46 | ||
45 | static void pop3_prefetch_free(struct generic_message_t * msg); | 47 | static void pop3_prefetch_free(struct generic_message_t * msg); |
46 | 48 | ||
47 | static int pop3_initialize(mailmessage * msg_info); | 49 | static int pop3_initialize(mailmessage * msg_info); |
48 | 50 | ||
49 | static int pop3_fetch_header(mailmessage * msg_info, | 51 | static int pop3_fetch_header(mailmessage * msg_info, |
@@ -75,16 +77,28 @@ static mailmessage_driver local_pop3_message_driver = { | |||
75 | .msg_fetch_section_body = mailmessage_generic_fetch_section_body, | 77 | .msg_fetch_section_body = mailmessage_generic_fetch_section_body, |
76 | .msg_fetch_envelope = mailmessage_generic_fetch_envelope, | 78 | .msg_fetch_envelope = mailmessage_generic_fetch_envelope, |
77 | 79 | ||
78 | .msg_get_flags = NULL, | 80 | .msg_get_flags = NULL, |
79 | }; | 81 | }; |
80 | 82 | ||
81 | mailmessage_driver * pop3_message_driver = &local_pop3_message_driver; | 83 | mailmessage_driver * pop3_message_driver = &local_pop3_message_driver; |
82 | 84 | ||
85 | static inline struct pop3_session_state_data * | ||
86 | get_data(mailsession * session) | ||
87 | { | ||
88 | return session->sess_data; | ||
89 | } | ||
90 | |||
91 | |||
92 | static mailpop3 * get_pop3_session(mailsession * session) | ||
93 | { | ||
94 | return get_data(session)->pop3_session; | ||
95 | } | ||
96 | |||
83 | 97 | ||
84 | static int pop3_prefetch(mailmessage * msg_info) | 98 | static int pop3_prefetch(mailmessage * msg_info) |
85 | { | 99 | { |
86 | char * msg_content; | 100 | char * msg_content; |
87 | size_t msg_length; | 101 | size_t msg_length; |
88 | struct generic_message_t * msg; | 102 | struct generic_message_t * msg; |
89 | int r; | 103 | int r; |
90 | 104 | ||
@@ -108,24 +122,44 @@ static void pop3_prefetch_free(struct generic_message_t * msg) | |||
108 | msg->msg_message = NULL; | 122 | msg->msg_message = NULL; |
109 | } | 123 | } |
110 | } | 124 | } |
111 | 125 | ||
112 | static int pop3_initialize(mailmessage * msg_info) | 126 | static int pop3_initialize(mailmessage * msg_info) |
113 | { | 127 | { |
114 | struct generic_message_t * msg; | 128 | struct generic_message_t * msg; |
115 | int r; | 129 | int r; |
130 | char * uid; | ||
131 | struct mailpop3_msg_info * info; | ||
132 | mailpop3 * pop3; | ||
133 | |||
134 | pop3 = get_pop3_session(msg_info->msg_session); | ||
135 | |||
136 | r = mailpop3_get_msg_info(pop3, msg_info->msg_index, &info); | ||
137 | switch (r) { | ||
138 | case MAILPOP3_NO_ERROR: | ||
139 | break; | ||
140 | default: | ||
141 | return pop3driver_pop3_error_to_mail_error(r); | ||
142 | } | ||
143 | |||
144 | uid = strdup(info->msg_uidl); | ||
145 | if (uid == NULL) | ||
146 | return MAIL_ERROR_MEMORY; | ||
116 | 147 | ||
117 | r = mailmessage_generic_initialize(msg_info); | 148 | r = mailmessage_generic_initialize(msg_info); |
118 | if (r != MAIL_NO_ERROR) | 149 | if (r != MAIL_NO_ERROR) { |
150 | free(uid); | ||
119 | return r; | 151 | return r; |
152 | } | ||
120 | 153 | ||
121 | msg = msg_info->msg_data; | 154 | msg = msg_info->msg_data; |
122 | msg->msg_prefetch = pop3_prefetch; | 155 | msg->msg_prefetch = pop3_prefetch; |
123 | msg->msg_prefetch_free = pop3_prefetch_free; | 156 | msg->msg_prefetch_free = pop3_prefetch_free; |
157 | msg_info->msg_uid = uid; | ||
124 | 158 | ||
125 | return MAIL_NO_ERROR; | 159 | return MAIL_NO_ERROR; |
126 | } | 160 | } |
127 | 161 | ||
128 | 162 | ||
129 | static int pop3_fetch_header(mailmessage * msg_info, | 163 | static int pop3_fetch_header(mailmessage * msg_info, |
130 | char ** result, | 164 | char ** result, |
131 | size_t * result_len) | 165 | size_t * result_len) |
diff --git a/kmicromail/libetpan/generic/pop3storage.c b/kmicromail/libetpan/generic/pop3storage.c index 8e7a94e..375aeaf 100644 --- a/kmicromail/libetpan/generic/pop3storage.c +++ b/kmicromail/libetpan/generic/pop3storage.c | |||
@@ -63,17 +63,17 @@ int pop3_mailstorage_init(struct mailstorage * storage, | |||
63 | char * pop3_servername, uint16_t pop3_port, | 63 | char * pop3_servername, uint16_t pop3_port, |
64 | char * pop3_command, | 64 | char * pop3_command, |
65 | int pop3_connection_type, int pop3_auth_type, | 65 | int pop3_connection_type, int pop3_auth_type, |
66 | char * pop3_login, char * pop3_password, | 66 | char * pop3_login, char * pop3_password, |
67 | int pop3_cached, char * pop3_cache_directory, char * pop3_flags_directory) | 67 | int pop3_cached, char * pop3_cache_directory, char * pop3_flags_directory) |
68 | { | 68 | { |
69 | struct pop3_mailstorage * pop3_storage; | 69 | struct pop3_mailstorage * pop3_storage; |
70 | 70 | ||
71 | pop3_storage = malloc(sizeof(struct pop3_mailstorage)); | 71 | pop3_storage = malloc(sizeof(* pop3_storage)); |
72 | if (pop3_storage == NULL) | 72 | if (pop3_storage == NULL) |
73 | goto err; | 73 | goto err; |
74 | 74 | ||
75 | pop3_storage->pop3_servername = strdup(pop3_servername); | 75 | pop3_storage->pop3_servername = strdup(pop3_servername); |
76 | if (pop3_storage->pop3_servername == NULL) | 76 | if (pop3_storage->pop3_servername == NULL) |
77 | goto free; | 77 | goto free; |
78 | 78 | ||
79 | pop3_storage->pop3_connection_type = pop3_connection_type; | 79 | pop3_storage->pop3_connection_type = pop3_connection_type; |
diff --git a/kmicromail/libetpan/imap/mailimap.c b/kmicromail/libetpan/imap/mailimap.c index c8fbfee..76d9454 100644 --- a/kmicromail/libetpan/imap/mailimap.c +++ b/kmicromail/libetpan/imap/mailimap.c | |||
@@ -1902,17 +1902,17 @@ int mailimap_unsubscribe(mailimap * session, const char * mb) | |||
1902 | if ((session->imap_state != MAILIMAP_STATE_AUTHENTICATED) && | 1902 | if ((session->imap_state != MAILIMAP_STATE_AUTHENTICATED) && |
1903 | (session->imap_state != MAILIMAP_STATE_SELECTED)) | 1903 | (session->imap_state != MAILIMAP_STATE_SELECTED)) |
1904 | return MAILIMAP_ERROR_BAD_STATE; | 1904 | return MAILIMAP_ERROR_BAD_STATE; |
1905 | 1905 | ||
1906 | r = send_current_tag(session); | 1906 | r = send_current_tag(session); |
1907 | if (r != MAILIMAP_NO_ERROR) | 1907 | if (r != MAILIMAP_NO_ERROR) |
1908 | return r; | 1908 | return r; |
1909 | 1909 | ||
1910 | r = mailimap_subscribe_send(session->imap_stream, mb); | 1910 | r = mailimap_unsubscribe_send(session->imap_stream, mb); |
1911 | if (r != MAILIMAP_NO_ERROR) | 1911 | if (r != MAILIMAP_NO_ERROR) |
1912 | return r; | 1912 | return r; |
1913 | 1913 | ||
1914 | r = mailimap_crlf_send(session->imap_stream); | 1914 | r = mailimap_crlf_send(session->imap_stream); |
1915 | if (r != MAILIMAP_NO_ERROR) | 1915 | if (r != MAILIMAP_NO_ERROR) |
1916 | return r; | 1916 | return r; |
1917 | 1917 | ||
1918 | if (mailstream_flush(session->imap_stream) == -1) | 1918 | if (mailstream_flush(session->imap_stream) == -1) |
diff --git a/kmicromail/libetpan/imap/mailimap_keywords.c b/kmicromail/libetpan/imap/mailimap_keywords.c index b277aed..4ec156e 100644 --- a/kmicromail/libetpan/imap/mailimap_keywords.c +++ b/kmicromail/libetpan/imap/mailimap_keywords.c | |||
@@ -48,17 +48,17 @@ struct mailimap_token_value { | |||
48 | }; | 48 | }; |
49 | 49 | ||
50 | int mailimap_token_case_insensitive_parse(mailstream * fd, | 50 | int mailimap_token_case_insensitive_parse(mailstream * fd, |
51 | MMAPString * buffer, | 51 | MMAPString * buffer, |
52 | size_t * index, | 52 | size_t * index, |
53 | const char * token) | 53 | const char * token) |
54 | { | 54 | { |
55 | int len; | 55 | int len; |
56 | int cur_token; | 56 | size_t cur_token; |
57 | int r; | 57 | int r; |
58 | 58 | ||
59 | cur_token = * index; | 59 | cur_token = * index; |
60 | len = strlen(token); | 60 | len = strlen(token); |
61 | 61 | ||
62 | #ifdef UNSTRICT_SYNTAX | 62 | #ifdef UNSTRICT_SYNTAX |
63 | r = mailimap_space_parse(fd, buffer, &cur_token); | 63 | r = mailimap_space_parse(fd, buffer, &cur_token); |
64 | if ((r != MAILIMAP_NO_ERROR) && (r != MAILIMAP_ERROR_PARSE)) | 64 | if ((r != MAILIMAP_NO_ERROR) && (r != MAILIMAP_ERROR_PARSE)) |
diff --git a/kmicromail/libetpan/imf/mailimf.c b/kmicromail/libetpan/imf/mailimf.c index 84d81a1..e0164b8 100644 --- a/kmicromail/libetpan/imf/mailimf.c +++ b/kmicromail/libetpan/imf/mailimf.c | |||
@@ -43,17 +43,17 @@ | |||
43 | already contains a Return-path header. SMTP servers performing a | 43 | already contains a Return-path header. SMTP servers performing a |
44 | relay function MUST NOT inspect the message data, and especially not | 44 | relay function MUST NOT inspect the message data, and especially not |
45 | to the extent needed to determine if Return-path headers are present. | 45 | to the extent needed to determine if Return-path headers are present. |
46 | SMTP servers making final delivery MAY remove Return-path headers | 46 | SMTP servers making final delivery MAY remove Return-path headers |
47 | before adding their own. | 47 | before adding their own. |
48 | */ | 48 | */ |
49 | 49 | ||
50 | #include <ctype.h> | 50 | #include <ctype.h> |
51 | #include <mmapstring.h> | 51 | #include "mmapstring.h" |
52 | #include <stdlib.h> | 52 | #include <stdlib.h> |
53 | #include <string.h> | 53 | #include <string.h> |
54 | 54 | ||
55 | #ifndef TRUE | 55 | #ifndef TRUE |
56 | #define TRUE 1 | 56 | #define TRUE 1 |
57 | #endif | 57 | #endif |
58 | 58 | ||
59 | #ifndef FALSE | 59 | #ifndef FALSE |
diff --git a/kmicromail/libetpan/include/libetpan/libetpan.h b/kmicromail/libetpan/include/libetpan/libetpan.h index 3b4a107..fe5637d 100644 --- a/kmicromail/libetpan/include/libetpan/libetpan.h +++ b/kmicromail/libetpan/include/libetpan/libetpan.h | |||
@@ -39,16 +39,17 @@ | |||
39 | 39 | ||
40 | #ifdef __cplusplus | 40 | #ifdef __cplusplus |
41 | extern "C" { | 41 | extern "C" { |
42 | #endif | 42 | #endif |
43 | 43 | ||
44 | #include <libetpan/libetpan_version.h> | 44 | #include <libetpan/libetpan_version.h> |
45 | #include <libetpan/maildriver.h> | 45 | #include <libetpan/maildriver.h> |
46 | #include <libetpan/mailmessage.h> | 46 | #include <libetpan/mailmessage.h> |
47 | #include <libetpan/mailfolder.h> | ||
47 | #include <libetpan/mailstorage.h> | 48 | #include <libetpan/mailstorage.h> |
48 | #include <libetpan/mailthread.h> | 49 | #include <libetpan/mailthread.h> |
49 | #include <libetpan/mailsmtp.h> | 50 | #include <libetpan/mailsmtp.h> |
50 | #include <libetpan/charconv.h> | 51 | #include <libetpan/charconv.h> |
51 | 52 | ||
52 | /* mbox driver */ | 53 | /* mbox driver */ |
53 | #include <libetpan/mboxdriver.h> | 54 | #include <libetpan/mboxdriver.h> |
54 | #include <libetpan/mboxdriver_message.h> | 55 | #include <libetpan/mboxdriver_message.h> |
@@ -86,19 +87,30 @@ extern "C" { | |||
86 | 87 | ||
87 | /* maildir driver */ | 88 | /* maildir driver */ |
88 | #include <libetpan/maildirdriver.h> | 89 | #include <libetpan/maildirdriver.h> |
89 | #include <libetpan/maildirdriver_message.h> | 90 | #include <libetpan/maildirdriver_message.h> |
90 | #include <libetpan/maildirdriver_cached.h> | 91 | #include <libetpan/maildirdriver_cached.h> |
91 | #include <libetpan/maildirdriver_cached_message.h> | 92 | #include <libetpan/maildirdriver_cached_message.h> |
92 | #include <libetpan/maildirstorage.h> | 93 | #include <libetpan/maildirstorage.h> |
93 | 94 | ||
95 | /* db driver */ | ||
96 | #include <libetpan/dbdriver.h> | ||
97 | #include <libetpan/dbdriver_message.h> | ||
98 | #include <libetpan/dbstorage.h> | ||
99 | |||
94 | /* message which content is given by a MIME structure */ | 100 | /* message which content is given by a MIME structure */ |
95 | #include <libetpan/mime_message_driver.h> | 101 | #include <libetpan/mime_message_driver.h> |
96 | 102 | ||
97 | /* message which content given by a string */ | 103 | /* message which content given by a string */ |
98 | #include <libetpan/data_message_driver.h> | 104 | #include <libetpan/data_message_driver.h> |
99 | 105 | ||
106 | /* engine */ | ||
107 | #include <libetpan/mailprivacy.h> | ||
108 | #include <libetpan/mailengine.h> | ||
109 | #include <libetpan/mailprivacy_gnupg.h> | ||
110 | #include <libetpan/mailprivacy_smime.h> | ||
111 | |||
100 | #ifdef __cplusplus | 112 | #ifdef __cplusplus |
101 | } | 113 | } |
102 | #endif | 114 | #endif |
103 | 115 | ||
104 | #endif | 116 | #endif |
diff --git a/kmicromail/libetpan/include/libetpan/maildir.h b/kmicromail/libetpan/include/libetpan/maildir.h index b782484..268dda1 100644 --- a/kmicromail/libetpan/include/libetpan/maildir.h +++ b/kmicromail/libetpan/include/libetpan/maildir.h | |||
@@ -40,19 +40,26 @@ | |||
40 | #include <libetpan/maildir_types.h> | 40 | #include <libetpan/maildir_types.h> |
41 | 41 | ||
42 | struct maildir * maildir_new(const char * path); | 42 | struct maildir * maildir_new(const char * path); |
43 | 43 | ||
44 | void maildir_free(struct maildir * md); | 44 | void maildir_free(struct maildir * md); |
45 | 45 | ||
46 | int maildir_update(struct maildir * md); | 46 | int maildir_update(struct maildir * md); |
47 | 47 | ||
48 | int maildir_message_add_uid(struct maildir * md, | ||
49 | const char * message, size_t size, | ||
50 | char * uid, size_t max_uid_len); | ||
51 | |||
48 | int maildir_message_add(struct maildir * md, | 52 | int maildir_message_add(struct maildir * md, |
49 | const char * message, size_t size); | 53 | const char * message, size_t size); |
50 | 54 | ||
55 | int maildir_message_add_file_uid(struct maildir * md, int fd, | ||
56 | char * uid, size_t max_uid_len); | ||
57 | |||
51 | int maildir_message_add_file(struct maildir * md, int fd); | 58 | int maildir_message_add_file(struct maildir * md, int fd); |
52 | 59 | ||
53 | char * maildir_message_get(struct maildir * md, const char * uid); | 60 | char * maildir_message_get(struct maildir * md, const char * uid); |
54 | 61 | ||
55 | int maildir_message_remove(struct maildir * md, const char * uid); | 62 | int maildir_message_remove(struct maildir * md, const char * uid); |
56 | 63 | ||
57 | int maildir_message_change_flags(struct maildir * md, | 64 | int maildir_message_change_flags(struct maildir * md, |
58 | const char * uid, int new_flags); | 65 | const char * uid, int new_flags); |
diff --git a/kmicromail/libetpan/include/libetpan/maildirstorage.h b/kmicromail/libetpan/include/libetpan/maildirstorage.h index d17ea2c..73d7b20 100644 --- a/kmicromail/libetpan/include/libetpan/maildirstorage.h +++ b/kmicromail/libetpan/include/libetpan/maildirstorage.h | |||
@@ -39,17 +39,17 @@ | |||
39 | 39 | ||
40 | #include <libetpan/maildirdriver_types.h> | 40 | #include <libetpan/maildirdriver_types.h> |
41 | 41 | ||
42 | #ifdef __cplusplus | 42 | #ifdef __cplusplus |
43 | extern "C" { | 43 | extern "C" { |
44 | #endif | 44 | #endif |
45 | 45 | ||
46 | /* | 46 | /* |
47 | maildir_mailstorage_init is the constructor for a mbox storage. | 47 | maildir_mailstorage_init is the constructor for a maildir storage. |
48 | 48 | ||
49 | @param storage this is the storage to initialize. | 49 | @param storage this is the storage to initialize. |
50 | 50 | ||
51 | @param pathname is the directory that contains the mailbox. | 51 | @param pathname is the directory that contains the mailbox. |
52 | 52 | ||
53 | @param cached if this value is != 0, a persistant cache will be | 53 | @param cached if this value is != 0, a persistant cache will be |
54 | stored on local system. | 54 | stored on local system. |
55 | 55 | ||
diff --git a/kmicromail/libetpan/include/libetpan/maildriver.h b/kmicromail/libetpan/include/libetpan/maildriver.h index 7da9aea..c773190 100644 --- a/kmicromail/libetpan/include/libetpan/maildriver.h +++ b/kmicromail/libetpan/include/libetpan/maildriver.h | |||
@@ -395,16 +395,19 @@ int mailsession_unsubscribe_folder(mailsession * session, char * mb); | |||
395 | 395 | ||
396 | @return MAIL_NO_ERROR is returned on success, MAIL_ERROR_XXX is returned | 396 | @return MAIL_NO_ERROR is returned on success, MAIL_ERROR_XXX is returned |
397 | on error | 397 | on error |
398 | */ | 398 | */ |
399 | 399 | ||
400 | int mailsession_append_message(mailsession * session, | 400 | int mailsession_append_message(mailsession * session, |
401 | char * message, size_t size); | 401 | char * message, size_t size); |
402 | 402 | ||
403 | int mailsession_append_message_flags(mailsession * session, | ||
404 | char * message, size_t size, struct mail_flags * flags); | ||
405 | |||
403 | /* | 406 | /* |
404 | NOTE: some drivers does not implement this | 407 | NOTE: some drivers does not implement this |
405 | 408 | ||
406 | mailsession_copy_message copies a message whose number is given to | 409 | mailsession_copy_message copies a message whose number is given to |
407 | a given mailbox. The mailbox must be accessible from the same session. | 410 | a given mailbox. The mailbox must be accessible from the same session. |
408 | 411 | ||
409 | @param session the session | 412 | @param session the session |
410 | @param num the message number | 413 | @param num the message number |
diff --git a/kmicromail/libetpan/include/libetpan/maildriver_types.h b/kmicromail/libetpan/include/libetpan/maildriver_types.h index 3ff9440..9eab4d6 100644 --- a/kmicromail/libetpan/include/libetpan/maildriver_types.h +++ b/kmicromail/libetpan/include/libetpan/maildriver_types.h | |||
@@ -502,16 +502,18 @@ struct mailsession_driver { | |||
502 | 502 | ||
503 | int (* sess_subscribe_folder)(mailsession * session, char * mb); | 503 | int (* sess_subscribe_folder)(mailsession * session, char * mb); |
504 | int (* sess_unsubscribe_folder)(mailsession * session, char * mb); | 504 | int (* sess_unsubscribe_folder)(mailsession * session, char * mb); |
505 | 505 | ||
506 | /* messages operations */ | 506 | /* messages operations */ |
507 | 507 | ||
508 | int (* sess_append_message)(mailsession * session, | 508 | int (* sess_append_message)(mailsession * session, |
509 | char * message, size_t size); | 509 | char * message, size_t size); |
510 | int (* sess_append_message_flags)(mailsession * session, | ||
511 | char * message, size_t size, struct mail_flags * flags); | ||
510 | int (* sess_copy_message)(mailsession * session, | 512 | int (* sess_copy_message)(mailsession * session, |
511 | uint32_t num, char * mb); | 513 | uint32_t num, char * mb); |
512 | int (* sess_move_message)(mailsession * session, | 514 | int (* sess_move_message)(mailsession * session, |
513 | uint32_t num, char * mb); | 515 | uint32_t num, char * mb); |
514 | 516 | ||
515 | int (* sess_get_message)(mailsession * session, | 517 | int (* sess_get_message)(mailsession * session, |
516 | uint32_t num, mailmessage ** result); | 518 | uint32_t num, mailmessage ** result); |
517 | 519 | ||
diff --git a/kmicromail/libetpan/include/libetpan/mailfolder.h b/kmicromail/libetpan/include/libetpan/mailfolder.h index 3ecad23..ff53470 100644 --- a/kmicromail/libetpan/include/libetpan/mailfolder.h +++ b/kmicromail/libetpan/include/libetpan/mailfolder.h | |||
@@ -12,16 +12,19 @@ int mailfolder_expunge(struct mailfolder * folder); | |||
12 | 12 | ||
13 | int mailfolder_status(struct mailfolder * folder, | 13 | int mailfolder_status(struct mailfolder * folder, |
14 | uint32_t * result_messages, uint32_t * result_recent, | 14 | uint32_t * result_messages, uint32_t * result_recent, |
15 | uint32_t * result_unseen); | 15 | uint32_t * result_unseen); |
16 | 16 | ||
17 | int mailfolder_append_message(struct mailfolder * folder, | 17 | int mailfolder_append_message(struct mailfolder * folder, |
18 | char * message, size_t size); | 18 | char * message, size_t size); |
19 | 19 | ||
20 | int mailfolder_append_message_flags(struct mailfolder * folder, | ||
21 | char * message, size_t size, struct mail_flags * flags); | ||
22 | |||
20 | int mailfolder_get_messages_list(struct mailfolder * folder, | 23 | int mailfolder_get_messages_list(struct mailfolder * folder, |
21 | struct mailmessage_list ** result); | 24 | struct mailmessage_list ** result); |
22 | 25 | ||
23 | int mailfolder_get_envelopes_list(struct mailfolder * folder, | 26 | int mailfolder_get_envelopes_list(struct mailfolder * folder, |
24 | struct mailmessage_list * result); | 27 | struct mailmessage_list * result); |
25 | 28 | ||
26 | int mailfolder_get_message(struct mailfolder * folder, | 29 | int mailfolder_get_message(struct mailfolder * folder, |
27 | uint32_t num, mailmessage ** result); | 30 | uint32_t num, mailmessage ** result); |
diff --git a/kmicromail/libetpan/include/libetpan/mailmbox.h b/kmicromail/libetpan/include/libetpan/mailmbox.h index 8be086c..0427f1f 100644 --- a/kmicromail/libetpan/include/libetpan/mailmbox.h +++ b/kmicromail/libetpan/include/libetpan/mailmbox.h | |||
@@ -46,16 +46,20 @@ extern "C" { | |||
46 | int | 46 | int |
47 | mailmbox_append_message_list(struct mailmbox_folder * folder, | 47 | mailmbox_append_message_list(struct mailmbox_folder * folder, |
48 | carray * append_tab); | 48 | carray * append_tab); |
49 | 49 | ||
50 | int | 50 | int |
51 | mailmbox_append_message(struct mailmbox_folder * folder, | 51 | mailmbox_append_message(struct mailmbox_folder * folder, |
52 | const char * data, size_t len); | 52 | const char * data, size_t len); |
53 | 53 | ||
54 | int | ||
55 | mailmbox_append_message_uid(struct mailmbox_folder * folder, | ||
56 | const char * data, size_t len, unsigned int * puid); | ||
57 | |||
54 | int mailmbox_fetch_msg(struct mailmbox_folder * folder, | 58 | int mailmbox_fetch_msg(struct mailmbox_folder * folder, |
55 | uint32_t num, char ** result, | 59 | uint32_t num, char ** result, |
56 | size_t * result_len); | 60 | size_t * result_len); |
57 | 61 | ||
58 | int mailmbox_fetch_msg_headers(struct mailmbox_folder * folder, | 62 | int mailmbox_fetch_msg_headers(struct mailmbox_folder * folder, |
59 | uint32_t num, char ** result, | 63 | uint32_t num, char ** result, |
60 | size_t * result_len); | 64 | size_t * result_len); |
61 | 65 | ||
diff --git a/kmicromail/libetpan/include/libetpan/mailmbox_types.h b/kmicromail/libetpan/include/libetpan/mailmbox_types.h index dd6758c..bd6ee30 100644 --- a/kmicromail/libetpan/include/libetpan/mailmbox_types.h +++ b/kmicromail/libetpan/include/libetpan/mailmbox_types.h | |||
@@ -123,16 +123,17 @@ mailmbox_msg_info_new(size_t msg_start, size_t msg_start_len, | |||
123 | size_t msg_size, size_t msg_padding, | 123 | size_t msg_size, size_t msg_padding, |
124 | uint32_t msg_uid); | 124 | uint32_t msg_uid); |
125 | 125 | ||
126 | void mailmbox_msg_info_free(struct mailmbox_msg_info * info); | 126 | void mailmbox_msg_info_free(struct mailmbox_msg_info * info); |
127 | 127 | ||
128 | struct mailmbox_append_info { | 128 | struct mailmbox_append_info { |
129 | const char * ai_message; | 129 | const char * ai_message; |
130 | size_t ai_size; | 130 | size_t ai_size; |
131 | unsigned int ai_uid; | ||
131 | }; | 132 | }; |
132 | 133 | ||
133 | struct mailmbox_append_info * | 134 | struct mailmbox_append_info * |
134 | mailmbox_append_info_new(const char * ai_message, size_t ai_size); | 135 | mailmbox_append_info_new(const char * ai_message, size_t ai_size); |
135 | 136 | ||
136 | void mailmbox_append_info_free(struct mailmbox_append_info * info); | 137 | void mailmbox_append_info_free(struct mailmbox_append_info * info); |
137 | 138 | ||
138 | #ifdef __cplusplus | 139 | #ifdef __cplusplus |
diff --git a/kmicromail/libetpan/include/libetpan/mailmh.h b/kmicromail/libetpan/include/libetpan/mailmh.h index 40432cb..00199b8 100644 --- a/kmicromail/libetpan/include/libetpan/mailmh.h +++ b/kmicromail/libetpan/include/libetpan/mailmh.h | |||
@@ -114,19 +114,26 @@ int mailmh_folder_get_message_filename(struct mailmh_folder * folder, | |||
114 | uint32_t index, char ** result); | 114 | uint32_t index, char ** result); |
115 | 115 | ||
116 | int mailmh_folder_get_message_fd(struct mailmh_folder * folder, | 116 | int mailmh_folder_get_message_fd(struct mailmh_folder * folder, |
117 | uint32_t index, int flags, int * result); | 117 | uint32_t index, int flags, int * result); |
118 | 118 | ||
119 | int mailmh_folder_get_message_size(struct mailmh_folder * folder, | 119 | int mailmh_folder_get_message_size(struct mailmh_folder * folder, |
120 | uint32_t index, size_t * result); | 120 | uint32_t index, size_t * result); |
121 | 121 | ||
122 | int mailmh_folder_add_message_uid(struct mailmh_folder * folder, | ||
123 | const char * message, size_t size, | ||
124 | uint32_t * pindex); | ||
125 | |||
122 | int mailmh_folder_add_message(struct mailmh_folder * folder, | 126 | int mailmh_folder_add_message(struct mailmh_folder * folder, |
123 | const char * message, size_t size); | 127 | const char * message, size_t size); |
124 | 128 | ||
129 | int mailmh_folder_add_message_file_uid(struct mailmh_folder * folder, | ||
130 | int fd, uint32_t * pindex); | ||
131 | |||
125 | int mailmh_folder_add_message_file(struct mailmh_folder * folder, | 132 | int mailmh_folder_add_message_file(struct mailmh_folder * folder, |
126 | int fd); | 133 | int fd); |
127 | 134 | ||
128 | int mailmh_folder_remove_message(struct mailmh_folder * folder, | 135 | int mailmh_folder_remove_message(struct mailmh_folder * folder, |
129 | uint32_t index); | 136 | uint32_t index); |
130 | 137 | ||
131 | int mailmh_folder_move_message(struct mailmh_folder * dest_folder, | 138 | int mailmh_folder_move_message(struct mailmh_folder * dest_folder, |
132 | struct mailmh_folder * src_folder, | 139 | struct mailmh_folder * src_folder, |
diff --git a/kmicromail/libetpan/include/libetpan/mailstorage.h b/kmicromail/libetpan/include/libetpan/mailstorage.h index d56aef1..4c57883 100644 --- a/kmicromail/libetpan/include/libetpan/mailstorage.h +++ b/kmicromail/libetpan/include/libetpan/mailstorage.h | |||
@@ -66,16 +66,18 @@ void mailstorage_free(struct mailstorage * storage); | |||
66 | /* | 66 | /* |
67 | session will be initialized on success. | 67 | session will be initialized on success. |
68 | */ | 68 | */ |
69 | 69 | ||
70 | int mailstorage_connect(struct mailstorage * storage); | 70 | int mailstorage_connect(struct mailstorage * storage); |
71 | 71 | ||
72 | void mailstorage_disconnect(struct mailstorage * storage); | 72 | void mailstorage_disconnect(struct mailstorage * storage); |
73 | 73 | ||
74 | int mailstorage_noop(struct mailstorage * storage); | ||
75 | |||
74 | 76 | ||
75 | /* folder */ | 77 | /* folder */ |
76 | 78 | ||
77 | struct mailfolder * mailfolder_new(struct mailstorage * fld_storage, | 79 | struct mailfolder * mailfolder_new(struct mailstorage * fld_storage, |
78 | char * fld_pathname, char * fld_virtual_name); | 80 | char * fld_pathname, char * fld_virtual_name); |
79 | 81 | ||
80 | void mailfolder_free(struct mailfolder * folder); | 82 | void mailfolder_free(struct mailfolder * folder); |
81 | 83 | ||
@@ -83,16 +85,15 @@ int mailfolder_add_child(struct mailfolder * parent, | |||
83 | struct mailfolder * child); | 85 | struct mailfolder * child); |
84 | 86 | ||
85 | int mailfolder_detach_parent(struct mailfolder * folder); | 87 | int mailfolder_detach_parent(struct mailfolder * folder); |
86 | 88 | ||
87 | int mailfolder_connect(struct mailfolder * folder); | 89 | int mailfolder_connect(struct mailfolder * folder); |
88 | 90 | ||
89 | void mailfolder_disconnect(struct mailfolder * folder); | 91 | void mailfolder_disconnect(struct mailfolder * folder); |
90 | 92 | ||
91 | |||
92 | #ifdef __cplusplus | 93 | #ifdef __cplusplus |
93 | } | 94 | } |
94 | #endif | 95 | #endif |
95 | 96 | ||
96 | #endif | 97 | #endif |
97 | 98 | ||
98 | 99 | ||
diff --git a/kmicromail/libetpan/maildir/maildir.c b/kmicromail/libetpan/maildir/maildir.c index 320ef81..0e038b1 100644 --- a/kmicromail/libetpan/maildir/maildir.c +++ b/kmicromail/libetpan/maildir/maildir.c | |||
@@ -425,18 +425,19 @@ static char * libetpan_basename(char * filename) | |||
425 | return filename; | 425 | return filename; |
426 | else | 426 | else |
427 | return p + 1; | 427 | return p + 1; |
428 | } | 428 | } |
429 | #else | 429 | #else |
430 | #define libetpan_basename(a) basename(a) | 430 | #define libetpan_basename(a) basename(a) |
431 | #endif | 431 | #endif |
432 | 432 | ||
433 | int maildir_message_add(struct maildir * md, | 433 | int maildir_message_add_uid(struct maildir * md, |
434 | const char * message, size_t size) | 434 | const char * message, size_t size, |
435 | char * uid, size_t max_uid_len) | ||
435 | { | 436 | { |
436 | char path_new[PATH_MAX]; | 437 | char path_new[PATH_MAX]; |
437 | char tmpname[PATH_MAX]; | 438 | char tmpname[PATH_MAX]; |
438 | int fd; | 439 | int fd; |
439 | int r; | 440 | int r; |
440 | char * mapping; | 441 | char * mapping; |
441 | char * delivery_tmp_name; | 442 | char * delivery_tmp_name; |
442 | char * delivery_tmp_basename; | 443 | char * delivery_tmp_basename; |
@@ -448,17 +449,18 @@ int maildir_message_add(struct maildir * md, | |||
448 | r = maildir_update(md); | 449 | r = maildir_update(md); |
449 | if (r != MAILDIR_NO_ERROR) { | 450 | if (r != MAILDIR_NO_ERROR) { |
450 | res = r; | 451 | res = r; |
451 | goto err; | 452 | goto err; |
452 | } | 453 | } |
453 | 454 | ||
454 | /* write to tmp/ with a classic temporary file */ | 455 | /* write to tmp/ with a classic temporary file */ |
455 | 456 | ||
456 | snprintf(tmpname, sizeof(tmpname), "%s/tmp/etpan-maildir-XXXXXX", md->mdir_path); | 457 | snprintf(tmpname, sizeof(tmpname), "%s/tmp/etpan-maildir-XXXXXX", |
458 | md->mdir_path); | ||
457 | fd = mkstemp(tmpname); | 459 | fd = mkstemp(tmpname); |
458 | if (fd < 0) { | 460 | if (fd < 0) { |
459 | res = MAILDIR_ERROR_FILE; | 461 | res = MAILDIR_ERROR_FILE; |
460 | goto err; | 462 | goto err; |
461 | } | 463 | } |
462 | 464 | ||
463 | r = ftruncate(fd, size); | 465 | r = ftruncate(fd, size); |
464 | if (r < 0) { | 466 | if (r < 0) { |
@@ -516,17 +518,20 @@ int maildir_message_add(struct maildir * md, | |||
516 | delivery_new_basename = libetpan_basename(delivery_new_name); | 518 | delivery_new_basename = libetpan_basename(delivery_new_name); |
517 | 519 | ||
518 | r = add_message(md, delivery_new_basename, 1); | 520 | r = add_message(md, delivery_new_basename, 1); |
519 | if (r != MAILDIR_NO_ERROR) { | 521 | if (r != MAILDIR_NO_ERROR) { |
520 | unlink(delivery_new_name); | 522 | unlink(delivery_new_name); |
521 | res = MAILDIR_ERROR_FILE; | 523 | res = MAILDIR_ERROR_FILE; |
522 | goto unlink_tmp; | 524 | goto unlink_tmp; |
523 | } | 525 | } |
524 | 526 | ||
527 | if (uid != NULL) | ||
528 | strncpy(uid, delivery_new_basename, max_uid_len); | ||
529 | |||
525 | unlink(delivery_tmp_name); | 530 | unlink(delivery_tmp_name); |
526 | free(delivery_tmp_name); | 531 | free(delivery_tmp_name); |
527 | 532 | ||
528 | return MAILDIR_NO_ERROR; | 533 | return MAILDIR_NO_ERROR; |
529 | 534 | ||
530 | unlink_tmp: | 535 | unlink_tmp: |
531 | unlink(delivery_tmp_name); | 536 | unlink(delivery_tmp_name); |
532 | free(delivery_tmp_name); | 537 | free(delivery_tmp_name); |
@@ -534,36 +539,50 @@ int maildir_message_add(struct maildir * md, | |||
534 | close: | 539 | close: |
535 | close(fd); | 540 | close(fd); |
536 | unlink: | 541 | unlink: |
537 | unlink(tmpname); | 542 | unlink(tmpname); |
538 | err: | 543 | err: |
539 | return res; | 544 | return res; |
540 | } | 545 | } |
541 | 546 | ||
542 | int maildir_message_add_file(struct maildir * md, int fd) | 547 | int maildir_message_add(struct maildir * md, |
548 | const char * message, size_t size) | ||
549 | { | ||
550 | return maildir_message_add_uid(md, message, size, | ||
551 | NULL, 0); | ||
552 | } | ||
553 | |||
554 | int maildir_message_add_file_uid(struct maildir * md, int fd, | ||
555 | char * uid, size_t max_uid_len) | ||
543 | { | 556 | { |
544 | char * message; | 557 | char * message; |
545 | struct stat buf; | 558 | struct stat buf; |
546 | int r; | 559 | int r; |
547 | 560 | ||
548 | if (fstat(fd, &buf) == -1) | 561 | if (fstat(fd, &buf) == -1) |
549 | return MAILDIR_ERROR_FILE; | 562 | return MAILDIR_ERROR_FILE; |
550 | 563 | ||
551 | message = mmap(NULL, buf.st_size, PROT_READ, MAP_PRIVATE, fd, 0); | 564 | message = mmap(NULL, buf.st_size, PROT_READ, MAP_PRIVATE, fd, 0); |
552 | if (message == MAP_FAILED) | 565 | if (message == MAP_FAILED) |
553 | return MAILDIR_ERROR_FILE; | 566 | return MAILDIR_ERROR_FILE; |
554 | 567 | ||
555 | r = maildir_message_add(md, message, buf.st_size); | 568 | r = maildir_message_add_uid(md, message, buf.st_size, uid, max_uid_len); |
556 | 569 | ||
557 | munmap(message, buf.st_size); | 570 | munmap(message, buf.st_size); |
558 | 571 | ||
559 | return r; | 572 | return r; |
560 | } | 573 | } |
561 | 574 | ||
575 | int maildir_message_add_file(struct maildir * md, int fd) | ||
576 | { | ||
577 | return maildir_message_add_file_uid(md, fd, | ||
578 | NULL, 0); | ||
579 | } | ||
580 | |||
562 | char * maildir_message_get(struct maildir * md, const char * uid) | 581 | char * maildir_message_get(struct maildir * md, const char * uid) |
563 | { | 582 | { |
564 | chashdatum key; | 583 | chashdatum key; |
565 | chashdatum value; | 584 | chashdatum value; |
566 | char filename[PATH_MAX]; | 585 | char filename[PATH_MAX]; |
567 | char * dup_filename; | 586 | char * dup_filename; |
568 | struct maildir_msg * msg; | 587 | struct maildir_msg * msg; |
569 | char * dir; | 588 | char * dir; |
diff --git a/kmicromail/libetpan/maildir/maildir.h b/kmicromail/libetpan/maildir/maildir.h index b782484..268dda1 100644 --- a/kmicromail/libetpan/maildir/maildir.h +++ b/kmicromail/libetpan/maildir/maildir.h | |||
@@ -40,19 +40,26 @@ | |||
40 | #include <libetpan/maildir_types.h> | 40 | #include <libetpan/maildir_types.h> |
41 | 41 | ||
42 | struct maildir * maildir_new(const char * path); | 42 | struct maildir * maildir_new(const char * path); |
43 | 43 | ||
44 | void maildir_free(struct maildir * md); | 44 | void maildir_free(struct maildir * md); |
45 | 45 | ||
46 | int maildir_update(struct maildir * md); | 46 | int maildir_update(struct maildir * md); |
47 | 47 | ||
48 | int maildir_message_add_uid(struct maildir * md, | ||
49 | const char * message, size_t size, | ||
50 | char * uid, size_t max_uid_len); | ||
51 | |||
48 | int maildir_message_add(struct maildir * md, | 52 | int maildir_message_add(struct maildir * md, |
49 | const char * message, size_t size); | 53 | const char * message, size_t size); |
50 | 54 | ||
55 | int maildir_message_add_file_uid(struct maildir * md, int fd, | ||
56 | char * uid, size_t max_uid_len); | ||
57 | |||
51 | int maildir_message_add_file(struct maildir * md, int fd); | 58 | int maildir_message_add_file(struct maildir * md, int fd); |
52 | 59 | ||
53 | char * maildir_message_get(struct maildir * md, const char * uid); | 60 | char * maildir_message_get(struct maildir * md, const char * uid); |
54 | 61 | ||
55 | int maildir_message_remove(struct maildir * md, const char * uid); | 62 | int maildir_message_remove(struct maildir * md, const char * uid); |
56 | 63 | ||
57 | int maildir_message_change_flags(struct maildir * md, | 64 | int maildir_message_change_flags(struct maildir * md, |
58 | const char * uid, int new_flags); | 65 | const char * uid, int new_flags); |
diff --git a/kmicromail/libetpan/mbox/mailmbox.c b/kmicromail/libetpan/mbox/mailmbox.c index 280c313..b3fce02 100644 --- a/kmicromail/libetpan/mbox/mailmbox.c +++ b/kmicromail/libetpan/mbox/mailmbox.c | |||
@@ -192,16 +192,19 @@ void mailmbox_timestamp(struct mailmbox_folder * folder) | |||
192 | open the file | 192 | open the file |
193 | */ | 193 | */ |
194 | 194 | ||
195 | int mailmbox_open(struct mailmbox_folder * folder) | 195 | int mailmbox_open(struct mailmbox_folder * folder) |
196 | { | 196 | { |
197 | int fd; | 197 | int fd; |
198 | int read_only; | 198 | int read_only; |
199 | 199 | ||
200 | fd = -1; | ||
201 | read_only = TRUE; | ||
202 | |||
200 | if (!folder->mb_read_only) { | 203 | if (!folder->mb_read_only) { |
201 | read_only = FALSE; | 204 | read_only = FALSE; |
202 | fd = open(folder->mb_filename, O_RDWR | O_CREAT, S_IRUSR | S_IWUSR); | 205 | fd = open(folder->mb_filename, O_RDWR | O_CREAT, S_IRUSR | S_IWUSR); |
203 | } | 206 | } |
204 | 207 | ||
205 | if (folder->mb_read_only || (fd < 0)) { | 208 | if (folder->mb_read_only || (fd < 0)) { |
206 | read_only = TRUE; | 209 | read_only = TRUE; |
207 | fd = open(folder->mb_filename, O_RDONLY); | 210 | fd = open(folder->mb_filename, O_RDONLY); |
@@ -612,16 +615,18 @@ mailmbox_append_message_list_no_lock(struct mailmbox_folder * folder, | |||
612 | struct mailmbox_append_info * info; | 615 | struct mailmbox_append_info * info; |
613 | 616 | ||
614 | info = carray_get(append_tab, i); | 617 | info = carray_get(append_tab, i); |
615 | extra_size += from_size; | 618 | extra_size += from_size; |
616 | extra_size += get_fixed_message_size(info->ai_message, info->ai_size, | 619 | extra_size += get_fixed_message_size(info->ai_message, info->ai_size, |
617 | folder->mb_max_uid + i + 1, | 620 | folder->mb_max_uid + i + 1, |
618 | folder->mb_no_uid); | 621 | folder->mb_no_uid); |
619 | extra_size += 2; /* CR LF */ | 622 | extra_size += 2; /* CR LF */ |
623 | |||
624 | info->ai_uid = folder->mb_max_uid + i + 1; | ||
620 | } | 625 | } |
621 | 626 | ||
622 | left = folder->mb_mapping_size; | 627 | left = folder->mb_mapping_size; |
623 | crlf_count = 0; | 628 | crlf_count = 0; |
624 | while (left >= 1) { | 629 | while (left >= 1) { |
625 | if (folder->mb_mapping[left - 1] == '\n') { | 630 | if (folder->mb_mapping[left - 1] == '\n') { |
626 | crlf_count ++; | 631 | crlf_count ++; |
627 | left --; | 632 | left --; |
@@ -739,18 +744,18 @@ mailmbox_append_message_list(struct mailmbox_folder * folder, | |||
739 | 744 | ||
740 | unlock: | 745 | unlock: |
741 | mailmbox_write_unlock(folder); | 746 | mailmbox_write_unlock(folder); |
742 | err: | 747 | err: |
743 | return res; | 748 | return res; |
744 | } | 749 | } |
745 | 750 | ||
746 | int | 751 | int |
747 | mailmbox_append_message(struct mailmbox_folder * folder, | 752 | mailmbox_append_message_uid(struct mailmbox_folder * folder, |
748 | const char * data, size_t len) | 753 | const char * data, size_t len, unsigned int * puid) |
749 | { | 754 | { |
750 | carray * tab; | 755 | carray * tab; |
751 | struct mailmbox_append_info * append_info; | 756 | struct mailmbox_append_info * append_info; |
752 | int res; | 757 | int res; |
753 | int r; | 758 | int r; |
754 | 759 | ||
755 | tab = carray_new(1); | 760 | tab = carray_new(1); |
756 | if (tab == NULL) { | 761 | if (tab == NULL) { |
@@ -766,30 +771,40 @@ mailmbox_append_message(struct mailmbox_folder * folder, | |||
766 | 771 | ||
767 | r = carray_add(tab, append_info, NULL); | 772 | r = carray_add(tab, append_info, NULL); |
768 | if (r < 0) { | 773 | if (r < 0) { |
769 | res = MAILMBOX_ERROR_MEMORY; | 774 | res = MAILMBOX_ERROR_MEMORY; |
770 | goto free_append_info; | 775 | goto free_append_info; |
771 | } | 776 | } |
772 | 777 | ||
773 | r = mailmbox_append_message_list(folder, tab); | 778 | r = mailmbox_append_message_list(folder, tab); |
774 | 779 | ||
780 | if (puid != NULL) | ||
781 | * puid = append_info->ai_uid; | ||
782 | |||
775 | mailmbox_append_info_free(append_info); | 783 | mailmbox_append_info_free(append_info); |
776 | carray_free(tab); | 784 | carray_free(tab); |
777 | 785 | ||
778 | return r; | 786 | return r; |
779 | 787 | ||
780 | free_append_info: | 788 | free_append_info: |
781 | mailmbox_append_info_free(append_info); | 789 | mailmbox_append_info_free(append_info); |
782 | free_list: | 790 | free_list: |
783 | carray_free(tab); | 791 | carray_free(tab); |
784 | err: | 792 | err: |
785 | return res; | 793 | return res; |
786 | } | 794 | } |
787 | 795 | ||
796 | int | ||
797 | mailmbox_append_message(struct mailmbox_folder * folder, | ||
798 | const char * data, size_t len) | ||
799 | { | ||
800 | return mailmbox_append_message_uid(folder, data, len, NULL); | ||
801 | } | ||
802 | |||
788 | /* ********************************************************************** */ | 803 | /* ********************************************************************** */ |
789 | 804 | ||
790 | int mailmbox_fetch_msg_no_lock(struct mailmbox_folder * folder, | 805 | int mailmbox_fetch_msg_no_lock(struct mailmbox_folder * folder, |
791 | uint32_t num, char ** result, | 806 | uint32_t num, char ** result, |
792 | size_t * result_len) | 807 | size_t * result_len) |
793 | { | 808 | { |
794 | struct mailmbox_msg_info * info; | 809 | struct mailmbox_msg_info * info; |
795 | int res; | 810 | int res; |
diff --git a/kmicromail/libetpan/mbox/mailmbox.h b/kmicromail/libetpan/mbox/mailmbox.h index 8be086c..0427f1f 100644 --- a/kmicromail/libetpan/mbox/mailmbox.h +++ b/kmicromail/libetpan/mbox/mailmbox.h | |||
@@ -46,16 +46,20 @@ extern "C" { | |||
46 | int | 46 | int |
47 | mailmbox_append_message_list(struct mailmbox_folder * folder, | 47 | mailmbox_append_message_list(struct mailmbox_folder * folder, |
48 | carray * append_tab); | 48 | carray * append_tab); |
49 | 49 | ||
50 | int | 50 | int |
51 | mailmbox_append_message(struct mailmbox_folder * folder, | 51 | mailmbox_append_message(struct mailmbox_folder * folder, |
52 | const char * data, size_t len); | 52 | const char * data, size_t len); |
53 | 53 | ||
54 | int | ||
55 | mailmbox_append_message_uid(struct mailmbox_folder * folder, | ||
56 | const char * data, size_t len, unsigned int * puid); | ||
57 | |||
54 | int mailmbox_fetch_msg(struct mailmbox_folder * folder, | 58 | int mailmbox_fetch_msg(struct mailmbox_folder * folder, |
55 | uint32_t num, char ** result, | 59 | uint32_t num, char ** result, |
56 | size_t * result_len); | 60 | size_t * result_len); |
57 | 61 | ||
58 | int mailmbox_fetch_msg_headers(struct mailmbox_folder * folder, | 62 | int mailmbox_fetch_msg_headers(struct mailmbox_folder * folder, |
59 | uint32_t num, char ** result, | 63 | uint32_t num, char ** result, |
60 | size_t * result_len); | 64 | size_t * result_len); |
61 | 65 | ||
diff --git a/kmicromail/libetpan/mbox/mailmbox_types.c b/kmicromail/libetpan/mbox/mailmbox_types.c index 1986182..4e3e521 100644 --- a/kmicromail/libetpan/mbox/mailmbox_types.c +++ b/kmicromail/libetpan/mbox/mailmbox_types.c | |||
@@ -173,17 +173,18 @@ mailmbox_append_info_new(const char * ai_message, size_t ai_size) | |||
173 | struct mailmbox_append_info * info; | 173 | struct mailmbox_append_info * info; |
174 | 174 | ||
175 | info = malloc(sizeof(* info)); | 175 | info = malloc(sizeof(* info)); |
176 | if (info == NULL) | 176 | if (info == NULL) |
177 | return NULL; | 177 | return NULL; |
178 | 178 | ||
179 | info->ai_message = ai_message; | 179 | info->ai_message = ai_message; |
180 | info->ai_size = ai_size; | 180 | info->ai_size = ai_size; |
181 | 181 | info->ai_uid = 0; | |
182 | |||
182 | return info; | 183 | return info; |
183 | } | 184 | } |
184 | 185 | ||
185 | void mailmbox_append_info_free(struct mailmbox_append_info * info) | 186 | void mailmbox_append_info_free(struct mailmbox_append_info * info) |
186 | { | 187 | { |
187 | free(info); | 188 | free(info); |
188 | } | 189 | } |
189 | 190 | ||
diff --git a/kmicromail/libetpan/mbox/mailmbox_types.h b/kmicromail/libetpan/mbox/mailmbox_types.h index dd6758c..bd6ee30 100644 --- a/kmicromail/libetpan/mbox/mailmbox_types.h +++ b/kmicromail/libetpan/mbox/mailmbox_types.h | |||
@@ -123,16 +123,17 @@ mailmbox_msg_info_new(size_t msg_start, size_t msg_start_len, | |||
123 | size_t msg_size, size_t msg_padding, | 123 | size_t msg_size, size_t msg_padding, |
124 | uint32_t msg_uid); | 124 | uint32_t msg_uid); |
125 | 125 | ||
126 | void mailmbox_msg_info_free(struct mailmbox_msg_info * info); | 126 | void mailmbox_msg_info_free(struct mailmbox_msg_info * info); |
127 | 127 | ||
128 | struct mailmbox_append_info { | 128 | struct mailmbox_append_info { |
129 | const char * ai_message; | 129 | const char * ai_message; |
130 | size_t ai_size; | 130 | size_t ai_size; |
131 | unsigned int ai_uid; | ||
131 | }; | 132 | }; |
132 | 133 | ||
133 | struct mailmbox_append_info * | 134 | struct mailmbox_append_info * |
134 | mailmbox_append_info_new(const char * ai_message, size_t ai_size); | 135 | mailmbox_append_info_new(const char * ai_message, size_t ai_size); |
135 | 136 | ||
136 | void mailmbox_append_info_free(struct mailmbox_append_info * info); | 137 | void mailmbox_append_info_free(struct mailmbox_append_info * info); |
137 | 138 | ||
138 | #ifdef __cplusplus | 139 | #ifdef __cplusplus |
diff --git a/kmicromail/libetpan/mh/mailmh.c b/kmicromail/libetpan/mh/mailmh.c index d6ff950..119f217 100644 --- a/kmicromail/libetpan/mh/mailmh.c +++ b/kmicromail/libetpan/mh/mailmh.c | |||
@@ -718,18 +718,19 @@ int mailmh_folder_get_message_size(struct mailmh_folder * folder, | |||
718 | if (r < 0) | 718 | if (r < 0) |
719 | return MAILMH_ERROR_FILE; | 719 | return MAILMH_ERROR_FILE; |
720 | 720 | ||
721 | * result = buf.st_size; | 721 | * result = buf.st_size; |
722 | 722 | ||
723 | return MAILMH_NO_ERROR; | 723 | return MAILMH_NO_ERROR; |
724 | } | 724 | } |
725 | 725 | ||
726 | int mailmh_folder_add_message(struct mailmh_folder * folder, | 726 | int mailmh_folder_add_message_uid(struct mailmh_folder * folder, |
727 | const char * message, size_t size) | 727 | const char * message, size_t size, |
728 | uint32_t * pindex) | ||
728 | { | 729 | { |
729 | char * tmpname; | 730 | char * tmpname; |
730 | int fd; | 731 | int fd; |
731 | size_t namesize; | 732 | size_t namesize; |
732 | size_t left; | 733 | size_t left; |
733 | ssize_t res; | 734 | ssize_t res; |
734 | struct mailmh_msg_info * msg_info; | 735 | struct mailmh_msg_info * msg_info; |
735 | uint32_t index; | 736 | uint32_t index; |
@@ -804,34 +805,43 @@ int mailmh_folder_add_message(struct mailmh_folder * folder, | |||
804 | #if 0 | 805 | #if 0 |
805 | r = cinthash_add(folder->fl_msgs_hash, index, msg_info); | 806 | r = cinthash_add(folder->fl_msgs_hash, index, msg_info); |
806 | #endif | 807 | #endif |
807 | key.data = &index; | 808 | key.data = &index; |
808 | key.len = sizeof(index); | 809 | key.len = sizeof(index); |
809 | data.data = msg_info; | 810 | data.data = msg_info; |
810 | data.len = 0; | 811 | data.len = 0; |
811 | 812 | ||
813 | if (pindex != NULL) | ||
814 | * pindex = index; | ||
815 | |||
812 | r = chash_set(folder->fl_msgs_hash, &key, &data, NULL); | 816 | r = chash_set(folder->fl_msgs_hash, &key, &data, NULL); |
813 | if (r < 0) { | 817 | if (r < 0) { |
814 | carray_delete_fast(folder->fl_msgs_tab, msg_info->msg_array_index); | 818 | carray_delete_fast(folder->fl_msgs_tab, msg_info->msg_array_index); |
815 | mailmh_msg_info_free(msg_info); | 819 | mailmh_msg_info_free(msg_info); |
816 | error = MAILMH_ERROR_MEMORY; | 820 | error = MAILMH_ERROR_MEMORY; |
817 | goto err; | 821 | goto err; |
818 | } | 822 | } |
819 | 823 | ||
820 | return MAILMH_NO_ERROR; | 824 | return MAILMH_NO_ERROR; |
821 | 825 | ||
822 | free: | 826 | free: |
823 | free(tmpname); | 827 | free(tmpname); |
824 | err: | 828 | err: |
825 | return error; | 829 | return error; |
826 | } | 830 | } |
827 | 831 | ||
828 | int mailmh_folder_add_message_file(struct mailmh_folder * folder, | 832 | int mailmh_folder_add_message(struct mailmh_folder * folder, |
829 | int fd) | 833 | const char * message, size_t size) |
834 | { | ||
835 | return mailmh_folder_add_message_uid(folder, message, size, NULL); | ||
836 | } | ||
837 | |||
838 | int mailmh_folder_add_message_file_uid(struct mailmh_folder * folder, | ||
839 | int fd, uint32_t * pindex) | ||
830 | { | 840 | { |
831 | char * message; | 841 | char * message; |
832 | struct stat buf; | 842 | struct stat buf; |
833 | int r; | 843 | int r; |
834 | 844 | ||
835 | #if 0 | 845 | #if 0 |
836 | r = mailmh_folder_update(folder); | 846 | r = mailmh_folder_update(folder); |
837 | if (r != MAILMH_NO_ERROR) | 847 | if (r != MAILMH_NO_ERROR) |
@@ -840,23 +850,29 @@ int mailmh_folder_add_message_file(struct mailmh_folder * folder, | |||
840 | 850 | ||
841 | if (fstat(fd, &buf) == -1) | 851 | if (fstat(fd, &buf) == -1) |
842 | return MAILMH_ERROR_FILE; | 852 | return MAILMH_ERROR_FILE; |
843 | 853 | ||
844 | message = mmap(NULL, buf.st_size, PROT_READ, MAP_PRIVATE, fd, 0); | 854 | message = mmap(NULL, buf.st_size, PROT_READ, MAP_PRIVATE, fd, 0); |
845 | if (message == MAP_FAILED) | 855 | if (message == MAP_FAILED) |
846 | return MAILMH_ERROR_FILE; | 856 | return MAILMH_ERROR_FILE; |
847 | 857 | ||
848 | r = mailmh_folder_add_message(folder, message, buf.st_size); | 858 | r = mailmh_folder_add_message_uid(folder, message, buf.st_size, pindex); |
849 | 859 | ||
850 | munmap(message, buf.st_size); | 860 | munmap(message, buf.st_size); |
851 | 861 | ||
852 | return r; | 862 | return r; |
853 | } | 863 | } |
854 | 864 | ||
865 | int mailmh_folder_add_message_file(struct mailmh_folder * folder, | ||
866 | int fd) | ||
867 | { | ||
868 | return mailmh_folder_add_message_file_uid(folder, fd, NULL); | ||
869 | } | ||
870 | |||
855 | int mailmh_folder_remove_message(struct mailmh_folder * folder, | 871 | int mailmh_folder_remove_message(struct mailmh_folder * folder, |
856 | uint32_t index) | 872 | uint32_t index) |
857 | { | 873 | { |
858 | char * filename; | 874 | char * filename; |
859 | struct mailmh_msg_info * msg_info; | 875 | struct mailmh_msg_info * msg_info; |
860 | int res; | 876 | int res; |
861 | int r; | 877 | int r; |
862 | chashdatum key; | 878 | chashdatum key; |
diff --git a/kmicromail/libetpan/mh/mailmh.h b/kmicromail/libetpan/mh/mailmh.h index 40432cb..00199b8 100644 --- a/kmicromail/libetpan/mh/mailmh.h +++ b/kmicromail/libetpan/mh/mailmh.h | |||
@@ -114,19 +114,26 @@ int mailmh_folder_get_message_filename(struct mailmh_folder * folder, | |||
114 | uint32_t index, char ** result); | 114 | uint32_t index, char ** result); |
115 | 115 | ||
116 | int mailmh_folder_get_message_fd(struct mailmh_folder * folder, | 116 | int mailmh_folder_get_message_fd(struct mailmh_folder * folder, |
117 | uint32_t index, int flags, int * result); | 117 | uint32_t index, int flags, int * result); |
118 | 118 | ||
119 | int mailmh_folder_get_message_size(struct mailmh_folder * folder, | 119 | int mailmh_folder_get_message_size(struct mailmh_folder * folder, |
120 | uint32_t index, size_t * result); | 120 | uint32_t index, size_t * result); |
121 | 121 | ||
122 | int mailmh_folder_add_message_uid(struct mailmh_folder * folder, | ||
123 | const char * message, size_t size, | ||
124 | uint32_t * pindex); | ||
125 | |||
122 | int mailmh_folder_add_message(struct mailmh_folder * folder, | 126 | int mailmh_folder_add_message(struct mailmh_folder * folder, |
123 | const char * message, size_t size); | 127 | const char * message, size_t size); |
124 | 128 | ||
129 | int mailmh_folder_add_message_file_uid(struct mailmh_folder * folder, | ||
130 | int fd, uint32_t * pindex); | ||
131 | |||
125 | int mailmh_folder_add_message_file(struct mailmh_folder * folder, | 132 | int mailmh_folder_add_message_file(struct mailmh_folder * folder, |
126 | int fd); | 133 | int fd); |
127 | 134 | ||
128 | int mailmh_folder_remove_message(struct mailmh_folder * folder, | 135 | int mailmh_folder_remove_message(struct mailmh_folder * folder, |
129 | uint32_t index); | 136 | uint32_t index); |
130 | 137 | ||
131 | int mailmh_folder_move_message(struct mailmh_folder * dest_folder, | 138 | int mailmh_folder_move_message(struct mailmh_folder * dest_folder, |
132 | struct mailmh_folder * src_folder, | 139 | struct mailmh_folder * src_folder, |
diff --git a/kmicromail/libetpan/mime/mailmime_decode.c b/kmicromail/libetpan/mime/mailmime_decode.c index 3025dcb..e48ec19 100644 --- a/kmicromail/libetpan/mime/mailmime_decode.c +++ b/kmicromail/libetpan/mime/mailmime_decode.c | |||
@@ -182,26 +182,36 @@ int mailmime_encoded_phrase_parse(const char * default_fromcode, | |||
182 | } | 182 | } |
183 | } | 183 | } |
184 | type = TYPE_WORD; | 184 | type = TYPE_WORD; |
185 | 185 | ||
186 | wordutf8 = NULL; | 186 | wordutf8 = NULL; |
187 | r = charconv(tocode, default_fromcode, raw_word, | 187 | r = charconv(tocode, default_fromcode, raw_word, |
188 | strlen(raw_word), &wordutf8); | 188 | strlen(raw_word), &wordutf8); |
189 | 189 | ||
190 | if (wordutf8 != NULL) { | 190 | switch (r) { |
191 | if (mmap_string_append(gphrase, wordutf8) == NULL) { | 191 | case MAIL_CHARCONV_ERROR_MEMORY: |
192 | free(wordutf8); | 192 | free(raw_word); |
193 | free(raw_word); | 193 | res = MAILIMF_ERROR_MEMORY; |
194 | res = MAILIMF_ERROR_MEMORY; | 194 | goto free; |
195 | goto free; | ||
196 | } | ||
197 | 195 | ||
196 | case MAIL_CHARCONV_ERROR_UNKNOWN_CHARSET: | ||
197 | case MAIL_CHARCONV_ERROR_CONV: | ||
198 | free(raw_word); | ||
199 | res = MAILIMF_ERROR_PARSE; | ||
200 | goto free; | ||
201 | } | ||
202 | |||
203 | if (mmap_string_append(gphrase, wordutf8) == NULL) { | ||
198 | free(wordutf8); | 204 | free(wordutf8); |
205 | free(raw_word); | ||
206 | res = MAILIMF_ERROR_MEMORY; | ||
207 | goto free; | ||
199 | } | 208 | } |
209 | |||
200 | free(raw_word); | 210 | free(raw_word); |
201 | first = FALSE; | 211 | first = FALSE; |
202 | } | 212 | } |
203 | else if (r == MAILIMF_ERROR_PARSE) { | 213 | else if (r == MAILIMF_ERROR_PARSE) { |
204 | break; | 214 | break; |
205 | } | 215 | } |
206 | else { | 216 | else { |
207 | res = r; | 217 | res = r; |
diff --git a/kmicromail/libetpan/mime/mailmime_write.c b/kmicromail/libetpan/mime/mailmime_write.c index 5c3b1f7..208e3ba 100644 --- a/kmicromail/libetpan/mime/mailmime_write.c +++ b/kmicromail/libetpan/mime/mailmime_write.c | |||
@@ -436,17 +436,17 @@ mailmime_disposition_param_write(FILE * f, int * col, | |||
436 | strlen(param->pa_data.pa_modification_date); | 436 | strlen(param->pa_data.pa_modification_date); |
437 | break; | 437 | break; |
438 | 438 | ||
439 | case MAILMIME_DISPOSITION_PARM_READ_DATE: | 439 | case MAILMIME_DISPOSITION_PARM_READ_DATE: |
440 | len = strlen("read-date=") + strlen(param->pa_data.pa_read_date); | 440 | len = strlen("read-date=") + strlen(param->pa_data.pa_read_date); |
441 | break; | 441 | break; |
442 | 442 | ||
443 | case MAILMIME_DISPOSITION_PARM_SIZE: | 443 | case MAILMIME_DISPOSITION_PARM_SIZE: |
444 | snprintf(sizestr, 20, "%u", param->pa_data.pa_size); | 444 | snprintf(sizestr, 20, "%lu", (unsigned long) param->pa_data.pa_size); |
445 | len = strlen("size=") + strlen(sizestr); | 445 | len = strlen("size=") + strlen(sizestr); |
446 | break; | 446 | break; |
447 | 447 | ||
448 | case MAILMIME_DISPOSITION_PARM_PARAMETER: | 448 | case MAILMIME_DISPOSITION_PARM_PARAMETER: |
449 | len = strlen(param->pa_data.pa_parameter->pa_name) + 1 + | 449 | len = strlen(param->pa_data.pa_parameter->pa_name) + 1 + |
450 | strlen(param->pa_data.pa_parameter->pa_value); | 450 | strlen(param->pa_data.pa_parameter->pa_value); |
451 | break; | 451 | break; |
452 | 452 | ||
diff --git a/kmicromail/libetpan/smtp/mailsmtp.c b/kmicromail/libetpan/smtp/mailsmtp.c index b3be432..3ab1d11 100644 --- a/kmicromail/libetpan/smtp/mailsmtp.c +++ b/kmicromail/libetpan/smtp/mailsmtp.c | |||
@@ -187,16 +187,18 @@ int mailsmtp_helo(mailsmtp * session) | |||
187 | snprintf(command, SMTP_STRING_SIZE, "HELO %s\r\n", hostname); | 187 | snprintf(command, SMTP_STRING_SIZE, "HELO %s\r\n", hostname); |
188 | r = send_command(session, command); | 188 | r = send_command(session, command); |
189 | if (r == -1) | 189 | if (r == -1) |
190 | return MAILSMTP_ERROR_STREAM; | 190 | return MAILSMTP_ERROR_STREAM; |
191 | r = read_response(session); | 191 | r = read_response(session); |
192 | 192 | ||
193 | switch (r) { | 193 | switch (r) { |
194 | case 250: | 194 | case 250: |
195 | session->esmtp = 0; | ||
196 | session->auth = MAILSMTP_AUTH_NOT_CHECKED; | ||
195 | return MAILSMTP_NO_ERROR; | 197 | return MAILSMTP_NO_ERROR; |
196 | 198 | ||
197 | case 504: | 199 | case 504: |
198 | return MAILSMTP_ERROR_NOT_IMPLEMENTED; | 200 | return MAILSMTP_ERROR_NOT_IMPLEMENTED; |
199 | 201 | ||
200 | case 550: | 202 | case 550: |
201 | return MAILSMTP_ERROR_ACTION_NOT_TAKEN; | 203 | return MAILSMTP_ERROR_ACTION_NOT_TAKEN; |
202 | 204 | ||
diff --git a/kmicromail/libetpan/smtp/mailsmtp_helper.c b/kmicromail/libetpan/smtp/mailsmtp_helper.c index 32d6564..7995377 100644 --- a/kmicromail/libetpan/smtp/mailsmtp_helper.c +++ b/kmicromail/libetpan/smtp/mailsmtp_helper.c | |||
@@ -36,29 +36,25 @@ | |||
36 | #include "mailsmtp.h" | 36 | #include "mailsmtp.h" |
37 | #include <string.h> | 37 | #include <string.h> |
38 | #include <stdlib.h> | 38 | #include <stdlib.h> |
39 | #include "mail.h" | 39 | #include "mail.h" |
40 | 40 | ||
41 | int mailsmtp_init(mailsmtp * session) | 41 | int mailsmtp_init(mailsmtp * session) |
42 | { | 42 | { |
43 | int r; | 43 | int r; |
44 | session->esmtp = 0; | 44 | |
45 | r = mailesmtp_ehlo(session); | 45 | r = mailesmtp_ehlo(session); |
46 | 46 | ||
47 | if (r == MAILSMTP_NO_ERROR) { | 47 | if (r == MAILSMTP_NO_ERROR) |
48 | // session->esmtp = TRUE; | ||
49 | return MAILSMTP_NO_ERROR; | 48 | return MAILSMTP_NO_ERROR; |
50 | } | ||
51 | 49 | ||
52 | r = mailsmtp_helo(session); | 50 | r = mailsmtp_helo(session); |
53 | /* if (r == MAILSMTP_NO_ERROR) { */ | 51 | if (r == MAILSMTP_NO_ERROR) |
54 | /* session->esmtp = FALSE; */ | 52 | return MAILSMTP_NO_ERROR; |
55 | /* return MAILSMTP_NO_ERROR; */ | ||
56 | /* } */ | ||
57 | 53 | ||
58 | return r; | 54 | return r; |
59 | } | 55 | } |
60 | 56 | ||
61 | 57 | ||
62 | 58 | ||
63 | int mailesmtp_send(mailsmtp * session, | 59 | int mailesmtp_send(mailsmtp * session, |
64 | const char * from, | 60 | const char * from, |