lib/zold/node/async_entrance.rb in zold-0.20.1 vs lib/zold/node/async_entrance.rb in zold-0.20.2

- old
+ new

@@ -58,13 +58,17 @@ end def start raise 'Block must be given to start()' unless block_given? FileUtils.mkdir_p(@dir) - DirItems.new(@dir).fetch.select { |f| f =~ /^[0-9a-f]{16}-/ }.each do |f| + DirItems.new(@dir).fetch.each do |f| file = File.join(@dir, f) - id = f.split('-')[0] - @queue << { id: Id.new(id), file: file } + if /^[0-9a-f]{16}-/.match?(f) + id = f.split('-')[0] + @queue << { id: Id.new(id), file: file } + else + File.delete(file) + end end @log.info("#{@queue.size} wallets pre-loaded into async_entrace from #{@dir}") unless @queue.size.zero? @entrance.start do (0..@threads).map do |i| @pool.add do