BaseController:subclass( "VFSController", { registry = {}, models = {} } ) function VFSController:actionnotfound(...) return self:index(table.unpack({...})) end function VFSController:index(...) local api = { description = "This api handle file operations", actions = { ["/fileinfo"] = "Get file information", ["/exists"] = "Check if file exists", ["/delete"] = "Delete a file", ["/get"] = "Get a file content", ["/mkdir"] = "Create directory", ["/move"] = "Move file to a new destination", ["/publish"] = "Share a file to all users", ["/scandir"] = "List all files and folders", ["/write"] = "Write data to file", ["/shared"] = "Get shared file content" } } result(api) return false end function VFSController:fileinfo(...) auth_or_die("User unauthorized. Please login") local vfspath = (JSON.decodeString(REQUEST.json)).path local r, m = require("vfs").fileinfo(vfspath) if r then result(m) else fail(m) end return false end function VFSController:exists(...) auth_or_die("User unauthorized. Please login") local vfs = require("vfs") local rq = (JSON.decodeString(REQUEST.json)) if rq ~= nil then result(vfs.exists(rq.path)) else fail("Uknown request") end return false end function VFSController:delete(...) auth_or_die("User unauthorized. Please login") local vfs = require("vfs") local rq = (JSON.decodeString(REQUEST.json)) if rq ~= nil then local r, e = vfs.delete(rq.path) if r then result(r) else fail(e) end else fail("Uknown request") end return false end function VFSController:get(...) local args = {...} local uri = implode(args, "/") auth_or_die("User unauthorized. Please login") local vfsfile = utils.decodeURI(uri) local r, m = require("vfs").checkperm(vfsfile, "read") if r then std.sendFile(m) else fail(m) end return false end function VFSController:mkdir(...) auth_or_die("User unauthorized. Please login") local rq = (JSON.decodeString(REQUEST.json)) if rq ~= nil then local r, m = require("vfs").mkdir(rq.path) if r then result(r) else fail(m) end else fail("Uknown request") end return false end function VFSController:move(...) auth_or_die("User unauthorized. Please login") local rq = (JSON.decodeString(REQUEST.json)) if rq ~= nil then local r, m = require("vfs").move(rq.src, rq.dest) if r then result(r) else fail(m) end else fail("Uknown request") end return false end function VFSController:publish(...) auth_or_die("User unauthorized. Please login") local rq = (JSON.decodeString(REQUEST.json)) if rq ~= nil then local p = nil if rq.publish then p = require("vfs").ospath(rq.path) else p = require("shared").ospath(rq.path) end local user = SESSION.user local uid = ulib.uid(user) local st = ulib.file_stat(p) if uid.id ~= st.uid then die("Only the owner can share or unshare this file") end local entry = {sid = enc.sha1(p), user = SESSION.user, path = p, uid = uid.id} local db = require("dbmodel").get("sysdb", "shared", entry) if db == nil then die("Cannot get system database") end local cond = nil if rq.publish then cond = {where = {path = p}} local data = db:find(cond) if data == nil or data[0] == nil then -- insert entry db:insert(entry) end else cond = { where = {sid = rq.path}} db:delete(cond) end db:close() result(entry.sid) else fail("Uknown request") end return false end function VFSController:scandir(...) auth_or_die("User unauthorized. Please login") local rq = JSON.decodeString(REQUEST.json) local vfspath = rq.path local r = require("vfs").readDir(vfspath) if r == nil then fail("Resource not found: " .. rq.path) else --print(JSON.encode(readDir(ospath, vfspath))) result(r) end return false end function VFSController:upload(...) auth_or_die("User unauthorized. Please login") local vfs = require("vfs") --LOG_DEBUG("UPLOAD COMMAND: %s", JSON.encode(REQUEST)) if REQUEST and REQUEST.multipart and REQUEST.multipart.path then local r, m = require("vfs").upload(REQUEST.multipart.path) if r then result(r) else self:error(m) fail(m) end else fail("Invalid query") end return false end function VFSController:write(...) auth_or_die("User unauthorized. Please login") local rq = (JSON.decodeString(REQUEST.json)) if rq ~= nil then local r, m = require("vfs").write(rq.path, rq.data) if r then result(r) else fail(m) end else fail("Uknown request") end return false end function VFSController:shared(sid) require("shared").get(sid) end