D-Net

package eu.dnetlib.repo.manager.service;

import com.fasterxml.jackson.databind.ObjectMapper;

import eu.dnetlib.api.functionality.ValidatorServiceException;

import eu.dnetlib.domain.data.Repository;

import eu.dnetlib.domain.data.RepositoryInterface;

import eu.dnetlib.domain.enabling.Vocabulary;

import eu.dnetlib.domain.functionality.validator.JobForValidation;

import eu.dnetlib.repo.manager.domain.*;

import eu.dnetlib.repo.manager.exception.ResourceNotFoundException;

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

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

import org.apache.commons.codec.digest.DigestUtils;

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.core.ParameterizedTypeReference;

import org.springframework.http.*;

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

import org.springframework.security.core.Authentication;

import org.springframework.security.core.context.SecurityContextHolder;

import org.springframework.stereotype.Service;

import org.springframework.web.client.RestClientException;

import org.springframework.web.client.RestTemplate;

import org.springframework.web.util.UriComponents;

import org.springframework.web.util.UriComponentsBuilder;

import javax.annotation.PostConstruct;

import java.io.IOException;

import java.sql.Timestamp;

import java.util.*;

import java.util.concurrent.ConcurrentHashMap;

import java.util.stream.Collectors;

@Service("repositoryService")

public class RepositoryServiceImpl implements RepositoryService {

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

    private String baseAddress;

    @Value("${services.repo-manager.adminEmail}")

    private String adminEmail;

    @Autowired

    RestTemplate restTemplate;

    private HttpHeaders httpHeaders;

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

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

    @Value("${services.repomanager.usageStatisticsDiagramsBaseURL}")

    private String usageStatisticsDiagramsBaseURL;

    @Value("${services.repomanager.usageStatisticsNumbersBaseURL}")

    private String usageStatisticsNumbersBaseURL;

    @Autowired

    private VocabularyLoader vocabularyLoader;

    @Autowired

    private PiWikService piWikService;

    @Autowired

    private EmailUtils emailUtils;

    @Autowired

    ValidatorService validatorService;

    private Map<String, Vocabulary> vocabularyMap = new ConcurrentHashMap<>();

    private Map<String, String> countriesMap = new HashMap<>();

    private Map<String, String> inverseCountriesMap = new HashMap<>();

    private static Map<String,List<String>> dataSourceClass = new HashMap<>();

    private static Map<String,String> invertedDataSourceClass = new HashMap<>();

    @PostConstruct

    private void init() {

        LOGGER.debug("Initialization method of repository api!");

        LOGGER.debug("Updated version!");

        dataSourceClass.put("opendoar",Arrays.asList("pubsrepository::institutional","pubsrepository::thematic","pubsrepository::unknown","pubsrepository::mock"));

        dataSourceClass.put("re3data", Collections.singletonList("datarepository::unknown"));

        dataSourceClass.put("journal", Collections.singletonList("pubsrepository::journal"));

        dataSourceClass.put("aggregator",Arrays.asList("aggregator::pubsrepository::institutional","aggregator::pubsrepository::journals","aggregator::datarepository", "aggregator::pubsrepository::unknown"));

        invertedDataSourceClass.put("pubsrepository::institutional","opendoar");

        invertedDataSourceClass.put("pubsrepository::thematic","opendoar");

        invertedDataSourceClass.put("pubsrepository::unknown","opendoar");

        invertedDataSourceClass.put("pubsrepository::mock","opendoar");

        invertedDataSourceClass.put("datarepository::unknown","re3data");

        invertedDataSourceClass.put("pubsrepository::journal","journal");

        invertedDataSourceClass.put("aggregator::pubsrepository::institutional","aggregator");

        invertedDataSourceClass.put("aggregator::pubsrepository::journals","aggregator");

        invertedDataSourceClass.put("aggregator::datarepository","aggregator");

        invertedDataSourceClass.put("aggregator::pubsrepository::unknown","aggregator");

        httpHeaders = new HttpHeaders();

        httpHeaders.setContentType(MediaType.APPLICATION_JSON_UTF8);

        for (String vocName : vocabularyNames) {

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

        }

        Country[] countries = getCountries();

        for (Country c : countries) {

            countriesMap.put(c.getName(), c.getCode());

            inverseCountriesMap.put(c.getCode(), c.getName());

        }

    }

