Function transaction

examples/transaction-with-watch.js:18–40

()

const pool = await client.createPool();

async function transaction() {
  try {
    await pool.execute(async (isolatedClient) => {
      await isolatedClient.watch('paymentId:1259');
      const multi = isolatedClient
        .multi()
        .set('paymentId:1259', 'Payment Successfully Completed!')
        .set('paymentId:1260', 'Refund Processed Successfully!');
      await delay(5000); // Do some changes to the watched key during this time...
      await multi.exec();
      console.log('Transaction completed Successfully!');
      client.quit();
    });
  } catch (error) {
    if (error instanceof WatchError) {
      console.log('Transaction Failed Due To Concurrent Modification!');
      fn();
    } else {
      console.log(`Error: ${error}`);
      client.quit();
    }
  }
}

transaction();