module Gemstash

# File lib/gemstash/env.rb, line 48
def self.available?
  !Thread.current[:gemstash_env].nil?
end

# File lib/gemstash/env.rb, line 52
def self.current
  raise EnvNotSetError unless Thread.current[:gemstash_env]

  Thread.current[:gemstash_env]
end

# File lib/gemstash/env.rb, line 58
def self.current=(value)
  Thread.current[:gemstash_env] = value
end

# File lib/gemstash/env.rb, line 145
def self.migrate(db)
  Sequel.extension :migration
  migrations_dir = File.expand_path("migrations", __dir__)
  Sequel::Migrator.run(db, migrations_dir, :use_transactions => true)
end

# File lib/gemstash/env.rb, line 42
def initialize(config = nil, cache: nil, db: nil)
  @config = config
  @cache = cache
  @db = db
end

# File lib/gemstash/env.rb, line 115
def atomic_write(file, &block)
  File.atomic_write(file, File.dirname(file), &block)
end

# File lib/gemstash/env.rb, line 90
def base_file(path)
  File.join(base_path, path)
end

# File lib/gemstash/env.rb, line 78
def base_path
  dir = config[:base_path]

  if config.default?(:base_path)
    FileUtils.mkpath(dir) unless Dir.exist?(dir)
  else
    raise "Base path '#{dir}' is not writable" unless File.writable?(dir)
  end

  dir
end

# File lib/gemstash/env.rb, line 151
def cache
  @cache ||= Gemstash::Cache.new(cache_client)
end

# File lib/gemstash/env.rb, line 155
def cache_client
  @cache_client ||= begin
    case config[:cache_type]
    when "memory"
      Gemstash::LruReduxClient.new
    when "memcached"
      Dalli::Client.new(config[:memcached_servers])
    when "redis"
      Gemstash::RedisClient.new(config[:redis_servers])
    else
      raise "Invalid cache client: '#{config[:cache_type]}'"
    end
  end
end

# File lib/gemstash/env.rb, line 62
def config
  @config ||= Gemstash::Configuration.new
end

# File lib/gemstash/env.rb, line 66
def config=(value)
  reset
  @config = value
end

# File lib/gemstash/env.rb, line 123
def db
  @db ||= begin
    case config[:db_adapter]
    when "sqlite3"
      db_path = base_file("gemstash.db")

      db = if RUBY_PLATFORM == "java"
        Sequel.connect("jdbc:sqlite:#{db_path}", config.database_connection_config)
      else
        Sequel.connect("sqlite://#{CGI.escape(db_path)}", config.database_connection_config)
      end
    when "postgres", "mysql", "mysql2"
      db = Sequel.connect(config[:db_url], config.database_connection_config)
    else
      raise "Unsupported DB adapter: '#{config[:db_adapter]}'"
    end

    Gemstash::Env.migrate(db)
    db
  end
end

# File lib/gemstash/env.rb, line 94
def log_file
  if config[:log_file] == :stdout
    $stdout
  else
    base_file(config[:log_file] || "server.log")
  end
end

# File lib/gemstash/env.rb, line 102
def pidfile
  if config[:pidfile]
    pathname = Pathname.new(config[:pidfile])
    if pathname.relative?
      base_file(pathname.to_s)
    else
      pathname.to_s
    end
  else
    base_file("puma.pid")
  end
end

# File lib/gemstash/env.rb, line 119
def rackup
  File.expand_path("config.ru", __dir__)
end

# File lib/gemstash/env.rb, line 71
def reset
  @config = nil
  @cache = nil
  @cache_client = nil
  @db = nil
end