add use-cases for project, skills, subs, invites, kanban & chat

Author: Awakich

projects/social_platform/src/app/api/auth/use-cases/download-cv.use-case.ts

@@ -0,0 +1,18 @@
+/** @format */
+
+import { inject, Injectable } from "@angular/core";
+import { catchError, map, Observable, of } from "rxjs";
+import { AuthRepositoryPort } from "../../../domain/auth/ports/auth.repository.port";
+import { fail, ok, Result } from "../../../domain/shared/result.type";
+
+@Injectable({ providedIn: "root" })
+export class DownloadCvUseCase {
+  private readonly authRepositoryPort = inject(AuthRepositoryPort);
+
+  execute(): Observable<Result<Blob, { kind: "download_cv_error"; cause?: unknown }>> {
+    return this.authRepositoryPort.downloadCV().pipe(
+      map(file => ok<Blob>(file)),
+      catchError(error => of(fail({ kind: "download_cv_error" as const, cause: error })))
+    );
+  }
+}

projects/social_platform/src/app/api/chat/use-cases/check-unreads.use-case.ts

@@ -0,0 +1,20 @@
+/** @format */
+
+import { inject, Injectable } from "@angular/core";
+import { catchError, map, Observable, of } from "rxjs";
+import { fail, ok, Result } from "../../../domain/shared/result.type";
+import { ChatRepositoryPort } from "../../../domain/chat/ports/chat.repository.port";
+
+export type CheckUnreadsError = { kind: "server_error" };
+
+@Injectable({ providedIn: "root" })
+export class CheckUnreadsUseCase {
+  private readonly chatRepository = inject(ChatRepositoryPort);
+
+  execute(): Observable<Result<boolean, CheckUnreadsError>> {
+    return this.chatRepository.hasUnreads().pipe(
+      map(hasUnreads => ok<boolean>(hasUnreads)),
+      catchError(() => of(fail<CheckUnreadsError>({ kind: "server_error" })))
+    );
+  }
+}

projects/social_platform/src/app/api/chat/use-cases/delete-message.use-case.ts

@@ -0,0 +1,14 @@
+/** @format */
+
+import { inject, Injectable } from "@angular/core";
+import { ChatRealtimePort } from "../../../domain/chat/ports/chat-realtime.port";
+import { DeleteChatMessageDto } from "../../../domain/chat/chat.model";
+
+@Injectable({ providedIn: "root" })
+export class DeleteMessageUseCase {
+  private readonly chatRealtime = inject(ChatRealtimePort);
+
+  execute(message: DeleteChatMessageDto): void {
+    this.chatRealtime.deleteMessage(message);
+  }
+}

projects/social_platform/src/app/api/chat/use-cases/edit-message.use-case.ts

@@ -0,0 +1,14 @@
+/** @format */
+
+import { inject, Injectable } from "@angular/core";
+import { ChatRealtimePort } from "../../../domain/chat/ports/chat-realtime.port";
+import { EditChatMessageDto } from "../../../domain/chat/chat.model";
+
+@Injectable({ providedIn: "root" })
+export class EditMessageUseCase {
+  private readonly chatRealtime = inject(ChatRealtimePort);
+
+  execute(message: EditChatMessageDto): void {
+    this.chatRealtime.editMessage(message);
+  }
+}

projects/social_platform/src/app/api/chat/use-cases/load-messages.use-case.ts

@@ -0,0 +1,26 @@
+/** @format */
+
+import { inject, Injectable } from "@angular/core";
+import { catchError, map, Observable, of } from "rxjs";
+import { fail, ok, Result } from "../../../domain/shared/result.type";
+import { ChatRepositoryPort } from "../../../domain/chat/ports/chat.repository.port";
+import { ApiPagination } from "../../../domain/other/api-pagination.model";
+import { ChatMessage } from "../../../domain/chat/chat-message.model";
+
+export type LoadMessagesError = { kind: "server_error" };
+
+@Injectable({ providedIn: "root" })
+export class LoadMessagesUseCase {
+  private readonly chatRepository = inject(ChatRepositoryPort);
+
+  execute(
+    projectId: number,
+    offset?: number,
+    limit?: number
+  ): Observable<Result<ApiPagination<ChatMessage>, LoadMessagesError>> {
+    return this.chatRepository.loadMessages(projectId, offset, limit).pipe(
+      map(page => ok<ApiPagination<ChatMessage>>(page)),
+      catchError(() => of(fail<LoadMessagesError>({ kind: "server_error" })))
+    );
+  }
+}

