/* This file is part of Telegram Desktop, the official desktop application for the Telegram messaging service. For license and copyright information please follow this link: https://github.com/telegramdesktop/tdesktop/blob/master/LEGAL */ #include "storage/localimageloader.h" #include "api/api_text_entities.h" #include "api/api_sending.h" #include "data/data_document.h" #include "data/data_session.h" #include "core/file_utilities.h" #include "core/mime_type.h" #include "base/unixtime.h" #include "media/audio/media_audio.h" #include "media/clip/media_clip_reader.h" #include "mtproto/facade.h" #include "lottie/lottie_animation.h" #include "history/history.h" #include "history/history_item.h" #include "boxes/send_files_box.h" #include "boxes/confirm_box.h" #include "lang/lang_keys.h" #include "storage/file_download.h" #include "storage/storage_media_prepare.h" #include "window/themes/window_theme_preview.h" #include "mainwidget.h" #include "mainwindow.h" #include "main/main_session.h" #include "app.h" #include #include namespace { constexpr auto kThumbnailQuality = 87; constexpr auto kThumbnailSize = 320; constexpr auto kPhotoUploadPartSize = 32 * 1024; using Ui::ValidateThumbDimensions; struct PreparedFileThumbnail { uint64 id = 0; QString name; QImage image; QByteArray bytes; MTPPhotoSize mtpSize = MTP_photoSizeEmpty(MTP_string()); }; PreparedFileThumbnail PrepareFileThumbnail(QImage &&original) { const auto width = original.width(); const auto height = original.height(); if (!ValidateThumbDimensions(width, height)) { return {}; } auto result = PreparedFileThumbnail(); result.id = rand_value(); const auto scaled = (width > kThumbnailSize || height > kThumbnailSize); const auto scaledWidth = [&] { return (width > height) ? kThumbnailSize : int(std::round(kThumbnailSize * width / float64(height))); }; const auto scaledHeight = [&] { return (width > height) ? int(std::round(kThumbnailSize * height / float64(width))) : kThumbnailSize; }; result.image = scaled ? original.scaled( scaledWidth(), scaledHeight(), Qt::IgnoreAspectRatio, Qt::SmoothTransformation) : std::move(original); result.mtpSize = MTP_photoSize( MTP_string(), MTP_fileLocationToBeDeprecated(MTP_long(0), MTP_int(0)), MTP_int(result.image.width()), MTP_int(result.image.height()), MTP_int(0)); return result; } bool FileThumbnailUploadRequired(const QString &filemime, int32 filesize) { constexpr auto kThumbnailUploadBySize = 5 * 1024 * 1024; const auto kThumbnailKnownMimes = { "image/jpeg", "image/gif", "image/png", "image/webp", "video/mp4", }; return (filesize > kThumbnailUploadBySize) || (ranges::find(kThumbnailKnownMimes, filemime.toLower()) == end(kThumbnailKnownMimes)); } PreparedFileThumbnail FinalizeFileThumbnail( PreparedFileThumbnail &&prepared, const QString &filemime, int32 filesize, bool isSticker) { prepared.name = isSticker ? qsl("thumb.webp") : qsl("thumb.jpg"); if (FileThumbnailUploadRequired(filemime, filesize)) { const auto format = QByteArray(isSticker ? "WEBP" : "JPG"); auto buffer = QBuffer(&prepared.bytes); prepared.image.save(&buffer, format, kThumbnailQuality); } return std::move(prepared); } auto FindAlbumItem( std::vector &items, not_null item) { const auto result = ranges::find( items, item->fullId(), &SendingAlbum::Item::msgId); Ensures(result != end(items)); return result; } MTPInputSingleMedia PrepareAlbumItemMedia( not_null item, const MTPInputMedia &media, uint64 randomId) { auto caption = item->originalText(); TextUtilities::Trim(caption); auto sentEntities = Api::EntitiesToMTP( &item->history()->session(), caption.entities, Api::ConvertOption::SkipLocal); const auto flags = !sentEntities.v.isEmpty() ? MTPDinputSingleMedia::Flag::f_entities : MTPDinputSingleMedia::Flag(0); return MTP_inputSingleMedia( MTP_flags(flags), media, MTP_long(randomId), MTP_string(caption.text), sentEntities); } } // namespace SendMediaReady::SendMediaReady( SendMediaType type, const QString &file, const QString &filename, int32 filesize, const QByteArray &data, const uint64 &id, const uint64 &thumbId, const QString &thumbExt, const PeerId &peer, const MTPPhoto &photo, const PreparedPhotoThumbs &photoThumbs, const MTPDocument &document, const QByteArray &jpeg, MsgId replyTo) : replyTo(replyTo) , type(type) , file(file) , filename(filename) , filesize(filesize) , data(data) , thumbExt(thumbExt) , id(id) , thumbId(thumbId) , peer(peer) , photo(photo) , document(document) , photoThumbs(photoThumbs) { if (!jpeg.isEmpty()) { int32 size = jpeg.size(); for (int32 i = 0, part = 0; i < size; i += kPhotoUploadPartSize, ++part) { parts.insert(part, jpeg.mid(i, kPhotoUploadPartSize)); } jpeg_md5.resize(32); hashMd5Hex(jpeg.constData(), jpeg.size(), jpeg_md5.data()); } } SendMediaReady PreparePeerPhoto(MTP::DcId dcId, PeerId peerId, QImage &&image) { PreparedPhotoThumbs photoThumbs; QVector photoSizes; QByteArray jpeg; QBuffer jpegBuffer(&jpeg); image.save(&jpegBuffer, "JPG", 87); const auto scaled = [&](int size) { return image.scaled( size, size, Qt::KeepAspectRatio, Qt::SmoothTransformation); }; const auto push = [&]( const char *type, QImage &&image, QByteArray bytes = QByteArray()) { photoSizes.push_back(MTP_photoSize( MTP_string(type), MTP_fileLocationToBeDeprecated(MTP_long(0), MTP_int(0)), MTP_int(image.width()), MTP_int(image.height()), MTP_int(0))); photoThumbs.emplace(type[0], PreparedPhotoThumb{ .image = std::move(image), .bytes = std::move(bytes) }); }; push("a", scaled(160)); push("b", scaled(320)); push("c", std::move(image), jpeg); const auto id = rand_value(); const auto photo = MTP_photo( MTP_flags(0), MTP_long(id), MTP_long(0), MTP_bytes(), MTP_int(base::unixtime::now()), MTP_vector(photoSizes), MTPVector(), MTP_int(dcId)); QString file, filename; int32 filesize = 0; QByteArray data; return SendMediaReady( SendMediaType::Photo, file, filename, filesize, data, id, id, qsl("jpg"), peerId, photo, photoThumbs, MTP_documentEmpty(MTP_long(0)), jpeg, 0); } TaskQueue::TaskQueue(crl::time stopTimeoutMs) { if (stopTimeoutMs > 0) { _stopTimer = new QTimer(this); connect(_stopTimer, SIGNAL(timeout()), this, SLOT(stop())); _stopTimer->setSingleShot(true); _stopTimer->setInterval(int(stopTimeoutMs)); } } TaskId TaskQueue::addTask(std::unique_ptr &&task) { const auto result = task->id(); { QMutexLocker lock(&_tasksToProcessMutex); _tasksToProcess.push_back(std::move(task)); } wakeThread(); return result; } void TaskQueue::addTasks(std::vector> &&tasks) { { QMutexLocker lock(&_tasksToProcessMutex); for (auto &task : tasks) { _tasksToProcess.push_back(std::move(task)); } } wakeThread(); } void TaskQueue::wakeThread() { if (!_thread) { _thread = new QThread(); _worker = new TaskQueueWorker(this); _worker->moveToThread(_thread); connect(this, SIGNAL(taskAdded()), _worker, SLOT(onTaskAdded())); connect(_worker, SIGNAL(taskProcessed()), this, SLOT(onTaskProcessed())); _thread->start(); } if (_stopTimer) _stopTimer->stop(); emit taskAdded(); } void TaskQueue::cancelTask(TaskId id) { const auto removeFrom = [&](std::deque> &queue) { const auto proj = [](const std::unique_ptr &task) { return task->id(); }; auto i = ranges::find(queue, id, proj); if (i != queue.end()) { queue.erase(i); } }; { QMutexLocker lock(&_tasksToProcessMutex); removeFrom(_tasksToProcess); if (_taskInProcessId == id) { _taskInProcessId = TaskId(); } } QMutexLocker lock(&_tasksToFinishMutex); removeFrom(_tasksToFinish); } void TaskQueue::onTaskProcessed() { do { auto task = std::unique_ptr(); { QMutexLocker lock(&_tasksToFinishMutex); if (_tasksToFinish.empty()) break; task = std::move(_tasksToFinish.front()); _tasksToFinish.pop_front(); } task->finish(); } while (true); if (_stopTimer) { QMutexLocker lock(&_tasksToProcessMutex); if (_tasksToProcess.empty() && !_taskInProcessId) { _stopTimer->start(); } } } void TaskQueue::stop() { if (_thread) { _thread->requestInterruption(); _thread->quit(); DEBUG_LOG(("Waiting for taskThread to finish")); _thread->wait(); delete base::take(_worker); delete base::take(_thread); } _tasksToProcess.clear(); _tasksToFinish.clear(); _taskInProcessId = TaskId(); } TaskQueue::~TaskQueue() { stop(); delete _stopTimer; } void TaskQueueWorker::onTaskAdded() { if (_inTaskAdded) return; _inTaskAdded = true; bool someTasksLeft = false; do { auto task = std::unique_ptr(); { QMutexLocker lock(&_queue->_tasksToProcessMutex); if (!_queue->_tasksToProcess.empty()) { task = std::move(_queue->_tasksToProcess.front()); _queue->_tasksToProcess.pop_front(); _queue->_taskInProcessId = task->id(); } } if (task) { task->process(); bool emitTaskProcessed = false; { QMutexLocker lockToProcess(&_queue->_tasksToProcessMutex); if (_queue->_taskInProcessId == task->id()) { _queue->_taskInProcessId = TaskId(); someTasksLeft = !_queue->_tasksToProcess.empty(); QMutexLocker lockToFinish(&_queue->_tasksToFinishMutex); emitTaskProcessed = _queue->_tasksToFinish.empty(); _queue->_tasksToFinish.push_back(std::move(task)); } } if (emitTaskProcessed) { emit taskProcessed(); } } QCoreApplication::processEvents(); } while (someTasksLeft && !thread()->isInterruptionRequested()); _inTaskAdded = false; } SendingAlbum::SendingAlbum() : groupId(rand_value()) { } void SendingAlbum::fillMedia( not_null item, const MTPInputMedia &media, uint64 randomId) { const auto i = FindAlbumItem(items, item); Assert(!i->media); i->randomId = randomId; i->media = PrepareAlbumItemMedia(item, media, randomId); } void SendingAlbum::refreshMediaCaption(not_null item) { const auto i = FindAlbumItem(items, item); if (!i->media) { return; } i->media = i->media->match([&](const MTPDinputSingleMedia &data) { return PrepareAlbumItemMedia( item, data.vmedia(), data.vrandom_id().v); }); } void SendingAlbum::removeItem(not_null item) { const auto localId = item->fullId(); const auto i = ranges::find(items, localId, &Item::msgId); const auto moveCaption = (items.size() > 1) && (i == begin(items)); Assert(i != end(items)); items.erase(i); if (moveCaption) { const auto caption = item->originalText(); const auto firstId = items.front().msgId; if (const auto first = item->history()->owner().message(firstId)) { // We don't need to finishEdition() here, because the whole // album will be rebuilt after one item was removed from it. first->setText(caption); refreshMediaCaption(first); } } } FileLoadResult::FileLoadResult( TaskId taskId, uint64 id, const FileLoadTo &to, const TextWithTags &caption, std::shared_ptr album) : taskId(taskId) , id(id) , to(to) , album(std::move(album)) , caption(caption) { } void FileLoadResult::setFileData(const QByteArray &filedata) { if (filedata.isEmpty()) { partssize = 0; } else { partssize = filedata.size(); for (int32 i = 0, part = 0; i < partssize; i += kPhotoUploadPartSize, ++part) { fileparts.insert(part, filedata.mid(i, kPhotoUploadPartSize)); } filemd5.resize(32); hashMd5Hex(filedata.constData(), filedata.size(), filemd5.data()); } } void FileLoadResult::setThumbData(const QByteArray &thumbdata) { if (!thumbdata.isEmpty()) { thumbbytes = thumbdata; int32 size = thumbdata.size(); for (int32 i = 0, part = 0; i < size; i += kPhotoUploadPartSize, ++part) { thumbparts.insert(part, thumbdata.mid(i, kPhotoUploadPartSize)); } thumbmd5.resize(32); hashMd5Hex(thumbdata.constData(), thumbdata.size(), thumbmd5.data()); } } FileLoadTask::FileLoadTask( not_null session, const QString &filepath, const QByteArray &content, std::unique_ptr information, SendMediaType type, const FileLoadTo &to, const TextWithTags &caption, std::shared_ptr album, MsgId msgIdToEdit) : _id(rand_value()) , _session(session) , _dcId(session->mainDcId()) , _to(to) , _album(std::move(album)) , _filepath(filepath) , _content(content) , _information(std::move(information)) , _type(type) , _caption(caption) , _msgIdToEdit(msgIdToEdit) { Expects(to.options.scheduled || (_msgIdToEdit == 0 || IsServerMsgId(_msgIdToEdit))); } FileLoadTask::FileLoadTask( not_null session, const QByteArray &voice, int32 duration, const VoiceWaveform &waveform, const FileLoadTo &to, const TextWithTags &caption) : _id(rand_value()) , _session(session) , _dcId(session->mainDcId()) , _to(to) , _content(voice) , _duration(duration) , _waveform(waveform) , _type(SendMediaType::Audio) , _caption(caption) { } FileLoadTask::~FileLoadTask() = default; auto FileLoadTask::ReadMediaInformation( const QString &filepath, const QByteArray &content, const QString &filemime) -> std::unique_ptr { auto result = std::make_unique(); result->filemime = filemime; if (CheckForSong(filepath, content, result)) { return result; } else if (CheckForVideo(filepath, content, result)) { return result; } else if (CheckForImage(filepath, content, result)) { return result; } return result; } template bool FileLoadTask::CheckMimeOrExtensions( const QString &filepath, const QString &filemime, Mimes &mimes, Extensions &extensions) { if (std::find(std::begin(mimes), std::end(mimes), filemime) != std::end(mimes)) { return true; } if (std::find_if(std::begin(extensions), std::end(extensions), [&filepath](auto &extension) { return filepath.endsWith(extension, Qt::CaseInsensitive); }) != std::end(extensions)) { return true; } return false; } bool FileLoadTask::CheckForSong( const QString &filepath, const QByteArray &content, std::unique_ptr &result) { static const auto mimes = { qstr("audio/mp3"), qstr("audio/m4a"), qstr("audio/aac"), qstr("audio/ogg"), qstr("audio/flac"), qstr("audio/opus"), }; static const auto extensions = { qstr(".mp3"), qstr(".m4a"), qstr(".aac"), qstr(".ogg"), qstr(".flac"), qstr(".opus"), qstr(".oga"), }; if (!filepath.isEmpty() && !CheckMimeOrExtensions( filepath, result->filemime, mimes, extensions)) { return false; } auto media = Media::Player::PrepareForSending(filepath, content); if (media.duration < 0) { return false; } if (!ValidateThumbDimensions(media.cover.width(), media.cover.height())) { media.cover = QImage(); } result->media = std::move(media); return true; } bool FileLoadTask::CheckForVideo( const QString &filepath, const QByteArray &content, std::unique_ptr &result) { static const auto mimes = { qstr("video/mp4"), qstr("video/quicktime"), }; static const auto extensions = { qstr(".mp4"), qstr(".mov"), }; if (!CheckMimeOrExtensions(filepath, result->filemime, mimes, extensions)) { return false; } auto media = Media::Clip::PrepareForSending(filepath, content); if (media.duration < 0) { return false; } auto coverWidth = media.thumbnail.width(); auto coverHeight = media.thumbnail.height(); if (!ValidateThumbDimensions(coverWidth, coverHeight)) { return false; } if (filepath.endsWith(qstr(".mp4"), Qt::CaseInsensitive)) { result->filemime = qstr("video/mp4"); } result->media = std::move(media); return true; } bool FileLoadTask::CheckForImage( const QString &filepath, const QByteArray &content, std::unique_ptr &result) { auto animated = false; auto image = [&] { if (filepath.endsWith(qstr(".tgs"), Qt::CaseInsensitive)) { auto image = Lottie::ReadThumbnail( Lottie::ReadContent(content, filepath)); if (!image.isNull()) { animated = true; result->filemime = qstr("application/x-tgsticker"); } return image; } if (!content.isEmpty()) { return App::readImage(content, nullptr, false, &animated); } else if (!filepath.isEmpty()) { return App::readImage(filepath, nullptr, false, &animated); } return QImage(); }(); return FillImageInformation(std::move(image), animated, result); } bool FileLoadTask::FillImageInformation( QImage &&image, bool animated, std::unique_ptr &result) { Expects(result != nullptr); if (image.isNull()) { return false; } auto media = Ui::PreparedFileInformation::Image(); media.data = std::move(image); media.animated = animated; result->media = media; return true; } void FileLoadTask::process(Args &&args) { _result = std::make_shared( id(), _id, _to, _caption, _album); _result->edit = (_msgIdToEdit > 0); QString filename, filemime; qint64 filesize = 0; QByteArray filedata; auto isAnimation = false; auto isSong = false; auto isVideo = false; auto isVoice = (_type == SendMediaType::Audio); auto isSticker = false; auto fullimage = QImage(); auto info = _filepath.isEmpty() ? QFileInfo() : QFileInfo(_filepath); if (info.exists()) { if (info.isDir()) { _result->filesize = -1; return; } // Voice sending is supported only from memory for now. // Because for voice we force mime type and don't read MediaInformation. // For a real file we always read mime type and read MediaInformation. Assert(!isVoice); filesize = info.size(); filename = info.fileName(); if (!_information) { _information = readMediaInformation(Core::MimeTypeForFile(info).name()); } filemime = _information->filemime; if (auto image = std::get_if( &_information->media)) { fullimage = base::take(image->data); if (!Core::IsMimeSticker(filemime)) { fullimage = Images::prepareOpaque(std::move(fullimage)); } isAnimation = image->animated; } } else if (!_content.isEmpty()) { filesize = _content.size(); if (isVoice) { filename = filedialogDefaultName(qsl("audio"), qsl(".ogg"), QString(), true); filemime = "audio/ogg"; } else { if (_information) { if (auto image = std::get_if( &_information->media)) { fullimage = base::take(image->data); } } const auto mimeType = Core::MimeTypeForData(_content); filemime = mimeType.name(); if (!Core::IsMimeSticker(filemime)) { fullimage = Images::prepareOpaque(std::move(fullimage)); } if (filemime == "image/jpeg") { filename = filedialogDefaultName(qsl("photo"), qsl(".jpg"), QString(), true); } else if (filemime == "image/png") { filename = filedialogDefaultName(qsl("image"), qsl(".png"), QString(), true); } else { QString ext; QStringList patterns = mimeType.globPatterns(); if (!patterns.isEmpty()) { ext = patterns.front().replace('*', QString()); } filename = filedialogDefaultName(qsl("file"), ext, QString(), true); } } } else { if (_information) { if (auto image = std::get_if( &_information->media)) { fullimage = base::take(image->data); } } if (!fullimage.isNull() && fullimage.width() > 0) { if (_type == SendMediaType::Photo) { if (ValidateThumbDimensions(fullimage.width(), fullimage.height())) { filesize = -1; // Fill later. filemime = Core::MimeTypeForName("image/jpeg").name(); filename = filedialogDefaultName(qsl("image"), qsl(".jpg"), QString(), true); } else { _type = SendMediaType::File; } } if (_type == SendMediaType::File) { filemime = Core::MimeTypeForName("image/png").name(); filename = filedialogDefaultName(qsl("image"), qsl(".png"), QString(), true); { QBuffer buffer(&_content); fullimage.save(&buffer, "PNG"); } filesize = _content.size(); } fullimage = Images::prepareOpaque(std::move(fullimage)); } } _result->filesize = (int32)qMin(filesize, qint64(INT_MAX)); if (!filesize || filesize > kFileSizeLimit) { return; } PreparedPhotoThumbs photoThumbs; QVector photoSizes; QImage goodThumbnail; QByteArray goodThumbnailBytes; QVector attributes(1, MTP_documentAttributeFilename(MTP_string(filename))); auto thumbnail = PreparedFileThumbnail(); auto photo = MTP_photoEmpty(MTP_long(0)); auto document = MTP_documentEmpty(MTP_long(0)); if (!isVoice) { if (!_information) { _information = readMediaInformation(filemime); filemime = _information->filemime; } if (auto song = std::get_if( &_information->media)) { isSong = true; auto flags = MTPDdocumentAttributeAudio::Flag::f_title | MTPDdocumentAttributeAudio::Flag::f_performer; attributes.push_back(MTP_documentAttributeAudio(MTP_flags(flags), MTP_int(song->duration), MTP_string(song->title), MTP_string(song->performer), MTPstring())); thumbnail = PrepareFileThumbnail(std::move(song->cover)); } else if (auto video = std::get_if( &_information->media)) { isVideo = true; auto coverWidth = video->thumbnail.width(); auto coverHeight = video->thumbnail.height(); if (video->isGifv && !_album) { attributes.push_back(MTP_documentAttributeAnimated()); } auto flags = MTPDdocumentAttributeVideo::Flags(0); if (video->supportsStreaming) { flags |= MTPDdocumentAttributeVideo::Flag::f_supports_streaming; } attributes.push_back(MTP_documentAttributeVideo(MTP_flags(flags), MTP_int(video->duration), MTP_int(coverWidth), MTP_int(coverHeight))); if (args.generateGoodThumbnail) { goodThumbnail = video->thumbnail; { QBuffer buffer(&goodThumbnailBytes); goodThumbnail.save(&buffer, "JPG", kThumbnailQuality); } } thumbnail = PrepareFileThumbnail(std::move(video->thumbnail)); } else if (filemime == qstr("application/x-tdesktop-theme") || filemime == qstr("application/x-tgtheme-tdesktop")) { goodThumbnail = Window::Theme::GeneratePreview(_content, _filepath); if (!goodThumbnail.isNull()) { QBuffer buffer(&goodThumbnailBytes); goodThumbnail.save(&buffer, "JPG", kThumbnailQuality); thumbnail = PrepareFileThumbnail(base::duplicate(goodThumbnail)); } } } if (!fullimage.isNull() && fullimage.width() > 0 && !isSong && !isVideo && !isVoice) { auto w = fullimage.width(), h = fullimage.height(); attributes.push_back(MTP_documentAttributeImageSize(MTP_int(w), MTP_int(h))); if (ValidateThumbDimensions(w, h)) { isSticker = Core::IsMimeSticker(filemime) && (filesize < Storage::kMaxStickerBytesSize) && (Core::IsMimeStickerAnimated(filemime) || GoodStickerDimensions(w, h)); if (isSticker) { attributes.push_back(MTP_documentAttributeSticker( MTP_flags(0), MTP_string(), MTP_inputStickerSetEmpty(), MTPMaskCoords())); if (isAnimation && args.generateGoodThumbnail) { goodThumbnail = fullimage; { QBuffer buffer(&goodThumbnailBytes); goodThumbnail.save(&buffer, "WEBP", kThumbnailQuality); } } } else if (isAnimation) { attributes.push_back(MTP_documentAttributeAnimated()); } else if (_type != SendMediaType::File) { auto medium = (w > 320 || h > 320) ? fullimage.scaled(320, 320, Qt::KeepAspectRatio, Qt::SmoothTransformation) : fullimage; auto full = (w > 1280 || h > 1280) ? fullimage.scaled(1280, 1280, Qt::KeepAspectRatio, Qt::SmoothTransformation) : fullimage; { QBuffer buffer(&filedata); QImageWriter writer(&buffer, "JPEG"); writer.setQuality(87); writer.setProgressiveScanWrite(true); writer.write(full); } photoThumbs.emplace('m', PreparedPhotoThumb{ .image = medium }); photoSizes.push_back(MTP_photoSize(MTP_string("m"), MTP_fileLocationToBeDeprecated(MTP_long(0), MTP_int(0)), MTP_int(medium.width()), MTP_int(medium.height()), MTP_int(0))); photoThumbs.emplace('y', PreparedPhotoThumb{ .image = full, .bytes = filedata }); photoSizes.push_back(MTP_photoSize(MTP_string("y"), MTP_fileLocationToBeDeprecated(MTP_long(0), MTP_int(0)), MTP_int(full.width()), MTP_int(full.height()), MTP_int(0))); photo = MTP_photo( MTP_flags(0), MTP_long(_id), MTP_long(0), MTP_bytes(), MTP_int(base::unixtime::now()), MTP_vector(photoSizes), MTPVector(), MTP_int(_dcId)); if (filesize < 0) { filesize = _result->filesize = filedata.size(); } } thumbnail = PrepareFileThumbnail(std::move(fullimage)); } } thumbnail = FinalizeFileThumbnail( std::move(thumbnail), filemime, filesize, isSticker); if (_type == SendMediaType::Photo && photo.type() == mtpc_photoEmpty) { _type = SendMediaType::File; } if (isVoice) { auto flags = MTPDdocumentAttributeAudio::Flag::f_voice | MTPDdocumentAttributeAudio::Flag::f_waveform; attributes[0] = MTP_documentAttributeAudio(MTP_flags(flags), MTP_int(_duration), MTPstring(), MTPstring(), MTP_bytes(documentWaveformEncode5bit(_waveform))); attributes.resize(1); document = MTP_document( MTP_flags(0), MTP_long(_id), MTP_long(0), MTP_bytes(), MTP_int(base::unixtime::now()), MTP_string(filemime), MTP_int(filesize), MTP_vector(1, thumbnail.mtpSize), MTPVector(), MTP_int(_dcId), MTP_vector(attributes)); } else if (_type != SendMediaType::Photo) { document = MTP_document( MTP_flags(0), MTP_long(_id), MTP_long(0), MTP_bytes(), MTP_int(base::unixtime::now()), MTP_string(filemime), MTP_int(filesize), MTP_vector(1, thumbnail.mtpSize), MTPVector(), MTP_int(_dcId), MTP_vector(attributes)); _type = SendMediaType::File; } _result->type = _type; _result->filepath = _filepath; _result->content = _content; _result->filename = filename; _result->filemime = filemime; _result->setFileData(filedata); _result->thumbId = thumbnail.id; _result->thumbname = thumbnail.name; _result->setThumbData(thumbnail.bytes); _result->thumb = std::move(thumbnail.image); _result->goodThumbnail = std::move(goodThumbnail); _result->goodThumbnailBytes = std::move(goodThumbnailBytes); _result->photo = photo; _result->document = document; _result->photoThumbs = photoThumbs; } void FileLoadTask::finish() { if (!_result || !_result->filesize || _result->filesize < 0) { Ui::show( Box( tr::lng_send_image_empty(tr::now, lt_name, _filepath)), Ui::LayerOption::KeepOther); removeFromAlbum(); } else if (_result->filesize > kFileSizeLimit) { Ui::show( Box( tr::lng_send_image_too_large(tr::now, lt_name, _filepath)), Ui::LayerOption::KeepOther); removeFromAlbum(); } else if (const auto session = _session.get()) { const auto fullId = _msgIdToEdit ? std::make_optional(FullMsgId( peerToChannel(_to.peer), _msgIdToEdit)) : std::nullopt; Api::SendConfirmedFile(session, _result, fullId); } } FileLoadResult *FileLoadTask::peekResult() const { return _result.get(); } std::unique_ptr FileLoadTask::readMediaInformation( const QString &filemime) const { return ReadMediaInformation(_filepath, _content, filemime); } void FileLoadTask::removeFromAlbum() { if (!_album) { return; } const auto proj = [](const SendingAlbum::Item &item) { return item.taskId; }; const auto it = ranges::find(_album->items, id(), proj); Assert(it != _album->items.end()); _album->items.erase(it); }