-<?php

-define('IN_PHPBB', true);

-define('PHPBB_ROOT_PATH', './../');

-define('PHP_EXT', substr(strrchr(__FILE__, '.'), 1));

-include(PHPBB_ROOT_PATH . 'common.' . PHP_EXT);

-

-//$db = new dbal_mysqli();

-

-class posting_api

-{

- /*

- topic table:

- topic_id

- forum_id

- topic_title

- topic_status

- topic_type

- topic_shadow_id // to implement

-

- sec:

- topic_posts

- topic_shadow_posts

- topic_deleted_posts

- topic_unapproved_posts

-

- all must be approved:

- topic_poster

- topic_first_poster_name

- topic_first_poster_id

- topic_last_post_id

- topic_last_poster_name

- topic_last_poster_id

- topic_last_post_title

- topic_last_post_time

- */

-

- /*

- post table:

- post_id

- topic_id

- post_subject

- post_body

- post_status

- post_type

- post_username

- poster_id

- forum_id

- post_time

-

- /*

- forum table:

- forum_id

- forum_posts

- forum_shadow_posts

- forum_deleted_posts

- forum_unapproved_posts

-

- sec:

- forum_topics

- forum_shadow_topics

- forum_deleted_topics

- forum_unapproved_topics

-

- forum_last_poster_name

- forum_last_user_id

- forum_last_post_title

- forum_last_post_time

- */

-

- const NORMAL = 0;

-

- // status

- const UNAPPROVED = 1;

- const DELETED = 2;

-

- // type

- const ANNOUNCEMENT = 1;

- const STICKY = 2;

-

- // we, for now, only support the insertion of posts that are not already

- // shadow'd and not deleted (it must first exist for it to be shadow'd or deleted!)

- static function insert_topic($data)

- {

- // one transaction, we can now garuntee that atomicity of insertions

- phpbb::$db->sql_transaction('begin');

-

- $user_id = (int) $data['user_id'];

- $forum_id = (int) $data['forum_id'];

- $topic_title = $data['title'];

- $post_contents = $data['post_contents'];

- $topic_status = (int) $data['status'];

- $topic_type = (int) $data['type'];

- $approved = (bool) $data['approved'];

-

- $shadow_forums = $data['shadow_forums'];

-

- $time = ($data['time']) ? (int) $data['time'] : time();

-

- if (isset($data['username']))

- {

- $username = $data['username'];

- }

- else

- {

- $sql = 'SELECT username

- FROM ' . USERS_TABLE . '

- WHERE user_id = ' . $user_id;

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

- $username = (string) phpbb::$db->sql_fetchfield('username');

- phpbb::$db->sql_freeresult($result);

- }

-

- $sql = 'SELECT forum_topics, forum_unapproved_topics, forum_posts, forum_unapproved_posts

- FROM ' . FORUMS_TABLE . '

- WHERE forum_id = ' . (int) $forum_id;

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

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

- phpbb::$db->sql_freeresult($result);

-

- // throw our topic to the dogs

- $topic_data = array(

- 'topic_title' => $topic_title,

- 'topic_status' => $topic_status,

- 'topic_type' => $topic_type,

- 'topic_posts' => 1,

- 'topic_shadow_posts' => 0,

- 'topic_deleted_posts' => 0,

- 'topic_unapproved_posts' => ($approved) ? 0 : 1,

- 'topic_first_poster_name' => $username,

- 'topic_poster' => $user_id,

- 'topic_last_username' => $username,

- 'topic_last_post_title' => $topic_title,

- 'topic_last_post_time' => $time,

- 'topic_last_poster_id' => $user_id,

- 'forum_id' => $forum_id

- );

-

- phpbb::$db->sql_handle_data('INSERT', TOPICS_TABLE, $topic_data);

- $topic_id = phpbb::$db->sql_nextid();

-

- // I suppose it is time to make us a post, no?

- $post_data = array(

- 'topic_id' => $topic_id,

- 'post_subject' => $topic_title,

- 'post_body' => $post_contents,

- 'post_username' => $username,

- 'poster_id' => $user_id,

- 'post_status' => $topic_status, // first post inherits its type from the topic

- 'post_type' => self::NORMAL, // for now, there are no shadow, global or sticky posts

- 'forum_id' => $forum_id

- );

-

- phpbb::$db->sql_handle_data('INSERT', POSTS_TABLE, $post_data);

- $post_id = phpbb::$db->sql_nextid();

-

- // time to fill in the blanks

- phpbb::$db->sql_handle_data('UPDATE', TOPICS_TABLE, array('topic_first_post_id' => $post_id, 'topic_last_post_id' => $post_id), "topic_id = $topic_id");

-

- // let's go update the forum table

- $forum_data = array(

- 'forum_posts' => ++$row['forum_posts'],

- 'forum_topics' => ++$row['forum_topics'],

- );

-

- // the last post inserted is always the latest,

- // we must update the forum records to make sure everybody knows the good news

- if ($approved)

- {

- $forum_data['forum_last_poster_name'] = $username;

- $forum_data['forum_last_user_id'] = $user_id;

- $forum_data['forum_last_post_title'] = $topic_title;

- $forum_data['forum_last_post_time'] = $time;

- }

- else

- {

- $forum_data['forum_unapproved_posts'] = ++$row['forum_unapproved_posts'];

- $forum_data['forum_unapproved_topics'] = ++$row['forum_unapproved_topics'];

- }

-

- phpbb::$db->sql_handle_data('UPDATE', FORUMS_TABLE, $forum_data, "forum_id = $forum_id");

-

- foreach ($shadow_forums as $shadow_forum_id)

- {

- $data['shadow_topic_id'] = $topic_id;

- $data['forum_id'] = $shadow_forum_id;

- self::insert_shadow_topic($data);

- }

-

- // we are consistant, victory is ours

- phpbb::$db->sql_transaction('commit');

- }

-

- // inserts a shadow topic into the database

- static function insert_shadow_topic($data)

- {

- // one transaction, we can now garuntee that atomicity of insertions

- phpbb::$db->sql_transaction('begin');

-

- $user_id = (int) $data['user_id'];

- $forum_id = (int) $data['forum_id'];

- $topic_title = $data['title'];

- $topic_status = (int) $data['status'];

- $topic_type = (int) $data['type'];

- $time = ($data['time']) ? (int) $data['time'] : time();

- $shadow_topic_id = (int) $data['shadow_topic_id'];

- $approved = (bool) $data['approved'];

-

- if (isset($data['username']))

- {

- $username = $data['username'];

- }

- else

- {

- $sql = 'SELECT username

- FROM ' . USERS_TABLE . '

- WHERE user_id = ' . $user_id;

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

- $username = (stromg) phpbb::$db->sql_fetchfield('username');

- phpbb::$db->sql_freeresult($result);

- }

-

- $sql = 'SELECT forum_topics, forum_shadow_topics

- FROM ' . FORUMS_TABLE . '

- WHERE forum_id = ' . (int) $forum_id;

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

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

- phpbb::$db->sql_freeresult($result);

-

- // throw our topic to the dogs

- $topic_data = array(

- 'topic_title' => $topic_title,

- 'topic_status' => $topic_status,

- 'topic_type' => $topic_type,

- 'topic_posts' => 0,

- 'topic_shadow_posts' => 0,

- 'topic_deleted_posts' => 0,

- 'topic_unapproved_posts' => ($approved ? 0 : 1),

- 'topic_first_poster_name' => $username,

- 'topic_poster' => $user_id,

- 'topic_last_username' => $username,

- 'topic_last_post_title' => $topic_title,

- 'topic_last_post_time' => $time,

- 'topic_last_poster_id' => $user_id,

- 'forum_id' => $forum_id,

- 'topic_shadow_id' => $shadow_topic_id

- );

-

- phpbb::$db->sql_handle_data('INSERT', TOPICS_TABLE, $topic_data);

-

- // let's go update the forum table

- $forum_data = array(

- 'forum_topics' => ++$row['forum_topics'],

- 'forum_shadow_topics' => ++$row['forum_shadow_topics']

- );

-

- // an unapproved shadow topic? I suppose...

- if (!$approved)

- {

- $forum_data['forum_unapproved_topics'] = ++$row['forum_unapproved_topics'];

- }

-

- phpbb::$db->sql_handle_data('UPDATE', FORUMS_TABLE, $forum_data, "forum_id = $forum_id");

-

- // we are consistant, victory is ours

- phpbb::$db->transaction('END');

- }

-

- static function insert_post($data)

- {

- // one transaction, we can now garuntee that atomicity of insertions

- phpbb::$db->transaction('BEGIN');

-

- $user_id = (int) $data['user_id'];

- $topic_id = (int) $data['topic_id'];

-

- // begin massive amounts of hand holding

-

- if (isset($data['forum_id']))

- {

- $forum_id = (int) $data['forum_id'];

- }

- else

- {

- $sql = 'SELECT forum_id

- FROM ' . TOPICS_TABLE . '

- WHERE topic_id = ' . $topic_id;

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

- $forum_id = (int) phpbb::$db->sql_fetchfield('forum_id');

- phpbb::$db->sql_freeresult($result);

- }

-

- $post_title = $data['title'];

- $post_contents = $data['post_contents'];

- $time = ($data['time']) ? (int) $data['time'] : time();

-

- if (isset($data['username']))

- {

- $username = $data['username'];

- }

- else

- {

- $sql = 'SELECT username

- FROM ' . USERS_TABLE . '

- WHERE user_id = ' . $user_id;

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

- $username = (string) phpbb::$db->sql_fetchfield('username');

- phpbb::$db->sql_freeresult($result);

- }

-

- // hand holding complete, lets write some posts

-

- $sql = 'SELECT forum_topics, forum_unapproved_topics, forum_posts, forum_unapproved_posts

- FROM ' . FORUMS_TABLE . '

- WHERE forum_id = ' . (int) $forum_id;

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

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

- phpbb::$db->sql_freeresult($result);

-

- $post_status = (int) $data['post_status'];

- $approved = ($post_status === self::NORMAL);

-

- // I suppose it is time to make us a post, no?

- $post_data = array(

- 'topic_id' => $topic_id,

- 'post_subject' => $post_title,

- 'post_body' => $post_contents,

- 'post_username' => $username,

- 'poster_id' => $user_id,

- 'post_status' => $post_status,

- 'forum_id' => $forum_id,

- );

- phpbb::$db->sql_handle_data('INSERT', POSTS_TABLE, $post_data);

-

- // what is the new post_id?

- $post_id = phpbb::$db->sql_nextid();

-

- // iceberg ahead! we must only update the topic information if the post is approved ;)

- if ($approved)

- {

- // time to fill in the blanks

- $topics_data = array(

- 'topic_last_poster_id' => $user_id,

- 'topic_last_post_id' => $post_id,

- 'topic_last_poster_name'=> $username,

- 'topic_last_post_title' => $post_title,

- 'topic_last_post_time' => $time,

- );

- phpbb::$db->sql_handle_data('UPDATE', TOPICS_TABLE, $topics_data, "topic_id = $topic_id");

- }

-

- // let's go update the forum table

- $forum_data = array(

- 'forum_posts' => ++$row['forum_posts'],

- );

-

- // the last post inserted is always the latest,

- // we must update the forum records to make sure everybody knows the good news

- if ($approved)

- {

- $forum_data['forum_last_poster_name'] = $username;

- $forum_data['forum_last_user_id'] = $user_id;

- $forum_data['forum_last_post_title'] = $post_title;

- $forum_data['forum_last_post_time'] = $time;

- }

- else

- {

- $forum_data['forum_unapproved_posts'] = ++$row['forum_unapproved_posts'];

- }

-

- phpbb::$db->sql_handle_data('UPDATE', FORUMS_TABLE, $forum_data, "forum_id = $forum_id");

-

- // we are consistant, victory is ours

- phpbb::$db->sql_transaction('commit');

- }

-

- static function delete_topic($data)

- {

- // just call the more powerful variant with just one topic :)

- self::delete_topics(array('topic_ids' => array($data['topic_id'])));

- }

-

- static function delete_topics($data)

- {

- // lets get this party started

- phpbb::$db->sql_transaction('begin');

-

- $topic_ids = array_map('intval', $data['topic_ids']);

-

- // what kind of topic is this? lets find out how much we must tamper with the forum table...

- // TODO: investigate how aggregate functions can speed this up/reduce the number of results returned/misc. other benefits

- $sql = 'SELECT topic_posts, topic_shadow_posts, topic_deleted_posts, topic_unapproved_posts, topic_shadow_id, forum_id, topic_status

- FROM ' . TOPICS_TABLE . '

- WHERE ' . phpbb::$db->sql_in_set('topic_id', $topic_ids);

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

- // the following in an array, key'd by forum id that refers to topic rows

- $forum_lookup = array();

- while ($topic_row = phpbb::$db->sql_fetchrow($result))

- {

- $forum_id = (int) $topic_row['forum_id'];

-

- // deal with posts

- $forum_lookup[$forum_id]['forum_posts'] += $topic_row['topic_posts'];

- $forum_lookup[$forum_id]['forum_shadow_posts'] += $topic_row['topic_shadow_posts'];

- $forum_lookup[$forum_id]['forum_deleted_posts'] += $topic_row['topic_deleted_posts'];

- $forum_lookup[$forum_id]['forum_unapproved_posts'] += $topic_row['topic_unapproved_posts'];

-

- // deal with topics

- $topic_status = (int) $topic_row['topic_status'];

- $forum_lookup[$forum_id]['forum_topics']++; // a topic is a topic

- $forum_lookup[$forum_id]['forum_shadow_topics'] += ($topic_row['topic_shadow_id'] != 0);

- $forum_lookup[$forum_id]['forum_deleted_topics'] += ($topic_status & self::DELETED);

- $forum_lookup[$forum_id]['forum_unapproved_topics'] += ($topic_status & self::UNAPPROVED);

- }

- phpbb::$db->sql_freeresult($result);

-

- // goodnight, topics

- phpbb::$db->sql_query('DELETE FROM ' . TOPICS_TABLE . ' WHERE ' . phpbb::$db->sql_in_set('topic_id', $topic_ids));

-

- // goodnight, posts

- phpbb::$db->sql_query('DELETE FROM ' . POSTS_TABLE . ' WHERE ' . phpbb::$db->sql_in_set('topic_id', $topic_ids));

-

- $forum_ids = array_keys($forum_lookup);

-

- // what kind of topic is this? lets find out how much we must tamper with the forum table...

- $sql = 'SELECT forum_posts, forum_shadow_posts, forum_deleted_posts, forum_unapproved_posts, forum_id

- FROM ' . FORUMS_TABLE . '

- WHERE ' . phpbb::$db->sql_in_set('forum_id', $forum_ids);

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

- $forum_rows = array();

- while ($forum_row = phpbb::$db->sql_fetchrow($result))

- {

- $forum_id = (int) $forum_row['forum_id'];

- $forum_rows[$forum_id] = $forum_row;

- }

- phpbb::$db->sql_freeresult($result);

-

- $shadow_topic_ids = array();

- foreach ($forum_rows as $forum_id => $forum_row)

- {

- $topic_row = $forum_lookup[$forum_id];

- $forum_array = array(

- 'forum_posts' => max($forum_row['forum_posts'] - $topic_row['forum_posts'], 0),

- 'forum_shadow_posts' => max($forum_row['forum_shadow_posts'] - $topic_row['forum_shadow_posts'], 0),

- 'forum_deleted_posts' => max($forum_row['forum_deleted_posts'] - $topic_row['forum_deleted_posts'], 0),

- 'forum_unapproved_posts' => max($forum_row['forum_unapproved_posts'] - $topic_row['forum_unapproved_posts'], 0),

-

- 'forum_topics' => max($forum_row['forum_topics'] - $topic_row['forum_topics'], 0),

- 'forum_shadow_topics' => max($forum_row['forum_shadow_topics'] - $topic_row['forum_shadow_topics'], 0),

- 'forum_deleted_topics' => max($forum_row['forum_deleted_topics'] - $topic_row['forum_deleted_topics'], 0),

- 'forum_unapproved_topics' => max($forum_row['forum_unapproved_topics'] - $topic_row['forum_unapproved_topics'], 0),

- );

-

- // get the last "normal" post in the forum, we _must_ update it

- $sql = 'SELECT MAX(post_id) as max_post_id

- FROM ' . POSTS_TABLE . '

- WHERE post_status = ' . self::NORMAL . '

- AND forum_id = ' . $forum_id;

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

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

- phpbb::$db->sql_freeresult($result);

-

- // anything left?

- if ($row)

- {

- // OK, lets go do some magick

- $sql = 'SELECT post_username, poster_id, post_subject, post_time

- FROM '. POSTS_TABLE . '

- WHERE post_id = ' . (int) $row['max_post_id'];

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

- $last_post = phpbb::$db->sql_fetchrow($result);

- phpbb::$db->sql_freeresult($result);

-

- $forum_array['forum_last_user_id'] = (int) $last_post['poster_id'];

- $forum_array['forum_last_poster_name'] = $last_post['post_username'];

- $forum_array['forum_last_post_title'] = $last_post['post_subject'];

- $forum_array['forum_last_post_time'] = (int) $last_post['post_time'];

- }

- else

- {

- // reset forum state

- $forum_array['forum_last_user_id'] = 0;

- $forum_array['forum_last_poster_name'] = '';

- $forum_array['forum_last_post_title'] = '';

- $forum_array['forum_last_post_time'] = 0;

- }

-

- phpbb::$db->sql_handle_data('UPDATE', FORUMS_TABLE, $forum_array, "forum_id = $forum_id");

- }

-

- // let's not get too hasty, we can kill off the shadows later,

- // instead we compose a list of all shadows and then efficiently kill them off :)

- $sql = 'SELECT topic_id

- FROM ' . TOPICS_TABLE . '

- WHERE ' . phpbb::$db->sql_in_set('topic_shadow_id', $topic_ids);

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

-

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

- {

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

- }

-

- phpbb::$db->sql_freeresult($result);

-

- // recursion, the other white meat.

- if (sizeof($shadow_topic_ids))

- {

- self::delete_topics(array('topic_ids' => $shadow_topic_ids));

- }

-

- // goodnight, moon

- phpbb::$db->transaction('commit');

- }

-

- static function delete_post($data)

- {

- // just call the more powerful variant with just one post :)

- self::delete_posts(array('post_ids' => array($data['post_id'])));

- }

-

- static function delete_posts($data)

- {

- // lets get this party started

- phpbb::$db->sql_transaction('begin');

-

- $post_ids = array_map('intval', $data['post_ids']);

-

- $sql = 'SELECT topic_id, post_status, post_id, post_shadow_id, forum_id

- FROM ' . POSTS_TABLE . '

- WHERE ' . phpbb::$db->sql_in_set('post_id', $post_ids);

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

-

- // the following arrays are designed to allow for much faster updates

- $topic_lookup = array();

- $forum_lookup = array();

-

- while ($post_row = phpbb::$db->sql_fetchrow($result))

- {

- $topic_id = (int) $post_row['topic_id'];

- $forum_id = (int) $post_row['forum_id'];

- $post_status = (int) $post_row['post_status'];

-

- $topic_lookup[$topic_id]['topic_posts']++; // we remove a post, go figure

- $topic_lookup[$topic_id]['topic_shadow_posts'] += ($post_row['post_shadow_id'] != 0); // did we just try to kill a shadow post?!

- $topic_lookup[$topic_id]['topic_deleted_posts'] += ($post_status & self::DELETED);

- $topic_lookup[$topic_id]['topic_unapproved_posts'] += ($post_status & self::UNAPPROVED);

-

- $forum_lookup[$forum_id]['forum_posts']++;

- $forum_lookup[$topic_id]['forum_shadow_posts'] += ($post_row['post_shadow_id'] != 0); // did we just try to kill a shadow post?!

- $forum_lookup[$topic_id]['forum_deleted_posts'] += ($post_status & self::DELETED);

- $forum_lookup[$topic_id]['forum_unapproved_posts'] += ($post_status & self::UNAPPROVED);

- }

- phpbb::$db->sql_freeresult($result);

-

- $topic_ids = array_keys($forum_lookup);

-

- // goodnight, posts

- phpbb::$db->sql_query('DELETE FROM ' . POSTS_TABLE . ' WHERE ' . phpbb::$db->sql_in_set('topic_id', $topic_ids));

-

- // mangle the forums table

- $sql = 'SELECT forum_posts, forum_shadow_posts, forum_deleted_posts, forum_unapproved_posts, forum_id

- FROM ' . FORUMS_TABLE . '

- WHERE forum_id = ' . $forum_id;

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

- $forum_rows = array();

- while ($forum_row = phpbb::$db->sql_fetchrow($result))

- {

- $forum_id = (int) $forum_row['forum_id'];

- $forum_rows[$forum_id] = $forum_row;

- }

- phpbb::$db->sql_freeresult($result);

-

- $shadow_topic_ids = array();

- foreach ($forum_rows as $forum_id => $forum_row)

- {

- $topic_row = $forum_lookup[$forum_id];

- $forum_array = array(

- 'forum_posts' => max($forum_row['forum_posts'] - $topic_row['forum_posts'], 0),

- 'forum_shadow_posts' => max($forum_row['forum_shadow_posts'] - $topic_row['forum_shadow_posts'], 0),

- 'forum_deleted_posts' => max($forum_row['forum_deleted_posts'] - $topic_row['forum_deleted_posts'], 0),

- 'forum_unapproved_posts' => max($forum_row['forum_unapproved_posts'] - $topic_row['forum_unapproved_posts'], 0),

- );

-

- // get the last "normal" post in the forum, we _must_ update it

- $sql = 'SELECT MAX(post_id) as max_post_id

- FROM ' . POSTS_TABLE . '

- WHERE post_status = ' . self::NORMAL . '

- AND forum_id = ' . $forum_id;

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

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

- phpbb::$db->sql_freeresult($result);

-

- // anything left?

- if ($row)

- {

- // OK, lets go do some magick

- $sql = 'SELECT post_username, poster_id, post_subject, post_time

- FROM '. POSTS_TABLE . '

- WHERE post_id = ' . (int) $row['max_post_id'];

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

- $last_post = phpbb::$db->sql_fetchrow($result);

- phpbb::$db->sql_freeresult($result);

-

- $forum_array['forum_last_user_id'] = (int) $last_post['poster_id'];

- $forum_array['forum_last_poster_name'] = $last_post['post_username'];

- $forum_array['forum_last_post_title'] = $last_post['post_subject'];

- $forum_array['forum_last_post_time'] = (int) $last_post['post_time'];

- }

- else

- {

- // reset forum state

- $forum_array['forum_last_user_id'] = 0;

- $forum_array['forum_last_poster_name'] = '';

- $forum_array['forum_last_post_title'] = '';

- $forum_array['forum_last_post_time'] = 0;

- }

-

- phpbb::$db->sql_handle_data('UPDATE', FORUMS_TABLE, $forum_array, "forum_id = $forum_id");

- }

-

- // mangle the topics table now :)

- $sql = 'SELECT topic_posts, topic_shadow_posts, topic_deleted_posts, topic_unapproved_posts, topic_id

- FROM ' . TOPICS_TABLE . '

- WHERE forum_id = ' . $forum_id;

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

- $topic_rows = array();

- while ($topic_row = phpbb::$db->sql_fetchrow($result))

- {

- $topic_id = (int) $topic_row['topic_id'];

- $topic_rows[$topic_id] = $topic_row;

- }

- phpbb::$db->sql_freeresult($result);

-

- $empty_topic_ids = array();

-

- foreach ($topic_rows as $topic_id => $topic_row)

- {

- $post_row = $topic_lookup[$topic_id];

- $topic_array = array(

- 'topic_posts' => max($topic_row['topic_posts'] - $post_row['topic_posts'], 0),

- 'topic_shadow_posts' => max($topic_row['topic_shadow_posts'] - $post_row['topic_shadow_posts'], 0),

- 'topic_deleted_posts' => max($topic_row['topic_deleted_posts'] - $post_row['topic_deleted_posts'], 0),

- 'topic_unapproved_posts' => max($topic_row['topic_unapproved_posts'] - $post_row['topic_unapproved_posts'], 0),

- );

-

- // get the last "normal" post in the topic, we _must_ update it

- $sql = 'SELECT MAX(post_id) as max_post_id

- FROM ' . POSTS_TABLE . '

- WHERE post_status = ' . self::NORMAL . '

- AND topic_id = ' . $topic_id;

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

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

- phpbb::$db->sql_freeresult($result);

-

- // anything left?

- if ($row)

- {

- // OK, lets go do some magick

- $sql = 'SELECT post_username, poster_id, post_subject, post_time

- FROM '. POSTS_TABLE . '

- WHERE post_id = ' . (int) $row['max_post_id'];

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

- $last_post = phpbb::$db->sql_fetchrow($result);

- phpbb::$db->sql_freeresult($result);

-

- $topic_array['topic_last_user_id'] = (int) $last_post['poster_id'];

- $topic_array['topic_last_poster_name'] = $last_post['post_username'];

- $topic_array['topic_last_post_title'] = $last_post['post_subject'];

- $topic_array['topic_last_post_time'] = (int) $last_post['post_time'];

- }

- else

- {

- // mark this post for execution!

- $empty_topic_ids[] = $topic_id;

- }

-

- phpbb::$db->sql_handle_data('UPDATE', TOPICS_TABLE, $topic_array, "topic_id = $topic_id");

- }

-

- $shadow_post_ids = array();

-

- // let's not get too hasty, we can kill off the shadows later,

- // instead we compose a list of all shadows and then efficiently kill them off :)

- $sql = 'SELECT post_id

- FROM ' . POSTS_TABLE . '

- WHERE ' . phpbb::$db->sql_in_set('post_shadow_id', $topic_ids);

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

-

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

- {

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

- }

-

- phpbb::$db->sql_freeresult($result);

-

- // recursion, the other white meat.

- if (sizeof($shadow_topic_ids))

- {

- self::delete_posts(array('post_ids' => $shadow_post_ids));

- }

-

- // we killed all the posts in a topic, time to kill the topics!

- if (sizeof($empty_topic_ids))

- {

- self::delete_topics(array('topic_ids' => $empty_topic_ids));

- }

-

- // goodnight, moon

- phpbb::$db->transaction('commit');

- }

-

- static function move_topic($data)

- {

- self::move_topics(array('topic_forum_mapping' => array(array('topic_id' => $data['topic_id'], 'forum_id' => $data['forum_id'], 'make_shadow' => $data['make_shadow']))));

- }

-

- static function move_topics($data)

- {

- // lets get this party started

- phpbb::$db->transaction('begin');

-

- // all of each are indexed by topic id

- $to_forum_ids = $shadow_topic_ids = array();

-

- foreach ($data['topic_forum_mapping'] as $mapping)

- {

- $topic_id = (int) $mapping['topic_id'];

- $to_forum_ids[$topic_id] = (int) $mapping['forum_id'];

- if ($mapping['make_shadow'])

- {

- $shadow_topic_ids[] = $topic_id;

- }

- }

-

- $forum_columns = array('forum_posts', 'forum_shadow_posts', 'forum_deleted_posts', 'forum_unapproved_posts', 'forum_topics', 'forum_shadow_topics', 'forum_deleted_topics', 'forum_unapproved_topics');

-

- $topic_ids = array_keys($to_forum_ids);

-

- // let us first determine how many items we are removing from the pool

- $sql = 'SELECT topic_posts, topic_shadow_posts, topic_deleted_posts, topic_unapproved_posts, forum_id, topic_status, topic_type, topic_shadow_id, topic_id

- FROM ' . TOPICS_TABLE . '

- WHERE ' . phpbb::$db->sql_in_set('topic_id', $topic_ids);

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

- $forum_lookup = array();

- while ($topic_row = phpbb::$db->sql_fetchrow($result))

- {

- $topic_id = $topic_row['topic_id'];

- $from_forum_id = (int) $topic_row['forum_id'];

- $to_forum_id = $to_forum_ids[$topic_id];

-

- // we are iterating one topic at a time...

- $forum_lookup[$from_forum_id]['forum_topics'] = $forum_lookup[$to_forum_id]['forum_topics'] = 1;

-

- foreach ($forum_columns as $column)

- {

- $forum_lookup[$from_forum_id][$column] -= $topic_row['topic_posts'];

- $forum_lookup[$to_forum_id][$column] += $topic_row['topic_posts'];

- }

- }

- phpbb::$db->sql_freeresult($result);

-

- // determine the totals

- $sql = 'SELECT forum_posts, forum_shadow_posts, forum_deleted_posts, forum_unapproved_posts, forum_id, forum_topics, forum_deleted_topics, forum_unapproved_topics

- FROM ' . FORUMS_TABLE . '

- WHERE ' . phpbb::$db->sql_in_set('forum_id', array_keys($forum_lookup));

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

-

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

- {

- $forum_id = (int) $row['forum_id'];

-

- foreach ($forum_columns as $column)

- {

- $forum_lookup[$forum_id][$column] += (int) $row[$column];

- }

- }

-

- // create a listing of which topics are going in which forums

- $update_list = array();

-

- foreach ($to_forum_ids as $topic_id => $forum_id)

- {

- $update_list[$forum_id][] = $topic_id;

- }

-

- // we save as many queries as we can by updating all similar topics at once

- foreach ($update_list as $forum_id => $topic_ids)

- {

- // update the topic itself

- phpbb::$db->sql_handle_data('UPDATE', TOPICS_TABLE, array('forum_id' => $to_forum_id), phpbb::$db->sql_in_set('topic_id', $topic_ids));

-

- // update the posts now

- phpbb::$db->sql_handle_data('UPDATE', POSTS_TABLE, array('forum_id' => $to_forum_id), phpbb::$db->sql_in_set('topic_id', $topic_ids));

- }

-

- // start building the needed arrays for updating the forum data

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

- {

- foreach ($forum_columns as $column)

- {

- $forum_data[$column] = max($forum_data[$column], 0); // ensure the result is unsigned

- }

-

- // get the last "normal" post in the old forum, we _must_ update it

- $sql = 'SELECT MAX(post_id) as max_post_id

- FROM ' . POSTS_TABLE . '

- WHERE post_status = ' . self::NORMAL . '

- AND forum_id = ' . $forum_id;

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

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

- phpbb::$db->sql_freeresult($result);

-

- // anything left?

- if ($row)

- {

- // OK, lets go do some magick

- $sql = 'SELECT post_username, poster_id, post_subject, post_time

- FROM '. POSTS_TABLE . '

- WHERE post_id = ' . (int) $row['max_post_id'];

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

- $last_post = phpbb::$db->sql_fetchrow($result);

- phpbb::$db->sql_freeresult($result);

-

- $forum_data['forum_last_user_id'] = (int) $last_post['poster_id'];

- $forum_data['forum_last_poster_name'] = $last_post['post_username'];

- $forum_data['forum_last_post_title'] = $last_post['post_subject'];

- $forum_data['forum_last_post_time'] = (int) $last_post['post_time'];

- }

- else

- {

- // reset forum state

- $forum_data['forum_last_user_id'] = 0;

- $forum_data['forum_last_poster_name'] = '';

- $forum_data['forum_last_post_title'] = '';

- $forum_data['forum_last_post_time'] = 0;

- }

-

- // update the old forum

- phpbb::$db->sql_handle_data('UPDATE', FORUMS_TABLE, $forum_data, "forum_id = $forum_id");

- }

-

- // hooray for code reuse!

- foreach ($shadow_topic_ids as $topic_id)

- {

- $data['shadow_topic_id'] = $topic_id;

- $data['forum_id'] = $from_forum_id;

- self::insert_shadow_topic($data);

- }

-

- phpbb::$db->sql_transaction('commit');

-

- }

-}

-

-?> \ No newline at end of file