miniflux-legacy/app/models/feed.php

211 lines
5.4 KiB
PHP
Raw Permalink Normal View History

<?php
2016-08-25 03:17:58 +02:00
namespace Miniflux\Model\Feed;
use Miniflux\Model\Favicon;
2016-08-25 03:17:58 +02:00
use Miniflux\Model\Item;
use Miniflux\Model\Group;
2014-02-08 20:13:14 +01:00
use PicoDb\Database;
use PicoDb\SQLException;
use PicoFeed\Parser\Feed;
const STATUS_ACTIVE = 1;
const STATUS_INACTIVE = 0;
const TABLE = 'feeds';
function create($user_id, Feed $feed, $etag, $last_modified, $expiration = 0, $rtl = false, $scraper = false, $cloak_referrer = false)
{
2015-08-15 03:33:39 +02:00
$db = Database::getInstance('db');
if ($db->table('feeds')->eq('user_id', $user_id)->eq('feed_url', $feed->getFeedUrl())->exists()) {
return -1;
}
$feed_id = $db
->table(TABLE)
->persist(array(
'user_id' => $user_id,
'title' => $feed->getTitle(),
'site_url' => $feed->getSiteUrl(),
'feed_url' => $feed->getFeedUrl(),
'download_content' => $scraper ? 1 : 0,
'rtl' => $rtl ? 1 : 0,
'etag' => $etag,
'last_modified' => $last_modified,
'last_checked' => time(),
'expiration' => $expiration,
'cloak_referrer' => $cloak_referrer ? 1 : 0,
));
if ($feed_id !== false) {
Item\update_feed_items($user_id, $feed_id, $feed->getItems(), $rtl);
}
return $feed_id;
}
function get_feeds($user_id)
{
2015-12-24 15:34:55 +01:00
return Database::getInstance('db')
->table(TABLE)
->eq('user_id', $user_id)
2016-12-26 21:07:18 +01:00
->desc('parsing_error')
->desc('enabled')
->asc('title')
->findAll();
}
function get_feeds_with_items_count_and_groups($user_id)
{
2016-12-26 21:07:18 +01:00
$feeds_count = array();
$feeds = get_feeds($user_id);
$feed_items = Database::getInstance('db')
->table(Item\TABLE)
->columns('feed_id', 'status', 'count(*) as nb')
->eq('user_id', $user_id)
->neq('status', Item\STATUS_REMOVED)
->groupBy('feed_id', 'status')
->findAll();
2016-12-26 21:07:18 +01:00
foreach ($feed_items as $row) {
if (! isset($feeds_count[$row['feed_id']])) {
$feeds_count[$row['feed_id']] = array('unread' => 0, 'total' => 0);
}
if ($row['status'] === 'unread') {
$feeds_count[$row['feed_id']]['unread'] = $row['nb'];
}
$feeds_count[$row['feed_id']]['total'] += $row['nb'];
}
foreach ($feeds as &$feed) {
$feed['items_unread'] = isset($feeds_count[$feed['id']]) ? $feeds_count[$feed['id']]['unread'] : 0;
$feed['items_total'] = isset($feeds_count[$feed['id']]) ? $feeds_count[$feed['id']]['total'] : 0;
$feed['groups'] = Group\get_feed_groups($feed['id']);
2016-12-26 21:07:18 +01:00
}
return $feeds;
}
function get_feed_ids_to_refresh($user_id, $limit = null, $expiration = 0)
{
if ($expiration === 0) {
$expiration = time();
}
$query = Database::getInstance('db')
->table(TABLE)
->eq('user_id', $user_id)
->eq('enabled', STATUS_ACTIVE)
->lte('expiration', $expiration)
->asc('last_checked')
->asc('id');
if ($limit !== null) {
$query->limit($limit);
}
return $query->findAllByColumn('id');
}
function get_feed($user_id, $feed_id)
{
2015-12-24 15:34:55 +01:00
return Database::getInstance('db')
->table(TABLE)
->eq('user_id', $user_id)
->eq('id', $feed_id)
->findOne();
}
2017-01-15 20:00:32 +01:00
function is_duplicated_feed($user_id, $feed_id, $feed_url)
{
return Database::getInstance('db')
->table(TABLE)
->eq('user_id', $user_id)
->neq('id', $feed_id)
->eq('feed_url', $feed_url)
->exists();
}
function update_feed($user_id, $feed_id, array $values)
{
$db = Database::getInstance('db');
try {
$db->startTransaction();
$feed = $values;
unset($feed['id']);
unset($feed['group_name']);
unset($feed['feed_group_ids']);
if (isset($feed['ignore_expiration']) && $feed['ignore_expiration'] == 1) {
$feed['expiration'] = 0;
}
$result = Database::getInstance('db')
->table('feeds')
->eq('user_id', $user_id)
->eq('id', $feed_id)
->update($feed);
if ($result) {
if (isset($values['feed_group_ids']) && isset($values['group_name']) &&
! Group\update_feed_groups($user_id, $values['id'], $values['feed_group_ids'], $values['group_name'])) {
$db->cancelTransaction();
return false;
}
$db->closeTransaction();
return true;
}
} catch (SQLException $e) {}
$db->cancelTransaction();
return false;
}
function change_feed_status($user_id, $feed_id, $status = STATUS_ACTIVE)
{
return Database::getInstance('db')
->table(TABLE)
->eq('user_id', $user_id)
->eq('id', $feed_id)
->save((array('enabled' => $status)));
}
function remove_feed($user_id, $feed_id)
{
$result = Database::getInstance('db')
->table(TABLE)
->eq('user_id', $user_id)
->eq('id', $feed_id)
->remove();
if ($result) {
Favicon\purge_favicons();
}
return $result;
}
function count_failed_feeds($user_id)
{
return Database::getInstance('db')
->table(TABLE)
->eq('user_id', $user_id)
->eq('parsing_error', 1)
->count();
}
function count_feeds($user_id)
{
return Database::getInstance('db')
->table(TABLE)
->eq('user_id', $user_id)
->count();
}