LumeWeb
/
filer
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Added stat support.

This commit is contained in:
Alan Kligman 2012-10-09 13:40:25 -04:00
parent 3ef1488691
commit 3daebb73ad
2 changed files with 43 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
examples/test.html
View File

@ -14,12 +14,10 @@ require.config({
require(["../../javascript-debug/debug", "src/filesystem"], function(debug, FileSystem) { require(["../../javascript-debug/debug", "src/filesystem"], function(debug, FileSystem) {
var fs = new FileSystem(undefined, true); var fs = new FileSystem(undefined, true);
// debug.log("filesystem state: ", fs.state);
fs.then(function(fs) { fs.then(function(fs) {
// debug.log("filesystem state: ", fs.state); fs.mkdir("/tmp");
var p = fs.mkdir("/tmp"); fs.stat("/tmp").then(function(result) {
p.then(function(e) { console.log(result);
fs.mkdir("/tmp");
}); });
}); });
}); });

53
src/filesystem.js
View File

@ -128,7 +128,8 @@ define(function(require) {
} }
var fs = this; var fs = this;
fs.OBJECT_STORE_NAME = "files"; var FILE_STORE_NAME = "files";
var METADATA_STORE_NAME = "metadata";
fs.name = name || "default"; fs.name = name || "default";
fs.pending = {}; fs.pending = {};
@ -177,20 +178,24 @@ define(function(require) {
updateState(); updateState();
var openRequest = new OpenDBRequest(indexedDB.open(name), function(e) { var openRequest = new OpenDBRequest(indexedDB.open(name), function(e) {
var db = fs.db = e.target.result; var db = fs.db = e.target.result;
if(db.objectStoreNames.contains("files")) { if(db.objectStoreNames.contains(METADATA_STORE_NAME)) {
db.deleteObjectStore("files"); db.deleteObjectStore(METADATA_STORE_NAME);
} }
var store = db.createObjectStore("files"); if(db.objectStoreNames.contains(FILE_STORE_NAME)) {
store.createIndex("parent", "parent", {unique: false}); db.deleteObjectStore(FILE_STORE_NAME);
store.createIndex("name", "name", {unique: true}); }
var metadata = db.createObjectStore(METADATA_STORE_NAME);
metadata.createIndex("parent", "parent", {unique: false});
metadata.createIndex("name", "name", {unique: true});
var files = db.createObjectStore(FILE_STORE_NAME);
format = true; format = true;
}); });
openRequest.then(function(e) { openRequest.then(function(e) {
fs.db = e.target.result; fs.db = e.target.result;
var db = fs.db; var db = fs.db;
var transaction = new Transaction(db, [fs.OBJECT_STORE_NAME], RW); var transaction = new Transaction(db, [METADATA_STORE_NAME], RW);
var store = transaction.objectStore(fs.OBJECT_STORE_NAME); var store = transaction.objectStore(METADATA_STORE_NAME);
if(format) { if(format) {
debug.info("format required"); debug.info("format required");
var clearRequest = new Request(store.clear()); var clearRequest = new Request(store.clear());
@ -207,8 +212,8 @@ define(function(require) {
var mkdir = this.mkdir = function mkdir(name, transaction) { var mkdir = this.mkdir = function mkdir(name, transaction) {
debug.info("mkdir invoked"); debug.info("mkdir invoked");
var deferred = when.defer(); var deferred = when.defer();
var transaction = transaction || new Transaction(fs.db, [this.OBJECT_STORE_NAME], RW); var transaction = transaction || new Transaction(fs.db, [METADATA_STORE_NAME], RW);
var store = transaction.objectStore(fs.OBJECT_STORE_NAME); var store = transaction.objectStore(METADATA_STORE_NAME);
var nameIndex = store.index("name"); var nameIndex = store.index("name");
var getRequest = new Request(nameIndex.get(name)); var getRequest = new Request(nameIndex.get(name));
@ -218,11 +223,12 @@ define(function(require) {
debug.info("mkdir error: PATH_EXISTS_ERR"); debug.info("mkdir error: PATH_EXISTS_ERR");
deferred.reject(new DirectoryError(DirectoryError.PATH_EXISTS_ERR)); deferred.reject(new DirectoryError(DirectoryError.PATH_EXISTS_ERR));
} else { } else {
var parent = dirname(name); var parent = ("/" === name) ? null : dirname(name);
parent = (name === parent) ? null : parent;
var directoryRequest = new Request(store.put({ var directoryRequest = new Request(store.put({
"parent": parent, "parent": parent,
"name": name "name": name,
"last-modified": Date.now(),
"content-type": "application/directory"
}, name)); }, name));
directoryRequest.then(function(e) { directoryRequest.then(function(e) {
debug.info("mkdir complete"); debug.info("mkdir complete");
@ -232,6 +238,27 @@ define(function(require) {
}); });
return deferred.promise; return deferred.promise;
}; };
var stat = this.stat = function stat(name, transaction) {
debug.info("stat invoked");
var deferred = when.defer();
var transaction = transaction || new Transaction(fs.db, [METADATA_STORE_NAME], RO);
var store = transaction.objectStore(METADATA_STORE_NAME);
var nameIndex = store.index("name");
var getRequest = new Request(nameIndex.get(name));
getRequest.then(function(e) {
var result = e.target.result;
if(!result) {
debug.info("stat error: MISSING_PATH_COMPONENT_ERR");
deferred.reject(new DirectoryError(DirectoryError.MISSING_PATH_COMPONENT_ERR));
} else {
debug.info("stat complete");
deferred.resolve(result);
}
});
return deferred.promise;
}
} }
FileSystem.READY = 0; FileSystem.READY = 0;
FileSystem.PENDING = 1; FileSystem.PENDING = 1;