added all them doxygens

1 files changed, 421 insertions, 404 deletions

diff --git a/classes/Notice.php b/classes/Notice.php
index 93d5de790..c68098c65 100644
--- a/classes/Notice.php
+++ b/classes/Notice.php
@@ -1,5 +1,5 @@
 <?php
-/*
+/**
  * StatusNet - the distributed open-source microblogging tool
  * Copyright (C) 2008, 2009, StatusNet, Inc.
  *
@@ -15,13 +15,30 @@
  *
  * You should have received a copy of the GNU Affero General Public License
  * along with this program.     If not, see <http://www.gnu.org/licenses/>.
+ * 
+ * @category Notices
+ * @package  StatusNet
+ * @author   Brenda Wallace <shiny@cpan.org>
+ * @author   Christopher Vollick <psycotica0@gmail.com>
+ * @author   CiaranG <ciaran@ciarang.com>
+ * @author   Craig Andrews <candrews@integralblue.com>
+ * @author   Evan Prodromou <evan@controlezvous.ca>
+ * @author   Gina Haeussge <osd@foosel.net>
+ * @author   Jeffery To <jeffery.to@gmail.com>
+ * @author   Mike Cochrane <mikec@mikenz.geek.nz>
+ * @author   Robin Millette <millette@controlyourself.ca>
+ * @author   Sarven Capadisli <csarven@controlyourself.ca>
+ * @author   Tom Adams <tom@holizz.com>
+ * @license  GNU Affero General Public License http://www.gnu.org/licenses/
  */
 
-if (!defined('STATUSNET') && !defined('LACONICA')) { exit(1); }
+if (!defined('STATUSNET') && !defined('LACONICA')) { 
+    exit(1); 
+}
 
 /**
- * Table Definition for notice
- */
+* Table Definition for notice
+*/
 require_once INSTALLDIR.'/classes/Memcached_DataObject.php';
 
 /* We keep the first three 20-notice pages, plus one for pagination check,
@@ -35,7 +52,7 @@ class Notice extends Memcached_DataObject
 {
     ###START_AUTOCODE
     /* the code below is auto generated do not remove the above tag */
-
+    
     public $__table = 'notice';                          // table name
     public $id;                              // int(4)  primary_key not_null
     public $profile_id;                      // int(4)   not_null
@@ -49,45 +66,45 @@ class Notice extends Memcached_DataObject
     public $is_local;                        // tinyint(1)
     public $source;                          // varchar(32)
     public $conversation;                    // int(4)
-
+    
     /* Static get */
     function staticGet($k,$v=NULL) { return Memcached_DataObject::staticGet('Notice',$k,$v); }
-
+    
     /* the code above is auto generated do not remove the tag below */
     ###END_AUTOCODE
-
+    
     /* Notice types */
     const LOCAL_PUBLIC    =  1;
     const REMOTE_OMB      =  0;
     const LOCAL_NONPUBLIC = -1;
     const GATEWAY         = -2;
-
+    
     function getProfile()
     {
         return Profile::staticGet('id', $this->profile_id);
     }
