*/

function clean_sentbox($num_sentbox_messages)

{

// Check Message Limit

if ($user->data['message_limit'] && $num_sentbox_messages > $user->data['message_limit'])

*/

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

{

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

{

return false;

break;

case ACTION_DELETE_MESSAGE:

// Check for admins/mods - users are not allowed to remove those messages...

// We do the check here to make sure the data we use is consistent

}

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

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

{

global $db, $user, $phpbb_container;

$phpbb_notifications = $phpbb_container->get('notification_manager');

$sql = 'UPDATE ' . PRIVMSGS_TO_TABLE . "

SET pm_unread = 0

*/

function handle_mark_actions($user_id, $mark_action)

{

if (!sizeof($msg_ids))

{

*/

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

{

$user_id = (int) $user_id;

$folder_id = (int) $folder_id;

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

}

$phpbb_notifications = $phpbb_container->get('notification_manager');

$phpbb_notifications->delete_notifications('notification.type.pm', array_keys($delete_rows));

if (sizeof($delete_ids))

{

// Check if there are any attachments we need to remove

$sql = 'DELETE FROM ' . PRIVMSGS_TABLE . '

WHERE ' . $db->sql_in_set('msg_id', $delete_ids);

*/

function phpbb_delete_user_pms($user_id)

{

$user_id = (int) $user_id;

if (!$user_id)

*/

function phpbb_delete_users_pms($user_ids)

{

$user_id_sql = $db->sql_in_set('user_id', $user_ids);

$author_id_sql = $db->sql_in_set('author_id', $user_ids);

$db->sql_transaction('begin');

$phpbb_notifications = $phpbb_container->get('notification_manager');

if (!empty($undelivered_msg))

if (!empty($delete_ids))

{

// Check if there are any attachments we need to remove

$sql = 'DELETE FROM ' . PRIVMSGS_TABLE . '

WHERE ' . $db->sql_in_set('msg_id', $delete_ids);

*/

function rebuild_header($check_ary)

{

$address = array();

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

*/

function write_pm_addresses($check_ary, $author_id, $plaintext = false)

{

$addresses = array();

{

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

{

}

}

$db->sql_freeresult($result);

{

if ($check_type == 'to' || $author_id == $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']);

}

}

*/

function get_folder_status($folder_id, $folder)

{

if (isset($folder[$folder_id]))

{

/**

* Submit PM

*/

{

// We do not handle erasing pms here

if ($mode == 'delete')

$current_time = time();

/**

* Get all parts of the PM that are to be submited to the DB.

*

*/

$vars = array('mode', 'subject', 'data');

extract($phpbb_dispatcher->trigger_event('core.submit_pm_before', compact($vars)));

// Collect some basic information about which tables and which rows to update/insert

$sql_data = array();

$_types = array('u', 'g');

foreach ($_types as $ug_type)

{

{

{

$id = (int) $id;

}

}

{

// We need to check the PM status of group members (do they want to receive PM's?)

// Only check if not a moderator or admin, since they are allowed to override this user setting

$sql = 'SELECT u.user_type, ug.group_id, ug.user_id

FROM ' . USERS_TABLE . ' u, ' . USER_GROUP_TABLE . ' ug

AND ug.user_pending = 0

AND u.user_id = ug.user_id

AND u.user_type IN (' . USER_NORMAL . ', ' . USER_FOUNDER . ')' .

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

{

$recipients[$row['user_id']] = $field;

}

$db->sql_freeresult($result);

{

case 'reply':

case 'quote':

// Set message_replied switch for this user

$sql = 'UPDATE ' . PRIVMSGS_TO_TABLE . '

SET pm_replied = 1

// no break

case 'quotepost':

$sql_data = array(

'root_level' => $root_level,

'message_time' => $current_time,

'message_subject' => $subject,

'to_address' => implode(':', $to),

'bcc_address' => implode(':', $bcc),

'message_reported' => 0,

case 'edit':

$sql_data = array(

'message_edit_time' => $current_time,

'message_subject' => $subject,

);

break;

}

if (sizeof($sql_data))

{

if ($mode == 'post' || $mode == 'reply' || $mode == 'quote' || $mode == 'quotepost' || $mode == 'forward')

{

$db->sql_query('INSERT INTO ' . PRIVMSGS_TABLE . ' ' . $db->sql_build_array('INSERT', $sql_data));

}

else if ($mode == 'edit')

{

$sql = 'UPDATE ' . PRIVMSGS_TABLE . '

SET message_edit_count = message_edit_count + 1, ' . $db->sql_build_array('UPDATE', $sql_data) . '

$db->sql_query($sql);

}

}

foreach ($recipients as $user_id => $type)

{

$sql_ary[] = array(

'user_id' => (int) $user_id,

'folder_id' => PRIVMSGS_NO_BOX,

'pm_new' => 1,

'pm_unread' => 1,

if ($put_in_outbox)

{

$db->sql_query('INSERT INTO ' . PRIVMSGS_TO_TABLE . ' ' . $db->sql_build_array('INSERT', array(

'folder_id' => PRIVMSGS_OUTBOX,

'pm_new' => 0,

'pm_unread' => 0,

{

$sql = 'UPDATE ' . USERS_TABLE . "

SET user_lastpost_time = $current_time

$db->sql_query($sql);

}

// Submit Attachments

{

$space_taken = $files_added = 0;

$orphan_rows = array();

{

$orphan_rows[(int) $attach_row['attach_id']] = array();

}

$db->sql_freeresult($result);

}

{

if ($attach_row['is_orphan'] && !isset($orphan_rows[$attach_row['attach_id']]))

{

$files_added++;

$attach_sql = array(

'topic_id' => 0,

'is_orphan' => 0,

'attach_comment' => $attach_row['attach_comment'],

);

if ($space_taken && $files_added)

{

}

}

// Delete draft if post was loaded...

if ($draft_id)

{

$sql = 'DELETE FROM ' . DRAFTS_TABLE . "

WHERE draft_id = $draft_id

$db->sql_query($sql);

}

$db->sql_transaction('commit');

// Send Notifications

'message_subject' => $subject,

'recipients' => $recipients,

));

$phpbb_notifications = $phpbb_container->get('notification_manager');

if ($mode == 'edit')

$phpbb_notifications->add_notifications('notification.type.pm', $pm_data);

}

/**

* Get PM message ID after submission to DB

*

*/

$vars = array('mode', 'subject', 'data', 'pm_data');

extract($phpbb_dispatcher->trigger_event('core.submit_pm_after', compact($vars)));

}

/**

*/

function message_history($msg_id, $user_id, $message_row, $folder, $in_post_mode = false)

{

// Select all receipts and the author from the pm we currently view, to only display their pm-history

$sql = 'SELECT author_id, user_id

'S_IN_POST_MODE' => $in_post_mode,

'MSG_ID' => $row['msg_id'],

'U_VIEW_MESSAGE' => "$url&f=$folder_id&p=" . $row['msg_id'],

'U_QUOTE' => (!$in_post_mode && $auth->acl_get('u_sendpm') && $author_id != ANONYMOUS) ? "$url&mode=compose&action=quote&f=" . $folder_id . "&p=" . $row['msg_id'] : '',

'U_POST_REPLY_PM' => ($author_id != $user->data['user_id'] && $author_id != ANONYMOUS && $auth->acl_get('u_sendpm')) ? "$url&mode=compose&action=reply&f=$folder_id&p=" . $row['msg_id'] : '')

{

global $user, $db, $config;

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

AND ug.user_pending = 0

AND ug.group_id = g.group_id';

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

$db->sql_freeresult($result);

}

/**

*/

function get_recipient_strings($pm_by_id)

{

$address_list = $recipient_list = $address = array();

{

if ($ug_type == 'g')

{

}

$recipient_list[$ug_type][$row['id']] = array('name' => $row['name'], 'colour' => $row['colour']);