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:  738:  739:  740:  741:  742:  743:  744:  745:  746:  747:  748:  749:  750:  751:  752:  753:  754:  755:  756:  757:  758:  759:  760:  761:  762:  763:  764:  765:  766:  767:  768:  769:  770:  771:  772:  773:  774:  775:  776:  777:  778:  779:  780:  781:  782:  783:  784:  785:  786:  787:  788:  789:  790:  791:  792:  793:  794:  795:  796:  797:  798:  799:  800:  801:  802:  803:  804:  805:  806:  807:  808:  809:  810:  811:  812:  813:  814:  815:  816:  817:  818:  819:  820:  821:  822:  823:  824:  825:  826:  827:  828:  829:  830:  831:  832:  833:  834:  835:  836:  837:  838:  839:  840:  841:  842:  843:  844:  845:  846:  847:  848:  849:  850:  851:  852:  853:  854:  855:  856:  857:  858:  859:  860:  861:  862:  863:  864:  865:  866:  867:  868:  869:  870:  871:  872:  873:  874:  875:  876:  877:  878:  879:  880:  881:  882:  883:  884:  885:  886:  887:  888:  889:  890:  891:  892:  893:  894:  895:  896:  897:  898:  899:  900:  901:  902:  903:  904:  905:  906:  907:  908:  909:  910:  911:  912:  913:  914:  915:  916:  917:  918:  919:  920:  921:  922:  923:  924:  925:  926:  927:  928:  929:  930:  931:  932:  933:  934:  935:  936:  937:  938:  939:  940:  941:  942:  943:  944:  945:  946:  947:  948:  949:  950:  951:  952:  953:  954:  955:  956:  957:  958:  959:  960:  961:  962:  963:  964:  965:  966:  967:  968:  969:  970:  971:  972:  973:  974:  975:  976:  977:  978:  979:  980:  981:  982:  983:  984:  985:  986:  987:  988:  989:  990:  991:  992:  993:  994:  995:  996:  997:  998:  999: 1000: 1001: 1002: 1003: 1004: 1005: 1006: 1007: 1008: 1009: 1010: 1011: 1012: 1013: 1014: 1015: 1016: 1017: 1018: 1019: 1020: 1021: 1022: 1023: 1024: 1025: 1026: 1027: 1028: 1029: 1030: 1031: 1032: 1033: 1034: 1035: 1036: 1037: 1038: 1039: 1040: 1041: 1042: 1043: 1044: 1045: 1046: 1047: 1048: 1049: 1050: 1051: 1052: 1053: 1054: 1055: 1056: 1057: 1058: 1059: 1060: 1061: 1062: 1063: 1064: 1065: 1066: 1067: 1068: 1069: 1070: 1071: 1072: 1073: 1074: 1075: 1076: 1077: 1078: 1079: 1080: 1081: 1082: 1083: 1084: 1085: 1086: 1087: 1088: 1089: 1090: 1091: 1092: 1093: 1094: 1095: 1096: 1097: 1098: 1099: 1100: 1101: 1102: 1103: 1104: 1105: 1106: 1107: 1108: 1109: 1110: 1111: 1112: 1113: 1114: 1115: 1116: 1117: 1118: 1119: 1120: 1121: 1122: 1123: 1124: 1125: 1126: 1127: 1128: 1129: 1130: 1131: 1132: 1133: 1134: 1135: 1136: 1137: 1138: 1139: 1140: 1141: 1142: 1143: 1144: 1145: 1146: 1147: 1148: 1149: 1150: 1151: 1152: 1153: 1154: 1155: 1156: 1157: 1158: 1159: 1160: 1161: 1162: 1163: 1164: 1165: 1166: 1167: 1168: 1169: 1170: 1171: 1172: 1173: 1174: 1175: 1176: 1177: 1178: 1179: 1180: 1181: 1182: 1183: 1184: 1185: 1186: 1187: 1188: 1189: 1190: 1191: 1192: 1193: 1194: 1195: 1196: 1197: 1198: 1199: 1200: 1201: 1202: 1203: 1204: 1205: 1206: 1207: 1208: 1209: 1210: 1211: 1212: 1213: 1214: 1215: 1216: 1217: 1218: 1219: 1220: 1221: 1222: 1223: 1224: 1225: 1226: 1227: 1228: 1229: 1230: 1231: 1232: 1233: 1234: 1235: 1236: 1237: 1238: 1239: 1240: 1241: 1242: 1243: 1244: 1245: 1246: 1247: 1248: 1249: 1250: 1251: 1252: 1253: 1254: 1255: 1256: 1257: 1258: 1259: 1260: 1261: 1262: 1263: 1264: 1265: 1266: 1267: 1268: 1269: 1270: 1271: 1272: 1273: 1274: 1275: 1276: 1277: 1278: 1279: 1280: 1281: 1282: 1283: 1284: 1285: 1286: 1287: 1288: 1289: 1290: 1291: 1292: 1293: 1294: 1295: 1296: 1297: 1298: 1299: 1300: 1301: 1302: 1303: 1304: 1305: 1306: 1307: 1308: 1309: 1310: 1311: 1312: 1313: 1314: 1315: 1316: 1317: 1318: 1319: 1320: 1321: 1322: 1323: 1324: 1325: 1326: 1327: 1328: 1329: 1330: 1331: 1332: 1333: 1334: 1335: 1336: 1337: 1338: 1339: 1340: 1341: 1342: 1343: 1344: 1345: 1346: 1347: 1348: 1349: 1350: 1351: 1352: 1353: 1354: 1355: 1356: 1357: 1358: 1359: 1360: 1361: 1362: 1363: 1364: 1365: 1366: 1367: 1368: 1369: 1370: 1371: 1372: 1373: 1374: 1375: 1376: 1377: 1378: 1379: 1380: 1381: 1382: 1383: 1384: 1385: 1386: 1387: 1388: 1389: 1390: 1391: 1392: 1393: 1394: 1395: 1396: 1397: 1398: 1399: 1400: 1401: 1402: 1403: 1404: 1405: 1406: 1407: 1408: 1409: 1410: 1411: 1412: 1413: 1414: 1415: 1416: 1417: 1418: 1419: 1420: 1421: 1422: 1423: 1424: 1425: 1426: 1427: 1428: 1429: 1430: 1431: 1432: 1433: 1434: 1435: 1436: 1437: 1438: 1439: 1440: 1441: 1442: 1443: 1444: 1445: 1446: 1447: 1448: 1449: 1450: 1451: 1452: 1453: 1454: 1455: 1456: 1457: 1458: 1459: 1460: 1461: 1462: 1463: 1464: 1465: 1466: 1467: 1468: 1469: 1470: 1471: 1472: 1473: 1474: 1475: 1476: 1477: 1478: 1479: 1480: 1481: 1482: 1483: 1484: 1485: 1486: 1487: 1488: 1489: 1490: 1491: 1492: 1493: 1494: 1495: 1496: 1497: 1498: 1499: 1500: 1501: 1502: 1503: 1504: 1505: 1506: 1507: 1508: 1509: 1510: 1511: 1512: 1513: 1514: 1515: 1516: 1517: 1518: 1519: 1520: 1521: 1522: 1523: 1524: 1525: 1526: 1527: 1528: 1529: 1530: 1531: 1532: 1533: 1534: 1535: 1536: 1537: 1538: 1539: 1540: 1541: 1542: 1543: 1544: 1545: 1546: 1547: 1548: 1549: 1550: 1551: 1552: 1553: 1554: 1555: 1556: 1557: 1558: 1559: 1560: 1561: 1562: 1563: 1564: 1565: 1566: 1567: 1568: 1569: 1570: 1571: 1572: 1573: 1574: 1575: 1576: 1577: 1578: 1579: 1580: 1581: 1582: 1583: 1584: 1585: 1586: 1587: 1588: 1589: 1590: 1591: 1592: 1593: 1594: 1595: 1596: 1597: 1598: 1599: 1600: 1601: 1602: 1603: 1604: 1605: 1606: 1607: 1608: 1609: 1610: 1611: 1612: 1613: 1614: 1615: 1616: 1617: 1618: 1619: 1620: 1621: 1622: 1623: 1624: 1625: 1626: 1627: 1628: 1629: 1630: 1631: 1632: 1633: 1634: 1635: 1636: 1637: 1638: 1639: 1640: 1641: 1642: 1643: 1644: 1645: 1646: 1647: 1648: 1649: 1650: 1651: 1652: 1653: 1654: 1655: 1656: 1657: 1658: 1659: 1660: 1661: 1662: 1663: 1664: 1665: 1666: 1667: 1668: 1669: 1670: 1671: 1672: 1673: 1674: 1675: 1676: 1677: 1678: 1679: 1680: 1681: 1682: 1683: 1684: 1685: 1686: 1687: 1688: 1689: 1690: 1691: 1692: 1693: 1694: 1695: 1696: 1697: 1698: 1699: 1700: 1701: 1702: 1703: 1704: 1705: 1706: 1707: 1708: 1709: 1710: 1711: 1712: 1713: 1714: 1715: 1716: 1717: 1718: 1719: 1720: 1721: 1722: 1723: 1724: 1725: 1726: 1727: 1728: 1729: 1730: 1731: 1732: 1733: 1734: 1735: 1736: 1737: 1738: 1739: 1740: 1741: 1742: 1743: 1744: 1745: 1746: 1747: 1748: 1749: 1750: 1751: 1752: 1753: 1754: 1755: 1756: 1757: 1758: 1759: 1760: 1761: 1762: 1763: 1764: 1765: 1766: 1767: 1768: 1769: 1770: 1771: 1772: 1773: 1774: 1775: 1776: 1777: 1778: 1779: 1780: 1781: 1782: 1783: 1784: 1785: 1786: 1787: 1788: 1789: 1790: 1791: 1792: 1793: 1794: 1795: 1796: 1797: 1798: 1799: 1800: 1801: 1802: 1803: 1804: 1805: 1806: 1807: 1808: 1809: 1810: 1811: 1812: 1813: 1814: 1815: 1816: 1817: 1818: 1819: 1820: 1821: 1822: 1823: 1824: 1825: 1826: 1827: 1828: 1829: 1830: 1831: 1832: 1833: 1834: 1835: 1836: 1837: 1838: 

