Sha256: bb146713a46c4c2a5a03d79a9a53c264fb67a67166447c9238c713a3949a5d12
Contents?: true
Size: 1.88 KB
Versions: 9
Compression:
Stored size: 1.88 KB
Contents
require 'json'
require 'logger'
require "base64"
require "prepare-environment"
require "trace-runner"
class HelperRun
def initialize ()
@basePath = "#{Pathname.new(Canzea::config[:catalog_location]).realpath}/catalog"
@log = Logger.new(Canzea::config[:logging_root] + '/plans.log')
end
def runPlan (plans)
plans.each { | plan |
puts "Running #{plan[:action]}"
self.run plan[:solution], plan[:action], JSON.generate(plan[:parameters])
}
end
def enrich (params)
# If there is context information, then merge them into the parameters before calling the helper
if (ENV.has_key?('WORK_DIR') and File.exists?ENV['WORK_DIR'] + "/context.json")
context = JSON.parse(File.read(ENV['WORK_DIR'] + "/context.json"))
result = JSON.parse(params).merge(context)
return JSON.generate(result)
end
return params
end
def run (solution, action, parameters, status = false)
type = "ruby"
parameters = self.enrich(parameters)
envPush = PrepareEnvironment.new
begin
envScript = "#{@basePath}/helpers/#{solution}/environment.json"
if File.exist?(envScript)
@log.info("Adding environment variables...")
envPush.addToEnv "#{envScript}"
end
r = RunnerWorker.new
ENV['CATALOG_LOCATION'] = "#{@basePath}";
if (type == "ruby")
cmd = "ruby #{@basePath}/helpers/#{solution}/#{action}.rb '#{parameters}'"
else
cmd = "#{@basePath}/helpers/#{solution}/#{action}.sh \"#{parameters}\""
end
r.run cmd, 1, 1, status
rescue => exception
@log.error(cmd)
@log.error(exception.to_s)
@log.error(exception.backtrace)
abort()
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems