1:   2:   3:   4:   5:   6:   7:   8:   9:  10:  11:  12:  13:  14:  15:  16:  17:  18:  19:  20:  21:  22:  23:  24:  25:  26:  27:  28:  29:  30:  31:  32:  33:  34:  35:  36:  37:  38:  39:  40:  41:  42:  43:  44:  45:  46:  47:  48:  49:  50:  51:  52:  53:  54:  55:  56:  57:  58:  59:  60:  61:  62:  63:  64:  65:  66:  67:  68:  69:  70:  71:  72:  73:  74:  75:  76:  77:  78:  79:  80:  81:  82:  83:  84:  85:  86:  87:  88:  89:  90:  91:  92:  93:  94:  95:  96:  97:  98:  99: 100: 101: 102: 103: 104: 105: 106: 107: 108: 109: 110: 111: 112: 113: 114: 115: 116: 117: 118: 119: 120: 121: 122: 123: 124: 125: 126: 127: 128: 129: 130: 131: 132: 133: 134: 135: 136: 137: 138: 139: 140: 141: 142: 143: 144: 145: 146: 147: 148: 149: 150: 151: 152: 153: 154: 155: 156: 157: 158: 159: 160: 161: 162: 163: 164: 165: 166: 167: 168: 169: 170: 171: 172: 173: 174: 175: 176: 177: 178: 179: 180: 181: 182: 183: 184: 185: 186: 187: 188: 189: 190: 191: 192: 193: 194: 195: 196: 197: 198: 199: 200: 201: 202: 203: 204: 205: 206: 207: 208: 209: 210: 211: 212: 213: 214: 215: 216: 217: 218: 219: 220: 221: 222: 223: 224: 225: 226: 227: 228: 229: 230: 231: 232: 233: 234: 235: 236: 237: 238: 239: 240: 241: 242: 243: 244: 245: 246: 247: 248: 249: 250: 251: 252: 253: 254: 255: 256: 257: 258: 259: 260: 261: 262: 263: 264: 265: 266: 267: 268: 269: 270: 271: 272: 273: 274: 275: 276: 277: 278: 279: 280: 281: 282: 283: 284: 285: 286: 287: 288: 289: 290: 291: 292: 293: 294: 295: 296: 297: 298: 299: 300: 301: 302: 303: 304: 305: 306: 307: 308: 309: 310: 311: 312: 313: 314: 315: 316: 317: 318: 319: 320: 321: 322: 323: 324: 325: 326: 327: 328: 329: 330: 331: 332: 333: 334: 335: 336: 337: 338: 339: 340: 341: 342: 343: 344: 345: 346: 347: 348: 349: 350: 351: 352: 353: 354: 355: 356: 357: 358: 359: 360: 361: 362: 363: 364: 365: 366: 367: 368: 369: 370: 371: 372: 373: 374: 375: 376: 377: 378: 379: 380: 381: 382: 383: 384: 385: 386: 387: 388: 389: 390: 391: 392: 393: 394: 395: 396: 397: 398: 399: 400: 401: 402: 403: 404: 405: 406: 407: 408: 409: 410: 411: 412: 413: 414: 415: 416: 417: 418: 419: 420: 421: 422: 423: 424: 425: 426: 427: 428: 429: 430: 431: 432: 433: 434: 435: 436: 437: 438: 439: 440: 441: 442: 443: 444: 445: 446: 447: 448: 449: 450: 451: 452: 453: 454: 455: 456: 457: 458: 459: 460: 461: 462: 463: 464: 465: 466: 467: 468: 469: 470: 471: 472: 473: 474: 475: 476: 477: 478: 479: 480: 481: 482: 483: 484: 485: 486: 487: 488: 489: 490: 491: 492: 493: 494: 495: 496: 497: 498: 499: 500: 501: 502: 503: 504: 505: 506: 507: 508: 509: 510: 511: 512: 513: 514: 515: 516: 517: 518: 519: 520: 521: 522: 523: 524: 525: 526: 527: 528: 529: 530: 531: 532: 533: 534: 535: 536: 537: 538: 539: 540: 541: 542: 543: 544: 545: 546: 547: 548: 549: 550: 551: 552: 553: 554: 555: 556: 557: 558: 559: 560: 561: 562: 563: 564: 565: 566: 567: 568: 569: 570: 571: 572: 573: 574: 575: 576: 577: 578: 579: 580: 581: 582: 583: 584: 585: 586: 587: 588: 589: 590: 591: 592: 593: 594: 595: 596: 597: 598: 599: 600: 601: 602: 603: 604: 605: 606: 607: 608: 609: 610: 611: 612: 613: 614: 615: 616: 617: 618: 619: 620: 621: 622: 623: 624: 625: 626: 627: 628: 629: 630: 631: 632: 633: 634: 635: 636: 637: 638: 639: 640: 641: 642: 643: 644: 645: 646: 647: 648: 649: 650: 651: 652: 653: 654: 655: 656: 657: 658: 659: 660: 661: 662: 663: 664: 665: 666: 667: 668: 669: 670: 671: 672: 673: 674: 675: 676: 677: 678: 679: 680: 681: 682: 683: 684: 685: 686: 687: 688: 689: 690: 691: 692: 693: 694: 695: 696: 697: 698: 699: 700: 701: 702: 703: 704: 705: 706: 707: 708: 709: 710: 711: 712: 713: 714: 715: 716: 717: 718: 719: 720: 721: 722: 723: 724: 725: 726: 727: 728: 729: 730: 731: 732: 733: 734: 735: 736: 737: 

