feedController.php 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837
  1. <?php
  2. /**
  3. * Controller to handle every feed actions.
  4. */
  5. class FreshRSS_feed_Controller extends Minz_ActionController {
  6. /**
  7. * This action is called before every other action in that class. It is
  8. * the common boiler plate for every action. It is triggered by the
  9. * underlying framework.
  10. */
  11. public function firstAction() {
  12. if (!FreshRSS_Auth::hasAccess()) {
  13. // Token is useful in the case that anonymous refresh is forbidden
  14. // and CRON task cannot be used with php command so the user can
  15. // set a CRON task to refresh his feeds by using token inside url
  16. $token = FreshRSS_Context::$user_conf->token;
  17. $token_param = Minz_Request::param('token', '');
  18. $token_is_ok = ($token != '' && $token == $token_param);
  19. $action = Minz_Request::actionName();
  20. $allow_anonymous_refresh = FreshRSS_Context::$system_conf->allow_anonymous_refresh;
  21. if ($action !== 'actualize' ||
  22. !($allow_anonymous_refresh || $token_is_ok)) {
  23. Minz_Error::error(403);
  24. }
  25. }
  26. $this->updateTTL();
  27. }
  28. /**
  29. * @param $url
  30. * @param string $title
  31. * @param int $cat_id
  32. * @param string $new_cat_name
  33. * @param string $http_auth
  34. * @return FreshRSS_Feed|the
  35. * @throws FreshRSS_AlreadySubscribed_Exception
  36. * @throws FreshRSS_FeedNotAdded_Exception
  37. * @throws FreshRSS_Feed_Exception
  38. * @throws Minz_FileNotExistException
  39. */
  40. public static function addFeed($url, $title = '', $cat_id = 0, $new_cat_name = '', $http_auth = '', $attributes = array()) {
  41. FreshRSS_UserDAO::touch();
  42. @set_time_limit(300);
  43. $catDAO = FreshRSS_Factory::createCategoryDao();
  44. $url = trim($url);
  45. /** @var $url */
  46. $url = Minz_ExtensionManager::callHook('check_url_before_add', $url);
  47. if (null === $url) {
  48. throw new FreshRSS_FeedNotAdded_Exception($url, $title);
  49. }
  50. $cat = null;
  51. if ($cat_id > 0) {
  52. $cat = $catDAO->searchById($cat_id);
  53. }
  54. if ($cat == null && $new_cat_name != '') {
  55. $new_cat_id = $catDAO->addCategory(array('name' => $new_cat_name));
  56. $cat_id = $new_cat_id > 0 ? $new_cat_id : $cat_id;
  57. $cat = $catDAO->searchById($cat_id);
  58. }
  59. if ($cat == null) {
  60. $catDAO->checkDefault();
  61. }
  62. $cat_id = $cat == null ? FreshRSS_CategoryDAO::DEFAULTCATEGORYID : $cat->id();
  63. $feed = new FreshRSS_Feed($url); //Throws FreshRSS_BadUrl_Exception
  64. $feed->_attributes('', $attributes);
  65. $feed->_httpAuth($http_auth);
  66. $feed->load(true); //Throws FreshRSS_Feed_Exception, Minz_FileNotExistException
  67. $feed->_category($cat_id);
  68. $feedDAO = FreshRSS_Factory::createFeedDao();
  69. if ($feedDAO->searchByUrl($feed->url())) {
  70. throw new FreshRSS_AlreadySubscribed_Exception($url, $feed->name());
  71. }
  72. /** @var FreshRSS_Feed $feed */
  73. $feed = Minz_ExtensionManager::callHook('feed_before_insert', $feed);
  74. if ($feed === null) {
  75. throw new FreshRSS_FeedNotAdded_Exception($url, $feed->name());
  76. }
  77. $values = array(
  78. 'url' => $feed->url(),
  79. 'category' => $feed->category(),
  80. 'name' => $title != '' ? $title : $feed->name(),
  81. 'website' => $feed->website(),
  82. 'description' => $feed->description(),
  83. 'lastUpdate' => time(),
  84. 'httpAuth' => $feed->httpAuth(),
  85. 'attributes' => $feed->attributes(),
  86. );
  87. $id = $feedDAO->addFeed($values);
  88. if (!$id) {
  89. // There was an error in database... we cannot say what here.
  90. throw new FreshRSS_FeedNotAdded_Exception($url, $feed->name());
  91. }
  92. $feed->_id($id);
  93. // Ok, feed has been added in database. Now we have to refresh entries.
  94. self::actualizeFeed($id, $url, false, null, true);
  95. return $feed;
  96. }
  97. /**
  98. * This action subscribes to a feed.
  99. *
  100. * It can be reached by both GET and POST requests.
  101. *
  102. * GET request displays a form to add and configure a feed.
  103. * Request parameter is:
  104. * - url_rss (default: false)
  105. *
  106. * POST request adds a feed in database.
  107. * Parameters are:
  108. * - url_rss (default: false)
  109. * - category (default: false)
  110. * - new_category (required if category == 'nc')
  111. * - http_user (default: false)
  112. * - http_pass (default: false)
  113. * It tries to get website information from RSS feed.
  114. * If no category is given, feed is added to the default one.
  115. *
  116. * If url_rss is false, nothing happened.
  117. */
  118. public function addAction() {
  119. $url = Minz_Request::param('url_rss');
  120. if ($url === false) {
  121. // No url, do nothing
  122. Minz_Request::forward(array(
  123. 'c' => 'subscription',
  124. 'a' => 'index'
  125. ), true);
  126. }
  127. $feedDAO = FreshRSS_Factory::createFeedDao();
  128. $url_redirect = array(
  129. 'c' => 'subscription',
  130. 'a' => 'add',
  131. 'params' => array(),
  132. );
  133. $limits = FreshRSS_Context::$system_conf->limits;
  134. $this->view->feeds = $feedDAO->listFeeds();
  135. if (count($this->view->feeds) >= $limits['max_feeds']) {
  136. Minz_Request::bad(_t('feedback.sub.feed.over_max', $limits['max_feeds']),
  137. $url_redirect);
  138. }
  139. if (Minz_Request::isPost()) {
  140. $cat = Minz_Request::param('category');
  141. // HTTP information are useful if feed is protected behind a
  142. // HTTP authentication
  143. $user = trim(Minz_Request::param('http_user', ''));
  144. $pass = trim(Minz_Request::param('http_pass', ''));
  145. $http_auth = '';
  146. if ($user != '' && $pass != '') { //TODO: Sanitize
  147. $http_auth = $user . ':' . $pass;
  148. }
  149. $attributes = array(
  150. 'ssl_verify' => null,
  151. 'timeout' => null,
  152. );
  153. if (FreshRSS_Auth::hasAccess('admin')) {
  154. $attributes['ssl_verify'] = Minz_Request::paramTernary('ssl_verify');
  155. $timeout = intval(Minz_Request::param('timeout', 0));
  156. $attributes['timeout'] = $timeout > 0 ? $timeout : null;
  157. }
  158. try {
  159. $feed = self::addFeed($url, '', $cat, null, $http_auth, $attributes);
  160. } catch (FreshRSS_BadUrl_Exception $e) {
  161. // Given url was not a valid url!
  162. Minz_Log::warning($e->getMessage());
  163. Minz_Request::bad(_t('feedback.sub.feed.invalid_url', $url), $url_redirect);
  164. } catch (FreshRSS_Feed_Exception $e) {
  165. // Something went bad (timeout, server not found, etc.)
  166. Minz_Log::warning($e->getMessage());
  167. Minz_Request::bad(_t('feedback.sub.feed.internal_problem', _url('index', 'logs')), $url_redirect);
  168. } catch (Minz_FileNotExistException $e) {
  169. // Cache directory doesn't exist!
  170. Minz_Log::error($e->getMessage());
  171. Minz_Request::bad(_t('feedback.sub.feed.internal_problem', _url('index', 'logs')), $url_redirect);
  172. } catch (FreshRSS_AlreadySubscribed_Exception $e) {
  173. Minz_Request::bad(_t('feedback.sub.feed.already_subscribed', $e->feedName()), $url_redirect);
  174. } catch (FreshRSS_FeedNotAdded_Exception $e) {
  175. Minz_Request::bad(_t('feedback.sub.feed.not_added', $e->feedName()), $url_redirect);
  176. }
  177. // Entries are in DB, we redirect to feed configuration page.
  178. $url_redirect['a'] = 'index';
  179. $url_redirect['params']['id'] = $feed->id();
  180. Minz_Request::good(_t('feedback.sub.feed.added', $feed->name()), $url_redirect);
  181. } else {
  182. // GET request: we must ask confirmation to user before adding feed.
  183. Minz_View::prependTitle(_t('sub.feed.title_add') . ' · ');
  184. $this->catDAO = FreshRSS_Factory::createCategoryDao();
  185. $this->view->categories = $this->catDAO->listCategories(false);
  186. $this->view->feed = new FreshRSS_Feed($url);
  187. try {
  188. // We try to get more information about the feed.
  189. $this->view->feed->load(true);
  190. $this->view->load_ok = true;
  191. } catch (Exception $e) {
  192. $this->view->load_ok = false;
  193. }
  194. $feed = $feedDAO->searchByUrl($this->view->feed->url());
  195. if ($feed) {
  196. // Already subscribe so we redirect to the feed configuration page.
  197. $url_redirect['a'] = 'index';
  198. $url_redirect['params']['id'] = $feed->id();
  199. Minz_Request::good(_t('feedback.sub.feed.already_subscribed', $feed->name()), $url_redirect);
  200. }
  201. }
  202. }
  203. /**
  204. * This action remove entries from a given feed.
  205. *
  206. * It should be reached by a POST action.
  207. *
  208. * Parameter is:
  209. * - id (default: false)
  210. */
  211. public function truncateAction() {
  212. $id = Minz_Request::param('id');
  213. $url_redirect = array(
  214. 'c' => 'subscription',
  215. 'a' => 'index',
  216. 'params' => array('id' => $id)
  217. );
  218. if (!Minz_Request::isPost()) {
  219. Minz_Request::forward($url_redirect, true);
  220. }
  221. $feedDAO = FreshRSS_Factory::createFeedDao();
  222. $n = $feedDAO->truncate($id);
  223. invalidateHttpCache();
  224. if ($n === false) {
  225. Minz_Request::bad(_t('feedback.sub.feed.error'), $url_redirect);
  226. } else {
  227. Minz_Request::good(_t('feedback.sub.feed.n_entries_deleted', $n), $url_redirect);
  228. }
  229. }
  230. public static function actualizeFeed($feed_id, $feed_url, $force, $simplePiePush = null, $isNewFeed = false, $noCommit = false, $maxFeeds = 10) {
  231. @set_time_limit(300);
  232. $feedDAO = FreshRSS_Factory::createFeedDao();
  233. $entryDAO = FreshRSS_Factory::createEntryDao();
  234. // Create a list of feeds to actualize.
  235. // If feed_id is set and valid, corresponding feed is added to the list but
  236. // alone in order to automatize further process.
  237. $feeds = array();
  238. if ($feed_id > 0 || $feed_url) {
  239. $feed = $feed_id > 0 ? $feedDAO->searchById($feed_id) : $feedDAO->searchByUrl($feed_url);
  240. if ($feed) {
  241. $feeds[] = $feed;
  242. }
  243. } else {
  244. $feeds = $feedDAO->listFeedsOrderUpdate(-1);
  245. }
  246. // Set maxFeeds to a minimum of 10
  247. if (!is_int($maxFeeds) || $maxFeeds < 10) {
  248. $maxFeeds = 10;
  249. }
  250. // WebSub (PubSubHubbub) support
  251. $pubsubhubbubEnabledGeneral = FreshRSS_Context::$system_conf->pubsubhubbub_enabled;
  252. $pshbMinAge = time() - (3600 * 24); //TODO: Make a configuration.
  253. $updated_feeds = 0;
  254. $nb_new_articles = 0;
  255. foreach ($feeds as $feed) {
  256. /** @var FreshRSS_Feed $feed */
  257. $feed = Minz_ExtensionManager::callHook('feed_before_actualize', $feed);
  258. if (null === $feed) {
  259. continue;
  260. }
  261. $url = $feed->url(); //For detection of HTTP 301
  262. $pubSubHubbubEnabled = $pubsubhubbubEnabledGeneral && $feed->pubSubHubbubEnabled();
  263. if ((!$simplePiePush) && (!$feed_id) && $pubSubHubbubEnabled && ($feed->lastUpdate() > $pshbMinAge)) {
  264. //$text = 'Skip pull of feed using PubSubHubbub: ' . $url;
  265. //Minz_Log::debug($text);
  266. //Minz_Log::debug($text, PSHB_LOG);
  267. continue; //When PubSubHubbub is used, do not pull refresh so often
  268. }
  269. $mtime = 0;
  270. if ($feed->mute()) {
  271. continue; //Feed refresh is disabled
  272. }
  273. $ttl = $feed->ttl();
  274. if ((!$simplePiePush) && (!$feed_id) &&
  275. ($feed->lastUpdate() + 10 >= time() - (
  276. $ttl == FreshRSS_Feed::TTL_DEFAULT ? FreshRSS_Context::$user_conf->ttl_default : $ttl))) {
  277. //Too early to refresh from source, but check whether the feed was updated by another user
  278. $mtime = $feed->cacheModifiedTime();
  279. if ($feed->lastUpdate() + 10 >= $mtime) {
  280. continue; //Nothing newer from other users
  281. }
  282. //Minz_Log::debug($feed->url(false) . ' was updated at ' . date('c', $mtime) . ' by another user');
  283. //Will take advantage of the newer cache
  284. }
  285. if (!$feed->lock()) {
  286. Minz_Log::notice('Feed already being actualized: ' . $feed->url(false));
  287. continue;
  288. }
  289. try {
  290. if ($simplePiePush) {
  291. $simplePie = $simplePiePush; //Used by WebSub
  292. } else {
  293. $simplePie = $feed->load(false, $isNewFeed);
  294. }
  295. $newGuids = $simplePie == null ? [] : $feed->loadGuids($simplePie);
  296. $entries = $simplePie == null ? [] : $feed->loadEntries($simplePie);
  297. } catch (FreshRSS_Feed_Exception $e) {
  298. Minz_Log::warning($e->getMessage());
  299. $feedDAO->updateLastUpdate($feed->id(), true);
  300. $feed->unlock();
  301. continue;
  302. }
  303. $needFeedCacheRefresh = false;
  304. if (count($newGuids) > 0) {
  305. // For this feed, check existing GUIDs already in database.
  306. $existingHashForGuids = $entryDAO->listHashForFeedGuids($feed->id(), $newGuids);
  307. $newGuids = array();
  308. $oldGuids = array();
  309. // Add entries in database if possible.
  310. foreach ($entries as $entry) {
  311. if (isset($newGuids[$entry->guid()])) {
  312. continue; //Skip subsequent articles with same GUID
  313. }
  314. $newGuids[$entry->guid()] = true;
  315. $entry_date = $entry->date(true);
  316. if (isset($existingHashForGuids[$entry->guid()])) {
  317. $existingHash = $existingHashForGuids[$entry->guid()];
  318. if (strcasecmp($existingHash, $entry->hash()) === 0) {
  319. //This entry already exists and is unchanged.
  320. $oldGuids[] = $entry->guid();
  321. } else { //This entry already exists but has been updated
  322. //Minz_Log::debug('Entry with GUID `' . $entry->guid() . '` updated in feed ' . $feed->url(false) .
  323. //', old hash ' . $existingHash . ', new hash ' . $entry->hash());
  324. $mark_updated_article_unread = $feed->attributes('mark_updated_article_unread') !== null ? (
  325. $feed->attributes('mark_updated_article_unread')
  326. ) : FreshRSS_Context::$user_conf->mark_updated_article_unread;
  327. $needFeedCacheRefresh = $mark_updated_article_unread;
  328. $entry->_isRead($mark_updated_article_unread ? false : null); //Change is_read according to policy.
  329. $entry = Minz_ExtensionManager::callHook('entry_before_insert', $entry);
  330. if ($entry === null) {
  331. // An extension has returned a null value, there is nothing to insert.
  332. continue;
  333. }
  334. if (!$entryDAO->inTransaction()) {
  335. $entryDAO->beginTransaction();
  336. }
  337. $entryDAO->updateEntry($entry->toArray());
  338. }
  339. } else {
  340. $id = uTimeString();
  341. $entry->_id($id);
  342. $entry->applyFilterActions();
  343. $entry = Minz_ExtensionManager::callHook('entry_before_insert', $entry);
  344. if ($entry === null) {
  345. // An extension has returned a null value, there is nothing to insert.
  346. continue;
  347. }
  348. if ($pubSubHubbubEnabled && !$simplePiePush) { //We use push, but have discovered an article by pull!
  349. $text = 'An article was discovered by pull although we use PubSubHubbub!: Feed ' . $url .
  350. ' GUID ' . $entry->guid();
  351. Minz_Log::warning($text, PSHB_LOG);
  352. Minz_Log::warning($text);
  353. $pubSubHubbubEnabled = false;
  354. $feed->pubSubHubbubError(true);
  355. }
  356. if (!$entryDAO->inTransaction()) {
  357. $entryDAO->beginTransaction();
  358. }
  359. $entryDAO->addEntry($entry->toArray());
  360. $nb_new_articles++;
  361. }
  362. }
  363. $entryDAO->updateLastSeen($feed->id(), $oldGuids, $mtime);
  364. }
  365. unset($entries);
  366. if (mt_rand(0, 30) === 1) { // Remove old entries once in 30.
  367. if (!$entryDAO->inTransaction()) {
  368. $entryDAO->beginTransaction();
  369. }
  370. $nb = $feed->cleanOldEntries();
  371. if ($nb > 0) {
  372. $needFeedCacheRefresh = true;
  373. }
  374. }
  375. $feedDAO->updateLastUpdate($feed->id(), false, $mtime);
  376. if ($needFeedCacheRefresh) {
  377. $feedDAO->updateCachedValues($feed->id());
  378. }
  379. if ($entryDAO->inTransaction()) {
  380. $entryDAO->commit();
  381. }
  382. $feedProperties = [];
  383. if ($pubsubhubbubEnabledGeneral && $feed->hubUrl() && $feed->selfUrl()) { //selfUrl has priority for WebSub
  384. if ($feed->selfUrl() !== $url) { // https://github.com/pubsubhubbub/PubSubHubbub/wiki/Moving-Feeds-or-changing-Hubs
  385. $selfUrl = checkUrl($feed->selfUrl());
  386. if ($selfUrl) {
  387. Minz_Log::debug('WebSub unsubscribe ' . $feed->url(false));
  388. if (!$feed->pubSubHubbubSubscribe(false)) { //Unsubscribe
  389. Minz_Log::warning('Error while WebSub unsubscribing from ' . $feed->url(false));
  390. }
  391. $feed->_url($selfUrl, false);
  392. Minz_Log::notice('Feed ' . $url . ' canonical address moved to ' . $feed->url(false));
  393. $feedDAO->updateFeed($feed->id(), array('url' => $feed->url()));
  394. }
  395. }
  396. } elseif ($feed->url() !== $url) { // HTTP 301 Moved Permanently
  397. Minz_Log::notice('Feed ' . $url . ' moved permanently to ' . $feed->url(false));
  398. $feedProperties['url'] = $feed->url();
  399. }
  400. if ($simplePie != null) {
  401. if (trim($feed->name()) == '') {
  402. //HTML to HTML-PRE //ENT_COMPAT except '&'
  403. $name = strtr(html_only_entity_decode($simplePie->get_title()), array('<' => '&lt;', '>' => '&gt;', '"' => '&quot;'));
  404. $feedProperties['name'] = $name == '' ? $feed->url() : $name;
  405. }
  406. if (trim($feed->website()) == '') {
  407. $website = html_only_entity_decode($simplePie->get_link());
  408. $feedProperties['website'] = $website == '' ? $feed->url() : $website;
  409. }
  410. if (trim($feed->description()) == '') {
  411. $description = html_only_entity_decode($simplePie->get_description());
  412. if ($description != '') {
  413. $feedProperties['description'] = $description;
  414. }
  415. }
  416. }
  417. if (!empty($feedProperties)) {
  418. $feedDAO->updateFeed($feed->id(), $feedProperties);
  419. }
  420. $feed->faviconPrepare();
  421. if ($pubsubhubbubEnabledGeneral && $feed->pubSubHubbubPrepare()) {
  422. Minz_Log::notice('WebSub subscribe ' . $feed->url(false));
  423. if (!$feed->pubSubHubbubSubscribe(true)) { //Subscribe
  424. Minz_Log::warning('Error while WebSub subscribing to ' . $feed->url(false));
  425. }
  426. }
  427. $feed->unlock();
  428. $updated_feeds++;
  429. unset($feed);
  430. gc_collect_cycles();
  431. // No more than $maxFeeds feeds unless $force is true to avoid overloading
  432. // the server.
  433. if ($updated_feeds >= $maxFeeds && !$force) {
  434. break;
  435. }
  436. }
  437. if (!$noCommit && ($nb_new_articles > 0 || $updated_feeds > 0)) {
  438. if (!$entryDAO->inTransaction()) {
  439. $entryDAO->beginTransaction();
  440. }
  441. $entryDAO->commitNewEntries();
  442. $feedDAO->updateCachedValues();
  443. if ($entryDAO->inTransaction()) {
  444. $entryDAO->commit();
  445. }
  446. $databaseDAO = FreshRSS_Factory::createDatabaseDAO();
  447. $databaseDAO->minorDbMaintenance();
  448. }
  449. return array($updated_feeds, reset($feeds), $nb_new_articles);
  450. }
  451. /**
  452. * This action actualizes entries from one or several feeds.
  453. *
  454. * Parameters are:
  455. * - id (default: false): Feed ID
  456. * - url (default: false): Feed URL
  457. * - force (default: false)
  458. * - noCommit (default: 0): Set to 1 to prevent committing the new articles to the main database
  459. * If id and url are not specified, all the feeds are actualized. But if force is
  460. * false, process stops at 10 feeds to avoid time execution problem.
  461. */
  462. public function actualizeAction() {
  463. Minz_Session::_param('actualize_feeds', false);
  464. $id = Minz_Request::param('id');
  465. $url = Minz_Request::param('url');
  466. $force = Minz_Request::param('force');
  467. $maxFeeds = (int)Minz_Request::param('maxFeeds');
  468. $noCommit = Minz_Request::fetchPOST('noCommit', 0) == 1;
  469. if ($id == -1 && !$noCommit) { //Special request only to commit & refresh DB cache
  470. $updated_feeds = 0;
  471. $entryDAO = FreshRSS_Factory::createEntryDao();
  472. $feedDAO = FreshRSS_Factory::createFeedDao();
  473. $entryDAO->beginTransaction();
  474. $entryDAO->commitNewEntries();
  475. $feedDAO->updateCachedValues();
  476. $entryDAO->commit();
  477. $databaseDAO = FreshRSS_Factory::createDatabaseDAO();
  478. $databaseDAO->minorDbMaintenance();
  479. } else {
  480. list($updated_feeds, $feed, $nb_new_articles) = self::actualizeFeed($id, $url, $force, null, false, $noCommit, $maxFeeds);
  481. }
  482. if (Minz_Request::param('ajax')) {
  483. // Most of the time, ajax request is for only one feed. But since
  484. // there are several parallel requests, we should return that there
  485. // are several updated feeds.
  486. $notif = array(
  487. 'type' => 'good',
  488. 'content' => _t('feedback.sub.feed.actualizeds')
  489. );
  490. Minz_Session::_param('notification', $notif);
  491. // No layout in ajax request.
  492. $this->view->_layout(false);
  493. } else {
  494. // Redirect to the main page with correct notification.
  495. if ($updated_feeds === 1) {
  496. Minz_Request::good(_t('feedback.sub.feed.actualized', $feed->name()), array(
  497. 'params' => array('get' => 'f_' . $feed->id())
  498. ));
  499. } elseif ($updated_feeds > 1) {
  500. Minz_Request::good(_t('feedback.sub.feed.n_actualized', $updated_feeds), array());
  501. } else {
  502. Minz_Request::good(_t('feedback.sub.feed.no_refresh'), array());
  503. }
  504. }
  505. return $updated_feeds;
  506. }
  507. public static function renameFeed($feed_id, $feed_name) {
  508. if ($feed_id <= 0 || $feed_name == '') {
  509. return false;
  510. }
  511. FreshRSS_UserDAO::touch();
  512. $feedDAO = FreshRSS_Factory::createFeedDao();
  513. return $feedDAO->updateFeed($feed_id, array('name' => $feed_name));
  514. }
  515. public static function moveFeed($feed_id, $cat_id, $new_cat_name = '') {
  516. if ($feed_id <= 0 || ($cat_id <= 0 && $new_cat_name == '')) {
  517. return false;
  518. }
  519. FreshRSS_UserDAO::touch();
  520. $catDAO = FreshRSS_Factory::createCategoryDao();
  521. if ($cat_id > 0) {
  522. $cat = $catDAO->searchById($cat_id);
  523. $cat_id = $cat == null ? 0 : $cat->id();
  524. }
  525. if ($cat_id <= 1 && $new_cat_name != '') {
  526. $cat_id = $catDAO->addCategory(array('name' => $new_cat_name));
  527. }
  528. if ($cat_id <= 1) {
  529. $catDAO->checkDefault();
  530. $cat_id = FreshRSS_CategoryDAO::DEFAULTCATEGORYID;
  531. }
  532. $feedDAO = FreshRSS_Factory::createFeedDao();
  533. return $feedDAO->updateFeed($feed_id, array('category' => $cat_id));
  534. }
  535. /**
  536. * This action changes the category of a feed.
  537. *
  538. * This page must be reached by a POST request.
  539. *
  540. * Parameters are:
  541. * - f_id (default: false)
  542. * - c_id (default: false)
  543. * If c_id is false, default category is used.
  544. *
  545. * @todo should handle order of the feed inside the category.
  546. */
  547. public function moveAction() {
  548. if (!Minz_Request::isPost()) {
  549. Minz_Request::forward(array('c' => 'subscription'), true);
  550. }
  551. $feed_id = Minz_Request::param('f_id');
  552. $cat_id = Minz_Request::param('c_id');
  553. if (self::moveFeed($feed_id, $cat_id)) {
  554. // TODO: return something useful
  555. // Log a notice to prevent "Empty IF statement" warning in PHP_CodeSniffer
  556. Minz_Log::notice('Moved feed `' . $feed_id . '` in the category `' . $cat_id . '`');
  557. } else {
  558. Minz_Log::warning('Cannot move feed `' . $feed_id . '` in the category `' . $cat_id . '`');
  559. Minz_Error::error(404);
  560. }
  561. }
  562. public static function deleteFeed($feed_id) {
  563. FreshRSS_UserDAO::touch();
  564. $feedDAO = FreshRSS_Factory::createFeedDao();
  565. if ($feedDAO->deleteFeed($feed_id)) {
  566. // TODO: Delete old favicon
  567. // Remove related queries
  568. FreshRSS_Context::$user_conf->queries = remove_query_by_get(
  569. 'f_' . $feed_id, FreshRSS_Context::$user_conf->queries);
  570. FreshRSS_Context::$user_conf->save();
  571. return true;
  572. }
  573. return false;
  574. }
  575. /**
  576. * This action deletes a feed.
  577. *
  578. * This page must be reached by a POST request.
  579. * If there are related queries, they are deleted too.
  580. *
  581. * Parameters are:
  582. * - id (default: false)
  583. * - r (default: false)
  584. * r permits to redirect to a given page at the end of this action.
  585. *
  586. * @todo handle "r" redirection in Minz_Request::forward()?
  587. */
  588. public function deleteAction() {
  589. $redirect_url = Minz_Request::param('r', false, true);
  590. if (!$redirect_url) {
  591. $redirect_url = array('c' => 'subscription', 'a' => 'index');
  592. }
  593. if (!Minz_Request::isPost()) {
  594. Minz_Request::forward($redirect_url, true);
  595. }
  596. $id = Minz_Request::param('id');
  597. if (self::deleteFeed($id)) {
  598. Minz_Request::good(_t('feedback.sub.feed.deleted'), $redirect_url);
  599. } else {
  600. Minz_Request::bad(_t('feedback.sub.feed.error'), $redirect_url);
  601. }
  602. }
  603. /**
  604. * This action force clears the cache of a feed.
  605. *
  606. * Parameters are:
  607. * - id (mandatory - no default): Feed ID
  608. *
  609. */
  610. public function clearCacheAction() {
  611. //Get Feed.
  612. $id = Minz_Request::param('id');
  613. $feedDAO = FreshRSS_Factory::createFeedDao();
  614. $feed = $feedDAO->searchById($id);
  615. if (!$feed) {
  616. Minz_Request::bad(_t('feedback.sub.feed.not_found'), array());
  617. return;
  618. }
  619. $feed->clearCache();
  620. Minz_Request::good(_t('feedback.sub.feed.cache_cleared', $feed->name()), array(
  621. 'params' => array('get' => 'f_' . $feed->id())
  622. ));
  623. }
  624. /**
  625. * This action forces reloading the articles of a feed.
  626. *
  627. * Parameters are:
  628. * - id (mandatory - no default): Feed ID
  629. *
  630. */
  631. public function reloadAction() {
  632. @set_time_limit(300);
  633. //Get Feed ID.
  634. $feed_id = Minz_Request::param('id');
  635. $feedDAO = FreshRSS_Factory::createFeedDao();
  636. $entryDAO = FreshRSS_Factory::createEntryDao();
  637. $feed = $feedDAO->searchById($feed_id);
  638. if (!$feed) {
  639. Minz_Request::bad(_t('feedback.sub.feed.not_found'), array());
  640. return;
  641. }
  642. //Re-fetch articles as if the feed was new.
  643. self::actualizeFeed($feed_id, null, false, null, true);
  644. //Extract all feed entries from database, load complete content and store them back in database.
  645. $entries = $entryDAO->listWhere('f', $feed_id, FreshRSS_Entry::STATE_ALL, 'DESC', 0);
  646. //We need another DB connection in parallel
  647. Minz_ModelPdo::$usesSharedPdo = false;
  648. $entryDAO2 = FreshRSS_Factory::createEntryDao();
  649. foreach ($entries as $entry) {
  650. $entry->loadCompleteContent(true);
  651. $entryDAO2->updateEntry($entry->toArray());
  652. }
  653. Minz_ModelPdo::$usesSharedPdo = true;
  654. //Give feedback to user.
  655. Minz_Request::good(_t('feedback.sub.feed.reloaded', $feed->name()), array(
  656. 'params' => array('get' => 'f_' . $feed->id())
  657. ));
  658. }
  659. /**
  660. * This action creates a preview of a content-selector.
  661. *
  662. * Parameters are:
  663. * - id (mandatory - no default): Feed ID
  664. * - selector (mandatory - no default): Selector to preview
  665. *
  666. */
  667. public function contentSelectorPreviewAction() {
  668. //Configure.
  669. $this->view->fatalError = '';
  670. $this->view->selectorSuccess = false;
  671. $this->view->htmlContent = '';
  672. $this->view->_layout(false);
  673. $this->_csp([
  674. 'default-src' => "'self'",
  675. 'frame-src' => '*',
  676. 'img-src' => '* data:',
  677. 'media-src' => '*',
  678. ]);
  679. //Get parameters.
  680. $feed_id = Minz_Request::param('id');
  681. $content_selector = trim(Minz_Request::param('selector'));
  682. if (!$content_selector) {
  683. $this->view->fatalError = _t('feedback.sub.feed.selector_preview.selector_empty');
  684. return;
  685. }
  686. //Check Feed ID validity.
  687. $entryDAO = FreshRSS_Factory::createEntryDao();
  688. $entries = $entryDAO->listWhere('f', $feed_id);
  689. $entry = null;
  690. //Get first entry (syntax robust for Generator or Array)
  691. foreach ($entries as $myEntry) {
  692. if ($entry == null) {
  693. $entry = $myEntry;
  694. }
  695. }
  696. if ($entry == null) {
  697. $this->view->fatalError = _t('feedback.sub.feed.selector_preview.no_entries');
  698. return;
  699. }
  700. //Get feed.
  701. $feed = $entry->feed(true);
  702. if (!$feed) {
  703. $this->view->fatalError = _t('feedback.sub.feed.selector_preview.no_feed');
  704. return;
  705. }
  706. //Fetch & select content.
  707. try {
  708. $fullContent = FreshRSS_Entry::getContentByParsing(
  709. htmlspecialchars_decode($entry->link(), ENT_QUOTES),
  710. $content_selector,
  711. $feed->attributes()
  712. );
  713. if ($fullContent != '') {
  714. $this->view->selectorSuccess = true;
  715. $this->view->htmlContent = $fullContent;
  716. } else {
  717. $this->view->selectorSuccess = false;
  718. $this->view->htmlContent = $entry->content();
  719. }
  720. } catch (Exception $e) {
  721. $this->view->fatalError = _t('feedback.sub.feed.selector_preview.http_error');
  722. }
  723. }
  724. /**
  725. * This method update TTL values for feeds if needed.
  726. * It changes the old default value (-2) to the new default value (0).
  727. * It changes the old disabled value (-1) to the default disabled value.
  728. */
  729. private function updateTTL() {
  730. $feedDAO = FreshRSS_Factory::createFeedDao();
  731. $feedDAO->updateTTL();
  732. }
  733. }