add event-driven architecture with EventBus, domain events & repository listeners

Author: Awakich

projects/social_platform/src/app/api/auth/facades/ui/auth-ui-info.service.ts

@@ -1,6 +1,6 @@
 /** @format */
 
-import { inject, Injectable, signal } from "@angular/core";
+import { computed, inject, Injectable, signal } from "@angular/core";
 import { FormBuilder, FormGroup, Validators } from "@angular/forms";
 import { ValidationService } from "@corelib";
 import dayjs from "dayjs";
@@ -10,7 +10,12 @@ import {
 } from "projects/social_platform/src/app/domain/auth/results/login.result";
 import { PasswordError } from "projects/social_platform/src/app/domain/auth/results/password.result";
 import { RegisterError } from "projects/social_platform/src/app/domain/auth/results/register.result";
-import { AsyncState, initial } from "projects/social_platform/src/app/domain/shared/async-state";
+import {
+  AsyncState,
+  initial,
+  isFailure,
+  isLoading,
+} from "projects/social_platform/src/app/domain/shared/async-state";
 
 @Injectable()
 export class AuthUIInfoService {
@@ -22,17 +27,27 @@ export class AuthUIInfoService {
   readonly showPassword = signal<boolean>(false);
 
   readonly login$ = signal<AsyncState<LoginResult, LoginError>>(initial());
+  readonly loginIsSubmitting = computed(() => isLoading(this.login$()));
+  readonly errorWrongAuth = computed(() => isFailure(this.login$()));
 
   // password
   readonly credsSubmitInitiated = signal<boolean>(false);
   readonly password$ = signal<AsyncState<void, PasswordError>>(initial());
+  readonly isSubmitting = computed(() => isLoading(this.password$()));
+  readonly errorServer = computed(() => {
+    const s = this.password$();
+    return isFailure(s) && s.error.kind === "server_error";
+  });
+  readonly errorRequest = computed(() => isFailure(this.password$()));
 
   // register
   readonly registerAgreement = signal<boolean>(false);
   readonly ageAgreement = signal<boolean>(false);
   readonly infoSubmitInitiated = signal<boolean>(false);
 
   readonly register$ = signal<AsyncState<void, RegisterError>>(initial());
+  readonly registerIsSubmitting = computed(() => isLoading(this.register$()));
+  readonly isUserCreationModalError = computed(() => isFailure(this.register$()));
   readonly step = signal<"credentials" | "info">("credentials");
 
   // login

projects/social_platform/src/app/api/invite/use-cases/accept-invite.use-case.ts

@@ -2,15 +2,21 @@
 
 import { inject, Injectable } from "@angular/core";
 import { InviteRepositoryPort } from "../../../domain/invite/ports/invite.repository.port";
-import { catchError, map, Observable, of } from "rxjs";
+import { catchError, map, Observable, of, tap } from "rxjs";
 import { fail, ok, Result } from "../../../domain/shared/result.type";
+import { EventBus } from "../../../domain/shared/event-bus";
+import { acceptInvite } from "../../../domain/invite/events/accept-invite.event";
 
 @Injectable({ providedIn: "root" })
 export class AcceptInviteUseCase {
   private readonly inviteRepositoryPort = inject(InviteRepositoryPort);
+  private readonly eventBus = inject(EventBus);
 
   execute(inviteId: number): Observable<Result<void, { kind: "unknown" }>> {
     return this.inviteRepositoryPort.acceptInvite(inviteId).pipe(
+      tap(invite =>
+        this.eventBus.emit(acceptInvite(invite.id, invite.project.id, invite.user.id, invite.role))
+      ),
       map(() => ok<void>(undefined)),
       catchError(() => of(fail({ kind: "unknown" as const })))
     );

projects/social_platform/src/app/api/invite/use-cases/reject-invite.use-case.ts

@@ -2,15 +2,19 @@
 
 import { inject, Injectable } from "@angular/core";
 import { InviteRepositoryPort } from "../../../domain/invite/ports/invite.repository.port";
-import { catchError, map, Observable, of } from "rxjs";
+import { catchError, map, Observable, of, tap } from "rxjs";
 import { fail, ok, Result } from "../../../domain/shared/result.type";
+import { EventBus } from "../../../domain/shared/event-bus";
+import { rejectInvite } from "../../../domain/invite/events/reject-invite.event";
 
 @Injectable({ providedIn: "root" })
 export class RejectInviteUseCase {
   private readonly inviteRepositoryPort = inject(InviteRepositoryPort);
+  private readonly eventBus = inject(EventBus);
 
   execute(inviteId: number): Observable<Result<void, { kind: "unknown" }>> {
     return this.inviteRepositoryPort.rejectInvite(inviteId).pipe(
+      tap(invite => this.eventBus.emit(rejectInvite(invite.id, invite.project.id, invite.user.id))),
       map(() => ok<void>(undefined)),
       catchError(() => of(fail({ kind: "unknown" as const })))
     );

projects/social_platform/src/app/api/invite/use-cases/revoke-invite.use-case.ts

@@ -2,17 +2,21 @@
 
 import { inject, Injectable } from "@angular/core";
 import { InviteRepositoryPort } from "../../../domain/invite/ports/invite.repository.port";
-import { catchError, map, Observable, of } from "rxjs";
+import { catchError, map, Observable, of, tap } from "rxjs";
 import { fail, ok, Result } from "../../../domain/shared/result.type";
+import { EventBus } from "../../../domain/shared/event-bus";
+import { revokeInvite } from "../../../domain/invite/events/revoke-invite.event";
 
 @Injectable({ providedIn: "root" })
 export class RevokeInviteUseCase {
   private readonly inviteRepositoryPort = inject(InviteRepositoryPort);
+  private readonly eventBus = inject(EventBus);
 
   execute(
     invitationId: number
   ): Observable<Result<void, { kind: "revoke_invite_error"; cause?: unknown }>> {
     return this.inviteRepositoryPort.revokeInvite(invitationId).pipe(
+      tap(invite => this.eventBus.emit(revokeInvite(invite.id, invite.project.id, invite.user.id))),
       map(() => ok<void>(undefined)),
       catchError(error => of(fail({ kind: "revoke_invite_error" as const, cause: error })))
     );

projects/social_platform/src/app/api/office/facades/office-info.service.ts

@@ -1,7 +1,7 @@
 /** @format */
 
 import { inject, Injectable } from "@angular/core";
-import { map, Subject, takeUntil } from "rxjs";
+import { map, Subject, takeUntil, tap } from "rxjs";
 import { ActivatedRoute, Router } from "@angular/router";
 import { ChatService } from "../../chat/chat.service";
 import { Invite } from "../../../domain/invite/invite.model";
@@ -52,20 +52,25 @@ export class OfficeInfoService {
   }
 
   private initializationNavItems(): void {
-    this.authRepository.profile.pipe(takeUntil(this.destroy$)).subscribe(profile => {
-      this.officeUIInfoService.applyCreateNavItems(profile.id);
-
-      if (!profile?.doesCompleted()) {
-        this.router
-          .navigateByUrl("/office/onboarding")
-          .then(() => this.logger.debug("Route changed from OfficeComponent"));
-      } else if (
-        profile?.verificationDate === null &&
-        localStorage.getItem("waitVerificationAccepted") !== "true"
-      ) {
-        this.officeUIInfoService.applyOpenVerificationModal();
-      }
-    });
+    this.authRepository.profile
+      .pipe(
+        tap(profile => {
+          this.officeUIInfoService.applyCreateNavItems(profile.id);
+
+          if (!profile?.doesCompleted()) {
+            this.router
+              .navigateByUrl("/office/onboarding")
+              .then(() => this.logger.debug("Route changed from OfficeComponent"));
+          } else if (
+            profile?.verificationDate === null &&
+            localStorage.getItem("waitVerificationAccepted") !== "true"
+          ) {
+            this.officeUIInfoService.applyOpenVerificationModal();
+          }
+        }),
+        takeUntil(this.destroy$)
+      )
+      .subscribe();
   }
 
   private initializationStatus(): void {
@@ -125,9 +130,8 @@ export class OfficeInfoService {
 
     this.acceptInviteUseCase
       .execute(inviteId)
-      .pipe(takeUntil(this.destroy$))
-      .subscribe({
-        next: result => {
+      .pipe(
+        tap(result => {
           if (!result.ok) {
             this.officeUIInfoService.applyOpenInviteErrorModal();
             return;
@@ -138,18 +142,23 @@ export class OfficeInfoService {
           this.router
             .navigateByUrl(`/office/projects/${invite.project.id}`)
             .then(() => this.logger.debug("Route changed from SidebarComponent"));
-        },
-      });
+        }),
+        takeUntil(this.destroy$)
+      )
+      .subscribe();
   }
 
   onLogout() {
     this.authRepository
       .logout()
-      .pipe(takeUntil(this.destroy$))
-      .subscribe(() =>
-        this.router
-          .navigateByUrl("/auth")
-          .then(() => this.logger.debug("Route changed from OfficeComponent"))
-      );
+      .pipe(
+        tap(() => {
+          this.router
+            .navigateByUrl("/auth")
+            .then(() => this.logger.debug("Route changed from OfficeComponent"));
+        }),
+        takeUntil(this.destroy$)
+      )
+      .subscribe();
   }
 }

projects/social_platform/src/app/api/onboarding/facades/stages/onboarding-stage-one-info.service.ts

@@ -32,8 +32,8 @@ export class OnboardingStageOneInfoService {
 
   private stageForm = this.onboardingStageOneUIInfoService.stageForm;
 
-  private readonly stageSubmitting = this.onboardingUIInfoService.stageSubmitting;
-  private readonly skipSubmitting = this.onboardingUIInfoService.skipSubmitting;
+  private readonly stageSubmitting = this.onboardingUIInfoService.stageSubmitting$;
+  private readonly skipSubmitting = this.onboardingUIInfoService.skipSubmitting$;
 
   readonly inlineSpecializations = this.searchesService.inlineSpecs;
 

projects/social_platform/src/app/api/onboarding/facades/stages/onboarding-stage-three-info.service.ts

@@ -1,7 +1,7 @@
 /** @format */
 
 import { inject, Injectable } from "@angular/core";
-import { concatMap, Subject, take, takeUntil } from "rxjs";
+import { concatMap, Subject, take, takeUntil, tap } from "rxjs";
 import { OnboardingService } from "../../onboarding.service";
 import { Router } from "@angular/router";
 import { OnboardingUIInfoService } from "./ui/onboarding-ui-info.service";
@@ -24,7 +24,7 @@ export class OnboardingStageThreeInfoService {
   private readonly userRole = this.onboardingStageThreeUIInfoService.userRole;
 
   private readonly stageTouched = this.onboardingUIInfoService.stageTouched;
-  private readonly stageSubmitting = this.onboardingUIInfoService.stageSubmitting;
+  private readonly stageSubmitting = this.onboardingUIInfoService.stageSubmitting$;
 
   destroy(): void {
     this.destroy$.next();
@@ -49,12 +49,13 @@ export class OnboardingStageThreeInfoService {
       .updateProfile({ userType: this.userRole() })
       .pipe(
         concatMap(() => this.authRepository.updateOnboardingStage(null)),
+        tap(() => {
+          this.router
+            .navigateByUrl("/office")
+            .then(() => this.logger.debug("Route changed from OnboardingStageTwo"));
+        }),
         takeUntil(this.destroy$)
       )
-      .subscribe(() => {
-        this.router
-          .navigateByUrl("/office")
-          .then(() => this.logger.debug("Route changed from OnboardingStageTwo"));
-      });
+      .subscribe();
   }
 }

projects/social_platform/src/app/api/onboarding/facades/stages/onboarding-stage-two-info.service.ts

@@ -30,8 +30,8 @@ export class OnboardingStageTwoInfoService {
 
   private readonly stageForm = this.onboardingStageTwoUIInfoService.stageForm;
 
-  private readonly stageSubmitting = this.onboardingUIInfoService.stageSubmitting;
-  private readonly skipSubmitting = this.onboardingUIInfoService.skipSubmitting;
+  private readonly stageSubmitting = this.onboardingUIInfoService.stageSubmitting$;
+  private readonly skipSubmitting = this.onboardingUIInfoService.skipSubmitting$;
 
   destroy(): void {
     this.destroy$.next();

projects/social_platform/src/app/api/onboarding/facades/stages/onboarding-stage-zero-info.service.ts

@@ -32,8 +32,8 @@ export class OnboardingStageZeroInfoService {
   private readonly workExperience = this.onboardingStageZeroUIInfoService.workExperience;
   private readonly userLanguages = this.onboardingStageZeroUIInfoService.userLanguages;
 
-  private readonly stageSubmitting = this.onboardingUIInfoService.stageSubmitting;
-  private readonly skipSubmitting = this.onboardingUIInfoService.skipSubmitting;
+  private readonly stageSubmitting = this.onboardingUIInfoService.stageSubmitting$;
+  private readonly skipSubmitting = this.onboardingUIInfoService.skipSubmitting$;
 
   initializationStageZero(): void {
     this.authRepository.profile.pipe(takeUntil(this.destroy$)).subscribe(p => {

projects/social_platform/src/app/api/onboarding/facades/stages/ui/onboarding-ui-info.service.ts

@@ -1,11 +1,15 @@
 /** @format */
 
-import { Injectable, signal } from "@angular/core";
-import { AsyncState, initial } from "../../../../../domain/shared/async-state";
+import { computed, Injectable, signal } from "@angular/core";
+import { AsyncState, initial, isLoading } from "../../../../../domain/shared/async-state";
 
 @Injectable()
 export class OnboardingUIInfoService {
-  readonly stageSubmitting = signal<AsyncState<void>>(initial());
-  readonly skipSubmitting = signal<AsyncState<void>>(initial());
+  readonly stageSubmitting$ = signal<AsyncState<void>>(initial());
+  readonly stageSubmitting = computed(() => isLoading(this.stageSubmitting$()));
+
+  readonly skipSubmitting$ = signal<AsyncState<void>>(initial());
+  readonly skipSubmitting = computed(() => isLoading(this.skipSubmitting$()));
+
   readonly stageTouched = signal<boolean>(false);
 }