<?php

/**
 * This is here for the "repair any errors" feature in the admin center.
 *
 * 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...');

/**
 * Finds or repairs errors in the database to fix possible problems.
 * Requires the admin_forum permission.
 * Calls createSalvageArea() to create a new board, if necessary.
 * Accessed by ?action=admin;area=repairboards.
 *
 * @uses repair_boards sub-template.
 */
function RepairBoards()
{
    global $txt, $context, $sourcedir, $salvageBoardID;

    isAllowedTo('admin_forum');

    // Try secure more memory.
    setMemoryLimit('128M');

    // Print out the top of the webpage.
    $context['page_title'] = $txt['admin_repair'];
    $context['sub_template'] = 'repair_boards';
    $context[$context['admin_menu_name']]['current_subsection'] = 'general';

    // Load the language file.
    loadLanguage('ManageMaintenance');

    // Make sure the tabs stay nice.
    $context[$context['admin_menu_name']]['tab_data'] = array(
        'title' => $txt['maintain_title'],
        'help' => '',
        'description' => $txt['maintain_info'],
        'tabs' => array(),
    );

    // Start displaying errors without fixing them.
    if (isset($_GET['fixErrors']))
        checkSession('get');

    // Will want this.
    loadForumTests();

    // Giant if/else. The first displays the forum errors if a variable is not set and asks
    // if you would like to continue, the other fixes the errors.
    if (!isset($_GET['fixErrors']))
    {
        $context['error_search'] = true;
        $context['repair_errors'] = array();
        $context['to_fix'] = findForumErrors();

        if (!empty($context['to_fix']))
        {
            $_SESSION['repairboards_to_fix'] = $context['to_fix'];
            $_SESSION['repairboards_to_fix2'] = null;

            if (empty($context['repair_errors']))
                $context['repair_errors'][] = '???';
        }

        // Need a token here.
        createToken('admin-repairboards', 'request');
    }
    else
    {
        // Validate the token, create a new one and tell the not done template.
        validateToken('admin-repairboards', 'request');
        createToken('admin-repairboards', 'request');
        $context['not_done_token'] = 'admin-repairboards';

        $context['error_search'] = false;
        $context['to_fix'] = isset($_SESSION['repairboards_to_fix']) ? $_SESSION['repairboards_to_fix'] : array();

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

        // Actually do the fix.
        findForumErrors(true);

        // Note that we've changed everything possible ;)
        updateSettings(array(
            'settings_updated' => time(),
        ));
        updateStats('message');
        updateStats('topic');
        updateSettings(array(
            'calendar_updated' => time(),
        ));

        // If we created a salvage area, we may need to recount stats properly.
        if (!empty($salvageBoardID) || !empty($_SESSION['salvageBoardID']))
        {
            unset($_SESSION['salvageBoardID']);
            $context['redirect_to_recount'] = true;
            createToken('admin-maint');
        }

        $_SESSION['repairboards_to_fix'] = null;
        $_SESSION['repairboards_to_fix2'] = null;

        // We are done at this point, dump the token,
        validateToken('admin-repairboards', 'request', false);
    }
}

/**
 * Show the not_done template to avoid CGI timeouts and similar.
 * Called when 3 or more seconds have passed while searching for errors.
 * If max_substep is set, $_GET['substep'] / $max_substep is the percent
 * done this step is.
 *
 * @param array $to_fix An array of information about what to fix
 * @param string $current_step_description The description of the current step
 * @param int $max_substep The maximum substep to reach before pausing
 * @param bool $force Whether to force pausing even if we don't really need to
 */
function pauseRepairProcess($to_fix, $current_step_description, $max_substep = 0, $force = false)
{
    global $context, $txt, $db_temp_cache, $db_cache;

    // More time, I need more time!
    @set_time_limit(600);
    if (function_exists('apache_reset_timeout'))
        @apache_reset_timeout();

    // Errr, wait.  How much time has this taken already?
    if (!$force && (time() - TIME_START) < 3)
        return;

    // Restore the query cache if interested.
    if (!empty($db_temp_cache))
        $db_cache = $db_temp_cache;

    $context['continue_get_data'] = '?action=admin;area=repairboards' . (isset($_GET['fixErrors']) ? ';fixErrors' : '') . ';step=' . $_GET['step'] . ';substep=' . $_GET['substep'] . ';' . $context['session_var'] . '=' . $context['session_id'];
    $context['page_title'] = $txt['not_done_title'];
    $context['continue_post_data'] = '';
    $context['continue_countdown'] = '2';
    $context['sub_template'] = 'not_done';

    // Change these two if more steps are added!
    if (empty($max_substep))
        $context['continue_percent'] = round(($_GET['step'] * 100) / $context['total_steps']);
    else
        $context['continue_percent'] = round((($_GET['step'] + ($_GET['substep'] / $max_substep)) * 100) / $context['total_steps']);

    // Never more than 100%!
    $context['continue_percent'] = min($context['continue_percent'], 100);

    // What about substeps?
    $context['substep_enabled'] = $max_substep != 0;
    $context['substep_title'] = sprintf($txt['repair_currently_' . (isset($_GET['fixErrors']) ? 'fixing' : 'checking')], (isset($txt['repair_operation_' . $current_step_description]) ? $txt['repair_operation_' . $current_step_description] : $current_step_description));
    $context['substep_continue_percent'] = $max_substep == 0 ? 0 : round(($_GET['substep'] * 100) / $max_substep, 1);

    $_SESSION['repairboards_to_fix'] = $to_fix;
    $_SESSION['repairboards_to_fix2'] = $context['repair_errors'];

    obExit();
}

/**
 * Load up all the tests we might want to do ;)
 */
