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
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
|
/*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
*
* This program 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 General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* Jabber
* Copyright (C) 1998-1999 The Jabber Team http://jabber.org/
*/
#include <string.h>
#include <stdlib.h>
#include <sys/types.h>
#include <stdio.h>
#include <setjmp.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <errno.h>
#include <signal.h>
#include <stdarg.h>
#include <time.h>
#include <ctype.h>
#ifdef _WIN32
#undef DATADIR
#include "sock.h"
#endif
#include "lib.h"
#ifndef INCL_JABBER_H
#define INCL_JABBER_H
#ifdef __cplusplus
extern "C" {
#endif
/* --------------------------------------------------------- */
/* */
/* JID structures & constants */
/* */
/* --------------------------------------------------------- */
#define JID_RESOURCE 1
#define JID_USER 2
#define JID_SERVER 4
typedef struct jid_struct
{
pool p;
char* resource;
char* user;
char* server;
char* full;
struct jid_struct *next; /* for lists of jids */
} *jid;
jid jid_new(pool p, char *idstr); /* Creates a jabber id from the idstr */
void jid_set(jid id, char *str, int item); /* Individually sets jid components */
char* jid_full(jid id); /* Builds a string type=user/resource@server from the jid data */
int jid_cmp(jid a, jid b); /* Compares two jid's, returns 0 for perfect match */
int jid_cmpx(jid a, jid b, int parts); /* Compares just the parts specified as JID_|JID_ */
jid jid_append(jid a, jid b); /* Appending b to a (list), no dups */
xmlnode jid_xres(jid id); /* Returns xmlnode representation of the resource?query=string */
xmlnode jid_nodescan(jid id, xmlnode x); /* Scans the children of the node for a matching jid attribute */
jid jid_user(jid a); /* returns the same jid but just of the user@host part */
/* --------------------------------------------------------- */
/* */
/* JPacket structures & constants */
/* */
/* --------------------------------------------------------- */
#define JPACKET_UNKNOWN 0x00
#define JPACKET_MESSAGE 0x01
#define JPACKET_PRESENCE 0x02
#define JPACKET_IQ 0x04
#define JPACKET_S10N 0x08
#define JPACKET__UNKNOWN 0
#define JPACKET__NONE 1
#define JPACKET__ERROR 2
#define JPACKET__CHAT 3
#define JPACKET__GROUPCHAT 4
#define JPACKET__GET 5
#define JPACKET__SET 6
#define JPACKET__RESULT 7
#define JPACKET__SUBSCRIBE 8
#define JPACKET__SUBSCRIBED 9
#define JPACKET__UNSUBSCRIBE 10
#define JPACKET__UNSUBSCRIBED 11
#define JPACKET__AVAILABLE 12
#define JPACKET__UNAVAILABLE 13
#define JPACKET__PROBE 14
#define JPACKET__HEADLINE 15
#define JPACKET__INVISIBLE 16
typedef struct jpacket_struct
{
unsigned char type;
int subtype;
int flag;
void* aux1;
xmlnode x;
jid to;
jid from;
char* iqns;
xmlnode iq;
pool p;
} *jpacket, _jpacket;
jpacket jpacket_new(xmlnode x); /* Creates a jabber packet from the xmlnode */
int jpacket_subtype(jpacket p); /* Returns the subtype value (looks at xmlnode for it) */
/* --------------------------------------------------------- */
/* */
/* Presence Proxy DB structures & constants */
/* */
/* --------------------------------------------------------- */
typedef struct ppdb_struct
{
jid id; /* entry data */
int pri;
xmlnode x;
struct ppdb_struct* user; /* linked list for user@server */
pool p; /* db-level data */
struct ppdb_struct* next;
} _ppdb, *ppdb;
ppdb ppdb_insert(ppdb db, jid id, xmlnode x); /* Inserts presence into the proxy */
xmlnode ppdb_primary(ppdb db, jid id); /* Fetches the matching primary presence for the id */
void ppdb_free(ppdb db); /* Frees the db and all entries */
xmlnode ppdb_get(ppdb db, jid id); /* Called successively to return each presence xmlnode */
/* for the id and children, returns NULL at the end */
/* --------------------------------------------------------- */
/* */
/* Simple Jabber Rate limit functions */
/* */
/* --------------------------------------------------------- */
typedef struct jlimit_struct
{
char *key;
int start;
int points;
int maxt, maxp;
pool p;
} *jlimit, _jlimit;
jlimit jlimit_new(int maxt, int maxp);
void jlimit_free(jlimit r);
int jlimit_check(jlimit r, char *key, int points);
/* --------------------------------------------------------- */
/* */
/* Error structures & constants */
/* */
/* --------------------------------------------------------- */
typedef struct terror_struct
{
int code;
char msg[64];
} terror;
#define TERROR_BAD (terror){400,"Bad Request"}
#define TERROR_AUTH (terror){401,"Unauthorized"}
#define TERROR_PAY (terror){402,"Payment Required"}
#define TERROR_FORBIDDEN (terror){403,"Forbidden"}
#define TERROR_NOTFOUND (terror){404,"Not Found"}
#define TERROR_NOTALLOWED (terror){405,"Not Allowed"}
#define TERROR_NOTACCEPTABLE (terror){406,"Not Acceptable"}
#define TERROR_REGISTER (terror){407,"Registration Required"}
#define TERROR_REQTIMEOUT (terror){408,"Request Timeout"}
#define TERROR_CONFLICT (terror){409,"Conflict"}
#define TERROR_INTERNAL (terror){500,"Internal Server Error"}
#define TERROR_NOTIMPL (terror){501,"Not Implemented"}
#define TERROR_EXTERNAL (terror){502,"Remote Server Error"}
#define TERROR_UNAVAIL (terror){503,"Service Unavailable"}
#define TERROR_EXTTIMEOUT (terror){504,"Remote Server Timeout"}
#define TERROR_DISCONNECTED (terror){510,"Disconnected"}
/* --------------------------------------------------------- */
/* */
/* Namespace constants */
/* */
/* --------------------------------------------------------- */
#define NSCHECK(x,n) (j_strcmp(xmlnode_get_attrib(x,"xmlns"),n) == 0)
#define NS_CLIENT "jabber:client"
#define NS_SERVER "jabber:server"
#define NS_AUTH "jabber:iq:auth"
#define NS_REGISTER "jabber:iq:register"
#define NS_ROSTER "jabber:iq:roster"
#define NS_OFFLINE "jabber:x:offline"
#define NS_AGENT "jabber:iq:agent"
#define NS_AGENTS "jabber:iq:agents"
#define NS_DELAY "jabber:x:delay"
#define NS_VERSION "jabber:iq:version"
#define NS_TIME "jabber:iq:time"
#define NS_VCARD "vcard-temp"
#define NS_PRIVATE "jabber:iq:private"
#define NS_SEARCH "jabber:iq:search"
#define NS_OOB "jabber:iq:oob"
#define NS_XOOB "jabber:x:oob"
#define NS_ADMIN "jabber:iq:admin"
#define NS_FILTER "jabber:iq:filter"
#define NS_AUTH_0K "jabber:iq:auth:0k"
/* --------------------------------------------------------- */
/* */
/* Message Types */
/* */
/* --------------------------------------------------------- */
#define TMSG_NORMAL "normal"
#define TMSG_ERROR "error"
#define TMSG_CHAT "chat"
#define TMSG_GROUPCHAT "groupchat"
#define TMSG_HEADLINE "headline"
/* --------------------------------------------------------- */
/* */
/* JUtil functions */
/* */
/* --------------------------------------------------------- */
xmlnode jutil_presnew(int type, char *to, char *status); /* Create a skeleton presence packet */
xmlnode jutil_iqnew(int type, char *ns); /* Create a skeleton iq packet */
xmlnode jutil_msgnew(char *type, char *to, char *subj, char *body);
/* Create a skeleton message packet */
xmlnode jutil_header(char* xmlns, char* server); /* Create a skeleton stream packet */
int jutil_priority(xmlnode x); /* Determine priority of this packet */
void jutil_tofrom(xmlnode x); /* Swaps to/from fields on a packet */
xmlnode jutil_iqresult(xmlnode x); /* Generate a skeleton iq/result, given a iq/query */
char* jutil_timestamp(void); /* Get stringified timestamp */
void jutil_error(xmlnode x, terror E); /* Append an <error> node to x */
void jutil_delay(xmlnode msg, char *reason); /* Append a delay packet to msg */
char* jutil_regkey(char *key, char *seed); /* pass a seed to generate a key, pass the key again to validate (returns it) */
/* --------------------------------------------------------- */
/* */
/* JConn structures & functions */
/* */
/* --------------------------------------------------------- */
#define JCONN_STATE_OFF 0
#define JCONN_STATE_CONNECTED 1
#define JCONN_STATE_ON 2
#define JCONN_STATE_AUTH 3
typedef struct jconn_struct
{
/* Core structure */
pool p; /* Memory allocation pool */
int state; /* Connection state flag */
int fd; /* Connection file descriptor */
jid user; /* User info */
char *pass; /* User passwd */
/* Stream stuff */
int id; /* id counter for jab_getid() function */
char idbuf[9]; /* temporary storage for jab_getid() */
char *sid; /* stream id from server, for digest auth */
XML_Parser parser; /* Parser instance */
xmlnode current; /* Current node in parsing instance.. */
/* Event callback ptrs */
void (*on_state)(struct jconn_struct *j, int state);
void (*on_packet)(struct jconn_struct *j, jpacket p);
} *jconn, jconn_struct;
typedef void (*jconn_state_h)(jconn j, int state);
typedef void (*jconn_packet_h)(jconn j, jpacket p);
jconn jab_new(char *user, char *pass);
void jab_delete(jconn j);
void jab_state_handler(jconn j, jconn_state_h h);
void jab_packet_handler(jconn j, jconn_packet_h h);
void jab_start(jconn j);
void jab_stop(jconn j);
int jab_getfd(jconn j);
jid jab_getjid(jconn j);
char *jab_getsid(jconn j);
char *jab_getid(jconn j);
void jab_send(jconn j, xmlnode x);
void jab_send_raw(jconn j, const char *str);
void jab_recv(jconn j);
void jab_poll(jconn j, int timeout);
char *jab_auth(jconn j);
char *jab_reg(jconn j);
#ifdef __cplusplus
}
#endif
#endif /* INCL_JABBER_H */
|
