lib/lora_mesh: added Border Router example

Author: Catalin Ioana

lib/lora_mesh/loramesh.py

@@ -39,6 +39,7 @@ def __init__(self, lora=None):
         self.ip_link = ''
         self.single = True
         self.state = STATE_DISABLED
+        self.ip_others = []
 
     def _state_update(self):
         """ Returns the Thread role """
@@ -54,6 +55,7 @@ def _rloc_ip_net_addr(self):
 
     def _update_ips(self):
         """ Updates all the unicast IPv6 of the Thread interface """
+        self.ip_others = []
         ips = self.mesh.ipaddr()
         self.rloc16 = self.mesh.rloc()
         for line in ips:
@@ -73,6 +75,8 @@ def _update_ips(self):
             elif line.startswith('fe80'):
                 # Link-Local
                 self.ip_link = line
+            else:
+                self.ip_others.append(line)
 
     def is_connected(self):
         """ Returns true if it is connected as either Child, Router or Leader """
@@ -89,10 +93,18 @@ def led_state(self):
         else:
             pycom.rgbled(self.RGBLED[self.state])
 
-    def ip(self):
+    # returns the IP ML-EID or the ip having this prefix
+    def ip(self, prefix = None):
         """ Returns the IPv6 RLOC """
-        self._update_ips()
-        return self.rloc
+        ip = self._update_ips()
+        if prefix is None:
+            return self.ip_eid
+        # we need to check al IPs from self.ip_others that may start with prefix
+        p = prefix.split("::")[0]
+        for ip in self.ip_others:
+            if ip.startswith(p):
+                return ip
+        return None
 
     def neighbors(self):
         """ Returns a list with all properties of the neighbors """

lib/lora_mesh/main_border_router.py

@@ -0,0 +1,90 @@
+from network import LoRa
+import ubinascii
+from loramesh import Loramesh
+import pycom
+import time
+import socket
+import struct
+
+BORDER_ROUTER_HEADER_FORMAT = '!BHHHHHHHHH'
+
+pycom.wifi_on_boot(False)
+pycom.heartbeat(False)
+border_router_net = "2001:dead:beef:caff::/64"
+
+lora = LoRa(mode=LoRa.LORA, region=LoRa.EU868, bandwidth=LoRa.BW_125KHZ, sf=7)
+#mesh = lora.Mesh()
+MAC = str(ubinascii.hexlify(lora.mac()))[2:-1]
+print("LoRa MAC: %s"%MAC)
+
+mesh = Loramesh(lora)
+
+# waiting until it connected to Mesh network
+while True:
+    mesh.led_state()
+    print("%d: State %s, single %s"%(time.time(), mesh.cli('state'), mesh.cli('singleton')))
+    time.sleep(2)
+    if not mesh.is_connected():
+        continue
+
+    print('Neighbors found: %s'%mesh.neighbors())
+    print('IPs: %s'%mesh.mesh.ipaddr())
+    print('BRs: %s'%mesh.mesh.border_router())
+    break
+
+#add BR
+if int(MAC, 16) == 8:
+    if len(mesh.mesh.border_router()) == 0:
+        mesh.mesh.border_router(border_router_net, 1)
+        print("Set Border Router with prefix %s"%border_router_net)
+
+# create UDP socket for Border Router interface
+br_socket = socket.socket(socket.AF_LORA, socket.SOCK_RAW)
+myport = 1234
+print("Please wait until BR gets propagated to the Leader ...")
+while True:
+    ip = mesh.ip(border_router_net)
+    #ip = mesh.ip()
+    if ip is not None:
+        br_socket.bind((ip, myport))
+        #s.bind(myport)
+        print("Created socked for (%s, %d)"%(ip, myport))
+        break
+    time.sleep(1)
+
+eid_sock = socket.socket(socket.AF_LORA, socket.SOCK_RAW)
+myport = 1235
+ip = mesh.ip()# ipv6 EID
+if ip is not None:
+    eid_sock.bind((ip, myport))
+    #s.bind(myport)
+    print("Created socked for (%s, %d)"%(ip, myport))
+
+# handler responisble for receiving packets on UDP Pymesh socket
+def receive_pack(dummy):
+    # listen for incomming packets
+    sock = eid_sock
+    while True:
+        rcv_data, rcv_addr = sock.recvfrom(128)
+        if len(rcv_data) == 0:
+            rcv_data, rcv_addr = br_socket.recvfrom(128)
+            if len(rcv_data) == 0:
+                break
+            print("Data from Border Router socket")
+            sock = br_socket
+        rcv_ip = rcv_addr[0]
+        rcv_port = rcv_addr[1]
+        print('Incomming %d bytes from %s (port %d)'%(len(rcv_data), rcv_ip, rcv_port))
+        if sock == br_socket and len(rcv_data) >= struct.calcsize(BORDER_ROUTER_HEADER_FORMAT):
+            br_header = struct.unpack(BORDER_ROUTER_HEADER_FORMAT, rcv_data)
+            print("IP dest: %X:%X:%X:%X:%X:%X:%X:%X (port %d)"%(
+                br_header[1],br_header[2],br_header[3],br_header[4],
+                br_header[5],br_header[6],br_header[7],br_header[8], br_header[9]))
+            print(rcv_data[struct.calcsize(BORDER_ROUTER_HEADER_FORMAT):])
+        else:
+            print(rcv_data)
+        if  not rcv_data.startswith("ACK"):
+            print("Sent ACK back")
+            sock.sendto('ACK', (rcv_ip, rcv_port))
+
+mesh.mesh.rx_cb(receive_pack, None)