wamo/gnu-social
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

create new Inbox from Notice_inbox if not exists at read/write time

Browse Source
This commit is contained in:
Evan Prodromou 2010-01-09 10:26:50 -08:00
parent 920c878221
commit 5e81149e47
1 changed files with 6 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
classes/Inbox.php
View File

@ -79,7 +79,7 @@ class Inbox extends Memcached_DataObject
$inbox = new Inbox(); $inbox = new Inbox();
$inbox->user_id = $user_id; $inbox->user_id = $user_id;
$inbox->notice_ids = pack('N*', $ids); $inbox->notice_ids = call_user_func_array('pack', array_merge(array('N*'), $ids));
$result = $inbox->insert(); $result = $inbox->insert();
@ -110,10 +110,10 @@ class Inbox extends Memcached_DataObject
$notice_id, $user_id)); $notice_id, $user_id));
if ($result) { if ($result) {
$c = $this->memcache(); $c = self::memcache();
if (!empty($c)) { if (!empty($c)) {
$c->delete($this->cacheKey($this->tableName(), 'user_id', $user_id)); $c->delete(self::cacheKey('inbox', 'user_id', $user_id));
} }
} }
@ -122,25 +122,9 @@ class Inbox extends Memcached_DataObject
static function bulkInsert($notice_id, $user_ids) static function bulkInsert($notice_id, $user_ids)
{ {
$cnt = count($user_ids); foreach ($user_ids as $user_id)
{
for ($off = 0; $off < $cnt; $off += self::BOXCAR) { Inbox::insertNotice($user_id, $notice_id);
$boxcar = array_slice($user_ids, $off, self::BOXCAR);
if (empty($boxcar)) { // jump in, hobo!
break;
}
$inbox = new Inbox();
$inbox->query(sprintf('UPDATE inbox '.
'set notice_ids = concat(cast(0x%08x as binary(4)), '.
'substr(notice_ids, 1, 4092)) '.
'WHERE user_id in (%s)',
$notice_id, implode(',', $boxcar)));
$inbox->free();
} }
} }