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 SearchProjectsService {

    private sizeOfDescription: number = 497;

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

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

        console.info("In searchProjects");

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

        let url = link+"?";

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

            url += params;

        }

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

            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, "project")]);

        }

        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, "project")]);

    }

    getProjectsforDataProvider (datasourceId: string, page: number, size: number ):any {

      let url = OpenaireProperties.getSearchResourcesAPIURL();

      var basicQuery = "(oaftype exact project) "

      url += "?query=";

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

        url +=" ( "+basicQuery+ " ) " +" and (collectedfromdatasourceid exact \"" + datasourceId + "\")";

      }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 => {

        this._cache.set(key, res);

      })

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

    }

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

      let url = OpenaireProperties.getSearchResourcesAPIURL();

      var basicQuery = "(oaftype exact project) "

      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'])]);

    }

    getFunders():any {

       let url = OpenaireProperties.getSearchAPIURLLast()+"projects?refine=true&fields=funderid&size=0"+ "&format=json";;

       let key = url;

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

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

       }

       return this.http.get(url)

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

                   .do(res => {

                     this._cache.set(key, res);

                   })

                   .map(res => [res['meta'].total, res['refineResults']['funderid']]);

      }

      searchForProjectsObs(keyword:string, funderId:string):any {

         let url = 'search?action=search&sTransformer=projects_openaire&query='+

         '%28oaftype+exact+project%29+and+%28%28projecttitle+%3D+%22'+keyword+'%22%29+or+%28projectacronym+%3D+%22'+keyword+'%22%29+or+%28projectcode+%3D+%22'+keyword+'%22%29%29+and+%28funderid+exact+'+funderId+'%29&size=10&locale=en_GB&format=json';

         let key = url;

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

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

         }

         return this.http.get(url).toPromise()

                    .then(request =>{

                      return (request.json().response.results)?request.json().response.results.result:request.json().response.result;

                }) ;

        }

    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:project'] : data['result']['metadata']['oaf:entity']['oaf:project'];

            var result: SearchResult = new SearchResult();

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

            if(Array.isArray(resData['title'])) {

                // resData['title'][0].hasOwnProperty("content") {

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

                // }

            } else {

                // resData['title'].hasOwnProperty("content") {

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

                // }

            }

            // if(resData['title'].hasOwnProperty("content")) {

            //     result['title'].name = resData['title'].content;

            // }

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

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

            if(resData['rels'].hasOwnProperty("rel")) {

                let relLength = Array.isArray(resData['rels']['rel']) ? resData['rels']['rel'].length : 1;

                for(let j=0; j<relLength; j++) {

                    let relation = Array.isArray(resData['rels']['rel']) ? resData['rels']['rel'][j] : resData['rels']['rel'];

                    if(relation.hasOwnProperty("to")) {

                         if(relation['to'].class == "hasParticipant") {

                            if(result['organizations'] == undefined) {

                                result['organizations'] = new Array<

                                    { "name": string, "url": string}>();

                            }

                            let countOrganizations = result['organizations'].length;

                            result['organizations'][countOrganizations] = { "name": "", "url": "" }

                            result['organizations'][countOrganizations]['url'] =

                                OpenaireProperties.getsearchLinkToOrganization() + relation['to'].content;

                            result['organizations'][countOrganizations]['name'] = relation.legalname;

                        }

                    }

                }

            }

            if(resData.hasOwnProperty("fundingtree")) {

              if(result['funders'] == undefined) {

                  result['funders'] = new Array<

                      {"funderShortname": string, "funderName": string}>();

              }

                let fundingLength = Array.isArray(resData['fundingtree']) ? resData['fundingtree'].length : 1;

                for(let z=0; z<fundingLength; z++) {

                    let fundingData = Array.isArray(resData['fundingtree']) ? resData['fundingtree'][z] : resData['fundingtree'];

                      let countFunders = result['funders'].length;

                    if(fundingData.hasOwnProperty("funder")) {

                        result['funders'][countFunders] =   {"funderShortname": "", "funderName": ""};

                        result['funders'][countFunders]['funderShortname'] = fundingData['funder'].shortname;

                        result['funders'][countFunders]['funderName'] = fundingData['funder'].name;

                    }

                }

            }

            if(resData.hasOwnProperty("startdate")) {

              result.startYear = resData.startdate.split('-')[0];

            }

            if(resData.hasOwnProperty("enddate")) {

              result.endYear = resData.enddate.split('-')[0];

            }

            results.push(result);

        }

        return results;

    }

    numOfEntityProjects(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+"/projects/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);

                    });

    }

    numOfSearchProjects(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()+"projects/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);

                    });

    }

}