package org.gcube.portlets.user.td.monitorwidget.client.background; import java.util.ArrayList; import java.util.List; import org.gcube.portlets.user.td.gwtservice.shared.monitor.OperationMonitor; import org.gcube.portlets.user.td.gwtservice.shared.task.ValidationsTasksMetadata; import org.gcube.portlets.user.td.gwtservice.shared.task.WorkerState; import org.gcube.portlets.user.td.gwtservice.shared.task.WorkerStateParser; import org.gcube.portlets.user.td.monitorwidget.client.details.tree.MonitorBaseDto; import org.gcube.portlets.user.td.monitorwidget.client.details.tree.MonitorFolderDto; import org.gcube.portlets.user.td.monitorwidget.client.details.tree.MonitorTreeDataGenerator; import org.gcube.portlets.user.td.monitorwidget.client.details.tree.MonitorValidationJobSDto; import org.gcube.portlets.user.td.monitorwidget.client.resources.ResourceBundle; import org.gcube.portlets.user.td.widgetcommonevent.shared.TRId; import com.google.gwt.cell.client.AbstractCell; import com.google.gwt.cell.client.Cell.Context; import com.google.gwt.resources.client.ImageResource; import com.google.gwt.safehtml.shared.SafeHtmlBuilder; import com.google.gwt.safehtml.shared.SafeHtmlUtils; import com.google.web.bindery.event.shared.EventBus; import com.sencha.gxt.cell.core.client.ProgressBarCell; import com.sencha.gxt.core.client.ToStringValueProvider; import com.sencha.gxt.core.client.ValueProvider; import com.sencha.gxt.core.client.util.Margins; import com.sencha.gxt.data.shared.IconProvider; import com.sencha.gxt.data.shared.ModelKeyProvider; import com.sencha.gxt.data.shared.TreeStore; import com.sencha.gxt.widget.core.client.FramedPanel; import com.sencha.gxt.widget.core.client.button.TextButton; import com.sencha.gxt.widget.core.client.container.MarginData; 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.CollapseItemEvent; import com.sencha.gxt.widget.core.client.event.CollapseItemEvent.CollapseItemHandler; import com.sencha.gxt.widget.core.client.event.ExpandItemEvent; import com.sencha.gxt.widget.core.client.event.ExpandItemEvent.ExpandItemHandler; import com.sencha.gxt.widget.core.client.event.SelectEvent; import com.sencha.gxt.widget.core.client.event.SelectEvent.SelectHandler; 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.menu.Menu; import com.sencha.gxt.widget.core.client.menu.MenuItem; import com.sencha.gxt.widget.core.client.toolbar.ToolBar; import com.sencha.gxt.widget.core.client.treegrid.TreeGrid; /** * * @author "Giancarlo Panichi" g.panichi@isti.cnr.it * */ public class MonitorBackgroundPanel extends FramedPanel implements MonitorBackgroundUpdaterListener { protected static final int STATUS_POLLING_DELAY = 2000; protected static final String WIDTH = "298px"; protected static final String HEIGHT = "520px"; protected static final int CC1WIDTH = 168; protected static final int CC2WIDTH = 100; protected static final int CC3WIDTH = 140; protected static final int CC4WIDTH = 100; protected ArrayList monitorBackgroundEventUIListeners = new ArrayList(); protected MonitorBackgroundPanel thisPanel; protected Menu contextMenu; protected MenuItem resumeItem; protected MenuItem resolveItem; protected TRId trId; protected VerticalLayoutContainer con; protected ValidationsTasksMetadata validationsTasksMetadata; protected MonitorTreeDataGenerator gen; protected TreeStore store; protected TreeGrid tree; protected ArrayList operationMonitorList; protected EventBus eventBus; protected MonitorBackgroundUpdater monitorBackgroundUpdater; class KeyProvider implements ModelKeyProvider { @Override public String getKey(MonitorBaseDto item) { return (item instanceof MonitorFolderDto ? "f-" : "v-") + item.getId(); } } public MonitorBackgroundPanel(EventBus eventBus) { super(); this.eventBus = eventBus; forceLayoutOnResize = true; init(); create(); } protected void init() { setWidth(WIDTH); setHeight(HEIGHT); setHeaderVisible(false); setBodyBorder(false); setResize(true); } protected void create() { con = new VerticalLayoutContainer(); // con.setScrollMode(ScrollMode.AUTO); store = new TreeStore(new KeyProvider()); addChildrensToStore(); ColumnConfig cc1 = new ColumnConfig( new ToStringValueProvider("task"), CC1WIDTH, "Task"); cc1.setHeader("Task"); cc1.setCell(new AbstractCell() { @Override public void render(Context context, String value, SafeHtmlBuilder sb) { sb.appendHtmlConstant("" + value + ""); } }); ColumnConfig cc2 = new ColumnConfig( new ValueProvider() { @Override public String getValue(MonitorBaseDto object) { String state = null; if (object instanceof MonitorValidationJobSDto) { state = ((MonitorValidationJobSDto) object) .getWorkerState().toString(); } if (object instanceof MonitorFolderDto) { state = ((MonitorFolderDto) object).getState(); } return state; } @Override public void setValue(MonitorBaseDto object, String value) { if (object instanceof MonitorValidationJobSDto) { WorkerState workerState = WorkerStateParser.parse(value); ((MonitorValidationJobSDto) object) .setWorkerState(workerState); } if (object instanceof MonitorFolderDto) { ((MonitorFolderDto) object).setState(value); } } @Override public String getPath() { return "status"; } }, CC2WIDTH, "Status"); cc2.setHeader("Status"); ColumnConfig cc3 = new ColumnConfig( new ValueProvider() { @Override public String getValue(MonitorBaseDto object) { String state = null; if (object instanceof MonitorValidationJobSDto) { state = ((MonitorValidationJobSDto) object).getHumanReadableStatus(); } if (object instanceof MonitorFolderDto) { state = ((MonitorFolderDto) object).getHumanReadableStatus(); } return state; } @Override public void setValue(MonitorBaseDto object, String value) { if (object instanceof MonitorValidationJobSDto) { ((MonitorValidationJobSDto) object) .setHumanReadableStatus(value); } if (object instanceof MonitorFolderDto) { ((MonitorFolderDto) object).setHumanReadableStatus(value); } } @Override public String getPath() { return "humanreadablestatus"; } }, CC3WIDTH, "Human Readble"); cc3.setHeader("Human Readble"); ColumnConfig cc4 = new ColumnConfig( new ValueProvider() { @Override public Double getValue(MonitorBaseDto object) { Double d = null; if (object instanceof MonitorValidationJobSDto) { Float f = ((MonitorValidationJobSDto) object).getProgress(); d = new Double(f); } if (object instanceof MonitorFolderDto) { Float f = ((MonitorFolderDto) object).getProgress(); d = new Double(f); } return d; } @Override public void setValue(MonitorBaseDto object, Double value) { if (object instanceof MonitorValidationJobSDto) { ((MonitorValidationJobSDto) object) .setProgress(value.floatValue()); } if (object instanceof MonitorFolderDto) { ((MonitorFolderDto) object).setProgress(value .floatValue()); } } @Override public String getPath() { return "progress"; } }, CC4WIDTH, "Progress"); cc4.setHeader("Progress"); ProgressBarCell progress = new ProgressBarCell() { @Override public boolean handlesSelection() { return true; } }; progress.setProgressText("{0}% Complete"); progress.setWidth(110); cc4.setCell(progress); List> l = new ArrayList>(); l.add(cc1); l.add(cc2); l.add(cc3); l.add(cc4); ColumnModel cm = new ColumnModel(l); tree = new TreeGrid(store, cm, cc1); tree.getView().setAutoFill(true); tree.setBorders(false); tree.setLoadMask(true); tree.setColumnResize(true); tree.getView().setAutoExpandColumn(cc1); IconProvider iconProvider = new IconProvider() { @Override public ImageResource getIcon(MonitorBaseDto model) { ImageResource img = null; if (model instanceof MonitorFolderDto) { String type = ((MonitorFolderDto) model).getType(); if (type.compareTo("job") == 0) { img = ResourceBundle.INSTANCE.cog(); } else { if (type.compareTo("task") == 0) { img = ResourceBundle.INSTANCE.basket(); } else { } } } else { img = ResourceBundle.INSTANCE.tableValidation(); } return img; } }; tree.setIconProvider(iconProvider); tree.addExpandHandler(new ExpandItemHandler() { @Override public void onExpand(ExpandItemEvent event) { forceLayout(); } }); tree.addCollapseHandler(new CollapseItemHandler() { @Override public void onCollapse(CollapseItemEvent event) { forceLayout(); } }); // createContextMenu(); ToolBar toolBar = new ToolBar(); TextButton btnExpandAll = new TextButton(); btnExpandAll.setIcon(ResourceBundle.INSTANCE.magnifierZoomIn()); btnExpandAll.setToolTip("Expand All"); btnExpandAll.addSelectHandler(new SelectHandler() { @Override public void onSelect(SelectEvent event) { tree.expandAll(); forceLayout(); } }); toolBar.add(btnExpandAll); TextButton btnCollapseAll = new TextButton(); btnCollapseAll.setIcon(ResourceBundle.INSTANCE.magnifierZoomOut()); btnCollapseAll.setToolTip("Collapse All"); btnCollapseAll.addSelectHandler(new SelectHandler() { @Override public void onSelect(SelectEvent event) { tree.collapseAll(); forceLayout(); } }); toolBar.add(btnCollapseAll); con.add(toolBar, new VerticalLayoutData(1, -1, new Margins(0))); con.add(tree, new VerticalLayoutData(1, -1, new Margins(0))); add(con, new MarginData(0)); addMonitor(); //tree.expandAll(); forceLayout(); } protected void addMonitor() { monitorBackgroundUpdater = new MonitorBackgroundUpdater(); monitorBackgroundUpdater.addListener(this); monitorBackgroundUpdater.scheduleRepeating(STATUS_POLLING_DELAY); addMonitorBackgroundEventUIListener(monitorBackgroundUpdater); } public void addMonitorBackgroundEventUIListener( MonitorBackgroundEventUIListener listener) { monitorBackgroundEventUIListeners.add(listener); } public void removeMonitorBackgroundEventUIListener( MonitorBackgroundEventUIListener listener) { monitorBackgroundEventUIListeners.remove(listener); } public void update() { forceLayout(); } protected void close() { /* * if (parent != null) { parent.close(); } */ } protected void requestOperationOnKey(Context context) { String key = (String) context.getKey(); @SuppressWarnings("unused") MonitorBaseDto d = store.findModelWithKey(key); } private void addChildrensToStore() { gen = new MonitorTreeDataGenerator(); MonitorFolderDto root = gen.getRoot(operationMonitorList); for (MonitorBaseDto base : root.getChildrens()) { store.add(base); if (base instanceof MonitorFolderDto) { processFolder(store, (MonitorFolderDto) base); } } } private void processFolder(TreeStore store, MonitorFolderDto folder) { for (MonitorBaseDto child : folder.getChildrens()) { store.add(folder, child); if (child instanceof MonitorFolderDto) { processFolder(store, (MonitorFolderDto) child); } } } @Override public void operationMonitorListUpdated( ArrayList operationMonitorList) { store.clear(); store.commitChanges(); addChildrensToStore(); store.commitChanges(); tree.expandAll(); forceLayout(); } @Override public void retrieveOperationMonitorListFailed(Throwable caught) { // TODO Auto-generated method stub } }