X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=classes%2FUser.php;h=c9c61d3aed40606267eb5e6268b624b91e39a1c4;hb=a2d8305e2159f60df979898983b5fe4ccf166a16;hp=ec6ceccf1244c79e6c48f608b4b274488274dc4a;hpb=a964ea61cd03d887a47cf6238c2e73a8a1837295;p=quix0rs-gnu-social.git diff --git a/classes/User.php b/classes/User.php index ec6ceccf12..c9c61d3aed 100644 --- a/classes/User.php +++ b/classes/User.php @@ -42,7 +42,6 @@ class User extends Managed_DataObject public $emailnotifynudge; // tinyint(1) default_1 public $emailnotifymsg; // tinyint(1) default_1 public $emailnotifyattn; // tinyint(1) default_1 - public $emailmicroid; // tinyint(1) default_1 public $language; // varchar(50) public $timezone; // varchar(50) public $emailpost; // tinyint(1) default_1 @@ -77,7 +76,6 @@ class User extends Managed_DataObject 'emailnotifynudge' => array('type' => 'int', 'size' => 'tiny', 'default' => 1, 'description' => 'Notify by email of nudges'), 'emailnotifymsg' => array('type' => 'int', 'size' => 'tiny', 'default' => 1, 'description' => 'Notify by email of direct messages'), 'emailnotifyattn' => array('type' => 'int', 'size' => 'tiny', 'default' => 1, 'description' => 'Notify by email of @-replies'), - 'emailmicroid' => array('type' => 'int', 'size' => 'tiny', 'default' => 1, 'description' => 'whether to publish email microid'), 'language' => array('type' => 'varchar', 'length' => 50, 'description' => 'preferred language'), 'timezone' => array('type' => 'varchar', 'length' => 50, 'description' => 'timezone'), 'emailpost' => array('type' => 'int', 'size' => 'tiny', 'default' => 1, 'description' => 'Post by email'), @@ -142,6 +140,16 @@ class User extends Managed_DataObject return $this->uri; } + static function getByUri($uri) + { + $user = new User(); + $user->uri = $uri; + if (!$user->find(true)) { + throw new NoResultException($user); + } + return $user; + } + public function getNickname() { return $this->getProfile()->getNickname(); @@ -182,7 +190,7 @@ class User extends Managed_DataObject return Sms_carrier::getKV('id', $this->carrier); } - function hasBlocked($other) + function hasBlocked(Profile $other) { return $this->getProfile()->hasBlocked($other); } @@ -209,7 +217,7 @@ class User extends Managed_DataObject * @return User object * @throws Exception on failure */ - static function register(array $fields) { + static function register(array $fields, $accept_email_fail=false) { // MAGICALLY put fields into current scope @@ -276,9 +284,7 @@ class User extends Managed_DataObject $user->emailnotifynudge = 1; $user->emailnotifymsg = 1; $user->emailnotifyattn = 1; - $user->emailmicroid = 1; $user->emailpost = 1; - $user->jabbermicroid = 1; $user->created = common_sql_now(); @@ -303,7 +309,7 @@ class User extends Managed_DataObject } if (!empty($password)) { // may not have a password for OpenID users - $user->password = common_munge_password($password, $id); + $user->password = common_munge_password($password); } $result = $user->insert(); @@ -337,7 +343,8 @@ class User extends Managed_DataObject $invite->convert($user); } - if (!empty($email) && !$user->email) { + if (!empty($email) && empty($user->email)) { + // The actual email will be sent further down, after the database COMMIT $confirm = new Confirm_address(); $confirm->code = common_confirmation_code(128); @@ -347,7 +354,7 @@ class User extends Managed_DataObject $result = $confirm->insert(); - if (!$result) { + if ($result===false) { common_log_db_error($confirm, 'INSERT', __FILE__); $profile->query('ROLLBACK'); // TRANS: Email confirmation data could not be inserted for some reason. @@ -375,8 +382,15 @@ class User extends Managed_DataObject $profile->query('COMMIT'); - if (!empty($email) && !$user->email) { - mail_confirm_address($user, $confirm->code, $profile->nickname, $email); + if (!empty($email) && empty($user->email)) { + try { + $confirm->sendConfirmation(); + } catch (EmailException $e) { + common_log(LOG_ERR, "Could not send user registration email for user id=={$profile->getID()}: {$e->getMessage()}"); + if (!$accept_email_fail) { + throw $e; + } + } } // Welcome message @@ -394,7 +408,7 @@ class User extends Managed_DataObject // TRANS: %1$s is the sitename, $2$s is the registering user's nickname. sprintf(_('Welcome to %1$s, @%2$s!'), common_config('site', 'name'), - $user->nickname), + $profile->getNickname()), 'system'); } } @@ -402,7 +416,7 @@ class User extends Managed_DataObject Event::handle('EndUserRegister', array($profile)); } - if (!$user instanceof User) { + if (!$user instanceof User || empty($user->id)) { throw new ServerException('User could not be registered. Probably an event hook that failed.'); } @@ -420,13 +434,14 @@ class User extends Managed_DataObject if ($invites->find()) { while ($invites->fetch()) { try { - $other = Profile::getKV('id', $invites->user_id); - if (!($other instanceof Profile)) { // remove when getKV throws exceptions - continue; - } + $other = Profile::getByID($invites->user_id); Subscription::start($other, $this->getProfile()); + } catch (NoResultException $e) { + // profile did not exist + } catch (AlreadyFulfilledException $e) { + // already subscribed to this profile } catch (Exception $e) { - continue; + common_log(LOG_ERR, 'On-invitation-completion subscription failed when subscribing '._ve($invites->user_id).' to '.$this->getProfile()->getID().': '._ve($e->getMessage())); } } } @@ -466,16 +481,6 @@ class User extends Managed_DataObject return $this->getProfile()->getNotices($offset, $limit, $since_id, $before_id); } - function getSelfTags() - { - return Profile_tag::getTagsArray($this->id, $this->id, $this->id); - } - - function setSelfTags($newtags, $privacy) - { - return Profile_tag::setTags($this->id, $this->id, $newtags, $privacy); - } - function block(Profile $other) { // Add a new block record @@ -612,8 +617,10 @@ class User extends Managed_DataObject } try { - $profile = $this->getProfile(); - $profile->delete(); + if (!$this->hasRole(Profile_role::DELETED)) { + $profile = $this->getProfile(); + $profile->delete(); + } } catch (UserNoProfileException $unp) { common_log(LOG_INFO, "User {$this->nickname} has no profile; continuing deletion."); } @@ -696,15 +703,18 @@ class User extends Managed_DataObject function repeatedByMe($offset=0, $limit=20, $since_id=null, $max_id=null) { - $stream = new RepeatedByMeNoticeStream($this); + // FIXME: Use another way to get Profile::current() since we + // want to avoid confusion between session user and queue processing. + $stream = new RepeatedByMeNoticeStream($this->getProfile(), Profile::current()); return $stream->getNotices($offset, $limit, $since_id, $max_id); } function repeatsOfMe($offset=0, $limit=20, $since_id=null, $max_id=null) { - $stream = new RepeatsOfMeNoticeStream($this); - + // FIXME: Use another way to get Profile::current() since we + // want to avoid confusion between session user and queue processing. + $stream = new RepeatsOfMeNoticeStream($this->getProfile(), Profile::current()); return $stream->getNotices($offset, $limit, $since_id, $max_id); } @@ -868,6 +878,8 @@ class User extends Managed_DataObject static function recoverPassword($nore) { + require_once(INSTALLDIR . '/lib/mail.php'); + // $confirm_email will be used as a fallback if our user doesn't have a confirmed email $confirm_email = null; @@ -1019,6 +1031,29 @@ class User extends Managed_DataObject return $this->getProfile()->isPrivateStream(); } + public function hasPassword() + { + return !empty($this->password); + } + + public function setPassword($password) + { + $orig = clone($this); + $this->password = common_munge_password($password, $this->getProfile()); + + if ($this->validate() !== true) { + // TRANS: Form validation error on page where to change password. + throw new ServerException(_('Error saving user; invalid.')); + } + + if (!$this->update($orig)) { + common_log_db_error($this, 'UPDATE', __FILE__); + // TRANS: Server error displayed on page where to change password when password change + // TRANS: could not be made because of a server error. + throw new ServerException(_('Cannot save new password.')); + } + } + public function delPref($namespace, $topic) { return $this->getProfile()->delPref($namespace, $topic);