From 653f0704123b041aae6902e5a25cd97bff070a62 Mon Sep 17 00:00:00 2001
From: Oskar Dudycz <oskar.dudycz@gmail.com>
Date: Fri, 9 Aug 2024 16:58:41 +0200
Subject: [PATCH] Bumped to 0.12.5

---
 src/package-lock.json                         |  6 +-
 src/package.json                              |  2 +-
 src/packages/pongo/package.json               |  2 +-
 .../core/pongoClient.connections.int.spec.ts  | 98 +++++++++----------
 4 files changed, 54 insertions(+), 54 deletions(-)

diff --git a/src/package-lock.json b/src/package-lock.json
index b7eabc7..e93cda4 100644
--- a/src/package-lock.json
+++ b/src/package-lock.json
@@ -1,12 +1,12 @@
 {
   "name": "@event-driven-io/pongo-core",
-  "version": "0.12.4",
+  "version": "0.12.5",
   "lockfileVersion": 3,
   "requires": true,
   "packages": {
     "": {
       "name": "@event-driven-io/pongo-core",
-      "version": "0.12.4",
+      "version": "0.12.5",
       "workspaces": [
         "packages/dumbo",
         "packages/pongo"
@@ -5694,7 +5694,7 @@
     },
     "packages/pongo": {
       "name": "@event-driven-io/pongo",
-      "version": "0.12.4",
+      "version": "0.12.5",
       "dependencies": {
         "@types/pg-connection-string": "^2.0.0",
         "pg-connection-string": "^2.6.4"
diff --git a/src/package.json b/src/package.json
index 57e6b6d..feabc9f 100644
--- 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
index 541bfcc..5c99627 100644
--- 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
index 7f1b0f9..a1f1a85 100644
--- 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();
+      }
+    });
   });
 });