59a30d0a93f400b40268730a69933522ccc2df61
[claws.git] / src / nntp.c
1 /*
2  * Sylpheed -- a GTK+ based, lightweight, and fast e-mail client
3  * Copyright (C) 1999,2000 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 #ifdef HAVE_CONFIG_H
21 #  include "config.h"
22 #endif
23
24 #include <glib.h>
25 #include <stdio.h>
26 #include <string.h>
27
28 #include "intl.h"
29 #include "nntp.h"
30 #include "socket.h"
31 #include "utils.h"
32
33 static gint verbose = 1;
34
35 static void nntp_gen_send(gint sock, const gchar *format, ...);
36 static gint nntp_gen_recv(gint sock, gchar *buf, gint size);
37
38 gint nntp_open(const gchar *server, gushort port, gchar *buf)
39 {
40         SockInfo *sockinfo;
41         gint sock;
42
43         if ((sockinfo = sock_connect(server, port)) == NULL) {
44                 log_warning(_("Can't connect to NNTP server: %s:%d\n"),
45                             server, port);
46                 return -1;
47         }
48         sock = sockinfo->sock;
49         sock_sockinfo_free(sockinfo);
50
51         if (nntp_ok(sock, buf) == NN_SUCCESS)
52                 return sock;
53         else {
54                 sock_close(sock);
55                 return -1;
56         }
57 }
58
59 gint nntp_group(gint sock, const gchar *group,
60                 gint *num, gint *first, gint *last)
61 {
62         gint ok;
63         gint resp;
64         gchar buf[NNTPBUFSIZE];
65
66         nntp_gen_send(sock, "GROUP %s", group);
67
68         if ((ok = nntp_ok(sock, buf)) != NN_SUCCESS)
69                 return ok;
70
71         if (sscanf(buf, "%d %d %d %d", &resp, num, first, last)
72             != 4) {
73                 log_warning(_("protocol error: %s\n"), buf);
74                 return NN_PROTOCOL;
75         }
76
77         return NN_SUCCESS;
78 }
79
80 gint nntp_get_article(gint sock, const gchar *cmd, gint num, gchar **msgid)
81 {
82         gint ok;
83         gchar buf[NNTPBUFSIZE];
84
85         if (num > 0)
86                 nntp_gen_send(sock, "%s %d", cmd, num);
87         else
88                 nntp_gen_send(sock, cmd);
89
90         if ((ok = nntp_ok(sock, buf)) != NN_SUCCESS)
91                 return ok;
92
93         extract_parenthesis(buf, '<', '>');
94         if (buf[0] == '\0') {
95                 log_warning(_("protocol error\n"));
96                 return NN_PROTOCOL;
97         }
98         *msgid = g_strdup(buf);
99
100         return NN_SUCCESS;
101 }
102
103 gint nntp_article(gint sock, gint num, gchar **msgid)
104 {
105         return nntp_get_article(sock, "ARTICLE", num, msgid);
106 }
107
108 gint nntp_body(gint sock, gint num, gchar **msgid)
109 {
110         return nntp_get_article(sock, "BODY", num, msgid);
111 }
112
113 gint nntp_head(gint sock, gint num, gchar **msgid)
114 {
115         return nntp_get_article(sock, "HEAD", num, msgid);
116 }
117
118 gint nntp_stat(gint sock, gint num, gchar **msgid)
119 {
120         return nntp_get_article(sock, "STAT", num, msgid);
121 }
122
123 gint nntp_next(gint sock, gint *num, gchar **msgid)
124 {
125         gint ok;
126         gint resp;
127         gchar buf[NNTPBUFSIZE];
128
129         nntp_gen_send(sock, "NEXT");
130
131         if ((ok = nntp_ok(sock, buf)) != NN_SUCCESS)
132                 return ok;
133
134         if (sscanf(buf, "%d %d", &resp, num) != 2) {
135                 log_warning(_("protocol error: %s\n"), buf);
136                 return NN_PROTOCOL;
137         }
138
139         extract_parenthesis(buf, '<', '>');
140         if (buf[0] == '\0') {
141                 log_warning(_("protocol error\n"));
142                 return NN_PROTOCOL;
143         }
144         *msgid = g_strdup(buf);
145
146         return NN_SUCCESS;
147 }
148
149 gint nntp_xover(gint sock, gint first, gint last)
150 {
151         gint ok;
152         gchar buf[NNTPBUFSIZE];
153
154         nntp_gen_send(sock, "XOVER %d-%d", first, last);
155         if ((ok = nntp_ok(sock, buf)) != NN_SUCCESS)
156                 return ok;
157
158         return NN_SUCCESS;
159 }
160
161 gint nntp_post(gint sock, FILE *fp)
162 {
163         gint ok;
164         gchar buf[NNTPBUFSIZE];
165
166         nntp_gen_send(sock, "POST");
167         if ((ok = nntp_ok(sock, buf)) != NN_SUCCESS)
168                 return ok;
169
170         while (fgets(buf, sizeof(buf), fp) != NULL) {
171                 strretchomp(buf);
172                 if (buf[0] == '.') {
173                         if (sock_write(sock, ".", 1) < 0) {
174                                 log_warning(_("Error occurred while posting\n"));
175                                 return NN_SOCKET;
176                         }
177                 }
178
179                 if (sock_puts(sock, buf) < 0) {
180                         log_warning(_("Error occurred while posting\n"));
181                         return NN_SOCKET;
182                 }
183         }
184
185         sock_write(sock, ".\r\n", 3);
186         if ((ok = nntp_ok(sock, buf)) != NN_SUCCESS)
187                 return ok;
188
189         return NN_SUCCESS;
190 }
191
192 gint nntp_newgroups(gint sock)
193 {
194         return NN_SUCCESS;
195 }
196
197 gint nntp_newnews(gint sock)
198 {
199         return NN_SUCCESS;
200 }
201
202 gint nntp_mode(gint sock, gboolean stream)
203 {
204         gint ok;
205
206         nntp_gen_send(sock, "MODE %s", stream ? "STREAM" : "READER");
207         ok = nntp_ok(sock, NULL);
208
209         return ok;
210 }
211
212 gint nntp_authinfo_user(gint sock, const gchar *user)
213 {
214         gint ok;
215         gchar buf[NNTPBUFSIZE];
216
217         nntp_gen_send(sock, "AUTHINFO USER %s", user);
218         ok = nntp_ok(sock, buf);
219
220         return ok;
221 }
222
223 gint nntp_authinfo_pass(gint sock, const gchar *pass)
224 {
225         gint ok;
226         gchar buf[NNTPBUFSIZE];
227
228         nntp_gen_send(sock, "AUTHINFO PASS %s", pass);
229         ok = nntp_ok(sock, buf);
230
231         return ok;
232 }
233
234 gint nntp_ok(gint sock, gchar *argbuf)
235 {
236         gint ok;
237         gchar buf[NNTPBUFSIZE];
238
239         if ((ok = nntp_gen_recv(sock, buf, sizeof(buf))) == NN_SUCCESS) {
240                 if (strlen(buf) < 4)
241                         return NN_ERROR;
242
243                 if ((buf[0] == '1' || buf[0] == '2' || buf[0] == '3') &&
244                     buf[3] == ' ') {
245                         if (argbuf)
246                                 strcpy(argbuf, buf);
247
248                         if (!strncmp(buf, "381 ", 4))
249                                 return NN_AUTHCONT;
250                         return NN_SUCCESS;
251                 } else if (!strncmp(buf, "480 ", 4))
252                         return NN_AUTHREQ;
253                 else
254                         return NN_ERROR;
255         }
256
257         return ok;
258 }
259
260 static void nntp_gen_send(gint sock, const gchar *format, ...)
261 {
262         gchar buf[NNTPBUFSIZE];
263         va_list args;
264
265         va_start(args, format);
266         g_vsnprintf(buf, sizeof(buf), format, args);
267         va_end(args);
268
269         if (verbose) {
270                 if (!g_strncasecmp(buf, "AUTHINFO PASS", 13))
271                         log_print("NNTP> AUTHINFO PASS ***\n");
272                 else
273                         log_print("NNTP> %s\n", buf);
274         }
275
276         strcat(buf, "\r\n");
277         sock_write(sock, buf, strlen(buf));
278 }
279
280 static gint nntp_gen_recv(gint sock, gchar *buf, gint size)
281 {
282         if (sock_read(sock, buf, size) == -1)
283                 return NN_SOCKET;
284
285         strretchomp(buf);
286
287         if (verbose)
288                 log_print("NNTP< %s\n", buf);
289
290         return NN_SUCCESS;
291 }
292
293 /*
294   nntp_list sends the command "LIST" to the news server,
295   a function is needed to read the newsgroups list.
296  */
297
298 gint nntp_list(gint sock)
299 {
300         GList * result = NULL;
301
302         gint ok;
303         gint resp;
304         gchar buf[NNTPBUFSIZE];
305
306         nntp_gen_send(sock, "LIST");
307
308         if ((ok = nntp_ok(sock, buf)) != NN_SUCCESS)
309                 return NN_ERROR;
310
311         if (verbose)
312                 log_print("NNTP< %s\n", buf);
313
314         return NN_SUCCESS;
315 }