fairnesscoop / permacoop

@CommandHandler(DeleteActivityCommand)

export class DeleteActivityCommandHandler {

  constructor(

    @Inject('IActivityRepository')

    private readonly activityRepository: IActivityRepository

  ) {}

  public async execute(command: DeleteActivityCommand): Promise<void> {

    const {activityId, user} = command;

    const activity = await this.activityRepository.findOneById(activityId);

    if (!(activity instanceof Activity)) {

      throw new ActivityNotFoundException();

    }

    if (activity.getUser().getId() !== user.getId()) {

      throw new NotActivityOwnerException();

    }

    this.activityRepository.deleteById(activityId);