Code Forge

<?php

/***************************************************************************

 *                                 modcp.php

 *                            -------------------

 *   begin                : July 4, 2001

 *   copyright            : (C) 2001 The phpBB Group

 *   email                : support@phpbb.com

 *

 *   $Id$

 *

 *

 ***************************************************************************/

/***************************************************************************

 *

 *   This program is free software; you can redistribute it and/or modify

 *   it under the terms of the GNU General Public License as published by

 *   the Free Software Foundation; either version 2 of the License, or

 *   (at your option) any later version.

 *

 ***************************************************************************/

/**

 * Moderator Control Panel

 *

 * From this 'Control Panel' the moderator of a forum will be able to do

 * mass topic operations (locking/unlocking/moving/deleteing), and it will

 * provide an interface to do quick locking/unlocking/moving/deleting of

 * topics via the moderator operations buttons on all of the viewtopic pages.

 */

define('IN_PHPBB', true);

$phpbb_root_path = './';

include($phpbb_root_path . 'extension.inc');

include($phpbb_root_path . 'common.'.$phpEx);

include($phpbb_root_path . 'includes/bbcode.'.$phpEx);

include($phpbb_root_path . 'includes/functions_admin.'.$phpEx);

//

// Obtain initial var settings

//

if ( isset($HTTP_GET_VARS[POST_FORUM_URL]) || isset($HTTP_POST_VARS[POST_FORUM_URL]) )

{

        $forum_id = (isset($HTTP_POST_VARS[POST_FORUM_URL])) ? intval($HTTP_POST_VARS[POST_FORUM_URL]) : intval($HTTP_GET_VARS[POST_FORUM_URL]);

}

else

{

        $forum_id = '';

}

if ( isset($HTTP_GET_VARS[POST_POST_URL]) || isset($HTTP_POST_VARS[POST_POST_URL]) )

{

        $post_id = (isset($HTTP_POST_VARS[POST_POST_URL])) ? intval($HTTP_POST_VARS[POST_POST_URL]) : intval($HTTP_GET_VARS[POST_POST_URL]);

}

else

{

        $post_id = '';

}

if ( isset($HTTP_GET_VARS[POST_TOPIC_URL]) || isset($HTTP_POST_VARS[POST_TOPIC_URL]) )

{

        $topic_id = (isset($HTTP_POST_VARS[POST_TOPIC_URL])) ? intval($HTTP_POST_VARS[POST_TOPIC_URL]) : intval($HTTP_GET_VARS[POST_TOPIC_URL]);

}

else

{

        $topic_id = '';

}

$confirm = ( $HTTP_POST_VARS['confirm'] ) ? TRUE : 0;

//

// Continue var definitions

//

$start = ( isset($HTTP_GET_VARS['start']) ) ? intval($HTTP_GET_VARS['start']) : 0;

$delete = ( isset($HTTP_POST_VARS['delete']) ) ? TRUE : FALSE;

$move = ( isset($HTTP_POST_VARS['move']) ) ? TRUE : FALSE;

$lock = ( isset($HTTP_POST_VARS['lock']) ) ? TRUE : FALSE;

$unlock = ( isset($HTTP_POST_VARS['unlock']) ) ? TRUE : FALSE;

if ( isset($HTTP_POST_VARS['mode']) || isset($HTTP_GET_VARS['mode']) )

{

        $mode = ( isset($HTTP_POST_VARS['mode']) ) ? $HTTP_POST_VARS['mode'] : $HTTP_GET_VARS['mode'];

}

else

{

        if ( $delete )

        {

                $mode = 'delete';

        }

        else if ( $move )

        {

                $mode = 'move';

        }

        else if ( $lock )

        {

                $mode = 'lock';

        }

        else if ( $unlock )

        {

                $mode = 'unlock';

        }

        else

        {

                $mode = '';

        }

}

//

// Obtain relevant data

//

if ( !empty($topic_id) )

