Method accept

src/microReticulum/Resource.cpp:60–149

Accept an incoming resource advertisement, instantiate a receiver-side Resource and register it with the link. Mirror Python Resource.py:167. Returns a Resource (or NONE on rejection / duplicate). */

Returns a Resource (or NONE on rejection / duplicate).
*/
Resource Resource::accept(const Packet& advertisement_packet, Callbacks::concluded callback /*= nullptr*/, Callbacks::progress progress_callback /*= nullptr*/, const Bytes& request_id /*= {Bytes::NONE}*/) {
	ResourceAdvertisement adv = ResourceAdvertisement::unpack(advertisement_packet.plaintext());
	if (!adv._h) {
		DEBUG("Could not decode resource advertisement, dropping resource");
		return {Type::NONE};
	}

	// Allocate a receiver-side Resource via the minimal constructor. The
	// per-advertisement fields below overwrite the constructor's defaults
	// directly, so no fluent configuration is needed here.
	Link link = advertisement_packet.link();
	Resource resource({Bytes::NONE}, link);
	assert(resource._object);

	resource._object->_status            = Type::Resource::TRANSFERRING;
	resource._object->_flags             = adv._f;
	resource._object->_size              = adv._t;
	resource._object->_total_size        = adv._d;
	resource._object->_uncompressed_size = adv._d;
	resource._object->_hash              = adv._h;
	resource._object->_original_hash     = adv._o;
	resource._object->_random_hash       = adv._r;
	resource._object->_hashmap_raw       = adv._m;
	resource._object->_encrypted         = adv._e;
	resource._object->_compressed        = adv._c;
	resource._object->_initiator         = false;
	resource._object->_callbacks._concluded = callback;
	resource._object->_callbacks._progress  = progress_callback;
	resource._object->_total_parts       = static_cast<uint32_t>((adv._t + resource._object->_sdu - 1) / resource._object->_sdu);
	resource._object->_received_count    = 0;
	resource._object->_outstanding_parts = 0;
	resource._object->_window            = Type::Resource::WINDOW;
	resource._object->_window_max        = Type::Resource::WINDOW_MAX_SLOW;
	resource._object->_window_min        = Type::Resource::WINDOW_MIN;
	resource._object->_window_flexibility = Type::Resource::WINDOW_FLEXIBILITY;
	resource._object->_last_activity     = Utilities::OS::time();
	resource._object->_started_transferring = resource._object->_last_activity;
	resource._object->_advertisement_packet = advertisement_packet;
	resource._object->_segment_index     = adv._i;
	resource._object->_total_segments    = adv._l;
	resource._object->_split             = (adv._l > 1);
	resource._object->_has_metadata      = adv._x;
	resource._object->_consecutive_completed_height = -1;
	resource._object->_waiting_for_hmu   = false;
	resource._object->_receiving_part    = false;
	resource._object->_request_id        = request_id;
	// Mirror Python: the advertisement carries the request/response flags;
	// these are used by Link::resource_concluded() to dispatch on completion.
	resource._object->_is_response       = adv._p;

	// Pre-allocate the parts buffer with empty slots; receive_part() fills
	// each slot as the corresponding packet arrives.
	resource._object->_parts.clear();
	resource._object->_parts.reserve(resource._object->_total_parts);
	for (uint32_t i = 0; i < resource._object->_total_parts; ++i) {
		resource._object->_parts.push_back({Type::NONE});
	}
	// Hashmap holds N x MAPHASH_LEN bytes; pre-zero so missing entries are