lib_rss.php 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432
  1. <?php
  2. if (!function_exists('json_decode')) {
  3. require_once('JSON.php');
  4. function json_decode($var) {
  5. $JSON = new Services_JSON;
  6. return (array)($JSON->decode($var));
  7. }
  8. }
  9. if (!function_exists('json_encode')) {
  10. require_once('JSON.php');
  11. function json_encode($var) {
  12. $JSON = new Services_JSON;
  13. return $JSON->encodeUnsafe($var);
  14. }
  15. }
  16. /**
  17. * Build a directory path by concatenating a list of directory names.
  18. *
  19. * @param $path_parts a list of directory names
  20. * @return a string corresponding to the final pathname
  21. */
  22. function join_path() {
  23. $path_parts = func_get_args();
  24. return join(DIRECTORY_SEPARATOR, $path_parts);
  25. }
  26. //<Auto-loading>
  27. function classAutoloader($class) {
  28. if (strpos($class, 'FreshRSS') === 0) {
  29. $components = explode('_', $class);
  30. switch (count($components)) {
  31. case 1:
  32. include(APP_PATH . '/' . $components[0] . '.php');
  33. return;
  34. case 2:
  35. include(APP_PATH . '/Models/' . $components[1] . '.php');
  36. return;
  37. case 3: //Controllers, Exceptions
  38. @include(APP_PATH . '/' . $components[2] . 's/' . $components[1] . $components[2] . '.php');
  39. return;
  40. }
  41. } elseif (strpos($class, 'Minz') === 0) {
  42. include(LIB_PATH . '/' . str_replace('_', '/', $class) . '.php');
  43. } elseif (strpos($class, 'SimplePie') === 0) {
  44. include(LIB_PATH . '/SimplePie/' . str_replace('_', '/', $class) . '.php');
  45. }
  46. }
  47. spl_autoload_register('classAutoloader');
  48. //</Auto-loading>
  49. function checkUrl($url) {
  50. if (empty ($url)) {
  51. return '';
  52. }
  53. if (!preg_match ('#^https?://#i', $url)) {
  54. $url = 'http://' . $url;
  55. }
  56. if (filter_var($url, FILTER_VALIDATE_URL) ||
  57. (version_compare(PHP_VERSION, '5.3.3', '<') && (strpos($url, '-') > 0) && //PHP bug #51192
  58. ($url === filter_var($url, FILTER_SANITIZE_URL)))) {
  59. return $url;
  60. } else {
  61. return false;
  62. }
  63. }
  64. function format_number($n, $precision = 0) {
  65. // number_format does not seem to be Unicode-compatible
  66. return str_replace(' ', ' ', //Espace fine insécable
  67. number_format($n, $precision, '.', ' ')
  68. );
  69. }
  70. function format_bytes($bytes, $precision = 2, $system = 'IEC') {
  71. if ($system === 'IEC') {
  72. $base = 1024;
  73. $units = array('B', 'KiB', 'MiB', 'GiB', 'TiB');
  74. } elseif ($system === 'SI') {
  75. $base = 1000;
  76. $units = array('B', 'KB', 'MB', 'GB', 'TB');
  77. }
  78. $bytes = max(intval($bytes), 0);
  79. $pow = $bytes === 0 ? 0 : floor(log($bytes) / log($base));
  80. $pow = min($pow, count($units) - 1);
  81. $bytes /= pow($base, $pow);
  82. return format_number($bytes, $precision) . ' ' . $units[$pow];
  83. }
  84. function timestamptodate ($t, $hour = true) {
  85. $month = _t('gen.date.' . date('M', $t));
  86. if ($hour) {
  87. $date = _t('gen.date.format_date_hour', $month);
  88. } else {
  89. $date = _t('gen.date.format_date', $month);
  90. }
  91. return @date ($date, $t);
  92. }
  93. function html_only_entity_decode($text) {
  94. static $htmlEntitiesOnly = null;
  95. if ($htmlEntitiesOnly === null) {
  96. if (version_compare(PHP_VERSION, '5.3.4') >= 0) {
  97. $htmlEntitiesOnly = array_flip(array_diff(
  98. get_html_translation_table(HTML_ENTITIES, ENT_NOQUOTES, 'UTF-8'), //Decode HTML entities
  99. get_html_translation_table(HTML_SPECIALCHARS, ENT_NOQUOTES, 'UTF-8') //Preserve XML entities
  100. ));
  101. } else {
  102. $htmlEntitiesOnly = array_map('utf8_encode', array_flip(array_diff(
  103. get_html_translation_table(HTML_ENTITIES, ENT_NOQUOTES), //Decode HTML entities
  104. get_html_translation_table(HTML_SPECIALCHARS, ENT_NOQUOTES) //Preserve XML entities
  105. )));
  106. }
  107. }
  108. return strtr($text, $htmlEntitiesOnly);
  109. }
  110. function customSimplePie() {
  111. $system_conf = Minz_Configuration::get('system');
  112. $limits = $system_conf->limits;
  113. $simplePie = new SimplePie();
  114. $simplePie->set_useragent(_t('gen.freshrss') . '/' . FRESHRSS_VERSION . ' (' . PHP_OS . '; ' . FRESHRSS_WEBSITE . ') ' . SIMPLEPIE_NAME . '/' . SIMPLEPIE_VERSION);
  115. $simplePie->set_syslog($system_conf->simplepie_syslog_enabled);
  116. $simplePie->set_cache_location(CACHE_PATH);
  117. $simplePie->set_cache_duration($limits['cache_duration']);
  118. $simplePie->set_timeout($limits['timeout']);
  119. $simplePie->strip_htmltags(array(
  120. 'base', 'blink', 'body', 'doctype', 'embed',
  121. 'font', 'form', 'frame', 'frameset', 'html',
  122. 'link', 'input', 'marquee', 'meta', 'noscript',
  123. 'object', 'param', 'plaintext', 'script', 'style',
  124. ));
  125. $simplePie->strip_attributes(array_merge($simplePie->strip_attributes, array(
  126. 'autoplay', 'onload', 'onunload', 'onclick', 'ondblclick', 'onmousedown', 'onmouseup',
  127. 'onmouseover', 'onmousemove', 'onmouseout', 'onfocus', 'onblur',
  128. 'onkeypress', 'onkeydown', 'onkeyup', 'onselect', 'onchange', 'seamless')));
  129. $simplePie->add_attributes(array(
  130. 'img' => array('lazyload' => '', 'postpone' => ''), //http://www.w3.org/TR/resource-priorities/
  131. 'audio' => array('lazyload' => '', 'postpone' => '', 'preload' => 'none'),
  132. 'iframe' => array('lazyload' => '', 'postpone' => '', 'sandbox' => 'allow-scripts allow-same-origin'),
  133. 'video' => array('lazyload' => '', 'postpone' => '', 'preload' => 'none'),
  134. ));
  135. $simplePie->set_url_replacements(array(
  136. 'a' => 'href',
  137. 'area' => 'href',
  138. 'audio' => 'src',
  139. 'blockquote' => 'cite',
  140. 'del' => 'cite',
  141. 'form' => 'action',
  142. 'iframe' => 'src',
  143. 'img' => array(
  144. 'longdesc',
  145. 'src'
  146. ),
  147. 'input' => 'src',
  148. 'ins' => 'cite',
  149. 'q' => 'cite',
  150. 'source' => 'src',
  151. 'track' => 'src',
  152. 'video' => array(
  153. 'poster',
  154. 'src',
  155. ),
  156. ));
  157. return $simplePie;
  158. }
  159. function sanitizeHTML($data, $base = '') {
  160. static $simplePie = null;
  161. if ($simplePie == null) {
  162. $simplePie = customSimplePie();
  163. $simplePie->init();
  164. }
  165. return html_only_entity_decode($simplePie->sanitize->sanitize($data, SIMPLEPIE_CONSTRUCT_HTML, $base));
  166. }
  167. /* permet de récupérer le contenu d'un article pour un flux qui n'est pas complet */
  168. function get_content_by_parsing ($url, $path) {
  169. require_once (LIB_PATH . '/lib_phpQuery.php');
  170. Minz_Log::notice('FreshRSS GET ' . SimplePie_Misc::url_remove_credentials($url));
  171. $html = file_get_contents ($url);
  172. if ($html) {
  173. $doc = phpQuery::newDocument ($html);
  174. $content = $doc->find ($path);
  175. return sanitizeHTML($content->__toString(), $url);
  176. } else {
  177. throw new Exception ();
  178. }
  179. }
  180. /**
  181. * Add support of image lazy loading
  182. * Move content from src attribute to data-original
  183. * @param content is the text we want to parse
  184. */
  185. function lazyimg($content) {
  186. return preg_replace(
  187. '/<((?:img|iframe)[^>]+?)src=[\'"]([^"\']+)[\'"]([^>]*)>/i',
  188. '<$1src="' . Minz_Url::display('/themes/icons/grey.gif') . '" data-original="$2"$3>',
  189. $content
  190. );
  191. }
  192. function uTimeString() {
  193. $t = @gettimeofday();
  194. return $t['sec'] . str_pad($t['usec'], 6, '0');
  195. }
  196. function uSecString() {
  197. $t = @gettimeofday();
  198. return str_pad($t['usec'], 6, '0');
  199. }
  200. function invalidateHttpCache() {
  201. Minz_Session::_param('touch', uTimeString());
  202. return touch(join_path(DATA_PATH, 'users', Minz_Session::param('currentUser', '_'), 'log.txt'));
  203. }
  204. function listUsers() {
  205. $final_list = array();
  206. $base_path = join_path(DATA_PATH, 'users');
  207. $dir_list = array_values(array_diff(
  208. scandir($base_path),
  209. array('..', '.', '_')
  210. ));
  211. foreach ($dir_list as $file) {
  212. if (is_dir(join_path($base_path, $file))) {
  213. $final_list[] = $file;
  214. }
  215. }
  216. return $final_list;
  217. }
  218. /**
  219. * Register and return the configuration for a given user.
  220. *
  221. * Note this function has been created to generate temporary configuration
  222. * objects. If you need a long-time configuration, please don't use this function.
  223. *
  224. * @param $username the name of the user of which we want the configuration.
  225. * @return a Minz_Configuration object, null if the configuration cannot be loaded.
  226. */
  227. function get_user_configuration($username) {
  228. $namespace = 'user_' . $username;
  229. try {
  230. Minz_Configuration::register($namespace,
  231. join_path(USERS_PATH, $username, 'config.php'),
  232. join_path(USERS_PATH, '_', 'config.default.php'));
  233. } catch (Minz_ConfigurationNamespaceException $e) {
  234. // namespace already exists, do nothing.
  235. } catch (Minz_FileNotExistException $e) {
  236. Minz_Log::warning($e->getMessage());
  237. return null;
  238. }
  239. return Minz_Configuration::get($namespace);
  240. }
  241. function httpAuthUser() {
  242. return isset($_SERVER['REMOTE_USER']) ? $_SERVER['REMOTE_USER'] : '';
  243. }
  244. function cryptAvailable() {
  245. if (version_compare(PHP_VERSION, '5.3.3', '>=')) {
  246. try {
  247. $hash = '$2y$04$usesomesillystringfore7hnbRJHxXVLeakoG8K30oukPsA.ztMG';
  248. return $hash === @crypt('password', $hash);
  249. } catch (Exception $e) {
  250. }
  251. }
  252. return false;
  253. }
  254. function is_referer_from_same_domain() {
  255. if (empty($_SERVER['HTTP_REFERER'])) {
  256. return false;
  257. }
  258. $host = parse_url(((isset($_SERVER['HTTPS']) && $_SERVER['HTTPS'] === 'on') ? 'https://' : 'http://') .
  259. (empty($_SERVER['HTTP_HOST']) ? $_SERVER['SERVER_NAME'] : $_SERVER['HTTP_HOST']));
  260. $referer = parse_url($_SERVER['HTTP_REFERER']);
  261. if (empty($host['host']) || empty($referer['host']) || $host['host'] !== $referer['host']) {
  262. return false;
  263. }
  264. //TODO: check 'scheme', taking into account the case of a proxy
  265. if ((isset($host['port']) ? $host['port'] : 0) !== (isset($referer['port']) ? $referer['port'] : 0)) {
  266. return false;
  267. }
  268. return true;
  269. }
  270. /**
  271. * Check PHP and its extensions are well-installed.
  272. *
  273. * @return array of tested values.
  274. */
  275. function check_install_php() {
  276. $pdo_mysql = extension_loaded('pdo_mysql');
  277. $pdo_sqlite = extension_loaded('pdo_sqlite');
  278. return array(
  279. 'php' => version_compare(PHP_VERSION, '5.2.1') >= 0,
  280. 'minz' => file_exists(LIB_PATH . '/Minz'),
  281. 'curl' => extension_loaded('curl'),
  282. 'pdo' => $pdo_mysql || $pdo_sqlite,
  283. 'pcre' => extension_loaded('pcre'),
  284. 'ctype' => extension_loaded('ctype'),
  285. 'dom' => class_exists('DOMDocument'),
  286. 'json' => extension_loaded('json'),
  287. 'zip' => extension_loaded('zip'),
  288. );
  289. }
  290. /**
  291. * Check different data files and directories exist.
  292. *
  293. * @return array of tested values.
  294. */
  295. function check_install_files() {
  296. return array(
  297. 'data' => DATA_PATH && is_writable(DATA_PATH),
  298. 'cache' => CACHE_PATH && is_writable(CACHE_PATH),
  299. 'users' => USERS_PATH && is_writable(USERS_PATH),
  300. 'favicons' => is_writable(DATA_PATH . '/favicons'),
  301. 'persona' => is_writable(DATA_PATH . '/persona'),
  302. 'tokens' => is_writable(DATA_PATH . '/tokens'),
  303. );
  304. }
  305. /**
  306. * Check database is well-installed.
  307. *
  308. * @return array of tested values.
  309. */
  310. function check_install_database() {
  311. $status = array(
  312. 'connection' => true,
  313. 'tables' => false,
  314. 'categories' => false,
  315. 'feeds' => false,
  316. 'entries' => false,
  317. );
  318. try {
  319. $dbDAO = FreshRSS_Factory::createDatabaseDAO();
  320. $status['tables'] = $dbDAO->tablesAreCorrect();
  321. $status['categories'] = $dbDAO->categoryIsCorrect();
  322. $status['feeds'] = $dbDAO->feedIsCorrect();
  323. $status['entries'] = $dbDAO->entryIsCorrect();
  324. } catch(Minz_PDOConnectionException $e) {
  325. $status['connection'] = false;
  326. }
  327. return $status;
  328. }
  329. /**
  330. * Remove a directory recursively.
  331. *
  332. * From http://php.net/rmdir#110489
  333. *
  334. * @param $dir the directory to remove
  335. */
  336. function recursive_unlink($dir) {
  337. if (!is_dir($dir)) {
  338. return true;
  339. }
  340. $files = array_diff(scandir($dir), array('.', '..'));
  341. foreach ($files as $filename) {
  342. $filename = $dir . '/' . $filename;
  343. if (is_dir($filename)) {
  344. @chmod($filename, 0777);
  345. recursive_unlink($filename);
  346. } else {
  347. unlink($filename);
  348. }
  349. }
  350. return rmdir($dir);
  351. }
  352. /**
  353. * Remove queries where $get is appearing.
  354. * @param $get the get attribute which should be removed.
  355. * @param $queries an array of queries.
  356. * @return the same array whithout those where $get is appearing.
  357. */
  358. function remove_query_by_get($get, $queries) {
  359. $final_queries = array();
  360. foreach ($queries as $key => $query) {
  361. if (empty($query['get']) || $query['get'] !== $get) {
  362. $final_queries[$key] = $query;
  363. }
  364. }
  365. return $final_queries;
  366. }
  367. /**
  368. * Add a value in an array and take care it is unique.
  369. * @param $array the array in which we add the value.
  370. * @param $value the value to add.
  371. */
  372. function array_push_unique(&$array, $value) {
  373. $found = array_search($value, $array) !== false;
  374. if (!$found) {
  375. $array[] = $value;
  376. }
  377. }
  378. /**
  379. * Remove a value from an array.
  380. * @param $array the array from wich value is removed.
  381. * @param $value the value to remove.
  382. */
  383. function array_remove(&$array, $value) {
  384. $array = array_diff($array, array($value));
  385. }