get chat secction usecase added

server/src/domain/interface/repositories/IVideoSectionRepository.ts

@@ -6,9 +6,8 @@ export interface IVideoSectionRepository {
   update(id: string, videoSection: IVideoSection): Promise<IVideoSection | null>;
   delete(id: string): Promise<void>;
   findByAppointmentId(appointmentId: string): Promise<IVideoSection | null>;
-  findByStartTime(startTime: Date): Promise<IVideoSection | null>;
-  findByEndTime(endTime: Date): Promise<IVideoSection | null>;
   findByStatus(status: VideoSectionStatus): Promise<IVideoSection | null>;
+  findByStartTimeRange(startTime: string, endTime: string): Promise<IVideoSection[] | null>;
 }
 
 

server/src/infrastructure/repositories/VideoSectionRepository.ts

@@ -25,12 +25,10 @@ export default class VideoSectionRepository implements IVideoSectionRepository {
         return await this.model.findOne({ appointmentId });
     }
 
-    async findByStartTime(startTime: Date): Promise<IVideoSection | null> {
-        return await this.model.findOne({ startTime });
-    }
-
-    async findByEndTime(endTime: Date): Promise<IVideoSection | null> {
-        return await this.model.findOne({ endTime });
+    async findByStartTimeRange(startTime: string, endTime: string): Promise<IVideoSection[] | null> {
+        return await this.model.find({
+            startTime: { $gte: startTime, $lte: endTime }
+        });
     }
 
     async findByStatus(status: VideoSectionStatus): Promise<IVideoSection | null> {

server/src/use_case/video/GetVideoSectionUseCase.ts

@@ -0,0 +1,31 @@
+import IVideoSection from "../../domain/entities/IVideoChatSection";
+// import IAppointmentRepository from "../../domain/interface/repositories/IAppointmentRepository";
+import { IVideoSectionRepository } from "../../domain/interface/repositories/IVideoSectionRepository";
+import IValidatorService from "../../domain/interface/services/IValidatorService";
+
+export default class GetVideoSectionUseCase {
+    constructor(
+        private readonly videoSectionRepository: IVideoSectionRepository,
+        private readonly validatorService: IValidatorService
+        // private readonly appointmentRepository: IAppointmentRepository
+    ) { }
+
+    async getSectionById(id: string): Promise<IVideoSection | null> {
+        this.validatorService.validateIdFormat(id)
+        return await this.videoSectionRepository.findById(id);
+    }
+
+    async getSectionByAppointmentId(appointmentId: string): Promise<IVideoSection | null> {
+        this.validatorService.validateIdFormat(appointmentId)
+        return await this.videoSectionRepository.findByAppointmentId(appointmentId);
+    }
+
+    async getSectionsInOneHour(): Promise<IVideoSection[] | []> {
+        const currentTime = new Date();
+        const afterOneHour = new Date(currentTime.getTime() + 60 * 60 * 1000);
+        const sections = await this.videoSectionRepository.findByStartTimeRange(currentTime.toISOString(), afterOneHour.toISOString());
+        return sections ?? [];
+    }
+
+
+}