From 524db5e9794881d1c105025119e6fafe50335695 Mon Sep 17 00:00:00 2001
From: jimmy <git@jimmy.nz>
Date: Thu, 19 Jun 2025 19:05:08 +1200
Subject: [PATCH] Move espnow to seperate file

---
 src/main.py | 14 ++------------
 src/p2p.py  | 17 +++++++++++++++++
 2 files changed, 19 insertions(+), 12 deletions(-)
 create mode 100644 src/p2p.py

diff --git a/src/main.py b/src/main.py
index a4c0edb..f0a3db4 100644
--- a/src/main.py
+++ b/src/main.py
@@ -9,6 +9,7 @@ import machine
 import time
 import wifi
 import json
+from p2p import p2p
 
 async def main():
     settings = Settings()
@@ -26,17 +27,6 @@ async def main():
             patterns.tick()
             await asyncio.sleep_ms(1)
 
-
-    async def espnow():
-        e = aioespnow.AIOESPNow()  # Returns AIOESPNow enhanced with async support
-        e.active(True)
-        async for mac, msg in e:
-            data = json.loads(msg)
-            #print(data)
-            if "ids" not in data or settings["id"] in data["ids"]:
-                settings.set_settings(data["settings"], patterns, data.get("save", False))
-        print("should not print")
-
     async def wifi_connect():
         for i in range(10):
             config = wifi.connect(settings.get("wifi_ssid", ""),
@@ -60,7 +50,7 @@ async def main():
 
     #asyncio.create_task(wifi_connect())
     asyncio.create_task(tick())
-    asyncio.create_task(espnow())
+    asyncio.create_task(p2p(settings, patterns))
 
     while True:
 
diff --git a/src/p2p.py b/src/p2p.py
new file mode 100644
index 0000000..26fd2aa
--- /dev/null
+++ b/src/p2p.py
@@ -0,0 +1,17 @@
+import asyncio
+import aioespnow
+import json
+
+async def p2p(settings, patterns):
+    e = aioespnow.AIOESPNow()  # Returns AIOESPNow enhanced with async support
+    e.active(True)
+    async for mac, msg in e:
+        try:
+            data = json.loads(msg)
+        except:
+            print(f"Failed to load espnow data {msg}")
+            continue
+        #print(data)
+        if "ids" not in data or settings.get("id") in data.get("ids", []):
+            settings.set_settings(data.get("settings", {}), patterns, data.get("save", False))
+    print("should not print")