]> git.stg.codes - stg.git/blob - projects/stargazer/plugins/configuration/sgconfig/parser.cpp
При записи информации в файловом плагине теперь используется функционал
[stg.git] / projects / stargazer / plugins / configuration / sgconfig / parser.cpp
1 #include <string.h>
2 #include <errno.h>
3 #include <stdio.h>
4 #include <sys/utsname.h>
5 #include <sys/types.h>
6 #include <sys/socket.h>
7 #include <netinet/in.h>
8 #include <arpa/inet.h>
9 #include <sstream>
10
11 #include "parser.h"
12 #include "version.h"
13
14 #define  UNAME_LEN      (256)
15 //-----------------------------------------------------------------------------
16 //  GET SERVER INFO
17 //-----------------------------------------------------------------------------
18 int PARSER_GET_SERVER_INFO::ParseStart(void *, const char *el, const char **)
19 {
20 answerList->erase(answerList->begin(), answerList->end());
21 if (strcasecmp(el, "GetServerInfo") == 0)
22     {
23     return 0;
24     }
25 return -1;
26 }
27 //-----------------------------------------------------------------------------
28 int PARSER_GET_SERVER_INFO::ParseEnd(void *, const char *el)
29 {
30 if (strcasecmp(el, "GetServerInfo") == 0)
31     {
32     CreateAnswer();
33     return 0;
34     }
35 return -1;
36 }
37 //-----------------------------------------------------------------------------
38 void PARSER_GET_SERVER_INFO::CreateAnswer()
39 {
40 char s[UNAME_LEN + 128];
41 char un[UNAME_LEN];
42 struct utsname utsn;
43
44 uname(&utsn);
45 un[0] = 0;
46
47 strcat(un, utsn.sysname);
48 strcat(un, " ");
49 strcat(un, utsn.release);
50 strcat(un, " ");
51 strcat(un, utsn.machine);
52 strcat(un, " ");
53 strcat(un, utsn.nodename);
54
55 //answerList->clear();
56 answerList->erase(answerList->begin(), answerList->end());
57 answerList->push_back("<ServerInfo>");
58
59 sprintf(s, "<version value=\"%s\"/>", SERVER_VERSION);
60 answerList->push_back(s);
61
62 sprintf(s, "<tariff_num value=\"%d\"/>", tariffs->GetTariffsNum());
63 answerList->push_back(s);
64
65 sprintf(s, "<tariff value=\"%d\"/>", 2);
66 answerList->push_back(s);
67
68 sprintf(s, "<users_num value=\"%d\"/>", users->GetUserNum());
69 answerList->push_back(s);
70
71 sprintf(s, "<uname value=\"%s\"/>", un);
72 answerList->push_back(s);
73
74 sprintf(s, "<dir_num value=\"%d\"/>", DIR_NUM);
75 answerList->push_back(s);
76
77 sprintf(s, "<day_fee value=\"%d\"/>", settings->GetDayFee());
78 answerList->push_back(s);
79
80 for (int i = 0; i< DIR_NUM; i++)
81     {
82     string dn2e;
83     Encode12str(dn2e, settings->GetDirName(i));
84     sprintf(s, "<dir_name_%d value=\"%s\"/>", i, dn2e.c_str());
85     answerList->push_back(s);
86     }
87
88 answerList->push_back("</ServerInfo>");
89 }
90 //-----------------------------------------------------------------------------
91 //  GET USER
92 //-----------------------------------------------------------------------------
93 PARSER_GET_USER::PARSER_GET_USER()
94 {
95
96 }
97 //-----------------------------------------------------------------------------
98 int PARSER_GET_USER::ParseStart(void *, const char *el, const char **attr)
99 {
100 if (strcasecmp(el, "GetUser") == 0)
101     {
102     if (attr[0] && attr[1])
103         login = attr[1];
104     else
105         {
106         //login.clear();
107         login.erase(login.begin(), login.end());
108         return -1;
109         }
110     return 0;
111     }
112 return -1;
113 }
114 //-----------------------------------------------------------------------------
115 int PARSER_GET_USER::ParseEnd(void *, const char *el)
116 {
117 if (strcasecmp(el, "GetUser") == 0)
118     {
119     CreateAnswer();
120     return 0;
121     }
122 return -1;
123 }
124 //-----------------------------------------------------------------------------
125 void PARSER_GET_USER::CreateAnswer()
126 {
127 string s;
128 string enc;
129
130 user_iter u;
131
132 answerList->erase(answerList->begin(), answerList->end());
133
134 if (users->FindByName(login, &u))
135     {
136     s = "<user result=\"error\"/>";
137     answerList->push_back(s);
138     return;
139     }
140
141 s = "<user result=\"ok\">";
142 answerList->push_back(s);
143
144 s = "<login value=\"" + u->GetLogin() + "\"/>";
145 answerList->push_back(s);
146
147 if (currAdmin.GetPriv()->userConf || currAdmin.GetPriv()->userPasswd)
148     s = "<password value=\"" + u->property.password.Get() + "\" />";
149 else
150     s = "<password value=\"++++++\"/>";
151 answerList->push_back(s);
152
153 strprintf(&s, "<cash value=\"%f\" />", u->property.cash.Get());
154 answerList->push_back(s);
155
156 strprintf(&s, "<freemb value=\"%f\" />", u->property.freeMb.Get());
157 answerList->push_back(s);
158
159 strprintf(&s, "<credit value=\"%f\" />", u->property.credit.Get());
160 answerList->push_back(s);
161
162 if (u->property.nextTariff.Get() != "")
163     {
164     strprintf(&s, "<tariff value=\"%s/%s\" />",
165               u->property.tariffName.Get().c_str(),
166               u->property.nextTariff.Get().c_str());
167     }
168 else
169     {
170     strprintf(&s, "<tariff value=\"%s\" />",
171               u->property.tariffName.Get().c_str());
172     }
173
174 answerList->push_back(s);
175
176 Encode12str(enc, u->property.note);
177 s = "<note value=\"" + enc + "\" />";
178 answerList->push_back(s);
179
180 Encode12str(enc, u->property.phone);
181 s = "<phone value=\"" + enc + "\" />";
182 answerList->push_back(s);
183
184 Encode12str(enc, u->property.address);
185 s = "<address value=\"" + enc + "\" />";
186 answerList->push_back(s);
187
188 Encode12str(enc, u->property.email);
189 s = "<email value=\"" + enc + "\" />";
190 answerList->push_back(s);
191
192
193 vector<USER_PROPERTY_LOGGED<string> *> userdata;
194 userdata.push_back(u->property.userdata0.GetPointer());
195 userdata.push_back(u->property.userdata1.GetPointer());
196 userdata.push_back(u->property.userdata2.GetPointer());
197 userdata.push_back(u->property.userdata3.GetPointer());
198 userdata.push_back(u->property.userdata4.GetPointer());
199 userdata.push_back(u->property.userdata5.GetPointer());
200 userdata.push_back(u->property.userdata6.GetPointer());
201 userdata.push_back(u->property.userdata7.GetPointer());
202 userdata.push_back(u->property.userdata8.GetPointer());
203 userdata.push_back(u->property.userdata9.GetPointer());
204
205 string tmpI;
206 for (unsigned i = 0; i < userdata.size(); i++)
207     {
208     Encode12str(enc, userdata[i]->Get());
209     s = "<UserData" + x2str(i, tmpI) + " value=\"" + enc + "\" />";
210     answerList->push_back(s);
211     }
212
213 Encode12str(enc, u->property.realName);
214 s = "<name value=\"" + enc + "\" />";
215 answerList->push_back(s);
216
217 Encode12str(enc, u->property.group);
218 s = "<GROUP value=\"" + enc + "\" />";
219 answerList->push_back(s);
220
221 strprintf(&s, "<status value=\"%d\" />", u->GetConnected());
222 answerList->push_back(s);
223
224 strprintf(&s, "<aonline value=\"%d\" />", u->property.alwaysOnline.Get());
225 answerList->push_back(s);
226
227 strprintf(&s, "<currip value=\"%s\" />", inet_ntostring(u->GetCurrIP()).c_str());
228 answerList->push_back(s);
229
230 strprintf(&s, "<PingTime value=\"%lu\" />", u->GetPingTime());
231 answerList->push_back(s);
232
233 stringstream sstr;
234 sstr << u->property.ips.Get();
235 strprintf(&s, "<ip value=\"%s\" />", sstr.str().c_str());
236 answerList->push_back(s);
237
238 char * ss;
239 ss = new char[DIR_NUM*25*4 + 50];
240 char st[50];
241 sprintf(ss, "<traff");
242 DIR_TRAFF upload;
243 DIR_TRAFF download;
244 download = u->property.down.Get();
245 upload = u->property.up.Get();
246
247 for (int j = 0; j < DIR_NUM; j++)
248     {
249     string s;
250     x2str(upload[j], s);
251     sprintf(st, " MU%d=\"%s\"", j, s.c_str());
252     strcat(ss, st);
253
254     x2str(download[j], s);
255     sprintf(st, " MD%d=\"%s\"", j, s.c_str());
256     strcat(ss, st);
257
258     sprintf(st, " SU%d=\"0\"", j);
259     strcat(ss, st);
260
261     sprintf(st, " SD%d=\"0\"", j);
262     strcat(ss, st);
263     }
264 strcat(ss, " />");
265 answerList->push_back(ss);
266 delete[] ss;
267
268 strprintf(&s, "<down value=\"%d\" />", u->property.disabled.Get());
269 answerList->push_back(s);
270
271 strprintf(&s, "<DisableDetailStat value=\"%d\" />", u->property.disabledDetailStat.Get());
272 answerList->push_back(s);
273
274 strprintf(&s, "<passive value=\"%d\" />", u->property.passive.Get());
275 answerList->push_back(s);
276
277 strprintf(&s, "<LastCash value=\"%f\" />", u->property.lastCashAdd.Get());
278 answerList->push_back(s);
279
280 strprintf(&s, "<LastTimeCash value=\"%ld\" />", u->property.lastCashAddTime.Get());
281 answerList->push_back(s);
282
283 strprintf(&s, "<LastActivityTime value=\"%ld\" />", u->property.lastActivityTime.Get());
284 answerList->push_back(s);
285
286 strprintf(&s, "<CreditExpire value=\"%ld\" />", u->property.creditExpire.Get());
287 answerList->push_back(s);
288
289 strprintf(&s, "</user>");
290 answerList->push_back(s);
291 }
292 //-----------------------------------------------------------------------------
293 //  GET USERS
294 //-----------------------------------------------------------------------------
295 PARSER_GET_USERS::PARSER_GET_USERS()
296     : lastUserUpdateTime(0),
297       lastUpdateFound(false)
298 {
299 }
300 //-----------------------------------------------------------------------------
301 int PARSER_GET_USERS::ParseStart(void *, const char *el, const char ** attr)
302 {
303 /*if (attr && *attr && *(attr+1))
304     {
305     printfd(__FILE__, "attr=%s %s\n", *attr, *(attr+1));
306     }
307 else
308     {
309     printfd(__FILE__, "attr = NULL\n");
310     }*/
311
312 lastUpdateFound = false;
313 if (strcasecmp(el, "GetUsers") == 0)
314     {
315     while (attr && *attr && *(attr+1))
316         {
317         if (strcasecmp(*attr, "LastUpdate") == 0)
318             {
319             if (str2x(*(attr+1), lastUserUpdateTime) == 0)
320                 {
321                 //printfd(__FILE__, "lastUserUpdateTime=%d\n", lastUserUpdateTime);
322                 lastUpdateFound = true;
323                 }
324             else
325                 {
326                 //printfd(__FILE__, "NO lastUserUpdateTime\n");
327                 }
328             }
329         ++attr;
330         }
331
332     return 0;
333     }
334 return -1;
335 }
336 //-----------------------------------------------------------------------------
337 int PARSER_GET_USERS::ParseEnd(void *, const char *el)
338 {
339 if (strcasecmp(el, "GetUsers") == 0)
340     {
341     CreateAnswer();
342     return 0;
343     }
344 return -1;
345 }
346 //-----------------------------------------------------------------------------
347 void PARSER_GET_USERS::CreateAnswer()
348 {
349 answerList->erase(answerList->begin(), answerList->end());
350
351 string s;
352 string userStart;
353 string traffStart;
354 string traffMiddle;
355 string traffFinish;
356 string middle;
357 string userFinish;
358
359
360 string enc;
361
362 user_iter u;
363
364 int h = users->OpenSearch();
365 if (!h)
366     {
367     printfd(__FILE__, "users->OpenSearch() error\n");
368     users->CloseSearch(h);
369     return;
370     }
371 string updateTime;
372 x2str(time(NULL), updateTime);
373
374 if (lastUpdateFound)
375     answerList->push_back("<Users LastUpdate=\"" + updateTime + "\">");
376 else
377     answerList->push_back("<Users>");
378
379 while (1)
380     {
381     if (users->SearchNext(h, &u))
382         {
383         break;
384         }
385     userStart = "<user login=\"" + u->GetLogin() + "\">";
386     middle = "";
387
388     if (u->property.password.ModificationTime() > lastUserUpdateTime)
389         {
390         if (currAdmin.GetPriv()->userConf || currAdmin.GetPriv()->userPasswd)
391             s = "<password value=\"" + u->property.password.Get() + "\" />";
392         else
393             s = "<password value=\"++++++\"/>";
394         middle += s;
395         }
396
397
398     if (u->property.cash.ModificationTime() > lastUserUpdateTime)
399         {
400         strprintf(&s, "<cash value=\"%f\" />", u->property.cash.Get());
401         middle += s;
402         //printfd(__FILE__, "cash value=\"%f\"\n", u->property.cash.Get());
403         }
404
405
406     if (u->property.freeMb.ModificationTime() > lastUserUpdateTime)
407         {
408         strprintf(&s, "<freemb value=\"%f\" />", u->property.freeMb.Get());
409         middle += s;
410         }
411
412     if (u->property.credit.ModificationTime() > lastUserUpdateTime)
413         {
414         strprintf(&s, "<credit value=\"%f\" />", u->property.credit.Get());
415         middle += s;
416         }
417
418     if (u->property.nextTariff.Get() != "")
419         {
420         if (u->property.tariffName.ModificationTime() > lastUserUpdateTime
421             || u->property.nextTariff.ModificationTime() > lastUserUpdateTime)
422             {
423             strprintf(&s, "<tariff value=\"%s/%s\" />",
424                       u->property.tariffName.Get().c_str(),
425                       u->property.nextTariff.Get().c_str());
426             middle += s;
427             }
428         }
429     else
430         {
431         if (u->property.tariffName.ModificationTime() > lastUserUpdateTime)
432             {
433             strprintf(&s, "<tariff value=\"%s\" />",
434                       u->property.tariffName.Get().c_str());
435             middle += s;
436             }
437         }
438
439     if (u->property.note.ModificationTime() > lastUserUpdateTime)
440         {
441         Encode12str(enc, u->property.note);
442         strprintf(&s, "<note value=\"%s\" />", enc.c_str());
443         middle += s;
444         }
445
446     if (u->property.phone.ModificationTime() > lastUserUpdateTime)
447         {
448         Encode12str(enc, u->property.phone);
449         strprintf(&s, "<phone value=\"%s\" />", enc.c_str());
450         middle += s;
451         }
452
453     if (u->property.address.ModificationTime() > lastUserUpdateTime)
454         {
455         Encode12str(enc, u->property.address);
456         strprintf(&s, "<address value=\"%s\" />", enc.c_str());
457         middle += s;
458         }
459
460     if (u->property.email.ModificationTime() > lastUserUpdateTime)
461         {
462         Encode12str(enc, u->property.email);
463         strprintf(&s, "<email value=\"%s\" />", enc.c_str());
464         middle += s;
465         }
466
467     vector<USER_PROPERTY_LOGGED<string> *> userdata;
468     userdata.push_back(u->property.userdata0.GetPointer());
469     userdata.push_back(u->property.userdata1.GetPointer());
470     userdata.push_back(u->property.userdata2.GetPointer());
471     userdata.push_back(u->property.userdata3.GetPointer());
472     userdata.push_back(u->property.userdata4.GetPointer());
473     userdata.push_back(u->property.userdata5.GetPointer());
474     userdata.push_back(u->property.userdata6.GetPointer());
475     userdata.push_back(u->property.userdata7.GetPointer());
476     userdata.push_back(u->property.userdata8.GetPointer());
477     userdata.push_back(u->property.userdata9.GetPointer());
478
479     string tmpI;
480     for (unsigned i = 0; i < userdata.size(); i++)
481         {
482         if (userdata[i]->ModificationTime() > lastUserUpdateTime)
483             {
484             Encode12str(enc, userdata[i]->Get());
485             s = "<UserData" + x2str(i, tmpI) + " value=\"" + enc + "\" />";
486             middle += s;
487             }
488         }
489
490     if (u->property.realName.ModificationTime() > lastUserUpdateTime)
491         {
492         Encode12str(enc, u->property.realName);
493         strprintf(&s, "<name value=\"%s\" />", enc.c_str());
494         middle += s;
495         }
496
497     if (u->property.group.ModificationTime() > lastUserUpdateTime)
498         {
499         Encode12str(enc, u->property.group);
500         strprintf(&s, "<GROUP value=\"%s\" />", enc.c_str());
501         middle += s;
502         }
503
504     if (u->property.alwaysOnline.ModificationTime() > lastUserUpdateTime)
505         {
506         strprintf(&s, "<aonline value=\"%d\" />", u->property.alwaysOnline.Get());
507         middle += s;
508         }
509
510     if (u->GetCurrIPModificationTime() > lastUserUpdateTime)
511         {
512         strprintf(&s, "<currip value=\"%s\" />", inet_ntostring(u->GetCurrIP()).c_str());
513         middle += s;
514         }
515
516
517     if (u->GetConnectedModificationTime() > lastUserUpdateTime)
518         {
519         strprintf(&s, "<status value=\"%d\" />", u->GetConnected());
520         middle += s;
521         }
522
523     if (u->GetPingTime() > lastUserUpdateTime)
524         {
525         strprintf(&s, "<PingTime value=\"%lu\" />", u->GetPingTime());
526         middle += s;
527         }
528
529     if (u->property.ips.ModificationTime() > lastUserUpdateTime)
530         {
531         stringstream sstr;
532         sstr << u->property.ips.Get();
533         strprintf(&s, "<ip value=\"%s\" />", sstr.str().c_str());
534         middle += s;
535         }
536
537     char st[50];
538     traffStart = "<traff";
539     DIR_TRAFF upload;
540     DIR_TRAFF download;
541     download = u->property.down.Get();
542     upload = u->property.up.Get();
543     traffMiddle = "";
544
545     if (u->property.up.ModificationTime() > lastUserUpdateTime)
546         {
547         for (int j = 0; j < DIR_NUM; j++)
548             {
549             string s;
550             x2str(upload[j], s);
551             sprintf(st, " MU%d=\"%s\" ", j, s.c_str());
552             traffMiddle += st;
553             }
554         }
555
556     if (u->property.down.ModificationTime() > lastUserUpdateTime)
557         {
558         for (int j = 0; j < DIR_NUM; j++)
559             {
560             x2str(download[j], s);
561             sprintf(st, " MD%d=\"%s\" ", j, s.c_str());
562             traffMiddle += st;
563             }
564         }
565
566     traffFinish = " />";
567     if (traffMiddle.length() > 0)
568         {
569         middle += traffStart;
570         middle += traffMiddle;
571         middle += traffFinish;
572         }
573
574     if (u->property.disabled.ModificationTime() > lastUserUpdateTime)
575         {
576         strprintf(&s, "<down value=\"%d\" />", u->property.disabled.Get());
577         middle += s;
578         }
579
580     if (u->property.disabledDetailStat.ModificationTime() > lastUserUpdateTime)
581         {
582         strprintf(&s, "<DisableDetailStat value=\"%d\" />", u->property.disabledDetailStat.Get());
583         middle += s;
584         }
585
586     //printfd(__FILE__, ">>>>> %s\n", s.c_str());
587
588     if (u->property.passive.ModificationTime() > lastUserUpdateTime)
589         {
590         strprintf(&s, "<passive value=\"%d\" />", u->property.passive.Get());
591         middle += s;
592         }
593
594     if (u->property.lastCashAdd.ModificationTime() > lastUserUpdateTime)
595         {
596         strprintf(&s, "<LastCash value=\"%f\" />", u->property.lastCashAdd.Get());
597         middle += s;
598         }
599
600     if (u->property.lastCashAddTime.ModificationTime() > lastUserUpdateTime)
601         {
602         strprintf(&s, "<LastTimeCash value=\"%ld\" />", u->property.lastCashAddTime.Get());
603         middle += s;
604         }
605
606
607     if (u->property.lastActivityTime.ModificationTime() > lastUserUpdateTime)
608         {
609         strprintf(&s, "<LastActivityTime value=\"%ld\" />", u->property.lastActivityTime.Get());
610         middle += s;
611         }
612
613     if (u->property.creditExpire.ModificationTime() > lastUserUpdateTime)
614         {
615         strprintf(&s, "<CreditExpire value=\"%ld\" />", u->property.creditExpire.Get());
616         middle += s;
617         }
618
619
620     userFinish = "</user>";
621
622     if (middle.length() > 0)
623         {
624         /*printfd(__FILE__, "login: %s\n", u->GetLogin().c_str());
625         printfd(__FILE__, "middle: %s\n", middle.c_str());*/
626
627         answerList->push_back(userStart);
628         answerList->push_back(middle);
629         answerList->push_back(userFinish);
630         }
631     }
632
633 users->CloseSearch(h);
634
635 //answerList->push_back("</Users>");
636
637 answerList->push_back("</Users>");
638 }
639 //-----------------------------------------------------------------------------
640 //  ADD USER
641 //-----------------------------------------------------------------------------
642 PARSER_ADD_USER::PARSER_ADD_USER()
643 {
644 depth = 0;
645 }
646 //-----------------------------------------------------------------------------
647 int PARSER_ADD_USER::ParseStart(void *, const char *el, const char **attr)
648 {
649 depth++;
650
651 if (depth == 1)
652     {
653     if (strcasecmp(el, "AddUser") == 0)
654         {
655         return 0;
656         }
657     }
658 else
659     {
660     if (strcasecmp(el, "login") == 0)
661         {
662         login = attr[1];
663         return 0;
664         }
665     }
666 return -1;
667 }
668 //-----------------------------------------------------------------------------
669 int PARSER_ADD_USER::ParseEnd(void *, const char *el)
670 {
671 if (depth == 1)
672     {
673     if (strcasecmp(el, "AddUser") == 0)
674         {
675         CreateAnswer();
676         depth--;
677         return 0;
678         }
679     }
680
681 depth--;
682 return -1;
683 }
684 //-----------------------------------------------------------------------------
685 void PARSER_ADD_USER::Reset()
686 {
687 BASE_PARSER::Reset();
688 depth = 0;
689 }
690 //-----------------------------------------------------------------------------
691 void PARSER_ADD_USER::CreateAnswer()
692 {
693 //answerList->clear();
694 answerList->erase(answerList->begin(), answerList->end());
695
696 if (CheckUserData() == 0)
697     {
698     answerList->push_back("<AddUser result=\"ok\"/>");
699     }
700 else
701     {
702     answerList->push_back("<AddUser result=\"error\" reason=\"Access denied\"/>");
703     }
704 }
705 //-----------------------------------------------------------------------------
706 int PARSER_ADD_USER::CheckUserData()
707 {
708 user_iter u;
709 if (users->FindByName(login, &u))
710     {
711     return users->Add(login, currAdmin);
712     }
713 return -1;
714 }
715 //-----------------------------------------------------------------------------
716 //  PARSER CHG USER
717 //-----------------------------------------------------------------------------
718 PARSER_CHG_USER::PARSER_CHG_USER()
719     : usr(NULL),
720       ucr(NULL),
721       upr(NULL),
722       downr(NULL),
723       cashMustBeAdded(false),
724       res(0)
725 {
726 Reset();
727 }
728 //-----------------------------------------------------------------------------
729 PARSER_CHG_USER::~PARSER_CHG_USER()
730 {
731 delete usr;
732 delete ucr;
733 delete[] upr;
734 delete[] downr;
735 }
736 //-----------------------------------------------------------------------------
737 void PARSER_CHG_USER::Reset()
738 {
739 depth = 0;
740 delete usr;
741
742 delete ucr;
743
744 delete[] upr;
745
746 delete[] downr;
747
748 usr = new USER_STAT_RES;
749 ucr = new USER_CONF_RES;
750
751 upr = new RESETABLE<uint64_t>[DIR_NUM];
752 downr = new RESETABLE<uint64_t>[DIR_NUM];
753 };
754 //-----------------------------------------------------------------------------
755 string PARSER_CHG_USER::EncChar2String(const char * strEnc)
756 {
757 string str;
758 Decode21str(str, strEnc);
759 return str;
760 }
761 //-----------------------------------------------------------------------------
762 int PARSER_CHG_USER::ParseStart(void *, const char *el, const char **attr)
763 {
764 depth++;
765
766 if (depth == 1)
767     {
768     if (strcasecmp(el, "SetUser") == 0)
769         {
770         return 0;
771         }
772     }
773 else
774     {
775     //printfd(__FILE__, "el=%s\n", el);
776     if (strcasecmp(el, "login") == 0)
777         {
778         login = attr[1];
779         return 0;
780         }
781
782     if (strcasecmp(el, "ip") == 0)
783         {
784         try
785             {
786             ucr->ips = StrToIPS(attr[1]);
787             }
788         catch (...)
789             {
790             printfd(__FILE__, "StrToIPS Error!\n");
791             }
792         }
793
794     if (strcasecmp(el, "password") == 0)
795         {
796         ucr->password = attr[1];
797         return 0;
798         }
799
800     if (strcasecmp(el, "address") == 0)
801         {
802         ucr->address = EncChar2String(attr[1]);
803         return 0;
804         }
805
806     if (strcasecmp(el, "aonline") == 0)
807         {
808         ucr->alwaysOnline = (*(attr[1]) != '0');
809         return 0;
810         }
811
812     if (strcasecmp(el, "cash") == 0)
813         {
814         if (attr[2] && (strcasecmp(attr[2], "msg") == 0))
815             {
816             cashMsg = EncChar2String(attr[3]);
817             }
818
819         double cash;
820         if (strtodouble2(attr[1], cash) == 0)
821             usr->cash = cash;
822
823         if (strcasecmp(attr[0], "set") == 0)
824             cashMustBeAdded = false;
825
826         if (strcasecmp(attr[0], "add") == 0)
827             cashMustBeAdded = true;
828
829         return 0;
830         }
831
832     if (strcasecmp(el, "CreditExpire") == 0)
833         {
834         long int creditExpire = 0;
835         if (str2x(attr[1], creditExpire) == 0)
836             ucr->creditExpire = (time_t)creditExpire;
837
838         return 0;
839         }
840
841     if (strcasecmp(el, "credit") == 0)
842         {
843         double credit;
844         if (strtodouble2(attr[1], credit) == 0)
845             ucr->credit = credit;
846         return 0;
847         }
848
849     if (strcasecmp(el, "freemb") == 0)
850         {
851         double freeMb;
852         if (strtodouble2(attr[1], freeMb) == 0)
853             usr->freeMb = freeMb;
854         return 0;
855         }
856
857     if (strcasecmp(el, "down") == 0)
858         {
859         int down = 0;
860         if (str2x(attr[1], down) == 0)
861             ucr->disabled = down;
862         return 0;
863         }
864
865     if (strcasecmp(el, "DisableDetailStat") == 0)
866         {
867         int disabledDetailStat = 0;
868         if (str2x(attr[1], disabledDetailStat) == 0)
869             ucr->disabledDetailStat = disabledDetailStat;
870         return 0;
871         }
872
873     if (strcasecmp(el, "email") == 0)
874         {
875         ucr->email = EncChar2String(attr[1]);
876         return 0;
877         }
878
879     for (int i = 0; i < USERDATA_NUM; i++)
880         {
881         char name[15];
882         sprintf(name, "userdata%d", i);
883         if (strcasecmp(el, name) == 0)
884             {
885             ucr->userdata[i] = EncChar2String(attr[1]);
886             return 0;
887             }
888         }
889
890     if (strcasecmp(el, "group") == 0)
891         {
892         ucr->group = EncChar2String(attr[1]);
893         return 0;
894         }
895
896     if (strcasecmp(el, "note") == 0)
897         {
898         ucr->note = EncChar2String(attr[1]);
899         return 0;
900         }
901
902     if (strcasecmp(el, "passive") == 0)
903         {
904         int passive = 0;
905         if (str2x(attr[1], passive) == 0)
906             ucr->passive = passive;
907         return 0;
908         }
909
910     if (strcasecmp(el, "phone") == 0)
911         {
912         ucr->phone = EncChar2String(attr[1]);
913         return 0;
914         }
915
916     if (strcasecmp(el, "Name") == 0)
917         {
918         ucr->realName = EncChar2String(attr[1]);
919         return 0;
920         }
921
922     if (strcasecmp(el, "traff") == 0)
923         {
924         int j = 0;
925         int dir;
926         DIR_TRAFF dtu;
927         DIR_TRAFF dtd;
928         unsigned long long t = 0;
929         while (attr[j])
930             {
931             dir = attr[j][2] - '0';
932
933             if (strncasecmp(attr[j], "md", 2) == 0)
934                 {
935                 str2x(attr[j+1], t);
936                 dtd[dir] = t;
937                 downr[dir] = t;
938                 }
939             if (strncasecmp(attr[j], "mu", 2) == 0)
940                 {
941                 str2x(attr[j+1], t);
942                 dtu[dir] = t;
943                 upr[dir] = t;
944                 }
945             j+=2;
946             }
947         usr->down = dtd;
948         usr->up = dtu;
949         return 0;
950         }
951
952     if (strcasecmp(el, "tariff") == 0)
953         {
954         if (strcasecmp(attr[0], "now") == 0)
955             ucr->tariffName = attr[1];
956
957         if (strcasecmp(attr[0], "delayed") == 0)
958             ucr->nextTariff = attr[1];
959
960         return 0;
961         }
962     }
963 return -1;
964 }
965 //-----------------------------------------------------------------------------
966 int PARSER_CHG_USER::ParseEnd(void *, const char *el)
967 {
968 if (depth == 1)
969     {
970     if (strcasecmp(el, "SetUser") == 0)
971         {
972         AplayChanges();
973         CreateAnswer();
974         depth--;
975         return 0;
976         }
977     }
978
979 depth--;
980 return -1;
981 }
982 //-----------------------------------------------------------------------------
983 void PARSER_CHG_USER::CreateAnswer()
984 {
985 //answerList->clear();
986 answerList->erase(answerList->begin(), answerList->end());
987
988 switch (res)
989     {
990     case 0:
991         answerList->push_back("<SetUser result=\"ok\"/>");
992         break;
993     case -1:
994         answerList->push_back("<SetUser result=\"error\"/>");
995         break;
996     case -2:
997         answerList->push_back("<SetUser result=\"error\"/>");
998         break;
999     default:
1000         answerList->push_back("<SetUser result=\"error\"/>");
1001         break;
1002     }
1003
1004 }
1005 //-----------------------------------------------------------------------------
1006 int PARSER_CHG_USER::CheckUserData()
1007 {
1008 return true;
1009 }
1010 //-----------------------------------------------------------------------------
1011 int PARSER_CHG_USER::AplayChanges()
1012 {
1013 user_iter u;
1014
1015 res = 0;
1016 if (users->FindByName(login, &u))
1017     {
1018     res = -1;
1019     return -1;
1020     }
1021
1022 if (!ucr->ips.res_empty())
1023     if (!u->property.ips.Set(ucr->ips.const_data(), currAdmin, login, store))
1024         res = -1;
1025
1026 if (!ucr->address.res_empty())
1027     if (!u->property.address.Set(ucr->address.const_data(), currAdmin, login, store))
1028         res = -1;
1029
1030 if (!ucr->alwaysOnline.res_empty())
1031     if (!u->property.alwaysOnline.Set(ucr->alwaysOnline.const_data(),
1032                                       currAdmin, login, store))
1033         res = -1;
1034
1035 if (!ucr->creditExpire.res_empty())
1036     if (!u->property.creditExpire.Set(ucr->creditExpire.const_data(),
1037                                       currAdmin, login, store))
1038         res = -1;
1039
1040 if (!ucr->credit.res_empty())
1041     if (!u->property.credit.Set(ucr->credit.const_data(), currAdmin, login, store))
1042         res = -1;
1043
1044 if (!usr->freeMb.res_empty())
1045     if (!u->property.freeMb.Set(usr->freeMb.const_data(), currAdmin, login, store))
1046         res = -1;
1047
1048 if (!ucr->disabled.res_empty())
1049     if (!u->property.disabled.Set(ucr->disabled.const_data(), currAdmin, login, store))
1050         res = -1;
1051
1052 if (!ucr->disabledDetailStat.res_empty())
1053     if (!u->property.disabledDetailStat.Set(ucr->disabledDetailStat.const_data(), currAdmin, login, store))
1054         res = -1;
1055
1056 if (!ucr->email.res_empty())
1057     if (!u->property.email.Set(ucr->email.const_data(), currAdmin, login, store))
1058         res = -1;
1059
1060 if (!ucr->group.res_empty())
1061     if (!u->property.group.Set(ucr->group.const_data(), currAdmin, login, store))
1062         res = -1;
1063
1064 if (!ucr->note.res_empty())
1065     if (!u->property.note.Set(ucr->note.const_data(), currAdmin, login, store))
1066         res = -1;
1067
1068 vector<USER_PROPERTY_LOGGED<string> *> userdata;
1069 userdata.push_back(u->property.userdata0.GetPointer());
1070 userdata.push_back(u->property.userdata1.GetPointer());
1071 userdata.push_back(u->property.userdata2.GetPointer());
1072 userdata.push_back(u->property.userdata3.GetPointer());
1073 userdata.push_back(u->property.userdata4.GetPointer());
1074 userdata.push_back(u->property.userdata5.GetPointer());
1075 userdata.push_back(u->property.userdata6.GetPointer());
1076 userdata.push_back(u->property.userdata7.GetPointer());
1077 userdata.push_back(u->property.userdata8.GetPointer());
1078 userdata.push_back(u->property.userdata9.GetPointer());
1079
1080 for (int i = 0; i < (int)userdata.size(); i++)
1081     {
1082     if (!ucr->userdata[i].res_empty())
1083         {
1084         if(!userdata[i]->Set(ucr->userdata[i].const_data(), currAdmin, login, store))
1085             res = -1;
1086         }
1087     }
1088
1089 if (!ucr->passive.res_empty())
1090     if (!u->property.passive.Set(ucr->passive.const_data(), currAdmin, login, store))
1091         res = -1;
1092
1093 if (!ucr->password.res_empty())
1094     if (!u->property.password.Set(ucr->password.const_data(), currAdmin, login, store))
1095         res = -1;
1096
1097 if (!ucr->phone.res_empty())
1098     if (!u->property.phone.Set(ucr->phone.const_data(), currAdmin, login, store))
1099         res = -1;
1100
1101 if (!ucr->realName.res_empty())
1102     if (!u->property.realName.Set(ucr->realName.const_data(), currAdmin, login, store))
1103         res = -1;
1104
1105
1106 if (!usr->cash.res_empty())
1107     {
1108     //if (currAdmin->GetPriv()->userCash)
1109         {
1110         if (cashMustBeAdded)
1111             {
1112             if (!u->property.cash.Set(usr->cash.const_data() + u->property.cash,
1113                                       currAdmin,
1114                                       login,
1115                                       store,
1116                                       cashMsg))
1117                 res = -1;
1118             }
1119         else
1120             {
1121             if (!u->property.cash.Set(usr->cash.const_data(), currAdmin, login, store, cashMsg))
1122                 res = -1;
1123             }
1124         }
1125     }
1126
1127
1128 if (!ucr->tariffName.res_empty())
1129     {
1130     if (tariffs->FindByName(ucr->tariffName.const_data()))
1131         {
1132         if (!u->property.tariffName.Set(ucr->tariffName.const_data(), currAdmin, login, store))
1133             res = -1;
1134         u->ResetNextTariff();
1135         }
1136     else
1137         {
1138         //WriteServLog("SetUser: Tariff %s not found", ud.conf.tariffName.c_str());
1139         res = -1;
1140         }
1141     }
1142
1143 if (!ucr->nextTariff.res_empty())
1144     {
1145     if (tariffs->FindByName(ucr->nextTariff.const_data()))
1146         {
1147         if (!u->property.nextTariff.Set(ucr->nextTariff.const_data(), currAdmin, login, store))
1148             res = -1;
1149         }
1150     else
1151         {
1152         //WriteServLog("SetUser: Tariff %s not found", ud.conf.tariffName.c_str());
1153         res = -1;
1154         }
1155     }
1156
1157 DIR_TRAFF up = u->property.up;
1158 DIR_TRAFF down = u->property.down;
1159 int upCount = 0;
1160 int downCount = 0;
1161 for (int i = 0; i < DIR_NUM; i++)
1162     {
1163     if (!upr[i].res_empty())
1164         {
1165         up[i] = upr[i];
1166         upCount++;
1167         }
1168     if (!downr[i].res_empty())
1169         {
1170         down[i] = downr[i];
1171         downCount++;
1172         }
1173     }
1174
1175 if (upCount)
1176     if (!u->property.up.Set(up, currAdmin, login, store))
1177         res = -1;
1178
1179 if (downCount)
1180     if (!u->property.down.Set(down, currAdmin, login, store))
1181         res = -1;
1182
1183 /*if (!usr->down.res_empty())
1184     {
1185     u->property.down.Set(usr->down.const_data(), currAdmin, login, store);
1186     }
1187 if (!usr->up.res_empty())
1188     {
1189     u->property.up.Set(usr->up.const_data(), currAdmin, login, store);
1190     }*/
1191
1192 u->WriteConf();
1193 u->WriteStat();
1194
1195 return 0;
1196 }
1197 //-----------------------------------------------------------------------------
1198 //      SEND MESSAGE
1199 //-----------------------------------------------------------------------------
1200 int PARSER_SEND_MESSAGE::ParseStart(void *, const char *el, const char **attr)
1201 {
1202 if (strcasecmp(el, "Message") == 0)
1203     {
1204     for (int i = 0; i < 14; i++)
1205         {
1206         if (attr[i] == NULL)
1207             {
1208             result = res_params_error;
1209             CreateAnswer();
1210             printfd(__FILE__, "To few parameters\n");
1211             return 0;
1212             }
1213         }
1214
1215     for (int i = 0; i < 14; i+=2)
1216         {
1217         if (strcasecmp(attr[i], "login") == 0)
1218             {
1219             ParseLogins(attr[i+1]);
1220             /*if (users->FindByName(login, &u))
1221                 {
1222                 result = res_unknown;
1223                 break;
1224                 }*/
1225             }
1226
1227         if (strcasecmp(attr[i], "MsgVer") == 0)
1228             {
1229             str2x(attr[i+1], msg.header.ver);
1230             if (msg.header.ver != 1)
1231                 result = res_params_error;
1232             }
1233
1234         if (strcasecmp(attr[i], "MsgType") == 0)
1235             {
1236             str2x(attr[i+1], msg.header.type);
1237             if (msg.header.type != 1)
1238                 result = res_params_error;
1239             }
1240
1241         if (strcasecmp(attr[i], "Repeat") == 0)
1242             {
1243             str2x(attr[i+1], msg.header.repeat);
1244             if (msg.header.repeat < 0)
1245                 result = res_params_error;
1246             }
1247
1248         if (strcasecmp(attr[i], "RepeatPeriod") == 0)
1249             {
1250             str2x(attr[i+1], msg.header.repeatPeriod);
1251             }
1252
1253         if (strcasecmp(attr[i], "ShowTime") == 0)
1254             {
1255             str2x(attr[i+1], msg.header.showTime);
1256             }
1257
1258         if (strcasecmp(attr[i], "Text") == 0)
1259             {
1260             Decode21str(msg.text, attr[i+1]);
1261             result = res_ok;
1262             }
1263         }
1264     return 0;
1265     }
1266 return -1;
1267 }
1268 //-----------------------------------------------------------------------------
1269 int PARSER_SEND_MESSAGE::ParseEnd(void *, const char *el)
1270 {
1271 //MSG msg;
1272 if (strcasecmp(el, "Message") == 0)
1273     {
1274     result = res_unknown;
1275     for (unsigned i = 0; i < logins.size(); i++)
1276         {
1277         if (users->FindByName(logins[i], &u))
1278             {
1279             printfd(__FILE__, "User not found. %s\n", logins[i].c_str());
1280             continue;
1281             }
1282         msg.header.creationTime = stgTime;
1283         u->AddMessage(&msg);
1284         result = res_ok;
1285         }
1286     /*if (result == res_ok)
1287         {
1288         if (strcmp(login, "*") == 0)
1289             {
1290             msg.text = text;
1291             msg.prio = pri;
1292             printfd(__FILE__, "SendMsg text: %s\n", text);
1293             users->GetAllUsers(SendMessageAllUsers, &msg);
1294             }
1295         else
1296             {
1297             u->AddMessage(pri, text);
1298             }
1299         }*/
1300     CreateAnswer();
1301     return 0;
1302     }
1303 return -1;
1304 }
1305 //-----------------------------------------------------------------------------
1306 int PARSER_SEND_MESSAGE::ParseLogins(const char * login)
1307 {
1308 char * p;
1309 char * l = new char[strlen(login) + 1];
1310 strcpy(l, login);
1311 p = strtok(l, ":");
1312 logins.clear();
1313 while(p)
1314     {
1315     logins.push_back(p);
1316     p = strtok(NULL, ":");
1317     }
1318
1319 delete[] l;
1320 return 0;
1321 }
1322 //-----------------------------------------------------------------------------
1323 void PARSER_SEND_MESSAGE::CreateAnswer()
1324 {
1325 //answerList->clear();
1326 answerList->erase(answerList->begin(), answerList->end());
1327 //answerList->push_back("<SendMessageResult value=\"ok\"/>");
1328 //
1329 switch (result)
1330     {
1331     case res_ok:
1332         answerList->push_back("<SendMessageResult value=\"ok\"/>");
1333         break;
1334     case res_params_error:
1335         printfd(__FILE__, "res_params_error\n");
1336         answerList->push_back("<SendMessageResult value=\"Parameters error\"/>");
1337         break;
1338     case res_unknown:
1339         printfd(__FILE__, "res_unknown\n");
1340         answerList->push_back("<SendMessageResult value=\"Unknown user\"/>");
1341         break;
1342     default:
1343         printfd(__FILE__, "res_default\n");
1344     }
1345
1346 }
1347 //-----------------------------------------------------------------------------
1348 //      DEL USER
1349 //-----------------------------------------------------------------------------
1350 int PARSER_DEL_USER::ParseStart(void *, const char *el, const char **attr)
1351 {
1352 res = 0;
1353 if (strcasecmp(el, "DelUser") == 0)
1354     {
1355     if (attr[0] == NULL || attr[1] == NULL)
1356         {
1357         //CreateAnswer("Parameters error!");
1358         CreateAnswer();
1359         return 0;
1360         }
1361
1362     if (users->FindByName(attr[1], &u))
1363         {
1364         res = 1;
1365         CreateAnswer();
1366         return 0;
1367         }
1368     CreateAnswer();
1369     return 0;
1370     }
1371 return -1;
1372 }
1373 //-----------------------------------------------------------------------------
1374 int PARSER_DEL_USER::ParseEnd(void *, const char *el)
1375 {
1376 if (strcasecmp(el, "DelUser") == 0)
1377     {
1378     if (!res)
1379         users->Del(u->GetLogin(), currAdmin);
1380
1381     return 0;
1382     }
1383 return -1;
1384 }
1385 //-----------------------------------------------------------------------------
1386 void PARSER_DEL_USER::CreateAnswer()
1387 {
1388 if (res)
1389     answerList->push_back("<DelUser value=\"error\" reason=\"User not found\"/>");
1390 else
1391     answerList->push_back("<DelUser value=\"ok\"/>");
1392 }
1393 //-----------------------------------------------------------------------------
1394 /*void PARSERDELUSER::CreateAnswer(char * mes)
1395 {
1396 //answerList->clear();
1397 answerList->erase(answerList->begin(), answerList->end());
1398
1399 char str[255];
1400 sprintf(str, "<DelUser value=\"%s\"/>", mes);
1401 answerList->push_back(str);
1402 }*/
1403 //-----------------------------------------------------------------------------
1404 //  CHECK USER
1405 // <checkuser login="vasya" password=\"123456\"/>
1406 //-----------------------------------------------------------------------------
1407 int PARSER_CHECK_USER::ParseStart(void *, const char *el, const char **attr)
1408 {
1409 result = false;
1410
1411 if (strcasecmp(el, "CheckUser") == 0)
1412     {
1413     if (attr[0] == NULL || attr[1] == NULL
1414      || attr[2] == NULL || attr[3] == NULL)
1415         {
1416         result = false;
1417         CreateAnswer();
1418         printfd(__FILE__, "PARSER_CHECK_USER - attr err\n");
1419         return 0;
1420         }
1421
1422     user_iter user;
1423     if (users->FindByName(attr[1], &user))
1424         {
1425         result = false;
1426         CreateAnswer();
1427         printfd(__FILE__, "PARSER_CHECK_USER - login err\n");
1428         return 0;
1429         }
1430
1431     if (strcmp(user->property.password.Get().c_str(), attr[3]))
1432         {
1433         result = false;
1434         CreateAnswer();
1435         printfd(__FILE__, "PARSER_CHECK_USER - passwd err\n");
1436         return 0;
1437         }
1438
1439     result = true;
1440     CreateAnswer();
1441     return 0;
1442     }
1443 return -1;
1444 }
1445 //-----------------------------------------------------------------------------
1446 int PARSER_CHECK_USER::ParseEnd(void *, const char *el)
1447 {
1448 if (strcasecmp(el, "CheckUser") == 0)
1449     {
1450     return 0;
1451     }
1452 return -1;
1453 }
1454 //-----------------------------------------------------------------------------
1455 void PARSER_CHECK_USER::CreateAnswer()
1456 {
1457 if (result)
1458     answerList->push_back("<CheckUser value=\"Ok\"/>");
1459 else
1460     answerList->push_back("<CheckUser value=\"Err\"/>");
1461 }
1462 //-----------------------------------------------------------------------------
1463 //-----------------------------------------------------------------------------
1464 //-----------------------------------------------------------------------------