diff options
author | Benjamin Neff <benjamin@coding4coffee.ch> | 2022-06-29 14:28:02 +0300 |
---|---|---|
committer | Benjamin Neff <benjamin@coding4coffee.ch> | 2022-06-29 14:28:02 +0300 |
commit | 1b2270572b7de768d8e8a67cf0017a01a275f3c8 (patch) | |
tree | 47de0ca59d553662381d9aeede6360a5353c9222 /lib | |
parent | add707252a0514ddb49b6f62f60b8d9ab0193156 (diff) | |
parent | 739fc780c3b4cff075311e200b3639ad586ddf30 (diff) |
Merge branch 'next-minor' into develop
Diffstat (limited to 'lib')
-rw-r--r-- | lib/diaspora/federated/retraction.rb | 3 | ||||
-rw-r--r-- | lib/diaspora/federation/dispatcher.rb | 4 |
2 files changed, 4 insertions, 3 deletions
diff --git a/lib/diaspora/federated/retraction.rb b/lib/diaspora/federated/retraction.rb index b0ea20dbc..538ba7e9b 100644 --- a/lib/diaspora/federated/retraction.rb +++ b/lib/diaspora/federated/retraction.rb @@ -36,7 +36,8 @@ class Retraction def defer_dispatch(user, include_target_author=true) subscribers = dispatch_subscribers(include_target_author) - Workers::DeferredRetraction.perform_async(user.id, self.class.to_s, data, subscribers.map(&:id), service_opts(user)) + Workers::DeferredRetraction.perform_async(user.id, self.class.to_s, data.deep_stringify_keys, + subscribers.map(&:id), service_opts(user).deep_stringify_keys) end def perform diff --git a/lib/diaspora/federation/dispatcher.rb b/lib/diaspora/federation/dispatcher.rb index 4e03e725f..2ad441715 100644 --- a/lib/diaspora/federation/dispatcher.rb +++ b/lib/diaspora/federation/dispatcher.rb @@ -21,7 +21,7 @@ module Diaspora end def self.defer_dispatch(sender, object, opts={}) - Workers::DeferredDispatch.perform_async(sender.id, object.class.to_s, object.id, opts) + Workers::DeferredDispatch.perform_async(sender.id, object.class.to_s, object.id, opts.deep_stringify_keys) end def dispatch @@ -69,7 +69,7 @@ module Diaspora when StatusMessage each_service {|service| Workers::PostToService.perform_async(service.id, object.id, opts[:url]) } when Retraction - each_service {|service| Workers::DeletePostFromService.perform_async(service.id, opts) } + each_service {|service| Workers::DeletePostFromService.perform_async(service.id, opts.deep_stringify_keys) } end end |