<?php

/**
 * This file contains the functions required to move topics from one board to
 * another board.
 *
 * Simple Machines Forum (SMF)
 *
 * @package SMF
 * @author Simple Machines https://www.simplemachines.org
 * @copyright 2020 Simple Machines and individual contributors
 * @license https://www.simplemachines.org/about/smf/license.php BSD
 *
 * @version 2.1 RC2
 */

if (!defined('SMF'))
    die('No direct access...');

/**
 * This function allows to move a topic, making sure to ask the moderator
 * to give reason for topic move.
 * It must be called with a topic specified. (that is, global $topic must
 * be set... @todo fix this thing.)
 * If the member is the topic starter requires the move_own permission,
 * otherwise the move_any permission.
 * Accessed via ?action=movetopic.
 *
 * @uses the MoveTopic template, main sub-template.
 */
function MoveTopic()
{
    global $txt, $board, $topic, $user_info, $context, $language, $scripturl, $smcFunc, $modSettings, $sourcedir;

    if (empty($topic))
        fatal_lang_error('no_access', false);

    $request = $smcFunc['db_query']('', '
        SELECT t.id_member_started, ms.subject, t.approved
        FROM {db_prefix}topics AS t
            INNER JOIN {db_prefix}messages AS ms ON (ms.id_msg = t.id_first_msg)
        WHERE t.id_topic = {int:current_topic}
        LIMIT 1',
        array(
            'current_topic' => $topic,
        )
    );
    list ($id_member_started, $context['subject'], $context['is_approved']) = $smcFunc['db_fetch_row']($request);
    $smcFunc['db_free_result']($request);

    // Can they see it - if not approved?
    if ($modSettings['postmod_active'] && !$context['is_approved'])
        isAllowedTo('approve_posts');

    // Permission check!
    // @todo
    if (!allowedTo('move_any'))
    {
        if ($id_member_started == $user_info['id'])
        {
            isAllowedTo('move_own');
        }
        else
            isAllowedTo('move_any');
    }

    $context['move_any'] = $user_info['is_admin'] || $modSettings['topic_move_any'];
    $boards = array();

    if (!$context['move_any'])
    {
        $boards = array_diff(boardsAllowedTo('post_new'), array($board));
        if (empty($boards))
        {
            // No boards? Too bad...
            fatal_lang_error('moveto_no_boards');
        }
    }

    loadTemplate('MoveTopic');

    $options = array(
        'not_redirection' => true,
    );

    if (!empty($_SESSION['move_to_topic']) && $_SESSION['move_to_topic'] != $board)
        $options['selected_board'] = $_SESSION['move_to_topic'];

    if (!$context['move_any'])
        $options['included_boards'] = $boards;

    require_once($sourcedir . '/Subs-MessageIndex.php');
    $context['categories'] = getBoardList($options);

    $context['page_title'] = $txt['move_topic'];

    $context['linktree'][] = array(
        'url' => $scripturl . '?topic=' . $topic . '.0',
        'name' => $context['subject'],
    );

    $context['linktree'][] = array(
        'name' => $txt['move_topic'],
    );

    $context['back_to_topic'] = isset($_REQUEST['goback']);

    if ($user_info['language'] != $language)
    {
        loadLanguage('index', $language);
        $temp = $txt['movetopic_default'];
        loadLanguage('index');

        $txt['movetopic_default'] = $temp;
    }

    $context['sub_template'] = 'move';

    moveTopicConcurrence();

    // Register this form and get a sequence number in $context.
    checkSubmitOnce('register');
}

