mirror of
https://github.com/discourse/discourse.git
synced 2024-11-27 09:50:23 +08:00
4d12bdfdcb
In some situations, these HTTP calls would cause some cache to warmup and send a `/distributed_hash` message-bus message. We can avoid tracking those by passing a specific channel name to `track_publish`.
221 lines
6.4 KiB
Ruby
221 lines
6.4 KiB
Ruby
# frozen_string_literal: true
|
||
|
||
RSpec.describe UserStatusController do
|
||
describe "#get" do
|
||
it "requires user to be logged in" do
|
||
get "/user-status.json"
|
||
expect(response.status).to eq(403)
|
||
end
|
||
|
||
it "returns 404 if the feature is disabled" do
|
||
user = Fabricate(:user)
|
||
sign_in(user)
|
||
SiteSetting.enable_user_status = false
|
||
|
||
get "/user-status.json"
|
||
|
||
expect(response.status).to eq(404)
|
||
end
|
||
|
||
describe "when feature is enabled and a user is logged in" do
|
||
fab!(:user) { Fabricate(:user) }
|
||
|
||
before do
|
||
sign_in(user)
|
||
SiteSetting.enable_user_status = true
|
||
end
|
||
|
||
it "returns user status" do
|
||
status = "off to dentist"
|
||
status_emoji = "tooth"
|
||
ends_at = "2100-01-01T18:00:00.000Z"
|
||
user.set_status!(status, status_emoji, DateTime.parse(ends_at))
|
||
|
||
get "/user-status.json"
|
||
|
||
expect(response.status).to eq(200)
|
||
expect(response.parsed_body["description"]).to eq(status)
|
||
expect(response.parsed_body["emoji"]).to eq(status_emoji)
|
||
expect(response.parsed_body["ends_at"]).to eq(ends_at)
|
||
end
|
||
end
|
||
end
|
||
|
||
describe "#set" do
|
||
it "requires user to be logged in" do
|
||
put "/user-status.json", params: { description: "off to dentist" }
|
||
expect(response.status).to eq(403)
|
||
end
|
||
|
||
it "returns 404 if the feature is disabled" do
|
||
user = Fabricate(:user)
|
||
sign_in(user)
|
||
SiteSetting.enable_user_status = false
|
||
|
||
put "/user-status.json", params: { description: "off" }
|
||
|
||
expect(response.status).to eq(404)
|
||
end
|
||
|
||
describe "feature is enabled and user is logged in" do
|
||
fab!(:user) { Fabricate(:user) }
|
||
|
||
before do
|
||
sign_in(user)
|
||
SiteSetting.enable_user_status = true
|
||
end
|
||
|
||
it "the description parameter is mandatory" do
|
||
put "/user-status.json", params: { emoji: "tooth" }
|
||
expect(response.status).to eq(400)
|
||
end
|
||
|
||
it "the emoji parameter is mandatory" do
|
||
put "/user-status.json", params: { description: "off to dentist" }
|
||
expect(response.status).to eq(400)
|
||
end
|
||
|
||
it "validates emoji" do
|
||
put "/user-status.json",
|
||
params: {
|
||
emoji: "invalid_emoji_name",
|
||
description: "off to dentist",
|
||
}
|
||
expect(response.status).to eq(422)
|
||
end
|
||
|
||
it "limits description’s length" do
|
||
put "/user-status.json",
|
||
params: {
|
||
emoji: "tooth",
|
||
description: "x" * UserStatus::MAX_DESCRIPTION_LENGTH,
|
||
}
|
||
expect(response.status).to eq(200)
|
||
|
||
put "/user-status.json",
|
||
params: {
|
||
emoji: "tooth",
|
||
description: "x" * (UserStatus::MAX_DESCRIPTION_LENGTH + 1),
|
||
}
|
||
expect(response.status).to eq(422)
|
||
end
|
||
|
||
it "sets user status" do
|
||
status = "off to dentist"
|
||
status_emoji = "tooth"
|
||
ends_at = DateTime.parse("2100-01-01 18:00")
|
||
|
||
put "/user-status.json",
|
||
params: {
|
||
description: status,
|
||
emoji: status_emoji,
|
||
ends_at: ends_at,
|
||
}
|
||
|
||
expect(response.status).to eq(200)
|
||
expect(user.user_status.description).to eq(status)
|
||
expect(user.user_status.emoji).to eq(status_emoji)
|
||
expect(user.user_status.ends_at).to eq_time(ends_at)
|
||
end
|
||
|
||
it "following calls update status" do
|
||
status = "off to dentist"
|
||
status_emoji = "tooth"
|
||
ends_at = DateTime.parse("2100-01-01 18:00")
|
||
put "/user-status.json",
|
||
params: {
|
||
description: status,
|
||
emoji: status_emoji,
|
||
ends_at: ends_at,
|
||
}
|
||
expect(response.status).to eq(200)
|
||
|
||
user.reload
|
||
expect(user.user_status.description).to eq(status)
|
||
expect(user.user_status.emoji).to eq(status_emoji)
|
||
expect(user.user_status.ends_at).to eq_time(ends_at)
|
||
|
||
new_status = "surfing"
|
||
new_status_emoji = "surfing_man"
|
||
new_ends_at = DateTime.parse("2100-01-01 18:59")
|
||
put "/user-status.json",
|
||
params: {
|
||
description: new_status,
|
||
emoji: new_status_emoji,
|
||
ends_at: new_ends_at,
|
||
}
|
||
expect(response.status).to eq(200)
|
||
|
||
user.reload
|
||
expect(user.user_status.description).to eq(new_status)
|
||
expect(user.user_status.emoji).to eq(new_status_emoji)
|
||
expect(user.user_status.ends_at).to eq_time(new_ends_at)
|
||
end
|
||
|
||
it "publishes to message bus" do
|
||
status = "off to dentist"
|
||
emoji = "tooth"
|
||
ends_at = "2100-01-01T18:00:00Z"
|
||
|
||
messages =
|
||
MessageBus.track_publish("/user-status") do
|
||
put "/user-status.json", params: { description: status, emoji: emoji, ends_at: ends_at }
|
||
end
|
||
|
||
expect(messages.map(&:channel)).to contain_exactly("/user-status")
|
||
expect(messages[0].channel).to eq("/user-status")
|
||
expect(messages[0].group_ids).to eq([Group::AUTO_GROUPS[:trust_level_0]])
|
||
|
||
expect(messages[0].data[user.id][:description]).to eq(status)
|
||
expect(messages[0].data[user.id][:emoji]).to eq(emoji)
|
||
expect(messages[0].data[user.id][:ends_at]).to eq(ends_at)
|
||
end
|
||
end
|
||
end
|
||
|
||
describe "#clear" do
|
||
it "requires you to be logged in" do
|
||
delete "/user-status.json"
|
||
expect(response.status).to eq(403)
|
||
end
|
||
|
||
it "returns 404 if the feature is disabled" do
|
||
user = Fabricate(:user)
|
||
sign_in(user)
|
||
SiteSetting.enable_user_status = false
|
||
|
||
delete "/user-status.json"
|
||
|
||
expect(response.status).to eq(404)
|
||
end
|
||
|
||
describe "feature is enabled and user is logged in" do
|
||
fab!(:user_status) { Fabricate(:user_status, description: "off to dentist") }
|
||
fab!(:user) { Fabricate(:user, user_status: user_status) }
|
||
|
||
before do
|
||
sign_in(user)
|
||
SiteSetting.enable_user_status = true
|
||
end
|
||
|
||
it "clears user status" do
|
||
delete "/user-status.json"
|
||
expect(response.status).to eq(200)
|
||
|
||
user.reload
|
||
expect(user.user_status).to be_nil
|
||
end
|
||
|
||
it "publishes to message bus" do
|
||
messages = MessageBus.track_publish("/user-status") { delete "/user-status.json" }
|
||
|
||
expect(messages.size).to eq(1)
|
||
expect(messages[0].channel).to eq("/user-status")
|
||
expect(messages[0].group_ids).to eq([Group::AUTO_GROUPS[:trust_level_0]])
|
||
|
||
expect(messages[0].data[user.id]).to eq(nil)
|
||
end
|
||
end
|
||
end
|
||
end
|