Fix some usages of ctype_digit().
[platal.git] / classes / userfilter.php
index 3e89426..2d33bca 100644 (file)
@@ -39,10 +39,10 @@ interface UserFilterCondition extends PlFilterCondition
 }
 // }}}
 
-// {{{ class UFC_Profile
+// {{{ class UFC_HasProfile
 /** Filters users who have a profile
  */
-class UFC_Profile implements UserFilterCondition
+class UFC_HasProfile implements UserFilterCondition
 {
     public function buildCondition(PlFilter &$uf)
     {
@@ -70,8 +70,31 @@ class UFC_Hruid implements UserFilterCondition
     public function buildCondition(PlFilter &$uf)
     {
         $ufc->requireAccounts();
+        return XDB::format('a.hruid IN {?}', $this->hruids);
+    }
+}
+// }}}
+
+// {{{ class UFC_Hrpid
+/** Filters users based on the hrpid of their profiles
+ * @param $val Either an hrpid, or a list of those
+ */
+class UFC_Hrpid implements UserFilterCondition
+{
+    private $hrpids;
+
+    public function __construct($val)
+    {
+        if (!is_array($val)) {
+            $val = array($val);
+        }
+        $this->hrpids = $val;
+    }
 
-        return 'a.hruid IN ' . XDB::formatArray($this->hruids);
+    public function buildCondition(PlFilter &$uf)
+    {
+        $uf->requireProfiles();
+        return XDB::format('p.hrpid IN {?}', $this->hrpids);
     }
 }
 // }}}
@@ -214,7 +237,7 @@ class UFC_EducationSchool implements UserFilterCondition
     public function buildCondition(PlFilter &$uf)
     {
         $sub = $uf->addEducationFilter();
-        return 'pe' . $sub . '.eduid IN ' . XDB::formatArray($this->val);
+        return XDB::format('pe' . $sub . '.eduid IN {?}', $this->val);
     }
 }
 // }}}
@@ -235,7 +258,7 @@ class UFC_EducationDegree implements UserFilterCondition
     public function buildCondition(PlFilter &$uf)
     {
         $sub = $uf->addEducationFilter();
-        return 'pee' . $sub . '.degreeid IN ' . XDB::formatArray($this->val);
+        return XDB::format('pee' . $sub . '.degreeid IN {?}', $this->val);
     }
 }
 // }}}
@@ -256,7 +279,7 @@ class UFC_EducationField implements UserFilterCondition
     public function buildCondition(PlFilter &$uf)
     {
         $sub = $uf->addEducationFilter();
-        return 'pee' . $sub . '.fieldid IN ' . XDB::formatArray($this->val);
+        return XDB::format('pee' . $sub . '.fieldid IN {?}', $this->val);
     }
 }
 // }}}
@@ -345,19 +368,19 @@ class UFC_NameTokens implements UserFilterCondition
         $sub = $uf->addNameTokensFilter(!($this->exact || $this->soundex));
         $conds = array();
         if ($this->soundex) {
-            $conds[] = $sub . '.soundex IN ' . XDB::formatArray($this->tokens);
+            $conds[] = XDB::format($sub . '.soundex IN {?}', $this->tokens);
         } else if ($this->exact) {
-            $conds[] = $sub . '.token IN ' . XDB::formatArray($this->tokens);
+            $conds[] = XDB::format($sub . '.token IN {?}', $this->tokens);
         } else {
             $tokconds = array();
             foreach ($this->tokens as $token) {
-                $tokconds[] = $sub . '.token ' . XDB::formatWildcards(XDB::WILDCARD_CONTAINS, $token);
+                $tokconds[] = $sub . '.token ' . XDB::formatWildcards(XDB::WILDCARD_PREFIX, $token);
             }
             $conds[] = implode(' OR ', $tokconds);
         }
 
         if ($this->flags != null) {
-            $conds[] = $sub . '.flags IN ' . XDB::formatArray($this->flags);
+            $conds[] = XDB::format($sub . '.flags IN {?}', $this->flags);
         }
 
         return implode(' AND ', $conds);
