Add DTOs, exceptions, and jobs for translation service.

Introduced new Data Transfer Objects (DTOs), exceptions, and jobs to enhance the translation service functionality. Updated namespaces for consistency and added rate limiting to the translation provider. Expanded the README with detailed usage instructions.

.gitignore

@@ -0,0 +1 @@
+/vendor

README.md

@@ -2,14 +2,99 @@
 
 Библиотека для Laravel, что бы общаться с сервисом перевода от <a href="https://yandex.cloud/ru/docs/translate/" target="_blank">yandex</a>. В будущем (скорей всего в далёком будущем) планирую расширить поддержку разных сервисов перевода. Что бы можно было общаться через один интерфейс с разными сервисами.
 
-Параметры в **.env**:
+# Параметры в **.env**:
 
-# TRANSLATE_SERVICE
+### TRANSLATE_SERVICE
 По умолчанию через какой сервис обращаться за переводом. На данный момент доступен только один сервис - **yandex**.
 
-# TRANSLATE_YANDEX_FOLDER_ID
+### TRANSLATE_YANDEX_FOLDER_ID
 ID folder. Код можно увидеть в адресе console.yandex.cloud/folders/**{тут будет код}**.
 
-# TRANSLATE_YANDEX_AUTHORIZED_KEY_PATH
+### TRANSLATE_YANDEX_AUTHORIZED_KEY_PATH
 Абсолютный путь в рамках приложения Laravel к файлу **authorized_key.json**.
-Например: положили файл в корень Laravel. Тогда будет путь такой: **/authorized_key.json**.
+Например: положили файл в корень Laravel. Тогда будет путь такой: **/authorized_key.json**.
+
+### TRANSLATE_YANDEX_LIMIT_MAX_REQUEST
+Максимальное количество запросов в период, который указан в TRANSLATE_YANDEX_LIMIT_RATE_SECONDS. По умолчанию 20 запросов в секунду. **На данный момент работает только перевод через систему очередей.**
+
+### TRANSLATE_YANDEX_LIMIT_RATE_SECONDS
+Период в котором считается максимальное количество запросов. По умолчанию стоит секунда. **На данный момент работает только перевод через систему очередей.**
+
+### TRANSLATE_YANDEX_LIMIT_MAX_SYMBOLS
+Максимальное количество символов за один запрос. Если превышает, то делится на две части и делает по очереди два запроса. По умолчанию стоит 9000 символов. **На данный момент работает только перевод через систему очередей.**
+
+# Методы
+### Перевести обычный текст
+> \KorElf\TranslateLaravel\Facades\Translate::translateText(
+> <br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;string | array \$text, 
+> <br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;string &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;\$targetLanguageCode, 
+> <br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;?string &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;\$sourceLanguageCode = null
+> <br>): string | array
+
+**\$text** - текст который нужно перевести.
+<br>**\$targetLanguageCode** - язык на который надо перевести.
+<br>**\$sourceLanguageCode** - язык с которого надо перевести. Если **null**, то сервис сам пытается определить язык.
+
+<br>
+
+### Перевести текст в формате HTML
+> \KorElf\TranslateLaravel\Facades\Translate::translateHtml(
+> <br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;string | array \$text,
+> <br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;string &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;\$targetLanguageCode,
+> <br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;?string &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;\$sourceLanguageCode = null
+> <br>): string | array
+
+**\$text** - текст который нужно перевести.
+<br>**\$targetLanguageCode** - язык на который надо перевести.
+<br>**\$sourceLanguageCode** - язык с которого надо перевести. Если **null**, то сервис сам пытается определить язык.
+
+<br>
+
+### Получить список языков, который сервис поддерживает
+> \KorElf\TranslateLaravel\Facades\Translate::listLanguages(): \KorElf\TranslateLaravel\DTO\Languages
+
+<br>
+
+### Перевести с помощью очередей (Queues)
+> \KorElf\TranslateLaravel\Facades\Translate::runJob(
+> <br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;\KorElf\TranslateLaravel\DTO\RunTranslateDto &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;\$params,
+> <br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;\KorElf\TranslateLaravel\Contracts\TranslationCompletedListener \$completedListener
+<br>): \Illuminate\Foundation\Bus\PendingDispatch
+
+**\$params** - параметры перевода.
+<br>**\$completedListener** - после завершения перевода отправляет результат в этот объект. Объект должен соблюдать контракт **\KorElf\TranslateLaravel\Contracts\TranslationCompletedListener**.
+
+**Пример:**
+> Создаём файл TranslationListener например в папке app/Services
+> 
+>       <?php declare(strict_types=1);
+>
+>       namespace App\Services;
+>
+>       use Illuminate\Support\Facades\Log;
+>       use KorElf\TranslateLaravel\Contracts\TranslationCompletedListener;
+>
+>       final class TranslationListener implements TranslationCompletedListener
+>       {
+>           public function onTranslationCompleted(array $translatedText): void
+>           {
+>               foreach ($translatedText as $translatedTextKey => $translatedTextValue) {
+>                   Log::info($translatedTextKey . ': ' . $translatedTextValue);
+>               }
+>           }
+>       }
+> 
+> Потом например в каком-то контроллере (а лучше конечно в сервисе) пишем такой метод
+>
+>     public function sendingForTranslation(\App\Services\TranslationListener $translationListener): View
+>     {
+>          // Вначале создаём объект с параметрами
+>         $params = (new \KorElf\TranslateLaravel\DTO\RunTranslateDto)
+>            ->addParamText('title', 'Заголовок', 'en', 'ru')
+>            ->addParamHtml('content', '<p>Привет, Мир!</p>', 'en', 'ru');
+> 
+>         // Отправляем на очередь
+>         \KorElf\TranslateLaravel\Facades\Translate::runJob($params, $translationListener);
+>         
+>         return view('success');
+>     }

