Revert "remove the Repeat plugin (for now)"
This reverts commit c10fa99b04.
This commit is contained in:
Evan Prodromou
parent
c10fa99b04
commit
2c9b30a31b
|
|
@ -0,0 +1,127 @@
|
|||
<?php
|
||||
/*
|
||||
* StatusNet - the distributed open-source microblogging tool
|
||||
* Copyright (C) 2009, StatusNet, Inc.
|
||||
*
|
||||
* 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/>.
|
||||
*/
|
||||
|
||||
if (!defined('STATUSNET')) {
|
||||
exit(1);
|
||||
}
|
||||
|
||||
/**
|
||||
* Table Definition for location_namespace
|
||||
*/
|
||||
|
||||
require_once INSTALLDIR.'/classes/Memcached_DataObject.php';
|
||||
|
||||
class Forward extends Memcached_DataObject
|
||||
{
|
||||
###START_AUTOCODE
|
||||
/* the code below is auto generated do not remove the above tag */
|
||||
|
||||
public $__table = 'forward'; // table name
|
||||
public $profile_id; // int(4) primary_key not_null
|
||||
public $notice_id; // int(4) primary_key not_null
|
||||
public $created; // datetime not_null default_0000-00-00%2000%3A00%3A00
|
||||
|
||||
/* Static get */
|
||||
function staticGet($k,$v=NULL) { return Memcached_DataObject::staticGet('Forward',$k,$v); }
|
||||
|
||||
/* the code above is auto generated do not remove the tag below */
|
||||
###END_AUTOCODE
|
||||
|
||||
function &pkeyGet($kv)
|
||||
{
|
||||
return Memcached_DataObject::pkeyGet('Forward', $kv);
|
||||
}
|
||||
|
||||
static function saveNew($profile_id, $notice_id)
|
||||
{
|
||||
$forward = new Forward();
|
||||
|
||||
$forward->profile_id = $profile_id;
|
||||
$forward->notice_id = $notice_id;
|
||||
$forward->created = common_sql_now();
|
||||
|
||||
$forward->query('BEGIN');
|
||||
|
||||
if (!$forward->insert()) {
|
||||
throw new ServerException(_("Couldn't insert forward."));
|
||||
}
|
||||
|
||||
$ni = $forward->addToInboxes();
|
||||
|
||||
$forward->query('COMMIT');
|
||||
|
||||
$forward->blowCache($ni);
|
||||
|
||||
return $forward;
|
||||
}
|
||||
|
||||
function addToInboxes()
|
||||
{
|
||||
$inbox = new Notice_inbox();
|
||||
|
||||
$user = new User();
|
||||
|
||||
$usertable = common_database_tablename('user');
|
||||
$user->query("SELECT $usertable.* FROM $usertable INNER JOIN subscription ON $usertable.id = subscription.subscriber ".
|
||||
'WHERE subscription.subscribed = '.$this->profile_id);
|
||||
|
||||
$ni = array();
|
||||
|
||||
$notice = Notice::staticGet('id', $this->notice_id);
|
||||
|
||||
$author = Profile::staticGet('id', $notice->profile_id);
|
||||
|
||||
while ($user->fetch()) {
|
||||
$inbox = Notice_inbox::pkeyGet(array('user_id' => $user->id,
|
||||
'notice_id' => $this->notice_id));
|
||||
|
||||
if (empty($inbox)) {
|
||||
if (!$user->hasBlocked($author)) {
|
||||
$ni[$user->id] = NOTICE_INBOX_SOURCE_FORWARD;
|
||||
}
|
||||
} else {
|
||||
$inbox->free();
|
||||
}
|
||||
}
|
||||
|
||||
$user->free();
|
||||
$author->free();
|
||||
|
||||
unset($user);
|
||||
unset($author);
|
||||
|
||||
Notice_inbox::bulkInsert($this->notice_id, $this->created, $ni);
|
||||
|
||||
return $ni;
|
||||
}
|
||||
|
||||
function blowCache($ni)
|
||||
{
|
||||
$cache = common_memcache();
|
||||
|
||||
if (!empty($cache)) {
|
||||
foreach ($ni as $id => $source) {
|
||||
$cache->delete(common_cache_key('notice_inbox:by_user:'.$id));
|
||||
$cache->delete(common_cache_key('notice_inbox:by_user_own:'.$id));
|
||||
$cache->delete(common_cache_key('notice_inbox:by_user:'.$id.';last'));
|
||||
$cache->delete(common_cache_key('notice_inbox:by_user_own:'.$id.';last'));
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,122 @@
|
|||
<?php
|
||||
|
||||
/**
|
||||
* Forward action.
|
||||
*
|
||||
* PHP version 5
|
||||
*
|
||||
* @category Action
|
||||
* @package StatusNet
|
||||
* @author Evan Prodromou <evan@status.net>
|
||||
* @license http://www.fsf.org/licensing/licenses/agpl.html AGPLv3
|
||||
* @link http://status.net/
|
||||
*
|
||||
* StatusNet - the distributed open-source microblogging tool
|
||||
* Copyright (C) 2008, 2009, StatusNet, Inc.
|
||||
*
|
||||
* 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/>.
|
||||
*/
|
||||
|
||||
if (!defined('STATUSNET')) {
|
||||
exit(1);
|
||||
}
|
||||
|
||||
/**
|
||||
* Forward action
|
||||
*
|
||||
* @category Action
|
||||
* @package StatusNet
|
||||
* @author Evan Prodromou <evan@status.net>
|
||||
* @license http://www.fsf.org/licensing/licenses/agpl.html AGPLv3
|
||||
* @link http://status.net/
|
||||
*/
|
||||
|
||||
class ForwardAction extends Action
|
||||
{
|
||||
var $user = null;
|
||||
var $notice = null;
|
||||
|
||||
function prepare($args)
|
||||
{
|
||||
parent::prepare($args);
|
||||
|
||||
$this->user = common_current_user();
|
||||
|
||||
if (empty($this->user)) {
|
||||
$this->clientError(_("Only logged-in users can forward notices."));
|
||||
return false;
|
||||
}
|
||||
|
||||
$id = $this->trimmed('notice');
|
||||
|
||||
if (empty($id)) {
|
||||
$this->clientError(_("No notice specified."));
|
||||
return false;
|
||||
}
|
||||
|
||||
$this->notice = Notice::staticGet('id', $id);
|
||||
|
||||
if (empty($this->notice)) {
|
||||
$this->clientError(_("No notice specified."));
|
||||
return false;
|
||||
}
|
||||
|
||||
if ($this->user->id == $this->notice->profile_id) {
|
||||
$this->clientError(_("You can't forward your own notice."));
|
||||
return false;
|
||||
}
|
||||
|
||||
$token = $this->trimmed('token-'.$id);
|
||||
|
||||
if (empty($token) || $token != common_session_token()) {
|
||||
$this->clientError(_("There was a problem with your session token. Try again, please."));
|
||||
return false;
|
||||
}
|
||||
|
||||
$profile = $this->user->getProfile();
|
||||
|
||||
if ($profile->hasForwarded($id)) {
|
||||
$this->clientError(_("You already forwarded that notice."));
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
/**
|
||||
* Class handler.
|
||||
*
|
||||
* @param array $args query arguments
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
|
||||
function handle($args)
|
||||
{
|
||||
$forward = Forward::saveNew($this->user->id, $this->notice->id);
|
||||
|
||||
if ($this->boolean('ajax')) {
|
||||
$this->startHTML('text/xml;charset=utf-8');
|
||||
$this->elementStart('head');
|
||||
$this->element('title', null, _('Forwarded'));
|
||||
$this->elementEnd('head');
|
||||
$this->elementStart('body');
|
||||
$this->element('p', array('id' => 'forward_response'), _('Forwarded!'));
|
||||
$this->elementEnd('body');
|
||||
$this->elementEnd('html');
|
||||
} else {
|
||||
// FIXME!
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,147 @@
|
|||
<?php
|
||||
/**
|
||||
* StatusNet, the distributed open-source microblogging tool
|
||||
*
|
||||
* Form for forwarding a notice
|
||||
*
|
||||
* PHP version 5
|
||||
*
|
||||
* LICENCE: 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 Form
|
||||
* @package StatusNet
|
||||
* @author Evan Prodromou <evan@status.net>
|
||||
* @copyright 2009 StatusNet, Inc.
|
||||
* @license http://www.fsf.org/licensing/licenses/agpl-3.0.html GNU Affero General Public License version 3.0
|
||||
* @link http://status.net/
|
||||
*/
|
||||
|
||||
if (!defined('STATUSNET') && !defined('LACONICA')) {
|
||||
exit(1);
|
||||
}
|
||||
|
||||
require_once INSTALLDIR.'/lib/form.php';
|
||||
|
||||
/**
|
||||
* Form for forwarding a notice
|
||||
*
|
||||
* @category Form
|
||||
* @package StatusNet
|
||||
* @author Evan Prodromou <evan@status.net>
|
||||
* @license http://www.fsf.org/licensing/licenses/agpl-3.0.html GNU Affero General Public License version 3.0
|
||||
* @link http://status.net/
|
||||
*/
|
||||
|
||||
class ForwardForm extends Form
|
||||
{
|
||||
/**
|
||||
* Notice to forward
|
||||
*/
|
||||
|
||||
var $notice = null;
|
||||
|
||||
/**
|
||||
* Constructor
|
||||
*
|
||||
* @param HTMLOutputter $out output channel
|
||||
* @param Notice $notice notice to forward
|
||||
*/
|
||||
|
||||
function __construct($out=null, $notice=null)
|
||||
{
|
||||
parent::__construct($out);
|
||||
|
||||
$this->notice = $notice;
|
||||
}
|
||||
|
||||
/**
|
||||
* ID of the form
|
||||
*
|
||||
* @return int ID of the form
|
||||
*/
|
||||
|
||||
function id()
|
||||
{
|
||||
return 'forward-' . $this->notice->id;
|
||||
}
|
||||
|
||||
/**
|
||||
* Action of the form
|
||||
*
|
||||
* @return string URL of the action
|
||||
*/
|
||||
|
||||
function action()
|
||||
{
|
||||
return common_local_url('forward');
|
||||
}
|
||||
|
||||
/**
|
||||
* Include a session token for CSRF protection
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
|
||||
function sessionToken()
|
||||
{
|
||||
$this->out->hidden('token-' . $this->notice->id,
|
||||
common_session_token());
|
||||
}
|
||||
|
||||
/**
|
||||
* Legend of the Form
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
function formLegend()
|
||||
{
|
||||
$this->out->element('legend', null, _('Forward this notice'));
|
||||
}
|
||||
|
||||
/**
|
||||
* Data elements
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
|
||||
function formData()
|
||||
{
|
||||
$this->out->hidden('notice-n'.$this->notice->id,
|
||||
$this->notice->id,
|
||||
'notice');
|
||||
}
|
||||
|
||||
/**
|
||||
* Action elements
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
|
||||
function formActions()
|
||||
{
|
||||
$this->out->submit('forward-submit-' . $this->notice->id,
|
||||
_('Forward'), 'submit', null, _('Forward this notice'));
|
||||
}
|
||||
|
||||
/**
|
||||
* Class of the form.
|
||||
*
|
||||
* @return string the form's class
|
||||
*/
|
||||
|
||||
function formClass()
|
||||
{
|
||||
return 'form_forward';
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,85 @@
|
|||
<?php
|
||||
|
||||
class InboxNoticeList extends NoticeList
|
||||
{
|
||||
var $owner = null;
|
||||
|
||||
function __construct($notice, $owner, $out=null)
|
||||
{
|
||||
parent::__construct($notice, $out);
|
||||
$this->owner = $owner;
|
||||
}
|
||||
|
||||
function newListItem($notice)
|
||||
{
|
||||
return new InboxNoticeListItem($notice, $this->owner, $this->out);
|
||||
}
|
||||
}
|
||||
|
||||
class InboxNoticeListItem extends NoticeListItem
|
||||
{
|
||||
var $owner = null;
|
||||
var $ib = null;
|
||||
|
||||
function __construct($notice, $owner, $out=null)
|
||||
{
|
||||
parent::__construct($notice, $out);
|
||||
$this->owner = $owner;
|
||||
|
||||
$this->ib = Notice_inbox::pkeyGet(array('user_id' => $owner->id,
|
||||
'notice_id' => $notice->id));
|
||||
}
|
||||
|
||||
function showAuthor()
|
||||
{
|
||||
parent::showAuthor();
|
||||
if ($this->ib->source == NOTICE_INBOX_SOURCE_FORWARD) {
|
||||
$this->out->element('span', 'forward', _('Fwd'));
|
||||
}
|
||||
}
|
||||
|
||||
function showEnd()
|
||||
{
|
||||
if ($this->ib->source == NOTICE_INBOX_SOURCE_FORWARD) {
|
||||
|
||||
$forward = new Forward();
|
||||
|
||||
// FIXME: scary join!
|
||||
|
||||
$forward->query('SELECT profile_id '.
|
||||
'FROM forward JOIN subscription ON forward.profile_id = subscription.subscribed '.
|
||||
'WHERE subscription.subscriber = ' . $this->owner->id . ' '.
|
||||
'AND forward.notice_id = ' . $this->notice->id . ' '.
|
||||
'ORDER BY forward.created ');
|
||||
|
||||
$n = 0;
|
||||
|
||||
$firstForwarder = null;
|
||||
|
||||
while ($forward->fetch()) {
|
||||
if (empty($firstForwarder)) {
|
||||
$firstForwarder = Profile::staticGet('id', $forward->profile_id);
|
||||
}
|
||||
$n++;
|
||||
}
|
||||
|
||||
$forward->free();
|
||||
unset($forward);
|
||||
|
||||
$this->out->elementStart('span', 'forwards');
|
||||
|
||||
$link = XMLStringer::estring('a', array('href' => $firstForwarder->profileurl),
|
||||
$firstForwarder->nickname);
|
||||
|
||||
if ($n == 1) {
|
||||
$this->out->raw(sprintf(_('Forwarded by %s'), $link));
|
||||
} else {
|
||||
// XXX: use that cool ngettext thing
|
||||
$this->out->raw(sprintf(_('Forwarded by %s and %d other(s)'), $link, $n - 1));
|
||||
}
|
||||
|
||||
$this->out->elementEnd('span');
|
||||
}
|
||||
parent::showEnd();
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue