fossasia/loklak_webclient

'use strict';
/* jshint unused:false */
/* global angular */

var controllersModule = require('./_index');


controllersModule.controller('DataConnectCtrl',
    ['$scope', '$rootScope', '$stateParams', 'SearchService', 'PushService', 'SourceTypeService',
    'ImportProfileService', 'HarvestingFrequencyService', 'MapPopUpTemplateService',
    function($scope, $rootScope, $stateParams, SearchService, PushService, SourceTypeService,
        ImportProfileService, HarvestingFrequencyService, MapPopUpTemplateService) {

    if ($stateParams.source_type !== null) {
        $stateParams.source_type = $stateParams.source_type.toLowerCase();

        // invalid 'source_type' parameter : returning to default MyConnection page
        if (!SourceTypeService.sourceTypeList[$stateParams.source_type]) {
            $location.url('/dataConnect');
            return;
        }
    }

    // duration (in ms) of waiting for elastic up-to-date state before retrieval new datasource list
    const DELAY_BEFORE_RELOAD = 2000;

    $scope.dataSourceEditableItems =
    [
        {
            'label': 'Update frequency',
            'field': 'harvesting_freq'
        },
        {
            'label': 'Lifetime',
            'field': 'lifetime'
        }
    ];
    $scope.dataSourceItems = [];
    /**
     * Messages that are displayed in the main datasource page
     */
    $scope.dataSourceMessages = {};

    $scope.sourceTypesList = SourceTypeService.sourceTypeList;
    $scope.harvestingFreqList = HarvestingFrequencyService.values;
    $scope.mapRulesNum = 0;

    $scope.setMessageView= function(profile) {
        $scope.selectedProfile = profile;
        var messageIds = profile.imported;
        if (messageIds !== $scope.fileIds) {
            $scope.fileIds = messageIds;
            var query = '';
            for (var key in messageIds) {
                query += 'id:' + messageIds[key] + ' ';
            }
            SearchService.getData(query).then(function(data) {
                $scope.selectedMessages = data.statuses;
            }, function() {});
        }
    };

    $scope.setMapView = function(profile) {
        $scope.selectedMapProfile = profile;
        var messageIds = profile.imported;
        if (messageIds !== $scope.mapIds) {
            $scope.mapIds = messageIds;
            var query = '';
            for (var key in messageIds) {
                query += 'id:' + messageIds[key] + ' ';
            }
            SearchService.getData(query).then(function(data) {
                $scope.selectedMapMessages = data.statuses;
                $scope.updateMap();
            }, function() {});
        }
    };

    function updateDataSources(callback) {
        if (!$rootScope.root.twitterSession) {
            return;
        }
        SearchService.getImportProfiles($stateParams.source_type || "", $rootScope.root.twitterSession.screen_name).then(function(data) {
            var count_item = 0;
            $scope.dataSourceItems = [];
            for (var k in data.profiles) {
                var profile = data.profiles[k];
                profile.source_type = profile.source_type.toLowerCase();
                // Unknown source type
                if (!$scope.sourceTypesList[profile.source_type]) {
                    console.error("Unknown source type : '" + profile.source_type + "'");
                    profile.display_source_type = profile.source_type;
                } else {
                    profile.display_source_type = $scope.sourceTypesList[profile.source_type].name;
                }
                profile.public = profile.privacy_status === 'PUBLIC';
                profile.editing = false;
                $scope.dataSourceItems[count_item] = profile;
                count_item++;
            }
            if (callback) {
                callback();
            }
        }, function() {});
    }

    $scope.returnFromAddConnection = function(message, knownProfiles) {
        $scope.dataSourceMessages.success = message;
        $scope.dataSourceMessages.knownProfiles = knownProfiles;
        setTimeout(updateDataSources, DELAY_BEFORE_RELOAD);
    };

    $scope.onUpdateDataSources = function() {
        $scope.dataSourceMessages = {};
        var refreshButton = angular.element("#refreshButton i");
        refreshButton.addClass("fa-spin");
        updateDataSources(function() {
            refreshButton.removeClass("fa-spin");
        });
    };

    $scope.showRowDetail = function(e) {
        // do not trigger when event source is a link or the span badge
        if (e.target.localName === 'a' || e.target.localName === 'span') {
            return;
        }
        angular.element(e.currentTarget).toggleClass("showing-detail");
    };

    $scope.toggleEditDataSource = function(event, item) {
        if (item.editing) {
            item.editing = false;
            angular.element(event.target).text("Edit").removeClass("btn-default").addClass("btn-loklak-blue");
        } else {
            item.editing = true;
            angular.element(event.target).text("Cancel").removeClass("btn-loklak-blue").addClass("btn-default");
        }
    };

    $scope.saveDataSource = function(item) {
        ImportProfileService.update(item).then(function(data) {
            setTimeout(updateDataSources, DELAY_BEFORE_RELOAD);
        }, function(error) {
            console.error(error);
            $scope.dataSourceMessages.error = 'Unable to save edited changes. If the problem persists, please contact loklak administrator for help.';
        });
    };

    $scope.openConfirmUnsubcribeModal = function(item) {
        $scope.toUnsubscribeItem = item;
        angular.element('#open-confirm-modal').trigger('click');
    };
    $scope.unsubscribeDataSource = function() {
        ImportProfileService.unsubscribe($scope.toUnsubscribeItem).then(function(data) {
            setTimeout(updateDataSources, DELAY_BEFORE_RELOAD);
            $scope.dataSourceMessages.success = 'Data source unsubscribed.';
        }, function(error) {
            console.error(error);
            $scope.dataSourceMessages.error = 'Unable to unsubscribe data source. If the problem persists, please contact loklak administrator for help.';
        });
    };

    // wait until logged in to uploadDataSource
    // this is necessary since sometimes this function is called before user finished logging in
    $rootScope.$watchCollection('root.twitterSession', function() {
        if ($rootScope.root.twitterSession) {
            updateDataSources();
        }
    });
}]);