update webhook worker to auto-disable frozen endpoints

Author: ezekg

app/workers/webhook_worker.rb

@@ -155,6 +155,14 @@ def perform(account_id, event_id, endpoint_id, event_data)
         event.update!(status: 'FAILED')
         endpoint.disable!
 
+        return
+      in last_response_code: 530
+        Keygen.logger.warn "[webhook_worker] Disabling Frozen endpoint: type=#{event_type.event} account=#{account.id} event=#{event.id} endpoint=#{endpoint.id} url=#{endpoint.url} code=#{res.code}"
+
+        # Automatically disable endpoints returning 530 Frozen
+        event.update!(status: 'FAILED')
+        endpoint.disable!
+
         return
       else
         Keygen.logger.warn "[webhook_worker] Failed webhook event: type=#{event_type.event} account=#{account.id} event=#{event.id} endpoint=#{endpoint.id} url=#{endpoint.url} code=#{res.code}"

spec/services/broadcast_event_service_spec.rb

@@ -249,6 +249,21 @@ def jsonapi_render(resource, account:, meta: nil, **options)
     expect(endpoint.subscriptions).to be_empty
   end
 
+  it 'should disable endpoint when status is 530 Frozen' do
+    allow(WebhookWorker::Request).to receive(:post) {
+      OpenStruct.new(code: 530, body: '530 Frozen')
+    }
+
+    event = nil
+    expect { event = create_webhook_event!(account, resource) }.to_not raise_error
+    expect(event).to_not be_nil
+    expect(event.last_response_body).to eq '530 Frozen'
+    expect(event.last_response_code).to eq 530
+
+    expect { endpoint.reload }.to_not raise_error
+    expect(endpoint.subscriptions).to be_empty
+  end
+
   context 'when endpoint has an environment' do
     before do
       create_list(:webhook_endpoint, 5, :in_isolated_environment, account:)