about summary refs log tree commit diff
path: root/app/workers
diff options
context:
space:
mode:
authorEugen Rochko <eugen@zeonfederated.com>2016-09-29 21:28:21 +0200
committerEugen Rochko <eugen@zeonfederated.com>2016-09-29 21:28:21 +0200
commit927333f4f89403c5a6a2b421065112e517d88193 (patch)
tree1767e142ee9263b5b6968b5b43228ee0889232c5 /app/workers
parente4aebad35afae12f4b7503fb6c3783fcd3809761 (diff)
Improve code style
Diffstat (limited to 'app/workers')
-rw-r--r--app/workers/distribution_worker.rb2
-rw-r--r--app/workers/notification_worker.rb2
-rw-r--r--app/workers/thread_resolve_worker.rb2
3 files changed, 3 insertions, 3 deletions
diff --git a/app/workers/distribution_worker.rb b/app/workers/distribution_worker.rb
index d529ed87f..a69b39523 100644
--- a/app/workers/distribution_worker.rb
+++ b/app/workers/distribution_worker.rb
@@ -2,6 +2,6 @@ class DistributionWorker
   include Sidekiq::Worker
 
   def perform(status_id)
-    FanOutOnWriteService.new.(Status.find(status_id))
+    FanOutOnWriteService.new.call(Status.find(status_id))
   end
 end
diff --git a/app/workers/notification_worker.rb b/app/workers/notification_worker.rb
index 129512a5a..473a9232b 100644
--- a/app/workers/notification_worker.rb
+++ b/app/workers/notification_worker.rb
@@ -2,6 +2,6 @@ class NotificationWorker
   include Sidekiq::Worker
 
   def perform(stream_entry_id, target_account_id)
-    SendInteractionService.new.(StreamEntry.find(stream_entry_id), Account.find(target_account_id))
+    SendInteractionService.new.call(StreamEntry.find(stream_entry_id), Account.find(target_account_id))
   end
 end
diff --git a/app/workers/thread_resolve_worker.rb b/app/workers/thread_resolve_worker.rb
index ccc56380b..c59fb093a 100644
--- a/app/workers/thread_resolve_worker.rb
+++ b/app/workers/thread_resolve_worker.rb
@@ -3,7 +3,7 @@ class ThreadResolveWorker
 
   def perform(child_status_id, parent_url)
     child_status  = Status.find(child_status_id)
-    parent_status = FetchRemoteStatusService.new.(parent_url)
+    parent_status = FetchRemoteStatusService.new.call(parent_url)
 
     unless parent_status.nil?
       child_status.thread = parent_status