SkayperTeam
commented
1 week ago I will also add the code of my new attempt. I have taken out the file processing and now I am trying to understand more clearly what file I am dealing with when forming "multi_media"
Output logger('mediaResultArray', [$media]):
[
{
"media": {
"_": "inputMediaUploadedPhoto",
"file": {
"danog\\MadelineProto\\LocalFile": {
"file": "/home/vlad/Desktop/projects/telegram-bot-chicko/storage/app/public/2/01J79Z355SW6DQMCMATD0VFZTY.png"
}
}
},
"message": "<p>test</p><br /><br /> @eteeeeernal",
"parse_mode": {
"danog\\MadelineProto\\ParseMode": "HTML"
}
}
]<?php
namespace App\Console\Commands;
use App\MailingStatusEnum;
use App\Models\Mailing;
use App\Models\TelegramGroup;
use App\Models\TelegramUser;
use App\Models\Topic;
use danog\MadelineProto\API;
use danog\MadelineProto\LocalFile;
use danog\MadelineProto\ParseMode;
use danog\MadelineProto\RemoteUrl;
use Illuminate\Console\Command;
use Throwable;
class SendMailingsCommand extends Command
{
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'app:send-mailings-command';
/**
* The console command description.
*
* @var string
*/
protected $description = 'Проверяет все рассылки в статусе new и отправляет';
/**
* Execute the console command.
*/
public function handle(): void
{
$madelineProto = new API('session.madeline');
Mailing::query()
->where('status', MailingStatusEnum::NEW)
->each(function (Mailing $mailing) use ($madelineProto) {
try {
$mailing->update(['status' => MailingStatusEnum::PROCESSING]);
foreach ($mailing->telegram_group_ids as $telegramGroupId) {
$group = TelegramGroup::query()->find($telegramGroupId);
$text = str_replace(' ', ' ', $mailing->text) . '<br /><br />';
$group
->usersWithRoles()
->whereIn('role_id', $mailing->role_ids)
->each(function (TelegramUser $telegramUser) use (&$text) {
$text .= $telegramUser->telegram_tag ? ' @'.$telegramUser->telegram_tag : " <a href='tg://user?id={$telegramUser->id}'>$telegramUser->name</a>";
});
$media = [];
$mediaFiles = $mailing->getMedia();
foreach ($mediaFiles as $index => $mediaFile) {
// $filePath = $mediaFile->getPath();
if ($file = $this->handleFile($mediaFile, $index, $text)) {
logger('file', [$file]);
$media[] = $file;
}
}
logger('mediaResultArray', [$media]);
$mailing->update([
'media_files' => $media
]);
$group
->topics()
->whereIn('name', $mailing->topic_ids)
->each(fn(Topic $topic) => count($media) === 0
? $madelineProto
->sendMessage(
peer: $group->telegram_id,
message: $text,
parseMode: ParseMode::HTML,
replyToMsgId: $topic->topic_id,
topMsgId: $topic->topic_id,
)
: $madelineProto
->messages
->sendMultiMedia(
peer: $group->telegram_id,
reply_to_msg_id: $topic->topic_id,
top_msg_id: $topic->topic_id,
multi_media: $media,
)
);
}
$mailing->update(['status' => MailingStatusEnum::SENDED]);
} catch (Throwable $e) {
logger("error", [$e]);
$mailing->update([
'status' => MailingStatusEnum::FAILED,
'error' => [$e],
]);
}
});
}
protected function handleFile($mediaFile, int $index, string $text): array|null
{
$filePath = $mediaFile->getPath();
$mimeType = mime_content_type($filePath);
// Логика для обработки различных типов медиафайлов
if (strpos($mimeType, 'image') !== false) {
// images
return [
'media' => [
'_' => 'inputMediaUploadedPhoto',
'file' => new LocalFile($filePath),
],
'message' => $index === 0 ? $text : '',
'parse_mode' => ParseMode::HTML,
];
} elseif (strpos($mimeType, 'video') !== false) {
// videos
return [
'media' => [
'_' => 'inputMediaUploadedDocument',
'file' => new LocalFile($filePath),
'mime_type' => $mimeType,
'attributes' => [
['_' => 'documentAttributeVideo', 'supports_streaming' => true]
]
],
'message' => $index === 0 ? $text : '',
'parse_mode' => ParseMode::HTML,
];
} elseif (strpos($mimeType, 'audio') !== false) {
// audios
return [
'media' => [
'_' => 'inputMediaUploadedDocument',
'file' => new LocalFile($filePath),
'mime_type' => $mimeType,
'attributes' => [
['_' => 'documentAttributeAudio', 'voice' => false]
]
],
'message' => $index === 0 ? $text : '',
'parse_mode' => ParseMode::HTML,
];
} elseif (strpos($mimeType, 'application') !== false) {
//(PDF, JSON, ZIP, ...)
return [
'media' => [
'_' => 'inputMediaUploadedDocument',
'file' => new LocalFile($filePath),
'mime_type' => $mimeType,
'attributes' => [
['_' => 'documentAttributeFilename', 'file_name' => basename($filePath)]
]
],
'message' => $index === 0 ? $text : '',
'parse_mode' => ParseMode::HTML,
];
} elseif (strpos($mimeType, 'text') !== false) {
// (HTML, plain text, ...)
return [
'media' => [
'_' => 'inputMediaUploadedDocument',
'file' => new LocalFile($filePath),
'mime_type' => $mimeType,
'attributes' => [
['_' => 'documentAttributeFilename', 'file_name' => basename($filePath)]
]
],
'message' => $index === 0 ? $text : '',
'parse_mode' => ParseMode::HTML,
];
}
return null;
}
}
php: 8.2 laravel/framework": 11.22.0 danog/madelineproto: 8.3.0
Hello! I'm trying to execute the following code:
When I run it I get the error:
I can’t figure out what attribute I need to pass and how to proceed? In my case, in theory, json, mp4, png, jpeg and others can be transmitted. Please tell me what to do?
*If necessary, I can send you the full error trace.