const fs = require('fs')
const { Stream } = require('stream')
const util = require('util')
const pipeline = util.promisify(Stream.pipeline)

const { MongoClient, GridFSBucket } = require('mongodb')
let client

async function main(args) {
    client = await MongoClient.connect(`mongodb://127.0.0.1:27017`);

    const database = client.db('test1');
    const bucket = new GridFSBucket(database, { bucketName: 'aaa' });

    const rs = fs.createReadStream('./main.js'); // Read this source file
    const ws = bucket.openUploadStream('test')
    await pipeline(rs, ws)
}

main(process.argv)
    .then(console.log)
    .catch(console.error)
    .finally(async () => {
        await client.close()
        console.log('done.')
    })