Sha256: d97c96bf266a6d4c661e5b6cde784fa5d314a277c9d5304495c7907a0e20a0d8
Contents?: true
Size: 1.54 KB
Versions: 8
Compression:
Stored size: 1.54 KB
Contents
# frozen_string_literal: true
require "open3"
module Hanami
module CLI
# @api private
# @since 2.1.0
class InteractiveSystemCall
# @api private
# @since 2.1.0
def initialize(out: $stdout, err: $stderr, exit_after: true)
@out = out
@err = err
@exit_after = exit_after
super()
end
# @api private
# @since 2.1.0
def call(cmd, *args, env: {}, out_prefix: "")
::Bundler.with_unbundled_env do
threads = []
exit_status = 0
# rubocop:disable Lint/SuppressedException
Open3.popen3(env, command(cmd, *args)) do |_stdin, stdout, stderr, wait_thr|
threads << Thread.new do
stdout.each_line do |line|
out.puts("#{out_prefix}#{line}")
end
rescue IOError # FIXME: Check if this is legit
end
threads << Thread.new do
stderr.each_line do |line|
err.puts("#{out_prefix}#{line}")
end
rescue IOError # FIXME: Check if this is legit
end
threads.each(&:join)
exit_status = wait_thr.value
end
# rubocop:enable Lint/SuppressedException
exit(exit_status.exitstatus) if @exit_after
end
end
private
# @api private
# @since 2.1.0
attr_reader :out, :err
# @since 2.1.0
# @api public
def command(cmd, *args)
[cmd, args].flatten(1).compact.join(" ")
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems