|
3 | 3 | require "flores/random"
|
4 | 4 | require 'concurrent/atomic/count_down_latch'
|
5 | 5 | require "logstash/outputs/elasticsearch"
|
6 |
| - |
7 | 6 | require 'logstash/plugin_mixins/ecs_compatibility_support/spec_helper'
|
| 7 | +require 'rspec/collection_matchers' |
8 | 8 |
|
9 | 9 | describe LogStash::Outputs::ElasticSearch do
|
10 | 10 | subject(:elasticsearch_output_instance) { described_class.new(options) }
|
|
394 | 394 | ]}
|
395 | 395 | it "rejects unsupported actions" do
|
396 | 396 | event_result = subject.send(:safe_interpolation_map_events, events)
|
397 |
| - expect(event_result.successful_events.size).to be == 3 |
| 397 | + expect(event_result.successful_events).to have_exactly(3).items |
398 | 398 | event_result.successful_events.each do |action, _|
|
399 | 399 | expect(action).to_not eql("unsupported_action")
|
400 | 400 | end
|
| 401 | + expect(event_result.event_mapping_errors).to have_exactly(1).items |
401 | 402 | event_result.event_mapping_errors.each do |event_mapping_error|
|
402 | 403 | expect(event_mapping_error.message).to eql("Elasticsearch doesn't support [unsupported_action] action")
|
403 | 404 | end
|
|
413 | 414 | ]}
|
414 | 415 | it "rejects unsupported actions" do
|
415 | 416 | event_result = subject.send(:safe_interpolation_map_events, events)
|
416 |
| - expect(event_result.successful_events.size).to be == 3 |
| 417 | + expect(event_result.successful_events).to have_exactly(3).items |
417 | 418 | event_result.successful_events.each do |action, _|
|
418 | 419 | expect(action).to_not eql("unsupported_action")
|
419 | 420 | end
|
| 421 | + expect(event_result.event_mapping_errors).to have_exactly(1).items |
420 | 422 | event_result.event_mapping_errors.each do |event_mapping_error|
|
421 | 423 | expect(event_mapping_error.message).to eql("Elasticsearch doesn't support [unsupported_action] action")
|
422 | 424 | end
|
|
432 | 434 | ]}
|
433 | 435 | it "rejects unsupported actions" do
|
434 | 436 | event_result = subject.send(:safe_interpolation_map_events, events)
|
435 |
| - expect(event_result.successful_events.size).to be == 0 |
| 437 | + expect(event_result.successful_events).to have(:no).items |
436 | 438 | event_result.successful_events.each do |action, _|
|
437 | 439 | expect(action).to_not eql("unsupported_action")
|
438 | 440 | end
|
| 441 | + expect(event_result.event_mapping_errors).to have_exactly(4).items |
439 | 442 | event_result.event_mapping_errors.each do |event_mapping_error|
|
440 | 443 | expect(event_mapping_error.message).to include "Elasticsearch doesn't support"
|
441 | 444 | end
|
|
451 | 454 | ]}
|
452 | 455 | it "rejects unsupported actions" do
|
453 | 456 | event_result = subject.send(:safe_interpolation_map_events, events)
|
454 |
| - expect(event_result.successful_events.size).to be == 2 |
455 |
| - expect(event_result.event_mapping_errors.size).to be == 2 |
| 457 | + expect(event_result.successful_events).to have_exactly(2).items |
| 458 | + expect(event_result.event_mapping_errors).to have_exactly(2).items |
456 | 459 | event_result.event_mapping_errors.each do |event_mapping_error|
|
457 | 460 | expect(event_mapping_error.message).to include "Elasticsearch doesn't support"
|
458 | 461 | end
|
|
468 | 471 | ]}
|
469 | 472 | it "rejects unsupported action" do
|
470 | 473 | event_result = subject.send(:safe_interpolation_map_events, events)
|
471 |
| - expect(event_result.successful_events.size).to be == 3 |
| 474 | + expect(event_result.successful_events).to have_exactly(3).items |
| 475 | + expect(event_result.event_mapping_errors).to have_exactly(1).items |
472 | 476 | event_result.event_mapping_errors.each do |event_mapping_error|
|
473 | 477 | expect(event_mapping_error.message).to eql("Elasticsearch doesn't support [unsupported_action3] action")
|
474 | 478 | end
|
|
0 commit comments