about summary refs log tree commit diff
path: root/app/channels
diff options
context:
space:
mode:
authorEugen Rochko <eugen@zeonfederated.com>2017-02-09 20:25:39 +0100
committerEugen Rochko <eugen@zeonfederated.com>2017-02-09 20:25:39 +0100
commit6331ed16e5953e3a006896c6df07b0f82cfd2350 (patch)
treeb1b03e90ccb2feddc65aaf689808658381118228 /app/channels
parentc424df5192f346dba5332a4b3a2de43b2f028e0c (diff)
Fix #614 - extra reply-boolean on statuses to account for cases when replied-to
status is not in the system at time of distribution; fix #607 - reset privacy
settings to defaults when cancelling replies
Diffstat (limited to 'app/channels')
-rw-r--r--app/channels/application_cable/channel.rb22
-rw-r--r--app/channels/application_cable/connection.rb22
-rw-r--r--app/channels/hashtag_channel.rb13
-rw-r--r--app/channels/public_channel.rb11
-rw-r--r--app/channels/timeline_channel.rb7
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