Sha256: aa53f9ddf73495db23b73330caedc285f9f9977bd9233b587160efe1f2fd18e7
Contents?: true
Size: 2 KB
Versions: 9
Compression:
Stored size: 2 KB
Contents
# frozen_string_literal: true
module Motor
module Queries
module Persistance
NameAlreadyExists = Class.new(StandardError)
module_function
def build_from_params(params, current_user = nil)
query = assign_attributes(Query.new, params)
query.author = current_user
query
end
def create_from_params!(params, current_user = nil)
raise NameAlreadyExists if Query.exists?(['lower(name) = ?', params[:name].to_s.downcase])
query = build_from_params(params, current_user)
ApplicationRecord.transaction do
query.save!
end
query
rescue ActiveRecord::RecordNotUnique
retry
end
def update_from_params!(query, params, force_replace: false)
tag_ids = query.tags.ids
query = assign_attributes(query, params)
raise NameAlreadyExists if !force_replace && name_already_exists?(query)
ApplicationRecord.transaction do
archive_with_existing_name(query) if force_replace
query.save!
end
query.touch if tag_ids.sort != query.tags.reload.ids.sort && params[:updated_at].blank?
query
rescue ActiveRecord::RecordNotUnique
retry
end
def assign_attributes(query, params)
query.assign_attributes(params.slice(:name, :description, :sql_body, :preferences))
query.updated_at = [params[:updated_at], Time.current].min if params[:updated_at].present?
Motor::Tags.assign_tags(query, params[:tags])
end
def archive_with_existing_name(query)
Motor::Query.where(['lower(name) = ? AND id != ?', query.name.to_s.downcase, query.id])
.update_all(deleted_at: Time.current)
end
def name_already_exists?(query)
if query.new_record?
Query.exists?(['lower(name) = ?', query.name.to_s.downcase])
else
Query.exists?(['lower(name) = ? AND id != ?', query.name.to_s.downcase, query.id])
end
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems