udp_spec.rb

require'libuv'
require'thread'


describeLibuv::UDPdo
before:eachdo
@log=[]
@general_failure=[]

@reactor=Libuv::Reactor.new
@server=@reactor.udp
@client=@reactor.udp
@timeout=@reactor.timerdo
@reactor.stop
@general_failure << "test timed out"
end
@timeout.start(5000)

@reactor.notifierdo |error,context|
begin
@general_failure << "Log called: #{context}\n#{error.message}\n#{error.backtrace.join("\n")iferror.backtrace}\n"
rescueException=>e
@general_failure << "error in logger #{e.inspect}"
end
end

@reactor.all(@server,@client,@timeout).catchdo |reason|
@general_failure << reason.inspect
end
end

describe'basic client server'do
it"should send a ping and return a pong",:network=>truedo
@reactor.run{ |reactor|
@server.bind('127.0.0.1',34567)
@server.progressdo |data,ip,port,server|
@log << data
server.send(ip,port,'pong')
end
@server.start_read

# catch errors
@server.catchdo |reason|
@general_failure << reason.inspect
end


# connect client to server
@client.bind('127.0.0.1',34568)
@client.progressdo |data,ip,port,client|
@log << data
client.close
end
@client.start_read
@client.send('127.0.0.1',34567,'ping')

# catch errors
@client.catchdo |reason|
@general_failure << reason.inspect
end

# close the handle
@client.finallydo
@server.close
@reactor.stop
end
}

expect(@log).toeq(['ping','pong'])
expect(@general_failure).toeq([])
end
end
end