content refactor (dedup on send)
This commit is contained in:
parent
c61824d95f
commit
1f53bc9e54
@ -17,8 +17,19 @@
|
|||||||
#include <iostream>
|
#include <iostream>
|
||||||
#include <variant>
|
#include <variant>
|
||||||
|
|
||||||
|
namespace Message::Components {
|
||||||
|
|
||||||
|
using Content = ContentHandle;
|
||||||
|
|
||||||
|
} // Message::Components
|
||||||
|
|
||||||
|
// TODO: rename to content components
|
||||||
namespace Components {
|
namespace Components {
|
||||||
|
|
||||||
|
struct Messages {
|
||||||
|
std::vector<Message3Handle> messages;
|
||||||
|
};
|
||||||
|
|
||||||
using FT1InfoSHA1 = FT1InfoSHA1;
|
using FT1InfoSHA1 = FT1InfoSHA1;
|
||||||
|
|
||||||
struct FT1InfoSHA1Data {
|
struct FT1InfoSHA1Data {
|
||||||
@ -73,7 +84,7 @@ static size_t chunkSize(const FT1InfoSHA1& sha1_info, size_t chunk_index) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
void SHA1_NGCFT1::queueUpRequestChunk(uint32_t group_number, uint32_t peer_number, Message3Handle msg, const SHA1Digest& hash) {
|
void SHA1_NGCFT1::queueUpRequestChunk(uint32_t group_number, uint32_t peer_number, ContentHandle content, const SHA1Digest& hash) {
|
||||||
// TODO: transfers
|
// TODO: transfers
|
||||||
for (auto& [i_g, i_p, i_m, i_h, i_t] : _queue_requested_chunk) {
|
for (auto& [i_g, i_p, i_m, i_h, i_t] : _queue_requested_chunk) {
|
||||||
// if already in queue
|
// if already in queue
|
||||||
@ -85,13 +96,34 @@ void SHA1_NGCFT1::queueUpRequestChunk(uint32_t group_number, uint32_t peer_numbe
|
|||||||
}
|
}
|
||||||
|
|
||||||
// not in queue yet
|
// not in queue yet
|
||||||
_queue_requested_chunk.push_back(std::make_tuple(group_number, peer_number, msg, hash, 0.f));
|
_queue_requested_chunk.push_back(std::make_tuple(group_number, peer_number, content, hash, 0.f));
|
||||||
}
|
}
|
||||||
|
|
||||||
uint64_t SHA1_NGCFT1::combineIds(const uint32_t group_number, const uint32_t peer_number) {
|
uint64_t SHA1_NGCFT1::combineIds(const uint32_t group_number, const uint32_t peer_number) {
|
||||||
return (uint64_t(group_number) << 32) | peer_number;
|
return (uint64_t(group_number) << 32) | peer_number;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void SHA1_NGCFT1::updateMessages(ContentHandle ce) {
|
||||||
|
assert(ce.all_of<Components::Messages>());
|
||||||
|
|
||||||
|
for (auto msg : ce.get<Components::Messages>().messages) {
|
||||||
|
if (ce.all_of<Message::Components::Transfer::FileInfo>() && !msg.all_of<Message::Components::Transfer::FileInfo>()) {
|
||||||
|
msg.emplace<Message::Components::Transfer::FileInfo>(ce.get<Message::Components::Transfer::FileInfo>());
|
||||||
|
}
|
||||||
|
if (ce.all_of<Message::Components::Transfer::FileInfoLocal>()) {
|
||||||
|
msg.emplace_or_replace<Message::Components::Transfer::FileInfoLocal>(ce.get<Message::Components::Transfer::FileInfoLocal>());
|
||||||
|
}
|
||||||
|
if (ce.all_of<Message::Components::Transfer::BytesSent>()) {
|
||||||
|
msg.emplace_or_replace<Message::Components::Transfer::BytesSent>(ce.get<Message::Components::Transfer::BytesSent>());
|
||||||
|
}
|
||||||
|
if (auto* cc = ce.try_get<Components::FT1ChunkSHA1Cache>(); cc != nullptr && cc->have_all) {
|
||||||
|
msg.emplace_or_replace<Message::Components::Transfer::TagHaveAll>();
|
||||||
|
}
|
||||||
|
|
||||||
|
_rmm.throwEventUpdate(msg);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
SHA1_NGCFT1::SHA1_NGCFT1(
|
SHA1_NGCFT1::SHA1_NGCFT1(
|
||||||
Contact3Registry& cr,
|
Contact3Registry& cr,
|
||||||
RegistryMessageModel& rmm,
|
RegistryMessageModel& rmm,
|
||||||
@ -245,14 +277,17 @@ bool SHA1_NGCFT1::onEvent(const Events::NGCFT1_recv_request& e) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
SHA1Digest info_hash{e.file_id, e.file_id_size};
|
SHA1Digest info_hash{e.file_id, e.file_id_size};
|
||||||
if (!_info_to_message.count(info_hash)) {
|
if (!_info_to_content.count(info_hash)) {
|
||||||
// we dont know about this
|
// we dont know about this
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
auto msg = _info_to_message.at(info_hash);
|
auto content = _info_to_content.at(info_hash);
|
||||||
|
|
||||||
assert(msg.all_of<Components::FT1InfoSHA1Data>());
|
if (!content.all_of<Components::FT1InfoSHA1Data>()) {
|
||||||
|
// we dont have the info for that infohash (yet?)
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
// TODO: queue instead
|
// TODO: queue instead
|
||||||
//queueUpRequestInfo(e.group_number, e.peer_number, info_hash);
|
//queueUpRequestInfo(e.group_number, e.peer_number, info_hash);
|
||||||
@ -261,14 +296,14 @@ bool SHA1_NGCFT1::onEvent(const Events::NGCFT1_recv_request& e) {
|
|||||||
e.group_number, e.peer_number,
|
e.group_number, e.peer_number,
|
||||||
static_cast<uint32_t>(e.file_kind),
|
static_cast<uint32_t>(e.file_kind),
|
||||||
e.file_id, e.file_id_size,
|
e.file_id, e.file_id_size,
|
||||||
msg.get<Components::FT1InfoSHA1Data>().data.size(),
|
content.get<Components::FT1InfoSHA1Data>().data.size(),
|
||||||
&transfer_id
|
&transfer_id
|
||||||
);
|
);
|
||||||
|
|
||||||
_sending_transfers
|
_sending_transfers
|
||||||
[combineIds(e.group_number, e.peer_number)]
|
[combineIds(e.group_number, e.peer_number)]
|
||||||
[transfer_id]
|
[transfer_id]
|
||||||
.v = SendingTransfer::Info{msg.get<Components::FT1InfoSHA1Data>().data};
|
.v = SendingTransfer::Info{content.get<Components::FT1InfoSHA1Data>().data};
|
||||||
} else if (e.file_kind == NGCFT1_file_kind::HASH_SHA1_CHUNK) {
|
} else if (e.file_kind == NGCFT1_file_kind::HASH_SHA1_CHUNK) {
|
||||||
if (e.file_id_size != 20) {
|
if (e.file_id_size != 20) {
|
||||||
// error
|
// error
|
||||||
@ -337,14 +372,16 @@ bool SHA1_NGCFT1::onEvent(const Events::NGCFT1_send_data& e) {
|
|||||||
}
|
}
|
||||||
} else if (std::holds_alternative<SendingTransfer::Chunk>(transfer.v)) {
|
} else if (std::holds_alternative<SendingTransfer::Chunk>(transfer.v)) {
|
||||||
auto& chunk_transfer = std::get<SendingTransfer::Chunk>(transfer.v);
|
auto& chunk_transfer = std::get<SendingTransfer::Chunk>(transfer.v);
|
||||||
const auto data = chunk_transfer.msg.get<Message::Components::Transfer::File>()->read(chunk_transfer.offset_into_file + e.data_offset, e.data_size);
|
// TODO: should we really use file?
|
||||||
|
const auto data = chunk_transfer.content.get<Message::Components::Transfer::File>()->read(chunk_transfer.offset_into_file + e.data_offset, e.data_size);
|
||||||
|
|
||||||
// TODO: optimize
|
// TODO: optimize
|
||||||
for (size_t i = 0; i < e.data_size && i < data.size(); i++) {
|
for (size_t i = 0; i < e.data_size && i < data.size(); i++) {
|
||||||
e.data[i] = data[i];
|
e.data[i] = data[i];
|
||||||
}
|
}
|
||||||
|
|
||||||
chunk_transfer.msg.get_or_emplace<Message::Components::Transfer::BytesSent>().total += data.size();
|
chunk_transfer.content.get_or_emplace<Message::Components::Transfer::BytesSent>().total += data.size();
|
||||||
|
// TODO: add event to propergate to messages
|
||||||
//_rmm.throwEventUpdate(transfer); // should we?
|
//_rmm.throwEventUpdate(transfer); // should we?
|
||||||
|
|
||||||
//if (e.data_offset + e.data_size >= *insert chunk size here*) {
|
//if (e.data_offset + e.data_size >= *insert chunk size here*) {
|
||||||
@ -411,11 +448,6 @@ bool SHA1_NGCFT1::onEvent(const Events::NGCFT1_recv_message& e) {
|
|||||||
|
|
||||||
reg.emplace<Message::Components::Transfer::TagReceiving>(new_msg_e); // add sending?
|
reg.emplace<Message::Components::Transfer::TagReceiving>(new_msg_e); // add sending?
|
||||||
|
|
||||||
//reg_ptr->emplace<Components::FT1InfoSHA1>(e, sha1_info);
|
|
||||||
//reg_ptr->emplace<Components::FT1InfoSHA1Data>(e, sha1_info_data); // keep around? or file?
|
|
||||||
reg.emplace<Components::FT1InfoSHA1Hash>(new_msg_e, std::vector<uint8_t>{e.file_id, e.file_id+e.file_id_size});
|
|
||||||
// TODO: queue info dl
|
|
||||||
|
|
||||||
reg.emplace<Message::Components::TimestampProcessed>(new_msg_e, ts);
|
reg.emplace<Message::Components::TimestampProcessed>(new_msg_e, ts);
|
||||||
//reg.emplace<Components::TimestampWritten>(new_msg_e, 0);
|
//reg.emplace<Components::TimestampWritten>(new_msg_e, 0);
|
||||||
reg.emplace<Message::Components::Timestamp>(new_msg_e, ts); // reactive?
|
reg.emplace<Message::Components::Timestamp>(new_msg_e, ts); // reactive?
|
||||||
@ -425,6 +457,58 @@ bool SHA1_NGCFT1::onEvent(const Events::NGCFT1_recv_message& e) {
|
|||||||
synced_by.emplace(self_c);
|
synced_by.emplace(self_c);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// check if content exists
|
||||||
|
const auto sha1_info_hash = std::vector<uint8_t>{e.file_id, e.file_id+e.file_id_size};
|
||||||
|
ContentHandle ce;
|
||||||
|
if (_info_to_content.count(sha1_info_hash)) {
|
||||||
|
ce = _info_to_content.at(sha1_info_hash);
|
||||||
|
std::cout << "SHA1_NGCFT1: new message has existing content\n";
|
||||||
|
} else {
|
||||||
|
ce = {_contentr, _contentr.create()};
|
||||||
|
_info_to_content[sha1_info_hash] = ce;
|
||||||
|
std::cout << "SHA1_NGCFT1: new message has new content\n";
|
||||||
|
|
||||||
|
//ce.emplace<Components::FT1InfoSHA1>(sha1_info);
|
||||||
|
//ce.emplace<Components::FT1InfoSHA1Data>(sha1_info_data); // keep around? or file?
|
||||||
|
ce.emplace<Components::FT1InfoSHA1Hash>(sha1_info_hash);
|
||||||
|
//{ // lookup tables and have
|
||||||
|
//auto& cc = ce.emplace<Components::FT1ChunkSHA1Cache>();
|
||||||
|
//cc.have_all = true;
|
||||||
|
//// skip have vec, since all
|
||||||
|
////cc.have_chunk
|
||||||
|
//cc.have_count = sha1_info.chunks.size(); // need?
|
||||||
|
|
||||||
|
//_info_to_content[sha1_info_hash] = ce;
|
||||||
|
//for (size_t i = 0; i < sha1_info.chunks.size(); i++) {
|
||||||
|
//_chunks[sha1_info.chunks[i]] = ce;
|
||||||
|
//cc.chunk_hash_to_index[sha1_info.chunks[i]] = i;
|
||||||
|
//}
|
||||||
|
//}
|
||||||
|
|
||||||
|
// TODO: ft1 specific comp
|
||||||
|
//ce.emplace<Message::Components::Transfer::File>(std::move(file_impl));
|
||||||
|
}
|
||||||
|
ce.get_or_emplace<Components::Messages>().messages.push_back({reg, new_msg_e});
|
||||||
|
|
||||||
|
// TODO: queue info dl
|
||||||
|
|
||||||
|
//reg_ptr->emplace<Components::FT1InfoSHA1>(e, sha1_info);
|
||||||
|
//reg_ptr->emplace<Components::FT1InfoSHA1Data>(e, sha1_info_data); // keep around? or file?
|
||||||
|
//reg.emplace<Components::FT1InfoSHA1Hash>(new_msg_e, std::vector<uint8_t>{e.file_id, e.file_id+e.file_id_size});
|
||||||
|
|
||||||
|
if (auto* cc = ce.try_get<Components::FT1ChunkSHA1Cache>(); cc != nullptr && cc->have_all) {
|
||||||
|
reg_ptr->emplace<Message::Components::Transfer::TagHaveAll>(new_msg_e);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (ce.all_of<Message::Components::Transfer::FileInfo>()) {
|
||||||
|
reg_ptr->emplace<Message::Components::Transfer::FileInfo>(new_msg_e, ce.get<Message::Components::Transfer::FileInfo>());
|
||||||
|
}
|
||||||
|
if (ce.all_of<Message::Components::Transfer::FileInfoLocal>()) {
|
||||||
|
reg_ptr->emplace<Message::Components::Transfer::FileInfoLocal>(new_msg_e, ce.get<Message::Components::Transfer::FileInfoLocal>());
|
||||||
|
}
|
||||||
|
if (ce.all_of<Message::Components::Transfer::BytesSent>()) {
|
||||||
|
reg_ptr->emplace<Message::Components::Transfer::BytesSent>(new_msg_e, ce.get<Message::Components::Transfer::BytesSent>());
|
||||||
|
}
|
||||||
|
|
||||||
// TODO: queue info/check if we already have info
|
// TODO: queue info/check if we already have info
|
||||||
|
|
||||||
@ -448,7 +532,8 @@ bool SHA1_NGCFT1::sendFilePath(const Contact3 c, std::string_view file_name, std
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
// TODO: rw
|
// TODO: rw?
|
||||||
|
// TODO: memory mapped would be king
|
||||||
auto file_impl = std::make_unique<FileRFile>(file_path);
|
auto file_impl = std::make_unique<FileRFile>(file_path);
|
||||||
if (!file_impl->isGood()) {
|
if (!file_impl->isGood()) {
|
||||||
std::cerr << "SHA1_NGCFT1 error: failed opening file '" << file_path << "'!\n";
|
std::cerr << "SHA1_NGCFT1 error: failed opening file '" << file_path << "'!\n";
|
||||||
@ -489,56 +574,127 @@ bool SHA1_NGCFT1::sendFilePath(const Contact3 c, std::string_view file_name, std
|
|||||||
sha1_info_hash = hash_sha1(sha1_info_data.data(), sha1_info_data.size());
|
sha1_info_hash = hash_sha1(sha1_info_data.data(), sha1_info_data.size());
|
||||||
std::cout << "SHA1_NGCFT1 sha1_info_hash: " << bin2hex(sha1_info_hash) << "\n";
|
std::cout << "SHA1_NGCFT1 sha1_info_hash: " << bin2hex(sha1_info_hash) << "\n";
|
||||||
|
|
||||||
|
// check if content exists
|
||||||
|
ContentHandle ce;
|
||||||
|
if (_info_to_content.count(sha1_info_hash)) {
|
||||||
|
ce = _info_to_content.at(sha1_info_hash);
|
||||||
|
|
||||||
|
// TODO: check if content is incomplete and use file instead
|
||||||
|
if (!ce.all_of<Components::FT1InfoSHA1>()) {
|
||||||
|
ce.emplace<Components::FT1InfoSHA1>(sha1_info);
|
||||||
|
}
|
||||||
|
if (!ce.all_of<Components::FT1InfoSHA1Data>()) {
|
||||||
|
ce.emplace<Components::FT1InfoSHA1Data>(sha1_info_data);
|
||||||
|
}
|
||||||
|
|
||||||
|
// hash has to be set already
|
||||||
|
// Components::FT1InfoSHA1Hash
|
||||||
|
|
||||||
|
{ // lookup tables and have
|
||||||
|
auto& cc = ce.get_or_emplace<Components::FT1ChunkSHA1Cache>();
|
||||||
|
cc.have_all = true;
|
||||||
|
// skip have vec, since all
|
||||||
|
//cc.have_chunk
|
||||||
|
cc.have_count = sha1_info.chunks.size(); // need?
|
||||||
|
|
||||||
|
_info_to_content[sha1_info_hash] = ce;
|
||||||
|
for (size_t i = 0; i < sha1_info.chunks.size(); i++) {
|
||||||
|
_chunks[sha1_info.chunks[i]] = ce;
|
||||||
|
cc.chunk_hash_to_index[sha1_info.chunks[i]] = i;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
{ // file info
|
||||||
|
// TODO: not overwrite fi? since same?
|
||||||
|
auto& file_info = ce.emplace_or_replace<Message::Components::Transfer::FileInfo>();
|
||||||
|
file_info.file_list.emplace_back() = {std::string{file_name}, file_impl->_file_size};
|
||||||
|
file_info.total_size = file_impl->_file_size;
|
||||||
|
|
||||||
|
ce.emplace_or_replace<Message::Components::Transfer::FileInfoLocal>(std::vector{std::string{file_path}});
|
||||||
|
}
|
||||||
|
|
||||||
|
// cleanup file
|
||||||
|
if (ce.all_of<Message::Components::Transfer::File>()) {
|
||||||
|
// replace
|
||||||
|
ce.remove<Message::Components::Transfer::File>();
|
||||||
|
}
|
||||||
|
ce.emplace<Message::Components::Transfer::File>(std::move(file_impl));
|
||||||
|
|
||||||
|
if (!ce.all_of<Message::Components::Transfer::BytesSent>()) {
|
||||||
|
ce.emplace<Message::Components::Transfer::BytesSent>(0u);
|
||||||
|
}
|
||||||
|
|
||||||
|
// TODO: make sure to abort every receiving transfer (sending info and chunk should be fine, info uses copy and chunk handle)
|
||||||
|
} else {
|
||||||
|
ce = {_contentr, _contentr.create()};
|
||||||
|
_info_to_content[sha1_info_hash] = ce;
|
||||||
|
|
||||||
|
ce.emplace<Components::FT1InfoSHA1>(sha1_info);
|
||||||
|
ce.emplace<Components::FT1InfoSHA1Data>(sha1_info_data); // keep around? or file?
|
||||||
|
ce.emplace<Components::FT1InfoSHA1Hash>(sha1_info_hash);
|
||||||
|
{ // lookup tables and have
|
||||||
|
auto& cc = ce.emplace<Components::FT1ChunkSHA1Cache>();
|
||||||
|
cc.have_all = true;
|
||||||
|
// skip have vec, since all
|
||||||
|
//cc.have_chunk
|
||||||
|
cc.have_count = sha1_info.chunks.size(); // need?
|
||||||
|
|
||||||
|
_info_to_content[sha1_info_hash] = ce;
|
||||||
|
for (size_t i = 0; i < sha1_info.chunks.size(); i++) {
|
||||||
|
_chunks[sha1_info.chunks[i]] = ce;
|
||||||
|
cc.chunk_hash_to_index[sha1_info.chunks[i]] = i;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
{ // file info
|
||||||
|
auto& file_info = ce.emplace<Message::Components::Transfer::FileInfo>();
|
||||||
|
//const auto& file = ce.get<Message::Components::Transfer::File>();
|
||||||
|
file_info.file_list.emplace_back() = {std::string{file_name}, file_impl->_file_size};
|
||||||
|
file_info.total_size = file_impl->_file_size;
|
||||||
|
|
||||||
|
ce.emplace<Message::Components::Transfer::FileInfoLocal>(std::vector{std::string{file_path}});
|
||||||
|
}
|
||||||
|
|
||||||
|
ce.emplace<Message::Components::Transfer::File>(std::move(file_impl));
|
||||||
|
|
||||||
|
ce.emplace<Message::Components::Transfer::BytesSent>(0u);
|
||||||
|
}
|
||||||
|
|
||||||
const auto c_self = _cr.get<Contact::Components::Self>(c).self;
|
const auto c_self = _cr.get<Contact::Components::Self>(c).self;
|
||||||
if (!_cr.valid(c_self)) {
|
if (!_cr.valid(c_self)) {
|
||||||
std::cerr << "SHA1_NGCFT1 error: failed to get self!\n";
|
std::cerr << "SHA1_NGCFT1 error: failed to get self!\n";
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
const auto e = reg_ptr->create();
|
|
||||||
reg_ptr->emplace<Message::Components::ContactTo>(e, c);
|
|
||||||
reg_ptr->emplace<Message::Components::ContactFrom>(e, c_self);
|
|
||||||
reg_ptr->emplace<Message::Components::Timestamp>(e, ts); // reactive?
|
|
||||||
|
|
||||||
reg_ptr->emplace<Message::Components::Transfer::TagHaveAll>(e);
|
const auto msg_e = reg_ptr->create();
|
||||||
reg_ptr->emplace<Message::Components::Transfer::TagSending>(e);
|
reg_ptr->emplace<Message::Components::ContactTo>(msg_e, c);
|
||||||
|
reg_ptr->emplace<Message::Components::ContactFrom>(msg_e, c_self);
|
||||||
|
reg_ptr->emplace<Message::Components::Timestamp>(msg_e, ts); // reactive?
|
||||||
|
|
||||||
reg_ptr->emplace<Components::FT1InfoSHA1>(e, sha1_info);
|
reg_ptr->emplace<Message::Components::Transfer::TagHaveAll>(msg_e);
|
||||||
reg_ptr->emplace<Components::FT1InfoSHA1Data>(e, sha1_info_data); // keep around? or file?
|
reg_ptr->emplace<Message::Components::Transfer::TagSending>(msg_e);
|
||||||
reg_ptr->emplace<Components::FT1InfoSHA1Hash>(e, sha1_info_hash);
|
|
||||||
{ // lookup tables and have
|
ce.get_or_emplace<Components::Messages>().messages.push_back({*reg_ptr, msg_e});
|
||||||
auto& cc = reg_ptr->emplace<Components::FT1ChunkSHA1Cache>(e);
|
|
||||||
cc.have_all = true;
|
|
||||||
// skip have vec, since all
|
|
||||||
//cc.have_chunk
|
|
||||||
cc.have_count = sha1_info.chunks.size(); // need?
|
|
||||||
|
|
||||||
_info_to_message[sha1_info_hash] = {*reg_ptr, e};
|
|
||||||
for (size_t i = 0; i < sha1_info.chunks.size(); i++) {
|
|
||||||
_chunks[sha1_info.chunks[i]] = {*reg_ptr, e};
|
|
||||||
cc.chunk_hash_to_index[sha1_info.chunks[i]] = i;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
//reg_ptr->emplace<Message::Components::Transfer::FileKind>(e, file_kind);
|
//reg_ptr->emplace<Message::Components::Transfer::FileKind>(e, file_kind);
|
||||||
// file id would be sha1_info hash or something
|
// file id would be sha1_info hash or something
|
||||||
//reg_ptr->emplace<Message::Components::Transfer::FileID>(e, file_id);
|
//reg_ptr->emplace<Message::Components::Transfer::FileID>(e, file_id);
|
||||||
|
|
||||||
{ // file info
|
if (ce.all_of<Message::Components::Transfer::FileInfo>()) {
|
||||||
auto& file_info = reg_ptr->emplace<Message::Components::Transfer::FileInfo>(e);
|
reg_ptr->emplace<Message::Components::Transfer::FileInfo>(msg_e, ce.get<Message::Components::Transfer::FileInfo>());
|
||||||
file_info.file_list.emplace_back() = {std::string{file_name}, file_impl->_file_size};
|
}
|
||||||
file_info.total_size = file_impl->_file_size;
|
if (ce.all_of<Message::Components::Transfer::FileInfoLocal>()) {
|
||||||
|
reg_ptr->emplace<Message::Components::Transfer::FileInfoLocal>(msg_e, ce.get<Message::Components::Transfer::FileInfoLocal>());
|
||||||
reg_ptr->emplace<Message::Components::Transfer::FileInfoLocal>(e, std::vector{std::string{file_path}});
|
}
|
||||||
|
if (ce.all_of<Message::Components::Transfer::BytesSent>()) {
|
||||||
|
reg_ptr->emplace<Message::Components::Transfer::BytesSent>(msg_e, ce.get<Message::Components::Transfer::BytesSent>());
|
||||||
}
|
}
|
||||||
|
|
||||||
reg_ptr->emplace<Message::Components::Transfer::BytesSent>(e);
|
|
||||||
|
|
||||||
// TODO: determine if this is true
|
// TODO: determine if this is true
|
||||||
//reg_ptr->emplace<Message::Components::Transfer::TagPaused>(e);
|
//reg_ptr->emplace<Message::Components::Transfer::TagPaused>(e);
|
||||||
|
|
||||||
// TODO: ft1 specific comp
|
|
||||||
reg_ptr->emplace<Message::Components::Transfer::File>(e, std::move(file_impl));
|
|
||||||
#if 0
|
#if 0
|
||||||
const auto friend_number = _cr.get<Contact::Components::ToxFriendEphemeral>(c).friend_number;
|
const auto friend_number = _cr.get<Contact::Components::ToxFriendEphemeral>(c).friend_number;
|
||||||
const auto&& [transfer_id, err] = _t.toxFileSend(friend_number, file_kind, file_impl->_file_size, file_id, file_name);
|
const auto&& [transfer_id, err] = _t.toxFileSend(friend_number, file_kind, file_impl->_file_size, file_id, file_name);
|
||||||
@ -556,10 +712,10 @@ bool SHA1_NGCFT1::sendFilePath(const Contact3 c, std::string_view file_name, std
|
|||||||
|
|
||||||
// TODO: check return
|
// TODO: check return
|
||||||
_nft.NGC_FT1_send_message_public(group_number, message_id, static_cast<uint32_t>(NGCFT1_file_kind::HASH_SHA1_INFO), sha1_info_hash.data(), sha1_info_hash.size());
|
_nft.NGC_FT1_send_message_public(group_number, message_id, static_cast<uint32_t>(NGCFT1_file_kind::HASH_SHA1_INFO), sha1_info_hash.data(), sha1_info_hash.size());
|
||||||
reg_ptr->emplace<Message::Components::ToxGroupMessageID>(e, message_id);
|
reg_ptr->emplace<Message::Components::ToxGroupMessageID>(msg_e, message_id);
|
||||||
|
|
||||||
// TODO: generalize?
|
// TODO: generalize?
|
||||||
auto& synced_by = reg_ptr->emplace<Message::Components::SyncedBy>(e).list;
|
auto& synced_by = reg_ptr->emplace<Message::Components::SyncedBy>(msg_e).list;
|
||||||
synced_by.emplace(c_self);
|
synced_by.emplace(c_self);
|
||||||
} else if (
|
} else if (
|
||||||
// non online group
|
// non online group
|
||||||
@ -567,14 +723,17 @@ bool SHA1_NGCFT1::sendFilePath(const Contact3 c, std::string_view file_name, std
|
|||||||
) {
|
) {
|
||||||
// create msg_id
|
// create msg_id
|
||||||
const uint32_t message_id = randombytes_random();
|
const uint32_t message_id = randombytes_random();
|
||||||
reg_ptr->emplace<Message::Components::ToxGroupMessageID>(e, message_id);
|
reg_ptr->emplace<Message::Components::ToxGroupMessageID>(msg_e, message_id);
|
||||||
|
|
||||||
// TODO: generalize?
|
// TODO: generalize?
|
||||||
auto& synced_by = reg_ptr->emplace<Message::Components::SyncedBy>(e).list;
|
auto& synced_by = reg_ptr->emplace<Message::Components::SyncedBy>(msg_e).list;
|
||||||
synced_by.emplace(c_self);
|
synced_by.emplace(c_self);
|
||||||
}
|
}
|
||||||
|
|
||||||
_rmm.throwEventConstruct(*reg_ptr, e);
|
_rmm.throwEventConstruct(*reg_ptr, msg_e);
|
||||||
|
|
||||||
|
// TODO: place in iterate?
|
||||||
|
updateMessages(ce);
|
||||||
|
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
@ -10,28 +10,36 @@
|
|||||||
|
|
||||||
#include "./ft1_sha1_info.hpp"
|
#include "./ft1_sha1_info.hpp"
|
||||||
|
|
||||||
|
#include <entt/entity/registry.hpp>
|
||||||
|
#include <entt/entity/handle.hpp>
|
||||||
#include <entt/container/dense_map.hpp>
|
#include <entt/container/dense_map.hpp>
|
||||||
|
|
||||||
#include <variant>
|
#include <variant>
|
||||||
|
|
||||||
|
enum class Content : uint32_t {};
|
||||||
|
using ContentRegistry = entt::basic_registry<Content>;
|
||||||
|
using ContentHandle = entt::basic_handle<ContentRegistry>;
|
||||||
|
|
||||||
class SHA1_NGCFT1 : public RegistryMessageModelEventI, public NGCFT1EventI {
|
class SHA1_NGCFT1 : public RegistryMessageModelEventI, public NGCFT1EventI {
|
||||||
Contact3Registry& _cr;
|
Contact3Registry& _cr;
|
||||||
RegistryMessageModel& _rmm;
|
RegistryMessageModel& _rmm;
|
||||||
NGCFT1& _nft;
|
NGCFT1& _nft;
|
||||||
ToxContactModel2& _tcm;
|
ToxContactModel2& _tcm;
|
||||||
|
|
||||||
|
// registry per group?
|
||||||
|
ContentRegistry _contentr;
|
||||||
|
|
||||||
// limit this to each group?
|
// limit this to each group?
|
||||||
entt::dense_map<SHA1Digest, Message3Handle> _info_to_message;
|
entt::dense_map<SHA1Digest, ContentHandle> _info_to_content;
|
||||||
|
|
||||||
// sha1 chunk index
|
// sha1 chunk index
|
||||||
// TODO: optimize lookup
|
// TODO: optimize lookup
|
||||||
entt::dense_map<SHA1Digest, Message3Handle> _chunks;
|
entt::dense_map<SHA1Digest, ContentHandle> _chunks;
|
||||||
|
|
||||||
// group_number, peer_number, message, chunk_hash, timer
|
// group_number, peer_number, content, chunk_hash, timer
|
||||||
std::deque<std::tuple<uint32_t, uint32_t, Message3Handle, SHA1Digest, float>> _queue_requested_chunk;
|
std::deque<std::tuple<uint32_t, uint32_t, ContentHandle, SHA1Digest, float>> _queue_requested_chunk;
|
||||||
//void queueUpRequestInfo(uint32_t group_number, uint32_t peer_number, const SHA1Digest& hash);
|
//void queueUpRequestInfo(uint32_t group_number, uint32_t peer_number, const SHA1Digest& hash);
|
||||||
void queueUpRequestChunk(uint32_t group_number, uint32_t peer_number, Message3Handle msg, const SHA1Digest& hash);
|
void queueUpRequestChunk(uint32_t group_number, uint32_t peer_number, ContentHandle content, const SHA1Digest& hash);
|
||||||
|
|
||||||
struct SendingTransfer {
|
struct SendingTransfer {
|
||||||
struct Info {
|
struct Info {
|
||||||
@ -41,7 +49,7 @@ class SHA1_NGCFT1 : public RegistryMessageModelEventI, public NGCFT1EventI {
|
|||||||
};
|
};
|
||||||
|
|
||||||
struct Chunk {
|
struct Chunk {
|
||||||
Message3Handle msg;
|
ContentHandle content;
|
||||||
uint64_t offset_into_file;
|
uint64_t offset_into_file;
|
||||||
// or data?
|
// or data?
|
||||||
// if memmapped, this would be just a pointer
|
// if memmapped, this would be just a pointer
|
||||||
@ -54,8 +62,32 @@ class SHA1_NGCFT1 : public RegistryMessageModelEventI, public NGCFT1EventI {
|
|||||||
// key is groupid + peerid
|
// key is groupid + peerid
|
||||||
entt::dense_map<uint64_t, entt::dense_map<uint8_t, SendingTransfer>> _sending_transfers;
|
entt::dense_map<uint64_t, entt::dense_map<uint8_t, SendingTransfer>> _sending_transfers;
|
||||||
|
|
||||||
|
struct ReceivingTransfer {
|
||||||
|
struct Info {
|
||||||
|
// copy of info data
|
||||||
|
// too large?
|
||||||
|
std::vector<uint8_t> info_data;
|
||||||
|
// content?
|
||||||
|
};
|
||||||
|
|
||||||
|
struct Chunk {
|
||||||
|
ContentHandle content;
|
||||||
|
uint64_t offset_into_file;
|
||||||
|
// or data?
|
||||||
|
// if memmapped, this would be just a pointer
|
||||||
|
};
|
||||||
|
|
||||||
|
std::variant<Info, Chunk> v;
|
||||||
|
|
||||||
|
float time_since_activity {0.f};
|
||||||
|
};
|
||||||
|
// key is groupid + peerid
|
||||||
|
entt::dense_map<uint64_t, entt::dense_map<uint8_t, ReceivingTransfer>> _receiving_transfers;
|
||||||
|
|
||||||
static uint64_t combineIds(const uint32_t group_number, const uint32_t peer_number);
|
static uint64_t combineIds(const uint32_t group_number, const uint32_t peer_number);
|
||||||
|
|
||||||
|
void updateMessages(ContentHandle ce);
|
||||||
|
|
||||||
public: // TODO: config
|
public: // TODO: config
|
||||||
bool _udp_only {false};
|
bool _udp_only {false};
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user