Method afterFlush

tests/issues/GH3737.test.ts:62–72

(args: FlushEventArgs)

class ProjectUsersSubscriber implements EventSubscriber<ProjectUser> {
  async afterFlush(args: FlushEventArgs): Promise<void> {
    const uow = args.uow;
    const changeSets = uow.getChangeSets().filter(cs => cs.entity instanceof ProjectUser);
    for (const cs of changeSets) {
      const pk = cs.getPrimaryKey(true)! as Record<string, unknown>;
      expect(pk).toBeInstanceOf(Object);
      expect(Array.isArray(pk)).toBe(false);
      expect(Object.keys(pk)).toMatchObject(['project', 'user']);
      expect(Object.values(pk).map(v => typeof v)).toMatchObject(['number', 'number']);
    }
  }
}

let orm: MikroORM;