Contents

require 'ap'
require_relative '../../lib/toq'

def pems_path
    File.expand_path( File.dirname( __FILE__ ) + '/../' )
end

def rpc_opts
    {
        host:       '127.0.0.1',
        port:       7331,
        token:      'superdupersecret',
        serializer: Marshal,
    }
end

def rpc_opts_with_socket
    opts = rpc_opts
    opts.delete( :host )
    opts.delete( :port )

    opts.merge( socket: '/tmp/toq-rpc-test' )
end

def rpc_opts_with_ssl_primitives
    rpc_opts.merge(
        port:     7332,
        ssl_ca:   pems_path + '/pems/cacert.pem',
        ssl_pkey: pems_path + '/pems/client/key.pem',
        ssl_cert: pems_path + '/pems/client/cert.pem'
    )
end

def rpc_opts_with_invalid_ssl_primitives
    rpc_opts_with_ssl_primitives.merge(
        ssl_pkey: pems_path + '/pems/client/foo-key.pem',
        ssl_cert: pems_path + '/pems/client/foo-cert.pem'
    )
end

def rpc_opts_with_mixed_ssl_primitives
    rpc_opts_with_ssl_primitives.merge(
        ssl_pkey: pems_path + '/pems/client/key.pem',
        ssl_cert: pems_path + '/pems/client/foo-cert.pem'
    )
end

module MyModule
    def in_module
        true
    end
end

class Parent
    include MyModule

    def foo( arg )
        arg
    end

    def in_parent
        true
    end
end

class Test < Parent

    def in_child
        true
    end

    def delay( arg, &block )
        Raktr.global.run_in_thread if !Raktr.global.running?
        Raktr.global.delay( 1 ) { block.call( arg ) }
    end

    def exception
        fail
    end

    def defer( arg, &block )
        Thread.new do
            block.call( arg )
        end
    end

    private

    def private_method
        true
    end
end

def start_server( opts, do_not_start = false )
    server = Toq::Server.new( opts )
    server.add_async_check { |method| method.parameters.flatten.include? :block }
    server.add_handler( 'test', Test.new )
    server.run if !do_not_start
    server
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
toq-0.1.0	spec/servers/server.rb