From 5ada0920f06cf842bf16bdfd9ffd6b4a36320576 Mon Sep 17 00:00:00 2001
From: eichhornchen <eichhornchen@aspiredeb>
Date: Thu, 7 Jan 2021 15:23:28 +0100
Subject: [PATCH] for tests

---
 for_testing_multicast/peer.py   | 31 +++++++++++++++++++++++++++++++
 for_testing_multicast/sender.py | 15 +++++++++++++++
 2 files changed, 46 insertions(+)
 create mode 100644 for_testing_multicast/peer.py
 create mode 100644 for_testing_multicast/sender.py

diff --git a/for_testing_multicast/peer.py b/for_testing_multicast/peer.py
new file mode 100644
index 0000000..8a992ac
--- /dev/null
+++ b/for_testing_multicast/peer.py
@@ -0,0 +1,31 @@
+from typing import Any, Tuple, Generator
+from ipaddress import IPv6Address
+import re
+import socket
+import time
+import struct
+
+# Initialise socket for IPv6 datagrams
+sock = socket.socket(socket.AF_INET6, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
+
+# Allows address to be reused
+sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
+
+# Binds to all interfaces on the given port
+sock.bind(('', 1212))
+
+# Allow messages from this socket to loop back for development
+#sock.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_MULTICAST_LOOP, True)
+
+# Construct message for joining multicast group
+#mreq = struct.pack("16s15s".encode('utf-8'), socket.inet_pton(socket.AF_INET6, "ff02::4242:4242"), (chr(0) * 16).encode('utf-8'))
+
+mreq = struct.pack("16s15s", socket.inet_pton(socket.AF_INET6, "ff02::4242:4242"), bytes(socket.INADDR_ANY))
+sock.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_JOIN_GROUP, mreq)
+
+data, addr = sock.recvfrom(1024)
+print(data)
+print(addr[0], addr[1])
+
+time.sleep(3)
+sock.sendto("hello world".encode('utf-8'), ("addr[0]", int(addr[1])))
diff --git a/for_testing_multicast/sender.py b/for_testing_multicast/sender.py
new file mode 100644
index 0000000..54f2ba2
--- /dev/null
+++ b/for_testing_multicast/sender.py
@@ -0,0 +1,15 @@
+from typing import Any, Tuple, Generator
+from ipaddress import IPv6Address
+import re
+import socket
+import time
+import struct
+
+# Initialise socket for IPv6 datagrams
+sock = socket.socket(socket.AF_INET6, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
+
+sock.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL, 2)
+
+sock.sendto("hello world".encode('utf-8'), ("ff02::4242:4242", 1212))
+
+