server

removed client display size editing feature

Download Browse

+31 −69

Author

Debayan Sutradhar (rnayabed) 2021-03-10 14:27

Committer

Debayan Sutradhar (rnayabed) 2021-03-10 14:27

Hash f75bebd0c36b6494f7eafa18795efc8730d9f4bc

Parent c8c2abfc1cb9df1895d24cea5c8f29a47648e65d

Reference git #server/f75bebd0c36b6494f7eafa18795efc8730d9f4bc

Modified Files

List

Side by side diff

Inline diff

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

+11 −11

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

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

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

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

(at your option) any later version.

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

but WITHOUT ANY WARRANTY; without even the implied warranty of

MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

GNU General Public License for more details.

Written by : Debayan Sutradhar (rnayabed)

package com.stream_pi.server.client;

import com.stream_pi.util.platform.Platform;

import com.stream_pi.util.platform.ReleaseStatus;

import com.stream_pi.util.version.Version;

import java.net.SocketAddress;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

public class Client

{

private String nickName;

private final SocketAddress remoteSocketAddress;

private final Platform platform;

private final Version version;

private final Version commStandardVersion;

private final Version themeAPIVersion;

private final ReleaseStatus releaseStatus;

private double startupDisplayHeight, startupDisplayWidth;

private double displayHeight, displayWidth;

private final HashMap<String,ClientProfile> profiles;

private final HashMap<String,ClientTheme> themes;

private String defaultProfileID;

private String defaultThemeFullName;

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

{

this.version = version;

this.releaseStatus = releaseStatus;

this.commStandardVersion = commStandardVersion;

this.themeAPIVersion = themeAPIVersion;

this.nickName = nickName;

this.remoteSocketAddress = remoteSocketAddress;

this.platform = platform;

this.profiles = new HashMap<>();

this.themes = new HashMap<>();

}

public ReleaseStatus getReleaseStatus() {

return releaseStatus;

}

public void setDefaultThemeFullName(String defaultThemeFullName) {

this.defaultThemeFullName = defaultThemeFullName;

}

public String getDefaultThemeFullName() {

return defaultThemeFullName;

}

public void setDefaultProfileID(String ID)

{

defaultProfileID = ID;

}

public void addTheme(ClientTheme clientTheme) throws CloneNotSupportedException

{

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

}

public ArrayList<ClientTheme> getThemes()

{

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

for(String clientTheme : themes.keySet())

{

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

}

return clientThemes;

}

public ClientTheme getThemeByFullName(String fullName)

{

return themes.getOrDefault(fullName, null);

}

public String getDefaultProfileID()

{

return defaultProfileID;

}

//client Profiles

public void setNickName(String nickName)

{

this.nickName = nickName;

}

public List<ClientProfile> getAllClientProfiles()

{

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

for(String profile : profiles.keySet())

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

return clientProfiles;

}

public void removeProfileFromID(String ID)

{

profiles.remove(ID);

}

public void addProfile(ClientProfile clientProfile) throws CloneNotSupportedException {

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

}

public synchronized ClientProfile getProfileByID(String ID) {

return profiles.getOrDefault(ID, null);

}

public SocketAddress getRemoteSocketAddress()

{

return remoteSocketAddress;

}

public Platform getPlatform()

{

return platform;

}

public String getNickName()

{

return nickName;

}

public Version getVersion()

{

return version;

}

public Version getCommStandardVersion()

{

return commStandardVersion;

}

public Version getThemeAPIVersion()

{

return themeAPIVersion;

}

public double getStartupDisplayHeight()

public double getDisplayHeight()

{

return startupDisplayHeight;

return displayHeight;

}

public double getStartupDisplayWidth()

public double getDisplayWidth()

{

return startupDisplayWidth;

return displayWidth;

}

public void setStartupDisplayHeight(double height)

public void setDisplayHeight(double height)

{

startupDisplayHeight = height;

displayHeight = height;

}

public void setStartupDisplayWidth(double width)

public void setDisplayWidth(double width)

{

startupDisplayWidth = width;

displayWidth = width;

}

private int getMaxRows(int eachActionSize)

{

return (int) (startupDisplayHeight / eachActionSize);

return (int) (displayHeight / eachActionSize);

}

public int getMaxCols(int eachActionSize)

{

return (int) (startupDisplayWidth / eachActionSize);

return (int) (displayWidth / eachActionSize);

}

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

+3 −7

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

import com.stream_pi.server.action.NormalActionPlugins;

import com.stream_pi.server.client.Client;

import com.stream_pi.server.client.ClientProfile;

import com.stream_pi.server.client.ClientTheme;

import com.stream_pi.server.info.ServerInfo;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

import com.stream_pi.util.alert.StreamPiAlert;

import com.stream_pi.util.alert.StreamPiAlertType;

import com.stream_pi.util.comms.Message;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.exception.SevereException;

import com.stream_pi.util.exception.StreamPiException;

import com.stream_pi.util.platform.Platform;

import com.stream_pi.util.platform.ReleaseStatus;

import com.stream_pi.util.version.Version;

import javafx.concurrent.Task;

import java.io.*;

import java.lang.reflect.Array;

import java.net.Socket;

import java.util.ArrayList;

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 "+socket.getRemoteSocketAddress());

disconnect();

}

catch (SevereException e)

{

e.printStackTrace();

exceptionAndAlertHandler.handleSevereException(e);

}

public synchronized void exitAndRemove()

{

exit();

removeConnection();

serverListener.clearTemp();

}

public void removeConnection()

{

ClientConnections.getInstance().removeConnection(this);

}

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

{

try

{

Thread.sleep(50);

}

catch (InterruptedException e)

{

e.printStackTrace();

}

Message message = new Message("action_icon");

message.setStringArrValue(profileID, actionID);

message.setByteArrValue(icon);

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

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

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

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

client.setDefaultProfileID(ar[8]);

client.setDefaultThemeFullName(ar[9]);

//call get profiles command.

serverListener.clearTemp();

}

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 "client_details" : initAfterConnectionQueryReceive(message);

getProfilesFromClient();

getThemesFromClient();

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": actionClicked(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)

{

String[] s = message.getStringArrValue();

String profileID = s[0];

String actionID = s[1];

getClient().getProfileByID(profileID).getActionByID(actionID).setIcon(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

{

oos.writeObject(message);

oos.flush();

}

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

}

public void registerProfilesFromClient(Message message) throws StreamPiException

{

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

String[] r = message.getStringArrValue();

for (String profileID : r) {

getProfileDetailsFromClient(profileID);

}

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 void getActionIcon(String profileID, String actionID) throws StreamPiException

{

System.out.println("getting action icon from "+profileID+", "+actionID);

writeToStream("get_action_icon::"+profileID+"::"+actionID);

}*/

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

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

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

//text

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

String displayFontColor = r[9];

String displayText = r[10];

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

//location

String row = r[12];

String col = r[13];

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

Action action = new Action(ID, actionType);

action.setBgColourHex(bgColorHex);

action.setShowIcon(isShowIcon);

action.setHasIcon(isHasIcon);

action.setShowDisplayText(isShowDisplayText);

action.setDisplayTextFontColourHex(displayFontColor);

action.setDisplayText(displayText);

action.setDisplayTextAlignment(displayTextAlignment);

action.setLocation(location);

String root = r[14];

action.setParent(root);

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

}

action.setClientProperties(clientProperties);

action.setModuleName(r[4]);

//set up action

//action toBeAdded = null;

if(actionType == ActionType.NORMAL)

{

NormalAction actionCopy = NormalActionPlugins.getInstance().getPluginByModuleName(r[4]);

if(actionCopy == null)

{

action.setInvalid(true);

}

else

{

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

//action.setHelpLink(actionCopy.getHelpLink());

if(actionCopy.getVersion().getMajor() != action.getVersion().getMajor())

{

action.setInvalid(true);

}

else

{

action.setName(actionCopy.getName());

ClientProperties finalClientProperties = new ClientProperties();

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

{

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

{

Property property1 = action.getClientProperties().get().get(i);

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

{

property.setRawValue(property1.getRawValue());

finalClientProperties.addProperty(property);

}

action.setClientProperties(finalClientProperties);

}

try

{

for(Property prop : action.getClientProperties().get())

{

logger.info("G@@@@@ : "+prop.getRawValue());

}

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

for(String action1x : getClient().getProfileByID(profileID).getActionsKeySet())

{

Action action1 = getClient().getProfileByID(profileID).getActionByID(action1x);

logger.info("231cc : "+action1.getID());

for(Property prop : action1.getClientProperties().get())

{

logger.info("G@VVVV@@@ : "+prop.getRawValue());

}

catch (CloneNotSupportedException e)

{

e.printStackTrace();

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

}

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

{

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

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

}

else

{

a.add("no");

}

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

{

a.add(action.getModuleName());

}

else

{

a.add("nut");

}

//display

a.add(action.getBgColourHex());

//icon

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

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

//text

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

a.add(action.getDisplayTextFontColourHex());

a.add(action.getDisplayText());

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

//location

if(action.getLocation() == null)

{

a.add("-1");

}

else

{

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

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

}

a.add(action.getParent());

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 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 screenWidth, String screenHeight, String defaultProfileID,

public void saveClientDetails(String clientNickname, String defaultProfileID,

String defaultThemeFullName) throws SevereException

{

Message message = new Message("save_client_details");

message.setStringArrValue(

clientNickname,

screenWidth,

screenHeight,

defaultProfileID,

defaultThemeFullName

);

sendMessage(message);

client.setNickName(clientNickname);

client.setStartupDisplayWidth(Double.parseDouble(screenWidth));

client.setStartupDisplayHeight(Double.parseDouble(screenHeight));

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 actionClicked(Message message)

{

try

{

String[] r = message.getStringArrValue();

String profileID = r[0];

String actionID = r[1];

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

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

{

NormalAction original = NormalActionPlugins.getInstance().getPluginByModuleName(

action.getModuleName()

);

if(original == null)

{

throw new MinorException(

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

);

}

NormalAction normalAction = original.clone();

normalAction.setLocation(action.getLocation());

normalAction.setDisplayText(action.getDisplayText());

normalAction.setID(actionID);

normalAction.setDelayBeforeExecuting(action.getDelayBeforeExecuting());

normalAction.setClientProperties(action.getClientProperties());

new Thread(new Task<Void>() {

@Override

protected Void call()

{

try

{

System.out.println("@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@2 "+normalAction.getDelayBeforeExecuting());

Thread.sleep(normalAction.getDelayBeforeExecuting());

boolean result = serverListener.onNormalActionClicked(normalAction);

if(!result)

{

sendActionFailed(profileID, actionID);

}

catch (SevereException e)

{

exceptionAndAlertHandler.handleSevereException(e);

}

catch (Exception e)

{

e.printStackTrace();

}

return null;

}

}).start();

}

} catch (Exception e) {

e.printStackTrace();

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

}

public void 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/window/settings/ClientsSettings.java

+17 −51

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

try {

Double.parseDouble(clientSettingsVBox.getStartupWindowHeight());

}

catch (NumberFormatException e)

{

errors.append(" Must have integer display height. \n");

}

try {

Double.parseDouble(clientSettingsVBox.getStartupWindowWidth());

}

catch (NumberFormatException e)

{

errors.append(" Must have integer display width. \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");

}

try {

int rows = Integer.parseInt(clientProfileVBox.getRows());

int actionsSize = Integer.parseInt(clientProfileVBox.getActionSize());

double startupWidth = Double.parseDouble(clientSettingsVBox.getStartupWindowWidth());

if((rows*actionsSize) > (startupWidth - 50))

if((rows*actionsSize) > (clientSettingsVBox.getDisplayWidth() - 50))

{

errors2.append(" Rows out of bounds of screen size. \n");

}

catch (NumberFormatException e)

{

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

}

try {

int cols = Integer.parseInt(clientProfileVBox.getCols());

int actionsSize = Integer.parseInt(clientProfileVBox.getActionSize());

double startupHeight = Double.parseDouble(clientSettingsVBox.getStartupWindowHeight());

if((cols*actionsSize) > (startupHeight - 50))

if((cols*actionsSize) > (clientSettingsVBox.getDisplayHeight() - 50))

{

errors2.append(" Cols out of bounds of screen size. \n");

}

catch (NumberFormatException e)

{

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

}

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

{

errors.append(" ")

.append(clientProfileVBox.getRealName())

.append("\n")

.append(errors2.toString())

.append("\n");

}

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

{

finalErrors.append("* ")

.append(clientSettingsVBox.getRealNickName())

.append("\n")

.append(errors.toString())

.append("\n");

}

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

throw new MinorException("You made form mistakes",

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

//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 TextField startupWindowHeightTextField;

private double displayHeight;

private double displayWidth;

public double getDisplayHeight() {

return displayHeight;

}

public String getStartupWindowHeight() {

public void setDisplayHeight(double displayHeight) {

return startupWindowHeightTextField.getText();

this.displayHeight = displayHeight;

}

private TextField startupWindowWidthTextField;

public double getDisplayWidth() {

return displayWidth;

}

public String getStartupWindowWidth() {

public void setDisplayWidth(double displayWidth) {

return startupWindowWidthTextField.getText();

this.displayWidth = displayWidth;

}

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;

private HBoxInputBox startupWindowHeightInputBox, startupWindowWidthInputBox;

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

startupWindowWidthTextField.getText(),

startupWindowHeightTextField.getText(),

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

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

);

System.out.println("OUT");

logger.info("Profiles : ");

for(ClientProfileVBox clientProfileVBox : clientProfileVBoxes)

{

logger.info("Name : "+clientProfileVBox.getClientProfile().getName());

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

startupWindowHeightTextField = new TextField();

startupWindowWidthTextField = new TextField();

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

startupWindowHeightInputBox = new HBoxInputBox("Startup window Height", startupWindowHeightTextField);

startupWindowHeightInputBox.managedProperty().bind(startupWindowHeightInputBox.visibleProperty());

startupWindowWidthInputBox = new HBoxInputBox("Startup window Width", startupWindowWidthTextField);

startupWindowWidthInputBox.managedProperty().bind(startupWindowWidthInputBox.visibleProperty());

this.getChildren().addAll(

nickNameLabel,

socketConnectionLabel,

platformLabel,

versionLabel,

new HBoxInputBox("Nickname",nicknameTextField),

new HBox(

new Label("Theme"),

SpaceFiller.horizontal(),

themesComboBox

startupWindowHeightInputBox,

startupWindowWidthInputBox,

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

if(client.getPlatform() == com.stream_pi.util.platform.Platform.ANDROID)

{

startupWindowHeightInputBox.setVisible(false);

startupWindowWidthInputBox.setVisible(false);

}

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

startupWindowWidthTextField.setText(client.getStartupDisplayWidth()+"");

setDisplayHeight(client.getDisplayHeight());

startupWindowHeightTextField.setText(client.getStartupDisplayHeight()+"");

setDisplayWidth(client.getDisplayWidth());

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("Columns", rowsTextField),

new HBoxInputBox("Rows", 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;

}

Public

server

Clone or download

removed client display size editing feature

Modified Files