Mirror of forum.nim-lang.org

5084 :: Server-sent events in Jester

• konradmb (orginal) [2019-08-09T18:12:55+02:00] view original

  I'm trying to do server-sent events in Jester.

  What I have now is this:

  router index:
    get "/time":
      let data =
        "retry: 3000\n" &
        "data: {time: \'" & getClockStr() & "\'} \n\n"
      resp(data, "text/event-stream")
  Run

  It's working because browser is reconnecting every 3 seconds and getting new data.
  But in principle, the server is supposed to keep the existing connection open and send more data through it.
  

  I've found some code that does exactly what I want in alltest.nim, but the response is undeclared in this context.

  # get "/live":
  #   await response.sendHeaders()
  #   for i in 0 .. 10:
  #     await response.send("The number is: " & $i & "</br>")
  #     await sleepAsync(1000)
  #   response.client.close()
  Run

  Is there any way to get response object inside route? Or is there another approach?

---

• dom96 (orginal) [2019-08-10T11:31:18+02:00] view original

  Try s/response/request in the code you've found, it might work. You will also need to use request.getNativeReq to get the socket and to close it. (These details are defined here: https://github.com/dom96/jester/blob/master/jester/request.nim#L5-L22 and a NativeRequest-agnostic close would appreciated in a PR :) )

---

• konradmb (orginal) [2019-08-10T14:50:26+02:00] view original

  Thanks! Ended up with this:

  import nativesockets, httpbeast
  …
    
    get "/time-live":
      request.sendHeaders(Http200,@({"Content-Type": "text/event-stream"}))
      for i in 0 .. 10:
        let data =
          "retry: 3000\n" &
          "data: {time: \'" & getClockStr() & "\'} \n\n"
        request.send(data)
        await sleepAsync(1000)
      let nativeReq = request.getNativeReq()
      nativeReq.forget()
      nativeReq.client.close()
      result.matched=true
      break routesList
  Run

  NativeRequest-agnostic close would appreciated in a PR :)

  I'll look into it 😉

---