TEST Removing all streaming for now 2
TEST • Removing: - all streaming for now 2 (from server side)
This commit is contained in:
parent
8313f4b11d
commit
574b45e04b
@ -43,7 +43,7 @@ class CustomFilter < ApplicationRecord
|
||||
|
||||
def remove_cache
|
||||
Rails.cache.delete("filters:#{account_id}")
|
||||
Redis.current.publish("timeline:#{account_id}", Oj.dump(event: :filters_changed))
|
||||
# Redis.current.publish("timeline:#{account_id}", Oj.dump(event: :filters_changed))
|
||||
end
|
||||
|
||||
def context_must_be_valid
|
||||
|
@ -180,8 +180,8 @@ class FetchLinkCardService < BaseService
|
||||
end
|
||||
|
||||
def send_status_update_payload(status)
|
||||
@payload = InlineRenderer.render(status, nil, :status)
|
||||
@payload = Oj.dump(event: :update, payload: @payload)
|
||||
Redis.current.publish("statuscard:#{status.account_id}", @payload)
|
||||
# @payload = InlineRenderer.render(status, nil, :status)
|
||||
# @payload = Oj.dump(event: :update, payload: @payload)
|
||||
# Redis.current.publish("statuscard:#{status.account_id}", @payload)
|
||||
end
|
||||
end
|
||||
|
@ -92,7 +92,7 @@ class NotifyService < BaseService
|
||||
def push_notification!
|
||||
return if @notification.activity.nil?
|
||||
|
||||
Redis.current.publish("timeline:#{@recipient.id}", Oj.dump(event: :notification, payload: InlineRenderer.render(@notification, @recipient, :notification)))
|
||||
# Redis.current.publish("timeline:#{@recipient.id}", Oj.dump(event: :notification, payload: InlineRenderer.render(@notification, @recipient, :notification)))
|
||||
send_push_notifications!
|
||||
end
|
||||
|
||||
|
@ -60,10 +60,10 @@ class PostChatMessageService < BaseService
|
||||
recipient.is_hidden = false
|
||||
|
||||
# check if muting
|
||||
unless recipient.is_muted
|
||||
payload = InlineRenderer.render(@chat, recipient.account, :chat_message)
|
||||
Redis.current.publish("chat_messages:#{recipient.account.id}", Oj.dump(event: :notification, payload: payload))
|
||||
end
|
||||
# unless recipient.is_muted
|
||||
# payload = InlineRenderer.render(@chat, recipient.account, :chat_message)
|
||||
# Redis.current.publish("chat_messages:#{recipient.account.id}", Oj.dump(event: :notification, payload: payload))
|
||||
# end
|
||||
end
|
||||
else
|
||||
recipient.unread_count = 0
|
||||
|
@ -22,7 +22,7 @@ class ReblogService < BaseService
|
||||
text = options[:status] || ''
|
||||
reblog = account.statuses.create!(reblog: reblogged_status, text: text, visibility: visibility)
|
||||
|
||||
DistributionWorker.perform_async(reblog.id)
|
||||
# DistributionWorker.perform_async(reblog.id)
|
||||
|
||||
create_notification(reblog)
|
||||
bump_potential_friendship(account, reblog)
|
||||
|
Loading…
Reference in New Issue
Block a user