# frozen_string_literal: true

require 'pathname'
require 'fileutils'

module ROM
  module SQL
    module RakeSupport
      MissingEnv = Class.new(StandardError)

      class << self
        def run_migrations(options = {})
          gateway.run_migrations(migration_options.merge(options))
        end

        def create_migration(*args)
          gateway.migrator.create_file(*args)
        end

        # Global environment used for running migrations. You normally
        # set in the `db:setup` task with `ROM::SQL::RakeSupport.env = ROM.container(...)`
        # or something similar.
        #
        # @api public
        attr_accessor :env


        # Migration options, which are passed to `ROM::SQL::RakeSupport.run_migrations`. You can 
        # set them in the `db:setup` task with `ROM::SQL::RakeSupport.migration_options = { ... }`
        #
        # @api public
        attr_accessor :migration_options

        private

        def gateway
          if env.nil?
            Gateway.instance ||
              raise(
                MissingEnv,
                'Set up a configuration with ROM::SQL::RakeSupport.env= in the db:setup task'
              )
          else
            env.gateways[:default]
          end
        end
      end

      @env = nil
      @migration_options = {}
    end
  end
end

namespace :db do
  task :rom_configuration do
    Rake::Task['db:setup'].invoke
  end

  desc 'Perform migration reset (full erase and migration up)'
  task reset: :rom_configuration do
    ROM::SQL::RakeSupport.run_migrations(target: 0)
    ROM::SQL::RakeSupport.run_migrations
    puts '<= db:reset executed'
  end

  desc 'Migrate the database (options [version_number])]'
  task :migrate, [:version] => :rom_configuration do |_, args|
    version = args[:version]

    if version.nil?
      ROM::SQL::RakeSupport.run_migrations
      puts '<= db:migrate executed'
    else
      ROM::SQL::RakeSupport.run_migrations(target: version.to_i)
      puts "<= db:migrate version=[#{version}] executed"
    end
  end

  desc 'Perform migration down (removes all tables)'
  task clean: :rom_configuration do
    ROM::SQL::RakeSupport.run_migrations(target: 0)
    puts '<= db:clean executed'
  end

  desc 'Create a migration (parameters: NAME, VERSION)'
  task :create_migration, [:name, :version] => :rom_configuration do |_, args|
    name, version = args.values_at(:name, :version)

    if name.nil?
      puts "No NAME specified. Example usage:
        `rake db:create_migration[create_users]`"
      exit
    end

    path = ROM::SQL::RakeSupport.create_migration(*[name, version].compact)

    puts "<= migration file created #{path}"
  end
end