composer.json

@@ -21,18 +21,20 @@
     "php": "^8.2",
     "illuminate/support": "^10.0|^11.0",
     "guzzlehttp/guzzle": "^7.0.1",
-    "web-token/jwt-framework": "^3.0"
+    "web-token/jwt-framework": "^3.0",
+    "ext-libxml": "^2.11.7",
+    "ext-dom": "^2.11.7"
   },
   "extra": {
     "laravel": {
       "providers": [
-        "korElf\\TranslateLaravel\\TranslateLaravelProvider"
+        "KorElf\\TranslateLaravel\\TranslateLaravelProvider"
       ]
     }
   },
   "autoload": {
     "psr-4": {
-      "korElf\\TranslateLaravel\\": "src/"
+      "KorElf\\TranslateLaravel\\": "src/"
     }
   }
 }

config/translate.php

@@ -24,10 +24,15 @@ return [
 
     'services' => [
         'yandex' => [
-            'driver' => '\korElf\TranslateLaravel\Translate\YandexDriver',
+            'driver' => '\KorElf\TranslateLaravel\Translate\YandexDriver',
             'config' => [
                 'folder_id'           => env('TRANSLATE_YANDEX_FOLDER_ID'),
                 'authorized_key_path' => base_path(env('TRANSLATE_YANDEX_AUTHORIZED_KEY_PATH')),
+                'limit' => [
+                    'max_request'  => (int) env('TRANSLATE_YANDEX_LIMIT_MAX_REQUEST', 20),
+                    'rate_seconds' => (int) env('TRANSLATE_YANDEX_LIMIT_RATE_SECONDS', 1),
+                    'max_symbols' => (int) env('TRANSLATE_YANDEX_LIMIT_MAX_SYMBOLS', 9000),
+                ],
             ],
         ],
     ],

src/Contracts/ProcessTranslateContract.php

@@ -0,0 +1,10 @@
+<?php declare(strict_types=1);
+
+namespace KorElf\TranslateLaravel\Contracts;
+
+use KorElf\TranslateLaravel\DTO\ProcessTranslateLimit;
+
+interface ProcessTranslateContract
+{
+    public function getLimited(): ProcessTranslateLimit;
+}

src/Contracts/Translate.php

@@ -1,8 +1,8 @@
 <?php declare(strict_types=1);
 
-namespace korElf\TranslateLaravel\Contracts;
+namespace KorElf\TranslateLaravel\Contracts;
 
-use korElf\TranslateLaravel\DTO\Languages;
+use KorElf\TranslateLaravel\DTO\Languages;
 use Illuminate\Contracts\Foundation\Application;
 
 interface Translate

src/Contracts/TranslationCompletedListener.php

@@ -0,0 +1,8 @@
+<?php declare(strict_types=1);
+
+namespace KorElf\TranslateLaravel\Contracts;
+
+interface TranslationCompletedListener
+{
+    public function onTranslationCompleted(array $translatedText): void;
+}

src/DTO/Languages.php

@@ -1,6 +1,6 @@
 <?php declare(strict_types=1);
 
-namespace korElf\TranslateLaravel\DTO;
+namespace KorElf\TranslateLaravel\DTO;
 
 final class Languages
 {

src/DTO/Parameter.php

@@ -0,0 +1,41 @@
+<?php declare(strict_types=1);
+
+namespace KorElf\TranslateLaravel\DTO;
+
+use KorElf\TranslateLaravel\Enums\TextType;
+
+final readonly class Parameter
+{
+    public function __construct(
+        private string   $text,
+        private TextType $textType,
+        private string   $targetLanguageCode,
+        private ?string  $sourceLanguageCode = null,
+        private ?string  $driver = null
+    ) { }
+
+    public function getText(): string
+    {
+        return $this->text;
+    }
+
+    public function getTextType(): TextType
+    {
+        return $this->textType;
+    }
+
+    public function getTargetLanguageCode(): string
+    {
+        return $this->targetLanguageCode;
+    }
+
+    public function getSourceLanguageCode(): ?string
+    {
+        return $this->sourceLanguageCode;
+    }
+
+    public function getDriver(): ?string
+    {
+        return $this->driver;
+    }
+}

src/DTO/ProcessTranslateDto.php

@@ -0,0 +1,59 @@
+<?php declare(strict_types=1);
+
+namespace KorElf\TranslateLaravel\DTO;
+
+use KorElf\TranslateLaravel\Enums\TextType;
+
+final readonly class ProcessTranslateDto
+{
+    public function __construct(
+        private string   $groupName,
+        private string   $key,
+        private int      $part,
+        private string   $text,
+        private TextType $textType,
+        private string   $targetLanguageCode,
+        private ?string  $sourceLanguageCode = null,
+        private ?string  $driver = null
+    ) { }
+
+    public function getGroupName(): string
+    {
+        return $this->groupName;
+    }
+
+    public function getKey(): string
+    {
+        return $this->key;
+    }
+
+    public function getPart(): int
+    {
+        return $this->part;
+    }
+
+    public function getText(): string
+    {
+        return $this->text;
+    }
+
+    public function getTextType(): TextType
+    {
+        return $this->textType;
+    }
+
+    public function getTargetLanguageCode(): string
+    {
+        return $this->targetLanguageCode;
+    }
+
+    public function getSourceLanguageCode(): ?string
+    {
+        return $this->sourceLanguageCode;
+    }
+
+    public function getDriver(): ?string
+    {
+        return $this->driver;
+    }
+}

src/DTO/ProcessTranslateLimit.php

@@ -0,0 +1,27 @@
+<?php declare(strict_types=1);
+
+namespace KorElf\TranslateLaravel\DTO;
+
+final readonly class ProcessTranslateLimit
+{
+    public function __construct(
+        private int    $maxRequest,
+        private int    $rateSeconds,
+        private string $driver,
+    ) { }
+
+    public function getMaxRequest(): int
+    {
+        return $this->maxRequest;
+    }
+
+    public function getRateSeconds(): int
+    {
+        return $this->rateSeconds;
+    }
+
+    public function getDriver(): string
+    {
+        return $this->driver;
+    }
+}

src/DTO/RunTranslateDto.php

@@ -0,0 +1,65 @@
+<?php declare(strict_types=1);
+
+namespace KorElf\TranslateLaravel\DTO;
+
+use KorElf\TranslateLaravel\Enums\TextType;
+use KorElf\TranslateLaravel\Exceptions\RunTranslateDtoException;
+
+final class RunTranslateDto
+{
+    /**
+     * @var array [key => \KorElf\TranslateLaravel\DTO\Parameter]
+     */
+    private array $params = [];
+
+    public function addParam(
+        string   $key,
+        string   $text,
+        TextType $textType,
+        string   $targetLanguageCode,
+        ?string  $sourceLanguageCode = null,
+        ?string  $driver = null
+    ): self
+    {
+        if (isset($this->params[$key])) {
+            throw new RunTranslateDtoException('Duplicate key: ' . $key);
+        }
+
+        $this->params[$key] = new Parameter(
+            $text,
+            $textType,
+            $targetLanguageCode,
+            $sourceLanguageCode,
+            $driver,
+        );
+
+        return $this;
+    }
+
+    public function addParamHtml(
+        string   $key,
+        string   $text,
+        string   $targetLanguageCode,
+        ?string  $sourceLanguageCode = null,
+        ?string  $driver = null
+    ): self
+    {
+        return $this->addParam($key, $text, TextType::Html, $targetLanguageCode, $sourceLanguageCode, $driver);
+    }
+
+    public function addParamText(
+        string   $key,
+        string   $text,
+        string   $targetLanguageCode,
+        ?string  $sourceLanguageCode = null,
+        ?string  $driver = null
+    ): self
+    {
+        return $this->addParam($key, $text, TextType::Text, $targetLanguageCode, $sourceLanguageCode, $driver);
+    }
+
+    public function getParams(): array
+    {
+        return $this->params;
+    }
+}

src/DTO/Translated.php

@@ -0,0 +1,20 @@
+<?php declare(strict_types=1);
+
+namespace KorElf\TranslateLaravel\DTO;
+
+final class Translated
+{
+    private array $data = [];
+
+    public function add(string $key, int $parts): self
+    {
+        $this->data[$key] = $parts;
+
+        return $this;
+    }
+
+    public function toArray(): array
+    {
+        return $this->data;
+    }
+}

src/Enums/TextType.php

@@ -0,0 +1,17 @@
+<?php declare(strict_types=1);
+
+namespace KorElf\TranslateLaravel\Enums;
+
+enum TextType: string
+{
+    case Text = 'text';
+    case Html = 'html';
+
+    public function functionName(): string
+    {
+        return match ($this) {
+            self::Text => 'translateText',
+            self::Html => 'translateHtml',
+        };
+    }
+}

src/Exceptions/AfterTranslateException.php

@@ -0,0 +1,10 @@
+<?php declare(strict_types=1);
+
+namespace KorElf\TranslateLaravel\Exceptions;
+
+use RuntimeException;
+
+final class AfterTranslateException extends RuntimeException
+{
+
+}

src/Exceptions/RunTranslateDtoException.php

@@ -0,0 +1,10 @@
+<?php declare(strict_types=1);
+
+namespace KorElf\TranslateLaravel\Exceptions;
+
+use RuntimeException;
+
+final class RunTranslateDtoException extends RuntimeException
+{
+
+}

src/Exceptions/TranslateException.php

@@ -1,10 +1,10 @@
 <?php declare(strict_types=1);
 
-namespace korElf\TranslateLaravel\Exceptions;
+namespace KorElf\TranslateLaravel\Exceptions;
 
 use RuntimeException;
 
-class TranslateException extends RuntimeException
+final class TranslateException extends RuntimeException
 {
 
 }

src/Facades/Translate.php

@@ -1,18 +1,22 @@
 <?php declare(strict_types=1);
 
-namespace korElf\TranslateLaravel\Facades;
+namespace KorElf\TranslateLaravel\Facades;
 
 use Illuminate\Support\Facades\Facade;
+use KorElf\TranslateLaravel\Contracts\TranslationCompletedListener;
+use KorElf\TranslateLaravel\DTO\RunTranslateDto;
 
 /**
- * @method static \korElf\TranslateLaravel\Contracts\Translate service(?string $name = null)
- * @method static \korElf\TranslateLaravel\Contracts\Translate resolve(string $name)
+ * @method static \KorElf\TranslateLaravel\Contracts\Translate service(?string $name = null)
+ * @method static \KorElf\TranslateLaravel\Contracts\Translate resolve(string $name)
  * @method static string|array translateText(string|array $text, string $targetLanguageCode, ?string $sourceLanguageCode = null)
  * @method static string|array translateHtml(string|array $text, string $targetLanguageCode, ?string $sourceLanguageCode = null)
- * @method static \korElf\TranslateLaravel\DTO\Languages listLanguages()
+ * @method static \Illuminate\Foundation\Bus\PendingDispatch runJob(RunTranslateDto $params, TranslationCompletedListener $completedListener)
+ * @method static \KorElf\TranslateLaravel\DTO\Languages listLanguages()
  * @method static string getDefaultDriver()
  * @method static void setDefaultDriver(string $name)
  * @method static void purge(?string $name)
+ * @method static array getLimit(?string $driver)
  */
 
 final class Translate extends Facade

src/Jobs/AfterTranslate.php

@@ -0,0 +1,53 @@
+<?php declare(strict_types=1);
+
+namespace KorElf\TranslateLaravel\Jobs;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldBeEncrypted;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Support\Facades\Cache;
+use KorElf\TranslateLaravel\Contracts\TranslationCompletedListener;
+use KorElf\TranslateLaravel\DTO\Translated;
+use KorElf\TranslateLaravel\Exceptions\AfterTranslateException;
+
+final class AfterTranslate implements ShouldQueue, ShouldBeEncrypted
+{
+    use Dispatchable, InteractsWithQueue, Queueable;
+
+    /**
+     * Create a new job instance.
+     */
+    public function __construct(
+        private readonly string                       $groupName,
+        private readonly TranslationCompletedListener $listener,
+        private readonly Translated                   $translated,
+    ) { }
+
+    /**
+     * Execute the job.
+     */
+    public function handle(): void
+    {
+        $translated = [];
+        $data = Cache::get($this->groupName, []);
+
+        $errors = [];
+        foreach ($this->translated->toArray() as $key => $parts) {
+            if (!isset($data[$key]) || count($data[$key]) !== $parts) {
+                $errors[] = $key;
+                continue;
+            }
+
+            $translated[$key] = implode(' ', $data[$key]);
+        }
+
+        if (empty($data)) {
+            throw new AfterTranslateException('Part or all of the text has not been translated. Keys: ' . implode(', ', $errors));
+        }
+        Cache::forget($this->groupName);
+
+        $this->listener->onTranslationCompleted($translated);
+    }
+}

src/Jobs/ProcessTranslate.php

@@ -0,0 +1,86 @@
+<?php declare(strict_types=1);
+
+namespace KorElf\TranslateLaravel\Jobs;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldBeEncrypted;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\Middleware\RateLimited;
+use Illuminate\Support\Facades\Cache;
+use KorElf\TranslateLaravel\Contracts\ProcessTranslateContract;
+use KorElf\TranslateLaravel\DTO\ProcessTranslateDto;
+use KorElf\TranslateLaravel\DTO\ProcessTranslateLimit;
+use KorElf\TranslateLaravel\Facades\Translate;
+
+final class ProcessTranslate implements ShouldQueue, ShouldBeEncrypted, ProcessTranslateContract
+{
+    use Dispatchable, InteractsWithQueue, Queueable;
+
+    /**
+     * Create a new job instance.
+     */
+    public function __construct(
+        private readonly ProcessTranslateDto $param
+    ) { }
+
+    /**
+     * Get the middleware the job should pass through.
+     *
+     * @return array<int, object>
+     */
+    public function middleware(): array
+    {
+        return [
+            new RateLimited('kor-elf-translate'),
+        ];
+    }
+
+    public function getLimited(): ProcessTranslateLimit
+    {
+        $driver = $this->param->getDriver();
+        if ($driver === null) {
+            $driver = Translate::getDefaultDriver();
+        }
+        $limit = Translate::getLimit($driver);
+
+        return new ProcessTranslateLimit(
+            maxRequest: $limit['max_request'] ?? 1000000000,
+            rateSeconds: $limit['rate_seconds'] ?? 1,
+            driver: $driver,
+        );
+    }
+
+    /**
+     * Execute the job.
+     */
+    public function handle(): void
+    {
+        $param = $this->param;
+        $groupName = $param->getGroupName();
+
+        $translated = Cache::get($groupName, []);
+        if (!isset($translated[$param->getKey()])) {
+            $translated[$param->getKey()] = [];
+        }
+
+        $translate = Translate::service($param->getDriver());
+        $function = $param->getTextType()->functionName();
+        $key = $param->getKey();
+        $part = $param->getPart();
+
+        $translated[$key][$part] = $param->getText();
+        if (\trim($param->getText()) !== '') {
+
+            $translated[$key][$part] = $translate->{$function}(
+                $param->getText(),
+                $param->getTargetLanguageCode(),
+                $param->getSourceLanguageCode()
+            );
+
+        }
+
+        Cache::put($groupName, $translated, 86400);
+    }
+}

src/Jobs/RunTranslate.php

@@ -0,0 +1,62 @@
+<?php declare(strict_types=1);
+
+namespace KorElf\TranslateLaravel\Jobs;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldBeEncrypted;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Support\Facades\Bus;
+use Illuminate\Support\Str;
+use KorElf\TranslateLaravel\Contracts\TranslationCompletedListener;
+use KorElf\TranslateLaravel\DTO\ProcessTranslateDto;
+use korElf\TranslateLaravel\DTO\RunTranslateDto;
+use KorElf\TranslateLaravel\DTO\Translated;
+use KorElf\TranslateLaravel\Translate\SplitTextIntoPartsCommand;
+
+final class RunTranslate implements ShouldQueue, ShouldBeEncrypted
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+    /**
+     * Create a new job instance.
+     */
+    public function __construct(
+        private readonly RunTranslateDto              $runTranslateDto,
+        private readonly TranslationCompletedListener $translationCompletedListener,
+    ) { }
+
+    /**
+     * Execute the job.
+     */
+    public function handle(SplitTextIntoPartsCommand $splitTextIntoPartsCommand): void
+    {
+        $chains = [];
+        $groupName = 'KorElf\TranslateLaravel\Jobs-' . Str::uuid()->toString();
+        $translated = new Translated();
+        foreach ($this->runTranslateDto->getParams() as $key => $param) {
+            /* @var \KorElf\TranslateLaravel\DTO\Parameter $param */
+
+            $texts = $splitTextIntoPartsCommand->execute($param->getText(), $param->getTextType(), $param->getDriver());
+            foreach ($texts as $part => $partText) {
+                $processTranslateDto = new ProcessTranslateDto(
+                    $groupName,
+                    $key,
+                    $part,
+                    $partText,
+                    $param->getTextType(),
+                    $param->getTargetLanguageCode(),
+                    $param->getSourceLanguageCode(),
+                    $param->getDriver(),
+                );
+                $chains[] = new ProcessTranslate($processTranslateDto);
+            }
+            $translated->add($key, count($texts));
+        }
+        $chains[] = new AfterTranslate($groupName, $this->translationCompletedListener, $translated);
+
+        Bus::chain($chains)->dispatch();
+    }
+}

src/Translate/SplitTextIntoPartsCommand.php

@@ -0,0 +1,115 @@
+<?php declare(strict_types=1);
+
+namespace KorElf\TranslateLaravel\Translate;
+
+use KorElf\TranslateLaravel\Enums\TextType;
+use KorElf\TranslateLaravel\Facades\Translate;
+use DOMDocument;
+
+final readonly class SplitTextIntoPartsCommand
+{
+    public function execute(string $text, TextType $textType, ?string $driver): array
+    {
+        $maxLength = Translate::getLimit($driver);
+        $maxLength = $maxLength['max_symbols'] ?? null;
+        if ($maxLength === null || $maxLength > mb_strlen($text)) {
+            return [$text];
+        }
+
+        if ($textType === TextType::Html) {
+            return $this->splitHtmlText($text, $maxLength);
+        }
+
+        return $this->splitTextBySentences($text, $maxLength);
+    }
+
+    private function splitTextBySentences(string $text, int $maxLength): array
+    {
+        // Common expression for searching for sentences.
+        $sentenceEndings = '/(?<=[.?!])\s+(?=[A-ZА-Я])/u';
+
+        //Dividing the text into sentences
+        $sentences = preg_split($sentenceEndings, $text, -1, PREG_SPLIT_NO_EMPTY);
+
+        $parts = [];
+        $currentPart = '';
+
+        foreach ($sentences as $sentence) {
+            // If adding a sentence does not exceed the limit, add it to the current part.
+            if (mb_strlen($currentPart . ' ' . $sentence) <= $maxLength) {
+                $currentPart .= (empty($currentPart) ? '' : ' ') . $sentence;
+                continue;
+            }
+
+            // Otherwise, save the current part and start a new one.
+            if (!empty($currentPart)) {
+                $parts[] = $currentPart;
+                $currentPart = '';
+            }
+            $currentPart = $sentence;
+        }
+
+        if (!empty($currentPart)) {
+            $parts[] = $currentPart;
+        }
+
+        return $parts;
+    }
+
+    private function splitHtmlText(string $html, int $maxLength): array
+    {
+        libxml_use_internal_errors(true);
+
+        $dom = new DOMDocument();
+        $dom->loadHTML(mb_convert_encoding('<body>' . $html . '</body>', 'HTML-ENTITIES', 'UTF-8'), LIBXML_HTML_NOIMPLIED | LIBXML_HTML_NODEFDTD);
+
+        $parts = [];
+        $currentPart = new DOMDocument();
+        $currentLength = 0;
+
+        // Iterate through all child nodes of the root element
+        foreach ($dom->documentElement->childNodes as $node) {
+            if ($node->nodeType === XML_TEXT_NODE || $node->nodeType === XML_CDATA_SECTION_NODE) {
+                // Dividing text nodes into sentences
+                $sentences = preg_split('/(?<=[.?!])\s+(?=[A-ZА-Я])/', $node->textContent, -1, PREG_SPLIT_NO_EMPTY);
+
+                foreach ($sentences as $sentence) {
+                    $sentenceHtml = htmlspecialchars($sentence);
+                    if ($currentLength + mb_strlen($sentenceHtml) > $maxLength) {
+                        $parts[] = $currentPart->saveHTML();
+
+                        // Start new part
+                        $currentPart = new DOMDocument();
+                        $currentLength = 0;
+                    }
+
+                    $textNode = $currentPart->createTextNode($sentence . ' ');
+                    $currentPart->appendChild($textNode);
+                    $currentLength += mb_strlen($sentenceHtml);
+                }
+                continue;
+            }
+
+            $nodeHtml = $dom->saveHTML($node);
+
+            if ($currentLength + mb_strlen($nodeHtml) > $maxLength) {
+                $parts[] = $currentPart->saveHTML();
+
+                // Start new part
+                $currentPart = new DOMDocument();
+                $currentLength = mb_strlen($nodeHtml);
+            }
+
+            $currentPart->appendChild($currentPart->importNode($node, true));
+            $currentLength += mb_strlen($nodeHtml);
+        }
+
+        if ($currentPart->hasChildNodes()) {
+            $parts[] = $currentPart->saveHTML();
+        }
+
+        libxml_clear_errors();
+
+        return $parts;
+    }
+}

src/Translate/TranslateManager.php

@@ -1,10 +1,15 @@
 <?php declare(strict_types=1);
 
-namespace korElf\TranslateLaravel\Translate;
+namespace KorElf\TranslateLaravel\Translate;
 
 use Illuminate\Contracts\Foundation\Application;
-use korElf\TranslateLaravel\Contracts\Translate;
+use Illuminate\Foundation\Bus\PendingDispatch;
+use KorElf\TranslateLaravel\Contracts\CallbackAfterTranslated;
+use KorElf\TranslateLaravel\Contracts\Translate;
 use InvalidArgumentException;
+use KorElf\TranslateLaravel\Contracts\TranslationCompletedListener;
+use KorElf\TranslateLaravel\DTO\RunTranslateDto;
+use KorElf\TranslateLaravel\Jobs\RunTranslate;
 
 final class TranslateManager
 {
@@ -44,7 +49,7 @@ final class TranslateManager
         $config = $this->getConfig($name);
 
         if (\is_null($config)) {
-            throw new InvalidArgumentException("Translate service [{$name}] is not defined.");
+            throw new InvalidArgumentException('Translate service [' . $name . '] is not defined.');
         }
 
         return $config['driver']::init($this->app, $config['config']);
@@ -60,6 +65,25 @@ final class TranslateManager
         unset($this->translates[$name]);
     }
 
+    /**
+     * Run through queues.
+     */
+    public function runJob(RunTranslateDto $params, TranslationCompletedListener $completedListener): PendingDispatch
+    {
+        return RunTranslate::dispatch($params, $completedListener);
+    }
+
+    public function getLimit(?string $driver = null): array
+    {
+        if ($driver === null) {
+            $driver = $this->getDefaultDriver();
+        }
+
+        $config = $this->getConfig($driver);
+
+        return $config['config']['limit'] ?? [];
+    }
+
     /**
      * Dynamically call the default driver instance.
      */

src/Translate/Yandex/Connection.php

@@ -1,6 +1,6 @@
 <?php declare(strict_types=1);
 
-namespace korElf\TranslateLaravel\Translate\Yandex;
+namespace KorElf\TranslateLaravel\Translate\Yandex;
 
 use Illuminate\Support\Facades\Http;
 use Illuminate\Support\Facades\Cache;
@@ -10,15 +10,15 @@ use Jose\Component\KeyManagement\JWKFactory;
 use Jose\Component\Signature\Algorithm\PS256;
 use Jose\Component\Signature\JWSBuilder;
 use Jose\Component\Signature\Serializer\CompactSerializer;
-use korElf\TranslateLaravel\Exceptions\TranslateException;
+use KorElf\TranslateLaravel\Exceptions\TranslateException;
 
 final class Connection
 {
-    private readonly string $path;
-    private readonly string $folderId;
-    private readonly string $privateKey;
-    private readonly string $keyId;
-    private readonly string $serviceAccountId;
+    private string $path;
+    private string $folderId;
+    private string $privateKey;
+    private string $keyId;
+    private string $serviceAccountId;
 
     public function __construct(string $path, string $folderId, string $privateKey, string $keyId, string $serviceAccountId)
     {

src/Translate/YandexDriver.php

@@ -1,11 +1,11 @@
 <?php declare(strict_types=1);
 
-namespace korElf\TranslateLaravel\Translate;
+namespace KorElf\TranslateLaravel\Translate;
 
-use korElf\TranslateLaravel\Contracts\Translate;
-use korElf\TranslateLaravel\DTO\Languages;
-use korElf\TranslateLaravel\Exceptions\TranslateException;
-use korElf\TranslateLaravel\Translate\Yandex\Connection;
+use KorElf\TranslateLaravel\Contracts\Translate;
+use KorElf\TranslateLaravel\DTO\Languages;
+use KorElf\TranslateLaravel\Exceptions\TranslateException;
+use KorElf\TranslateLaravel\Translate\Yandex\Connection;
 use Illuminate\Contracts\Foundation\Application;
 
 final class YandexDriver implements Translate

src/TranslateLaravelProvider.php

@@ -1,10 +1,13 @@
 <?php declare(strict_types=1);
 
-namespace korElf\TranslateLaravel;
+namespace KorElf\TranslateLaravel;
 
+use Illuminate\Cache\RateLimiting\Limit;
+use Illuminate\Support\Facades\RateLimiter;
 use Illuminate\Support\ServiceProvider;
 use Illuminate\Contracts\Foundation\Application;
-use korElf\TranslateLaravel\Translate\TranslateManager;
+use KorElf\TranslateLaravel\Contracts\ProcessTranslateContract;
+use KorElf\TranslateLaravel\Translate\TranslateManager;
 
 final class TranslateLaravelProvider extends ServiceProvider
 {
@@ -13,6 +16,15 @@ final class TranslateLaravelProvider extends ServiceProvider
         $this->publishes([
             __DIR__ . '/../config/translate.php' => config_path('translate.php'),
         ], 'config');
+
+        RateLimiter::for('kor-elf-translate', function (ProcessTranslateContract $job) {
+            $limited = $job->getLimited();
+
+            return Limit::perSecond(
+                $limited->getMaxRequest(),
+                $limited->getRateSeconds()
+            )->by($limited->getDriver());
+        });
     }
 
     /**
@@ -26,7 +38,6 @@ final class TranslateLaravelProvider extends ServiceProvider
             __DIR__ . '/../config/translate.php',
             'translate'
         );
-
         $this->app->singleton('translate', function (Application $app) {
             return new TranslateManager($app);
         });