mirror of
https://github.com/YunoHost-Apps/freshrss_ynh.git
synced 2024-09-03 18:36:33 +02:00
391 lines
12 KiB
PHP
Executable file
391 lines
12 KiB
PHP
Executable file
<?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;
|
|
}
|
|
}
|