D-Net

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

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

import {Observable}     from 'rxjs/Observable';

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

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

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

import 'rxjs/add/observable/of';

import 'rxjs/add/operator/do';

import 'rxjs/add/operator/share';

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

@Injectable()

export class SearchDatasetsService {

    private sizeOfDescription: number = 497;

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

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

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

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

        }

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

    }

    searchDatasetsByDois (DOIs: string[], refineParams:string, page: number, size: number, refineFields:string[] ):any {

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

        let url = link+"?";

        var doisParams = "";

        for(var i =0 ;i < DOIs.length; i++){

          doisParams+=(doisParams.length > 0?" or ":"")+'((pidclassid exact doi) and (pid exact "'+ DOIs[i]+'"))';

        }

        if(doisParams.length > 0){

          url += "q=("+doisParams+")"

        }

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

        }

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

    }

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

      let url = OpenaireProperties.getSearchResourcesAPIURL();

      var basicQuery = "(oaftype exact result) and (resulttypeid exact dataset)  "

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

      }

      return this.http.get(url)

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

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

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

      .do(res => {

        this._cache.set(key, res);

      });

    }

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

        let link = OpenaireProperties.getSearchAPIURLLast();

        let url = link+params+"/datasets"+"?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'])]);

    }

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

        let link = OpenaireProperties.getSearchAPIURLLast();

        let url = link+params+"&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'])]);

    }

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

            var result: SearchResult = new SearchResult();

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

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

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

            } else {

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

            }

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

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

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

            if(resData['bestlicense'].hasOwnProperty("classid")) {

                result['title'].accessMode = resData['bestlicense'].classid;

            }

            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 == "hasAuthor") {

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

                                result['authors'] = new Array<{"name": string, "url": string}>();

                            }

                            result['authors'].push({"name": relation.fullname, "url": OpenaireProperties.getsearchLinkToPerson()+relation['to'].content});

                        } else if(relation['to'].class == "isProducedBy") {

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

                                result['projects'] = new Array<

                                    { "url": string, "acronym": string, "title": string,

                                      "funderShortname": string, "funderName": string,

                                      "code": string

                                    }>();

                            }

                            let countProjects = result['projects'].length;

                            result['projects'][countProjects] = {

                                "url": "", "acronym": "", "title": "",

                                "funderShortname": "", "funderName": "",

                                "code": ""

                            }

                            result['projects'][countProjects]['url'] =

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

                            result['projects'][countProjects]['acronym'] = relation.acronym;

                            result['projects'][countProjects]['title'] = relation.title;

                            result['projects'][countProjects]['code'] = relation.code;

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

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

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

                                    let fundingData = Array.isArray(relation['funding']) ? relation['funding'][z] : relation['funding'];

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

                                        result['projects'][countProjects]['funderShortname'] = fundingData['funder'].shortname;

                                        result['projects'][countProjects]['funderName'] = fundingData['funder'].name;

                                    }

                                }

                            }

                        }

                    }

                }

            }

            result.year = resData.dateofacceptance.split('-')[0];

            if(!Array.isArray(resData.description)) {

                result.description = resData.description;

            } else {

                result.description = resData.description[0];

            }

            if(result.description.length > this.sizeOfDescription) {

                result.description = result.description.substring(0, this.sizeOfDescription)+"...";

            }

            result.embargoEndDate = resData.embargoenddate;

            if(!Array.isArray(resData.publisher)) {

                result.publisher = resData.publisher;

            } else {

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

                    if(result.publisher != undefined){

                        result.publisher += ', '+resData['publisher'][i];

                    } else {

                        result.publisher = resData['publisher'][i];

                    }

                }

            }

            results.push(result);

        }

        return results;

    }

    numOfEntityDatasets(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+"/datasets/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);

                    });

    }

    numOfSearchDatasets(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()+"datasets/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);

                    });

    }

}