1 /*
2 * Sylpheed -- a GTK+ based, lightweight, and fast e-mail client
3 * Copyright (C) 1999-2012 Hiroyuki Yamamoto and the Claws Mail team
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 3 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, see <http://www.gnu.org/licenses/>.
17 *
18 */
19
20 #ifdef HAVE_CONFIG_H
21 # include "config.h"
22 #include "claws-features.h"
23 #endif
24
25 #ifdef HAVE_LIBETPAN
26
27 #include "defs.h"
28
29 #include <glib.h>
30 #include <glib/gi18n.h>
31 #include <stdio.h>
32 #include <string.h>
33 #include <stdlib.h>
34 #include <dirent.h>
35 #include <unistd.h>
36 #include <time.h>
37 #include <libetpan/libetpan.h>
38
39 #include "nntp-thread.h"
40 #include "news.h"
41 #include "news_gtk.h"
42 #include "socket.h"
43 #include "recv.h"
44 #include "procmsg.h"
45 #include "procheader.h"
46 #include "folder.h"
47 #include "session.h"
48 #include "statusbar.h"
49 #include "codeconv.h"
50 #include "utils.h"
51 #include "passwordstore.h"
52 #include "prefs_common.h"
53 #include "prefs_account.h"
54 #include "inputdialog.h"
55 #include "log.h"
56 #include "progressindicator.h"
57 #include "remotefolder.h"
58 #include "alertpanel.h"
59 #include "inc.h"
60 #include "account.h"
61 #ifdef USE_GNUTLS
62 # include "ssl.h"
63 #endif
64 #include "main.h"
65 #include "file-utils.h"
66
67 #define NNTP_PORT 119
68 #ifdef USE_GNUTLS
69 #define NNTPS_PORT 563
70 #endif
71
72 typedef struct _NewsFolder NewsFolder;
73 typedef struct _NewsSession NewsSession;
74
75 #define NEWS_FOLDER(obj) ((NewsFolder *)obj)
76 #define NEWS_SESSION(obj) ((NewsSession *)obj)
77
78 struct _NewsFolder
79 {
80 RemoteFolder rfolder;
81
82 gboolean use_auth;
83 gboolean lock_count;
84 guint refcnt;
85 };
86
87 struct _NewsSession
88 {
89 Session session;
90 Folder *folder;
91 gchar *group;
92 };
93
94 static void news_folder_init(Folder *folder, const gchar *name,
95 const gchar *path);
96
97 static Folder *news_folder_new (const gchar *name,
98 const gchar *folder);
99 static void news_folder_destroy (Folder *folder);
100
101 static gchar *news_fetch_msg (Folder *folder,
102 FolderItem *item,
103 gint num);
104 static void news_remove_cached_msg (Folder *folder,
105 FolderItem *item,
106 MsgInfo *msginfo);
107 #ifdef USE_GNUTLS
108 static Session *news_session_new (Folder *folder,
109 const PrefsAccount *account,
110 gushort port,
111 SSLType ssl_type);
112 #else
113 static Session *news_session_new (Folder *folder,
114 const PrefsAccount *account,
115 gushort port);
116 #endif
117
118 static gint news_get_article (Folder *folder,
119 gint num,
120 gchar *filename);
121
122 static gint news_select_group (Folder *folder,
123 const gchar *group,
124 gint *num,
125 gint *first,
126 gint *last);
127 static MsgInfo *news_parse_xover (struct newsnntp_xover_resp_item *item);
128 static gint news_get_num_list (Folder *folder,
129 FolderItem *item,
130 GSList **list,
131 gboolean *old_uids_valid);
132 static MsgInfo *news_get_msginfo (Folder *folder,
133 FolderItem *item,
134 gint num);
135 static GSList *news_get_msginfos (Folder *folder,
136 FolderItem *item,
137 GSList *msgnum_list);
138 static gboolean news_scan_required (Folder *folder,
139 FolderItem *item);
140
141 static gchar *news_folder_get_path (Folder *folder);
142 static gchar *news_item_get_path (Folder *folder,
143 FolderItem *item);
144 static void news_synchronise (FolderItem *item, gint days);
145 static int news_remove_msg (Folder *folder,
146 FolderItem *item,
147 gint msgnum);
148 static gint news_rename_folder (Folder *folder,
149 FolderItem *item,
150 const gchar *name);
151 static gint news_remove_folder (Folder *folder,
152 FolderItem *item);
153 static FolderClass news_class;
154
news_get_class(void)155 FolderClass *news_get_class(void)
156 {
157 if (news_class.idstr == NULL) {
158 news_class.type = F_NEWS;
159 news_class.idstr = "news";
160 news_class.uistr = "News";
161 news_class.supports_server_search = FALSE;
162
163 /* Folder functions */
164 news_class.new_folder = news_folder_new;
165 news_class.destroy_folder = news_folder_destroy;
166
167 /* FolderItem functions */
168 news_class.item_get_path = news_item_get_path;
169 news_class.get_num_list = news_get_num_list;
170 news_class.scan_required = news_scan_required;
171 news_class.rename_folder = news_rename_folder;
172 news_class.remove_folder = news_remove_folder;
173
174 /* Message functions */
175 news_class.get_msginfo = news_get_msginfo;
176 news_class.get_msginfos = news_get_msginfos;
177 news_class.fetch_msg = news_fetch_msg;
178 news_class.synchronise = news_synchronise;
179 news_class.search_msgs = folder_item_search_msgs_local;
180 news_class.remove_msg = news_remove_msg;
181 news_class.remove_cached_msg = news_remove_cached_msg;
182 };
183
184 return &news_class;
185 }
186
nntp_folder_get_refcnt(Folder * folder)187 guint nntp_folder_get_refcnt(Folder *folder)
188 {
189 return ((NewsFolder *)folder)->refcnt;
190 }
191
nntp_folder_ref(Folder * folder)192 void nntp_folder_ref(Folder *folder)
193 {
194 ((NewsFolder *)folder)->refcnt++;
195 }
196
nntp_folder_unref(Folder * folder)197 void nntp_folder_unref(Folder *folder)
198 {
199 if (((NewsFolder *)folder)->refcnt > 0)
200 ((NewsFolder *)folder)->refcnt--;
201 }
202
news_remove_msg(Folder * folder,FolderItem * item,gint msgnum)203 static int news_remove_msg (Folder *folder,
204 FolderItem *item,
205 gint msgnum)
206 {
207 gchar *path, *filename;
208
209 cm_return_val_if_fail(folder != NULL, -1);
210 cm_return_val_if_fail(item != NULL, -1);
211
212 path = folder_item_get_path(item);
213 if (!is_dir_exist(path))
214 make_dir_hier(path);
215
216 filename = g_strconcat(path, G_DIR_SEPARATOR_S, itos(msgnum), NULL);
217 g_free(path);
218 claws_unlink(filename);
219 g_free(filename);
220 return 0;
221 }
222
news_folder_lock(NewsFolder * folder)223 static void news_folder_lock(NewsFolder *folder)
224 {
225 folder->lock_count++;
226 }
227
news_folder_unlock(NewsFolder * folder)228 static void news_folder_unlock(NewsFolder *folder)
229 {
230 if (folder->lock_count > 0)
231 folder->lock_count--;
232 }
233
news_folder_locked(Folder * folder)234 int news_folder_locked(Folder *folder)
235 {
236 if (folder == NULL)
237 return 0;
238
239 return NEWS_FOLDER(folder)->lock_count;
240 }
241
news_folder_new(const gchar * name,const gchar * path)242 static Folder *news_folder_new(const gchar *name, const gchar *path)
243 {
244 Folder *folder;
245
246 folder = (Folder *)g_new0(NewsFolder, 1);
247 folder->klass = &news_class;
248 news_folder_init(folder, name, path);
249
250 return folder;
251 }
252
news_folder_destroy(Folder * folder)253 static void news_folder_destroy(Folder *folder)
254 {
255 gchar *dir;
256
257 while (nntp_folder_get_refcnt(folder) > 0)
258 gtk_main_iteration();
259
260 dir = news_folder_get_path(folder);
261 if (is_dir_exist(dir))
262 remove_dir_recursive(dir);
263 g_free(dir);
264
265 nntp_done(folder);
266 folder_remote_folder_destroy(REMOTE_FOLDER(folder));
267 }
268
news_folder_init(Folder * folder,const gchar * name,const gchar * path)269 static void news_folder_init(Folder *folder, const gchar *name,
270 const gchar *path)
271 {
272 folder_remote_folder_init(folder, name, path);
273 }
274
news_session_destroy(Session * session)275 static void news_session_destroy(Session *session)
276 {
277 NewsSession *news_session = NEWS_SESSION(session);
278
279 cm_return_if_fail(session != NULL);
280
281 if (news_session->group)
282 g_free(news_session->group);
283 }
284
nntp_ping(gpointer data)285 static gboolean nntp_ping(gpointer data)
286 {
287 Session *session = (Session *)data;
288 NewsSession *news_session = NEWS_SESSION(session);
289 int r;
290 struct tm lt;
291
292 if (session->state != SESSION_READY || news_folder_locked(news_session->folder))
293 return FALSE;
294
295 news_folder_lock(NEWS_FOLDER(news_session->folder));
296
297 if ((r = nntp_threaded_date(news_session->folder, <)) != NEWSNNTP_NO_ERROR) {
298 if (r != NEWSNNTP_ERROR_COMMAND_NOT_SUPPORTED &&
299 r != NEWSNNTP_ERROR_COMMAND_NOT_UNDERSTOOD) {
300 log_warning(LOG_PROTOCOL, _("NNTP connection to %s:%d has been"
301 " disconnected.\n"),
302 news_session->folder->account->nntp_server,
303 news_session->folder->account->set_nntpport ?
304 news_session->folder->account->nntpport : NNTP_PORT);
305 REMOTE_FOLDER(news_session->folder)->session = NULL;
306 news_folder_unlock(NEWS_FOLDER(news_session->folder));
307 session->state = SESSION_DISCONNECTED;
308 session->sock = NULL;
309 session_destroy(session);
310 return FALSE;
311 }
312 }
313
314 news_folder_unlock(NEWS_FOLDER(news_session->folder));
315 session_set_access_time(session);
316 return TRUE;
317 }
318
319
320 #ifdef USE_GNUTLS
news_session_new(Folder * folder,const PrefsAccount * account,gushort port,SSLType ssl_type)321 static Session *news_session_new(Folder *folder, const PrefsAccount *account, gushort port,
322 SSLType ssl_type)
323 #else
324 static Session *news_session_new(Folder *folder, const PrefsAccount *account, gushort port)
325 #endif
326 {
327 NewsSession *session;
328 const char *server = account->nntp_server;
329 int r = 0;
330 ProxyInfo *proxy_info = NULL;
331
332 cm_return_val_if_fail(server != NULL, NULL);
333
334 log_message(LOG_PROTOCOL,
335 _("Account '%s': Connecting to NNTP server: %s:%d...\n"),
336 folder->account->account_name, server, port);
337
338 session = g_new0(NewsSession, 1);
339 session_init(SESSION(session), folder->account, FALSE);
340 SESSION(session)->type = SESSION_NEWS;
341 SESSION(session)->server = g_strdup(server);
342 SESSION(session)->port = port;
343 SESSION(session)->sock = NULL;
344 SESSION(session)->destroy = news_session_destroy;
345
346 if (account->use_proxy) {
347 if (account->use_default_proxy) {
348 proxy_info = (ProxyInfo *)&(prefs_common.proxy_info);
349 if (proxy_info->use_proxy_auth)
350 proxy_info->proxy_pass = passwd_store_get(PWS_CORE, PWS_CORE_PROXY,
351 PWS_CORE_PROXY_PASS);
352 } else {
353 proxy_info = (ProxyInfo *)&(account->proxy_info);
354 if (proxy_info->use_proxy_auth)
355 proxy_info->proxy_pass = passwd_store_get_account(account->account_id,
356 PWS_ACCOUNT_PROXY_PASS);
357 }
358 }
359 SESSION(session)->proxy_info = proxy_info;
360
361 nntp_init(folder);
362
363 #ifdef USE_GNUTLS
364 SESSION(session)->use_tls_sni = account->use_tls_sni;
365 if (ssl_type != SSL_NONE)
366 r = nntp_threaded_connect_ssl(folder, server, port, proxy_info);
367 else
368 #endif
369 r = nntp_threaded_connect(folder, server, port, proxy_info);
370
371 if (r != NEWSNNTP_NO_ERROR) {
372 log_error(LOG_PROTOCOL, _("Error logging in to %s:%d...\n"), server, port);
373 session_destroy(SESSION(session));
374 return NULL;
375 }
376
377 session->folder = folder;
378
379 return SESSION(session);
380 }
381
news_session_new_for_folder(Folder * folder)382 static Session *news_session_new_for_folder(Folder *folder)
383 {
384 Session *session;
385 PrefsAccount *ac;
386 const gchar *userid = NULL;
387 gchar *passwd = NULL;
388 gushort port;
389 int r;
390
391 cm_return_val_if_fail(folder != NULL, NULL);
392 cm_return_val_if_fail(folder->account != NULL, NULL);
393
394 ac = folder->account;
395
396 #ifdef USE_GNUTLS
397 port = ac->set_nntpport ? ac->nntpport
398 : ac->ssl_nntp ? NNTPS_PORT : NNTP_PORT;
399 session = news_session_new(folder, ac, port, ac->ssl_nntp);
400 #else
401 if (ac->ssl_nntp != SSL_NONE) {
402 if (alertpanel_full(_("Insecure connection"),
403 _("This connection is configured to be secured "
404 "using SSL/TLS, but SSL/TLS is not available "
405 "in this build of Claws Mail. \n\n"
406 "Do you want to continue connecting to this "
407 "server? The communication would not be "
408 "secure."),
409 GTK_STOCK_CANCEL, _("Con_tinue connecting"), NULL,
410 ALERTFOCUS_FIRST, FALSE, NULL, ALERT_WARNING) != G_ALERTALTERNATE)
411 return NULL;
412 }
413 port = ac->set_nntpport ? ac->nntpport : NNTP_PORT;
414 session = news_session_new(folder, ac, port);
415 #endif
416
417 if (ac->use_nntp_auth && ac->userid && ac->userid[0]) {
418 userid = ac->userid;
419 if (password_get(userid, ac->nntp_server, "nntp", port, &passwd)) {
420 /* NOP */;
421 } else if ((passwd = passwd_store_get_account(ac->account_id,
422 PWS_ACCOUNT_RECV)) == NULL) {
423 passwd = input_dialog_query_password_keep(ac->nntp_server,
424 userid,
425 &(ac->session_passwd));
426 }
427 }
428
429 if (session != NULL)
430 r = nntp_threaded_mode_reader(folder);
431 else
432 r = NEWSNNTP_ERROR_CONNECTION_REFUSED;
433
434 if (r != NEWSNNTP_NO_ERROR) {
435 if (r == NEWSNNTP_WARNING_REQUEST_AUTHORIZATION_USERNAME) {
436 /*
437 FIX ME when libetpan implements 480 to indicate authorization
438 is required to use this capability. Libetpan treats a 480 as a
439 381 which is clearly wrong.
440 RFC 4643 section 2.
441 Response code 480
442 Generic response
443 Meaning: command unavailable until the client
444 has authenticated itself.
445 */
446 /* if the server does not advertise the capability MODE-READER,
447 we normally should not send MODE READER. However this can't
448 hurt: a transit-only server returns 502 and closes the cnx.
449 Ref.: http://tools.ietf.org/html/rfc3977#section-5.3
450 */
451 log_error(LOG_PROTOCOL, _("Libetpan does not support return code 480 "
452 "so for now we choose to continue\n"));
453 }
454 else if (r == NEWSNNTP_ERROR_UNEXPECTED_RESPONSE) {
455 /* if the server does not advertise the capability MODE-READER,
456 we normally should not send MODE READER. However this can't
457 hurt: a transit-only server returns 502 and closes the cnx.
458 Ref.: http://tools.ietf.org/html/rfc3977#section-5.3
459 */
460 log_error(LOG_PROTOCOL, _("Mode reader failed, continuing nevertheless\n"));
461 }
462 else {
463 /* An error state bail out */
464 log_error(LOG_PROTOCOL, _("Error creating session with %s:%d\n"), ac->nntp_server, port);
465 if (session != NULL)
466 session_destroy(SESSION(session));
467 g_free(passwd);
468 if (ac->session_passwd) {
469 g_free(ac->session_passwd);
470 ac->session_passwd = NULL;
471 }
472 return NULL;
473 }
474 }
475
476 if ((session != NULL) && ac->use_nntp_auth) { /* FIXME: && ac->use_nntp_auth_onconnect */
477 if (nntp_threaded_login(folder, userid, passwd) !=
478 NEWSNNTP_NO_ERROR) {
479 log_error(LOG_PROTOCOL, _("Error authenticating to %s:%d...\n"), ac->nntp_server, port);
480 session_destroy(SESSION(session));
481 g_free(passwd);
482 if (ac->session_passwd) {
483 g_free(ac->session_passwd);
484 ac->session_passwd = NULL;
485 }
486 return NULL;
487 }
488 }
489 g_free(passwd);
490
491 return session;
492 }
493
news_session_get(Folder * folder)494 static NewsSession *news_session_get(Folder *folder)
495 {
496 RemoteFolder *rfolder = REMOTE_FOLDER(folder);
497
498 cm_return_val_if_fail(folder != NULL, NULL);
499 cm_return_val_if_fail(FOLDER_CLASS(folder) == &news_class, NULL);
500 cm_return_val_if_fail(folder->account != NULL, NULL);
501
502 if (prefs_common.work_offline &&
503 !inc_offline_should_override(FALSE,
504 _("Claws Mail needs network access in order "
505 "to access the News server."))) {
506 return NULL;
507 }
508
509 if (!rfolder->session) {
510 rfolder->session = news_session_new_for_folder(folder);
511 session_register_ping(SESSION(rfolder->session), nntp_ping);
512 return NEWS_SESSION(rfolder->session);
513 }
514
515 /* Handle port change (also ssl/nossl change) without needing to
516 * restart application. */
517 if (rfolder->session->port != folder->account->nntpport) {
518 session_destroy(rfolder->session);
519 rfolder->session = news_session_new_for_folder(folder);
520 session_register_ping(SESSION(rfolder->session), nntp_ping);
521 goto newsession;
522 }
523
524 if (time(NULL) - rfolder->session->last_access_time <
525 SESSION_TIMEOUT_INTERVAL) {
526 return NEWS_SESSION(rfolder->session);
527 }
528
529 if (!nntp_ping(rfolder->session)) {
530 rfolder->session = news_session_new_for_folder(folder);
531 session_register_ping(SESSION(rfolder->session), nntp_ping);
532 }
533
534 newsession:
535 if (rfolder->session)
536 session_set_access_time(rfolder->session);
537
538 return NEWS_SESSION(rfolder->session);
539 }
540
news_remove_cached_msg(Folder * folder,FolderItem * item,MsgInfo * msginfo)541 static void news_remove_cached_msg(Folder *folder, FolderItem *item, MsgInfo *msginfo)
542 {
543 gchar *path, *filename;
544
545 path = folder_item_get_path(item);
546
547 if (!is_dir_exist(path)) {
548 g_free(path);
549 return;
550 }
551
552 filename = g_strconcat(path, G_DIR_SEPARATOR_S, itos(msginfo->msgnum), NULL);
553 g_free(path);
554
555 if (is_file_exist(filename)) {
556 claws_unlink(filename);
557 }
558 g_free(filename);
559 }
560
news_fetch_msg(Folder * folder,FolderItem * item,gint num)561 static gchar *news_fetch_msg(Folder *folder, FolderItem *item, gint num)
562 {
563 gchar *path, *filename;
564 NewsSession *session;
565 gint ok;
566
567 cm_return_val_if_fail(folder != NULL, NULL);
568 cm_return_val_if_fail(item != NULL, NULL);
569
570 path = folder_item_get_path(item);
571 if (!is_dir_exist(path))
572 make_dir_hier(path);
573 filename = g_strconcat(path, G_DIR_SEPARATOR_S, itos(num), NULL);
574 g_free(path);
575
576 if (is_file_exist(filename)) {
577 debug_print("article %d has been already cached.\n", num);
578 return filename;
579 }
580
581 session = news_session_get(folder);
582 if (!session) {
583 g_free(filename);
584 return NULL;
585 }
586
587 ok = news_select_group(folder, item->path, NULL, NULL, NULL);
588 if (ok != NEWSNNTP_NO_ERROR) {
589 if (ok == NEWSNNTP_ERROR_STREAM) {
590 session_destroy(SESSION(session));
591 REMOTE_FOLDER(folder)->session = NULL;
592 }
593 g_free(filename);
594 return NULL;
595 }
596
597 debug_print("getting article %d...\n", num);
598 ok = news_get_article(folder,
599 num, filename);
600 if (ok != NEWSNNTP_NO_ERROR) {
601 g_warning("can't read article %d", num);
602 if (ok == NEWSNNTP_ERROR_STREAM) {
603 session_destroy(SESSION(session));
604 REMOTE_FOLDER(folder)->session = NULL;
605 }
606 g_free(filename);
607 return NULL;
608 }
609 GTK_EVENTS_FLUSH();
610 return filename;
611 }
612
news_group_info_new(const gchar * name,gint first,gint last,gchar type)613 static NewsGroupInfo *news_group_info_new(const gchar *name,
614 gint first, gint last, gchar type)
615 {
616 NewsGroupInfo *ginfo;
617
618 ginfo = g_new(NewsGroupInfo, 1);
619 ginfo->name = g_strdup(name);
620 ginfo->first = first;
621 ginfo->last = last;
622 ginfo->type = type;
623
624 return ginfo;
625 }
626
news_group_info_free(NewsGroupInfo * ginfo)627 static void news_group_info_free(NewsGroupInfo *ginfo)
628 {
629 g_free(ginfo->name);
630 g_free(ginfo);
631 }
632
news_group_info_compare(NewsGroupInfo * ginfo1,NewsGroupInfo * ginfo2)633 static gint news_group_info_compare(NewsGroupInfo *ginfo1,
634 NewsGroupInfo *ginfo2)
635 {
636 return g_ascii_strcasecmp(ginfo1->name, ginfo2->name);
637 }
638
news_get_group_list(Folder * folder)639 GSList *news_get_group_list(Folder *folder)
640 {
641 gchar *path, *filename;
642 FILE *fp;
643 GSList *list = NULL;
644 GSList *last = NULL;
645 gchar buf[BUFFSIZE];
646
647 cm_return_val_if_fail(folder != NULL, NULL);
648 cm_return_val_if_fail(FOLDER_CLASS(folder) == &news_class, NULL);
649
650 path = folder_item_get_path(FOLDER_ITEM(folder->node->data));
651 if (!is_dir_exist(path))
652 make_dir_hier(path);
653 filename = g_strconcat(path, G_DIR_SEPARATOR_S, NEWSGROUP_LIST, NULL);
654 g_free(path);
655
656 if ((fp = claws_fopen(filename, "rb")) == NULL) {
657 NewsSession *session;
658 gint ok;
659 clist *grouplist = NULL;
660 clistiter *cur;
661 fp = claws_fopen(filename, "wb");
662
663 if (!fp) {
664 g_free(filename);
665 return NULL;
666 }
667 session = news_session_get(folder);
668 if (!session) {
669 claws_fclose(fp);
670 g_free(filename);
671 return NULL;
672 }
673
674 ok = nntp_threaded_list(folder, &grouplist);
675
676 if (ok != NEWSNNTP_NO_ERROR) {
677 if (ok == NEWSNNTP_ERROR_STREAM) {
678 session_destroy(SESSION(session));
679 REMOTE_FOLDER(folder)->session = NULL;
680 }
681 claws_fclose(fp);
682 g_free(filename);
683 return NULL;
684 }
685
686 if (grouplist) {
687 for (cur = clist_begin(grouplist); cur; cur = clist_next(cur)) {
688 struct newsnntp_group_info *info = (struct newsnntp_group_info *)
689 clist_content(cur);
690 if (fprintf(fp, "%s %d %d %c\n",
691 info->grp_name,
692 info->grp_last,
693 info->grp_first,
694 info->grp_type) < 0) {
695 log_error(LOG_PROTOCOL, ("Can't write newsgroup list\n"));
696 session_destroy(SESSION(session));
697 REMOTE_FOLDER(folder)->session = NULL;
698 claws_fclose(fp);
699 g_free(filename);
700 newsnntp_list_free(grouplist);
701 return NULL;
702 }
703 }
704 newsnntp_list_free(grouplist);
705 }
706 if (claws_safe_fclose(fp) == EOF) {
707 log_error(LOG_PROTOCOL, ("Can't write newsgroup list\n"));
708 session_destroy(SESSION(session));
709 REMOTE_FOLDER(folder)->session = NULL;
710 g_free(filename);
711 return NULL;
712 }
713
714 if ((fp = claws_fopen(filename, "rb")) == NULL) {
715 FILE_OP_ERROR(filename, "claws_fopen");
716 g_free(filename);
717 return NULL;
718 }
719 }
720
721 while (claws_fgets(buf, sizeof(buf), fp) != NULL) {
722 gchar *p = buf;
723 gchar *name;
724 gint last_num;
725 gint first_num;
726 gchar type;
727 NewsGroupInfo *ginfo;
728
729 p = strchr(p, ' ');
730 if (!p) continue;
731 *p = '\0';
732 p++;
733 name = buf;
734
735 if (sscanf(p, "%d %d %c", &last_num, &first_num, &type) < 3)
736 continue;
737
738 ginfo = news_group_info_new(name, first_num, last_num, type);
739
740 if (!last)
741 last = list = g_slist_append(NULL, ginfo);
742 else {
743 last = g_slist_append(last, ginfo);
744 last = last->next;
745 }
746 }
747
748 claws_fclose(fp);
749 g_free(filename);
750
751 list = g_slist_sort(list, (GCompareFunc)news_group_info_compare);
752
753 return list;
754 }
755
news_group_list_free(GSList * group_list)756 void news_group_list_free(GSList *group_list)
757 {
758 GSList *cur;
759
760 if (!group_list) return;
761
762 for (cur = group_list; cur != NULL; cur = cur->next)
763 news_group_info_free((NewsGroupInfo *)cur->data);
764 g_slist_free(group_list);
765 }
766
news_remove_group_list_cache(Folder * folder)767 void news_remove_group_list_cache(Folder *folder)
768 {
769 gchar *path, *filename;
770
771 cm_return_if_fail(folder != NULL);
772 cm_return_if_fail(FOLDER_CLASS(folder) == &news_class);
773
774 path = folder_item_get_path(FOLDER_ITEM(folder->node->data));
775 filename = g_strconcat(path, G_DIR_SEPARATOR_S, NEWSGROUP_LIST, NULL);
776 g_free(path);
777
778 if (is_file_exist(filename)) {
779 if (claws_unlink(filename) < 0)
780 FILE_OP_ERROR(filename, "remove");
781 }
782 g_free(filename);
783 }
784
news_post(Folder * folder,const gchar * file)785 gint news_post(Folder *folder, const gchar *file)
786 {
787 gint ok;
788 char *contents = file_read_to_str_no_recode(file);
789 NewsSession *session;
790
791 cm_return_val_if_fail(folder != NULL, -1);
792 cm_return_val_if_fail(FOLDER_CLASS(folder) == &news_class, -1);
793 cm_return_val_if_fail(contents != NULL, -1);
794
795 session = news_session_get(folder);
796 if (!session) {
797 g_free(contents);
798 return -1;
799 }
800
801 ok = nntp_threaded_post(folder, contents, strlen(contents));
802
803 g_free(contents);
804
805 if (ok == NEWSNNTP_ERROR_STREAM) {
806 session_destroy(SESSION(session));
807 REMOTE_FOLDER(folder)->session = NULL;
808 }
809
810 return (ok == NEWSNNTP_NO_ERROR ? 0 : -1);
811 }
812
news_get_article(Folder * folder,gint num,gchar * filename)813 static gint news_get_article(Folder *folder, gint num, gchar *filename)
814 {
815 size_t len;
816 char *result = NULL;
817 int r;
818
819 r = nntp_threaded_article(folder, num, &result, &len);
820
821 if (r == NEWSNNTP_NO_ERROR) {
822 if (str_write_to_file(result, filename, FALSE) < 0) {
823 mmap_string_unref(result);
824 return -1;
825 }
826 mmap_string_unref(result);
827 }
828
829 return r;
830 }
831
832 /**
833 * news_select_group:
834 * @session: Active NNTP session.
835 * @group: Newsgroup name.
836 * @num: Estimated number of articles.
837 * @first: First article number.
838 * @last: Last article number.
839 *
840 * Select newsgroup @group with the GROUP command if it is not already
841 * selected in @session, or article numbers need to be returned.
842 *
843 * Return value: NNTP result code.
844 **/
news_select_group(Folder * folder,const gchar * group,gint * num,gint * first,gint * last)845 static gint news_select_group(Folder *folder, const gchar *group,
846 gint *num, gint *first, gint *last)
847 {
848 gint ok;
849 gint num_, first_, last_;
850 struct newsnntp_group_info *info = NULL;
851 NewsSession *session = NEWS_SESSION(news_session_get(folder));
852
853 cm_return_val_if_fail(session != NULL, -1);
854
855 if (!num || !first || !last) {
856 if (session->group && g_ascii_strcasecmp(session->group, group) == 0)
857 return NEWSNNTP_NO_ERROR;
858 num = &num_;
859 first = &first_;
860 last = &last_;
861 }
862
863 g_free(session->group);
864 session->group = NULL;
865
866 ok = nntp_threaded_group(folder, group, &info);
867
868 if (ok == NEWSNNTP_NO_ERROR && info) {
869 session->group = g_strdup(group);
870 *num = info->grp_first;
871 *first = info->grp_first;
872 *last = info->grp_last;
873 newsnntp_group_free(info);
874 } else {
875 log_warning(LOG_PROTOCOL, _("couldn't select group: %s\n"), group);
876 }
877 return ok;
878 }
879
news_parse_xover(struct newsnntp_xover_resp_item * item)880 static MsgInfo *news_parse_xover(struct newsnntp_xover_resp_item *item)
881 {
882 MsgInfo *msginfo;
883
884 /* set MsgInfo */
885 msginfo = procmsg_msginfo_new();
886 msginfo->msgnum = item->ovr_article;
887 msginfo->size = item->ovr_size;
888
889 msginfo->date = g_strdup(item->ovr_date);
890 msginfo->date_t = procheader_date_parse(NULL, item->ovr_date, 0);
891
892 msginfo->from = conv_unmime_header(item->ovr_author, NULL, TRUE);
893 msginfo->fromname = procheader_get_fromname(msginfo->from);
894
895 msginfo->subject = conv_unmime_header(item->ovr_subject, NULL, TRUE);
896
897 remove_return(msginfo->from);
898 remove_return(msginfo->fromname);
899 remove_return(msginfo->subject);
900
901 if (item->ovr_message_id) {
902 gchar *tmp = g_strdup(item->ovr_message_id);
903 extract_parenthesis(tmp, '<', '>');
904 remove_space(tmp);
905 if (*tmp != '\0')
906 msginfo->msgid = g_strdup(tmp);
907 g_free(tmp);
908 }
909
910 /* FIXME: this is a quick fix; references' meaning was changed
911 * into having the actual list of references in the References: header.
912 * We need a GSList here, so msginfo_free() and msginfo_copy() can do
913 * their things properly. */
914 if (item->ovr_references && *(item->ovr_references)) {
915 gchar **ref_tokens = g_strsplit(item->ovr_references, " ", -1);
916 guint i = 0;
917 char *tmp;
918 char *p;
919 while (ref_tokens[i]) {
920 gchar *cur_ref = ref_tokens[i];
921 msginfo->references = references_list_append(msginfo->references,
922 cur_ref);
923 i++;
924 }
925 g_strfreev(ref_tokens);
926
927 tmp = g_strdup(item->ovr_references);
928 eliminate_parenthesis(tmp, '(', ')');
929 if ((p = strrchr(tmp, '<')) != NULL) {
930 extract_parenthesis(p, '<', '>');
931 remove_space(p);
932 if (*p != '\0')
933 msginfo->inreplyto = g_strdup(p);
934 }
935 g_free(tmp);
936 }
937
938 return msginfo;
939 }
940
news_cancel_article(Folder * folder,MsgInfo * msginfo)941 gint news_cancel_article(Folder * folder, MsgInfo * msginfo)
942 {
943 gchar * tmp;
944 FILE * tmpfp;
945 gchar date[RFC822_DATE_BUFFSIZE];
946
947 tmp = g_strdup_printf("%s%ccancel%p", get_tmp_dir(),
948 G_DIR_SEPARATOR, msginfo);
949 if (tmp == NULL)
950 return -1;
951
952 if ((tmpfp = claws_fopen(tmp, "wb")) == NULL) {
953 FILE_OP_ERROR(tmp, "claws_fopen");
954 return -1;
955 }
956 if (change_file_mode_rw(tmpfp, tmp) < 0) {
957 FILE_OP_ERROR(tmp, "chmod");
958 g_warning("can't change file mode");
959 }
960
961 if (prefs_common.hide_timezone)
962 get_rfc822_date_hide_tz(date, sizeof(date));
963 else
964 get_rfc822_date(date, sizeof(date));
965 if (fprintf(tmpfp, "From: %s\r\n"
966 "Newsgroups: %s\r\n"
967 "Subject: cmsg cancel <%s>\r\n"
968 "Control: cancel <%s>\r\n"
969 "Approved: %s\r\n"
970 "X-Cancelled-by: %s\r\n"
971 "Date: %s\r\n"
972 "\r\n"
973 "removed with Claws Mail\r\n",
974 msginfo->from,
975 msginfo->newsgroups,
976 msginfo->msgid,
977 msginfo->msgid,
978 msginfo->from,
979 msginfo->from,
980 date) < 0) {
981 FILE_OP_ERROR(tmp, "fprintf");
982 claws_fclose(tmpfp);
983 claws_unlink(tmp);
984 g_free(tmp);
985 return -1;
986 }
987
988 if (claws_safe_fclose(tmpfp) == EOF) {
989 FILE_OP_ERROR(tmp, "claws_fclose");
990 claws_unlink(tmp);
991 g_free(tmp);
992 return -1;
993 }
994
995 news_post(folder, tmp);
996 claws_unlink(tmp);
997
998 g_free(tmp);
999
1000 return 0;
1001 }
1002
news_folder_get_path(Folder * folder)1003 static gchar *news_folder_get_path(Folder *folder)
1004 {
1005 gchar *folder_path;
1006
1007 cm_return_val_if_fail(folder->account != NULL, NULL);
1008
1009 folder_path = g_strconcat(get_news_cache_dir(),
1010 G_DIR_SEPARATOR_S,
1011 folder->account->nntp_server,
1012 NULL);
1013 return folder_path;
1014 }
1015
news_item_get_path(Folder * folder,FolderItem * item)1016 static gchar *news_item_get_path(Folder *folder, FolderItem *item)
1017 {
1018 gchar *folder_path, *path;
1019
1020 cm_return_val_if_fail(folder != NULL, NULL);
1021 cm_return_val_if_fail(item != NULL, NULL);
1022 folder_path = news_folder_get_path(folder);
1023
1024 cm_return_val_if_fail(folder_path != NULL, NULL);
1025 if (g_path_is_absolute(folder_path)) {
1026 if (item->path)
1027 path = g_strconcat(folder_path, G_DIR_SEPARATOR_S,
1028 item->path, NULL);
1029 else
1030 path = g_strdup(folder_path);
1031 } else {
1032 if (item->path)
1033 path = g_strconcat(get_home_dir(), G_DIR_SEPARATOR_S,
1034 folder_path, G_DIR_SEPARATOR_S,
1035 item->path, NULL);
1036 else
1037 path = g_strconcat(get_home_dir(), G_DIR_SEPARATOR_S,
1038 folder_path, NULL);
1039 }
1040 g_free(folder_path);
1041 #ifdef G_OS_WIN32
1042 while (strchr(path, '/'))
1043 *strchr(path, '/') = '\\';
1044 #endif
1045 return path;
1046 }
1047
news_get_num_list(Folder * folder,FolderItem * item,GSList ** msgnum_list,gboolean * old_uids_valid)1048 static gint news_get_num_list(Folder *folder, FolderItem *item, GSList **msgnum_list, gboolean *old_uids_valid)
1049 {
1050 NewsSession *session;
1051 gint i, ok, num, first, last, nummsgs = 0;
1052 gchar *dir;
1053
1054 cm_return_val_if_fail(item != NULL, -1);
1055 cm_return_val_if_fail(item->folder != NULL, -1);
1056 cm_return_val_if_fail(FOLDER_CLASS(folder) == &news_class, -1);
1057
1058 session = news_session_get(folder);
1059 cm_return_val_if_fail(session != NULL, -1);
1060
1061 *old_uids_valid = TRUE;
1062
1063 news_folder_lock(NEWS_FOLDER(item->folder));
1064
1065 ok = news_select_group(folder, item->path, &num, &first, &last);
1066 if (ok != NEWSNNTP_NO_ERROR) {
1067 log_warning(LOG_PROTOCOL, _("couldn't set group: %s\n"), item->path);
1068 news_folder_unlock(NEWS_FOLDER(item->folder));
1069 return -1;
1070 }
1071
1072 dir = news_folder_get_path(folder);
1073 if (num <= 0)
1074 remove_all_numbered_files(dir);
1075 else if (last < first)
1076 log_warning(LOG_PROTOCOL, _("invalid article range: %d - %d\n"),
1077 first, last);
1078 else {
1079 for (i = first; i <= last; i++) {
1080 *msgnum_list = g_slist_prepend(*msgnum_list,
1081 GINT_TO_POINTER(i));
1082 nummsgs++;
1083 }
1084 debug_print("removing old messages from %d to %d in %s\n",
1085 first, last, dir);
1086 remove_numbered_files(dir, 1, first - 1);
1087 }
1088 g_free(dir);
1089 news_folder_unlock(NEWS_FOLDER(item->folder));
1090 return nummsgs;
1091 }
1092
news_set_msg_flags(FolderItem * item,MsgInfo * msginfo)1093 static void news_set_msg_flags(FolderItem *item, MsgInfo *msginfo)
1094 {
1095 msginfo->flags.tmp_flags = 0;
1096 if (item->folder->account->mark_crosspost_read && msginfo->msgid) {
1097 if (item->folder->newsart &&
1098 g_hash_table_lookup(item->folder->newsart, msginfo->msgid) != NULL) {
1099 msginfo->flags.perm_flags = MSG_COLORLABEL_TO_FLAGS(item->folder->account->crosspost_col);
1100
1101 } else {
1102 if (!item->folder->newsart)
1103 item->folder->newsart = g_hash_table_new(g_str_hash, g_str_equal);
1104 g_hash_table_insert(item->folder->newsart,
1105 g_strdup(msginfo->msgid), GINT_TO_POINTER(1));
1106 msginfo->flags.perm_flags = MSG_NEW|MSG_UNREAD;
1107 }
1108 } else {
1109 msginfo->flags.perm_flags = MSG_NEW|MSG_UNREAD;
1110 }
1111 }
1112
news_get_extra_fields(NewsSession * session,FolderItem * item,GSList * msglist)1113 static void news_get_extra_fields(NewsSession *session, FolderItem *item, GSList *msglist)
1114 {
1115 MsgInfo *msginfo = NULL;
1116 gint ok;
1117 GSList *cur;
1118 clist *hdrlist = NULL;
1119 clistiter *hdr;
1120 gint first = -1, last = -1;
1121 GHashTable *hash_table;
1122
1123 cm_return_if_fail(session != NULL);
1124 cm_return_if_fail(item != NULL);
1125 cm_return_if_fail(item->folder != NULL);
1126 cm_return_if_fail(FOLDER_CLASS(item->folder) == &news_class);
1127
1128 if (msglist == NULL)
1129 return;
1130
1131 news_folder_lock(NEWS_FOLDER(item->folder));
1132
1133 hash_table = g_hash_table_new(g_direct_hash, g_direct_equal);
1134
1135 for (cur = msglist; cur; cur = cur->next) {
1136 msginfo = (MsgInfo *)cur->data;
1137 if (first == -1 || msginfo->msgnum < first)
1138 first = msginfo->msgnum;
1139 if (last == -1 || msginfo->msgnum > last)
1140 last = msginfo->msgnum;
1141 g_hash_table_insert(hash_table,
1142 GINT_TO_POINTER(msginfo->msgnum), msginfo);
1143 }
1144
1145 if (first == -1 || last == -1) {
1146 g_hash_table_destroy(hash_table);
1147 return;
1148 }
1149
1150 /* Newsgroups */
1151 ok = nntp_threaded_xhdr(item->folder, "newsgroups", first, last, &hdrlist);
1152
1153 if (ok != NEWSNNTP_NO_ERROR) {
1154 log_warning(LOG_PROTOCOL, _("couldn't get xhdr\n"));
1155 if (ok == NEWSNNTP_ERROR_STREAM) {
1156 session_destroy(SESSION(session));
1157 REMOTE_FOLDER(item->folder)->session = NULL;
1158 }
1159 news_folder_unlock(NEWS_FOLDER(item->folder));
1160 if (hdrlist != NULL)
1161 newsnntp_xhdr_free(hdrlist);
1162 return;
1163 }
1164
1165 for (hdr = clist_begin(hdrlist); hdr; hdr = clist_next(hdr)) {
1166 struct newsnntp_xhdr_resp_item *hdrval = clist_content(hdr);
1167 msginfo = g_hash_table_lookup(hash_table, GINT_TO_POINTER(hdrval->hdr_article));
1168 if (msginfo) {
1169 if (msginfo->newsgroups)
1170 g_free(msginfo->newsgroups);
1171 msginfo->newsgroups = g_strdup(hdrval->hdr_value);
1172 }
1173 }
1174 newsnntp_xhdr_free(hdrlist);
1175 hdrlist = NULL;
1176
1177 /* To */
1178 ok = nntp_threaded_xhdr(item->folder, "to", first, last, &hdrlist);
1179
1180 if (ok != NEWSNNTP_NO_ERROR) {
1181 log_warning(LOG_PROTOCOL, _("couldn't get xhdr\n"));
1182 if (ok == NEWSNNTP_ERROR_STREAM) {
1183 session_destroy(SESSION(session));
1184 REMOTE_FOLDER(item->folder)->session = NULL;
1185 }
1186 news_folder_unlock(NEWS_FOLDER(item->folder));
1187 if (hdrlist != NULL)
1188 newsnntp_xhdr_free(hdrlist);
1189 return;
1190 }
1191
1192 for (hdr = clist_begin(hdrlist); hdr; hdr = clist_next(hdr)) {
1193 struct newsnntp_xhdr_resp_item *hdrval = clist_content(hdr);
1194 msginfo = g_hash_table_lookup(hash_table, GINT_TO_POINTER(hdrval->hdr_article));
1195 if (msginfo) {
1196 if (msginfo->to)
1197 g_free(msginfo->to);
1198 msginfo->to = g_strdup(hdrval->hdr_value);
1199 }
1200 }
1201 newsnntp_xhdr_free(hdrlist);
1202 hdrlist = NULL;
1203
1204 /* Cc */
1205 ok = nntp_threaded_xhdr(item->folder, "cc", first, last, &hdrlist);
1206
1207 if (ok != NEWSNNTP_NO_ERROR) {
1208 log_warning(LOG_PROTOCOL, _("couldn't get xhdr\n"));
1209 if (ok == NEWSNNTP_ERROR_STREAM) {
1210 session_destroy(SESSION(session));
1211 REMOTE_FOLDER(item->folder)->session = NULL;
1212 }
1213 news_folder_unlock(NEWS_FOLDER(item->folder));
1214 if (hdrlist != NULL)
1215 newsnntp_xhdr_free(hdrlist);
1216 return;
1217 }
1218
1219 for (hdr = clist_begin(hdrlist); hdr; hdr = clist_next(hdr)) {
1220 struct newsnntp_xhdr_resp_item *hdrval = clist_content(hdr);
1221 msginfo = g_hash_table_lookup(hash_table, GINT_TO_POINTER(hdrval->hdr_article));
1222 if (msginfo) {
1223 if (msginfo->cc)
1224 g_free(msginfo->cc);
1225 msginfo->cc = g_strdup(hdrval->hdr_value);
1226 }
1227 }
1228 newsnntp_xhdr_free(hdrlist);
1229 hdrlist = NULL;
1230
1231 g_hash_table_destroy(hash_table);
1232 news_folder_unlock(NEWS_FOLDER(item->folder));
1233 }
1234
news_get_msginfos_for_range(NewsSession * session,FolderItem * item,guint begin,guint end)1235 static GSList *news_get_msginfos_for_range(NewsSession *session, FolderItem *item, guint begin, guint end)
1236 {
1237 GSList *newlist = NULL;
1238 GSList *llast = NULL;
1239 MsgInfo *msginfo;
1240 gint ok;
1241 clist *msglist = NULL;
1242 clistiter *cur;
1243 cm_return_val_if_fail(session != NULL, NULL);
1244 cm_return_val_if_fail(item != NULL, NULL);
1245
1246 log_message(LOG_PROTOCOL, _("getting xover %d - %d in %s...\n"),
1247 begin, end, item->path);
1248
1249 news_folder_lock(NEWS_FOLDER(item->folder));
1250
1251 ok = news_select_group(item->folder, item->path, NULL, NULL, NULL);
1252 if (ok != NEWSNNTP_NO_ERROR) {
1253 log_warning(LOG_PROTOCOL, _("couldn't set group: %s\n"), item->path);
1254 news_folder_unlock(NEWS_FOLDER(item->folder));
1255 return NULL;
1256 }
1257
1258 ok = nntp_threaded_xover(item->folder, begin, end, NULL, &msglist);
1259
1260 if (ok != NEWSNNTP_NO_ERROR) {
1261 log_warning(LOG_PROTOCOL, _("couldn't get xover\n"));
1262 if (ok == NEWSNNTP_ERROR_STREAM) {
1263 session_destroy(SESSION(session));
1264 REMOTE_FOLDER(item->folder)->session = NULL;
1265 }
1266 news_folder_unlock(NEWS_FOLDER(item->folder));
1267 if (msglist != NULL)
1268 newsnntp_xover_resp_list_free(msglist);
1269 return NULL;
1270 }
1271
1272 if (msglist) {
1273 for (cur = clist_begin(msglist); cur; cur = clist_next(cur)) {
1274 struct newsnntp_xover_resp_item *ritem = (struct newsnntp_xover_resp_item *)clist_content(cur);
1275 msginfo = news_parse_xover(ritem);
1276
1277 if (!msginfo) {
1278 log_warning(LOG_PROTOCOL, _("invalid xover line\n"));
1279 continue;
1280 }
1281
1282 msginfo->folder = item;
1283 news_set_msg_flags(item, msginfo);
1284 msginfo->flags.tmp_flags |= MSG_NEWS;
1285
1286 if (!newlist)
1287 llast = newlist = g_slist_append(newlist, msginfo);
1288 else {
1289 llast = g_slist_append(llast, msginfo);
1290 llast = llast->next;
1291 }
1292 }
1293 newsnntp_xover_resp_list_free(msglist);
1294 }
1295
1296 news_folder_unlock(NEWS_FOLDER(item->folder));
1297
1298 session_set_access_time(SESSION(session));
1299
1300 news_get_extra_fields(session, item, newlist);
1301
1302 return newlist;
1303 }
1304
news_get_msginfo(Folder * folder,FolderItem * item,gint num)1305 static MsgInfo *news_get_msginfo(Folder *folder, FolderItem *item, gint num)
1306 {
1307 GSList *msglist = NULL;
1308 NewsSession *session;
1309 MsgInfo *msginfo = NULL;
1310
1311 session = news_session_get(folder);
1312 cm_return_val_if_fail(session != NULL, NULL);
1313 cm_return_val_if_fail(item != NULL, NULL);
1314 cm_return_val_if_fail(item->folder != NULL, NULL);
1315 cm_return_val_if_fail(FOLDER_CLASS(item->folder) == &news_class, NULL);
1316
1317 msglist = news_get_msginfos_for_range(session, item, num, num);
1318
1319 if (msglist)
1320 msginfo = msglist->data;
1321
1322 g_slist_free(msglist);
1323
1324 return msginfo;
1325 }
1326
news_get_msginfos(Folder * folder,FolderItem * item,GSList * msgnum_list)1327 static GSList *news_get_msginfos(Folder *folder, FolderItem *item, GSList *msgnum_list)
1328 {
1329 NewsSession *session;
1330 GSList *elem, *msginfo_list = NULL, *tmp_msgnum_list, *tmp_msginfo_list;
1331 guint first, last, next;
1332
1333 cm_return_val_if_fail(folder != NULL, NULL);
1334 cm_return_val_if_fail(FOLDER_CLASS(folder) == &news_class, NULL);
1335 cm_return_val_if_fail(msgnum_list != NULL, NULL);
1336 cm_return_val_if_fail(item != NULL, NULL);
1337
1338 session = news_session_get(folder);
1339 cm_return_val_if_fail(session != NULL, NULL);
1340
1341 tmp_msgnum_list = g_slist_copy(msgnum_list);
1342 tmp_msgnum_list = g_slist_sort(tmp_msgnum_list, g_int_compare);
1343
1344 progressindicator_start(PROGRESS_TYPE_NETWORK);
1345
1346 first = GPOINTER_TO_INT(tmp_msgnum_list->data);
1347 last = first;
1348
1349 news_folder_lock(NEWS_FOLDER(item->folder));
1350
1351 for(elem = g_slist_next(tmp_msgnum_list); elem != NULL; elem = g_slist_next(elem)) {
1352 next = GPOINTER_TO_INT(elem->data);
1353 if(next != (last + 1)) {
1354 tmp_msginfo_list = news_get_msginfos_for_range(session, item, first, last);
1355 msginfo_list = g_slist_concat(msginfo_list, tmp_msginfo_list);
1356 first = next;
1357 }
1358 last = next;
1359 }
1360
1361 news_folder_unlock(NEWS_FOLDER(item->folder));
1362
1363 tmp_msginfo_list = news_get_msginfos_for_range(session, item, first, last);
1364 msginfo_list = g_slist_concat(msginfo_list, tmp_msginfo_list);
1365
1366 g_slist_free(tmp_msgnum_list);
1367
1368 progressindicator_stop(PROGRESS_TYPE_NETWORK);
1369
1370 return msginfo_list;
1371 }
1372
news_scan_required(Folder * folder,FolderItem * item)1373 static gboolean news_scan_required(Folder *folder, FolderItem *item)
1374 {
1375 return TRUE;
1376 }
1377
news_synchronise(FolderItem * item,gint days)1378 void news_synchronise(FolderItem *item, gint days)
1379 {
1380 news_gtk_synchronise(item, days);
1381 }
1382
news_rename_folder(Folder * folder,FolderItem * item,const gchar * name)1383 static gint news_rename_folder(Folder *folder, FolderItem *item,
1384 const gchar *name)
1385 {
1386 gchar *path;
1387
1388 cm_return_val_if_fail(folder != NULL, -1);
1389 cm_return_val_if_fail(item != NULL, -1);
1390 cm_return_val_if_fail(item->path != NULL, -1);
1391 cm_return_val_if_fail(name != NULL, -1);
1392
1393 path = folder_item_get_path(item);
1394 if (!is_dir_exist(path))
1395 make_dir_hier(path);
1396
1397 g_free(item->name);
1398 item->name = g_strdup(name);
1399
1400 return 0;
1401 }
1402
news_remove_folder(Folder * folder,FolderItem * item)1403 static gint news_remove_folder(Folder *folder, FolderItem *item)
1404 {
1405 gchar *path;
1406
1407 cm_return_val_if_fail(folder != NULL, -1);
1408 cm_return_val_if_fail(item != NULL, -1);
1409 cm_return_val_if_fail(item->path != NULL, -1);
1410
1411 path = folder_item_get_path(item);
1412 if (remove_dir_recursive(path) < 0) {
1413 g_warning("can't remove directory '%s'", path);
1414 g_free(path);
1415 return -1;
1416 }
1417
1418 g_free(path);
1419 folder_item_remove(item);
1420 return 0;
1421 }
1422
nntp_disconnect_all(gboolean have_connectivity)1423 void nntp_disconnect_all(gboolean have_connectivity)
1424 {
1425 GList *list;
1426 gboolean short_timeout;
1427 #ifdef HAVE_NETWORKMANAGER_SUPPORT
1428 GError *error;
1429 #endif
1430
1431 #ifdef HAVE_NETWORKMANAGER_SUPPORT
1432 error = NULL;
1433 short_timeout = !networkmanager_is_online(&error);
1434 if(error) {
1435 short_timeout = TRUE;
1436 g_error_free(error);
1437 }
1438 #else
1439 short_timeout = TRUE;
1440 #endif
1441
1442 if(short_timeout)
1443 nntp_main_set_timeout(1);
1444
1445 for (list = account_get_list(); list != NULL; list = list->next) {
1446 PrefsAccount *account = list->data;
1447 if (account->protocol == A_NNTP) {
1448 RemoteFolder *folder = (RemoteFolder *)account->folder;
1449 if (folder && folder->session) {
1450 NewsSession *session = (NewsSession *)folder->session;
1451 if (have_connectivity)
1452 nntp_threaded_disconnect(FOLDER(folder));
1453 SESSION(session)->state = SESSION_DISCONNECTED;
1454 SESSION(session)->sock = NULL;
1455 session_destroy(SESSION(session));
1456 folder->session = NULL;
1457 }
1458 }
1459 }
1460
1461 if(short_timeout)
1462 nntp_main_set_timeout(prefs_common.io_timeout_secs);
1463 }
1464
1465 #else
1466 #include <glib.h>
1467 #include <glib/gi18n.h>
1468 #include <gtk/gtk.h>
1469 #include "folder.h"
1470 #include "alertpanel.h"
1471
1472 static FolderClass news_class;
1473
warn_etpan(void)1474 static void warn_etpan(void)
1475 {
1476 static gboolean missing_news_warning = TRUE;
1477 if (missing_news_warning) {
1478 missing_news_warning = FALSE;
1479 alertpanel_error(
1480 _("You have one or more News accounts "
1481 "defined. However this version of "
1482 "Claws Mail has been built without "
1483 "News support; your News accounts are "
1484 "disabled.\n\n"
1485 "You probably need to "
1486 "install libetpan and recompile "
1487 "Claws Mail."));
1488 }
1489 }
news_folder_new(const gchar * name,const gchar * path)1490 static Folder *news_folder_new(const gchar *name, const gchar *path)
1491 {
1492 warn_etpan();
1493 return NULL;
1494 }
news_group_list_free(GSList * group_list)1495 void news_group_list_free(GSList *group_list)
1496 {
1497 warn_etpan();
1498 }
news_remove_group_list_cache(Folder * folder)1499 void news_remove_group_list_cache(Folder *folder)
1500 {
1501 warn_etpan();
1502 }
news_folder_locked(Folder * folder)1503 int news_folder_locked(Folder *folder)
1504 {
1505 warn_etpan();
1506 return 0;
1507 }
news_post(Folder * folder,const gchar * file)1508 gint news_post(Folder *folder, const gchar *file)
1509 {
1510 warn_etpan();
1511 return -1;
1512 }
1513
news_cancel_article(Folder * folder,MsgInfo * msginfo)1514 gint news_cancel_article(Folder * folder, MsgInfo * msginfo)
1515 {
1516 warn_etpan();
1517 return -1;
1518 }
1519
news_get_group_list(Folder * folder)1520 GSList *news_get_group_list(Folder *folder)
1521 {
1522 warn_etpan();
1523 return NULL;
1524 }
1525
1526
news_get_class(void)1527 FolderClass *news_get_class(void)
1528 {
1529 if (news_class.idstr == NULL) {
1530 news_class.type = F_NEWS;
1531 news_class.idstr = "news";
1532 news_class.uistr = "News";
1533
1534 /* Folder functions */
1535 news_class.new_folder = news_folder_new;
1536 };
1537
1538 return &news_class;
1539 }
1540
nntp_disconnect_all(gboolean have_connectivity)1541 void nntp_disconnect_all(gboolean have_connectivity)
1542 {
1543 }
1544
1545 #endif
1546