-
+    
     function delete()
     {
         $this->blowCaches(true);
         $this->blowFavesCache(true);
         $this->blowSubsCache(true);
-
+        
         // For auditing purposes, save a record that the notice
         // was deleted.
-
+        
         $deleted = new Deleted_notice();
-
+        
         $deleted->id         = $this->id;
         $deleted->profile_id = $this->profile_id;
         $deleted->uri        = $this->uri;
         $deleted->created    = $this->created;
         $deleted->deleted    = common_sql_now();
-
+        
         $this->query('BEGIN');
-
+        
         $deleted->insert();
-
+        
         //Null any notices that are replies to this notice
         $this->query(sprintf("UPDATE notice set reply_to = null WHERE reply_to = %d", $this->id));
         $related = array('Reply',
@@ -106,7 +123,7 @@ class Notice extends Memcached_DataObject
         $result = parent::delete();
         $this->query('COMMIT');
     }
-
+    
     function saveTags()
     {
         /* extract all #hastags */
@@ -114,14 +131,14 @@ class Notice extends Memcached_DataObject
         if (!$count) {
             return true;
         }
-
+        
         //turn each into their canonical tag
         //this is needed to remove dupes before saving e.g. #hash.tag = #hashtag
         $hashtags = array();
         for($i=0; $i<count($match[1]); $i++) {
             $hashtags[] = common_canonical_tag($match[1][$i]);
         }
-
+        
         /* Add them to the database */
         foreach(array_unique($hashtags) as $hashtag) {
             /* elide characters we don't want in the tag */
@@ -129,7 +146,7 @@ class Notice extends Memcached_DataObject
         }
         return true;
     }
-
+    
     function saveTag($hashtag)
     {
         $tag = new Notice_tag();
@@ -137,158 +154,158 @@ class Notice extends Memcached_DataObject
         $tag->tag = $hashtag;
         $tag->created = $this->created;
         $id = $tag->insert();
-
+        
         if (!$id) {
             throw new ServerException(sprintf(_('DB error inserting hashtag: %s'),
                                               $last_error->message));
             return;
         }
     }
-
+    
     static function saveNew($profile_id, $content, $source=null,
                             $is_local=Notice::LOCAL_PUBLIC, $reply_to=null, $uri=null, $created=null) {
-
-        $profile = Profile::staticGet($profile_id);
-
-        $final = common_shorten_links($content);
-
-        if (Notice::contentTooLong($final)) {
-            throw new ClientException(_('Problem saving notice. Too long.'));
-        }
-
-        if (!$profile) {
-            throw new ClientException(_('Problem saving notice. Unknown user.'));
-        }
-
-        if (common_config('throttle', 'enabled') && !Notice::checkEditThrottle($profile_id)) {
-            common_log(LOG_WARNING, 'Excessive posting by profile #' . $profile_id . '; throttled.');
-            throw new ClientException(_('Too many notices too fast; take a breather '.
+                                
+                                $profile = Profile::staticGet($profile_id);
+                                
+                                $final = common_shorten_links($content);
+                                
+                                if (Notice::contentTooLong($final)) {
+                                    throw new ClientException(_('Problem saving notice. Too long.'));
+                                }
+                                
+                                if (!$profile) {
+                                    throw new ClientException(_('Problem saving notice. Unknown user.'));
+                                }
+                                
+                                if (common_config('throttle', 'enabled') && !Notice::checkEditThrottle($profile_id)) {
+                                    common_log(LOG_WARNING, 'Excessive posting by profile #' . $profile_id . '; throttled.');
+                                    throw new ClientException(_('Too many notices too fast; take a breather '.
                                         'and post again in a few minutes.'));
-        }
-
-        if (common_config('site', 'dupelimit') > 0 && !Notice::checkDupes($profile_id, $final)) {
-            common_log(LOG_WARNING, 'Dupe posting by profile #' . $profile_id . '; throttled.');
-			throw new ClientException(_('Too many duplicate messages too quickly;'.
+                                }
+                                
+                                if (common_config('site', 'dupelimit') > 0 && !Notice::checkDupes($profile_id, $final)) {
+                                    common_log(LOG_WARNING, 'Dupe posting by profile #' . $profile_id . '; throttled.');
+                                    throw new ClientException(_('Too many duplicate messages too quickly;'.
                                         ' take a breather and post again in a few minutes.'));
-        }
-
-		$banned = common_config('profile', 'banned');
-
-        if ( in_array($profile_id, $banned) || in_array($profile->nickname, $banned)) {
-            common_log(LOG_WARNING, "Attempted post from banned user: $profile->nickname (user id = $profile_id).");
-            throw new ClientException(_('You are banned from posting notices on this site.'));
-        }
-
-        $notice = new Notice();
-        $notice->profile_id = $profile_id;
-
-        $blacklist = common_config('public', 'blacklist');
-        $autosource = common_config('public', 'autosource');
-
+                                }
+                                
+                                $banned = common_config('profile', 'banned');
+                                
+                                if ( in_array($profile_id, $banned) || in_array($profile->nickname, $banned)) {
+                                    common_log(LOG_WARNING, "Attempted post from banned user: $profile->nickname (user id = $profile_id).");
+                                    throw new ClientException(_('You are banned from posting notices on this site.'));
+                                }
+                                
+                                $notice = new Notice();
+                                $notice->profile_id = $profile_id;
+                                
+                                $blacklist = common_config('public', 'blacklist');
+                                $autosource = common_config('public', 'autosource');
+                                
         # Blacklisted are non-false, but not 1, either
-
-        if (($blacklist && in_array($profile_id, $blacklist)) ||
-            ($source && $autosource && in_array($source, $autosource))) {
-            $notice->is_local = Notice::LOCAL_NONPUBLIC;
-        } else {
-            $notice->is_local = $is_local;
-        }
-
-        if (!empty($created)) {
-            $notice->created = $created;
-        } else {
-            $notice->created = common_sql_now();
-        }
-
-		$notice->content = $final;
-		$notice->rendered = common_render_content($final, $notice);
-		$notice->source = $source;
-		$notice->uri = $uri;
-
-		$notice->reply_to = self::getReplyTo($reply_to, $profile_id, $source, $final);
-
-        if (!empty($notice->reply_to)) {
-            $reply = Notice::staticGet('id', $notice->reply_to);
-            $notice->conversation = $reply->conversation;
-        }
-
-        if (Event::handle('StartNoticeSave', array(&$notice))) {
-
+                                
+                                if (($blacklist && in_array($profile_id, $blacklist)) ||
+                                    ($source && $autosource && in_array($source, $autosource))) {
+                                        $notice->is_local = Notice::LOCAL_NONPUBLIC;
+                                    } else {
+                                        $notice->is_local = $is_local;
+                                    }
+                                
+                                if (!empty($created)) {
+                                    $notice->created = $created;
+                                } else {
+                                    $notice->created = common_sql_now();
+                                }
+                                
+                                $notice->content = $final;
+                                $notice->rendered = common_render_content($final, $notice);
+                                $notice->source = $source;
+                                $notice->uri = $uri;
+                                
+                                $notice->reply_to = self::getReplyTo($reply_to, $profile_id, $source, $final);
+                                
+                                if (!empty($notice->reply_to)) {
+                                    $reply = Notice::staticGet('id', $notice->reply_to);
+                                    $notice->conversation = $reply->conversation;
+                                }
+                                
+                                if (Event::handle('StartNoticeSave', array(&$notice))) {
+                                    
             // XXX: some of these functions write to the DB
-
-            $notice->query('BEGIN');
-
-            $id = $notice->insert();
-
-            if (!$id) {
-                common_log_db_error($notice, 'INSERT', __FILE__);
-                throw new ServerException(_('Problem saving notice.'));
-            }
-
+                                    
+                                    $notice->query('BEGIN');
+                                    
+                                    $id = $notice->insert();
+                                    
+                                    if (!$id) {
+                                        common_log_db_error($notice, 'INSERT', __FILE__);
+                                        throw new ServerException(_('Problem saving notice.'));
+                                    }
+                                    
             // Update ID-dependent columns: URI, conversation
-
-            $orig = clone($notice);
-
-            $changed = false;
-
-            if (empty($uri)) {
-                $notice->uri = common_notice_uri($notice);
-                $changed = true;
-            }
-
+                                    
+                                    $orig = clone($notice);
+                                    
+                                    $changed = false;
+                                    
+                                    if (empty($uri)) {
+                                        $notice->uri = common_notice_uri($notice);
+                                        $changed = true;
+                                    }
+                                    
             // If it's not part of a conversation, it's
             // the beginning of a new conversation.
-
-            if (empty($notice->conversation)) {
-                $notice->conversation = $notice->id;
-                $changed = true;
-            }
-
-            if ($changed) {
-                if (!$notice->update($orig)) {
-                    common_log_db_error($notice, 'UPDATE', __FILE__);
-                    throw new ServerException(_('Problem saving notice.'));
-                }
-            }
-
+                                    
+                                    if (empty($notice->conversation)) {
+                                        $notice->conversation = $notice->id;
+                                        $changed = true;
+                                    }
+                                    
+                                    if ($changed) {
+                                        if (!$notice->update($orig)) {
+                                            common_log_db_error($notice, 'UPDATE', __FILE__);
+                                            throw new ServerException(_('Problem saving notice.'));
+                                        }
+                                    }
+                                    
             // XXX: do we need to change this for remote users?
-
-            $notice->saveReplies();
-            $notice->saveTags();
-
-            $notice->addToInboxes();
-
-            $notice->saveUrls();
-
-            $notice->query('COMMIT');
-
-            Event::handle('EndNoticeSave', array($notice));
-        }
-
+                                    
+                                    $notice->saveReplies();
+                                    $notice->saveTags();
+                                    
+                                    $notice->addToInboxes();
+                                    
+                                    $notice->saveUrls();
+                                    
+                                    $notice->query('COMMIT');
+                                    
+                                    Event::handle('EndNoticeSave', array($notice));
+                                }
+                                
         # Clear the cache for subscribed users, so they'll update at next request
         # XXX: someone clever could prepend instead of clearing the cache
-
-        $notice->blowCaches();
-
-        return $notice;
-    }
-
+                                
+                                $notice->blowCaches();
+                                
+                                return $notice;
+                            }
+    
     /** save all urls in the notice to the db
-     *
-     * follow redirects and save all available file information
-     * (mimetype, date, size, oembed, etc.)
-     *
-     * @return void
-     */
-    function saveUrls() {
-        common_replace_urls_callback($this->content, array($this, 'saveUrl'), $this->id);
-    }
-
+        *
+        * follow redirects and save all available file information
+        * (mimetype, date, size, oembed, etc.)
+        *
+        * @return void
+        */
+        function saveUrls() {
+            common_replace_urls_callback($this->content, array($this, 'saveUrl'), $this->id);
+        }
+    
     function saveUrl($data) {
         list($url, $notice_id) = $data;
         File::processNew($url, $notice_id);
     }
-
+    
     static function checkDupes($profile_id, $content) {
         $profile = Profile::staticGet($profile_id);
         if (!$profile) {
@@ -311,14 +328,14 @@ class Notice extends Memcached_DataObject
         $notice->profile_id = $profile_id;
         $notice->content = $content;
         if (common_config('db','type') == 'pgsql')
-          $notice->whereAdd('extract(epoch from now() - created) < ' . common_config('site', 'dupelimit'));
+            $notice->whereAdd('extract(epoch from now() - created) < ' . common_config('site', 'dupelimit'));
         else
-          $notice->whereAdd('now() - created < ' . common_config('site', 'dupelimit'));
-
+            $notice->whereAdd('now() - created < ' . common_config('site', 'dupelimit'));
+        
         $cnt = $notice->count();
         return ($cnt == 0);
     }
-
+    
     static function checkEditThrottle($profile_id) {
         $profile = Profile::staticGet($profile_id);
         if (!$profile) {
@@ -336,7 +353,7 @@ class Notice extends Memcached_DataObject
         # Either not N notices in the stream, OR the Nth was not posted within timespan seconds
         return true;
     }
-
+    
     function getUploadedAttachment() {
         $post = clone $this;
         $query = 'select file.url as up, file.id as i from file join file_to_post on file.id = file_id where post_id=' . $post->escape($post->id) . ' and url like "%/notice/%/file"';
@@ -350,7 +367,7 @@ class Notice extends Memcached_DataObject
         $post->free();
         return $ret;
     }
-
+    
     function hasAttachments() {
         $post = clone $this;
         $query = "select count(file_id) as n_attachments from file join file_to_post on (file_id = file.id) join notice on (post_id = notice.id) where post_id = " . $post->escape($post->id);
@@ -360,7 +377,7 @@ class Notice extends Memcached_DataObject
         $post->free();
         return $n_attachments;
     }
-
+    
     function attachments() {
         // XXX: cache this
         $att = array();
@@ -374,7 +391,7 @@ class Notice extends Memcached_DataObject
         }
         return $att;
     }
-
+    
     function blowCaches($blowLast=false)
     {
         $this->blowSubsCache($blowLast);
@@ -387,7 +404,7 @@ class Notice extends Memcached_DataObject
         $profile = Profile::staticGet($this->profile_id);
         $profile->blowNoticeCount();
     }
-
+    
     function blowConversationCache($blowLast=false)
     {
         $cache = common_memcache();
@@ -399,7 +416,7 @@ class Notice extends Memcached_DataObject
             }
         }
     }
-
+    
     function blowGroupCache($blowLast=false)
     {
         $cache = common_memcache();
@@ -428,7 +445,7 @@ class Notice extends Memcached_DataObject
             unset($group_inbox);
         }
     }
-
+    
     function blowTagCache($blowLast=false)
     {
         $cache = common_memcache();
@@ -439,7 +456,7 @@ class Notice extends Memcached_DataObject
                 while ($tag->fetch()) {
                     $tag->blowCache($blowLast);
                     $ck = 'profile:notice_ids_tagged:' . $this->profile_id . ':' . $tag->tag;
-
+                    
                     $cache->delete($ck);
                     if ($blowLast) {
                         $cache->delete($ck . ';last');
@@ -450,19 +467,19 @@ class Notice extends Memcached_DataObject
             unset($tag);
         }
     }
-
+    
     function blowSubsCache($blowLast=false)
     {
         $cache = common_memcache();
         if ($cache) {
             $user = new User();
-
+            
             $UT = common_config('db','type')=='pgsql'?'"user"':'user';
             $user->query('SELECT id ' .
-
+                         
                          "FROM $UT JOIN subscription ON $UT.id = subscription.subscriber " .
                          'WHERE subscription.subscribed = ' . $this->profile_id);
-
+            
             while ($user->fetch()) {
                 $cache->delete(common_cache_key('notice_inbox:by_user:'.$user->id));
                 $cache->delete(common_cache_key('notice_inbox:by_user_own:'.$user->id));
@@ -475,7 +492,7 @@ class Notice extends Memcached_DataObject
             unset($user);
         }
     }
-
+    
     function blowNoticeCache($blowLast=false)
     {
         if ($this->is_local) {
@@ -488,7 +505,7 @@ class Notice extends Memcached_DataObject
             }
         }
     }
-
+    
     function blowRepliesCache($blowLast=false)
     {
         $cache = common_memcache();
@@ -507,7 +524,7 @@ class Notice extends Memcached_DataObject
             unset($reply);
         }
     }
-
+    
     function blowPublicCache($blowLast=false)
     {
         if ($this->is_local == Notice::LOCAL_PUBLIC) {
@@ -520,7 +537,7 @@ class Notice extends Memcached_DataObject
             }
         }
     }
-
+    
     function blowFavesCache($blowLast=false)
     {
         $cache = common_memcache();
@@ -541,14 +558,14 @@ class Notice extends Memcached_DataObject
             unset($fave);
         }
     }
