From 63c4a4b2c7cd03b0ba7280000ab38fccdbddaadc Mon Sep 17 00:00:00 2001
From: Radkesvat <134321679+radkesvat@users.noreply.github.com>
Date: Wed, 7 Aug 2024 23:00:13 +0000
Subject: [PATCH] implement layer 3 sender

---
 tunnels/layer3/sender/CMakeLists.txt |  15 ++++
 tunnels/layer3/sender/sender.c       | 112 +++++++++++++++++++++++++++
 tunnels/layer3/sender/sender.h       |   9 +++
 3 files changed, 136 insertions(+)
 create mode 100644 tunnels/layer3/sender/CMakeLists.txt
 create mode 100644 tunnels/layer3/sender/sender.c
 create mode 100644 tunnels/layer3/sender/sender.h

diff --git a/tunnels/layer3/sender/CMakeLists.txt b/tunnels/layer3/sender/CMakeLists.txt
new file mode 100644
index 0000000..65096ed
--- /dev/null
+++ b/tunnels/layer3/sender/CMakeLists.txt
@@ -0,0 +1,15 @@
+
+
+add_library(Layer3Sender STATIC
+                    sender.c
+  
+)
+
+target_link_libraries(Layer3Sender ww)
+# add dependencies
+include(${CMAKE_BINARY_DIR}/cmake/CPM.cmake)
+
+target_include_directories(Layer3Sender PUBLIC ${CMAKE_CURRENT_SOURCE_DIR}/../../shared/layer3)
+
+
+target_compile_definitions(Layer3Sender PRIVATE  Layer3Sender_VERSION=0.1)
diff --git a/tunnels/layer3/sender/sender.c b/tunnels/layer3/sender/sender.c
new file mode 100644
index 0000000..a74159b
--- /dev/null
+++ b/tunnels/layer3/sender/sender.c
@@ -0,0 +1,112 @@
+#include "sender.h"
+#include "hsocket.h"
+#include "loggers/network_logger.h"
+#include "managers/node_manager.h"
+#include "utils/jsonutils.h"
+#include "utils/stringutils.h"
+
+typedef struct layer3_senderstate_s
+{
+    char     *tundevice_name;
+    tunnel_t *tun_device_tunnel;
+
+} layer3_senderstate_t;
+
+typedef struct layer3_sendercon_state_s
+{
+    void *_;
+} layer3_sendercon_state_t;
+
+static void upStream(tunnel_t *self, context_t *c)
+{
+    layer3_senderstate_t *state = TSTATE(self);
+
+    state->tun_device_tunnel->upStream(state->tun_device_tunnel, c);
+}
+
+static void downStream(tunnel_t *self, context_t *c)
+{
+    (void) (self);
+    (void) (c);
+    assert(false);
+
+    if (c->payload)
+    {
+        dropContexPayload(c);
+    }
+    destroyContext(c);
+}
+
+tunnel_t *newLayer3Sender(node_instance_context_t *instance_info)
+{
+    layer3_senderstate_t *state = globalMalloc(sizeof(layer3_senderstate_t));
+    memset(state, 0, sizeof(layer3_senderstate_t));
+    cJSON *settings = instance_info->node_settings_json;
+
+    if (! (cJSON_IsObject(settings) && settings->child != NULL))
+    {
+        LOGF("JSON Error: Layer3Sender->settings (object field) : The object was empty or invalid");
+        globalFree(state);
+        return NULL;
+    }
+
+    if (! getStringFromJsonObject(&(state->tundevice_name), settings, "device"))
+    {
+        LOGF("JSON Error: Layer3Sender->settings->device (string field) : The string was empty or invalid");
+        globalFree(state);
+        return NULL;
+    }
+
+    hash_t  hash_tdev_name = CALC_HASH_BYTES(state->tundevice_name, strlen(state->tundevice_name));
+    node_t *tundevice_node = getNode(instance_info->node_manager_config, hash_tdev_name);
+    if (tundevice_node == NULL)
+    {
+        LOGF("Layer3Sender: could not find tun device node \"%s\"", state->tundevice_name);
+        globalFree(state);
+        return NULL;
+    }
+
+    if (tundevice_node->instance != NULL)
+    {
+        LOGF("Layer3Sender: tun device \"%s\" cannot be used by 2 receivers", state->tundevice_name);
+        globalFree(state);
+        return NULL;
+    }
+    runNode(instance_info->node_manager_config, tundevice_node, 0);
+
+    if (tundevice_node->instance == NULL)
+    {
+        globalFree(state);
+        return NULL;
+    }
+
+    state->tun_device_tunnel = tundevice_node->instance;
+
+    tunnel_t *t = newTunnel();
+
+    t->state      = state;
+    t->upStream   = &upStream;
+    t->downStream = &downStream;
+
+    chain(tundevice_node->instance, t);
+
+    return t;
+}
+
+api_result_t apiLayer3Sender(tunnel_t *self, const char *msg)
+{
+    (void) (self);
+    (void) (msg);
+    return (api_result_t) {0};
+}
+
+tunnel_t *destroyLayer3Sender(tunnel_t *self)
+{
+    (void) (self);
+    return NULL;
+}
+
+tunnel_metadata_t getMetadataLayer3Sender(void)
+{
+    return (tunnel_metadata_t) {.version = 0001, .flags = 0x0};
+}
diff --git a/tunnels/layer3/sender/sender.h b/tunnels/layer3/sender/sender.h
new file mode 100644
index 0000000..6267f29
--- /dev/null
+++ b/tunnels/layer3/sender/sender.h
@@ -0,0 +1,9 @@
+#pragma once
+#include "api.h"
+
+// Layer3Packet  ------>  Layer3Sender ------>  TunDevice
+
+tunnel_t *        newLayer3Sender(node_instance_context_t *instance_info);
+api_result_t      apiLayer3Sender(tunnel_t *self, const char *msg);
+tunnel_t *        destroyLayer3Sender(tunnel_t *self);
+tunnel_metadata_t getMetadataLayer3Sender(void);