avatar sending, uses self in avatar dir

also fix cwd in file selector

src/tox_avatar_sender.cpp

@@ -0,0 +1,215 @@
+#include "./tox_avatar_sender.hpp"
+
+#include <solanaceae/contact/components.hpp>
+#include <solanaceae/contact/contact_store_events.hpp>
+#include <solanaceae/tox_contacts/components.hpp>
+#include <solanaceae/object_store/object_store.hpp>
+#include <solanaceae/object_store/meta_components.hpp>
+#include <solanaceae/object_store/meta_components_file.hpp>
+#include <solanaceae/tox_messages/obj_components.hpp>
+
+#include <iostream>
+
+namespace Components {
+	struct TagAvatarOffered {};
+} // Components
+
+bool ToxAvatarSender::checkContact(ContactHandle4 c) {
+	// check if tox friend and not sent
+	if (!c.all_of<
+		Contact::Components::ToxFriendEphemeral,
+		Contact::Components::ConnectionState
+	>()) {
+		return false;
+	}
+	if (c.any_of<Components::TagAvatarOffered>()) {
+		return false;
+	}
+
+	// is (not) self
+	if (c.all_of<Contact::Components::TagSelfStrong>()) {
+		return false;
+	}
+
+	if (!c.all_of<Contact::Components::Self>()) {
+		std::cout << "TAS warning: contact has no self\n";
+		return false;
+	}
+
+	auto self_c = _cs.contactHandle(c.get<Contact::Components::Self>().self);
+	if (!static_cast<bool>(self_c)) {
+		std::cerr << "TAS error: invalid self\n";
+		assert(false);
+		return false;
+	}
+
+	// self has avatar (obj)
+	if (!self_c.all_of<Contact::Components::AvatarObj>()) {
+		return false;
+	}
+
+	return true;
+}
+
+bool ToxAvatarSender::inQueue(ContactHandle4 c) const {
+	return std::find_if(_queue.cbegin(), _queue.cend(), [&c](const Entry& e) { return e.c == c; }) != _queue.cend();
+}
+
+void ToxAvatarSender::addToQueue(ContactHandle4 c) {
+	assert(!inQueue(c));
+	_queue.push_back({
+		c,
+		c.get<Contact::Components::ConnectionState>().state
+	});
+}
+
+void ToxAvatarSender::sendAvatar(ContactHandle4 c) {
+	std::cout << "TAS: sending self avatar to " << entt::to_integral(c.entity()) << "\n";
+
+	if (!c.all_of<Contact::Components::Self>()) {
+		std::cout << "TAS warning: contact has no self\n";
+		return;
+	}
+
+	auto self_c = _cs.contactHandle(c.get<Contact::Components::Self>().self);
+	if (!static_cast<bool>(self_c)) {
+		std::cerr << "TAS error: invalid self\n";
+		assert(false);
+		return;
+	}
+
+	if (!self_c.all_of<Contact::Components::AvatarObj>()) {
+		return;
+	}
+
+	const auto ao = self_c.get<Contact::Components::AvatarObj>().obj;
+
+	// .... ?
+	// duplicate object?
+	// a single object can only ever be one transfer (meh)
+	// TODO: make object multi transfer-able (enforce)
+	auto self_o = _os.objectHandle(ao);
+	if (!static_cast<bool>(self_o)) {
+		std::cerr << "TAS error: self avatar obj not real?\n";
+		return;
+	}
+	// TODO: move to tox avatar specific backend
+	// HACK: manual clone
+	// using self_o meta backend newObject() should emplace the file backend too
+	auto new_o = self_o.get<ObjComp::Ephemeral::BackendMeta>().ptr->newObject(ByteSpan{}, false);
+	assert(new_o);
+
+	if (self_o.all_of<ObjComp::ID>()) {
+		new_o.emplace_or_replace<ObjComp::ID>(self_o.get<ObjComp::ID>());
+	}
+	if (self_o.all_of<ObjComp::F::SingleInfo>()) {
+		new_o.emplace_or_replace<ObjComp::F::SingleInfo>(self_o.get<ObjComp::F::SingleInfo>());
+	}
+	if (self_o.all_of<ObjComp::F::SingleInfoLocal>()) {
+		new_o.emplace_or_replace<ObjComp::F::SingleInfoLocal>(self_o.get<ObjComp::F::SingleInfoLocal>());
+	}
+	if (self_o.all_of<ObjComp::F::TagLocalHaveAll>()) {
+		new_o.emplace_or_replace<ObjComp::F::TagLocalHaveAll>();
+	}
+
+	// tox avatar
+	new_o.emplace_or_replace<ObjComp::Tox::FileKind>(uint64_t(1));
+
+	_os.throwEventConstruct(new_o); // ?
+
+	if (!_rmm.sendFileObj(c, new_o)) {
+		std::cerr << "TAS error: failed to send avatar file obj\n";
+		_os.throwEventDestroy(new_o);
+		new_o.destroy();
+	}
+
+	c.emplace_or_replace<Components::TagAvatarOffered>();
+}
+
+ToxAvatarSender::ToxAvatarSender(ObjectStore2& os, ContactStore4I& cs, RegistryMessageModelI& rmm) :
+	_os(os),
+	_cs(cs),
+	_cs_sr(cs.newSubRef(this)),
+	_rmm(rmm),
+	_rmm_sr(_rmm.newSubRef(this))
+{
+	_cs_sr
+		.subscribe(ContactStore4_Event::contact_construct)
+		.subscribe(ContactStore4_Event::contact_update)
+		.subscribe(ContactStore4_Event::contact_destroy)
+	;
+
+	_rmm_sr
+		.subscribe(RegistryMessageModel_Event::send_file_obj)
+	;
+}
+
+void ToxAvatarSender::iterate(float delta) {
+	for (auto it = _queue.begin(); it != _queue.end();) {
+		it->timer -= delta;
+		if (it->timer <= 0.f) {
+			sendAvatar(it->c);
+			it = _queue.erase(it);
+		} else {
+			it++;
+		}
+	}
+}
+
+bool ToxAvatarSender::onEvent(const ContactStore::Events::Contact4Construct& e) {
+	if (!static_cast<bool>(e.e)) {
+		assert(false);
+		return false;
+	}
+
+	if (!checkContact(e.e)) {
+		return false;
+	}
+
+	if (e.e.get<Contact::Components::ConnectionState>().state == Contact::Components::ConnectionState::disconnected) {
+		return false;
+	}
+
+	addToQueue(e.e);
+
+	return false;
+}
+
+bool ToxAvatarSender::onEvent(const ContactStore::Events::Contact4Update& e) {
+	if (!static_cast<bool>(e.e)) {
+		assert(false);
+		return false;
+	}
+
+	if (!checkContact(e.e)) {
+		return false;
+	}
+
+	auto it = std::find_if(_queue.begin(), _queue.end(), [c = e.e](const Entry& en) { return en.c == c; });
+	if (it != _queue.end()) {
+		// check if connections state changed and reset timer
+		const auto current_state = e.e.get<Contact::Components::ConnectionState>().state;
+		if (current_state == Contact::Components::ConnectionState::disconnected) {
+			_queue.erase(it);
+		} else if (it->ls != current_state) {
+			// state changed, reset timer
+			it->timer = 21.33f;
+		}
+	} else if (e.e.get<Contact::Components::ConnectionState>().state != Contact::Components::ConnectionState::disconnected) {
+		addToQueue(e.e);
+	}
+
+	return false;
+}
+
+bool ToxAvatarSender::onEvent(const ContactStore::Events::Contact4Destory& e) {
+	// remove from queue
+	// queue is assumed to be short
+	auto it = std::find_if(_queue.begin(), _queue.end(), [c = e.e](const Entry& en) { return en.c == c; });
+	if (it != _queue.end()) {
+		_queue.erase(it);
+	}
+
+	return false;
+}
+