-
+    
     # XXX: too many args; we need to move to named params or even a separate
     # class for notice streams
-
+    
     static function getStream($qry, $cachekey, $offset=0, $limit=20, $since_id=0, $max_id=0, $order=null, $since=null) {
-
+        
         if (common_config('memcached', 'enabled')) {
-
+            
             # Skip the cache if this is a since, since_id or max_id qry
             if ($since_id > 0 || $max_id > 0 || $since) {
                 return Notice::getStreamDirect($qry, $offset, $limit, $since_id, $max_id, $order, $since);
@@ -556,127 +573,127 @@ class Notice extends Memcached_DataObject
                 return Notice::getCachedStream($qry, $cachekey, $offset, $limit, $order);
             }
         }
-
+        
         return Notice::getStreamDirect($qry, $offset, $limit, $since_id, $max_id, $order, $since);
     }
-
+    
     static function getStreamDirect($qry, $offset, $limit, $since_id, $max_id, $order, $since) {
-
+        
         $needAnd = false;
         $needWhere = true;
-
+        
         if (preg_match('/\bWHERE\b/i', $qry)) {
             $needWhere = false;
             $needAnd = true;
         }
-
+        
         if ($since_id > 0) {
-
+            
             if ($needWhere) {
                 $qry .= ' WHERE ';
                 $needWhere = false;
             } else {
                 $qry .= ' AND ';
             }
-
+            
             $qry .= ' notice.id > ' . $since_id;
         }
-
+        
         if ($max_id > 0) {
-
+            
             if ($needWhere) {
                 $qry .= ' WHERE ';
                 $needWhere = false;
             } else {
                 $qry .= ' AND ';
             }
-
+            
             $qry .= ' notice.id <= ' . $max_id;
         }
-
+        
         if ($since) {
-
+            
             if ($needWhere) {
                 $qry .= ' WHERE ';
                 $needWhere = false;
             } else {
                 $qry .= ' AND ';
             }
-
+            
             $qry .= ' notice.created > \'' . date('Y-m-d H:i:s', $since) . '\'';
         }
-
+        
         # Allow ORDER override
-
+        
         if ($order) {
             $qry .= $order;
         } else {
             $qry .= ' ORDER BY notice.created DESC, notice.id DESC ';
         }
-
+        
         if (common_config('db','type') == 'pgsql') {
             $qry .= ' LIMIT ' . $limit . ' OFFSET ' . $offset;
         } else {
             $qry .= ' LIMIT ' . $offset . ', ' . $limit;
         }
-
+        
         $notice = new Notice();
-
+        
         $notice->query($qry);
-
+        
         return $notice;
     }
