server

Updated according to the latest Action API

Download Browse

+35 −89

Author

Debayan Sutradhar (rnayabed) 2021-05-31 19:40

Committer

Debayan Sutradhar (rnayabed) 2021-05-31 19:40

Hash 6a93a8c496fae3efda8b549fa2374d7c7a4746ca

Parent ba405b488f7871c9824aa07071e756b92fe650fb

Reference git #server/6a93a8c496fae3efda8b549fa2374d7c7a4746ca

Modified Files

List

Side by side diff

Inline diff

M src/main/java/com/stream_pi/server/action/ExternalPlugins.java

+5 −6

Stream-Pi - Free & Open-Source Modular Cross-Platform Programmable Macropad

This program is free software: you can redistribute it and/or modify

it under the terms of the GNU General Public License as published by

the Free Software Foundation, either version 3 of the License, or

(at your option) any later version.

This program is distributed in the hope that it will be useful,

but WITHOUT ANY WARRANTY; without even the implied warranty of

MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

GNU General Public License for more details.

Written by : Debayan Sutradhar (rnayabed)

package com.stream_pi.server.action;

import com.stream_pi.action_api.action.Action;

import com.stream_pi.action_api.action.ActionType;

import com.stream_pi.action_api.action.PropertySaver;

import com.stream_pi.action_api.action.ServerConnection;

import com.stream_pi.action_api.actionproperty.ServerProperties;

import com.stream_pi.action_api.actionproperty.property.Property;

import com.stream_pi.action_api.actionproperty.property.Type;

import com.stream_pi.action_api.externalplugin.ExternalPlugin;

import com.stream_pi.action_api.externalplugin.ToggleAction;

import com.stream_pi.action_api.externalplugin.ToggleExtras;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.exception.SevereException;

import com.stream_pi.util.exception.StreamPiException;

import com.stream_pi.util.version.Version;

import com.stream_pi.util.xmlconfighelper.XMLConfigHelper;

import org.w3c.dom.Document;

import org.w3c.dom.Element;

import org.w3c.dom.Node;

import org.w3c.dom.NodeList;

import javax.xml.parsers.DocumentBuilder;

import javax.xml.parsers.DocumentBuilderFactory;

import javax.xml.transform.Result;

import javax.xml.transform.Source;

import javax.xml.transform.Transformer;

import javax.xml.transform.TransformerFactory;

import javax.xml.transform.dom.DOMSource;

import javax.xml.transform.stream.StreamResult;

import java.io.File;

import java.lang.module.Configuration;

import java.lang.module.ModuleDescriptor;

import java.lang.module.ModuleFinder;

import java.lang.module.ModuleReference;

import java.nio.file.Path;

import java.nio.file.Paths;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.ServiceLoader;

import java.util.logging.Level;

import java.util.logging.Logger;

import java.util.stream.Collectors;

public class ExternalPlugins

