thomascube
2005-11-18 fbf77b4493f1b77c99751d8a86365c712ae3fb1b
commit | author | age
4e17e6 1 <?php
T 2
3 /*
4  +-----------------------------------------------------------------------+
5  | program/include/session.inc                                           |
6  |                                                                       |
7  | This file is part of the RoundCube Webmail client                     |
8  | Copyright (C) 2005, RoundCube Dev, - Switzerland                      |
30233b 9  | Licensed under the GNU GPL                                            |
4e17e6 10  |                                                                       |
T 11  | PURPOSE:                                                              |
12  |   Provide database supported session management                       |
13  |                                                                       |
14  +-----------------------------------------------------------------------+
15  | Author: Thomas Bruederli <roundcube@gmail.com>                        |
16  +-----------------------------------------------------------------------+
17
18  $Id$
19
20 */
21
22
23 function sess_open($save_path, $session_name)
24   {
25   return TRUE;
26   }
27
28
29
30 function sess_close()
31   {
32   return TRUE;
33   }
34
35
36 // read session data
37 function sess_read($key)
38   {
39   global $DB, $SESS_CHANGED;
40   
d7cb77 41   $sql_result = $DB->query("SELECT vars, ip, ".$DB->unixtimestamp('changed')." AS changed
S 42                             FROM ".get_table_name('session')."
43                             WHERE  sess_id=?",
44                             $key);
4e17e6 45
T 46   if ($sql_arr = $DB->fetch_assoc($sql_result))
47     {
48     $SESS_CHANGED = $sql_arr['changed'];
49
50     if (strlen($sql_arr['vars']))
51       return $sql_arr['vars'];
52     }
53
54   return FALSE;
55   }
56   
57
58 // save session data
59 function sess_write($key, $vars)
60   {
61   global $DB;
62   
d7cb77 63   $sql_result = $DB->query("SELECT 1
S 64                             FROM ".get_table_name('session')."
65                             WHERE  sess_id=?",
66                             $key);
4e17e6 67
T 68   if ($DB->num_rows($sql_result))
69     {
70     session_decode($vars);
d7cb77 71     $DB->query("UPDATE ".get_table_name('session')."
S 72                 SET    vars=?,
667737 73                        changed=now()
d7cb77 74                 WHERE  sess_id=?",
S 75                 $vars,
76                 $key);
4e17e6 77     }
T 78   else
79     {
d7cb77 80     $DB->query("INSERT INTO ".get_table_name('session')."
S 81                 (sess_id, vars, ip, created, changed)
667737 82                 VALUES (?, ?, ?, now(), now())",
d7cb77 83                 $key,
S 84                 $vars,
85                 $_SERVER['REMOTE_ADDR']);
4e17e6 86     }
T 87
88   return TRUE;
89   }
90
91
92 // handler for session_destroy()
93 function sess_destroy($key)
94   {
95   global $DB;
96   
d7cb77 97   // delete session entries in cache table
S 98   $DB->query("DELETE FROM ".get_table_name('cache')."
99               WHERE  session_id=?",
100               $key);
101               
102   $DB->query("DELETE FROM ".get_table_name('session')."
103               WHERE sess_id=?",
104               $key);
4e17e6 105                      
T 106   return TRUE;
107   }
108
109
110 // garbage collecting function
111 function sess_gc($maxlifetime)
112   {
113   global $DB;
114
115   // get all expired sessions  
d7cb77 116   $sql_result = $DB->query("SELECT sess_id
S 117                             FROM ".get_table_name('session')."
667737 118                             WHERE ".$DB->unixtimestamp('now()')."-".$DB->unixtimestamp('created')." > ?",
d7cb77 119                             $maxlifetime);
4e17e6 120                                    
T 121   $a_exp_sessions = array();
122   while ($sql_arr = $DB->fetch_assoc($sql_result))
123     $a_exp_sessions[] = $sql_arr['sess_id'];
124
125   
126   if (sizeof($a_exp_sessions))
127     {
d7cb77 128     // delete session cache records
S 129     $DB->query("DELETE FROM ".get_table_name('cache')."
130                 WHERE  session_id IN ('".join("','", $a_exp_sessions)."')");
131                 
4e17e6 132     // delete session records
d7cb77 133     $DB->query("DELETE FROM ".get_table_name('session')."
S 134                 WHERE sess_id IN ('".join("','", $a_exp_sessions)."')");
4e17e6 135     }
T 136
137   return TRUE;
138   }
139
140
141 // set custom functions for PHP session management
142 session_set_save_handler('sess_open', 'sess_close', 'sess_read', 'sess_write', 'sess_destroy', 'sess_gc');
143
144 ?>