aboutsummaryrefslogtreecommitdiff
path: root/app/controllers/feedController.php
diff options
context:
space:
mode:
Diffstat (limited to 'app/controllers/feedController.php')
-rwxr-xr-xapp/controllers/feedController.php376
1 files changed, 207 insertions, 169 deletions
diff --git a/app/controllers/feedController.php b/app/controllers/feedController.php
index c67609d57..77f1787d0 100755
--- a/app/controllers/feedController.php
+++ b/app/controllers/feedController.php
@@ -2,94 +2,114 @@
class feedController extends ActionController {
public function firstAction () {
+ if (login_is_conf ($this->view->conf) && !is_logged ()) {
+ Error::error (
+ 403,
+ array ('error' => array (Translate::t ('access_denied')))
+ );
+ }
+
$catDAO = new CategoryDAO ();
$catDAO->checkDefault ();
}
public function addAction () {
- if (login_is_conf ($this->view->conf) && !is_logged ()) {
- Error::error (
- 403,
- array ('error' => array ('Vous n\'avez pas le droit d\'accéder à cette page'))
- );
- } else {
- if (Request::isPost ()) {
- $url = Request::param ('url_rss');
- $cat = Request::param ('category');
- $params = array ();
-
- try {
- $feed = new Feed ($url);
- $feed->_category ($cat);
- $feed->load ();
-
- $feedDAO = new FeedDAO ();
- $values = array (
- 'id' => $feed->id (),
- 'url' => $feed->url (),
- 'category' => $feed->category (),
- 'name' => $feed->name (),
- 'website' => $feed->website (),
- 'description' => $feed->description (),
- 'lastUpdate' => time ()
- );
+ if (Request::isPost ()) {
+ $url = Request::param ('url_rss');
+ $cat = Request::param ('category');
+ $user = Request::param ('username');
+ $pass = Request::param ('password');
+ $params = array ();
- if ($feedDAO->searchByUrl ($values['url'])) {
- $notif = array (
- 'type' => 'bad',
- 'content' => 'Vous êtes déjà abonné à <em>' . $feed->name () . '</em>'
- );
- Session::_param ('notification', $notif);
- } elseif ($feedDAO->addFeed ($values)) {
- $entryDAO = new EntryDAO ();
- $entries = $feed->entries ();
-
- foreach ($entries as $entry) {
- $values = $entry->toArray ();
- $entryDAO->addEntry ($values);
- }
+ try {
+ $feed = new Feed ($url);
+ $feed->_category ($cat);
- // notif
- $notif = array (
- 'type' => 'good',
- 'content' => 'Le flux <em>' . $feed->name () . '</em> a bien été ajouté'
- );
- Session::_param ('notification', $notif);
- $params['id'] = $feed->id ();
- } else {
- // notif
- $notif = array (
- 'type' => 'bad',
- 'content' => '<em>' . $feed->name () . '</em> n\' a pas pu être ajouté'
- );
- Session::_param ('notification', $notif);
- }
- } catch (FeedException $e) {
- Log::record ($e->getMessage (), Log::ERROR);
+ $httpAuth = '';
+ if ($user != '' || $pass != '') {
+ $httpAuth = $user . ':' . $pass;
+ }
+ $feed->_httpAuth ($httpAuth);
+
+ $feed->load ();
+
+ $feedDAO = new FeedDAO ();
+ $values = array (
+ 'id' => $feed->id (),
+ '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' => 'Un problème interne a été rencontré, le flux n\'a pas pu être ajouté'
+ 'content' => Translate::t ('already_subscribed', $feed->name ())
);
Session::_param ('notification', $notif);
- } catch (FileNotExistException $e) {
- Log::record ($e->getMessage (), Log::ERROR);
- // notif
+ } elseif (!$feedDAO->addFeed ($values)) {
+ // problème au niveau de la base de données
$notif = array (
'type' => 'bad',
- 'content' => 'Un problème de configuration a empêché l\'ajout du flux. Voir les logs pour plus d\'informations'
+ 'content' => Translate::t ('feed_not_added', $feed->name ())
);
Session::_param ('notification', $notif);
- } catch (Exception $e) {
- // notif
+ } else {
+ $entryDAO = new EntryDAO ();
+ $entries = $feed->entries ();
+
+ // on calcule la date des articles les plus anciens qu'on accepte
+ $nb_month_old = $this->view->conf->oldEntries ();
+ $date_min = time () - (60 * 60 * 24 * 30 * $nb_month_old);
+
+ // on ajoute les articles en masse sans vérification
+ foreach ($entries as $entry) {
+ if ($entry->date (true) >= $date_min) {
+ $values = $entry->toArray ();
+ $entryDAO->addEntry ($values);
+ }
+ }
+
+ // ok, ajout terminé
$notif = array (
- 'type' => 'bad',
- 'content' => 'L\'url <em>' . $url . '</em> est invalide'
+ 'type' => 'good',
+ 'content' => Translate::t ('feed_added', $feed->name ())
);
Session::_param ('notification', $notif);
- }
- Request::forward (array ('c' => 'configure', 'a' => 'feed', 'params' => $params), true);
+ // permet de rediriger vers la page de conf du flux
+ $params['id'] = $feed->id ();
+ }
+ } catch (BadUrlException $e) {
+ Log::record ($e->getMessage (), Log::ERROR);
+ $notif = array (
+ 'type' => 'bad',
+ 'content' => Translate::t ('invalid_url', $url)
+ );
+ Session::_param ('notification', $notif);
+ } catch (FeedException $e) {
+ Log::record ($e->getMessage (), Log::ERROR);
+ $notif = array (
+ 'type' => 'bad',
+ 'content' => Translate::t ('internal_problem_feed')
+ );
+ Session::_param ('notification', $notif);
+ } catch (FileNotExistException $e) {
+ // Répertoire de cache n'existe pas
+ Log::record ($e->getMessage (), Log::ERROR);
+ $notif = array (
+ 'type' => 'bad',
+ 'content' => Translate::t ('internal_problem_feed')
+ );
+ Session::_param ('notification', $notif);
}
+
+ Request::forward (array ('c' => 'configure', 'a' => 'feed', 'params' => $params), true);
}
}
@@ -98,6 +118,11 @@ class feedController extends ActionController {
$entryDAO = new EntryDAO ();
$id = Request::param ('id');
+ $force = Request::param ('force', false);
+
+ // 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 ();
if ($id) {
$feed = $feedDAO->searchById ($id);
@@ -108,7 +133,7 @@ class feedController extends ActionController {
$feeds = $feedDAO->listFeedsOrderUpdate ();
}
- // pour ne pas ajouter des entrées trop anciennes
+ // on calcule la date des articles les plus anciens qu'on accepte
$nb_month_old = $this->view->conf->oldEntries ();
$date_min = time () - (60 * 60 * 24 * 30 * $nb_month_old);
@@ -118,6 +143,11 @@ class feedController extends ActionController {
$feed->load ();
$entries = $feed->entries ();
+ // ajout des articles en masse sans se soucier des erreurs
+ // On ne vérifie pas que l'article n'est pas déjà en BDD
+ // car demanderait plus de ressources
+ // La BDD refusera l'ajout de son côté car l'id doit être
+ // unique
foreach ($entries as $entry) {
if ($entry->date (true) >= $date_min) {
$values = $entry->toArray ();
@@ -125,37 +155,45 @@ class feedController extends ActionController {
}
}
+ // on indique que le flux vient d'être mis à jour en BDD
$feedDAO->updateLastUpdate ($feed->id ());
} catch (FeedException $e) {
Log::record ($e->getMessage (), Log::ERROR);
+ // TODO si on a une erreur ici, il faut mettre
+ // le flux à jour en BDD (error = 1) (issue #70)
}
+ // On arrête à 10 flux pour ne pas surcharger le serveur
+ // sauf si le paramètre $force est à vrai
$i++;
- if ($i >= 10) {
+ if ($i >= 10 && !$force) {
break;
}
}
$entryDAO->cleanOldEntries ($nb_month_old);
- // notif
$url = array ();
if ($i == 1) {
+ // on a mis un seul flux à jour
+ // reset permet de récupérer ce flux
$feed = reset ($feeds);
$notif = array (
'type' => 'good',
- 'content' => '<em>' . $feed->name () . '</em> a été mis à jour'
+ 'content' => Translate::t ('feed_actualized', $feed->name ())
);
$url['params'] = array ('get' => 'f_' . $feed->id ());
- } elseif ($i > 0) {
+ } elseif ($i > 1) {
+ // plusieurs flux on été mis à jour
$notif = array (
'type' => 'good',
- 'content' => $i . ' flux ont été mis à jour'
+ 'content' => Translate::t ('n_feeds_actualized', $i)
);
} else {
+ // aucun flux n'a été mis à jour, oups
$notif = array (
'type' => 'bad',
- 'content' => 'Aucun flux n\'a pu être mis à jour'
+ 'content' => Translate::t ('no_feed_actualized')
);
}
@@ -163,124 +201,124 @@ class feedController extends ActionController {
Session::_param ('notification', $notif);
Request::forward ($url, true);
} 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' => 'Les flux ont été mis à jour'
+ 'content' => Translate::t ('feeds_actualized')
);
Session::_param ('notification', $notif);
+ // et on désactive le layout car ne sert à rien
$this->view->_useLayout (false);
}
}
public function massiveImportAction () {
- if (login_is_conf ($this->view->conf) && !is_logged ()) {
- Error::error (
- 403,
- array ('error' => array ('Vous n\'avez pas le droit d\'accéder à cette page'))
- );
- } else {
- $entryDAO = new EntryDAO ();
- $feedDAO = new FeedDAO ();
-
- $categories = Request::param ('categories', array ());
- $feeds = Request::param ('feeds', array ());
-
- $this->addCategories ($categories);
-
- $nb_month_old = $this->view->conf->oldEntries ();
- $date_min = time () - (60 * 60 * 24 * 30 * $nb_month_old);
-
- $error = false;
- $i = 0;
- foreach ($feeds as $feed) {
- try {
- $feed->load ();
-
- // Enregistrement du flux
- $values = array (
- 'id' => $feed->id (),
- 'url' => $feed->url (),
- 'category' => $feed->category (),
- 'name' => $feed->name (),
- 'website' => $feed->website (),
- 'description' => $feed->description (),
- 'lastUpdate' => 0
- );
+ $entryDAO = new EntryDAO ();
+ $feedDAO = new FeedDAO ();
- if (!$feedDAO->searchByUrl ($values['url'])) {
- if (!$feedDAO->addFeed ($values)) {
- $error = true;
- }
+ $categories = Request::param ('categories', array ());
+ $feeds = Request::param ('feeds', array ());
+
+ // on ajoute les catégories en masse dans une fonction à part
+ $this->addCategories ($categories);
+
+ // on calcule la date des articles les plus anciens qu'on accepte
+ $nb_month_old = $this->view->conf->oldEntries ();
+ $date_min = time () - (60 * 60 * 24 * 30 * $nb_month_old);
+
+ // la variable $error permet de savoir si une erreur est survenue
+ // Le but est de ne pas arrêter l'import même en cas d'erreur
+ // L'utilisateur sera mis au courant s'il y a eu des erreurs, mais
+ // ne connaîtra pas les détails. Ceux-ci seront toutefois logguées
+ $error = false;
+ $i = 0;
+ foreach ($feeds as $feed) {
+ try {
+ $feed->load ();
+
+ $values = array (
+ 'id' => $feed->id (),
+ 'url' => $feed->url (),
+ 'category' => $feed->category (),
+ 'name' => $feed->name (),
+ 'website' => $feed->website (),
+ 'description' => $feed->description (),
+ 'lastUpdate' => 0
+ );
+
+ // ajout du flux que s'il n'est pas déjà en BDD
+ if (!$feedDAO->searchByUrl ($values['url'])) {
+ if (!$feedDAO->addFeed ($values)) {
+ $error = true;
}
- } catch (FeedException $e) {
- $error = true;
- Log::record ($e->getMessage (), Log::ERROR);
}
+ } catch (FeedException $e) {
+ $error = true;
+ Log::record ($e->getMessage (), Log::ERROR);
}
+ }
- if ($error) {
- $res = 'Les flux ont été importés mais des erreurs sont survenus';
- } else {
- $res = 'Les flux ont été importés';
- }
- $notif = array (
- 'type' => 'good',
- 'content' => $res
- );
- Session::_param ('notification', $notif);
-
- Request::forward (array (
- 'c' => 'configure',
- 'a' => 'importExport'
- ), true);
+ if ($error) {
+ $res = Translate::t ('feeds_imported_with_errors');
+ } else {
+ $res = Translate::t ('feeds_imported');
}
+
+ $notif = array (
+ 'type' => 'good',
+ 'content' => $res
+ );
+ Session::_param ('notification', $notif);
+
+ // et on redirige vers la page import/export
+ Request::forward (array (
+ 'c' => 'configure',
+ 'a' => 'importExport'
+ ), true);
}
public function deleteAction () {
- if (login_is_conf ($this->view->conf) && !is_logged ()) {
- Error::error (
- 403,
- array ('error' => array ('Vous n\'avez pas le droit d\'accéder à cette page'))
- );
- } else {
- $type = Request::param ('type', 'feed');
- $id = Request::param ('id');
+ $type = Request::param ('type', 'feed');
+ $id = Request::param ('id');
- $feedDAO = new FeedDAO ();
- if ($type == 'category') {
- if ($feedDAO->deleteFeedByCategory ($id)) {
- $notif = array (
- 'type' => 'good',
- 'content' => 'La catégorie a été vidée'
- );
- } else {
- $notif = array (
- 'type' => 'bad',
- 'content' => 'Un problème est survenu'
- );
- }
+ $feedDAO = new FeedDAO ();
+ if ($type == 'category') {
+ if ($feedDAO->deleteFeedByCategory ($id)) {
+ $notif = array (
+ 'type' => 'good',
+ 'content' => Translate::t ('category_emptied')
+ );
} else {
- if ($feedDAO->deleteFeed ($id)) {
- $notif = array (
- 'type' => 'good',
- 'content' => 'Le flux a été supprimé'
- );
- } else {
- $notif = array (
- 'type' => 'bad',
- 'content' => 'Un problème est survenu'
- );
- }
+ $notif = array (
+ 'type' => 'bad',
+ 'content' => Translate::t ('error_occured')
+ );
}
-
- Session::_param ('notification', $notif);
-
- if ($type == 'category') {
- Request::forward (array ('c' => 'configure', 'a' => 'categorize'), true);
+ } else {
+ if ($feedDAO->deleteFeed ($id)) {
+ $notif = array (
+ 'type' => 'good',
+ 'content' => Translate::t ('feed_deleted')
+ );
} else {
- Request::forward (array ('c' => 'configure', 'a' => 'feed'), true);
+ $notif = array (
+ 'type' => 'bad',
+ 'content' => Translate::t ('error_occured')
+ );
}
}
+
+ Session::_param ('notification', $notif);
+
+ if ($type == 'category') {
+ Request::forward (array ('c' => 'configure', 'a' => 'categorize'), true);
+ } else {
+ Request::forward (array ('c' => 'configure', 'a' => 'feed'), true);
+ }
}
private function addCategories ($categories) {
generated by cgit v1.2.3 (git 2.39.1) at 2026-02-10 05:03:34 +0000