server

Fix #61

Download Browse

+52 −9

Author

Debayan Sutradhar (rnayabed) 2021-06-15 14:26

Committer

Debayan Sutradhar (rnayabed) 2021-06-15 14:26

Hash c4a78c94f624f53e118cf8013c51dfee26a5ced3

Parent 9ad30b8c61629ee750709736855b8149086e300c

Reference git #server/c4a78c94f624f53e118cf8013c51dfee26a5ced3

Modified Files

List

Side by side diff

Inline diff

M src/main/java/com/stream_pi/server/client/Client.java

+16 −1

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.client;

import com.stream_pi.util.platform.Platform;

import com.stream_pi.util.platform.ReleaseStatus;

import com.stream_pi.util.version.Version;

import javafx.geometry.Orientation;

import java.net.SocketAddress;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

public class Client

{

private String nickName;

private final SocketAddress remoteSocketAddress;

private final Platform platform;

private final Version version;

private final Version commStandardVersion;

private final Version themeAPIVersion;

private final ReleaseStatus releaseStatus;

private double displayHeight, displayWidth;

private final HashMap<String,ClientProfile> profiles;

private final HashMap<String,ClientTheme> themes;

private String defaultProfileID;

private String defaultThemeFullName;

public Client(Version version, ReleaseStatus releaseStatus, Version commStandardVersion, Version themeAPIVersion, String nickName, Platform platform, SocketAddress remoteSocketAddress)

private Orientation orientation;

public Client(Version version, ReleaseStatus releaseStatus, Version commStandardVersion,

Version themeAPIVersion, String nickName, Platform platform, SocketAddress remoteSocketAddress,

Orientation orientation)

{

this.version = version;

this.releaseStatus = releaseStatus;

this.commStandardVersion = commStandardVersion;

this.themeAPIVersion = themeAPIVersion;

this.nickName = nickName;

this.remoteSocketAddress = remoteSocketAddress;

this.platform = platform;

this.profiles = new HashMap<>();

this.themes = new HashMap<>();

this.orientation = orientation;

}

public ReleaseStatus getReleaseStatus() {

return releaseStatus;

}

public void setDefaultThemeFullName(String defaultThemeFullName) {

this.defaultThemeFullName = defaultThemeFullName;

}

public String getDefaultThemeFullName() {

return defaultThemeFullName;

}

public void setDefaultProfileID(String ID)

{

defaultProfileID = ID;

}

public void addTheme(ClientTheme clientTheme) throws CloneNotSupportedException

{

themes.put(clientTheme.getThemeFullName(), (ClientTheme) clientTheme.clone());

}

public ArrayList<ClientTheme> getThemes()

{

ArrayList<ClientTheme> clientThemes = new ArrayList<>();

for(String clientTheme : themes.keySet())

{

clientThemes.add(themes.get(clientTheme));

}

return clientThemes;

}

public ClientTheme getThemeByFullName(String fullName)

{

return themes.getOrDefault(fullName, null);

}

public String getDefaultProfileID()

{

return defaultProfileID;

}

//client Profiles

public void setNickName(String nickName)

{

this.nickName = nickName;

}

public List<ClientProfile> getAllClientProfiles()

{

ArrayList<ClientProfile> clientProfiles = new ArrayList<>();

for(String profile : profiles.keySet())

clientProfiles.add(profiles.get(profile));

return clientProfiles;

}

public void removeProfileFromID(String ID)

{

profiles.remove(ID);

}

public void addProfile(ClientProfile clientProfile) throws CloneNotSupportedException {

profiles.put(clientProfile.getID(), (ClientProfile) clientProfile.clone());

}

public synchronized ClientProfile getProfileByID(String ID) {

return profiles.getOrDefault(ID, null);

}

public SocketAddress getRemoteSocketAddress()

{

return remoteSocketAddress;

}

public Platform getPlatform()

{

return platform;

}

public String getNickName()

{

return nickName;

}

public Version getVersion()

{

return version;

}

public Version getCommStandardVersion()

{

return commStandardVersion;

}

public Version getThemeAPIVersion()

{

return themeAPIVersion;

}

public double getDisplayHeight()

{

return displayHeight;

}

public double getDisplayWidth()

{

return displayWidth;

}

public void setDisplayHeight(double height)

{

displayHeight = height;

}

public void setDisplayWidth(double width)

{

displayWidth = width;

}

private int getMaxRows(int eachActionSize)

{

return (int) (displayHeight / eachActionSize);

}

public int getMaxCols(int eachActionSize)

{

return (int) (displayWidth / eachActionSize);

}

public void setOrientation(Orientation orientation)

{

this.orientation = orientation;

}

public Orientation getOrientation()

{

return orientation;

}

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

+12 −1

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.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.controller.ServerListener;

import com.stream_pi.server.info.ServerInfo;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

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 javafx.geometry.Orientation;

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 (MinorException e)

{

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

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

exceptionAndAlertHandler.handleMinorException(e);

}

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 = new Client(clientVersion, releaseStatus, commsStandard, themesStandard, ar[4],

Platform.valueOf(ar[7]), socket.getRemoteSocketAddress(), Orientation.valueOf(ar[10]));

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;

case "client_orientation": updateClientOrientation(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 updateClientOrientation(Message message) throws MinorException

{

getClient().setOrientation(Orientation.valueOf(message.getStringValue()));

javafx.application.Platform.runLater(()-> serverListener.getDashboardBase().reDrawProfile());

}

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);

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 (MinorException e)

{

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

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

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)

{

temporaryProfilesCheck = null;

sendMessage(new Message("ready"));

}

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)

