mirror of
https://github.com/stripe/stripe-ruby.git
synced 2025-10-27 00:02:34 -04:00
c1d0ced565
* Add response field to RequestEndEvent * Add request body field to RequestEventEnd * Add request headers field to RequestEventEnd * Create a RequestContext class * Create a ResponseContext class * Update tests
92 lines
2.6 KiB
Ruby
92 lines
2.6 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require_relative "../test_helper"
|
|
|
|
module Stripe
|
|
class InstrumentationTest < Test::Unit::TestCase
|
|
context ".notify" do
|
|
teardown do
|
|
Stripe::Instrumentation.send(:subscribers).clear
|
|
end
|
|
|
|
should "notify subscribers for the right topic" do
|
|
sub1_events = []
|
|
Stripe::Instrumentation.subscribe(:test1, :sub1) { |event| sub1_events << event }
|
|
sub2_events = []
|
|
Stripe::Instrumentation.subscribe(:test2, :sub2) { |event| sub2_events << event }
|
|
|
|
Stripe::Instrumentation.notify(:test1, "hello")
|
|
assert_equal(1, sub1_events.size)
|
|
assert_equal(0, sub2_events.size)
|
|
end
|
|
|
|
should "notify multiple subscribers of the same topic" do
|
|
sub1_events = []
|
|
Stripe::Instrumentation.subscribe(:test, :sub1) { |event| sub1_events << event }
|
|
sub2_events = []
|
|
Stripe::Instrumentation.subscribe(:test, :sub2) { |event| sub2_events << event }
|
|
|
|
Stripe::Instrumentation.notify(:test, "hello")
|
|
assert_equal(1, sub1_events.size)
|
|
assert_equal(1, sub2_events.size)
|
|
end
|
|
|
|
should "not notify a subscriber once it has unsubscribed" do
|
|
events = []
|
|
Stripe::Instrumentation.subscribe(:test, :sub) { |event| events << event }
|
|
|
|
Stripe::Instrumentation.notify(:test, "hello")
|
|
assert_equal(1, events.size)
|
|
|
|
Stripe::Instrumentation.unsubscribe(:test, :sub)
|
|
Stripe::Instrumentation.notify(:test, "hello")
|
|
assert_equal(1, events.size)
|
|
end
|
|
end
|
|
|
|
context "RequestEventBegin" do
|
|
should "return a frozen object" do
|
|
event = Stripe::Instrumentation::RequestBeginEvent.new(
|
|
method: :get,
|
|
path: "/v1/test",
|
|
user_data: nil
|
|
)
|
|
|
|
assert(event.frozen?)
|
|
end
|
|
end
|
|
|
|
context "RequestEventEnd" do
|
|
should "return a frozen object" do
|
|
mock_context = stub(
|
|
duration: 0.1,
|
|
method: :get,
|
|
path: "/v1/test",
|
|
request_id: "req_123",
|
|
body: ""
|
|
)
|
|
|
|
request_context = Stripe::Instrumentation::RequestContext.new(
|
|
duration: 0.1,
|
|
context: mock_context,
|
|
header: nil
|
|
)
|
|
|
|
response_context = Stripe::Instrumentation::ResponseContext.new(
|
|
http_status: 200,
|
|
response: nil
|
|
)
|
|
|
|
event = Stripe::Instrumentation::RequestEndEvent.new(
|
|
num_retries: 0,
|
|
request_context: request_context,
|
|
response_context: response_context,
|
|
user_data: nil
|
|
)
|
|
|
|
assert(event.frozen?)
|
|
end
|
|
end
|
|
end
|
|
end
|