bitloops
diff --git a/‎backend/development-steps.md‎
Lines changed: 18 additions & 12 deletions b/‎backend/development-steps.md‎
Lines changed: 18 additions & 12 deletions
diff --git a/‎backend/src/api/todo.grpc.controller.ts‎
Lines changed: 2 additions & 2 deletions b/‎backend/src/api/todo.grpc.controller.ts‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎backend/src/api/todo.rest.controller.ts‎
Lines changed: 3 additions & 3 deletions b/‎backend/src/api/todo.rest.controller.ts‎
Lines changed: 3 additions & 3 deletions
diff --git a/‎backend/src/bounded-contexts/iam/iam/iam.module.ts‎
Lines changed: 3 additions & 3 deletions b/‎backend/src/bounded-contexts/iam/iam/iam.module.ts‎
Lines changed: 3 additions & 3 deletions
diff --git a/‎backend/src/bounded-contexts/iam/iam/repository/user-write.pg.repository.ts‎
Lines changed: 3 additions & 3 deletions b/‎backend/src/bounded-contexts/iam/iam/repository/user-write.pg.repository.ts‎
Lines changed: 3 additions & 3 deletions
diff --git a/‎backend/src/bounded-contexts/iam/iam/repository/user-write.repository.ts‎
Lines changed: 3 additions & 3 deletions b/‎backend/src/bounded-contexts/iam/iam/repository/user-write.repository.ts‎
Lines changed: 3 additions & 3 deletions
diff --git a/‎backend/src/bounded-contexts/marketing/marketing/marketing.module.ts‎
Lines changed: 23 additions & 3 deletions b/‎backend/src/bounded-contexts/marketing/marketing/marketing.module.ts‎
Lines changed: 23 additions & 3 deletions
diff --git a/‎backend/src/bounded-contexts/marketing/marketing/repository/notification-template.repository.ts‎
Lines changed: 2 additions & 2 deletions b/‎backend/src/bounded-contexts/marketing/marketing/repository/notification-template.repository.ts‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎backend/src/bounded-contexts/marketing/marketing/repository/user-write.repository.ts‎
Lines changed: 7 additions & 0 deletions b/‎backend/src/bounded-contexts/marketing/marketing/repository/user-write.repository.ts‎
Lines changed: 7 additions & 0 deletions
diff --git a/‎backend/src/bounded-contexts/marketing/marketing/service/mock-email.service.ts‎
Lines changed: 2 additions & 4 deletions b/‎backend/src/bounded-contexts/marketing/marketing/service/mock-email.service.ts‎
Lines changed: 2 additions & 4 deletions
@@ -1,29 +1,35 @@
-### Source code under `lib/` folder is transpiled based on the bl code we have written.
+## Transpile bl code
 
-It contains our application and domain layers. Each application handler/use-case is injected some ports which are associated with a token. This token will be used to attach the concreted adapter.
+Transpile your bl code giving as target option path the absolute path of your project's `src/lib`.
 
-### Every folder under `bitloops/` is a nestjs plugin, and can be assumed to be a npm package.
+Remove strict and strictNullChecks from your tsconfig if present.
 
-Add `config/` folder and define some initial configuration for your app. e.g. http_port, host etc. You will be adding database, apiKeys, secrets and so on there later based on your adapters.
-`yarn add @nestjs/config`. Create a `.development.env` file and gitignore it.
+## Install dependencies
 
-## Project structure
-
-We start with 2 root modules. The `api` module, which contains all the controllers and acts as our application gateway, and the `app` module which is a modular monolith containing all our modules(with their infra, application & domain layers). We need to write the api code, and the infra code for each module(with concretions of each port used by application layers).
+```bash
+# install bitloops plugins
+yarn add @bitloops/bl-boilerplate-core \
+      @bitloops/bl-boilerplate-infra-mongo \
+      @bitloops/bl-boilerplate-infra-nest-auth-passport \
+      @bitloops/bl-boilerplate-infra-nest-jetstream \
+      @bitloops/bl-boilerplate-infra-postgres \
+      @bitloops/bl-boilerplate-infra-telemetry \
+      nats \
+      mongodb
+```
 
 ### Api module
 
-Each controller will have injected the commandBus or/and the queryBus from the bus-plugin you will be using. On `api.module.ts` we register the controllers, and as imports the buses-plugin, the auth-module plugin and nest' config module if we need it. Each controller dispatches a command/query using the appropriate bus and then handles the response matching each error to the appropriate response code.
-
-- grpc
-  `yarn add @grpc/grpc-js google-protobuf`
+Each controller will have injected the commandBus or/and the queryBus from the bus-plugin you will be using. On `api.module.ts` we register the controllers, import the buses-plugin, the auth-module plugin and nest's config module if needed. Each controller dispatches a command/query using the appropriate bus and then handles the response, by matching each error to the appropriate response code.
 
 ### App module
 
 We will be registering each bl module, connecting it with its required adapters. We can place this code under `src/bounded-contexts/[bounded-context-name]/[module-name]/`.
 
 Each bl module is a dynamic module, so when we import it, we need to pass the injected modules & adapters(nestjs providers) as arguments.
 
