server

Refactored, Added factory reset

Download Browse

+78 −36

Author

Debayan Sutradhar (rnayabed) 2021-06-07 21:11

Committer

Debayan Sutradhar (rnayabed) 2021-06-07 21:11

Hash 8c133fa5ae6357984b757089a065a58e8f7cfc6e

Parent 2878616b9fa69da0102d9b17da38e9b78b0e6b58

Reference git #server/8c133fa5ae6357984b757089a065a58e8f7cfc6e

Modified Files

List

Side by side diff

Inline diff

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

+1 −4

package com.stream_pi.server.connection;

import com.stream_pi.action_api.action.Action;

import com.stream_pi.action_api.action.ActionType;

import com.stream_pi.action_api.action.DisplayTextAlignment;

import com.stream_pi.action_api.action.Location;

import com.stream_pi.action_api.actionproperty.ClientProperties;

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

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

import com.stream_pi.action_api.externalplugin.ExternalPlugin;

import com.stream_pi.action_api.externalplugin.NormalAction;

import com.stream_pi.action_api.externalplugin.ToggleAction;

import com.stream_pi.action_api.otheractions.CombineAction;

import com.stream_pi.action_api.otheractions.FolderAction;

import com.stream_pi.server.action.ExternalPlugins;

import com.stream_pi.server.client.Client;

import com.stream_pi.server.client.ClientProfile;

import com.stream_pi.server.client.ClientTheme;

import com.stream_pi.server.controller.ServerListener;

import com.stream_pi.server.info.ServerInfo;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

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

import com.stream_pi.util.alert.StreamPiAlert;

import com.stream_pi.util.alert.StreamPiAlertType;

import com.stream_pi.util.comms.Message;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.exception.SevereException;

import com.stream_pi.util.exception.StreamPiException;

import com.stream_pi.util.platform.Platform;

import com.stream_pi.util.platform.ReleaseStatus;

import com.stream_pi.util.version.Version;

import javafx.concurrent.Task;

import javafx.scene.control.Toggle;

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.setDisplayWidth(Double.parseDouble(ar[5]));

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

client.setDefaultProfileID(ar[8]);

client.setDefaultThemeFullName(ar[9]);

//call get profiles command.

serverListener.clearTemp();

}

public void updateClientDetails(Message message)

{

String[] ar = message.getStringArrValue();

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

client.setNickName(ar[4]);

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

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

client.setDefaultProfileID(ar[8]);

client.setDefaultThemeFullName(ar[9]);

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

}

public synchronized Client getClient()

{

return client;

}

@Override

