2

I'm beginner in crystal. I have question, maybe somebody can help me.

I use Kemal framework. Have this code:

require "kemal"
require "json"

channel = Channel(Card).new

post "/posts" do |env|
  json = JSON.parse(env.request.body as String)

  url = json["url"].to_s

  spawn do
    # Slow process
    page = Scraper.new(url)
    channel.send(page)
  end

  {"url" => url}.to_json
end

ws "/" do |socket|
  data = channel.receive
  socket.send data.to_h.to_json
end

Kemal.run

But the result is sent to web socket only once.

(Only after first post request)

How can I fix it?

Serdar Dogruyol
  • 5,147
  • 3
  • 24
  • 32
schumi
  • 21
  • 3

1 Answers1

2

I'm not a kemal expert, and I don't know what's your intended behaviour, but if you want to send the websocket a message each time someone posts to "/posts", I would make a loop:

while data = channel.receive?
  socket.send(data.to_h.to_json)
end
asterite
  • 2,906
  • 1
  • 14
  • 14