Nextcloud-News/js/service/OPMLImporter.js

/**
 * Nextcloud - News
 *
 * This file is licensed under the Affero General Public License version 3 or
 * later. See the COPYING file.
 *
 * @author Bernhard Posselt <dev@bernhard-posselt.com>
 * @copyright Bernhard Posselt 2014
 */
app.service('OPMLImporter', function (FeedResource, FolderResource, Publisher, $q) {
    'use strict';
    var startFeedJob = function (queue) {
        var deferred = $q.defer();
        try {
            if (queue.length > 0) {
                var feed = queue.pop();
                var url = feed.url;
                var title = feed.title;
                var folderId = 0;
                var folderName = feed.folderName;

                if (folderName !== undefined &&
                    FolderResource.get(folderName) !== undefined) {
                    var folder = FolderResource.get(folderName);
                    folder.opened = true;
                    folderId = folder.id;

                    // display folder while adding the feed
                    folder.getsFeed = true;
                    folder.getsFeedCounter = folder.getsFeedCounter || 0;
                    folder.getsFeedCounter += 1;
                }

                // make sure to not add already existing feeds
                if (url !== undefined && FeedResource.get(url) === undefined) {
                    FeedResource.create(url, folderId, title)
                        .then(function (data) {
                            Publisher.publishAll(data);
                        })
                        .finally(function () {
                            if (folderId !== 0) {
                                folder.getsFeedCounter -= 1;

                                if (folder.getsFeedCounter === 0) {
                                    folder.getsFeed = false;
                                }
                            }
                            startFeedJob(queue);
                        });
                }
            } else {
                deferred.resolve();
            }
        } catch (e) {
            console.error(e);
            deferred.resolve();
        }

        return deferred.promise;
    };

    this.importFolders = function (content) {
        // assumption: folders are fast to create and we dont need a queue for
        // them
        var feedQueue = [];
        var folderPromises = [];
        content.folders.forEach(function (folder) {
            if (folder.name !== undefined) {
                // skip already created folders
                if (FolderResource.get(folder.name) === undefined) {
                    var promise = FolderResource.create(folder.name)
                        .then(function (data) {
                            Publisher.publishAll(data);
                        });
                    folderPromises.push(promise);
                }

                folder.feeds.forEach(function (feed) {
                    feed.folderName = folder.name;
                    feedQueue.push(feed);
                });
            }
        });
        feedQueue = feedQueue.concat(content.feeds);

        var deferred = $q.defer();

        $q.all(folderPromises).finally(function () {
            deferred.resolve(feedQueue);
        });

        return deferred.promise;
    };

    this.importFeedQueue = function (feedQueue, jobSize) {
        // queue feeds to prevent server slowdown
        var deferred = $q.defer();

        var jobPromises = [];
        for (var i = 0; i < jobSize; i += 1) {
            jobPromises.push(startFeedJob(feedQueue));
        }

        $q.all(jobPromises).then(function () {
            deferred.resolve();
        });

        return deferred.promise;
    };

});