Software Público Brasileiro

(function() {
  'use strict';

  angular
  .module('dialoga')
  .factory('ArticleService', ArticleService);

  /** @ngInject */
  function ArticleService($http, $q, $rootScope, API, UtilService, Slug, GUID, $log) {
    $log.debug('ArticleService');

    var service = {
      apiArticles: $rootScope.basePath + '/api/v1/articles/',
      apiCommunities: $rootScope.basePath + '/api/v1/communities/',
      apiProposals: $rootScope.basePath + '/api/v1/proposals_discussion_plugin/',
      apiSearch: $rootScope.basePath + '/api/v1/search/',
      getArticleById: getArticleById,
      getArticleBySlug: getArticleBySlug,
      getArtcilesByParentId: getArtcilesByParentId,
      getCategories: getCategories,
      getCategoryBySlug: getCategoryBySlug,
      getTopics: getTopics,
      getTopicById: getTopicById,
      getProposals: getProposals,
      getProposalById: getProposalById,
      getProposalsByTopicId: getProposalsByTopicId,
      getProposalsByTopicIdRanked: getProposalsByTopicIdRanked,
      getResponseByProposalId: getResponseByProposalId,
      createProposal: createProposal,
      voteProposal: voteProposal,
      getEvents: getEvents,
      subscribeToEvent: subscribeToEvent,
      searchTopics: searchTopics,
      searchProposals: searchProposals,
      sendContactForm: sendContactForm,
      getRankedProposalsByTopicId: getRankedProposalsByTopicId
    };

    return service;

    function _getArticleById (articleId, params, cbSuccess, cbError) {

      var url = service.apiArticles + articleId;
      var paramsExtended = angular.extend({}, params);

      UtilService.get(url, {params: paramsExtended})
      .then(function(data){
        cbSuccess(data);
      }).catch(function(error){
        cbError(error);
      });
    }

    function getArticleById (articleId, params, cbSuccess, cbError) {
      _getArticleById(articleId, params, cbSuccess, cbError);
    }

    function getArticleBySlug (/*slug, params, cbSuccess, cbError*/) {
      throw { name: 'NotImplementedYet', message: 'The service "getArticleBySlug" is not implemented yet.'};
    }

    function getArtcilesByParentId (parentId, params) {
      // Ex.: /api/v1/articles/103358/children?fields=

      var url = service.apiArticles + parentId + '/children';
      var paramsExtended = angular.extend({
        'fields[]': ['id', 'slug', 'title', 'body']
      }, params);

      return UtilService.get(url, {params: paramsExtended});
    }

    function getCategories (articleId, params, cbSuccess, cbError) {
      // Ex.: /api/v1/articles/103358?fields=

      var url = service.apiArticles + articleId;
      var paramsExtended = angular.extend({
        'fields[]': ['id', 'categories']
      }, params);

      UtilService.get(url, {params: paramsExtended})
      .then(function(data){
        cbSuccess(data);
      }).catch(function(error){
        cbError(error);
      });
    }

    function getCategoryBySlug (/*slug, params, cbSuccess, cbError*/) {
      throw { name: 'NotImplementedYet', message: 'The service "getArticleBySlug" is not implemented yet.'};
    }

    function getTopics (params, cbSuccess, cbError) {
      // Ex.: /api/v1/articles/103358/children?fields=
      getTopicById(API.articleId.home, params, cbSuccess, cbError);
    }

    function getTopicById (topicId, params, cbSuccess, cbError) {
      // Ex.: /api/v1/articles/103358/children?fields=

      var url = service.apiArticles + topicId + '/children';
      var paramsExtended = angular.extend({
        'fields[]': ['id', 'categories']
        // 'fields[]': ['id', 'title', 'body', 'slug', 'abstract', 'categories', 'setting', 'children_count', 'hits']
      }, params);

      UtilService.get(url, {params: paramsExtended})
      .then(function(data){
        cbSuccess(data);
      }).catch(function(error){
        cbError(error);
      });
    }

    function getProposals (params, cbSuccess, cbError) {
      var paramsExtended = angular.extend({
        query: ''
      }, params);

      searchProposals(paramsExtended, cbSuccess, cbError);
    }

    function getProposalById (proposalId, params, cbSuccess, cbError) {
      var url = service.apiArticles + proposalId;

      var paramsExtended = angular.extend({
        // 'fields[]': ['id', 'title', 'abstract', 'children', 'children_count', 'ranking_position', 'hits', 'votes_for', 'votes_against'],
        // 'per_page':'1',
        'limit':'1',
        'content_type':'ProposalsDiscussionPlugin::Proposal'
      }, params);

      UtilService.get(url, {params: paramsExtended}).then(function(data){
        _pipeInjectSlugIntoParentProgram(data);
        cbSuccess(data);
      }).catch(function(error){
        cbError(error);
      });

    }

    function getRankedProposalsByTopicId (proposalId, params, cbSuccess, cbError) {
      var url = service.apiProposals + proposalId + '/ranking';
      var paramsExtended = angular.extend({
        page: 1,
        per_page: 10,
        type: 'ProposalsDiscussionPlugin::Proposal',
        'fields[]': [
        'id',
        'abstract',
        'hits',
        'ranking_position',
        'votes_against',
        'votes_count',
        'votes_for',
        'parent',
        'categories',
        'slug',
        'url', // parent.image.url
        'image',
        'title',
        'archived',
        ]
      }, params);

      UtilService.get(url, {params: paramsExtended}).then(function(data){
        cbSuccess(data);
      }).catch(function(error){
        cbError(error);
      });
    }

    function getProposalByIdRanked (proposalId, params, cbSuccess, cbError) {
      var url = service.apiProposals + proposalId + '/ranking?per_page=5&page=1';
      var paramsExtended = angular.extend({
        // 'fields[]': ['id', 'title', 'abstract', 'children', 'children_count', 'ranking_position', 'hits', 'votes_for', 'votes_against'],
        // 'per_page':'1',
        'limit':'1',
        'content_type':'ProposalsDiscussionPlugin::Proposal'
      }, params);

      UtilService.get(url, {params: paramsExtended}).then(function(data){
        _pipeInjectSlugIntoParentProgramRanked(data);
        cbSuccess(data);
      }).catch(function(error){
        cbError(error);
      });

    }

    /**
     * Ex.: /api/v1/articles/[article_id]/children?[params]content_type=ProposalsDiscussionPlugin::Proposal
     * Ex.: /api/v1/articles/103644/children?limit=20&fields=id,name,slug,abstract,created_by&content_type=ProposalsDiscussionPlugin::Proposal
     *
     * @param  {Integer}  topicId   topic where has those proposals
     * @param  {Object}   params    params for pagination ant others
     * @param  {Function} cbSuccess callback for success
     * @param  {Function} cbError   callback for error
     * @return {Array}           [description]
     */
     function getProposalsByTopicId (topicId, params, cbSuccess, cbError) {
      getProposalById(topicId + '/children', params, cbSuccess, cbError);
    }

    function getProposalsByTopicIdRanked (topicId, params, cbSuccess, cbError) {
      getProposalByIdRanked(topicId, params, cbSuccess, cbError);
    }

    function getResponseByProposalId (proposalId) {
      var url = service.apiArticles + proposalId + '/children?content_type=ProposalsDiscussionPlugin::Response&limit=1';

      // var paramsExtended = {};
      
      return UtilService.get(url);
    }

    function createProposal (proposal, targetId, categoryId, cbSuccess, cbError){

      if(!$rootScope.currentUser){
        cbError({message: 'Usuário não logado.'});
      }else{
        // /api/v1/proposals_discussion_plugin/' + targetId + '/propose
        var url = service.apiProposals + targetId + '/propose';

        var encodedParams = [];
        encodedParams.push('article%5Babstract%5D=' + proposal);
        encodedParams.push('article%5Bcategory_ids%5D%5B%5D=' + categoryId);
        encodedParams.push('article%5Btype%5D=ProposalsDiscussionPlugin%3A%3AProposal');
        encodedParams.push('content_type=ProposalsDiscussionPlugin%3A%3AProposal');
        encodedParams.push('private_token=' + $rootScope.currentUser.private_token);
        encodedParams.push('fields=id');
        encodedParams.push('article[name]=article_' + GUID.generate());
        encodedParams = encodedParams.join('&');

        UtilService.post(url, encodedParams).then(function(response){
          cbSuccess(response);
        }).catch(function(error){
          cbError(error);
        });
      }
    }

    function voteProposal (proposal_id, params){
      var url = service.apiArticles + proposal_id + '/vote';

      var private_token = null;
      if($rootScope.currentUser && $rootScope.currentUser.private_token){
        private_token = $rootScope.currentUser.private_token;
      }else{
        private_token = $rootScope.temporaryToken;
      }

      var paramsExtended = angular.extend({
        private_token: private_token
      }, params);

      var encodedParams = angular.element.param(paramsExtended);

      return UtilService.post(url, encodedParams);
    }

    function getEvents (community_id, params) {
      // Ex.: /api/v1/communities/19195/articles?categories_ids[]=' + cat_id + '&content_type=Event';
      // Ex.: /api/v1/communities/' + community_id + '/articles?categories_ids[]=' + cat_id + '&content_type=Event';

      var url = service.apiCommunities + community_id + '/articles';
      var paramsExtended = angular.extend({
        'fields[]': ['id', 'title', 'abstract', 'body', 'setting', 'presenter', 'created_at', 'update_at', 'start_date', 'end_date', 'followers_count', 'image', 'url'],
        'content_type':'Event'
      }, params);

      return UtilService.get(url, {params: paramsExtended}).then(function(data){
        _pipeRemoveOldEvents(data);
        return data;
      });
    }

    // function getSubscribers (event_id, params, cbSuccess, cbError) {
    //   var url = service.apiArticles + event_id + '/followers?_=' + new Date().getTime();
    //   var paramsExtended = angular.extend({
    //     // 'fields[]': ['id', 'slug', 'title', 'abstract', 'body', 'categories', 'created_at', 'start_date', 'end_date', 'hits'],
    //     'content_type':'Event'
    //   }, params);

    //   UtilService.get(url, {params: paramsExtended}).then(function(data){
    //     cbSuccess(data.articles);
    //   }).catch(function(error){
    //     cbError(error);
    //   });
    // }

    function subscribeToEvent (event_id) {
      var url = service.apiArticles + event_id + '/follow';
      var encodedParams = 'private_token=' + $rootScope.currentUser.private_token;

      return UtilService.post(url, encodedParams);
    }

    function sendContactForm (community_id, data){
      var url = service.apiCommunities + community_id + '/contact';
      var encodedParams = [
      'contact[name]=' + data.name,
      'contact[email]=' + data.email,
      'contact[subject]=' + data.subject,
      'contact[message]=' + data.message
      ].join('&');

      return UtilService.post(url, encodedParams);
    }

    function searchTopics (params, cbSuccess, cbError) {
      // Ex.: /api/v1/search/article?type=ProposalsDiscussionPlugin::Topic&query=cisternas
      var url = service.apiSearch + 'article';
      var paramsExtended = angular.extend({
        // 'fields[]': ['id', 'title', 'slug', 'abstract', 'categories', 'setting', 'children_count', 'hits'],
        'type': 'ProposalsDiscussionPlugin::Topic'
      }, params);

      UtilService.get(url, {params: paramsExtended}).then(function(data){
        cbSuccess(data);
      }).catch(function(error){
        cbError(error);
      });
    }

    function searchProposals (params, cbSuccess, cbError) {
      // Ex.: /api/v1/search/article?type=ProposalsDiscussionPlugin::Proposal&query=cisternas
      var url = service.apiSearch + 'article';
      var paramsExtended = angular.extend({
        page: 1,
        per_page: 10,
        type: 'ProposalsDiscussionPlugin::Proposal',
        'fields[]': [
        'id',
        'abstract',
        'hits',
        'ranking_position',
        'votes_against',
        'votes_count',
        'votes_for',
        'parent',
        'categories',
        'slug',
        'url', // parent.image.url
        'image',
        'title',
        'archived',
        ]
      }, params);

      UtilService.get(url, {params: paramsExtended}).then(function(data){
        _pipeInjectSlugIntoParentProgram(data);
        cbSuccess(data);
      }).catch(function(error){
        cbError(error);
      });
    }

    function _pipeInjectSlugIntoParentProgram(data){
      if(!data.articles && data.article){
        data.articles = [data.article];
      }
      var proposals = data.articles;
      for (var i = proposals.length - 1; i >= 0; i--) {
        var proposal = proposals[i];
        if(proposal.parent && !proposal.parent.slug){
          proposal.parent.slug = Slug.slugify(proposal.parent.title);
        }
      }
    }

//Refazer esse método. Não faz sentido
function _pipeInjectSlugIntoParentProgramRanked(data){
  if(!data.proposals && data.proposals){
    data.proposals = [data.proposals];
  }
  var proposals = data.proposals;
  for (var i = proposals.length - 1; i >= 0; i--) {
    var proposal = proposals[i];
    if(proposal.parent && !proposal.parent.slug){
      proposal.parent.slug = Slug.slugify(proposal.parent.title);
    }
  }
}

function _pipeRemoveOldEvents(data){
  if(!data.articles && data.article){
    data.articles = [data.article];
    data.article = null;
  }

  var now = (new Date()).getTime();
  var eventDate = null;
  var events = data.articles;

  var results = [];
  for (var i = events.length - 1; i >= 0; i--) {
    var event = events[i];

    if(event.end_date){
      eventDate = new Date(event.end_date);
    }

        // if(eventDate.getTime() < now){
        //   event.isOld = true;
        // }
        if(eventDate.getTime() >= now){
          results.push(event);
        }
      }

      data.articles = results;
    }
  }
})();