Added guide on gracefuly stopping PostgreSQL connection

src/docs/getting-started.md

@@ -456,8 +456,6 @@ $ yarn add @testcontainers/postgresql
 $ bun add @testcontainers/postgresql
 ```
 
-:::
-
 ::: info EventStoreDB testing
 
 Emmett provides the package with additional test containers like the one for [EventStoreDB](https://developers.eventstore.com/). If you're using EventStoreDB, install [emmett-testcontainers](https://www.npmjs.com/package/@event-driven-io/emmett-testcontainers) and get the test container for it.
@@ -468,6 +466,12 @@ Having that, we can set our test container with:
 
 <<< @/snippets/gettingStarted/webApi/apiBDDE2EGiven.ts#test-container
 
+::: info Event store lifetime
+
+The PostgreSQL event store creates an internal connection pool to use PostgreSQL efficiently. You can set it up globally per application. After the application is ended or tests are finished, we need to close it to gracefully release open connections in the connection pool.
+
+:::
+
 And create our test specification using the `ApiE2ESpecification` type:
 
 <<< @/snippets/gettingStarted/webApi/apiBDDE2EGiven.ts#given

src/docs/snippets/gettingStarted/webApi/apiBDD.e2e.spec.ts

@@ -10,7 +10,10 @@ import {
   getApplication,
   type TestRequest,
 } from '@event-driven-io/emmett-expressjs';
-import { getPostgreSQLEventStore } from '@event-driven-io/emmett-postgresql';
+import {
+  getPostgreSQLEventStore,
+  type PostgresEventStore,
+} from '@event-driven-io/emmett-postgresql';
 import {
   PostgreSqlContainer,
   type StartedPostgreSqlContainer,
@@ -22,13 +25,17 @@ void describe('ShoppingCart E2E', () => {
   let clientId: string;
   let shoppingCartId: string;
   let postgreSQLContainer: StartedPostgreSqlContainer;
+  let eventStore: PostgresEventStore;
   let given: ApiE2ESpecification;
 
   before(async () => {
     postgreSQLContainer = await new PostgreSqlContainer().start();
+    eventStore = getPostgreSQLEventStore(
+      postgreSQLContainer.getConnectionUri(),
+    );
 
     given = ApiE2ESpecification.for(
-      () => getPostgreSQLEventStore(postgreSQLContainer.getConnectionUri()),
+      () => eventStore,
       (eventStore) =>
         getApplication({
           apis: [
@@ -47,7 +54,8 @@ void describe('ShoppingCart E2E', () => {
     shoppingCartId = `shopping_cart:${clientId}:current`;
   });
 
-  after(() => {
+  after(async () => {
+    await eventStore.close();
     return postgreSQLContainer.stop();
   });
 

src/docs/snippets/gettingStarted/webApi/apiBDDE2EGiven.ts

@@ -6,35 +6,45 @@ const unitPrice = 100;
 const now = new Date();
 
 // #region test-container
+import {
+  getPostgreSQLEventStore,
+  type PostgresEventStore,
+} from '@event-driven-io/emmett-postgresql';
 import {
   PostgreSqlContainer,
   StartedPostgreSqlContainer,
 } from '@testcontainers/postgresql';
 
-let postgreSQLContainer: StartedPostgreSqlContainer;
 void describe('ShoppingCart E2E', () => {
-  // Set up a container before all tests
+  let postgreSQLContainer: StartedPostgreSqlContainer;
+  let eventStore: PostgresEventStore;
+
+  // Set up a container and event store before all tests
   before(async () => {
     postgreSQLContainer = await new PostgreSqlContainer().start();
+    eventStore = getPostgreSQLEventStore(
+      postgreSQLContainer.getConnectionUri(),
+    );
   });
 
-  // Stop container once we finished testing
-  after(() => {
+  // Close PostgreSQL connection and stop container once we finished testing
+  after(async () => {
+    await eventStore.close();
     return postgreSQLContainer.stop();
   });
   // (...) Tests will go here
 });
 // #endregion test-container
 
+const eventStore: PostgresEventStore = undefined!;
 // #region given
 import {
   ApiE2ESpecification,
   getApplication,
 } from '@event-driven-io/emmett-expressjs';
-import { getPostgreSQLEventStore } from '@event-driven-io/emmett-postgresql';
 
 const given = ApiE2ESpecification.for(
-  () => getPostgreSQLEventStore(postgreSQLContainer.getConnectionUri()),
+  () => eventStore,
   (eventStore) =>
     getApplication({
       apis: [