server

work

Download Browse

+158 −111

Author

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

Committer

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

Hash cc356f309430ed3f1e70d77bd6402e9d09077ad6

Parent 2b302cd273eba45a080b2479761460114a5ad6f4

Reference git #server/cc356f309430ed3f1e70d77bd6402e9d09077ad6

Modified Files

List

Side by side diff

Inline diff

M pom.xml

+6 −0

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

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

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

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

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

<artifactId>server</artifactId>

<version>1.0.0-SNAPSHOT</version>

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

<maven.compiler.source>11</maven.compiler.source>

<maven.compiler.target>11</maven.compiler.target>

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

<ActionAPIVersion>1.0.0-SNAPSHOT</ActionAPIVersion>

<ThemeAPIVersion>1.0.0-SNAPSHOT</ThemeAPIVersion>

<UtilVersion>1.0.0-SNAPSHOT</UtilVersion>

<MainClassName>com.stream_pi.server.Main</MainClassName>

</properties>

<groupId>org.openjfx</groupId>

<artifactId>javafx-controls</artifactId>

<version>${JavaFXVersion}</version>

</dependency>

<groupId>org.openjfx</groupId>

<artifactId>javafx-media</artifactId>

<version>${JavaFXVersion}</version>

</dependency>

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

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

<version>${IkonliFA5PackVersion}</version>

</dependency>

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

<artifactId>ikonli-javafx</artifactId>

<version>${IkonliVersion}</version>

</dependency>

<groupId>org.openjfx</groupId>

<artifactId>javafx-base</artifactId>

<version>${JavaFXVersion}</version>

</dependency>

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

<artifactId>action-api</artifactId>

<version>${ActionAPIVersion}</version>

</dependency>

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

<version>${UtilVersion}</version>

</dependency>

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

<artifactId>theme-api</artifactId>

<version>${ThemeAPIVersion}</version>

</dependency>

</dependency>

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

<artifactId>commons-lang3</artifactId>

</dependency>

</dependencies>

<id>gluon-releases</id>

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

</repository>

</repositories>

<build>

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

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

</configuration>

</plugin>

<groupId>org.openjfx</groupId>

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

<commandlineArgs>-DStreamPi.startupRunnerFileName=run_min -DStreamPi.startupMode=maximise</commandlineArgs>

<option>-Dglass.gtk.uiScale=1.0</option>

</options>

<mainClass>${MainClassName}</mainClass>

</configuration>

</plugin>

<groupId>com.gluonhq</groupId>

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

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

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

</nativeImageArgs>

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

</bundlesList>

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

</reflectionList>

<mainClass>${MainClassName}</mainClass>

</configuration>

</plugin>

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

</configuration>

</plugin>

</plugins>

</build>

<id>gluon-releases</id>

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

</pluginRepository>

<id>gluon-snapshots</id>

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

</pluginRepository>

</pluginRepositories>

</project>

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

+0 −1

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

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

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

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

(at your option) any later version.

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

but WITHOUT ANY WARRANTY; without even the implied warranty of

MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

GNU General Public License for more details.

Written by : Debayan Sutradhar (rnayabed)

package com.stream_pi.server;

import com.stream_pi.server.controller.Controller;

import com.stream_pi.server.info.ServerInfo;

import javafx.application.Application;

import javafx.scene.Scene;

import javafx.stage.Stage;