/**
 * Execute the move of a topic.
 * It is called on the submit of MoveTopic.
 * This function logs that topics have been moved in the moderation log.
 * If the member is the topic starter requires the move_own permission,
 * otherwise requires the move_any permission.
 * Upon successful completion redirects to message index.
 * Accessed via ?action=movetopic2.
 *
 * @uses Subs-Post.php.
 */
function MoveTopic2()
{
    global $txt, $topic, $scripturl, $sourcedir, $context;
    global $board, $language, $user_info, $smcFunc;

    if (empty($topic))
        fatal_lang_error('no_access', false);

    // You can't choose to have a redirection topic and use an empty reason.
    if (isset($_POST['postRedirect']) && (!isset($_POST['reason']) || trim($_POST['reason']) == ''))
        fatal_lang_error('movetopic_no_reason', false);

    moveTopicConcurrence();

    // Make sure this form hasn't been submitted before.
    checkSubmitOnce('check');

    $request = $smcFunc['db_query']('', '
        SELECT id_member_started, id_first_msg, approved
        FROM {db_prefix}topics
        WHERE id_topic = {int:current_topic}
        LIMIT 1',
        array(
            'current_topic' => $topic,
        )
    );
    list ($id_member_started, $id_first_msg, $context['is_approved']) = $smcFunc['db_fetch_row']($request);
    $smcFunc['db_free_result']($request);

    // Can they see it?
    if (!$context['is_approved'])
        isAllowedTo('approve_posts');

    // Can they move topics on this board?
    if (!allowedTo('move_any'))
    {
        if ($id_member_started == $user_info['id'])
            isAllowedTo('move_own');
        else
            isAllowedTo('move_any');
    }

    checkSession();
    require_once($sourcedir . '/Subs-Post.php');

    // The destination board must be numeric.
    $_POST['toboard'] = (int) $_POST['toboard'];

    // Make sure they can see the board they are trying to move to (and get whether posts count in the target board).
    $request = $smcFunc['db_query']('', '
        SELECT b.count_posts, b.name, m.subject
        FROM {db_prefix}boards AS b
            INNER JOIN {db_prefix}topics AS t ON (t.id_topic = {int:current_topic})
            INNER JOIN {db_prefix}messages AS m ON (m.id_msg = t.id_first_msg)
        WHERE {query_see_board}
            AND b.id_board = {int:to_board}
            AND b.redirect = {string:blank_redirect}
        LIMIT 1',
        array(
            'current_topic' => $topic,
            'to_board' => $_POST['toboard'],
            'blank_redirect' => '',
        )
    );
    if ($smcFunc['db_num_rows']($request) == 0)
        fatal_lang_error('no_board');

    list ($pcounter, $board_name, $subject) = $smcFunc['db_fetch_row']($request);
    $smcFunc['db_free_result']($request);

    // Remember this for later.
    $_SESSION['move_to_topic'] = $_POST['toboard'];

    // Rename the topic...
    if (isset($_POST['reset_subject'], $_POST['custom_subject']) && $_POST['custom_subject'] != '')
    {
        $_POST['custom_subject'] = strtr($smcFunc['htmltrim']($smcFunc['htmlspecialchars']($_POST['custom_subject'])), array("\r" => '', "\n" => '', "\t" => ''));
        // Keep checking the length.
        if ($smcFunc['strlen']($_POST['custom_subject']) > 100)
            $_POST['custom_subject'] = $smcFunc['substr']($_POST['custom_subject'], 0, 100);

        // If it's still valid move onwards and upwards.
        if ($_POST['custom_subject'] != '')
        {
            if (isset($_POST['enforce_subject']))
            {
                // Get a response prefix, but in the forum's default language.
                if (!isset($context['response_prefix']) && !($context['response_prefix'] = cache_get_data('response_prefix')))
                {
                    if ($language === $user_info['language'])
                        $context['response_prefix'] = $txt['response_prefix'];
                    else
                    {
                        loadLanguage('index', $language, false);
                        $context['response_prefix'] = $txt['response_prefix'];
                        loadLanguage('index');
                    }
                    cache_put_data('response_prefix', $context['response_prefix'], 600);
                }

                $smcFunc['db_query']('', '
                    UPDATE {db_prefix}messages
                    SET subject = {string:subject}
                    WHERE id_topic = {int:current_topic}',
                    array(
                        'current_topic' => $topic,
                        'subject' => $context['response_prefix'] . $_POST['custom_subject'],
                    )
                );
            }

            $smcFunc['db_query']('', '
                UPDATE {db_prefix}messages
                SET subject = {string:custom_subject}
                WHERE id_msg = {int:id_first_msg}',
                array(
                    'id_first_msg' => $id_first_msg,
                    'custom_subject' => $_POST['custom_subject'],
                )
            );

            // Fix the subject cache.
            updateStats('subject', $topic, $_POST['custom_subject']);
        }
    }

    // Create a link to this in the old board.
    // @todo Does this make sense if the topic was unapproved before? I'd just about say so.
    if (isset($_POST['postRedirect']))
    {
        // Should be in the boardwide language.
        if ($user_info['language'] != $language)
            loadLanguage('index', $language);

        $_POST['reason'] = $smcFunc['htmlspecialchars']($_POST['reason'], ENT_QUOTES);
        preparsecode($_POST['reason']);

        // Add a URL onto the message.
        $_POST['reason'] = strtr($_POST['reason'], array(
            $txt['movetopic_auto_board'] => '[url=' . $scripturl . '?board=' . $_POST['toboard'] . '.0]' . $board_name . '[/url]',
            $txt['movetopic_auto_topic'] => '[iurl]' . $scripturl . '?topic=' . $topic . '.0[/iurl]'
        ));

        // auto remove this MOVED redirection topic in the future?
        $redirect_expires = !empty($_POST['redirect_expires']) ? ((int) ($_POST['redirect_expires'] * 60) + time()) : 0;

        // redirect to the MOVED topic from topic list?
        $redirect_topic = isset($_POST['redirect_topic']) ? $topic : 0;

        $msgOptions = array(
            'subject' => $txt['moved'] . ': ' . $subject,
            'body' => $_POST['reason'],
            'icon' => 'moved',
            'smileys_enabled' => 1,
        );
        $topicOptions = array(
            'board' => $board,
            'lock_mode' => 1,
            'mark_as_read' => true,
            'redirect_expires' => $redirect_expires,
            'redirect_topic' => $redirect_topic,
        );
        $posterOptions = array(
            'id' => $user_info['id'],
            'update_post_count' => empty($pcounter),
        );
        createPost($msgOptions, $topicOptions, $posterOptions);
    }

    $request = $smcFunc['db_query']('', '
        SELECT count_posts
        FROM {db_prefix}boards
        WHERE id_board = {int:current_board}
        LIMIT 1',
        array(
            'current_board' => $board,
        )
    );
    list ($pcounter_from) = $smcFunc['db_fetch_row']($request);
    $smcFunc['db_free_result']($request);

    if ($pcounter_from != $pcounter)
    {
        $request = $smcFunc['db_query']('', '
            SELECT id_member
            FROM {db_prefix}messages
            WHERE id_topic = {int:current_topic}
                AND approved = {int:is_approved}',
            array(
                'current_topic' => $topic,
                'is_approved' => 1,
            )
        );
        $posters = array();
        while ($row = $smcFunc['db_fetch_assoc']($request))
        {
            if (!isset($posters[$row['id_member']]))
                $posters[$row['id_member']] = 0;

            $posters[$row['id_member']]++;
        }
        $smcFunc['db_free_result']($request);

        foreach ($posters as $id_member => $posts)
        {
            // The board we're moving from counted posts, but not to.
            if (empty($pcounter_from))
                updateMemberData($id_member, array('posts' => 'posts - ' . $posts));
            // The reverse: from didn't, to did.
            else
                updateMemberData($id_member, array('posts' => 'posts + ' . $posts));
        }
    }

    // Do the move (includes statistics update needed for the redirect topic).
    moveTopics($topic, $_POST['toboard']);

    // Log that they moved this topic.
    if (!allowedTo('move_own') || $id_member_started != $user_info['id'])
        logAction('move', array('topic' => $topic, 'board_from' => $board, 'board_to' => $_POST['toboard']));
    // Notify people that this topic has been moved?
    sendNotifications($topic, 'move');

    call_integration_hook('integrate_movetopic2_end');

    // Why not go back to the original board in case they want to keep moving?
    if (!isset($_REQUEST['goback']))
        redirectexit('board=' . $board . '.0');
    else
        redirectexit('topic=' . $topic . '.0');
}

