Contents

=begin
    Copyright 2010-2022 Ecsypno <http://www.ecsypno.com>

    This file is part of the Arachni Framework project and is subject to
    redistribution and commercial restrictions. Please see the Arachni Framework
    web site for more information on licensing and terms of use.
=end

module Arachni
class Data
class Framework

# Data for {Arachni::RPC::Server::Framework}.
#
# @author Tasos "Zapotek" Laskos <[e-mail]>
class RPC

    # @return   [Support::Database::Queue]
    attr_reader :distributed_page_queue

    def initialize
        @distributed_page_queue = Support::Database::Queue.new
    end

    def statistics
        { distributed_page_queue: @distributed_page_queue.size }
    end

    def dump( directory )
        FileUtils.mkdir_p( directory )

        page_queue_directory = "#{directory}/distributed_page_queue/"

        FileUtils.rm_rf( page_queue_directory )
        FileUtils.mkdir_p( page_queue_directory )

        distributed_page_queue.buffer.each do |page|
            IO.binwrite(
                "#{page_queue_directory}/#{page.persistent_hash}",
                distributed_page_queue.serialize( page )
            )
        end

        distributed_page_queue.disk.each do |filepath|
            FileUtils.cp filepath, "#{page_queue_directory}/"
        end
    end

    def self.load( directory )
        rpc = new

        Dir["#{directory}/distributed_page_queue/*"].each do |page_file|
            rpc.distributed_page_queue.disk << page_file
        end

        rpc
    end

    def clear
        @distributed_page_queue.clear
    end

end

end
end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
arachni-1.6.1.3	lib/arachni/data/framework/rpc.rb
arachni-1.6.1.2	lib/arachni/data/framework/rpc.rb
arachni-1.6.1.1	lib/arachni/data/framework/rpc.rb
arachni-1.6.1	lib/arachni/data/framework/rpc.rb
arachni-1.6.0	lib/arachni/data/framework/rpc.rb