Class: Specwrk::CLI::Watch

Inherits:

Dry::CLI::Command

• Object
• Dry::CLI::Command
• Specwrk::CLI::Watch

Defined in:

lib/specwrk/cli.rb

Instance Method Summary

• #call(count:, watchfile:, **args) ⇒ Object

Instance Method Details

#call(count:, watchfile:, **args) ⇒ Object

# File 'lib/specwrk/cli.rb', line 293

def call(count:, watchfile:, **args)
  $stdout.sync = true

  # nil this env var if it exists to prevent never-ending workers
  ENV["SPECWRK_SRV_URI"] = nil

  # Start on a random open port to not conflict with another server
  ENV["SPECWRK_SRV_PORT"] = find_open_port.to_s
  ENV["SPECWRK_SRV_URI"] = "http://localhost:#{ENV.fetch("SPECWRK_SRV_PORT", "5138")}"

  ENV["SPECWRK_SEED_WAITS"] = "0"
  ENV["SPECWRK_MAX_BUCKET_SIZE"] = "1"
  ENV["SPECWRK_COUNT"] = count.to_s
  ENV["SPECWRK_RUN"] = "watch"

  web_pid

  return if Specwrk.force_quit

  seed_pid

  start_watcher(watchfile)

  require "specwrk/cli_reporter"

  title "👀 for changes"

  loop do
    status "👀 Watching for file changes..."

    @worker_pids = nil
    Thread.pass until file_queue.length.positive? || Specwrk.force_quit

    break if Specwrk.force_quit

    files = []
    files.push(file_queue.pop) until file_queue.length.zero?
    status "Running specs for #{files.join(" ")}..."
    ipc.write(files.join(" "))

    example_count = ipc.read.to_i
    if example_count.positive?
      puts "\n🌱 Seeded #{example_count} examples for execution\n"
    else
      puts "\n🙅 No examples to seed for execution\n"
    end

    next if example_count.zero?
    title "👷 on #{example_count} examples"

    return if Specwrk.force_quit
    start_workers

    Specwrk.wait_for_pids_exit(@worker_pids)

    drain_outputs
    return if Specwrk.force_quit

    reporter = Specwrk::CLIReporter.new

    status = reporter.report
    puts

    if status.zero?
      title "🟢 #{reporter.example_count} examples passed"
    else
      title " 🔴 #{reporter.failure_count}/#{reporter.example_count} examples failed"
    end

    $stdout.flush
  end

  ipc.write "INT" # wakes the socket
  Specwrk.wait_for_pids_exit([web_pid, seed_pid])
end