if (common_config('queue', 'enabled')) {
$notice->blowAuthorCaches();
} else {
- common_debug("Blowing caches for new notice.");
$notice->blowCaches();
}
}
'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:'.$user->id));
if ($blowLast) {
- $cache->delete(common_cache_key('notice_inbox:by_user:'.$user_id.';last'));
+ $cache->delete(common_cache_key('notice_inbox:by_user:'.$user->id.';last'));
}
}
$user->free();
if (empty($cache) ||
$since_id != 0 || $before_id != 0 || !is_null($since) ||
($offset + $limit) > INBOX_CACHE_WINDOW) {
- common_debug('Doing direct DB hit for notice_inbox since the params are screwy.');
return Notice_inbox::_streamDirect($user_id, $offset, $limit, $since_id, $before_id, $since);
}
if (!empty($idstr)) {
// Cache hit! Woohoo!
- common_debug('Cache hit for notice_inbox.');
$window = explode(',', $idstr);
$ids = array_slice($window, $offset, $limit);
return $ids;
$laststr = common_cache_key($idkey.';last');
if (!empty($laststr)) {
- common_debug('Cache hit for notice_inbox on last item.');
-
$window = explode(',', $laststr);
$last_id = $window[0];
$new_ids = Notice_inbox::_streamDirect($user_id, 0, INBOX_CACHE_WINDOW,