mirror of
https://github.com/elastic/logstash.git
synced 2025-04-24 14:47:19 -04:00
3897b718ff
Clean backport of #16959 from 8.x to 8.17
----
Reimplements `LogStash::Setting::String` Ruby setting class into the `org.logstash.settings.SettingString` and exposes it through `java_import` as `LogStash::Setting::SettingString`.
Updates the rspec tests in two ways:
- logging mock is now converted to real Log4J appender that spy log line that are later verified
- verifies `java.lang.IllegalArgumentException` instead of `ArgumentError` is thrown because the kind of exception thrown by Java code, during verification.
* Fixed the rename of NullableString to SettingNullableString
* Fixed runner test to use real spy logger from Java Settings instead of mock test double
(cherry picked from commit a0378c05cb)
Co-authored-by: Andrea Selva <selva.andre@gmail.com>
109 lines
No EOL
3.2 KiB
Ruby
109 lines
No EOL
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 "logstash/devutils/rspec/spec_helper"
|
|
|
|
require "flores/rspec"
|
|
require "flores/random"
|
|
require "pathname"
|
|
require "stud/task"
|
|
require "support/resource_dsl_methods"
|
|
require "support/mocks_classes"
|
|
require "support/helpers"
|
|
require "support/shared_contexts"
|
|
require "support/shared_examples"
|
|
require 'rspec/expectations'
|
|
require "logstash/settings"
|
|
require 'rack/test'
|
|
require 'rspec'
|
|
require "json"
|
|
require 'logstash/runner'
|
|
|
|
# Code coverage setup
|
|
if ENV['COVERAGE']
|
|
require 'simplecov'
|
|
require 'simplecov-json'
|
|
|
|
SimpleCov.formatter = SimpleCov::Formatter::JSONFormatter
|
|
|
|
SimpleCov.start do
|
|
add_filter 'spec/'
|
|
add_filter 'vendor/'
|
|
end
|
|
end
|
|
|
|
class JSONIOThingy < IO
|
|
def initialize; end
|
|
def flush; end
|
|
|
|
def puts(payload)
|
|
# Ensure that all log payloads are valid json.
|
|
LogStash::Json.load(payload)
|
|
end
|
|
end
|
|
|
|
# Refactor the suite to https://github.com/elastic/logstash/issues/7148
|
|
RSpec::Expectations.configuration.on_potential_false_positives = :nothing
|
|
|
|
RSpec.configure do |c|
|
|
Flores::RSpec.configure(c)
|
|
c.include LogStashHelper
|
|
c.extend LogStashHelper
|
|
|
|
if ENV['COVERAGE']
|
|
c.after(:suite) do
|
|
SimpleCov.result.format!
|
|
end
|
|
end
|
|
|
|
# Some tests mess with LogStash::SETTINGS, and data on the filesystem can leak state
|
|
# from one spec to another; run each spec with its own temporary data directory for `path.data`
|
|
c.around(:each) do |example|
|
|
Dir.mktmpdir do |temp_directory|
|
|
# Some tests mess with the settings. This ensures one test cannot pollute another
|
|
LogStash::SETTINGS.reset
|
|
|
|
LogStash::SETTINGS.set("queue.type", "memory")
|
|
LogStash::SETTINGS.set("path.data", temp_directory)
|
|
|
|
LogStash::Util.set_thread_name("RSPEC Example #{example.full_description} (from: `#{example.location}`)") do
|
|
example.run
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
def installed_plugins
|
|
Gem::Specification.find_all.select { |spec| spec.metadata["logstash_plugin"] }.map { |plugin| plugin.name }
|
|
end
|
|
|
|
java_import org.apache.logging.log4j.core.appender.AbstractAppender
|
|
|
|
class CustomAppender < AbstractAppender
|
|
|
|
attr_reader :events_collector
|
|
|
|
def initialize(events)
|
|
super("CustomCaptorAppender", nil, nil, true, org.apache.logging.log4j.core.config.Property::EMPTY_ARRAY)
|
|
@events_collector = events
|
|
end
|
|
|
|
# override the append to catch all the calls and collect the events
|
|
def append(log_event)
|
|
@events_collector << log_event.message.formatted_message
|
|
end
|
|
end |