Changeset 462 for trunk/bp-messages/bp-messages-classes.php

Timestamp:

10/30/2008 12:18:36 AM (17 years ago)

Author:

apeatling

Message:

Added message email notifications.

File:

• trunk/bp-messages/bp-messages-classes.php (modified) (5 diffs)

trunk/bp-messages/bp-messages-classes.php

@@ -284 +284 @@
     
     var $thread_id;
-    var $recipients;
+    var $recipients = false;
 
     function bp_messages_message( $id = null ) {
@@ -318 +318 @@
 
         // First insert the message into the messages table
-        $sql = $wpdb->prepare( "INSERT INTO " . $bp['messages']['table_name_messages'] . " ( sender_id, subject, message, date_sent, message_order, sender_is_group ) VALUES ( %d, %s, %s, FROM_UNIXTIME(%d), %d, %d )", $userdata->ID, $this->subject, $this->message, $this->date_sent, $this->message_order, $this->sender_is_group );
-
-        if ( $wpdb->query($sql) === false )
-            return false;
-
+        if ( !$wpdb->query( $wpdb->prepare( "INSERT INTO " . $bp['messages']['table_name_messages'] . " ( sender_id, subject, message, date_sent, message_order, sender_is_group ) VALUES ( %d, %s, %s, FROM_UNIXTIME(%d), %d, %d )", $userdata->ID, $this->subject, $this->message, $this->date_sent, $this->message_order, $this->sender_is_group ) ) )
+            return false;
+            
         // Next, if thread_id is set, we are adding to an existing thread, if not, start a new one.
         if ( $this->thread_id ) {
@@ -331 +329 @@
             $message_ids = serialize($message_ids);
             
+            // We need this so we can return the new message ID.
+            $message_id = $wpdb->insert_id;
+            
             // Update the sender ids for the thread
             $sender_ids = unserialize($the_ids->sender_ids);
@@ -345 +346 @@
             
             // Find the recipients and update the unread counts for each
-            $recipients = $wpdb->get_results( $wpdb->prepare( "SELECT user_id FROM " . $bp['messages']['table_name_recipients'] . " WHERE thread_id = %d", $this->thread_id ) );
-            
-            for ( $i = 0; $i < count($recipients); $i++ ) {
-                if ( $recipients[$i]->user_id != $userdata->ID )
-                    $wpdb->query( $wpdb->prepare( "UPDATE " . $bp['messages']['table_name_recipients'] . " SET unread_count = unread_count + 1, sender_only = 0 WHERE thread_id = %d AND user_id = %d", $this->thread_id, $recipients[$i]->user_id ) );
+            if ( !$this->recipients )
+                $this->recipients = $this->get_recipients();
+            
+            for ( $i = 0; $i < count($this->recipients); $i++ ) {
+                if ( $this->recipients[$i]->user_id != $userdata->ID )
+                    $wpdb->query( $wpdb->prepare( "UPDATE " . $bp['messages']['table_name_recipients'] . " SET unread_count = unread_count + 1, sender_only = 0 WHERE thread_id = %d AND user_id = %d", $this->thread_id, $this->recipients[$i]->user_id ) );
             }
         } else {
@@ -374 +376 @@
             }
         }
-        update_usermeta( $userdata->ID, 'last_activity', date( 'Y-m-d H:i:s' ) ); 
+        
+        $this->id = $message_id;
         
         return true;
+    }
+    
+    function get_recipients() {
+        global $bp, $wpdb;
+        
+        return $wpdb->get_results( $wpdb->prepare( "SELECT user_id FROM " . $bp['messages']['table_name_recipients'] . " WHERE thread_id = %d", $this->thread_id ) );
     }