    @Override

    public Country[] getCountries() {

        UriComponents uriComponents = UriComponentsBuilder

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

                .build().encode();

        return restTemplate.getForObject(uriComponents.toUri(), Country[].class);

    }

    @Override

    public List<RepositorySnippet> getRepositoriesByCountry(String country,

                                                            String mode,

                                                            Boolean managed) throws JSONException, IOException {

        LOGGER.debug("Getting repositories by country!");

        int page = 0;

        int size = 100;

        List<RepositorySnippet> resultSet = new ArrayList<>();

        ObjectMapper mapper = new ObjectMapper();

        String filterKey = "UNKNOWN";

        if (mode.equalsIgnoreCase("opendoar"))

            filterKey = "openaire____::opendoar";

        else if (mode.equalsIgnoreCase("re3data"))

            filterKey = "openaire____::re3data";

        LOGGER.debug("Country code equals : " + country);

        LOGGER.debug("Filter mode equals : " + filterKey);

        UriComponents uriComponents = searchSnipperDatasource(String.valueOf(page),String.valueOf(size));

        RequestFilter requestFilter = new RequestFilter();

        requestFilter.setCountry(country);

        requestFilter.setCollectedfrom(filterKey);

        try{

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

            JSONArray jsonArray = (JSONArray) new JSONObject(rs).get("datasourceInfo");

            while (jsonArray.length() > 0 ) {

                resultSet.addAll(mapper.readValue(String.valueOf(jsonArray),

                        mapper.getTypeFactory().constructCollectionType(List.class, RepositorySnippet.class)));

                page += 1;

                uriComponents = searchSnipperDatasource(String.valueOf(page),String.valueOf(size));

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

                jsonArray = (JSONArray) new JSONObject(rs).get("datasourceInfo");

            }

            return resultSet;

        }catch (Exception e){

            LOGGER.debug("Exception on getRepositoriesByCountry" , e);

//            emailUtils.reportException(e);

            throw e;

        }

    }

    public List<RepositorySnippet> searchRegisteredRepositories(String country, String typology, String englishName,

            String officialName, String requestSortBy, String order, int page, int pageSize) throws Exception {

        LOGGER.debug("Searching registered repositories");

        List<RepositorySnippet> resultSet = new ArrayList<>();

        ObjectMapper mapper = new ObjectMapper();

        UriComponents uriComponents = searchRegisteredDatasource(requestSortBy, order, Integer.toString(page), Integer.toString(pageSize));

        RequestFilter requestFilter = new RequestFilter();

        requestFilter.setCountry(country);

        requestFilter.setTypology(typology);

        requestFilter.setOfficialname(officialName);

        requestFilter.setEnglishname(englishName);

        try {

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

            JSONArray jsonArray = (JSONArray) new JSONObject(rs).get("datasourceInfo");

            resultSet.addAll(mapper.readValue(String.valueOf(jsonArray),  mapper.getTypeFactory().constructCollectionType(List.class, RepositorySnippet.class)));

             return resultSet;

        }catch (Exception e){

            LOGGER.error("Error searching registered datasources" , e);

            throw e;

        }

    }

    private Repository updateRepositoryInfo(Repository r) throws JSONException {

        /*

        * from datasource class

        * we get the datasource type form the inverted map

        * */

        r.setDatasourceType(getRepositoryType(r.getDatasourceClass()));

        r.setInterfaces(this.getRepositoryInterface(r.getId()));

        r.setPiwikInfo(piWikService.getPiwikSiteForRepo(r.getId()));

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

        return r;

    }

