- add even more bugs to the codebase

- changed submit_pm to carry on the from userdata


git-svn-id: file:///svn/phpbb/trunk@5241 89ea8834-ac86-4346-8a33-228a782c2dd0
This commit is contained in:
Meik Sievertsen 2005-10-02 18:17:06 +00:00
parent 58d146cac6
commit 1a18e36684
3 changed files with 50 additions and 33 deletions

View file

@ -228,7 +228,7 @@ class messenger
global $user, $phpEx, $phpbb_root_path; global $user, $phpEx, $phpbb_root_path;
// Session doesn't exist, create it // Session doesn't exist, create it
$user->start(); $user->session_begin();
include_once($phpbb_root_path . 'includes/functions_admin.'.$phpEx); include_once($phpbb_root_path . 'includes/functions_admin.'.$phpEx);
add_log('critical', 'LOG_' . $type . '_ERROR', $msg); add_log('critical', 'LOG_' . $type . '_ERROR', $msg);
@ -472,7 +472,12 @@ class queue
foreach ($this->queue_data as $object => $data_ary) foreach ($this->queue_data as $object => $data_ary)
{ {
@set_time_limit(60); @set_time_limit(0);
if (!isset($data_ary['package_size']))
{
$data_ary['package_size'] = 0;
}
$package_size = $data_ary['package_size']; $package_size = $data_ary['package_size'];
$num_items = (sizeof($data_ary['data']) < $package_size) ? sizeof($data_ary['data']) : $package_size; $num_items = (sizeof($data_ary['data']) < $package_size) ? sizeof($data_ary['data']) : $package_size;
@ -798,7 +803,7 @@ function smtpmail($addresses, $subject, $message, &$err_msg, $encoding, $headers
// We try to send messages even if a few people do not seem to have valid email addresses, but if no one has, we have to exit here. // We try to send messages even if a few people do not seem to have valid email addresses, but if no one has, we have to exit here.
if (!$rcpt) if (!$rcpt)
{ {
$user->start(); $user->session_begin();
$err_msg .= '<br /><br />' . sprintf($user->lang['INVALID_EMAIL_LOG'], htmlspecialchars($mail_to_address)); $err_msg .= '<br /><br />' . sprintf($user->lang['INVALID_EMAIL_LOG'], htmlspecialchars($mail_to_address));
$smtp->close_session(); $smtp->close_session();
return false; return false;

View file

@ -140,7 +140,8 @@ function update_last_post_information($type, $id)
*/ */
function upload_attachment($form_name, $forum_id, $local = false, $local_storage = '', $is_message = false) function upload_attachment($form_name, $forum_id, $local = false, $local_storage = '', $is_message = false)
{ {
global $auth, $user, $config, $db, $phpbb_root_path; global $auth, $user, $config, $db, $cache;
global $phpbb_root_path;
$filedata = array(); $filedata = array();
$filedata['error'] = array(); $filedata['error'] = array();
@ -164,18 +165,11 @@ function upload_attachment($form_name, $forum_id, $local = false, $local_storage
} }
$extensions = array(); $extensions = array();
obtain_attach_extensions($extensions, $forum_id); $cache->obtain_attach_extensions($extensions, $forum_id);
$upload->set_allowed_extensions(array_keys($extensions['_allowed_'])); $upload->set_allowed_extensions(array_keys($extensions['_allowed_']));
if ($local) $file = ($local) ? $upload->local_upload($local_storage) : $upload->form_upload($form_name);
{
$file = $upload->local_upload($local_storage);
}
else
{
$file = $upload->form_upload($form_name);
}
if ($file->init_error) if ($file->init_error)
{ {
@ -475,11 +469,11 @@ function decode_message(&$message, $bbcode_uid = '')
*/ */
function posting_gen_topic_icons($mode, $icon_id) function posting_gen_topic_icons($mode, $icon_id)
{ {
global $phpbb_root_path, $config, $template; global $phpbb_root_path, $config, $template, $cache;
// Grab icons // Grab icons
$icons = array(); $icons = array();
obtain_icons($icons); $cache->obtain_icons($icons);
if (!$icon_id) if (!$icon_id)
{ {

View file

@ -11,9 +11,6 @@
/** /**
*/ */
// Define Rule processing schema
// NOTE: might change
/* /*
Ability to simply add own rules by doing three things: Ability to simply add own rules by doing three things:
1) Add an appropiate constant 1) Add an appropiate constant
@ -1080,7 +1077,7 @@ function get_folder_status($folder_id, $folder)
*/ */
function submit_pm($mode, $subject, &$data, $update_message, $put_in_outbox = true) function submit_pm($mode, $subject, &$data, $update_message, $put_in_outbox = true)
{ {
global $db, $auth, $user, $config, $phpEx, $SID, $template; global $db, $auth, $config, $phpEx, $SID, $template, $user;
// We do not handle erasing posts here // We do not handle erasing posts here
if ($mode == 'delete') if ($mode == 'delete')
@ -1150,16 +1147,17 @@ function submit_pm($mode, $subject, &$data, $update_message, $put_in_outbox = tr
// Set message_replied switch for this user // Set message_replied switch for this user
$sql = 'UPDATE ' . PRIVMSGS_TO_TABLE . ' $sql = 'UPDATE ' . PRIVMSGS_TO_TABLE . '
SET replied = 1 SET replied = 1
WHERE user_id = ' . $user->data['user_id'] . ' WHERE user_id = ' . $data['from_user_id'] . '
AND msg_id = ' . $data['reply_from_msg_id']; AND msg_id = ' . $data['reply_from_msg_id'];
case 'forward': case 'forward':
case 'post': case 'post':
case 'quotepost':
$sql_data = array( $sql_data = array(
'root_level' => $root_level, 'root_level' => $root_level,
'author_id' => (int) $user->data['user_id'], 'author_id' => $data['from_user_id'],
'icon_id' => $data['icon_id'], 'icon_id' => $data['icon_id'],
'author_ip' => $user->ip, 'author_ip' => $data['from_user_ip'],
'message_time' => $current_time, 'message_time' => $current_time,
'enable_bbcode' => $data['enable_bbcode'], 'enable_bbcode' => $data['enable_bbcode'],
'enable_html' => $data['enable_html'], 'enable_html' => $data['enable_html'],
@ -1200,7 +1198,7 @@ function submit_pm($mode, $subject, &$data, $update_message, $put_in_outbox = tr
if (sizeof($sql_data)) if (sizeof($sql_data))
{ {
if ($mode == 'post' || $mode == 'reply' || $mode == 'quote' || $mode == 'forward') 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)); $db->sql_query('INSERT INTO ' . PRIVMSGS_TABLE . ' ' . $db->sql_build_array('INSERT', $sql_data));
$data['msg_id'] = $db->sql_nextid(); $data['msg_id'] = $db->sql_nextid();
@ -1224,12 +1222,13 @@ function submit_pm($mode, $subject, &$data, $update_message, $put_in_outbox = tr
} }
unset($sql); unset($sql);
$sql_ary = array();
foreach ($recipients as $user_id => $type) foreach ($recipients as $user_id => $type)
{ {
$db->sql_query('INSERT INTO ' . PRIVMSGS_TO_TABLE . ' ' . $db->sql_build_array('INSERT', array( $sql_ary[] = array(
'msg_id' => $data['msg_id'], 'msg_id' => $data['msg_id'],
'user_id' => $user_id, 'user_id' => $user_id,
'author_id' => $user->data['user_id'], 'author_id' => $data['from_user_id'],
'folder_id' => PRIVMSGS_NO_BOX, 'folder_id' => PRIVMSGS_NO_BOX,
'new' => 1, 'new' => 1,
'unread' => 1, 'unread' => 1,
@ -1237,6 +1236,25 @@ function submit_pm($mode, $subject, &$data, $update_message, $put_in_outbox = tr
); );
} }
if (sizeof($sql_ary))
{
switch (SQL_LAYER)
{
case 'mysql':
case 'mysql4':
case 'mysqli':
$db->sql_query('INSERT INTO ' . PRIVMSGS_TO_TABLE . ' ' . $db->sql_build_array('MULTI_INSERT', $sql_ary);
break;
default:
foreach ($sql_ary as $ary)
{
$db->sql_query('INSERT INTO ' . PRIVMSGS_TO_TABLE . ' ' . $db->sql_build_array('INSERT', $ary));
}
break;
}
}
$sql = 'UPDATE ' . USERS_TABLE . ' $sql = 'UPDATE ' . USERS_TABLE . '
SET user_new_privmsg = user_new_privmsg + 1, user_unread_privmsg = user_unread_privmsg + 1, user_last_privmsg = ' . time() . ' SET user_new_privmsg = user_new_privmsg + 1, user_unread_privmsg = user_unread_privmsg + 1, user_last_privmsg = ' . time() . '
WHERE user_id IN (' . implode(', ', array_keys($recipients)) . ')'; WHERE user_id IN (' . implode(', ', array_keys($recipients)) . ')';
@ -1247,8 +1265,8 @@ function submit_pm($mode, $subject, &$data, $update_message, $put_in_outbox = tr
{ {
$db->sql_query('INSERT INTO ' . PRIVMSGS_TO_TABLE . ' ' . $db->sql_build_array('INSERT', array( $db->sql_query('INSERT INTO ' . PRIVMSGS_TO_TABLE . ' ' . $db->sql_build_array('INSERT', array(
'msg_id' => (int) $data['msg_id'], 'msg_id' => (int) $data['msg_id'],
'user_id' => (int) $user->data['user_id'], 'user_id' => (int) $data['from_user_id'],
'author_id' => (int) $user->data['user_id'], 'author_id' => (int) $data['from_user_id'],
'folder_id' => PRIVMSGS_OUTBOX, 'folder_id' => PRIVMSGS_OUTBOX,
'new' => 0, 'new' => 0,
'unread' => 0, 'unread' => 0,
@ -1260,18 +1278,18 @@ function submit_pm($mode, $subject, &$data, $update_message, $put_in_outbox = tr
} }
// Set user last post time // Set user last post time
if ($mode == 'reply' || $mode == 'quote' || $mode == 'forward' || $mode == 'post') if ($mode == 'reply' || $mode == 'quote' || $mode == 'quotepost' || $mode == 'forward' || $mode == 'post')
{ {
$sql = 'UPDATE ' . USERS_TABLE . " $sql = 'UPDATE ' . USERS_TABLE . "
SET user_lastpost_time = $current_time SET user_lastpost_time = $current_time
WHERE user_id = " . $user->data['user_id']; WHERE user_id = " . $data['from_user_id'];
$db->sql_query($sql); $db->sql_query($sql);
} }
$db->sql_transaction(); $db->sql_transaction();
// Submit Attachments // Submit Attachments
if (sizeof($data['attachment_data']) && $data['msg_id'] && in_array($mode, array('post', 'reply', 'quote', 'edit', 'forward'))) if (sizeof($data['attachment_data']) && $data['msg_id'] && in_array($mode, array('post', 'reply', 'quote', 'quotepost', 'edit', 'forward')))
{ {
$space_taken = $files_added = 0; $space_taken = $files_added = 0;
@ -1292,7 +1310,7 @@ function submit_pm($mode, $subject, &$data, $update_message, $put_in_outbox = tr
'post_msg_id' => $data['msg_id'], 'post_msg_id' => $data['msg_id'],
'topic_id' => 0, 'topic_id' => 0,
'in_message' => 1, 'in_message' => 1,
'poster_id' => $user->data['user_id'], 'poster_id' => $data['from_user_id'],
'physical_filename' => basename($attach_row['physical_filename']), 'physical_filename' => basename($attach_row['physical_filename']),
'real_filename' => basename($attach_row['real_filename']), 'real_filename' => basename($attach_row['real_filename']),
'comment' => $attach_row['comment'], 'comment' => $attach_row['comment'],
@ -1335,14 +1353,14 @@ function submit_pm($mode, $subject, &$data, $update_message, $put_in_outbox = tr
{ {
$sql = 'DELETE FROM ' . DRAFTS_TABLE . " $sql = 'DELETE FROM ' . DRAFTS_TABLE . "
WHERE draft_id = $draft_id WHERE draft_id = $draft_id
AND user_id = " . $user->data['user_id']; AND user_id = " . $data['from_user_id'];
$db->sql_query($sql); $db->sql_query($sql);
} }
// Send Notifications // Send Notifications
if ($mode != 'edit') if ($mode != 'edit')
{ {
pm_notification($mode, stripslashes($user->data['username']), $recipients, stripslashes($subject), stripslashes($data['message'])); pm_notification($mode, stripslashes($data['from_username']), $recipients, stripslashes($subject), stripslashes($data['message']));
} }
return $data['msg_id']; return $data['msg_id'];