summaryrefslogtreecommitdiff
path: root/classes
diff options
context:
space:
mode:
authorEvan Prodromou <evan@status.net>2010-01-09 10:26:50 -0800
committerEvan Prodromou <evan@status.net>2010-01-09 10:26:50 -0800
commit5e81149e4773799b2dcf426987e6263b8841c5cc (patch)
treeee1dcd6de45579466e999b3ba614b01bef435e5f /classes
parent920c878221cf87c1cf74baabbf0636337550eeab (diff)
create new Inbox from Notice_inbox if not exists at read/write time
Diffstat (limited to 'classes')
-rw-r--r--classes/Inbox.php28
1 files changed, 6 insertions, 22 deletions
diff --git a/classes/Inbox.php b/classes/Inbox.php
index de52e1e0c..e14d4f4e7 100644
--- a/classes/Inbox.php
+++ b/classes/Inbox.php
@@ -79,7 +79,7 @@ class Inbox extends Memcached_DataObject
$inbox = new Inbox();
$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();
@@ -110,10 +110,10 @@ class Inbox extends Memcached_DataObject
$notice_id, $user_id));
if ($result) {
- $c = $this->memcache();
+ $c = self::memcache();
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)
{
- $cnt = count($user_ids);
-
- for ($off = 0; $off < $cnt; $off += self::BOXCAR) {
-
- $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();
+ foreach ($user_ids as $user_id)
+ {
+ Inbox::insertNotice($user_id, $notice_id);
}
}