961b0df2bd599c5874096d7e9cd5ec4795776929
[claws.git] / src / msgcache.c
1 /*
2  * Sylpheed -- a GTK+ based, lightweight, and fast e-mail client
3  * Copyright (C) 1999-2001 Hiroyuki Yamamoto
4  *
5  * This program is free software; you can redistribute it and/or modify
6  * it under the terms of the GNU General Public License as published by
7  * the Free Software Foundation; either version 2 of the License, or
8  * (at your option) any later version.
9  *
10  * This program is distributed in the hope that it will be useful,
11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
13  * GNU General Public License for more details.
14  *
15  * You should have received a copy of the GNU General Public License
16  * along with this program; if not, write to the Free Software
17  * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
18  */
19
20 #include "defs.h"
21
22 #include <glib.h>
23
24 #include <time.h>
25
26 #include "intl.h"
27 #include "msgcache.h"
28 #include "utils.h"
29 #include "procmsg.h"
30
31 struct _MsgCache {
32         GHashTable      *msgnum_table;
33         GHashTable      *msgid_table;
34         guint            memusage;
35         time_t           last_access;
36 };
37
38 MsgCache *msgcache_new()
39 {
40         MsgCache *cache;
41         
42         cache = g_new0(MsgCache, 1),
43         cache->msgnum_table = g_hash_table_new(g_int_hash, g_int_equal);
44         cache->msgid_table = g_hash_table_new(g_str_hash, g_str_equal);
45         cache->last_access = time(NULL);
46
47         return cache;
48 }
49
50 static gboolean msgcache_msginfo_free_func(gpointer num, gpointer msginfo, gpointer user_data)
51 {
52         procmsg_msginfo_free((MsgInfo *)msginfo);
53         return TRUE;
54 }                                                                                         
55
56 void msgcache_destroy(MsgCache *cache)
57 {
58         g_return_if_fail(cache != NULL);
59
60         g_hash_table_foreach_remove(cache->msgnum_table, msgcache_msginfo_free_func, NULL);
61         g_hash_table_destroy(cache->msgid_table);
62         g_hash_table_destroy(cache->msgnum_table);
63         g_free(cache);
64 }
65
66 void msgcache_add_msg(MsgCache *cache, MsgInfo *msginfo) 
67 {
68         MsgInfo *newmsginfo;
69
70         g_return_if_fail(cache != NULL);
71         g_return_if_fail(msginfo != NULL);
72
73         newmsginfo = procmsg_msginfo_new_ref(msginfo);
74         g_hash_table_insert(cache->msgnum_table, &newmsginfo->msgnum, newmsginfo);
75         if(newmsginfo->msgid != NULL)
76                 g_hash_table_insert(cache->msgid_table, newmsginfo->msgid, newmsginfo);
77         cache->memusage += procmsg_msginfo_memusage(msginfo);
78         cache->last_access = time(NULL);
79
80         debug_print("Cache size: %d messages, %d byte\n", g_hash_table_size(cache->msgnum_table), cache->memusage);
81 }
82
83 void msgcache_remove_msg(MsgCache *cache, guint msgnum)
84 {
85         MsgInfo *msginfo;
86
87         g_return_if_fail(cache != NULL);
88         g_return_if_fail(msgnum > 0);
89
90         msginfo = (MsgInfo *) g_hash_table_lookup(cache->msgnum_table, &msgnum);
91         if(!msginfo)
92                 return;
93
94         cache->memusage -= procmsg_msginfo_memusage(msginfo);
95         if(msginfo->msgid)
96                 g_hash_table_remove(cache->msgid_table, msginfo->msgid);
97         g_hash_table_remove(cache->msgnum_table, &msginfo->msgnum);
98         procmsg_msginfo_free(msginfo);
99         cache->last_access = time(NULL);
100
101         debug_print("Cache size: %d messages, %d byte\n", g_hash_table_size(cache->msgnum_table), cache->memusage);
102 }
103
104 void msgcache_update_msg(MsgCache *cache, MsgInfo *msginfo)
105 {
106         MsgInfo *oldmsginfo, *newmsginfo;
107         
108         g_return_if_fail(cache != NULL);
109         g_return_if_fail(msginfo != NULL);
110
111         oldmsginfo = g_hash_table_lookup(cache->msgnum_table, &msginfo->msgnum);
112         if(msginfo) {
113                 g_hash_table_remove(cache->msgid_table, oldmsginfo->msgid);
114                 g_hash_table_remove(cache->msgnum_table, &oldmsginfo->msgnum);
115                 procmsg_msginfo_free(oldmsginfo);
116         }
117         cache->memusage -= procmsg_msginfo_memusage(oldmsginfo);
118
119         newmsginfo = procmsg_msginfo_new_ref(msginfo);
120         g_hash_table_insert(cache->msgnum_table, &newmsginfo->msgnum, newmsginfo);
121         if(newmsginfo->msgid)
122                 g_hash_table_insert(cache->msgid_table, newmsginfo->msgid, newmsginfo);
123         cache->memusage += procmsg_msginfo_memusage(newmsginfo);
124         cache->last_access = time(NULL);
125         
126         debug_print("Cache size: %d messages, %d byte\n", g_hash_table_size(cache->msgnum_table), cache->memusage);
127
128         return;
129 }
130
131 static gint msgcache_read_cache_data_str(FILE *fp, gchar **str)
132 {
133         gchar buf[BUFFSIZE];
134         gint ret = 0;
135         size_t len;
136
137         if (fread(&len, sizeof(len), 1, fp) == 1) {
138                 if (len < 0)
139                         ret = -1;
140                 else {
141                         gchar *tmp = NULL;
142
143                         while (len > 0) {
144                                 size_t size = MIN(len, BUFFSIZE - 1);
145
146                                 if (fread(buf, size, 1, fp) != 1) {
147                                         ret = -1;
148                                         if (tmp) g_free(tmp);
149                                         *str = NULL;
150                                         break;
151                                 }
152
153                                 buf[size] = '\0';
154                                 if (tmp) {
155                                         *str = g_strconcat(tmp, buf, NULL);
156                                         g_free(tmp);
157                                         tmp = *str;
158                                 } else
159                                         tmp = *str = g_strdup(buf);
160
161                                 len -= size;
162                         }
163                 }
164         } else
165                 ret = -1;
166
167         if (ret < 0)
168                 g_warning("Cache data is corrupted\n");
169
170         return ret;
171 }
172
173
174 #define READ_CACHE_DATA(data, fp) \
175 { \
176         if (msgcache_read_cache_data_str(fp, &data) < 0) { \
177                 procmsg_msginfo_free(msginfo); \
178                 error = TRUE; \
179                 break; \
180         } \
181 }
182
183 #define READ_CACHE_DATA_INT(n, fp) \
184 { \
185         if (fread(&n, sizeof(n), 1, fp) != 1) { \
186                 g_warning("Cache data is corrupted\n"); \
187                 procmsg_msginfo_free(msginfo); \
188                 error = TRUE; \
189                 break; \
190         } \
191 }
192
193 MsgCache *msgcache_read_cache(FolderItem *item, const gchar *cache_file)
194 {
195         MsgCache *cache;
196         FILE *fp;
197         MsgInfo *msginfo;
198         MsgTmpFlags tmp_flags = 0;
199         gchar file_buf[BUFFSIZE];
200         gint ver;
201         guint num;
202         gboolean error = FALSE;
203
204         g_return_val_if_fail(cache_file != NULL, NULL);
205         g_return_val_if_fail(item != NULL, NULL);
206
207         if ((fp = fopen(cache_file, "rb")) == NULL) {
208                 debug_print("\tNo cache file\n");
209                 return NULL;
210         }
211         setvbuf(fp, file_buf, _IOFBF, sizeof(file_buf));
212
213         debug_print("\tReading message cache from %s...\n", cache_file);
214
215         /* compare cache version */
216         if (fread(&ver, sizeof(ver), 1, fp) != 1 ||
217             CACHE_VERSION != ver) {
218                 debug_print("Cache version is different. Discarding it.\n");
219                 fclose(fp);
220                 return NULL;
221         }
222
223         if (item->stype == F_QUEUE) {
224                 tmp_flags |= MSG_QUEUED;
225         } else if (item->stype == F_DRAFT) {
226                 tmp_flags |= MSG_DRAFT;
227         }
228
229         cache = msgcache_new();
230
231         g_hash_table_freeze(cache->msgnum_table);
232
233         while (fread(&num, sizeof(num), 1, fp) == 1) {
234                 msginfo = procmsg_msginfo_new();
235                 msginfo->msgnum = num;
236                 READ_CACHE_DATA_INT(msginfo->size, fp);
237                 READ_CACHE_DATA_INT(msginfo->mtime, fp);
238                 READ_CACHE_DATA_INT(msginfo->date_t, fp);
239                 READ_CACHE_DATA_INT(msginfo->flags.tmp_flags, fp);
240
241                 READ_CACHE_DATA(msginfo->fromname, fp);
242
243                 READ_CACHE_DATA(msginfo->date, fp);
244                 READ_CACHE_DATA(msginfo->from, fp);
245                 READ_CACHE_DATA(msginfo->to, fp);
246                 READ_CACHE_DATA(msginfo->cc, fp);
247                 READ_CACHE_DATA(msginfo->newsgroups, fp);
248                 READ_CACHE_DATA(msginfo->subject, fp);
249                 READ_CACHE_DATA(msginfo->msgid, fp);
250                 READ_CACHE_DATA(msginfo->inreplyto, fp);
251                 READ_CACHE_DATA(msginfo->references, fp);
252                 READ_CACHE_DATA(msginfo->xref, fp);
253
254                 msginfo->folder = item;
255                 msginfo->flags.tmp_flags |= tmp_flags;
256
257                 g_hash_table_insert(cache->msgnum_table, &msginfo->msgnum, msginfo);
258                 if(msginfo->msgid)
259                         g_hash_table_insert(cache->msgid_table, msginfo->msgid, msginfo);
260                 cache->memusage += procmsg_msginfo_memusage(msginfo);
261         }
262         fclose(fp);
263
264         if(error) {
265                 g_hash_table_thaw(cache->msgnum_table);
266                 msgcache_destroy(cache);
267                 return NULL;
268         }
269
270         cache->last_access = time(NULL);
271         g_hash_table_thaw(cache->msgnum_table);
272
273         debug_print("done. (%d items read)\n", g_hash_table_size(cache->msgnum_table));
274         debug_print("Cache size: %d messages, %d byte\n", g_hash_table_size(cache->msgnum_table), cache->memusage);
275
276         return cache;
277 }
278
279 void msgcache_read_mark(MsgCache *cache, const gchar *mark_file)
280 {
281         FILE *fp;
282         MsgInfo *msginfo;
283         MsgPermFlags perm_flags;
284         gint ver;
285         guint num;
286
287         if ((fp = fopen(mark_file, "rb")) == NULL) {
288                 debug_print("Mark file not found.\n");
289                 return;
290         } else if (fread(&ver, sizeof(ver), 1, fp) != 1 || MARK_VERSION != ver) {
291                 debug_print("Mark version is different (%d != %d). "
292                               "Discarding it.\n", ver, MARK_VERSION);
293         } else {
294                 debug_print("\tReading message marks from %s...\n", mark_file);
295
296                 while (fread(&num, sizeof(num), 1, fp) == 1) {
297                         if (fread(&perm_flags, sizeof(perm_flags), 1, fp) != 1) break;
298
299                         msginfo = g_hash_table_lookup(cache->msgnum_table, &num);
300                         if(msginfo) {
301                                 msginfo->flags.perm_flags = perm_flags;
302                         }
303                 }
304         }
305         fclose(fp);
306 }
307
308 #define WRITE_CACHE_DATA_INT(n, fp) \
309         fwrite(&n, sizeof(n), 1, fp)
310
311 #define WRITE_CACHE_DATA(data, fp) \
312 { \
313         gint len; \
314         if (data == NULL) \
315                 len = 0; \
316         else \
317                 len = strlen(data); \
318         WRITE_CACHE_DATA_INT(len, fp); \
319         if (len > 0) { \
320                 fwrite(data, len, 1, fp); \
321         } \
322 }
323
324 void msgcache_write_cache(MsgInfo *msginfo, FILE *fp)
325 {
326         MsgTmpFlags flags = msginfo->flags.tmp_flags & MSG_CACHED_FLAG_MASK;
327
328         WRITE_CACHE_DATA_INT(msginfo->msgnum, fp);
329         WRITE_CACHE_DATA_INT(msginfo->size, fp);
330         WRITE_CACHE_DATA_INT(msginfo->mtime, fp);
331         WRITE_CACHE_DATA_INT(msginfo->date_t, fp);
332         WRITE_CACHE_DATA_INT(flags, fp);
333
334         WRITE_CACHE_DATA(msginfo->fromname, fp);
335
336         WRITE_CACHE_DATA(msginfo->date, fp);
337         WRITE_CACHE_DATA(msginfo->from, fp);
338         WRITE_CACHE_DATA(msginfo->to, fp);
339         WRITE_CACHE_DATA(msginfo->cc, fp);
340         WRITE_CACHE_DATA(msginfo->newsgroups, fp);
341         WRITE_CACHE_DATA(msginfo->subject, fp);
342         WRITE_CACHE_DATA(msginfo->msgid, fp);
343         WRITE_CACHE_DATA(msginfo->inreplyto, fp);
344         WRITE_CACHE_DATA(msginfo->references, fp);
345         WRITE_CACHE_DATA(msginfo->xref, fp);
346 }
347
348 static void msgcache_write_flags(MsgInfo *msginfo, FILE *fp)
349 {
350         MsgPermFlags flags = msginfo->flags.perm_flags;
351
352         WRITE_CACHE_DATA_INT(msginfo->msgnum, fp);
353         WRITE_CACHE_DATA_INT(flags, fp);
354 }
355
356 struct write_fps
357 {
358         FILE *cache_fp;
359         FILE *mark_fp;
360 };
361
362 static void msgcache_write_func(gpointer key, gpointer value, gpointer user_data)
363 {
364         MsgInfo *msginfo;
365         struct write_fps *write_fps;
366
367         msginfo = (MsgInfo *)value;
368         write_fps = user_data;
369
370         msgcache_write_cache(msginfo, write_fps->cache_fp);
371         msgcache_write_flags(msginfo, write_fps->mark_fp);
372 }
373
374 gint msgcache_write(const gchar *cache_file, const gchar *mark_file, MsgCache *cache)
375 {
376         FILE *fp;
377         struct write_fps write_fps;
378         gint ver;
379
380         g_return_val_if_fail(cache_file != NULL, -1);
381         g_return_val_if_fail(mark_file != NULL, -1);
382         g_return_val_if_fail(cache != NULL, -1);
383
384         debug_print("\tWriting message cache to %s and %s...\n", cache_file, mark_file);
385
386         if ((fp = fopen(cache_file, "wb")) == NULL) {
387                 FILE_OP_ERROR(cache_file, "fopen");
388                 return -1;
389         }
390         if (change_file_mode_rw(fp, cache_file) < 0)
391                 FILE_OP_ERROR(cache_file, "chmod");
392
393         ver = CACHE_VERSION;
394         WRITE_CACHE_DATA_INT(ver, fp);  
395         write_fps.cache_fp = fp;
396
397         if ((fp = fopen(mark_file, "wb")) == NULL) {
398                 FILE_OP_ERROR(mark_file, "fopen");
399                 fclose(write_fps.cache_fp);
400                 return -1;
401         }
402
403         ver = MARK_VERSION;
404         WRITE_CACHE_DATA_INT(ver, fp);
405         write_fps.mark_fp = fp;
406
407         g_hash_table_foreach(cache->msgnum_table, msgcache_write_func, (gpointer)&write_fps);
408
409         fclose(write_fps.cache_fp);
410         fclose(write_fps.mark_fp);
411
412         cache->last_access = time(NULL);
413
414         debug_print("done.\n");
415         return 0;
416 }
417
418 MsgInfo *msgcache_get_msg(MsgCache *cache, guint num)
419 {
420         MsgInfo *msginfo;
421
422         g_return_val_if_fail(cache != NULL, NULL);
423
424         msginfo = g_hash_table_lookup(cache->msgnum_table, &num);
425         if(!msginfo)
426                 return NULL;
427         cache->last_access = time(NULL);
428         
429         return procmsg_msginfo_new_ref(msginfo);
430 }
431
432 MsgInfo *msgcache_get_msg_by_id(MsgCache *cache, const gchar *msgid)
433 {
434         MsgInfo *msginfo;
435         
436         g_return_val_if_fail(cache != NULL, NULL);
437
438         msginfo = g_hash_table_lookup(cache->msgid_table, msgid);
439         if(!msginfo)
440                 return NULL;
441         cache->last_access = time(NULL);
442         
443         return procmsg_msginfo_new_ref(msginfo);        
444 }
445
446 static void msgcache_get_msg_list_func(gpointer key, gpointer value, gpointer user_data)
447 {
448         MsgInfoList **listptr = user_data;
449         MsgInfo *msginfo = value;
450
451         *listptr = g_slist_prepend(*listptr, procmsg_msginfo_new_ref(msginfo));
452 }
453
454 MsgInfoList *msgcache_get_msg_list(MsgCache *cache)
455 {
456         MsgInfoList *msg_list = NULL;
457
458         g_return_val_if_fail(cache != NULL, NULL);
459
460         g_hash_table_foreach((GHashTable *)cache->msgnum_table, msgcache_get_msg_list_func, (gpointer)&msg_list);       
461         cache->last_access = time(NULL);
462         
463         msg_list = g_slist_reverse(msg_list);
464
465         return msg_list;
466 }
467
468 time_t msgcache_get_last_access_time(MsgCache *cache)
469 {
470         g_return_val_if_fail(cache != NULL, 0);
471         
472         return cache->last_access;
473 }
474
475 gint msgcache_get_memory_usage(MsgCache *cache)
476 {
477         g_return_val_if_fail(cache != NULL, 0);
478
479         return cache->memusage;
480 }