From c0cb29374365c021890d8e3ff8400a62d9db46a0 Mon Sep 17 00:00:00 2001 From: Stephen Paul Weber Date: Tue, 7 Apr 2026 10:18:12 -0500 Subject: [PATCH] hotfixes --- bin/notify_inbound_failures_job | 8 ++++---- bin/view-events | 2 +- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/bin/notify_inbound_failures_job b/bin/notify_inbound_failures_job index 9a9cf6006bb0b925d40c87d0c28004cb1d72dd6e..1aa0be1d3a872493ba33c4f321a8d7db51a6a27c 100755 --- a/bin/notify_inbound_failures_job +++ b/bin/notify_inbound_failures_job @@ -74,7 +74,7 @@ class BlockedMessage def notify! EM::HttpRequest.new( - OPTIONS[:webhook_endpoint], + URI(OPTIONS[:webhook_endpoint]), tls: {verify_peer: true} ).post( body: [to_h].to_json, @@ -99,6 +99,8 @@ class BandwidthMessages def each(&block) req.then { |res| + puts "Found #{res.response["messages"].length} blocked messages" + EMPromise.all(res.response["messages"].map { |msg| block.call(BlockedMessage.new(msg)) }).then { res } @@ -107,9 +109,7 @@ class BandwidthMessages } end - URL = "https://messaging.bandwidth.com/api/v2/users/" \ - "#{OPTIONS[:account_id]}" \ - "/messages" + URL = URI("https://messaging.bandwidth.com/api/v2/users/#{OPTIONS[:account_id]}/messages") def req EM::HttpRequest diff --git a/bin/view-events b/bin/view-events index 1939a0345c22e99146975ae2a2a5fedf32e4f16d..1c96cd7e6b09d64269483868315601455f6f655c 100755 --- a/bin/view-events +++ b/bin/view-events @@ -68,7 +68,7 @@ def to_stream_id(str) "#{epoch * 1000}-0" end -def format_event(fields, json: False, **) +def format_event(fields, json: false, **) return JSON.dump(fields) if json event = fields["event"]