mirror of
https://github.com/Retrospring/retrospring.git
synced 2025-03-21 02:27:47 +01:00
don't break loops
This commit is contained in:
parent
c846b963a4
commit
97ad1285fe
1 changed files with 2 additions and 2 deletions
|
@ -11,11 +11,11 @@ class QuestionWorker
|
||||||
user = User.find(user_id)
|
user = User.find(user_id)
|
||||||
if rcpt == 'followers'
|
if rcpt == 'followers'
|
||||||
user.followers.each do |f|
|
user.followers.each do |f|
|
||||||
Inbox.create!(user_id: f.id, question_id: question_id, new: true)
|
Inbox.create(user_id: f.id, question_id: question_id, new: true)
|
||||||
end
|
end
|
||||||
elsif rcpt.start_with? 'grp:'
|
elsif rcpt.start_with? 'grp:'
|
||||||
user.groups.find_by_name!(rcpt.sub 'grp:', '').members.each do |m|
|
user.groups.find_by_name!(rcpt.sub 'grp:', '').members.each do |m|
|
||||||
Inbox.create!(user_id: m.user.id, question_id: question_id, new: true)
|
Inbox.create(user_id: m.user.id, question_id: question_id, new: true)
|
||||||
end
|
end
|
||||||
else
|
else
|
||||||
logger.info "unknown rcpt #{rcpt}"
|
logger.info "unknown rcpt #{rcpt}"
|
||||||
|
|
Loading…
Reference in a new issue