diff -urp privatemsg/privatemsg-view.tpl.php privatemsg_nbz/privatemsg-view.tpl.php --- privatemsg/privatemsg-view.tpl.php 2008-06-10 09:38:27.000000000 +0100 +++ privatemsg_nbz/privatemsg-view.tpl.php 2008-10-12 22:17:30.646291300 +0100 @@ -21,6 +21,9 @@
+
+ +
\ No newline at end of file diff -urp privatemsg/privatemsg.install privatemsg_nbz/privatemsg.install --- privatemsg/privatemsg.install 2008-07-27 02:42:01.000000000 +0100 +++ privatemsg_nbz/privatemsg.install 2008-10-12 20:19:15.890291300 +0100 @@ -17,20 +17,8 @@ function privatemsg_schema() { 'not null' => TRUE, 'unsigned' => TRUE, ), - 'recipient' => array( - 'description' => t('UID of the recipient'), - 'type' => 'int', - 'not null' => TRUE, - 'unsigned' => TRUE, - ), - 'author' => array( - 'description' => t('UID of the author'), - 'type' => 'int', - 'not null' => TRUE, - 'unsigned' => TRUE, - ), - 'timestamp' => array( - 'description' => t('Time when the message was sent'), + 'uid' => array( + 'description' => t('UID of either the author or the recipient'), 'type' => 'int', 'not null' => TRUE, 'unsigned' => TRUE, @@ -42,14 +30,20 @@ function privatemsg_schema() { 'not null' => TRUE, 'unsigned' => TRUE, ), + 'deleted' => array( + 'description' => t('Whether the user has deleted this message'), + 'type' => 'int', + 'unsigned' => TRUE, + 'not null' => TRUE, + 'default' => 0 + ), + ), 'indexes' => array( '`mid`' => array('`mid`'), - '`author`' => array('`author`'), '`thread_id`' => array('`thread_id`'), - '`recipient`' => array('`recipient`'), - '`timestamp`' => array('`timestamp`'), - '`new`' => array('`mid`','`recipient`','`new`',), + '`uid`' => array('`uid`'), + '`new`' => array('`mid`','`uid`','`new`',), ), ); @@ -80,11 +74,18 @@ function privatemsg_schema() { 'not null' => TRUE, 'size' => 'big', ), + 'timestamp' => array( + 'description' => t('Time when the message was sent'), + 'type' => 'int', + 'not null' => TRUE, + 'unsigned' => TRUE, + ), ), 'primary key' => array('mid'), 'indexes' => array( '`author`' => array('`author`'), '`subject`' => array(array('`subject`', 20)), + '`timestamp`' => array('`timestamp`'), ), ); diff -urp privatemsg/privatemsg.module privatemsg_nbz/privatemsg.module --- privatemsg/privatemsg.module 2008-09-20 21:22:20.000000000 +0100 +++ privatemsg_nbz/privatemsg.module 2008-10-12 22:26:49.401091300 +0100 @@ -65,6 +65,14 @@ function privatemsg_menu() { 'type' => MENU_CALLBACK, 'weight' => -10, ); + $items['messages/delete/%'] = array( + 'title' => 'Delete message', + 'page callback' => 'privatemsg_delete', + 'page arguments' => array(2), + 'access arguments' => array('read privatemsg'), + 'type' => MENU_CALLBACK, + 'weight' => -10, + ); $items['messages/new'] = array( 'title' => 'Create', 'page callback' => 'drupal_get_form', @@ -179,9 +187,7 @@ function privatemsg_preprocess_privatems $vars['author_name_link'] = theme('username', $message['author']); $vars['message_timestamp'] = date("M j \a\\t g:ia", $message['timestamp']); $vars['message_body'] = check_markup($message['body']); -// drupal_set_message('
'. print_r('what', 1) .'
'); -// drupal_set_message('
'. print_r(func_get_args(), 1) .'
'); -// drupal_set_message('
'. print_r($vars, 1) .'
'); + $vars ['message_actions'] = privatemsg_per_message_actions($message['mid']); } function privatemsg_preprocess_privatemsg_to(&$vars) { @@ -251,7 +257,7 @@ function privatemsg_list($uid = NULL) { $messages = array(); while ($row = db_fetch_array($result)) { - $row['subject'] = l($row['subject'], 'messages/view/'. $row['id']); + $row['subject'] = l($row['subject'], 'messages/view/'. $row['thread_id']); $messages[] = $row; } @@ -262,12 +268,6 @@ function privatemsg_list($uid = NULL) { switch ($index) { case 'id': continue 2; - case 'author': - $col = 'from'; - break; - case 'recipient': - $col = 'to'; - break; case 'timestamp': $col = arg(1) == 'sent' ? 'sent' : 'received'; break; @@ -362,7 +362,7 @@ function privatemsg_set_new_status($acco global $user; $account = $user; } - $query = "UPDATE {pm_index} pmi SET new = %d WHERE recipient = %d AND new = %d"; + $query = "UPDATE {pm_index} pmi SET new = %d WHERE uid = %d AND new = %d"; $arg[] = $new; $arg[] = $account->uid; $arg[] = ($new == 0) ? 1 : 0; @@ -417,12 +417,16 @@ function privatemsg_view($thread_id) { $output = theme('privatemsg_to', $message); } $output .= theme('privatemsg_view', $message); + $message_count++; } - if (user_access('write privatemsg')) { + if (user_access('write privatemsg') && $message_count > 0) { $output .= drupal_get_form('privatemsg_new'); } + else { + drupal_set_message('There are no messages available to display', 'error'); + } return $output; } @@ -604,7 +608,8 @@ function pm_send($form, &$form_state) { $args[] = $message['subject']; $args[] = $message['author']->uid; $args[] = $message['body']; - $query = "INSERT INTO {pm_message} (mid, subject, author, body) VALUES (null, '%s', %d, '%s')"; + $args[] = $message['timestamp']; + $query = "INSERT INTO {pm_message} (mid, subject, author, body, timestamp) VALUES (null, '%s', %d, '%s', %d)"; $resuld = db_query($query, $args); $mid = db_last_insert_id('pm_message', 'mid'); $message['mid'] = $mid; @@ -615,13 +620,14 @@ function pm_send($form, &$form_state) { } // 2) Save message to recipients. // Each recipient gets a record in the pm_index table. - $query = "INSERT INTO {pm_index} (mid, thread_id, recipient, author, timestamp, new) VALUES (%d, %d, %d, %d, %d, 1)"; + $query = "INSERT INTO {pm_index} (mid, thread_id, uid, new, deleted) VALUES (%d, %d, %d, %d, 0)"; foreach ($message['recipients'] as $recipient) { $mid = $message['mid']; $thread_id = $message['thread_id']; - $timestamp = $message['timestamp']; - db_query($query, $mid, $thread_id, $recipient->uid, $message['author']->uid , $timestamp); + db_query($query, $mid, $thread_id, $recipient->uid, 1); } + // Also add a record for tha author to the pm_index table - set column "new" to 0. + db_query($query, $mid, $thread_id, $message['author']->uid, 0); drupal_set_message('A private message has been sent to '. $form_state['values']['recipient']); } @@ -666,33 +672,22 @@ function pm_preview($form, &$form_state) function privatemsg_privatemsg_list_sent_alter(&$fragments, $account) { $fragments['primary_table'] = '{pm_message} pm'; - $fragments['select'][] = 'MAX(pm.mid) as id'; $fragments['select'][] = 'pmi.thread_id'; $fragments['select'][] = 'pm.subject'; - if ($account->uid != $GLOBALS['user']->uid) { - $fragments['select'][] = 'pmi.author'; - } - $fragments['select'][] = 'pmi.recipient'; - $fragments['select'][] = 'pmi.timestamp'; + $fragments['select'][] = 'MAX(pm.timestamp) as timestamp'; $fragments['inner_join'][] = 'INNER JOIN {pm_index} pmi ON pm.mid = pmi.mid'; - $fragments['where'][] = 'pmi.author = %d'; + $fragments['where'][] = 'pm.author = %d'; + $fragments['where'][] = 'pmi.deleted = 0'; $fragments['group_by'][] = 'pmi.thread_id'; - $order = 'MAX(pmi.timestamp)'; + $order = 'timestamp'; $sort = 'desc'; if (isset($_GET['order'])) { switch ($_GET['order']) { case ('subject'): $order = 'pm.subject'; break; - case ('from'): - $order = 'pmi.author'; - break; - case ('to'): - $order = 'pmi.recipient'; - break; - case ('sent'): default: - $order = 'pmi.timestamp'; + $order = 'timestamp'; } $sort = isset($_GET['sort']) && ($_GET['sort'] == 'asc' || $_GET['sort'] == 'desc') ? $_GET['sort'] : 'desc'; } @@ -703,18 +698,14 @@ function privatemsg_privatemsg_list_sent function privatemsg_privatemsg_list_alter(&$fragments, $account) { $fragments['primary_table'] = '{pm_message} pm'; - $fragments['select'][] = 'MAX(pmi.mid) as id'; $fragments['select'][] = 'pmi.thread_id'; $fragments['select'][] = 'pm.subject'; - $fragments['select'][] = 'pmi.author'; - if ($account->uid != $GLOBALS['user']->uid) { - $fragments['select'][] = 'pmi.recipient'; - } - $fragments['select'][] = 'pmi.timestamp'; - $fragments['select'][] = 'MAX(pmi.new) as new'; + $fragments['select'][] = 'MAX(pm.timestamp) as timestamp'; + $fragments['select'][] = 'MAX(pmi.new) as new'; $fragments['inner_join'][] = 'INNER JOIN {pm_index} pmi ON pm.mid = pmi.mid'; - $fragments['where'][] = 'pmi.recipient = %d'; - $fragments['group_by'][] = 'pmi.thread_id'; + $fragments['where'][] = 'pmi.uid = %d'; + $fragments['where'][] = 'pmi.deleted = 0'; + $fragments['group_by'][] = 'pmi.thread_id'; $order = 'pmi.new'; $sort = 'desc'; if (isset($_GET['order'])) { @@ -722,15 +713,8 @@ function privatemsg_privatemsg_list_alte case ('subject'): $order = 'pm.subject'; break; - case ('from'): - $order = 'pmi.author'; - break; - case ('to'): - $order = 'pmi.recipient'; - break; - case ('received'): default: - $order = 'MAX(pmi.timestamp)'; + $order = 'timestamp'; } $sort = isset($_GET['sort']) && ($_GET['sort'] == 'asc' || $_GET['sort'] == 'desc') ? $_GET['sort'] : 'desc'; } @@ -743,14 +727,17 @@ function privatemsg_privatemsg_load_alte // drupal_set_message('
'. print_r(func_get_args(), 1) . '
'); $fragments['primary_table'] = '{pm_message} pm'; // Our primary table - $fragments['select'][] = "pm.*"; // Gets all data from primary table. - $fragments['select'][] = "pmi.*"; + $fragments['select'][] = "pm.mid"; + $fragments['select'][] = "pm.author"; + $fragments['select'][] = "pm.subject"; + $fragments['select'][] = "pm.body"; + $fragments['select'][] = "pm.timestamp"; + $fragments['select'][] = "pmi.new"; $fragments['inner_join'][] = 'INNER JOIN {pm_index} pmi ON pm.mid = pmi.mid'; $fragments['where'][] = 'pmi.mid = %d'; $fragments['query_args'][] = $pmid; - $fragments['where'][] = 'pmi.recipient = %d or pmi.author = %d'; - $fragments['query_args'][] = $uid; + $fragments['where'][] = 'pmi.uid = %d'; $fragments['query_args'][] = $uid; } @@ -760,26 +747,19 @@ function privatemsg_privatemsg_messages_ $fragments['select'][] = 'DISTINCT(pmi.mid) as mid'; $fragments['where'][] = 'pmi.thread_id = %d'; $fragments['query_args'][] = $thread_id; - if (!(user_access('read all private messages'))) { - $fragments['where'][] = 'pmi.author = %d'; - $fragments['query_args'][] = $uid; - $fragments['union_select'][] = 'DISTINCT(pmi.mid) as mid'; - $fragments['union_where'][] = 'pmi.thread_id = %d'; - $fragments['union_where'][] = 'pmi.recipient = %d'; - $fragments['query_args'][] = $thread_id; +// if (!(user_access('read all private messages'))) { + $fragments['where'][] = 'pmi.uid = %d'; $fragments['query_args'][] = $uid; - } +// } + $fragments['where'][] = 'pmi.deleted = 0'; $fragments['order_by'][] = 'mid ASC'; } function privatemsg_privatemsg_participants_alter(&$fragments, $thread_id) { $fragments['primary_table'] = '{pm_index} pmi'; - $fragments['select'][] = 'pmi.recipient as uid'; + $fragments['select'][] = 'DISTINCT(pmi.uid) as uid'; $fragments['where'][] = 'pmi.thread_id = %d'; - $fragments['union_select'][] = 'pmi.author as uid'; - $fragments['union_where'][] = 'pmi.thread_id = %d'; - $fragments['query_args'][] = $thread_id; $fragments['query_args'][] = $thread_id; } @@ -787,9 +767,9 @@ function privatemsg_privatemsg_participa function privatemsg_privatemsg_unread_count_alter(&$fragments, $account) { $fragments['primary_table'] = '{pm_index} pmi'; - $fragments['select'][] = 'count(*) as unread_count'; + $fragments['select'][] = 'COUNT(DISTINCT thread_id) as unread_count'; $fragments['where'][] = 'pmi.new = 1'; - $fragments['where'][] = 'pmi.recipient = %d'; + $fragments['where'][] = 'pmi.uid = %d'; $fragments['query_args'][] = $account->uid; } @@ -954,4 +934,22 @@ function privatemsg_form_alter(&$form, $ } break; } +} + +function privatemsg_delete($pmid, $deleted = 1) { + global $user; + + db_query('UPDATE {pm_index} SET deleted = %d WHERE mid = %d AND uid = %d', $deleted, $pmid, $user->uid); + drupal_set_message('Message has been deleted'); + drupal_goto('messages'); +} + +function privatemsg_per_message_actions($pmid) { + $output = ''; + + return $output; } \ No newline at end of file diff -urp privatemsg/privatemsgapi/privatemsgapi.inc privatemsg_nbz/privatemsgapi/privatemsgapi.inc --- privatemsg/privatemsgapi/privatemsgapi.inc 2008-09-20 21:22:20.000000000 +0100 +++ privatemsg_nbz/privatemsgapi/privatemsgapi.inc 2008-10-12 20:19:15.952691300 +0100 @@ -67,9 +67,6 @@ function _privatemsg_assemble_query($que $SELECT = array(); $INNER_JOIN = array(); $WHERE = array(); - $UNION_SELECT = array(); - $UNION_INNER_JOIN = array(); - $UNION_WHERE = array(); $GROUP_BY = array(); $ORDER_BY = array(); $QUERY_ARGS = array(); @@ -79,9 +76,6 @@ function _privatemsg_assemble_query($que 'select' => $SELECT, 'inner_join' => $INNER_JOIN, 'where' => $WHERE, - 'union_select' => $UNION_SELECT, - 'union_inner_join' => $UNION_INNER_JOIN, - 'union_where' => $UNION_WHERE, 'group_by' => $GROUP_BY, 'order_by' => $ORDER_BY, 'query_args' => $QUERY_ARGS, @@ -109,9 +103,6 @@ function _privatemsg_assemble_query($que $SELECT = $fragments['select']; $INNER_JOIN = $fragments['inner_join']; $WHERE = $fragments['where']; - $UNION_SELECT = $fragments['union_select']; - $UNION_INNER_JOIN = $fragments['union_inner_join']; - $UNION_WHERE = $fragments['union_where']; $GROUP_BY = $fragments['group_by']; $ORDER_BY = $fragments['order_by']; $QUERY_ARGS = $fragments['query_args']; @@ -133,18 +124,6 @@ function _privatemsg_assemble_query($que $str_where = '('. implode(') AND (', $WHERE) .')'; $query .= " WHERE {$str_where}"; } - if (!empty($UNION_SELECT)) { - $str_union_select = implode(", ", $UNION_SELECT); - $query .= "UNION SELECT {$str_union_select} FROM ". $primary_table; - } - if (!empty($UNION_INNER_JOIN)) { - $str_union_inner_join = implode(' ', $UNION_INNER_JOIN); - $query .= " {$str_union_inner_join}"; - } - if (!empty($UNION_WHERE)) { - $str_union_where = '('. implode(') AND (', $UNION_WHERE) .')'; - $query .= " WHERE {$str_union_where}"; - } if (!empty($GROUP_BY)) { $str_group_by = ' GROUP BY '. implode(", ", $GROUP_BY) ; $query .= " {$str_group_by}"; diff -urp privatemsg/styles/privatemsg-view.css privatemsg_nbz/styles/privatemsg-view.css --- privatemsg/styles/privatemsg-view.css 2008-06-10 09:39:48.000000000 +0100 +++ privatemsg_nbz/styles/privatemsg-view.css 2008-10-12 22:29:00.597091300 +0100 @@ -45,4 +45,11 @@ padding : 0px; margin : 0 0 0 5px; overflow : auto; +} + +.message-actions li { + list-style-type:none; + float:left; + padding:5px; + background-image:none; } \ No newline at end of file