Add s3_buckets test

Create a new S3 bucket and test that it exists on each node.

Author: ian-mi

tests/s3_buckets.erl

@@ -0,0 +1,43 @@
+-module(s3_buckets).
+
+-behaviour(riak_test).
+
+-export([confirm/0]).
+
+-define(BUCKET, <<"bucket">>).
+-define(USER, "user").
+
+confirm() ->
+    Cluster = [Node1, _Node2] = rt:build_cluster(2),
+    prepare_s3(Cluster),
+    create_bucket(Node1),
+    lists:foreach(fun (Node) ->
+                          rt:wait_until(fun () -> verify_bucket(Node) end)
+                  end, Cluster),
+    pass.
+
+prepare_s3(Cluster) ->
+    rt:create_and_activate_bucket_type(hd(Cluster), <<"s3">>, []),
+    rt:wait_until_bucket_type_visible(Cluster, <<"s3">>).
+
+create_bucket(Node) ->
+    rpc:call(Node, riak_s3_bucket, create, [?BUCKET, ?USER]).
+
+verify_bucket(Node) ->
+    case rpc:call(Node, riak_s3_bucket, lookup, [?BUCKET]) of
+        not_found ->
+            not_found;
+        {error, Reason} ->
+            Reason;
+        Bucket ->
+            BucketName = riak_s3_bucket:get_name(Bucket),
+            User = riak_s3_bucket:get_user(Bucket),
+            if BucketName == ?BUCKET andalso  User == ?USER ->
+                    true;
+               BucketName /= ?BUCKET ->
+                    {incorrect_bucket_name, BucketName};
+               User /= ?USER ->
+                    {incorrect_user, User}
+            end
+    end.
+