Make it possible to use our own initialize and some other improvements

A couple of improvements are introduced here.
- Be able to pin what version of StimulusReflex we are using. The
tradeoff is that we need to maintain a fork that is lightly touched
to allow for that functionality.
- Be able to decouple from how rails expect the identifier would look
like
- The javascript code for actioncable is no longer a dependency.

javascript/stimulus-websocket/index.js

@@ -1,4 +1,9 @@
 import ReconnectingWebSocket from "reconnecting-websocket"
+import { Controller } from 'stimulus'
+import StimulusReflex from "stimulus_reflex"
+import actionCable from 'stimulus_reflex/javascript/transports/action_cable'
+import { reflexControllerMethods } from "stimulus_reflex/javascript/reflexes"
+
 
 // read up on the default options that actioncable has for websockets.
 
@@ -106,6 +111,43 @@ class Subscriptions {
     }
 }
 
+class StimulusReflexController extends Controller {
+  constructor (...args) {
+    super(...args)
+    register(this)
+  }
+}
+
+
+const register = (controller, options = {}) => {
+  const channel = 'StimulusReflex::Channel'
+  controller.StimulusReflex = { ...options, channel }
+  actionCable.createSubscription(controller)
+  Object.assign(controller, reflexControllerMethods)
+}
+
+const initialize = (application, {
+  controller = StimulusReflexController,
+  consumer,
+  debug,
+  params,
+  isolate,
+  deprecate
+} = {}) => {
+  let options = {consumer, controller, debug, params, isolate, deprecate}
+  StimulusReflex.initialize(application, options)
+}
+
+
+const Sockpuppet = {
+  initialize: initialize,
+  register: register,
+}
+
+export {
+  Sockpuppet
+}
+
 export default class WebsocketConsumer {
     constructor(url, options = {}) {
         this._url = url

package.json

@@ -32,14 +32,17 @@
         "rollup-plugin-babel": "^4.4.0",
         "rollup-plugin-terser": "^7.0.2",
         "stimulus": ">=1.1",
-        "stimulus_reflex": ">=3.4.1",
         "webpack": "^4.43.0",
         "webpack-bundle-analyzer": "^3.7.0",
         "webpack-cli": "^3.3.11",
         "cable_ready": ">= 4.4"
     },
+    "peerDependencies": {
+        "stimulus": ">= 1.1"
+    },
     "dependencies": {
-        "reconnecting-websocket": "^4.4.0"
+        "reconnecting-websocket": "^4.4.0",
+        "stimulus_reflex": "jonathan-s/stimulus_reflex#sockpuppet"
     },
     "files": [
         "javascript/stimulus-websocket/index.js"
@@ -54,4 +57,4 @@
         "cypress:open": "cypress open",
         "cypress:run": "cypress run"
     }
-}
+}

sockpuppet/js/sockpuppet.js

@@ -1,11 +1,11 @@
 import { Application } from 'stimulus'
-import StimulusReflex from 'stimulus_reflex'
 // because travis had issues with 'sockpuppet-js' we had to do this.
 import WebsocketConsumer from '../../javascript/stimulus-websocket/index'
+import { Sockpuppet } from '../../javascript/stimulus-websocket/index'
 
 const application = Application.start()
 const consumer = new WebsocketConsumer(
   `${location.protocol=='https:'?'wss':'ws'}://${window.location.host}/ws/sockpuppet-sync`, {debug: false}
 )
 
-StimulusReflex.initialize(application, { consumer })
+Sockpuppet.initialize(application, { consumer })

tests/example/javascript/example.js

@@ -3,6 +3,7 @@ import StimulusReflex from 'stimulus_reflex'
 import CableReady from 'cable_ready'
 // because travis had issues with 'sockpuppet-js' we had to do this.
 import WebsocketConsumer from '../../../javascript/stimulus-websocket/index'
+import { Sockpuppet } from '../../../javascript/stimulus-websocket/index'
 import ExampleController from './controllers/example_controller'
 
 const application = Application.start()
@@ -16,4 +17,4 @@ consumer.subscriptions.create('progress', {
   }
 })
 application.register("example", ExampleController)
-StimulusReflex.initialize(application, { consumer, debug: true})
+Sockpuppet.initialize(application, { consumer, debug: true})