Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/diaspora/diaspora.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorBenjamin Neff <benjamin@coding4coffee.ch>2022-06-29 14:28:02 +0300
committerBenjamin Neff <benjamin@coding4coffee.ch>2022-06-29 14:28:02 +0300
commit1b2270572b7de768d8e8a67cf0017a01a275f3c8 (patch)
tree47de0ca59d553662381d9aeede6360a5353c9222 /lib
parentadd707252a0514ddb49b6f62f60b8d9ab0193156 (diff)
parent739fc780c3b4cff075311e200b3639ad586ddf30 (diff)
Merge branch 'next-minor' into develop
Diffstat (limited to 'lib')
-rw-r--r--lib/diaspora/federated/retraction.rb3
-rw-r--r--lib/diaspora/federation/dispatcher.rb4
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