Wisper 和 Grape return 来自 POST 请求的结果

Question

我有一个简单的 POST Grape 端点，背景是 Wisper pub/sub：

module Something
  class Doit < Grape::API
    post :now do
      service = SomePub.new
      service.subscribe(SomeSub.new)
      service.call(params)
    end
  end
end

这里是 SomeSub 实际计算发生的地方：

class SomeSub
  def do_calculations(payload)
     {result: "42"}.to_json
  end
end

SomePub也很简单：

class SomePub
  include Wisper::Publisher

  def call(payload)
    broadcast(:do_calculations, payload)
  end
end

所以我需要的是在调用 Grape 的 post :now 端点时用 JSON {result: "42"} 响应。

不幸的是，它不是这样工作的，我所拥有的是：

{"local_registrations":[{"listener":{},"on":{},"with":null,"prefix":"","allowed_classes":[],"broadcaster":{}}]}

Wisper 的 wiki 中的那个例子帮助不大 (https://github.com/krisleech/wisper/wiki/Grape)

对于如何通过 Grape 的端点调用实际传递 SomePub#do_calculations 结果有什么想法吗？

Answer 1

PubSub 模式的要点是发布者完全不知道其订阅者。您试图实现的是将订阅者的结果传递回发布者，这与所有想法背道而驰。

但是，您可以做的是让您的订阅者也成为发布者，并在单独的订阅者中收集响应。

请注意，这是示例代码，因为我手头没有安装 Grape（但希望它能工作）：

class ResponseListener
  attr_reader :response

  def initialize
    @response = {}
  end

  def collect_response(item)
    @response.merge!(item) # customize as you wish
  end
end

class SomeSub
  include Wisper::Publisher

  def do_calculations(payload)
     broadcast(:collect_response, result: "42")
  end
end

module Something
  class Doit < Grape::API
    post :now do
      response_listener = ResponseListener.new
      # globally subscribe response_listener to all events it can respond to
      Wisper.subscribe(response_listener) 

      service = SomePub.new
      service.subscribe(SomeSub.new)
      service.call(params)

      response_listener.response.to_json # render collected response
    end
  end
end

Wisper 和 Grape return 来自 POST 请求的结果

Wisper and Grape return results from a POST request

ruby

ruby-grape

grape-api

wisper