@@ -573,7 +596,7 @@ class UFC_Binet implements UserFilterCondition
     public function buildCondition(PlFilter &$uf)
     {
         $sub = $uf->addBinetsFilter();
-        return $sub . '.binet_id IN ' . XDB::formatArray($this->val);
+        return XDB::format($sub . '.binet_id IN {?}', $this->val);
     }
 }
 // }}}
@@ -600,51 +623,22 @@ class UFC_Section implements UserFilterCondition
 // }}}
 
 // {{{ class UFC_Email
-/** Filters users based on email address
- * @param $email Email whose owner we are looking for
- */
-class UFC_Email implements UserFilterCondition
-{
-    private $email;
-    public function __construct($email)
-    {
-        $this->email = $email;
-    }
-
-    public function buildCondition(PlFilter &$uf)
-    {
-        if (User::isForeignEmailAddress($this->email)) {
-            $sub = $uf->addEmailRedirectFilter($this->email);
-            return XDB::format('e' . $sub . '.email IS NOT NULL OR a.email = {?}', $this->email);
-        } else if (User::isVirtualEmailAddress($this->email)) {
-            $sub = $uf->addVirtualEmailFilter($this->email);
-            return 'vr' . $sub . '.redirect IS NOT NULL';
-        } else {
-            @list($user, $domain) = explode('@', $this->email);
-            $sub = $uf->addAliasFilter($user);
-            return 'al' . $sub . '.alias IS NOT NULL';
-        }
-    }
-}
-// }}}
-
-// {{{ class UFC_EmailList
-/** Filters users based on an email list
+/** Filters users based on an email or a list of emails
  * @param $emails List of emails whose owner must be selected
  */
-class UFC_EmailList implements UserFilterCondition
+class UFC_Email implements UserFilterCondition
 {
     private $emails;
-    public function __construct($emails)
+    public function __construct()
     {
-        $this->emails = $emails;
+        $this->emails = func_get_args();
     }
 
     public function buildCondition(PlFilter &$uf)
     {
-        $email   = null;
-        $virtual = null;
-        $alias   = null;
+        $foreign = array();
+        $virtual = array();
+        $aliases = array();
         $cond = array();
 
         if (count($this->emails) == 0) {
@@ -653,23 +647,27 @@ class UFC_EmailList implements UserFilterCondition
 
         foreach ($this->emails as $entry) {
             if (User::isForeignEmailAddress($entry)) {
-                if (is_null($email)) {
-                    $email = $uf->addEmailRedirectFilter();
-                }
-                $cond[] = XDB::format('e' . $email . '.email = {?} OR a.email = {?}', $entry, $entry);
+                $foreign[] = $entry;
             } else if (User::isVirtualEmailAddress($entry)) {
-                if (is_null($virtual)) {
-                    $virtual = $uf->addVirtualEmailFilter();
-                }
-                $cond[] = XDB::format('vr' . $virtual . '.redirect IS NOT NULL AND v' . $virtual . '.alias = {?}', $entry);
+                $virtual[] = $entry;
             } else {
-                if (is_null($alias)) {
-                    $alias = $uf->addAliasFilter();
-                }
                 @list($user, $domain) = explode('@', $entry);
-                $cond[] = XDB::format('al' . $alias . '.alias = {?}', $user);
+                $aliases[] = $user;
             }
         }
+
+        if (count($foreign) > 0) {
+            $sub = $uf->addEmailRedirectFilter($foreign);
+            $cond[] = XDB::format('e' . $sub . '.email IS NOT NULL OR a.email IN {?}', $foreign);
+        }
+        if (count($virtual) > 0) {
+            $sub = $uf->addVirtualEmailFilter($virtual);
+            $cond[] = 'vr' . $sub . '.redirect IS NOT NULL';
+        }
+        if (count($aliases) > 0) {
+            $sub = $uf->addAliasFilter($aliases);
+            $cond[] = 'al' . $sub . '.alias IS NOT NULL';
+        }
         return '(' . implode(') OR (', $cond) . ')';
     }
 }
@@ -732,7 +730,7 @@ abstract class UFC_Address implements UserFilterCondition
             }
         }
         if (count($types)) {
-            $conds[] = $sub . '.type IN ' . XDB::formatArray($types);
+            $conds[] = XDB::foramt($sub . '.type IN {?}', $types);
         }
 
         if ($this->flags != self::FLAG_ANY) {
@@ -859,7 +857,7 @@ class UFC_AddressField extends UFC_Address
         default:
             Platal::page()->killError('Invalid address field type: ' . $this->fieldtype);
         }
