Contents

require "pact_broker/db/data_migrations/helpers"

module PactBroker
  module DB
    module DataMigrations
      class DeleteDeprecatedWebhookExecutions
        extend Helpers

        def self.call(connection)
          if columns_exist?(connection)
            connection[:webhook_executions].where(triggered_webhook_id: nil).delete
          end
        end

        def self.columns_exist?(connection)
          column_exists?(connection, :webhook_executions, :triggered_webhook_id)
        end
      end
    end
  end
end

Version data entries

45 entries across 45 versions & 1 rubygems

Version	Path
pact_broker-2.84.0	lib/pact_broker/db/data_migrations/delete_deprecated_webhook_executions.rb
pact_broker-2.83.0	lib/pact_broker/db/data_migrations/delete_deprecated_webhook_executions.rb
pact_broker-2.82.0	lib/pact_broker/db/data_migrations/delete_deprecated_webhook_executions.rb
pact_broker-2.81.0	lib/pact_broker/db/data_migrations/delete_deprecated_webhook_executions.rb
pact_broker-2.80.0	lib/pact_broker/db/data_migrations/delete_deprecated_webhook_executions.rb