/**
 *
 */
package org.gcube.portlets.user.workspace.server.publish;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.InputStream;
import java.util.HashSet;
import java.util.UUID;

import javax.servlet.http.HttpSession;

import org.gcube.common.homelibrary.home.HomeLibrary;
import org.gcube.common.homelibrary.home.exceptions.HomeNotFoundException;
import org.gcube.common.homelibrary.home.exceptions.InternalErrorException;
import org.gcube.common.homelibrary.home.exceptions.UserNotFoundException;
import org.gcube.common.homelibrary.home.workspace.Workspace;
import org.gcube.common.homelibrary.home.workspace.WorkspaceFolder;
import org.gcube.common.homelibrary.home.workspace.exceptions.InsufficientPrivilegesException;
import org.gcube.common.homelibrary.home.workspace.exceptions.ItemAlreadyExistException;
import org.gcube.common.homelibrary.home.workspace.exceptions.WorkspaceException;
import org.gcube.common.homelibrary.home.workspace.exceptions.WorkspaceFolderNotFoundException;
import org.gcube.common.homelibrary.home.workspace.exceptions.WrongDestinationException;
import org.gcube.portlets.user.workspace.server.reader.ApplicationProfileReader;
import org.gcube.portlets.user.workspace.server.util.WsUtil;
import org.gcube.portlets.user.workspace.shared.TransferOnThreddsReport;
import org.gcube.usecases.ws.thredds.FolderConfiguration;
import org.gcube.usecases.ws.thredds.PublishFolders;
import org.gcube.usecases.ws.thredds.TokenSetter;
import org.gcube.usecases.ws.thredds.engine.TransferRequestServer;
import org.gcube.usecases.ws.thredds.engine.TransferRequestServer.Report;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;


/**
 * The Class PublishOnThredds.
 *
 * @author Francesco Mangiacrapa francesco.mangiacrapa@isti.cnr.it
 * Sep 27, 2017
 */
public class PublishOnThredds {

	private HashSet<FolderConfiguration> configs;
	private Logger logger = LoggerFactory.getLogger(ApplicationProfileReader.class);
	private String username;
	private HttpSession httpSession;

	/**
	 * Instantiates a new publish on thredds.
	 *
	 * @param publishingScope the publishing scope
	 * @param username the username
	 * @param httpSession the http session
	 */
	public PublishOnThredds(String publishingScope, String username, HttpSession httpSession) {
		TokenSetter.set(publishingScope);
		this.configs = new HashSet<FolderConfiguration>();
		this.username = username;
		this.httpSession = httpSession;
	}


	/**
	 * Publish folder.
	 *
	 * @param folderId the folder id
	 * @param metadataFolderID the metadata folder id
	 * @param publishingUserToken the publishing user token
	 * @param catalogueName the catalogue name
	 * @return the transfer on thredds report
	 */
	public TransferOnThreddsReport publishFolder(final String folderId, final String metadataFolderID, final String publishingUserToken, final String catalogueName){

		final String transferId = UUID.randomUUID().toString();
		final TransferOnThreddsReport tr = new TransferOnThreddsReport(transferId, folderId, false, null);

		new Thread(){
			/* (non-Javadoc)
			 * @see java.lang.Thread#run()
			 */
			@Override
			public void run() {

				WsUtil.setTransferPublishingOnThredds(httpSession, tr);

				FolderConfiguration folderConfig=new FolderConfiguration(publishingUserToken,folderId,catalogueName);
				folderConfig.setProvidedMetadata(false);

				if(metadataFolderID!=null){
					folderConfig.setProvidedMetadata(true);
					folderConfig.setMetadataFolderId(metadataFolderID);
				}
				configs.add(folderConfig);
				TransferRequestServer server=new TransferRequestServer();
				for(FolderConfiguration entry:configs){

					try{
						Workspace ws = HomeLibrary.getHomeManagerFactory().getHomeManager().getHome(username).getWorkspace();
//						FolderReport report=new FolderReport(entry);
						logger.debug("Managing {} ",entry);
						WorkspaceFolder folder = (WorkspaceFolder) ws.getItem(entry.getFolderId());
						PublishFolders.handleFolder(ws,entry,server,folder);


					}catch(WorkspaceException | HomeNotFoundException | InternalErrorException | UserNotFoundException e){
						System.err.println("WORKSPACE EXC ");
						logger.error("WORKSPACE EXC ", e);
						setStatusOnTransferId(transferId, true, "Sorry, an error has occurred during getting workspace for user: "+e.getMessage(), false);
					}catch(Exception e){
						System.err.println("UNEXPECTED EXC");
						logger.error("UNEXPECTED EXC ", e);
						setStatusOnTransferId(transferId, true, "Sorry, an unexpected error has occurred during getting workspace for user", false);
					}
				}

				logger.info("Waiting for service.. ");
				server.waitCompletion();

				Report report = server.getReport();
				File reportFile = report.toFile(folderConfig);
				if(reportFile!=null){
					Workspace workspace;
					try {
						workspace = HomeLibrary.getHomeManagerFactory().getHomeManager().getHome(username).getWorkspace();
						InputStream fileData = new FileInputStream(reportFile);
						workspace.createExternalFile("Publishing on thredds report file", "", "text/plain", fileData, folderId);
						setStatusOnTransferId(transferId, false, "Sorry, an unexpected error has occurred during getting workspace for user",true);

					}
					catch (WorkspaceFolderNotFoundException
									| InternalErrorException
									| HomeNotFoundException
									| UserNotFoundException e) {
						logger.error("Error on getting workspace for thredds transfering to folder: "+folderId, e);
						setStatusOnTransferId(transferId, true, "Sorry, an error has occurred during getting workspace for user: "+e.getMessage(),false);
					}
					catch (FileNotFoundException | InsufficientPrivilegesException | ItemAlreadyExistException | WrongDestinationException e) {
						// TODO Auto-generated catch block
						logger.error("Error on writing report for thredds transfering to folder: "+folderId, e);
						setStatusOnTransferId(transferId, true, "Sorry, an error has occurred during report creation to transfer resulting: "+e.getMessage(),false);
					}
				}
			}
		}.start();

		return tr;

	}


	/**
	 * Gets the status of transfer id.
	 *
	 * @param httpSession the http session
	 * @param transferId the transfer id
	 * @return the status of transfer id
	 */
	public static TransferOnThreddsReport getStatusOfTransferId(HttpSession httpSession, String transferId){
		return WsUtil.geTransferPublishingOnThreddsForId(httpSession, transferId);
	}


	/**
	 * Sets the error on transfer id.
	 *
	 * @param transferId the new error on transfer id
	 * @param error the error
	 * @param reportMessage the report message
	 * @param reportCreated the report created
	 */
	public void setStatusOnTransferId(String transferId, Boolean error, String reportMessage, Boolean reportCreated){
		TransferOnThreddsReport tr = WsUtil.geTransferPublishingOnThreddsForId(httpSession, transferId);

		if(tr!=null){
			tr.setOnError(error);
			tr.setReportMessage(reportMessage);
			tr.setReportCreatedOnWorkspace(reportCreated);
			WsUtil.setTransferPublishingOnThredds(httpSession, tr);
		}


	}
}