Class: Pact::V2::Provider::ProviderServerRunner

Inherits:
Object
  • Object
show all
Defined in:
lib/pact/v2/provider/provider_server_runner.rb

Constant Summary collapse

SETUP_PROVIDER_STATE_PATH = 
"/setup-provider"
VERIFY_MESSAGE_PATH = 
"/verify-message"

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(port: 9001, host: "127.0.0.1", logger: nil) ⇒ ProviderServerRunner 



14
15
16
17
18
19
20
21
22
23
24
 
# File 'lib/pact/v2/provider/provider_server_runner.rb', line 14

def initialize(port: 9001, host: "127.0.0.1", logger: nil)
  @host = host
  @port = port
  @provider_setup_states = {}
  @provider_teardown_states = {}
  @logger = logger || Logger.new($stdout)

  @state_servlet = ProviderStateServlet.new(logger: @logger)
  @message_servlet = MessageProviderServlet.new(logger: @logger)
  @thread = nil
end

Instance Attribute Details

#logger ⇒ Object (readonly)

Returns the value of attribute logger.



9
10
11
 
# File 'lib/pact/v2/provider/provider_server_runner.rb', line 9

def logger
  @logger
end

Instance Method Details

#add_message_handler(state_name, &block) ⇒ Object 



70
71
72
 
# File 'lib/pact/v2/provider/provider_server_runner.rb', line 70

def add_message_handler(state_name, &block)
  @message_servlet.add_message_handler(state_name, &block)
end

#add_setup_state(state_name, use_before_setup_hook = true, &block) ⇒ Object 



74
75
76
 
# File 'lib/pact/v2/provider/provider_server_runner.rb', line 74

def add_setup_state(state_name, use_before_setup_hook = true, &block)
  @state_servlet.add_setup_state(state_name, use_before_setup_hook, &block)
end

#add_teardown_state(state_name, use_after_teardown_hook = true, &block) ⇒ Object 



78
79
80
 
# File 'lib/pact/v2/provider/provider_server_runner.rb', line 78

def add_teardown_state(state_name, use_after_teardown_hook = true, &block)
  @state_servlet.add_teardown_state(state_name, use_after_teardown_hook, &block)
end

#message_setup_url ⇒ Object 



30
31
32
 
# File 'lib/pact/v2/provider/provider_server_runner.rb', line 30

def message_setup_url
  "http://#{@host}:#{@port}#{VERIFY_MESSAGE_PATH}"
end

#run ⇒ Object 



59
60
61
62
63
64
65
66
67
68
 
# File 'lib/pact/v2/provider/provider_server_runner.rb', line 59

def run
  start

  yield
rescue => e
  logger.fatal("FATAL ERROR: #{e.message} #{e.backtrace.join("\n")}")
  raise
ensure
  stop
end

#set_after_teardown_hook(&block) ⇒ Object 



86
87
88
 
# File 'lib/pact/v2/provider/provider_server_runner.rb', line 86

def set_after_teardown_hook(&block)
  @state_servlet.after_teardown(&block)
end

#set_before_setup_hook(&block) ⇒ Object 



82
83
84
 
# File 'lib/pact/v2/provider/provider_server_runner.rb', line 82

def set_before_setup_hook(&block)
  @state_servlet.before_setup(&block)
end

#start ⇒ Object 



34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
 
# File 'lib/pact/v2/provider/provider_server_runner.rb', line 34

def start
  raise "server already running, stop server before starting new one" if @thread

    @server = WEBrick::HTTPServer.new(
    { BindAddress: @host, Port: @port, Logger: @logger, AccessLog: [] },
    WEBrick::Config::HTTP
    )
  @server.mount(SETUP_PROVIDER_STATE_PATH, @state_servlet)
  @server.mount(VERIFY_MESSAGE_PATH, @message_servlet)

  @thread = Thread.new do
    @logger.debug "starting provider setup server"
    @server.start
  end
end

#state_setup_url ⇒ Object 



26
27
28
 
# File 'lib/pact/v2/provider/provider_server_runner.rb', line 26

def state_setup_url
  "http://#{@host}:#{@port}#{SETUP_PROVIDER_STATE_PATH}"
end

#stop ⇒ Object 



50
51
52
53
54
55
56
57
 
# File 'lib/pact/v2/provider/provider_server_runner.rb', line 50

def stop
  @logger.info("stopping provider setup server")

  @server&.shutdown
  @thread&.join

  @logger.info("provider setup server stopped")
end