Finished CRUD examples

Author: oskardudycz

samples/from_crud_to_eventsourcing/src/core/validation.ts

@@ -7,6 +7,7 @@ export const enum ValidationErrors {
   NOT_A_STRING_OR_UNDEFINED = 'NOT_A_STRING_OR_UNDEFINED',
   NOT_A_POSITIVE_NUMBER = 'NOT_A_POSITIVE_NUMBER',
   NOT_AN_UNSIGNED_BIGINT = 'NOT_AN_UNSIGNED_BIGINT',
+  NOT_AN_ARRAY = 'NOT_AN_ARRAY',
 }
 
 export const assertNotEmptyString = (value: any): string => {
@@ -37,3 +38,10 @@ export const assertUnsignedBigInt = (value: string): bigint => {
   }
   return number;
 };
+
+export const assertArray = (value: any): [] => {
+  if (!Array.isArray(value)) {
+    throw ValidationErrors.NOT_AN_ARRAY;
+  }
+  return value as [];
+};

samples/from_crud_to_eventsourcing/src/crud/index.ts

@@ -0,0 +1,21 @@
+import { startAPI } from '#core/api';
+import { getPostgres } from '#core/postgres';
+import { router } from './shoppingCarts/routes';
+
+//////////////////////////////////////////////////////////
+/// Make sure that we dispose Postgres connection pool
+//////////////////////////////////////////////////////////
+
+process.once('SIGTERM', () => {
+  const db = getPostgres();
+
+  db.dispose().catch((ex) => {
+    console.error(ex);
+  });
+});
+
+//////////////////////////////////////////////////////////
+/// API
+//////////////////////////////////////////////////////////
+
+startAPI(router);

samples/from_crud_to_eventsourcing/src/crud/shoppingCarts/routes.ts

@@ -0,0 +1,137 @@
+import { getPostgres } from '#core/postgres';
+import {
+  assertArray,
+  assertNotEmptyString,
+  assertPositiveNumber,
+  assertStringOrUndefined,
+} from '#core/validation';
+import { NextFunction, Request, Response, Router } from 'express';
+import { cartItems, carts } from '../db';
+
+//////////////////////////////////////
+/// Routes
+//////////////////////////////////////
+
+export const router = Router();
+
+// Open Shopping cart
+router.post(
+  '/v1/shopping-carts/:sessionId',
+  async (request: Request, response: Response, next: NextFunction) => {
+    try {
+      const sessionId = assertNotEmptyString(request.params.sessionId);
+
+      const shoppingCarts = carts(getPostgres());
+      const shoppingCartItems = cartItems(getPostgres());
+
+      const { items, ...cart } = getShoppingCart(request);
+
+      let resultCarts = await shoppingCarts.insertOrIgnore({
+        ...cart,
+        sessionId,
+        createdAt: new Date(),
+      });
+
+      if (resultCarts.length === 0) {
+        await shoppingCarts.update(
+          { sessionId },
+          {
+            ...cart,
+            updatedAt: new Date(),
+          }
+        );
+      }
+
+      const cartId = resultCarts[0].id;
+
+      // delete and recreate all cart items
+      shoppingCartItems.delete({ cartId: resultCarts[0].id });
+
+      await shoppingCartItems.bulkInsert({
+        columnsToInsert: [
+          'cartId',
+          'content',
+          'createdAt',
+          'discount',
+          'price',
+          'productId',
+          'quantity',
+          'sku',
+          'updatedAt',
+        ],
+        records: items.map((item) => {
+          return {
+            ...item,
+            cartId,
+            createdAt: new Date(),
+            updatedAt: new Date(),
+          };
+        }),
+      });
+
+      response.status(200);
+    } catch (error) {
+      next(error);
+    }
+  }
+);
+
+const getShoppingCart = (request: Request) => {
+  return {
+    city: assertStringOrUndefined(request.body.city),
+    country: assertStringOrUndefined(request.body.country) ?? null,
+    content: assertStringOrUndefined(request.body.content) ?? null,
+    email: assertStringOrUndefined(request.body.email) ?? null,
+    firstName: assertStringOrUndefined(request.body.lastName) ?? null,
+    lastName: assertStringOrUndefined(request.body.firstName) ?? null,
+    middleName: assertStringOrUndefined(request.body.middleName) ?? null,
+    line1: assertStringOrUndefined(request.body.line1) ?? null,
+    line2: assertStringOrUndefined(request.body.line2) ?? null,
+    mobile: assertStringOrUndefined(request.body.mobile) ?? null,
+    province: assertStringOrUndefined(request.body.province) ?? null,
+    status: assertPositiveNumber(request.body.status),
+    userId: assertPositiveNumber(request.body.userId),
+    items: assertArray(request.body.items).map((item: any) => {
+      return {
+        content: assertStringOrUndefined(item.content) ?? null,
+        discount: assertPositiveNumber(item.discount),
+        productId: assertPositiveNumber(item.productId),
+        price: assertPositiveNumber(item.price),
+        quantity: assertPositiveNumber(item.quantity),
+        sku: assertNotEmptyString(item.sku),
+      };
+    }),
+  };
+};
+
+router.get(
+  '/v1/shopping-carts/:shoppingCartId',
+  async (request: Request, response: Response, next: NextFunction) => {
+    try {
+      const shoppingCarts = carts(getPostgres());
+      const shoppingCartItems = cartItems(getPostgres());
+
+      const result = await shoppingCarts.findOne({
+        sessionId: assertNotEmptyString(request.params.shoppingCartId),
+      });
+
+      if (result === null) {
+        response.sendStatus(404);
+        return;
+      }
+
+      const items = await shoppingCartItems
+        .find({
+          cartId: result.id,
+        })
+        .all();
+
+      response.send({
+        ...result,
+        items,
+      });
+    } catch (error) {
+      next(error);
+    }
+  }
+);

samples/from_crud_to_eventsourcing/src/eventsourced/shoppingCarts/routes.ts

@@ -13,7 +13,7 @@ import { create, update } from '#eventsourced/core/commandHandling';
 import { getEventStore } from '#eventsourced/core/streams';
 import { NextFunction, Request, Response, Router } from 'express';
 import { v4 as uuid } from 'uuid';
-import { carts } from '../db';
+import { cartItems, carts } from '../db';
 import { getPricedProductItem } from './productItem';
 import {
   AddProductItemToShoppingCart,
@@ -168,6 +168,7 @@ router.get(
   async (request: Request, response: Response, next: NextFunction) => {
     try {
       const shoppingCarts = carts(getPostgres());
+      const shoppingCartItems = cartItems(getPostgres());
 
       const result = await shoppingCarts.findOne({
         sessionId: assertNotEmptyString(request.params.shoppingCartId),
@@ -178,8 +179,17 @@ router.get(
         return;
       }
 
+      const items = await shoppingCartItems
+        .find({
+          cartId: result.id,
+        })
+        .all();
+
       response.set('ETag', toWeakETag(result.revision));
-      response.send(result);
+      response.send({
+        ...result,
+        items,
+      });
     } catch (error) {
       next(error);
     }