FreakU
/
Retrospring
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

more fixes

This commit is contained in:
Yuki 2015-07-27 13:12:00 +05:30
parent bde8b64977
commit c846b963a4
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
app/workers/question_worker.rb
View File

@ -3,7 +3,7 @@ class QuestionWorker
sidekiq_options queue: :question, retry: false
# @param rcpt [Integer] string recipient
# @param rcpt [String] recipient
# @param user_id [Integer] user id passed from Devise
# @param question_id [Integer] newly created question id
def perform(rcpt, user_id, question_id)
@ -11,12 +11,14 @@ class QuestionWorker
user = User.find(user_id)
if rcpt == 'followers'
user.followers.each do |f|
Inbox.create(user_id: fid, question_id: question_id, new: true)
Inbox.create!(user_id: f.id, question_id: question_id, new: true)
end
elsif rcpt.start_with? 'grp:'
current_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)
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)
end
else
logger.info "unknown rcpt #{rcpt}"
end
rescue => e
logger.info "failed to ask question: #{e.message}"