gistfile1.cr

require "socket"

class AeonClient

  def self.main
    alter_aeon_server = "alteraeon.com"
    alter_aeon_port = 3000
    connection = TCPSocket.new(alter_aeon_server, alter_aeon_port)
    spawn autoreader(connection)
    # spawn writer(connection)
    Signal::INT.trap do
      connection << "quit" if connection
      sleep 1
      connection.close rescue nil
      puts "Exiting.."
      exit 0
    end
    unless connection.closed?
      begin
        buff = gets
        connection << buff.to_s if connection
      rescue e : Exception
        puts e
      end
    end
  end

  def self.autoreader(connection)
    until connection.closed?
      begin
        buf :: UInt8[4096]
        len = connection.read(buf.to_slice)
        if len > 0
          data = String.new(buf.buffer, len)
          print data if !data.empty?
        end
        break if len <= 0
      rescue e : IO::EOFError
        puts "EOFError"
        sleep 0.5
      rescue e : Exception
        p e
        puts e.message
        puts e.class
        sleep 0.5
      end
    end
  end

end

AeonClient.main