Use Thruster (AnyCabled)

Author: palkan

Gemfile

@@ -21,8 +21,11 @@ gem 'cssbundling-rails'
 gem 'jsbundling-rails'
 gem 'propshaft'
 
+gem 'anycable-thruster'
+
 group :development, :test do
-  gem 'debug', '~> 1.9'
+  # FIXME: Fails with Operation not supported by device - <STDIN> when running within Thruster
+  gem 'debug', '~> 1.9'#, require: false
   gem 'rspec-rails', '~> 6.0'
 end
 
@@ -33,9 +36,7 @@ end
 group :test do
   gem 'capybara'
   gem 'cuprite'
-
-  # Rack-based AnyCable server implementation
-  gem 'anycable-rack-server', '~> 0.5'
+  gem 'childprocess'
 
   gem 'test-prof'
 end

Gemfile.lock

@@ -83,18 +83,18 @@ GEM
     anycable-core (1.5.0)
       anyway_config (~> 2.2)
       google-protobuf (~> 3.25)
-    anycable-rack-server (0.5.1)
-      anycable (> 1.0.99, < 2.0)
-      anyway_config (>= 2.1.0)
-      connection_pool (~> 2.2)
-      websocket (~> 1.2)
     anycable-rails (1.5.1)
       anycable (~> 1.5.0)
       anycable-rails-core (= 1.5.1)
     anycable-rails-core (1.5.1)
       actioncable (>= 6.0)
       anycable-core (~> 1.5.0)
       globalid
+    anycable-thruster (0.1.3)
+    anycable-thruster (0.1.3-aarch64-linux)
+    anycable-thruster (0.1.3-arm64-darwin)
+    anycable-thruster (0.1.3-x86_64-darwin)
+    anycable-thruster (0.1.3-x86_64-linux)
     anyway_config (2.6.3)
       ruby-next-core (~> 1.0)
     ast (2.4.2)
@@ -112,6 +112,7 @@ GEM
       rack-test (>= 0.6.3)
       regexp_parser (>= 1.5, < 3.0)
       xpath (~> 3.2)
+    childprocess (5.0.0)
     concurrent-ruby (1.2.3)
     connection_pool (2.4.1)
     crass (1.0.6)
@@ -320,7 +321,6 @@ GEM
       diff-lcs (~> 1.3)
       parser (>= 3.3.0)
     webrick (1.8.1)
-    websocket (1.2.10)
     websocket-driver (0.7.6)
       websocket-extensions (>= 0.1.0)
     websocket-extensions (0.1.5)
@@ -339,10 +339,11 @@ PLATFORMS
   x86_64-linux
 
 DEPENDENCIES
-  anycable-rack-server (~> 0.5)
   anycable-rails (~> 1.5)
+  anycable-thruster
   bootsnap (>= 1.4.2)
   capybara
+  childprocess
   cssbundling-rails
   cuprite
   daemons (~> 1.3)

Procfile.dev

@@ -1,4 +1,3 @@
-server: bundle exec rails s -p 3000
+server: ANYCABLE_OPT="--broadcast_adapter=http --presets=broker --rpc_host=http://localhost:3100/_anycable" HTTP_PORT=3000 TARGET_PORT=3100 bundle exec thrust bin/rails s
 css: yarn build:css --watch
 js: yarn build --watch
-ws: bin/anycable-go --port=8080 --broadcast_adapter=http --presets=broker --rpc_host=http://localhost:3000/_anycable

README.md

@@ -24,10 +24,10 @@ bin/setup
 
 ## Running
 