projects/social_platform/src/app/api/chat/use-cases/load-project-files.use-case.ts

@@ -0,0 +1,21 @@
+/** @format */
+
+import { inject, Injectable } from "@angular/core";
+import { catchError, map, Observable, of } from "rxjs";
+import { fail, ok, Result } from "../../../domain/shared/result.type";
+import { ChatRepositoryPort } from "../../../domain/chat/ports/chat.repository.port";
+import { ChatFile } from "../../../domain/chat/chat-message.model";
+
+export type LoadProjectFilesError = { kind: "server_error" };
+
+@Injectable({ providedIn: "root" })
+export class LoadProjectFilesUseCase {
+  private readonly chatRepository = inject(ChatRepositoryPort);
+
+  execute(projectId: number): Observable<Result<ChatFile[], LoadProjectFilesError>> {
+    return this.chatRepository.loadProjectFiles(projectId).pipe(
+      map(files => ok<ChatFile[]>(files)),
+      catchError(() => of(fail<LoadProjectFilesError>({ kind: "server_error" })))
+    );
+  }
+}

projects/social_platform/src/app/api/chat/use-cases/read-message.use-case.ts

@@ -0,0 +1,14 @@
+/** @format */
+
+import { inject, Injectable } from "@angular/core";
+import { ChatRealtimePort } from "../../../domain/chat/ports/chat-realtime.port";
+import { ReadChatMessageDto } from "../../../domain/chat/chat.model";
+
+@Injectable({ providedIn: "root" })
+export class ReadMessageUseCase {
+  private readonly chatRealtime = inject(ChatRealtimePort);
+
+  execute(message: ReadChatMessageDto): void {
+    this.chatRealtime.readMessage(message);
+  }
+}

projects/social_platform/src/app/api/chat/use-cases/send-message.use-case.ts

@@ -0,0 +1,14 @@
+/** @format */
+
+import { inject, Injectable } from "@angular/core";
+import { ChatRealtimePort } from "../../../domain/chat/ports/chat-realtime.port";
+import { SendChatMessageDto } from "../../../domain/chat/chat.model";
+
+@Injectable({ providedIn: "root" })
+export class SendMessageUseCase {
+  private readonly chatRealtime = inject(ChatRealtimePort);
+
+  execute(message: SendChatMessageDto): void {
+    this.chatRealtime.sendMessage(message);
+  }
+}

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

@@ -15,21 +15,21 @@ import {
   throttleTime,
 } from "rxjs";
 import { FeedItem, FeedItemType } from "../../../domain/feed/feed-item.model";
-import { ApiPagination } from "projects/skills/src/models/api-pagination.model";
+import { ApiPagination } from "../../../domain/other/api-pagination.model";
 import { FeedUIInfoService } from "./ui/feed-ui-info.service";
