alfresco-content-app/src/app/components/files/files.component.ts

/*!
 * @license
 * Alfresco Example Content Application
 *
 * Copyright (C) 2005 - 2017 Alfresco Software Limited
 *
 * This file is part of the Alfresco Example Content Application.
 * If the software was purchased under a paid Alfresco license, the terms of
 * the paid license agreement will prevail.  Otherwise, the software is
 * provided under the following open source license terms:
 *
 * The Alfresco Example Content Application is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * The Alfresco Example Content Application 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 Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with Alfresco. If not, see <http://www.gnu.org/licenses/>.
 */

import { Observable, Subscription } from 'rxjs/Rx';
import { Component, OnInit, OnDestroy, NgZone } from '@angular/core';
import { Router, ActivatedRoute, Params } from '@angular/router';
import { MinimalNodeEntity, MinimalNodeEntryEntity, PathElementEntity, NodePaging, PathElement } from 'alfresco-js-api';
import {
    UploadService, FileUploadEvent, NodesApiService,
    ContentService, AlfrescoApiService, UserPreferencesService
} from '@alfresco/adf-core';

import { BrowsingFilesService } from '../../common/services/browsing-files.service';
import { ContentManagementService } from '../../common/services/content-management.service';
import { NodeActionsService } from '../../common/services/node-actions.service';

import { PageComponent } from '../page.component';

@Component({
    templateUrl: './files.component.html'
})
export class FilesComponent extends PageComponent implements OnInit, OnDestroy {

    private routeData: any = {};
    isValidPath = true;

    private nodePath: PathElement[];
    private subscriptions: Subscription[] = [];

    sorting = [ 'modifiedAt', 'desc' ];

    constructor(private router: Router,
                private zone: NgZone,
                private route: ActivatedRoute,
                private nodesApi: NodesApiService,
                private nodeActionsService: NodeActionsService,
                private uploadService: UploadService,
                private contentManagementService: ContentManagementService,
                private browsingFilesService: BrowsingFilesService,
                private contentService: ContentService,
                private apiService: AlfrescoApiService,
                preferences: UserPreferencesService) {
        super(preferences);

        const sortingKey = preferences.get('personal-files.sorting.key') || 'modifiedAt';
        const sortingDirection = preferences.get('personal-files.sorting.direction') || 'desc';

        this.sorting = [sortingKey, sortingDirection];
    }

    ngOnInit() {
        const { route, contentManagementService, contentService, nodeActionsService, uploadService } = this;
        const { data } = route.snapshot;

        this.routeData = data;
        this.title = data.i18nTitle;

        route.params.subscribe(({ folderId }: Params) => {
            const nodeId = folderId || data.defaultNodeId;
            this.isLoading = true;

            this.fetchNode(nodeId)
                .do((node) => {
                    if (node.isFolder) {
                        this.updateCurrentNode(node);
                    } else {
                        this.router.navigate(['/personal-files', node.parentId], { replaceUrl: true });
                    }
                })
                .skipWhile(node => !node.isFolder)
                .flatMap((node) => this.fetchNodes(node.id))
                .subscribe(
                    (page) => {
                        this.isValidPath = true;
                        this.onPageLoaded(page);
                    },
                    error => {
                        this.isValidPath = false;
                        this.onFetchError(error);
                    }
                );
        });

        this.subscriptions = this.subscriptions.concat([
            nodeActionsService.contentCopied.subscribe((nodes) => this.onContentCopied(nodes)),
            contentService.folderCreate.subscribe(() => this.load(false, this.pagination)),
            contentService.folderEdit.subscribe(() => this.load(false, this.pagination)),
            contentManagementService.nodeDeleted.subscribe(() => this.load(false, this.pagination)),
            contentManagementService.nodeMoved.subscribe(() => this.load(false, this.pagination)),
            contentManagementService.nodeRestored.subscribe(() => this.load(false, this.pagination)),
            uploadService.fileUploadComplete.subscribe(file => this.onFileUploadedEvent(file)),
            uploadService.fileUploadDeleted.subscribe((file) => this.onFileUploadedEvent(file))
        ]);
    }

    ngOnDestroy() {
        this.subscriptions.forEach(s => s.unsubscribe());

        this.browsingFilesService.onChangeParent.next(null);
    }

    fetchNode(nodeId: string): Observable<MinimalNodeEntryEntity> {
        return this.nodesApi.getNode(nodeId);
    }

    fetchNodes(parentNodeId?: string, options: any = {}): Observable<NodePaging> {
        const defaults = {
            include: [ 'isLocked', 'path', 'properties', 'allowableOperations' ]
        };

        const queryOptions = Object.assign({}, defaults, options);

        return this.nodesApi.getNodeChildren(parentNodeId, queryOptions);
    }

    navigate(nodeId: string = null) {
        const commands = [ './' ];

        if (nodeId && !this.isRootNode(nodeId)) {
            commands.push(nodeId);
        }

        this.router.navigate(commands, {
            relativeTo: this.route.parent
        });
    }

