Skip to content

Commit 8ef6672

Browse files
committed
[db] process connection string for replica sets in singleDefaultConnection correctly
1 parent 642a3cd commit 8ef6672

File tree

1 file changed

+10
-6
lines changed

1 file changed

+10
-6
lines changed

plugins/pluginManager.js

+10-6
Original file line numberDiff line numberDiff line change
@@ -579,13 +579,17 @@ var pluginManager = function pluginManager(){
579579

580580
this.singleDefaultConnection = function() {
581581
if(typeof countlyConfig.mongodb === "string"){
582-
var urlParts = url.parse(countlyConfig.mongodb, true);
583-
if(!urlParts.query){
584-
urlParts.query = {};
582+
var query = {};
583+
var url = countlyConfig.mongodb;
584+
if(countlyConfig.mongodb.indexOf("?") !== -1){
585+
var parts = countlyConfig.mongodb.split("?");
586+
query = querystring.parse(parts.pop());
587+
url = parts[0];
585588
}
586-
urlParts.query.maxPoolSize = 1;
587-
delete urlParts.search;
588-
return this.dbConnection({mongodb: url.format(urlParts)});
589+
query.maxPoolSize = 1;
590+
url += "?"+querystring.stringify(query);
591+
console.log(url);
592+
return this.dbConnection({mongodb: url});
589593
}
590594
else{
591595
var conf = Object.assign({}, countlyConfig.mongodb);

0 commit comments

Comments
 (0)