Branding Change
This commit is contained in:
1 parent
3d1316bd07
commit
ce11e4846e
4 files changed
+683
-330
No files matched your search
@@ -19,22 +19,43 @@ from modules.logging_colors import logger
|
||||
from modules.ui import create_refresh_button
|
||||
from modules.utils import gradio
|
||||
|
||||
#Required for sentence splitting
|
||||
##############################################################
|
||||
#### LOAD PARAMS FROM CONFIG.JSON - REQUIRED FOR BRANDING ####
|
||||
##############################################################
|
||||
# STARTUP VARIABLE - Create "this_dir" variable as the current script directory
|
||||
this_dir = Path(__file__).parent.resolve()
|
||||
|
||||
|
||||
# load config file in and get settings
|
||||
def load_config(file_path):
|
||||
with open(file_path, "r") as config_file:
|
||||
config = json.load(config_file)
|
||||
return config
|
||||
|
||||
|
||||
config_file_path = this_dir / "config.json"
|
||||
params = load_config(config_file_path)
|
||||
|
||||
|
||||
# Required for sentence splitting
|
||||
try:
|
||||
from TTS.api import TTS
|
||||
from TTS.utils.synthesizer import Synthesizer
|
||||
except ModuleNotFoundError:
|
||||
logger.error(
|
||||
"[CoquiTTS Startup] \033[91mWarning\033[0m Could not find the TTS module. Make sure to install the requirements for the coqui_tts extension."
|
||||
"[CoquiTTS Startup] \033[91mWarning\033[0m Linux / Mac:\npip install -r extensions/coqui_tts/requirements.txt\n"
|
||||
"[CoquiTTS Startup] \033[91mWarning\033[0m Windows:\npip install -r extensions\\coqui_tts\\requirements.txt\n"
|
||||
"[CoquiTTS Startup] \033[91mWarning\033[0m If you used the one-click installer, paste the command above in the terminal window launched after running the \"cmd_\" script. On Windows, that's \"cmd_windows.bat\"."
|
||||
"[params['branding']]\033[91mWarning\033[0m Could not find the TTS module. Make sure to install the requirements for the "
|
||||
+ params["branding"]
|
||||
+ " extension."
|
||||
"[params['branding']]\033[91mWarning\033[0m Linux / Mac:\npip install -r extensions/alltalk_tts/requirements.txt\n"
|
||||
"[params['branding']]\033[91mWarning\033[0m Windows:\npip install -r extensions\\alltalk_tts\\requirements.txt\n"
|
||||
"[params['branding']]\033[91mWarning\033[0m If you used the one-click installer, paste the command above in the terminal window launched after running the cmd_ script. On Windows, that's cmd_windows.bat."
|
||||
)
|
||||
raise
|
||||
|
||||
#IMPORT - Attempt Importing DeepSpeed
|
||||
# IMPORT - Attempt Importing DeepSpeed
|
||||
try:
|
||||
import deepspeed
|
||||
|
||||
deepspeed_installed = True
|
||||
except ImportError:
|
||||
deepspeed_installed = False
|
||||
@@ -42,41 +63,36 @@ except ImportError:
|
||||
###########################
|
||||
#### STARTUP VARIABLES ####
|
||||
###########################
|
||||
#STARTUP VARIABLE - Create "this_dir" variable as the current script directory
|
||||
this_dir = Path(__file__).parent.resolve()
|
||||
#STARTUP VARIABLE - Import languges file for Gradio to be able to display them in the interface
|
||||
with open(this_dir / 'languages.json', encoding='utf8') as f:
|
||||
# STARTUP VARIABLE - Import languges file for Gradio to be able to display them in the interface
|
||||
with open(this_dir / "languages.json", encoding="utf8") as f:
|
||||
languages = json.load(f)
|
||||
# Create a global lock
|
||||
process_lock = threading.Lock()
|
||||
|
||||
#######################################
|
||||
#### LOAD PARAMS FROM CONFIG.JSON ####
|
||||
#######################################
|
||||
def load_config(file_path):
|
||||
with open(file_path, 'r') as config_file:
|
||||
config = json.load(config_file)
|
||||
return config
|
||||
|
||||
config_file_path = (this_dir / 'config.json')
|
||||
params = load_config(config_file_path)
|
||||
|
||||
def get_available_voices():
|
||||
return sorted([voice.name for voice in Path(f"{this_dir}/voices").glob("*.wav")])
|
||||
|
||||
|
||||
#########################
|
||||
#### LICENSE DISPLAY ####
|
||||
#########################
|
||||
#STARTUP Display Licence Information
|
||||
print("[CoquiTTS Startup] \033[94mCoqui Public Model License\033[0m")
|
||||
print("[CoquiTTS Startup] \033[94mhttps://coqui.ai/cpml.txt\033[0m")
|
||||
# STARTUP Display Licence Information
|
||||
print("[" + params["branding"] + "Startup] \033[94mCoqui Public Model License\033[0m")
|
||||
print("[" + params["branding"] + "Startup] \033[94mhttps://coqui.ai/cpml.txt\033[0m")
|
||||
|
||||
|
||||
############################################
|
||||
#### DELETE OLD OUTPUT WAV FILES IF SET ####
|
||||
############################################
|
||||
def delete_old_files(folder_path, days_to_keep):
|
||||
current_time = datetime.now()
|
||||
print("[CoquiTTS Startup] Deletion of old output folder WAV files is currently enabled and set at", delete_output_wavs_setting)
|
||||
print(
|
||||
"["
|
||||
+ params["branding"]
|
||||
+ "Startup] Deletion of old output folder WAV files is currently enabled and set at",
|
||||
delete_output_wavs_setting,
|
||||
)
|
||||
for file_name in os.listdir(folder_path):
|
||||
file_path = os.path.join(folder_path, file_name)
|
||||
if os.path.isfile(file_path):
|
||||
@@ -85,6 +101,7 @@ def delete_old_files(folder_path, days_to_keep):
|
||||
if age > timedelta(days=days_to_keep):
|
||||
os.remove(file_path)
|
||||
|
||||
|
||||
# Extract settings using params dictionary
|
||||
delete_output_wavs_setting = params["delete_output_wavs"]
|
||||
output_folder_wav = params["output_folder_wav"]
|
||||
@@ -92,25 +109,33 @@ output_folder_wav = os.path.normpath(output_folder_wav)
|
||||
|
||||
# Check and perform file deletion
|
||||
if delete_output_wavs_setting.lower() == "disabled":
|
||||
print("[CoquiTTS Startup] Old output wav file deletion is set to disabled.")
|
||||
print(
|
||||
"["
|
||||
+ params["branding"]
|
||||
+ "Startup] Old output wav file deletion is set to disabled."
|
||||
)
|
||||
else:
|
||||
try:
|
||||
days_to_keep = int(delete_output_wavs_setting.split()[0])
|
||||
delete_old_files(output_folder_wav, days_to_keep)
|
||||
except ValueError:
|
||||
print("[CoquiTTS Startup] Invalid setting for deleting old wav files. Please use 'Disabled' or 'X Days' format.")
|
||||
print(
|
||||
f"[{params['branding']}Startup] Invalid setting for deleting old wav files. Please use 'Disabled' or 'X Days' format."
|
||||
)
|
||||
|
||||
|
||||
########################
|
||||
#### STARTUP CHECKS ####
|
||||
########################
|
||||
#STARTUP Checks routine
|
||||
# STARTUP Checks routine
|
||||
def check_required_files():
|
||||
this_dir = Path(__file__).parent.resolve()
|
||||
download_script_path = this_dir / 'modeldownload.py'
|
||||
subprocess.run(['python', str(download_script_path)])
|
||||
print("[CoquiTTS Startup] All required files are present.")
|
||||
download_script_path = this_dir / "modeldownload.py"
|
||||
subprocess.run(["python", str(download_script_path)])
|
||||
print(f"[{params['branding']}Startup] All required files are present.")
|
||||
|
||||
#STARTUP Call Check routine
|
||||
|
||||
# STARTUP Call Check routine
|
||||
check_required_files()
|
||||
|
||||
#################################################
|
||||
@@ -124,72 +149,102 @@ elif params["tts_method_api_local"] == True:
|
||||
elif params["tts_method_xtts_local"] == True:
|
||||
gr_modelchoice = "XTTSv2 Local"
|
||||
|
||||
|
||||
######################
|
||||
#### GRADIO STUFF ####
|
||||
######################
|
||||
def remove_tts_from_history(history):
|
||||
for i, entry in enumerate(history['internal']):
|
||||
history['visible'][i] = [history['visible'][i][0], entry[1]]
|
||||
for i, entry in enumerate(history["internal"]):
|
||||
history["visible"][i] = [history["visible"][i][0], entry[1]]
|
||||
return history
|
||||
|
||||
|
||||
def toggle_text_in_history(history):
|
||||
for i, entry in enumerate(history['visible']):
|
||||
for i, entry in enumerate(history["visible"]):
|
||||
visible_reply = entry[1]
|
||||
if visible_reply.startswith('<audio'):
|
||||
if params['show_text']:
|
||||
reply = history['internal'][i][1]
|
||||
history['visible'][i] = [history['visible'][i][0], f"{visible_reply.split('</audio>')[0]}</audio>\n\n{reply}"]
|
||||
if visible_reply.startswith("<audio"):
|
||||
if params["show_text"]:
|
||||
reply = history["internal"][i][1]
|
||||
history["visible"][i] = [
|
||||
history["visible"][i][0],
|
||||
f"{visible_reply.split('</audio>')[0]}</audio>\n\n{reply}",
|
||||
]
|
||||
else:
|
||||
history['visible'][i] = [history['visible'][i][0], f"{visible_reply.split('</audio>')[0]}</audio>"]
|
||||
history["visible"][i] = [
|
||||
history["visible"][i][0],
|
||||
f"{visible_reply.split('</audio>')[0]}</audio>",
|
||||
]
|
||||
return history
|
||||
|
||||
|
||||
def history_modifier(history):
|
||||
# Remove autoplay from the last reply
|
||||
if len(history['internal']) > 0:
|
||||
history['visible'][-1] = [
|
||||
history['visible'][-1][0],
|
||||
history['visible'][-1][1].replace('controls autoplay>', 'controls>')
|
||||
if len(history["internal"]) > 0:
|
||||
history["visible"][-1] = [
|
||||
history["visible"][-1][0],
|
||||
history["visible"][-1][1].replace("controls autoplay>", "controls>"),
|
||||
]
|
||||
|
||||
return history
|
||||
|
||||
|
||||
######################################
|
||||
#### SUBPROCESS/WEBSERVER STARTUP ####
|
||||
######################################
|
||||
base_url = f"http://{params['ip_address']}:{params['port_number']}"
|
||||
script_path = this_dir / 'tts_server.py'
|
||||
script_path = this_dir / "tts_server.py"
|
||||
|
||||
|
||||
def signal_handler(sig, frame):
|
||||
print("[CoquiTTS Shutdown] \033[94mReceived Ctrl+C, terminating subprocess\033[92m")
|
||||
print(
|
||||
f"[{params['branding']}Shutdown] \033[94mReceived Ctrl+C, terminating subprocess\033[92m"
|
||||
)
|
||||
if process.poll() is None:
|
||||
process.terminate()
|
||||
process.wait() # Wait for the subprocess to finish
|
||||
sys.exit(0)
|
||||
|
||||
|
||||
# Attach the signal handler to the SIGINT signal (Ctrl+C)
|
||||
signal.signal(signal.SIGINT, signal_handler)
|
||||
|
||||
# Start the subprocess
|
||||
process = subprocess.Popen(['python', script_path])
|
||||
process = subprocess.Popen(["python", script_path])
|
||||
|
||||
# Check if the subprocess has started successfully
|
||||
if process.poll() is None:
|
||||
print("[CoquiTTS Startup] TTS Subprocess starting")
|
||||
print("[CoquiTTS Startup] Readme available here:", f"http://{params['ip_address']}:{params['port_number']}")
|
||||
print(f"[{params['branding']}Startup] TTS Subprocess starting")
|
||||
print(
|
||||
f"[{params['branding']}Startup] Readme available here:",
|
||||
f"http://{params['ip_address']}:{params['port_number']}",
|
||||
)
|
||||
else:
|
||||
print("[CoquiTTS Startup] \033[91mWarning\033[0m TTS Subprocess Webserver failing to start process")
|
||||
print("[CoquiTTS Startup] \033[91mWarning\033[0m It could be that you have something on port:", params['port_number'])
|
||||
print("[CoquiTTS Startup] \033[91mWarning\033[0m Or you have not started in a Python environement with all the necesssary bits installed")
|
||||
print("[CoquiTTS Startup] \033[91mWarning\033[0m Check you are starting Text-generation-webui with either the start_xxxxx file or the Python environment with cmd_xxxxx file.")
|
||||
print("[CoquiTTS Startup] \033[91mWarning\033[0m xxxxx is the type of OS you are on e.g. windows, linux or mac.")
|
||||
print("[CoquiTTS Startup] \033[91mWarning\033[0m Alternatively, you could check no other Python processes are running that shouldnt be e.g. Restart your computer is the simple way.")
|
||||
#Cleanly kill off this script, but allow text-generation-webui to keep running, albeit without this coquii_tts
|
||||
print(
|
||||
f"[{params['branding']}Startup] \033[91mWarning\033[0m TTS Subprocess Webserver failing to start process"
|
||||
)
|
||||
print(
|
||||
f"[{params['branding']}Startup] \033[91mWarning\033[0m It could be that you have something on port:",
|
||||
params["port_number"],
|
||||
)
|
||||
print(
|
||||
f"[{params['branding']}Startup] \033[91mWarning\033[0m Or you have not started in a Python environement with all the necesssary bits installed"
|
||||
)
|
||||
print(
|
||||
f"[{params['branding']}Startup] \033[91mWarning\033[0m Check you are starting Text-generation-webui with either the start_xxxxx file or the Python environment with cmd_xxxxx file."
|
||||
)
|
||||
print(
|
||||
f"[{params['branding']}Startup] \033[91mWarning\033[0m xxxxx is the type of OS you are on e.g. windows, linux or mac."
|
||||
)
|
||||
print(
|
||||
f"[{params['branding']}Startup] \033[91mWarning\033[0m Alternatively, you could check no other Python processes are running that shouldnt be e.g. Restart your computer is the simple way."
|
||||
)
|
||||
# Cleanly kill off this script, but allow text-generation-webui to keep running, albeit without this alltalk_tts
|
||||
sys.exit(1)
|
||||
|
||||
timeout = 60 # Adjust the timeout as needed
|
||||
|
||||
# Introduce a delay before starting the check loop
|
||||
time.sleep(25) #Wait 25 secs before checking if the tts_server.py has started up.
|
||||
time.sleep(25) # Wait 25 secs before checking if the tts_server.py has started up.
|
||||
start_time = time.time()
|
||||
while time.time() - start_time < timeout:
|
||||
try:
|
||||
@@ -198,17 +253,22 @@ while time.time() - start_time < timeout:
|
||||
break
|
||||
except requests.RequestException as e:
|
||||
# Print the exception for debugging purposes
|
||||
print(f"[CoquiTTS Startup] \033[91mWarning\033[0m TTS Subprocess has NOT started up yet, Will keep trying for 60 seconds maximum")
|
||||
print(
|
||||
f"[{params['branding']}Startup] \033[91mWarning\033[0m TTS Subprocess has NOT started up yet, Will keep trying for 60 seconds maximum"
|
||||
)
|
||||
time.sleep(1)
|
||||
else:
|
||||
print("[CoquiTTS Startup] Startup timed out. Check the server logs for more information.")
|
||||
#Cleanly kill off this script, but allow text-generation-webui to keep running, albeit without this coquii_tts
|
||||
print(
|
||||
f"[{params['branding']}Startup] Startup timed out. Check the server logs for more information."
|
||||
)
|
||||
# Cleanly kill off this script, but allow text-generation-webui to keep running, albeit without this alltalk_tts
|
||||
sys.exit(1)
|
||||
|
||||
|
||||
#####################################
|
||||
#### MODEL LOADING AND UNLOADING ####
|
||||
#####################################
|
||||
#MODEL - Swap model based on Gradio selection API TTS, API Local, XTTSv2 Local
|
||||
# MODEL - Swap model based on Gradio selection API TTS, API Local, XTTSv2 Local
|
||||
def send_reload_request(tts_method):
|
||||
try:
|
||||
params["model_loaded"] = False
|
||||
@@ -224,13 +284,16 @@ def send_reload_request(tts_method):
|
||||
return json_response
|
||||
except requests.exceptions.RequestException as e:
|
||||
# Handle the HTTP request error
|
||||
print(f"[CoquiTTS Server] \033[91mWarning\033[0m Error during request to webserver process: {e}")
|
||||
print(
|
||||
f"[{params['branding']}Server] \033[91mWarning\033[0m Error during request to webserver process: {e}"
|
||||
)
|
||||
return {"status": "error", "message": str(e)}
|
||||
|
||||
|
||||
##################
|
||||
#### LOW VRAM ####
|
||||
##################
|
||||
#LOW VRAM - Gradio Checkbox handling
|
||||
# LOW VRAM - Gradio Checkbox handling
|
||||
def send_lowvram_request(low_vram):
|
||||
try:
|
||||
params["model_loaded"] = False
|
||||
@@ -246,13 +309,16 @@ def send_lowvram_request(low_vram):
|
||||
return json_response
|
||||
except requests.exceptions.RequestException as e:
|
||||
# Handle the HTTP request error
|
||||
print(f"[CoquiTTS Server] \033[91mWarning\033[0m Error during request to webserver process: {e}")
|
||||
print(
|
||||
f"[{params['branding']}Server] \033[91mWarning\033[0m Error during request to webserver process: {e}"
|
||||
)
|
||||
return {"status": "error", "message": str(e)}
|
||||
|
||||
|
||||
###################
|
||||
#### DeepSpeed ####
|
||||
###################
|
||||
#DEEPSPEED - Reload the model when DeepSpeed checkbox is enabled/disabled
|
||||
# DEEPSPEED - Reload the model when DeepSpeed checkbox is enabled/disabled
|
||||
def send_deepspeed_request(deepspeed_param):
|
||||
try:
|
||||
params["model_loaded"] = False
|
||||
@@ -268,54 +334,63 @@ def send_deepspeed_request(deepspeed_param):
|
||||
return json_response
|
||||
except requests.exceptions.RequestException as e:
|
||||
# Handle the HTTP request error
|
||||
print(f"[CoquiTTS Server] \033[91mWarning\033[0m Error during request to webserver process: {e}")
|
||||
print(
|
||||
f"[{params['branding']}Server] \033[91mWarning\033[0m Error during request to webserver process: {e}"
|
||||
)
|
||||
return {"status": "error", "message": str(e)}
|
||||
|
||||
|
||||
# DEEPSPEED - Display DeepSpeed Checkbox Yes or No
|
||||
deepspeed_condition = params["tts_method_xtts_local"] == "True" and deepspeed_installed
|
||||
|
||||
|
||||
########################
|
||||
#### TTS GENERATION ####
|
||||
########################
|
||||
#PREVIEW VOICE - Generate Random Sentence if Voice Preview box is empty
|
||||
# PREVIEW VOICE - Generate Random Sentence if Voice Preview box is empty
|
||||
def random_sentence():
|
||||
with open(Path("extensions/coqui_tts/harvard_sentences.txt")) as f:
|
||||
with open(Path("extensions/alltalk_tts/harvard_sentences.txt")) as f:
|
||||
return random.choice(list(f))
|
||||
|
||||
#PREVIEW VOICE- Generate TTS Function
|
||||
|
||||
# PREVIEW VOICE- Generate TTS Function
|
||||
def voice_preview(string):
|
||||
if not params['activate']:
|
||||
return string
|
||||
if not params["activate"]:
|
||||
return string
|
||||
# Clean the string, capture model not loaded, and move model to cuda if needed
|
||||
cleaned_string = before_audio_generation(string, params)
|
||||
cleaned_string = before_audio_generation(string, params)
|
||||
if cleaned_string is None:
|
||||
return
|
||||
string = cleaned_string
|
||||
return
|
||||
string = cleaned_string
|
||||
# Setup the output file
|
||||
output_file = Path(params["output_folder_wav"]) / "voice_preview.wav"
|
||||
# Generate the audio
|
||||
language_code = languages.get(params["language"])
|
||||
language_code = languages.get(params["language"])
|
||||
# Convert the WindowsPath object to a string before using it in JSON payload
|
||||
output_file_str = output_file.as_posix()
|
||||
output_file_str = output_file.as_posix()
|
||||
# Lock before making the generate request
|
||||
with process_lock:
|
||||
generate_response = send_generate_request(string, params["voice"], language_code, output_file_str)
|
||||
generate_response = send_generate_request(
|
||||
string, params["voice"], language_code, output_file_str
|
||||
)
|
||||
# Check if lock is already acquired
|
||||
if process_lock.locked():
|
||||
print("[CoquiTTS Model] \033[91mWarning\033[0m Audio generation is already in progress. Please wait.")
|
||||
print(
|
||||
f"[{params['branding']}Model] \033[91mWarning\033[0m Audio generation is already in progress. Please wait."
|
||||
)
|
||||
return
|
||||
if generate_response.get("status") == "generate-success":
|
||||
# Handle Gradio and playback
|
||||
autoplay = 'autoplay' if params['autoplay'] else ''
|
||||
autoplay = "autoplay" if params["autoplay"] else ""
|
||||
return f'<audio src="file/{output_file_str}?{int(time.time())}" controls {autoplay}></audio>'
|
||||
else:
|
||||
# Handle the case where audio generation was not successful
|
||||
return f"Audio generation failed. Status: {generate_response.get('status')}"
|
||||
return f"[{params['branding']}Server] Audio generation failed. Status: {generate_response.get('status')}"
|
||||
|
||||
#STANDARD VOICE - Generate TTS Function
|
||||
|
||||
# STANDARD VOICE - Generate TTS Function
|
||||
def output_modifier(string, state):
|
||||
if not params['activate']:
|
||||
if not params["activate"]:
|
||||
return string
|
||||
original_string = string
|
||||
cleaned_string = before_audio_generation(string, params)
|
||||
@@ -323,50 +398,63 @@ def output_modifier(string, state):
|
||||
return
|
||||
string = cleaned_string
|
||||
# Setup the output file
|
||||
output_file = Path(f'{params["output_folder_wav"]}/{state["character_menu"]}_{int(time.time())}.wav')
|
||||
output_file = Path(
|
||||
f'{params["output_folder_wav"]}/{state["character_menu"]}_{int(time.time())}.wav'
|
||||
)
|
||||
# Generate the audio and handle the response
|
||||
language_code = languages.get(params["language"])
|
||||
# Convert the WindowsPath object to a string before using it in JSON payload
|
||||
output_file_str = output_file.as_posix()
|
||||
|
||||
# Lock before making the generate request
|
||||
# Lock before making the generate request
|
||||
with process_lock:
|
||||
generate_response = send_generate_request(string, params["voice"], language_code, output_file_str)
|
||||
|
||||
generate_response = send_generate_request(
|
||||
string, params["voice"], language_code, output_file_str
|
||||
)
|
||||
|
||||
# Check if lock is already acquired
|
||||
if process_lock.locked():
|
||||
print("[CoquiTTS Model] \033[91mWarning\033[0m Audio generation is already in progress. Please wait.")
|
||||
print(
|
||||
f"[{params['branding']}Model] \033[91mWarning\033[0m Audio generation is already in progress. Please wait."
|
||||
)
|
||||
return
|
||||
|
||||
|
||||
if generate_response.get("status") == "generate-success":
|
||||
audio_path = generate_response.get("data", {}).get("audio_path")
|
||||
if audio_path:
|
||||
# Handle Gradio and playback
|
||||
autoplay = 'autoplay' if params['autoplay'] else ''
|
||||
autoplay = "autoplay" if params["autoplay"] else ""
|
||||
string = f'<audio src="file/{audio_path}" controls {autoplay}></audio>'
|
||||
|
||||
if params['show_text']:
|
||||
string += f'\n\n{original_string}'
|
||||
|
||||
if params["show_text"]:
|
||||
string += f"\n\n{original_string}"
|
||||
shared.processing_message = "*Is typing...*"
|
||||
|
||||
|
||||
return string
|
||||
else:
|
||||
print("No audio path in the response.")
|
||||
print(
|
||||
f"[{params['branding']}Server] \033[91mWarning\033[0m No audio path in the response."
|
||||
)
|
||||
else:
|
||||
print("[CoquiTTS Server] \033[91mWarning\033[0m Audio generation failed. Status:", generate_response.get("message"))
|
||||
|
||||
print(
|
||||
f"[{params['branding']}Server] \033[91mWarning\033[0m Audio generation failed. Status:",
|
||||
generate_response.get("message"),
|
||||
)
|
||||
|
||||
|
||||
def send_generate_request(text, voice, language, output_file):
|
||||
url = f"{base_url}/api/generate"
|
||||
payload = {
|
||||
"text": text,
|
||||
"voice": voice,
|
||||
"language": language,
|
||||
"output_file": output_file
|
||||
"output_file": output_file,
|
||||
}
|
||||
headers = {"Content-Type": "application/json"}
|
||||
response = requests.post(url, json=payload, headers=headers)
|
||||
return response.json()
|
||||
|
||||
|
||||
#############################################################
|
||||
#### TTS STRING CLEANING & PROCESSING PRE SENDING TO TTS ####
|
||||
#############################################################
|
||||
@@ -375,12 +463,13 @@ def preprocess(raw_input):
|
||||
# raw_input = raw_input.strip("\"")
|
||||
return raw_input
|
||||
|
||||
|
||||
def new_split_into_sentences(self, text):
|
||||
sentences = self.seg.segment(text)
|
||||
if params['remove_trailing_dots']:
|
||||
if params["remove_trailing_dots"]:
|
||||
sentences_without_dots = []
|
||||
for sentence in sentences:
|
||||
if sentence.endswith('.') and not sentence.endswith('...'):
|
||||
if sentence.endswith(".") and not sentence.endswith("..."):
|
||||
sentence = sentence[:-1]
|
||||
|
||||
sentences_without_dots.append(sentence)
|
||||
@@ -389,104 +478,182 @@ def new_split_into_sentences(self, text):
|
||||
else:
|
||||
return sentences
|
||||
|
||||
|
||||
Synthesizer.split_into_sentences = new_split_into_sentences
|
||||
|
||||
#TTS STRING CLEANING - Clean String before TTS generation (Called from voice_preview and output_modifer)
|
||||
|
||||
# TTS STRING CLEANING - Clean String before TTS generation (Called from voice_preview and output_modifer)
|
||||
def before_audio_generation(string, params):
|
||||
#Check Model is loaded into cuda or cpu and error if not
|
||||
# Check Model is loaded into cuda or cpu and error if not
|
||||
if not params["model_loaded"]:
|
||||
print("[CoquiTTS Model] \033[91mWarning\033[0m Model is still loading, please wait before trying to generate TTS")
|
||||
print(
|
||||
f"[{params['branding']}Model] \033[91mWarning\033[0m Model is still loading, please wait before trying to generate TTS"
|
||||
)
|
||||
return
|
||||
string = html.unescape(string) or random_sentence()
|
||||
# Replace double quotes with single, asterisks, carriage returns, and line feeds
|
||||
string = string.replace('"', "'").replace(".'", "'.").replace('*', '').replace('\r', '').replace('\n', '')
|
||||
if string == '':
|
||||
return '*Empty string*'
|
||||
string = (
|
||||
string.replace('"', "'")
|
||||
.replace(".'", "'.")
|
||||
.replace("*", "")
|
||||
.replace("\r", "")
|
||||
.replace("\n", "")
|
||||
)
|
||||
if string == "":
|
||||
return "*Empty string*"
|
||||
return string
|
||||
|
||||
|
||||
################################
|
||||
#### SUBPORCESS TERMINATION ####
|
||||
################################
|
||||
#Register the termination code to be executed at exit
|
||||
# Register the termination code to be executed at exit
|
||||
atexit.register(lambda: process.terminate() if process.poll() is None else None)
|
||||
|
||||
|
||||
######################
|
||||
#### GRADIO STUFF ####
|
||||
######################
|
||||
def state_modifier(state):
|
||||
if not params['activate']:
|
||||
if not params["activate"]:
|
||||
return state
|
||||
|
||||
state['stream'] = False
|
||||
state["stream"] = False
|
||||
return state
|
||||
|
||||
|
||||
def input_modifier(string, state):
|
||||
if not params['activate']:
|
||||
if not params["activate"]:
|
||||
return string
|
||||
|
||||
shared.processing_message = "*Is recording a voice message...*"
|
||||
return string
|
||||
|
||||
|
||||
def custom_css():
|
||||
path_to_css = Path(f"{this_dir}/style.css")
|
||||
return open(path_to_css, 'r').read()
|
||||
return open(path_to_css, "r").read()
|
||||
|
||||
|
||||
def ui():
|
||||
with gr.Accordion("Coqui TTS (XTTSv2)"):
|
||||
with gr.Accordion(params["branding"] + " TTS (XTTSv2)"):
|
||||
with gr.Row():
|
||||
activate = gr.Checkbox(value=params['activate'], label='Activate TTS')
|
||||
autoplay = gr.Checkbox(value=params['autoplay'], label='Play TTS automatically')
|
||||
activate = gr.Checkbox(value=params["activate"], label="Activate TTS")
|
||||
autoplay = gr.Checkbox(
|
||||
value=params["autoplay"], label="Play TTS automatically"
|
||||
)
|
||||
|
||||
with gr.Row():
|
||||
show_text = gr.Checkbox(value=params['show_text'], label='Show message text under audio player')
|
||||
remove_trailing_dots = gr.Checkbox(value=params['remove_trailing_dots'], label='Remove trailing "." from text segments before generation')
|
||||
|
||||
show_text = gr.Checkbox(
|
||||
value=params["show_text"], label="Show message text under audio player"
|
||||
)
|
||||
remove_trailing_dots = gr.Checkbox(
|
||||
value=params["remove_trailing_dots"],
|
||||
label='Remove trailing "." from text segments before generation',
|
||||
)
|
||||
|
||||
with gr.Row():
|
||||
low_vram = gr.Checkbox(value=params['low_vram'], label='Low VRAM mode (Read NOTE)')
|
||||
deepspeed_checkbox = gr.Checkbox(value=params['deepspeed_activate'], label='Activate DeepSpeed (Read NOTE)', visible=deepspeed_installed)
|
||||
|
||||
low_vram = gr.Checkbox(
|
||||
value=params["low_vram"], label="Low VRAM mode (Read NOTE)"
|
||||
)
|
||||
deepspeed_checkbox = gr.Checkbox(
|
||||
value=params["deepspeed_activate"],
|
||||
label="Activate DeepSpeed (Read NOTE)",
|
||||
visible=deepspeed_installed,
|
||||
)
|
||||
|
||||
with gr.Row():
|
||||
tts_radio_buttons = gr.Radio(
|
||||
choices=["API TTS", "API Local", "XTTSv2 Local"],
|
||||
label="Select TTS Generation Method (Read NOTE)",
|
||||
value=gr_modelchoice # Set the default value
|
||||
choices=["API TTS", "API Local", "XTTSv2 Local"],
|
||||
label="Select TTS Generation Method (Read NOTE)",
|
||||
value=gr_modelchoice, # Set the default value
|
||||
)
|
||||
explanation_text = gr.HTML(f"<p>NOTE: Switching Model Type, Low VRAM & DeepSpeed takes 15 seconds. Each TTS generation method has a slightly different sound. DeepSpeed checkbox is only visible if DeepSpeed is present. Readme & Settings: <a href='http://{params['ip_address']}:{params['port_number']}'>http://{params['ip_address']}:{params['port_number']}</a>")
|
||||
|
||||
explanation_text = gr.HTML(
|
||||
f"<p>NOTE: Switching Model Type, Low VRAM & DeepSpeed takes 15 seconds. Each TTS generation method has a slightly different sound. DeepSpeed checkbox is only visible if DeepSpeed is present. Readme & Settings: <a href='http://{params['ip_address']}:{params['port_number']}'>http://{params['ip_address']}:{params['port_number']}</a>"
|
||||
)
|
||||
|
||||
with gr.Row():
|
||||
with gr.Row():
|
||||
voice = gr.Dropdown(get_available_voices(), label="Voice wav", value=params["voice"])
|
||||
create_refresh_button(voice, lambda: None, lambda: {'choices': get_available_voices(), 'value': params["voice"]}, 'refresh-button')
|
||||
voice = gr.Dropdown(
|
||||
get_available_voices(), label="Voice wav", value=params["voice"]
|
||||
)
|
||||
create_refresh_button(
|
||||
voice,
|
||||
lambda: None,
|
||||
lambda: {
|
||||
"choices": get_available_voices(),
|
||||
"value": params["voice"],
|
||||
},
|
||||
"refresh-button",
|
||||
)
|
||||
|
||||
language = gr.Dropdown(languages.keys(), label="Language", value=params["language"])
|
||||
language = gr.Dropdown(
|
||||
languages.keys(), label="Language", value=params["language"]
|
||||
)
|
||||
|
||||
with gr.Row():
|
||||
preview_text = gr.Text(show_label=False, placeholder="Preview text", elem_id="silero_preview_text")
|
||||
preview_text = gr.Text(
|
||||
show_label=False,
|
||||
placeholder="Preview text",
|
||||
elem_id="silero_preview_text",
|
||||
)
|
||||
preview_play = gr.Button("Preview")
|
||||
preview_audio = gr.HTML(visible=False)
|
||||
|
||||
with gr.Row():
|
||||
convert = gr.Button('Permanently replace audios with the message texts')
|
||||
convert_cancel = gr.Button('Cancel', visible=False)
|
||||
convert_confirm = gr.Button('Confirm (cannot be undone)', variant="stop", visible=False)
|
||||
convert = gr.Button("Permanently replace audios with the message texts")
|
||||
convert_cancel = gr.Button("Cancel", visible=False)
|
||||
convert_confirm = gr.Button(
|
||||
"Confirm (cannot be undone)", variant="stop", visible=False
|
||||
)
|
||||
|
||||
# Convert history with confirmation
|
||||
convert_arr = [convert_confirm, convert, convert_cancel]
|
||||
convert.click(lambda: [gr.update(visible=True), gr.update(visible=False), gr.update(visible=True)], None, convert_arr)
|
||||
convert.click(
|
||||
lambda: [
|
||||
gr.update(visible=True),
|
||||
gr.update(visible=False),
|
||||
gr.update(visible=True),
|
||||
],
|
||||
None,
|
||||
convert_arr,
|
||||
)
|
||||
convert_confirm.click(
|
||||
lambda: [gr.update(visible=False), gr.update(visible=True), gr.update(visible=False)], None, convert_arr).then(
|
||||
remove_tts_from_history, gradio('history'), gradio('history')).then(
|
||||
chat.save_history, gradio('history', 'unique_id', 'character_menu', 'mode'), None).then(
|
||||
chat.redraw_html, gradio(ui_chat.reload_arr), gradio('display'))
|
||||
lambda: [
|
||||
gr.update(visible=False),
|
||||
gr.update(visible=True),
|
||||
gr.update(visible=False),
|
||||
],
|
||||
None,
|
||||
convert_arr,
|
||||
).then(remove_tts_from_history, gradio("history"), gradio("history")).then(
|
||||
chat.save_history,
|
||||
gradio("history", "unique_id", "character_menu", "mode"),
|
||||
None,
|
||||
).then(
|
||||
chat.redraw_html, gradio(ui_chat.reload_arr), gradio("display")
|
||||
)
|
||||
|
||||
convert_cancel.click(lambda: [gr.update(visible=False), gr.update(visible=True), gr.update(visible=False)], None, convert_arr)
|
||||
convert_cancel.click(
|
||||
lambda: [
|
||||
gr.update(visible=False),
|
||||
gr.update(visible=True),
|
||||
gr.update(visible=False),
|
||||
],
|
||||
None,
|
||||
convert_arr,
|
||||
)
|
||||
|
||||
# Toggle message text in history
|
||||
show_text.change(
|
||||
lambda x: params.update({"show_text": x}), show_text, None).then(
|
||||
toggle_text_in_history, gradio('history'), gradio('history')).then(
|
||||
chat.save_history, gradio('history', 'unique_id', 'character_menu', 'mode'), None).then(
|
||||
chat.redraw_html, gradio(ui_chat.reload_arr), gradio('display'))
|
||||
show_text.change(lambda x: params.update({"show_text": x}), show_text, None).then(
|
||||
toggle_text_in_history, gradio("history"), gradio("history")
|
||||
).then(
|
||||
chat.save_history,
|
||||
gradio("history", "unique_id", "character_menu", "mode"),
|
||||
None,
|
||||
).then(
|
||||
chat.redraw_html, gradio(ui_chat.reload_arr), gradio("display")
|
||||
)
|
||||
|
||||
# Event functions to update the parameters in the backend
|
||||
activate.change(lambda x: params.update({"activate": x}), activate, None)
|
||||
@@ -495,7 +662,9 @@ def ui():
|
||||
low_vram.change(lambda x: send_lowvram_request(x), low_vram, None)
|
||||
tts_radio_buttons.change(send_reload_request, tts_radio_buttons, None)
|
||||
deepspeed_checkbox.change(send_deepspeed_request, deepspeed_checkbox, None)
|
||||
remove_trailing_dots.change(lambda x: params.update({"remove_trailing_dots": x}), remove_trailing_dots, None)
|
||||
remove_trailing_dots.change(
|
||||
lambda x: params.update({"remove_trailing_dots": x}), remove_trailing_dots, None
|
||||
)
|
||||
voice.change(lambda x: params.update({"voice": x}), voice, None)
|
||||
language.change(lambda x: params.update({"language": x}), language, None)
|
||||
|
||||
|
||||
Reference in new issue
Block a user