{

private static ExternalPlugins instance = null;

private final Logger logger;

private File configFile;

private Document document;

private static String pluginsLocation = null;

/**

* Singleton class instance getter. Creates new one, when asked for the first time

* @return returns instance of NormalActionPlugins (one and only, always)

public static synchronized ExternalPlugins getInstance()

{

if(instance == null)

{

instance = new ExternalPlugins();

}

return instance;

}

/**

* Sets the folder location where the plugin JARs and their dependencies are stored

* @param location Folder location

public static void setPluginsLocation(String location)

{

pluginsLocation = location;

}

/**

* Private constructor

private ExternalPlugins()

{

logger = Logger.getLogger(ExternalPlugins.class.getName());

externalPluginsHashmap = new HashMap<>();

}

/**

* init Method

public void init() throws SevereException, MinorException

{

registerPlugins();

initPlugins();

}

/**

* Used to fetch list of all external Plugins

* @return List of plugins

public List<ExternalPlugin> getPlugins()

{

return externalPlugins;

}

/**

* Returns a plugin by its module name

* @param name Module Name

* @return The plugin. If not found, then null is returned

public ExternalPlugin getPluginByModuleName(String name)

{

logger.info("Plugin being requested : "+name);

Integer index = externalPluginsHashmap.getOrDefault(name, -1);

if(index != -1)

{

return externalPlugins.get(index);

}

return null;

}

private List<ExternalPlugin> externalPlugins = null;

HashMap<String, Integer> externalPluginsHashmap;

/**

* Used to register plugins from plugin location

public void registerPlugins() throws SevereException, MinorException

{

logger.info("Registering external plugins from "+pluginsLocation+" ...");

try

{

configFile = new File(pluginsLocation+"/config.xml");

DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance();

DocumentBuilder docBuilder = docFactory.newDocumentBuilder();

document = docBuilder.parse(configFile);

}

catch (Exception e)

{

e.printStackTrace();

throw new SevereException("Plugins","Error reading plugins config.xml. Cannot continue.");

}

ArrayList<ExternalPlugin> errorModules = new ArrayList<>();

ArrayList<String> errorModuleError = new ArrayList<>();

ArrayList<Action> pluginsConfigs = new ArrayList<>();

NodeList actionsNode = document.getElementsByTagName("actions").item(0).getChildNodes();

for(int i=0; i<actionsNode.getLength(); i++)

{

Node eachActionNode = actionsNode.item(i);

if(eachActionNode.getNodeType() != Node.ELEMENT_NODE ||

!eachActionNode.getNodeName().equals("action"))

continue;

Element eachActionElement = (Element) eachActionNode;

String name;

Version version;

ActionType actionType;

try

{

name = XMLConfigHelper.getStringProperty(eachActionElement, "module-name");

actionType = ActionType.valueOf(XMLConfigHelper.getStringProperty(eachActionElement, "type"));

version = new Version(XMLConfigHelper.getStringProperty(eachActionElement, "version"));

}

catch (Exception e)

{

logger.log(Level.WARNING, "Skipping configuration because invalid ...");

e.printStackTrace();

continue;

}

ServerProperties serverProperties = new ServerProperties();

NodeList serverPropertiesNodeList = eachActionElement.getElementsByTagName("properties").item(0).getChildNodes();

for(int j = 0;j<serverPropertiesNodeList.getLength();j++)

{

Node eachPropertyNode = serverPropertiesNodeList.item(j);

if(eachPropertyNode.getNodeType() != Node.ELEMENT_NODE)

continue;

if(!eachPropertyNode.getNodeName().equals("property"))

continue;

Element eachPropertyElement = (Element) eachPropertyNode;

try

{

Property property = new Property(XMLConfigHelper.getStringProperty(eachPropertyElement, "name"), Type.STRING);

property.setRawValue(XMLConfigHelper.getStringProperty(eachPropertyElement, "value"));

serverProperties.addProperty(property);

}

catch (Exception e)

{

logger.log(Level.WARNING, "Skipping property because invalid ...");

e.printStackTrace();

}

Action action = new Action(actionType);

action.setModuleName(name);

action.setVersion(version);

action.getServerProperties().set(serverProperties);

pluginsConfigs.add(action);

}

logger.info("Size : "+pluginsConfigs.size());

Path pluginsDir = Paths.get(pluginsLocation); // Directory with plugins JARs

try

{

// Search for plugins in the plugins directory

ModuleFinder pluginsFinder = ModuleFinder.of(pluginsDir);

// Find all names of all found plugin modules

List<String> p = pluginsFinder

.findAll()

.stream()

.map(ModuleReference::descriptor)

.map(ModuleDescriptor::name)

.collect(Collectors.toList());

// Create configuration that will resolve plugin modules

// (verify that the graph of modules is correct)

Configuration pluginsConfiguration = ModuleLayer

.boot()

.configuration()

.resolve(pluginsFinder, ModuleFinder.of(), p);

// Create a module layer for plugins

ModuleLayer layer = ModuleLayer

.boot()

.defineModulesWithOneLoader(pluginsConfiguration, ClassLoader.getSystemClassLoader());

logger.info("Loading plugins from jar ...");

// Now you can use the new module layer to find service implementations in it

externalPlugins = ServiceLoader

.load(layer, ExternalPlugin.class).stream()

.map(ServiceLoader.Provider::get)

.collect(Collectors.toList());

logger.info("...Done!");

}

catch (Exception e)

{

e.printStackTrace();

throw new MinorException("Error", "Error loading modules\n"+e.getMessage()+"\nPlease fix the errors. Other plugins wont be loaded.");

}

sortedPlugins = new HashMap<>();

for (ExternalPlugin eachPlugin : externalPlugins)

{

try

{

eachPlugin.setPropertySaver(getPropertySaver());

eachPlugin.setServerConnection(serverConnection);

if(eachPlugin instanceof ToggleAction)

((ToggleAction) eachPlugin).setToggleExtras(getToggleExtras());

eachPlugin.initProperties();

logger.info("MODULE : "+eachPlugin.getModuleName());

Action foundAction = null;

for (Action action : pluginsConfigs)

{

if (action.getModuleName().equals(eachPlugin.getModuleName())

&& action.getVersion().isEqual(eachPlugin.getVersion()))

{

foundAction = action;

List<Property> eachPluginStoredProperties = action.getServerProperties().get();

List<Property> eachPluginCodeProperties = eachPlugin.getServerProperties().get();

for (int i =0;i< eachPluginCodeProperties.size(); i++)

{

Property eachPluginCodeProperty = eachPluginCodeProperties.get(i);

Property foundProp = null;

for (Property eachPluginStoredProperty : eachPluginStoredProperties) {

if (eachPluginCodeProperty.getName().equals(eachPluginStoredProperty.getName())) {

eachPluginCodeProperty.setRawValue(eachPluginStoredProperty.getRawValue());

foundProp = eachPluginStoredProperty;

}

eachPluginCodeProperties.set(i, eachPluginCodeProperty);

if (foundProp != null) {

eachPluginStoredProperties.remove(foundProp);

}

eachPlugin.getServerProperties().set(eachPluginCodeProperties);

break;

}

if (foundAction != null)

pluginsConfigs.remove(foundAction);

else

{

List<Property> eachPluginStoredProperties = eachPlugin.getServerProperties().get();

for(Property property :eachPluginStoredProperties)

{

if(property.getType() == Type.STRING || property.getType() == Type.INTEGER || property.getType() == Type.DOUBLE)

property.setRawValue(property.getDefaultRawValue());

}

if (!sortedPlugins.containsKey(eachPlugin.getCategory())) {

sortedPlugins.put(eachPlugin.getCategory(), new ArrayList<>());

}

sortedPlugins.get(eachPlugin.getCategory()).add(eachPlugin);

}

catch (Exception e)

catch (MinorException e)

{

e.printStackTrace();

errorModules.add(eachPlugin);

errorModuleError.add(e.getMessage());

errorModuleError.add(e.getShortMessage());

}

try {

saveServerSettings();

} catch (MinorException e) {

e.printStackTrace();

}

logger.log(Level.INFO, "All plugins registered!");

if(errorModules.size() > 0)

{

StringBuilder errors = new StringBuilder("The following action modules could not be loaded:");

for(int i = 0; i<errorModules.size(); i++)

{

externalPlugins.remove(errorModules.get(i));

errors.append("\n * ").append(errorModules.get(i).getModuleName()).append("\n(")

.append(errorModuleError.get(i)).append(")");

}

throw new MinorException("Plugins", errors.toString());

}

for(int i=0; i<externalPlugins.size(); i++)

{

externalPluginsHashmap.put(externalPlugins.get(i).getModuleName(), i);

}

/**

* Used to init plugins

public void initPlugins() throws MinorException

{

StringBuilder errors = new StringBuilder("There were errors registering the following plugins. As a result, they have been omitted : ");

boolean isError = false;

for(ExternalPlugin eachPlugin : externalPlugins)

{

try

{

eachPlugin.initAction();

}

catch (Exception e)

catch (MinorException e)

{

e.printStackTrace();

isError = true;

errors.append("\n* ")

.append(eachPlugin.getName())

.append(" - ")

.append(eachPlugin.getModuleName())

.append("\n");

if(e instanceof StreamPiException)

errors.append(e.getShortMessage());

errors.append(((MinorException) e).getShortMessage());

errors.append("\n");

}

if(isError)

{

throw new MinorException("Plugin init error", errors.toString());

}

HashMap<String, ArrayList<ExternalPlugin>> sortedPlugins;

/**

* Gets list of sorted plugins

* @return Hashmap with category key, and list of plugins of each category

public HashMap<String, ArrayList<ExternalPlugin>> getSortedPlugins()

{

return sortedPlugins;

}

/**

* @return Gets actions element from the config.xml in plugins folder

private Element getActionsElement()

{

return (Element) document.getElementsByTagName("actions").item(0);

}

/**

* Saves ServerProperties of every plugin in config.xml in plugins folder

* @throws MinorException Thrown when failed to save settings

public void saveServerSettings() throws MinorException

{

XMLConfigHelper.removeChilds(getActionsElement());

for(ExternalPlugin externalPlugin : externalPlugins)

{

Element actionElement = document.createElement("action");

getActionsElement().appendChild(actionElement);

Element moduleNameElement = document.createElement("module-name");

moduleNameElement.setTextContent(externalPlugin.getModuleName());

actionElement.appendChild(moduleNameElement);

Element versionElement = document.createElement("version");

versionElement.setTextContent(externalPlugin.getVersion().getText());

actionElement.appendChild(versionElement);

Element actionTypeElement = document.createElement("type");

actionTypeElement.setTextContent(externalPlugin.getActionType().toString());

actionElement.appendChild(actionTypeElement);

Element propertiesElement = document.createElement("properties");

actionElement.appendChild(propertiesElement);

for(String key : externalPlugin.getServerProperties().getNames())

{

for(Property eachProperty : externalPlugin.getServerProperties().getMultipleProperties(key))

{

Element propertyElement = document.createElement("property");

propertiesElement.appendChild(propertyElement);

Element nameElement = document.createElement("name");

nameElement.setTextContent(eachProperty.getName());

propertyElement.appendChild(nameElement);

Element valueElement = document.createElement("value");

valueElement.setTextContent(eachProperty.getRawValue());

propertyElement.appendChild(valueElement);

}

save();

}

private PropertySaver propertySaver = null;

/**

* Set PropertySaver class

* @param propertySaver instance of PropertySaver

public void setPropertySaver(PropertySaver propertySaver)

{

this.propertySaver = propertySaver;

}

public PropertySaver getPropertySaver()

{

return propertySaver;

}

private ToggleExtras toggleExtras = null;

/**

* Set PropertySaver class

* @param toggleExtras instance of PropertySaver

public void setToggleExtras(ToggleExtras toggleExtras)

{

this.toggleExtras = toggleExtras;

}

public ToggleExtras getToggleExtras() {

return toggleExtras;

}

private ServerConnection serverConnection = null;

/**

* Set setServerConnection class

* @param serverConnection instance of ServerConnection

public void setServerConnection(ServerConnection serverConnection)

{

this.serverConnection = serverConnection;

}

/**

* Get plugin from index from list

* @param index of plugin

* @return found plugin

public ExternalPlugin getActionFromIndex(int index)

{

return externalPlugins.get(index);

}

/**

* Calls onShutDown method in every plugin

public void shutDownActions()

{

if(externalPlugins != null)

{

for(ExternalPlugin eachPlugin : externalPlugins)

{

try

{

eachPlugin.onShutDown();

}

catch (Exception e)

catch (MinorException e)

{

e.printStackTrace();

}

externalPlugins.clear();

}

/**

* Saves all Server Properties of each Plugin in config.xml in Plugins folder

* @throws MinorException thrown when failed to save

public void save() throws MinorException

{

try

{

Transformer transformer = TransformerFactory.newInstance().newTransformer();

Result output = new StreamResult(configFile);

Source input = new DOMSource(document);

transformer.transform(input, output);

}

catch (Exception e)

{

throw new MinorException("Config", "unable to save server plugins settings");

}

M src/main/java/com/stream_pi/server/connection/ClientConnection.java

+8 −14

package com.stream_pi.server.connection;

import com.stream_pi.action_api.action.Action;

import com.stream_pi.action_api.action.ActionType;

import com.stream_pi.action_api.action.DisplayTextAlignment;

import com.stream_pi.action_api.action.Location;

import com.stream_pi.action_api.actionproperty.ClientProperties;

import com.stream_pi.action_api.actionproperty.property.Property;

import com.stream_pi.action_api.actionproperty.property.Type;

import com.stream_pi.action_api.externalplugin.ExternalPlugin;

import com.stream_pi.action_api.externalplugin.NormalAction;

import com.stream_pi.action_api.externalplugin.ToggleAction;

import com.stream_pi.action_api.otheractions.CombineAction;

import com.stream_pi.action_api.otheractions.FolderAction;

import com.stream_pi.server.action.ExternalPlugins;

import com.stream_pi.server.client.Client;

import com.stream_pi.server.client.ClientProfile;

import com.stream_pi.server.client.ClientTheme;

import com.stream_pi.server.info.ServerInfo;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

import com.stream_pi.server.window.dashboard.actiongridpane.ActionBox;

import com.stream_pi.util.alert.StreamPiAlert;

import com.stream_pi.util.alert.StreamPiAlertType;

import com.stream_pi.util.comms.Message;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.exception.SevereException;

import com.stream_pi.util.exception.StreamPiException;

import com.stream_pi.util.platform.Platform;

import com.stream_pi.util.platform.ReleaseStatus;

import com.stream_pi.util.version.Version;

import javafx.concurrent.Task;

import java.io.*;

import java.net.Socket;

import java.net.SocketAddress;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.concurrent.atomic.AtomicBoolean;

import java.util.logging.Level;

import java.util.logging.Logger;

public class ClientConnection extends Thread

{

private Socket socket;

private ServerListener serverListener;

private AtomicBoolean stop = new AtomicBoolean(false);

private ObjectOutputStream oos;

private ObjectInputStream ois;

private Logger logger;

private Client client = null;

private ExceptionAndAlertHandler exceptionAndAlertHandler;

public ClientConnection(Socket socket, ServerListener serverListener, ExceptionAndAlertHandler exceptionAndAlertHandler)

{

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

this.socket = socket;

this.serverListener = serverListener;

logger = Logger.getLogger(ClientConnection.class.getName());

try

{

oos = new ObjectOutputStream(socket.getOutputStream());

ois = new ObjectInputStream(socket.getInputStream());

} catch (IOException e) {

e.printStackTrace();

exceptionAndAlertHandler.handleMinorException(new MinorException("Unable to start socket streams"));

}

start();

}

public synchronized void exit()

{

if(stop.get())

return;

logger.info("Stopping ...");

try

{

if(socket !=null)

{

logger.info("Stopping connection "+getRemoteSocketAddress());

disconnect();

}

catch (SevereException e)

{

e.printStackTrace();

exceptionAndAlertHandler.handleSevereException(e);

}

public SocketAddress getRemoteSocketAddress()

{

return socket.getRemoteSocketAddress();

}

public synchronized void exitAndRemove()

{

exit();

callOnClientDisconnectOnAllActions();

removeConnection();

serverListener.clearTemp();

}

public void callOnClientDisconnectOnAllActions()

{

for(ClientProfile profile : getClient().getAllClientProfiles())

{

for (String actionID : profile.getActionsKeySet())

{

Action action = profile.getActionByID(actionID);

if(action instanceof ExternalPlugin)

{

try

{

((ExternalPlugin) action).onClientDisconnected();

}

catch (Exception e)

catch (MinorException e)

{

e.printStackTrace();

e.setTitle("Unable to run onClientDisconnected for "+action.getModuleName());

e.setShortMessage("Detailed message :\n\n"+e.getShortMessage());

exceptionAndAlertHandler.handleMinorException(

exceptionAndAlertHandler.handleMinorException(e);

new MinorException(

"Unable to run onClientDisconnected for "+action.getModuleName(),

"Detailed message : "+e.getMessage()

)

);

}

public void removeConnection()

{

ClientConnections.getInstance().removeConnection(this);

}

public Logger getLogger()

{

return logger;

}

public void sendIcon(String profileID, String actionID, String state, byte[] icon) throws SevereException

{

getLogger().info("Sending icon "+state+" len "+icon.length+"; profile:"+profileID+"; actionid:"+actionID+"\n\n\n\n");

try

{

Thread.sleep(50);

}

catch (InterruptedException e)

{

e.printStackTrace();

}

Message message = new Message("action_icon");

message.setStringArrValue(profileID, actionID, state);

message.setByteArrValue(icon);

sendMessage(message);

}

public void initAfterConnectionQueryReceive(Message message) throws StreamPiException

{

String[] ar = message.getStringArrValue();

logger.info("Setting up client object ...");

Version clientVersion;

Version commsStandard;

Version themesStandard;

ReleaseStatus releaseStatus;

try

{

clientVersion = new Version(ar[0]);

releaseStatus = ReleaseStatus.valueOf(ar[1]);

commsStandard = new Version(ar[2]);

themesStandard = new Version(ar[3]);

}

catch (MinorException e)

{

exitAndRemove();

throw new MinorException(e.getShortMessage()+" (client '"+socket.getRemoteSocketAddress()+"' )");

}

if(!commsStandard.isEqual(ServerInfo.getInstance().getCommStandardVersion()))

{

String errTxt = "Server and client Communication standards do not match. Make sure you are on the latest version of server and client.\n" +

"Server Comms. Standard : "+ServerInfo.getInstance().getCommStandardVersion().getText()+

"\nclient Comms. Standard : "+commsStandard.getText();

disconnect(errTxt);

throw new MinorException(errTxt);

}

client = new Client(clientVersion, releaseStatus, commsStandard, themesStandard, ar[4], Platform.valueOf(ar[7]), socket.getRemoteSocketAddress());

client.setDisplayWidth(Double.parseDouble(ar[5]));

client.setDisplayHeight(Double.parseDouble(ar[6]));

client.setDefaultProfileID(ar[8]);

client.setDefaultThemeFullName(ar[9]);

//call get profiles command.

serverListener.clearTemp();

}

public void updateClientDetails(Message message)

{

String[] ar = message.getStringArrValue();

logger.info("Setting up client object ...");

client.setNickName(ar[4]);

client.setDisplayWidth(Double.parseDouble(ar[5]));

client.setDisplayHeight(Double.parseDouble(ar[6]));

client.setDefaultProfileID(ar[8]);

client.setDefaultThemeFullName(ar[9]);

serverListener.getSettingsBase().getClientsSettings().loadData();

}

public synchronized Client getClient()

{

return client;

}

@Override

public void run() {

try {

initAfterConnectionQuerySend();

} catch (SevereException e) {

e.printStackTrace();

exceptionAndAlertHandler.handleSevereException(e);

exitAndRemove();

return;

}

try

{

while(!stop.get())

{

try

{

Message message = (Message) ois.readObject();

String header = message.getHeader();

switch (header)

{

case "action_icon" : onActionIconReceived(message);

break;

case "disconnect" : clientDisconnected(message);

break;

case "register_client_details" : initAfterConnectionQueryReceive(message);

getProfilesFromClient();

getThemesFromClient();

break;

case "update_client_details" : updateClientDetails(message);

break;

case "client_screen_details" : onClientScreenDetailsReceived(message);

break;

case "profiles" : registerProfilesFromClient(message);

break;

case "profile_details" : registerProfileDetailsFromClient(message);

break;

case "action_details" : registerActionToProfile(message);

break;

case "themes": registerThemes(message);

break;

case "action_clicked": onActionClicked(message);

break;

default: logger.warning("Command '"+header+"' does not match records. Make sure client and server versions are equal.");

}

catch (IOException | ClassNotFoundException e)

{

logger.log(Level.SEVERE, e.getMessage());

e.printStackTrace();

serverListener.clearTemp();

if(!stop.get())

{

removeConnection();

throw new MinorException("Accidentally disconnected from "+getClient().getNickName()+".");

}

exitAndRemove();

return;

}

catch (StreamPiException e)

{

e.printStackTrace();

if(e instanceof MinorException)

exceptionAndAlertHandler.handleMinorException((MinorException) e);

else if (e instanceof SevereException)

exceptionAndAlertHandler.handleSevereException((SevereException) e);

}

// commands

private void onActionIconReceived(Message message) throws MinorException

{

String[] s = message.getStringArrValue();

String profileID = s[0];

String actionID = s[1];

String iconState = s[2];

getClient()

.getProfileByID(profileID)

.getActionByID(actionID)

.addIcon(iconState,message.getByteArrValue());

}

public void initAfterConnectionQuerySend() throws SevereException

{

logger.info("Asking client details ...");

sendMessage(new Message("get_client_details"));

}

public void disconnect() throws SevereException {

disconnect("");

}

public void disconnect(String message) throws SevereException {

if(stop.get())

return;

stop.set(true);

logger.info("Sending client disconnect message ...");

Message m = new Message("disconnect");

m.setStringValue(message);

sendMessage(m);

try

{

if(!socket.isClosed())

socket.close();

}

catch (IOException e)

{

e.printStackTrace();

throw new SevereException("Unable to close socket");

}

public synchronized void sendMessage(Message message) throws SevereException

{

try

{

logger.info("Sending message with heading "+message.getHeader()+" ...");

oos.writeObject(message);

oos.flush();

logger.info("... Done!");

}

catch (IOException e)

{

e.printStackTrace();

throw new SevereException("Unable to write to io Stream!");

}

public void clientDisconnected(Message message)

{

stop.set(true);

String txt = "Disconnected!";

String msg = message.getStringValue();

if(!msg.isBlank())

txt = "Message : "+msg;

new StreamPiAlert("Disconnected from "+getClient().getNickName()+".", txt, StreamPiAlertType.WARNING).show();;

exitAndRemove();

}

public void getProfilesFromClient() throws StreamPiException

{

logger.info("Asking client to send profiles ...");

sendMessage(new Message("get_profiles"));

}

public void getThemesFromClient() throws StreamPiException

{

logger.info("Asking clients to send themes ...");

sendMessage(new Message("get_themes"));

}

public void registerThemes(Message message)

{

String[] r = message.getStringArrValue();

for(int i =0; i<(r.length);i+=4)

{

ClientTheme clientTheme = new ClientTheme(

r[i],

r[i+1],

r[i+2],

r[i+3]

);

try

{

getClient().addTheme(clientTheme);

}

catch (CloneNotSupportedException e)

{

logger.log(Level.SEVERE, e.getMessage());

e.printStackTrace();

}

private HashMap<String, Integer> temporaryProfilesCheck = null;

public void registerProfilesFromClient(Message message) throws StreamPiException

{

logger.info("Registering profiles ...");

String[] profileIds = message.getStringArrValue();

int[] profilesActionIds = message.getIntArrValue();

temporaryProfilesCheck = new HashMap<>();

for (int i = 0;i<profileIds.length;i++)

{

temporaryProfilesCheck.put(profileIds[i], profilesActionIds[i]);

getProfileDetailsFromClient(profileIds[i]);

}

public void getProfileDetailsFromClient(String ID) throws StreamPiException

{

logger.info("Asking client to send details of profile : "+ID);

Message message = new Message("get_profile_details");

message.setStringValue(ID);

sendMessage(message);

}

public void registerProfileDetailsFromClient(Message message)

{

String[] r = message.getStringArrValue();

String ID = r[0];

logger.info("Registering details for profile : "+ID);

String name = r[1];

int rows = Integer.parseInt(r[2]);

int cols = Integer.parseInt(r[3]);

int actionSize = Integer.parseInt(r[4]);

int actionGap = Integer.parseInt(r[5]);

ClientProfile clientProfile = new ClientProfile(name, ID, rows, cols, actionSize, actionGap);

logger.info("Added client profile "+clientProfile.getName());

try

{

getClient().addProfile(clientProfile);

}

catch (CloneNotSupportedException e)

{

logger.severe(e.getMessage());

e.printStackTrace();

}

serverListener.clearTemp();

}

public synchronized void registerActionToProfile(Message message) throws StreamPiException

{

String[] r = message.getStringArrValue();

String profileID = r[0];

String ID = r[1];

ActionType actionType = ActionType.valueOf(r[2]);

//3 - Version

//4 - ModuleName

//display

String bgColorHex = r[5];

//icon

String[] allIconStateNames = r[6].split("::");

String defaultIconState = r[7];

//text

boolean isShowDisplayText = r[8].equals("true");

String displayFontColor = r[9];

String displayText = r[10];

DisplayTextAlignment displayTextAlignment = DisplayTextAlignment.valueOf(r[11]);

//location

String row = r[12];

String col = r[13];

Location location = new Location(Integer.parseInt(row), Integer.parseInt(col));

String root = r[14];

int delayBeforeRunning = Integer.parseInt(r[15]);

//client properties

int clientPropertiesSize = Integer.parseInt(r[16]);

ClientProperties clientProperties = new ClientProperties();

if(actionType == ActionType.FOLDER)

clientProperties.setDuplicatePropertyAllowed(true);

for(int i = 17;i<((clientPropertiesSize*2) + 17); i+=2)

{

Property property = new Property(r[i], Type.STRING);

property.setRawValue(r[i+1]);

clientProperties.addProperty(property);

}

//set up action

temporaryProfilesCheck.replace(

profileID,

(temporaryProfilesCheck.get(profileID) - 1)

);

if(temporaryProfilesCheck.get(profileID) == 0)

{

temporaryProfilesCheck.remove(profileID);

}

//action toBeAdded = null;

boolean isInvalidAction = false;

if(actionType == ActionType.NORMAL || actionType == ActionType.TOGGLE)

{

String moduleName = r[4];

Version version = new Version(r[3]);

ExternalPlugin originalAction = ExternalPlugins.getInstance().getPluginByModuleName(moduleName);

if(originalAction == null)

{

isInvalidAction = true;

}

else

{

if(originalAction.getVersion().getMajor() != version.getMajor())

{

isInvalidAction = true;

}

else

{

try

{

ExternalPlugin newPlugin = originalAction.clone();

newPlugin.setID(ID);

System.out.println("SAVVEEEEEEEEEEEEEEE@@@@@ : "+profileID);

newPlugin.setProfileID(profileID);

newPlugin.setSocketAddressForClient(socket.getRemoteSocketAddress());

newPlugin.setBgColourHex(bgColorHex);

newPlugin.setCurrentIconState(defaultIconState);

newPlugin.setShowDisplayText(isShowDisplayText);

newPlugin.setDisplayTextFontColourHex(displayFontColor);

newPlugin.setDisplayText(displayText);

newPlugin.setDisplayTextAlignment(displayTextAlignment);

newPlugin.setLocation(location);

newPlugin.setParent(root);

newPlugin.setDelayBeforeExecuting(delayBeforeRunning);

ClientProperties finalClientProperties = new ClientProperties();

for(Property property : originalAction.getClientProperties().get())

{

for(int i = 0;i<clientProperties.getSize();i++)

{

Property property1 = clientProperties.get().get(i);

if (property.getName().equals(property1.getName()))

{

property.setRawValue(property1.getRawValue());

finalClientProperties.addProperty(property);

}

newPlugin.setClientProperties(finalClientProperties);

getClient().getProfileByID(profileID).addAction(newPlugin);

new Thread(new Task<Void>() {

@Override

protected Void call()

{

try

{

newPlugin.onClientConnected();

}

catch (Exception e)

catch (MinorException e)

{

e.printStackTrace();

e.setTitle("Unable to run onClientConnected for "+moduleName);

exceptionAndAlertHandler.handleMinorException(

e.setShortMessage("Detailed message :\n\n"+e.getShortMessage());

new MinorException("Failed","Error "+moduleName+" at onClientConnected \nMessage"+e.getMessage())

exceptionAndAlertHandler.handleMinorException(e);

);

}

return null;

}

}).start();

}

catch (CloneNotSupportedException e)

{

exceptionAndAlertHandler.handleMinorException(new MinorException("action", "Unable to clone"));

}

checkIfReady();

return;

}

Action action = null;

if(isInvalidAction)

{

String moduleName = r[4];

Version version = new Version(r[3]);

action = new Action();

action.setInvalid(true);

action.setVersion(version);

action.setModuleName(moduleName);

}

else

{

if(actionType == ActionType.COMBINE)

{

action = new CombineAction();

}

else if(actionType == ActionType.FOLDER)

{

action = new FolderAction();

}

action.setID(ID);

action.setProfileID(profileID);

action.setSocketAddressForClient(socket.getRemoteSocketAddress());

action.setBgColourHex(bgColorHex);

action.setCurrentIconState(defaultIconState);

action.setShowDisplayText(isShowDisplayText);

action.setDisplayTextFontColourHex(displayFontColor);

action.setDisplayText(displayText);

action.setDisplayTextAlignment(displayTextAlignment);

action.setLocation(location);

action.setParent(root);

action.setClientProperties(clientProperties);

try

{

getClient().getProfileByID(profileID).addAction(action);

}

catch (CloneNotSupportedException e)

{

e.printStackTrace();

exceptionAndAlertHandler.handleMinorException(new MinorException("action", "Unable to clone"));

}

checkIfReady();

}

public void checkIfReady() throws SevereException

{

if(temporaryProfilesCheck.size() == 0)

{

getLogger().info("PASSS");

temporaryProfilesCheck = null;

sendMessage(new Message("ready"));

}

else

{

getLogger().info("FAIL");

}

public synchronized void saveActionDetails(String profileID, Action action) throws SevereException

{

ArrayList<String> a = new ArrayList<>();

a.add(profileID);

a.add(action.getID());

a.add(action.getActionType()+"");

if(action.getActionType() == ActionType.NORMAL || action.getActionType() == ActionType.TOGGLE)

{

a.add(action.getVersion().getText());

System.out.println("VERSION :sdd "+action.getVersion().getText());

}

else

{

a.add("no");

}

if(action.getActionType() == ActionType.NORMAL || action.getActionType() == ActionType.TOGGLE)

{

a.add(action.getModuleName());

}

else

{

a.add("nut");

}

//display

a.add(action.getBgColourHex());

//icon

StringBuilder allIconStatesNames = new StringBuilder();

for(String eachState : action.getIcons().keySet())

{

allIconStatesNames.append(eachState).append("::");

}

a.add(allIconStatesNames.toString());

a.add(action.getCurrentIconState());

//text

a.add(action.isShowDisplayText()+"");

a.add(action.getDisplayTextFontColourHex());

a.add(action.getDisplayText());

a.add(action.getDisplayTextAlignment()+"");

//location

if(action.getLocation() == null)

{

a.add("-1");

}

else

{

a.add(action.getLocation().getRow()+"");

a.add(action.getLocation().getCol()+"");

}

a.add(action.getParent());

a.add(action.getDelayBeforeExecuting()+"");

//client properties

ClientProperties clientProperties = action.getClientProperties();

a.add(clientProperties.getSize()+"");

for(Property property : clientProperties.get())

{

a.add(property.getName());

a.add(property.getRawValue());

}

Message message = new Message("save_action_details");

String[] x = new String[a.size()];

x = a.toArray(x);

message.setStringArrValue(x);

sendMessage(message);

}

public void getClientScreenDetails() throws SevereException

{

Message message = new Message("get_client_screen_details");

sendMessage(message);

}

public void onClientScreenDetailsReceived(Message message)

{

getClient().setDisplayWidth(message.getDoubleArrValue()[0]);

getClient().setDisplayHeight(message.getDoubleArrValue()[1]);

}

public void deleteAction(String profileID, String actionID) throws SevereException

{

Message message = new Message("delete_action");

message.setStringArrValue(profileID, actionID);

sendMessage(message);

}

public void saveClientDetails(String clientNickname, String defaultProfileID,

String defaultThemeFullName) throws SevereException

{

Message message = new Message("save_client_details");

message.setStringArrValue(

clientNickname,

defaultProfileID,

defaultThemeFullName

);

sendMessage(message);

client.setNickName(clientNickname);

client.setDefaultProfileID(defaultProfileID);

client.setDefaultThemeFullName(defaultThemeFullName);

}

public void saveProfileDetails(ClientProfile clientProfile) throws SevereException, CloneNotSupportedException {

if(client.getProfileByID(clientProfile.getID()) !=null)

{

client.getProfileByID(clientProfile.getID()).setName(clientProfile.getName());

client.getProfileByID(clientProfile.getID()).setRows(clientProfile.getRows());

client.getProfileByID(clientProfile.getID()).setCols(clientProfile.getCols());

client.getProfileByID(clientProfile.getID()).setActionSize(clientProfile.getActionSize());

client.getProfileByID(clientProfile.getID()).setActionGap(clientProfile.getActionGap());

}

else

client.addProfile(clientProfile);

Message message = new Message("save_client_profile");

message.setStringArrValue(

clientProfile.getID(),

clientProfile.getName(),

clientProfile.getRows()+"",

clientProfile.getCols()+"",

clientProfile.getActionSize()+"",

clientProfile.getActionGap()+""

);

sendMessage(message);

}

public void deleteProfile(String ID) throws SevereException

{

Message message = new Message("delete_profile");

message.setStringValue(ID);

sendMessage(message);

}

public void onActionClicked(Message message)

{

try

{

String[] r = message.getStringArrValue();

String profileID = r[0];

String actionID = r[1];

boolean toggle = r[2].equals("true");

Action action = client.getProfileByID(profileID).getActionByID(actionID);

if(action.getActionType() == ActionType.NORMAL || action.getActionType() == ActionType.TOGGLE)

{

if(action.isInvalid())

{

throw new MinorException(

"The action isn't installed on the server."

);

}

else

{

if(action instanceof ToggleAction)

{

new Thread(new Task<Void>() {

@Override

protected Void call()

{

try

{

boolean result = serverListener.onToggleActionClicked((ToggleAction) action, toggle, profileID);

if(!result)

{

sendActionFailed(profileID, actionID);

}

catch (SevereException e)

{

exceptionAndAlertHandler.handleSevereException(e);

}

catch (Exception e)

{

e.printStackTrace();

}

return null;

}

}).start();

}

else if(action instanceof NormalAction)

{

new Thread(new Task<Void>() {

@Override

protected Void call()

{

try

{

boolean result = serverListener.onNormalActionClicked((NormalAction) action, profileID);

if(!result)

{

sendActionFailed(profileID, actionID);

}

catch (SevereException e)

{

exceptionAndAlertHandler.handleSevereException(e);

}

catch (Exception e)

{

e.printStackTrace();

}

return null;

}

}).start();

}

} catch (Exception e) {

e.printStackTrace();

exceptionAndAlertHandler.handleMinorException(new MinorException(e.getMessage()));

}

public void setToggleStatus(boolean status, String profileID, String actionID) throws SevereException

{

Message message = new Message("set_toggle_status");

message.setStringArrValue(profileID, actionID, status+"");

sendMessage(message);

}

public void sendActionFailed(String profileID, String actionID) throws SevereException {

logger.info("Sending failed status ...");

Message message = new Message("action_failed");

message.setStringArrValue(profileID, actionID);

sendMessage(message);

}

M src/main/java/com/stream_pi/server/controller/Controller.java

+10 −54

package com.stream_pi.server.controller;

import com.stream_pi.action_api.action.Action;

import com.stream_pi.action_api.action.PropertySaver;

import com.stream_pi.action_api.action.ServerConnection;

import com.stream_pi.action_api.externalplugin.NormalAction;

import com.stream_pi.action_api.externalplugin.ToggleAction;

import com.stream_pi.action_api.externalplugin.ToggleExtras;

import com.stream_pi.server.Main;

import com.stream_pi.server.action.ExternalPlugins;

import com.stream_pi.server.client.Client;

import com.stream_pi.server.client.ClientProfile;

import com.stream_pi.server.connection.ClientConnection;

import com.stream_pi.server.connection.ClientConnections;

import com.stream_pi.server.connection.MainServer;

import com.stream_pi.server.info.ServerInfo;

import com.stream_pi.server.io.Config;

import com.stream_pi.server.window.Base;

import com.stream_pi.server.window.dashboard.DashboardBase;

import com.stream_pi.server.window.dashboard.DonatePopupContent;

import com.stream_pi.server.window.dashboard.actiongridpane.ActionBox;

import com.stream_pi.server.window.firsttimeuse.FirstTimeUse;

import com.stream_pi.server.window.settings.SettingsBase;

import com.stream_pi.util.alert.StreamPiAlert;

import com.stream_pi.util.alert.StreamPiAlertListener;

import com.stream_pi.util.alert.StreamPiAlertType;

import com.stream_pi.util.exception.*;

import javafx.animation.Animation;

import javafx.animation.Interpolator;

import javafx.animation.KeyFrame;

import javafx.animation.KeyValue;

import javafx.animation.Timeline;

import javafx.application.Platform;

import javafx.concurrent.Task;

import javafx.scene.Node;

import javafx.scene.Scene;

import javafx.scene.image.Image;

import javafx.stage.Modality;

import javafx.stage.Stage;

import javafx.stage.WindowEvent;

import javafx.util.Duration;

import java.awt.MenuItem;

import java.awt.PopupMenu;

import java.awt.SystemTray;

import java.awt.Toolkit;

import java.awt.TrayIcon;

import java.net.SocketAddress;

import java.util.Objects;

import java.util.Random;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.logging.Level;

public class Controller extends Base implements PropertySaver, ServerConnection, ToggleExtras

{

private ExecutorService executor = Executors.newCachedThreadPool();

private MainServer mainServer;

private Animation openSettingsAnimation;

private Animation closeSettingsAnimation;

public Controller(){

mainServer = null;

}

public void setupDashWindow() throws SevereException

{

try

{

getStage().setOnCloseRequest(this::onCloseRequest);

}

catch (Exception e)

{

e.printStackTrace();

throw new SevereException(e.getMessage());

}

@Override

public void init()

{

try

{

initBase();

setupDashWindow();

setupSettingsWindowsAnimations();

ExternalPlugins.getInstance().setPropertySaver(this);

ExternalPlugins.getInstance().setToggleExtras(this);

ExternalPlugins.getInstance().setServerConnection(this);

getDashboardBase().getPluginsPane().getSettingsButton().setOnAction(event -> {

openSettingsAnimation.play();

});

getSettingsBase().getCloseButton().setOnAction(event -> {

closeSettingsAnimation.play();

});

getSettingsBase().getThemesSettings().setController(this);

mainServer = new MainServer(this, this);

if(getConfig().isFirstTimeUse())

{

Stage stage = new Stage();

Scene s = new Scene(new FirstTimeUse(this, this),

getConfig().getStartupWindowWidth(), getConfig().getStartupWindowHeight());

stage.setScene(s);

stage.getIcons().add(new Image(Objects.requireNonNull(Main.class.getResourceAsStream("app_icon.png"))));

stage.setTitle("Stream-Pi Server Setup");

stage.initModality(Modality.APPLICATION_MODAL);

stage.setOnCloseRequest(event->Platform.exit());

stage.show();

}

else

{

if(getConfig().isAllowDonatePopup())

{

if(new Random().nextInt(5) == 3)

new DonatePopupContent(getHostServices(), this).show();

}

othInit();

}

catch (SevereException e)

{

handleSevereException(e);

}

@Override

public void othInit()

{

try

{

if(ServerInfo.getInstance().isStartMinimised() && SystemTray.isSupported())

minimiseApp();

else

getStage().show();

}

catch(MinorException e)

{

handleMinorException(e);

}

executor.execute(new Task<Void>() {

@Override

protected Void call()

{

try

{

getSettingsBase().getGeneralSettings().loadDataFromConfig();

//themes

getSettingsBase().getThemesSettings().setThemes(getThemes());

getSettingsBase().getThemesSettings().setCurrentThemeFullName(getCurrentTheme().getFullName());

getSettingsBase().getThemesSettings().loadThemes();

//clients

getSettingsBase().getClientsSettings().loadData();

try

{

//Plugins

Platform.runLater(()->{

getDashboardBase().getPluginsPane().clearData();

getDashboardBase().getPluginsPane().loadOtherActions();

});

ExternalPlugins.setPluginsLocation(getConfig().getPluginsPath());

ExternalPlugins.getInstance().init();

Platform.runLater(()->getDashboardBase().getPluginsPane().loadData());

getSettingsBase().getPluginsSettings().loadPlugins();

}

catch (MinorException e)

{

getSettingsBase().getPluginsSettings().showPluginInitError();

handleMinorException(e);

}

//Server

mainServer.setPort(getConfig().getPort());

mainServer.start();

}

catch (SevereException e)

{

handleSevereException(e);

}

return null;

}

});

}

private void setupSettingsWindowsAnimations()

{

Node settingsNode = getSettingsBase();

Node dashboardNode = getDashboardBase();

openSettingsAnimation = createOpenSettingsAnimation(settingsNode, dashboardNode);

closeSettingsAnimation = createCloseSettingsAnimation(settingsNode, dashboardNode);

}

public void onCloseRequest(WindowEvent event)

{

try

{

if(Config.getInstance().getMinimiseToSystemTrayOnClose() &&

SystemTray.isSupported())

{

minimiseApp();

event.consume();

return;

}

onQuitApp();

ExternalPlugins.getInstance().shutDownActions();

Platform.exit();

}

catch (SevereException e)

{

handleSevereException(e);

}

catch (MinorException e)

{

handleMinorException(e);

}

public void onQuitApp()

{

try

{

if(getConfig() != null)

{

getConfig().setStartupWindowSize(getWidth(), getHeight());

getConfig().setRightDividerPositions(getDashboardBase().getDividerPositions());

getConfig().setLeftDividerPositions(getDashboardBase().getLeftSplitPane().getDividerPositions());

getConfig().save();

}

catch (SevereException e)

{

handleSevereException(e);

}

stopServerAndAllConnections();

executor.shutdown();

getLogger().info("Shutting down ...");

closeLogger();

}

private void stopServerAndAllConnections()

{

if(mainServer!=null)

mainServer.stopListeningForConnections();

ClientConnections.getInstance().disconnectAll();

}

@Override

public void restart()

{

getLogger().info("Restarting ...");

stopServerAndAllConnections();

Platform.runLater(this::init);

}

public void minimiseApp() throws MinorException

{

try

{

SystemTray systemTray = SystemTray.getSystemTray();

if(getTrayIcon() == null)

initIconTray(systemTray);

systemTray.add(getTrayIcon());

getStage().hide();

getStage().setOnShown(windowEvent -> {

systemTray.remove(getTrayIcon());

});

}

catch(Exception e)

{

throw new MinorException(e.getMessage());

}

public void initIconTray(SystemTray systemTray)

{

Platform.setImplicitExit(false);

PopupMenu popup = new PopupMenu();

MenuItem exitItem = new MenuItem("Exit");

exitItem.addActionListener(l->{

systemTray.remove(getTrayIcon());

onQuitApp();

Platform.exit();

});

popup.add(exitItem);

TrayIcon trayIcon = new TrayIcon(

Toolkit.getDefaultToolkit().getImage(Main.class.getResource("app_icon.png")),

"Stream-Pi Server",

popup

);

trayIcon.addActionListener(l-> Platform.runLater(()-> {

getStage().show();

getStage().setAlwaysOnTop(true);

getStage().setAlwaysOnTop(false);

}));

trayIcon.setImageAutoSize(true);

this.trayIcon = trayIcon;

}

private TrayIcon trayIcon = null;

public TrayIcon getTrayIcon()

{

return trayIcon;

}

@Override

public void handleMinorException(MinorException e)

{

getLogger().log(Level.SEVERE, e.getMessage(), e);

getLogger().log(Level.SEVERE, e.getShortMessage(), e);

e.printStackTrace();

Platform.runLater(()-> new StreamPiAlert(e.getTitle(), e.getShortMessage(), StreamPiAlertType.WARNING).show());

}

@Override

public void handleSevereException(SevereException e) {

getLogger().log(Level.SEVERE, e.getMessage(), e);

getLogger().log(Level.SEVERE, e.getShortMessage(), e);

e.printStackTrace();

Platform.runLater(()->{

StreamPiAlert alert = new StreamPiAlert(e.getTitle(), e.getShortMessage(), StreamPiAlertType.ERROR);

alert.setOnClicked(new StreamPiAlertListener()

{

@Override

public void onClick(String txt)

{

onQuitApp();

Platform.exit();

}

});

alert.show();

});

}

@Override

public synchronized boolean onNormalActionClicked(NormalAction action, String profileID)

{

try{

getLogger().info("action "+action.getID()+" clicked!");

action.onActionClicked();

return true;

}

catch (Exception e)

catch (MinorException e)

{

e.printStackTrace();

e.setTitle("Unable to execute action! ["+action.getDisplayText()+"]");

//check if its windows UAC related

handleMinorException(e);

if(e.getMessage().contains("operation requires elevation"))

{

handleMinorException(new MinorException(

"Action Execution Failed!",

"Error running action at ["+action.getLocation().getRow()+","+action.getLocation().getCol()+"] ("+action.getDisplayText()+")\n"+

"This action requires higher UAC privileges. Re-launch Stream-Pi Server with 'Administrator Privileges' in order to run this command.")

);

}

else

{

handleMinorException(new MinorException(

"Action Execution Failed!",

"Error running action at ["+action.getLocation().getRow()+","+action.getLocation().getCol()+"] ("+action.getDisplayText()+")\n"+

"Check stacktrace/log to know what exactly happened\n\nMessage : \n"+e.getMessage() )

);

}

return false;

}

@Override

public boolean onToggleActionClicked(ToggleAction action, boolean toggle, String profileID)

{

try{

try

{

getLogger().info("action "+action.getID()+" clicked!");

if(toggle)

{

action.onToggleOn();

}

else

{

action.onToggleOff();

}

// ActionBox actionBox = getDashboardBase().getActionGridPane().getActionBoxByIDAndProfileID(

// action.getID(),

// profileID

// );

// if(actionBox != null)

// {

// Platform.runLater(()->actionBox.init(toggle));

// }

return true;

}

catch (Exception e)

catch (MinorException e)

{

e.printStackTrace();

e.setTitle("Unable to execute action! ["+action.getDisplayText()+"]");

//check if its windows UAC related

handleMinorException(e);

if(e.getMessage().contains("operation requires elevation"))

{

handleMinorException(new MinorException(

"Action Execution Failed!",

"Error running action at ["+action.getLocation().getRow()+","+action.getLocation().getCol()+"] ("+action.getDisplayText()+")\n"+

"This action requires higher UAC privileges. Re-launch Stream-Pi Server with 'Administrator Privileges' in order to run this command.")

);

}

else

{

handleMinorException(new MinorException(

"Action Execution Failed!",

"Error running action at ["+action.getLocation().getRow()+","+action.getLocation().getCol()+"] ("+action.getDisplayText()+")\n"+

"Check stacktrace/log to know what exactly happened\n\nMessage : \n"+e.getMessage() )

);

}

return false;

}

@Override

public void clearTemp() {

Platform.runLater(() -> {

getDashboardBase().getClientAndProfileSelectorPane().refresh();

getDashboardBase().getActionGridPane().clear();

getDashboardBase().getActionGridPane().setFreshRender(true);

getDashboardBase().getActionDetailsPane().clear();

getSettingsBase().getClientsSettings().loadData();

});

}

@Override

public void saveServerProperties()

{

try

{

ExternalPlugins.getInstance().saveServerSettings();

getSettingsBase().getPluginsSettings().loadPlugins();

} catch (MinorException e) {

e.printStackTrace();

handleMinorException(e);

}

private void saveClientActionMain(String profileID, String actionID, SocketAddress socketAddress, boolean sendIcons)

{

try {

ClientConnection clientConnection = ClientConnections.getInstance().getClientConnectionBySocketAddress(socketAddress);

ClientProfile clientProfile = clientConnection.getClient().getProfileByID(profileID);

Action action = clientProfile.getActionByID(actionID);

clientConnection.saveActionDetails(profileID, action);

if(sendIcons && action.isHasIcon())

{

saveAllIcons(profileID, actionID, socketAddress, false);

}

Platform.runLater(()->{

try {

ActionBox actionBox = getDashboardBase().getActionGridPane().getActionBoxByIDAndProfileID(

action.getID(),

profileID

);

if(actionBox != null)

{

Platform.runLater(actionBox::init);

}

if(getDashboardBase().getActionDetailsPane().getAction() != null)

{

// This block is executed when no Action is selected.

if(getDashboardBase().getActionDetailsPane().getAction().getID().equals(actionID))

{

getDashboardBase().getActionDetailsPane().setAction(action);

getDashboardBase().getActionDetailsPane().refresh();

}

catch (Exception e)

{

e.printStackTrace();

}

});

}

catch (SevereException e)

{

handleSevereException(e);

}

@Override

public void saveClientAction(String profileID, String actionID, SocketAddress socketAddress, boolean sendIcons, boolean runAsync)

{

if(runAsync)

{

executor.execute(new Task<Void>() {

@Override

protected Void call()

{

saveClientActionMain(profileID, actionID, socketAddress, sendIcons);

return null;

}

});

}

else

{

saveClientActionMain(profileID, actionID, socketAddress, sendIcons);

}

@Override

public void saveAllIcons(String profileID, String actionID, SocketAddress socketAddress)

{

saveAllIcons(profileID, actionID, socketAddress, true);

}

public void saveAllIcons(String profileID, String actionID, SocketAddress socketAddress, boolean async)

{

if(async)

{

executor.execute(new Task<Void>() {

@Override

protected Void call()

{

saveAllIconsMain(profileID, actionID, socketAddress);

return null;

}

});

}

else

{

saveAllIconsMain(profileID, actionID, socketAddress);

}

private void saveAllIconsMain(String profileID, String actionID, SocketAddress socketAddress)

{

try {

ClientConnection clientConnection = ClientConnections.getInstance().getClientConnectionBySocketAddress(socketAddress);

ClientProfile clientProfile = clientConnection.getClient().getProfileByID(profileID);

Action action = clientProfile.getActionByID(actionID);

for(String eachState : action.getIcons().keySet())

{

clientConnection.sendIcon(profileID, actionID, eachState,

action.getIcon(eachState));

}

catch (SevereException e)

{

handleSevereException(e);

}

@Override

public void saveIcon(String state, String profileID, String actionID, SocketAddress socketAddress) {

executor.execute(new Task<Void>() {

@Override

protected Void call()

{

try {

ClientConnection clientConnection = ClientConnections.getInstance().getClientConnectionBySocketAddress(socketAddress);

ClientProfile clientProfile = clientConnection.getClient().getProfileByID(profileID);

Action action = clientProfile.getActionByID(actionID);

clientConnection.sendIcon(profileID, actionID, state, action.getIcon(state));

}

catch (SevereException e)

{

handleSevereException(e);

}

return null;

}

});

}

@Override

public com.stream_pi.util.platform.Platform getPlatform() {

return ServerInfo.getInstance().getPlatform();

}

private Animation createOpenSettingsAnimation(Node settingsNode, Node dashboardNode) {

Timeline openSettingsTimeline = new Timeline();

openSettingsTimeline.setCycleCount(1);

openSettingsTimeline.getKeyFrames().addAll(

new KeyFrame(Duration.millis(0.0D),

new KeyValue(settingsNode.opacityProperty(),

0.0D, Interpolator.EASE_IN),

new KeyValue(settingsNode.scaleXProperty(),

1.1D, Interpolator.EASE_IN),

new KeyValue(settingsNode.scaleYProperty(),

1.1D, Interpolator.EASE_IN),

new KeyValue(settingsNode.scaleZProperty(),

1.1D, Interpolator.EASE_IN)),

new KeyFrame(Duration.millis(90.0D),

new KeyValue(settingsNode.opacityProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(settingsNode.scaleXProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(settingsNode.scaleYProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(settingsNode.scaleZProperty(),

1.0D, Interpolator.LINEAR)),

new KeyFrame(Duration.millis(0.0D),

new KeyValue(dashboardNode.opacityProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleXProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleYProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleZProperty(),

1.0D, Interpolator.LINEAR)),

new KeyFrame(Duration.millis(90.0D),

new KeyValue(dashboardNode.opacityProperty(),

0.0D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleXProperty(),

0.9D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleYProperty(),

0.9D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleZProperty(),

0.9D, Interpolator.LINEAR))

);

openSettingsTimeline.setOnFinished(e -> settingsNode.toFront());

return openSettingsTimeline;

}

private Animation createCloseSettingsAnimation(Node settingsNode, Node dashboardNode) {

Timeline closeSettingsTimeline = new Timeline();

closeSettingsTimeline.setCycleCount(1);

closeSettingsTimeline.getKeyFrames().addAll(

new KeyFrame(Duration.millis(0.0D),

new KeyValue(settingsNode.opacityProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(settingsNode.scaleXProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(settingsNode.scaleYProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(settingsNode.scaleZProperty(),

1.0D, Interpolator.LINEAR)),

new KeyFrame(Duration.millis(90.0D),

new KeyValue(settingsNode.opacityProperty(),

0.0D, Interpolator.LINEAR),

new KeyValue(settingsNode.scaleXProperty(),

1.1D, Interpolator.LINEAR),

new KeyValue(settingsNode.scaleYProperty(),

1.1D, Interpolator.LINEAR),

new KeyValue(settingsNode.scaleZProperty(),

1.1D, Interpolator.LINEAR)),

new KeyFrame(Duration.millis(0.0D),

new KeyValue(dashboardNode.opacityProperty(),

0.0D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleXProperty(),

0.9D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleYProperty(),

0.9D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleZProperty(),

0.9D, Interpolator.LINEAR)),

new KeyFrame(Duration.millis(90.0D),

new KeyValue(dashboardNode.opacityProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleXProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleYProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleZProperty(),

1.0D, Interpolator.LINEAR))

);

closeSettingsTimeline.setOnFinished(event1 -> {

dashboardNode.toFront();

executor.execute(new Task<Void>() {

@Override

protected Void call() {

try {

getSettingsBase().getClientsSettings().loadData();

getSettingsBase().getGeneralSettings().loadDataFromConfig();

getSettingsBase().getPluginsSettings().loadPlugins();

getSettingsBase().getThemesSettings().setThemes(getThemes());

getSettingsBase().getThemesSettings().setCurrentThemeFullName(getCurrentTheme().getFullName());

getSettingsBase().getThemesSettings().loadThemes();

getSettingsBase().setDefaultTabToGeneral();

}

catch (SevereException e)

{

handleSevereException(e);

}

catch (MinorException e)

{

handleMinorException(e);

}

return null;

}

});

return closeSettingsTimeline;

}

@Override

public void setToggleStatus(boolean currentStatus, String profileID, String actionID, SocketAddress clientSocketAddress)

throws MinorException

{

ClientConnection clientConnection = ClientConnections.getInstance().getClientConnectionBySocketAddress(

clientSocketAddress

);

if(clientConnection == null)

throw new ClientNotFoundException("setToggleStatus failed because no client found with given socket address");

new Thread(new Task<Void>() {

@Override

protected Void call()

{

try

{

clientConnection.setToggleStatus(currentStatus, profileID, actionID);

}

catch (SevereException e)

{

handleSevereException(e);

}

return null;

}

}).start();

}

M src/main/java/com/stream_pi/server/window/dashboard/actiondetailpane/ActionDetailsPane.java

+4 −2

package com.stream_pi.server.window.dashboard.actiondetailpane;

import com.stream_pi.action_api.action.Action;

import com.stream_pi.action_api.action.ActionType;

import com.stream_pi.action_api.action.DisplayTextAlignment;

import com.stream_pi.action_api.action.Location;

import com.stream_pi.action_api.actionproperty.ClientProperties;

import com.stream_pi.action_api.actionproperty.property.ControlType;

import com.stream_pi.action_api.actionproperty.property.FileExtensionFilter;

import com.stream_pi.action_api.actionproperty.property.Property;

import com.stream_pi.action_api.actionproperty.property.Type;

import com.stream_pi.action_api.externalplugin.ExternalPlugin;

import com.stream_pi.action_api.otheractions.CombineAction;

import com.stream_pi.action_api.otheractions.FolderAction;

import com.stream_pi.server.uipropertybox.UIPropertyBox;

import com.stream_pi.server.client.Client;

import com.stream_pi.server.client.ClientProfile;

import com.stream_pi.server.connection.ClientConnection;

import com.stream_pi.server.connection.ClientConnections;

import com.stream_pi.server.window.dashboard.actiongridpane.ActionBox;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

import com.stream_pi.server.controller.ActionDataFormats;

import com.stream_pi.server.window.dashboard.actiongridpane.ActionGridPaneListener;

import com.stream_pi.util.alert.StreamPiAlert;

import com.stream_pi.util.alert.StreamPiAlertListener;

import com.stream_pi.util.alert.StreamPiAlertType;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.exception.SevereException;

import com.stream_pi.util.uihelper.HBoxInputBox;

import com.stream_pi.util.uihelper.HBoxInputBoxWithFileChooser;

import com.stream_pi.util.uihelper.SpaceFiller;

import javafx.application.HostServices;

import javafx.collections.FXCollections;

import javafx.concurrent.Task;

import javafx.geometry.Insets;

import javafx.geometry.Pos;

import javafx.scene.Node;

import javafx.scene.control.*;

import javafx.scene.input.Dragboard;

import javafx.scene.input.TransferMode;

import javafx.scene.layout.HBox;

import javafx.scene.layout.Priority;

import javafx.scene.layout.VBox;

import javafx.scene.paint.Color;

import javafx.stage.FileChooser;

import javafx.stage.Window;

import javafx.util.Callback;

import org.kordamp.ikonli.javafx.FontIcon;

import java.io.File;

import java.nio.file.Files;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.logging.Logger;

public class ActionDetailsPane extends VBox implements ActionDetailsPaneListener

{

private ScrollPane scrollPane;

private VBox vbox;

private VBox clientPropertiesVBox;

private Button saveButton;

private Button deleteButton;

private Button openFolderButton;

private Button resetToDefaultsButton;

private HBox buttonBar;

private VBox pluginExtraButtonBar;

private Label actionHeadingLabel;

private Logger logger;

private Button returnButtonForCombineActionChild;

private ExceptionAndAlertHandler exceptionAndAlertHandler;

private HostServices hostServices;

private ActionGridPaneListener actionGridPaneListener;

public ActionDetailsPane(ExceptionAndAlertHandler exceptionAndAlertHandler, HostServices hostServices,

ActionGridPaneListener actionGridPaneListener)

{

this.hostServices = hostServices;

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

this.actionGridPaneListener = actionGridPaneListener;

logger = Logger.getLogger(ActionDetailsPane.class.getName());

setSpacing(10.0);

clientPropertiesVBox = new VBox();

clientPropertiesVBox.setSpacing(10.0);

vbox = new VBox();

vbox.setPadding(new Insets(0, 25, 0, 5));

vbox.getStyleClass().add("action_details_pane_vbox");

vbox.setSpacing(10.0);

pluginExtraButtonBar = new VBox();

pluginExtraButtonBar.setSpacing(10.0);

getStyleClass().add("action_details_pane");

scrollPane = new ScrollPane();

VBox.setMargin(scrollPane, new Insets(0, 0, 0, 10));

scrollPane.getStyleClass().add("action_details_pane_scroll_pane");

setMinHeight(210);

scrollPane.setContent(vbox);

vbox.prefWidthProperty().bind(scrollPane.widthProperty());

scrollPane.prefWidthProperty().bind(widthProperty());

VBox.setVgrow(scrollPane, Priority.ALWAYS);

scrollPane.setHbarPolicy(ScrollPane.ScrollBarPolicy.NEVER);

openFolderButton = new Button("Open Folder");

openFolderButton.managedProperty().bind(openFolderButton.visibleProperty());

FontIcon folderOpenIcon = new FontIcon("far-folder-open");

openFolderButton.setGraphic(folderOpenIcon);

openFolderButton.setOnAction(event -> onOpenFolderButtonClicked());

saveButton = new Button("Save");

saveButton.getStyleClass().add("action_details_pane_save_button");

FontIcon syncIcon = new FontIcon("far-save");

syncIcon.getStyleClass().add("action_details_save_delete_button_icon");

saveButton.setGraphic(syncIcon);

saveButton.setOnAction(event -> onSaveButtonClicked());

deleteButton = new Button();

deleteButton.getStyleClass().add("action_details_pane_delete_button");

FontIcon deleteIcon = new FontIcon("fas-trash");

deleteIcon.getStyleClass().add("action_details_pane_delete_button_icon");

deleteButton.setGraphic(deleteIcon);

deleteButton.setOnAction(event -> onDeleteButtonClicked());

resetToDefaultsButton = new Button("Reset");

resetToDefaultsButton.managedProperty().bind(resetToDefaultsButton.visibleProperty());

resetToDefaultsButton.getStyleClass().add("action_details_pane_reset_button");

FontIcon resetToDefaultsIcon = new FontIcon("fas-sync-alt");

resetToDefaultsIcon.getStyleClass().add("action_details_pane_reset_button_icon");

resetToDefaultsButton.setGraphic(resetToDefaultsIcon);

resetToDefaultsButton.setOnAction(event -> onResetToDefaultsButtonClicked());

returnButtonForCombineActionChild = new Button("Return");

returnButtonForCombineActionChild.setGraphic(new FontIcon("fas-caret-left"));

returnButtonForCombineActionChild.managedProperty().bind(returnButtonForCombineActionChild.visibleProperty());

returnButtonForCombineActionChild.setOnAction(event -> {

try

{

onActionClicked(getClientProfile().getActionByID(getAction().getParent()), getActionBox());

} catch (MinorException e)

{

e.printStackTrace();

}

});

buttonBar = new HBox(openFolderButton, resetToDefaultsButton, returnButtonForCombineActionChild, saveButton, deleteButton);

buttonBar.getStyleClass().add("action_details_pane_button_bar");

buttonBar.setPadding(new Insets(10, 10, 10, 0));

buttonBar.setAlignment(Pos.CENTER_RIGHT);

buttonBar.setVisible(false);

buttonBar.setSpacing(10.0);

actionHeadingLabel = new Label();

actionHeadingLabel.getStyleClass().add("action_details_pane_heading_label");

HBox headingHBox = new HBox(actionHeadingLabel);

headingHBox.getStyleClass().add("action_details_pane_heading_box");

headingHBox.setPadding(new Insets(5, 10, 0, 10));

getChildren().addAll(headingHBox, scrollPane, buttonBar);

displayTextAlignmentComboBox = new ComboBox<>(FXCollections.observableArrayList(DisplayTextAlignment.TOP,

DisplayTextAlignment.CENTER, DisplayTextAlignment.BOTTOM));

displayTextAlignmentComboBox.managedProperty().bind(displayTextAlignmentComboBox.visibleProperty());

Callback<ListView<DisplayTextAlignment>, ListCell<DisplayTextAlignment>> displayTextAlignmentComboBoxFactory = new Callback<>() {

@Override

public ListCell<DisplayTextAlignment> call(ListView<DisplayTextAlignment> displayTextAlignment) {

return new ListCell<>() {

@Override

protected void updateItem(DisplayTextAlignment displayTextAlignment, boolean b) {

super.updateItem(displayTextAlignment, b);

if (displayTextAlignment != null) {

setText(displayTextAlignment.getUIName());

}

};

}

};

displayTextAlignmentComboBox.setCellFactory(displayTextAlignmentComboBoxFactory);

displayTextAlignmentComboBox.setButtonCell(displayTextAlignmentComboBoxFactory.call(null));

actionClientProperties = new ArrayList<>();

displayNameTextField = new TextField();

displayNameTextField.managedProperty().bind(displayNameTextField.visibleProperty());

defaultIconFileTextField = new TextField();

defaultIconFileTextField.textProperty().addListener((observableValue, s, t1) -> {

try {

if (!s.equals(t1) && t1.length() > 0) {

byte[] iconFileByteArray = Files.readAllBytes(new File(t1).toPath());

hideDefaultIconCheckBox.setDisable(false);

hideDefaultIconCheckBox.setSelected(false);

clearIconButton.setDisable(false);

getAction().addIcon("default", iconFileByteArray);

getAction().setCurrentIconState("default");

setSendIcon(true);

}

} catch (Exception e) {

e.printStackTrace();

exceptionAndAlertHandler.handleMinorException(new MinorException(e.getMessage()));

}

});

toggleOffIconFileTextField = new TextField();

toggleOffIconFileTextField.textProperty().addListener((observableValue, s, t1) -> {

try {

if (!s.equals(t1) && t1.length() > 0) {

byte[] iconFileByteArray = Files.readAllBytes(new File(t1).toPath());

hideToggleOffIconCheckBox.setDisable(false);

hideToggleOffIconCheckBox.setSelected(false);

clearIconButton.setDisable(false);

getAction().addIcon("toggle_off", iconFileByteArray);

setSendIcon(true);

}

} catch (Exception e) {

e.printStackTrace();

exceptionAndAlertHandler.handleMinorException(new MinorException(e.getMessage()));

}

});

toggleOnIconFileTextField = new TextField();

toggleOnIconFileTextField.textProperty().addListener((observableValue, s, t1) -> {

try {

if (!s.equals(t1) && t1.length() > 0) {

byte[] iconFileByteArray = Files.readAllBytes(new File(t1).toPath());

hideToggleOnIconCheckBox.setDisable(false);

hideToggleOnIconCheckBox.setSelected(false);

clearIconButton.setDisable(false);

getAction().addIcon("toggle_on", iconFileByteArray);

setSendIcon(true);

}

} catch (Exception e) {

e.printStackTrace();

exceptionAndAlertHandler.handleMinorException(new MinorException(e.getMessage()));

}

});

clearIconButton = new Button("Clear Icon");

clearIconButton.managedProperty().bind(clearIconButton.visibleProperty());

clearIconButton.setOnAction(event ->

{

hideDefaultIconCheckBox.setDisable(true);

hideDefaultIconCheckBox.setSelected(false);

hideToggleOffIconCheckBox.setDisable(true);

hideToggleOffIconCheckBox.setSelected(false);

hideToggleOnIconCheckBox.setDisable(true);

hideToggleOnIconCheckBox.setSelected(false);

clearIconButton.setDisable(true);

setSendIcon(false);

defaultIconFileTextField.clear();

toggleOffIconFileTextField.clear();

toggleOnIconFileTextField.clear();

});

hideDisplayTextCheckBox = new CheckBox("Hide");

hideDisplayTextCheckBox.managedProperty().bind(hideDisplayTextCheckBox.visibleProperty());

hideDefaultIconCheckBox = new CheckBox("Hide");

hideToggleOnIconCheckBox = new CheckBox("Hide");

hideToggleOffIconCheckBox = new CheckBox("Hide");

actionBackgroundColourPicker = new ColorPicker();

actionBackgroundColourPicker.managedProperty().bind(actionBackgroundColourPicker.visibleProperty());

displayTextColourPicker = new ColorPicker();

displayTextColourPicker.managedProperty().bind(displayTextColourPicker.visibleProperty());

actionBackgroundColourTransparentCheckBox = new CheckBox("Default");

actionBackgroundColourPicker.disableProperty()

.bind(actionBackgroundColourTransparentCheckBox.selectedProperty());

HBox.setMargin(actionBackgroundColourTransparentCheckBox, new Insets(0, 0, 0, 10));

displayTextColourDefaultCheckBox = new CheckBox("Default");

displayTextColourPicker.disableProperty()

.bind(displayTextColourDefaultCheckBox.selectedProperty());

HBox.setMargin(displayTextColourDefaultCheckBox, new Insets(0, 0, 0, 10));

HBox displayTextColourHBox = new HBox(new Label("Display Text Colour"), SpaceFiller.horizontal(), displayTextColourPicker,

displayTextColourDefaultCheckBox);

displayTextColourHBox.setAlignment(Pos.CENTER);

displayTextColourHBox.setSpacing(5.0);

HBox bgColourHBox = new HBox(new Label("Background Colour"), SpaceFiller.horizontal(), actionBackgroundColourPicker,

actionBackgroundColourTransparentCheckBox);

bgColourHBox.setAlignment(Pos.CENTER);

bgColourHBox.setSpacing(5.0);

HBox clearIconHBox = new HBox(clearIconButton);

clearIconHBox.setAlignment(Pos.CENTER_RIGHT);

displayTextFieldHBox = new HBoxInputBox("Display Name", displayNameTextField, hideDisplayTextCheckBox);

HBox alignmentHBox = new HBox(new Label("Alignment"), SpaceFiller.horizontal(),

displayTextAlignmentComboBox);

normalToggleActionCommonPropsVBox = new VBox(

displayTextColourHBox,

alignmentHBox,

bgColourHBox

);

normalToggleActionCommonPropsVBox.managedProperty().bind(normalToggleActionCommonPropsVBox.visibleProperty());

normalToggleActionCommonPropsVBox.setSpacing(10.0);

FileChooser.ExtensionFilter iconExtensions = new FileChooser.ExtensionFilter("Images", "*.jpeg", "*.jpg", "*.png", "*.gif");

normalActionsPropsVBox = new VBox(

new HBoxInputBoxWithFileChooser("Icon", defaultIconFileTextField, hideDefaultIconCheckBox,

iconExtensions)

);

normalActionsPropsVBox.managedProperty().bind(normalActionsPropsVBox.visibleProperty());

normalActionsPropsVBox.setSpacing(10.0);

toggleActionsPropsVBox = new VBox(

new HBoxInputBoxWithFileChooser("Toggle Off Icon", toggleOffIconFileTextField, hideToggleOffIconCheckBox,

iconExtensions),

new HBoxInputBoxWithFileChooser("Toggle On Icon", toggleOnIconFileTextField, hideToggleOnIconCheckBox,

iconExtensions)

);

toggleActionsPropsVBox.managedProperty().bind(toggleActionsPropsVBox.visibleProperty());

toggleActionsPropsVBox.setSpacing(10.0);

vbox.getChildren().addAll(displayTextFieldHBox,normalToggleActionCommonPropsVBox,

normalActionsPropsVBox, toggleActionsPropsVBox,

clearIconHBox, clientPropertiesVBox,

pluginExtraButtonBar);

vbox.setVisible(false);

scrollPane.setVbarPolicy(ScrollPane.ScrollBarPolicy.NEVER);

setOnDragOver(dragEvent -> {

if (dragEvent.getDragboard().hasContent(ActionDataFormats.ACTION_TYPE) && action != null) {

if (getAction().getActionType() == ActionType.COMBINE) {

dragEvent.acceptTransferModes(TransferMode.ANY);

dragEvent.consume();

}

});

setOnDragDropped(dragEvent -> {

try {

Dragboard db = dragEvent.getDragboard();

ActionType actionType = (ActionType) db.getContent(ActionDataFormats.ACTION_TYPE);

if(actionType == ActionType.NORMAL || actionType == ActionType.TOGGLE)

{

ExternalPlugin newAction = actionGridPaneListener.createNewActionFromExternalPlugin(

(String) db.getContent(ActionDataFormats.MODULE_NAME)

);

boolean isNew = (boolean) db.getContent(ActionDataFormats.IS_NEW);

if(isNew)

{

newAction.setDisplayText("Untitled Action");

newAction.setShowDisplayText(true);

newAction.setDisplayTextAlignment(DisplayTextAlignment.CENTER);

if(actionType == ActionType.TOGGLE)

newAction.setCurrentIconState("false__false");

}

else

{

newAction.setClientProperties((ClientProperties) db.getContent(ActionDataFormats.CLIENT_PROPERTIES));

newAction.setIcons((HashMap<String, byte[]>) db.getContent(ActionDataFormats.ICONS));

newAction.setCurrentIconState((String) db.getContent(ActionDataFormats.CURRENT_ICON_STATE));

newAction.setBgColourHex((String) db.getContent(ActionDataFormats.BACKGROUND_COLOUR));

newAction.setDisplayTextFontColourHex((String) db.getContent(ActionDataFormats.DISPLAY_TEXT_FONT_COLOUR));

newAction.setDisplayText((String) db.getContent(ActionDataFormats.DISPLAY_TEXT));

newAction.setDisplayTextAlignment((DisplayTextAlignment) db.getContent(ActionDataFormats.DISPLAY_TEXT_ALIGNMENT));

newAction.setShowDisplayText((boolean) db.getContent(ActionDataFormats.DISPLAY_TEXT_SHOW));

}

newAction.setLocation(new Location(-1, -1));

newAction.setParent(getAction().getID());

newAction.setProfileID(actionGridPaneListener.getCurrentProfile().getID());

newAction.setSocketAddressForClient(actionGridPaneListener.getClientConnection().getRemoteSocketAddress());

try

{

newAction.onActionCreate();

}

catch (Exception e)

catch (MinorException e)

{

exceptionAndAlertHandler.handleMinorException(new MinorException("Error","onCreate() failed for "+getAction().getModuleName()+"\n\n"+e.getMessage()));

e.setTitle("Error");

e.setShortMessage("onCreate() failed for "+getAction().getModuleName()+"\n\n"+e.getShortMessage());

exceptionAndAlertHandler.handleMinorException(e);

}

combineActionPropertiesPane.getCombineAction().addChild(newAction.getID());

addActionToCurrentClientProfile(newAction);

ClientConnection connection = ClientConnections.getInstance()

.getClientConnectionBySocketAddress(getClient().getRemoteSocketAddress());

connection.saveActionDetails(getClientProfile().getID(), newAction);

combineActionPropertiesPane.renderProps();

saveAction(true, false);

}

} catch (MinorException e) {

exceptionAndAlertHandler.handleMinorException(e);

e.printStackTrace();

} catch (SevereException e) {

exceptionAndAlertHandler.handleSevereException(e);

e.printStackTrace();

} catch (CloneNotSupportedException e) {

e.printStackTrace();

} catch (Exception e)

{

e.printStackTrace();

}

});

}

private void onResetToDefaultsButtonClicked()

{

StreamPiAlert streamPiAlert = new StreamPiAlert(

"Warning",

"Are you sure you want to reset the action?",

StreamPiAlertType.WARNING

);

String optionYes = "Yes";

String optionNo = "No";

streamPiAlert.setButtons(optionYes, optionNo);

streamPiAlert.setOnClicked(new StreamPiAlertListener() {

@Override

public void onClick(String s) {

if(s.equals(optionYes))

{

getAction().getClientProperties().resetToDefaults();

try

{

onActionClicked(getAction(), getActionBox());

saveAction(true, true);

}

catch (MinorException e)

{

exceptionAndAlertHandler.handleMinorException(e);

}

});

streamPiAlert.show();

}

private VBox normalActionsPropsVBox;

private VBox normalToggleActionCommonPropsVBox;

private VBox toggleActionsPropsVBox;

private HBox displayTextFieldHBox;

private ClientConnection clientConnection;

private ClientProfile clientProfile;

public void setClientConnection(ClientConnection clientConnection) {

this.clientConnection = clientConnection;

}

public ClientConnection getClientConnection() {

return clientConnection;

}

public Client getClient()

{

return getClientConnection().getClient();

}

public void setClientProfile(ClientProfile clientProfile) {

this.clientProfile = clientProfile;

}

public ClientProfile getClientProfile() {

return clientProfile;

}

public void setActionHeadingLabelText(String text) {

actionHeadingLabel.setText(text);

}

private Action action;

public synchronized Action getAction() {

return action;

}

private ActionBox actionBox;

public ActionBox getActionBox() {

return actionBox;

}

@Override

public void onActionClicked(Action action, ActionBox actionBox) throws MinorException

{

clear();

setAction(action);

this.actionBox = actionBox;

actionBox.setSelected(true);

renderActionProperties();

}

public void refresh()

{

clear(false);

try

{

renderActionProperties();

}

catch (MinorException e)

{

exceptionAndAlertHandler.handleMinorException(e);

}

private TextField displayNameTextField;

private CheckBox hideDisplayTextCheckBox;

private CheckBox hideDefaultIconCheckBox;

private TextField defaultIconFileTextField;

private CheckBox hideToggleOnIconCheckBox;

private TextField toggleOnIconFileTextField;

private CheckBox hideToggleOffIconCheckBox;

private TextField toggleOffIconFileTextField;

private Button clearIconButton;

private ColorPicker actionBackgroundColourPicker;

private ColorPicker displayTextColourPicker;

private CheckBox actionBackgroundColourTransparentCheckBox;

private CheckBox displayTextColourDefaultCheckBox;

private ComboBox<DisplayTextAlignment> displayTextAlignmentComboBox;

public void clear(boolean actionNull)

{

sendIcon = false;

actionClientProperties.clear();

displayNameTextField.clear();

defaultIconFileTextField.clear();

toggleOffIconFileTextField.clear();

toggleOnIconFileTextField.clear();

clientPropertiesVBox.getChildren().clear();

pluginExtraButtonBar.getChildren().clear();

vbox.setVisible(false);

normalActionsPropsVBox.setVisible(false);

toggleActionsPropsVBox.setVisible(false);

saveButton.setVisible(false);

openFolderButton.setVisible(false);

resetToDefaultsButton.setVisible(false);

returnButtonForCombineActionChild.setVisible(false);

scrollPane.setVbarPolicy(ScrollPane.ScrollBarPolicy.NEVER);

buttonBar.setVisible(false);

setActionHeadingLabelText("");

actionBackgroundColourPicker.setValue(Color.WHITE);

displayTextColourPicker.setValue(Color.WHITE);

if(actionNull)

{

action = null;

if(actionBox !=null)

{

actionBox.setSelected(false);

actionBox = null;

}

@Override

public void clear()

{

clear(true);

}

boolean isCombineChild = false;

public boolean isCombineChild() {

return isCombineChild;

}

public void renderActionProperties() throws MinorException

{

//Combine Child action

isCombineChild = getAction().getLocation().getCol() == -1;

displayNameTextField.setText(getAction().getDisplayText());

vbox.setVisible(true);

scrollPane.setVbarPolicy(ScrollPane.ScrollBarPolicy.AS_NEEDED);

buttonBar.setVisible(true);

displayTextAlignmentComboBox.getSelectionModel().select(getAction().getDisplayTextAlignment());

if(!getAction().getBgColourHex().isEmpty())

actionBackgroundColourPicker.setValue(Color.valueOf(getAction().getBgColourHex()));

else

actionBackgroundColourTransparentCheckBox.setSelected(true);

if(!getAction().getDisplayTextFontColourHex().isEmpty())

displayTextColourPicker.setValue(Color.valueOf(getAction().getDisplayTextFontColourHex()));

else

displayTextColourDefaultCheckBox.setSelected(true);

hideDisplayTextCheckBox.setSelected(!getAction().isShowDisplayText());

if(getAction().isInvalid())

{

setActionHeadingLabelText("Invalid action ("+getAction().getModuleName()+")");

return;

}

saveButton.setVisible(!getAction().isInvalid());

if(isCombineChild)

{

setReturnButtonForCombineActionChildVisible(true);

normalActionsPropsVBox.setVisible(false);

normalToggleActionCommonPropsVBox.setVisible(false);

hideDisplayTextCheckBox.setSelected(false);

hideDisplayTextCheckBox.setVisible(false);

}

else

{

normalToggleActionCommonPropsVBox.setVisible(true);

if(getAction().getActionType() == ActionType.TOGGLE)

{

normalActionsPropsVBox.setVisible(false);

toggleActionsPropsVBox.setVisible(true);

boolean doesToggleOnExist = getAction().getIcons().containsKey("toggle_on");

boolean isToggleOnHidden = getAction().getCurrentIconState().contains("toggle_on");

if(!doesToggleOnExist)

isToggleOnHidden = false;

hideToggleOnIconCheckBox.setDisable(!doesToggleOnExist);

hideToggleOnIconCheckBox.setSelected(isToggleOnHidden);

boolean doesToggleOffExist = getAction().getIcons().containsKey("toggle_off");

boolean isToggleOffHidden = getAction().getCurrentIconState().contains("toggle_off");

if(!doesToggleOffExist)

isToggleOffHidden = false;

hideToggleOffIconCheckBox.setDisable(!doesToggleOffExist);

hideToggleOffIconCheckBox.setSelected(isToggleOffHidden);

}

else

{

normalActionsPropsVBox.setVisible(true);

toggleActionsPropsVBox.setVisible(false);

boolean doesDefaultExist = getAction().getIcons().containsKey("default");

boolean isDefaultHidden = !getAction().getCurrentIconState().equals("default");

if(!doesDefaultExist)

isDefaultHidden = false;

hideDefaultIconCheckBox.setDisable(!doesDefaultExist);

hideDefaultIconCheckBox.setSelected(isDefaultHidden);

}

setReturnButtonForCombineActionChildVisible(false);

hideDisplayTextCheckBox.setVisible(true);

setFolderButtonVisible(getAction().getActionType().equals(ActionType.FOLDER));

setResetToDefaultsButtonVisible(!(getAction().getActionType().equals(ActionType.FOLDER) || getAction().getActionType().equals(ActionType.COMBINE)));

clearIconButton.setDisable(!getAction().isHasIcon());

}

if(getAction().getActionType() == ActionType.NORMAL || getAction().getActionType() == ActionType.TOGGLE)

{

setActionHeadingLabelText(getAction().getName());

}

else if(getAction().getActionType() == ActionType.COMBINE)

{

setActionHeadingLabelText("Combine action");

}

else if(getAction().getActionType() == ActionType.FOLDER)

{

setActionHeadingLabelText("Folder action");

}

if(getAction().getActionType() == ActionType.NORMAL || getAction().getActionType() == ActionType.TOGGLE)

{

renderClientProperties();

renderPluginExtraButtonBar();

}

else if(getAction().getActionType() == ActionType.COMBINE)

renderCombineActionProperties();

}

private void renderPluginExtraButtonBar()

{

ExternalPlugin externalPlugin = (ExternalPlugin) getAction();

externalPlugin.initClientActionSettingsButtonBar();

if(externalPlugin.getClientActionSettingsButtonBar() != null)

{

HBox tba = new HBox(SpaceFiller.horizontal(), externalPlugin.getClientActionSettingsButtonBar());

pluginExtraButtonBar.getChildren().add(tba);

}

private CombineActionPropertiesPane combineActionPropertiesPane;

public CombineActionPropertiesPane getCombineActionPropertiesPane() {

return combineActionPropertiesPane;

}

public void setReturnButtonForCombineActionChildVisible(boolean visible)

{

returnButtonForCombineActionChild.setVisible(visible);

}

public void renderCombineActionProperties()

{

try

{

combineActionPropertiesPane = new CombineActionPropertiesPane((CombineAction) getAction(),

getClientProfile(),

this

);

clientPropertiesVBox.getChildren().add(combineActionPropertiesPane);

}

catch (MinorException e)

{

e.printStackTrace();

exceptionAndAlertHandler.handleMinorException(e);

}

@Override

public synchronized void setAction(Action action) {

this.action = action;

}

@Override

public void onOpenFolderButtonClicked()

{

actionBox.getActionGridPaneListener().renderFolder((FolderAction) getAction());

clear();

}

@Override

public Window getCurrentWindow() {

return getScene().getWindow();

}

private ArrayList<UIPropertyBox> actionClientProperties;

private TextField delayBeforeRunningTextField;

public void renderClientProperties() throws MinorException

{

delayBeforeRunningTextField = new TextField();

delayBeforeRunningTextField.setText(getAction().getDelayBeforeExecuting()+"");

clientPropertiesVBox.getChildren().add(

new HBoxInputBox("Delay before running (milli-seconds)", delayBeforeRunningTextField, 100)

);

for(int i =0;i< getAction().getClientProperties().getSize(); i++)

{

Property eachProperty = getAction().getClientProperties().get().get(i);

if(!eachProperty.isVisible())

continue;

Label label = new Label(eachProperty.getDisplayName());

HBox hBox = new HBox(label);

hBox.setSpacing(5.0);

hBox.setAlignment(Pos.CENTER_LEFT);

Node controlNode = null;

if(eachProperty.getHelpLink() != null)

{

Button helpButton = new Button();

FontIcon questionIcon = new FontIcon("fas-question");

helpButton.setGraphic(questionIcon);

helpButton.setOnAction(event -> {

hostServices.showDocument(eachProperty.getHelpLink());

});

hBox.getChildren().add(helpButton);

hBox.getChildren().add(controlNode);

}

hBox.getChildren().add(SpaceFiller.horizontal());

if(eachProperty.getControlType() == ControlType.COMBO_BOX)

{

ComboBox<String> comboBox = new ComboBox<>();

comboBox.getItems().addAll(eachProperty.getListValue());

comboBox.getSelectionModel().select(eachProperty.getSelectedIndex());

controlNode = comboBox;

hBox.getChildren().add(controlNode);

}

else if(eachProperty.getControlType() == ControlType.FILE_PATH)

{

TextField textField = new TextField(eachProperty.getRawValue());

FileExtensionFilter[] fileExtensionFilters = eachProperty.getExtensionFilters();

FileChooser.ExtensionFilter[] extensionFilters = new FileChooser.ExtensionFilter[fileExtensionFilters.length];

for(int x = 0;x<fileExtensionFilters.length;x++)

{

extensionFilters[x] = new FileChooser.ExtensionFilter(

fileExtensionFilters[x].getDescription(),

fileExtensionFilters[x].getExtensions()

);

}

hBox = new HBoxInputBoxWithFileChooser(eachProperty.getDisplayName(), textField, null,

extensionFilters);

controlNode = textField;

}

else if(eachProperty.getControlType() == ControlType.TEXT_FIELD)

{

controlNode= new TextField(eachProperty.getRawValue());

hBox.getChildren().add(controlNode);

}

else if(eachProperty.getControlType() == ControlType.TEXT_FIELD_MASKED)

{

PasswordField textField = new PasswordField();

textField.setText(eachProperty.getRawValue());

controlNode= textField;

hBox.getChildren().add(controlNode);

}

else if(eachProperty.getControlType() == ControlType.TOGGLE)

{

ToggleButton toggleButton = new ToggleButton();

toggleButton.setSelected(eachProperty.getBoolValue());

if(eachProperty.getBoolValue())

toggleButton.setText("ON");

else

toggleButton.setText("OFF");

toggleButton.selectedProperty().addListener((observableValue, aBoolean, t1) -> {

if(t1)

toggleButton.setText("ON");

else

toggleButton.setText("OFF");

});

controlNode = toggleButton;

hBox.getChildren().add(controlNode);

}

else if(eachProperty.getControlType() == ControlType.SLIDER_DOUBLE)

{

Slider slider = new Slider();

slider.setValue(eachProperty.getDoubleValue());

slider.setMax(eachProperty.getMaxDoubleValue());

slider.setMin(eachProperty.getMinDoubleValue());

controlNode = slider;

hBox.getChildren().add(controlNode);

}

else if(eachProperty.getControlType() == ControlType.SLIDER_INTEGER)

{

Slider slider = new Slider();

slider.setValue(eachProperty.getIntValue());

slider.setMax(eachProperty.getMaxIntValue());

slider.setMin(eachProperty.getMinIntValue());

slider.setBlockIncrement(1.0);

slider.setSnapToTicks(true);

controlNode = slider;

hBox.getChildren().add(controlNode);

}

UIPropertyBox clientProperty = new UIPropertyBox(i, eachProperty.getDisplayName(), controlNode,

eachProperty.getControlType(), eachProperty.getType(), eachProperty.isCanBeBlank());

actionClientProperties.add(clientProperty);

clientPropertiesVBox.getChildren().add(hBox);

}

public void onSaveButtonClicked()

{

try

{

validateForm();

saveAction(true, true);

}

catch (MinorException e)

{

exceptionAndAlertHandler.handleMinorException(e);

}

private boolean sendIcon = false;

@Override

public void setSendIcon(boolean sendIcon)

{

this.sendIcon = sendIcon;

}

public void addActionToCurrentClientProfile(Action newAction) throws CloneNotSupportedException {

getClientProfile().addAction(newAction);

}

@Override

public synchronized void saveAction(Action action, boolean runAsync, boolean runOnActionSavedFromServer)

{

String delayBeforeRunning = "0";

if(action.getActionType() != ActionType.FOLDER && action.getActionType() !=ActionType.COMBINE)

delayBeforeRunning =delayBeforeRunningTextField.getText();

new OnSaveActionTask(

ClientConnections.getInstance().getClientConnectionBySocketAddress(

getClient().getRemoteSocketAddress()

action, delayBeforeRunning,

displayNameTextField.getText(),

isCombineChild(),

!hideDisplayTextCheckBox.isSelected(),

displayTextColourDefaultCheckBox.isSelected(),

"#" + displayTextColourPicker.getValue().toString().substring(2),

clearIconButton.isDisable(),

hideDefaultIconCheckBox.isSelected(),

hideToggleOffIconCheckBox.isSelected(),

hideToggleOnIconCheckBox.isSelected(),

displayTextAlignmentComboBox.getSelectionModel().getSelectedItem(),

actionBackgroundColourTransparentCheckBox.isSelected(),

"#" + actionBackgroundColourPicker.getValue().toString().substring(2),

getCombineActionPropertiesPane(),

clientProfile, sendIcon, actionBox, actionClientProperties, exceptionAndAlertHandler,

saveButton, deleteButton, resetToDefaultsButton, runOnActionSavedFromServer, runAsync, this

);

}

@Override

public void saveAction(boolean runAsync, boolean runOnActionSavedFromServer)

{

saveAction(getAction(), runAsync, runOnActionSavedFromServer);

}

public void setFolderButtonVisible(boolean visible)

{

openFolderButton.setVisible(visible);

}

public void setResetToDefaultsButtonVisible(boolean visible)

{

resetToDefaultsButton.setVisible(visible);

}

public void validateForm() throws MinorException

{

String displayNameStr = displayNameTextField.getText();

StringBuilder finalErrors = new StringBuilder();

if(displayNameStr.isBlank())

{

finalErrors.append(" * Display Name cannot be blank\n");

}

if(!isCombineChild())

{

if(getAction().getActionType() == ActionType.NORMAL)

{

if(getAction().isHasIcon())

{

if(hideDisplayTextCheckBox.isSelected() && hideDefaultIconCheckBox.isSelected())

{

finalErrors.append(" * Both Icon and display text check box cannot be hidden.\n");

}

else

{

if(hideDisplayTextCheckBox.isSelected())

finalErrors.append(" * Display Text cannot be hidden, since there is also no icon.\n");

}

if(getAction().getActionType() == ActionType.NORMAL)

{

try

{

int n = Integer.parseInt(delayBeforeRunningTextField.getText());

if (n<0)

{

finalErrors.append(" * Sleep should be greater than 0.\n");

}

catch (Exception e)

{

finalErrors.append(" * Sleep should be a number.\n");

}

for (UIPropertyBox clientProperty : actionClientProperties) {

Node controlNode = clientProperty.getControlNode();

if (clientProperty.getControlType() == ControlType.TEXT_FIELD ||

clientProperty.getControlType() == ControlType.FILE_PATH)

{

String value = ((TextField) controlNode).getText();

if(clientProperty.getType() == Type.INTEGER)

{

try

{

Integer.parseInt(value);

}

catch (NumberFormatException e)

{

finalErrors.append(" -> ").append(clientProperty.getDisplayName()).append(" must be integer.\n");

}

else

{

if(value.isBlank() && !clientProperty.isCanBeBlank())

finalErrors.append(" -> ").append(clientProperty.getDisplayName()).append(" cannot be blank.\n");

}

if(!finalErrors.toString().isEmpty())

{

throw new MinorException("You made mistakes",

finalErrors.toString());

}

@Override

public void onDeleteButtonClicked()

{

StreamPiAlert streamPiAlert = new StreamPiAlert(

"Warning",

"Are you sure you want to delete the action?",

StreamPiAlertType.WARNING

);

String optionYes = "Yes";

String optionNo = "No";

streamPiAlert.setButtons(optionYes, optionNo);

ActionDetailsPane actionDetailsPane = this;

streamPiAlert.setOnClicked(new StreamPiAlertListener() {

@Override

public void onClick(String s) {

if(s.equals(optionYes))

{

new OnDeleteActionTask(

ClientConnections.getInstance().getClientConnectionBySocketAddress(

getClient().getRemoteSocketAddress()

action,

isCombineChild(),

getCombineActionPropertiesPane(),

clientProfile, actionBox, actionDetailsPane, exceptionAndAlertHandler,

!isCombineChild

);

}

});

streamPiAlert.show();

}

M src/main/java/com/stream_pi/server/window/dashboard/actiondetailpane/OnDeleteActionTask.java

+4 −9

package com.stream_pi.server.window.dashboard.actiondetailpane;

import java.util.logging.Logger;

import com.stream_pi.action_api.action.Action;

import com.stream_pi.action_api.externalplugin.ExternalPlugin;

import com.stream_pi.server.client.ClientProfile;

import com.stream_pi.server.connection.ClientConnection;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

import com.stream_pi.server.window.dashboard.actiongridpane.ActionBox;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.exception.SevereException;

import javafx.application.Platform;

import javafx.concurrent.Task;

public class OnDeleteActionTask extends Task<Void>

{

private Logger logger;

public OnDeleteActionTask(ClientConnection connection, Action action, boolean isCombineChild,

CombineActionPropertiesPane combineActionPropertiesPane, ClientProfile clientProfile, ActionBox actionBox,

ActionDetailsPane actionDetailsPane,

ExceptionAndAlertHandler exceptionAndAlertHandler, boolean runAsync)

{

this.connection = connection;

this.action = action;

this.isCombineChild = isCombineChild;

this.combineActionPropertiesPane = combineActionPropertiesPane;

this.clientProfile = clientProfile;

this.actionBox = actionBox;

this.actionDetailsPane = actionDetailsPane;

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

logger = Logger.getLogger(getClass().getName());

if(runAsync)

new Thread(this).start();

else

runTask();

}

private ClientConnection connection;

private Action action;

private ActionBox actionBox;

private ActionDetailsPane actionDetailsPane;

private boolean isCombineChild;

private ClientProfile clientProfile;

private CombineActionPropertiesPane combineActionPropertiesPane;

private ExceptionAndAlertHandler exceptionAndAlertHandler;

private void runTask()

{

try {

if(action instanceof ExternalPlugin)

{

try

{

((ExternalPlugin) action).onActionDeleted();

}

catch (Exception e)

catch (MinorException e)

{

e.printStackTrace();

e.setTitle("Unable to run onActionDeleted for "+action.getModuleName());

e.setShortMessage("Display Text: "+action.getDisplayText()+"\nDetailed message : \n\n"+e.getShortMessage());

exceptionAndAlertHandler.handleMinorException(

exceptionAndAlertHandler.handleMinorException(e);

new MinorException(

"Unable to run onActionDeleted for "+action.getModuleName(),

"Detailed message : "+e.getMessage()

)

);

}

Action a = clientProfile.getActionByID(action.getID());

if(a instanceof ExternalPlugin)

{

try

{

((ExternalPlugin) a).onActionDeleted();

}

catch (Exception e)

{

e.printStackTrace();

exceptionAndAlertHandler.handleMinorException(

new MinorException("failed at onActionDeleted for "+a.getModuleName(),

"Detailed Message : "+e.getMessage())

);

}

connection.deleteAction(clientProfile.getID(), action.getID());

clientProfile.removeActionByID(action.getID());

if(isCombineChild)

{

System.out.println("ACTION ID TO BE REMOVED : "+action.getID());

combineActionPropertiesPane.getCombineAction().removeChild(action.getID());

System.out.println("222155 "+combineActionPropertiesPane.getCombineAction().getClientProperties().getSize());

combineActionPropertiesPane.renderProps();

try {

System.out.println(combineActionPropertiesPane.getCombineAction().getDisplayText());

connection.saveActionDetails(clientProfile.getID(), combineActionPropertiesPane.getCombineAction());

actionDetailsPane.onActionClicked(

combineActionPropertiesPane.getCombineAction(),

actionBox

);

} catch (MinorException e) {

e.printStackTrace();

}

else

{

Platform.runLater(()->{

actionBox.clear();

actionDetailsPane.clear();

});

}

// Platform.runLater(()->{

// saveButton.setDisable(false);

// deleteButton.setDisable(false);

// });

}

catch (SevereException e)

{

e.printStackTrace();

exceptionAndAlertHandler.handleSevereException(e);

}

catch (MinorException e)

{

e.printStackTrace();

exceptionAndAlertHandler.handleMinorException(e);

}

@Override

protected Void call() throws Exception

{

runTask();

return null;

}

M src/main/java/com/stream_pi/server/window/dashboard/actiondetailpane/OnSaveActionTask.java

+4 −4

package com.stream_pi.server.window.dashboard.actiondetailpane;

import java.util.ArrayList;

import java.util.List;

import java.util.logging.Logger;

import com.stream_pi.action_api.action.Action;

import com.stream_pi.action_api.action.ActionType;

import com.stream_pi.action_api.action.DisplayTextAlignment;

import com.stream_pi.action_api.actionproperty.ClientProperties;

import com.stream_pi.action_api.actionproperty.property.Property;

import com.stream_pi.action_api.actionproperty.property.Type;

import com.stream_pi.action_api.externalplugin.ExternalPlugin;

import com.stream_pi.server.client.ClientProfile;

import com.stream_pi.server.connection.ClientConnection;

import com.stream_pi.server.uipropertybox.UIPropertyBox;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

import com.stream_pi.server.window.dashboard.actiongridpane.ActionBox;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.exception.SevereException;

import javafx.application.Platform;

import javafx.concurrent.Task;

import javafx.scene.control.Button;

public class OnSaveActionTask extends Task<Void>

{

private Logger logger;

public OnSaveActionTask(ClientConnection connection, Action action, String delayBeforeRunningString, String displayNameText, boolean isCombineChild,

boolean isShowDisplayText, boolean isDefaultDisplayTextColour, String displayTextFontColour, boolean isClearIcon,

boolean isHideDefaultIcon, boolean isHideToggleOffIcon, boolean isHideToggleOnIcon, DisplayTextAlignment displayTextAlignment, boolean isTransparentBackground, String backgroundColour,

CombineActionPropertiesPane combineActionPropertiesPane, ClientProfile clientProfile, boolean sendIcon, ActionBox actionBox,

ArrayList<UIPropertyBox> actionClientProperties, ExceptionAndAlertHandler exceptionAndAlertHandler, Button saveButton, Button deleteButton, Button resetButton,

boolean runOnActionSavedFromServer, boolean runAsync, ActionDetailsPaneListener actionDetailsPaneListener)

{

this.saveButton = saveButton;

this.deleteButton = deleteButton;

this.resetButton = resetButton;

this.delayBeforeRunningString = delayBeforeRunningString;

this.connection = connection;

this.action = action;

this.displayNameText = displayNameText;

this.isCombineChild = isCombineChild;

this.isShowDisplayText = isShowDisplayText;

this.isDefaultDisplayTextColour = isDefaultDisplayTextColour;

this.displayTextFontColour = displayTextFontColour;

this.isClearIcon = isClearIcon;

this.isHideDefaultIcon = isHideDefaultIcon;

this.isHideToggleOffIcon = isHideToggleOffIcon;

this.isHideToggleOnIcon = isHideToggleOnIcon;

this.displayTextAlignment = displayTextAlignment;

this.isTransparentBackground = isTransparentBackground;

this.combineActionPropertiesPane = combineActionPropertiesPane;

this.clientProfile = clientProfile;

this.sendIcon = sendIcon;

this.actionBox = actionBox;

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

this.backgroundColour = backgroundColour;

this.actionClientProperties = actionClientProperties;

this.runOnActionSavedFromServer = runOnActionSavedFromServer;

this.actionDetailsPaneListener = actionDetailsPaneListener;

logger = Logger.getLogger(getClass().getName());

if(runAsync)

new Thread(this).start();

else

runTask();

}

private boolean runOnActionSavedFromServer;

private ActionDetailsPaneListener actionDetailsPaneListener;

private Button saveButton;

private Button deleteButton;

private Button resetButton;

private String delayBeforeRunningString;

private boolean isShowDisplayText;

private boolean isCombineChild;

private String displayNameText;

private boolean isDefaultDisplayTextColour;

private ArrayList<UIPropertyBox> actionClientProperties;

private String displayTextFontColour;

private boolean isClearIcon;

private boolean isHideDefaultIcon;

private boolean isHideToggleOffIcon;

private boolean isHideToggleOnIcon;

private DisplayTextAlignment displayTextAlignment;

private boolean isTransparentBackground;

private String backgroundColour;

private CombineActionPropertiesPane combineActionPropertiesPane;

private ClientProfile clientProfile;

private boolean sendIcon;

private ActionBox actionBox;

private ExceptionAndAlertHandler exceptionAndAlertHandler;

private Action action;

private ClientConnection connection;

private void setSaveDeleteResetButtonState(boolean state)

{

Platform.runLater(()->{

resetButton.setDisable(state);

saveButton.setDisable(state);

deleteButton.setDisable(state);

});

}

private void runTask()

{

action.setDisplayText(displayNameText);

if(!isCombineChild)

{

setSaveDeleteResetButtonState(true);

action.setShowDisplayText(isShowDisplayText);

if(isDefaultDisplayTextColour)

action.setDisplayTextFontColourHex("");

else

{

action.setDisplayTextFontColourHex(displayTextFontColour);

//String fontColour = "#" + displayTextColourPicker.getValue().toString().substring(2);

//action.setDisplayTextFontColourHex(fontColour);

}

if(isClearIcon)

{

action.getIcons().clear();

action.setCurrentIconState("");

}

if(action.getActionType() == ActionType.NORMAL ||

action.getActionType() == ActionType.FOLDER ||

action.getActionType() == ActionType.COMBINE)

{

if(isHideDefaultIcon)

{

action.setCurrentIconState("");

}

else

{

if(action.getIcon("default") != null)

action.setCurrentIconState("default");

}

else if (action.getActionType() == ActionType.TOGGLE)

{

action.setCurrentIconState(isHideToggleOffIcon+"__"+isHideToggleOnIcon);

}

action.setDisplayTextAlignment(displayTextAlignment);

if(isTransparentBackground)

action.setBgColourHex("");

else

{

action.setBgColourHex(backgroundColour);

}

System.out.println("parent : "+action.getParent());

if(action.getActionType() == ActionType.COMBINE)

{

List<String> finalChildren = combineActionPropertiesPane.getFinalChildren();

System.out.println("2334 "+finalChildren.size());

ClientProperties clientProperties = new ClientProperties();

for(int i = 0;i<finalChildren.size();i++)

{

Property property = new Property(i+"", Type.STRING);

property.setRawValue(finalChildren.get(i));

clientProperties.addProperty(property);

}

action.getClientProperties().set(clientProperties);

}

else

{

if(action.getActionType() != ActionType.FOLDER)

action.setDelayBeforeExecuting(Integer.parseInt(delayBeforeRunningString));

//properties

for (UIPropertyBox clientProperty : actionClientProperties) {

action.getClientProperties().get().get(clientProperty.getIndex()).setRawValue(clientProperty.getRawValue());

}

try

{

logger.info("Saving action ... "+action.isHasIcon()+"+"+sendIcon);

if(runOnActionSavedFromServer)

{

try

{

if(action instanceof ExternalPlugin)

{

System.out.println(action.getSocketAddressForClient());

((ExternalPlugin) action).onActionSavedFromServer();

}

catch (Exception e)

catch (MinorException e)

{

e.printStackTrace();

e.setTitle("Error");

exceptionAndAlertHandler.handleMinorException(new MinorException("Error","onActionSavedFromServer() failed for "+action.getModuleName()+"\n\n"+e.getMessage()));

e.setShortMessage("onActionSavedFromServer() failed for "+action.getModuleName()+"\n\n"+e.getShortMessage());

exceptionAndAlertHandler.handleMinorException(e);

}

connection.saveActionDetails(clientProfile.getID(), action);

if(sendIcon)

{

sendAllIcons(clientProfile, action);

}

if(!isCombineChild)

{

Platform.runLater(()->{

// actionBox.clear();

actionBox.setAction(action);

//actionBox.baseInit();

actionBox.init();

});

setSaveDeleteResetButtonState(false);

}

clientProfile.removeActionByID(action.getID());

clientProfile.addAction(action);

Platform.runLater(actionDetailsPaneListener::refresh);

}

catch (SevereException e)

{

e.printStackTrace();

exceptionAndAlertHandler.handleSevereException(e);

}

catch (Exception e)

{

e.printStackTrace();

}

private void sendAllIcons(ClientProfile clientProfile, Action action) throws SevereException

{

for(String state : action.getIcons().keySet())

{

System.out.println("Sending icon " +state+" -> "+action.getID()+ "-> "+clientProfile.getID());

connection.sendIcon(clientProfile.getID(), action.getID(), state, action.getIcon(state));

}

@Override

protected Void call() throws Exception

{

runTask();

return null;

}

Public

server

Clone or download

Updated according to the latest Action API

Modified Files