-        $conds[] = $sub . '.' . $field . ' IN ' . XDB::formatArray($this->val);
+        $conds[] = XDB::format($sub . '.' . $field . ' IN {?}', $this->val);
 
         return implode(' AND ', $conds);
     }
@@ -1253,14 +1251,14 @@ class UFC_WatchRegistration extends UFC_UserRelated
 {
     public function buildCondition(PlFilter &$uf)
     {
-        if (!$this->user->watch('registration')) {
+        if (!$this->user->watchType('registration')) {
             return PlFilterCondition::COND_FALSE;
         }
         $uids = $this->user->watchUsers();
         if (count($uids) == 0) {
             return PlFilterCondition::COND_FALSE;
         } else {
-            return '$UID IN ' . XDB::formatArray($uids);
+            return XDB::format('$UID IN {?}', $uids);
         }
     }
 }
@@ -1288,7 +1286,7 @@ class UFC_WatchPromo extends UFC_UserRelated
         } else {
             $sube = $uf->addEducationFilter(true, $this->grade);
             $field = 'pe' . $sube . '.' . UserFilter::promoYear($this->grade);
-            return $field . ' IN ' . XDB::formatArray($promos);
+            return XDB::format($field . ' IN {?}', $promos);
         }
     }
 }
@@ -1309,6 +1307,26 @@ class UFC_WatchContact extends UFC_Contact
 }
 // }}}
 
