Sha256: acd41c9a75909a24cb5488b1143dc8729eb3180d3d97d3be655d9093b4b8e078

Contents?: true

Size: 1.69 KB

Versions: 30

Compression:

Stored size: 1.69 KB

Contents

module ActiveRecord

  class Base

    def self.reflect_on_all_aggregations
      base_class.instance_eval { @aggregations ||= [] }
    end

    def self.reflect_on_aggregation(attribute)
      reflect_on_all_aggregations.detect { |aggregation| aggregation.attribute == attribute }
    end

  end

  module Aggregations

    class AggregationReflection

      attr_reader :klass_name
      attr_reader :attribute
      attr_reader :mapped_attributes
      attr_reader :constructor

      def construct(args)

      end

      def initialize(owner_class, macro, name, options = {})
        owner_class.reflect_on_all_aggregations << self
        @owner_class = owner_class
        @constructor = options[:constructor] || :new
        @klass_name =  options[:class_name] || name.camelize
        @attribute =   name
        if options[:mapping].respond_to? :collect
          @mapped_attributes = options[:mapping].collect &:last
        else
          ReactiveRecord::Base.log("improper aggregate definition #{@owner_class}, :#{name}, class_name: #{@klass_name} - missing mapping", :error)
          @mapped_attributes = []
        end
      end

      def klass
        @klass ||= Object.const_get(@klass_name)
      end

      def serialize(object)
        if object.nil?
          object # return dummy value if that is what we got
        else
          @mapped_attributes.collect { |attr| object.send(attr) }
        end
      end

      def deserialize(array)
        if array.nil?
          array # return dummy value if that is what we got
        elsif @constructor.respond_to?(:call)
          @constructor.call(*array)
        else
          klass.send(@constructor, *array)
        end
      end

    end

  end


end

Version data entries

30 entries across 30 versions & 2 rubygems

Version Path
hyper-mesh-0.6.0 lib/reactive_record/active_record/aggregations.rb
hyper-mesh-0.5.4 lib/reactive_record/active_record/aggregations.rb
hyper-mesh-0.5.3 lib/reactive_record/active_record/aggregations.rb
hyper-mesh-0.5.2 lib/reactive_record/active_record/aggregations.rb
hyper-mesh-0.5.1 lib/reactive_record/active_record/aggregations.rb
hyper-mesh-0.5.0 lib/reactive_record/active_record/aggregations.rb
hyper-mesh-0.4.0 lib/reactive_record/active_record/aggregations.rb
reactive-record-0.8.3 lib/reactive_record/active_record/aggregations.rb
reactive-record-0.8.2 lib/reactive_record/active_record/aggregations.rb
reactive-record-0.8.1 lib/reactive_record/active_record/aggregations.rb
reactive-record-0.7.43 lib/reactive_record/active_record/aggregations.rb
reactive-record-0.7.42 lib/reactive_record/active_record/aggregations.rb
reactive-record-0.7.41 lib/reactive_record/active_record/aggregations.rb
reactive-record-0.7.40 lib/reactive_record/active_record/aggregations.rb
reactive-record-0.7.39 lib/reactive_record/active_record/aggregations.rb
reactive-record-0.7.38 lib/reactive_record/active_record/aggregations.rb
reactive-record-0.7.37 lib/reactive_record/active_record/aggregations.rb
reactive-record-0.7.36 lib/reactive_record/active_record/aggregations.rb
reactive-record-0.7.35 lib/reactive_record/active_record/aggregations.rb
reactive-record-0.7.34 lib/reactive_record/active_record/aggregations.rb