module Asposetasksjava

# File lib/asposetasksjava.rb, line 67
def self.configure_aspose_tasks config
  Asposetasksjava.aspose_tasks_config = config
end

# File lib/asposetasksjava.rb, line 12
def initialize_aspose_tasks
  aspose_jars_dir = Asposetasksjava.aspose_tasks_config ? Asposetasksjava.aspose_tasks_config['jar_dir'] : nil  
  aspose_license_path = Asposetasksjava.aspose_tasks_config ? Asposetasksjava.aspose_tasks_config['license_path'] : nil
  jvm_args = Asposetasksjava.aspose_tasks_config ? Asposetasksjava.aspose_tasks_config['jvm_args'] : nil
  
  load_aspose_jars(aspose_jars_dir, jvm_args)
  load_aspose_license(aspose_license_path)
end

# File lib/asposetasksjava.rb, line 50
def input_file(file)
  Rjb::import('java.io.FileInputStream').new(file)
end

# File lib/asposetasksjava.rb, line 31
def load_aspose_jars(aspose_jars_dir, jvm_args)
  if aspose_jars_dir && File.exist?(aspose_jars_dir)
    jardir = File.join(aspose_jars_dir, '**', '*.jar')
  else
    jardir = File.join(File.dirname(File.dirname(__FILE__)), 'jars', '**', '*.jar')
  end

  if jvm_args
    args = jvm_args.split(' ') << '-Djava.awt.headless=true'
    logger = Logger.new(STDOUT)
    logger.level = Logger::DEBUG
    logger.debug("JVM args : #{args}")
    Rjb::load(classpath = Dir.glob(jardir).join(':'), jvmargs=args)
  else
    Rjb::load(classpath = Dir.glob(jardir).join(':'), jvmargs=['-Djava.awt.headless=true'])
  end

end

# File lib/asposetasksjava.rb, line 21
def load_aspose_license(aspose_license_path)
  if aspose_license_path && File.exist?(aspose_license_path)
    set_license(File.join(aspose_license_path))
  else
    logger = Logger.new(STDOUT)
    logger.level = Logger::WARN
    logger.warn('Using the non licensed aspose jar. Please specify path to your aspose license directory in config/aspose.yml file!')
  end
end

# File lib/asposetasksjava.rb, line 54
def set_license(aspose_license_file)
  begin
    fstream = input_file(aspose_license_file)
    license = Rjb::import('com.aspose.api.License').new()
    license.setLicense(fstream)
  rescue Exception => ex
    logger = Logger.new(STDOUT)
    logger.level = Logger::ERROR
    logger.error("Could not load the license file : #{ex}")
    fstream.close() if fstream
  end
end