/**
* Table Definition for profile_tag
*/
-require_once INSTALLDIR.'/classes/Memcached_DataObject.php';
-class Profile_tag extends Memcached_DataObject
+class Profile_tag extends Managed_DataObject
{
- ###START_AUTOCODE
- /* the code below is auto generated do not remove the above tag */
-
public $__table = 'profile_tag'; // table name
public $tagger; // int(4) primary_key not_null
public $tagged; // int(4) primary_key not_null
public $tag; // varchar(64) primary_key not_null
public $modified; // timestamp() not_null default_CURRENT_TIMESTAMP
- /* Static get */
- function staticGet($k,$v=null)
- { return Memcached_DataObject::staticGet('Profile_tag',$k,$v); }
-
- /* the code above is auto generated do not remove the tag below */
- ###END_AUTOCODE
-
- function pkeyGet($kv) {
- return Memcached_DataObject::pkeyGet('Profile_tag', $kv);
+ public static function schemaDef()
+ {
+ return array(
+
+ 'fields' => array(
+ 'tagger' => array('type' => 'int', 'not null' => true, 'description' => 'user making the tag'),
+ 'tagged' => array('type' => 'int', 'not null' => true, 'description' => 'profile tagged'),
+ 'tag' => array('type' => 'varchar', 'length' => 64, 'not null' => true, 'description' => 'hash tag associated with this notice'),
+ 'modified' => array('type' => 'timestamp', 'not null' => true, 'description' => 'date the tag was added'),
+ ),
+ 'primary key' => array('tagger', 'tagged', 'tag'),
+ 'foreign keys' => array(
+ 'profile_tag_tagger_fkey' => array('profile', array('tagger' => 'id')),
+ 'profile_tag_tagged_fkey' => array('profile', array('tagged' => 'id')),
+ 'profile_tag_tag_fkey' => array('profile_list', array('tag' => 'tag')),
+ ),
+ 'indexes' => array(
+ 'profile_tag_modified_idx' => array('modified'),
+ 'profile_tag_tagger_tag_idx' => array('tagger', 'tag'),
+ 'profile_tag_tagged_idx' => array('tagged'),
+ ),
+ );
}
function links()
return Profile_list::pkeyGet(array('tagger' => $this->tagger, 'tag' => $this->tag));
}
+ static function getSelfTagsArray(Profile $target)
+ {
+ return self::getTagsArray($target->getID(), $target->getID(), $target);
+ }
+
+ static function setSelfTags(Profile $target, array $newtags, array $privacy=array())
+ {
+ return self::setTags($target->getID(), $target->getID(), $newtags, $privacy);
+ }
+
static function getTags($tagger, $tagged, $auth_user=null) {
$profile_list = new Profile_list();
return $tags;
}
- $profile_tag = new Profile_tag();
- $profile_list->tagger = $tagger;
- $profile_tag->tagged = $tagged;
+ $qry = 'select profile_list.* from profile_list left join '.
+ 'profile_tag on (profile_list.tag = profile_tag.tag and '.
+ 'profile_list.tagger = profile_tag.tagger) where '.
+ 'profile_tag.tagger = %d and profile_tag.tagged = %d ';
+ $qry = sprintf($qry, $tagger, $tagged);
- $profile_list->selectAdd();
+ if (!$include_priv) {
+ $qry .= ' and profile_list.private = 0';
+ }
- // only fetch id, tag, mainpage and
- // private hoping this will be faster
- $profile_list->selectAdd('profile_list.id, ' .
- 'profile_list.tag, ' .
- 'profile_list.mainpage, ' .
- 'profile_list.private');
- $profile_list->joinAdd($profile_tag);
- $profile_list->find();
+ $profile_list->query($qry);
Profile_list::setCache($key, $profile_list);
return $profile_list;
}
- static function getTagsArray($tagger, $tagged, $auth_user_id=null)
+ static function getTagsArray($tagger, $tagged, Profile $scoped=null)
{
$ptag = new Profile_tag();
- $ptag->tagger = $tagger;
- $ptag->tagged = $tagged;
-
- if ($tagger != $auth_user_id) {
- $list = new Profile_list();
- $list->private = false;
- $ptag->joinAdd($list);
- $ptag->selectAdd();
- $ptag->selectAdd('profile_tag.tag');
+
+ $qry = sprintf('select profile_tag.tag '.
+ 'from profile_tag join profile_list '.
+ ' on (profile_tag.tagger = profile_list.tagger ' .
+ ' and profile_tag.tag = profile_list.tag) ' .
+ 'where profile_tag.tagger = %d ' .
+ 'and profile_tag.tagged = %d ',
+ $tagger, $tagged);
+
+ if (!$scoped instanceof Profile || $scoped->getID() !== $tagger) {
+ $qry .= 'and profile_list.private = 0';
}
$tags = array();
- $ptag->find();
+
+ $ptag->query($qry);
+
while ($ptag->fetch()) {
$tags[] = $ptag->tag;
}
- $ptag->free();
return $tags;
}
- static function setTags($tagger, $tagged, $newtags, $privacy=array()) {
+ static function setTags($tagger, $tagged, array $newtags, array $privacy=array()) {
$newtags = array_unique($newtags);
- $oldtags = self::getTagsArray($tagger, $tagged, $tagger);
+ $oldtags = self::getTagsArray($tagger, $tagged, Profile::getByID($tagger));
$ptag = new Profile_tag();
'tag' => $tag));
# if tag already exists, return it
- if(!empty($ptag)) {
+ if ($ptag instanceof Profile_tag) {
return $ptag;
}
- $tagger_profile = Profile::staticGet('id', $tagger);
- $tagged_profile = Profile::staticGet('id', $tagged);
+ $tagger_profile = Profile::getByID($tagger);
+ $tagged_profile = Profile::getByID($tagged);
if (Event::handle('StartTagProfile', array($tagger_profile, $tagged_profile, $tag))) {
if (!$tagger_profile->canTag($tagged_profile)) {
+ // TRANS: Client exception thrown trying to set a tag for a user that cannot be tagged.
throw new ClientException(_('You cannot tag this user.'));
- return false;
}
$tags = new Profile_list();
$count = (int) $tags->count('distinct tag');
if ($count >= common_config('peopletag', 'maxtags')) {
+ // TRANS: Client exception thrown trying to set more tags than allowed.
throw new ClientException(sprintf(_('You already have created %d or more tags ' .
'which is the maximum allowed number of tags. ' .
'Try using or deleting some existing tags.'),
common_config('peopletag', 'maxtags')));
- return false;
}
$plist = new Profile_list();
$profile_list = Profile_list::ensureTag($tagger, $tag, $desc, $private);
if ($profile_list->taggedCount() >= common_config('peopletag', 'maxpeople')) {
- throw new ClientException(sprintf(_('You already have %d or more people tagged %s ' .
- 'which is the maximum allowed number.' .
- 'Try untagging others with the same tag first.'),
+ // TRANS: Client exception thrown when trying to add more people than allowed to a list.
+ throw new ClientException(sprintf(_('You already have %1$d or more people in list %2$s, ' .
+ 'which is the maximum allowed number. ' .
+ 'Try unlisting others first.'),
common_config('peopletag', 'maxpeople'), $tag));
- return false;
}
$newtag = new Profile_tag();
$result = $newtag->insert();
-
if (!$result) {
common_log_db_error($newtag, 'INSERT', __FILE__);
+ $plist->query('ROLLBACK');
return false;
}
$newtag->delete();
$profile_list->delete();
throw $e;
- return false;
}
$profile_list->taggedCount(true);
if (Event::handle('StartUntagProfile', array($ptag))) {
$orig = clone($ptag);
$result = $ptag->delete();
- if (!$result) {
+ if ($result === false) {
common_log_db_error($this, 'DELETE', __FILE__);
return false;
}
Event::handle('EndUntagProfile', array($orig));
- if ($result) {
- $profile_list = Profile_list::pkeyGet(array('tag' => $tag, 'tagger' => $tagger));
+ $profile_list = Profile_list::pkeyGet(array('tag' => $tag, 'tagger' => $tagger));
+ if (!empty($profile_list)) {
$profile_list->taggedCount(true);
- self::blowCaches($tagger, $tagged);
- return true;
}
- return false;
+ self::blowCaches($tagger, $tagged);
+ return true;
}
}
'tag = "%s", tagger = "%s" ' .
'WHERE tag = "%s" ' .
'AND tagger = "%s"';
- $result = $tags->query(sprintf($qry, $new->tag, $new->tagger,
- $orig->tag, $orig->tagger));
+ $result = $tags->query(sprintf($qry,
+ $tags->escape($new->tag),
+ $tags->escape($new->tagger),
+ $tags->escape($orig->tag),
+ $tags->escape($orig->tagger)));
- if (!$result) {
+ if ($result === false) {
common_log_db_error($tags, 'UPDATE', __FILE__);
- return false;
+ throw new Exception('Could not move Profile_tag, see db log for details.');
}
- return true;
+ return $result;
}
static function blowCaches($tagger, $tagged) {
$profile->query('SELECT profile.* ' .
'FROM profile JOIN profile_tag ' .
'ON profile.id = profile_tag.tagged ' .
- 'WHERE profile_tag.tagger = ' . $tagger . ' ' .
- 'AND profile_tag.tag = "' . $tag . '" ');
+ 'WHERE profile_tag.tagger = ' . $profile->escape($tagger) . ' ' .
+ 'AND profile_tag.tag = "' . $profile->escape($tag) . '" ');
$tagged = array();
while ($profile->fetch()) {
$tagged[] = clone($profile);
}
return true;
}
+
+ function insert()
+ {
+ $result = parent::insert();
+ if ($result) {
+ self::blow('profile_list:tagged_count:%d:%s',
+ $this->tagger,
+ $this->tag);
+ }
+ return $result;
+ }
+
+ function delete($useWhere=false)
+ {
+ $result = parent::delete($useWhere);
+ if ($result !== false) {
+ self::blow('profile_list:tagged_count:%d:%s',
+ $this->tagger,
+ $this->tag);
+ }
+ return $result;
+ }
}
projects / quix0rs-gnu-social.git / blobdiff