Crystal WebSocket Client/Server Ping/Pong

websocker.cr

# Client

require "http"

client = HTTP::WebSocket.new(URI.parse("ws://127.0.0.1:9333"))
client.send "ping"
client.on_message do |str|
  puts str
  client.send "ping"
  sleep 1
end

client.on_close do |str|
  puts "disconnected"
end
client.run

# Server
require "http/server"

handler = HTTP::WebSocketHandler.new do |session|
  puts session
  session.on_message do |str|
    puts str
    session.send("pong")
    sleep 1
  end

  session.on_close do |str|
    puts "closed"
    puts str
  end
end

server = HTTP::Server.new(handler)

puts "Listening on http://0.0.0.0:9333"
server.listen("0.0.0.0", 9333)