mirror of
https://github.com/discourse/discourse.git
synced 2024-11-24 21:16:08 +08:00
8437081d94
This commit adds variousMessageBus.last_ids to serializer payloads for chat channels and the chat view (for chat live pane) so we can use those IDs when subscribing to MessageBus channels from chat. This allows us to ensure that any messages created between the server being hit and the UI loaded and subscribing end up being delivered to the client, rather than just silently dropped. This commit also fixes an issue where we were subscribing to the new-messages and new-mentions MessageBus channels multiple times when following/unfollowing a channel multiple times.
850 lines
31 KiB
Ruby
850 lines
31 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require "rails_helper"
|
|
|
|
RSpec.describe Chat::ChatChannelsController do
|
|
fab!(:user) { Fabricate(:user, username: "johndoe", name: "John Doe") }
|
|
fab!(:other_user) { Fabricate(:user, username: "janemay", name: "Jane May") }
|
|
fab!(:admin) { Fabricate(:admin, username: "andyjones", name: "Andy Jones") }
|
|
fab!(:category) { Fabricate(:category) }
|
|
fab!(:chat_channel) { Fabricate(:category_channel, chatable: category) }
|
|
fab!(:dm_chat_channel) { Fabricate(:direct_message_channel, users: [user, admin]) }
|
|
|
|
before do
|
|
SiteSetting.chat_enabled = true
|
|
SiteSetting.chat_allowed_groups = Group::AUTO_GROUPS[:everyone]
|
|
SiteSetting.chat_duplicate_message_sensitivity = 0
|
|
end
|
|
|
|
describe "#index" do
|
|
fab!(:private_group) { Fabricate(:group) }
|
|
fab!(:user_with_private_access) { Fabricate(:user, group_ids: [private_group.id]) }
|
|
|
|
fab!(:private_category) { Fabricate(:private_category, group: private_group) }
|
|
fab!(:private_category_cc) { Fabricate(:category_channel, chatable: private_category) }
|
|
|
|
describe "with memberships for all channels" do
|
|
before do
|
|
ChatChannel.all.each do |cc|
|
|
model =
|
|
(
|
|
if cc.direct_message_channel?
|
|
:user_chat_channel_membership_for_dm
|
|
else
|
|
:user_chat_channel_membership
|
|
end
|
|
)
|
|
|
|
Fabricate(model, chat_channel: cc, user: user)
|
|
Fabricate(model, chat_channel: cc, user: user_with_private_access)
|
|
Fabricate(model, chat_channel: cc, user: admin)
|
|
end
|
|
end
|
|
|
|
it "errors for user that is not allowed to chat" do
|
|
sign_in(user)
|
|
SiteSetting.chat_allowed_groups = Group::AUTO_GROUPS[:staff]
|
|
|
|
get "/chat/chat_channels.json"
|
|
|
|
expect(response.status).to eq(403)
|
|
end
|
|
|
|
it "returns public channels to only-public user" do
|
|
sign_in(user)
|
|
get "/chat/chat_channels.json"
|
|
|
|
expect(response.status).to eq(200)
|
|
expect(
|
|
response.parsed_body["public_channels"].map { |channel| channel["id"] },
|
|
).to match_array([chat_channel.id])
|
|
end
|
|
|
|
it "returns channels visible to user with private access" do
|
|
sign_in(user_with_private_access)
|
|
get "/chat/chat_channels.json"
|
|
|
|
expect(response.status).to eq(200)
|
|
expect(
|
|
response.parsed_body["public_channels"].map { |channel| channel["id"] },
|
|
).to match_array([chat_channel.id, private_category_cc.id])
|
|
end
|
|
|
|
it "returns all channels for admin" do
|
|
sign_in(admin)
|
|
get "/chat/chat_channels.json"
|
|
|
|
expect(response.status).to eq(200)
|
|
expect(
|
|
response.parsed_body["public_channels"].map { |channel| channel["id"] },
|
|
).to match_array([chat_channel.id, private_category_cc.id])
|
|
end
|
|
|
|
it "doesn't error when a chat channel's chatable is destroyed" do
|
|
sign_in(user_with_private_access)
|
|
private_category.destroy!
|
|
|
|
get "/chat/chat_channels.json"
|
|
expect(response.status).to eq(200)
|
|
end
|
|
|
|
it "serializes unread_mentions properly" do
|
|
sign_in(admin)
|
|
Jobs.run_immediately!
|
|
Chat::ChatMessageCreator.create(
|
|
chat_channel: chat_channel,
|
|
user: user,
|
|
content: "Hi @#{admin.username}",
|
|
)
|
|
get "/chat/chat_channels.json"
|
|
cc = response.parsed_body["public_channels"].detect { |c| c["id"] == chat_channel.id }
|
|
expect(cc["current_user_membership"]["unread_mentions"]).to eq(1)
|
|
end
|
|
|
|
it "returns the last message bus ids for various message bus channels scoped to this channel id" do
|
|
sign_in(admin)
|
|
get "/chat/chat_channels.json"
|
|
expect(response.status).to eq(200)
|
|
|
|
expect(response.parsed_body["message_bus_last_ids"]["channel_metadata"]).not_to eq(nil)
|
|
expect(response.parsed_body["message_bus_last_ids"]["channel_edits"]).not_to eq(nil)
|
|
expect(response.parsed_body["message_bus_last_ids"]["channel_status"]).not_to eq(nil)
|
|
expect(response.parsed_body["message_bus_last_ids"]["new_channel"]).not_to eq(nil)
|
|
|
|
first_channel = response.parsed_body["public_channels"][0]
|
|
expect(first_channel["message_bus_last_ids"]["new_messages"]).not_to eq(nil)
|
|
expect(first_channel["message_bus_last_ids"]["new_mentions"]).not_to eq(nil)
|
|
end
|
|
|
|
describe "direct messages" do
|
|
fab!(:user1) { Fabricate(:user) }
|
|
fab!(:user2) { Fabricate(:user) }
|
|
fab!(:user3) { Fabricate(:user) }
|
|
|
|
before do
|
|
Group.refresh_automatic_groups!
|
|
@dm1 =
|
|
Chat::DirectMessageChannelCreator.create!(
|
|
acting_user: user1,
|
|
target_users: [user1, user2],
|
|
)
|
|
@dm2 =
|
|
Chat::DirectMessageChannelCreator.create!(
|
|
acting_user: user1,
|
|
target_users: [user1, user3],
|
|
)
|
|
@dm3 =
|
|
Chat::DirectMessageChannelCreator.create!(
|
|
acting_user: user1,
|
|
target_users: [user1, user2, user3],
|
|
)
|
|
@dm4 =
|
|
Chat::DirectMessageChannelCreator.create!(
|
|
acting_user: user1,
|
|
target_users: [user2, user3],
|
|
)
|
|
end
|
|
|
|
it "returns correct DMs for creator" do
|
|
sign_in(user1)
|
|
|
|
get "/chat/chat_channels.json"
|
|
expect(
|
|
response.parsed_body["direct_message_channels"].map { |c| c["id"] },
|
|
).to match_array([@dm1.id, @dm2.id, @dm3.id])
|
|
end
|
|
|
|
it "returns correct DMs when not following" do
|
|
sign_in(user2)
|
|
|
|
get "/chat/chat_channels.json"
|
|
expect(
|
|
response.parsed_body["direct_message_channels"].map { |c| c["id"] },
|
|
).to match_array([])
|
|
end
|
|
|
|
it "returns correct DMs when following" do
|
|
user3
|
|
.user_chat_channel_memberships
|
|
.where(chat_channel_id: @dm3.id)
|
|
.update!(following: true)
|
|
|
|
sign_in(user3)
|
|
|
|
get "/chat/chat_channels.json"
|
|
dm3_response = response.parsed_body
|
|
expect(dm3_response["direct_message_channels"].map { |c| c["id"] }).to match_array(
|
|
[@dm3.id],
|
|
)
|
|
end
|
|
|
|
it "correctly set unread_count for DMs for creator" do
|
|
sign_in(user1)
|
|
Chat::ChatMessageCreator.create(
|
|
chat_channel: @dm2,
|
|
user: user1,
|
|
content: "What's going on?!",
|
|
)
|
|
get "/chat/chat_channels.json"
|
|
dm2_response =
|
|
response.parsed_body["direct_message_channels"].detect { |c| c["id"] == @dm2.id }
|
|
expect(dm2_response["current_user_membership"]["unread_count"]).to eq(0)
|
|
end
|
|
|
|
it "correctly set membership for DMs when user is not following" do
|
|
sign_in(user2)
|
|
Chat::ChatMessageCreator.create(
|
|
chat_channel: @dm2,
|
|
user: user1,
|
|
content: "What's going on?!",
|
|
)
|
|
get "/chat/chat_channels.json"
|
|
dm2_channel =
|
|
response.parsed_body["direct_message_channels"].detect { |c| c["id"] == @dm2.id }
|
|
expect(dm2_channel).to be_nil
|
|
end
|
|
|
|
it "correctly set unread_count for DMs when user is following" do
|
|
user3
|
|
.user_chat_channel_memberships
|
|
.where(chat_channel_id: @dm2.id)
|
|
.update!(following: true)
|
|
|
|
sign_in(user3)
|
|
Chat::ChatMessageCreator.create(
|
|
chat_channel: @dm2,
|
|
user: user1,
|
|
content: "What's going on?!",
|
|
)
|
|
get "/chat/chat_channels.json"
|
|
dm3_response =
|
|
response.parsed_body["direct_message_channels"].detect { |c| c["id"] == @dm2.id }
|
|
expect(dm3_response["current_user_membership"]["unread_count"]).to eq(1)
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
describe "#follow" do
|
|
it "creates a user_chat_channel_membership record if one doesn't exist" do
|
|
sign_in(user)
|
|
expect { post "/chat/chat_channels/#{chat_channel.id}/follow.json" }.to change {
|
|
UserChatChannelMembership.where(user_id: user.id, following: true).count
|
|
}.by(1)
|
|
expect(response.status).to eq(200)
|
|
end
|
|
|
|
it "updates 'following' to true for existing record" do
|
|
sign_in(user)
|
|
membership_record =
|
|
UserChatChannelMembership.create!(
|
|
chat_channel_id: chat_channel.id,
|
|
user_id: user.id,
|
|
following: false,
|
|
)
|
|
|
|
expect { post "/chat/chat_channels/#{chat_channel.id}/follow.json" }.to change {
|
|
membership_record.reload.following
|
|
}.to(true).from(false)
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["current_user_membership"]["following"]).to eq(true)
|
|
expect(response.parsed_body["current_user_membership"]["chat_channel_id"]).to eq(
|
|
chat_channel.id,
|
|
)
|
|
end
|
|
end
|
|
|
|
describe "#unfollow" do
|
|
it "updates 'following' to false for existing record" do
|
|
sign_in(user)
|
|
membership_record =
|
|
UserChatChannelMembership.create!(
|
|
chat_channel_id: chat_channel.id,
|
|
user_id: user.id,
|
|
following: true,
|
|
)
|
|
|
|
expect { post "/chat/chat_channels/#{chat_channel.id}/unfollow.json" }.to change {
|
|
membership_record.reload.following
|
|
}.to(false).from(true)
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["current_user_membership"]["following"]).to eq(false)
|
|
expect(response.parsed_body["current_user_membership"]["chat_channel_id"]).to eq(
|
|
chat_channel.id,
|
|
)
|
|
end
|
|
|
|
it "allows to unfollow a direct_message_channel" do
|
|
sign_in(user)
|
|
membership_record =
|
|
UserChatChannelMembership.create!(
|
|
chat_channel_id: dm_chat_channel.id,
|
|
user_id: user.id,
|
|
following: true,
|
|
desktop_notification_level: 2,
|
|
mobile_notification_level: 2,
|
|
)
|
|
|
|
post "/chat/chat_channels/#{dm_chat_channel.id}/unfollow.json"
|
|
expect(response.status).to eq(200)
|
|
expect(membership_record.reload.following).to eq(false)
|
|
end
|
|
end
|
|
|
|
describe "#create" do
|
|
fab!(:category2) { Fabricate(:category) }
|
|
|
|
it "errors for non-staff" do
|
|
sign_in(user)
|
|
put "/chat/chat_channels.json", params: { id: category2.id, name: "hi" }
|
|
expect(response.status).to eq(403)
|
|
end
|
|
|
|
it "errors when chatable doesn't exist" do
|
|
sign_in(admin)
|
|
put "/chat/chat_channels.json", params: { id: Category.last.id + 1, name: "hi" }
|
|
expect(response.status).to eq(404)
|
|
end
|
|
|
|
it "errors when the name is over SiteSetting.max_topic_title_length" do
|
|
sign_in(admin)
|
|
SiteSetting.max_topic_title_length = 10
|
|
put "/chat/chat_channels.json",
|
|
params: {
|
|
id: category2.id,
|
|
name: "Hi, this is over 10 characters",
|
|
}
|
|
expect(response.status).to eq(400)
|
|
end
|
|
|
|
it "errors when channel for category and same name already exists" do
|
|
sign_in(admin)
|
|
name = "beep boop hi"
|
|
category2.create_chat_channel!(name: name)
|
|
|
|
put "/chat/chat_channels.json", params: { id: category2.id, name: name }
|
|
expect(response.status).to eq(400)
|
|
end
|
|
|
|
it "creates a channel for category and if name is unique" do
|
|
sign_in(admin)
|
|
category2.create_chat_channel!(name: "this is a name")
|
|
|
|
expect {
|
|
put "/chat/chat_channels.json", params: { id: category2.id, name: "Different name!" }
|
|
}.to change { ChatChannel.where(chatable: category2).count }.by(1)
|
|
expect(response.status).to eq(200)
|
|
end
|
|
|
|
it "creates a user_chat_channel_membership when the channel is created" do
|
|
sign_in(admin)
|
|
expect {
|
|
put "/chat/chat_channels.json", params: { id: category2.id, name: "hi hi" }
|
|
}.to change { UserChatChannelMembership.where(user: admin).count }.by(1)
|
|
expect(response.status).to eq(200)
|
|
end
|
|
end
|
|
|
|
describe "#edit" do
|
|
it "errors for non-staff" do
|
|
sign_in(user)
|
|
post "/chat/chat_channels/#{chat_channel.id}.json", params: { name: "hello" }
|
|
expect(response.status).to eq(403)
|
|
end
|
|
|
|
it "returns a 404 when chat_channel doesn't exist" do
|
|
sign_in(admin)
|
|
chat_channel.destroy!
|
|
post "/chat/chat_channels/#{chat_channel.id}.json", params: { name: "hello" }
|
|
expect(response.status).to eq(404)
|
|
end
|
|
|
|
it "updates name correctly and leaves description alone" do
|
|
sign_in(admin)
|
|
new_name = "newwwwwwwww name"
|
|
description = "this is something"
|
|
chat_channel.update(description: description)
|
|
post "/chat/chat_channels/#{chat_channel.id}.json", params: { name: new_name }
|
|
expect(response.status).to eq(200)
|
|
expect(chat_channel.reload.name).to eq(new_name)
|
|
expect(chat_channel.description).to eq(description)
|
|
end
|
|
|
|
it "updates name correctly and leaves description alone" do
|
|
sign_in(admin)
|
|
name = "beep boop"
|
|
new_description = "this is something"
|
|
chat_channel.update(name: name)
|
|
post "/chat/chat_channels/#{chat_channel.id}.json", params: { description: new_description }
|
|
expect(response.status).to eq(200)
|
|
expect(chat_channel.reload.name).to eq(name)
|
|
expect(chat_channel.description).to eq(new_description)
|
|
end
|
|
|
|
it "updates name and description together" do
|
|
sign_in(admin)
|
|
new_name = "beep boop"
|
|
new_description = "this is something"
|
|
post "/chat/chat_channels/#{chat_channel.id}.json",
|
|
params: {
|
|
name: new_name,
|
|
description: new_description,
|
|
}
|
|
expect(response.status).to eq(200)
|
|
expect(chat_channel.reload.name).to eq(new_name)
|
|
expect(chat_channel.description).to eq(new_description)
|
|
end
|
|
end
|
|
|
|
describe "#search" do
|
|
describe "without chat permissions" do
|
|
it "errors errors for anon" do
|
|
get "/chat/chat_channels/search.json", params: { filter: "so" }
|
|
expect(response.status).to eq(403)
|
|
end
|
|
|
|
it "errors when user cannot chat" do
|
|
SiteSetting.chat_allowed_groups = Group::AUTO_GROUPS[:staff]
|
|
sign_in(user)
|
|
get "/chat/chat_channels/search.json", params: { filter: "so" }
|
|
expect(response.status).to eq(403)
|
|
end
|
|
end
|
|
|
|
describe "with chat permissions" do
|
|
before do
|
|
sign_in(user)
|
|
chat_channel.update(name: "something")
|
|
end
|
|
|
|
it "returns the correct channels with filter 'so'" do
|
|
get "/chat/chat_channels/search.json", params: { filter: "so" }
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["public_channels"][0]["id"]).to eq(chat_channel.id)
|
|
expect(response.parsed_body["direct_message_channels"].count).to eq(0)
|
|
expect(response.parsed_body["users"].count).to eq(0)
|
|
end
|
|
|
|
it "returns the correct channels with filter 'something'" do
|
|
get "/chat/chat_channels/search.json", params: { filter: "something" }
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["public_channels"][0]["id"]).to eq(chat_channel.id)
|
|
expect(response.parsed_body["direct_message_channels"].count).to eq(0)
|
|
expect(response.parsed_body["users"].count).to eq(0)
|
|
end
|
|
|
|
it "returns the correct channels with filter 'andyjones'" do
|
|
get "/chat/chat_channels/search.json", params: { filter: "andyjones" }
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["public_channels"].count).to eq(0)
|
|
expect(response.parsed_body["direct_message_channels"][0]["id"]).to eq(dm_chat_channel.id)
|
|
expect(response.parsed_body["users"].count).to eq(0)
|
|
end
|
|
|
|
it "returns the current user inside the users array if their username matches the filter too" do
|
|
user.update(username: "andysmith")
|
|
get "/chat/chat_channels/search.json", params: { filter: "andy" }
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["direct_message_channels"][0]["id"]).to eq(dm_chat_channel.id)
|
|
expect(response.parsed_body["users"].map { |u| u["id"] }).to match_array([user.id])
|
|
end
|
|
|
|
it "returns no channels with a whacky filter" do
|
|
get "/chat/chat_channels/search.json", params: { filter: "hello good sir" }
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["public_channels"].count).to eq(0)
|
|
expect(response.parsed_body["direct_message_channels"].count).to eq(0)
|
|
expect(response.parsed_body["users"].count).to eq(0)
|
|
end
|
|
|
|
it "only returns open channels" do
|
|
chat_channel.update(status: ChatChannel.statuses[:closed])
|
|
get "/chat/chat_channels/search.json", params: { filter: "so" }
|
|
expect(response.parsed_body["public_channels"].count).to eq(0)
|
|
|
|
chat_channel.update(status: ChatChannel.statuses[:read_only])
|
|
get "/chat/chat_channels/search.json", params: { filter: "so" }
|
|
expect(response.parsed_body["public_channels"].count).to eq(0)
|
|
|
|
chat_channel.update(status: ChatChannel.statuses[:archived])
|
|
get "/chat/chat_channels/search.json", params: { filter: "so" }
|
|
expect(response.parsed_body["public_channels"].count).to eq(0)
|
|
|
|
# Now set status to open and the channel is there!
|
|
chat_channel.update(status: ChatChannel.statuses[:open])
|
|
get "/chat/chat_channels/search.json", params: { filter: "so" }
|
|
expect(response.parsed_body["public_channels"][0]["id"]).to eq(chat_channel.id)
|
|
end
|
|
|
|
it "only finds users by username_lower if not enable_names" do
|
|
SiteSetting.enable_names = false
|
|
get "/chat/chat_channels/search.json", params: { filter: "Andy J" }
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["public_channels"].count).to eq(0)
|
|
expect(response.parsed_body["direct_message_channels"].count).to eq(0)
|
|
|
|
get "/chat/chat_channels/search.json", params: { filter: "andyjones" }
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["public_channels"].count).to eq(0)
|
|
expect(response.parsed_body["direct_message_channels"][0]["id"]).to eq(dm_chat_channel.id)
|
|
end
|
|
|
|
it "only finds users by username if prioritize_username_in_ux" do
|
|
SiteSetting.prioritize_username_in_ux = true
|
|
get "/chat/chat_channels/search.json", params: { filter: "Andy J" }
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["public_channels"].count).to eq(0)
|
|
expect(response.parsed_body["direct_message_channels"].count).to eq(0)
|
|
|
|
get "/chat/chat_channels/search.json", params: { filter: "andyjones" }
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["public_channels"].count).to eq(0)
|
|
expect(response.parsed_body["direct_message_channels"][0]["id"]).to eq(dm_chat_channel.id)
|
|
end
|
|
|
|
it "can find users by name or username if not prioritize_username_in_ux and enable_names" do
|
|
SiteSetting.prioritize_username_in_ux = false
|
|
SiteSetting.enable_names = true
|
|
get "/chat/chat_channels/search.json", params: { filter: "Andy J" }
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["public_channels"].count).to eq(0)
|
|
expect(response.parsed_body["direct_message_channels"][0]["id"]).to eq(dm_chat_channel.id)
|
|
|
|
get "/chat/chat_channels/search.json", params: { filter: "andyjones" }
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["public_channels"].count).to eq(0)
|
|
expect(response.parsed_body["direct_message_channels"][0]["id"]).to eq(dm_chat_channel.id)
|
|
end
|
|
|
|
it "does not return DM channels for users who do not have chat enabled" do
|
|
admin.user_option.update!(chat_enabled: false)
|
|
get "/chat/chat_channels/search.json", params: { filter: "andyjones" }
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["direct_message_channels"].count).to eq(0)
|
|
end
|
|
|
|
it "does not return DM channels for users who are not in the chat allowed group" do
|
|
group = Fabricate(:group, name: "chatpeeps")
|
|
SiteSetting.chat_allowed_groups = group.id
|
|
GroupUser.create(user: user, group: group)
|
|
dm_chat_channel_2 = Fabricate(:direct_message_channel, users: [user, other_user])
|
|
|
|
get "/chat/chat_channels/search.json", params: { filter: "janemay" }
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["direct_message_channels"].count).to eq(0)
|
|
|
|
GroupUser.create(user: other_user, group: group)
|
|
get "/chat/chat_channels/search.json", params: { filter: "janemay" }
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["direct_message_channels"][0]["id"]).to eq(dm_chat_channel_2.id)
|
|
end
|
|
|
|
it "returns DM channels for staff users even if they are not in chat_allowed_groups" do
|
|
group = Fabricate(:group, name: "chatpeeps")
|
|
SiteSetting.chat_allowed_groups = group.id
|
|
GroupUser.create(user: user, group: group)
|
|
|
|
get "/chat/chat_channels/search.json", params: { filter: "andyjones" }
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["direct_message_channels"][0]["id"]).to eq(dm_chat_channel.id)
|
|
end
|
|
|
|
it "returns followed channels" do
|
|
Fabricate(
|
|
:user_chat_channel_membership,
|
|
user: user,
|
|
chat_channel: chat_channel,
|
|
following: true,
|
|
)
|
|
|
|
get "/chat/chat_channels/search.json", params: { filter: chat_channel.name }
|
|
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["public_channels"][0]["id"]).to eq(chat_channel.id)
|
|
end
|
|
|
|
it "returns not followed channels" do
|
|
Fabricate(
|
|
:user_chat_channel_membership,
|
|
user: user,
|
|
chat_channel: chat_channel,
|
|
following: false,
|
|
)
|
|
|
|
get "/chat/chat_channels/search.json", params: { filter: chat_channel.name }
|
|
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["public_channels"][0]["id"]).to eq(chat_channel.id)
|
|
end
|
|
end
|
|
end
|
|
|
|
describe "#show" do
|
|
fab!(:channel) do
|
|
Fabricate(:category_channel, chatable: category, name: "My Great Channel & Stuff")
|
|
end
|
|
|
|
it "can find channel by id" do
|
|
sign_in(user)
|
|
get "/chat/chat_channels/#{channel.id}.json"
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["id"]).to eq(channel.id)
|
|
end
|
|
|
|
it "can find channel by name" do
|
|
sign_in(user)
|
|
get "/chat/chat_channels/#{UrlHelper.encode_component("My Great Channel & Stuff")}.json"
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["id"]).to eq(channel.id)
|
|
end
|
|
|
|
it "can find channel by chatable title/name" do
|
|
sign_in(user)
|
|
|
|
channel.update!(chatable: Fabricate(:category, name: "Support Chat"))
|
|
get "/chat/chat_channels/#{UrlHelper.encode_component("Support Chat")}.json"
|
|
expect(response.status).to eq(200)
|
|
expect(response.parsed_body["id"]).to eq(channel.id)
|
|
end
|
|
|
|
it "gives a not found error if the channel cannot be found by name or id" do
|
|
channel.destroy
|
|
sign_in(user)
|
|
get "/chat/chat_channels/#{channel.id}.json"
|
|
expect(response.status).to eq(404)
|
|
get "/chat/chat_channels/#{UrlHelper.encode_component(channel.name)}.json"
|
|
expect(response.status).to eq(404)
|
|
end
|
|
end
|
|
|
|
describe "#archive" do
|
|
fab!(:channel) { Fabricate(:category_channel, chatable: category, name: "The English Channel") }
|
|
let(:new_topic_params) do
|
|
{ type: "newTopic", title: "This is a test archive topic", category_id: category.id }
|
|
end
|
|
let(:existing_topic_params) { { type: "existingTopic", topic_id: Fabricate(:topic).id } }
|
|
|
|
it "returns error if user is not staff" do
|
|
sign_in(user)
|
|
put "/chat/chat_channels/#{channel.id}/archive.json", params: new_topic_params
|
|
expect(response.status).to eq(403)
|
|
end
|
|
|
|
it "returns error if type or chat_channel_id is not provided" do
|
|
sign_in(admin)
|
|
put "/chat/chat_channels/#{channel.id}/archive.json", params: {}
|
|
expect(response.status).to eq(400)
|
|
end
|
|
|
|
it "returns error if title is not provided for new topic" do
|
|
sign_in(admin)
|
|
put "/chat/chat_channels/#{channel.id}/archive.json", params: { type: "newTopic" }
|
|
expect(response.status).to eq(400)
|
|
end
|
|
|
|
it "returns error if topic_id is not provided for existing topic" do
|
|
sign_in(admin)
|
|
put "/chat/chat_channels/#{channel.id}/archive.json", params: { type: "existingTopic" }
|
|
expect(response.status).to eq(400)
|
|
end
|
|
|
|
it "returns error if the channel cannot be archived" do
|
|
channel.update!(status: :archived)
|
|
sign_in(admin)
|
|
put "/chat/chat_channels/#{channel.id}/archive.json", params: new_topic_params
|
|
expect(response.status).to eq(403)
|
|
end
|
|
|
|
it "starts the archive process using a new topic" do
|
|
sign_in(admin)
|
|
put "/chat/chat_channels/#{channel.id}/archive.json", params: new_topic_params
|
|
channel_archive = ChatChannelArchive.find_by(chat_channel: channel)
|
|
expect(
|
|
job_enqueued?(
|
|
job: :chat_channel_archive,
|
|
args: {
|
|
chat_channel_archive_id: channel_archive.id,
|
|
},
|
|
),
|
|
).to eq(true)
|
|
expect(channel.reload.status).to eq("read_only")
|
|
end
|
|
|
|
it "starts the archive process using an existing topic" do
|
|
sign_in(admin)
|
|
put "/chat/chat_channels/#{channel.id}/archive.json", params: existing_topic_params
|
|
channel_archive = ChatChannelArchive.find_by(chat_channel: channel)
|
|
expect(
|
|
job_enqueued?(
|
|
job: :chat_channel_archive,
|
|
args: {
|
|
chat_channel_archive_id: channel_archive.id,
|
|
},
|
|
),
|
|
).to eq(true)
|
|
expect(channel.reload.status).to eq("read_only")
|
|
end
|
|
|
|
it "does nothing if the chat channel archive already exists" do
|
|
sign_in(admin)
|
|
put "/chat/chat_channels/#{channel.id}/archive.json", params: new_topic_params
|
|
expect(response.status).to eq(200)
|
|
expect {
|
|
put "/chat/chat_channels/#{channel.id}/archive.json", params: new_topic_params
|
|
}.not_to change { ChatChannelArchive.count }
|
|
end
|
|
end
|
|
|
|
describe "#retry_archive" do
|
|
fab!(:channel) do
|
|
Fabricate(
|
|
:category_channel,
|
|
chatable: category,
|
|
name: "The English Channel",
|
|
status: :read_only,
|
|
)
|
|
end
|
|
fab!(:archive) do
|
|
ChatChannelArchive.create!(
|
|
chat_channel: channel,
|
|
destination_topic_title: "test archive topic title",
|
|
archived_by: admin,
|
|
total_messages: 10,
|
|
)
|
|
end
|
|
|
|
it "returns error if user is not staff" do
|
|
sign_in(user)
|
|
put "/chat/chat_channels/#{channel.id}/retry_archive.json"
|
|
expect(response.status).to eq(403)
|
|
end
|
|
|
|
it "returns a 404 if the archive has not been started" do
|
|
archive.destroy
|
|
sign_in(admin)
|
|
put "/chat/chat_channels/#{channel.id}/retry_archive.json"
|
|
expect(response.status).to eq(404)
|
|
end
|
|
|
|
it "returns a 403 error if the archive is not currently failed" do
|
|
sign_in(admin)
|
|
archive.update!(archive_error: nil)
|
|
put "/chat/chat_channels/#{channel.id}/retry_archive.json"
|
|
expect(response.status).to eq(403)
|
|
end
|
|
|
|
it "returns a 403 error if the channel is not read_only" do
|
|
sign_in(admin)
|
|
archive.update!(archive_error: "bad stuff", archived_messages: 1)
|
|
channel.update!(status: "open")
|
|
put "/chat/chat_channels/#{channel.id}/retry_archive.json"
|
|
expect(response.status).to eq(403)
|
|
end
|
|
|
|
it "re-enqueues the archive job" do
|
|
sign_in(admin)
|
|
archive.update!(archive_error: "bad stuff", archived_messages: 1)
|
|
put "/chat/chat_channels/#{channel.id}/retry_archive.json"
|
|
expect(response.status).to eq(200)
|
|
expect(
|
|
job_enqueued?(job: :chat_channel_archive, args: { chat_channel_archive_id: archive.id }),
|
|
).to eq(true)
|
|
end
|
|
end
|
|
|
|
describe "#change_status" do
|
|
fab!(:channel) do
|
|
Fabricate(:category_channel, chatable: category, name: "Channel Orange", status: :open)
|
|
end
|
|
|
|
it "returns error if user is not staff" do
|
|
sign_in(user)
|
|
put "/chat/chat_channels/#{channel.id}/change_status.json", params: { status: "closed" }
|
|
expect(response.status).to eq(403)
|
|
end
|
|
|
|
it "returns a 404 if the channel does not exist" do
|
|
channel.destroy!
|
|
sign_in(admin)
|
|
put "/chat/chat_channels/#{channel.id}/change_status.json", params: { status: "closed" }
|
|
expect(response.status).to eq(404)
|
|
end
|
|
|
|
it "returns a 400 if the channel status is not closed or open" do
|
|
channel.update!(status: "read_only")
|
|
sign_in(admin)
|
|
put "/chat/chat_channels/#{channel.id}/change_status.json", params: { status: "closed" }
|
|
expect(response.status).to eq(403)
|
|
end
|
|
|
|
it "changes the channel to closed if it is open" do
|
|
sign_in(admin)
|
|
put "/chat/chat_channels/#{channel.id}/change_status.json", params: { status: "closed" }
|
|
expect(response.status).to eq(200)
|
|
expect(channel.reload.status).to eq("closed")
|
|
end
|
|
|
|
it "changes the channel to open if it is closed" do
|
|
channel.update!(status: "closed")
|
|
sign_in(admin)
|
|
put "/chat/chat_channels/#{channel.id}/change_status.json", params: { status: "open" }
|
|
expect(response.status).to eq(200)
|
|
expect(channel.reload.status).to eq("open")
|
|
end
|
|
end
|
|
|
|
describe "#delete" do
|
|
fab!(:channel) do
|
|
Fabricate(:category_channel, chatable: category, name: "Ambrose Channel", status: :open)
|
|
end
|
|
|
|
it "returns error if user is not staff" do
|
|
sign_in(user)
|
|
delete "/chat/chat_channels/#{channel.id}.json",
|
|
params: {
|
|
channel_name_confirmation: "ambrose channel",
|
|
}
|
|
expect(response.status).to eq(403)
|
|
end
|
|
|
|
it "returns a 404 if the channel does not exist" do
|
|
channel.destroy!
|
|
sign_in(admin)
|
|
delete "/chat/chat_channels/#{channel.id}.json",
|
|
params: {
|
|
channel_name_confirmation: "ambrose channel",
|
|
}
|
|
expect(response.status).to eq(404)
|
|
end
|
|
|
|
it "returns a 400 if the channel_name_confirmation does not match the channel name" do
|
|
sign_in(admin)
|
|
delete "/chat/chat_channels/#{channel.id}.json",
|
|
params: {
|
|
channel_name_confirmation: "some Other channel",
|
|
}
|
|
expect(response.status).to eq(400)
|
|
end
|
|
|
|
it "deletes the channel right away and enqueues the background job to delete all its chat messages and related content" do
|
|
sign_in(admin)
|
|
delete "/chat/chat_channels/#{channel.id}.json",
|
|
params: {
|
|
channel_name_confirmation: "ambrose channel",
|
|
}
|
|
expect(response.status).to eq(200)
|
|
expect(channel.reload.trashed?).to eq(true)
|
|
expect(job_enqueued?(job: :chat_channel_delete, args: { chat_channel_id: channel.id })).to eq(
|
|
true,
|
|
)
|
|
expect(
|
|
UserHistory.exists?(
|
|
acting_user_id: admin.id,
|
|
action: UserHistory.actions[:custom_staff],
|
|
custom_type: "chat_channel_delete",
|
|
),
|
|
).to eq(true)
|
|
end
|
|
end
|
|
end
|