{

        $sql = "SELECT f.forum_id, f.forum_name, f.forum_topics

                FROM " . TOPICS_TABLE . " t, " . FORUMS_TABLE . " f

                WHERE t.topic_id = " . $topic_id . "

                        AND f.forum_id = t.forum_id";

        if ( !($result = $db->sql_query($sql)) )

        {

                message_die(GENERAL_MESSAGE, 'Topic_post_not_exist');

        }

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

        $forum_topics = ( $topic_row['forum_topics'] == 0 ) ? 1 : $topic_row['forum_topics'];

        $forum_id = $topic_row['forum_id'];

        $forum_name = $topic_row['forum_name'];

}

else if ( !empty($forum_id) )

{

        $sql = "SELECT forum_name, forum_topics

                FROM " . FORUMS_TABLE . "

                WHERE forum_id = " . $forum_id;

        if ( !($result = $db->sql_query($sql)) )

        {

                message_die(GENERAL_MESSAGE, 'Forum_not_exist');

        }

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

        $forum_topics = ( $topic_row['forum_topics'] == 0 ) ? 1 : $topic_row['forum_topics'];

        $forum_name = $topic_row['forum_name'];

}

else

{

        message_die(GENERAL_MESSAGE, 'Forum_not_exist');

}

//

// Start session management

//

$userdata = session_pagestart($user_ip, $forum_id);

init_userprefs($userdata);

//

// End session management

//

//

// Check if user did or did not confirm

// If they did not, forward them to the last page they were on

//

if ( isset($HTTP_POST_VARS['cancel']) )

{

        if ( $topic_id )

        {

                $redirect = "viewtopic.$phpEx?" . POST_TOPIC_URL . "=$topic_id";

        }

        else if ( $forum_id )

        {

                $redirect = "viewforum.$phpEx?" . POST_FORUM_URL . "=$forum_id";

        }

        else

        {

                $redirect = "index.$phpEx";

        }

        $header_location = ( @preg_match('/Microsoft|WebSTAR|Xitami/', getenv('SERVER_SOFTWARE')) ) ? 'Refresh: 0; URL=' : 'Location: ';

        header($header_location . append_sid($redirect, true));

        exit;

}

//

// Start auth check

//

$is_auth = auth(AUTH_ALL, $forum_id, $userdata);

if ( !$is_auth['auth_mod'] )

{

        message_die(GENERAL_MESSAGE, $lang['Not_Moderator'], $lang['Not_Authorised']);

}

//

// End Auth Check

//

//

// Do major work ...

//

switch( $mode )

