D-Net

package eu.dnetlib.parthenos.publisher;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import eu.dnetlib.parthenos.publisher.ParthenosPublisherHelper.ParthenosTargets;

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.scheduling.annotation.Async;

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;

@RestController

public class ParthenosPublisherController {

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

	//TODO: to nicely handle arrors, follow https://docs.spring.io/spring-boot/docs/current/reference/htmlsingle/#boot-features-error-handling

	@Autowired

	private ParthenosPublisherHelper parthenosPublisherHelper;

	private ExecutorService executorService = Executors.newCachedThreadPool();

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

	@Async

	public void publish(@RequestParam final String record, @RequestParam(required = false) String parthenosTarget)

			throws ParthenosPublisherException, InterruptedException {

		parthenosPublisherHelper.publish(record, getTarget(parthenosTarget));

	}

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

	@Async

	public void unpublish(@RequestParam final String datasourceApi, @RequestParam(required = false) String parthenosTarget) throws ParthenosPublisherException {

		this.parthenosPublisherHelper.unpublish(datasourceApi, getTarget(parthenosTarget));

	}

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

	@Async

	public void unpublish() throws ParthenosPublisherException {

		this.parthenosPublisherHelper.dropRegistry();

	}

	private ParthenosTargets getTarget(String value){

		ParthenosTargets target = ParthenosTargets.ALL;

		if (StringUtils.isNotBlank(value)) {

			target = ParthenosTargets.valueOf(value);

		}

		return target;

	}

	public ParthenosPublisherHelper getParthenosPublisherHelper() {

		return parthenosPublisherHelper;

	}

	public void setParthenosPublisherHelper(final ParthenosPublisherHelper parthenosPublisherHelper) {

		this.parthenosPublisherHelper = parthenosPublisherHelper;

	}

}