D-Net

package eu.dnetlib.repo.manager.service.controllers;

import eu.dnetlib.repo.manager.service.utils.Converter;

import eu.dnetlib.domain.data.Repository;

import eu.dnetlib.domain.data.RepositoryInterface;

import org.json.JSONArray;

import org.json.JSONException;

import org.json.JSONObject;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter;

import org.springframework.stereotype.Component;

import org.springframework.web.bind.annotation.PathVariable;

import org.springframework.web.bind.annotation.RequestBody;

import org.springframework.web.bind.annotation.RequestParam;

import org.springframework.web.client.RestTemplate;

import org.springframework.web.util.UriComponents;

import org.springframework.web.util.UriComponentsBuilder;

import javax.annotation.PostConstruct;

import java.util.List;

@Component

public class RepositoryApiImpl implements RepositoryApi {

    @Value("${api.baseAddress}")

    private String baseAddress;

    private RestTemplate restTemplate = null;

    @PostConstruct

    private void init(){

        restTemplate = new RestTemplate();

        restTemplate.getMessageConverters().add(new MappingJackson2HttpMessageConverter());

    }

    @Override

    public String getCountries()  {

        UriComponents uriComponents = UriComponentsBuilder

                .fromHttpUrl(baseAddress + "/ds/countries")

                .build().encode();

        return restTemplate.getForObject(uriComponents.toUri(), String.class);

    }

    @Override

    public List<Repository> getRepositoriesByCountry(@PathVariable("country") String country,

                                                     @PathVariable("page") String page,

                                                     @PathVariable("size") String size) throws JSONException {

       /* String vars = page+"/"+size+"?country="+country;

        String uri = baseAddress+ "/ds/search/country/" + vars;

        JSONArray jsonArray = new JSONArray(RestService.executeGET(uri));

        return Converter.jsonToRepositoryList(jsonArray);*/

        UriComponents uriComponents = UriComponentsBuilder

                                            .fromHttpUrl(baseAddress + "/ds/search/country/")

                                            .path("/{page}/{size}/")

                                            .queryParam("country",country)

                                            .build().expand(page,size).encode();

        RestTemplate template = new RestTemplate();

        template.getMessageConverters().add(new MappingJackson2HttpMessageConverter());

        String rs = template.getForObject(uriComponents.toUri(), String.class);

        return Converter.jsonToRepositoryList(new JSONArray(rs));

    }

    @Override

    public List<Repository> getRepositoriesOfUser(@PathVariable("userEmail") String userEmail,

                                                  @PathVariable("page") String page,

                                                  @PathVariable("size") String size) throws JSONException {

        String vars = page+"/"+size+"?contactemail="+userEmail;

        String uri = baseAddress+ "/ds/search/email/" + vars;

        JSONArray jsonArray = new JSONArray(RestService.executeGET(uri));

        return Converter.jsonToRepositoryList(jsonArray);

    }

    @Override

    public Repository getRepositoryById(@PathVariable("id") String id) throws JSONException {

        String uri = baseAddress+ "/ds/get/" + id;

        JSONObject jsonObject = new JSONObject( RestService.executeGET(uri) );

        return  Converter.jsonToRepositoryObject(jsonObject);

    }

    @Override

    public List<Repository> getRepositoriesByName(@PathVariable("name") String name,

                                                  @PathVariable("page") String page,

                                                  @PathVariable("size") String size) throws JSONException {

        String vars = page+"/"+size+"?name="+name;

        String uri = baseAddress+ "/ds/search/name/" + vars;

        JSONArray jsonArray = new JSONArray(RestService.executeGET(uri));

        return Converter.jsonToRepositoryList(jsonArray);

    }

    @Override

    public RepositoryInterface getRepositoyInterface(@PathVariable("id") String id) throws JSONException {

        String uri = baseAddress+ "/ds/service/" + id;

        JSONArray jsonArray = new JSONArray( RestService.executeGET(uri) );

        return  Converter.jsonToRepositoryInterfaceObject(jsonArray.getJSONObject(0));

    }

    @Override

    public String addRepository(@RequestBody Repository repository) throws JSONException {

        String uri = baseAddress+ "/ds/add/";

        return RestService.executePOST(uri, Converter.repositoryObjectToJson(repository));

    }

    @Override

    public String addRepositoryInterface(RepositoryInterface repositoryInterface) throws JSONException {

        String uri = baseAddress+ "/ds/service/add/";

        return RestService.executePOST(uri, Converter.repositoryInterfaceObjectToJson(repositoryInterface));

    }

    @Override

    public List<String> getDnetCountries() {

        return Converter.readFile("countries.txt");

    }

    @Override

    public List<String> getTypologies() {

        System.out.println("Typologies");

        return Converter.readFile("typologies.txt");

    }

    @Override

    public List<String> getTimezones() {

        return Converter.readFile("timezones.txt");

    }

    @Override

    public String updateManagedStatus(@RequestParam(value = "id")   String id,

                                      @RequestParam(value = "managed")  String managed) {

        String uri = baseAddress+ "/ds/manage?id="+id+"&managed="+managed;

        return RestService.executePOST(uri,null);

    }

    @Override

    public String updateEnglishName(@RequestParam(value = "id")   String id,

                                    @RequestParam(value = "englishname")  String englishName) {

        String uri = baseAddress+ "/ds/manage?dsId="+id+"&englishname="+englishName;

        return RestService.executePOST(uri,null);

    }

    @Override

    public String updateLatitude(@RequestParam(value = "id")   String id,

                                 @RequestParam(value = "managed")  String latitude) {

        String uri = baseAddress+ "/ds/manage?dsId="+id+"&latitude="+latitude;

        return RestService.executePOST(uri,null);

    }

    @Override

    public String updateLongitude(@RequestParam(value = "id")   String id,

                                  @RequestParam(value = "longitude")  String longitude) {

        String uri = baseAddress+ "/ds/manage?dsId="+id+"&longitude="+longitude;

        return RestService.executePOST(uri,null);

    }

    @Override

    public String updateOfficialName(@RequestParam(value = "id")   String id,

                                     @RequestParam(value = "officialname")  String officialname) {

        String uri = baseAddress+ "/ds/manage?dsId="+id+"&officialname="+officialname;

        return RestService.executePOST(uri,null);

    }

    @Override

    public String getUrlsOfUserRepos(@PathVariable("user_email") String user_email) {

        //TODO create service a join datasource d for user u method

        return null;

    }

}