+<?php

+// -------------------------------------------------------------

+//

+// $Id$

+//

+// FILENAME : functions_privmsgs.php

+// STARTED : Sun Apr 18, 2004

+// COPYRIGHT : © 2004 phpBB Group

+// WWW : http://www.phpbb.com/

+// LICENCE : GPL vs2.0 [ see /docs/COPYING ]

+//

+// -------------------------------------------------------------

+

+// Define Rule processing scheme

+// NOTE: might change

+

+/*

+ Ability to simply add own rules by doing three things:

+ 1) Add an appropiate constant

+ 2) Add a new check array to the global_privmsgs_rules variable and the condition array (if one is required)

+ 3) Add a new language variable to ucp.php

+

+ The user is then able to select the new rule. It will be checked agains and handled as specified.

+ To add new actions (yes, checks can be added here too) to the rule management, the core code has to be modified.

+*/

+

+define('RULE_IS_LIKE', 1); // Is Like

+define('RULE_IS_NOT_LIKE', 2); // Is Not Like

+define('RULE_IS', 3); // Is

+define('RULE_IS_NOT', 4); // Is Not

+define('RULE_BEGINS_WITH', 5); // Begins with

+define('RULE_ENDS_WITH', 6); // Ends with

+define('RULE_IS_FRIEND', 7); // Is Friend

+define('RULE_IS_FOE', 8); // Is Foe

+define('RULE_IS_USER', 9); // Is User

+define('RULE_IS_GROUP', 10); // Is In Usergroup

+define('RULE_ANSWERED', 11); // Answered

+define('RULE_FORWARDED', 12); // Forwarded

+define('RULE_REPORTED', 13); // Reported

+define('RULE_TO_GROUP', 14); // Usergroup

+define('RULE_TO_ME', 15); // Me

+

+define('ACTION_PLACE_INTO_FOLDER', 1);

+define('ACTION_MARK_AS_READ', 2);

+define('ACTION_MARK_AS_IMPORTANT', 3);

+define('ACTION_DELETE_MESSAGE', 4);

+

+define('CHECK_SUBJECT', 1);

+define('CHECK_SENDER', 2);

+define('CHECK_MESSAGE', 3);

+define('CHECK_STATUS', 4);

+define('CHECK_TO', 5);

+

+$global_privmsgs_rules = array(

+ CHECK_SUBJECT => array(

+ RULE_IS_LIKE => array('check0' => 'message_subject', 'function' => 'preg_match("/" . preg_quote({STRING}) . "/i", {CHECK0})'),

+ RULE_IS_NOT_LIKE => array('check0' => 'message_subject', 'function' => '!(preg_match("/" . preg_quote({STRING}) . "/i", {CHECK0}))'),

+ RULE_IS => array('check0' => 'message_subject', 'function' => '{CHECK0} == {STRING}'),

+ RULE_IS_NOT => array('check0' => 'message_subject', 'function' => '{CHECK0} != {STRING}'),

+ RULE_BEGINS_WITH => array('check0' => 'message_subject', 'function' => 'preg_match("/^" . preg_quote({STRING}) . "/i", {CHECK0})'),

+ RULE_ENDS_WITH => array('check0' => 'message_subject', 'function' => 'preg_match("/" . preg_quote({STRING}) . "$/i", {CHECK0})')),

+

+ CHECK_SENDER => array(

+ RULE_IS_LIKE => array('check0' => 'username', 'function' => 'preg_match("/" . preg_quote({STRING}) . "/i", {CHECK0})'),

+ RULE_IS_NOT_LIKE => array('check0' => 'username', 'function' => '!(preg_match("/" . preg_quote({STRING}) . "/i", {CHECK0}))'),

+ RULE_IS => array('check0' => 'username', 'function' => '{CHECK0} == {STRING}'),

+ RULE_IS_NOT => array('check0' => 'username', 'function' => '{CHECK0} != {STRING}'),

+ RULE_BEGINS_WITH => array('check0' => 'username', 'function' => 'preg_match("/^" . preg_quote({STRING}) . "/i", {CHECK0})'),

+ RULE_ENDS_WITH => array('check0' => 'username', 'function' => 'preg_match("/" . preg_quote({STRING}) . "$/i", {CHECK0})'),

+ RULE_IS_FRIEND => array('check0' => 'friend', 'function' => '{CHECK0} == 1'),

+ RULE_IS_FOE => array('check0' => 'foe', 'function' => '{CHECK0} == 1'),

+ RULE_IS_USER => array('check0' => 'author_id', 'function' => '{CHECK0} == {USER_ID}'),

+ RULE_IS_GROUP => array('check0' => 'author_in_group', 'function' => '{CHECK0} == {GROUP_ID}')),

+

+ CHECK_MESSAGE => array(

+ RULE_IS_LIKE => array('check0' => 'message_text', 'function' => 'preg_match("/" . preg_quote({STRING}) . "/i", {CHECK0})'),

+ RULE_IS_NOT_LIKE => array('check0' => 'message_text', 'function' => '!(preg_match("/" . preg_quote({STRING}) . "/i", {CHECK0}))'),

+ RULE_IS => array('check0' => 'message_text', 'function' => '{CHECK0} == {STRING}'),

+ RULE_IS_NOT => array('check0' => 'message_text', 'function' => '{CHECK0} != {STRING}')),

+

+ CHECK_STATUS => array(

+ RULE_ANSWERED => array('check0' => 'replied', 'function' => '{CHECK0} == 1'),

+ RULE_FORWARDED => array('check0' => 'forwarded', 'function' => '{CHECK0} == 1'),

+ RULE_REPORTED => array('check0' => 'message_reported', 'function' => '{CHECK0} == 1')),

+

+ CHECK_TO => array(

+ RULE_TO_GROUP => array('check0' => 'to', 'check1' => 'bcc', 'check2' => 'user_in_group', 'function' => 'in_array("g_" . {CHECK2}, {CHECK0}) || in_array("g_" . {CHECK2}, {CHECK1})'),

+ RULE_TO_ME => array('check0' => 'to', 'check1' => 'bcc', 'function' => 'in_array("u_" . $user_id, {CHECK0}) || in_array("u_" . $user_id, {CHECK1})'))

+);

