derEmulatorV1.1.0

--derEmulator (Draconic Evolution Reactor Emulator) V1.1.0
--Official Stamper (c) Aug 2018

--Changelog V1.1.0 added OC Code


-- Listen for modem request from control

local modemSide = 'top'    -- Only required for CC
local modemTx = 299
local modemRx = 299

-- Emulation values
local fuelInject = 10368
local fuelConversion = 0 --0.5427

--Peripherals and components (do not initialise to values)
--local monitor
local modem
--local emulatedReactor
local serialization

--check os version
local OSVer = ""
local OC = false
local CC = false

if _OSVERSION then
    OSVer = _OSVERSION
    OC = true
elseif os.version() then
    OSVer = os.version()
    CC = true
end

if CC then
    --Open the modem on the channel specified
    modem = peripheral.wrap(modemSide)
    os.loadAPI("emulatedReactor")
    --local reactor = peripheral.wrap(reactorSide)

elseif OC then
    local component = require("component")
    local computer = require("computer")
    local event = require("event")
    local term = require("term")
    serialization = require("serialization")
    modem = component.modem
    local gpu = component.gpu
    emulatedReactor = require("mooviesReactor")
    os.pullEvent = event.pull
    modem.transmit = modem.broadcast
else
    -- no valid OS
end

--Initialise emulatedReactor
emulatedReactor.fluxGates.input.setFlowOverride(0)
emulatedReactor.fluxGates.output.setFlowOverride(0)
emulatedReactor.fluxGates.input.setOverrideEnabled(true)
emulatedReactor.fluxGates.output.setOverrideEnabled(true)
emulatedReactor.setFuel(fuelInject, fuelConversion)

modem.open(modemRx)
print("Listening.....")

local request = {
    getReactorInfo  = function(id)
                            local info = emulatedReactor.getReactorInfo()
                            if OC then info = serialization.serialize(info) end
                            modem.transmit(modemTx, id, info)
                        end,
    chargeReactor   = function() emulatedReactor.chargeReactor() end,
    activateReactor = function() emulatedReactor.activateReactor() end,
    stopReactor     = function() emulatedReactor.stopReactor() end,
    setFailSafe     = function() emulatedReactor.setFailSafe() end,
    reset           = function() emulatedReactor.reset() end
}

function main()
    while true do

        local event, modemSide, senderChannel, id, message, senderDistance, more = os.pullEvent("modem_message")

        if OC then
            senderChannel = id
            id = senderDistance
            message = serialization.unserialize(more)
        end

        if (senderChannel == modemRx) then  -- is this message for me?
            emulatedReactor.fluxGates.input.setFlowOverride(message.inRF)
            emulatedReactor.fluxGates.output.setFlowOverride(message.outRF)
            emulatedReactor.update()
            request[message.req](id)
        else
            --Message not for me
        end

    end
end

main()
--local errNo, errMsg = pcall(main)

-- print(tostring(errNo).." : "..errMsg)

-- if errMsg == "Terminated" then
    -- return
-- else
    -- local f = fs.open("log","a")
    -- f.writeLine(textutils.formatTime(os.time("utc"),true).."(UTC) #"..os.getComputerID()..": "..errMsg)
    -- f.close()
    -- os.reboot()
-- end