D-Net

package eu.dnetlib.openaire.exporter.datasource;

import java.util.List;

import eu.dnetlib.common.rmi.DNetRestDocumentation;

import eu.dnetlib.openaire.exporter.AbstractExporterController;

import eu.dnetlib.openaire.exporter.datasource.clients.DatasourceDao;

import eu.dnetlib.openaire.exporter.model.datasource.BrowseTerm;

import eu.dnetlib.openaire.exporter.model.datasource.DatasourceResponse;

import eu.dnetlib.openaire.exporter.model.datasource.Response;

import eu.dnetlib.openaire.exporter.model.datasource.db.Api;

import eu.dnetlib.openaire.exporter.model.datasource.db.Datasource;

import eu.dnetlib.openaire.exporter.model.datasource.db.SearchInterfacesEntry;

import eu.dnetlib.openaire.exporter.vocabularies.Country;

import io.swagger.annotations.ApiOperation;

import io.swagger.annotations.ApiResponse;

import io.swagger.annotations.ApiResponses;

import org.apache.commons.lang.StringUtils;

import org.apache.commons.lang3.time.StopWatch;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.apache.http.HttpStatus;

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

import org.springframework.data.domain.PageRequest;

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

@RestController

@DNetRestDocumentation

public class DatasourcesApiController extends AbstractExporterController implements DatasourcesApi {

	private static final Log log = LogFactory.getLog(DatasourcesApiController.class);

	@Autowired

	private DatasourceDao dsDao;

	@Override

	@RequestMapping(value = "/ds/list/{page}/{size}", produces = { "application/json" }, method = RequestMethod.GET)

    public List<String> listIds(@PathVariable int page, @PathVariable int size) throws ApiException {

	    return dsDao.listIds(new PageRequest(page, size));

    }

    @Override

    @RequestMapping(value = "/ds/get/{id}", produces = { "application/json" }, method = RequestMethod.GET)

    public DatasourceResponse getDs(@PathVariable final String id) {

	    if (log.isDebugEnabled()) {

		    log.debug(String.format("getDatasourceInfo(dsId = %s)", id));

	    }

	    final StopWatch stop = StopWatch.createStarted();

	    final Response rsp = dsDao.getDsById(id);

	    rsp.getHeader().setTime(stop.getTime());

	    if (log.isDebugEnabled()) {

	    	log.debug("getDs by id: " + rsp.getHeader().toJson());

	    }

    	return rsp.getDatasourceResponse().get(0);

    }

	@Override

	@RequestMapping(value = "/ds/search/name/{page}/{size}", produces = { "application/json" }, method = RequestMethod.GET)

	public List<DatasourceResponse> searchByName(

			@RequestParam final String name, @PathVariable final int page, @PathVariable final int size) {

		final StopWatch stop = StopWatch.createStarted();

		final Response rsp = dsDao.searchByName(name, new PageRequest(page, size));

		rsp.getHeader().setTime(stop.getTime());

		if (log.isDebugEnabled()) {

			log.debug("searchByName: " + rsp.getHeader().toJson());

		}

		return rsp.getDatasourceResponse();

	}

	@Override

	@RequestMapping(value = "/ds/search/email/{page}/{size}", produces = { "application/json" }, method = RequestMethod.GET)

	public List<DatasourceResponse> searchByContactemail(

			@RequestParam final String contactemail, @PathVariable final int page, @PathVariable final int size) {

		final StopWatch stop = StopWatch.createStarted();

		final Response rsp = dsDao.searchByContactemail(contactemail, new PageRequest(page, size));

		rsp.getHeader().setTime(stop.getTime());

		if (log.isDebugEnabled()) {

			log.debug("searchByContactemail: " + rsp.getHeader().toJson());

		}

		return rsp.getDatasourceResponse();

	}

	@Override

	@RequestMapping(value = "/ds/search/country/{page}/{size}", produces = { "application/json" }, method = RequestMethod.GET)

	public List<DatasourceResponse> searchByCountry(

			@RequestParam final String country, @PathVariable final int page, @PathVariable final int size) {

		final StopWatch stop = StopWatch.createStarted();

		final Response rsp = dsDao.searchByCountry(country, new PageRequest(page, size));

		rsp.getHeader().setTime(stop.getTime());

		if (log.isDebugEnabled()) {

			log.debug("searchByCountry: " + rsp.getHeader().toJson());

		}

		return rsp.getDatasourceResponse();

	}

	@Override

	@RequestMapping(value = "/ds/search/registeredby/{page}/{size}", produces = { "application/json" }, method = RequestMethod.GET)

	public List<DatasourceResponse> searchByRegisteringUser(final String registeredBy, final int page, final int size) {

		final StopWatch stop = StopWatch.createStarted();

		final Response rsp = dsDao.searchByRegisteringUser(registeredBy, new PageRequest(page, size));

		rsp.getHeader().setTime(stop.getTime());

		if (log.isDebugEnabled()) {

			log.debug("searchByRegisteringUser: " + rsp.getHeader().toJson());

		}

		return rsp.getDatasourceResponse();

	}

	@Override

	@RequestMapping(value = "/api/search/{field}", produces = { "application/json" }, method = RequestMethod.GET)

	public List<SearchInterfacesEntry> searchInterface(@PathVariable final String field, @RequestParam final String value) {

		return dsDao.searchInterface(field, value);

	}

	@Override

	@RequestMapping(value = "/api/baseurl/{page}/{size}", produces = { "application/json" }, method = RequestMethod.GET)

	public List<String> searchBaseUrls(@RequestParam final String userEmail, @RequestParam(required = false) final Boolean managed, @PathVariable final int page, @PathVariable final int size) throws ApiException {

		return dsDao.findBaseURLs(userEmail, managed, new PageRequest(page, size));

	}

	@Override

	@RequestMapping(value = "/api/browse/{field}", produces = { "application/json" }, method = RequestMethod.GET)

	public List<? extends BrowseTerm> browseField(@PathVariable final String field) throws ApiException {

		switch (field) {

		case "country":

			return dsDao.browseCountries();

		case "typology":

			return dsDao.browseTypologies();

		case "protocol":

			return dsDao.browseProtocols();

		case "compatibility":

			return dsDao.browseCompatibility();

		case "activation":

			return dsDao.browseActivation();

		default:

			throw new ApiException(HttpStatus.SC_BAD_REQUEST, String.format("unsupported browse field '%s'", field));

		}

	}

	@Override

	@RequestMapping(value = "/ds/countries", produces = { "application/json" }, method = RequestMethod.GET)

	public List<Country> listCountries() throws ApiException {

		return dsDao.listCountries();

	}

	@Override

	@RequestMapping(value = "/ds/api/{dsId}", produces = { "application/json" }, method = RequestMethod.GET)

	public List<Api> getApi(@PathVariable final String dsId) throws ApiException {

		return dsDao.getApi(dsId);

	}

	@Override

	@RequestMapping(value = "/ds/api/{dsId}", method = RequestMethod.DELETE)

	public void deleteApi(@PathVariable final String apiId) throws ApiException {

		dsDao.deleteApi(apiId);

	}

	@Override

	@RequestMapping(value = "/ds/api/add", method = RequestMethod.POST)

	public void addApi(@RequestParam final Api api) throws ApiException {

		if (StringUtils.isBlank(api.getDatasource())) {

			throw new ApiException(HttpStatus.SC_BAD_REQUEST, "missing datasource id");

		}

		dsDao.addApi(api);

	}

	@Override

	@RequestMapping(value = "/ds/manage", method = RequestMethod.POST)

	public void setManaged(@RequestParam final String id, @RequestParam final boolean managed) {

		dsDao.setManaged(id, managed);

	}

	@Override

	@RequestMapping(value = "/ds/add", method = RequestMethod.POST)

	public void saveDatasource(@RequestBody final Datasource datasource) throws ApiException {

		if (dsDao.exist(datasource)) { //TODO further check that the DS doesn't have any API

			throw new ApiException(HttpStatus.SC_CONFLICT, String.format("cannot already defined '%s'", datasource.getId()));

		}

		dsDao.save(datasource);

	}

	@Override

	@RequestMapping(value = "/ds/officialname", method = RequestMethod.POST)

	public void updateOfficialname(@RequestParam final String dsId, @RequestParam final String officialname) throws ApiException {

		dsDao.updateOfficialName(dsId, officialname);

	}

	@Override

	@RequestMapping(value = "/ds/englishname", method = RequestMethod.POST)

	public void updateEnglishname(@RequestParam final String dsId, @RequestParam final String englishname) throws ApiException {

		dsDao.updateEnglishName(dsId, englishname);

	}

	@Override

	@RequestMapping(value = "/ds/latitude", method = RequestMethod.POST)

	public void updateLatitude(@RequestParam final String dsId, @RequestParam final Double latitude) throws ApiException {

		dsDao.updateLatitude(dsId, latitude);

	}

	@Override

	@RequestMapping(value = "/ds/longitude", method = RequestMethod.POST)

	public void updateLongitude(@RequestParam final String dsId, @RequestParam final Double longitude) throws ApiException {

		dsDao.updateLongitude(dsId, longitude);

	}

	@Override

	@RequestMapping(value = "/ds/logourl", method = RequestMethod.POST)

	public void updateLogourl(@RequestParam final String dsId, @RequestParam final String logourl) throws ApiException {

		dsDao.updateLogourl(dsId, logourl);

	}

	@Override

	@RequestMapping(value = "/ds/timezone", method = RequestMethod.POST)

	public void updateTimezone(@RequestParam final String dsId, @RequestParam final String timezone) throws ApiException {

		dsDao.updateTimezone(dsId, timezone);

	}

	@Override

	@RequestMapping(value = "/ds/typology", method = RequestMethod.POST)

	public void updateTypology(@RequestParam final String dsId, @RequestParam final String typology) throws ApiException {

		dsDao.updateDatasourceTypology(dsId, typology);

	}

	@Override

	@RequestMapping(value = "/ds/registeredby", method = RequestMethod.POST)

	public void updateRegisteringUser(@RequestParam final String dsId, @RequestParam final String registeredBy) throws ApiException {

		dsDao.updateDatasourceRegisteringUser(dsId, registeredBy);

	}

	@ApiOperation(value = "drop the datasource manager caches", notes = "drop the datasource manager caches", httpMethod = "GET")

	@ApiResponses(value = {

			@ApiResponse(code = 200, message = "OK"),

			@ApiResponse(code = 500, message = "unexpected error") })

	@RequestMapping(value = "/ds/dropcache.do", method = RequestMethod.GET)

	public void dropDsCaches() {

		dsDao.dropCaches();

	}

}