Memcache returns false on cache miss

[quix0rs-gnu-social.git] / classes / Notice.php

diff --git a/classes/Notice.php b/classes/Notice.php
index a00114f95df2043db1a0258c7c009ceb629e6352..c60237ffb0b429647a60834b80c48f98d7d65989 100644 (file)
--- a/classes/Notice.php
+++ b/classes/Notice.php
@@ -22,9 +22,9 @@ if (!defined('LACONICA')) { exit(1); }
 /**
  * Table Definition for notice
  */
-require_once 'DB/DataObject.php';
+require_once INSTALLDIR.'/classes/Memcached_DataObject.php';
 
-class Notice extends DB_DataObject 
+class Notice extends Memcached_DataObject 
 {
     ###START_AUTOCODE
     /* the code below is auto generated do not remove the above tag */
@@ -39,9 +39,11 @@ class Notice extends DB_DataObject
     public $created;                         // datetime()   not_null
     public $modified;                        // timestamp()   not_null default_CURRENT_TIMESTAMP
     public $reply_to;                        // int(4)  
+    public $is_local;                        // tinyint(1)  
+    public $source;                          // varchar(32)  
 
     /* Static get */
-    function staticGet($k,$v=NULL) { return DB_DataObject::staticGet('Notice',$k,$v); }
+    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
@@ -49,4 +51,92 @@ class Notice extends DB_DataObject
        function getProfile() {
                return Profile::staticGet($this->profile_id);
        }
+
+       function saveTags() {
+               /* extract all #hastags */
+               $count = preg_match_all('/(?:^|\s)#([A-Za-z0-9_\-\.]{1,64})/', strtolower($this->content), $match);
+               if (!$count) {
+                       return true;
+               }
+               
+               /* elide characters we don't want in the tag */
+               $match[1] = str_replace(array('-', '_', '.'), '', $match[1]);
+
+               /* Add them to the database */
+               foreach(array_unique($match[1]) as $hashtag) {
+                       $tag = DB_DataObject::factory('Notice_tag');
+                       $tag->notice_id = $this->id;
+                       $tag->tag = $hashtag;
+                       $tag->created = $this->created;
+                       $id = $tag->insert();
+                       if (!$id) {
+                               $last_error = PEAR::getStaticProperty('DB_DataObject','lastError');
+                               common_log(LOG_ERR, 'DB error inserting hashtag: ' . $last_error->message);
+                               common_server_error(sprintf(_('DB error inserting hashtag: %s'), $last_error->message));
+                               return;
+                       }
+               }
+               return true;
+       }
+
+       static function saveNew($profile_id, $content, $source=NULL, $is_local=1, $reply_to=NULL, $uri=NULL) {
+               
+               $notice = new Notice();
+               $notice->profile_id = $profile_id;
+               $notice->is_local = $is_local;
+               $notice->reply_to = $reply_to;
+               $notice->created = common_sql_now();
+               $notice->content = $content;
+               $notice->rendered = common_render_content($notice->content, $notice);
+               $notice->source = $source;
+               $notice->uri = $uri;
+               
+               $id = $notice->insert();
+
+               if (!$id) {
+                       return _('Problem saving notice.');
+               }
+
+               # Update the URI after the notice is in the database
+               if (!$uri) {
+                       $orig = clone($notice);
+                       $notice->uri = common_notice_uri($notice);
+
+                       if (!$notice->update($orig)) {
+                               return _('Problem saving notice.');
+                       }
+               }
+
+               # XXX: do we need to change this for remote users?
+               
+               common_save_replies($notice);
+               $notice->saveTags();
+
+               # Clear the cache for subscribed users, so they'll update at next request
+               # XXX: someone clever could prepend instead of clearing the cache
+               
+               if (common_config('memcached', 'enabled')) {
+                       $notice->blowSubsCache();
+               }
+               
+               return $notice;
+       }
+       
+       function blowSubsCache() {
+               $cache = new Memcache();
+               if ($cache->connect(common_config('memcached', 'server'), common_config('memcached', 'port'))) {
+                       $user = new User();
+                       
+                       $user->query('SELECT id ' .
+                                                'FROM user JOIN subscription ON user.id = subscription.subscriber ' .
+                                                'WHERE subscription.subscribed = ' . $this->profile_id);
+                       
+                       while ($user->fetch()) {
+                               $cache->delete(common_cache_key('user:notices_with_friends:' . $user->id));
+                       }
+                       
+                       $user->free();
+                       unset($user);
+               }
+       }
 }