1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
|
/*
* LibSylph -- E-Mail client library
* Copyright (C) 1999-2006 Hiroyuki Yamamoto
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
*/
#ifndef __SESSION_H__
#define __SESSION_H__
#ifdef HAVE_CONFIG_H
# include "config.h"
#endif
#include <glib.h>
#include <stdio.h>
#include <time.h>
#include <unistd.h>
#include "socket.h"
#define SESSION_BUFFSIZE 8192
typedef struct _Session Session;
#define SESSION(obj) ((Session *)obj)
typedef enum {
SESSION_UNKNOWN,
SESSION_IMAP,
SESSION_NEWS,
SESSION_SMTP,
SESSION_POP3
} SessionType;
typedef enum {
SESSION_READY,
SESSION_SEND,
SESSION_RECV,
SESSION_EOF,
SESSION_TIMEOUT,
SESSION_ERROR,
SESSION_DISCONNECTED
} SessionState;
typedef enum
{
SESSION_MSG_NORMAL,
SESSION_MSG_SEND_DATA,
SESSION_MSG_RECV_DATA,
SESSION_MSG_CONTROL,
SESSION_MSG_ERROR,
SESSION_MSG_UNKNOWN
} SessionMsgType;
#ifndef USE_SSL
typedef enum
{
SSL_NONE
} SSLType;
#endif
typedef gint (*RecvMsgNotify) (Session *session,
const gchar *msg,
gpointer user_data);
typedef gint (*RecvDataProgressiveNotify) (Session *session,
guint cur_len,
guint total_len,
gpointer user_data);
typedef gint (*RecvDataNotify) (Session *session,
guint len,
gpointer user_data);
typedef gint (*SendDataProgressiveNotify) (Session *session,
guint cur_len,
guint total_len,
gpointer user_data);
typedef gint (*SendDataNotify) (Session *session,
guint len,
gpointer user_data);
struct _Session
{
SessionType type;
SockInfo *sock;
gchar *server;
gushort port;
SSLType ssl_type;
gboolean nonblocking;
SessionState state;
time_t last_access_time;
GTimeVal tv_prev;
gint conn_id;
gint io_tag;
gchar read_buf[SESSION_BUFFSIZE];
gchar *read_buf_p;
gint read_buf_len;
/* buffer for short messages */
GString *read_msg_buf;
/* buffer for relatively short multiple lines data */
GByteArray *read_data_buf;
gchar *read_data_terminator;
/* buffer for large data */
FILE *read_data_fp;
gint read_data_pos;
gint preread_len;
/* buffer for short messages */
gchar *write_buf;
gchar *write_buf_p;
gint write_buf_len;
/* buffer for large data */
FILE *write_data_fp;
gint write_data_pos;
gint write_data_len;
guint timeout_tag;
guint timeout_interval;
guint ping_tag;
gpointer data;
/* virtual methods to parse server responses */
gint (*recv_msg) (Session *session,
const gchar *msg);
gint (*send_data_finished) (Session *session,
guint len);
gint (*recv_data_finished) (Session *session,
guchar *data,
guint len);
gint (*recv_data_as_file_finished) (Session *session,
FILE *fp,
guint len);
void (*destroy) (Session *session);
/* notification functions */
RecvMsgNotify recv_msg_notify;
RecvDataProgressiveNotify recv_data_progressive_notify;
RecvDataNotify recv_data_notify;
SendDataProgressiveNotify send_data_progressive_notify;
SendDataNotify send_data_notify;
gpointer recv_msg_notify_data;
gpointer recv_data_progressive_notify_data;
gpointer recv_data_notify_data;
gpointer send_data_progressive_notify_data;
gpointer send_data_notify_data;
};
void session_init (Session *session);
gint session_connect (Session *session,
const gchar *server,
gushort port);
gint session_disconnect (Session *session);
void session_destroy (Session *session);
gboolean session_is_connected (Session *session);
void session_set_access_time (Session *session);
void session_set_timeout (Session *session,
guint interval);
void session_set_recv_message_notify (Session *session,
RecvMsgNotify notify_func,
gpointer data);
void session_set_recv_data_progressive_notify
(Session *session,
RecvDataProgressiveNotify notify_func,
gpointer data);
void session_set_recv_data_notify (Session *session,
RecvDataNotify notify_func,
gpointer data);
void session_set_send_data_progressive_notify
(Session *session,
SendDataProgressiveNotify notify_func,
gpointer data);
void session_set_send_data_notify (Session *session,
SendDataNotify notify_func,
gpointer data);
#if USE_SSL
gint session_start_tls (Session *session);
#endif
gint session_send_msg (Session *session,
SessionMsgType type,
const gchar *msg);
gint session_recv_msg (Session *session);
gint session_send_data (Session *session,
FILE *data_fp,
guint size);
gint session_recv_data (Session *session,
guint size,
const gchar *terminator);
gint session_recv_data_as_file (Session *session,
guint size,
const gchar *terminator);
#endif /* __SESSION_H__ */
|