    private Collection<Repository> getRepositoriesByMode(String mode, List<Repository> rs) {

        List<Repository> reps = new ArrayList<>();

        for (Repository r : rs) {

            if (r.getCollectedFrom() != null && r.getCollectedFrom().equals(mode))

                reps.add(r);

        }

        return reps;

    }

    @Override

    public List<Repository> getRepositoriesOfUser(String userEmail,

                                                  String page,

                                                  String size) throws JSONException {

        LOGGER.debug("Retreiving repositories of user : " + userEmail );

        UriComponents uriComponents = searchDatasource(page,size);

        RequestFilter requestFilter = new RequestFilter();

        requestFilter.setRegisteredby(userEmail);

        try{

            long start = System.currentTimeMillis();

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

            long end = System.currentTimeMillis();

            System.out.println("POST request finished in " + (end-start)+"ms");

            start=System.currentTimeMillis();

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

            end=System.currentTimeMillis();

            System.out.println("Converting json to repo list finished in " + (end-start)+"ms");

            start=System.currentTimeMillis();

            for (Repository r : repos)

                r.setPiwikInfo(piWikService.getPiwikSiteForRepo(r.getId()));

            end=System.currentTimeMillis();

            System.out.println("Updating "+repos.size()+" repository infos in " + (end-start)+"ms");

            return repos;

        }catch (Exception e){

            LOGGER.debug("Exception on getRepositoriesOfUser" , e);

            emailUtils.reportException(e);

            throw e;

        }

    }

    @Override

    public Repository getRepositoryById(String id) throws JSONException,ResourceNotFoundException {

        LOGGER.debug("Retreiving repositories with id : " + id );

        Repository repo = null;

        UriComponents uriComponents = searchDatasource("0","100");

        RequestFilter requestFilter = new RequestFilter();

        requestFilter.setId(id);

        try{

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

            JSONArray jsonArray = (JSONArray) new JSONObject(rs).get("datasourceInfo");

            if(jsonArray.length() == 0)

                throw new ResourceNotFoundException();

            repo = Converter.jsonToRepositoryObject(jsonArray.getJSONObject(0));

            return updateRepositoryInfo(repo);

        }catch (JSONException e){

            LOGGER.debug("Exception on getRepositoryById" , e);

            emailUtils.reportException(e);

            throw e;

        }

    }

    @Override

    public List<AggregationDetails> getRepositoryAggregations(String id, int from, int size) throws JSONException {

        LOGGER.debug("Retreiving aggregations for repository with id : " + id );

        UriComponents uriComponents = searchDatasource(from+"",size+"");

        RequestFilter requestFilter = new RequestFilter();

        requestFilter.setId(id);

        List<AggregationDetails> aggregationHistory = new ArrayList<>();

        try {

            long start = System.currentTimeMillis();

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

            long end = System.currentTimeMillis();

            System.out.println("Aggregations request through rest template took " + (end-start)+"ms");

            JSONObject repository = new JSONObject(rs);

            if(repository.getJSONArray("datasourceInfo").length() == 0)

                return aggregationHistory;

            start = System.currentTimeMillis();

            aggregationHistory.addAll(Converter.getAggregationHistoryFromJson(repository.getJSONArray("datasourceInfo").getJSONObject(0)));

            end = System.currentTimeMillis();

            System.out.println("Getting aggregations history from json " + (end-start)+"ms");

            return aggregationHistory.size() == 0? aggregationHistory : aggregationHistory.stream()

                                                    .sorted(Comparator.comparing(AggregationDetails::getDate).reversed())

                                                    .limit(size)

                                                    .collect(Collectors.toList());

        } catch (JSONException e) {

            LOGGER.debug("Exception on getRepositoryAggregations" , e);

            emailUtils.reportException(e);

            throw e;

        }

    }

    @Override

