fairnesscoop / permacoop

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

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

import {CreateLeaveCommand} from './CreateLeaveRequestCommand';

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

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

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

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

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

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

@CommandHandler(CreateLeaveCommand)

export class CreateLeaveCommandHandler {

  constructor(

    @Inject('ILeaveRepository')

    private readonly leaveRepository: ILeaveRepository,

    private readonly doesLeaveRequestExistForPeriod: DoesLeaveRequestExistForPeriod,

    private readonly doesEventsExistForPeriod: DoesEventsExistForPeriod

  ) {}

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

    const {

      user,

      endDate,

      endsAllDay,

      leaveType,

      startDate,

      startsAllDay,

      comment

    } = command;

    if (

      true ===

      (await this.doesLeaveRequestExistForPeriod.isSatisfiedBy(

        user,

        startDate,

        endDate

      ))

    ) {

      throw new LeaveAlreadyExistForThisPeriodException();

    }

    if (

      true ===

      (await this.doesEventsExistForPeriod.isSatisfiedBy(

        user,

        startDate,

        endDate

      ))

    ) {

      throw new EventsAlreadyExistForThisPeriodException();

    }

    const leave = await this.leaveRepository.save(

      new Leave(

        user,

        leaveType,

        startDate,

        startsAllDay,

        endDate,

        endsAllDay,

        comment

      )

    );

    return leave.getId();

  }

}