View difference between Paste ID: sAyTp5Q4 and p8NcuwNR

 local mqtt = require("mqtt")
 
-local reactor = peripheral.wrap("bottom")
+local boiler = peripheral.wrap("bottom")
 
-if reactor == nil or reactor.isFormed() == false then
+if boiler == nil or boiler.isFormed() == false then
-    print("Unable to find reactor. Restarting in 5")
+    print("Unable to find boiler. Restarting in 5")
     os.sleep(5)
     os.reboot()
 end
 
 local keep_alive = 60
-local baseTopic = "/ftbUniversity19/ITLandfill/fission/reactor/"
+local baseTopic = "/ftbUniversity19/ITLandfill/fission/boiler/"
 local refresh = 10
 
 local connected = false
 
 -- create mqtt client
 local client = mqtt.client {
     -- NOTE: this broker is not working sometimes; comment username = "..." below if you still want to use it
     uri = "ws://test.mosquitto.org:8080",
     clean = true,
     keep_alive = keep_alive
 }
 
 print("created MQTT client", client)
 
 client:on {
     connect = function(connack)
         if connack.rc ~= 0 then
             print("connection to broker failed:", connack:reason_string(), connack)
             return
         end
         print("connected:", connack) -- successful connection
         connected = true
         -- subscribe to test topic and publish message after it
-        assert(client:subscribe { topic = baseTopic .. "command/#", qos = 1, callback = function(suback)
+        assert(client:subscribe { topic = "/hfdghwl/#", qos = 1, callback = function(suback)
             print("subscribed:", suback)
 
         end })
     end,
 
     message = function(msg)
         assert(client:acknowledge(msg))
 
         print("received:", msg)
 
         if msg.payload == "disconnect" then
             print("disconnecting...")
             assert(client:disconnect())
         end
-
+
-        local command = string.sub(msg.topic, string.len(baseTopic .. "command/"))
+
-        print("Command topic: " .. command)
+
-        print("Command: " .. msg.payload)
+
     end,
 
     close = function()
         print("MQTT conn closed")
     end
 }
 
 function sendMessage(topic, message, retain)
     if connected then
         assert(client:publish {
             topic = baseTopic..topic,
             payload = message,
             retain = retain
         })
     else
         print("Not connected")
     end
 end
 
 function sendUpdate()
     sendMessage("sensor/boil/capacity", tostring(boiler.getBoilCapacity()), false)
     sendMessage("sensor/boil/rate", tostring(boiler.getBoilRate()), false)
     sendMessage("sensor/cooledCoolant", tostring(boiler.getCooledCoolantFilledPercentage()), false)
     sendMessage("sensor/heatedCoolant", tostring(boiler.getHeatedCoolantFilledPercentage()), false)
-    sendMessage("sensor/status", tostring(reactor.getStatus()), false)
+    sendMessage("sensor/boil/maxRate", tostring(boiler.getMaxBoilRate()), false)
-    sendMessage("sensor/temperature", tostring(reactor.getTemperature()), false)
+    sendMessage("sensor/steam", tostring(boiler.getSteamFilledPercentage()), false)
-    sendMessage("sensor/damage", tostring(reactor.getDamagePercent()), false)
+    sendMessage("sensor/water", tostring(boiler.getWaterFilledPercentage()), false)
-    sendMessage("sensor/coolant", tostring(reactor.getCoolantFilledPercentage()), false)
+    sendMessage("sensor/temperature", tostring(boiler.getTemperature()), false)
-    sendMessage("sensor/heatedCoolant", tostring(reactor.getHeatedCoolantFilledPercentage()), false)
+
-    sendMessage("sensor/fuel", tostring(reactor.getFuelFilledPercentage()), false)
+
-    sendMessage("sensor/waste", tostring(reactor.getWasteFilledPercentage()), false)
+
-
+
-    --local burnRate = "{\"max\":"..tostring(reactor.getMaxBurnRate()) ..", \"set\":" .. tostring(reactor.getBurnRate()) .. ",\"val\":" .. tostring(reactor.getActualBurnRate()) .. "}"
+
-    sendMessage("sensor/burnRate/set", tostring(reactor.getBurnRate()), false)
+
-    sendMessage("sensor/burnRate/actual", tostring(reactor.getActualBurnRate()), false)
+
-    sendMessage("sensor/burnRate/max", tostring(reactor.getMaxBurnRate()), false)
+
-    sendMessage("sensor/burnRate/percent", tostring(reactor.getActualBurnRate()/reactor.getMaxBurnRate()), false)
+
-    --sendMessage("sensor/burnRate", burnRate, false)
+
     function()
         while true do
             os.sleep(keep_alive)
             client:send_pingreq()
         end
     end,
     function()
         while true do
             os.sleep(refresh)
             if (pcall(sendUpdate) == false) then
                 print("Error updating. Restarting in 5")
                 os.sleep(5)
                 os.reboot()
             end
         end
     end
 )