mirror of
https://github.com/elastic/logstash.git
synced 2025-04-24 22:57:16 -04:00
26d1c7ccdb
Set of changes to make Logstash compatible to JRuby 9.4. Bundle JRuby 9.4.3.0 - Redefine space token in `LSCL` and `grammar` treetop from `_` which would generated methods in the form `def _0` (deprecated since `2.7`) to `sc`. - `I18n.t` method doesn't accept hash as second argument - `URI.encode` has been replaced with same functionality with `URI::Parser.new.escape` - `YAML.load` needs explicit `fallback: false` to return false when the yaml string is empty (or contains only comments) - JRuby's `JavaClass` has been removed, now it can use `java.lang.Class` directly - explicitly require gem `thwait` to satisfy `require "thwait"` (In `Gemfile.template` and `logstash-core/logstash-core.gemspec`) - fix not args `clone` to be `def clone(*args)` - fix `Enumeration.each_slice` which from `Ruby 3.1` is [chainable](https://rubyreferences.github.io/rubychanges/3.1.html#enumerableeach_cons-and-each_slice-return-a-receiver) and doesn't return `nil`. JRuby fixed in https://github.com/jruby/jruby/issues/7015 - Expanded `Down.download` arguments map ca16bbed3c302006967413eb9d3862f2da81f7ae - Avoid to pass `nil` in the list of couples used in `Hash[ <list of couples> ]` which from Ruby `3.0` generates an `ArgumentError` - Removed space not allowed between method name and parentheses `initialize (` is forbidden. 29b607dcdef98f81a73ad171639fd13aaa65e243 - With [Ruby 2.7 the `Kernel#open`](https://rubyreferences.github.io/rubychanges/2.7.html#network-and-web) doesn't fallback to `URI#open`, fixed test code that used that to verify open port. e5b70de54c5301f51a767da67294092af0cfafdc - Avoid to drop `rdoc/` folder from vendored JRuby else `bin/logstash -i irb` would crash, commit b71f73e9c6edb81a7b7ae1305047e506f61c6e8c Co-authored-by: João Duarte <jsvd@users.noreply.github.com>
114 lines
3.2 KiB
Ruby
114 lines
3.2 KiB
Ruby
# Licensed to Elasticsearch B.V. under one or more contributor
|
|
# license agreements. See the NOTICE file distributed with
|
|
# this work for additional information regarding copyright
|
|
# ownership. Elasticsearch B.V. licenses this file to you under
|
|
# the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License.
|
|
# You may obtain a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing,
|
|
# software distributed under the License is distributed on an
|
|
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
|
# KIND, either express or implied. See the License for the
|
|
# specific language governing permissions and limitations
|
|
# under the License.
|
|
|
|
require "pluginmanager/ui"
|
|
require "pathname"
|
|
require "rubygems/package"
|
|
require "fileutils"
|
|
|
|
module LogStash module PluginManager
|
|
# Install a physical gem package to the appropriate location inside logstash
|
|
# - Extract the gem
|
|
# - Generate the specifications
|
|
# - Copy the data in the right folders
|
|
class GemInstaller
|
|
GEM_HOME = Pathname.new(::File.join(LogStash::Environment::BUNDLE_DIR, "jruby", "3.1.0"))
|
|
SPECIFICATIONS_DIR = "specifications"
|
|
GEMS_DIR = "gems"
|
|
CACHE_DIR = "cache"
|
|
|
|
attr_reader :gem_home
|
|
|
|
def initialize(gem_file, display_post_install_message = false, gem_home = GEM_HOME)
|
|
@gem_file = gem_file
|
|
@gem = ::Gem::Package.new(@gem_file)
|
|
@gem_home = Pathname.new(gem_home)
|
|
@display_post_install_message = display_post_install_message
|
|
end
|
|
|
|
def install
|
|
create_destination_folders
|
|
extract_files
|
|
write_specification
|
|
copy_gem_file_to_cache
|
|
post_install_message
|
|
end
|
|
|
|
def self.install(gem_file, display_post_install_message = false, gem_home = GEM_HOME)
|
|
self.new(gem_file, display_post_install_message, gem_home).install
|
|
end
|
|
|
|
private
|
|
def spec
|
|
gem_spec = @gem.spec
|
|
def gem_spec.for_cache
|
|
spec = dup
|
|
spec.test_files = nil
|
|
spec
|
|
end
|
|
gem_spec
|
|
end
|
|
|
|
def spec_dir
|
|
gem_home.join(SPECIFICATIONS_DIR)
|
|
end
|
|
|
|
def cache_dir
|
|
gem_home.join(CACHE_DIR)
|
|
end
|
|
|
|
def spec_file
|
|
spec_dir.join("#{spec.full_name}.gemspec")
|
|
end
|
|
|
|
def gem_dir
|
|
gem_home.join(GEMS_DIR, spec.full_name)
|
|
end
|
|
|
|
def extract_files
|
|
@gem.extract_files gem_dir
|
|
end
|
|
|
|
def write_specification
|
|
::File.open(spec_file, 'w') do |file|
|
|
spec.installed_by_version = ::Gem.rubygems_version
|
|
file.puts spec.to_ruby_for_cache
|
|
file.fsync rescue nil # Force writing to disk
|
|
end
|
|
end
|
|
|
|
def post_install_message
|
|
spec.post_install_message if display_post_install_message?
|
|
end
|
|
|
|
def display_post_install_message?
|
|
@display_post_install_message && !spec.post_install_message.nil?
|
|
end
|
|
|
|
def copy_gem_file_to_cache
|
|
destination = ::File.join(cache_dir, ::File.basename(@gem_file))
|
|
FileUtils.cp(@gem_file, destination)
|
|
end
|
|
|
|
def create_destination_folders
|
|
FileUtils.mkdir_p(gem_home)
|
|
FileUtils.mkdir_p(gem_dir)
|
|
FileUtils.mkdir_p(spec_dir)
|
|
FileUtils.mkdir_p(cache_dir)
|
|
end
|
|
end
|
|
end end
|