-Since you need to run multiple processes (Rails, AnyCable-Go), we recommend using a process manager, e.g., [Hivemind](https://github.com/DarthSim/hivemind):
+Run Rails server and all secondary processes (CSS/JS bundling):
 
 ```sh
-hivemind Procfile.dev
+bin/dev
 ```
 
 Then go to [http://localhost:3000/](http://localhost:3000/) and see the application in action.

config/anycable.yml

@@ -1,41 +1,19 @@
-# This file contains per-environment settings for AnyCable.
-#
-# Since AnyCable config is based on anyway_config (https://github.com/palkan/anyway_config), all AnyCable settings
-# can be set or overridden through the corresponding environment variables.
-# E.g., `rpc_host` is overridden by ANYCABLE_RPC_HOST, `debug` by ANYCABLE_DEBUG etc.
-#
-# Note that AnyCable recognizes REDIS_URL env variable for Redis pub/sub adapter. If you want to
-# use another Redis instance for AnyCable, provide ANYCABLE_REDIS_URL variable.
-#
-# Read more about AnyCable configuration here: https://docs.anycable.io/#/ruby/configuration
+# Read more about AnyCable configuration here: https://docs.anycable.io/ruby/configuration
 #
 default: &default
   # Turn on/off access logs ("Started..." and "Finished...")
   access_logs_disabled: false
-  # Persist "dirty" session between RPC calls (might be required for apps using stimulus_reflex <3.0)
-  # persistent_session_enabled: true
-  # This is the host and the port to run AnyCable RPC server on.
-  # You must configure your WebSocket server to connect to it, e.g.:
-  #   $ anycable-go --rpc-host="<rpc hostname>:50051"
-  rpc_host: "127.0.0.1:50051"
-  # Whether to enable gRPC level logging or not
-  log_grpc: false
   # Use HTTP adapter for a quick start (since redis gem is not present in the project)
   broadcast_adapter: http
-  # Use the same channel name for WebSocket server, e.g.:
-  #   $ anycable-go --redis-channel="__anycable__"
-  redis_channel: "__anycable__"
   # WebSocket server URL for clients
-  websocket_url: "ws://localhost:8080/cable"
+  websocket_url: "/cable"
+  http_rpc_mount_path: "/_anycable"
 
 development:
   <<: *default
-  http_rpc_mount_path: "/_anycable"
 
 test:
   <<: *default
-  rpc_pool_size: 5
-  http_broadcast_url: "http://localhost:3023/_anycable_rack_broadcast"
 
 production:
   <<: *default

config/environments/test.rb

@@ -11,13 +11,6 @@
     AnyCable::Rails.extend_adapter!(ActionCable.server.pubsub)
   end
 
-  # Specify AnyCable WebSocket server URL to use by JS client
-  config.action_cable.url = "/rack_cable"
-  # Disable built-in Action Cable
-  config.action_cable.mount_path = nil
-  # Run AnyCable Rack server at a custom path
-  config.any_cable_rack.mount_path = "/rack_cable"
-
   # Settings specified here will take precedence over those in config/application.rb.
   config.cache_classes = true
 

spec/system/support/anycable_setup.rb

@@ -1,5 +1,33 @@
 # frozen_string_literal: true
 
+# Capybara Thruster integration
+require "childprocess"
+Capybara.register_server :thruster do |app, port, host, **options|
+  puma_port = port + 1
+
+  # TODO: Figure out how to avoid sleep here
+  process = ChildProcess.build("bundle", "exec", "thrust", "sleep", "100")
+  process.environment["TARGET_PORT"] = puma_port.to_s
+  process.environment["HTTP_PORT"] = port.to_s
+
+  # AnyCable options
+  anycable_options = {rpc_host: "http://localhost:#{puma_port}/_anycable", broadcast_adapter: "http"}
+  anycable_options.merge!(options[:anycable_options]) if options[:anycable_options]
+  process.environment["ANYCABLE_OPT"] = anycable_options.reduce(+"") { |acc, (k, v)| "#{acc} --#{k}=#{v}" }
+
+  # Additional environment variables
+  options.fetch(:env, {}).each { |k, v| process.environment[k.to_s] = v.to_s }
+
+  process.io.inherit! if options.delete(:debug) == true
+  process.start
+
+  at_exit { process.stop }
+
+  Capybara.servers[:puma].call(app, puma_port, host)
+end
+
+Capybara.server = :thruster, {debug: ENV["DEBUG"] == "1"}
+
 # Capybara settings (not covered by Rails system tests)
 
 # Don't wait too long in `have_xyz` matchers