    public Map<String, List<AggregationDetails>> getRepositoryAggregationsByYear(String id) throws JSONException {

        LOGGER.debug("Retreiving aggregations (by year) for repository with id : " + id );

        UriComponents uriComponents = searchDatasource("0","100");

        RequestFilter requestFilter = new RequestFilter();

        requestFilter.setId(id);

        List<AggregationDetails> aggregationHistory = new ArrayList<>();

        Map<String, List<AggregationDetails>> aggregationByYear = new HashMap<>();

        try {

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

            JSONObject repository = new JSONObject(rs);

            if(repository.getJSONArray("datasourceInfo").length() == 0)

                return aggregationByYear;

            aggregationHistory.addAll(Converter.getAggregationHistoryFromJson(repository.getJSONArray("datasourceInfo").getJSONObject(0)));

            return aggregationHistory.size() == 0? aggregationByYear:createYearMap(aggregationHistory);

        } catch (JSONException e) {

            LOGGER.debug("Exception on getRepositoryAggregations" , e);

            emailUtils.reportException(e);

            throw e;

        }

    }

    private Map<String,List<AggregationDetails>> createYearMap(List<AggregationDetails> aggregationHistory) {

        Map<String, List<AggregationDetails>> aggregationByYear;

        aggregationHistory = aggregationHistory.stream()

                            .sorted(Comparator.comparing(AggregationDetails::getDate).reversed())

                            .collect(Collectors.toList());

       return aggregationHistory.stream()

                            .collect(Collectors.groupingBy(AggregationDetails::getYear));

    }

    @Override

    public List<Repository> getRepositoriesByName(String name,

                                                  String page,

                                                  String size) throws JSONException {

        LOGGER.debug("Retreiving  repositories with official name : " + name );

        UriComponents uriComponents = searchDatasource("0","100");

        RequestFilter requestFilter = new RequestFilter();

        requestFilter.setOfficialname(name);

        try{

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

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

            for (Repository r : repos)

                updateRepositoryInfo(r);

            return repos;

        }catch (Exception e){

            LOGGER.debug("Exception on getRepositoriesByName" , e);

            emailUtils.reportException(e);

            throw e;

        }

    }

    @Override

    public List<RepositoryInterface> getRepositoryInterface(String id) throws JSONException {

        UriComponents uriComponents = UriComponentsBuilder

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

                .path("/{id}")

                .build().expand(id).encode();

        try{

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

            return Converter.jsonToRepositoryInterfaceList(new JSONObject(rs));

        }catch (Exception e ){

            LOGGER.debug("Exception on getRepositoryInterface" , e);

            emailUtils.reportException(e);

            throw e;

        }

    }

    @Override

    public Repository addRepository(String datatype,

                                    Repository repository) throws Exception {

        LOGGER.debug("storing " + datatype + " repository with id: " + repository.getId());

        repository.setCountryCode(countriesMap.get(repository.getCountryName()));

        repository.setActivationId(UUID.randomUUID().toString());

        repository.setCollectedFrom("infrastruct_::openaire");

        if (datatype.equals("journal")) {

            repository.setId("openaire____::issn" + repository.getIssn());

            repository.setNamespacePrefix("issn" + repository.getIssn());

            this.storeRepository(repository, SecurityContextHolder.getContext().getAuthentication());

        }else if (datatype.equals("aggregator")) {

            repository.setId("openaire____::" + com.unboundid.util.Base64.encode(repository.getOfficialName()));

            repository.setNamespacePrefix(DigestUtils.md5Hex(repository.getOfficialName()).substring(0,12));

            this.storeRepository(repository, SecurityContextHolder.getContext().getAuthentication());

        }else {

            this.latentUpdate(repository, SecurityContextHolder.getContext().getAuthentication());

        }

        return repository;

    }

    /* update method acting as add -> send email with registration topic/body*/

