miniflux-legacy/fever/index.php

<?php

require '../common.php';

use Model\Feed;
use Model\Group;
use Model\Service;
use PicoDb\Database;

// Route handler
function route($name, Closure $callback = null)
{
    static $routes = array();

    if ($callback !== null) {
        $routes[$name] = $callback;
    } elseif (isset($routes[$name])) {
        $routes[$name]();
    }
}

// Serialize the payload in Json (XML is not supported)
function response(array $response)
{
    header('Content-Type: application/json');
    echo json_encode($response);
    exit;
}

// Fever authentication
function auth()
{
    if (! empty($_GET['database'])) {
        // Return unauthorized if the requested database could not be found
        if (! Model\Database\select($_GET['database'])) {
            return array(
                'api_version' => 3,
                'auth' => 0,
            );
        }
    }

    $credentials = Database::getInstance('db')->hashtable('settings')->get('username', 'fever_token');
    $api_key = md5($credentials['username'].':'.$credentials['fever_token']);

    $response = array(
        'api_version' => 3,
        'auth' => (int) (isset($_POST['api_key']) && (strcasecmp($_POST['api_key'],  $api_key) === 0)),
        'last_refreshed_on_time' => time(),
    );

    return $response;
}

// Call: ?api&groups
route('groups', function () {

    $response = auth();

    if ($response['auth']) {
        $response['groups'] = Group\get_all();
        $response['feeds_groups'] = array();
        $group_map = Group\get_map();

        foreach ($group_map as $group_id => $feed_ids) {
            $response['feeds_groups'][] = array(
                'group_id' => $group_id,
                'feed_ids' => implode(',', $feed_ids)
            );
        }
    }

    response($response);
});

// Call: ?api&feeds
route('feeds', function () {

    $response = auth();

    if ($response['auth']) {
        $response['feeds'] = array();
        $response['feeds_groups'] = array();

        $feeds = Feed\get_all();

        foreach ($feeds as $feed) {
            $response['feeds'][] = array(
                'id' => (int) $feed['id'],
                'favicon_id' => (int) $feed['id'],
                'title' => $feed['title'],
                'url' => $feed['feed_url'],
                'site_url' => $feed['site_url'],
                'is_spark' => 0,
                'last_updated_on_time' => $feed['last_checked'] ?: time(),
            );
        }

        $group_map = Group\get_map();
        foreach ($group_map as $group_id => $feed_ids) {
            $response['feeds_groups'][] = array(
                'group_id' => $group_id,
                'feed_ids' => implode(',', $feed_ids)
            );
        }
    }

    response($response);
});

// Call: ?api&favicons
route('favicons', function () {

    $response = auth();

    if ($response['auth']) {
        $favicons = Database::getInstance('db')
            ->table('favicons')
            ->columns(
                'feed_id',
                'file',
                'type'
            )
            ->findAll();

        $response['favicons'] = array();
        foreach ($favicons as $favicon) {
            $response['favicons'][] = array(
                'id' => (int) $favicon['feed_id'],
                'data' => 'data:'.$favicon['type'].';base64,'.base64_encode(file_get_contents(FAVICON_DIRECTORY.DIRECTORY_SEPARATOR.$favicon['file']))
            );
        }
    }

    response($response);
});

