Contents

module Octopus
  class ScopeProxy < BasicObject
    include ::Octopus::ShardTracking::Attribute

    module CaseFixer
      def ===(other)
        other = other.klass while ::Octopus::ScopeProxy === other
        super
      end
    end

    attr_accessor :klass

    # Dup and clone should be delegated to the class.
    # We want to dup the query, not the scope proxy.
    delegate :dup, :clone, to: :klass

    def initialize(shard, klass)
      @current_shard = shard
      @klass = klass
    end

    def using(shard)
      fail "Nonexistent Shard Name: #{shard}" if @klass.connection.shards[shard].nil?
      @current_shard = shard
      self
    end

    # Transaction Method send all queries to a specified shard.
    def transaction(options = {}, &block)
      run_on_shard { klass.transaction(**options, &block) }
    end

    def connection
      @klass.connection_proxy.current_shard = @current_shard

      if @klass.custom_octopus_connection && @klass.allowed_shard?(@current_shard)
        # Force use of proxy, given we called 'using' explicitly to get here
        @klass.connection_proxy.current_model = @klass
        @klass.connection_proxy
      else
        @klass.connection
      end
    end

    def method_missing(method, *args, &block)
      result = run_on_shard { @klass.__send__(method, *args, &block) }
      if result.respond_to?(:all)
        return ::Octopus::ScopeProxy.new(current_shard, result)
      end

      if result.respond_to?(:current_shard)
        result.current_shard = current_shard
      end

      result
    end

    # Delegates to method_missing (instead of @klass) so that User.using(:blah).where(:name => "Mike")
    # gets run in the correct shard context when #== is evaluated.
    def ==(other)
      method_missing(:==, other)
    end
    alias_method :eql?, :==
  end
end

ActiveRecord::Relation.extend(Octopus::ScopeProxy::CaseFixer)

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
ar-octopus-ruby-3-0.11.3	lib/octopus/scope_proxy.rb
ar-octopus-ruby-3-0.11.2	lib/octopus/scope_proxy.rb