/* This file is part of Telegram Desktop, the official desktop version of Telegram messaging app, see https://telegram.org Telegram Desktop 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. It 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. In addition, as a special exception, the copyright holders give permission to link the code of portions of this program with the OpenSSL library. Full license: https://github.com/telegramdesktop/tdesktop/blob/master/LICENSE Copyright (c) 2014-2016 John Preston, https://desktop.telegram.org */ #include "stdafx.h" #include "style.h" #include "lang.h" #include "history.h" #include "mainwidget.h" #include "application.h" #include "fileuploader.h" #include "window.h" #include "gui/filedialog.h" #include "boxes/confirmbox.h" #include "audio.h" #include "localstorage.h" namespace { int32 peerColorIndex(const PeerId &peer) { int32 myId(MTP::authedId()), peerId(peerToBareInt(peer)); QByteArray both(qsl("%1%2").arg(peerId).arg(myId).toUtf8()); if (both.size() > 15) { both = both.mid(0, 15); } uchar md5[16]; hashMd5(both.constData(), both.size(), md5); return (md5[peerId & 0x0F] & (peerIsUser(peer) ? 0x07 : 0x03)); } } style::color peerColor(int32 index) { static const style::color peerColors[8] = { style::color(st::color1), style::color(st::color2), style::color(st::color3), style::color(st::color4), style::color(st::color5), style::color(st::color6), style::color(st::color7), style::color(st::color8) }; return peerColors[index]; } ImagePtr userDefPhoto(int32 index) { static const ImagePtr userDefPhotos[UserColorsCount] = { ImagePtr(qsl(":/ava/art/usercolor1.png"), "PNG"), ImagePtr(qsl(":/ava/art/usercolor2.png"), "PNG"), ImagePtr(qsl(":/ava/art/usercolor3.png"), "PNG"), ImagePtr(qsl(":/ava/art/usercolor4.png"), "PNG"), ImagePtr(qsl(":/ava/art/usercolor5.png"), "PNG"), ImagePtr(qsl(":/ava/art/usercolor6.png"), "PNG"), ImagePtr(qsl(":/ava/art/usercolor7.png"), "PNG"), ImagePtr(qsl(":/ava/art/usercolor8.png"), "PNG"), }; return userDefPhotos[index]; } ImagePtr chatDefPhoto(int32 index) { static const ImagePtr chatDefPhotos[4] = { ImagePtr(qsl(":/ava/art/chatcolor1.png"), "PNG"), ImagePtr(qsl(":/ava/art/chatcolor2.png"), "PNG"), ImagePtr(qsl(":/ava/art/chatcolor3.png"), "PNG"), ImagePtr(qsl(":/ava/art/chatcolor4.png"), "PNG"), }; return chatDefPhotos[index]; } ImagePtr channelDefPhoto(int32 index) { static const ImagePtr channelDefPhotos[4] = { ImagePtr(qsl(":/ava/art/channelcolor1.png"), "PNG"), ImagePtr(qsl(":/ava/art/channelcolor2.png"), "PNG"), ImagePtr(qsl(":/ava/art/channelcolor3.png"), "PNG"), ImagePtr(qsl(":/ava/art/channelcolor4.png"), "PNG"), }; return channelDefPhotos[index]; } NotifySettings globalNotifyAll, globalNotifyUsers, globalNotifyChats; NotifySettingsPtr globalNotifyAllPtr = UnknownNotifySettings, globalNotifyUsersPtr = UnknownNotifySettings, globalNotifyChatsPtr = UnknownNotifySettings; PeerData::PeerData(const PeerId &id) : id(id) , lnk(new PeerLink(this)) , loaded(false) , colorIndex(peerColorIndex(id)) , color(peerColor(colorIndex)) , photo((isChat() || isMegagroup()) ? chatDefPhoto(colorIndex) : (isChannel() ? channelDefPhoto(colorIndex) : userDefPhoto(colorIndex))) , photoId(UnknownPeerPhotoId) , nameVersion(0) , notify(UnknownNotifySettings) { if (!peerIsUser(id) && !peerIsChannel(id)) updateName(QString(), QString(), QString()); } void PeerData::updateName(const QString &newName, const QString &newNameOrPhone, const QString &newUsername) { if (name == newName && nameVersion > 0) { if (isUser()) { if (asUser()->nameOrPhone == newNameOrPhone && asUser()->username == newUsername) { return; } } else if (isChannel()) { if (asChannel()->username == newUsername) { return; } } else if (isChat()) { return; } } ++nameVersion; name = newName; nameText.setText(st::msgNameFont, name, _textNameOptions); if (isUser()) { asUser()->username = newUsername; asUser()->setNameOrPhone(newNameOrPhone); } else if (isChannel()) { if (asChannel()->username != newUsername) { asChannel()->username = newUsername; if (newUsername.isEmpty()) { asChannel()->flags &= ~MTPDchannel::flag_username; } else { asChannel()->flags |= MTPDchannel::flag_username; } if (App::main()) { App::main()->peerUsernameChanged(this); } } } Names oldNames = names; NameFirstChars oldChars = chars; fillNames(); if (App::main()) { emit App::main()->peerNameChanged(this, oldNames, oldChars); } } const Text &BotCommand::descriptionText() const { if (_descriptionText.isEmpty() && !_description.isEmpty()) { _descriptionText.setText(st::mentionFont, _description, _textNameOptions); } return _descriptionText; } void UserData::setPhoto(const MTPUserProfilePhoto &p) { // see Local::readPeer as well PhotoId newPhotoId = photoId; ImagePtr newPhoto = photo; StorageImageLocation newPhotoLoc = photoLoc; switch (p.type()) { case mtpc_userProfilePhoto: { const MTPDuserProfilePhoto d(p.c_userProfilePhoto()); newPhotoId = d.vphoto_id.v; newPhotoLoc = App::imageLocation(160, 160, d.vphoto_small); newPhoto = newPhotoLoc.isNull() ? userDefPhoto(colorIndex) : ImagePtr(newPhotoLoc); //App::feedPhoto(App::photoFromUserPhoto(peerToUser(id), MTP_int(unixtime()), p)); } break; default: { newPhotoId = 0; if (id == ServiceUserId) { if (photo->isNull()) { newPhoto = ImagePtr(QPixmap::fromImage(App::wnd()->iconLarge().scaledToWidth(160, Qt::SmoothTransformation), Qt::ColorOnly), "PNG"); } } else { newPhoto = userDefPhoto(colorIndex); } newPhotoLoc = StorageImageLocation(); } break; } if (newPhotoId != photoId || newPhoto.v() != photo.v() || newPhotoLoc != photoLoc) { photoId = newPhotoId; photo = newPhoto; photoLoc = newPhotoLoc; if (App::main()) { emit App::main()->peerPhotoChanged(this); } } } void PeerData::fillNames() { names.clear(); chars.clear(); QString toIndex = textAccentFold(name); if (cRussianLetters().match(toIndex).hasMatch()) { toIndex += ' ' + translitRusEng(toIndex); } if (isUser()) { if (!asUser()->nameOrPhone.isEmpty() && asUser()->nameOrPhone != name) toIndex += ' ' + textAccentFold(asUser()->nameOrPhone); if (!asUser()->username.isEmpty()) toIndex += ' ' + textAccentFold(asUser()->username); } else if (isChannel()) { if (!asChannel()->username.isEmpty()) toIndex += ' ' + textAccentFold(asChannel()->username); } toIndex += ' ' + rusKeyboardLayoutSwitch(toIndex); QStringList namesList = toIndex.toLower().split(cWordSplit(), QString::SkipEmptyParts); for (QStringList::const_iterator i = namesList.cbegin(), e = namesList.cend(); i != e; ++i) { names.insert(*i); chars.insert(i->at(0)); } } void UserData::setName(const QString &first, const QString &last, const QString &phoneName, const QString &usern) { bool updName = !first.isEmpty() || !last.isEmpty(), updUsername = (username != usern); if (updName && first.trimmed().isEmpty()) { firstName = last; lastName = QString(); updateName(firstName, phoneName, usern); } else { if (updName) { firstName = first; lastName = last; } updateName(lastName.isEmpty() ? firstName : lng_full_name(lt_first_name, firstName, lt_last_name, lastName), phoneName, usern); } if (updUsername) { if (App::main()) { App::main()->peerUsernameChanged(this); } } } void UserData::setPhone(const QString &newPhone) { phone = newPhone; } void UserData::setBotInfoVersion(int32 version) { if (version < 0) { if (botInfo) { if (!botInfo->commands.isEmpty()) { botInfo->commands.clear(); Notify::botCommandsChanged(this); } delete botInfo; botInfo = 0; Notify::userIsBotChanged(this); } } else if (!botInfo) { botInfo = new BotInfo(); botInfo->version = version; Notify::userIsBotChanged(this); } else if (botInfo->version < version) { if (!botInfo->commands.isEmpty()) { botInfo->commands.clear(); Notify::botCommandsChanged(this); } botInfo->description.clear(); botInfo->version = version; botInfo->inited = false; } } void UserData::setBotInfo(const MTPBotInfo &info) { switch (info.type()) { case mtpc_botInfo: { const MTPDbotInfo &d(info.c_botInfo()); if (peerFromUser(d.vuser_id.v) != id || !botInfo) return; QString desc = qs(d.vdescription); if (botInfo->description != desc) { botInfo->description = desc; botInfo->text = Text(st::msgMinWidth); } const QVector &v(d.vcommands.c_vector().v); botInfo->commands.reserve(v.size()); bool changedCommands = false; int32 j = 0; for (int32 i = 0, l = v.size(); i < l; ++i) { if (v.at(i).type() != mtpc_botCommand) continue; QString cmd = qs(v.at(i).c_botCommand().vcommand), desc = qs(v.at(i).c_botCommand().vdescription); if (botInfo->commands.size() <= j) { botInfo->commands.push_back(BotCommand(cmd, desc)); changedCommands = true; } else { if (botInfo->commands[j].command != cmd) { botInfo->commands[j].command = cmd; changedCommands = true; } if (botInfo->commands[j].setDescription(desc)) { changedCommands = true; } } ++j; } while (j < botInfo->commands.size()) { botInfo->commands.pop_back(); changedCommands = true; } botInfo->inited = true; if (changedCommands) { Notify::botCommandsChanged(this); } } break; } } void UserData::setNameOrPhone(const QString &newNameOrPhone) { if (nameOrPhone != newNameOrPhone) { nameOrPhone = newNameOrPhone; phoneText.setText(st::msgNameFont, nameOrPhone, _textNameOptions); } } void UserData::madeAction() { if (botInfo || isServiceUser(id)) return; int32 t = unixtime(); if (onlineTill <= 0 && -onlineTill < t) { onlineTill = -t - SetOnlineAfterActivity; App::markPeerUpdated(this); } else if (onlineTill > 0 && onlineTill < t + 1) { onlineTill = t + SetOnlineAfterActivity; App::markPeerUpdated(this); } } void ChatData::setPhoto(const MTPChatPhoto &p, const PhotoId &phId) { // see Local::readPeer as well PhotoId newPhotoId = photoId; ImagePtr newPhoto = photo; StorageImageLocation newPhotoLoc = photoLoc; switch (p.type()) { case mtpc_chatPhoto: { const MTPDchatPhoto d(p.c_chatPhoto()); if (phId != UnknownPeerPhotoId) { newPhotoId = phId; } newPhotoLoc = App::imageLocation(160, 160, d.vphoto_small); newPhoto = newPhotoLoc.isNull() ? chatDefPhoto(colorIndex) : ImagePtr(newPhotoLoc); // photoFull = ImagePtr(640, 640, d.vphoto_big, chatDefPhoto(colorIndex)); } break; default: { newPhotoId = 0; newPhotoLoc = StorageImageLocation(); newPhoto = chatDefPhoto(colorIndex); // photoFull = ImagePtr(); } break; } if (newPhotoId != photoId || newPhoto.v() != photo.v() || newPhotoLoc != photoLoc) { photoId = newPhotoId; photo = newPhoto; photoLoc = newPhotoLoc; emit App::main()->peerPhotoChanged(this); } } void ChannelData::setPhoto(const MTPChatPhoto &p, const PhotoId &phId) { // see Local::readPeer as well PhotoId newPhotoId = photoId; ImagePtr newPhoto = photo; StorageImageLocation newPhotoLoc = photoLoc; switch (p.type()) { case mtpc_chatPhoto: { const MTPDchatPhoto d(p.c_chatPhoto()); if (phId != UnknownPeerPhotoId) { newPhotoId = phId; } newPhotoLoc = App::imageLocation(160, 160, d.vphoto_small); newPhoto = newPhotoLoc.isNull() ? (isMegagroup() ? chatDefPhoto(colorIndex) : channelDefPhoto(colorIndex)) : ImagePtr(newPhotoLoc); // photoFull = ImagePtr(640, 640, d.vphoto_big, (isMegagroup() ? chatDefPhoto(colorIndex) : channelDefPhoto(colorIndex))); } break; default: { newPhotoId = 0; newPhotoLoc = StorageImageLocation(); newPhoto = (isMegagroup() ? chatDefPhoto(colorIndex) : channelDefPhoto(colorIndex)); // photoFull = ImagePtr(); } break; } if (newPhotoId != photoId || newPhoto.v() != photo.v() || newPhotoLoc != photoLoc) { photoId = newPhotoId; photo = newPhoto; photoLoc = newPhotoLoc; if (App::main()) emit App::main()->peerPhotoChanged(this); } } void ChannelData::setName(const QString &newName, const QString &usern) { bool updName = !newName.isEmpty(), updUsername = (username != usern); updateName(newName.isEmpty() ? name : newName, QString(), usern); } void ChannelData::updateFull(bool force) { if (!_lastFullUpdate || force || getms(true) > _lastFullUpdate + UpdateFullChannelTimeout) { if (App::api()) { App::api()->requestFullPeer(this); if (!amCreator() && !inviter) App::api()->requestSelfParticipant(this); } } } void ChannelData::fullUpdated() { _lastFullUpdate = getms(true); } void ChannelData::flagsUpdated() { if (isMegagroup()) { if (!mgInfo) { mgInfo = new MegagroupInfo(); } if (History *h = App::historyLoaded(id)) { if (h->asChannelHistory()->onlyImportant()) { MsgId fixInScrollMsgId = 0; int32 fixInScrollMsgTop = 0; h->asChannelHistory()->getSwitchReadyFor(SwitchAtTopMsgId, fixInScrollMsgId, fixInScrollMsgTop); } } } else if (mgInfo) { delete mgInfo; mgInfo = 0; } } ChannelData::~ChannelData() { delete mgInfo; } uint64 PtsWaiter::ptsKey(PtsSkippedQueue queue) { return _queue.insert(uint64(uint32(_last)) << 32 | uint64(uint32(_count)), queue).key(); } void PtsWaiter::setWaitingForSkipped(ChannelData *channel, int32 ms) { if (ms >= 0) { if (App::main()) { App::main()->ptsWaiterStartTimerFor(channel, ms); } _waitingForSkipped = true; } else { _waitingForSkipped = false; checkForWaiting(channel); } } void PtsWaiter::setWaitingForShortPoll(ChannelData *channel, int32 ms) { if (ms >= 0) { if (App::main()) { App::main()->ptsWaiterStartTimerFor(channel, ms); } _waitingForShortPoll = true; } else { _waitingForShortPoll = false; checkForWaiting(channel); } } void PtsWaiter::checkForWaiting(ChannelData *channel) { if (!_waitingForSkipped && !_waitingForShortPoll && App::main()) { App::main()->ptsWaiterStartTimerFor(channel, -1); } } void PtsWaiter::applySkippedUpdates(ChannelData *channel) { if (!_waitingForSkipped) return; setWaitingForSkipped(channel, -1); if (!App::main() || _queue.isEmpty()) return; ++_applySkippedLevel; for (QMap::const_iterator i = _queue.cbegin(), e = _queue.cend(); i != e; ++i) { switch (i.value()) { case SkippedUpdate: App::main()->feedUpdate(_updateQueue.value(i.key())); break; case SkippedUpdates: App::main()->feedUpdates(_updatesQueue.value(i.key())); break; } } --_applySkippedLevel; clearSkippedUpdates(); } void PtsWaiter::clearSkippedUpdates() { _queue.clear(); _updateQueue.clear(); _updatesQueue.clear(); _applySkippedLevel = 0; } bool PtsWaiter::updated(ChannelData *channel, int32 pts, int32 count) { if (_requesting || _applySkippedLevel) { return true; } else if (pts <= _good && count > 0) { return false; } return check(channel, pts, count); } bool PtsWaiter::updated(ChannelData *channel, int32 pts, int32 count, const MTPUpdates &updates) { if (_requesting || _applySkippedLevel) { return true; } else if (pts <= _good && count > 0) { return false; } else if (check(channel, pts, count)) { return true; } _updatesQueue.insert(ptsKey(SkippedUpdates), updates); return false; } bool PtsWaiter::updated(ChannelData *channel, int32 pts, int32 count, const MTPUpdate &update) { if (_requesting || _applySkippedLevel) { return true; } else if (pts <= _good && count > 0) { return false; } else if (check(channel, pts, count)) { return true; } _updateQueue.insert(ptsKey(SkippedUpdate), update); return false; } bool PtsWaiter::check(ChannelData *channel, int32 pts, int32 count) { // return false if need to save that update and apply later if (!inited()) { init(pts); return true; } _last = qMax(_last, pts); _count += count; if (_last == _count) { _good = _last; return true; } else if (_last < _count) { setWaitingForSkipped(channel, 1); } else { setWaitingForSkipped(channel, WaitForSkippedTimeout); } return !count; } PhotoData::PhotoData(const PhotoId &id, const uint64 &access, int32 date, const ImagePtr &thumb, const ImagePtr &medium, const ImagePtr &full) : id(id) , access(access) , date(date) , thumb(thumb) , medium(medium) , full(full) , peer(0) , uploadingData(0) { } void PhotoData::automaticLoad(const HistoryItem *item) { full->automaticLoad(item); } void PhotoData::automaticLoadSettingsChanged() { full->automaticLoadSettingsChanged(); } void PhotoData::download() { full->loadEvenCancelled(); notifyLayoutChanged(); } bool PhotoData::loaded() const { bool wasLoading = loading(); if (full->loaded()) { if (wasLoading) { notifyLayoutChanged(); } return true; } return false; } bool PhotoData::loading() const { return full->loading(); } bool PhotoData::displayLoading() const { return full->loading() ? full->displayLoading() : uploading(); } void PhotoData::cancel() { full->cancel(); notifyLayoutChanged(); } void PhotoData::notifyLayoutChanged() const { const PhotoItems &items(App::photoItems()); PhotoItems::const_iterator i = items.constFind(const_cast(this)); if (i != items.cend()) { for (HistoryItemsMap::const_iterator j = i->cbegin(), e = i->cend(); j != e; ++j) { Notify::historyItemLayoutChanged(j.key()); } } } float64 PhotoData::progress() const { if (uploading()) { if (uploadingData->size > 0) { return float64(uploadingData->offset) / uploadingData->size; } return 0; } return full->progress(); } int32 PhotoData::loadOffset() const { return full->loadOffset(); } bool PhotoData::uploading() const { return uploadingData; } void PhotoData::forget() { thumb->forget(); replyPreview->forget(); medium->forget(); full->forget(); } ImagePtr PhotoData::makeReplyPreview() { if (replyPreview->isNull() && !thumb->isNull()) { if (thumb->loaded()) { int w = thumb->width(), h = thumb->height(); if (w <= 0) w = 1; if (h <= 0) h = 1; replyPreview = ImagePtr(w > h ? thumb->pix(w * st::msgReplyBarSize.height() / h, st::msgReplyBarSize.height()) : thumb->pix(st::msgReplyBarSize.height()), "PNG"); } else { thumb->load(); } } return replyPreview; } PhotoData::~PhotoData() { deleteAndMark(uploadingData); } void PhotoLink::onClick(Qt::MouseButton button) const { if (button == Qt::LeftButton) { App::wnd()->showPhoto(this, App::hoveredLinkItem() ? App::hoveredLinkItem() : App::contextItem()); } } void PhotoSaveLink::onClick(Qt::MouseButton button) const { if (button != Qt::LeftButton) return; PhotoData *data = photo(); if (!data->date) return; data->download(); } void PhotoCancelLink::onClick(Qt::MouseButton button) const { if (button != Qt::LeftButton) return; PhotoData *data = photo(); if (!data->date) return; if (data->uploading()) { if (HistoryItem *item = App::hoveredLinkItem() ? App::hoveredLinkItem() : (App::contextItem() ? App::contextItem() : 0)) { if (HistoryMessage *msg = item->toHistoryMessage()) { if (msg->getMedia() && msg->getMedia()->type() == MediaTypePhoto && static_cast(msg->getMedia())->photo() == data) { App::contextItem(item); App::main()->deleteLayer(-2); } } } } else { data->cancel(); } } QString saveFileName(const QString &title, const QString &filter, const QString &prefix, QString name, bool savingAs, const QDir &dir) { #ifdef Q_OS_WIN name = name.replace(QRegularExpression(qsl("[\\\\\\/\\:\\*\\?\\\"\\<\\>\\|]")), qsl("_")); #elif defined Q_OS_MAC name = name.replace(QRegularExpression(qsl("[\\:]")), qsl("_")); #elif defined Q_OS_LINUX name = name.replace(QRegularExpression(qsl("[\\/]")), qsl("_")); #endif if (cAskDownloadPath() || savingAs) { if (!name.isEmpty() && name.at(0) == QChar::fromLatin1('.')) { name = filedialogDefaultName(prefix, name); } else if (dir.path() != qsl(".")) { QString path = dir.absolutePath(); if (path != cDialogLastPath()) { cSetDialogLastPath(path); Local::writeUserSettings(); } } // check if extension of filename is present in filter // it should be in first filter section on the first place // place it there, if it is not QString ext = QFileInfo(name).suffix(), fil = filter, sep = qsl(";;"); if (!ext.isEmpty()) { if (QRegularExpression(qsl("^[a-zA-Z_0-9]+$")).match(ext).hasMatch()) { QStringList filters = filter.split(sep); if (filters.size() > 1) { QString first = filters.at(0); int32 start = first.indexOf(qsl("(*.")); if (start >= 0) { if (!QRegularExpression(qsl("\\(\\*\\.") + ext + qsl("[\\)\\s]"), QRegularExpression::CaseInsensitiveOption).match(first).hasMatch()) { QRegularExpressionMatch m = QRegularExpression(qsl(" \\*\\.") + ext + qsl("[\\)\\s]"), QRegularExpression::CaseInsensitiveOption).match(first); if (m.hasMatch() && m.capturedStart() > start + 3) { int32 oldpos = m.capturedStart(), oldend = m.capturedEnd(); fil = first.mid(0, start + 3) + ext + qsl(" *.") + first.mid(start + 3, oldpos - start - 3) + first.mid(oldend - 1) + sep + filters.mid(1).join(sep); } else { fil = first.mid(0, start + 3) + ext + qsl(" *.") + first.mid(start + 3) + sep + filters.mid(1).join(sep); } } } else { fil = QString(); } } else { fil = QString(); } } else { fil = QString(); } } return filedialogGetSaveFile(name, title, fil, name) ? name : QString(); } QString path; if (cDownloadPath().isEmpty()) { path = psDownloadPath(); } else if (cDownloadPath() == qsl("tmp")) { path = cTempDir(); } else { path = cDownloadPath(); } if (name.isEmpty()) name = qsl(".unknown"); if (name.at(0) == QChar::fromLatin1('.')) { if (!QDir().exists(path)) QDir().mkpath(path); return filedialogDefaultName(prefix, name, path); } if (dir.path() != qsl(".")) { path = dir.absolutePath() + '/'; } QString nameStart, extension; int32 extPos = name.lastIndexOf('.'); if (extPos >= 0) { nameStart = name.mid(0, extPos); extension = name.mid(extPos); } else { nameStart = name; } QString nameBase = path + nameStart; name = nameBase + extension; for (int i = 0; QFileInfo(name).exists(); ++i) { name = nameBase + QString(" (%1)").arg(i + 2) + extension; } if (!QDir().exists(path)) QDir().mkpath(path); return name; } bool StickerData::setInstalled() const { switch (set.type()) { case mtpc_inputStickerSetID: { StickerSets::const_iterator it = cStickerSets().constFind(set.c_inputStickerSetID().vid.v); return (it != cStickerSets().cend()) && !(it->flags & MTPDstickerSet::flag_disabled); } break; case mtpc_inputStickerSetShortName: { QString name = qs(set.c_inputStickerSetShortName().vshort_name).toLower(); for (StickerSets::const_iterator it = cStickerSets().cbegin(), e = cStickerSets().cend(); it != e; ++it) { if (it->shortName.toLower() == name) { return !(it->flags & MTPDstickerSet::flag_disabled); } } } break; } return false; } QString documentSaveFilename(DocumentData *data, bool forceSavingAs = false, const QString already = QString(), const QDir &dir = QDir()) { QString name, filter, caption, prefix; MimeType mimeType = mimeTypeForName(data->mime); QStringList p = mimeType.globPatterns(); QString pattern = p.isEmpty() ? QString() : p.front(); if (data->voice()) { bool mp3 = (data->mime == qstr("audio/mp3")); name = already.isEmpty() ? (mp3 ? qsl(".mp3") : qsl(".ogg")) : already; filter = mp3 ? qsl("MP3 Audio (*.mp3);;All files (*.*)") : qsl("OGG Opus Audio (*.ogg);;All files (*.*)"); caption = lang(lng_save_audio); prefix = qsl("audio"); } else if (data->isVideo()) { name = already.isEmpty() ? qsl(".mov") : already; filter = qsl("MOV Video (*.mov);;All files (*.*)"); caption = lang(lng_save_video); prefix = qsl("video"); } else { name = already.isEmpty() ? data->name : already; if (name.isEmpty()) { name = pattern.isEmpty() ? qsl(".unknown") : pattern.replace('*', QString()); } if (pattern.isEmpty()) { filter = QString(); } else { filter = mimeType.filterString() + qsl(";;All files (*.*)"); } caption = lang(lng_save_file); prefix = qsl("doc"); } return saveFileName(caption, filter, prefix, name, forceSavingAs, dir); } void DocumentOpenLink::doOpen(DocumentData *data, ActionOnLoad action) { if (!data->date) return; HistoryItem *item = App::hoveredLinkItem() ? App::hoveredLinkItem() : (App::contextItem() ? App::contextItem() : 0); bool playVoice = data->voice() && audioPlayer() && item; bool playMusic = data->song() && audioPlayer() && item; bool playAnimation = data->isAnimation() && item && item->getMedia(); const FileLocation &location(data->location(true)); if (!location.isEmpty() || (!data->data().isEmpty() && (playVoice || playMusic || playAnimation))) { if (playVoice) { AudioMsgId playing; AudioPlayerState playingState = AudioPlayerStopped; audioPlayer()->currentState(&playing, &playingState); if (playing.msgId == item->fullId() && !(playingState & AudioPlayerStoppedMask) && playingState != AudioPlayerFinishing) { audioPlayer()->pauseresume(OverviewVoiceFiles); } else { AudioMsgId audio(data, item->fullId()); audioPlayer()->play(audio); if (App::main()) { App::main()->audioPlayProgress(audio); App::main()->mediaMarkRead(data); } } } else if (playMusic) { SongMsgId playing; AudioPlayerState playingState = AudioPlayerStopped; audioPlayer()->currentState(&playing, &playingState); if (playing.msgId == item->fullId() && !(playingState & AudioPlayerStoppedMask) && playingState != AudioPlayerFinishing) { audioPlayer()->pauseresume(OverviewFiles); } else { SongMsgId song(data, item->fullId()); audioPlayer()->play(song); if (App::main()) App::main()->documentPlayProgress(song); } } else if (data->voice() || data->isVideo()) { psOpenFile(location.name()); if (App::main()) App::main()->mediaMarkRead(data); } else if (data->size < MediaViewImageSizeLimit) { if (!data->data().isEmpty() && playAnimation) { if (action == ActionOnLoadPlayInline && item->getMedia()) { item->getMedia()->playInline(item); } else { App::wnd()->showDocument(data, item); } } else if (location.accessEnable()) { if (item && (data->isAnimation() || QImageReader(location.name()).canRead())) { if (action == ActionOnLoadPlayInline && item->getMedia()) { item->getMedia()->playInline(item); } else { App::wnd()->showDocument(data, item); } } else { psOpenFile(location.name()); } location.accessDisable(); } else { psOpenFile(location.name()); } } else { psOpenFile(location.name()); } return; } if (data->status != FileReady) return; QString filename; if (!data->saveToCache()) { filename = documentSaveFilename(data); if (filename.isEmpty()) return; } data->save(filename, action, item ? item->fullId() : FullMsgId()); } void DocumentOpenLink::onClick(Qt::MouseButton button) const { if (button != Qt::LeftButton) return; doOpen(document(), document()->voice() ? ActionOnLoadNone : ActionOnLoadOpen); } void VoiceSaveLink::onClick(Qt::MouseButton button) const { if (button != Qt::LeftButton) return; doOpen(document(), ActionOnLoadNone); } void GifOpenLink::onClick(Qt::MouseButton button) const { if (button != Qt::LeftButton) return; doOpen(document(), ActionOnLoadPlayInline); } void DocumentSaveLink::doSave(DocumentData *data, bool forceSavingAs) { if (!data->date) return; QString already = data->already(true); bool openWith = !already.isEmpty(); if (openWith && !forceSavingAs) { QPoint pos(QCursor::pos()); if (!psShowOpenWithMenu(pos.x(), pos.y(), already)) { psOpenFile(already, true); } } else { QFileInfo alreadyInfo(already); QDir alreadyDir(already.isEmpty() ? QDir() : alreadyInfo.dir()); QString alreadyName(already.isEmpty() ? QString() : alreadyInfo.fileName()); QString filename = documentSaveFilename(data, forceSavingAs, alreadyName, alreadyDir); if (!filename.isEmpty()) { ActionOnLoad action = already.isEmpty() ? ActionOnLoadNone : ActionOnLoadOpenWith; FullMsgId actionMsgId = App::hoveredLinkItem() ? App::hoveredLinkItem()->fullId() : (App::contextItem() ? App::contextItem()->fullId() : FullMsgId()); data->save(filename, action, actionMsgId); } } } void DocumentSaveLink::onClick(Qt::MouseButton button) const { if (button != Qt::LeftButton) return; doSave(document()); } void DocumentCancelLink::onClick(Qt::MouseButton button) const { if (button != Qt::LeftButton) return; DocumentData *data = document(); if (!data->date) return; if (data->uploading()) { if (HistoryItem *item = App::hoveredLinkItem() ? App::hoveredLinkItem() : (App::contextItem() ? App::contextItem() : 0)) { if (HistoryMessage *msg = item->toHistoryMessage()) { if (msg->getMedia() && msg->getMedia()->getDocument() == data) { App::contextItem(item); App::main()->deleteLayer(-2); } } } } else { data->cancel(); } } VoiceData::~VoiceData() { if (!waveform.isEmpty() && waveform.at(0) == -1 && waveform.size() > int32(sizeof(TaskId))) { TaskId taskId = 0; memcpy(&taskId, waveform.constData() + 1, sizeof(taskId)); Local::cancelTask(taskId); } } DocumentData::DocumentData(const DocumentId &id, const uint64 &access, int32 date, const QVector &attributes, const QString &mime, const ImagePtr &thumb, int32 dc, int32 size) : id(id) , type(FileDocument) , access(access) , date(date) , mime(mime) , thumb(thumb) , dc(dc) , size(size) , status(FileReady) , uploadOffset(0) , _additional(0) , _duration(-1) , _actionOnLoad(ActionOnLoadNone) , _loader(0) { setattributes(attributes); _location = Local::readFileLocation(mediaKey()); } void DocumentData::setattributes(const QVector &attributes) { for (int32 i = 0, l = attributes.size(); i < l; ++i) { switch (attributes[i].type()) { case mtpc_documentAttributeImageSize: { const MTPDdocumentAttributeImageSize &d(attributes[i].c_documentAttributeImageSize()); dimensions = QSize(d.vw.v, d.vh.v); } break; case mtpc_documentAttributeAnimated: if (type == FileDocument || type == StickerDocument || type == VideoDocument) { type = AnimatedDocument; delete _additional; _additional = 0; } break; case mtpc_documentAttributeSticker: { const MTPDdocumentAttributeSticker &d(attributes[i].c_documentAttributeSticker()); if (type == FileDocument) { type = StickerDocument; StickerData *sticker = new StickerData(); _additional = sticker; } if (sticker()) { sticker()->alt = qs(d.valt); sticker()->set = d.vstickerset; } } break; case mtpc_documentAttributeVideo: { const MTPDdocumentAttributeVideo &d(attributes[i].c_documentAttributeVideo()); if (type == FileDocument) { type = VideoDocument; } _duration = d.vduration.v; dimensions = QSize(d.vw.v, d.vh.v); } break; case mtpc_documentAttributeAudio: { const MTPDdocumentAttributeAudio &d(attributes[i].c_documentAttributeAudio()); if (type == FileDocument) { if (d.is_voice()) { type = VoiceDocument; VoiceData *voice = new VoiceData(); _additional = voice; } else { type = SongDocument; SongData *song = new SongData(); _additional = song; } } if (voice()) { voice()->duration = d.vduration.v; VoiceWaveform waveform = documentWaveformDecode(qba(d.vwaveform)); uchar wavemax = 0; for (int32 i = 0, l = waveform.size(); i < l; ++i) { uchar waveat = waveform.at(i); if (wavemax < waveat) wavemax = waveat; } voice()->waveform = waveform; voice()->wavemax = wavemax; } else if (song()) { song()->duration = d.vduration.v; song()->title = qs(d.vtitle); song()->performer = qs(d.vperformer); } } break; case mtpc_documentAttributeFilename: name = qs(attributes[i].c_documentAttributeFilename().vfile_name); break; } } if (type == StickerDocument) { if (dimensions.width() <= 0 || dimensions.height() <= 0 || dimensions.width() > StickerMaxSize || dimensions.height() > StickerMaxSize || size > StickerInMemory) { type = FileDocument; delete _additional; _additional = 0; } } } bool DocumentData::saveToCache() const { return (type == StickerDocument) || (isAnimation() && size < AnimationInMemory) || (voice() && size < AudioVoiceMsgInMemory); } void DocumentData::forget() { thumb->forget(); if (sticker()) sticker()->img->forget(); replyPreview->forget(); _data.clear(); } void DocumentData::automaticLoad(const HistoryItem *item) { if (loaded() || status != FileReady) return; if (saveToCache() && _loader != CancelledMtpFileLoader) { if (type == StickerDocument) { save(QString(), _actionOnLoad, _actionOnLoadMsgId); } else if (isAnimation()) { bool loadFromCloud = false; if (item) { if (item->history()->peer->isUser()) { loadFromCloud = !(cAutoDownloadGif() & dbiadNoPrivate); } else { loadFromCloud = !(cAutoDownloadGif() & dbiadNoGroups); } } else { // if load at least anywhere loadFromCloud = !(cAutoDownloadGif() & dbiadNoPrivate) || !(cAutoDownloadGif() & dbiadNoGroups); } save(QString(), _actionOnLoad, _actionOnLoadMsgId, loadFromCloud ? LoadFromCloudOrLocal : LoadFromLocalOnly, true); } else if (voice()) { if (item) { bool loadFromCloud = false; if (item->history()->peer->isUser()) { loadFromCloud = !(cAutoDownloadAudio() & dbiadNoPrivate); } else { loadFromCloud = !(cAutoDownloadAudio() & dbiadNoGroups); } save(QString(), _actionOnLoad, _actionOnLoadMsgId, loadFromCloud ? LoadFromCloudOrLocal : LoadFromLocalOnly, true); } } } } void DocumentData::automaticLoadSettingsChanged() { if (loaded() || status != FileReady || (!isAnimation() && !voice()) || !saveToCache() || _loader != CancelledMtpFileLoader) return; _loader = 0; } void DocumentData::performActionOnLoad() { if (_actionOnLoad == ActionOnLoadNone) return; const FileLocation &loc(location(true)); QString already = loc.name(); HistoryItem *item = _actionOnLoadMsgId.msg ? App::histItemById(_actionOnLoadMsgId) : 0; bool showImage = !isVideo() && item && (size < MediaViewImageSizeLimit); bool playVoice = voice() && audioPlayer() && (_actionOnLoad == ActionOnLoadPlayInline || _actionOnLoad == ActionOnLoadOpen) && item; bool playMusic = song() && audioPlayer() && (_actionOnLoad == ActionOnLoadPlayInline || _actionOnLoad == ActionOnLoadOpen) && item; bool playAnimation = isAnimation() && (_actionOnLoad == ActionOnLoadPlayInline || _actionOnLoad == ActionOnLoadOpen) && showImage && item->getMedia(); if (playVoice) { if (loaded()) { AudioMsgId playing; AudioPlayerState state = AudioPlayerStopped; audioPlayer()->currentState(&playing, &state); if (playing.msgId == _actionOnLoadMsgId && !(state & AudioPlayerStoppedMask) && state != AudioPlayerFinishing) { audioPlayer()->pauseresume(OverviewVoiceFiles); } else { audioPlayer()->play(AudioMsgId(this, _actionOnLoadMsgId)); if (App::main()) App::main()->mediaMarkRead(this); } } } else if (playMusic) { if (loaded()) { SongMsgId playing; AudioPlayerState playingState = AudioPlayerStopped; audioPlayer()->currentState(&playing, &playingState); if (playing.msgId == item->fullId() && !(playingState & AudioPlayerStoppedMask) && playingState != AudioPlayerFinishing) { audioPlayer()->pauseresume(OverviewFiles); } else { SongMsgId song(this, item->fullId()); audioPlayer()->play(song); if (App::main()) App::main()->documentPlayProgress(song); } } } else if (playAnimation) { if (loaded()) { if (_actionOnLoad == ActionOnLoadPlayInline && item->getMedia()) { item->getMedia()->playInline(item); } else { App::wnd()->showDocument(this, item); } } } else { if (already.isEmpty()) return; if (_actionOnLoad == ActionOnLoadOpenWith) { QPoint pos(QCursor::pos()); if (!psShowOpenWithMenu(pos.x(), pos.y(), already)) { psOpenFile(already, true); } } else if (_actionOnLoad == ActionOnLoadOpen || _actionOnLoad == ActionOnLoadPlayInline) { if (voice() || isVideo()) { psOpenFile(already); if (App::main()) App::main()->mediaMarkRead(this); } else if (loc.accessEnable()) { if (showImage && QImageReader(loc.name()).canRead()) { if (_actionOnLoad == ActionOnLoadPlayInline && item->getMedia()) { item->getMedia()->playInline(item); } else { App::wnd()->showDocument(this, item); } } else { psOpenFile(already); } loc.accessDisable(); } else { psOpenFile(already); } } } _actionOnLoad = ActionOnLoadNone; } bool DocumentData::loaded(bool check) const { if (loading() && _loader->done()) { if (_loader->fileType() == mtpc_storage_fileUnknown) { _loader->deleteLater(); _loader->rpcClear(); _loader = CancelledMtpFileLoader; } else { DocumentData *that = const_cast(this); that->_location = FileLocation(mtpToStorageType(_loader->fileType()), _loader->fileName()); that->_data = _loader->bytes(); if (that->sticker() && !_loader->imagePixmap().isNull()) { that->sticker()->img = ImagePtr(_data, _loader->imageFormat(), _loader->imagePixmap()); } _loader->deleteLater(); _loader->rpcClear(); _loader = 0; } notifyLayoutChanged(); } return !_data.isEmpty() || !already(check).isEmpty(); } bool DocumentData::loading() const { return _loader && _loader != CancelledMtpFileLoader; } bool DocumentData::displayLoading() const { return loading() ? (!_loader->loadingLocal() || !_loader->autoLoading()) : uploading(); } float64 DocumentData::progress() const { if (uploading()) { if (size > 0) { return float64(uploadOffset) / size; } return 0; } return loading() ? _loader->currentProgress() : (loaded() ? 1 : 0); } int32 DocumentData::loadOffset() const { return loading() ? _loader->currentOffset() : 0; } bool DocumentData::uploading() const { return status == FileUploading; } void DocumentData::save(const QString &toFile, ActionOnLoad action, const FullMsgId &actionMsgId, LoadFromCloudSetting fromCloud, bool autoLoading) { if (loaded(true)) { const FileLocation &l(location(true)); if (!toFile.isEmpty()) { if (!_data.isEmpty()) { QFile f(toFile); f.open(QIODevice::WriteOnly); f.write(_data); } else if (l.accessEnable()) { QFile(l.name()).copy(toFile); l.accessDisable(); } } return; } if (_loader == CancelledMtpFileLoader) _loader = 0; if (_loader) { if (!_loader->setFileName(toFile)) { cancel(); _loader = 0; } } _actionOnLoad = action; _actionOnLoadMsgId = actionMsgId; if (_loader) { if (fromCloud == LoadFromCloudOrLocal) _loader->permitLoadFromCloud(); } else { status = FileReady; LocationType type = voice() ? AudioFileLocation : (isVideo() ? VideoFileLocation : DocumentFileLocation); _loader = new mtpFileLoader(dc, id, access, type, toFile, size, (saveToCache() ? LoadToCacheAsWell : LoadToFileOnly), fromCloud, autoLoading); _loader->connect(_loader, SIGNAL(progress(FileLoader*)), App::main(), SLOT(documentLoadProgress(FileLoader*))); _loader->connect(_loader, SIGNAL(failed(FileLoader*,bool)), App::main(), SLOT(documentLoadFailed(FileLoader*,bool))); _loader->start(); } notifyLayoutChanged(); } void DocumentData::cancel() { if (!loading()) return; mtpFileLoader *l = _loader; _loader = CancelledMtpFileLoader; if (l) { l->cancel(); l->deleteLater(); l->rpcClear(); notifyLayoutChanged(); } _actionOnLoad = ActionOnLoadNone; } void DocumentData::notifyLayoutChanged() const { const DocumentItems &items(App::documentItems()); DocumentItems::const_iterator i = items.constFind(const_cast(this)); if (i != items.cend()) { for (HistoryItemsMap::const_iterator j = i->cbegin(), e = i->cend(); j != e; ++j) { Notify::historyItemLayoutChanged(j.key()); } } } VoiceWaveform documentWaveformDecode(const QByteArray &encoded5bit) { VoiceWaveform result((encoded5bit.size() * 8) / 5, 0); for (int32 i = 0, l = result.size(); i < l; ++i) { // read each 5 bit of encoded5bit as 0-31 unsigned char int32 byte = (i * 5) / 8, shift = (i * 5) % 8; result[i] = (((*(uint16*)(encoded5bit.constData() + byte)) >> shift) & 0x1F); } return result; } QByteArray documentWaveformEncode5bit(const VoiceWaveform &waveform) { QByteArray result((waveform.size() * 5 + 7) / 8, 0); for (int32 i = 0, l = waveform.size(); i < l; ++i) { // write each 0-31 unsigned char as 5 bit to result int32 byte = (i * 5) / 8, shift = (i * 5) % 8; (*(uint16*)(result.data() + byte)) |= (uint16(waveform.at(i) & 0x1F) << shift); } return result; } QString DocumentData::already(bool check) const { if (check && _location.name().isEmpty()) return QString(); return location(check).name(); } QByteArray DocumentData::data() const { return _data; } const FileLocation &DocumentData::location(bool check) const { if (check && !_location.check()) { const_cast(this)->_location = Local::readFileLocation(mediaKey()); } return _location; } void DocumentData::setLocation(const FileLocation &loc) { if (loc.check()) { _location = loc; } } ImagePtr DocumentData::makeReplyPreview() { if (replyPreview->isNull() && !thumb->isNull()) { if (thumb->loaded()) { int w = thumb->width(), h = thumb->height(); if (w <= 0) w = 1; if (h <= 0) h = 1; replyPreview = ImagePtr(w > h ? thumb->pix(w * st::msgReplyBarSize.height() / h, st::msgReplyBarSize.height()) : thumb->pix(st::msgReplyBarSize.height()), "PNG"); } else { thumb->load(); } } return replyPreview; } bool fileIsImage(const QString &name, const QString &mime) { QString lowermime = mime.toLower(), namelower = name.toLower(); if (lowermime.startsWith(qstr("image/"))) { return true; } else if (namelower.endsWith(qstr(".bmp")) || namelower.endsWith(qstr(".jpg")) || namelower.endsWith(qstr(".jpeg")) || namelower.endsWith(qstr(".gif")) || namelower.endsWith(qstr(".webp")) || namelower.endsWith(qstr(".tga")) || namelower.endsWith(qstr(".tiff")) || namelower.endsWith(qstr(".tif")) || namelower.endsWith(qstr(".psd")) || namelower.endsWith(qstr(".png"))) { return true; } return false; } void DocumentData::recountIsImage() { if (isAnimation() || isVideo()) return; _duration = fileIsImage(name, mime) ? 1 : -1; // hack } DocumentData::~DocumentData() { delete _additional; if (loading()) { _loader->deleteLater(); _loader->stop(); _loader = 0; } } WebPageData::WebPageData(const WebPageId &id, WebPageType type, const QString &url, const QString &displayUrl, const QString &siteName, const QString &title, const QString &description, PhotoData *photo, DocumentData *doc, int32 duration, const QString &author, int32 pendingTill) : id(id) , type(type) , url(url) , displayUrl(displayUrl) , siteName(siteName) , title(title) , description(description) , duration(duration) , author(author) , photo(photo) , doc(doc) , pendingTill(pendingTill) { } void InlineResult::automaticLoadGif() { if (loaded() || type != qstr("gif") || (content_type != qstr("video/mp4") && content_type != "image/gif")) return; if (_loader != CancelledWebFileLoader) { // if load at least anywhere bool loadFromCloud = !(cAutoDownloadGif() & dbiadNoPrivate) || !(cAutoDownloadGif() & dbiadNoGroups); saveFile(QString(), loadFromCloud ? LoadFromCloudOrLocal : LoadFromLocalOnly, true); } } void InlineResult::automaticLoadSettingsChangedGif() { if (loaded() || _loader != CancelledWebFileLoader) return; _loader = 0; } void InlineResult::saveFile(const QString &toFile, LoadFromCloudSetting fromCloud, bool autoLoading) { if (loaded()) { return; } if (_loader == CancelledWebFileLoader) _loader = 0; if (_loader) { if (!_loader->setFileName(toFile)) { cancelFile(); _loader = 0; } } if (_loader) { if (fromCloud == LoadFromCloudOrLocal) _loader->permitLoadFromCloud(); } else { _loader = new webFileLoader(content_url, toFile, fromCloud, autoLoading); App::regInlineResultLoader(_loader, this); _loader->connect(_loader, SIGNAL(progress(FileLoader*)), App::main(), SLOT(inlineResultLoadProgress(FileLoader*))); _loader->connect(_loader, SIGNAL(failed(FileLoader*,bool)), App::main(), SLOT(inlineResultLoadFailed(FileLoader*,bool))); _loader->start(); } } void InlineResult::cancelFile() { if (!loading()) return; App::unregInlineResultLoader(_loader); webFileLoader *l = _loader; _loader = CancelledWebFileLoader; if (l) { l->cancel(); l->deleteLater(); l->stop(); } } QByteArray InlineResult::data() const { return _data; } bool InlineResult::loading() const { return _loader && _loader != CancelledWebFileLoader; } bool InlineResult::loaded() const { if (loading() && _loader->done()) { App::unregInlineResultLoader(_loader); if (_loader->fileType() == mtpc_storage_fileUnknown) { _loader->deleteLater(); _loader->stop(); _loader = CancelledWebFileLoader; } else { InlineResult *that = const_cast(this); that->_data = _loader->bytes(); _loader->deleteLater(); _loader->stop(); _loader = 0; } } return !_data.isEmpty(); } bool InlineResult::displayLoading() const { return loading() ? (!_loader->loadingLocal() || !_loader->autoLoading()) : false; } void InlineResult::forget() { thumb->forget(); _data.clear(); } float64 InlineResult::progress() const { return loading() ? _loader->currentProgress() : (loaded() ? 1 : 0); return false; } InlineResult::~InlineResult() { cancelFile(); } void PeerLink::onClick(Qt::MouseButton button) const { if (button == Qt::LeftButton && App::main()) { if (peer() && peer()->isChannel() && App::main()->historyPeer() != peer()) { if (!peer()->asChannel()->isPublic() && !peer()->asChannel()->amIn()) { Ui::showLayer(new InformBox(lang((peer()->isMegagroup()) ? lng_group_not_accessible : lng_channel_not_accessible))); } else { Ui::showPeerHistory(peer(), ShowAtUnreadMsgId); } } else { App::main()->showPeerProfile(peer()); } } } void MessageLink::onClick(Qt::MouseButton button) const { if (button == Qt::LeftButton && App::main()) { HistoryItem *current = App::mousedItem(); if (current && current->history()->peer->id == peer()) { App::main()->pushReplyReturn(current); } Ui::showPeerHistory(peer(), msgid()); } } void CommentsLink::onClick(Qt::MouseButton button) const { if (button == Qt::LeftButton && App::main() && _item->history()->isChannel()) { Ui::showPeerHistoryAtItem(_item); } } MsgId clientMsgId() { static MsgId currentClientMsgId = StartClientMsgId; Q_ASSERT(currentClientMsgId < EndClientMsgId); return currentClientMsgId++; }