30 lines
711 B
Nim
30 lines
711 B
Nim
import chronos, stew/byteutils
|
|
import ../webrtc/udp_connection
|
|
import ../webrtc/stun/stun_connection
|
|
import ../webrtc/dtls/dtls
|
|
import ../webrtc/sctp
|
|
|
|
proc sendPong(conn: SctpConn) {.async.} =
|
|
var i = 0
|
|
while true:
|
|
let msg = await conn.read()
|
|
echo "Received: ", string.fromBytes(msg.data)
|
|
await conn.write(("pong " & $i).toBytes)
|
|
i.inc()
|
|
|
|
proc main() {.async.} =
|
|
let laddr = initTAddress("127.0.0.1:4242")
|
|
let udp = UdpConn()
|
|
udp.init(laddr)
|
|
let stun = StunConn()
|
|
stun.init(udp, laddr)
|
|
let dtls = Dtls()
|
|
dtls.init(stun, laddr)
|
|
let sctp = Sctp.new(dtls, laddr)
|
|
sctp.listen(13)
|
|
while true:
|
|
let conn = await sctp.accept()
|
|
asyncSpawn conn.sendPong()
|
|
|
|
waitFor(main())
|