Inbox class a bit more consistent in argument order and type

diff --git a/classes/Inbox.php b/classes/Inbox.php
index e584e9e82b6e7abefc65707001b55e91aa323fff..429d2ae02b6247a28d0db6fb54622ded23027925 100644 (file)
--- a/classes/Inbox.php
+++ b/classes/Inbox.php
@@ -66,7 +66,7 @@ class Inbox extends Managed_DataObject {
      * @param int $notice_id
      * @return boolean success
      */
-    static function insertNotice($user_id, $notice_id)
+    static function insertNotice(Notice $notice, $user_id)
     {
         // Going straight to the DB rather than trusting our caching
         // during an update. Note: not using DB_DataObject::staticGet,
@@ -80,7 +80,7 @@ class Inbox extends Managed_DataObject {
         }
 
         $ids = $inbox->unpack();
-        if (in_array(intval($notice_id), $ids)) {
+        if (in_array(intval($notice->id), $ids)) {
             // Already in there, we probably re-ran some inbox adds
             // due to an error. Skip the dupe silently.
             return true;
@@ -90,7 +90,7 @@ class Inbox extends Managed_DataObject {
                                         'SET notice_ids = concat(cast(0x%08x as binary(4)), '.
                                         'SUBSTR(notice_ids, 1, %d)) '.
                                         'WHERE user_id = %d',
-                                        $notice_id,
+                                        $notice->id,
                                         4 * (self::MAX_NOTICES - 1),
                                         $user_id));
 
@@ -101,11 +101,11 @@ class Inbox extends Managed_DataObject {
         return $result;
     }
 
-    static function bulkInsert($notice_id, $user_ids)
+    static function bulkInsert(Notice $notice, array $user_ids)
     {
         foreach ($user_ids as $user_id)
         {
-            self::insertNotice($user_id, $notice_id);
+            self::insertNotice($notice, $user_id);
         }
     }
 

diff --git a/classes/Notice.php b/classes/Notice.php
index 4b0db2988da188bd2374cb136efd29407ae0f641..f40a4c2111b326ac3c11cb6798d03e4a1c5b4000 100644 (file)
--- a/classes/Notice.php
+++ b/classes/Notice.php
@@ -1086,7 +1086,7 @@ class Notice extends Managed_DataObject
 
         // Bulk insert
 
-        Inbox::bulkInsert($this->id, $ids);
+        Inbox::bulkInsert($this, $ids);
 
         return;
     }
@@ -2058,7 +2058,7 @@ class Notice extends Managed_DataObject
 
         $user = User::getKV('id', $this->profile_id);
         if ($user instanceof User) {
-            Inbox::insertNotice($user->id, $this->id);
+            Inbox::insertNotice($this, $user->id);
         }
 
         if (common_config('queue', 'inboxes')) {

diff --git a/plugins/TwitterBridge/lib/tweetinqueuehandler.php b/plugins/TwitterBridge/lib/tweetinqueuehandler.php
index 7f34ade23b8c5f1d58ecf7a10e5ea327efa9ce27..cc4d2f47d4be2838a57e0bd65884312d33128f99 100644 (file)
--- a/plugins/TwitterBridge/lib/tweetinqueuehandler.php
+++ b/plugins/TwitterBridge/lib/tweetinqueuehandler.php
@@ -50,13 +50,13 @@ class TweetInQueueHandler extends QueueHandler
 
         $importer = new TwitterImport();
         $notice = $importer->importStatus($status);
-        if ($notice) {
+        if ($notice instanceof Notice) {
             $flink = Foreign_link::getByForeignID($receiver, TWITTER_SERVICE);
-            if ($flink) {
+            if ($flink instanceof Foreign_link) {
                 common_log(LOG_DEBUG, "TweetInQueueHandler - Got flink so add notice ".
                            $notice->id." to inbox ".$flink->user_id);
                 // @fixme this should go through more regular channels?
-                Inbox::insertNotice($flink->user_id, $notice->id);
+                Inbox::insertNotice($notice, $flink->user_id);
             }else {
                common_log(LOG_DEBUG, "TweetInQueueHandler - No flink found for foreign user ".$receiver);
             }

diff --git a/plugins/TwitterBridge/scripts/streamtest.php b/plugins/TwitterBridge/scripts/streamtest.php
index 800d8c1e1cef9043fe5cca1de83924ac9c153281..c42fa38f10d07f6bddd07cacf6b5e4a65b2582da 100644 (file)
--- a/plugins/TwitterBridge/scripts/streamtest.php
+++ b/plugins/TwitterBridge/scripts/streamtest.php
@@ -170,9 +170,9 @@ $stream->hookEvent('status', function($data, $context) {
         $importer = new TwitterImport();
         printf("\timporting...");
         $notice = $importer->importStatus($data);
-        if ($notice) {
+        if ($notice instanceof Notice) {
             global $myuser;
-            Inbox::insertNotice($myuser->id, $notice->id);
+            Inbox::insertNotice($notice, $myuser->id);
             printf(" %s\n", $notice->id);
         } else {
             printf(" FAIL\n");