-
+    
     # XXX: this is pretty long and should probably be broken up into
     # some helper functions
-
+    
     static function getCachedStream($qry, $cachekey, $offset, $limit, $order) {
-
+        
         # If outside our cache window, just go to the DB
-
+        
         if ($offset + $limit > NOTICE_CACHE_WINDOW) {
             return Notice::getStreamDirect($qry, $offset, $limit, null, null, $order, null);
         }
-
+        
         # Get the cache; if we can't, just go to the DB
-
+        
         $cache = common_memcache();
-
+        
         if (!$cache) {
             return Notice::getStreamDirect($qry, $offset, $limit, null, null, $order, null);
         }
-
+        
         # Get the notices out of the cache
-
+        
         $notices = $cache->get(common_cache_key($cachekey));
-
+        
         # On a cache hit, return a DB-object-like wrapper
-
+        
         if ($notices !== false) {
             $wrapper = new ArrayWrapper(array_slice($notices, $offset, $limit));
             return $wrapper;
         }
-
+        
         # If the cache was invalidated because of new data being
         # added, we can try and just get the new stuff. We keep an additional
         # copy of the data at the key + ';last'
-
+        
         # No cache hit. Try to get the *last* cached version
-
+        
         $last_notices = $cache->get(common_cache_key($cachekey) . ';last');
-
+        
         if ($last_notices) {
-
+            
             # Reverse-chron order, so last ID is last.
-
+            
             $last_id = $last_notices[0]->id;
-
+            
             # XXX: this assumes monotonically increasing IDs; a fair
             # bet with our DB.
-
+            
             $new_notice = Notice::getStreamDirect($qry, 0, NOTICE_CACHE_WINDOW,
-                                                  $last_id, null, $order, null);
-
+                $last_id, null, $order, null);
+            
             if ($new_notice) {
                 $new_notices = array();
                 while ($new_notice->fetch()) {
@@ -685,54 +702,54 @@ class Notice extends Memcached_DataObject
                 $new_notice->free();
                 $notices = array_slice(array_merge($new_notices, $last_notices),
                                        0, NOTICE_CACHE_WINDOW);
-
+                
                 # Store the array in the cache for next time
-
+                
                 $result = $cache->set(common_cache_key($cachekey), $notices);
                 $result = $cache->set(common_cache_key($cachekey) . ';last', $notices);
-
+                
                 # return a wrapper of the array for use now
-
+                
                 return new ArrayWrapper(array_slice($notices, $offset, $limit));
             }
         }
-
+        
         # Otherwise, get the full cache window out of the DB
-
+        
         $notice = Notice::getStreamDirect($qry, 0, NOTICE_CACHE_WINDOW, null, null, $order, null);
-
+        
         # If there are no hits, just return the value
-
+        
         if (!$notice) {
             return $notice;
         }
-
+        
         # Pack results into an array
-
+        
         $notices = array();
-
+        
         while ($notice->fetch()) {
             $notices[] = clone($notice);
         }
-
+        
         $notice->free();
-
+        
         # Store the array in the cache for next time
-
+        
         $result = $cache->set(common_cache_key($cachekey), $notices);
         $result = $cache->set(common_cache_key($cachekey) . ';last', $notices);
-
+        
         # return a wrapper of the array for use now
-
+        
         $wrapper = new ArrayWrapper(array_slice($notices, $offset, $limit));
-
+        
         return $wrapper;
     }
