|
 |
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
*
|
|
|
ef5584 |
* @package acp
|
|
|
ef5584 |
* @version $Id: functions_admin.php 9065 2008-11-13 17:32:55Z toonarmy $
|
|
|
ef5584 |
* @copyright (c) 2005 phpBB Group
|
|
|
ef5584 |
* @license http://opensource.org/licenses/gpl-license.php GNU Public License
|
|
|
ef5584 |
*
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* @ignore
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
if (!defined('IN_PHPBB'))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
exit;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Recalculate Binary Tree
|
|
|
ef5584 |
function recalc_btree($sql_id, $sql_table, $module_class = '')
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db;
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!$sql_id || !$sql_table)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
return;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql_where = ($module_class) ? " WHERE module_class = '" . $db->sql_escape($module_class) . "'" : '';
|
|
|
ef5584 |
|
|
|
ef5584 |
// Reset to minimum possible left and right id
|
|
|
ef5584 |
$sql = "SELECT MIN(left_id) as min_left_id, MIN(right_id) as min_right_id
|
|
|
ef5584 |
FROM $sql_table
|
|
|
ef5584 |
$sql_where";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
$row = $db->sql_fetchrow($result);
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
$substract = (int) (min($row['min_left_id'], $row['min_right_id']) - 1);
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($substract > 0)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = "UPDATE $sql_table
|
|
|
ef5584 |
SET left_id = left_id - $substract, right_id = right_id - $substract
|
|
|
ef5584 |
$sql_where";
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = "SELECT $sql_id, parent_id, left_id, right_id
|
|
|
ef5584 |
FROM $sql_table
|
|
|
ef5584 |
$sql_where
|
|
|
ef5584 |
ORDER BY left_id ASC, parent_id ASC, $sql_id ASC";
|
|
|
ef5584 |
$f_result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($item_data = $db->sql_fetchrow($f_result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($item_data['parent_id'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = "SELECT left_id, right_id
|
|
|
ef5584 |
FROM $sql_table
|
|
|
ef5584 |
$sql_where " . (($sql_where) ? 'AND' : 'WHERE') . "
|
|
|
ef5584 |
$sql_id = {$item_data['parent_id']}";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!$row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = "UPDATE $sql_table SET parent_id = 0 WHERE $sql_id = " . $item_data[$sql_id];
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = "UPDATE $sql_table
|
|
|
ef5584 |
SET left_id = left_id + 2, right_id = right_id + 2
|
|
|
ef5584 |
$sql_where " . (($sql_where) ? 'AND' : 'WHERE') . "
|
|
|
ef5584 |
left_id > {$row['right_id']}";
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = "UPDATE $sql_table
|
|
|
ef5584 |
SET right_id = right_id + 2
|
|
|
ef5584 |
$sql_where " . (($sql_where) ? 'AND' : 'WHERE') . "
|
|
|
ef5584 |
{$row['left_id']} BETWEEN left_id AND right_id";
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$item_data['left_id'] = $row['right_id'];
|
|
|
ef5584 |
$item_data['right_id'] = $row['right_id'] + 1;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = "SELECT MAX(right_id) AS right_id
|
|
|
ef5584 |
FROM $sql_table
|
|
|
ef5584 |
$sql_where";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
$row = $db->sql_fetchrow($result);
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
$item_data['left_id'] = $row['right_id'] + 1;
|
|
|
ef5584 |
$item_data['right_id'] = $row['right_id'] + 2;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = "UPDATE $sql_table
|
|
|
ef5584 |
SET left_id = {$item_data['left_id']}, right_id = {$item_data['right_id']}
|
|
|
ef5584 |
WHERE $sql_id = " . $item_data[$sql_id];
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($f_result);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Simple version of jumpbox, just lists authed forums
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function make_forum_select($select_id = false, $ignore_id = false, $ignore_acl = false, $ignore_nonpost = false, $ignore_emptycat = true, $only_acl_post = false, $return_array = false)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db, $user, $auth;
|
|
|
ef5584 |
|
|
|
ef5584 |
$acl = ($ignore_acl) ? '' : (($only_acl_post) ? 'f_post' : array('f_list', 'a_forum', 'a_forumadd', 'a_forumdel'));
|
|
|
ef5584 |
|
|
|
ef5584 |
// This query is identical to the jumpbox one
|
|
|
ef5584 |
$sql = 'SELECT forum_id, forum_name, parent_id, forum_type, left_id, right_id
|
|
|
ef5584 |
FROM ' . FORUMS_TABLE . '
|
|
|
ef5584 |
ORDER BY left_id ASC';
|
|
|
ef5584 |
$result = $db->sql_query($sql, 600);
|
|
|
ef5584 |
|
|
|
ef5584 |
$right = 0;
|
|
|
ef5584 |
$padding_store = array('0' => '');
|
|
|
ef5584 |
$padding = '';
|
|
|
ef5584 |
$forum_list = ($return_array) ? array() : '';
|
|
|
ef5584 |
|
|
|
ef5584 |
// Sometimes it could happen that forums will be displayed here not be displayed within the index page
|
|
|
ef5584 |
// This is the result of forums not displayed at index, having list permissions and a parent of a forum with no permissions.
|
|
|
ef5584 |
// If this happens, the padding could be "broken"
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($row['left_id'] < $right)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$padding .= ' ';
|
|
|
ef5584 |
$padding_store[$row['parent_id']] = $padding;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else if ($row['left_id'] > $right + 1)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$padding = (isset($padding_store[$row['parent_id']])) ? $padding_store[$row['parent_id']] : '';
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$right = $row['right_id'];
|
|
|
ef5584 |
$disabled = false;
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($acl && !$auth->acl_gets($acl, $row['forum_id']))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// List permission?
|
|
|
ef5584 |
if ($auth->acl_get('f_list', $row['forum_id']))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$disabled = true;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
continue;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if (
|
|
|
ef5584 |
((is_array($ignore_id) && in_array($row['forum_id'], $ignore_id)) || $row['forum_id'] == $ignore_id)
|
|
|
ef5584 |
||
|
|
|
ef5584 |
// Non-postable forum with no subforums, don't display
|
|
|
ef5584 |
($row['forum_type'] == FORUM_CAT && ($row['left_id'] + 1 == $row['right_id']) && $ignore_emptycat)
|
|
|
ef5584 |
||
|
|
|
ef5584 |
($row['forum_type'] != FORUM_POST && $ignore_nonpost)
|
|
|
ef5584 |
)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$disabled = true;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($return_array)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// Include some more information...
|
|
|
ef5584 |
$selected = (is_array($select_id)) ? ((in_array($row['forum_id'], $select_id)) ? true : false) : (($row['forum_id'] == $select_id) ? true : false);
|
|
|
ef5584 |
$forum_list[$row['forum_id']] = array_merge(array('padding' => $padding, 'selected' => ($selected && !$disabled), 'disabled' => $disabled), $row);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$selected = (is_array($select_id)) ? ((in_array($row['forum_id'], $select_id)) ? ' selected="selected"' : '') : (($row['forum_id'] == $select_id) ? ' selected="selected"' : '');
|
|
|
ef5584 |
$forum_list .= '<option value="' . $row['forum_id'] . '"' . (($disabled) ? ' disabled="disabled" class="disabled-option"' : $selected) . '>' . $padding . $row['forum_name'] . '</option>';
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
unset($padding_store);
|
|
|
ef5584 |
|
|
|
ef5584 |
return $forum_list;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Generate size select options
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function size_select_options($size_compare)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $user;
|
|
|
ef5584 |
|
|
|
ef5584 |
$size_types_text = array($user->lang['BYTES'], $user->lang['KIB'], $user->lang['MIB']);
|
|
|
ef5584 |
$size_types = array('b', 'kb', 'mb');
|
|
|
ef5584 |
|
|
|
ef5584 |
$s_size_options = '';
|
|
|
ef5584 |
|
|
|
ef5584 |
for ($i = 0, $size = sizeof($size_types_text); $i < $size; $i++)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$selected = ($size_compare == $size_types[$i]) ? ' selected="selected"' : '';
|
|
|
ef5584 |
$s_size_options .= '<option value="' . $size_types[$i] . '"' . $selected . '>' . $size_types_text[$i] . '</option>';
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
return $s_size_options;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Generate list of groups (option fields without select)
|
|
|
ef5584 |
*
|
|
|
ef5584 |
* @param int $group_id The default group id to mark as selected
|
|
|
ef5584 |
* @param array $exclude_ids The group ids to exclude from the list, false (default) if you whish to exclude no id
|
|
|
ef5584 |
* @param int $manage_founder If set to false (default) all groups are returned, if 0 only those groups returned not being managed by founders only, if 1 only those groups returned managed by founders only.
|
|
|
ef5584 |
*
|
|
|
ef5584 |
* @return string The list of options.
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function group_select_options($group_id, $exclude_ids = false, $manage_founder = false)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db, $user, $config;
|
|
|
ef5584 |
|
|
|
ef5584 |
$exclude_sql = ($exclude_ids !== false && sizeof($exclude_ids)) ? 'WHERE ' . $db->sql_in_set('group_id', array_map('intval', $exclude_ids), true) : '';
|
|
|
ef5584 |
$sql_and = (!$config['coppa_enable']) ? (($exclude_sql) ? ' AND ' : ' WHERE ') . "group_name <> 'REGISTERED_COPPA'" : '';
|
|
|
ef5584 |
$sql_founder = ($manage_founder !== false) ? (($exclude_sql || $sql_and) ? ' AND ' : ' WHERE ') . 'group_founder_manage = ' . (int) $manage_founder : '';
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT group_id, group_name, group_type
|
|
|
ef5584 |
FROM ' . GROUPS_TABLE . "
|
|
|
ef5584 |
$exclude_sql
|
|
|
ef5584 |
$sql_and
|
|
|
ef5584 |
$sql_founder
|
|
|
ef5584 |
ORDER BY group_type DESC, group_name ASC";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$s_group_options = '';
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$selected = ($row['group_id'] == $group_id) ? ' selected="selected"' : '';
|
|
|
ef5584 |
$s_group_options .= '<option' . (($row['group_type'] == GROUP_SPECIAL) ? ' class="sep"' : '') . ' value="' . $row['group_id'] . '"' . $selected . '>' . (($row['group_type'] == GROUP_SPECIAL) ? $user->lang['G_' . $row['group_name']] : $row['group_name']) . '</option>';
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
return $s_group_options;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Obtain authed forums list
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function get_forum_list($acl_list = 'f_list', $id_only = true, $postable_only = false, $no_cache = false)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db, $auth;
|
|
|
ef5584 |
static $forum_rows;
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!isset($forum_rows))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// This query is identical to the jumpbox one
|
|
|
ef5584 |
$expire_time = ($no_cache) ? 0 : 600;
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT forum_id, forum_name, parent_id, forum_type, left_id, right_id
|
|
|
ef5584 |
FROM ' . FORUMS_TABLE . '
|
|
|
ef5584 |
ORDER BY left_id ASC';
|
|
|
ef5584 |
$result = $db->sql_query($sql, $expire_time);
|
|
|
ef5584 |
|
|
|
ef5584 |
$forum_rows = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
$right = $padding = 0;
|
|
|
ef5584 |
$padding_store = array('0' => 0);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($row['left_id'] < $right)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$padding++;
|
|
|
ef5584 |
$padding_store[$row['parent_id']] = $padding;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else if ($row['left_id'] > $right + 1)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// Ok, if the $padding_store for this parent is empty there is something wrong. For now we will skip over it.
|
|
|
ef5584 |
// @todo digging deep to find out "how" this can happen.
|
|
|
ef5584 |
$padding = (isset($padding_store[$row['parent_id']])) ? $padding_store[$row['parent_id']] : $padding;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$right = $row['right_id'];
|
|
|
ef5584 |
$row['padding'] = $padding;
|
|
|
ef5584 |
|
|
|
ef5584 |
$forum_rows[] = $row;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
unset($padding_store);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$rowset = array();
|
|
|
ef5584 |
foreach ($forum_rows as $row)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($postable_only && $row['forum_type'] != FORUM_POST)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
continue;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($acl_list == '' || ($acl_list != '' && $auth->acl_gets($acl_list, $row['forum_id'])))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$rowset[] = ($id_only) ? $row['forum_id'] : $row;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
return $rowset;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Get forum branch
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function get_forum_branch($forum_id, $type = 'all', $order = 'descending', $include_forum = true)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db;
|
|
|
ef5584 |
|
|
|
ef5584 |
switch ($type)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
case 'parents':
|
|
|
ef5584 |
$condition = 'f1.left_id BETWEEN f2.left_id AND f2.right_id';
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'children':
|
|
|
ef5584 |
$condition = 'f2.left_id BETWEEN f1.left_id AND f1.right_id';
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
default:
|
|
|
ef5584 |
$condition = 'f2.left_id BETWEEN f1.left_id AND f1.right_id OR f1.left_id BETWEEN f2.left_id AND f2.right_id';
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$rows = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT f2.*
|
|
|
ef5584 |
FROM ' . FORUMS_TABLE . ' f1
|
|
|
ef5584 |
LEFT JOIN ' . FORUMS_TABLE . " f2 ON ($condition)
|
|
|
ef5584 |
WHERE f1.forum_id = $forum_id
|
|
|
ef5584 |
ORDER BY f2.left_id " . (($order == 'descending') ? 'ASC' : 'DESC');
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (!$include_forum && $row['forum_id'] == $forum_id)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
continue;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$rows[] = $row;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
return $rows;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Get physical file listing
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function filelist($rootdir, $dir = '', $type = 'gif|jpg|jpeg|png')
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$matches = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
// Remove initial / if present
|
|
|
ef5584 |
$rootdir = (substr($rootdir, 0, 1) == '/') ? substr($rootdir, 1) : $rootdir;
|
|
|
ef5584 |
// Add closing / if not present
|
|
|
ef5584 |
$rootdir = ($rootdir && substr($rootdir, -1) != '/') ? $rootdir . '/' : $rootdir;
|
|
|
ef5584 |
|
|
|
ef5584 |
// Remove initial / if present
|
|
|
ef5584 |
$dir = (substr($dir, 0, 1) == '/') ? substr($dir, 1) : $dir;
|
|
|
ef5584 |
// Add closing / if not present
|
|
|
ef5584 |
$dir = ($dir && substr($dir, -1) != '/') ? $dir . '/' : $dir;
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!is_dir($rootdir . $dir))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
return $matches;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$dh = @opendir($rootdir . $dir);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!$dh)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
return $matches;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
while (($fname = readdir($dh)) !== false)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (is_file("$rootdir$dir$fname"))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (filesize("$rootdir$dir$fname") && preg_match('#\.' . $type . '$#i', $fname))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$matches[$dir][] = $fname;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else if ($fname[0] != '.' && is_dir("$rootdir$dir$fname"))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$matches += filelist($rootdir, "$dir$fname", $type);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
closedir($dh);
|
|
|
ef5584 |
|
|
|
ef5584 |
return $matches;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Move topic(s)
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function move_topics($topic_ids, $forum_id, $auto_sync = true)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db;
|
|
|
ef5584 |
|
|
|
ef5584 |
if (empty($topic_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
return;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$forum_ids = array($forum_id);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!is_array($topic_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_ids = array($topic_ids);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'DELETE FROM ' . TOPICS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('topic_moved_id', $topic_ids) . '
|
|
|
ef5584 |
AND forum_id = ' . $forum_id;
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($auto_sync)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'SELECT DISTINCT forum_id
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('topic_id', $topic_ids);
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$forum_ids[] = $row['forum_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$table_ary = array(TOPICS_TABLE, POSTS_TABLE, LOG_TABLE, DRAFTS_TABLE, TOPICS_TRACK_TABLE);
|
|
|
ef5584 |
foreach ($table_ary as $table)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = "UPDATE $table
|
|
|
ef5584 |
SET forum_id = $forum_id
|
|
|
ef5584 |
WHERE " . $db->sql_in_set('topic_id', $topic_ids);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
unset($table_ary);
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($auto_sync)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
sync('forum', 'forum_id', $forum_ids, true, true);
|
|
|
ef5584 |
unset($forum_ids);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Move post(s)
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function move_posts($post_ids, $topic_id, $auto_sync = true)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db;
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!is_array($post_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$post_ids = array($post_ids);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$forum_ids = array();
|
|
|
ef5584 |
$topic_ids = array($topic_id);
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT DISTINCT topic_id, forum_id
|
|
|
ef5584 |
FROM ' . POSTS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('post_id', $post_ids);
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$forum_ids[] = $row['forum_id'];
|
|
|
ef5584 |
$topic_ids[] = $row['topic_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT forum_id
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . '
|
|
|
ef5584 |
WHERE topic_id = ' . $topic_id;
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
$forum_row = $db->sql_fetchrow($result);
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!$forum_row)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
trigger_error('NO_TOPIC');
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'UPDATE ' . POSTS_TABLE . '
|
|
|
ef5584 |
SET forum_id = ' . $forum_row['forum_id'] . ", topic_id = $topic_id
|
|
|
ef5584 |
WHERE " . $db->sql_in_set('post_id', $post_ids);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'UPDATE ' . ATTACHMENTS_TABLE . "
|
|
|
ef5584 |
SET topic_id = $topic_id, in_message = 0
|
|
|
ef5584 |
WHERE " . $db->sql_in_set('post_msg_id', $post_ids);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($auto_sync)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$forum_ids[] = $forum_row['forum_id'];
|
|
|
ef5584 |
|
|
|
ef5584 |
sync('topic_reported', 'topic_id', $topic_ids);
|
|
|
ef5584 |
sync('topic_attachment', 'topic_id', $topic_ids);
|
|
|
ef5584 |
sync('topic', 'topic_id', $topic_ids, true);
|
|
|
ef5584 |
sync('forum', 'forum_id', $forum_ids, true, true);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// Update posted information
|
|
|
ef5584 |
update_posted_info($topic_ids);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Remove topic(s)
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function delete_topics($where_type, $where_ids, $auto_sync = true, $post_count_sync = true, $call_delete_posts = true)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db, $config;
|
|
|
ef5584 |
|
|
|
ef5584 |
$approved_topics = 0;
|
|
|
ef5584 |
$forum_ids = $topic_ids = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($where_type === 'range')
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$where_clause = $where_ids;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$where_ids = (is_array($where_ids)) ? array_unique($where_ids) : array($where_ids);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!sizeof($where_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
return array('topics' => 0, 'posts' => 0);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$where_clause = $db->sql_in_set($where_type, $where_ids);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// Making sure that delete_posts does not call delete_topics again...
|
|
|
ef5584 |
$return = array(
|
|
|
ef5584 |
'posts' => ($call_delete_posts) ? delete_posts($where_type, $where_ids, false, true, $post_count_sync, false) : 0,
|
|
|
ef5584 |
);
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT topic_id, forum_id, topic_approved, topic_moved_id
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $where_clause;
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$forum_ids[] = $row['forum_id'];
|
|
|
ef5584 |
$topic_ids[] = $row['topic_id'];
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($row['topic_approved'] && !$row['topic_moved_id'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$approved_topics++;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
$return['topics'] = sizeof($topic_ids);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!sizeof($topic_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
return $return;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$db->sql_transaction('begin');
|
|
|
ef5584 |
|
|
|
ef5584 |
$table_ary = array(TOPICS_TRACK_TABLE, TOPICS_POSTED_TABLE, POLL_VOTES_TABLE, POLL_OPTIONS_TABLE, TOPICS_WATCH_TABLE, TOPICS_TABLE);
|
|
|
ef5584 |
|
|
|
ef5584 |
foreach ($table_ary as $table)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = "DELETE FROM $table
|
|
|
ef5584 |
WHERE " . $db->sql_in_set('topic_id', $topic_ids);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
unset($table_ary);
|
|
|
ef5584 |
|
|
|
ef5584 |
$moved_topic_ids = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
// update the other forums
|
|
|
ef5584 |
$sql = 'SELECT topic_id, forum_id
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('topic_moved_id', $topic_ids);
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$forum_ids[] = $row['forum_id'];
|
|
|
ef5584 |
$moved_topic_ids[] = $row['topic_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (sizeof($moved_topic_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'DELETE FROM ' . TOPICS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('topic_id', $moved_topic_ids);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$db->sql_transaction('commit');
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($auto_sync)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
sync('forum', 'forum_id', array_unique($forum_ids), true, true);
|
|
|
ef5584 |
sync('topic_reported', $where_type, $where_ids);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($approved_topics)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
set_config('num_topics', $config['num_topics'] - $approved_topics, true);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
return $return;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Remove post(s)
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function delete_posts($where_type, $where_ids, $auto_sync = true, $posted_sync = true, $post_count_sync = true, $call_delete_topics = true)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db, $config, $phpbb_root_path, $phpEx;
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($where_type === 'range')
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$where_clause = $where_ids;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (is_array($where_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$where_ids = array_unique($where_ids);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$where_ids = array($where_ids);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!sizeof($where_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
return false;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$where_clause = $db->sql_in_set($where_type, array_map('intval', $where_ids));
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$approved_posts = 0;
|
|
|
ef5584 |
$post_ids = $topic_ids = $forum_ids = $post_counts = $remove_topics = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT post_id, poster_id, post_approved, post_postcount, topic_id, forum_id
|
|
|
ef5584 |
FROM ' . POSTS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $where_clause;
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$post_ids[] = $row['post_id'];
|
|
|
ef5584 |
$poster_ids[] = $row['poster_id'];
|
|
|
ef5584 |
$topic_ids[] = $row['topic_id'];
|
|
|
ef5584 |
$forum_ids[] = $row['forum_id'];
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($row['post_postcount'] && $post_count_sync && $row['post_approved'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$post_counts[$row['poster_id']] = (!empty($post_counts[$row['poster_id']])) ? $post_counts[$row['poster_id']] + 1 : 1;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($row['post_approved'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$approved_posts++;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!sizeof($post_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
return false;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$db->sql_transaction('begin');
|
|
|
ef5584 |
|
|
|
ef5584 |
$table_ary = array(POSTS_TABLE, REPORTS_TABLE);
|
|
|
ef5584 |
|
|
|
ef5584 |
foreach ($table_ary as $table)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = "DELETE FROM $table
|
|
|
ef5584 |
WHERE " . $db->sql_in_set('post_id', $post_ids);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
unset($table_ary);
|
|
|
ef5584 |
|
|
|
ef5584 |
// Adjust users post counts
|
|
|
ef5584 |
if (sizeof($post_counts) && $post_count_sync)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
foreach ($post_counts as $poster_id => $substract)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'UPDATE ' . USERS_TABLE . '
|
|
|
ef5584 |
SET user_posts = 0
|
|
|
ef5584 |
WHERE user_id = ' . $poster_id . '
|
|
|
ef5584 |
AND user_posts < ' . $substract;
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'UPDATE ' . USERS_TABLE . '
|
|
|
ef5584 |
SET user_posts = user_posts - ' . $substract . '
|
|
|
ef5584 |
WHERE user_id = ' . $poster_id . '
|
|
|
ef5584 |
AND user_posts >= ' . $substract;
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// Remove topics now having no posts?
|
|
|
ef5584 |
if (sizeof($topic_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'SELECT topic_id
|
|
|
ef5584 |
FROM ' . POSTS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('topic_id', $topic_ids) . '
|
|
|
ef5584 |
GROUP BY topic_id';
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$remove_topics[] = $row['topic_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
// Actually, those not within remove_topics should be removed. ;)
|
|
|
ef5584 |
$remove_topics = array_diff($topic_ids, $remove_topics);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// Remove the message from the search index
|
|
|
ef5584 |
$search_type = basename($config['search_type']);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!file_exists($phpbb_root_path . 'includes/search/' . $search_type . '.' . $phpEx))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
trigger_error('NO_SUCH_SEARCH_MODULE');
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
include_once("{$phpbb_root_path}includes/search/$search_type.$phpEx");
|
|
|
ef5584 |
|
|
|
ef5584 |
$error = false;
|
|
|
ef5584 |
$search = new $search_type($error);
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($error)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
trigger_error($error);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$search->index_remove($post_ids, $poster_ids, $forum_ids);
|
|
|
ef5584 |
|
|
|
ef5584 |
delete_attachments('post', $post_ids, false);
|
|
|
ef5584 |
|
|
|
ef5584 |
$db->sql_transaction('commit');
|
|
|
ef5584 |
|
|
|
ef5584 |
// Resync topics_posted table
|
|
|
ef5584 |
if ($posted_sync)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
update_posted_info($topic_ids);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($auto_sync)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
sync('topic_reported', 'topic_id', $topic_ids);
|
|
|
ef5584 |
sync('topic', 'topic_id', $topic_ids, true);
|
|
|
ef5584 |
sync('forum', 'forum_id', $forum_ids, true, true);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($approved_posts)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
set_config('num_posts', $config['num_posts'] - $approved_posts, true);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// We actually remove topics now to not be inconsistent (the delete_topics function calls this function too)
|
|
|
ef5584 |
if (sizeof($remove_topics) && $call_delete_topics)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
delete_topics('topic_id', $remove_topics, $auto_sync, $post_count_sync, false);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
return sizeof($post_ids);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Delete Attachments
|
|
|
ef5584 |
*
|
|
|
ef5584 |
* @param string $mode can be: post|message|topic|attach|user
|
|
|
ef5584 |
* @param mixed $ids can be: post_ids, message_ids, topic_ids, attach_ids, user_ids
|
|
|
ef5584 |
* @param bool $resync set this to false if you are deleting posts or topics
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function delete_attachments($mode, $ids, $resync = true)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db, $config;
|
|
|
ef5584 |
|
|
|
ef5584 |
if (is_array($ids) && sizeof($ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$ids = array_unique($ids);
|
|
|
ef5584 |
$ids = array_map('intval', $ids);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$ids = array((int) $ids);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!sizeof($ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
return false;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
switch ($mode)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
case 'post':
|
|
|
ef5584 |
case 'message':
|
|
|
ef5584 |
$sql_id = 'post_msg_id';
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'topic':
|
|
|
ef5584 |
$sql_id = 'topic_id';
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'user':
|
|
|
ef5584 |
$sql_id = 'poster_id';
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'attach':
|
|
|
ef5584 |
default:
|
|
|
ef5584 |
$sql_id = 'attach_id';
|
|
|
ef5584 |
$mode = 'attach';
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$post_ids = $message_ids = $topic_ids = $physical = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
// Collect post and topic ids for later use if we need to touch remaining entries (if resync is enabled)
|
|
|
ef5584 |
$sql = 'SELECT post_msg_id, topic_id, in_message, physical_filename, thumbnail, filesize, is_orphan
|
|
|
ef5584 |
FROM ' . ATTACHMENTS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set($sql_id, $ids);
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// We only need to store post/message/topic ids if resync is enabled and the file is not orphaned
|
|
|
ef5584 |
if ($resync && !$row['is_orphan'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (!$row['in_message'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$post_ids[] = $row['post_msg_id'];
|
|
|
ef5584 |
$topic_ids[] = $row['topic_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$message_ids[] = $row['post_msg_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$physical[] = array('filename' => $row['physical_filename'], 'thumbnail' => $row['thumbnail'], 'filesize' => $row['filesize'], 'is_orphan' => $row['is_orphan']);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
// Delete attachments
|
|
|
ef5584 |
$sql = 'DELETE FROM ' . ATTACHMENTS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set($sql_id, $ids);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
$num_deleted = $db->sql_affectedrows();
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!$num_deleted)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
return 0;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// Delete attachments from filesystem
|
|
|
ef5584 |
$space_removed = $files_removed = 0;
|
|
|
ef5584 |
foreach ($physical as $file_ary)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (phpbb_unlink($file_ary['filename'], 'file', true) && !$file_ary['is_orphan'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// Only non-orphaned files count to the file size
|
|
|
ef5584 |
$space_removed += $file_ary['filesize'];
|
|
|
ef5584 |
$files_removed++;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($file_ary['thumbnail'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
phpbb_unlink($file_ary['filename'], 'thumbnail', true);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($space_removed || $files_removed)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
set_config('upload_dir_size', $config['upload_dir_size'] - $space_removed, true);
|
|
|
ef5584 |
set_config('num_files', $config['num_files'] - $files_removed, true);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// If we do not resync, we do not need to adjust any message, post, topic or user entries
|
|
|
ef5584 |
if (!$resync)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
return $num_deleted;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// No more use for the original ids
|
|
|
ef5584 |
unset($ids);
|
|
|
ef5584 |
|
|
|
ef5584 |
// Now, we need to resync posts, messages, topics. We go through every one of them
|
|
|
ef5584 |
$post_ids = array_unique($post_ids);
|
|
|
ef5584 |
$message_ids = array_unique($message_ids);
|
|
|
ef5584 |
$topic_ids = array_unique($topic_ids);
|
|
|
ef5584 |
|
|
|
ef5584 |
// Update post indicators for posts now no longer having attachments
|
|
|
ef5584 |
if (sizeof($post_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'UPDATE ' . POSTS_TABLE . '
|
|
|
ef5584 |
SET post_attachment = 0
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('post_id', $post_ids);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// Update message table if messages are affected
|
|
|
ef5584 |
if (sizeof($message_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'UPDATE ' . PRIVMSGS_TABLE . '
|
|
|
ef5584 |
SET message_attachment = 0
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('msg_id', $message_ids);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// Now update the topics. This is a bit trickier, because there could be posts still having attachments within the topic
|
|
|
ef5584 |
if (sizeof($topic_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// Just check which topics are still having an assigned attachment not orphaned by querying the attachments table (much less entries expected)
|
|
|
ef5584 |
$sql = 'SELECT topic_id
|
|
|
ef5584 |
FROM ' . ATTACHMENTS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('topic_id', $topic_ids) . '
|
|
|
ef5584 |
AND is_orphan = 0';
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$remaining_ids = array();
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$remaining_ids[] = $row['topic_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
// Now only unset those ids remaining
|
|
|
ef5584 |
$topic_ids = array_diff($topic_ids, $remaining_ids);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (sizeof($topic_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'UPDATE ' . TOPICS_TABLE . '
|
|
|
ef5584 |
SET topic_attachment = 0
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('topic_id', $topic_ids);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
return $num_deleted;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Remove topic shadows
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function delete_topic_shadows($max_age, $forum_id = '', $auto_sync = true)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$where = (is_array($forum_id)) ? 'AND ' . $db->sql_in_set('t.forum_id', array_map('intval', $forum_id)) : (($forum_id) ? 'AND t.forum_id = ' . (int) $forum_id : '');
|
|
|
ef5584 |
|
|
|
ef5584 |
switch ($db->sql_layer)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
case 'mysql4':
|
|
|
ef5584 |
case 'mysqli':
|
|
|
ef5584 |
$sql = 'DELETE t.*
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . ' t, ' . TOPICS_TABLE . ' t2
|
|
|
ef5584 |
WHERE t.topic_moved_id = t2.topic_id
|
|
|
ef5584 |
AND t.topic_time < ' . (time() - $max_age)
|
|
|
ef5584 |
. $where;
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
default:
|
|
|
ef5584 |
$sql = 'SELECT t.topic_id
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . ' t, ' . TOPICS_TABLE . ' t2
|
|
|
ef5584 |
WHERE t.topic_moved_id = t2.topic_id
|
|
|
ef5584 |
AND t.topic_time < ' . (time() - $max_age)
|
|
|
ef5584 |
. $where;
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$topic_ids = array();
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_ids[] = $row['topic_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (sizeof($topic_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'DELETE FROM ' . TOPICS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('topic_id', $topic_ids);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($auto_sync)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$where_type = ($forum_id) ? 'forum_id' : '';
|
|
|
ef5584 |
sync('forum', $where_type, $forum_id, true, true);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Update/Sync posted information for topics
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function update_posted_info(&$topic_ids)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db, $config;
|
|
|
ef5584 |
|
|
|
ef5584 |
if (empty($topic_ids) || !$config['load_db_track'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
return;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// First of all, let us remove any posted information for these topics
|
|
|
ef5584 |
$sql = 'DELETE FROM ' . TOPICS_POSTED_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('topic_id', $topic_ids);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
// Now, let us collect the user/topic combos for rebuilding the information
|
|
|
ef5584 |
$sql = 'SELECT poster_id, topic_id
|
|
|
ef5584 |
FROM ' . POSTS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('topic_id', $topic_ids) . '
|
|
|
ef5584 |
AND poster_id <> ' . ANONYMOUS . '
|
|
|
ef5584 |
GROUP BY poster_id, topic_id';
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$posted = array();
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// Add as key to make them unique (grouping by) and circumvent empty keys on array_unique
|
|
|
ef5584 |
$posted[$row['poster_id']][] = $row['topic_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
// Now add the information...
|
|
|
ef5584 |
$sql_ary = array();
|
|
|
ef5584 |
foreach ($posted as $user_id => $topic_row)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
foreach ($topic_row as $topic_id)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql_ary[] = array(
|
|
|
ef5584 |
'user_id' => (int) $user_id,
|
|
|
ef5584 |
'topic_id' => (int) $topic_id,
|
|
|
ef5584 |
'topic_posted' => 1,
|
|
|
ef5584 |
);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
unset($posted);
|
|
|
ef5584 |
|
|
|
ef5584 |
$db->sql_multi_insert(TOPICS_POSTED_TABLE, $sql_ary);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Delete attached file
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function phpbb_unlink($filename, $mode = 'file', $entry_removed = false)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db, $phpbb_root_path, $config;
|
|
|
ef5584 |
|
|
|
ef5584 |
// Because of copying topics or modifications a physical filename could be assigned more than once. If so, do not remove the file itself.
|
|
|
ef5584 |
$sql = 'SELECT COUNT(attach_id) AS num_entries
|
|
|
ef5584 |
FROM ' . ATTACHMENTS_TABLE . "
|
|
|
ef5584 |
WHERE physical_filename = '" . $db->sql_escape(basename($filename)) . "'";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
$num_entries = (int) $db->sql_fetchfield('num_entries');
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
// Do not remove file if at least one additional entry with the same name exist.
|
|
|
ef5584 |
if (($entry_removed && $num_entries > 0) || (!$entry_removed && $num_entries > 1))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
return false;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$filename = ($mode == 'thumbnail') ? 'thumb_' . basename($filename) : basename($filename);
|
|
|
ef5584 |
return @unlink($phpbb_root_path . $config['upload_path'] . '/' . $filename);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* All-encompasing sync function
|
|
|
ef5584 |
*
|
|
|
ef5584 |
* Exaples:
|
|
|
ef5584 |
*
|
|
|
ef5584 |
* sync('topic', 'topic_id', 123); // resync topic #123
|
|
|
ef5584 |
* sync('topic', 'forum_id', array(2, 3)); // resync topics from forum #2 and #3
|
|
|
ef5584 |
* sync('topic'); // resync all topics
|
|
|
ef5584 |
* sync('topic', 'range', 'topic_id BETWEEN 1 AND 60'); // resync a range of topics/forums (only available for 'topic' and 'forum' modes)
|
|
|
ef5584 |
*
|
|
|
ef5584 |
*
|
|
|
ef5584 |
* Modes:
|
|
|
ef5584 |
* - forum Resync complete forum
|
|
|
ef5584 |
* - topic Resync topics
|
|
|
ef5584 |
* - topic_moved Removes topic shadows that would be in the same forum as the topic they link to
|
|
|
ef5584 |
* - topic_approved Resyncs the topic_approved flag according to the status of the first post
|
|
|
ef5584 |
* - post_reported Resyncs the post_reported flag, relying on actual reports
|
|
|
ef5584 |
* - topic_reported Resyncs the topic_reported flag, relying on post_reported flags
|
|
|
ef5584 |
* - post_attachement Same as post_reported, but with attachment flags
|
|
|
ef5584 |
* - topic_attachement Same as topic_reported, but with attachment flags
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function sync($mode, $where_type = '', $where_ids = '', $resync_parents = false, $sync_extra = false)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db;
|
|
|
ef5584 |
|
|
|
ef5584 |
if (is_array($where_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$where_ids = array_unique($where_ids);
|
|
|
ef5584 |
$where_ids = array_map('intval', $where_ids);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else if ($where_type != 'range')
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$where_ids = ($where_ids) ? array((int) $where_ids) : array();
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($mode == 'forum' || $mode == 'topic' || $mode == 'topic_approved' || $mode == 'topic_reported' || $mode == 'post_reported')
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (!$where_type)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$where_sql = '';
|
|
|
ef5584 |
$where_sql_and = 'WHERE';
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else if ($where_type == 'range')
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// Only check a range of topics/forums. For instance: 'topic_id BETWEEN 1 AND 60'
|
|
|
ef5584 |
$where_sql = 'WHERE (' . $mode[0] . ".$where_ids)";
|
|
|
ef5584 |
$where_sql_and = $where_sql . "\n\tAND";
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// Do not sync the "global forum"
|
|
|
ef5584 |
$where_ids = array_diff($where_ids, array(0));
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!sizeof($where_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// Empty array with IDs. This means that we don't have any work to do. Just return.
|
|
|
ef5584 |
return;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// Limit the topics/forums we are syncing, use specific topic/forum IDs.
|
|
|
ef5584 |
// $where_type contains the field for the where clause (forum_id, topic_id)
|
|
|
ef5584 |
$where_sql = 'WHERE ' . $db->sql_in_set($mode[0] . '.' . $where_type, $where_ids);
|
|
|
ef5584 |
$where_sql_and = $where_sql . "\n\tAND";
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (!sizeof($where_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
return;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// $where_type contains the field for the where clause (forum_id, topic_id)
|
|
|
ef5584 |
$where_sql = 'WHERE ' . $db->sql_in_set($mode[0] . '.' . $where_type, $where_ids);
|
|
|
ef5584 |
$where_sql_and = $where_sql . "\n\tAND";
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
switch ($mode)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
case 'topic_moved':
|
|
|
ef5584 |
switch ($db->sql_layer)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
case 'mysql4':
|
|
|
ef5584 |
case 'mysqli':
|
|
|
ef5584 |
$sql = 'DELETE FROM ' . TOPICS_TABLE . '
|
|
|
ef5584 |
USING ' . TOPICS_TABLE . ' t1, ' . TOPICS_TABLE . " t2
|
|
|
ef5584 |
WHERE t1.topic_moved_id = t2.topic_id
|
|
|
ef5584 |
AND t1.forum_id = t2.forum_id";
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
default:
|
|
|
ef5584 |
$sql = 'SELECT t1.topic_id
|
|
|
ef5584 |
FROM ' .TOPICS_TABLE . ' t1, ' . TOPICS_TABLE . " t2
|
|
|
ef5584 |
WHERE t1.topic_moved_id = t2.topic_id
|
|
|
ef5584 |
AND t1.forum_id = t2.forum_id";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$topic_id_ary = array();
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_id_ary[] = $row['topic_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!sizeof($topic_id_ary))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
return;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'DELETE FROM ' . TOPICS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('topic_id', $topic_id_ary);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'topic_approved':
|
|
|
ef5584 |
switch ($db->sql_layer)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
case 'mysql4':
|
|
|
ef5584 |
case 'mysqli':
|
|
|
ef5584 |
$sql = 'UPDATE ' . TOPICS_TABLE . ' t, ' . POSTS_TABLE . " p
|
|
|
ef5584 |
SET t.topic_approved = p.post_approved
|
|
|
ef5584 |
$where_sql_and t.topic_first_post_id = p.post_id";
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
default:
|
|
|
ef5584 |
$sql = 'SELECT t.topic_id, p.post_approved
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . ' t, ' . POSTS_TABLE . " p
|
|
|
ef5584 |
$where_sql_and p.post_id = t.topic_first_post_id
|
|
|
ef5584 |
AND p.post_approved <> t.topic_approved";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$topic_ids = array();
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_ids[] = $row['topic_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!sizeof($topic_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
return;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'UPDATE ' . TOPICS_TABLE . '
|
|
|
ef5584 |
SET topic_approved = 1 - topic_approved
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('topic_id', $topic_ids);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'post_reported':
|
|
|
ef5584 |
$post_ids = $post_reported = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT p.post_id, p.post_reported
|
|
|
ef5584 |
FROM ' . POSTS_TABLE . " p
|
|
|
ef5584 |
$where_sql
|
|
|
ef5584 |
GROUP BY p.post_id, p.post_reported";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$post_ids[$row['post_id']] = $row['post_id'];
|
|
|
ef5584 |
if ($row['post_reported'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$post_reported[$row['post_id']] = 1;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT DISTINCT(post_id)
|
|
|
ef5584 |
FROM ' . REPORTS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('post_id', $post_ids) . '
|
|
|
ef5584 |
AND report_closed = 0';
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$post_ids = array();
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (!isset($post_reported[$row['post_id']]))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$post_ids[] = $row['post_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
unset($post_reported[$row['post_id']]);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
// $post_reported should be empty by now, if it's not it contains
|
|
|
ef5584 |
// posts that are falsely flagged as reported
|
|
|
ef5584 |
foreach ($post_reported as $post_id => $void)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$post_ids[] = $post_id;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if (sizeof($post_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'UPDATE ' . POSTS_TABLE . '
|
|
|
ef5584 |
SET post_reported = 1 - post_reported
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('post_id', $post_ids);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'topic_reported':
|
|
|
ef5584 |
if ($sync_extra)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
sync('post_reported', $where_type, $where_ids);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$topic_ids = $topic_reported = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT DISTINCT(t.topic_id)
|
|
|
ef5584 |
FROM ' . POSTS_TABLE . " t
|
|
|
ef5584 |
$where_sql_and t.post_reported = 1";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_reported[$row['topic_id']] = 1;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT t.topic_id, t.topic_reported
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . " t
|
|
|
ef5584 |
$where_sql";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($row['topic_reported'] ^ isset($topic_reported[$row['topic_id']]))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_ids[] = $row['topic_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (sizeof($topic_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'UPDATE ' . TOPICS_TABLE . '
|
|
|
ef5584 |
SET topic_reported = 1 - topic_reported
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('topic_id', $topic_ids);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'post_attachment':
|
|
|
ef5584 |
$post_ids = $post_attachment = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT p.post_id, p.post_attachment
|
|
|
ef5584 |
FROM ' . POSTS_TABLE . " p
|
|
|
ef5584 |
$where_sql
|
|
|
ef5584 |
GROUP BY p.post_id, p.post_attachment";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$post_ids[$row['post_id']] = $row['post_id'];
|
|
|
ef5584 |
if ($row['post_attachment'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$post_attachment[$row['post_id']] = 1;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT DISTINCT(post_msg_id)
|
|
|
ef5584 |
FROM ' . ATTACHMENTS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('post_msg_id', $post_ids) . '
|
|
|
ef5584 |
AND in_message = 0';
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$post_ids = array();
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (!isset($post_attachment[$row['post_msg_id']]))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$post_ids[] = $row['post_msg_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
unset($post_attachment[$row['post_msg_id']]);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
// $post_attachment should be empty by now, if it's not it contains
|
|
|
ef5584 |
// posts that are falsely flagged as having attachments
|
|
|
ef5584 |
foreach ($post_attachment as $post_id => $void)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$post_ids[] = $post_id;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if (sizeof($post_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'UPDATE ' . POSTS_TABLE . '
|
|
|
ef5584 |
SET post_attachment = 1 - post_attachment
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('post_id', $post_ids);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'topic_attachment':
|
|
|
ef5584 |
if ($sync_extra)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
sync('post_attachment', $where_type, $where_ids);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$topic_ids = $topic_attachment = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT DISTINCT(t.topic_id)
|
|
|
ef5584 |
FROM ' . POSTS_TABLE . " t
|
|
|
ef5584 |
$where_sql_and t.post_attachment = 1";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_attachment[$row['topic_id']] = 1;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT t.topic_id, t.topic_attachment
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . " t
|
|
|
ef5584 |
$where_sql";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($row['topic_attachment'] ^ isset($topic_attachment[$row['topic_id']]))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_ids[] = $row['topic_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (sizeof($topic_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'UPDATE ' . TOPICS_TABLE . '
|
|
|
ef5584 |
SET topic_attachment = 1 - topic_attachment
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('topic_id', $topic_ids);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'forum':
|
|
|
ef5584 |
|
|
|
ef5584 |
// 1: Get the list of all forums
|
|
|
ef5584 |
$sql = 'SELECT f.*
|
|
|
ef5584 |
FROM ' . FORUMS_TABLE . " f
|
|
|
ef5584 |
$where_sql";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$forum_data = $forum_ids = $post_ids = $last_post_id = $post_info = array();
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($row['forum_type'] == FORUM_LINK)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
continue;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$forum_id = (int) $row['forum_id'];
|
|
|
ef5584 |
$forum_ids[$forum_id] = $forum_id;
|
|
|
ef5584 |
|
|
|
ef5584 |
$forum_data[$forum_id] = $row;
|
|
|
ef5584 |
if ($sync_extra)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$forum_data[$forum_id]['posts'] = 0;
|
|
|
ef5584 |
$forum_data[$forum_id]['topics'] = 0;
|
|
|
ef5584 |
$forum_data[$forum_id]['topics_real'] = 0;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$forum_data[$forum_id]['last_post_id'] = 0;
|
|
|
ef5584 |
$forum_data[$forum_id]['last_post_subject'] = '';
|
|
|
ef5584 |
$forum_data[$forum_id]['last_post_time'] = 0;
|
|
|
ef5584 |
$forum_data[$forum_id]['last_poster_id'] = 0;
|
|
|
ef5584 |
$forum_data[$forum_id]['last_poster_name'] = '';
|
|
|
ef5584 |
$forum_data[$forum_id]['last_poster_colour'] = '';
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!sizeof($forum_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$forum_ids = array_values($forum_ids);
|
|
|
ef5584 |
|
|
|
ef5584 |
// 2: Get topic counts for each forum (optional)
|
|
|
ef5584 |
if ($sync_extra)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'SELECT forum_id, topic_approved, COUNT(topic_id) AS forum_topics
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('forum_id', $forum_ids) . '
|
|
|
ef5584 |
GROUP BY forum_id, topic_approved';
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$forum_id = (int) $row['forum_id'];
|
|
|
ef5584 |
$forum_data[$forum_id]['topics_real'] += $row['forum_topics'];
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($row['topic_approved'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$forum_data[$forum_id]['topics'] = $row['forum_topics'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// 3: Get post count for each forum (optional)
|
|
|
ef5584 |
if ($sync_extra)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (sizeof($forum_ids) == 1)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'SELECT SUM(t.topic_replies + 1) AS forum_posts
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . ' t
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('t.forum_id', $forum_ids) . '
|
|
|
ef5584 |
AND t.topic_approved = 1
|
|
|
ef5584 |
AND t.topic_status <> ' . ITEM_MOVED;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'SELECT t.forum_id, SUM(t.topic_replies + 1) AS forum_posts
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . ' t
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('t.forum_id', $forum_ids) . '
|
|
|
ef5584 |
AND t.topic_approved = 1
|
|
|
ef5584 |
AND t.topic_status <> ' . ITEM_MOVED . '
|
|
|
ef5584 |
GROUP BY t.forum_id';
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$forum_id = (sizeof($forum_ids) == 1) ? (int) $forum_ids[0] : (int) $row['forum_id'];
|
|
|
ef5584 |
|
|
|
ef5584 |
$forum_data[$forum_id]['posts'] = (int) $row['forum_posts'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// 4: Get last_post_id for each forum
|
|
|
ef5584 |
if (sizeof($forum_ids) == 1)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'SELECT MAX(t.topic_last_post_id) as last_post_id
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . ' t
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('t.forum_id', $forum_ids) . '
|
|
|
ef5584 |
AND t.topic_approved = 1';
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'SELECT t.forum_id, MAX(t.topic_last_post_id) as last_post_id
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . ' t
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('t.forum_id', $forum_ids) . '
|
|
|
ef5584 |
AND t.topic_approved = 1
|
|
|
ef5584 |
GROUP BY t.forum_id';
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$forum_id = (sizeof($forum_ids) == 1) ? (int) $forum_ids[0] : (int) $row['forum_id'];
|
|
|
ef5584 |
|
|
|
ef5584 |
$forum_data[$forum_id]['last_post_id'] = (int) $row['last_post_id'];
|
|
|
ef5584 |
|
|
|
ef5584 |
$post_ids[] = $row['last_post_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
// 5: Retrieve last_post infos
|
|
|
ef5584 |
if (sizeof($post_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'SELECT p.post_id, p.poster_id, p.post_subject, p.post_time, p.post_username, u.username, u.user_colour
|
|
|
ef5584 |
FROM ' . POSTS_TABLE . ' p, ' . USERS_TABLE . ' u
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('p.post_id', $post_ids) . '
|
|
|
ef5584 |
AND p.poster_id = u.user_id';
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$post_info[$row['post_id']] = $row;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
foreach ($forum_data as $forum_id => $data)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($data['last_post_id'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (isset($post_info[$data['last_post_id']]))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$forum_data[$forum_id]['last_post_subject'] = $post_info[$data['last_post_id']]['post_subject'];
|
|
|
ef5584 |
$forum_data[$forum_id]['last_post_time'] = $post_info[$data['last_post_id']]['post_time'];
|
|
|
ef5584 |
$forum_data[$forum_id]['last_poster_id'] = $post_info[$data['last_post_id']]['poster_id'];
|
|
|
ef5584 |
$forum_data[$forum_id]['last_poster_name'] = ($post_info[$data['last_post_id']]['poster_id'] != ANONYMOUS) ? $post_info[$data['last_post_id']]['username'] : $post_info[$data['last_post_id']]['post_username'];
|
|
|
ef5584 |
$forum_data[$forum_id]['last_poster_colour'] = $post_info[$data['last_post_id']]['user_colour'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// For some reason we did not find the post in the db
|
|
|
ef5584 |
$forum_data[$forum_id]['last_post_id'] = 0;
|
|
|
ef5584 |
$forum_data[$forum_id]['last_post_subject'] = '';
|
|
|
ef5584 |
$forum_data[$forum_id]['last_post_time'] = 0;
|
|
|
ef5584 |
$forum_data[$forum_id]['last_poster_id'] = 0;
|
|
|
ef5584 |
$forum_data[$forum_id]['last_poster_name'] = '';
|
|
|
ef5584 |
$forum_data[$forum_id]['last_poster_colour'] = '';
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
unset($post_info);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// 6: Now do that thing
|
|
|
ef5584 |
$fieldnames = array('last_post_id', 'last_post_subject', 'last_post_time', 'last_poster_id', 'last_poster_name', 'last_poster_colour');
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($sync_extra)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
array_push($fieldnames, 'posts', 'topics', 'topics_real');
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
foreach ($forum_data as $forum_id => $row)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql_ary = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
foreach ($fieldnames as $fieldname)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($row['forum_' . $fieldname] != $row[$fieldname])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (preg_match('#(name|colour|subject)$#', $fieldname))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql_ary['forum_' . $fieldname] = (string) $row[$fieldname];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql_ary['forum_' . $fieldname] = (int) $row[$fieldname];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if (sizeof($sql_ary))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'UPDATE ' . FORUMS_TABLE . '
|
|
|
ef5584 |
SET ' . $db->sql_build_array('UPDATE', $sql_ary) . '
|
|
|
ef5584 |
WHERE forum_id = ' . $forum_id;
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'topic':
|
|
|
ef5584 |
$topic_data = $post_ids = $approved_unapproved_ids = $resync_forums = $delete_topics = $delete_posts = $moved_topics = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT t.topic_id, t.forum_id, t.topic_moved_id, t.topic_approved, ' . (($sync_extra) ? 't.topic_attachment, t.topic_reported, ' : '') . 't.topic_poster, t.topic_time, t.topic_replies, t.topic_replies_real, t.topic_first_post_id, t.topic_first_poster_name, t.topic_first_poster_colour, t.topic_last_post_id, t.topic_last_post_subject, t.topic_last_poster_id, t.topic_last_poster_name, t.topic_last_poster_colour, t.topic_last_post_time
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . " t
|
|
|
ef5584 |
$where_sql";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($row['topic_moved_id'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$moved_topics[] = $row['topic_id'];
|
|
|
ef5584 |
continue;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$topic_id = (int) $row['topic_id'];
|
|
|
ef5584 |
$topic_data[$topic_id] = $row;
|
|
|
ef5584 |
$topic_data[$topic_id]['replies_real'] = -1;
|
|
|
ef5584 |
$topic_data[$topic_id]['replies'] = 0;
|
|
|
ef5584 |
$topic_data[$topic_id]['first_post_id'] = 0;
|
|
|
ef5584 |
$topic_data[$topic_id]['last_post_id'] = 0;
|
|
|
ef5584 |
unset($topic_data[$topic_id]['topic_id']);
|
|
|
ef5584 |
|
|
|
ef5584 |
// This array holds all topic_ids
|
|
|
ef5584 |
$delete_topics[$topic_id] = '';
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($sync_extra)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_data[$topic_id]['reported'] = 0;
|
|
|
ef5584 |
$topic_data[$topic_id]['attachment'] = 0;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
// Use "t" as table alias because of the $where_sql clause
|
|
|
ef5584 |
// NOTE: 't.post_approved' in the GROUP BY is causing a major slowdown.
|
|
|
ef5584 |
$sql = 'SELECT t.topic_id, t.post_approved, COUNT(t.post_id) AS total_posts, MIN(t.post_id) AS first_post_id, MAX(t.post_id) AS last_post_id
|
|
|
ef5584 |
FROM ' . POSTS_TABLE . " t
|
|
|
ef5584 |
$where_sql
|
|
|
ef5584 |
GROUP BY t.topic_id, t.post_approved";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_id = (int) $row['topic_id'];
|
|
|
ef5584 |
|
|
|
ef5584 |
$row['first_post_id'] = (int) $row['first_post_id'];
|
|
|
ef5584 |
$row['last_post_id'] = (int) $row['last_post_id'];
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!isset($topic_data[$topic_id]))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// Hey, these posts come from a topic that does not exist
|
|
|
ef5584 |
$delete_posts[$topic_id] = '';
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// Unset the corresponding entry in $delete_topics
|
|
|
ef5584 |
// When we'll be done, only topics with no posts will remain
|
|
|
ef5584 |
unset($delete_topics[$topic_id]);
|
|
|
ef5584 |
|
|
|
ef5584 |
$topic_data[$topic_id]['replies_real'] += $row['total_posts'];
|
|
|
ef5584 |
$topic_data[$topic_id]['first_post_id'] = (!$topic_data[$topic_id]['first_post_id']) ? $row['first_post_id'] : min($topic_data[$topic_id]['first_post_id'], $row['first_post_id']);
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($row['post_approved'] || !$topic_data[$topic_id]['last_post_id'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_data[$topic_id]['replies'] = $row['total_posts'] - 1;
|
|
|
ef5584 |
$topic_data[$topic_id]['last_post_id'] = $row['last_post_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
foreach ($topic_data as $topic_id => $row)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$post_ids[] = $row['first_post_id'];
|
|
|
ef5584 |
if ($row['first_post_id'] != $row['last_post_id'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$post_ids[] = $row['last_post_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// Now we delete empty topics and orphan posts
|
|
|
ef5584 |
if (sizeof($delete_posts))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
delete_posts('topic_id', array_keys($delete_posts), false);
|
|
|
ef5584 |
unset($delete_posts);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!sizeof($topic_data))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// If we get there, topic ids were invalid or topics did not contain any posts
|
|
|
ef5584 |
delete_topics($where_type, $where_ids, true);
|
|
|
ef5584 |
return;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if (sizeof($delete_topics))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$delete_topic_ids = array();
|
|
|
ef5584 |
foreach ($delete_topics as $topic_id => $void)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
unset($topic_data[$topic_id]);
|
|
|
ef5584 |
$delete_topic_ids[] = $topic_id;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
delete_topics('topic_id', $delete_topic_ids, false);
|
|
|
ef5584 |
unset($delete_topics, $delete_topic_ids);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT p.post_id, p.topic_id, p.post_approved, p.poster_id, p.post_subject, p.post_username, p.post_time, u.username, u.user_colour
|
|
|
ef5584 |
FROM ' . POSTS_TABLE . ' p, ' . USERS_TABLE . ' u
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('p.post_id', $post_ids) . '
|
|
|
ef5584 |
AND u.user_id = p.poster_id';
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$post_ids = array();
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_id = intval($row['topic_id']);
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($row['post_id'] == $topic_data[$topic_id]['first_post_id'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($topic_data[$topic_id]['topic_approved'] != $row['post_approved'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$approved_unapproved_ids[] = $topic_id;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$topic_data[$topic_id]['time'] = $row['post_time'];
|
|
|
ef5584 |
$topic_data[$topic_id]['poster'] = $row['poster_id'];
|
|
|
ef5584 |
$topic_data[$topic_id]['first_poster_name'] = ($row['poster_id'] == ANONYMOUS) ? $row['post_username'] : $row['username'];
|
|
|
ef5584 |
$topic_data[$topic_id]['first_poster_colour'] = $row['user_colour'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($row['post_id'] == $topic_data[$topic_id]['last_post_id'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_data[$topic_id]['last_poster_id'] = $row['poster_id'];
|
|
|
ef5584 |
$topic_data[$topic_id]['last_post_subject'] = $row['post_subject'];
|
|
|
ef5584 |
$topic_data[$topic_id]['last_post_time'] = $row['post_time'];
|
|
|
ef5584 |
$topic_data[$topic_id]['last_poster_name'] = ($row['poster_id'] == ANONYMOUS) ? $row['post_username'] : $row['username'];
|
|
|
ef5584 |
$topic_data[$topic_id]['last_poster_colour'] = $row['user_colour'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
// Make sure shadow topics do link to existing topics
|
|
|
ef5584 |
if (sizeof($moved_topics))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$delete_topics = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT t1.topic_id, t1.topic_moved_id
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . ' t1
|
|
|
ef5584 |
LEFT JOIN ' . TOPICS_TABLE . ' t2 ON (t2.topic_id = t1.topic_moved_id)
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('t1.topic_id', $moved_topics) . '
|
|
|
ef5584 |
AND t2.topic_id IS NULL';
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$delete_topics[] = $row['topic_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (sizeof($delete_topics))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
delete_topics('topic_id', $delete_topics, false);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
unset($delete_topics);
|
|
|
ef5584 |
|
|
|
ef5584 |
// Make sure shadow topics having no last post data being updated (this only rarely happens...)
|
|
|
ef5584 |
$sql = 'SELECT topic_id, topic_moved_id, topic_last_post_id, topic_first_post_id
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('topic_id', $moved_topics) . '
|
|
|
ef5584 |
AND topic_last_post_time = 0';
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$shadow_topic_data = $post_ids = array();
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$shadow_topic_data[$row['topic_moved_id']] = $row;
|
|
|
ef5584 |
$post_ids[] = $row['topic_last_post_id'];
|
|
|
ef5584 |
$post_ids[] = $row['topic_first_post_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
$sync_shadow_topics = array();
|
|
|
ef5584 |
if (sizeof($post_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'SELECT p.post_id, p.topic_id, p.post_approved, p.poster_id, p.post_subject, p.post_username, p.post_time, u.username, u.user_colour
|
|
|
ef5584 |
FROM ' . POSTS_TABLE . ' p, ' . USERS_TABLE . ' u
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('p.post_id', $post_ids) . '
|
|
|
ef5584 |
AND u.user_id = p.poster_id';
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$post_ids = array();
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_id = (int) $row['topic_id'];
|
|
|
ef5584 |
|
|
|
ef5584 |
// Ok, there should be a shadow topic. If there isn't, then there's something wrong with the db.
|
|
|
ef5584 |
// However, there's not much we can do about it.
|
|
|
ef5584 |
if (!empty($shadow_topic_data[$topic_id]))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($row['post_id'] == $shadow_topic_data[$topic_id]['topic_first_post_id'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$orig_topic_id = $shadow_topic_data[$topic_id]['topic_id'];
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!isset($sync_shadow_topics[$orig_topic_id]))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sync_shadow_topics[$orig_topic_id] = array();
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$sync_shadow_topics[$orig_topic_id]['topic_time'] = $row['post_time'];
|
|
|
ef5584 |
$sync_shadow_topics[$orig_topic_id]['topic_poster'] = $row['poster_id'];
|
|
|
ef5584 |
$sync_shadow_topics[$orig_topic_id]['topic_first_poster_name'] = ($row['poster_id'] == ANONYMOUS) ? $row['post_username'] : $row['username'];
|
|
|
ef5584 |
$sync_shadow_topics[$orig_topic_id]['topic_first_poster_colour'] = $row['user_colour'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($row['post_id'] == $shadow_topic_data[$topic_id]['topic_last_post_id'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$orig_topic_id = $shadow_topic_data[$topic_id]['topic_id'];
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!isset($sync_shadow_topics[$orig_topic_id]))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sync_shadow_topics[$orig_topic_id] = array();
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$sync_shadow_topics[$orig_topic_id]['topic_last_poster_id'] = $row['poster_id'];
|
|
|
ef5584 |
$sync_shadow_topics[$orig_topic_id]['topic_last_post_subject'] = $row['post_subject'];
|
|
|
ef5584 |
$sync_shadow_topics[$orig_topic_id]['topic_last_post_time'] = $row['post_time'];
|
|
|
ef5584 |
$sync_shadow_topics[$orig_topic_id]['topic_last_poster_name'] = ($row['poster_id'] == ANONYMOUS) ? $row['post_username'] : $row['username'];
|
|
|
ef5584 |
$sync_shadow_topics[$orig_topic_id]['topic_last_poster_colour'] = $row['user_colour'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
$shadow_topic_data = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
// Update the information we collected
|
|
|
ef5584 |
if (sizeof($sync_shadow_topics))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
foreach ($sync_shadow_topics as $sync_topic_id => $sql_ary)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'UPDATE ' . TOPICS_TABLE . '
|
|
|
ef5584 |
SET ' . $db->sql_build_array('UPDATE', $sql_ary) . '
|
|
|
ef5584 |
WHERE topic_id = ' . $sync_topic_id;
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
unset($sync_shadow_topics, $shadow_topic_data);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// approved becomes unapproved, and vice-versa
|
|
|
ef5584 |
if (sizeof($approved_unapproved_ids))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'UPDATE ' . TOPICS_TABLE . '
|
|
|
ef5584 |
SET topic_approved = 1 - topic_approved
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('topic_id', $approved_unapproved_ids);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
unset($approved_unapproved_ids);
|
|
|
ef5584 |
|
|
|
ef5584 |
// These are fields that will be synchronised
|
|
|
ef5584 |
$fieldnames = array('time', 'replies', 'replies_real', 'poster', 'first_post_id', 'first_poster_name', 'first_poster_colour', 'last_post_id', 'last_post_subject', 'last_post_time', 'last_poster_id', 'last_poster_name', 'last_poster_colour');
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($sync_extra)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// This routine assumes that post_reported values are correct
|
|
|
ef5584 |
// if they are not, use sync('post_reported') first
|
|
|
ef5584 |
$sql = 'SELECT t.topic_id, p.post_id
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . ' t, ' . POSTS_TABLE . " p
|
|
|
ef5584 |
$where_sql_and p.topic_id = t.topic_id
|
|
|
ef5584 |
AND p.post_reported = 1
|
|
|
ef5584 |
GROUP BY t.topic_id, p.post_id";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$fieldnames[] = 'reported';
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_data[intval($row['topic_id'])]['reported'] = 1;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
// This routine assumes that post_attachment values are correct
|
|
|
ef5584 |
// if they are not, use sync('post_attachment') first
|
|
|
ef5584 |
$sql = 'SELECT t.topic_id, p.post_id
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . ' t, ' . POSTS_TABLE . " p
|
|
|
ef5584 |
$where_sql_and p.topic_id = t.topic_id
|
|
|
ef5584 |
AND p.post_attachment = 1
|
|
|
ef5584 |
GROUP BY t.topic_id, p.post_id";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$fieldnames[] = 'attachment';
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_data[intval($row['topic_id'])]['attachment'] = 1;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
foreach ($topic_data as $topic_id => $row)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql_ary = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
foreach ($fieldnames as $fieldname)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (isset($row[$fieldname]) && isset($row['topic_' . $fieldname]) && $row['topic_' . $fieldname] != $row[$fieldname])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql_ary['topic_' . $fieldname] = $row[$fieldname];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if (sizeof($sql_ary))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'UPDATE ' . TOPICS_TABLE . '
|
|
|
ef5584 |
SET ' . $db->sql_build_array('UPDATE', $sql_ary) . '
|
|
|
ef5584 |
WHERE topic_id = ' . $topic_id;
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$resync_forums[$row['forum_id']] = $row['forum_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
unset($topic_data);
|
|
|
ef5584 |
|
|
|
ef5584 |
// if some topics have been resync'ed then resync parent forums
|
|
|
ef5584 |
// except when we're only syncing a range, we don't want to sync forums during
|
|
|
ef5584 |
// batch processing.
|
|
|
ef5584 |
if ($resync_parents && sizeof($resync_forums) && $where_type != 'range')
|
|
|
ef5584 |
{
|
|
|
ef5584 |
sync('forum', 'forum_id', array_values($resync_forums), true, true);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
return;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Prune function
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function prune($forum_id, $prune_mode, $prune_date, $prune_flags = 0, $auto_sync = true)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db;
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!is_array($forum_id))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$forum_id = array($forum_id);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!sizeof($forum_id))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
return;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql_and = '';
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!($prune_flags & FORUM_FLAG_PRUNE_ANNOUNCE))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql_and .= ' AND topic_type <> ' . POST_ANNOUNCE;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!($prune_flags & FORUM_FLAG_PRUNE_STICKY))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql_and .= ' AND topic_type <> ' . POST_STICKY;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($prune_mode == 'posted')
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql_and .= " AND topic_last_post_time < $prune_date";
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($prune_mode == 'viewed')
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql_and .= " AND topic_last_view_time < $prune_date";
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT topic_id
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('forum_id', $forum_id) . "
|
|
|
ef5584 |
AND poll_start = 0
|
|
|
ef5584 |
$sql_and";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$topic_list = array();
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_list[] = $row['topic_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($prune_flags & FORUM_FLAG_PRUNE_POLL)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'SELECT topic_id
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('forum_id', $forum_id) . "
|
|
|
ef5584 |
AND poll_start > 0
|
|
|
ef5584 |
AND poll_last_vote < $prune_date
|
|
|
ef5584 |
$sql_and";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_list[] = $row['topic_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
$topic_list = array_unique($topic_list);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
return delete_topics('topic_id', $topic_list, $auto_sync, false);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Function auto_prune(), this function now relies on passed vars
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function auto_prune($forum_id, $prune_mode, $prune_flags, $prune_days, $prune_freq)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db;
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT forum_name
|
|
|
ef5584 |
FROM ' . FORUMS_TABLE . "
|
|
|
ef5584 |
WHERE forum_id = $forum_id";
|
|
|
ef5584 |
$result = $db->sql_query($sql, 3600);
|
|
|
ef5584 |
$row = $db->sql_fetchrow($result);
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($row)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$prune_date = time() - ($prune_days * 86400);
|
|
|
ef5584 |
$next_prune = time() + ($prune_freq * 86400);
|
|
|
ef5584 |
|
|
|
ef5584 |
prune($forum_id, $prune_mode, $prune_date, $prune_flags, true);
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'UPDATE ' . FORUMS_TABLE . "
|
|
|
ef5584 |
SET prune_next = $next_prune
|
|
|
ef5584 |
WHERE forum_id = $forum_id";
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
add_log('admin', 'LOG_AUTO_PRUNE', $row['forum_name']);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
return;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* remove_comments will strip the sql comment lines out of an uploaded sql file
|
|
|
ef5584 |
* specifically for mssql and postgres type files in the install....
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function remove_comments(&$output)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$lines = explode("\n", $output);
|
|
|
ef5584 |
$output = '';
|
|
|
ef5584 |
|
|
|
ef5584 |
// try to keep mem. use down
|
|
|
ef5584 |
$linecount = sizeof($lines);
|
|
|
ef5584 |
|
|
|
ef5584 |
$in_comment = false;
|
|
|
ef5584 |
for ($i = 0; $i < $linecount; $i++)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (trim($lines[$i]) == '/*')
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$in_comment = true;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!$in_comment)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$output .= $lines[$i] . "\n";
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if (trim($lines[$i]) == '*/')
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$in_comment = false;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
unset($lines);
|
|
|
ef5584 |
return $output;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Cache moderators, called whenever permissions are changed via admin_permissions. Changes of username
|
|
|
ef5584 |
* and group names must be carried through for the moderators table
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function cache_moderators()
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db, $cache, $auth, $phpbb_root_path, $phpEx;
|
|
|
ef5584 |
|
|
|
ef5584 |
// Remove cached sql results
|
|
|
ef5584 |
$cache->destroy('sql', MODERATOR_CACHE_TABLE);
|
|
|
ef5584 |
|
|
|
ef5584 |
// Clear table
|
|
|
ef5584 |
switch ($db->sql_layer)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
case 'sqlite':
|
|
|
ef5584 |
case 'firebird':
|
|
|
ef5584 |
$db->sql_query('DELETE FROM ' . MODERATOR_CACHE_TABLE);
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
default:
|
|
|
ef5584 |
$db->sql_query('TRUNCATE TABLE ' . MODERATOR_CACHE_TABLE);
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// We add moderators who have forum moderator permissions without an explicit ACL_NEVER setting
|
|
|
ef5584 |
$hold_ary = $ug_id_ary = $sql_ary = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
// Grab all users having moderative options...
|
|
|
ef5584 |
$hold_ary = $auth->acl_user_raw_data(false, 'm_%', false);
|
|
|
ef5584 |
|
|
|
ef5584 |
// Add users?
|
|
|
ef5584 |
if (sizeof($hold_ary))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// At least one moderative option warrants a display
|
|
|
ef5584 |
$ug_id_ary = array_keys($hold_ary);
|
|
|
ef5584 |
|
|
|
ef5584 |
// Remove users who have group memberships with DENY moderator permissions
|
|
|
ef5584 |
$sql = $db->sql_build_query('SELECT', array(
|
|
|
ef5584 |
'SELECT' => 'a.forum_id, ug.user_id',
|
|
|
ef5584 |
|
|
|
ef5584 |
'FROM' => array(
|
|
|
ef5584 |
ACL_OPTIONS_TABLE => 'o',
|
|
|
ef5584 |
USER_GROUP_TABLE => 'ug',
|
|
|
ef5584 |
ACL_GROUPS_TABLE => 'a'
|
|
|
ef5584 |
),
|
|
|
ef5584 |
|
|
|
ef5584 |
'LEFT_JOIN' => array(
|
|
|
ef5584 |
array(
|
|
|
ef5584 |
'FROM' => array(ACL_ROLES_DATA_TABLE => 'r'),
|
|
|
ef5584 |
'ON' => 'a.auth_role_id = r.role_id'
|
|
|
ef5584 |
)
|
|
|
ef5584 |
),
|
|
|
ef5584 |
|
|
|
ef5584 |
'WHERE' => '(o.auth_option_id = a.auth_option_id OR o.auth_option_id = r.auth_option_id)
|
|
|
ef5584 |
AND ((a.auth_setting = ' . ACL_NEVER . ' AND r.auth_setting IS NULL)
|
|
|
ef5584 |
OR r.auth_setting = ' . ACL_NEVER . ')
|
|
|
ef5584 |
AND a.group_id = ug.group_id
|
|
|
ef5584 |
AND ' . $db->sql_in_set('ug.user_id', $ug_id_ary) . "
|
|
|
ef5584 |
AND ug.user_pending = 0
|
|
|
ef5584 |
AND o.auth_option " . $db->sql_like_expression('m_' . $db->any_char),
|
|
|
ef5584 |
));
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (isset($hold_ary[$row['user_id']][$row['forum_id']]))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
unset($hold_ary[$row['user_id']][$row['forum_id']]);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (sizeof($hold_ary))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// Get usernames...
|
|
|
ef5584 |
$sql = 'SELECT user_id, username
|
|
|
ef5584 |
FROM ' . USERS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('user_id', array_keys($hold_ary));
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$usernames_ary = array();
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$usernames_ary[$row['user_id']] = $row['username'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
foreach ($hold_ary as $user_id => $forum_id_ary)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// Do not continue if user does not exist
|
|
|
ef5584 |
if (!isset($usernames_ary[$user_id]))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
continue;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
foreach ($forum_id_ary as $forum_id => $auth_ary)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql_ary[] = array(
|
|
|
ef5584 |
'forum_id' => (int) $forum_id,
|
|
|
ef5584 |
'user_id' => (int) $user_id,
|
|
|
ef5584 |
'username' => (string) $usernames_ary[$user_id],
|
|
|
ef5584 |
'group_id' => 0,
|
|
|
ef5584 |
'group_name' => ''
|
|
|
ef5584 |
);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// Now to the groups...
|
|
|
ef5584 |
$hold_ary = $auth->acl_group_raw_data(false, 'm_%', false);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (sizeof($hold_ary))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$ug_id_ary = array_keys($hold_ary);
|
|
|
ef5584 |
|
|
|
ef5584 |
// Make sure not hidden or special groups are involved...
|
|
|
ef5584 |
$sql = 'SELECT group_name, group_id, group_type
|
|
|
ef5584 |
FROM ' . GROUPS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('group_id', $ug_id_ary);
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$groupnames_ary = array();
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($row['group_type'] == GROUP_HIDDEN || $row['group_type'] == GROUP_SPECIAL)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
unset($hold_ary[$row['group_id']]);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$groupnames_ary[$row['group_id']] = $row['group_name'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
foreach ($hold_ary as $group_id => $forum_id_ary)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// If there is no group, we do not assign it...
|
|
|
ef5584 |
if (!isset($groupnames_ary[$group_id]))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
continue;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
foreach ($forum_id_ary as $forum_id => $auth_ary)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$flag = false;
|
|
|
ef5584 |
foreach ($auth_ary as $auth_option => $setting)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// Make sure at least one ACL_YES option is set...
|
|
|
ef5584 |
if ($setting == ACL_YES)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$flag = true;
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!$flag)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
continue;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql_ary[] = array(
|
|
|
ef5584 |
'forum_id' => (int) $forum_id,
|
|
|
ef5584 |
'user_id' => 0,
|
|
|
ef5584 |
'username' => '',
|
|
|
ef5584 |
'group_id' => (int) $group_id,
|
|
|
ef5584 |
'group_name' => (string) $groupnames_ary[$group_id]
|
|
|
ef5584 |
);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$db->sql_multi_insert(MODERATOR_CACHE_TABLE, $sql_ary);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* View log
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function view_log($mode, &$log, &$log_count, $limit = 0, $offset = 0, $forum_id = 0, $topic_id = 0, $user_id = 0, $limit_days = 0, $sort_by = 'l.log_time DESC')
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db, $user, $auth, $phpEx, $phpbb_root_path, $phpbb_admin_path;
|
|
|
ef5584 |
|
|
|
ef5584 |
$topic_id_list = $reportee_id_list = $is_auth = $is_mod = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
$profile_url = (defined('IN_ADMIN')) ? append_sid("{$phpbb_admin_path}index.$phpEx", 'i=users&mode=overview') : append_sid("{$phpbb_root_path}memberlist.$phpEx", 'mode=viewprofile');
|
|
|
ef5584 |
|
|
|
ef5584 |
switch ($mode)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
case 'admin':
|
|
|
ef5584 |
$log_type = LOG_ADMIN;
|
|
|
ef5584 |
$sql_forum = '';
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'mod':
|
|
|
ef5584 |
$log_type = LOG_MOD;
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($topic_id)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql_forum = 'AND l.topic_id = ' . intval($topic_id);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else if (is_array($forum_id))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql_forum = 'AND ' . $db->sql_in_set('l.forum_id', array_map('intval', $forum_id));
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql_forum = ($forum_id) ? 'AND l.forum_id = ' . intval($forum_id) : '';
|
|
|
ef5584 |
}
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'user':
|
|
|
ef5584 |
$log_type = LOG_USERS;
|
|
|
ef5584 |
$sql_forum = 'AND l.reportee_id = ' . (int) $user_id;
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'users':
|
|
|
ef5584 |
$log_type = LOG_USERS;
|
|
|
ef5584 |
$sql_forum = '';
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'critical':
|
|
|
ef5584 |
$log_type = LOG_CRITICAL;
|
|
|
ef5584 |
$sql_forum = '';
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
default:
|
|
|
ef5584 |
return;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = "SELECT l.*, u.username, u.username_clean, u.user_colour
|
|
|
ef5584 |
FROM " . LOG_TABLE . " l, " . USERS_TABLE . " u
|
|
|
ef5584 |
WHERE l.log_type = $log_type
|
|
|
ef5584 |
AND u.user_id = l.user_id
|
|
|
ef5584 |
" . (($limit_days) ? "AND l.log_time >= $limit_days" : '') . "
|
|
|
ef5584 |
$sql_forum
|
|
|
ef5584 |
ORDER BY $sort_by";
|
|
|
ef5584 |
$result = $db->sql_query_limit($sql, $limit, $offset);
|
|
|
ef5584 |
|
|
|
ef5584 |
$i = 0;
|
|
|
ef5584 |
$log = array();
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($row['topic_id'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_id_list[] = $row['topic_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($row['reportee_id'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$reportee_id_list[] = $row['reportee_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$log[$i] = array(
|
|
|
ef5584 |
'id' => $row['log_id'],
|
|
|
ef5584 |
|
|
|
ef5584 |
'reportee_id' => $row['reportee_id'],
|
|
|
ef5584 |
'reportee_username' => '',
|
|
|
ef5584 |
'reportee_username_full'=> '',
|
|
|
ef5584 |
|
|
|
ef5584 |
'user_id' => $row['user_id'],
|
|
|
ef5584 |
'username' => $row['username'],
|
|
|
ef5584 |
'username_full' => get_username_string('full', $row['user_id'], $row['username'], $row['user_colour'], false, $profile_url),
|
|
|
ef5584 |
|
|
|
ef5584 |
'ip' => $row['log_ip'],
|
|
|
ef5584 |
'time' => $row['log_time'],
|
|
|
ef5584 |
'forum_id' => $row['forum_id'],
|
|
|
ef5584 |
'topic_id' => $row['topic_id'],
|
|
|
ef5584 |
|
|
|
ef5584 |
'viewforum' => ($row['forum_id'] && $auth->acl_get('f_read', $row['forum_id'])) ? append_sid("{$phpbb_root_path}viewforum.$phpEx", 'f=' . $row['forum_id']) : false,
|
|
|
ef5584 |
'action' => (isset($user->lang[$row['log_operation']])) ? $user->lang[$row['log_operation']] : '{' . ucfirst(str_replace('_', ' ', $row['log_operation'])) . '}',
|
|
|
ef5584 |
);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!empty($row['log_data']))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$log_data_ary = unserialize($row['log_data']);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (isset($user->lang[$row['log_operation']]))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// Check if there are more occurrences of % than arguments, if there are we fill out the arguments array
|
|
|
ef5584 |
// It doesn't matter if we add more arguments than placeholders
|
|
|
ef5584 |
if ((substr_count($log[$i]['action'], '%') - sizeof($log_data_ary)) > 0)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$log_data_ary = array_merge($log_data_ary, array_fill(0, substr_count($log[$i]['action'], '%') - sizeof($log_data_ary), ''));
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$log[$i]['action'] = vsprintf($log[$i]['action'], $log_data_ary);
|
|
|
ef5584 |
|
|
|
ef5584 |
// If within the admin panel we do not censor text out
|
|
|
ef5584 |
if (defined('IN_ADMIN'))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$log[$i]['action'] = bbcode_nl2br($log[$i]['action']);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$log[$i]['action'] = bbcode_nl2br(censor_text($log[$i]['action']));
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$log[$i]['action'] .= '
' . implode('', $log_data_ary);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/* Apply make_clickable... has to be seen if it is for good. :/
|
|
|
ef5584 |
// Seems to be not for the moment, reconsider later...
|
|
|
ef5584 |
$log[$i]['action'] = make_clickable($log[$i]['action']);
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$i++;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (sizeof($topic_id_list))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$topic_id_list = array_unique($topic_id_list);
|
|
|
ef5584 |
|
|
|
ef5584 |
// This query is not really needed if move_topics() updates the forum_id field,
|
|
|
ef5584 |
// although it's also used to determine if the topic still exists in the database
|
|
|
ef5584 |
$sql = 'SELECT topic_id, forum_id
|
|
|
ef5584 |
FROM ' . TOPICS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('topic_id', array_map('intval', $topic_id_list));
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$default_forum_id = 0;
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (!$row['forum_id'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($auth->acl_getf_global('f_read'))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (!$default_forum_id)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'SELECT forum_id
|
|
|
ef5584 |
FROM ' . FORUMS_TABLE . '
|
|
|
ef5584 |
WHERE forum_type = ' . FORUM_POST;
|
|
|
ef5584 |
$f_result = $db->sql_query_limit($sql, 1);
|
|
|
ef5584 |
$default_forum_id = (int) $db->sql_fetchfield('forum_id', false, $f_result);
|
|
|
ef5584 |
$db->sql_freeresult($f_result);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$is_auth[$row['topic_id']] = $default_forum_id;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($auth->acl_get('f_read', $row['forum_id']))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$is_auth[$row['topic_id']] = $row['forum_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($auth->acl_gets('a_', 'm_', $row['forum_id']))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$is_mod[$row['topic_id']] = $row['forum_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
foreach ($log as $key => $row)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$log[$key]['viewtopic'] = (isset($is_auth[$row['topic_id']])) ? append_sid("{$phpbb_root_path}viewtopic.$phpEx", 'f=' . $is_auth[$row['topic_id']] . '&t=' . $row['topic_id']) : false;
|
|
|
ef5584 |
$log[$key]['viewlogs'] = (isset($is_mod[$row['topic_id']])) ? append_sid("{$phpbb_root_path}mcp.$phpEx", 'i=logs&mode=topic_logs&t=' . $row['topic_id'], true, $user->session_id) : false;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if (sizeof($reportee_id_list))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$reportee_id_list = array_unique($reportee_id_list);
|
|
|
ef5584 |
$reportee_names_list = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT user_id, username, user_colour
|
|
|
ef5584 |
FROM ' . USERS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('user_id', $reportee_id_list);
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$reportee_names_list[$row['user_id']] = $row;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
foreach ($log as $key => $row)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (!isset($reportee_names_list[$row['reportee_id']]))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
continue;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$log[$key]['reportee_username'] = $reportee_names_list[$row['reportee_id']]['username'];
|
|
|
ef5584 |
$log[$key]['reportee_username_full'] = get_username_string('full', $row['reportee_id'], $reportee_names_list[$row['reportee_id']]['username'], $reportee_names_list[$row['reportee_id']]['user_colour'], false, $profile_url);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT COUNT(l.log_id) AS total_entries
|
|
|
ef5584 |
FROM ' . LOG_TABLE . " l
|
|
|
ef5584 |
WHERE l.log_type = $log_type
|
|
|
ef5584 |
AND l.log_time >= $limit_days
|
|
|
ef5584 |
$sql_forum";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
$log_count = (int) $db->sql_fetchfield('total_entries');
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
return;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Update foes - remove moderators and administrators from foe lists...
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function update_foes($group_id = false, $user_id = false)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db, $auth;
|
|
|
ef5584 |
|
|
|
ef5584 |
// update foes for some user
|
|
|
ef5584 |
if (is_array($user_id) && sizeof($user_id))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'DELETE FROM ' . ZEBRA_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('zebra_id', $user_id) . '
|
|
|
ef5584 |
AND foe = 1';
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
return;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// update foes for some group
|
|
|
ef5584 |
if (is_array($group_id) && sizeof($group_id))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
// Grab group settings...
|
|
|
ef5584 |
$sql = $db->sql_build_query('SELECT', array(
|
|
|
ef5584 |
'SELECT' => 'a.group_id',
|
|
|
ef5584 |
|
|
|
ef5584 |
'FROM' => array(
|
|
|
ef5584 |
ACL_OPTIONS_TABLE => 'ao',
|
|
|
ef5584 |
ACL_GROUPS_TABLE => 'a'
|
|
|
ef5584 |
),
|
|
|
ef5584 |
|
|
|
ef5584 |
'LEFT_JOIN' => array(
|
|
|
ef5584 |
array(
|
|
|
ef5584 |
'FROM' => array(ACL_ROLES_DATA_TABLE => 'r'),
|
|
|
ef5584 |
'ON' => 'a.auth_role_id = r.role_id'
|
|
|
ef5584 |
),
|
|
|
ef5584 |
),
|
|
|
ef5584 |
|
|
|
ef5584 |
'WHERE' => '(ao.auth_option_id = a.auth_option_id OR ao.auth_option_id = r.auth_option_id)
|
|
|
ef5584 |
AND ' . $db->sql_in_set('a.group_id', $group_id) . "
|
|
|
ef5584 |
AND ao.auth_option IN ('a_', 'm_')",
|
|
|
ef5584 |
|
|
|
ef5584 |
'GROUP_BY' => 'a.group_id'
|
|
|
ef5584 |
));
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$groups = array();
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$groups[] = (int) $row['group_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!sizeof($groups))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
return;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
switch ($db->sql_layer)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
case 'mysqli':
|
|
|
ef5584 |
case 'mysql4':
|
|
|
ef5584 |
$sql = 'DELETE ' . (($db->sql_layer === 'mysqli' || version_compare($db->sql_server_info(true), '4.1', '>=')) ? 'z.*' : ZEBRA_TABLE) . '
|
|
|
ef5584 |
FROM ' . ZEBRA_TABLE . ' z, ' . USER_GROUP_TABLE . ' ug
|
|
|
ef5584 |
WHERE z.zebra_id = ug.user_id
|
|
|
ef5584 |
AND z.foe = 1
|
|
|
ef5584 |
AND ' . $db->sql_in_set('ug.group_id', $groups);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
default:
|
|
|
ef5584 |
$sql = 'SELECT user_id
|
|
|
ef5584 |
FROM ' . USER_GROUP_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('group_id', $groups);
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$users = array();
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$users[] = (int) $row['user_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (sizeof($users))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'DELETE FROM ' . ZEBRA_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('zebra_id', $users) . '
|
|
|
ef5584 |
AND foe = 1';
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
return;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
// update foes for everyone
|
|
|
ef5584 |
$perms = array();
|
|
|
ef5584 |
foreach ($auth->acl_get_list(false, array('a_', 'm_'), false) as $forum_id => $forum_ary)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
foreach ($forum_ary as $auth_option => $user_ary)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$perms = array_merge($perms, $user_ary);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if (sizeof($perms))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'DELETE FROM ' . ZEBRA_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('zebra_id', array_unique($perms)) . '
|
|
|
ef5584 |
AND foe = 1';
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
unset($perms);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Lists inactive users
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function view_inactive_users(&$users, &$user_count, $limit = 0, $offset = 0, $limit_days = 0, $sort_by = 'user_inactive_time DESC')
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db, $user;
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT COUNT(user_id) AS user_count
|
|
|
ef5584 |
FROM ' . USERS_TABLE . '
|
|
|
ef5584 |
WHERE user_type = ' . USER_INACTIVE .
|
|
|
ef5584 |
(($limit_days) ? " AND user_inactive_time >= $limit_days" : '');
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
$user_count = (int) $db->sql_fetchfield('user_count');
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($offset >= $user_count)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$offset = ($offset - $limit < 0) ? 0 : $offset - $limit;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT user_id, username, user_regdate, user_lastvisit, user_inactive_time, user_inactive_reason
|
|
|
ef5584 |
FROM ' . USERS_TABLE . '
|
|
|
ef5584 |
WHERE user_type = ' . USER_INACTIVE .
|
|
|
ef5584 |
(($limit_days) ? " AND user_inactive_time >= $limit_days" : '') . "
|
|
|
ef5584 |
ORDER BY $sort_by";
|
|
|
ef5584 |
$result = $db->sql_query_limit($sql, $limit, $offset);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$row['inactive_reason'] = $user->lang['INACTIVE_REASON_UNKNOWN'];
|
|
|
ef5584 |
switch ($row['user_inactive_reason'])
|
|
|
ef5584 |
{
|
|
|
ef5584 |
case INACTIVE_REGISTER:
|
|
|
ef5584 |
$row['inactive_reason'] = $user->lang['INACTIVE_REASON_REGISTER'];
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case INACTIVE_PROFILE:
|
|
|
ef5584 |
$row['inactive_reason'] = $user->lang['INACTIVE_REASON_PROFILE'];
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case INACTIVE_MANUAL:
|
|
|
ef5584 |
$row['inactive_reason'] = $user->lang['INACTIVE_REASON_MANUAL'];
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case INACTIVE_REMIND:
|
|
|
ef5584 |
$row['inactive_reason'] = $user->lang['INACTIVE_REASON_REMIND'];
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$users[] = $row;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
return $offset;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Lists warned users
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function view_warned_users(&$users, &$user_count, $limit = 0, $offset = 0, $limit_days = 0, $sort_by = 'user_warnings DESC')
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db;
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT user_id, username, user_colour, user_warnings, user_last_warning
|
|
|
ef5584 |
FROM ' . USERS_TABLE . '
|
|
|
ef5584 |
WHERE user_warnings > 0
|
|
|
ef5584 |
' . (($limit_days) ? "AND user_last_warning >= $limit_days" : '') . "
|
|
|
ef5584 |
ORDER BY $sort_by";
|
|
|
ef5584 |
$result = $db->sql_query_limit($sql, $limit, $offset);
|
|
|
ef5584 |
$users = $db->sql_fetchrowset($result);
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT count(user_id) AS user_count
|
|
|
ef5584 |
FROM ' . USERS_TABLE . '
|
|
|
ef5584 |
WHERE user_warnings > 0
|
|
|
ef5584 |
' . (($limit_days) ? "AND user_last_warning >= $limit_days" : '');
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
$user_count = (int) $db->sql_fetchfield('user_count');
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
return;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Get database size
|
|
|
ef5584 |
* Currently only mysql and mssql are supported
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function get_database_size()
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db, $user, $table_prefix;
|
|
|
ef5584 |
|
|
|
ef5584 |
$database_size = false;
|
|
|
ef5584 |
|
|
|
ef5584 |
// This code is heavily influenced by a similar routine in phpMyAdmin 2.2.0
|
|
|
ef5584 |
switch ($db->sql_layer)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
case 'mysql':
|
|
|
ef5584 |
case 'mysql4':
|
|
|
ef5584 |
case 'mysqli':
|
|
|
ef5584 |
$sql = 'SELECT VERSION() AS mysql_version';
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
$row = $db->sql_fetchrow($result);
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($row)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$version = $row['mysql_version'];
|
|
|
ef5584 |
|
|
|
ef5584 |
if (preg_match('#(3\.23|[45]\.)#', $version))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$db_name = (preg_match('#^(?:3\.23\.(?:[6-9]|[1-9]{2}))|[45]\.#', $version)) ? "`{$db->dbname}`" : $db->dbname;
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SHOW TABLE STATUS
|
|
|
ef5584 |
FROM ' . $db_name;
|
|
|
ef5584 |
$result = $db->sql_query($sql, 7200);
|
|
|
ef5584 |
|
|
|
ef5584 |
$database_size = 0;
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ((isset($row['Type']) && $row['Type'] != 'MRG_MyISAM') || (isset($row['Engine']) && ($row['Engine'] == 'MyISAM' || $row['Engine'] == 'InnoDB')))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($table_prefix != '')
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if (strpos($row['Name'], $table_prefix) !== false)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$database_size += $row['Data_length'] + $row['Index_length'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$database_size += $row['Data_length'] + $row['Index_length'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'firebird':
|
|
|
ef5584 |
global $dbname;
|
|
|
ef5584 |
|
|
|
ef5584 |
// if it on the local machine, we can get lucky
|
|
|
ef5584 |
if (file_exists($dbname))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$database_size = filesize($dbname);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'sqlite':
|
|
|
ef5584 |
global $dbhost;
|
|
|
ef5584 |
|
|
|
ef5584 |
if (file_exists($dbhost))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$database_size = filesize($dbhost);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'mssql':
|
|
|
ef5584 |
case 'mssql_odbc':
|
|
|
ef5584 |
$sql = 'SELECT ((SUM(size) * 8.0) * 1024.0) as dbsize
|
|
|
ef5584 |
FROM sysfiles';
|
|
|
ef5584 |
$result = $db->sql_query($sql, 7200);
|
|
|
ef5584 |
$database_size = ($row = $db->sql_fetchrow($result)) ? $row['dbsize'] : false;
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'postgres':
|
|
|
ef5584 |
$sql = "SELECT proname
|
|
|
ef5584 |
FROM pg_proc
|
|
|
ef5584 |
WHERE proname = 'pg_database_size'";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
$row = $db->sql_fetchrow($result);
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($row['proname'] == 'pg_database_size')
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$database = $db->dbname;
|
|
|
ef5584 |
if (strpos($database, '.') !== false)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
list($database, ) = explode('.', $database);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = "SELECT oid
|
|
|
ef5584 |
FROM pg_database
|
|
|
ef5584 |
WHERE datname = '$database'";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
$row = $db->sql_fetchrow($result);
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
$oid = $row['oid'];
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT pg_database_size(' . $oid . ') as size';
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
$row = $db->sql_fetchrow($result);
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
$database_size = $row['size'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
|
|
|
ef5584 |
case 'oracle':
|
|
|
ef5584 |
$sql = 'SELECT SUM(bytes) as dbsize
|
|
|
ef5584 |
FROM user_segments';
|
|
|
ef5584 |
$result = $db->sql_query($sql, 7200);
|
|
|
ef5584 |
$database_size = ($row = $db->sql_fetchrow($result)) ? $row['dbsize'] : false;
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
break;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$database_size = ($database_size !== false) ? get_formatted_filesize($database_size) : $user->lang['NOT_AVAILABLE'];
|
|
|
ef5584 |
|
|
|
ef5584 |
return $database_size;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Retrieve contents from remotely stored file
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function get_remote_file($host, $directory, $filename, &$errstr, &$errno, $port = 80, $timeout = 10)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $user;
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($fsock = @fsockopen($host, $port, $errno, $errstr, $timeout))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
@fputs($fsock, "GET $directory/$filename HTTP/1.1\r\n");
|
|
|
ef5584 |
@fputs($fsock, "HOST: $host\r\n");
|
|
|
ef5584 |
@fputs($fsock, "Connection: close\r\n\r\n");
|
|
|
ef5584 |
|
|
|
ef5584 |
$file_info = '';
|
|
|
ef5584 |
$get_info = false;
|
|
|
ef5584 |
|
|
|
ef5584 |
while (!@feof($fsock))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($get_info)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$file_info .= @fread($fsock, 1024);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$line = @fgets($fsock, 1024);
|
|
|
ef5584 |
if ($line == "\r\n")
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$get_info = true;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else if (stripos($line, '404 not found') !== false)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$errstr = $user->lang['FILE_NOT_FOUND'] . ': ' . $filename;
|
|
|
ef5584 |
return false;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
@fclose($fsock);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($errstr)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$errstr = utf8_convert_message($errstr);
|
|
|
ef5584 |
return false;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
else
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$errstr = $user->lang['FSOCK_DISABLED'];
|
|
|
ef5584 |
return false;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
return $file_info;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Tidy Warnings
|
|
|
ef5584 |
* Remove all warnings which have now expired from the database
|
|
|
ef5584 |
* The duration of a warning can be defined by the administrator
|
|
|
ef5584 |
* This only removes the warning and reduces the associated count,
|
|
|
ef5584 |
* it does not remove the user note recording the contents of the warning
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function tidy_warnings()
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db, $config;
|
|
|
ef5584 |
|
|
|
ef5584 |
$expire_date = time() - ($config['warnings_expire_days'] * 86400);
|
|
|
ef5584 |
$warning_list = $user_list = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'SELECT * FROM ' . WARNINGS_TABLE . "
|
|
|
ef5584 |
WHERE warning_time < $expire_date";
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$warning_list[] = $row['warning_id'];
|
|
|
ef5584 |
$user_list[$row['user_id']] = isset($user_list[$row['user_id']]) ? ++$user_list[$row['user_id']] : 1;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
if (sizeof($warning_list))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$db->sql_transaction('begin');
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'DELETE FROM ' . WARNINGS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('warning_id', $warning_list);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
foreach ($user_list as $user_id => $value)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$sql = 'UPDATE ' . USERS_TABLE . " SET user_warnings = user_warnings - $value
|
|
|
ef5584 |
WHERE user_id = $user_id";
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$db->sql_transaction('commit');
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
set_config('warnings_last_gc', time(), true);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Tidy database, doing some maintanance tasks
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function tidy_database()
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $db;
|
|
|
ef5584 |
|
|
|
ef5584 |
// Here we check permission consistency
|
|
|
ef5584 |
|
|
|
ef5584 |
// Sometimes, it can happen permission tables having forums listed which do not exist
|
|
|
ef5584 |
$sql = 'SELECT forum_id
|
|
|
ef5584 |
FROM ' . FORUMS_TABLE;
|
|
|
ef5584 |
$result = $db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$forum_ids = array(0);
|
|
|
ef5584 |
while ($row = $db->sql_fetchrow($result))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$forum_ids[] = $row['forum_id'];
|
|
|
ef5584 |
}
|
|
|
ef5584 |
$db->sql_freeresult($result);
|
|
|
ef5584 |
|
|
|
ef5584 |
// Delete those rows from the acl tables not having listed the forums above
|
|
|
ef5584 |
$sql = 'DELETE FROM ' . ACL_GROUPS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('forum_id', $forum_ids, true);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
$sql = 'DELETE FROM ' . ACL_USERS_TABLE . '
|
|
|
ef5584 |
WHERE ' . $db->sql_in_set('forum_id', $forum_ids, true);
|
|
|
ef5584 |
$db->sql_query($sql);
|
|
|
ef5584 |
|
|
|
ef5584 |
set_config('database_last_gc', time(), true);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
/**
|
|
|
ef5584 |
* Add permission language - this will make sure custom files will be included
|
|
|
ef5584 |
*/
|
|
|
ef5584 |
function add_permission_language()
|
|
|
ef5584 |
{
|
|
|
ef5584 |
global $user, $phpEx;
|
|
|
ef5584 |
|
|
|
ef5584 |
// First of all, our own file. We need to include it as the first file because it presets all relevant variables.
|
|
|
ef5584 |
$user->add_lang('acp/permissions_phpbb');
|
|
|
ef5584 |
|
|
|
ef5584 |
$files_to_add = array();
|
|
|
ef5584 |
|
|
|
ef5584 |
// Now search in acp and mods folder for permissions_ files.
|
|
|
ef5584 |
foreach (array('acp/', 'mods/') as $path)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$dh = @opendir($user->lang_path . $user->lang_name . '/' . $path);
|
|
|
ef5584 |
|
|
|
ef5584 |
if ($dh)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
while (($file = readdir($dh)) !== false)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
if ($file !== 'permissions_phpbb.' . $phpEx && strpos($file, 'permissions_') === 0 && substr($file, -(strlen($phpEx) + 1)) === '.' . $phpEx)
|
|
|
ef5584 |
{
|
|
|
ef5584 |
$files_to_add[] = $path . substr($file, 0, -(strlen($phpEx) + 1));
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
closedir($dh);
|
|
|
ef5584 |
}
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
if (!sizeof($files_to_add))
|
|
|
ef5584 |
{
|
|
|
ef5584 |
return false;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
$user->add_lang($files_to_add);
|
|
|
ef5584 |
return true;
|
|
|
ef5584 |
}
|
|
|
ef5584 |
|
|
|
ef5584 |
?>
|