Contents

#!/usr/bin/env ruby
# frozen_string_literal: true

require "bundler/setup"
require "wamp"

require "optparse"

options = { host: "127.0.0.1", port: 8080, realm: "realm1", directory: ".", app: "App" }
OptionParser.new do |opts|
  opts.banner = "Usage: xconn [options]"

  opts.on("-hHOST", "--host HOST", "WebSocket host (default: ws://127.0.0.1:8080/ws)") do |host|
    options[:host] = host
  end

  opts.on("-rREALM", "--realm REALM", "Realm (default: reaml1)") do |realm|
    options[:realm] = realm
  end

  opts.on("-pPORT", "--port PORT", "Port (default: 8080)") do |port|
    options[:port] = port
  end

  opts.on("-dDIRECTORY", "--directory DIRECTORY", 'Directory (default: ".")') do |directory|
    options[:directory] = directory
  end

  opts.on("-aAPP", "--app APP", 'App (default: "App")') do |app|
    options[:app] = app
  end

  opts.on("-v", "--version", "Gem Version") do |version|
    options[:version] = version
  end
end.parse!

if options.include?(:version)
  puts "Xconn v#{Wamp::VERSION}"
  exit 0
end

def create_client_session(router)
  session = Wamp::Connection::Session.new

  server_session = Wamp::Router::Client.new
  server_session.router = router
  server_session.connection = session

  session.stream = server_session
  session
end

router = Wamp::Router::Base.new
router.add_realm(options.fetch(:realm))

client = create_client_session(router).tap(&:on_open)

begin
  Pathname.new(options[:directory]).glob("**/*.rb").each { |file| require file.to_s }
rescue LoadError => e
  puts e.message
  exit 1
end

begin
  app = Object.const_get(options[:app])
  app.new.procedures.each do |procedure, func|
    client.api.register(procedure, func) do
      puts "Registered procedure: #{procedure}"
    end
  end
rescue StandardError => e
  puts e.message
  exit 1
end

server = Wamp::Router::Server.new(router, options)
server.run

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
xconn-0.1.2	bin/xconn
xconn-0.1.1	bin/xconn
xconn-0.1.0	bin/xconn