Use FixedString in GetTTS

Cargo.toml

@@ -22,6 +22,7 @@ jsonwebtoken = "9"
 mp3-duration = "0.1"
 itertools = "0.12"
 aws-sdk-polly = "1.7.0"
+small-fixed-array = { version = "0.4.0", features = ["serde"] }
 
 [dependencies.fernet]
 version = "0.2"

src/gcloud.rs

@@ -189,7 +189,7 @@ pub async fn get_tts(
     text: &str,
     lang: &str,
     speaking_rate: f32,
-    preferred_format: Option<String>,
+    preferred_format: Option<&str>,
 ) -> Result<(bytes::Bytes, Option<reqwest::header::HeaderValue>)> {
     let jwt_token = refresh_jwt(state).await?;
     let reqwest = state.read().await.reqwest.clone();

src/main.rs

@@ -17,6 +17,7 @@ use bytes::Bytes;
 use deadpool_redis::redis::AsyncCommands;
 use serde_json::to_value;
 use sha2::Digest;
+use small_fixed_array::FixedString;
 use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
 
 mod espeak;
@@ -65,15 +66,15 @@ async fn get_voices(
 
 #[derive(serde::Deserialize)]
 struct GetTTS {
-    text: String,
+    text: FixedString,
     mode: TTSMode,
     #[serde(rename = "lang")]
-    voice: String,
+    voice: FixedString<u8>,
     #[serde(default)]
     speaking_rate: Option<f32>,
     max_length: Option<u64>,
     #[serde(default)]
-    preferred_format: Option<String>,
+    preferred_format: Option<FixedString<u8>>,
 }
 
 async fn get_tts(
@@ -150,7 +151,7 @@ async fn get_tts(
                 text,
                 &voice,
                 speaking_rate.map(|r| r as u8),
-                preferred_format,
+                preferred_format.as_deref(),
             )
             .await?
         }
@@ -160,7 +161,7 @@ async fn get_tts(
                 &text,
                 &voice,
                 speaking_rate.unwrap_or(0.0),
-                preferred_format,
+                preferred_format.as_deref(),
             )
             .await?
         }
@@ -210,11 +211,11 @@ impl TTSMode {
             .map_err(Into::into)
     }
 
-    #[cfg_attr(
-        not(feature = "polly"),
-        allow(unused_variables, clippy::unnecessary_wraps)
-    )]
-    async fn check_voice(self, state: &State, voice: String) -> ResponseResult<String> {
+    async fn check_voice(
+        self,
+        state: &State,
+        voice: FixedString<u8>,
+    ) -> ResponseResult<FixedString<u8>> {
         if match self {
             Self::gTTS => gtts::check_voice(&voice),
             Self::eSpeak => espeak::check_voice(&voice),
@@ -363,7 +364,7 @@ async fn main() -> Result<()> {
 #[derive(Debug)]
 enum Error {
     Unauthorized,
-    UnknownVoice(String),
+    UnknownVoice(FixedString<u8>),
     AudioTooLong,
     InvalidSpeakingRate(f32),
 

src/polly.rs

@@ -1,5 +1,6 @@
 use aws_sdk_polly::types::{Engine, Gender, LanguageCode, OutputFormat, TextType, VoiceId};
 use serde::ser::SerializeStruct;
+use small_fixed_array::FixedString;
 
 use crate::Result;
 
@@ -60,14 +61,16 @@ impl serde::Serialize for VoiceLocal {
 
 pub async fn get_tts(
     state: &State,
-    mut text: String,
+    text: FixedString,
     voice: &str,
     speaking_rate: Option<u8>,
-    preferred_format: Option<String>,
+    preferred_format: Option<&str>,
 ) -> Result<(bytes::Bytes, Option<reqwest::header::HeaderValue>)> {
-    if let Some(speaking_rate) = speaking_rate {
-        text = format!("<speak><prosody rate=\"{speaking_rate}%\">{text}</prosody></speak>");
-    }
+    let text = if let Some(speaking_rate) = speaking_rate {
+        format!("<speak><prosody rate=\"{speaking_rate}%\">{text}</prosody></speak>")
+    } else {
+        text.into_string()
+    };
 
     let resp = state
         .synthesize_speech()