mirror of
https://github.com/antos-rde/antos-backend.git
synced 2024-12-25 12:48:22 +01:00
store package cache in temporal file if unable to create cached file
All checks were successful
gitea-sync/antos-backend/pipeline/head This commit looks good
All checks were successful
gitea-sync/antos-backend/pipeline/head This commit looks good
This commit is contained in:
DanyLE
parent
8d1d91f054
commit
16cfeb6591
@ -1,119 +1,132 @@
|
||||
local packages={}
|
||||
local packages = {}
|
||||
local vfs = require("vfs")
|
||||
local uid = ulib.uid(SESSION.user)
|
||||
|
||||
packages._cache = function(y)
|
||||
local p = vfs.ospath(y)
|
||||
local f = io.open(p.."/packages.json", "w")
|
||||
local has_cache = false
|
||||
local i = 1
|
||||
local meta = {}
|
||||
if f then
|
||||
local files = vfs.readDir(y)
|
||||
for k,v in pairs(files) do
|
||||
if v.type == "dir" then
|
||||
local f1 = io.open(vfs.ospath(v.path.."/package.json"))
|
||||
if f1 then
|
||||
|
||||
local name = utils.basename(v.path)
|
||||
local mt = JSON.decodeString(f1:read("*all"))
|
||||
mt.path = v.path
|
||||
meta[i] ='"'..name..'":'..JSON.encode(mt)
|
||||
i = i+1
|
||||
f1:close()
|
||||
has_cache = true;
|
||||
end
|
||||
end
|
||||
end
|
||||
f:write(table.concat(meta, ","))
|
||||
f:close()
|
||||
if has_cache == false then
|
||||
ulib.delete(p.."/packages.json");
|
||||
end
|
||||
end
|
||||
local p = vfs.ospath(y)
|
||||
local file_path = p .. "/packages.json"
|
||||
local f = io.open(file_path, "w")
|
||||
local has_cache = false
|
||||
local i = 1
|
||||
local meta = {}
|
||||
|
||||
if not f then
|
||||
-- store it is temporal file
|
||||
file_path = string.format("%s/%s.packages.json",__api__.tmpdir, enc.sha1(p))
|
||||
f = io.open(file_path, "w")
|
||||
end
|
||||
if f then
|
||||
local files = vfs.readDir(y)
|
||||
for k, v in pairs(files) do
|
||||
if v.type == "dir" then
|
||||
local f1 = io.open(vfs.ospath(v.path .. "/package.json"))
|
||||
if f1 then
|
||||
|
||||
local name = utils.basename(v.path)
|
||||
local mt = JSON.decodeString(f1:read("*all"))
|
||||
mt.path = v.path
|
||||
meta[i] = '"' .. name .. '":' .. JSON.encode(mt)
|
||||
i = i + 1
|
||||
f1:close()
|
||||
has_cache = true;
|
||||
end
|
||||
end
|
||||
end
|
||||
f:write(table.concat(meta, ","))
|
||||
f:close()
|
||||
if has_cache == false then
|
||||
ulib.delete(file_path);
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
-- we will change this later
|
||||
packages.list = function(paths)
|
||||
std.json()
|
||||
std.t("{\"result\" : { ")
|
||||
local first = true
|
||||
--std.f(__ROOT__.."/system/packages.json")
|
||||
for k,v in pairs(paths) do
|
||||
local osp = vfs.ospath(v.."/packages.json")
|
||||
if ulib.exists(osp) == false then
|
||||
packages._cache(v)
|
||||
std.json()
|
||||
std.t("{\"result\" : { ")
|
||||
local first = true
|
||||
for k, v in pairs(paths) do
|
||||
local p = vfs.ospath(v)
|
||||
local f1 = p.."/packages.json"
|
||||
local f2 = string.format("%s/%s.packages.json",__api__.tmpdir, enc.sha1(p))
|
||||
|
||||
if not ulib.exists(f1) and not ulib.exists(f2) then
|
||||
packages._cache(v)
|
||||
end
|
||||
local osp = f1
|
||||
if not ulib.exists(osp) then
|
||||
osp = f2
|
||||
end
|
||||
if ulib.exists(osp) then
|
||||
if first == false then
|
||||
std.t(",")
|
||||
else
|
||||
first = false
|
||||
end
|
||||
std.f(osp)
|
||||
end
|
||||
end
|
||||
std.t("}, \"error\":false}")
|
||||
if ulib.exists(osp) then
|
||||
if first == false then
|
||||
std.t(",")
|
||||
else
|
||||
first = false
|
||||
end
|
||||
std.f(osp)
|
||||
end
|
||||
end
|
||||
std.t("}, \"error\":false}")
|
||||
end
|
||||
|
||||
-- generate the packages caches
|
||||
packages.cache = function(args)
|
||||
-- perform a packages caches
|
||||
for x,y in pairs(args.paths) do
|
||||
packages._cache(y)
|
||||
end
|
||||
result(true)
|
||||
-- perform a packages caches
|
||||
for x, y in pairs(args.paths) do
|
||||
packages._cache(y)
|
||||
end
|
||||
result(true)
|
||||
end
|
||||
-- install a function from zip file
|
||||
packages.install = function(args)
|
||||
local path = vfs.ospath(args.dest)
|
||||
local zip = vfs.ospath(args.zip)
|
||||
if(ulib.exists(path) == false) then
|
||||
-- create directory if not exist
|
||||
ulib.mkdir(path)
|
||||
-- change permission
|
||||
ulib.chown(path, uid.id, uid.gid)
|
||||
end
|
||||
-- extract the zip file to it
|
||||
if(ulib.unzip(zip, path)) then
|
||||
-- read metadata
|
||||
local meta = JSON.decodeFile(path.."/metadata.json")
|
||||
meta.path = args.dest
|
||||
meta.scope = "user"
|
||||
local f=io.open(path.."/package.json","w")
|
||||
if f then
|
||||
f:write(JSON.encode(meta))
|
||||
f:close()
|
||||
end
|
||||
result(true)
|
||||
else
|
||||
fail("Problem extracting zip file")
|
||||
end
|
||||
|
||||
local path = vfs.ospath(args.dest)
|
||||
local zip = vfs.ospath(args.zip)
|
||||
if (ulib.exists(path) == false) then
|
||||
-- create directory if not exist
|
||||
ulib.mkdir(path)
|
||||
-- change permission
|
||||
ulib.chown(path, uid.id, uid.gid)
|
||||
end
|
||||
-- extract the zip file to it
|
||||
if (ulib.unzip(zip, path)) then
|
||||
-- read metadata
|
||||
local meta = JSON.decodeFile(path .. "/metadata.json")
|
||||
meta.path = args.dest
|
||||
meta.scope = "user"
|
||||
local f = io.open(path .. "/package.json", "w")
|
||||
if f then
|
||||
f:write(JSON.encode(meta))
|
||||
f:close()
|
||||
end
|
||||
result(true)
|
||||
else
|
||||
fail("Problem extracting zip file")
|
||||
end
|
||||
|
||||
end
|
||||
-- uninstall the package
|
||||
packages.uninstall = function(path)
|
||||
local osf = vfs.ospath(path)
|
||||
if(osf and ulib.exists(osf) ) then
|
||||
--remove it
|
||||
ulib.delete(osf)
|
||||
result(true)
|
||||
else
|
||||
fail("Cannot find package")
|
||||
end
|
||||
local osf = vfs.ospath(path)
|
||||
if (osf and ulib.exists(osf)) then
|
||||
-- remove it
|
||||
ulib.delete(osf)
|
||||
result(true)
|
||||
else
|
||||
fail("Cannot find package")
|
||||
end
|
||||
end
|
||||
-- set user packages environment
|
||||
packages.init = function(paths)
|
||||
if(paths) then
|
||||
for k,v in pairs(paths) do
|
||||
local p = vfs.ospath(v)
|
||||
if p and (ulib.exists(p) == false) then
|
||||
ulib.mkdir(p)
|
||||
-- change permission
|
||||
ulib.chown(p, uid.id, uid.gid)
|
||||
end
|
||||
end
|
||||
end
|
||||
if (paths) then
|
||||
for k, v in pairs(paths) do
|
||||
local p = vfs.ospath(v)
|
||||
if p and (ulib.exists(p) == false) then
|
||||
ulib.mkdir(p)
|
||||
-- change permission
|
||||
ulib.chown(p, uid.id, uid.gid)
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
return packages
|
||||
return packages
|
||||
|
||||
13
libs/vfs.lua
13
libs/vfs.lua
@ -3,19 +3,24 @@ local vfs = {}
|
||||
vfs.ospath = function(path)
|
||||
local user = SESSION.user
|
||||
local prefix = string.match(path, "%a+:/")
|
||||
local os_path = nil
|
||||
if (prefix ~= nil) then
|
||||
local suffix = string.gsub(path, prefix, "")
|
||||
if prefix == "home:/" then
|
||||
return string.format(VFS_HOME, user) .. '/' .. suffix
|
||||
os_path = string.format(VFS_HOME, user) .. '/' .. suffix
|
||||
elseif prefix == "desktop:/" then
|
||||
return string.format(VFS_HOME, user) .. "/.desktop/" .. suffix
|
||||
os_path = string.format(VFS_HOME, user) .. "/.desktop/" .. suffix
|
||||
elseif prefix == "shared:/" then
|
||||
return require("shared").ospath(ulib.trim(suffix, "/"))
|
||||
os_path = require("shared").ospath(ulib.trim(suffix, "/"))
|
||||
elseif prefix == "os:/" then
|
||||
return WWW_ROOT .. "/" .. suffix
|
||||
os_path = WWW_ROOT .. "/" .. suffix
|
||||
else
|
||||
return nil
|
||||
end
|
||||
while os_path:match("//") do
|
||||
os_path = os_path:gsub("//","/")
|
||||
end
|
||||
return os_path
|
||||
else
|
||||
return nil;
|
||||
end
|
||||
|
||||
Loading…
Reference in New Issue
Block a user