Lib/YandexSynthesize.php - master - mikopbx/ModuleAutoDialer

Lib/YandexSynthesize.php
134 строки5 KB
Alexey Portnov
Fix RHVoice sox conversion and harden TTS cache validation
17 мар 2026, 12:46
17 мар 2026, 12:46ab37f54
<?php
/*
 * MikoPBX - free phone system for small business
 * Copyright © 2017-2023 Alexey Portnov and Nikolay Beketov
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License along with this program.
 * If not, see <https://www.gnu.org/licenses/>.
 */

namespace Modules\ModuleAutoDialer\Lib;
use GuzzleHttp\Client;
use GuzzleHttp\Exception\GuzzleException;
use MikoPBX\Core\System\Util;

class YandexSynthesize
{
    private string $ttsDir;
    private string $apiKey;

    /**
     * Инициализация класса.
     * @param string $ttsDir
     * @param string $apiKey
     */
    public function __construct(string $ttsDir, string $apiKey)
    {
        $this->apiKey = $apiKey;
        $this->ttsDir = $ttsDir;
        if(!file_exists($this->ttsDir)){
            Util::mwMkdir($this->ttsDir);
        }
    }

    /**
     * Генерирует и скачивает в на внешний диск файл с речью.
     *
     * @param $text_to_speech - генерируемый текст
     * @param $lang           - язык
     *
     * @return null|string
     *
     * https://tts.api.cloud.yandex.net/speech/v1/tts:synthesize
     */
    public function makeSpeechFromText(string $text_to_speech, string $lang): ?string
    {
        if (trim($text_to_speech) === '') {
            return null;
        }
        $tmpLang = strtolower($lang);
        if($tmpLang === 'uz-uz') {
            $voice = 'nigora';
            $lang = 'uz-UZ';
        }elseif($tmpLang === 'en-en'){
            $lang = 'en-US';
            $voice = 'john';
        }else{
            $lang = 'ru-RU';
            $voice = 'alena';
        }
        $speech_extension        = '.raw';
        $result_extension        = '.wav';
        $speech_filename         = md5($text_to_speech . $voice);
        $fullFileName            = $this->ttsDir .'/'. $speech_filename . $result_extension;
        $fullFileNameFromService = $this->ttsDir .'/'. $speech_filename . $speech_extension;
        $fullFileNameFromText    = $this->ttsDir .'/'. $speech_filename . '.txt';
        // Проверим мб мы ранее уже генерировали такой файл.
        // WAV-заголовок занимает ~44 байта, файл меньше 300 байт — битый кеш, удаляем
        if (file_exists($fullFileName)) {
            if (filesize($fullFileName) > 300) {
                return $fullFileName;
            }
            unlink($fullFileName);
        }
        // Файла нет в кеше, будем генерировать новый.
        $post_vars = [
            'lang'            => $lang,
            'format'          => 'lpcm',
            'speed'           => '1.0',
            'sampleRateHertz' => '8000',
            'voice'           => $voice,
            'text'            => urldecode(strip_tags($text_to_speech)),
        ];
        // Использование GuzzleHttp для выполнения запроса
        $client = new Client();
        try {
            $response = $client->post('https://tts.api.cloud.yandex.net/speech/v1/tts:synthesize', [
                'headers' => [
                    'Authorization' => 'Api-Key ' . $this->apiKey,
                ],
                'form_params' => $post_vars,
                'sink' => $fullFileNameFromService,
            ]);

            // Проверка успешности запроса
            $http_code = $response->getStatusCode();
            if ($http_code === 200 && file_exists($fullFileNameFromService) && filesize($fullFileNameFromService) > 0) {
                // Конвертация raw в wav с помощью sox
                $soxPath = Util::which('sox');
                shell_exec("$soxPath -r 8000 -e signed-integer -b 16 -c 1 -t raw $fullFileNameFromService $fullFileName");
                if (file_exists($fullFileName) && filesize($fullFileName) > 300) {
                    // Удаляем raw файл
                    unlink($fullFileNameFromService);
                    // Сохраняем текст и язык в файл
                    file_put_contents($fullFileNameFromText, serialize([$text_to_speech, $lang]));
                    return $fullFileName;
                }
                // sox создал битый файл, удаляем
                if (file_exists($fullFileName)) {
                    unlink($fullFileName);
                }
            } elseif (file_exists($fullFileNameFromService)) {
                // Удаляем raw файл, если что-то пошло не так
                unlink($fullFileNameFromService);
            }
            if(200 !== $http_code){
                Util::sysLogMsg('TTS Yandex, return code: '. $http_code, '');
            }
        } catch (GuzzleException $e) {
            // Логирование ошибок
            Util::sysLogMsg('TTS Yandex, error: ' . $e->getMessage(), '');
        }
        return null;
    }
}