@ -15,8 +15,6 @@
# visibility :integer default("public"), not null
# spoiler_text :text default(""), not null
# reply :boolean default(FALSE), not null
# favourites_count :integer default(0), not null
# reblogs_count :integer default(0), not null
# language :string
# conversation_id :bigint(8)
# local :boolean
@ -28,6 +26,8 @@
#
class Status < ApplicationRecord
self . cache_versioning = false
include Paginable
include Streamable
include Cacheable
@ -62,6 +62,7 @@ class Status < ApplicationRecord
has_one :notification , as : :activity , dependent : :destroy
has_one :stream_entry , as : :activity , inverse_of : :status
has_one :status_stat , inverse_of : :status
validates :uri , uniqueness : true , presence : true , unless : :local?
validates :text , presence : true , unless : - > { with_media? || reblog? }
@ -86,7 +87,25 @@ class Status < ApplicationRecord
scope :not_local_only , - > { where ( local_only : [ false , nil ] ) }
cache_associated :account , :application , :media_attachments , :conversation , :tags , :stream_entry , mentions : :account , reblog : [ :account , :application , :stream_entry , :tags , :media_attachments , :conversation , mentions : :account ] , thread : :account
cache_associated :account ,
:application ,
:media_attachments ,
:conversation ,
:status_stat ,
:tags ,
:stream_entry ,
mentions : :account ,
reblog : [
:account ,
:application ,
:stream_entry ,
:tags ,
:media_attachments ,
:conversation ,
:status_stat ,
mentions : :account ,
] ,
thread : :account
delegate :domain , to : :account , prefix : true
@ -180,6 +199,26 @@ class Status < ApplicationRecord
@marked_for_mass_destruction
end
def replies_count
status_stat & . replies_count || 0
end
def reblogs_count
status_stat & . reblogs_count || 0
end
def favourites_count
status_stat & . favourites_count || 0
end
def increment_count! ( key )
update_status_stat! ( key = > public_send ( key ) + 1 )
end
def decrement_count! ( key )
update_status_stat! ( key = > [ public_send ( key ) - 1 , 0 ] . max )
end
after_create :increment_counter_caches
after_destroy :decrement_counter_caches
@ -197,6 +236,10 @@ class Status < ApplicationRecord
before_validation :set_local
class << self
def cache_ids
left_outer_joins ( :status_stat ) . select ( 'statuses.id, greatest(statuses.updated_at, status_stats.updated_at) AS updated_at' )
end
def in_chosen_languages ( account )
where ( language : nil ) . or where ( language : account . chosen_languages )
end
@ -372,6 +415,11 @@ class Status < ApplicationRecord
private
def update_status_stat! ( attrs )
record = status_stat || build_status_stat
record . update ( attrs )
end
def store_uri
update_attribute ( :uri , ActivityPub :: TagManager . instance . uri_for ( self ) ) if uri . nil?
end
@ -434,13 +482,8 @@ class Status < ApplicationRecord
Account . where ( id : account_id ) . update_all ( 'statuses_count = COALESCE(statuses_count, 0) + 1' )
end
return unless reblog?
if association ( :reblog ) . loaded?
reblog . update_attribute ( :reblogs_count , reblog . reblogs_count + 1 )
else
Status . where ( id : reblog_of_id ) . update_all ( 'reblogs_count = COALESCE(reblogs_count, 0) + 1' )
end
reblog . increment_count! ( :reblogs_count ) if reblog?
thread . increment_count! ( :replies_count ) if in_reply_to_id . present? && ( public_visibility? || unlisted_visibility? )
end
def decrement_counter_caches
@ -452,12 +495,7 @@ class Status < ApplicationRecord
Account . where ( id : account_id ) . update_all ( 'statuses_count = GREATEST(COALESCE(statuses_count, 0) - 1, 0)' )
end
return unless reblog?
if association ( :reblog ) . loaded?
reblog . update_attribute ( :reblogs_count , [ reblog . reblogs_count - 1 , 0 ] . max )
else
Status . where ( id : reblog_of_id ) . update_all ( 'reblogs_count = GREATEST(COALESCE(reblogs_count, 0) - 1, 0)' )
end
reblog . decrement_count! ( :reblogs_count ) if reblog?
thread . decrement_count! ( :replies_count ) if in_reply_to_id . present? && ( public_visibility? || unlisted_visibility? )
end
end
Thibaut Girka
6 years ago