    onNodeDoubleClick(event) {
        if (!!event.detail && !!event.detail.node) {

            const node: MinimalNodeEntryEntity = event.detail.node.entry;
            if (node) {

                if (node.isFolder) {
                    this.navigate(node.id);
                }

                if (PageComponent.isLockedNode(node)) {
                    event.preventDefault();

                } else if (node.isFile) {
                    this.router.navigate(['./preview', node.id], { relativeTo: this.route });
                }
            }

        }
    }

    showPreview(node: MinimalNodeEntryEntity) {
        if (node) {
            if (node.isFile) {
                this.router.navigate(['./preview', node.id], { relativeTo: this.route });
            }
        }
    }

    onBreadcrumbNavigate(route: PathElementEntity) {
        // todo: review this approach once 5.2.3 is out
        if (this.nodePath && this.nodePath.length > 2) {
            if (this.nodePath[1].name === 'Sites' && this.nodePath[2].id === route.id) {
                return this.navigate(this.nodePath[3].id);
            }
        }
        this.navigate(route.id);
    }

    onFileUploadedEvent(event: FileUploadEvent) {
        if (event && event.file.options.parentId === this.getParentNodeId()) {
            this.load(false, this.pagination);
        }
    }

    onContentCopied(nodes: MinimalNodeEntity[]) {
        const newNode = nodes
            .find((node) => {
                return node && node.entry && node.entry.parentId === this.getParentNodeId();
            });
        if (newNode) {
            this.load(false, this.pagination);
        }
    }

    canCreateContent(parentNode: MinimalNodeEntryEntity): boolean {
        if (parentNode) {
            return this.contentService.hasPermission(parentNode, 'create');
        }

        return false;
    }

    load(showIndicator: boolean = false, pagination: any = {}) {
        this.isLoading = showIndicator;

        this.fetchNodes(this.getParentNodeId(), pagination)
            .flatMap((page) => {
                if (this.isCurrentPageEmpty(page) && this.isNotFirstPage(page)) {
                    const newSkipCount = pagination.skipCount - pagination.maxItems;

                    return this.fetchNodes(this.getParentNodeId(), {skipCount: newSkipCount, maxItems: pagination.maxItems});
                }

                return Observable.of(page);
            })
            .subscribe(
                (page) => this.zone.run(() => this.onPageLoaded(page)),
                error => this.onFetchError(error)
            );
    }

    isCurrentPageEmpty(page): boolean {
        return !this.hasPageEntries(page);
    }

    hasPageEntries(page): boolean {
        return page && page.list && page.list.entries && page.list.entries.length > 0;
    }

    isNotFirstPage(page): boolean {
        return (page.list.pagination.skipCount >= page.list.pagination.maxItems);
    }

    // todo: review this approach once 5.2.3 is out
    private async updateCurrentNode(node: MinimalNodeEntryEntity) {
        this.nodePath = null;

        if (node && node.path && node.path.elements) {
            const elements = node.path.elements;

            this.nodePath = elements.map(pathElement => {
                return Object.assign({}, pathElement);
            });

            if (elements.length > 1) {
                if (elements[1].name === 'User Homes') {
                    elements.splice(0, 2);
                } else if (elements[1].name === 'Sites') {
                    await this.normalizeSitePath(node);
                }
            }
        }

        this.node = node;
        this.browsingFilesService.onChangeParent.next(node);
    }

    // todo: review this approach once 5.2.3 is out
    private async normalizeSitePath(node: MinimalNodeEntryEntity) {
        const elements = node.path.elements;

        // remove 'Sites'
        elements.splice(1, 1);

        if (this.isSiteContainer(node)) {
            // rename 'documentLibrary' entry to the target site display name
            // clicking on the breadcrumb entry loads the site content
            const parentNode = await this.apiService.nodesApi.getNodeInfo(node.parentId);
            node.name = parentNode.properties['cm:title'] || parentNode.name;

            // remove the site entry
            elements.splice(1, 1);
        } else {
            // remove 'documentLibrary' in the middle of the path
            const docLib = elements.findIndex(el => el.name === 'documentLibrary');
            if (docLib > -1) {
                const siteFragment = elements[docLib - 1];
                const siteNode = await this.apiService.nodesApi.getNodeInfo(siteFragment.id);

                // apply Site Name to the parent fragment
                siteFragment.name = siteNode.properties['cm:title'] || siteNode.name;
                elements.splice(docLib, 1);
            }
        }
    }

    isSiteContainer(node: MinimalNodeEntryEntity): boolean {
        if (node && node.aspectNames && node.aspectNames.length > 0) {
            return node.aspectNames.indexOf('st:siteContainer') >= 0;
        }
        return false;
    }

    isRootNode(nodeId: string): boolean {
        if (this.node && this.node.path && this.node.path.elements && this.node.path.elements.length > 0) {
            return this.node.path.elements[0].id === nodeId;
        }
        return false;
    }

    onSortingChanged(event: CustomEvent) {
        this.preferences.set('personal-files.sorting.key', event.detail.key || 'modifiedAt');
        this.preferences.set('personal-files.sorting.direction', event.detail.direction || 'desc');
    }
}