TEST Removing all streaming for now 2

TEST

• Removing:
- all streaming for now 2 (from server side)

app/models/custom_filter.rb

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

app/services/fetch_link_card_service.rb

@@ -180,8 +180,8 @@ class FetchLinkCardService < BaseService
   end
 
   def send_status_update_payload(status)
-    @payload = InlineRenderer.render(status, nil, :status)
+    # @payload = InlineRenderer.render(status, nil, :status)
-    @payload = Oj.dump(event: :update, payload: @payload)
+    # @payload = Oj.dump(event: :update, payload: @payload)
-    Redis.current.publish("statuscard:#{status.account_id}", @payload)
+    # Redis.current.publish("statuscard:#{status.account_id}", @payload)
   end
 end

app/services/notify_service.rb

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

app/services/post_chat_message_service.rb

@@ -60,10 +60,10 @@ class PostChatMessageService < BaseService
           recipient.is_hidden = false
 
           # check if muting
-          unless recipient.is_muted
+          # unless recipient.is_muted
-            payload = InlineRenderer.render(@chat, recipient.account, :chat_message)
+          #   payload = InlineRenderer.render(@chat, recipient.account, :chat_message)
-            Redis.current.publish("chat_messages:#{recipient.account.id}", Oj.dump(event: :notification, payload: payload))
+          #   Redis.current.publish("chat_messages:#{recipient.account.id}", Oj.dump(event: :notification, payload: payload))
-          end
+          # end
         end
       else
         recipient.unread_count = 0

app/services/reblog_service.rb

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