Sha256: fcc1bed98a0b5f602d39e445ce0f82ecc6b8ec3fdf5ee0fa66ac1f87840e5413
Contents?: true
Size: 1.71 KB
Versions: 14
Compression:
Stored size: 1.71 KB
Contents
module SuperForm
module AtomicSave
extend ActiveSupport::Concern
included do
include ActiveSupport::Callbacks
define_callbacks :transaction, :queries, :validations
def self.before_transaction(method_name)
set_callback :transaction, :before, method_name
end
def self.before_queries(method_name)
set_callback :queries, :before, method_name
end
def self.before_commit(method_name)
set_callback :queries, :after, method_name
end
def self.after_commit(method_name)
set_callback :transaction, :after, method_name
end
def self.before_validations(method_name)
set_callback :validations, :after, method_name
end
def self.after_validations(method_name)
set_callback :validations, :after, method_name
end
end
ReformAtomicSaveError = Class.new(StandardError)
def save_with_transaction(params={}, &block)
begin
save_with_transaction!(params, &block)
rescue ReformAtomicSaveError
false
end
end
def save_with_transaction!(params={}, &block)
run_callbacks :transaction do
ActiveRecord::Base.transaction do
run_callbacks :queries do
# 1. do validate data
run_callbacks :validations do
if validate(params) == false
raise ReformAtomicSaveError, "Not Validate => #{self.errors.full_messages.inspect}"
end
end
# 2. sync to model
sync
# 2. define how to store data in block
yield if block_given?
# 3. save all data
save!
end
end
end
true
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems