superdesk/superdesk-client-core

import _ from 'lodash';
import {AuthoringWorkspaceService} from 'apps/authoring/authoring/services/AuthoringWorkspaceService';
import {gettext} from 'core/utils';

PackagesService.$inject = ['api', '$q', 'archiveService', 'lock', 'autosave', 'authoring',
    'authoringWorkspace', 'desks', '$rootScope'];
export function PackagesService(api, $q, archiveService, lock, autosave, authoring,
    authoringWorkspace: AuthoringWorkspaceService, desks, $rootScope) {
    var self = this;

    this.groupList = ['main', 'story', 'sidebars', 'fact box'];
    this.packageGroupItems = {};

    this.fetch = function fetch(_id) {
        return api.find('archive', _id).then((result) => result);
    };

    this.open = function open(_id, readOnly) {
        return authoring.open(_id, readOnly);
    };

    this.createPackageFromItems = function(items, defaults) {
        const idRef = 'main';
        const label = gettext('main');
        const item = items[0];
        let newPackage: any = {
            headline: item.headline || item.description_text || '',
            slugline: item.slugline || '',
            description_text: item.description_text || '',
            state: 'draft',
            type: 'composite',
            version: 0,
        };
        const groups = [{
            role: 'grpRole:NEP',
            refs: [{idRef, label}],
            id: 'root',
        },
        getGroupFor(null, idRef),
        ];

        newPackage = setDefaults(newPackage, defaults);
        newPackage.groups = groups;
        if (!newPackage.task || !newPackage.task.desk) {
            newPackage.task = {desk: desks.getCurrentDeskId()};
        }
        this.addItemsToPackage(newPackage, idRef, items);
        return api.save('archive', newPackage);
    };

    this.createEmptyPackage = function(
        defaults,
        initializeAsUpdated?: boolean,
        idRef = 'main',
        label = gettext('main'),
    ) {
        var newPackage: any = {
            headline: '',
            slugline: '',
            description_text: '',
            type: 'composite',
            version: initializeAsUpdated ? 1 : 0,
            groups: [
                {
                    role: 'grpRole:NEP',
                    refs: [{idRef, label}],
                    id: 'root',
                },
                getGroupFor(null, idRef),
            ],
        };

        newPackage = setDefaults(newPackage, defaults);

        if (!newPackage.task || !newPackage.task.desk) {
            newPackage.task = {desk: desks.getCurrentDeskId()};
        }

        return api.save('archive', newPackage);
    };

    this.addItemsToPackage = function(current, groupId, items) {
        var origGroups = _.cloneDeep(current.groups);

        var targetGroup = _.find(origGroups, (group) => group.id.toLowerCase() === groupId);

        if (!targetGroup) {
            var rootGroup: any = _.find(origGroups, {id: 'root'});

            rootGroup.refs.push({idRef: groupId});
            targetGroup = {
                id: groupId,
                refs: [],
                role: 'grpRole:' + groupId,
            };
            origGroups.push(targetGroup);
        }
        _.each(items, (item) => {
            targetGroup.refs.push(self.getReferenceFor(item));
        });
        _.extend(current, {groups: origGroups});
    };

    this.isAdded = function(pkg, item) {
        var added = pkg.groups ?
            pkg.groups.some((group) => group.refs.some((ref) => ref.guid === item._id || ref.residRef === item._id))
            : false;
        var addedToPkg = this.isAddedToPackage(pkg, item);

        return added || addedToPkg;
    };

    this.fetchItem = function(packageItem) {
        var repo = packageItem.location || 'ingest';

        return api(repo).getById(packageItem.residRef)
            .then((item) => item, (response) => {
                if (response.status === 404) {
                    console.error('Item not found.');
                }
            });
    };

    this.getReferenceFor = function(item) {
        return {
            type: item.type || '',
            headline: item.headline || '',
            residRef: item._id,
            location: 'archive',
            slugline: item.slugline || '',
            renditions: item.renditions || {},
            itemClass: item.type ? 'icls:' + item.type : '',
        };
    };

    function setItemLabel(pkg, item, label) {
        _.forEach(pkg.groups, (group) => {
            var ref: any = _.find(group.refs, {residRef: item._id});

            if (ref) {
                ref.label = label ? label.qcode : null;
                $rootScope.$broadcast('package:updateGroupRef', {ref: ref, group: group});
            }
        });
    }

    this.setItemLabel = function(item, label) {
        var pkg = authoringWorkspace.getItem();

        if (pkg._autosaved) {
            autosave.get(pkg).then((autosavedPkg) => {
                setItemLabel(autosavedPkg._autosave, item, label);
            });
        } else {
            setItemLabel(pkg, item, label);
        }
    };

    this.isSetItemLabel = function(item, label) {
        var qcode = label ? label.qcode : null;
        var pkg = authoringWorkspace.getItem();
        var isSet = false;

        _.forEach(pkg.groups, (group) => {
            var ref: any = _.find(group.refs, {guid: item._id});

            if (ref && ref.label === qcode) {
                isSet = true;
            }
        });
        return isSet;
    };

    this.addPackageGroupItem = function(group, item, broadcast) {
        var pkg = authoringWorkspace.getItem();
        var pkgId = pkg._id;

        if (typeof this.packageGroupItems[pkgId] === 'undefined') {
            this.packageGroupItems[pkgId] = [];
        }
        if (_.indexOf(this.packageGroupItems[pkgId], item._id) === -1) {
            this.packageGroupItems[pkgId].unshift(item._id);
        }
        if (typeof broadcast === 'undefined') {
            $rootScope.$broadcast('package:addItems', {items: [item], group: group});
        }
    };

    this.removePackageGroupItem = function(group, item) {
        var pkg = authoringWorkspace.getItem();

        _.remove(this.packageGroupItems[pkg._id], item._id);
    };

    this.isAddedToPackage = function(pkg, item) {
        return pkg ? _.indexOf(this.packageGroupItems[pkg._id], item._id) !== -1 : false;
    };

    function getGroupFor(item, idRef) {
        var refs = [];

        if (item) {
            refs.push({
                headline: item.headline || '',
                residRef: item._id,
                location: 'archive',
                slugline: item.slugline || '',
                renditions: item.renditions || {},
            });
        }
        return {
            refs: refs,
            id: idRef,
            role: 'grpRole:' + idRef,
        };
    }

    function setDefaults(item, defaults) {
        let obj = defaults;

        if (angular.isUndefined(defaults) || !_.isObject(defaults)) {
            obj = {};
        }

        archiveService.addTaskToArticle(obj);
        return _.merge(item, obj);
    }
}