public class Main extends Application {

/**

* First method to be called

* This method first parses all the available command line arguments passed.

* Then a new instance of controller is created, and then initialised.

public void start(Stage stage) {

for(String eachArg : getParameters().getRaw())

{

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

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

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

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

ServerInfo.getInstance().setStartMinimised(r[1].equals("min"));

}

Controller d = new Controller();

Scene s = new Scene(d);

stage.setScene(s);

d.setHostServices(getHostServices());

d.init();

}

/**

* This is a fallback. Called in some JVMs.

* This method just sends the command line arguments to JavaFX Application

public static void main(String[] args)

{

launch(args);

}

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

+12 −2

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 org.apache.commons.lang3.ArrayUtils;

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;

//actionIconsToBeSent = new ArrayList__();

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

message.setByteArrValue(ArrayUtils.toObject(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.setStartupDisplayHeight(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());

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

//client properties

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

ClientProperties clientProperties = new ClientProperties();

if(actionType == ActionType.FOLDER)

clientProperties.setDuplicatePropertyAllowed(true);

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

{

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

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

clientProperties.addProperty(property);

}

action.setClientProperties(clientProperties);

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

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

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

Message message = new Message("action_failed");

message.setStringArrValue(profileID, actionID);

sendMessage(message);

}

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

+23 −49

package com.stream_pi.server.controller;

import com.stream_pi.action_api.action.ServerConnection;

import com.stream_pi.action_api.action.PropertySaver;

import com.stream_pi.action_api.normalaction.NormalAction;

import com.stream_pi.server.Main;

import com.stream_pi.server.action.NormalActionPlugins;

import com.stream_pi.server.connection.ClientConnections;

import com.stream_pi.server.connection.MainServer;

import com.stream_pi.server.io.Config;

import com.stream_pi.server.info.ServerInfo;

import com.stream_pi.server.window.Base;

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

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

import com.stream_pi.util.alert.StreamPiAlert;

import com.stream_pi.util.alert.StreamPiAlertListener;

import com.stream_pi.util.alert.StreamPiAlertType;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.exception.SevereException;

import com.stream_pi.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("Stream-Pi 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());

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("Stream-Pi Server Setup");

stage.initModality(Modality.APPLICATION_MODAL);

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

stage.show();

}

else

{

if(getConfig().isAllowDonatePopup())

{

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

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

}

othInit();

}

catch (SevereException e)

{

handleSevereException(e);

}

@Override

public void othInit()

{

try

{

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

if(ServerInfo.getInstance().isStartMinimised() && SystemTray.isSupported())

minimiseApp();

else

getStage().show();

}

catch(MinorException e)

{

handleMinorException(e);

}

new Thread(new Task<Void>() {

@Override

protected Void call()

{

try

{

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

//themes

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

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

{

getConfig().setStartupWindowSize(

if(SystemTray.isSupported())

{

minimiseApp();

event.consume();

return;

}

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

{

SystemTray systemTray = SystemTray.getSystemTray();

if(SystemTray.isSupported())

if(getTrayIcon() == null)

{

initIconTray(systemTray);

if(getTrayIcon() == null)

initIconTray();

systemTray.add(getTrayIcon());

getStage().hide();

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

public void initIconTray(SystemTray systemTray)

{

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

"Stream-Pi 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)

{

//check if its windows UAC related

if(e.getMessage().contains("operation requires elevation"))

{

handleMinorException(new MinorException(

"Action Execution Failed!",

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

"This action requires higher UAC privileges. Re-launch Stream-Pi Server with 'Administrator Privileges' in order to run this command.")

);

}

else

{

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.stream_pi.util.platform.Platform getPlatform() {

return ServerInfo.getInstance().getPlatformType();

}

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

+33 −4

package com.stream_pi.server.window;

import com.stream_pi.server.connection.ServerListener;

import com.stream_pi.server.io.Config;

import com.stream_pi.server.info.ServerInfo;

import com.stream_pi.server.Main;

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

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

import com.stream_pi.theme_api.Theme;

import com.stream_pi.theme_api.Themes;

import com.stream_pi.util.alert.StreamPiAlert;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.exception.SevereException;

import com.stream_pi.util.iohelper.IOHelper;

import com.stream_pi.util.loggerhelper.StreamPiLogFileHandler;

import javafx.application.HostServices;

import javafx.scene.image.Image;

import javafx.scene.layout.StackPane;

import javafx.scene.text.Font;

import javafx.stage.Stage;

import java.io.File;

import java.util.logging.Logger;

public abstract class Base extends StackPane implements ExceptionAndAlertHandler, ServerListener {

private Config config;

private ServerInfo serverInfo;

private Stage stage;

private HostServices hostServices;

public Logger getLogger(){

return logger;

}

private SettingsBase settingsBase;

private DashboardBase dashboardBase;

private StackPane alertStackPane;

public void setHostServices(HostServices hostServices)

{

this.hostServices = hostServices;

}

public HostServices getHostServices()

{

return hostServices;

}

private Logger logger = null;

private StreamPiLogFileHandler logFileHandler = null;

public void initLogger() throws SevereException

{

try

{

if(logger != null)

return;

logger = Logger.getLogger("");

logFileHandler = new StreamPiLogFileHandler(ServerInfo.getInstance().getPrePath()+"../streampi.log");

logger.addHandler(logFileHandler);

}

catch(Exception e)

{

e.printStackTrace();

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

}

public void closeLogger()

{

if(logFileHandler != null)

logFileHandler.close();

}

public void initBase() throws SevereException {

public void initBase() throws SevereException

{

initLogger();

getChildren().clear();

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

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

getStage().setMinWidth(500);

getStage().setMinHeight(500);

checkPrePathDirectory();

config = Config.getInstance();

stage.setWidth(config.getStartupWindowWidth());

stage.setHeight(config.getStartupWindowHeight());

stage.centerOnScreen();

serverInfo = ServerInfo.getInstance();

initThemes();

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

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

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

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

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

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

alertStackPane = new StackPane();

alertStackPane.setVisible(false);

StreamPiAlert.setParent(alertStackPane);

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

dashboardBase.toFront();

}

private void checkPrePathDirectory() throws SevereException

{

try {

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

if(!filex.exists())

{

filex.mkdirs();

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

}

catch (Exception e)

{

e.printStackTrace();

getStage().show();

throw new SevereException(e.getMessage());

}

public void initThemes() throws SevereException {

clearStylesheets();

registerThemes();

applyDefaultTheme();

applyDefaultStylesheet();

applyDefaultTheme();

applyDefaultIconsStylesheet();

}

public Stage getStage()

{

return stage;

}

public void applyDefaultStylesheet()

{

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

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

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

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

}

public void applyDefaultIconsStylesheet()

{

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

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

}

public DashboardBase getDashboardPane()

{

return dashboardBase;

}

public SettingsBase getSettingsPane()

{

return settingsBase;

}

public Config getConfig()

{

return config;

}

public ServerInfo getServerInfo()

{

return serverInfo;

}

private Theme currentTheme;

public Theme getCurrentTheme()

{

return currentTheme;

}

public void applyTheme(Theme t)

{

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

if(t.getFonts() != null)

{

for(String fontFile : t.getFonts())

{

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

}

currentTheme = t;

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

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

}

public void clearStylesheets()

{

getStylesheets().clear();

}

Themes themes;

public void registerThemes() throws SevereException

{

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

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

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

{

StringBuilder themeErrors = new StringBuilder();

for(MinorException eachException : themes.getErrors())

{

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

}

if(themes.getIsBadThemeTheCurrentOne())

{

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

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

getConfig().save();

}

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

}

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

}

public Themes getThemes()

{

return themes;

}

public void applyDefaultTheme()

{

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

boolean foundTheme = false;

for(Theme t: themes.getThemeList())

{

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

{

foundTheme = true;

applyTheme(t);

break;

}

if(foundTheme)

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

else

{

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

try {

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

Config.getInstance().save();

applyDefaultTheme();

}

catch (SevereException e)

{

handleSevereException(e);

}

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

+11 −7

package com.stream_pi.server.window.firsttimeuse;

import com.stream_pi.server.connection.ServerListener;

import com.stream_pi.server.io.Config;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

import com.stream_pi.util.exception.SevereException;

import com.stream_pi.util.uihelper.HBoxInputBox;

import com.stream_pi.util.uihelper.SpaceFiller;

import javafx.geometry.Pos;

import javafx.scene.control.Alert;

import javafx.scene.control.Button;

import javafx.scene.control.Label;

import javafx.scene.control.TextField;

import javafx.scene.control.Alert.AlertType;

import javafx.scene.layout.HBox;

import javafx.scene.layout.Region;

import javafx.scene.layout.VBox;

import javafx.stage.Stage;

public class FinalConfigPane extends VBox

{

private TextField serverNicknameTextField;

private TextField serverPortTextField;

private Button nextButton;

private ExceptionAndAlertHandler exceptionAndAlertHandler;

private ServerListener serverListener;

public FinalConfigPane(ExceptionAndAlertHandler exceptionAndAlertHandler, ServerListener serverListener)

public FinalConfigPane(ExceptionAndAlertHandler exceptionAndAlertHandler, ServerListener serverListener,

Button nextButton)

{

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

this.serverListener = serverListener;

this.nextButton = nextButton;

getStyleClass().add("first_time_use_pane_final_config");

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

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

label.setWrapText(true);

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

serverNicknameTextField = new TextField();

serverPortTextField = new TextField("2004");

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

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

Button confirmButton = new Button("Confirm");

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

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

HBox bBar = new HBox(confirmButton);

bBar.setAlignment(Pos.CENTER_RIGHT);

getChildren().addAll(label, serverNickNameInputBox, serverPortInputBox, SpaceFiller.vertical(), bBar);

setSpacing(10.0);

setVisible(false);

}

public void makeChangesToNextButton()

{

nextButton.setText("Confirm");

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

}

private void onConfirmButtonClicked()

{

StringBuilder errors = new StringBuilder();

String serverNameStr = serverNicknameTextField.getText();

String serverPortStr = serverPortTextField.getText();

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

{

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

}

int serverPort=-1;

try {

serverPort = Integer.parseInt(serverPortStr);

if (serverPort < 1024)

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

}

catch (NumberFormatException e)

{

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

}

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

{

try

{

Config.getInstance().setServerName(serverNameStr);

Config.getInstance().setServerPort(serverPort);

Config.getInstance().setFirstTimeUse(false);

Config.getInstance().save();

serverListener.othInit();

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

}

catch(SevereException e)

{

exceptionAndAlertHandler.handleSevereException(e);

}

else

{

Alert alert = new Alert(AlertType.ERROR);

alert.setResizable(false);

alert.getDialogPane().setPrefHeight(250);

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

alert.show();

}

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

+18 −17

package com.stream_pi.server.window.firsttimeuse;

import com.stream_pi.server.Main;

import com.stream_pi.server.connection.ServerListener;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

import com.stream_pi.util.uihelper.SpaceFiller;

import javafx.geometry.Insets;

import javafx.scene.control.Button;

import javafx.scene.control.Label;

import javafx.scene.layout.HBox;

import javafx.scene.layout.Priority;

import javafx.scene.layout.StackPane;

import javafx.scene.layout.VBox;

import javafx.scene.text.Font;

public class FirstTimeUse extends VBox{

public FirstTimeUse(ExceptionAndAlertHandler exceptionAndAlertHandler, ServerListener serverListener)

{

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

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

getStyleClass().add("first_time_use_pane");

setSpacing(10.0);

setPadding(new Insets(5));

headingLabel = new Label();

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

StackPane stackPane = new StackPane();

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

VBox.setVgrow(stackPane, Priority.ALWAYS);

welcomePane = new WelcomePane();

licensePane = new LicensePane();

finalConfigPane = new FinalConfigPane(exceptionAndAlertHandler, serverListener);

stackPane.getChildren().addAll(

welcomePane,

licensePane,

finalConfigPane

);

nextButton = new Button("Next");

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

previousButton = new Button("Previous");

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

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

buttonBar.setSpacing(10.0);

welcomePane = new WelcomePane();

licensePane = new LicensePane();

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

stackPane.getChildren().addAll(

welcomePane,

licensePane,

finalConfigPane

);

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

setWindow(WindowName.WELCOME);

}

private Label headingLabel;

private Button nextButton;

private Button previousButton;

private WelcomePane welcomePane;

private LicensePane licensePane;

private FinalConfigPane finalConfigPane;

private WindowName windowName;

private void onNextButtonClicked()

{

if(windowName == WindowName.WELCOME)

{

setWindow(WindowName.LICENSE);

}

else if(windowName == WindowName.LICENSE)

{

setWindow(WindowName.FINAL);

}

private void onPreviousButtonClicked()

{

if(windowName == WindowName.FINAL)

{

setWindow(WindowName.LICENSE);

}

else if(windowName == WindowName.LICENSE)

{

setWindow(WindowName.WELCOME);

}

private void setWindow(WindowName windowName)

{

if (windowName == WindowName.WELCOME)

{

this.windowName = WindowName.WELCOME;

welcomePane.toFront();

welcomePane.setVisible(true);

licensePane.setVisible(false);

finalConfigPane.setVisible(false);

headingLabel.setText("");

nextButton.setDisable(false);

nextButton.setText("Next");

previousButton.setDisable(true);

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

previousButton.setVisible(false);

}

else if (windowName == WindowName.LICENSE)

{

this.windowName = WindowName.LICENSE;

licensePane.toFront();

welcomePane.setVisible(false);

licensePane.setVisible(true);

finalConfigPane.setVisible(false);

headingLabel.setText("License Agreement");

nextButton.setDisable(false);

nextButton.setText("Agree and Continue");

previousButton.setDisable(false);

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

previousButton.setVisible(true);

}

else if (windowName == WindowName.FINAL)

{

this.windowName = WindowName.FINAL;

finalConfigPane.toFront();

welcomePane.setVisible(false);

licensePane.setVisible(false);

finalConfigPane.setVisible(true);

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

nextButton.setDisable(true);

finalConfigPane.makeChangesToNextButton();

previousButton.setDisable(false);

previousButton.setVisible(true);

}

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

+4 −6

package com.stream_pi.server.window.firsttimeuse;

import com.stream_pi.server.info.License;

import javafx.scene.control.Button;

import javafx.scene.control.Label;

import javafx.scene.control.TextArea;

import javafx.scene.layout.Priority;

import javafx.scene.layout.VBox;

public class LicensePane extends VBox {

public class LicensePane extends VBox

{

public LicensePane()

{

getStyleClass().add("first_time_use_pane_license");

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

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

label.setWrapText(true);

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

licenseTextArea.setWrapText(false);

licenseTextArea.setEditable(false);

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

VBox.setVgrow(licenseTextArea, Priority.ALWAYS);

getChildren().addAll(label, licenseTextArea);

getChildren().addAll(licenseTextArea);

}

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

+0 −5

package com.stream_pi.server.window.settings;

import com.stream_pi.server.connection.ServerListener;

import com.stream_pi.server.io.Config;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

import com.stream_pi.server.info.ServerInfo;

import com.stream_pi.util.alert.StreamPiAlert;

import com.stream_pi.util.alert.StreamPiAlertType;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.exception.SevereException;

import com.stream_pi.util.startatboot.SoftwareType;

import com.stream_pi.util.startatboot.StartAtBoot;

import com.stream_pi.util.version.Version;

import javafx.application.HostServices;

import javafx.application.Platform;

import javafx.concurrent.Task;

import javafx.geometry.Insets;

import javafx.geometry.Pos;

import javafx.scene.control.*;

import javafx.scene.control.Button;

import javafx.scene.control.Label;

import javafx.scene.control.ScrollPane;

import javafx.scene.control.TextField;

import javafx.scene.layout.*;

import javafx.stage.DirectoryChooser;

import org.json.JSONObject;

import org.kordamp.ikonli.javafx.FontIcon;

import java.awt.SystemTray;

import java.io.BufferedReader;

import java.io.File;

import java.io.InputStreamReader;

import java.net.URL;

import java.util.logging.Logger;

public class GeneralSettings extends VBox {

private final TextField serverNameTextField;

private final TextField portTextField;

private final TextField pluginsPathTextField;

private final TextField themesPathTextField;

private final TextField actionGridPaneActionBoxSize;

private final TextField actionGridPaneActionBoxGap;

private final ToggleButton startOnBootToggleButton;

private final ToggleButton closeOnXToggleButton;

private final Button saveButton;

private final Button checkForUpdatesButton;

private Logger logger;

private ExceptionAndAlertHandler exceptionAndAlertHandler;

private ServerListener serverListener;

private HostServices hostServices;

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

{

this.hostServices = hostServices;

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

this.serverListener = serverListener;

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

serverNameTextField = new TextField();

portTextField = new TextField();

pluginsPathTextField = new TextField();

themesPathTextField = new TextField();

actionGridPaneActionBoxSize = new TextField();

actionGridPaneActionBoxGap = new TextField();

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

closeOnXToggleButton = new ToggleButton("Quit On window Close");

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

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

getStyleClass().add("general_settings");

prefWidthProperty().bind(widthProperty());

setAlignment(Pos.CENTER);

setSpacing(5);

getChildren().addAll(

getUIInputBox("Server Name", serverNameTextField),

getUIInputBox("Port", portTextField),

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

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

getUIInputBoxWithDirectoryChooser("Plugins Path", pluginsPathTextField),

getUIInputBoxWithDirectoryChooser("Themes Path", themesPathTextField)

);

serverNameTextField.setPrefWidth(200);

HBox toggleButtons = new HBox(closeOnXToggleButton, startOnBootToggleButton);

toggleButtons.setSpacing(10.0);

VBox.setMargin(toggleButtons, new Insets(30, 0 , 0,0));

toggleButtons.setAlignment(Pos.CENTER);

saveButton = new Button("Save");

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

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

setPadding(new Insets(10));

}

private HBox getUIInputBoxWithDirectoryChooser(String labelText, TextField textField)

{

HBox hBox = getUIInputBox(labelText, textField);

hBox.setSpacing(5.0);

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

tf.setPrefWidth(300);

tf.setDisable(true);

Button button = new Button();

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

button.setGraphic(fontIcon);

button.setOnAction(event -> {

DirectoryChooser directoryChooser = new DirectoryChooser();

try {

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

textField.setText(selectedDirectory.getAbsolutePath());

}

catch (NullPointerException e)

{

logger.info("No folder selected");

}

});

hBox.getChildren().add(button);

return hBox;

}

private HBox getUIInputBox(String labelText, TextField textField)

{

textField.setPrefWidth(100);

Label label = new Label(labelText);

Region region = new Region();

HBox.setHgrow(region, Priority.ALWAYS);

return new HBox(label, region, textField);

}

public void loadDataFromConfig() throws SevereException {

Config config = Config.getInstance();

Platform.runLater(()->

{

serverNameTextField.setText(config.getServerName());

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

pluginsPathTextField.setText(config.getPluginsPath());

themesPathTextField.setText(config.getThemesPath());

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

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

closeOnXToggleButton.setSelected(config.getCloseOnX());

startOnBootToggleButton.setSelected(config.getStartOnBoot());

});

}

public void save()

{

new Thread(new Task<Void>() {

@Override

protected Void call()

{

try {

boolean toBeReloaded = false;

boolean dashToBeReRendered = false;

Platform.runLater(()->{

saveButton.setDisable(true);

serverNameTextField.setDisable(true);

portTextField.setDisable(true);

closeOnXToggleButton.setDisable(true);

startOnBootToggleButton.setDisable(true);

});

String serverNameStr = serverNameTextField.getText();

String serverPortStr = portTextField.getText();

String pluginsPathStr = pluginsPathTextField.getText();

String themesPathStr = themesPathTextField.getText();

String actionGridActionBoxSize = actionGridPaneActionBoxSize.getText();

String actionGridActionBoxGap = actionGridPaneActionBoxGap.getText();

boolean closeOnX = closeOnXToggleButton.isSelected();

boolean startOnBoot = startOnBootToggleButton.isSelected();

Config config = Config.getInstance();

StringBuilder errors = new StringBuilder();

if(serverNameStr.isBlank())

{

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

}

else

{

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

{

toBeReloaded = true;

}

int serverPort=-1;

try {

serverPort = Integer.parseInt(serverPortStr);

if (serverPort < 1024)

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

if(config.getPort()!=serverPort)

{

toBeReloaded = true;

}

catch (NumberFormatException e)

{

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

}

int actionSize=-1;

try {

actionSize = Integer.parseInt(actionGridActionBoxSize);

if(config.getActionGridActionSize() != actionSize)

{

dashToBeReRendered = true;

}

catch (NumberFormatException e)

{

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

}

int actionGap=-1;

try {

actionGap = Integer.parseInt(actionGridActionBoxGap);

if(config.getActionGridActionGap() != actionGap)

{

dashToBeReRendered = true;

}

catch (NumberFormatException e)

{

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

}

if(pluginsPathStr.isBlank())

{

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

}

else

{

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

{

toBeReloaded = true;

}

if(themesPathStr.isBlank())

{

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

}

else

{

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

{

toBeReloaded = true;

}

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

{

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

}

if(config.getStartOnBoot() != startOnBoot)

{

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

{

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

startOnBoot = false;

}

else

{

StartAtBoot startAtBoot = new StartAtBoot(SoftwareType.SERVER, ServerInfo.getInstance().getPlatformType());

if(startOnBoot)

{

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

}

else

{

boolean result = startAtBoot.delete();

if(!result)

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

}

if(!closeOnX)

{

System.out.println("XYZ");

if(!SystemTray.isSupported())

{

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

alert.show();

closeOnX = true;

}

else

{

System.out.println("YES");

}

config.setServerName(serverNameStr);

config.setServerPort(serverPort);

config.setActionGridGap(actionGap);

config.setActionGridSize(actionSize);

config.setPluginsPath(pluginsPathStr);

config.setThemesPath(themesPathStr);

config.setCloseOnX(closeOnX);

config.setStartupOnBoot(startOnBoot);

config.save();

loadDataFromConfig();

if(toBeReloaded)

{

new StreamPiAlert("Restart","Restart to see changes", StreamPiAlertType.INFORMATION).show();

}

if(dashToBeReRendered)

{

serverListener.clearTemp();

}

catch (MinorException e)

{

exceptionAndAlertHandler.handleMinorException(e);

}

catch (SevereException e)

{

exceptionAndAlertHandler.handleSevereException(e);

}

finally {

Platform.runLater(()->{

saveButton.setDisable(false);

serverNameTextField.setDisable(false);

portTextField.setDisable(false);

closeOnXToggleButton.setDisable(false);

startOnBootToggleButton.setDisable(false);

});

}

return null;

}

}).start();

}

public void checkForUpdates()

{

new Thread(new Task<Void>()

{

@Override

protected Void call() throws Exception {

try

{

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

String jsonRaw = readUrl("https://stream-pi.com/API/get_latest.php?TYPE=SERVER");

System.out.println(jsonRaw);

JSONObject jsonObject = new JSONObject(jsonRaw);

String latestVersionRaw = jsonObject.getString("Version");

String releasePage = jsonObject.getString("Release Page");

Version latestVersion = new Version(latestVersionRaw);

Version currentVersion = ServerInfo.getInstance().getVersion();

if(latestVersion.isBiggerThan(currentVersion))

{

VBox vBox = new VBox();

Hyperlink urlLabel = new Hyperlink(releasePage);

urlLabel.setOnAction(event->hostServices.showDocument(releasePage));

Label label = new Label(

"New Version "+latestVersionRaw+" Available.\n" +

"Current Version "+currentVersion.getText()+".\n"+

"Changelog and install instructions are included in the release page.\n" +

"It is recommended to update to ensure maximum stability and least bugs.");

label.setWrapText(true);

vBox.setSpacing(5);

vBox.getChildren().addAll(

urlLabel,

label

);

new StreamPiAlert("New Update Available!", StreamPiAlertType.INFORMATION, vBox).show();;

}

else

{

new StreamPiAlert("Up to Date", "Server is upto date. ("+currentVersion.getText()+")", StreamPiAlertType.INFORMATION).show();;

}

catch (Exception e)

{

e.printStackTrace();

new StreamPiAlert("Uh Oh", "Update Check Failed. API Error/Network issue.", StreamPiAlertType.WARNING).show();;

}

finally

{

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

}

return null;

}

}).start();;

}

private String readUrl(String urlString) throws Exception {

BufferedReader reader = null;

try {

URL url = new URL(urlString);

reader = new BufferedReader(new InputStreamReader(url.openStream()));

StringBuffer buffer = new StringBuffer();

int read;

char[] chars = new char[1024];

while ((read = reader.read(chars)) != -1)

buffer.append(chars, 0, read);

return buffer.toString();

} finally {

if (reader != null)

reader.close();

}

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

+2 −0

module com.stream_pi.server {

uses com.stream_pi.action_api.action.Action;

uses com.stream_pi.action_api.normalaction.NormalAction;

requires com.stream_pi.action_api;

requires com.stream_pi.util;

requires com.stream_pi.theme_api;

requires org.kordamp.ikonli.javafx;

requires org.apache.commons.lang3;

requires java.xml;

requires javafx.base;

requires javafx.graphics;

requires javafx.controls;

requires javafx.media;

requires java.desktop;

requires java.sql;

requires org.json;

exports com.stream_pi.server;

}

A src/main/resources/com/stream_pi/server/default_icons.css

+19 −0

.alert_error_icon

{

-fx-icon-color: RED;

}

.alert_information_icon

{

-fx-icon-color: BLUE;

}

.alert_warning_icon

{

-fx-icon-color: #ffcc00;

}

.action_details_pane_delete_button_icon

{

-fx-icon-color:red;

}

M src/main/resources/com/stream_pi/server/style.css

+30 −20

.root {

-fx-font-family : 'Roboto';

}

.about_donate_hyperlink

{

-fx-font-size : 19;

-fx-font-weight : bold;

}

.about_license_label

{

-fx-font-size : 16;

}

.theme_settings_each_theme_box, .plugins_settings_each_plugin_box, .clients_settings_each_client_box

{

-fx-border-width : 0 0 1 0;

-fx-border-color : grey;

}

.plugins_settings_each_plugin_heading_label, .themes_settings_each_theme_heading, .client_settings_each_client_nick_name_label

{

-fx-font-size : 19;

}

.action_box

{

-fx-border-width: 1px;

-fx-shape: "M100,100 h200 a20,20 0 0 1 20,20 v200 a20,20 0 0 1 -20,20 h-200 a20,20 0 0 1 -20,-20 v-200 a20,20 0 0 1 20,-20 z";

}

.action_box_icon_present

{

}

.action_box_icon_not_present

{

}

.action_box_valid

{

-fx-border-color: grey;

}

.action_box_invalid

{

-fx-border-color: red;

}

.action_box_display_text_label

{

-fx-font-size : 16;

-fx-background-color : transparent;

}

.action_details_pane_heading_label

{

-fx-font-size : 16;

}

.client_settings_each_client_socket_connection_label

{

-fx-font-size : 16;

}

.general_settings{

-fx-alignment : TOP_CENTER;

-fx-padding : 10;

}

.alert_header

{

-fx-padding: 5;

}

.alert_pane

{

-fx-border-width : 5;

-fx-border-radius : 5;

-fx-background-radius : 5;

-fx-max-width : 400;

-fx-effect: dropshadow( three-pass-box , rgba(0,0,0,0.6) , 5, 0.0 , 0.0 , 0 );

}

.alert_header_icon

{

-fx-icon-size : 30;

}

.alert_error_icon

{

-fx-icon-color: RED;

}

.alert_information_icon

{

-fx-icon-color: BLUE;

}

.alert_warning_icon

{

-fx-icon-color: #ffcc00;

}

.alert_content_pane

{

-fx-padding: 5;

}

.alert_pane_parent

{

-fx-background-color : rgba(0,0,0,0.5);

}

.alert_pane_header_text

{

-fx-font-size: 18;

}

.alert_button_bar

{

-fx-alignment: CENTER_RIGHT;

-fx-spacing: 5;

-fx-padding: 5;

}

.alert_scroll_pane {

-fx-max-height : 300;

/*-fx-focus-color: #FFFFFF;

-fx-faint-focus-color:#FFFFFF;*/

}

