essential-actions

[OBS] Updated Mother, SetCurrentProfile, SetCurrentScene, SetCurrentTransition, SetMute, SetRecording, SetPreviewScene according to 2.0.0

Download Browse

+336 −201

Author

Debayan Sutradhar (rnayabed) 2021-04-10 13:14

Committer

Debayan Sutradhar (rnayabed) 2021-04-10 13:14

Hash fc65908b61fabef8448551ce2c28be8e5203d7ea

Parent 72cc1be04b7e42b2aec17408ba367f83f01615cd

Reference git #essential-actions/fc65908b61fabef8448551ce2c28be8e5203d7ea

Modified Files

List

Side by side diff

Inline diff

M obssuite/mother/.gitignore

+1 −0

.idea/

target/

.classpath

.factorypath

.project

.settings/

obssuite_motheraction.iml

D obssuite/mother/OBSSuite-MotherAction.iml

+0 −35

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

<output-test url="file://$MODULE_DIR$/target/test-classes" />

</content>

</component>

</module>

M obssuite/mother/src/main/java/mother/OBSActionConnectionTask.java

+1 −1

package mother;

import mother.motherconnection.MotherConnection;

import javafx.application.Platform;

import javafx.concurrent.Task;

import javafx.scene.control.Button;

import net.twasi.obsremotejava.OBSRemoteController;

import com.stream_pi.util.alert.StreamPiAlert;

import com.stream_pi.util.alert.StreamPiAlertType;

public class OBSActionConnectionTask extends Task<Void>

