-// * Split topic:

-// * As current but need better way of listing all posts

-// * Merge topics:

-// * Similar to split(?) but reverse

-// Do major work ... (<= being the 1-billion dollars man)

- add_log('mod', $forum_id, $topic_id, $mode);

- resync('approved', 'topic_id', $topic_id_list);

- foreach ($topic_id_list as $topic_id)

- {

- add_log('mod', $forum_id, $topic_id, $mode);

- }

-

- ORDER BY t.topic_approved ASC';

- if (!$row = $db->sql_fetchrow($result))

- $header = '';

- do

- if ($row['poster_id'] == ANONYMOUS)

- {

- $author = ($row['post_username']) ? $row['post_username'] : $user->lang['Guest'];

- }

- else

- {

- $author = '<a href="ucp.' . $phpEx . $SID . '&amp;mode=viewprofile&amp;u=' . $row['poster_id'] . '">' . $row['username'] . '</a>';

- }

- $posts_header = FALSE;

- $topics_header = FALSE;

- if ($row['post_id'] == $row['topic_first_post_id'] && $header != 'topics')

- $header = 'topics';

- $topics_header = TRUE;

- }

- elseif ($header != 'posts')

- {

- $header = 'posts';

- $posts_header = TRUE;

- }

- $template->assign_block_vars('postrow', array(

- 'S_POSTS_HEADER' => $posts_header,

- 'S_TOPICS_HEADER' => $topics_header,

-

- 'U_POST_DETAILS' => $mcp_url . '&amp;mode=post_details',

- 'FORUM' => '<a href="viewforum.' . $phpEx . $SID . '&amp;f=' . $row['forum_id'] . '">' . $row['forum_name'] . '</a>',

- 'TOPIC' => '<a href="viewtopic.' . $phpEx . $SID . '&amp;f=' . $row['forum_id'] . '&amp;t=' . $row['topic_id'] . '">' . $row['topic_title'] . '</a>',

- 'AUTHOR' => $author,

- 'SUBJECT' => '<a href="mcp.' . $phpEx . $SID . '&amp;p=' . $row['post_id'] . '&amp;mode=post_details">' . (($row['post_subject']) ? $row['post_subject'] : $user->lang['NO_SUBJECT']) . '</a>',

- 'POST_TIME' => $user->format_date($row['post_time']),

- 'S_CHECKBOX' => '<input type="checkbox" name="post_id_list" value="' . $row['post_id'] . '">'

- ));

- while ($row = $db->sql_fetchrow($result));

- resync('topic', 'topic_id', $topic_id_list);

-

- // TODO: what happens if the user deletes the first post of the topic? Currently, the topic is resync'ed normally and topic time/topic author are updated by the new first post

-

- $hidden_fields = '<input type="hidden" name="mode" value="delete" />';

-/*

- // Temp fix for merge: display all posts after the topic has been selected to avoid any confusion

- if ($to_topic_id)

- {

- $sort_days = 0;

- $posts_per_page = 0;

- }

-*/

-

- // Following section altered for consistency with viewforum, viewtopic, etc.

- // Post ordering options

- $limit_days = array(0 => $user->lang['ALL_POSTS'], 1 => $user->lang['1_DAY'], 7 => $user->lang['7_DAYS'], 14 => $user->lang['2_WEEKS'], 30 => $user->lang['1_MONTH'], 90 => $user->lang['3_MONTHS'], 180 => $user->lang['6_MONTHS'], 364 => $user->lang['1_YEAR']);

- $sort_by_text = array('a' => $user->lang['AUTHOR'], 't' => $user->lang['POST_TIME'], 's' => $user->lang['SUBJECT']);

- $sort_by_sql = array('a' => 'u.username', 't' => 'p.post_id', 's' => 'p.post_subject');

-

- $sort_days = (!empty($_REQUEST['st'])) ? max(intval($_REQUEST['st']), 0) : 0;

- $sort_key = (!empty($_REQUEST['sk'])) ? htmlspecialchars($_REQUEST['sk']) : 't';

- $sort_dir = (!empty($_REQUEST['sd'])) ? htmlspecialchars($_REQUEST['sd']) : 'a';

- $sort_order = $sort_by_sql[$sort_key] . ' ' . (($sort_dir == 'd') ? 'DESC' : 'ASC');

-

