actualize_script.php 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758
  1. <?php
  2. require(dirname(__FILE__) . '/../constants.php');
  3. //<Mutex>
  4. $lock = DATA_PATH . '/actualize.lock.txt';
  5. if (file_exists($lock) && ((time() - @filemtime($lock)) > 3600)) {
  6. @unlink($lock);
  7. }
  8. if (($handle = @fopen($lock, 'x')) === false) {
  9. syslog(LOG_INFO, 'FreshRSS actualize already running?');
  10. return;
  11. }
  12. register_shutdown_function('unlink', $lock);
  13. //Could use http://php.net/function.pcntl-signal.php to catch interruptions
  14. @fclose($handle);
  15. //</Mutex>
  16. require(LIB_PATH . '/lib_rss.php'); //Includes class autoloader
  17. session_cache_limiter('');
  18. ob_implicit_flush(false);
  19. ob_start();
  20. echo 'Results: ', "\n"; //Buffered
  21. Minz_Configuration::init();
  22. $users = listUsers();
  23. shuffle($users); //Process users in random order
  24. array_unshift($users, Minz_Configuration::defaultUser()); //But always start with admin
  25. $users = array_unique($users);
  26. foreach ($users as $myUser) {
  27. syslog(LOG_INFO, 'FreshRSS actualize ' . $myUser);
  28. fwrite(STDOUT, 'Actualize ' . $myUser . "...\n"); //Unbuffered
  29. echo $myUser, ' '; //Buffered
  30. $_GET['c'] = 'feed';
  31. $_GET['a'] = 'actualize';
  32. $_GET['ajax'] = 1;
  33. $_GET['force'] = true;
  34. $_SERVER['HTTP_HOST'] = '';
  35. $freshRSS = new FreshRSS();
  36. $freshRSS->_useOb(false);
  37. Minz_Session::init('FreshRSS');
  38. Minz_Session::_param('currentUser', $myUser);
  39. $freshRSS->init();
  40. $freshRSS->run();
  41. invalidateHttpCache();
  42. Minz_Session::unset_session(true);
  43. Minz_ModelPdo::clean();
  44. }
  45. syslog(LOG_INFO, 'FreshRSS actualize done.');
  46. ob_end_flush();
  47. fwrite(STDOUT, 'Done.' . "\n");