hets.rb revision 519002bc41b20a069be1c669660e702f9bd4a593
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger class VersionOutdatedError < DeploymentError; end
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger class ConfigDateFormatError < DeploymentError; end
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger class VersionDateFormatError < DeploymentError; end
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger attr_reader :path, :library_path, :stack_size, :env
58721b9d3a8cd6a624269ddf507f80af4417c9bdhenning mueller yaml = YAML.load_file(File.join(Rails.root, 'config', 'hets.yml'))
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger @path = first_which_exists yaml['hets_path']
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger @library_path = first_which_exists yaml['hets_lib']
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger raise DeploymentError, 'Could not find hets' unless @path
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger raise DeploymentError, 'Hets library not found.' unless @library_path
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger unless is_compatible? yaml['version_minimum_date']
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger raise VersionOutdatedError, 'The installed version of Hets is too old'
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger # Set hets environment variables
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger %w( hets_lib hets_owl_tools ).each do |key|
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger @env[key.upcase] = first_which_exists yaml[key]
40c5626383ebd5e8cf11a636f864023a2aafcd6bDaniel Couto Vale # Checks Hets installation compatibility by its version date
b0c849916b1471424344717ada19c745833e4c5bhenning mueller # * - +minimum_date+ -> Minimum working hets version date
40c5626383ebd5e8cf11a636f864023a2aafcd6bDaniel Couto Vale # * *Returns* :
40c5626383ebd5e8cf11a636f864023a2aafcd6bDaniel Couto Vale # * - true if hets version minimum date prior or equal to actual hets version date
40c5626383ebd5e8cf11a636f864023a2aafcd6bDaniel Couto Vale # * - false otherwise
40c5626383ebd5e8cf11a636f864023a2aafcd6bDaniel Couto Vale # Read Hets version minimum date
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger raise ConfigDateFormatError, 'Could not read hets version minimum date in YAML' unless minimum_date
40c5626383ebd5e8cf11a636f864023a2aafcd6bDaniel Couto Vale # Read Hets version date
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger raise VersionDateFormatError, 'Could not read hets version date in output of `hets -V`' unless version_date
40c5626383ebd5e8cf11a636f864023a2aafcd6bDaniel Couto Vale # Return true if minimum date is prior or equal to version date
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger paths.map { |path| File.expand_path path }.find do |path|
58721b9d3a8cd6a624269ddf507f80af4417c9bdhenning mueller # Runs hets with input_file and returns XML output file path.
519002bc41b20a069be1c669660e702f9bd4a593Eugen Kuksa def self.parse(input_file, url_catalog = [], output_path = nil, structure_only: false)
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger args = [config.path, *%w( -o pp.xml -o xml --full-signatures -a none -v2 )]
aa056a2e5efb6505701a4e4a31bf2f7e71ff1738henning mueller args += ['-C', url_catalog.join(',')] unless url_catalog.empty?
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger args += ['+RTS', "-K#{config.stack_size}", '-RTS']
a274d776b3371051dcdd74b598182ce113ca5135Julian Kornberger # add the path to the input file as last argument
b5bf21df9d1d61069e6dc9e13569543d0b868bc8Daniel Couto Vale # Executes command with low priority
a274d776b3371051dcdd74b598182ce113ca5135Julian Kornberger Rails.logger.debug "Running hets with: #{args.inspect}"
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger output = Subprocess.run :nice, *args, config.env
a274d776b3371051dcdd74b598182ce113ca5135Julian Kornberger if output.starts_with? '*** Error'
a274d776b3371051dcdd74b598182ce113ca5135Julian Kornberger # some error occured
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger raise ExecutionError, output
a274d776b3371051dcdd74b598182ce113ca5135Julian Kornberger elsif match = output.lines.last.match(/Writing file: (.+)/)
a274d776b3371051dcdd74b598182ce113ca5135Julian Kornberger # successful execution
a274d776b3371051dcdd74b598182ce113ca5135Julian Kornberger # we can not handle this response
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger raise ExecutionError, "Unexpected output:\n#{output}"
a274d776b3371051dcdd74b598182ce113ca5135Julian Kornberger rescue Subprocess::Error => e
a274d776b3371051dcdd74b598182ce113ca5135Julian Kornberger output = e.output
a274d776b3371051dcdd74b598182ce113ca5135Julian Kornberger # Exclude usage message if exit status equals 2
a274d776b3371051dcdd74b598182ce113ca5135Julian Kornberger if e.status == 2 and output.include? 'Usage:'
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger raise ExecutionError, output.split("Usage:").first
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger raise ExecutionError, e.message
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger def self.config
2e7a48951591a6eeda9a3ab4e14cd13012cb43eaJulian Kornberger config ||= Config.new