+Every bl module has a `constants.ts` file, listing all the injection tokens its respective infra module will have to provide.
+
 ## Tracing
 
 We can trace the execution of a method by using the @Traceable decorator provided by the bitloops-tracing plugin. Let's say we want to use it on the api module to trace the duration of a `addTodo` post http route. First we have to register the plugin in the `api.module.ts`. After that we just decorate the method we want.
 
@@ -23,12 +23,12 @@ import { CorrelationIdInterceptor } from '@bitloops/bl-boilerplate-infra-telemet
 import { GetTodosQuery } from '@src/lib/bounded-contexts/todo/todo/queries/get-todos.query';
 import { CompleteTodoCommand } from '@src/lib/bounded-contexts/todo/todo/commands/complete-todo.command';
 import { UncompleteTodoCommand } from '@src/lib/bounded-contexts/todo/todo/commands/uncomplete-todo.command';
-import { ModifyTodoTitleCommand } from '@src/lib/bounded-contexts/todo/todo/commands/modify-title-todo.command';
+import { ModifyTodoTitleCommand } from '@src/lib/bounded-contexts/todo/todo/commands/modify-todo-title.command';
 import { DeleteTodoCommand } from '@src/lib/bounded-contexts/todo/todo/commands/delete-todo.command';
 import { AuthEnvironmentVariables } from '@src/config/auth.configuration';
 
 import { todo } from '../proto/generated/todo';
-import { AddTodoCommand } from '../lib/bounded-contexts/todo/todo/commands/add-todo.command';
+import { AddTodoCommand } from '@src/lib/bounded-contexts/todo/todo/commands/add-todo.command';
 import { TodoAddedPubSubIntegrationEventHandler } from './pub-sub-handlers/todo-added.integration-handler';
 import { TodoDeletedPubSubIntegrationEventHandler } from './pub-sub-handlers/todo-deleted.integration-handler';
 import { TodoCompletedPubSubIntegrationEventHandler } from './pub-sub-handlers/todo-completed.integration-handler';
 
@@ -11,17 +11,17 @@ import {
   Request,
 } from '@nestjs/common';
 import { ConfigService } from '@nestjs/config';
-import { TodoReadModel } from '../lib/bounded-contexts/todo/todo/domain/TodoReadModel';
-import { AddTodoCommand } from '../lib/bounded-contexts/todo/todo/commands/add-todo.command';
 import { AddTodoDto } from './dto/add-todo.dto';
 import { CompleteTodoDto } from './dto/complete-todo.dto';
-import { GetTodosQuery } from '../lib/bounded-contexts/todo/todo/queries/get-todos.query';
 
 import { BUSES_TOKENS } from '@bitloops/bl-boilerplate-infra-nest-jetstream';
 import { AuthEnvironmentVariables } from '@src/config/auth.configuration';
 import { JwtAuthGuard } from '@bitloops/bl-boilerplate-infra-nest-auth-passport';
 import { Infra } from '@bitloops/bl-boilerplate-core';
 import { CompleteTodoCommand } from '@src/lib/bounded-contexts/todo/todo/commands/complete-todo.command';
+import { TodoReadModel } from '@src/lib/bounded-contexts/todo/todo/domain/todo.read-model';
+import { AddTodoCommand } from '@src/lib/bounded-contexts/todo/todo/commands/add-todo.command';
+import { GetTodosQuery } from '@src/lib/bounded-contexts/todo/todo/queries/get-todos.query';
 
 @Injectable()
 @Controller('todo')
 
@@ -1,19 +1,19 @@
 import { Module } from '@nestjs/common';
 
-import { IamModule as LibIamModule } from 'src/lib/bounded-contexts/iam/authentication/iam.module';
+import { AuthenticationModule as LibIamModule } from '@src/lib/bounded-contexts/iam/authentication/authentication.module';
 import { MongoModule } from '@bitloops/bl-boilerplate-infra-mongo';
 import { PostgresModule } from '@bitloops/bl-boilerplate-infra-postgres';
-import { UserWriteRepoPortToken } from '@src/lib/bounded-contexts/iam/authentication/ports/UserWriteRepoPort';
 import { PubSubCommandHandlers } from '@src/lib/bounded-contexts/iam/authentication/application/command-handlers';
 import {
   JetstreamModule,
   NatsStreamingDomainEventBus,
   NatsStreamingIntegrationEventBus,
 } from '@bitloops/bl-boilerplate-infra-nest-jetstream';
