upsert, update and remove bulk

Author: diego herrera

.idea/.gitignore

@@ -1,45 +1,6 @@
-## 3.1.5
-  - Fixed @timestamp handling, BSON::ObjectId generation, close method [#57](https://github.com/logstash-plugins/logstash-output-mongodb/pull/57)
-
-## 3.1.4
-  - Docs: Set the default_codec doc attribute.
-
-## 3.1.3
-  - Update gemspec summary
-
-## 3.1.2
-  - Fix some documentation issues
-
-## 3.1.0
- - Add support for bulk inserts to improve performance.
-
-## 3.0.1
- - Docs: Fix doc generation issue by removing extraneous comments and adding a short description of the plugin
-
-## 3.0.0
- - Breaking: Updated plugin to use new Java Event APIs
- - relax logstash-core-plugin-api constrains
- - update .travis.yml
-
-## 2.0.5
-  - Depend on logstash-core-plugin-api instead of logstash-core, removing the need to mass update plugins on major releases of logstash
-
-## 2.0.4
-  - New dependency requirements for logstash-core for the 5.0 release
-
-## 2.0.3
- - Patch Timestamp and BigDecimal with to_bson method and register with BSON.
-
-## 2.0.0
- - Plugins were updated to follow the new shutdown semantic, this mainly allows Logstash to instruct input plugins to terminate gracefully,
-   instead of using Thread.raise on the plugins' threads. Ref: https://github.com/elastic/logstash/pull/3895
- - Dependency on logstash-core update to 2.0
-
 ## 1.0.0
- - Fixes the plugin to be in the 2.0 series
- - Add integration and unit test to the project
- - Adapt the codebase to be 2.0 compatible
- - Make the internal logger in mongo to report to LS logger
-
-## 0.2.0
- - Add basic registration test to the project
+  - Basic integration for
+    - insert
+    - update
+    - upsert
+    - delete

.idea/logstash-output-mongodb.iml

@@ -2,20 +2,7 @@ The following is a list of people who have contributed ideas, code, bug
 reports, or in general have helped logstash along its way.
 
 Contributors:
-* Aaron Mildenstein (untergeek)
-* Graham Bleach (bleach)
-* John E. Vincent (lusis)
-* Jordan Sissel (jordansissel)
-* Kevin Amorin (kamorin)
-* Kevin O'Connor (kjoconnor)
-* Kurt Hurtado (kurtado)
-* Mathias Gug (zimathias)
-* Pete Fritchman (fetep)
-* Pier-Hugues Pellerin (ph)
-* Richard Pijnenburg (electrical)
-* bitsofinfo (bitsofinfo)
-* Guy Boertje (guyboertje)
-* Colin Surprenant (colinsurprenant)
+* Diego Herrera (lancha90)
 
 Note: If you've sent us patches, bug reports, or otherwise contributed to
 Logstash, and you aren't on the list above and want to be, please let us know

.idea/misc.xml

@@ -87,6 +87,17 @@ bin/plugin install --no-verify
 ```
 - Start Logstash and proceed to test the plugin
 
+## Publish
+
+```sh
+# Build Gem 
+gem build logstash-output-mongo.gemspec 
+
+# Publish Gem
+gem push logstash-output-mongo-1.0.0.gem
+```
+
+
 ## Contributing
 
 All contributions are welcome: ideas, patches, documentation, bug reports, complaints, and even something you drew up on a napkin.

.idea/modules.xml

@@ -33,8 +33,8 @@ module BigDecimal
     #   1.221311.to_bson
     # @return [ String ] The encoded string.
     # @see http://bsonspec.org/#/specification
-    def to_bson(encoded = ''.force_encoding(BINARY))
-      encoded << [ self ].pack(PACK)
+    def to_bson(buffer = ByteBuffer.new, validating_keys = Config.validating_keys?)
+      buffer.put_bytes([ self ].pack(PACK))
     end
 
     module ClassMethods
@@ -44,7 +44,7 @@ module ClassMethods
       # @return [ BigDecimal ] The decoded BigDecimal.
       # @see http://bsonspec.org/#/specification
       def from_bson(bson)
-        from_bson_double(bson.read(8))
+        from_bson_double(bson.get_bytes(8))
       end
 
       private
@@ -63,4 +63,4 @@ def from_bson_double(double)
   # @since 2.0.0
   ::BigDecimal.send(:include, BigDecimal)
   ::BigDecimal.send(:extend, BigDecimal::ClassMethods)
-end
+end

.idea/vcs.xml

@@ -30,7 +30,7 @@ module LogStashEvent
     #   Event.new("field" => "value").to_bson
     # @return [ String ] The encoded string.
     # @see http://bsonspec.org/#/specification
-     def to_bson(buffer = ByteBuffer.new)
+    def to_bson(buffer = ByteBuffer.new, validating_keys = Config.validating_keys?)
       position = buffer.length
       buffer.put_int32(0)
       to_hash.each do |field, value|
@@ -73,4 +73,4 @@ def from_bson(buffer)
   # Enrich the core LogStash::Event class with this module.
   ::LogStash::Event.send(:include, ::LogStashEvent)
   ::LogStash::Event.send(:extend, ::LogStashEvent::ClassMethods)
-end
+end