1347
|
1 #include "jabber.h"
|
|
2
|
|
3 /* util for making presence packets */
|
|
4 xmlnode jutil_presnew(int type, char *to, char *status)
|
|
5 {
|
|
6 xmlnode pres;
|
|
7
|
|
8 pres = xmlnode_new_tag("presence");
|
|
9 switch(type)
|
|
10 {
|
|
11 case JPACKET__SUBSCRIBE:
|
|
12 xmlnode_put_attrib(pres,"type","subscribe");
|
|
13 break;
|
|
14 case JPACKET__UNSUBSCRIBE:
|
|
15 xmlnode_put_attrib(pres,"type","unsubscribe");
|
|
16 break;
|
|
17 case JPACKET__SUBSCRIBED:
|
|
18 xmlnode_put_attrib(pres,"type","subscribed");
|
|
19 break;
|
|
20 case JPACKET__UNSUBSCRIBED:
|
|
21 xmlnode_put_attrib(pres,"type","unsubscribed");
|
|
22 break;
|
|
23 case JPACKET__PROBE:
|
|
24 xmlnode_put_attrib(pres,"type","probe");
|
|
25 break;
|
|
26 case JPACKET__UNAVAILABLE:
|
|
27 xmlnode_put_attrib(pres,"type","unavailable");
|
|
28 break;
|
|
29 }
|
|
30 if(to != NULL)
|
|
31 xmlnode_put_attrib(pres,"to",to);
|
|
32 if(status != NULL)
|
|
33 xmlnode_insert_cdata(xmlnode_insert_tag(pres,"status"),status,strlen(status));
|
|
34
|
|
35 return pres;
|
|
36 }
|
|
37
|
|
38 /* util for making IQ packets */
|
|
39 xmlnode jutil_iqnew(int type, char *ns)
|
|
40 {
|
|
41 xmlnode iq;
|
|
42
|
|
43 iq = xmlnode_new_tag("iq");
|
|
44 switch(type)
|
|
45 {
|
|
46 case JPACKET__GET:
|
|
47 xmlnode_put_attrib(iq,"type","get");
|
|
48 break;
|
|
49 case JPACKET__SET:
|
|
50 xmlnode_put_attrib(iq,"type","set");
|
|
51 break;
|
|
52 case JPACKET__RESULT:
|
|
53 xmlnode_put_attrib(iq,"type","result");
|
|
54 break;
|
|
55 case JPACKET__ERROR:
|
|
56 xmlnode_put_attrib(iq,"type","error");
|
|
57 break;
|
|
58 }
|
|
59 xmlnode_put_attrib(xmlnode_insert_tag(iq,"query"),"xmlns",ns);
|
|
60
|
|
61 return iq;
|
|
62 }
|
|
63
|
|
64 /* util for making message packets */
|
|
65 xmlnode jutil_msgnew(char *type, char *to, char *subj, char *body)
|
|
66 {
|
|
67 xmlnode msg;
|
|
68
|
|
69 msg = xmlnode_new_tag("message");
|
|
70 xmlnode_put_attrib (msg, "type", type);
|
|
71 xmlnode_put_attrib (msg, "to", to);
|
|
72
|
|
73 if (subj)
|
|
74 {
|
|
75 xmlnode_insert_cdata (xmlnode_insert_tag (msg, "subject"), subj, strlen (subj));
|
|
76 }
|
|
77
|
|
78 xmlnode_insert_cdata (xmlnode_insert_tag (msg, "body"), body, strlen (body));
|
|
79
|
|
80 return msg;
|
|
81 }
|
|
82
|
|
83 /* util for making stream packets */
|
|
84 xmlnode jutil_header(char* xmlns, char* server)
|
|
85 {
|
|
86 xmlnode result;
|
|
87 if ((xmlns == NULL)||(server == NULL))
|
|
88 return NULL;
|
|
89 result = xmlnode_new_tag("stream:stream");
|
|
90 xmlnode_put_attrib(result, "xmlns:stream", "http://etherx.jabber.org/streams");
|
|
91 xmlnode_put_attrib(result, "xmlns", xmlns);
|
|
92 xmlnode_put_attrib(result, "to", server);
|
|
93
|
|
94 return result;
|
|
95 }
|
|
96
|
|
97 /* returns the priority on a presence packet */
|
|
98 int jutil_priority(xmlnode x)
|
|
99 {
|
|
100 char *str;
|
|
101 int p;
|
|
102
|
|
103 if(x == NULL)
|
|
104 return -1;
|
|
105
|
|
106 if(xmlnode_get_attrib(x,"type") != NULL)
|
|
107 return -1;
|
|
108
|
|
109 x = xmlnode_get_tag(x,"priority");
|
|
110 if(x == NULL)
|
|
111 return 0;
|
|
112
|
|
113 str = xmlnode_get_data((x));
|
|
114 if(str == NULL)
|
|
115 return 0;
|
|
116
|
|
117 p = atoi(str);
|
|
118 if(p >= 0)
|
|
119 return p;
|
|
120 else
|
|
121 return 0;
|
|
122 }
|
|
123
|
|
124 void jutil_tofrom(xmlnode x)
|
|
125 {
|
|
126 char *to, *from;
|
|
127
|
|
128 to = xmlnode_get_attrib(x,"to");
|
|
129 from = xmlnode_get_attrib(x,"from");
|
|
130 xmlnode_put_attrib(x,"from",to);
|
|
131 xmlnode_put_attrib(x,"to",from);
|
|
132 }
|
|
133
|
|
134 xmlnode jutil_iqresult(xmlnode x)
|
|
135 {
|
|
136 xmlnode cur;
|
|
137
|
|
138 jutil_tofrom(x);
|
|
139
|
|
140 xmlnode_put_attrib(x,"type","result");
|
|
141
|
|
142 /* hide all children of the iq, they go back empty */
|
|
143 for(cur = xmlnode_get_firstchild(x); cur != NULL; cur = xmlnode_get_nextsibling(cur))
|
|
144 xmlnode_hide(cur);
|
|
145
|
|
146 return x;
|
|
147 }
|
|
148
|
|
149 char *jutil_timestamp(void)
|
|
150 {
|
|
151 time_t t;
|
|
152 struct tm *new_time;
|
|
153 static char timestamp[18];
|
|
154 int ret;
|
|
155
|
|
156 t = time(NULL);
|
|
157
|
|
158 if(t == (time_t)-1)
|
|
159 return NULL;
|
|
160 new_time = gmtime(&t);
|
|
161
|
|
162 ret = snprintf(timestamp, 18, "%d%02d%02dT%02d:%02d:%02d", 1900+new_time->tm_year,
|
|
163 new_time->tm_mon+1, new_time->tm_mday, new_time->tm_hour,
|
|
164 new_time->tm_min, new_time->tm_sec);
|
|
165
|
|
166 if(ret == -1)
|
|
167 return NULL;
|
|
168
|
|
169 return timestamp;
|
|
170 }
|
|
171
|
|
172 void jutil_error(xmlnode x, terror E)
|
|
173 {
|
|
174 xmlnode err;
|
|
175 char code[4];
|
|
176
|
|
177 xmlnode_put_attrib(x,"type","error");
|
|
178 err = xmlnode_insert_tag(x,"error");
|
|
179
|
|
180 snprintf(code,4,"%d",E.code);
|
|
181 xmlnode_put_attrib(err,"code",code);
|
|
182 if(E.msg != NULL)
|
|
183 xmlnode_insert_cdata(err,E.msg,strlen(E.msg));
|
|
184
|
|
185 jutil_tofrom(x);
|
|
186 }
|
|
187
|
|
188 void jutil_delay(xmlnode msg, char *reason)
|
|
189 {
|
|
190 xmlnode delay;
|
|
191
|
|
192 delay = xmlnode_insert_tag(msg,"x");
|
|
193 xmlnode_put_attrib(delay,"xmlns",NS_DELAY);
|
|
194 xmlnode_put_attrib(delay,"from",xmlnode_get_attrib(msg,"to"));
|
|
195 xmlnode_put_attrib(delay,"stamp",jutil_timestamp());
|
|
196 if(reason != NULL)
|
|
197 xmlnode_insert_cdata(delay,reason,strlen(reason));
|
|
198 }
|
|
199
|
|
200 #define KEYBUF 100
|
|
201
|
|
202 char *jutil_regkey(char *key, char *seed)
|
|
203 {
|
|
204 static char keydb[KEYBUF][41];
|
|
205 static char seeddb[KEYBUF][41];
|
|
206 static int last = -1;
|
|
207 char *str, strint[32];
|
|
208 int i;
|
|
209
|
|
210 /* blanket the keydb first time */
|
|
211 if(last == -1)
|
|
212 {
|
|
213 last = 0;
|
|
214 memset(&keydb,0,KEYBUF*41);
|
|
215 memset(&seeddb,0,KEYBUF*41);
|
|
216 srand(time(NULL));
|
|
217 }
|
|
218
|
|
219 /* creation phase */
|
|
220 if(key == NULL && seed != NULL)
|
|
221 {
|
|
222 /* create a random key hash and store it */
|
|
223 sprintf(strint,"%d",rand());
|
|
224 strcpy(keydb[last],shahash(strint));
|
|
225
|
|
226 /* store a hash for the seed associated w/ this key */
|
|
227 strcpy(seeddb[last],shahash(seed));
|
|
228
|
|
229 /* return it all */
|
|
230 str = keydb[last];
|
|
231 last++;
|
|
232 if(last == KEYBUF) last = 0;
|
|
233 return str;
|
|
234 }
|
|
235
|
|
236 /* validation phase */
|
|
237 str = shahash(seed);
|
|
238 for(i=0;i<KEYBUF;i++)
|
|
239 if(j_strcmp(keydb[i],key) == 0 && j_strcmp(seeddb[i],str) == 0)
|
|
240 {
|
|
241 seeddb[i][0] = '\0'; /* invalidate this key */
|
|
242 return keydb[i];
|
|
243 }
|
|
244
|
|
245 return NULL;
|
|
246 }
|
|
247
|