430 lines
13 KiB
Ruby
430 lines
13 KiB
Ruby
require_relative "spec_helper"
|
|
|
|
describe "Directories" do
|
|
include Rack::Test::Methods
|
|
include RemoteStorage::Riak
|
|
|
|
before do
|
|
purge_all_buckets
|
|
|
|
auth = auth_bucket.new("jimmy:123")
|
|
auth.data = [":r", "documents:r", "tasks:rw"]
|
|
auth.store
|
|
|
|
header "Authorization", "Bearer 123"
|
|
end
|
|
|
|
describe "GET listing" do
|
|
before do
|
|
put "/jimmy/tasks/foo", "do the laundry"
|
|
put "/jimmy/tasks/http%3A%2F%2F5apps.com", "prettify design"
|
|
end
|
|
|
|
it "lists the objects with a timestamp of the last modification" do
|
|
get "/jimmy/tasks/"
|
|
|
|
last_response.status.must_equal 200
|
|
last_response.content_type.must_equal "application/json"
|
|
|
|
content = JSON.parse(last_response.body)
|
|
content.must_include "http%3A%2F%2F5apps.com"
|
|
content.must_include "foo"
|
|
content["foo"].must_be_kind_of Integer
|
|
content["foo"].to_s.length.must_equal 13
|
|
end
|
|
|
|
it "has a Last-Modifier header set" do
|
|
get "/jimmy/tasks/"
|
|
|
|
last_response.status.must_equal 200
|
|
last_response.headers["Last-Modified"].wont_be_nil
|
|
|
|
now = Time.now
|
|
last_modified = DateTime.parse(last_response.headers["Last-Modified"])
|
|
last_modified.year.must_equal now.year
|
|
last_modified.day.must_equal now.day
|
|
end
|
|
|
|
it "has CORS headers set" do
|
|
get "/jimmy/tasks/"
|
|
|
|
last_response.status.must_equal 200
|
|
last_response.headers["Access-Control-Allow-Origin"].must_equal "*"
|
|
last_response.headers["Access-Control-Allow-Methods"].must_equal "GET, PUT, DELETE"
|
|
last_response.headers["Access-Control-Allow-Headers"].must_equal "Authorization, Content-Type, Origin"
|
|
end
|
|
|
|
context "with sub-directories" do
|
|
before do
|
|
put "/jimmy/tasks/home/laundry", "do the laundry"
|
|
end
|
|
|
|
it "lists the containing objects as well as the direct sub-directories" do
|
|
get "/jimmy/tasks/"
|
|
|
|
last_response.status.must_equal 200
|
|
|
|
content = JSON.parse(last_response.body)
|
|
content.must_include "foo"
|
|
content.must_include "http%3A%2F%2F5apps.com"
|
|
content.must_include "home/"
|
|
content["home/"].must_be_kind_of Integer
|
|
content["home/"].to_s.length.must_equal 13
|
|
end
|
|
|
|
context "for a different user" do
|
|
before do
|
|
auth = auth_bucket.new("alice:321")
|
|
auth.data = [":r", "documents:r", "tasks:rw"]
|
|
auth.store
|
|
|
|
header "Authorization", "Bearer 321"
|
|
|
|
put "/alice/tasks/homework", "write an essay"
|
|
end
|
|
|
|
it "does not list the directories of jimmy" do
|
|
get "/alice/tasks/"
|
|
|
|
last_response.status.must_equal 200
|
|
|
|
content = JSON.parse(last_response.body)
|
|
content.wont_include "/"
|
|
content.wont_include "tasks/"
|
|
content.wont_include "home/"
|
|
content.must_include "homework"
|
|
end
|
|
end
|
|
|
|
context "sub-directories without objects" do
|
|
it "lists the direct sub-directories" do
|
|
put "/jimmy/tasks/private/projects/world-domination/start", "write a manifesto"
|
|
get "/jimmy/tasks/private/"
|
|
|
|
last_response.status.must_equal 200
|
|
|
|
content = JSON.parse(last_response.body)
|
|
content.must_include "projects/"
|
|
content["projects/"].must_be_kind_of Integer
|
|
content["projects/"].to_s.length.must_equal 13
|
|
end
|
|
|
|
it "updates the timestamps of the existing directory objects" do
|
|
directory = directory_bucket.new("jimmy:tasks")
|
|
directory.content_type = "text/plain"
|
|
directory.data = (2.seconds.ago.to_f * 1000).to_i
|
|
directory.store
|
|
|
|
put "/jimmy/tasks/private/projects/world-domination/start", "write a manifesto"
|
|
|
|
object = data_bucket.get("jimmy:tasks/private/projects/world-domination:start")
|
|
directory = directory_bucket.get("jimmy:tasks")
|
|
|
|
directory.data.to_i.must_equal object.meta['timestamp'][0].to_i
|
|
end
|
|
end
|
|
|
|
context "with binary data" do
|
|
context "charset given in content-type header" do
|
|
before do
|
|
header "Content-Type", "image/jpeg; charset=binary"
|
|
filename = File.join(File.expand_path(File.dirname(__FILE__)), "fixtures", "rockrule.jpeg")
|
|
@image = File.open(filename, "r").read
|
|
put "/jimmy/tasks/jaypeg.jpg", @image
|
|
end
|
|
|
|
it "lists the binary files" do
|
|
get "/jimmy/tasks/"
|
|
|
|
last_response.status.must_equal 200
|
|
|
|
content = JSON.parse(last_response.body)
|
|
content.must_include "jaypeg.jpg"
|
|
content["jaypeg.jpg"].must_be_kind_of Integer
|
|
content["jaypeg.jpg"].to_s.length.must_equal 13
|
|
end
|
|
end
|
|
|
|
context "no charset in content-type header" do
|
|
before do
|
|
header "Content-Type", "image/jpeg"
|
|
filename = File.join(File.expand_path(File.dirname(__FILE__)), "fixtures", "rockrule.jpeg")
|
|
@image = File.open(filename, "r").read
|
|
put "/jimmy/tasks/jaypeg.jpg", @image
|
|
end
|
|
|
|
it "lists the binary files" do
|
|
get "/jimmy/tasks/"
|
|
|
|
last_response.status.must_equal 200
|
|
|
|
content = JSON.parse(last_response.body)
|
|
content.must_include "jaypeg.jpg"
|
|
content["jaypeg.jpg"].must_be_kind_of Integer
|
|
content["jaypeg.jpg"].to_s.length.must_equal 13
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
context "for a sub-directory" do
|
|
before do
|
|
put "/jimmy/tasks/home/laundry", "do the laundry"
|
|
end
|
|
|
|
it "lists the objects with timestamp" do
|
|
get "/jimmy/tasks/home/"
|
|
|
|
last_response.status.must_equal 200
|
|
|
|
content = JSON.parse(last_response.body)
|
|
content.must_include "laundry"
|
|
content["laundry"].must_be_kind_of Integer
|
|
content["laundry"].to_s.length.must_equal 13
|
|
end
|
|
end
|
|
|
|
context "for an empty or absent directory" do
|
|
it "returns an empty listing" do
|
|
get "/jimmy/documents/notfound/"
|
|
|
|
last_response.status.must_equal 200
|
|
last_response.body.must_equal "{}"
|
|
end
|
|
end
|
|
|
|
context "for the root directory" do
|
|
before do
|
|
auth = auth_bucket.new("jimmy:123")
|
|
auth.data = [":rw"]
|
|
auth.store
|
|
|
|
put "/jimmy/root-1", "Put my root down"
|
|
put "/jimmy/root-2", "Back to the roots"
|
|
end
|
|
|
|
it "lists the containing objects and direct sub-directories" do
|
|
get "/jimmy/"
|
|
|
|
last_response.status.must_equal 200
|
|
|
|
content = JSON.parse(last_response.body)
|
|
content.must_include "root-1"
|
|
content.must_include "root-2"
|
|
content.must_include "tasks/"
|
|
content["tasks/"].must_be_kind_of Integer
|
|
content["tasks/"].to_s.length.must_equal 13
|
|
end
|
|
end
|
|
|
|
context "for the public directory" do
|
|
before do
|
|
auth = auth_bucket.new("jimmy:123")
|
|
auth.data = ["documents:r", "bookmarks:rw"]
|
|
auth.store
|
|
|
|
put "/jimmy/public/bookmarks/5apps", "http://5apps.com"
|
|
end
|
|
|
|
context "when authorized for the category" do
|
|
it "lists the files" do
|
|
get "/jimmy/public/bookmarks/"
|
|
|
|
last_response.status.must_equal 200
|
|
|
|
content = JSON.parse(last_response.body)
|
|
content.must_include "5apps"
|
|
end
|
|
end
|
|
|
|
context "when directly authorized for the public directory" do
|
|
before do
|
|
auth = auth_bucket.new("jimmy:123")
|
|
auth.data = ["documents:r", "public/bookmarks:rw"]
|
|
auth.store
|
|
end
|
|
|
|
it "lists the files" do
|
|
get "/jimmy/public/bookmarks/"
|
|
|
|
last_response.status.must_equal 200
|
|
|
|
content = JSON.parse(last_response.body)
|
|
content.must_include "5apps"
|
|
end
|
|
end
|
|
|
|
context "when not authorized" do
|
|
before do
|
|
auth_bucket.delete("jimmy:123")
|
|
end
|
|
|
|
it "does not allow a directory listing of the public root" do
|
|
get "/jimmy/public/"
|
|
|
|
last_response.status.must_equal 403
|
|
end
|
|
|
|
it "does not allow a directory listing of a sub-directory" do
|
|
get "/jimmy/public/bookmarks/"
|
|
|
|
last_response.status.must_equal 403
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
describe "directory object" do
|
|
describe "PUT file" do
|
|
context "no existing directory object" do
|
|
it "creates a new directory object" do
|
|
put "/jimmy/tasks/home/trash", "take out the trash"
|
|
|
|
object = data_bucket.get("jimmy:tasks/home:trash")
|
|
directory = directory_bucket.get("jimmy:tasks/home")
|
|
|
|
directory.data.wont_be_nil
|
|
directory.data.to_i.must_equal object.meta['timestamp'][0].to_i
|
|
end
|
|
|
|
it "sets the correct index for the directory object" do
|
|
put "/jimmy/tasks/home/trash", "take out the trash"
|
|
|
|
object = directory_bucket.get("jimmy:tasks/home")
|
|
object.indexes["directory_bin"].must_include "tasks"
|
|
end
|
|
|
|
it "creates directory objects for the parent directories" do
|
|
put "/jimmy/tasks/home/trash", "take out the trash"
|
|
|
|
object = directory_bucket.get("jimmy:tasks")
|
|
object.indexes["directory_bin"].must_include CGI.escape("/")
|
|
object.data.wont_be_nil
|
|
|
|
object = directory_bucket.get("jimmy:")
|
|
object.indexes["directory_bin"].must_be_empty
|
|
object.data.wont_be_nil
|
|
end
|
|
end
|
|
|
|
context "existing directory object" do
|
|
before do
|
|
directory = directory_bucket.new("jimmy:tasks/home")
|
|
directory.content_type = "text/plain"
|
|
directory.data = (2.seconds.ago.to_f * 1000).to_i
|
|
directory.store
|
|
end
|
|
|
|
it "updates the timestamp of the directory" do
|
|
put "/jimmy/tasks/home/trash", "take out the trash"
|
|
|
|
last_response.status.must_equal 200
|
|
|
|
object = data_bucket.get("jimmy:tasks/home:trash")
|
|
directory = directory_bucket.get("jimmy:tasks/home")
|
|
|
|
directory.data.to_i.must_equal object.meta['timestamp'][0].to_i
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
describe "OPTIONS listing" do
|
|
it "has CORS headers set" do
|
|
options "/jimmy/tasks/"
|
|
|
|
last_response.status.must_equal 200
|
|
|
|
last_response.headers["Access-Control-Allow-Origin"].must_equal "*"
|
|
last_response.headers["Access-Control-Allow-Methods"].must_equal "GET, PUT, DELETE"
|
|
last_response.headers["Access-Control-Allow-Headers"].must_equal "Authorization, Content-Type, Origin"
|
|
end
|
|
|
|
context "sub-directories" do
|
|
it "has CORS headers set" do
|
|
options "/jimmy/tasks/foo/bar/"
|
|
|
|
last_response.status.must_equal 200
|
|
|
|
last_response.headers["Access-Control-Allow-Origin"].must_equal "*"
|
|
last_response.headers["Access-Control-Allow-Methods"].must_equal "GET, PUT, DELETE"
|
|
last_response.headers["Access-Control-Allow-Headers"].must_equal "Authorization, Content-Type, Origin"
|
|
end
|
|
end
|
|
|
|
context "root directory" do
|
|
it "has CORS headers set" do
|
|
options "/jimmy/"
|
|
|
|
last_response.status.must_equal 200
|
|
|
|
last_response.headers["Access-Control-Allow-Origin"].must_equal "*"
|
|
last_response.headers["Access-Control-Allow-Methods"].must_equal "GET, PUT, DELETE"
|
|
last_response.headers["Access-Control-Allow-Headers"].must_equal "Authorization, Content-Type, Origin"
|
|
end
|
|
end
|
|
end
|
|
|
|
describe "DELETE file" do
|
|
context "last file in directory" do
|
|
before do
|
|
put "/jimmy/tasks/home/trash", "take out the trash"
|
|
end
|
|
|
|
it "deletes the directory objects for all empty parent directories" do
|
|
delete "/jimmy/tasks/home/trash"
|
|
|
|
last_response.status.must_equal 204
|
|
|
|
lambda {
|
|
directory_bucket.get("jimmy:tasks/home")
|
|
}.must_raise Riak::HTTPFailedRequest
|
|
|
|
lambda {
|
|
directory_bucket.get("jimmy:tasks")
|
|
}.must_raise Riak::HTTPFailedRequest
|
|
|
|
lambda {
|
|
directory_bucket.get("jimmy:")
|
|
}.must_raise Riak::HTTPFailedRequest
|
|
end
|
|
end
|
|
|
|
context "with additional files in directory" do
|
|
before do
|
|
put "/jimmy/tasks/home/trash", "take out the trash"
|
|
put "/jimmy/tasks/home/laundry/washing", "wash the clothes"
|
|
end
|
|
|
|
it "does not delete the directory objects for the parent directories" do
|
|
delete "/jimmy/tasks/home/trash"
|
|
|
|
directory_bucket.get("jimmy:tasks/home").wont_be_nil
|
|
directory_bucket.get("jimmy:tasks").wont_be_nil
|
|
directory_bucket.get("jimmy:").wont_be_nil
|
|
end
|
|
|
|
describe "timestamps" do
|
|
before do
|
|
@old_timestamp = (2.seconds.ago.to_f * 1000).to_i
|
|
|
|
["tasks/home", "tasks", ""].each do |dir|
|
|
directory = directory_bucket.get("jimmy:#{dir}")
|
|
directory.data = @old_timestamp.to_s
|
|
directory.store
|
|
end
|
|
end
|
|
|
|
it "updates the timestamp for the parent directories" do
|
|
delete "/jimmy/tasks/home/trash"
|
|
|
|
directory_bucket.get("jimmy:tasks/home").data.to_i.must_be :>, @old_timestamp
|
|
directory_bucket.get("jimmy:tasks").data.to_i.must_be :>, @old_timestamp
|
|
directory_bucket.get("jimmy:").data.to_i.must_be :>, @old_timestamp
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
end
|