40 lines
1.6 KiB
Ruby
40 lines
1.6 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
RSpec.describe Clog do
|
|
let(:now) { Time.parse("2023-01-17 12:10:54 -0800") }
|
|
|
|
before do
|
|
allow(Config).to receive(:test?).and_return(false)
|
|
allow(Time).to receive(:now).and_return(now)
|
|
end
|
|
|
|
it "adds the thread name to the structured data" do
|
|
Thread.new do
|
|
Thread.current.name = "test thread name"
|
|
expect($stdout).to receive(:write).with('{"message":"hello","time":"' + now.to_s + '","thread":"test thread name"}' + "\n")
|
|
described_class.emit "hello"
|
|
end.join
|
|
end
|
|
|
|
it "doesn't include a thread name if it is not set" do
|
|
expect($stdout).to receive(:write).with('{"message":"hello","time":"' + now.to_s + '"}' + "\n")
|
|
described_class.emit "hello"
|
|
end
|
|
|
|
it "writes an error when an invalid type is yield from the block" do
|
|
expect($stdout).to receive(:write).with('{"invalid_type":"Integer","message":"ngmi","time":"' + now.to_s + '"}' + "\n")
|
|
described_class.emit("ngmi") { 1 }
|
|
end
|
|
|
|
it "returns the key with redacted values for Sequel::Model" do
|
|
expect($stdout).to receive(:write).with('{"vm":{"id":"123"},"message":"model","time":"' + now.to_s + '"}' + "\n")
|
|
described_class.emit("model") { Vm.new(public_key: "redacted_key").tap { _1.id = "123" } }
|
|
end
|
|
|
|
it "returns a combined hash when the metadata is an array" do
|
|
expect($stdout).to receive(:write).with('{"vm":{"id":"123"},"field1":"custom","invalid_type":"String","message":"model","time":"' + now.to_s + '"}' + "\n")
|
|
vm = Vm.new(public_key: "redacted_key").tap { _1.id = "123" }
|
|
described_class.emit("model") { [vm, {field1: "custom"}, "invalid"] }
|
|
end
|
|
end
|