dbmedialab/reader-critics

//
// LESERKRITIKK v2 (aka Reader Critics)
// Copyright (C) 2017 DB Medialab/Aller Media AS, Oslo, Norway
// https://github.com/dbmedialab/reader-critics/
//
// This program is free software: you can redistribute it and/or modify it under
// the terms of the GNU General Public License as published by the Free Software
// Foundation, either version 3 of the License, or (at your option) any later
// version.
//
// This program is distributed in the hope that it will be useful, but WITHOUT
// ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
// FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License along with
// this program. If not, see <http://www.gnu.org/licenses/>.

import {defaultLimit, defaultSkip, defaultSort} from 'app/services/BasicPersistingService';
import {ArticleDocument, ArticleModel} from 'app/db/models';

// getRange with count of feedbacks using internal populate
export default function(skip: number = defaultSkip,
                        limit: number = defaultLimit,
                        sort: Object = defaultSort,
                        search?: string
): Promise <ArticleDocument[]> {
    if ('title' in sort) {
        sort['itemField.text'] = sort['title'];
        delete sort['title'];
    }

    const match = {
        feedbacks: {$not: {$eq: 0}},
        'itemField.order.type': 1,
        'itemField.order.item': 1,
    };

    if (search) {
        match['$or'] = [
            {'itemField.text' : new RegExp(`${search}`, 'i')},
            {'url' : new RegExp(`^(?:http(?:s)?\\:\\/\\/)?(?:www\\.)?(?:.*\\..*\\/)${search}`, 'i')},
            // The RegExp above is looking for search string match in URL AFTER the domain part
            // Example: for string 'dagbladet' it would find only the article with second link below:
            // - 'http://www.dagbladet.no/articles/65342134'
            // - 'http://avisa.tld/articles/dagbladet-never-die/63232123'
        ];
    }

    return ArticleModel
        .aggregate([
            {
                $lookup: {
                    from: 'feedbacks',
                    localField: '_id',
                    foreignField: 'article',
                    as: 'feedbacks',
                },
            },
            {
                $project: {
                    ID: '$_id',
                    url: '$url',
                    version: '$version',
                    website: '$website',
                    date: '$date',
                    items: '$items',
                    authors: '$authors',
                    title: '$title',
                    feedbacks: {
                        $size: '$feedbacks',
                    },
                    itemField: '$items',
                },
            },
            {
                $unwind: '$itemField',
            },
            {
                $match: match,
            },
            {$sort: sort},
            {$skip: skip},
            {$limit: limit},
            {
                $project: {
                    ID: '$_id',
                    url: '$url',
                    version: '$version',
                    website: '$website',
                    date: '$date',
                    items: '$items',
                    authors: '$authors',
                    title: '$title',
                    feedbacks: '$feedbacks',
                },
            },
        ])
        .then(populateArticle);
}

// Internal populate

function populateArticle (
    query: ArticleDocument[]
    ): Promise <ArticleDocument[]> {

    // We don't have  a populate method in Mongoose aggregation, so we have to call in from model
    // and pass the aggregation result as a first param.
    return ArticleModel.populate(query, {
        path: 'authors',
        populate: {
            path: 'authors',
        },
    }).then(result => ArticleModel.populate(result, {
        path: 'website',
        populate: {
            path: 'website',
            select: 'name',
        },
    }));
}