add pause test
[brisk.git] / web / Obj / brisk.phh
1 <?php
2 /*
3  *  brisk - brisk.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
26 define('BRISK_CONF', "brisk.conf.pho");
27 define('FTOK_PATH', "/var/lib/brisk");
28 define('LEGAL_PATH', "/tmp/legal_brisk");
29 define('PROXY_PATH', "/var/lib/brisk_proxy");
30 define('TABLES_N', 36);
31 define('TABLES_AUTH_N', 4);
32 define('PLAYERS_N', 3);
33 define('MAX_POINTS', 5);
34 define('MAX_PLAYERS', (20 + (PLAYERS_N * TABLES_N)));
35 define('SHM_DIMS_MIN', (50000 + 10000 * TABLES_N + 15000 * MAX_PLAYERS));
36 define('SHM_DIMS_MAX', SHM_DIMS_MIN + 1048576);
37 define('SHM_DIMS_DLT', 65536);
38
39 define('SHM_DIMS_U_MIN', 4096);
40 define('SHM_DIMS_U_MAX', 65536);
41 define('SHM_DIMS_U_DLT', 4096);
42
43 define('COMM_N', 18);
44 define('COMM_GEN_N', 50);
45
46 define('CHAT_N', 3);
47 define('CHAT_ILL_TIME', 6);
48 define('CHAT_ENABLED', TRUE);
49
50 define('SESS_LEN', 13);
51 define('STREAM_TIMEOUT', 60);
52 /* FIXME: move to sac-a-push .phh */
53 /* TIME_RD define the server-side timeout, after half of it a ping request
54    is sent to client, after this time the client is log out */
55 define('EXPIRE_TIME_RD', 180);
56 define('EXPIRE_TIME_SMAMMA', 360);
57 define('EXPIRE_TIME_WAG', 10);
58 define('WAKEUP_TIME', 12);
59 // BAN_TIME da allineare anche in commons.js
60 define('BAN_TIME', 3600);
61 define('GARBAGE_TIMEOUT', 10);
62 define('NICKSERV', "<i>BriskServ</i>");
63
64 define('LOCK_SHARE_MAX', 10000);
65
66 define('DBG_ONL2', 0x0001);
67 define('DBG_ONLY', 0x0002);
68 define('DBG_MAIN', 0x0004);
69 define('DBG_READ', 0x0008);
70 define('DBG_REA2', 0x0010);
71 define('DBG_SEND', 0x0020);
72 define('DBG_LOCK', 0x0040);
73 define('DBG_WRIT', 0x0080);
74 define('DBG_LOAD', 0x0100);
75 define('DBG_AUTH', 0x0200);
76 define('DBG_CRIT', 0x0400);
77 define('DBG_LMOP', 0x0800);
78 define('DBG_TRAC', 0x1000);
79 define('DBG_SHME', 0x2000);
80 // NOTE: BRISK DEBUG must be a numerical constant, not the result of operations on symbols 
81 define('BRISK_DEBUG', 0x0800);
82
83 define('BRISK_SINGLE_DEBUG',0);
84 define('BRISK_SINGLE_SESS', "");
85 define('DEBUGGING', "no-debugging");
86
87 require_once("$DOCUMENT_ROOT/Etc/".BRISK_CONF);
88
89 $mlang_brisk = array( 'btn_backstand'=> array( 'it' => 'torna in piedi',
90                                                'en' => 'back standing' ),
91                       'btn_close' => array( 'it' => 'chiudi',
92                                             'en' => 'close'),
93
94                       'tit_all' => array( 'it' => 'tutti',
95                                           'en' => 'all' ),
96
97                       'tabtout_a'=> array( 'it' => '<br>Sei stato inattivo per ', 
98                                            'en' => '<br>You are being idle for ' ),
99                       'tabtout_b'=> array( 'it' => ' minuti. <br><br>Quindi ritorni tra i <b>Giocatori in piedi</b>.',
100                                            'en' => ' minutes. <br><br>Then you return with the <b>standing players</b>.'),
101                       'tickmust' => array( 'it' => '<br>Per attivare il messaggio di segnalazione del tavolo occorre essere seduti.<br><br>',
102                                            'en' => '<br>To activate the signalling message of the table it\'s necessary to be sitting<br><br>'),
103                       'tickjust' => array( 'it' => '<br>Il messaggio di segnalazione del tavolo &egrave; gi&agrave; attivato.<br><br> ',
104                                            'en' => 'EN<br>Il messaggio di segnalazione del tavolo &egrave; gi&agrave; attivato.<br><br> '),
105                       'tickwait' => array( 'it' => '<br>Il messaggio di segnalazione del tavolo<br>&egrave; disattivato ancora per %d second%s.<br><br>',
106                                            'en' => 'EN<br>The signalling message of the table<br>will be deactivated for %d second%s.<br><br>'),
107                       'alarpass' => array( 'it' => '<br>La password digitata non &egrave; corretta.<br><br>',
108                                            'en' => '<br>The entered password is not correct.<br><br>'),
109                       'alarret'  => array( 'it' => '"Alarm \\"<b>%s</b>\\" inviato a <b>%s</b>."',
110                                            'en' => '"Alarm \\"<b>%s</b>\\" sent to <b>%s</b>."'),
111                       'authmust' => array( 'it' => '<b>Per autenticare qualcuno devi a tua volta essere autenticato.</b>',
112                                            'en' => '<b>To authenticate someone you have to be authenticated.</b>'), // on your turn
113                       'mesgmust' => array( 'it' => '<b>Per inviare un messaggio devi essere autenticato.</b>',
114                                            'en' => '<b>To send a message you have to be authenticated.</b>'),
115                       'nickmust' => array( 'it' => 'Il nickname deve contenere almeno una lettera dell\'alfabeto o una cifra.',
116                                            'en' => 'The nickname have to contain at least one letter or one number.'),
117                       'nickdupl' => array( 'it' => 'Nickname <b>%s</b> gi&agrave; in uso.',
118                                            'en' => 'The nickname <b>%s</b> is already in use.'),
119                       'authchan' => array( 'it' => '<b>Non puoi cambiare nick a un tavolo per soli autenticati o se sei in modalità isolata.</b>',
120                                            'en' => '<b>You can\'t change your nickname into a table for only authenticated or if you are in isolation mode.</b>'),
121                       'nickjust' => array( 'it' => 'Il nickname <b>\'%s\'</b> &egrave; gi&agrave; registrato, <b>se il suo proprietario si autentificher&agrave; verrai rinominato d\'ufficio come ghost<i>N</i>.</b>',
122                                            'en' => 'The nickname <b>\'%s\'</b> is already registered, <b>if its proprietary will authenticate you will named again officially ghost<i>N</i>.</b>'), // FIXME: him ???
123                       'statunkn' => array( 'it' => 'Questo stato non esiste.',
124                                            'en' => 'This state don\'t exists.'),
125                       'tabincon' => array( 'it' => '<br>I dati del tavolo n&deg; %d sono inconsistenti, verranno resettati.<br><br>Torni in piedi.<br><br>',
126                                            'en' => 'EN <br>I dati del tavolo n&deg; %d sono inconsistenti, verranno resettati.<br><br>Torni in piedi.<br><br>'),
127                       'listmust' => array( 'it' => '<b>Per andare in isolamento non bisogna essere seduti a tavoli non riservati.</b>',
128                                            'en' => '<b>To go to isolation you must don\'t stay on not reserved tables</b>'),
129
130                       'tit_onauth'=>array( 'it' => '(solo aut.)',
131                                            'en' => '(only aut.)'),
132                       'tit_onisol'=>array( 'it' => '(isolam.to)',
133                                            'en' => '(isolation)'),
134                       'db_failed' =>array('it'  => '<br>Il collegamento al database è fallito.<br>Temporaneamente tutte le autenticazioni verranno sospese, accederai a Brisk come un utente normale.<br><br>Ci scusiamo per il disagio.',
135                                           'en'  => 'Connection to the database failed<br>All authentications are suspended temporarly, you login as normal user.<br>We are about the limitation')
136                       
137
138 );
139
140 $G_lng = langtolng($G_lang);
141
142 $G_all_points = array( 11,10,4,3,2, 0,0,0,0,0 );
143 $G_brisk_version = "4.3.0";
144
145 /* MLANG: ALL THE INFO STRINGS IN brisk.phh */
146 $root_wellarr = array( 'it' => array ( 'Brisk (Ver. '.$G_brisk_version.'), <b>NOVITA\'</b>: adottato sac-a-push come motore per l\'invio dei dati in tempo reale, nuovo trasporto httpfile per explorer, tanti bug fixati, freeze su disco, fix del calcolo dei punti, nuovo stream dati xhr.',
147                                        'Se vuoi iscriverti alla <a target="_blank" href="mailto:ml-briscola+subscribe@milug.org">Mailing List</a>, cliccala!' ),
148                        'en' => array ( 'Brisk (Ver. '.$G_brisk_version.'), <b>NEWS</b>: usage of reader/writer locking instead of generic exclusive locking.',
149                                        'If you want to subscribe our <a target="_blank" href="ml-briscola+subscribe@milug.org">Mailing List</a>, click it!' ) );
150
151 $G_room_help = array( 'it' => '
152 <div style=\\"text-align: left; padding: 8px;\\">
153 <b>Descrizione</b><br>
154 Questa è un\'implementazione della briscola in cinque, cos&igrave; come &egrave; spiegata su
155 <a target=\\"_blank\\" href=\\"http://it.wikipedia.org/wiki/Briscola#Gioco_a_5\\">Wikipedia</a>; in breve &egrave; la variante con l\'asta prima sulla carta e poi sui punti.<br><br>
156 <b>Configurazione del browser.</b><br>
157 Occorre abilitare i cookies.<br>
158 <br>
159 <b>Uso del sito</b><br>
160 Potete sedervi a un tavolo o rimanere in piedi.<br>
161 Se al vostro tavolo si raggiungono i 5 giocatori inizia automaticamente la partita.<br>
162 <br>
163 <b>Partita</b><br>
164 All\'inizio vengono distribuite le carte e parte l\'asta; per partecipare all\'asta, quando sar&agrave; il vostro turno, potrete scegliere se andare avanti o passare cliccando sulle icone corrispondenti. Se si arriva ai punti, scrivete nella textbox il vostro rilancio e cliccate PUNTI.<br><br>
165 Chi vince l\'asta dovr&agrave; decidere il seme della carta scelta e inizier&agrave; la mano.<br>
166 Per giocare le carte dovrete trascinarle nel quadrato al centro del vostro schermo.<br><br>
167 Il vostro turno &egrave; sempre segnalato da una cornice verde lampeggiante intorno al quadrato al centro del vostro schermo.<br><br>
168 Durante la partita, se vorrete ricaricare la pagina, usate l\'apposito bottone \\"reload\\" in basso a destra.<br>
169 Dopo che &egrave; iniziata una partita per uscirne dovete chiedere agli altri giocatori di sbloccarla cliccando sul lucchetto. Se non si segue questa prassi, una volta usciti, non vi potrete sedere a nessun tavolo per '.floor(BAN_TIME/60).' minuti.
170 <dl>
171 <dt><b>Comandi della chat</b>
172 <dd><b>/nick <i>&lt;nuovo_nickname&gt;</i></b> - cambio di nickname
173 <dd><b>/tav <i>&lt;frase di invito&gt;</i></b> - invito per gli altri giocatori al tavolo dove si &egrave; seduti 
174 <dd><b>/st <i>&lt;stato&gt;</i></b> - cambia l\'icona associata al tuo user; <i>stato</i> pu&ograve; valere: \\"normale\\", \\"fuori\\", \\"pausa\\", \\"cibo\\", \\"cane\\", \\"lavoro\\", \\"presente\\" oppure \\"sigaretta\\"
175 <dd><b>/authreq</b> - se si &egrave; autenticati permette di garantire per un utente fidato
176 <dd><b>/mesgtoadm</b> - se si &egrave; autenticati permette di lasciare un messaggio all\'amministratore del sito
177 <dd><b>/listen &lt;all or auth&gt;</b> - se si &egrave; autenticati permette leggere solo i messaggi degli altri autenticati (auth) o di tutti (all)
178 </dl>
179 </div>
180 ',
181
182 'en' => '
183 <div style=\\"text-align: left; padding: 8px;\\">
184 <b>EN Descrizione</b><br>
185 EN Questa è un\'implementazione della briscola in cinque, cos&igrave; come &egrave; spiegata su
186 <a target=\\"_blank\\" href=\\"http://it.wikipedia.org/wiki/Briscola#Gioco_a_5\\">Wikipedia</a>; in breve &egrave; la variante con l\'asta prima sulla carta e poi sui punti.<br><br>
187 <b>EN Configurazione del browser.</b><br>
188 Occorre abilitare i cookies.<br>
189 <br>
190 <b>Uso del sito</b><br>
191 Potete sedervi a un tavolo o rimanere in piedi.<br>
192 Se al vostro tavolo si raggiungono i 5 giocatori inizia automaticamente la partita.<br>
193 <br>
194 <b>Partita</b><br>
195 All\'inizio vengono distribuite le carte e parte l\'asta; per partecipare all\'asta, quando sar&agrave; il vostro turno, potrete scegliere se andare avanti o passare cliccando sulle icone corrispondenti. Se si arriva ai punti, scrivete nella textbox il vostro rilancio e cliccate PUNTI.<br><br>
196 Chi vince l\'asta dovr&agrave; decidere il seme della carta scelta e inizier&agrave; la mano.<br>
197 Per giocare le carte dovrete trascinarle nel quadrato al centro del vostro schermo.<br><br>
198 Il vostro turno &egrave; sempre segnalato da una cornice verde lampeggiante intorno al quadrato al centro del vostro schermo.<br><br>
199 Durante la partita, se vorrete ricaricare la pagina, usate l\'apposito bottone \\"reload\\" in basso a destra.<br>
200 Dopo che &egrave; iniziata una partita per uscirne dovete chiedere agli altri giocatori di sbloccarla cliccando sul lucchetto. Se non si segue questa prassi, una volta usciti, non vi potrete sedere a nessun tavolo per '.floor(BAN_TIME/60).' minuti.
201 <dl>
202 <dt><b>Comandi della chat</b>
203 <dd><b>/nick <i>&lt;nuovo_nickname&gt;</i></b> - cambio di nickname
204 <dd><b>/tav <i>&lt;frase di invito&gt;</i></b> - invito per gli altri giocatori al tavolo dove si &egrave; seduti 
205 <dd><b>/st <i>&lt;stato&gt;</i></b> - cambia l\'icona associata al tuo user; <i>stato</i> pu&ograve; valere: \\"normale\\", \\"fuori\\", \\"pausa\\", \\"cibo\\", \\"cane\\", \\"lavoro\\", \\"presente\\" oppure \\"sigaretta\\"
206 <dd><b>/authreq</b> - se si &egrave; autenticati permette di garantire per un utente fidato
207 <dd><b>/mesgtoadm</b> - se si &egrave; autenticati permette di lasciare un messaggio all\'amministratore del sito
208 <dd><b>/listen &lt;all or auth&gt;</b> - se si &egrave; autenticati permette leggere solo i messaggi degli altri autenticati (auth) o di tutti (all)
209 </dl>
210 </div>
211 ');
212
213 //  
214 $G_room_passwdhowto = array( 'it' => '<br><h2>Come registrarsi su Brisk</h2>
215 <div style=\\"text-align: left; padding: 8px;\\">
216 Attualmente ci sono due metodi per ottenere una password sul sito:<br><br>
217 <dir>
218 <li><b>Facendosi garantire da un utente di Brisk che gi&agrave; possidede una password</b><br><br>
219 <li><b>Auto-garantendosi utilizzando uno dei seguenti sistemi di identificazione digitale:</b><br><br>
220 <dir>
221 <li>Carta Regionale dei Servizi della Lombardia (la tessera sanitaria)
222 <li>Carta Regionale dei Servizi del Friuli Venezia Giulia (la tessera sanitaria)
223 <li>Smart card di InfoCamere
224 </dir>
225 <br>
226 <b>Per auto-garantisi occorre possedere:</b><br><br>
227 <dir>
228 <li>il codice PIN della propria carta
229 <li>il lettore di smart-card per collegare la carta al PC (acquistabile di solito presso le edicole)
230 </dir>
231 <br>
232 <b>Per effettuare la registrazione collegarsi al sito:</b><br><br>
233 <dl>
234 <dd><a class=\\"flat\\"  target=\\"_blank\\" href=\\"https://brisk.mine.nu\\">https://brisk.mine.nu</a>
235 </dl>
236 <br><br>
237 Se sei in possesso di una carta che permette l\'identificazione via internet che non è nell\'elenco qui sopra
238 <a class=\\"flat\\" href=\\"mailto:authadmbrisk@alternativeoutput.it\\">fai una segnalazione</a>.
239
240 </dir>
241 </div>
242 ',
243                              'en' => '<br><h2>EN Come registrarsi su Brisk</h2>
244 <div style=\\"text-align: left; padding: 8px;\\">
245 EN Attualmente ci sono due metodi per ottenere una password sul sito:<br><br>
246 <dir>
247 <li><b>Facendosi garantire da un utente di Brisk che gi&agrave; possidede una password</b><br><br>
248 <li><b>Auto-garantendosi utilizzando uno dei seguenti sistemi di identificazione digitale:</b><br><br>
249 <dir>
250 <li>Carta Regionale dei Servizi della Lombardia (la tessera sanitaria)
251 <li>Carta Regionale dei Servizi del Friuli Venezia Giulia (la tessera sanitaria)
252 </dir>
253 <br>
254 <b>Per auto-garantisi occorre possedere:</b><br><br>
255 <dir>
256 <li>il codice PIN della propria carta
257 <li>il lettore di smart-card per collegare la carta al PC (acquistabile di solito presso le edicole)
258 </dir>
259 <br>
260 <b>Per effettuare la registrazione collegarsi al sito:</b><br><br>
261 <dl>
262 <dd><a class=\\"flat\\"  target=\\"_blank\\" href=\\"https://brisk.mine.nu\\">https://brisk.mine.nu</a>
263 </dl>
264 <br><br>
265 Se sei in possesso di una carta che permette l\'identificazione via internet che non è nell\'elenco qui sopra
266 <a class=\\"flat\\" href=\\"mailto:authadmbrisk@alternativeoutput.it\\">fai una segnalazione</a>.
267
268 </dir>
269 </div>
270 ' );
271 /*
272 <dd>Seguendo la procedura di auto-garanzia all\'url: <a href="https://brisk.mine.nu">https://brisk.mine.nu</a>
273 ';
274 */
275
276 $G_room_about = array( 'it' => '<br>
277 <div id=\\"header\\" class=\\"header\\">
278   <img class=\\"nobo\\" src=\\"img/brisk_logo64.png\\">
279   briscola chiamata in salsa ajax
280 </div>
281 <br><b>version '.$G_brisk_version.'</b><br><br>
282 Copyright 2006-2012 <a href=\\"mailto:brisk@alternativeoutput.it\\">Matteo Nastasi</a> (aka mop)<br><br>',
283                       'en' => '<br>
284 <div id=\\"header\\" class=\\"header\\">
285   <img class=\\"nobo\\" src=\\"img/brisk_logo64.png\\">
286   declaration briscola in ajax sauce <b>(Beta)</b>
287 </div>
288 <br><b>version '.$G_brisk_version.'</b><br><br>
289 Copyright 2006-2012 <a href=\\"mailto:brisk@alternativeoutput.it\\">Matteo Nastasi</a> (aka mop)<br><br>');
290
291 function mop_flush()
292 {
293     for ($i = 0; $i < ob_get_level(); $i++)
294         ob_end_flush();
295     ob_implicit_flush(1);
296     flush();
297 }
298
299 function force_no_cache(&$header_out)
300 {
301     $header_out['Pragma'] = 'no-cache, must-revalidate';
302     $header_out['Cache-Control'] = 'no-cache';
303     $header_out['Expires'] = '-1';
304 }
305
306 function file_lock($fname, $is_exclusive)
307 {
308     if (($res = @fopen($fname, "r+")) == FALSE) {
309         return (FALSE);
310     }
311         
312     if (flock($res, ($is_exclusive ? LOCK_EX : LOCK_SH)) == FALSE) {
313         fclose($res);
314         return (FALSE);
315     }
316
317     return ($res);
318 }
319
320 function file_unlock($res)
321 {
322     if ($res != FALSE) {
323         flock($res, LOCK_UN);
324         fclose($res);
325     }
326 }
327
328 function webservers_exceeded()
329 {
330     return(file_exists(PROXY_PATH."/webservers_exceded.flag"));
331 }
332
333 function webservers_check()
334 {
335     GLOBAL $G_webserver_max;
336
337     /* FIXME: check all procs expirations */
338     return (10);
339
340     $ct = 0;
341
342     $dh = opendir('/proc');
343     while (($file = readdir($dh)) !== false) {
344         if (preg_match('/[0-9]+/', $file)) {
345             $cmdline = explode("\0", file_get_contents('/proc/'.$file.'/cmdline'));
346             // echo "xxx".$cmdline[0].$n;
347             if (strstr('/usr/sbin/apache2', $cmdline[0]) != FALSE) {
348                 // echo "yyy".$cmdline[0].$n;
349                 $ct++;
350             }
351         }
352     }
353     closedir($dh);
354
355     if ($ct >= $G_webserver_max) {
356         touch(PROXY_PATH."/webservers_exceded.flag");
357     }
358     else {
359         unlink(PROXY_PATH."/webservers_exceded.flag");
360     }
361     return ($ct);
362 }
363
364 $escpush_from = array("\\", "\"");
365 $escpush_to   = array("\\\\", "\\\"");
366 function escpush($s)
367 {
368     GLOBAL $escpush_from, $escpush_to;
369
370     return str_replace($escpush_from, $escpush_to, $s);
371 }
372
373 $escinp_from = array( "\""     );
374 $escinp_to = array(   "&quot;" );
375
376 function escinput($s)
377 {
378     GLOBAL $escinp_from, $escinp_to;
379     
380     return str_replace($escinp_from, $escinp_to, $s);
381 }
382
383 function eschtml($s)
384 {
385     return htmlentities($s);
386 }
387
388 function esclfhtml($s)
389 {
390     return str_replace("\n", "<br>\n", htmlentities($s));
391 }
392
393
394 function langtolng($lang)
395 {
396   GLOBAL $G_lang;
397
398   return ($G_lang == 'en' ? '-en' : '');
399 }
400
401 function csplitter($in, $sep)
402 {
403   $st = 0;
404   $id = 0;
405   $out = array();
406   $out[$id] = "";
407   for ($i = 0 ; $i < strlen($in) ; $i++) {
408     $ini = substr($in, $i, 1);
409     if ($st == 0) {
410       if ($ini == '\\')
411         $st = 1;
412       else if ($ini == $sep) {
413         $id++;
414         $out[$id] = "";
415       }
416       else {
417         $out[$id] .= $ini;
418       }
419     }
420     else if ($st == 1) {
421       $out[$id] .= $ini;
422       $st = 0;
423     }
424   }
425
426   return ($out);
427 }
428
429 function xcape($s)
430 {
431   $from = array (   '\\',     '@',        '|' );
432   $to   = array ( '\\\\', '&#64;', '&brvbar;' );
433
434   return (str_replace($from, $to, htmlentities($s,ENT_COMPAT,"UTF-8")));
435 }
436
437 function xcapelt($s)
438 {
439   $from = array (   '\\',     '|',  "\t",  "\n");
440   $to   = array ( '\\\\',   '\\|', "\\t", "\\n");
441
442   return (str_replace($from, $to, $s));
443 }
444
445 function xcapemesg($s)
446 {
447   $from = array (  "\n");
448   $to   = array ( "\\n");
449
450   return (str_replace($from, $to, $s));
451 }
452
453
454 class Vect {
455     function Vect($a)
456     {
457         $this->el = $a;
458     }
459     
460     function getbyid($idx)
461     {
462         return ($this->el[$idx]);
463     }
464     
465     function setbyid($idx, $v)
466     {
467         $this->el[$idx] = $v;
468     }
469 }
470
471 class Table {
472   var $idx;
473   var $player;
474   var $player_n;
475
476   var $auth_only;     // se tavolo riservato o libero
477
478   var $wag_own;
479   var $wag_com;
480   var $wag_tout;
481
482   var $table_token;
483   var $table_start;   // information field
484
485   var $wakeup_time;
486
487   function Table() 
488   {
489   }
490   
491   function create($idx) 
492   {
493     if (($thiz = new Table()) == FALSE)
494       return (FALSE);
495
496     $thiz->idx       =   $idx;
497     $thiz->player    =   array();
498     $thiz->player_n  =   0;
499     $thiz->auth_only =   FALSE;
500
501     $thiz->wag_own   =  -1;
502     $thiz->wag_com   =  "";
503     $thiz->wag_tout   =  0;
504
505     $thiz->table_token  = "";
506     $thiz->table_start  = 0;
507     
508     $thiz->wakeup_time = 0;
509
510     return ($thiz);
511   }
512
513   function copy($from)
514   {
515     $this->idx = $from->idx;
516     $this->player = array();
517     for ($i = 0 ; $i < $from->player_n ; $i++)
518       $this->player[$i] = $from->player[$i];
519     $this->player_n = $from->player_n;
520
521     log_main("PLAYER_N - parent::copy.".$this->player_n);
522     
523     $this->auth_only =  $from->auth_only;
524
525     $this->wag_own   =  $from->wag_own;
526     $this->wag_com   =  $from->wag_com;
527     $this->wag_tout  =  $from->wag_tout;
528
529     $this->table_token  = $from->table_token;
530     $this->table_start  = $from->table_start;
531
532     $this->wakeup_time = $from->wakeup_time;
533   }
534
535   function myclone($from)
536   {
537     if (($thiz = new Table()) == FALSE)
538       return (FALSE);
539
540     $this->copy($from);
541
542     return ($thiz);
543   }
544   
545   function spawn($from)
546   {
547     if (($thiz = new Table()) == FALSE)
548       return (FALSE);
549     
550     $thiz->idx = $from->idx;
551     $thiz->player = array();
552     for ($i = 0 ; $i < $from->player_n ; $i++)
553       $thiz->player[$i] = $i;
554     $thiz->player_n = $from->player_n;
555
556     $thiz->auth_only =  $from->auth_only;
557
558     $thiz->wag_own = $from->wag_own;
559     $thiz->wag_com = $from->wag_com;
560     $thiz->wag_tout  =  $from->wag_tout;
561
562     $thiz->table_token  = $from->table_token;
563     $thiz->table_start  = $from->table_start;
564
565     $thiz->wakeup_time = $from->wakeup_time;
566
567     return ($thiz);
568   }
569
570   function wag_set($user_idx, $mesg)
571   {
572     log_main("WAG_SET");
573
574     $this->wag_own  =  $user_idx;
575     $this->wag_com  =  $mesg;
576     $this->wag_tout =  0;
577   }
578
579   function wag_reset($timeout)
580   {
581     log_main("WAG_RESET");
582
583     unset($this->wag_own);
584     $this->wag_own  = -1;
585     $this->wag_com  = "";
586     $this->wag_tout = $timeout;
587   }
588
589   function player_get($idx)
590   {
591     return ($this->player[$idx]);
592   }
593
594   function player_set($idx, $player)
595   {
596     $this->player[$idx] = $player;
597   }
598
599   function user_add($idx)
600   {
601     $this->player[$this->player_n] = $idx;
602     $this->player_n++;
603     
604     return ($this->player_n - 1);
605   }
606   
607   function user_rem($room, $user)
608   {
609     $tabpos = $user->table_pos;
610     
611     /* verifico la consistenza dei dati */
612     if ($room->user[$this->player[$tabpos]] == $user) {
613       
614       /* aggiorna l'array dei giocatori al tavolo. */
615       for ($i = $tabpos ; $i < $this->player_n-1 ; $i++) {
616         $this->player[$i] = $this->player[$i+1];
617         $user_cur = $room->user[$this->player[$i]];
618         $user_cur->table_pos = $i;
619       }
620       $this->player_n--;
621     }
622     else {
623       log_main("INCONSISTENCY ON TABLE.");
624     }
625   }
626
627
628
629   //      $ret .= table_act_content(($user->subst == 'standup'), $this->table[$i]->player_n, $i, $user->table, 
630   //                              ($this->table[$i]->auth_only == FALSE ? TRUE : $user->flags & USER_FLAG_AUTH));
631
632   // function act_content($isstanding, $sitted, $table, $cur_table, $allowed)
633   function act_content($user)
634   {
635     $ret = "";
636     $isstanding = ($user->subst == 'standup');
637     $sitted = $this->player_n;
638     $table = $this->idx;
639     $cur_table = $user->table;
640     $allowed = TRUE;
641
642     if ($isstanding) {
643       if ($sitted < PLAYERS_N) {
644         if ($this->auth_only) {
645           if ($user->flags & USER_FLAG_AUTH) 
646             $act = "sitreser";
647           else
648             $act = 'reserved';
649         }
650         else {
651           $act = 'sit';
652         }
653       }
654       else {
655         $act = 'none';
656       }
657     }
658     else {
659       if ($table == $cur_table)
660         $act = 'wake';
661       else
662         $act = 'none';
663     }
664     
665     if ($act != '')
666       $ret = sprintf('j_tab_act_cont(%d, \'%s\');', $table, $act);
667     
668     return ($ret);
669   }
670 } // end class Table
671
672
673
674
675 class Room
676 {
677     static $delta_t;
678     
679     var $crystal_filename;
680     var $user;
681     var $table;
682     var $match;
683     var $comm; // commands for many people
684     var $step; // current step of the comm array
685     var $garbage_timeout;
686     var $shm_sz;
687     
688     function Room ($crystal_filename) {
689         $this->crystal_filename = $crystal_filename;
690         $this->user  = array();
691         $this->table = array();
692         $this->match = array();
693         
694         for ($i = 0 ; $i < MAX_PLAYERS ; $i++) {
695             $this->user[$i] = User::create($this, $i, "", "");
696         }
697         
698         for ($i = 0 ; $i < TABLES_N ; $i++) {
699             $this->table[$i] = Table::create($i);
700             /* OLD METHOD
701                if ($i < 12) {
702                $row = ( (((int)($i / 4)) % 2) == 0 );
703                $col = ($i % 2 == 0);
704                $this->table[$i]->auth_only = (($row && $col) || (!$row && !$col));
705                }
706                else {
707                $this->table[$i]->auth_only = FALSE;
708                }
709             */
710             if ($i < TABLES_AUTH_N) 
711                 $this->table[$i]->auth_only = TRUE;
712             else
713                 $this->table[$i]->auth_only = FALSE;
714         }
715         $this->garbage_timeout = 0;
716         $this->shm_sz = SHM_DIMS_MIN;
717     }
718
719   function garbage_manager($force)
720   {
721     GLOBAL $G_lang, $mlang_brisk, $G_base;
722
723     $ismod = FALSE;
724
725     log_rd2("garbage_manager START");
726
727     /* Garbage collector degli utenti in timeout */
728     $curtime = time();
729
730     if (!$force && !($this->garbage_timeout < $curtime)) {
731         return ($ismod);
732     }
733       
734     webservers_check();
735     
736     // Before all align times with table timeout
737     for ($table_idx = 0 ; $table_idx < TABLES_N ; $table_idx++) {
738         $table_cur = $this->table[$table_idx];
739         // if the table is complete and exists its shared mem we get the info about users lacc
740         
741         if ($table_cur->player_n == PLAYERS_N) {
742             log_main("PLAYERS == N TABLE ".$table_idx);
743             
744             
745             $no_recovery = FALSE;
746             if (isset($this->match[$table_idx])) {
747                 $bri = $this->match[$table_idx];
748
749                 if ($table_cur->table_token != $bri->table_token) {
750                     log_main("ERROR: not matching table_token. Room: ".$table_cur->table_token."  Table: ".$bri->table_token);
751                     log_main("ERROR: not matching table_start. Room: ".$table_cur->table_start."  Table: ".$bri->table_start);
752                     $no_recovery = TRUE;
753                     $bri = FALSE;
754                 }
755
756
757                 if ($bri != FALSE) {
758                     //
759                     //  SPAWN: JOIN
760                     //
761                     log_main("garbage_manager: bri loaded successfully.");
762                     $bri->garbage_manager(TRUE);
763                     
764                     $bri_table = $bri->table[0];
765                     
766                     // is the end of the table
767                     
768                     if ($bri->the_end == TRUE) {
769                         /*
770                          *  DESTROY OF FINISHED TABLE && MOVE PLAYER TO ROOM AGAIN
771                          */
772                         log_main("garbage_manager: INSIDE THE END.");
773                         
774                         $plist = "$table_cur->table_token|$table_cur->idx|$table_cur->player_n";
775                         for ($i = 0 ; $i < $table_cur->player_n ; $i++) {
776                             $plist .= '|'.$this->user[$table_cur->player[$i]]->sess;
777                         }
778                         
779                         for ($i = 0 ; $i < $bri_table->player_n ; $i++) {
780                             // stat must be "table" by definition
781                             $user_cur = $this->user[$table_cur->player[$i]];
782                             $bri_user = $bri->user[$i];
783                             
784                             $user_cur->subst      = $bri_user->subst;
785                             $user_cur->step       = $bri_user->step;
786                             $user_cur->lacc       = $bri_user->lacc;
787                             $user_cur->laccwr     = $bri_user->lacc;
788                             $user_cur->bantime    = $bri_user->bantime;
789                         }
790                         
791                         log_legal($curtime, 'xxx', $user_cur, "STAT:DESTROY_GAME", $plist);
792                         
793                         $this->room_join_wakeup($user_cur, FALSE, 0); 
794                         $table_cur->table_token = "";
795                         $table_cur->wakeup_time = $curtime + WAKEUP_TIME;
796                         
797                         $this->match_del($table_idx);
798                     }
799                     else {
800                         log_main("gm:: save_data");
801                         
802                         for ($i = 0 ; $i < $bri_table->player_n ; $i++) {
803                             $this->user[$table_cur->player[$i]]->lacc = $bri->user[$i]->lacc;
804                         }
805                     }
806                 } // if ($bri == FALSE
807                 else if ($no_recovery == FALSE) {
808                     log_crit("ERROR: table ".$table_idx." unrecoverable join");
809                     
810                     for ($i = 0 ; $i < $table_cur->player_n ; $i++) {
811                         $user_cur = $this->user[$table_cur->player[$i]];
812                         $user_cur->subst = "shutdowner";
813                         $user_cur->step_inc();
814                         
815                         $ret = sprintf('stat = "%s"; subst = "%s";',  $user_cur->stat, $user_cur->subst);
816                         $ret .= "gst.st = ".($user_cur->step+1)."; ";
817                         // MLANG <br>I dati del tavolo n&deg; ".$user_cur->table." sono inconsistenti, verranno resettati.<br><br>Torni in piedi.<br><br>
818                         $prestr = sprintf($mlang_brisk['tabincon'][$G_lang], $user_cur->table);
819                         $ret .= show_notify($prestr, 2000, $mlang_brisk['btn_close'][$G_lang], 400, 110);
820                         $user_cur->comm[$user_cur->step % COMM_N] = $ret;
821                         $user_cur->step_inc();
822                     }
823                     
824                     $plist = "$table_cur->table_token|$user_cur->table|$table_cur->player_n";
825                     for ($i = 0 ; $i < $table_cur->player_n ; $i++) {
826                         $plist .= '|'.$this->user[$table_cur->player[$i]]->sess;
827                     }
828                     log_legal($curtime, 'xxx', $user_cur, "STAT:DESTROY_GAME(RECOVERY)", $plist);
829                     
830                     $this->room_join_wakeup($user_cur, TRUE, -2); 
831                     $table_cur->table_token = "";
832                 }
833             }
834         } //  if ($table_cur->player_n == PLAYERS_N) {
835     } //  for ($table_idx = 0 ; $table_idx < TABLES_N ; $table_idx++) {
836     
837     log_rd2("out new loop.");
838     
839     for ($i = 0 ; $i < MAX_PLAYERS ; $i++) {
840         $user_cur = $this->user[$i];
841         
842         log_rd2("User: ".$user_cur->name."  stat: ".$user_cur->stat."  subst: ".$user_cur->subst);
843         
844         if ($user_cur->sess == "") 
845             continue;
846         
847         if ($user_cur->lacc + EXPIRE_TIME_RD < $curtime) {
848             // Auto logout dell'utente
849             log_rd2("AUTO LOGOUT.".($user_cur->lacc + EXPIRE_TIME_RD)." curtime ".$curtime);
850             
851             if ($user_cur->stat == 'table' || $user_cur->stat == 'room') {
852                 log_auth($user_cur->sess, "Autologout session.");
853                 
854                 $user_cur->reset();
855             
856                 log_rd2("AUTO LOGOUT.");
857                 if ($user_cur->subst == 'sitdown' || $user_cur->stat == 'table')
858                     $this->room_wakeup($user_cur);
859                 else if ($user_cur->subst == 'standup')
860                     $this->room_outstandup($user_cur);
861                 else
862                     log_rd2("LOGOUT FROM WHAT ???");
863             }
864         }
865
866         if ($user_cur->laccwr + EXPIRE_TIME_SMAMMA < $curtime) { // lo rimettiamo in piedi
867             if ($user_cur->stat == 'room' && $user_cur->subst == 'sitdown') {
868                 $this->room_wakeup($user_cur);
869                 $user_cur->comm[$user_cur->step % COMM_N] = "gst.st = ".($user_cur->step+1)."; ";
870                 /* MLANG: <br>Sei stato inattivo per ".(EXPIRE_TIME_SMAMMA/60.0)." minuti. <br><br>Quindi ritorni tra i <b>Giocatori in piedi</b>.", "torna ai tavoli" */
871                 $user_cur->comm[$user_cur->step % COMM_N] .=  show_notify($mlang_brisk['tabtout_a'][$G_lang].(EXPIRE_TIME_SMAMMA/60.0).$mlang_brisk['tabtout_b'][$G_lang], 0, $mlang_brisk['btn_backstand'][$G_lang], 400, 100);
872                 $user_cur->step_inc();
873             }
874         }
875     }
876     log_rd2("GARBAGE UPDATED!");
877     
878     $this->garbage_timeout = $curtime + GARBAGE_TIMEOUT;
879     $ismod = TRUE;
880
881     return ($ismod);
882   }
883
884   function show_room($user_step, $user)
885   {
886     GLOBAL $G_lang, $mlang_brisk;
887     log_main("show_room: username: ".$user->name);
888     
889     $ret = sprintf('gst.st = %d; ',  $user_step);
890
891     if ($user->flags & USER_FLAG_ISOLAUTH) {
892       $ret .= 'list_set(\'isolation\', false, \''.$mlang_brisk['tit_onisol'][$G_lang].'\' ); ';
893     }
894     else if ($user->flags & USER_FLAG_LISTAUTH) {
895       $ret .= 'list_set(\'auth\', false, \''.$mlang_brisk['tit_onauth'][$G_lang].'\' ); ';
896     }
897     else {
898       $ret .= 'list_set(\'all\', false, \'\' ); ';
899     }
900
901     if ($user->subst == 'standup')
902       $ret .= "tra.show(); ";
903     else
904       $ret .= "tra.hide(); ";
905
906     $ret .= sprintf('stat = "%s";',  $user->stat);
907     
908     $ret .= root_wellcome($user);
909     if ($user->flags & USER_FLAG_DBFAILED) {
910         $ret .= "gst.st = ".($user->step+1)."; ";
911         $ret .= show_notify($mlang_brisk['db_failed'][$G_lang], 0, $mlang_brisk['btn_close'][$G_lang], 400, 140);
912     }
913
914     $ret .= sprintf('subst = "%s";', $user->subst);
915     $ret .= $user->myname_innerHTML();
916
917     for ($i = 0 ; $i < TABLES_N ; $i++) {
918
919       $ret .= $this->table_content($user, $i);
920       // $ret .= table_act_content(($user->subst == 'standup'), $this->table[$i]->player_n, $i, $user->table, 
921       //                          ($this->table[$i]->auth_only == FALSE ? TRUE : $user->flags & USER_FLAG_AUTH));
922       $ret .=  $this->table[$i]->act_content($user);
923       if ($this->table[$i]->wag_own != -1) 
924         $ret .= sprintf('tra.add(%d, "%s: %s"); ', $i,  $this->user[$this->table[$i]->wag_own]->name, $this->table[$i]->wag_com);
925       else 
926         $ret .= sprintf('tra.rem(%d); ', $i);
927     }
928     $ret .= $this->standup_content($user);
929     $ret .= "setTimeout(preload_images, 0, g_preload_img_arr, g_imgct); ";
930
931     return ($ret);
932   }
933   
934
935   function room_wakeup($user)
936   {
937     $table_idx = $user->table;
938     $table = $this->table[$table_idx];
939
940     log_main("WAKEUP: begin function table:".$table_idx."  stat: ".$user->stat."  subst: ".$user->subst);
941
942     $curtime = time();
943
944     $from_table = ($user->stat == "table");
945     if ($from_table) {
946       log_main("WAKEUP: from table [".$user->table."] nplayers_n: ".$this->table[$user->table]->player_n);
947
948       for ($i = 0 ; $i < $table->player_n ; $i++) {
949         $user_cur = $this->user[$table->player[$i]];
950         log_main("PREIMPOST: INLOOP name: ".$user_cur->name);
951
952         if ($user->idx_get() != $table->player[$i]) {
953           $user_cur->stat_set("room");
954           $user_cur->subst = "sitdown";
955           $user_cur->laccwr = $curtime;
956         }
957         else if ($user->sess != "") {
958           $user_cur->stat_set("room");
959           $user_cur->subst = "standup";
960           $user_cur->laccwr = $curtime;
961           $user_cur->table = -1;
962         }
963       }
964     }
965     else {
966       $user->stat_set("room");
967       $user->subst = "standup";
968       $user->laccwr = $curtime;
969     }
970     
971     $remove_wagon = FALSE;
972     if($table->wag_own == $user->idx_get()) {
973       $table->wag_reset($curtime);
974       $remove_wagon = TRUE;
975     }
976     
977
978     /* aggiorna l'array dei giocatori al tavolo. */
979     $table->user_rem($this, $user);
980
981     for ($i = 0 ; $i < MAX_PLAYERS ; $i++) {
982       $user_cur = $this->user[$i];
983       if ($user_cur->sess == '' || $user_cur->stat != 'room')
984         continue;
985       
986       // log_main("VALORI: name: ".$user_cur->name."from_table: ".$from_table."  tab: ".$user_cur->table." taix: ".$table_idx."  ucur: ".$user_cur."  us: ".$user);
987
988       $ret = "gst.st = ".($user_cur->step+1)."; ".($remove_wagon ? sprintf("tra.rem(%d);",$table_idx) : "");
989       if ($from_table && ($user_cur->table == $table_idx || $user->idx_get() == $i)) {
990         $ret .= 'gst.st_loc++; xstm.stop(); window.onunload = null; window.onbeforeunload = null; document.location.assign("index.php");|';
991         // $ret .= 'gst.st_loc++; document.location.assign("index.php");|';
992         log_main("DOCUMENT.index.php: from table");
993       }
994       else if ($user_cur->stat == "room") {
995         log_main("DOCUMENT.index.php: from table");
996
997         $ret .= $this->table_content($user_cur, $table_idx);
998         $ret .= $this->standup_content($user_cur);
999         
1000         // $ret .= table_act_content(FALSE, 0, $table_idx, $user->table, FALSE);
1001         $ret .= $table->act_content($user);
1002
1003         if ($user->idx_get() == $i) {
1004           // set the new status 
1005           $ret .=  'subst = "standup"; tra.show(); ';
1006           // clean the action buttons in other tables
1007           for ($e = 0 ; $e < TABLES_N ; $e++) {
1008             if ($this->table[$e]->player_n < PLAYERS_N) {
1009               // $ret .= table_act_content(TRUE, 0, $e, $user->table, 
1010               //                           ($this->table[$e]->auth_only == FALSE ? TRUE : $user->flags & USER_FLAG_AUTH));
1011               $ret .= $this->table[$e]->act_content($user);
1012             }
1013           }
1014         }
1015         else {
1016           // $ret .= table_act_content(($user_cur->subst == 'standup'), $table->player_n, $table_idx, $user_cur->table,
1017           //                           ($table->auth_only == FALSE ? TRUE : $user_cur->flags & USER_FLAG_AUTH));
1018           $ret .= $table->act_content($user_cur);
1019         }
1020       }
1021       log_wr("ROOM_WAKEUP: ".$ret);
1022       $user_cur->comm[$user_cur->step % COMM_N] = $ret;
1023       $user_cur->step_inc();
1024     }
1025   }
1026
1027   function room_join_wakeup($user, $update_lacc = FALSE, $trans_delta)
1028   {
1029     $table_idx = $user->table;
1030     $table = $this->table[$table_idx];
1031     
1032     log_main("JOIN_WAKEUP: begin function table:".$table_idx."  stat: ".$user->stat."  subst: ".$user->subst);
1033
1034     $curtime = time();
1035     $user_wup = array();
1036     $user_wup_n = 0;
1037     $user_tab = array();
1038     $user_tab_n = 0;
1039     log_main("JOIN WAKEUP: from table [".$user->table."] nplayers_n: ".$this->table[$user->table]->player_n);
1040     
1041     for ($i = 0 ; $i < $table->player_n ; $i++) {
1042       $user_cur = $this->user[$table->player[$i]];
1043       log_main("PREIMPOST INLOOP name: ".$user_cur->name);
1044       if ($user_cur->sess != "") {
1045         if ($update_lacc == TRUE) {
1046           $user_cur->laccwr = $curtime;
1047         }
1048         log_main("cur: ".$user_cur->name."  subst: ".$user_cur->subst);
1049         if ($user_cur->subst == "shutdowned") {
1050           $user_cur->stat_set("room");
1051           $user_cur->subst = "sitdown";
1052         }
1053         else if ($user_cur->subst == "shutdowner") {
1054           $user_cur->stat_set("room");
1055           $user_cur->subst = "standup";
1056           $user_cur->table = -1;
1057           $user_wup[$user_wup_n++] = $user_cur;
1058           
1059           $remove_wagon = FALSE;
1060           if($table->wag_own == $table->player[$i]) {
1061             $remove_wagon = TRUE;
1062             $table->wag_reset($curtime);
1063           }
1064         }
1065         $user_tab[$user_tab_n++] = $table->player[$i];
1066       }
1067     }
1068
1069     for ($wup_idx = 0 ; $wup_idx < $user_wup_n  ; $wup_idx++)
1070       $table->user_rem($this, $user_wup[$wup_idx]);
1071
1072     /* aggiorna l'array dei giocatori al tavolo. */
1073
1074     for ($i = 0 ; $i < MAX_PLAYERS ; $i++) {
1075       log_main("START LOOP");
1076       $user_cur = $this->user[$i];
1077       if ($user_cur->sess == '' || $user_cur->stat != 'room') {
1078         log_main("name: ".$user_cur->name."skip   subst: ".$user_cur->subst);
1079         continue;
1080       }
1081
1082       log_main("___");
1083       log_main("VALORI name: ".$user_cur->name."  tab: ".$user_cur->table." taix: ".$table_idx);
1084
1085       $ret = "gst.st = ".($user_cur->step+1)."; ".($remove_wagon ? sprintf("tra.rem(%d);",$table_idx) : "");
1086       if ($user_cur->stat == "room") {
1087         log_main("DOCUMENT.index.php from table");
1088
1089         $ret .= $this->table_content($user_cur, $table_idx);
1090         $ret .= $this->standup_content($user_cur);
1091         
1092         // $ret .= table_act_content(FALSE, 0, $table_idx, $user_cur->table,
1093         //                           ($table->auth_only == FALSE ? TRUE : $user_cur->flags & USER_FLAG_AUTH));
1094         $ret .= $table->act_content($user_cur);
1095
1096
1097         for ($tab_idx = 0 ; $tab_idx < $user_tab_n  ; $tab_idx++)
1098             if ($user_tab[$tab_idx] == $i) 
1099                 break;
1100
1101         // for users that wakeup the room will be reconstructed by index_rd.php
1102         if ($tab_idx < $user_tab_n) {
1103           log_main("PRE show_room username: ".$user_cur->name."  STEP: ".$user_cur->step);
1104
1105 //        ARRAY_POP DISABLED
1106 //        if ($trans_delta == 0)
1107 //          while (array_pop($user_cur->comm) != NULL);
1108
1109           $user_cur->trans_step = $user_cur->step + 1 + $trans_delta;
1110           $user_cur->comm[$user_cur->step % COMM_N] = "";
1111           $user_cur->step_inc();
1112           $user_cur->comm[$user_cur->step % COMM_N] = $this->show_room(($user_cur->step + 1), $user_cur);
1113           $user_cur->step_inc();
1114           log_main("POST show_room username: ".$user_cur->name."  STEP: ".$user_cur->step);
1115
1116           continue;
1117         }
1118         log_main("JOIN_WAKEUP wup_idx ".$wup_idx."  wup_n ".$user_wup_n);
1119
1120         log_main("JOIN_WAKEUP more");
1121         // $ret .= table_act_content(($user_cur->subst == 'standup'), $table->player_n, $table_idx, $user_cur->table,
1122         //                           ($table->auth_only == FALSE ? TRUE : $user_cur->flags & USER_FLAG_AUTH));
1123         $ret .= $table->act_content($user_cur);
1124
1125         log_main("JOIN_WAKEUP end more");
1126       }
1127       log_wr("ROOM_JOIN_WAKEUP: ".$ret);
1128       $user_cur->comm[$user_cur->step % COMM_N] = $ret;
1129       $user_cur->step_inc();
1130     }
1131   }
1132
1133   function room_outstandup($user)
1134   {
1135     $this->room_sitdown($user, -1);
1136   }
1137   
1138   function table_update($user)
1139   {
1140     log_main("table_update: pre - USER: ".$user->name);
1141
1142     $table_idx = $user->table;
1143
1144     if ($table_idx > -1) 
1145       $table = $this->table[$table_idx];
1146     
1147     for ($i = 0 ; $i < MAX_PLAYERS ; $i++) {
1148       $ret = "";
1149       $user_cur = $this->user[$i];
1150       if ($user_cur->sess == '' || $user_cur->stat != 'room')
1151       continue;
1152       
1153       $ret = "gst.st = ".($user_cur->step+1)."; ";
1154       if ($table_idx > -1)
1155         $ret .= $this->table_content($user_cur, $table_idx);
1156       
1157       if ($user->idx_get() == $i) {
1158           $ret .= $user->myname_innerHTML();
1159       }
1160       $user_cur->comm[$user_cur->step % COMM_N] = $ret;
1161       $user_cur->step_inc();
1162     }
1163
1164     log_main("table_update: post");
1165   }
1166
1167   function room_sitdown($user, $table_idx)
1168   {
1169     log_main("room_sitdown ".($user == FALSE ? "USER: FALSE" : "USER: ".$user->name));
1170
1171     $train_app = "";
1172
1173     if ($table_idx > -1 && $table_idx < TABLES_N) { 
1174       $table = $this->table[$table_idx];
1175
1176       // wagon shutdown 
1177       if ($table->wag_own != -1 && $table->player_n == PLAYERS_N) {        
1178         for ($i = 0 ; $i < TABLES_N ; $i++) {
1179             if ($table->wag_own == $table->player[$i]) {
1180                 $train_app = sprintf("tra.rem(%d); ", $table_idx); 
1181                 $table->wag_reset(time());
1182                 break;
1183             }
1184         }
1185       }
1186     }
1187
1188     for ($i = 0 ; $i < MAX_PLAYERS ; $i++) {
1189       $ret = "";
1190       $user_cur = $this->user[$i];
1191       if ($user_cur->sess == '' || $user_cur->stat != 'room')
1192       continue;
1193       
1194       $ret = "gst.st = ".($user_cur->step+1)."; ".$train_app;
1195       if ($table_idx > -1)
1196       $ret .= $this->table_content($user_cur, $table_idx);
1197       $ret .= $this->standup_content($user_cur);
1198       
1199       if ($user->idx_get() == $i) {
1200         $ret .=  'subst = "sitdown"; tra.hide(); ';
1201         // clean the action buttons in other tables
1202         for ($e = 0 ; $e < TABLES_N ; $e++) {
1203           // $ret .= table_act_content(FALSE, 0, $e, $user_cur->table, FALSE);
1204           $ret .= $this->table[$e]->act_content($user_cur);
1205         }
1206       }
1207       else if ($table_idx > -1) {
1208         if ($table->player_n == PLAYERS_N) {
1209           // $ret .= table_act_content(($user_cur->subst == 'standup'), PLAYERS_N, $table_idx, $user_cur->table,
1210           ///                      ($table->auth_only == FALSE ? TRUE : $user_cur->flags & USER_FLAG_AUTH));
1211           $ret .= $table->act_content($user_cur);
1212         }
1213       }
1214       $user_cur->comm[$user_cur->step % COMM_N] = $ret;
1215       $user_cur->step_inc();
1216     }
1217   }
1218
1219   function chatt_send($user, $mesg)
1220   {
1221     GLOBAL $G_base, $G_alarm_passwd, $mlang_brisk, $G_lang;
1222     $only_you = FALSE;
1223     
1224     // common settings
1225     $msg = mb_substr($mesg, 6, 128, "UTF-8");
1226     $curtime = time();
1227     $dt = date("H:i ", $curtime);
1228     $target = "";
1229
1230     //
1231     //  Compute actions
1232     //
1233
1234     $to_user     = FALSE;
1235     $to_all      = FALSE;
1236     $to_room     = FALSE;
1237     $to_tabl     = FALSE;
1238     $is_normchat = FALSE;
1239     /* for old isolation management $is_ticker   = FALSE; */
1240     $update_room = FALSE;
1241
1242     if (strcmp($msg,  "/tav") == 0 || 
1243         strncmp($msg, "/tav ", 5) == 0) {
1244       do {
1245         if ($user->stat != 'room' || $user->subst != 'sitdown') {
1246           /* MLANG: "<br>Per attivare il messaggio di segnalazione del tavolo occorre essere seduti.<br><br>", "<br>Il messaggio di segnalazione del tavolo &egrave; gi&agrave; attivato.<br><br>", "<br>Il messaggio di segnalazione del tavolo<br>&egrave; disattivato ancora per %d second%s.<br><br>" */
1247           $msg = $mlang_brisk['tickmust'][$G_lang];
1248           $to_user = show_notify($msg, 0, "chiudi", 400, 100);
1249
1250           break;
1251         }
1252
1253         $table = $this->table[$user->table];
1254         
1255         if ($table->wag_own != -1) {
1256           // MLANG <br>Il messaggio di segnalazione del tavolo &egrave; gi&agrave; attivato.<br><br> 
1257           $msg = $mlang_brisk['tickjust'][$G_lang];
1258           $to_user = show_notify($msg, 0, "chiudi", 400, 100);
1259
1260           break;
1261         }
1262
1263         $dtime = $curtime - $table->wag_tout;
1264         if ($dtime  < EXPIRE_TIME_WAG) {
1265           // MLANG - <br>Il messaggio di segnalazione del tavolo<br>&egrave; disattivato ancora per %d second%s.<br><br>
1266           $msg = sprintf($mlang_brisk['tickwait'][$G_lang],
1267                          EXPIRE_TIME_WAG - $dtime, (EXPIRE_TIME_WAG - $dtime == 1 ? ($G_lang == 'en' ? "" : "o") : ($G_lang == 'en' ? "s" : "i")));
1268           $to_user = show_notify($msg, 0, $mlang_brisk['btn_close'][$G_lang] , 400, 100);
1269
1270           break;
1271         }
1272         
1273         $msg = substr($msg, 5);
1274         
1275         $table->wag_set($user->idx_get(), $msg);
1276         $to_user = sprintf('tra.add(%d, "%s");', $user->table, xcape(sprintf("%s: %s", $user->name, $msg)));
1277         $to_room = $to_user;
1278         /* for old isolation management $is_ticker = TRUE; */
1279       } while (0);
1280     } // /tav chat command
1281
1282     else if (strncmp($msg, "/alarm ", 7) == 0) {
1283       if (strncmp($msg, "/alarm to ", 10) == 0) {
1284         $sp_pos = strpos($msg, " ", 10);
1285         $target = substr($msg, 10, $sp_pos - 10);
1286         $alarm_check = "/alarm to ".$target." ".$G_alarm_passwd." ";
1287       }
1288       else {
1289         $target = "";
1290         $alarm_check = "/alarm ".$G_alarm_passwd." ";
1291       }
1292       do {
1293         if (strncmp($msg, $alarm_check, strlen($alarm_check)) != 0) {
1294           /* MLANG: "<br>La password digitata non &egrave; corretta.<br><br>" */
1295           $msg = $mlang_brisk['alarpass'][$G_lang];
1296           $to_user = show_notify($msg, 0, $mlang_brisk['btn_close'][$G_lang], 400, 100);
1297
1298           break;
1299         }
1300
1301         /* MLANG: "Alarm <b>%s</b> inviato a <b>%s</b>." */
1302         $prestr = sprintf($mlang_brisk['alarret'][$G_lang], xcape(substr($msg, strlen($alarm_check))), 
1303                            ($target == "" ? $mlang_brisk['tit_all'][$G_lang] : xcape($target)) );
1304         $to_user = sprintf('chatt_sub("%s", [2, "%s"],%s);', 
1305                            $dt, NICKSERV, $prestr);
1306
1307         $msg = sprintf("<br><b>%s<br><br>%s</b><br><br>",
1308                        $dt.NICKSERV, xcape(substr($msg, strlen($alarm_check))));
1309         /* MLANG: "chiudi" */
1310         $to_all = show_notify($msg, 0, $mlang_brisk['btn_close'][$G_lang], 400, 120);
1311       } while (0);
1312     } // /alarm chat command
1313     else if (strncmp($msg, "/listen ", 8) == 0) {
1314       $arg = substr($msg, 8);
1315
1316       if (strcasecmp($arg, "isolation") == 0) {
1317         $flags_old = 0;
1318         if ($user->stat == 'room' && $user->subst == 'sitdown' &&
1319             $user->table >= TABLES_AUTH_N) {
1320           $to_user = sprintf('chatt_sub("%s", [2, "%s"],"%s");', $dt, NICKSERV, $mlang_brisk['listmust'][$G_lang]);
1321           
1322         }
1323         else {
1324           $user->flags &= ~USER_FLAG_MAP_AUTH;
1325           $user->flags |= USER_FLAG_ISOLAUTH;
1326           $to_user = 'list_set(\'isolation\', true, \''.$mlang_brisk['tit_onisol'][$G_lang].'\'); ';
1327         }
1328       }
1329       else if (strcasecmp($arg, "auth") == 0) {
1330         $flags_old = $user->flags;
1331         $user->flags &= ~USER_FLAG_MAP_AUTH;
1332         $user->flags |= USER_FLAG_LISTAUTH;
1333         $to_user = 'list_set(\'auth\', true, \''.$mlang_brisk['tit_onauth'][$G_lang].'\'); ';
1334       }
1335       else {
1336         $flags_old = $user->flags;
1337         $user->flags &= ~USER_FLAG_MAP_AUTH;
1338         $to_user = 'list_set(\'all\', true, \'\'); ';
1339         
1340       }
1341       // if from isolation redraw standup area
1342       if (($flags_old ^ $user->flags) & USER_FLAG_ISOLAUTH) {
1343         $to_user .= 'standup_data_old = null; '.$this->standup_content($user);
1344         
1345       }
1346     }
1347     else if (strcmp($msg, "/authreq") == 0) {
1348       if ($user->flags & USER_FLAG_AUTH) {
1349         $to_user = sprintf('authbox(300,200);');
1350       }
1351       else {
1352         /* MLANG: "<b>Per autenticare qualcuno devi a tua volta essere autenticato.</b>", "Il nickname deve contenere almeno una lettera dell\'alfabeto o una cifra.", "Nickname <b>%s</b> gi&agrave; in uso." */
1353         $to_user = sprintf('chatt_sub("%s", [2, "%s"],"%s");', $dt, NICKSERV, $mlang_brisk['authmust'][$G_lang]);
1354       }
1355     }
1356     else if (strncmp($msg, "/mesgtoadm", 8) == 0) {
1357       if ($user->flags & USER_FLAG_AUTH) {
1358         $to_user = sprintf('mesgtoadmbox(500,300);');
1359       }
1360       else {
1361         /* MLANG: "<b>Per inviare un messaggio devi essere autenticato.</b>" */
1362         $to_user = sprintf('chatt_sub("%s", [2, "%s"],"%s");', $dt, NICKSERV, $mlang_brisk['mesgmust'][$G_lang]);
1363       }
1364     }
1365     else if (strncmp($msg, "/nick ", 6) == 0) {
1366       log_main("chatt_send BEGIN");
1367
1368       do {
1369         if (($name_new = validate_name(substr($msg, 6))) == FALSE) {
1370           $to_user = sprintf('chatt_sub("%s", [2,"%s"],"%s");', $dt, NICKSERV, $mlang_brisk['nickmust'][$G_lang]);
1371           break;
1372         }
1373
1374         $msg = "COMMAND ".$msg;
1375         for ($i = 0 ; $i < MAX_PLAYERS ; $i++) {
1376           $user_cur = $this->user[$i];
1377
1378           if ($user_cur->sess == '')
1379             continue;
1380           if (strcasecmp($user_cur->name,$name_new) == 0)
1381             break;
1382           }
1383         if ($i <  MAX_PLAYERS) {
1384           $prestr = sprintf($mlang_brisk['nickdupl'][$G_lang], xcape($name_new));
1385           $to_user = sprintf('chatt_sub("%s", [2, "%s"],"%s");', $dt, NICKSERV, $prestr);
1386           break;
1387         }
1388         
1389         /* MLANG: "<b>Non puoi cambiare nick a un tavolo per soli autenticati.</b>", "Il nickname <b>\'%s\'</b> &egrave; gi&agrave; registrato, <b>se il suo proprietario si autentificher&agrave; verrai rinominato d\'ufficio come ghost<i>N</i>.</b>" */
1390         if ($user->flags & USER_FLAG_AUTH) {
1391           if (strcasecmp($user->name,$name_new) != 0) {
1392              if (( ($user->flags & USER_FLAG_MAP_AUTH) != USER_FLAG_ISOLAUTH) &&
1393                 ($user->subst == 'standup' || 
1394                  ($user->subst != 'standup' && $this->table[$user->table]->auth_only == FALSE)
1395                  )
1396                 ) {
1397               $user->flags &= ~(USER_FLAG_AUTH | USER_FLAG_TY_ALL); // Remove auth if name changed
1398               for ($i = 0 ; $i < TABLES_N ; $i++) {
1399                 $to_user .= $this->table[$i]->act_content($user);
1400               }
1401             }
1402             else {
1403               $to_user = sprintf('chatt_sub("%s", [2, "%s"],"%s");', $dt, NICKSERV, $mlang_brisk['authchan'][$G_lang]);
1404               break;
1405             }
1406           }
1407         }
1408         $user->name = $name_new; // OK - nick changed
1409         /* se nome gia' in uso, segnala cosa potrebbe capitare */
1410         if (($user->flags & USER_FLAG_AUTH) == 0) {
1411             if (($bdb = BriskDB::create()) != FALSE) {
1412                 $bdb->users_load();
1413                 /* MLANG: "Il nickname <b>\'%s\'</b> &egrave; gi&agrave; registrato, <b>se il suo proprietario si autentificher&agrave; verrai rinominato d\'ufficio come ghost<i>N</i>.</b>" */
1414                 if ($bdb->login_exists($name_new)) {
1415                     $prestr = sprintf($mlang_brisk['nickjust'][$G_lang], xcape($name_new));
1416                     $to_user .= sprintf('chatt_sub("%s", [2, "%s"],"%s");', $dt, NICKSERV, $prestr);
1417                 }
1418             }
1419         }
1420
1421         log_main("chatt_send start set");
1422
1423         $update_room = TRUE;
1424       } while (0);
1425     } // nick chat command
1426
1427     else if (strncmp($msg, "/st ", 4) == 0) {
1428       log_main("chatt_send BEGIN");
1429
1430       do {
1431         $st_str = substr($msg, 4);
1432         
1433         if (strcasecmp($st_str, "normale") == 0) {
1434           $st = USER_FLAG_S_NORM;
1435         }
1436         else if (strcasecmp($st_str, "pausa") == 0) {
1437           $st = USER_FLAG_S_PAU;
1438         }
1439         else if (strcasecmp($st_str, "fuori") == 0) {
1440           $st = USER_FLAG_S_OUT;
1441         }
1442         else if (strcasecmp($st_str, "cane") == 0) {
1443           $st = USER_FLAG_S_DOG;
1444         }
1445         else if (strcasecmp($st_str, "cibo") == 0) {
1446           $st = USER_FLAG_S_EAT;
1447         }
1448         else if (strcasecmp($st_str, "lavoro") == 0) {
1449           $st = USER_FLAG_S_WRK;
1450         }
1451         else if (strcasecmp($st_str, "sigaretta") == 0) {
1452           $st = USER_FLAG_S_SMK;
1453         }
1454         else if (strcasecmp($st_str, "presente") == 0) {
1455           $st = USER_FLAG_S_EYE;
1456         }
1457         else if (strcasecmp($st_str, "coniglio") == 0) {
1458           $st = USER_FLAG_S_RABB;
1459         }
1460         else if (strcasecmp($st_str, "calcio") == 0) {
1461           $st = USER_FLAG_S_SOCC;
1462         }
1463         else if (strcasecmp($st_str, "pupo") == 0) {
1464           $st = USER_FLAG_S_BABY;
1465         }
1466         else if (strcasecmp($st_str, "pulizie") == 0) {
1467           $st = USER_FLAG_S_MOP;
1468         }
1469         else {
1470           /* MLANG: "Questo stato non esiste." */
1471           $to_user = sprintf('chatt_sub("%s", [2,"%s"],"%s");', $dt, NICKSERV, $mlang_brisk['statunkn'][$G_lang]);
1472           break;
1473         }
1474
1475         log_main("chatt_send start set");
1476         if (($user->flags & USER_FLAG_S_ALL) != $st) {
1477           $update_room = TRUE;
1478           $user->flags = ($user->flags & ~USER_FLAG_S_ALL) | $st;
1479         }
1480       } while (0);
1481     } // nick chat command
1482
1483     else { // normal chat line
1484       $is_normchat = TRUE;
1485       if (CHAT_ENABLED && $curtime < ($user->chat_ban + $user->chat_dlt)) {
1486         $only_you = TRUE;
1487         $user->chat_dlt = $user->chat_dlt * 2; 
1488         if ($user->chat_dlt > 120)
1489           $user->chat_dlt = 120; 
1490       }
1491       else if ($user->chat_lst == $msg)
1492         $only_you = TRUE;
1493       else if (CHAT_ENABLED && $curtime - $user->chattime[($user->chat_cur + 1) % CHAT_N] < CHAT_ILL_TIME) {
1494         $user->chat_ban = $curtime;
1495         $user->chat_dlt = 5;
1496         $only_you = TRUE;
1497       }
1498       else {
1499         $user->chat_ban = 0;
1500         $user->chat_dlt = 0;
1501       }
1502
1503       if ($only_you) {
1504         $to_user = sprintf('chatt_sub("%s", [%d, "%s"],"%s");', $dt, $user->flags, xcape($user->name), xcape("== chat ban =="));
1505       }
1506       else {
1507         $to_user = sprintf('chatt_sub("%s", [%d, "%s"],"%s");', $dt, $user->flags, xcape($user->name), xcape($msg));
1508         // temporary silentiation for troll (will became array check)
1509         // if (strcasecmp($user->name,'JackRokka') != 0 && $user->sess != '47ea653f602e8')
1510         $to_room = $to_user;
1511       }
1512
1513       log_legal($curtime, 'xxx', $user, 
1514                 ($user->stat == 'room' ? 'room' : 'table '.$user->table),$msg);
1515       
1516       $user->chat_lst = "$msg";
1517       $user->chattime[$user->chat_cur % CHAT_N] = $curtime;
1518       $user->chat_cur++;
1519     }
1520
1521     if ($to_all) {
1522       $to_room = $to_all;
1523       $to_tabl = $to_all;
1524     }
1525
1526     //
1527     //  Output to clients
1528     //
1529
1530     if ($to_user != FALSE) {
1531       $user->comm[$user->step % COMM_N] =  "gst.st = ".($user->step+1)."; ";
1532       $user->comm[$user->step % COMM_N] .= $to_user;
1533       $user->step_inc();
1534     }
1535
1536     if ($to_room != FALSE) {
1537       for ($i = 0 ; $i < MAX_PLAYERS ; $i++) {
1538         $user_cur = $this->user[$i];
1539         if ($target != "" && $user_cur->name != $target)
1540           continue;
1541         if ($user_cur->sess == '' || $user_cur->stat == 'table' || $user->idx_get() == $i)
1542           continue;
1543         
1544         if ($is_normchat == TRUE) {
1545           // use MAP_AUTH to check if auth or isolation
1546           if ($user_cur->flags & USER_FLAG_MAP_AUTH) {
1547             if (($user->flags & USER_FLAG_AUTH) == 0) {
1548               continue;
1549             }
1550           }
1551         }
1552         /*
1553         else if ($is_ticker) {
1554           if (($user_cur->flags & USER_FLAG_MAP_AUTH) == USER_FLAG_ISOLAUTH) {
1555             if ($user->table >= TABLES_AUTH_N)
1556               continue;
1557           }
1558         }
1559         */
1560         $user_cur->comm[$user_cur->step % COMM_N] =  "gst.st = ".($user_cur->step+1)."; ";
1561         $user_cur->comm[$user_cur->step % COMM_N] .= $to_room; 
1562         $user_cur->step_inc();
1563       }
1564     }
1565     
1566     if ($to_tabl) {
1567         // FIXME BRISK4: include for each kind of table
1568         require_once("${G_base}briskin5/Obj/briskin5.phh");
1569         // Before all align times with table timeout
1570         for ($table_idx = 0 ; $table_idx < TABLES_N ; $table_idx++) {
1571             if (isset($this->match[$table_idx])) {
1572                 $bri = $this->match[$table_idx];
1573
1574                 $bri_table = $bri->table[0];
1575                 for ($i = 0 ; $i < $bri_table->player_n ; $i++) {
1576                     // stat must be "table" by definition
1577                     $bri_user = $bri->user[$i];
1578               
1579                     if ($target != "" && $bri_user->name != $target)
1580                         continue;
1581                     log_main("writa: ".$user_mesg);
1582                     $bri_user->comm[$bri_user->step % COMM_N] = "gst.st = ".($bri_user->step+1)."; ";
1583                     $bri_user->comm[$bri_user->step % COMM_N] .= $to_tabl;
1584                     $bri_user->step_inc();
1585                 }
1586             } // if (isset($this->match
1587         } //  for ($table_idx = 0 ; $table_idx < TABLES_N ; $table_idx++) {
1588     } // if ($to_tabl == true ...
1589
1590     if ($update_room) {
1591       if ($user->stat == 'room' && $user->subst == 'standup') {
1592         $this->standup_update($user);
1593       }
1594       else if ($user->stat == 'room' && $user->subst == 'sitdown') {
1595         log_main("chatt_send pre table update");
1596         $this->table_update($user);
1597         log_main("chatt_send post table update");
1598       }
1599     } // if ($update_room ...
1600
1601     return;
1602   } // function chatt_send( ...
1603
1604   function get_user($sess, &$idx)
1605   {
1606     GLOBAL $PHP_SELF;
1607
1608     if (validate_sess($sess)) {
1609       for ($i = 0 ; $i < MAX_PLAYERS ; $i++) {
1610         if (strcmp($sess, $this->user[$i]->sess) == 0) {
1611           // find it
1612           $idx = $i;
1613           $ret = $this->user[$i];
1614           return ($ret);
1615         }
1616       }
1617       log_main(sprintf("get_user: Wrong sess from page [%s]",$PHP_SELF));
1618       // for ($i = 0 ; $i < MAX_PLAYERS ; $i++) 
1619       // log_main(sprintf("get_user: Wrong sess compared with [%s]",$this->user[$i]->sess));
1620     }
1621     else {
1622       log_main(sprintf("get_user: Wrong strlen [%s]",$sess));
1623     }
1624
1625     return (FALSE);
1626   }
1627
1628   /*
1629    * function add_user(&$room, &$sess, &$idx, $name, $pass, $ip)
1630    *
1631    * RETURN VALUE:
1632    *   if ($idx >  -1    && ret == FALSE)  =>  duplicated nick
1633    *   if ($idx == -2    && ret == FALSE)  =>  invalid name
1634    *   if ($idx == -3    && ret == FALSE)  =>  wrong password
1635    *   if ($idx == -1    && ret == FALSE)  =>  no space left
1636    *   if ($idx ==  0    && ret == user)   =>  SUCCESS
1637    *   if ($idx == -$idx && ret == user)   =>  SUCCESS (but the login exists in the auth db)
1638    */
1639
1640   function add_user(&$sess, &$idx, $name, $pass, $ip, $cookie)
1641   {
1642     GLOBAL $G_base;
1643
1644     $idx = 0;
1645
1646     $authenticate = FALSE;
1647     $user_type    = 0;
1648     $login_exists = FALSE;
1649     $ghost = -1;
1650     $ghost_auth = FALSE;
1651     $idx = -1;
1652     $idfree = -1;
1653     $code = FALSE;
1654
1655     if (($name_new = validate_name($name)) == FALSE) {
1656       $idx = -2;
1657       return (FALSE);
1658     }
1659
1660     log_auth("XXX", sprintf("ARRIVA: [%s] pass:[%s]", $sess, ($pass == FALSE ? "FALSE" : $pass)));
1661     if (validate_sess($sess) == FALSE) 
1662       $sess = "";
1663
1664     /* if pass != FALSE verify the login with pass */
1665     log_auth("XXX", "auth1");
1666
1667     if (($bdb = BriskDB::create()) != FALSE) {
1668         $bdb->users_load();
1669         if ($pass != FALSE) { // TODO: here add a method to $bdb to check if the db is available.
1670             log_auth("XXX", "auth2");
1671             $authenticate = $bdb->login_verify($name_new, $pass, $code);
1672             log_auth("XXX", "authenticate: ".($authenticate != FALSE ? "TRUE" : "FALSE"));
1673             
1674             if ($authenticate != FALSE) {
1675                 $user_type = $authenticate->type_get();
1676             }
1677             else {
1678                 $idx = -3;
1679                 return (FALSE);
1680             }
1681         }
1682         else {
1683             $login_exists =  $bdb->login_exists($name_new);
1684         }
1685     }
1686     else {
1687         // if db is down, send a warning and verify only current users
1688         // no actions at this moment
1689     }
1690     for ($i = 0 ; $i < MAX_PLAYERS ; $i++) {
1691       /* free user ? */
1692       if (strcmp($sess, $this->user[$i]->sess) == 0) {
1693         if ($idx == -1)
1694           $idx = $i;
1695       }
1696       if ($idfree == -1 && strcmp($this->user[$i]->sess, "") == 0) {
1697         $idfree = $i;
1698         continue; // NOTE: CHECK IT !!
1699       }
1700       if (strcasecmp($this->user[$i]->name, $name_new) == 0) {
1701           if ($authenticate != FALSE) {
1702               $ghost = $i;
1703               $ghost_auth = ($this->user[$i]->flags & USER_FLAG_AUTH);
1704           }
1705           else {
1706               $idx = $i;
1707               break;
1708           }
1709       }
1710     }
1711     if ($idx == -1)
1712       $idx = $idfree;
1713
1714     log_auth("XXX", sprintf("TROVATO A QUESTO PUNTO [%d] sess [%s] name [%s]", $idx, $sess, $name_new));
1715
1716     /* there is another user logged with your account and you and him have authenticated => new user
1717        get the session of the old user */
1718     if ($ghost > -1 && $ghost_auth && ($authenticate != FALSE)) {
1719       /* swap session */
1720
1721       $ghost_user = $this->user[$ghost];
1722       $curtime = time();
1723       $ghost_user->comm[$ghost_user->step % COMM_N] = "";
1724       $ghost_user->step_inc();
1725       if ($sess == "") {
1726         $sess = uniqid(""); 
1727         $ghost_user->sess = $sess;
1728       }
1729       else {
1730         $ghost_user->sess = $sess;
1731       }
1732       
1733       // If user at the table we need to update the table data too
1734       $table_idx = $ghost_user->table;
1735       if ($ghost_user->stat == "table" && $this->table[$table_idx]->player_n == PLAYERS_N) {
1736           require_once("${G_base}briskin5/Obj/briskin5.phh");
1737           if (isset($this->match[$table_idx])) {
1738               $bri = $this->match[$table_idx];
1739
1740               if ($bri->the_end != TRUE) {
1741                   $bri->user[$ghost_user->table_pos]->comm[$bri->user[$ghost_user->table_pos]->step % COMM_N] = "";
1742                   $bri->user[$ghost_user->table_pos]->step_inc();
1743                   $bri->user[$ghost_user->table_pos]->sess = $sess;
1744               }
1745           }
1746       }
1747
1748       $idx = $ghost;
1749       return ($this->user[$ghost]);
1750     }
1751     else if ($idx != -1 && $i == MAX_PLAYERS) {
1752       /* SUCCESS */
1753       $curtime = time();
1754       if ($sess == "") {
1755         $sess = uniqid("");
1756         $this->user[$idx]->sess = $sess;
1757       }
1758       else {
1759         $this->user[$idx]->sess = $sess;
1760       }
1761       $this->user[$idx]->name = $name_new; // OK - add new user
1762       $this->user[$idx]->stat_set("room");
1763       $this->user[$idx]->step_set(0);
1764       while (array_pop($this->user[$idx]->comm) != NULL);
1765       $this->user[$idx]->subst = "standup";
1766       $this->user[$idx]->lacc =   $curtime;
1767       $this->user[$idx]->laccwr = $curtime;
1768       $this->user[$idx]->bantime = 0;
1769       $this->user[$idx]->ip = $ip;
1770
1771       $this->user[$idx]->flags = $user_type;
1772       $this->user[$idx]->flags |= ($authenticate != FALSE ? USER_FLAG_AUTH : 0x00);
1773       $this->user[$idx]->flags |= ( ($pass != FALSE && $bdb == FALSE) ? USER_FLAG_DBFAILED : 0x00);
1774       log_auth("XXX", sprintf("FLAGS: [%x]", $this->user[$idx]->flags));
1775
1776       
1777       if ($authenticate != FALSE) {
1778         $this->user[$idx]->code = $authenticate->code_get();
1779         $this->user[$idx]->flags |= USER_FLAG_LISTAUTH;
1780
1781         if (isset($cookie['CO_list'])) {
1782           if (strcmp($cookie['CO_list'], "auth") == 0) {
1783             $this->user[$idx]->flags &= ~USER_FLAG_MAP_AUTH;
1784             $this->user[$idx]->flags |= USER_FLAG_LISTAUTH;
1785           }
1786           if (strcmp($cookie['CO_list'], "isolation") == 0) {
1787             $this->user[$idx]->flags &= ~USER_FLAG_MAP_AUTH;
1788             $this->user[$idx]->flags |= USER_FLAG_ISOLAUTH;
1789           }
1790           else {
1791             $this->user[$idx]->flags &= ~USER_FLAG_MAP_AUTH;
1792           }
1793         }
1794       }
1795       
1796       if ($ghost > -1) {
1797         log_main("ghost: rename!");
1798         $ghost_user = $this->user[$ghost];
1799
1800         if ($ghost_auth == FALSE) {
1801           for ($sfx = 1 ; $sfx <= MAX_PLAYERS ; $sfx++) {
1802             $ghostname = 'ghost'.$sfx;
1803             for ($i = 0 ; $i < MAX_PLAYERS ; $i++) {
1804               if (strcmp("", $this->user[$i]->sess) == 0) 
1805                 continue;
1806               
1807               if (strcasecmp($this->user[$i]->name, $ghostname) == 0) {
1808                 $ghostname = '';
1809                 break;
1810               }
1811             }
1812             if ($ghostname != '')
1813               break;
1814           }
1815           
1816           $ghost_user->name = $ghostname;
1817           
1818           if ($ghost_user->stat == 'room' && $ghost_user->subst == 'standup') {
1819             $this->standup_update($ghost_user);
1820           }
1821           else {
1822             log_main("chatt_send pre table update");
1823             $this->table_update($ghost_user);
1824           log_main("chatt_send post table update");
1825           }
1826         } // if ($ghost_auth == FALSE
1827         else {
1828           // FIXME: cacciare il vecchio utente room && table (if needed)
1829           $ghost_user->the_end = TRUE;
1830           $ghost_user->lacc = 0;
1831           $this->garbage_manager(TRUE);
1832         }
1833       } //  if ($ghost > -1) {
1834
1835       $real_idx = $idx;
1836       if ($login_exists)
1837         $idx = -($idx + 1);
1838       log_main(sprintf("TROVATO LIBERO A [%d] sess [%s] name [%s] count [%d] name [%s] code [%s]", $idx, $sess, $name_new, count($this->user),$this->user[$real_idx]->name, $this->user[$real_idx]->code));
1839
1840       $ret = $this->user[$real_idx];
1841       return ($ret);
1842     }
1843
1844     return (FALSE);
1845   }
1846   
1847   function standup_update($user)
1848   {
1849     for ($i = 0 ; $i < MAX_PLAYERS ; $i++) {
1850       $user_cur = $this->user[$i];
1851       if ($user_cur->sess == '')
1852         continue;
1853
1854       log_main("STANDUP START: ".$user_cur->stat);
1855       
1856       if ($user_cur->stat == 'room') {
1857         $user_cur->comm[$user_cur->step % COMM_N] = "gst.st = ".($user_cur->step+1)."; ".$this->standup_content($user_cur);
1858         if ($user->idx_get() == $i) {
1859           $user_cur->comm[$user_cur->step % COMM_N] .= $user->myname_innerHTML();
1860         }
1861         log_main("FROM STANDUP: NAME: ".$user_cur->name." SENDED: ".$user_cur->comm[$user_cur->step % COMM_N]);
1862         
1863         $user_cur->step_inc();
1864       }
1865     }
1866   }
1867
1868   // Static functions
1869   static function create($crystal_filename)
1870   {
1871       if (($room_ser = @file_get_contents($crystal_filename)) == FALSE ||
1872           ($room = unserialize($room_ser)) == FALSE) {
1873           fprintf(STDERR, "NEW ROOM\n");
1874           $room = new Room($crystal_filename);
1875       }
1876       else {
1877           fprintf(STDERR, "ROOM FROM FILE\n");
1878       }
1879
1880     return $room;
1881   }
1882   
1883   
1884   function load_data() 
1885   {
1886     GLOBAL $sess;
1887
1888     do {
1889       if (($tok = @ftok(FTOK_PATH."/main", "C")) == -1) {
1890         log_main("ftok failed");
1891         break;
1892       }
1893     
1894       if (($shm_sz = sharedmem_sz($tok)) == -1) {
1895         log_main("shmop_open failed");
1896       }
1897         
1898       if ($shm_sz == -1)
1899         $shm_sz = SHM_DIMS_MIN;
1900
1901       if ($shm = shm_attach($tok, $shm_sz)) {
1902           $room = @shm_get_var($shm, $tok); // CHECKED BELOW
1903           
1904           log_only("bri ==  ".($room == FALSE ?   "FALSE" : "TRUE")."  bri ===  ".($room === FALSE ? "FALSE" : "TRUE")."  bri isset ".(isset($room) ?   "TRUE" : "FALSE"));
1905           if (isset($room)) 
1906               log_only("bri count ".count($room));
1907           
1908           if ($room == FALSE) {
1909               log_only("INIT MAIN DATA");
1910               shm_detach($shm);
1911               
1912               $room = Room::create();
1913               
1914               log_shme("Room::create");
1915
1916               if (Room::save_data($room) == FALSE)
1917                   return FALSE;
1918
1919               return $room;
1920           }
1921           $room->shm_sz = $shm_sz;
1922           
1923           shm_detach($shm);
1924
1925           for ($i = 0 ; $i < MAX_PLAYERS ; $i++) {
1926               if (($room->user[$i] = User::load_data($i, FALSE)) == FALSE) {
1927                   log_crit("User::load_data failed");
1928                   break;
1929               }
1930           }
1931           if ($i < MAX_PLAYERS) {
1932               break;
1933           }
1934       }
1935       
1936       //  
1937       // SHSPLIT: load users from the shared memory
1938       //
1939       return ($room);
1940     } while (0);
1941     
1942     return (FALSE);
1943   }
1944   
1945
1946   function save_data_orig($room) 
1947   {
1948     GLOBAL $sess;
1949     
1950     $shm =   FALSE;
1951     
1952     // var_dump($room);
1953     
1954     if (($tok = @ftok(FTOK_PATH."/main", "C")) == -1) 
1955       return (FALSE);
1956     
1957     while ($room->shm_sz < SHM_DIMS_MAX) {
1958       if (($shm = shm_attach($tok, $room->shm_sz)) == FALSE)
1959         break;
1960       
1961       // log_only("PUT_VAR DI ".strlen(serialize($room)));
1962       if (@shm_put_var($shm, $tok, $room) != FALSE) {
1963         shm_detach($shm);
1964         return (TRUE);
1965       }
1966       if (shm_remove($shm) === FALSE) {
1967         log_only("REMOVE FALLITA");
1968         break;
1969       }
1970       shm_detach($shm);
1971       $room->shm_sz += SHM_DIMS_DLT;
1972     } 
1973
1974     if ($shm)
1975       shm_detach($shm);
1976     
1977     return (FALSE);
1978   }
1979   function dump_data()
1980   {
1981       $room_ser = serialize($this);
1982       $room_ser_len = mb_strlen($room_ser, "ASCII");
1983       if (file_put_contents($this->crystal_filename, $room_ser) == $room_ser_len) {
1984           return (TRUE);
1985       }
1986       
1987       return (FALSE);
1988   }
1989
1990   function save_data($room) 
1991   {
1992       GLOBAL $sess;
1993     
1994       $ret =   FALSE;
1995       $shm =   FALSE;
1996     
1997       if (($tok = @ftok(FTOK_PATH."/main", "C")) == -1) 
1998           return (FALSE);
1999     
2000       // SHSPLIT: before save the $room you must save users, 
2001       //          detach from main struct and (then) reattach
2002       $user_park = array();
2003       for ($i = 0 ; $i < MAX_PLAYERS ; $i++) {
2004           $user_park[$i]  = $room->user[$i];
2005           $room->user[$i] = FALSE;
2006       }
2007
2008       while ($room->shm_sz < SHM_DIMS_MAX) {
2009           if (($shm = shm_attach($tok, $room->shm_sz)) == FALSE)
2010               break;
2011       
2012           // log_only("PUT_VAR DI ".strlen(serialize($room)));
2013           if (@shm_put_var($shm, $tok, $room) != FALSE) {
2014               log_shme("Room::save_data");
2015               $ret = TRUE;
2016               break;
2017           }
2018           if (shm_remove($shm) === FALSE) {
2019               log_only("REMOVE FALLITA");
2020               break;
2021           }
2022           shm_detach($shm);
2023           $room->shm_sz += SHM_DIMS_DLT;
2024       } 
2025
2026       if ($shm)
2027           shm_detach($shm);
2028     
2029       // SHSPLIT: reattach users to the room class
2030       for ($i = 0 ; $i < MAX_PLAYERS ; $i++) {
2031           User::save_data($user_park[$i], $i);
2032           $room->user[$i] = $user_park[$i];
2033       }
2034       log_load("FINISH: ".($ret == TRUE ? "TRUE" : "FALSE"));
2035
2036       return ($ret);
2037   }
2038
2039   static function lock_data($is_exclusive)
2040   {
2041       if (($res = file_lock(FTOK_PATH."/main", $is_exclusive)) != FALSE) {
2042           self::$delta_t = microtime(TRUE);
2043           log_lock("LOCK   room         [".self::$delta_t."]");
2044           
2045           return ($res);
2046       }
2047
2048       return (FALSE);
2049   }
2050   
2051   static function unlock_data($res)
2052   {
2053     GLOBAL $sess; 
2054     
2055     log_lock("UNLOCK room         [".(microtime(TRUE) - (self::$delta_t))."]");
2056
2057     file_unlock($res);
2058   }
2059
2060
2061   function standup_content($user)
2062   {
2063     $ret = "";
2064     $content = "";
2065     
2066     if ($user->stat != 'room')
2067       return;
2068     
2069     for ($i = 0 , $ct = 0 ; $ct < 4 && $i < MAX_PLAYERS ; $i++) {
2070       if ($this->user[$i]->sess == "" || $this->user[$i]->stat != "room" || $this->user[$i]->name == "")
2071         continue;
2072       $ct++;
2073     }
2074     
2075     // $content .= sprintf('<table cols=\\"%d\\" class=\\"table_standup\\">', $ct);
2076     
2077     $content = ' j_stand_cont( [ ';
2078
2079     for ($i = 0 , $ct = 0 ; $i < MAX_PLAYERS ; $i++) {
2080       if ($this->user[$i]->sess == "" || $this->user[$i]->stat != "room" || $this->user[$i]->name == "")
2081         continue;
2082       
2083       $flags = $this->user[$i]->flags;
2084       
2085       if ($this->user[$i]->subst == "standup") {
2086           if ($user->idx_get() == $i) { 
2087               $flags |= 1;
2088           }
2089           
2090           $content .= sprintf('%s[ %d, "%s" ]',($ct > 0 ? ', ' : ''), $flags, xcape($this->user[$i]->name));
2091           $ct++;
2092       }
2093     }
2094     $content .= ' ]);';
2095     
2096     return ($content);
2097   }
2098   
2099   function table_content($user, $table_idx)
2100   {
2101     $content = "";
2102     $ret = "";
2103     // TODO
2104     //
2105     //   Si possono usare i dati nella classe table
2106     //
2107     
2108     $sess = $user->sess;
2109     $table = $this->table[$table_idx];
2110     
2111     if ($user->stat != 'room')
2112       return;
2113     
2114     $content = "[ ";
2115     for ($i = 0 ; $i < $table->player_n ; $i++) {
2116         $user_cur = $this->user[$table->player[$i]];
2117         
2118         $flags = $user_cur->flags;
2119         
2120         if ($user->idx_get() == $table->player[$i]) 
2121             $flags |= 1;
2122         
2123         log_main($user_cur->name. sprintf(" IN TABLE [%d]", $table_idx));
2124         
2125         $content .= sprintf('%s[ %d, "%s" ]',($i == 0 ? '' : ', '), $flags, xcape($user_cur->name));
2126     }
2127
2128     $content .= ' ]';
2129
2130     $ret .= sprintf('j_tab_cont(%d, %s);', $table_idx, $content);
2131     
2132     return ($ret);
2133   }
2134
2135   function request_mgr(&$s_a_p, $header, &$header_out, &$new_socket, $path, $addr, $get, $post, $cookie)
2136   {
2137       printf("NEW_SOCKET (root): %d\n", intval($new_socket));
2138
2139       $enc = get_encoding($header);
2140       if (isset($header['User-Agent']) && strstr($header['User-Agent'], "MSIE")) {
2141           $transp_type = "htmlfile";
2142       }
2143       else {
2144           $transp_type = "iframe";
2145       }
2146       force_no_cache($header_out);
2147
2148       switch ($path) {
2149       case "":
2150       case "index.php":
2151           ob_start();
2152           index_main($this, $transp_type, $header_out, $addr, $get, $post, $cookie);
2153           $content = ob_get_contents();
2154           ob_end_clean();
2155
2156           $s_a_p->pgflush_try_add($enc, $new_socket, 20, $header_out, $content);
2157           return TRUE;
2158
2159           break;
2160       case "index_wr.php":
2161           ob_start();
2162           index_wr_main($this, $addr, $get, $post, $cookie);
2163           $content = ob_get_contents();
2164           ob_end_clean();
2165           
2166           $s_a_p->pgflush_try_add($enc, $new_socket, 20, $header_out, $content);
2167           return TRUE;
2168
2169           break;
2170       case "index_rd_ifra.php":
2171           do {
2172               if (!isset($cookie['sess'])
2173                   || (($user = $this->get_user($cookie['sess'], $idx)) == FALSE)) {
2174                   $content = User::stream_fini($s_a_p->rndstr, TRUE);
2175                   
2176                   $s_a_p->pgflush_try_add($enc, $new_socket, 20, $header_out, $content);
2177                   return TRUE;
2178
2179                   break;
2180               }
2181               // close a previous opened index_read_ifra socket, if exists
2182               if (($prev = $user->rd_socket_get()) != NULL) {
2183                   $s_a_p->socks_unset($user->rd_socket_get());
2184                   fclose($user->rd_socket_get());
2185                   printf("CLOSE AND OPEN AGAIN ON IFRA2\n");
2186                   $user->rd_socket_set(NULL);
2187               }
2188
2189               $content = "";
2190               $user->stream_init($s_a_p->rndstr, $enc, $header_out, $content, $get, $post, $cookie);
2191               
2192               $response = headers_render($header_out, -1).chunked_content($user->rd_zls_get(), $content);
2193               $response_l = mb_strlen($response, "ASCII");
2194               
2195               $wret = @fwrite($new_socket, $response, $response_l);
2196               if ($wret < $response_l) {
2197                   printf("TROUBLES WITH FWRITE: %d\n", $wret);
2198                   $user->rd_cache_set(mb_substr($content, $wret, $response_l - $wret, "ASCII"));
2199               }
2200               else {
2201                   $user->rd_cache_set("");
2202               }
2203               fflush($new_socket);
2204               
2205               
2206               $s_a_p->socks_set($new_socket, $user);
2207               $user->rd_socket_set($new_socket);
2208               printf(" - qui ci siamo - ");
2209               return TRUE;
2210           } while (FALSE);
2211           
2212           return FALSE;
2213           break;
2214
2215       default:
2216           /* FAR TODO: move all into an array of registered sub-apps */
2217           $subs = "briskin5/";
2218           $subs_l = strlen($subs);
2219           if (!strncmp($path, $subs, $subs_l)) {
2220               $ret = Bin5::request_mgr(&$s_a_p, $header, &$header_out, &$new_socket, substr($path, $subs_l) , $addr, $get, $post, $cookie);
2221               return ($ret);
2222           }
2223           break;
2224       }
2225
2226       return (FALSE);
2227   }
2228
2229   function match_add($idx, $match)
2230   {
2231       $this->match[$idx] = $match;
2232   }
2233
2234   function match_del($idx)
2235   {
2236       unset($this->match[$idx]);
2237   }
2238
2239   function match_get($idx, $token)
2240   {
2241       if (isset($this->match[$idx])) {
2242           if (   $token == NULL 
2243               || $token == $this->match[$idx]->table_token) {
2244               return ($this->match[$idx]);
2245           }
2246       }
2247       return NULL;
2248   }
2249
2250 } // end class Room
2251
2252 function make_seed()
2253 {
2254   list($usec, $sec) = explode(' ', microtime());
2255   return (float) $sec + ((float) $usec * 100000);
2256 }
2257
2258 function btrace_line($ar)
2259 {
2260     GLOBAL $G_btrace_pref_sub;
2261
2262     $ret = "";
2263     for ($i = 0 ; $i < count($ar) ; $i++) {
2264         $with_class = isset($ar[$i]['class']);
2265         $with_file  = isset($ar[$i]['file']);
2266         $ret .= sprintf("%s%s%s (%s:%d)", ($i == 0 ? "" : ", "), 
2267                         ($with_class ?  $ar[$i]['class'].$ar[$i]['type'] : ""), 
2268                         $ar[$i]['function'], ($with_file ? str_replace($G_btrace_pref_sub, "", $ar[$i]['file']) : ""), 
2269                         ($with_file ? $ar[$i]['line'] : ""));
2270     }
2271     
2272     return ($ret);
2273 }
2274
2275 function trace_ftok($id, $add)
2276 {
2277     // NOTE: without space to use sed to substitute "= @ftok("  with "= @ftok("
2278     $tok=@ftok($id, $add);
2279
2280     log_shme($tok.": ".$id." + ".$add);
2281
2282     return ($tok);
2283 }
2284
2285 function log_mop($step, $log)
2286 {
2287     GLOBAL $sess, $PHP_SELF;
2288     
2289     if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_LMOP) == 0)
2290         return;
2291     
2292     if (isset($sess) == FALSE)
2293         $ssess = "XXXX";
2294     else
2295         $ssess = $sess;
2296     
2297     if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_LMOP) == 0)
2298         return;
2299     
2300     if ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC)
2301         $btrace = btrace_line(debug_backtrace());
2302     else
2303         $btrace = "";
2304     if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) {
2305         fwrite($fp, sprintf("LMOP: [%f] [%05d] [%s] [%s]\n", gettimeofday(TRUE), $step, $log, $btrace));
2306         fclose($fp);
2307     }
2308 }
2309
2310
2311 function log_only2($log)
2312 {
2313     GLOBAL $sess, $PHP_SELF;
2314     
2315     if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_ONL2) == 0)
2316         return;
2317     
2318     if (isset($sess) == FALSE)
2319         $ssess = "XXXX";
2320     else
2321         $ssess = $sess;
2322     
2323     if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_ONL2) == 0)
2324         return;
2325     
2326     if ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC)
2327         $btrace = btrace_line(debug_backtrace());
2328     else
2329         $btrace = "";
2330     if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) {
2331         fwrite($fp, sprintf("ONL2: [%s] [%s] [%s]\n", $ssess, $log, $btrace));
2332         fclose($fp);
2333     }
2334 }
2335
2336 function log_crit($log)
2337 {
2338     GLOBAL $sess, $PHP_SELF;
2339     
2340     if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_CRIT) == 0)
2341         return;
2342     
2343     if (isset($sess) == FALSE)
2344         $ssess = "XXXX";
2345     else
2346         $ssess = $sess;
2347     
2348     if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_CRIT) == 0)
2349         return;
2350     
2351     if ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC)
2352         $btrace = btrace_line(debug_backtrace());
2353     else
2354         $btrace = "";
2355     if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) {
2356         fwrite($fp, sprintf("CRIT: [%s] [%s] [%s]\n", $ssess, $log, $btrace));
2357         fclose($fp);
2358     }
2359 }
2360
2361 function log_only($log)
2362 {
2363     GLOBAL $sess, $PHP_SELF;
2364     
2365     if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_ONLY) == 0)
2366         return;
2367     
2368     if (isset($sess) == FALSE)
2369         $ssess = "XXXX";
2370     else
2371         $ssess = $sess;
2372     
2373     if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_ONLY) == 0)
2374         return;
2375     
2376     if ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC)
2377         $btrace = btrace_line(debug_backtrace());
2378     else
2379         $btrace = "";
2380     if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) {
2381         fwrite($fp, sprintf("ONLY: [%s] [%s] [%s]\n", $ssess, $log, $btrace));
2382         fclose($fp);
2383     }
2384 }
2385
2386 function log_main($log)
2387 {
2388     GLOBAL $sess, $PHP_SELF;
2389     
2390     if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_MAIN) == 0)
2391         return;
2392     
2393     if (isset($sess) == FALSE)
2394         $ssess = "XXXX";
2395     else
2396         $ssess = $sess;
2397     
2398     if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_MAIN) == 0)
2399         return;
2400     
2401     if ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC)
2402         $btrace = btrace_line(debug_backtrace());
2403     else
2404         $btrace = "";
2405     if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) {
2406         fwrite($fp, sprintf("MAIN: [%s] [%s] [%s]\n", $ssess, $log, $btrace));
2407         fclose($fp);
2408     }
2409 }
2410
2411 function log_rd($log)
2412 {
2413     GLOBAL $sess, $PHP_SELF;
2414     
2415     if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_READ) == 0)
2416         return;
2417     
2418     if (isset($sess) == FALSE)
2419         $ssess = "XXXX";
2420     else
2421         $ssess = $sess;
2422     
2423     if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_READ) == 0)
2424         return;
2425
2426     if ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC)
2427         $btrace = btrace_line(debug_backtrace());
2428     else
2429         $btrace = "";    
2430     if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) {
2431         fwrite($fp, sprintf("READ: [%s] [%s] [%s]\n", $ssess, $log, $btrace));
2432         fclose($fp);
2433     }
2434 }
2435
2436 function log_rd2($log)
2437 {
2438     GLOBAL $sess, $PHP_SELF;
2439     
2440     if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_REA2) == 0)
2441         return;
2442     
2443     if (isset($sess) == FALSE)
2444         $ssess = "XXXX";
2445     else
2446         $ssess = $sess;
2447     
2448     if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_REA2) == 0)
2449         return;
2450     
2451     if ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC)
2452         $btrace = btrace_line(debug_backtrace());
2453     else
2454         $btrace = "";
2455     
2456     if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) {
2457         fwrite($fp, sprintf("REA2: [%s] [%s] [%s]\n", $ssess, $log, $btrace));
2458         fclose($fp);
2459     }
2460 }
2461
2462 function log_send($log)
2463 {
2464     GLOBAL $sess, $PHP_SELF;
2465     
2466     if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_SEND) == 0)
2467         return;
2468     
2469     if (isset($sess) == FALSE)
2470         $ssess = "XXXX";
2471     else
2472         $ssess = $sess;
2473     
2474     if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_SEND) == 0)
2475         return;
2476
2477     if ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC)    
2478         $btrace = btrace_line(debug_backtrace());
2479     else
2480         $btrace = "";
2481     if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) {
2482         fwrite($fp, sprintf("SEND: [%s] [%s] [%s]\n", $ssess, $log, $btrace));
2483         fclose($fp);
2484     }
2485 }
2486
2487 function log_lock($log)
2488 {
2489     GLOBAL $sess, $PHP_SELF;
2490     
2491     if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_LOCK) == 0)
2492         return;
2493     
2494     if (isset($sess) == FALSE)
2495         $ssess = "XXXX";
2496     else
2497         $ssess = $sess;
2498     
2499     if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_LOCK) == 0)
2500         return;
2501     
2502     if ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC)
2503         $btrace = btrace_line(debug_backtrace());
2504     else
2505         $btrace = "";
2506     if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) {
2507         fwrite($fp, sprintf("LOCK: [%s] [%s] [%s]\n", $ssess, $log, $btrace));
2508         fclose($fp);
2509     }
2510 }
2511
2512 function log_wr($log)
2513 {
2514     GLOBAL $sess, $PHP_SELF;
2515     
2516     if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_WRIT) == 0)
2517         return;
2518     
2519     if (isset($sess) == FALSE)
2520         $ssess = "XXXX";
2521     else
2522         $ssess = $sess;
2523     
2524     if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_WRIT) == 0)
2525         return;
2526     
2527     if ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC)
2528         $btrace = btrace_line(debug_backtrace());
2529     else
2530         $btrace = "";
2531     if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) {
2532         fwrite($fp, sprintf("WRIT: [%s] [%s] [%s]\n", $ssess, $log, $btrace));
2533         fclose($fp);
2534     }
2535 }
2536
2537 function log_load($log)
2538 {
2539     GLOBAL $sess, $PHP_SELF;
2540     
2541     if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_LOAD) == 0)
2542         return;
2543     
2544     if (isset($sess) == FALSE)
2545         $ssess = "XXXX";
2546     else
2547         $ssess = $sess;
2548     
2549     if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_LOAD) == 0)
2550         return;
2551     
2552     if ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC)
2553         $btrace = btrace_line(debug_backtrace());
2554     else
2555         $btrace = "";
2556     if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) {
2557         fwrite($fp, sprintf("LOAD: [%s] [%s] [%s]\n", $ssess, $log, $btrace));
2558         fclose($fp);
2559     }
2560 }
2561
2562 function log_auth($sess, $log)
2563 {
2564     GLOBAL $PHP_SELF;
2565
2566     if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_AUTH) == 0)
2567         return;
2568     
2569     if (( (BRISK_DEBUG | ($sess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_AUTH) == 0)
2570         return;
2571     
2572     if ((BRISK_DEBUG | ($sess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC)
2573         $btrace = btrace_line(debug_backtrace());
2574     else
2575         $btrace = "";
2576     if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) {
2577         fwrite($fp, sprintf("LOAD: [%s] [%d] [%s] [%s]\n", $sess, time(), $log, $btrace));
2578         fclose($fp);
2579     }
2580 }
2581
2582 function log_shme($log)
2583 {
2584     GLOBAL $sess, $PHP_SELF;
2585     
2586     if (BRISK_SINGLE_SESS == "" && (BRISK_DEBUG & DBG_SHME) == 0)
2587         return;
2588     
2589     if (isset($sess) == FALSE)
2590         $ssess = "XXXX";
2591     else
2592         $ssess = $sess;
2593     
2594     if (( (BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_SHME) == 0)
2595         return;
2596     
2597     if ((BRISK_DEBUG | ($ssess == BRISK_SINGLE_SESS ? BRISK_SINGLE_DEBUG : 0) ) & DBG_TRAC)
2598         $btrace = btrace_line(debug_backtrace());
2599     else
2600         $btrace = "";
2601     if (($fp = @fopen(LEGAL_PATH."/brisk.log", 'a')) != FALSE) {
2602         fwrite($fp, sprintf("SHME: [%s] [%s] [%s]\n", $ssess, $log, $btrace));
2603         fclose($fp);
2604     }
2605 }
2606
2607
2608
2609 // function log_legal($curtime, $sess, $name, $where, $mesg) 
2610 function log_legal($curtime, $addr, $user, $where, $mesg) 
2611 {
2612
2613   if (($fp = @fopen(LEGAL_PATH."/legal.log", 'a')) != FALSE) {
2614     /* Unix time | session | nickname | IP | where was | mesg */
2615     fwrite($fp, sprintf("%ld|%s|%s|%s|%s|%s|%s|\n", $curtime, $user->sess,
2616                         ($user->flags & USER_FLAG_AUTH ? 'A' : 'N'),
2617                         $user->name, $addr, $where , $mesg));
2618     fclose($fp);
2619   }
2620 }
2621
2622 function table_act_content($isstanding, $sitted, $table, $cur_table, $allowed)
2623 {
2624   $ret = "";
2625
2626   if ($isstanding) {
2627     if ($sitted < PLAYERS_N) {
2628       if ($allowed)
2629         $act = 'sit';
2630       else
2631         $act = 'reserved';
2632     }
2633   }
2634   else {
2635     if ($table == $cur_table)
2636       $act = 'wake';
2637     else
2638       $act = 'none';
2639   }
2640
2641   if ($act != '')
2642     $ret = sprintf('j_tab_act_cont(%d, \'%s\');', $table, $act);
2643
2644   return ($ret);
2645 }
2646
2647 function show_notify($text, $tout, $butt, $w, $h)
2648 {
2649   log_main("SHOW_NOTIFY: ".$text);
2650   return sprintf('var noti = new notify(gst,"%s",%d,"%s",%d,%d);', $text, $tout, $butt, $w, $h);
2651 }
2652
2653 function show_notify_ex($text, $tout, $butt, $w, $h, $is_opaque, $block_time)
2654 {
2655   log_main("SHOW_NOTIFY OPAQUE: ".$text);
2656   return sprintf('var noti = new notify_ex(gst,"%s",%d,"%s",%d,%d, %s, %d);', $text, $tout, $butt, $w, $h, ($is_opaque ? "true" : "false"), $block_time);
2657 }
2658
2659
2660 function root_wellcome($user)
2661 {
2662   GLOBAL $root_wellarr, $G_lang;
2663   $ret = "";
2664
2665   $curtime = time();
2666   $dt = date("H:i ", $curtime);
2667     
2668   for ($i = 0 ; $i < count($root_wellarr[$G_lang]) ; $i++)
2669     $ret .= sprintf('chatt_sub("%s", [2, "%s"],"%s");', $dt, NICKSERV, str_replace('"', '\"', $root_wellarr[$G_lang][$i]));
2670
2671   return ($ret);
2672 }
2673
2674
2675
2676 function validate_sess($sess) 
2677 {
2678   if (strlen($sess) == SESS_LEN) 
2679     return (TRUE);
2680   else
2681     return (FALSE);
2682 }
2683
2684 function validate_name($name) 
2685 {
2686     $name_new = str_replace(' ', '_', mb_substr(trim($name),0,12, "UTF-8"));
2687
2688   for ($i = 0 ; $i < strlen($name_new) ; $i++) {
2689     $c = $name_new[$i];
2690     if (($c >= "a" && $c <= "z") || ($c >= "A" && $c <= "Z") || ($c >= "0" && $c <= "9"))
2691       return ($name_new);
2692   }
2693
2694   return (FALSE);
2695 }
2696
2697 function playsound($filename)
2698 {
2699   return (sprintf('playsound("flasou", "%s");', $filename));
2700 }
2701
2702 function secstoword($secs)
2703 {
2704   GLOBAL $G_lang;
2705
2706   $ret = "";
2707
2708   $mins = floor($secs / 60);
2709   $secs = $secs % 60;
2710   if ($G_lang == 'en') {
2711     if ($mins > 0) 
2712       $ret = sprintf("%d minute%s%s", $mins, ($mins > 1 ? "s" : ""), ($secs > 0 ? " and " : ""));
2713     
2714     if ($secs > 0)
2715       $ret .= sprintf("%d second%s", $secs, ($secs > 1 ? "s" : ""));
2716   }
2717   else {
2718     if ($mins > 0) 
2719       $ret = sprintf("%d minut%s%s", $mins, ($mins > 1 ? "i" : "o"), ($secs > 0 ? " e " : ""));
2720     
2721     if ($secs > 0)
2722       $ret .= sprintf("%d second%s", $secs, ($secs > 1 ? "i" : "o"));
2723   }
2724   return ($ret);
2725 }
2726
2727 function sharedmem_sz($tok)
2728 {
2729   if (($shm_id = @shmop_open($tok, 'a', 0, 0)) == FALSE) {
2730     log_main("shmop_open failed");
2731     return (-1);
2732   }
2733   $shm_sz = shmop_size($shm_id);
2734   shmop_close($shm_id);
2735   
2736   // log_main("shm_sz: ".$shm_sz."   SHM_DIMS: ".SHM_DIMS);
2737   return ($shm_sz);
2738 }    
2739
2740 class Warrant {
2741     static $delta_t;
2742
2743   static function lock_data($is_exclusive)
2744   {
2745       if (($res = file_lock(FTOK_PATH."/warrant", $is_exclusive)) != FALSE) {
2746           self::$delta_t = microtime(TRUE);
2747           log_lock("LOCK   warrant      [".self::$delta_t."]");
2748           
2749           return ($res);
2750       }
2751
2752       return (FALSE);
2753   }
2754   
2755   static function unlock_data($res)
2756   {
2757     GLOBAL $sess; 
2758     
2759     log_lock("UNLOCK warrant      [".(microtime(TRUE) - (self::$delta_t))."]");
2760
2761     file_unlock($res);
2762   }
2763 }
2764
2765 class Poll {
2766     static $delta_t;
2767
2768   static function lock_data($is_exclusive)
2769   {
2770       if (($res = file_lock(FTOK_PATH."/poll", $is_exclusive)) != FALSE) {
2771           self::$delta_t = microtime(TRUE);
2772           log_lock("LOCK   poll         [".self::$delta_t."]");
2773           
2774           return ($res);
2775       }
2776
2777       return (FALSE);
2778   }
2779   
2780   static function unlock_data($res)
2781   {
2782     GLOBAL $sess; 
2783     
2784     log_lock("UNLOCK poll         [".(microtime(TRUE) - (self::$delta_t))."]");
2785     
2786     file_unlock($res);
2787   }
2788 }
2789
2790 ?>