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

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

    searchOrganizationsForDeposit (params: string, collectedFrom: string, page: number, size: number):any {

        console.info("In searchOrganizationsforDeposit");

        let link = OpenaireProperties.getSearchResourcesAPIURL();

        let url = link+"?query=";

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

          url += "((oaftype exact organization and deletedbyinference=false and "+

            "(reldatasourcecompatibilityid=driver or reldatasourcecompatibilityid=driver-openaire2.0 or reldatasourcecompatibilityid=openaire2.0 or reldatasourcecompatibilityid=openaire3.0 or reldatasourcecompatibilityid=openaire2.0_data or reldatasourcecompatibilityid=hostedBy or relprojectid=*))"+

            " and ((organizationlegalname all "+this.quote(params)+") or (organizationlegalshortname all "+this.quote(params)+")) " +

            // "and " + this.quote(params) + " " +

            "and (collectedfromdatasourcename exact "+collectedFrom+")) "

        }

        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 => this.parseResultsForDeposit(res['results']))

                    .do(res => {

                      this._cache.set(key, res);

                    });

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

    }

    quote(params: string):string {

        return encodeURIComponent('"'+params+'"');

        //return '"'+params+'"';

    }

    parseResultsForDeposit(data: any): {"name": string, "id": string}[] {

        let results: {"name": string, "id": string}[] = [];

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

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

            let name: string = '';

            let id: string = '';

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

            name = resData.legalname;

            if(name == '') {

                name = resData.legalshortname;

            }

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

            results.push({"name": name, "id": id});

        }

        console.info(results);

        return results;

    }

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

        console.info("In searchOrganizations");

        let link = OpenaireProperties.getSearchAPIURL()+"organizations";

        let url = link+"?";

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

            url += params;

        }

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

            url += refineParams;

        }

        url += "&page="+page+"&size="+size;

        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']),RefineResultsUtils.parse(res['refineResults'],refineFields)])

                    .do(res => {

                      this._cache.set(key, res);

                    });

    }

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

      let url = OpenaireProperties.getSearchResourcesAPIURL();

      var basicQuery = "(oaftype exact organization) "

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

      });

    }

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

            var result: SearchResult = new SearchResult();

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

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

            if(result['title'].name == '') {

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

            }

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

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

                            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;

                                    }

                                }

                            }

                        }

                    }

                }

            }

            if(resData.country.hasOwnProperty("classname")) {

                result.country = resData.country.classname;

            }

            results.push(result);

        }

        return results;

    }

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

        //OpenaireProperties.getSearchAPIURL()

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

        let url = OpenaireProperties.getSearchAPIURL()+entity+id+"/organizations/count"

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

                    });

    }

    numOfSearchOrganizations(params: string):any {

        //OpenaireProperties.getSearchAPIURL()

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

        let url = OpenaireProperties.getSearchAPIURL()+"organizations/count?q="+params;

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

                    });

    }

}