function loadForumTests()
{
    global $errorTests, $smcFunc, $txt, $context;

    /* Here this array is defined like so:
        string check_query: Query to be executed when testing if errors exist.
        string check_type:  Defines how it knows if a problem was found. If set to count looks for the first variable from check_query
                    being > 0. Anything else it looks for some results. If not set assumes you want results.
        string fix_it_query:    When doing fixes if an error was detected this query is executed to "fix" it.
        string fix_query:   The query to execute to get data when doing a fix. If not set check_query is used again.
        array fix_collect:  This array is used if the fix is basically gathering all broken ids and then doing something with it.
            - string index:     The value returned from the main query and passed to the processing function.
            - process:      A function passed an array of ids to execute the fix on.
        function fix_processing:
                    Function called for each row returned from fix_query to execute whatever fixes are required.
        function fix_full_processing:
                    As above but does the while loop and everything itself - except the freeing.
        array force_fix:    If this is set then the error types included within this array will also be assumed broken.
                    Note: At the moment only processes these if they occur after the primary error in the array.
    */

    // This great array contains all of our error checks, fixes, etc etc etc.
    $errorTests = array(
        // Make a last-ditch-effort check to get rid of topics with zeros..
        'zero_topics' => array(
            'check_query' => '
                SELECT COUNT(*)
                FROM {db_prefix}topics
                WHERE id_topic = 0',
            'check_type' => 'count',
            'fix_it_query' => '
                UPDATE {db_prefix}topics
                SET id_topic = NULL
                WHERE id_topic = 0',
            'message' => 'repair_zero_ids',
        ),
        // ... and same with messages.
        'zero_messages' => array(
            'check_query' => '
                SELECT COUNT(*)
                FROM {db_prefix}messages
                WHERE id_msg = 0',
            'check_type' => 'count',
            'fix_it_query' => '
                UPDATE {db_prefix}messages
                SET id_msg = NULL
                WHERE id_msg = 0',
            'message' => 'repair_zero_ids',
        ),
        // Find messages that don't have existing topics.
        'missing_topics' => array(
            'substeps' => array(
                'step_size' => 1000,
                'step_max' => '
                    SELECT MAX(id_topic)
                    FROM {db_prefix}messages'
            ),
            'check_query' => '
                SELECT m.id_topic, m.id_msg
                FROM {db_prefix}messages AS m
                    LEFT JOIN {db_prefix}topics AS t ON (t.id_topic = m.id_topic)
                WHERE m.id_topic BETWEEN {STEP_LOW} AND {STEP_HIGH}
                    AND t.id_topic IS NULL
                ORDER BY m.id_topic, m.id_msg',
            'fix_query' => '
                SELECT
                    m.id_board, m.id_topic, MIN(m.id_msg) AS myid_first_msg, MAX(m.id_msg) AS myid_last_msg,
                    COUNT(*) - 1 AS my_num_replies
                FROM {db_prefix}messages AS m
                    LEFT JOIN {db_prefix}topics AS t ON (t.id_topic = m.id_topic)
                WHERE t.id_topic IS NULL
                GROUP BY m.id_topic, m.id_board',
            'fix_processing' => function($row) use ($smcFunc)
            {
                global $salvageBoardID;

                // Only if we don't have a reasonable idea of where to put it.
                if ($row['id_board'] == 0)
                {
                    createSalvageArea();
                    $row['id_board'] = $_SESSION['salvageBoardID'] = (int) $salvageBoardID;
                }

                // Make sure that no topics claim the first/last message as theirs.
                $smcFunc['db_query']('', '
                    UPDATE {db_prefix}topics
                    SET id_first_msg = 0
                    WHERE id_first_msg = {int:id_first_msg}',
                    array(
                        'id_first_msg' => $row['myid_first_msg'],
                    )
                );
                $smcFunc['db_query']('', '
                    UPDATE {db_prefix}topics
                    SET id_last_msg = 0
                    WHERE id_last_msg = {int:id_last_msg}',
                    array(
                        'id_last_msg' => $row['myid_last_msg'],
                    )
                );

                $memberStartedID = (int) getMsgMemberID($row['myid_first_msg']);
                $memberUpdatedID = (int) getMsgMemberID($row['myid_last_msg']);

                $newTopicID = $smcFunc['db_insert']('',
                    '{db_prefix}topics',
                    array(
                        'id_board' => 'int',
                        'id_member_started' => 'int',
                        'id_member_updated' => 'int',
                        'id_first_msg' => 'int',
                        'id_last_msg' => 'int',
                        'num_replies' => 'int'
                    ),
                    array(
                        $row['id_board'],
                        $memberStartedID,
                        $memberUpdatedID,
                        $row['myid_first_msg'],
                        $row['myid_last_msg'],
                        $row['my_num_replies']
                    ),
                    array('id_topic'),
                    1
                );

                $smcFunc['db_query']('', '
                    UPDATE {db_prefix}messages
                    SET id_topic = {int:newTopicID}, id_board = {int:board_id}
                    WHERE id_topic = {int:topic_id}',
                    array(
                        'board_id' => $row['id_board'],
                        'topic_id' => $row['id_topic'],
                        'newTopicID' => $newTopicID,
                    )
                );
            },
            'force_fix' => array('stats_topics'),
            'messages' => array('repair_missing_topics', 'id_msg', 'id_topic'),
        ),
        // Find topics with no messages.
        'missing_messages' => array(
            'substeps' => array(
                'step_size' => 1000,
                'step_max' => '
                    SELECT MAX(id_topic)
                    FROM {db_prefix}topics'
            ),
            'check_query' => '
                SELECT t.id_topic, COUNT(m.id_msg) AS num_msg
                FROM {db_prefix}topics AS t
                    LEFT JOIN {db_prefix}messages AS m ON (m.id_topic = t.id_topic)
                WHERE t.id_topic BETWEEN {STEP_LOW} AND {STEP_HIGH}
                GROUP BY t.id_topic
                HAVING COUNT(m.id_msg) = 0',
            // Remove all topics that have zero messages in the messages table.
            'fix_collect' => array(
                'index' => 'id_topic',
                'process' => function($topics) use ($smcFunc)
                {
                    $smcFunc['db_query']('', '
                        DELETE FROM {db_prefix}topics
                        WHERE id_topic IN ({array_int:topics})',
                        array(
                            'topics' => $topics,
                        )
                    );
                    $smcFunc['db_query']('', '
                        DELETE FROM {db_prefix}log_topics
                        WHERE id_topic IN ({array_int:topics})',
                        array(
                            'topics' => $topics,
                        )
                    );
                },
            ),
            'messages' => array('repair_missing_messages', 'id_topic'),
        ),
        'poll_options_missing_poll' => array(
            'substeps' => array(
                'step_size' => 500,
                'step_max' => '
                    SELECT MAX(id_poll)
                    FROM {db_prefix}poll_choices'
            ),
            'check_query' => '
                SELECT o.id_poll, count(*) as amount, t.id_topic, t.id_board, t.id_member_started AS id_poster, m.member_name AS poster_name
                FROM {db_prefix}poll_choices AS o
                    LEFT JOIN {db_prefix}polls AS p ON (p.id_poll = o.id_poll)
                    LEFT JOIN {db_prefix}topics AS t ON (t.id_poll = o.id_poll)
                    LEFT JOIN {db_prefix}members AS m ON (m.id_member = t.id_member_started)
                WHERE o.id_poll BETWEEN {STEP_LOW} AND {STEP_HIGH}
                    AND p.id_poll IS NULL
                GROUP BY o.id_poll, t.id_topic, t.id_board, t.id_member_started, m.member_name',
            'fix_processing' => function($row) use ($smcFunc, $txt)
            {
                global $salvageBoardID;

                $row['poster_name'] = !empty($row['poster_name']) ? $row['poster_name'] : $txt['guest'];
                $row['id_poster'] = !empty($row['id_poster']) ? $row['id_poster'] : 0;

                if (empty($row['id_board']))
                {
                    // Only if we don't have a reasonable idea of where to put it.
                    createSalvageArea();
                    $row['id_board'] = $_SESSION['salvageBoardID'] = (int) $salvageBoardID;
                }

                if (empty($row['id_topic']))
                {
                    $newMessageID = $smcFunc['db_insert']('',
                        '{db_prefix}messages',
                        array(
                            'id_board' => 'int',
                            'id_topic' => 'int',
                            'poster_time' => 'int',
                            'id_member' => 'int',
                            'subject' => 'string-255',
                            'poster_name' => 'string-255',
                            'poster_email' => 'string-255',
                            'poster_ip' => 'inet',
                            'smileys_enabled' => 'int',
                            'body' => 'string-65534',
                            'icon' => 'string-16',
                            'approved' => 'int',
                        ),
                        array(
                            $row['id_board'],
                            0,
                            time(),
                            $row['id_poster'],
                            $txt['salvaged_poll_topic_name'],
                            $row['poster_name'],
                            $txt['salvaged_poll_topic_name'],
                            '127.0.0.1',
                            1,
                            $txt['salvaged_poll_message_body'],
                            'xx',
                            1,
                        ),
                        array('id_msg'),
                        1
                    );

                    $row['id_topic'] = $smcFunc['db_insert']('',
                        '{db_prefix}topics',
                        array(
                            'id_board' => 'int',
                            'id_poll' => 'int',
                            'id_member_started' => 'int',
                            'id_member_updated' => 'int',
                            'id_first_msg' => 'int',
                            'id_last_msg' => 'int',
                            'num_replies' => 'int',
                        ),
                        array(
                            $row['id_board'],
                            $row['id_poll'],
                            $row['id_poster'],
                            $row['id_poster'],
                            $newMessageID,
                            $newMessageID,
                            0,
                        ),
                        array('id_topic'),
                        1
                    );

                    $smcFunc['db_query']('', '
                        UPDATE {db_prefix}messages
                        SET id_topic = {int:newTopicID}, id_board = {int:id_board}
                        WHERE id_msg = {int:newMessageID}',
                        array(
                            'id_board' => $row['id_board'],
                            'newTopicID' => $row['id_topic'],
                            'newMessageID' => $newMessageID,
                        )
                    );

                    updateStats('subject', $row['id_topic'], $txt['salvaged_poll_topic_name']);
                }

                $smcFunc['db_insert']('',
                    '{db_prefix}polls',
                    array(
                        'id_poll' => 'int',
                        'question' => 'string-255',
                        'voting_locked' => 'int',
                        'max_votes' => 'int',
                        'expire_time' => 'int',
                        'hide_results' => 'int',
                        'change_vote' => 'int',
                        'guest_vote' => 'int',
                        'num_guest_voters' => 'int',
                        'reset_poll' => 'int',
                        'id_member' => 'int',
                        'poster_name' => 'string-255',
                    ),
                    array(
                        $row['id_poll'],
                        $txt['salvaged_poll_question'],
                        1,
                        0,
                        0,
                        0,
                        0,
                        0,
                        0,
                        0,
                        $row['id_poster'],
                        $row['poster_name'],
                    ),
                    array()
                );
            },
            'force_fix' => array('stats_topics'),
            'messages' => array('repair_poll_options_missing_poll', 'id_poll', 'amount'),
        ),
        'polls_missing_topics' => array(
            'substeps' => array(
                'step_size' => 500,
                'step_max' => '
                    SELECT MAX(id_poll)
                    FROM {db_prefix}polls'
            ),
            'check_query' => '
                SELECT p.id_poll, p.id_member, p.poster_name, t.id_board
                FROM {db_prefix}polls AS p
                    LEFT JOIN {db_prefix}topics AS t ON (t.id_poll = p.id_poll)
                WHERE p.id_poll BETWEEN {STEP_LOW} AND {STEP_HIGH}
                    AND t.id_poll IS NULL',
            'fix_processing' => function($row) use ($smcFunc, $txt)
            {
                global $salvageBoardID;

                // Only if we don't have a reasonable idea of where to put it.
                if ($row['id_board'] == 0)
                {
                    createSalvageArea();
                    $row['id_board'] = $_SESSION['salvageBoardID'] = (int) $salvageBoardID;
                }

                $row['poster_name'] = !empty($row['poster_name']) ? $row['poster_name'] : $txt['guest'];

                $newMessageID = $smcFunc['db_insert']('',
                    '{db_prefix}messages',
                    array(
                        'id_board' => 'int',
                        'id_topic' => 'int',
                        'poster_time' => 'int',
                        'id_member' => 'int',
                        'subject' => 'string-255',
                        'poster_name' => 'string-255',
                        'poster_email' => 'string-255',
                        'poster_ip' => 'inet',
                        'smileys_enabled' => 'int',
                        'body' => 'string-65534',
                        'icon' => 'string-16',
                        'approved' => 'int',
                    ),
                    array(
                        $row['id_board'],
                        0,
                        time(),
                        $row['id_member'],
                        $txt['salvaged_poll_topic_name'],
                        $row['poster_name'],
                        '',
                        '127.0.0.1',
                        1,
                        $txt['salvaged_poll_message_body'],
                        'xx',
                        1,
                    ),
                    array('id_msg'),
                    1
                );

                $newTopicID = $smcFunc['db_insert']('',
                    '{db_prefix}topics',
                    array(
                        'id_board' => 'int',
                        'id_poll' => 'int',
                        'id_member_started' => 'int',
                        'id_member_updated' => 'int',
                        'id_first_msg' => 'int',
                        'id_last_msg' => 'int',
                        'num_replies' => 'int',
                    ),
                    array(
                        $row['id_board'],
                        $row['id_poll'],
                        $row['id_member'],
                        $row['id_member'],
                        $newMessageID,
                        $newMessageID,
                        0,
                    ),
                    array('id_topic'),
                    1
                );

                $smcFunc['db_query']('', '
                    UPDATE {db_prefix}messages
                    SET id_topic = {int:newTopicID}, id_board = {int:id_board}
                    WHERE id_msg = {int:newMessageID}',
                    array(
                        'id_board' => $row['id_board'],
                        'newTopicID' => $newTopicID,
                        'newMessageID' => $newMessageID,
                    )
                );

                updateStats('subject', $newTopicID, $txt['salvaged_poll_topic_name']);
            },
            'force_fix' => array('stats_topics'),
            'messages' => array('repair_polls_missing_topics', 'id_poll', 'id_topic'),
        ),
        'stats_topics' => array(
            'substeps' => array(
                'step_size' => 200,
                'step_max' => '
                    SELECT MAX(id_topic)
                    FROM {db_prefix}topics'
            ),
            'check_query' => '
                SELECT
                    t.id_topic, t.id_first_msg, t.id_last_msg,
                    CASE WHEN MIN(ma.id_msg) > 0 THEN
                        CASE WHEN MIN(mu.id_msg) > 0 THEN
                            CASE WHEN MIN(mu.id_msg) < MIN(ma.id_msg) THEN MIN(mu.id_msg) ELSE MIN(ma.id_msg) END ELSE
                        MIN(ma.id_msg) END ELSE
                    MIN(mu.id_msg) END AS myid_first_msg,
                    CASE WHEN MAX(ma.id_msg) > 0 THEN MAX(ma.id_msg) ELSE MIN(mu.id_msg) END AS myid_last_msg,
                    t.approved, mf.approved, mf.approved AS firstmsg_approved
                FROM {db_prefix}topics AS t
                    LEFT JOIN {db_prefix}messages AS ma ON (ma.id_topic = t.id_topic AND ma.approved = 1)
                    LEFT JOIN {db_prefix}messages AS mu ON (mu.id_topic = t.id_topic AND mu.approved = 0)
                    LEFT JOIN {db_prefix}messages AS mf ON (mf.id_msg = t.id_first_msg)
                WHERE t.id_topic BETWEEN {STEP_LOW} AND {STEP_HIGH}
                GROUP BY t.id_topic, t.id_first_msg, t.id_last_msg, t.approved, mf.approved
                ORDER BY t.id_topic',
            'fix_processing' => function($row) use ($smcFunc)
            {
                $row['firstmsg_approved'] = (int) $row['firstmsg_approved'];
                $row['myid_first_msg'] = (int) $row['myid_first_msg'];
                $row['myid_last_msg'] = (int) $row['myid_last_msg'];

                // Not really a problem?
                if ($row['id_first_msg'] == $row['myid_first_msg'] && $row['id_last_msg'] == $row['myid_last_msg'] && $row['approved'] == $row['firstmsg_approved'])
                    return false;

                $memberStartedID = (int) getMsgMemberID($row['myid_first_msg']);
                $memberUpdatedID = (int) getMsgMemberID($row['myid_last_msg']);

                $smcFunc['db_query']('', '
                    UPDATE {db_prefix}topics
                    SET id_first_msg = {int:myid_first_msg},
                        id_member_started = {int:memberStartedID}, id_last_msg = {int:myid_last_msg},
                        id_member_updated = {int:memberUpdatedID}, approved = {int:firstmsg_approved}
                    WHERE id_topic = {int:topic_id}',
                    array(
                        'myid_first_msg' => $row['myid_first_msg'],
                        'memberStartedID' => $memberStartedID,
                        'myid_last_msg' => $row['myid_last_msg'],
                        'memberUpdatedID' => $memberUpdatedID,
                        'firstmsg_approved' => $row['firstmsg_approved'],
                        'topic_id' => $row['id_topic'],
                    )
                );
            },
            'message_function' => function($row) use ($txt, &$context)
            {
                // A pretend error?
                if ($row['id_first_msg'] == $row['myid_first_msg'] && $row['id_last_msg'] == $row['myid_last_msg'] && $row['approved'] == $row['firstmsg_approved'])
                    return false;

                if ($row['id_first_msg'] != $row['myid_first_msg'])
                    $context['repair_errors'][] = sprintf($txt['repair_topic_wrong_first_id'], $row['id_topic'], $row['id_first_msg']);
                if ($row['id_last_msg'] != $row['myid_last_msg'])
                    $context['repair_errors'][] = sprintf($txt['repair_topic_wrong_last_id'], $row['id_topic'], $row['id_last_msg']);
                if ($row['approved'] != $row['firstmsg_approved'])
                    $context['repair_errors'][] = sprintf($txt['repair_topic_wrong_approval'], $row['id_topic']);

                return true;
            },
        ),
        // Find topics with incorrect num_replies.
        'stats_topics2' => array(
            'substeps' => array(
                'step_size' => 300,
                'step_max' => '
                    SELECT MAX(id_topic)
                    FROM {db_prefix}topics'
            ),
            'check_query' => '
                SELECT
                    t.id_topic, t.num_replies, mf.approved,
                    CASE WHEN COUNT(ma.id_msg) > 0 THEN CASE WHEN mf.approved > 0 THEN COUNT(ma.id_msg) - 1 ELSE COUNT(ma.id_msg) END ELSE 0 END AS my_num_replies
                FROM {db_prefix}topics AS t
                    LEFT JOIN {db_prefix}messages AS ma ON (ma.id_topic = t.id_topic AND ma.approved = 1)
                    LEFT JOIN {db_prefix}messages AS mf ON (mf.id_msg = t.id_first_msg)
                WHERE t.id_topic BETWEEN {STEP_LOW} AND {STEP_HIGH}
                GROUP BY t.id_topic, t.num_replies, mf.approved
                ORDER BY t.id_topic',
            'fix_processing' => function($row)
            {
                global $smcFunc;
                $row['my_num_replies'] = (int) $row['my_num_replies'];

                // Not really a problem?
                if ($row['my_num_replies'] == $row['num_replies'])
                    return false;

                $smcFunc['db_query']('', '
                    UPDATE {db_prefix}topics
                    SET num_replies = {int:my_num_replies}
                    WHERE id_topic = {int:topic_id}',
                    array(
                        'my_num_replies' => $row['my_num_replies'],
                        'topic_id' => $row['id_topic'],
                    )
                );
            },
            'message_function' => function($row)
            {
                global $txt, $context;

                // Just joking?
                if ($row['my_num_replies'] == $row['num_replies'])
                    return false;

                if ($row['num_replies'] != $row['my_num_replies'])
                    $context['repair_errors'][] = sprintf($txt['repair_topic_wrong_replies'], $row['id_topic'], $row['num_replies']);

                return true;
            },
        ),
        // Find topics with incorrect unapproved_posts.
        'stats_topics3' => array(
            'substeps' => array(
                'step_size' => 1000,
                'step_max' => '
                    SELECT MAX(id_topic)
                    FROM {db_prefix}topics'
            ),
            'check_query' => '
                SELECT
                    t.id_topic, t.unapproved_posts, COUNT(mu.id_msg) AS my_unapproved_posts
                FROM {db_prefix}topics AS t
                    LEFT JOIN {db_prefix}messages AS mu ON (mu.id_topic = t.id_topic AND mu.approved = 0)
                WHERE t.id_topic BETWEEN {STEP_LOW} AND {STEP_HIGH}
                GROUP BY t.id_topic, t.unapproved_posts
                HAVING unapproved_posts != COUNT(mu.id_msg)
                ORDER BY t.id_topic',
            'fix_processing' => function($row)
            {
                global $smcFunc;
                $row['my_unapproved_posts'] = (int) $row['my_unapproved_posts'];

                $smcFunc['db_query']('', '
                    UPDATE {db_prefix}topics
                    SET unapproved_posts = {int:my_unapproved_posts}
                    WHERE id_topic = {int:topic_id}',
                    array(
                        'my_unapproved_posts' => $row['my_unapproved_posts'],
                        'topic_id' => $row['id_topic'],
                    )
                );
            },
            'messages' => array('repair_topic_wrong_unapproved_number', 'id_topic', 'unapproved_posts'),
        ),
        // Find topics with nonexistent boards.
        'missing_boards' => array(
            'substeps' => array(
                'step_size' => 1000,
                'step_max' => '
                    SELECT MAX(id_topic)
                    FROM {db_prefix}topics'
            ),
            'check_query' => '
                SELECT t.id_topic, t.id_board
                FROM {db_prefix}topics AS t
                    LEFT JOIN {db_prefix}boards AS b ON (b.id_board = t.id_board)
                WHERE b.id_board IS NULL
                    AND t.id_topic BETWEEN {STEP_LOW} AND {STEP_HIGH}
                ORDER BY t.id_board, t.id_topic',
            'fix_query' => '
                SELECT t.id_board, COUNT(*) AS my_num_topics, COUNT(m.id_msg) AS my_num_posts
                FROM {db_prefix}topics AS t
                    LEFT JOIN {db_prefix}boards AS b ON (b.id_board = t.id_board)
                    LEFT JOIN {db_prefix}messages AS m ON (m.id_topic = t.id_topic)
                WHERE b.id_board IS NULL
                    AND t.id_topic BETWEEN {STEP_LOW} AND {STEP_HIGH}
                GROUP BY t.id_board',
            'fix_processing' => function($row)
            {
                global $smcFunc, $salvageCatID, $txt;
                createSalvageArea();

                $row['my_num_topics'] = (int) $row['my_num_topics'];
                $row['my_num_posts'] = (int) $row['my_num_posts'];

                $newBoardID = $smcFunc['db_insert']('',
                    '{db_prefix}boards',
                    array('id_cat' => 'int', 'name' => 'string', 'description' => 'string', 'num_topics' => 'int', 'num_posts' => 'int', 'member_groups' => 'string'),
                    array($salvageCatID, $txt['salvaged_board_name'], $txt['salvaged_board_description'], $row['my_num_topics'], $row['my_num_posts'], '1'),
                    array('id_board'),
                    1
                );

                $smcFunc['db_query']('', '
                    UPDATE {db_prefix}topics
                    SET id_board = {int:newBoardID}
                    WHERE id_board = {int:board_id}',
                    array(
                        'newBoardID' => $newBoardID,
                        'board_id' => $row['id_board'],
                    )
                );
                $smcFunc['db_query']('', '
                    UPDATE {db_prefix}messages
                    SET id_board = {int:newBoardID}
                    WHERE id_board = {int:board_id}',
                    array(
                        'newBoardID' => $newBoardID,
                        'board_id' => $row['id_board'],
                    )
                );
            },
            'messages' => array('repair_missing_boards', 'id_topic', 'id_board'),
        ),
        // Find boards with nonexistent categories.
        'missing_categories' => array(
            'check_query' => '
                SELECT b.id_board, b.id_cat
                FROM {db_prefix}boards AS b
                    LEFT JOIN {db_prefix}categories AS c ON (c.id_cat = b.id_cat)
                WHERE c.id_cat IS NULL
                ORDER BY b.id_cat, b.id_board',
            'fix_collect' => array(
                'index' => 'id_cat',
                'process' => function($cats)
                {
                    global $smcFunc, $salvageCatID;
                    createSalvageArea();
                    $smcFunc['db_query']('', '
                        UPDATE {db_prefix}boards
                        SET id_cat = {int:salvageCatID}
                        WHERE id_cat IN ({array_int:categories})',
                        array(
                            'salvageCatID' => $salvageCatID,
                            'categories' => $cats,
                        )
                    );
                },
            ),
            'messages' => array('repair_missing_categories', 'id_board', 'id_cat'),
        ),
        // Find messages with nonexistent members.
        'missing_posters' => array(
            'substeps' => array(
                'step_size' => 2000,
                'step_max' => '
                    SELECT MAX(id_msg)
                    FROM {db_prefix}messages'
            ),
            'check_query' => '
                SELECT m.id_msg, m.id_member
                FROM {db_prefix}messages AS m
                    LEFT JOIN {db_prefix}members AS mem ON (mem.id_member = m.id_member)
                WHERE mem.id_member IS NULL
                    AND m.id_member != 0
                    AND m.id_msg BETWEEN {STEP_LOW} AND {STEP_HIGH}
                ORDER BY m.id_msg',
            // Last step-make sure all non-guest posters still exist.
            'fix_collect' => array(
                'index' => 'id_msg',
                'process' => function($msgs)
                {
                    global $smcFunc;
                    $smcFunc['db_query']('', '
                        UPDATE {db_prefix}messages
                        SET id_member = {int:guest_id}
                        WHERE id_msg IN ({array_int:msgs})',
                        array(
                            'msgs' => $msgs,
                            'guest_id' => 0,
                        )
                    );
                },
            ),
            'messages' => array('repair_missing_posters', 'id_msg', 'id_member'),
        ),
        // Find boards with nonexistent parents.
        'missing_parents' => array(
            'check_query' => '
                SELECT b.id_board, b.id_parent
                FROM {db_prefix}boards AS b
                    LEFT JOIN {db_prefix}boards AS p ON (p.id_board = b.id_parent)
                WHERE b.id_parent != 0
                    AND (p.id_board IS NULL OR p.id_board = b.id_board)
                ORDER BY b.id_parent, b.id_board',
            'fix_collect' => array(
                'index' => 'id_parent',
                'process' => function($parents)
                {
                    global $smcFunc, $salvageBoardID, $salvageCatID;

                    createSalvageArea();
                    $_SESSION['salvageBoardID'] = (int) $salvageBoardID;

                    $smcFunc['db_query']('', '
                        UPDATE {db_prefix}boards
                        SET id_parent = {int:salvageBoardID}, id_cat = {int:salvageCatID}, child_level = 1
                        WHERE id_parent IN ({array_int:parents})',
                        array(
                            'salvageBoardID' => $salvageBoardID,
                            'salvageCatID' => $salvageCatID,
                            'parents' => $parents,
                        )
                    );
                },
            ),
            'messages' => array('repair_missing_parents', 'id_board', 'id_parent'),
        ),
        'missing_polls' => array(
            'substeps' => array(
                'step_size' => 500,
                'step_max' => '
                    SELECT MAX(id_poll)
                    FROM {db_prefix}topics'
            ),
            'check_query' => '
                SELECT t.id_poll, t.id_topic
                FROM {db_prefix}topics AS t
                    LEFT JOIN {db_prefix}polls AS p ON (p.id_poll = t.id_poll)
                WHERE t.id_poll != 0
                    AND t.id_poll BETWEEN {STEP_LOW} AND {STEP_HIGH}
                    AND p.id_poll IS NULL',
            'fix_collect' => array(
                'index' => 'id_poll',
                'process' => function($polls)
                {
                    global $smcFunc;
                    $smcFunc['db_query']('', '
                        UPDATE {db_prefix}topics
                        SET id_poll = 0
                        WHERE id_poll IN ({array_int:polls})',
                        array(
                            'polls' => $polls,
                        )
                    );
                },
            ),
            'messages' => array('repair_missing_polls', 'id_topic', 'id_poll'),
        ),
        'missing_calendar_topics' => array(
            'substeps' => array(
                'step_size' => 1000,
                'step_max' => '
                    SELECT MAX(id_topic)
                    FROM {db_prefix}calendar'
            ),
            'check_query' => '
                SELECT cal.id_topic, cal.id_event
                FROM {db_prefix}calendar AS cal
                    LEFT JOIN {db_prefix}topics AS t ON (t.id_topic = cal.id_topic)
                WHERE cal.id_topic != 0
                    AND cal.id_topic BETWEEN {STEP_LOW} AND {STEP_HIGH}
                    AND t.id_topic IS NULL
                ORDER BY cal.id_topic',
            'fix_collect' => array(
                'index' => 'id_topic',
                'process' => function($events)
                {
                    global $smcFunc;
                    $smcFunc['db_query']('', '
                        UPDATE {db_prefix}calendar
                        SET id_topic = 0, id_board = 0
                        WHERE id_topic IN ({array_int:events})',
                        array(
                            'events' => $events,
                        )
                    );
                },
            ),
            'messages' => array('repair_missing_calendar_topics', 'id_event', 'id_topic'),
        ),
        'missing_log_topics' => array(
            'substeps' => array(
                'step_size' => 150,
                'step_max' => '
                    SELECT MAX(id_member)
                    FROM {db_prefix}log_topics'
            ),
            'check_query' => '
                SELECT lt.id_topic
                FROM {db_prefix}log_topics AS lt
                    LEFT JOIN {db_prefix}topics AS t ON (t.id_topic = lt.id_topic)
                WHERE t.id_topic IS NULL
                    AND lt.id_member BETWEEN {STEP_LOW} AND {STEP_HIGH}',
            'fix_collect' => array(
                'index' => 'id_topic',
                'process' => function($topics)
                {
                    global $smcFunc;
                    $smcFunc['db_query']('', '
                        DELETE FROM {db_prefix}log_topics
                        WHERE id_topic IN ({array_int:topics})',
                        array(
                            'topics' => $topics,
                        )
                    );
                },
            ),
            'messages' => array('repair_missing_log_topics', 'id_topic'),
        ),
        'missing_log_topics_members' => array(
            'substeps' => array(
                'step_size' => 150,
                'step_max' => '
                    SELECT MAX(id_member)
                    FROM {db_prefix}log_topics'
            ),
            'check_query' => '
                SELECT lt.id_member
                FROM {db_prefix}log_topics AS lt
                    LEFT JOIN {db_prefix}members AS mem ON (mem.id_member = lt.id_member)
                WHERE mem.id_member IS NULL
                    AND lt.id_member BETWEEN {STEP_LOW} AND {STEP_HIGH}
                GROUP BY lt.id_member',
            'fix_collect' => array(
                'index' => 'id_member',
                'process' => function($members)
                {
                    global $smcFunc;
                    $smcFunc['db_query']('', '
                        DELETE FROM {db_prefix}log_topics
                        WHERE id_member IN ({array_int:members})',
                        array(
                            'members' => $members,
                        )
                    );
                },
            ),
            'messages' => array('repair_missing_log_topics_members', 'id_member'),
        ),
        'missing_log_boards' => array(
            'substeps' => array(
                'step_size' => 500,
                'step_max' => '
                    SELECT MAX(id_member)
                    FROM {db_prefix}log_boards'
            ),
            'check_query' => '
                SELECT lb.id_board
                FROM {db_prefix}log_boards AS lb
                    LEFT JOIN {db_prefix}boards AS b ON (b.id_board = lb.id_board)
                WHERE b.id_board IS NULL
                    AND lb.id_member BETWEEN {STEP_LOW} AND {STEP_HIGH}
                GROUP BY lb.id_board',
            'fix_collect' => array(
                'index' => 'id_board',
                'process' => function($boards)
                {
                    global $smcFunc;
                    $smcFunc['db_query']('', '
                        DELETE FROM {db_prefix}log_boards
                        WHERE id_board IN ({array_int:boards})',
                        array(
                            'boards' => $boards,
                        )
                    );
                },
            ),
            'messages' => array('repair_missing_log_boards', 'id_board'),
        ),
        'missing_log_boards_members' => array(
            'substeps' => array(
                'step_size' => 500,
                'step_max' => '
                    SELECT MAX(id_member)
                    FROM {db_prefix}log_boards'
            ),
            'check_query' => '
                SELECT lb.id_member
                FROM {db_prefix}log_boards AS lb
                    LEFT JOIN {db_prefix}members AS mem ON (mem.id_member = lb.id_member)
                WHERE mem.id_member IS NULL
                    AND lb.id_member BETWEEN {STEP_LOW} AND {STEP_HIGH}
                GROUP BY lb.id_member',
            'fix_collect' => array(
                'index' => 'id_member',
                'process' => function($members) use ($smcFunc)
                {
                    $smcFunc['db_query']('', '
                        DELETE FROM {db_prefix}log_boards
                        WHERE id_member IN ({array_int:members})',
                        array(
                            'members' => $members,
                        )
                    );
                },
            ),
            'messages' => array('repair_missing_log_boards_members', 'id_member'),
        ),
        'missing_log_mark_read' => array(
            'substeps' => array(
                'step_size' => 500,
                'step_max' => '
                    SELECT MAX(id_member)
                    FROM {db_prefix}log_mark_read'
            ),
            'check_query' => '
                SELECT lmr.id_board
                FROM {db_prefix}log_mark_read AS lmr
                    LEFT JOIN {db_prefix}boards AS b ON (b.id_board = lmr.id_board)
                WHERE b.id_board IS NULL
                    AND lmr.id_member BETWEEN {STEP_LOW} AND {STEP_HIGH}
                GROUP BY lmr.id_board',
            'fix_collect' => array(
                'index' => 'id_board',
                'process' => function($boards) use ($smcFunc)
                {
                    $smcFunc['db_query']('', '
                        DELETE FROM {db_prefix}log_mark_read
                        WHERE id_board IN ({array_int:boards})',
                        array(
                            'boards' => $boards,
                        )
                    );
                },
            ),
            'messages' => array('repair_missing_log_mark_read', 'id_board'),
        ),
        'missing_log_mark_read_members' => array(
            'substeps' => array(
                'step_size' => 500,
                'step_max' => '
                    SELECT MAX(id_member)
                    FROM {db_prefix}log_mark_read'
            ),
            'check_query' => '
                SELECT lmr.id_member
                FROM {db_prefix}log_mark_read AS lmr
                    LEFT JOIN {db_prefix}members AS mem ON (mem.id_member = lmr.id_member)
                WHERE mem.id_member IS NULL
                    AND lmr.id_member BETWEEN {STEP_LOW} AND {STEP_HIGH}
                GROUP BY lmr.id_member',
            'fix_collect' => array(
                'index' => 'id_member',
                'process' => function($members) use ($smcFunc)
                {
                    $smcFunc['db_query']('', '
                        DELETE FROM {db_prefix}log_mark_read
                        WHERE id_member IN ({array_int:members})',
                        array(
                            'members' => $members,
                        )
                    );
                },
            ),
            'messages' => array('repair_missing_log_mark_read_members', 'id_member'),
        ),
        'missing_pms' => array(
            'substeps' => array(
                'step_size' => 500,
                'step_max' => '
                    SELECT MAX(id_pm)
                    FROM {db_prefix}pm_recipients'
            ),
            'check_query' => '
                SELECT pmr.id_pm
                FROM {db_prefix}pm_recipients AS pmr
                    LEFT JOIN {db_prefix}personal_messages AS pm ON (pm.id_pm = pmr.id_pm)
                WHERE pm.id_pm IS NULL
                    AND pmr.id_pm BETWEEN {STEP_LOW} AND {STEP_HIGH}
                GROUP BY pmr.id_pm',
            'fix_collect' => array(
                'index' => 'id_pm',
                'process' => function($pms) use ($smcFunc)
                {
                    $smcFunc['db_query']('', '
                        DELETE FROM {db_prefix}pm_recipients
                        WHERE id_pm IN ({array_int:pms})',
                        array(
                            'pms' => $pms,
                        )
                    );
                },
            ),
            'messages' => array('repair_missing_pms', 'id_pm'),
        ),
        'missing_recipients' => array(
            'substeps' => array(
                'step_size' => 500,
                'step_max' => '
                    SELECT MAX(id_member)
                    FROM {db_prefix}pm_recipients'
            ),
            'check_query' => '
                SELECT pmr.id_member
                FROM {db_prefix}pm_recipients AS pmr
                    LEFT JOIN {db_prefix}members AS mem ON (mem.id_member = pmr.id_member)
                WHERE pmr.id_member != 0
                    AND pmr.id_member BETWEEN {STEP_LOW} AND {STEP_HIGH}
                    AND mem.id_member IS NULL
                GROUP BY pmr.id_member',
            'fix_collect' => array(
                'index' => 'id_member',
                'process' => function($members)
                {
                    global $smcFunc;
                    $smcFunc['db_query']('', '
                        DELETE FROM {db_prefix}pm_recipients
                        WHERE id_member IN ({array_int:members})',
                        array(
                            'members' => $members,
                        )
                    );
                },
            ),
            'messages' => array('repair_missing_recipients', 'id_member'),
        ),
        'missing_senders' => array(
            'substeps' => array(
                'step_size' => 500,
                'step_max' => '
                    SELECT MAX(id_pm)
                    FROM {db_prefix}personal_messages'
            ),
            'check_query' => '
                SELECT pm.id_pm, pm.id_member_from
                FROM {db_prefix}personal_messages AS pm
                    LEFT JOIN {db_prefix}members AS mem ON (mem.id_member = pm.id_member_from)
                WHERE pm.id_member_from != 0
                    AND pm.id_pm BETWEEN {STEP_LOW} AND {STEP_HIGH}
                    AND mem.id_member IS NULL',
            'fix_collect' => array(
                'index' => 'id_pm',
                'process' => function($guestMessages)
                {
                    global $smcFunc;
                    $smcFunc['db_query']('', '
                        UPDATE {db_prefix}personal_messages
                        SET id_member_from = 0
                        WHERE id_pm IN ({array_int:guestMessages})',
                        array(
                            'guestMessages' => $guestMessages,
                        )
                    );
                },
            ),
            'messages' => array('repair_missing_senders', 'id_pm', 'id_member_from'),
        ),
        'missing_notify_members' => array(
            'substeps' => array(
                'step_size' => 500,
                'step_max' => '
                    SELECT MAX(id_member)
                    FROM {db_prefix}log_notify'
            ),
            'check_query' => '
                SELECT ln.id_member
                FROM {db_prefix}log_notify AS ln
                    LEFT JOIN {db_prefix}members AS mem ON (mem.id_member = ln.id_member)
                WHERE ln.id_member BETWEEN {STEP_LOW} AND {STEP_HIGH}
                    AND mem.id_member IS NULL
                GROUP BY ln.id_member',
            'fix_collect' => array(
                'index' => 'id_member',
                'process' => function($members) use ($smcFunc)
                {
                    $smcFunc['db_query']('', '
                        DELETE FROM {db_prefix}log_notify
                        WHERE id_member IN ({array_int:members})',
                        array(
                            'members' => $members,
                        )
                    );
                },
            ),
            'messages' => array('repair_missing_notify_members', 'id_member'),
        ),
        'missing_cached_subject' => array(
            'substeps' => array(
                'step_size' => 100,
                'step_max' => '
                    SELECT MAX(id_topic)
                    FROM {db_prefix}topics'
            ),
            'check_query' => '
                SELECT t.id_topic, fm.subject
                FROM {db_prefix}topics AS t
                    INNER JOIN {db_prefix}messages AS fm ON (fm.id_msg = t.id_first_msg)
                    LEFT JOIN {db_prefix}log_search_subjects AS lss ON (lss.id_topic = t.id_topic)
                WHERE t.id_topic BETWEEN {STEP_LOW} AND {STEP_HIGH}
                    AND lss.id_topic IS NULL',
            'fix_full_processing' => function($result)
            {
                global $smcFunc;

                $inserts = array();
                while ($row = $smcFunc['db_fetch_assoc']($result))
                {
                    foreach (text2words($row['subject']) as $word)
                        $inserts[] = array($word, $row['id_topic']);
                    if (count($inserts) > 500)
                    {
                        $smcFunc['db_insert']('ignore',
                            '{db_prefix}log_search_subjects',
                            array('word' => 'string', 'id_topic' => 'int'),
                            $inserts,
                            array('word', 'id_topic')
                        );
                        $inserts = array();
                    }
                }

                if (!empty($inserts))
                    $smcFunc['db_insert']('ignore',
                        '{db_prefix}log_search_subjects',
                        array('word' => 'string', 'id_topic' => 'int'),
                        $inserts,
                        array('word', 'id_topic')
                    );
            },
            'message_function' => function($row)
            {
                global $txt, $context;

                if (count(text2words($row['subject'])) != 0)
                {
                    $context['repair_errors'][] = sprintf($txt['repair_missing_cached_subject'], $row['id_topic']);
                    return true;
                }

                return false;
            },
        ),
        'missing_topic_for_cache' => array(
            'substeps' => array(
                'step_size' => 50,
                'step_max' => '
                    SELECT MAX(id_topic)
                    FROM {db_prefix}log_search_subjects'
            ),
            'check_query' => '
                SELECT lss.id_topic, lss.word
                FROM {db_prefix}log_search_subjects AS lss
                    LEFT JOIN {db_prefix}topics AS t ON (t.id_topic = lss.id_topic)
                WHERE lss.id_topic BETWEEN {STEP_LOW} AND {STEP_HIGH}
                    AND t.id_topic IS NULL',
            'fix_collect' => array(
                'index' => 'id_topic',
                'process' => function($deleteTopics)
                {
                    global $smcFunc;
                    $smcFunc['db_query']('', '
                        DELETE FROM {db_prefix}log_search_subjects
                        WHERE id_topic IN ({array_int:deleteTopics})',
                        array(
                            'deleteTopics' => $deleteTopics,
                        )
                    );
                },
            ),
            'messages' => array('repair_missing_topic_for_cache', 'word'),
        ),
        'missing_member_vote' => array(
            'substeps' => array(
                'step_size' => 500,
                'step_max' => '
                    SELECT MAX(id_member)
                    FROM {db_prefix}log_polls'
            ),
            'check_query' => '
                SELECT lp.id_poll, lp.id_member
                FROM {db_prefix}log_polls AS lp
                    LEFT JOIN {db_prefix}members AS mem ON (mem.id_member = lp.id_member)
                WHERE lp.id_member BETWEEN {STEP_LOW} AND {STEP_HIGH}
                    AND lp.id_member > 0
                    AND mem.id_member IS NULL',
            'fix_collect' => array(
                'index' => 'id_member',
                'process' => function($members)
                {
                    global $smcFunc;
                    $smcFunc['db_query']('', '
                        DELETE FROM {db_prefix}log_polls
                        WHERE id_member IN ({array_int:members})',
                        array(
                            'members' => $members,
                        )
                    );
                },
            ),
            'messages' => array('repair_missing_log_poll_member', 'id_poll', 'id_member'),
        ),
        'missing_log_poll_vote' => array(
            'substeps' => array(
                'step_size' => 500,
                'step_max' => '
                    SELECT MAX(id_poll)
                    FROM {db_prefix}log_polls'
            ),
            'check_query' => '
                SELECT lp.id_poll, lp.id_member
                FROM {db_prefix}log_polls AS lp
                    LEFT JOIN {db_prefix}polls AS p ON (p.id_poll = lp.id_poll)
                WHERE lp.id_poll BETWEEN {STEP_LOW} AND {STEP_HIGH}
                    AND p.id_poll IS NULL',
            'fix_collect' => array(
                'index' => 'id_poll',
                'process' => function($polls)
                {
                    global $smcFunc;
                    $smcFunc['db_query']('', '
                        DELETE FROM {db_prefix}log_polls
                        WHERE id_poll IN ({array_int:polls})',
                        array(
                            'polls' => $polls,
                        )
                    );
                },
            ),
            'messages' => array('repair_missing_log_poll_vote', 'id_member', 'id_poll'),
        ),
        'report_missing_comments' => array(
            'substeps' => array(
                'step_size' => 500,
                'step_max' => '
                    SELECT MAX(id_report)
                    FROM {db_prefix}log_reported'
            ),
            'check_query' => '
                SELECT lr.id_report, lr.subject
                FROM {db_prefix}log_reported AS lr
                    LEFT JOIN {db_prefix}log_reported_comments AS lrc ON (lrc.id_report = lr.id_report)
                WHERE lr.id_report BETWEEN {STEP_LOW} AND {STEP_HIGH}
                    AND lrc.id_report IS NULL',
            'fix_collect' => array(
                'index' => 'id_report',
                'process' => function($reports)
                {
                    global $smcFunc;
                    $smcFunc['db_query']('', '
                        DELETE FROM {db_prefix}log_reported
                        WHERE id_report IN ({array_int:reports})',
                        array(
                            'reports' => $reports,
                        )
                    );
                },
            ),
            'messages' => array('repair_report_missing_comments', 'id_report', 'subject'),
        ),
        'comments_missing_report' => array(
            'substeps' => array(
                'step_size' => 200,
                'step_max' => '
                    SELECT MAX(id_report)
                    FROM {db_prefix}log_reported_comments'
            ),
            'check_query' => '
                SELECT lrc.id_report, lrc.membername
                FROM {db_prefix}log_reported_comments AS lrc
                    LEFT JOIN {db_prefix}log_reported AS lr ON (lr.id_report = lrc.id_report)
                WHERE lrc.id_report BETWEEN {STEP_LOW} AND {STEP_HIGH}
                    AND lr.id_report IS NULL',
            'fix_collect' => array(
                'index' => 'id_report',
                'process' => function($reports)
                {
                    global $smcFunc;
                    $smcFunc['db_query']('', '
                        DELETE FROM {db_prefix}log_reported_comments
                        WHERE id_report IN ({array_int:reports})',
                        array(
                            'reports' => $reports,
                        )
                    );
                },
            ),
            'messages' => array('repair_comments_missing_report', 'id_report', 'membername'),
        ),
        'group_request_missing_member' => array(
            'substeps' => array(
                'step_size' => 200,
                'step_max' => '
                    SELECT MAX(id_member)
                    FROM {db_prefix}log_group_requests'
            ),
            'check_query' => '
                SELECT lgr.id_member
                FROM {db_prefix}log_group_requests AS lgr
                    LEFT JOIN {db_prefix}members AS mem ON (mem.id_member = lgr.id_member)
                WHERE lgr.id_member BETWEEN {STEP_LOW} AND {STEP_HIGH}
                    AND mem.id_member IS NULL
                GROUP BY lgr.id_member',
            'fix_collect' => array(
                'index' => 'id_member',
                'process' => function($members)
                {
                    global $smcFunc;
                    $smcFunc['db_query']('', '
                        DELETE FROM {db_prefix}log_group_requests
                        WHERE id_member IN ({array_int:members})',
                        array(
                            'members' => $members,
                        )
                    );
                },
            ),
            'messages' => array('repair_group_request_missing_member', 'id_member'),
        ),
        'group_request_missing_group' => array(
            'substeps' => array(
                'step_size' => 200,
                'step_max' => '
                    SELECT MAX(id_group)
                    FROM {db_prefix}log_group_requests'
            ),
            'check_query' => '
                SELECT lgr.id_group
                FROM {db_prefix}log_group_requests AS lgr
                    LEFT JOIN {db_prefix}membergroups AS mg ON (mg.id_group = lgr.id_group)
                WHERE lgr.id_group BETWEEN {STEP_LOW} AND {STEP_HIGH}
                    AND mg.id_group IS NULL
                GROUP BY lgr.id_group',
            'fix_collect' => array(
                'index' => 'id_group',
                'process' => function($groups)
                {
                    global $smcFunc;
                    $smcFunc['db_query']('', '
                        DELETE FROM {db_prefix}log_group_requests
                        WHERE id_group IN ({array_int:groups})',
                        array(
                            'groups' => $groups,
                        )
                    );
                },
            ),
            'messages' => array('repair_group_request_missing_group', 'id_group'),
        ),
    );
}

