bnd/org.eclipse.sensinact.studio.navigator.device/src/org/eclipse/sensinact/studio/navigator/device/ui/dialogs/resourceInvoker/ResourceInvokerDialog.java

/**
 * Copyright (c) 2019 CEA.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 *  Contributors:
 *     CEA - initial API and implementation and/or initial documentation
 */
package org.eclipse.sensinact.studio.navigator.device.ui.dialogs.resourceInvoker;

import org.apache.log4j.Logger;
import org.eclipse.jface.dialogs.IDialogConstants;
import org.eclipse.jface.dialogs.TitleAreaDialog;
import org.eclipse.sensinact.studio.http.messages.snamessage.MsgSensinact;
import org.eclipse.sensinact.studio.http.services.client.GatewayHttpClient;
import org.eclipse.sensinact.studio.http.services.client.GatewayHttpClient.RequestParameter;
import org.eclipse.sensinact.studio.model.resource.utils.ResourceDescriptor;
import org.eclipse.sensinact.studio.model.resource.utils.Segments;
import org.eclipse.sensinact.studio.navigator.device.ui.dialogs.resourceInvoker.methodprovider.MethodProvider;
import org.eclipse.sensinact.studio.resource.AccessMethod;
import org.eclipse.sensinact.studio.resource.AccessMethodType;
import org.eclipse.swt.SWT;
import org.eclipse.swt.events.MouseEvent;
import org.eclipse.swt.events.MouseListener;
import org.eclipse.swt.layout.GridData;
import org.eclipse.swt.layout.GridLayout;
import org.eclipse.swt.widgets.Composite;
import org.eclipse.swt.widgets.Control;
import org.eclipse.swt.widgets.Shell;

/**
 * @author Nicolas Hili, Etienne Gandrille
 */
public class ResourceInvokerDialog extends TitleAreaDialog {

	private static final Logger logger = Logger.getLogger(ResourceInvokerDialog.class);
	
	private final ResourceDescriptor descriptor;	
	private final MethodProvider methodProvider;

	private ParametersComposite parameterComposite;
	private ResultLabel resultLabel;
	
	public ResourceInvokerDialog(Shell parent, ResourceDescriptor descriptor, MethodProvider methodProvider) {
		super(parent);
		
		this.descriptor = descriptor;
		
		this.methodProvider = methodProvider;
		methodProvider.registerResourceInvokerDialog(this);
		setHelpAvailable(false);
	}
	
	@Override
	public void create() {
		super.create();
		setTitle("Resource Invoker");
		setShellStyle(SWT.DIALOG_TRIM | SWT.RESIZE | SWT.MAX);
	}
		
	@Override
	protected Control createDialogArea(Composite parent) {
		Composite area = (Composite) super.createDialogArea(parent);
		configureDialogArea(area);

		methodProvider.createDialogArea(area);
		parameterComposite = new ParametersComposite(area);
		resultLabel = new ResultLabel(area);
			
		return area;
	}
	
	@Override
	protected Control createContents(Composite parent) {
		Control control = super.createContents(parent);
		updateWidgets();
		return control;
	}
	
	
	private static void configureDialogArea(Composite area) {
		GridLayout gridLayout = (GridLayout) area.getLayout();
		gridLayout.marginRight = 5;
		gridLayout.marginLeft = 5;
		GridData gridData = (GridData) area.getLayoutData();
		gridData.widthHint = 640;
	}
	
	@Override
	protected void createButtonsForButtonBar(Composite parent) {
		createButton(parent, IDialogConstants.PROCEED_ID, "Proceed", true);
		getButton(IDialogConstants.PROCEED_ID).setEnabled(false);
		super.createButtonsForButtonBar(parent);
		getButton(OK).setVisible(false);
		getButton(CANCEL).setText("Close");
		setDialogHelpAvailable(false);
		getButton(IDialogConstants.PROCEED_ID).addMouseListener(new MouseListener() {		
			@Override
			public void mouseUp(MouseEvent e) {
				launchRequest(e);
			}

			@Override
			public void mouseDown(MouseEvent e) {}

			@Override
			public void mouseDoubleClick(MouseEvent e) {}
		});
	}
	
	public void updateWidgets() {
		String type = methodProvider.getAccessMethodType();
		AccessMethod method = methodProvider.getAccessMethod();
		
        // update parameters
		if (method != null) {
			parameterComposite.createParameterList(method);
			getShell().pack(true);
			getShell().setSize(getShell().computeSize(SWT.DEFAULT, SWT.DEFAULT, true));	
		} else {
			parameterComposite.clearContent();
		}
		
		// button value
		if (type != null) {
			getButton(IDialogConstants.PROCEED_ID).setText(type);
		} else {
			getButton(IDialogConstants.PROCEED_ID).setText("Proceed");
		}
		
		// click button 
		if (method != null && type != null) {
			getButton(IDialogConstants.PROCEED_ID).setEnabled(true);
		} else {
			getButton(IDialogConstants.PROCEED_ID).setEnabled(false);
		}
	}

	protected void launchRequest(MouseEvent e) {
		AccessMethodType type = AccessMethodType.get(methodProvider.getAccessMethodType());		
		String message = "";
		switch (type) {
		case GET:
			message = actionPressed();
			break;
		case ACT:
			message = actionPressed();
			break;
		case SUBSCRIBE:
			message = subscribePressed();
			break;
		case UNSUBSCRIBE:
			message = unsubscribePressed();
			break;
		case SET:
			message = actionPressed();
			break;
		default:
			break;
		}
		
		resultLabel.setText(message);		
	}
	
	/**
	 * This method is called when the user selected an ACT/GET/SET access method.
	 * It sends an ACT/GET/SET request to the gateway and get the result of the request
	 * @return the result of the request
	 */
	private String actionPressed() {
		try {
			AccessMethod method = methodProvider.getAccessMethod();
			AccessMethodType type = method.getType();
			Segments segments = new Segments.Builder().resource(descriptor).method(type).build();
			if (type.equals(AccessMethodType.GET)) {
				MsgSensinact msg = GatewayHttpClient.sendGetRequest(segments);
				return msg.getType() + "\n" + msg.toString();
			} else {
				RequestParameter[] params = parameterComposite.getParametersValues(method);
				GatewayHttpClient.sendPostRequest(segments,null, params);
				MsgSensinact msg = GatewayHttpClient.sendPostRequest(segments,null, params);
				return msg.getType() + "\n" + msg.toString();
			}
		} catch (Exception e) {
			logger.error("action failure", e);
			return "[ERROR] " + e.getMessage();
		}
	}
	
	/**
	 * This method is called when the user selected an SUBSCRIBE access method.
	 * It sends a SUBSCRIBE request to the gateway and get the result of the request
	 * @return the result of the request
	 */
	private String subscribePressed() 
	{
		// TODO update this class with implements SubscriptionListener {
		return "Not yet implemented";
	}

	/**
	 * This method is called when the user selected an UNSUBSCRIBE access method.
	 * It sends an UNSUBSCRIBE request to the gateway using the current subscriptionId 
	 * of the resource  passed as parameter
	 * 
	 * @return the result of the request
	 */
	private String unsubscribePressed() 
	{
		// TODO update this class with implements SubscriptionListener {
		return "Not yet implemented";
	}
}