- $s_limit_days = $s_sort_key = $s_sort_dir = '';

- gen_sort_selects($limit_days, $sort_by_text, $sort_days, $sort_key, $sort_dir, $s_limit_days, $s_sort_key, $s_sort_dir);

-

- if ($sort_days)

- {

- $min_post_time = time() - ($sort_days * 86400);

-

- $sql = 'SELECT COUNT(post_id) AS num_posts

- FROM ' . POSTS_TABLE . "

- WHERE topic_id = $topic_id

- AND post_time >= $min_post_time";

- $result = $db->sql_query($sql);

-

- $total_posts = ($row = $db->sql_fetchrow($result)) ? $row['num_posts'] : 0;

- $limit_posts_time = "AND p.post_time >= $min_post_time ";

- }

- else

- {

- $limit_posts_time = '';

- $total_posts = $topic_info['topic_replies'] + 1;

- }

-

-// $result = $db->sql_query_limit($sql, $posts_per_page, $start);

- $result = $db->sql_query_limit($sql, $start, $posts_per_page);

- 'UNAPPROVED_IMG' => $user->img('icon_warning', 'POST_NOT_BEEN_APPROVED', FALSE, TRUE),

- 'S_SELECT_SORT_DIR' => $s_sort_dir,

- 'S_SELECT_SORT_KEY' => $s_sort_key,

- 'S_SELECT_SORT_DAYS'=> $s_limit_days,

- add_log('mod', $to_forum_id, $topic_id, 'topic_moved', $forum_id, $to_forum_id);

- add_log('mod', $forum_id, $topic_id, $mode);

- add_log('mod', $to_forum_id, $to_topic_id, 'log_post_merged', $topic_id);

- if (!$post_id)

- $sort_by_sql = array('a' => 'u.username', 't' => 'p.post_id', 's' => 'p.post_subject');

-

- $sort_days = (!empty($_REQUEST['st'])) ? max(intval($_REQUEST['st']), 0) : 0;

- $sort_key = (!empty($_REQUEST['sk'])) ? htmlspecialchars($_REQUEST['sk']) : 't';

- $sort_dir = (!empty($_REQUEST['sd'])) ? htmlspecialchars($_REQUEST['sd']) : 'a';

- $sort_order = $sort_by_sql[$sort_key] . ' ' . (($sort_dir == 'd') ? 'DESC' : 'ASC');

-

- $s_limit_days = $s_sort_key = $s_sort_dir = '';

- gen_sort_selects($limit_days, $sort_by_text, $sort_days, $sort_key, $sort_dir, $s_limit_days, $s_sort_key, $s_sort_dir);

-

- if ($sort_days)

- {

- $min_post_time = time() - ($sort_days * 86400);

-

- $sql = 'SELECT COUNT(post_id) AS num_posts

- FROM ' . POSTS_TABLE . "

- WHERE topic_id = $topic_id

- AND post_time >= $min_post_time";

- $result = $db->sql_query($sql);

-

- $total_posts = ($row = $db->sql_fetchrow($result)) ? $row['num_posts'] : 0;

- $limit_posts_time = "AND p.post_time >= $min_post_time ";

- }

- else

- {

- $limit_posts_time = '';

- $total_posts = $topic_info['topic_replies'] + 1;

- }

-

- $result = $db->sql_query_limit($sql, -1, $start);

-/* $post_id_str = short_id_list($post_id_list);

- redirect(str_replace('&amp;', '&', $mcp_url) . '&mode=forum_view&post_id_list=' . $post_id_str);

- break;

-*/

-

- mcp_header('mcp_forum.html', TRUE);

- global $phpbb_root_path, $phpEx, $SID, $template, $auth, $user, $db, $config;

- // NOTE: this will stop working if the jumpbox method is changed to POST

- if (!empty($_GET['post_id_list']))

- {

- $extra_form_fields['post_id_list'] = $_GET['post_id_list'];

- }

-

- make_jumpbox('mcp.' . $phpEx, $forum_id, $extra_form_fields);

-

- if ($forum_nav)

- {

- generate_forum_nav($forum_info);

- }

- $template->assign_var('S_FORUM_NAV', $forum_nav);

-}

-

-function move_topics($topic_ids, $forum_id, $auto_sync = TRUE)

