CDRIVER-837: Parse readConcernLevel from the connection string

Author: bjori

src/mongoc/mongoc-uri.c

@@ -623,6 +623,8 @@ mongoc_uri_parse_option (mongoc_uri_t *uri,
    } else if (!strcasecmp(key, "authmechanism") ||
               !strcasecmp(key, "authsource")) {
       bson_append_utf8(&uri->credentials, key, -1, value, -1);
+   } else if (!strcasecmp(key, "readconcernlevel")) {
+      mongoc_read_concern_set_level (uri->read_concern, value);
    } else if (!strcasecmp(key, "authmechanismproperties")) {
       if (!mongoc_uri_parse_auth_mechanism_properties(uri, value)) {
          bson_free(key);
@@ -926,6 +928,9 @@ mongoc_uri_new (const char *uri_string)
    /* Initialize read_prefs since tag parsing may add to it */
    uri->read_prefs = mongoc_read_prefs_new(MONGOC_READ_PRIMARY);
 
+   /* Initialize empty read_concern */
+   uri->read_concern = mongoc_read_concern_new ();
+
    if (!uri_string) {
       uri_string = "mongodb://127.0.0.1/";
    }
@@ -943,7 +948,7 @@ mongoc_uri_new (const char *uri_string)
       mongoc_uri_destroy(uri);
       return NULL;
    }
-   
+
    _mongoc_uri_build_write_concern (uri);
 
    if (!_mongoc_write_concern_is_valid(uri->write_concern)) {

tests/test-mongoc-uri.c

@@ -707,6 +707,53 @@ test_mongoc_uri_write_concern (void)
    }
 }
 
+static void
+test_mongoc_uri_read_concern (void)
+{
+   const mongoc_read_concern_t *rc;
+   mongoc_uri_t *uri;
+
+   uri = mongoc_uri_new ("mongodb://localhost/?readConcernLevel=majority");
+   rc = mongoc_uri_get_read_concern (uri);
+   ASSERT_CMPSTR (mongoc_read_concern_get_level (rc), "majority");
+   mongoc_uri_destroy (uri);
+
+   uri = mongoc_uri_new ("mongodb://localhost/?readConcernLevel=" MONGOC_READ_CONCERN_LEVEL_MAJORITY);
+   rc = mongoc_uri_get_read_concern (uri);
+   ASSERT_CMPSTR (mongoc_read_concern_get_level (rc), "majority");
+   mongoc_uri_destroy (uri);
+
+
+   uri = mongoc_uri_new ("mongodb://localhost/?readConcernLevel=local");
+   rc = mongoc_uri_get_read_concern (uri);
+   ASSERT_CMPSTR (mongoc_read_concern_get_level (rc), "local");
+   mongoc_uri_destroy (uri);
+
+   uri = mongoc_uri_new ("mongodb://localhost/?readConcernLevel=" MONGOC_READ_CONCERN_LEVEL_LOCAL);
+   rc = mongoc_uri_get_read_concern (uri);
+   ASSERT_CMPSTR (mongoc_read_concern_get_level (rc), "local");
+   mongoc_uri_destroy (uri);
+
+
+   uri = mongoc_uri_new ("mongodb://localhost/?readConcernLevel=randomstuff");
+   rc = mongoc_uri_get_read_concern (uri);
+   ASSERT_CMPSTR (mongoc_read_concern_get_level (rc), "randomstuff");
+   mongoc_uri_destroy (uri);
+
+
+   uri = mongoc_uri_new ("mongodb://localhost/");
+   rc = mongoc_uri_get_read_concern (uri);
+   ASSERT (mongoc_read_concern_get_level (rc) == NULL);
+   mongoc_uri_destroy (uri);
+
+
+   uri = mongoc_uri_new ("mongodb://localhost/?readConcernLevel=");
+   rc = mongoc_uri_get_read_concern (uri);
+   ASSERT_CMPSTR (mongoc_read_concern_get_level (rc), "");
+   mongoc_uri_destroy (uri);
+}
+
+
 
 void
 test_uri_install (TestSuite *suite)
@@ -715,6 +762,7 @@ test_uri_install (TestSuite *suite)
    TestSuite_Add (suite, "/Uri/new_for_host_port", test_mongoc_uri_new_for_host_port);
    TestSuite_Add (suite, "/Uri/unescape", test_mongoc_uri_unescape);
    TestSuite_Add (suite, "/Uri/read_prefs", test_mongoc_uri_read_prefs);
+   TestSuite_Add (suite, "/Uri/read_concern", test_mongoc_uri_read_concern);
    TestSuite_Add (suite, "/Uri/write_concern", test_mongoc_uri_write_concern);
    TestSuite_Add (suite, "/HostList/from_string", test_mongoc_host_list_from_string);
    TestSuite_Add (suite, "/Uri/functions", test_mongoc_uri_functions);