z_executor.rb

require 'redis'
require 'json'
require 'dorothy'
require 'uri'
require 'open-uri'

def setup_game(file='games/LostPig.z8')
  @game = Z::Machine.new(file)
  @game.run
  @bot_name = ["@adventure","@a"]
  @game.output.join
end

def wait_for_messages
  @from_redis ||= Redis.new
  loop do
    msg = @from_redis.brpop("to_game").last
    js = JSON.parse(msg)
    unless js["user_name"] && @bot_name.include?(js["user_name"])
      query = extract_message(js)
      command_response = check_command(query)
      if command_response
        puts "special command #{query} run"
        send_reply(response: command_response, original: js)
      else
        puts "sending '#{query}' to game"
        send_reply(response: execute_message(query), original: js)
      end
    end
  end
end

def extract_message(json)
  @bot_name.each do |name|
    json["text"] = json["text"].gsub(/^#{name}/,"").strip
  end
  json["text"]
end

def send_reply(message)
  puts "sending #{message.to_json}"
  (@to_redis ||= Redis.new).lpush("to_user",message.to_json)
end

def check_command(message)
  case message
  when /^\/reset/
    setup_game
    @game.output.join
  when /^\/load .+/
    load_game(message.scan(/^\/load (.+)/).first.first)
  when /^\/help/
    "special commands are '/reset', and '/load <file>'"
  when /^\/games/
    list_games
  else
    nil
  end
end

def url_to_filename(url)
  url.split("/").last
end

def load_game(name)
  if name[0] == "<"
    name = name[1..-2]
  end
  if name[URI::regexp]
    load_remote name
    setup_game("games/#{url_to_filename(name)}")
  else
    if File.exist?("games/#{name}")
      setup_game("games/#{name}")
    else
      "cannot find file games/#{name}"
    end
  end
end

def list_games
  "games: " + (Dir.foreach('games').to_a - [".", ".."]).join("\n")
end

def load_remote(url)
  open("games/" + url_to_filename(url),'w'){|f|
    puts url
    f.write open(url).read
  }
end

def execute_message(message)
  begin
    @game.output.clear
    @game.keyboard << message + "\n"
    @game.run
    @game.output.join
  rescue
    "sorry, there was an error running '#{message}':  " + $!.message.to_s
  end
end

if __FILE__ == $0
  setup_game
  wait_for_messages
end