-
+    
     function getStreamByIds($ids)
     {
         $cache = common_memcache();
-
+        
         if (!empty($cache)) {
             $notices = array();
             foreach ($ids as $id) {
@@ -750,35 +767,35 @@ class Notice extends Memcached_DataObject
             }
             $notice->whereAdd('id in (' . implode(', ', $ids) . ')');
             $notice->orderBy('id DESC');
-
+            
             $notice->find();
             return $notice;
         }
     }
-
+    
     function publicStream($offset=0, $limit=20, $since_id=0, $max_id=0, $since=null)
     {
         $ids = Notice::stream(array('Notice', '_publicStreamDirect'),
                               array(),
                               'public',
                               $offset, $limit, $since_id, $max_id, $since);
-
+        
         return Notice::getStreamByIds($ids);
     }
-
+    
     function _publicStreamDirect($offset=0, $limit=20, $since_id=0, $max_id=0, $since=null)
     {
         $notice = new Notice();
-
+        
         $notice->selectAdd(); // clears it
         $notice->selectAdd('id');
-
+        
         $notice->orderBy('id DESC');
-
+        
         if (!is_null($offset)) {
             $notice->limit($offset, $limit);
         }
-
+        
         if (common_config('public', 'localonly')) {
             $notice->whereAdd('is_local = ' . Notice::LOCAL_PUBLIC);
         } else {
@@ -786,108 +803,108 @@ class Notice extends Memcached_DataObject
             $notice->whereAdd('is_local !='. Notice::LOCAL_NONPUBLIC);
             $notice->whereAdd('is_local !='. Notice::GATEWAY);
         }
-
+        
         if ($since_id != 0) {
             $notice->whereAdd('id > ' . $since_id);
         }
-
+        
         if ($max_id != 0) {
             $notice->whereAdd('id <= ' . $max_id);
         }
-
+        
         if (!is_null($since)) {
             $notice->whereAdd('created > \'' . date('Y-m-d H:i:s', $since) . '\'');
         }
-
+        
         $ids = array();
-
+        
         if ($notice->find()) {
             while ($notice->fetch()) {
                 $ids[] = $notice->id;
             }
         }
-
+        
         $notice->free();
         $notice = NULL;
-
+        
         return $ids;
     }