/**
 * Checks for errors in steps, until 5 seconds have passed.
 * It keeps track of the errors it did find, so that the actual repair
 * won't have to recheck everything.
 *
 * @param bool $do_fix Whether to actually fix the errors or just return the info
 * @return array, the errors found.
 */
function findForumErrors($do_fix = false)
{
    global $context, $txt, $smcFunc, $errorTests, $db_cache, $db_temp_cache;

    // This may take some time...
    @set_time_limit(600);

    $to_fix = !empty($_SESSION['repairboards_to_fix']) ? $_SESSION['repairboards_to_fix'] : array();
    $context['repair_errors'] = isset($_SESSION['repairboards_to_fix2']) ? $_SESSION['repairboards_to_fix2'] : array();

    $_GET['step'] = empty($_GET['step']) ? 0 : (int) $_GET['step'];
    $_GET['substep'] = empty($_GET['substep']) ? 0 : (int) $_GET['substep'];

    // Don't allow the cache to get too full.
    $db_temp_cache = $db_cache;
    $db_cache = array();

    $context['total_steps'] = count($errorTests);

    // For all the defined error types do the necessary tests.
    $current_step = -1;
    $total_queries = 0;
    foreach ($errorTests as $error_type => $test)
    {
        $current_step++;

        // Already done this?
        if ($_GET['step'] > $current_step)
            continue;

        // If we're fixing it but it ain't broke why try?
        if ($do_fix && !in_array($error_type, $to_fix))
        {
            $_GET['step']++;
            continue;
        }

        // Has it got substeps?
        if (isset($test['substeps']))
        {
            $step_size = isset($test['substeps']['step_size']) ? $test['substeps']['step_size'] : 100;
            $request = $smcFunc['db_query']('',
                $test['substeps']['step_max'],
                array(
                )
            );
            list ($step_max) = $smcFunc['db_fetch_row']($request);

            $total_queries++;
            $smcFunc['db_free_result']($request);
        }

        // We in theory keep doing this... the substeps.
        $done = false;
        while (!$done)
        {
            // Make sure there's at least one ID to test.
            if (isset($test['substeps']) && empty($step_max))
                break;

            // What is the testing query (Changes if we are testing or fixing)
            if (!$do_fix)
                $test_query = 'check_query';
            else
                $test_query = isset($test['fix_query']) ? 'fix_query' : 'check_query';

            // Do the test...
            $request = $smcFunc['db_query']('',
                isset($test['substeps']) ? strtr($test[$test_query], array('{STEP_LOW}' => $_GET['substep'], '{STEP_HIGH}' => $_GET['substep'] + $step_size - 1)) : $test[$test_query],
                array(
                )
            );

            // Does it need a fix?
            if (!empty($test['check_type']) && $test['check_type'] == 'count')
                list ($needs_fix) = $smcFunc['db_fetch_row']($request);
            else
                $needs_fix = $smcFunc['db_num_rows']($request);

            $total_queries++;

            if ($needs_fix)
            {
                // What about a message to the user?
                if (!$do_fix)
                {
                    // Assume need to fix.
                    $found_errors = true;

                    if (isset($test['message']))
                        $context['repair_errors'][] = $txt[$test['message']];

                    // One per row!
                    elseif (isset($test['messages']))
                    {
                        while ($row = $smcFunc['db_fetch_assoc']($request))
                        {
                            $variables = $test['messages'];
                            foreach ($variables as $k => $v)
                            {
                                if ($k == 0 && isset($txt[$v]))
                                    $variables[$k] = $txt[$v];
                                elseif ($k > 0 && isset($row[$v]))
                                    $variables[$k] = $row[$v];
                            }
                            $context['repair_errors'][] = call_user_func_array('sprintf', $variables);
                        }
                    }

                    // A function to process?
                    elseif (isset($test['message_function']))
                    {
                        // Find out if there are actually errors.
                        $found_errors = false;
                        while ($row = $smcFunc['db_fetch_assoc']($request))
                            $found_errors |= $test['message_function']($row);
                    }

                    // Actually have something to fix?
                    if ($found_errors)
                        $to_fix[] = $error_type;
                }

                // We want to fix, we need to fix - so work out what exactly to do!
                else
                {
                    // Are we simply getting a collection of ids?
                    if (isset($test['fix_collect']))
                    {
                        $ids = array();
                        while ($row = $smcFunc['db_fetch_assoc']($request))
                            $ids[] = $row[$test['fix_collect']['index']];
                        if (!empty($ids))
                        {
                            // Fix it!
                            $test['fix_collect']['process']($ids);
                        }
                    }

                    // Simply executing a fix it query?
                    elseif (isset($test['fix_it_query']))
                        $smcFunc['db_query']('',
                            $test['fix_it_query'],
                            array(
                            )
                        );

                    // Do we have some processing to do?
                    elseif (isset($test['fix_processing']))
                    {
                        while ($row = $smcFunc['db_fetch_assoc']($request))
                            $test['fix_processing']($row);
                    }

                    // What about the full set of processing?
                    elseif (isset($test['fix_full_processing']))
                        $test['fix_full_processing']($request);

                    // Do we have other things we need to fix as a result?
                    if (!empty($test['force_fix']))
                    {
                        foreach ($test['force_fix'] as $item)
                            if (!in_array($item, $to_fix))
                                $to_fix[] = $item;
                    }
                }
            }

            // Free the result.
            $smcFunc['db_free_result']($request);
            // Keep memory down.
            $db_cache = array();

            // Are we done yet?
            if (isset($test['substeps']))
            {
                $_GET['substep'] += $step_size;
                // Not done?
                if ($_GET['substep'] <= $step_max)
                {
                    pauseRepairProcess($to_fix, $error_type, $step_max);
                }
                else
                    $done = true;
            }
            else
                $done = true;

            // Don't allow more than 1000 queries at a time.
            if ($total_queries >= 1000)
                pauseRepairProcess($to_fix, $error_type, $step_max, true);
        }

        // Keep going.
        $_GET['step']++;
        $_GET['substep'] = 0;

        $to_fix = array_unique($to_fix);

        // If we're doing fixes and this needed a fix and we're all done then don't do it again.
        if ($do_fix)
        {
            $key = array_search($error_type, $to_fix);
            if ($key !== false && isset($to_fix[$key]))
                unset($to_fix[$key]);
        }

        // Are we done?
        pauseRepairProcess($to_fix, $error_type);
    }

    // Restore the cache.
    $db_cache = $db_temp_cache;

    return $to_fix;
}

