couchdbfs_lib.rb @@ -1,200 +1,24 @@ -require 'fusefs' -require 'rubygems' -require 'couchrest' +require 'couchdbfs_lib' -DEBUG = false #true - -class CouchdbDir - def initialize() - @db = CouchRest.database!("http://127.0.0.1:5984/couchfs") - create_view() - create_root() - end - - def create_view - @view = {} - @view['path'] = {'map' => "function(doc) { - if (doc['path']) { - if(doc['path'] == \"/\") - { - emit(doc['path'], null); - } - else - { - emit(doc['path'].replace(/\\/$/, \"\"), null); - } - } - }" - } - - @view['base_path'] = {'map' => "function(doc) { - if (doc['base_path']) { - if(doc['base_path'] == \"/\") - { - emit(doc['base_path'], null); - } - else - { - emit(doc['base_path'].replace(/\\/$/, \"\"), null); - } - } - }" - } - @db.save({ - "_id" => "_design/doc", - :views => @view - }) - end - - #create the root dir - def create_root - if @db.view("doc/path", :key => "/")['rows'].nitems == 0 - ret = {"path" => "/", "name" => "/", "files" => []} - @db.save(ret) - end - end - - def contents(path) - p "call:contents?(#{path})" if DEBUG - files = @db.view("doc/base_path", :key => path) - p files if DEBUG - ret = [] - files['rows'].each do |fil| - ret << @db.get(fil['id'])['name'] - end - return ret - end - def directory?(path) - dir = @db.view("doc/path", :key => path)['rows'] - if dir.nitems > 0 - return !@db.get(dir[0]['id']).key?("size") - else - return false - end - end - - def file?(path) - dir = @db.view("doc/path", :key => path)['rows'] - if dir.nitems > 0 - return @db.get(dir[0]['id']).key?("size") - else - return false - end +if (File.basename($0) == File.basename(__FILE__)) + if (ARGV.size < 1) + puts "Usage: #{$0} <directory> <options>" + exit end - def touch(path) - write_to(path, "") - end - def read_file(path) - ret = @db.view("doc/path", :key => path) - if ret['rows'].nitems > 0 - file = @db.get(ret['rows'][0]['id']) - if file.key?("size") - return @db.fetch_attachment(file["_id"], file["name"]) - end - end - return false - end - def size(path) - ret = @db.view("doc/path", :key => path) - if ret['rows'].nitems > 0 - file = @db.get(ret['rows'][0]['id']) - if file.key?("size") - return file["size"] - else - #directory - return 0 - end - end - return 0 - end + dirname, yamlfile = ARGV.shift, ARGV.shift - # File writing - def can_write?(path) - return @db.view("doc/path", :key => path)['rows'].nitems == 0 + unless File.directory?(dirname) + puts "Usage: #{dirname} is not a directory." + exit end - def write_to(path, body) - name = File.basename(path) - path_only = path.sub(/#{name}$/, "") - file = {"path" => path, "base_path" => path_only, "_attachments" => { name => {"data" => body}}, "name" => name, "size" => body.length, "type" => "f"} - @db.save(file) - end - # Delete a file - def can_delete?(path) - rows = @db.view("doc/path", :key => path)['rows'] - if rows.nitems > 0 - file = @db.get(rows[0]['id']) - if file.key?("size") - return true - end - end - false - end - def delete(path) - row = @db.view("doc/path", :key => path)['rows'] - if row.nitems > 0 - file = @db.get(row[0]['id']) - @db.delete(file) - end - end + root = CouchdbDir.new() - def can_mkdir?(path) - return @db.view("doc/path", :key => path)['rows'].nitems == 0 - end - def mkdir(path) - name = File.basename(path) - path_only = path.sub(/#{name}$/, "") - dir = {"path" => path, "base_path" => path_only, "name" => name} - @db.save(dir) - end + # Set the root FuseFS + FuseFS.set_root(root) - # rmdir - def can_rmdir?(path) - if path != "/" - if @db.view("doc/base_path", :key => path)['rows'].nitems == 0 - row = @db.view("doc/path", :key => path)['rows'] - if row.nitems > 0 - file = @db.get(row[0]['id']) - if !file.key?('size') - return true - end - end - end - end - return false - end - def rmdir(path) - ret = @db.view("doc/path", :key => path) - ret.each do |fil| - fil.destroy - end - end + FuseFS.mount_under(dirname, *ARGV) - def delete_db - @db.delete! - end + FuseFS.run # This doesn't return until we're unmounted. end - -#if (File.basename($0) == File.basename(__FILE__)) -# if (ARGV.size < 1) -# puts "Usage: #{$0} <directory> <options>" -# exit -# end -# -# dirname, yamlfile = ARGV.shift, ARGV.shift -# -# unless File.directory?(dirname) -# puts "Usage: #{dirname} is not a directory." -# exit -# end -# -# root = CouchdbDir.new() -# -# # Set the root FuseFS -# FuseFS.set_root(root) -# -# FuseFS.mount_under(dirname, *ARGV) -# -# FuseFS.run # This doesn't return until we're unmounted. -#end couchdbfs.rb @@ -1,5 +1,5 @@ require 'test/unit' -require 'couchdbfs' +require 'couchdbfs_lib' class TestCouchFs < Test::Unit::TestCase @@ -228,9 +228,15 @@ class TestCouchFs < Test::Unit::TestCase #17 def test_rmdir test_create_dir_with_file() + ret = @root.contents("/") + assert(ret.include?("dir_test1")) ret = @root.delete("/dir_test1/test3") ret = @root.delete("/dir_test1/test") - assert(!@root.rmdir?("/dir_test1")) + ret = @root.contents("/") + assert(ret.include?("dir_test1")) + ret = @root.rmdir("/dir_test1") + ret = @root.contents("/") + assert(!ret.include?("dir_test1")) end def teardown couchdbfs_test.rb 4d45a58c0e1fc01ddd50aaf828013cefbe749001 nik sacchi.nicola@gmail.com http://github.com/niky81/couchdbfs/commit/0f1fc175daece32d0b4b0bb16aaed9994d37fbc8 0f1fc175daece32d0b4b0bb16aaed9994d37fbc8 2009-03-02T04:58:33-08:00 2009-03-02T04:58:33-08:00 not working 3046a98a2b9c5184bd12d5e4008591abb8dea1c7 nik sacchi.nicola@gmail.com