Module: MongoidVersionedAtomic::VAtomic::ClassMethods

Defined in:
lib/mongoid_versioned_atomic/v_atomic.rb

Instance Method Summary collapse

Instance Method Details

#after_persist(doc, instance) ⇒ Object

return [Boolean] : always returns true.



127
128
129
130
131
132
133
134
135
136
137
138
 
# File 'lib/mongoid_versioned_atomic/v_atomic.rb', line 127

def after_persist(doc,instance)
    doc.keys.each do |f|
      if f == "version"
        instance.send("#{f}=",doc[f])
      else
        if instance.send("#{f}") != doc[f]
          instance.send("#{f}=",doc[f])
        end
      end
    end
  return true
end

#before_persist(options, update, bypass_versioning = false) ⇒ Array

Returns : returns the options, and update.

Returns:

  • (Array) —

    : returns the options, and update.



101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
 
# File 'lib/mongoid_versioned_atomic/v_atomic.rb', line 101

def before_persist(options,update,bypass_versioning=false)

  options[:return_document] = :after

  if !bypass_versioning
if update["$inc"].nil?
update["$inc"] = {
  "version" => 1 }
          else
update["$inc"]["version"] = 1
          end
        end

        return options,update

end

#bson_to_mongoid(bson_doc, klass) ⇒ Object

converts a bson_doc to the target klass instance. return [Object] : either the document in the target class or nil.

Parameters:

  • bson_doc (BSON Document) —

    : a bson_document instance

  • klass (klass) —

    : klass of the target document.



41
42
43
44
45
46
47
48
49
50
51
52
53
 
# File 'lib/mongoid_versioned_atomic/v_atomic.rb', line 41

def bson_to_mongoid(bson_doc,klass)
  if !bson_doc.nil?
    
    t = Mongoid::Factory.from_db(klass,bson_doc)
    return t

  else

    return nil

  end

end

#log_opts(query, update, options, create_or_update, log) ⇒ Object

logs



141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
 
# File 'lib/mongoid_versioned_atomic/v_atomic.rb', line 141

def log_opts(query,update,options,create_or_update,log)

  if log

    puts "doing-------------------- #{create_or_update}"


    puts "the query is :"
    puts JSON.pretty_generate(query)

    puts "the update is"
    puts JSON.pretty_generate(update)

    puts "the options are"
    puts JSON.pretty_generate(options)
  
  end

end

#versioned_upsert_one(query = {}, update = {}, klass = nil, upsert = true, log = false, bypass_versioning = false) ⇒ Object

Returns mongoid document instance or nil(if the update hash was empty). You need to check the document to see whether it has the changes you requested.

Returns:

  • mongoid document instance or nil(if the update hash was empty). You need to check the document to see whether it has the changes you requested.



75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
 
# File 'lib/mongoid_versioned_atomic/v_atomic.rb', line 75

def versioned_upsert_one(query={},update={},klass=nil,upsert=true,log=false,bypass_versioning=false)
  
  options = {}

  if query.empty?
    bypass_versioning = true
  end

  options,update = before_persist(options,update,bypass_versioning)
  
        options[:upsert] = upsert
        if !update.empty?
          return bson_to_mongoid(collection.find_one_and_update(query,update,options),klass)
        end

        return nil

end