Skip to content

Commit

Permalink
update mongodb connection options
Browse files Browse the repository at this point in the history
  • Loading branch information
joseAbarcaSaavedra committed Feb 7, 2023
1 parent 3861b0d commit f3f2175
Show file tree
Hide file tree
Showing 2 changed files with 15 additions and 9 deletions.
5 changes: 3 additions & 2 deletions package.json
Original file line number Diff line number Diff line change
@@ -1,7 +1,8 @@
{
"name": "services-db-mixin",
"version": "2.3.2",
"description": "Moleculer mixin to provide a mongodb interface for microservices",
"version": "2.3.3",
"description":
"Moleculer mixin to provide a mongodb interface for microservices",
"main": "src/index.js",
"repository": {
"type": "git",
Expand Down
19 changes: 12 additions & 7 deletions src/index.js
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
const MongoAdapter = require("moleculer-db-adapter-mongo")
const DbService = require("moleculer-db")
const { entityCreated, entityDeleted, entityUpdated } = require("./events")
const LogInfo = require("./loginfo.mixin")
const MongoAdapter = require('moleculer-db-adapter-mongo')
const DbService = require('moleculer-db')
const { entityCreated, entityDeleted, entityUpdated } = require('./events')
const LogInfo = require('./loginfo.mixin')
/**
* Creates a DB interface for Moleculer Services
*
Expand All @@ -13,15 +13,20 @@ const LogInfo = require("./loginfo.mixin")
* @param {Object} logger.action Action to call on the logger service
* @returns
*/
module.exports = function(mongoUrl, collection, logger) {
module.exports = function (mongoUrl, collection, logger) {
const dbUrl = mongoUrl || process.env.MONGO_URI
if (!dbUrl) {
console.warn("MONGODB_URI not set. Using memory adapter")
console.warn('MONGODB_URI not set. Using memory adapter')
}

return {
mixins: [DbService, LogInfo(logger)],
adapter: dbUrl ? new MongoAdapter(dbUrl) : new DbService.MemoryAdapter(),
adapter: dbUrl
? new MongoAdapter(dbUrl, {
useNewUrlParser: true,
useUnifiedTopology: true
})
: new DbService.MemoryAdapter(),
collection,
methods: {
entityCreated,
Expand Down

0 comments on commit f3f2175

Please sign in to comment.