1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
|
# frozen_string_literal: true
# Redmine - project management software
# Copyright (C) 2006- Jean-Philippe Lang
#
# This program is free software; you can redistribute it and/or
# modify it under the terms of the GNU General Public License
# as published by the Free Software Foundation; either version 2
# of the License, or (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program; if not, write to the Free Software
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
require_relative '../test_helper'
class ReactionTest < ActiveSupport::TestCase
test 'validates :inclusion of reactable_type' do
%w(Issue Journal News Comment Message).each do |type|
reaction = Reaction.new(reactable_type: type, user: User.new)
assert reaction.valid?
end
assert_not Reaction.new(reactable_type: 'InvalidType', user: User.new).valid?
end
test 'scope: by' do
user2_reactions = issues(:issues_001).reactions.by(users(:users_002))
assert_equal [reactions(:reaction_002)], user2_reactions
end
test "should prevent duplicate reactions with unique constraint under concurrent creation" do
user = users(:users_001)
issue = issues(:issues_004)
threads = []
results = []
# Ensure both threads start at the same time
barrier = Concurrent::CyclicBarrier.new(2)
# Create two threads to simulate concurrent creation
2.times do
threads << Thread.new do
barrier.wait # Wait for both threads to be ready
begin
reaction = Reaction.create(
reactable: issue,
user: user
)
results << reaction.persisted?
rescue ActiveRecord::RecordNotUnique
results << false
end
end
end
# Wait for both threads to finish
threads.each(&:join)
# Ensure only one reaction was created
assert_equal 1, Reaction.where(reactable: issue, user: user).count
assert_includes results, true
assert_equal 1, results.count(true)
end
test 'build_detail_map_for generates a detail map for reactable objects' do
result = Reaction.build_detail_map_for([issues(:issues_001), issues(:issues_006)], users(:users_003))
expected = {
1 => Reaction::Detail.new(
reaction_count: 3,
visible_users: [users(:users_003), users(:users_002), users(:users_001)],
user_reaction: reactions(:reaction_003)
),
6 => Reaction::Detail.new(
reaction_count: 1,
visible_users: [users(:users_002)],
user_reaction: nil
)
}
assert_equal expected, result
# When an object have no reactions, the result should be empty.
result = Reaction.build_detail_map_for([journals(:journals_002)], users(:users_002))
assert_empty result
end
test 'build_detail_map_for filters users based on visibility' do
current_user = User.generate!
visible_user = users(:users_002)
non_visible_user = User.generate!
project = Project.generate!
role = Role.generate!(users_visibility: 'members_of_visible_projects')
User.add_to_project(current_user, project, role)
User.add_to_project(visible_user, project, roles(:roles_001))
issue = Issue.generate!(project: project)
[current_user, visible_user, non_visible_user].each do |user|
issue.reactions.create!(user: user)
end
result = Reaction.build_detail_map_for([issue], current_user)
assert_equal(
[current_user, visible_user].sort_by(&:id),
result[issue.id].visible_users.sort_by(&:id)
)
end
end
|
