Contents

# frozen_string_literal: true

require 'apartment/adapters/abstract_adapter'

module Apartment
  module Tenant
    def self.sqlite3_adapter(config)
      Adapters::Sqlite3Adapter.new(config)
    end
  end

  module Adapters
    class Sqlite3Adapter < AbstractAdapter
      def initialize(config)
        @default_dir = File.expand_path(File.dirname(config[:database]))

        super
      end

      def drop(tenant)
        unless File.exist?(database_file(tenant))
          raise TenantNotFound,
                "The tenant #{environmentify(tenant)} cannot be found."
        end

        File.delete(database_file(tenant))
      end

      def current
        File.basename(Apartment.connection.instance_variable_get(:@config)[:database], '.sqlite3')
      end

      protected

      def connect_to_new(tenant)
        unless File.exist?(database_file(tenant))
          raise TenantNotFound,
                "The tenant #{environmentify(tenant)} cannot be found."
        end

        super database_file(tenant)
      end

      def create_tenant(tenant)
        if File.exist?(database_file(tenant))
          raise TenantExists,
                "The tenant #{environmentify(tenant)} already exists."
        end

        begin
          f = File.new(database_file(tenant), File::CREAT)
        ensure
          f.close
        end
      end

      private

      def database_file(tenant)
        "#{@default_dir}/#{environmentify(tenant)}.sqlite3"
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
ros-apartment-2.5.0	lib/apartment/adapters/sqlite3_adapter.rb
ros-apartment-2.4.0	lib/apartment/adapters/sqlite3_adapter.rb