Update entrypointclient.lua

Added a function to generate default routes for clients in the distance map.

entrypointclient.lua

@@ -1,5 +1,7 @@
+llocal max_distance = {}
+
 local pullEvent = os.pullEventRaw
-local modem = peripheral.find("modem")
+local modem = peripheral.find("modem",function (s) return peripheral.wrap(s).isWireless() end)
 term.clear()
 term.setCursorPos(1,1)
 _G.network = {}
@@ -9,11 +11,12 @@ if not modem then
 end
 local message_queue = {}
 modem.open(15125)
-local canidate = {id = -1, distance = 170}
+local canidate = {id = -1, distance = 764}
 parallel.waitForAny(function () repeat sleep(0.1) until canidate.id ~= -1 end,
 function ()
     while true do
         local _, _, channel, _, msg, distance = pullEvent("modem_message")
+        max_distance[msg.sender] = math.max(distance,max_distance[msg.sender] or 0)
         if channel == 15125 then
             if msg.protocol == "entrypoint_advertise" then
                 if distance < canidate.distance then
@@ -34,9 +37,9 @@ local function receive()
             if msg.protocol == "heartbeat" and msg.target == os.getComputerID() and msg.sender == canidate.id then
                 last_heartbeat = os.epoch("utc")
                 modem.transmit(15125,15125,{protocol="heartbeat_response",sender=os.getComputerID(),target=canidate.id})
-                if distance > 170 then
+                if distance > (max_distance[msg.sender]or 764) then
                     modem.transmit(15125,15125,{protocol="entrypoint_disconnect",sender=os.getComputerID(),target=canidate.id})
-                    canidate = {id = -1, distance = 170}
+                    canidate = {id = -1, distance = (max_distance[msg.sender]or 764)}
                     parallel.waitForAny(function () repeat sleep(0.1) until canidate.id ~= -1 end,
                     function ()
                         while true do
@@ -76,7 +79,7 @@ end
 local function connect()
     while true do
         if os.epoch("utc") - last_heartbeat > 200 then
-            canidate = {id = -1, distance = 170}
+            canidate = {id = -1, distance = 764}
             parallel.waitForAny(function () repeat sleep(0.1) until canidate.id ~= -1 end,
             function ()
                 while true do

meshrouter.lua

@@ -1,6 +1,6 @@
 local interactions = {}
 local radio = peripheral.find("radio_tower")
-local modem = peripheral.find("modem")
+local modem = peripheral.find("modem",function (s) return peripheral.wrap(s).isWireless() end)
 local distancemap = {}
 local message_queue = {}
 
@@ -41,7 +41,7 @@ if radio and modem then
             local data = {os.pullEvent()}
             if data[1] == "radio_message" then
                data[3] = textutils.unserialise(data[3])
-                if data[3]._target == os.getComputerID() or data[3]._target == nil then return data[2], data[3], data[4] end 
+                if data[3]._target == os.getComputerID() or data[3]._target == nil and data[4] < 2611  then return data[2], data[3], data[4] end 
             elseif data[1] == "modem_message" then
                 if data[5]._target == os.getComputerID() or data[5]._target == nil then return data[2], data[5], data[6] end
             end
@@ -61,7 +61,7 @@ elseif radio then
         while true do
             local data = {os.pullEvent("radio_message")}
             data[3] = textutils.unserialise(data[3])
-            if data[3]._target == os.getComputerID() or data[3]._target == nil then return data[2], data[3], data[4] end
+            if data[3]._target == os.getComputerID() or data[3]._target == nil and data[4] < 2611 then return data[2], data[3], data[4] end
         end
     end
     function interactions.send(message,target)

meshrouterentrypoint.lua

@@ -1,6 +1,6 @@
 local interactions = {}
 local radio = peripheral.find("radio_tower")
-local modem = peripheral.find("modem")
+local modem = peripheral.find("modem",function (s) return peripheral.wrap(s).isWireless() end)
 local distancemap = {}
 local clients = {}
 local message_queue = {}
@@ -82,7 +82,7 @@ if radio and modem then
             local data = {os.pullEvent()}
             if data[1] == "radio_message" then
                data[3] = textutils.unserialise(data[3])
-                if data[3]._target == os.getComputerID() or data[3]._target == nil then return data[2], data[3], data[4] end 
+                if data[3]._target == os.getComputerID() or data[3]._target == nil and data[4] < 2611  then return data[2], data[3], data[4] end 
             elseif data[1] == "modem_message" then
                 if data[5]._target == os.getComputerID() or data[5]._target == nil and data[3] == 15124 then return data[2], data[5], data[6] end
                 if data[3] == 15125 then
@@ -126,7 +126,14 @@ queue_message({protocol="getroutes"})
 interactions.send({protocol="route_erase",destination=os.getComputerID()})
 queue_message({protocol="route",destination=os.getComputerID(),distance=0})
 local heartbeat = false
-
+local function generate_default_routes()
+    local map = {}
+    map[os.computerID()] = {dist = 0, sender = os.computerID()}
+    for client,_ in pairs(clients) do
+        map[client] = {dist = 1, sender = client}
+    end
+    return map
+end
 local function recieve()
 while true do
     local _, msg = interactions.receive()
@@ -188,8 +195,7 @@ while true do
             if (not msg.visited) then msg.visited = {} end
             msg.visited[#msg.visited+1] = os.getComputerID()
             print("rerouting")
-            distancemap = {}
-            distancemap[os.computerID()] = {dist = 0, sender = os.computerID()}
+            distancemap = generate_default_routes()
             queue_message({protocol="getroutes"})
             queue_message(msg)
         end
@@ -219,6 +225,7 @@ local function heartbeat_f()
                     end
                 end)
                 if not heartbeat then
+                    print(k, "timed out")
                     distancemap[k] = nil
                     queue_message({protocol="reroute"})
                 end