|
|
|
<?php
|
|
|
|
|
|
|
|
class Feed extends Model {
|
|
|
|
private $id = null;
|
|
|
|
private $url;
|
|
|
|
private $category = '000000';
|
|
|
|
private $nbEntries = -1;
|
|
|
|
private $nbNotRead = -1;
|
|
|
|
private $entries = null;
|
|
|
|
private $name = '';
|
|
|
|
private $website = '';
|
|
|
|
private $description = '';
|
|
|
|
private $lastUpdate = 0;
|
|
|
|
private $priority = 10;
|
|
|
|
private $pathEntries = '';
|
|
|
|
private $httpAuth = '';
|
|
|
|
private $error = false;
|
|
|
|
private $keep_history = false;
|
|
|
|
|
|
|
|
public function __construct ($url, $validate=true) {
|
|
|
|
if ($validate) {
|
|
|
|
$this->_url ($url);
|
|
|
|
} else {
|
|
|
|
$this->url = $url;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
public function id () {
|
|
|
|
if(is_null($this->id)) {
|
|
|
|
return small_hash ($this->url . Configuration::selApplication ());
|
|
|
|
} else {
|
|
|
|
return $this->id;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
public function url () {
|
|
|
|
return $this->url;
|
|
|
|
}
|
|
|
|
public function category () {
|
|
|
|
return $this->category;
|
|
|
|
}
|
|
|
|
public function entries () {
|
|
|
|
if (!is_null ($this->entries)) {
|
|
|
|
return $this->entries;
|
|
|
|
} else {
|
|
|
|
return array ();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
public function name () {
|
|
|
|
return $this->name;
|
|
|
|
}
|
|
|
|
public function website () {
|
|
|
|
return $this->website;
|
|
|
|
}
|
|
|
|
public function description () {
|
|
|
|
return $this->description;
|
|
|
|
}
|
|
|
|
public function lastUpdate () {
|
|
|
|
return $this->lastUpdate;
|
|
|
|
}
|
|
|
|
public function priority () {
|
|
|
|
return $this->priority;
|
|
|
|
}
|
|
|
|
public function pathEntries () {
|
|
|
|
return $this->pathEntries;
|
|
|
|
}
|
|
|
|
public function httpAuth ($raw = true) {
|
|
|
|
if ($raw) {
|
|
|
|
return $this->httpAuth;
|
|
|
|
} else {
|
|
|
|
$pos_colon = strpos ($this->httpAuth, ':');
|
|
|
|
$user = substr ($this->httpAuth, 0, $pos_colon);
|
|
|
|
$pass = substr ($this->httpAuth, $pos_colon + 1);
|
|
|
|
|
|
|
|
return array (
|
|
|
|
'username' => $user,
|
|
|
|
'password' => $pass
|
|
|
|
);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
public function inError () {
|
|
|
|
return $this->error;
|
|
|
|
}
|
|
|
|
public function keepHistory () {
|
|
|
|
return $this->keep_history;
|
|
|
|
}
|
|
|
|
public function nbEntries () {
|
|
|
|
if ($this->nbEntries < 0) {
|
|
|
|
$feedDAO = new FeedDAO ();
|
|
|
|
$this->nbEntries = $feedDAO->countEntries ($this->id ());
|
|
|
|
}
|
|
|
|
|
|
|
|
return $this->nbEntries;
|
|
|
|
}
|
|
|
|
public function nbNotRead () {
|
|
|
|
if ($this->nbNotRead < 0) {
|
|
|
|
$feedDAO = new FeedDAO ();
|
|
|
|
$this->nbNotRead = $feedDAO->countNotRead ($this->id ());
|
|
|
|
}
|
|
|
|
|
|
|
|
return $this->nbNotRead;
|
|
|
|
}
|
|
|
|
public function favicon () {
|
|
|
|
$file = '/data/favicons/' . $this->id () . '.ico';
|
|
|
|
|
|
|
|
$favicon_url = Url::display ($file);
|
|
|
|
if (!file_exists (PUBLIC_PATH . $file)) {
|
|
|
|
$favicon_url = dowload_favicon ($this->website (), $this->id ());
|
|
|
|
}
|
|
|
|
|
|
|
|
return $favicon_url;
|
|
|
|
}
|
|
|
|
|
|
|
|
public function _id ($value) {
|
|
|
|
$this->id = $value;
|
|
|
|
}
|
|
|
|
public function _url ($value) {
|
|
|
|
if (empty ($value)) {
|
|
|
|
throw new BadUrlException ($value);
|
|
|
|
}
|
|
|
|
if (!preg_match ('#^https?://#i', $value)) {
|
|
|
|
$value = 'http://' . $value;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (filter_var ($value, FILTER_VALIDATE_URL)) {
|
|
|
|
$this->url = $value;
|
|
|
|
} elseif (version_compare(PHP_VERSION, '5.3.3', '<') && (strpos($value, '-') > 0) && ($value === filter_var($value, FILTER_SANITIZE_URL))) { //PHP bug #51192
|
|
|
|
$this->url = $value;
|
|
|
|
} else {
|
|
|
|
throw new BadUrlException ($value);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
public function _category ($value) {
|
|
|
|
$this->category = $value;
|
|
|
|
}
|
|
|
|
public function _name ($value) {
|
|
|
|
if (is_null ($value)) {
|
|
|
|
$value = '';
|
|
|
|
}
|
|
|
|
$this->name = $value;
|
|
|
|
}
|
|
|
|
public function _website ($value) {
|
|
|
|
if (is_null ($value)) {
|
|
|
|
$value = '';
|
|
|
|
}
|
|
|
|
$this->website = $value;
|
|
|
|
}
|
|
|
|
public function _description ($value) {
|
|
|
|
if (is_null ($value)) {
|
|
|
|
$value = '';
|
|
|
|
}
|
|
|
|
$this->description = $value;
|
|
|
|
}
|
|
|
|
public function _lastUpdate ($value) {
|
|
|
|
$this->lastUpdate = $value;
|
|
|
|
}
|
|
|
|
public function _priority ($value) {
|
|
|
|
$this->priority = is_numeric ($value) ? intval ($value) : 10;
|
|
|
|
}
|
|
|
|
public function _pathEntries ($value) {
|
|
|
|
$this->pathEntries = $value;
|
|
|
|
}
|
|
|
|
public function _httpAuth ($value) {
|
|
|
|
$this->httpAuth = $value;
|
|
|
|
}
|
|
|
|
public function _error ($value) {
|
|
|
|
if ($value) {
|
|
|
|
$value = true;
|
|
|
|
} else {
|
|
|
|
$value = false;
|
|
|
|
}
|
|
|
|
$this->error = $value;
|
|
|
|
}
|
|
|
|
public function _keepHistory ($value) {
|
|
|
|
if ($value) {
|
|
|
|
$value = true;
|
|
|
|
} else {
|
|
|
|
$value = false;
|
|
|
|
}
|
|
|
|
$this->keep_history = $value;
|
|
|
|
}
|
|
|
|
public function _nbNotRead ($value) {
|
|
|
|
$this->nbNotRead = is_numeric ($value) ? intval ($value) : -1;
|
Grosse optimisation JavaScript
* Fusion de endless_mode.js dans main.js car endless_mode.js est
toujours chargé et assez petit.
* Suppression des changements de style en JavaScript lors du chargement
(genre boucle de .hide(), ou d'ajout de classe ".stick") et
implémentation en PHP + CSS à la place.
* Chargement JavaScript asynchrone (defer + async) pour de meilleurs
performances.
* Utilisation préférable des événements globaux plutôt que des
événements pour chaque élément avec jQuery.on(events, selector) pour un
chargement plus rapide et moins de mémoire utilisée.
* Optimisation manuelle du JavaScript (sélecteurs CSS plus performants,
méthodes jQuery plus appropriées, etc.).
* Désactivation de init_img() qui était coûteux, lancé à un moment où
les images ne sont de toute manière pas encore chargées, et qui
n'apporte rien car il y a déjà un img {max-width:100%} en CSS.
* JavaScript en mode strict.
* Enfin, passage du code JavaScript dans JSLint et du coup nombreuses
corrections (syntaxe, variables, méthodes dépréciées...).
* Devrait permettre de fermer
https://github.com/marienfressinaud/FreshRSS/issues/121
* Au passage, quelques simplifications CSS pour de meilleures
performances.
11 years ago
|
|
|
}
|
|
|
|
public function _nbEntries ($value) {
|
|
|
|
$this->nbEntries = is_numeric ($value) ? intval ($value) : -1;
|
|
|
|
}
|
|
|
|
|
|
|
|
public function load () {
|
|
|
|
if (!is_null ($this->url)) {
|
|
|
|
if (CACHE_PATH === false) {
|
|
|
|
throw new FileNotExistException (
|
|
|
|
'CACHE_PATH',
|
|
|
|
MinzException::ERROR
|
|
|
|
);
|
|
|
|
} else {
|
|
|
|
$feed = new SimplePie ();
|
|
|
|
$url = str_replace ('&', '&', $this->url);
|
|
|
|
if ($this->httpAuth != '') {
|
|
|
|
$url = preg_replace ('#((.+)://)(.+)#', '${1}' . $this->httpAuth . '@${3}', $url);
|
|
|
|
}
|
|
|
|
|
|
|
|
$feed->set_feed_url ($url);
|
|
|
|
$feed->set_cache_location (CACHE_PATH);
|
|
|
|
$feed->set_cache_duration(1500);
|
|
|
|
$feed->strip_htmltags (array (
|
|
|
|
'base', 'blink', 'body', 'doctype',
|
|
|
|
'font', 'form', 'frame', 'frameset', 'html',
|
|
|
|
'input', 'marquee', 'meta', 'noscript',
|
|
|
|
'param', 'script', 'style'
|
|
|
|
));
|
|
|
|
$feed->strip_attributes(array_merge($feed->strip_attributes, array(
|
|
|
|
'onload', 'onunload', 'onclick', 'ondblclick', 'onmousedown', 'onmouseup',
|
|
|
|
'onmouseover', 'onmousemove', 'onmouseout', 'onfocus', 'onblur',
|
|
|
|
'onkeypress', 'onkeydown', 'onkeyup', 'onselect', 'onchange')));
|
|
|
|
$feed->init ();
|
|
|
|
|
|
|
|
if ($feed->error ()) {
|
|
|
|
throw new FeedException ($feed->error . ' [' . $url . ']');
|
|
|
|
}
|
|
|
|
|
|
|
|
// si on a utilisé l'auto-discover, notre url va avoir changé
|
|
|
|
$subscribe_url = $feed->subscribe_url ();
|
|
|
|
if (!is_null ($subscribe_url) && $subscribe_url != $this->url) {
|
|
|
|
if ($this->httpAuth != '') {
|
|
|
|
// on enlève les id si authentification HTTP
|
|
|
|
$subscribe_url = preg_replace ('#((.+)://)((.+)@)(.+)#', '${1}${5}', $subscribe_url);
|
|
|
|
}
|
|
|
|
$this->_url ($subscribe_url);
|
|
|
|
}
|
|
|
|
|
|
|
|
if (empty($this->name)) { // May come from OPML
|
|
|
|
$title = $feed->get_title ();
|
|
|
|
$this->_name (!is_null ($title) ? $title : $this->url);
|
|
|
|
}
|
|
|
|
|
|
|
|
$this->_website ($feed->get_link ());
|
|
|
|
$this->_description ($feed->get_description ());
|
|
|
|
|
|
|
|
// et on charge les articles du flux
|
|
|
|
$this->loadEntries ($feed);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
static function html_only_entity_decode($text) {
|
|
|
|
static $htmlEntitiesOnly = null;
|
|
|
|
if ($htmlEntitiesOnly === null) {
|
|
|
|
$htmlEntitiesOnly = array_flip(array_diff(
|
|
|
|
get_html_translation_table(HTML_ENTITIES, ENT_NOQUOTES, 'UTF-8'), //Decode HTML entities
|
|
|
|
get_html_translation_table(HTML_SPECIALCHARS, ENT_NOQUOTES, 'UTF-8') //Preserve XML entities
|
|
|
|
));
|
|
|
|
}
|
|
|
|
return strtr($text, $htmlEntitiesOnly);
|
|
|
|
}
|
|
|
|
private function loadEntries ($feed) {
|
|
|
|
$entries = array ();
|
|
|
|
|
|
|
|
foreach ($feed->get_items () as $item) {
|
|
|
|
$title = self::html_only_entity_decode (strip_tags ($item->get_title ()));
|
|
|
|
$author = self::html_only_entity_decode ($item->get_author ());
|
|
|
|
$link = $item->get_permalink ();
|
|
|
|
$date = strtotime ($item->get_date ());
|
|
|
|
|
|
|
|
// gestion des tags (catégorie == tag)
|
|
|
|
$tags_tmp = $item->get_categories ();
|
|
|
|
$tags = array ();
|
|
|
|
if (!is_null ($tags_tmp)) {
|
|
|
|
foreach ($tags_tmp as $tag) {
|
|
|
|
$tags[] = self::html_only_entity_decode ($tag->get_label ());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
$content = self::html_only_entity_decode ($item->get_content ());
|
|
|
|
|
|
|
|
$elinks = array();
|
|
|
|
foreach ($item->get_enclosures() as $enclosure) {
|
|
|
|
$elink = $enclosure->get_link();
|
|
|
|
if (array_key_exists($elink, $elinks)) continue;
|
|
|
|
$elinks[$elink] = '1';
|
|
|
|
$mime = strtolower($enclosure->get_type());
|
|
|
|
if (strpos($mime, 'image/') === 0) {
|
|
|
|
$content .= '<br /><img src="' . $elink . '" alt="" />';
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
$entry = new Entry (
|
|
|
|
$this->id (),
|
|
|
|
$item->get_id (),
|
|
|
|
!is_null ($title) ? $title : '',
|
|
|
|
!is_null ($author) ? $author->name : '',
|
|
|
|
!is_null ($content) ? $content : '',
|
|
|
|
!is_null ($link) ? $link : '',
|
|
|
|
$date ? $date : time ()
|
|
|
|
);
|
|
|
|
$entry->_tags ($tags);
|
|
|
|
// permet de récupérer le contenu des flux tronqués
|
|
|
|
$entry->loadCompleteContent($this->pathEntries());
|
|
|
|
|
|
|
|
$entries[$entry->id ()] = $entry;
|
|
|
|
}
|
|
|
|
|
|
|
|
$this->entries = $entries;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
class FeedDAO extends Model_pdo {
|
|
|
|
public function addFeed ($valuesTmp) {
|
|
|
|
$sql = 'INSERT INTO ' . $this->prefix . 'feed (id, url, category, name, website, description, lastUpdate, priority, httpAuth, error, keep_history) VALUES(?, ?, ?, ?, ?, ?, ?, 10, ?, 0, 0)';
|
|
|
|
$stm = $this->bd->prepare ($sql);
|
|
|
|
|
|
|
|
$values = array (
|
|
|
|
$valuesTmp['id'],
|
|
|
|
substr($valuesTmp['url'], 0, 511),
|
|
|
|
$valuesTmp['category'],
|
|
|
|
substr($valuesTmp['name'], 0, 255),
|
|
|
|
substr($valuesTmp['website'], 0, 255),
|
|
|
|
substr($valuesTmp['description'], 0, 1023),
|
|
|
|
$valuesTmp['lastUpdate'],
|
|
|
|
base64_encode ($valuesTmp['httpAuth']),
|
|
|
|
);
|
|
|
|
|
|
|
|
if ($stm && $stm->execute ($values)) {
|
|
|
|
return true;
|
|
|
|
} else {
|
|
|
|
$info = $stm->errorInfo();
|
|
|
|
Minz_Log::record ('SQL error : ' . $info[2], Minz_Log::ERROR);
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
public function updateFeed ($id, $valuesTmp) {
|
|
|
|
$set = '';
|
|
|
|
foreach ($valuesTmp as $key => $v) {
|
|
|
|
$set .= $key . '=?, ';
|
|
|
|
|
|
|
|
if ($key == 'httpAuth') {
|
|
|
|
$valuesTmp[$key] = base64_encode ($v);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
$set = substr ($set, 0, -2);
|
|
|
|
|
|
|
|
$sql = 'UPDATE ' . $this->prefix . 'feed SET ' . $set . ' WHERE id=?';
|
|
|
|
$stm = $this->bd->prepare ($sql);
|
|
|
|
|
|
|
|
foreach ($valuesTmp as $v) {
|
|
|
|
$values[] = $v;
|
|
|
|
}
|
|
|
|
$values[] = $id;
|
|
|
|
|
|
|
|
if ($stm && $stm->execute ($values)) {
|
|
|
|
return true;
|
|
|
|
} else {
|
|
|
|
$info = $stm->errorInfo();
|
|
|
|
Minz_Log::record ('SQL error : ' . $info[2], Minz_Log::ERROR);
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
public function updateLastUpdate ($id) {
|
|
|
|
$sql = 'UPDATE ' . $this->prefix . 'feed SET lastUpdate=?, error=0 WHERE id=?';
|
|
|
|
$stm = $this->bd->prepare ($sql);
|
|
|
|
|
|
|
|
$values = array (
|
|
|
|
time (),
|
|
|
|
$id
|
|
|
|
);
|
|
|
|
|
|
|
|
if ($stm && $stm->execute ($values)) {
|
|
|
|
return true;
|
|
|
|
} else {
|
|
|
|
$info = $stm->errorInfo();
|
|
|
|
Minz_Log::record ('SQL error : ' . $info[2], Minz_Log::ERROR);
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
public function isInError ($id) {
|
|
|
|
$sql = 'UPDATE ' . $this->prefix . 'feed SET error=1 WHERE id=?';
|
|
|
|
$stm = $this->bd->prepare ($sql);
|
|
|
|
|
|
|
|
$values = array (
|
|
|
|
$id
|
|
|
|
);
|
|
|
|
|
|
|
|
if ($stm && $stm->execute ($values)) {
|
|
|
|
return true;
|
|
|
|
} else {
|
|
|
|
$info = $stm->errorInfo();
|
|
|
|
Minz_Log::record ('SQL error : ' . $info[2], Minz_Log::ERROR);
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
public function changeCategory ($idOldCat, $idNewCat) {
|
|
|
|
$catDAO = new CategoryDAO ();
|
|
|
|
$newCat = $catDAO->searchById ($idNewCat);
|
|
|
|
if (!$newCat) {
|
|
|
|
$newCat = $catDAO->getDefault ();
|
|
|
|
}
|
|
|
|
|
|
|
|
$sql = 'UPDATE ' . $this->prefix . 'feed SET category=? WHERE category=?';
|
|
|
|
$stm = $this->bd->prepare ($sql);
|
|
|
|
|
|
|
|
$values = array (
|
|
|
|
$newCat->id (),
|
|
|
|
$idOldCat
|
|
|
|
);
|
|
|
|
|
|
|
|
if ($stm && $stm->execute ($values)) {
|
|
|
|
return true;
|
|
|
|
} else {
|
|
|
|
$info = $stm->errorInfo();
|
|
|
|
Minz_Log::record ('SQL error : ' . $info[2], Minz_Log::ERROR);
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
public function deleteFeed ($id) {
|
|
|
|
$sql = 'DELETE FROM ' . $this->prefix . 'feed WHERE id=?';
|
|
|
|
$stm = $this->bd->prepare ($sql);
|
|
|
|
|
|
|
|
$values = array ($id);
|
|
|
|
|
|
|
|
if ($stm && $stm->execute ($values)) {
|
|
|
|
return true;
|
|
|
|
} else {
|
|
|
|
$info = $stm->errorInfo();
|
|
|
|
Minz_Log::record ('SQL error : ' . $info[2], Minz_Log::ERROR);
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
public function deleteFeedByCategory ($id) {
|
|
|
|
$sql = 'DELETE FROM ' . $this->prefix . 'feed WHERE category=?';
|
|
|
|
$stm = $this->bd->prepare ($sql);
|
|
|
|
|
|
|
|
$values = array ($id);
|
|
|
|
|
|
|
|
if ($stm && $stm->execute ($values)) {
|
|
|
|
return true;
|
|
|
|
} else {
|
|
|
|
$info = $stm->errorInfo();
|
|
|
|
Minz_Log::record ('SQL error : ' . $info[2], Minz_Log::ERROR);
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
public function searchById ($id) {
|
|
|
|
$sql = 'SELECT * FROM ' . $this->prefix . 'feed WHERE id=?';
|
|
|
|
$stm = $this->bd->prepare ($sql);
|
|
|
|
|
|
|
|
$values = array ($id);
|
|
|
|
|
|
|
|
$stm->execute ($values);
|
|
|
|
$res = $stm->fetchAll (PDO::FETCH_ASSOC);
|
|
|
|
$feed = HelperFeed::daoToFeed ($res);
|
|
|
|
|
|
|
|
if (isset ($feed[$id])) {
|
|
|
|
return $feed[$id];
|
|
|
|
} else {
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
public function searchByUrl ($url) {
|
|
|
|
$sql = 'SELECT * FROM ' . $this->prefix . 'feed WHERE url=?';
|
|
|
|
$stm = $this->bd->prepare ($sql);
|
|
|
|
|
|
|
|
$values = array ($url);
|
|
|
|
|
|
|
|
$stm->execute ($values);
|
|
|
|
$res = $stm->fetchAll (PDO::FETCH_ASSOC);
|
|
|
|
$feed = current (HelperFeed::daoToFeed ($res));
|
|
|
|
|
|
|
|
if (isset ($feed)) {
|
|
|
|
return $feed;
|
|
|
|
} else {
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
public function listFeeds () {
|
|
|
|
$sql = 'SELECT * FROM ' . $this->prefix . 'feed ORDER BY name';
|
|
|
|
$stm = $this->bd->prepare ($sql);
|
|
|
|
$stm->execute ();
|
|
|
|
|
|
|
|
return HelperFeed::daoToFeed ($stm->fetchAll (PDO::FETCH_ASSOC));
|
|
|
|
}
|
|
|
|
|
|
|
|
public function listFeedsOrderUpdate () {
|
|
|
|
$sql = 'SELECT * FROM ' . $this->prefix . 'feed ORDER BY lastUpdate';
|
|
|
|
$stm = $this->bd->prepare ($sql);
|
|
|
|
$stm->execute ();
|
|
|
|
|
|
|
|
return HelperFeed::daoToFeed ($stm->fetchAll (PDO::FETCH_ASSOC));
|
|
|
|
}
|
|
|
|
|
|
|
|
public function listByCategory ($cat) {
|
|
|
|
$sql = 'SELECT * FROM ' . $this->prefix . 'feed WHERE category=? ORDER BY name';
|
|
|
|
$stm = $this->bd->prepare ($sql);
|
|
|
|
|
|
|
|
$values = array ($cat);
|
|
|
|
|
|
|
|
$stm->execute ($values);
|
|
|
|
|
|
|
|
return HelperFeed::daoToFeed ($stm->fetchAll (PDO::FETCH_ASSOC));
|
|
|
|
}
|
|
|
|
|
|
|
|
public function count () { //Is this used?
|
|
|
|
$sql = 'SELECT COUNT(*) AS count FROM ' . $this->prefix . 'feed';
|
|
|
|
$stm = $this->bd->prepare ($sql);
|
|
|
|
$stm->execute ();
|
|
|
|
$res = $stm->fetchAll (PDO::FETCH_ASSOC);
|
|
|
|
|
|
|
|
return $res[0]['count'];
|
|
|
|
}
|
|
|
|
|
|
|
|
public function countEntries ($id) {
|
|
|
|
$sql = 'SELECT COUNT(*) AS count FROM ' . $this->prefix . 'entry WHERE id_feed=?';
|
|
|
|
$stm = $this->bd->prepare ($sql);
|
|
|
|
$values = array ($id);
|
|
|
|
$stm->execute ($values);
|
|
|
|
$res = $stm->fetchAll (PDO::FETCH_ASSOC);
|
|
|
|
|
|
|
|
return $res[0]['count'];
|
|
|
|
}
|
|
|
|
public function countNotRead ($id) { //Is this used?
|
|
|
|
$sql = 'SELECT COUNT(*) AS count FROM ' . $this->prefix . 'entry WHERE is_read=0 AND id_feed=?';
|
|
|
|
$stm = $this->bd->prepare ($sql);
|
|
|
|
$values = array ($id);
|
|
|
|
$stm->execute ($values);
|
|
|
|
$res = $stm->fetchAll (PDO::FETCH_ASSOC);
|
|
|
|
|
|
|
|
return $res[0]['count'];
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
class HelperFeed {
|
|
|
|
public static function daoToFeed ($listDAO, $catID = null) {
|
|
|
|
$list = array ();
|
|
|
|
|
|
|
|
if (!is_array ($listDAO)) {
|
|
|
|
$listDAO = array ($listDAO);
|
|
|
|
}
|
|
|
|
|
|
|
|
foreach ($listDAO as $key => $dao) {
|
|
|
|
if (!isset ($dao['name'])) {
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
if (isset ($dao['id'])) {
|
|
|
|
$key = $dao['id'];
|
|
|
|
}
|
|
|
|
|
|
|
|
$myFeed = new Feed (isset($dao['url']) ? $dao['url'] : '', false);
|
|
|
|
$myFeed->_category ($catID === null ? $dao['category'] : $catID);
|
|
|
|
$myFeed->_name ($dao['name']);
|
|
|
|
$myFeed->_website ($dao['website']);
|
|
|
|
$myFeed->_description (isset($dao['description']) ? $dao['description'] : '');
|
|
|
|
$myFeed->_lastUpdate (isset($dao['lastUpdate']) ? $dao['lastUpdate'] : 0);
|
|
|
|
$myFeed->_priority ($dao['priority']);
|
|
|
|
$myFeed->_pathEntries (isset($dao['pathEntries']) ? $dao['pathEntries'] : '');
|
|
|
|
$myFeed->_httpAuth (isset($dao['httpAuth']) ? base64_decode ($dao['httpAuth']) : '');
|
|
|
|
$myFeed->_error ($dao['error']);
|
|
|
|
$myFeed->_keepHistory (isset($dao['keep_history']) ? $dao['keep_history'] : '');
|
|
|
|
if (isset ($dao['nbNotRead'])) {
|
|
|
|
$myFeed->_nbNotRead ($dao['nbNotRead']);
|
|
|
|
}
|
|
|
|
if (isset ($dao['nbEntries'])) {
|
|
|
|
$myFeed->_nbEntries ($dao['nbEntries']);
|
|
|
|
}
|
|
|
|
if (isset ($dao['id'])) {
|
|
|
|
$myFeed->_id ($dao['id']);
|
|
|
|
}
|
|
|
|
$list[$key] = $myFeed;
|
|
|
|
}
|
|
|
|
|
|
|
|
return $list;
|
|
|
|
}
|
|
|
|
}
|