diff options
| author | Benjamin Neff <benjamin@coding4coffee.ch> | 2016-05-18 04:24:58 +0300 |
|---|---|---|
| committer | Benjamin Neff <benjamin@coding4coffee.ch> | 2016-06-26 07:21:00 +0300 |
| commit | 596659a78fd129e60ba35079c477f1a15950e9cb (patch) | |
| tree | cb154a87804d74c43d754521158ae80cd5c6d1a2 /app/workers/deferred_dispatch.rb | |
| parent | 83f5662d629fd51d7966b42d958a8534034062ad (diff) | |
first structure of Diaspora::Federation::Dispatcher
Diffstat (limited to 'app/workers/deferred_dispatch.rb')
| -rw-r--r-- | app/workers/deferred_dispatch.rb | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/app/workers/deferred_dispatch.rb b/app/workers/deferred_dispatch.rb index fb5d4a311..50a70d4de 100644 --- a/app/workers/deferred_dispatch.rb +++ b/app/workers/deferred_dispatch.rb @@ -10,10 +10,8 @@ module Workers user = User.find(user_id) object = object_class_name.constantize.find(object_id) opts = HashWithIndifferentAccess.new(opts) - opts[:services] = user.services.where(type: opts.delete(:service_types)) - add_additional_subscribers(object, object_class_name, opts) - Postzord::Dispatcher.build(user, object, opts).post + Diaspora::Federation::Dispatcher.build(user, object, opts).dispatch rescue ActiveRecord::RecordNotFound # The target got deleted before the job was run end |