-{

- global $db;

-

- $forum_ids = array($forum_id);

- $where_sql = (is_array($topic_ids)) ? 'IN (' . implode(', ', $topic_ids) . ')' : '= ' . $topic_ids;

-

- if ($auto_sync)

- {

- $sql = 'SELECT DISTINCT forum_id

- FROM ' . TOPICS_TABLE . '

- WHERE topic_id ' . $where_sql;

- $result = $db->sql_query($sql);

- while ($row = $db->sql_fetchrow($result))

- {

- $forum_ids[] = $row['forum_id'];

- }

- }

-

- $sql = 'DELETE FROM ' . TOPICS_TABLE . "

- WHERE topic_moved_id $where_sql

- AND forum_id = " . $forum_id;

- $db->sql_query($sql);

-

- $sql = 'UPDATE ' . TOPICS_TABLE . "

- SET forum_id = $forum_id

- WHERE topic_id " . $where_sql;

- $db->sql_query($sql);

-

- $sql = 'UPDATE ' . POSTS_TABLE . "

- SET forum_id = $forum_id

- WHERE topic_id " . $where_sql;

- $db->sql_query($sql);

-

- if ($auto_sync)

- {

- resync('forum', 'forum_id', $forum_ids, TRUE);

- }

-}

-

-function move_posts($post_ids, $topic_id, $auto_sync = TRUE)

-{

- global $db;

- if (!is_array($post_ids))

- {

- $post_ids = array($post_ids);

- }

-

- if ($auto_sync)

- {

- $forum_ids = array();

- $topic_ids = array($topic_id);

-

- $sql = 'SELECT DISTINCT topic_id, forum_id

- FROM ' . POSTS_TABLE . '

- WHERE post_id IN (' . implode(', ', $post_ids) . ')';

- $result = $db->sql_query($sql);

- while ($row = $db->sql_fetchrow($result))

- {

- $forum_ids[] = $row['forum_id'];

- $topic_ids[] = $row['topic_id'];

- }

- }

-

- $sql = 'SELECT * FROM ' . TOPICS_TABLE . ' WHERE topic_id = ' . $topic_id;

- $result = $db->sql_query($sql);

- if (!$row = $db->sql_fetchrow($result))

- {

- trigger_error('Topic_post_not_exist');

- }

-

- $sql = 'UPDATE ' . POSTS_TABLE . '

- SET forum_id = ' . $row['forum_id'] . ", topic_id = $topic_id

- WHERE post_id IN (" . implode(', ', $post_ids) . ')';

- $db->sql_query($sql);

-

- if ($auto_sync)

- $forum_ids[] = $row['forum_id'];

-

- resync('topic', 'topic_id', $topic_ids, TRUE);

- resync('forum', 'forum_id', $forum_ids, TRUE);

- }

-}

-

-function delete_topics($where_type, $where_ids, $auto_sync = TRUE)

-{

- global $db;

- $forum_ids = $topic_ids = array();

-

- if (is_array($where_ids))

- {

- $where_ids = array_unique($where_ids);

- }

- delete_posts($where_type, $where_ids, FALSE);

-

- $where_sql = "WHERE $where_type " . ((!is_array($where_ids)) ? "= $where_ids" : 'IN (' . implode(', ', $where_ids) . ')');

-

- $sql = 'SELECT topic_id, forum_id

- FROM ' . TOPICS_TABLE . "

- WHERE $where_type " . ((!is_array($where_ids)) ? "= $where_ids" : 'IN (' . implode(', ', $where_ids) . ')');

-

- $result = $db->sql_query($sql);

- while ($row = $db->sql_fetchrow($result))

- {

- $forum_ids[] = $row['forum_id'];

- $topic_ids[] = $row['topic_id'];

- }

-

- if (!count($topic_ids))

- {

- return;

- }

-

- // TODO: clean up topics cache if any, last read marking, probably some other stuff too

-

- $where_sql = ' IN (' . implode(', ', $topic_ids) . ')';

-

- $db->sql_query('DELETE FROM ' . POLL_VOTES_TABLE . ' WHERE topic_id' . $where_sql);

- $db->sql_query('DELETE FROM ' . POLL_OPTIONS_TABLE . ' WHERE topic_id' . $where_sql);

- $db->sql_query('DELETE FROM ' . TOPICS_WATCH_TABLE . ' WHERE topic_id' . $where_sql);

- $db->sql_query('DELETE FROM ' . TOPICS_TABLE . ' WHERE topic_moved_id' . $where_sql);

- $db->sql_query('DELETE FROM ' . TOPICS_TABLE . ' WHERE topic_id' . $where_sql);

-

- if ($auto_sync)

- {

- resync('forum', 'forum_id', $forum_ids, TRUE);

- }

-}

