diff --git a/bin/notify_inbound_failures_job b/bin/notify_inbound_failures_job index 763b2c93093cffd97e9c196c68df4a86ec7736af..13696f205f4c0b90f43ac9e21919843d1c8e9d41 100755 --- a/bin/notify_inbound_failures_job +++ b/bin/notify_inbound_failures_job @@ -45,7 +45,7 @@ class BlockedMessage def notification_text "This is an automated notification from JMP " \ - "letting you know that a message from #{@msg['sourceTn']} " \ + "letting you know that a message to you " \ "was blocked by the carrier or otherwise failed " \ "to be delivered at #{@msg['receiveTime']}." end @@ -64,12 +64,12 @@ class BlockedMessage end def to_h - [{ + { time: @msg["receiveTime"], type: "sms", description: "Notification of failed or blocked message", message: notification_body - }].to_json + } end def notify! @@ -77,7 +77,7 @@ class BlockedMessage OPTIONS[:webhook_endpoint], tls: {verify_peer: true} ).post( - body: to_h, + body: [to_h].to_json, head: {"Content-Type"=>"application/json"} ) end @@ -112,11 +112,10 @@ class BandwidthMessages "/messages" def req - req = EM::HttpRequest.new(URL, tls: {verify_peer: true}) - req.use(EM::Middleware::JSONResponse).get( - head: BW_HEAD, - query: @query - ) + EM::HttpRequest + .new(URL, tls: {verify_peer: true}) + .use(EM::Middleware::JSONResponse) + .get(head: BW_HEAD, query: @query) end def for_next_page(res) @@ -159,7 +158,6 @@ EM.run do EMPromise.resolve( redis.mget("bw_last_msg_failed_date", "bw_last_msg_failed_id") ).then { |(last_msg_date, last_msg_id)| - ## Full disclosure, string format came from ChatGPT thirty_mins_ago = (Time.now - 30 * 60).strftime("%Y-%m-%dT%H:%M:%S.%LZ") last_msg_date ||= thirty_mins_ago last_msg_date = [last_msg_date, thirty_mins_ago].max