IntenseWebs/discourse
3
0
Fork 0
mirror of https://github.com/discourse/discourse.git synced 2025-02-25 18:55:32 -06:00
Code Issues Packages Projects Releases Wiki Activity

FIX: don't fail if dupe timings are sent in

Browse Source
This commit is contained in:
Sam 2015-05-06 17:33:03 +10:00
parent cea9cfe49f
commit 8dd4aa145c
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
app/models/post_timing.rb
View File

@ -40,13 +40,19 @@ class PostTiming < ActiveRecord::Base
if rows == 0 if rows == 0
exec_sql("INSERT INTO post_timings (topic_id, user_id, post_number, msecs) begin
exec_sql("INSERT INTO post_timings (topic_id, user_id, post_number, msecs)
SELECT :topic_id, :user_id, :post_number, :msecs SELECT :topic_id, :user_id, :post_number, :msecs
WHERE NOT EXISTS(SELECT 1 FROM post_timings WHERE NOT EXISTS(SELECT 1 FROM post_timings
WHERE topic_id = :topic_id WHERE topic_id = :topic_id
AND user_id = :user_id AND user_id = :user_id
AND post_number = :post_number)", AND post_number = :post_number)",
args) args)
rescue PG::UniqueViolation
# concurrency is hard, we are not running serialized so this can possibly
# still happen, if it happens we just don't care, its an invalid record anyway
return
end
Post.where(['topic_id = :topic_id and post_number = :post_number', args]).update_all 'reads = reads + 1' Post.where(['topic_id = :topic_id and post_number = :post_number', args]).update_all 'reads = reads + 1'
UserStat.where(user_id: args[:user_id]).update_all 'posts_read_count = posts_read_count + 1' UserStat.where(user_id: args[:user_id]).update_all 'posts_read_count = posts_read_count + 1'