D-Net

package eu.dnetlib.enabling.datasources;

import java.util.Date;

import java.util.List;

import java.util.Map;

import org.apache.commons.lang3.StringUtils;

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

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

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

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

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

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

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

import eu.dnetlib.clients.dsManager.BrowsableField;

import eu.dnetlib.clients.dsManager.BrowseTerm;

import eu.dnetlib.clients.dsManager.DatasourceDesc;

import eu.dnetlib.clients.dsManager.DatasourcePoint;

import eu.dnetlib.clients.dsManager.IfaceDesc;

import eu.dnetlib.clients.dsManager.SearchInterfacesEntry;

import eu.dnetlib.clients.dsManager.SimpleDatasourceDesc;

import eu.dnetlib.enabling.annotations.DnetService;

import eu.dnetlib.enabling.annotations.DnetServiceType;

import eu.dnetlib.services.BaseService;

@RestController

@RequestMapping(value = "/dsManager")

@DnetService(DnetServiceType.dsManager)

public class DatasourceManagerController extends BaseService {

	@Autowired

	private DatasourceManagerCore core;

	@RequestMapping(value = "map", method = RequestMethod.GET)

	public List<DatasourcePoint> getRepositoryMap() throws DatasourceManagerServiceException {

		return core.getDatasourceMap();

	}

	@RequestMapping(value = "ds/{type}", method = RequestMethod.GET)

	public List<SimpleDatasourceDesc> simpleListDatasourcesByType(@PathVariable final String type) throws DatasourceManagerServiceException {

		return core.simpleListDatasourcesByType(type);

	}

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

	public String addDatasource(@RequestBody final DatasourceDesc ds) throws DatasourceManagerServiceException {

		return core.addDatasource(ds);

	}

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

	public boolean deleteDatasource(@RequestParam final String dsId) throws DatasourceManagerServiceException {

		return core.deleteDatasource(dsId);

	}

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

	public DatasourceDesc getDatasource(@RequestParam final String dsId) throws DatasourceManagerServiceException {

		return core.getDatasource(dsId);

	}

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

	public List<DatasourceDesc> listDatasources(

			@RequestParam(required = false) final String compliance,

			@RequestParam(required = false) final String contentDescription,

			@RequestParam(required = false) final String collectedFrom) throws DatasourceManagerServiceException {

		return core.listDatasources(compliance, contentDescription, collectedFrom);

	}

	@RequestMapping(value = "api/compliance", method = RequestMethod.GET)

	public boolean updateLevelOfCompliance(@RequestParam final String dsId,

			@RequestParam final String ifaceId,

			@RequestParam(required = false, defaultValue = "") final String level,

			@RequestParam(required = false, defaultValue = "false") final boolean override) throws DatasourceManagerServiceException {

		if (override && StringUtils.isBlank(level)) {

			return core.resetLevelOfCompliance(dsId, ifaceId);

		} else {

			return core.updateLevelOfCompliance(dsId, ifaceId, level, override);

		}

	}

	@RequestMapping(value = "api/baseUrl", method = RequestMethod.GET)

	public boolean updateBaseUrl(@RequestParam final String dsId,

			@RequestParam final String ifaceId,

			@RequestParam final String baseUrl)

			throws DatasourceManagerServiceException {

		return core.updateBaseUrl(dsId, ifaceId, baseUrl);

	}

	@RequestMapping(value = "api/activation", method = RequestMethod.GET)

	public boolean updateActivationStatus(@RequestParam final String dsId,

			@RequestParam final String ifaceId,

			@RequestParam final boolean active) throws DatasourceManagerServiceException {

		return core.updateActivationStatus(dsId, ifaceId, active);

	}

	@RequestMapping(value = "api/contentDescr", method = RequestMethod.GET)

	public boolean updateContentDescription(@RequestParam final String dsId,

			@RequestParam final String ifaceId,

			@RequestParam final String desc) throws DatasourceManagerServiceException {

		return core.updateContentDescription(dsId, ifaceId, desc);

	}

	@RequestMapping(value = "api/extraField/{field}", method = RequestMethod.GET)

	public boolean updateExtraField(@RequestParam final String dsId,

			@RequestParam final String ifaceId,

			@PathVariable final String field,

			@RequestParam final String value,

			@RequestParam(required = false, defaultValue = "true") final boolean preserveOriginal) throws DatasourceManagerServiceException {

		return core.updateExtraField(dsId, ifaceId, field, value, preserveOriginal);

	}

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

	public boolean deleteExtraField(@RequestParam final String dsId,

			@RequestParam final String ifaceId,

			@PathVariable final String field) throws DatasourceManagerServiceException {

		return core.deleteExtraField(dsId, ifaceId, field);

	}

	@RequestMapping(value = "api/accessParam/{field}", method = RequestMethod.GET)

	public boolean updateAccessParam(@RequestParam final String dsId,

			@RequestParam final String ifaceId,

			@PathVariable final String field,

			@RequestParam final String value,

			@RequestParam(required = false, defaultValue = "true") final boolean preserveOriginal) throws DatasourceManagerServiceException {

		return core.updateAccessParam(dsId, ifaceId, field, value, preserveOriginal);

	}

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

	public boolean deleteAccessParam(@RequestParam final String dsId,

			@RequestParam final String ifaceId,

			@PathVariable final String field) throws DatasourceManagerServiceException {

		return core.deleteAccessParam(dsId, ifaceId, field);

	}

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

	public boolean addInterface(@RequestParam final String dsId, @RequestBody final IfaceDesc iface) throws DatasourceManagerServiceException {

		return core.addInterface(dsId, iface);

	}

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

	public boolean deleteInterface(@RequestParam final String dsId, @RequestParam final String ifaceId) throws DatasourceManagerServiceException {

		return core.deleteInterface(dsId, ifaceId);

	}

	@RequestMapping(value = "api/nextScheduledExecution", method = RequestMethod.GET)

	public Date findNextScheduledExecution(@RequestParam final String dsId, @RequestParam final String ifaceId) throws DatasourceManagerServiceException {

		return core.findNextScheduledExecution(dsId, ifaceId);

	}

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

	public boolean bulkUpdateApiExtraFields(@RequestParam final String dsId,

			@RequestParam final String ifaceId,

			@RequestBody final Map<String, String> fields) throws DatasourceManagerServiceException {

		return core.bulkUpdateApiExtraFields(dsId, ifaceId, fields);

	}

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

	public boolean bulkUpdateApiAccessParams(@RequestParam final String dsId,

			@RequestParam final String ifaceId,

			@RequestBody final Map<String, String> params) throws DatasourceManagerServiceException {

		return core.bulkUpdateApiAccessParams(dsId, ifaceId, params);

	}

	@RequestMapping(value = "browse/api/fields", method = RequestMethod.GET)

	public List<BrowsableField> listBrowsableFields() throws DatasourceManagerServiceException {

		return core.listBrowsableFields();

	}

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

	public List<BrowseTerm> browseField(@PathVariable final String field) throws DatasourceManagerServiceException {

		return core.browseField(field);

	}

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

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

			throws DatasourceManagerServiceException {

		return core.searchInterface(field, value);

	}

}