D-Net

package eu.dnetlib.administration.uis.modules.datasources;

import java.util.List;

import java.util.Map;

import org.apache.commons.lang3.StringUtils;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

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

import org.springframework.cache.annotation.CacheEvict;

import org.springframework.cache.annotation.Cacheable;

import org.springframework.stereotype.Controller;

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

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

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

import com.google.gson.Gson;

import eu.dnetlib.administration.uis.functions.ProtocolParameterValue;

import eu.dnetlib.administration.uis.utils.ProtocolParametersInspector;

import eu.dnetlib.clients.dsManager.BrowseTerm;

import eu.dnetlib.clients.dsManager.DatasourcePoint;

import eu.dnetlib.clients.dsManager.DsManagerClient;

import eu.dnetlib.clients.dsManager.IfaceDesc;

import eu.dnetlib.clients.dsManager.SearchInterfacesEntry;

import eu.dnetlib.clients.dsManager.SimpleDatasourceDesc;

import eu.dnetlib.clients.msro.MsroClient;

import eu.dnetlib.exceptions.DnetGenericException;

@Controller

public class RepoInternalController {

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

	@Autowired

	private DsManagerClient dsManager;

	@Autowired

	private ProtocolParametersInspector ppInspector;

	@Autowired

	private MsroClient msroClient;

	@RequestMapping(value = "/ui/browseRepoField.do")

	public @ResponseBody List<BrowseTerm> browseRepoField(@RequestParam(value = "field", required = true) final String field) throws Exception {

		return dsManager.browseField(field);

	}

	@Cacheable("listApis")

	@RequestMapping(value = "/ui/listApis.do")

	public @ResponseBody List<SearchInterfacesEntry> listApis(

			@RequestParam(value = "param", required = true) final String param,

			@RequestParam(value = "value", required = true) final String value) throws Exception {

		return dsManager.searchInterface(param, value);

	}

	@CacheEvict(value = "listApis", allEntries = true, beforeInvocation = true)

	@RequestMapping(value = "/ui/refreshApis.do")

	public @ResponseBody List<SearchInterfacesEntry> refreshApis(

			@RequestParam(value = "param", required = true) final String param,

			@RequestParam(value = "value", required = true) final String value) throws Exception {

		return listApis(param, value);

	}

	@RequestMapping(value = "/ui/listRepositories.map")

	public @ResponseBody List<DatasourcePoint> listRepositories_asMap() throws Exception {

		return dsManager.getRepositoryMap();

	}

	@RequestMapping(value = "/ui/listRepositories.json")

	public @ResponseBody List<SimpleDatasourceDesc> listRepositories(@RequestParam(value = "type", required = true) final String type) throws Exception {

		return dsManager.simpleListDatasourcesByType(type);

	}

	@SuppressWarnings("unchecked")

	@RequestMapping("/ui/repo/repoApi.update")

	public @ResponseBody boolean updateRepoApi(

			@RequestParam(value = "id", required = true) final String repoId,

			@RequestParam(value = "iface", required = true) final String ifaceId,

			@RequestParam(value = "accessParams", required = true) final String accessParamsJson) throws Exception {

		if (!StringUtils.isEmpty(accessParamsJson)) {

			dsManager.bulkUpdateApiAccessParams(repoId, ifaceId, new Gson().fromJson(accessParamsJson, Map.class));

		}

		return true;

	}

	@RequestMapping("/ui/repo/repoApiCompliance.update")

	@CacheEvict(value = "listApis", allEntries = true)

	public @ResponseBody boolean updateRepoApiCompliance(@RequestParam(value = "id", required = true) final String repoId,

			@RequestParam(value = "iface", required = true) final String ifaceId,

			@RequestParam(value = "compliance", required = true) final String compliance) throws Exception {

		log.debug("SET COMPLIANCE TO " + compliance);

		dsManager.overrideCompliance(repoId, ifaceId, compliance);

		return true;

	}

	@RequestMapping("/ui/repo/repoApiCompliance.reset")

	@CacheEvict(value = "listApis", allEntries = true)

	public @ResponseBody boolean resetRepoApiCompliance(@RequestParam(value = "id", required = true) final String repoId,

			@RequestParam(value = "iface", required = true) final String ifaceId) throws Exception {

		log.debug("RESET COMPLIANCE");

		dsManager.overrideCompliance(repoId, ifaceId, null);

		return true;

	}

	@RequestMapping("/ui/repoApi.new")

	public @ResponseBody boolean addRepoApi(@RequestParam(value = "repoId", required = true) final String repoId,

			@RequestParam(value = "iface", required = true) final String ifaceJson) throws DnetGenericException {

		final IfaceDesc iface = new Gson().fromJson(ifaceJson, IfaceDesc.class);

		log.info("Adding interface " + iface.getId() + " to repository " + repoId);

		return dsManager.addInterface(repoId, iface);

	}

	@RequestMapping("/ui/listValidValuesForParam.do")

	public @ResponseBody List<ProtocolParameterValue> listValidValuesForParam(

			@RequestParam(value = "protocol", required = true) final String protocol,

			@RequestParam(value = "param", required = true) final String param,

			@RequestParam(value = "baseUrl", required = true) final String baseUrl) throws DnetGenericException {

		return ppInspector.listValidValuesForParam(protocol, param, baseUrl);

	}

}