openaire-library/services/searchOrganizations.service.ts

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 {SearchResult}     from '../utils/entities/searchResult';
import {RefineResultsUtils} from './servicesUtils/refineResults.class';
import{EnvProperties} from '../utils/properties/env-properties';
import {StringUtils} from '../utils/string-utils.class';

@Injectable()
export class SearchOrganizationsService {

    constructor(private http: Http ) {}

    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[] , properties:EnvProperties):any {

        console.info("In searchOrganizations");

        let link = properties.searchAPIURLLAst+"organizations";

        let url = link+"?";
        if(params!= null && params != ''  ) {
            url += params;
        }
        if(refineParams!= null && refineParams != ''  ) {
            url += refineParams;
        }
        url += "&page="+(page-1)+"&size="+size + "&format=json";


        return this.http.get((properties.useCache)? (properties.cacheUrl+encodeURIComponent(url)): 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, "organization")]);
    }
    advancedSearchOrganizations (params: string, page: number, size: number, properties:EnvProperties ):any {
      let url = properties.searchResourcesAPIURL;
      var basicQuery = "oaftype exact organization and "
      +"(reldatasourcecompatibilityid exact driver or reldatasourcecompatibilityid exact driver-openaire2.0 or " +
                "reldatasourcecompatibilityid exact openaire2.0 or reldatasourcecompatibilityid exact openaire3.0 or " +
                "reldatasourcecompatibilityid exact openaire2.0_data or reldatasourcecompatibilityid exact hostedBy or relproject=*)";

      url += "?query=";
      if(params!= null && params != ''  ) {
        url +=" ( "+basicQuery+ " ) " +" and (" + params + ")";
      }else{
        url +=" ( "+basicQuery+ " ) ";
      }

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

      return this.http.get((properties.useCache)? (properties.cacheUrl+encodeURIComponent(url)): url)
      .map(res => <any> res.json())
      //.do(res => console.info(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:organization'] : data['result']['metadata']['oaf:entity']['oaf:organization'];

            var result: SearchResult = new SearchResult();

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

            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'];
            result['id'] = 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<
                                    { "id": string, "acronym": string, "title": string,
                                      "funderShortname": string, "funderName": string,
                                      "code": string
                                    }>();
                            }

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

                            result['projects'][countProjects] = {
                                "id": "", "acronym": "", "title": "",
                                "funderShortname": "", "funderName": "",
                                "code": ""
                            }

                            if(relation.title != 'unidentified') {
                                result['projects'][countProjects]['id'] =
                                    /*OpenaireProperties.getsearchLinkToProject() + */relation['to'].content;
                                result['projects'][countProjects]['acronym'] = relation.acronym;
                                result['projects'][countProjects]['title'] = relation.title;
                                result['projects'][countProjects]['code'] = relation.code;
                            } else {
                                result['projects'][countProjects]['id'] = "";
                                result['projects'][countProjects]['acronym'] = "";
                                result['projects'][countProjects]['title'] = "";
                                result['projects'][countProjects]['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;
    }

    numOfOrganizations(url: string, properties:EnvProperties ): any {

      return this.http.get((properties.useCache)? (properties.cacheUrl+encodeURIComponent(url)): url)
                  .map(res => <any> res.json())
                  .map(res => res.total);
    }

    numOfEntityOrganizations(id: string, entity: string, properties:EnvProperties ):any {
        // currently not used - if used fix entity comparison below
        var parameters: string = "";
        if(entity == "organization") {
          parameters = "organizations/"+id+"/organizations/count";
        }

        let url = properties.searchAPIURLLAst+parameters+"?format=json";
        return this.numOfOrganizations(url, properties);
    }

    numOfSearchOrganizations(params: string, properties:EnvProperties ):any {
        let url = properties.searchAPIURLLAst+"organizations/count?format=json";
        if(params != "") {
          url += "&q=" + StringUtils.URIEncode(params);
        }
        return this.numOfOrganizations(url, properties);
    }
}