class Apartment::Adapters::PostgresqlSchemaFromSqlAdapter

def check_input_against_regexps(input, regexps)
  regexps.select {|c| input.match c}
end

def clone_pg_schema
  pg_schema_sql = patch_search_path(pg_dump_schema)
  Apartment.connection.execute(pg_schema_sql)
end

def collect_table_names(models)
  models.map do |m|
    m.constantize.table_name
  end
end

def copy_schema_migrations
  pg_migrations_data = patch_search_path(pg_dump_schema_migrations_data)
  Apartment.connection.execute(pg_migrations_data)
end

def dbname
  ActiveRecord::Base.connection_config[:database]
end

def default_schema
  Apartment.default_schema
end

def import_database_schema
  clone_pg_schema
  copy_schema_migrations
end

def patch_search_path(sql)
  search_path = "SET search_path = \"#{current}\", #{default_schema};"
  sql
    .split("\n")
    .select {|line| check_input_against_regexps(line, PSQL_DUMP_BLACKLISTED_STATEMENTS).empty?}
    .prepend(search_path)
    .join("\n")
end

def pg_dump_schema
  # Skip excluded tables? :/
  # excluded_tables =
  #   collect_table_names(Apartment.excluded_models)
  #   .map! {|t| "-T #{t}"}
  #   .join(' ')
  # `pg_dump -s -x -O -n #{default_schema} #{excluded_tables} #{dbname}`
  `pg_dump -s -x -O -n #{default_schema} #{dbname}`
end

def pg_dump_schema_migrations_data
  `pg_dump -a --inserts -t schema_migrations -n #{default_schema} #{dbname}`
end