Contents

# frozen_string_literal: true

# https://upstash.com/docs/qstash/api/messages/cancel
# https://upstash.com/docs/qstash/api/messages/bulk-cancel
module Qstash
  module Message
    class Cancel
      include Qstash::Callable
      attr_reader :message_ids, :headers

      def initialize(message_ids, headers: {})
        @message_ids = Array(message_ids)
        @headers = headers
      end

      def call
        uri = URI(endpoint)
        client = Qstash::HttpClient.new(uri)
        client.delete(body, headers)
      end

      private

      def base_url
        Qstash.config.url.sub(/\/$/, "")
      end

      def body
        (message_ids.length > 1) ? {messageIds: message_ids} : {}
      end

      def endpoint
        [
          base_url,
          (message_ids.length > 1) ? Endpoints::BULK_CANCEL_ENDPOINT : "#{Endpoints::CANCEL_ENDPOINT}/#{message_ids.first}"
        ].join("/")
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
qstash-rb-0.1.3	lib/qstash/message/cancel.rb