feat(example): add encrypted user aggregate example

Author: sgomez

.dockerignore

@@ -1,3 +1,5 @@
+dist
+example/dist
 example/src/nestjs-eventstore
 
 # Common

.npmignore

@@ -1,4 +1,6 @@
 # source
+example
+node_modules
 src
 index.ts
 package-lock.json
@@ -8,4 +10,5 @@ tsconfig.build.json
 .eslintignore
 .eslintrc.js
 .prettierrc
+.prettierignore
 .release-it.json

docker-compose.override.yaml

@@ -0,0 +1,11 @@
+version: '3.6'
+
+services:
+  app:
+    volumes:
+      - type: bind
+        source: ./example
+        target: /app
+      - type: bind
+        source: ./src
+        target: /app/src/nestjs-eventstore

docker-compose.recreate.yaml

@@ -0,0 +1,5 @@
+version: '3.6'
+
+services:
+  app:
+    command: ['npm', 'run', 'console:dev', 'eventstore:readmodel:restore']

docker-compose.yaml

@@ -48,16 +48,10 @@ services:
     ports:
       - 3000:3000
     environment:
-      - MONGO_URI=mongodb://mongo:27017/projections
+      - MONGO_URI=mongodb://mongo:27017/example
       - EVENTSTORE_URI=esdb://eventstore.db:2113?tls=false
+      - KEYSTORE_URI=mongodb://mongo:27017/keystore
       - PORT=3000
-    volumes:
-      - type: bind
-        source: ./example/
-        target: /app
-      - type: bind
-        source: ./src/
-        target: /app/src/nestjs-eventstore/
 
 volumes:
   eventstore-volume-data:

example/nest-cli.json

@@ -1,7 +1,5 @@
 {
   "collection": "@nestjs/schematics",
   "sourceRoot": "src",
-  "compilerOptions": {
-    "plugins": ["@nestjs/swagger"]
-  }
+  "compilerOptions": {}
 }

example/package-lock.json

@@ -9,6 +9,7 @@ import {
   EventStoreModule,
   EVENTSTORE_KEYSTORE_CONNECTION,
 } from './nestjs-eventstore';
+import { UserModule } from './user';
 
 @Module({
   imports: [
@@ -27,11 +28,19 @@ import {
       category: 'example',
       connection: process.env.EVENTSTORE_URI,
     }),
-    MongooseModule.forRoot(process.env.MONGO_URI),
+    MongooseModule.forRoot(process.env.MONGO_URI, {
+      useCreateIndex: true,
+      useFindAndModify: false,
+      useNewUrlParser: true,
+    }),
     MongooseModule.forRoot(process.env.KEYSTORE_URI, {
       connectionName: EVENTSTORE_KEYSTORE_CONNECTION,
+      useCreateIndex: true,
+      useFindAndModify: false,
+      useNewUrlParser: true,
     }),
     AccountModule,
+    UserModule,
   ],
 })
 export class AppModule {}

example/src/app.module.ts

@@ -5,6 +5,9 @@ import { AppModule } from './app.module';
 const bootstrap = new BootstrapConsole({
   module: AppModule,
   useDecorators: true,
+  contextOptions: {
+    logger: ['debug', 'error', 'log', 'verbose', 'warn'],
+  },
 });
 bootstrap.init().then(async (app) => {
   try {

example/src/console.ts

@@ -1,5 +1,9 @@
-import { Logger, ValidationPipe } from '@nestjs/common';
-import { NestFactory } from '@nestjs/core';
+import {
+  ClassSerializerInterceptor,
+  Logger,
+  ValidationPipe,
+} from '@nestjs/common';
+import { NestFactory, Reflector } from '@nestjs/core';
 import { DocumentBuilder, SwaggerModule } from '@nestjs/swagger';
 import { AppModule } from './app.module';
 
@@ -16,6 +20,7 @@ async function bootstrap() {
 
   const port = process.env.PORT || 3000;
   app.useGlobalPipes(new ValidationPipe());
+  app.useGlobalInterceptors(new ClassSerializerInterceptor(app.get(Reflector)));
   await app.listen(port, () => {
     Logger.log(`Listening at http://localhost:${port}/api`);
   });

example/src/main.ts

@@ -0,0 +1,30 @@
+import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
+import {
+  AggregateRepository,
+  IdAlreadyRegisteredError,
+  InjectAggregateRepository,
+} from '../../../nestjs-eventstore';
+import { Password, User, UserId, Username } from '../../domain';
+import { CreateUserCommand } from './create-user.query';
+
+@CommandHandler(CreateUserCommand)
+export class CreateUserHandler implements ICommandHandler<CreateUserCommand> {
+  constructor(
+    @InjectAggregateRepository(User)
+    private readonly users: AggregateRepository<User, UserId>,
+  ) {}
+
+  async execute(command: CreateUserCommand) {
+    const userId = UserId.with(command.id);
+    const username = Username.with(command.username);
+    const password = Password.with(command.password);
+
+    if ((await this.users.find(userId)) instanceof User) {
+      throw IdAlreadyRegisteredError.withId(userId);
+    }
+
+    const user = User.add(userId, username, password);
+
+    this.users.save(user);
+  }
+}

example/src/user/application/command/create-user.handler.ts

@@ -0,0 +1,9 @@
+import { ICommand } from '@nestjs/cqrs';
+
+export class CreateUserCommand implements ICommand {
+  constructor(
+    public readonly id: string,
+    public readonly username: string,
+    public readonly password: string,
+  ) {}
+}

example/src/user/application/command/create-user.query.ts

@@ -0,0 +1,30 @@
+import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
+import {
+  AggregateRepository,
+  IdNotFoundError,
+  InjectAggregateRepository,
+} from '../../../nestjs-eventstore';
+import { User, UserId } from '../../domain';
+import { DeleteUserCommand } from './delete-user.query';
+
+@CommandHandler(DeleteUserCommand)
+export class DeleteUserHandler implements ICommandHandler<DeleteUserCommand> {
+  constructor(
+    @InjectAggregateRepository(User)
+    private readonly users: AggregateRepository<User, UserId>,
+  ) {}
+
+  async execute(command: DeleteUserCommand): Promise<void> {
+    const userId = UserId.with(command.id);
+
+    const user = await this.users.find(userId);
+
+    if (!user || user.deleted) {
+      throw IdNotFoundError.withId(userId);
+    }
+
+    user.delete();
+
+    this.users.delete(user);
+  }
+}

example/src/user/application/command/delete-user.handler.ts

@@ -0,0 +1,5 @@
+import { ICommand } from '@nestjs/cqrs';
+
+export class DeleteUserCommand implements ICommand {
+  constructor(public readonly id: string) {}
+}

example/src/user/application/command/delete-user.query.ts

@@ -0,0 +1,13 @@
+import { CreateUserHandler } from './create-user.handler';
+import { DeleteUserHandler } from './delete-user.handler';
+import { UpdateUserHandler } from './update-user.handler';
+
+export const commandHandlers = [
+  CreateUserHandler,
+  UpdateUserHandler,
+  DeleteUserHandler,
+];
+
+export * from './create-user.query';
+export * from './update-user.query';
+export * from './delete-user.query';