123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208 |
- <?php
- require_once(__DIR__ . '/BridgeInterface.php');
- abstract class FeedExpander extends BridgeAbstract {
- private $name;
- private $uri;
- private $feedType;
- public function collectExpandableDatas($url, $maxItems = -1){
- if(empty($url)) {
- returnServerError('There is no $url for this RSS expander');
- }
- debugMessage('Loading from ' . $url);
- /* Notice we do not use cache here on purpose:
- * we want a fresh view of the RSS stream each time
- */
- $content = getContents($url)
- or returnServerError('Could not request ' . $url);
- $rssContent = simplexml_load_string($content);
- debugMessage('Detecting feed format/version');
- switch(true) {
- case isset($rssContent->item[0]):
- debugMessage('Detected RSS 1.0 format');
- $this->feedType = "RSS_1_0";
- break;
- case isset($rssContent->channel[0]):
- debugMessage('Detected RSS 0.9x or 2.0 format');
- $this->feedType = "RSS_2_0";
- break;
- case isset($rssContent->entry[0]):
- debugMessage('Detected ATOM format');
- $this->feedType = "ATOM_1_0";
- break;
- default:
- debugMessage('Unknown feed format/version');
- returnServerError('The feed format is unknown!');
- break;
- }
- debugMessage('Calling function "collect_' . $this->feedType . '_data"');
- $this->{'collect_' . $this->feedType . '_data'}($rssContent, $maxItems);
- }
- protected function collect_RSS_1_0_data($rssContent, $maxItems){
- $this->load_RSS_2_0_feed_data($rssContent->channel[0]);
- foreach($rssContent->item as $item) {
- debugMessage('parsing item ' . var_export($item, true));
- $tmp_item = $this->parseItem($item);
- if (!empty($tmp_item)) {
- $this->items[] = $tmp_item;
- }
- if($maxItems !== -1 && count($this->items) >= $maxItems) break;
- }
- }
- protected function collect_RSS_2_0_data($rssContent, $maxItems){
- $rssContent = $rssContent->channel[0];
- debugMessage('RSS content is ===========\n'
- . var_export($rssContent, true)
- . '===========');
- $this->load_RSS_2_0_feed_data($rssContent);
- foreach($rssContent->item as $item) {
- debugMessage('parsing item ' . var_export($item, true));
- $tmp_item = $this->parseItem($item);
- if (!empty($tmp_item)) {
- $this->items[] = $tmp_item;
- }
- if($maxItems !== -1 && count($this->items) >= $maxItems) break;
- }
- }
- protected function collect_ATOM_1_0_data($content, $maxItems){
- $this->load_ATOM_feed_data($content);
- foreach($content->entry as $item) {
- debugMessage('parsing item ' . var_export($item, true));
- $tmp_item = $this->parseItem($item);
- if (!empty($tmp_item)) {
- $this->items[] = $tmp_item;
- }
- if($maxItems !== -1 && count($this->items) >= $maxItems) break;
- }
- }
- protected function RSS_2_0_time_to_timestamp($item){
- return DateTime::createFromFormat('D, d M Y H:i:s e', $item->pubDate)->getTimestamp();
- }
- // TODO set title, link, description, language, and so on
- protected function load_RSS_2_0_feed_data($rssContent){
- $this->name = trim((string)$rssContent->title);
- $this->uri = trim((string)$rssContent->link);
- }
- protected function load_ATOM_feed_data($content){
- $this->name = (string)$content->title;
- // Find best link (only one, or first of 'alternate')
- if(!isset($content->link)) {
- $this->uri = '';
- } elseif (count($content->link) === 1) {
- $this->uri = $content->link[0]['href'];
- } else {
- $this->uri = '';
- foreach($content->link as $link) {
- if(strtolower($link['rel']) === 'alternate') {
- $this->uri = $link['href'];
- break;
- }
- }
- }
- }
- protected function parseATOMItem($feedItem){
- $item = array();
- if(isset($feedItem->id)) $item['uri'] = (string)$feedItem->id;
- if(isset($feedItem->title)) $item['title'] = (string)$feedItem->title;
- if(isset($feedItem->updated)) $item['timestamp'] = strtotime((string)$feedItem->updated);
- if(isset($feedItem->author)) $item['author'] = (string)$feedItem->author->name;
- if(isset($feedItem->content)) $item['content'] = (string)$feedItem->content;
- return $item;
- }
- protected function parseRSS_0_9_1_Item($feedItem){
- $item = array();
- if(isset($feedItem->link)) $item['uri'] = (string)$feedItem->link;
- if(isset($feedItem->title)) $item['title'] = (string)$feedItem->title;
- // rss 0.91 doesn't support timestamps
- // rss 0.91 doesn't support authors
- if(isset($feedItem->description)) $item['content'] = (string)$feedItem->description;
- return $item;
- }
- protected function parseRSS_1_0_Item($feedItem){
- // 1.0 adds optional elements around the 0.91 standard
- $item = $this->parseRSS_0_9_1_Item($feedItem);
- $namespaces = $feedItem->getNamespaces(true);
- if(isset($namespaces['dc'])) {
- $dc = $feedItem->children($namespaces['dc']);
- if(isset($dc->date)) $item['timestamp'] = strtotime((string)$dc->date);
- if(isset($dc->creator)) $item['author'] = (string)$dc->creator;
- }
- return $item;
- }
- protected function parseRSS_2_0_Item($feedItem){
- // Primary data is compatible to 0.91 with some additional data
- $item = $this->parseRSS_0_9_1_Item($feedItem);
- $namespaces = $feedItem->getNamespaces(true);
- if(isset($namespaces['dc'])) $dc = $feedItem->children($namespaces['dc']);
- if(isset($feedItem->guid)) {
- foreach($feedItem->guid->attributes() as $attribute => $value) {
- if($attribute === 'isPermaLink'
- && ($value === 'true' || filter_var($feedItem->guid, FILTER_VALIDATE_URL))) {
- $item['uri'] = (string)$feedItem->guid;
- break;
- }
- }
- }
- if(isset($feedItem->pubDate)) {
- $item['timestamp'] = strtotime((string)$feedItem->pubDate);
- } elseif(isset($dc->date)) {
- $item['timestamp'] = strtotime((string)$dc->date);
- }
- if(isset($feedItem->author)) {
- $item['author'] = (string)$feedItem->author;
- } elseif(isset($dc->creator)) {
- $item['author'] = (string)$dc->creator;
- }
- return $item;
- }
- /**
- * Method should return, from a source RSS item given by lastRSS, one of our Items objects
- * @param $item the input rss item
- * @return a RSS-Bridge Item, with (hopefully) the whole content)
- */
- protected function parseItem($item){
- switch($this->feedType) {
- case 'RSS_1_0':
- return $this->parseRSS_1_0_Item($item);
- break;
- case 'RSS_2_0':
- return $this->parseRSS_2_0_Item($item);
- break;
- case 'ATOM_1_0':
- return $this->parseATOMItem($item);
- break;
- default: returnClientError('Unknown version ' . $this->getInput('version') . '!');
- }
- }
- public function getURI(){
- return $this->uri ?: parent::getURI();
- }
- public function getName(){
- return $this->name ?: parent::getName();
- }
- }
|