server

work

Download Browse

+62 −65

Author

Debayan Sutradhar (rnayabed) 2021-01-17 13:28

Committer

Debayan Sutradhar (rnayabed) 2021-01-17 13:28

Hash 34ec98c7ef065ec74c2811a8e31cdb9057dd03e2

Parent 8c9a6e6c0dcb154f78e987184e5790504bbb1811

Reference git #server/34ec98c7ef065ec74c2811a8e31cdb9057dd03e2

Modified Files

List

Side by side diff

Inline diff

M src/main/java/com/StreamPi/Server/Action/NormalActionPlugins.java

+7 −4

package com.StreamPi.Server.Action;

import com.StreamPi.ActionAPI.Action.Action;

import com.StreamPi.ActionAPI.Action.ActionType;

import com.StreamPi.ActionAPI.Action.ServerConnection;

import com.StreamPi.ActionAPI.Action.PropertySaver;

import com.StreamPi.ActionAPI.ActionProperty.ClientProperties;

import com.StreamPi.ActionAPI.ActionProperty.Property.ControlType;

import com.StreamPi.ActionAPI.ActionProperty.Property.Property;

import com.StreamPi.ActionAPI.ActionProperty.Property.Type;

import com.StreamPi.ActionAPI.ActionProperty.ServerProperties;

import com.StreamPi.ActionAPI.NormalAction.NormalAction;

import com.StreamPi.Server.Controller.Controller;

import com.StreamPi.Util.Exception.MinorException;

import com.StreamPi.Util.Exception.SevereException;

import com.StreamPi.Util.Exception.StreamPiException;

import com.StreamPi.Util.Version.Version;

import com.StreamPi.Util.XMLConfigHelper.XMLConfigHelper;

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 javafx.scene.image.ImageView;

import org.w3c.dom.NodeList;

import org.kordamp.ikonli.javafx.FontIcon;

import org.w3c.dom.Document;

import org.w3c.dom.Node;

import java.io.File;

import java.lang.module.*;

import java.nio.file.Path;

import java.nio.file.Paths;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.ServiceLoader;

import java.util.logging.Level;

import java.util.logging.Logger;

import java.util.stream.Collectors;

import org.w3c.dom.Element;

import javax.xml.parsers.DocumentBuilder;

import javax.xml.parsers.DocumentBuilderFactory;

import javax.xml.transform.Transformer;

public class NormalActionPlugins

{

private static NormalActionPlugins instance = null;

private final Logger logger;

private File configFile;

private Document document;

private static String pluginsLocation = null;

public static synchronized NormalActionPlugins getInstance()

{

if(instance == null)

{

instance = new NormalActionPlugins();

}

return instance;

}

public static void setPluginsLocation(String location)

{

pluginsLocation = location;

}

private NormalActionPlugins()

{

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

normalPluginsHashmap = new HashMap<>();

}

public void init() throws SevereException, MinorException

{

registerPlugins();

initPlugins();

}

public List<NormalAction> getPlugins()

{

return normalPlugins;

}

public NormalAction getPluginByModuleName(String name)

{

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

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

if(index != -1)

{

return normalPlugins.get(index);

}

return null;

}

private List<NormalAction> normalPlugins;

private List<NormalAction> normalPlugins = null;

HashMap<String, Integer> normalPluginsHashmap;

public void registerPlugins() throws SevereException, MinorException

{

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

try

{

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

DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance();

DocumentBuilder docBuilder = docFactory.newDocumentBuilder();

document = docBuilder.parse(configFile);

}

catch (Exception e)

{

e.printStackTrace();

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

}

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

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

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

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

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

{

Node eachActionNode = actionsNode.item(i);

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

continue;

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

continue;

Element eachActionElement = (Element) eachActionNode;

String name="";

Version version;

try

{

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

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

}

catch (Exception e)

{

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

e.printStackTrace();

continue;

}

ServerProperties serverProperties = new ServerProperties();

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

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

{

Node eachPropertyNode = serverPropertiesNodeList.item(j);

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

continue;

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

continue;

Element eachPropertyElement = (Element) eachPropertyNode;

try

{

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

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

serverProperties.addProperty(property);

}

catch (Exception e)

{

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

e.printStackTrace();

}

Action action = new Action(ActionType.NORMAL);

action.setModuleName(name);

action.setVersion(version);

action.getServerProperties().set(serverProperties);

pluginsConfigs.add(action);

}

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

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

try

{

// Search for plugins in the plugins directory

ModuleFinder pluginsFinder = ModuleFinder.of(pluginsDir);

// Find all names of all found plugin modules

List<String> p = pluginsFinder

.findAll()

.stream()

.map(ModuleReference::descriptor)

.map(ModuleDescriptor::name)

.collect(Collectors.toList());

// Create configuration that will resolve plugin modules

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

Configuration pluginsConfiguration = ModuleLayer

.boot()

.configuration()

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

// Create a module layer for plugins

ModuleLayer layer = ModuleLayer

.boot()

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

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

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

normalPlugins = ServiceLoader

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

.map(ServiceLoader.Provider::get)

.collect(Collectors.toList());

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

}

catch (Exception e)

{

e.printStackTrace();

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

}

sortedPlugins = new HashMap<>();

for (NormalAction eachPlugin : normalPlugins) {

try {

eachPlugin.setPropertySaver(propertySaver);

eachPlugin.setServerConnection(serverConnection);

eachPlugin.initProperties();

Action foundAction = null;

for (Action action : pluginsConfigs) {

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

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

foundAction = action;

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

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

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

Property eachPluginCodeProperty = eachPluginCodeProperties.get(i);

Property foundProp = null;

for (Property eachPluginStoredProperty : eachPluginStoredProperties) {

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

eachPluginCodeProperty.setRawValue(eachPluginStoredProperty.getRawValue());

foundProp = eachPluginStoredProperty;

}

eachPluginCodeProperties.set(i, eachPluginCodeProperty);

if (foundProp != null) {

eachPluginStoredProperties.remove(foundProp);

}

eachPlugin.getServerProperties().set(eachPluginCodeProperties);

break;

}

if (foundAction != null)

pluginsConfigs.remove(foundAction);

else

{

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

for(Property property :eachPluginStoredProperties)

{

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

property.setRawValue(property.getDefaultRawValue());

}

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

ArrayList<NormalAction> actions = new ArrayList<>();

sortedPlugins.put(eachPlugin.getCategory(), actions);

}

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

/*logger.debug("-----Custom Plugin Debug-----" +

"\nAction Type : " + eachPlugin.getActionType() +

"\nName : " + eachPlugin.getName() +

"\nFull Module Name : " + eachPlugin.getModuleName() +

"\nAuthor : " + eachPlugin.getAuthor() +

"\nCategory : " + eachPlugin.getCategory() +

"\nRepo : " + eachPlugin.getRepo() +

"\nVersion : " + eachPlugin.getVersion().getText() +

"\n---------------------------");*/

} catch (Exception e) {

e.printStackTrace();

errorModules.add(eachPlugin);

errorModuleError.add(e.getMessage());

}

try {

saveServerSettings();

} catch (MinorException e) {

e.printStackTrace();

}

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

if(errorModules.size() > 0)

{

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

for(NormalAction e : errorModules)

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

{

normalPlugins.remove(e);

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

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

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

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

}

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

}

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

{

normalPluginsHashmap.put(normalPlugins.get(i).getModuleName(), i);

}

public void initPlugins() throws MinorException

{

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

boolean isError = false;

for(NormalAction eachPlugin : normalPlugins)

{

try

{

eachPlugin.initAction();

}

catch (Exception e)

{

e.printStackTrace();

isError = true;

errors.append("\n* ")

.append(eachPlugin.getName())

.append(" - ")

.append(eachPlugin.getModuleName())

.append("\n");

if(e instanceof StreamPiException)

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

errors.append("\n");

}

if(isError)

{

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

}

HashMap<String, ArrayList<NormalAction>> sortedPlugins;

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

{

return sortedPlugins;

}

private Element getActionsElement()

{

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

}

public void saveServerSettings() throws MinorException

{

XMLConfigHelper.removeChilds(getActionsElement());

for(NormalAction normalAction : normalPlugins)

{

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

getActionsElement().appendChild(actionElement);

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

moduleNameElement.setTextContent(normalAction.getModuleName());

actionElement.appendChild(moduleNameElement);

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

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

actionElement.appendChild(versionElement);

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

actionElement.appendChild(propertiesElement);

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

{

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

{

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

propertiesElement.appendChild(propertyElement);

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

nameElement.setTextContent(eachProperty.getName());

propertyElement.appendChild(nameElement);

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

valueElement.setTextContent(eachProperty.getRawValue());

propertyElement.appendChild(valueElement);

}

save();

}

private PropertySaver propertySaver = null;

public void setPropertySaver(PropertySaver propertySaver)

{

this.propertySaver = propertySaver;

}

private ServerConnection serverConnection = null;

public void setServerConnection(ServerConnection serverConnection)

{

this.serverConnection = serverConnection;

}

public NormalAction getActionFromIndex(int index)

{

return normalPlugins.get(index);

}

public void shutDownActions()

{

if(normalPlugins != null)

{

for(NormalAction eachPlugin : normalPlugins)

{

try

{

eachPlugin.onShutDown();

}

catch (Exception e)

{

e.printStackTrace();

}

normalPlugins.clear();

}

public void save() throws MinorException

{

try

{

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

Result output = new StreamResult(configFile);

Source input = new DOMSource(document);

transformer.transform(input, output);

}

catch (Exception e)

{

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

}

M src/main/java/com/StreamPi/Server/Client/Client.java

+6 −20

package com.StreamPi.Server.Client;

import com.StreamPi.Server.Connection.ClientConnection;

import com.StreamPi.ThemeAPI.Theme;

import com.StreamPi.Util.Exception.MinorException;

import com.StreamPi.Util.Platform.Platform;

import com.StreamPi.Util.Platform.ReleaseStatus;

import com.StreamPi.Util.Version.Version;

import javafx.geometry.Dimension2D;

import java.net.SocketAddress;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.LinkedList;

import java.util.List;

public class Client {

private String nickName;

private final SocketAddress remoteSocketAddress;

private final Platform platform;

private ClientConnection connectionHandler;

private final Version version;

private final Version commAPIVersion;

private final Version commStandardVersion;

private final Version themeAPIVersion;

private final ReleaseStatus releaseStatus;

private double startupDisplayHeight, startupDisplayWidth;

private final HashMap<String,ClientProfile> profiles;

private final HashMap<String,ClientTheme> themes;

private String defaultProfileID;

private String defaultThemeFullName;

private int totalNoOfProfiles;

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

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

{

this.version = version;

this.releaseStatus = releaseStatus;

this.commAPIVersion = commAPIVersion;

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 setTotalNoOfProfiles(int totalNoOfProfiles)

{

this.totalNoOfProfiles = totalNoOfProfiles;

}

public int getTotalNoOfProfiles()

{

return totalNoOfProfiles;

}

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;

}

public void setConnectionHandler(ClientConnection connectionHandler)

{

this.connectionHandler = connectionHandler;

}

public ClientConnection getConnectionHandler()

{

return connectionHandler;

}

//Client Profiles

/*public ArrayList<ClientProfile> getProfiles()

{

return 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) throws MinorException {

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

public Version getCommStandardVersion()

{

return commAPIVersion;

return commStandardVersion;

}

public Version getThemeAPIVersion()

{

return themeAPIVersion;

}

public double getStartupDisplayHeight()

{

return startupDisplayHeight;

}

public double getStartupDisplayWidth()

{

return startupDisplayWidth;

}

public void setStartupDisplayHeight(double height)

{

startupDisplayHeight = height;

}

public void setStartupDisplayWidth(double width)

{

startupDisplayWidth = width;

}

public void debugPrint()

{

System.out.println("Client Info : "+

"\nNickname : "+nickName+

"\nRemote address : "+remoteSocketAddress+

"\nPlatform : "+platform.getUIName()+

"\nVersion : "+version.getText()+

"\nComm API Version : "+commAPIVersion.getText()+

"\nTheme API Version : "+themeAPIVersion.getText()+

"\nDisplay Width : "+startupDisplayWidth+

"\nDisplay Height : "+startupDisplayHeight+

"\nDefault Profile ID : "+defaultProfileID);

}

private int getMaxRows(int eachActionSize)

{

return (int) (startupDisplayHeight / eachActionSize);

}

public int getMaxCols(int eachActionSize)

{

return (int) (startupDisplayWidth / eachActionSize);

}

M src/main/java/com/StreamPi/Server/Connection/ClientConnection.java

+3 −5

package com.StreamPi.Server.Connection;

import com.StreamPi.ActionAPI.Action.Action;

import com.StreamPi.ActionAPI.Action.ActionType;

import com.StreamPi.ActionAPI.Action.DisplayTextAlignment;

import com.StreamPi.ActionAPI.Action.Location;

import com.StreamPi.ActionAPI.ActionProperty.ClientProperties;

import com.StreamPi.ActionAPI.ActionProperty.Property.Property;

import com.StreamPi.ActionAPI.ActionProperty.Property.Type;

import com.StreamPi.ActionAPI.NormalAction.NormalAction;

import com.StreamPi.ActionAPI.OtherActions.CombineAction;

import com.StreamPi.ActionAPI.OtherActions.FolderAction;

import com.StreamPi.Server.Action.NormalActionPlugins;

import com.StreamPi.Server.Client.Client;

import com.StreamPi.Server.Client.ClientProfile;

import com.StreamPi.Server.Client.ClientTheme;

import com.StreamPi.Server.Info.ServerInfo;

import com.StreamPi.Server.Window.ExceptionAndAlertHandler;

import com.StreamPi.Util.Alert.StreamPiAlert;

import com.StreamPi.Util.Alert.StreamPiAlertType;

import com.StreamPi.Util.Exception.MinorException;

import com.StreamPi.Util.Exception.SevereException;

import com.StreamPi.Util.Exception.StreamPiException;

import com.StreamPi.Util.Platform.Platform;

import com.StreamPi.Util.Platform.ReleaseStatus;

import com.StreamPi.Util.Version.Version;

import javafx.concurrent.Task;

import java.io.ByteArrayOutputStream;

import java.io.DataInputStream;

import java.io.DataOutputStream;

import java.io.IOException;

import java.net.ServerSocket;

import java.net.Socket;

import java.net.SocketException;

import java.net.SocketTimeoutException;

import java.nio.ByteBuffer;

import java.nio.charset.Charset;

import java.nio.charset.StandardCharsets;

import java.util.ArrayList;

import java.util.List;

import java.util.Random;

import java.util.UUID;

import java.util.concurrent.atomic.AtomicBoolean;

import java.util.logging.Level;

import java.util.logging.Logger;

import java.util.stream.Stream;

public class ClientConnection extends Thread{

private Socket socket;

private ServerListener serverListener;

private AtomicBoolean stop = new AtomicBoolean(false);

private DataInputStream dis;

private DataOutputStream dos;

private Logger logger;

private Client client = null;

private ExceptionAndAlertHandler exceptionAndAlertHandler;

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

{

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

//actionIconsToBeSent = new ArrayList__();

this.socket = socket;

this.serverListener = serverListener;

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

try

{

dis = new DataInputStream(socket.getInputStream());

dos = new DataOutputStream(socket.getOutputStream());

} 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 writeToStream(String text) throws SevereException

{

/*try

{

logger.debug(text);

dos.writeUTF(text);

dos.flush();

}

catch (IOException e)

{

e.printStackTrace();

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

}*/

try

{

byte[] txtBytes = text.getBytes();

Thread.sleep(50);

dos.writeUTF("string:: ::");

dos.flush();

dos.writeInt(txtBytes.length);

dos.flush();

write(txtBytes);

dos.flush();

}

catch (IOException | InterruptedException e)

{

e.printStackTrace();

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

}

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

{

try

{

logger.info("Sending action Icon...");

//Thread.sleep(50);

System.out.println("1");

dos.writeUTF("action_icon::"+profileID+"!!"+actionID+"!!::"+icon.length);

System.out.println("2");

dos.flush();

System.out.println("3");

dos.writeInt(icon.length);

System.out.println("4");

dos.flush();

System.out.println("5");

write(icon);

System.out.println("6");

dos.flush();

System.out.println("7");

}

catch (IOException e)

{

e.printStackTrace();

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

}

public void write(byte[] array) throws SevereException

{

try

{

dos.write(array);

}

catch (IOException e)

{

e.printStackTrace();

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

}

public void initAfterConnectionQueryReceive(String[] arr) throws StreamPiException

{

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

Version clientVersion;

Version commsStandard;

Version themesStandard;

ReleaseStatus releaseStatus;

try

{

clientVersion = new Version(arr[1]);

releaseStatus = ReleaseStatus.valueOf(arr[2]);

commsStandard = new Version(arr[3]);

themesStandard = new Version(arr[4]);

}

catch (MinorException e)

{

exitAndRemove();

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

}

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

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().getCommAPIVersion().getText()+

"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, arr[5], Platform.valueOf(arr[8]), socket.getRemoteSocketAddress());

client.setStartupDisplayWidth(Double.parseDouble(arr[6]));

client.setStartupDisplayHeight(Double.parseDouble(arr[7]));

client.setDefaultProfileID(arr[9]);

client.setDefaultThemeFullName(arr[10]);

client.debugPrint();

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

{

String msg = "";

try

{

String raw = dis.readUTF();

int length = dis.readInt();

System.out.println("SIZE TO READ : "+length);

String[] precursor = raw.split("::");

String inputType = precursor[0];

String secondArg = precursor[1];

ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();

/*int count;

int chunkSize = 512;

while (length>0)

{

if(chunkSize > length)

chunkSize = length;

else

chunkSize = 512;

byte[] buffer = new byte[chunkSize];

count = dis.read(buffer);

System.out.println(count);

byteArrayOutputStream.write(buffer);

length-=count;

}*/

/*byte[] buffer = new byte[8192];

int read;

while((read = dis.read(buffer)) != -1){

System.out.println("READ : "+read);

byteArrayOutputStream.write(buffer, 0, read);

}

System.out.println("READ : "+byteArrayOutputStream.size());

byteArrayOutputStream.close();

byte[] bArr = byteArrayOutputStream.toByteArray();*/

byte[] bArr = new byte[length];

dis.readFully(bArr);

if(inputType.equals("string"))

{

msg = new String(bArr);

}

else if(inputType.equals("action_icon"))

{

String[] secondArgSep = secondArg.split("!!");

String profileID = secondArgSep[0];

String actionID = secondArgSep[1];

getClient().getProfileByID(profileID).getActionByID(actionID).setIcon(bArr);

//serverListener.clearTemp();

continue;

}

catch (IOException 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;

}

logger.info("Received text : '"+msg+"'");

String[] sep = msg.split("::");

String command = sep[0];

switch (command)

{

case "disconnect" : clientDisconnected(msg);

break;

case "client_details" : initAfterConnectionQueryReceive(sep);

getProfilesFromClient();

getThemesFromClient();

break;

case "profiles" : registerProfilesFromClient(sep);

break;

case "profile_details" : registerProfileDetailsFromClient(sep);

break;

case "action_details" : registerActionToProfile(sep);

break;

case "themes": registerThemes(sep);

break;

case "action_clicked": actionClicked(sep[1], sep[2]);

break;

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

}

catch (StreamPiException e)

{

e.printStackTrace();

if(e instanceof MinorException)

exceptionAndAlertHandler.handleMinorException((MinorException) e);

else if (e instanceof SevereException)

exceptionAndAlertHandler.handleSevereException((SevereException) e);

}

// commands

public void initAfterConnectionQuerySend() throws SevereException

{

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

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

writeToStream("disconnect::"+message+"::");

try

{

if(!socket.isClosed())

socket.close();

}

catch (IOException e)

{

e.printStackTrace();

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

}

public void clientDisconnected(String message)

{

stop.set(true);

String txt = "Disconnected!";

if(!message.equals("disconnect::::"))

txt = "Message : "+message.split("::")[1];

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

exitAndRemove();

}

public void getProfilesFromClient() throws StreamPiException

{

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

writeToStream("get_profiles::");

}

public void getThemesFromClient() throws StreamPiException

{

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

writeToStream("get_themes::");

}

public void registerThemes(String[] sep)

{

for(int i =1; i<sep.length;i++)

{

String[] internal = sep[i].split("__");

ClientTheme clientTheme = new ClientTheme(

internal[0],

internal[1],

internal[2],

internal[3]

);

try

{

getClient().addTheme(clientTheme);

}

catch (CloneNotSupportedException e)

{

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

e.printStackTrace();

}

public void registerProfilesFromClient(String[] sep) throws StreamPiException

{

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

int noOfProfiles = Integer.parseInt(sep[1]);

getClient().setTotalNoOfProfiles(noOfProfiles);

for(int i = 2; i<(noOfProfiles + 2); i++)

{

String profileID = sep[i];

getProfileDetailsFromClient(profileID);

}

public void getProfileDetailsFromClient(String ID) throws StreamPiException

{

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

writeToStream("get_profile_details::"+ID+"::");

}

public void registerProfileDetailsFromClient(String[] sep)

{

String ID = sep[1];

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

String name = sep[2];

int rows = Integer.parseInt(sep[3]);

int cols = Integer.parseInt(sep[4]);

int actionSize = Integer.parseInt(sep[5]);

int actionGap = Integer.parseInt(sep[6]);

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(String[] sep) throws StreamPiException

{

String profileID = sep[1];

String ID = sep[2];

ActionType actionType = ActionType.valueOf(sep[3]);

//4 - Version

//5 - ModuleName

//display

String bgColorHex = sep[6];

//icon

boolean isHasIcon = sep[7].equals("true");

boolean isShowIcon = sep[8].equals("true");

//text

boolean isShowDisplayText = sep[9].equals("true");

String displayFontColor = sep[10];

String displayText = sep[11];

DisplayTextAlignment displayTextAlignment = DisplayTextAlignment.valueOf(sep[12]);

//location

String row = sep[13];

String col = sep[14];

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

//client properties

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

String root = sep[17];

action.setParent(root);

String[] clientPropertiesRaw = sep[16].split("!!");

ClientProperties clientProperties = new ClientProperties();

if(actionType == ActionType.FOLDER)

clientProperties.setDuplicatePropertyAllowed(true);

for(int i = 0;i<clientPropertiesSize; i++)

{

String[] clientPraw = clientPropertiesRaw[i].split("__");

Property property = new Property(clientPraw[0], Type.STRING);

if(clientPraw.length > 1)

property.setRawValue(clientPraw[1]);

clientProperties.addProperty(property);

}

action.setClientProperties(clientProperties);

action.setModuleName(sep[5]);

//set up action

//Action toBeAdded = null;

if(actionType == ActionType.NORMAL)

{

NormalAction actionCopy = NormalActionPlugins.getInstance().getPluginByModuleName(sep[5]);

if(actionCopy == null)

{

action.setInvalid(true);

}

else

{

action.setVersion(new Version(sep[4]));

action.setRepo(actionCopy.getRepo());

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

{

StringBuilder finalQuery = new StringBuilder("save_action_details::");

finalQuery.append(profileID)

.append("::")

.append(action.getID())

.append("::")

.append(action.getActionType())

.append("::");

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

{

finalQuery.append(action.getVersion().getText());

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

}

finalQuery.append("::");

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

finalQuery.append(action.getModuleName());

finalQuery.append("::");

//display

finalQuery.append(action.getBgColourHex())

.append("::");

//icon

finalQuery.append(action.isHasIcon())

.append("::")

.append(action.isShowIcon())

.append("::");

//text

finalQuery.append(action.isShowDisplayText())

.append("::")

.append(action.getDisplayTextFontColourHex())

.append("::")

.append(action.getDisplayText())

.append("::")

.append(action.getDisplayTextAlignment())

.append("::");

//location

if(action.getLocation() == null)

finalQuery.append("-1::-1::");

else

finalQuery.append(action.getLocation().getRow())

.append("::")

.append(action.getLocation().getCol())

.append("::");

//client properties

ClientProperties clientProperties = action.getClientProperties();

finalQuery.append(clientProperties.getSize())

.append("::");

for(Property property : clientProperties.get())

{

finalQuery.append(property.getName())

.append("__")

.append(property.getRawValue())

.append("__");

finalQuery.append("!!");

}

finalQuery.append("::")

.append(action.getParent())

.append("::");

writeToStream(finalQuery.toString());

}

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

{

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

}

public void saveClientDetails(String clientNickname, String screenWidth, String screenHeight, String defaultProfileID,

String defaultThemeFullName) throws SevereException

{

writeToStream("save_client_details::"+

clientNickname+"::"+

screenWidth+"::"+

screenHeight+"::"+

defaultProfileID+"::"+

defaultThemeFullName+"::");

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

writeToStream("save_client_profile::"+

clientProfile.getID()+"::"+

clientProfile.getName()+"::"+

clientProfile.getRows()+"::"+

clientProfile.getCols()+"::"+

clientProfile.getActionSize()+"::"+

clientProfile.getActionGap()+"::");

}

public void deleteProfile(String ID) throws SevereException

{

writeToStream("delete_profile::"+ID+"::");

}

public void actionClicked(String profileID, String actionID) {

try

{

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

new Thread(new Task<Void>() {

@Override

protected Void call()

{

try

{

boolean result = serverListener.onNormalActionClicked(normalAction);

if(!result)

{

sendActionFailed(profileID, actionID);

}

catch (SevereException e)

{

exceptionAndAlertHandler.handleSevereException(e);

}

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

writeToStream("action_failed::"+

profileID+"::"+

actionID+"::");

}

M src/main/java/com/StreamPi/Server/Controller/Controller.java

+26 −19

package com.StreamPi.Server.Controller;

import com.StreamPi.ActionAPI.Action.ServerConnection;

import com.StreamPi.ActionAPI.Action.PropertySaver;

import com.StreamPi.ActionAPI.NormalAction.NormalAction;

import com.StreamPi.Server.Main;

import com.StreamPi.Server.Action.NormalActionPlugins;

import com.StreamPi.Server.Connection.ClientConnections;

import com.StreamPi.Server.Connection.MainServer;

import com.StreamPi.Server.IO.Config;

import com.StreamPi.Server.Info.ServerInfo;

import com.StreamPi.Server.Window.Base;

import com.StreamPi.Server.Window.Dashboard.DonatePopupContent;

import com.StreamPi.Server.Window.FirstTimeUse.FirstTimeUse;

import com.StreamPi.Util.Alert.StreamPiAlert;

import com.StreamPi.Util.Alert.StreamPiAlertListener;

import com.StreamPi.Util.Alert.StreamPiAlertType;

import com.StreamPi.Util.Exception.MinorException;

import com.StreamPi.Util.Exception.SevereException;

import com.StreamPi.Util.IOHelper.IOHelper;

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.stage.Modality;

import javafx.stage.Stage;

import javafx.stage.WindowEvent;

import java.awt.SystemTray;

import javafx.util.Duration;

import java.awt.Toolkit;

import java.awt.TrayIcon;

import java.awt.PopupMenu;

import java.awt.MenuItem;

import java.io.File;

import java.net.InetAddress;

import java.net.UnknownHostException;

import java.util.Random;

import java.util.logging.Level;

public class Controller extends Base implements PropertySaver, ServerConnection

{

MainServer mainServer;

final SystemTray systemTray;

public void setupDashWindow() throws SevereException

{

try

{

getStage().setTitle("StreamPi Server - "+InetAddress.getLocalHost().getCanonicalHostName()+":"+Config.getInstance().getPort()); //Sets title

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

}

catch (UnknownHostException e)

{

e.printStackTrace();

throw new SevereException(e.getMessage());

}

private void checkPrePathDirectory() throws SevereException

{

try {

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

System.out.println("SAX : "+filex.exists());

if(!filex.exists())

{

filex.mkdirs();

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

}

catch (Exception e)

{

e.printStackTrace();

throw new SevereException(e.getMessage());

}

@Override

public void init()

{

try {

checkPrePathDirectory();

initBase();

setupDashWindow();

setupSettingsWindowsAnimations();

NormalActionPlugins.getInstance().setPropertySaver(this);

NormalActionPlugins.getInstance().setServerConnection(this);

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

openSettingsTimeLine.play();

});

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

closeSettingsTimeLine.play();

});

getSettingsPane().getThemesSettings().setController(this);

mainServer = new MainServer(this, this);

if(getConfig().isFirstTimeUse())

{

Stage stage = new Stage();

Scene s = new Scene(new FirstTimeUse(this, this), 512, 300);

stage.setResizable(false);

stage.setScene(s);

stage.setTitle("StreamPi Server Setup");

stage.initModality(Modality.APPLICATION_MODAL);

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

stage.show();

}

else

{

if(getConfig().isAllowDonatePopup())

{

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

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

}

othInit();

}

catch (SevereException e)

{

handleSevereException(e);

}

@Override

public void othInit()

{

try

{

if(ServerInfo.getInstance().isStartMinimised())

minimiseApp();

else

getStage().show();

}

catch(MinorException e)

{

handleMinorException(e);

}

new Thread(new Task<Void>() {

@Override

protected Void call()

{

try

{

getSettingsPane().getGeneralSettings().loadDataFromConfig();

Platform.runLater(()->{

//themes

getDashboardPane().getPluginsPane().clearData();

getDashboardPane().getPluginsPane().loadOtherActions();

});

NormalActionPlugins.setPluginsLocation(getConfig().getPluginsPath());

NormalActionPlugins.getInstance().init();

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

getSettingsPane().getPluginsSettings().loadPlugins();

getSettingsPane().getThemesSettings().setThemes(getThemes());

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

getSettingsPane().getThemesSettings().loadThemes();

//clients

getSettingsPane().getClientsSettings().loadData();

try

{

//Plugins

Platform.runLater(()->{

getDashboardPane().getPluginsPane().clearData();

getDashboardPane().getPluginsPane().loadOtherActions();

});

NormalActionPlugins.setPluginsLocation(getConfig().getPluginsPath());

NormalActionPlugins.getInstance().init();

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

getSettingsPane().getPluginsSettings().loadPlugins();

}

catch (MinorException e)

{

getSettingsPane().getPluginsSettings().showPluginInitError();

handleMinorException(e);

}

//Server

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

mainServer.start();

}

catch (MinorException e)

{

handleMinorException(e);

}

catch (SevereException e)

{

handleSevereException(e);

}

return null;

}

}).start();

}

private void setupSettingsWindowsAnimations()

{

Node settingsNode = getSettingsPane();

Node dashboardNode = getDashboardPane();

openSettingsTimeLine = new Timeline();

openSettingsTimeLine.setCycleCount(1);

openSettingsTimeLine.getKeyFrames().addAll(

new KeyFrame(Duration.millis(0.0D),

new KeyValue(settingsNode.opacityProperty(),

0.0D, Interpolator.EASE_IN),

new 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(event1 -> {

settingsNode.toFront();

});

closeSettingsTimeLine = new Timeline();

closeSettingsTimeLine.setCycleCount(1);

closeSettingsTimeLine.getKeyFrames().addAll(

new KeyFrame(Duration.millis(0.0D),

new KeyValue(settingsNode.opacityProperty(),

1.0D, Interpolator.LINEAR),

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

new Thread(new Task<Void>() {

@Override

protected Void call() {

try {

getSettingsPane().getClientsSettings().loadData();

getSettingsPane().getGeneralSettings().loadDataFromConfig();

getSettingsPane().getPluginsSettings().loadPlugins();

getSettingsPane().getThemesSettings().setThemes(getThemes());

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

getSettingsPane().getThemesSettings().loadThemes();

getSettingsPane().setDefaultTabToGeneral();

}

catch (SevereException e)

{

handleSevereException(e);

}

catch (MinorException e)

{

handleMinorException(e);

}

return null;

}

}).start();

});

}

private Timeline openSettingsTimeLine;

private Timeline closeSettingsTimeLine;

public Controller(){

systemTray = SystemTray.getSystemTray();

mainServer = null;

}

public void onCloseRequest(WindowEvent event)

{

try

{

if(Config.getInstance().getCloseOnX())

{

getConfig().setStartupWindowSize(

getWidth(),

getHeight()

);

getConfig().save();

onQuitApp();

NormalActionPlugins.getInstance().shutDownActions();

Platform.exit();

}

else

{

minimiseApp();

event.consume();

}

catch (SevereException e)

{

handleSevereException(e);

}

catch (MinorException e)

{

handleMinorException(e);

}

finally

{

closeLogger();

}

public void onQuitApp()

{

if(mainServer!=null)

mainServer.stopListeningForConnections();

ClientConnections.getInstance().disconnectAll();

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

}

public void minimiseApp() throws MinorException

{

try

{

if(SystemTray.isSupported())

{

if(getTrayIcon() == null)

initIconTray();

systemTray.add(getTrayIcon());

//getStage().setIconified(true);

getStage().hide();

}

else

{

new StreamPiAlert("System Tray Error", "Your System does not support System Tray", StreamPiAlertType.ERROR).show();

}

catch(Exception e)

{

throw new MinorException(e.getMessage());

}

public void initIconTray()

{

Platform.setImplicitExit(false);

PopupMenu popup = new PopupMenu();

MenuItem showItem = new MenuItem("Show");

showItem.addActionListener(l->{

systemTray.remove(getTrayIcon());

Platform.runLater(()->{

//getStage().setIconified(false);

getStage().show();

});

MenuItem exitItem = new MenuItem("Exit");

exitItem.addActionListener(l->{

systemTray.remove(getTrayIcon());

onQuitApp();

Platform.exit();

});

popup.add(showItem);

popup.addSeparator();

popup.add(exitItem);

TrayIcon trayIcon = new TrayIcon(

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

"StreamPi Server",

popup

);

trayIcon.setImageAutoSize(true);

this.trayIcon = trayIcon;

}

private TrayIcon trayIcon = null;

public TrayIcon getTrayIcon()

{

return trayIcon;

}

@Override

public void handleMinorException(MinorException e) {

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

e.printStackTrace();

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

}

@Override

public void handleSevereException(SevereException e) {

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

e.printStackTrace();

Platform.runLater(()->{

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

alert.setOnClicked(new StreamPiAlertListener()

{

@Override

public void onClick(String txt)

{

onQuitApp();

Platform.exit();

}

});

alert.show();

});

}

@Override

public synchronized boolean onNormalActionClicked(NormalAction action) {

try{

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

action.onActionClicked();

return true;

}

catch (Exception e)

{

handleMinorException(new MinorException(

"Action Execution Failed!",

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

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

);

return false;

}

@Override

public void clearTemp() {

Platform.runLater(() -> {

getDashboardPane().getClientDetailsPane().refresh();

getDashboardPane().getActionGridPane().clear();

getDashboardPane().getActionDetailsPane().clear();

getSettingsPane().getClientsSettings().loadData();

});

}

@Override

public void saveServerProperties() {

try {

NormalActionPlugins.getInstance().saveServerSettings();

getSettingsPane().getPluginsSettings().loadPlugins();

} catch (MinorException e) {

e.printStackTrace();

handleMinorException(e);

}

@Override

public com.StreamPi.Util.Platform.Platform getPlatform() {

return ServerInfo.getInstance().getPlatformType();

}

M src/main/java/com/StreamPi/Server/Info/ServerInfo.java

+7 −12

ServerInfo.java

Stores basic information about the server - name, platform type

Contributors: Debayan Sutradhar (@dubbadhar)

package com.StreamPi.Server.Info;

import com.StreamPi.Util.Exception.MinorException;

import com.StreamPi.Util.Platform.Platform;

import com.StreamPi.Util.Platform.ReleaseStatus;

import com.StreamPi.Util.Version.Version;

public class ServerInfo {

private Version version;

private final ReleaseStatus releaseStatus;

private final Platform platformType;

private String prePath;

private Version minThemeSupportVersion;

private Version minPluginSupportVersion;

private Version commAPIVersion;

private Version commStandardVersion;

private static ServerInfo instance = null;

private String runnerFileName = null;

private boolean startMinimised = false;

private ServerInfo(){

version = new Version(1,0,0);

try {

minThemeSupportVersion = new Version(1,0,0);

version = new Version("1.0.0");

minPluginSupportVersion = new Version(1,0,0);

minThemeSupportVersion = new Version("1.0.0");

commStandardVersion = new Version(1,0,0);

minPluginSupportVersion = new Version("1.0.0");

commAPIVersion = new Version("1.0.0");

} catch (MinorException e) {

e.printStackTrace();

}

releaseStatus = ReleaseStatus.EA;

prePath = "data/";

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

if(osName.contains("windows"))

platformType = Platform.WINDOWS;

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

platformType = Platform.LINUX;

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

platformType = Platform.MAC;

else

platformType = Platform.UNKNOWN;

}

public String getPrePath() {

return prePath;

}

public void setStartMinimised(boolean startMinimised)

{

this.startMinimised = startMinimised;

}

public boolean isStartMinimised()

{

return startMinimised;

}

public void setRunnerFileName(String runnerFileName)

{

this.runnerFileName = runnerFileName;

}

public String getRunnerFileName()

{

return runnerFileName;

}

public static synchronized ServerInfo getInstance(){

if(instance == null)

{

instance = new ServerInfo();

}

return instance;

}

public Platform getPlatformType()

{

return platformType;

}

public Version getVersion() {

return version;

}

public ReleaseStatus getReleaseStatus()

{

return releaseStatus;

}

public Version getMinThemeSupportVersion()

{

return minThemeSupportVersion;

}

public Version getMinPluginSupportVersion()

{

return minPluginSupportVersion;

}

public Version getCommAPIVersion()

public Version getCommStandardVersion()

{

return commAPIVersion;

return commStandardVersion;

}

M src/main/java/com/StreamPi/Server/Window/Dashboard/DashboardBase.java

+0 −3

package com.StreamPi.Server.Window.Dashboard;

import java.util.logging.Logger;

import com.StreamPi.ActionAPI.Action.Action;

import com.StreamPi.Server.Client.ClientProfile;

import com.StreamPi.Server.Connection.ClientConnection;

import com.StreamPi.Server.Window.Dashboard.ActionGridPane.ActionGridPane;

import com.StreamPi.Server.Window.Dashboard.ActionsDetailPane.ActionDetailsPane;

import com.StreamPi.Server.Window.ExceptionAndAlertHandler;

import com.StreamPi.Util.Exception.SevereException;

import javafx.application.HostServices;

import javafx.scene.CacheHint;

import javafx.scene.layout.HBox;

import javafx.scene.layout.Priority;

import javafx.scene.layout.VBox;

public class DashboardBase extends HBox implements DashboardInterface {

private final VBox leftPane;

private Logger logger;

public ClientProfile currentClientProfile;

private ExceptionAndAlertHandler exceptionAndAlertHandler;

public DashboardBase(ExceptionAndAlertHandler exceptionAndAlertHandler, HostServices hostServices)

{

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

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

leftPane = new VBox();

HBox.setHgrow(leftPane, Priority.ALWAYS);

getChildren().add(leftPane);

setPluginsPane(new PluginsPane(hostServices));

setClientDetailsPane(new ClientDetailsPane(this));

setActionGridPane(new ActionGridPane(exceptionAndAlertHandler));

setActionDetailsPane(new ActionDetailsPane(exceptionAndAlertHandler, hostServices));

getActionGridPane().setActionDetailsPaneListener(getActionDetailsPane());

}

private PluginsPane pluginsPane;

private void setPluginsPane(PluginsPane pluginsPane)

{

this.pluginsPane = pluginsPane;

getChildren().add(this.pluginsPane);

}

public PluginsPane getPluginsPane()

{

return pluginsPane;

}

private ClientDetailsPane clientDetailsPane;

private void setClientDetailsPane(ClientDetailsPane clientDetailsPane)

{

this.clientDetailsPane = clientDetailsPane;

leftPane.getChildren().add(this.clientDetailsPane);

}

public ClientDetailsPane getClientDetailsPane()

{

return clientDetailsPane;

}

private ActionGridPane actionGridPane;

private void setActionGridPane(ActionGridPane actionGridPane)

{

this.actionGridPane = actionGridPane;

leftPane.getChildren().add(this.actionGridPane);

}

public ActionGridPane getActionGridPane()

{

return actionGridPane;

}

private ActionDetailsPane actionDetailsPane;

private void setActionDetailsPane(ActionDetailsPane actionDetailsPane)

{

this.actionDetailsPane = actionDetailsPane;

leftPane.getChildren().add(this.actionDetailsPane);

}

public ActionDetailsPane getActionDetailsPane()

{

return actionDetailsPane;

}

public void newSelectedClientConnection(ClientConnection clientConnection)

{

if(clientConnection == null)

{

logger.info("Remove action grid");

}

else

{

getActionDetailsPane().setClient(clientConnection.getClient());

getActionGridPane().setClient(clientConnection.getClient());

logger.info("Current selected client details:");

clientConnection.getClient().debugPrint();

}

public void newSelectedClientProfile(ClientProfile clientProfile)

{

this.currentClientProfile = clientProfile;

getActionDetailsPane().setClientProfile(clientProfile);

drawProfile(this.currentClientProfile);

}

public void drawProfile(ClientProfile clientProfile)

{

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

getActionGridPane().setClientProfile(clientProfile);

try {

getActionGridPane().renderGrid();

getActionGridPane().renderActions();

}

catch (SevereException e)

{

exceptionAndAlertHandler.handleSevereException(e);

}

M src/main/java/com/StreamPi/Server/Window/Settings/About.java

+2 −2

package com.StreamPi.Server.Window.Settings;

import com.StreamPi.ActionAPI.ActionAPI;

import com.StreamPi.Server.Info.License;

import com.StreamPi.Server.Info.ServerInfo;

import com.StreamPi.Server.Main;

import com.StreamPi.Util.Platform.Platform;

import com.StreamPi.Util.Platform.ReleaseStatus;

import javafx.application.HostServices;

import javafx.geometry.Insets;

import javafx.geometry.Pos;

import javafx.scene.control.Hyperlink;

import javafx.scene.control.Label;

import javafx.scene.control.TextArea;

import javafx.scene.image.Image;

import javafx.scene.image.ImageView;

import javafx.scene.layout.HBox;

import javafx.scene.layout.Priority;

import javafx.scene.layout.Region;

import javafx.scene.layout.VBox;

import java.io.IOException;

import java.net.URISyntaxException;

import java.net.URL;

public class About extends VBox{

private HostServices hostServices;

public About(HostServices hostServices)

{

getStyleClass().add("about");

this.hostServices = hostServices;

setAlignment(Pos.TOP_CENTER);

Image appIcon = new Image(Main.class.getResourceAsStream("app_icon.png"));

ImageView appIconImageView = new ImageView(appIcon);

appIconImageView.setFitHeight(196);

appIconImageView.setFitWidth(182);

// Label headerLabel = new Label("StreamPi");

// headerLabel.getStyleClass().add("settings_about_streampi_header");

Label licenseLabel = new Label("License");

licenseLabel.getStyleClass().add("settings_about_license_label");

VBox.setMargin(licenseLabel, new Insets(20, 0 , 10 ,0));

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

licenseTextArea.setWrapText(false);

licenseTextArea.setEditable(false);

licenseTextArea.setMaxWidth(500);

VBox.setVgrow(licenseTextArea, Priority.ALWAYS);

HBox links = new HBox();

Hyperlink github = new Hyperlink("GitHub");

github.setOnAction(event -> {

openWebpage("https://github.com/Stream-Pi");

});

Hyperlink discord = new Hyperlink("Discord");

discord.setOnAction(event -> {

openWebpage("https://discord.gg/BExqGmk");

});

Hyperlink website = new Hyperlink("Website");

website.setOnAction(event -> {

openWebpage("https://stream-pi.com");

});

Hyperlink twitter = new Hyperlink("Twitter");

twitter.setOnAction(event -> {

openWebpage("https://twitter.com/Stream_Pi");

});

links.setSpacing(30);

links.setAlignment(Pos.CENTER);

links.getChildren().addAll(github, discord, website, twitter);

Hyperlink donateButton = new Hyperlink("DONATE");

donateButton.setOnAction(event -> {

openWebpage("https://www.patreon.com/streampi");

});

donateButton.getStyleClass().add("settings_about_donate_hyperlink");

Region gap = new Region();

VBox.setVgrow(gap, Priority.ALWAYS);

ServerInfo serverInfo = ServerInfo.getInstance();

Label versionText = new Label(serverInfo.getVersion().getText() + " - "+ serverInfo.getPlatformType().getUIName() + " - "+ serverInfo.getReleaseStatus().getUIName());

Label commAPILabel = new Label("CommAPI "+serverInfo.getCommAPIVersion().getText());

Label commStandardLabel = new Label("CommStandard "+serverInfo.getCommStandardVersion().getText());

Label minThemeAPILabel = new Label("Min ThemeAPI "+serverInfo.getMinThemeSupportVersion().getText());

Label minActionAPILabel = new Label("Min ActionAPI "+serverInfo.getMinPluginSupportVersion().getText());

Label currentActionAPILabel = new Label("ActionAPI "+ ActionAPI.API_VERSION.getText());

setSpacing(3);

getChildren().addAll(appIconImageView, licenseLabel, licenseTextArea, links, donateButton, gap, versionText, commAPILabel, minThemeAPILabel, minActionAPILabel, currentActionAPILabel);

getChildren().addAll(appIconImageView, licenseLabel, licenseTextArea, links, donateButton, gap, versionText, commStandardLabel, minThemeAPILabel, minActionAPILabel, currentActionAPILabel);

}

public void openWebpage(String url) {

hostServices.showDocument(url);

}

M src/main/java/com/StreamPi/Server/Window/Settings/PluginsSettings.java

+11 −0

package com.StreamPi.Server.Window.Settings;

import com.StreamPi.Server.UIPropertyBox.UIPropertyBox;

import com.StreamPi.ActionAPI.ActionProperty.Property.ControlType;

import com.StreamPi.ActionAPI.ActionProperty.Property.Property;

import com.StreamPi.ActionAPI.ActionProperty.Property.Type;

import com.StreamPi.ActionAPI.NormalAction.NormalAction;

import com.StreamPi.Server.Action.NormalActionPlugins;

import com.StreamPi.Server.Connection.ServerListener;

import com.StreamPi.Server.Window.ExceptionAndAlertHandler;

import com.StreamPi.Util.Exception.MinorException;

import com.StreamPi.Util.FormHelper.SpaceFiller;

import com.StreamPi.Util.FormHelper.SpaceFiller.FillerType;

import org.kordamp.ikonli.javafx.FontIcon;

import javafx.application.HostServices;

import javafx.application.Platform;

import javafx.geometry.Insets;

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

setPadding(new Insets(10));

pluginsSettingsVBox = new VBox();

pluginsSettingsVBox.setSpacing(10.0);

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

}

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

NormalActionPlugins.getInstance().getActionFromIndex(pp.getIndex())

.getServerProperties().get()

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

}

NormalActionPlugins.getInstance().saveServerSettings();

NormalActionPlugins.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<NormalAction> actions = NormalActionPlugins.getInstance().getPlugins();

System.out.println("asdasdasdasd"+actions.size());

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

if(actions.size() == 0)

{

Platform.runLater(()->{

pluginsSettingsVBox.getChildren().add(new Label("No Plugins Installed."));

saveButton.setVisible(false);

});

return;

}

else

{

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

}

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

{

NormalAction action = actions.get(i);

if(!action.isVisibleInServerSettingsPane())

continue;

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

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

HBox headerHBox = new HBox(headingLabel, new SpaceFiller(FillerType.HBox));

if (action.getRepo()!=null)

{

Button helpButton = new Button();

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

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

helpButton.setGraphic(questionIcon);

helpButton.setOnAction(event -> {

hostServices.showDocument(action.getRepo());

});

headerHBox.getChildren().add(helpButton);

}

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

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

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

VBox serverPropertiesVBox = new VBox();

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, new SpaceFiller(SpaceFiller.FillerType.HBox));

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

Region region1 = new Region();

region1.setPrefHeight(5);

Platform.runLater(()->{

VBox vBox = new VBox();

vBox.setSpacing(5.0);

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

if(action.getButtonBar()!=null)

vBox.getChildren().add(new HBox(new SpaceFiller(SpaceFiller.FillerType.HBox), action.getButtonBar()));

vBox.getChildren().add(region1);

//vBox.setId(i+"");

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

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;

}

Public

server

Clone or download

work

Modified Files