-import { StreamingDomainEventHandlers } from '@src/lib/bounded-contexts/iam/authentication/application/event-handlers';
+import { StreamingDomainEventHandlers } from '@src/lib/bounded-contexts/iam/authentication/application/event-handlers/domain';
 import {
   StreamingDomainEventBusToken,
   StreamingIntegrationEventBusToken,
+  UserWriteRepoPortToken,
 } from '@src/lib/bounded-contexts/iam/authentication/constants';
 import { UserWritePostgresRepository } from './repository/user-write.pg.repository';
 
 
@@ -8,10 +8,10 @@ import {
 } from '@bitloops/bl-boilerplate-core';
 import { Injectable, Inject } from '@nestjs/common';
 import * as jwtwebtoken from 'jsonwebtoken';
-import { UserWriteRepoPort } from '@src/lib/bounded-contexts/iam/authentication/ports/UserWriteRepoPort';
-import { UserEntity } from '@src/lib/bounded-contexts/iam/authentication/domain/UserEntity';
+import { UserWriteRepoPort } from '@src/lib/bounded-contexts/iam/authentication/ports/user-write.repo-port';
+import { UserEntity } from '@src/lib/bounded-contexts/iam/authentication/domain/user.entity';
 import { constants } from '@bitloops/bl-boilerplate-infra-postgres';
-import { EmailVO } from '@src/lib/bounded-contexts/iam/authentication/domain/EmailVO';
+import { EmailVO } from '@src/lib/bounded-contexts/iam/authentication/domain/email.value-object';
 import { ConfigService } from '@nestjs/config';
 import { AuthEnvironmentVariables } from '@src/config/auth.configuration';
 import { StreamingDomainEventBusToken } from '@src/lib/bounded-contexts/iam/authentication/constants';
 
@@ -15,9 +15,9 @@ import {
   ClientSession,
 } from 'mongodb';
 import * as jwtwebtoken from 'jsonwebtoken';
-import { UserWriteRepoPort } from '@src/lib/bounded-contexts/iam/authentication/ports/UserWriteRepoPort';
-import { UserEntity } from '@src/lib/bounded-contexts/iam/authentication/domain/UserEntity';
-import { EmailVO } from '@src/lib/bounded-contexts/iam/authentication/domain/EmailVO';
+import { UserWriteRepoPort } from '@src/lib/bounded-contexts/iam/authentication/ports/user-write.repo-port';
+import { UserEntity } from '@src/lib/bounded-contexts/iam/authentication/domain/user.entity';
+import { EmailVO } from '@src/lib/bounded-contexts/iam/authentication/domain/email.value-object';
 import { ConfigService } from '@nestjs/config';
 import { AuthEnvironmentVariables } from '@src/config/auth.configuration';
 import { StreamingDomainEventBusToken } from '@src/lib/bounded-contexts/iam/authentication/constants';
 
@@ -2,21 +2,28 @@ import { Module } from '@nestjs/common';
 
 import { MarketingModule as LibMarketingModule } from 'src/lib/bounded-contexts/marketing/marketing/marketing.module';
 import { UserWriteRepository } from './repository/user-write.repository';
-import { UserWriteRepoPortToken } from '@src/lib/bounded-contexts/marketing/marketing/ports/user-write.repo-port';
-import { NotificationTemplateReadRepoPortToken } from '@src/lib/bounded-contexts/marketing/marketing/ports/notification-template-read.repo-port.';
 import { NotificationTemplateReadRepository } from './repository/notification-template.repository';
 import {
   EmailServicePortToken,
+  NotificationTemplateReadRepoPortToken,
+  PubSubIntegrationEventBusToken,
   StreamingCommandBusToken,
+  StreamingDomainEventBusToken,
+  StreamingIntegrationEventBusToken,
+  UserWriteRepoPortToken,
 } from '@src/lib/bounded-contexts/marketing/marketing/constants';
 import { MockEmailService } from './service';
 import { MongoModule } from '@bitloops/bl-boilerplate-infra-mongo';
-import { StreamingIntegrationEventHandlers } from '@src/lib/bounded-contexts/marketing/marketing/application/event-handlers';
+import { StreamingIntegrationEventHandlers } from '@src/lib/bounded-contexts/marketing/marketing/application/event-handlers/integration';
 import { StreamingCommandHandlers } from '@src/lib/bounded-contexts/marketing/marketing/application/command-handlers';
 import {
   NatsStreamingCommandBus,
   JetstreamModule,
+  NatsStreamingDomainEventBus,
+  NatsStreamingIntegrationEventBus,
+  NatsPubSubIntegrationEventsBus,
 } from '@bitloops/bl-boilerplate-infra-nest-jetstream';