{

private Runnable onFailToConnectRunnable = null;

private Runnable onConnectRunnable = null;

private Runnable onDisconnectRunnable = null;

public OBSActionConnectionTask(boolean runAsync, Runnable onFailToConnectRunnable,

Runnable onConnectRunnable, Runnable onDisconnectRunnable)

{

this.onFailToConnectRunnable = onFailToConnectRunnable;

this.onConnectRunnable = onConnectRunnable;

this.onDisconnectRunnable = onDisconnectRunnable;

if(runAsync)

{

new Thread(this).start();

}

else

{

call();

}

@Override

protected Void call()

{

try

{

String url = MotherConnection.getUrl();

String pass = MotherConnection.getPass();

setConnectDisconnectButtonDisable(true);

if(!url.startsWith("ws://"))

{

new StreamPiAlert("Invalid URL","Please fix URL and try again", StreamPiAlertType.ERROR).show();

return null;

}

if(pass.isEmpty() || pass.isBlank())

pass = null;

OBSRemoteController obsRemoteController = new OBSRemoteController(url, false, pass);

if(obsRemoteController.isFailed())

{

new StreamPiAlert("Unable to Connect to OBS", "Is it even running? Make sure the websocket plugin is installed. Check Credentials too", StreamPiAlertType.ERROR).show();

}

obsRemoteController.registerConnectionFailedCallback(message->{

setConnectDisconnectButtonText("Connect");

new StreamPiAlert("Unable to Connect", "Unable to establish connection to WebSocket with provided crendentials\n\n"+

"Detailed Error : "+message, StreamPiAlertType.ERROR).show();

MotherConnection.setRemoteController(null);

if(onFailToConnectRunnable != null)

{

onFailToConnectRunnable.run();

onFailToConnectRunnable = null;

}

});

obsRemoteController.registerDisconnectCallback(()->{

setConnectDisconnectButtonText("Connect");

MotherConnection.setRemoteController(null);

if(onDisconnectRunnable != null)

{

onDisconnectRunnable.run();

onDisconnectRunnable = null;

}

});

obsRemoteController.registerConnectCallback(onConnect->{

setConnectDisconnectButtonText("Disconnect");

MotherConnection.setRemoteController(obsRemoteController);

if(onConnectRunnable != null)

{

onConnectRunnable.run();

onConnectRunnable = null;

}

});

}

catch (Exception e)

{

new StreamPiAlert("Unable to Connect", "Unable to establish connection to WebSocket with provided crendentials", StreamPiAlertType.ERROR).show();

MotherConnection.showOBSNotRunningError();

MotherConnection.setRemoteController(null);

e.printStackTrace();

}

finally

{

setConnectDisconnectButtonDisable(false);

}

return null;

}

private void setConnectDisconnectButtonText(String text)

{

if(MotherConnection.getConnectDisconnectButton() == null)

return;

Platform.runLater(()-> MotherConnection.getConnectDisconnectButton().setText(text));

}

private void setConnectDisconnectButtonDisable(boolean disable)

{

if(MotherConnection.getConnectDisconnectButton() == null)

return;

Platform.runLater(()-> MotherConnection.getConnectDisconnectButton().setDisable(disable));

}

M obssuite/mother/src/main/java/mother/motherconnection/MotherConnection.java

+8 −0

package mother.motherconnection;

import com.stream_pi.util.alert.StreamPiAlert;

import com.stream_pi.util.alert.StreamPiAlertType;

import com.stream_pi.util.version.Version;

import javafx.scene.control.Button;

import mother.OBSActionConnectionTask;

import net.twasi.obsremotejava.OBSRemoteController;

import net.twasi.obsremotejava.callbacks.Callback;

import net.twasi.obsremotejava.requests.ResponseBase;

public class MotherConnection

{

private static OBSRemoteController obsRemoteController = null;

public static final Version VERSION = new Version(2,0,0);

private static String url = null;

private static String pass = null;

private static Button connectDisconnectButton = null;

public static void setConnectDisconnectButton(Button connectDisconnectButton)

{

MotherConnection.connectDisconnectButton = connectDisconnectButton;

}

public static Button getConnectDisconnectButton()

{

return connectDisconnectButton;

}

public static void setUrl(String url) {

MotherConnection.url = url;

}

public static void setPass(String pass) {

MotherConnection.pass = pass;

}

public static String getUrl() {

return url;

}

public static String getPass() {

return pass;

}

public static void connect()

{

connect(true, null, null, null);

}

public static void connect(Runnable onConnectRunnable)

{

connect(true, null, onConnectRunnable, null);

}

public static void connect(boolean runAsync, Runnable onFailToConnectRunnable,

Runnable onConnectRunnable, Runnable onDisconnectRunnable)

{

new OBSActionConnectionTask(runAsync, onFailToConnectRunnable,

onConnectRunnable, onDisconnectRunnable);

}

public static OBSRemoteController getRemoteController()

{

return obsRemoteController;

}

public static void setRemoteController(OBSRemoteController obsRemoteController)

{

MotherConnection.obsRemoteController = obsRemoteController;

}

public static Callback getDefaultCallBack(String head, String content)

{

return response ->

{

if(response.getStatus().equals("error"))

{

new StreamPiAlert(head, content, StreamPiAlertType.ERROR).show();

}

};

}

public static void showOBSNotRunningError()

{

new StreamPiAlert("Is OBS Connected?",

"It seems there is no connection to OBS, please connect it in Settings", StreamPiAlertType.WARNING)

.show();

}

M obssuite/setcurrentprofile/src/main/java/setcurrentprofile/SetCurrentProfile.java

+1 −3

package setcurrentprofile;

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

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

import com.stream_pi.action_api.externalplugin.NormalAction;

import com.stream_pi.util.alert.StreamPiAlert;

import com.stream_pi.util.alert.StreamPiAlertType;

import com.stream_pi.util.exception.MinorException;

import mother.motherconnection.MotherConnection;

public class SetCurrentProfile extends NormalAction

{

public SetCurrentProfile() {

setName("Set Current Profile");

setCategory("OBS");

setVisibilityInServerSettingsPane(false);

setAuthor("rnayabed");

setVersion(MotherConnection.VERSION);

}

@Override

public void initProperties() throws Exception

{

Property currentProfileProperty = new Property("profile", Type.STRING);

currentProfileProperty.setDisplayName("Profile Name");

Property autoConnectProperty = new Property("auto_connect", Type.BOOLEAN);

autoConnectProperty.setDefaultValueBoolean(true);

autoConnectProperty.setDisplayName("Auto Connect if not connected");

addClientProperties(currentProfileProperty, autoConnectProperty);

}

@Override

public void onActionClicked() throws Exception

{

String profile = getClientProperties().getSingleProperty("profile").getStringValue();

if(profile.isBlank())

{

throw new MinorException("Blank Profile Name","No Profile Name specified");

}

if (MotherConnection.getRemoteController() == null)

{

boolean autoConnect = getClientProperties().getSingleProperty(

"auto_connect"

).getBoolValue();

if(autoConnect)

{

MotherConnection.connect(()->setProfile(profile));

}

else

{

new StreamPiAlert("Is OBS Connected?",

MotherConnection.showOBSNotRunningError();

"It seems there is no connection to OBS, please connect it in Settings", StreamPiAlertType.WARNING)

.show();

}

else

{

setProfile(profile);

}

public void setProfile(String profile)

{

MotherConnection.getRemoteController().setCurrentProfile(profile, setCurrentProfileResponse -> {

String status = setCurrentProfileResponse.getStatus();

String error = setCurrentProfileResponse.getError();

if(status.equals("error"))

{

String content;

if(error.equals("profile does not exist"))

{

content = "Profile "+profile+" does not exist.";

}

else

{

content = error;

}

new StreamPiAlert("OBS",content, StreamPiAlertType.ERROR).show();

}

});

}

M obssuite/setcurrentscene/pom.xml

+2 −2

<?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>obssuite_setcurrentsceneaction</artifactId>

<build>

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

<artifactId>maven-jar-plugin</artifactId>

<phase>package</phase>

<goals>

</goals>

</execution>

</executions>

</plugin>

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

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

</configuration>

</plugin>

</plugins>

</build>

<ActionAPIVersion>1.0.0-SNAPSHOT</ActionAPIVersion>

<UtilVersion>1.0.0-SNAPSHOT</UtilVersion>

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

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

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

</properties>

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

<version>${UtilVersion}</version>

</dependency>

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

<artifactId>action-api</artifactId>

<version>${ActionAPIVersion}</version>

</dependency>

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

<artifactId>obssuite_motheraction</artifactId>

<version>${OBSSuiteMotherVersion}</version>

</dependency>

</dependencies>

</project>

M obssuite/setcurrentscene/src/main/java/setcurrentscene/SetCurrentScene.java

+62 −32

package setcurrentscene;

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

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

import com.stream_pi.action_api.externalplugin.NormalAction;

import com.stream_pi.util.alert.StreamPiAlert;

import com.stream_pi.util.alert.StreamPiAlertType;

import com.stream_pi.util.version.Version;

import com.stream_pi.util.exception.MinorException;

import mother.motherconnection.MotherConnection;

import net.twasi.obsremotejava.OBSRemoteController;

public class SetCurrentScene extends NormalAction {

public class SetCurrentScene extends NormalAction

{

public SetCurrentScene() {

public SetCurrentScene()

{

setName("Set Current Scene");

setCategory("OBS");

setVisibilityInServerSettingsPane(false);

setAuthor("rnayabed");

setVersion(new Version(1, 0, 0));

setVersion(MotherConnection.VERSION);

}

@Override

public void initProperties() throws Exception {

public void initProperties() throws Exception

// TODO Auto-generated method stub

{

Property currentSceneProperty = new Property("scene", Type.STRING);

Property currentSceneProperty = new Property("current_scene", Type.STRING);

currentSceneProperty.setDisplayName("Scene Name");

addClientProperties(currentSceneProperty);

}

@Override

Property autoConnectProperty = new Property("auto_connect", Type.BOOLEAN);

public void initAction() throws Exception {

autoConnectProperty.setDefaultValueBoolean(true);

// TODO Auto-generated method stub

autoConnectProperty.setDisplayName("Auto Connect if not connected");

addClientProperties(currentSceneProperty, autoConnectProperty);

}

@Override

public void onActionClicked() throws Exception {

public void onActionClicked() throws Exception

// TODO Auto-generated method stub

{

String scene = getClientProperties().getSingleProperty("scene").getStringValue();

OBSRemoteController controller = MotherConnection.getRemoteController();

if(scene.isBlank())

if (controller == null) {

{

new StreamPiAlert("Is OBS Connected?",

throw new MinorException("Blank Scene Name","No Scene Name specified");

"It seems there is no connection to OBS, please connect it in Settings", StreamPiAlertType.WARNING)

}

.show();

} else {

if (MotherConnection.getRemoteController() == null)

controller.setCurrentScene(getClientProperties().getSingleProperty("current_scene").getStringValue(), MotherConnection.getDefaultCallBack(

{

"Unable to Set Current Scene","Failed to set current Scene"

boolean autoConnect = getClientProperties().getSingleProperty(

));

"auto_connect"

).getBoolValue();

if(autoConnect)

{

MotherConnection.connect(()->setScene(scene));

}

else

{

MotherConnection.showOBSNotRunningError();

}

else

{

setScene(scene);

}

@Override

public void setScene(String scene)

public void onShutDown() throws Exception {

{

// TODO Auto-generated method stub

MotherConnection.getRemoteController().setCurrentScene(scene, setCurrentSceneResponse -> {

String status = setCurrentSceneResponse.getStatus();

String error = setCurrentSceneResponse.getError();

if(status.equals("error"))

{

String content;

if(error.equals("scene does not exist"))

{

content = "Scene "+scene+" does not exist.";

}

else

{

content = error;

}

new StreamPiAlert("OBS",content, StreamPiAlertType.ERROR).show();

}

});

}

M obssuite/setcurrenttransition/pom.xml

+2 −2

<?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>obssuite_setcurrenttransitionaction</artifactId>

<build>

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

<artifactId>maven-jar-plugin</artifactId>

<phase>package</phase>

<goals>

</goals>

</execution>

</executions>

</plugin>

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

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

</configuration>

</plugin>

</plugins>

</build>

<ActionAPIVersion>1.0.0-SNAPSHOT</ActionAPIVersion>

<UtilVersion>1.0.0-SNAPSHOT</UtilVersion>

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

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

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

</properties>

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

<version>${UtilVersion}</version>

</dependency>

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

<artifactId>action-api</artifactId>

<version>${ActionAPIVersion}</version>

</dependency>

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

<artifactId>obssuite_motheraction</artifactId>

<version>${OBSSuiteMotherVersion}</version>

</dependency>

</dependencies>

</project>

M obssuite/setcurrenttransition/src/main/java/setcurrenttransition/SetCurrentTransition.java

+62 −27

package setcurrenttransition;

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

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

import com.stream_pi.action_api.externalplugin.NormalAction;

import com.stream_pi.util.alert.StreamPiAlert;

import com.stream_pi.util.alert.StreamPiAlertType;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.version.Version;

import mother.motherconnection.MotherConnection;

import net.twasi.obsremotejava.OBSRemoteController;

public class SetCurrentTransition extends NormalAction {

public SetCurrentTransition() {

public SetCurrentTransition()

{

setName("Set Current Transition");

setCategory("OBS");

setVisibilityInServerSettingsPane(false);

setAuthor("rnayabed");

setVersion(new Version(1, 0, 0));

setVersion(MotherConnection.VERSION);

}

@Override

public void initProperties() throws Exception {

public void initProperties() throws Exception

Property currentTransitionProperty = new Property("current_transition", Type.STRING);

{

Property currentTransitionProperty = new Property("transition", Type.STRING);

currentTransitionProperty.setDisplayName("Transition Name");

addClientProperties(currentTransitionProperty);

}

@Override

Property autoConnectProperty = new Property("auto_connect", Type.BOOLEAN);

public void initAction() throws Exception {

autoConnectProperty.setDefaultValueBoolean(true);

// TODO Auto-generated method stub

autoConnectProperty.setDisplayName("Auto Connect if not connected");

addClientProperties(currentTransitionProperty, autoConnectProperty);

}

@Override

public void onActionClicked() throws Exception {

public void onActionClicked() throws Exception

// TODO Auto-generated method stub

{

String transition = getClientProperties().getSingleProperty("transition").getStringValue();

OBSRemoteController controller = MotherConnection.getRemoteController();

if(transition.isBlank())

if (controller == null) {

{

new StreamPiAlert("Is OBS Connected?",

throw new MinorException("Blank Transition Name","No Transition Name specified");

"It seems there is no connection to OBS, please connect it in Settings", StreamPiAlertType.WARNING)

}

.show();

} else {

if (MotherConnection.getRemoteController() == null)

controller.setCurrentTransition(getClientProperties().getSingleProperty("current_transition").getStringValue(), MotherConnection.getDefaultCallBack(

{

"Unable to Set Current Transition","Failed to set current Transition"

boolean autoConnect = getClientProperties().getSingleProperty(

));

"auto_connect"

).getBoolValue();

if(autoConnect)

{

MotherConnection.connect(()->setTransition(transition));

}

else

{

MotherConnection.showOBSNotRunningError();

}

else

{

setTransition(transition);

}

@Override

public void onShutDown() throws Exception {

// TODO Auto-generated method stub

public void setTransition(String transition)

{

MotherConnection.getRemoteController().setCurrentTransition(transition, setCurrentTransitionResponse -> {

String status = setCurrentTransitionResponse.getStatus();

String error = setCurrentTransitionResponse.getError();

if(status.equals("error"))

{

String content;

if(error.equals("transition does not exist"))

{

content = "Transition "+transition+" does not exist.";

}

else

{

content = error;

}

new StreamPiAlert("OBS",content, StreamPiAlertType.ERROR).show();

}

});

}

M obssuite/setmute/pom.xml

+2 −2

<?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>obssuite_setmuteaction</artifactId>

<build>

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

<artifactId>maven-jar-plugin</artifactId>

<phase>package</phase>

<goals>

</goals>

</execution>

</executions>

</plugin>

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

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

</configuration>

</plugin>

</plugins>

</build>

<ActionAPIVersion>1.0.0-SNAPSHOT</ActionAPIVersion>

<UtilVersion>1.0.0-SNAPSHOT</UtilVersion>

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

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

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

</properties>

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

<version>${UtilVersion}</version>

</dependency>

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

<artifactId>action-api</artifactId>

<version>${ActionAPIVersion}</version>

</dependency>

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

<artifactId>obssuite_motheraction</artifactId>

<version>${OBSSuiteMotherVersion}</version>

</dependency>

</dependencies>

</project>

M obssuite/setmute/src/main/java/setmute/SetMute.java

+73 −31

package setmute;

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

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

import com.stream_pi.action_api.externalplugin.NormalAction;

import com.stream_pi.action_api.externalplugin.ToggleAction;

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.version.Version;

import mother.motherconnection.MotherConnection;

import net.twasi.obsremotejava.OBSRemoteController;

public class SetMute extends NormalAction {

public class SetMute extends ToggleAction

{

public SetMute() {

public SetMute()

{

setName("Set Mute");

setCategory("OBS");

setVisibilityInServerSettingsPane(false);

setAuthor("rnayabed");

setVersion(new Version(1, 0, 0));

setVersion(MotherConnection.VERSION);

}

@Override

public void initProperties() throws Exception {

public void onToggleOn() throws Exception

Property sourceProperty = new Property("source", Type.STRING);

{

sourceProperty.setDisplayName("Source");

onClicked(true);

Property isMuteProperty = new Property("mute", Type.BOOLEAN);

isMuteProperty.setDisplayName("Mute");

addClientProperties(sourceProperty,isMuteProperty);

}

@Override

public void initAction() throws Exception {

public void onToggleOff() throws Exception

// TODO Auto-generated method stub

{

onClicked(false);

}

@Override

public void onActionClicked() throws Exception {

public void initProperties() throws Exception

// TODO Auto-generated method stub

{

Property sourceProperty = new Property("source", Type.STRING);

OBSRemoteController controller = MotherConnection.getRemoteController();

sourceProperty.setDisplayName("Source");

if (controller == null) {

Property autoConnectProperty = new Property("auto_connect", Type.BOOLEAN);

new StreamPiAlert("Is OBS Connected?",

autoConnectProperty.setDefaultValueBoolean(true);

"It seems there is no connection to OBS, please connect it in Settings", StreamPiAlertType.WARNING)

autoConnectProperty.setDisplayName("Auto Connect if not connected");

.show();

} else {

addClientProperties(sourceProperty, autoConnectProperty);

controller.setMute(getClientProperties().getSingleProperty("source").getStringValue(), getClientProperties().getSingleProperty("mute").getBoolValue(), MotherConnection.getDefaultCallBack(

}

"Failed to mute source","Failed to do that"

));

public void onClicked(boolean mute) throws MinorException

{

String source = getClientProperties().getSingleProperty("source").getStringValue();

if(source.isBlank())

{

throw new MinorException("Blank Source Name","No Source specified");

}

if (MotherConnection.getRemoteController() == null)

{

boolean autoConnect = getClientProperties().getSingleProperty(

"auto_connect"

).getBoolValue();

if(autoConnect)

{

MotherConnection.connect(()->setMute(source, mute));

}

else

{

MotherConnection.showOBSNotRunningError();

}

else

{

setMute(source, mute);

}

@Override

public void setMute(String scene, boolean mute)

public void onShutDown() throws Exception {

{

// TODO Auto-generated method stub

MotherConnection.getRemoteController().setMute(scene, mute, setMuteResponse -> {

String status = setMuteResponse.getStatus();

String error = setMuteResponse.getError();

if(status.equals("error"))

{

String content;

if(error.equals("source does not exist"))

{

content = "Source "+scene+" does not exist.";

}

else

{

content = error;

}

new StreamPiAlert("OBS",content, StreamPiAlertType.ERROR).show();

}

});

}

M obssuite/setpreviewscene/pom.xml

+2 −2

<?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>obssuite_setpreviewsceneaction</artifactId>

<build>

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

<artifactId>maven-jar-plugin</artifactId>

<phase>package</phase>

<goals>

</goals>

</execution>

</executions>

</plugin>

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

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

</configuration>

</plugin>

</plugins>

</build>

<ActionAPIVersion>1.0.0-SNAPSHOT</ActionAPIVersion>

<UtilVersion>1.0.0-SNAPSHOT</UtilVersion>

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

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

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

</properties>

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

<version>${UtilVersion}</version>

</dependency>

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

<artifactId>action-api</artifactId>

<version>${ActionAPIVersion}</version>

</dependency>

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

<artifactId>obssuite_motheraction</artifactId>

<version>${OBSSuiteMotherVersion}</version>

</dependency>

</dependencies>

</project>

M obssuite/setpreviewscene/src/main/java/setpreviewscene/SetPreviewScene.java

+58 −26

package setpreviewscene;

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

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

import com.stream_pi.action_api.externalplugin.NormalAction;

import com.stream_pi.util.alert.StreamPiAlert;

import com.stream_pi.util.alert.StreamPiAlertType;

import com.stream_pi.util.exception.MinorException;

import com.stream_pi.util.version.Version;

import mother.motherconnection.MotherConnection;

import net.twasi.obsremotejava.OBSRemoteController;

public class SetPreviewScene extends NormalAction {

public class SetPreviewScene extends NormalAction

{

public SetPreviewScene() {

public SetPreviewScene()

{

setName("Set Preview Scene");

setCategory("OBS");

setVisibilityInServerSettingsPane(false);

setAuthor("rnayabed");

setVersion(new Version(1, 0, 0));

setVersion(MotherConnection.VERSION);

}

@Override

public void initProperties() throws Exception {

Property previewSceneProperty = new Property("preview_scene", Type.STRING);

previewSceneProperty.setDisplayName("Preview Scene");

addClientProperties(previewSceneProperty);

Property autoConnectProperty = new Property("auto_connect", Type.BOOLEAN);

}

autoConnectProperty.setDefaultValueBoolean(true);

autoConnectProperty.setDisplayName("Auto Connect if not connected");

@Override

addClientProperties(previewSceneProperty, autoConnectProperty);

public void initAction() throws Exception {

// TODO Auto-generated method stub

}

@Override

public void onActionClicked() throws Exception {

public void onActionClicked() throws Exception

// TODO Auto-generated method stub

{

String previewScene = getClientProperties().getSingleProperty("preview_scene").getStringValue();

OBSRemoteController controller = MotherConnection.getRemoteController();

if(previewScene.isBlank())

if (controller == null) {

{

new StreamPiAlert("Is OBS Connected?",

throw new MinorException("Blank Preview Scene Name","No Preview Scene Name specified");

"It seems there is no connection to OBS, please connect it in Settings", StreamPiAlertType.WARNING)

}

.show();

} else {

if (MotherConnection.getRemoteController() == null)

controller.setPreviewScene(getClientProperties().getSingleProperty("preview_scene").getStringValue(), MotherConnection.getDefaultCallBack(

{

"Failed to set preview scene","Failed to do that"

boolean autoConnect = getClientProperties().getSingleProperty(

));

"auto_connect"

).getBoolValue();

if(autoConnect)

{

MotherConnection.connect(()->setPreviewScene(previewScene));

}

else

{

MotherConnection.showOBSNotRunningError();

}

else

{

setPreviewScene(previewScene);

}

@Override

public void setPreviewScene(String previewScene)

public void onShutDown() throws Exception {

{

// TODO Auto-generated method stub

MotherConnection.getRemoteController().setPreviewScene(previewScene, setPreviewSceneResponse -> {

String status = setPreviewSceneResponse.getStatus();

String error = setPreviewSceneResponse.getError();

if(status.equals("error"))

{

String content;

if(error.equals("scene does not exist"))

{

content = "Preview Scene "+previewScene+" does not exist.";

}

else

{

content = error;

}

new StreamPiAlert("OBS",content, StreamPiAlertType.ERROR).show();

}

});

}

M obssuite/setrecording/pom.xml

+2 −2

<?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>obssuite_setrecordingaction</artifactId>

<build>

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

<artifactId>maven-jar-plugin</artifactId>

<phase>package</phase>

<goals>

</goals>

</execution>

</executions>

</plugin>

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

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

</configuration>

</plugin>

</plugins>

</build>

<ActionAPIVersion>1.0.0-SNAPSHOT</ActionAPIVersion>

<UtilVersion>1.0.0-SNAPSHOT</UtilVersion>

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

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

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

</properties>

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

<version>${UtilVersion}</version>

</dependency>

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

<artifactId>action-api</artifactId>

<version>${ActionAPIVersion}</version>

</dependency>

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

<artifactId>obssuite_motheraction</artifactId>

<version>${OBSSuiteMotherVersion}</version>

</dependency>

</dependencies>

</project>

M obssuite/setrecording/src/main/java/setrecording/SetRecording.java

+60 −36

package setrecording;

import java.util.ArrayList;

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

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

import com.stream_pi.action_api.externalplugin.NormalAction;

import com.stream_pi.action_api.externalplugin.ToggleAction;

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.version.Version;

import mother.motherconnection.MotherConnection;

import net.twasi.obsremotejava.OBSRemoteController;

public class SetRecording extends NormalAction {

public class SetRecording extends ToggleAction

{

public SetRecording() {

setName("Set Recording");

setCategory("OBS");

setVisibilityInServerSettingsPane(false);

setAuthor("rnayabed");

setVersion(new Version(1, 0, 0));

setVersion(MotherConnection.VERSION);

states = new ArrayList<>();

states.add("Start");

states.add("Stop");

}

private ArrayList<String> states;

@Override

public void initProperties() throws Exception {

public void onToggleOn() throws Exception

{

Property recordingStatusProperty = new Property("recording_status", Type.LIST);

onClicked(true);

recordingStatusProperty.setListValue(states);

recordingStatusProperty.setDisplayName("Recording State");

addClientProperties(recordingStatusProperty);

}

@Override

public void initAction() throws Exception {

public void onToggleOff() throws Exception

// TODO Auto-generated method stub

{

onClicked(false);

}

@Override

public void onActionClicked() throws Exception {

public void initProperties() throws Exception

// TODO Auto-generated method stub

{

Property autoConnectProperty = new Property("auto_connect", Type.BOOLEAN);

autoConnectProperty.setDefaultValueBoolean(true);

autoConnectProperty.setDisplayName("Auto Connect if not connected");

OBSRemoteController controller = MotherConnection.getRemoteController();

addClientProperties(autoConnectProperty);

}

if (controller == null) {

public void onClicked(boolean record) throws MinorException

new StreamPiAlert("Is OBS Connected?",

{

"It seems there is no connection to OBS, please connect it in Settings", StreamPiAlertType.WARNING)

if (MotherConnection.getRemoteController() == null)

.show();

{

} else {

boolean autoConnect = getClientProperties().getSingleProperty(

"auto_connect"

String state = states.get(getClientProperties().getSingleProperty("recording_status").getSelectedIndex());

).getBoolValue();

if(state.equals("Start"))

if(autoConnect)

{

controller.startRecording(MotherConnection.getDefaultCallBack("Failed to Start Recording","Failed to do that"));

MotherConnection.connect(()->setRecording(record));

}

else if(state.equals("Stop"))

else

{

controller.stopRecording(MotherConnection.getDefaultCallBack("Failed to Stop Recording","Failed to do that"));

MotherConnection.showOBSNotRunningError();

}

else

{

setRecording(record);

}

@Override

public void setRecording(boolean recording)

public void onShutDown() throws Exception {

{

// TODO Auto-generated method stub

if(recording)

{

MotherConnection.getRemoteController().startRecording(setRecordingResponse -> {

String status = setRecordingResponse.getStatus();

String error = setRecordingResponse.getError();

errorHandler(status, error);

});

}

else

{

MotherConnection.getRemoteController().stopRecording(setRecordingResponse -> {

String status = setRecordingResponse.getStatus();

String error = setRecordingResponse.getError();

errorHandler(status, error);

});

}

private void errorHandler(String status, String error)

{

if(status.equals("error"))

{

new StreamPiAlert("OBS",error, StreamPiAlertType.ERROR).show();

}

Public

essential-actions

Clone or download

[OBS] Updated Mother, SetCurrentProfile, SetCurrentScene, SetCurrentTransition, SetMute, SetRecording, SetPreviewScene according to 2.0.0

Modified Files