diff options
author | Eugen Rochko <eugen@zeonfederated.com> | 2016-11-09 19:16:27 +0100 |
---|---|---|
committer | Eugen Rochko <eugen@zeonfederated.com> | 2016-11-09 19:16:27 +0100 |
commit | c5e03a2e0d7eac132a5d62d1d7d523a6969697cc (patch) | |
tree | 64beb72b535d9375653e01af7cfd7e9da428421f | |
parent | 448ab18a201c902b4e7a1aa468c352c20d034989 (diff) |
Status removal is broadcast to public/hashtag timelines too
-rw-r--r-- | app/channels/application_cable/channel.rb | 7 | ||||
-rw-r--r-- | app/services/remove_status_service.rb | 12 |
2 files changed, 17 insertions, 2 deletions
diff --git a/app/channels/application_cable/channel.rb b/app/channels/application_cable/channel.rb index d27b058fb..43adadbd9 100644 --- a/app/channels/application_cable/channel.rb +++ b/app/channels/application_cable/channel.rb @@ -4,14 +4,17 @@ module ApplicationCable def hydrate_status(encoded_message) message = ActiveSupport::JSON.decode(encoded_message) - status = Status.find_by(id: message['id']) + + return [nil, message] if message['type'] == 'delete' + + status = Status.find_by(id: message['id']) message['message'] = FeedManager.instance.inline_render(current_user.account, status) [status, message] end def filter?(status) - status.nil? || current_user.account.blocking?(status.account) || (status.reblog? && current_user.account.blocking?(status.reblog.account)) + !status.nil? && (current_user.account.blocking?(status.account) || (status.reblog? && current_user.account.blocking?(status.reblog.account))) end end end diff --git a/app/services/remove_status_service.rb b/app/services/remove_status_service.rb index 0b78b131a..66fa1be18 100644 --- a/app/services/remove_status_service.rb +++ b/app/services/remove_status_service.rb @@ -4,6 +4,8 @@ class RemoveStatusService < BaseService remove_from_followers(status) remove_from_mentioned(status) remove_reblogs(status) + remove_from_hashtags(status) + remove_from_public(status) status.destroy! end @@ -49,6 +51,16 @@ class RemoveStatusService < BaseService FeedManager.instance.broadcast(receiver.id, type: 'delete', id: status.id) end + def remove_from_hashtags(status) + status.tags.each do |tag| + FeedManager.instance.broadcast("hashtag:#{tag.name}", type: 'delete', id: status.id) + end + end + + def remove_from_public(status) + FeedManager.instance.broadcast(:public, type: 'delete', id: status.id) + end + def redis $redis end |