]> git.stg.codes - stg.git/blob - stargazer/plugins/configuration/rpcconfig/user_helper.cpp
84ba514724a11cb007d024cf111446717e83f86d
[stg.git] / stargazer / plugins / configuration / rpcconfig / user_helper.cpp
1 #include <cmath>
2
3 #include "stg/tariffs.h"
4 #include "stg/admin.h"
5 #include "stg/store.h"
6 #include "stg/user_ips.h"
7 #include "stg/common.h"
8 #include "stg/user_property.h"
9 #include "user_helper.h"
10
11 //------------------------------------------------------------------------------
12
13 void USER_HELPER::GetUserInfo(xmlrpc_c::value * info,
14                               bool hidePassword)
15 {
16 std::map<std::string, xmlrpc_c::value> structVal;
17
18 structVal["result"] = xmlrpc_c::value_boolean(true);
19 structVal["login"] = xmlrpc_c::value_string(ptr->GetLogin());
20
21 if (!hidePassword)
22     {
23     structVal["password"] = xmlrpc_c::value_string(ptr->GetProperty().password.Get());
24     }
25 else
26     {
27     structVal["password"] = xmlrpc_c::value_string("++++++++");
28     }
29
30 structVal["cash"] = xmlrpc_c::value_double(ptr->GetProperty().cash.Get());
31 structVal["freemb"] = xmlrpc_c::value_double(ptr->GetProperty().freeMb.Get());
32 structVal["credit"] = xmlrpc_c::value_double(ptr->GetProperty().credit.Get());
33
34 if (ptr->GetProperty().nextTariff.Get() != "")
35     {
36     structVal["tariff"] = xmlrpc_c::value_string(
37             ptr->GetProperty().tariffName.Get() +
38             "/" +
39             ptr->GetProperty().nextTariff.Get()
40             );
41     }
42 else
43     {
44     structVal["tariff"] = xmlrpc_c::value_string(ptr->GetProperty().tariffName.Get());
45     }
46
47 structVal["note"] = xmlrpc_c::value_string(IconvString(ptr->GetProperty().note, "KOI8-RU", "UTF-8"));
48
49 structVal["phone"] = xmlrpc_c::value_string(IconvString(ptr->GetProperty().phone, "KOI8-RU", "UTF-8"));
50
51 structVal["address"] = xmlrpc_c::value_string(IconvString(ptr->GetProperty().address, "KOI8-RU", "UTF-8"));
52
53 structVal["email"] = xmlrpc_c::value_string(IconvString(ptr->GetProperty().email, "KOI8-RU", "UTF-8"));
54
55 std::vector<xmlrpc_c::value> userdata;
56
57 userdata.push_back(xmlrpc_c::value_string(IconvString(ptr->GetProperty().userdata0.Get(), "KOI8-RU", "UTF-8")));
58 userdata.push_back(xmlrpc_c::value_string(IconvString(ptr->GetProperty().userdata1.Get(), "KOI8-RU", "UTF-8")));
59 userdata.push_back(xmlrpc_c::value_string(IconvString(ptr->GetProperty().userdata2.Get(), "KOI8-RU", "UTF-8")));
60 userdata.push_back(xmlrpc_c::value_string(IconvString(ptr->GetProperty().userdata3.Get(), "KOI8-RU", "UTF-8")));
61 userdata.push_back(xmlrpc_c::value_string(IconvString(ptr->GetProperty().userdata4.Get(), "KOI8-RU", "UTF-8")));
62 userdata.push_back(xmlrpc_c::value_string(IconvString(ptr->GetProperty().userdata5.Get(), "KOI8-RU", "UTF-8")));
63 userdata.push_back(xmlrpc_c::value_string(IconvString(ptr->GetProperty().userdata6.Get(), "KOI8-RU", "UTF-8")));
64 userdata.push_back(xmlrpc_c::value_string(IconvString(ptr->GetProperty().userdata7.Get(), "KOI8-RU", "UTF-8")));
65 userdata.push_back(xmlrpc_c::value_string(IconvString(ptr->GetProperty().userdata8.Get(), "KOI8-RU", "UTF-8")));
66 userdata.push_back(xmlrpc_c::value_string(IconvString(ptr->GetProperty().userdata9.Get(), "KOI8-RU", "UTF-8")));
67
68 structVal["userdata"] = xmlrpc_c::value_array(userdata);
69
70 structVal["name"] = xmlrpc_c::value_string(IconvString(ptr->GetProperty().realName, "KOI8-RU", "UTF-8"));
71
72 structVal["group"] = xmlrpc_c::value_string(IconvString(ptr->GetProperty().group, "KOI8-RU", "UTF-8"));
73
74 structVal["status"] = xmlrpc_c::value_boolean(ptr->GetConnected());
75 structVal["aonline"] = xmlrpc_c::value_boolean(ptr->GetProperty().alwaysOnline.Get());
76 structVal["currip"] = xmlrpc_c::value_string(inet_ntostring(ptr->GetCurrIP()));
77 structVal["pingtime"] = xmlrpc_c::value_int(static_cast<int>(ptr->GetPingTime()));
78 structVal["ips"] = xmlrpc_c::value_string(ptr->GetProperty().ips.Get().GetIpStr());
79
80 std::map<std::string, xmlrpc_c::value> traffInfo;
81 std::vector<xmlrpc_c::value> mu(DIR_NUM);
82 std::vector<xmlrpc_c::value> md(DIR_NUM);
83 std::vector<xmlrpc_c::value> su(DIR_NUM);
84 std::vector<xmlrpc_c::value> sd(DIR_NUM);
85
86 DIR_TRAFF upload;
87 DIR_TRAFF download;
88 DIR_TRAFF supload;
89 DIR_TRAFF sdownload;
90 download = ptr->GetProperty().down.Get();
91 upload = ptr->GetProperty().up.Get();
92 sdownload = ptr->GetSessionUpload();
93 supload = ptr->GetSessionDownload();
94
95 for (int j = 0; j < DIR_NUM; j++)
96     {
97     mu[j] = xmlrpc_c::value_string(std::to_string(upload[j]));
98     md[j] = xmlrpc_c::value_string(std::to_string(download[j]));
99     su[j] = xmlrpc_c::value_string(std::to_string(supload[j]));
100     sd[j] = xmlrpc_c::value_string(std::to_string(sdownload[j]));
101     }
102
103 traffInfo["mu"] = xmlrpc_c::value_array(mu);
104 traffInfo["md"] = xmlrpc_c::value_array(md);
105 traffInfo["su"] = xmlrpc_c::value_array(su);
106 traffInfo["sd"] = xmlrpc_c::value_array(sd);
107
108 structVal["traff"] = xmlrpc_c::value_struct(traffInfo);
109
110 structVal["down"] = xmlrpc_c::value_boolean(ptr->GetProperty().disabled.Get());
111 structVal["disableddetailstat"] = xmlrpc_c::value_boolean(ptr->GetProperty().disabledDetailStat.Get());
112 structVal["passive"] = xmlrpc_c::value_boolean(ptr->GetProperty().passive.Get());
113 structVal["lastcash"] = xmlrpc_c::value_double(ptr->GetProperty().lastCashAdd.Get());
114 structVal["lasttimecash"] = xmlrpc_c::value_int(static_cast<int>(ptr->GetProperty().lastCashAddTime.Get()));
115 structVal["lastactivitytime"] = xmlrpc_c::value_int(static_cast<int>(ptr->GetProperty().lastActivityTime.Get()));
116 structVal["creditexpire"] = xmlrpc_c::value_int(static_cast<int>(ptr->GetProperty().creditExpire.Get()));
117
118 *info = xmlrpc_c::value_struct(structVal);
119 }
120
121 //------------------------------------------------------------------------------
122
123 bool USER_HELPER::SetUserInfo(const xmlrpc_c::value & info,
124                               const ADMIN * admin,
125                               const std::string & login,
126                               const STORE & store,
127                               TARIFFS * tariffs)
128 {
129 std::map<std::string, xmlrpc_c::value> structVal(
130     static_cast<std::map<std::string, xmlrpc_c::value> >(xmlrpc_c::value_struct(info))
131     );
132
133 std::map<std::string, xmlrpc_c::value>::iterator it;
134
135 bool check = false;
136 bool alwaysOnline = ptr->GetProperty().alwaysOnline;
137 if ((it = structVal.find("aonline")) != structVal.end())
138     {
139     check = true;
140     alwaysOnline = xmlrpc_c::value_boolean(it->second);
141     }
142 bool onlyOneIP = ptr->GetProperty().ips.ConstData().OnlyOneIP();
143 if ((it = structVal.find("ips")) != structVal.end())
144     {
145     check = true;
146     onlyOneIP = StrToIPS(xmlrpc_c::value_string(it->second)).OnlyOneIP();
147     }
148
149 if (check && alwaysOnline && !onlyOneIP)
150     {
151     printfd(__FILE__, "Requested change leads to a forbidden state: AlwaysOnline with multiple IP's\n");
152     return true;
153     }
154
155 if ((it = structVal.find("ips")) != structVal.end())
156     {
157     USER_IPS ips;
158     ips = StrToIPS(xmlrpc_c::value_string(it->second));
159
160     for (size_t i = 0; i < ips.Count(); ++i)
161         {
162         CONST_USER_PTR user;
163         uint32_t ip = ips[i].ip;
164         if (users.IsIPInUse(ip, login, &user))
165             {
166             printfd(__FILE__, "Trying to assign an IP %s to '%s' that is already in use by '%s'\n", inet_ntostring(ip).c_str(), login.c_str(), user->GetLogin().c_str());
167             return true;
168             }
169         }
170
171     if (!ptr->GetProperty().ips.Set(ips,
172                                 admin,
173                                 login,
174                                 &store))
175         return true;
176     }
177
178 if ((it = structVal.find("aonline")) != structVal.end())
179     {
180     bool value(xmlrpc_c::value_boolean(it->second));
181     if (ptr->GetProperty().alwaysOnline.Get() != value)
182         if (!ptr->GetProperty().alwaysOnline.Set(value,
183                                              admin,
184                                              login,
185                                              &store))
186             return true;
187     }
188
189 if ((it = structVal.find("password")) != structVal.end())
190     {
191     std::string value(xmlrpc_c::value_string(it->second));
192     if (ptr->GetProperty().password.Get() != value)
193         if (!ptr->GetProperty().password.Set(value,
194                                          admin,
195                                          login,
196                                          &store))
197             return true;
198     }
199
200 if ((it = structVal.find("address")) != structVal.end())
201     {
202     std::string value(IconvString(xmlrpc_c::value_string(it->second), "UTF-8", "KOI8-RU"));
203     if (ptr->GetProperty().address.Get() != value)
204         if (!ptr->GetProperty().address.Set(value,
205                                         admin,
206                                         login,
207                                         &store))
208             return true;
209     }
210
211 if ((it = structVal.find("phone")) != structVal.end())
212     {
213     std::string value(IconvString(xmlrpc_c::value_string(it->second), "UTF-8", "KOI8-RU"));
214     if (ptr->GetProperty().phone.Get() != value)
215         if (!ptr->GetProperty().phone.Set(value,
216                                       admin,
217                                       login,
218                                       &store))
219             return true;
220     }
221
222 if ((it = structVal.find("email")) != structVal.end())
223     {
224     std::string value(IconvString(xmlrpc_c::value_string(it->second), "UTF-8", "KOI8-RU"));
225     if (ptr->GetProperty().email.Get() != value)
226         if (!ptr->GetProperty().email.Set(value,
227                                       admin,
228                                       login,
229                                       &store))
230             return true;
231     }
232
233 if ((it = structVal.find("cash")) != structVal.end())
234     {
235     double value(xmlrpc_c::value_double(it->second));
236     if (std::fabs(ptr->GetProperty().cash.Get() - value) > 1.0e-3)
237         if (!ptr->GetProperty().cash.Set(value,
238                                      admin,
239                                      login,
240                                      &store))
241             return true;
242     }
243
244 if ((it = structVal.find("creditexpire")) != structVal.end())
245     {
246     time_t value(xmlrpc_c::value_int(it->second));
247     if (ptr->GetProperty().creditExpire.Get() != value)
248         if (!ptr->GetProperty().creditExpire.Set(value,
249                                              admin,
250                                              login,
251                                              &store))
252             return true;
253     }
254
255 if ((it = structVal.find("credit")) != structVal.end())
256     {
257     double value(xmlrpc_c::value_double(it->second));
258     if (std::fabs(ptr->GetProperty().credit.Get() - value) > 1.0e-3)
259         if (!ptr->GetProperty().credit.Set(value,
260                                        admin,
261                                        login,
262                                        &store))
263             return true;
264     }
265
266 if ((it = structVal.find("freemb")) != structVal.end())
267     {
268     double value(xmlrpc_c::value_double(it->second));
269     if (std::fabs(ptr->GetProperty().freeMb.Get() - value) > 1.0e-3)
270         if (!ptr->GetProperty().freeMb.Set(value,
271                                        admin,
272                                        login,
273                                        &store))
274             return true;
275     }
276
277 if ((it = structVal.find("down")) != structVal.end())
278     {
279     bool value(xmlrpc_c::value_boolean(it->second));
280     if (ptr->GetProperty().disabled.Get() != value)
281         if (!ptr->GetProperty().disabled.Set(value,
282                                          admin,
283                                          login,
284                                          &store))
285             return true;
286     }
287
288 if ((it = structVal.find("passive")) != structVal.end())
289     {
290     bool value(xmlrpc_c::value_boolean(it->second));
291     if (ptr->GetProperty().passive.Get() != value)
292         if (!ptr->GetProperty().passive.Set(value,
293                                         admin,
294                                         login,
295                                         &store))
296             return true;
297     }
298
299 if ((it = structVal.find("disableddetailstat")) != structVal.end())
300     {
301     bool value(xmlrpc_c::value_boolean(it->second));
302     if (ptr->GetProperty().disabledDetailStat.Get() != value)
303         if (!ptr->GetProperty().disabledDetailStat.Set(value,
304                                                    admin,
305                                                    login,
306                                                    &store))
307             return true;
308     }
309
310 if ((it = structVal.find("name")) != structVal.end())
311     {
312     std::string value(IconvString(xmlrpc_c::value_string(it->second), "UTF-8", "KOI8-RU"));
313     if (ptr->GetProperty().realName.Get() != value)
314         if (!ptr->GetProperty().realName.Set(value,
315                                          admin,
316                                          login,
317                                          &store))
318             return true;
319     }
320
321 if ((it = structVal.find("group")) != structVal.end())
322     {
323     std::string value(IconvString(xmlrpc_c::value_string(it->second), "UTF-8", "KOI8-RU"));
324     if (ptr->GetProperty().group.Get() != value)
325         if (!ptr->GetProperty().group.Set(value,
326                                       admin,
327                                       login,
328                                       &store))
329             return true;
330     }
331
332 if ((it = structVal.find("note")) != structVal.end())
333     {
334     std::string value(IconvString(xmlrpc_c::value_string(it->second), "UTF-8", "KOI8-RU"));
335     if (ptr->GetProperty().note.Get() != value)
336         if (!ptr->GetProperty().note.Set(value,
337                                      admin,
338                                      login,
339                                      &store))
340             return true;
341     }
342
343 if ((it = structVal.find("userdata")) != structVal.end())
344     {
345     std::vector<USER_PROPERTY_LOGGED<std::string> *> userdata;
346     userdata.push_back(ptr->GetProperty().userdata0.GetPointer());
347     userdata.push_back(ptr->GetProperty().userdata1.GetPointer());
348     userdata.push_back(ptr->GetProperty().userdata2.GetPointer());
349     userdata.push_back(ptr->GetProperty().userdata3.GetPointer());
350     userdata.push_back(ptr->GetProperty().userdata4.GetPointer());
351     userdata.push_back(ptr->GetProperty().userdata5.GetPointer());
352     userdata.push_back(ptr->GetProperty().userdata6.GetPointer());
353     userdata.push_back(ptr->GetProperty().userdata7.GetPointer());
354     userdata.push_back(ptr->GetProperty().userdata8.GetPointer());
355     userdata.push_back(ptr->GetProperty().userdata9.GetPointer());
356
357     std::vector<xmlrpc_c::value> udata(
358         xmlrpc_c::value_array(it->second).vectorValueValue()
359         );
360
361     for (unsigned i = 0; i < userdata.size(); ++i)
362         {
363         std::string value(IconvString(xmlrpc_c::value_string(udata[i]), "UTF-8", "KOI8-RU"));
364         if (userdata[i]->Get() != value)
365             if (!userdata[i]->Set(value,
366                                   admin,
367                                   login,
368                                   &store))
369                 return true;
370         }
371     }
372
373 if ((it = structVal.find("traff")) != structVal.end())
374     {
375     std::map<std::string, xmlrpc_c::value> traff(
376         static_cast<std::map<std::string, xmlrpc_c::value> >(xmlrpc_c::value_struct(it->second))
377         );
378
379     DIR_TRAFF dtData;
380     dtData = ptr->GetProperty().up.Get();
381     if ((it = traff.find("mu")) != traff.end())
382         {
383         std::vector<xmlrpc_c::value> data(xmlrpc_c::value_array(it->second).vectorValueValue());
384
385         for (int i = 0; i < std::min(DIR_NUM, static_cast<int>(data.size())); ++i)
386             {
387             int64_t value;
388             if (str2x(xmlrpc_c::value_string(data[i]), value))
389                 printfd(__FILE__, "USER_HELPER::SetUserInfo(): 'Invalid month upload value'\n");
390             else
391                 dtData[i] = value;
392             }
393         if (!ptr->GetProperty().up.Set(dtData,
394                                    admin,
395                                    login,
396                                    &store))
397             return true;
398         }
399     dtData = ptr->GetProperty().down.Get();
400     if ((it = traff.find("md")) != traff.end())
401         {
402         std::vector<xmlrpc_c::value> data(xmlrpc_c::value_array(it->second).vectorValueValue());
403
404         for (int i = 0; i < std::min(DIR_NUM, static_cast<int>(data.size())); ++i)
405             {
406             int64_t value;
407             if (str2x(xmlrpc_c::value_string(data[i]), value))
408                 printfd(__FILE__, "USER_HELPER::SetUserInfo(): 'Invalid month download value'\n");
409             else
410                 dtData[i] = value;
411             }
412         if (!ptr->GetProperty().down.Set(dtData,
413                                      admin,
414                                      login,
415                                      &store))
416             return true;
417         }
418     }
419
420 if ((it = structVal.find("tariff")) != structVal.end())
421     {
422     std::string tariff(xmlrpc_c::value_string(it->second));
423     size_t pos = tariff.find('/');
424     std::string nextTariff;
425     if (pos != std::string::npos)
426         {
427         nextTariff = tariff.substr(pos + 1);
428         tariff = tariff.substr(0, pos);
429         }
430
431     const TARIFF * newTariff = tariffs->FindByName(tariff);
432     if (newTariff)
433         {
434         const TARIFF * currentTariff = ptr->GetTariff();
435         std::string message = currentTariff->TariffChangeIsAllowed(*newTariff, stgTime);
436         if (message.empty())
437             {
438             if (ptr->GetProperty().tariffName.Get() != tariff)
439                 {
440                 if (!ptr->GetProperty().tariffName.Set(tariff,
441                                                    admin,
442                                                    login,
443                                                    &store))
444                     return true;
445                 }
446             }
447         else
448             {
449                 PluginLogger::get("conf_rpc")("Tariff change is prohibited for user %s. %s", ptr->GetLogin().c_str(), message.c_str());
450             }
451         }
452
453     if (nextTariff != "" &&
454         tariffs->FindByName(nextTariff))
455         if (ptr->GetProperty().nextTariff.Get() != nextTariff)
456             if (!ptr->GetProperty().nextTariff.Set(tariff,
457                                                admin,
458                                                login,
459                                                &store))
460                 return true;
461     }
462
463 return false;
464 }