Module: CouchbaseOrm::Associations

Extended by:
ActiveSupport::Concern
Included in:
Base
Defined in:
lib/couchbase-orm/associations.rb

Defined Under Namespace

Modules: ClassMethods

Instance Method Summary collapse

Instance Method Details

#destroy_associations! ⇒ Object 



181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
 
# File 'lib/couchbase-orm/associations.rb', line 181

def destroy_associations!
    assoc = self.class.associations
    assoc.each do |name, dependent|
        next unless dependent

        model = self.__send__(name)
        if model.present?
            case dependent
            when :destroy, :delete
                if model.respond_to?(:stream)
                    model.stream { |mod| mod.__send__(dependent) }
                elsif model.is_a?(Array) || model.is_a?(CouchbaseOrm::ResultsProxy)
                    model.each { |m| m.__send__(dependent) }
                else
                    model.__send__(dependent)
                end
            when :restrict_with_exception
                raise RecordExists.new("#{self.class.name} instance maintains a restricted reference to #{name}", self)
            when :restrict_with_error
                # TODO::
            end
        end
    end
end

#reset_associations ⇒ Object 



206
207
208
209
210
211
212
 
# File 'lib/couchbase-orm/associations.rb', line 206

def reset_associations
    assoc = self.class.associations
    assoc.each do |name, _|
        instance_var = :"@__assoc_#{name}"
        remove_instance_variable(instance_var) if instance_variable_defined?(instance_var)
    end
end

#update_has_and_belongs_to_many_reverse_association(assoc, keys, is_add, **options) ⇒ Object 



152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
 
# File 'lib/couchbase-orm/associations.rb', line 152

def update_has_and_belongs_to_many_reverse_association(assoc, keys, is_add, **options)
    remote_method = options[:inverse_of] || self.class.to_s.pluralize.underscore.to_sym
    return if keys.empty?

    models = if options[:polymorphic]
              ::CouchbaseOrm.try_load(keys)
          else
              assoc.constantize.find(keys, quiet: true)
          end
    models = Array.wrap(models)
    models.each do |v|
        next unless v.respond_to?(remote_method)

        tab = v.__send__(remote_method) || []
        index = tab.find_index(self)
        if is_add && !index
            tab = tab.dup
            tab.push(self)
        elsif !is_add && index
            tab = tab.dup
            tab.delete_at(index)
        else
            next
        end
        v[remote_method] = tab
        v.save!
    end
end