/**
 * Moves one or more topics to a specific board. (doesn't check permissions.)
 * Determines the source boards for the supplied topics
 * Handles the moving of mark_read data
 * Updates the posts count of the affected boards
 *
 * @param int|int[] $topics The ID of a single topic to move or an array containing the IDs of multiple topics to move
 * @param int $toBoard The ID of the board to move the topics to
 */
function moveTopics($topics, $toBoard)
{
    global $sourcedir, $user_info, $modSettings, $smcFunc, $cache_enable;

    // Empty array?
    if (empty($topics))
        return;

    // Only a single topic.
    if (is_numeric($topics))
        $topics = array($topics);

    $fromBoards = array();

    // Destination board empty or equal to 0?
    if (empty($toBoard))
        return;

    // Are we moving to the recycle board?
    $isRecycleDest = !empty($modSettings['recycle_enable']) && $modSettings['recycle_board'] == $toBoard;

    // Callback for search APIs to do their thing
    require_once($sourcedir . '/Search.php');
    $searchAPI = findSearchAPI();
    if ($searchAPI->supportsMethod('topicsMoved'))
        $searchAPI->topicsMoved($topics, $toBoard);

    // Determine the source boards...
    $request = $smcFunc['db_query']('', '
        SELECT id_board, approved, COUNT(*) AS num_topics, SUM(unapproved_posts) AS unapproved_posts,
            SUM(num_replies) AS num_replies
        FROM {db_prefix}topics
        WHERE id_topic IN ({array_int:topics})
        GROUP BY id_board, approved',
        array(
            'topics' => $topics,
        )
    );
    // Num of rows = 0 -> no topics found. Num of rows > 1 -> topics are on multiple boards.
    if ($smcFunc['db_num_rows']($request) == 0)
        return;
    while ($row = $smcFunc['db_fetch_assoc']($request))
    {
        if (!isset($fromBoards[$row['id_board']]['num_posts']))
        {
            $fromBoards[$row['id_board']] = array(
                'num_posts' => 0,
                'num_topics' => 0,
                'unapproved_posts' => 0,
                'unapproved_topics' => 0,
                'id_board' => $row['id_board']
            );
        }
        // Posts = (num_replies + 1) for each approved topic.
        $fromBoards[$row['id_board']]['num_posts'] += $row['num_replies'] + ($row['approved'] ? $row['num_topics'] : 0);
        $fromBoards[$row['id_board']]['unapproved_posts'] += $row['unapproved_posts'];

        // Add the topics to the right type.
        if ($row['approved'])
            $fromBoards[$row['id_board']]['num_topics'] += $row['num_topics'];
        else
            $fromBoards[$row['id_board']]['unapproved_topics'] += $row['num_topics'];
    }
    $smcFunc['db_free_result']($request);

    // Move over the mark_read data. (because it may be read and now not by some!)
    $SaveAServer = max(0, $modSettings['maxMsgID'] - 50000);
    $request = $smcFunc['db_query']('', '
        SELECT lmr.id_member, lmr.id_msg, t.id_topic, COALESCE(lt.unwatched, 0) AS unwatched
        FROM {db_prefix}topics AS t
            INNER JOIN {db_prefix}log_mark_read AS lmr ON (lmr.id_board = t.id_board
                AND lmr.id_msg > t.id_first_msg AND lmr.id_msg > {int:protect_lmr_msg})
            LEFT JOIN {db_prefix}log_topics AS lt ON (lt.id_topic = t.id_topic AND lt.id_member = lmr.id_member)
        WHERE t.id_topic IN ({array_int:topics})
            AND lmr.id_msg > COALESCE(lt.id_msg, 0)',
        array(
            'protect_lmr_msg' => $SaveAServer,
            'topics' => $topics,
        )
    );
    $log_topics = array();
    while ($row = $smcFunc['db_fetch_assoc']($request))
    {
        $log_topics[] = array($row['id_topic'], $row['id_member'], $row['id_msg'], (is_null($row['unwatched']) ? 0 : $row['unwatched']));

        // Prevent queries from getting too big. Taking some steam off.
        if (count($log_topics) > 500)
        {
            $smcFunc['db_insert']('replace',
                '{db_prefix}log_topics',
                array('id_topic' => 'int', 'id_member' => 'int', 'id_msg' => 'int', 'unwatched' => 'int'),
                $log_topics,
                array('id_topic', 'id_member')
            );

            $log_topics = array();
        }
    }
    $smcFunc['db_free_result']($request);

    // Now that we have all the topics that *should* be marked read, and by which members...
    if (!empty($log_topics))
    {
        // Insert that information into the database!
        $smcFunc['db_insert']('replace',
            '{db_prefix}log_topics',
            array('id_topic' => 'int', 'id_member' => 'int', 'id_msg' => 'int', 'unwatched' => 'int'),
            $log_topics,
            array('id_topic', 'id_member')
        );
    }

    // Update the number of posts on each board.
    $totalTopics = 0;
    $totalPosts = 0;
    $totalUnapprovedTopics = 0;
    $totalUnapprovedPosts = 0;
    foreach ($fromBoards as $stats)
    {
        $smcFunc['db_query']('', '
            UPDATE {db_prefix}boards
            SET
                num_posts = CASE WHEN {int:num_posts} > num_posts THEN 0 ELSE num_posts - {int:num_posts} END,
                num_topics = CASE WHEN {int:num_topics} > num_topics THEN 0 ELSE num_topics - {int:num_topics} END,
                unapproved_posts = CASE WHEN {int:unapproved_posts} > unapproved_posts THEN 0 ELSE unapproved_posts - {int:unapproved_posts} END,
                unapproved_topics = CASE WHEN {int:unapproved_topics} > unapproved_topics THEN 0 ELSE unapproved_topics - {int:unapproved_topics} END
            WHERE id_board = {int:id_board}',
            array(
                'id_board' => $stats['id_board'],
                'num_posts' => $stats['num_posts'],
                'num_topics' => $stats['num_topics'],
                'unapproved_posts' => $stats['unapproved_posts'],
                'unapproved_topics' => $stats['unapproved_topics'],
            )
        );
        $totalTopics += $stats['num_topics'];
        $totalPosts += $stats['num_posts'];
        $totalUnapprovedTopics += $stats['unapproved_topics'];
        $totalUnapprovedPosts += $stats['unapproved_posts'];
    }
    $smcFunc['db_query']('', '
        UPDATE {db_prefix}boards
        SET
            num_topics = num_topics + {int:total_topics},
            num_posts = num_posts + {int:total_posts},' . ($isRecycleDest ? '
            unapproved_posts = {int:no_unapproved}, unapproved_topics = {int:no_unapproved}' : '
            unapproved_posts = unapproved_posts + {int:total_unapproved_posts},
            unapproved_topics = unapproved_topics + {int:total_unapproved_topics}') . '
        WHERE id_board = {int:id_board}',
        array(
            'id_board' => $toBoard,
            'total_topics' => $totalTopics,
            'total_posts' => $totalPosts,
            'total_unapproved_topics' => $totalUnapprovedTopics,
            'total_unapproved_posts' => $totalUnapprovedPosts,
            'no_unapproved' => 0,
        )
    );

    // Move the topic.  Done.  :P
    $smcFunc['db_query']('', '
        UPDATE {db_prefix}topics
        SET id_board = {int:id_board}' . ($isRecycleDest ? ',
            unapproved_posts = {int:no_unapproved}, approved = {int:is_approved}' : '') . '
        WHERE id_topic IN ({array_int:topics})',
        array(
            'id_board' => $toBoard,
            'topics' => $topics,
            'is_approved' => 1,
            'no_unapproved' => 0,
        )
    );

    // If this was going to the recycle bin, check what messages are being recycled, and remove them from the queue.
    if ($isRecycleDest && ($totalUnapprovedTopics || $totalUnapprovedPosts))
    {
        $request = $smcFunc['db_query']('', '
            SELECT id_msg
            FROM {db_prefix}messages
            WHERE id_topic IN ({array_int:topics})
                AND approved = {int:not_approved}',
            array(
                'topics' => $topics,
                'not_approved' => 0,
            )
        );
        $approval_msgs = array();
        while ($row = $smcFunc['db_fetch_assoc']($request))
            $approval_msgs[] = $row['id_msg'];

        $smcFunc['db_free_result']($request);

        // Empty the approval queue for these, as we're going to approve them next.
        if (!empty($approval_msgs))
            $smcFunc['db_query']('', '
                DELETE FROM {db_prefix}approval_queue
                WHERE id_msg IN ({array_int:message_list})
                    AND id_attach = {int:id_attach}',
                array(
                    'message_list' => $approval_msgs,
                    'id_attach' => 0,
                )
            );

        // Get all the current max and mins.
        $request = $smcFunc['db_query']('', '
            SELECT id_topic, id_first_msg, id_last_msg
            FROM {db_prefix}topics
            WHERE id_topic IN ({array_int:topics})',
            array(
                'topics' => $topics,
            )
        );
        $topicMaxMin = array();
        while ($row = $smcFunc['db_fetch_assoc']($request))
        {
            $topicMaxMin[$row['id_topic']] = array(
                'min' => $row['id_first_msg'],
                'max' => $row['id_last_msg'],
            );
        }
        $smcFunc['db_free_result']($request);

        // Check the MAX and MIN are correct.
        $request = $smcFunc['db_query']('', '
            SELECT id_topic, MIN(id_msg) AS first_msg, MAX(id_msg) AS last_msg
            FROM {db_prefix}messages
            WHERE id_topic IN ({array_int:topics})
            GROUP BY id_topic',
            array(
                'topics' => $topics,
            )
        );
        while ($row = $smcFunc['db_fetch_assoc']($request))
        {
            // If not, update.
            if ($row['first_msg'] != $topicMaxMin[$row['id_topic']]['min'] || $row['last_msg'] != $topicMaxMin[$row['id_topic']]['max'])
                $smcFunc['db_query']('', '
                    UPDATE {db_prefix}topics
                    SET id_first_msg = {int:first_msg}, id_last_msg = {int:last_msg}
                    WHERE id_topic = {int:selected_topic}',
                    array(
                        'first_msg' => $row['first_msg'],
                        'last_msg' => $row['last_msg'],
                        'selected_topic' => $row['id_topic'],
                    )
                );
        }
        $smcFunc['db_free_result']($request);
    }

    $smcFunc['db_query']('', '
        UPDATE {db_prefix}messages
        SET id_board = {int:id_board}' . ($isRecycleDest ? ',approved = {int:is_approved}' : '') . '
        WHERE id_topic IN ({array_int:topics})',
        array(
            'id_board' => $toBoard,
            'topics' => $topics,
            'is_approved' => 1,
        )
    );
    $smcFunc['db_query']('', '
        UPDATE {db_prefix}log_reported
        SET id_board = {int:id_board}
        WHERE id_topic IN ({array_int:topics})',
        array(
            'id_board' => $toBoard,
            'topics' => $topics,
        )
    );
    $smcFunc['db_query']('', '
        UPDATE {db_prefix}calendar
        SET id_board = {int:id_board}
        WHERE id_topic IN ({array_int:topics})',
        array(
            'id_board' => $toBoard,
            'topics' => $topics,
        )
    );

    // Mark target board as seen, if it was already marked as seen before.
    $request = $smcFunc['db_query']('', '
        SELECT (COALESCE(lb.id_msg, 0) >= b.id_msg_updated) AS isSeen
        FROM {db_prefix}boards AS b
            LEFT JOIN {db_prefix}log_boards AS lb ON (lb.id_board = b.id_board AND lb.id_member = {int:current_member})
        WHERE b.id_board = {int:id_board}',
        array(
            'current_member' => $user_info['id'],
            'id_board' => $toBoard,
        )
    );
    list ($isSeen) = $smcFunc['db_fetch_row']($request);
    $smcFunc['db_free_result']($request);

    if (!empty($isSeen) && !$user_info['is_guest'])
    {
        $smcFunc['db_insert']('replace',
            '{db_prefix}log_boards',
            array('id_board' => 'int', 'id_member' => 'int', 'id_msg' => 'int'),
            array($toBoard, $user_info['id'], $modSettings['maxMsgID']),
            array('id_board', 'id_member')
        );
    }

    // Update the cache?
    if (!empty($cache_enable) && $cache_enable >= 3)
        foreach ($topics as $topic_id)
            cache_put_data('topic_board-' . $topic_id, null, 120);

    require_once($sourcedir . '/Subs-Post.php');

    $updates = array_keys($fromBoards);
    $updates[] = $toBoard;

    updateLastMessages(array_unique($updates));

    // Update 'em pesky stats.
    updateStats('topic');
    updateStats('message');
    updateSettings(array(
        'calendar_updated' => time(),
    ));
}

/**
 * Called after a topic is moved to update $board_link and $topic_link to point to new location
 */
function moveTopicConcurrence()
{
    global $board, $topic, $smcFunc, $scripturl;

    if (isset($_GET['current_board']))
        $move_from = (int) $_GET['current_board'];

    if (empty($move_from) || empty($board) || empty($topic))
        return true;

    if ($move_from == $board)
        return true;
    else
    {
        $request = $smcFunc['db_query']('', '
            SELECT m.subject, b.name
            FROM {db_prefix}topics as t
                LEFT JOIN {db_prefix}boards AS b ON (t.id_board = b.id_board)
                LEFT JOIN {db_prefix}messages AS m ON (t.id_first_msg = m.id_msg)
            WHERE t.id_topic = {int:topic_id}
            LIMIT 1',
            array(
                'topic_id' => $topic,
            )
        );
        list($topic_subject, $board_name) = $smcFunc['db_fetch_row']($request);
        $smcFunc['db_free_result']($request);
        $board_link = '<a href="' . $scripturl . '?board=' . $board . '.0">' . $board_name . '</a>';
        $topic_link = '<a href="' . $scripturl . '?topic=' . $topic . '.0">' . $topic_subject . '</a>';
        fatal_lang_error('topic_already_moved', false, array($topic_link, $board_link));
    }
}

?>