client

work

Download Browse

+141 −81

Author

Debayan Sutradhar (rnayabed) 2021-02-12 15:56

Committer

Debayan Sutradhar (rnayabed) 2021-02-12 15:56

Hash 30a6bcf2d99fb258bddef6fda77dc8f2be6bc317

Parent 595089abf23645218bfa4a7ac47071f8c2264e1c

Reference git #client/30a6bcf2d99fb258bddef6fda77dc8f2be6bc317

Modified Files

List

Side by side diff

Inline diff

M pom.xml

+11 −18

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

<groupId>com.stream-pi</groupId>

<artifactId>client</artifactId>

<version>1.0.0-SNAPSHOT</version>

<url>https://stream-pi.com/</url>

<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

<maven.compiler.release>11</maven.compiler.release>

<javafx.version>16-ea+6</javafx.version>

<client.plugin.version>0.1.36</client.plugin.version>

<ikonli.version>11.5.0</ikonli.version>

<action.api.version>1.0.0-SNAPSHOT</action.api.version>

<util.version>1.0.0-SNAPSHOT</util.version>

<theme.api.version>1.0.0-SNAPSHOT</theme.api.version>

<main.class.name>com.stream_pi.client.Main</main.class.name>

</properties>

<groupId>org.openjfx</groupId>

<artifactId>javafx-controls</artifactId>

<version>${javafx.version}</version>

</dependency>

<groupId>org.kordamp.ikonli</groupId>

<artifactId>ikonli-fontawesome5-pack</artifactId>

<version>${ikonli.version}</version>

</dependency>

<groupId>org.kordamp.ikonli</groupId>

<artifactId>ikonli-javafx</artifactId>

<version>${ikonli.version}</version>

</dependency>

<groupId>com.stream-pi</groupId>

<artifactId>action-api</artifactId>

<version>${action.api.version}</version>

</dependency>

<groupId>com.stream-pi</groupId>

<artifactId>theme-api</artifactId>

<version>${theme.api.version}</version>

</dependency>

<groupId>com.stream-pi</groupId>

<version>${util.version}</version>

</dependency>

<groupId>com.gluonhq.attach</groupId>

<artifactId>lifecycle</artifactId>

</dependency>

<groupId>com.gluonhq.attach</groupId>

</dependency>

<groupId>org.apache.commons</groupId>

<artifactId>commons-lang3</artifactId>

</dependency>

</dependencies>

<id>gluon-releases</id>

<url>http://nexus.gluonhq.com/nexus/content/repositories/releases/</url>

</repository>

</repositories>

<build>

<groupId>org.apache.maven.plugins</groupId>

<artifactId>maven-compiler-plugin</artifactId>

</plugin>

<groupId>org.openjfx</groupId>

<artifactId>javafx-maven-plugin</artifactId>

<mainClass>${main.class.name}</mainClass>

</configuration>

</plugin>

<groupId>com.gluonhq</groupId>

<artifactId>client-maven-plugin</artifactId>

<version>${client.plugin.version}</version>

<target>${clientTarget}</target>

<target>android</target>

<list>--initialize-at-build-time=com.sun.org.apache.xml.internal.serializer.ToXMLStream</list>

<list>${additionalArgs}</list>

<list>-Dsvm.targetName=android</list>

</nativeImageArgs>

<list>com.sun.org.apache.xerces.internal.impl.msg.XMLMessages</list>

</bundlesList>

<list>lifecycle</list>

</attachList>

<list>java.util.logging.FileHandler</list>

</reflectionList>

<mainClass>${main.class.name}</mainClass>

</configuration>

</plugin>

<artifactId>maven-resources-plugin</artifactId>

</configuration>

</plugin>

</plugins>

</build>

<!--profiles>

<id>android</id>

<clientTarget>android</clientTarget>

<additionalArgs>-Dsvm.targetName=android</additionalArgs>

</properties>

</profile>

<clientTarget>linux-aarch64</clientTarget>

<additionalArgs>-Dsvm.targetName=linux_raspberrypi</additionalArgs>

</properties>

</profile>

</profiles-->

<id>windows64</id>

<clientTarget>windows</clientTarget>

<additionalArgs>-Dsvm.targetName=windows</additionalArgs>

</properties>

</profile>

<id>linux64</id>

<additionalArgs>-Dsvm.targetName=linux</additionalArgs>

</properties>

</profile>

</profiles>

<id>gluon-releases</id>

<url>http://nexus.gluonhq.com/nexus/content/repositories/releases/</url>

</pluginRepository>

<id>gluon-snapshots</id>

<url>https://nexus.gluonhq.com/nexus/content/repositories/public-snapshots</url>

</pluginRepository>

</pluginRepositories>

</project>

M src/main/java/com/stream_pi/client/Main.java

+14 −4

package com.stream_pi.client;

import com.stream_pi.client.controller.Controller;

import com.stream_pi.client.info.ClientInfo;

import javafx.application.Application;

import javafx.scene.Scene;

import javafx.stage.Stage;

public class Main extends Application {

@Override

public void start(Stage stage)

{

Controller d = new Controller();

Scene s = new Scene(d);

stage.setScene(s);

d.init();

}

public static void main(String[] args)

{

for(String eachArg : args)

{

String[] r = eachArg.split("=");

if(r[0].equals("-DStreamPi.startupRunnerFileName"))

String arg = r[0];

ClientInfo.getInstance().setRunnerFileName(r[1]);

String val = r[1];

else if(r[0].equals("-DStreamPi.showShutDownButton"))

ClientInfo.getInstance().setShowShutDownButton(r[1].equals("true"));

switch (arg) {

case "-DStreamPi.startupRunnerFileName":

ClientInfo.getInstance().setRunnerFileName(val);

break;

case "-DStreamPi.showShutDownButton":

ClientInfo.getInstance().setShowShutDownButton(val.equals("true"));

break;

case "-DStreamPi.isXMode":

ClientInfo.getInstance().setXMode(val.equals("true"));

break;

}

launch(args);

}

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

+35 −24

package com.stream_pi.client.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.client.io.Config;

import com.stream_pi.client.info.ClientInfo;

import com.stream_pi.client.profile.ClientProfile;

import com.stream_pi.client.window.ExceptionAndAlertHandler;

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

import com.stream_pi.theme_api.Theme;

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.version.Version;

import javafx.application.Platform;

import javafx.concurrent.Task;

import org.apache.commons.lang3.ArrayUtils;

import java.io.*;

import java.net.InetSocketAddress;

import java.net.Socket;

import java.util.ArrayList;

import java.util.concurrent.atomic.AtomicBoolean;

import java.util.logging.Logger;

public class Client extends Thread{

private Socket socket;

private ObjectOutputStream oos;

private ObjectInputStream ois;

private final AtomicBoolean stop = new AtomicBoolean(false);

private final ClientListener clientListener;

private final ExceptionAndAlertHandler exceptionAndAlertHandler;

private final ClientInfo clientInfo;

private final String serverIP;

private final int serverPort;

private final Logger logger;

public Client(String serverIP, int serverPort, ClientListener clientListener, ExceptionAndAlertHandler exceptionAndAlertHandler)

{

this.serverIP = serverIP;

this.serverPort = serverPort;

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

this.clientInfo = ClientInfo.getInstance();

this.clientListener = clientListener;

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

new Thread(new Task<Void>() {

@Override

protected Void call()

{

try

{

try

{

logger.info("Trying to connect to server at "+serverIP+":"+serverPort);

socket = new Socket();

socket.connect(new InetSocketAddress(serverIP, serverPort), 5000);

clientListener.setConnected(true);

clientListener.updateSettingsConnectDisconnectButton();

logger.info("Connected to "+socket.getRemoteSocketAddress()+" !");

}

catch (IOException e)

{

e.printStackTrace();

clientListener.setConnected(false);

clientListener.updateSettingsConnectDisconnectButton();

throw new MinorException("Connection Error", "Unable to connect to server. Please check settings and connection and try again.");

}

try

{

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

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

}

catch (IOException e)

{

logger.severe(e.getMessage());

e.printStackTrace();

throw new MinorException("Unable to set up io Streams to server. Check connection and try again.");

}

start();

} catch (MinorException e)

{

exceptionAndAlertHandler.handleMinorException(e);

}

return null;

}

}).start();

}

public synchronized void exit()

{

if(stop.get())

return;

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

try

{

if(socket!=null)

{

disconnect();

}

catch (SevereException e)

{

logger.severe(e.getMessage());

exceptionAndAlertHandler.handleSevereException(e);

e.printStackTrace();

}

public synchronized void sendMessage(Message message) throws SevereException

{

try

{

oos.writeObject(message);

oos.flush();

}

catch (IOException e)

{

e.printStackTrace();

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

}

@Override

public void run() {

try

{

while(!stop.get())

{

try

{

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

String header = message.getHeader();

logger.info("Message Received. Heading : "+header);

switch (header)

{

case "action_icon" : onActionIconReceived(message);

break;

case "disconnect" : serverDisconnected(message);

break;

case "get_client_details" : sendClientDetails();

break;

case "get_profiles" : sendProfileNamesToServer();

break;

case "get_profile_details": sendProfileDetailsToServer(message);

break;

case "save_action_details": saveActionDetails(message);

break;

case "delete_action": deleteAction(message);

break;

case "get_themes": sendThemesToServer();

break;

case "save_client_details": saveClientDetails(message);

break;

case "save_client_profile": saveProfileDetails(message);

break;

case "delete_profile": deleteProfile(message);

break;

case "action_failed": actionFailed(message);

break;

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

}

catch (IOException | ClassNotFoundException e)

{

logger.severe(e.getMessage());

e.printStackTrace();

clientListener.setConnected(false);

clientListener.updateSettingsConnectDisconnectButton();

if(!stop.get())

{

//isDisconnect.set(true); //Prevent running disconnect

throw new MinorException("Accidentally disconnected from Server! (Failed at readUTF)");

}

exit();

return;

}

catch (SevereException e)

{

logger.severe(e.getMessage());

e.printStackTrace();

exceptionAndAlertHandler.handleSevereException(e);

}

catch (MinorException e)

{

logger.severe(e.getMessage());

e.printStackTrace();

exceptionAndAlertHandler.handleMinorException(e);

}

private void onActionIconReceived(Message message)

{

String profileID = message.getStringArrValue()[0];

String actionID = message.getStringArrValue()[1];

clientListener.getClientProfiles().getProfileFromID(profileID).saveActionIcon(

actionID,

message.getByteArrValue()

ArrayUtils.toPrimitive(message.getByteArrValue())

);

Action a = clientListener.getClientProfiles().getProfileFromID(profileID).getActionFromID(actionID);

clientListener.clearActionBox(a.getLocation().getCol(), a.getLocation().getRow());

clientListener.renderAction(profileID, a);

}

//commands

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

{

try

{

Thread.sleep(50);

}

catch (InterruptedException e)

{

e.printStackTrace();

}

Message message = new Message("action_icon");

message.setStringArrValue(profileID, actionID);

message.setByteArrValue(icon);

message.setByteArrValue(ArrayUtils.toObject(icon));

sendMessage(message);

}

public void disconnect() throws SevereException

{

disconnect("");

}

public void disconnect(String message) throws SevereException

{

if(stop.get())

return;

stop.set(true);

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

Message m = new Message("disconnect");

m.setStringValue(message);

sendMessage(m);

try

{

if(!socket.isClosed())

socket.close();

clientListener.setConnected(false);

clientListener.updateSettingsConnectDisconnectButton();

}

catch (IOException e)

{

e.printStackTrace();

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

}

public void sendThemesToServer() throws SevereException

{

Message message = new Message("themes");

String[] arr = new String[clientListener.getThemes().getThemeList().size()*4];

int x = 0;

for(int i = 0;i<clientListener.getThemes().getThemeList().size();i++)

{

Theme theme = clientListener.getThemes().getThemeList().get(i);

arr[x] = theme.getFullName();

arr[x+1] = theme.getShortName();

arr[x+2] = theme.getAuthor();

arr[x+3] = theme.getVersion().getText();

x+=4;

}

message.setStringArrValue(arr);

sendMessage(message);

}

public void sendActionIcon(String clientProfileID, String actionID) throws SevereException

{

System.out.println("sending action icon "+clientProfileID+", "+actionID);

sendIcon(clientProfileID, actionID, clientListener.getClientProfiles().getProfileFromID(clientProfileID).getActionFromID(actionID).getIconAsByteArray());

}

public void serverDisconnected(Message message)

{

stop.set(true);

String txt = "Disconnected!";

String m = message.getStringValue();

if(!m.isBlank())

txt = "Message : "+m;

exceptionAndAlertHandler.onAlert("Disconnected from Server", txt, StreamPiAlertType.WARNING);

if(!socket.isClosed()) {

try {

socket.close();

} catch (IOException e) {

e.printStackTrace();

}

clientListener.setConnected(false);

clientListener.updateSettingsConnectDisconnectButton();

}

public void sendClientDetails() throws SevereException

{

String clientVersion = clientInfo.getVersion().getText();

String releaseStatus = clientInfo.getReleaseStatus().toString();

String clientCommsStandard = clientInfo.getCommsStandardVersion().getText();

String clientMinThemeStandard = clientInfo.getMinThemeSupportVersion().getText();

String clientNickname = Config.getInstance().getClientNickName();

String screenWidth = Config.getInstance().getStartupWindowWidth()+"";

String screenHeight = Config.getInstance().getStartupWindowHeight()+"";

String OS = clientInfo.getPlatformType()+"";

String defaultProfileID = Config.getInstance().getStartupProfileID();

Message toBeSent = new Message("client_details");

toBeSent.setStringArrValue(

clientVersion,

releaseStatus,

clientCommsStandard,

clientMinThemeStandard,

clientNickname,

screenWidth,

screenHeight,

OS,

defaultProfileID,

clientListener.getDefaultThemeFullName()

);

sendMessage(toBeSent);

}

public void sendProfileNamesToServer() throws SevereException

{

Message message = new Message("profiles");

String[] arr = new String[clientListener.getClientProfiles().getClientProfiles().size()];

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

{

ClientProfile clientProfile = clientListener.getClientProfiles().getClientProfiles().get(i);

arr[i] = clientProfile.getID();

}

message.setStringArrValue(arr);

sendMessage(message);

}

public void sendProfileDetailsToServer(Message message) throws SevereException

{

String ID = message.getStringValue();

Message tbs1 = new Message("profile_details");

ClientProfile clientProfile = clientListener.getClientProfiles().getProfileFromID(ID);

String[] arr = new String[]{

ID,

clientProfile.getName(),

clientProfile.getRows()+"",

clientProfile.getCols()+"",

clientProfile.getActionSize()+"",

clientProfile.getActionGap()+""

};

tbs1.setStringArrValue(arr);

sendMessage(tbs1);

for(Action action : clientProfile.getActions())

{

sendActionDetails(clientProfile.getID(), action);

}

for(Action action : clientProfile.getActions())

{

if(action.isHasIcon())

{

sendActionIcon(clientProfile.getID(), action.getID());

}

public void sendActionDetails(String profileID, Action action) throws SevereException {

if(action == null)

{

logger.info("NO SUCH ACTION");

return;

}

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

a.add(profileID);

a.add(action.getID());

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

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

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

}

else

{

a.add("no");

}

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

{

a.add(action.getModuleName());

}

else

{

a.add("nut");

}

//display

a.add(action.getBgColourHex());

//icon

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

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

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

//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("action_details");

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

x = a.toArray(x);

message.setStringArrValue(x);

sendMessage(message);

}

public void saveActionDetails(Message message)

{

String[] r = message.getStringArrValue();

String profileID = r[0];

String actionID = r[1];

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

//3 - Version

//4 - ModuleName

//display

String bgColorHex = r[5];

//icon

boolean isHasIcon = r[6].equals("true");

boolean isShowIcon = r[7].equals("true");

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

Action action = new Action(actionID, actionType);

if(actionType == ActionType.NORMAL)

{

try

{

action.setVersion(new Version(r[3]));

action.setModuleName(r[4]);

}

catch (Exception e)

{

logger.severe(e.getMessage());

e.printStackTrace();

}

action.setBgColourHex(bgColorHex);

action.setShowIcon(isShowIcon);

action.setHasIcon(isHasIcon);

System.out.println("IS HAS ICON : "+isHasIcon+", IS SHOW ICON :"+isShowIcon);

action.setShowDisplayText(isShowDisplayText);

action.setDisplayTextFontColourHex(displayFontColor);

action.setDisplayText(displayText);

action.setDisplayTextAlignment(displayTextAlignment);

action.setLocation(location);

String parent = r[14];

action.setParent(parent);

//client properties

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

ClientProperties clientProperties = new ClientProperties();

if(actionType == ActionType.FOLDER)

clientProperties.setDuplicatePropertyAllowed(true);

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

{

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

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

clientProperties.addProperty(property);

}

action.setClientProperties(clientProperties);

try

{

Action old = clientListener.getClientProfiles().getProfileFromID(profileID).getActionFromID(action.getID());

if(old != null)

{

if(action.isHasIcon())

action.setIcon(clientListener.getClientProfiles().getProfileFromID(profileID).getActionFromID(action.getID()).getIconAsByteArray());

}

clientListener.getClientProfiles().getProfileFromID(profileID).addAction(action);

System.out.println("XXXXXXXXXXX " +action.isHasIcon());

clientListener.getClientProfiles().getProfileFromID(profileID).saveAction(action);

clientListener.renderAction(profileID, action);

/*if(clientListener.getCurrentProfile().getID().equals(profileID) &&

clientListener.get&& action.getLocation().getCol()!=-1)

{

javafx.application.Platform.runLater(()->{

ActionBox box = clientListener.getActionBox(action.getLocation().getCol(), action.getLocation().getRow());

System.out.println(box==null);

System.out.println("jj : "+action.getLocation().getCol()+","+action.getLocation().getRow());

if(box!=null)

{

box.clear();

box.setAction(action);

box.baseInit();

box.init();

}

});

}*/

}

catch (Exception e)

{

e.printStackTrace();

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

}

public void deleteAction(Message message)

{

try

{

String[] arr = message.getStringArrValue();

String profileID = arr[0];

String actionID = arr[1];

Action acc = clientListener.getClientProfiles().getProfileFromID(profileID).getActionFromID(actionID);

if(acc.getActionType() == ActionType.FOLDER)

{

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

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

String folderToBeDeletedID = clientListener.getClientProfiles().getProfileFromID(profileID).getActionFromID(actionID).getID();

folders.add(folderToBeDeletedID);

boolean startOver = true;

while(startOver)

{

startOver = false;

for(Action action : clientListener.getClientProfiles().getProfileFromID(profileID).getActions())

{

if(folders.contains(action.getParent()))

{

if(!idsToBeRemoved.contains(action.getID()))

{

idsToBeRemoved.add(action.getID());

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

{

folders.add(action.getID());

startOver = true;

}

for(String ids : idsToBeRemoved)

{

clientListener.getClientProfiles().getProfileFromID(profileID).removeAction(ids);

}

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

{

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

{

clientListener.getClientProfiles().getProfileFromID(profileID).removeAction(property.getRawValue());

}

clientListener.getClientProfiles().getProfileFromID(profileID).removeAction(acc.getID());

clientListener.getClientProfiles().getProfileFromID(profileID).saveActions();

if(acc.getLocation().getCol()!=-1)

{

clientListener.clearActionBox(acc.getLocation().getCol(), acc.getLocation().getRow());

String currentParent = clientListener.getCurrentParent();

clientListener.addBlankActionBox(acc.getLocation().getCol(), acc.getLocation().getRow());

if(acc.getParent().equals(currentParent))

{

clientListener.clearActionBox(acc.getLocation().getCol(), acc.getLocation().getRow());

clientListener.addBlankActionBox(acc.getLocation().getCol(), acc.getLocation().getRow());

}

if(acc.getActionType() == ActionType.FOLDER && currentParent.equals(acc.getID()))

{

Platform.runLater(()->{

try

{

clientListener.renderRootDefaultProfile();

}

catch (SevereException e)

{

e.printStackTrace();

exceptionAndAlertHandler.handleSevereException(e);

}

});

}

catch (Exception e)

{

e.printStackTrace();

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

}

public void saveClientDetails(Message message)

{

try

{

String[] sep = message.getStringArrValue();

Config.getInstance().setNickName(sep[0]);

String oldWidth = Config.getInstance().getStartupWindowWidth()+"";

String oldHeight = Config.getInstance().getStartupWindowHeight()+"";

Config.getInstance().setStartupWindowSize(

Double.parseDouble(sep[1]),

Double.parseDouble(sep[2])

);

Config.getInstance().setStartupProfileID(sep[3]);

String oldThemeFullName = Config.getInstance().getCurrentThemeFullName();

Config.getInstance().setCurrentThemeFullName(sep[4]);

if(!oldHeight.equals(sep[2]) || !oldWidth.equals(sep[1]) || !oldThemeFullName.equals(sep[4]))

javafx.application.Platform.runLater(clientListener::init);

Config.getInstance().save();

javafx.application.Platform.runLater(clientListener::loadSettings);

}

catch (SevereException e)

{

e.printStackTrace();

exceptionAndAlertHandler.handleSevereException(e);

}

public void saveProfileDetails(Message message) throws SevereException, MinorException

{

String[] sep = message.getStringArrValue();

ClientProfile clientProfile = clientListener.getClientProfiles().getProfileFromID(sep[0]);

if(clientProfile == null)

{

clientProfile = new ClientProfile(new File(Config.getInstance().getProfilesPath()+"/"+sep[0]+".xml"),

Config.getInstance().getIconsPath());

}

clientProfile.setName(sep[1]);

clientProfile.setRows(Integer.parseInt(sep[2]));

clientProfile.setCols(Integer.parseInt(sep[3]));

clientProfile.setActionSize(Integer.parseInt(sep[4]));

clientProfile.setActionGap(Integer.parseInt(sep[5]));

try

{

clientListener.getClientProfiles().addProfile(clientProfile);

clientProfile.saveProfileDetails();

clientListener.refreshGridIfCurrent(sep[0]);

javafx.application.Platform.runLater(clientListener::loadSettings);

}

catch (Exception e)

{

e.printStackTrace();

throw new SevereException(e.getMessage());

}

public void deleteProfile(Message message)

{

clientListener.getClientProfiles().deleteProfile(clientListener.getClientProfiles().getProfileFromID(

message.getStringValue()

));

}

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

{

Message m = new Message("action_clicked");

m.setStringArrValue(profileID, actionID);

sendMessage(m);

}

public void actionFailed(Message message)

{

String[] r = message.getStringArrValue();

String profileID = r[0];

String actionID = r[1];

clientListener.onActionFailed(profileID, actionID);

}

M src/main/java/com/stream_pi/client/connection/ClientListener.java

+2 −0

package com.stream_pi.client.connection;

import com.stream_pi.action_api.action.Action;

import com.stream_pi.client.profile.ClientProfile;

import com.stream_pi.client.profile.ClientProfiles;

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

import com.stream_pi.theme_api.Theme;

import com.stream_pi.theme_api.Themes;

import com.stream_pi.util.exception.SevereException;

public interface ClientListener

{

void onActionFailed(String profileID, String actionID);

void onNormalActionClicked(String profileID, String actionID);

ClientProfiles getClientProfiles();

Themes getThemes();

String getDefaultThemeFullName();

void renderRootDefaultProfile() throws SevereException;

void setConnected(boolean isConnected);

boolean isConnected();

void renderProfile(ClientProfile clientProfile);

void clearActionBox(int col, int row);

void addBlankActionBox(int col, int row);

void renderAction(String currentProfileID, Action action);

void refreshGridIfCurrent(String currentProfileID);

ActionBox getActionBox(int col, int row);

ClientProfile getCurrentProfile();

String getCurrentParent();

Theme getCurrentTheme();

void init();

void disconnect(String message) throws SevereException;

void setupClientConnection();

void updateSettingsConnectDisconnectButton();

void onCloseRequest();

void loadSettings();

}

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

+6 −0

package com.stream_pi.client.controller;

import com.stream_pi.action_api.action.Action;

import com.stream_pi.client.connection.Client;

import com.stream_pi.client.io.Config;

import com.stream_pi.client.info.ClientInfo;

import com.stream_pi.client.profile.ClientProfile;

import com.stream_pi.client.profile.ClientProfiles;

import com.stream_pi.client.window.Base;

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

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.gluonhq.attach.lifecycle.LifecycleService;

import com.gluonhq.attach.util.Services;

import javafx.animation.Interpolator;

import javafx.animation.KeyFrame;

import javafx.animation.KeyValue;

import javafx.animation.Timeline;

import javafx.application.Platform;

import javafx.scene.Node;

import javafx.util.Duration;

import java.io.*;

public class Controller extends Base

{

private Client client;

public Controller()

{

client = null;

}

private boolean firstRun = true;

@Override

public void init()

{

try

{

if(firstRun)

initBase();

applyDefaultTheme();

if(getClientInfo().getPlatformType()!= com.stream_pi.util.platform.Platform.ANDROID && getClientInfo().getPlatformType() != com.stream_pi.util.platform.Platform.IOS) {

getStage().setWidth(getConfig().getStartupWindowWidth());

getStage().setHeight(getConfig().getStartupWindowHeight());

getStage().centerOnScreen();

setupFlags();

}

setupDashWindow();

getStage().show();

requestFocus();

if(Config.getInstance().isFirstTimeUse())

return;

setupSettingsWindowsAnimations();

getDashboardPane().getSettingsButton().setOnAction(event -> {

openSettingsTimeLine.play();

});

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

closeSettingsTimeLine.play();

});

setClientProfiles(new ClientProfiles(new File(getConfig().getProfilesPath()), getConfig().getStartupProfileID()));

if(getClientProfiles().getLoadingErrors().size() > 0)

{

StringBuilder errors = new StringBuilder("Please rectify the following errors and try again");

for(MinorException exception : getClientProfiles().getLoadingErrors())

{

errors.append("\n * ")

.append(exception.getMessage());

}

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

}

renderRootDefaultProfile();

loadSettings();

if(firstRun)

{

setupClientConnection();

firstRun = false;

}

catch (SevereException e)

{

handleSevereException(e);

return;

}

catch (MinorException e)

{

handleMinorException(e);

return;

}

@Override

public void setupClientConnection()

{

Platform.runLater(()->getSettingsPane().setDisableStatus(true));

client = new Client(getConfig().getSavedServerHostNameOrIP(), getConfig().getSavedServerPort(), this, this);

}

@Override

public void updateSettingsConnectDisconnectButton() {

getSettingsPane().setConnectDisconnectButtonStatus();

}

@Override

public void disconnect(String message) throws SevereException {

client.disconnect(message);

}

public void setupDashWindow()

{

getStage().setTitle("Stream-Pi Client");

getStage().setOnCloseRequest(e->onCloseRequest());

}

@Override

public void onCloseRequest()

{

if(isConnected())

client.exit();

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

closeLogger();

if (ClientInfo.getInstance().getPlatformType() == com.stream_pi.util.platform.Platform.ANDROID)

Services.get(LifecycleService.class).ifPresent(LifecycleService::shutdown);

}

@Override

public void loadSettings() {

try {

getSettingsPane().loadData();

} catch (SevereException e) {

e.printStackTrace();

handleSevereException(e);

}

private Timeline openSettingsTimeLine;

private Timeline closeSettingsTimeLine;

private void setupSettingsWindowsAnimations()

{

Node settingsNode = getSettingsPane();

Node dashboardNode = getDashboardPane();

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 KeyFrame(Duration.millis(90.0D),

new KeyValue(settingsNode.opacityProperty(),

1.0D, Interpolator.LINEAR)),

new KeyFrame(Duration.millis(0.0D),

new KeyValue(dashboardNode.opacityProperty(),

1.0D, Interpolator.LINEAR)),

new KeyFrame(Duration.millis(90.0D),

new KeyValue(dashboardNode.opacityProperty(),

0.0D, Interpolator.LINEAR))

);

openSettingsTimeLine.setOnFinished(event1 -> settingsNode.toFront());

closeSettingsTimeLine = new Timeline();

closeSettingsTimeLine.setCycleCount(1);

closeSettingsTimeLine.getKeyFrames().addAll(

new KeyFrame(Duration.millis(0.0D),

new KeyValue(settingsNode.opacityProperty(),

1.0D, Interpolator.LINEAR)),

new KeyFrame(Duration.millis(90.0D),

new KeyValue(settingsNode.opacityProperty(),

0.0D, Interpolator.LINEAR)),

new KeyFrame(Duration.millis(0.0D),

new KeyValue(dashboardNode.opacityProperty(),

0.0D, Interpolator.LINEAR)),

new KeyFrame(Duration.millis(90.0D),

new KeyValue(dashboardNode.opacityProperty(),

1.0D, Interpolator.LINEAR))

);

closeSettingsTimeLine.setOnFinished(event1 -> {

dashboardNode.toFront();

Platform.runLater(()-> {

try {

getSettingsPane().loadData();

} catch (SevereException e) {

e.printStackTrace();

handleSevereException(e);

}

});

}

@Override

public void handleMinorException(MinorException e)

{

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

}

@Override

public void handleSevereException(SevereException e)

{

Platform.runLater(()->

{

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

alert.setOnClicked(new StreamPiAlertListener()

{

@Override

public void onClick(String txt)

{

onCloseRequest();

Platform.exit();

}

});

alert.show();

});

}

@Override

public void onAlert(String title, String body, StreamPiAlertType alertType) {

Platform.runLater(()-> genNewAlert(title, body, alertType).show());

}

public StreamPiAlert genNewAlert(String title, String message, StreamPiAlertType alertType)

{

StreamPiAlert alert = new StreamPiAlert(title, message, alertType);

return alert;

}

private boolean isConnected = false;

@Override

public void onActionFailed(String profileID, String actionID) {

Platform.runLater(()-> getDashboardPane().getActionGridPane().actionFailed(profileID, actionID));

}

@Override

public void onNormalActionClicked(String profileID, String actionID) {

try {

client.onActionClicked(profileID, actionID);

} catch (SevereException e) {

e.printStackTrace();

handleSevereException(e);

}

@Override

public void setConnected(boolean isConnected) {

this.isConnected = isConnected;

}

@Override

public ActionBox getActionBox(int col, int row)

{

return getDashboardPane().getActionGridPane().getActionBox(col, row);

}

@Override

public boolean isConnected()

{

return isConnected;

}

@Override

public void renderProfile(ClientProfile clientProfile) {

try {

getDashboardPane().renderProfile(clientProfile);

} catch (SevereException e) {

e.printStackTrace();

handleSevereException(e);

}

@Override

public void clearActionBox(int col, int row)

{

Platform.runLater(()->getDashboardPane().getActionGridPane().clearActionBox(col, row));

}

@Override

public void addBlankActionBox(int col, int row)

{

Platform.runLater(()->getDashboardPane().getActionGridPane().addBlankActionBox(col, row));

}

@Override

public void renderAction(String currentProfileID, Action action)

{

Platform.runLater(()->{

try {

if(getDashboardPane().getActionGridPane().getCurrentParent().equals(action.getParent()) &&

getDashboardPane().getActionGridPane().getClientProfile().getID().equals(currentProfileID))

{

getDashboardPane().getActionGridPane().renderAction(action);

}

catch (Exception e)

{

e.printStackTrace();

}

});

}

@Override

public void refreshGridIfCurrent(String profileID) {

ClientProfile clientProfile = getDashboardPane().getActionGridPane().getClientProfile();

if(clientProfile.getID().equals(profileID))

{

Platform.runLater(()->{

try {

getDashboardPane().renderProfile(getClientProfiles().getProfileFromID(profileID));

} catch (SevereException e) {

e.printStackTrace();

handleSevereException(e);

}

});

}

@Override

public ClientProfile getCurrentProfile() {

return getDashboardPane().getActionGridPane().getClientProfile();

}

@Override

public String getCurrentParent()

{

return getDashboardPane().getActionGridPane().getCurrentParent();

}

M src/main/java/com/stream_pi/client/info/ClientInfo.java

+11 −0

ServerInfo.java

Stores basic information about the server - name, platform type

Contributors: Debayan Sutradhar (@dubbadhar)

package com.stream_pi.client.info;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.platform.Platform;

import com.stream_pi.util.platform.ReleaseStatus;

import com.stream_pi.util.version.Version;

public class ClientInfo {

private Version version;

private final ReleaseStatus releaseStatus;

private Platform platformType = null;

private String prePath;

private Version minThemeSupportVersion;

private Version minPluginSupportVersion;

private Version commsStandardVersion;

private String runnerFileName;

private static ClientInfo instance = null;

private ClientInfo(){

try {

version = new Version("1.0.0");

minThemeSupportVersion = new Version("1.0.0");

minPluginSupportVersion = new Version("1.0.0");

commsStandardVersion = new Version("1.0.0");

} catch (MinorException e) {

e.printStackTrace();

}

releaseStatus = ReleaseStatus.EA;

if(platformType == null)

{

String osName = System.getProperty("os.name").toLowerCase();

if(osName.contains("windows"))

{

prePath = "data/";

platformType = Platform.WINDOWS;

}

else if (osName.contains("linux"))

{

if(osName.contains("raspberrypi"))

{

prePath = "data/";

platformType = Platform.LINUX_RPI;

}

else

{

prePath = "data/";

platformType = Platform.LINUX;

}

else if(osName.contains("android")) // SPECIFY -Dsvm.targetName=android WHILE BUILDING ANDROID NATIVE IMAGE

{

prePath = "/sdcard/StreamPiClient/";

platformType = Platform.ANDROID;

}

else if (osName.contains("mac"))

{

prePath = "data/";

platformType = Platform.MAC;

}

else

{

prePath = "data/";

platformType = Platform.UNKNOWN;

}

public void setRunnerFileName(String runnerFileName)

{

this.runnerFileName = runnerFileName;

}

public String getRunnerFileName()

{

return runnerFileName;

}

public static synchronized ClientInfo getInstance(){

if(instance == null)

{

instance = new ClientInfo();

}

return instance;

}

private boolean isShowShutDownButton = false;

public void setShowShutDownButton(boolean showShutDownButton) {

isShowShutDownButton = showShutDownButton;

}

private boolean isXMode = false;

public void setXMode(boolean isXMode)

{

this.isXMode = isXMode;

}

public boolean isXMode() {

return isXMode;

}

public boolean isShowShutDownButton() {

return isShowShutDownButton;

}

public String getPrePath() {

return prePath;

}

public Platform getPlatformType()

{

return platformType;

}

public Version getVersion() {

return version;

}

public ReleaseStatus getReleaseStatus()

{

return releaseStatus;

}

public Version getMinThemeSupportVersion()

{

return minThemeSupportVersion;

}

public Version getMinPluginSupportVersion()

{

return minPluginSupportVersion;

}

public Version getCommsStandardVersion()

{

return commsStandardVersion;

}

M src/main/java/com/stream_pi/client/window/Base.java

+2 −1

package com.stream_pi.client.window;

import com.stream_pi.client.connection.ClientListener;

import com.stream_pi.client.io.Config;

import com.stream_pi.client.info.ClientInfo;

import java.io.File;

import java.util.logging.Logger;

import com.stream_pi.client.Main;

import com.stream_pi.client.profile.ClientProfiles;

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

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

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

import com.stream_pi.theme_api.Theme;

import com.stream_pi.theme_api.Themes;

import com.stream_pi.util.alert.StreamPiAlert;

import com.stream_pi.util.combobox.StreamPiComboBox;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.exception.SevereException;

import com.stream_pi.util.iohelper.IOHelper;

import com.stream_pi.util.loggerhelper.StreamPiLogFallbackHandler;

import com.stream_pi.util.loggerhelper.StreamPiLogFileHandler;

import com.stream_pi.util.platform.Platform;

import javafx.geometry.Insets;

import javafx.scene.CacheHint;

import javafx.scene.Cursor;

import javafx.scene.input.KeyCombination;

import javafx.scene.layout.StackPane;

import javafx.scene.text.Font;

import javafx.stage.Stage;

public abstract class Base extends StackPane implements ExceptionAndAlertHandler, ClientListener {

private Config config;

private ClientProfiles clientProfiles;

private ClientInfo clientInfo;

private Stage stage;

public Stage getStage()

{

return stage;

}

public Logger getLogger()

{

return logger;

}

private DashboardBase dashboardBase;

private SettingsBase settingsBase;

private FirstTimeUse firstTimeUse;

public FirstTimeUse getFirstTimeUse() {

return firstTimeUse;

}

private StackPane alertStackPane;

@Override

public ClientProfiles getClientProfiles() {

return clientProfiles;

}

public void setClientProfiles(ClientProfiles clientProfiles) {

this.clientProfiles = clientProfiles;

}

private Logger logger = null;

private StreamPiLogFileHandler logFileHandler = null;

private StreamPiLogFallbackHandler logFallbackHandler = null;

public void initLogger()

{

try

{

if(logger != null || logFileHandler != null)

return;

closeLogger();

logger = Logger.getLogger("");

if(new File(ClientInfo.getInstance().getPrePath()).getAbsoluteFile().getParentFile().canWrite())

{

String path = ClientInfo.getInstance().getPrePath()+"../streampi.log";

if(ClientInfo.getInstance().getPlatformType() == Platform.ANDROID)

path = ClientInfo.getInstance().getPrePath()+"streampi.log";

logFileHandler = new StreamPiLogFileHandler(path);

logger.addHandler(logFileHandler);

}

else

{

logFallbackHandler = new StreamPiLogFallbackHandler();

logger.addHandler(logFallbackHandler);

}

catch(Exception e)

{

e.printStackTrace();

//throw new SevereException("Cant get logger started!");

}

public void closeLogger()

{

if(logFileHandler != null)

logFileHandler.close();

else if(logFallbackHandler != null)

logFallbackHandler.close();

}

public void initBase() throws SevereException

{

stage = (Stage) getScene().getWindow();

initLogger();

clientInfo = ClientInfo.getInstance();

dashboardBase = new DashboardBase(this, this);

dashboardBase.setCache(true);

dashboardBase.setCacheHint(CacheHint.SPEED);

dashboardBase.prefWidthProperty().bind(widthProperty());

dashboardBase.prefHeightProperty().bind(heightProperty());

settingsBase = new SettingsBase(this, this);

settingsBase.setCache(true);

settingsBase.setCacheHint(CacheHint.SPEED);

alertStackPane = new StackPane();

alertStackPane.setPadding(new Insets(10));

alertStackPane.setVisible(false);

StreamPiAlert.setParent(alertStackPane);

StreamPiComboBox.setParent(alertStackPane);

firstTimeUse = new FirstTimeUse(this, this);

getChildren().clear();

getChildren().addAll(settingsBase, dashboardBase, alertStackPane);

setStyle(null);

checkPrePathDirectory();

config = Config.getInstance();

if(config.isFirstTimeUse())

{

clearStylesheets();

applyDefaultStylesheet();

applyDefaultIconsStylesheet();

getChildren().add(firstTimeUse);

firstTimeUse.toFront();

}

else

{

dashboardBase.toFront();

}

registerThemes();

}

private void checkPrePathDirectory() throws SevereException

{

try

{

File filex = new File(ClientInfo.getInstance().getPrePath());

if(filex.getAbsoluteFile().getParentFile().canWrite())

{

if(!filex.exists())

{

filex.mkdirs();

IOHelper.unzip(Main.class.getResourceAsStream("Default.obj"), ClientInfo.getInstance().getPrePath());

}

else

{

clearStylesheets();

applyDefaultStylesheet();

applyDefaultIconsStylesheet();

getStage().show();

throw new SevereException("No storage permission. Give it!");

}

catch (Exception e)

{

e.printStackTrace();

throw new SevereException(e.getMessage());

}

public void setupFlags()

{

//Full Screen

if(getConfig().isFullscreen())

{

getStage().setFullScreenExitKeyCombination(KeyCombination.NO_MATCH);

getStage().setFullScreen(true);

}

else

{

getStage().setFullScreenExitKeyCombination(KeyCombination.keyCombination("Esc"));

getStage().setFullScreen(false);

}

//Cursor

if(getConfig().isShowCursor())

{

setCursor(Cursor.DEFAULT);

}

else

{

setCursor(Cursor.NONE);

}

public SettingsBase getSettingsPane() {

return settingsBase;

}

public DashboardBase getDashboardPane() {

return dashboardBase;

}

public void renderRootDefaultProfile() throws SevereException {

public void renderRootDefaultProfile() throws SevereException

{

getDashboardPane().renderProfile(getClientProfiles().getProfileFromID(

Config.getInstance().getStartupProfileID()

));

}

public void clearStylesheets()

{

getStylesheets().clear();

}

public void applyDefaultStylesheet()

{

Font.loadFont(Main.class.getResourceAsStream("Roboto.ttf"), 13);

getStylesheets().add(Main.class.getResource("style.css").toExternalForm());

}

public void applyDefaultIconsStylesheet()

{

Font.loadFont(Main.class.getResourceAsStream("Roboto.ttf"), 13);

getStylesheets().add(Main.class.getResource("default_icons.css").toExternalForm());

}

public Config getConfig()

{

return config;

}

public ClientInfo getClientInfo()

{

return clientInfo;

}

private Theme currentTheme;

@Override

public Theme getCurrentTheme()

{

return currentTheme;

}

public void applyTheme(Theme t)

{

logger.info("Applying theme '"+t.getFullName()+"' ...");

if(t.getFonts() != null)

{

for(String fontFile : t.getFonts())

{

Font.loadFont(fontFile.replace("%20",""), 13);

}

currentTheme = t;

clearStylesheets();

applyDefaultStylesheet();

getStylesheets().addAll(t.getStylesheets());

applyDefaultIconsStylesheet();

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

}

Themes themes;

public void registerThemes() throws SevereException

{

logger.info("Loading themes ...");

themes = new Themes(getConfig().getThemesPath(), getConfig().getCurrentThemeFullName(), clientInfo.getMinThemeSupportVersion());

if(themes.getErrors().size()>0)

{

StringBuilder themeErrors = new StringBuilder();

for(MinorException eachException : themes.getErrors())

{

themeErrors.append("\n * ").append(eachException.getShortMessage());

}

if(themes.getIsBadThemeTheCurrentOne())

{

themeErrors.append("\n\nReverted to default theme! (").append(getConfig().getDefaultCurrentThemeFullName()).append(")");

getConfig().setCurrentThemeFullName(getConfig().getDefaultCurrentThemeFullName());

getConfig().save();

}

handleMinorException(new MinorException("Theme Loading issues", themeErrors.toString()));

}

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

}

@Override

public Themes getThemes() {

return themes;

}

public void applyDefaultTheme()

{

logger.info("Applying default theme ...");

boolean foundTheme = false;

for(Theme t: themes.getThemeList())

{

if(t.getFullName().equals(config.getCurrentThemeFullName()))

{

foundTheme = true;

applyTheme(t);

break;

}

if(foundTheme)

{

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

}

else

{

logger.info("Theme not found. reverting to light theme ...");

try {

Config.getInstance().setCurrentThemeFullName("com.StreamPi.DefaultLight");

Config.getInstance().save();

applyDefaultTheme();

}

catch (SevereException e)

{

handleSevereException(e);

}

@Override

public String getDefaultThemeFullName()

{

return config.getCurrentThemeFullName();

}

M src/main/java/com/stream_pi/client/window/dashboard/actiongridpane/ActionBox.java

+2 −1

package com.stream_pi.client.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.client.window.ExceptionAndAlertHandler;

import javafx.animation.Interpolator;

import javafx.animation.KeyFrame;

import javafx.animation.KeyValue;

import javafx.animation.Timeline;

import javafx.geometry.Pos;

import javafx.scene.CacheHint;

import javafx.scene.control.Label;

import javafx.scene.image.Image;

import javafx.scene.layout.Background;

import javafx.scene.layout.BackgroundImage;

import javafx.scene.layout.BackgroundPosition;

import javafx.scene.layout.BackgroundRepeat;

import javafx.scene.layout.BackgroundSize;

import javafx.scene.layout.StackPane;

import javafx.scene.text.TextAlignment;

import javafx.util.Duration;

import org.kordamp.ikonli.javafx.FontIcon;

import java.io.ByteArrayInputStream;

import java.io.ObjectInputStream;

import java.nio.ByteBuffer;

public class ActionBox extends StackPane{

private Label displayTextLabel;

private int row;

private int col;

public int getRow() {

return row;

}

public int getCol() {

return col;

}

public void clear()

{

setAction(null);

setBackground(Background.EMPTY);

setStyle(null);

getChildren().clear();

}

private FontIcon statusIcon;

public void baseInit()

{

displayTextLabel = new Label();

displayTextLabel.setWrapText(true);

displayTextLabel.setTextAlignment(TextAlignment.CENTER);

displayTextLabel.getStyleClass().add("action_box_display_text_label");

displayTextLabel.prefHeightProperty().bind(heightProperty());

displayTextLabel.prefWidthProperty().bind(widthProperty());

statusIcon = new FontIcon();

statusIcon.setOpacity(0);

statusIcon.setCache(true);

statusIcon.setCacheHint(CacheHint.SPEED);

statusIcon.setIconSize(size - 30);

getChildren().addAll(statusIcon, displayTextLabel);

setMinSize(size, size);

setMaxSize(size, size);

getStyleClass().clear();

getStyleClass().add("action_box");

getStyleClass().add("action_box_icon_not_present");

getStyleClass().add("action_box_"+row+"_"+col);

setOnMouseClicked(touchEvent -> actionClicked());

setOnMousePressed(TouchEvent -> {

if(action != null)

{

getStyleClass().add("action_box_onclick");

}

});

setOnMouseReleased(TouchEvent ->{

if(action != null)

{

getStyleClass().remove("action_box_onclick");

}

});

statusIconAnimation = new Timeline(

new KeyFrame(

Duration.millis(0.0D),

new KeyValue(statusIcon.opacityProperty(), 0.0D, Interpolator.EASE_IN)),

new KeyFrame(

Duration.millis(100.0D),

new KeyValue(statusIcon.opacityProperty(), 1.0D, Interpolator.EASE_IN)),

new KeyFrame(

Duration.millis(600.0D),

new KeyValue(statusIcon.opacityProperty(), 1.0D, Interpolator.EASE_OUT)),

new KeyFrame(

Duration.millis(700.0D),

new KeyValue(statusIcon.opacityProperty(), 0.0D, Interpolator.EASE_OUT))

);

statusIconAnimation.setOnFinished(event -> {

statusIcon.toBack();

});

setCache(true);

setCacheHint(CacheHint.SPEED);

}

public void actionClicked()

{

if(action!=null)

{

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

{

getActionGridPaneListener().renderFolder(action.getID());

}

else

{

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

{

getActionGridPaneListener().combineActionClicked(action.getID());

}

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

{

getActionGridPaneListener().normalActionClicked(action.getID());

}

public FontIcon getStatusIcon() {

return statusIcon;

}

private Timeline statusIconAnimation;

public Timeline getStatusIconAnimation() {

return statusIconAnimation;

}

public ActionGridPaneListener getActionGridPaneListener() {

return actionGridPaneListener;

}

private int size;

private ActionGridPaneListener actionGridPaneListener;

public ActionBox(int size, ActionGridPaneListener actionGridPaneListener, int row, int col)

{

this.actionGridPaneListener = actionGridPaneListener;

this.size = size;

this.row = row;

this.col = col;

baseInit();

}

public static Action deserialize(ByteBuffer buffer) {

try {

ByteArrayInputStream is = new ByteArrayInputStream(buffer.array());

ObjectInputStream ois = new ObjectInputStream(is);

return (Action) ois.readObject();

} catch (Exception e) {

e.printStackTrace();

throw new RuntimeException(e);

}

public void setIcon(byte[] iconByteArray)

{

if(iconByteArray == null)

{

getStyleClass().remove("action_box_icon_present");

getStyleClass().add("action_box_icon_not_present");

setBackground(Background.EMPTY);

}

else

{

getStyleClass().add("action_box_icon_present");

getStyleClass().remove("action_box_icon_not_present");

setBackground(

new Background(

new BackgroundImage(new Image(

new ByteArrayInputStream(iconByteArray), size, size, false, true

), BackgroundRepeat.NO_REPEAT, BackgroundRepeat.NO_REPEAT, BackgroundPosition.CENTER,

new BackgroundSize(100, 100, true, true, true, false))

)

);

}

private Action action;

public Action getAction() {

return action;

}

private ExceptionAndAlertHandler exceptionAndAlertHandler;

private String parent;

public String getStreamPiParent() {

return parent;

}

public void setStreamPiParent(String parent) {

this.parent = parent;

}

public ActionBox(int size, Action action, ExceptionAndAlertHandler exceptionAndAlertHandler,

ActionGridPaneListener actionGridPaneListener, int row, int col)

{

this.actionGridPaneListener = actionGridPaneListener;

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

this.action = action;

this.size = size;

this.row = row;

this.col = col;

baseInit();

init();

}

public void setAction(Action action)

{

this.action = action;

}

public void init()

{

setDisplayTextFontColour(action.getDisplayTextFontColourHex());

if(action.isShowDisplayText())

setDisplayTextLabel(action.getDisplayText());

else

setDisplayTextLabel("");

setDisplayTextAlignment(action.getDisplayTextAlignment());

setBackgroundColour(action.getBgColourHex());

if(action.isHasIcon() && action.isShowIcon())

{

setIcon(action.getIconAsByteArray());

}

else

{

setIcon(null);

}

public void animateStatus()

{

statusIcon.toFront();

statusIconAnimation.play();

}

public void setDisplayTextLabel(String text)

{

displayTextLabel.setText(text);

}

public void setDisplayTextAlignment(DisplayTextAlignment displayTextAlignment)

{

if(displayTextAlignment == DisplayTextAlignment.CENTER)

displayTextLabel.setAlignment(Pos.CENTER);

else if (displayTextAlignment == DisplayTextAlignment.BOTTOM)

displayTextLabel.setAlignment(Pos.BOTTOM_CENTER);

else if (displayTextAlignment == DisplayTextAlignment.TOP)

displayTextLabel.setAlignment(Pos.TOP_CENTER);

}

public void setDisplayTextFontColour(String colour)

{

System.out.println("'"+colour+"'COLOR");

if(!colour.isEmpty())

{

System.out.println(

"putting ..." + Thread.currentThread().getName()

);

displayTextLabel.setStyle("-fx-text-fill : "+colour+";");

}

public void setBackgroundColour(String colour)

{

System.out.println("COLOr : "+colour);

if(!colour.isEmpty() && action.getIconAsByteArray() == null)

setStyle("-fx-background-color : "+colour);

}

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

+2 −1

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

import java.util.logging.Logger;

import com.stream_pi.action_api.action.Action;

import com.stream_pi.action_api.action.Location;

import com.stream_pi.client.connection.ClientListener;

import com.stream_pi.client.profile.ClientProfile;

import com.stream_pi.client.window.ExceptionAndAlertHandler;

import com.stream_pi.util.alert.StreamPiAlertType;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.exception.SevereException;

import javafx.concurrent.Task;

import javafx.geometry.Insets;

import javafx.geometry.Pos;

import javafx.scene.Node;

import javafx.scene.layout.GridPane;

import javafx.scene.layout.Priority;

import javafx.scene.layout.StackPane;

import javafx.scene.layout.VBox;

import javafx.scene.paint.Color;

import org.kordamp.ikonli.javafx.FontIcon;

public class ActionGridPane extends GridPane implements ActionGridPaneListener {

private ExceptionAndAlertHandler exceptionAndAlertHandler;

private ClientListener clientListener;

public ActionGridPane(ExceptionAndAlertHandler exceptionAndAlertHandler, ClientListener clientListener)

{

this.clientListener = clientListener;

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

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

getStyleClass().add("action_grid_pane");

setPadding(new Insets(5.0));

setPrefSize(USE_COMPUTED_SIZE, USE_COMPUTED_SIZE);

setAlignment(Pos.CENTER);

VBox.setVgrow(this, Priority.ALWAYS);

}

private String currentParent;

public void setCurrentParent(String currentParent) {

this.currentParent = currentParent;

}

public ClientProfile getClientProfile() {

return clientProfile;

}

private int rows, cols;

private ClientProfile clientProfile;

public void setClientProfile(ClientProfile clientProfile)

{

this.clientProfile = clientProfile;

setCurrentParent("root");

setRows(clientProfile.getRows());

setCols(clientProfile.getCols());

}

public void actionFailed(String profileID, String actionID)

{

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

{

Action action = getClientProfile().getActionFromID(actionID);

if(action != null)

{

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

{

failShow(action);

}

else

{

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

{

failShow(getClientProfile().getActionFromID(action.getParent()));

}

public void failShow(Action action)

{

for(Node node : getChildren())

{

if(GridPane.getColumnIndex(node) == action.getLocation().getRow() &&

GridPane.getRowIndex(node) == action.getLocation().getCol())

{

ActionBox actionBox = (ActionBox) node;

actionBox.getStatusIcon().setIconLiteral("fas-exclamation-triangle");

actionBox.getStatusIcon().setIconColor(Color.RED);

actionBox.animateStatus();

break;

}

public String getCurrentParent() {

return currentParent;

}

public StackPane getFolderBackButton() throws SevereException

{

StackPane stackPane = new StackPane();

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

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

stackPane.setPrefSize(

getClientProfile().getActionSize(),

getClientProfile().getActionSize()

);

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

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

fontIcon.setIconSize(getClientProfile().getActionSize() - 30);

stackPane.setAlignment(Pos.CENTER);

stackPane.getChildren().add(fontIcon);

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

return stackPane;

}

public void renderGrid() throws SevereException {

public void renderGrid() throws SevereException

{

clear();

setHgap(getClientProfile().getActionGap());

setVgap(getClientProfile().getActionGap());

boolean isFolder = false;

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

{

isFolder = true;

add(getFolderBackButton(), 0,0);

}

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

{

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

{

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

continue;

addBlankActionBox(col, row);

}

public void renderActions()

{

StringBuilder errors = new StringBuilder();

for(Action eachAction : getClientProfile().getActions())

{

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

{

getChildren().clear();

}

private Logger logger;

public void clearActionBox(int col, int row)

{

for(Node node : getChildren())

{

if(GridPane.getColumnIndex(node) == row &&

GridPane.getRowIndex(node) == col)

{

getChildren().remove(node);

break;

}

public ActionBox getActionBox(int col, int row)

{

for(Node node : getChildren())

{

if(GridPane.getColumnIndex(node) == row &&

GridPane.getRowIndex(node) == col)

{

return (ActionBox) node;

}

return null;

}

public void addBlankActionBox(int col, int row)

{

ActionBox actionBox = new ActionBox(getClientProfile().getActionSize(), this, row, col);

actionBox.setStreamPiParent(currentParent);

add(actionBox, row, col);

}

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 = new ActionBox(getClientProfile().getActionSize(), action, exceptionAndAlertHandler, this, location.getRow(), location.getCol());

actionBox.setStreamPiParent(currentParent);

clearActionBox(location.getCol(), location.getRow());

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

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;

}

private String previousParent;

public void setPreviousParent(String previousParent) {

this.previousParent = previousParent;

}

public String getPreviousParent() {

return previousParent;

}

@Override

public void renderFolder(String actionID) {

setCurrentParent(clientProfile.getActionFromID(actionID).getID());

setPreviousParent(clientProfile.getActionFromID(actionID).getParent());

try {

renderGrid();

renderActions();

} catch (SevereException e) {

e.printStackTrace();

}

@Override

public void normalActionClicked(String ID) {

if(clientListener.isConnected())

clientListener.onNormalActionClicked(getClientProfile().getID(), ID);

else

exceptionAndAlertHandler.onAlert("Not Connected", "Not Connected to any Server", StreamPiAlertType.ERROR);

}

@Override

public void combineActionClicked(String ID) {

if(clientListener.isConnected())

{

new Thread(new Task<Void>() {

@Override

protected Void call()

{

Action action = getClientProfile().getActionFromID(ID);

for(int i = 0;i<action.getClientProperties().get().size();i++)

{

try {

logger.info("Clicking "+i+", '"+action.getClientProperties().getSingleProperty(i+"").getRawValue()+"'");

normalActionClicked(action.getClientProperties().getSingleProperty(i+"").getRawValue());

} catch (MinorException e) {

e.printStackTrace();

exceptionAndAlertHandler.handleMinorException(e);

}

return null;

}

}).start();

}

public void returnToPreviousParent()

{

setCurrentParent(getPreviousParent());

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

{

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

setPreviousParent(getClientProfile().getActionFromID(

getPreviousParent()

).getParent());

}

try {

renderGrid();

renderActions();

} catch (SevereException e) {

e.printStackTrace();

}

M src/main/java/com/stream_pi/client/window/firsttimeuse/FinalConfigPane.java

+11 −7

package com.stream_pi.client.window.firsttimeuse;

import com.stream_pi.client.connection.ClientListener;

import com.stream_pi.client.io.Config;

import com.stream_pi.client.info.ClientInfo;

import com.stream_pi.client.window.ExceptionAndAlertHandler;

import com.stream_pi.util.alert.StreamPiAlert;

import com.stream_pi.util.alert.StreamPiAlertType;

import com.stream_pi.util.exception.SevereException;

import com.stream_pi.util.uihelper.HBoxInputBox;

import com.stream_pi.util.uihelper.SpaceFiller;

import com.stream_pi.util.platform.Platform;

import javafx.geometry.Pos;

import javafx.scene.control.Button;

import javafx.scene.control.Label;

import javafx.scene.control.ScrollPane;

import javafx.scene.control.TextField;

import javafx.scene.layout.HBox;

import javafx.scene.layout.Priority;

import javafx.scene.layout.VBox;

public class FinalConfigPane extends VBox

{

private TextField clientNicknameTextField;

private TextField serverIPHostNameTextField;

private TextField serverPortTextField;

private TextField displayWidthTextField;

private TextField displayHeightTextField;

private Button nextButton;

private ExceptionAndAlertHandler exceptionAndAlertHandler;

private ClientListener clientListener;

public FinalConfigPane(ExceptionAndAlertHandler exceptionAndAlertHandler, ClientListener clientListener)

public FinalConfigPane(ExceptionAndAlertHandler exceptionAndAlertHandler, ClientListener clientListener,

Button nextButton)

{

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

this.clientListener = clientListener;

this.nextButton = nextButton;

getStyleClass().add("first_time_use_pane_final_config");

Label label = new Label("Thats it. Now just a little bit and then you're set!");

label.setWrapText(true);

VBox.setVgrow(label, Priority.ALWAYS);

label.getStyleClass().add("first_time_use_pane_final_config_label");

clientNicknameTextField = new TextField();

serverIPHostNameTextField = new TextField();

serverPortTextField = new TextField();

displayWidthTextField = new TextField();

displayHeightTextField = new TextField();

HBoxInputBox clientNickNameInputBox = new HBoxInputBox("Nickname", clientNicknameTextField);

HBoxInputBox serverIPHostNameInputBox = new HBoxInputBox("Server IP", serverIPHostNameTextField);

HBoxInputBox serverIPPortInputBox = new HBoxInputBox("Server Port", serverPortTextField);

HBoxInputBox displayWidthInputBox = new HBoxInputBox("Display Width", displayWidthTextField);

HBoxInputBox displayHeightInputBox = new HBoxInputBox("Display Height", displayHeightTextField);

if(ClientInfo.getInstance().getPlatformType() == Platform.ANDROID)

{

displayWidthInputBox.setVisible(false);

displayHeightInputBox.setVisible(false);

}

Button confirmButton = new Button("Confirm");

confirmButton.setOnAction(event -> onConfirmButtonClicked());

HBox bBar = new HBox(confirmButton);

bBar.setAlignment(Pos.CENTER_RIGHT);

VBox v = new VBox(clientNickNameInputBox, serverIPHostNameInputBox, serverIPPortInputBox,

displayWidthInputBox, displayHeightInputBox);

v.setSpacing(10.0);

ScrollPane scrollPane = new ScrollPane(v);

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

v.prefWidthProperty().bind(scrollPane.widthProperty().subtract(25));

getChildren().addAll(label, scrollPane, SpaceFiller.vertical(), bBar);

getChildren().addAll(label, scrollPane);

setSpacing(10.0);

setVisible(false);

}

public void makeChangesToNextButton()

{

nextButton.setText("Confirm");

nextButton.setOnAction(event -> onConfirmButtonClicked());

}

private void onConfirmButtonClicked()

{

StringBuilder errors = new StringBuilder();

if(clientNicknameTextField.getText().isBlank())

{

errors.append("* Nick name cannot be blank.\n");

}

if(serverIPHostNameTextField.getText().isBlank())

{

errors.append("* Server IP cannot be empty.\n");

}

int port = -1;

try

{

port = Integer.parseInt(serverPortTextField.getText());

if(port < 1024)

errors.append("* Server IP should be above 1024.\n");

}

catch (NumberFormatException exception)

{

errors.append("* Server IP should be a number.\n");

}

double width=-1,height=-1;

if(ClientInfo.getInstance().getPlatformType() != Platform.ANDROID)

{

try

{

width = Double.parseDouble(displayWidthTextField.getText());

if(width < 0)

errors.append("* Display Width should be above 0.\n");

}

catch (NumberFormatException exception)

{

errors.append("* Display Width should be a number.\n");

}

try

{

height = Double.parseDouble(displayHeightTextField.getText());

if(height < 0)

errors.append("* Display Height should be above 0.\n");

}

catch (NumberFormatException exception)

{

errors.append("* Display Height should be a number.\n");

}

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

{

try

{

Config.getInstance().setNickName(clientNicknameTextField.getText());

Config.getInstance().setServerHostNameOrIP(serverIPHostNameTextField.getText());

Config.getInstance().setServerPort(port);

Config.getInstance().setFirstTimeUse(false);

if(ClientInfo.getInstance().getPlatformType() != Platform.ANDROID)

{

Config.getInstance().setStartupWindowSize(

width, height

);

}

Config.getInstance().save();

clientListener.init();

}

catch(SevereException e)

{

exceptionAndAlertHandler.handleSevereException(e);

}

else

{

new StreamPiAlert("Uh Oh", "Please rectify the following errors and try again:\n"+errors.toString(), StreamPiAlertType.ERROR).show();

}

M src/main/java/com/stream_pi/client/window/firsttimeuse/FirstTimeUse.java

+21 −19

package com.stream_pi.client.window.firsttimeuse;

import com.stream_pi.client.Main;

import com.stream_pi.client.connection.ClientListener;

import com.stream_pi.client.window.ExceptionAndAlertHandler;

import com.stream_pi.util.uihelper.SpaceFiller;

import javafx.geometry.Insets;

import javafx.scene.control.Button;

import javafx.scene.control.Label;

import javafx.scene.layout.HBox;

import javafx.scene.layout.Priority;

import javafx.scene.layout.StackPane;

import javafx.scene.layout.VBox;

import javafx.scene.text.Font;

public class FirstTimeUse extends VBox{

public FirstTimeUse(ExceptionAndAlertHandler exceptionAndAlertHandler, ClientListener clientListener)

{

Font.loadFont(Main.class.getResourceAsStream("Roboto.ttf"), 13);

getStylesheets().add(Main.class.getResource("style.css").toExternalForm());

getStyleClass().add("first_time_use_pane");

setSpacing(10.0);

setPadding(new Insets(5));

headingLabel = new Label();

headingLabel.getStyleClass().add("first_time_use_pane_heading_label");

StackPane stackPane = new StackPane();

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

VBox.setVgrow(stackPane, Priority.ALWAYS);

welcomePane = new WelcomePane();

licensePane = new LicensePane();

finalConfigPane = new FinalConfigPane(exceptionAndAlertHandler, clientListener);

stackPane.getChildren().addAll(

welcomePane,

licensePane,

finalConfigPane

);

nextButton = new Button("Next");

nextButton.setOnAction(event-> onNextButtonClicked());

previousButton = new Button("Previous");

previousButton.setOnAction(event-> onPreviousButtonClicked());

HBox buttonBar = new HBox(previousButton, SpaceFiller.horizontal(), nextButton);

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

buttonBar.setSpacing(10.0);

welcomePane = new WelcomePane();

licensePane = new LicensePane();

finalConfigPane = new FinalConfigPane(exceptionAndAlertHandler, clientListener, nextButton);

stackPane.getChildren().addAll(

welcomePane,

licensePane,

finalConfigPane

);

getChildren().addAll(headingLabel, stackPane, buttonBar);

setWindow(WindowName.WELCOME);

}

private Label headingLabel;

private Button nextButton;

private Button previousButton;

private WelcomePane welcomePane;

private LicensePane licensePane;

private FinalConfigPane finalConfigPane;

private WindowName windowName;

private void onNextButtonClicked()

{

if(windowName == WindowName.WELCOME)

{

setWindow(WindowName.LICENSE);

}

else if(windowName == WindowName.LICENSE)

{

setWindow(WindowName.FINAL);

}

private void onPreviousButtonClicked()

{

nextButton.setText("Next");

if(windowName == WindowName.FINAL)

{

setWindow(WindowName.LICENSE);

}

else if(windowName == WindowName.LICENSE)

{

setWindow(WindowName.WELCOME);

}

private void setWindow(WindowName windowName)

{

if (windowName == WindowName.WELCOME)

{

this.windowName = WindowName.WELCOME;

welcomePane.toFront();

welcomePane.setVisible(true);

licensePane.setVisible(false);

finalConfigPane.setVisible(false);

headingLabel.setText("");

nextButton.setDisable(false);

nextButton.setText("Next");

previousButton.setDisable(true);

nextButton.setOnAction(event-> onNextButtonClicked());

previousButton.setVisible(false);

}

else if (windowName == WindowName.LICENSE)

{

this.windowName = WindowName.LICENSE;

licensePane.toFront();

welcomePane.setVisible(false);

licensePane.setVisible(true);

finalConfigPane.setVisible(false);

headingLabel.setText("License Agreement");

nextButton.setDisable(false);

nextButton.setText("Agree and Continue");

previousButton.setDisable(false);

nextButton.setOnAction(event-> onNextButtonClicked());

previousButton.setVisible(true);

}

else if (windowName == WindowName.FINAL)

{

this.windowName = WindowName.FINAL;

finalConfigPane.toFront();

welcomePane.setVisible(false);

licensePane.setVisible(false);

finalConfigPane.setVisible(true);

headingLabel.setText("Finishing up ...");

nextButton.setDisable(true);

finalConfigPane.makeChangesToNextButton();

previousButton.setDisable(false);

previousButton.setVisible(true);

}

M src/main/java/com/stream_pi/client/window/firsttimeuse/LicensePane.java

+1 −5

package com.stream_pi.client.window.firsttimeuse;

import com.stream_pi.client.info.License;

import javafx.scene.control.Label;

import javafx.scene.control.TextArea;

import javafx.scene.layout.Priority;

import javafx.scene.layout.VBox;

public class LicensePane extends VBox {

public LicensePane()

{

getStyleClass().add("first_time_use_pane_license");

Label label = new Label("By clicking on 'Next' you agree with the Stream-Pi license, and, the license('s) of the library('s) used/included with this software.");

label.prefWidthProperty().bind(widthProperty());

label.setWrapText(true);

TextArea licenseTextArea = new TextArea(License.getLicense());

licenseTextArea.setWrapText(false);

licenseTextArea.setEditable(false);

licenseTextArea.prefWidthProperty().bind(widthProperty());

VBox.setVgrow(licenseTextArea, Priority.ALWAYS);

getChildren().addAll(label, licenseTextArea);

getChildren().addAll(licenseTextArea);

}

M src/main/java/com/stream_pi/client/window/settings/SettingsBase.java

+2 −1

package com.stream_pi.client.window.settings;

import java.io.File;

import com.stream_pi.client.connection.ClientListener;

import com.stream_pi.client.io.Config;

import com.stream_pi.client.info.ClientInfo;

import com.stream_pi.client.profile.ClientProfile;

import com.stream_pi.client.window.ExceptionAndAlertHandler;

import com.stream_pi.theme_api.Theme;

import com.stream_pi.util.alert.StreamPiAlert;

import com.stream_pi.util.alert.StreamPiAlertType;

import com.stream_pi.util.combobox.StreamPiComboBox;

import com.stream_pi.util.combobox.StreamPiComboBoxFactory;

import com.stream_pi.util.combobox.StreamPiComboBoxListener;

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

import com.stream_pi.util.startatboot.SoftwareType;

import com.stream_pi.util.startatboot.StartAtBoot;

import javafx.application.Platform;

import javafx.geometry.Insets;

import javafx.geometry.Pos;

import javafx.scene.control.*;

import javafx.scene.layout.HBox;

import javafx.scene.layout.Priority;

import javafx.scene.layout.VBox;

public class SettingsBase extends VBox {

private TextField serverPortTextField;

private TextField serverHostNameOrIPTextField;

private StreamPiComboBox<ClientProfile> clientProfileComboBox;

private StreamPiComboBox<Theme> themeComboBox;

private TextField displayWidthTextField;

private TextField displayHeightTextField;

private TextField nickNameTextField;

private Button closeButton;

private Button saveButton;

private Button connectDisconnectButton;

private Button shutdownButton;

private ToggleButton startOnBootToggleButton;

private ToggleButton showCursorToggleButton;

private ToggleButton fullScreenToggleButton;

private ClientListener clientListener;

private ExceptionAndAlertHandler exceptionAndAlertHandler;

private TextField themesPathTextField;

private TextField iconsPathTextField;

private TextField profilesPathTextField;

public SettingsBase(ExceptionAndAlertHandler exceptionAndAlertHandler, ClientListener clientListener) {

getStyleClass().add("settings_base");

this.clientListener = clientListener;

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

serverPortTextField = new TextField();

serverHostNameOrIPTextField = new TextField();

nickNameTextField = new TextField();

clientProfileComboBox = new StreamPiComboBox<>();

clientProfileComboBox.setStreamPiComboBoxFactory(new StreamPiComboBoxFactory<ClientProfile>()

{

@Override

public String getOptionDisplayText(ClientProfile object)

{

return object.getName();

}

});

clientProfileComboBox.setStreamPiComboBoxListener(new StreamPiComboBoxListener<ClientProfile>(){

@Override

public void onNewItemSelected(ClientProfile selectedItem)

{

clientListener.renderProfile(selectedItem);

}

});

themeComboBox = new StreamPiComboBox<>();

themeComboBox.setStreamPiComboBoxFactory(new StreamPiComboBoxFactory<Theme>()

{

@Override

public String getOptionDisplayText(Theme object)

{

return object.getShortName();

}

});

displayHeightTextField = new TextField();

displayWidthTextField = new TextField();

themesPathTextField = new TextField();

iconsPathTextField = new TextField();

profilesPathTextField = new TextField();

startOnBootToggleButton = new ToggleButton("Start On Boot");

startOnBootToggleButton.managedProperty().bind(startOnBootToggleButton.visibleProperty());

showCursorToggleButton = new ToggleButton("Show Cursor");

showCursorToggleButton.managedProperty().bind(showCursorToggleButton.visibleProperty());

fullScreenToggleButton = new ToggleButton("Full Screen");

fullScreenToggleButton.managedProperty().bind(fullScreenToggleButton.visibleProperty());

int prefWidth = 200;

Label licenseLabel = new Label("This software is licensed to GNU GPLv3. Check StreamPi Server > settings > About to see full License Statement.");

licenseLabel.setWrapText(true);

Label versionLabel = new Label(ClientInfo.getInstance().getReleaseStatus().getUIName() +" "+ClientInfo.getInstance().getVersion().getText());

HBoxInputBox themesPathInputBox = new HBoxInputBox("Themes Path", themesPathTextField, prefWidth);

themesPathInputBox.managedProperty().bind(themesPathInputBox.visibleProperty());

HBoxInputBox iconsPathInputBox = new HBoxInputBox("Icons Path", iconsPathTextField, prefWidth);

iconsPathInputBox.managedProperty().bind(iconsPathInputBox.visibleProperty());

HBoxInputBox profilesPathInputBox = new HBoxInputBox("Profiles Path", profilesPathTextField, prefWidth);

profilesPathInputBox.managedProperty().bind(profilesPathInputBox.visibleProperty());

HBoxInputBox screenHeightInputBox = new HBoxInputBox("Screen Height", displayHeightTextField, prefWidth);

screenHeightInputBox.managedProperty().bind(screenHeightInputBox.visibleProperty());

HBoxInputBox screenWidthInputBox = new HBoxInputBox("Screen Width", displayWidthTextField, prefWidth);

screenWidthInputBox.managedProperty().bind(screenWidthInputBox.visibleProperty());

if(ClientInfo.getInstance().getPlatformType() == com.stream_pi.util.platform.Platform.ANDROID)

{

themesPathInputBox.setVisible(false);

iconsPathInputBox.setVisible(false);

profilesPathInputBox.setVisible(false);

startOnBootToggleButton.setVisible(false);

showCursorToggleButton.setVisible(false);

fullScreenToggleButton.setVisible(false);

screenHeightInputBox.setVisible(false);

screenWidthInputBox.setVisible(false);

}

VBox vBox = new VBox(

new HBoxInputBox("Device Name", nickNameTextField, prefWidth),

new HBoxInputBox("Host Name/IP", serverHostNameOrIPTextField, prefWidth),

new HBoxInputBox("Port", serverPortTextField, prefWidth),

new HBox(

new Label("Current profile"),

SpaceFiller.horizontal(),

clientProfileComboBox

new HBox(

new Label("Theme"),

SpaceFiller.horizontal(),

themeComboBox

screenHeightInputBox,

screenWidthInputBox,

themesPathInputBox,

iconsPathInputBox,

profilesPathInputBox,

startOnBootToggleButton,

showCursorToggleButton,

fullScreenToggleButton,

licenseLabel,

versionLabel

);

vBox.getStyleClass().add("settings_base_vbox");

vBox.setSpacing(5.0);

vBox.setPadding(new Insets(5));

ScrollPane scrollPane = new ScrollPane();

scrollPane.setHbarPolicy(ScrollPane.ScrollBarPolicy.AS_NEEDED);

VBox.setVgrow(scrollPane, Priority.ALWAYS);

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

scrollPane.setContent(vBox);

vBox.setMinWidth(300);

vBox.prefWidthProperty().bind(scrollPane.widthProperty().subtract(25));

Label settingsLabel = new Label("Settings");

settingsLabel.setPadding(new Insets(5,0,0,5));

settingsLabel.getStyleClass().add("settings_heading_label");

saveButton = new Button("Save");

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

closeButton = new Button("Close");

connectDisconnectButton = new Button("Connect");

connectDisconnectButton.setOnAction(event -> onConnectDisconnectButtonClicked());

shutdownButton = new Button("Shutdown");

shutdownButton.setOnAction(event -> onShutdownButtonClicked());

Button exitButton = new Button("Exit");

exitButton.setOnAction(event -> onExitButtonClicked());

HBox buttonBar = new HBox(connectDisconnectButton, saveButton, exitButton, closeButton);

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

if(ClientInfo.getInstance().getPlatformType() == com.stream_pi.util.platform.Platform.LINUX &&

ClientInfo.getInstance().isShowShutDownButton())

{

buttonBar.getChildren().add(shutdownButton);

}

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

buttonBar.setSpacing(5.0);

buttonBar.setAlignment(Pos.CENTER_RIGHT);

setSpacing(5.0);

getChildren().addAll(

settingsLabel,

scrollPane,

buttonBar

);

}

public void onExitButtonClicked()

{

clientListener.onCloseRequest();

Platform.exit();

}

public void setDisableStatus(boolean status)

{

saveButton.setDisable(status);

connectDisconnectButton.setDisable(status);

}

public void onShutdownButtonClicked()

{

clientListener.onCloseRequest();

try {

Runtime.getRuntime().exec("sudo halt");

}

catch (Exception e)

{

e.printStackTrace();

}

public void onConnectDisconnectButtonClicked()

{

try

{

if(clientListener.isConnected())

clientListener.disconnect("Client disconnected from settings");

else

clientListener.setupClientConnection();

}

catch (SevereException e)

{

e.printStackTrace();

exceptionAndAlertHandler.handleSevereException(e);

}

public void setConnectDisconnectButtonStatus()

{

Platform.runLater(()->{

setDisableStatus(false);

if(clientListener.isConnected())

connectDisconnectButton.setText("Disconnect");

else

connectDisconnectButton.setText("Connect");

});

}

public Button getCloseButton() {

return closeButton;

}

public void loadData() throws SevereException

{

nickNameTextField.setText(Config.getInstance().getClientNickName());

serverHostNameOrIPTextField.setText(Config.getInstance().getSavedServerHostNameOrIP());

serverPortTextField.setText(Config.getInstance().getSavedServerPort()+"");

clientProfileComboBox.setOptions(clientListener.getClientProfiles().getClientProfiles());

int ind = 0;

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

{

if(clientProfileComboBox.getOptions().get(i).getID().equals(clientListener.getCurrentProfile().getID()))

{

ind = i;

break;

}

clientProfileComboBox.setCurrentSelectedItemIndex(ind);

themeComboBox.setOptions(clientListener.getThemes().getThemeList());

int ind2 = 0;

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

{

if(themeComboBox.getOptions().get(i).getFullName().equals(clientListener.getCurrentTheme().getFullName()))

{

ind2 = i;

break;

}

themeComboBox.setCurrentSelectedItemIndex(ind2);

displayWidthTextField.setText(Config.getInstance().getStartupWindowWidth()+"");

displayHeightTextField.setText(Config.getInstance().getStartupWindowHeight()+"");

themesPathTextField.setText(Config.getInstance().getThemesPath());

iconsPathTextField.setText(Config.getInstance().getIconsPath());

profilesPathTextField.setText(Config.getInstance().getProfilesPath());

startOnBootToggleButton.setSelected(Config.getInstance().isStartOnBoot());

fullScreenToggleButton.setSelected(Config.getInstance().isFullscreen());

showCursorToggleButton.setSelected(Config.getInstance().isShowCursor());

}

public void onSaveButtonClicked()

{

StringBuilder errors = new StringBuilder();

int port = -1;

try

{

port = Integer.parseInt(serverPortTextField.getText());

if(port < 1024)

errors.append("* Server IP should be above 1024.\n");

}

catch (NumberFormatException exception)

{

errors.append("* Server IP should be a number.\n");

}

double width = -1;

try

{

width = Double.parseDouble(displayWidthTextField.getText());

if(width < 0)

errors.append("* Display Width should be above 0.\n");

}

catch (NumberFormatException exception)

{

errors.append("* Display Width should be a number.\n");

}

double height = -1;

try

{

height = Double.parseDouble(displayHeightTextField.getText());

if(height < 0)

errors.append("* Display Height should be above 0.\n");

}

catch (NumberFormatException exception)

{

errors.append("* Display Height should be a number.\n");

}

if(serverHostNameOrIPTextField.getText().isBlank())

{

errors.append("* Server IP cannot be empty.\n");

}

if(nickNameTextField.getText().isBlank())

{

errors.append("* Nick name cannot be blank.\n");

}

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

{

exceptionAndAlertHandler.handleMinorException(new MinorException(

"You made mistakes",

"Please fix the errors and try again :\n"+errors.toString()

));

return;

}

try {

boolean toBeReloaded = false;

boolean breakConnection = false;

if(!Config.getInstance().getCurrentThemeFullName().equals(themeComboBox.getCurrentSelectedItem().getFullName()))

{

breakConnection = true;

toBeReloaded = true;

}

Config.getInstance().setCurrentThemeFullName(themeComboBox.getCurrentSelectedItem().getFullName());

if(width != Config.getInstance().getStartupWindowWidth() || height != Config.getInstance().getStartupWindowHeight())

toBeReloaded = true;

Config.getInstance().setStartupWindowSize(width, height);

if(!Config.getInstance().getClientNickName().equals(nickNameTextField.getText()))

breakConnection = true;

Config.getInstance().setNickName(nickNameTextField.getText());

if(port != Config.getInstance().getSavedServerPort() || !serverHostNameOrIPTextField.getText().equals(Config.getInstance().getSavedServerHostNameOrIP()))

breakConnection = true;

Config.getInstance().setServerPort(port);

Config.getInstance().setServerHostNameOrIP(serverHostNameOrIPTextField.getText());

boolean startOnBoot = startOnBootToggleButton.isSelected();

if(Config.getInstance().isStartOnBoot() != startOnBoot)

{

if(ClientInfo.getInstance().getRunnerFileName() == null)

{

new StreamPiAlert("Uh Oh", "No Runner File Name Specified as startup arguments. Cant set run at boot.", StreamPiAlertType.ERROR).show();

startOnBoot = false;

}

else

{

StartAtBoot startAtBoot = new StartAtBoot(SoftwareType.CLIENT, ClientInfo.getInstance().getPlatformType());

if(startOnBoot)

{

startAtBoot.create(new File(ClientInfo.getInstance().getRunnerFileName()));

startAtBoot.create(new File(ClientInfo.getInstance().getRunnerFileName()),

ClientInfo.getInstance().isXMode());

}

else

{

boolean result = startAtBoot.delete();

if(!result)

new StreamPiAlert("Uh Oh!", "Unable to delete starter file", StreamPiAlertType.ERROR).show();

}

Config.getInstance().setStartOnBoot(startOnBoot);

if(Config.getInstance().isFullscreen() != fullScreenToggleButton.isSelected() ||

Config.getInstance().isShowCursor() != showCursorToggleButton.isSelected())

toBeReloaded = true;

Config.getInstance().setFullscreen(fullScreenToggleButton.isSelected());

Config.getInstance().setShowCursor(showCursorToggleButton.isSelected());

if(!Config.getInstance().getThemesPath().equals(themesPathTextField.getText()))

toBeReloaded = true;

Config.getInstance().setThemesPath(themesPathTextField.getText());

if(!Config.getInstance().getIconsPath().equals(iconsPathTextField.getText()))

toBeReloaded = true;

Config.getInstance().setIconsPath(iconsPathTextField.getText());

if(!Config.getInstance().getProfilesPath().equals(profilesPathTextField.getText()))

toBeReloaded = true;

Config.getInstance().setProfilesPath(profilesPathTextField.getText());

Config.getInstance().save();

loadData();

if(breakConnection)

{

if(clientListener.isConnected())

{

clientListener.disconnect("Client connection settings were changed. Client will reconnect again.");

clientListener.setupClientConnection();

}

if(toBeReloaded)

{

clientListener.init();

clientListener.renderRootDefaultProfile();

}

catch (SevereException e)

{

e.printStackTrace();

exceptionAndAlertHandler.handleSevereException(e);

}

catch (MinorException e)

{

e.printStackTrace();

exceptionAndAlertHandler.handleMinorException(e);

}

M src/main/java/module-info.java

+2 −0

module com.stream_pi.client {

requires javafx.base;

requires javafx.graphics;

requires javafx.controls;

requires org.kordamp.iconli.core;

requires org.kordamp.ikonli.javafx;

requires com.gluonhq.attach.lifecycle;

requires com.gluonhq.attach.util;

requires org.apache.commons.lang3;

requires java.xml;

requires com.stream_pi.util;

requires com.stream_pi.theme_api;

requires com.stream_pi.action_api;

requires org.kordamp.ikonli.fontawesome5;

exports com.stream_pi.client;

}

A src/main/resources/META-INF/native-image/serialization-config.json

+8 −0

[

{"name":"com.stream_pi.util.comms.Message"},

{"name": "java.lang.String"},

{"name": "java.lang.String[]"},

{"name": "java.lang.Byte"},

{"name": "java.lang.Byte[]"},

{"name": "java.lang.Number"}

]

A test.json

+11 −0

[

{

"name":"com.stream_pi.util.comms.StreamPiMessage",

"allDeclaredConstructors" : true,

"allPublicConstructors" : true,

"allDeclaredMethods" : true,

"allPublicMethods" : true,

"allDeclaredClasses" : true,

"allPublicClasses" : true

}

]

Public

client

Clone or download

work

Modified Files