const mongodb = require('mongodb');

run().catch(error => console.log(error));

async function run() {
  const client = await mongodb.MongoClient.connect('mongodb://localhost:27017,localhost:27018,localhost:27019/test?replicaSet=rs', {
    useNewUrlParser: true
  });
  const db = client.db();  await db.dropDatabase();
  await db.createCollection('Test');  const session = await client.startSession();
  let success = false;
  for (let i = 0; i < 10; ++i) {
    try {
      session.startTransaction();
      await db.collection('Test').insertOne({ value: 'foo' }, { session });
      await db.collection('Test').createIndex({ value: 1 }, { session });
      await session.commitTransaction();
      success = true;
      break;
    } catch (err) {
      await session.abortTransaction();
      if (err.errorLabels != null && err.errorLabels.includes('TransientTransactionError')) { 
        console.log('Retry...');
        await new Promise(resolve => setTimeout(resolve, 100));
        continue;
      }
      throw err;
    }
  }  if (!success) { 
    throw new Error('Failed!')
  }
}