fairnesscoop / permacoop

import { Inject } from '@nestjs/common';

import { CommandHandler } from '@nestjs/cqrs';

import { CreateLeaveRequestCommand } from './CreateLeaveRequestCommand';

import { ILeaveRequestRepository } from 'src/Domain/HumanResource/Leave/Repository/ILeaveRequestRepository';

import { LeaveRequest } from 'src/Domain/HumanResource/Leave/LeaveRequest.entity';

import { DoesLeaveRequestExistForPeriod } from 'src/Domain/HumanResource/Leave/Specification/DoesLeaveRequestExistForPeriod';

import { LeaveRequestAlreadyExistForThisPeriodException } from 'src/Domain/HumanResource/Leave/Exception/LeaveRequestAlreadyExistForThisPeriodException';

import { DoesEventsExistForPeriod } from 'src/Domain/FairCalendar/Specification/DoesEventsExistForPeriod';

import { EventsAlreadyExistForThisPeriodException } from 'src/Domain/FairCalendar/Exception/EventsAlreadyExistForThisPeriodException';

@CommandHandler(CreateLeaveRequestCommand)

export class CreateLeaveRequestCommandHandler {

  constructor(

    @Inject('ILeaveRequestRepository')

    private readonly leaveRequestRepository: ILeaveRequestRepository,

    private readonly doesLeaveRequestExistForPeriod: DoesLeaveRequestExistForPeriod,

    private readonly doesEventsExistForPeriod: DoesEventsExistForPeriod

  ) {}

  public async execute(command: CreateLeaveRequestCommand): Promise<string> {

    const {

      user,

      endDate,

      endsAllDay,

      type,

      startDate,

      startsAllDay,

      comment

    } = command;

    if (

      true ===

      (await this.doesLeaveRequestExistForPeriod.isSatisfiedBy(

        user,

        startDate,

        endDate

      ))

    ) {

      throw new LeaveRequestAlreadyExistForThisPeriodException();

    }

    if (

      true ===

      (await this.doesEventsExistForPeriod.isSatisfiedBy(

        user,

        startDate,

        endDate

      ))

    ) {

      throw new EventsAlreadyExistForThisPeriodException();

    }

    const leaveRequest = await this.leaveRequestRepository.save(

      new LeaveRequest(

        user,

        type,

        startDate,

        startsAllDay,

        endDate,

        endsAllDay,

        comment

      )

    );

    return leaveRequest.getId();

  }

}