-import { FeedHttpAdapter } from "../../../infrastructure/adapters/feed/feed-http.adapter";
-import { ProjectNewsRepository } from "../../../infrastructure/repository/project/project-news.repository";
-import { ProfileNewsRepository } from "../../../infrastructure/repository/profile/profile-news.repository";
+import { FetchFeedUseCase } from "../use-cases/fetch-feed.use-case";
+import { ReadFeedNewsUseCase } from "../use-cases/read-feed-news.use-case";
+import { ToggleFeedLikeUseCase } from "../use-cases/toggle-feed-like.use-case";
 
 const DEFAULT_FEED_TYPES: FeedItemType[] = ["vacancy", "project", "news"];
 const FILTER_SPLIT_SYMBOL = "|";
 
 @Injectable()
 export class FeedInfoService {
   private readonly route = inject(ActivatedRoute);
-  private readonly projectNewsRepository = inject(ProjectNewsRepository);
-  private readonly profileNewsRepository = inject(ProfileNewsRepository);
-  private readonly feedHttpAdapter = inject(FeedHttpAdapter);
+  private readonly fetchFeedUseCase = inject(FetchFeedUseCase);
+  private readonly readFeedNewsUseCase = inject(ReadFeedNewsUseCase);
+  private readonly toggleFeedLikeUseCase = inject(ToggleFeedLikeUseCase);
   private readonly feedUIInfoService = inject(FeedUIInfoService);
 
   private observer?: IntersectionObserver;
@@ -147,11 +147,11 @@ export class FeedInfoService {
         ? DEFAULT_FEED_TYPES.join(FILTER_SPLIT_SYMBOL)
         : includes.join(FILTER_SPLIT_SYMBOL);
 
-    return this.feedHttpAdapter.fetchFeed(offset, limit, type).pipe(
-      tap(res => {
-        this.feedUIInfoService.totalItemsCount.set(res.count);
+    return this.fetchFeedUseCase.execute(offset, limit, type).pipe(
+      tap(result => {
+        this.feedUIInfoService.totalItemsCount.set(result.ok ? result.value.count : 0);
       }),
-      map(res => res.results)
+      map(result => (result.ok ? result.value.results : []))
     );
   }
 
@@ -172,16 +172,16 @@ export class FeedInfoService {
 
     projectNews.forEach(news => {
       if (news.typeModel !== "news") return;
-      this.projectNewsRepository
-        .readNews(news.content.contentObject.id, [news.content.id])
+      this.readFeedNewsUseCase
+        .execute("project", news.content.contentObject.id, [news.content.id])
         .pipe(takeUntil(this.destroy$))
         .subscribe();
     });
 
     profileNews.forEach(news => {
       if (news.typeModel !== "news") return;
-      this.projectNewsRepository
-        .readNews(news.content.contentObject.id, [news.content.id])
+      this.readFeedNewsUseCase
+        .execute("profile", news.content.contentObject.id, [news.content.id])
         .pipe(takeUntil(this.destroy$))
         .subscribe();
     });
@@ -194,25 +194,31 @@ export class FeedInfoService {
     if (!item || item.typeModel !== "news") return;
 
     if ("email" in item.content.contentObject) {
-      this.profileNewsRepository
-        .toggleLike(
+      this.toggleFeedLikeUseCase
+        .execute(
+          "profile",
           item.content.contentObject.id as unknown as string,
           newsId,
           !item.content.isUserLiked
         )
         .pipe(takeUntil(this.destroy$))
-        .subscribe(() => {
+        .subscribe(result => {
+          if (!result.ok) return;
+
           this.feedUIInfoService.applyLikeNews(itemIdx);
         });
     } else if ("leader" in item.content.contentObject) {
-      this.projectNewsRepository
-        .toggleLike(
+      this.toggleFeedLikeUseCase
+        .execute(
+          "project",
           item.content.contentObject.id as unknown as string,
           newsId,
           !item.content.isUserLiked
         )
         .pipe(takeUntil(this.destroy$))
-        .subscribe(() => {
+        .subscribe(result => {
+          if (!result.ok) return;
+
           this.feedUIInfoService.applyLikeNews(itemIdx);
         });
     }

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

@@ -1,7 +1,7 @@
 /** @format */
 
 import { Injectable, signal } from "@angular/core";
-import { ApiPagination } from "projects/skills/src/models/api-pagination.model";
+import { ApiPagination } from "projects/social_platform/src/app/domain/other/api-pagination.model";
 import { FeedItem } from "projects/social_platform/src/app/domain/feed/feed-item.model";
 
 @Injectable()