/[imapfilter]/imapfilter/imap.c
ViewVC logotype

Annotation of /imapfilter/imap.c

Parent Directory Parent Directory | Revision Log Revision Log


Revision 1.41 - (hide annotations)
Mon Feb 9 17:34:56 2004 UTC (20 years, 2 months ago) by lefcha
Branch: MAIN
Changes since 1.40: +2 -8 lines
File MIME type: text/plain
Move DEBUG from compilation #define variable to runtime command line option.

1 lefcha 1.1 #include <stdio.h>
2     #include <string.h>
3    
4     #include "config.h"
5     #include "imapfilter.h"
6 lefcha 1.38 #include "buffer.h"
7 lefcha 1.1
8    
9 lefcha 1.37 extern conn_t connpri, connaux;
10 lefcha 1.24
11 lefcha 1.36 buffer_t obuf; /* Output buffer. */
12    
13 lefcha 1.39 static unsigned int tag = 0x1000; /* Every IMAP command is prefixed with
14     * a unique [:alnum:] string. */
15 lefcha 1.1
16 lefcha 1.38
17     unsigned int send_command(conn_t * conn, char *cmd);
18     void send_command_cont(conn_t * conn, char *cmd);
19    
20    
21 lefcha 1.1 /*
22 lefcha 1.13 * Send to server data; a command.
23 lefcha 1.1 */
24 lefcha 1.30 unsigned int
25 lefcha 1.37 send_command(conn_t * conn, char *cmd)
26 lefcha 1.1 {
27 lefcha 1.41 debug("sending command (%s):\n\n%s\n",
28 lefcha 1.37 (conn == &connpri ? "primary" : "auxiliary"), cmd);
29     verbose("%s: %s", (conn == &connpri ? "C" : "c"), cmd);
30 lefcha 1.18
31 lefcha 1.37 socket_write(conn, cmd);
32 lefcha 1.25
33 lefcha 1.39 if (tag == 0xFFFF)
34     tag = 0x0FFF;
35    
36 lefcha 1.30 return tag++;
37 lefcha 1.1 }
38    
39    
40 lefcha 1.34 #ifdef CRAM_MD5
41     /*
42     * Send to server data: a continuation command.
43     */
44     void
45 lefcha 1.37 send_command_cont(conn_t * conn, char *cmd)
46 lefcha 1.34 {
47 lefcha 1.41 debug("sending command (%s):\n\n%s\r\n\n",
48 lefcha 1.37 (conn == &connpri ? "primary" : "auxiliary"), cmd);
49 lefcha 1.34
50 lefcha 1.37 socket_write(conn, cmd);
51     socket_write(conn, "\r\n");
52 lefcha 1.34 }
53     #endif
54    
55    
56 lefcha 1.1 /*
57     * IMAP NOOP: does nothing always succeeds.
58     */
59 lefcha 1.30 int
60 lefcha 1.37 imap_noop(conn_t * conn)
61 lefcha 1.1 {
62 lefcha 1.36 reset_buffer(&obuf);
63     check_buffer(&obuf, strlen("NOOP") + 12);
64 lefcha 1.1
65 lefcha 1.39 snprintf(obuf.data, obuf.size, "%04X NOOP\r\n", tag);
66 lefcha 1.1
67 lefcha 1.37 return send_command(conn, obuf.data);
68 lefcha 1.1 }
69    
70    
71     /*
72 lefcha 1.21 * IMAP CAPABILITY: requests listing of capabilities that the server supports.
73 lefcha 1.16 */
74 lefcha 1.30 int
75 lefcha 1.37 imap_capability(conn_t * conn)
76 lefcha 1.16 {
77 lefcha 1.36 reset_buffer(&obuf);
78     check_buffer(&obuf, strlen("CAPABILITY") + 12);
79 lefcha 1.16
80 lefcha 1.39 snprintf(obuf.data, obuf.size, "%04X CAPABILITY\r\n", tag);
81 lefcha 1.21
82 lefcha 1.37 return send_command(conn, obuf.data);
83 lefcha 1.21 }
84    
85    
86     /*
87     * IMAP NAMESPACE: discovers the prefix and delimeter of namespaces used by
88     * the server for mailboxes (RFC 2342).
89     */
90 lefcha 1.30 int
91 lefcha 1.37 imap_namespace(conn_t * conn)
92 lefcha 1.21 {
93 lefcha 1.36 reset_buffer(&obuf);
94     check_buffer(&obuf, strlen("NAMESPACE") + 12);
95 lefcha 1.21
96 lefcha 1.39 snprintf(obuf.data, obuf.size, "%04X NAMESPACE\r\n", tag);
97 lefcha 1.16
98 lefcha 1.37 return send_command(conn, obuf.data);
99 lefcha 1.16 }
100    
101    
102     /*
103 lefcha 1.1 * IMAP LOGOUT: informs server that client is done.
104     */
105 lefcha 1.30 int
106 lefcha 1.37 imap_logout(conn_t * conn)
107 lefcha 1.1 {
108 lefcha 1.36 reset_buffer(&obuf);
109     check_buffer(&obuf, strlen("LOGOUT") + 12);
110 lefcha 1.1
111 lefcha 1.39 snprintf(obuf.data, obuf.size, "%04X LOGOUT\r\n", tag);
112 lefcha 1.1
113 lefcha 1.37 return send_command(conn, obuf.data);
114 lefcha 1.28 }
115    
116    
117 lefcha 1.35 /*
118     * IMAP STARTTLS: begin TLS negotiation.
119     */
120     int
121 lefcha 1.37 imap_starttls(conn_t * conn)
122 lefcha 1.35 {
123 lefcha 1.36 reset_buffer(&obuf);
124     check_buffer(&obuf, strlen("STARTTLS") + 12);
125 lefcha 1.35
126 lefcha 1.39 snprintf(obuf.data, obuf.size, "%04X STARTTLS\r\n", tag);
127 lefcha 1.35
128 lefcha 1.37 return send_command(conn, obuf.data);
129 lefcha 1.35 }
130    
131    
132 lefcha 1.34 #ifdef CRAM_MD5
133 lefcha 1.28 /*
134     * IMAP AUTHENTICATE: indicates authentication mechanism and performs an
135     * authentication protocol exchange.
136     */
137 lefcha 1.30 int
138 lefcha 1.37 imap_authenticate(conn_t * conn, char *auth, int cont)
139 lefcha 1.28 {
140 lefcha 1.36 reset_buffer(&obuf);
141     check_buffer(&obuf, strlen("AUTHENTICATE") + 12);
142 lefcha 1.30
143 lefcha 1.34 if (!cont) {
144 lefcha 1.39 snprintf(obuf.data, obuf.size, "%04X AUTHENTICATE %s\r\n",
145 lefcha 1.36 tag, auth);
146 lefcha 1.37 return send_command(conn, obuf.data);
147 lefcha 1.34 } else {
148 lefcha 1.37 send_command_cont(conn, auth);
149 lefcha 1.34 return 0;
150     }
151     }
152     #endif
153 lefcha 1.1
154    
155     /*
156     * IMAP LOGIN: identifies client to server.
157     */
158 lefcha 1.30 int
159 lefcha 1.37 imap_login(conn_t * conn, char *user, char *pass)
160 lefcha 1.1 {
161 lefcha 1.36 int r, n;
162     char *sbuf;
163 lefcha 1.25
164 lefcha 1.36 n = strlen("LOGIN") + strlen(user) + strlen(pass) + 18;
165     sbuf = (char *)smalloc(n);
166 lefcha 1.1
167 lefcha 1.39 snprintf(sbuf, n, "%04X LOGIN \"%s\" \"%s\"\r\n", tag, user, pass);
168 lefcha 1.1
169 lefcha 1.37 r = send_command(conn, sbuf);
170 lefcha 1.25
171 lefcha 1.36 sfree(sbuf);
172 lefcha 1.23
173 lefcha 1.30 return r;
174 lefcha 1.1 }
175    
176    
177     /*
178 lefcha 1.24 * IMAP LIST: returns a subset of names from the complete set of names
179     * available to the client.
180     *
181 lefcha 1.37 int imap_list(conn_t *conn, char *refer, char *mbox)
182 lefcha 1.24 {
183 lefcha 1.36 int r;
184    
185     reset_buffer(&obuf);
186     check_buffer(&obuf, strlen("LIST") + strlen(refer) + strlen(mbox) + 18);
187    
188 lefcha 1.39 snprintf(obuf.data, obuf.size, "%04X LIST \"%s\" \"%s\"\r\n", tag,
189 lefcha 1.36 refer, mbox);
190 lefcha 1.25
191 lefcha 1.37 r = send_command(conn, obuf.data);
192 lefcha 1.25
193 lefcha 1.36 return r;
194 lefcha 1.24 }*/
195    
196    
197     /*
198     * IMAP SUBSCRIBE: adds the specified mailbox name to the server's
199     * set of "active" or "subscribed" mailboxes.
200     */
201 lefcha 1.30 int
202 lefcha 1.37 imap_subscribe(conn_t * conn, char *mbox)
203 lefcha 1.24 {
204 lefcha 1.36 reset_buffer(&obuf);
205     check_buffer(&obuf, strlen("SUBSCRIBE") + strlen(mbox) + 15);
206 lefcha 1.24
207 lefcha 1.39 snprintf(obuf.data, obuf.size, "%04X SUBSCRIBE \"%s\"\r\n", tag, mbox);
208 lefcha 1.24
209 lefcha 1.37 return send_command(conn, obuf.data);
210 lefcha 1.24 }
211    
212    
213     /*
214 lefcha 1.13 * IMAP EXAMINE: access a mailbox in READ-ONLY mode.
215 lefcha 1.31 *
216 lefcha 1.30 int
217 lefcha 1.37 imap_examine(conn_t *conn, char *mbox)
218 lefcha 1.1 {
219 lefcha 1.36 reset_buffer(&obuf);
220     check_buffer(&obuf, strlen("EXAMINE") + strlen(mbox) + 15);
221 lefcha 1.1
222 lefcha 1.39 snprintf(obuf.data, MEDIUM_CMD, "%04X EXAMINE \"%s\"\r\n", tag, mbox);
223 lefcha 1.1
224 lefcha 1.37 return send_command(conn, obuf.data);
225 lefcha 1.31 }*/
226 lefcha 1.10
227 lefcha 1.13
228 lefcha 1.10 /*
229 lefcha 1.13 * IMAP SELECT: access a mailbox in READ-WRITE mode.
230 lefcha 1.10 */
231 lefcha 1.30 int
232 lefcha 1.37 imap_select(conn_t * conn, char *mbox)
233 lefcha 1.10 {
234 lefcha 1.36 reset_buffer(&obuf);
235     check_buffer(&obuf, strlen("SELECT") + strlen(mbox) + 15);
236 lefcha 1.10
237 lefcha 1.39 snprintf(obuf.data, obuf.size, "%04X SELECT \"%s\"\r\n", tag, mbox);
238 lefcha 1.10
239 lefcha 1.37 return send_command(conn, obuf.data);
240 lefcha 1.1 }
241 lefcha 1.10
242 lefcha 1.1
243     /*
244 lefcha 1.13 * IMAP STATUS: requests status of the indicated mailbox.
245 lefcha 1.1 */
246 lefcha 1.30 int
247 lefcha 1.37 imap_status(conn_t * conn, char *mbox, char *items)
248 lefcha 1.1 {
249 lefcha 1.36 reset_buffer(&obuf);
250     check_buffer(&obuf, strlen("STATUS") + strlen(mbox) +
251     strlen(items) + 18);
252 lefcha 1.1
253 lefcha 1.39 snprintf(obuf.data, obuf.size, "%04X STATUS \"%s\" (%s)\r\n", tag, mbox, items);
254 lefcha 1.5
255 lefcha 1.37 return send_command(conn, obuf.data);
256 lefcha 1.1 }
257    
258    
259     /*
260 lefcha 1.13 * IMAP CREATE: create mailbox.
261 lefcha 1.1 */
262 lefcha 1.30 int
263 lefcha 1.37 imap_create(conn_t * conn, char *mbox)
264 lefcha 1.1 {
265 lefcha 1.36 reset_buffer(&obuf);
266     check_buffer(&obuf, strlen("CREATE") + strlen(mbox) + 14);
267 lefcha 1.1
268 lefcha 1.39 snprintf(obuf.data, obuf.size, "%04X CREATE \"%s\"\r\n", tag, mbox);
269 lefcha 1.1
270 lefcha 1.37 return send_command(conn, obuf.data);
271 lefcha 1.1 }
272    
273    
274     /*
275 lefcha 1.13 * IMAP SEARCH: searches the mailbox for messages that match certain criteria.
276 lefcha 1.1 */
277 lefcha 1.30 int
278 lefcha 1.37 imap_search(conn_t * conn, char *charset, char *search)
279 lefcha 1.1 {
280 lefcha 1.36 reset_buffer(&obuf);
281     check_buffer(&obuf, strlen("SEARCH CHARSET") + strlen(charset) +
282     strlen(search) + 15);
283 lefcha 1.1
284 lefcha 1.30 if (*charset)
285 lefcha 1.39 snprintf(obuf.data, obuf.size, "%04X SEARCH CHARSET \"%s\" %s\r\n",
286 lefcha 1.36 tag, charset, search);
287 lefcha 1.30 else
288 lefcha 1.39 snprintf(obuf.data, obuf.size, "%04X SEARCH %s\r\n", tag, search);
289 lefcha 1.1
290 lefcha 1.37 return send_command(conn, obuf.data);
291 lefcha 1.1 }
292    
293    
294     /*
295 lefcha 1.13 * IMAP FETCH: retrieves data associated with a message.
296 lefcha 1.1 */
297 lefcha 1.30 int
298 lefcha 1.37 imap_fetch(conn_t * conn, char *mesg, char *items)
299 lefcha 1.1 {
300 lefcha 1.36 reset_buffer(&obuf);
301     check_buffer(&obuf, strlen("FETCH") + strlen(mesg) + strlen(items) + 14);
302 lefcha 1.1
303 lefcha 1.39 snprintf(obuf.data, obuf.size, "%04X FETCH %s %s\r\n", tag, mesg, items);
304 lefcha 1.1
305 lefcha 1.37 return send_command(conn, obuf.data);
306 lefcha 1.1 }
307    
308    
309     /*
310 lefcha 1.13 * IMAP STORE: alters data associated with a message.
311 lefcha 1.1 */
312 lefcha 1.30 int
313 lefcha 1.37 imap_store(conn_t * conn, char *mesg, unsigned int mode, char *flags)
314 lefcha 1.1 {
315 lefcha 1.36 reset_buffer(&obuf);
316     check_buffer(&obuf, strlen("STORE") + strlen(mesg) +
317     strlen("FLAGS.SILENT") + strlen(flags) + 18);
318 lefcha 1.1
319 lefcha 1.39 snprintf(obuf.data, obuf.size, "%04X STORE %s %sFLAGS.SILENT (%s)\r\n",
320 lefcha 1.36 tag, mesg, (mode == STORE_FLAG_REPLACE ? "" :
321 lefcha 1.30 mode == STORE_FLAG_ADD ? "+" : "-"), flags);
322 lefcha 1.5
323 lefcha 1.37 return send_command(conn, obuf.data);
324 lefcha 1.5 }
325    
326    
327     /*
328 lefcha 1.13 * IMAP COPY: copy messages to mailbox.
329 lefcha 1.5 */
330 lefcha 1.30 int
331 lefcha 1.37 imap_copy(conn_t * conn, char *mesg, char *mbox)
332 lefcha 1.5 {
333 lefcha 1.36 reset_buffer(&obuf);
334     check_buffer(&obuf, strlen("COPY") + strlen(mesg) + strlen(mbox) + 16);
335 lefcha 1.5
336 lefcha 1.39 snprintf(obuf.data, obuf.size, "%04X COPY %s \"%s\"\r\n", tag, mesg, mbox);
337 lefcha 1.5
338 lefcha 1.37 return send_command(conn, obuf.data);
339 lefcha 1.5 }
340 lefcha 1.2
341    
342 lefcha 1.5 /*
343 lefcha 1.24 * IMAP APPEND: append message to the end of a mailbox.
344     */
345 lefcha 1.30 int
346 lefcha 1.40 imap_append(conn_t * conn, char *mbox, char *flags, char *date, unsigned int size)
347 lefcha 1.24 {
348 lefcha 1.36 reset_buffer(&obuf);
349 lefcha 1.40 check_buffer(&obuf, strlen("APPEND") + strlen(mbox) + strlen(flags) +
350     strlen(date) + strlen(ultostr(size, 10)) + 24);
351 lefcha 1.25
352 lefcha 1.40 snprintf(obuf.data, obuf.size, "%04X APPEND \"%s\" (%s) \"%s\" {%d}\r\n",
353     tag, mbox, flags, date, size);
354 lefcha 1.25
355 lefcha 1.37 return send_command(conn, obuf.data);
356 lefcha 1.24 }
357    
358    
359    
360     /*
361 lefcha 1.13 * IMAP CLOSE: delete messages and return to authenticated state.
362 lefcha 1.5 */
363 lefcha 1.30 int
364 lefcha 1.37 imap_close(conn_t * conn)
365 lefcha 1.5 {
366 lefcha 1.36 reset_buffer(&obuf);
367     check_buffer(&obuf, strlen("CLOSE") + 12);
368 lefcha 1.4
369 lefcha 1.39 snprintf(obuf.data, obuf.size, "%04X CLOSE\r\n", tag);
370 lefcha 1.13
371 lefcha 1.37 return send_command(conn, obuf.data);
372 lefcha 1.5 }
373 lefcha 1.4
374 lefcha 1.1
375     /*
376 lefcha 1.13 * IMAP EXPUNGE: permanently removes any messages with the \Deleted flag set.
377 lefcha 1.25 */
378 lefcha 1.30 int
379 lefcha 1.37 imap_expunge(conn_t * conn)
380 lefcha 1.1 {
381 lefcha 1.36 reset_buffer(&obuf);
382     check_buffer(&obuf, strlen("EXPUNGE") + 12);
383 lefcha 1.1
384 lefcha 1.39 snprintf(obuf.data, obuf.size, "%04X EXPUNGE\r\n", tag);
385 lefcha 1.4
386 lefcha 1.37 return send_command(conn, obuf.data);
387 lefcha 1.25 }

webmaster@linux.gr
ViewVC Help
Powered by ViewVC 1.1.26