-
+    
     function conversationStream($id, $offset=0, $limit=20, $since_id=0, $max_id=0, $since=null)
     {
         $ids = Notice::stream(array('Notice', '_conversationStreamDirect'),
                               array($id),
                               'notice:conversation_ids:'.$id,
                               $offset, $limit, $since_id, $max_id, $since);
-
+        
         return Notice::getStreamByIds($ids);
     }
-
+    
     function _conversationStreamDirect($id, $offset=0, $limit=20, $since_id=0, $max_id=0, $since=null)
     {
         $notice = new Notice();
-
+        
         $notice->selectAdd(); // clears it
         $notice->selectAdd('id');
-
+        
         $notice->conversation = $id;
-
+        
         $notice->orderBy('id DESC');
-
+        
         if (!is_null($offset)) {
             $notice->limit($offset, $limit);
         }
-
+        
         if ($since_id != 0) {
             $notice->whereAdd('id > ' . $since_id);
         }
-
+        
         if ($max_id != 0) {
             $notice->whereAdd('id <= ' . $max_id);
         }
-
+        
         if (!is_null($since)) {
             $notice->whereAdd('created > \'' . date('Y-m-d H:i:s', $since) . '\'');
         }
-
+        
         $ids = array();
-
+        
         if ($notice->find()) {
             while ($notice->fetch()) {
                 $ids[] = $notice->id;
             }
         }
-
+        
         $notice->free();
         $notice = NULL;
-
+        
         return $ids;
     }
-
+    
     function addToInboxes()
     {
         $enabled = common_config('inboxes', 'enabled');
-
+        
         if ($enabled === true || $enabled === 'transitional') {
-
+            
             // XXX: loads constants
-
+            
             $inbox = new Notice_inbox();
-
+            
             $users = $this->getSubscribedUsers();
-
+            
             // FIXME: kind of ignoring 'transitional'...
             // we'll probably stop supporting inboxless mode
             // in 0.9.x
-
+            
             $ni = array();
-
+            
             foreach ($users as $id) {
                 $ni[$id] = NOTICE_INBOX_SOURCE_SUB;
             }
-
+            
             $groups = $this->saveGroups();
-
+            
             foreach ($groups as $group) {
                 $users = $group->getUserMembers();
                 foreach ($users as $id) {
@@ -896,12 +913,12 @@ class Notice extends Memcached_DataObject
                     }
                 }
             }
-
+            
             $cnt = 0;
-
+            
             $qryhdr = 'INSERT INTO notice_inbox (user_id, notice_id, source, created) VALUES ';
             $qry = $qryhdr;
-
+            
             foreach ($ni as $id => $source) {
                 if ($cnt > 0) {
                     $qry .= ', ';
@@ -919,52 +936,52 @@ class Notice extends Memcached_DataObject
                     $cnt = 0;
                 }
             }
-
+            
             if ($cnt > 0) {
                 $inbox = new Notice_inbox();
                 $inbox->query($qry);
             }
         }
-
+        
         return;
     }
-
+    
     function getSubscribedUsers()
     {
         $user = new User();
-
+        
         if(common_config('db','quote_identifiers'))
-          $user_table = '"user"';
+            $user_table = '"user"';
         else $user_table = 'user';
-
+        
         $qry =
-          'SELECT id ' .
-          'FROM '. $user_table .' JOIN subscription '.
-          'ON '. $user_table .'.id = subscription.subscriber ' .
-          'WHERE subscription.subscribed = %d ';
-
+            'SELECT id ' .
+            'FROM '. $user_table .' JOIN subscription '.
+            'ON '. $user_table .'.id = subscription.subscriber ' .
+            'WHERE subscription.subscribed = %d ';
+        
         $user->query(sprintf($qry, $this->profile_id));
-
+        
         $ids = array();
-
+        
         while ($user->fetch()) {
             $ids[] = $user->id;
         }
-
+        
         $user->free();
-
+        
         return $ids;
     }
-
+    
     function saveGroups()
     {
         $groups = array();
-
+        
         $enabled = common_config('inboxes', 'enabled');
         if ($enabled !== true && $enabled !== 'transitional') {
             return $groups;
         }
-
+        
         /* extract all !group */
         $count = preg_match_all('/(?:^|\s)!([A-Za-z0-9]{1,64})/',
                                 strtolower($this->content),
@@ -972,62 +989,62 @@ class Notice extends Memcached_DataObject
         if (!$count) {
             return $groups;
         }
-
+        
         $profile = $this->getProfile();
-
+        
         /* Add them to the database */
-
+        
         foreach (array_unique($match[1]) as $nickname) {
             /* XXX: remote groups. */
             $group = User_group::getForNickname($nickname);
-
+            
             if (empty($group)) {
                 continue;
             }
-
+            
             // we automatically add a tag for every group name, too
-
+            
             $tag = Notice_tag::pkeyGet(array('tag' => common_canonical_tag($nickname),
                                              'notice_id' => $this->id));
-
+            
             if (is_null($tag)) {
                 $this->saveTag($nickname);
             }
-
+            
             if ($profile->isMember($group)) {
-
+                
                 $result = $this->addToGroupInbox($group);
-
+                
                 if (!$result) {
                     common_log_db_error($gi, 'INSERT', __FILE__);
                 }
-
+                
                 $groups[] = clone($group);
             }
         }
-
+        
         return $groups;
     }
-
+    
     function addToGroupInbox($group)
     {
         $gi = Group_inbox::pkeyGet(array('group_id' => $group->id,
                                          'notice_id' => $this->id));
-
+        
         if (empty($gi)) {
-
+            
             $gi = new Group_inbox();
-
+            
             $gi->group_id  = $group->id;
             $gi->notice_id = $this->id;
             $gi->created   = $this->created;
-
+            
             return $gi->insert();
         }
-
+        
         return true;
     }
-
+    
     function saveReplies()
     {
         // Alternative reply format
@@ -1037,21 +1054,21 @@ class Notice extends Memcached_DataObject
         }
         // extract all @messages
         $cnt = preg_match_all('/(?:^|\s)@([a-z0-9]{1,64})/', $this->content, $match);
-
+        
         $names = array();
-
+        
         if ($cnt || $tname) {
             // XXX: is there another way to make an array copy?
             $names = ($tname) ? array_unique(array_merge(array(strtolower($tname)), $match[1])) : array_unique($match[1]);
         }
-
+        
         $sender = Profile::staticGet($this->profile_id);
-
+        
         $replied = array();
-
+        
         // store replied only for first @ (what user/notice what the reply directed,
         // we assume first @ is it)
-
+        
         for ($i=0; $i<count($names); $i++) {
             $nickname = $names[$i];
             $recipient = common_relative_profile($sender, $nickname, $this->created);
@@ -1076,7 +1093,7 @@ class Notice extends Memcached_DataObject
                 $replied[$recipient->id] = 1;
             }
         }