+import { StreamingDomainEventHandlers } from '@src/lib/bounded-contexts/marketing/marketing/application/event-handlers/domain';
 
 const RepoProviders = [
   {
@@ -35,6 +42,18 @@ const RepoProviders = [
     provide: StreamingCommandBusToken,
     useClass: NatsStreamingCommandBus,
   },
+  {
+    provide: StreamingDomainEventBusToken,
+    useClass: NatsStreamingDomainEventBus,
+  },
+  {
+    provide: StreamingIntegrationEventBusToken,
+    useClass: NatsStreamingIntegrationEventBus,
+  },
+  {
+    provide: PubSubIntegrationEventBusToken,
+    useClass: NatsPubSubIntegrationEventsBus,
+  },
 ];
 @Module({
   imports: [
@@ -45,6 +64,7 @@ const RepoProviders = [
     JetstreamModule.forFeature({
       moduleOfHandlers: MarketingModule,
       streamingIntegrationEventHandlers: [...StreamingIntegrationEventHandlers],
+      streamingDomainEventHandlers: [...StreamingDomainEventHandlers],
       streamingCommandHandlers: [...StreamingCommandHandlers],
     }),
   ],
 
@@ -1,8 +1,8 @@
 import { Injectable, Inject } from '@nestjs/common';
 import { Collection, MongoClient } from 'mongodb';
 import * as jwtwebtoken from 'jsonwebtoken';
-import { NotificationTemplateReadRepoPort } from '@src/lib/bounded-contexts/marketing/marketing/ports/notification-template-read.repo-port.';
-import { NotificationTemplateReadModel } from '@src/lib/bounded-contexts/marketing/marketing/domain/read-models/notification-template.read-model';
+import { NotificationTemplateReadRepoPort } from '@src/lib/bounded-contexts/marketing/marketing/ports/notification-template-read.repo-port';
+import { NotificationTemplateReadModel } from '@src/lib/bounded-contexts/marketing/marketing/domain/notification-template.read-model';
 import { AuthEnvironmentVariables } from '@src/config/auth.configuration';
 import { ConfigService } from '@nestjs/config';
 import {
 
@@ -2,6 +2,7 @@ import {
   Application,
   Domain,
   Either,
+  Infra,
   asyncLocalStorage,
   ok,
 } from '@bitloops/bl-boilerplate-core';
@@ -12,6 +13,7 @@ import { UserEntity } from '@src/lib/bounded-contexts/marketing/marketing/domain
 import { UserWriteRepoPort } from '@src/lib/bounded-contexts/marketing/marketing/ports/user-write.repo-port';
 import { ConfigService } from '@nestjs/config';
 import { AuthEnvironmentVariables } from '@src/config/auth.configuration';
+import { StreamingDomainEventBusToken } from '@src/lib/bounded-contexts/marketing/marketing/constants';
 
 const MONGO_DB_DATABASE = process.env.MONGO_DB_DATABASE || 'marketing';
 const MONGO_DB_TODO_COLLECTION =
@@ -26,6 +28,8 @@ export class UserWriteRepository implements UserWriteRepoPort {
 
   constructor(
     @Inject('MONGO_DB_CONNECTION') private client: MongoClient,
+    @Inject(StreamingDomainEventBusToken)
+    private readonly domainEventBus: Infra.EventBus.IEventBus,
     private configService: ConfigService<AuthEnvironmentVariables, true>,
   ) {
     this.collection = this.client
@@ -59,6 +63,8 @@ export class UserWriteRepository implements UserWriteRepoPort {
         $set: userInfo,
       },
     );
+
+    this.domainEventBus.publish(user.domainEvents);
     return ok();
   }
 
@@ -113,6 +119,7 @@ export class UserWriteRepository implements UserWriteRepoPort {
       ...createdUser,
     });
 
+    this.domainEventBus.publish(user.domainEvents);
     return ok();
   }
 }
@@ -1,9 +1,7 @@
 import { Application, Either, ok } from '@bitloops/bl-boilerplate-core';
 import { Injectable } from '@nestjs/common';
-import {
-  EmailServicePort,
-  SendEmailRequest,
-} from 'src/lib/bounded-contexts/marketing/marketing/ports/email-service-port';
+import { EmailServicePort } from '@src/lib/bounded-contexts/marketing/marketing/ports/email.service-port';
+import { SendEmailRequest } from '@src/lib/bounded-contexts/marketing/marketing/structs/send-email-request.struct';
 
 @Injectable()
 export class MockEmailService implements EmailServicePort {