Update lua-minify.lua

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

entrypointclient.lua

@@ -1,5 +1,5 @@
 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,14 +9,15 @@ if not modem then
 end
 local message_queue = {}
 modem.open(15125)
-local canidate = {id = -1, distance = 170}
+local canidate = {id = -1, distance = 764, max_distance=0}
 parallel.waitForAny(function () repeat sleep(0.1) until canidate.id ~= -1 end,
 function ()
     while true do
         local _, _, channel, _, msg, distance = pullEvent("modem_message")
         if channel == 15125 then
             if msg.protocol == "entrypoint_advertise" then
-                if distance < canidate.distance then
+                if distance < canidate.distance and distance < (msg.max_distance or 128) then
+                    canidate.max_distance = (msg.max_distance or 128)
                     canidate.id = msg.sender
                     canidate.distance = distance
                 end
@@ -34,9 +35,11 @@ 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
+                canidate.distance = distance
+                canidate.max_distance = msg.max_distance
+                if distance > (msg.max_distance 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 = 764, max_distance=0}
                     parallel.waitForAny(function () repeat sleep(0.1) until canidate.id ~= -1 end,
                     function ()
                         while true do
@@ -44,6 +47,7 @@ local function receive()
                             if channel == 15125 then
                                 if msg.protocol == "entrypoint_advertise" then
                                     if distance < canidate.distance then
+                                        canidate.max_distance = msg.max_distance
                                         canidate.id = msg.sender
                                         canidate.distance = distance
                                     end
@@ -75,15 +79,18 @@ end
 
 local function connect()
     while true do
-        if os.epoch("utc") - last_heartbeat > 200 then
+        if os.epoch("utc") - last_heartbeat > math.max((300*canidate.distance)/100,300) then
-            canidate = {id = -1, distance = 170}
+            canidate = {id = -1, distance = 764, max_distance=0}
             parallel.waitForAny(function () repeat sleep(0.1) until canidate.id ~= -1 end,
             function ()
                 while true do
                     local _, _, channel, _, msg, distance = pullEvent("modem_message")
                     if channel == 15125 then
                         if msg.protocol == "entrypoint_advertise" then
-                            if distance < canidate.distance then
+                            if distance > (msg.max_distance or 128) then
+                                modem.transmit(15125,15125,{protocol="out_of_range",sender=os.getComputerID(),target=msg.sender})
+                            elseif distance < canidate.distance then
+                                canidate.max_distance = msg.max_distance
                                 canidate.id = msg.sender
                                 canidate.distance = distance
                             end
@@ -94,8 +101,12 @@ local function connect()
             if canidate.id == -1 then
                 sleep(5)
             else
-                modem.transmit(15125,15125,{protocol="entrypoint_connect",sender=os.getComputerID(),target=canidate.id})
+                if canidate.distance > (canidate.max_distance or 128) then
-                last_heartbeat = os.epoch("utc")
+                    modem.transmit(15125,15125,{protocol="out_of_range",sender=os.getComputerID(),target=canidate.id})
+                else
+                    modem.transmit(15125,15125,{protocol="entrypoint_connect",sender=os.getComputerID(),target=canidate.id})
+                    last_heartbeat = os.epoch("utc")
+                end
             end
         else
                 local msg = table.remove(message_queue,1)
@@ -106,5 +117,8 @@ local function connect()
         sleep()
     end
 end
+function _G.network.getCandidate()
+    return canidate
+end
 parallel.waitForAny(receive, connect,function () shell.run("shell") end)
 os.shutdown()

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,8 @@
 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 max_distance = 128
 local distancemap = {}
 local clients = {}
 local message_queue = {}
@@ -48,6 +50,8 @@ local function entrypoint_recieving(channel, msg)
                         print("No route to",msg.destination)
                     end
                 end
+            elseif msg.protocol == "out_of_range" then
+                print("readjusting range")
             end
         end
 end
@@ -84,6 +88,8 @@ if radio and modem 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 
             elseif data[1] == "modem_message" then
+                print(data[6])
+                max_distance = math.max(data[6] or 0,max_distance)
                 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
                     entrypoint_recieving(data[3], data[5])
@@ -107,6 +113,7 @@ elseif modem then
         local data = {[5]={_target=-1}}
         while true do
             data = {os.pullEvent("modem_message")}
+            max_distance = math.max(data[6] or 0,max_distance)
             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
                 entrypoint_recieving(data[3], data[5])
@@ -126,7 +133,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 +202,7 @@ while true do
             if (not msg.visited) then msg.visited = {} end
             msg.visited[#msg.visited+1] = os.getComputerID()
             print("rerouting")
-            distancemap = {}
+            distancemap = generate_default_routes()
-            distancemap[os.computerID()] = {dist = 0, sender = os.computerID()}
             queue_message({protocol="getroutes"})
             queue_message(msg)
         end
@@ -219,6 +232,7 @@ local function heartbeat_f()
                     end
                 end)
                 if not heartbeat then
+                    print(k, "timed out")
                     distancemap[k] = nil
                     queue_message({protocol="reroute"})
                 end
@@ -229,7 +243,7 @@ local function heartbeat_f()
 end
 local function entrypoint_advertising()
     while true do
-        modem.transmit(15125,15125,{protocol="entrypoint_advertise",sender=os.getComputerID()})
+        modem.transmit(15125,15125,{protocol="entrypoint_advertise",sender=os.getComputerID(),max_distance=max_distance-10})
         sleep(0.1)
     end
 end
@@ -242,7 +256,7 @@ local function healthcheck()
                 sleep(0.1)
             end, function()
                 while not heartbeat_entrypoint do
-                    modem.transmit(15125,15125,{protocol="heartbeat",sender=os.getComputerID(),target=client})
+                    modem.transmit(15125,15125,{protocol="heartbeat",sender=os.getComputerID(),target=client,max_distance=max_distance-10})
                     sleep()
                 end
             end)