如何从irb控制台测试LiteCable广播？

问题描述

实际上，我的问题不只是控制台。我没有找到用于测试LiteCable的任何库，而是尝试实现一些库。我现在面临的问题是，当我在控制台中调用类似（与官方example完全相同）的东西时：

LiteCable.broadcast "chat_#{chat_id}",user: user,message: data["message"],sid: sid

它返回nil。我尝试将byebug放在代码中，当我在那里使用绝对相同的参数调用此方法时，我得到了一个很大的表，其中包含一些无法读取的参数。而且主要的问题是我没有看到尝试从控制台发送的消息。

有人可以解释为什么吗？如何实现从控制台发送请求？关键是我正在研究仅api的应用程序，并尝试通过适当的测试涵盖此功能。提前非常感谢您！

P.S：该项目位于纯红宝石上，无轨

解决方法

由于您没有完整的代码，因此我无法清楚地了解您的设置。 LiteCable的默认broadcast_adapter是memory，因此，如果要从控制台进行广播，则控制台外部的进程将不会接收到此类流。如果您使用anycable adapter（我相信它会在Redis中将广播排队），那么只要您具有正确的连接，就应该可以从控制台进行广播。

这是使用不带Rails的LiteCable的WS客户端和服务器的简单实现

# ~/app/server.rb
# A simple WS server that evaluates math expression literally using ruby eval
# Run this server with ruby server.rb

require "rack"
require "rack/handler/puma"
require "lite_cable"
require "lite_cable/server"

class CalculatorConnection < LiteCable::Connection::Base
  identified_by :token

  def connect
    self.token = request.params["token"]

    $stdout.puts "Session #{token} is connected to the server"
  end

  def disconnect
    $stdout.puts "Session #{token} disconnected from the server"
  end
end

class CalculatorChannel < LiteCable::Channel::Base
  identifier :calculator
  
  def subscribed
    stream_from "calculator"
  end

  def evaluate(payload)
    $stdout.puts "Data received from the client"

    LiteCable.broadcast "calculator",result: eval(payload['expression']) 
  end
end

app = Rack::Builder.new 
app.map "/cable" do
  use LiteCable::Server::Middleware,connection_class: CalculatorConnection
  
  run(proc { |_| [200,{"Content-Type" => "text/plain"},["OK"]] })
end

Rack::Handler::Puma.run app

// ~/app/client.js
// A client that talks to the WS server.
// To run,Open chrome console and paste this code 

let socket = null;

(function init() {
  socket = new WebSocket("ws://0.0.0.0:9292/cable?token=abc123");

  socket.onopen = function (e) {
    console.info("[connected] : Connection established to the server");
  };

  socket.onmessage = function (e) {
    console.info("[message] : Message from the server",e.data);
  };

  socket.onerror = function (e) {
    console.error("[error] : Error establishing connection",e.message);
  };

})();

// subscribe to the calculator channel
socket.send(
  JSON.stringify({
    command: "subscribe",identifier: JSON.stringify({
      channel: "calculator",}),})
);

// call the evaluate method on the Calculator channel
socket.send(
  JSON.stringify({
    command: "message",data: JSON.stringify({
      expression: "150 * 4 - 3 / (2 + 2)",action: "evaluate",})
);

这里没有什么特别的事情，只是使用Puma的简单机架应用程序增加了对机架插座劫持的支持。这应该可以指导您正确的方向。确保同时打开服务器和chrome控制台以查看输出。尝试向服务器发送其他消息以查看输出。

如果您正在考虑使用LiteCable在ruby中实现WebSocket客户端而不是js，请在LiteCable存储库中使用check the client socket class