|
25
|
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 |