+

+// This is for defining which condition fields to show for which Rule

+$global_rule_conditions = array(

+ RULE_IS_LIKE => 'text',

+ RULE_IS_NOT_LIKE => 'text',

+ RULE_IS => 'text',

+ RULE_IS_NOT => 'text',

+ RULE_BEGINS_WITH => 'text',

+ RULE_ENDS_WITH => 'text',

+ RULE_IS_USER => 'user',

+ RULE_IS_GROUP => 'group'

+);

+

+// Get number of unread messages from all folder

+function get_unread_pm($user_id)

+{

+ global $db;

+

+ $unread_pm = array();

+

+ $sql = 'SELECT folder_id, SUM(unread) as sum_unread

+ FROM ' . PRIVMSGS_TO_TABLE . "

+ WHERE user_id = $user_id

+ AND folder_id <> " . PRIVMSGS_OUTBOX . '

+ GROUP BY folder_id';

+ $result = $db->sql_query($sql);

+

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

+ {

+ if ($row['sum_unread'])

+ {

+ $unread_pm[$row['folder_id']] = $row['sum_unread'];

+ }

+ }

+ $db->sql_freeresult($result);

+

+ return $unread_pm;

+}

+

+// Get all folder

+function get_folder($user_id, &$folder)

+{

+ global $db, $user;

+

+ if (!is_array($folder))

+ {

+ $folder = array();

+ }

+

+ $sql = 'SELECT folder_id, COUNT(msg_id) as num_messages

+ FROM ' . PRIVMSGS_TO_TABLE . "

+ WHERE user_id = $user_id

+ AND folder_id <> " . PRIVMSGS_NO_BOX . '

+ GROUP BY folder_id';

+ $result = $db->sql_query($sql);

+

+ $num_messages = array();

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

+ {

+ $num_messages[(int) $row['folder_id']] = $row['num_messages'];

+ }

+ $db->sql_freeresult($result);

+

+ if (!isset($num_messages[PRIVMSGS_OUTBOX]))

+ {

+ $num_messages[PRIVMSGS_OUTBOX] = 0;

+ }

+

+ $folder[PRIVMSGS_INBOX] = array('folder_name' => $user->lang['PM_INBOX'], 'num_messages' => (int) $num_messages[PRIVMSGS_INBOX]);

+

+ $sql = 'SELECT folder_id, folder_name, pm_count

+ FROM ' . PRIVMSGS_FOLDER_TABLE . "

+ WHERE user_id = $user_id";

+ $result = $db->sql_query($sql);

+

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

+ {

+ $folder[$row['folder_id']] = array('folder_name' => $row['folder_name'], 'num_messages' => $row['pm_count']);

+ }

+ $db->sql_freeresult($result);

+

+ $folder[PRIVMSGS_OUTBOX] = array('folder_name' => $user->lang['PM_OUTBOX'], 'num_messages' => (int) $num_messages[PRIVMSGS_OUTBOX]);

+ $folder[PRIVMSGS_SENTBOX] = array('folder_name' => $user->lang['PM_SENTBOX'], 'num_messages' => (int) $num_messages[PRIVMSGS_SENTBOX]);

+

+ return;

+}

+

+// Delete Messages From Sentbox - we are doing this here because this saves us a bunch of checks and queries

+function clean_sentbox($num_sentbox_messages)

+{

+ global $db, $user, $config;

+

+ $message_limit = (!$user->data['group_message_limit']) ? $config['pm_max_msgs'] : $user->data['group_message_limit'];

+

+ // Check Message Limit -

+ if ($message_limit && $num_sentbox_messages > $message_limit)

+ {

+ // Delete old messages

+ $sql = 'SELECT t.msg_id

+ FROM ' . PRIVMSGS_TO_TABLE . ' t, ' . PRIVMSGS_TABLE . ' p

+ WHERE t.msg_id = p.msg_id

+ AND t.user_id = ' . $user->data['user_id'] . '

+ AND t.folder_id = ' . PRIVMSGS_SENTBOX . '

+ ORDER BY p.message_time ASC';

+ $result = $db->sql_query_limit($sql, ($num_sentbox_messages - $message_limit));

+

+ $delete_ids = array();

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

+ {

+ $delete_ids[] = $row['msg_id'];

+ }

+ $db->sql_freeresult($result);

+ delete_pm($user->data['user_id'], $delete_ids, PRIVMSGS_SENTBOX);

+ }

+}

