EDIT

 * Copyright (C) 2007 EDIT

 * European Distributed Institute of Taxonomy

 * http://www.e-taxonomy.eu

 *

 * The contents of this file are subject to the Mozilla Public License Version 1.1

 * See LICENSE.TXT at the top of this package for the full license terms.

 */

import org.springframework.web.bind.WebDataBinder;

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

import eu.etaxonomy.cdm.model.common.CdmBase;

import eu.etaxonomy.cdm.remote.dto.common.ErrorResponse;

import eu.etaxonomy.cdm.remote.editor.CdmTypePropertyEditor;

@RequestMapping(value = { "/manage" })

public class ManagementController {

	public static final Logger logger = Logger

			.getLogger(ManagementController.class);

	// @Autowired

	private DataSourceReloader datasoucrceLoader;

	@Autowired

	public ICdmMassIndexer indexer;

	@Autowired

	public ProgressMonitorController progressMonitorController;

	/**

	 * There should only be one processes operating on the lucene index

	 * therefore the according progress monitor uuid is stored in this static

	 * field.

	 */

	private static UUID indexMonitorUuid = null;

	@InitBinder

	public void initIndexClassBinder(WebDataBinder binder) {

		binder.registerCustomEditor(Class.class, new CdmTypePropertyEditor());

	}

	@InitBinder

	public void initIndexArrayBinder(WebDataBinder binder) {

		binder.registerCustomEditor(Class[].class, new CdmTypePropertyEditor());

	}

	/*

	 * return page not found http error (404) for unknown or incorrect UUIDs

	 * (non-Javadoc)

	 * 

	 * @see

	 * org.springframework.web.servlet.mvc.AbstractController#handleRequestInternal

	 * (javax.servlet.http.HttpServletRequest,

	 * javax.servlet.http.HttpServletResponse)

	 */

	// @RequestMapping(value = { "/manager/datasources/list" }, method =

	// RequestMethod.GET)

	protected ModelAndView doList(HttpServletRequest request,

			HttpServletResponse respone) throws Exception {

		ModelAndView mv = new ModelAndView();

		Map<String, DataSourceInfo> dataSourceInfos = datasoucrceLoader.test();

		mv.addObject(dataSourceInfos);

		return mv;

	}

	// @RequestMapping(value = { "/manager/datasources/reload" }, method =

	// RequestMethod.GET)

	public ModelAndView doReload(HttpServletRequest request,

			HttpServletResponse respone) throws Exception {

		ModelAndView mv = new ModelAndView();

		Map<String, DataSourceInfo> dataSourceInfos = datasoucrceLoader

				.reload();

		mv.addObject(dataSourceInfos);

		return mv;

	}

	/**

	 * 

	 * Reindex all cdm entities listed in

	 * {@link ICdmMassIndexer#indexedClasses()}. Re-indexing will not purge the

	 * index.

	 * 

	 * @param frontendBaseUrl

	 *            if the CDM server is running behind a reverse proxy you need

	 *            to supply the base URL of web service front-end which is

	 *            provided by the proxy server.

	 * @param request

	 * @param respone

	 * @return

	 * @throws Exception

	 */

	@RequestMapping(value = { "reindex" }, method = RequestMethod.GET)

	public ModelAndView doReindex(

			@RequestParam(value = "frontendBaseUrl", required = false) String frontendBaseUrl,

			@RequestParam(value = "type", required = true) Class<? extends CdmBase>[] types,

			@RequestParam(value = "priority", required = false) Integer priority,

			HttpServletRequest request, HttpServletResponse response)

			throws Exception {

		indexer.clearIndexedClasses();

		for (Class<? extends CdmBase> type : types) {

			if(type != null) {

				indexer.addToIndexedClasses(type);

			}

		}

		String processLabel = "Re-indexing";

		ProgressMonitorUtil progressUtil = new ProgressMonitorUtil(

				progressMonitorController);

		if (!progressMonitorController.isMonitorRunning(indexMonitorUuid)) {

			indexMonitorUuid = progressUtil.registerNewMonitor();

			Thread subThread = new Thread() {

				@Override

				public void run() {

					indexer.reindex(progressMonitorController

							.getMonitor(indexMonitorUuid));

				}

			};

			if (priority == null) {

				priority = AbstractController.DEFAULT_BATCH_THREAD_PRIORITY;

			}

			subThread.setPriority(priority);

			subThread.start();

		}

		// send redirect "see other"

		return progressUtil.respondWithMonitor(frontendBaseUrl, request,

				response, processLabel, indexMonitorUuid);

	}

	/**

	 * 

	 * Create dictionaries for all cdm entities listed in

	 * {@link ICdmMassIndexer#dictionaryClasses()}. Re-dicting will not purge

	 * the dictionaries.

	 * 

	 * @param frontendBaseUrl

	 *            if the CDM server is running behind a reverse proxy you need

	 *            to supply the base URL of web service front-end which is

	 *            provided by the proxy server.

	 * @param request

	 * @param respone

	 * @return

	 * @throws Exception

	 */

	@RequestMapping(value = { "redict" }, method = RequestMethod.GET)

	public ModelAndView doRedict(

			@RequestParam(value = "frontendBaseUrl", required = false) String frontendBaseUrl,

			@RequestParam(value = "priority", required = false) Integer priority,

			HttpServletRequest request, HttpServletResponse response)

			throws Exception {

		String processLabel = "Re-Dicting";

		ProgressMonitorUtil progressUtil = new ProgressMonitorUtil(

				progressMonitorController);

		if (!progressMonitorController.isMonitorRunning(indexMonitorUuid)) {

			indexMonitorUuid = progressUtil.registerNewMonitor();

			Thread subThread = new Thread() {

				@Override

				public void run() {

					indexer.createDictionary(progressMonitorController

							.getMonitor(indexMonitorUuid));

				}

			};

			if (priority == null) {

				priority = AbstractController.DEFAULT_BATCH_THREAD_PRIORITY;

			}

			subThread.setPriority(priority);

			subThread.start();

		}

		// send redirect "see other"

		return progressUtil.respondWithMonitor(frontendBaseUrl, request,

				response, processLabel, indexMonitorUuid);

	}

	/**

	 * This will wipe out the index.

	 * 

	 * @param request

	 * @param respone

	 * @return

	 * @throws Exception

	 */

	@RequestMapping(value = { "purge" }, method = RequestMethod.GET)

	public ModelAndView doPurge(

			@RequestParam(value = "frontendBaseUrl", required = false) String frontendBaseUrl,

			@RequestParam(value = "priority", required = false) Integer priority,

			HttpServletRequest request, HttpServletResponse response)

			throws Exception {

		String processLabel = "Purging";

		ProgressMonitorUtil progressUtil = new ProgressMonitorUtil(

				progressMonitorController);

		if (!progressMonitorController.isMonitorRunning(indexMonitorUuid)) {

			indexMonitorUuid = progressUtil.registerNewMonitor();

			Thread subThread = new Thread() {

				@Override

				public void run() {

					indexer.purge(progressMonitorController

							.getMonitor(indexMonitorUuid));

				}

			};

			if (priority == null) {

				priority = AbstractController.DEFAULT_BATCH_THREAD_PRIORITY;

			}

			subThread.setPriority(priority);

			subThread.start();

		}

		// send redirect "see other"

		return progressUtil.respondWithMonitor(frontendBaseUrl, request,

				response, processLabel, indexMonitorUuid);

	}