ckan-content-moderator-widget/src/main/java/org/gcube/portlets/widgets/ckancontentmoderator/server/CkanContentModeratorServiceImpl.java

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

import java.util.ArrayList;
import java.util.List;

import org.gcube.common.authorization.library.provider.SecurityTokenProvider;
import org.gcube.common.scope.api.ScopeProvider;
import org.gcube.datacatalogue.utillibrary.server.cms.CatalogueContentModeratorSystem;
import org.gcube.datacatalogue.utillibrary.shared.ItemStatus;
import org.gcube.datacatalogue.utillibrary.shared.jackan.model.CkanDataset;
import org.gcube.portlets.widgets.ckancontentmoderator.client.CkanContentModeratorService;
import org.gcube.portlets.widgets.ckancontentmoderator.shared.CatalogueDataset;
import org.gcube.portlets.widgets.ckancontentmoderator.shared.SearchedData;
import org.gcube.vomanagement.usermanagement.model.GCubeUser;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.google.gwt.user.server.rpc.RemoteServiceServlet;

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

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

	@Override
	public boolean isContentModeratorEnabled() {
		LOG.info("called isContentModeratorEnabled");
		LOG.warn("isContentModeratorEnabled METHOD MUST BE IMPLEMENTED!!!");
		return true;
	}

	@Override
	public void setStatus(String itemId, ItemStatus theStatus) {
		// TODO Auto-generated method stub

	}

	/**
	 * Gets the list items for status.
	 *
	 * @param theStatus the the status
	 * @param offset the offset
	 * @param limit the limit
	 * @return the list items for status
	 * @throws Exception the exception
	 */
	@Override
	public List<CatalogueDataset> getListItemsForStatus(ItemStatus theStatus, int offset, int limit) throws Exception {
		LOG.info("called getListItemsForStatus with [status: " + theStatus + ", offset: " + offset + "], [limit: "
				+ limit + "]");
		List<CatalogueDataset> datasetList = null;
		try {

			String scope = WsUtil.getCurrentScope(this.getThreadLocalRequest());
			GCubeUser user = WsUtil.getCurrentUser(this.getThreadLocalRequest());
			String token = WsUtil.getCurrentToken(scope, user.getUsername());
			ScopeProvider.instance.set(scope);
			SecurityTokenProvider.instance.set(token);
			CatalogueContentModeratorSystem cmsInstance = CatalogueCMSFactory.getFactory().getCMSPerScope(scope);
			List<CkanDataset> datasets = cmsInstance.getListItemsForStatus(theStatus, limit, offset);
			if (datasets != null) {
				int size = datasets.size();
				datasetList = new ArrayList<CatalogueDataset>(size);
				LOG.info("datasetList for input parameters returned by CMS has size: " + size);
				for (CkanDataset ckanDataset : datasets) {
					CatalogueDataset ds = CatalogueBeansConverter.toCatalogueDataset.apply(ckanDataset);
					LOG.debug("converted dataset is: " + ds);
					datasetList.add(ds);
				}
			}

		} catch (Exception e) {
			LOG.error(e.getMessage(), e);
			throw new Exception(
					"Error occurrend on reading items for status: " + theStatus + ". Caused by: " + e.getMessage());
		}
		
		LOG.info("returning "+datasetList.size()+ " dataset");
		return datasetList;
	}

	@Override
	public void approveItem(String itemId) {
		LOG.info("Called approve Item: " + itemId);

	}

	@Override
	public void rejectItem(String itemId, boolean permanentlyDelete, String reasonMsg) {
		// TODO Auto-generated method stub

	}

	@Override
	public void permanentlyDelete(String itemId) {
		// TODO Auto-generated method stub

	}

	@Override
	public SearchedData getDataForStatus(ItemStatus status, int offset, int limit, int serverStartIndex) throws Exception {
		LOG.info("called getDataForStatus [status: "+status+", offset: "+offset+", limit: "+limit+", serverIndex: "+serverStartIndex);

		try {
			String scope = WsUtil.getCurrentScope(this.getThreadLocalRequest());
			GCubeUser user = WsUtil.getCurrentUser(this.getThreadLocalRequest());
			String token = WsUtil.getCurrentToken(scope, user.getUsername());
			ScopeProvider.instance.set(scope);
			SecurityTokenProvider.instance.set(token);
			//int searchStartIndex = limit < serverStartIndex? serverStartIndex : offset;
			
			int searchStartIndex = offset;

			CatalogueContentModeratorSystem cmsInstance = CatalogueCMSFactory.getFactory().getCMSPerScope(scope);
			SearchedData searchedData = new SearchedData(offset, limit, searchStartIndex, false);
			long totalItemsForStatus = cmsInstance.countListItemsForStatus(status);
			LOG.info("totalItemsForStatus "+status+" are : "+totalItemsForStatus);
			List<CatalogueDataset> listDataset = new ArrayList<CatalogueDataset>();
			try {
				LOG.debug("getListItemsForStatus with searchStartIndex: "+searchStartIndex+", limit: "+limit);
				listDataset = getListItemsForStatus(status, searchStartIndex, limit);
			}catch (Exception e) {
				LOG.error("Error occurred on gettin items for status: "+status,e);
			}
			
			int listDatasetSize = listDataset.size();
			LOG.debug("Returned "+listDatasetSize+" with above parameters");
			searchedData.setData(listDataset);
			searchedData.setTotalItems(totalItemsForStatus);

			if(listDatasetSize == limit || listDatasetSize==0){
				LOG.debug("Page completed returning "+listDatasetSize+ " items");
				int newOffset = searchStartIndex+offset;
				searchedData.setServerSearchFinished(newOffset>totalItemsForStatus || listDatasetSize == 0);
				LOG.debug("is Search finished: "+searchedData.isServerSearchFinished());
				return searchedData;
			}

			/*int offsetStartIndex = searchStartIndex;
			boolean pageOffsetOut = false;
			while(listDatasetSize < offset && !searchedData.isServerSearchFinished() && !pageOffsetOut){ //&& SEARCH NOT ULTIMATED
				LOG.debug("MyLg new WHILE Items count: "+totalItemsForStatus+" is less than limit..");

				int newOffsetStartIndex = offsetStartIndex+limit+1;
				LOG.debug("MyLg NewStartIndex is startIndex+limit: "+newOffsetStartIndex);

				//THERE ARE OTHER CHILDREN OVER NEW START INDEX
				if(newOffsetStartIndex < totalItemsForStatus){
					//newLimit = limit - childrenToReturn.size();
					LOG.debug("MyLg getting items with index start: "+newOffsetStartIndex + ", limit: "+offset);
					
					int diff = (int) (offset - totalItemsForStatus); //How items are remaining
					//int offset = 0;
					LOG.debug("MyLg new search start: "+newOffsetStartIndex + ", diff: "+diff+ ", retrieved: "+listDatasetSize);
					if(diff >= listDatasetSize){
					}else{
						pageOffsetOut = true;
					}
					offsetStartIndex = newOffsetStartIndex;
					LOG.debug("MyLg items count is: "+totalItemsForStatus + " serverEndIndex: "+offsetStartIndex);
					searchedData.setServerEndIndex(offsetStartIndex);
				}else{
					LOG.debug("New start index (oldStartIndex+limit) is grather than total items count, search is finished");
					searchedData.setServerSearchFinished(true);
				}
			}*/
			LOG.debug("Returning: "+searchedData);
			return searchedData;

		} catch (Exception e) {
			LOG.error("Error during folder retrieving", e);
			throw new Exception("Sorry, an error occurred on loading items");
		}
	}
}