ckan2zenodo-publisher-widget/src/main/java/org/gcube/portlets/widgets/ckan2zenodopublisher/server/CkanToZenodoPublisherServiceImpl.java

package org.gcube.portlets.widgets.ckan2zenodopublisher.server;

import java.util.ArrayList;

import org.gcube.data.publishing.ckan2zenodo.Ckan2Zenodo;
import org.gcube.data.publishing.ckan2zenodo.model.CkanItemDescriptor;
import org.gcube.data.publishing.ckan2zenodo.model.faults.ConfigurationException;
import org.gcube.data.publishing.ckan2zenodo.model.faults.GcatException;
import org.gcube.data.publishing.ckan2zenodo.model.faults.InvalidItemException;
import org.gcube.data.publishing.ckan2zenodo.model.faults.TransformationException;
import org.gcube.data.publishing.ckan2zenodo.model.faults.ZenodoException;
import org.gcube.data.publishing.ckan2zenodo.model.zenodo.FileDeposition;
import org.gcube.data.publishing.ckan2zenodo.model.zenodo.ZenodoDeposition;
import org.gcube.portlets.widgets.ckan2zenodopublisher.client.CkanToZendoPublisherWidgetConstant;
import org.gcube.portlets.widgets.ckan2zenodopublisher.client.CkanToZenodoPublisherService;
import org.gcube.portlets.widgets.ckan2zenodopublisher.server.converter.ItemToZenodoConverter;
import org.gcube.portlets.widgets.ckan2zenodopublisher.shared.CatalogueItem;
import org.gcube.portlets.widgets.ckan2zenodopublisher.shared.wrapped.ZenodoFile;
import org.gcube.portlets.widgets.ckan2zenodopublisher.shared.wrapped.ZenodoItem;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.google.gwt.user.server.rpc.RemoteServiceServlet;
import com.liferay.portal.service.UserLocalServiceUtil;

/**
 * The server side implementation of the RPC service.
 */
@SuppressWarnings("serial")
public class CkanToZenodoPublisherServiceImpl extends RemoteServiceServlet implements CkanToZenodoPublisherService {

	private static Logger LOG = LoggerFactory.getLogger(CkanToZenodoPublisherServiceImpl.class);

	
	@Override
	public String publishOnZenodo(ZenodoItem zenodoItem) throws Exception {

		try {

			ZenodoDeposition zdPreview=loadItemPreviewFromService(zenodoItem.getName());
			
			//(EVENTUALLY) UPDATING INFO CHANGED BY FORM ON CLIENT-SIDE
			//metadata
			zdPreview.setTitle(zenodoItem.getTitle());
			//files
			if(zenodoItem.getFiles()!=null) {
				ArrayList<FileDeposition> listOfFiles = new ArrayList<FileDeposition>(zenodoItem.getFiles().size());
				for (ZenodoFile zf : zenodoItem.getFiles()) {
					FileDeposition fileDepos = ItemToZenodoConverter.toServiceFileDeposition(zf);
					listOfFiles.add(fileDepos);
				}
				zdPreview.setFiles(listOfFiles);
			}
			
			//Ckan2ZenodoImpl.publish(item.getItemName());
			//Eventually update values
			//zdPreview.getMetadata().setAccess_conditions("Ask me");

			//Actually publish to zenodo : 
			// Step 1 : metadata
			Ckan2Zenodo client= Ckan2Zenodo.get();
			CkanItemDescriptor item=client.read(zenodoItem.getName());
			zdPreview = client.updatedMetadata(zdPreview);

			//Step 2 : publish Resources 
//			Future<ZenodoDeposition> future_Dep=client.uploadFiles(Collections.singleton(toFilter.get(0)), zdPreview);
//			ZenodoDeposition preview = future_Dep.get();

			//Finalize
			// Get the item representation

			client.publish(zdPreview, item);
			
			return "OK";
			
		} catch (Exception e) {
			String error = "Error on publishing on Zenodo the catalogue item: "+zenodoItem.getName();
			LOG.error(error, e);
			String clientError = String.format("%s. %s", error, CkanToZendoPublisherWidgetConstant.MSG_OF_ERROR_REFRESH_AND_TRY_AGAIN_OR_CONTACT_THE_SUPPORT);
			throw new Exception(clientError);
		}

	}
	
	@Override
	public ZenodoItem convertToZenodoItem(CatalogueItem item) throws Exception {

		try {
			
			if(isOutFromPortal()) {
				PortalUtils.getCurrentContext(this.getThreadLocalRequest(), true);
				PortalUtils.getCurrentToken(this.getThreadLocalRequest(), true);
			}
			
			//Get a preview of the deposition to be published
			ZenodoDeposition zdPreview=loadItemPreviewFromService(item.getItemName());

			//Filter resources according to VRE policies
			//List<CkanResource> toFilterFiles=client.filterResources(itemDescr);
			
			//zdPreview.setFiles(toFilterFiles);
			ZenodoItem zenodoItem = ItemToZenodoConverter.toZenodoItem(zdPreview);
			zenodoItem.setName(item.getItemName());
			return zenodoItem;

//			//TO TEST
//			ZenodoDeposition zd = new ZenodoDeposition();
//			zd.setTitle("My beautiful title");
//			ArrayList<FileDeposition> files = new ArrayList<FileDeposition>();
//			for (int i = 0; i < 5; i++) {
//				FileDeposition fd = new FileDeposition();
//				int index = i+1;
//				fd.setFilename("My file "+index);
//				files.add(fd);
//			}
//			zd.setFiles(files);
//			DepositionMetadata metadata = new DepositionMetadata(UploadType.dataset, new Date(), "My title", new ArrayList<Creator>(), "My desr", AccessRights.open);
//			metadata.setDescription("My beautiful description");
//			List<RelatedIdentifier> related_identifiers = new ArrayList<RelatedIdentifier>(1);
//			related_identifiers.add(new RelatedIdentifier("12345", Relation.cites));
//			metadata.setRelated_identifiers(related_identifiers);
//			zd.setMetadata(metadata);
//			return ItemToZenodoConverter.toZenodoItem(zd);
			
		} catch (Exception e) {
			String error = "Error on converting the catalogue item: "+item.getItemName();
			LOG.error(error, e);
			String clientError = String.format("%s. %s", error, e.getMessage());
			throw new Exception(clientError);
		}

	}
	
	
	/**
	 * Load item preview from service.
	 *
	 * @param itemName the item name
	 * @return 
	 * @throws GcatException 
	 * @throws TransformationException 
	 * @throws ConfigurationException 
	 * @throws ZenodoException 
	 * @throws InvalidItemException 
	 */
	private ZenodoDeposition loadItemPreviewFromService(String itemName) throws GcatException, InvalidItemException, ZenodoException, ConfigurationException, TransformationException {
		
		Ckan2Zenodo client= Ckan2Zenodo.get();
		
		// Get the item representation
		CkanItemDescriptor itemDescr=client.read(itemName);
		
		//Get a preview of the deposition to be published
		return client.translate(itemDescr);
	}
	
	/**
	 * Online or in development mode?
	 * @return true if you're running into the portal, false if in development
	 */
	private boolean isOutFromPortal() {
		try {
			UserLocalServiceUtil.getService();
			return false;
		}
		catch (com.liferay.portal.kernel.bean.BeanLocatorException ex) {
			LOG.debug("Development Mode ON");
			return true;
		}
	}
}