miniflux-legacy/model.php

610 lines
14 KiB
PHP
Raw Normal View History

2013-02-18 03:48:21 +01:00
<?php
namespace Model;
require_once 'vendor/PicoFeed/Export.php';
require_once 'vendor/PicoFeed/Import.php';
require_once 'vendor/PicoFeed/Reader.php';
require_once 'vendor/SimpleValidator/Validator.php';
require_once 'vendor/SimpleValidator/Base.php';
require_once 'vendor/SimpleValidator/Validators/Required.php';
require_once 'vendor/SimpleValidator/Validators/Unique.php';
require_once 'vendor/SimpleValidator/Validators/MaxLength.php';
require_once 'vendor/SimpleValidator/Validators/MinLength.php';
require_once 'vendor/SimpleValidator/Validators/Integer.php';
require_once 'vendor/SimpleValidator/Validators/Equals.php';
use SimpleValidator\Validator;
use SimpleValidator\Validators;
use PicoFeed\Import;
use PicoFeed\Reader;
use PicoFeed\Export;
2013-04-13 03:08:55 +02:00
function get_languages()
{
return array(
'en_US' => t('English'),
2013-07-02 00:02:47 +02:00
'fr_FR' => t('French'),
'de_DE' => t('German')
2013-04-13 03:08:55 +02:00
);
}
2013-05-26 19:09:34 +02:00
function get_autoflush_options()
{
return array(
'0' => t('Never'),
'1' => t('After %d day', 1),
'5' => t('After %d days', 5),
'15' => t('After %d days', 15),
'30' => t('After %d days', 30)
);
}
function encode_item_id($input)
{
return strtr(base64_encode($input), '+/=', '-_,');
}
function decode_item_id($input)
{
return base64_decode(strtr($input, '-_,', '+/='));
}
2013-02-18 03:48:21 +01:00
function export_feeds()
{
$opml = new Export(get_feeds());
return $opml->execute();
}
function import_feeds($content)
{
$import = new Import($content);
$feeds = $import->execute();
if ($feeds) {
$db = \PicoTools\singleton('db');
$db->startTransaction();
foreach ($feeds as $feed) {
if (! $db->table('feeds')->eq('feed_url', $feed->feed_url)->count()) {
$db->table('feeds')->save(array(
'title' => $feed->title,
'site_url' => $feed->site_url,
'feed_url' => $feed->feed_url
));
}
}
$db->closeTransaction();
return true;
}
return false;
}
function import_feed($url)
{
$reader = new Reader;
$resource = $reader->download($url, '', '', HTTP_TIMEOUT, APP_USERAGENT);
2013-02-18 03:48:21 +01:00
$parser = $reader->getParser();
if ($parser !== false) {
$feed = $parser->execute();
if ($feed === false) return false;
if (! $feed->title || ! $feed->url) return false;
2013-04-04 03:19:02 +02:00
2013-02-18 03:48:21 +01:00
$db = \PicoTools\singleton('db');
if (! $db->table('feeds')->eq('feed_url', $reader->getUrl())->count()) {
// Etag and LastModified are added the next update
2013-02-18 03:48:21 +01:00
$rs = $db->table('feeds')->save(array(
'title' => $feed->title,
'site_url' => $feed->url,
'feed_url' => $reader->getUrl()
));
if ($rs) {
$feed_id = $db->getConnection()->getLastId();
update_items($feed_id, $feed->items);
}
}
return true;
}
return false;
}
2013-05-21 12:25:13 +02:00
2013-05-18 20:35:16 +02:00
function update_feeds($limit = LIMIT_ALL)
{
2013-05-18 20:35:16 +02:00
$feeds_id = get_feeds_id($limit);
foreach ($feeds_id as $feed_id) {
update_feed($feed_id);
}
// Auto-vacuum for people using the cronjob
\PicoTools\singleton('db')->getConnection()->exec('VACUUM');
}
function update_feed($feed_id)
{
$feed = get_feed($feed_id);
$reader = new Reader;
$resource = $reader->download(
$feed['feed_url'],
$feed['last_modified'],
$feed['etag'],
HTTP_TIMEOUT,
APP_USERAGENT
);
2013-05-21 12:25:13 +02:00
// Update the `last_checked` column each time, HTTP cache or not
2013-05-18 20:35:16 +02:00
update_feed_last_checked($feed_id);
if (! $resource->isModified()) {
return true;
}
$parser = $reader->getParser();
if ($parser !== false) {
$feed = $parser->execute();
if ($feed !== false) {
update_feed_cache_infos($feed_id, $resource->getLastModified(), $resource->getEtag());
update_items($feed_id, $feed->items);
return true;
}
}
return false;
}
2013-05-18 20:35:16 +02:00
function get_feeds_id($limit = LIMIT_ALL)
{
2013-05-18 20:35:16 +02:00
$table_feeds = \PicoTools\singleton('db')->table('feeds')
2013-05-18 21:47:22 +02:00
->asc('last_checked');
2013-05-18 20:35:16 +02:00
2013-05-21 12:25:13 +02:00
if ($limit !== LIMIT_ALL) {
2013-05-18 20:35:16 +02:00
$table_feeds->limit((int)$limit);
}
return $table_feeds->listing('id', 'id');
}
2013-02-18 03:48:21 +01:00
function get_feeds()
{
return \PicoTools\singleton('db')
->table('feeds')
->asc('title')
->findAll();
}
function get_feed($feed_id)
{
return \PicoTools\singleton('db')
->table('feeds')
->eq('id', $feed_id)
->findOne();
}
2013-05-21 12:25:13 +02:00
function update_feed_last_checked($feed_id)
{
2013-05-18 20:35:16 +02:00
\PicoTools\singleton('db')
->table('feeds')
->eq('id', $feed_id)
->save(array(
2013-05-21 12:25:13 +02:00
'last_checked' => time()
2013-05-18 20:35:16 +02:00
));
}
2013-02-18 03:48:21 +01:00
2013-05-21 12:25:13 +02:00
function update_feed_cache_infos($feed_id, $last_modified, $etag)
{
\PicoTools\singleton('db')
->table('feeds')
->eq('id', $feed_id)
->save(array(
'last_modified' => $last_modified,
2013-05-21 12:25:13 +02:00
'etag' => $etag
));
}
2013-02-18 03:48:21 +01:00
function remove_feed($feed_id)
{
// Items are removed by a sql constraint
2013-02-18 03:48:21 +01:00
$db = \PicoTools\singleton('db');
return $db->table('feeds')->eq('id', $feed_id)->remove();
}
2013-07-06 04:37:19 +02:00
function get_unread_items($offset = null, $limit = null)
2013-02-18 03:48:21 +01:00
{
return \PicoTools\singleton('db')
->table('items')
2013-06-15 05:12:08 +02:00
->columns('items.id', 'items.title', 'items.updated', 'items.url', 'items.content', 'items.bookmark', 'items.status', 'feeds.site_url')
2013-02-18 03:48:21 +01:00
->join('feeds', 'id', 'feed_id')
->eq('status', 'unread')
->desc('updated')
2013-07-06 04:37:19 +02:00
->offset($offset)
->limit($limit)
2013-02-18 03:48:21 +01:00
->findAll();
}
2013-07-06 04:37:19 +02:00
function count_items($status)
{
return \PicoTools\singleton('db')
->table('items')
->eq('status', $status)
->count();
}
function get_read_items($offset = null, $limit = null)
2013-02-18 03:48:21 +01:00
{
return \PicoTools\singleton('db')
->table('items')
2013-06-15 05:12:08 +02:00
->columns('items.id', 'items.title', 'items.updated', 'items.url', 'items.bookmark', 'feeds.site_url')
2013-02-18 03:48:21 +01:00
->join('feeds', 'id', 'feed_id')
->eq('status', 'read')
->desc('updated')
2013-07-06 04:37:19 +02:00
->offset($offset)
->limit($limit)
2013-02-18 03:48:21 +01:00
->findAll();
}
2013-07-06 04:37:19 +02:00
function count_bookmarks()
{
return \PicoTools\singleton('db')
->table('items')
->eq('bookmark', 1)
->count();
}
function get_bookmarks($offset = null, $limit = null)
{
return \PicoTools\singleton('db')
->table('items')
2013-06-15 05:12:08 +02:00
->columns('items.id', 'items.title', 'items.updated', 'items.url', 'items.status', 'feeds.site_url')
->join('feeds', 'id', 'feed_id')
2013-06-15 05:12:08 +02:00
->in('status', array('read', 'unread'))
->eq('bookmark', 1)
->desc('updated')
2013-07-06 04:37:19 +02:00
->offset($offset)
->limit($limit)
->findAll();
2013-02-18 03:48:21 +01:00
}
function get_item($id)
{
return \PicoTools\singleton('db')
->table('items')
->eq('id', $id)
->findOne();
}
2013-05-26 19:09:34 +02:00
2013-02-18 03:48:21 +01:00
function get_nav_item($item)
{
$unread_items = \PicoTools\singleton('db')
->table('items')
->columns('items.id')
->eq('status', 'unread')
->desc('updated')
->findAll();
$next_item = null;
$previous_item = null;
for ($i = 0, $ilen = count($unread_items); $i < $ilen; $i++) {
if ($unread_items[$i]['id'] == $item['id']) {
if ($i > 0) $previous_item = $unread_items[$i - 1];
if ($i < ($ilen - 1)) $next_item = $unread_items[$i + 1];
break;
}
}
return array(
'next' => $next_item,
'previous' => $previous_item
);
}
function set_item_removed($id)
{
\PicoTools\singleton('db')
->table('items')
->eq('id', $id)
->save(array('status' => 'removed', 'content' => ''));
}
2013-02-18 03:48:21 +01:00
function set_item_read($id)
{
\PicoTools\singleton('db')
->table('items')
->eq('id', $id)
->save(array('status' => 'read'));
}
2013-04-03 04:49:14 +02:00
function set_item_unread($id)
{
\PicoTools\singleton('db')
->table('items')
->eq('id', $id)
->save(array('status' => 'unread'));
}
2013-06-15 05:12:08 +02:00
function set_bookmark_value($id, $value)
{
\PicoTools\singleton('db')
->table('items')
->eq('id', $id)
2013-06-15 05:12:08 +02:00
->save(array('bookmark' => $value));
}
2013-04-03 04:49:14 +02:00
function switch_item_status($id)
{
$item = \PicoTools\singleton('db')
->table('items')
->columns('status')
->eq('id', $id)
->findOne();
if ($item['status'] == 'unread') {
\PicoTools\singleton('db')
->table('items')
->eq('id', $id)
->save(array('status' => 'read'));
return 'read';
}
else {
\PicoTools\singleton('db')
->table('items')
->eq('id', $id)
->save(array('status' => 'unread'));
return 'unread';
}
return '';
}
function mark_as_read()
{
\PicoTools\singleton('db')
->table('items')
->eq('status', 'unread')
->save(array('status' => 'read'));
}
2013-05-26 19:09:34 +02:00
function mark_as_removed()
2013-02-18 03:48:21 +01:00
{
\PicoTools\singleton('db')
->table('items')
2013-05-26 19:09:34 +02:00
->eq('status', 'read')
->eq('bookmark', 0)
->save(array('status' => 'removed', 'content' => ''));
2013-02-18 03:48:21 +01:00
}
2013-05-26 19:09:34 +02:00
function autoflush()
{
$autoflush = \PicoTools\singleton('db')->table('config')->findOneColumn('autoflush');
2013-05-26 19:09:34 +02:00
if ($autoflush) {
2013-05-26 19:09:34 +02:00
\PicoTools\singleton('db')
->table('items')
2013-06-15 14:45:43 +02:00
->eq('bookmark', 0)
2013-05-26 19:09:34 +02:00
->eq('status', 'read')
->lt('updated', strtotime('-'.$autoflush.'day'))
->save(array('status' => 'removed', 'content' => ''));
2013-05-26 19:09:34 +02:00
}
2013-02-18 03:48:21 +01:00
}
function update_items($feed_id, array $items)
{
2013-06-11 04:09:51 +02:00
$nocontent = (bool) \PicoTools\singleton('db')->table('config')->findOneColumn('nocontent');
$items_in_feed = array();
2013-02-18 03:48:21 +01:00
$db = \PicoTools\singleton('db');
$db->startTransaction();
foreach ($items as $item) {
// Item parsed correctly?
if ($item->id) {
// Insert only new item
if ($db->table('items')->eq('id', $item->id)->count() !== 1) {
$db->table('items')->save(array(
'id' => $item->id,
'title' => $item->title,
'url' => $item->url,
'updated' => $item->updated,
'author' => $item->author,
2013-06-11 04:09:51 +02:00
'content' => $nocontent ? '' : $item->content,
'status' => 'unread',
'feed_id' => $feed_id
));
}
// Items inside this feed
$items_in_feed[] = $item->id;
2013-02-18 03:48:21 +01:00
}
}
// Remove from the database items marked as "removed"
// and not present inside the feed
if (! empty($items_in_feed)) {
\PicoTools\singleton('db')
->table('items')
->notin('id', $items_in_feed)
->eq('status', 'removed')
->eq('feed_id', $feed_id)
->remove();
}
2013-02-18 03:48:21 +01:00
$db->closeTransaction();
}
function get_config()
{
return \PicoTools\singleton('db')
->table('config')
->columns('username', 'language', 'autoflush', 'nocontent')
2013-02-18 03:48:21 +01:00
->findOne();
}
2013-07-04 04:05:10 +02:00
function get_user($username)
2013-02-18 03:48:21 +01:00
{
return \PicoTools\singleton('db')
->table('config')
2013-05-26 19:09:34 +02:00
->columns('username', 'password', 'language')
2013-07-04 04:05:10 +02:00
->eq('username', $username)
2013-02-18 03:48:21 +01:00
->findOne();
}
function validate_login(array $values)
{
$v = new Validator($values, array(
2013-04-13 03:08:55 +02:00
new Validators\Required('username', t('The user name is required')),
new Validators\MaxLength('username', t('The maximum length is 50 characters'), 50),
new Validators\Required('password', t('The password is required'))
2013-02-18 03:48:21 +01:00
));
$result = $v->execute();
$errors = $v->getErrors();
if ($result) {
2013-07-04 04:05:10 +02:00
$user = get_user($values['username']);
2013-02-18 03:48:21 +01:00
2013-03-20 05:21:48 +01:00
if ($user && \password_verify($values['password'], $user['password'])) {
2013-02-18 03:48:21 +01:00
2013-04-13 03:08:55 +02:00
unset($user['password']);
2013-02-18 03:48:21 +01:00
$_SESSION['user'] = $user;
}
else {
$result = false;
2013-04-13 03:08:55 +02:00
$errors['login'] = t('Bad username or password');
2013-02-18 03:48:21 +01:00
}
}
return array(
$result,
$errors
);
}
function validate_config_update(array $values)
{
if (! empty($values['password'])) {
$v = new Validator($values, array(
2013-04-13 03:08:55 +02:00
new Validators\Required('username', t('The user name is required')),
new Validators\MaxLength('username', t('The maximum length is 50 characters'), 50),
new Validators\Required('password', t('The password is required')),
new Validators\MinLength('password', t('The minimum length is 6 characters'), 6),
new Validators\Required('confirmation', t('The confirmation is required')),
new Validators\Equals('password', 'confirmation', t('Passwords doesn\'t match')),
2013-05-26 19:09:34 +02:00
new Validators\Required('autoflush', t('Value required'))
2013-02-18 03:48:21 +01:00
));
}
else {
$v = new Validator($values, array(
2013-04-13 03:08:55 +02:00
new Validators\Required('username', t('The user name is required')),
new Validators\MaxLength('username', t('The maximum length is 50 characters'), 50)
2013-02-18 03:48:21 +01:00
));
}
return array(
$v->execute(),
$v->getErrors()
);
}
function save_config(array $values)
{
2013-03-18 02:57:47 +01:00
if (! empty($values['password'])) {
2013-03-20 05:21:48 +01:00
$values['password'] = \password_hash($values['password'], PASSWORD_BCRYPT);
2013-03-18 02:57:47 +01:00
}
else {
unset($values['password']);
}
2013-02-18 03:48:21 +01:00
unset($values['confirmation']);
2013-04-13 03:08:55 +02:00
$_SESSION['user']['language'] = $values['language'];
unset($_COOKIE['language']);
2013-04-13 03:27:51 +02:00
\PicoTools\Translator\load($values['language']);
2013-06-11 04:09:51 +02:00
// If the user does not want content of feeds, remove it in previous ones
2013-07-01 16:03:43 +02:00
if (isset($values['nocontent']) && (bool) $values['nocontent']) {
2013-06-11 04:09:51 +02:00
\PicoTools\singleton('db')->table('items')->update(array('content' => ''));
}
2013-02-18 03:48:21 +01:00
return \PicoTools\singleton('db')->table('config')->update($values);
}