ActionCable: working again

app/channels/application_cable/connection.rb

@@ -20,4 +20,4 @@ def find_verified_user
       end
     end
   end
-end
+end

app/channels/export_channel.rb

@@ -9,4 +9,4 @@ def subscribed
   def unsubscribed
     # Any cleanup needed when channel is unsubscribed
   end
-end
+end

app/javascript/channels/export_channel.js

@@ -3,16 +3,16 @@ import consumer from "./consumer"
 consumer.subscriptions.create({ channel: "ExportChannel" }, {
   connected() {
     // Called when the subscription is ready for use on the server
-    console.log('Export Channel Connected');
+    console.log("GBL Admin - ExportChannel connected");
   },
 
   disconnected() {
     // Called when the subscription has been terminated by the server
-    console.log('Export Channel Disconnected');
+    console.log("GBL Admin - ExportChannel disconnected");
   },
 
   received(data) {
-    console.log('Export Channel Received');
+    console.log('GBL Admin - ExportChannel received!');
     console.log(data);
 
     if (data['progress']) {

app/javascript/channels/index.js

@@ -1,5 +1,8 @@
-// Load all the channels within this directory and all subdirectories.
-// Channel files must be named *_channel.js.
+// Function to dynamically import all channel files
+async function importAllChannels() {
+  const modules = import.meta.glob('./*_channel.js');
+  const importPromises = Object.keys(modules).map(path => modules[path]());
+  await Promise.all(importPromises);
+}
 
-const channels = require.context('.', true, /_channel\.js$/)
-channels.keys().forEach(channels)
+importAllChannels();

app/javascript/entrypoints/application.js

@@ -22,7 +22,9 @@ console.log('Vite ⚡️ Rails')
 // ActiveStorage.start()
 //
 // // Import all channels.
-// const channels = import.meta.globEager('./**/*_channel.js')
+import '../channels/consumer'
+import '../channels/export_channel'
+import '../channels/index'
 
 // Example: Import a stylesheet in app/frontend/index.css
 // import '~/index.css'

config/cable.yml

@@ -1,10 +1,9 @@
+# config/cable.yml
+production:
+  adapter: postgresql
+
 development:
-  adapter: async
+  adapter: postgresql
 
 test:
-  adapter: async
-
-production:
-  adapter: redis
-  url: <%= ENV.fetch("REDIS_URL") { "redis://localhost:6379/1" } %>
-  channel_prefix: geoblacklight_production
+  adapter: postgresql

config/environments/development.rb

@@ -64,12 +64,12 @@
   # Raises error for missing translations.
   # config.i18n.raise_on_missing_translations = true
 
-  # config.active_job.queue_adapter = :inline
   config.active_job.queue_adapter = :sidekiq
+  Redis.exists_returns_integer = true
 
   # Annotate rendered view with file names.
   # config.action_view.annotate_rendered_view_with_filenames = true
 
   # Uncomment if you wish to allow Action Cable access from any origin.
-  # config.action_cable.disable_request_forgery_protection = true
+  config.action_cable.disable_request_forgery_protection = true
 end

config/routes.rb

@@ -1,4 +1,6 @@
 Rails.application.routes.draw do
+  mount ActionCable.server => "/cable"
+
   get 'about', :to => redirect('https://gin.btaa.org/')
   get 'help', :to => redirect('https://gin.btaa.org/guides/')
   get 'robots.:format' => 'robots#robots'
@@ -297,8 +299,6 @@
 
   # @TODO
   # mount Qa::Engine => "/authorities"
-  mount ActionCable.server => "/cable"
-
     # @TODO
     authenticate :user, ->(user) { user } do
       mount Blazer::Engine, at: "blazer"