]> git.stg.codes - stg.git/blob - stglibs/srvconf.lib/servconf.cpp
Добавлен файл версии
[stg.git] / stglibs / srvconf.lib / servconf.cpp
1 /*
2  *    This program is free software; you can redistribute it and/or modify
3  *    it under the terms of the GNU General Public License as published by
4  *    the Free Software Foundation; either version 2 of the License, or
5  *    (at your option) any later version.
6  *
7  *    This program is distributed in the hope that it will be useful,
8  *    but WITHOUT ANY WARRANTY; without even the implied warranty of
9  *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
10  *    GNU General Public License for more details.
11  *
12  *    You should have received a copy of the GNU General Public License
13  *    along with this program; if not, write to the Free Software
14  *    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
15  */
16
17 /*
18  *    Author : Boris Mikhailenko <stg34@stargazer.dp.ua>
19  */
20
21  /*
22  $Revision: 1.8 $
23  $Date: 2010/08/04 00:40:38 $
24  $Author: faust $
25  */
26
27 #include <stdio.h>
28 #include <string.h>
29
30 #include "servconf.h"
31
32 using namespace std;
33
34 //-----------------------------------------------------------------------------
35 int AnsRecv(void * data, list<string> * list1)
36 {
37 //NODE * node;
38 SERVCONF * sc;
39 char ans[ENC_MSG_LEN + 1];
40 int len, done = 0;
41
42 sc = (SERVCONF*)data;
43
44 XML_ParserReset(sc->parser, NULL);
45 XML_SetElementHandler(sc->parser, Start, End);
46 XML_SetUserData(sc->parser, data);
47
48 //loop parsing
49 list<string>::iterator node;
50 node = list1->begin();
51
52 if (node == list1->end())
53     {
54     return st_ok;
55     }
56
57 while (node != list1->end())
58     {
59     strncpy(ans, node->c_str(), ENC_MSG_LEN);
60     ans[ENC_MSG_LEN] = 0;
61        //printf("---> %s\n", ans);
62     len = strlen(ans);
63
64     if (XML_Parse(sc->parser, ans, len, done) == XML_STATUS_ERROR)
65         {
66         snprintf(sc->errorMsg, MAX_ERR_STR_LEN, "XML parse error at line %d: %s",
67                  static_cast<int>(XML_GetCurrentLineNumber(sc->parser)),
68                  XML_ErrorString(XML_GetErrorCode(sc->parser)));
69         printf(sc->errorMsg, "XML parse error at line %d: %s",
70                XML_GetCurrentLineNumber(sc->parser),
71                XML_ErrorString(XML_GetErrorCode(sc->parser)));
72         return st_xml_parse_error;
73         }
74     ++node;
75
76     }
77
78 return 0;
79 }
80 //-----------------------------------------------------------------------------
81 void Start(void *data, const char *el, const char **attr)
82 {
83 SERVCONF * sc;
84 sc = (SERVCONF*)data;
85 sc->Start(el, attr);
86 }
87 //-----------------------------------------------------------------------------
88 void End(void *data, const char *el)
89 {
90 SERVCONF * sc;
91 sc = (SERVCONF*)data;
92 sc->End(el);
93 }
94 //-----------------------------------------------------------------------------
95 SERVCONF::SERVCONF()
96 {
97 parser = XML_ParserCreate(NULL);
98 parseDepth = 0;
99 }
100 //-----------------------------------------------------------------------------
101 void SERVCONF::SetServer(const char * server)
102 {
103 nt.SetServer(server);
104 }
105 //-----------------------------------------------------------------------------
106 void SERVCONF::SetPort(uint16_t port)
107 {
108 nt.SetServerPort(port);
109 }
110 //-----------------------------------------------------------------------------
111 void SERVCONF::SetAdmLogin(const char * login)
112 {
113 nt.SetLogin(login);
114 }
115 //-----------------------------------------------------------------------------
116 void SERVCONF::SetAdmPassword(const char * password)
117 {
118 nt.SetPassword(password);
119 }
120 //-----------------------------------------------------------------------------
121 int SERVCONF::GetUser(const char * l)
122 {
123 char request[255];
124 snprintf(request, 255, "<GetUser login=\"%s\"/>", l);
125 int ret;
126
127 currParser = &parserGetUser;
128 ((PARSER_GET_USER*)currParser)->SetUserDataRecvCb(RecvGetUserDataCb, getUserDataDataCb);
129
130 nt.Reset();
131 nt.SetRxCallback(this, AnsRecv);
132
133 if ((ret = nt.Connect()) != st_ok)
134     {
135     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
136     return ret;
137     }
138 if ((ret = nt.Transact(request)) != st_ok)
139     {
140     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
141     return ret;
142     }
143 if ((ret = nt.Disconnect()) != st_ok)
144     {
145     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
146     return ret;
147     }
148
149 return st_ok;
150 }
151 //-----------------------------------------------------------------------------
152 int SERVCONF::GetUsers()
153 {
154 char request[] = "<GetUsers/>";
155 int ret;
156
157 currParser = &parserGetUsers;
158 ((PARSER_GET_USERS*)currParser)->SetUserDataRecvCb(RecvUserDataCb, getUsersDataDataCb);
159
160 nt.Reset();
161 nt.SetRxCallback(this, AnsRecv);
162
163 if ((ret = nt.Connect()) != st_ok)
164     {
165     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
166     return ret;
167     }
168 if ((ret = nt.Transact(request)) != st_ok)
169     {
170     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
171     return ret;
172     }
173 if ((ret = nt.Disconnect()) != st_ok)
174     {
175     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
176     return ret;
177     }
178
179 return st_ok;
180 }
181 //-----------------------------------------------------------------------------
182 int SERVCONF::SendMessage(const char * login, const char * message, int prio)
183 {
184 char request[1000];
185 char msg[500];
186 Encode12(msg, message, strlen(message));
187 snprintf(request, 1000, "<Message login=\"%s\" priority=\"%d\" text=\"%s\"/>", login, prio, msg);
188 int ret;
189
190 currParser = &parserSendMessage;
191 parserSendMessage.SetSendMessageRecvCb(RecvSendMessageCb, sendMessageDataCb);
192
193 nt.Reset();
194 nt.SetRxCallback(this, AnsRecv);
195
196 if ((ret = nt.Connect()) != st_ok)
197     {
198     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
199     return ret;
200     }
201 if ((ret = nt.Transact(request)) != st_ok)
202     {
203     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
204     return ret;
205     }
206 if ((ret = nt.Disconnect()) != st_ok)
207     {
208     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
209     return ret;
210     }
211
212 return st_ok;
213 }
214 //-----------------------------------------------------------------------------
215 int SERVCONF::GetServerInfo()
216 {
217 char request[] = "<GetServerInfo/>";
218 int ret;
219
220 currParser = &parserServerInfo;
221 ((PARSER_GET_SERVER_INFO*)currParser)->SetServerInfoRecvCb(RecvServerInfoDataCb, getServerInfoDataCb);
222
223 nt.Reset();
224 nt.SetRxCallback(this, AnsRecv);
225
226 if ((ret = nt.Connect()) != st_ok)
227     {
228     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
229     return ret;
230     }
231 if ((ret = nt.Transact(request)) != st_ok)
232     {
233     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
234     return ret;
235     }
236 if ((ret = nt.Disconnect()) != st_ok)
237     {
238     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
239     return ret;
240     }
241
242 return st_ok;
243 }
244 //-----------------------------------------------------------------------------
245 int SERVCONF::ChgUser(const char * request)
246 {
247 int ret;
248
249 currParser = &parserChgUser;
250 ((PARSER_CHG_USER*)currParser)->SetChgUserRecvCb(RecvChgUserCb, chgUserDataCb);
251
252 nt.Reset();
253 nt.SetRxCallback(this, AnsRecv);
254
255 if ((ret = nt.Connect()) != st_ok)
256     {
257     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
258     printfd(__FILE__, "Error on connect: '%s'\n", errorMsg);
259     return ret;
260     }
261 if ((ret = nt.Transact(request)) != st_ok)
262     {
263     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
264     printfd(__FILE__, "Error on transact: '%s'\n", errorMsg);
265     return ret;
266     }
267 if ((ret = nt.Disconnect()) != st_ok)
268     {
269     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
270     printfd(__FILE__, "Error on disconnect: '%s'\n", errorMsg);
271     return ret;
272     }
273
274 return st_ok;
275 }
276 //-----------------------------------------------------------------------------
277 //  TODO: remove this shit!
278 //-----------------------------------------------------------------------------
279 int SERVCONF::MsgUser(const char * request)
280 {
281 int ret;
282
283 currParser = &parserSendMessage;
284 parserSendMessage.SetSendMessageRecvCb(RecvSendMessageCb, sendMessageDataCb);
285
286 nt.Reset();
287 nt.SetRxCallback(this, AnsRecv);
288
289 if ((ret = nt.Connect()) != st_ok)
290     {
291     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
292     return ret;
293     }
294 if ((ret = nt.Transact(request)) != st_ok)
295     {
296     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
297     return ret;
298     }
299 if ((ret = nt.Disconnect()) != st_ok)
300     {
301     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
302     return ret;
303     }
304
305 return st_ok;
306 }
307 //-----------------------------------------------------------------------------
308 int SERVCONF::CheckUser(const char * login, const char * password)
309 {
310 char request[255];
311 snprintf(request, 255, "<CheckUser login=\"%s\" password=\"%s\"/>", login, password);
312 int ret;
313
314 currParser = &parserCheckUser;
315 ((PARSER_CHECK_USER*)currParser)->SetCheckUserRecvCb(RecvCheckUserCb, checkUserDataCb);
316
317 nt.Reset();
318 nt.SetRxCallback(this, AnsRecv);
319
320 if ((ret = nt.Connect()) != st_ok)
321     {
322     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
323     return ret;
324     }
325 if ((ret = nt.Transact(request)) != st_ok)
326     {
327     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
328     return ret;
329     }
330 if ((ret = nt.Disconnect()) != st_ok)
331     {
332     strncpy(errorMsg, nt.GetError(), MAX_ERR_STR_LEN);
333     return ret;
334     }
335
336 return st_ok;
337 }
338 //-----------------------------------------------------------------------------
339 int SERVCONF::Start(const char *el, const char **attr)
340 {
341 currParser->ParseStart(el, attr);
342 return 0;
343 }
344 //-----------------------------------------------------------------------------
345 void SERVCONF::End(const char *el)
346 {
347 currParser->ParseEnd(el);
348 }
349 //-----------------------------------------------------------------------------
350 void SERVCONF::SetUserDataRecvCb(RecvUserDataCb_t f, void * data)
351 {
352 RecvUserDataCb = f;
353 getUsersDataDataCb = data;
354 }
355 //-----------------------------------------------------------------------------
356 void SERVCONF::SetGetUserDataRecvCb(RecvUserDataCb_t f, void * data)
357 {
358 RecvGetUserDataCb = f;            //GET_USER
359 getUserDataDataCb = data;
360 }
361 //-----------------------------------------------------------------------------
362 void SERVCONF::SetServerInfoRecvCb(RecvServerInfoDataCb_t f, void * data)
363 {
364 RecvServerInfoDataCb = f;
365 getServerInfoDataCb = data;
366 }
367 //-----------------------------------------------------------------------------
368 void SERVCONF::SetChgUserCb(RecvChgUserCb_t f, void * data)
369 {
370 RecvChgUserCb = f;
371 chgUserDataCb = data;
372 }
373 //-----------------------------------------------------------------------------
374 void SERVCONF::SetCheckUserCb(RecvCheckUserCb_t f, void * data)
375 {
376 RecvCheckUserCb = f;
377 checkUserDataCb = data;
378 }
379 //-----------------------------------------------------------------------------
380 void SERVCONF::SetSendMessageCb(RecvSendMessageCb_t f, void * data)
381 {
382 RecvSendMessageCb = f;
383 sendMessageDataCb = data;
384 }
385 //-----------------------------------------------------------------------------
386 char * SERVCONF::GetStrError()
387 {
388 return errorMsg;
389 }
390 //-----------------------------------------------------------------------------
391 int SERVCONF::GetError()
392 {
393 int e = error;
394 error = 0;
395 return e;
396 }
397 //-----------------------------------------------------------------------------
398