| 520 | } |
| 521 | |
| 522 | bool ProtocolClient::needToWaitForGroupData(openmittsu::protocol::GroupId const& groupId, openmittsu::messages::MessageWithEncryptedPayload const*const messageWithEncryptedPayload, bool isGroupCreationMessage) { |
| 523 | if (needToWaitForMissingIdentity(groupId.getOwner(), messageWithEncryptedPayload)) { |
| 524 | return true; |
| 525 | } else if (groupsWithMissingIdentities.contains(groupId)) { |
| 526 | if (messageWithEncryptedPayload == nullptr) { |
| 527 | LOGGER()->warn("Trying to enqueue new message for group {} on existing MissingIdentityProcessor, but the encryptedPayload pointer is null.", groupId.toString()); |
| 528 | return true; |
| 529 | } |
| 530 | |
| 531 | LOGGER_DEBUG("Enqueuing new message for group {} on existing MissingIdentityProcessor.", groupId.toString()); |
| 532 | groupsWithMissingIdentities.constFind(groupId).value()->enqueueMessage(*messageWithEncryptedPayload); |
| 533 | return true; |
| 534 | } |
| 535 | |
| 536 | return false; |
| 537 | } |
| 538 | |
| 539 | void ProtocolClient::handleIncomingMessage(openmittsu::messages::FullMessageHeader const& messageHeader, std::shared_ptr<openmittsu::messages::contact::ContactAudioMessageContent const> contactAudioMessageContent) { |
| 540 | LOGGER_DEBUG("Received an audio message from {}.", messageHeader.getSender().toString()); |
nothing calls this directly
no test coverage detected