TTS Models

import re

def preprocess_text(text):
    # Expand abbreviations
    replacements = {
        "Dr.": "Doctor",
        "Mr.": "Mister",
        "Mrs.": "Misses",
        "vs.": "versus"
    }
    
    for abbr, full in replacements.items():
        text = text.replace(abbr, full)
    
    # Clean special characters
    text = re.sub(r'[^\w\s.,!?;:\-\'"()]', '', text)
    
    # Ensure proper ending punctuation
    if not text.endswith(('.', '!', '?')):
        text += '.'
    
    return text

class ConnectionManager {
  constructor(apiKey) {
    this.apiKey = apiKey;
    this.reconnectAttempts = 0;
    this.maxReconnects = 5;
  }

  connect() {
    this.ws = new WebSocket('wss://api.sub200.dev/v1/tts', {
      headers: { 'Authorization': `Bearer ${this.apiKey}` }
    });

    this.ws.on('close', () => {
      this.handleReconnect();
    });
  }

  handleReconnect() {
    if (this.reconnectAttempts < this.maxReconnects) {
      const delay = Math.pow(2, this.reconnectAttempts) * 1000;
      setTimeout(() => {
        this.reconnectAttempts++;
        this.connect();
      }, delay);
    }
  }
}

class ErrorHandler:
    def handle_error(self, error):
        error_handlers = {
            'RATE_LIMIT_EXCEEDED': self.handle_rate_limit,
            'INVALID_API_KEY': self.handle_auth_error,
            'TEXT_TOO_LONG': self.handle_text_length,
            'SERVER_ERROR': self.handle_server_error
        }
        
        handler = error_handlers.get(
            error['code'], 
            self.handle_generic
        )
        return handler(error)
    
    def handle_rate_limit(self, error):
        reset_time = error['details']['reset_at']
        print(f"Rate limit hit. Resets at {reset_time}")
        # Implement backoff strategy