Added Duplicates

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/portlets/user/tabular-data-table-widget@92843 82a268e6-3cf1-43bd-a215-b396298e98cf

src/main/java/org/gcube/portlets/user/td/tablewidget/client/progress/DuplicatesRowsProgressBarUpdater.java

@@ -0,0 +1,75 @@
+/**
+ * 
+ */
+package org.gcube.portlets.user.td.tablewidget.client.progress;
+
+
+
+
+import org.gcube.portlets.user.td.widgetcommonevent.shared.TRId;
+
+import com.allen_sauer.gwt.log.client.Log;
+import com.sencha.gxt.widget.core.client.ProgressBar;
+
+/**
+ * 
+ * @author "Giancarlo Panichi" 
+ * <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a> 
+ *
+ */
+public class DuplicatesRowsProgressBarUpdater implements DuplicatesRowsProgressListener {
+	
+	protected ProgressBar progressBar;
+	
+	/**
+	 * Creates a new {@link ProgressBar} updater.
+	 * @param progressBar the {@link ProgressBar} to update.
+	 */
+	public DuplicatesRowsProgressBarUpdater(ProgressBar progressBar) {
+		this.progressBar = progressBar;
+	}
+
+	
+	/**
+	 * {@inheritDoc}
+	 */
+	public void operationComplete(TRId trId) {
+		Log.info("Completed");
+		progressBar.updateProgress(1, "Completed");	
+		
+	}
+
+	/**
+	 * {@inheritDoc}
+	 */
+	public void operationFailed(Throwable caught, String reason, String failureDetails) {
+		Log.info("Failed");
+		progressBar.updateText("Failed");
+	}
+
+	public void operationInitializing() {
+		Log.info("Inizializing");
+		progressBar.updateProgress(0, "Initializing...");
+	}
+
+	public void operationUpdate(float elaborated) {
+		Log.info("Elaborated: "+elaborated);
+		if (elaborated == 0) progressBar.updateProgress(0, "Initializing...");
+		if (elaborated>0 && elaborated<1) {
+			Log.trace("progress "+elaborated);
+			int elab=new Float(elaborated*100).intValue();
+			progressBar.updateProgress(elaborated,elab+"% Progress...");
+		}
+		if (elaborated == 1) progressBar.updateProgress(1, "Completing...");
+		
+	}
+
+
+	@Override
+	public void operationStopped(TRId trId,String reason, String details) {
+		Log.debug("Operation Stopped: ["+trId.toString()+", "+reason+", "+details+"]");
+		progressBar.updateText("Stopped");
+		
+	}
+
+}

src/main/java/org/gcube/portlets/user/td/tablewidget/client/progress/DuplicatesRowsProgressDialog.java