+

+// Check Rule against Message Informations

+function check_rule($rules, $rule_row, $message_row, $user_id)

+{

+ global $user, $config;

+

+ if (!isset($rules[$rule_row['rule_check']][$rule_row['rule_connection']]))

+ {

+ return false;

+ }

+

+ $check_ary = $rules[$rule_row['rule_check']][$rule_row['rule_connection']];

+

+ // Replace Check Literals

+ $evaluate = $check_ary['function'];

+ $evaluate = preg_replace('/{(CHECK[0-9])}/', '$message_row[$check_ary[strtolower("\1")]]', $evaluate);

+

+ // Replace Rule Literals

+ $evaluate = preg_replace('/{(STRING|USER_ID|GROUP_ID)}/', '$rule_row["rule_" . strtolower("\1")]', $evaluate);

+

+ // Eval Statement

+ $result = false;

+ eval('$result = (' . $evaluate . ') ? true : false;');

+

+ if (!$result)

+ {

+ return false;

+ }

+

+ switch ($rule_row['rule_action'])

+ {

+ case ACTION_PLACE_INTO_FOLDER:

+ return array('action' => $rule_row['rule_action'], 'folder_id' => $rule_row['rule_folder_id']);

+ break;

+ case ACTION_MARK_AS_READ:

+ case ACTION_MARK_AS_IMPORTANT:

+ case ACTION_DELETE_MESSAGE:

+ return array('action' => $rule_row['rule_action'], 'unread' => $row['unread'], 'important' => $row['important']);

+ break;

+ default:

+ return false;

+ }

+

+ return false;

+}

+

+// Place new messages into appropiate folder

+function place_pm_into_folder($global_privmsgs_rules, $release = false)

