Integrate chat persistence

COS301-SE-2023 · Sep 27, 2023 · 134a9d0 · 134a9d0
1 parent 922692f
commit 134a9d0
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 0 deletions.
diff --git a/libs/app/api/src/lib/app-api.ts b/libs/app/api/src/lib/app-api.ts
@@ -24,6 +24,7 @@ import {
   IEventId,
   IGetAllEventCategoriesResponse,
   IGetAllEventsResponse,
+  IGetEventChatMessagesResponse,
   IGetEventDevicePositionResponse,
   IGetEventFloorlayoutImageResponse,
   IGetEventFloorlayoutResponse,
@@ -576,4 +577,19 @@ export class AppApiService {
       return response;
     });
   }
+
+  async getEventChats(eventId: string) : Promise<IGetEventChatMessagesResponse> {
+    return firstValueFrom(
+      this.http.get<IGetEventChatMessagesResponse>(
+        `/api/event/getEventChats?eventId=${eventId}`,
+        {
+          headers: {
+            'x-csrf-token': this.cookieService.get('csrf'),
+          },
+        }
+      )
+    ).then((response) => {
+      return response;
+    });
+  }
 }
diff --git a/libs/app/components/src/lib/streaming/streaming.component.ts b/libs/app/components/src/lib/streaming/streaming.component.ts
@@ -87,6 +87,9 @@ export class StreamingComponent implements OnInit, AfterViewInit {
   }
 
   async ngAfterViewInit() {
+    this.appApiService.getEventChats(this.eventID).then((data) => {
+      this.eventMessages = data.messages;
+    });
     this.consumer_component.eventID = this.eventID;
     await this.consumer_component.connect();
     this.socket = this.consumer_component.socket;