@@ -0,0 +1,133 @@
+package org.gcube.portlets.user.td.tablewidget.client.progress;
+
+import org.gcube.portlets.user.td.gwtservice.shared.tr.rows.DuplicatesSession;
+import org.gcube.portlets.user.td.widgetcommonevent.client.event.ChangeTableRequestEvent;
+import org.gcube.portlets.user.td.widgetcommonevent.client.type.ChangeTableRequestType;
+import org.gcube.portlets.user.td.widgetcommonevent.shared.TRId;
+
+import com.allen_sauer.gwt.log.client.Log;
+import com.google.web.bindery.event.shared.EventBus;
+import com.sencha.gxt.core.client.util.Margins;
+import com.sencha.gxt.widget.core.client.FramedPanel;
+import com.sencha.gxt.widget.core.client.ProgressBar;
+import com.sencha.gxt.widget.core.client.Window;
+import com.sencha.gxt.widget.core.client.box.AlertMessageBox;
+import com.sencha.gxt.widget.core.client.button.TextButton;
+import com.sencha.gxt.widget.core.client.container.VerticalLayoutContainer;
+import com.sencha.gxt.widget.core.client.container.VerticalLayoutContainer.VerticalLayoutData;
+import com.sencha.gxt.widget.core.client.event.HideEvent;
+import com.sencha.gxt.widget.core.client.event.HideEvent.HideHandler;
+import com.sencha.gxt.widget.core.client.event.SelectEvent;
+import com.sencha.gxt.widget.core.client.event.SelectEvent.SelectHandler;
+
+
+
+/**
+ * LabelColumnProgressDialog is a Dialog that show progress of change the column label 
+ * 
+ * @author "Giancarlo Panichi" 
+ * <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a> 
+ *
+ */
+public class DuplicatesRowsProgressDialog extends Window implements DuplicatesRowsProgressListener {
+		public static final int STATUS_POLLING_DELAY = 1000;
+		protected String WIDTH = "400px";
+		protected String HEIGHT = "120px";
+		protected DuplicatesSession duplicatesSession;
+		protected EventBus eventBus;
+		protected DuplicatesRowsProgressUpdater progressUpdater;
+		protected TextButton ok;
+		protected TRId trId;
+		
+		public DuplicatesRowsProgressDialog(DuplicatesSession duplicatesSession, EventBus eventBus) {
+			this.duplicatesSession=duplicatesSession;
+			this.eventBus=eventBus;
+			setWidth(WIDTH);
+			setHeight(HEIGHT);
+			setBodyBorder(false);
+			setResizable(true);
+			setModal(true);
+			setHeadingText("Duplicates Rows Progress");
+			
+			trId=null;
+			
+			FramedPanel panel=new FramedPanel();
+			panel.setHeaderVisible(false);
+			panel.setBodyBorder(false);
+			
+			VerticalLayoutContainer v = new VerticalLayoutContainer();
+			
+			
+			ProgressBar progressBar = new ProgressBar();
+			
+			ok=new TextButton("OK");
+			ok.addSelectHandler(new SelectHandler() {
+				
+				public void onSelect(SelectEvent event) {
+					updateInvocation();
+					
+				}
+			});
+			
+			v.add(progressBar, new VerticalLayoutData(1,
+					1, new Margins(5, 5, 5, 5)));
+			
+			panel.add(v);
+			panel.addButton(ok);
+			add(panel);
+			
+			
+			progressUpdater = new DuplicatesRowsProgressUpdater();
+			progressUpdater.addListener(new DuplicatesRowsProgressBarUpdater(progressBar));
+
+			progressUpdater.addListener(this);
+			progressUpdater.scheduleRepeating(STATUS_POLLING_DELAY);
+			show();
+			ok.setVisible(false);
+					
+		}
+
+		public void operationInitializing() {
+			// TODO Auto-generated method stub
+			
+		}
+
+		public void operationUpdate(float elaborated) {
+			// TODO Auto-generated method stub
+			
+		}
+
+		public void operationComplete(TRId trId) {
+			Log.debug("Operation Complete return: "+trId.toString());
+			ok.setVisible(true);
+			this.trId=trId;
+		}
+
+		public void operationFailed(Throwable caught, String reason,
+				String failureDetails) {
+			ok.setVisible(true);
+			this.trId=null;
+			AlertMessageBox d = new AlertMessageBox("Error Deleting Rows", reason);
+			d.addHideHandler(new HideHandler() {
+				public void onHide(HideEvent event) {	
+				}
+			});
+			d.show();
+		}
+		
+		public void updateInvocation(){
+			if(trId!=null){
+				ChangeTableRequestEvent changeTableRequestEvent=
+						new ChangeTableRequestEvent(ChangeTableRequestType.DUPLICATES, trId);
+				eventBus.fireEvent(changeTableRequestEvent);
+			}
+			hide();
+		}
+
+		@Override
+		public void operationStopped(TRId trId,String reason, String details) {
+			Log.debug("Operation Stopped: ["+trId.toString()+", "+reason+", "+details+"]");
+			ok.setVisible(true);
+			this.trId=trId;
+		}
+}

src/main/java/org/gcube/portlets/user/td/tablewidget/client/progress/DuplicatesRowsProgressListener.java

