lib/zold/node/journaled_pipeline.rb in zold-0.29.23 vs lib/zold/node/journaled_pipeline.rb in zold-0.29.24
- old
+ new
@@ -73,13 +73,13 @@
'dir': @dir
)
end
# Returns a list of modifed wallets (as Zold::Id)
- def push(id, body, wallets, log)
+ def push(id, body, wallets, log, lifetime: 6)
DirItems.new(@dir).fetch.each do |f|
f = File.join(@dir, f)
- File.delete(f) if File.mtime(f) < Time.now - 24 * 60 * 60
+ File.delete(f) if File.mtime(f) < Time.now - lifetime * 60 * 60
end
journal = File.join(@dir, "#{Time.now.utc.iso8601.gsub(/[^0-9]/, '-')}-#{id}")
jlog = Logger.new(journal)
jlog.level = Logger::DEBUG
jlog.formatter = Log::COMPACT