microReticulum/test/test_rns_loopback/test_main.cpp

#include <unity.h>

#include "../common/filesystem/FileSystem.h"

#include <Reticulum.h>
#include <Transport.h>
#include <Log.h>

#ifdef ARDUINO
const char destination_table_path[] = "/destination_table";
#else
const char destination_table_path[] = "destination_table";
#endif

class InInterface : public RNS::InterfaceImpl {
public:
	InInterface(const char *name = "InInterface") : RNS::InterfaceImpl(name) {
		_OUT = false;
		_IN = true;
	}
	virtual ~InInterface() {
		_name = "(deleted)";
	}
	// Incoming interface only, send_outgoing not currently implemented
	virtual void send_outgoing(const RNS::Bytes &data) {}
	// Incoming is be handled automatically by InterfaceImpl::handle_incoming called via Interface::handle_incoming from OutInterface
};

class OutInterface : public RNS::InterfaceImpl {
public:
	OutInterface(RNS::Interface& in_interface, const char *name = "OutInterface") : RNS::InterfaceImpl(name), _in_interface(in_interface) {
		_OUT = true;
		_IN = false;
	}
	virtual ~OutInterface() {
		_name = "(deleted)";
	}
	virtual void send_outgoing(const RNS::Bytes &data) {
		HEADF(RNS::LOG_TRACE, "OutInterface.send_outgoing: data: %s", data.toHex().c_str());

		// Loop data back to InInterface for testing
		// NOTE: This sends the incoming data directory to RNS::Interface (which relays to Transport)
		//       and does not actually go through InInterface.
		_in_interface.handle_incoming(data);

		// Perform post-send housekeeping
		InterfaceImpl::handle_outgoing(data);
	}
private:
	RNS::Interface& _in_interface;
};