@@ -0,0 +1,52 @@
+/**
+ * 
+ */
+package org.gcube.portlets.user.td.tablewidget.client.progress;
+
+import org.gcube.portlets.user.td.widgetcommonevent.shared.TRId;
+
+
+
+/**
+ * Defines a listener for operation progress.
+ *
+ * @author "Giancarlo Panichi" 
+ * <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a> 
+ *
+ */
+public interface DuplicatesRowsProgressListener {
+	
+	/**
+	 * Called when the operation is starting.
+	 */
+	public void operationInitializing();
+	
+	/**
+	 * Called when there is a progress for the operation.
+	 * @param elaborated the elaborated part.
+	 */
+	public void operationUpdate(float elaborated);
+	
+	
+	/**
+	 * Called when the operation is complete.
+	 */
+	public void operationComplete(TRId trId);
+
+	/**
+	 * Called when the operation is failed.
+	 * @param caught the failure exception.
+	 * @param reason the failure reason.
+	 */
+	public void operationFailed(Throwable caught, String reason, String failureDetails);
+	
+	/**
+	 * Called when the operation is stopped
+	 * 
+	 * @param trId
+	 * @param reason
+	 * @param details
+	 */
+	public void operationStopped(TRId trId, String reason, String details);
+
+}

src/main/java/org/gcube/portlets/user/td/tablewidget/client/progress/DuplicatesRowsProgressUpdater.java

