Skip to content
Open
Original file line number Diff line number Diff line change
Expand Up @@ -363,10 +363,9 @@ private void startLiveEvent(String liveEventName) {
@Override
public String triggerProcessingStep1(CaptureSessionDTO captureSession, String captureSessionNoHyphen,
UUID recordingId) {
if (!azureIngestStorageService.doesValidAssetExist(captureSession.getBookingId().toString())) {
log.info("No valid asset files found for capture session [{}] in container named [{}]",
captureSession.getId(),
captureSession.getBookingId().toString()
if (!checkLiveFeedAvailable(captureSession.getId())) {
log.info("No valid recording content found for capture session [{}] in Mediakind",
captureSession.getId()
);
azureIngestStorageService.markContainerAsSafeToDelete(captureSession.getBookingId().toString());
return null;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,6 @@

@Service
public class AzureIngestStorageService extends AzureStorageService {
private static final String BLOB_GC_STATE = "gc_state";
private static final String TAG_KEY_STATUS = "status";
private static final String TAG_VALUE_PROCESSING = "processing";
private static final String TAG_VALUE_SAFE_TO_DELETE = "safe_to_delete";
Expand All @@ -17,10 +16,6 @@ public AzureIngestStorageService(BlobServiceClient ingestStorageClient, AzureCon
super(ingestStorageClient, azureConfiguration);
}

public boolean doesValidAssetExist(String containerName) {
return doesIsmFileExist(containerName) || doesBlobExist(containerName, BLOB_GC_STATE);
}

public void markContainerAsProcessing(String containerName) {
tagAllBlobsInContainer(containerName, TAG_KEY_STATUS, TAG_VALUE_PROCESSING);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -889,7 +889,7 @@ void checkStreamCaptureSessionIsmFileExists() throws Exception {

@Test
@DisplayName("Should return 200 with updated capture session when streaming path exists")
void checkStreamCaptureSessionGcStateExists() throws Exception {
void checkStreamCaptureSessionStreamingPathExists() throws Exception {
var dto = new CaptureSessionDTO();
dto.setId(UUID.randomUUID());
dto.setStatus(RecordingStatus.STANDBY);
Expand Down
Loading
Loading