add methods to store users::lice_vers and renamed store_set to prefs_store to be...
[brisk.git] / web / Obj / dbase_pgsql.phh
1 <?php
2   /*
3    *  brisk - dbase_pgsql.phh
4    *
5    *  Copyright (C) 2006-2012 Matteo Nastasi
6    *                          mailto: nastasi@alternativeoutput.it
7    *                                  matteo.nastasi@milug.org
8    *                          web: http://www.alternativeoutput.it
9    *
10    * This program is free software; you can redistribute it and/or modify
11    * it under the terms of the GNU General Public License as published by
12    * the Free Software Foundation; either version 2 of the License, or
13    * (at your option) any later version.
14    *
15    * This program is distributed in the hope that it will be useful, but
16    * WITHOUT ANY WARRANTY; without even the implied warranty of
17    * MERCHANTABLILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
18    * General Public License for more details. You should have received a
19    * copy of the GNU General Public License along with this program; if
20    * not, write to the Free Software Foundation, Inc, 59 Temple Place -
21    * Suite 330, Boston, MA 02111-1307, USA.
22    *
23    */
24
25 require_once("${G_base}Obj/dbase_base.phh");
26
27 $escsql_from = array( "\\",   "'"   );
28 $escsql_to   = array( "\\\\", "\\'" );
29
30 function escsql($s)
31 {
32     GLOBAL $escsql_from, $escsql_to;
33
34     return str_replace($escsql_from, $escsql_to, $s);
35 }
36
37 class DBConn
38 {
39     static $dbcnnx = FALSE;
40     var $db = FALSE;
41
42     function DBConn()
43     {
44         $this->db = DBConn::$dbcnnx;
45     }
46
47     static function create()
48     {
49         GLOBAL $G_dbauth;
50
51         if (DBConn::$dbcnnx == FALSE) {
52             if (!(DBConn::$dbcnnx = @pg_connect ($G_dbauth, PGSQL_CONNECT_FORCE_NEW))) {
53                 return (FALSE);
54             }
55         }
56
57         $out = new DBConn();
58
59         return $out;
60     }
61
62     static function destroy()
63     {
64         if (DBConn::$dbcnnx != FALSE) {
65             DBConn::$dbcnnx = FALSE;
66             return (pg_close(DBConn::$dbcnnx));
67         }
68         return TRUE;
69     }
70
71     static function recover()
72     {
73         self::destroy();
74         return (self::create());
75     }
76
77     function db()
78     {
79         return ($this->db);
80     }
81 }
82
83 class BriskDB
84 {
85     var $dbconn;
86     var $item;
87     var $item_n;
88
89     function BriskDB($dbconn)
90     {
91         $this->dbconn = $dbconn;
92     }
93
94     static function create()
95     {
96         GLOBAL $DOCUMENT_ROOT, $G_dbpfx;
97
98         $ret = FALSE;
99
100         log_main("BriskDB create:start");
101
102         do {
103             if (($dbconn = DBConn::create()) == FALSE) {
104                 break;
105             }
106
107             $ret = new BriskDB($dbconn);
108         } while (0);
109
110         return ($ret);
111     }
112
113     function query($sql)
114     {
115         if (($res = pg_query($this->dbconn->db(), $sql)) == FALSE) {
116             // try to recover the connection
117             if (($this->dbconn = DBConn::recover()) == FALSE)
118                 return FALSE;
119             return (pg_query($this->dbconn->db(), $sql));
120         }
121
122         return ($res);
123     }
124
125     function users_load()
126     {
127     }
128
129     function login_exists($login)
130     {
131         GLOBAL $G_dbpfx;
132
133         /* check the existence of the nick in the BriskDB */
134         log_main("login_exists: ".$login);
135
136         $user_sql = sprintf("SELECT * FROM %susers WHERE login = lower('%s') AND (type & CAST (X'%08x' as integer)) = 0;",
137                             $G_dbpfx, escsql($login), USER_FLAG_TY_DISABLE);
138         if (($user_pg = $this->query($user_sql)) != FALSE)
139             if (pg_numrows($user_pg) == 1)
140                 return TRUE;
141
142         return FALSE;
143     }
144
145     function getrecord_bylogin($login) {
146         GLOBAL $G_dbpfx;
147
148         $user_sql = sprintf("SELECT * FROM %susers WHERE login = lower('%s') AND (type & CAST (X'%08x' as integer)) = 0;",  $G_dbpfx, escsql($login), USER_FLAG_TY_DISABLE);
149         if (($user_pg  = $this->query($user_sql)) == FALSE) {
150             return FALSE;
151         }
152         if (pg_numrows($user_pg) != 1)
153             return FALSE;
154
155         $user_obj = pg_fetch_object($user_pg, 0);
156
157         return ($user_obj);
158     }
159
160     function user_update_login_time($code, $lintm)
161     {
162         GLOBAL $G_dbpfx;
163
164         $user_sql = sprintf("UPDATE %susers SET (lintm) = (date 'epoch' + %d * INTERVAL '1 second') WHERE code = %d;", $G_dbpfx, $lintm, $code);
165
166         if ( ! (($user_pg  = $this->query($user_sql)) != FALSE && pg_affected_rows($user_pg) == 1) ) {
167              return FALSE;
168         }
169
170         return TRUE;
171     }
172
173     function user_prefs_update($code, $flags, $supp_comp)
174     {
175         GLOBAL $G_dbpfx;
176
177         $user_sql = sprintf("UPDATE %susers SET (type, supp_comp) = (%d, '%s') WHERE code = %d;",
178                             $G_dbpfx, $flags, escsql($supp_comp), $code);
179         fprintf(STDERR, "REQUEST [%s]\n", $user_sql);
180         if ( ! (($user_pg  = $this->query($user_sql)) != FALSE && pg_affected_rows($user_pg) == 1) ) {
181              return FALSE;
182         }
183         fprintf(STDERR, "REQUEST GOOD [%s]\n", $user_sql);
184
185         return TRUE;
186     }
187
188     function user_licence_update($code, $lice_vers)
189     {
190         GLOBAL $G_dbpfx;
191
192         $user_sql = sprintf("UPDATE %susers SET (lice_vers) = ('%s') WHERE code = %d;",
193                             $G_dbpfx, escsql($lice_vers), $code);
194         fprintf(STDERR, "REQUEST [%s]\n", $user_sql);
195         if ( ! (($user_pg  = $this->query($user_sql)) != FALSE && pg_affected_rows($user_pg) == 1) ) {
196              return FALSE;
197         }
198         fprintf(STDERR, "REQUEST GOOD [%s]\n", $user_sql);
199
200         return TRUE;
201     }
202
203     /*
204       if success return a LoginDBItem object
205      */
206     function login_verify($login, $pass)
207     {
208         GLOBAL $G_dbpfx;
209
210         $ret = FALSE;
211
212         log_main("login_verify: ".$login);
213
214         //O /* check the existence of the nick in the BriskDB */
215         //O for ($i = 0 ; $i < $this->item_n ; $i++) {
216         //O log_main("login_verify: BEGIN");
217
218         if (($user_obj = $this->getrecord_bylogin($login)) == FALSE) {
219             return FALSE;
220         }
221
222         log_main("login[".$user_obj->code."]: ".$user_obj->login);
223
224         /* if it exists check for a valid challenge */
225         if (($a_sem = Challenges::lock_data(TRUE)) != FALSE) {
226             if (($chals = &Challenges::load_data()) != FALSE) {
227                 for ($e = 0 ; $e < $chals->item_n ; $e++) {
228                     log_main("challenge[".$e."]: ".$chals->item[$e]->login);
229                     if (strcmp($login, $chals->item[$e]->login) == 0) {
230                         log_main("login_verify [".$pass."] with [".md5($chals->item[$e]->token.$user_obj->pass)."]");
231
232                         if (strcmp($pass, md5($chals->item[$e]->token.$user_obj->pass)) == 0) {
233                             log_main("login_verify SUCCESS for ".$login);
234
235                             $chals->rem($login);
236                             $this->user_update_login_time($user_obj->code, time());
237                             $ret = LoginDBItem::LoginDBItemFromRecord($user_obj);
238                             break;
239                         }
240                     }
241                 } // end for ($e = 0 ...
242             }
243
244             if ($chals->ismod()) {
245                 Challenges::save_data(&$chals);
246             }
247
248             Challenges::unlock_data($a_sem);
249         }
250         //O break;
251         // O } //  if (strcasecmp($this->item[$i]->login, ...
252         //O }
253
254         return ($ret);
255     }
256
257     function getitem_bylogin($login, &$id) {
258         $ret = FALSE;
259         $id = -1;
260
261         log_main("getitem_bylogin: ".$login);
262
263         if (($user_obj = $this->getrecord_bylogin($login)) == FALSE)
264             return $ret;
265
266         $id = $user_obj->code;
267         return (LoginDBItem::LoginDBItemFromRecord($user_obj));
268     }
269
270     // TODO FOR DB
271     function getmail($login)
272     {
273         log_main("getmail");
274
275         if (($ret = $this->getrecord_bylogin($login)) == FALSE)
276             return FALSE;
277
278         return ($ret->email);
279     }
280
281     function addusers_from_olddb($olddb, &$cont)
282     {
283         GLOBAL $G_dbpfx;
284
285         for ($i = 0 ; $i < $olddb->count() ; $i++) {
286             $user_sql = sprintf("INSERT INTO %susers ( login, pass, email, type) VALUES ('%s', '%s', '%s', %d);",
287                                 $G_dbpfx, escsql(strtolower($olddb->item[$i]->login)), escsql($olddb->item[$i]->pass),
288                                 escsql($olddb->item[$i]->email), $olddb->item[$i]->type & USER_FLAG_TY_ALL);
289
290             if ( ! (($user_pg  = $this->query($user_sql)) != FALSE && pg_affected_rows($user_pg) == 1) ) {
291                 $cont .= sprintf("ERROR IN LINE: %s\n", eschtml($user_sql));
292
293                 return FALSE;
294             }
295         }
296         return TRUE;
297     }
298
299     function getdbconn()
300     {
301         return ($this->dbconn);
302     }
303
304     // return array of array('code', 'login' [, 'first', 'last', 'tidx']) ordered by table position
305     function users_get($match_code, $with_minmaxtidx, $is_newmatch)
306     {
307         GLOBAL $G_dbpfx;
308
309         if ($is_newmatch) { // is new
310             $usr_sql = sprintf("SELECT u.code AS code, u.login AS login%s
311                                   FROM %sbin5_matches AS m, %sbin5_games AS g, %sbin5_points AS p,
312                                        %susers AS u, %sbin5_table_orders AS o
313                                   WHERE m.code = g.mcode AND g.code = p.gcode AND u.code = p.ucode
314                                        AND m.code = o.mcode AND u.code = o.ucode AND m.code = %d
315                                   GROUP BY u.code, u.login%s, o.pos
316                                   ORDER BY o.pos;",
317                                ($with_minmaxtidx ? ", min(g.tstamp) AS first, max(g.tstamp) AS last, m.tidx AS tidx" : ""),
318                                $G_dbpfx, $G_dbpfx, $G_dbpfx, $G_dbpfx, $G_dbpfx, $match_code,
319                                ($with_minmaxtidx ? ", m.tidx" : ""));
320         }
321         else { // is old
322             $usr_sql = sprintf("SELECT u.code AS code, u.login AS login%s
323                                   FROM %sbin5_matches AS m, %sbin5_games AS g, %sbin5_points AS p, %susers AS u
324                                   WHERE m.code = g.mcode AND g.code = p.gcode AND u.code = p.ucode AND m.code = %d
325                                   GROUP BY u.code, u.login%s;",
326                                ($with_minmaxtidx ? ", min(g.tstamp) AS first, max(g.tstamp) AS last, m.tidx AS tidx" : ""),
327                                $G_dbpfx, $G_dbpfx, $G_dbpfx, $G_dbpfx, $match_code,
328                                ($with_minmaxtidx ? ", m.tidx" : ""));
329         }
330
331         if (($usr_pg  = pg_query($this->dbconn->db(), $usr_sql)) == FALSE ) {
332             log_crit(sprintf("%s::%s: pg_query usr_sql failed [%s]", __CLASS__, __FUNCTION__, $usr_sql));
333             return (FALSE);
334         }
335         $usr_n = pg_numrows($usr_pg);
336         if ($usr_n != BIN5_PLAYERS_N) {
337             log_crit(sprintf("%s::%s: wrong number of players [%s] %d", __CLASS__, __FUNCTION__, $usr_sql, $usr_n));
338             return (FALSE);
339         }
340         $users = array();
341
342         if ($with_minmaxtidx)
343             $fields = array('code', 'login', 'first', 'last', 'tidx');
344         else
345             $fields = array('code', 'login');
346
347         for ($u = 0 ; $u < $usr_n ; $u++) {
348             $usr_obj = pg_fetch_object($usr_pg, $u);
349             $users[$u] = array();
350             foreach($fields as $field) {
351                 $users[$u][$field] = $usr_obj->$field;
352             }
353         }
354         return ($users);
355     }
356
357     // out: tab->{points,points_n,old_reason}, in: tab->ttok
358     function match_continue($match_code, $table, $tidx)
359     {
360         GLOBAL $G_dbpfx;
361
362         if (($users = $this->users_get($match_code, FALSE /*without minmaxidx*/, TRUE /*new game*/)) == FALSE) {
363             log_crit(sprintf("%s::%s: retrieve users fails", __CLASS__, __FUNCTION__));
364             return (FALSE);
365         }
366
367         $num_sql = sprintf("SELECT count(*) AS points_n FROM %sbin5_games WHERE mcode = %d;", $G_dbpfx, $match_code);
368         if (($num_pg  = $this->query($num_sql)) == FALSE || pg_numrows($num_pg) != 1) {
369             log_crit(sprintf("%s::%s: get games number fails", __CLASS__, __FUNCTION__));
370             return (FALSE);
371         }
372         $num_obj = pg_fetch_object($num_pg, 0);
373         $table->points_n = $num_obj->points_n;
374
375         $tot_sql = sprintf("SELECT sum(p.pts) AS pts
376                             FROM %sbin5_games AS g, %sbin5_points AS p, %susers AS u,
377                                  %sbin5_table_orders AS o
378                             WHERE g.mcode = %d AND g.code = p.gcode AND p.ucode = u.code
379                                   AND p.ucode = o.ucode AND g.mcode = o.mcode
380                             GROUP BY p.ucode, o.pos
381                             ORDER BY o.pos;",
382                            $G_dbpfx, $G_dbpfx, $G_dbpfx, $G_dbpfx, $match_code);
383         if (($tot_pg  = pg_query($this->dbconn->db(), $tot_sql)) == FALSE
384             || pg_numrows($tot_pg) != BIN5_PLAYERS_N) {
385             log_crit(sprintf("%s::%s: get games totals fails", __CLASS__, __FUNCTION__));
386             return(FALSE);
387         }
388
389         $u = 0;
390         foreach ($users as $user) {
391             $pts_sql = sprintf("SELECT p.pts AS pts
392                                     FROM %sbin5_points as p, %sbin5_games as g
393                                     WHERE p.gcode = g.code AND g.mcode = %d AND p.ucode = %d
394                                     ORDER BY g.code ASC
395                                     LIMIT %d OFFSET %d;",
396                                $G_dbpfx, $G_dbpfx, $match_code, $user['code'],
397                                MAX_POINTS,
398                                ($num_obj->points_n < MAX_POINTS ? 0 : $num_obj->points_n - MAX_POINTS));
399
400             // points of the match for each user
401             if (($pts_pg  = $this->query($pts_sql)) == FALSE) {
402                 log_crit(sprintf("%s::%s: get points fails", __CLASS__, __FUNCTION__));
403                 return (FALSE);
404             }
405             $pts_n = pg_numrows($pts_pg);
406             if ($pts_n > $table->points_n) {
407                 // inconsistent scenario number of points great than number of games
408                 log_crit(sprintf("%s::%s: number of points great than number of games", __CLASS__, __FUNCTION__));
409                 return (FALSE);
410             }
411             for ($i = 0 , $ct = $table->points_n - $pts_n; $ct < $table->points_n ; $ct++, $i++) {
412                 $pts_obj = pg_fetch_object($pts_pg, $i);
413                 $table->points[$ct % MAX_POINTS][$u] = $pts_obj->pts;
414             }
415             $tot_obj = pg_fetch_object($tot_pg, $u);
416             $table->total[$u] = $tot_obj->pts;
417
418             $u++;
419         }
420
421         $gam_sql = sprintf("SELECT * FROM %sbin5_games WHERE mcode = %d ORDER BY code DESC LIMIT 1;", $G_dbpfx, $match_code);
422         if (($gam_pg  = $this->query($gam_sql)) == FALSE || pg_numrows($gam_pg) != 1) {
423             log_crit(sprintf("%s::%s: get last game fails", __CLASS__, __FUNCTION__));
424             return (FALSE);
425         }
426         $gam_obj = pg_fetch_object($gam_pg, 0);
427
428         $table->old_reason = game_description($gam_obj->act, 'html', $gam_obj->mult,
429                                               $gam_obj->asta_win, ($gam_obj->asta_win != -1 ?
430                                                                    $users[$gam_obj->asta_win]['login'] : ""),
431                                               $gam_obj->friend, ($gam_obj->friend != -1 ?
432                                                                  $users[$gam_obj->friend]['login'] : ""),
433                                               $gam_obj->pnt, $gam_obj->asta_pnt);
434
435         return (TRUE);
436     }
437
438     function match_order_get(&$match_data, $match_code, $exp_num)
439     {
440         GLOBAL $G_dbpfx;
441
442         $ord_sql = sprintf("SELECT ucode FROM %sbin5_table_orders WHERE mcode = %d ORDER BY pos ASC;",
443                            $G_dbpfx, $match_code);
444
445         if (($ord_pg  = $this->query($ord_sql)) == FALSE || pg_numrows($ord_pg) != $exp_num) {
446             log_crit(sprintf("%s: fails for id or users number", __FUNCTION__));
447             return (FALSE);
448         }
449
450         $ucodes = array();
451         for ($i = 0 ; $i < $exp_num ; $i++) {
452             $ord_obj = pg_fetch_object($ord_pg, $i);
453             $ucodes[$i] = $ord_obj->ucode;
454         }
455
456         if ($match_data !== NULL) {
457             $mtdt_sql = sprintf("SELECT * FROM %sbin5_matches WHERE code = %d;",
458                                 $G_dbpfx, $match_code);
459
460             if (($mtdt_pg  = $this->query($mtdt_sql)) == FALSE || pg_numrows($mtdt_pg) != 1) {
461                 log_crit(sprintf("%s: fails retrieve match_data values [%d]", __FUNCTION__, $match_code));
462                 return (FALSE);
463             }
464
465             $mtdt_obj = pg_fetch_object($mtdt_pg, 0);
466
467             foreach (array('ttok', 'tidx', 'mult_next', 'mazzo_next', 'tcode') as $match_name) {
468                 $match_data[$match_name] = $mtdt_obj->$match_name;
469             }
470         }
471
472         return ($ucodes);
473     }
474
475     //   ttok   text UNIQUE,
476     //   tidx
477     function bin5_points_save($date, $table, $tidx, $action, $ucodes, $pts)
478     {
479         GLOBAL $G_dbpfx;
480         $sql_ttok = escsql($table->table_token);
481
482         $is_trans = FALSE;
483         $ret = FALSE;
484
485         $n = count($ucodes);
486         /* check the existence of the nick in the BriskDB */
487         log_main("bin5_points_save: ");
488
489         do {
490             if ($this->query("BEGIN") == FALSE) {
491                 break;
492             }
493             $is_trans = TRUE;
494
495             /*
496              * matches management
497              */
498             $mtc_sql = sprintf("UPDATE %sbin5_matches SET (mazzo_next, mult_next) = (%d, %d) WHERE ttok = '%s' RETURNING *;",
499                                $G_dbpfx, $table->mazzo, $table->mult, $sql_ttok);
500             if (($mtc_pg  = $this->query($mtc_sql)) == FALSE || pg_numrows($mtc_pg) != 1) {
501
502                 // match not exists, insert it
503                 $mtc_sql = sprintf("INSERT INTO %sbin5_matches (ttok, tidx, mazzo_next, mult_next) VALUES ('%s', %d, %d, %d) RETURNING *;",
504                                    $G_dbpfx, $sql_ttok, $tidx, $table->mazzo, $table->mult);
505                 if (($mtc_pg  = $this->query($mtc_sql)) == FALSE || pg_affected_rows($mtc_pg) != 1) {
506                     log_crit(sprintf("bin5_points_save: failed at insert match [%s]", $mtc_sql));
507                     break;
508                 }
509                 $mtc_obj = pg_fetch_object($mtc_pg, 0);
510
511                 for ($i = 0 ; $i < $n ; $i++) {
512                     $ord_sql = sprintf("INSERT INTO %sbin5_table_orders (mcode, ucode, pos) VALUES (%d, %d, %d);",
513                                        $G_dbpfx, $mtc_obj->code, $ucodes[$i], $i);
514                     if (($ord_pg = $this->query($ord_sql)) == FALSE || pg_affected_rows($ord_pg) != 1 ) {
515                         log_crit(sprintf("bin5_points_save: failed at insert table order [%s]", $ord_sql));
516                         break;
517                     }
518                 }
519                 if ($i < $n)
520                     break;
521             }
522             else {
523                 $mtc_obj = pg_fetch_object($mtc_pg,0);
524             }
525
526             /*
527              * games management
528              */
529             $gam_sql = sprintf("INSERT INTO %sbin5_games (mcode, tstamp, act, asta_pnt, pnt, asta_win, friend, mazzo, mult)
530                                                VALUES (%d, to_timestamp(%d), %d, %d, %d, %d, %d, %d, %d) RETURNING *;",
531                                $G_dbpfx, $mtc_obj->code, $date, $action,
532                                $table->old_asta_pnt, $table->old_pnt,
533                                $table->old_asta_win,
534                                $table->old_friend,
535                                $table->old_mazzo, $table->old_mult);
536             if (($gam_pg  = $this->query($gam_sql)) == FALSE || pg_affected_rows($gam_pg) != 1) {
537                 log_crit(sprintf("bin5_points_save: failed at insert game [%s]", $gam_sql));
538                 break;
539             }
540
541             $gam_obj = pg_fetch_object($gam_pg,0);
542
543             /*
544              * points management
545              */
546             for ($i = 0 ; $i < $n ; $i++) {
547                 /* put points */
548                 $pts_sql = sprintf("INSERT INTO %sbin5_points (gcode, ucode, pts)
549                                                VALUES (%d, %d, %d);",
550                                    $G_dbpfx, $gam_obj->code, $ucodes[$i], $pts[$i]);
551                 if (($pts_pg  = $this->query($pts_sql)) == FALSE || pg_affected_rows($pts_pg) != 1) {
552                     log_crit(sprintf("bin5_points_save: failed at insert point [%s]", $pts_sql));
553                     break;
554                 }
555             }
556             if ($i < $n)
557                 break;
558
559             if ($this->query("COMMIT") == FALSE) {
560                 break;
561             }
562
563             $is_trans = FALSE;
564
565             $table->match_id = $mtc_obj->code;
566             $ret = TRUE;
567         } while (0);
568
569         if ($is_trans)
570             $this->query("ROLLBACK");
571
572         return $ret;
573     }
574
575 } // End class BriskDB
576
577 class LoginDBOld
578 {
579     var $item;
580     var $item_n;
581
582     function LoginDBOld($filename)
583     {
584         GLOBAL $DOCUMENT_ROOT;
585         log_main("LoginDBOld create:start");
586
587         if (file_exists("$DOCUMENT_ROOT/Etc/".$filename)) {
588             require("$DOCUMENT_ROOT/Etc/".$filename);
589         }
590         else {
591             return (FALSE);
592         }
593         $this->item_n = count($this->item);
594         log_main("LoginDBOld create:end");
595     }
596
597     function count()
598     {
599         return ($this->item_n);
600     }
601
602 } // End class LoginDBOld
603
604 ?>