actualize_script.php 1.5 KB

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