Contents

class Outbox
  include Mongoid::Document
  include Mongoid::Timestamps
  include SimpleEnum::Mongoid

  attr_accessor :allow_publish

  # Fields
  field :status, type: String, default: 'pending'
  field :size, type: String, default: 'single'

  field :exchange, type: String, default: ''
  field :routing_key, type: String, default: ''

  field :attempts, type: Integer, default: 0

  field :last_attempted_at, type: DateTime, default: nil

  field :retry_at, type: DateTime, default: nil

  field :payload, type: Hash, default: {}
  field :headers, type: Hash, default: {}

  before_save :check_publishing

  # Callbacks
  before_create :set_last_attempted_at
  after_commit :publish, if: :allow_publish?

  # Enums
  as_enum :status, { pending: 0, processing: 1, published: 2, failed: 3 }, pluralize_scopes: false, map: :string
  as_enum :size, { single: 0, batch: 1 }, pluralize_scopes: false, map: :string

  # Validations
  validates :payload, :exchange, :routing_key, presence: true

  # Associations
  belongs_to :outboxable, polymorphic: true, optional: true

  def set_last_attempted_at
    self.last_attempted_at = 10.seconds.from_now
  end

  def publish
    Outboxable::Worker.perform_async(id)
    update(status: :processing, last_attempted_at: 1.minute.from_now, allow_publish: false)
  end

  def check_publishing
    self.allow_publish = false if published?
  end

  def allow_publish
    @allow_publish || true
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
outboxable-1.0.0	lib/templates/mongoid_outbox.rb