Sha256: faa3150faed5bb9db125160f9c858c30c4090d7e3159e4a68287ed73716a6864
Contents?: true
Size: 1.32 KB
Versions: 7
Compression:
Stored size: 1.32 KB
Contents
# frozen_string_literal: true
require 'active_job'
module WCC::Contentful
class WebhookEnableJob < ActiveJob::Base
self.queue_adapter = :async
queue_as :default
def perform(args)
client = WCC::Contentful::SimpleClient::Management.new(
args
)
enable_webhook(client, args.slice(:app_url, :webhook_username, :webhook_password))
end
def enable_webhook(client, app_url:, webhook_username: nil, webhook_password: nil)
expected_url = URI.join(app_url, 'webhook/receive').to_s
webhook = client.webhook_definitions.items.find { |w| w['url'] == expected_url }
logger.debug "existing webhook: #{webhook.inspect}" if webhook
return if webhook
body = {
'name' => 'WCC::Contentful webhook',
'url' => expected_url,
'topics' => [
'*.publish',
'*.unpublish'
]
}
body['httpBasicUsername'] = webhook_username if webhook_username.present?
body['httpBasicPassword'] = webhook_password if webhook_password.present?
begin
resp = client.post_webhook_definition(body)
logger.info "Created webhook: #{resp.raw.dig('sys', 'id')}"
rescue WCC::Contentful::SimpleClient::ApiError => e
logger.error "#{e.response.code}: #{e.response.raw}" if e.response
raise
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems