module IdempotentBlock

# File lib/idempotent_block.rb, line 4
def self.included(base)
  base.extend(ClassMethods)
end

# File lib/idempotent_block.rb, line 22
def executed?
  @executed ||= false
end

# File lib/idempotent_block.rb, line 18
def finished?
  @finished ||= record_exist?
end

# File lib/idempotent_block.rb, line 26
def start(force: false)
  self.class.transaction do
    yield

    begin
      save!
    rescue ActiveRecord::RecordNotUnique
      raise ActiveRecord::Rollback unless force
    end

    @finished = true
    @executed = true
  end
end

# File lib/idempotent_block.rb, line 43
def record_exist?
  self.class.exists?(self.class.idempotent_columns.map { |k| [k, send(k)] }.to_h)
end