lib_rss.php 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864
  1. <?php
  2. if (version_compare(PHP_VERSION, FRESHRSS_MIN_PHP_VERSION, '<')) {
  3. die(sprintf('FreshRSS error: FreshRSS requires PHP %s+!', FRESHRSS_MIN_PHP_VERSION));
  4. }
  5. if (!function_exists('mb_strcut')) {
  6. function mb_strcut($str, $start, $length = null, $encoding = 'UTF-8') {
  7. return substr($str, $start, $length);
  8. }
  9. }
  10. if (!function_exists('str_starts_with')) {
  11. /** Polyfill for PHP <8.0 */
  12. function str_starts_with(string $haystack, string $needle): bool {
  13. return strncmp($haystack, $needle, strlen($needle)) === 0;
  14. }
  15. }
  16. // @phpstan-ignore-next-line
  17. if (COPY_SYSLOG_TO_STDERR) {
  18. openlog('FreshRSS', LOG_CONS | LOG_ODELAY | LOG_PID | LOG_PERROR, LOG_USER);
  19. } else {
  20. openlog('FreshRSS', LOG_CONS | LOG_ODELAY | LOG_PID, LOG_USER);
  21. }
  22. /**
  23. * Build a directory path by concatenating a list of directory names.
  24. *
  25. * @param string ...$path_parts a list of directory names
  26. * @return string corresponding to the final pathname
  27. */
  28. function join_path(...$path_parts): string {
  29. return join(DIRECTORY_SEPARATOR, $path_parts);
  30. }
  31. //<Auto-loading>
  32. function classAutoloader($class) {
  33. if (strpos($class, 'FreshRSS') === 0) {
  34. $components = explode('_', $class);
  35. switch (count($components)) {
  36. case 1:
  37. include(APP_PATH . '/' . $components[0] . '.php');
  38. return;
  39. case 2:
  40. include(APP_PATH . '/Models/' . $components[1] . '.php');
  41. return;
  42. case 3: //Controllers, Exceptions
  43. include(APP_PATH . '/' . $components[2] . 's/' . $components[1] . $components[2] . '.php');
  44. return;
  45. }
  46. } elseif (strpos($class, 'Minz') === 0) {
  47. include(LIB_PATH . '/' . str_replace('_', '/', $class) . '.php');
  48. } elseif (strpos($class, 'SimplePie') === 0) {
  49. include(LIB_PATH . '/SimplePie/' . str_replace('_', '/', $class) . '.php');
  50. } elseif (str_starts_with($class, 'Gt\\CssXPath\\')) {
  51. $prefix = 'Gt\\CssXPath\\';
  52. $base_dir = LIB_PATH . '/phpgt/cssxpath/src/';
  53. $relative_class_name = substr($class, strlen($prefix));
  54. require $base_dir . str_replace('\\', '/', $relative_class_name) . '.php';
  55. } elseif (str_starts_with($class, 'PHPMailer\\PHPMailer\\')) {
  56. $prefix = 'PHPMailer\\PHPMailer\\';
  57. $base_dir = LIB_PATH . '/phpmailer/phpmailer/src/';
  58. $relative_class_name = substr($class, strlen($prefix));
  59. require $base_dir . str_replace('\\', '/', $relative_class_name) . '.php';
  60. }
  61. }
  62. spl_autoload_register('classAutoloader');
  63. //</Auto-loading>
  64. /**
  65. * @param string $url
  66. * @return string
  67. */
  68. function idn_to_puny($url) {
  69. if (function_exists('idn_to_ascii')) {
  70. $idn = parse_url($url, PHP_URL_HOST);
  71. if ($idn != '') {
  72. // https://wiki.php.net/rfc/deprecate-and-remove-intl_idna_variant_2003
  73. if (defined('INTL_IDNA_VARIANT_UTS46')) {
  74. $puny = idn_to_ascii($idn, IDNA_DEFAULT, INTL_IDNA_VARIANT_UTS46);
  75. } elseif (defined('INTL_IDNA_VARIANT_2003')) {
  76. $puny = idn_to_ascii($idn, IDNA_DEFAULT, INTL_IDNA_VARIANT_2003);
  77. } else {
  78. $puny = idn_to_ascii($idn);
  79. }
  80. $pos = strpos($url, $idn);
  81. if ($puny != '' && $pos !== false) {
  82. $url = substr_replace($url, $puny, $pos, strlen($idn));
  83. }
  84. }
  85. }
  86. return $url;
  87. }
  88. /**
  89. * @param string $url
  90. * @param bool $fixScheme
  91. * @return string|false
  92. */
  93. function checkUrl($url, $fixScheme = true) {
  94. $url = trim($url);
  95. if ($url == '') {
  96. return '';
  97. }
  98. if ($fixScheme && !preg_match('#^https?://#i', $url)) {
  99. $url = 'https://' . ltrim($url, '/');
  100. }
  101. $url = idn_to_puny($url); //PHP bug #53474 IDN
  102. $urlRelaxed = str_replace('_', 'z', $url); //PHP discussion #64948 Underscore
  103. if (filter_var($urlRelaxed, FILTER_VALIDATE_URL)) {
  104. return $url;
  105. } else {
  106. return false;
  107. }
  108. }
  109. /**
  110. * @param string $text
  111. * @return string
  112. */
  113. function safe_ascii($text) {
  114. return filter_var($text, FILTER_DEFAULT, FILTER_FLAG_STRIP_LOW | FILTER_FLAG_STRIP_HIGH);
  115. }
  116. if (function_exists('mb_convert_encoding')) {
  117. /**
  118. * @param string $text
  119. * @return string
  120. */
  121. function safe_utf8($text) {
  122. return mb_convert_encoding($text, 'UTF-8', 'UTF-8');
  123. }
  124. } elseif (function_exists('iconv')) {
  125. /**
  126. * @param string $text
  127. * @return string
  128. */
  129. function safe_utf8($text) {
  130. return iconv('UTF-8', 'UTF-8//IGNORE', $text);
  131. }
  132. } else {
  133. /**
  134. * @param string $text
  135. * @return string
  136. */
  137. function safe_utf8($text) {
  138. return $text;
  139. }
  140. }
  141. /**
  142. * @param string $text
  143. * @param bool $extended
  144. * @return string
  145. */
  146. function escapeToUnicodeAlternative($text, $extended = true) {
  147. $text = htmlspecialchars_decode($text, ENT_QUOTES);
  148. //Problematic characters
  149. $problem = array('&', '<', '>');
  150. //Use their fullwidth Unicode form instead:
  151. $replace = array('&', '<', '>');
  152. // https://raw.githubusercontent.com/mihaip/google-reader-api/master/wiki/StreamId.wiki
  153. if ($extended) {
  154. $problem += array("'", '"', '^', '?', '\\', '/', ',', ';');
  155. $replace += array("’", '"', '^', '?', '\', '/', ',', ';');
  156. }
  157. return trim(str_replace($problem, $replace, $text));
  158. }
  159. function format_number($n, $precision = 0) {
  160. // number_format does not seem to be Unicode-compatible
  161. return str_replace(' ', ' ', // Thin non-breaking space
  162. number_format($n, $precision, '.', ' ')
  163. );
  164. }
  165. function format_bytes($bytes, $precision = 2, $system = 'IEC') {
  166. if ($system === 'IEC') {
  167. $base = 1024;
  168. $units = array('B', 'KiB', 'MiB', 'GiB', 'TiB');
  169. } elseif ($system === 'SI') {
  170. $base = 1000;
  171. $units = array('B', 'KB', 'MB', 'GB', 'TB');
  172. } else {
  173. return format_number($bytes, $precision);
  174. }
  175. $bytes = max(intval($bytes), 0);
  176. $pow = $bytes === 0 ? 0 : floor(log($bytes) / log($base));
  177. $pow = min($pow, count($units) - 1);
  178. $bytes /= pow($base, $pow);
  179. return format_number($bytes, $precision) . ' ' . $units[$pow];
  180. }
  181. function timestamptodate ($t, $hour = true) {
  182. $month = _t('gen.date.' . date('M', $t));
  183. if ($hour) {
  184. $date = _t('gen.date.format_date_hour', $month);
  185. } else {
  186. $date = _t('gen.date.format_date', $month);
  187. }
  188. return @date ($date, $t);
  189. }
  190. /**
  191. * Decode HTML entities but preserve XML entities.
  192. * @param string|null $text
  193. */
  194. function html_only_entity_decode($text): string {
  195. static $htmlEntitiesOnly = null;
  196. if ($htmlEntitiesOnly === null) {
  197. $htmlEntitiesOnly = array_flip(array_diff(
  198. get_html_translation_table(HTML_ENTITIES, ENT_NOQUOTES, 'UTF-8'), //Decode HTML entities
  199. get_html_translation_table(HTML_SPECIALCHARS, ENT_NOQUOTES, 'UTF-8') //Preserve XML entities
  200. ));
  201. }
  202. return $text == '' ? '' : strtr($text, $htmlEntitiesOnly);
  203. }
  204. /**
  205. * Remove passwords in FreshRSS logs.
  206. * See also ../cli/sensitive-log.sh for Web server logs.
  207. * @param array<string,mixed>|string $log
  208. * @return array<string,mixed>|string
  209. */
  210. function sensitive_log($log) {
  211. if (is_array($log)) {
  212. foreach ($log as $k => $v) {
  213. if (in_array($k, ['api_key', 'Passwd', 'T'])) {
  214. $log[$k] = '██';
  215. } else {
  216. $log[$k] = sensitive_log($v);
  217. }
  218. }
  219. } elseif (is_string($log)) {
  220. $log = preg_replace([
  221. '/\b(auth=.*?\/)[^&]+/i',
  222. '/\b(Passwd=)[^&]+/i',
  223. '/\b(Authorization)[^&]+/i',
  224. ], '$1█', $log);
  225. }
  226. return $log;
  227. }
  228. /**
  229. * @param array<string,mixed> $attributes
  230. */
  231. function customSimplePie($attributes = array()): SimplePie {
  232. $limits = FreshRSS_Context::$system_conf->limits;
  233. $simplePie = new SimplePie();
  234. $simplePie->set_useragent(FRESHRSS_USERAGENT);
  235. $simplePie->set_syslog(FreshRSS_Context::$system_conf->simplepie_syslog_enabled);
  236. $simplePie->set_cache_name_function('sha1');
  237. $simplePie->set_cache_location(CACHE_PATH);
  238. $simplePie->set_cache_duration($limits['cache_duration']);
  239. $simplePie->enable_order_by_date(false);
  240. $feed_timeout = empty($attributes['timeout']) ? 0 : intval($attributes['timeout']);
  241. $simplePie->set_timeout($feed_timeout > 0 ? $feed_timeout : $limits['timeout']);
  242. $curl_options = FreshRSS_Context::$system_conf->curl_options;
  243. if (isset($attributes['ssl_verify'])) {
  244. $curl_options[CURLOPT_SSL_VERIFYHOST] = $attributes['ssl_verify'] ? 2 : 0;
  245. $curl_options[CURLOPT_SSL_VERIFYPEER] = $attributes['ssl_verify'] ? true : false;
  246. if (!$attributes['ssl_verify']) {
  247. $curl_options[CURLOPT_SSL_CIPHER_LIST] = 'DEFAULT@SECLEVEL=1';
  248. }
  249. }
  250. if (!empty($attributes['curl_params']) && is_array($attributes['curl_params'])) {
  251. foreach ($attributes['curl_params'] as $co => $v) {
  252. $curl_options[$co] = $v;
  253. }
  254. }
  255. $simplePie->set_curl_options($curl_options);
  256. $simplePie->strip_comments(true);
  257. $simplePie->strip_htmltags(array(
  258. 'base', 'blink', 'body', 'doctype', 'embed',
  259. 'font', 'form', 'frame', 'frameset', 'html',
  260. 'link', 'input', 'marquee', 'meta', 'noscript',
  261. 'object', 'param', 'plaintext', 'script', 'style',
  262. 'svg', //TODO: Support SVG after sanitizing and URL rewriting of xlink:href
  263. ));
  264. $simplePie->rename_attributes(array('id', 'class'));
  265. $simplePie->strip_attributes(array_merge($simplePie->strip_attributes, array(
  266. 'autoplay', 'class', 'onload', 'onunload', 'onclick', 'ondblclick', 'onmousedown', 'onmouseup',
  267. 'onmouseover', 'onmousemove', 'onmouseout', 'onfocus', 'onblur',
  268. 'onkeypress', 'onkeydown', 'onkeyup', 'onselect', 'onchange', 'seamless', 'sizes', 'srcset')));
  269. $simplePie->add_attributes(array(
  270. 'audio' => array('controls' => 'controls', 'preload' => 'none'),
  271. 'iframe' => array('sandbox' => 'allow-scripts allow-same-origin'),
  272. 'video' => array('controls' => 'controls', 'preload' => 'none'),
  273. ));
  274. $simplePie->set_url_replacements(array(
  275. 'a' => 'href',
  276. 'area' => 'href',
  277. 'audio' => 'src',
  278. 'blockquote' => 'cite',
  279. 'del' => 'cite',
  280. 'form' => 'action',
  281. 'iframe' => 'src',
  282. 'img' => array(
  283. 'longdesc',
  284. 'src'
  285. ),
  286. 'input' => 'src',
  287. 'ins' => 'cite',
  288. 'q' => 'cite',
  289. 'source' => 'src',
  290. 'track' => 'src',
  291. 'video' => array(
  292. 'poster',
  293. 'src',
  294. ),
  295. ));
  296. $https_domains = array();
  297. $force = @file(FRESHRSS_PATH . '/force-https.default.txt', FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES);
  298. if (is_array($force)) {
  299. $https_domains = array_merge($https_domains, $force);
  300. }
  301. $force = @file(DATA_PATH . '/force-https.txt', FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES);
  302. if (is_array($force)) {
  303. $https_domains = array_merge($https_domains, $force);
  304. }
  305. $simplePie->set_https_domains($https_domains);
  306. return $simplePie;
  307. }
  308. /**
  309. * @param int|false $maxLength
  310. */
  311. function sanitizeHTML($data, string $base = '', $maxLength = false) {
  312. if (!is_string($data) || ($maxLength !== false && $maxLength <= 0)) {
  313. return '';
  314. }
  315. if ($maxLength !== false) {
  316. $data = mb_strcut($data, 0, $maxLength, 'UTF-8');
  317. }
  318. static $simplePie = null;
  319. if ($simplePie == null) {
  320. $simplePie = customSimplePie();
  321. $simplePie->init();
  322. }
  323. $result = html_only_entity_decode($simplePie->sanitize->sanitize($data, SIMPLEPIE_CONSTRUCT_HTML, $base));
  324. if ($maxLength !== false && strlen($result) > $maxLength) {
  325. //Sanitizing has made the result too long so try again shorter
  326. $data = mb_strcut($result, 0, (2 * $maxLength) - strlen($result) - 2, 'UTF-8');
  327. return sanitizeHTML($data, $base, $maxLength);
  328. }
  329. return $result;
  330. }
  331. function cleanCache(int $hours = 720) {
  332. // N.B.: GLOB_BRACE is not available on all platforms
  333. $files = array_merge(glob(CACHE_PATH . '/*.html', GLOB_NOSORT), glob(CACHE_PATH . '/*.spc', GLOB_NOSORT));
  334. foreach ($files as $file) {
  335. if (substr($file, -10) === 'index.html') {
  336. continue;
  337. }
  338. $cacheMtime = @filemtime($file);
  339. if ($cacheMtime !== false && $cacheMtime < time() - (3600 * $hours)) {
  340. unlink($file);
  341. }
  342. }
  343. }
  344. /**
  345. * Set an XML preamble to enforce the HTML content type charset received by HTTP.
  346. * @param string $html the row downloaded HTML content
  347. * @param string $contentType an HTTP Content-Type such as 'text/html; charset=utf-8'
  348. * @return string an HTML string with XML encoding information for DOMDocument::loadHTML()
  349. */
  350. function enforceHttpEncoding(string $html, string $contentType = ''): string {
  351. $httpCharset = preg_match('/\bcharset=([0-9a-z_-]{2,12})$/i', $contentType, $matches) === 1 ? $matches[1] : '';
  352. if ($httpCharset == '') {
  353. // No charset defined by HTTP, do nothing
  354. return $html;
  355. }
  356. $httpCharsetNormalized = SimplePie_Misc::encoding($httpCharset);
  357. if ($httpCharsetNormalized === 'windows-1252') {
  358. // Default charset for HTTP, do nothing
  359. return $html;
  360. }
  361. if (substr($html, 0, 3) === "\xEF\xBB\xBF" || // UTF-8 BOM
  362. substr($html, 0, 2) === "\xFF\xFE" || // UTF-16 Little Endian BOM
  363. substr($html, 0, 2) === "\xFE\xFF" || // UTF-16 Big Endian BOM
  364. substr($html, 0, 4) === "\xFF\xFE\x00\x00" || // UTF-32 Little Endian BOM
  365. substr($html, 0, 4) === "\x00\x00\xFE\xFF") { // UTF-32 Big Endian BOM
  366. // Existing byte order mark, do nothing
  367. return $html;
  368. }
  369. if (preg_match('/^<[?]xml[^>]+encoding\b/', substr($html, 0, 64))) {
  370. // Existing XML declaration, do nothing
  371. return $html;
  372. }
  373. return '<' . '?xml version="1.0" encoding="' . $httpCharsetNormalized . '" ?' . ">\n" . $html;
  374. }
  375. /**
  376. * @param string $type {html,opml}
  377. * @param array<string,mixed> $attributes
  378. */
  379. function httpGet(string $url, string $cachePath, string $type = 'html', array $attributes = []): string {
  380. $limits = FreshRSS_Context::$system_conf->limits;
  381. $feed_timeout = empty($attributes['timeout']) ? 0 : intval($attributes['timeout']);
  382. $cacheMtime = @filemtime($cachePath);
  383. if ($cacheMtime !== false && $cacheMtime > time() - intval($limits['cache_duration'])) {
  384. $body = @file_get_contents($cachePath);
  385. if ($body != '') {
  386. syslog(LOG_DEBUG, 'FreshRSS uses cache for ' . SimplePie_Misc::url_remove_credentials($url));
  387. return $body;
  388. }
  389. }
  390. if (mt_rand(0, 30) === 1) { // Remove old entries once in a while
  391. cleanCache();
  392. }
  393. if (FreshRSS_Context::$system_conf->simplepie_syslog_enabled) {
  394. syslog(LOG_INFO, 'FreshRSS GET ' . $type . ' ' . SimplePie_Misc::url_remove_credentials($url));
  395. }
  396. $accept = '*/*;q=0.8';
  397. switch ($type) {
  398. case 'opml':
  399. $accept = 'text/x-opml,text/xml;q=0.9,application/xml;q=0.9,*/*;q=0.8';
  400. break;
  401. case 'html':
  402. default:
  403. $accept = 'text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8';
  404. break;
  405. }
  406. // TODO: Implement HTTP 1.1 conditional GET If-Modified-Since
  407. $ch = curl_init();
  408. curl_setopt_array($ch, [
  409. CURLOPT_URL => $url,
  410. CURLOPT_HTTPHEADER => array('Accept: ' . $accept),
  411. CURLOPT_USERAGENT => FRESHRSS_USERAGENT,
  412. CURLOPT_CONNECTTIMEOUT => $feed_timeout > 0 ? $feed_timeout : $limits['timeout'],
  413. CURLOPT_TIMEOUT => $feed_timeout > 0 ? $feed_timeout : $limits['timeout'],
  414. CURLOPT_MAXREDIRS => 4,
  415. CURLOPT_RETURNTRANSFER => true,
  416. CURLOPT_FOLLOWLOCATION => true,
  417. CURLOPT_ENCODING => '', //Enable all encodings
  418. ]);
  419. curl_setopt_array($ch, FreshRSS_Context::$system_conf->curl_options);
  420. if (isset($attributes['curl_params']) && is_array($attributes['curl_params'])) {
  421. curl_setopt_array($ch, $attributes['curl_params']);
  422. }
  423. if (isset($attributes['ssl_verify'])) {
  424. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, $attributes['ssl_verify'] ? 2 : 0);
  425. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, $attributes['ssl_verify'] ? true : false);
  426. if (!$attributes['ssl_verify']) {
  427. curl_setopt($ch, CURLOPT_SSL_CIPHER_LIST, 'DEFAULT@SECLEVEL=1');
  428. }
  429. }
  430. $body = curl_exec($ch);
  431. $c_status = curl_getinfo($ch, CURLINFO_HTTP_CODE);
  432. $c_content_type = curl_getinfo($ch, CURLINFO_CONTENT_TYPE); //TODO: Check if that may be null
  433. $c_error = curl_error($ch);
  434. curl_close($ch);
  435. if ($c_status != 200 || $c_error != '' || $body === false) {
  436. Minz_Log::warning('Error fetching content: HTTP code ' . $c_status . ': ' . $c_error . ' ' . $url);
  437. $body = '';
  438. // TODO: Implement HTTP 410 Gone
  439. }
  440. if ($body == false) {
  441. $body = '';
  442. } else {
  443. $body = enforceHttpEncoding($body, $c_content_type);
  444. }
  445. if (file_put_contents($cachePath, $body) === false) {
  446. Minz_Log::warning("Error saving cache $cachePath for $url");
  447. }
  448. return $body;
  449. }
  450. /**
  451. * Validate an email address, supports internationalized addresses.
  452. *
  453. * @param string $email The address to validate
  454. *
  455. * @return bool true if email is valid, else false
  456. */
  457. function validateEmailAddress($email) {
  458. $mailer = new PHPMailer\PHPMailer\PHPMailer();
  459. $mailer->CharSet = 'utf-8';
  460. $punyemail = $mailer->punyencodeAddress($email);
  461. return PHPMailer\PHPMailer\PHPMailer::validateAddress($punyemail, 'html5');
  462. }
  463. /**
  464. * Add support of image lazy loading
  465. * Move content from src attribute to data-original
  466. * @param string $content is the text we want to parse
  467. * @return string
  468. */
  469. function lazyimg($content) {
  470. return preg_replace([
  471. '/<((?:img|iframe)[^>]+?)src="([^"]+)"([^>]*)>/i',
  472. "/<((?:img|iframe)[^>]+?)src='([^']+)'([^>]*)>/i",
  473. ], [
  474. '<$1src="' . Minz_Url::display('/themes/icons/grey.gif') . '" data-original="$2"$3>',
  475. "<$1src='" . Minz_Url::display('/themes/icons/grey.gif') . "' data-original='$2'$3>",
  476. ],
  477. $content
  478. );
  479. }
  480. /**
  481. * @return string
  482. */
  483. function uTimeString() {
  484. $t = @gettimeofday();
  485. return $t['sec'] . str_pad('' . $t['usec'], 6, '0', STR_PAD_LEFT);
  486. }
  487. function invalidateHttpCache($username = '') {
  488. if (!FreshRSS_user_Controller::checkUsername($username)) {
  489. Minz_Session::_param('touch', uTimeString());
  490. $username = Minz_Session::param('currentUser', '_');
  491. }
  492. $ok = @touch(DATA_PATH . '/users/' . $username . '/' . LOG_FILENAME);
  493. //if (!$ok) {
  494. //TODO: Display notification error on front-end
  495. //}
  496. return $ok;
  497. }
  498. /**
  499. * @return array<string>
  500. */
  501. function listUsers() {
  502. $final_list = array();
  503. $base_path = join_path(DATA_PATH, 'users');
  504. $dir_list = array_values(array_diff(
  505. scandir($base_path),
  506. array('..', '.', '_')
  507. ));
  508. foreach ($dir_list as $file) {
  509. if ($file[0] !== '.' && is_dir(join_path($base_path, $file)) && file_exists(join_path($base_path, $file, 'config.php'))) {
  510. $final_list[] = $file;
  511. }
  512. }
  513. return $final_list;
  514. }
  515. /**
  516. * Return if the maximum number of registrations has been reached.
  517. *
  518. * Note a max_regstrations of 0 means there is no limit.
  519. *
  520. * @return boolean true if number of users >= max registrations, false else.
  521. */
  522. function max_registrations_reached() {
  523. $limit_registrations = FreshRSS_Context::$system_conf->limits['max_registrations'];
  524. $number_accounts = count(listUsers());
  525. return $limit_registrations > 0 && $number_accounts >= $limit_registrations;
  526. }
  527. /**
  528. * Register and return the configuration for a given user.
  529. *
  530. * Note this function has been created to generate temporary configuration
  531. * objects. If you need a long-time configuration, please don't use this function.
  532. *
  533. * @param string $username the name of the user of which we want the configuration.
  534. * @return FreshRSS_UserConfiguration|null object, or null if the configuration cannot be loaded.
  535. */
  536. function get_user_configuration($username) {
  537. if (!FreshRSS_user_Controller::checkUsername($username)) {
  538. return null;
  539. }
  540. $namespace = 'user_' . $username;
  541. try {
  542. Minz_Configuration::register($namespace,
  543. USERS_PATH . '/' . $username . '/config.php',
  544. FRESHRSS_PATH . '/config-user.default.php');
  545. } catch (Minz_ConfigurationNamespaceException $e) {
  546. // namespace already exists, do nothing.
  547. Minz_Log::warning($e->getMessage(), ADMIN_LOG);
  548. } catch (Minz_FileNotExistException $e) {
  549. Minz_Log::warning($e->getMessage(), ADMIN_LOG);
  550. return null;
  551. }
  552. /**
  553. * @var FreshRSS_UserConfiguration $user_conf
  554. */
  555. $user_conf = Minz_Configuration::get($namespace);
  556. return $user_conf;
  557. }
  558. /**
  559. * Converts an IP (v4 or v6) to a binary representation using inet_pton
  560. *
  561. * @param string $ip the IP to convert
  562. * @return string a binary representation of the specified IP
  563. */
  564. function ipToBits(string $ip): string {
  565. $binaryip = '';
  566. foreach (str_split(inet_pton($ip)) as $char) {
  567. $binaryip .= str_pad(decbin(ord($char)), 8, '0', STR_PAD_LEFT);
  568. }
  569. return $binaryip;
  570. }
  571. /**
  572. * Check if an ip belongs to the provided range (in CIDR format)
  573. *
  574. * @param string $ip the IP that we want to verify (ex: 192.168.16.1)
  575. * @param string $range the range to check against (ex: 192.168.16.0/24)
  576. * @return boolean true if the IP is in the range, otherwise false
  577. */
  578. function checkCIDR(string $ip, string $range): bool {
  579. $binary_ip = ipToBits($ip);
  580. list($subnet, $mask_bits) = explode('/', $range);
  581. $mask_bits = intval($mask_bits);
  582. $binary_subnet = ipToBits($subnet);
  583. $ip_net_bits = substr($binary_ip, 0, $mask_bits);
  584. $subnet_bits = substr($binary_subnet, 0, $mask_bits);
  585. return $ip_net_bits === $subnet_bits;
  586. }
  587. /**
  588. * Check if the client is allowed to send unsafe headers
  589. * This uses the REMOTE_ADDR header to determine the sender's IP
  590. * and the configuration option "trusted_sources" to get an array of the authorized ranges
  591. *
  592. * @return boolean, true if the sender's IP is in one of the ranges defined in the configuration, else false
  593. */
  594. function checkTrustedIP(): bool {
  595. if (!empty($_SERVER['REMOTE_ADDR'])) {
  596. foreach (FreshRSS_Context::$system_conf->trusted_sources as $cidr) {
  597. if (checkCIDR($_SERVER['REMOTE_ADDR'], $cidr)) {
  598. return true;
  599. }
  600. }
  601. }
  602. return false;
  603. }
  604. /**
  605. * @return string
  606. */
  607. function httpAuthUser() {
  608. if (!empty($_SERVER['REMOTE_USER'])) {
  609. return $_SERVER['REMOTE_USER'];
  610. } elseif (!empty($_SERVER['HTTP_REMOTE_USER']) && checkTrustedIP()) {
  611. return $_SERVER['HTTP_REMOTE_USER'];
  612. } elseif (!empty($_SERVER['REDIRECT_REMOTE_USER'])) {
  613. return $_SERVER['REDIRECT_REMOTE_USER'];
  614. } elseif (!empty($_SERVER['HTTP_X_WEBAUTH_USER']) && checkTrustedIP()) {
  615. return $_SERVER['HTTP_X_WEBAUTH_USER'];
  616. }
  617. return '';
  618. }
  619. /**
  620. * @return bool
  621. */
  622. function cryptAvailable() {
  623. try {
  624. $hash = '$2y$04$usesomesillystringfore7hnbRJHxXVLeakoG8K30oukPsA.ztMG';
  625. return $hash === @crypt('password', $hash);
  626. } catch (Exception $e) {
  627. Minz_Log::warning($e->getMessage());
  628. }
  629. return false;
  630. }
  631. /**
  632. * Check PHP and its extensions are well-installed.
  633. *
  634. * @return array<string,bool> of tested values.
  635. */
  636. function check_install_php() {
  637. $pdo_mysql = extension_loaded('pdo_mysql');
  638. $pdo_pgsql = extension_loaded('pdo_pgsql');
  639. $pdo_sqlite = extension_loaded('pdo_sqlite');
  640. return array(
  641. 'php' => version_compare(PHP_VERSION, FRESHRSS_MIN_PHP_VERSION) >= 0,
  642. 'curl' => extension_loaded('curl'),
  643. 'pdo' => $pdo_mysql || $pdo_sqlite || $pdo_pgsql,
  644. 'pcre' => extension_loaded('pcre'),
  645. 'ctype' => extension_loaded('ctype'),
  646. 'fileinfo' => extension_loaded('fileinfo'),
  647. 'dom' => class_exists('DOMDocument'),
  648. 'json' => extension_loaded('json'),
  649. 'mbstring' => extension_loaded('mbstring'),
  650. 'zip' => extension_loaded('zip'),
  651. );
  652. }
  653. /**
  654. * Check different data files and directories exist.
  655. *
  656. * @return array<string,bool> of tested values.
  657. */
  658. function check_install_files() {
  659. return array(
  660. // @phpstan-ignore-next-line
  661. 'data' => DATA_PATH && touch(DATA_PATH . '/index.html'), // is_writable() is not reliable for a folder on NFS
  662. // @phpstan-ignore-next-line
  663. 'cache' => CACHE_PATH && touch(CACHE_PATH . '/index.html'),
  664. // @phpstan-ignore-next-line
  665. 'users' => USERS_PATH && touch(USERS_PATH . '/index.html'),
  666. 'favicons' => touch(DATA_PATH . '/favicons/index.html'),
  667. 'tokens' => touch(DATA_PATH . '/tokens/index.html'),
  668. );
  669. }
  670. /**
  671. * Check database is well-installed.
  672. *
  673. * @return array<string,bool> of tested values.
  674. */
  675. function check_install_database() {
  676. $status = array(
  677. 'connection' => true,
  678. 'tables' => false,
  679. 'categories' => false,
  680. 'feeds' => false,
  681. 'entries' => false,
  682. 'entrytmp' => false,
  683. 'tag' => false,
  684. 'entrytag' => false,
  685. );
  686. try {
  687. $dbDAO = FreshRSS_Factory::createDatabaseDAO();
  688. $status['tables'] = $dbDAO->tablesAreCorrect();
  689. $status['categories'] = $dbDAO->categoryIsCorrect();
  690. $status['feeds'] = $dbDAO->feedIsCorrect();
  691. $status['entries'] = $dbDAO->entryIsCorrect();
  692. $status['entrytmp'] = $dbDAO->entrytmpIsCorrect();
  693. $status['tag'] = $dbDAO->tagIsCorrect();
  694. $status['entrytag'] = $dbDAO->entrytagIsCorrect();
  695. } catch(Minz_PDOConnectionException $e) {
  696. $status['connection'] = false;
  697. }
  698. return $status;
  699. }
  700. /**
  701. * Remove a directory recursively.
  702. *
  703. * From http://php.net/rmdir#110489
  704. *
  705. * @param string $dir the directory to remove
  706. */
  707. function recursive_unlink($dir) {
  708. if (!is_dir($dir)) {
  709. return true;
  710. }
  711. $files = array_diff(scandir($dir), array('.', '..'));
  712. foreach ($files as $filename) {
  713. $filename = $dir . '/' . $filename;
  714. if (is_dir($filename)) {
  715. @chmod($filename, 0777);
  716. recursive_unlink($filename);
  717. } else {
  718. unlink($filename);
  719. }
  720. }
  721. return rmdir($dir);
  722. }
  723. /**
  724. * Remove queries where $get is appearing.
  725. * @param string $get the get attribute which should be removed.
  726. * @param array<int,array<string,string>> $queries an array of queries.
  727. * @return array<int,array<string,string>> without queries where $get is appearing.
  728. */
  729. function remove_query_by_get($get, $queries) {
  730. $final_queries = array();
  731. foreach ($queries as $key => $query) {
  732. if (empty($query['get']) || $query['get'] !== $get) {
  733. $final_queries[$key] = $query;
  734. }
  735. }
  736. return $final_queries;
  737. }
  738. function _i(string $icon, int $type = FreshRSS_Themes::ICON_DEFAULT): string {
  739. return FreshRSS_Themes::icon($icon, $type);
  740. }
  741. const SHORTCUT_KEYS = [
  742. '0', '1', '2', '3', '4', '5', '6', '7', '8', '9',
  743. 'a', 'b', 'c', 'd', 'e', 'f', 'g', 'h', 'i', 'j', 'k', 'l', 'm',
  744. 'n', 'o', 'p', 'q', 'r', 's', 't', 'u', 'v', 'w', 'x', 'y', 'z',
  745. 'F1', 'F2', 'F3', 'F4', 'F5', 'F6', 'F7', 'F8', 'F9', 'F10', 'F11', 'F12',
  746. 'ArrowDown', 'ArrowLeft', 'ArrowRight', 'ArrowUp', 'Backspace', 'Delete',
  747. 'End', 'Enter', 'Escape', 'Home', 'Insert', 'PageDown', 'PageUp', 'Space', 'Tab',
  748. ];
  749. function getNonStandardShortcuts($shortcuts) {
  750. $standard = strtolower(implode(' ', SHORTCUT_KEYS));
  751. $nonStandard = array_filter($shortcuts, function ($shortcut) use ($standard) {
  752. $shortcut = trim($shortcut);
  753. return $shortcut !== '' & stripos($standard, $shortcut) === false;
  754. });
  755. return $nonStandard;
  756. }
  757. function errorMessageInfo($errorTitle, $error = '') {
  758. $errorTitle = htmlspecialchars($errorTitle, ENT_NOQUOTES, 'UTF-8');
  759. $message = '';
  760. $details = '';
  761. // Prevent empty tags by checking if error isn not empty first
  762. if ($error) {
  763. $error = htmlspecialchars($error, ENT_NOQUOTES, 'UTF-8');
  764. // First line is the main message, other lines are the details
  765. list($message, $details) = explode("\n", $error, 2);
  766. $message = "<h2>{$message}</h2>";
  767. $details = "<pre>{$details}</pre>";
  768. }
  769. header("Content-Security-Policy: default-src 'self'");
  770. return <<<MSG
  771. <!DOCTYPE html><html><header><title>HTTP 500: {$errorTitle}</title></header><body>
  772. <h1>HTTP 500: {$errorTitle}</h1>
  773. {$message}
  774. {$details}
  775. <hr />
  776. <small>For help see the documentation: <a href="https://freshrss.github.io/FreshRSS/en/admins/logs_and_errors.html" target="_blank">
  777. https://freshrss.github.io/FreshRSS/en/admins/logs_and_errors.html</a></small>
  778. </body></html>
  779. MSG;
  780. }