Fixes test units, updated readme

Author: zookzook

CHANGELOG.md

@@ -1,11 +1,16 @@
+## v0.5.2
+
+* Enhancements
+  * Added `op_msg` support ([See](https://docs.mongodb.com/manual/reference/mongodb-wire-protocol/#op-msg))
+  
 ## v0.5.1
 
 * Enhancements
-  * upgraded to DBConnection 2.0.6
-  * refactored code, simplified code and api
-  * replaced deprecated op_code by database commands
-  * update_one, update_many, replace_one, replace_many return upserted ids
-  * support for all find options
+  * Upgraded to DBConnection 2.0.6
+  * Refactored code, simplified code and api
+  * Replaced deprecated op_code by database commands
+  * Update_one, update_many, replace_one, replace_many return upserted ids
+  * Support for all find options
   * Support for MongoDB 3.6 collection [Change Streams](https://docs.mongodb.com/manual/changeStreams/)
   * Support for SCRAM-SHA-256 (MongoDB 4.x)
 

README.md

@@ -25,7 +25,7 @@ to implement the current requirements for the driver.
   * [x] Removed depreacated op codes ([See](https://docs.mongodb.com/manual/reference/mongodb-wire-protocol/#request-opcodes))
   * [x] Support for SCRAM-SHA-256 (MongoDB 4.x)
   * [x] Support for change streaming api ([See](https://github.com/mongodb/specifications/blob/master/source/change-streams/change-streams.rst))
-  * [ ] Add `op_msg` support ([See](https://docs.mongodb.com/manual/reference/mongodb-wire-protocol/#op-msg))
+  * [x] Add `op_msg` support ([See](https://docs.mongodb.com/manual/reference/mongodb-wire-protocol/#op-msg))
   * [ ] driver sessions ([See](https://github.com/mongodb/specifications/blob/master/source/sessions/driver-sessions.rst))
   * [ ] driver transactions ([See](https://github.com/mongodb/specifications/blob/master/source/transactions/transactions.rst)) 
   * [ ] Because the driver is used in production environments, quick adjustments are necessary.

lib/mongo.ex

@@ -576,7 +576,7 @@ defmodule Mongo do
   defp check_for_error(%{"ok" => ok} = response) when ok == 1 do
     {:ok, response}
   end
-  defp check_for_error(%{"code" => code, "codeName" => _name, "errmsg" => msg}) do
+  defp check_for_error(%{"code" => code, "errmsg" => msg}) do
     {:error, Mongo.Error.exception(message: msg, code: code)}
   end
 
@@ -945,11 +945,12 @@ defmodule Mongo do
     # from the specs
     # https://github.com/mongodb/specifications/blob/f4bb783627e7ed5c4095c5554d35287956ef8970/source/enumerate-collections.rst#post-mongodb-280-rc3-versions
     #
-    # In versions 2.8.0-rc3 and later, the listCollections command returns a cursor!
-    #
     cmd = [listCollections: 1]
     cursor(topology_pid, cmd, opts)
-    |> Stream.filter(fn coll -> coll["type"] == "collection" end)
+    |> Stream.filter(fn
+      %{"type" => name} -> name == "collection"
+      _                 -> true
+    end)
     |> Stream.map(fn coll -> coll["name"] end)
   end
 

lib/mongo_db_connection/utils.ex

@@ -59,11 +59,9 @@ defmodule Mongo.MongoDBConnection.Utils do
 
   def get_doc(op_reply() = response) do
     case response do
-      op_reply(flags: flags, docs: [%{"$err" => reason, "code" => code}]) when (@reply_query_failure &&& flags) != 0 -> {:error, Mongo.Error.exception(message: reason, code: code)}
-      op_reply(flags: flags) when (@reply_cursor_not_found &&& flags) != 0 -> {:error, Mongo.Error.exception(message: "cursor not found")}
-      op_reply(docs: [%{"ok" => 0.0, "errmsg" => reason} = error])         -> {:error, %Mongo.Error{message: "command failed: #{reason}", code: error["code"]}}
-      op_reply(docs: [%{"ok" => ok} = doc]) when ok == 1                   -> {:ok, doc}
-      op_reply(docs: [])                                                   -> {:ok, nil}
+      op_reply(docs: [])    -> {:ok, nil}
+      op_reply(docs: [doc]) -> {:ok, doc}
+      op_reply(docs: docs)  -> {:ok, docs}
     end
   end
   def get_doc(op_msg(flags: _flags, sections: sections)) do

test/mongo_test.exs

@@ -17,15 +17,12 @@ defmodule Mongo.Test do
 
   test "command", c do
     assert {:ok, %{"ok" => 1.0}} = Mongo.command(c.pid, [ping: true])
-    assert {:error, %Mongo.Error{}} =
-      Mongo.command(c.pid, [drop: "unexisting-database"])
+    assert {:error, %Mongo.Error{}} = Mongo.command(c.pid, [drop: "unexisting-database"])
   end
 
   test "command!", c do
     assert %{"ok" => 1.0} = Mongo.command!(c.pid, [ping: true])
-    assert_raise Mongo.Error, fn ->
-      Mongo.command!(c.pid, [drop: "unexisting-database"])
-    end
+    assert_raise Mongo.Error, fn -> Mongo.command!(c.pid, [drop: "unexisting-database"]) end
   end
 
   test "show_collections", c do