Green-Sky/solanaceae_tox
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

track message of file transfer, and call update on completion

Browse Source
This commit is contained in:
Green Sky 2024-10-06 19:58:44 +02:00
parent 2e34ad2100
commit a0c3336f37
No known key found for this signature in database
3 changed files with 28 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
solanaceae/tox_messages/obj_components.hpp
View File

@ -2,6 +2,8 @@
#include <solanaceae/object_store/meta_components_file.hpp> // contains the alias
#include <solanaceae/message3/registry_message_model.hpp>
#include <solanaceae/toxcore/tox_key.hpp>
namespace ObjectStore::Components {
@ -34,6 +36,12 @@ namespace ObjectStore::Components {
uint32_t transfer_number;
};
// TODO: replace this with something generic
struct ToxMessage {
// the message, if the ft is visible as a message
Message3Handle m;
};
} // Ephemeral
} // ObjectStore::Components

1
solanaceae/tox_messages/obj_components_id.inl
View File

@ -26,6 +26,7 @@ DEFINE_COMP_ID(ObjComp::Tox::TagIncomming)
DEFINE_COMP_ID(ObjComp::Tox::TagOutgoing)
DEFINE_COMP_ID(ObjComp::Ephemeral::ToxTransferFriend)
DEFINE_COMP_ID(ObjComp::Ephemeral::ToxMessage)
#undef DEFINE_COMP_ID

33
solanaceae/tox_messages/tox_transfer_manager.cpp
View File

@ -532,6 +532,8 @@ bool ToxTransferManager::onToxEvent(const Tox_Event_File_Recv* e) {
}
msg.emplace<Message::Components::MessageFileObject>(o);
o.emplace<ObjComp::Ephemeral::ToxMessage>(msg);
_os.throwEventConstruct(o);
_rmm.throwEventConstruct(msg);
@ -611,22 +613,25 @@ bool ToxTransferManager::onToxEvent(const Tox_Event_File_Recv_Chunk* e) {
o.emplace_or_replace<ObjComp::F::TagLocalHaveAll>();
#if 0 // TODO: track back msg
// re-unread a finished transfer
msg.emplace_or_replace<Message::Components::TagUnread>();
msg.remove<Message::Components::Read>();
auto c = _tcm.getContactFriend(friend_number);
if (static_cast<bool>(c)) {
auto self_c = _cr.get<Contact::Components::Self>(c).self;
auto& rb = msg.get_or_emplace<Message::Components::ReceivedBy>().ts;
rb.try_emplace(self_c, ts); // on completion
}
#endif
_os.throwEventUpdate(o);
//_rmm.throwEventUpdate(msg);
// TODO: move out generic? do we want to update on EVERY chunk?
if (const auto* msg_ptr = o.try_get<ObjComp::Ephemeral::ToxMessage>(); msg_ptr != nullptr && static_cast<bool>(msg_ptr->m)) {
const auto& msg = msg_ptr->m;
// re-unread a finished transfer
msg.emplace_or_replace<Message::Components::TagUnread>();
msg.remove<Message::Components::Read>();
auto c = _tcm.getContactFriend(friend_number);
if (static_cast<bool>(c)) {
auto self_c = _cr.get<Contact::Components::Self>(c).self;
auto& rb = msg.get_or_emplace<Message::Components::ReceivedBy>().ts;
rb.try_emplace(self_c, ts); // on completion
}
_rmm.throwEventUpdate(msg);
}
} else if (!o.all_of<Components::TFTFile2>() || !o.get<Components::TFTFile2>().file || !o.get<Components::TFTFile2>().file->isGood()) {
std::cerr << "TTM error: file not good f" << friend_number << " t" << file_number << ", closing\n";
_t.toxFileControl(friend_number, file_number, Tox_File_Control::TOX_FILE_CONTROL_CANCEL);