iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Now using mode

Browse Source
This commit is contained in:
bskjon 2025-02-23 18:53:11 +01:00
parent 9df446b2b3
commit cec4e2aca2
1 changed files with 15 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/controller/RequestEventController.kt
View File

@ -21,57 +21,51 @@ class RequestEventController(@Autowired var coordinator: Coordinator) {
@PostMapping("/convert") @PostMapping("/convert")
@ResponseStatus(HttpStatus.OK) @ResponseStatus(HttpStatus.OK)
fun requestConvert(@RequestBody payload: String): ResponseEntity<String> { fun requestConvert(@RequestBody payload: EventRequest): ResponseEntity<String> {
var convert: EventRequest? = null
var referenceId: String? var referenceId: String?
try { try {
convert = Gson().fromJson(payload, EventRequest::class.java) val file = File(payload.file)
val file = File(convert.file)
if (!file.exists()) { if (!file.exists()) {
return ResponseEntity.status(HttpStatus.NO_CONTENT).body(convert.file) return ResponseEntity.status(HttpStatus.NO_CONTENT).body(payload.file)
} }
referenceId = coordinator.startProcess(file, ProcessType.FLOW, listOf(OperationEvents.CONVERT)).toString() referenceId = coordinator.startProcess(file, payload.mode, listOf(OperationEvents.CONVERT)).toString()
} catch (e: Exception) { } catch (e: Exception) {
return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(Gson().toJson(convert)) return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(Gson().toJson(payload))
} }
return ResponseEntity.ok(referenceId) return ResponseEntity.ok(referenceId)
} }
@PostMapping("/extract") @PostMapping("/extract")
@ResponseStatus(HttpStatus.OK) @ResponseStatus(HttpStatus.OK)
fun requestExtract(@RequestBody payload: String): ResponseEntity<String> { fun requestExtract(@RequestBody payload: EventRequest): ResponseEntity<String> {
var request: EventRequest? = null
var referenceId: String? var referenceId: String?
try { try {
request = Gson().fromJson(payload, EventRequest::class.java) val file = File(payload.file)
val file = File(request.file)
if (!file.exists()) { if (!file.exists()) {
return ResponseEntity.status(HttpStatus.NO_CONTENT).body(payload) return ResponseEntity.status(HttpStatus.NO_CONTENT).body(Gson().toJson(payload))
} }
referenceId = coordinator.startProcess(file, ProcessType.MANUAL, listOf(OperationEvents.EXTRACT)).toString() referenceId = coordinator.startProcess(file, payload.mode, listOf(OperationEvents.EXTRACT)).toString()
} catch (e: Exception) { } catch (e: Exception) {
return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(payload) return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(Gson().toJson(payload))
} }
return ResponseEntity.ok(referenceId) return ResponseEntity.ok(referenceId)
} }
@PostMapping("/all") @PostMapping("/all")
@ResponseStatus(HttpStatus.OK) @ResponseStatus(HttpStatus.OK)
fun requestAll(@RequestBody payload: String): ResponseEntity<String> { fun requestAll(@RequestBody payload: EventRequest): ResponseEntity<String> {
var request: EventRequest? = null
var referenceId: String? var referenceId: String?
try { try {
request = Gson().fromJson(payload, EventRequest::class.java) val file = File(payload.file)
val file = File(request.file)
if (!file.exists()) { if (!file.exists()) {
return ResponseEntity.status(HttpStatus.NO_CONTENT).body(payload) return ResponseEntity.status(HttpStatus.NO_CONTENT).body(payload.file)
} }
referenceId = coordinator.startProcess(file, type = ProcessType.MANUAL).toString() referenceId = coordinator.startProcess(file, type = payload.mode).toString()
} catch (e: Exception) { } catch (e: Exception) {
return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(payload) return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(Gson().toJson(payload))
} }
return ResponseEntity.ok(referenceId) return ResponseEntity.ok(referenceId)
} }