rdkartono/AAS_NewGeneration
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

commit 11/12/2025

Browse Source
This commit is contained in:
rdkartono
2025-12-11 08:21:39 +07:00
parent cbca8cd43d
commit bdb24a7c03
5 changed files with 66 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
src/web/WebApp.kt
View File

@@ -45,6 +45,8 @@ import codes.configKeys
import config
import database.QueueTable
import google.GoogleTTS
import google.autoadd
import google.fileoperation
import io.javalin.websocket.WsCloseStatus
import org.tinylog.Logger
import java.io.File
@@ -210,10 +212,13 @@ class WebApp(val listenPort: Int, var userlist: List<Pair<String, String>>, val
val languagecode = js.get("languagecode")?.asText("id-ID") ?: "id-ID"
val databasesource = js.get("databasesource")?.asText("VOICE_1") ?: "VOICE_1"
val targetas = js.get("targetas")?.asText("VOICE_2") ?: "VOICE_2"
val fileoperation = js.get("fileoperation")?.asText("overwrite") ?: "overwrite"
val autoadd = js.get("autoadd")?.asText("add") ?: "add"
val fop = js.get("fileoperation")?.asText("overwrite") ?: "overwrite"
val aa = js.get("autoadd")?.asText("add") ?: "add"
Logger.info {"Starting TTS Soundbank Generation, VoiceType=$voicetype, Language"}
ttsjob.GenerateSoundbank(voicetype, languagecode, databasesource, targetas, fileoperation, autoadd){ progress, message ->
ttsjob.GenerateSoundbank(voicetype, Language.from_GoogleTTSLanguage(languagecode),
VoiceType.fromString(databasesource),
VoiceType.fromString(targetas), fileoperation.fromString(fop),
autoadd.fromString(aa)){ progress, message ->
SendReply(wsMessageContext, "tts_generate_progress", objectmapper.writeValueAsString(
mapOf(
"progress" to progress,
@@ -427,7 +432,7 @@ class WebApp(val listenPort: Int, var userlist: List<Pair<String, String>>, val
val key = ctx.cookie("client-stream-id")
if (command == "Open"){
// open command
if (key!=null && key.isNotEmpty()){
if (!key.isNullOrEmpty()){
// ada connection sebelumnya, kemungkinan reconnect
val prev = WsContextMap[key]
if (prev!=null){
@@ -445,7 +450,7 @@ class WebApp(val listenPort: Int, var userlist: List<Pair<String, String>>, val
} else {
// close command
if (key!=null && key.isNotEmpty()){
if (!key.isNullOrEmpty()){
// close connection
val prev = WsContextMap[key]
if (prev!=null){
@@ -465,7 +470,7 @@ class WebApp(val listenPort: Int, var userlist: List<Pair<String, String>>, val
ws("ws"){ wscontext ->
wscontext.onConnect {
val key = it.cookie("client-stream-id")
if (key!=null && key.isNotEmpty()){
if (!key.isNullOrEmpty()){
val lld = WsContextMap[key]
if (lld!=null){
it.enableAutomaticPings()
@@ -490,7 +495,7 @@ class WebApp(val listenPort: Int, var userlist: List<Pair<String, String>>, val
}
wscontext.onClose {
val key = it.cookie("client-stream-id")
if (key!=null && key.isNotEmpty()){
if (!key.isNullOrEmpty()){
val lld = WsContextMap[key]
lld?.bc?.Remove_Mp3_Consumer(key)
lld?.ws?.closeSession()
@@ -731,7 +736,7 @@ class WebApp(val listenPort: Int, var userlist: List<Pair<String, String>>, val
.result(objectmapper.writeValueAsString(resultMessage("Failed to update soundbank with index $index")))
} else it.status(400)
.result(objectmapper.writeValueAsString(resultMessage("Nothing has changed for soundbank with index $index")))
} else Exception("Some fields are empty")
}
} catch (e: Exception) {
it.status(400)
.result(objectmapper.writeValueAsString(resultMessage("Unable to parse request body to Soundbank, Message: ${e.message}")))