woe/data/script/main.rb

script "log.rb"

log "Main mruby script loaded OK."
p Signal.constants

script "client.rb"

# Return an array of symbols of constants of klass that match value
def const_syms(klass, value)
  res = []
  klass.constants.each do |c|
     cv = klass.const_get(c)
     res << c if cv == value
  end
  return res
end


def signal_syms(value)
  return const_syms(Signal, value) 
end


def start_timers
  @started_timers ||= false
  if @started_timers
    log "Timers already started."
  else
    log "Staring timer(s)..."
    @timer_id = Woe::Server.new_timer()
    Woe::Server.set_timer(@timer_id, 1.0, 1.0);
  end
  @started_timers = true
end

def woe_on_connect(client_id)
  p "Client #{client_id} connected"
  Client.add(client_id)
end

def woe_on_disconnect(client_id)
  p "Client #{client_id} disconnected"
  Client.remove(client_id)
end

def woe_on_input(client_id, buf)
  p "Client #{client_id} input #{buf}"
  client = Client.get(client_id)
  unless client
    log "Unknown client #{client_id} in woe_on_input."
    Woe::Server.disconnect(client_id)
  else
    p "Client #{client} #{client.id} ok."
    client.on_input(buf)
  end  
end

def woe_on_negotiate(client_id, how, option) 
  p "Client #{client_id} negotiating."
end

def woe_on_subnegotiate(client_id, option, buffer) 
  p "Client #{client_id} subnegotiating."
end

def woe_on_iac(client_id, option, command) 
  p "Client #{client_id} iac #{command}."
end


def woe_on_ttype(client_id, cmd, name) 
  p "Client #{client_id} ttype #{cmd} #{name}."
end

def woe_on_error(client_id, code, message) 
end

def woe_on_warning(client_id, code, message) 
end


def woe_begin_compress(client_id, state) 
end


def woe_begin_zmp(client_id, size) 
end

def woe_zmp_arg(client_id, index, value)  
end

def woe_finish_zmp(client_id, size) 
end


def woe_begin_environ(client_id, size) 
end

def woe_environ_arg(client_id, index, type, key, value)  
end

def woe_finish_environ(client_id, size) 
end


def woe_begin_mssp(client_id, size) 
end

def woe_mssp_arg(client_id, index, type, key, value)  
end

def woe_finish_mssp(client_id, size) 
end



def woe_on_signal(signal)
  log "Received signal #{signal} #{signal_syms(signal)} in script"
  case signal 
    when 10 # SIGUSR1
      log "Reloading main script."
      script "main.rb"
    when 28 
      # ignore this signal
    else
      Woe::Server.quit 
  end
end


def woe_on_timer(timer, value, interval)
  log "Timer #{timer} #{value} #{interval} passed."
end


start_timers