X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=classes%2FProfile.php;h=5e196051815fc63612da1fe05be18b36aea94b9c;hb=874f1db38980bd5a748b2a70159bd70ef7798c08;hp=b56e508c6a8d0da3a66cdf0f8b6a1027307a4688;hpb=01f32e3998b8d031d2a39e2d0506253142b6632e;p=quix0rs-gnu-social.git diff --git a/classes/Profile.php b/classes/Profile.php index b56e508c6a..f635ee470d 100644 --- a/classes/Profile.php +++ b/classes/Profile.php @@ -1,7 +1,7 @@ id); + if (is_int($this->_user) && $this->_user == -1) { + $this->_user = User::staticGet('id', $this->id); + } + + return $this->_user; } function getAvatar($width, $height=null) @@ -62,9 +73,17 @@ class Profile extends Memcached_DataObject if (is_null($height)) { $height = $width; } - return Avatar::pkeyGet(array('profile_id' => $this->id, - 'width' => $width, - 'height' => $height)); + + $avatar = null; + + if (Event::handle('StartProfileGetAvatar', array($this, $width, &$avatar))) { + $avatar = Avatar::pkeyGet(array('profile_id' => $this->id, + 'width' => $width, + 'height' => $height)); + Event::handle('EndProfileGetAvatar', array($this, $width, &$avatar)); + } + + return $avatar; } function getOriginalAvatar() @@ -93,7 +112,7 @@ class Profile extends Memcached_DataObject $avatar->url = Avatar::url($filename); $avatar->created = DB_DataObject_Cast::dateTime(); # current time - # XXX: start a transaction here + // XXX: start a transaction here if (!$this->delete_avatars() || !$avatar->insert()) { @unlink(Avatar::path($filename)); @@ -101,7 +120,7 @@ class Profile extends Memcached_DataObject } foreach (array(AVATAR_PROFILE_SIZE, AVATAR_STREAM_SIZE, AVATAR_MINI_SIZE) as $size) { - # We don't do a scaled one if original is our scaled size + // We don't do a scaled one if original is our scaled size if (!($avatar->width == $size && $avatar->height == $size)) { $scaled_filename = $imagefile->resize($size); @@ -125,6 +144,14 @@ class Profile extends Memcached_DataObject return $avatar; } + /** + * Delete attached avatars for this user from the database and filesystem. + * This should be used instead of a batch delete() to ensure that files + * get removed correctly. + * + * @param boolean $original true to delete only the original-size file + * @return + */ function delete_avatars($original=true) { $avatar = new Avatar(); @@ -160,7 +187,7 @@ class Profile extends Memcached_DataObject function getFancyName() { if ($this->fullname) { - // TRANS: Full name of a profile or group followed by nickname in parens + // TRANS: Full name of a profile or group (%1$s) followed by nickname (%2$s) in parentheses. return sprintf(_m('FANCYNAME','%1$s (%2$s)'), $this->fullname, $this->nickname); } else { return $this->nickname; @@ -172,12 +199,15 @@ class Profile extends Memcached_DataObject * * @return mixed Notice or null */ - function getCurrentNotice() { $notice = $this->getNotices(0, 1); if ($notice->fetch()) { + if ($notice instanceof ArrayWrapper) { + // hack for things trying to work with single notices + return $notice->_items[0]; + } return $notice; } else { return null; @@ -186,178 +216,320 @@ class Profile extends Memcached_DataObject function getTaggedNotices($tag, $offset=0, $limit=NOTICES_PER_PAGE, $since_id=0, $max_id=0) { - $ids = Notice::stream(array($this, '_streamTaggedDirect'), - array($tag), - 'profile:notice_ids_tagged:' . $this->id . ':' . $tag, - $offset, $limit, $since_id, $max_id); - return Notice::getStreamByIds($ids); + $stream = new TaggedProfileNoticeStream($this, $tag); + + return $stream->getNotices($offset, $limit, $since_id, $max_id); } function getNotices($offset=0, $limit=NOTICES_PER_PAGE, $since_id=0, $max_id=0) { - // XXX: I'm not sure this is going to be any faster. It probably isn't. - $ids = Notice::stream(array($this, '_streamDirect'), - array(), - 'profile:notice_ids:' . $this->id, - $offset, $limit, $since_id, $max_id); + $stream = new ProfileNoticeStream($this); + + return $stream->getNotices($offset, $limit, $since_id, $max_id); + } + + function isMember($group) + { + $gm = Group_member::pkeyGet(array('profile_id' => $this->id, + 'group_id' => $group->id)); + return (!empty($gm)); + } - return Notice::getStreamByIds($ids); + function isAdmin($group) + { + $gm = Group_member::pkeyGet(array('profile_id' => $this->id, + 'group_id' => $group->id)); + return (!empty($gm) && $gm->is_admin); } - function _streamTaggedDirect($tag, $offset, $limit, $since_id, $max_id) + function isPendingMember($group) { - // XXX It would be nice to do this without a join + $request = Group_join_queue::pkeyGet(array('profile_id' => $this->id, + 'group_id' => $group->id)); + return !empty($request); + } - $notice = new Notice(); + function getGroups($offset=0, $limit=PROFILES_PER_PAGE) + { + $ids = array(); + + $keypart = sprintf('profile:groups:%d', $this->id); + + $idstring = self::cacheGet($keypart); + + if ($idstring !== false) { + $ids = explode(',', $idstring); + } else { + $gm = new Group_member(); - $query = - "select id from notice join notice_tag on id=notice_id where tag='". - $notice->escape($tag) . - "' and profile_id=" . $notice->escape($this->id); + $gm->profile_id = $this->id; - if ($since_id != 0) { - $query .= " and id > $since_id"; + if ($gm->find()) { + while ($gm->fetch()) { + $ids[] = $gm->group_id; + } + } + + self::cacheSet($keypart, implode(',', $ids)); } - if ($max_id != 0) { - $query .= " and id <= $max_id"; + $groups = array(); + + foreach ($ids as $id) { + $group = User_group::staticGet('id', $id); + if (!empty($group)) { + $groups[] = $group; + } } - $query .= ' order by id DESC'; + return new ArrayWrapper($groups); + } - if (!is_null($offset)) { - $query .= " LIMIT $limit OFFSET $offset"; + function isTagged($peopletag) + { + $tag = Profile_tag::pkeyGet(array('tagger' => $peopletag->tagger, + 'tagged' => $this->id, + 'tag' => $peopletag->tag)); + return !empty($tag); + } + + function canTag($tagged) + { + if (empty($tagged)) { + return false; } - $notice->query($query); + if ($tagged->id == $this->id) { + return true; + } - $ids = array(); + $all = common_config('peopletag', 'allow_tagging', 'all'); + $local = common_config('peopletag', 'allow_tagging', 'local'); + $remote = common_config('peopletag', 'allow_tagging', 'remote'); + $subs = common_config('peopletag', 'allow_tagging', 'subs'); - while ($notice->fetch()) { - $ids[] = $notice->id; + if ($all) { + return true; } - return $ids; + $tagged_user = $tagged->getUser(); + if (!empty($tagged_user)) { + if ($local) { + return true; + } + } else if ($subs) { + return (Subscription::exists($this, $tagged) || + Subscription::exists($tagged, $this)); + } else if ($remote) { + return true; + } + return false; } - function _streamDirect($offset, $limit, $since_id, $max_id) + function getLists($auth_user, $offset=0, $limit=null, $since_id=0, $max_id=0) { - $notice = new Notice(); + $ids = array(); + + $keypart = sprintf('profile:lists:%d', $this->id); + + $idstr = self::cacheGet($keypart); - // Temporary hack until notice_profile_id_idx is updated - // to (profile_id, id) instead of (profile_id, created, id). - // It's been falling back to PRIMARY instead, which is really - // very inefficient for a profile that hasn't posted in a few - // months. Even though forcing the index will cause a filesort, - // it's usually going to be better. - if (common_config('db', 'type') == 'mysql') { - $index = ''; - $query = - "select id from notice force index (notice_profile_id_idx) ". - "where profile_id=" . $notice->escape($this->id); - - if ($since_id != 0) { - $query .= " and id > $since_id"; + if ($idstr !== false) { + $ids = explode(',', $idstr); + } else { + $list = new Profile_list(); + $list->selectAdd(); + $list->selectAdd('id'); + $list->tagger = $this->id; + $list->selectAdd('id as "cursor"'); + + if ($since_id>0) { + $list->whereAdd('id > '.$since_id); + } + + if ($max_id>0) { + $list->whereAdd('id <= '.$max_id); } - if ($max_id != 0) { - $query .= " and id <= $max_id"; + if($offset>=0 && !is_null($limit)) { + $list->limit($offset, $limit); } - $query .= ' order by id DESC'; + $list->orderBy('id DESC'); - if (!is_null($offset)) { - $query .= " LIMIT $limit OFFSET $offset"; + if ($list->find()) { + while ($list->fetch()) { + $ids[] = $list->id; + } } - $notice->query($query); - } else { - $index = ''; + self::cacheSet($keypart, implode(',', $ids)); + } - $notice->profile_id = $this->id; + $showPrivate = (($auth_user instanceof User || + $auth_user instanceof Profile) && + $auth_user->id === $this->id); - $notice->selectAdd(); - $notice->selectAdd('id'); + $lists = array(); - if ($since_id != 0) { - $notice->whereAdd('id > ' . $since_id); - } + foreach ($ids as $id) { + $list = Profile_list::staticGet('id', $id); + if (!empty($list) && + ($showPrivate || !$list->private)) { - if ($max_id != 0) { - $notice->whereAdd('id <= ' . $max_id); + if (!isset($list->cursor)) { + $list->cursor = $list->id; + } + + $lists[] = $list; } + } + + return new ArrayWrapper($lists); + } + + function getOtherTags($auth_user=null, $offset=0, $limit=null, $since_id=0, $max_id=0) + { + $lists = new Profile_list(); - $notice->orderBy('id DESC'); + $tags = new Profile_tag(); + $tags->tagged = $this->id; - if (!is_null($offset)) { - $notice->limit($offset, $limit); - } + $lists->joinAdd($tags); + #@fixme: postgres (round(date_part('epoch', my_date))) + $lists->selectAdd('unix_timestamp(profile_tag.modified) as "cursor"'); - $notice->find(); + if ($auth_user instanceof User || $auth_user instanceof Profile) { + $lists->whereAdd('( ( profile_list.private = false ) ' . + 'OR ( profile_list.tagger = ' . $auth_user->id . ' AND ' . + 'profile_list.private = true ) )'); + } else { + $lists->private = false; } - $ids = array(); + if ($since_id>0) { + $lists->whereAdd('cursor > '.$since_id); + } - while ($notice->fetch()) { - $ids[] = $notice->id; + if ($max_id>0) { + $lists->whereAdd('cursor <= '.$max_id); } - return $ids; + if($offset>=0 && !is_null($limit)) { + $lists->limit($offset, $limit); + } + + $lists->orderBy('profile_tag.modified DESC'); + $lists->find(); + + return $lists; } - function isMember($group) + function getPrivateTags($offset=0, $limit=null, $since_id=0, $max_id=0) { - $mem = new Group_member(); + $tags = new Profile_list(); + $tags->private = true; + $tags->tagger = $this->id; - $mem->group_id = $group->id; - $mem->profile_id = $this->id; + if ($since_id>0) { + $tags->whereAdd('id > '.$since_id); + } - if ($mem->find()) { - return true; - } else { - return false; + if ($max_id>0) { + $tags->whereAdd('id <= '.$max_id); } + + if($offset>=0 && !is_null($limit)) { + $tags->limit($offset, $limit); + } + + $tags->orderBy('id DESC'); + $tags->find(); + + return $tags; } - function isAdmin($group) + function hasLocalTags() { - $mem = new Group_member(); + $tags = new Profile_tag(); - $mem->group_id = $group->id; - $mem->profile_id = $this->id; - $mem->is_admin = 1; + $tags->joinAdd(array('tagger', 'user:id')); + $tags->whereAdd('tagged = '.$this->id); + $tags->whereAdd('tagger != '.$this->id); - if ($mem->find()) { - return true; - } else { - return false; - } + $tags->limit(0, 1); + $tags->fetch(); + + return ($tags->N == 0) ? false : true; } - function getGroups($offset=0, $limit=null) + function getTagSubscriptions($offset=0, $limit=null, $since_id=0, $max_id=0) { - $qry = - 'SELECT user_group.* ' . - 'FROM user_group JOIN group_member '. - 'ON user_group.id = group_member.group_id ' . - 'WHERE group_member.profile_id = %d ' . - 'ORDER BY group_member.created DESC '; - - if ($offset>0 && !is_null($limit)) { - if ($offset) { - if (common_config('db','type') == 'pgsql') { - $qry .= ' LIMIT ' . $limit . ' OFFSET ' . $offset; - } else { - $qry .= ' LIMIT ' . $offset . ', ' . $limit; - } - } + $lists = new Profile_list(); + $subs = new Profile_tag_subscription(); + + $lists->joinAdd($subs); + #@fixme: postgres (round(date_part('epoch', my_date))) + $lists->selectAdd('unix_timestamp(profile_tag_subscription.created) as "cursor"'); + + $lists->whereAdd('profile_tag_subscription.profile_id = '.$this->id); + + if ($since_id>0) { + $lists->whereAdd('cursor > '.$since_id); + } + + if ($max_id>0) { + $lists->whereAdd('cursor <= '.$max_id); } - $groups = new User_group(); + if($offset>=0 && !is_null($limit)) { + $lists->limit($offset, $limit); + } - $cnt = $groups->query(sprintf($qry, $this->id)); + $lists->orderBy('"cursor" DESC'); + $lists->find(); - return $groups; + return $lists; + } + + /** + * Request to join the given group. + * May throw exceptions on failure. + * + * @param User_group $group + * @return mixed: Group_member on success, Group_join_queue if pending approval, null on some cancels? + */ + function joinGroup(User_group $group) + { + $join = null; + if ($group->join_policy == User_group::JOIN_POLICY_MODERATE) { + $join = Group_join_queue::saveNew($this, $group); + } else { + if (Event::handle('StartJoinGroup', array($group, $this))) { + $join = Group_member::join($group->id, $this->id); + self::blow('profile:groups:%d', $this->id); + Event::handle('EndJoinGroup', array($group, $this)); + } + } + if ($join) { + // Send any applicable notifications... + $join->notify(); + } + return $join; + } + + /** + * Leave a group that this profile is a member of. + * + * @param User_group $group + */ + function leaveGroup(User_group $group) + { + if (Event::handle('StartLeaveGroup', array($group, $this))) { + Group_member::leave($group->id, $this->id); + self::blow('profile:groups:%d', $this->id); + Event::handle('EndLeaveGroup', array($group, $this)); + } } function avatarUrl($size=AVATAR_PROFILE_SIZE) @@ -372,67 +544,82 @@ class Profile extends Memcached_DataObject function getSubscriptions($offset=0, $limit=null) { - $qry = - 'SELECT profile.* ' . - 'FROM profile JOIN subscription ' . - 'ON profile.id = subscription.subscribed ' . - 'WHERE subscription.subscriber = %d ' . - 'AND subscription.subscribed != subscription.subscriber ' . - 'ORDER BY subscription.created DESC '; + $subs = Subscription::bySubscriber($this->id, + $offset, + $limit); - if ($offset>0 && !is_null($limit)){ - if (common_config('db','type') == 'pgsql') { - $qry .= ' LIMIT ' . $limit . ' OFFSET ' . $offset; - } else { - $qry .= ' LIMIT ' . $offset . ', ' . $limit; + $profiles = array(); + + while ($subs->fetch()) { + $profile = Profile::staticGet($subs->subscribed); + if ($profile) { + $profiles[] = $profile; } } - $profile = new Profile(); + return new ArrayWrapper($profiles); + } - $profile->query(sprintf($qry, $this->id)); + function getSubscribers($offset=0, $limit=null) + { + $subs = Subscription::bySubscribed($this->id, + $offset, + $limit); - return $profile; + $profiles = array(); + + while ($subs->fetch()) { + $profile = Profile::staticGet($subs->subscriber); + if ($profile) { + $profiles[] = $profile; + } + } + + return new ArrayWrapper($profiles); } - function getSubscribers($offset=0, $limit=null) + function getTaggedSubscribers($tag) { $qry = 'SELECT profile.* ' . - 'FROM profile JOIN subscription ' . + 'FROM profile JOIN (subscription, profile_tag, profile_list) ' . 'ON profile.id = subscription.subscriber ' . + 'AND profile.id = profile_tag.tagged ' . + 'AND profile_tag.tagger = profile_list.tagger AND profile_tag.tag = profile_list.tag ' . 'WHERE subscription.subscribed = %d ' . 'AND subscription.subscribed != subscription.subscriber ' . - 'ORDER BY subscription.created DESC '; - - if ($offset>0 && !is_null($limit)){ - if ($offset) { - if (common_config('db','type') == 'pgsql') { - $qry .= ' LIMIT ' . $limit . ' OFFSET ' . $offset; - } else { - $qry .= ' LIMIT ' . $offset . ', ' . $limit; - } - } - } + 'AND profile_tag.tagger = %d AND profile_tag.tag = "%s" ' . + 'AND profile_list.private = false ' . + 'ORDER BY subscription.created DESC'; $profile = new Profile(); + $tagged = array(); - $cnt = $profile->query(sprintf($qry, $this->id)); + $cnt = $profile->query(sprintf($qry, $this->id, $this->id, $tag)); - return $profile; + while ($profile->fetch()) { + $tagged[] = clone($profile); + } + return $tagged; } - function getConnectedApps($offset = 0, $limit = null) + /** + * Get pending subscribers, who have not yet been approved. + * + * @param int $offset + * @param int $limit + * @return Profile + */ + function getRequests($offset=0, $limit=null) { $qry = - 'SELECT u.* ' . - 'FROM oauth_application_user u, oauth_application a ' . - 'WHERE u.profile_id = %d ' . - 'AND a.id = u.application_id ' . - 'AND u.access_type > 0 ' . - 'ORDER BY u.created DESC '; - - if ($offset > 0) { + 'SELECT profile.* ' . + 'FROM profile JOIN subscription_queue '. + 'ON profile.id = subscription_queue.subscriber ' . + 'WHERE subscription_queue.subscribed = %d ' . + 'ORDER BY subscription_queue.created DESC '; + + if ($limit != null) { if (common_config('db','type') == 'pgsql') { $qry .= ' LIMIT ' . $limit . ' OFFSET ' . $offset; } else { @@ -440,11 +627,10 @@ class Profile extends Memcached_DataObject } } - $apps = new Oauth_application_user(); - - $cnt = $apps->query(sprintf($qry, $this->id)); + $members = new Profile(); - return $apps; + $members->query(sprintf($qry, $this->id)); + return $members; } function subscriptionCount() @@ -494,36 +680,42 @@ class Profile extends Memcached_DataObject return $cnt; } - function hasFave($notice) + /** + * Is this profile subscribed to another profile? + * + * @param Profile $other + * @return boolean + */ + function isSubscribed($other) { - $cache = Cache::instance(); - - // XXX: Kind of a hack. - - if (!empty($cache)) { - // This is the stream of favorite notices, in rev chron - // order. This forces it into cache. - - $ids = Fave::stream($this->id, 0, NOTICE_CACHE_WINDOW); - - // If it's in the list, then it's a fave - - if (in_array($notice->id, $ids)) { - return true; - } - - // If we're not past the end of the cache window, - // then the cache has all available faves, so this one - // is not a fave. + return Subscription::exists($this, $other); + } - if (count($ids) < NOTICE_CACHE_WINDOW) { - return false; - } + /** + * Check if a pending subscription request is outstanding for this... + * + * @param Profile $other + * @return boolean + */ + function hasPendingSubscription($other) + { + return Subscription_queue::exists($this, $other); + } - // Otherwise, cache doesn't have all faves; - // fall through to the default - } + /** + * Are these two profiles subscribed to each other? + * + * @param Profile $other + * @return boolean + */ + function mutuallySubscribed($other) + { + return $this->isSubscribed($other) && + $other->isSubscribed($this); + } + function hasFave($notice) + { $fave = Fave::pkeyGet(array('user_id' => $this->id, 'notice_id' => $notice->id)); return ((is_null($fave)) ? false : true); @@ -641,9 +833,11 @@ class Profile extends Memcached_DataObject $this->_deleteMessages(); $this->_deleteTags(); $this->_deleteBlocks(); + $this->delete_avatars(); - $related = array('Avatar', - 'Reply', + // Warning: delete() will run on the batch objects, + // not on individual objects. + $related = array('Reply', 'Group_member', ); Event::handle('ProfileDeleteRelated', array($this, &$related)); @@ -793,6 +987,10 @@ class Profile extends Memcached_DataObject throw new Exception("Can't save role '$name' for profile '{$this->id}'"); } + if ($name == 'owner') { + User::blow('user:site_owner'); + } + Event::handle('EndGrantRole', array($this, $name)); } @@ -821,6 +1019,10 @@ class Profile extends Memcached_DataObject throw new Exception(sprintf(_('Cannot revoke role "%1$s" for user #%2$d; database error.'),$name, $this->id)); } + if ($name == 'owner') { + User::blow('user:site_owner'); + } + Event::handle('EndRevokeRole', array($this, $name)); return true; @@ -897,6 +1099,7 @@ class Profile extends Memcached_DataObject case Right::NEWNOTICE: case Right::NEWMESSAGE: case Right::SUBSCRIBE: + case Right::CREATEGROUP: $result = !$this->isSilenced(); break; case Right::PUBLICNOTICE: @@ -905,6 +1108,24 @@ class Profile extends Memcached_DataObject case Right::EMAILONFAVE: $result = !$this->isSandboxed(); break; + case Right::WEBLOGIN: + $result = !$this->isSilenced(); + break; + case Right::API: + $result = !$this->isSilenced(); + break; + case Right::BACKUPACCOUNT: + $result = common_config('profile', 'backup'); + break; + case Right::RESTOREACCOUNT: + $result = common_config('profile', 'restore'); + break; + case Right::DELETEACCOUNT: + $result = common_config('profile', 'delete'); + break; + case Right::MOVEACCOUNT: + $result = common_config('profile', 'move'); + break; default: $result = false; break; @@ -952,6 +1173,31 @@ class Profile extends Memcached_DataObject return $xs->getString(); } + /** + * Extra profile info for atom entries + * + * Clients use some extra profile info in the atom stream. + * This gives it to them. + * + * @param User $cur Current user + * + * @return array representation of element or null + */ + + function profileInfo($cur) + { + $profileInfoAttr = array('local_id' => $this->id); + + if ($cur != null) { + // Whether the current user is a subscribed to this profile + $profileInfoAttr['following'] = $cur->isSubscribed($this) ? 'true' : 'false'; + // Whether the current user is has blocked this profile + $profileInfoAttr['blocking'] = $cur->hasBlocked($this) ? 'true' : 'false'; + } + + return array('statusnet:profile_info', $profileInfoAttr, null); + } + /** * Returns an XML string fragment with profile information as an * Activity Streams element. @@ -999,13 +1245,8 @@ class Profile extends Memcached_DataObject if (!empty($user)) { $uri = $user->uri; - } else { - // return OMB profile if any - $remote = Remote_profile::staticGet('id', $this->id); - if (!empty($remote)) { - $uri = $remote->uri; - } } + Event::handle('EndGetProfileUri', array($this, &$uri)); } @@ -1050,15 +1291,78 @@ class Profile extends Memcached_DataObject $user = User::staticGet('uri', $uri); if (!empty($user)) { $profile = $user->getProfile(); - } else { - $remote_profile = Remote_profile::staticGet('uri', $uri); - if (!empty($remote_profile)) { - $profile = Profile::staticGet('id', $remote_profile->profile_id); - } } Event::handle('EndGetProfileFromURI', array($uri, $profile)); } return $profile; } + + function canRead(Notice $notice) + { + if ($notice->scope & Notice::SITE_SCOPE) { + $user = $this->getUser(); + if (empty($user)) { + return false; + } + } + + if ($notice->scope & Notice::ADDRESSEE_SCOPE) { + $replies = $notice->getReplies(); + + if (!in_array($this->id, $replies)) { + $groups = $notice->getGroups(); + + $foundOne = false; + + foreach ($groups as $group) { + if ($this->isMember($group)) { + $foundOne = true; + break; + } + } + + if (!$foundOne) { + return false; + } + } + } + + if ($notice->scope & Notice::FOLLOWER_SCOPE) { + $author = $notice->getProfile(); + if (!Subscription::exists($this, $author)) { + return false; + } + } + + return true; + } + + static function current() + { + $user = common_current_user(); + if (empty($user)) { + $profile = null; + } else { + $profile = $user->getProfile(); + } + return $profile; + } + + /** + * Magic function called at serialize() time. + * + * We use this to drop a couple process-specific references + * from DB_DataObject which can cause trouble in future + * processes. + * + * @return array of variable names to include in serialization. + */ + + function __sleep() + { + $vars = parent::__sleep(); + $skip = array('_user'); + return array_diff($vars, $skip); + } }