Remember and use an identifier for the duration of the conversation.

Author: zookzook

lib/mongo/auth/scram.ex

@@ -31,7 +31,7 @@ defmodule Mongo.Auth.SCRAM do
     end
   end
 
-  defp first(%{"conversationId" => 1, "payload" => server_payload, "done" => false}, first_bare, username, password, client_nonce, digest) do
+  defp first(%{"conversationId" => conversation_id, "payload" => server_payload, "done" => false}, first_bare, username, password, client_nonce, digest) do
 
     params          = parse_payload(server_payload)
     server_nonce    = params["r"]
@@ -47,18 +47,18 @@ defmodule Mongo.Auth.SCRAM do
     server_signature     = generate_signature(salted_password, auth_message, digest)
     proof                = generate_proof(salted_password, auth_message, digest)
     client_final_message = %BSON.Binary{binary: "#{client_message},#{proof}"}
-    message              = [saslContinue: 1, conversationId: 1, payload: client_final_message]
+    message              = [saslContinue: 1, conversationId: conversation_id, payload: client_final_message]
 
     {message, server_signature}
   end
 
-  defp second(%{"conversationId" => 1, "payload" => payload, "done" => false}, signature) do
+  defp second(%{"conversationId" => conversation_id, "payload" => payload, "done" => false}, signature) do
     params = parse_payload(payload)
     ^signature = params["v"] |> Base.decode64!
-    [saslContinue: 1, conversationId: 1, payload: %BSON.Binary{binary: ""}]
+    [saslContinue: 1, conversationId: conversation_id, payload: %BSON.Binary{binary: ""}]
   end
 
-  defp final(%{"conversationId" => 1, "payload" => %BSON.Binary{binary: ""}, "done" => true}) do
+  defp final(%{"conversationId" => _, "payload" => %BSON.Binary{binary: ""}, "done" => true}) do
     :ok
   end