aboutsummaryrefslogtreecommitdiffstats
path: root/lib/active_vault/site/mirror_site.rb
diff options
context:
space:
mode:
authorDavid Heinemeier Hansson <david@loudthinking.com>2017-07-05 18:57:45 +0200
committerDavid Heinemeier Hansson <david@loudthinking.com>2017-07-05 18:57:45 +0200
commitabda6d784eb0940b352cd28c28a3f3e87757a489 (patch)
treef33357d6db36f44b7e84fb06b6166b47902815b4 /lib/active_vault/site/mirror_site.rb
parent54886cb7b0754fb4c09febf1b70dd6eae48995cf (diff)
downloadrails-abda6d784eb0940b352cd28c28a3f3e87757a489.tar.gz
rails-abda6d784eb0940b352cd28c28a3f3e87757a489.tar.bz2
rails-abda6d784eb0940b352cd28c28a3f3e87757a489.zip
Basic MirrorSite
Still need to convert it to threading
Diffstat (limited to 'lib/active_vault/site/mirror_site.rb')
-rw-r--r--lib/active_vault/site/mirror_site.rb9
1 files changed, 6 insertions, 3 deletions
diff --git a/lib/active_vault/site/mirror_site.rb b/lib/active_vault/site/mirror_site.rb
index 67d79a2607..62b2f20586 100644
--- a/lib/active_vault/site/mirror_site.rb
+++ b/lib/active_vault/site/mirror_site.rb
@@ -6,7 +6,10 @@ class ActiveVault::Site::MirrorSite < ActiveVault::Site
end
def upload(key, io)
- perform_across_sites :upload, key, io
+ sites.collect do |site|
+ site.upload key, io
+ io.rewind
+ end
end
def download(key)
@@ -35,10 +38,10 @@ class ActiveVault::Site::MirrorSite < ActiveVault::Site
sites.first
end
- def perform_across_sites(method, **args)
+ def perform_across_sites(method, *args)
# FIXME: Convert to be threaded
sites.collect do |site|
- site.send method, **args
+ site.public_send method, *args
end
end
end