3 * StatusNet - the distributed open-source microblogging tool
4 * Copyright (C) 2008, 2009, StatusNet, Inc.
6 * This program is free software: you can redistribute it and/or modify
7 * it under the terms of the GNU Affero General Public License as published by
8 * the Free Software Foundation, either version 3 of the License, or
9 * (at your option) any later version.
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU Affero General Public License for more details.
16 * You should have received a copy of the GNU Affero General Public License
17 * along with this program. If not, see <http://www.gnu.org/licenses/>.
20 if (!defined('STATUSNET') && !defined('LACONICA')) { exit(1); }
23 * Table Definition for profile
25 require_once INSTALLDIR.'/classes/Memcached_DataObject.php';
27 class Profile extends Memcached_DataObject
30 /* the code below is auto generated do not remove the above tag */
32 public $__table = 'profile'; // table name
33 public $id; // int(4) primary_key not_null
34 public $nickname; // varchar(64) multiple_key not_null
35 public $fullname; // varchar(255) multiple_key
36 public $profileurl; // varchar(255)
37 public $homepage; // varchar(255) multiple_key
38 public $bio; // text() multiple_key
39 public $location; // varchar(255) multiple_key
40 public $lat; // decimal(10,7)
41 public $lon; // decimal(10,7)
42 public $location_id; // int(4)
43 public $location_ns; // int(4)
44 public $created; // datetime() not_null
45 public $modified; // timestamp() not_null default_CURRENT_TIMESTAMP
48 function staticGet($k,$v=NULL) {
49 return Memcached_DataObject::staticGet('Profile',$k,$v);
52 /* the code above is auto generated do not remove the tag below */
57 return User::staticGet('id', $this->id);
60 function getAvatar($width, $height=null)
62 if (is_null($height)) {
65 return Avatar::pkeyGet(array('profile_id' => $this->id,
67 'height' => $height));
70 function getOriginalAvatar()
72 $avatar = DB_DataObject::factory('avatar');
73 $avatar->profile_id = $this->id;
74 $avatar->original = true;
75 if ($avatar->find(true)) {
82 function setOriginal($filename)
84 $imagefile = new ImageFile($this->id, Avatar::path($filename));
86 $avatar = new Avatar();
87 $avatar->profile_id = $this->id;
88 $avatar->width = $imagefile->width;
89 $avatar->height = $imagefile->height;
90 $avatar->mediatype = image_type_to_mime_type($imagefile->type);
91 $avatar->filename = $filename;
92 $avatar->original = true;
93 $avatar->url = Avatar::url($filename);
94 $avatar->created = DB_DataObject_Cast::dateTime(); # current time
96 # XXX: start a transaction here
98 if (!$this->delete_avatars() || !$avatar->insert()) {
99 @unlink(Avatar::path($filename));
103 foreach (array(AVATAR_PROFILE_SIZE, AVATAR_STREAM_SIZE, AVATAR_MINI_SIZE) as $size) {
104 # We don't do a scaled one if original is our scaled size
105 if (!($avatar->width == $size && $avatar->height == $size)) {
107 $scaled_filename = $imagefile->resize($size);
109 //$scaled = DB_DataObject::factory('avatar');
110 $scaled = new Avatar();
111 $scaled->profile_id = $this->id;
112 $scaled->width = $size;
113 $scaled->height = $size;
114 $scaled->original = false;
115 $scaled->mediatype = image_type_to_mime_type($imagefile->type);
116 $scaled->filename = $scaled_filename;
117 $scaled->url = Avatar::url($scaled_filename);
118 $scaled->created = DB_DataObject_Cast::dateTime(); # current time
120 if (!$scaled->insert()) {
129 function delete_avatars($original=true)
131 $avatar = new Avatar();
132 $avatar->profile_id = $this->id;
134 while ($avatar->fetch()) {
135 if ($avatar->original) {
136 if ($original == false) {
145 function getBestName()
147 return ($this->fullname) ? $this->fullname : $this->nickname;
150 # Get latest notice on or before date; default now
151 function getCurrentNotice($dt=null)
153 $notice = new Notice();
154 $notice->profile_id = $this->id;
156 $notice->whereAdd('created < "' . $dt . '"');
158 $notice->orderBy('created DESC, notice.id DESC');
160 if ($notice->find(true)) {
166 function getTaggedNotices($tag, $offset=0, $limit=NOTICES_PER_PAGE, $since_id=0, $max_id=0, $since=null)
168 $ids = Notice::stream(array($this, '_streamTaggedDirect'),
170 'profile:notice_ids_tagged:' . $this->id . ':' . $tag,
171 $offset, $limit, $since_id, $max_id, $since);
172 return Notice::getStreamByIds($ids);
175 function getNotices($offset=0, $limit=NOTICES_PER_PAGE, $since_id=0, $max_id=0, $since=null)
177 // XXX: I'm not sure this is going to be any faster. It probably isn't.
178 $ids = Notice::stream(array($this, '_streamDirect'),
180 'profile:notice_ids:' . $this->id,
181 $offset, $limit, $since_id, $max_id, $since);
183 return Notice::getStreamByIds($ids);
186 function _streamTaggedDirect($tag, $offset, $limit, $since_id, $max_id, $since)
188 // XXX It would be nice to do this without a join
190 $notice = new Notice();
193 "select id from notice join notice_tag on id=notice_id where tag='".
194 $notice->escape($tag) .
195 "' and profile_id=" . $notice->escape($this->id);
197 if ($since_id != 0) {
198 $query .= " and id > $since_id";
202 $query .= " and id < $max_id";
205 if (!is_null($since)) {
206 $query .= " and created > '" . date('Y-m-d H:i:s', $since) . "'";
209 $query .= ' order by id DESC';
211 if (!is_null($offset)) {
212 $query .= " LIMIT $limit OFFSET $offset";
215 $notice->query($query);
219 while ($notice->fetch()) {
220 $ids[] = $notice->id;
226 function _streamDirect($offset, $limit, $since_id, $max_id, $since = null)
228 $notice = new Notice();
230 $notice->profile_id = $this->id;
232 $notice->selectAdd();
233 $notice->selectAdd('id');
235 if ($since_id != 0) {
236 $notice->whereAdd('id > ' . $since_id);
240 $notice->whereAdd('id <= ' . $max_id);
243 if (!is_null($since)) {
244 $notice->whereAdd('created > \'' . date('Y-m-d H:i:s', $since) . '\'');
247 $notice->orderBy('id DESC');
249 if (!is_null($offset)) {
250 $notice->limit($offset, $limit);
255 if ($notice->find()) {
256 while ($notice->fetch()) {
257 $ids[] = $notice->id;
264 function isMember($group)
266 $mem = new Group_member();
268 $mem->group_id = $group->id;
269 $mem->profile_id = $this->id;
278 function isAdmin($group)
280 $mem = new Group_member();
282 $mem->group_id = $group->id;
283 $mem->profile_id = $this->id;
293 function avatarUrl($size=AVATAR_PROFILE_SIZE)
295 $avatar = $this->getAvatar($size);
297 return $avatar->displayUrl();
299 return Avatar::defaultImage($size);
303 function getSubscriptions($offset=0, $limit=null)
306 'SELECT profile.* ' .
307 'FROM profile JOIN subscription ' .
308 'ON profile.id = subscription.subscribed ' .
309 'WHERE subscription.subscriber = %d ' .
310 'AND subscription.subscribed != subscription.subscriber ' .
311 'ORDER BY subscription.created DESC ';
313 if (common_config('db','type') == 'pgsql') {
314 $qry .= ' LIMIT ' . $limit . ' OFFSET ' . $offset;
316 $qry .= ' LIMIT ' . $offset . ', ' . $limit;
319 $profile = new Profile();
321 $profile->query(sprintf($qry, $this->id));
326 function getSubscribers($offset=0, $limit=null)
329 'SELECT profile.* ' .
330 'FROM profile JOIN subscription ' .
331 'ON profile.id = subscription.subscriber ' .
332 'WHERE subscription.subscribed = %d ' .
333 'AND subscription.subscribed != subscription.subscriber ' .
334 'ORDER BY subscription.created DESC ';
337 if (common_config('db','type') == 'pgsql') {
338 $qry .= ' LIMIT ' . $limit . ' OFFSET ' . $offset;
340 $qry .= ' LIMIT ' . $offset . ', ' . $limit;
344 $profile = new Profile();
346 $cnt = $profile->query(sprintf($qry, $this->id));
351 function subscriptionCount()
353 $c = common_memcache();
356 $cnt = $c->get(common_cache_key('profile:subscription_count:'.$this->id));
357 if (is_integer($cnt)) {
362 $sub = new Subscription();
363 $sub->subscriber = $this->id;
365 $cnt = (int) $sub->count('distinct subscribed');
367 $cnt = ($cnt > 0) ? $cnt - 1 : $cnt;
370 $c->set(common_cache_key('profile:subscription_count:'.$this->id), $cnt);
376 function subscriberCount()
378 $c = common_memcache();
380 $cnt = $c->get(common_cache_key('profile:subscriber_count:'.$this->id));
381 if (is_integer($cnt)) {
386 $sub = new Subscription();
387 $sub->subscribed = $this->id;
389 $cnt = (int) $sub->count('distinct subscriber');
391 $cnt = ($cnt > 0) ? $cnt - 1 : $cnt;
394 $c->set(common_cache_key('profile:subscriber_count:'.$this->id), $cnt);
402 $c = common_memcache();
404 $cnt = $c->get(common_cache_key('profile:fave_count:'.$this->id));
405 if (is_integer($cnt)) {
411 $faves->user_id = $this->id;
412 $cnt = (int) $faves->count('distinct notice_id');
415 $c->set(common_cache_key('profile:fave_count:'.$this->id), $cnt);
421 function noticeCount()
423 $c = common_memcache();
426 $cnt = $c->get(common_cache_key('profile:notice_count:'.$this->id));
427 if (is_integer($cnt)) {
432 $notices = new Notice();
433 $notices->profile_id = $this->id;
434 $cnt = (int) $notices->count('distinct id');
437 $c->set(common_cache_key('profile:notice_count:'.$this->id), $cnt);
443 function blowSubscriberCount()
445 $c = common_memcache();
447 $c->delete(common_cache_key('profile:subscriber_count:'.$this->id));
451 function blowSubscriptionCount()
453 $c = common_memcache();
455 $c->delete(common_cache_key('profile:subscription_count:'.$this->id));
459 function blowFaveCount()
461 $c = common_memcache();
463 $c->delete(common_cache_key('profile:fave_count:'.$this->id));
467 function blowNoticeCount()
469 $c = common_memcache();
471 $c->delete(common_cache_key('profile:notice_count:'.$this->id));
475 static function maxBio()
477 $biolimit = common_config('profile', 'biolimit');
478 // null => use global limit (distinct from 0!)
479 if (is_null($biolimit)) {
480 $biolimit = common_config('site', 'textlimit');
485 static function bioTooLong($bio)
487 $biolimit = self::maxBio();
488 return ($biolimit > 0 && !empty($bio) && (mb_strlen($bio) > $biolimit));
493 $this->_deleteNotices();
494 $this->_deleteSubscriptions();
495 $this->_deleteMessages();
496 $this->_deleteTags();
497 $this->_deleteBlocks();
499 $related = array('Avatar',
504 foreach ($related as $cls) {
506 $inst->profile_id = $this->id;
513 function _deleteNotices()
515 $notice = new Notice();
516 $notice->profile_id = $this->id;
518 if ($notice->find()) {
519 while ($notice->fetch()) {
520 $other = clone($notice);
526 function _deleteSubscriptions()
528 $sub = new Subscription();
529 $sub->subscriber = $this->id;
532 $subd = new Subscription();
533 $subd->subscribed = $this->id;
537 function _deleteMessages()
539 $msg = new Message();
540 $msg->from_profile = $this->id;
543 $msg = new Message();
544 $msg->to_profile = $this->id;
548 function _deleteTags()
550 $tag = new Profile_tag();
551 $tag->tagged = $this->id;
555 function _deleteBlocks()
557 $block = new Profile_block();
558 $block->blocked = $this->id;
561 $block = new Group_block();
562 $block->blocked = $this->id;
566 // XXX: identical to Notice::getLocation.
568 function getLocation()
572 if (!empty($this->location_id) && !empty($this->location_ns)) {
573 $location = Location::fromId($this->location_id, $this->location_ns);
576 if (is_null($location)) { // no ID, or Location::fromId() failed
577 if (!empty($this->lat) && !empty($this->lon)) {
578 $location = Location::fromLatLon($this->lat, $this->lon);
582 if (is_null($location)) { // still haven't found it!
583 if (!empty($this->location)) {
584 $location = Location::fromName($this->location);