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

	@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;

		}

	}

}