/**
 * Create a salvage area for repair purposes, if one doesn't already exist.
 * Uses the forum's default language, and checks based on that name.
 */
function createSalvageArea()
{
    global $txt, $language, $salvageBoardID, $salvageCatID, $smcFunc;
    static $createOnce = false;

    // Have we already created it?
    if ($createOnce)
        return;
    else
        $createOnce = true;

    // Back to the forum's default language.
    loadLanguage('Admin', $language);

    // Check to see if a 'Salvage Category' exists, if not => insert one.
    $result = $smcFunc['db_query']('', '
        SELECT id_cat
        FROM {db_prefix}categories
        WHERE name = {string:cat_name}
        LIMIT 1',
        array(
            'cat_name' => $txt['salvaged_category_name'],
        )
    );
    if ($smcFunc['db_num_rows']($result) != 0)
        list ($salvageCatID) = $smcFunc['db_fetch_row']($result);
    $smcFunc['db_free_result']($result);

    if (empty($salvageCatID))
    {
        $salvageCatID = $smcFunc['db_insert']('',
            '{db_prefix}categories',
            array('name' => 'string-255', 'cat_order' => 'int', 'description' => 'string-255'),
            array($txt['salvaged_category_name'], -1, $txt['salvaged_category_description']),
            array('id_cat'),
            1
        );

        if ($smcFunc['db_affected_rows']() <= 0)
        {
            loadLanguage('Admin');
            fatal_lang_error('salvaged_category_error', false);
        }
    }

    // Check to see if a 'Salvage Board' exists, if not => insert one.
    $result = $smcFunc['db_query']('', '
        SELECT id_board
        FROM {db_prefix}boards
        WHERE id_cat = {int:id_cat}
            AND name = {string:board_name}
        LIMIT 1',
        array(
            'id_cat' => $salvageCatID,
            'board_name' => $txt['salvaged_board_name'],
        )
    );
    if ($smcFunc['db_num_rows']($result) != 0)
        list ($salvageBoardID) = $smcFunc['db_fetch_row']($result);
    $smcFunc['db_free_result']($result);

    if (empty($salvageBoardID))
    {
        $salvageBoardID = $smcFunc['db_insert']('',
            '{db_prefix}boards',
            array('name' => 'string-255', 'description' => 'string-255', 'id_cat' => 'int', 'member_groups' => 'string', 'board_order' => 'int', 'redirect' => 'string'),
            array($txt['salvaged_board_name'], $txt['salvaged_board_description'], $salvageCatID, '1', -1, ''),
            array('id_board'),
            1
        );

        if ($smcFunc['db_affected_rows']() <= 0)
        {
            loadLanguage('Admin');
            fatal_lang_error('salvaged_board_error', false);
        }
    }

    // Restore the user's language.
    loadLanguage('Admin');
}

?>