diff options
Diffstat (limited to 'app/channels')
-rw-r--r-- | app/channels/application_cable/channel.rb | 22 | ||||
-rw-r--r-- | app/channels/application_cable/connection.rb | 22 | ||||
-rw-r--r-- | app/channels/hashtag_channel.rb | 13 | ||||
-rw-r--r-- | app/channels/public_channel.rb | 11 | ||||
-rw-r--r-- | app/channels/timeline_channel.rb | 7 |
5 files changed, 0 insertions, 75 deletions
diff --git a/app/channels/application_cable/channel.rb b/app/channels/application_cable/channel.rb deleted file mode 100644 index 344511cae..000000000 --- a/app/channels/application_cable/channel.rb +++ /dev/null @@ -1,22 +0,0 @@ -# frozen_string_literal: true - -module ApplicationCable - class Channel < ActionCable::Channel::Base - protected - - def hydrate_status(encoded_message) - message = Oj.load(encoded_message) - - return [nil, message] if message['event'] == 'delete' - - status_json = Oj.load(message['payload']) - status = Status.find(status_json['id']) - - [status, message] - end - - def filter?(status) - !status.nil? && FeedManager.instance.filter?(:public, status, current_user.account) - end - end -end diff --git a/app/channels/application_cable/connection.rb b/app/channels/application_cable/connection.rb deleted file mode 100644 index 33f9aa429..000000000 --- a/app/channels/application_cable/connection.rb +++ /dev/null @@ -1,22 +0,0 @@ -# frozen_string_literal: true - -module ApplicationCable - class Connection < ActionCable::Connection::Base - identified_by :current_user - - def connect - self.current_user = find_verified_user - end - - protected - - def find_verified_user - catch :warden do - verified_user = env['warden'].user - return verified_user if verified_user - end - - reject_unauthorized_connection - end - end -end diff --git a/app/channels/hashtag_channel.rb b/app/channels/hashtag_channel.rb deleted file mode 100644 index 4470a0e99..000000000 --- a/app/channels/hashtag_channel.rb +++ /dev/null @@ -1,13 +0,0 @@ -# frozen_string_literal: true - -class HashtagChannel < ApplicationCable::Channel - def subscribed - tag = params[:tag].downcase - - stream_from "timeline:hashtag:#{tag}", lambda { |encoded_message| - status, message = hydrate_status(encoded_message) - next if filter?(status) - transmit message - } - end -end diff --git a/app/channels/public_channel.rb b/app/channels/public_channel.rb deleted file mode 100644 index 9ef9e5dd7..000000000 --- a/app/channels/public_channel.rb +++ /dev/null @@ -1,11 +0,0 @@ -# frozen_string_literal: true - -class PublicChannel < ApplicationCable::Channel - def subscribed - stream_from 'timeline:public', lambda { |encoded_message| - status, message = hydrate_status(encoded_message) - next if filter?(status) - transmit message - } - end -end diff --git a/app/channels/timeline_channel.rb b/app/channels/timeline_channel.rb deleted file mode 100644 index 7b8d63ef5..000000000 --- a/app/channels/timeline_channel.rb +++ /dev/null @@ -1,7 +0,0 @@ -# frozen_string_literal: true - -class TimelineChannel < ApplicationCable::Channel - def subscribed - stream_from "timeline:#{current_user.account_id}" - end -end |