f7f67cdd33890883eba0f6a2685d5355a704d40f
[brisk.git] / 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         // $user_pg = $this->query($user_sql);
167         // $row_n = pg_affected_rows($user_pg);
168         // fprintf(STDERR, "query: %s   NUM: %d\n", ($user_pg == FALSE ? "FALSE" : "TRUE"), $row_n);
169         if ( ! (($user_pg  = $this->query($user_sql)) != FALSE && pg_affected_rows($user_pg) == 1) ) {
170              return FALSE;
171         }
172
173         return TRUE;
174     }
175
176     function user_prefs_update($code, $flags, $supp_comp)
177     {
178         GLOBAL $G_dbpfx;
179
180         $user_sql = sprintf("UPDATE %susers SET (type, supp_comp) = (%d, '%s') WHERE code = %d;",
181                             $G_dbpfx, $flags, $supp_comp, $code);
182         fprintf(STDERR, "REQUEST [%s]\n", $user_sql);
183         if ( ! (($user_pg  = $this->query($user_sql)) != FALSE && pg_affected_rows($user_pg) == 1) ) {
184              return FALSE;
185         }
186         fprintf(STDERR, "REQUEST GOOD [%s]\n", $user_sql);
187
188         return TRUE;
189     }
190
191     /*
192       if success return a LoginDBItem object
193      */
194     function login_verify($login, $pass)
195     {
196         GLOBAL $G_dbpfx;
197
198         $ret = FALSE;
199
200         log_main("login_verify: ".$login);
201
202         //O /* check the existence of the nick in the BriskDB */
203         //O for ($i = 0 ; $i < $this->item_n ; $i++) {
204         //O log_main("login_verify: BEGIN");
205
206         if (($user_obj = $this->getrecord_bylogin($login)) == FALSE) {
207             return FALSE;
208         }
209
210         log_main("login[".$user_obj->code."]: ".$user_obj->login);
211
212         /* if it exists check for a valid challenge */
213         if (($a_sem = Challenges::lock_data(TRUE)) != FALSE) {
214             if (($chals = &Challenges::load_data()) != FALSE) {
215                 for ($e = 0 ; $e < $chals->item_n ; $e++) {
216                     log_main("challenge[".$e."]: ".$chals->item[$e]->login);
217                     if (strcmp($login, $chals->item[$e]->login) == 0) {
218                         log_main("login_verify [".$pass."] with [".md5($chals->item[$e]->token.$user_obj->pass)."]");
219
220                         if (strcmp($pass, md5($chals->item[$e]->token.$user_obj->pass)) == 0) {
221                             log_main("login_verify SUCCESS for ".$login);
222
223                             $chals->rem($login);
224                             $this->user_update_login_time($user_obj->code, time());
225                             $ret = LoginDBItem::LoginDBItemFromRecord($user_obj);
226                             break;
227                         }
228                     }
229                 } // end for ($e = 0 ...
230             }
231
232             if ($chals->ismod()) {
233                 Challenges::save_data(&$chals);
234             }
235
236             Challenges::unlock_data($a_sem);
237         }
238         //O break;
239         // O } //  if (strcasecmp($this->item[$i]->login, ...
240         //O }
241
242         return ($ret);
243     }
244
245     function getitem_bylogin($login, &$id) {
246         $ret = FALSE;
247         $id = -1;
248
249         log_main("getitem_bylogin: ".$login);
250
251         if (($user_obj = $this->getrecord_bylogin($login)) == FALSE)
252             return $ret;
253
254         $id = $user_obj->code;
255         return (LoginDBItem::LoginDBItemFromRecord($user_obj));
256     }
257
258     // TODO FOR DB
259     function getmail($login)
260     {
261         log_main("getmail");
262
263         if (($ret = $this->getrecord_bylogin($login)) == FALSE)
264             return FALSE;
265
266         return ($ret->email);
267     }
268
269     function addusers_from_olddb($olddb, &$cont)
270     {
271         GLOBAL $G_dbpfx;
272
273         for ($i = 0 ; $i < $olddb->count() ; $i++) {
274             $user_sql = sprintf("INSERT INTO %susers ( login, pass, email, type) VALUES ('%s', '%s', '%s', %d);",
275                                 $G_dbpfx, escsql(strtolower($olddb->item[$i]->login)), escsql($olddb->item[$i]->pass),
276                                 escsql($olddb->item[$i]->email), $olddb->item[$i]->type & USER_FLAG_TY_ALL);
277
278             if ( ! (($user_pg  = $this->query($user_sql)) != FALSE && pg_affected_rows($user_pg) == 1) ) {
279                 $cont .= sprintf("ERROR IN LINE: %s\n", eschtml($user_sql));
280
281                 return FALSE;
282             }
283         }
284         return TRUE;
285     }
286
287     function getdbconn()
288     {
289         return ($this->dbconn);
290     }
291
292     // return array of array('code', 'login' [, 'first', 'last', 'tidx']) ordered by table position
293     function users_get($match_code, $with_minmaxtidx, $is_newmatch)
294     {
295         GLOBAL $G_dbpfx;
296
297         if ($is_newmatch) { // is new
298             $usr_sql = sprintf("SELECT u.code AS code, u.login AS login%s
299                                   FROM %sbin5_matches AS m, %sbin5_games AS g, %sbin5_points AS p,
300                                        %susers AS u, %sbin5_table_orders AS o
301                                   WHERE m.code = g.mcode AND g.code = p.gcode AND u.code = p.ucode
302                                        AND m.code = o.mcode AND u.code = o.ucode AND m.code = %d
303                                   GROUP BY u.code, u.login%s, o.pos
304                                   ORDER BY o.pos;",
305                                ($with_minmaxtidx ? ", min(g.tstamp) AS first, max(g.tstamp) AS last, m.tidx AS tidx" : ""),
306                                $G_dbpfx, $G_dbpfx, $G_dbpfx, $G_dbpfx, $G_dbpfx, $match_code,
307                                ($with_minmaxtidx ? ", m.tidx" : ""));
308         }
309         else { // is old
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, %susers AS u
312                                   WHERE m.code = g.mcode AND g.code = p.gcode AND u.code = p.ucode AND m.code = %d
313                                   GROUP BY u.code, u.login%s;",
314                                ($with_minmaxtidx ? ", min(g.tstamp) AS first, max(g.tstamp) AS last, m.tidx AS tidx" : ""),
315                                $G_dbpfx, $G_dbpfx, $G_dbpfx, $G_dbpfx, $match_code,
316                                ($with_minmaxtidx ? ", m.tidx" : ""));
317         }
318
319         if (($usr_pg  = pg_query($this->dbconn->db(), $usr_sql)) == FALSE ) {
320             log_crit(sprintf("%s::%s: pg_query usr_sql failed [%s]", __CLASS__, __FUNCTION__, $usr_sql));
321             return (FALSE);
322         }
323         $usr_n = pg_numrows($usr_pg);
324         if ($usr_n != BIN5_PLAYERS_N) {
325             log_crit(sprintf("%s::%s: wrong number of players [%s] %d", __CLASS__, __FUNCTION__, $usr_sql, $usr_n));
326             return (FALSE);
327         }
328         $users = array();
329
330         if ($with_minmaxtidx)
331             $fields = array('code', 'login', 'first', 'last', 'tidx');
332         else
333             $fields = array('code', 'login');
334
335         for ($u = 0 ; $u < $usr_n ; $u++) {
336             $usr_obj = pg_fetch_object($usr_pg, $u);
337             $users[$u] = array();
338             foreach($fields as $field) {
339                 $users[$u][$field] = $usr_obj->$field;
340             }
341         }
342         return ($users);
343     }
344
345     // out: tab->{points,points_n,old_reason}, in: tab->ttok
346     function match_continue($match_code, $table, $tidx)
347     {
348         GLOBAL $G_dbpfx;
349
350         if (($users = $this->users_get($match_code, FALSE /*without minmaxidx*/, TRUE /*new game*/)) == FALSE) {
351             log_crit(sprintf("%s::%s: retrieve users fails", __CLASS__, __FUNCTION__));
352             return (FALSE);
353         }
354
355         $num_sql = sprintf("SELECT count(*) AS points_n FROM %sbin5_games WHERE mcode = %d;", $G_dbpfx, $match_code);
356         if (($num_pg  = $this->query($num_sql)) == FALSE || pg_numrows($num_pg) != 1) {
357             log_crit(sprintf("%s::%s: get games number fails", __CLASS__, __FUNCTION__));
358             return (FALSE);
359         }
360         $num_obj = pg_fetch_object($num_pg, 0);
361         $table->points_n = $num_obj->points_n;
362
363         $tot_sql = sprintf("SELECT sum(p.pts) AS pts
364                             FROM %sbin5_games AS g, %sbin5_points AS p, %susers AS u,
365                                  %sbin5_table_orders AS o
366                             WHERE g.mcode = %d AND g.code = p.gcode AND p.ucode = u.code
367                                   AND p.ucode = o.ucode AND g.mcode = o.mcode
368                             GROUP BY p.ucode, o.pos
369                             ORDER BY o.pos;",
370                            $G_dbpfx, $G_dbpfx, $G_dbpfx, $G_dbpfx, $match_code);
371         if (($tot_pg  = pg_query($this->dbconn->db(), $tot_sql)) == FALSE
372             || pg_numrows($tot_pg) != BIN5_PLAYERS_N) {
373             log_crit(sprintf("%s::%s: get games totals fails", __CLASS__, __FUNCTION__));
374             return(FALSE);
375         }
376
377         $u = 0;
378         foreach ($users as $user) {
379             $pts_sql = sprintf("SELECT p.pts AS pts
380                                     FROM %sbin5_points as p, %sbin5_games as g
381                                     WHERE p.gcode = g.code AND g.mcode = %d AND p.ucode = %d
382                                     ORDER BY g.code ASC
383                                     LIMIT %d OFFSET %d;",
384                                $G_dbpfx, $G_dbpfx, $match_code, $user['code'],
385                                MAX_POINTS,
386                                ($num_obj->points_n < MAX_POINTS ? 0 : $num_obj->points_n - MAX_POINTS));
387
388             // points of the match for each user
389             if (($pts_pg  = $this->query($pts_sql)) == FALSE) {
390                 log_crit(sprintf("%s::%s: get points fails", __CLASS__, __FUNCTION__));
391                 return (FALSE);
392             }
393             $pts_n = pg_numrows($pts_pg);
394             if ($pts_n > $table->points_n) {
395                 // inconsistent scenario number of points great than number of games
396                 log_crit(sprintf("%s::%s: number of points great than number of games", __CLASS__, __FUNCTION__));
397                 return (FALSE);
398             }
399             for ($i = 0 , $ct = $table->points_n - $pts_n; $ct < $table->points_n ; $ct++, $i++) {
400                 $pts_obj = pg_fetch_object($pts_pg, $i);
401                 $table->points[$ct % MAX_POINTS][$u] = $pts_obj->pts;
402             }
403             $tot_obj = pg_fetch_object($tot_pg, $u);
404             $table->total[$u] = $tot_obj->pts;
405
406             $u++;
407         }
408
409         $gam_sql = sprintf("SELECT * FROM %sbin5_games WHERE mcode = %d ORDER BY code DESC LIMIT 1;", $G_dbpfx, $match_code);
410         if (($gam_pg  = $this->query($gam_sql)) == FALSE || pg_numrows($gam_pg) != 1) {
411             log_crit(sprintf("%s::%s: get last game fails", __CLASS__, __FUNCTION__));
412             return (FALSE);
413         }
414         $gam_obj = pg_fetch_object($gam_pg, 0);
415
416         $table->old_reason = game_description($gam_obj->act, 'html', $gam_obj->mult,
417                                               $gam_obj->asta_win, ($gam_obj->asta_win != -1 ?
418                                                                    $users[$gam_obj->asta_win]['login'] : ""),
419                                               $gam_obj->friend, ($gam_obj->friend != -1 ?
420                                                                  $users[$gam_obj->friend]['login'] : ""),
421                                               $gam_obj->pnt, $gam_obj->asta_pnt);
422
423         return (TRUE);
424     }
425
426     function match_order_get(&$match_data, $match_code, $exp_num)
427     {
428         GLOBAL $G_dbpfx;
429
430         $ord_sql = sprintf("SELECT ucode FROM %sbin5_table_orders WHERE mcode = %d ORDER BY pos ASC;",
431                            $G_dbpfx, $match_code);
432
433         if (($ord_pg  = $this->query($ord_sql)) == FALSE || pg_numrows($ord_pg) != $exp_num) {
434             log_crit(sprintf("%s: fails for id or users number", __FUNCTION__));
435             return (FALSE);
436         }
437
438         $ucodes = array();
439         for ($i = 0 ; $i < $exp_num ; $i++) {
440             $ord_obj = pg_fetch_object($ord_pg, $i);
441             $ucodes[$i] = $ord_obj->ucode;
442         }
443
444         if ($match_data !== NULL) {
445             $mtdt_sql = sprintf("SELECT * FROM %sbin5_matches WHERE code = %d;",
446                                 $G_dbpfx, $match_code);
447
448             if (($mtdt_pg  = $this->query($mtdt_sql)) == FALSE || pg_numrows($mtdt_pg) != 1) {
449                 log_crit(sprintf("%s: fails retrieve match_data values [%d]", __FUNCTION__, $match_code));
450                 return (FALSE);
451             }
452
453             $mtdt_obj = pg_fetch_object($mtdt_pg, 0);
454
455             foreach (array('ttok', 'tidx', 'mult_next', 'mazzo_next', 'tcode') as $match_name) {
456                 $match_data[$match_name] = $mtdt_obj->$match_name;
457             }
458         }
459
460         return ($ucodes);
461     }
462
463     //   ttok   text UNIQUE,
464     //   tidx
465     function bin5_points_save($date, $table, $tidx, $action, $ucodes, $pts)
466     {
467         GLOBAL $G_dbpfx;
468         $sql_ttok = escsql($table->table_token);
469
470         $is_trans = FALSE;
471         $ret = FALSE;
472
473         $n = count($ucodes);
474         /* check the existence of the nick in the BriskDB */
475         log_main("bin5_points_save: ");
476
477         do {
478             if ($this->query("BEGIN") == FALSE) {
479                 break;
480             }
481             $is_trans = TRUE;
482
483             /*
484              * matches management
485              */
486             $mtc_sql = sprintf("UPDATE %sbin5_matches SET (mazzo_next, mult_next) = (%d, %d) WHERE ttok = '%s' RETURNING *;",
487                                $G_dbpfx, $table->mazzo, $table->mult, $sql_ttok);
488             if (($mtc_pg  = $this->query($mtc_sql)) == FALSE || pg_numrows($mtc_pg) != 1) {
489
490                 // match not exists, insert it
491                 $mtc_sql = sprintf("INSERT INTO %sbin5_matches (ttok, tidx, mazzo_next, mult_next) VALUES ('%s', %d, %d, %d) RETURNING *;",
492                                    $G_dbpfx, $sql_ttok, $tidx, $table->mazzo, $table->mult);
493                 if (($mtc_pg  = $this->query($mtc_sql)) == FALSE || pg_affected_rows($mtc_pg) != 1) {
494                     log_crit(sprintf("bin5_points_save: failed at insert match [%s]", $mtc_sql));
495                     break;
496                 }
497                 $mtc_obj = pg_fetch_object($mtc_pg, 0);
498
499                 for ($i = 0 ; $i < $n ; $i++) {
500                     $ord_sql = sprintf("INSERT INTO %sbin5_table_orders (mcode, ucode, pos) VALUES (%d, %d, %d);",
501                                        $G_dbpfx, $mtc_obj->code, $ucodes[$i], $i);
502                     if (($ord_pg = $this->query($ord_sql)) == FALSE || pg_affected_rows($ord_pg) != 1 ) {
503                         log_crit(sprintf("bin5_points_save: failed at insert table order [%s]", $ord_sql));
504                         break;
505                     }
506                 }
507                 if ($i < $n)
508                     break;
509             }
510             else {
511                 $mtc_obj = pg_fetch_object($mtc_pg,0);
512             }
513
514             /*
515              * games management
516              */
517             $gam_sql = sprintf("INSERT INTO %sbin5_games (mcode, tstamp, act, asta_pnt, pnt, asta_win, friend, mazzo, mult)
518                                                VALUES (%d, to_timestamp(%d), %d, %d, %d, %d, %d, %d, %d) RETURNING *;",
519                                $G_dbpfx, $mtc_obj->code, $date, $action,
520                                $table->old_asta_pnt, $table->old_pnt,
521                                $table->old_asta_win,
522                                $table->old_friend,
523                                $table->old_mazzo, $table->old_mult);
524             if (($gam_pg  = $this->query($gam_sql)) == FALSE || pg_affected_rows($gam_pg) != 1) {
525                 log_crit(sprintf("bin5_points_save: failed at insert game [%s]", $gam_sql));
526                 break;
527             }
528
529             $gam_obj = pg_fetch_object($gam_pg,0);
530
531             /*
532              * points management
533              */
534             for ($i = 0 ; $i < $n ; $i++) {
535                 /* put points */
536                 $pts_sql = sprintf("INSERT INTO %sbin5_points (gcode, ucode, pts)
537                                                VALUES (%d, %d, %d);",
538                                    $G_dbpfx, $gam_obj->code, $ucodes[$i], $pts[$i]);
539                 if (($pts_pg  = $this->query($pts_sql)) == FALSE || pg_affected_rows($pts_pg) != 1) {
540                     log_crit(sprintf("bin5_points_save: failed at insert point [%s]", $pts_sql));
541                     break;
542                 }
543             }
544             if ($i < $n)
545                 break;
546
547             if ($this->query("COMMIT") == FALSE) {
548                 break;
549             }
550
551             $is_trans = FALSE;
552
553             $table->match_id = $mtc_obj->code;
554             $ret = TRUE;
555         } while (0);
556
557         if ($is_trans)
558             $this->query("ROLLBACK");
559
560         return $ret;
561     }
562
563 } // End class BriskDB
564
565 class LoginDBOld
566 {
567     var $item;
568     var $item_n;
569
570     function LoginDBOld($filename)
571     {
572         GLOBAL $DOCUMENT_ROOT;
573         log_main("LoginDBOld create:start");
574
575         if (file_exists("$DOCUMENT_ROOT/Etc/".$filename)) {
576             require("$DOCUMENT_ROOT/Etc/".$filename);
577         }
578         else {
579             return (FALSE);
580         }
581         $this->item_n = count($this->item);
582         log_main("LoginDBOld create:end");
583     }
584
585     function count()
586     {
587         return ($this->item_n);
588     }
589
590 } // End class LoginDBOld
591
592 ?>