server

work

Download Browse

+27 −103

Author

Debayan Sutradhar (rnayabed) 2021-02-25 18:26

Committer

Debayan Sutradhar (rnayabed) 2021-02-25 18:26

Hash 727369ea07049de0a65426a05b837438e3c3052f

Parent ed813d9863c5180233a39848af2bf8405260499f

Reference git #server/727369ea07049de0a65426a05b837438e3c3052f

Modified Files

List

Side by side diff

Inline diff

M pom.xml

+0 −5

<?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>

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

+9 −10

package com.stream_pi.server.connection;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

import com.stream_pi.util.exception.SevereException;

import java.io.IOException;

import java.net.BindException;

import java.net.ServerSocket;

import java.net.Socket;

import java.net.SocketException;

import java.util.concurrent.atomic.AtomicBoolean;

import java.util.logging.Logger;

public class MainServer extends Thread{

private ServerListener serverListener;

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

private int port;

private ServerSocket serverSocket = null;

//private Server server;

private AtomicBoolean stop = new AtomicBoolean(false);

private ExceptionAndAlertHandler exceptionAndAlertHandler;

public MainServer(ServerListener serverListener, ExceptionAndAlertHandler exceptionAndAlertHandler)

{

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

this.port = port;

this.serverListener = serverListener;

}

public void setPort(int port) {

this.port = port;

}

@Override

public synchronized void start() {

stop.set(false);

super.start();

}

public void stopListeningForConnections()

{

/*if(server !=null)

{

if(!server.isShutdown())

server.shutdown();

}*/

try

{

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

if(serverSocket!=null)

if(!serverSocket.isClosed())

{

stop.set(true);

serverSocket.close();

}

} catch (IOException e) {

e.printStackTrace();

}

finally {

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

}

stop.set(true);

}

@Override

public void run() {

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

try {

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

/*Server server = ServerBuilder.forPort(port)

.addService(new ConnectionService(serverListener))

.build();

server.start();

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

serverSocket = new ServerSocket(port);

while(!stop.get())

{

Socket s = serverSocket.accept();

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

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

}

catch (SocketException e)

{

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

if(!e.getMessage().contains("Socket closed"))

exceptionAndAlertHandler.handleSevereException(new SevereException("Sorry","Unable to Start Server. Check logs, stacktrace. \n\n"+e.getMessage()));

{

e.printStackTrace();

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

exceptionAndAlertHandler.handleSevereException(new SevereException("Sorry","Another Server Instance probably running. Unable to Start Server \n\n"+e.getMessage()));

e.printStackTrace();

}

catch (IOException e)

{

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

e.printStackTrace();

}

M src/main/java/com/stream_pi/server/info/ServerInfo.java

+4 −2

ServerInfo.java

Stores basic information about the server - name, platform type

Contributors: Debayan Sutradhar (@dubbadhar)

package com.stream_pi.server.info;

import com.stream_pi.util.platform.Platform;

import com.stream_pi.util.platform.ReleaseStatus;

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

private static ServerInfo instance = null;

private String runnerFileName = null;

private boolean startMinimised = false;

private ServerInfo(){

private ServerInfo()

{

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

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

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

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

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

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

{

return commStandardVersion;

}

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

+4 −0

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

import com.stream_pi.action_api.action.Action;

import com.stream_pi.action_api.action.Location;

import com.stream_pi.action_api.otheractions.FolderAction;

import com.stream_pi.server.client.Client;

import com.stream_pi.server.client.ClientProfile;

import com.stream_pi.server.io.Config;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

import com.stream_pi.server.window.dashboard.actiondetailpane.ActionDetailsPaneListener;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.exception.SevereException;

import javafx.geometry.Insets;

import javafx.geometry.Pos;

import javafx.scene.CacheHint;

import javafx.scene.Node;

import javafx.scene.control.ScrollPane;

import javafx.scene.layout.*;

import org.kordamp.ikonli.javafx.FontIcon;

import java.util.logging.Logger;

public class ActionGridPane extends ScrollPane implements ActionGridPaneListener {

private ExceptionAndAlertHandler exceptionAndAlertHandler;

private ActionDetailsPaneListener actionDetailsPaneListener;

public ActionGridPane(ExceptionAndAlertHandler exceptionAndAlertHandler)

{

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

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

getStyleClass().add("action_grid_pane_parent");

VBox.setVgrow(this, Priority.ALWAYS);

actionsGridPane = new GridPane();

actionsGridPane.setPadding(new Insets(5.0));

actionsGridPane.getStyleClass().add("action_grid_pane");

actionsGridPane.setPrefSize(USE_COMPUTED_SIZE, USE_COMPUTED_SIZE);

setContent(actionsGridPane);

setCache(true);

setCacheHint(CacheHint.SPEED);

}

public void setActionDetailsPaneListener(ActionDetailsPaneListener actionDetailsPaneListener) {

this.actionDetailsPaneListener = actionDetailsPaneListener;

}

private String currentParent;

@Override

public void setCurrentParent(String currentParent) {

this.currentParent = currentParent;

}

public ClientProfile getClientProfile() {

return clientProfile;

}

private Client client;

public void setClient(Client client) {

this.client = client;

}

public Client getClient() {

return client;

}

private int rows, cols;

private GridPane actionsGridPane;

private ClientProfile clientProfile;

public void setClientProfile(ClientProfile clientProfile)

{

this.clientProfile = clientProfile;

setCurrentParent("root");

setRows(clientProfile.getRows());

setCols(clientProfile.getCols());

}

@Override

public String getCurrentParent() {

return currentParent;

}

public StackPane getFolderBackButton() throws SevereException

{

StackPane stackPane = new StackPane();

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

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

stackPane.setPrefSize(

Config.getInstance().getActionGridActionSize(),

Config.getInstance().getActionGridActionSize()

);

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

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

fontIcon.setIconSize(Config.getInstance().getActionGridActionSize() - 30);

stackPane.setAlignment(Pos.CENTER);

stackPane.getChildren().add(fontIcon);

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

return stackPane;

}

private ActionBox[][] actionBoxes;

private boolean isFreshRender = true;

private Node folderBackButton = null;

public void renderGrid() throws SevereException

{

actionsGridPane.setHgap(Config.getInstance().getActionGridActionGap());

actionsGridPane.setVgap(Config.getInstance().getActionGridActionGap());

if(isFreshRender)

{

clear();

actionBoxes = new ActionBox[cols][rows];

}

boolean isFolder = false;

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

{

if(folderBackButton != null)

{

actionsGridPane.getChildren().remove(folderBackButton);

folderBackButton = null;

actionBoxes[0][0] = addBlankActionBox(0,0);

}

else

{

isFolder = true;

if(folderBackButton != null)

{

actionsGridPane.getChildren().remove(folderBackButton);

folderBackButton = null;

}

else

{

actionsGridPane.getChildren().remove(actionBoxes[0][0]);

}

folderBackButton = getFolderBackButton();

actionsGridPane.add(folderBackButton, 0,0);

}

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

{

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

{

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

continue;

if(isFreshRender)

{

actionBoxes[col][row] = addBlankActionBox(col, row);

}

else

{

if(actionBoxes[col][row].getAction() != null)

{

actionBoxes[col][row].clear();

}

isFreshRender = false;

}

public void setFreshRender(boolean freshRender)

{

isFreshRender = freshRender;

}

public ActionBox addBlankActionBox(int col, int row) throws SevereException {

ActionBox actionBox = new ActionBox(Config.getInstance().getActionGridActionSize(), actionDetailsPaneListener, this,

col, row);

actionsGridPane.add(actionBox, row, col);

return actionBox;

}

public void renderActions()

{

StringBuilder errors = new StringBuilder();

for(String action1x : getClientProfile().getActionsKeySet())

{

Action eachAction = getClientProfile().getActionByID(action1x);

logger.info("action ID : "+eachAction.getID()+

"\nInvalid : "+eachAction.isInvalid());

try {

renderAction(eachAction);

}

catch (SevereException e)

{

exceptionAndAlertHandler.handleSevereException(e);

}

catch (MinorException e)

{

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

}

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

{

exceptionAndAlertHandler.handleMinorException(new MinorException("Error while rendering following actions", errors.toString()));

}

public void clear()

{

actionsGridPane.getChildren().clear();

}

private Logger logger;

public void renderAction(Action action) throws SevereException, MinorException

{

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

{

logger.info("Skipping action "+action.getID()+", not current parent!");

return;

}

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

{

logger.info("action has -1 rowIndex. Probably Combine action. Skipping ...");

return;

}

if(action.getLocation().getRow() >= rows || action.getLocation().getCol() >= cols)

{

throw new MinorException("action "+action.getDisplayText()+" ("+action.getID()+") falls outside bounds.\n" +

" Consider increasing rows/cols from client settings and relocating/deleting it.");

}

Location location = action.getLocation();

ActionBox actionBox = actionBoxes[location.getCol()][location.getRow()];

actionBox.clear();

actionBox.setAction(action);

actionBox.init();

/*ActionBox actionBox = new ActionBox(Config.getInstance().getActionGridActionSize(), action, actionDetailsPaneListener, exceptionAndAlertHandler, this);

Location location = action.getLocation();

actionBox.setStreamPiParent(currentParent);

actionBox.setRow(location.getRow());

actionBox.setCol(location.getCol());

for(Node node : actionsGridPane.getChildren())

{

if(GridPane.getColumnIndex(node) == location.getRow() &&

GridPane.getRowIndex(node) == location.getCol())

{

actionsGridPane.getChildren().remove(node);

break;

}

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

actionsGridPane.add(actionBox, location.getRow(), location.getCol());*/

}

public void setRows(int rows)

{

this.rows = rows;

}

public void setCols(int cols)

{

this.cols = cols;

}

public int getRows()

{

return rows;

}

public int getCols()

{

return cols;

}

@Override

public void addActionToCurrentClientProfile(Action newAction) {

try {

getClientProfile().addAction(newAction);

} catch (CloneNotSupportedException e) {

e.printStackTrace();

}

private String previousParent;

public void setPreviousParent(String previousParent) {

this.previousParent = previousParent;

}

public String getPreviousParent() {

return previousParent;

}

@Override

public void renderFolder(FolderAction action) {

setCurrentParent(action.getID());

setPreviousParent(action.getParent());

try {

renderGrid();

renderActions();

} catch (SevereException e) {

e.printStackTrace();

}

public void returnToPreviousParent()

{

setCurrentParent(getPreviousParent());

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

{

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

setPreviousParent(getClientProfile().getActionByID(

getPreviousParent()

).getParent());

}

try {

renderGrid();

renderActions();

} catch (SevereException e) {

e.printStackTrace();

}

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

+9 −84

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

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.platform.PlatformType;

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

{

new CheckForUpdates(checkForUpdatesButton, hostServices,

PlatformType.SERVER, ServerInfo.getInstance().getVersion());

}

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

StartAtBoot startAtBoot = new StartAtBoot(PlatformType.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)

{

if(!SystemTray.isSupported())

{

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

alert.show();

closeOnX = true;

}

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

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/com/stream_pi/server/window/settings/SettingsBase.java

+1 −1

package com.stream_pi.server.window.settings;

import com.stream_pi.server.connection.ServerListener;

import com.stream_pi.server.window.ExceptionAndAlertHandler;

import javafx.application.HostServices;

import javafx.geometry.Insets;

import javafx.geometry.Pos;

import javafx.scene.CacheHint;

import javafx.scene.control.*;

import javafx.scene.layout.Priority;

import javafx.scene.layout.VBox;

public class SettingsBase extends VBox {

private TabPane tabPane;

private GeneralSettings generalSettings;

private PluginsSettings pluginsSettings;

private ThemesSettings themesSettings;

private ClientsSettings clientsSettings;

private Button closeButton;

private HostServices hostServices;

private ExceptionAndAlertHandler exceptionAndAlertHandler;

public SettingsBase(HostServices hostServices, ExceptionAndAlertHandler exceptionAndAlertHandler,

ServerListener serverListener)

{

this.exceptionAndAlertHandler = exceptionAndAlertHandler;

this.hostServices = hostServices;

tabPane = new TabPane();

tabPane.setTabClosingPolicy(TabPane.TabClosingPolicy.UNAVAILABLE);

VBox.setVgrow(tabPane, Priority.ALWAYS);

Tab generalSettingsTab = new Tab("General");

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

generalSettingsTab.setContent(generalSettings);

Tab pluginsSettingsTab = new Tab("Plugins");

pluginsSettings = new PluginsSettings(exceptionAndAlertHandler, hostServices);

pluginsSettingsTab.setContent(pluginsSettings);

Tab themesSettingsTab = new Tab("Themes");

themesSettings = new ThemesSettings(hostServices);

themesSettingsTab.setContent(themesSettings);

Tab clientsSettingsTab = new Tab("Clients");

clientsSettings = new ClientsSettings(exceptionAndAlertHandler, serverListener);

clientsSettingsTab.setContent(clientsSettings);

Tab aboutTab = new Tab("About");

aboutTab.setContent(new About(hostServices));

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

setAlignment(Pos.TOP_RIGHT);

closeButton = new Button("Close");

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

getChildren().addAll(tabPane, closeButton);

setCache(true);

setCacheHint(CacheHint.QUALITY);

setCacheHint(CacheHint.SPEED);

}

public void setDefaultTabToGeneral()

{

tabPane.getSelectionModel().selectFirst();

}

public Button getCloseButton()

{

return closeButton;

}

public GeneralSettings getGeneralSettings()

{

return generalSettings;

}

public PluginsSettings getPluginsSettings()

{

return pluginsSettings;

}

public ThemesSettings getThemesSettings()

{

return themesSettings;

}

public ClientsSettings getClientsSettings()

{

return clientsSettings;

}

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

+0 −1

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 java.xml;

requires org.json;

requires javafx.base;

requires javafx.graphics;

requires javafx.controls;

requires javafx.media;

requires java.desktop;

requires java.sql;

exports com.stream_pi.server;

}

Public

server

Clone or download

work

Modified Files