feat(stream): add streaming endpoint and indicator

src/main/java/com/ddf/vodsystem/controllers/StreamController.java

@@ -1,6 +1,7 @@
 package com.ddf.vodsystem.controllers;
 
 import com.ddf.vodsystem.controllers.dto.ClipSectionRequest;
+import com.ddf.vodsystem.controllers.dto.StreamResponse;
 import com.ddf.vodsystem.dto.APIResponse;
 import com.ddf.vodsystem.controllers.dto.SaveSectionRequest;
 import com.ddf.vodsystem.entities.Stream;
@@ -12,6 +13,7 @@ import org.springframework.web.bind.annotation.*;
 
 import java.io.IOException;
 import java.util.List;
+import java.util.Optional;
 
 @RestController
 @RequestMapping("/api/v1/stream")
@@ -66,4 +68,14 @@ public class StreamController {
         List<Stream> history = streamService.getStreamHistory(userId);
         return ResponseEntity.ok(new APIResponse<>("success", "Stream history retrieved", history));
     }
+
+    @GetMapping("/current")
+    public ResponseEntity<APIResponse<StreamResponse>> getCurrentStream() {
+        Optional<Stream> stream = streamService.getActiveStream();
+        return stream.map(value -> ResponseEntity.ok(new APIResponse<>("success",
+                "Streaming status retrieved",
+                new StreamResponse(true, value.getId())))).orElseGet(() -> ResponseEntity.ok(new APIResponse<>("success",
+                "Streaming status retrieved",
+                new StreamResponse(false, null))));
+    }
 }

src/main/java/com/ddf/vodsystem/controllers/dto/StreamResponse.java

@@ -0,0 +1,7 @@
+package com.ddf.vodsystem.controllers.dto;
+
+public record StreamResponse(
+        boolean isStreaming,
+        Long id
+) {
+}

src/main/java/com/ddf/vodsystem/services/StreamService.java

@@ -85,9 +85,14 @@ public class StreamService {
         streamRepository.saveAndFlush(stream);
     }
 
-    public Optional<Stream> getActiveStream(String streamKey) {
-        User user = resolveUser(streamKey);
-        return streamRepository.findByUserAndEndDateIsNull(user);
+    public Optional<Stream> getActiveStream() {
+        Optional<User> user = userService.getLoggedInUser();
+
+        if (user.isEmpty()) {
+            throw new NotAuthenticated("Log in to see user streams");
+        }
+
+        return streamRepository.findByUserAndEndDateIsNull(user.get());
     }
 
     public List<Stream> getStreamHistory(Long userId) {

src/main/java/com/ddf/vodsystem/services/UserService.java

@@ -28,7 +28,6 @@ public class UserService {
     private final UserRepository userRepository;
     private final JwtService jwtService;
 
-
     public UserService(UserRepository userRepository,
                        JwtService jwtService,
                        @Value("${google.client.id}") String googleClientId) {