Revert streaming removals 2c8b4f7fb, 574b45e04, 8313f4b11

• Revert:
- streaming removals 2c8b4f7fb, 574b45e04, 8313f4b11

app/javascript/gabsocial/containers/gabsocial.js

@@ -109,9 +109,9 @@ export default class GabSocial extends React.PureComponent {
 
   componentDidMount() {
     if (!!me) {
-      // this.disconnect = store.dispatch(connectUserStream())
-      // store.dispatch(connectStatusUpdateStream())
-      // store.dispatch(connectChatMessagesStream(me))
+      this.disconnect = store.dispatch(connectUserStream())
+      store.dispatch(connectStatusUpdateStream())
+      store.dispatch(connectChatMessagesStream(me))
     }
 
     console.log('%cGab Social ', [

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

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_status_service.rb

@@ -118,7 +118,7 @@ class PostStatusService < BaseService
 
   def postprocess_status!
     LinkCrawlWorker.perform_async(@status.id)
-    # DistributionWorker.perform_async(@status.id)
+    DistributionWorker.perform_async(@status.id)
     ExpiringStatusWorker.perform_at(@status.expires_at, @status.id) if @status.expires_at && @account.is_pro
     PollExpirationNotifyWorker.perform_at(@status.poll.expires_at, @status.poll.id) if @status.poll
   end

app/services/reblog_service.rb

@@ -28,7 +28,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)