about summary refs log tree commit diff
path: root/app/services/process_mentions_service.rb
diff options
context:
space:
mode:
authorEugen Rochko <eugen@zeonfederated.com>2016-02-25 00:17:01 +0100
committerEugen Rochko <eugen@zeonfederated.com>2016-02-25 00:17:01 +0100
commit71fe24096c612996cb2a827c919a4c88ae1e3495 (patch)
treefb1deed15866b83f0ed1583c91bc4d6fcb432827 /app/services/process_mentions_service.rb
parent42eeecba3f334227c10533a065e238f51f6dee4c (diff)
Adding a Mention model, test stubs
Diffstat (limited to 'app/services/process_mentions_service.rb')
-rw-r--r--app/services/process_mentions_service.rb33
1 files changed, 33 insertions, 0 deletions
diff --git a/app/services/process_mentions_service.rb b/app/services/process_mentions_service.rb
new file mode 100644
index 000000000..93866666a
--- /dev/null
+++ b/app/services/process_mentions_service.rb
@@ -0,0 +1,33 @@
+class ProcessMentionsService < BaseService
+  # Scan status for mentions and fetch remote mentioned users, create
+  # local mention pointers, send Salmon notifications to mentioned
+  # remote users
+  # @param [Status] status
+  def call(status)
+    status.text.scan(Account::MENTION_RE).each do |match|
+      username, domain = match.first.split('@')
+      local_account = Account.find_by(username: username, domain: domain)
+
+      if local_account.nil?
+        local_account = follow_remote_account_service.("acct:#{match.first}")
+      end
+
+      local_account.mentions.first_or_create(status: status)
+    end
+
+    status.mentions.each do |mentioned_account|
+      next if mentioned_account.local?
+      send_interaction_service.(status.stream_entry, mentioned_account)
+    end
+  end
+
+  private
+
+  def follow_remote_account_service
+    @follow_remote_account_service ||= FollowRemoteAccountService.new
+  end
+
+  def send_interaction_service
+    @send_interaction_service ||= SendInteractionService.new
+  end
+end