+{

+ global $db, $user, $config;

+

+ if (!$user->data['user_new_privmsg'])

+ {

+ return;

+ }

+

+ $user_new_privmsg = (int) $user->data['user_new_privmsg'];

+ $user_message_rules = (int) $user->data['user_message_rules'];

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

+

+ $user_rules = $zebra = array();

+ if ($user_message_rules)

+ {

+ $sql = 'SELECT *

+ FROM ' . PRIVMSGS_RULES_TABLE . "

+ WHERE user_id = $user_id";

+ $result = $db->sql_query($sql);

+

+ $user_rules = $db->sql_fetchrowset($result);

+ $db->sql_freeresult($result);

+

+ if (sizeof($user_rules))

+ {

+ $sql = 'SELECT zebra_id, friend, foe

+ FROM ' . ZEBRA_TABLE . "

+ WHERE user_id = $user_id";

+ $result = $db->sql_query($sql);

+

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

+ {

+ $zebra[$row['zebra_id']] = $row;

+ }

+ $db->sql_freeresult($result);

+ }

+ }

+

+ if ($release)

+ {

+ $sql = 'UPDATE ' . PRIVMSGS_TO_TABLE . '

+ SET folder_id = ' . PRIVMSGS_NO_BOX . '

+ WHERE folder_id = ' . PRIVMSGS_HOLD_BOX . "

+ AND user_id = $user_id";

+ $db->sql_query($sql);

+ }

+

+ // Get those messages not yet placed into any box

+ // NOTE: Expand Group Information to all groups the user/author is in?

+ $sql = 'SELECT t.*, p.*, u.username, u.group_id as author_in_group

+ FROM ' . PRIVMSGS_TO_TABLE . ' t, ' . PRIVMSGS_TABLE . ' p, ' . USERS_TABLE . " u

+ WHERE t.user_id = $user_id

+ AND p.author_id = u.user_id

+ AND t.folder_id = " . PRIVMSGS_NO_BOX . '

+ AND t.msg_id = p.msg_id';

+ $result = $db->sql_query($sql);

+

+ $action_ary = $move_into_folder = array();

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

+ {

+ $row['to'] = explode(':', $row['to_address']);

+ $row['bcc'] = explode(':', $row['bcc_address']);

+ $row['friend'] = (isset($zebra[$row['author_id']])) ? $zebra[$row['author_id']]['friend'] : 0;

+ $row['foe'] = (isset($zebra[$row['author_id']])) ? $zebra[$row['author_id']]['foe'] : 0;

+ $row['user_in_group'] = $user->data['group_id'];

+

+ // Check Rule - this should be very quick since we have all informations we need

+ $is_match = false;

+ foreach ($user_rules as $rule_row)

+ {

+ if (($action = check_rule($global_privmsgs_rules, $rule_row, $row, $user_id)) !== false)

+ {

+ $is_match = true;

+ $action_ary[$row['msg_id']][] = $action;

+ }

+ }

+

+ if (!$is_match)

+ {

+ $action_ary[$row['msg_id']][] = array('action' => false);

+ $move_into_folder[PRIVMSGS_INBOX][] = $row['msg_id'];

+ }

+ }

+ $db->sql_freeresult($result);

+

+ // We place actions into arrays, to save queries.

+ $num_new = $num_unread = 0;

+ $sql = $unread_ids = $delete_ids = $important_ids = array();

+

+ foreach ($action_ary as $msg_id => $msg_ary)

+ {

+ // It is allowed to execute actions more than once, except placing messages into folder

+ $folder_action = false;

+

+ foreach ($msg_ary as $pos => $rule_ary)

+ {

+ if ($folder_action && $rule_ary['action'] == ACTION_PLACE_INTO_FOLDER)

+ {

+ continue;

+ }

+

+ switch ($rule_ary['action'])

+ {

+ case ACTION_PLACE_INTO_FOLDER:

+ $folder_action = true;

+ $move_into_folder[$rule_ary['folder_id']][] = $msg_id;

+ $num_new++;

+ break;

+

+ case ACTION_MARK_AS_READ:

+ if ($rule_ary['unread'])

+ {

+ $unread_ids[] = $msg_id;

+ }

+ $move_into_folder[PRIVMSGS_INBOX][] = $msg_id;

+ break;

+

+ case ACTION_DELETE_MESSAGE:

+ $delete_ids[] = $msg_id;

+ break;

+

+ case ACTION_MARK_AS_IMPORTANT:

+ if (!$rule_ary['important'])

+ {

+ $important_ids[] = $msg_id;

+ }

+ $move_into_folder[PRIVMSGS_INBOX][] = $msg_id;

+ break;

+

+ default:

+ }

+ }

+ }

+

+ $num_new += sizeof(array_unique($delete_ids));

+ $num_unread += sizeof(array_unique($delete_ids));

+ $num_unread += sizeof(array_unique($unread_ids));

+

+ // Do not change the order of processing

+ // The number of queries needed to be executed here highly depends on the defined rules and are

+ // only gone through if new messages arrive.

+ $num_not_moved = 0;

+

+ // Delete messages

+ if (sizeof($delete_ids))

+ {

+ delete_pm($user_id, $delete_ids, PRIVMSGS_NO_BOX);

+ }

+

+ // Set messages to Unread

+ if (sizeof($unread_ids))

+ {

+ $sql = 'UPDATE ' . PRIVMSGS_TO_TABLE . '

+ SET unread = 0

+ WHERE msg_id IN (' . implode(', ', $unread_ids) . ")

+ AND user_id = $user_id

+ AND folder_id = " . PRIVMSGS_NO_BOX;

+ $db->sql_query($sql);

+ }

+

+ // mark messages as important

+ if (sizeof($important_ids))

+ {

+ $sql = 'UPDATE ' . PRIVMSGS_TO_TABLE . '

+ SET marked = !marked

+ WHERE folder_id = ' . PRIVMSGS_NO_BOX . "

+ AND user_id = $user_id

+ AND msg_id IN (" . implode(', ', $important_ids) . ')';

+ $db->sql_query($sql);

+ }

+

+ // Move into folder

+ $folder = array();

+

+ if (sizeof($move_into_folder))

+ {

+ // Determine Full Folder Action - we need the move to folder id later eventually

+ $full_folder_action = ($user->data['user_full_folder'] == FULL_FOLDER_NONE) ? ($config['full_folder_action'] - (FULL_FOLDER_NONE*(-1))) : $user->data['user_full_folder'];

+

+ $sql = 'SELECT folder_id, pm_count

+ FROM ' . PRIVMSGS_FOLDER_TABLE . '

+ WHERE folder_id IN (' . implode(', ', array_keys($move_into_folder)) . (($full_folder_action >= 0) ? ', ' . $full_folder_action : '') . ")

+ AND user_id = $user_id";

+ $result = $db->sql_query($sql);

+

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

+ {

+ $folder[(int) $row['folder_id']] = (int) $row['pm_count'];

+ }

+ $db->sql_freeresult($result);

+

+ if (in_array(PRIVMSGS_INBOX, array_keys($move_into_folder)))

+ {

+ $sql = 'SELECT folder_id, COUNT(msg_id) as num_messages

+ FROM ' . PRIVMSGS_TO_TABLE . "

+ WHERE user_id = $user_id

+ AND folder_id = " . PRIVMSGS_INBOX . "

+ GROUP BY folder_id";

+ $result = $db->sql_query_limit($sql, 1);

+

+ $folder[PRIVMSGS_INBOX] = (int) $db->sql_fetchfield('num_messages', 0, $result);

+ $db->sql_freeresult($result);

+ }

+ }

+

+ // Here we have ideally only one folder to move into

+ foreach ($move_into_folder as $folder_id => $msg_ary)

+ {

+ $message_limit = (!$user->data['group_message_limit']) ? $config['pm_max_msgs'] : $user->data['group_message_limit'];

+ $dest_folder = $folder_id;

+ $full_folder_action = FULL_FOLDER_NONE;

+

+ // Check Message Limit - we calculate with the complete array, most of the time it is one message

+ // But we are making sure that the other way around works too (more messages in queue than allowed to be stored)

+ if ($message_limit && $folder[$folder_id] && ($folder[$folder_id] + sizeof($msg_ary)) > $message_limit)

+ {

+ $full_folder_action = ($user->data['user_full_folder'] == FULL_FOLDER_NONE) ? ($config['full_folder_action'] - (FULL_FOLDER_NONE*(-1))) : $user->data['user_full_folder'];

+

+ // If destination folder itself is full...

+ if ($full_folder_action >= 0 && ($folder[$full_folder_action] + sizeof($msg_ary)) > $message_limit)

+ {

+ $full_folder_action = $config['full_folder_action'] - (FULL_FOLDER_NONE*(-1));

+ }

+

+ // If Full Folder Action is to move to another folder, we simply adjust the destination folder

+ if ($full_folder_action >= 0)

+ {

+ $dest_folder = $full_folder_action;

+ }

+ else if ($full_folder_action == FULL_FOLDER_DELETE)

+ {

+ // Delete some messages ;)

+ $sql = 'SELECT t.msg_id

+ FROM ' . PRIVMSGS_TO_TABLE . ' t, ' . PRIVMSGS_TABLE . " p

+ WHERE t.msg_id = p.msg_id

+ AND t.user_id = $user_id

+ AND t.folder_id = $dest_folder

+ ORDER BY p.message_time ASC";

+ $result = $db->sql_query_limit($sql, (($folder[$dest_folder] + sizeof($msg_ary)) - $message_limit));

+

+ $delete_ids = array();

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

+ {

+ $delete_ids[] = $row['msg_id'];

+ }

+ $db->sql_freeresult($result);

+ delete_pm($user_id, $delete_ids, $dest_folder);

+ }

+ }

+

+ if ($full_folder_action != FULL_FOLDER_MOVE)

+ {

+ $sql = 'UPDATE ' . PRIVMSGS_TO_TABLE . "

+ SET folder_id = $dest_folder, new = 0

+ WHERE folder_id = " . PRIVMSGS_NO_BOX . "

+ AND user_id = $user_id

+ AND new = 1

+ AND msg_id IN (" . implode(', ', $msg_ary) . ')';

+ $db->sql_query($sql);

+

+ if ($dest_folder != PRIVMSGS_INBOX)

+ {

+ $sql = 'UPDATE ' . PRIVMSGS_FOLDER_TABLE . '

+ SET pm_count = pm_count + ' . (int) $db->sql_affectedrows() . "

+ WHERE folder_id = $dest_folder

+ AND user_id = $user_id";

+ $db->sql_query($sql);

+ }

+ else

+ {

+ $num_new += $db->sql_affectedrows();

+ }

+ }

+ else

+ {

+ $num_not_moved += sizeof($msg_ary);

+ $sql = 'UPDATE ' . PRIVMSGS_TO_TABLE . '

+ SET folder_id = ' . PRIVMSGS_HOLD_BOX . '

+ WHERE folder_id = ' . PRIVMSGS_NO_BOX . "

+ AND user_id = $user_id

+ AND msg_id IN (" . implode(', ', $msg_ary) . ')';

+ $db->sql_query($sql);

+ }

+ }

+

+ if (sizeof($action_ary))

+ {

+ // Move from OUTBOX to SENTBOX

+ // We are not checking any full folder status here... SENTBOX is a special treatment (old messages get deleted)

+ $sql = 'UPDATE ' . PRIVMSGS_TO_TABLE . '

+ SET folder_id = ' . PRIVMSGS_SENTBOX . '

+ WHERE folder_id = ' . PRIVMSGS_OUTBOX . '

+ AND msg_id IN (' . implode(', ', array_keys($action_ary)) . ')';

+ $db->sql_query($sql);

+ }

+

+ // Update unread and new status field

+ if ($num_unread || $num_new)

+ {

+ $set_sql = ($num_unread) ? 'user_unread_privmsg = user_unread_privmsg - ' . $num_unread : '';

+ if ($num_new)

+ {

+ $set_sql .= ($set_sql != '') ? ', ' : '';

+ $set_sql .= 'user_new_privmsg = user_new_privmsg - ' . $num_new;

+ }

+

+ $db->sql_query('UPDATE ' . USERS_TABLE . " SET $set_sql WHERE user_id = $user_id");

+ $user->data['user_new_privmsg'] -= $num_new;

+ $user->data['user_unread_privmsg'] -= $num_unread;

+ }

+

+ return $num_not_moved;

+}

+

+// Move PM from one to another folder

+function move_pm($user_id, $message_limit)

+{

+ global $db, $user;

+ global $_POST, $phpbb_root_path, $phpEx, $SID;

+

+ $move_msg_ids = (isset($_POST['marked_msg_id'])) ? array_map('intval', $_POST['marked_msg_id']) : array();

+ $dest_folder = request_var('dest_folder', PRIVMSGS_NO_BOX);

+ $cur_folder_id = request_var('cur_folder_id', PRIVMSGS_NO_BOX);

+

+ $num_moved = 0;

+

+ if (sizeof($move_msg_ids) && !in_array($dest_folder, array(PRIVMSGS_NO_BOX, PRIVMSGS_OUTBOX, PRIVMSGS_SENTBOX)) &&

+ !in_array($cur_folder_id, array(PRIVMSGS_NO_BOX, PRIVMSGS_OUTBOX, PRIVMSGS_SENTBOX)) && $cur_folder_id != $dest_folder)

+ {

+ // We have to check the destination folder ;)

+ if ($dest_folder != PRIVMSGS_INBOX)

+ {

+ $sql = 'SELECT folder_id, folder_name, pm_count

+ FROM ' . PRIVMSGS_FOLDER_TABLE . "

+ WHERE folder_id = $dest_folder

+ AND user_id = $user_id";

+ $result = $db->sql_query($sql);

+

+ if (!($row = $db->sql_fetchrow($result)))

+ {

+ trigger_error('NOT_AUTHORIZED');

+ }

+ $db->sql_freeresult($result);

+

+ if ($row['pm_count'] + sizeof($move_msg_ids) > $message_limit)

+ {

+ $message = sprintf($user->lang['NOT_ENOUGH_SPACE_FOLDER'], $row['folder_name']) . '<br /><br />';

+ $message .= sprintf($user->lang['CLICK_RETURN_FOLDER'], "<a href=\"{$phpbb_root_path}ucp.$phpEx$SID&amp;i=pm&amp;folder={$row['folder_id']}\">", '</a>', $row['folder_name']);

+ trigger_error($message);

+ }

+ }

+ else

+ {

+ $sql = 'SELECT COUNT(msg_id) as num_messages

+ FROM ' . PRIVMSGS_TO_TABLE . '

+ WHERE folder_id = ' . PRIVMSGS_INBOX . "

+ AND user_id = $user_id";

+ $result = $db->sql_query($sql);

+ if ($db->sql_fetchfield('num_messages', 0, $result) + sizeof($move_msg_ids) > $message_limit)

+ {

+ $message = sprintf($user->lang['NOT_ENOUGH_SPACE_FOLDER'], $user->lang['PM_INBOX']) . '<br /><br />';

+ $message .= sprintf($user->lang['CLICK_RETURN_FOLDER'], "<a href=\"{$phpbb_root_path}ucp.$phpEx$SID&amp;i=pm&amp;folder=inbox\">", '</a>', $user->lang['PM_INBOX']);

+ trigger_error($message);

+ }

+ }

+

+ $sql = 'UPDATE ' . PRIVMSGS_TO_TABLE . "

+ SET folder_id = $dest_folder

+ WHERE folder_id = $cur_folder_id

+ AND user_id = $user_id

+ AND msg_id IN (" . implode(', ', $move_msg_ids) . ')';

+ $db->sql_query($sql);

+ $num_moved = $db->sql_affectedrows();

+

+ // Update pm counts

+ if ($num_moved)

+ {

+ if (!in_array($cur_folder_id, array(PRIVMSGS_INBOX, PRIVMSGS_OUTBOX, PRIVMSGS_SENTBOX)))

+ {

+ $sql = 'UPDATE ' . PRIVMSGS_FOLDER_TABLE . "

+ SET pm_count = pm_count - $num_moved

+ WHERE folder_id = $cur_folder_id

+ AND user_id = $user_id";

+ $db->sql_query($sql);

+ }

+

+ if ($dest_folder != PRIVMSGS_INBOX)

+ {

+ $sql = 'UPDATE ' . PRIVMSGS_FOLDER_TABLE . "

+ SET pm_count = pm_count + $num_moved

+ WHERE folder_id = $dest_folder

+ AND user_id = $user_id";

+ $db->sql_query($sql);

+ }

+ }

+ }

+

+ return $num_moved;

+}

+

+// Update unread message status

+function update_unread_status($unread, $msg_id, $user_id, $folder_id)

+{

+ if (!$unread)

+ {

+ return;

+ }

+

+ global $db;

+

+ $sql = 'UPDATE ' . PRIVMSGS_TO_TABLE . "

+ SET unread = 0

+ WHERE msg_id = $msg_id

+ AND user_id = $user_id

+ AND folder_id = $folder_id";

+ $db->sql_query($sql);

+

+ $sql = 'UPDATE ' . USERS_TABLE . "

+ SET user_unread_privmsg = user_unread_privmsg - 1

+ WHERE user_id = $user_id";

+ $db->sql_query($sql);

+}

+

+// Handle all actions possible with marked messages

+function handle_mark_actions($user_id, $mark_action)

+{

+ global $db, $user, $_POST, $phpbb_root_path, $SID, $phpEx;

+

+ $msg_ids = (isset($_POST['marked_msg_id'])) ? array_map('intval', $_POST['marked_msg_id']) : array();

+ $cur_folder_id = request_var('cur_folder_id', PRIVMSGS_NO_BOX);

+ $confirm = (isset($_POST['confirm'])) ? true : false;

+

+ if (!sizeof($msg_ids))

+ {

+ return;

+ }

+

+ switch ($mark_action)

+ {

+ case 'mark_important':

+

+ $sql = 'UPDATE ' . PRIVMSGS_TO_TABLE . "

+ SET marked = !marked

+ WHERE folder_id = $cur_folder_id

+ AND user_id = $user_id

+ AND msg_id IN (" . implode(', ', $msg_ids) . ')';

+ $db->sql_query($sql);

+

+ break;

+

+ case 'delete_marked':

+ $hidden_fields = array('cur_folder_id' => $cur_folder_id, 'mark_option' => 'delete_marked', 'submit_mark' => true);

+ $hidden_fields['marked_msg_id'] = $msg_ids;

+ $s_hidden_fields = '';

+

+ foreach ($hidden_fields as $key => $var)

+ {

+ if (is_array($var))

+ {

+ foreach ($var as $_key => $_var)

+ {

+ $s_hidden_fields .= '<input type="hidden" name="' . $key . '[' . $_key . ']" value="' . $_var . '" />';

+ }

+ }

+ else

+ {

+ $s_hidden_fields .= '<input type="hidden" name="' . $key . '" value="' . $var . '" />';

+ }

+ }

+ unset($hidden_fields);

+

+ if (confirm_box(true))

+ {

+ delete_pm($user_id, $msg_ids, $cur_folder_id);

+ // TODO: meta blabla

+ trigger_error('MESSAGE_DELETED');

+ }

+ else

+ {

+ confirm_box(false, 'DELETE_MARKED_PM', $s_hidden_fields);

+ }

+

+ break;

+

+ case 'export_as_xml':

+ case 'export_as_csv':

+ case 'export_as_txt':

+ $export_as = str_replace('export_as_', '', $mark_action);

+ break;

+

+ default:

+ return false;

+ }

+

+ return true;

+}

+

+// Delete PM(s)

+function delete_pm($user_id, $msg_ids, $folder_id)

+{

+ global $db;

+

+ $user_id = (int) $user_id;

+ $folder_id = (int) $folder_id;

+

+ if (!$user_id)

+ {

+ return false;

+ }

+

+ if (!is_array($msg_ids))

+ {

+ if (!$msg_ids)

+ {

+ return false;

+ }

+ $msg_ids = array($msg_ids);

+ }

+

+ if (!sizeof($msg_ids))

+ {

+ return false;

+ }

+

+ // Get PM Informations for later deleting

+ $sql = 'SELECT msg_id, unread, new

+ FROM ' . PRIVMSGS_TO_TABLE . '

+ WHERE msg_id IN (' . implode(', ', array_map('intval', $msg_ids)) . ")

+ AND folder_id = $folder_id

+ AND user_id = $user_id";

+ $result = $db->sql_query($sql);

+

+ $delete_rows = array();

+ $num_unread = $num_new = $num_deleted = 0;

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

+ {

+ $num_unread += (int) $row['unread'];

+ $num_new += (int) $row['new'];

+

+ $delete_rows[$row['msg_id']] = 1;

+ }

+ $db->sql_freeresult($result);

+ unset($msg_ids);

+

+ if (!sizeof($delete_rows))

+ {

+ return false;

+ }

+

+ // if no one has read the message yet (meaning it is in users outbox)

+ // then mark the message as deleted...

+ if ($folder_id == PRIVMSGS_OUTBOX)

+ {

+ // TODO: Recipients will see the message as deleted later

+ $sql = 'UPDATE ' . PRIVMSGS_TO_TABLE . '

+ SET deleted = 1, msg_id = 0

+ WHERE msg_id IN (' . implode(', ', array_keys($delete_rows)) . ')';

+ $db->sql_query($sql);

+ $num_deleted = $db->sql_affectedrows();

+ }

+ else

+ {

+ // Delete Private Message Informations

+ $sql = 'DELETE FROM ' . PRIVMSGS_TO_TABLE . "

+ WHERE user_id = $user_id

+ AND folder_id = $folder_id

+ AND msg_id IN (" . implode(', ', array_keys($delete_rows)) . ')';

+ $db->sql_query($sql);

+ $num_deleted = $db->sql_affectedrows();

+ }

+

+ // if folder id is user defined folder then decrease pm_count

+ if (!in_array($folder_id, array(PRIVMSGS_INBOX, PRIVMSGS_OUTBOX, PRIVMSGS_SENTBOX, PRIVMSGS_NO_BOX)))

+ {

+ $sql = 'UPDATE ' . PRIVMSGS_FOLDER_TABLE . "

+ SET pm_count = pm_count - $num_deleted

+ WHERE folder_id = $folder_id";

+ $db->sql_query($sql);

+ }

+

+ // Update unread and new status field

+ if ($num_unread || $num_new)

+ {

+ $set_sql = ($num_unread) ? 'user_unread_privmsg = user_unread_privmsg - ' . $num_unread : '';

+ if ($num_new)

+ {

+ $set_sql .= ($set_sql != '') ? ', ' : '';

+ $set_sql .= 'user_new_privmsg = user_new_privmsg - ' . $num_new;

+ }

+

+ $db->sql_query('UPDATE ' . USERS_TABLE . " SET $set_sql WHERE user_id = $user_id");

+ }

+

+ // Now we have to check which messages we can delete completely

+ $sql = 'SELECT msg_id

+ FROM ' . PRIVMSGS_TO_TABLE . '

+ WHERE msg_id IN (' . implode(', ', array_keys($delete_rows)) . ')';

+ $result = $db->sql_query($sql);

+

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

+ {

+ unset($delete_rows[$row['msg_id']]);

+ }

+ $db->sql_freeresult($result);

+

+ $delete_ids = implode(', ', $delete_rows);

+

+ if ($delete_ids)

+ {

+ $sql = 'DELETE FROM ' . PRIVMSGS_TABLE . '

+ WHERE msg_id IN (' . $delete_ids . ')';

+ $db->sql_query($sql);

+ }

+}

+

+// Rebuild message header

+function rebuild_header($check_ary)

+{

+ global $db;

+

+ $address = array();

+

+ foreach ($check_ary as $check_type => $address_field)

+ {

+ // Split Addresses into users and groups

+ preg_match_all('/:?(u|g)_([0-9]+):?/', $address_field, $match);

+

+ $u = $g = array();

+ foreach ($match[1] as $id => $type)

+ {

+ ${$type}[] = (int) $match[2][$id];

+ }

+

+ foreach (array('u', 'g') as $type)

+ {

+ if (sizeof($$type))

+ {

+ foreach ($$type as $id)

+ {

+ $address[$type][$id] = $check_type;

+ }

+ }

+ }

+ }

+

+ return $address;

+}

+

+// Print out/Assign recipient informations

+function write_pm_addresses($check_ary, $author, $plaintext = false)

+{

+ global $db, $user, $template, $phpbb_root_path, $SID, $phpEx;

+

+ $addresses = array();

+

+ foreach ($check_ary as $check_type => $address_field)

+ {

+ // Split Addresses into users and groups

+ preg_match_all('/:?(u|g)_([0-9]+):?/', $address_field, $match);

+

+ $u = $g = array();

+ foreach ($match[1] as $id => $type)

+ {

+ ${$type}[] = (int) $match[2][$id];

+ }

+

+ $address = array();

+ if (sizeof($u))

+ {

+ $sql = 'SELECT user_id, username, user_colour

+ FROM ' . USERS_TABLE . '

+ WHERE user_id IN (' . implode(', ', $u) . ')';

+ $result = $db->sql_query($sql);

+

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

+ {

+ if ($check_type == 'to' || $author == $user->data['user_id'] || $row['user_id'] == $user->data['user_id'])

+ {

+ if ($plaintext)

+ {

+ $address[] = $row['username'];

+ }

+ else

+ {

+ $address['user'][$row['user_id']] = array('name' => $row['username'], 'colour' => $row['user_colour']);

+ }

+ }

+ }

+ $db->sql_freeresult($result);

+ }

+

+ if (sizeof($g))

+ {

+ if ($plaintext)

+ {

+ $sql = 'SELECT group_name

+ FROM ' . GROUPS_TABLE . '

+ WHERE group_id IN (' . implode(', ', $g) . ')';

+ $result = $db->sql_query($sql);

+

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

+ {

+ if ($check_type == 'to' || $author == $user->data['user_id'] || $row['user_id'] == $user->data['user_id'])

+ {

+ $address[] = $row['group_name'];

+ }

+ }

+ $db->sql_freeresult($result);

+ }

+ else

+ {

+ $sql = 'SELECT g.group_id, g.group_name, g.group_colour, ug.user_id

+ FROM ' . GROUPS_TABLE . ' g, ' . USER_GROUP_TABLE . ' ug

+ WHERE g.group_id IN (' . implode(', ', $g) . ')

+ AND g.group_id = ug.group_id

+ AND ug.user_pending = 0';

+ $result = $db->sql_query($sql);

+

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

+ {

+ if (!isset($address['group'][$row['group_id']]))

+ {

+ if ($check_type == 'to' || $author == $user->data['user_id'] || $row['user_id'] == $user->data['user_id'])

+ {

+ $address['group'][$row['group_id']] = array('name' => $row['group_name'], 'colour' => $row['group_colour']);

+ }

+ }

+

+ if (isset($address['user'][$row['user_id']]))

+ {

+ $address['user'][$row['user_id']]['in_group'] = $row['group_id'];

+ }

+ }

+ $db->sql_freeresult($result);

+ }

+ }

+

+ if (sizeof($address) && !$plaintext)

+ {

+ $template->assign_var('S_' . strtoupper($check_type) . '_RECIPIENT', true);

+

+ foreach ($address as $type => $adr_ary)

+ {

+ foreach ($adr_ary as $id => $row)

+ {

+ $template->assign_block_vars($check_type . '_recipient', array(

+ 'NAME' => $row['name'],

+ 'IS_GROUP' => ($type == 'group'),

+ 'IS_USER' => ($type == 'user'),

+ 'COLOUR' => ($row['colour']) ? $row['colour'] : '',

+ 'UG_ID' => $id,

+ 'U_VIEW' => ($type == 'user') ? "{$phpbb_root_path}memberlist.$phpEx$SID&amp;mode=viewprofile&amp;u=" . $id : "{$phpbb_root_path}groupcp.$phpEx$SID&amp;g=" . $id)

+ );

+ }

+ }

+ }

+

+ $addresses[$check_type] = $address;

+ }

+

+ return $addresses;

+}

+

+// Get folder status

+function get_folder_status($folder_id, $folder)

+{

+ global $db, $user, $config;

+

+ $folder = $folder[$folder_id];

+ $return = array();

+

+ $message_limit = (!$user->data['group_message_limit']) ? $config['pm_max_msgs'] : $user->data['group_message_limit'];

+

+ $return = array(

+ 'folder_name' => $folder['folder_name'],

+ 'cur' => $folder['num_messages'],

+ 'remaining' => $message_limit - $folder['num_messages'],

+ 'max' => $message_limit,

+ 'percent' => ($message_limit > 0) ? round(($folder['num_messages'] / $message_limit) * 100) : 100

+ );

+

+ $return['message'] = sprintf($user->lang['FOLDER_STATUS_MSG'], $return['percent'], $return['cur'], $return['max']);

+

+ return $return;

+}

+

+?> \ No newline at end of file