// Test AnnounceHandler
class ExampleAnnounceHandler : public RNS::AnnounceHandler {
public:
	ExampleAnnounceHandler(const char* aspect_filter = nullptr) : AnnounceHandler(aspect_filter) {}
	virtual ~ExampleAnnounceHandler() {}
	virtual void received_announce(const RNS::Bytes& destination_hash, const RNS::Identity& announced_identity, const RNS::Bytes& app_data) {
		INFO("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
		INFOF("ExampleAnnounceHandler: destination hash: %s", destination_hash.toHex().c_str());
		if (announced_identity) {
			INFOF("ExampleAnnounceHandler: announced identity hash: %s", announced_identity.hash().toHex().c_str());
			INFOF("ExampleAnnounceHandler: announced identity app data: %s", announced_identity.app_data().toHex().c_str());
		}
        if (app_data) {
			INFOF("ExampleAnnounceHandler: app data text: \"%s\"", app_data.toString().c_str());
		}
		INFO("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
	}
};

//ExampleAnnounceHandler announce_handler((const char*)"example_utilities.announcesample.fruits");
//RNS::HAnnounceHandler announce_handler(new ExampleAnnounceHandler("example_utilities.announcesample.fruits"));
RNS::HAnnounceHandler announce_handler(new ExampleAnnounceHandler());

// Test packet receive callback
//void(*)(const Bytes& data, const Packet& packet)
void onPacket(const RNS::Bytes& data, const RNS::Packet& packet) {
	INFO("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
	INFOF("onPacket: data: %s", data.toHex().c_str());
	INFOF("onPacket: text: \"%s\"", data.toString().c_str());
	//TRACEF("onPacket: %s", packet.debugString().c_str());
	INFO("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
}

// Ping packet receive callback
//void(*)(const Bytes& data, const Packet& packet)
void onPingPacket(const RNS::Bytes& data, const RNS::Packet& packet) {
	INFO("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
	INFOF("onPingPacket: data: %s", data.toHex().c_str());
	INFOF("onPingPacket: text: \"%s\"", data.toString().c_str());
	//TRACEF("onPingPacket: %s", packet.debugString().c_str());
	INFO("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
}


RNS::Reticulum reticulum({RNS::Type::NONE});
RNS::Identity identity({RNS::Type::NONE});
RNS::Destination destination({RNS::Type::NONE});
RNS::Interface in_interface(new InInterface());
RNS::Interface out_interface(new OutInterface(in_interface));

void testReticulum() {
	HEAD("Running testReticulum...", RNS::LOG_TRACE);

	HEAD("Registering Filesystem with OS...", RNS::LOG_TRACE);
	RNS::FileSystem reticulum_filesystem = new FileSystem();
	((FileSystem*)reticulum_filesystem.get())->init();
	RNS::Utilities::OS::register_filesystem(reticulum_filesystem);

	HEAD("Registering Interface instances with Transport...", RNS::LOG_TRACE);
	RNS::Transport::register_interface(in_interface);
	RNS::Transport::register_interface(out_interface);

	RNS::Bytes transport_prv_bytes;
#ifdef ARDUINO
	transport_prv_bytes.assignHex("CAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFECAFE");
#else
	transport_prv_bytes.assignHex("BABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABEBABE");
#endif
	RNS::Identity transport_identity(false);
	transport_identity.load_private_key(transport_prv_bytes);
	RNS::Transport::identity(transport_identity);

	HEAD("Creating Reticulum instance...", RNS::LOG_TRACE);
    reticulum = RNS::Reticulum();
	reticulum.transport_enabled(true);
	reticulum.probe_destination_enabled(true);
	reticulum.start();

	HEAD("Creating Identity instance...", RNS::LOG_TRACE);
	// new identity
	identity = RNS::Identity(false);
	RNS::Bytes prv_bytes;
#ifdef ARDUINO
	prv_bytes.assignHex("78E7D93E28D55871608FF13329A226CABC3903A357388A035B360162FF6321570B092E0583772AB80BC425F99791DF5CA2CA0A985FF0415DAB419BBC64DDFAE8");
#else
	prv_bytes.assignHex("E0D43398EDC974EBA9F4A83463691A08F4D306D4E56BA6B275B8690A2FBD9852E9EBE7C03BC45CAEC9EF8E78C830037210BFB9986F6CA2DEE2B5C28D7B4DE6B0");
#endif
	identity.load_private_key(prv_bytes);
	// 22.6% (+0.7%)

	HEAD("Creating Destination instance...", RNS::LOG_TRACE);
	//RNS::Destination destination(identity, RNS::Type::Destination::IN, RNS::Type::Destination::SINGLE, "app", "aspects");
	destination = RNS::Destination(identity, RNS::Type::Destination::IN, RNS::Type::Destination::SINGLE, "app", "aspects");
	// 23.0% (+0.4%)

	// Register DATA packet callback
	HEAD("Registering packet callback with Destination...", RNS::LOG_TRACE);
	destination.set_packet_callback(onPacket);
	destination.set_proof_strategy(RNS::Type::Destination::PROVE_ALL);

	{
		// Register PING packet callback
		HEAD("Creating PING Destination instance...", RNS::LOG_TRACE);
		RNS::Destination ping_destination(identity, RNS::Type::Destination::IN, RNS::Type::Destination::SINGLE, "example_utilities", "echo.request");

		HEAD("Registering packet callback with PING Destination...", RNS::LOG_TRACE);
		ping_destination.set_packet_callback(onPingPacket);
		ping_destination.set_proof_strategy(RNS::Type::Destination::PROVE_ALL);
	}

	HEAD("Registering announce handler with Transport...", RNS::LOG_TRACE);
	RNS::Transport::register_announce_handler(announce_handler);

	HEAD("Announcing destination...", RNS::LOG_TRACE);
	// test path
	//destination.announce(RNS::bytesFromString("test"), true, nullptr, RNS::bytesFromString("test_tag"));
	// test packet send
	destination.announce(RNS::bytesFromString("test"));
	// 23.9% (+0.8%)

	HEAD("Destroying Reticulum instance...", RNS::LOG_TRACE);
	reticulum = {RNS::Type::NONE};

	RNS::Utilities::OS::remove_file(destination_table_path);
}


void setUp(void) {
	// set stuff up here before each test
}

void tearDown(void) {
	// clean stuff up here after each test
}

int runUnityTests(void) {
	UNITY_BEGIN();
	RUN_TEST(testReticulum);
	return UNITY_END();
}

// For native dev-platform or for some embedded frameworks
int main(void) {
	return runUnityTests();
}

#ifdef ARDUINO
// For Arduino framework
void setup() {
	// Wait ~2 seconds before the Unity test runner
	// establishes connection with a board Serial interface
	delay(2000);
	
	runUnityTests();
}
void loop() {}
#endif

// For ESP-IDF framework
void app_main() {
	runUnityTests();
}