import { Entity, PrimaryKey, Property } from '@mikro-orm/core';
import { MikroORM } from '@mikro-orm/mongodb';

@Entity()
export class User {

  @PrimaryKey()
  _id!: number;

  @Property()
  email!: string;

}
let orm: MikroORM;

beforeAll(async () => {
  orm = await MikroORM.init({
    entities: [User],
    dbName: 'mikro-orm-test-gh3261',
  });
  await orm.schema.dropSchema();
});

afterAll(() => orm.close(true));

test('retry limit to 3 when ensureIndex() fails', async () => {
  const user1 = orm.em.create(User, {
    email: 'test',
  });
  const user2 = orm.em.create(User, {
    email: 'test',
  });
  await orm.em.persistAndFlush(
    [user1, user2],
  );
  const userMeta = orm.em.getMetadata(User);
  userMeta.uniques = [{
    properties: 'email',
  }];
  await expect(
    orm.schema.ensureIndexes(),
  ).rejects.toThrowError(/Failed to create indexes:/);
});