51 lines
1.6 KiB
JavaScript
51 lines
1.6 KiB
JavaScript
const MDBClient = require('mongodb').MongoClient
|
|
|
|
const url = process.env.MONGO_URL
|
|
|
|
if (
|
|
!process.env.MONGO_URL ||
|
|
!process.env.DB_NAME ||
|
|
!process.env.COLLECTION_NAME ||
|
|
!process.env.COMMAND ||
|
|
!process.env.ARGUMENT
|
|
) {
|
|
throw new Error(`process.env.MONGO_URL ${process.env.MONGO_URL?.replace(/./ig, '*')}
|
|
process.env.DB_NAME ${process.env.DB_NAME}
|
|
process.env.COLLECTION_NAME ${process.env.COLLECTION_NAME}
|
|
process.env.COMMAND ${process.env.COMMAND}
|
|
process.env.ARGUMENT ${process.env.ARGUMENT}
|
|
|
|
Данные переменные окружения должны быть заполнены`)
|
|
}
|
|
|
|
const mongoDBConnect = async () => {
|
|
try {
|
|
const MongoClient = new MDBClient(url, {
|
|
useUnifiedTopology: true,
|
|
})
|
|
return await MongoClient.connect()
|
|
} catch (error) {
|
|
console.error(error)
|
|
}
|
|
}
|
|
console.log('try connect')
|
|
mongoDBConnect().then(async (client) => {
|
|
console.log('Connected to MongoDB')
|
|
try {
|
|
const db = await client.db(process.env.DB_NAME)
|
|
const collection = await db.collection(process.env.COLLECTION_NAME)
|
|
|
|
console.log('command', process.env.COMMAND)
|
|
console.log('argument', process.env.ARGUMENT, process.env.ARGUMENT.replace("ISODate()", new Date()))
|
|
|
|
const answer = await collection[process.env.COMMAND](JSON.parse(process.env.ARGUMENT.replace("ISODate()", `${new Date().toISOString()}`)))
|
|
|
|
await client.close();
|
|
return answer.ops?.[0] ?? answer
|
|
} catch (error) {
|
|
await client.close();
|
|
}
|
|
})
|
|
.then(console.log)
|
|
.catch(console.error)
|