.plugins_pane

{

-fx-spacing: 5;

}

.plugins_pane_each_plugin_button_imageview

{

-fx-width:20;

-fx-height:20;

}

.about_donate_hyperlink

{

-fx-padding : 10 0 0 0;

-fx-font-size : 25;

}

.first_time_use_pane

{

-fx-padding : 5;

}

.first_time_use_pane_heading_label

{

-fx-font-size: 20;

}

.first_time_use_pane_stackpane

{

}

.first_time_use_pane_welcome

{

}

.first_time_use_pane_license

{

-fx-spacing : 10;

}

.first_time_use_pane_final_config

{

}

.first_time_use_pane_final_config_label

{

-fx-padding: 0 0 30 0;

}

.first_time_use_welcome_pane_welcome_label

{

-fx-font-size: 30;

}

.first_time_use_welcome_pane_next_to_continue_label

{

-fx-font-size: 15;

}

.scroll-pane

{

-fx-focus-color:transparent;

-fx-faint-focus-color:transparent;

}

.plugins_settings_scroll_pane, .themes_settings_scroll_pane, .clients_settings_scroll_pane

{

-fx-padding: 10 0 0 0;

}

.plugins_settings_each_plugin_box, .theme_settings_each_theme_box, .clients_settings_each_client_box

{

-fx-spacing : 5;

-fx-padding : 10 0 10 0;

}

.plugins_pane_each_plugin_box_parent, .plugins_pane_each_plugin_box

{

-fx-spacing : 5;

}

.about

{

-fx-spacing : 5;

}

.about_links_box

{

-fx-spacing : 15;

}

.action_details_pane_delete_button

{

-fx-text-fill : red;

}

.action_details_pane_delete_button_icon

{

-fx-icon-color:red;

}

.client_and_profile_selector_pane_stack

{

-fx-spacing: 5;

}

.plugins_settings, .themes_settings, .clients_settings

{

-fx-padding: 0 10 0 0;

}

/*Alert Classes added to default stylesheet to show init error, if occurs */

.action_box_display_text_label

{

-fx-font-size : 16;

-fx-background-color : transparent;

}

.alert_pane

{

-fx-background-color : white;

-fx-border-color : white;

}

.alert_content_pane

{

-fx-background-color: white;

-fx-padding: 5;

}

.alert_scroll_pane

{

-fx-background: white;

-fx-border-color:white;

}

.alert_button_bar

{

-fx-background-color:white;

}

Public

server

Clone or download

work

Modified Files