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