recv.nim

proc recv*(connection: Connection): int =
  var
    socket = connection.socket.get()
    buffer = newSeq[byte]()
    b: byte

  while true:
    try:
      let bytesReceived = socket.recv(addr(b), 1, 1)

      if bytesReceived == -1:
        error "Socket disconnect on read."
        connection.disconnect()
      else:
        buffer.add(b)
    except TimeoutError:
      # The socket is empty.
      break

  if buffer.len > 0:
    connection.onDataAvailable(buffer.mapIt(it.char).join())

  result = buffer.len