You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
391 lines
12 KiB
391 lines
12 KiB
<?php |
|
|
|
class FreshRSS_FeedDAO extends Minz_ModelPdo implements FreshRSS_Searchable { |
|
public function addFeed($valuesTmp) { |
|
$sql = 'INSERT INTO `' . $this->prefix . 'feed` (url, category, name, website, description, lastUpdate, priority, httpAuth, error, keep_history, ttl) VALUES(?, ?, ?, ?, ?, ?, 10, ?, 0, -2, -2)'; |
|
$stm = $this->bd->prepare($sql); |
|
|
|
$values = array( |
|
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 $this->bd->lastInsertId(); |
|
} else { |
|
$info = $stm == null ? array(2 => 'syntax error') : $stm->errorInfo(); |
|
Minz_Log::error('SQL error addFeed: ' . $info[2]); |
|
return false; |
|
} |
|
} |
|
|
|
public function addFeedObject($feed) { |
|
// TODO: not sure if we should write this method in DAO since DAO |
|
// should not be aware about feed class |
|
|
|
// Add feed only if we don't find it in DB |
|
$feed_search = $this->searchByUrl($feed->url()); |
|
if (!$feed_search) { |
|
$values = array( |
|
'id' => $feed->id(), |
|
'url' => $feed->url(), |
|
'category' => $feed->category(), |
|
'name' => $feed->name(), |
|
'website' => $feed->website(), |
|
'description' => $feed->description(), |
|
'lastUpdate' => 0, |
|
'httpAuth' => $feed->httpAuth() |
|
); |
|
|
|
$id = $this->addFeed($values); |
|
if ($id) { |
|
$feed->_id($id); |
|
$feed->faviconPrepare(); |
|
} |
|
|
|
return $id; |
|
} |
|
|
|
return $feed_search->id(); |
|
} |
|
|
|
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 $stm->rowCount(); |
|
} else { |
|
$info = $stm == null ? array(2 => 'syntax error') : $stm->errorInfo(); |
|
Minz_Log::error('SQL error updateFeed: ' . $info[2]); |
|
return false; |
|
} |
|
} |
|
|
|
public function updateLastUpdate($id, $inError = 0, $updateCache = true) { |
|
if ($updateCache) { |
|
$sql = 'UPDATE `' . $this->prefix . 'feed` ' //2 sub-requests with FOREIGN KEY(e.id_feed), INDEX(e.is_read) faster than 1 request with GROUP BY or CASE |
|
. 'SET cache_nbEntries=(SELECT COUNT(e1.id) FROM `' . $this->prefix . 'entry` e1 WHERE e1.id_feed=`' . $this->prefix . 'feed`.id),' |
|
. 'cache_nbUnreads=(SELECT COUNT(e2.id) FROM `' . $this->prefix . 'entry` e2 WHERE e2.id_feed=`' . $this->prefix . 'feed`.id AND e2.is_read=0),' |
|
. 'lastUpdate=?, error=? ' |
|
. 'WHERE id=?'; |
|
} else { |
|
$sql = 'UPDATE `' . $this->prefix . 'feed` ' |
|
. 'SET lastUpdate=?, error=? ' |
|
. 'WHERE id=?'; |
|
} |
|
|
|
$values = array( |
|
time(), |
|
$inError, |
|
$id, |
|
); |
|
|
|
$stm = $this->bd->prepare($sql); |
|
|
|
if ($stm && $stm->execute($values)) { |
|
return $stm->rowCount(); |
|
} else { |
|
$info = $stm == null ? array(2 => 'syntax error') : $stm->errorInfo(); |
|
Minz_Log::error('SQL error updateLastUpdate: ' . $info[2]); |
|
return false; |
|
} |
|
} |
|
|
|
public function changeCategory($idOldCat, $idNewCat) { |
|
$catDAO = new FreshRSS_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 $stm->rowCount(); |
|
} else { |
|
$info = $stm == null ? array(2 => 'syntax error') : $stm->errorInfo(); |
|
Minz_Log::error('SQL error changeCategory: ' . $info[2]); |
|
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 $stm->rowCount(); |
|
} else { |
|
$info = $stm == null ? array(2 => 'syntax error') : $stm->errorInfo(); |
|
Minz_Log::error('SQL error deleteFeed: ' . $info[2]); |
|
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 $stm->rowCount(); |
|
} else { |
|
$info = $stm == null ? array(2 => 'syntax error') : $stm->errorInfo(); |
|
Minz_Log::error('SQL error deleteFeedByCategory: ' . $info[2]); |
|
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 = self::daoToFeed($res); |
|
|
|
if (isset($feed[$id])) { |
|
return $feed[$id]; |
|
} else { |
|
return null; |
|
} |
|
} |
|
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(self::daoToFeed($res)); |
|
|
|
if (isset($feed) && $feed !== false) { |
|
return $feed; |
|
} else { |
|
return null; |
|
} |
|
} |
|
|
|
public function listFeeds() { |
|
$sql = 'SELECT * FROM `' . $this->prefix . 'feed` ORDER BY name'; |
|
$stm = $this->bd->prepare($sql); |
|
$stm->execute(); |
|
|
|
return self::daoToFeed($stm->fetchAll(PDO::FETCH_ASSOC)); |
|
} |
|
|
|
public function arrayFeedCategoryNames() { //For API |
|
$sql = 'SELECT f.id, f.name, c.name as c_name FROM `' . $this->prefix . 'feed` f ' |
|
. 'INNER JOIN `' . $this->prefix . 'category` c ON c.id = f.category'; |
|
$stm = $this->bd->prepare($sql); |
|
$stm->execute(); |
|
$res = $stm->fetchAll(PDO::FETCH_ASSOC); |
|
$feedCategoryNames = array(); |
|
foreach ($res as $line) { |
|
$feedCategoryNames[$line['id']] = array( |
|
'name' => $line['name'], |
|
'c_name' => $line['c_name'], |
|
); |
|
} |
|
return $feedCategoryNames; |
|
} |
|
|
|
public function listFeedsOrderUpdate($defaultCacheDuration = 3600) { |
|
if ($defaultCacheDuration < 0) { |
|
$defaultCacheDuration = 2147483647; |
|
} |
|
$sql = 'SELECT id, url, name, website, lastUpdate, pathEntries, httpAuth, keep_history, ttl ' |
|
. 'FROM `' . $this->prefix . 'feed` ' |
|
. 'WHERE ttl <> -1 AND lastUpdate < (' . (time() + 60) . '-(CASE WHEN ttl=-2 THEN ' . intval($defaultCacheDuration) . ' ELSE ttl END)) ' |
|
. 'ORDER BY lastUpdate'; |
|
$stm = $this->bd->prepare($sql); |
|
if (!($stm && $stm->execute())) { |
|
$sql2 = 'ALTER TABLE `' . $this->prefix . 'feed` ADD COLUMN ttl INT NOT NULL DEFAULT -2'; //v0.7.3 |
|
$stm = $this->bd->prepare($sql2); |
|
$stm->execute(); |
|
$stm = $this->bd->prepare($sql); |
|
$stm->execute(); |
|
} |
|
|
|
return self::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 self::daoToFeed($stm->fetchAll(PDO::FETCH_ASSOC)); |
|
} |
|
|
|
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) { |
|
$sql = 'SELECT COUNT(*) AS count FROM `' . $this->prefix . 'entry` WHERE id_feed=? AND is_read=0'; |
|
$stm = $this->bd->prepare($sql); |
|
$values = array($id); |
|
$stm->execute($values); |
|
$res = $stm->fetchAll(PDO::FETCH_ASSOC); |
|
|
|
return $res[0]['count']; |
|
} |
|
|
|
public function updateCachedValues() { //For one single feed, call updateLastUpdate($id) |
|
$sql = 'UPDATE `' . $this->prefix . 'feed` f ' |
|
. 'INNER JOIN (' |
|
. 'SELECT e.id_feed, ' |
|
. 'COUNT(CASE WHEN e.is_read = 0 THEN 1 END) AS nbUnreads, ' |
|
. 'COUNT(e.id) AS nbEntries ' |
|
. 'FROM `' . $this->prefix . 'entry` e ' |
|
. 'GROUP BY e.id_feed' |
|
. ') x ON x.id_feed=f.id ' |
|
. 'SET f.cache_nbEntries=x.nbEntries, f.cache_nbUnreads=x.nbUnreads'; |
|
$stm = $this->bd->prepare($sql); |
|
|
|
if ($stm && $stm->execute()) { |
|
return $stm->rowCount(); |
|
} else { |
|
$info = $stm == null ? array(2 => 'syntax error') : $stm->errorInfo(); |
|
Minz_Log::error('SQL error updateCachedValues: ' . $info[2]); |
|
return false; |
|
} |
|
} |
|
|
|
public function truncate($id) { |
|
$sql = 'DELETE FROM `' . $this->prefix . 'entry` WHERE id_feed=?'; |
|
$stm = $this->bd->prepare($sql); |
|
$values = array($id); |
|
$this->bd->beginTransaction(); |
|
if (!($stm && $stm->execute($values))) { |
|
$info = $stm == null ? array(2 => 'syntax error') : $stm->errorInfo(); |
|
Minz_Log::error('SQL error truncate: ' . $info[2]); |
|
$this->bd->rollBack(); |
|
return false; |
|
} |
|
$affected = $stm->rowCount(); |
|
|
|
$sql = 'UPDATE `' . $this->prefix . 'feed` ' |
|
. 'SET cache_nbEntries=0, cache_nbUnreads=0 WHERE id=?'; |
|
$values = array($id); |
|
$stm = $this->bd->prepare($sql); |
|
if (!($stm && $stm->execute($values))) { |
|
$info = $stm == null ? array(2 => 'syntax error') : $stm->errorInfo(); |
|
Minz_Log::error('SQL error truncate: ' . $info[2]); |
|
$this->bd->rollBack(); |
|
return false; |
|
} |
|
|
|
$this->bd->commit(); |
|
return $affected; |
|
} |
|
|
|
public function cleanOldEntries($id, $date_min, $keep = 15) { //Remember to call updateLastUpdate($id) or updateCachedValues() just after |
|
$sql = 'DELETE FROM `' . $this->prefix . 'entry` ' |
|
. 'WHERE id_feed=:id_feed AND id<=:id_max ' |
|
. 'AND is_favorite=0 ' //Do not remove favourites |
|
. 'AND lastSeen < (SELECT maxLastSeen FROM (SELECT (MAX(e3.lastSeen)-99) AS maxLastSeen FROM `' . $this->prefix . 'entry` e3 WHERE e3.id_feed=:id_feed) recent) ' //Do not remove the most newly seen articles, plus a few seconds of tolerance |
|
. 'AND id NOT IN (SELECT id FROM (SELECT e2.id FROM `' . $this->prefix . 'entry` e2 WHERE e2.id_feed=:id_feed ORDER BY id DESC LIMIT :keep) keep)'; //Double select: MySQL doesn't support 'LIMIT & IN/ALL/ANY/SOME subquery' |
|
$stm = $this->bd->prepare($sql); |
|
|
|
if ($stm) { |
|
$id_max = intval($date_min) . '000000'; |
|
$stm->bindParam(':id_feed', $id, PDO::PARAM_INT); |
|
$stm->bindParam(':id_max', $id_max, PDO::PARAM_STR); |
|
$stm->bindParam(':keep', $keep, PDO::PARAM_INT); |
|
} |
|
|
|
if ($stm && $stm->execute()) { |
|
return $stm->rowCount(); |
|
} else { |
|
$info = $stm == null ? array(2 => 'syntax error') : $stm->errorInfo(); |
|
Minz_Log::error('SQL error cleanOldEntries: ' . $info[2]); |
|
return false; |
|
} |
|
} |
|
|
|
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']; |
|
} |
|
if ($catID === null) { |
|
$category = isset($dao['category']) ? $dao['category'] : 0; |
|
} else { |
|
$category = $catID ; |
|
} |
|
|
|
$myFeed = new FreshRSS_Feed(isset($dao['url']) ? $dao['url'] : '', false); |
|
$myFeed->_category($category); |
|
$myFeed->_name($dao['name']); |
|
$myFeed->_website(isset($dao['website']) ? $dao['website'] : '', false); |
|
$myFeed->_description(isset($dao['description']) ? $dao['description'] : ''); |
|
$myFeed->_lastUpdate(isset($dao['lastUpdate']) ? $dao['lastUpdate'] : 0); |
|
$myFeed->_priority(isset($dao['priority']) ? $dao['priority'] : 10); |
|
$myFeed->_pathEntries(isset($dao['pathEntries']) ? $dao['pathEntries'] : ''); |
|
$myFeed->_httpAuth(isset($dao['httpAuth']) ? base64_decode($dao['httpAuth']) : ''); |
|
$myFeed->_error(isset($dao['error']) ? $dao['error'] : 0); |
|
$myFeed->_keepHistory(isset($dao['keep_history']) ? $dao['keep_history'] : -2); |
|
$myFeed->_ttl(isset($dao['ttl']) ? $dao['ttl'] : -2); |
|
$myFeed->_nbNotRead(isset($dao['cache_nbUnreads']) ? $dao['cache_nbUnreads'] : 0); |
|
$myFeed->_nbEntries(isset($dao['cache_nbEntries']) ? $dao['cache_nbEntries'] : 0); |
|
if (isset($dao['id'])) { |
|
$myFeed->_id($dao['id']); |
|
} |
|
$list[$key] = $myFeed; |
|
} |
|
|
|
return $list; |
|
} |
|
}
|
|
|