?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
Update code_sniffer build.xml file to be executable on our system
[phpbb.git] / phpBB / includes / functions_admin.php
blobdee0f82566e9adb8b52c8b2b6d2dd9f3040caaf5
1 <?php
2 /**
3 *
4 * @package acp
5 * @version $Id$
6 * @copyright (c) 2005 phpBB Group
7 * @license http://opensource.org/licenses/gpl-license.php GNU Public License
8 *
9 */
10
11 /**
12 * @ignore
13 */
14 if (!defined('IN_PHPBB'))
15 {
16 exit;
17 }
18
19 /**
20 * Recalculate Binary Tree
21 function recalc_btree($sql_id, $sql_table, $module_class = '')
22 {
23 if (!$sql_id || !$sql_table)
24 {
25 return;
26 }
27
28 $sql_where = ($module_class) ? " WHERE module_class = '" . phpbb::$db->sql_escape($module_class) . "'" : '';
29
30 // Reset to minimum possible left and right id
31 $sql = "SELECT MIN(left_id) as min_left_id, MIN(right_id) as min_right_id
32 FROM $sql_table
33 $sql_where";
34 $result = phpbb::$db->sql_query($sql);
35 $row = phpbb::$db->sql_fetchrow($result);
36 phpbb::$db->sql_freeresult($result);
37
38 $substract = (int) (min($row['min_left_id'], $row['min_right_id']) - 1);
39
40 if ($substract > 0)
41 {
42 $sql = "UPDATE $sql_table
43 SET left_id = left_id - $substract, right_id = right_id - $substract
44 $sql_where";
45 phpbb::$db->sql_query($sql);
46 }
47
48 $sql = "SELECT $sql_id, parent_id, left_id, right_id
49 FROM $sql_table
50 $sql_where
51 ORDER BY left_id ASC, parent_id ASC, $sql_id ASC";
52 $f_result = phpbb::$db->sql_query($sql);
53
54 while ($item_data = phpbb::$db->sql_fetchrow($f_result))
55 {
56 if ($item_data['parent_id'])
57 {
58 $sql = "SELECT left_id, right_id
59 FROM $sql_table
60 $sql_where " . (($sql_where) ? 'AND' : 'WHERE') . "
61 $sql_id = {$item_data['parent_id']}";
62 $result = phpbb::$db->sql_query($sql);
63
64 if (!$row = phpbb::$db->sql_fetchrow($result))
65 {
66 $sql = "UPDATE $sql_table SET parent_id = 0 WHERE $sql_id = " . $item_data[$sql_id];
67 phpbb::$db->sql_query($sql);
68 }
69 phpbb::$db->sql_freeresult($result);
70
71 $sql = "UPDATE $sql_table
72 SET left_id = left_id + 2, right_id = right_id + 2
73 $sql_where " . (($sql_where) ? 'AND' : 'WHERE') . "
74 left_id > {$row['right_id']}";
75 phpbb::$db->sql_query($sql);
76
77 $sql = "UPDATE $sql_table
78 SET right_id = right_id + 2
79 $sql_where " . (($sql_where) ? 'AND' : 'WHERE') . "
80 {$row['left_id']} BETWEEN left_id AND right_id";
81 phpbb::$db->sql_query($sql);
82
83 $item_data['left_id'] = $row['right_id'];
84 $item_data['right_id'] = $row['right_id'] + 1;
85 }
86 else
87 {
88 $sql = "SELECT MAX(right_id) AS right_id
89 FROM $sql_table
90 $sql_where";
91 $result = phpbb::$db->sql_query($sql);
92 $row = phpbb::$db->sql_fetchrow($result);
93 phpbb::$db->sql_freeresult($result);
94
95 $item_data['left_id'] = $row['right_id'] + 1;
96 $item_data['right_id'] = $row['right_id'] + 2;
97 }
98
99 $sql = "UPDATE $sql_table
100 SET left_id = {$item_data['left_id']}, right_id = {$item_data['right_id']}
101 WHERE $sql_id = " . $item_data[$sql_id];
102 phpbb::$db->sql_query($sql);
103 }
104 phpbb::$db->sql_freeresult($f_result);
105 }
106 */
107
108 /**
109 * Simple version of jumpbox, just lists authed forums
110 */
111 function make_forum_select($select_id = false, $ignore_id = false, $ignore_acl = false, $ignore_nonpost = false, $ignore_emptycat = true, $only_acl_post = false, $return_array = false)
112 {
113 $acl = ($ignore_acl) ? '' : (($only_acl_post) ? 'f_post' : array('f_list', 'a_forum', 'a_forumadd', 'a_forumdel'));
114
115 // This query is identical to the jumpbox one
116 $sql = 'SELECT forum_id, forum_name, parent_id, forum_type, left_id, right_id
117 FROM ' . FORUMS_TABLE . '
118 ORDER BY left_id ASC';
119 $result = phpbb::$db->sql_query($sql, 600);
120
121 $right = 0;
122 $padding_store = array('0' => '');
123 $padding = '';
124 $forum_list = ($return_array) ? array() : '';
125
126 // Sometimes it could happen that forums will be displayed here not be displayed within the index page
127 // This is the result of forums not displayed at index, having list permissions and a parent of a forum with no permissions.
128 // If this happens, the padding could be "broken"
129
130 while ($row = phpbb::$db->sql_fetchrow($result))
131 {
132 if ($row['left_id'] < $right)
133 {
134 $padding .= '&nbsp; &nbsp;';
135 $padding_store[$row['parent_id']] = $padding;
136 }
137 else if ($row['left_id'] > $right + 1)
138 {
139 $padding = (isset($padding_store[$row['parent_id']])) ? $padding_store[$row['parent_id']] : '';
140 }
141
142 $right = $row['right_id'];
143 $disabled = false;
144
145 if ($acl && !phpbb::$acl->acl_gets($acl, $row['forum_id']))
146 {
147 // List permission?
148 if (phpbb::$acl->acl_get('f_list', $row['forum_id']))
149 {
150 $disabled = true;
151 }
152 else
153 {
154 continue;
155 }
156 }
157
158 if (
159 ((is_array($ignore_id) && in_array($row['forum_id'], $ignore_id)) || $row['forum_id'] == $ignore_id)
160 ||
161 // Non-postable forum with no subforums, don't display
162 ($row['forum_type'] == FORUM_CAT && ($row['left_id'] + 1 == $row['right_id']) && $ignore_emptycat)
163 ||
164 ($row['forum_type'] != FORUM_POST && $ignore_nonpost)
165 )
166 {
167 $disabled = true;
168 }
169
170 if ($return_array)
171 {
172 // Include some more information...
173 $selected = (is_array($select_id)) ? ((in_array($row['forum_id'], $select_id)) ? true : false) : (($row['forum_id'] == $select_id) ? true : false);
174 $forum_list[$row['forum_id']] = array_merge(array('padding' => $padding, 'selected' => ($selected && !$disabled), 'disabled' => $disabled), $row);
175 }
176 else
177 {
178 $selected = (is_array($select_id)) ? ((in_array($row['forum_id'], $select_id)) ? ' selected="selected"' : '') : (($row['forum_id'] == $select_id) ? ' selected="selected"' : '');
179 $forum_list .= '<option value="' . $row['forum_id'] . '"' . (($disabled) ? ' disabled="disabled" class="disabled-option"' : $selected) . '>' . $padding . $row['forum_name'] . '</option>';
180 }
181 }
182 phpbb::$db->sql_freeresult($result);
183 unset($padding_store);
184
185 return $forum_list;
186 }
187
188 /**
189 * Generate size select options
190 */
191 function size_select_options($size_compare)
192 {
193 $size_types_text = array(phpbb::$user->lang['BYTES'], phpbb::$user->lang['KIB'], phpbb::$user->lang['MIB']);
194 $size_types = array('b', 'kb', 'mb');
195
196 $s_size_options = '';
197
198 for ($i = 0, $size = sizeof($size_types_text); $i < $size; $i++)
199 {
200 $selected = ($size_compare == $size_types[$i]) ? ' selected="selected"' : '';
201 $s_size_options .= '<option value="' . $size_types[$i] . '"' . $selected . '>' . $size_types_text[$i] . '</option>';
202 }
203
204 return $s_size_options;
205 }
206
207 /**
208 * Generate list of groups (option fields without select)
209 *
210 * @param int $group_id The default group id to mark as selected
211 * @param array $exclude_ids The group ids to exclude from the list, false (default) if you whish to exclude no id
212 * @param int $manage_founder If set to false (default) all groups are returned, if 0 only those groups returned not being managed by founders only, if 1 only those groups returned managed by founders only.
213 *
214 * @return string The list of options.
215 */
216 function group_select_options($group_id, $exclude_ids = false, $manage_founder = false)
217 {
218 $exclude_sql = ($exclude_ids !== false && sizeof($exclude_ids)) ? 'WHERE ' . phpbb::$db->sql_in_set('group_id', array_map('intval', $exclude_ids), true) : '';
219 $sql_and = (!phpbb::$config['coppa_enable']) ? (($exclude_sql) ? ' AND ' : ' WHERE ') . "group_name <> 'REGISTERED_COPPA'" : '';
220 $sql_founder = ($manage_founder !== false) ? (($exclude_sql || $sql_and) ? ' AND ' : ' WHERE ') . 'group_founder_manage = ' . (int) $manage_founder : '';
221
222 $sql = 'SELECT group_id, group_name, group_type
223 FROM ' . GROUPS_TABLE . "
224 $exclude_sql
225 $sql_and
226 $sql_founder
227 ORDER BY group_type DESC, group_name ASC";
228 $result = phpbb::$db->sql_query($sql);
229
230 $s_group_options = '';
231 while ($row = phpbb::$db->sql_fetchrow($result))
232 {
233 $selected = ($row['group_id'] == $group_id) ? ' selected="selected"' : '';
234 $s_group_options .= '<option' . (($row['group_type'] == GROUP_SPECIAL) ? ' class="sep"' : '') . ' value="' . $row['group_id'] . '"' . $selected . '>' . (($row['group_type'] == GROUP_SPECIAL) ? phpbb::$user->lang['G_' . $row['group_name']] : $row['group_name']) . '</option>';
235 }
236 phpbb::$db->sql_freeresult($result);
237
238 return $s_group_options;
239 }
240
241 /**
242 * Obtain authed forums list
243 */
244 function get_forum_list($acl_list = 'f_list', $id_only = true, $postable_only = false, $no_cache = false)
245 {
246 static $forum_rows;
247
248 if (!isset($forum_rows))
249 {
250 // This query is identical to the jumpbox one
251 $expire_time = ($no_cache) ? 0 : 600;
252
253 $sql = 'SELECT forum_id, forum_name, parent_id, forum_type, left_id, right_id
254 FROM ' . FORUMS_TABLE . '
255 ORDER BY left_id ASC';
256 $result = phpbb::$db->sql_query($sql, $expire_time);
257
258 $forum_rows = array();
259
260 $right = $padding = 0;
261 $padding_store = array('0' => 0);
262
263 while ($row = phpbb::$db->sql_fetchrow($result))
264 {
265 if ($row['left_id'] < $right)
266 {
267 $padding++;
268 $padding_store[$row['parent_id']] = $padding;
269 }
270 else if ($row['left_id'] > $right + 1)
271 {
272 // Ok, if the $padding_store for this parent is empty there is something wrong. For now we will skip over it.
273 // @todo digging deep to find out "how" this can happen.
274 $padding = (isset($padding_store[$row['parent_id']])) ? $padding_store[$row['parent_id']] : $padding;
275 }
276
277 $right = $row['right_id'];
278 $row['padding'] = $padding;
279
280 $forum_rows[] = $row;
281 }
282 phpbb::$db->sql_freeresult($result);
283 unset($padding_store);
284 }
285
286 $rowset = array();
287 foreach ($forum_rows as $row)
288 {
289 if ($postable_only && $row['forum_type'] != FORUM_POST)
290 {
291 continue;
292 }
293
294 if ($acl_list == '' || ($acl_list != '' && phpbb::$acl->acl_gets($acl_list, $row['forum_id'])))
295 {
296 $rowset[] = ($id_only) ? $row['forum_id'] : $row;
297 }
298 }
299
300 return $rowset;
301 }
302
303 /**
304 * Get forum branch
305 */
306 function get_forum_branch($forum_id, $type = 'all', $order = 'descending', $include_forum = true)
307 {
308 switch ($type)
309 {
310 case 'parents':
311 $condition = 'f1.left_id BETWEEN f2.left_id AND f2.right_id';
312 break;
313
314 case 'children':
315 $condition = 'f2.left_id BETWEEN f1.left_id AND f1.right_id';
316 break;
317
318 default:
319 $condition = 'f2.left_id BETWEEN f1.left_id AND f1.right_id OR f1.left_id BETWEEN f2.left_id AND f2.right_id';
320 break;
321 }
322
323 $rows = array();
324
325 $sql = 'SELECT f2.*
326 FROM ' . FORUMS_TABLE . ' f1
327 LEFT JOIN ' . FORUMS_TABLE . " f2 ON ($condition)
328 WHERE f1.forum_id = $forum_id
329 ORDER BY f2.left_id " . (($order == 'descending') ? 'ASC' : 'DESC');
330 $result = phpbb::$db->sql_query($sql);
331
332 while ($row = phpbb::$db->sql_fetchrow($result))
333 {
334 if (!$include_forum && $row['forum_id'] == $forum_id)
335 {
336 continue;
337 }
338
339 $rows[] = $row;
340 }
341 phpbb::$db->sql_freeresult($result);
342
343 return $rows;
344 }
345
346 /**
347 * Get physical file listing
348 */
349 function filelist($rootdir, $dir = '', $type = 'gif|jpg|jpeg|png')
350 {
351 $matches = array();
352
353 // Remove initial / if present
354 $rootdir = (substr($rootdir, 0, 1) == '/') ? substr($rootdir, 1) : $rootdir;
355 // Add closing / if not present
356 $rootdir = ($rootdir && substr($rootdir, -1) != '/') ? $rootdir . '/' : $rootdir;
357
358 // Remove initial / if present
359 $dir = (substr($dir, 0, 1) == '/') ? substr($dir, 1) : $dir;
360 // Add closing / if not present
361 $dir = ($dir && substr($dir, -1) != '/') ? $dir . '/' : $dir;
362
363 if (!is_dir($rootdir . $dir))
364 {
365 return $matches;
366 }
367
368 $dh = @opendir($rootdir . $dir);
369
370 if (!$dh)
371 {
372 return $matches;
373 }
374
375 while (($fname = readdir($dh)) !== false)
376 {
377 if (is_file("$rootdir$dir$fname"))
378 {
379 if (filesize("$rootdir$dir$fname") && preg_match('#\.' . $type . '$#i', $fname))
380 {
381 $matches[$dir][] = $fname;
382 }
383 }
384 else if ($fname[0] != '.' && is_dir("$rootdir$dir$fname"))
385 {
386 $matches += filelist($rootdir, "$dir$fname", $type);
387 }
388 }
389 closedir($dh);
390
391 return $matches;
392 }
393
394 /**
395 * Move topic(s)
396 */
397 function move_topics($topic_ids, $forum_id, $auto_sync = true)
398 {
399 if (empty($topic_ids))
400 {
401 return;
402 }
403
404 $forum_ids = array($forum_id);
405
406 if (!is_array($topic_ids))
407 {
408 $topic_ids = array($topic_ids);
409 }
410
411 $sql = 'DELETE FROM ' . TOPICS_TABLE . '
412 WHERE ' . phpbb::$db->sql_in_set('topic_moved_id', $topic_ids) . '
413 AND forum_id = ' . $forum_id;
414 phpbb::$db->sql_query($sql);
415
416 if ($auto_sync)
417 {
418 $sql = 'SELECT DISTINCT forum_id
419 FROM ' . TOPICS_TABLE . '
420 WHERE ' . phpbb::$db->sql_in_set('topic_id', $topic_ids);
421 $result = phpbb::$db->sql_query($sql);
422
423 while ($row = phpbb::$db->sql_fetchrow($result))
424 {
425 $forum_ids[] = $row['forum_id'];
426 }
427 phpbb::$db->sql_freeresult($result);
428 }
429
430 $table_ary = array(TOPICS_TABLE, POSTS_TABLE, LOG_TABLE, DRAFTS_TABLE, TOPICS_TRACK_TABLE);
431 foreach ($table_ary as $table)
432 {
433 $sql = "UPDATE $table
434 SET forum_id = $forum_id
435 WHERE " . phpbb::$db->sql_in_set('topic_id', $topic_ids);
436 phpbb::$db->sql_query($sql);
437 }
438 unset($table_ary);
439
440 if ($auto_sync)
441 {
442 sync('forum', 'forum_id', $forum_ids, true, true);
443 unset($forum_ids);
444 }
445 }
446
447 /**
448 * Move post(s)
449 */
450 function move_posts($post_ids, $topic_id, $auto_sync = true)
451 {
452 if (!is_array($post_ids))
453 {
454 $post_ids = array($post_ids);
455 }
456
457 $forum_ids = array();
458 $topic_ids = array($topic_id);
459
460 $sql = 'SELECT DISTINCT topic_id, forum_id
461 FROM ' . POSTS_TABLE . '
462 WHERE ' . phpbb::$db->sql_in_set('post_id', $post_ids);
463 $result = phpbb::$db->sql_query($sql);
464
465 while ($row = phpbb::$db->sql_fetchrow($result))
466 {
467 $forum_ids[] = $row['forum_id'];
468 $topic_ids[] = $row['topic_id'];
469 }
470 phpbb::$db->sql_freeresult($result);
471
472 $sql = 'SELECT forum_id
473 FROM ' . TOPICS_TABLE . '
474 WHERE topic_id = ' . $topic_id;
475 $result = phpbb::$db->sql_query($sql);
476 $forum_row = phpbb::$db->sql_fetchrow($result);
477 phpbb::$db->sql_freeresult($result);
478
479 if (!$forum_row)
480 {
481 trigger_error('NO_TOPIC');
482 }
483
484 $sql = 'UPDATE ' . POSTS_TABLE . '
485 SET forum_id = ' . $forum_row['forum_id'] . ", topic_id = $topic_id
486 WHERE " . phpbb::$db->sql_in_set('post_id', $post_ids);
487 phpbb::$db->sql_query($sql);
488
489 $sql = 'UPDATE ' . ATTACHMENTS_TABLE . "
490 SET topic_id = $topic_id, in_message = 0
491 WHERE " . phpbb::$db->sql_in_set('post_msg_id', $post_ids);
492 phpbb::$db->sql_query($sql);
493
494 if ($auto_sync)
495 {
496 $forum_ids[] = $forum_row['forum_id'];
497
498 sync('topic_reported', 'topic_id', $topic_ids);
499 sync('topic_attachment', 'topic_id', $topic_ids);
500 sync('topic', 'topic_id', $topic_ids, true);
501 sync('forum', 'forum_id', $forum_ids, true, true);
502 }
503
504 // Update posted information
505 update_posted_info($topic_ids);
506 }
507
508 /**
509 * Remove topic(s)
510 */
511 function delete_topics($where_type, $where_ids, $auto_sync = true, $post_count_sync = true, $call_delete_posts = true)
512 {
513 $approved_topics = 0;
514 $forum_ids = $topic_ids = array();
515
516 if ($where_type === 'range')
517 {
518 $where_clause = $where_ids;
519 }
520 else
521 {
522 $where_ids = (is_array($where_ids)) ? array_unique($where_ids) : array($where_ids);
523
524 if (!sizeof($where_ids))
525 {
526 return array('topics' => 0, 'posts' => 0);
527 }
528
529 $where_clause = phpbb::$db->sql_in_set($where_type, $where_ids);
530 }
531
532 // Making sure that delete_posts does not call delete_topics again...
533 $return = array(
534 'posts' => ($call_delete_posts) ? delete_posts($where_type, $where_ids, false, true, $post_count_sync, false) : 0,
535 );
536
537 $sql = 'SELECT topic_id, forum_id, topic_approved, topic_moved_id
538 FROM ' . TOPICS_TABLE . '
539 WHERE ' . $where_clause;
540 $result = phpbb::$db->sql_query($sql);
541
542 while ($row = phpbb::$db->sql_fetchrow($result))
543 {
544 $forum_ids[] = $row['forum_id'];
545 $topic_ids[] = $row['topic_id'];
546
547 if ($row['topic_approved'] && !$row['topic_moved_id'])
548 {
549 $approved_topics++;
550 }
551 }
552 phpbb::$db->sql_freeresult($result);
553
554 $return['topics'] = sizeof($topic_ids);
555
556 if (!sizeof($topic_ids))
557 {
558 return $return;
559 }
560
561 phpbb::$db->sql_transaction('begin');
562
563 $table_ary = array(TOPICS_TRACK_TABLE, TOPICS_POSTED_TABLE, POLL_VOTES_TABLE, POLL_OPTIONS_TABLE, TOPICS_WATCH_TABLE, TOPICS_TABLE);
564
565 foreach ($table_ary as $table)
566 {
567 $sql = "DELETE FROM $table
568 WHERE " . phpbb::$db->sql_in_set('topic_id', $topic_ids);
569 phpbb::$db->sql_query($sql);
570 }
571 unset($table_ary);
572
573 $moved_topic_ids = array();
574
575 // update the other forums
576 $sql = 'SELECT topic_id, forum_id
577 FROM ' . TOPICS_TABLE . '
578 WHERE ' . phpbb::$db->sql_in_set('topic_moved_id', $topic_ids);
579 $result = phpbb::$db->sql_query($sql);
580
581 while ($row = phpbb::$db->sql_fetchrow($result))
582 {
583 $forum_ids[] = $row['forum_id'];
584 $moved_topic_ids[] = $row['topic_id'];
585 }
586 phpbb::$db->sql_freeresult($result);
587
588 if (sizeof($moved_topic_ids))
589 {
590 $sql = 'DELETE FROM ' . TOPICS_TABLE . '
591 WHERE ' . phpbb::$db->sql_in_set('topic_id', $moved_topic_ids);
592 phpbb::$db->sql_query($sql);
593 }
594
595 phpbb::$db->sql_transaction('commit');
596
597 if ($auto_sync)
598 {
599 sync('forum', 'forum_id', array_unique($forum_ids), true, true);
600 sync('topic_reported', $where_type, $where_ids);
601 }
602
603 if ($approved_topics)
604 {
605 set_config_count('num_topics', $approved_topics * (-1), true);
606 }
607
608 return $return;
609 }
610
611 /**
612 * Remove post(s)
613 */
614 function delete_posts($where_type, $where_ids, $auto_sync = true, $posted_sync = true, $post_count_sync = true, $call_delete_topics = true)
615 {
616 if ($where_type === 'range')
617 {
618 $where_clause = $where_ids;
619 }
620 else
621 {
622 if (is_array($where_ids))
623 {
624 $where_ids = array_unique($where_ids);
625 }
626 else
627 {
628 $where_ids = array($where_ids);
629 }
630
631 if (!sizeof($where_ids))
632 {
633 return false;
634 }
635
636 $where_ids = array_map('intval', $where_ids);
637
638 // Split post deletion into chunks to overcome database limitations
639 if (sizeof($where_ids) >= 1001)
640 {
641 // Split into chunks of 1000
642 $chunks = array_chunk($where_ids, 1000);
643 $removed_posts = 0;
644
645 foreach ($chunks as $_where_ids)
646 {
647 $removed_posts += delete_posts($where_type, $_where_ids, $auto_sync, $posted_sync, $post_count_sync, $call_delete_topics);
648 }
649
650 return $removed_posts;
651 }
652
653 $where_clause = phpbb::$db->sql_in_set($where_type, $where_ids);
654 }
655
656 $approved_posts = 0;
657 $post_ids = $topic_ids = $forum_ids = $post_counts = $remove_topics = array();
658
659 $sql = 'SELECT post_id, poster_id, post_approved, post_postcount, topic_id, forum_id
660 FROM ' . POSTS_TABLE . '
661 WHERE ' . $where_clause;
662 $result = phpbb::$db->sql_query($sql);
663
664 while ($row = phpbb::$db->sql_fetchrow($result))
665 {
666 $post_ids[] = (int) $row['post_id'];
667 $poster_ids[] = (int) $row['poster_id'];
668 $topic_ids[] = (int) $row['topic_id'];
669 $forum_ids[] = (int) $row['forum_id'];
670
671 if ($row['post_postcount'] && $post_count_sync && $row['post_approved'])
672 {
673 $post_counts[$row['poster_id']] = (!empty($post_counts[$row['poster_id']])) ? $post_counts[$row['poster_id']] + 1 : 1;
674 }
675
676 if ($row['post_approved'])
677 {
678 $approved_posts++;
679 }
680 }
681 phpbb::$db->sql_freeresult($result);
682
683 if (!sizeof($post_ids))
684 {
685 return false;
686 }
687
688 phpbb::$db->sql_transaction('begin');
689
690 $table_ary = array(POSTS_TABLE, REPORTS_TABLE);
691
692 foreach ($table_ary as $table)
693 {
694 $sql = "DELETE FROM $table
695 WHERE " . phpbb::$db->sql_in_set('post_id', $post_ids);
696 phpbb::$db->sql_query($sql);
697 }
698 unset($table_ary);
699
700 // Adjust users post counts
701 if (sizeof($post_counts) && $post_count_sync)
702 {
703 foreach ($post_counts as $poster_id => $substract)
704 {
705 $sql = 'UPDATE ' . USERS_TABLE . '
706 SET user_posts = 0
707 WHERE user_id = ' . $poster_id . '
708 AND user_posts < ' . $substract;
709 phpbb::$db->sql_query($sql);
710
711 $sql = 'UPDATE ' . USERS_TABLE . '
712 SET user_posts = user_posts - ' . $substract . '
713 WHERE user_id = ' . $poster_id . '
714 AND user_posts >= ' . $substract;
715 phpbb::$db->sql_query($sql);
716 }
717 }
718
719 // Remove topics now having no posts?
720 if (sizeof($topic_ids))
721 {
722 $sql = 'SELECT topic_id
723 FROM ' . POSTS_TABLE . '
724 WHERE ' . phpbb::$db->sql_in_set('topic_id', $topic_ids) . '
725 GROUP BY topic_id';
726 $result = phpbb::$db->sql_query($sql);
727
728 while ($row = phpbb::$db->sql_fetchrow($result))
729 {
730 $remove_topics[] = $row['topic_id'];
731 }
732 phpbb::$db->sql_freeresult($result);
733
734 // Actually, those not within remove_topics should be removed. ;)
735 $remove_topics = array_diff($topic_ids, $remove_topics);
736 }
737
738 // Remove the message from the search index
739 $search_type = basename(phpbb::$config['search_type']);
740
741 if (!file_exists(PHPBB_ROOT_PATH . 'includes/search/' . $search_type . '.' . PHP_EXT))
742 {
743 trigger_error('NO_SUCH_SEARCH_MODULE');
744 }
745
746 include_once(PHPBB_ROOT_PATH . "includes/search/$search_type." . PHP_EXT);
747
748 $error = false;
749 $search = new $search_type($error);
750
751 if ($error)
752 {
753 trigger_error($error);
754 }
755
756 $search->index_remove($post_ids, $poster_ids, $forum_ids);
757
758 delete_attachments('post', $post_ids, false);
759
760 phpbb::$db->sql_transaction('commit');
761
762 // Resync topics_posted table
763 if ($posted_sync)
764 {
765 update_posted_info($topic_ids);
766 }
767
768 if ($auto_sync)
769 {
770 sync('topic_reported', 'topic_id', $topic_ids);
771 sync('topic', 'topic_id', $topic_ids, true);
772 sync('forum', 'forum_id', $forum_ids, true, true);
773 }
774
775 if ($approved_posts)
776 {
777 set_config_count('num_posts', $approved_posts * (-1), true);
778 }
779
780 // We actually remove topics now to not be inconsistent (the delete_topics function calls this function too)
781 if (sizeof($remove_topics) && $call_delete_topics)
782 {
783 delete_topics('topic_id', $remove_topics, $auto_sync, $post_count_sync, false);
784 }
785
786 return sizeof($post_ids);
787 }
788
789 /**
790 * Delete Attachments
791 *
792 * @param string $mode can be: post|message|topic|attach|user
793 * @param mixed $ids can be: post_ids, message_ids, topic_ids, attach_ids, user_ids
794 * @param bool $resync set this to false if you are deleting posts or topics
795 */
796 function delete_attachments($mode, $ids, $resync = true)
797 {
798 if (is_array($ids) && sizeof($ids))
799 {
800 $ids = array_unique($ids);
801 $ids = array_map('intval', $ids);
802 }
803 else
804 {
805 $ids = array((int) $ids);
806 }
807
808 if (!sizeof($ids))
809 {
810 return false;
811 }
812
813 $sql_where = '';
814
815 switch ($mode)
816 {
817 case 'post':
818 case 'message':
819 $sql_id = 'post_msg_id';
820 $sql_where = ' AND in_message = ' . ($mode == 'message' ? 1 : 0);
821 break;
822
823 case 'topic':
824 $sql_id = 'topic_id';
825 break;
826
827 case 'user':
828 $sql_id = 'poster_id';
829 break;
830
831 case 'attach':
832 default:
833 $sql_id = 'attach_id';
834 $mode = 'attach';
835 break;
836 }
837
838 $post_ids = $message_ids = $topic_ids = $physical = array();
839
840 // Collect post and topic ids for later use if we need to touch remaining entries (if resync is enabled)
841 $sql = 'SELECT post_msg_id, topic_id, in_message, physical_filename, thumbnail, filesize, is_orphan
842 FROM ' . ATTACHMENTS_TABLE . '
843 WHERE ' . phpbb::$db->sql_in_set($sql_id, $ids);
844
845 $sql .= $sql_where;
846
847 $result = phpbb::$db->sql_query($sql);
848
849 while ($row = phpbb::$db->sql_fetchrow($result))
850 {
851 // We only need to store post/message/topic ids if resync is enabled and the file is not orphaned
852 if ($resync && !$row['is_orphan'])
853 {
854 if (!$row['in_message'])
855 {
856 $post_ids[] = $row['post_msg_id'];
857 $topic_ids[] = $row['topic_id'];
858 }
859 else
860 {
861 $message_ids[] = $row['post_msg_id'];
862 }
863 }
864
865 $physical[] = array('filename' => $row['physical_filename'], 'thumbnail' => $row['thumbnail'], 'filesize' => $row['filesize'], 'is_orphan' => $row['is_orphan']);
866 }
867 phpbb::$db->sql_freeresult($result);
868
869 // Delete attachments
870 $sql = 'DELETE FROM ' . ATTACHMENTS_TABLE . '
871 WHERE ' . phpbb::$db->sql_in_set($sql_id, $ids);
872
873 $sql .= $sql_where;
874
875 phpbb::$db->sql_query($sql);
876 $num_deleted = phpbb::$db->sql_affectedrows();
877
878 if (!$num_deleted)
879 {
880 return 0;
881 }
882
883 // Delete attachments from filesystem
884 $space_removed = $files_removed = 0;
885 foreach ($physical as $file_ary)
886 {
887 if (phpbb_unlink($file_ary['filename'], 'file', true) && !$file_ary['is_orphan'])
888 {
889 // Only non-orphaned files count to the file size
890 $space_removed += $file_ary['filesize'];
891 $files_removed++;
892 }
893
894 if ($file_ary['thumbnail'])
895 {
896 phpbb_unlink($file_ary['filename'], 'thumbnail', true);
897 }
898 }
899
900 if ($space_removed || $files_removed)
901 {
902 set_config_count('upload_dir_size', $space_removed * (-1), true);
903 set_config_count('num_files', $files_removed * (-1), true);
904 }
905
906 // If we do not resync, we do not need to adjust any message, post, topic or user entries
907 if (!$resync)
908 {
909 return $num_deleted;
910 }
911
912 // No more use for the original ids
913 unset($ids);
914
915 // Now, we need to resync posts, messages, topics. We go through every one of them
916 $post_ids = array_unique($post_ids);
917 $message_ids = array_unique($message_ids);
918 $topic_ids = array_unique($topic_ids);
919
920 // Update post indicators for posts now no longer having attachments
921 if (sizeof($post_ids))
922 {
923 $sql = 'UPDATE ' . POSTS_TABLE . '
924 SET post_attachment = 0
925 WHERE ' . phpbb::$db->sql_in_set('post_id', $post_ids);
926 phpbb::$db->sql_query($sql);
927 }
928
929 // Update message table if messages are affected
930 if (sizeof($message_ids))
931 {
932 $sql = 'UPDATE ' . PRIVMSGS_TABLE . '
933 SET message_attachment = 0
934 WHERE ' . phpbb::$db->sql_in_set('msg_id', $message_ids);
935 phpbb::$db->sql_query($sql);
936 }
937
938 // Now update the topics. This is a bit trickier, because there could be posts still having attachments within the topic
939 if (sizeof($topic_ids))
940 {
941 // Just check which topics are still having an assigned attachment not orphaned by querying the attachments table (much less entries expected)
942 $sql = 'SELECT topic_id
943 FROM ' . ATTACHMENTS_TABLE . '
944 WHERE ' . phpbb::$db->sql_in_set('topic_id', $topic_ids) . '
945 AND is_orphan = 0';
946 $result = phpbb::$db->sql_query($sql);
947
948 $remaining_ids = array();
949 while ($row = phpbb::$db->sql_fetchrow($result))
950 {
951 $remaining_ids[] = $row['topic_id'];
952 }
953 phpbb::$db->sql_freeresult($result);
954
955 // Now only unset those ids remaining
956 $topic_ids = array_diff($topic_ids, $remaining_ids);
957
958 if (sizeof($topic_ids))
959 {
960 $sql = 'UPDATE ' . TOPICS_TABLE . '
961 SET topic_attachment = 0
962 WHERE ' . phpbb::$db->sql_in_set('topic_id', $topic_ids);
963 phpbb::$db->sql_query($sql);
964 }
965 }
966
967 return $num_deleted;
968 }
969
970 /**
971 * Remove topic shadows
972 */
973 function delete_topic_shadows($max_age, $forum_id = '', $auto_sync = true)
974 {
975 $where = (is_array($forum_id)) ? 'AND ' . phpbb::$db->sql_in_set('t.forum_id', array_map('intval', $forum_id)) : (($forum_id) ? 'AND t.forum_id = ' . (int) $forum_id : '');
976
977 if (phpbb::$db->features['multi_table_deletion'])
978 {
979 $sql = 'DELETE FROM ' . TOPICS_TABLE . ' t
980 USING ' . TOPICS_TABLE . ' t2
981 WHERE t.topic_moved_id = t2.topic_id
982 AND t.topic_time < ' . (time() - $max_age)
983 . $where;
984 phpbb::$db->sql_query($sql);
985 }
986 else
987 {
988 $sql = 'SELECT t.topic_id
989 FROM ' . TOPICS_TABLE . ' t, ' . TOPICS_TABLE . ' t2
990 WHERE t.topic_moved_id = t2.topic_id
991 AND t.topic_time < ' . (time() - $max_age)
992 . $where;
993 $result = phpbb::$db->sql_query($sql);
994
995 $topic_ids = array();
996 while ($row = phpbb::$db->sql_fetchrow($result))
997 {
998 $topic_ids[] = $row['topic_id'];
999 }
1000 phpbb::$db->sql_freeresult($result);
1001
1002 if (sizeof($topic_ids))
1003 {
1004 $sql = 'DELETE FROM ' . TOPICS_TABLE . '
1005 WHERE ' . phpbb::$db->sql_in_set('topic_id', $topic_ids);
1006 phpbb::$db->sql_query($sql);
1007 }
1008 }
1009
1010 if ($auto_sync)
1011 {
1012 $where_type = ($forum_id) ? 'forum_id' : '';
1013 sync('forum', $where_type, $forum_id, true, true);
1014 }
1015 }
1016
1017 /**
1018 * Update/Sync posted information for topics
1019 */
1020 function update_posted_info(&$topic_ids)
1021 {
1022 if (empty($topic_ids) || !phpbb::$config['load_db_track'])
1023 {
1024 return;
1025 }
1026
1027 // First of all, let us remove any posted information for these topics
1028 $sql = 'DELETE FROM ' . TOPICS_POSTED_TABLE . '
1029 WHERE ' . phpbb::$db->sql_in_set('topic_id', $topic_ids);
1030 phpbb::$db->sql_query($sql);
1031
1032 // Now, let us collect the user/topic combos for rebuilding the information
1033 $sql = 'SELECT poster_id, topic_id
1034 FROM ' . POSTS_TABLE . '
1035 WHERE ' . phpbb::$db->sql_in_set('topic_id', $topic_ids) . '
1036 AND poster_id <> ' . ANONYMOUS . '
1037 GROUP BY poster_id, topic_id';
1038 $result = phpbb::$db->sql_query($sql);
1039
1040 $posted = array();
1041 while ($row = phpbb::$db->sql_fetchrow($result))
1042 {
1043 // Add as key to make them unique (grouping by) and circumvent empty keys on array_unique
1044 $posted[$row['poster_id']][] = $row['topic_id'];
1045 }
1046 phpbb::$db->sql_freeresult($result);
1047
1048 // Now add the information...
1049 $sql_ary = array();
1050 foreach ($posted as $user_id => $topic_row)
1051 {
1052 foreach ($topic_row as $topic_id)
1053 {
1054 $sql_ary[] = array(
1055 'user_id' => (int) $user_id,
1056 'topic_id' => (int) $topic_id,
1057 'topic_posted' => 1,
1058 );
1059 }
1060 }
1061 unset($posted);
1062
1063 phpbb::$db->sql_multi_insert(TOPICS_POSTED_TABLE, $sql_ary);
1064 }
1065
1066 /**
1067 * Delete attached file
1068 */
1069 function phpbb_unlink($filename, $mode = 'file', $entry_removed = false)
1070 {
1071 // Because of copying topics or modifications a physical filename could be assigned more than once. If so, do not remove the file itself.
1072 $sql = 'SELECT COUNT(attach_id) AS num_entries
1073 FROM ' . ATTACHMENTS_TABLE . "
1074 WHERE physical_filename = '" . phpbb::$db->sql_escape(basename($filename)) . "'";
1075 $result = phpbb::$db->sql_query($sql);
1076 $num_entries = (int) phpbb::$db->sql_fetchfield('num_entries');
1077 phpbb::$db->sql_freeresult($result);
1078
1079 // Do not remove file if at least one additional entry with the same name exist.
1080 if (($entry_removed && $num_entries > 0) || (!$entry_removed && $num_entries > 1))
1081 {
1082 return false;
1083 }
1084
1085 $filename = ($mode == 'thumbnail') ? 'thumb_' . basename($filename) : basename($filename);
1086 return @unlink(PHPBB_ROOT_PATH . phpbb::$config['upload_path'] . '/' . $filename);
1087 }
1088
1089 /**
1090 * All-encompasing sync function
1091 *
1092 * Exaples:
1093 * <code>
1094 * sync('topic', 'topic_id', 123); // resync topic #123
1095 * sync('topic', 'forum_id', array(2, 3)); // resync topics from forum #2 and #3
1096 * sync('topic'); // resync all topics
1097 * sync('topic', 'range', 'topic_id BETWEEN 1 AND 60'); // resync a range of topics/forums (only available for 'topic' and 'forum' modes)
1098 * </code>
1099 *
1100 * Modes:
1101 * - forum Resync complete forum
1102 * - topic Resync topics
1103 * - topic_moved Removes topic shadows that would be in the same forum as the topic they link to
1104 * - topic_approved Resyncs the topic_approved flag according to the status of the first post
1105 * - post_reported Resyncs the post_reported flag, relying on actual reports
1106 * - topic_reported Resyncs the topic_reported flag, relying on post_reported flags
1107 * - post_attachement Same as post_reported, but with attachment flags
1108 * - topic_attachement Same as topic_reported, but with attachment flags
1109 */
1110 function sync($mode, $where_type = '', $where_ids = '', $resync_parents = false, $sync_extra = false)
1111 {
1112 if (is_array($where_ids))
1113 {
1114 $where_ids = array_unique($where_ids);
1115 $where_ids = array_map('intval', $where_ids);
1116 }
1117 else if ($where_type != 'range')
1118 {
1119 $where_ids = ($where_ids) ? array((int) $where_ids) : array();
1120 }
1121
1122 if ($mode == 'forum' || $mode == 'topic' || $mode == 'topic_approved' || $mode == 'topic_reported' || $mode == 'post_reported')
1123 {
1124 if (!$where_type)
1125 {
1126 $where_sql = '';
1127 $where_sql_and = 'WHERE';
1128 }
1129 else if ($where_type == 'range')
1130 {
1131 // Only check a range of topics/forums. For instance: 'topic_id BETWEEN 1 AND 60'
1132 $where_sql = 'WHERE (' . $mode[0] . ".$where_ids)";
1133 $where_sql_and = $where_sql . "\n\tAND";
1134 }
1135 else
1136 {
1137 // Do not sync the "global forum"
1138 $where_ids = array_diff($where_ids, array(0));
1139
1140 if (!sizeof($where_ids))
1141 {
1142 // Empty array with IDs. This means that we don't have any work to do. Just return.
1143 return;
1144 }
1145
1146 // Limit the topics/forums we are syncing, use specific topic/forum IDs.
1147 // $where_type contains the field for the where clause (forum_id, topic_id)
1148 $where_sql = 'WHERE ' . phpbb::$db->sql_in_set($mode[0] . '.' . $where_type, $where_ids);
1149 $where_sql_and = $where_sql . "\n\tAND";
1150 }
1151 }
1152 else
1153 {
1154 if (!sizeof($where_ids))
1155 {
1156 return;
1157 }
1158
1159 // $where_type contains the field for the where clause (forum_id, topic_id)
1160 $where_sql = 'WHERE ' . phpbb::$db->sql_in_set($mode[0] . '.' . $where_type, $where_ids);
1161 $where_sql_and = $where_sql . "\n\tAND";
1162 }
1163
1164 switch ($mode)
1165 {
1166 case 'topic_moved':
1167 if (phpbb::$db->features['multi_table_deletion'])
1168 {
1169 $sql = 'DELETE FROM ' . TOPICS_TABLE . '
1170 USING ' . TOPICS_TABLE . ' t1, ' . TOPICS_TABLE . " t2
1171 WHERE t1.topic_moved_id = t2.topic_id
1172 AND t1.forum_id = t2.forum_id";
1173 phpbb::$db->sql_query($sql);
1174 }
1175 else
1176 {
1177 $sql = 'SELECT t1.topic_id
1178 FROM ' .TOPICS_TABLE . ' t1, ' . TOPICS_TABLE . " t2
1179 WHERE t1.topic_moved_id = t2.topic_id
1180 AND t1.forum_id = t2.forum_id";
1181 $result = phpbb::$db->sql_query($sql);
1182
1183 $topic_id_ary = array();
1184 while ($row = phpbb::$db->sql_fetchrow($result))
1185 {
1186 $topic_id_ary[] = $row['topic_id'];
1187 }
1188 phpbb::$db->sql_freeresult($result);
1189
1190 if (!sizeof($topic_id_ary))
1191 {
1192 return;
1193 }
1194
1195 $sql = 'DELETE FROM ' . TOPICS_TABLE . '
1196 WHERE ' . phpbb::$db->sql_in_set('topic_id', $topic_id_ary);
1197 phpbb::$db->sql_query($sql);
1198 }
1199 break;
1200
1201 case 'topic_approved':
1202 if (phpbb::$db->dbms_type == 'mysql')
1203 {
1204 $sql = 'UPDATE ' . TOPICS_TABLE . ' t, ' . POSTS_TABLE . " p
1205 SET t.topic_approved = p.post_approved
1206 $where_sql_and t.topic_first_post_id = p.post_id";
1207 phpbb::$db->sql_query($sql);
1208 }
1209 else
1210 {
1211 $sql = 'SELECT t.topic_id, p.post_approved
1212 FROM ' . TOPICS_TABLE . ' t, ' . POSTS_TABLE . " p
1213 $where_sql_and p.post_id = t.topic_first_post_id
1214 AND p.post_approved <> t.topic_approved";
1215 $result = phpbb::$db->sql_query($sql);
1216
1217 $topic_ids = array();
1218 while ($row = phpbb::$db->sql_fetchrow($result))
1219 {
1220 $topic_ids[] = $row['topic_id'];
1221 }
1222 phpbb::$db->sql_freeresult($result);
1223
1224 if (!sizeof($topic_ids))
1225 {
1226 return;
1227 }
1228
1229 $sql = 'UPDATE ' . TOPICS_TABLE . '
1230 SET topic_approved = 1 - topic_approved
1231 WHERE ' . phpbb::$db->sql_in_set('topic_id', $topic_ids);
1232 phpbb::$db->sql_query($sql);
1233 }
1234 break;
1235
1236 case 'post_reported':
1237 $post_ids = $post_reported = array();
1238
1239 $sql = 'SELECT p.post_id, p.post_reported
1240 FROM ' . POSTS_TABLE . " p
1241 $where_sql
1242 GROUP BY p.post_id, p.post_reported";
1243 $result = phpbb::$db->sql_query($sql);
1244
1245 while ($row = phpbb::$db->sql_fetchrow($result))
1246 {
1247 $post_ids[$row['post_id']] = $row['post_id'];
1248 if ($row['post_reported'])
1249 {
1250 $post_reported[$row['post_id']] = 1;
1251 }
1252 }
1253 phpbb::$db->sql_freeresult($result);
1254
1255 $sql = 'SELECT DISTINCT(post_id)
1256 FROM ' . REPORTS_TABLE . '
1257 WHERE ' . phpbb::$db->sql_in_set('post_id', $post_ids) . '
1258 AND report_closed = 0';
1259 $result = phpbb::$db->sql_query($sql);
1260
1261 $post_ids = array();
1262 while ($row = phpbb::$db->sql_fetchrow($result))
1263 {
1264 if (!isset($post_reported[$row['post_id']]))
1265 {
1266 $post_ids[] = $row['post_id'];
1267 }
1268 else
1269 {
1270 unset($post_reported[$row['post_id']]);
1271 }
1272 }
1273 phpbb::$db->sql_freeresult($result);
1274
1275 // $post_reported should be empty by now, if it's not it contains
1276 // posts that are falsely flagged as reported
1277 foreach ($post_reported as $post_id => $void)
1278 {
1279 $post_ids[] = $post_id;
1280 }
1281
1282 if (sizeof($post_ids))
1283 {
1284 $sql = 'UPDATE ' . POSTS_TABLE . '
1285 SET post_reported = 1 - post_reported
1286 WHERE ' . phpbb::$db->sql_in_set('post_id', $post_ids);
1287 phpbb::$db->sql_query($sql);
1288 }
1289 break;
1290
1291 case 'topic_reported':
1292 if ($sync_extra)
1293 {
1294 sync('post_reported', $where_type, $where_ids);
1295 }
1296
1297 $topic_ids = $topic_reported = array();
1298
1299 $sql = 'SELECT DISTINCT(t.topic_id)
1300 FROM ' . POSTS_TABLE . " t
1301 $where_sql_and t.post_reported = 1";
1302 $result = phpbb::$db->sql_query($sql);
1303
1304 while ($row = phpbb::$db->sql_fetchrow($result))
1305 {
1306 $topic_reported[$row['topic_id']] = 1;
1307 }
1308 phpbb::$db->sql_freeresult($result);
1309
1310 $sql = 'SELECT t.topic_id, t.topic_reported
1311 FROM ' . TOPICS_TABLE . " t
1312 $where_sql";
1313 $result = phpbb::$db->sql_query($sql);
1314
1315 while ($row = phpbb::$db->sql_fetchrow($result))
1316 {
1317 if ($row['topic_reported'] ^ isset($topic_reported[$row['topic_id']]))
1318 {
1319 $topic_ids[] = $row['topic_id'];
1320 }
1321 }
1322 phpbb::$db->sql_freeresult($result);
1323
1324 if (sizeof($topic_ids))
1325 {
1326 $sql = 'UPDATE ' . TOPICS_TABLE . '
1327 SET topic_reported = 1 - topic_reported
1328 WHERE ' . phpbb::$db->sql_in_set('topic_id', $topic_ids);
1329 phpbb::$db->sql_query($sql);
1330 }
1331 break;
1332
1333 case 'post_attachment':
1334 $post_ids = $post_attachment = array();
1335
1336 $sql = 'SELECT p.post_id, p.post_attachment
1337 FROM ' . POSTS_TABLE . " p
1338 $where_sql
1339 GROUP BY p.post_id, p.post_attachment";
1340 $result = phpbb::$db->sql_query($sql);
1341
1342 while ($row = phpbb::$db->sql_fetchrow($result))
1343 {
1344 $post_ids[$row['post_id']] = $row['post_id'];
1345 if ($row['post_attachment'])
1346 {
1347 $post_attachment[$row['post_id']] = 1;
1348 }
1349 }
1350 phpbb::$db->sql_freeresult($result);
1351
1352 $sql = 'SELECT DISTINCT(post_msg_id)
1353 FROM ' . ATTACHMENTS_TABLE . '
1354 WHERE ' . phpbb::$db->sql_in_set('post_msg_id', $post_ids) . '
1355 AND in_message = 0';
1356 $result = phpbb::$db->sql_query($sql);
1357
1358 $post_ids = array();
1359 while ($row = phpbb::$db->sql_fetchrow($result))
1360 {
1361 if (!isset($post_attachment[$row['post_msg_id']]))
1362 {
1363 $post_ids[] = $row['post_msg_id'];
1364 }
1365 else
1366 {
1367 unset($post_attachment[$row['post_msg_id']]);
1368 }
1369 }
1370 phpbb::$db->sql_freeresult($result);
1371
1372 // $post_attachment should be empty by now, if it's not it contains
1373 // posts that are falsely flagged as having attachments
1374 foreach ($post_attachment as $post_id => $void)
1375 {
1376 $post_ids[] = $post_id;
1377 }
1378
1379 if (sizeof($post_ids))
1380 {
1381 $sql = 'UPDATE ' . POSTS_TABLE . '
1382 SET post_attachment = 1 - post_attachment
1383 WHERE ' . phpbb::$db->sql_in_set('post_id', $post_ids);
1384 phpbb::$db->sql_query($sql);
1385 }
1386 break;
1387
1388 case 'topic_attachment':
1389 if ($sync_extra)
1390 {
1391 sync('post_attachment', $where_type, $where_ids);
1392 }
1393
1394 $topic_ids = $topic_attachment = array();
1395
1396 $sql = 'SELECT DISTINCT(t.topic_id)
1397 FROM ' . POSTS_TABLE . " t
1398 $where_sql_and t.post_attachment = 1";
1399 $result = phpbb::$db->sql_query($sql);
1400
1401 while ($row = phpbb::$db->sql_fetchrow($result))
1402 {
1403 $topic_attachment[$row['topic_id']] = 1;
1404 }
1405 phpbb::$db->sql_freeresult($result);
1406
1407 $sql = 'SELECT t.topic_id, t.topic_attachment
1408 FROM ' . TOPICS_TABLE . " t
1409 $where_sql";
1410 $result = phpbb::$db->sql_query($sql);
1411
1412 while ($row = phpbb::$db->sql_fetchrow($result))
1413 {
1414 if ($row['topic_attachment'] ^ isset($topic_attachment[$row['topic_id']]))
1415 {
1416 $topic_ids[] = $row['topic_id'];
1417 }
1418 }
1419 phpbb::$db->sql_freeresult($result);
1420
1421 if (sizeof($topic_ids))
1422 {
1423 $sql = 'UPDATE ' . TOPICS_TABLE . '
1424 SET topic_attachment = 1 - topic_attachment
1425 WHERE ' . phpbb::$db->sql_in_set('topic_id', $topic_ids);
1426 phpbb::$db->sql_query($sql);
1427 }
1428 break;
1429
1430 case 'forum':
1431
1432 // 1: Get the list of all forums
1433 $sql = 'SELECT f.*
1434 FROM ' . FORUMS_TABLE . " f
1435 $where_sql";
1436 $result = phpbb::$db->sql_query($sql);
1437
1438 $forum_data = $forum_ids = $post_ids = $last_post_id = $post_info = array();
1439 while ($row = phpbb::$db->sql_fetchrow($result))
1440 {
1441 if ($row['forum_type'] == FORUM_LINK)
1442 {
1443 continue;
1444 }
1445
1446 $forum_id = (int) $row['forum_id'];
1447 $forum_ids[$forum_id] = $forum_id;
1448
1449 $forum_data[$forum_id] = $row;
1450 if ($sync_extra)
1451 {
1452 $forum_data[$forum_id]['posts'] = 0;
1453 $forum_data[$forum_id]['topics'] = 0;
1454 $forum_data[$forum_id]['topics_real'] = 0;
1455 }
1456 $forum_data[$forum_id]['last_post_id'] = 0;
1457 $forum_data[$forum_id]['last_post_subject'] = '';
1458 $forum_data[$forum_id]['last_post_time'] = 0;
1459 $forum_data[$forum_id]['last_poster_id'] = 0;
1460 $forum_data[$forum_id]['last_poster_name'] = '';
1461 $forum_data[$forum_id]['last_poster_colour'] = '';
1462 }
1463 phpbb::$db->sql_freeresult($result);
1464
1465 if (!sizeof($forum_ids))
1466 {
1467 break;
1468 }
1469
1470 $forum_ids = array_values($forum_ids);
1471
1472 // 2: Get topic counts for each forum (optional)
1473 if ($sync_extra)
1474 {
1475 $sql = 'SELECT forum_id, topic_approved, COUNT(topic_id) AS forum_topics
1476 FROM ' . TOPICS_TABLE . '
1477 WHERE ' . phpbb::$db->sql_in_set('forum_id', $forum_ids) . '
1478 GROUP BY forum_id, topic_approved';
1479 $result = phpbb::$db->sql_query($sql);
1480
1481 while ($row = phpbb::$db->sql_fetchrow($result))
1482 {
1483 $forum_id = (int) $row['forum_id'];
1484 $forum_data[$forum_id]['topics_real'] += $row['forum_topics'];
1485
1486 if ($row['topic_approved'])
1487 {
1488 $forum_data[$forum_id]['topics'] = $row['forum_topics'];
1489 }
1490 }
1491 phpbb::$db->sql_freeresult($result);
1492 }
1493
1494 // 3: Get post count for each forum (optional)
1495 if ($sync_extra)
1496 {
1497 if (sizeof($forum_ids) == 1)
1498 {
1499 $sql = 'SELECT SUM(t.topic_replies + 1) AS forum_posts
1500 FROM ' . TOPICS_TABLE . ' t
1501 WHERE ' . phpbb::$db->sql_in_set('t.forum_id', $forum_ids) . '
1502 AND t.topic_approved = 1
1503 AND t.topic_status <> ' . ITEM_MOVED;
1504 }
1505 else
1506 {
1507 $sql = 'SELECT t.forum_id, SUM(t.topic_replies + 1) AS forum_posts
1508 FROM ' . TOPICS_TABLE . ' t
1509 WHERE ' . phpbb::$db->sql_in_set('t.forum_id', $forum_ids) . '
1510 AND t.topic_approved = 1
1511 AND t.topic_status <> ' . ITEM_MOVED . '
1512 GROUP BY t.forum_id';
1513 }
1514
1515 $result = phpbb::$db->sql_query($sql);
1516
1517 while ($row = phpbb::$db->sql_fetchrow($result))
1518 {
1519 $forum_id = (sizeof($forum_ids) == 1) ? (int) $forum_ids[0] : (int) $row['forum_id'];
1520
1521 $forum_data[$forum_id]['posts'] = (int) $row['forum_posts'];
1522 }
1523 phpbb::$db->sql_freeresult($result);
1524 }
1525
1526 // 4: Get last_post_id for each forum
1527 if (sizeof($forum_ids) == 1)
1528 {
1529 $sql = 'SELECT MAX(t.topic_last_post_id) as last_post_id
1530 FROM ' . TOPICS_TABLE . ' t
1531 WHERE ' . phpbb::$db->sql_in_set('t.forum_id', $forum_ids) . '
1532 AND t.topic_approved = 1';
1533 }
1534 else
1535 {
1536 $sql = 'SELECT t.forum_id, MAX(t.topic_last_post_id) as last_post_id
1537 FROM ' . TOPICS_TABLE . ' t
1538 WHERE ' . phpbb::$db->sql_in_set('t.forum_id', $forum_ids) . '
1539 AND t.topic_approved = 1
1540 GROUP BY t.forum_id';
1541 }
1542
1543 $result = phpbb::$db->sql_query($sql);
1544
1545 while ($row = phpbb::$db->sql_fetchrow($result))
1546 {
1547 $forum_id = (sizeof($forum_ids) == 1) ? (int) $forum_ids[0] : (int) $row['forum_id'];
1548
1549 $forum_data[$forum_id]['last_post_id'] = (int) $row['last_post_id'];
1550
1551 $post_ids[] = $row['last_post_id'];
1552 }
1553 phpbb::$db->sql_freeresult($result);
1554
1555 // 5: Retrieve last_post infos
1556 if (sizeof($post_ids))
1557 {
1558 $sql = 'SELECT p.post_id, p.poster_id, p.post_subject, p.post_time, p.post_username, u.username, u.user_colour
1559 FROM ' . POSTS_TABLE . ' p, ' . USERS_TABLE . ' u
1560 WHERE ' . phpbb::$db->sql_in_set('p.post_id', $post_ids) . '
1561 AND p.poster_id = u.user_id';
1562 $result = phpbb::$db->sql_query($sql);
1563
1564 while ($row = phpbb::$db->sql_fetchrow($result))
1565 {
1566 $post_info[$row['post_id']] = $row;
1567 }
1568 phpbb::$db->sql_freeresult($result);
1569
1570 foreach ($forum_data as $forum_id => $data)
1571 {
1572 if ($data['last_post_id'])
1573 {
1574 if (isset($post_info[$data['last_post_id']]))
1575 {
1576 $forum_data[$forum_id]['last_post_subject'] = $post_info[$data['last_post_id']]['post_subject'];
1577 $forum_data[$forum_id]['last_post_time'] = $post_info[$data['last_post_id']]['post_time'];
1578 $forum_data[$forum_id]['last_poster_id'] = $post_info[$data['last_post_id']]['poster_id'];
1579 $forum_data[$forum_id]['last_poster_name'] = ($post_info[$data['last_post_id']]['poster_id'] != ANONYMOUS) ? $post_info[$data['last_post_id']]['username'] : $post_info[$data['last_post_id']]['post_username'];
1580 $forum_data[$forum_id]['last_poster_colour'] = $post_info[$data['last_post_id']]['user_colour'];
1581 }
1582 else
1583 {
1584 // For some reason we did not find the post in the db
1585 $forum_data[$forum_id]['last_post_id'] = 0;
1586 $forum_data[$forum_id]['last_post_subject'] = '';
1587 $forum_data[$forum_id]['last_post_time'] = 0;
1588 $forum_data[$forum_id]['last_poster_id'] = 0;
1589 $forum_data[$forum_id]['last_poster_name'] = '';
1590 $forum_data[$forum_id]['last_poster_colour'] = '';
1591 }
1592 }
1593 }
1594 unset($post_info);
1595 }
1596
1597 // 6: Now do that thing
1598 $fieldnames = array('last_post_id', 'last_post_subject', 'last_post_time', 'last_poster_id', 'last_poster_name', 'last_poster_colour');
1599
1600 if ($sync_extra)
1601 {
1602 array_push($fieldnames, 'posts', 'topics', 'topics_real');
1603 }
1604
1605 foreach ($forum_data as $forum_id => $row)
1606 {
1607 $sql_ary = array();
1608
1609 foreach ($fieldnames as $fieldname)
1610 {
1611 if ($row['forum_' . $fieldname] != $row[$fieldname])
1612 {
1613 if (preg_match('#(name|colour|subject)$#', $fieldname))
1614 {
1615 $sql_ary['forum_' . $fieldname] = (string) $row[$fieldname];
1616 }
1617 else
1618 {
1619 $sql_ary['forum_' . $fieldname] = (int) $row[$fieldname];
1620 }
1621 }
1622 }
1623
1624 if (sizeof($sql_ary))
1625 {
1626 $sql = 'UPDATE ' . FORUMS_TABLE . '
1627 SET ' . phpbb::$db->sql_build_array('UPDATE', $sql_ary) . '
1628 WHERE forum_id = ' . $forum_id;
1629 phpbb::$db->sql_query($sql);
1630 }
1631 }
1632 break;
1633
1634 case 'topic':
1635 $topic_data = $post_ids = $approved_unapproved_ids = $resync_forums = $delete_topics = $delete_posts = $moved_topics = array();
1636
1637 $sql = 'SELECT t.topic_id, t.forum_id, t.topic_moved_id, t.topic_approved, ' . (($sync_extra) ? 't.topic_attachment, t.topic_reported, ' : '') . 't.topic_poster, t.topic_time, t.topic_replies, t.topic_replies_real, t.topic_first_post_id, t.topic_first_poster_name, t.topic_first_poster_colour, t.topic_last_post_id, t.topic_last_post_subject, t.topic_last_poster_id, t.topic_last_poster_name, t.topic_last_poster_colour, t.topic_last_post_time
1638 FROM ' . TOPICS_TABLE . " t
1639 $where_sql";
1640 $result = phpbb::$db->sql_query($sql);
1641
1642 while ($row = phpbb::$db->sql_fetchrow($result))
1643 {
1644 if ($row['topic_moved_id'])
1645 {
1646 $moved_topics[] = $row['topic_id'];
1647 continue;
1648 }
1649
1650 $topic_id = (int) $row['topic_id'];
1651 $topic_data[$topic_id] = $row;
1652 $topic_data[$topic_id]['replies_real'] = -1;
1653 $topic_data[$topic_id]['replies'] = 0;
1654 $topic_data[$topic_id]['first_post_id'] = 0;
1655 $topic_data[$topic_id]['last_post_id'] = 0;
1656 unset($topic_data[$topic_id]['topic_id']);
1657
1658 // This array holds all topic_ids
1659 $delete_topics[$topic_id] = '';
1660
1661 if ($sync_extra)
1662 {
1663 $topic_data[$topic_id]['reported'] = 0;
1664 $topic_data[$topic_id]['attachment'] = 0;
1665 }
1666 }
1667 phpbb::$db->sql_freeresult($result);
1668
1669 // Use "t" as table alias because of the $where_sql clause
1670 // NOTE: 't.post_approved' in the GROUP BY is causing a major slowdown.
1671 $sql = 'SELECT t.topic_id, t.post_approved, COUNT(t.post_id) AS total_posts, MIN(t.post_id) AS first_post_id, MAX(t.post_id) AS last_post_id
1672 FROM ' . POSTS_TABLE . " t
1673 $where_sql
1674 GROUP BY t.topic_id, t.post_approved";
1675 $result = phpbb::$db->sql_query($sql);
1676
1677 while ($row = phpbb::$db->sql_fetchrow($result))
1678 {
1679 $topic_id = (int) $row['topic_id'];
1680
1681 $row['first_post_id'] = (int) $row['first_post_id'];
1682 $row['last_post_id'] = (int) $row['last_post_id'];
1683
1684 if (!isset($topic_data[$topic_id]))
1685 {
1686 // Hey, these posts come from a topic that does not exist
1687 $delete_posts[$topic_id] = '';
1688 }
1689 else
1690 {
1691 // Unset the corresponding entry in $delete_topics
1692 // When we'll be done, only topics with no posts will remain
1693 unset($delete_topics[$topic_id]);
1694
1695 $topic_data[$topic_id]['replies_real'] += $row['total_posts'];
1696 $topic_data[$topic_id]['first_post_id'] = (!$topic_data[$topic_id]['first_post_id']) ? $row['first_post_id'] : min($topic_data[$topic_id]['first_post_id'], $row['first_post_id']);
1697
1698 if ($row['post_approved'] || !$topic_data[$topic_id]['last_post_id'])
1699 {
1700 $topic_data[$topic_id]['replies'] = $row['total_posts'] - 1;
1701 $topic_data[$topic_id]['last_post_id'] = $row['last_post_id'];
1702 }
1703 }
1704 }
1705 phpbb::$db->sql_freeresult($result);
1706
1707 foreach ($topic_data as $topic_id => $row)
1708 {
1709 $post_ids[] = $row['first_post_id'];
1710 if ($row['first_post_id'] != $row['last_post_id'])
1711 {
1712 $post_ids[] = $row['last_post_id'];
1713 }
1714 }
1715
1716 // Now we delete empty topics and orphan posts
1717 if (sizeof($delete_posts))
1718 {
1719 delete_posts('topic_id', array_keys($delete_posts), false);
1720 unset($delete_posts);
1721 }
1722
1723 if (!sizeof($topic_data))
1724 {
1725 // If we get there, topic ids were invalid or topics did not contain any posts
1726 delete_topics($where_type, $where_ids, true);
1727 return;
1728 }
1729
1730 if (sizeof($delete_topics))
1731 {
1732 $delete_topic_ids = array();
1733 foreach ($delete_topics as $topic_id => $void)
1734 {
1735 unset($topic_data[$topic_id]);
1736 $delete_topic_ids[] = $topic_id;
1737 }
1738
1739 delete_topics('topic_id', $delete_topic_ids, false);
1740 unset($delete_topics, $delete_topic_ids);
1741 }
1742
1743 $sql = 'SELECT p.post_id, p.topic_id, p.post_approved, p.poster_id, p.post_subject, p.post_username, p.post_time, u.username, u.user_colour
1744 FROM ' . POSTS_TABLE . ' p, ' . USERS_TABLE . ' u
1745 WHERE ' . phpbb::$db->sql_in_set('p.post_id', $post_ids) . '
1746 AND u.user_id = p.poster_id';
1747 $result = phpbb::$db->sql_query($sql);
1748
1749 $post_ids = array();
1750 while ($row = phpbb::$db->sql_fetchrow($result))
1751 {
1752 $topic_id = intval($row['topic_id']);
1753
1754 if ($row['post_id'] == $topic_data[$topic_id]['first_post_id'])
1755 {
1756 if ($topic_data[$topic_id]['topic_approved'] != $row['post_approved'])
1757 {
1758 $approved_unapproved_ids[] = $topic_id;
1759 }
1760 $topic_data[$topic_id]['time'] = $row['post_time'];
1761 $topic_data[$topic_id]['poster'] = $row['poster_id'];
1762 $topic_data[$topic_id]['first_poster_name'] = ($row['poster_id'] == ANONYMOUS) ? $row['post_username'] : $row['username'];
1763 $topic_data[$topic_id]['first_poster_colour'] = $row['user_colour'];
1764 }
1765
1766 if ($row['post_id'] == $topic_data[$topic_id]['last_post_id'])
1767 {
1768 $topic_data[$topic_id]['last_poster_id'] = $row['poster_id'];
1769 $topic_data[$topic_id]['last_post_subject'] = $row['post_subject'];
1770 $topic_data[$topic_id]['last_post_time'] = $row['post_time'];
1771 $topic_data[$topic_id]['last_poster_name'] = ($row['poster_id'] == ANONYMOUS) ? $row['post_username'] : $row['username'];
1772 $topic_data[$topic_id]['last_poster_colour'] = $row['user_colour'];
1773 }
1774 }
1775 phpbb::$db->sql_freeresult($result);
1776
1777 // Make sure shadow topics do link to existing topics
1778 if (sizeof($moved_topics))
1779 {
1780 $delete_topics = array();
1781
1782 $sql = 'SELECT t1.topic_id, t1.topic_moved_id
1783 FROM ' . TOPICS_TABLE . ' t1
1784 LEFT JOIN ' . TOPICS_TABLE . ' t2 ON (t2.topic_id = t1.topic_moved_id)
1785 WHERE ' . phpbb::$db->sql_in_set('t1.topic_id', $moved_topics) . '
1786 AND t2.topic_id IS NULL';
1787 $result = phpbb::$db->sql_query($sql);
1788
1789 while ($row = phpbb::$db->sql_fetchrow($result))
1790 {
1791 $delete_topics[] = $row['topic_id'];
1792 }
1793 phpbb::$db->sql_freeresult($result);
1794
1795 if (sizeof($delete_topics))
1796 {
1797 delete_topics('topic_id', $delete_topics, false);
1798 }
1799 unset($delete_topics);
1800
1801 // Make sure shadow topics having no last post data being updated (this only rarely happens...)
1802 $sql = 'SELECT topic_id, topic_moved_id, topic_last_post_id, topic_first_post_id
1803 FROM ' . TOPICS_TABLE . '
1804 WHERE ' . phpbb::$db->sql_in_set('topic_id', $moved_topics) . '
1805 AND topic_last_post_time = 0';
1806 $result = phpbb::$db->sql_query($sql);
1807
1808 $shadow_topic_data = $post_ids = array();
1809 while ($row = phpbb::$db->sql_fetchrow($result))
1810 {
1811 $shadow_topic_data[$row['topic_moved_id']] = $row;
1812 $post_ids[] = $row['topic_last_post_id'];
1813 $post_ids[] = $row['topic_first_post_id'];
1814 }
1815 phpbb::$db->sql_freeresult($result);
1816
1817 $sync_shadow_topics = array();
1818 if (sizeof($post_ids))
1819 {
1820 $sql = 'SELECT p.post_id, p.topic_id, p.post_approved, p.poster_id, p.post_subject, p.post_username, p.post_time, u.username, u.user_colour
1821 FROM ' . POSTS_TABLE . ' p, ' . USERS_TABLE . ' u
1822 WHERE ' . phpbb::$db->sql_in_set('p.post_id', $post_ids) . '
1823 AND u.user_id = p.poster_id';
1824 $result = phpbb::$db->sql_query($sql);
1825
1826 $post_ids = array();
1827 while ($row = phpbb::$db->sql_fetchrow($result))
1828 {
1829 $topic_id = (int) $row['topic_id'];
1830
1831 // Ok, there should be a shadow topic. If there isn't, then there's something wrong with the db.
1832 // However, there's not much we can do about it.
1833 if (!empty($shadow_topic_data[$topic_id]))
1834 {
1835 if ($row['post_id'] == $shadow_topic_data[$topic_id]['topic_first_post_id'])
1836 {
1837 $orig_topic_id = $shadow_topic_data[$topic_id]['topic_id'];
1838
1839 if (!isset($sync_shadow_topics[$orig_topic_id]))
1840 {
1841 $sync_shadow_topics[$orig_topic_id] = array();
1842 }
1843
1844 $sync_shadow_topics[$orig_topic_id]['topic_time'] = $row['post_time'];
1845 $sync_shadow_topics[$orig_topic_id]['topic_poster'] = $row['poster_id'];
1846 $sync_shadow_topics[$orig_topic_id]['topic_first_poster_name'] = ($row['poster_id'] == ANONYMOUS) ? $row['post_username'] : $row['username'];
1847 $sync_shadow_topics[$orig_topic_id]['topic_first_poster_colour'] = $row['user_colour'];
1848 }
1849
1850 if ($row['post_id'] == $shadow_topic_data[$topic_id]['topic_last_post_id'])
1851 {
1852 $orig_topic_id = $shadow_topic_data[$topic_id]['topic_id'];
1853
1854 if (!isset($sync_shadow_topics[$orig_topic_id]))
1855 {
1856 $sync_shadow_topics[$orig_topic_id] = array();
1857 }
1858
1859 $sync_shadow_topics[$orig_topic_id]['topic_last_poster_id'] = $row['poster_id'];
1860 $sync_shadow_topics[$orig_topic_id]['topic_last_post_subject'] = $row['post_subject'];
1861 $sync_shadow_topics[$orig_topic_id]['topic_last_post_time'] = $row['post_time'];
1862 $sync_shadow_topics[$orig_topic_id]['topic_last_poster_name'] = ($row['poster_id'] == ANONYMOUS) ? $row['post_username'] : $row['username'];
1863 $sync_shadow_topics[$orig_topic_id]['topic_last_poster_colour'] = $row['user_colour'];
1864 }
1865 }
1866 }
1867 phpbb::$db->sql_freeresult($result);
1868
1869 $shadow_topic_data = array();
1870
1871 // Update the information we collected
1872 if (sizeof($sync_shadow_topics))
1873 {
1874 foreach ($sync_shadow_topics as $sync_topic_id => $sql_ary)
1875 {
1876 $sql = 'UPDATE ' . TOPICS_TABLE . '
1877 SET ' . phpbb::$db->sql_build_array('UPDATE', $sql_ary) . '
1878 WHERE topic_id = ' . $sync_topic_id;
1879 phpbb::$db->sql_query($sql);
1880 }
1881 }
1882 }
1883
1884 unset($sync_shadow_topics, $shadow_topic_data);
1885 }
1886
1887 // approved becomes unapproved, and vice-versa
1888 if (sizeof($approved_unapproved_ids))
1889 {
1890 $sql = 'UPDATE ' . TOPICS_TABLE . '
1891 SET topic_approved = 1 - topic_approved
1892 WHERE ' . phpbb::$db->sql_in_set('topic_id', $approved_unapproved_ids);
1893 phpbb::$db->sql_query($sql);
1894 }
1895 unset($approved_unapproved_ids);
1896
1897 // These are fields that will be synchronised
1898 $fieldnames = array('time', 'replies', 'replies_real', 'poster', 'first_post_id', 'first_poster_name', 'first_poster_colour', 'last_post_id', 'last_post_subject', 'last_post_time', 'last_poster_id', 'last_poster_name', 'last_poster_colour');
1899
1900 if ($sync_extra)
1901 {
1902 // This routine assumes that post_reported values are correct
1903 // if they are not, use sync('post_reported') first
1904 $sql = 'SELECT t.topic_id, p.post_id
1905 FROM ' . TOPICS_TABLE . ' t, ' . POSTS_TABLE . " p
1906 $where_sql_and p.topic_id = t.topic_id
1907 AND p.post_reported = 1
1908 GROUP BY t.topic_id, p.post_id";
1909 $result = phpbb::$db->sql_query($sql);
1910
1911 $fieldnames[] = 'reported';
1912 while ($row = phpbb::$db->sql_fetchrow($result))
1913 {
1914 $topic_data[intval($row['topic_id'])]['reported'] = 1;
1915 }
1916 phpbb::$db->sql_freeresult($result);
1917
1918 // This routine assumes that post_attachment values are correct
1919 // if they are not, use sync('post_attachment') first
1920 $sql = 'SELECT t.topic_id, p.post_id
1921 FROM ' . TOPICS_TABLE . ' t, ' . POSTS_TABLE . " p
1922 $where_sql_and p.topic_id = t.topic_id
1923 AND p.post_attachment = 1
1924 GROUP BY t.topic_id, p.post_id";
1925 $result = phpbb::$db->sql_query($sql);
1926
1927 $fieldnames[] = 'attachment';
1928 while ($row = phpbb::$db->sql_fetchrow($result))
1929 {
1930 $topic_data[intval($row['topic_id'])]['attachment'] = 1;
1931 }
1932 phpbb::$db->sql_freeresult($result);
1933 }
1934
1935 foreach ($topic_data as $topic_id => $row)
1936 {
1937 $sql_ary = array();
1938
1939 foreach ($fieldnames as $fieldname)
1940 {
1941 if (isset($row[$fieldname]) && isset($row['topic_' . $fieldname]) && $row['topic_' . $fieldname] != $row[$fieldname])
1942 {
1943 $sql_ary['topic_' . $fieldname] = $row[$fieldname];
1944 }
1945 }
1946
1947 if (sizeof($sql_ary))
1948 {
1949 $sql = 'UPDATE ' . TOPICS_TABLE . '
1950 SET ' . phpbb::$db->sql_build_array('UPDATE', $sql_ary) . '
1951 WHERE topic_id = ' . $topic_id;
1952 phpbb::$db->sql_query($sql);
1953
1954 $resync_forums[$row['forum_id']] = $row['forum_id'];
1955 }
1956 }
1957 unset($topic_data);
1958
1959 // if some topics have been resync'ed then resync parent forums
1960 // except when we're only syncing a range, we don't want to sync forums during
1961 // batch processing.
1962 if ($resync_parents && sizeof($resync_forums) && $where_type != 'range')
1963 {
1964 sync('forum', 'forum_id', array_values($resync_forums), true, true);
1965 }
1966 break;
1967 }
1968
1969 return;
1970 }
1971
1972 /**
1973 * Prune function
1974 */
1975 function prune($forum_id, $prune_mode, $prune_date, $prune_flags = 0, $auto_sync = true)
1976 {
1977 if (!is_array($forum_id))
1978 {
1979 $forum_id = array($forum_id);
1980 }
1981
1982 if (!sizeof($forum_id))
1983 {
1984 return;
1985 }
1986
1987 $sql_and = '';
1988
1989 if (!($prune_flags & FORUM_FLAG_PRUNE_ANNOUNCE))
1990 {
1991 $sql_and .= ' AND topic_type <> ' . POST_ANNOUNCE;
1992 }
1993
1994 if (!($prune_flags & FORUM_FLAG_PRUNE_STICKY))
1995 {
1996 $sql_and .= ' AND topic_type <> ' . POST_STICKY;
1997 }
1998
1999 if ($prune_mode == 'posted')
2000 {
2001 $sql_and .= " AND topic_last_post_time < $prune_date";
2002 }
2003
2004 if ($prune_mode == 'viewed')
2005 {
2006 $sql_and .= " AND topic_last_view_time < $prune_date";
2007 }
2008
2009 $sql = 'SELECT topic_id
2010 FROM ' . TOPICS_TABLE . '
2011 WHERE ' . phpbb::$db->sql_in_set('forum_id', $forum_id) . "
2012 AND poll_start = 0
2013 $sql_and";
2014 $result = phpbb::$db->sql_query($sql);
2015
2016 $topic_list = array();
2017 while ($row = phpbb::$db->sql_fetchrow($result))
2018 {
2019 $topic_list[] = $row['topic_id'];
2020 }
2021 phpbb::$db->sql_freeresult($result);
2022
2023 if ($prune_flags & FORUM_FLAG_PRUNE_POLL)
2024 {
2025 $sql = 'SELECT topic_id
2026 FROM ' . TOPICS_TABLE . '
2027 WHERE ' . phpbb::$db->sql_in_set('forum_id', $forum_id) . "
2028 AND poll_start > 0
2029 AND poll_last_vote < $prune_date
2030 $sql_and";
2031 $result = phpbb::$db->sql_query($sql);
2032
2033 while ($row = phpbb::$db->sql_fetchrow($result))
2034 {
2035 $topic_list[] = $row['topic_id'];
2036 }
2037 phpbb::$db->sql_freeresult($result);
2038
2039 $topic_list = array_unique($topic_list);
2040 }
2041
2042 return delete_topics('topic_id', $topic_list, $auto_sync, false);
2043 }
2044
2045 /**
2046 * Function auto_prune(), this function now relies on passed vars
2047 */
2048 function auto_prune($forum_id, $prune_mode, $prune_flags, $prune_days, $prune_freq)
2049 {
2050 $sql = 'SELECT forum_name
2051 FROM ' . FORUMS_TABLE . "
2052 WHERE forum_id = $forum_id";
2053 $result = phpbb::$db->sql_query($sql, 3600);
2054 $row = phpbb::$db->sql_fetchrow($result);
2055 phpbb::$db->sql_freeresult($result);
2056
2057 if ($row)
2058 {
2059 $prune_date = time() - ($prune_days * 86400);
2060 $next_prune = time() + ($prune_freq * 86400);
2061
2062 prune($forum_id, $prune_mode, $prune_date, $prune_flags, true);
2063
2064 $sql = 'UPDATE ' . FORUMS_TABLE . "
2065 SET prune_next = $next_prune
2066 WHERE forum_id = $forum_id";
2067 phpbb::$db->sql_query($sql);
2068
2069 add_log('admin', 'LOG_AUTO_PRUNE', $row['forum_name']);
2070 }
2071
2072 return;
2073 }
2074
2075 /**
2076 * remove_comments will strip the sql comment lines out of an uploaded sql file
2077 * specifically for mssql and postgres type files in the install....
2078 */
2079 function remove_comments(&$output)
2080 {
2081 $lines = explode("\n", $output);
2082 $output = '';
2083
2084 // try to keep mem. use down
2085 $linecount = sizeof($lines);
2086
2087 $in_comment = false;
2088 for ($i = 0; $i < $linecount; $i++)
2089 {
2090 if (trim($lines[$i]) == '/*')
2091 {
2092 $in_comment = true;
2093 }
2094
2095 if (!$in_comment)
2096 {
2097 $output .= $lines[$i] . "\n";
2098 }
2099
2100 if (trim($lines[$i]) == '*/')
2101 {
2102 $in_comment = false;
2103 }
2104 }
2105
2106 unset($lines);
2107 return $output;
2108 }
2109
2110 /**
2111 * Cache moderators, called whenever permissions are changed via admin_permissions. Changes of username
2112 * and group names must be carried through for the moderators table
2113 */
2114 function cache_moderators()
2115 {
2116 // Remove cached sql results
2117 phpbb::$acm->destroy_sql(MODERATOR_CACHE_TABLE);
2118
2119 // Clear table
2120 if (phpbb::$db->features['truncate'])
2121 {
2122 phpbb::$db->sql_query('TRUNCATE TABLE ' . MODERATOR_CACHE_TABLE);
2123 }
2124 else
2125 {
2126 phpbb::$db->sql_query('DELETE FROM ' . MODERATOR_CACHE_TABLE);
2127 }
2128
2129 // We add moderators who have forum moderator permissions without an explicit ACL_NEVER setting
2130 $hold_ary = $ug_id_ary = $sql_ary = array();
2131
2132 // Grab all users having moderative options...
2133 $hold_ary = phpbb::$acl->acl_user_raw_data(false, 'm_%', false);
2134
2135 // Add users?
2136 if (sizeof($hold_ary))
2137 {
2138 // At least one moderative option warrants a display
2139 $ug_id_ary = array_keys($hold_ary);
2140
2141 // Remove users who have group memberships with DENY moderator permissions
2142 $sql = phpbb::$db->sql_build_query('SELECT', array(
2143 'SELECT' => 'a.forum_id, ug.user_id',
2144
2145 'FROM' => array(
2146 ACL_OPTIONS_TABLE => 'o',
2147 USER_GROUP_TABLE => 'ug',
2148 ACL_GROUPS_TABLE => 'a'
2149 ),
2150
2151 'LEFT_JOIN' => array(
2152 array(
2153 'FROM' => array(ACL_ROLES_DATA_TABLE => 'r'),
2154 'ON' => 'a.auth_role_id = r.role_id'
2155 )
2156 ),
2157
2158 'WHERE' => '(o.auth_option_id = a.auth_option_id OR o.auth_option_id = r.auth_option_id)
2159 AND ((a.auth_setting = ' . phpbb::ACL_NEVER . ' AND r.auth_setting IS NULL)
2160 OR r.auth_setting = ' . phpbb::ACL_NEVER . ')
2161 AND a.group_id = ug.group_id
2162 AND ' . phpbb::$db->sql_in_set('ug.user_id', $ug_id_ary) . "
2163 AND ug.user_pending = 0
2164 AND o.auth_option " . phpbb::$db->sql_like_expression('m_' . phpbb::$db->any_char),
2165 ));
2166 $result = phpbb::$db->sql_query($sql);
2167
2168 while ($row = phpbb::$db->sql_fetchrow($result))
2169 {
2170 if (isset($hold_ary[$row['user_id']][$row['forum_id']]))
2171 {
2172 unset($hold_ary[$row['user_id']][$row['forum_id']]);
2173 }
2174 }
2175 phpbb::$db->sql_freeresult($result);
2176
2177 if (sizeof($hold_ary))
2178 {
2179 // Get usernames...
2180 $sql = 'SELECT user_id, username
2181 FROM ' . USERS_TABLE . '
2182 WHERE ' . phpbb::$db->sql_in_set('user_id', array_keys($hold_ary));
2183 $result = phpbb::$db->sql_query($sql);
2184
2185 $usernames_ary = array();
2186 while ($row = phpbb::$db->sql_fetchrow($result))
2187 {
2188 $usernames_ary[$row['user_id']] = $row['username'];
2189 }
2190
2191 foreach ($hold_ary as $user_id => $forum_id_ary)
2192 {
2193 // Do not continue if user does not exist
2194 if (!isset($usernames_ary[$user_id]))
2195 {
2196 continue;
2197 }
2198
2199 foreach ($forum_id_ary as $forum_id => $auth_ary)
2200 {
2201 $sql_ary[] = array(
2202 'forum_id' => (int) $forum_id,
2203 'user_id' => (int) $user_id,
2204 'username' => (string) $usernames_ary[$user_id],
2205 'group_id' => 0,
2206 'group_name' => ''
2207 );
2208 }
2209 }
2210 }
2211 }
2212
2213 // Now to the groups...
2214 $hold_ary = phpbb::$acl->acl_group_raw_data(false, 'm_%', false);
2215
2216 if (sizeof($hold_ary))
2217 {
2218 $ug_id_ary = array_keys($hold_ary);
2219
2220 // Make sure not hidden or special groups are involved...
2221 $sql = 'SELECT group_name, group_id, group_type
2222 FROM ' . GROUPS_TABLE . '
2223 WHERE ' . phpbb::$db->sql_in_set('group_id', $ug_id_ary);
2224 $result = phpbb::$db->sql_query($sql);
2225
2226 $groupnames_ary = array();
2227 while ($row = phpbb::$db->sql_fetchrow($result))
2228 {
2229 if ($row['group_type'] == GROUP_HIDDEN || $row['group_type'] == GROUP_SPECIAL)
2230 {
2231 unset($hold_ary[$row['group_id']]);
2232 }
2233
2234 $groupnames_ary[$row['group_id']] = $row['group_name'];
2235 }
2236 phpbb::$db->sql_freeresult($result);
2237
2238 foreach ($hold_ary as $group_id => $forum_id_ary)
2239 {
2240 // If there is no group, we do not assign it...
2241 if (!isset($groupnames_ary[$group_id]))
2242 {
2243 continue;
2244 }
2245
2246 foreach ($forum_id_ary as $forum_id => $auth_ary)
2247 {
2248 $flag = false;
2249 foreach ($auth_ary as $auth_option => $setting)
2250 {
2251 // Make sure at least one ACL_YES option is set...
2252 if ($setting == phpbb::ACL_YES)
2253 {
2254 $flag = true;
2255 break;
2256 }
2257 }
2258
2259 if (!$flag)
2260 {
2261 continue;
2262 }
2263
2264 $sql_ary[] = array(
2265 'forum_id' => (int) $forum_id,
2266 'user_id' => 0,
2267 'username' => '',
2268 'group_id' => (int) $group_id,
2269 'group_name' => (string) $groupnames_ary[$group_id]
2270 );
2271 }
2272 }
2273 }
2274
2275 phpbb::$db->sql_multi_insert(MODERATOR_CACHE_TABLE, $sql_ary);
2276 }
2277
2278 /**
2279 * View log
2280 */
2281 function view_log($mode, &$log, &$log_count, $limit = 0, $offset = 0, $forum_id = 0, $topic_id = 0, $user_id = 0, $limit_days = 0, $sort_by = 'l.log_time DESC')
2282 {
2283 $topic_id_list = $reportee_id_list = $is_auth = $is_mod = array();
2284
2285 $profile_url = (defined('IN_ADMIN')) ? phpbb::$url->append_sid(PHPBB_ADMIN_PATH . 'index.' . PHP_EXT, 'i=users&amp;mode=overview') : phpbb::$url->append_sid('memberlist', 'mode=viewprofile');
2286
2287 switch ($mode)
2288 {
2289 case 'admin':
2290 $log_type = LOG_ADMIN;
2291 $sql_forum = '';
2292 break;
2293
2294 case 'mod':
2295 $log_type = LOG_MOD;
2296
2297 if ($topic_id)
2298 {
2299 $sql_forum = 'AND l.topic_id = ' . intval($topic_id);
2300 }
2301 else if (is_array($forum_id))
2302 {
2303 $sql_forum = 'AND ' . phpbb::$db->sql_in_set('l.forum_id', array_map('intval', $forum_id));
2304 }
2305 else
2306 {
2307 $sql_forum = ($forum_id) ? 'AND l.forum_id = ' . intval($forum_id) : '';
2308 }
2309 break;
2310
2311 case 'user':
2312 $log_type = LOG_USERS;
2313 $sql_forum = 'AND l.reportee_id = ' . (int) $user_id;
2314 break;
2315
2316 case 'users':
2317 $log_type = LOG_USERS;
2318 $sql_forum = '';
2319 break;
2320
2321 case 'critical':
2322 $log_type = LOG_CRITICAL;
2323 $sql_forum = '';
2324 break;
2325
2326 default:
2327 return;
2328 }
2329
2330 $sql = "SELECT l.*, u.username, u.username_clean, u.user_colour
2331 FROM " . LOG_TABLE . " l, " . USERS_TABLE . " u
2332 WHERE l.log_type = $log_type
2333 AND u.user_id = l.user_id
2334 " . (($limit_days) ? "AND l.log_time >= $limit_days" : '') . "
2335 $sql_forum
2336 ORDER BY $sort_by";
2337 $result = phpbb::$db->sql_query_limit($sql, $limit, $offset);
2338
2339 $i = 0;
2340 $log = array();
2341 while ($row = phpbb::$db->sql_fetchrow($result))
2342 {
2343 if ($row['topic_id'])
2344 {
2345 $topic_id_list[] = $row['topic_id'];
2346 }
2347
2348 if ($row['reportee_id'])
2349 {
2350 $reportee_id_list[] = $row['reportee_id'];
2351 }
2352
2353 $log[$i] = array(
2354 'id' => $row['log_id'],
2355
2356 'reportee_id' => $row['reportee_id'],
2357 'reportee_username' => '',
2358 'reportee_username_full'=> '',
2359
2360 'user_id' => $row['user_id'],
2361 'username' => $row['username'],
2362 'username_full' => get_username_string('full', $row['user_id'], $row['username'], $row['user_colour'], false, $profile_url),
2363
2364 'ip' => $row['log_ip'],
2365 'time' => $row['log_time'],
2366 'forum_id' => $row['forum_id'],
2367 'topic_id' => $row['topic_id'],
2368
2369 'viewforum' => ($row['forum_id'] && phpbb::$acl->acl_get('f_read', $row['forum_id'])) ? phpbb::$url->append_sid('viewforum', 'f=' . $row['forum_id']) : false,
2370 'action' => (isset(phpbb::$user->lang[$row['log_operation']])) ? phpbb::$user->lang[$row['log_operation']] : '{' . ucfirst(str_replace('_', ' ', $row['log_operation'])) . '}',
2371 );
2372
2373 if (!empty($row['log_data']))
2374 {
2375 $log_data_ary = unserialize($row['log_data']);
2376
2377 if (isset(phpbb::$user->lang[$row['log_operation']]))
2378 {
2379 // Check if there are more occurrences of % than arguments, if there are we fill out the arguments array
2380 // It doesn't matter if we add more arguments than placeholders
2381 if ((substr_count($log[$i]['action'], '%') - sizeof($log_data_ary)) > 0)
2382 {
2383 $log_data_ary = array_merge($log_data_ary, array_fill(0, substr_count($log[$i]['action'], '%') - sizeof($log_data_ary), ''));
2384 }
2385
2386 $log[$i]['action'] = vsprintf($log[$i]['action'], $log_data_ary);
2387
2388 // If within the admin panel we do not censor text out
2389 if (defined('IN_ADMIN'))
2390 {
2391 $log[$i]['action'] = bbcode_nl2br($log[$i]['action']);
2392 }
2393 else
2394 {
2395 $log[$i]['action'] = bbcode_nl2br(censor_text($log[$i]['action']));
2396 }
2397 }
2398 else
2399 {
2400 $log[$i]['action'] .= '<br />' . implode('', $log_data_ary);
2401 }
2402
2403 /* Apply make_clickable... has to be seen if it is for good. :/
2404 // Seems to be not for the moment, reconsider later...
2405 $log[$i]['action'] = make_clickable($log[$i]['action']);
2406 */
2407 }
2408
2409 $i++;
2410 }
2411 phpbb::$db->sql_freeresult($result);
2412
2413 if (sizeof($topic_id_list))
2414 {
2415 $topic_id_list = array_unique($topic_id_list);
2416
2417 // This query is not really needed if move_topics() updates the forum_id field,
2418 // although it's also used to determine if the topic still exists in the database
2419 $sql = 'SELECT topic_id, forum_id
2420 FROM ' . TOPICS_TABLE . '
2421 WHERE ' . phpbb::$db->sql_in_set('topic_id', array_map('intval', $topic_id_list));
2422 $result = phpbb::$db->sql_query($sql);
2423
2424 $default_forum_id = 0;
2425
2426 while ($row = phpbb::$db->sql_fetchrow($result))
2427 {
2428 if (!$row['forum_id'])
2429 {
2430 if (phpbb::$acl->acl_getf_global('f_read'))
2431 {
2432 if (!$default_forum_id)
2433 {
2434 $sql = 'SELECT forum_id
2435 FROM ' . FORUMS_TABLE . '
2436 WHERE forum_type = ' . FORUM_POST;
2437 $f_result = phpbb::$db->sql_query_limit($sql, 1);
2438 $default_forum_id = (int) phpbb::$db->sql_fetchfield('forum_id', $f_result);
2439 phpbb::$db->sql_freeresult($f_result);
2440 }
2441
2442 $is_auth[$row['topic_id']] = $default_forum_id;
2443 }
2444 }
2445 else
2446 {
2447 if (phpbb::$acl->acl_get('f_read', $row['forum_id']))
2448 {
2449 $is_auth[$row['topic_id']] = $row['forum_id'];
2450 }
2451 }
2452
2453 if (phpbb::$acl->acl_gets('a_', 'm_', $row['forum_id']))
2454 {
2455 $is_mod[$row['topic_id']] = $row['forum_id'];
2456 }
2457 }
2458 phpbb::$db->sql_freeresult($result);
2459
2460 foreach ($log as $key => $row)
2461 {
2462 $log[$key]['viewtopic'] = (isset($is_auth[$row['topic_id']])) ? phpbb::$url->append_sid('viewtopic', 'f=' . $is_auth[$row['topic_id']] . '&amp;t=' . $row['topic_id']) : false;
2463 $log[$key]['viewlogs'] = (isset($is_mod[$row['topic_id']])) ? phpbb::$url->append_sid('mcp', 'i=logs&amp;mode=topic_logs&amp;t=' . $row['topic_id'], true, phpbb::$user->session_id) : false;
2464 }
2465 }
2466
2467 if (sizeof($reportee_id_list))
2468 {
2469 $reportee_id_list = array_unique($reportee_id_list);
2470 $reportee_names_list = array();
2471
2472 $sql = 'SELECT user_id, username, user_colour
2473 FROM ' . USERS_TABLE . '
2474 WHERE ' . phpbb::$db->sql_in_set('user_id', $reportee_id_list);
2475 $result = phpbb::$db->sql_query($sql);
2476
2477 while ($row = phpbb::$db->sql_fetchrow($result))
2478 {
2479 $reportee_names_list[$row['user_id']] = $row;
2480 }
2481 phpbb::$db->sql_freeresult($result);
2482
2483 foreach ($log as $key => $row)
2484 {
2485 if (!isset($reportee_names_list[$row['reportee_id']]))
2486 {
2487 continue;
2488 }
2489
2490 $log[$key]['reportee_username'] = $reportee_names_list[$row['reportee_id']]['username'];
2491 $log[$key]['reportee_username_full'] = get_username_string('full', $row['reportee_id'], $reportee_names_list[$row['reportee_id']]['username'], $reportee_names_list[$row['reportee_id']]['user_colour'], false, $profile_url);
2492 }
2493 }
2494
2495 $sql = 'SELECT COUNT(l.log_id) AS total_entries
2496 FROM ' . LOG_TABLE . " l
2497 WHERE l.log_type = $log_type
2498 AND l.log_time >= $limit_days
2499 $sql_forum";
2500 $result = phpbb::$db->sql_query($sql);
2501 $log_count = (int) phpbb::$db->sql_fetchfield('total_entries');
2502 phpbb::$db->sql_freeresult($result);
2503
2504 return;
2505 }
2506
2507 /**
2508 * Update foes - remove moderators and administrators from foe lists...
2509 */
2510 function update_foes($group_id = false, $user_id = false)
2511 {
2512 // update foes for some user
2513 if (is_array($user_id) && sizeof($user_id))
2514 {
2515 $sql = 'DELETE FROM ' . ZEBRA_TABLE . '
2516 WHERE ' . phpbb::$db->sql_in_set('zebra_id', $user_id) . '
2517 AND foe = 1';
2518 phpbb::$db->sql_query($sql);
2519 return;
2520 }
2521
2522 // update foes for some group
2523 if (is_array($group_id) && sizeof($group_id))
2524 {
2525 // Grab group settings...
2526 $sql = phpbb::$db->sql_build_query('SELECT', array(
2527 'SELECT' => 'a.group_id',
2528
2529 'FROM' => array(
2530 ACL_OPTIONS_TABLE => 'ao',
2531 ACL_GROUPS_TABLE => 'a'
2532 ),
2533
2534 'LEFT_JOIN' => array(
2535 array(
2536 'FROM' => array(ACL_ROLES_DATA_TABLE => 'r'),
2537 'ON' => 'a.auth_role_id = r.role_id'
2538 ),
2539 ),
2540
2541 'WHERE' => '(ao.auth_option_id = a.auth_option_id OR ao.auth_option_id = r.auth_option_id)
2542 AND ' . phpbb::$db->sql_in_set('a.group_id', $group_id) . "
2543 AND ao.auth_option IN ('a_', 'm_')",
2544
2545 'GROUP_BY' => 'a.group_id'
2546 ));
2547 $result = phpbb::$db->sql_query($sql);
2548
2549 $groups = array();
2550 while ($row = phpbb::$db->sql_fetchrow($result))
2551 {
2552 $groups[] = (int) $row['group_id'];
2553 }
2554 phpbb::$db->sql_freeresult($result);
2555
2556 if (!sizeof($groups))
2557 {
2558 return;
2559 }
2560
2561 if (phpbb::$db->features['multi_table_deletion'])
2562 {
2563 $sql = 'DELETE FROM' . ZEBRA_TABLE . ' z
2564 USING ' . USER_GROUP_TABLE . ' ug
2565 WHERE z.zebra_id = ug.user_id
2566 AND z.foe = 1
2567 AND ' . phpbb::$db->sql_in_set('ug.group_id', $groups);
2568 phpbb::$db->sql_query($sql);
2569 }
2570 else
2571 {
2572 $sql = 'SELECT user_id
2573 FROM ' . USER_GROUP_TABLE . '
2574 WHERE ' . phpbb::$db->sql_in_set('group_id', $groups);
2575 $result = phpbb::$db->sql_query($sql);
2576
2577 $users = array();
2578 while ($row = phpbb::$db->sql_fetchrow($result))
2579 {
2580 $users[] = (int) $row['user_id'];
2581 }
2582 phpbb::$db->sql_freeresult($result);
2583
2584 if (sizeof($users))
2585 {
2586 $sql = 'DELETE FROM ' . ZEBRA_TABLE . '
2587 WHERE ' . phpbb::$db->sql_in_set('zebra_id', $users) . '
2588 AND foe = 1';
2589 phpbb::$db->sql_query($sql);
2590 }
2591 }
2592
2593 return;
2594 }
2595
2596 // update foes for everyone
2597 $perms = array();
2598 foreach (phpbb::$acl->acl_get_list(false, array('a_', 'm_'), false) as $forum_id => $forum_ary)
2599 {
2600 foreach ($forum_ary as $auth_option => $user_ary)
2601 {
2602 $perms = array_merge($perms, $user_ary);
2603 }
2604 }
2605
2606 if (sizeof($perms))
2607 {
2608 $sql = 'DELETE FROM ' . ZEBRA_TABLE . '
2609 WHERE ' . phpbb::$db->sql_in_set('zebra_id', array_unique($perms)) . '
2610 AND foe = 1';
2611 phpbb::$db->sql_query($sql);
2612 }
2613 unset($perms);
2614 }
2615
2616 /**
2617 * Lists inactive users
2618 */
2619 function view_inactive_users(&$users, &$user_count, $limit = 0, $offset = 0, $limit_days = 0, $sort_by = 'user_inactive_time DESC')
2620 {
2621 $sql = 'SELECT COUNT(user_id) AS user_count
2622 FROM ' . USERS_TABLE . '
2623 WHERE user_type = ' . phpbb::USER_INACTIVE .
2624 (($limit_days) ? " AND user_inactive_time >= $limit_days" : '');
2625 $result = phpbb::$db->sql_query($sql);
2626 $user_count = (int) phpbb::$db->sql_fetchfield('user_count');
2627 phpbb::$db->sql_freeresult($result);
2628
2629 if ($offset >= $user_count)
2630 {
2631 $offset = ($offset - $limit < 0) ? 0 : $offset - $limit;
2632 }
2633
2634 $sql = 'SELECT user_id, username, user_regdate, user_lastvisit, user_inactive_time, user_inactive_reason
2635 FROM ' . USERS_TABLE . '
2636 WHERE user_type = ' . phpbb::USER_INACTIVE .
2637 (($limit_days) ? " AND user_inactive_time >= $limit_days" : '') . "
2638 ORDER BY $sort_by";
2639 $result = phpbb::$db->sql_query_limit($sql, $limit, $offset);
2640
2641 while ($row = phpbb::$db->sql_fetchrow($result))
2642 {
2643 $row['inactive_reason'] = phpbb::$user->lang['INACTIVE_REASON_UNKNOWN'];
2644 switch ($row['user_inactive_reason'])
2645 {
2646 case INACTIVE_REGISTER:
2647 $row['inactive_reason'] = phpbb::$user->lang['INACTIVE_REASON_REGISTER'];
2648 break;
2649
2650 case INACTIVE_PROFILE:
2651 $row['inactive_reason'] = phpbb::$user->lang['INACTIVE_REASON_PROFILE'];
2652 break;
2653
2654 case INACTIVE_MANUAL:
2655 $row['inactive_reason'] = phpbb::$user->lang['INACTIVE_REASON_MANUAL'];
2656 break;
2657
2658 case INACTIVE_REMIND:
2659 $row['inactive_reason'] = phpbb::$user->lang['INACTIVE_REASON_REMIND'];
2660 break;
2661 }
2662
2663 $users[] = $row;
2664 }
2665
2666 return $offset;
2667 }
2668
2669 /**
2670 * Lists warned users
2671 */
2672 function view_warned_users(&$users, &$user_count, $limit = 0, $offset = 0, $limit_days = 0, $sort_by = 'user_warnings DESC')
2673 {
2674 $sql = 'SELECT user_id, username, user_colour, user_warnings, user_last_warning
2675 FROM ' . USERS_TABLE . '
2676 WHERE user_warnings > 0
2677 ' . (($limit_days) ? "AND user_last_warning >= $limit_days" : '') . "
2678 ORDER BY $sort_by";
2679 $result = phpbb::$db->sql_query_limit($sql, $limit, $offset);
2680 $users = phpbb::$db->sql_fetchrowset($result);
2681 phpbb::$db->sql_freeresult($result);
2682
2683 $sql = 'SELECT count(user_id) AS user_count
2684 FROM ' . USERS_TABLE . '
2685 WHERE user_warnings > 0
2686 ' . (($limit_days) ? "AND user_last_warning >= $limit_days" : '');
2687 $result = phpbb::$db->sql_query($sql);
2688 $user_count = (int) phpbb::$db->sql_fetchfield('user_count');
2689 phpbb::$db->sql_freeresult($result);
2690
2691 return;
2692 }
2693
2694 /**
2695 * Get database size
2696 */
2697 function get_database_size()
2698 {
2699 $database_size = false;
2700
2701 // This code is heavily influenced by a similar routine in phpMyAdmin 2.2.0
2702 switch (phpbb::$db->dbms_type)
2703 {
2704 case 'mysql':
2705 $sql = 'SELECT VERSION() AS mysql_version';
2706 $result = phpbb::$db->sql_query($sql);
2707 $row = phpbb::$db->sql_fetchrow($result);
2708 phpbb::$db->sql_freeresult($result);
2709
2710 if ($row)
2711 {
2712 $version = $row['mysql_version'];
2713
2714 if (preg_match('#(3\.23|[45]\.)#', $version))
2715 {
2716 $db_name = (preg_match('#^(?:3\.23\.(?:[6-9]|[1-9]{2}))|[45]\.#', $version)) ? "`" . phpbb::$db->dbname . "`" : phpbb::$db->dbname;
2717
2718 $sql = 'SHOW TABLE STATUS
2719 FROM ' . $db_name;
2720 $result = phpbb::$db->sql_query($sql, 7200);
2721
2722 $database_size = 0;
2723 while ($row = phpbb::$db->sql_fetchrow($result))
2724 {
2725 if ((isset($row['Type']) && $row['Type'] != 'MRG_MyISAM') || (isset($row['Engine']) && ($row['Engine'] == 'MyISAM' || $row['Engine'] == 'InnoDB')))
2726 {
2727 if (phpbb::$base_config['table_prefix'] != '')
2728 {
2729 if (strpos($row['Name'], phpbb::$base_config['table_prefix']) !== false)
2730 {
2731 $database_size += $row['Data_length'] + $row['Index_length'];
2732 }
2733 }
2734 else
2735 {
2736 $database_size += $row['Data_length'] + $row['Index_length'];
2737 }
2738 }
2739 }
2740 phpbb::$db->sql_freeresult($result);
2741 }
2742 }
2743 break;
2744
2745 case 'firebird':
2746 global $dbname;
2747
2748 // if it on the local machine, we can get lucky
2749 if (file_exists($dbname))
2750 {
2751 $database_size = filesize($dbname);
2752 }
2753
2754 break;
2755
2756 case 'sqlite':
2757 global $dbhost;
2758
2759 if (file_exists($dbhost))
2760 {
2761 $database_size = filesize($dbhost);
2762 }
2763
2764 break;
2765
2766 case 'mssql':
2767 $sql = 'SELECT ((SUM(size) * 8.0) * 1024.0) as dbsize
2768 FROM sysfiles';
2769 $result = phpbb::$db->sql_query($sql, 7200);
2770 $database_size = ($row = phpbb::$db->sql_fetchrow($result)) ? $row['dbsize'] : false;
2771 phpbb::$db->sql_freeresult($result);
2772 break;
2773
2774 case 'postgres':
2775 $sql = "SELECT proname
2776 FROM pg_proc
2777 WHERE proname = 'pg_database_size'";
2778 $result = phpbb::$db->sql_query($sql);
2779 $row = phpbb::$db->sql_fetchrow($result);
2780 phpbb::$db->sql_freeresult($result);
2781
2782 if ($row['proname'] == 'pg_database_size')
2783 {
2784 $database = phpbb::$db->dbname;
2785 if (strpos($database, '.') !== false)
2786 {
2787 list($database, ) = explode('.', $database);
2788 }
2789
2790 $sql = "SELECT oid
2791 FROM pg_database
2792 WHERE datname = '$database'";
2793 $result = phpbb::$db->sql_query($sql);
2794 $row = phpbb::$db->sql_fetchrow($result);
2795 phpbb::$db->sql_freeresult($result);
2796
2797 $oid = $row['oid'];
2798
2799 $sql = 'SELECT pg_database_size(' . $oid . ') as size';
2800 $result = phpbb::$db->sql_query($sql);
2801 $row = phpbb::$db->sql_fetchrow($result);
2802 phpbb::$db->sql_freeresult($result);
2803
2804 $database_size = $row['size'];
2805 }
2806 break;
2807
2808 case 'oracle':
2809 $sql = 'SELECT SUM(bytes) as dbsize
2810 FROM user_segments';
2811 $result = phpbb::$db->sql_query($sql, 7200);
2812 $database_size = ($row = phpbb::$db->sql_fetchrow($result)) ? $row['dbsize'] : false;
2813 phpbb::$db->sql_freeresult($result);
2814 break;
2815 }
2816
2817 $database_size = ($database_size !== false) ? get_formatted_filesize($database_size) : phpbb::$user->lang['NOT_AVAILABLE'];
2818
2819 return $database_size;
2820 }
2821
2822 /**
2823 * Retrieve contents from remotely stored file
2824 */
2825 function get_remote_file($host, $directory, $filename, &$errstr, &$errno, $port = 80, $timeout = 10)
2826 {
2827 if ($fsock = @fsockopen($host, $port, $errno, $errstr, $timeout))
2828 {
2829 @fputs($fsock, "GET $directory/$filename HTTP/1.1\r\n");
2830 @fputs($fsock, "HOST: $host\r\n");
2831 @fputs($fsock, "Connection: close\r\n\r\n");
2832
2833 $file_info = '';
2834 $get_info = false;
2835
2836 while (!@feof($fsock))
2837 {
2838 if ($get_info)
2839 {
2840 $file_info .= @fread($fsock, 1024);
2841 }
2842 else
2843 {
2844 $line = @fgets($fsock, 1024);
2845 if ($line == "\r\n")
2846 {
2847 $get_info = true;
2848 }
2849 else if (stripos($line, '404 not found') !== false)
2850 {
2851 $errstr = phpbb::$user->lang['FILE_NOT_FOUND'] . ': ' . $filename;
2852 return false;
2853 }
2854 }
2855 }
2856 @fclose($fsock);
2857 }
2858 else
2859 {
2860 if ($errstr)
2861 {
2862 $errstr = utf8_convert_message($errstr);
2863 return false;
2864 }
2865 else
2866 {
2867 $errstr = phpbb::$user->lang['FSOCK_DISABLED'];
2868 return false;
2869 }
2870 }
2871
2872 return $file_info;
2873 }
2874
2875 /**
2876 * Tidy Warnings
2877 * Remove all warnings which have now expired from the database
2878 * The duration of a warning can be defined by the administrator
2879 * This only removes the warning and reduces the associated count,
2880 * it does not remove the user note recording the contents of the warning
2881 */
2882 function tidy_warnings()
2883 {
2884 $expire_date = time() - (phpbb::$config['warnings_expire_days'] * 86400);
2885 $warning_list = $user_list = array();
2886
2887 $sql = 'SELECT * FROM ' . WARNINGS_TABLE . "
2888 WHERE warning_time < $expire_date";
2889 $result = phpbb::$db->sql_query($sql);
2890
2891 while ($row = phpbb::$db->sql_fetchrow($result))
2892 {
2893 $warning_list[] = $row['warning_id'];
2894 $user_list[$row['user_id']] = isset($user_list[$row['user_id']]) ? ++$user_list[$row['user_id']] : 1;
2895 }
2896 phpbb::$db->sql_freeresult($result);
2897
2898 if (sizeof($warning_list))
2899 {
2900 phpbb::$db->sql_transaction('begin');
2901
2902 $sql = 'DELETE FROM ' . WARNINGS_TABLE . '
2903 WHERE ' . phpbb::$db->sql_in_set('warning_id', $warning_list);
2904 phpbb::$db->sql_query($sql);
2905
2906 foreach ($user_list as $user_id => $value)
2907 {
2908 $sql = 'UPDATE ' . USERS_TABLE . " SET user_warnings = user_warnings - $value
2909 WHERE user_id = $user_id";
2910 phpbb::$db->sql_query($sql);
2911 }
2912
2913 phpbb::$db->sql_transaction('commit');
2914 }
2915
2916 set_config('warnings_last_gc', time(), true);
2917 }
2918
2919 /**
2920 * Tidy database, doing some maintanance tasks
2921 */
2922 function tidy_database()
2923 {
2924 // Here we check permission consistency
2925
2926 // Sometimes, it can happen permission tables having forums listed which do not exist
2927 $sql = 'SELECT forum_id
2928 FROM ' . FORUMS_TABLE;
2929 $result = phpbb::$db->sql_query($sql);
2930
2931 $forum_ids = array(0);
2932 while ($row = phpbb::$db->sql_fetchrow($result))
2933 {
2934 $forum_ids[] = $row['forum_id'];
2935 }
2936 phpbb::$db->sql_freeresult($result);
2937
2938 // Delete those rows from the acl tables not having listed the forums above
2939 $sql = 'DELETE FROM ' . ACL_GROUPS_TABLE . '
2940 WHERE ' . phpbb::$db->sql_in_set('forum_id', $forum_ids, true);
2941 phpbb::$db->sql_query($sql);
2942
2943 $sql = 'DELETE FROM ' . ACL_USERS_TABLE . '
2944 WHERE ' . phpbb::$db->sql_in_set('forum_id', $forum_ids, true);
2945 phpbb::$db->sql_query($sql);
2946
2947 set_config('database_last_gc', time(), true);
2948 }
2949
2950 /**
2951 * Add permission language - this will make sure custom files will be included
2952 */
2953 function add_permission_language()
2954 {
2955 // First of all, our own file. We need to include it as the first file because it presets all relevant variables.
2956 phpbb::$user->add_lang('acp/permissions_phpbb');
2957
2958 $files_to_add = array();
2959
2960 // Now search in acp and mods folder for permissions_ files.
2961 foreach (array('acp/', 'mods/') as $path)
2962 {
2963 $dh = @opendir(phpbb::$user->lang_path . phpbb::$user->lang_name . '/' . $path);
2964
2965 if ($dh)
2966 {
2967 while (($file = readdir($dh)) !== false)
2968 {
2969 if ($file !== 'permissions_phpbb.' . PHP_EXT && strpos($file, 'permissions_') === 0 && substr($file, -(strlen(PHP_EXT) + 1)) === '.' . PHP_EXT)
2970 {
2971 $files_to_add[] = $path . substr($file, 0, -(strlen(PHP_EXT) + 1));
2972 }
2973 }
2974 closedir($dh);
2975 }
2976 }
2977
2978 if (!sizeof($files_to_add))
2979 {
2980 return false;
2981 }
2982
2983 phpbb::$user->add_lang($files_to_add);
2984 return true;
2985 }
2986
2987 /**
2988 * Upload files or let the user download them as appropriate
2989 */
2990 function process_transfer($module_url, $update_list, $new_location, $download_filename)
2991 {
2992 // todo: add $s_hidden_fields as a parameter to this function
2993 $s_hidden_fields = '';
2994
2995 if (request_var('download', false))
2996 {
2997 $use_method = request_var('use_method', '');
2998 $methods = array('.tar');
2999
3000 $available_methods = array('.tar.gz' => 'zlib', '.tar.bz2' => 'bz2', '.zip' => 'zlib');
3001 foreach ($available_methods as $type => $module)
3002 {
3003 if (!@extension_loaded($module))
3004 {
3005 continue;
3006 }
3007
3008 $methods[] = $type;
3009 }
3010
3011 // Let the user decide in which format he wants to have the pack
3012 if (!$use_method)
3013 {
3014 $radio_buttons = '';
3015 foreach ($methods as $method)
3016 {
3017 $radio_buttons .= '<label><input type="radio"' . ((!$radio_buttons) ? ' id="use_method"' : '') . ' class="radio" value="' . $method . '" name="use_method" /> ' . $method . '</label>';
3018 }
3019
3020 phpbb::$template->assign_vars(array(
3021 'S_DOWNLOAD_FILES' => true,
3022 'U_ACTION' => append_sid($module_url),
3023 'RADIO_BUTTONS' => $radio_buttons,
3024 'S_HIDDEN_FIELDS' => $s_hidden_fields)
3025 );
3026
3027 // To ease the update process create a file location map
3028 $script_path = (phpbb::$config['force_server_vars']) ? ((phpbb::$config['script_path'] == '/') ? '/' : phpbb::$config['script_path'] . '/') : phpbb::$user->page['root_script_path'];
3029
3030 foreach ($update_list as $status => $files)
3031 {
3032 if ($status == 'up_to_date' || $status == 'no_update' || $status == 'status')
3033 {
3034 continue;
3035 }
3036
3037 foreach ($files as $file_struct)
3038 {
3039 phpbb::$template->assign_block_vars('location', array(
3040 'SOURCE' => htmlspecialchars($file_struct['filename']),
3041 'DESTINATION' => $script_path . htmlspecialchars($file_struct['filename']),
3042 ));
3043 }
3044 }
3045 return 'SELECT_DOWNLOAD_FORMAT';
3046 }
3047
3048 if (!in_array($use_method, $methods))
3049 {
3050 $use_method = '.tar';
3051 }
3052
3053 $update_mode = 'download';
3054 }
3055 else
3056 {
3057 // Choose FTP, if not available use fsock...
3058 $method = basename(request_var('method', ''));
3059 $submit = phpbb_request::is_set_post('update');
3060 $test_ftp_connection = request_var('test_connection', '');
3061
3062 if (!$method || !class_exists($method))
3063 {
3064 $method = 'ftp';
3065 $methods = transfer::methods();
3066
3067 if (!in_array('ftp', $methods))
3068 {
3069 $method = $methods[0];
3070 }
3071 }
3072
3073 $test_connection = false;
3074 if ($test_ftp_connection || $submit)
3075 {
3076 $transfer = new $method(request_var('host', ''), request_var('username', ''), request_var('password', ''), request_var('root_path', ''), request_var('port', ''), request_var('timeout', ''));
3077 $test_connection = $transfer->open_session();
3078
3079 // Make sure that the directory is correct by checking for the existence of common.php
3080 if ($test_connection === true)
3081 {
3082 // Check for common.php file
3083 if (!$transfer->file_exists(PHPBB_ROOT_PATH, 'common.' . PHP_EXT))
3084 {
3085 $test_connection = 'ERR_WRONG_PATH_TO_PHPBB';
3086 }
3087 }
3088
3089 $transfer->close_session();
3090
3091 // Make sure the login details are correct before continuing
3092 if ($submit && $test_connection !== true)
3093 {
3094 $submit = false;
3095 $test_ftp_connection = true;
3096 }
3097 }
3098
3099 $s_hidden_fields .= build_hidden_fields(array('method' => $method));
3100
3101 if (!$submit)
3102 {
3103 if (!class_exists($method))
3104 {
3105 trigger_error('Method does not exist.', E_USER_ERROR);
3106 }
3107
3108 $requested_data = call_user_func(array($method, 'data'));
3109 foreach ($requested_data as $data => $default)
3110 {
3111 phpbb::$template->assign_block_vars('data', array(
3112 'DATA' => $data,
3113 'NAME' => phpbb::$user->lang[strtoupper($method . '_' . $data)],
3114 'EXPLAIN' => phpbb::$user->lang[strtoupper($method . '_' . $data) . '_EXPLAIN'],
3115 'DEFAULT' => (request_var($data, false)) ? request_var($data, '') : $default
3116 ));
3117 }
3118
3119 phpbb::$template->assign_vars(array(
3120 'S_CONNECTION_SUCCESS' => ($test_ftp_connection && $test_connection === true) ? true : false,
3121 'S_CONNECTION_FAILED' => ($test_ftp_connection && $test_connection !== true) ? true : false,
3122 'ERROR_MSG' => ($test_ftp_connection && $test_connection !== true) ? phpbb::$user->lang[$test_connection] : '',
3123
3124 'S_FTP_UPLOAD' => true,
3125 'UPLOAD_METHOD' => $method,
3126 'U_ACTION' => $module_url,
3127 'U_DOWNLOAD_METHOD' => $module_url . '&amp;download=1',
3128 'S_HIDDEN_FIELDS' => $s_hidden_fields,
3129 ));
3130
3131 return 'SELECT_FTP_SETTINGS';
3132 }
3133
3134 $update_mode = 'upload';
3135 }
3136
3137 // Now init the connection
3138 if ($update_mode == 'download')
3139 {
3140 // Now update the installation or download the archive...
3141 $archive_filename = $download_filename . '_' . time() . '_' . unique_id();
3142
3143 if ($use_method == '.zip')
3144 {
3145 $compress = new compress_zip('w', PHPBB_ROOT_PATH . 'store/' . $archive_filename . $use_method);
3146 }
3147 else
3148 {
3149 $compress = new compress_tar('w', PHPBB_ROOT_PATH . 'store/' . $archive_filename . $use_method, $use_method);
3150 }
3151 }
3152 else
3153 {
3154 $transfer = new $method(request_var('host', ''), request_var('username', ''), request_var('password', ''), request_var('root_path', ''), request_var('port', ''), request_var('timeout', ''));
3155 $transfer->open_session();
3156 }
3157
3158 // Ok, go through the update list and do the operations based on their status
3159 foreach ($update_list as $status => $files)
3160 {
3161 if (!is_array($files))
3162 {
3163 continue;
3164 }
3165
3166 foreach ($files as $file_struct)
3167 {
3168 $original_filename = ($file_struct['custom']) ? $file_struct['original'] : $file_struct['filename'];
3169
3170 switch ($status)
3171 {
3172 case 'new':
3173 case 'new_conflict':
3174 case 'not_modified':
3175
3176 if ($update_mode == 'download')
3177 {
3178 $compress->add_custom_file($new_location . $original_filename, $file_struct['filename']);
3179 }
3180 else
3181 {
3182 if ($status != 'new')
3183 {
3184 $transfer->rename($file_struct['filename'], $file_struct['filename'] . '.bak');
3185 }
3186
3187 // New directory too?
3188 $dirname = dirname($file_struct['filename']);
3189
3190 if ($dirname && !file_exists(PHPBB_ROOT_PATH . $dirname))
3191 {
3192 $transfer->make_dir($dirname);
3193 }
3194
3195 $transfer->copy_file($new_location . $original_filename, $file_struct['filename']);
3196 }
3197 break;
3198
3199 case 'modified':
3200
3201 $contents = base64_decode($cache->get($file_list[$file_struct['filename']]));
3202
3203 if ($update_mode == 'download')
3204 {
3205 $compress->add_data($contents, $file_struct['filename']);
3206 }
3207 else
3208 {
3209 // @todo add option to specify if a backup file should be created?
3210 $transfer->rename($file_struct['filename'], $file_struct['filename'] . '.bak');
3211 $transfer->write_file($file_struct['filename'], $contents);
3212 }
3213 break;
3214
3215 case 'conflict':
3216
3217 $contents = base64_decode($cache->get($file_list[$file_struct['filename']]));
3218
3219 if ($update_mode == 'download')
3220 {
3221 $compress->add_data($contents, $file_struct['filename']);
3222 }
3223 else
3224 {
3225 $transfer->rename($file_struct['filename'], $file_struct['filename'] . '.bak');
3226 $transfer->write_file($file_struct['filename'], $contents);
3227 }
3228 break;
3229 }
3230 }
3231 }
3232
3233 if ($update_mode == 'download')
3234 {
3235 $compress->close();
3236
3237 $compress->download($archive_filename, $download_filename);
3238 @unlink(PHPBB_ROOT_PATH . 'store/' . $archive_filename . $use_method);
3239
3240 exit;
3241 }
3242 else
3243 {
3244 $transfer->close_session();
3245
3246 phpbb::$template->assign_var('S_UPLOAD_SUCCESS', true);
3247 return;
3248 }
3249 }
3250
3251 ?>
phpbb is a php-based BBS (buletin board system)