@@ -0,0 +1,181 @@
+/**
+ * 
+ */
+package org.gcube.portlets.user.td.tablewidget.client.progress;
+
+import java.util.ArrayList;
+
+import org.gcube.portlets.user.td.gwtservice.client.rpc.TDGWTServiceAsync;
+import org.gcube.portlets.user.td.gwtservice.shared.tr.rows.DuplicatesMonitor;
+import org.gcube.portlets.user.td.widgetcommonevent.shared.TRId;
+
+import com.allen_sauer.gwt.log.client.Log;
+import com.google.gwt.user.client.Timer;
+import com.google.gwt.user.client.rpc.AsyncCallback;
+
+
+/**
+ * 
+ * @author "Giancarlo Panichi" 
+ * <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a> 
+ *
+ */
+public class DuplicatesRowsProgressUpdater extends Timer {
+
+	protected ArrayList<DuplicatesRowsProgressListener> listeners = new ArrayList<DuplicatesRowsProgressListener>();
+
+	/**
+	 * {@inheritDoc}
+	 */
+	@Override
+	public void run() {
+		Log.debug("requesting operation progress");
+		TDGWTServiceAsync.INSTANCE
+				.getDuplicatesMonitor(new AsyncCallback<DuplicatesMonitor>() {
+
+					
+					public void onFailure(Throwable caught) {
+						cancel();
+						Log.error("Error retrieving the operation state",
+								caught);
+						String message = getStack(caught);
+						fireOperationFailed(caught,
+								"Failed getting operation updates", message);
+					}
+
+					public void onSuccess(DuplicatesMonitor result) {
+						Log.info("retrieved DuplicatesMonitor: "
+								+ result.getStatus());
+						switch (result.getStatus()) {
+						case INITIALIZING:
+							Log.info("Initializing...");
+							fireOperationInitializing();
+							break;
+						case ABORTED:
+							cancel();
+							Log.info("Operation Aborted");
+							break;
+						case IN_PROGRESS:
+							fireOperationUpdate(result.getProgress());
+							break;
+						case VALIDATING_RULES:
+							fireOperationUpdate(result.getProgress());
+							break;	
+						case STOPPED:
+							cancel();
+							stopMessage(result);
+							break;		
+						case FAILED:
+							cancel();
+							errorMessage(result);
+							break;
+						case SUCCEDED:
+							cancel();
+							Log.info("Fisnish TableId :"
+									+ result.getTrId());
+							fireOperationComplete(result.getTrId());
+							break;
+						default:
+							Log.info("Unknow State");
+							break;
+						}
+
+					}
+
+					
+
+				});
+
+	}
+
+	protected void errorMessage(DuplicatesMonitor result) {
+		Log.info("Operation on duplicates Failed");
+		Throwable th = null;
+		String failure = null;
+		String details = null;
+		if (result.getError() != null) {
+			th = result.getError();
+			failure = "Failed Client Library Operation on duplicates";
+			details = result.getError().getLocalizedMessage();
+		} else {
+			th = new Throwable("Failed");
+			failure = "Failed Client Library Operation on duplicates";
+			details = "Operation on duplicates failed";
+		}
+		
+		fireOperationFailed(th, failure, details);
+	}
+	
+	protected void stopMessage(DuplicatesMonitor result) {
+		Log.info("Operation on duplicates Stopped");
+		String failure = null;
+		String details = null;
+		if (result.getError() != null) {	
+			failure = "Stopped operation on duplicates";
+			details = result.getError().getLocalizedMessage();
+		} else {
+			failure = "Stopped operation on duplicates";
+			details = "Operation on duplicates stopped";
+		}
+	
+		fireOperationStopped(result.getTrId(),failure, details);
+	}
+	
+
+	protected String getStack(Throwable e) {
+		String message = e.getLocalizedMessage() + " -> <br>";
+		Throwable c = e.getCause();
+		if (c != null)
+			message += getStack(c);
+		return message;
+	}
+
+	protected void fireOperationInitializing() {
+		for (DuplicatesRowsProgressListener listener : listeners)
+			listener.operationInitializing();
+	}
+
+	protected void fireOperationUpdate(float elaborated) {
+		for (DuplicatesRowsProgressListener listener : listeners)
+			listener.operationUpdate(elaborated);
+	}
+
+	protected void fireOperationComplete(TRId trId) {
+		for (DuplicatesRowsProgressListener listener : listeners)
+			listener.operationComplete(trId);
+	}
+
+	protected void fireOperationFailed(Throwable caught, String failure,
+			String failureDetails) {
+		for (DuplicatesRowsProgressListener listener : listeners)
+			listener.operationFailed(caught, failure, failureDetails);
+	}
+
+	protected void fireOperationStopped(TRId trId, String reason, String details) {
+		for (DuplicatesRowsProgressListener listener : listeners)
+			listener.operationStopped(trId,reason, details);
+	}
+	
+	
+	/**
+	 * Add a new {@link DuplicatesRowsProgressListener} to this
+	 * {@link DuplicatesRowsProgressUpdater}.
+	 * 
+	 * @param listener
+	 *            the listener to add.
+	 */
+	public void addListener(DuplicatesRowsProgressListener listener) {
+		listeners.add(listener);
+	}
+
+	/**
+	 * Removes the specified {@link DuplicatesRowsProgressListener} from this
+	 * {@link DuplicatesRowsProgressUpdater}.
+	 * 
+	 * @param listener
+	 *            the listener to remove.
+	 */
+	public void removeListener(DuplicatesRowsProgressListener listener) {
+		listeners.remove(listener);
+	}
+}

src/main/java/org/gcube/portlets/user/td/tablewidget/client/rows/DuplicatesRowsPanel.java

@@ -5,8 +5,8 @@ import java.util.List;
 
 import org.gcube.portlets.user.td.gwtservice.client.rpc.TDGWTServiceAsync;
 import org.gcube.portlets.user.td.gwtservice.shared.tr.ColumnData;
-import org.gcube.portlets.user.td.gwtservice.shared.tr.rows.DeleteRowsSession;
-import org.gcube.portlets.user.td.tablewidget.client.progress.DeleteRowsProgressDialog;
+import org.gcube.portlets.user.td.gwtservice.shared.tr.rows.DuplicatesSession;
+import org.gcube.portlets.user.td.tablewidget.client.progress.DuplicatesRowsProgressDialog;
 import org.gcube.portlets.user.td.tablewidget.client.properties.ColumnDataProperties;
 import org.gcube.portlets.user.td.widgetcommonevent.shared.TRId;
 
