D-Net

package eu.dnetlib.repo.manager.controllers;

import eu.dnetlib.domain.data.Repository;

import eu.dnetlib.domain.data.RepositoryInterface;

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

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

import eu.dnetlib.repo.manager.service.RepositoryApiImpl;

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

import io.swagger.annotations.Api;

import org.json.JSONException;

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

import org.springframework.http.MediaType;

import org.springframework.security.access.prepost.PreAuthorize;

import org.springframework.security.core.Authentication;

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

import java.io.IOException;

import java.util.List;

import java.util.Map;

@RestController

@RequestMapping(value = "/repository")

@Api(description = "Repository API",  tags = {"repository"})

public class RepositoryController {

    @Autowired

    RepositoryApiImpl repositoryApi;

    @RequestMapping(value = "/getCountries", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    public Country[] getCountries() {

        return repositoryApi.getCountries();

    }

    @RequestMapping(value = "/getRepositoriesByCountry/{country}/{mode}", method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

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

                                                            @PathVariable("mode") String mode,

                                                            @RequestParam(value = "managed",required=false) Boolean managed) throws JSONException, IOException {

        return repositoryApi.getRepositoriesByCountry(country, mode, managed);

    }

    @RequestMapping(value = "/getRepositoriesOfUser/{userEmail}/{page}/{size}",method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    @PreAuthorize("hasRole('ROLE_USER')")

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

                                                  @PathVariable("page") String page,

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

       return repositoryApi.getRepositoriesOfUser(userEmail, page, size);

    }

    @RequestMapping(value = "/getRepositoryById/{id}", method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

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

        return repositoryApi.getRepositoryById(id);

    }

    @RequestMapping(value = "/getRepositoryAggregations/{id}", method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    public List<AggregationDetails> getRepositoryAggregations(@PathVariable("id") String id) throws JSONException {

        return repositoryApi.getRepositoryAggregations(id);

    }

    @RequestMapping(value = "/getRepositoryAggregationsByYear/{id}", method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

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

        return repositoryApi.getRepositoryAggregationsByYear(id);

    }

    @RequestMapping(value = "/getRepositoriesByName/{name:.+}/{page}/{size}/", method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

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

                                                  @PathVariable("page") String page,

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

        return repositoryApi.getRepositoriesByName(name, page, size);

    }

    @RequestMapping(value = "/getRepositoryInterface/{id}", method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

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

        return repositoryApi.getRepositoryInterface(id);

    }

    @RequestMapping(value = "/addRepository", method = RequestMethod.POST,

            consumes = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    @PreAuthorize("hasRole('ROLE_USER') and #repository.registeredBy == authentication.userInfo.email")

    public Repository addRepository(@RequestParam("datatype") String datatype,

                                    @RequestBody Repository repository) throws Exception {

        return repositoryApi.addRepository(datatype, repository);

    }

    @RequestMapping(value = "/getDnetCountries", method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    List<String> getDnetCountries(){

        return repositoryApi.getDnetCountries();

    }

    @RequestMapping(value = "/getTypologies", method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    List<String> getTypologies(){

        return repositoryApi.getTypologies();

    }

    @RequestMapping(value = "/getTimezones", method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    List<Timezone> getTimezones(){

        return repositoryApi.getTimezones();

    }

    @RequestMapping(value = "/updateRepository", method = RequestMethod.POST,

            consumes = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    //@PreAuthorize("hasRole('ROLE_USER') and #repository.registeredBy == authentication.userInfo.email")

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

        return repositoryApi.updateRepository(repository, authentication);

    }

    @RequestMapping(value = "/deleteInterface/", method = RequestMethod.DELETE)

    @PreAuthorize("hasRole('ROLE_USER') and #registeredBy == authentication.userInfo.email")

    public void deleteRepositoryInterface(@RequestParam("id") String id ,

                                          @RequestParam("registeredBy") String registeredBy){

        repositoryApi.deleteRepositoryInterface(id, registeredBy);

    }

    @RequestMapping(value = "/addInterface", method = RequestMethod.POST,

            consumes = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    @PreAuthorize("hasRole('ROLE_USER') and #registeredBy == authentication.userInfo.email")

    public RepositoryInterface addRepositoryInterface(@RequestParam("datatype") String datatype,

                                                      @RequestParam("repoId") String repoId,

                                                      @RequestParam("registeredBy") String registeredBy,

                                                      @RequestBody RepositoryInterface repositoryInterface) throws JSONException,ResourceNotFoundException {

        return repositoryApi.addRepositoryInterface(datatype, repoId, registeredBy, repositoryInterface);

    }

    @RequestMapping(value = "/getUrlsOfUserRepos/{user_email}/{page}/{size}/",method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    @PreAuthorize("hasRole('ROLE_USER')")

    public List<String> getUrlsOfUserRepos(@PathVariable("user_email") String userEmail,

                                           @PathVariable("page") String page,

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

        return repositoryApi.getUrlsOfUserRepos(userEmail, page, size);

    }

    @RequestMapping(value = "/getDatasourceVocabularies/{mode}",method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    public List<String> getDatasourceVocabularies(@PathVariable("mode") String mode) {

       return repositoryApi.getDatasourceVocabularies(mode);

    }

    @RequestMapping(value = "/getCompatibilityClasses/{mode}",method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    public Map<String, String> getCompatibilityClasses(@PathVariable("mode") String mode)  {

        return repositoryApi.getCompatibilityClasses(mode);

    }

    @RequestMapping(value = "/getDatasourceClasses/{mode}",method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    public Map<String, String> getDatasourceClasses(@PathVariable("mode") String mode)  {

       return repositoryApi.getDatasourceClasses(mode);

    }

    @RequestMapping(value = "/getMetricsInfoForRepository/{repoId}",method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    public MetricsInfo getMetricsInfoForRepository(@PathVariable("repoId")  String repoId) throws RepositoryServiceException {

        return repositoryApi.getMetricsInfoForRepository(repoId);

    }

    @RequestMapping(value = "/getListLatestUpdate/{mode}",method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    public Map<String, String> getListLatestUpdate(@PathVariable("mode")  String mode) throws JSONException {

        return repositoryApi.getListLatestUpdate(mode);

    }

    @RequestMapping(value = "/updateRepositoryInterface", method = RequestMethod.POST,

            consumes = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    @PreAuthorize("hasRole('ROLE_USER') and #registeredBy == authentication.userInfo.email")

    public RepositoryInterface updateRepositoryInterface(@RequestParam("repoId") String repoId,

                                                         @RequestParam("registeredBy") String registeredBy,

                                                         @RequestBody RepositoryInterface repositoryInterface) throws JSONException {

        return repositoryApi.updateRepositoryInterface(repoId, registeredBy, repositoryInterface);

    }

}