-

-function delete_posts($where_type, $where_ids, $auto_sync = TRUE)

-{

- global $db;

-

- if (!$where_ids)

- {

- return;

- }

- if (is_array($where_ids))

- {

- $where_ids = array_unique($where_ids);

- }

-

- $post_ids = $topic_ids = $forum_ids = array();

-

- $sql = 'SELECT post_id, topic_id, forum_id

- FROM ' . POSTS_TABLE . "

- WHERE $where_type " . ((!is_array($where_ids)) ? "= $where_ids" : 'IN (' . implode(', ', $where_ids) . ')');

-

- $result = $db->sql_query($sql);

- while ($row = $db->sql_fetchrow($result))

- {

- $post_ids[] = $row['post_id'];

- $topic_ids[] = $row['topic_id'];

- $forum_ids[] = $row['forum_id'];

- }

-

- if (!count($post_ids))

- {

- return;

- }

-

- $where_sql = ' WHERE post_id IN (' . implode(', ', $post_ids) . ')';

-

- $db->sql_return_on_error(FALSE);

- $db->sql_query('DELETE FROM ' . POSTS_TABLE . $where_sql);

-// $db->sql_query('DELETE FROM ' . POSTS_TEXT_TABLE . $where_sql);

- $db->sql_query('DELETE FROM ' . RATINGS_TABLE . $where_sql);

- $db->sql_query('DELETE FROM ' . SEARCH_MATCH_TABLE . $where_sql);

- $db->sql_return_on_error(TRUE);

-

- if ($auto_sync)

- {

- resync('topic', 'topic_id', $topic_ids, TRUE);

- resync('forum', 'forum_id', $forum_ids, TRUE);

- }

-}

-

-//

-// Usage:

-// sync('topic', 'topic_id', 123); <= resynch topic #123

-// sync('topic', 'forum_id', array(2, 3)); <= resynch topics from forum #2 and #3

-// sync('topic'); <= resynch all topics

-//

-/* NOTES:

-

-Queries are kinda tricky.

-

-- subforums: we have to be able to get post/topic counts including subforums, hence the join

-** UPDATE: I removed these joins because they cause too much load on large forums. The new logic may be slightly slower on small forums but is way more scalable.

-

-- empty topics/forums: we have to be able to resync empty topics as well as empty forums therefore we have to use a LEFT join because a full join would only return results greater than 0

-** UPDATE: not anymore needed when sync'ing forums, I'm considering the removal of the join used when sync'ing topics if possible.

-

-- approved posts and topics: I do not like to put the "*_approved = 1" condition in the left join condition but if it's put as a WHERE condition it won't return any row for empty forums. If it causes any problem it could be replaced with a group condition like "GROUP BY p.post_approved"

-

-*/

-function resync($mode, $where_type = '', $where_ids = '', $resync_parents = FALSE)

