X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=classes%2FUser_group.php;h=50f4b7ddc7cb232e10e1c5dd60c862f71b6fc746;hb=59744937077b51c8ff1e43d9cc386a90fb06463d;hp=6168f219b998d51a022a9bb93d6efd51ae2c8724;hpb=25198a8d4cee5b2182f1ecb99192a4108a01afa4;p=quix0rs-gnu-social.git diff --git a/classes/User_group.php b/classes/User_group.php index 6168f219b9..50f4b7ddc7 100644 --- a/classes/User_group.php +++ b/classes/User_group.php @@ -3,10 +3,11 @@ * Table Definition for user_group */ -class User_group extends Memcached_DataObject +class User_group extends Managed_DataObject { const JOIN_POLICY_OPEN = 0; const JOIN_POLICY_MODERATE = 1; + const CACHE_WINDOW = 201; ###START_AUTOCODE /* the code below is auto generated do not remove the above tag */ @@ -29,15 +30,45 @@ class User_group extends Memcached_DataObject public $join_policy; // tinyint public $force_scope; // tinyint - /* Static get */ - function staticGet($k,$v=NULL) { - return Memcached_DataObject::staticGet('User_group',$k,$v); - } - /* the code above is auto generated do not remove the tag below */ ###END_AUTOCODE - function defaultLogo($size) + public static function schemaDef() + { + return array( + 'fields' => array( + 'id' => array('type' => 'serial', 'not null' => true, 'description' => 'unique identifier'), + + 'nickname' => array('type' => 'varchar', 'length' => 64, 'description' => 'nickname for addressing'), + 'fullname' => array('type' => 'varchar', 'length' => 255, 'description' => 'display name'), + 'homepage' => array('type' => 'varchar', 'length' => 255, 'description' => 'URL, cached so we dont regenerate'), + 'description' => array('type' => 'text', 'description' => 'group description'), + 'location' => array('type' => 'varchar', 'length' => 255, 'description' => 'related physical location, if any'), + + 'original_logo' => array('type' => 'varchar', 'length' => 255, 'description' => 'original size logo'), + 'homepage_logo' => array('type' => 'varchar', 'length' => 255, 'description' => 'homepage (profile) size logo'), + 'stream_logo' => array('type' => 'varchar', 'length' => 255, 'description' => 'stream-sized logo'), + 'mini_logo' => array('type' => 'varchar', 'length' => 255, 'description' => 'mini logo'), + + 'created' => array('type' => 'datetime', 'not null' => true, 'description' => 'date this record was created'), + 'modified' => array('type' => 'timestamp', 'not null' => true, 'description' => 'date this record was modified'), + + 'uri' => array('type' => 'varchar', 'length' => 255, 'description' => 'universal identifier'), + 'mainpage' => array('type' => 'varchar', 'length' => 255, 'description' => 'page for group info to link to'), + 'join_policy' => array('type' => 'int', 'size' => 'tiny', 'description' => '0=open; 1=requires admin approval'), + 'force_scope' => array('type' => 'int', 'size' => 'tiny', 'description' => '0=never,1=sometimes,-1=always'), + ), + 'primary key' => array('id'), + 'unique keys' => array( + 'user_group_uri_key' => array('uri'), + ), + 'indexes' => array( + 'user_group_nickname_idx' => array('nickname'), + ), + ); + } + + public static function defaultLogo($size) { static $sizenames = array(AVATAR_PROFILE_SIZE => 'profile', AVATAR_STREAM_SIZE => 'stream', @@ -101,27 +132,52 @@ class User_group extends Memcached_DataObject return !in_array($nickname, $blacklist); } - function getMembers($offset=0, $limit=null) + function getMembers($offset=0, $limit=null) { + $ids = null; + if (is_null($limit) || $offset + $limit > User_group::CACHE_WINDOW) { + $ids = $this->getMemberIDs($offset, + $limit); + } else { + $key = sprintf('group:member_ids:%d', $this->id); + $window = self::cacheGet($key); + if ($window === false) { + $window = $this->getMemberIDs(0, + User_group::CACHE_WINDOW); + self::cacheSet($key, $window); + } + + $ids = array_slice($window, + $offset, + $limit); + } + + return Profile::multiGet('id', $ids); + } + + function getMemberIDs($offset=0, $limit=null) { - $qry = - 'SELECT profile.* ' . - 'FROM profile JOIN group_member '. - 'ON profile.id = group_member.profile_id ' . - 'WHERE group_member.group_id = %d ' . - 'ORDER BY group_member.created DESC '; + $gm = new Group_member(); - if ($limit != null) { - if (common_config('db','type') == 'pgsql') { - $qry .= ' LIMIT ' . $limit . ' OFFSET ' . $offset; - } else { - $qry .= ' LIMIT ' . $offset . ', ' . $limit; - } + $gm->selectAdd(); + $gm->selectAdd('profile_id'); + + $gm->group_id = $this->id; + + $gm->orderBy('created DESC'); + + if (!is_null($limit)) { + $gm->limit($offset, $limit); } - $members = new Profile(); + $ids = array(); - $members->query(sprintf($qry, $this->id)); - return $members; + if ($gm->find()) { + while ($gm->fetch()) { + $ids[] = $gm->profile_id; + } + } + + return $ids; } /** @@ -156,17 +212,44 @@ class User_group extends Memcached_DataObject function getMemberCount() { - // XXX: WORM cache this + $key = sprintf("group:member_count:%d", $this->id); - $members = $this->getMembers(); - $member_count = 0; + $cnt = self::cacheGet($key); - /** $member->count() doesn't work. */ - while ($members->fetch()) { - $member_count++; + if (is_integer($cnt)) { + return (int) $cnt; } - return $member_count; + $mem = new Group_member(); + $mem->group_id = $this->id; + + // XXX: why 'distinct'? + + $cnt = (int) $mem->count('distinct profile_id'); + + self::cacheSet($key, $cnt); + + return $cnt; + } + + function getBlockedCount() + { + // XXX: WORM cache this + + $block = new Group_block(); + $block->group_id = $this->id; + + return $block->count(); + } + + function getQueueCount() + { + // XXX: WORM cache this + + $queue = new Group_join_queue(); + $queue->group_id = $this->id; + + return $queue->count(); } function getAdmins($offset=0, $limit=null) @@ -316,7 +399,7 @@ class User_group extends Memcached_DataObject // Are there any matching remote groups this profile's in? if ($profile) { - $group = $profile->getGroups(); + $group = $profile->getGroups(0, null); while ($group->fetch()) { if ($group->nickname == $nickname) { // @fixme is this the best way? @@ -327,13 +410,13 @@ class User_group extends Memcached_DataObject // If not, check local groups. - $group = Local_group::staticGet('nickname', $nickname); + $group = Local_group::getKV('nickname', $nickname); if (!empty($group)) { - return User_group::staticGet('id', $group->group_id); + return User_group::getKV('id', $group->group_id); } - $alias = Group_alias::staticGet('alias', $nickname); + $alias = Group_alias::getKV('alias', $nickname); if (!empty($alias)) { - return User_group::staticGet('id', $alias->group_id); + return User_group::getKV('id', $alias->group_id); } return null; } @@ -477,7 +560,7 @@ class User_group extends Memcached_DataObject static function register($fields) { if (!empty($fields['userid'])) { - $profile = Profile::staticGet('id', $fields['userid']); + $profile = Profile::getKV('id', $fields['userid']); if ($profile && !$profile->hasRight(Right::CREATEGROUP)) { common_log(LOG_WARNING, "Attempted group creation from banned user: " . $profile->nickname); @@ -489,6 +572,18 @@ class User_group extends Memcached_DataObject // MAGICALLY put fields into current scope // @fixme kill extract(); it makes debugging absurdly hard + $defaults = array('nickname' => null, + 'fullname' => null, + 'homepage' => null, + 'description' => null, + 'location' => null, + 'uri' => null, + 'mainpage' => null, + 'aliases' => array(), + 'userid' => null); + + $fields = array_merge($defaults, $fields); + extract($fields); $group = new User_group(); @@ -636,7 +731,7 @@ class User_group extends Memcached_DataObject // or we'll miss clearing some cache keys; that can make it hard // to create a new group with one of those names or aliases. $this->setAliases(array()); - $local = Local_group::staticGet('group_id', $this->id); + $local = Local_group::getKV('group_id', $this->id); if ($local) { $local->delete(); } @@ -645,7 +740,7 @@ class User_group extends Memcached_DataObject self::blow('user_group:notice_ids:%d', $this->id); } else { - common_log(LOG_WARN, "Ambiguous user_group->delete(); skipping related tables."); + common_log(LOG_WARNING, "Ambiguous user_group->delete(); skipping related tables."); } parent::delete(); }