Skip to content

Commit 7c0d4cd

Browse files
author
Siddhath Kulkarni
committed
DEV-118709 Fix failing tets.
1 parent c2ec220 commit 7c0d4cd

File tree

2 files changed

+8
-6
lines changed

2 files changed

+8
-6
lines changed

lib/logstash/outputs/lmlogs.rb

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -266,7 +266,9 @@ def multi_receive(events)
266266
if @include_metadata
267267
lmlogs_event = event_json
268268
lmlogs_event.delete("@timestamp") # remove redundant timestamp field
269-
lmlogs_event["event"].delete("original") # remove redundant log field
269+
if lmlogs_event.dig("event", "original") != nil
270+
lmlogs_event["event"].delete("original") # remove redundant log field
271+
end
270272
end
271273

272274
lmlogs_event["message"] = event.get(@message_key).to_s

spec/outputs/lmlogs_spec.rb

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -34,12 +34,12 @@
3434
event1 = LogStash::Event.new("message" => "hello this is log 1", "host" => "host1")
3535
event2 = LogStash::Event.new("message" => "hello this is log 2", "host" => "host2")
3636
event3 = LogStash::Event.new("message" => "hello this is log 3", "host" => "host3")
37-
expect(client).to receive(:post).once.with("https://localhost.logicmonitor.com/rest/log/ingest",:body => LogStash::Json.dump(
38-
[{"message" => "hello this is log 1", "_lm.resourceId" => {"test.property" => "host1"}, "timestamp" => event1.timestamp.to_s,"@version":"1", "host" => "host1"},
39-
{"message" => "hello this is log 2", "_lm.resourceId" => {"test.property" => "host2"}, "timestamp" => event2.timestamp.to_s,"@version":"1", "host" => "host2"},
40-
{"message" => "hello this is log 3", "_lm.resourceId" => {"test.property" => "host3"}, "timestamp" => event3.timestamp.to_s}
37+
expect(client).to receive(:post).once.with("https://localhost.logicmonitor.com/rest/log/ingest",hash_including(:body => LogStash::Json.dump(
38+
[{ "host" => "host1", "message" => "hello this is log 1","@version":"1", "_lm.resourceId" => {"test.property" => "host1"}, "timestamp" => event1.timestamp.to_s,},
39+
{"host" => "host2","message" => "hello this is log 2","@version":"1", "_lm.resourceId" => {"test.property" => "host2"}, "timestamp" => event2.timestamp.to_s},
40+
{"host" => "host3","message" => "hello this is log 3","@version":"1", "_lm.resourceId" => {"test.property" => "host3"}, "timestamp" => event3.timestamp.to_s}
4141
]
42-
)).and_call_original
42+
))).and_call_original
4343
@lmlogs.multi_receive([event1, event2, event3])
4444
end
4545

0 commit comments

Comments
 (0)