fix: lint

CloudNativeEntrepreneur · Mar 11, 2022 · ecc0f05 · ecc0f05
1 parent a99c26e
commit ecc0f05
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 35 deletions.
diff --git a/__tests__/integration/persistenceLayer-postgres.ts b/__tests__/integration/persistenceLayer-postgres.ts
@@ -49,8 +49,7 @@ const postgresConnectionUrl =
   process.env.POSTGRES_URL ||
   "postgresql://sourced:sourced@localhost:5432/sourced";
 
-
-describe('error', () => {
+describe("error", () => {
   it("should throw an error if trying to initialize a repository before connection has been established", () => {
     try {
       new Repository(Person);
@@ -79,10 +78,8 @@ describe("sourced-repo-typeorm", () => {
   afterAll(async () => {
     await persistenceLayer?.disconnect();
   });
-
 
   it("should connect to persistenceLayer, get and commit Entities, then disconnect", async () => {
-
     const personRepository = new Repository(Person);
 
     const person1 = await personRepository.get(1);
@@ -148,12 +145,6 @@ describe("sourced-repo-typeorm", () => {
     hpFromMultipleSnapshots.on("birthday", async (wizard) => {
       log("birthday event handler");
       expect(wizard.age).toBe(41);
-
-      // try {
-      //   await persistenceLayer.disconnect();
-      // } finally {
-      //   expect(persistenceLayer.connection).toBeDefined();
-      // }
     });
 
     hpFromMultipleSnapshots.birthday();
@@ -165,16 +156,6 @@ describe("sourced-repo-typeorm", () => {
     const now = Date.now();
     log("duplicate event test...");
 
-    // try {
-    //   await persistenceLayer.connect({
-    //     type: "postgres",
-    //     url: postgresConnectionUrl,
-    //     connectTimeoutMS: 1000,
-    //   });
-    // } finally {
-    //   expect(persistenceLayer.connection).toBeDefined();
-    // }
-
     const id = `test-dupe-${now}`;
 
     const personRepository = new Repository(Person);
@@ -200,21 +181,9 @@ describe("sourced-repo-typeorm", () => {
       expect(err.detail).toBeDefined();
       expect(err.code).toBe("23505");
     }
-
-    // await persistenceLayer.disconnect();
   });
 
   it("should be able to force a snapshot with options on commit", async () => {
-    // try {
-    //   await persistenceLayer.connect({
-    //     type: "postgres",
-    //     url: postgresConnectionUrl,
-    //     connectTimeoutMS: 1000,
-    //   });
-    // } finally {
-    //   expect(persistenceLayer.connection).toBeDefined();
-    // }
-
     const personRepository = new Repository(Person);
 
     const person = new Person();
@@ -227,8 +196,6 @@ describe("sourced-repo-typeorm", () => {
 
     expect(person.version).toBe(3);
     expect(person.snapshotVersion).toBe(3);
-
-    // await persistenceLayer.disconnect();
   });
 });
 

diff --git a/src/Repository.ts b/src/Repository.ts
@@ -141,7 +141,8 @@ export class Repository extends EventEmitter {
     });
 
     if (
-      this.forceSnapshot || options?.forceSnapshot ||
+      this.forceSnapshot ||
+      options?.forceSnapshot ||
       entity.version >= entity.snapshotVersion + this.snapshotFrequency
     ) {
       const snapshot = entity.snapshot();