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