From b12df5470fbe851a285f70796747e2d8bc07ae66 Mon Sep 17 00:00:00 2001
From: Garret Alfert <garret@5apps.com>
Date: Mon, 7 Oct 2013 15:23:09 +0200
Subject: [PATCH] Make sure that 'allow_mult' is false for all buckets

---
 lib/remote_storage/riak.rb | 30 +++++++++++++++++++++++++-----
 spec/spec_helper.rb        | 36 ++++++++++++++++++++++++++++--------
 2 files changed, 53 insertions(+), 13 deletions(-)

diff --git a/lib/remote_storage/riak.rb b/lib/remote_storage/riak.rb
index 3f806ef..250070e 100644
--- a/lib/remote_storage/riak.rb
+++ b/lib/remote_storage/riak.rb
@@ -393,23 +393,43 @@ module RemoteStorage
     end
 
     def data_bucket
-      @data_bucket ||= client.bucket(settings['buckets']['data'])
+      @data_bucket ||= begin
+                         bucket = client.bucket(settings['buckets']['data'])
+                         bucket.allow_mult = false
+                         bucket
+                       end
     end
 
     def directory_bucket
-      @directory_bucket ||= client.bucket(settings['buckets']['directories'])
+      @directory_bucket ||= begin
+                              bucket = client.bucket(settings['buckets']['directories'])
+                              bucket.allow_mult = false
+                              bucket
+                            end
     end
 
     def auth_bucket
-      @auth_bucket ||= client.bucket(settings['buckets']['authorizations'])
+      @auth_bucket ||= begin
+                         bucket = client.bucket(settings['buckets']['authorizations'])
+                         bucket.allow_mult = false
+                         bucket
+                       end
     end
 
     def binary_bucket
-      @binary_bucket ||= client.bucket(settings['buckets']['binaries'])
+      @binary_bucket ||= begin
+                           bucket = client.bucket(settings['buckets']['binaries'])
+                           bucket.allow_mult = false
+                           bucket
+                         end
     end
 
     def opslog_bucket
-      @opslog_bucket ||= client.bucket(settings['buckets']['opslog'])
+      @opslog_bucket ||= begin
+                           bucket = client.bucket(settings['buckets']['opslog'])
+                           bucket.allow_mult = false
+                           bucket
+                         end
     end
 
     def cs_client
diff --git a/spec/spec_helper.rb b/spec/spec_helper.rb
index 6730f55..03c5f41 100644
--- a/spec/spec_helper.rb
+++ b/spec/spec_helper.rb
@@ -38,23 +38,43 @@ if app.settings.riak
   end
 
   def data_bucket
-    @data_bucket ||= client.bucket(app.settings.riak['buckets']['data'])
-  end
-
-  def auth_bucket
-    @auth_bucket ||= client.bucket(app.settings.riak['buckets']['authorizations'])
+    @data_bucket ||= begin
+                       bucket = client.bucket(app.settings.riak['buckets']['data'])
+                       bucket.allow_mult = false
+                       bucket
+                     end
   end
 
   def directory_bucket
-    @directory_bucket ||= client.bucket(app.settings.riak['buckets']['directories'])
+    @directory_bucket ||= begin
+                            bucket = client.bucket(app.settings.riak['buckets']['directories'])
+                            bucket.allow_mult = false
+                            bucket
+                          end
+  end
+
+  def auth_bucket
+    @auth_bucket ||= begin
+                       bucket = client.bucket(app.settings.riak['buckets']['authorizations'])
+                       bucket.allow_mult = false
+                       bucket
+                     end
   end
 
   def binary_bucket
-    @binary_bucket ||= client.bucket(app.settings.riak['buckets']['binaries'])
+    @binary_bucket ||= begin
+                         bucket = client.bucket(app.settings.riak['buckets']['binaries'])
+                         bucket.allow_mult = false
+                         bucket
+                       end
   end
 
   def opslog_bucket
-    @opslog_bucket ||= client.bucket(app.settings.riak['buckets']['opslog'])
+    @opslog_bucket ||= begin
+                         bucket = client.bucket(app.settings.riak['buckets']['opslog'])
+                         bucket.allow_mult = false
+                         bucket
+                       end
   end
 
   def purge_all_buckets