D-Net

import {Injectable} from '@angular/core';

import {Http, Response} from '@angular/http';

import {Observable}     from 'rxjs/Observable';

import 'rxjs/add/observable/of';

import 'rxjs/add/operator/do';

import 'rxjs/add/operator/share';

import { CacheService  } from '../shared/cache.service';

import {OpenaireProperties} from '../utils/properties/openaireProperties';

import {SearchResult}     from '../utils/entities/searchResult';

import {RefineResultsUtils} from './servicesUtils/refineResults.class';

@Injectable()

export class SearchPeopleService {

    constructor(private http: Http, public _cache: CacheService) {}

    searchPeople (params: string, refineParams:string, page: number, size: number, refineFields:string[] ):any {

        console.info("In searchProjects");

        let link = OpenaireProperties.getSearchAPIURLLast()+"people";

        let url = link+"?";

        if(params!= null && params != ''  ) {

            url += params;

        }

        if(refineParams!= null && params != ''  ) {

            url += refineParams;

        }

        url += "&page="+(page-1)+"&size="+size + "&format=json";

        let key = url;

        if (this._cache.has(key)) {

          return Observable.of(this._cache.get(key)).map(res => [res['meta'].total, this.parseResults(res['results']),RefineResultsUtils.parse(res['refineResults'],refineFields, "person")]);

        }

        return this.http.get(url)

                    .map(res => <any> res.json())

                    //.do(res => console.info(res))

                    .do(res => {

                      this._cache.set(key, res);

                    })

                    .map(res => [res['meta'].total, this.parseResults(res['results']),RefineResultsUtils.parse(res['refineResults'],refineFields, "person")]);

    }

    advancedSearchPeople (params: string, page: number, size: number ):any {

      let url = OpenaireProperties.getSearchResourcesAPIURL();

      var basicQuery = "(oaftype exact person) "

      url += "?query=";

      if(params!= null && params != ''  ) {

        url +=" ( "+basicQuery+ " ) " +" and (" + params + ")";

      }else{

        url +=" ( "+basicQuery+ " ) ";

      }

      url += "&page="+(page-1)+"&size="+size;

      url += "&format=json";

      let key = url;

      if (this._cache.has(key)) {

        return Observable.of(this._cache.get(key)).map(res => [res['meta'].total, this.parseResults(res['results'])]);

      }

      return this.http.get(url)

      .map(res => <any> res.json())

      //.do(res => console.info(res))

      .do(res => {

        this._cache.set(key, res);

      })

      .map(res => [res['meta'].total, this.parseResults(res['results'])]);

    }

    parseResults(data: any): SearchResult[] {

        let results: SearchResult[] = [];

        let length = Array.isArray(data) ? data.length : 1;

        for(let i=0; i<length; i++) {

            let resData = Array.isArray(data) ? data[i]['result']['metadata']['oaf:entity']['oaf:person'] : data['result']['metadata']['oaf:entity']['oaf:person'];

            var result: SearchResult = new SearchResult();

            result['title'] = {"name": '', "url": '', "accessMode": ''};

            result['title'].name = resData.fullname;

            result['title'].url = OpenaireProperties.getsearchLinkToPerson();

            result['title'].url +=  Array.isArray(data) ? data[i]['result']['header']['dri:objIdentifier'] : data['result']['header']['dri:objIdentifier'];

            results.push(result);

        }

        return results;

    }

    numOfEntityPeople(id: string, entity: string):any {

        //OpenaireProperties.getSearchAPIURLLast()

        //"http://rudie.di.uoa.gr:8080/dnet-functionality-services-2.0.0-SNAPSHOT/rest/v2/api/"

        let url = OpenaireProperties.getSearchAPIURLLast()+entity+id+"/people/count"+ "?format=json";

        let key = url;

        if (this._cache.has(key)) {

          return Observable.of(this._cache.get(key));

        }

        return this.http.get(url)

                    .map(res => <any> res.json())

                    .map(res => res.total)

                    .do(res => {

                      this._cache.set(key, res);

                    });

    }

    numOfSearchPeople(params: string):any {

        //OpenaireProperties.getSearchAPIURLLast()

        //"http://rudie.di.uoa.gr:8080/dnet-functionality-services-2.0.0-SNAPSHOT/rest/v2/api/"

        let url = OpenaireProperties.getSearchAPIURLLast()+"people/count?q="+'"' + params + '"'+ "&format=json";

        let key = url;

        if (this._cache.has(key)) {

          return Observable.of(this._cache.get(key));

        }

        return this.http.get(url)

                    .map(res => <any> res.json())

                    .map(res => res.total)

                    .do(res => {

                      this._cache.set(key, res);

                    });

    }

}