+// {{{ class UFC_MarketingHash
+/** Filters users using the hash generated
+ * to send marketing emails to him.
+ */
+class UFC_MarketingHash implements UserFilterCondition
+{
+    private $hash;
+
+    public function __construct($hash)
+    {
+        $this->hash = $hash;
+    }
+
+    public function buildCondition(PlFilter &$uf)
+    {
+        $table = $uf->addMarketingHash();
+        return XDB::format('rm.hash = {?}', $this->hash);
+    }
+}
+// }}}
 
 /******************
  * ORDERS
@@ -1584,7 +1602,7 @@ class UserFilter extends PlFilter
         $lim = $limit->getSql();
         $cond = '';
         if (!is_null($uids)) {
-            $cond = ' AND a.uid IN ' . XDB::formatArray($uids);
+            $cond = XDB::format(' AND a.uid IN {?}', $uids);
         }
         $fetched = XDB::fetchColumn('SELECT SQL_CALC_FOUND_ROWS  a.uid
                                     ' . $this->query . $cond . '
@@ -1602,7 +1620,7 @@ class UserFilter extends PlFilter
         $lim = $limit->getSql();
         $cond = '';
         if (!is_null($pids)) {
-            $cond = ' AND p.pid IN ' . XDB::formatArray($pids);
+            $cond = XDB::format(' AND p.pid IN {?}', $pids);
         }
         $fetched = XDB::fetchColumn('SELECT  SQL_CALC_FOUND_ROWS  p.pid
                                     ' . $this->query . $cond . '
@@ -1834,7 +1852,14 @@ class UserFilter extends PlFilter
 
     static private function getDBSuffix($string)
     {
-        return preg_replace('/[^a-z0-9]/i', '', $string);
+        if (is_array($string)) {
+            if (count($string) == 1) {
+                return self::getDBSuffix(array_pop($string));
+            }
+            return md5(implode('|', $string));
+        } else {
+            return preg_replace('/[^a-z0-9]/i', '', $string);
+        }
     }
 
 
@@ -1884,14 +1909,14 @@ class UserFilter extends PlFilter
         $joins = array();
         /** Quick search is much more efficient with sn first and PID second */
         if ($this->with_forced_sn) {
-            $joins['p'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profiles', '$PID = sn.uid');
+            $joins['p'] = PlSqlJoin::left('profiles', '$PID = sn.pid');
             if ($this->with_accounts) {
-                $joins['ap'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'account_profiles', '$ME.pid = $PID');
-                $joins['a'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'accounts', '$UID = ap.uid');
+                $joins['ap'] = PlSqlJoin::left('account_profiles', '$ME.pid = $PID');
+                $joins['a'] = PlSqlJoin::left('accounts', '$UID = ap.uid');
             }
         } else if ($this->with_profiles && $this->with_accounts) {
-            $joins['ap'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'account_profiles', '$ME.uid = $UID AND FIND_IN_SET(\'owner\', ap.perms)');
-            $joins['p'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profiles', '$PID = ap.pid');
+            $joins['ap'] = PlSqlJoin::left('account_profiles', '$ME.uid = $UID AND FIND_IN_SET(\'owner\', ap.perms)');
+            $joins['p'] = PlSqlJoin::left('profiles', '$PID = ap.pid');
         }
         return $joins;
     }
@@ -1910,7 +1935,7 @@ class UserFilter extends PlFilter
     protected function displayJoins()
     {
         if ($this->pd) {
-            return array('pd' => new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_display', '$ME.pid = $PID'));
+            return array('pd' => PlSqlJoin::left('profile_display', '$ME.pid = $PID'));
         } else {
             return array();
         }
@@ -1930,7 +1955,7 @@ class UserFilter extends PlFilter
     {
         $joins = array();
         if ($this->with_logger) {
-            $joins['ls'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'log_sessions', '$ME.uid = $UID');
+            $joins['ls'] = PlSqlJoin::left('log_sessions', '$ME.uid = $UID');
         }
         return $joins;
     }
@@ -1940,7 +1965,7 @@ class UserFilter extends PlFilter
 
     static public function assertName($name)
     {
-        if (!Profile::getNameTypeId($name)) {
+        if (!DirEnum::getID(DirEnum::NAMETYPES, $name)) {
             Platal::page()->kill('Invalid name type: ' . $name);
         }
     }
@@ -1960,7 +1985,7 @@ class UserFilter extends PlFilter
         if (!is_null($variant) && $variant == 'other') {
             $sub .= $this->option++;
         }
-        $this->pn[$sub] = Profile::getNameTypeId($ft);
+        $this->pn[$sub] = DirEnum::getID(DirEnum::NAMETYPES, $ft);
         return $sub;
     }
 
@@ -1968,7 +1993,7 @@ class UserFilter extends PlFilter
     {
         $joins = array();
         foreach ($this->pn as $sub => $type) {
-            $joins['pn' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_name', '$ME.pid = $PID AND $ME.typeid = ' . $type);
+            $joins['pn' . $sub] = PlSqlJoin::left('profile_name', '$ME.pid = $PID AND $ME.typeid = {?}', $type);
         }
         return $joins;
     }
@@ -1990,7 +2015,7 @@ class UserFilter extends PlFilter
         /* We don't return joins, since with_sn forces the SELECT to run on search_name first */
         if ($this->with_sn && !$this->with_forced_sn) {
             return array(
-                'sn' => new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'search_name', '$ME.uid = $PID')
+                'sn' => PlSqlJoin::left('search_name', '$ME.pid = $PID')
             );
         } else {
             return array();
@@ -2011,7 +2036,7 @@ class UserFilter extends PlFilter
     {
         $joins = array();
         if ($this->with_nat) {
-            $joins['ngc'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'geoloc_countries', '$ME.iso_3166_1_a2 = p.nationality1 OR $ME.iso_3166_1_a2 = p.nationality2 OR $ME.iso_3166_1_a2 = p.nationality3');
+            $joins['ngc'] = PlSqlJoin::left('geoloc_countries', '$ME.iso_3166_1_a2 = p.nationality1 OR $ME.iso_3166_1_a2 = p.nationality2 OR $ME.iso_3166_1_a2 = p.nationality3');
         }
         return $joins;
     }
@@ -2062,17 +2087,16 @@ class UserFilter extends PlFilter
     {
         $joins = array();
         if ($this->with_pee) {
-            $joins['pee'] = new PlSqlJoin(PlSqlJoin::MODE_INNER, 'profile_education_enum', 'pee.abbreviation = \'X\'');
+            $joins['pee'] = PlSqlJoin::inner('profile_education_enum', 'pee.abbreviation = \'X\'');
         }
         foreach ($this->pepe as $grade => $sub) {
             if ($this->isGrade($grade)) {
-                $joins['pe' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_education', '$ME.eduid = pee.id AND $ME.pid = $PID');
-                $joins['pede' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_INNER, 'profile_education_degree_enum', '$ME.id = pe' . $sub . '.degreeid AND $ME.abbreviation LIKE ' .
-                                                  XDB::format('{?}', $grade));
+                $joins['pe' . $sub] = PlSqlJoin::left('profile_education', '$ME.eduid = pee.id AND $ME.pid = $PID');
+                $joins['pede' . $sub] = PlSqlJoin::inner('profile_education_degree_enum', '$ME.id = pe' . $sub . '.degreeid AND $ME.abbreviation LIKE {?}', $grade);
             } else {
-                $joins['pe' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_education', '$ME.pid = $PID');
-                $joins['pee' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_INNER, 'profile_education_enum', '$ME.id = pe' . $sub . '.eduid');
-                $joins['pede' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_INNER, 'profile_education_degree_enum', '$ME.id = pe' . $sub . '.degreeid');
+                $joins['pe' . $sub] = PlSqlJoin::left('profile_education', '$ME.pid = $PID');
+                $joins['pee' . $sub] = PlSqlJoin::inner('profile_education_enum', '$ME.id = pe' . $sub . '.eduid');
+                $joins['pede' . $sub] = PlSqlJoin::inner('profile_education_degree_enum', '$ME.id = pe' . $sub . '.degreeid');
             }
         }
         return $joins;
@@ -2086,7 +2110,7 @@ class UserFilter extends PlFilter
     {
         $this->requireAccounts();
         if (!is_null($group)) {
-            if (ctype_digit($group)) {
+            if (is_int($group) || ctype_digit($group)) {
                 $index = $sub = $group;
             } else {
                 $index = $group;
@@ -2106,13 +2130,13 @@ class UserFilter extends PlFilter
         $joins = array();
         foreach ($this->gpm as $sub => $key) {
             if (is_null($key)) {
-                $joins['gpa' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_INNER, 'groups');
-                $joins['gpm' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'group_members', '$ME.uid = $UID AND $ME.asso_id = gpa' . $sub . '.id');
-            } else if (ctype_digit($key)) {
-                $joins['gpm' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'group_members', '$ME.uid = $UID AND $ME.asso_id = ' . $key);
+                $joins['gpa' . $sub] = PlSqlJoin::inner('groups');
+                $joins['gpm' . $sub] = PlSqlJoin::left('group_members', '$ME.uid = $UID AND $ME.asso_id = gpa' . $sub . '.id');
+            } else if (is_int($key) || ctype_digit($key)) {
+                $joins['gpm' . $sub] = PlSqlJoin::left('group_members', '$ME.uid = $UID AND $ME.asso_id = ' . $key);
             } else {
-                $joins['gpa' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_INNER, 'groups', XDB::format('$ME.diminutif = {?}', $key));
-                $joins['gpm' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'group_members', '$ME.uid = $UID AND $ME.asso_id = gpa' . $sub . '.id');
+                $joins['gpa' . $sub] = PlSqlJoin::inner('groups', '$ME.diminutif = {?}', $key);
+                $joins['gpm' . $sub] = PlSqlJoin::left('group_members', '$ME.uid = $UID AND $ME.asso_id = gpa' . $sub . '.id');
             }
         }
         return $joins;
@@ -2139,10 +2163,10 @@ class UserFilter extends PlFilter
     {
         $joins = array();
         if ($this->with_bi) {
-            $joins['bi'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_binets', '$ME.pid = $PID');
+            $joins['bi'] = PlSqlJoin::left('profile_binets', '$ME.pid = $PID');
         }
         if ($this->with_bd) {
-            $joins['bd'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_binet_enum', '$ME.id = bi.binet_id');
+            $joins['bd'] = PlSqlJoin::left('profile_binet_enum', '$ME.id = bi.binet_id');
         }
         return $joins;
     }
@@ -2178,33 +2202,45 @@ class UserFilter extends PlFilter
         $joins = array();
         foreach ($this->e as $sub=>$key) {
             if (is_null($key)) {
-                $joins['e' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'emails', '$ME.uid = $UID AND $ME.flags != \'filter\'');
+                $joins['e' . $sub] = PlSqlJoin::left('emails', '$ME.uid = $UID AND $ME.flags != \'filter\'');
             } else {
-                $joins['e' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'emails', XDB::format('$ME.uid = $UID AND $ME.flags != \'filter\' AND $ME.email = {?}', $key));
+                if (!is_array($key)) {
+                    $key = array($key);
+                }
+                $joins['e' . $sub] = PlSqlJoin::left('emails', '$ME.uid = $UID AND $ME.flags != \'filter\' 
+                                                               AND $ME.email IN {?}' . $key);
             }
         }
         foreach ($this->al as $sub=>$key) {
             if (is_null($key)) {
-                $joins['al' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'aliases', '$ME.uid = $UID AND $ME.type IN (\'alias\', \'a_vie\')');
+                $joins['al' . $sub] = PlSqlJoin::left('aliases', '$ME.uid = $UID AND $ME.type IN (\'alias\', \'a_vie\')');
             } else if ($key == self::ALIAS_BEST) {
-                $joins['al' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'aliases', '$ME.uid = $UID AND $ME.type IN (\'alias\', \'a_vie\') AND  FIND_IN_SET(\'bestalias\', $ME.flags)');
+                $joins['al' . $sub] = PlSqlJoin::left('aliases', '$ME.uid = $UID AND $ME.type IN (\'alias\', \'a_vie\') AND  FIND_IN_SET(\'bestalias\', $ME.flags)');
             } else if ($key == self::ALIAS_FORLIFE) {
-                $joins['al' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'aliases', '$ME.uid = $UID AND $ME.type = \'a_vie\'');
+                $joins['al' . $sub] = PlSqlJoin::left('aliases', '$ME.uid = $UID AND $ME.type = \'a_vie\'');
             } else {
-                $joins['al' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'aliases', XDB::format('$ME.uid = $UID AND $ME.type IN (\'alias\', \'a_vie\') AND $ME.alias = {?}', $key));
+                if (!is_array($key)) {
+                    $key = array($key);
+                }
+                $joins['al' . $sub] = PlSqlJoin::left('aliases', '$ME.uid = $UID AND $ME.type IN (\'alias\', \'a_vie\') 
+                                                                  AND $ME.alias IN {?}', $key);
             }
         }
         foreach ($this->ve as $sub=>$key) {
             if (is_null($key)) {
-                $joins['v' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'virtual', '$ME.type = \'user\'');
+                $joins['v' . $sub] = PlSqlJoin::left('virtual', '$ME.type = \'user\'');
             } else {
-                $joins['v' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'virtual', XDB::format('$ME.type = \'user\' AND $ME.alias = {?}', $key));
+                if (!is_array($key)) {
+                    $key = array($key);
+                }
+                $joins['v' . $sub] = PlSqlJoin::left('virtual', '$ME.type = \'user\' AND $ME.alias IN {?}', $key);
             }
-            $joins['vr' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'virtual_redirect', XDB::format('$ME.vid = v' . $sub . '.vid
-                                                                                 AND ($ME.redirect IN (CONCAT(al_forlife.alias, \'@\', {?}),
-                                                                                                       CONCAT(al_forlife.alias, \'@\', {?}),
-                                                                                                       a.email))',
-                                                                                $globals->mail->domain, $globals->mail->domain2));
+            $joins['vr' . $sub] = PlSqlJoin::left('virtual_redirect',
+                                                  '$ME.vid = v' . $sub . '.vid
+                                                   AND ($ME.redirect IN (CONCAT(al_forlife.alias, \'@\', {?}),
+                                                                         CONCAT(al_forlife.alias, \'@\', {?}),
+                                                                         a.email))',
+                                                  $globals->mail->domain, $globals->mail->domain2);
         }
         return $joins;
     }
@@ -2242,13 +2278,13 @@ class UserFilter extends PlFilter
     {
         $joins = array();
         if ($this->with_pa) {
-            $joins['pa'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_addresses', '$ME.pid = $PID');
+            $joins['pa'] = PlSqlJoin::left('profile_addresses', '$ME.pid = $PID');
         }
         if ($this->with_pac) {
-            $joins['gc'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'geoloc_countries', '$ME.iso_3166_1_a2 = pa.countryID');
+            $joins['gc'] = PlSqlJoin::left('geoloc_countries', '$ME.iso_3166_1_a2 = pa.countryID');
         }
         if ($this->with_pal) {
-            $joins['gl'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'geoloc_localities', '$ME.id = pa.localityID');
+            $joins['gl'] = PlSqlJoin::left('geoloc_localities', '$ME.id = pa.localityID');
         }
         return $joins;
     }
@@ -2285,13 +2321,13 @@ class UserFilter extends PlFilter
     {
         $joins = array();
         if ($this->pc) {
-            $joins['pc'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_corps', '$ME.pid = $PID');
+            $joins['pc'] = PlSqlJoin::left('profile_corps', '$ME.pid = $PID');
         }
         if ($this->pcr) {
-            $joins['pcr'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_corps_rank_enum', '$ME.id = pc.rankid');
+            $joins['pcr'] = PlSqlJoin::left('profile_corps_rank_enum', '$ME.id = pc.rankid');
         }
         foreach($this->pce as $sub => $field) {
-            $joins[$sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_corps_enum', '$ME.id = pc.' . $field);
+            $joins[$sub] = PlSqlJoin::left('profile_corps_enum', '$ME.id = pc.' . $field);
         }
         return $joins;
     }
@@ -2360,22 +2396,22 @@ class UserFilter extends PlFilter
     {
         $joins = array();
         if ($this->with_pj) {
-            $joins['pj'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_job', '$ME.pid = $PID');
+            $joins['pj'] = PlSqlJoin::left('profile_job', '$ME.pid = $PID');
         }
         if ($this->with_pje) {
-            $joins['pje'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_job_enum', '$ME.id = pj.jobid');
+            $joins['pje'] = PlSqlJoin::left('profile_job_enum', '$ME.id = pj.jobid');
         }
         if ($this->with_pjse) {
-            $joins['pjse'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_job_sector_enum', '$ME.id = pj.sectorid');
+            $joins['pjse'] = PlSqlJoin::left('profile_job_sector_enum', '$ME.id = pj.sectorid');
         }
         if ($this->with_pjsse) {
-            $joins['pjsse'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_job_subsector_enum', '$ME.id = pj.subsectorid');
+            $joins['pjsse'] = PlSqlJoin::left('profile_job_subsector_enum', '$ME.id = pj.subsectorid');
         }
         if ($this->with_pjssse) {
-            $joins['pjssse'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_job_subsubsector_enum', '$ME.id = pj.subsubsectorid');
+            $joins['pjssse'] = PlSqlJoin::left('profile_job_subsubsector_enum', '$ME.id = pj.subsubsectorid');
         }
         if ($this->with_pja) {
-            $joins['pja'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_job_alternates', '$ME.subsubsectorid = pj.subsubsectorid');
+            $joins['pja'] = PlSqlJoin::left('profile_job_alternates', '$ME.subsubsectorid = pj.subsubsectorid');
         }
         return $joins;
     }
@@ -2395,7 +2431,7 @@ class UserFilter extends PlFilter
     {
         $joins = array();
         if ($this->with_pnw) {
-            $joins['pnw'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_networking', '$ME.pid = $PID');
+            $joins['pnw'] = PlSqlJoin::left('profile_networking', '$ME.pid = $PID');
         }
         return $joins;
     }
@@ -2416,7 +2452,7 @@ class UserFilter extends PlFilter
     {
         $joins = array();
         if ($this->with_ptel) {
-            $joins['ptel'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_phones', '$ME.pid = $PID');
+            $joins['ptel'] = PlSqlJoin::left('profile_phones', '$ME.pid = $PID');
         }
         return $joins;
     }
@@ -2436,7 +2472,7 @@ class UserFilter extends PlFilter
     {
         $joins = array();
         if ($this->with_pmed) {
-            $joins['pmed'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_medals', '$ME.pid = $PID');
+            $joins['pmed'] = PlSqlJoin::left('profile_medals', '$ME.pid = $PID');
         }
         return $joins;
     }
@@ -2471,7 +2507,7 @@ class UserFilter extends PlFilter
     {
         $joins = array();
         foreach ($this->pms as $sub => $tab) {
-            $joins[$sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, $tab, '$ME.pid = $PID');
+            $joins[$sub] = PlSqlJoin::left($tab, '$ME.pid = $PID');
         }
         return $joins;
     }
@@ -2481,7 +2517,7 @@ class UserFilter extends PlFilter
     private $cts = array();
     public function addContactFilter($uid = null)
     {
-        $this->requireAccounts();
+        $this->requireProfiles();
         return $this->register_optional($this->cts, is_null($uid) ? null : 'user_' . $uid);
     }
 
@@ -2490,9 +2526,9 @@ class UserFilter extends PlFilter
         $joins = array();
         foreach ($this->cts as $sub=>$key) {
             if (is_null($key)) {
-                $joins['c' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'contacts', '$ME.contact = $UID');
+                $joins['c' . $sub] = PlSqlJoin::left('contacts', '$ME.contact = $PID');
             } else {
-                $joins['c' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'contacts', XDB::format('$ME.uid = {?} AND $ME.contact = $UID', substr($key, 5)));
+                $joins['c' . $sub] = PlSqlJoin::left('contacts', '$ME.uid = {?} AND $ME.contact = $PID', substr($key, 5));
             }
         }
         return $joins;
@@ -2527,34 +2563,53 @@ class UserFilter extends PlFilter
         $joins = array();
         foreach ($this->w as $sub=>$key) {
             if (is_null($key)) {
-                $joins['w' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'watch');
+                $joins['w' . $sub] = PlSqlJoin::left('watch');
             } else {
-                $joins['w' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'watch', XDB::format('$ME.uid = {?}', substr($key, 5)));
+                $joins['w' . $sub] = PlSqlJoin::left('watch', '$ME.uid = {?}', substr($key, 5));
             }
         }
         foreach ($this->wn as $sub=>$key) {
             if (is_null($key)) {
-                $joins['wn' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'watch_nonins', '$ME.ni_id = $UID');
+                $joins['wn' . $sub] = PlSqlJoin::left('watch_nonins', '$ME.ni_id = $UID');
             } else {
-                $joins['wn' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'watch_nonins', XDB::format('$ME.uid = {?} AND $ME.ni_id = $UID', substr($key, 5)));
+                $joins['wn' . $sub] = PlSqlJoin::left('watch_nonins', '$ME.uid = {?} AND $ME.ni_id = $UID', substr($key, 5));
             }
         }
         foreach ($this->wn as $sub=>$key) {
             if (is_null($key)) {
-                $joins['wn' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'watch_nonins', '$ME.ni_id = $UID');
+                $joins['wn' . $sub] = PlSqlJoin::left('watch_nonins', '$ME.ni_id = $UID');
             } else {
-                $joins['wn' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'watch_nonins', XDB::format('$ME.uid = {?} AND $ME.ni_id = $UID', substr($key, 5)));
+                $joins['wn' . $sub] = PlSqlJoin::left('watch_nonins', '$ME.uid = {?} AND $ME.ni_id = $UID', substr($key, 5));
             }
         }
         foreach ($this->wp as $sub=>$key) {
             if (is_null($key)) {
-                $joins['wp' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'watch_promo');
+                $joins['wp' . $sub] = PlSqlJoin::left('watch_promo');
             } else {
-                $joins['wp' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'watch_promo', XDB::format('$ME.uid = {?}', substr($key, 5)));
+                $joins['wp' . $sub] = PlSqlJoin::left('watch_promo', '$ME.uid = {?}', substr($key, 5));
             }
         }
         return $joins;
     }
+
+
+    /** MARKETING
+     */
+    private $with_rm;
+    public function addMarketingHash()
+    {
+        $this->requireAccounts();
+        $this->with_rm = true;
+    }
+
+    protected function marketingJoins()
+    {
+        if ($this->with_rm) {
+            return array('rm' => PlSqlJoin::left('register_marketing', '$ME.uid = $UID'));
+        } else {
+            return array();
+        }
+    }
 }
 // }}}