mirror of https://github.com/octoleo/lsyncd.git
150 lines
3.2 KiB
Lua
150 lines
3.2 KiB
Lua
require( 'posix' )
|
|
dofile( 'tests/testlib.lua' )
|
|
|
|
cwriteln( '****************************************************************' )
|
|
cwriteln( ' Testing crontab (rsync)' )
|
|
cwriteln( '****************************************************************' )
|
|
|
|
local tdir, srcdir, trgdir = mktemps( )
|
|
local logfile = tdir .. "log"
|
|
local cfgfile = tdir .. "config.lua"
|
|
local range = 5
|
|
local log = {"-log", "all"}
|
|
|
|
writefile(cfgfile, [[
|
|
settings {
|
|
logfile = "]]..logfile..[[",
|
|
nodaemon = true,
|
|
}
|
|
|
|
sync {
|
|
default.rsync,
|
|
crontab = {
|
|
-- trigger full sync every 1 minute
|
|
"*/10 * * * * *",
|
|
},
|
|
source = "]]..srcdir..[[",
|
|
action = function (inlet)
|
|
local e = inlet.getEvent( );
|
|
print("inhibit action ".. e.path.. " = " .. e.etype);
|
|
if e.etype ~= "Full" then
|
|
inlet.discardEvent(e);
|
|
return;
|
|
end
|
|
return default.rsync.action(inlet);
|
|
end,
|
|
target = "]]..trgdir..[[",
|
|
delay = 2,
|
|
delete = true,
|
|
rsync = {
|
|
verbose = true,
|
|
inplace = true,
|
|
_extra = {
|
|
"-vv",
|
|
"--info=progress2"
|
|
}
|
|
},
|
|
filter = {
|
|
'- /xb**',
|
|
'+ /x**',
|
|
'- /**',
|
|
},
|
|
}
|
|
]])
|
|
|
|
-- writes all files
|
|
local function writefiles
|
|
( )
|
|
writefile( srcdir .. 'xbc', 'xbc' )
|
|
writefile( srcdir .. 'xcc', 'xcc' )
|
|
writefile( srcdir .. 'yaa', 'yaa' )
|
|
posix.mkdir( srcdir .. 'xbx' )
|
|
writefile( srcdir .. 'xbx/a', 'xbxa' )
|
|
posix.mkdir( srcdir .. 'xcx' )
|
|
writefile( srcdir .. 'xcx/x', 'xcxx' )
|
|
writefile( srcdir .. 'xda', 'xda', '700' )
|
|
writefile( srcdir .. 'xdb', 'xdb', '755' )
|
|
end
|
|
|
|
-- test all files
|
|
local function testfiles
|
|
( )
|
|
testfile( trgdir .. 'xbc', false )
|
|
testfile( trgdir .. 'xcc', true )
|
|
testfile( trgdir .. 'yaa', false )
|
|
testfile( trgdir .. 'xbx/a', false )
|
|
testfile( trgdir .. 'xcx/x', true )
|
|
testfile( trgdir .. 'xda', true )
|
|
testfile( trgdir .. 'xdb', true )
|
|
end
|
|
|
|
|
|
cwriteln( 'testing crontab' )
|
|
|
|
writefiles( )
|
|
|
|
cwriteln( 'starting Lsyncd' )
|
|
|
|
local pid = spawn( './lsyncd', cfgfile, '-log', 'all' )
|
|
|
|
cwriteln( 'waiting for Lsyncd to start' )
|
|
|
|
posix.sleep( 3 )
|
|
|
|
cwriteln( 'testing filters after startup' )
|
|
|
|
testfiles( )
|
|
|
|
cwriteln( 'ok, removing sources' )
|
|
|
|
if srcdir:sub( 1,4 ) ~= '/tmp'
|
|
then
|
|
-- just to make sure before rm -rf
|
|
cwriteln( 'exit before drama, srcdir is "', srcdir, '"' )
|
|
|
|
os.exit( 1 )
|
|
end
|
|
|
|
os.execute( 'rm -rf '..srcdir..'/*' )
|
|
|
|
cwriteln( 'waiting for Lsyncd to remove destination' )
|
|
|
|
posix.sleep( 20 )
|
|
|
|
local result, code = execute( 'diff -urN ' .. srcdir .. ' ' .. trgdir )
|
|
|
|
if result ~= 'exit' or code ~= 0
|
|
then
|
|
cwriteln( 'fail, target directory not empty!' )
|
|
posix.kill( pid )
|
|
|
|
os.exit( 1 )
|
|
end
|
|
|
|
cwriteln( 'writing files after startup' )
|
|
|
|
writefiles( )
|
|
|
|
cwriteln( 'waiting for Lsyncd to transmit changes' )
|
|
|
|
posix.sleep( 20 )
|
|
|
|
testfiles( )
|
|
|
|
cwriteln( 'killing started Lsyncd' )
|
|
|
|
posix.kill( pid )
|
|
local _, exitmsg, exitcode = posix.wait( pid )
|
|
|
|
cwriteln( 'Exitcode of Lsyncd = ', exitmsg, ' ', exitcode );
|
|
|
|
if exitcode == 143
|
|
then
|
|
cwriteln( 'OK' )
|
|
os.exit( 0 )
|
|
else
|
|
os.exit( 1 )
|
|
end
|
|
|
|
-- TODO remove temp
|