Method: ReactiveRecord::Base#send_save_to_server

Defined in:

lib/reactive_record/active_record/reactive_record/isomorphic_base.rb

#send_save_to_server(save, validate, force, &block) ⇒ Object

# File 'lib/reactive_record/active_record/reactive_record/isomorphic_base.rb', line 264

def send_save_to_server(save, validate, force, &block)
  models, associations, backing_records = self.class.gather_records([self], force, self)

  begin
    backing_records.each { |id, record| record.saving! } if save

    promise = Promise.new
    Operations::Save.run(models: models, associations: associations, save: save, validate: validate)
    .then do |response|
      begin
        response[:models] = response[:saved_models].collect do |item|
          backing_records[item[0]].ar_instance
        end

        if save
          if response[:success]
            response[:saved_models].each do |item|
              Broadcast.to_self backing_records[item[0]].ar_instance, item[2]
            end
          else
            log(response[:message], :error)
            response[:saved_models].each do |item|
              log("  Model: #{item[1]}[#{item[0]}]  Attributes: #{item[2]}  Errors: #{item[3]}", :error) if item[3]
            end
          end
        end

        response[:saved_models].each do | item |
          backing_records[item[0]].sync_unscoped_collection! if save
          backing_records[item[0]].errors! item[3]
        end

        yield response[:success], response[:message], response[:models]  if block
        promise.resolve response  # TODO this could be problematic... there was no .json here, so .... what's to do?

      rescue Exception => e
        # debugger
        log("Exception raised while saving - #{e}", :error)
      ensure
        backing_records.each { |_id, record| record.saved! rescue nil } if save
      end
    end
    promise
  rescue Exception => e
    backing_records.each { |_id, record| record.saved!(true) rescue nil } if save
  end
rescue Exception => e
  debugger
  log("Exception raised while saving - #{e}", :error)
  yield false, e.message, [] if block
  promise.resolve({success: false, message: e.message, models: []})
  promise
end