    private Repository latentUpdate(Repository repository, Authentication authentication) throws Exception {

        UriComponents uriComponents = UriComponentsBuilder

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

                .build()

                .encode();

        try {

            String json_repository = Converter.repositoryObjectToJson(repository);

            LOGGER.debug("JSON to add(update) -> " + json_repository);

            HttpEntity<String> httpEntity = new HttpEntity<String>(json_repository, httpHeaders);

            ResponseEntity responseEntity = restTemplate.exchange(uriComponents.toUri(),HttpMethod.POST, httpEntity, ResponseEntity.class);

            if (responseEntity.getStatusCode().equals(HttpStatus.OK)) {

                emailUtils.sendUserRegistrationEmail(repository, authentication);

                emailUtils.sendAdminRegistrationEmail(repository, authentication);

            } else

                LOGGER.debug(responseEntity.getBody().toString());

            return repository;

        } catch (Exception e) {

            LOGGER.debug("Exception on updateRepository" , e);

            emailUtils.reportException(e);

            throw e;

        }

    }

    @Override

    public Repository updateRepository(Repository repository,Authentication authentication) throws Exception {

        UriComponents uriComponents = UriComponentsBuilder

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

                .build()

                .encode();

        try {

            String json_repository = Converter.repositoryObjectToJson(repository);

            LOGGER.debug("JSON to update -> " + json_repository);

            HttpEntity<String> httpEntity = new HttpEntity<String>(json_repository, httpHeaders);

            ResponseEntity responseEntity = restTemplate.exchange(uriComponents.toUri(),HttpMethod.POST, httpEntity

                    , ResponseEntity.class);

            if (responseEntity.getStatusCode().equals(HttpStatus.OK)) {

                emailUtils.sendUserUpdateRepositoryEmail(repository, authentication);

                emailUtils.sendAdminUpdateRepositoryEmail(repository, authentication);

            } else

                LOGGER.debug(responseEntity.getBody().toString());

            return repository;

        } catch (Exception e) {

            LOGGER.debug("Exception on updateRepository" , e);

            emailUtils.reportException(e);

            throw e;

        }

    }

    private void storeRepository(Repository repository, Authentication authentication) throws Exception {

        Date utilDate = new Date();

        Timestamp date = new Timestamp(utilDate.getTime());

        repository.setDateOfCollection(date);

        repository.setAggregator("OPENAIRE");

        repository.setCountryCode(countriesMap.get(repository.getCountryName()));

        UriComponents uriComponents = UriComponentsBuilder

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

                .build()

                .encode();

        String json_repository = Converter.repositoryObjectToJson(repository);

        HttpEntity<String> httpEntity = new HttpEntity <String> (json_repository,httpHeaders);

        ResponseEntity responseEntity = restTemplate.exchange(uriComponents.toUri(),HttpMethod.POST, httpEntity, ResponseEntity.class);

        if(responseEntity.getStatusCode().equals(HttpStatus.OK)) {

            emailUtils.sendUserRegistrationEmail(repository, authentication);

            emailUtils.sendAdminRegistrationEmail(repository, authentication);

        } else {

            LOGGER.debug(responseEntity.getBody().toString());

        }

    }

    @Override

    public void deleteRepositoryInterface(String id ,

                                          String registeredBy){

        UriComponents uriComponents = UriComponentsBuilder

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

                .path("/{id}")

                .build().expand(id).encode();

        LOGGER.debug(uriComponents.toUri());

        restTemplate.delete(uriComponents.toUri());

    }

    @Override

    public RepositoryInterface addRepositoryInterface(String datatype,

                                                      String repoId,

                                                      String registeredBy,

                                                      RepositoryInterface repositoryInterface) throws JSONException, ResourceNotFoundException, ValidatorServiceException {

        try {

            Repository e = this.getRepositoryById(repoId);

            repositoryInterface = createRepositoryInterface(e,repositoryInterface,datatype);

            String json_interface = Converter.repositoryInterfaceObjectToJson(e,repositoryInterface);

            UriComponents uriComponents = UriComponentsBuilder

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

                    .build()

                    .encode();

            HttpEntity<String> httpEntity = new HttpEntity <> (json_interface,httpHeaders);

            restTemplate.postForObject(uriComponents.toUri(),httpEntity,String.class);

            submitInterfaceValidation(e, registeredBy, repositoryInterface, false);

            return repositoryInterface;

        } catch (JSONException | ValidatorServiceException e) {

            LOGGER.debug("Exception on addRepositoryInterface" , e);

            emailUtils.reportException(e);

            throw e;

        }

    }

