Bumped to 0.12.5

event-driven-io · Aug 9, 2024 · 653f070 · 653f070
1 parent c15e238
commit 653f070
Show file tree

Hide file tree

Showing 4 changed files with 54 additions and 54 deletions.
diff --git a/src/package-lock.json b/src/package-lock.json
diff --git a/src/package.json b/src/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@event-driven-io/pongo-core",
-  "version": "0.12.4",
+  "version": "0.12.5",
   "description": "Pongo - Mongo with strong consistency on top of Postgres",
   "type": "module",
   "engines": {

diff --git a/src/packages/pongo/package.json b/src/packages/pongo/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@event-driven-io/pongo",
-  "version": "0.12.4",
+  "version": "0.12.5",
   "description": "Pongo - Mongo with strong consistency on top of Postgres",
   "type": "module",
   "scripts": {

diff --git a/src/packages/pongo/src/core/pongoClient.connections.int.spec.ts b/src/packages/pongo/src/core/pongoClient.connections.int.spec.ts
@@ -47,40 +47,40 @@ void describe('Pongo collection', () => {
   };
 
   void describe('Pool', () => {
-    // void it('connects using pool', async () => {
-    //   const pool = new pg.Pool({ connectionString });
-
-    //   try {
-    //     await insertDocumentUsingPongo(pool);
-    //   } catch (error) {
-    //     console.log(error);
-    //   } finally {
-    //     await pool.end();
-    //   }
-    // });
-
-    // void it('connects using connected pool client', async () => {
-    //   const pool = new pg.Pool({ connectionString });
-    //   const poolClient = await pool.connect();
-
-    //   try {
-    //     await insertDocumentUsingPongo(poolClient);
-    //   } finally {
-    //     poolClient.release();
-    //     await pool.end();
-    //   }
-    // });
-
-    // void it('connects using connected client', async () => {
-    //   const client = new pg.Client({ connectionString });
-    //   await client.connect();
-
-    //   try {
-    //     await insertDocumentUsingPongo(client);
-    //   } finally {
-    //     await client.end();
-    //   }
-    // });
+    void it('connects using pool', async () => {
+      const pool = new pg.Pool({ connectionString });
+
+      try {
+        await insertDocumentUsingPongo(pool);
+      } catch (error) {
+        console.log(error);
+      } finally {
+        await pool.end();
+      }
+    });
+
+    void it('connects using connected pool client', async () => {
+      const pool = new pg.Pool({ connectionString });
+      const poolClient = await pool.connect();
+
+      try {
+        await insertDocumentUsingPongo(poolClient);
+      } finally {
+        poolClient.release();
+        await pool.end();
+      }
+    });
+
+    void it('connects using connected client', async () => {
+      const client = new pg.Client({ connectionString });
+      await client.connect();
+
+      try {
+        await insertDocumentUsingPongo(client);
+      } finally {
+        await client.end();
+      }
+    });
 
     void it('connects using existing connection', async () => {
       const pool = dumbo({ connectionString });
@@ -101,20 +101,20 @@ void describe('Pongo collection', () => {
       }
     });
 
-    // void it('connects using existing connection from transaction', async () => {
-    //   const pool = dumbo({ connectionString });
-
-    //   try {
-    //     await pool.withTransaction(async ({ connection }) => {
-    //       const pongo = pongoClient(connectionString, { connection });
-
-    //       const users = pongo.db().collection<User>('connections');
-    //       await users.insertOne({ name: randomUUID() });
-    //       await users.insertOne({ name: randomUUID() });
-    //     });
-    //   } finally {
-    //     await pool.close();
-    //   }
-    // });
+    void it('connects using existing connection from transaction', async () => {
+      const pool = dumbo({ connectionString });
+
+      try {
+        await pool.withTransaction(async ({ connection }) => {
+          const pongo = pongoClient(connectionString, { connection });
+
+          const users = pongo.db().collection<User>('connections');
+          await users.insertOne({ name: randomUUID() });
+          await users.insertOne({ name: randomUUID() });
+        });
+      } finally {
+        await pool.close();
+      }
+    });
   });
 });