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,14 @@ 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. **Because of that, we recommend using a single event store instance per application.** The same advice applies to other storages.
+
+After the application ends 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: [