123456789_123456789_123456789_123456789_123456789_

Module: Mongo::BulkWrite::Validatable Private

Do not use. This module is for internal use only.
Relationships & Source Files
Extension / Inclusion / Inheritance Descendants
Included In:
OrderedCombiner, UnorderedCombiner
Defined in: lib/mongo/bulk_write/validatable.rb

Overview

Defines behavior around validations.

Since:

  • 2.1.0

Instance Method Summary

Instance Method Details

#validate(name, document) ⇒ Hash, BSON::Document

Validate the document.

Examples:

Validate the document.

validatable.validate(:insert_one, { _id: 0 })

Parameters:

  • name (Symbol) —

    The operation name.

  • document (Hash, BSON::Document) —

    The document.

Returns:

  • (Hash, BSON::Document) —

    The document.

Raises:

  • (InvalidBulkOperation) —

    If not valid.

Since:

  • 2.1.0

[ GitHub ] 

  


# File 'lib/mongo/bulk_write/validatable.rb', line 40



def validate(name, document)
  validate_operation(name)
  validate_document(name, document)
  @has_collation = true if document.respond_to?(:keys) && (document[:collation] || document[Operation::COLLATION])

  @has_array_filters = true if document.respond_to?(:keys) && document[:array_filters]

  return unless document.respond_to?(:keys) && document[:hint]

  @has_hint = true
end


  








  

    #validate_document(name, document)   (private)
  



  

    
  





  
Since:


    
  
  • 
    
    2.1.0
    
  
    • 





  [ GitHub ]


  

  


# File 'lib/mongo/bulk_write/validatable.rb', line 54



def validate_document(name, document)
  unless document.respond_to?(:keys) || document.respond_to?(:data)
    raise Error::InvalidBulkOperation.new(name, document)
  end

  document
end


  








  

    #validate_operation(name)   (private)
  



  

    
  





  
Raises:



Since:


    
  
  • 
    
    2.1.0
    
  
    • 





  [ GitHub ]


  

  


# File 'lib/mongo/bulk_write/validatable.rb', line 62



def validate_operation(name)
  return if Transformable::MAPPERS.key?(name)

  raise Error::InvalidBulkOperationType.new(name)
end