controllers_async_action_controller.rb

class AsyncActionsController < ApplicationController
  def show
    async_action = AsyncAction.find_by!(
      user: current_user,
      token: params[:id],
    )

    if @async_action.completed?
      case @async_action.action.fetch('kind')
      in 'redirect'
        redirect_to @async_action.action.fetch('path'), notice: @async_action.action['notice']
      end
    end
  end
end

job_async_action_complete.rb

class AsyncAction::CompleteJob < ApplicationJob
  def perform(action)
    action.update!(completed_at: Time.current) if action.completed_at.nil?
  end
end

job_async_action_expire_cron_job

# frozen_string_literal: true

class AsyncAction::ExpireCronJob < ApplicationJob
  def perform
    AsyncAction.expired.destroy_all
  end
end

lib_async_action_redirect.rb

module AsyncAction::Redirect
  extend self

  def call(user:, path:, notice:, job_class:, job_params:)
    action = AsyncAction.create!(
      user: user,
      action: {
        'kind' => 'redirect',
        'path' => path,
        'notice' => notice,
      },
    )

    batch = AngryBatch.new(label: "async_action: #{action.id}")
    batch.enqueue job_class, *Array(job_params)
    batch.on_complete AsyncAction::CompleteJob, action

    batch.perform_later

    action
  end
end

migration_create_async_action.rb

class CreateAsyncAction < ActiveRecord::Migration[8.0]
  def change
    create_table :async_actions do |t|
      t.references :user, null: true, foreign_key: true, index: true
      t.string :token, null: false, index: { unique: true }
      t.jsonb :action, null: false, default: {}
      t.datetime :completed_at, null: true
      t.timestamps
    end
  end
end

model_async_action.rb

# frozen_string_literal: true

# == Schema Information
#
# Table name: async_actions
#
#  id           :bigint(8)        not null, primary key
#  action       :jsonb            not null
#  completed_at :datetime
#  token        :string           not null
#  created_at   :datetime         not null
#  updated_at   :datetime         not null
#  user_id      :bigint(8)
#
# Indexes
#
#  index_async_actions_on_token    (token) UNIQUE
#  index_async_actions_on_user_id  (user_id)
#
# Foreign Keys
#
#  fk_rails_...  (user_id => users.id)
#
class AsyncAction < ApplicationRecord
  belongs_to :user, inverse_of: :async_actions

  has_secure_token :token, length: 24

  class << self
    def expired
      completed = where('completed_at > ?', 2.days.ago)
      failed = where(completed_at: nil).where('created_at < ?', 4.weeks.ago)

      completed.or(failed)
    end
  end

  def completed?
    completed_at.present?
  end
end