public void run() {

try {

initAfterConnectionQuerySend();

} catch (SevereException e) {

e.printStackTrace();

exceptionAndAlertHandler.handleSevereException(e);

exitAndRemove();

return;

}

try

{

while(!stop.get())

{

try

{

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

String header = message.getHeader();

switch (header)

{

case "action_icon" : onActionIconReceived(message);

break;

case "disconnect" : clientDisconnected(message);

break;

case "register_client_details" : initAfterConnectionQueryReceive(message);

getProfilesFromClient();

getThemesFromClient();

break;

case "update_client_details" : updateClientDetails(message);

break;

case "client_screen_details" : onClientScreenDetailsReceived(message);

break;

case "profiles" : registerProfilesFromClient(message);

break;

case "profile_details" : registerProfileDetailsFromClient(message);

break;

case "action_details" : registerActionToProfile(message);

break;

case "themes": registerThemes(message);

break;

case "action_clicked": onActionClicked(message);

break;

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

}

catch (IOException | ClassNotFoundException e)

{

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

e.printStackTrace();

serverListener.clearTemp();

if(!stop.get())

{

removeConnection();

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

}

exitAndRemove();

return;

}

catch (StreamPiException e)

{

e.printStackTrace();

if(e instanceof MinorException)

exceptionAndAlertHandler.handleMinorException((MinorException) e);

else if (e instanceof SevereException)

exceptionAndAlertHandler.handleSevereException((SevereException) e);

}

// commands

private void onActionIconReceived(Message message) throws MinorException

{

String[] s = message.getStringArrValue();

String profileID = s[0];

String actionID = s[1];

String iconState = s[2];

getClient()

.getProfileByID(profileID)

.getActionByID(actionID)

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

}

public void initAfterConnectionQuerySend() throws SevereException

{

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

sendMessage(new Message("get_client_details"));

}

public void disconnect() throws SevereException {

disconnect("");

}

public void disconnect(String message) throws SevereException {

if(stop.get())

return;

stop.set(true);

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

Message m = new Message("disconnect");

m.setStringValue(message);

sendMessage(m);

try

{

if(!socket.isClosed())

socket.close();

}

catch (IOException e)

{

e.printStackTrace();

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

}

public synchronized void sendMessage(Message message) throws SevereException

{

try

{

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

oos.writeObject(message);

oos.flush();

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

}

catch (IOException e)

{

e.printStackTrace();

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

}

public void clientDisconnected(Message message)

{

stop.set(true);

String txt = "Disconnected!";

String msg = message.getStringValue();

if(!msg.isBlank())

txt = "Message : "+msg;

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

exitAndRemove();

}

public void getProfilesFromClient() throws StreamPiException

{

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

sendMessage(new Message("get_profiles"));

}

public void getThemesFromClient() throws StreamPiException

{

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

sendMessage(new Message("get_themes"));

}

public void registerThemes(Message message)

{

String[] r = message.getStringArrValue();

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

{

ClientTheme clientTheme = new ClientTheme(

r[i],

r[i+1],

r[i+2],

r[i+3]

);

try

{

getClient().addTheme(clientTheme);

}

catch (CloneNotSupportedException e)

{

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

e.printStackTrace();

}

private HashMap<String, Integer> temporaryProfilesCheck = null;

public void registerProfilesFromClient(Message message) throws StreamPiException

{

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

String[] profileIds = message.getStringArrValue();

int[] profilesActionIds = message.getIntArrValue();

temporaryProfilesCheck = new HashMap<>();

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

{

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

getProfileDetailsFromClient(profileIds[i]);

}

public void getProfileDetailsFromClient(String ID) throws StreamPiException

{

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

Message message = new Message("get_profile_details");

message.setStringValue(ID);

sendMessage(message);

}

public void registerProfileDetailsFromClient(Message message)

{

String[] r = message.getStringArrValue();

String ID = r[0];

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

String name = r[1];

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

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

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

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

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

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

try

{

getClient().addProfile(clientProfile);

}

catch (CloneNotSupportedException e)

{

logger.severe(e.getMessage());

e.printStackTrace();

}

serverListener.clearTemp();

}

public synchronized void registerActionToProfile(Message message) throws StreamPiException

{

String[] r = message.getStringArrValue();

String profileID = r[0];

String ID = r[1];

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

//3 - Version

//4 - ModuleName

//display

String bgColorHex = r[5];

//icon

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

String defaultIconState = r[7];

//text

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

String displayFontColor = r[9];

String displayText = r[10];

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

//location

String row = r[12];

String col = r[13];

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

String root = r[14];

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

//client properties

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

ClientProperties clientProperties = new ClientProperties();

if(actionType == ActionType.FOLDER)

clientProperties.setDuplicatePropertyAllowed(true);

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

{

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

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

clientProperties.addProperty(property);

}

//set up action

temporaryProfilesCheck.replace(

profileID,

(temporaryProfilesCheck.get(profileID) - 1)

);

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

{

temporaryProfilesCheck.remove(profileID);

}

//action toBeAdded = null;

boolean isInvalidAction = false;

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

{

String moduleName = r[4];

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

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

if(originalAction == null)

{

isInvalidAction = true;

}

else

{

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

{

isInvalidAction = true;

}

else

{

try

{

ExternalPlugin newPlugin = originalAction.clone();

newPlugin.setID(ID);

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/connection/MainServer.java

+1 −0

package com.stream_pi.server.connection;

import com.stream_pi.server.controller.ServerListener;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.exception.SevereException;

import javafx.application.Platform;

import java.io.IOException;

import java.net.*;

import java.util.Enumeration;

import java.util.concurrent.atomic.AtomicBoolean;

import java.util.logging.Logger;

public class MainServer extends Thread {

private ServerListener serverListener;

private Logger logger = Logger.getLogger(MainServer.class.getName());

private int port;

private ServerSocket serverSocket = null;

//private Server server;

private AtomicBoolean stop = new AtomicBoolean(false);

private ExceptionAndAlertHandler exceptionAndAlertHandler;

public MainServer(ServerListener serverListener, ExceptionAndAlertHandler exceptionAndAlertHandler)

{

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

this.serverListener = serverListener;

}

public void setPort(int port) {

this.port = port;

}

@Override

public synchronized void start() {

stop.set(false);

super.start();

}

public void stopListeningForConnections()

{

/*if(server !=null)

{

if(!server.isShutdown())

server.shutdown();

}*/

try

{

logger.info("Stopping listening for connections ...");

if(serverSocket!=null)

if(!serverSocket.isClosed())

{

stop.set(true);

serverSocket.close();

}

} catch (IOException e) {

e.printStackTrace();

}

finally {

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

}

@Override

public void run() {

logger.warning("Starting main server on port "+port+" ...");

try {

logger.info("Starting server on port "+port+" ...");

serverSocket = new ServerSocket(port);

setupStageTitle(true);

while(!stop.get())

{

Socket s = serverSocket.accept();

ClientConnections.getInstance().addConnection(new ClientConnection(s, serverListener, exceptionAndAlertHandler));

logger.info("New client connected ("+s.getRemoteSocketAddress()+") !");

}

catch (SocketException e)

{

if(!e.getMessage().contains("Socket closed") && !e.getMessage().contains("Interrupted function call: accept failed"))

{

logger.info("Main Server stopped accepting calls ...");

setupStageTitle(false);

exceptionAndAlertHandler.handleMinorException(new MinorException("Sorry!","Server could not be started at "+port+".\n" +

"This could be due to another process or another instance of Stream-Pi Server using the same port. \n\n" +

"If another Server Instance probably running, close it. If not, try changing the port in settings and restart Stream-Pi Server." +

"If the problem still persists, consider contacting us. \n\nFull Message : "+e.getMessage()));

e.printStackTrace();

}

catch (IOException e)

{

exceptionAndAlertHandler.handleSevereException(new SevereException("MainServer io Exception occurred!"));

e.printStackTrace();

}

private void setupStageTitle(boolean isSuccess)

{

try

{

if(isSuccess)

{

StringBuilder ips = new StringBuilder();

Enumeration<NetworkInterface> e = NetworkInterface.getNetworkInterfaces();

while(e.hasMoreElements())

{

NetworkInterface n = e.nextElement();

Enumeration<InetAddress> ee = n.getInetAddresses();

while (ee.hasMoreElements())

{

InetAddress i = ee.nextElement();

String hostAddress = i.getHostAddress();

if(i instanceof Inet4Address)

{

ips.append(hostAddress);

if(e.hasMoreElements())

ips.append(" / ");

}

Platform.runLater(()-> serverListener.getStage().setTitle("Stream-Pi Server - IP(s): "+ips+" | Port: "+ port));

}

else

{

Platform.runLater(()-> serverListener.getStage().setTitle("Stream-Pi Server - Offline"));

}

catch (Exception e)

{

e.printStackTrace();

exceptionAndAlertHandler.handleMinorException(new MinorException("Error",e.getMessage()));

}

D src/main/java/com/stream_pi/server/connection/ServerListener.java

package com.stream_pi.server.connection;

import com.stream_pi.action_api.externalplugin.NormalAction;

import com.stream_pi.action_api.externalplugin.ToggleAction;

import com.stream_pi.server.client.Client;

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

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

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

import com.stream_pi.util.exception.SevereException;

import javafx.stage.Stage;

import java.net.SocketAddress;

public interface ServerListener

{

void onActionClicked(Client client, String profileID, String actionID, boolean toggle);

void clearTemp();

void init();

void restart();

void othInit();

Stage getStage();

DashboardBase getDashboardBase();

SettingsBase getSettingsBase();

void initLogger() throws SevereException;

}

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

+34 −7

package com.stream_pi.server.controller;

import com.stream_pi.action_api.action.Action;

import com.stream_pi.action_api.action.ActionType;

import com.stream_pi.action_api.action.PropertySaver;

import com.stream_pi.action_api.action.ServerConnection;

import com.stream_pi.action_api.externalplugin.NormalAction;

import com.stream_pi.action_api.externalplugin.ToggleAction;

import com.stream_pi.action_api.externalplugin.ToggleExtras;

import com.stream_pi.server.Main;

import com.stream_pi.server.action.ExternalPlugins;

import com.stream_pi.server.client.Client;

import com.stream_pi.server.client.ClientProfile;

import com.stream_pi.server.connection.ClientConnection;

import com.stream_pi.server.connection.ClientConnections;

import com.stream_pi.server.connection.MainServer;

import com.stream_pi.server.info.ServerInfo;

import com.stream_pi.server.info.StartupFlags;

import com.stream_pi.server.io.Config;

import com.stream_pi.server.window.Base;

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

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

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

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

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

import com.stream_pi.util.alert.StreamPiAlert;

import com.stream_pi.util.alert.StreamPiAlertListener;

import com.stream_pi.util.alert.StreamPiAlertType;

import com.stream_pi.util.exception.*;

import com.stream_pi.util.iohelper.IOHelper;

import javafx.animation.Animation;

import javafx.animation.Interpolator;

import javafx.animation.KeyFrame;

import javafx.animation.KeyValue;

import javafx.animation.Timeline;

import javafx.application.Platform;

import javafx.concurrent.Task;

import javafx.scene.Node;

import javafx.scene.Scene;

import javafx.scene.image.Image;

import javafx.stage.Modality;

import javafx.stage.Stage;

import javafx.stage.WindowEvent;

import javafx.util.Duration;

import java.awt.MenuItem;

import java.awt.PopupMenu;

import java.awt.SystemTray;

import java.awt.Toolkit;

import java.awt.TrayIcon;

import java.net.SocketAddress;

import java.util.Objects;

import java.util.Random;

import java.util.Timer;

import java.util.TimerTask;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.ScheduledExecutorService;

import java.util.logging.Level;

public class Controller extends Base implements PropertySaver, ServerConnection, ToggleExtras

{

private ExecutorService executor = Executors.newCachedThreadPool();

private final ExecutorService executor = Executors.newCachedThreadPool();

private MainServer mainServer;

private Animation openSettingsAnimation;

private Animation closeSettingsAnimation;

public Controller(){

mainServer = null;

}

public void setupDashWindow() throws SevereException

{

try

{

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

}

catch (Exception e)

{

e.printStackTrace();

throw new SevereException(e.getMessage());

}

@Override

public void init()

{

try

{

initBase();

setupDashWindow();

setupSettingsWindowsAnimations();

ExternalPlugins.getInstance().setPropertySaver(this);

ExternalPlugins.getInstance().setToggleExtras(this);

ExternalPlugins.getInstance().setServerConnection(this);

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

openSettingsAnimation.play();

});

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

closeSettingsAnimation.play();

});

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

mainServer = new MainServer(this, this);

if(getConfig().isFirstTimeUse())

{

Stage stage = new Stage();

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

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

stage.setScene(s);

stage.setMinHeight(500);

stage.setMinWidth(700);

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

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

stage.initModality(Modality.APPLICATION_MODAL);

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

stage.show();

}

else

{

if(getConfig().isAllowDonatePopup())

{

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

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

}

othInit();

}

catch (SevereException e)

{

handleSevereException(e);

}

@Override

public void othInit()

{

try

{

if(StartupFlags.START_MINIMISED && SystemTray.isSupported())

minimiseApp();

else

getStage().show();

}

catch(MinorException e)

{

handleMinorException(e);

}

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

@Override

protected Void call()

{

try

{

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

//themes

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

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

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

//clients

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

try

{

//Plugins

Platform.runLater(()->{

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

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

});

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

ExternalPlugins.getInstance().init();

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

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

}

catch (MinorException e)

{

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

handleMinorException(e);

}

//Server

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

mainServer.start();

}

catch (SevereException e)

{

handleSevereException(e);

}

return null;

}

});

}

@Override

public void factoryReset()

{

getLogger().info("Reset to factory ...");

onQuitApp();

boolean result = IOHelper.deleteFile(getServerInfo().getPrePath());

if(result)

{

getStage().close();

init();

}

else

{

handleSevereException(new SevereException("Unable to delete all files successfully. Installation corrupt. Re-install."));

}

private void setupSettingsWindowsAnimations()

{

Node settingsNode = getSettingsBase();

Node dashboardNode = getDashboardBase();

openSettingsAnimation = createOpenSettingsAnimation(settingsNode, dashboardNode);

closeSettingsAnimation = createCloseSettingsAnimation(settingsNode, dashboardNode);

}

public void onCloseRequest(WindowEvent event)

{

try

{

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

SystemTray.isSupported())

{

minimiseApp();

event.consume();

return;

}

onQuitApp();

ExternalPlugins.getInstance().shutDownActions();

exit();

Platform.exit();

}

catch (SevereException e)

{

handleSevereException(e);

}

catch (MinorException e)

{

handleMinorException(e);

}

public void onQuitApp()

{

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

try

{

if(getConfig() != null)

{

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

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

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

getConfig().save();

}

catch (SevereException e)

{

handleSevereException(e);

}

stopServerAndAllConnections();

executor.shutdown();

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

ExternalPlugins.getInstance().shutDownActions();

closeLogger();

Config.nullify();

}

public void exit()

{

Platform.exit();

}

private void stopServerAndAllConnections()

{

if(mainServer!=null)

mainServer.stopListeningForConnections();

ClientConnections.getInstance().disconnectAll();

}

@Override

public void restart()

{

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

stopServerAndAllConnections();

Platform.runLater(this::init);

}

public void minimiseApp() throws MinorException

{

try

{

SystemTray systemTray = SystemTray.getSystemTray();

if(getTrayIcon() == null)

initIconTray(systemTray);

systemTray.add(getTrayIcon());

getStage().hide();

getStage().setOnShown(windowEvent -> {

systemTray.remove(getTrayIcon());

});

}

catch(Exception e)

{

throw new MinorException(e.getMessage());

}

public void initIconTray(SystemTray systemTray)

{

Platform.setImplicitExit(false);

PopupMenu popup = new PopupMenu();

MenuItem exitItem = new MenuItem("Exit");

exitItem.addActionListener(l->{

systemTray.remove(getTrayIcon());

onQuitApp();

Platform.exit();

exit();

});

popup.add(exitItem);

TrayIcon trayIcon = new TrayIcon(

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

"Stream-Pi Server",

popup

);

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

getStage().show();

getStage().setAlwaysOnTop(true);

getStage().setAlwaysOnTop(false);

}));

trayIcon.setImageAutoSize(true);

this.trayIcon = trayIcon;

}

private TrayIcon trayIcon = null;

public TrayIcon getTrayIcon()

{

return trayIcon;

}

@Override

public void handleMinorException(MinorException e)

{

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

e.printStackTrace();

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

}

@Override

public void handleSevereException(SevereException e) {

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

e.printStackTrace();

Platform.runLater(()->{

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

alert.setOnClicked(new StreamPiAlertListener()

{

@Override

public void onClick(String txt)

{

onQuitApp();

Platform.exit();

exit();

}

});

alert.show();

});

}

@Override

public void onActionClicked(Client client, String profileID, String actionID, boolean toggle)

{

try

{

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

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

{

if(action.isInvalid())

{

throw new MinorException(

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

);

}

else

{

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

@Override

protected Void call()

{

try {

Thread.sleep(action.getDelayBeforeExecuting());

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

if(action instanceof ToggleAction)

{

onToggleActionClicked((ToggleAction) action, toggle, profileID,

client.getRemoteSocketAddress());

}

else if (action instanceof NormalAction)

{

onNormalActionClicked((NormalAction) action, profileID,

client.getRemoteSocketAddress());

}

catch (InterruptedException e)

{

e.printStackTrace();

getLogger().info("onActionClicked scheduled task was interrupted ...");

}

return null;

}

});

}

catch (Exception e)

{

e.printStackTrace();

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

}

public synchronized void onNormalActionClicked(NormalAction action, String profileID, SocketAddress socketAddress)

{

try

{

action.onActionClicked();

}

catch (MinorException e)

{

sendActionFailed(e, socketAddress, profileID, action.getID());

}

public synchronized void onToggleActionClicked(ToggleAction action, boolean toggle, String profileID, SocketAddress socketAddress)

{

try

{

if(toggle)

{

action.onToggleOn();

}

else

{

action.onToggleOff();

}

catch (MinorException e)

{

sendActionFailed(e, socketAddress, profileID, action.getID());

}

@Override

public void clearTemp() {

Platform.runLater(() -> {

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

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

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

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

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

});

}

@Override

public void saveServerProperties()

{

try

{

ExternalPlugins.getInstance().saveServerSettings();

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

} catch (MinorException e) {

e.printStackTrace();

handleMinorException(e);

}

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

{

try {

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

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

Action action = clientProfile.getActionByID(actionID);

clientConnection.saveActionDetails(profileID, action);

if(sendIcons && action.isHasIcon())

{

saveAllIcons(profileID, actionID, socketAddress, false);

}

Platform.runLater(()->{

try {

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

action.getID(),

profileID

);

if(actionBox != null)

{

Platform.runLater(actionBox::init);

}

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

{

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

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

{

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

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

}

catch (Exception e)

{

e.printStackTrace();

}

});

}

catch (SevereException e)

{

handleSevereException(e);

}

@Override

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

{

if(runAsync)

{

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

@Override

protected Void call()

{

saveClientActionMain(profileID, actionID, socketAddress, sendIcons);

return null;

}

});

}

else

{

saveClientActionMain(profileID, actionID, socketAddress, sendIcons);

}

@Override

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

{

saveAllIcons(profileID, actionID, socketAddress, true);

}

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

{

if(async)

{

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

@Override

protected Void call()

{

saveAllIconsMain(profileID, actionID, socketAddress);

return null;

}

});

}

else

{

saveAllIconsMain(profileID, actionID, socketAddress);

}

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

{

try {

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

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

Action action = clientProfile.getActionByID(actionID);

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

{

clientConnection.sendIcon(profileID, actionID, eachState,

action.getIcon(eachState));

}

catch (SevereException e)

{

handleSevereException(e);

}

@Override

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

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

@Override

protected Void call()

{

try {

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

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

Action action = clientProfile.getActionByID(actionID);

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

}

catch (SevereException e)

{

handleSevereException(e);

}

return null;

}

});

}

@Override

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

return ServerInfo.getInstance().getPlatform();

}

@Override

public void sendActionFailed(MinorException exception, SocketAddress socketAddress, String profileID, String actionID)

{

if(exception.getTitle() != null)

{

exception.setShortMessage(exception.getTitle()+"\n"+exception.getShortMessage());

}

exception.setTitle("Error while running action");

handleMinorException(exception);

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

@Override

protected Void call()

{

try {

ClientConnections.getInstance().getClientConnectionBySocketAddress(socketAddress)

.sendActionFailed(profileID, actionID);

}

catch (SevereException e)

{

handleSevereException(e);

}

return null;

}

});

}

private Animation createOpenSettingsAnimation(Node settingsNode, Node dashboardNode) {

Timeline openSettingsTimeline = new Timeline();

openSettingsTimeline.setCycleCount(1);

openSettingsTimeline.getKeyFrames().addAll(

new KeyFrame(Duration.millis(0.0D),

new KeyValue(settingsNode.opacityProperty(),

0.0D, Interpolator.EASE_IN),

new KeyValue(settingsNode.scaleXProperty(),

1.1D, Interpolator.EASE_IN),

new KeyValue(settingsNode.scaleYProperty(),

1.1D, Interpolator.EASE_IN),

new KeyValue(settingsNode.scaleZProperty(),

1.1D, Interpolator.EASE_IN)),

new KeyFrame(Duration.millis(90.0D),

new KeyValue(settingsNode.opacityProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(settingsNode.scaleXProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(settingsNode.scaleYProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(settingsNode.scaleZProperty(),

1.0D, Interpolator.LINEAR)),

new KeyFrame(Duration.millis(0.0D),

new KeyValue(dashboardNode.opacityProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleXProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleYProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleZProperty(),

1.0D, Interpolator.LINEAR)),

new KeyFrame(Duration.millis(90.0D),

new KeyValue(dashboardNode.opacityProperty(),

0.0D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleXProperty(),

0.9D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleYProperty(),

0.9D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleZProperty(),

0.9D, Interpolator.LINEAR))

);

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

return openSettingsTimeline;

}

private Animation createCloseSettingsAnimation(Node settingsNode, Node dashboardNode) {

Timeline closeSettingsTimeline = new Timeline();

closeSettingsTimeline.setCycleCount(1);

closeSettingsTimeline.getKeyFrames().addAll(

new KeyFrame(Duration.millis(0.0D),

new KeyValue(settingsNode.opacityProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(settingsNode.scaleXProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(settingsNode.scaleYProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(settingsNode.scaleZProperty(),

1.0D, Interpolator.LINEAR)),

new KeyFrame(Duration.millis(90.0D),

new KeyValue(settingsNode.opacityProperty(),

0.0D, Interpolator.LINEAR),

new KeyValue(settingsNode.scaleXProperty(),

1.1D, Interpolator.LINEAR),

new KeyValue(settingsNode.scaleYProperty(),

1.1D, Interpolator.LINEAR),

new KeyValue(settingsNode.scaleZProperty(),

1.1D, Interpolator.LINEAR)),

new KeyFrame(Duration.millis(0.0D),

new KeyValue(dashboardNode.opacityProperty(),

0.0D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleXProperty(),

0.9D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleYProperty(),

0.9D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleZProperty(),

0.9D, Interpolator.LINEAR)),

new KeyFrame(Duration.millis(90.0D),

new KeyValue(dashboardNode.opacityProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleXProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleYProperty(),

1.0D, Interpolator.LINEAR),

new KeyValue(dashboardNode.scaleZProperty(),

1.0D, Interpolator.LINEAR))

);

closeSettingsTimeline.setOnFinished(event1 -> {

dashboardNode.toFront();

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

@Override

protected Void call() {

try {

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

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

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

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

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

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

getSettingsBase().setDefaultTabToGeneral();

}

catch (SevereException e)

{

handleSevereException(e);

}

catch (MinorException e)

{

handleMinorException(e);

}

return null;

}

});

return closeSettingsTimeline;

}

@Override

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

throws MinorException

{

ClientConnection clientConnection = ClientConnections.getInstance().getClientConnectionBySocketAddress(

clientSocketAddress

);

if(clientConnection == null)

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

new Thread(new Task<Void>() {

@Override

protected Void call()

{

try

{

clientConnection.setToggleStatus(currentStatus, profileID, actionID);

}

catch (SevereException e)

{

handleSevereException(e);

}

return null;

}

}).start();

}

A src/main/java/com/stream_pi/server/controller/ServerListener.java

package com.stream_pi.server.controller;

import com.stream_pi.action_api.externalplugin.NormalAction;

import com.stream_pi.action_api.externalplugin.ToggleAction;

import com.stream_pi.server.client.Client;

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

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

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

import com.stream_pi.util.exception.SevereException;

import javafx.stage.Stage;

import java.net.SocketAddress;

public interface ServerListener

{

void onActionClicked(Client client, String profileID, String actionID, boolean toggle);

void clearTemp();

void init();

void restart();

void othInit();

Stage getStage();

DashboardBase getDashboardBase();

SettingsBase getSettingsBase();

void initLogger() throws SevereException;

void factoryReset();

}

M src/main/java/com/stream_pi/server/io/Config.java

+5 −0

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;

public class Config

{

private static Config instance = null;

private final File configFile;

private Document document;

private Config() throws SevereException {

try {

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

DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance();

DocumentBuilder docBuilder = docFactory.newDocumentBuilder();

document = docBuilder.parse(configFile);

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

}

private Element getServerElement()

{

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

}

//server

private Element getDividerPositionsElement()

{

return (Element) getServerElement().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) getServerElement().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(getServerElement(), "current-theme-full-name",

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

}

public String getThemesPath()

{

return XMLConfigHelper.getStringProperty(getServerElement(), "themes-path",

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

}

public String getPluginsPath()

{

return XMLConfigHelper.getStringProperty(getServerElement(), "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) getServerElement().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;

}

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

{

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

}

public void setThemesPath(String path)

{

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

}

public void setCurrentThemeFullName(String themeName)

{

getServerElement().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;

}

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

+3 −6

package com.stream_pi.server.window;

import com.stream_pi.server.connection.ServerListener;

import com.stream_pi.server.controller.ServerListener;

import com.stream_pi.server.io.Config;

import com.stream_pi.server.info.ServerInfo;

import com.stream_pi.server.Main;

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

import com.stream_pi.server.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.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.application.HostServices;

import javafx.beans.value.ChangeListener;

import javafx.beans.value.ObservableValue;

import javafx.scene.image.Image;

import javafx.scene.layout.StackPane;

import javafx.scene.text.Font;

import javafx.stage.Stage;

import java.awt.*;

import java.io.File;

import java.util.Objects;

import java.util.logging.Logger;

public abstract class Base extends StackPane implements ExceptionAndAlertHandler, ServerListener {

public abstract class Base extends StackPane implements ExceptionAndAlertHandler, ServerListener

{

private Config config;

private ServerInfo serverInfo;

private Stage stage;

private HostServices hostServices;

private SettingsBase settingsBase;

private DashboardBase dashboardBase;

private StackPane alertStackPane;

private StreamPiLogFileHandler logFileHandler = null;

private StreamPiLogFallbackHandler logFallbackHandler = null;

private Logger logger = null;

public Logger getLogger(){

return logger;

}

public void setHostServices(HostServices hostServices)

{

this.hostServices = hostServices;

}

public HostServices getHostServices()

{

return hostServices;

}

@Override

public void initLogger()

{

try

{

if(logFileHandler != null)

return;

closeLogger();

logger = Logger.getLogger("");

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

{

String path = ServerInfo.getInstance().getPrePath()+"../stream-pi-server.log";

if(ServerInfo.getInstance().getPlatform() == Platform.ANDROID)

path = ServerInfo.getInstance().getPrePath()+"stream-pi-server.log";

logFileHandler = new StreamPiLogFileHandler(path);

logger.addHandler(logFileHandler);

}

else

{

logFallbackHandler = new StreamPiLogFallbackHandler();

logger.addHandler(logFallbackHandler);

}

catch(Exception e)

{

e.printStackTrace();

logFallbackHandler = new StreamPiLogFallbackHandler();

logger.addHandler(logFallbackHandler);

}

public void closeLogger()

{

if(logFileHandler != null)

logFileHandler.close();

else if(logFallbackHandler != null)

logFallbackHandler.close();

}

public void initBase() throws SevereException

{

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

getStage().getIcons().clear();

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

getStage().setMinWidth(710);

getStage().setMinHeight(530);

serverInfo = ServerInfo.getInstance();

settingsBase = new SettingsBase(getHostServices(), this, this);

settingsBase.prefWidthProperty().bind(widthProperty());

settingsBase.prefHeightProperty().bind(heightProperty());

dashboardBase = new DashboardBase(this, getHostServices());

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

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

alertStackPane = new StackPane();

alertStackPane.setVisible(false);

StreamPiAlert.setParent(alertStackPane);

getChildren().clear();

getChildren().addAll(alertStackPane);

initLogger();

checkPrePathDirectory();

getChildren().addAll(settingsBase, dashboardBase);

applyDefaultStylesheet();

config = Config.getInstance();

initThemes();

stage.setWidth(config.getStartupWindowWidth());

stage.setHeight(config.getStartupWindowHeight());

stage.centerOnScreen();

dashboardBase.setDividerPositions(config.getRightDividerPositions());

dashboardBase.getLeftSplitPane().setDividerPositions(config.getLeftDividerPositions());

dashboardBase.toFront();

}

private void checkPrePathDirectory() throws SevereException

{

try

{

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

if(!filex.exists())

{

boolean result = filex.mkdirs();

if(result)

{

Config.unzipToDefaultPrePath();

initLogger();

}

else

{

setPrefSize(300,300);

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 initThemes() throws SevereException {

clearStylesheets();

registerThemes();

applyDefaultStylesheet();

applyDefaultTheme();

applyDefaultIconsStylesheet();

}

@Override

public Stage getStage()

{

return stage;

}

public void applyDefaultStylesheet()

{

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

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

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

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

}

public void applyDefaultIconsStylesheet()

{

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

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

}

public DashboardBase getDashboardBase()

{

return dashboardBase;

}

public SettingsBase getSettingsBase()

{

return settingsBase;

}

public Config getConfig()

{

return config;

}

public ServerInfo getServerInfo()

{

return serverInfo;

}

private Theme currentTheme;

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;

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

logger.info("... Theme applied successfully!");

}

public void clearStylesheets()

{

getStylesheets().clear();

}

Themes themes;

public void registerThemes() throws SevereException

{

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

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

if(!themes.getErrors().isEmpty())

{

StringBuilder themeErrors = new StringBuilder();

for(MinorException eachException : themes.getErrors())

{

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

}

if(themes.getIsBadThemeTheCurrentOne())

{

if(getConfig().getCurrentThemeFullName().equals(getConfig().getDefaultCurrentThemeFullName()))

{

throw new SevereException("Unable to get default theme ("+getConfig().getDefaultCurrentThemeFullName()+")\n" +

"Please restore the theme or reinstall.");

}

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("...Themes loaded successfully !");

}

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("Theme not found. reverting to light theme ...");

try {

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

Config.getInstance().save();

applyDefaultTheme();

}

catch (SevereException e)

{

handleSevereException(e);

}

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

+1 −5

package com.stream_pi.server.window.firsttimeuse;

import com.stream_pi.server.connection.ServerListener;

import com.stream_pi.server.controller.ServerListener;

import com.stream_pi.server.io.Config;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

import com.stream_pi.util.exception.SevereException;

import com.stream_pi.util.uihelper.HBoxInputBox;

import com.stream_pi.util.uihelper.SpaceFiller;

import javafx.geometry.Pos;

import javafx.scene.control.Alert;

import javafx.scene.control.Button;

import javafx.scene.control.Label;

import javafx.scene.control.TextField;

import javafx.scene.control.Alert.AlertType;

import javafx.scene.layout.HBox;

import javafx.scene.layout.Region;

import javafx.scene.layout.VBox;

import javafx.stage.Stage;

public class FinalConfigPane extends VBox

{

private TextField serverNicknameTextField;

private TextField serverPortTextField;

private Button nextButton;

private ExceptionAndAlertHandler exceptionAndAlertHandler;

private ServerListener serverListener;

public FinalConfigPane(ExceptionAndAlertHandler exceptionAndAlertHandler, ServerListener serverListener,

Button nextButton)

{

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

this.serverListener = serverListener;

this.nextButton = nextButton;

getStyleClass().add("first_time_use_pane_final_config");

Label label = new Label("Thats it. Now just name your Stream-Pi Server, and the port where the server will run on!\n" +

"You can leave the default value of the port as it is.");

label.setWrapText(true);

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

serverNicknameTextField = new TextField();

serverPortTextField = new TextField(Config.getDefaultPort()+"");

HBoxInputBox serverNickNameInputBox = new HBoxInputBox("Server Nickname", serverNicknameTextField, 200);

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

getChildren().addAll(label, serverNickNameInputBox, serverPortInputBox);

setSpacing(10.0);

setVisible(false);

}

public void makeChangesToNextButton()

{

nextButton.setText("Confirm");

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

}

private void onConfirmButtonClicked()

{

StringBuilder errors = new StringBuilder();

String serverNameStr = serverNicknameTextField.getText();

String serverPortStr = serverPortTextField.getText();

if(serverNameStr.isBlank() || serverNameStr.isEmpty())

{

errors.append("* Server Name cannot be blank.\n");

}

int serverPort=-1;

try {

serverPort = Integer.parseInt(serverPortStr);

if (serverPort < 1024)

errors.append("* Server Port must be more than 1024\n");

else if(serverPort > 65535)

errors.append("* Server Port must be lesser than 65535\n");

}

catch (NumberFormatException e)

{

errors.append("* Server Port must be integer.\n");

}

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

{

try

{

Config.getInstance().setServerName(serverNameStr);

Config.getInstance().setServerPort(serverPort);

Config.getInstance().setFirstTimeUse(false);

Config.getInstance().save();

serverListener.othInit();

serverListener.initLogger();

((Stage) getScene().getWindow()).close();

}

catch(SevereException e)

{

exceptionAndAlertHandler.handleSevereException(e);

}

else

{

Alert alert = new Alert(AlertType.ERROR);

alert.setResizable(false);

alert.getDialogPane().setPrefHeight(250);

alert.setContentText("Please rectify the following errors and try again:\n"+errors.toString());

alert.show();

}

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

+1 −1

package com.stream_pi.server.window.firsttimeuse;

import com.stream_pi.server.Main;

import com.stream_pi.server.connection.ServerListener;

import com.stream_pi.server.controller.ServerListener;

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

import java.util.Objects;

public class FirstTimeUse extends VBox{

public FirstTimeUse(ExceptionAndAlertHandler exceptionAndAlertHandler, ServerListener serverListener)

{

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

getStylesheets().add(Objects.requireNonNull(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);

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.setSpacing(10.0);

welcomePane = new WelcomePane();

licensePane = new LicensePane();

finalConfigPane = new FinalConfigPane(exceptionAndAlertHandler, serverListener, 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()

{

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.setText("Next");

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.setText("Agree and Continue");

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

finalConfigPane.makeChangesToNextButton();

previousButton.setVisible(true);

}

M src/main/java/com/stream_pi/server/window/settings/ClientsSettings.java

+1 −1

package com.stream_pi.server.window.settings;

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.connection.ClientConnection;

import com.stream_pi.server.connection.ClientConnections;

import com.stream_pi.server.connection.ServerListener;

import com.stream_pi.server.controller.ServerListener;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

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 javafx.application.Platform;

import javafx.collections.FXCollections;

import javafx.concurrent.Task;

import javafx.geometry.Insets;

import javafx.geometry.Pos;

import javafx.scene.CacheHint;

import javafx.scene.control.*;

import javafx.scene.layout.HBox;

import javafx.scene.layout.Priority;

import javafx.scene.layout.VBox;

import javafx.util.Callback;

import java.util.ArrayList;

import java.util.List;

import java.util.logging.Logger;

public class ClientsSettings extends VBox

{

private VBox clientsSettingsVBox;

private Button saveButton;

private ServerListener serverListener;

private Logger logger;

private ExceptionAndAlertHandler exceptionAndAlertHandler;

public ClientsSettings(ExceptionAndAlertHandler exceptionAndAlertHandler, ServerListener serverListener)

{

getStyleClass().add("clients_settings");

this.serverListener = serverListener;

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

clientSettingsVBoxArrayList = new ArrayList<>();

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

clientsSettingsVBox = new VBox();

clientsSettingsVBox.getStyleClass().add("clients_settings_vbox");

clientsSettingsVBox.setAlignment(Pos.TOP_CENTER);

setAlignment(Pos.TOP_CENTER);

ScrollPane scrollPane = new ScrollPane();

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

scrollPane.setHbarPolicy(ScrollPane.ScrollBarPolicy.AS_NEEDED);

VBox.setVgrow(scrollPane, Priority.ALWAYS);

scrollPane.maxWidthProperty().bind(widthProperty().multiply(0.8));

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

scrollPane.setContent(clientsSettingsVBox);

saveButton = new Button("Save");

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

HBox hBox = new HBox(saveButton);

hBox.setAlignment(Pos.CENTER_RIGHT);

getChildren().addAll(scrollPane, hBox);

setCache(true);

setCacheHint(CacheHint.SPEED);

}

public void onSaveButtonClicked()

{

new Thread(new Task<Void>() {

@Override

protected Void call()

{

try

{

Platform.runLater(()->saveButton.setDisable(true));

StringBuilder finalErrors = new StringBuilder();

for(ClientSettingsVBox clientSettingsVBox : clientSettingsVBoxArrayList)

{

StringBuilder errors = new StringBuilder();

if(clientSettingsVBox.getNickname().isBlank())

errors.append(" Cannot have blank nickname. \n");

for(ClientProfileVBox clientProfileVBox : clientSettingsVBox.getClientProfileVBoxes())

{

StringBuilder errors2 = new StringBuilder();

if(clientProfileVBox.getName().isBlank())

errors2.append(" cannot have blank nickname. \n");

try {

Integer.parseInt(clientProfileVBox.getActionSize());

}

catch (NumberFormatException e)

{

errors2.append(" Must have integer action Size. \n");

}

try {

Integer.parseInt(clientProfileVBox.getActionGap());

}

catch (NumberFormatException e)

{

errors2.append(" Must have integer action Gap. \n");

}

if(!errors2.toString().isEmpty())

{

errors.append(" ")

.append(clientProfileVBox.getRealName())

.append("\n")

.append(errors2)

.append("\n");

}

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

{

finalErrors.append("* ")

.append(clientSettingsVBox.getRealNickName())

.append("\n")

.append(errors)

.append("\n");

}

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

throw new MinorException("You made form mistakes",

"Please fix the following issues : \n"+finalErrors);

//save details and values

for(ClientSettingsVBox clientSettingsVBox : clientSettingsVBoxArrayList)

{

clientSettingsVBox.saveClientAndProfileDetails();

}

loadData();

serverListener.clearTemp();

}

catch (MinorException e)

{

e.printStackTrace();

exceptionAndAlertHandler.handleMinorException(e);

}

catch (SevereException e)

{

e.printStackTrace();

exceptionAndAlertHandler.handleSevereException(e);

}

catch (CloneNotSupportedException e)

{

e.printStackTrace();

exceptionAndAlertHandler.handleSevereException(new SevereException(

e.getMessage()

));

}

finally

{

Platform.runLater(()->saveButton.setDisable(false));

}

return null;

}

}).start();

}

private ArrayList<ClientSettingsVBox> clientSettingsVBoxArrayList;

public void loadData()

{

logger.info("Loading client data into ClientsSettings ...");

Platform.runLater(()-> clientsSettingsVBox.getChildren().clear());

clientSettingsVBoxArrayList.clear();

List<ClientConnection> clientConnections = ClientConnections.getInstance().getConnections();

if(clientConnections.size() == 0)

{

Platform.runLater(()->{

clientsSettingsVBox.getChildren().add(new Label("No Clients Connected."));

saveButton.setVisible(false);

});

}

else

{

Platform.runLater(()->saveButton.setVisible(true));

for (ClientConnection clientConnection : clientConnections) {

ClientSettingsVBox clientSettingsVBox = new ClientSettingsVBox(clientConnection);

clientSettingsVBoxArrayList.add(clientSettingsVBox);

Platform.runLater(()->clientsSettingsVBox.getChildren().add(clientSettingsVBox));

}

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

}

public class ClientSettingsVBox extends VBox

{

private ComboBox<ClientProfile> profilesComboBox;

private ComboBox<ClientTheme> themesComboBox;

private Client client;

public void setClient(Client client)

{

this.client = client;

}

public double getDisplayHeight() {

return client.getDisplayHeight();

}

public double getDisplayWidth() {

return client.getDisplayWidth();

}

private TextField nicknameTextField;

public String getNickname() {

return nicknameTextField.getText();

}

private Label nickNameLabel;

private Label versionLabel;

public String getRealNickName()

{

return nickNameLabel.getText();

}

private com.stream_pi.util.platform.Platform platform;

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

return platform;

}

private Label socketConnectionLabel;

private ClientConnection connection;

private Accordion profilesAccordion;

private ArrayList<ClientProfileVBox> clientProfileVBoxes;

private Label platformLabel;

public ArrayList<ClientProfileVBox> getClientProfileVBoxes() {

return clientProfileVBoxes;

}

public ClientSettingsVBox(ClientConnection connection)

{

this.connection = connection;

this.platform = connection.getClient().getPlatform();

clientProfileVBoxes = new ArrayList<>();

getStyleClass().add("clients_settings_each_client_box");

initUI();

loadValues();

}

public ClientConnection getConnection()

{

return connection;

}

public void saveClientAndProfileDetails() throws SevereException, CloneNotSupportedException, MinorException {

getConnection().saveClientDetails(

nicknameTextField.getText(),

profilesComboBox.getSelectionModel().getSelectedItem().getID(),

themesComboBox.getSelectionModel().getSelectedItem().getThemeFullName()

);

for(ClientProfileVBox clientProfileVBox : clientProfileVBoxes)

{

getConnection().saveProfileDetails(clientProfileVBox.getClientProfile());

}

//remove deleted client profiles

for(ClientProfile clientProfile : connection.getClient().getAllClientProfiles())

{

boolean found = false;

for(ClientProfileVBox clientProfileVBox : clientProfileVBoxes)

{

if(clientProfileVBox.getClientProfile().getID().equals(clientProfile.getID()))

{

found = true;

break;

}

if(!found)

{

connection.getClient().removeProfileFromID(clientProfile.getID());

connection.deleteProfile(clientProfile.getID());

}

public void initUI()

{

profilesComboBox = new ComboBox<>();

Callback<ListView<ClientProfile>, ListCell<ClientProfile>> profilesComboBoxFactory = new Callback<>() {

@Override

public ListCell<ClientProfile> call(ListView<ClientProfile> clientConnectionListView) {

return new ListCell<>() {

@Override

protected void updateItem(ClientProfile clientProfile, boolean b) {

super.updateItem(clientProfile, b);

if(clientProfile == null)

{

setText(null);

}

else

{

setText(clientProfile.getName());

}

};

}

};

profilesComboBox.setCellFactory(profilesComboBoxFactory);

profilesComboBox.setButtonCell(profilesComboBoxFactory.call(null));

themesComboBox = new ComboBox<>();

Callback<ListView<ClientTheme>, ListCell<ClientTheme>> themesComboBoxFactory = new Callback<>() {

@Override

public ListCell<ClientTheme> call(ListView<ClientTheme> clientConnectionListView) {

return new ListCell<>() {

@Override

protected void updateItem(ClientTheme clientTheme, boolean b) {

super.updateItem(clientTheme, b);

if(clientTheme == null)

{

setText(null);

}

else

{

setText(clientTheme.getShortName());

}

};

}

};

themesComboBox.setCellFactory(themesComboBoxFactory);

themesComboBox.setButtonCell(themesComboBoxFactory.call(null));

platformLabel = new Label();

platformLabel.getStyleClass().add("client_settings_each_client_platform_label");

socketConnectionLabel = new Label();

socketConnectionLabel.getStyleClass().add("client_settings_each_client_socket_connection_label");

nicknameTextField = new TextField();

nickNameLabel = new Label();

nickNameLabel.getStyleClass().add("client_settings_each_client_nick_name_label");

versionLabel = new Label();

versionLabel.getStyleClass().add("client_settings_each_client_version_label");

profilesAccordion = new Accordion();

profilesAccordion.getStyleClass().add("client_settings_each_client_profiles_accordion");

VBox.setMargin(profilesAccordion, new Insets(0,0,20,0));

Button addNewProfileButton = new Button("Add new Profile");

addNewProfileButton.setOnAction(event -> onNewProfileButtonClicked());

setSpacing(10.0);

getStyleClass().add("settings_clients_each_client");

this.getChildren().addAll(

nickNameLabel,

socketConnectionLabel,

platformLabel,

versionLabel,

new HBoxInputBox("Nickname",nicknameTextField),

new HBox(

new Label("Theme"),

SpaceFiller.horizontal(),

themesComboBox

new HBox(new Label("Startup Profile"),

SpaceFiller.horizontal(),

profilesComboBox),

addNewProfileButton,

profilesAccordion);

}

public void loadValues()

{

Client client = connection.getClient();

profilesComboBox.setItems(FXCollections.observableList(client.getAllClientProfiles()));

profilesComboBox.getSelectionModel().select(

client.getProfileByID(client.getDefaultProfileID())

);

themesComboBox.setItems(FXCollections.observableList(client.getThemes()));

themesComboBox.getSelectionModel().select(

client.getThemeByFullName(

client.getDefaultThemeFullName()

)

);

nicknameTextField.setText(client.getNickName());

platformLabel.setText("Platform : "+client.getPlatform().getUIName());

setClient(client);

socketConnectionLabel.setText(client.getRemoteSocketAddress().toString().substring(1)); //substring removes the `/`

nickNameLabel.setText(client.getNickName());

versionLabel.setText(client.getReleaseStatus().getUIName()+" "+client.getVersion().getText());

//add profiles

for(ClientProfile clientProfile : client.getAllClientProfiles())

{

TitledPane titledPane = new TitledPane();

titledPane.getStyleClass().add("client_settings_each_client_accordion_each_titled_pane");

titledPane.setText(clientProfile.getName());

ClientProfileVBox clientProfileVBox = new ClientProfileVBox(clientProfile);

clientProfileVBox.getRemoveButton().setOnAction(event -> onProfileDeleteButtonClicked(clientProfileVBox, titledPane));

titledPane.setContent(clientProfileVBox);

clientProfileVBoxes.add(clientProfileVBox);

profilesAccordion.getPanes().add(titledPane);

}

public void onNewProfileButtonClicked()

{

ClientProfile clientProfile = new ClientProfile(

"Untitled Profile",

100,

);

ClientProfileVBox clientProfileVBox = new ClientProfileVBox(clientProfile);

TitledPane titledPane = new TitledPane();

titledPane.setContent(clientProfileVBox);

titledPane.setText(clientProfile.getName());

clientProfileVBox.getRemoveButton().setOnAction(event -> onProfileDeleteButtonClicked(clientProfileVBox, titledPane));

clientProfileVBoxes.add(clientProfileVBox);

profilesAccordion.getPanes().add(titledPane);

}

public void onProfileDeleteButtonClicked(ClientProfileVBox clientProfileVBox, TitledPane titledPane)

{

if(clientProfileVBoxes.size() == 1)

{

exceptionAndAlertHandler.handleMinorException(new MinorException("Only one",

"You cannot delete all profiles"));

}

else

{

if(profilesComboBox.getSelectionModel().getSelectedItem().getID().equals(clientProfileVBox.getClientProfile().getID()))

{

exceptionAndAlertHandler.handleMinorException(new MinorException("Default",

"You cannot delete default profile. Change to another one to delete this."));

}

else

{

clientProfileVBoxes.remove(clientProfileVBox);

profilesComboBox.getItems().remove(clientProfileVBox.getClientProfile());

profilesAccordion.getPanes().remove(titledPane);

}

public class ClientProfileVBox extends VBox

{

private TextField nameTextField;

public String getName()

{

return nameTextField.getText();

}

private TextField rowsTextField;

public String getRows()

{

return rowsTextField.getText();

}

private TextField colsTextField;

public String getCols()

{

return colsTextField.getText();

}

private TextField actionSizeTextField;

public String getActionSize()

{

return actionSizeTextField.getText();

}

private TextField actionGapTextField;

public String getActionGap()

{

return actionGapTextField.getText();

}

private Button removeButton;

private ClientProfile clientProfile;

public String getRealName()

{

return clientProfile.getName();

}

public ClientProfileVBox(ClientProfile clientProfile)

{

this.clientProfile = clientProfile;

getStyleClass().add("client_settings_each_client_accordion_each_profile_box");

initUI();

loadValues(clientProfile);

}

public void initUI()

{

setPadding(new Insets(5.0));

setSpacing(10.0);

nameTextField = new TextField();

rowsTextField = new TextField();

colsTextField = new TextField();

actionSizeTextField = new TextField();

actionGapTextField = new TextField();

removeButton = new Button("Remove");

HBox hBox = new HBox(removeButton);

hBox.setAlignment(Pos.CENTER_RIGHT);

getChildren().addAll(

new HBoxInputBox("Name ", nameTextField),

new HBoxInputBox("Rows", rowsTextField),

new HBoxInputBox("Columns", colsTextField),

new HBoxInputBox("Action Size", actionSizeTextField),

new HBoxInputBox("Action Gap", actionGapTextField),

hBox

);

}

public Button getRemoveButton()

{

return removeButton;

}

public void loadValues(ClientProfile clientProfile)

{

nameTextField.setText(clientProfile.getName());

rowsTextField.setText(clientProfile.getRows()+"");

colsTextField.setText(clientProfile.getCols()+"");

actionSizeTextField.setText(clientProfile.getActionSize()+"");

actionGapTextField.setText(clientProfile.getActionGap()+"");

}

public ClientProfile getClientProfile()

{

clientProfile.setActionGap(Integer.parseInt(actionGapTextField.getText()));

clientProfile.setActionSize(Integer.parseInt(actionSizeTextField.getText()));

clientProfile.setRows(Integer.parseInt(rowsTextField.getText()));

clientProfile.setCols(Integer.parseInt(colsTextField.getText()));

clientProfile.setName(nameTextField.getText());

return clientProfile;

}

M src/main/java/com/stream_pi/server/window/settings/GeneralSettings.java

+29 −9

package com.stream_pi.server.window.settings;

import com.stream_pi.server.connection.ServerListener;

import com.stream_pi.server.controller.ServerListener;

import com.stream_pi.server.info.StartupFlags;

import com.stream_pi.server.io.Config;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

import com.stream_pi.server.info.ServerInfo;

import com.stream_pi.theme_api.Themes;

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.checkforupdates.CheckForUpdates;

import com.stream_pi.util.checkforupdates.UpdateHyperlinkOnClick;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.exception.SevereException;

import com.stream_pi.util.platform.PlatformType;

import com.stream_pi.util.startatboot.StartAtBoot;

import com.stream_pi.util.uihelper.HBoxWithSpaceBetween;

import com.stream_pi.util.version.Version;

import javafx.application.HostServices;

import javafx.application.Platform;

import javafx.concurrent.Task;

import javafx.event.ActionEvent;

import javafx.geometry.Insets;

import javafx.geometry.Pos;

import javafx.scene.control.*;

import javafx.scene.control.Button;

import javafx.scene.control.Label;

import javafx.scene.control.ScrollPane;

import javafx.scene.control.TextField;

import javafx.scene.layout.*;

import javafx.stage.DirectoryChooser;

import org.controlsfx.control.ToggleSwitch;

import org.kordamp.ikonli.javafx.FontIcon;

import java.awt.SystemTray;

import java.io.BufferedReader;

import java.io.File;

import java.io.InputStreamReader;

import java.net.URL;

import java.util.logging.Logger;

public class GeneralSettings extends VBox {

private final TextField serverNameTextField;

private final TextField portTextField;

private final TextField pluginsPathTextField;

private final TextField themesPathTextField;

private final TextField actionGridPaneActionBoxSize;

private final TextField actionGridPaneActionBoxGap;

private final ToggleSwitch startOnBootToggleSwitch;

private final HBoxWithSpaceBetween startOnBootHBox;

private final ToggleSwitch minimizeToSystemTrayOnCloseToggleSwitch;

private final HBoxWithSpaceBetween minimizeToSystemTrayOnCloseHBox;

private final ToggleSwitch showAlertsPopupToggleSwitch;

private final HBoxWithSpaceBetween showAlertsPopupHBox;

private final Button saveButton;

private final Button checkForUpdatesButton;

private final Button factoryResetButton;

private Logger logger;

private ExceptionAndAlertHandler exceptionAndAlertHandler;

private ServerListener serverListener;

private HostServices hostServices;

public GeneralSettings(ExceptionAndAlertHandler exceptionAndAlertHandler, ServerListener serverListener, HostServices hostServices)

{

this.hostServices = hostServices;

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

this.serverListener = serverListener;

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

serverNameTextField = new TextField();

portTextField = new TextField();

pluginsPathTextField = new TextField();

themesPathTextField = new TextField();

actionGridPaneActionBoxSize = new TextField();

actionGridPaneActionBoxGap = new TextField();

startOnBootToggleSwitch = new ToggleSwitch();

startOnBootHBox = new HBoxWithSpaceBetween("Start on Boot", startOnBootToggleSwitch);

startOnBootHBox.managedProperty().bind(startOnBootHBox.visibleProperty());

minimizeToSystemTrayOnCloseToggleSwitch = new ToggleSwitch();

minimizeToSystemTrayOnCloseHBox = new HBoxWithSpaceBetween("Minimise To Tray On Close", minimizeToSystemTrayOnCloseToggleSwitch);

showAlertsPopupToggleSwitch = new ToggleSwitch();

showAlertsPopupHBox = new HBoxWithSpaceBetween("Show Popup On Alert", showAlertsPopupToggleSwitch);

checkForUpdatesButton = new Button("Check for updates");

checkForUpdatesButton.setOnAction(event->checkForUpdates());

factoryResetButton = new Button("Factory Reset");

factoryResetButton.setOnAction(actionEvent -> onFactoryResetButtonClicked());

getStyleClass().add("general_settings");

prefWidthProperty().bind(widthProperty());

setAlignment(Pos.CENTER);

setSpacing(5);

getChildren().addAll(

getUIInputBox("Server Name", serverNameTextField),

getUIInputBox("Port", portTextField),

getUIInputBox("Grid Pane - Box Size", actionGridPaneActionBoxSize),

getUIInputBox("Grid Pane - Box Gap", actionGridPaneActionBoxGap),

getUIInputBoxWithDirectoryChooser("Plugins Path", pluginsPathTextField),

getUIInputBoxWithDirectoryChooser("Themes Path", themesPathTextField),

minimizeToSystemTrayOnCloseHBox,

startOnBootHBox,

showAlertsPopupHBox

);

serverNameTextField.setPrefWidth(200);

saveButton = new Button("Save");

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

getChildren().addAll(checkForUpdatesButton, saveButton);

getChildren().addAll(factoryResetButton, checkForUpdatesButton, saveButton);

setPadding(new Insets(10));

}

private void checkForUpdates()

{

new CheckForUpdates(checkForUpdatesButton,

PlatformType.SERVER, ServerInfo.getInstance().getVersion(), new UpdateHyperlinkOnClick() {

@Override

public void handle(ActionEvent actionEvent) {

hostServices.showDocument(getURL());

}

});

}

private HBox getUIInputBoxWithDirectoryChooser(String labelText, TextField textField)

{

HBox hBox = getUIInputBox(labelText, textField);

hBox.setSpacing(5.0);

TextField tf = (TextField) hBox.getChildren().get(2);

tf.setPrefWidth(300);

tf.setDisable(true);

Button button = new Button();

FontIcon fontIcon = new FontIcon("far-folder");

button.setGraphic(fontIcon);

button.setOnAction(event -> {

DirectoryChooser directoryChooser = new DirectoryChooser();

try {

File selectedDirectory = directoryChooser.showDialog(getScene().getWindow());

textField.setText(selectedDirectory.getAbsolutePath());

}

catch (NullPointerException e)

{

logger.info("No folder selected");

}

});

hBox.getChildren().add(button);

return hBox;

}

private HBox getUIInputBox(String labelText, TextField textField)

{

textField.setPrefWidth(100);

Label label = new Label(labelText);

Region region = new Region();

HBox.setHgrow(region, Priority.ALWAYS);

return new HBox(label, region, textField);

}

public void loadDataFromConfig() throws SevereException {

Config config = Config.getInstance();

Platform.runLater(()->

{

serverNameTextField.setText(config.getServerName());

portTextField.setText(config.getPort()+"");

pluginsPathTextField.setText(config.getPluginsPath());

themesPathTextField.setText(config.getThemesPath());

actionGridPaneActionBoxSize.setText(config.getActionGridActionSize()+"");

actionGridPaneActionBoxGap.setText(config.getActionGridActionGap()+"");

minimizeToSystemTrayOnCloseToggleSwitch.setSelected(config.getMinimiseToSystemTrayOnClose());

showAlertsPopupToggleSwitch.setSelected(config.isShowAlertsPopup());

startOnBootToggleSwitch.setSelected(config.getStartOnBoot());

});

}

public void save()

{

new Thread(new Task<Void>() {

@Override

protected Void call()

{

try {

boolean toBeReloaded = false;

boolean dashToBeReRendered = false;

Platform.runLater(()->{

saveButton.setDisable(true);

});

String serverNameStr = serverNameTextField.getText();

String serverPortStr = portTextField.getText();

String pluginsPathStr = pluginsPathTextField.getText();

String themesPathStr = themesPathTextField.getText();

String actionGridActionBoxSize = actionGridPaneActionBoxSize.getText();

String actionGridActionBoxGap = actionGridPaneActionBoxGap.getText();

boolean minimizeToSystemTrayOnClose = minimizeToSystemTrayOnCloseToggleSwitch.isSelected();

boolean showAlertsPopup = showAlertsPopupToggleSwitch.isSelected();

boolean startOnBoot = startOnBootToggleSwitch.isSelected();

Config config = Config.getInstance();

StringBuilder errors = new StringBuilder();

if(serverNameStr.isBlank())

{

errors.append("* Server Name cannot be blank.\n");

}

else

{

if(!config.getServerName().equals(serverNameStr))

{

toBeReloaded = true;

}

int serverPort=-1;

try {

serverPort = Integer.parseInt(serverPortStr);

if (serverPort < 1024)

errors.append("* Server Port must be more than 1024\n");

else if(serverPort > 65535)

errors.append("* Server Port must be lesser than 65535\n");

if(config.getPort()!=serverPort)

{

toBeReloaded = true;

}

catch (NumberFormatException e)

{

errors.append("* Server Port must be integer.\n");

}

int actionSize=-1;

try {

actionSize = Integer.parseInt(actionGridActionBoxSize);

if(config.getActionGridActionSize() != actionSize)

{

dashToBeReRendered = true;

}

catch (NumberFormatException e)

{

errors.append("* action Size must be integer.\n");

}

int actionGap=-1;

try {

actionGap = Integer.parseInt(actionGridActionBoxGap);

if(config.getActionGridActionGap() != actionGap)

{

dashToBeReRendered = true;

}

catch (NumberFormatException e)

{

errors.append("* action Gap must be integer.\n");

}

if(pluginsPathStr.isBlank())

{

errors.append("* Plugins Path must not be blank.\n");

}

else

{

if(!config.getPluginsPath().equals(pluginsPathStr))

{

toBeReloaded = true;

}

if(themesPathStr.isBlank())

{

errors.append("* Themes Path must not be blank.\n");

}

else

{

if(!config.getThemesPath().equals(themesPathStr))

{

toBeReloaded = true;

}

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

{

throw new MinorException("Uh Oh!", "Please rectify the following errors and try again :\n"+errors.toString());

}

if(config.getStartOnBoot() != startOnBoot)

{

if(StartupFlags.RUNNER_FILE_NAME == 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(PlatformType.SERVER, ServerInfo.getInstance().getPlatform());

if(startOnBoot)

{

startAtBoot.create(new File(StartupFlags.RUNNER_FILE_NAME));

}

else

{

boolean result = startAtBoot.delete();

if(!result)

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

}

if(minimizeToSystemTrayOnClose)

{

if(!SystemTray.isSupported())

{

StreamPiAlert alert = new StreamPiAlert("Not Supported", "Tray System not supported on this platform ", StreamPiAlertType.ERROR);

alert.show();

minimizeToSystemTrayOnClose = false;

}

config.setServerName(serverNameStr);

config.setServerPort(serverPort);

config.setActionGridGap(actionGap);

config.setActionGridSize(actionSize);

config.setPluginsPath(pluginsPathStr);

config.setThemesPath(themesPathStr);

config.setMinimiseToSystemTrayOnClose(minimizeToSystemTrayOnClose);

StreamPiAlert.setIsShowPopup(showAlertsPopup);

config.setShowAlertsPopup(showAlertsPopup);

config.setStartupOnBoot(startOnBoot);

config.save();

loadDataFromConfig();

if(toBeReloaded)

{

StreamPiAlert restartPrompt = new StreamPiAlert(

"Warning",

"Stream-Pi Server needs to be restarted for these changes to take effect. Restart?\n" +

"All your current connections will be disconnected.",

StreamPiAlertType.WARNING

);

String yesOption = "Yes";

String noOption = "No";

restartPrompt.setButtons(yesOption, noOption);

restartPrompt.setOnClicked(new StreamPiAlertListener() {

@Override

public void onClick(String s) {

if(s.equals(yesOption))

{

serverListener.restart();

}

});

restartPrompt.show();

}

if(dashToBeReRendered)

{

serverListener.clearTemp();

}

catch (MinorException e)

{

exceptionAndAlertHandler.handleMinorException(e);

}

catch (SevereException e)

{

exceptionAndAlertHandler.handleSevereException(e);

}

finally {

Platform.runLater(()->{

saveButton.setDisable(false);

});

}

return null;

}

}).start();

}

private void onFactoryResetButtonClicked()

{

StreamPiAlert confirmation = new StreamPiAlert("Warning","Are you sure?\n" +

"This will erase everything.",StreamPiAlertType.WARNING);

String yesButton = "Yes";

String noButton = "No";

confirmation.setButtons(yesButton, noButton);

confirmation.setOnClicked(new StreamPiAlertListener() {

@Override

public void onClick(String s) {

if(s.equals(yesButton))

{

serverListener.factoryReset();

}

});

confirmation.show();

}

M src/main/java/com/stream_pi/server/window/settings/PluginsSettings.java

+1 −2

package com.stream_pi.server.window.settings;

import com.stream_pi.action_api.externalplugin.ExternalPlugin;

import com.stream_pi.server.uipropertybox.UIPropertyBox;

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

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

import com.stream_pi.server.action.ExternalPlugins;

import com.stream_pi.server.connection.ServerListener;

import com.stream_pi.server.controller.ServerListener;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.uihelper.SpaceFiller;

import org.kordamp.ikonli.javafx.FontIcon;

import javafx.application.HostServices;

import javafx.application.Platform;

import javafx.geometry.Pos;

import javafx.scene.Node;

import javafx.scene.control.*;

import javafx.scene.layout.HBox;

import javafx.scene.layout.Priority;

import javafx.scene.layout.Region;

import javafx.scene.layout.VBox;

import java.util.ArrayList;

import java.util.List;

import java.util.logging.Logger;

public class PluginsSettings extends VBox {

private VBox pluginsSettingsVBox;

private ServerListener serverListener;

private Logger logger;

private ExceptionAndAlertHandler exceptionAndAlertHandler;

private HostServices hostServices;

public PluginsSettings(ExceptionAndAlertHandler exceptionAndAlertHandler, HostServices hostServices)

{

getStyleClass().add("plugins_settings");

this.hostServices = hostServices;

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

pluginProperties = new ArrayList<>();

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

pluginsSettingsVBox = new VBox();

pluginsSettingsVBox.getStyleClass().add("plugins_settings_vbox");

pluginsSettingsVBox.setAlignment(Pos.TOP_CENTER);

ScrollPane scrollPane = new ScrollPane();

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

scrollPane.setHbarPolicy(ScrollPane.ScrollBarPolicy.NEVER);

scrollPane.maxWidthProperty().bind(widthProperty().multiply(0.8));

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

scrollPane.setContent(pluginsSettingsVBox);

VBox.setVgrow(scrollPane, Priority.ALWAYS);

setAlignment(Pos.TOP_CENTER);

saveButton = new Button("Save");

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

HBox hBox = new HBox(saveButton);

hBox.setAlignment(Pos.CENTER_RIGHT);

getChildren().addAll(scrollPane, hBox);

}

private Button saveButton;

public void onSaveButtonClicked()

{

try {

//form validation

StringBuilder finalErrors = new StringBuilder();

for (PluginProperties p : pluginProperties)

{

StringBuilder errors = new StringBuilder();

for(int j = 0; j < p.getServerPropertyUIBox().size(); j++)

{

UIPropertyBox serverProperty = p.getServerPropertyUIBox().get(j);

Node controlNode = serverProperty.getControlNode();

if (serverProperty.getControlType() == ControlType.TEXT_FIELD)

{

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

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

{

try

{

Integer.parseInt(value);

}

catch (NumberFormatException e)

{

errors.append(" -> ").append(serverProperty.getDisplayName()).append(" must be integer.\n");

}

else

{

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

errors.append(" -> ").append(serverProperty.getDisplayName()).append(" cannot be blank.\n");

}

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

{

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

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

errors.append(" -> ").append(serverProperty.getDisplayName()).append(" cannot be blank.\n");

}

if(!errors.toString().isBlank())

{

finalErrors.append(" * ").append(p.getName()).append("\n").append(errors.toString()).append("\n");

}

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

{

throw new MinorException("Form Validation Errors",

"Please rectify the following errors and try again \n"+finalErrors.toString());

}

//save

for (PluginProperties pp : pluginProperties) {

for (int j = 0; j < pp.getServerPropertyUIBox().size(); j++) {

UIPropertyBox serverProperty = pp.getServerPropertyUIBox().get(j);

String rawValue = serverProperty.getRawValue();

ExternalPlugins.getInstance().getActionFromIndex(pp.getIndex())

.getServerProperties().get()

.get(serverProperty.getIndex()).setRawValue(rawValue);

}

ExternalPlugins.getInstance().saveServerSettings();

ExternalPlugins.getInstance().initPlugins();

}

catch (MinorException e)

{

e.printStackTrace();

exceptionAndAlertHandler.handleMinorException(e);

}

private ArrayList<PluginProperties> pluginProperties;

public void showPluginInitError()

{

Platform.runLater(()->{

pluginsSettingsVBox.getChildren().add(new Label("Plugin init error. Resolve issues and restart."));

saveButton.setVisible(false);

});

}

public void loadPlugins() throws MinorException {

pluginProperties.clear();

List<ExternalPlugin> actions = ExternalPlugins.getInstance().getPlugins();

Platform.runLater(()-> pluginsSettingsVBox.getChildren().clear());

if(actions.size() == 0)

{

Platform.runLater(()->{

Label l = new Label("No Plugins Installed.");

l.getStyleClass().add("plugins_pane_no_plugins_installed_label");

pluginsSettingsVBox.getChildren().add(l);

saveButton.setVisible(false);

});

return;

}

else

{

Platform.runLater(()->saveButton.setVisible(true));

}

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

{

ExternalPlugin action = actions.get(i);

if(!action.isVisibleInServerSettingsPane())

continue;

Label headingLabel = new Label(action.getName());

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

HBox headerHBox = new HBox(headingLabel);

headerHBox.getStyleClass().add("plugins_settings_each_plugin_header");

if (action.getHelpLink()!=null)

{

Button helpButton = new Button();

helpButton.getStyleClass().add("plugins_settings_each_plugin_help_button");

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

questionIcon.getStyleClass().add("plugins_settings_each_plugin_help_icon");

helpButton.setGraphic(questionIcon);

helpButton.setOnAction(event -> hostServices.showDocument(action.getHelpLink()));

headerHBox.getChildren().addAll(SpaceFiller.horizontal() ,helpButton);

}

Label authorLabel = new Label(action.getAuthor());

authorLabel.getStyleClass().add("plugins_settings_each_plugin_author_label");

Label moduleLabel = new Label(action.getModuleName());

moduleLabel.getStyleClass().add("plugins_settings_each_plugin_module_label");

Label versionLabel = new Label("Version : "+action.getVersion().getText());

versionLabel.getStyleClass().add("plugins_settings_each_plugin_version_label");

VBox serverPropertiesVBox = new VBox();

serverPropertiesVBox.getStyleClass().add("plugins_settings_each_plugin_server_properties_box");

serverPropertiesVBox.setSpacing(10.0);

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

ArrayList<UIPropertyBox> serverPropertyArrayList = new ArrayList<>();

for(int j =0; j<serverProperties.size(); j++)

{

Property eachProperty = serverProperties.get(j);

if(!eachProperty.isVisible())

continue;

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

Region region = new Region();

HBox.setHgrow(region, Priority.ALWAYS);

HBox hBox = new HBox(label, SpaceFiller.horizontal());

//hBox.setId(j+"");

Node controlNode = null;

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

{

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

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

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

hBox.getChildren().add(comboBox);

controlNode = comboBox;

}

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

{

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

hBox.getChildren().add(textField);

controlNode = textField;

}

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

{

PasswordField textField = new PasswordField();

textField.setText(eachProperty.getRawValue());

controlNode= textField;

hBox.getChildren().add(controlNode);

}

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

{

ToggleButton toggleButton = new ToggleButton();

toggleButton.setSelected(eachProperty.getBoolValue());

if(eachProperty.getBoolValue())

toggleButton.setText("ON");

else

toggleButton.setText("OFF");

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

if(t1)

toggleButton.setText("ON");

else

toggleButton.setText("OFF");

});

hBox.getChildren().add(toggleButton);

controlNode = toggleButton;

}

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

{

Slider slider = new Slider();

slider.setValue(eachProperty.getDoubleValue());

slider.setMax(eachProperty.getMaxDoubleValue());

slider.setMin(eachProperty.getMinDoubleValue());

hBox.getChildren().add(slider);

controlNode = slider;

}

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

{

Slider slider = new Slider();

slider.setValue(eachProperty.getIntValue());

slider.setMax(eachProperty.getMaxIntValue());

slider.setMin(eachProperty.getMinIntValue());

slider.setBlockIncrement(1.0);

slider.setSnapToTicks(true);

hBox.getChildren().add(slider);

controlNode = slider;

}

UIPropertyBox serverProperty = new UIPropertyBox(j, eachProperty.getDisplayName(), controlNode, eachProperty.getControlType(), eachProperty.getType(), eachProperty.isCanBeBlank());

serverPropertyArrayList.add(serverProperty);

serverPropertiesVBox.getChildren().add(hBox);

}

PluginProperties pp = new PluginProperties(i, serverPropertyArrayList, action.getName());

pluginProperties.add(pp);

Platform.runLater(()->{

VBox vBox = new VBox();

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

vBox.setSpacing(5.0);

vBox.getChildren().addAll(headerHBox, authorLabel, moduleLabel, versionLabel, serverPropertiesVBox);

if(action.getServerSettingsButtonBar()!=null)

{

action.getServerSettingsButtonBar().getStyleClass().add("plugins_settings_each_plugin_button_bar");

HBox buttonBarHBox = new HBox(SpaceFiller.horizontal(), action.getServerSettingsButtonBar());

buttonBarHBox.getStyleClass().add("plugins_settings_each_plugin_button_bar_hbox");

vBox.getChildren().add(buttonBarHBox);

}

pluginsSettingsVBox.getChildren().add(vBox);

});

}

public class PluginProperties

{

private int index;

private ArrayList<UIPropertyBox> serverProperty;

private String name;

public PluginProperties(int index, ArrayList<UIPropertyBox> serverProperty, String name)

{

this.index = index;

this.serverProperty = serverProperty;

this.name = name;

}

public String getName()

{

return name;

}

public int getIndex() {

return index;

}

public ArrayList<UIPropertyBox> getServerPropertyUIBox() {

return serverProperty;

}

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

+1 −1

package com.stream_pi.server.window.settings;

import com.stream_pi.server.connection.ServerListener;

import com.stream_pi.server.controller.ServerListener;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

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

import javafx.application.HostServices;

import javafx.event.Event;

import javafx.geometry.Insets;

import javafx.geometry.Pos;

import javafx.scene.CacheHint;

import javafx.scene.control.*;

import javafx.scene.input.SwipeEvent;

import javafx.scene.layout.Priority;

import javafx.scene.layout.VBox;

public class SettingsBase extends VBox

{

private TabPane tabPane;

private GeneralSettings generalSettings;

private PluginsSettings pluginsSettings;

private ThemesSettings themesSettings;

private ClientsSettings clientsSettings;

private Button closeButton;

private HostServices hostServices;

private ExceptionAndAlertHandler exceptionAndAlertHandler;

public SettingsBase(HostServices hostServices, ExceptionAndAlertHandler exceptionAndAlertHandler,

ServerListener serverListener)

{

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

this.hostServices = hostServices;

tabPane = new TabPane();

tabPane.addEventFilter(SwipeEvent.ANY, Event::consume);

tabPane.setTabClosingPolicy(TabPane.TabClosingPolicy.UNAVAILABLE);

VBox.setVgrow(tabPane, Priority.ALWAYS);

Tab generalSettingsTab = new Tab("General");

generalSettings = new GeneralSettings(exceptionAndAlertHandler, serverListener, hostServices);

generalSettingsTab.setContent(generalSettings);

Tab pluginsSettingsTab = new Tab("Plugins");

pluginsSettings = new PluginsSettings(exceptionAndAlertHandler, hostServices);

pluginsSettingsTab.setContent(pluginsSettings);

Tab themesSettingsTab = new Tab("Themes");

themesSettings = new ThemesSettings(hostServices);

themesSettingsTab.setContent(themesSettings);

Tab clientsSettingsTab = new Tab("Clients");

clientsSettings = new ClientsSettings(exceptionAndAlertHandler, serverListener);

clientsSettingsTab.setContent(clientsSettings);

Tab aboutTab = new Tab("About");

aboutTab.setContent(new About(hostServices));

tabPane.getTabs().addAll(generalSettingsTab, pluginsSettingsTab, themesSettingsTab, clientsSettingsTab, aboutTab);

setAlignment(Pos.TOP_RIGHT);

closeButton = new Button("Close");

VBox.setMargin(closeButton, new Insets(10.0));

getChildren().addAll(tabPane, closeButton);

setCache(true);

setCacheHint(CacheHint.SPEED);

}

public void setDefaultTabToGeneral()

{

tabPane.getSelectionModel().selectFirst();

}

public Button getCloseButton()

{

return closeButton;

}

public GeneralSettings getGeneralSettings()

{

return generalSettings;

}

public PluginsSettings getPluginsSettings()

{

return pluginsSettings;

}

public ThemesSettings getThemesSettings()

{

return themesSettings;

}

public ClientsSettings getClientsSettings()

{

return clientsSettings;

}

Public

server

Clone or download

Refactored, Added factory reset

Modified Files