    @Override

    public RepositoryInterface updateRepositoryInterface(String repoId,

                                                         String registeredBy,

                                                         RepositoryInterface repositoryInterface) throws Exception {

        this.updateBaseUrl(repoId,repositoryInterface.getId(),repositoryInterface.getBaseUrl());

        this.updateCompliance(repoId,repositoryInterface.getId(),repositoryInterface.getCompliance());

        this.updateValidationSet(repoId,repositoryInterface.getId(),repositoryInterface.getAccessSet());

        submitInterfaceValidation(getRepositoryById(repoId),registeredBy,repositoryInterface,true);

        return repositoryInterface;

    }

    private void submitInterfaceValidation(Repository repo, String userEmail, RepositoryInterface iFace, boolean updateExisting) throws ValidatorServiceException {

        JobForValidation job = new JobForValidation();

        job.setActivationId(UUID.randomUUID().toString());

        job.setAdminEmails(Collections.singletonList(this.adminEmail));

        job.setBaseUrl(iFace.getBaseUrl());

        job.setDatasourceId(repo.getId());

        job.setDesiredCompatibilityLevel(iFace.getDesiredCompatibilityLevel());

        job.setInterfaceId(iFace.getId());

        job.setOfficialName(repo.getOfficialName());

        job.setRepoType(repo.getDatasourceType());

        job.setUserEmail(userEmail);

        job.setValidationSet((iFace.getAccessSet().isEmpty() ? "none" : iFace.getAccessSet()));

        job.setRecords(-1);

        job.setRegistration(!updateExisting);

        job.setUpdateExisting(updateExisting);

        this.validatorService.submitJobForValidation(job);

    }

    private RepositoryInterface createRepositoryInterface(Repository repo, RepositoryInterface iFace, String datatype) {

        iFace.setContentDescription("metadata");

        iFace.setCompliance("UNKNOWN");

        if (datatype.equals("re3data"))

            iFace.setAccessFormat("oai_datacite");

        else

            iFace.setAccessFormat("oai_dc");

        if (repo.getDatasourceClass() != null && !repo.getDatasourceClass().isEmpty())

            iFace.setTypology(repo.getDatasourceClass());

        else if (datatype.equalsIgnoreCase("journal"))

            iFace.setTypology("pubsrepository::journal");

        else if (datatype.equalsIgnoreCase("aggregator"))

            iFace.setTypology("aggregator::pubsrepository::unknown");

        else if (datatype.equalsIgnoreCase("opendoar"))

            iFace.setTypology("pubsrepository::unknown");

        else if (datatype.equalsIgnoreCase("re3data"))

            iFace.setTypology("datarepository::unknown");

        iFace.setRemovable(true);

        iFace.setAccessProtocol("oai");

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

        iFace.setId("api_________::" + repo.getId() + "::" + UUID.randomUUID().toString().substring(0, 8));

        if (iFace.getAccessSet() == null || iFace.getAccessSet().isEmpty()) {

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

            iFace.removeAccessSet();

            iFace.setAccessSet("none");

        }

        return iFace;

    }

    @Override

    public List<String> getDnetCountries() {

        LOGGER.debug("Getting dnet-countries!");

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

    }

    @Override

    public List<String> getTypologies() {

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

    }

    @Override

    public List<Timezone> getTimezones() {

        List<String> timezones =  Converter.readFile("timezones.txt");

        return Converter.toTimezones(timezones);

    }

