rename ACF2 to Alpine Configurator (aconf)

1 files changed, 107 insertions, 0 deletions

diff --git a/aconf/persistence/backends/files.lua b/aconf/persistence/backends/files.lua
new file mode 100644
index 0000000..e19763d
--- /dev/null
+++ b/aconf/persistence/backends/files.lua
@@ -0,0 +1,107 @@
+--[[
+Copyright (c) 2012-2014 Kaarle Ritvanen
+See LICENSE file for license details
+--]]
+
+local topology = require('aconf.model.root').topology
+local pth = require('aconf.path')
+local util = require('aconf.persistence.util')
+local copy = require('aconf.util').copy
+
+local posix = require('posix')
+local stringy = require('stringy')
+
+
+local function get_scope(top)
+   if not top or top.type ~= 'reference' or not pth.is_unique(top.scope) then
+      return
+   end
+
+   return stringy.startswith(
+      top.scope, '/files/'
+   ) and top.scope:sub(7, -1) or nil
+end
+
+
+local backend = require('aconf.object').class()
+
+-- TODO cache expiration
+function backend:init() self.cache = {} end
+
+function backend:get(path, top)
+   local name = pth.join('/', unpack(path))
+
+   if not self.cache[name] then
+      local t = posix.stat(name, 'type')
+      if not t then return end
+
+      if t == 'regular' then
+	 self.cache[name] = util.read_file(name)
+
+      elseif t == 'link' then
+	 -- TODO handle relative symlinks
+	 local target = posix.readlink(name)
+	 assert(target)
+
+	 local scope = get_scope(top)
+	 assert(scope)
+	 scope = scope..'/'
+
+	 local slen = scope:len()
+	 assert(target:sub(1, slen) == scope)
+	 return target:sub(slen + 1, -1)
+
+      elseif t == 'directory' then
+	 local res = {}
+	 for _, fname in ipairs(posix.dir(name)) do
+	    if not ({['.']=true, ['..']=true})[fname] then
+	       table.insert(res, pth.name(fname))
+	    end
+	 end
+	 return res
+
+      else error('Unsupported file type: '..name) end
+   end
+
+   return self.cache[name]
+end
+
+function backend:set(mods)
+   for _, mod in pairs(mods) do
+      local path, value = unpack(mod)
+      local name = pth.join('/', unpack(path))
+
+      if value == nil then
+	 print('DEL', name)
+
+	 local t = posix.stat(name, 'type')
+	 if t == 'directory' then
+	    assert(posix.rmdir(name))
+	 elseif t then assert(os.remove(name)) end
+
+	 self.cache[name] = nil
+
+      elseif type(value) == 'table' then
+	 assert(posix.mkdir(name))
+
+      else
+	 local scope = get_scope(topology('/files'..name))
+
+	 if scope then
+	    -- TODO use relative symlink
+	    os.remove(name)
+	    assert(posix.link(pth.to_absolute(value, scope), name, true))
+
+	 else
+	    local file = util.open_file(name, 'w')
+	    file:write(util.tostring(value))
+	    file:close()
+
+	    self.cache[name] = value
+	 end
+      end
+   end
+end
+
+
+return backend