From 0daab1ff64069a98b2491538d0d1885774427630 Mon Sep 17 00:00:00 2001 From: Axel Kittenberger Date: Sat, 13 Nov 2010 13:13:51 +0000 Subject: [PATCH] --- lsyncd.lua | 212 ++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 file changed, 210 insertions(+), 2 deletions(-) diff --git a/lsyncd.lua b/lsyncd.lua index 7a7db56..c23564a 100644 --- a/lsyncd.lua +++ b/lsyncd.lua @@ -1315,6 +1315,198 @@ local Inotifies = (function() end)() +------ +-- Writes functions for the user for layer 3 configuration. +-- +local functionWriter = (function() + + -- all variables for layer 3 + transVars = { + { "%^pathname", "event.pathname" , 1, }, + { "%^path", "event.path" , 1, }, + { "%^sourcePathname", "event.sourcePathname" , 1, }, + { "%^sourcePath", "event.sourcePath" , 1, }, + { "%^source", "event.source" , 1, }, + { "%^targetPathname", "event.targetPathname" , 1, }, + { "%^targetPath", "event.targetPath" , 1, }, + { "%^target", "event.target" , 1, }, + { "%^o%.pathname", "event.pathname" , 1, }, + { "%^o%.path", "event.path" , 1, }, + { "%^o%.sourcePathname", "event.sourcePathname" , 1, }, + { "%^o%.sourcePath", "event.sourcePath" , 1, }, + { "%^o%.targetPathname", "event.targetPathname" , 1, }, + { "%^o%.targetPath", "event.targetPath" , 1, }, + { "%^d%.pathname", "event2.pathname" , 2, }, + { "%^d%.path", "event2.path" , 2, }, + { "%^d%.sourcePathname", "event2.sourcePathname" , 2, }, + { "%^d%.sourcePath", "event2.sourcePath" , 2, }, + { "%^d%.targetPathname", "event2.targetPathname" , 2, }, + { "%^d%.targetPath", "event2.targetPath" , 2, }, + } + + ----- + -- Splits a user string into its arguments + -- + -- @param a string where parameters are seperated by spaces. + -- + -- @return a table of arguments + -- + local function splitStr(str) + local args = {} + while str ~= "" do + -- break where argument stops + local bp = #str + -- in a quote + local inQuote = false + -- tests characters to be space and not within quotes + for i=1,#str do + local c = string.sub(str, i, i) + if c == '"' then + inQuote = not inQuote + elseif c == ' ' and not inQuote then + bp = i - 1 + break + end + end + local arg = string.sub(str, 1, bp) + arg = string.gsub(arg, '"', '\\"') + table.insert(args, arg) + str = string.sub(str, bp + 1, -1) + str = string.match(str, "^%s*(.-)%s*$") + end + return args + end + + ----- + -- Translates a call to a binary to a lua function. + -- + -- TODO this has a little too much coding blocks. + -- + function translateBinary(str) + -- splits the string + local args = splitStr(str) + + -- true if there is a second event + local haveEvent2 = false + + for ia, iv in ipairs(args) do + -- a list of arguments this arg is split to + local a = {{true, iv}} + -- goes through all translates + for _, v in ipairs(transVars) do + ai = 1 + while ai <= #a do + if a[ai][1] then + local pre, post = + string.match(a[ai][2], "(.*)"..v[1].."(.*)") + if pre then + if pre ~= "" then + table.insert(a, ai, {true, pre}) + ai = ai + 1 + end + a[ai] = {false, v[2]} + if post ~= "" then + table.insert(a, ai + 1, {true, post}) + end + end + end + ai = ai + 1 + end + end + + local as = "" + local first = true + for _, v in ipairs(a) do + if not first then + as = as .. " .. " + end + if v[1] then + as = as .. '"' .. v[2] .. '"' + else + as = as .. v[2] + end + first = false + end + args[ia] = as + end + + local ft + if not haveEvent2 then + ft = "function(event)\n" + else + ft = "function(event, event2)\n" + end + ft = ft .. ' log("Normal", "Event " .. event.etype ..\n' + ft = ft .. " [[ spawns action '" .. str .. '\']])\n' + ft = ft .. " spawn(event" + for _, v in ipairs(args) do + ft = ft .. ",\n " .. v + end + ft = ft .. ")\nend" + return ft + end + + ----- + -- Translates a call using a shell to a lua function + -- + function translateShell(str) + local argn = 1 + local args = {} + local cmd = str + -- true if there is a second event + local haveEvent2 = false + + for _, v in ipairs(transVars) do + local occur = false + cmd = string.gsub(cmd, v[1], + function() occur = true; return '$'..argn end) + if occur then + argn = argn + 1 + table.insert(args, v[2]) + if v[3] > 1 then + haveEvent2 = true + end + end + end + local ft + if not haveEvent2 then + ft = "function(event)\n" + else + ft = "function(event, event2)\n" + end + ft = ft .. ' log("Normal", "Event " .. event.etype ..\n' + ft = ft .. " [[ spawns action '" .. str .. '\']])\n' + ft = ft .. " spawnShell(event, [[" .. cmd .. "]]" + for _, v in ipairs(args) do + ft = ft .. ",\n " .. v + end + ft = ft .. ")\nend" + return ft + end + + ----- + -- writes a lua function for a layer 3 user script. + function translate(str) + -- trim spaces + str = string.match(str, "^%s*(.-)%s*$") + + local ft + if string.byte(str, 1, 1) == 47 then + ft = translateBinary(str) + else + ft = translateShell(str) + end + log("FWrite","translated ",str," to ",ft) + return ft + end + + ----- + -- public interface + -- + return {translate = translate} +end() + + ---- -- Writes a status report file at most every [statusintervall] seconds. -- @@ -1515,7 +1707,7 @@ function runner.configure(args) -- TODO -- i = i + o[1] else - log("Error","unknown option command line option ", a) + log("Error","unknown option command line option ", args[i]) os.exit(-1) -- ERRNO end end @@ -1875,7 +2067,23 @@ default = { -- init = function(inlet) local config = inlet.getConfig() - -- creates a prior startup if configured + -- user functions + local ufuncs = { + "onAttrib", "onCreate", "onDelete", + "onModify", "onMove"} + -- checks if any user functions is a layer 3 string. + for _, fn in ipairs(funcs) do + if type(config[fn]) == 'string' then + local ft = functionWriter.translate(config[fn]) + config[fn] = loadstring("return" .. ft) + end + end + + if not config.action and not config.onAttrib and + not config.onCreate and not config.onModify and + not config.onDelete and not config.onMove + + -- calls a startup if given by user script. if type(config.onStartup) == "function" then local event = inlet.createBlanketEvent() local startup = config.onStartup(event)