-
+        
         // Hash format replies, too
         $cnt = preg_match_all('/(?:^|\s)@#([a-z0-9]{1,64})/', $this->content, $match);
         if ($cnt) {
@@ -1103,7 +1120,7 @@ class Notice extends Memcached_DataObject
                 }
             }
         }
-
+        
         foreach (array_keys($replied) as $recipient) {
             $user = User::staticGet('id', $recipient);
             if ($user) {
@@ -1111,22 +1128,22 @@ class Notice extends Memcached_DataObject
             }
         }
     }
-
+    
     function asAtomEntry($namespace=false, $source=false)
     {
         $profile = $this->getProfile();
-
+        
         $xs = new XMLStringer(true);
-
+        
         if ($namespace) {
             $attrs = array('xmlns' => 'http://www.w3.org/2005/Atom',
                            'xmlns:thr' => 'http://purl.org/syndication/thread/1.0');
         } else {
             $attrs = array();
         }
-
+        
         $xs->elementStart('entry', $attrs);
-
+        
         if ($source) {
             $xs->elementStart('source');
             $xs->element('title', null, $profile->nickname . " - " . common_config('site', 'name'));
@@ -1135,38 +1152,38 @@ class Notice extends Memcached_DataObject
             if (!empty($user)) {
                 $atom_feed = common_local_url('api',
                                               array('apiaction' => 'statuses',
-                                                    'method' => 'user_timeline',
-                                                    'argument' => $profile->nickname.'.atom'));
+                                                  'method' => 'user_timeline',
+                                                  'argument' => $profile->nickname.'.atom'));
                 $xs->element('link', array('rel' => 'self',
                                            'type' => 'application/atom+xml',
                                            'href' => $profile->profileurl));
                 $xs->element('link', array('rel' => 'license',
                                            'href' => common_config('license', 'url')));
             }
-
+            
             $xs->element('icon', null, $profile->avatarUrl(AVATAR_PROFILE_SIZE));
         }
-
+        
         $xs->elementStart('author');
         $xs->element('name', null, $profile->nickname);
         $xs->element('uri', null, $profile->profileurl);
         $xs->elementEnd('author');
-
+        
         if ($source) {
             $xs->elementEnd('source');
         }
-
+        
         $xs->element('title', null, $this->content);
         $xs->element('summary', null, $this->content);
-
+        
         $xs->element('link', array('rel' => 'alternate',
                                    'href' => $this->bestUrl()));
-
+        
         $xs->element('id', null, $this->uri);
-
+        
         $xs->element('published', null, common_date_w3dtf($this->created));
         $xs->element('updated', null, common_date_w3dtf($this->modified));
-
+        
         if ($this->reply_to) {
             $reply_notice = Notice::staticGet('id', $this->reply_to);
             if (!empty($reply_notice)) {
@@ -1177,9 +1194,9 @@ class Notice extends Memcached_DataObject
                                    'href' => $reply_notice->bestUrl()));
             }
         }
-
+        
         $xs->element('content', array('type' => 'html'), $this->rendered);
-
+        
         $tag = new Notice_tag();
         $tag->notice_id = $this->id;
         if ($tag->find()) {
@@ -1188,7 +1205,7 @@ class Notice extends Memcached_DataObject
             }
         }
         $tag->free();
-
+        
         # Enclosures
         $attachments = $this->attachments();
         if($attachments){
@@ -1203,12 +1220,12 @@ class Notice extends Memcached_DataObject
                 }
             }
         }
-
+        
         $xs->elementEnd('entry');
-
+        
         return $xs->getString();
     }
-
+    
     function bestUrl()
     {
         if (!empty($this->url)) {
@@ -1220,135 +1237,135 @@ class Notice extends Memcached_DataObject
                                     array('notice' => $this->id));
         }
     }
-
+    
     function stream($fn, $args, $cachekey, $offset=0, $limit=20, $since_id=0, $max_id=0, $since=null)
     {
         $cache = common_memcache();
-
+        
         if (empty($cache) ||
             $since_id != 0 || $max_id != 0 || (!is_null($since) && $since > 0) ||
             is_null($limit) ||
             ($offset + $limit) > NOTICE_CACHE_WINDOW) {
-            return call_user_func_array($fn, array_merge($args, array($offset, $limit, $since_id,
-                                                                      $max_id, $since)));
-        }
-
+                return call_user_func_array($fn, array_merge($args, array($offset, $limit, $since_id,
+                    $max_id, $since)));
+            }
+        
         $idkey = common_cache_key($cachekey);
