2023-05-11 07:50:53 -04:00
|
|
|
const { ObjectId } = require('mongodb')
|
|
|
|
const { waitForDb, db } = require('../../../app/src/infrastructure/mongodb')
|
|
|
|
const { getMongoClient } = require('../../../app/src/infrastructure/Mongoose')
|
2021-07-14 06:55:08 -04:00
|
|
|
|
2023-05-11 07:50:53 -04:00
|
|
|
async function main() {
|
|
|
|
try {
|
|
|
|
await waitForDb()
|
|
|
|
} catch (err) {
|
|
|
|
console.error('Cannot connect to mongodb')
|
|
|
|
throw err
|
|
|
|
}
|
|
|
|
try {
|
|
|
|
await testTransactions()
|
|
|
|
} catch (err) {
|
|
|
|
console.error("Mongo instance doesn't support transactions")
|
|
|
|
throw err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
async function testTransactions() {
|
|
|
|
const mongoClient = await getMongoClient()
|
|
|
|
const session = mongoClient.startSession()
|
|
|
|
try {
|
|
|
|
await session.withTransaction(async () => {
|
2023-12-18 05:54:01 -05:00
|
|
|
await db.users.findOne({ _id: new ObjectId() }, { session })
|
2023-05-11 07:50:53 -04:00
|
|
|
})
|
|
|
|
} finally {
|
|
|
|
await session.endSession()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
main()
|
2021-07-14 06:55:08 -04:00
|
|
|
.then(() => {
|
|
|
|
console.error('Mongodb is up.')
|
|
|
|
process.exit(0)
|
|
|
|
})
|
|
|
|
.catch(err => {
|
|
|
|
console.error(err)
|
|
|
|
process.exit(1)
|
|
|
|
})
|