    @Override

    public List<String> getUrlsOfUserRepos(String userEmail,

                                           String page,

                                           String size){

        UriComponents uriComponents = UriComponentsBuilder

                .fromHttpUrl(baseAddress + "/api/baseurl/")

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

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

        try{

            RequestFilter requestFilter = new RequestFilter();

            requestFilter.setRegisteredby(userEmail);

            return Arrays.asList(restTemplate.postForObject(uriComponents.toUri(),requestFilter, String[].class));

        }catch (Exception e){

            LOGGER.debug("Exception on addRepositoryInterface" , e);

            emailUtils.reportException(e);

            throw e;

        }

    }

    @Override

    public List<String> getDatasourceVocabularies(String mode) {

        List<String> resultSet = new ArrayList<>();

        for (Map.Entry<String, String> entry : this.getVocabulary("dnet:datasource_typologies").getAsMap().entrySet()) {

            if (mode.equalsIgnoreCase("aggregator")) {

                if (entry.getKey().contains("aggregator"))

                    resultSet.add(entry.getValue());

            } else if (mode.equalsIgnoreCase("journal")) {

                if (entry.getKey().contains("journal"))

                    resultSet.add(entry.getValue());

            } else if (mode.equalsIgnoreCase("opendoar")) {

                if (entry.getKey().contains("pubsrepository"))

                    resultSet.add(entry.getValue());

            } else if (mode.equalsIgnoreCase("re3data")) {

                if (entry.getKey().contains("datarepository"))

                    resultSet.add(entry.getValue());

            }

        }

        return resultSet;

    }

    private Vocabulary getVocabulary(String vocName) {

        if (!vocabularyMap.containsKey(vocName)) {

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

        }

        return vocabularyMap.get(vocName);

    }

    @Override

    public Map<String, String> getCompatibilityClasses(String mode)  {

        LOGGER.debug("Getting compatibility classes for mode: " + mode);

        Map<String, String> retMap = new HashMap<String, String>();

        Map<String, String> compatibilityClasses = this.getVocabulary("dnet:compatibilityLevel").getAsMap();

        boolean foundData = false;

        for (Map.Entry<String, String> entry : compatibilityClasses.entrySet()) {

            if (mode.equalsIgnoreCase(Constants.REPOSITORY_MODE_ALL))

                return compatibilityClasses;

            else if (mode.equalsIgnoreCase(Constants.REPOSITORY_MODE_RE3DATA)) {

                if (entry.getKey().matches("^openaire[1-9].0_data$")) {

                    retMap.put(entry.getKey(), entry.getValue());

                    foundData = true;

                }

            } else {

                if (entry.getKey().matches("^openaire[1-9].0$") || entry.getKey().equals("driver"))

                    retMap.put(entry.getKey(), entry.getValue());

            }

        }

        //TODO TO BE REMOVED WHEN VOCABULARIES ARE UPDATED

        if (mode.equalsIgnoreCase(Constants.REPOSITORY_MODE_RE3DATA) && !foundData)

            retMap.put("openaire2.0_data", "OpenAIRE Data (funded, referenced datasets)");

        return retMap;

    }

    @Override

    public Map<String, String> getDatasourceClasses(String mode)  {

        LOGGER.debug("Getting datasource classes for mode: " + mode);

        Map<String, String> retMap = new HashMap<String, String>();

        for (Map.Entry<String, String> entry : this.getVocabulary("dnet:datasource_typologies").getAsMap().entrySet()) {

            if (mode.equalsIgnoreCase("aggregator")) {

                if (entry.getKey().contains("aggregator"))

                    retMap.put(entry.getKey(), entry.getValue());

            } else if (mode.equalsIgnoreCase("journal")) {

                if (entry.getKey().contains("journal"))

                    retMap.put(entry.getKey(), entry.getValue());

            } else if (mode.equalsIgnoreCase("opendoar")) {

                if (entry.getKey().contains("pubsrepository"))