{

String[] r = message.getStringArrValue();

String profileID = r[0];

String actionID = r[1];

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

serverListener.onActionClicked(getClient(), profileID, actionID, toggle);

}

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/io/Config.java

+7 −3

Config.java

Contributor(s) : Debayan Sutradhar (@rnayabed)

handler for config.xml

package com.stream_pi.server.io;

import java.awt.*;

import java.io.File;

import java.lang.reflect.Array;

import java.util.Arrays;

import java.util.Objects;

import java.util.logging.Logger;

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 com.stream_pi.server.Main;

import com.stream_pi.server.info.ServerInfo;

import com.stream_pi.util.exception.SevereException;

import com.stream_pi.util.iohelper.IOHelper;

import com.stream_pi.util.xmlconfighelper.XMLConfigHelper;

import org.w3c.dom.Document;

import org.w3c.dom.Element;

import org.w3c.dom.Node;

public class Config

{

private static Config instance = null;

private final File configFile;

private Document document;

private Config() throws SevereException {

private Config() throws SevereException

try {

{

try

{

configFile = new File(ServerInfo.getInstance().getPrePath()+"config.xml");

DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance();

DocumentBuilder docBuilder = docFactory.newDocumentBuilder();

document = docBuilder.parse(configFile);

} catch (Exception e) {

}

catch (Exception e)

{

e.printStackTrace();

throw new SevereException("Config", "Unable to read config.xml\n"+e.getMessage());

}

public static synchronized Config getInstance() throws SevereException

{

if(instance == null)

instance = new Config();

return instance;

}

public static void nullify()

{

instance = null;

}

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

public void save() throws SevereException {

try {

logger.info("Saving config ...");

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

Result output = new StreamResult(configFile);

Source input = new DOMSource(document);

transformer.transform(input, output);

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

} catch (Exception e) {

throw new SevereException("Config", "unable to save config.xml");

}

//Getters

//comms

private Element getCommsElement()

{

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

}

public String getServerName()

{

return XMLConfigHelper.getStringProperty(getCommsElement(), "name",

getDefaultServerName(), false, true, document, configFile);

}

public int getPort()

{

return XMLConfigHelper.getIntProperty(getCommsElement(), "port",

getDefaultPort(), false, true, document, configFile);

}

//default getters

public String getDefaultServerName()

{

return "Stream-Pi Server";

}

public static int getDefaultPort()

{

return 6504;

}

//server

private Element getDividerPositionsElement()

{

return (Element) document.getElementsByTagName("divider-positions").item(0);

}

public String getDefaultLeftDividerPositions()

{

return "3.0";

}

public double[] getLeftDividerPositions()

{

String[] strArr = XMLConfigHelper.getStringProperty(getDividerPositionsElement(), "left",

getDefaultLeftDividerPositions(), false, true, document, configFile)

.split(",");

double[] r = new double[strArr.length];

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

{

r[i] = Double.parseDouble(strArr[i]);

}

return r;

}

public void setLeftDividerPositions(double[] position)

{

String r = Arrays.toString(position);

getDividerPositionsElement().getElementsByTagName("left").item(0).setTextContent(r.substring(1, r.length()-1));

}

public String getDefaultRightDividerPositions()

{

return "3.0";

}

public double[] getRightDividerPositions()

{

String[] strArr = XMLConfigHelper.getStringProperty(getDividerPositionsElement(), "right",

getDefaultRightDividerPositions(), false, true, document, configFile)

.split(",");

double[] r = new double[strArr.length];

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

{

r[i] = Double.parseDouble(strArr[i]);

}

return r;

}

public void setRightDividerPositions(double[] position)

{

String r = Arrays.toString(position);

getDividerPositionsElement().getElementsByTagName("right").item(0).setTextContent(r.substring(1, r.length()-1));

}

private Element getActionGridElement()

{

return (Element) document.getElementsByTagName("action-grid").item(0);

}

public int getActionGridActionGap()

{

return XMLConfigHelper.getIntProperty(getActionGridElement(), "gap",

getDefaultActionGridActionGap(), false, true, document, configFile);

}

public int getActionGridActionSize()

{

return XMLConfigHelper.getIntProperty(getActionGridElement(), "size",

getDefaultActionGridSize(), false, true, document, configFile);

}

public String getCurrentThemeFullName()

{

return XMLConfigHelper.getStringProperty(document, "current-theme-full-name",

getDefaultCurrentThemeFullName(), false, true, document, configFile);

}

public String getThemesPath()

{

return XMLConfigHelper.getStringProperty(document, "themes-path",

getDefaultThemesPath(), false, true, document, configFile);

}

public String getPluginsPath()

{

return XMLConfigHelper.getStringProperty(document, "plugins-path",

getDefaultPluginsPath(), false, true, document, configFile);

}

//default getters

public String getDefaultCurrentThemeFullName()

{

return "com.stream_pi.defaultlight";

}

public String getDefaultThemesPath()

{

return ServerInfo.getInstance().getPrePath()+"Themes/";

}

public String getDefaultPluginsPath()

{

return ServerInfo.getInstance().getPrePath()+"Plugins/";

}

//server > startup-window-size

private Element getStartupWindowSizeElement()

{

return (Element) document.getElementsByTagName("startup-window-size").item(0);

}

public double getStartupWindowWidth()

{

return XMLConfigHelper.getDoubleProperty(getStartupWindowSizeElement(), "width",

getDefaultStartupWindowWidth(), false, true, document, configFile);

}

public double getStartupWindowHeight()

{

return XMLConfigHelper.getDoubleProperty(getStartupWindowSizeElement(), "height",

getDefaultStartupWindowHeight(), false, true, document, configFile);

}

//default getters

public int getDefaultStartupWindowWidth()

{

return 1024;

}

public int getDefaultStartupWindowHeight()

{

return 768;

}

//sound on action clicked

private Element getSoundOnActionClickedElement()

{

return (Element) document.getElementsByTagName("sound-on-action-clicked").item(0);

}

//others

private Element getOthersElement()

{

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

}

public boolean getStartOnBoot()

{

return XMLConfigHelper.getBooleanProperty(getOthersElement(), "start-on-boot",

getDefaultStartOnBoot(), false, true, document, configFile);

}

public boolean getMinimiseToSystemTrayOnClose()

{

return XMLConfigHelper.getBooleanProperty(getOthersElement(), "minimize-to-tray-on-close",

getDefaultMinimiseToSystemTrayOnClose(), false, true, document, configFile);

}

public boolean isFirstTimeUse()

{

return XMLConfigHelper.getBooleanProperty(getOthersElement(), "first-time-use", true, false, true, document, configFile);

}

public boolean isAllowDonatePopup()

{

return XMLConfigHelper.getBooleanProperty(getOthersElement(), "allow-donate-popup", true, false, true, document, configFile);

}

//default getters

public boolean getDefaultStartOnBoot()

{

return false;

}

public boolean getDefaultMinimiseToSystemTrayOnClose()

{

return true;

}

//Setters

//comms

public void setServerName(String name)

{

getCommsElement().getElementsByTagName("name").item(0).setTextContent(name);

}

public void setServerPort(int port)

{

getCommsElement().getElementsByTagName("port").item(0).setTextContent(port+"");

}

//server

public int getDefaultActionGridActionGap()

{

return 5;

}

public int getDefaultActionGridSize()

{

return 100;

}

public void setActionGridSize(int size)

{

getActionGridElement().getElementsByTagName("size").item(0).setTextContent(size+"");

}

public void setActionGridGap(int size)

{

getActionGridElement().getElementsByTagName("gap").item(0).setTextContent(size+"");

}

public void setPluginsPath(String path)

{

document.getElementsByTagName("plugins-path").item(0).setTextContent(path);

}

public void setThemesPath(String path)

{

document.getElementsByTagName("themes-path").item(0).setTextContent(path);

}

public void setCurrentThemeFullName(String themeName)

{

document.getElementsByTagName("current-theme-full-name").item(0).setTextContent(themeName);

}

//server > startup-window-size

public void setStartupWindowSize(double width, double height)

{

setStartupWindowWidth(width);

setStartupWindowHeight(height);

}

public void setStartupWindowWidth(double width)

{

getStartupWindowSizeElement().getElementsByTagName("width").item(0).setTextContent(width+"");

}

public void setStartupWindowHeight(double height)

{

getStartupWindowSizeElement().getElementsByTagName("height").item(0).setTextContent(height+"");

}

//others

public void setStartupOnBoot(boolean value)

{

getOthersElement().getElementsByTagName("start-on-boot").item(0).setTextContent(value+"");

}

public void setMinimiseToSystemTrayOnClose(boolean value)

{

getOthersElement().getElementsByTagName("minimize-to-tray-on-close").item(0).setTextContent(value+"");

}

public void setFirstTimeUse(boolean value)

{

getOthersElement().getElementsByTagName("first-time-use").item(0).setTextContent(value+"");

}

public void setAllowDonatePopup(boolean value)

{

getOthersElement().getElementsByTagName("allow-donate-popup").item(0).setTextContent(value+"");

}

public static void unzipToDefaultPrePath() throws Exception

{

IOHelper.unzip(Objects.requireNonNull(Main.class.getResourceAsStream("Default.zip")), ServerInfo.getInstance().getPrePath());

Config config = Config.getInstance();

config.setThemesPath(config.getDefaultThemesPath());

config.setPluginsPath(config.getDefaultPluginsPath());

if(SystemTray.isSupported())

{

config.setMinimiseToSystemTrayOnClose(true);

}

config.save();

}

public void setShowAlertsPopup(boolean value)

{

getOthersElement().getElementsByTagName("alerts-popup").item(0).setTextContent(value+"");

}

public boolean isShowAlertsPopup()

{

return XMLConfigHelper.getBooleanProperty(getOthersElement(), "alerts-popup", getDefaultIsShowAlertsPopup(), false, true, document, configFile);

}

public boolean getDefaultIsShowAlertsPopup()

{

return true;

}

public void setSoundOnActionClickedStatus(boolean value)

{

getSoundOnActionClickedElement().getElementsByTagName("status").item(0).setTextContent(value+"");

}

public boolean getSoundOnActionClickedStatus()

{

return XMLConfigHelper.getBooleanProperty(getSoundOnActionClickedElement(), "status", getDefaultSoundOnActionClickedStatus(), false, true, document, configFile);

}

public boolean getDefaultSoundOnActionClickedStatus()

{

return false;

}

public void setSoundOnActionClickedFilePath(String value)

{

getSoundOnActionClickedElement().getElementsByTagName("file-path").item(0).setTextContent(value);

}

public String getSoundOnActionClickedFilePath()

{

return XMLConfigHelper.getStringProperty(getSoundOnActionClickedElement(), "file-path", getDefaultSoundOnActionClickedFilePath(), false, true, document, configFile);

}

public String getDefaultSoundOnActionClickedFilePath()

{

return null; //To be replaced with a real default beep sound later.

}

M src/main/java/com/stream_pi/server/window/dashboard/DashboardBase.java

+5 −2

package com.stream_pi.server.window.dashboard;

import java.util.logging.Logger;

import com.stream_pi.server.client.ClientProfile;

import com.stream_pi.server.connection.ClientConnection;

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

import com.stream_pi.server.window.dashboard.actiondetailpane.ActionDetailsPane;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

import com.stream_pi.util.exception.SevereException;

import javafx.application.HostServices;

import javafx.geometry.Orientation;

import javafx.scene.control.SplitPane;

import javafx.scene.layout.HBox;

import javafx.scene.layout.Priority;

import javafx.scene.layout.VBox;

public class DashboardBase extends SplitPane implements DashboardInterface {

private final SplitPane leftSplitPane;

private Logger logger;

public ClientProfile currentClientProfile;

private ExceptionAndAlertHandler exceptionAndAlertHandler;

public DashboardBase(ExceptionAndAlertHandler exceptionAndAlertHandler, HostServices hostServices)

{

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

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

leftSplitPane = new SplitPane();

leftSplitPane.getStyleClass().add("dashboard_left_split_pane");

leftSplitPane.setOrientation(Orientation.VERTICAL);

getStyleClass().add("dashboard_right_split_pane");

getItems().add(leftSplitPane);

setPluginsPane(new PluginsPane(hostServices));

setClientDetailsPane(new ClientAndProfileSelectorPane(this));

setActionGridPane(new ActionGridPane(exceptionAndAlertHandler));

setActionDetailsPane(new ActionDetailsPane(exceptionAndAlertHandler, hostServices, getActionGridPane()));

getActionGridPane().setActionDetailsPaneListener(getActionDetailsPane());

}

private PluginsPane pluginsPane;

private void setPluginsPane(PluginsPane pluginsPane)

{

this.pluginsPane = pluginsPane;

getItems().add(this.pluginsPane);

}

public PluginsPane getPluginsPane()

{

return pluginsPane;

}

private ClientAndProfileSelectorPane clientAndProfileSelectorPane;

private void setClientDetailsPane(ClientAndProfileSelectorPane clientAndProfileSelectorPane)

{

this.clientAndProfileSelectorPane = clientAndProfileSelectorPane;

leftSplitPane.getItems().add(this.clientAndProfileSelectorPane);

}

public ClientAndProfileSelectorPane getClientAndProfileSelectorPane()

{

return clientAndProfileSelectorPane;

}

private ActionGridPane actionGridPane;

private void setActionGridPane(ActionGridPane actionGridPane)

{

this.actionGridPane = actionGridPane;

leftSplitPane.getItems().add(this.actionGridPane);

}

public ActionGridPane getActionGridPane()

{

return actionGridPane;

}

private ActionDetailsPane actionDetailsPane;

private void setActionDetailsPane(ActionDetailsPane actionDetailsPane)

{

this.actionDetailsPane = actionDetailsPane;

leftSplitPane.getItems().add(this.actionDetailsPane);

}

public ActionDetailsPane getActionDetailsPane()

{

return actionDetailsPane;

}

public void newSelectedClientConnection(ClientConnection clientConnection)

{

if(clientConnection == null)

{

logger.info("Remove action grid");

}

else

{

getActionDetailsPane().setClientConnection(clientConnection);

getActionGridPane().setClientConnection(clientConnection);

}

public void newSelectedClientProfile(ClientProfile clientProfile)

{

this.currentClientProfile = clientProfile;

getActionDetailsPane().setClientProfile(clientProfile);

drawProfile(this.currentClientProfile);

}

public void reDrawProfile()

{

drawProfile(getActionGridPane().getCurrentProfile());

}

public void drawProfile(ClientProfile clientProfile)

{

logger.info("Drawing ...");

getActionGridPane().setClientProfile(clientProfile);

try

{

getActionGridPane().setFreshRender(true);

getActionGridPane().renderGrid();

getActionGridPane().renderActions();

}

catch (SevereException e)

{

exceptionAndAlertHandler.handleSevereException(e);

}

public SplitPane getLeftSplitPane()

{

return leftSplitPane;

}

M src/main/java/com/stream_pi/server/window/dashboard/actiongridpane/ActionGridPane.java

+12 −2

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

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.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.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.io.Config;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

import com.stream_pi.server.window.dashboard.actiondetailpane.ActionDetailsPaneListener;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.exception.SevereException;

import javafx.geometry.Insets;

import javafx.geometry.Orientation;

import javafx.geometry.Pos;

import javafx.scene.CacheHint;

import javafx.scene.Node;

import javafx.scene.control.ScrollPane;

import javafx.scene.layout.*;

import org.kordamp.ikonli.javafx.FontIcon;

import java.util.HashMap;

import java.util.logging.Logger;

public class ActionGridPane extends ScrollPane implements ActionGridPaneListener {

private ExceptionAndAlertHandler exceptionAndAlertHandler;

private ActionDetailsPaneListener actionDetailsPaneListener;

public ActionGridPane(ExceptionAndAlertHandler exceptionAndAlertHandler)

{

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

actionBoxHashMap = new HashMap<>();

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

getStyleClass().add("action_grid_pane_parent");

actionsGridPane = new GridPane();

actionsGridPane.setPadding(new Insets(5.0));

actionsGridPane.getStyleClass().add("action_grid_pane");

actionsGridPane.setPrefSize(USE_COMPUTED_SIZE, USE_COMPUTED_SIZE);

setContent(actionsGridPane);

setCache(true);

setCacheHint(CacheHint.SPEED);

}

private HashMap<String, ActionBox> actionBoxHashMap;

public ActionBox getActionBoxByIDAndProfileID(String actionID, String profileID)

{

// Returns null when there is no such action available

if(getClientProfile() == null)

{

return null;

}

if(!getClientProfile().getID().equals(profileID))

{

return null;

}

return actionBoxHashMap.getOrDefault(actionID, null);

}

public void setActionDetailsPaneListener(ActionDetailsPaneListener actionDetailsPaneListener) {

this.actionDetailsPaneListener = actionDetailsPaneListener;

}

private String currentParent = null;

@Override

public ExternalPlugin createNewActionFromExternalPlugin(String moduleName) throws Exception

{

ExternalPlugin newAction = ExternalPlugins.getInstance().getPluginByModuleName(moduleName).clone();

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

{

newAction.setCurrentIconState("false__false");

}

newAction.setIDRandom();

newAction.setShowDisplayText(true);

newAction.setDisplayText("Untitled Action");

newAction.setDisplayTextAlignment(DisplayTextAlignment.CENTER);

newAction.setBgColourHex("");

newAction.setDisplayTextFontColourHex("");

return newAction;

}

@Override

public Action createNewOtherAction(ActionType actionType) throws Exception

{

Action newAction;

String displayText;

if(actionType == ActionType.FOLDER)

{

displayText = "Untitled Folder";

newAction = new FolderAction();

}

else if(actionType == ActionType.COMBINE)

{

displayText = "Untitled Combine";

newAction = new CombineAction();

}

else

throw new IllegalArgumentException("External Plugins are not supported here!");

newAction.setIDRandom();

newAction.setShowDisplayText(true);

newAction.setDisplayText(displayText);

newAction.setDisplayTextAlignment(DisplayTextAlignment.CENTER);

newAction.setBgColourHex("");

newAction.setDisplayTextFontColourHex("");

return newAction;

}

@Override

public void setCurrentParent(String currentParent) {

this.currentParent = currentParent;

}

@Override

public ClientConnection getClientConnection() {

return clientConnection;

}

public ClientProfile getClientProfile() {

return clientProfile;

}

private ClientConnection clientConnection;

public void setClientConnection(ClientConnection clientConnection)

{

this.clientConnection = clientConnection;

}

public Client getClient() {

return getClientConnection().getClient();

}

private int rows, cols;

private GridPane actionsGridPane;

private ClientProfile clientProfile;

public void setClientProfile(ClientProfile clientProfile)

{

this.clientProfile = clientProfile;

setCurrentParent("root");

setRows(clientProfile.getRows());

setCols(clientProfile.getCols());

}

@Override

public String getCurrentParent() {

return currentParent;

}

@Override

public ClientProfile getCurrentProfile() {

return clientProfile;

}

public StackPane getFolderBackButton() throws SevereException

{

StackPane stackPane = new StackPane();

stackPane.getStyleClass().add("action_box");

stackPane.getStyleClass().add("action_box_valid");

stackPane.setPrefSize(

Config.getInstance().getActionGridActionSize(),

Config.getInstance().getActionGridActionSize()

);

FontIcon fontIcon = new FontIcon("fas-chevron-left");

fontIcon.getStyleClass().add("folder_action_back_button_icon");

fontIcon.setIconSize((int) (Config.getInstance().getActionGridActionSize() * 0.8));

stackPane.setAlignment(Pos.CENTER);

stackPane.getChildren().add(fontIcon);

stackPane.setOnMouseClicked(e->returnToPreviousParent());

return stackPane;

}

private ActionBox[][] actionBoxes;

private boolean isFreshRender = true;

private Node folderBackButton = null;

public void renderGrid() throws SevereException

{

actionsGridPane.setHgap(Config.getInstance().getActionGridActionGap());

actionsGridPane.setVgap(Config.getInstance().getActionGridActionGap());

if(isFreshRender)

{

clear();

actionBoxes = new ActionBox[cols][rows];

}

boolean isFolder = false;

if(getCurrentParent().equals("root"))

{

if(folderBackButton != null)

{

actionsGridPane.getChildren().remove(folderBackButton);

folderBackButton = null;

actionBoxes[0][0] = addBlankActionBox(0,0);

}

else

{

isFolder = true;

if(folderBackButton != null)

{

actionsGridPane.getChildren().remove(folderBackButton);

folderBackButton = null;

}

else

{

actionsGridPane.getChildren().remove(actionBoxes[0][0]);

}

folderBackButton = getFolderBackButton();

actionsGridPane.add(folderBackButton, 0,0);

}

for(int row = 0; row<rows; row++)

{

for(int col = 0; col<cols; col++)

{

if(row == 0 && col == 0 && isFolder)

continue;

if(isFreshRender)

{

actionBoxes[col][row] = addBlankActionBox(col, row);

}

else

{

if(actionBoxes[col][row].getAction() != null)

{

actionBoxes[col][row].clear();

}

isFreshRender = false;

}

public void setFreshRender(boolean freshRender)

{

isFreshRender = freshRender;

}

public ActionBox addBlankActionBox(int col, int row) throws SevereException {

public ActionBox addBlankActionBox(int col, int row) throws SevereException

{

ActionBox actionBox = new ActionBox(Config.getInstance().getActionGridActionSize(), actionDetailsPaneListener, this,

col, row);

actionsGridPane.add(actionBox, col, row);

if(getClient().getOrientation() == Orientation.HORIZONTAL)

{

actionsGridPane.add(actionBox, col, row);

}

else

{

actionsGridPane.add(actionBox, row, col);

}

return actionBox;

}

public void renderActions()

{

StringBuilder errors = new StringBuilder();

for(String action1x : getClientProfile().getActionsKeySet())

{

Action eachAction = getClientProfile().getActionByID(action1x);

logger.info("action ID : "+eachAction.getID()+

"\nInvalid : "+eachAction.isInvalid());

try {

renderAction(eachAction);

}

catch (SevereException e)

{

exceptionAndAlertHandler.handleSevereException(e);

}

catch (MinorException e)

{

errors.append("*").append(e.getShortMessage()).append("\n");

}

if(!errors.toString().isEmpty())

{

exceptionAndAlertHandler.handleMinorException(new MinorException("Error while rendering following actions", errors.toString()));

}

public void clear()

{

actionBoxHashMap.clear();

actionsGridPane.getChildren().clear();

}

private Logger logger;

public void renderAction(Action action) throws SevereException, MinorException

{

if(!action.getParent().equals(currentParent))

{

logger.info("Skipping action "+action.getID()+", not current parent!");

return;

}

if(action.getLocation().getRow()==-1)

{

logger.info("action has -1 rowIndex. Probably Combine action. Skipping ...");

return;

}

if(action.getLocation().getRow() >= rows || action.getLocation().getCol() >= cols)

{

throw new MinorException("action "+action.getDisplayText()+" ("+action.getID()+") falls outside bounds.\n" +

" Consider increasing rows/cols from client settings and relocating/deleting it.");

}

Location location = action.getLocation();

ActionBox actionBox = actionBoxes[location.getCol()][location.getRow()];

actionBox.clear();

actionBox.setAction(action);

actionBox.init();

actionBoxHashMap.put(action.getID(), actionBox);

/*ActionBox actionBox = new ActionBox(Config.getInstance().getActionGridActionSize(), action, actionDetailsPaneListener, exceptionAndAlertHandler, this);

Location location = action.getLocation();

actionBox.setStreamPiParent(currentParent);

actionBox.setRow(location.getRow());

actionBox.setCol(location.getCol());

for(Node node : actionsGridPane.getChildren())

{

if(GridPane.getColumnIndex(node) == location.getRow() &&

GridPane.getRowIndex(node) == location.getCol())

{

actionsGridPane.getChildren().remove(node);

break;

}

System.out.println(location.getCol()+","+location.getRow());

actionsGridPane.add(actionBox, location.getRow(), location.getCol());*/

}

public void setRows(int rows)

{

this.rows = rows;

}

public void setCols(int cols)

{

this.cols = cols;

}

public int getRows()

{

return rows;

}

public int getCols()

{

return cols;

}

@Override

public void addActionToCurrentClientProfile(Action newAction) {

try {

getClientProfile().addAction(newAction);

} catch (CloneNotSupportedException e) {

e.printStackTrace();

}

private String previousParent;

public void setPreviousParent(String previousParent) {

this.previousParent = previousParent;

}

public String getPreviousParent() {

return previousParent;

}

@Override

public void renderFolder(FolderAction action) {

setCurrentParent(action.getID());

setPreviousParent(action.getParent());

try {

renderGrid();

renderActions();

} catch (SevereException e) {

e.printStackTrace();

}

public void returnToPreviousParent()

{

setCurrentParent(getPreviousParent());

if(!getPreviousParent().equals("root"))

{

System.out.println("parent : "+getPreviousParent());

setPreviousParent(getClientProfile().getActionByID(

getPreviousParent()

).getParent());

}

try {

renderGrid();

renderActions();

} catch (SevereException e) {

e.printStackTrace();

}

Public

server

Clone or download

Fix #61

Modified Files