Contents

module Locomotive::Steam
  module Adapters
    module MongoDB

      class Command

        def initialize(collection, mapper)
          @collection = collection
          @mapper     = mapper
        end

        def insert(entity)
          # make sure the entity gets a valid id
          entity[:_id] ||= BSON::ObjectId.new

          serialized_entity = @mapper.serialize(entity)

          @collection.insert_one(serialized_entity)

          entity
        end

        def delete(entity)
          @collection.find(_id: entity._id).delete_one if entity._id
        end

      end

    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
locomotivecms_steam-1.0.0	lib/locomotive/steam/adapters/mongodb/command.rb
locomotivecms_steam-1.0.0.rc10	lib/locomotive/steam/adapters/mongodb/command.rb
locomotivecms_steam-1.0.0.rc9	lib/locomotive/steam/adapters/mongodb/command.rb
locomotivecms_steam-1.0.0.rc8	lib/locomotive/steam/adapters/mongodb/command.rb
locomotivecms_steam-1.0.0.rc6	lib/locomotive/steam/adapters/mongodb/command.rb
locomotivecms_steam-1.0.0.rc4	lib/locomotive/steam/adapters/mongodb/command.rb