require 'kraken-mobile/test_scenario'

def start_test_kraken_server_in_background(scenario:)
  @scenario_tags = scenario.source_tag_names
  DeviceProcess.notify_process_state(
    process_id: process_id(scenario: scenario),
    state: K::PROCESS_STATES[:ready_to_start]
  )

  Timeout.timeout(K::DEFAULT_START_TIMEOUT_SECONDS, RuntimeError) do
    sleep(1) until TestScenario.ready_to_start?
  end
end

def shutdown_test_kraken_server(scenario:)
  @scenario_tags = scenario.source_tag_names
  DeviceProcess.notify_process_state(
    process_id: process_id(scenario: scenario),
    state: K::PROCESS_STATES[:ready_to_finish]
  )

  Timeout.timeout(K::DEFAULT_FINISH_TIMEOUT_SECONDS, RuntimeError) do
    sleep(1) until TestScenario.ready_to_finish?
  end
end

private

def process_id(scenario:)
  scenario_tags = scenario.source_tag_names
  tag_process_id = scenario_tags.grep(/@user/).first
  tag_process_id.delete_prefix('@user')
end