diff --git a/app/channels/session_channel.rb b/app/channels/session_channel.rb
new file mode 100644
index 0000000000000000000000000000000000000000..8b46fce31b2967fc342500694e70e9e13c57f82c
--- /dev/null
+++ b/app/channels/session_channel.rb
@@ -0,0 +1,9 @@
+class SessionChannel < ApplicationCable::Channel
+ def subscribed
+ # stream_from "some_channel"
+ end
+
+ def unsubscribed
+ # Any cleanup needed when channel is unsubscribed
+ end
+end
diff --git a/app/controllers/assignments_controller.rb b/app/controllers/assignments_controller.rb
index a0b4def1ea875aaebac80ca6673f51ccdd055c75..f7ab1eb03ffcb7a21545af8e555cfbd31a7f3ac2 100644
--- a/app/controllers/assignments_controller.rb
+++ b/app/controllers/assignments_controller.rb
@@ -14,7 +14,12 @@ class AssignmentsController < ApplicationController
params[:user_id] ||= params[:assignment][:user_id]
if params[:user_id].nil? or params[:user_id].empty?
flash.now[:alert] = 'Please select a user to assign.'
-
+ Turbo::StreamsChannel.broadcast_replace_later_to(
+ @session,
+ target: dom_id(@session),
+ partial: "sessions/session",
+ locals: { session: @session }
+ )
respond_to do |format|
format.turbo_stream { render turbo_stream: turbo_stream.replace(helpers.dom_id(@session), partial: "sessions/session", locals: { session: @session }), status: :unprocessable_entity }
format.html { redirect_to conference_session_path(@session.conference, @session), alert: 'Please select a user to assign.' }
@@ -27,6 +32,12 @@ class AssignmentsController < ApplicationController
@assignment = Assignment.new(user: @user, session: @session)
if @assignment.save
+ Turbo::StreamsChannel.broadcast_replace_later_to(
+ @session,
+ target: helpers.dom_id(@session),
+ partial: "sessions/session",
+ locals: { session: @session }
+ )
flash.now[:success] = 'User assigned successfully.'
respond_to do |format|
format.turbo_stream { render turbo_stream: turbo_stream.replace(helpers.dom_id(@session), partial: "sessions/session", locals: { session: @session }) }
@@ -46,6 +57,12 @@ class AssignmentsController < ApplicationController
@session = @assignment.session
if @assignment&.destroy
+ Turbo::StreamsChannel.broadcast_replace_later_to(
+ @session,
+ target: helpers.dom_id(@session),
+ partial: "sessions/session",
+ locals: { session: @session }
+ )
respond_to do |format|
format.turbo_stream { render turbo_stream: turbo_stream.replace(helpers.dom_id(@session), partial: "sessions/session", locals: { session: @session }) }
format.html { redirect_to conference_session_path(@session.conference, @session), notice: 'User removed successfully.' }
diff --git a/app/javascript/application.js b/app/javascript/application.js
index 84b06ebb56969db99d05c9c284ab917a6f2d6e19..0c66ece2255f65daf4262c959d1e4e3f8b650a61 100644
--- a/app/javascript/application.js
+++ b/app/javascript/application.js
@@ -15,4 +15,4 @@ document.addEventListener("turbo:load", function() {
flashMessage.parentNode.removeChild(flashMessage);
}, 5000);
});
-});
\ No newline at end of file
+});import "channels"
diff --git a/app/javascript/channels/consumer.js b/app/javascript/channels/consumer.js
new file mode 100644
index 0000000000000000000000000000000000000000..8ec3aad3ae962b501c348de0d0c6d5ade3802d71
--- /dev/null
+++ b/app/javascript/channels/consumer.js
@@ -0,0 +1,6 @@
+// Action Cable provides the framework to deal with WebSockets in Rails.
+// You can generate new channels where WebSocket features live using the `bin/rails generate channel` command.
+
+import { createConsumer } from "@rails/actioncable"
+
+export default createConsumer()
diff --git a/app/javascript/channels/index.js b/app/javascript/channels/index.js
new file mode 100644
index 0000000000000000000000000000000000000000..7b67b920150c440dea903703b0f836bbb029e1da
--- /dev/null
+++ b/app/javascript/channels/index.js
@@ -0,0 +1,2 @@
+// Import all the channels to be used by Action Cable
+import "channels/session_channel"
diff --git a/app/javascript/channels/session_channel.js b/app/javascript/channels/session_channel.js
new file mode 100644
index 0000000000000000000000000000000000000000..70416541775b681b4530cea1f736ac5257c9db52
--- /dev/null
+++ b/app/javascript/channels/session_channel.js
@@ -0,0 +1,15 @@
+import consumer from "channels/consumer"
+
+consumer.subscriptions.create("SessionChannel", {
+ connected() {
+ // Called when the subscription is ready for use on the server
+ },
+
+ disconnected() {
+ // Called when the subscription has been terminated by the server
+ },
+
+ received(data) {
+ // Called when there's incoming data on the websocket for this channel
+ }
+});
diff --git a/app/models/session.rb b/app/models/session.rb
index 402c57e3ad0ca45050a582662907cb2826bbe481..2c718d8e091b1aadc629584f7c9730d665e937b7 100644
--- a/app/models/session.rb
+++ b/app/models/session.rb
@@ -6,13 +6,13 @@ class Session < ApplicationRecord
has_many :session_speakers, dependent: :destroy
has_many :speakers, through: :session_speakers
-
scope :scheduled, -> { where(status: 'scheduled') }
-
+
validates :ref_id, uniqueness: { scope: :conference_id }
-
+
after_update :notify_if_changed
-
+ after_update_commit -> { broadcast_replace_to "sessions" }
+
self.implicit_order_column = :starts_at
def to_param
diff --git a/app/views/sessions/_session.html.erb b/app/views/sessions/_session.html.erb
index 2f2fb48ab751f52559c3dd18e50630715dcad133..4a49a8a8c3b9a38e4689d0bcc3bcd397bfab4254 100644
--- a/app/views/sessions/_session.html.erb
+++ b/app/views/sessions/_session.html.erb
@@ -1,4 +1,5 @@
-<% unassigned_users = @users - session.assignments.collect(&:user) %>
+<% unassigned_users = User.all - session.assignments.collect(&:user) %>
+<%= turbo_stream_from session %>
<%= turbo_frame_tag dom_id(session) do %>
<div class="session shadow hover:shadow-lg overflow-scroll text-sm w-full !h-full min-h-full hover:!min-h-max <%= session.translators_needed? ? "translators-needed" : "no-translators-needed" %> <%= session.backup_needed? ? "backup-needed" : "no-backup-needed" %> <%= session.has_assignees? ? "has-assignees" : "no-assignees" %>">
<h4>
diff --git a/config/importmap.rb b/config/importmap.rb
index cb0480c0c0a7e50463e1bd0e2665a6866ae0435c..8bebd2cd8c081f859058890a13f136614ffc73bd 100644
--- a/config/importmap.rb
+++ b/config/importmap.rb
@@ -5,3 +5,5 @@ pin "@hotwired/stimulus", to: "stimulus.min.js"
pin "@hotwired/stimulus-loading", to: "stimulus-loading.js"
pin_all_from "app/javascript/controllers", under: "controllers"
pin "@hotwired/turbo-rails", to: "turbo.min.js"
+pin "@rails/actioncable", to: "actioncable.esm.js"
+pin_all_from "app/javascript/channels", under: "channels"
diff --git a/test/channels/session_channel_test.rb b/test/channels/session_channel_test.rb
new file mode 100644
index 0000000000000000000000000000000000000000..f24560b2df2eb4d3e442a2a229a1bb3b841fed12
--- /dev/null
+++ b/test/channels/session_channel_test.rb
@@ -0,0 +1,8 @@
+require "test_helper"
+
+class SessionChannelTest < ActionCable::Channel::TestCase
+ # test "subscribes" do
+ # subscribe
+ # assert subscription.confirmed?
+ # end
+end