D-Net

package eu.dnetlib.openaire.exporter;

import com.fasterxml.jackson.annotation.JsonAutoDetect;

import org.apache.commons.lang3.StringUtils;

import org.apache.commons.lang3.exception.ExceptionUtils;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.springframework.http.HttpStatus;

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

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

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

/**

 * Created by claudio on 18/07/2017.

 */

public abstract class AbstractExporterController {

	private static final Log log = LogFactory.getLog(AbstractExporterController.class); // NOPMD by marko on 11/24/08 5:02 PM

	/*

	Tags used to group the operations on the swagger UI

	 */

	protected final static String DS = "datasource";

	protected final static String API = "API";

	protected final static String R = "read";

	protected final static String W = "write";

	protected final static String DSPACE = "DSpace";

	protected final static String EPRINT = "EPrints";

	protected final static String TSV = "TSV";

	protected final static String STREAMING = "Streaming";

	@ResponseBody

	@ExceptionHandler({Exception.class, Throwable.class})

	@ResponseStatus(value = HttpStatus.INTERNAL_SERVER_ERROR)

	public ErrorMessage handleSqlException(final Exception e) {

		log.debug(e.getMessage(), e);

		if (StringUtils.containsIgnoreCase(ExceptionUtils.getRootCauseMessage(e), "Broken pipe")) {

			return null;        //socket is closed, cannot return any response

		} else {

			return new ErrorMessage(e);

		}

	}

	@JsonAutoDetect

	public class ErrorMessage {

		private final String message;

		private final String stacktrace;

		public ErrorMessage(final Exception e) {

			this(e.getMessage(), ExceptionUtils.getStackTrace(e));

		}

		public ErrorMessage(final String message, final String stacktrace) {

			this.message = message;

			this.stacktrace = stacktrace;

		}

		public String getMessage() {

			return this.message;

		}

		public String getStacktrace() {

			return this.stacktrace;

		}

	}

}