aboutsummaryrefslogtreecommitdiff
path: root/app/Controllers/feedController.php
diff options
context:
space:
mode:
authorGravatar Marien Fressinaud <dev@marienfressinaud.fr> 2015-01-31 14:45:37 +0100
committerGravatar Marien Fressinaud <dev@marienfressinaud.fr> 2015-01-31 14:45:37 +0100
commita97bbd9bd54c5fa56d54b3c214cf4e8af96af8b2 (patch)
tree6e83890bc1b3814a12c3b7bedc0d5944f30f507b /app/Controllers/feedController.php
parent42fd539a1b14f883077048a35864b4294b6efe94 (diff)
parente91b72b63cd11ae3c4f59e48439e93955242c673 (diff)
Merge branch 'dev'
Conflicts: CHANGELOG README.fr.md README.md app/Controllers/feedController.php app/Controllers/indexController.php app/i18n/en.php app/i18n/fr.php app/views/helpers/view/normal_view.phtml app/views/stats/index.phtml app/views/stats/repartition.phtml constants.php p/scripts/main.js
Diffstat (limited to 'app/Controllers/feedController.php')
-rwxr-xr-xapp/Controllers/feedController.php704
1 files changed, 388 insertions, 316 deletions
diff --git a/app/Controllers/feedController.php b/app/Controllers/feedController.php
index f75c969d9..6f544d834 100755
--- a/app/Controllers/feedController.php
+++ b/app/Controllers/feedController.php
@@ -1,180 +1,217 @@
<?php
+/**
+ * Controller to handle every feed actions.
+ */
class FreshRSS_feed_Controller extends Minz_ActionController {
- public function firstAction () {
- if (!$this->view->loginOk) {
+ /**
+ * This action is called before every other action in that class. It is
+ * the common boiler plate for every action. It is triggered by the
+ * underlying framework.
+ */
+ public function firstAction() {
+ if (!FreshRSS_Auth::hasAccess()) {
// Token is useful in the case that anonymous refresh is forbidden
// and CRON task cannot be used with php command so the user can
// set a CRON task to refresh his feeds by using token inside url
- $token = $this->view->conf->token;
- $token_param = Minz_Request::param ('token', '');
+ $token = FreshRSS_Context::$user_conf->token;
+ $token_param = Minz_Request::param('token', '');
$token_is_ok = ($token != '' && $token == $token_param);
- $action = Minz_Request::actionName ();
- if (!(($token_is_ok || Minz_Configuration::allowAnonymousRefresh()) &&
- $action === 'actualize')
- ) {
- Minz_Error::error (
- 403,
- array ('error' => array (Minz_Translate::t ('access_denied')))
- );
+ $action = Minz_Request::actionName();
+ $allow_anonymous_refresh = FreshRSS_Context::$system_conf->allow_anonymous_refresh;
+ if ($action !== 'actualize' ||
+ !($allow_anonymous_refresh || $token_is_ok)) {
+ Minz_Error::error(403);
}
}
}
- public function addAction () {
- $url = Minz_Request::param('url_rss', false);
+ /**
+ * This action subscribes to a feed.
+ *
+ * It can be reached by both GET and POST requests.
+ *
+ * GET request displays a form to add and configure a feed.
+ * Request parameter is:
+ * - url_rss (default: false)
+ *
+ * POST request adds a feed in database.
+ * Parameters are:
+ * - url_rss (default: false)
+ * - category (default: false)
+ * - new_category (required if category == 'nc')
+ * - http_user (default: false)
+ * - http_pass (default: false)
+ * It tries to get website information from RSS feed.
+ * If no category is given, feed is added to the default one.
+ *
+ * If url_rss is false, nothing happened.
+ */
+ public function addAction() {
+ $url = Minz_Request::param('url_rss');
if ($url === false) {
+ // No url, do nothing
Minz_Request::forward(array(
- 'c' => 'configure',
- 'a' => 'feed'
+ 'c' => 'subscription',
+ 'a' => 'index'
), true);
}
$feedDAO = FreshRSS_Factory::createFeedDao();
- $this->catDAO = new FreshRSS_CategoryDAO ();
- $this->catDAO->checkDefault ();
+ $this->catDAO = new FreshRSS_CategoryDAO();
+ $url_redirect = array(
+ 'c' => 'subscription',
+ 'a' => 'index',
+ 'params' => array(),
+ );
+
+ $limits = FreshRSS_Context::$system_conf->limits;
+ $this->view->feeds = $feedDAO->listFeeds();
+ if (count($this->view->feeds) >= $limits['max_feeds']) {
+ Minz_Request::bad(_t('feedback.sub.feed.over_max', $limits['max_feeds']),
+ $url_redirect);
+ }
if (Minz_Request::isPost()) {
@set_time_limit(300);
-
- $cat = Minz_Request::param ('category', false);
+ $cat = Minz_Request::param('category');
if ($cat === 'nc') {
- $new_cat = Minz_Request::param ('new_category');
+ // User want to create a new category, new_category parameter
+ // must exist
+ $new_cat = Minz_Request::param('new_category');
if (empty($new_cat['name'])) {
$cat = false;
} else {
$cat = $this->catDAO->addCategory($new_cat);
}
}
+
if ($cat === false) {
- $def_cat = $this->catDAO->getDefault ();
- $cat = $def_cat->id ();
+ // If category was not given or if creating new category failed,
+ // get the default category
+ $this->catDAO->checkDefault();
+ $def_cat = $this->catDAO->getDefault();
+ $cat = $def_cat->id();
}
- $user = Minz_Request::param ('http_user');
- $pass = Minz_Request::param ('http_pass');
- $params = array ();
+ // HTTP information are useful if feed is protected behind a
+ // HTTP authentication
+ $user = Minz_Request::param('http_user');
+ $pass = Minz_Request::param('http_pass');
+ $http_auth = '';
+ if ($user != '' || $pass != '') {
+ $http_auth = $user . ':' . $pass;
+ }
- $transactionStarted = false;
+ $transaction_started = false;
try {
- $feed = new FreshRSS_Feed ($url);
- $feed->_category ($cat);
-
- $httpAuth = '';
- if ($user != '' || $pass != '') {
- $httpAuth = $user . ':' . $pass;
- }
- $feed->_httpAuth ($httpAuth);
+ $feed = new FreshRSS_Feed($url);
+ } catch (FreshRSS_BadUrl_Exception $e) {
+ // Given url was not a valid url!
+ Minz_Log::warning($e->getMessage());
+ Minz_Request::bad(_t('feedback.sub.feed.invalid_url', $url), $url_redirect);
+ }
+ try {
$feed->load(true);
-
- $values = array (
- 'url' => $feed->url (),
- 'category' => $feed->category (),
- 'name' => $feed->name (),
- 'website' => $feed->website (),
- 'description' => $feed->description (),
- 'lastUpdate' => time (),
- 'httpAuth' => $feed->httpAuth (),
- );
-
- if ($feedDAO->searchByUrl ($values['url'])) {
- // on est déjà abonné à ce flux
- $notif = array (
- 'type' => 'bad',
- 'content' => Minz_Translate::t ('already_subscribed', $feed->name ())
- );
- Minz_Session::_param ('notification', $notif);
- } else {
- $id = $feedDAO->addFeed ($values);
- if (!$id) {
- // problème au niveau de la base de données
- $notif = array (
- 'type' => 'bad',
- 'content' => Minz_Translate::t ('feed_not_added', $feed->name ())
- );
- Minz_Session::_param ('notification', $notif);
- } else {
- $feed->_id ($id);
- $feed->faviconPrepare();
-
- $is_read = $this->view->conf->mark_when['reception'] ? 1 : 0;
-
- $entryDAO = FreshRSS_Factory::createEntryDao();
- $entries = array_reverse($feed->entries()); //We want chronological order and SimplePie uses reverse order
-
- // on calcule la date des articles les plus anciens qu'on accepte
- $nb_month_old = $this->view->conf->old_entries;
- $date_min = time () - (3600 * 24 * 30 * $nb_month_old);
-
- //MySQL: http://docs.oracle.com/cd/E17952_01/refman-5.5-en/optimizing-innodb-transaction-management.html
- //SQLite: http://stackoverflow.com/questions/1711631/how-do-i-improve-the-performance-of-sqlite
- $preparedStatement = $entryDAO->addEntryPrepare();
- $transactionStarted = true;
- $feedDAO->beginTransaction();
- // on ajoute les articles en masse sans vérification
- foreach ($entries as $entry) {
- $values = $entry->toArray();
- $values['id_feed'] = $feed->id();
- $values['id'] = min(time(), $entry->date(true)) . uSecString();
- $values['is_read'] = $is_read;
- $entryDAO->addEntry($values, $preparedStatement);
- }
- $feedDAO->updateLastUpdate($feed->id());
- if ($transactionStarted) {
- $feedDAO->commit();
- }
- $transactionStarted = false;
-
- // ok, ajout terminé
- $notif = array (
- 'type' => 'good',
- 'content' => Minz_Translate::t ('feed_added', $feed->name ())
- );
- Minz_Session::_param ('notification', $notif);
-
- // permet de rediriger vers la page de conf du flux
- $params['id'] = $feed->id ();
- }
- }
- } catch (FreshRSS_BadUrl_Exception $e) {
- Minz_Log::record ($e->getMessage (), Minz_Log::WARNING);
- $notif = array (
- 'type' => 'bad',
- 'content' => Minz_Translate::t ('invalid_url', $url)
- );
- Minz_Session::_param ('notification', $notif);
} catch (FreshRSS_Feed_Exception $e) {
- Minz_Log::record ($e->getMessage (), Minz_Log::WARNING);
- $notif = array (
- 'type' => 'bad',
- 'content' => Minz_Translate::t ('internal_problem_feed', Minz_Url::display(array('a' => 'logs')))
+ // Something went bad (timeout, server not found, etc.)
+ Minz_Log::warning($e->getMessage());
+ Minz_Request::bad(
+ _t('feedback.sub.feed.internal_problem', _url('index', 'logs')),
+ $url_redirect
);
- Minz_Session::_param ('notification', $notif);
} catch (Minz_FileNotExistException $e) {
- // Répertoire de cache n'existe pas
- Minz_Log::record ($e->getMessage (), Minz_Log::ERROR);
- $notif = array (
- 'type' => 'bad',
- 'content' => Minz_Translate::t ('internal_problem_feed', Minz_Url::display(array('a' => 'logs')))
+ // Cache directory doesn't exist!
+ Minz_Log::error($e->getMessage());
+ Minz_Request::bad(
+ _t('feedback.sub.feed.internal_problem', _url('index', 'logs')),
+ $url_redirect
);
- Minz_Session::_param ('notification', $notif);
}
- if ($transactionStarted) {
- $feedDAO->rollBack ();
+
+ if ($feedDAO->searchByUrl($feed->url())) {
+ Minz_Request::bad(
+ _t('feedback.sub.feed.already_subscribed', $feed->name()),
+ $url_redirect
+ );
+ }
+
+ $feed->_category($cat);
+ $feed->_httpAuth($http_auth);
+
+ // Call the extension hook
+ $name = $feed->name();
+ $feed = Minz_ExtensionManager::callHook('feed_before_insert', $feed);
+ if (is_null($feed)) {
+ Minz_Request::bad(_t('feed_not_added', $name), $url_redirect);
+ }
+
+ $values = array(
+ 'url' => $feed->url(),
+ 'category' => $feed->category(),
+ 'name' => $feed->name(),
+ 'website' => $feed->website(),
+ 'description' => $feed->description(),
+ 'lastUpdate' => time(),
+ 'httpAuth' => $feed->httpAuth(),
+ );
+
+ $id = $feedDAO->addFeed($values);
+ if (!$id) {
+ // There was an error in database... we cannot say what here.
+ Minz_Request::bad(_t('feedback.sub.feed.not_added', $feed->name()), $url_redirect);
+ }
+
+ // Ok, feed has been added in database. Now we have to refresh entries.
+ $feed->_id($id);
+ $feed->faviconPrepare();
+
+ $is_read = FreshRSS_Context::$user_conf->mark_when['reception'] ? 1 : 0;
+
+ $entryDAO = FreshRSS_Factory::createEntryDao();
+ // We want chronological order and SimplePie uses reverse order.
+ $entries = array_reverse($feed->entries());
+
+ // Calculate date of oldest entries we accept in DB.
+ $nb_month_old = FreshRSS_Context::$user_conf->old_entries;
+ $date_min = time() - (3600 * 24 * 30 * $nb_month_old);
+
+ // Use a shared statement and a transaction to improve a LOT the
+ // performances.
+ $prepared_statement = $entryDAO->addEntryPrepare();
+ $feedDAO->beginTransaction();
+ foreach ($entries as $entry) {
+ // Entries are added without any verification.
+ $entry->_feed($feed->id());
+ $entry->_id(min(time(), $entry->date(true)) . uSecString());
+ $entry->_isRead($is_read);
+
+ $entry = Minz_ExtensionManager::callHook('entry_before_insert', $entry);
+ if (is_null($entry)) {
+ // An extension has returned a null value, there is nothing to insert.
+ continue;
+ }
+
+ $values = $entry->toArray();
+ $entryDAO->addEntry($values, $prepared_statement);
}
+ $feedDAO->updateLastUpdate($feed->id());
+ $feedDAO->commit();
- Minz_Request::forward (array ('c' => 'configure', 'a' => 'feed', 'params' => $params), true);
+ // Entries are in DB, we redirect to feed configuration page.
+ $url_redirect['params']['id'] = $feed->id();
+ Minz_Request::good(_t('feedback.sub.feed.added', $feed->name()), $url_redirect);
} else {
+ // GET request: we must ask confirmation to user before adding feed.
+ Minz_View::prependTitle(_t('sub.feed.title_add') . ' · ');
- // GET request so we must ask confirmation to user
- Minz_View::prependTitle(Minz_Translate::t('add_rss_feed') . ' · ');
$this->view->categories = $this->catDAO->listCategories(false);
$this->view->feed = new FreshRSS_Feed($url);
try {
- // We try to get some more information about the feed
+ // We try to get more information about the feed.
$this->view->feed->load(true);
$this->view->load_ok = true;
} catch (Exception $e) {
@@ -183,256 +220,291 @@ class FreshRSS_feed_Controller extends Minz_ActionController {
$feed = $feedDAO->searchByUrl($this->view->feed->url());
if ($feed) {
- // Already subscribe so we redirect to the feed configuration page
- $notif = array(
- 'type' => 'bad',
- 'content' => Minz_Translate::t(
- 'already_subscribed', $feed->name()
- )
- );
- Minz_Session::_param('notification', $notif);
-
- Minz_Request::forward(array(
- 'c' => 'configure',
- 'a' => 'feed',
- 'params' => array(
- 'id' => $feed->id()
- )
- ), true);
+ // Already subscribe so we redirect to the feed configuration page.
+ $url_redirect['params']['id'] = $feed->id();
+ Minz_Request::good(_t('feedback.sub.feed.already_subscribed', $feed->name()), $url_redirect);
}
}
}
- public function truncateAction () {
- if (Minz_Request::isPost ()) {
- $id = Minz_Request::param ('id');
- $feedDAO = FreshRSS_Factory::createFeedDao();
- $n = $feedDAO->truncate($id);
- $notif = array(
- 'type' => $n === false ? 'bad' : 'good',
- 'content' => Minz_Translate::t ('n_entries_deleted', $n)
- );
- Minz_Session::_param ('notification', $notif);
- invalidateHttpCache();
- Minz_Request::forward (array ('c' => 'configure', 'a' => 'feed', 'params' => array('id' => $id)), true);
+ /**
+ * This action remove entries from a given feed.
+ *
+ * It should be reached by a POST action.
+ *
+ * Parameter is:
+ * - id (default: false)
+ */
+ public function truncateAction() {
+ $id = Minz_Request::param('id');
+ $url_redirect = array(
+ 'c' => 'subscription',
+ 'a' => 'index',
+ 'params' => array('id' => $id)
+ );
+
+ if (!Minz_Request::isPost()) {
+ Minz_Request::forward($url_redirect, true);
+ }
+
+ $feedDAO = FreshRSS_Factory::createFeedDao();
+ $n = $feedDAO->truncate($id);
+
+ invalidateHttpCache();
+ if ($n === false) {
+ Minz_Request::bad(_t('feedback.sub.feed.error'), $url_redirect);
+ } else {
+ Minz_Request::good(_t('feedback.sub.feed.n_entries_deleted', $n), $url_redirect);
}
}
- public function actualizeAction () {
+ /**
+ * This action actualizes entries from one or several feeds.
+ *
+ * Parameters are:
+ * - id (default: false)
+ * - force (default: false)
+ * If id is not specified, all the feeds are actualized. But if force is
+ * false, process stops at 10 feeds to avoid time execution problem.
+ */
+ public function actualizeAction() {
@set_time_limit(300);
$feedDAO = FreshRSS_Factory::createFeedDao();
$entryDAO = FreshRSS_Factory::createEntryDao();
Minz_Session::_param('actualize_feeds', false);
- $id = Minz_Request::param ('id');
- $force = Minz_Request::param ('force', false);
+ $id = Minz_Request::param('id');
+ $force = Minz_Request::param('force');
- // on créé la liste des flux à mettre à actualiser
- // si on veut mettre un flux à jour spécifiquement, on le met
- // dans la liste, mais seul (permet d'automatiser le traitement)
- $feeds = array ();
+ // Create a list of feeds to actualize.
+ // If id is set and valid, corresponding feed is added to the list but
+ // alone in order to automatize further process.
+ $feeds = array();
if ($id) {
- $feed = $feedDAO->searchById ($id);
+ $feed = $feedDAO->searchById($id);
if ($feed) {
- $feeds = array ($feed);
+ $feeds[] = $feed;
}
} else {
- $feeds = $feedDAO->listFeedsOrderUpdate($this->view->conf->ttl_default);
+ $feeds = $feedDAO->listFeedsOrderUpdate(FreshRSS_Context::$user_conf->ttl_default);
}
- // on calcule la date des articles les plus anciens qu'on accepte
- $nb_month_old = max($this->view->conf->old_entries, 1);
- $date_min = time () - (3600 * 24 * 30 * $nb_month_old);
+ // Calculate date of oldest entries we accept in DB.
+ $nb_month_old = max(FreshRSS_Context::$user_conf->old_entries, 1);
+ $date_min = time() - (3600 * 24 * 30 * $nb_month_old);
- $i = 0;
- $flux_update = 0;
- $is_read = $this->view->conf->mark_when['reception'] ? 1 : 0;
+ $updated_feeds = 0;
+ $is_read = FreshRSS_Context::$user_conf->mark_when['reception'] ? 1 : 0;
foreach ($feeds as $feed) {
if (!$feed->lock()) {
- Minz_Log::record('Feed already being actualized: ' . $feed->url(), Minz_Log::NOTICE);
+ Minz_Log::notice('Feed already being actualized: ' . $feed->url());
continue;
}
- try {
- $url = $feed->url();
- $feedHistory = $feed->keepHistory();
+ try {
+ // Load entries
$feed->load(false);
- $entries = array_reverse($feed->entries()); //We want chronological order and SimplePie uses reverse order
- $hasTransaction = false;
+ } catch (FreshRSS_Feed_Exception $e) {
+ Minz_Log::notice($e->getMessage());
+ $feedDAO->updateLastUpdate($feed->id(), 1);
+ $feed->unlock();
+ continue;
+ }
- if (count($entries) > 0) {
- //For this feed, check last n entry GUIDs already in database
- $existingGuids = array_fill_keys ($entryDAO->listLastGuidsByFeed ($feed->id (), count($entries) + 10), 1);
- $useDeclaredDate = empty($existingGuids);
+ $url = $feed->url();
+ $feed_history = $feed->keepHistory();
+ if ($feed_history == -2) {
+ // TODO: -2 must be a constant!
+ // -2 means we take the default value from configuration
+ $feed_history = FreshRSS_Context::$user_conf->keep_history_default;
+ }
- if ($feedHistory == -2) { //default
- $feedHistory = $this->view->conf->keep_history_default;
+ // We want chronological order and SimplePie uses reverse order.
+ $entries = array_reverse($feed->entries());
+ if (count($entries) > 0) {
+ // For this feed, check last n entry GUIDs already in database.
+ $existing_guids = array_fill_keys($entryDAO->listLastGuidsByFeed(
+ $feed->id(), count($entries) + 10
+ ), 1);
+ $use_declared_date = empty($existing_guids);
+
+ // Add entries in database if possible.
+ $prepared_statement = $entryDAO->addEntryPrepare();
+ $feedDAO->beginTransaction();
+ foreach ($entries as $entry) {
+ $entry_date = $entry->date(true);
+ if (isset($existing_guids[$entry->guid()]) ||
+ ($feed_history == 0 && $entry_date < $date_min)) {
+ // This entry already exists in DB or should not be added
+ // considering configuration and date.
+ continue;
}
- $preparedStatement = $entryDAO->addEntryPrepare();
- $hasTransaction = true;
- $feedDAO->beginTransaction();
-
- // On ne vérifie pas strictement que l'article n'est pas déjà en BDD
- // La BDD refusera l'ajout car (id_feed, guid) doit être unique
- foreach ($entries as $entry) {
- $eDate = $entry->date(true);
- if ((!isset($existingGuids[$entry->guid()])) &&
- (($feedHistory != 0) || ($eDate >= $date_min))) {
- $values = $entry->toArray();
- //Use declared date at first import, otherwise use discovery date
- $values['id'] = ($useDeclaredDate || $eDate < $date_min) ?
- min(time(), $eDate) . uSecString() :
- uTimeString();
- $values['is_read'] = $is_read;
- $entryDAO->addEntry($values, $preparedStatement);
- }
+ $id = uTimeString();
+ if ($use_declared_date || $entry_date < $date_min) {
+ // Use declared date at first import.
+ $id = min(time(), $entry_date) . uSecString();
}
- }
- if (($feedHistory >= 0) && (rand(0, 30) === 1)) {
- if (!$hasTransaction) {
- $feedDAO->beginTransaction();
- }
- $nb = $feedDAO->cleanOldEntries ($feed->id (), $date_min, max($feedHistory, count($entries) + 10));
- if ($nb > 0) {
- Minz_Log::record ($nb . ' old entries cleaned in feed [' . $feed->url() . ']', Minz_Log::DEBUG);
+ $entry->_id($id);
+ $entry->_isRead($is_read);
+
+ $entry = Minz_ExtensionManager::callHook('entry_before_insert', $entry);
+ if (is_null($entry)) {
+ // An extension has returned a null value, there is nothing to insert.
+ continue;
}
+
+ $values = $entry->toArray();
+ $entryDAO->addEntry($values, $prepared_statement);
}
+ }
- // on indique que le flux vient d'être mis à jour en BDD
- $feedDAO->updateLastUpdate ($feed->id (), 0, $hasTransaction);
- if ($hasTransaction) {
- $feedDAO->commit();
+ if ($feed_history >= 0 && rand(0, 30) === 1) {
+ // TODO: move this function in web cron when available (see entry::purge)
+ // Remove old entries once in 30.
+ if (!$feedDAO->hasTransaction()) {
+ $feedDAO->beginTransaction();
}
- $flux_update++;
- if (($feed->url() !== $url)) { //HTTP 301 Moved Permanently
- Minz_Log::record('Feed ' . $url . ' moved permanently to ' . $feed->url(), Minz_Log::NOTICE);
- $feedDAO->updateFeed($feed->id(), array('url' => $feed->url()));
+
+ $nb = $feedDAO->cleanOldEntries($feed->id(),
+ $date_min,
+ max($feed_history, count($entries) + 10));
+ if ($nb > 0) {
+ Minz_Log::debug($nb . ' old entries cleaned in feed [' .
+ $feed->url() . ']');
}
- } catch (FreshRSS_Feed_Exception $e) {
- Minz_Log::record ($e->getMessage (), Minz_Log::NOTICE);
- $feedDAO->updateLastUpdate ($feed->id (), 1);
+ }
+
+ $feedDAO->updateLastUpdate($feed->id(), 0, $feedDAO->hasTransaction());
+ if ($feedDAO->hasTransaction()) {
+ $feedDAO->commit();
+ }
+
+ if ($feed->url() !== $url) {
+ // HTTP 301 Moved Permanently
+ Minz_Log::notice('Feed ' . $url . ' moved permanently to ' . $feed->url());
+ $feedDAO->updateFeed($feed->id(), array('url' => $feed->url()));
}
$feed->faviconPrepare();
$feed->unlock();
+ $updated_feeds++;
unset($feed);
- // On arrête à 10 flux pour ne pas surcharger le serveur
- // sauf si le paramètre $force est à vrai
- $i++;
- if ($i >= 10 && !$force) {
+ // No more than 10 feeds unless $force is true to avoid overloading
+ // the server.
+ if ($updated_feeds >= 10 && !$force) {
break;
}
}
- $url = array ();
- if ($flux_update === 1) {
- // on a mis un seul flux à jour
- $feed = reset ($feeds);
- $notif = array (
- 'type' => 'good',
- 'content' => Minz_Translate::t ('feed_actualized', $feed->name ())
- );
- } elseif ($flux_update > 1) {
- // plusieurs flux on été mis à jour
- $notif = array (
+ if (Minz_Request::param('ajax')) {
+ // Most of the time, ajax request is for only one feed. But since
+ // there are several parallel requests, we should return that there
+ // are several updated feeds.
+ $notif = array(
'type' => 'good',
- 'content' => Minz_Translate::t ('n_feeds_actualized', $flux_update)
+ 'content' => _t('feedback.sub.feed.actualizeds')
);
+ Minz_Session::_param('notification', $notif);
+ // No layout in ajax request.
+ $this->view->_useLayout(false);
+ return;
+ }
+
+ // Redirect to the main page with correct notification.
+ if ($updated_feeds === 1) {
+ $feed = reset($feeds);
+ Minz_Request::good(_t('feedback.sub.feed.actualized', $feed->name()), array(
+ 'params' => array('get' => 'f_' . $feed->id())
+ ));
+ } elseif ($updated_feeds > 1) {
+ Minz_Request::good(_t('feedback.sub.feed.n_actualized', $updated_feeds), array());
} else {
- // aucun flux n'a été mis à jour, oups
- $notif = array (
- 'type' => 'good',
- 'content' => Minz_Translate::t ('no_feed_to_refresh')
- );
+ Minz_Request::good(_t('feedback.sub.feed.no_refresh'), array());
+ }
+ }
+
+ /**
+ * This action changes the category of a feed.
+ *
+ * This page must be reached by a POST request.
+ *
+ * Parameters are:
+ * - f_id (default: false)
+ * - c_id (default: false)
+ * If c_id is false, default category is used.
+ *
+ * @todo should handle order of the feed inside the category.
+ */
+ public function moveAction() {
+ if (!Minz_Request::isPost()) {
+ Minz_Request::forward(array('c' => 'subscription'), true);
}
- if ($i === 1) {
- // Si on a voulu mettre à jour qu'un flux
- // on filtre l'affichage par ce flux
- $feed = reset ($feeds);
- $url['params'] = array ('get' => 'f_' . $feed->id ());
+ $feed_id = Minz_Request::param('f_id');
+ $cat_id = Minz_Request::param('c_id');
+
+ if ($cat_id === false) {
+ // If category was not given get the default one.
+ $catDAO = new FreshRSS_CategoryDAO();
+ $catDAO->checkDefault();
+ $def_cat = $catDAO->getDefault();
+ $cat_id = $def_cat->id();
}
- if (Minz_Request::param ('ajax', 0) === 0) {
- Minz_Session::_param ('notification', $notif);
- Minz_Request::forward ($url, true);
+ $feedDAO = FreshRSS_Factory::createFeedDao();
+ $values = array('category' => $cat_id);
+
+ $feed = $feedDAO->searchById($feed_id);
+ if ($feed && ($feed->category() == $cat_id ||
+ $feedDAO->updateFeed($feed_id, $values))) {
+ // TODO: return something useful
} else {
- // Une requête Ajax met un seul flux à jour.
- // Comme en principe plusieurs requêtes ont lieu,
- // on indique que "plusieurs flux ont été mis à jour".
- // Cela permet d'avoir une notification plus proche du
- // ressenti utilisateur
- $notif = array (
- 'type' => 'good',
- 'content' => Minz_Translate::t ('feeds_actualized')
- );
- Minz_Session::_param ('notification', $notif);
- // et on désactive le layout car ne sert à rien
- $this->view->_useLayout (false);
+ Minz_Log::warning('Cannot move feed `' . $feed_id . '` ' .
+ 'in the category `' . $cat_id . '`');
+ Minz_Error::error(404);
}
}
- public function deleteAction () {
- if (Minz_Request::isPost ()) {
- $type = Minz_Request::param ('type', 'feed');
- $id = Minz_Request::param ('id');
-
- $feedDAO = FreshRSS_Factory::createFeedDao();
- if ($type == 'category') {
- // List feeds to remove then related user queries.
- $feeds = $feedDAO->listByCategory($id);
+ /**
+ * This action deletes a feed.
+ *
+ * This page must be reached by a POST request.
+ * If there are related queries, they are deleted too.
+ *
+ * Parameters are:
+ * - id (default: false)
+ * - r (default: false)
+ * r permits to redirect to a given page at the end of this action.
+ *
+ * @todo handle "r" redirection in Minz_Request::forward()?
+ */
+ public function deleteAction() {
+ $redirect_url = Minz_Request::param('r', false, true);
+ if (!$redirect_url) {
+ $redirect_url = array('c' => 'subscription', 'a' => 'index');
+ }
- if ($feedDAO->deleteFeedByCategory ($id)) {
- // Remove related queries
- foreach ($feeds as $feed) {
- $this->view->conf->remove_query_by_get('f_' . $feed->id());
- }
- $this->view->conf->save();
+ if (!Minz_Request::isPost()) {
+ Minz_Request::forward($redirect_url, true);
+ }
- $notif = array (
- 'type' => 'good',
- 'content' => Minz_Translate::t ('category_emptied')
- );
- //TODO: Delete old favicons
- } else {
- $notif = array (
- 'type' => 'bad',
- 'content' => Minz_Translate::t ('error_occured')
- );
- }
- } else {
- if ($feedDAO->deleteFeed ($id)) {
- // Remove related queries
- $this->view->conf->remove_query_by_get('f_' . $id);
- $this->view->conf->save();
-
- $notif = array (
- 'type' => 'good',
- 'content' => Minz_Translate::t ('feed_deleted')
- );
- //TODO: Delete old favicon
- } else {
- $notif = array (
- 'type' => 'bad',
- 'content' => Minz_Translate::t ('error_occured')
- );
- }
- }
+ $id = Minz_Request::param('id');
+ $feedDAO = FreshRSS_Factory::createFeedDao();
+ if ($feedDAO->deleteFeed($id)) {
+ // TODO: Delete old favicon
- Minz_Session::_param ('notification', $notif);
+ // Remove related queries
+ FreshRSS_Context::$user_conf->queries = remove_query_by_get(
+ 'f_' . $id, FreshRSS_Context::$user_conf->queries);
+ FreshRSS_Context::$user_conf->save();
- $redirect_url = Minz_Request::param('r', false, true);
- if ($redirect_url) {
- Minz_Request::forward($redirect_url);
- } elseif ($type == 'category') {
- Minz_Request::forward(array ('c' => 'configure', 'a' => 'categorize'), true);
- } else {
- Minz_Request::forward(array ('c' => 'configure', 'a' => 'feed'), true);
- }
+ Minz_Request::good(_t('feedback.sub.feed.deleted'), $redirect_url);
+ } else {
+ Minz_Request::bad(_t('feedback.sub.feed.error'), $redirect_url);
}
}
}