{

        case 'delete':

                $page_title = $lang['Mod_CP'];

                include($phpbb_root_path . 'includes/page_header.'.$phpEx);

                if ( $confirm )

                {

                        include($phpbb_root_path . 'includes/functions_search.'.$phpEx);

                        $topics = ( isset($HTTP_POST_VARS['topic_id_list']) ) ?  $HTTP_POST_VARS['topic_id_list'] : array($topic_id);

                        $topic_id_sql = '';

                        for($i = 0; $i < count($topics); $i++)

                        {

                                $topic_id_sql .= ( ( $topic_id_sql != '' ) ? ', ' : '' ) . $topics[$i];

                        }

                        $sql = "SELECT post_id

                                FROM " . POSTS_TABLE . "

                                WHERE topic_id IN ($topic_id_sql)";

                        if ( !$result = $db->sql_query($sql) )

                        {

                                message_die(GENERAL_ERROR, 'Could not get post id information', '', __LINE__, __FILE__, $sql);

                        }

                        $post_id_sql = '';

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

                        {

                                $post_id_sql .= ( ( $post_id_sql != '' ) ? ', ' : '' ) . $row['post_id'];

                        }

                        $db->sql_freeresult($result);

                        $sql = "SELECT vote_id

                                FROM " . VOTE_DESC_TABLE . "

                                WHERE topic_id IN ($topic_id_sql)";

                        if ( !($result = $db->sql_query($sql)) )

                        {

                                message_die(GENERAL_ERROR, 'Could not get vote id information', '', __LINE__, __FILE__, $sql);

                        }

                        $vote_id_sql = '';

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

                        {

                                $vote_id_sql .= ( ( $vote_id_sql != '' ) ? ', ' : '' ) . $row['vote_id'];

                        }

                        $db->sql_freeresult($result);

                        //

                        // Got all required info so go ahead and start deleting everything

                        //

                        $sql = "DELETE

                                FROM " . TOPICS_TABLE . "

                                WHERE topic_id IN ($topic_id_sql)

                                        OR topic_moved_id IN ($topic_id_sql)";

                        if ( !$db->sql_query($sql, BEGIN_TRANSACTION) )

                        {

                                message_die(GENERAL_ERROR, 'Could not delete topics', '', __LINE__, __FILE__, $sql);

                        }

                        if ( $post_id_sql != '' )

                        {

                                $sql = "DELETE

                                        FROM " . POSTS_TABLE . "

                                        WHERE post_id IN ($post_id_sql)";

                                if ( !$db->sql_query($sql) )

                                {

                                        message_die(GENERAL_ERROR, 'Could not delete posts', '', __LINE__, __FILE__, $sql);

                                }

                                $sql = "DELETE

                                        FROM " . POSTS_TEXT_TABLE . "

                                        WHERE post_id IN ($post_id_sql)";

                                if ( !$db->sql_query($sql) )

                                {

                                        message_die(GENERAL_ERROR, 'Could not delete posts text', '', __LINE__, __FILE__, $sql);

                                }

                                remove_search_post($post_id_sql);

                        }

                        if ( $vote_id_sql != '' )

                        {

                                $sql = "DELETE

                                        FROM " . VOTE_DESC_TABLE . "

                                        WHERE vote_id IN ($vote_id_sql)";

                                if ( !$db->sql_query($sql) )

                                {

                                        message_die(GENERAL_ERROR, 'Could not delete vote descriptions', '', __LINE__, __FILE__, $sql);

                                }

                                $sql = "DELETE

                                        FROM " . VOTE_RESULTS_TABLE . "

                                        WHERE vote_id IN ($vote_id_sql)";

                                if ( !$db->sql_query($sql) )

                                {

                                        message_die(GENERAL_ERROR, 'Could not delete vote results', '', __LINE__, __FILE__, $sql);

                                }

                                $sql = "DELETE

                                        FROM " . VOTE_USERS_TABLE . "

                                        WHERE vote_id IN ($vote_id_sql)";

                                if ( !$db->sql_query($sql) )

                                {

                                        message_die(GENERAL_ERROR, 'Could not delete vote users', '', __LINE__, __FILE__, $sql);

                                }

                        }

                        $sql = "DELETE

                                FROM " . TOPICS_WATCH_TABLE . "

                                WHERE topic_id IN ($topic_id_sql)";

                        if ( !$db->sql_query($sql, END_TRANSACTION) )

                        {

                                message_die(GENERAL_ERROR, 'Could not delete watched post list', '', __LINE__, __FILE__, $sql);

                        }

                        sync('forum', $forum_id);

                        if ( !empty($topic_id) )

                        {

                                $redirect_page = append_sid("viewforum.$phpEx?" . POST_FORUM_URL . "=$forum_id");

                                $l_redirect = sprintf($lang['Click_return_forum'], '<a href="' . $redirect_page . '">', '</a>');

                        }

                        else

                        {

                                $redirect_page = append_sid("modcp.$phpEx?" . POST_FORUM_URL . "=$forum_id");

                                $l_redirect = sprintf($lang['Click_return_modcp'], '<a href="' . $redirect_page . '">', '</a>');

                        }

                        $template->assign_vars(array(

                                'META' => '<meta http-equiv="refresh" content="3;url=' . $redirect_page . '">')

                        );

                        message_die(GENERAL_MESSAGE, $lang['Topics_Removed'] . '<br /><br />' . $l_redirect);

                }

                else

                {

                        // Not confirmed, show confirmation message

                        if ( empty($HTTP_POST_VARS['topic_id_list']) && empty($topic_id) )

                        {

                                message_die(GENERAL_MESSAGE, $lang['None_selected']);

                        }

                        $hidden_fields = '<input type="hidden" name="mode" value="' . $mode . '" /><input type="hidden" name="' . POST_FORUM_URL . '" value="' . $forum_id . '" />';

                        if ( isset($HTTP_POST_VARS['topic_id_list']) )

                        {

                                $topics = $HTTP_POST_VARS['topic_id_list'];

                                for($i = 0; $i < count($topics); $i++)

                                {

                                        $hidden_fields .= '<input type="hidden" name="topic_id_list[]" value="' . intval($topics[$i]) . '" />';

                                }

                        }

                        else

                        {

                                $hidden_fields .= '<input type="hidden" name="' . POST_TOPIC_URL . '" value="' . $topic_id . '" />';

                        }

                        //

                        // Set template files

                        //

                        $template->set_filenames(array(

                                'confirm' => 'confirm_body.tpl')

                        );

                        $template->assign_vars(array(

                                'MESSAGE_TITLE' => $lang['Confirm'],

                                'MESSAGE_TEXT' => $lang['Confirm_delete_topic'],

                                'L_YES' => $lang['Yes'],

                                'L_NO' => $lang['No'],

                                'S_CONFIRM_ACTION' => append_sid("modcp.$phpEx"),

                                'S_HIDDEN_FIELDS' => $hidden_fields)

                        );

                        $template->pparse('confirm');

                        include($phpbb_root_path . 'includes/page_tail.'.$phpEx);

                }

                break;

        case 'move':

                $page_title = $lang['Mod_CP'];

                include($phpbb_root_path . 'includes/page_header.'.$phpEx);

                if ( $confirm )

                {

                        if ( empty($HTTP_POST_VARS['topic_id_list']) && empty($topic_id) )

                        {

                                message_die(GENERAL_MESSAGE, $lang['None_selected']);

                        }

                        $new_forum_id = $HTTP_POST_VARS['new_forum'];

                        $old_forum_id = $forum_id;

                        if ( $new_forum_id != $old_forum_id )

                        {

                                $topics = ( isset($HTTP_POST_VARS['topic_id_list']) ) ?  $HTTP_POST_VARS['topic_id_list'] : array($topic_id);

                                $topic_list = '';

                                for($i = 0; $i < count($topics); $i++)

                                {

                                        $topic_list .= ( ( $topic_list != '' ) ? ', ' : '' ) . intval($topics[$i]);

                                }

                                $sql = "SELECT *

                                        FROM " . TOPICS_TABLE . "

                                        WHERE topic_id IN ($topic_list)

                                                AND topic_status <> " . TOPIC_MOVED;

                                if ( !($result = $db->sql_query($sql, BEGIN_TRANSACTION)) )

                                {

                                        message_die(GENERAL_ERROR, 'Could not select from topic table', '', __LINE__, __FILE__, $sql);

                                }

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

                                $db->sql_freeresult($result);

                                for($i = 0; $i < count($row); $i++)

                                {

                                        $topic_id = $row[$i]['topic_id'];

                                        if ( isset($HTTP_POST_VARS['move_leave_shadow']) )

                                        {

                                                // Insert topic in the old forum that indicates that the forum has moved.

                                                $sql = "INSERT INTO " . TOPICS_TABLE . " (forum_id, topic_title, topic_poster, topic_time, topic_status, topic_type, topic_vote, topic_views, topic_replies, topic_first_post_id, topic_last_post_id, topic_moved_id)

                                                        VALUES ($old_forum_id, '" . addslashes(str_replace("\'", "''", $row[$i]['topic_title'])) . "', '" . str_replace("\'", "''", $row[$i]['topic_poster']) . "', " . $row[$i]['topic_time'] . ", " . TOPIC_MOVED . ", " . POST_NORMAL . ", " . $row[$i]['topic_vote'] . ", " . $row[$i]['topic_views'] . ", " . $row[$i]['topic_replies'] . ", " . $row[$i]['topic_first_post_id'] . ", " . $row[$i]['topic_last_post_id'] . ", $topic_id)";

                                                if ( !$db->sql_query($sql) )

                                                {

                                                        message_die(GENERAL_ERROR, 'Could not insert shadow topic', '', __LINE__, __FILE__, $sql);

                                                }

                                        }

                                        $sql = "UPDATE " . TOPICS_TABLE . "

                                                SET forum_id = $new_forum_id

                                                WHERE topic_id = $topic_id";

                                        if ( !$db->sql_query($sql) )

                                        {

                                                message_die(GENERAL_ERROR, 'Could not update old topic', '', __LINE__, __FILE__, $sql);

                                        }

                                        $sql = "UPDATE " . POSTS_TABLE . "

                                                SET forum_id = $new_forum_id

                                                WHERE topic_id = $topic_id";

                                        if ( !$db->sql_query($sql) )

                                        {

                                                message_die(GENERAL_ERROR, 'Could not update post topic ids', '', __LINE__, __FILE__, $sql);

                                        }

                                }

                                // Sync the forum indexes

                                sync('forum', $new_forum_id);

                                sync('forum', $old_forum_id);

                                $message = $lang['Topics_Moved'] . '<br /><br />';

                        }

                        else

                        {

                                $message = $lang['No_Topics_Moved'] . '<br /><br />';

                        }

                        if ( !empty($topic_id) )

                        {

                                $redirect_page = append_sid("viewtopic.$phpEx?" . POST_TOPIC_URL . "=$topic_id");

                                $message .= sprintf($lang['Click_return_topic'], '<a href="' . $redirect_page . '">', '</a>');

                        }

                        else

                        {

                                $redirect_page = append_sid("modcp.$phpEx?" . POST_FORUM_URL . "=$forum_id");

                                $message .= sprintf($lang['Click_return_modcp'], '<a href="' . $redirect_page . '">', '</a>');

                        }

                        $message = $message . '<br \><br \>' . sprintf($lang['Click_return_forum'], '<a href="' . append_sid("viewforum.$phpEx?" . POST_FORUM_URL . "=$old_forum_id") . '">', '</a>');

                        $template->assign_vars(array(

                                'META' => '<meta http-equiv="refresh" content="3;url=' . $redirect_page . '">')

                        );

                        message_die(GENERAL_MESSAGE, $message);

                }

                else

                {

                        if ( empty($HTTP_POST_VARS['topic_id_list']) && empty($topic_id) )

                        {

                                message_die(GENERAL_MESSAGE, $lang['None_selected']);

                        }

                        $hidden_fields = '<input type="hidden" name="mode" value="' . $mode . '" /><input type="hidden" name="' . POST_FORUM_URL . '" value="' . $forum_id . '" />';

                        if ( isset($HTTP_POST_VARS['topic_id_list']) )

                        {

                                $topics = $HTTP_POST_VARS['topic_id_list'];

                                for($i = 0; $i < count($topics); $i++)

                                {

                                        $hidden_fields .= '<input type="hidden" name="topic_id_list[]" value="' . intval($topics[$i]) . '" />';

                                }

                        }

                        else

                        {

                                $hidden_fields .= '<input type="hidden" name="' . POST_TOPIC_URL . '" value="' . $topic_id . '" />';

                        }

                        //

                        // Set template files

                        //

                        $template->set_filenames(array(

                                'movetopic' => 'modcp_move.tpl')

                        );

                        $template->assign_vars(array(

                                'MESSAGE_TITLE' => $lang['Confirm'],

                                'MESSAGE_TEXT' => $lang['Confirm_move_topic'],

                                'L_MOVE_TO_FORUM' => $lang['Move_to_forum'],

                                'L_LEAVESHADOW' => $lang['Leave_shadow_topic'],

                                'L_YES' => $lang['Yes'],

                                'L_NO' => $lang['No'],

                                'S_FORUM_SELECT' => make_forum_select('new_forum', $forum_id),

                                'S_MODCP_ACTION' => append_sid("modcp.$phpEx"),

                                'S_HIDDEN_FIELDS' => $hidden_fields)

                        );

                        $template->pparse('movetopic');

                        include($phpbb_root_path . 'includes/page_tail.'.$phpEx);

                }

                break;

        case 'lock':

                if ( empty($HTTP_POST_VARS['topic_id_list']) && empty($topic_id) )

                {

                        message_die(GENERAL_MESSAGE, $lang['None_selected']);

                }

                $topics = ( isset($HTTP_POST_VARS['topic_id_list']) ) ?  $HTTP_POST_VARS['topic_id_list'] : array($topic_id);

                $topic_id_sql = '';

                for($i = 0; $i < count($topics); $i++)

                {

                        $topic_id_sql .= ( ( $topic_id_sql != '' ) ? ', ' : '' ) . $topics[$i];

                }

                $sql = "UPDATE " . TOPICS_TABLE . "

                        SET topic_status = " . TOPIC_LOCKED . "

                        WHERE topic_id IN ($topic_id_sql)

                                AND topic_moved_id = 0";

                if ( !($result = $db->sql_query($sql)) )

                {

                        message_die(GENERAL_ERROR, 'Could not update topics table', '', __LINE__, __FILE__, $sql);

                }

                if ( !empty($topic_id) )

                {

                        $redirect_page = append_sid("viewtopic.$phpEx?" . POST_TOPIC_URL . "=$topic_id");

                        $message = sprintf($lang['Click_return_topic'], '<a href="' . $redirect_page . '">', '</a>');

                }

                else

                {

                        $redirect_page = append_sid("modcp.$phpEx?" . POST_FORUM_URL . "=$forum_id");

                        $message = sprintf($lang['Click_return_modcp'], '<a href="' . $redirect_page . '">', '</a>');

                }

                $message = $message . '<br \><br \>' . sprintf($lang['Click_return_forum'], '<a href="' . append_sid("viewforum.$phpEx?" . POST_FORUM_URL . "=$forum_id") . '">', '</a>');

                $template->assign_vars(array(

                        'META' => '<meta http-equiv="refresh" content="3;url=' . $redirect_page . '">')

                );

                message_die(GENERAL_MESSAGE, $lang['Topics_Locked'] . '<br /><br />' . $message);

                break;

        case 'unlock':

                if ( empty($HTTP_POST_VARS['topic_id_list']) && empty($topic_id) )

                {

                        message_die(GENERAL_MESSAGE, $lang['None_selected']);

                }

                $topics = ( isset($HTTP_POST_VARS['topic_id_list']) ) ?  $HTTP_POST_VARS['topic_id_list'] : array($topic_id);

                $topic_id_sql = '';

                for($i = 0; $i < count($topics); $i++)

                {

                        $topic_id_sql .= ( ( $topic_id_sql != "") ? ', ' : '' ) . $topics[$i];

                }

                $sql = "UPDATE " . TOPICS_TABLE . "

                        SET topic_status = " . TOPIC_UNLOCKED . "

                        WHERE topic_id IN ($topic_id_sql)

                                AND topic_moved_id = 0";

                if ( !($result = $db->sql_query($sql)) )

                {

                        message_die(GENERAL_ERROR, 'Could not update topics table', '', __LINE__, __FILE__, $sql);

                }

                if ( !empty($topic_id) )

                {

                        $redirect_page = append_sid("viewtopic.$phpEx?" . POST_TOPIC_URL . "=$topic_id");

                        $message = sprintf($lang['Click_return_topic'], '<a href="' . $redirect_page . '">', '</a>');

                }

                else

                {

                        $redirect_page = append_sid("modcp.$phpEx?" . POST_FORUM_URL . "=$forum_id");

                        $message = sprintf($lang['Click_return_modcp'], '<a href="' . $redirect_page . '">', '</a>');

                }

                $message = $message . '<br \><br \>' . sprintf($lang['Click_return_forum'], '<a href="' . append_sid("viewforum.$phpEx?" . POST_FORUM_URL . "=$forum_id") . '">', '</a>');

                $template->assign_vars(array(

                        'META' => '<meta http-equiv="refresh" content="3;url=' . $redirect_page . '">')

                );

                message_die(GENERAL_MESSAGE, $lang['Topics_Unlocked'] . '<br /><br />' . $message);

                break;

        case 'split':

                $page_title = $lang['Mod_CP'];

                include($phpbb_root_path . 'includes/page_header.'.$phpEx);

                if ( isset($HTTP_POST_VARS['split_type_all']) || isset($HTTP_POST_VARS['split_type_beyond']) )

                {

                        $posts = $HTTP_POST_VARS['post_id_list'];

                        $sql = "SELECT poster_id, topic_id, post_time

                                FROM " . POSTS_TABLE . "

                                WHERE post_id = " . $posts[0];

                        if ( !($result = $db->sql_query($sql)) )

                        {

                                message_die(GENERAL_ERROR, 'Could not get post information', '', __LINE__, __FILE__, $sql);

                        }

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

                        $first_poster = str_replace("\'", "''", $post_rowset['poster_id']);

                        $topic_id = $post_rowset['topic_id'];

                        $post_time = $post_rowset['post_time'];

                        $post_subject = trim(htmlspecialchars($HTTP_POST_VARS['subject']));

                        if ( empty($post_subject) )

                        {

                                message_die(GENERAL_MESSAGE, $lang['Empty_subject']);

                        }

                        $new_forum_id = intval($HTTP_POST_VARS['new_forum_id']);

                        $topic_time = time();

                        $sql  = "INSERT INTO " . TOPICS_TABLE . " (topic_title, topic_poster, topic_time, forum_id, topic_status, topic_type)

                                VALUES ('" . str_replace("\'", "''", $post_subject) . "', $first_poster, " . $topic_time . ", $new_forum_id, " . TOPIC_UNLOCKED . ", " . POST_NORMAL . ")";

                        if ( !($result = $db->sql_query($sql, BEGIN_TRANSACTION)) )

                        {

                                message_die(GENERAL_ERROR, 'Could not insert new topic', '', __LINE__, __FILE__, $sql);

                        }

                        $new_topic_id = $db->sql_nextid();

                        if( !empty($HTTP_POST_VARS['split_type_all']) )

                        {

                                $post_id_sql = '';

                                for($i = 0; $i < count($posts); $i++)

                                {

                                        $post_id_sql .= ( ( $post_id_sql != '' ) ? ', ' : '' ) . $posts[$i];

                                }

                                $sql = "UPDATE " . POSTS_TABLE . "

                                        SET topic_id = $new_topic_id, forum_id = $new_forum_id

                                        WHERE post_id IN ($post_id_sql)";

                        }

                        else if( !empty($HTTP_POST_VARS['split_type_beyond']) )

                        {

                                $sql = "UPDATE " . POSTS_TABLE . "

                                        SET topic_id = $new_topic_id, forum_id = $new_forum_id

                                        WHERE post_time >= $post_time

                                                AND topic_id = $topic_id";

                        }

                        if( !$db->sql_query($sql, END_TRANSACTION) )

                        {

                                message_die(GENERAL_ERROR, 'Could not update posts table', '', __LINE__, __FILE__, $sql);