Contents

##
# Manages process to create objects
#
# Usage:
#
#   Manager.new(config, logger).load_files(:before).create_objects
#
# or
#
#   Manager.new(config, logger).load_files(:after).create_objects
class PgObjects::Manager
  attr_reader :objects, :config

  def initialize(config, logger)
    raise PgObjects::UnsupportedAdapterError if ActiveRecord::Base.connection.adapter_name != 'PostgreSQL'

    @objects = []
    @config = config
    @log = logger.mute(config.silent) # Logger.new(silent: config.silent)
  end

  ##
  # event: +:before+ or +:after+
  #
  # used to reference configuration settings +before_path+ and +after_path+
  def load_files(event)
    dir = config.send "#{event}_path"
    Dir[File.join(dir, '**', "*.{#{config.extensions.join(',')}}")].each do |path|
      @objects << PgObjects::DbObject.new(path).create
    end

    self
  end

  def create_objects
    objects.each { create_object(_1) }
  end

  private

  def create_object(obj)
    return if obj.status == :done
    raise PgObjects::CyclicDependencyError, obj.name if obj.status == :processing

    obj.status = :processing

    create_dependencies(obj.dependencies)

    @log.write("creating #{obj.name}")
    ActiveRecord::Base.connection.execute obj.sql_query

    obj.status = :done
  end

  def create_dependencies(dependencies)
    dependencies.each { |dep_name| create_object(find_object(dep_name)) }
  end

  def find_object(dep_name)
    result = @objects.select { |obj| [obj.name, obj.full_name, obj.object_name].compact.include? dep_name }

    raise PgObjects::AmbiguousDependencyError, dep_name if result.size > 1
    raise PgObjects::DependencyNotExistError, dep_name if result.empty?

    result[0]
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
pg_objects-1.2.0	lib/pg_objects/manager.rb