# frozen_string_literal: true

require "bundler/inline"

gemfile(true) do
  source 'https://rubygems.org'

  gem "rails", github: "rails/rails", ref: "d6eec533c186c92448e7413e9af9c2a2009aca99"
end

require "action_cable"
require "minitest/autorun"
require "logger"

ActionCable.server.config.cable ||= {}
ActionCable.server.config.cable["adapter"] = "async"
ActionCable.server.config.logger = Logger.new(STDOUT)

module ApplicationCable
  class Connection < ActionCable::Connection::Base
  end
end

module ApplicationCable
  class Channel < ActionCable::Channel::Base
    def hello(data)
      ActionCable.server.broadcast("nice_#{params[:number]}", data)
    end

    private

    def subscribed
      stream_from "nice_#{params[:number]}"
      reject if Integer(params[:number], exception: false).negative?
    end
  end
end

class Test < ActionCable::Channel::TestCase
  tests ApplicationCable::Channel

  def test_hello
    subscribe number: "2"
    perform :hello, { name: "MM" }
  end
end