diff --git a/index.js b/index.js index 20cb538..ef1b51b 100644 --- a/index.js +++ b/index.js @@ -28,14 +28,23 @@ const mongoDBConnect = async () => { console.error(error) } } +console.log('try connect') mongoDBConnect().then(async (client) => { - const db = await client.db(process.env.DB_NAME) - const collection = await db.collection(process.env.COLLECTION_NAME) - - const answer = await collection[process.env.COMMAND](JSON.parse(process.env.ARGUMENT)) - - await client.close(); - return answer.ops?.[0] ?? answer + 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('2024-08-27T12:14:23.160Z').toISOString()}`)) + + const answer = await collection[process.env.COMMAND](JSON.parse(process.env.ARGUMENT.replace("ISODate()", `${new Date('2024-08-27T12:14:23.160Z').toISOString()}`))) + + await client.close(); + return answer.ops?.[0] ?? answer + } catch (error) { + await client.close(); + } }) .then(console.log) .catch(console.error)