MineOS/Libraries/Event.lua

local event, handlers, interruptingKeysDown, lastInterrupt = {
  interruptingEnabled = true,
  interruptingDelay = 1,
  interruptingFunction = error,
  interruptingKeyCodes = {
    [29] = true,
    [46] = true,
    [56] = true
  },
  push = computer.pushSignal
}, {}, {}, 0

local computerPullSignal, computerUptime, mathHuge, mathMin, skipSignalType = computer.pullSignal, computer.uptime, math.huge, math.min

--------------------------------------------------------------------------------------------------------

function event.addHandler(callback, interval, times)
  checkArg(1, callback, "function")
  checkArg(2, interval, "number", "nil")
  checkArg(3, times, "number", "nil")

  local handler = {
    callback = callback,
    times = times or mathHuge,
    interval = interval,
    nextTriggerTime = interval and computerUptime() + interval or 0
  }

  handlers[handler] = true

  return handler
end

function event.removeHandler(handler)
  checkArg(1, handler, "table")

  if handlers[handler] then
    handlers[handler] = nil

    return true
  else
    return false, "Handler with given table is not registered"
  end
end

function event.getHandlers()
  return handlers
end

function event.skip(signalType)
  skipSignalType = signalType
end

function event.pull(preferredTimeout)  
  local uptime, signalData = computerUptime()
  local deadline = uptime + (preferredTimeout or mathHuge)
  
  repeat
    -- Determining pullSignal timeout
    timeout = deadline
    for handler in pairs(handlers) do
      if handler.nextTriggerTime > 0 then
        timeout = mathMin(timeout, handler.nextTriggerTime)
      end
    end

    -- Pulling signal data
    signalData = { computerPullSignal(timeout - computerUptime()) }
        
    -- Handlers processing
    for handler in pairs(handlers) do
      if handler.times > 0 then
        uptime = computerUptime()

        if
          handler.nextTriggerTime <= uptime
        then
          handler.times = handler.times - 1
          if handler.nextTriggerTime > 0 then
            handler.nextTriggerTime = uptime + handler.interval
          end

          -- Callback running
          handler.callback(table.unpack(signalData))
        end
      else
        handlers[handler] = nil
      end
    end

    -- Program interruption support. It's faster to do it here instead of registering handlers
    if (signalData[1] == "key_down" or signalData[1] == "key_up") and event.interruptingEnabled then
      -- Analysing for which interrupting key is pressed - we don't need keyboard API for this
      if event.interruptingKeyCodes[signalData[4]] then
        interruptingKeysDown[signalData[4]] = signalData[1] == "key_down" and true or nil
      end

      local shouldInterrupt = true
      for keyCode in pairs(event.interruptingKeyCodes) do
        if not interruptingKeysDown[keyCode] then
          shouldInterrupt = false
        end
      end
      
      if shouldInterrupt and uptime - lastInterrupt > event.interruptingDelay then
        lastInterrupt = uptime
        interruptingFunction("interrupted", 0)
      end
    end
    
    -- Loop-breaking condition
    if signalData[1] then
      if signalData[1] == skipSignalType then
        skipSignalType = nil
      else
        return table.unpack(signalData)
      end
    end
  until uptime >= deadline
end

-- Sleeps "time" of seconds via "busy-wait" concept
function event.sleep(time)
  checkArg(1, time, "number", "nil")

  local deadline = computerUptime() + (time or 0)
  repeat
    event.pull(deadline - computerUptime())
  until computerUptime() >= deadline
end

--------------------------------------------------------------------------------------------------------

return event