@@ -29,6 +29,8 @@ import com.sencha.gxt.data.shared.loader.LoadResultListStoreBinding;
 import com.sencha.gxt.widget.core.client.FramedPanel;
 import com.sencha.gxt.widget.core.client.box.AlertMessageBox;
 import com.sencha.gxt.widget.core.client.button.TextButton;
+import com.sencha.gxt.widget.core.client.container.BoxLayoutContainer.BoxLayoutData;
+import com.sencha.gxt.widget.core.client.container.HBoxLayoutContainer;
 import com.sencha.gxt.widget.core.client.container.VerticalLayoutContainer;
 import com.sencha.gxt.widget.core.client.container.VerticalLayoutContainer.VerticalLayoutData;
 import com.sencha.gxt.widget.core.client.event.HideEvent;
@@ -41,36 +43,38 @@ import com.sencha.gxt.widget.core.client.grid.ColumnConfig;
 import com.sencha.gxt.widget.core.client.grid.ColumnModel;
 import com.sencha.gxt.widget.core.client.grid.Grid;
 
-public class DuplicateRowsDeletePanel extends FramedPanel {
+public class DuplicatesRowsPanel extends FramedPanel {
 	protected String WIDTH = "640px";
 	protected String HEIGHT = "520px";
 
 	protected TRId trId;
 	protected EventBus eventBus;
 	protected ArrayList<String> rows;
-	protected DeleteRowsSession deleteRowsSession;
-	protected DeleteRowsProgressDialog deleteRowsProgressDialog;
+
+	protected DuplicatesSession duplicatesSession;
+	protected DuplicatesRowsProgressDialog duplicatesRowsProgressDialog;
 
 	protected ListLoader<ListLoadConfig, ListLoadResult<ColumnData>> loader;
 	protected Grid<ColumnData> grid;
 	protected CheckBoxSelectionModel<ColumnData> sm;
 	protected FieldLabel columnsSelectLabel;
 	protected TextButton deleteButton;
+	protected TextButton validatesButton;
 
-	public DuplicateRowsDeletePanel(TRId trId, EventBus eventBus) {
+	public DuplicatesRowsPanel(TRId trId, EventBus eventBus) {
 		setWidth(WIDTH);
 		setHeight(HEIGHT);
 		setHeaderVisible(false);
 		setBodyBorder(false);
 		this.trId = trId;
 		this.eventBus = eventBus;
-		Log.debug("Create DeleteDuplicatePanel(): [" + trId.toString() + "]");
+		Log.debug("Create DuplicatesPanel(): [" + trId.toString() + "]");
 
 		ColumnDataProperties props = GWT.create(ColumnDataProperties.class);
 
 		ColumnConfig<ColumnData, String> labelCol = new ColumnConfig<ColumnData, String>(
 				props.label());
-		
+
 		IdentityValueProvider<ColumnData> identity = new IdentityValueProvider<ColumnData>();
 		sm = new CheckBoxSelectionModel<ColumnData>(identity);
 
@@ -115,32 +119,54 @@ public class DuplicateRowsDeletePanel extends FramedPanel {
 		grid.getView().setAutoExpandColumn(labelCol);
 		grid.getView().setStripeRows(true);
 		grid.getView().setColumnLines(true);
-		//grid.getView().setAutoFill(true);
+		// grid.getView().setAutoFill(true);
 		grid.setBorders(false);
 		grid.setLoadMask(true);
 		grid.setColumnReordering(true);
-	
+
 		// Delete Button
 		deleteButton = new TextButton("Delete");
-		SelectHandler changeHandler = new SelectHandler() {
+		SelectHandler deleteHandler = new SelectHandler() {
 
 			public void onSelect(SelectEvent event) {
 				onDeleteDuplicate();
 
 			}
 		};
-		deleteButton.addSelectHandler(changeHandler);
+		deleteButton.addSelectHandler(deleteHandler);
+
+		// Validates Button
+		validatesButton = new TextButton("Validates");
+		SelectHandler validatesHandler = new SelectHandler() {
+
+			public void onSelect(SelectEvent event) {
+				onValidatesDuplicate();
+
+			}
+		};
+		validatesButton.addSelectHandler(validatesHandler);
+		
 
 		FieldLabel columnsLabel = new FieldLabel(null, "Columns");
-
+		HBoxLayoutContainer hBox=new HBoxLayoutContainer();
+		hBox.add(validatesButton, new BoxLayoutData(new Margins(2,5,2,5)));
+		hBox.add(deleteButton,new BoxLayoutData(new Margins(2,5,2,5)));
+		
+		
 		VerticalLayoutContainer v = new VerticalLayoutContainer();
 		v.add(columnsLabel, new VerticalLayoutData(-1, -1, new Margins(0)));
 		v.add(grid, new VerticalLayoutData(-1, -1, new Margins(0)));
-		v.add(deleteButton, new VerticalLayoutData(-1, -1, new Margins(10, 0,
+		v.add(hBox, new VerticalLayoutData(-1, -1, new Margins(10, 0,
 				10, 0)));
 
 		add(v, new VerticalLayoutData(-1, -1, new Margins(0)));
-		
+
+	}
+
+	protected ArrayList<ColumnData> getSelectedItems() {
+		return new ArrayList<ColumnData>(grid.getSelectionModel()
+				.getSelectedItems());
+
 	}
 
 	public void update(TRId trId) {
@@ -173,23 +199,54 @@ public class DuplicateRowsDeletePanel extends FramedPanel {
 	}
 
 	protected void onDeleteDuplicate() {
-		/*
-		 * TDGWTServiceAsync.INSTANCE.startDeleteRows(deleteRowsSession, new
-		 * AsyncCallback<Void>() {
-		 * 
-		 * public void onFailure(Throwable caught) {
-		 * Log.debug("Delete Rows Error: " + caught.getLocalizedMessage());
-		 * alert("Error Deleting Rows",
-		 * "Error in invocation Delete Rows operation!");
-		 * 
-		 * }
-		 * 
-		 * public void onSuccess(Void result) { deleteRowsProgressDialog = new
-		 * DeleteRowsProgressDialog( deleteRowsSession, eventBus); }
-		 * 
-		 * });
-		 */
+		duplicatesSession = new DuplicatesSession(trId, getSelectedItems(),
+				DuplicatesSession.DuplicateOp.DELETE);
+
+		TDGWTServiceAsync.INSTANCE.startDuplicates(duplicatesSession,
+				new AsyncCallback<Void>() {
+
+					public void onFailure(Throwable caught) {
+						Log.debug("Delete Duplicates Error: "
+								+ caught.getLocalizedMessage());
+						alert("Error Deleting Rows",
+								"Error in invocation Delete Duplicates operation!");
+
+					}
+
+					public void onSuccess(Void result) {
+						duplicatesRowsProgressDialog = new DuplicatesRowsProgressDialog(
+								duplicatesSession, eventBus);
+					}
+
+				});
+
 	}
+	
+	
+	protected void onValidatesDuplicate() {
+		duplicatesSession = new DuplicatesSession(trId, getSelectedItems(),
+				DuplicatesSession.DuplicateOp.VALIDATE);
+
+		TDGWTServiceAsync.INSTANCE.startDuplicates(duplicatesSession,
+				new AsyncCallback<Void>() {
+
+					public void onFailure(Throwable caught) {
+						Log.debug("Validates Duplicates Error: "
+								+ caught.getLocalizedMessage());
+						alert("Error Deleting Rows",
+								"Error in invocation Validates Duplicates operation!");
+
+					}
+
+					public void onSuccess(Void result) {
+						duplicatesRowsProgressDialog = new DuplicatesRowsProgressDialog(
+								duplicatesSession, eventBus);
+					}
+
+				});
+
+	}
+	
 
 	private void alert(String title, String message) {
 		final AlertMessageBox d = new AlertMessageBox(title, message);