Drop turbo dependency and rely on vanilla action cable

Gemfile.lock

@@ -4,7 +4,6 @@ PATH
     hotwire_spark (0.1.0)
       listen
       rails (>= 8.0.0)
-      turbo-rails
       zeitwerk
 
 GEM
@@ -239,9 +238,6 @@ GEM
     stringio (3.1.2)
     thor (1.3.2)
     timeout (0.4.2)
-    turbo-rails (2.0.11)
-      actionpack (>= 6.0.0)
-      railties (>= 6.0.0)
     tzinfo (2.0.6)
       concurrent-ruby (~> 1.0)
     unicode-display_width (2.6.0)

app/channels/hotwire_spark/channel.rb

@@ -0,0 +1,5 @@
+class HotwireSpark::Channel < ActionCable::Channel::Base
+  def subscribed
+    stream_from "hotwire_spark"
+  end
+end

app/javascript/hotwire_spark/index.js

@@ -1,4 +1,4 @@
-import "./stream_actions"
+import { ReloadingMonitor } from "./reloading_monitor.js";
 
 const HotwireSpark = {
   config: {
@@ -7,3 +7,6 @@ const HotwireSpark = {
 }
 
 export default HotwireSpark
+
+ReloadingMonitor.start()
+

app/javascript/hotwire_spark/logger.js

@@ -1,4 +1,3 @@
-import "./stream_actions"
 import HotwireSpark from "./index.js"
 
 export function log(...args) {

app/javascript/hotwire_spark/reloaders/html_reloader.js

@@ -30,13 +30,6 @@ export class HtmlReloader {
   }
 
   #updateBody(newBody) {
-    Idiomorph.morph(document.body, newBody, {
-      callbacks: {
-        beforeNodeMorphed: function (oldNode, newNode) {
-          const value = !(oldNode instanceof HTMLElement) || !oldNode.closest("turbo-cable-stream-source")
-          return value
-        }
-      }
-    })
+    Idiomorph.morph(document.body, newBody)
   }
 }

app/javascript/hotwire_spark/reloading_monitor.js

@@ -0,0 +1,48 @@
+import { HtmlReloader } from "./reloaders/html_reloader.js"
+import { CssReloader } from "./reloaders/css_reloader.js";
+import { StimulusReloader } from "./reloaders/stimulus_reloader.js";
+import { nameFromFilePath } from "./helpers.js";
+import { createConsumer } from "@rails/actioncable"
+
+export class ReloadingMonitor {
+  static start() {
+    new ReloadingMonitor().start()
+  }
+
+  start() {
+    const consumer = createConsumer()
+
+    consumer.subscriptions.create({ channel: "HotwireSpark::Channel" }, {
+      received(data) {
+        this.dispatchMessage(data)
+      },
+
+      dispatchMessage({ action, path }) {
+        const filePath = nameFromFilePath(path)
+        switch (action) {
+          case "reload_html":
+            this.reloadHtml()
+            break
+          case "reload_css":
+            this.reloadCss(filePath)
+            break
+          case "reload_stimulus":
+            this.reloadStimulus(filePath)
+            break
+        }
+      },
+
+      reloadHtml() {
+        HtmlReloader.reload()
+      },
+
+      reloadCss(path) {
+        CssReloader.reload(new RegExp(path))
+      },
+
+      reloadStimulus(path) {
+        StimulusReloader.reload(new RegExp(path))
+      }
+    })
+  }
+}

hotwire_spark.gemspec

@@ -25,7 +25,6 @@ Gem::Specification.new do |spec|
   spec.add_dependency "rails", ">= 8.0.0"
   spec.add_dependency "zeitwerk"
   spec.add_dependency "listen"
-  spec.add_dependency "turbo-rails"
 
   spec.add_development_dependency "rubocop"
   spec.add_development_dependency "rubocop-rails-omakase"

lib/hotwire_spark/engine.rb

@@ -1,4 +1,3 @@
-require "turbo-rails"
 require "action_cable/server/base"
 
 module HotwireSpark

lib/hotwire_spark/installer.rb

@@ -38,17 +38,15 @@ def monitor_paths
 
     def monitor(paths_name, action:)
       file_watcher.monitor HotwireSpark.public_send(paths_name) do |file_path|
-        ActionCable.server.broadcast "hotwire_spark", stream_action_for(action, file_path)
+        ActionCable.server.broadcast "hotwire_spark", change_message_for(action, file_path)
       end
     end
 
     def file_watcher
       @file_watches ||= HotwireSpark::FileWatcher.new
     end
 
-    def stream_action_for(action, file_path)
-      <<~HTML
-        <turbo-stream action="#{action}" file_path="#{file_path}">
-      HTML
+    def change_message_for(action, file_path)
+      { action: action, path: file_path }
     end
 end

lib/hotwire_spark/middleware.rb

@@ -9,7 +9,6 @@ def call(env)
     if html_response?(headers)
       html = html_from(response)
       html = inject_javascript(html)
-      html = inject_turbo_stream(html)
       headers["Content-Length"] = html.bytesize.to_s if html
       response = [ html ]
     end
@@ -33,9 +32,4 @@ def inject_javascript(html)
       script_tag = ActionController::Base.helpers.javascript_include_tag(script_path)
       html.sub("</head>", "#{script_tag}</head>")
     end
-
-    def inject_turbo_stream(html)
-      turbo_stream_tag = ActionController::Base.helpers.turbo_stream_from "hotwire_spark", channel: HotwireSpark::ActionCable::StreamsChannel
-      html.sub("</body>", "#{turbo_stream_tag}</body>")
-    end
 end

package.json

@@ -14,7 +14,6 @@
     "@babel/core": "^7.23.0",
     "@babel/preset-env": "^7.26.0",
     "@hotwired/stimulus": "^3.2.2",
-    "@hotwired/turbo-rails": "^8.0.12",
     "@rails/actioncable": "^8.0.0",
     "@rollup/plugin-babel": "^6.0.4",
     "@rollup/plugin-commonjs": "^28.0.1",

yarn.lock

@@ -806,19 +806,6 @@
   resolved "https://registry.yarnpkg.com/@hotwired/stimulus/-/stimulus-3.2.2.tgz#071aab59c600fed95b97939e605ff261a4251608"
   integrity sha512-eGeIqNOQpXoPAIP7tC1+1Yc1yl1xnwYqg+3mzqxyrbE5pg5YFBZcA6YoTiByJB6DKAEsiWtl6tjTJS4IYtbB7A==
 
-"@hotwired/turbo-rails@^8.0.12":
-  version "8.0.12"
-  resolved "https://registry.yarnpkg.com/@hotwired/turbo-rails/-/turbo-rails-8.0.12.tgz#6f1a2661122c0a2bf717f3bc68b5106638798c89"
-  integrity sha512-ZXwu9ez+Gd4RQNeHIitqOQgi/LyqY8J4JqsUN0nnYiZDBRq7IreeFdMbz29VdJpIsmYqwooE4cFzPU7QvJkQkA==
-  dependencies:
-    "@hotwired/turbo" "^8.0.12"
-    "@rails/actioncable" "^7.0"
-
-"@hotwired/turbo@^8.0.12":
-  version "8.0.12"
-  resolved "https://registry.yarnpkg.com/@hotwired/turbo/-/turbo-8.0.12.tgz#50aa8345d7f62402680c6d2d9814660761837001"
-  integrity sha512-l3BiQRkD7qrnQv6ms6sqPLczvwbQpXt5iAVwjDvX0iumrz6yEonQkNAzNjeDX25/OJMFDTxpHjkJZHGpM9ikWw==
-
 "@jridgewell/gen-mapping@^0.3.5":
   version "0.3.5"
   resolved "https://registry.yarnpkg.com/@jridgewell/gen-mapping/-/gen-mapping-0.3.5.tgz#dcce6aff74bdf6dad1a95802b69b04a2fcb1fb36"
@@ -859,11 +846,6 @@
     "@jridgewell/resolve-uri" "^3.1.0"
     "@jridgewell/sourcemap-codec" "^1.4.14"
 
-"@rails/actioncable@^7.0":
-  version "7.2.200"
-  resolved "https://registry.yarnpkg.com/@rails/actioncable/-/actioncable-7.2.200.tgz#7f56b3313762dbb85b64490aa33c5f431419aafd"
-  integrity sha512-gVmi3MabEa+Bkatvw0/k1Y3WTidcIf3qNbb9L8qc+AmT2UmkVqUZhJpSLvKmH10twCYIGzn7yySW/lOpg81Duw==
-
 "@rails/actioncable@^8.0.0":
   version "8.0.0"
   resolved "https://registry.yarnpkg.com/@rails/actioncable/-/actioncable-8.0.0.tgz#b12d87d4c2bb152c4445e2c168df93b585068e7c"