Implemented a first working flow of projections handling

Author: oskardudycz

samples/from_crud_to_eventsourcing/.vscode/launch.json

@@ -2,19 +2,24 @@
   "version": "0.2.0",
   "configurations": [
     {
-      "name": "Debug",
+      "name": "Debug CRUD",
       "type": "node",
       "request": "launch",
       "runtimeExecutable": "npm",
-      "runtimeArgs": ["run-script", "start", "--", "--inspect-brk=9229"],
+      "runtimeArgs": ["run-script", "start:crud", "--", "--inspect-brk=9229"],
       "port": 9229
     },
     {
-      "name": "Debug Server",
+      "name": "Debug Event-Sourced",
       "type": "node",
       "request": "launch",
       "runtimeExecutable": "npm",
-      "runtimeArgs": ["run-script", "start:server", "--", "--inspect-brk=9229"],
+      "runtimeArgs": [
+        "run-script",
+        "start:eventsourced",
+        "--",
+        "--inspect-brk=9229"
+      ],
       "port": 9229
     }
   ]

samples/from_crud_to_eventsourcing/config.ts

@@ -25,6 +25,12 @@ const convictConfig = convict({
       arg: 'DATABASE_URL',
       env: 'DATABASE_URL',
     },
+    schemaName: {
+      format: String,
+      default: 'postgres',
+      arg: 'DATABASE_SCHEMA',
+      env: 'DATABASE_SCHEMA',
+    },
   },
 });
 

samples/from_crud_to_eventsourcing/config/dev.json

@@ -1 +1,5 @@
-{}
+{
+  "postgres": {
+    "schemaName": "ecommerce"
+  }
+}

samples/from_crud_to_eventsourcing/config/prod.json

@@ -1 +1,5 @@
-{}
+{
+  "postgres": {
+    "schemaName": "ecommerce"
+  }
+}

samples/from_crud_to_eventsourcing/config/test.json

@@ -1 +1,5 @@
-{}
+{
+  "postgres": {
+    "schemaName": "ecommerce"
+  }
+}

samples/from_crud_to_eventsourcing/data.sql

@@ -13,8 +13,10 @@
     "fix": "npm run fix:eslint && npm run fix:prettier",
     "fix:prettier": "prettier --write \"**/**/!(*.d).{ts,json,md}\"",
     "fix:eslint": "eslint **/*.ts --fix",
+    "crud:setup": "run-s crud:migrate crud:generate",
     "crud:migrate": "pg-migrations apply --database postgres://postgres:Password12!@localhost:5432/postgres --directory ./src/crud/migrations/",
     "crud:generate": "npx @databases/pg-schema-cli --database postgres://postgres:Password12!@localhost:5432/postgres --schemaName ecommerce --directory src/crud/db/__generated__",
+    "eventsourced:setup": "run-s eventsourced:migrate eventsourced:generate",
     "eventsourced:generate": "npx @databases/pg-schema-cli --database postgres://postgres:Password12!@localhost:5432/postgres --schemaName ecommerce --directory src/eventsourced/db/__generated__",
     "eventsourced:migrate": "pg-migrations apply --database postgres://postgres:Password12!@localhost:5432/postgres --directory ./src/eventsourced/migrations/ --ignore-error migration_file_edited"
   },

samples/from_crud_to_eventsourcing/package.json

@@ -9,12 +9,19 @@ import { DEFAULT_RETRY_OPTIONS, RetryOptions, retryPromise } from './retries';
 let db: ConnectionPool;
 
 export const getPostgres = (): ConnectionPool => {
-  if (!config.postgres.connectionString) {
-    throw 'Postgres connection string not set. Please define "DATABASE_URL" environment variable';
-  }
-
   if (!db) {
-    db = createConnectionPool(config.postgres.connectionString);
+    if (!config.postgres.connectionString) {
+      throw 'Postgres connection string not set. Please define "DATABASE_URL" environment variable';
+    }
+
+    if (!config.postgres.schemaName) {
+      throw 'Postgres schema name string not set. Please define "DATABASE_SCHEMA" environment variable';
+    }
+
+    db = createConnectionPool({
+      connectionString: config.postgres.connectionString,
+      schema: config.postgres.schemaName,
+    });
   }
 
   return db;

samples/from_crud_to_eventsourcing/src/core/postgres.ts

@@ -21,6 +21,9 @@ CREATE TABLE "ecommerce"."cart"
     "content"    TEXT         NULL     DEFAULT NULL
 );
 
+CREATE UNIQUE INDEX "idx_cart_sessionId"
+ON "ecommerce"."cart" ("sessionId");
+
 CREATE TABLE "ecommerce"."cart_item"
 (
     "id"        BIGSERIAL    PRIMARY KEY,

samples/from_crud_to_eventsourcing/src/crud/migrations/0001-initial_migration.sql

@@ -47,6 +47,8 @@ export const SubscriptionToAll =
         console.error(`Received error: ${error ?? 'UNEXPECTED ERROR'}.`);
       }
     );
+    console.info('Subscription is running');
+
     return subscription;
   };