From bd6ed970e18aef1da952c64c77cef6f3e28accbe Mon Sep 17 00:00:00 2001
From: William <William@willy.club>
Date: Wed, 15 Mar 2023 14:26:12 +0100
Subject: [PATCH] Bruh

---
 .gitignore       |  1 +
 index.html       | 10 -------
 rnssim.py        |  0
 util/rnssim.py   | 73 ++++++++++++++++++++++++++++++++++++++++++++++++
 util/watchdog.py | 21 ++++++++++++++
 5 files changed, 95 insertions(+), 10 deletions(-)
 create mode 100644 .gitignore
 delete mode 100644 rnssim.py
 create mode 100644 util/rnssim.py
 create mode 100644 util/watchdog.py

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..a12f0ae
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1 @@
+/nodes
\ No newline at end of file
diff --git a/index.html b/index.html
index b5f0913..89916c8 100644
--- a/index.html
+++ b/index.html
@@ -13,16 +13,6 @@
     font-family: sans-serif;
 ">
 
-<div id="loading" style="
-    background: #000000a0;
-    position: absolute;
-    height: 100%;
-    width: 100%;
-    text-align: center;
-    padding-top: 50vh;
-    color: #fff;
-">Loading</div>
-
 <div style="
     background: #eef;
     padding: .5rem;
diff --git a/rnssim.py b/rnssim.py
deleted file mode 100644
index e69de29..0000000
diff --git a/util/rnssim.py b/util/rnssim.py
new file mode 100644
index 0000000..b17e81b
--- /dev/null
+++ b/util/rnssim.py
@@ -0,0 +1,73 @@
+import subprocess
+import os
+import threading
+import time
+
+node_state = {}
+
+def main():
+    if not os.path.exists("nodes"):
+        os.mkdir("nodes")
+
+    os.chdir("nodes")
+    watchdog_thread = threading.Thread(target=watchdog)
+    watchdog_thread.start()
+
+    node_add(1)
+    node_add(2)
+    node_add(3)
+    node_add(4)
+    node_add(5)
+
+def watchdog():
+    while True:
+        for node_id in os.listdir():
+            if not node_id in node_state:
+                node_state[node_id] = {
+                    'active': False,
+                    'stdout': None
+                }
+
+            if not node_state[node_id]["active"]:
+                rnsd_thread = threading.Thread(target=rnsd, args=(node_id,))
+                rnsd_thread.start()
+
+        print(node_state)
+        time.sleep(1)
+
+def rnsd(node_id):
+    node_state[node_id]["active"] = True
+    subprocess.run(f"cd {node_id} && rnsd --config ./", shell=True, stdout=node_state[node_id]['stdout'])
+    node_state[node_id]["active"] = False 
+
+def node_add(node_id: int):
+    config = f"""
+    [reticulum]
+
+    enable_transport = False
+
+    share_instance = Yes
+    shared_instance_port = {37428 + node_id}
+    instance_control_port = {38429 + node_id}
+
+    [interfaces]
+
+    [[Autogenerated TCP Server Interface]]
+    type = TCPServerInterface
+    interface_enabled = True
+    listen_ip = localhost
+    listen_port = {42069 + node_id}
+    """
+    node_id = str(node_id)
+
+    if not os.path.exists(node_id):
+        os.mkdir(node_id)
+
+    with open(node_id + "/config", "w+") as file:
+        file.write(config)
+
+def node_connect(node1, node2):
+    pass
+
+if __name__ == "__main__":
+    main()
\ No newline at end of file
diff --git a/util/watchdog.py b/util/watchdog.py
new file mode 100644
index 0000000..5ad45ef
--- /dev/null
+++ b/util/watchdog.py
@@ -0,0 +1,21 @@
+import os, subprocess, threading
+
+test = ''
+
+def main():
+    if not os.path.exists("nodes"):
+        os.mkdir("nodes")
+
+    os.chdir("nodes")
+
+    for node_id in os.listdir():
+        t = threading.Thread(target=daemon, args=(node_id))
+        t.start()
+
+
+def daemon(node_id):
+    with open(f"{node_id}.log") as f:
+        subprocess.run(f"cd {node_id} && rnsd --config ./", shell=True, capture_output=True)
+
+if __name__ == "__main__":
+    main()
\ No newline at end of file