-{

- global $db, $dbms;

-

- if (is_array($where_ids))

- {

- $where_ids = array_unique($where_ids);

- $where_ids = array($where_ids);

- }

-

- if ($mode == 'approved' || $mode == 'reported')

- {

- $where_sql = "WHERE t.$where_type IN (" . implode(', ', $where_ids) . ')';

- $where_sql_and = $where_sql . "\n\tAND ";

- }

- else

- {

- if (!$where_type)

- {

- $where_sql = $where_sql_and = 'WHERE';

- }

- else

- {

- $where_sql = 'WHERE ' . $mode{0} . ".$where_type IN (" . implode(', ', $where_ids) . ')';

- $where_sql_and = $where_sql . "\n\tAND ";

- }

- }

-

- switch ($mode)

- {

- case 'approved':

- $sql = 'SELECT t.topic_id, t.topic_approved, p.post_approved

- FROM ' . TOPICS_TABLE . ' t, ' . POSTS_TABLE . " p

- $where_sql_and p.post_id = t.topic_first_post_id";

- $result = $db->sql_query($sql);

-

- $topic_ids = $approved_ids = $unapproved_ids = array();

-

- while ($row = $db->sql_fetchrow($result))

- {

- if ($row['topic_approved'] != $row['post_approved'])

- {

- if ($row['post_approved'])

- {

- $approved_ids[] = $row['topic_id'];

- }

- else

- {

- $unapproved_ids[] = $row['topic_id'];

- }

- }

- }

-

- if (count($approved_ids))

- {

- $sql = 'UPDATE ' . TOPICS_TABLE . '

- SET topic_approved = 1

- WHERE topic_id IN (' . implode(', ', $approved_ids) . ')';

- $db->sql_query($sql);

- }

- if (count($unapproved_ids))

- {

- $sql = 'UPDATE ' . TOPICS_TABLE . '

- SET topic_approved = 0

- WHERE topic_id IN (' . implode(', ', $unapproved_ids) . ')';

- $db->sql_query($sql);

- }

- return;

- break;

-

- case 'reported':

- $sql = "SELECT t.topic_id, t.topic_reported, p.post_reported, COUNT(p.post_id) AS total

- FROM " . TOPICS_TABLE . ' t, ' . POSTS_TABLE . " p

- $where_sql_and p.topic_id = t.topic_id

- GROUP BY p.topic_id, p.post_reported";

- $result = $db->sql_query($sql);

-

- $topic_ids = $status = $status_real = $reported_ids = $unreported_ids = array();

- while ($row = $db->sql_fetchrow($result))

- {

- if (!isset($status[$row['topic_id']]))

- {

- $topic_ids[] = $row['topic_id'];

- $status[$row['topic_id']] = $row['topic_reported'];

- $status_real[$row['topic_id']] = 0;

- }

- if ($row['total'] > 0 && $row['post_reported'])

- {

- $status_real[$row['topic_id']] = 1;

- }

- }

-

- foreach ($topic_ids as $i => $topic_id)

- {

- if ($status[$topic_id] != $status_real[$topic_id])

- {

- if ($status_real[$topic_id])

- {

- $reported_ids[] = $topic_id;

- }

- else

- {

- $unreported_ids[] = $topic_id;

- }

- }

- }

-

- if (count($reported_ids))

- {

- $sql = 'UPDATE ' . TOPICS_TABLE . '

- SET topic_reported = 1

- WHERE topic_id IN (' . implode(', ', $reported_ids) . ')';

- $db->sql_query($sql);

- }

- if (count($unreported_ids))

- {

- $sql = 'UPDATE ' . TOPICS_TABLE . '

- SET topic_reported = 0

- WHERE topic_id IN (' . implode(', ', $unreported_ids) . ')';

- $db->sql_query($sql);

- }

-

- return;

- break;

-

- case 'forum':

- if ($resync_parents)

- {

- $forum_ids = array();

-

- $sql = 'SELECT f2.forum_id

- FROM ' . FORUMS_TABLE . ' f, ' . FORUMS_TABLE . " f2

- $where_sql_and f.left_id BETWEEN f2.left_id AND f2.right_id";

-

- $result = $db->sql_query($sql);

- while ($row = $db->sql_fetchrow($result))

- {

- $forum_ids[] = $row['forum_id'];

- }

-

- if (count($forum_ids))

- {

- resync('forum', 'forum_id', $forum_ids, FALSE);

- }

-

- return;

- }

-

- // 1° Get the list of all forums and their children

- $sql = 'SELECT f.*, f2.forum_id AS id

- FROM ' . FORUMS_TABLE . ' f, ' . FORUMS_TABLE . " f2

- $where_sql_and f2.left_id BETWEEN f.left_id AND f.right_id";

-

- $forum_data = $forum_ids = $post_ids = $subforum_list = $post_count = $last_post_id = $post_info = $topic_count = array();

-

- $result = $db->sql_query($sql);

- while ($row = $db->sql_fetchrow($result))

- {

- $forum_ids[$row['id']] = $row['id'];

- if (!isset($subforum_list[$row['forum_id']]))

- {

- $forum_data[$row['forum_id']] = $row;

- $forum_data[$row['forum_id']]['posts'] = 0;

- $forum_data[$row['forum_id']]['topics'] = 0;

- $forum_data[$row['forum_id']]['last_post_id'] = 0;

- $forum_data[$row['forum_id']]['last_post_time'] = 0;

- $forum_data[$row['forum_id']]['last_poster_id'] = 0;

- $forum_data[$row['forum_id']]['last_poster_name'] = '';

- $subforum_list[$row['forum_id']] = array($row['id']);

- }

- else

- {

- $subforum_list[$row['forum_id']][] = $row['id'];

- }

- }

-

- // 2° Get topic counts for each forum

- $sql = 'SELECT forum_id, COUNT(topic_id) AS forum_topics

- FROM ' . TOPICS_TABLE . '

- WHERE forum_id IN (' . implode(', ', $forum_ids) . ')

- AND topic_approved = 1

- GROUP BY forum_id';

- $result = $db->sql_query($sql);

- while ($row = $db->sql_fetchrow($result))

- {

- $topic_count[$row['forum_id']] = intval($row['forum_topics']);

- }

-

- // 3° Get post counts for each forum

- $sql = 'SELECT forum_id, COUNT(post_id) AS forum_posts, MAX(post_id) AS last_post_id

- FROM ' . POSTS_TABLE . '

- WHERE forum_id IN (' . implode(', ', $forum_ids) . ')

- AND post_approved = 1

- GROUP BY forum_id';

- $result = $db->sql_query($sql);

- while ($row = $db->sql_fetchrow($result))

- {

- $post_count[$row['forum_id']] = intval($row['forum_posts']);

- $last_post_id[$row['forum_id']] = intval($row['last_post_id']);

- }

-

- // 4° Do the math

- foreach ($subforum_list as $forum_id => $subforums)

- {

- foreach ($subforums as $subforum_id)

- {

- if (isset($topic_count[$subforum_id]))

- {

- $forum_data[$forum_id]['topics'] += $topic_count[$subforum_id];

- }

- if (isset($post_count[$subforum_id]))

- {

- $forum_data[$forum_id]['posts'] += $post_count[$subforum_id];

- $forum_data[$forum_id]['last_post_id'] = max($forum_data[$forum_id]['last_post_id'], $last_post_id[$subforum_id]);

- }

- }

- }

-

- // 5° Retrieve last_post infos

- foreach ($forum_data as $forum_id => $data)

- {

- if ($data['last_post_id'])

- {

- $post_ids[] = $data['last_post_id'];

- }

- }

- if (count($post_ids))

- {

- $sql = 'SELECT p.post_id, p.poster_id, u.username, p.post_time

- FROM ' . POSTS_TABLE . ' p, ' . USERS_TABLE . ' u

- WHERE p.post_id IN (' . implode(', ', $post_ids) . ')

- AND p.poster_id = u.user_id';

- $result = $db->sql_query($sql);

- while ($row = $db->sql_fetchrow($result))

- {

- $post_info[$row['post_id']] = $row;

- }

-

- foreach ($forum_data as $forum_id => $data)

- {

- if ($data['last_post_id'])

- {

- $forum_data[$forum_id]['last_post_time'] = $post_info[$data['last_post_id']]['post_time'];

- $forum_data[$forum_id]['last_poster_id'] = $post_info[$data['last_post_id']]['poster_id'];

- $forum_data[$forum_id]['last_poster_name'] = $post_info[$data['last_post_id']]['username'];

- }

- }

- }

-

- $fieldnames = array('posts', 'topics', 'last_post_id', 'last_post_time', 'last_poster_id', 'last_poster_name');

-

- foreach ($forum_data as $forum_id => $row)

- {

- $need_update = FALSE;

-

- foreach ($fieldnames as $fieldname)

- {

- verify_data('forum', $fieldname, $need_update, $row);

- }

-

- if ($need_update)

- {

- $sql = array();

- foreach ($fieldnames as $fieldname)

- {

- if (preg_match('/name$/', $fieldname))

- {

- if (isset($row[$fieldname]))

- {

- $sql['forum_' . $fieldname] = (string) $row[$fieldname];

- }

- else

- {

- $sql['forum_' . $fieldname] = '';

- }

- }

- else

- {

- if (isset($row[$fieldname]))

- {

- $sql['forum_' . $fieldname] = (int) $row[$fieldname];

- }

- else

- {

- $sql['forum_' . $fieldname] = 0;

- }

- }

- }

-

- $sql = 'UPDATE ' . FORUMS_TABLE . '

- SET ' . $db->sql_build_array('UPDATE', $sql) . '

- WHERE forum_id = ' . $forum_id;

- $db->sql_query($sql);

- }

- }

- break;

-

- case 'topic':

- $topic_data = $topic_ids = $post_ids = $approved_ids = $unapproved_ids = $resync_forums = array();

-

- $sql = 'SELECT t.*, p.post_approved, COUNT(p.post_id) AS total_posts, MIN(p.post_id) AS first_post_id, MAX(p.post_id) AS last_post_id

- FROM ' . TOPICS_TABLE . ' t, ' . POSTS_TABLE . " p

- $where_sql_and p.topic_id = t.topic_id

- GROUP BY p.topic_id, p.post_approved";

-

- $result = $db->sql_query($sql);

- while ($row = $db->sql_fetchrow($result))

- {

- $row['total_posts'] = intval($row['total_posts']);

- $row['first_post_id'] = intval($row['first_post_id']);

- $row['last_post_id'] = intval($row['last_post_id']);

- $row['replies'] = $row['total_posts'] - 1;

-

- if (!isset($topic_data[$row['topic_id']]))

- {

- $topic_ids[] = $row['topic_id'];

- $topic_data[$row['topic_id']] = $row;

- }

- else

- {

- if ($topic_data[$row['topic_id']]['first_post_id'] > $row['first_post_id'])

- {

- $topic_data[$row['topic_id']]['first_post_id'] = $row['first_post_id'];

- }

- if ($row['post_approved'])

- {

- $topic_data[$row['topic_id']]['replies'] = $row['replies'];

- $topic_data[$row['topic_id']]['last_post_id'] = $row['last_post_id'];

- }

- }

- }

-

- foreach ($topic_data as $topic_id => $row)

- {

- $post_ids[] = $row['first_post_id'];

- if ($row['first_post_id'] != $row['last_post_id'])

- {

- $post_ids[] = $row['last_post_id'];

- }

- }

-

- if (!count($topic_ids))

- {

- // If we get there, topic ids were invalid or topics did not contain any posts

-

- delete_topics($where_type, $where_ids);

- return;

- }

- else

- {

- if (count($where_ids))

- {

- // If we get there, we already have a range of topic_ids; make a diff and delete topics

- // that didn't return any row

- $delete_ids = array_diff($where_ids, $topic_ids);

- if (count($delete_ids))

- {

- delete_topics('topic_id', $topic_ids);

- }

- }

- else

- {

- // We're resync'ing by forum_id so we'll have to determine which topics we have to delete

- $sql = 'SELECT topic_id

- FROM ' . TOPICS_TABLE . "

- $where_sql_and topic_id NOT IN (" . implode($topic_ids) . ')';

- $result = $db->sql_query($sql);

-

- $delete_ids = array();

- while ($row = $db->sql_fetchrow($result))

- {

- $delete_ids[] = $row['topic_id'];

- }

-

- if (count($delete_ids))

- {

- delete_topics('topic_id', $delete_ids);

- }

- }

- }

-

- $sql = 'SELECT p.post_id, p.topic_id, p.post_approved, p.poster_id, p.post_username, p.post_time, u.username

- FROM ' . POSTS_TABLE . ' p, ' . USERS_TABLE . ' u

- WHERE p.post_id IN (' . implode(', ', $post_ids) . ')

- AND u.user_id = p.poster_id';

- $result = $db->sql_query($sql);

- while ($row = $db->sql_fetchrow($result))

- {

- if ($row['post_id'] == $topic_data[$row['topic_id']]['first_post_id'])

- {

- if ($topic_data[$row['topic_id']]['topic_approved'] != $row['post_approved'])

- {

- if ($row['post_approved'])

- {

- $approved_ids[] = $row['topic_id'];

- }

- else

- {

- $unapproved_ids[] = $row['topic_id'];

- }

- }

- $topic_data[$row['topic_id']]['time'] = $row['post_time'];

- $topic_data[$row['topic_id']]['poster'] = $row['poster_id'];

- $topic_data[$row['topic_id']]['first_poster_name'] = ($row['poster_id'] == ANONYMOUS) ? $row['post_username'] : $row['username'];

- }

- if ($row['post_id'] == $topic_data[$row['topic_id']]['last_post_id'])

- {

- $topic_data[$row['topic_id']]['last_poster_id'] = $row['poster_id'];

- $topic_data[$row['topic_id']]['last_post_time'] = $row['post_time'];

- $topic_data[$row['topic_id']]['last_poster_name'] = ($row['poster_id'] == ANONYMOUS) ? $row['post_username'] : $row['username'];

- }

- }

-

- if (count($approved_ids))

- {

- $sql = 'UPDATE ' . TOPICS_TABLE . '

- SET topic_approved = 1

- WHERE topic_id IN (' . implode(', ', $approved_ids) . ')';

- $db->sql_query($sql);

- }

- if (count($unapproved_ids))

- {

- $sql = 'UPDATE ' . TOPICS_TABLE . '

- SET topic_approved = 0

- WHERE topic_id IN (' . implode(', ', $unapproved_ids) . ')';

- $db->sql_query($sql);

- }

-

- $fieldnames = array('time', 'replies', 'poster', 'first_post_id', 'first_poster_name', 'last_post_id', 'last_post_time', 'last_poster_id', 'last_poster_name');

-

- foreach ($topic_data as $topic_id => $row)

- {

- $need_update = FALSE;

-

- foreach ($fieldnames as $fieldname)

- {

- verify_data('topic', $fieldname, $need_update, $row);

- }

-

- if ($need_update)

- {

- $sql = array();

- foreach ($fieldnames as $fieldname)

- {

- if (preg_match('/name$/', $fieldname))

- {

- $sql['topic_' . $fieldname] = (string) $row[$fieldname];

- }

- else

- {

- $sql['topic_' . $fieldname] = (int) $row[$fieldname];

- }

- }

-

- // NOTE: should shadow topics be updated as well?

- $sql = 'UPDATE ' . TOPICS_TABLE . '

- SET ' . $db->sql_build_array('UPDATE', $sql) . '

- WHERE topic_id = ' . $topic_id;

- $db->sql_query($sql);

-

- $resync_forums[] = $row['forum_id'];

- }

- }

-

- // if some topics have been resync'ed then resync parent forums

- if ($resync_parents && count($resync_forums))

- {

- $sql = 'SELECT f.forum_id

- FROM ' .FORUMS_TABLE . ' f, ' . FORUMS_TABLE . ' f2

- WHERE f.left_id BETWEEN f2.left_id AND f2.right_id

- AND f2.forum_id IN (' . implode(', ', array_unique($resync_forums)) . ')

- GROUP BY f.forum_id';

- $result = $db->sql_query($sql);

-

- $forum_ids = array();

- while ($row = $db->sql_fetchrow($result))

- {

- $forum_ids[] = $row['forum_id'];

- }

- if (count($forum_ids))

- {

- resync('forum', 'forum_id', $forum_ids, FALSE);

- }

- }

- break;

- }

-

-

- // Should we resync posts and topics totals in config table?

- /*

- $result = $db->sql_query('SELECT SUM(forum_topics) AS total_topics, SUM(forum_posts) AS total_posts FROM ' . FORUMS_TABLE);

- $row = $db->sql_fetchrow($result);

- set_config('total_posts', $row['total_posts']);

- set_config('total_topics', $row['total_topics']);

- */

-}

-

-

-function verify_data($type, $fieldname, &$need_update, &$data)

-{

- // Check if the corresponding data actually exists. Must not fail when equal to zero.

- if (!isset($data[$fieldname]) || is_null($data[$fieldname]))

- {

- return;

- if ($data[$fieldname] != $data[$type . '_' . $fieldname])

- $need_update = TRUE;

- $data[$type . '_' . $fieldname] = $data[$fieldname];

- 'log_topic_locked' => 'Locked topic',

- 'log_topic_unlocked' => 'Unlocked topic',

- 'log_topic_moved' => 'Moved topic from forum #%s',

- 'log_topic_split' => 'Split topic from topic #%s',

- 'log_topic_deleted' => 'Deleted topic',

- 'log_topic_approved' => 'Approved topic',

- 'log_topic_unapproved' => 'Unapproved topic',

- 'log_post_approved' => 'Approved post',

- 'log_post_unapproved' => 'Unapproved post',

- 'log_post_deleted' => 'Deleted posts',

- 'log_post_merged' => 'Merged posts from topic #%s',

- 'log_set_announce' => 'Topic type changed to Announcement',

- 'log_set_sticky' => 'Topic type changed to Sticky',

- 'log_set_normal' => 'Topic type changed to Regular'