Create OBSController, OBSWebSocketService, WebSocketConfig

Author: GravityDarkLab

src/main/java/com/gravitylab/obscontrollerapi/config/WebSocketConfig.java

@@ -0,0 +1,21 @@
+package com.gravitylab.obscontrollerapi.config;
+
+import java.net.URI;
+import java.net.URISyntaxException;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import com.gravitylab.obscontrollerapi.websocket.OBSWebSocketClient;
+
+@Configuration
+public class WebSocketConfig {
+	private final static String WS = "ws://";
+	private final static String DEFAULT_IP_ADDRESS = "localhost";
+	private final static int DEFAULT_PORT = 4444;
+
+	@Bean
+	public OBSWebSocketClient obsWebSocketClient() throws URISyntaxException {
+		return new OBSWebSocketClient(new URI(WS + DEFAULT_IP_ADDRESS + ":" + DEFAULT_PORT));
+	}
+}

src/main/java/com/gravitylab/obscontrollerapi/controller/OBSController.java

@@ -0,0 +1,57 @@
+package com.gravitylab.obscontrollerapi.controller;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.gravitylab.obscontrollerapi.service.OBSWebSocketService;
+
+import lombok.extern.slf4j.Slf4j;
+
+@RestController
+@RequestMapping("/obs")
+@Slf4j
+public class OBSController {
+
+	private final OBSWebSocketService obsWebSocketService;
+
+	@Autowired
+	public OBSController(OBSWebSocketService obsWebSocketService) {
+		this.obsWebSocketService = obsWebSocketService;
+	}
+
+	@PostMapping("/authenticate")
+	public ResponseEntity<?> authenticate() {
+		this.obsWebSocketService.authenticate();
+		return ResponseEntity.ok().build();
+	}
+
+	@PostMapping("/reconnect")
+	public ResponseEntity<?> reconnect() {
+		this.obsWebSocketService.reconnect();
+		return ResponseEntity.ok().build();
+	}
+
+	@PostMapping("disconnect")
+	public ResponseEntity<?> disconnect() {
+		obsWebSocketService.disconnect();
+		return ResponseEntity.ok().build();
+	}
+
+	@PostMapping("/startRecording")
+	public ResponseEntity<?> startRecording() {
+		// Call service method to start recording
+		this.obsWebSocketService.startRecording();
+		return ResponseEntity.ok().build();
+	}
+
+	@PostMapping("/stopRecording")
+	public ResponseEntity<?> stopRecording() {
+		// Call service method to stop recording
+		obsWebSocketService.stopRecording();
+		return ResponseEntity.ok().build();
+	}
+
+}

src/main/java/com/gravitylab/obscontrollerapi/obswebsocket/package-info.java

@@ -0,0 +1,40 @@
+package com.gravitylab.obscontrollerapi.service;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.gravitylab.obscontrollerapi.websocket.OBSWebSocketClient;
+
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+@Service
+public class OBSWebSocketService {
+	private final OBSWebSocketClient obsWebSocketClient;
+
+	@Autowired
+	public OBSWebSocketService(OBSWebSocketClient obsWebSocketClient) {
+		this.obsWebSocketClient = obsWebSocketClient;
+		obsWebSocketClient.connect();
+	}
+
+	public void authenticate() {
+		obsWebSocketClient.authenticate();
+	}
+
+	public void disconnect() {
+		obsWebSocketClient.close();
+	}
+
+	public void startRecording() {
+		this.obsWebSocketClient.startRecording();
+	}
+
+	public void stopRecording() {
+		this.obsWebSocketClient.stopRecording();
+	}
+
+	public void reconnect() {
+		obsWebSocketClient.reconnect();
+	}
+}

src/main/java/com/gravitylab/obscontrollerapi/package-info.java

@@ -1 +1,2 @@
-
+obs.websocket.uri=ws://localhost:4444
+obs.websocket.password=secret