From 283d3ad575ca437647cebd149a12696fe6e15e09 Mon Sep 17 00:00:00 2001
From: Green Sky <green@g-s.xyz>
Date: Mon, 29 Jan 2024 17:07:58 +0100
Subject: [PATCH] reactive + more config

---
 src/solanaceae/rpbot/rpbot.cpp | 43 +++++++++++++++++++++++++++++++++-
 src/solanaceae/rpbot/rpbot.hpp |  5 +++-
 2 files changed, 46 insertions(+), 2 deletions(-)

diff --git a/src/solanaceae/rpbot/rpbot.cpp b/src/solanaceae/rpbot/rpbot.cpp
index 9df6879..5517eaf 100644
--- a/src/solanaceae/rpbot/rpbot.cpp
+++ b/src/solanaceae/rpbot/rpbot.cpp
@@ -172,7 +172,8 @@ float RPBot::doAllIdle(float time_delta) {
 		if (state.timeout <= 0.f) {
 			std::cout << "RPBot: idle timed out\n";
 			// TODO: use multiprompt and better system promp to start immediatly
-			if (auto* mreg = _rmm.get(c); mreg != nullptr && mreg->view<Message::Components::MessageText>().size() >= 4) {
+			// TODO: per id min_messages
+			if (auto* mreg = _rmm.get(c); mreg != nullptr && mreg->view<Message::Components::MessageText>().size() >= _conf.get_int("RPBot", "min_messages").value_or(4)) {
 				to_remove_stateidle.push_back(c);
 				min_tick_interval = 0.1f;
 
@@ -265,3 +266,43 @@ float RPBot::doAllTimingCheck(float time_delta) {
 	return min_tick_interval;
 }
 
+bool RPBot::onEvent(const Message::Events::MessageConstruct& e) {
+	if (!e.e.all_of<Message::Components::ContactFrom, Message::Components::ContactTo>()) {
+		return false;
+	}
+
+	const auto contact_to = e.e.get<Message::Components::ContactTo>().c;
+	const auto contact_from = e.e.get<Message::Components::ContactFrom>().c;
+
+	if (!_cr.valid(contact_to) || !_cr.valid(contact_from)) {
+		std::cerr << "RPBot error: invalid contact in message\n";
+		return false;
+	}
+
+	Contact3 rpbot_contact = entt::null;
+
+	// check ContactTo (public)
+	// check ContactTo parent (group private)
+	// check ContactFrom (private)
+
+	if (_cr.any_of<StateIdle, StateNextActor, StateGenerateMsg, StateTimingCheck>(contact_to)) {
+		rpbot_contact = contact_to;
+	} else if (_cr.all_of<Contact::Components::Parent>(contact_to)) {
+		rpbot_contact = _cr.get<Contact::Components::Parent>(contact_to).parent;
+	} else if (_cr.any_of<StateIdle, StateNextActor, StateGenerateMsg, StateTimingCheck>(contact_from)) {
+		rpbot_contact = contact_from;
+	} else {
+		return false; // not a rpbot related message
+	}
+
+	if (!_cr.all_of<StateIdle>(rpbot_contact)) {
+		return false; // not idle
+	}
+
+	auto& timeout = _cr.get<StateIdle>(rpbot_contact).timeout;
+	// TODO: config with id
+	timeout = std::min<float>(timeout, _conf.get_double("RPBot", "max_interactive_delay").value_or(4.f));
+
+	return false;
+}
+
diff --git a/src/solanaceae/rpbot/rpbot.hpp b/src/solanaceae/rpbot/rpbot.hpp
index 0de6563..7321791 100644
--- a/src/solanaceae/rpbot/rpbot.hpp
+++ b/src/solanaceae/rpbot/rpbot.hpp
@@ -16,7 +16,7 @@ struct StateNextActor;
 struct StateGenerateMsg;
 struct StateTimingCheck;
 
-struct RPBot {
+struct RPBot : public RegistryMessageModelEventI {
 	TextCompletionI& _completion;
 	ConfigModelI& _conf;
 	Contact3Registry& _cr;
@@ -57,5 +57,8 @@ struct RPBot {
 		float doAllNext(float time_delta);
 		float doAllGenerateMsg(float time_delta);
 		float doAllTimingCheck(float time_delta);
+
+	protected: // onMsg
+		bool onEvent(const Message::Events::MessageConstruct& e) override;
 };