diff options
author | GitLab Bot <gitlab-bot@gitlab.com> | 2022-07-19 21:09:21 +0300 |
---|---|---|
committer | GitLab Bot <gitlab-bot@gitlab.com> | 2022-07-19 21:09:21 +0300 |
commit | f602da84d10c36889714e46040f26cdfef5dce60 (patch) | |
tree | 6835a37866865775596881c5e3a35115f0ac8a49 /spec/channels/awareness_channel_spec.rb | |
parent | 9c8e8b5ffc6e11d827fa42f2dce5f90c4dc19493 (diff) |
Add latest changes from gitlab-org/gitlab@master
Diffstat (limited to 'spec/channels/awareness_channel_spec.rb')
-rw-r--r-- | spec/channels/awareness_channel_spec.rb | 80 |
1 files changed, 80 insertions, 0 deletions
diff --git a/spec/channels/awareness_channel_spec.rb b/spec/channels/awareness_channel_spec.rb new file mode 100644 index 00000000000..8d6dc36f6bd --- /dev/null +++ b/spec/channels/awareness_channel_spec.rb @@ -0,0 +1,80 @@ +# frozen_string_literal: true + +require 'spec_helper' + +RSpec.describe AwarenessChannel, :clean_gitlab_redis_shared_state, type: :channel do + before do + stub_action_cable_connection(current_user: user) + end + + context "with user" do + let(:user) { create(:user) } + + describe "when no path parameter given" do + it "rejects subscription" do + subscribe path: nil + + expect(subscription).to be_rejected + end + end + + describe "with valid path parameter" do + it "successfully subscribes" do + subscribe path: "/test" + + session = AwarenessSession.for("/test") + + expect(subscription).to be_confirmed + # check if we can use session object instead + expect(subscription).to have_stream_from("awareness:#{session.to_param}") + end + + it "broadcasts set of collaborators when subscribing" do + session = AwarenessSession.for("/test") + + freeze_time do + collaborator = { + id: user.id, + name: user.name, + avatar_url: user.avatar_url(size: 36), + last_activity: Time.zone.now, + last_activity_humanized: ActionController::Base.helpers.distance_of_time_in_words( + Time.zone.now, Time.zone.now + ) + } + + expect do + subscribe path: "/test" + end.to have_broadcasted_to("awareness:#{session.to_param}") + .with(collaborators: [collaborator]) + end + end + + it "transmits payload when user is touched" do + subscribe path: "/test" + + perform :touch + + expect(transmissions.size).to be 1 + end + + it "unsubscribes from channel" do + subscribe path: "/test" + session = AwarenessSession.for("/test") + + expect { subscription.unsubscribe_from_channel } + .to change { session.size}.by(-1) + end + end + end + + context "with guest" do + let(:user) { nil } + + it "rejects subscription" do + subscribe path: "/test" + + expect(subscription).to be_rejected + end + end +end |