mirror of
https://github.com/phpbb/phpbb.git
synced 2025-06-08 04:18:52 +00:00
Merge branch '3.3.x'
This commit is contained in:
commit
7934d3bd56
4 changed files with 223 additions and 60 deletions
|
@ -956,54 +956,79 @@ class session
|
||||||
{
|
{
|
||||||
global $db, $config, $phpbb_container, $phpbb_dispatcher;
|
global $db, $config, $phpbb_container, $phpbb_dispatcher;
|
||||||
|
|
||||||
$batch_size = 10;
|
|
||||||
|
|
||||||
if (!$this->time_now)
|
if (!$this->time_now)
|
||||||
{
|
{
|
||||||
$this->time_now = time();
|
$this->time_now = time();
|
||||||
}
|
}
|
||||||
|
|
||||||
// Firstly, delete guest sessions
|
/**
|
||||||
$sql = 'DELETE FROM ' . SESSIONS_TABLE . '
|
* Get expired sessions for registered users, only most recent for each user
|
||||||
WHERE session_user_id = ' . ANONYMOUS . '
|
* Inner SELECT gets most recent expired sessions for unique session_user_id
|
||||||
AND session_time < ' . (int) ($this->time_now - $config['session_length']);
|
* Outer SELECT gets data for them
|
||||||
|
*/
|
||||||
|
$sql_select = 'SELECT s1.session_page, s1.session_user_id, s1.session_time AS recent_time
|
||||||
|
FROM ' . SESSIONS_TABLE . ' AS s1
|
||||||
|
INNER JOIN (
|
||||||
|
SELECT session_user_id, MAX(session_time) AS recent_time
|
||||||
|
FROM ' . SESSIONS_TABLE . '
|
||||||
|
WHERE session_time < ' . ($this->time_now - (int) $config['session_length']) . '
|
||||||
|
AND session_user_id <> ' . ANONYMOUS . '
|
||||||
|
GROUP BY session_user_id
|
||||||
|
) AS s2
|
||||||
|
ON s1.session_user_id = s2.session_user_id
|
||||||
|
AND s1.session_time = s2.recent_time';
|
||||||
|
|
||||||
|
switch ($db->get_sql_layer())
|
||||||
|
{
|
||||||
|
case 'sqlite3':
|
||||||
|
if (phpbb_version_compare($db->sql_server_info(true), '3.8.3', '>='))
|
||||||
|
{
|
||||||
|
// For SQLite versions 3.8.3+ which support Common Table Expressions (CTE)
|
||||||
|
$sql = "WITH s3 (session_page, session_user_id, session_time) AS ($sql_select)
|
||||||
|
UPDATE " . USERS_TABLE . '
|
||||||
|
SET (user_lastpage, user_lastvisit) = (SELECT session_page, session_time FROM s3 WHERE session_user_id = user_id)
|
||||||
|
WHERE EXISTS (SELECT session_user_id FROM s3 WHERE session_user_id = user_id)';
|
||||||
$db->sql_query($sql);
|
$db->sql_query($sql);
|
||||||
|
|
||||||
// Get expired sessions, only most recent for each user
|
break;
|
||||||
$sql = 'SELECT session_user_id, session_page, MAX(session_time) AS recent_time
|
}
|
||||||
FROM ' . SESSIONS_TABLE . '
|
|
||||||
WHERE session_time < ' . ($this->time_now - $config['session_length']) . '
|
|
||||||
GROUP BY session_user_id, session_page';
|
|
||||||
$result = $db->sql_query_limit($sql, $batch_size);
|
|
||||||
|
|
||||||
$del_user_id = array();
|
|
||||||
$del_sessions = 0;
|
|
||||||
|
|
||||||
|
// No break, for SQLite versions prior to 3.8.3 and Oracle
|
||||||
|
case 'oracle':
|
||||||
|
$result = $db->sql_query($sql_select);
|
||||||
while ($row = $db->sql_fetchrow($result))
|
while ($row = $db->sql_fetchrow($result))
|
||||||
{
|
{
|
||||||
$sql = 'UPDATE ' . USERS_TABLE . '
|
$sql = 'UPDATE ' . USERS_TABLE . '
|
||||||
SET user_lastvisit = ' . (int) $row['recent_time'] . ", user_lastpage = '" . $db->sql_escape($row['session_page']) . "'
|
SET user_lastvisit = ' . (int) $row['recent_time'] . ", user_lastpage = '" . $db->sql_escape($row['session_page']) . "'
|
||||||
WHERE user_id = " . (int) $row['session_user_id'];
|
WHERE user_id = " . (int) $row['session_user_id'];
|
||||||
$db->sql_query($sql);
|
$db->sql_query($sql);
|
||||||
|
|
||||||
$del_user_id[] = (int) $row['session_user_id'];
|
|
||||||
$del_sessions++;
|
|
||||||
}
|
}
|
||||||
$db->sql_freeresult($result);
|
$db->sql_freeresult($result);
|
||||||
|
break;
|
||||||
|
|
||||||
if (count($del_user_id))
|
case 'mysqli':
|
||||||
{
|
$sql = 'UPDATE ' . USERS_TABLE . " u,
|
||||||
// Delete expired sessions
|
($sql_select) s3
|
||||||
$sql = 'DELETE FROM ' . SESSIONS_TABLE . '
|
SET u.user_lastvisit = s3.recent_time, u.user_lastpage = s3.session_page
|
||||||
WHERE ' . $db->sql_in_set('session_user_id', $del_user_id) . '
|
WHERE u.user_id = s3.session_user_id";
|
||||||
AND session_time < ' . ($this->time_now - $config['session_length']);
|
|
||||||
$db->sql_query($sql);
|
$db->sql_query($sql);
|
||||||
|
break;
|
||||||
|
|
||||||
|
default:
|
||||||
|
$sql = 'UPDATE ' . USERS_TABLE . "
|
||||||
|
SET user_lastvisit = s3.recent_time, user_lastpage = s3.session_page
|
||||||
|
FROM ($sql_select) s3
|
||||||
|
WHERE user_id = s3.session_user_id";
|
||||||
|
$db->sql_query($sql);
|
||||||
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
if ($del_sessions < $batch_size)
|
// Delete all expired sessions
|
||||||
{
|
$sql = 'DELETE FROM ' . SESSIONS_TABLE . '
|
||||||
// Less than 10 users, update gc timer ... else we want gc
|
WHERE session_time < ' . ($this->time_now - (int) $config['session_length']);
|
||||||
// called again to delete other sessions
|
$db->sql_query($sql);
|
||||||
|
|
||||||
|
// Update gc timer
|
||||||
$config->set('session_last_gc', $this->time_now, false);
|
$config->set('session_last_gc', $this->time_now, false);
|
||||||
|
|
||||||
if ($config['max_autologin_time'])
|
if ($config['max_autologin_time'])
|
||||||
|
@ -1014,14 +1039,13 @@ class session
|
||||||
}
|
}
|
||||||
|
|
||||||
// only called from CRON; should be a safe workaround until the infrastructure gets going
|
// only called from CRON; should be a safe workaround until the infrastructure gets going
|
||||||
/* @var $captcha_factory \phpbb\captcha\factory */
|
/* @var \phpbb\captcha\factory $captcha_factory */
|
||||||
$captcha_factory = $phpbb_container->get('captcha.factory');
|
$captcha_factory = $phpbb_container->get('captcha.factory');
|
||||||
$captcha_factory->garbage_collect($config['captcha_plugin']);
|
$captcha_factory->garbage_collect($config['captcha_plugin']);
|
||||||
|
|
||||||
$sql = 'DELETE FROM ' . LOGIN_ATTEMPT_TABLE . '
|
$sql = 'DELETE FROM ' . LOGIN_ATTEMPT_TABLE . '
|
||||||
WHERE attempt_time < ' . (time() - (int) $config['ip_login_limit_time']);
|
WHERE attempt_time < ' . (time() - (int) $config['ip_login_limit_time']);
|
||||||
$db->sql_query($sql);
|
$db->sql_query($sql);
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Event to trigger extension on session_gc
|
* Event to trigger extension on session_gc
|
||||||
|
|
|
@ -5,11 +5,23 @@
|
||||||
<column>username_clean</column>
|
<column>username_clean</column>
|
||||||
<column>user_permissions</column>
|
<column>user_permissions</column>
|
||||||
<column>user_sig</column>
|
<column>user_sig</column>
|
||||||
|
<column>user_lastpage</column>
|
||||||
|
<column>user_lastvisit</column>
|
||||||
<row>
|
<row>
|
||||||
<value>4</value>
|
<value>4</value>
|
||||||
<value>bar</value>
|
<value>bar</value>
|
||||||
<value></value>
|
<value></value>
|
||||||
<value></value>
|
<value></value>
|
||||||
|
<value>oldpage_user_bar.php</value>
|
||||||
|
<value>1400000000</value>
|
||||||
|
</row>
|
||||||
|
<row>
|
||||||
|
<value>5</value>
|
||||||
|
<value>foo</value>
|
||||||
|
<value></value>
|
||||||
|
<value></value>
|
||||||
|
<value>oldpage_user_foo.php</value>
|
||||||
|
<value>1400000000</value>
|
||||||
</row>
|
</row>
|
||||||
</table>
|
</table>
|
||||||
<table name="phpbb_sessions">
|
<table name="phpbb_sessions">
|
||||||
|
@ -18,12 +30,16 @@
|
||||||
<column>session_ip</column>
|
<column>session_ip</column>
|
||||||
<column>session_browser</column>
|
<column>session_browser</column>
|
||||||
<column>session_admin</column>
|
<column>session_admin</column>
|
||||||
|
<column>session_page</column>
|
||||||
|
<column>session_time</column>
|
||||||
<row>
|
<row>
|
||||||
<value>anon_session00000000000000000000</value>
|
<value>anon_session00000000000000000000</value>
|
||||||
<value>1</value>
|
<value>1</value>
|
||||||
<value>127.0.0.1</value>
|
<value>127.0.0.1</value>
|
||||||
<value>anonymous user agent</value>
|
<value>anonymous user agent</value>
|
||||||
<value>0</value>
|
<value>0</value>
|
||||||
|
<value></value>
|
||||||
|
<value>1500000005</value>
|
||||||
</row>
|
</row>
|
||||||
<row>
|
<row>
|
||||||
<value>bar_session000000000000000000000</value>
|
<value>bar_session000000000000000000000</value>
|
||||||
|
@ -31,6 +47,35 @@
|
||||||
<value>127.0.0.1</value>
|
<value>127.0.0.1</value>
|
||||||
<value>user agent</value>
|
<value>user agent</value>
|
||||||
<value>1</value>
|
<value>1</value>
|
||||||
|
<value>newpage_user_bar.php</value>
|
||||||
|
<value>1500000000</value>
|
||||||
|
</row>
|
||||||
|
<row>
|
||||||
|
<value>bar_session000000000000000000002</value>
|
||||||
|
<value>4</value>
|
||||||
|
<value>127.0.0.1</value>
|
||||||
|
<value>user agent</value>
|
||||||
|
<value>1</value>
|
||||||
|
<value>oldpage_user_bar.php</value>
|
||||||
|
<value>1400000000</value>
|
||||||
|
</row>
|
||||||
|
<row>
|
||||||
|
<value>foo_session000000000000000000000</value>
|
||||||
|
<value>5</value>
|
||||||
|
<value>127.0.0.1</value>
|
||||||
|
<value>user agent</value>
|
||||||
|
<value>0</value>
|
||||||
|
<value>newpage_user_foo.php</value>
|
||||||
|
<value>1500000000</value>
|
||||||
|
</row>
|
||||||
|
<row>
|
||||||
|
<value>foo_session000000000000000000002</value>
|
||||||
|
<value>5</value>
|
||||||
|
<value>127.0.0.1</value>
|
||||||
|
<value>user agent</value>
|
||||||
|
<value>0</value>
|
||||||
|
<value>oldpage_user_foo.php</value>
|
||||||
|
<value>1400000000</value>
|
||||||
</row>
|
</row>
|
||||||
</table>
|
</table>
|
||||||
<table name="phpbb_login_attempts">
|
<table name="phpbb_login_attempts">
|
||||||
|
|
|
@ -41,19 +41,91 @@ class phpbb_session_garbage_collection_test extends phpbb_session_test_case
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public function test_session_gc()
|
||||||
|
{
|
||||||
|
global $config;
|
||||||
|
$config['session_length'] = 3600;
|
||||||
|
|
||||||
|
$this->check_expired_sessions_recent(
|
||||||
|
[
|
||||||
|
[
|
||||||
|
'session_user_id' => 4,
|
||||||
|
'recent_time' => 1500000000,
|
||||||
|
],
|
||||||
|
[
|
||||||
|
'session_user_id' => 5,
|
||||||
|
'recent_time' => 1500000000,
|
||||||
|
],
|
||||||
|
],
|
||||||
|
'Before test, should get recent expired sessions only.'
|
||||||
|
);
|
||||||
|
|
||||||
|
$this->check_user_session_data(
|
||||||
|
[
|
||||||
|
[
|
||||||
|
'username_clean' => 'bar',
|
||||||
|
'user_lastvisit' => 1400000000,
|
||||||
|
'user_lastpage' => 'oldpage_user_bar.php',
|
||||||
|
],
|
||||||
|
[
|
||||||
|
'username_clean' => 'foo',
|
||||||
|
'user_lastvisit' => 1400000000,
|
||||||
|
'user_lastpage' => 'oldpage_user_foo.php',
|
||||||
|
],
|
||||||
|
],
|
||||||
|
'Before test, users session data is not updated yet.'
|
||||||
|
);
|
||||||
|
|
||||||
|
// There is an error unless the captcha plugin is set
|
||||||
|
$config['captcha_plugin'] = 'core.captcha.plugins.nogd';
|
||||||
|
$this->session->session_gc();
|
||||||
|
$this->check_expired_sessions_recent(
|
||||||
|
[],
|
||||||
|
'After garbage collection, all expired sessions should be removed.'
|
||||||
|
);
|
||||||
|
|
||||||
|
$this->check_user_session_data(
|
||||||
|
[
|
||||||
|
[
|
||||||
|
'username_clean' => 'bar',
|
||||||
|
'user_lastvisit' => '1500000000',
|
||||||
|
'user_lastpage' => 'newpage_user_bar.php',
|
||||||
|
],
|
||||||
|
[
|
||||||
|
'username_clean' => 'foo',
|
||||||
|
'user_lastvisit' => '1500000000',
|
||||||
|
'user_lastpage' => 'newpage_user_foo.php',
|
||||||
|
],
|
||||||
|
],
|
||||||
|
'After garbage collection, users session data should be updated to the recent expired sessions data.'
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
public function test_cleanup_all()
|
public function test_cleanup_all()
|
||||||
{
|
{
|
||||||
$this->check_sessions_equals(
|
$this->check_sessions_equals(
|
||||||
array(
|
[
|
||||||
array(
|
[
|
||||||
'session_id' => 'anon_session00000000000000000000',
|
'session_id' => 'anon_session00000000000000000000',
|
||||||
'session_user_id' => 1,
|
'session_user_id' => 1,
|
||||||
),
|
],
|
||||||
array(
|
[
|
||||||
'session_id' => 'bar_session000000000000000000000',
|
'session_id' => 'bar_session000000000000000000000',
|
||||||
'session_user_id' => 4,
|
'session_user_id' => 4,
|
||||||
),
|
],
|
||||||
),
|
[
|
||||||
|
'session_id' => 'bar_session000000000000000000002',
|
||||||
|
'session_user_id' => 4,
|
||||||
|
],
|
||||||
|
[
|
||||||
|
'session_id' => 'foo_session000000000000000000000',
|
||||||
|
'session_user_id' => 5,
|
||||||
|
],
|
||||||
|
[
|
||||||
|
'session_id' => 'foo_session000000000000000000002',
|
||||||
|
'session_user_id' => 5,
|
||||||
|
],
|
||||||
|
],
|
||||||
'Before test, should have some sessions.'
|
'Before test, should have some sessions.'
|
||||||
);
|
);
|
||||||
// Set session length so it clears all
|
// Set session length so it clears all
|
||||||
|
@ -63,7 +135,7 @@ class phpbb_session_garbage_collection_test extends phpbb_session_test_case
|
||||||
$config['captcha_plugin'] = 'core.captcha.plugins.nogd';
|
$config['captcha_plugin'] = 'core.captcha.plugins.nogd';
|
||||||
$this->session->session_gc();
|
$this->session->session_gc();
|
||||||
$this->check_sessions_equals(
|
$this->check_sessions_equals(
|
||||||
array(),
|
[],
|
||||||
'After setting session time to 0, should remove all.'
|
'After setting session time to 0, should remove all.'
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
|
@ -46,11 +46,33 @@ abstract class phpbb_session_test_case extends phpbb_database_test_case
|
||||||
new phpbb_session_testable_facade($this->db, $this->session_factory);
|
new phpbb_session_testable_facade($this->db, $this->session_factory);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
protected function check_user_session_data($expected_session_data, $message)
|
||||||
|
{
|
||||||
|
$sql= 'SELECT username_clean, user_lastvisit, user_lastpage
|
||||||
|
FROM ' . USERS_TABLE . '
|
||||||
|
ORDER BY user_id';
|
||||||
|
|
||||||
|
$this->assertSqlResultEquals($expected_session_data, $sql, $message);
|
||||||
|
}
|
||||||
|
|
||||||
|
protected function check_expired_sessions_recent($expected_sessions, $message)
|
||||||
|
{
|
||||||
|
global $config;
|
||||||
|
$time_now = time();
|
||||||
|
$sql = 'SELECT session_user_id, MAX(session_time) AS recent_time
|
||||||
|
FROM ' . SESSIONS_TABLE . '
|
||||||
|
WHERE session_time < ' . ($time_now - (int) $config['session_length']) . '
|
||||||
|
AND session_user_id <> ' . ANONYMOUS . '
|
||||||
|
GROUP BY session_user_id';
|
||||||
|
|
||||||
|
$this->assertSqlResultEquals($expected_sessions, $sql, $message);
|
||||||
|
}
|
||||||
|
|
||||||
protected function check_sessions_equals($expected_sessions, $message)
|
protected function check_sessions_equals($expected_sessions, $message)
|
||||||
{
|
{
|
||||||
$sql = 'SELECT session_id, session_user_id
|
$sql = 'SELECT session_id, session_user_id
|
||||||
FROM phpbb_sessions
|
FROM phpbb_sessions
|
||||||
ORDER BY session_user_id';
|
ORDER BY session_user_id, session_id';
|
||||||
|
|
||||||
$this->assertSqlResultEquals($expected_sessions, $sql, $message);
|
$this->assertSqlResultEquals($expected_sessions, $sql, $message);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Reference in a new issue