specter/mastodon
1
0
Fork 0
forked from fedi/mastodon
Code Pull requests Activity

Fix live status removal from public/hashtag channels

Browse source
This commit is contained in:
Eugen Rochko 2016-11-10 00:47:47 +01:00
parent aabf884c5f
commit bf5f55a6bb
3 changed files with 22 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
app/assets/javascripts/components/features/hashtag_timeline/index.jsx
View file

@ -4,7 +4,8 @@ import StatusListContainer from '../ui/containers/status_list_container';
import Column from '../ui/components/column'; import Column from '../ui/components/column';
import { import {
refreshTimeline, refreshTimeline,
updateTimeline updateTimeline,
deleteFromTimelines
} from '../../actions/timelines'; } from '../../actions/timelines';
const HashtagTimeline = React.createClass({ const HashtagTimeline = React.createClass({
@ -24,7 +25,12 @@ const HashtagTimeline = React.createClass({
}, { }, {
received (data) { received (data) {
dispatch(updateTimeline('tag', JSON.parse(data.message))); switch(data.type) {
case 'update':
return dispatch(updateTimeline('tag', JSON.parse(data.message)));
case 'delete':
return dispatch(deleteFromTimelines(data.id));
}
} }
}); });

10
app/assets/javascripts/components/features/public_timeline/index.jsx
View file

@ -4,7 +4,8 @@ import StatusListContainer from '../ui/containers/status_list_container';
import Column from '../ui/components/column'; import Column from '../ui/components/column';
import { import {
refreshTimeline, refreshTimeline,
updateTimeline updateTimeline,
deleteFromTimelines
} from '../../actions/timelines'; } from '../../actions/timelines';
const PublicTimeline = React.createClass({ const PublicTimeline = React.createClass({
@ -24,7 +25,12 @@ const PublicTimeline = React.createClass({
this.subscription = App.cable.subscriptions.create('PublicChannel', { this.subscription = App.cable.subscriptions.create('PublicChannel', {
received (data) { received (data) {
dispatch(updateTimeline('public', JSON.parse(data.message))); switch(data.type) {
case 'update':
return dispatch(updateTimeline('public', JSON.parse(data.message)));
case 'delete':
return dispatch(deleteFromTimelines(data.id));
}
} }
}); });

4
app/services/fan_out_on_write_service.rb
View file

@ -42,12 +42,12 @@ class FanOutOnWriteService < BaseService
Rails.logger.debug "Delivering status #{status.id} to hashtags" Rails.logger.debug "Delivering status #{status.id} to hashtags"
status.tags.find_each do |tag| status.tags.find_each do |tag|
FeedManager.instance.broadcast("hashtag:#{tag.name}", id: status.id) FeedManager.instance.broadcast("hashtag:#{tag.name}", type: 'update', id: status.id)
end end
end end
def deliver_to_public(status) def deliver_to_public(status)
Rails.logger.debug "Delivering status #{status.id} to public timeline" Rails.logger.debug "Delivering status #{status.id} to public timeline"
FeedManager.instance.broadcast(:public, id: status.id) FeedManager.instance.broadcast(:public, type: 'update', id: status.id)
end end
end end