#영상 스트리밍06 - 영상 플레이

0. 사용자 구독상태 체크, 확인후 사용자 정보 반환 1. 사용자정보를 검증(userId, userKey, contentId) 2. 인코딩 서버에서 저장된 userKey와 비교해서 일치할 경우 라이센스 키를 발급 3. Shaka Player에 발급받은 라이센스 키로 drm setting을 하고 다시 S3서버에 mpd파일요청 4. S3서버 mpd 파일 반환 5. Shaka Player는 영상을 복호화하여 재생

// 비디오 재생 버튼 클릭 이벤트 리스너 추가 document.querySelector('.playButton').addEventListener('click', function (event) { event.preventDefault(); // 앵커 태그의 기본 동작을 막습니다. const contentId = this.dataset.contentid; const filename = this.dataset.filename; // 여기서 구독 체크를 하고 사용자의 정보를 반환한다. fetch(`http://localhost:8080/api/check-subscription/${contentId}`, { method: 'GET', headers: { 'Content-Type': 'application/json' } }) .then(response => response.json()) .then(data => { if (data.response.isSubscribed) { if (filename) { const s3BaseUrl = 'https://ohflix-bucket.s3.ap-northeast-2.amazonaws.com/'; const videoUrl = `${s3BaseUrl}${filename}`; // 반환받은 사용자 정보로 라이센스 키와 영상을 요청한다. loadEncryptedVideo(data.response); } else { alert('동영상이 아직 업로드 되지 않았습니다.'); } } else { const userConfirmed = confirm('구독 후에 이용할 수 있습니다. 결제 페이지로 이동하시겠습니까?'); if (userConfirmed) { window.location.href = '/api/paymethod-form'; // 결제 페이지 URL로 변경 } } }) .catch(error => { console.error('Error:', error); alert('서버와 통신 중 오류가 발생했습니다.'); }); }); }) .catch(error => { modalData.innerText = 'Error loading data'; console.error('Error:', error); });

package com.project.ohflix.domain.user; import com.project.ohflix._core.utils.ApiUtil; import jakarta.servlet.http.HttpSession; import lombok.RequiredArgsConstructor; import org.springframework.http.ResponseEntity; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RestController; @RequiredArgsConstructor @RestController public class UserApiController { private final UserService userService; // 구독 여부체크 @GetMapping("/api/check-subscription/{contentId}") public ResponseEntity<?> checkSubscription(@PathVariable Integer contentId, HttpSession session) { SessionUser sessionUser = (SessionUser) session.getAttribute("sessionUser"); SessionUser sessionAdmin = (SessionUser) session.getAttribute("sessionAdmin"); Integer userId = null; if (sessionAdmin != null) { userId = sessionAdmin.getId(); } if (sessionUser != null) { userId = sessionUser.getId(); } // 회색 로직은 여기서 중요하지 않으니 일단 색을 빼겠다. // 구독 체크에는 사용자 ID랑 영상 ID만 넘어가면 된다. UserResponse.IsSubscribed respDTO = userService.checkSubscription(userId, contentId); return ResponseEntity.ok(new ApiUtil<>(respDTO)); }

// 사용자 구독 여부 체크 public UserResponse.IsSubscribed checkSubscription(Integer userId, Integer contentId) { User user = userRepository.findById(userId) .orElseThrow(() -> new Exception404("사용자를 찾을 수 없습니다.")); Content content = contentRepository.findById(contentId).orElseThrow(() -> new Exception404("영상을 찾을 수 없습니다.")); return new UserResponse.IsSubscribed(user, content); }

public class UserResponse { @Data public static class IsSubscribed { private Integer userId; private Integer contentId; private String userKey; private String videoPath; private Boolean isSubscribed; public IsSubscribed(User user, Content content) { this.userId = user.getId(); this.contentId = content.getId(); this.userKey = user.getUserKey(); this.videoPath = content.getVideoPath(); this.isSubscribed = user.getIsSubscribe(); } } }

// 사용자 검증후 라이센스 발급 @PostMapping("/get-license") public ResponseEntity<?> getVideo(@RequestBody @Valid KeyRequest.GetVideoDTO reqDTO, Error error) throws Exception { KeyResponse.LicenseKey respDTO = keyService.getLisence(reqDTO); return ResponseEntity.ok(new ApiUtil<>(respDTO)); }

@RequiredArgsConstructor @Service public class KeyService { private final KeyRepository keyRepository; @Value("${content.contentKey}") private String contentKey; @Value("${content.keyId}") private String keyId; public KeyResponse.LicenseKey getLisence(KeyRequest.GetVideoDTO reqDTO) { Key storedKey = keyRepository.findById(reqDTO.getUserId()).orElse(null); if (storedKey != null && storedKey.getUserKey().equals(reqDTO.getUserKey())){ return new KeyResponse.LicenseKey(keyId, contentKey); } else { throw new RuntimeException("Invalid user key"); } }

public class KeyResponse { @Data public static class LicenseKey { private String keyId; private String contentKey; public LicenseKey(String keyId, String contentKey) { this.keyId = keyId; this.contentKey = contentKey; } }