remove the Repeat plugin (for now)
This commit is contained in:
Evan Prodromou
parent
f3628afa00
commit
c10fa99b04
@ -1,127 +0,0 @@
|
|||||||
<?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'));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,122 +0,0 @@
|
|||||||
<?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!
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,147 +0,0 @@
|
|||||||
<?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';
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,85 +0,0 @@
|
|||||||
<?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
Block a user