TEST Removing all streaming for now 2

TEST

• Removing:
- all streaming for now 2 (from server side)
This commit is contained in:
mgabdev 2021-01-15 20:42:04 -05:00
parent 8313f4b11d
commit 574b45e04b
5 changed files with 10 additions and 10 deletions

View File

@ -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

View File

@ -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

View File

@ -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

View File

@ -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

View File

@ -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)