-
+        
         $idstr = $cache->get($idkey);
-
+        
         if (!empty($idstr)) {
             // Cache hit! Woohoo!
             $window = explode(',', $idstr);
             $ids = array_slice($window, $offset, $limit);
             return $ids;
         }
-
+        
         $laststr = $cache->get($idkey.';last');
-
+        
         if (!empty($laststr)) {
             $window = explode(',', $laststr);
             $last_id = $window[0];
             $new_ids = call_user_func_array($fn, array_merge($args, array(0, NOTICE_CACHE_WINDOW,
-                                                                          $last_id, 0, null)));
-
+                $last_id, 0, null)));
+            
             $new_window = array_merge($new_ids, $window);
-
+            
             $new_windowstr = implode(',', $new_window);
-
+            
             $result = $cache->set($idkey, $new_windowstr);
             $result = $cache->set($idkey . ';last', $new_windowstr);
-
+            
             $ids = array_slice($new_window, $offset, $limit);
-
+            
             return $ids;
         }
-
+        
         $window = call_user_func_array($fn, array_merge($args, array(0, NOTICE_CACHE_WINDOW,
-                                                                     0, 0, null)));
-
+            0, 0, null)));
+        
         $windowstr = implode(',', $window);
-
+        
         $result = $cache->set($idkey, $windowstr);
         $result = $cache->set($idkey . ';last', $windowstr);
-
+        
         $ids = array_slice($window, $offset, $limit);
-
+        
         return $ids;
     }
-
+    
     /**
-     * Determine which notice, if any, a new notice is in reply to.
-     *
-     * For conversation tracking, we try to see where this notice fits
-     * in the tree. Rough algorithm is:
-     *
-     * if (reply_to is set and valid) {
-     *     return reply_to;
-     * } else if ((source not API or Web) and (content starts with "T NAME" or "@name ")) {
-     *     return ID of last notice by initial @name in content;
-     * }
-     *
-     * Note that all @nickname instances will still be used to save "reply" records,
-     * so the notice shows up in the mentioned users' "replies" tab.
-     *
-     * @param integer $reply_to   ID passed in by Web or API
-     * @param integer $profile_id ID of author
-     * @param string  $source     Source tag, like 'web' or 'gwibber'
-     * @param string  $content    Final notice content
-     *
-     * @return integer ID of replied-to notice, or null for not a reply.
-     */
-
-    static function getReplyTo($reply_to, $profile_id, $source, $content)
+        * Determine which notice, if any, a new notice is in reply to.
+        *
+        * For conversation tracking, we try to see where this notice fits
+        * in the tree. Rough algorithm is:
+        *
+        * if (reply_to is set and valid) {
+        *     return reply_to;
+        * } else if ((source not API or Web) and (content starts with "T NAME" or "@name ")) {
+        *     return ID of last notice by initial @name in content;
+        * }
+    *
+        * Note that all @nickname instances will still be used to save "reply" records,
+        * so the notice shows up in the mentioned users' "replies" tab.
+        *
+        * @param integer $reply_to   ID passed in by Web or API
+        * @param integer $profile_id ID of author
+        * @param string  $source     Source tag, like 'web' or 'gwibber'
+        * @param string  $content    Final notice content
+        *
+        * @return integer ID of replied-to notice, or null for not a reply.
+        */
+        
+        static function getReplyTo($reply_to, $profile_id, $source, $content)
     {
         static $lb = array('xmpp', 'mail', 'sms', 'omb');
-
+        
         // If $reply_to is specified, we check that it exists, and then
         // return it if it does
-
+        
         if (!empty($reply_to)) {
             $reply_notice = Notice::staticGet('id', $reply_to);
             if (!empty($reply_notice)) {
                 return $reply_to;
             }
         }
-
+        
         // If it's not a "low bandwidth" source (one where you can't set
         // a reply_to argument), we return. This is mostly web and API
         // clients.
-
+        
         if (!in_array($source, $lb)) {
             return null;
         }
-
+        
         // Is there an initial @ or T?
-
+        
         if (preg_match('/^T ([A-Z0-9]{1,64}) /', $content, $match) ||
             preg_match('/^@([a-z0-9]{1,64})\s+/', $content, $match)) {
-            $nickname = common_canonical_nickname($match[1]);
-        } else {
-            return null;
-        }
-
+                $nickname = common_canonical_nickname($match[1]);
+            } else {
+                return null;
+            }
+        
         // Figure out who that is.
-
+        
         $sender = Profile::staticGet('id', $profile_id);
         $recipient = common_relative_profile($sender, $nickname, common_sql_now());
-
+        
         if (empty($recipient)) {
             return null;
         }
-
+        
         // Get their last notice
-
+        
         $last = $recipient->getCurrentNotice();
-
+        
         if (!empty($last)) {
             return $last->id;
         }
     }
-
+    
     static function maxContent()
     {
         $contentlimit = common_config('notice', 'contentlimit');
@@ -1358,7 +1375,7 @@ class Notice extends Memcached_DataObject
         }
         return $contentlimit;
     }
-
+    
     static function contentTooLong($content)
     {
         $contentlimit = self::maxContent();