Merge commit '3554c527954441fd924586a49c7d99a89101ac7e' into glitch-soc/merge-upstream

Conflicts:
- `app/controllers/authorize_interactions_controller.rb`:
  Small conflict due to our theming system.
- `streaming/index.js`:
  Upstream refactored part of the streaming server.
  We had some extra logic for handling local-only posts.
  Applied the refactor.

app/workers/push_conversation_worker.rb

@@ -9,7 +9,7 @@ class PushConversationWorker
     message      = InlineRenderer.render(conversation, conversation.account, :conversation)
     timeline_id  = "timeline:direct:#{conversation.account_id}"
 
-    redis.publish(timeline_id, Oj.dump(event: :conversation, payload: message, queued_at: (Time.now.to_f * 1000.0).to_i))
+    redis.publish(timeline_id, Oj.dump(event: :conversation, payload: message))
   rescue ActiveRecord::RecordNotFound
     true
   end

app/workers/push_encrypted_message_worker.rb

@@ -9,7 +9,7 @@ class PushEncryptedMessageWorker
     message           = InlineRenderer.render(encrypted_message, nil, :encrypted_message)
     timeline_id       = "timeline:#{encrypted_message.device.account_id}:#{encrypted_message.device.device_id}"
 
-    redis.publish(timeline_id, Oj.dump(event: :encrypted_message, payload: message, queued_at: (Time.now.to_f * 1000.0).to_i))
+    redis.publish(timeline_id, Oj.dump(event: :encrypted_message, payload: message))
   rescue ActiveRecord::RecordNotFound
     true
   end

app/workers/push_update_worker.rb

@@ -25,8 +25,7 @@ class PushUpdateWorker
   def message
     Oj.dump(
       event: update? ? :'status.update' : :update,
-      payload: @payload,
-      queued_at: (Time.now.to_f * 1000.0).to_i
+      payload: @payload
     )
   end
 

app/workers/scheduler/instance_refresh_scheduler.rb

@@ -7,5 +7,6 @@ class Scheduler::InstanceRefreshScheduler
 
   def perform
     Instance.refresh
+    InstancesIndex.import if Chewy.enabled?
   end
 end