123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117 |
- <?php
- /*
- * StatusNet - the distributed open-source microblogging tool
- *
- * Handler for reminder queue items which send reminder emails to all users
- * we would like to complete a given process (e.g.: registration).
- *
- * This program is free software: you can redistribute it and/or modify
- * it under the terms of the GNU Affero General Public License as published by
- * the Free Software Foundation, either version 3 of the License, or
- * (at your option) any later version.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU Affero General Public License for more details.
- *
- * You should have received a copy of the GNU Affero General Public License
- * along with this program. If not, see <http://www.gnu.org/licenses/>.
- *
- * @category Email
- * @package StatusNet
- * @author Zach Copley <zach@status.net>
- * @copyright 2011 StatusNet, Inc.
- * @license http://www.fsf.org/licensing/licenses/agpl-3.0.html AGPL 3.0
- * @link http://status.net/
- */
- if (!defined('STATUSNET')) {
- exit(1);
- }
- /**
- * Handler for reminder queue items which send reminder emails to all users
- * we would like to complete a given process (e.g.: registration)
- *
- * @category Email
- * @package StatusNet
- * @author Zach Copley <zach@status.net>
- * @copyright 2011 StatusNet, Inc.
- * @license http://www.fsf.org/licensing/licenses/agpl-3.0.html AGPL 3.0
- * @link http://status.net/
- */
- class SiteConfirmReminderHandler extends QueueHandler
- {
- /**
- * Return transport keyword which identifies items this queue handler
- * services; must be defined for all subclasses.
- *
- * Must be 8 characters or less to fit in the queue_item database.
- * ex "email", "jabber", "sms", "irc", ...
- *
- * @return string
- */
- function transport()
- {
- return 'siterem';
- }
- /**
- * Handle the site
- *
- * @param array $remitem type of reminder to send and any special options
- * @return boolean true on success, false on failure
- */
- function handle($remitem)
- {
- list($type, $opts) = $remitem;
- $qm = QueueManager::get();
- try {
- switch($type) {
- case UserConfirmRegReminderHandler::REGISTER_REMINDER:
- $confirm = new Confirm_address();
- $confirm->address_type = $type;
- $confirm->find();
- while ($confirm->fetch()) {
- try {
- $qm->enqueue(array($confirm, $opts), 'uregrem');
- } catch (Exception $e) {
- common_log(LOG_WARNING, $e->getMessage());
- continue;
- }
- }
- break;
- case UserInviteReminderHandler::INVITE_REMINDER:
- $invitation = new Invitation();
- // Only send one reminder (the latest one), regardless of how many invitations a user has
- $sql = 'SELECT * FROM (SELECT * FROM invitation WHERE registered_user_id IS NULL ORDER BY created DESC) invitees GROUP BY invitees.address';
- $invitation->query($sql);
- while ($invitation->fetch()) {
- try {
- $qm->enqueue(array($invitation, $opts), 'uinvrem');
- } catch (Exception $e) {
- common_log(LOG_WARNING, $e->getMessage());
- continue;
- }
- }
- break;
- default:
- // WTF?
- common_log(
- LOG_ERR,
- "Received unknown confirmation address type",
- __FILE__
- );
- }
- } catch (Exception $e) {
- common_log(LOG_ERR, $e->getMessage());
- return false;
- }
- return true;
- }
- }
|