Parser.php 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397
  1. <?php
  2. namespace PicoFeed\Parser;
  3. use PicoFeed\Processor\ContentFilterProcessor;
  4. use PicoFeed\Processor\ContentGeneratorProcessor;
  5. use PicoFeed\Processor\ItemPostProcessor;
  6. use PicoFeed\Processor\ScraperProcessor;
  7. use SimpleXMLElement;
  8. use PicoFeed\Client\Url;
  9. use PicoFeed\Encoding\Encoding;
  10. use PicoFeed\Filter\Filter;
  11. use PicoFeed\Logging\Logger;
  12. /**
  13. * Base parser class.
  14. *
  15. * @package PicoFeed\Parser
  16. * @author Frederic Guillot
  17. */
  18. abstract class Parser implements ParserInterface
  19. {
  20. /**
  21. * Config object.
  22. *
  23. * @var \PicoFeed\Config\Config
  24. */
  25. private $config;
  26. /**
  27. * DateParser object.
  28. *
  29. * @var \PicoFeed\Parser\DateParser
  30. */
  31. private $dateParser;
  32. /**
  33. * Hash algorithm used to generate item id, any value supported by PHP, see hash_algos().
  34. *
  35. * @var string
  36. */
  37. private $hash_algo = 'sha256';
  38. /**
  39. * Feed content (XML data).
  40. *
  41. * @var string
  42. */
  43. protected $content = '';
  44. /**
  45. * Fallback url.
  46. *
  47. * @var string
  48. */
  49. protected $fallback_url = '';
  50. /**
  51. * XML namespaces supported by parser.
  52. *
  53. * @var array
  54. */
  55. protected $namespaces = array();
  56. /**
  57. * XML namespaces used in document.
  58. *
  59. * @var array
  60. */
  61. protected $used_namespaces = array();
  62. /**
  63. * Item Post Processor instance
  64. *
  65. * @access private
  66. * @var ItemPostProcessor
  67. */
  68. private $itemPostProcessor;
  69. /**
  70. * Constructor.
  71. *
  72. * @param string $content Feed content
  73. * @param string $http_encoding HTTP encoding (headers)
  74. * @param string $fallback_url Fallback url when the feed provide relative or broken url
  75. */
  76. public function __construct($content, $http_encoding = '', $fallback_url = '')
  77. {
  78. $this->fallback_url = $fallback_url;
  79. $xml_encoding = XmlParser::getEncodingFromXmlTag($content);
  80. // Strip XML tag to avoid multiple encoding/decoding in the next XML processing
  81. $this->content = Filter::stripXmlTag($content);
  82. // Encode everything in UTF-8
  83. Logger::setMessage(get_called_class().': HTTP Encoding "'.$http_encoding.'" ; XML Encoding "'.$xml_encoding.'"');
  84. $this->content = Encoding::convert($this->content, $xml_encoding ?: $http_encoding);
  85. $this->itemPostProcessor = new ItemPostProcessor($this->config);
  86. $this->itemPostProcessor->register(new ContentGeneratorProcessor($this->config));
  87. $this->itemPostProcessor->register(new ContentFilterProcessor($this->config));
  88. }
  89. /**
  90. * Parse the document.
  91. * @return Feed
  92. * @throws MalformedXmlException
  93. */
  94. public function execute()
  95. {
  96. Logger::setMessage(get_called_class().': begin parsing');
  97. $xml = XmlParser::getSimpleXml($this->content);
  98. if ($xml === false) {
  99. Logger::setMessage(get_called_class().': Applying XML workarounds');
  100. $this->content = Filter::normalizeData($this->content);
  101. $xml = XmlParser::getSimpleXml($this->content);
  102. if ($xml === false) {
  103. Logger::setMessage(get_called_class().': XML parsing error');
  104. Logger::setMessage(XmlParser::getErrors());
  105. throw new MalformedXmlException('XML parsing error');
  106. }
  107. }
  108. $this->used_namespaces = $xml->getNamespaces(true);
  109. $xml = $this->registerSupportedNamespaces($xml);
  110. $feed = new Feed();
  111. $this->findFeedUrl($xml, $feed);
  112. $this->checkFeedUrl($feed);
  113. $this->findSiteUrl($xml, $feed);
  114. $this->checkSiteUrl($feed);
  115. $this->findFeedTitle($xml, $feed);
  116. $this->findFeedDescription($xml, $feed);
  117. $this->findFeedLanguage($xml, $feed);
  118. $this->findFeedId($xml, $feed);
  119. $this->findFeedDate($xml, $feed);
  120. $this->findFeedLogo($xml, $feed);
  121. $this->findFeedIcon($xml, $feed);
  122. foreach ($this->getItemsTree($xml) as $entry) {
  123. $entry = $this->registerSupportedNamespaces($entry);
  124. $item = new Item();
  125. $item->xml = $entry;
  126. $item->namespaces = $this->used_namespaces;
  127. $this->findItemAuthor($xml, $entry, $item);
  128. $this->findItemAuthorUrl($xml, $entry, $item);
  129. $this->findItemUrl($entry, $item);
  130. $this->checkItemUrl($feed, $item);
  131. $this->findItemTitle($entry, $item);
  132. $this->findItemContent($entry, $item);
  133. // Id generation can use the item url/title/content (order is important)
  134. $this->findItemId($entry, $item, $feed);
  135. $this->findItemDate($entry, $item, $feed);
  136. $this->findItemEnclosure($entry, $item, $feed);
  137. $this->findItemLanguage($entry, $item, $feed);
  138. $this->findItemCategories($entry, $item, $feed);
  139. $this->itemPostProcessor->execute($feed, $item);
  140. $feed->items[] = $item;
  141. }
  142. Logger::setMessage(get_called_class().PHP_EOL.$feed);
  143. return $feed;
  144. }
  145. /**
  146. * Check if the feed url is correct.
  147. *
  148. * @param Feed $feed Feed object
  149. */
  150. public function checkFeedUrl(Feed $feed)
  151. {
  152. if ($feed->getFeedUrl() === '') {
  153. $feed->feedUrl = $this->fallback_url;
  154. } else {
  155. $feed->feedUrl = Url::resolve($feed->getFeedUrl(), $this->fallback_url);
  156. }
  157. }
  158. /**
  159. * Check if the site url is correct.
  160. *
  161. * @param Feed $feed Feed object
  162. */
  163. public function checkSiteUrl(Feed $feed)
  164. {
  165. if ($feed->getSiteUrl() === '') {
  166. $feed->siteUrl = Url::base($feed->getFeedUrl());
  167. } else {
  168. $feed->siteUrl = Url::resolve($feed->getSiteUrl(), $this->fallback_url);
  169. }
  170. }
  171. /**
  172. * Check if the item url is correct.
  173. *
  174. * @param Feed $feed Feed object
  175. * @param Item $item Item object
  176. */
  177. public function checkItemUrl(Feed $feed, Item $item)
  178. {
  179. $item->url = Url::resolve($item->getUrl(), $feed->getSiteUrl());
  180. }
  181. /**
  182. * Find the item date.
  183. *
  184. * @param SimpleXMLElement $entry Feed item
  185. * @param Item $item Item object
  186. * @param \PicoFeed\Parser\Feed $feed Feed object
  187. */
  188. public function findItemDate(SimpleXMLElement $entry, Item $item, Feed $feed)
  189. {
  190. $this->findItemPublishedDate($entry, $item, $feed);
  191. $this->findItemUpdatedDate($entry, $item, $feed);
  192. if ($item->getPublishedDate() === null) {
  193. // Use the updated date if available, otherwise use the feed date
  194. $item->setPublishedDate($item->getUpdatedDate() ?: $feed->getDate());
  195. }
  196. if ($item->getUpdatedDate() === null) {
  197. // Use the published date as fallback
  198. $item->setUpdatedDate($item->getPublishedDate());
  199. }
  200. // Use the most recent of published and updated dates
  201. $item->setDate(max($item->getPublishedDate(), $item->getUpdatedDate()));
  202. }
  203. /**
  204. * Get Item Post Processor instance
  205. *
  206. * @access public
  207. * @return ItemPostProcessor
  208. */
  209. public function getItemPostProcessor()
  210. {
  211. return $this->itemPostProcessor;
  212. }
  213. /**
  214. * Get DateParser instance
  215. *
  216. * @access public
  217. * @return DateParser
  218. */
  219. public function getDateParser()
  220. {
  221. if ($this->dateParser === null) {
  222. $this->dateParser = new DateParser($this->config);
  223. }
  224. return $this->dateParser;
  225. }
  226. /**
  227. * Generate a unique id for an entry (hash all arguments).
  228. *
  229. * @return string
  230. */
  231. public function generateId()
  232. {
  233. return hash($this->hash_algo, implode(func_get_args()));
  234. }
  235. /**
  236. * Return true if the given language is "Right to Left".
  237. *
  238. * @static
  239. * @param string $language Language: fr-FR, en-US
  240. * @return bool
  241. */
  242. public static function isLanguageRTL($language)
  243. {
  244. $language = strtolower($language);
  245. $rtl_languages = array(
  246. 'ar', // Arabic (ar-**)
  247. 'fa', // Farsi (fa-**)
  248. 'ur', // Urdu (ur-**)
  249. 'ps', // Pashtu (ps-**)
  250. 'syr', // Syriac (syr-**)
  251. 'dv', // Divehi (dv-**)
  252. 'he', // Hebrew (he-**)
  253. 'yi', // Yiddish (yi-**)
  254. );
  255. foreach ($rtl_languages as $prefix) {
  256. if (strpos($language, $prefix) === 0) {
  257. return true;
  258. }
  259. }
  260. return false;
  261. }
  262. /**
  263. * Set Hash algorithm used for id generation.
  264. *
  265. * @param string $algo Algorithm name
  266. * @return \PicoFeed\Parser\Parser
  267. */
  268. public function setHashAlgo($algo)
  269. {
  270. $this->hash_algo = $algo ?: $this->hash_algo;
  271. return $this;
  272. }
  273. /**
  274. * Set config object.
  275. *
  276. * @param \PicoFeed\Config\Config $config Config instance
  277. * @return \PicoFeed\Parser\Parser
  278. */
  279. public function setConfig($config)
  280. {
  281. $this->config = $config;
  282. $this->itemPostProcessor->setConfig($config);
  283. return $this;
  284. }
  285. /**
  286. * Enable the content grabber.
  287. *
  288. * @return \PicoFeed\Parser\Parser
  289. */
  290. public function disableContentFiltering()
  291. {
  292. $this->itemPostProcessor->unregister('PicoFeed\Processor\ContentFilterProcessor');
  293. return $this;
  294. }
  295. /**
  296. * Enable the content grabber.
  297. *
  298. * @param bool $needsRuleFile true if only pages with rule files should be
  299. * scraped
  300. * @param null|\Closure $scraperCallback Callback function that gets called for each
  301. * scraper execution
  302. * @return \PicoFeed\Parser\Parser
  303. */
  304. public function enableContentGrabber($needsRuleFile = false, $scraperCallback = null)
  305. {
  306. $processor = new ScraperProcessor($this->config);
  307. if ($needsRuleFile) {
  308. $processor->getScraper()->disableCandidateParser();
  309. }
  310. if ($scraperCallback !== null) {
  311. $processor->setExecutionCallback($scraperCallback);
  312. }
  313. $this->itemPostProcessor->register($processor);
  314. return $this;
  315. }
  316. /**
  317. * Set ignored URLs for the content grabber.
  318. *
  319. * @param array $urls URLs
  320. * @return \PicoFeed\Parser\Parser
  321. */
  322. public function setGrabberIgnoreUrls(array $urls)
  323. {
  324. $this->itemPostProcessor->getProcessor('PicoFeed\Processor\ScraperProcessor')->ignoreUrls($urls);
  325. return $this;
  326. }
  327. /**
  328. * Register all supported namespaces to be used within an xpath query.
  329. *
  330. * @param SimpleXMLElement $xml Feed xml
  331. * @return SimpleXMLElement
  332. */
  333. public function registerSupportedNamespaces(SimpleXMLElement $xml)
  334. {
  335. foreach ($this->namespaces as $prefix => $ns) {
  336. $xml->registerXPathNamespace($prefix, $ns);
  337. }
  338. return $xml;
  339. }
  340. }