mirror of
https://github.com/MikaylaFischler/cc-mek-scada.git
synced 2024-08-30 18:22:34 +00:00
102 lines
3.3 KiB
Lua
102 lines
3.3 KiB
Lua
--
|
|
-- Data Bus - Central Communication Linking for PLC Front Panel
|
|
--
|
|
|
|
local log = require("scada-common.log")
|
|
local psil = require("scada-common.psil")
|
|
local util = require("scada-common.util")
|
|
|
|
local databus = {}
|
|
|
|
local dbus_iface = {
|
|
ps = psil.create(),
|
|
rps_scram = function () log.debug("DBUS: unset rps_scram() called") end,
|
|
rps_reset = function () log.debug("DBUS: unset rps_reset() called") end
|
|
}
|
|
|
|
-- call to toggle heartbeat signal
|
|
function databus.heartbeat() dbus_iface.ps.toggle("heartbeat") end
|
|
|
|
-- link RPS command functions
|
|
---@param scram function reactor SCRAM function
|
|
---@param reset function RPS reset function
|
|
function databus.link_rps(scram, reset)
|
|
dbus_iface.rps_scram = scram
|
|
dbus_iface.rps_reset = reset
|
|
end
|
|
|
|
-- transmit a command to the RPS to SCRAM
|
|
function databus.rps_scram() dbus_iface.rps_scram() end
|
|
|
|
-- transmit a command to the RPS to reset
|
|
function databus.rps_reset() dbus_iface.rps_reset() end
|
|
|
|
-- transmit firmware versions across the bus
|
|
---@param plc_v string PLC version
|
|
---@param comms_v string comms version
|
|
function databus.tx_versions(plc_v, comms_v)
|
|
dbus_iface.ps.publish("version", plc_v)
|
|
dbus_iface.ps.publish("comms_version", comms_v)
|
|
end
|
|
|
|
-- transmit unit ID across the bus
|
|
---@param id integer unit ID
|
|
function databus.tx_id(id)
|
|
dbus_iface.ps.publish("unit_id", id)
|
|
end
|
|
|
|
-- transmit hardware status across the bus
|
|
---@param plc_state plc_state
|
|
function databus.tx_hw_status(plc_state)
|
|
dbus_iface.ps.publish("reactor_dev_state", util.trinary(plc_state.no_reactor, 1, util.trinary(plc_state.reactor_formed, 3, 2)))
|
|
dbus_iface.ps.publish("has_modem", not plc_state.no_modem)
|
|
dbus_iface.ps.publish("degraded", plc_state.degraded)
|
|
dbus_iface.ps.publish("init_ok", plc_state.init_ok)
|
|
end
|
|
|
|
-- transmit thread (routine) statuses
|
|
---@param thread string thread name
|
|
---@param ok boolean thread state
|
|
function databus.tx_rt_status(thread, ok)
|
|
dbus_iface.ps.publish(util.c("routine__", thread), ok)
|
|
end
|
|
|
|
-- transmit supervisor link state across the bus
|
|
---@param state integer
|
|
function databus.tx_link_state(state)
|
|
dbus_iface.ps.publish("link_state", state)
|
|
end
|
|
|
|
-- transmit reactor enable state across the bus
|
|
---@param active boolean reactor active
|
|
function databus.tx_reactor_state(active)
|
|
dbus_iface.ps.publish("reactor_active", active)
|
|
end
|
|
|
|
-- transmit RPS data across the bus
|
|
---@param tripped boolean RPS tripped
|
|
---@param status table RPS status
|
|
function databus.tx_rps(tripped, status)
|
|
dbus_iface.ps.publish("rps_scram", tripped)
|
|
dbus_iface.ps.publish("rps_damage", status[1])
|
|
dbus_iface.ps.publish("rps_high_temp", status[2])
|
|
dbus_iface.ps.publish("rps_low_ccool", status[3])
|
|
dbus_iface.ps.publish("rps_high_waste", status[4])
|
|
dbus_iface.ps.publish("rps_high_hcool", status[5])
|
|
dbus_iface.ps.publish("rps_no_fuel", status[6])
|
|
dbus_iface.ps.publish("rps_fault", status[7])
|
|
dbus_iface.ps.publish("rps_timeout", status[8])
|
|
dbus_iface.ps.publish("rps_manual", status[9])
|
|
dbus_iface.ps.publish("rps_automatic", status[10])
|
|
dbus_iface.ps.publish("rps_sysfail", status[11])
|
|
end
|
|
|
|
-- link a function to receive data from the bus
|
|
---@param field string field name
|
|
---@param func function function to link
|
|
function databus.rx_field(field, func)
|
|
dbus_iface.ps.subscribe(field, func)
|
|
end
|
|
|
|
return databus
|