Adding transaction support

__test__/handler-remove-many.spec.ts

@@ -70,7 +70,7 @@ describe('Test Document Remove Many', () => {
     const Cat = model('Cat', CatSchema);
     const metadata = getModelMetadata(Cat);
     try {
-      await removeCallback('dummy_id', metadata);
+      await removeCallback('dummy_id', metadata, {}, {});
     } catch (err) {
       const error = err as StatusExecution;
       const dnf = new DocumentNotFoundError();

__test__/testData.ts

@@ -1,4 +1,4 @@
-import { Ottoman, SearchConsistency } from '../src';
+import { LogicalWhereExpr, Ottoman, SearchConsistency, FindOptions, ModelTypes } from '../src';
 
 export const bucketName = 'travel-sample';
 export const username = 'Administrator';
@@ -18,4 +18,12 @@ export const startInTest = async (ottoman: Ottoman): Promise<boolean> => {
   return true;
 };
 
+export const cleanUp = <T = any>(
+  model: ModelTypes<T>,
+  query: LogicalWhereExpr<T> = { _type: model.collectionName },
+  options: FindOptions = { consistency: SearchConsistency.LOCAL },
+) => {
+  return model.removeMany(query, options);
+};
+
 export const consistency = { consistency: SearchConsistency.LOCAL };

__test__/transaction-indexes.spec.ts

@@ -0,0 +1,43 @@
+import { Schema, model, getDefaultInstance, SearchConsistency } from '../src';
+import { delay, startInTest } from './testData';
+
+test('Testing indexes', async () => {
+  const UserSchema = new Schema({
+    name: String,
+    email: String,
+    card: {
+      cardNumber: String,
+      zipCode: String,
+    },
+    roles: [{ name: String }],
+  });
+
+  UserSchema.index.findN1qlByName = { by: 'name', options: { limit: 4, select: 'name' } };
+
+  const User = model('TransactionUser7', UserSchema);
+  const ottoman = getDefaultInstance();
+  await startInTest(ottoman);
+
+  const userData = {
+    name: `index`,
+    email: '[email protected]',
+    card: { cardNumber: '424242425252', zipCode: '42424' },
+    roles: [{ name: 'admin' }],
+  };
+
+  try {
+    await ottoman.$transactions(async (ctx) => {
+      await User.create(userData, { transactionContext: ctx });
+
+      await delay(2500);
+
+      const usersN1ql = await User.findN1qlByName(userData.name, { transactionContext: ctx });
+      expect(usersN1ql.rows[0].name).toBe(userData.name);
+    });
+  } catch (e) {
+    console.log(e);
+  }
+
+  const usersN1ql = await User.findN1qlByName(userData.name, { consistency: SearchConsistency.LOCAL });
+  expect(usersN1ql.rows[0].name).toBe(userData.name);
+});