diff --git a/test/test_helper.rb b/test/test_helper.rb index bc386f14439c2a38e81bdf01f6fc60ae4323e673..ce3edfc023170cb987258e41570f066bc8790602 100644 --- a/test/test_helper.rb +++ b/test/test_helper.rb @@ -42,6 +42,30 @@ def written SGXbwmsgsv2.instance_variable_get(:@written) end +def invoke_webhook(payload, extra_env: {}) + with_stubs([ + [ + SGXbwmsgsv2, + :write, + ->(data) { SGXbwmsgsv2.write_to_stream(data) } + ] + ]) do + handler = WebhookHandler.new + env = { + "REQUEST_URI" => "/", + "REQUEST_METHOD" => "POST", + "params" => { "_json" => [payload] } + }.merge(extra_env) + handler.instance_variable_set(:@env, env) + def handler.params + @env["params"] + end + EMPromise.resolve(nil).then { + handler.response(env) + }.sync + end +end + begin require "pry-byebug" diff --git a/test/test_webhook_handler.rb b/test/test_webhook_handler.rb index bc392318e51d3cbeea34d53448c37325b03e9c5b..63c6b7db78d7c58ce6e9a8ee8ef1e831b5fbc2d3 100644 --- a/test/test_webhook_handler.rb +++ b/test/test_webhook_handler.rb @@ -13,31 +13,6 @@ class WebhookHandlerTest < Minitest::Test reset_redis! end - def invoke_webhook(payload, extra_env: {}) - with_stubs([ - [ - SGXbwmsgsv2, - :write, - ->(data) { SGXbwmsgsv2.write_to_stream(data) } - ] - ]) do - handler = WebhookHandler.new - env = { - "REQUEST_URI" => "/", - "REQUEST_METHOD" => "POST", - "params" => {"_json" => [payload]} - }.merge(extra_env) - handler.instance_variable_set(:@env, env) - def handler.params - @env["params"] - end - - EMPromise.resolve(nil).then { - handler.response(env) - }.sync - end - end - def test_inbound_sms_emits_to_stream payload = { "type" => "message-received",