Contents

#!/usr/bin/env ruby
# WANT_JSON

# init bundler in dev env
if ENV['QB_DEV_ENV']
  ENV.each {|k, v|
    if k.start_with? 'QB_DEV_ENV_'
      ENV[k.sub('QB_DEV_ENV_', '')] = v
    end
  }
  require 'bundler/setup'
end

require 'qb'
require 'cmds'

class Stream < QB::Ansible::Module
  def main
    template = @args['template'] || @args['cmd']
    
    if template.nil?
      raise ArgumentError,
            "Must supply `template` or `cmd` argument."
    end
    
    if @args['creates'] && File.exists?( @args['creates'] )
      debug "File #{ @args['creates'] } exists, skipping"
      return nil
    end
    
    opts = {}
    
    [:args, :kwds, :input, :assert, :env, :chdir].each { |key|
      opts[key] = @args[key.to_s] if @args.key?(key.to_s)
    }
    
    [:format, :env_mode].each { |key|
      opts[key] = @args[key.to_s].to_sym if @args.key?(key.to_s)
    }
    
    cmd = Cmds.new(template, **opts)
    
    if @args['log']
      info "STREAMING\n\n#{ cmd.prepare }\n\n"
    end
    
    cmd.stream!
    
    changed!
  end
end

Stream.new.run

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
qb-0.3.14	library/stream
qb-0.3.13	library/stream