D-Net

import com.fasterxml.jackson.databind.DeserializationFeature;

import com.fasterxml.jackson.databind.ObjectMapper;

import eu.dnetlib.domain.enabling.Vocabulary;

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

import gr.uoa.di.driver.enabling.vocabulary.VocabularyLoader;

import org.apache.log4j.Logger;

import org.json.JSONArray;

import org.json.JSONException;

import org.json.JSONObject;

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

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.client.RestTemplate;

import org.springframework.web.util.UriComponents;

import org.springframework.web.util.UriComponentsBuilder;

import javax.annotation.PostConstruct;

import java.sql.Timestamp;

import java.text.Normalizer;

import java.util.*;

import java.util.concurrent.ConcurrentHashMap;

@Component

public class RepositoryApiImpl implements RepositoryApi {

    private RestTemplate restTemplate = null;

    private final String[] vocabularyNames = {"dnet:countries", "dnet:datasource_typologies", "dnet:compatibilityLevel"};

    private static final Logger LOGGER = Logger.getLogger(RepositoryApiImpl.class);

        restTemplate = new RestTemplate();

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

        for (String vocName : vocabularyNames) {

            vocabularyMap.put(vocName, vocabularyLoader.getVocabulary(vocName, Locale.ENGLISH, Locale.ROOT));

        }

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

        List<Repository> repos = Converter.jsonToRepositoryList(new JSONArray(rs));

        for (Repository r : repos){

            r.setCountryName(getCountryName(r.getCountryCode()));

        }

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

        Repository repo = Converter.jsonToRepositoryObject(new JSONObject(rs));

            repo.setCountryName(getCountryName(repo.getCountryCode()));

        return repo;

    }

    private void updateInterface(String datatype,RepositoryInterface iFace) {

        //TODO call update base url

        //((DatasourceManagerService) this.dmService.getService()).updateBaseUrl(repo.getId(), iFace.getId(), iFace.getBaseUrl());

        if (!iFace.getAccessSet().isEmpty()) {

            LOGGER.debug("set not empty: " + iFace.getAccessSet());

            //TODO call update method for access params

        iFace.setRemovable(true);

        iFace.setAccessProtocol("oai");

        iFace.setMetadataIdentifierPath("//*[local-name()='header']/*[local-name()='identifier']");

        if (iFace.getAccessSet().isEmpty()) {

            LOGGER.debug("set is empty: " + iFace.getAccessSet());

            iFace.removeAccessSet();

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

                .build()

                .encode();

    }

    @Override

    public RepositoryInterface addRepositoryInterface(@RequestBody String params) throws JSONException {

        JSONObject json_params = new JSONObject(params);

        String datatype = json_params.getString("datatype");

        String repoId = json_params.getString("repoId");

        String json_iFace = json_params.getString("iFace");

        try {

            e = this.getRepositoryById(repoId);

            iFace = createRepositoryInterface(e,iFace,datatype);

            UriComponents uriComponents = UriComponentsBuilder

                    .fromHttpUrl(baseAddress + "/ds/api/add/")

                    .build()

                    .encode();

        } catch (JSONException e1) {

            LOGGER.debug("Error parsing json ",e1);

        }