fairnesscoop / permacoop

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

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

import { CreateTaskCommand } from './CreateTaskCommand';

import { ITaskRepository } from 'src/Domain/Task/Repository/ITaskRepository';

import { IsTaskAlreadyExist } from 'src/Domain/Task/Specification/IsTaskAlreadyExist';

import { TaskAlreadyExistException } from 'src/Domain/Task/Exception/TaskAlreadyExistException';

import { Task } from 'src/Domain/Task/Task.entity';

@CommandHandler(CreateTaskCommand)

export class CreateTaskCommandHandler {

  constructor(

    @Inject('ITaskRepository')

    private readonly taskRepository: ITaskRepository,

    private readonly isTaskAlreadyExist: IsTaskAlreadyExist

  ) {}

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

    const { name } = command;

    if (true === (await this.isTaskAlreadyExist.isSatisfiedBy(name))) {

      throw new TaskAlreadyExistException();

    }

    const task = await this.taskRepository.save(new Task(name));

    return task.getId();

  }

}