8e74ffd996feda1e2c6e49168184e48cfb61f112
[brisk.git] / web / Obj / auth.phh
1 <?php
2   /*
3    *  brisk - auth.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_${G_dbasetype}.phh");
26
27 define(CHAL_SHM_DIMS_MIN, 16384);
28 define(CHAL_SHM_DIMS_MAX, 65536);
29 define(CHAL_SHM_DIMS_DLT, 16384);
30 define(CHAL_VALID_TIME,      15);
31 define(CHAL_GARBAGE_TIMEOUT,  5);
32
33
34 class Challenge {
35     var $login;
36     var $token;
37     var $ip;
38     var $tstamp;
39     
40     function Challenge($login, $token, $ip, $tstamp)
41     {
42         $this->login  = $login;
43         $this->token  = $token;
44         $this->ip     = $ip;
45         $this->tstamp = $tstamp + CHAL_VALID_TIME;
46     }
47 }
48
49 class Challenges {
50     static $delta_t;
51
52     var $item;
53     var $item_n;
54     var $mod;
55     var $shm_sz;
56     
57     var $garbage_timeout;
58     
59     
60     function Challenges()
61     {
62         $this->item = array();
63         $this->item_n = 0;
64         $this->garbage_timeout = 0;
65         $this->mod = FALSE;
66     }
67     
68     function add($login, $token, $ip, $tstamp) 
69     {
70         $chal = null;
71         
72         log_auth("xxx", sprintf("Challenges::add [%s]\n", $login));
73         // FIXME Checks here
74         if ($login == '') {
75             return (FALSE);
76         }
77         
78         // log_auth("xxx", "LOOPI tstamp: ".$this->item[$i]->tstamp."  curtime: ".$curtime);
79         
80         if (($chal = new Challenge($login, $token, $ip, $tstamp)) == FALSE) {
81             return (FALSE);
82         }
83         
84         $this->item[$this->item_n] = $chal;
85         $this->item_n++;
86
87         $this->mod = TRUE;
88
89         return ($chal);
90     }
91
92
93     /* remove all istances related to $login */
94
95     function rem($login)
96     {
97         $ismod  = FALSE;
98
99         for ($i = 0 ; $i < $this->item_n ; $i++) {
100             if ($this->item[$i]->login == $login) {
101                 $ismod = TRUE;
102                 for ($e = $i ; $e  < ($this->item_n - 1) ; $e++) {
103                     $this->item[$e] = $this->item[$e + 1];
104                 }
105         
106                 $i--;
107                 $this->item_n--;
108                 unset($this->item[$this->item_n]);
109                 $this->mod = TRUE;
110             }
111         }
112
113         return ($ismod);
114     }
115
116     function garbage_manager()
117     {
118         $curtime = time();
119
120         // FIXME remove set to 0
121         $this->garbage_timeout = 0;
122         if ($this->garbage_timeout > $curtime)
123             return (FALSE);
124
125         $ismod = FALSE;
126     
127         for ($i = 0 ; $i < $this->item_n ; $i++) {
128             log_auth("xxx", "LOOPI item: ".$i." tstamp: ".$this->item[$i]->tstamp."  curtime: ".$curtime);
129             if ($this->item[$i]->tstamp < $curtime) {
130                 for ($e = $i ; $e  < ($this->item_n - 1) ; $e++) {
131                     $this->item[$e] = $this->item[$e + 1];
132                 }
133         
134                 $i--;
135                 $this->item_n--;
136                 log_auth("xxx", "LOOPI unset: ".$this->item_n);
137                 unset($this->item[$this->item_n]);
138                 $ismod = TRUE;
139                 $this->mod = TRUE;
140             }
141         }
142     
143         log_auth("xxx", "LOOPI AFTER: ".count($this->item)." _n:" .$this->item_n );
144     
145         $this->garbage_timeout = $curtime + CHAL_GARBAGE_TIMEOUT;
146     
147         return ($ismod);
148     }
149   
150     function ismod()
151     {
152         return ($this->mod);
153     }
154
155     // Static functions
156     static function create()
157         {
158             $chal =& new Challenges();
159     
160             $chal->mod = TRUE;
161
162             return $chal;
163         }
164
165     function load_data() 
166         {
167             GLOBAL $sess;
168             do {
169                 if (($tok = @ftok(FTOK_PATH."/challenges", "B")) == -1) {
170                     log_main("ftok failed");
171                     break;
172                 }
173     
174                 if (($shm_sz = sharedmem_sz($tok)) == -1) {
175                     log_main("shmop_open failed");
176                 }
177         
178                 if ($shm_sz == -1)
179                     $shm_sz = CHAL_SHM_DIMS_MIN;
180
181                 if ($shm = shm_attach($tok, $shm_sz)) {
182                     $chals = @shm_get_var($shm, $tok);
183         
184                     log_only("challenges ==  ".($chals == FALSE ?   "FALSE" : "TRUE")."  challenges ===  ".($chals === FALSE ? "FALSE" : "TRUE")."  challenges isset ".(isset($chals) ?   "TRUE" : "FALSE"));
185         
186                     if ($chals == FALSE) {
187                         log_only("INIT CHALLENGES DATA");
188           
189                         $chals =& Challenges::create();
190                         if (@shm_put_var($shm, $tok, $chals) == FALSE) {
191                             log_only("PUT_VAR FALLITA ".strlen(serialize($chals)));
192                             log_only(serialize($chals));
193                         }
194                     }
195                     $chals->shm_sz = $shm_sz;
196         
197                     shm_detach($shm);
198                 }
199
200                 $chals->garbage_manager();
201
202                 return ($chals);
203             } while (0);
204     
205             return (FALSE);
206         }
207   
208
209     function save_data($chals) 
210     {
211         $shm =   FALSE;
212         $oldmod = $chals->mod;
213
214         if (($tok = @ftok(FTOK_PATH."/challenges", "B")) == -1) 
215             return (FALSE);
216     
217         while ($chals->shm_sz < CHAL_SHM_DIMS_MAX) {
218             if (($shm = shm_attach($tok, $chals->shm_sz)) == FALSE)
219                 break;
220       
221             if (isset($chals)) 
222                 log_only("challenges count ".count($chals->item)."  _n: ".$chals->item_n);
223
224             $chals->mod = FALSE;
225             if (shm_put_var($shm, $tok, $chals) != FALSE) {
226                 shm_detach($shm);
227                 return (TRUE);
228             }
229             $chals->mod = $oldmod;
230
231             if (shm_remove($shm) === FALSE) {
232                 log_only("REMOVE FALLITA");
233                 break;
234             }
235             shm_detach($shm);
236             $chals->shm_sz += CHAL_SHM_DIMS_DLT;
237         } 
238
239         if ($shm)
240             shm_detach($shm);
241     
242         return (FALSE);
243     }
244
245     function lock_data()
246     {
247         if (($tok = @ftok(FTOK_PATH."/challenges", "B")) == -1) {
248             return (FALSE);
249         }
250         // echo "FTOK ".$tok."<br>";
251         if (($res = sem_get($tok)) == FALSE) {
252             return (FALSE);
253         }
254         if (sem_acquire($res)) {   
255             self::$delta_t = microtime(TRUE);
256             log_lock("LOCK   challenges   [".self::$delta_t."]");
257             return ($res);
258         }
259         else
260             return (FALSE);
261     }
262   
263     function unlock_data($res)
264     {
265         GLOBAL $sess; 
266     
267         log_lock("UNLOCK challenges   [".(microtime(TRUE) - (self::$delta_t))."]");
268
269         return (sem_release($res));
270     }
271 } // End CLASS Challenges
272
273 ?>