// Call: ?api&items
route('items', function () {

    $response = auth();

    if ($response['auth']) {
        $query = Database::getInstance('db')
                        ->table('items')
                        ->columns(
                            'rowid',
                            'feed_id',
                            'title',
                            'author',
                            'content',
                            'url',
                            'updated',
                            'status',
                            'bookmark'
                        )
                        ->limit(50)
                        ->neq('status', 'removed');

        if (isset($_GET['since_id']) && is_numeric($_GET['since_id'])) {
            $items = $query->gt('rowid', $_GET['since_id'])
                           ->asc('rowid');
        } elseif (! empty($_GET['with_ids'])) {
            $query->in('rowid', explode(',', $_GET['with_ids']));
        }

        $items = $query->findAll();
        $response['items'] = array();

        foreach ($items as $item) {
            $response['items'][] = array(
                'id' => (int) $item['rowid'],
                'feed_id' => (int) $item['feed_id'],
                'title' => $item['title'],
                'author' => $item['author'],
                'html' => $item['content'],
                'url' => $item['url'],
                'is_saved' => (int) $item['bookmark'],
                'is_read' => $item['status'] == 'read' ? 1 : 0,
                'created_on_time' => $item['updated'],
            );
        }

        $response['total_items'] = Database::getInstance('db')
                                        ->table('items')
                                        ->neq('status', 'removed')
                                        ->count();
    }

    response($response);
});

// Call: ?api&links
route('links', function () {

    $response = auth();

    if ($response['auth']) {
        $response['links'] = array();
    }

    response($response);
});

// Call: ?api&unread_item_ids
route('unread_item_ids', function () {

    $response = auth();

    if ($response['auth']) {
        $item_ids = Database::getInstance('db')
                    ->table('items')
                    ->eq('status', 'unread')
                    ->findAllByColumn('rowid');

        $response['unread_item_ids'] = implode(',', $item_ids);
    }

    response($response);
});

// Call: ?api&saved_item_ids
route('saved_item_ids', function () {

    $response = auth();

    if ($response['auth']) {
        $item_ids = Database::getInstance('db')
                    ->table('items')
                    ->eq('bookmark', 1)
                    ->findAllByColumn('rowid');

        $response['saved_item_ids'] = implode(',', $item_ids);
    }

    response($response);
});

// handle write items
route('write_items', function () {

    $response = auth();

    if ($response['auth']) {
        $query = Database::getInstance('db')
                    ->table('items')
                    ->eq('rowid', $_POST['id']);

        if ($_POST['as'] === 'saved') {
            $query->update(array('bookmark' => 1));

            // Send bookmark to third-party services if enabled
            $item_id = Database::getInstance('db')
                            ->table('items')
                            ->eq('rowid', $_POST['id'])
                            ->findOneColumn('id');

            Service\push($item_id);
        } elseif ($_POST['as'] === 'unsaved') {
            $query->update(array('bookmark' => 0));
        } elseif ($_POST['as'] === 'read') {
            $query->update(array('status' => 'read'));
        } elseif ($_POST['as'] === 'unread') {
            $query->update(array('status' => 'unread'));
        }
    }

    response($response);
});

// handle write feeds
route('write_feeds', function () {

    $response = auth();

    if ($response['auth']) {
        Database::getInstance('db')
            ->table('items')
            ->eq('feed_id', $_POST['id'])
            ->lte('updated', $_POST['before'])
            ->update(array('status' => 'read'));
    }

    response($response);
});

// handle write groups
route('write_groups', function () {

    $response = auth();

    if ($response['auth']) {
        $db = Database::getInstance('db')
                ->table('items')
                ->lte('updated', $_POST['before']);

        if ($_POST['id'] > 0) {
            $db->in('feed_id', Model\Group\get_feeds_by_group($_POST['id']));
        }

        $db->update(array('status' => 'read'));
    }

    response($response);
});

foreach (array_keys($_GET) as $action) {
    route($action);
}

if (! empty($_POST['mark']) && ! empty($_POST['as'])
    && filter_input(INPUT_POST, 'id', FILTER_VALIDATE_INT, array('options' => array('default' => null, 'min_range' => -1))) !== null) {
    if ($_POST['mark'] === 'item') {
        route('write_items');
    } elseif ($_POST['mark'] === 'feed' && ! empty($_POST['before'])) {
        route('write_feeds');
    } elseif ($_POST['mark'] === 'group' && ! empty($_POST['before'])) {
        route('write_groups');
    }
}

response(auth());