a205b32cffa770c164ab9ead624d865f4dcff8aa
[brisk.git] / web / Obj / dbase_pgsql.phh
1 <?php
2   /*
3    *  brisk - dbase_pgsql.phh
4    *
5    *  Copyright (C) 2006-2011 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         GLOBAL $G_dbauth;
45         
46         if (DBConn::$dbcnnx == FALSE) {
47             if (!(DBConn::$dbcnnx = @pg_connect ($G_dbauth))) {
48                 echo "DB connection failed.";
49                 exit;
50             }
51         }
52         $this->db = DBConn::$dbcnnx;
53
54         return;
55     }
56     function db()
57     {
58         return ($this->db);
59     }
60 }
61
62 class BriskDB
63 {
64     var $dbconn;
65     var $item;
66     var $item_n;
67     
68     function BriskDB()
69     {
70         GLOBAL $DOCUMENT_ROOT, $G_dbpfx, $G_false;
71         log_main("BriskDB create:start");
72         
73         $this->dbconn = new DBConn();
74         
75         log_main("BriskDB create:end");
76     }
77
78     function users_load()
79     {
80     }
81     
82     function login_exists($login)
83     {
84         GLOBAL $G_dbpfx;
85
86         /* check the existence of the nick in the BriskDB */
87         log_main("login_exists: ".$login);
88         
89         $user_sql = sprintf("SELECT * FROM %susers WHERE login = lower('%s') AND (type & CAST (X'%08x' as integer)) = 0;",
90                             $G_dbpfx, escsql($login), USER_FLAG_TY_DISABLE);
91         if (($user_pg  = pg_query($this->dbconn->db(), $user_sql)) != FALSE)
92             if (pg_numrows($user_pg) == 1)
93                 return TRUE;
94         
95         return FALSE;
96     }
97
98     function &getrecord_bylogin($login) {
99         GLOBAL $G_false, $G_dbpfx;
100
101         $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);
102         if (($user_pg  = pg_query($this->dbconn->db(), $user_sql)) == FALSE)
103             return $ret;
104         
105         if (pg_numrows($user_pg) != 1)
106             return $ret;
107         
108         $user_obj = pg_fetch_object($user_pg, 0);
109
110         return ($user_obj);
111     }
112
113
114     
115     function &login_verify($login, $pass)
116     {
117         GLOBAL $G_dbpfx, $G_false;
118         
119         $ret = &$G_false;
120         
121         log_main("login_verify: ".$login);
122         
123         
124         //O /* check the existence of the nick in the BriskDB */
125         //O for ($i = 0 ; $i < $this->item_n ; $i++) {
126         //O log_main("login_verify: BEGIN");
127         
128         if (($user_obj = $this->getrecord_bylogin($login)) == FALSE)
129             return $ret;
130
131         log_main("login[".$user_obj->code."]: ".$user_obj->login);
132         
133         /* if it exists check for a valid challenge */
134         if (($a_sem = Challenges::lock_data()) != FALSE) { 
135             if (($chals = &Challenges::load_data()) != FALSE) {
136                 for ($e = 0 ; $e < $chals->item_n ; $e++) {
137                     
138                     log_main("challenge[".$e."]: ".$chals->item[$e]->login);
139                     if (strcmp($login, $chals->item[$e]->login) == 0) {
140                         log_main("login_verify [".$pass."] with [".md5($chals->item[$e]->token.$user_obj->pass)."]");
141                         
142                         if (strcmp($pass, md5($chals->item[$e]->token.$user_obj->pass)) == 0) {
143                             log_main("login_verify SUCCESS for ".$login);
144                             
145                             $chals->rem($login);
146                             $ret = LoginDBItem::LoginDBItemFromRecord($user_obj);
147                             break;
148                         }
149                     }
150                 } // end for ($e = 0 ...
151             }
152             
153             if ($chals->ismod()) {
154                 Challenges::save_data(&$chals);
155             }
156             
157             Challenges::unlock_data($a_sem);
158         }
159         //O break;
160         // O } //  if (strcasecmp($this->item[$i]->login, ...
161         //O }
162     
163         return ($ret);
164     }
165
166     function &getitem_bylogin($login, &$id) {
167         GLOBAL $G_false;
168         
169         $ret = &$G_false;
170         $id = -1;
171         
172         log_main("getitem_bylogin: ".$login);
173         
174         if (($user_obj = $this->getrecord_bylogin($login)) == FALSE)
175             return $ret;
176
177         $id = $user_obj->code;
178         return (LoginDBItem::LoginDBItemFromRecord($user_obj));
179     }
180     
181     // TODO FOR DB
182     function getmail($login)
183     {
184         log_main("getmail");
185
186         if (($ret = $this->getrecord_bylogin($login)) == FALSE)
187             return FALSE;
188         
189         return ($ret->email);
190     }
191
192     function addusers_from_olddb($olddb, &$cont)
193     {
194         GLOBAL $G_dbpfx;
195
196         for ($i = 0 ; $i < $olddb->count() ; $i++) {
197             $user_sql = sprintf("INSERT INTO %susers ( login, pass, email, type) VALUES ('%s', '%s', '%s', %d);",
198                                 $G_dbpfx, escsql(strtolower($olddb->item[$i]->login)), escsql($olddb->item[$i]->pass),
199                                 escsql($olddb->item[$i]->email), $olddb->item[$i]->type & USER_FLAG_TY_ALL); 
200             
201             // if ( ! (($user_pg = pg_exec($dbconn,$order_add_sql)) != FALSE && pg_affected_rows($order_pg) == 1) ) {
202
203             if ( ! (($user_pg  = pg_query($this->dbconn->db(), $user_sql)) != FALSE && pg_affected_rows($user_pg) == 1) ) {
204                 $cont .= sprintf("ERROR IN LINE: %s\n", eschtml($user_sql));
205
206                 return FALSE;
207             }
208         }
209         return TRUE;
210     }
211
212     function &getdbconn()
213     {
214         $ret = $this->dbconn;
215         return ($ret);
216     }
217
218     //   ttok   text UNIQUE,      
219     //   tidx   
220     function bin5_points_save($date, $ttok, $tidx, $ucodes, $pts)
221     {
222         GLOBAL $G_dbpfx;
223
224         $is_trans = FALSE;
225         $ret = FALSE;
226
227         $n = count($ucodes);
228         /* check the existence of the nick in the BriskDB */
229         log_main("bin5_points_save: ");
230         
231         do {
232             if (pg_query($this->dbconn->db(), "BEGIN") == FALSE) {
233                 break;
234             }
235             $is_trans = TRUE;
236
237             /*
238              * matches management
239              */
240             $mtc_sql = sprintf("SELECT * FROM %sbin5_matches WHERE ttok = '%s';", $G_dbpfx, escsql($ttok));
241             if (($mtc_pg  = pg_query($this->dbconn->db(), $mtc_sql)) == FALSE || pg_numrows($mtc_pg) != 1) {
242                 // match not exists, insert it
243                 $mtc_sql = sprintf("INSERT INTO %sbin5_matches (ttok, tidx) VALUES ('%s', %d) RETURNING *;",
244                                    $G_dbpfx, escsql($ttok), $tidx);
245                 if ( ! (($mtc_pg  = pg_query($this->dbconn->db(), $mtc_sql)) != FALSE && 
246                         pg_affected_rows($mtc_pg) == 1) ) {
247                     log_crit(sprintf("bin5_points_save: failed at insert match [%s]", $mtc_sql));
248                     break;
249                 }
250             }
251             $mtc_obj = pg_fetch_object($mtc_pg,0);
252
253             /*
254              * games management
255              */
256             $gam_sql = sprintf("INSERT INTO %sbin5_games (mcode, tstamp) 
257                                                VALUES (%d, to_timestamp(%d)) RETURNING *;",
258                                $G_dbpfx, $mtc_obj->code, $date);
259             if ( ! (($gam_pg  = pg_query($this->dbconn->db(), $gam_sql)) != FALSE && 
260                     pg_affected_rows($gam_pg) == 1) ) {
261                 log_crit(sprintf("bin5_points_save: failed at insert game [%s]", $gam_sql));
262                 break;                        
263             }
264         
265             $gam_obj = pg_fetch_object($gam_pg,0);
266
267             /*
268              * points management
269              */
270             for ($i = 0 ; $i < $n ; $i++) {
271                 /* put points */
272                 $pts_sql = sprintf("INSERT INTO %sbin5_points (gcode, ucode, pts) 
273                                                VALUES (%d, %d, %d);",
274                                    $G_dbpfx, $gam_obj->code, $ucodes[$i], $pts[$i]);
275                 if ( ! (($pts_pg  = pg_query($this->dbconn->db(), $pts_sql)) != FALSE && 
276                         pg_affected_rows($pts_pg) == 1) ) {
277                     log_crit(sprintf("bin5_points_save: failed at insert point [%s]", $pts_sql));
278                     break;                        
279                 }
280             }
281
282             if ($i < $n)
283                 break;
284             
285             if (pg_query($this->dbconn->db(), "COMMIT") == FALSE) {
286                 break;
287             }
288              
289             $is_trans = FALSE;
290
291             $ret =  TRUE;
292         } while (0);
293         
294         if ($is_trans)
295             pg_query($this->dbconn-db(), "ROLLBACK");
296         
297         return $ret;
298     }
299
300 } // End class BriskDB
301
302 class LoginDBOld 
303 {
304     var $item;
305     var $item_n;
306
307     function LoginDBOld($filename)
308     {
309         GLOBAL $DOCUMENT_ROOT;
310         log_main("LoginDBOld create:start");
311
312         if (file_exists("$DOCUMENT_ROOT/Etc/".$filename)) {
313             require("$DOCUMENT_ROOT/Etc/".$filename);
314         }
315         else {
316             return (FALSE);
317         }
318         $this->item_n = count($this->item);
319         log_main("LoginDBOld create:end");
320     }
321
322     function count()
323     {
324         return ($this->item_n);
325     }
326
327 } // End class LoginDBOld
328
329 ?>